package com.iailab.module.data.http.service.impl;

import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.core.toolkit.StringUtils;
import com.iailab.module.data.common.enums.CommonConstant;
import com.iailab.framework.common.service.impl.BaseServiceImpl;
import com.iailab.module.data.common.utils.HttpsRequest;
import com.iailab.module.data.common.utils.PageUtils;
import com.iailab.module.data.common.utils.Query;
import com.iailab.module.data.http.dao.HttpTagDao;
import com.iailab.module.data.http.dto.*;
import com.iailab.module.data.http.entity.HttpApiEntity;
import com.iailab.module.data.http.entity.HttpTagEntity;
import com.iailab.module.data.http.service.HttpApiService;
import com.iailab.module.data.http.service.HttpTagService;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.ObjectUtils;
import javax.annotation.Resource;
import org.springframework.stereotype.Service;

import java.lang.reflect.Field;
import java.math.BigDecimal;
import java.util.*;

/**
 * @author Houzhongjian
 * @Description
 * @createTime 2024年04月10日 17:35:00
 */
@Slf4j
@Service
public class HttpTagServiceImpl extends BaseServiceImpl<HttpTagDao, HttpTagEntity> implements HttpTagService {

    @Resource
    private HttpsRequest httpsRequest;

    @Resource
    private HttpApiService httpApiService;


    /**
     * 分页查询tag
     *
     * @param params
     */
    @Override
    public PageUtils queryPage(Map<String, Object> params) {
        String httpApiCode = (String) params.get("httpApiCode");
        String tagType = (String) params.get("tagType");
        String tagCode = (String) params.get("tagCode");
        String tagName = (String) params.get("tagName");

        IPage<HttpTagEntity> page = baseDao.selectPage(
                new Query<HttpTagEntity>().getPage(params),
                new QueryWrapper<HttpTagEntity>()
                        .like(StringUtils.isNotBlank(httpApiCode), "http_api_code", httpApiCode)
                        .like(StringUtils.isNotBlank(tagType), "tag_type", tagType)
                        .like(StringUtils.isNotBlank(tagCode), "tag_code", tagCode)
                        .like(StringUtils.isNotBlank(tagName), "tag_name", tagName)
                        .orderByDesc("create_time")
        );
        return new PageUtils(page);
    }

    @Override
    public List<HttpTagEntity> selectList(Map<String, Object> params) {
        String httpId = (String) params.get("httpId");
        HttpApiEntity httpApiEntity = httpApiService.selectById(httpId);
        return baseDao.selectList(new QueryWrapper<HttpTagEntity>()
                        .eq("http_api_code", httpApiEntity.getCode())
                        .orderByDesc("create_time"));
    }

    @Override
    public List<HttpTagEntity> getByCode(String code) {
        return baseDao.selectList(new QueryWrapper<HttpTagEntity>()
                .eq("http_api_code", code)
                .orderByDesc("create_time"));
    }

    @Override
    public List<String> getByTagType(String deviceId) {
        QueryWrapper<HttpTagEntity> queryWrapper = new QueryWrapper<>();
        queryWrapper.eq("tag_type", deviceId);
        List<HttpTagEntity> entityList = baseDao.selectList(queryWrapper);
        List<String> list = new ArrayList<>();
        if(ObjectUtils.isNotEmpty(entityList)) {
            entityList.stream().forEach(entity -> {
                String tagCode = entity.getTagCode();
                list.add(tagCode);
            });
        }
        return list;
    }

    @Override
    public List<HttpTagDTO> list(Map<String, Object> params) {
        List<HttpTagDTO> list = baseDao.getList(params);
        return list;
    }

    @Override
    public Map<String, BigDecimal> getTagsValues(String httpApiCode, List<TagCommonCurrentDto> tags) {
        Map<String, BigDecimal> stringBigDecimalMap = new HashMap<>();
        if (CommonConstant.YEAR_PEI_HTTP_TAG.equals(httpApiCode)) {
            stringBigDecimalMap = yearPeiTagsValues(tags);
        } else if(CommonConstant.CURRENT_PERFORMANCE_HTTP_TAG.equals(httpApiCode)) {
            stringBigDecimalMap = currentPerformanceTagsValues(tags);
        } else if(CommonConstant.CURRENT_SALE_HTTP_TAG.equals(httpApiCode)) {
            stringBigDecimalMap = currentSaleTagsValues(tags);
        } else if(CommonConstant.PRD_TIME_DIST_HTTP_TAG.equals(httpApiCode)) {
            stringBigDecimalMap = prdTimeDistTagsValues(tags);
        }
        return stringBigDecimalMap;
    }

