package com.jcdm.main.plcserver.callback;
import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.util.StrUtil;
import com.jcdm.common.core.domain.BaseEntity;
import com.jcdm.main.da.collectionParamConf.domain.DaCollectionParamConf;
import com.jcdm.main.da.collectionParamConf.service.IDaCollectionParamConfService;
import com.jcdm.main.da.paramCollection.domain.DaParamCollection;
import com.jcdm.main.da.paramCollection.service.IDaParamCollectionService;
import com.jcdm.main.da.passingStationCollection.service.impl.DaPassingStationCollectionServiceImpl;
import com.jcdm.main.da.tileMatchRules.service.IDaTileMatchRulesService;
import com.kangaroohy.milo.model.ReadWriteEntity;
import com.kangaroohy.milo.runner.subscription.SubscriptionCallback;
import com.kangaroohy.milo.service.MiloService;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.ObjectUtils;
import org.springframework.stereotype.Component;
import java.util.ArrayList;
import java.util.Comparator;
import java.util.Date;
import java.util.List;
import java.util.stream.Collectors;

@Slf4j
@Component
public class InitCallback implements SubscriptionCallback {

    public static MiloService miloService;

    public IDaCollectionParamConfService collectionParamConfService;

    public IDaParamCollectionService daParamCollectionService;

    public DaPassingStationCollectionServiceImpl passingStationCollectionServiceImpl;

    public IDaTileMatchRulesService daTileMatchRulesService;
    ;

    public InitCallback(MiloService miloService,
                        IDaCollectionParamConfService collectionParamConfService,
                        IDaParamCollectionService daParamCollectionService,
                        DaPassingStationCollectionServiceImpl passingStationCollectionServiceImpl,
                        IDaTileMatchRulesService daTileMatchRulesService) {
        InitCallback.miloService = miloService;
        this.collectionParamConfService = collectionParamConfService;
        this.daParamCollectionService = daParamCollectionService;
        this.passingStationCollectionServiceImpl = passingStationCollectionServiceImpl;
        this.daTileMatchRulesService = daTileMatchRulesService;

    }


    @Override
    public void onSubscribe(String identifier, Object value) {
        String ecpStr = "";//异常记录标记
        try {
            if (null != value) {
                //BCOP010出站校验
                if (identifier.equals("CFL4CVT.BCOP010.RecordData") && null != value && "2".equals(value.toString())) {
                    ReadWriteEntity entity = new ReadWriteEntity("CFL4CVT.BCOP010.MesRecordDataDone", 21);
                    miloService.writeToOpcShort(entity);
                }
                //BCOP40出站校验
                else if (identifier.equals("CFL4CVT.BCOP040.RecordData") && null != value && "2".equals(value.toString())) {
                    SaveData("CFL4CVT.BCOP040.RecordData");
                }
                //BCOP60出站校验
                else if (identifier.equals("CFL4CVT.BCOP060.RecordData") && null != value && "2".equals(value.toString())) {
                    SaveData("CFL4CVT.BCOP060.RecordData");
                }
                //BCOP100出站校验
                else if (identifier.equals("CFL4CVT.BCOP100.RecordData") && null != value && "2".equals(value.toString())) {
                    SaveData("CFL4CVT.BCOP100.RecordData");

                }
                //BP020出站校验
                else if (identifier.equals("CFL4CVT.BP020.RecordData") && null != value && "2".equals(value.toString())) {
                    SaveData("CFL4CVT.BP020.RecordData");
                }
                else if(identifier.equals("CFL4CVT.OP220.RecordData") && null != value && "2".equals(value.toString())) {
                    ReadWriteEntity entity = new ReadWriteEntity("CFL4CVT.OP220.MesRecordDataDone", 21);
                    miloService.writeToOpcShort(entity);
                }

            }
        } catch (Exception e) {

        } finally {
            if (!"".equals(ecpStr)) {
                System.out.println(ecpStr + "\r\n");

            }
        }
    }

//    public void SaveData(String Node) throws Exception {
//        String[] parts = Node.split("[.]");
//        Object SNCodeObject = miloService.readFromOpcUa(parts[0] + "." + parts[1] + ".Code1").getValue();
//
//        if (null != SNCodeObject) {
//            String SNCode = SNCodeObject.toString();
//            List<DaCollectionParamConf> list;
//            DaCollectionParamConf daCollectionParamConf = new DaCollectionParamConf();
//            daCollectionParamConf.setGatherAddress(parts[0] + "." + parts[1]);
//            list = collectionParamConfService.selectDaCollectionParamConfList(daCollectionParamConf);
//
//            List<String> nodeIdList = list.stream().map(info -> {
//                String nodeid = info.getGatherAddress();
//                return nodeid;
//            }).collect(Collectors.toList());
//
//            if (!nodeIdList.isEmpty()) {
//                List<ReadWriteEntity> readWriteEntityList = miloService.readFromOpcUa(nodeIdList);
//                List<DaParamCollection> daParamCollectionlist = new ArrayList<>();
//                for (int i = 0; i < nodeIdList.size(); i++) {
//                    DaParamCollection ParamCollection = new DaParamCollection();
//                    if (!readWriteEntityList.get(i).getValue().toString().equals("0.0")) {
//                        ParamCollection.setParamCode(readWriteEntityList.get(i).getIdentifier().toString().split("[.]")[2]);
//                        ParamCollection.setLocationCode(parts[1]);
//                        Object value = readWriteEntityList.get(i).getValue();
//                        if (ObjectUtils.isNotEmpty(value)) {
//                            String string = value.toString();
//                            ParamCollection.setParamValue(string);
//                        }
//                        ParamCollection.setSfcCode(SNCode);
//                        ParamCollection.setParamName(list.get(i).getCollectParameterName());
//                        ParamCollection.setParamUpper(list.get(i).getParamUpper());
//                        ParamCollection.setParamLower(list.get(i).getParamLower());
//                        ParamCollection.setUnit(list.get(i).getCollectParameterUnit());
//                        ParamCollection.setState("合格");
//                        ParamCollection.setType(list.get(i).getCollectParameterType());
//                        ParamCollection.setCollectionTime(new Date());
//                        daParamCollectionlist.add(ParamCollection);
//                    }
//                }
//                daParamCollectionService.saveBeachDaParamCollection(daParamCollectionlist);
//            }
//        }
//    }

