package com.qianwen.smartman.modules.mdc.service.impl;

import com.alibaba.fastjson.JSON;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.stream.Collectors;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.qianwen.smartman.common.cache.cps.WorkstationCache;
import com.qianwen.smartman.common.utils.CommonUtil;
import com.qianwen.core.tool.utils.DateUtil;
import com.qianwen.core.tool.utils.Func;
import com.qianwen.smartman.modules.cps.message.dto.TelemetryDataResponseDTO;
import com.qianwen.smartman.modules.mdc.constant.CollectConstant;
import com.qianwen.smartman.modules.mdc.dto.NewParamSaveDTO;
import com.qianwen.smartman.modules.mdc.mapper.SuperCollectJsonMapper;
import com.qianwen.smartman.modules.mdc.service.ISuperNewCollectService;
import org.springframework.stereotype.Service;

@Service
public class SuperNewCollectServiceImpl implements ISuperNewCollectService {
    private final SuperCollectJsonMapper collectJsonMapper;
    private static final Logger log = LoggerFactory.getLogger(SuperNewCollectServiceImpl.class);
    private static final Map<Integer, String> PROCESS_PARAM_MAP = new HashMap<>();

    static {
        PROCESS_PARAM_MAP.put(1, "STATE");
        PROCESS_PARAM_MAP.put(2, "OUTPUT");
        PROCESS_PARAM_MAP.put(3, CollectConstant.ALARM);
        PROCESS_PARAM_MAP.put(4, "PROGRAMNUM");
        PROCESS_PARAM_MAP.put(5, "OUTPUT");
        PROCESS_PARAM_MAP.put(6, CollectConstant.ALARM);
        PROCESS_PARAM_MAP.put(7, CollectConstant.ALARM);
    }

    public SuperNewCollectServiceImpl(final SuperCollectJsonMapper collectJsonMapper) {
        this.collectJsonMapper = collectJsonMapper;
    }

    
    @Override
    public void insertData(Set<String> workstationIds) {
        List<NewParamSaveDTO> data = workstationIds.stream().map(workstationId -> {
            Map<String, Object> realTimeData = WorkstationCache.getWorkstationAllCollect(workstationId);//实时数据，
            if (Func.isNotEmpty(realTimeData)) {
                int size = realTimeData.size();
                long time = DateUtil.now().getTime();
                Map<String, String> valuesMap = new HashMap<>(size);
                realTimeData.forEach((n, telemetry) -> {
                    if (!n.toUpperCase().contains(CollectConstant.ALARM)) {//去除ALARM数据
                        TelemetryDataResponseDTO dto = (TelemetryDataResponseDTO) telemetry;
                        String v = dto.getV();
                        if (Func.isNotEmpty(v) && v.length() <= CollectConstant.MAX_VALUE.intValue() && !v.contains("timestamp")) {
                            valuesMap.put(n, v);
                        }
                    }
                });
                String value = JSON.toJSONString(valuesMap);
                log.info("采集参数数据: {}", value);
                return NewParamSaveDTO.builder().value(value).ts(Long.valueOf(time)).workstationId(workstationId).build();
            }
            return null;
        }).filter((v0) -> {
            return Func.notNull(v0);
        }).collect(Collectors.toList());
        List<List<NewParamSaveDTO>> groupList = CommonUtil.groupList(data, 10);
        
        groupList.forEach(this.collectJsonMapper::insertValueJson);
        /*
        SuperCollectJsonMapper superCollectJsonMapper = this.collectJsonMapper;
        superCollectJsonMapper.getClass();
        groupList.forEach(this::insertValueJson);*/
    }
}