    private Map<String, BigDecimal> yearPeiTagsValues(List<TagCommonCurrentDto> tags) {
        Map<String, BigDecimal> result = new HashMap<>(tags.size());
        Calendar calendar = Calendar.getInstance();
        int currentMonth = calendar.get(Calendar.MONTH) + 1;
//        String url = httpApiService.getByCode(API_CODE).getUrl();
//        String responseStr = httpsRequest.doGet(url, params,"utf-8", "");
        String url = "http://192.168.55.121/Sunny/Action/BdApi/Invoke?code=Prd.YearPEI";
        String responseStr = "{\"sta\":true,\"msg\":null,\"res\":{\"yearData\":{\"year\":2024,\"xxPlan\":21850000.00,\"xxPerformance\":6794492.00,\"zqPlan\":12500000.00,\"zqPerformance\":3149110.41},\"monthData\":[{\"month\":1,\"xxPlan\":1400000.00,\"xxPerformance\":2022725.00,\"zqPlan\":800000.00,\"zqPerformance\":955066.76},{\"month\":2,\"xxPlan\":1400000.00,\"xxPerformance\":1829671.00,\"zqPlan\":800000.00,\"zqPerformance\":809494.02},{\"month\":3,\"xxPlan\":1700000.00,\"xxPerformance\":2225923.00,\"zqPlan\":1000000.00,\"zqPerformance\":971406.22},{\"month\":4,\"xxPlan\":1620000.00,\"xxPerformance\":716173.00,\"zqPlan\":1000000.00,\"zqPerformance\":345324.75},{\"month\":5,\"xxPlan\":0.0,\"xxPerformance\":0.00,\"zqPlan\":0.0,\"zqPerformance\":0.0},{\"month\":6,\"xxPlan\":0.0,\"xxPerformance\":0.0,\"zqPlan\":0.0,\"zqPerformance\":0.0},{\"month\":7,\"xxPlan\":0.0,\"xxPerformance\":0.0,\"zqPlan\":0.0,\"zqPerformance\":0.0},{\"month\":8,\"xxPlan\":0.0,\"xxPerformance\":0.0,\"zqPlan\":0.0,\"zqPerformance\":0.0},{\"month\":9,\"xxPlan\":0.0,\"xxPerformance\":0.0,\"zqPlan\":0.0,\"zqPerformance\":0.0},{\"month\":10,\"xxPlan\":0.0,\"xxPerformance\":0.0,\"zqPlan\":0.0,\"zqPerformance\":0.0},{\"month\":11,\"xxPlan\":0.0,\"xxPerformance\":0.0,\"zqPlan\":0.0,\"zqPerformance\":0.0},{\"month\":12,\"xxPlan\":0.0,\"xxPerformance\":0.0,\"zqPlan\":0.0,\"zqPerformance\":0.0}]}}";
        if (StringUtils.isNotBlank(responseStr)) {
            TagYearPeiJsonDto yearPeiJsonDto = parseYearPeiDto(responseStr);
            tags.stream().forEach(
                    item -> {
                        String tagType = item.getTagType();
                        String tagCode = item.getTagCode().split(CommonConstant.UNDERLINE)[1];
                        TagYearPeiJsonDto.DATA res = yearPeiJsonDto.getRes();
                        TagYearPeiJsonDto.DATA.YEAR yearData = res.getYearData();
                        List<TagYearPeiJsonDto.DATA.MONTH> monthDataList = res.getMonthData();
                        TagYearPeiJsonDto.DATA.MONTH month = monthDataList.get(currentMonth - 1);
                        Class<?> yearPeiClass = res.getClass();
                        String name = yearPeiClass.getName();
                        try {
                            BigDecimal value;
                            Class<?> yearPeiTypeClass1 = Class.forName(name + CommonConstant.DOLLAR + tagType.toUpperCase());
                            Field field = yearPeiTypeClass1.getDeclaredField(tagCode);
                            field.setAccessible(true);
                            if(CommonConstant.YEAR.equals(tagType)){
                                value = new BigDecimal((String) field.get(yearData));
                                result.put(item.getTagCode(), value);
                            } else if(CommonConstant.MONTH.equals(tagType)){
                                value = new BigDecimal((String) field.get(month));
                                result.put(item.getTagCode(), value);
                            }
                        } catch (NoSuchFieldException e) {
                            log.info("没有找到tag" + item.getTagType() + ";" + item.getTagCode());
                        } catch (IllegalAccessException e) {
                            log.info("没有反射权限");
                        } catch (ClassNotFoundException e) {
                            throw new RuntimeException(e);
                        }
                    }
            );
        }
        return result;
    }

