| 提交 | 用户 | 时间 | ||
| 0ca254 | 1 | package com.jcdm.main.plcserver; |
| A | 2 | |
| 3 | ||
| 4 | import com.jcdm.main.da.collectionParamConf.service.IDaCollectionParamConfService; | |
| 5 | import com.jcdm.main.da.paramCollection.service.IDaParamCollectionService; | |
| 6 | import com.jcdm.main.da.passingStationCollection.service.IDaPassingStationCollectionService; | |
| 7 | import com.jcdm.main.da.testDeviceInterface.service.IDaTestDeviceInterfaceService; | |
| 8 | import com.jcdm.main.om.productionOrde.service.IOmProductionOrdeInfoService; | |
| 9 | import com.jcdm.main.plcserver.conf.OPCElement; | |
| 10 | import com.jcdm.main.plcserver.sub.OPCUaSubscription; | |
| 11 | import com.kangaroohy.milo.service.MiloService; | |
| 12 | import org.springframework.beans.factory.annotation.Autowired; | |
| 13 | import org.springframework.boot.ApplicationArguments; | |
| 14 | import org.springframework.boot.ApplicationRunner; | |
| 15 | import org.springframework.stereotype.Component; | |
| 16 | ||
| 17 | import java.util.ArrayList; | |
| 18 | import java.util.List; | |
| 19 | ||
| 20 | @Component | |
| 21 | public class CustomRunner implements ApplicationRunner { | |
| 22 | ||
| 23 | @Autowired | |
| 24 | private MiloService miloService; | |
| 25 | ||
| 26 | @Autowired | |
| 27 | private IDaPassingStationCollectionService daPassingStationCollectionService; | |
| 28 | ||
| 29 | @Autowired | |
| 30 | private IDaCollectionParamConfService collectionParamConfService; | |
| 31 | ||
| 32 | @Autowired | |
| 33 | private IDaParamCollectionService daParamCollectionService; | |
| 34 | ||
| 35 | @Autowired | |
| 36 | private IDaCollectionParamConfService daCollectionParamConfService; | |
| 37 | ||
| 38 | @Autowired | |
| 39 | private IOmProductionOrdeInfoService omProductionOrdeInfoService; | |
| 40 | ||
| 41 | @Autowired | |
| 42 | private IDaTestDeviceInterfaceService daTestDeviceInterfaceService; | |
| 43 | ||
| 44 | @Override | |
| 45 | public void run(ApplicationArguments args) throws Exception { | |
| 46 | ||
| 47 | OPCUaSubscription opcUaSubscription = new OPCUaSubscription( | |
| 48 | miloService, | |
| 49 | daPassingStationCollectionService, | |
| 50 | collectionParamConfService, | |
| 51 | daParamCollectionService, | |
| 52 | omProductionOrdeInfoService, | |
| 53 | daTestDeviceInterfaceService); | |
| 54 | ||
| 55 | List<String> lists = getSubList(); | |
| 56 | System.out.println("订阅内容："+lists); | |
| 57 | miloService.subscriptionFromOpcUa(lists,50,opcUaSubscription); | |
| 58 | } | |
| 59 | ||
| 60 | /** | |
| 61 | * 订阅内容 | |
| 62 | */ | |
| 63 | public List<String> getSubList(){ | |
| 64 | List<String> lists = new ArrayList<>(); | |
| 65 | lists.add(OPCElement.PACK_OP230_RecordData);//请求记录数据 | |
| 66 | // lists.add(OPCElement.PACK_OP240_RecordData);//请求记录数据. | |
| 67 | // lists.add(OPCElement.PACK_OP240_AngleResult);//请求记录数据 | |
| 68 | // lists.add(OPCElement.PACK_OP2501_AngleResult);//请求记录数据 | |
| 69 | // lists.add(OPCElement.PACK_OP2502_AngleResult);//请求记录数据 | |
| 70 | // lists.add(OPCElement.PACK_OP2503_AngleResult);//请求记录数据 | |
| 71 | // lists.add(OPCElement.PACK_OP260_RecordData);//请求记录数据 | |
| 72 | // lists.add(OPCElement.PACK_OP260_AngleResult);//请求记录数据 | |
| 73 | // lists.add(OPCElement.PACK_OP270_RecordData);//请求记录数据 | |
| 74 | // lists.add(OPCElement.PACK_OP270_AngleResult);//请求记录数据 | |
| 75 | // lists.add(OPCElement.PACK_OP290_RecordData);//请求记录数据 | |
| 76 | // lists.add(OPCElement.PACK_OP290_AngleResult);//请求记录数据 | |
| 77 | // lists.add(OPCElement.PACK_OP300A_RecordData);//请求记录数据 | |
| 78 | // lists.add(OPCElement.PACK_OP300B_RecordData);//请求记录数据 | |
| 79 | // lists.add(OPCElement.PACK_OP310A_RecordData);//请求记录数据 | |
| 80 | // lists.add(OPCElement.PACK_OP310B_RecordData);//请求记录数据 | |
| 81 | // lists.add(OPCElement.PACK_OP330_RecordData);//请求记录数据 | |
| 82 | // lists.add(OPCElement.PACK_OP380_RecordData);//请求记录数据 | |
| 83 | // lists.add(OPCElement.PACK_OP380_AngleResult);//请求记录数据 | |
| 84 | // lists.add(OPCElement.PACK_OP400_RecordData);//请求记录数据 | |
| 85 | // lists.add(OPCElement.PACK_OP400_AngleResult);//请求记录数据 | |
| 86 | // lists.add(OPCElement.PACK_OP410_RecordData);//请求记录数据 | |
| 87 | // lists.add(OPCElement.PACK_OP410_AngleResult);//请求记录数据 | |
| 88 | // lists.add(OPCElement.PACK_OP4301_RecordData);//请求记录数据 | |
| 89 | // lists.add(OPCElement.PACK_OP4302_RecordData);//请求记录数据 | |
| 90 | // lists.add(OPCElement.PACK_OP4303_RecordData);//请求记录数据 | |
| 91 | // lists.add(OPCElement.PACK_OP4304_RecordData);//请求记录数据 | |
| 92 | // lists.add(OPCElement.PACK_OP440_RecordData);//请求记录数据 | |
| 93 | // lists.add(OPCElement.PACK_OP450_RecordData);//请求记录数据 | |
| 94 | // lists.add(OPCElement.PACK_OP450_AngleResult);//请求记录数据 | |
| 95 | // lists.add(OPCElement.PACK_OP460_RecordData);//请求记录数据 | |
| 96 | // lists.add(OPCElement.PACK_OP460_AngleResult);//请求记录数据 | |
| 97 | // lists.add(OPCElement.PACK_OP4801_RecordData);//请求记录数据 | |
| 98 | // lists.add(OPCElement.PACK_OP4802_RecordData);//请求记录数据 | |
| 99 | // lists.add(OPCElement.PACK_OP4803_RecordData);//请求记录数据 | |
| 100 | // | |
| 101 | // lists.add(OPCElement.PACK_OP500_RecordData);//请求记录数据 | |
| 102 | // lists.add(OPCElement.PACK_OP500_AngleResult);//请求记录数据 | |
| 103 | //// | |
| 104 | // lists.add(OPCElement.PACK_OP280_RecordData);//请求记录数据 | |
| 105 | // lists.add(OPCElement.PACK_OP320A_RecordData);//请求记录数据 | |
| 106 | // lists.add(OPCElement.PACK_OP320B_RecordData);//请求记录数据 | |
| 107 | // lists.add(OPCElement.PACK_OP340A_RecordData);//请求记录数据 | |
| 108 | // lists.add(OPCElement.PACK_OP340B_RecordData);//请求记录数据 | |
| 109 | // lists.add(OPCElement.PACK_OP350A_RecordData);//请求记录数据 | |
| 110 | // lists.add(OPCElement.PACK_OP350B_RecordData);//请求记录数据 | |
| 111 | // lists.add(OPCElement.PACK_OP360_RecordData);//请求记录数据 | |
| 112 | // lists.add(OPCElement.PACK_OP365_RecordData);//请求记录数据 | |
| 113 | // lists.add(OPCElement.PACK_OP370_RecordData);//请求记录数据 | |
| 114 | // lists.add(OPCElement.PACK_OP390_RecordData);//请求记录数据 | |
| 115 | // lists.add(OPCElement.PACK_OP470_RecordData);//请求记录数据 | |
| 116 | ||
| 117 | return lists; | |
| 118 | } | |
| 119 | } | |
| 120 | ||
