package com.iailab.module.ansteel.job.task;

import com.iailab.framework.common.util.date.DateUtils;
import com.iailab.module.ansteel.api.entity.CokingProcessConfEntity;
import com.iailab.module.ansteel.api.entity.CokingProcessMainEntity;
import com.iailab.module.ansteel.api.service.CokingProcessConfService;
import com.iailab.module.ansteel.api.service.CokingProcessMainService;
import com.iailab.module.ansteel.common.enums.ProcessConfDataTypeEnum;
import com.iailab.module.ansteel.common.enums.ProcessIndDataTypeEnum;
import com.iailab.module.data.api.ind.IndItemApi;
import com.iailab.module.data.api.ind.dto.ApiIndItemValueDTO;
import com.iailab.module.data.api.point.DataPointApi;
import org.apache.commons.lang3.ObjectUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;
import org.springframework.util.CollectionUtils;

import javax.annotation.Resource;
import java.util.*;
import java.util.concurrent.atomic.AtomicReference;
import java.util.stream.Collectors;

/**
 * @author HouZhongjian
 * @Description
 * @createTime 2025年04月12日
 */
@Component("runCokingMainDayTask")
public class RunCokingMainDayTask implements ITask {

    private Logger logger = LoggerFactory.getLogger(getClass());

    @Resource
    private CokingProcessConfService cokingProcessConfService;

    @Resource
    private CokingProcessMainService cokingProcessMainService;

    @Resource
    private DataPointApi dataPointApi;

    @Resource
    private IndItemApi indItemApi;

    @Override
    public void run(String params) {
        logger.info("RunCokingMainDayTask，参数为：{}", params);
        try {
            Calendar calendar = Calendar.getInstance();
            calendar.set(Calendar.MILLISECOND, 0);
            calendar.set(Calendar.SECOND, 0);
            calendar.add(Calendar.DAY_OF_YEAR, -1);
            String clock = DateUtils.format(calendar.getTime(), DateUtils.FORMAT_YEAR_MONTH_DAY);
            CokingProcessConfEntity queryParams = new CokingProcessConfEntity();
            queryParams.setIndType("main");
            List<CokingProcessConfEntity> list = cokingProcessConfService.list(queryParams);
            if (CollectionUtils.isEmpty(list)) {
                logger.info("ConfLis is Empty");
                return;
            }
            // 先建立ext1到sort的映射关系
            Map<String, Integer> ext1ToSort = list.stream()
                    .collect(Collectors.toMap(
                            CokingProcessConfEntity::getExt1,
                            CokingProcessConfEntity::getSort,
                            (oldValue, newValue) -> oldValue));

            // 然后按这个关系排序分组
            Map<String, List<CokingProcessConfEntity>> groupMap = list.stream()
                    .sorted(Comparator.comparing(CokingProcessConfEntity::getSort))
                    .collect(Collectors.collectingAndThen(
                            Collectors.groupingBy(CokingProcessConfEntity::getExt1),
                            map -> map.entrySet().stream()
                                    .sorted(Comparator.comparingInt(
                                            e -> ext1ToSort.get(e.getKey())))  // 按ext1对应的sort值排序
                                    .collect(Collectors.toMap(
                                            Map.Entry::getKey,
                                            Map.Entry::getValue,
                                            (a, b) -> a,
                                            LinkedHashMap::new))));

            logger.info("清理旧数据");
            cokingProcessMainService.deleteByClock(clock);

            //计数器
            AtomicReference<Integer> counter = new AtomicReference<>(1);
            groupMap.forEach((group, confList) -> {
                CokingProcessMainEntity cokingProcessMainEntity = new CokingProcessMainEntity();
                cokingProcessMainEntity.setInfoType("0");
                cokingProcessMainEntity.setSort(counter.getAndSet(counter.get() + 1));
                cokingProcessMainEntity.setCategory("day");
                CokingProcessConfEntity cokingProcessConfEntity = confList.get(0);
                cokingProcessMainEntity.setIndName(cokingProcessConfEntity.getExt3());
                cokingProcessMainEntity.setClock(clock);
                confList.forEach(conf -> {
                    String value = "";
                    switch (ProcessConfDataTypeEnum.getEumByCode(conf.getDataType())) {
                        case DATAPOINT:
                            List<String> points = new ArrayList<>();
                            points.add(conf.getPointNo());
                            Map<String, Object> pointsRealValue = dataPointApi.queryPointsRealValue(points);
                            value = pointsRealValue.get(conf.getPointNo()).toString();
                            break;
                        case IND:
                            List<ApiIndItemValueDTO> indValues = indItemApi.queryIndItemDefaultValue(conf.getPointNo());
                            if (!CollectionUtils.isEmpty(indValues)) {
                                value = indValues.get(indValues.size() - 1).getDataValue().toString();
                            }
                            break;
                        default:
                            break;
                    }
                    //保存数据
                    if(ObjectUtils.isNotEmpty(value)) {
                        if(conf.getExt2().equals(ProcessIndDataTypeEnum.LSPJ.getCode())) {
                            cokingProcessMainEntity.setAvgValue(value.toString());
                        } else if(conf.getExt2().equals(ProcessIndDataTypeEnum.LLZ.getCode())) {
                            cokingProcessMainEntity.setTheoryValue(value.toString());
                        } else if(conf.getExt2().equals(ProcessIndDataTypeEnum.SJZ.getCode())) {
                            cokingProcessMainEntity.setActualValue(value.toString());
                        } else if(conf.getExt2().equals(ProcessIndDataTypeEnum.JZZ.getCode())) {
                            cokingProcessMainEntity.setStandValue(value.toString());
                        } else if(conf.getExt2().equals(ProcessIndDataTypeEnum.SSSJ.getCode())) {
                            cokingProcessMainEntity.setRealValue(value.toString());
                        }
                    }
                });
                cokingProcessMainService.save(cokingProcessMainEntity);
            });

        } catch (Exception ex) {
            logger.error("RunCokingMainDayTask运行异常");
            ex.printStackTrace();
        }
        logger.info("RunCokingMainDayTask运行完成");

    }
}