    private Map<String, BigDecimal> currentPerformanceTagsValues(List<TagCommonCurrentDto> tags) {
        Map<String, BigDecimal> result = new HashMap<>(tags.size());
        Map<String, String> params = new HashMap<>(2);
//        String url = httpApiService.getByCode(API_CODE).getUrl();
//        String responseStr = httpsRequest.doGet(url, params,"utf-8", "");
        String responseStr = "{\"sta\":true,\"msg\":null,\"res\":{\"today\":{\"xxPerformance\":30866.00,\"zqPerformance\":0.0},\"yesterday\":{\"xxPerformance\":65748.00,\"zqPerformance\":36263.20},\"currentMonth\":{\"xxPerformance\":716173.00,\"zqPerformance\":345324.75},\"currentYear\":{\"xxPerformance\":6794492.00,\"zqPerformance\":3149110.41}}}";
        if (StringUtils.isNotBlank(responseStr)) {
            TagCurrentPerformanceJsonDto currentPerformanceJsonDto = parseCurrentPerformanceDto(responseStr);
            tags.stream().forEach(
                    item -> {
                        String tagType = item.getTagType();
                        String tagCode = item.getTagCode().split(CommonConstant.UNDERLINE)[1];
                        Class<?> currentPerformanceClass = currentPerformanceJsonDto.getRes().getClass();
                        String name = currentPerformanceClass.getName();
                        try {
                            Field declaredField = currentPerformanceClass.getDeclaredField(tagType);
                            Class<?> typeClass = Class.forName(name + CommonConstant.DOLLAR + tagType.toUpperCase());
                            Field field = typeClass.getDeclaredField(tagCode);
                            field.setAccessible(true);
                            declaredField.setAccessible(true);
                            BigDecimal value = new BigDecimal((String) field.get(declaredField.get(currentPerformanceJsonDto.getRes())));
                            result.put(item.getTagCode(), value);
                        } catch (NoSuchFieldException e) {
                            log.info("没有找到tag" + item.getTagType() + ";" + item.getTagCode());
                        } catch (IllegalAccessException e) {
                            log.info("没有反射权限");
                        } catch (ClassNotFoundException e) {
                            throw new RuntimeException(e);
                        }
                    }
            );
        }
        return result;
    }

    private Map<String, BigDecimal> currentSaleTagsValues(List<TagCommonCurrentDto> tags) {
        Map<String, BigDecimal> result = new HashMap<>(tags.size());
        Map<String, String> params = new HashMap<>(2);
//        String url = httpApiService.getByCode(API_CODE).getUrl();
//        String responseStr = httpsRequest.doGet(url, params,"utf-8", "");
        String responseStr = "{\"sta\":true,\"msg\":null,\"res\":{\"today\":{\"groundsales\":0.0,\"medblock\":0.0,\"nubmeasure\":0.0,\"gangue\":0.0,\"reshipped\":0.0,\"trainTon\":0.0,\"trainCount\":0},\"yesterday\":{\"groundsales\":15696.00,\"medblock\":14757.00,\"nubmeasure\":0.00,\"gangue\":4384.00,\"reshipped\":2447.00,\"trainTon\":36263.20,\"trainCount\":10},\"currentMonth\":{\"groundsales\":0.0,\"medblock\":0.0,\"nubmeasure\":0.0,\"gangue\":0.0,\"reshipped\":0.0,\"trainTon\":0.0,\"trainCount\":0},\"currentYear\":{\"groundsales\":521638.00,\"medblock\":266372.00,\"nubmeasure\":0.00,\"gangue\":143475.00,\"reshipped\":139695.00,\"trainTon\":0.0,\"trainCount\":0}}}";
        if (StringUtils.isNotBlank(responseStr)) {
            TagCurrentSaleJsonDto currentPerformanceJsonDto = parseCurrentSaleDto(responseStr);
            tags.stream().forEach(
                    item -> {
                        String tagType = item.getTagType();
                        String tagCode = item.getTagCode().split(CommonConstant.UNDERLINE)[1];
                        Class<?> currentSaleClass = currentPerformanceJsonDto.getRes().getClass();
                        String name = currentSaleClass.getName();
                        try {
                            Field declaredField = currentSaleClass.getDeclaredField(tagType);
                            Class<?> typeClass = Class.forName(name + CommonConstant.DOLLAR + tagType.toUpperCase());
                            Field field = typeClass.getDeclaredField(tagCode);
                            field.setAccessible(true);
                            declaredField.setAccessible(true);
                            BigDecimal value = new BigDecimal((String) field.get(declaredField.get(currentPerformanceJsonDto.getRes())));
                            result.put(item.getTagCode(), value);
                        } catch (NoSuchFieldException e) {
                            log.info("没有找到tag" + item.getTagType() + ";" + item.getTagCode());
                        } catch (IllegalAccessException e) {
                            log.info("没有反射权限");
                        } catch (ClassNotFoundException e) {
                            throw new RuntimeException(e);
                        }
                    }
            );
        }
        return result;
    }

