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