package com.jcdm.main.plcserver; import com.jcdm.main.bs.orderScheduling.service.IBsOrderSchedulingService; import com.jcdm.main.bs.technologyRouteChild.service.IBsTechnologyRouteChildInfoService; import com.jcdm.main.da.collectionParamConf.service.IDaCollectionParamConfService; import com.jcdm.main.da.opcuaconfig.domain.DaOpcuaConfig; import com.jcdm.main.da.opcuaconfig.service.IDaOpcuaConfigService; import com.jcdm.main.da.paramCollection.service.IDaParamCollectionService; import com.jcdm.main.da.passingStationCollection.service.impl.DaPassingStationCollectionServiceImpl; import com.jcdm.main.plcserver.sub.OPCUaSubscription; import com.jcdm.main.rm.repairRecord.service.IRmRepairRecordService; import com.kangaroohy.milo.service.MiloService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.ApplicationArguments; import org.springframework.boot.ApplicationRunner; import org.springframework.stereotype.Component; import javax.annotation.Resource; import java.util.List; import java.util.stream.Collectors; @Component public class CustomRunner implements ApplicationRunner { @Autowired public MiloService miloService; @Autowired public IDaCollectionParamConfService collectionParamConfService; @Autowired public IDaParamCollectionService daParamCollectionService; @Resource private DaPassingStationCollectionServiceImpl passingStationCollectionServiceImpl; @Resource private IDaOpcuaConfigService iDaOpcuaConfigService; @Resource private IBsOrderSchedulingService bsOrderSchedulingService; @Resource private IRmRepairRecordService rmRepairRecordService; @Resource private IBsTechnologyRouteChildInfoService bsTechnologyRouteChildInfoService; @Override public void run(ApplicationArguments args) throws Exception { List lists = getSubList(); List collect = lists.stream().map(DaOpcuaConfig::getNode).collect(Collectors.toList()); OPCUaSubscription opcUaSubscription = new OPCUaSubscription( miloService, collectionParamConfService, daParamCollectionService, passingStationCollectionServiceImpl, bsOrderSchedulingService, lists, rmRepairRecordService, bsTechnologyRouteChildInfoService); miloService.subscriptionFromOpcUa(collect,opcUaSubscription); } /** * 订阅内容 */ public List getSubList(){ DaOpcuaConfig config = new DaOpcuaConfig(); config.setState(0); List list = iDaOpcuaConfigService.selectDaOpcuaConfigList(config); // List lists = new ArrayList<>(); // if (CollUtil.isNotEmpty(list)){ // lists = list.stream().map(DaOpcuaConfig::getNode).distinct().collect(Collectors.toList()); // } // List lists = new ArrayList<>(); //// lists.add(OPCElement.OP010_SaveRequest);//请求保存 //// lists.add(OPCElement.OP010_CodeCheck);//请求检索条码 //// lists.add(OPCElement.OP020_SaveRequest);//请求保存 // lists.add(OPCElement.OP120_SaveRequestLast);//请求保存 // lists.add(OPCElement.OP120_ZZ_CODE_CHECK);//请求保存 return list; } }