    private Map<String, BigDecimal> prdTimeDistTagsValues(List<TagCommonCurrentDto> tags) {
        Map<String, BigDecimal> result = new HashMap<>(tags.size());
        Map<String, String> params = new HashMap<>(2);
//        String url = httpApiService.getByCode(API_CODE).getUrl();
//        String responseStr = httpsRequest.doGet(url, params,"utf-8", "");
        String responseStr = "{\"sta\":true,\"msg\":null,\"res\":{\"xx\":{\"runMinutes\":1120.0,\"overhaulMinutes\":305.0,\"affectMinutes\":15.0},\"zq\":{\"runMinutes\":645.0,\"overhaulMinutes\":223.0,\"affectMinutes\":572.0}}}";
        if (StringUtils.isNotBlank(responseStr)) {
            TagPrdTimeDistJsonDto prdTimeDistJsonDto = parsePrdTimeDistDto(responseStr);
            tags.stream().forEach(
                    item -> {
                        String tagType = item.getTagType();
                        String tagCode = item.getTagCode().split(CommonConstant.UNDERLINE)[1];
                        Class<?> prdTimeDistClass = prdTimeDistJsonDto.getRes().getClass();
                        String name = prdTimeDistClass.getName();
                        try {
                            Field declaredField = prdTimeDistClass.getDeclaredField(tagType);
                            Class<?> typeClass = Class.forName(name + CommonConstant.DOLLAR + tagType.toUpperCase());
                            Field field = typeClass.getDeclaredField(tagCode);
                            field.setAccessible(true);
                            declaredField.setAccessible(true);
                            BigDecimal value = new BigDecimal((String) field.get(declaredField.get(prdTimeDistJsonDto.getRes())));
                            result.put(item.getTagCode(), value);
                        } catch (NoSuchFieldException e) {
                            log.info("没有找到tag" + item.getTagType() + ";" + item.getTagCode());
                        } catch (IllegalAccessException e) {
                            log.info("没有反射权限");
                        } catch (ClassNotFoundException e) {
                            throw new RuntimeException(e);
                        }
                    }
            );
        }
        return result;
    }

    private TagYearPeiJsonDto parseYearPeiDto(String responseStr) {
        TagYearPeiJsonDto result = new TagYearPeiJsonDto();
        if (!StringUtils.isEmpty(responseStr)) {
            JSONObject items = JSONObject.parseObject(responseStr);
            result = items.toJavaObject(TagYearPeiJsonDto.class);
        }
        return result;
    }

    private TagCurrentPerformanceJsonDto parseCurrentPerformanceDto(String responseStr) {
        TagCurrentPerformanceJsonDto result = new TagCurrentPerformanceJsonDto();
        if (!StringUtils.isEmpty(responseStr)) {
            JSONObject items = JSONObject.parseObject(responseStr);
            result = items.toJavaObject(TagCurrentPerformanceJsonDto.class);
        }
        return result;
    }

    private TagCurrentSaleJsonDto parseCurrentSaleDto(String responseStr) {
        TagCurrentSaleJsonDto result = new TagCurrentSaleJsonDto();
        if (!StringUtils.isEmpty(responseStr)) {
            JSONObject items = JSONObject.parseObject(responseStr);
            result = items.toJavaObject(TagCurrentSaleJsonDto.class);
        }
        return result;
    }

    private TagPrdTimeDistJsonDto parsePrdTimeDistDto(String responseStr) {
        TagPrdTimeDistJsonDto result = new TagPrdTimeDistJsonDto();
        if (!StringUtils.isEmpty(responseStr)) {
            JSONObject items = JSONObject.parseObject(responseStr);
            result = items.toJavaObject(TagPrdTimeDistJsonDto.class);
        }
        return result;
    }
}