package cn.stylefeng.guns.plcserver.init; import cn.stylefeng.guns.modular.bs.collectionParamConf.service.CollectionParamConfService; import cn.stylefeng.guns.modular.bs.equipmentInfo.model.params.EquipmentInfoParam; import cn.stylefeng.guns.modular.bs.equipmentInfo.model.result.EquipmentInfoResult; import cn.stylefeng.guns.modular.bs.equipmentInfo.service.EquipmentInfoService; import cn.stylefeng.guns.modular.bs.locationInfo.service.LocationInfoService; import cn.stylefeng.guns.modular.cm.paramCollection.service.ParamCollectionService; import cn.stylefeng.guns.modular.cm.passingStationCollection.service.PassingStationCollectionService; import cn.stylefeng.guns.modular.dq.materialTraceability.service.MaterialTraceabilityService; import cn.stylefeng.guns.modular.em.equipmentAlarm.service.EquipmentAlarmService; import cn.stylefeng.guns.modular.em.equipmentStatus.service.EquipmentStatusService; import cn.stylefeng.guns.modular.gm.greaseManage.service.GreaseManageService; import cn.stylefeng.guns.modular.om.productionOrdeInfo.service.ProductionOrdeInfoService; import cn.stylefeng.guns.modular.om.productionOrderBatchInfo.service.ProductionOrderBatchInfoService; import cn.stylefeng.guns.modular.om.productionOrderRecords.service.ProductionOrderRecordsService; import cn.stylefeng.guns.modular.sc.repairManageInfo.service.RepairManageInfoService; import cn.stylefeng.guns.modular.sc.serialNumbersConf.service.SerialNumbersConfService; import cn.stylefeng.guns.plcserver.callback.*; import cn.stylefeng.guns.plcserver.opc.GlobalVariable; import cn.stylefeng.guns.plcserver.opc.OPCElement; import cn.stylefeng.guns.plcserver.server.OP010.OP010ServerInterface; import cn.stylefeng.guns.plcserver.server.OP010.impl.OP010ServerInterfaceImpl; import com.kangaroohy.milo.service.MiloService; import lombok.extern.slf4j.Slf4j; import org.openscada.opc.lib.da.Item; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.ApplicationArguments; import org.springframework.boot.ApplicationRunner; import org.springframework.stereotype.Component; import java.util.ArrayList; import java.util.List; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; @Component @Slf4j public class CustomRunner implements ApplicationRunner { @Autowired public MiloService miloService; @Autowired public ProductionOrdeInfoService productionOrdeInfoService; @Autowired public PassingStationCollectionService passingStationCollectionService; @Autowired public ParamCollectionService paramCollectionService; @Autowired public CollectionParamConfService collectionParamConfService; @Autowired public SerialNumbersConfService serialNumbersConfService; @Autowired private EquipmentStatusService equipmentStatusService; @Autowired private EquipmentAlarmService equipmentAlarmService; @Autowired private MaterialTraceabilityService materialTraceabilityService; @Autowired private EquipmentInfoService equipmentInfoService; @Autowired private RepairManageInfoService repairManageInfoService; @Autowired private LocationInfoService locationInfoService; @Autowired private GreaseManageService greaseManageService; @Autowired private ProductionOrderRecordsService productionOrderRecordsService; @Autowired private ProductionOrderBatchInfoService productionOrderBatchInfoService; private List stateLists = null; @Override public void run(ApplicationArguments args) throws Exception { GlobalVariable.PRODUCT_TYPE_MAP.put("12980500000198","1");//C1 36V GlobalVariable.PRODUCT_TYPE_MAP.put("12980500000174","2");//C1 48V GlobalVariable.PRODUCT_TYPE_MAP.put("12980500000194","3");//T1 36V GlobalVariable.PRODUCT_TYPE_MAP.put("12980500000201","4");//T1 48V GlobalVariable.PRODUCT_CODE_MAP.put("1","12980500000198"); GlobalVariable.PRODUCT_CODE_MAP.put("2","12980500000174"); GlobalVariable.PRODUCT_CODE_MAP.put("3","12980500000194"); GlobalVariable.PRODUCT_CODE_MAP.put("4","12980500000201"); EquipmentInfoParam equipmentInfoParam = new EquipmentInfoParam(); List list = equipmentInfoService.findListBySpec(equipmentInfoParam); /* state();*/ init(); /* COP010(); COP020(); COP030(); BOP010(); BOP020(); BOP030(); BOP030B(); BOP040(); BOP040B(); DOP010(); //DOP020(); EOP010(); EOP020(); EOP030(); EOP040(); EOP050(); EOP060(); EOP070(); EOP080(); EOP090(); EOP090B(); OP010(); OP020(); OP030(); OP040(); OP050(); OP070(); OP080(); OP090(); OP100(); OP110(); OP120(); OP120B(); OP130(); OP130B(); OP140(); //OP150(); OP160(); OP170(); state();*/ } private void init() throws Exception { InitCallback InitCallback = new InitCallback(miloService,productionOrdeInfoService, passingStationCollectionService,paramCollectionService,collectionParamConfService,serialNumbersConfService, equipmentStatusService,equipmentAlarmService,materialTraceabilityService,equipmentInfoService, repairManageInfoService,locationInfoService,greaseManageService,productionOrderRecordsService, productionOrderBatchInfoService); List lists = getList(); miloService.subscriptionFromOpcUa(lists,InitCallback); } private void state() throws Exception { StateCallback StateCallback = new StateCallback(miloService,productionOrdeInfoService, passingStationCollectionService,paramCollectionService,collectionParamConfService,serialNumbersConfService, equipmentStatusService,equipmentAlarmService,materialTraceabilityService,equipmentInfoService, repairManageInfoService,locationInfoService,greaseManageService,productionOrderRecordsService, productionOrderBatchInfoService); List lists = new ArrayList<>(); StateCallback.handleInfo(); // handleOilState("DOP020"); StateCallback.handleOilStateOP050("OP050"); StateCallback.handleOilStateBOP030("BOP030"); } private void COP010() throws Exception { COP010Callback COP010Callback = new COP010Callback(miloService,productionOrdeInfoService, passingStationCollectionService,paramCollectionService,collectionParamConfService,serialNumbersConfService, equipmentStatusService,equipmentAlarmService,materialTraceabilityService,equipmentInfoService, repairManageInfoService,locationInfoService,greaseManageService,productionOrderRecordsService, productionOrderBatchInfoService); List lists = new ArrayList<>(); lists.add(OPCElement.COP010_F_HEART_BEAT); lists.add(OPCElement.COP010_J_PLC_START); lists.add(OPCElement.COP010_J_PLC_FINISH); miloService.subscriptionFromOpcUa(lists,COP010Callback); System.out.println("1"); } private void COP020() throws Exception { COP020Callback COP020Callback = new COP020Callback(miloService,productionOrdeInfoService, passingStationCollectionService,paramCollectionService,collectionParamConfService,serialNumbersConfService, equipmentStatusService,equipmentAlarmService,materialTraceabilityService,equipmentInfoService, repairManageInfoService,locationInfoService,greaseManageService,productionOrderRecordsService, productionOrderBatchInfoService); List lists = new ArrayList<>(); lists.add(OPCElement.COP020_F_HEART_BEAT); lists.add(OPCElement.COP020_J_PLC_START); lists.add(OPCElement.COP020_J_PLC_FINISH); miloService.subscriptionFromOpcUa(lists,COP020Callback); } private void COP030() throws Exception { COP030Callback COP030Callback = new COP030Callback(miloService,productionOrdeInfoService, passingStationCollectionService,paramCollectionService,collectionParamConfService,serialNumbersConfService, equipmentStatusService,equipmentAlarmService,materialTraceabilityService,equipmentInfoService, repairManageInfoService,locationInfoService,greaseManageService,productionOrderRecordsService, productionOrderBatchInfoService); List lists = new ArrayList<>(); lists.add(OPCElement.COP030_F_HEART_BEAT); lists.add(OPCElement.COP030_J_PLC_START); lists.add(OPCElement.COP030_J_PLC_FINISH); miloService.subscriptionFromOpcUa(lists,COP030Callback); } private void BOP010() throws Exception { BOP010Callback BOP010Callback = new BOP010Callback(miloService,productionOrdeInfoService, passingStationCollectionService,paramCollectionService,collectionParamConfService,serialNumbersConfService, equipmentStatusService,equipmentAlarmService,materialTraceabilityService,equipmentInfoService, repairManageInfoService,locationInfoService,greaseManageService,productionOrderRecordsService, productionOrderBatchInfoService); List lists = new ArrayList<>(); lists.add(OPCElement.BOP010_F_HEART_BEAT); lists.add(OPCElement.BOP010_J_PLC_START); lists.add(OPCElement.BOP010_J_PLC_FINISH); miloService.subscriptionFromOpcUa(lists,BOP010Callback); } private void BOP020() throws Exception { BOP020Callback BOP020Callback = new BOP020Callback(miloService,productionOrdeInfoService, passingStationCollectionService,paramCollectionService,collectionParamConfService,serialNumbersConfService, equipmentStatusService,equipmentAlarmService,materialTraceabilityService,equipmentInfoService, repairManageInfoService,locationInfoService,greaseManageService,productionOrderRecordsService, productionOrderBatchInfoService); List lists = new ArrayList<>(); lists.add(OPCElement.BOP020_F_HEART_BEAT); lists.add(OPCElement.BOP020_J_PLC_START); lists.add(OPCElement.BOP020_J_PLC_FINISH); miloService.subscriptionFromOpcUa(lists,BOP020Callback); } private void BOP030() throws Exception { BOP030Callback BOP030Callback = new BOP030Callback(miloService,productionOrdeInfoService, passingStationCollectionService,paramCollectionService,collectionParamConfService,serialNumbersConfService, equipmentStatusService,equipmentAlarmService,materialTraceabilityService,equipmentInfoService, repairManageInfoService,locationInfoService,greaseManageService,productionOrderRecordsService, productionOrderBatchInfoService); List lists = new ArrayList<>(); lists.add(OPCElement.BOP030_F_HEART_BEAT); lists.add(OPCElement.BOP030_J_PLC_START); lists.add(OPCElement.BOP030_J_PLC_FINISH); miloService.subscriptionFromOpcUa(lists,BOP030Callback); } private void BOP030B() throws Exception { BOP030BCallback BOP030BCallback = new BOP030BCallback(miloService,productionOrdeInfoService, passingStationCollectionService,paramCollectionService,collectionParamConfService,serialNumbersConfService, equipmentStatusService,equipmentAlarmService,materialTraceabilityService,equipmentInfoService, repairManageInfoService,locationInfoService,greaseManageService,productionOrderRecordsService, productionOrderBatchInfoService); List lists = new ArrayList<>(); lists.add(OPCElement.BOP030B_F_HEART_BEAT); lists.add(OPCElement.BOP030B_J_PLC_START); lists.add(OPCElement.BOP030B_J_PLC_FINISH); miloService.subscriptionFromOpcUa(lists,BOP030BCallback); } private void BOP040() throws Exception { BOP040Callback BOP040Callback = new BOP040Callback(miloService,productionOrdeInfoService, passingStationCollectionService,paramCollectionService,collectionParamConfService,serialNumbersConfService, equipmentStatusService,equipmentAlarmService,materialTraceabilityService,equipmentInfoService, repairManageInfoService,locationInfoService,greaseManageService,productionOrderRecordsService, productionOrderBatchInfoService); List lists = new ArrayList<>(); lists.add(OPCElement.BOP040_F_HEART_BEAT); lists.add(OPCElement.BOP040_J_PLC_START); lists.add(OPCElement.BOP040_J_PLC_FINISH); miloService.subscriptionFromOpcUa(lists,BOP040Callback); } private void BOP040B() throws Exception { BOP040BCallback BOP040BCallback = new BOP040BCallback(miloService,productionOrdeInfoService, passingStationCollectionService,paramCollectionService,collectionParamConfService,serialNumbersConfService, equipmentStatusService,equipmentAlarmService,materialTraceabilityService,equipmentInfoService, repairManageInfoService,locationInfoService,greaseManageService,productionOrderRecordsService, productionOrderBatchInfoService); List lists = new ArrayList<>(); lists.add(OPCElement.BOP040B_F_HEART_BEAT); lists.add(OPCElement.BOP040B_J_PLC_START); lists.add(OPCElement.BOP040B_J_PLC_FINISH); miloService.subscriptionFromOpcUa(lists,BOP040BCallback); } private void DOP010() throws Exception { DOP010Callback DOP010Callback = new DOP010Callback(miloService,productionOrdeInfoService, passingStationCollectionService,paramCollectionService,collectionParamConfService,serialNumbersConfService, equipmentStatusService,equipmentAlarmService,materialTraceabilityService,equipmentInfoService, repairManageInfoService,locationInfoService,greaseManageService,productionOrderRecordsService, productionOrderBatchInfoService); List lists = new ArrayList<>(); lists.add(OPCElement.DOP010_F_HEART_BEAT); lists.add(OPCElement.DOP010_J_PLC_START); lists.add(OPCElement.DOP010_J_PLC_FINISH); miloService.subscriptionFromOpcUa(lists,DOP010Callback); } private void DOP020() throws Exception { DOP020Callback DOP020Callback = new DOP020Callback(miloService,productionOrdeInfoService, passingStationCollectionService,paramCollectionService,collectionParamConfService,serialNumbersConfService, equipmentStatusService,equipmentAlarmService,materialTraceabilityService,equipmentInfoService, repairManageInfoService,locationInfoService,greaseManageService,productionOrderRecordsService, productionOrderBatchInfoService); List lists = new ArrayList<>(); lists.add(OPCElement.DOP020_F_HEART_BEAT); lists.add(OPCElement.DOP020_J_PLC_START); lists.add(OPCElement.DOP020_J_PLC_FINISH); miloService.subscriptionFromOpcUa(lists,DOP020Callback); } private void EOP010() throws Exception { EOP010Callback EOP010Callback = new EOP010Callback(miloService,productionOrdeInfoService, passingStationCollectionService,paramCollectionService,collectionParamConfService,serialNumbersConfService, equipmentStatusService,equipmentAlarmService,materialTraceabilityService,equipmentInfoService, repairManageInfoService,locationInfoService,greaseManageService,productionOrderRecordsService, productionOrderBatchInfoService); List lists = new ArrayList<>(); lists.add(OPCElement.EOP010_F_HEART_BEAT); lists.add(OPCElement.EOP010_J_PLC_START); lists.add(OPCElement.EOP010_J_PLC_FINISH); miloService.subscriptionFromOpcUa(lists,EOP010Callback); } private void EOP020() throws Exception { EOP020Callback EOP020Callback = new EOP020Callback(miloService,productionOrdeInfoService, passingStationCollectionService,paramCollectionService,collectionParamConfService,serialNumbersConfService, equipmentStatusService,equipmentAlarmService,materialTraceabilityService,equipmentInfoService, repairManageInfoService,locationInfoService,greaseManageService,productionOrderRecordsService, productionOrderBatchInfoService); List lists = new ArrayList<>(); lists.add(OPCElement.EOP020_F_HEART_BEAT); lists.add(OPCElement.EOP020_J_PLC_START); lists.add(OPCElement.EOP020_J_PLC_FINISH); miloService.subscriptionFromOpcUa(lists,EOP020Callback); } private void EOP030() throws Exception { EOP030Callback EOP030Callback = new EOP030Callback(miloService,productionOrdeInfoService, passingStationCollectionService,paramCollectionService,collectionParamConfService,serialNumbersConfService, equipmentStatusService,equipmentAlarmService,materialTraceabilityService,equipmentInfoService, repairManageInfoService,locationInfoService,greaseManageService,productionOrderRecordsService, productionOrderBatchInfoService); List lists = new ArrayList<>(); lists.add(OPCElement.EOP030_F_HEART_BEAT); lists.add(OPCElement.EOP030_J_PLC_START); lists.add(OPCElement.EOP030_J_PLC_FINISH); miloService.subscriptionFromOpcUa(lists,EOP030Callback); } private void EOP040() throws Exception { EOP040Callback EOP040Callback = new EOP040Callback(miloService,productionOrdeInfoService, passingStationCollectionService,paramCollectionService,collectionParamConfService,serialNumbersConfService, equipmentStatusService,equipmentAlarmService,materialTraceabilityService,equipmentInfoService, repairManageInfoService,locationInfoService,greaseManageService,productionOrderRecordsService, productionOrderBatchInfoService); List lists = new ArrayList<>(); lists.add(OPCElement.EOP040_F_HEART_BEAT); lists.add(OPCElement.EOP040_J_PLC_START); lists.add(OPCElement.EOP040_J_PLC_FINISH); miloService.subscriptionFromOpcUa(lists,EOP040Callback); } private void EOP050() throws Exception { EOP050Callback EOP050Callback = new EOP050Callback(miloService,productionOrdeInfoService, passingStationCollectionService,paramCollectionService,collectionParamConfService,serialNumbersConfService, equipmentStatusService,equipmentAlarmService,materialTraceabilityService,equipmentInfoService, repairManageInfoService,locationInfoService,greaseManageService,productionOrderRecordsService, productionOrderBatchInfoService); List lists = new ArrayList<>(); lists.add(OPCElement.EOP050_F_HEART_BEAT); lists.add(OPCElement.EOP050_J_PLC_START); lists.add(OPCElement.EOP050_J_PLC_FINISH); miloService.subscriptionFromOpcUa(lists,EOP050Callback); } private void EOP060() throws Exception { EOP060Callback EOP060Callback = new EOP060Callback(miloService,productionOrdeInfoService, passingStationCollectionService,paramCollectionService,collectionParamConfService,serialNumbersConfService, equipmentStatusService,equipmentAlarmService,materialTraceabilityService,equipmentInfoService, repairManageInfoService,locationInfoService,greaseManageService,productionOrderRecordsService, productionOrderBatchInfoService); List lists = new ArrayList<>(); lists.add(OPCElement.EOP060_F_HEART_BEAT); lists.add(OPCElement.EOP060_J_PLC_START); lists.add(OPCElement.EOP060_J_PLC_FINISH); miloService.subscriptionFromOpcUa(lists,EOP060Callback); } private void EOP070() throws Exception { EOP070Callback EOP070Callback = new EOP070Callback(miloService,productionOrdeInfoService, passingStationCollectionService,paramCollectionService,collectionParamConfService,serialNumbersConfService, equipmentStatusService,equipmentAlarmService,materialTraceabilityService,equipmentInfoService, repairManageInfoService,locationInfoService,greaseManageService,productionOrderRecordsService, productionOrderBatchInfoService); List lists = new ArrayList<>(); lists.add(OPCElement.EOP070_F_HEART_BEAT); lists.add(OPCElement.EOP070_J_PLC_START); lists.add(OPCElement.EOP070_J_PLC_FINISH); miloService.subscriptionFromOpcUa(lists,EOP070Callback); } private void EOP080() throws Exception { EOP080Callback EOP080Callback = new EOP080Callback(miloService,productionOrdeInfoService, passingStationCollectionService,paramCollectionService,collectionParamConfService,serialNumbersConfService, equipmentStatusService,equipmentAlarmService,materialTraceabilityService,equipmentInfoService, repairManageInfoService,locationInfoService,greaseManageService,productionOrderRecordsService, productionOrderBatchInfoService); List lists = new ArrayList<>(); lists.add(OPCElement.EOP080_F_HEART_BEAT); lists.add(OPCElement.EOP080_J_PLC_START); lists.add(OPCElement.EOP080_J_PLC_FINISH); miloService.subscriptionFromOpcUa(lists,EOP080Callback); } private void EOP090() throws Exception { EOP090Callback EOP090Callback = new EOP090Callback(miloService,productionOrdeInfoService, passingStationCollectionService,paramCollectionService,collectionParamConfService,serialNumbersConfService, equipmentStatusService,equipmentAlarmService,materialTraceabilityService,equipmentInfoService, repairManageInfoService,locationInfoService,greaseManageService,productionOrderRecordsService, productionOrderBatchInfoService); List lists = new ArrayList<>(); lists.add(OPCElement.EOP090_F_HEART_BEAT); lists.add(OPCElement.EOP090_J_PLC_START); lists.add(OPCElement.EOP090_J_PLC_FINISH); miloService.subscriptionFromOpcUa(lists,EOP090Callback); } private void EOP090B() throws Exception { EOP090BCallback EOP090BCallback = new EOP090BCallback(miloService,productionOrdeInfoService, passingStationCollectionService,paramCollectionService,collectionParamConfService,serialNumbersConfService, equipmentStatusService,equipmentAlarmService,materialTraceabilityService,equipmentInfoService, repairManageInfoService,locationInfoService,greaseManageService,productionOrderRecordsService, productionOrderBatchInfoService); List lists = new ArrayList<>(); lists.add(OPCElement.EOP090B_F_HEART_BEAT); lists.add(OPCElement.EOP090B_J_PLC_START); lists.add(OPCElement.EOP090B_J_PLC_FINISH); miloService.subscriptionFromOpcUa(lists,EOP090BCallback); } private void OP010() throws Exception { OP010Callback OP010Callback = new OP010Callback(miloService,productionOrdeInfoService, passingStationCollectionService,paramCollectionService,collectionParamConfService,serialNumbersConfService, equipmentStatusService,equipmentAlarmService,materialTraceabilityService,equipmentInfoService, repairManageInfoService,locationInfoService,greaseManageService,productionOrderRecordsService, productionOrderBatchInfoService); List lists = new ArrayList<>(); lists.add(OPCElement.OP010_F_HEART_BEAT); lists.add(OPCElement.OP010_J_PLC_START); lists.add(OPCElement.OP010_J_PLC_FINISH); miloService.subscriptionFromOpcUa(lists,OP010Callback); } private void OP020() throws Exception { OP020Callback OP020Callback = new OP020Callback(miloService,productionOrdeInfoService, passingStationCollectionService,paramCollectionService,collectionParamConfService,serialNumbersConfService, equipmentStatusService,equipmentAlarmService,materialTraceabilityService,equipmentInfoService, repairManageInfoService,locationInfoService,greaseManageService,productionOrderRecordsService, productionOrderBatchInfoService); List lists = new ArrayList<>(); lists.add(OPCElement.OP020_F_HEART_BEAT); lists.add(OPCElement.OP020_J_PLC_START); lists.add(OPCElement.OP020_J_PLC_FINISH); miloService.subscriptionFromOpcUa(lists,OP020Callback); } private void OP030() throws Exception { OP030Callback OP030Callback = new OP030Callback(miloService,productionOrdeInfoService, passingStationCollectionService,paramCollectionService,collectionParamConfService,serialNumbersConfService, equipmentStatusService,equipmentAlarmService,materialTraceabilityService,equipmentInfoService, repairManageInfoService,locationInfoService,greaseManageService,productionOrderRecordsService, productionOrderBatchInfoService); List lists = new ArrayList<>(); lists.add(OPCElement.OP030_F_HEART_BEAT); lists.add(OPCElement.OP030_J_PLC_START); lists.add(OPCElement.OP030_J_PLC_FINISH); miloService.subscriptionFromOpcUa(lists,OP030Callback); } private void OP040() throws Exception { OP040Callback OP040Callback = new OP040Callback(miloService,productionOrdeInfoService, passingStationCollectionService,paramCollectionService,collectionParamConfService,serialNumbersConfService, equipmentStatusService,equipmentAlarmService,materialTraceabilityService,equipmentInfoService, repairManageInfoService,locationInfoService,greaseManageService,productionOrderRecordsService, productionOrderBatchInfoService); List lists = new ArrayList<>(); lists.add(OPCElement.OP040_F_HEART_BEAT); lists.add(OPCElement.OP040_J_PLC_START); lists.add(OPCElement.OP040_J_PLC_FINISH); miloService.subscriptionFromOpcUa(lists,OP040Callback); } private void OP050() throws Exception { OP050Callback OP050Callback = new OP050Callback(miloService,productionOrdeInfoService, passingStationCollectionService,paramCollectionService,collectionParamConfService,serialNumbersConfService, equipmentStatusService,equipmentAlarmService,materialTraceabilityService,equipmentInfoService, repairManageInfoService,locationInfoService,greaseManageService,productionOrderRecordsService, productionOrderBatchInfoService); List lists = new ArrayList<>(); lists.add(OPCElement.OP050_F_HEART_BEAT); lists.add(OPCElement.OP050_J_PLC_START); lists.add(OPCElement.OP050_J_PLC_FINISH); miloService.subscriptionFromOpcUa(lists,OP050Callback); } private void OP070() throws Exception { OP070Callback OP070Callback = new OP070Callback(miloService,productionOrdeInfoService, passingStationCollectionService,paramCollectionService,collectionParamConfService,serialNumbersConfService, equipmentStatusService,equipmentAlarmService,materialTraceabilityService,equipmentInfoService, repairManageInfoService,locationInfoService,greaseManageService,productionOrderRecordsService, productionOrderBatchInfoService); List lists = new ArrayList<>(); lists.add(OPCElement.OP070_F_HEART_BEAT); lists.add(OPCElement.OP070_J_PLC_START); lists.add(OPCElement.OP070_J_PLC_FINISH); miloService.subscriptionFromOpcUa(lists,OP070Callback); } private void OP080() throws Exception { OP080Callback OP080Callback = new OP080Callback(miloService,productionOrdeInfoService, passingStationCollectionService,paramCollectionService,collectionParamConfService,serialNumbersConfService, equipmentStatusService,equipmentAlarmService,materialTraceabilityService,equipmentInfoService, repairManageInfoService,locationInfoService,greaseManageService,productionOrderRecordsService, productionOrderBatchInfoService); List lists = new ArrayList<>(); lists.add(OPCElement.OP080_F_HEART_BEAT); lists.add(OPCElement.OP080_J_PLC_START); lists.add(OPCElement.OP080_J_PLC_FINISH); miloService.subscriptionFromOpcUa(lists,OP080Callback); } private void OP090() throws Exception { OP090Callback OP090Callback = new OP090Callback(miloService,productionOrdeInfoService, passingStationCollectionService,paramCollectionService,collectionParamConfService,serialNumbersConfService, equipmentStatusService,equipmentAlarmService,materialTraceabilityService,equipmentInfoService, repairManageInfoService,locationInfoService,greaseManageService,productionOrderRecordsService, productionOrderBatchInfoService); List lists = new ArrayList<>(); lists.add(OPCElement.OP090_F_HEART_BEAT); lists.add(OPCElement.OP090_J_PLC_START); lists.add(OPCElement.OP090_J_PLC_FINISH); miloService.subscriptionFromOpcUa(lists,OP090Callback); } private void OP100() throws Exception { OP100Callback OP100Callback = new OP100Callback(miloService,productionOrdeInfoService, passingStationCollectionService,paramCollectionService,collectionParamConfService,serialNumbersConfService, equipmentStatusService,equipmentAlarmService,materialTraceabilityService,equipmentInfoService, repairManageInfoService,locationInfoService,greaseManageService,productionOrderRecordsService, productionOrderBatchInfoService); List lists = new ArrayList<>(); lists.add(OPCElement.OP100_F_HEART_BEAT); lists.add(OPCElement.OP100_J_PLC_START); lists.add(OPCElement.OP100_J_PLC_FINISH); miloService.subscriptionFromOpcUa(lists,OP100Callback); } private void OP110() throws Exception { OP110Callback OP110Callback = new OP110Callback(miloService,productionOrdeInfoService, passingStationCollectionService,paramCollectionService,collectionParamConfService,serialNumbersConfService, equipmentStatusService,equipmentAlarmService,materialTraceabilityService,equipmentInfoService, repairManageInfoService,locationInfoService,greaseManageService,productionOrderRecordsService, productionOrderBatchInfoService); List lists = new ArrayList<>(); lists.add(OPCElement.OP110_F_HEART_BEAT); lists.add(OPCElement.OP110_J_PLC_START); lists.add(OPCElement.OP110_J_PLC_FINISH); miloService.subscriptionFromOpcUa(lists,OP110Callback); } private void OP120() throws Exception { OP120Callback OP120Callback = new OP120Callback(miloService,productionOrdeInfoService, passingStationCollectionService,paramCollectionService,collectionParamConfService,serialNumbersConfService, equipmentStatusService,equipmentAlarmService,materialTraceabilityService,equipmentInfoService, repairManageInfoService,locationInfoService,greaseManageService,productionOrderRecordsService, productionOrderBatchInfoService); List lists = new ArrayList<>(); lists.add(OPCElement.OP120_F_HEART_BEAT); lists.add(OPCElement.OP120_J_PLC_START); lists.add(OPCElement.OP120_J_PLC_FINISH); miloService.subscriptionFromOpcUa(lists,OP120Callback); } private void OP120B() throws Exception { OP120BCallback OP120BCallback = new OP120BCallback(miloService,productionOrdeInfoService, passingStationCollectionService,paramCollectionService,collectionParamConfService,serialNumbersConfService, equipmentStatusService,equipmentAlarmService,materialTraceabilityService,equipmentInfoService, repairManageInfoService,locationInfoService,greaseManageService,productionOrderRecordsService, productionOrderBatchInfoService); List lists = new ArrayList<>(); lists.add(OPCElement.OP120B_F_HEART_BEAT); lists.add(OPCElement.OP120B_J_PLC_START); lists.add(OPCElement.OP120B_J_PLC_FINISH); miloService.subscriptionFromOpcUa(lists,OP120BCallback); } private void OP130() throws Exception { OP130Callback OP130Callback = new OP130Callback(miloService,productionOrdeInfoService, passingStationCollectionService,paramCollectionService,collectionParamConfService,serialNumbersConfService, equipmentStatusService,equipmentAlarmService,materialTraceabilityService,equipmentInfoService, repairManageInfoService,locationInfoService,greaseManageService,productionOrderRecordsService, productionOrderBatchInfoService); List lists = new ArrayList<>(); lists.add(OPCElement.OP130_F_HEART_BEAT); lists.add(OPCElement.OP130_J_PLC_START); lists.add(OPCElement.OP130_J_PLC_FINISH); miloService.subscriptionFromOpcUa(lists,OP130Callback); } private void OP130B() throws Exception { OP130BCallback OP130BCallback = new OP130BCallback(miloService,productionOrdeInfoService, passingStationCollectionService,paramCollectionService,collectionParamConfService,serialNumbersConfService, equipmentStatusService,equipmentAlarmService,materialTraceabilityService,equipmentInfoService, repairManageInfoService,locationInfoService,greaseManageService,productionOrderRecordsService, productionOrderBatchInfoService); List lists = new ArrayList<>(); lists.add(OPCElement.OP130B_F_HEART_BEAT); lists.add(OPCElement.OP130B_J_PLC_START); lists.add(OPCElement.OP130B_J_PLC_FINISH); miloService.subscriptionFromOpcUa(lists,OP130BCallback); } private void OP140() throws Exception { OP140Callback OP140Callback = new OP140Callback(miloService,productionOrdeInfoService, passingStationCollectionService,paramCollectionService,collectionParamConfService,serialNumbersConfService, equipmentStatusService,equipmentAlarmService,materialTraceabilityService,equipmentInfoService, repairManageInfoService,locationInfoService,greaseManageService,productionOrderRecordsService, productionOrderBatchInfoService); List lists = new ArrayList<>(); lists.add(OPCElement.OP140_F_HEART_BEAT); lists.add(OPCElement.OP140_J_PLC_START); lists.add(OPCElement.OP140_J_PLC_FINISH); miloService.subscriptionFromOpcUa(lists,OP140Callback); } private void OP150() throws Exception { OP150Callback OP150Callback = new OP150Callback(miloService,productionOrdeInfoService, passingStationCollectionService,paramCollectionService,collectionParamConfService,serialNumbersConfService, equipmentStatusService,equipmentAlarmService,materialTraceabilityService,equipmentInfoService, repairManageInfoService,locationInfoService,greaseManageService,productionOrderRecordsService, productionOrderBatchInfoService); List lists = new ArrayList<>(); lists.add(OPCElement.OP150_F_HEART_BEAT); lists.add(OPCElement.OP150_J_PLC_START); lists.add(OPCElement.OP150_J_PLC_FINISH); miloService.subscriptionFromOpcUa(lists,OP150Callback); } private void OP160() throws Exception { OP160Callback OP160Callback = new OP160Callback(miloService,productionOrdeInfoService, passingStationCollectionService,paramCollectionService,collectionParamConfService,serialNumbersConfService, equipmentStatusService,equipmentAlarmService,materialTraceabilityService,equipmentInfoService, repairManageInfoService,locationInfoService,greaseManageService,productionOrderRecordsService, productionOrderBatchInfoService); List lists = new ArrayList<>(); lists.add(OPCElement.OP160_F_HEART_BEAT); lists.add(OPCElement.OP160_J_PLC_START); lists.add(OPCElement.OP160_J_PLC_FINISH); miloService.subscriptionFromOpcUa(lists,OP160Callback); } private void OP170() throws Exception { OP170Callback OP170Callback = new OP170Callback(miloService,productionOrdeInfoService, passingStationCollectionService,paramCollectionService,collectionParamConfService,serialNumbersConfService, equipmentStatusService,equipmentAlarmService,materialTraceabilityService,equipmentInfoService, repairManageInfoService,locationInfoService,greaseManageService,productionOrderRecordsService, productionOrderBatchInfoService); List lists = new ArrayList<>(); lists.add(OPCElement.OP170_F_HEART_BEAT); lists.add(OPCElement.OP170_J_PLC_START); lists.add(OPCElement.OP170_J_PLC_FINISH); miloService.subscriptionFromOpcUa(lists,OP170Callback); } public List getList(){ List lists = new ArrayList<>(); lists.add(OPCElement.COP010_F_HEART_BEAT); lists.add(OPCElement.COP010_J_PLC_START); lists.add(OPCElement.COP010_J_PLC_FINISH); lists.add(OPCElement.COP020_F_HEART_BEAT); lists.add(OPCElement.COP020_J_PLC_START); lists.add(OPCElement.COP020_J_PLC_FINISH); lists.add(OPCElement.COP030_F_HEART_BEAT); lists.add(OPCElement.COP030_J_PLC_START); lists.add(OPCElement.COP030_J_PLC_FINISH); lists.add(OPCElement.BOP010_F_HEART_BEAT); lists.add(OPCElement.BOP010_J_PLC_START); lists.add(OPCElement.BOP010_J_PLC_FINISH); lists.add(OPCElement.BOP020_F_HEART_BEAT); lists.add(OPCElement.BOP020_J_PLC_START); lists.add(OPCElement.BOP020_J_PLC_FINISH); lists.add(OPCElement.BOP030_F_HEART_BEAT); lists.add(OPCElement.BOP030_J_PLC_START); lists.add(OPCElement.BOP030_J_PLC_FINISH); lists.add(OPCElement.BOP030B_F_HEART_BEAT); lists.add(OPCElement.BOP030B_J_PLC_START); lists.add(OPCElement.BOP030B_J_PLC_FINISH); lists.add(OPCElement.BOP040_F_HEART_BEAT); lists.add(OPCElement.BOP040_J_PLC_START); lists.add(OPCElement.BOP040_J_PLC_FINISH); lists.add(OPCElement.BOP040B_F_HEART_BEAT); lists.add(OPCElement.BOP040B_J_PLC_START); lists.add(OPCElement.BOP040B_J_PLC_FINISH); lists.add(OPCElement.DOP010_F_HEART_BEAT); lists.add(OPCElement.DOP010_J_PLC_START); lists.add(OPCElement.DOP010_J_PLC_FINISH); /* lists.add(OPCElement.DOP020_F_HEART_BEAT); lists.add(OPCElement.DOP020_J_PLC_START); lists.add(OPCElement.DOP020_J_PLC_FINISH);*/ lists.add(OPCElement.EOP010_F_HEART_BEAT); lists.add(OPCElement.EOP010_J_PLC_START); lists.add(OPCElement.EOP010_J_PLC_FINISH); lists.add(OPCElement.EOP020_F_HEART_BEAT); lists.add(OPCElement.EOP020_J_PLC_START); lists.add(OPCElement.EOP020_J_PLC_FINISH); lists.add(OPCElement.EOP030_F_HEART_BEAT); lists.add(OPCElement.EOP030_J_PLC_START); lists.add(OPCElement.EOP030_J_PLC_FINISH); lists.add(OPCElement.EOP040_F_HEART_BEAT); lists.add(OPCElement.EOP040_J_PLC_START); lists.add(OPCElement.EOP040_J_PLC_FINISH); lists.add(OPCElement.EOP050_F_HEART_BEAT); lists.add(OPCElement.EOP050_J_PLC_START); lists.add(OPCElement.EOP050_J_PLC_FINISH); lists.add(OPCElement.EOP060_F_HEART_BEAT); lists.add(OPCElement.EOP060_J_PLC_START); lists.add(OPCElement.EOP060_J_PLC_FINISH); lists.add(OPCElement.EOP070_F_HEART_BEAT); lists.add(OPCElement.EOP070_J_PLC_START); lists.add(OPCElement.EOP070_J_PLC_FINISH); lists.add(OPCElement.EOP070_F_HEART_BEAT); lists.add(OPCElement.EOP070_J_PLC_START); lists.add(OPCElement.EOP070_J_PLC_FINISH); lists.add(OPCElement.EOP090_F_HEART_BEAT); lists.add(OPCElement.EOP090_J_PLC_START); lists.add(OPCElement.EOP090_J_PLC_FINISH); lists.add(OPCElement.EOP090B_F_HEART_BEAT); lists.add(OPCElement.EOP090B_J_PLC_START); lists.add(OPCElement.EOP090B_J_PLC_FINISH); lists.add(OPCElement.OP010_F_HEART_BEAT); lists.add(OPCElement.OP010_J_PLC_START); lists.add(OPCElement.OP010_J_PLC_FINISH); lists.add(OPCElement.OP020_F_HEART_BEAT); lists.add(OPCElement.OP020_J_PLC_START); lists.add(OPCElement.OP020_J_PLC_FINISH); lists.add(OPCElement.OP030_F_HEART_BEAT); lists.add(OPCElement.OP030_J_PLC_START); lists.add(OPCElement.OP030_J_PLC_FINISH); lists.add(OPCElement.OP040_F_HEART_BEAT); lists.add(OPCElement.OP040_J_PLC_START); lists.add(OPCElement.OP040_J_PLC_FINISH); lists.add(OPCElement.OP050_F_HEART_BEAT); lists.add(OPCElement.OP050_J_PLC_START); lists.add(OPCElement.OP050_J_PLC_FINISH); lists.add(OPCElement.OP070_F_HEART_BEAT); lists.add(OPCElement.OP070_J_PLC_START); lists.add(OPCElement.OP070_J_PLC_FINISH); lists.add(OPCElement.OP080_F_HEART_BEAT); lists.add(OPCElement.OP080_J_PLC_START); lists.add(OPCElement.OP080_J_PLC_FINISH); lists.add(OPCElement.OP090_F_HEART_BEAT); lists.add(OPCElement.OP090_J_PLC_START); lists.add(OPCElement.OP090_J_PLC_FINISH); lists.add(OPCElement.OP100_F_HEART_BEAT); lists.add(OPCElement.OP100_J_PLC_START); lists.add(OPCElement.OP100_J_PLC_FINISH); lists.add(OPCElement.OP110_F_HEART_BEAT); lists.add(OPCElement.OP110_J_PLC_START); lists.add(OPCElement.OP110_J_PLC_FINISH); lists.add(OPCElement.OP120_F_HEART_BEAT); lists.add(OPCElement.OP120_J_PLC_START); lists.add(OPCElement.OP120_J_PLC_FINISH); lists.add(OPCElement.OP120B_F_HEART_BEAT); lists.add(OPCElement.OP120B_J_PLC_START); lists.add(OPCElement.OP120B_J_PLC_FINISH); lists.add(OPCElement.OP130_F_HEART_BEAT); lists.add(OPCElement.OP130_J_PLC_START); lists.add(OPCElement.OP130_J_PLC_FINISH); lists.add(OPCElement.OP130B_F_HEART_BEAT); lists.add(OPCElement.OP130B_J_PLC_START); lists.add(OPCElement.OP130B_J_PLC_FINISH); lists.add(OPCElement.OP140_F_HEART_BEAT); lists.add(OPCElement.OP140_J_PLC_START); lists.add(OPCElement.OP140_J_PLC_FINISH); /* lists.add(OPCElement.OP150_F_HEART_BEAT); lists.add(OPCElement.OP150_J_PLC_START); lists.add(OPCElement.OP150_J_PLC_FINISH);*/ lists.add(OPCElement.OP160_F_HEART_BEAT); lists.add(OPCElement.OP160_J_PLC_START); lists.add(OPCElement.OP160_J_PLC_FINISH); lists.add(OPCElement.OP170_F_HEART_BEAT); lists.add(OPCElement.OP170_J_PLC_START); lists.add(OPCElement.OP170_J_PLC_FINISH); if(null == stateLists ){ EquipmentInfoParam equipmentInfoParam = new EquipmentInfoParam(); stateLists = equipmentInfoService.findListBySpec(equipmentInfoParam); } if(!stateLists.isEmpty()){ for(int i=0;i