    public void SaveData(String Node) throws Exception {
        String[] parts = Node.split("[.]");
        Object SNCodeObject = miloService.readFromOpcUa(parts[0] + "." + parts[1] + ".RecordData").getValue();
        if(null != SNCodeObject)
        {
            String SNCode = SNCodeObject.toString();
            List<DaCollectionParamConf> list;
            DaCollectionParamConf daCollectionParamConf = new DaCollectionParamConf();
            daCollectionParamConf.setGatherAddress(parts[0] + "." + parts[1]);
            list = collectionParamConfService.selectDaCollectionParamConfList(daCollectionParamConf);

            List<String> nodeIdList = list.stream().map(info -> {
                String nodeid = info.getGatherAddress();
                return nodeid;
            }).collect(Collectors.toList());

            if(!nodeIdList.isEmpty()){
                List<ReadWriteEntity> readWriteEntityList = miloService.readFromOpcUa(nodeIdList);
                List<DaParamCollection> daParamCollectionlist = new ArrayList<>();
                for(int i=0;i<nodeIdList.size();i++){
                    DaParamCollection ParamCollection = new DaParamCollection();
                    if(!readWriteEntityList.get(i).getValue().toString().equals("0.0")){
                        ParamCollection.setParamCode(readWriteEntityList.get(i).getIdentifier().toString().split("[.]")[2]);
                        ParamCollection.setLocationCode(parts[1]);
                        ParamCollection.setParamValue(readWriteEntityList.get(i).getValue().toString());
                        ParamCollection.setSfcCode(SNCode);
                        ParamCollection.setParamName(list.get(i).getCollectParameterName());
                        ParamCollection.setParamUpper(list.get(i).getParamUpper());
                        ParamCollection.setParamLower(list.get(i).getParamLower());
                        ParamCollection.setUnit(list.get(i).getCollectParameterUnit());
                        ParamCollection.setState("合格");
                        ParamCollection.setType(list.get(i).getCollectParameterType());
                        ParamCollection.setCollectionTime(new Date());
                        daParamCollectionlist.add(ParamCollection);
                    }
                }
                daParamCollectionService.saveBeachDaParamCollection(daParamCollectionlist);
                ReadWriteEntity entity = new ReadWriteEntity(parts[0] + "." + parts[1]   +".MesRecordDataDone", 21);
                miloService.writeToOpcShort(entity);
            }
        }
    }


}