hdy
2024-04-18 e2670e7912ea7316d1f9fb518d980b8a4ef94055
提交 | 用户 | 时间
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();
51         miloService.subscriptionFromOpcUa(lists,opcUaSubscription);
52
53     }
54
55     /**
56      * 订阅内容
57      */
58     public List<String> getSubList(){
59         List<String> lists = new ArrayList<>();
b5fcd8 60         lists.add(OPCElement.PACK_OP230_RecordData);//请求记录数据
e2670e 61         lists.add(OPCElement.PACK_OP230_AngleResult);//请求记录数据
e70fb4 62         lists.add(OPCElement.PACK_OP240_RecordData);//请求记录数据.
A 63         lists.add(OPCElement.PACK_OP240_AngleResult);//请求记录数据
e2670e 64         lists.add(OPCElement.PACK_OP260_RecordData);//请求记录数据
H 65         lists.add(OPCElement.PACK_OP260_AngleResult);//请求记录数据
63b254 66         lists.add(OPCElement.PACK_OP270_RecordData);//请求记录数据
67         lists.add(OPCElement.PACK_OP270_AngleResult);//请求记录数据
e2670e 68         lists.add(OPCElement.PACK_OP290_RecordData);//请求记录数据
H 69         lists.add(OPCElement.PACK_OP290_AngleResult);//请求记录数据
70         lists.add(OPCElement.PACK_OP300_RecordData);//请求记录数据
71         lists.add(OPCElement.PACK_OP300_AngleResult);//请求记录数据
72         lists.add(OPCElement.PACK_OP310_RecordData);//请求记录数据
73         lists.add(OPCElement.PACK_OP310_AngleResult);//请求记录数据
74         lists.add(OPCElement.PACK_OP330_RecordData);//请求记录数据
75         lists.add(OPCElement.PACK_OP330_AngleResult);//请求记录数据
76         lists.add(OPCElement.PACK_OP380_RecordData);//请求记录数据
77         lists.add(OPCElement.PACK_OP380_AngleResult);//请求记录数据
78         lists.add(OPCElement.PACK_OP400_RecordData);//请求记录数据
79         lists.add(OPCElement.PACK_OP400_AngleResult);//请求记录数据
80         lists.add(OPCElement.PACK_OP410_RecordData);//请求记录数据
81         lists.add(OPCElement.PACK_OP410_AngleResult);//请求记录数据
82         lists.add(OPCElement.PACK_OP440_RecordData);//请求记录数据
83         lists.add(OPCElement.PACK_OP440_AngleResult);//请求记录数据
84         lists.add(OPCElement.PACK_OP450_RecordData);//请求记录数据
85         lists.add(OPCElement.PACK_OP450_AngleResult);//请求记录数据
86         lists.add(OPCElement.PACK_OP460_RecordData);//请求记录数据
87         lists.add(OPCElement.PACK_OP460_AngleResult);//请求记录数据
88         lists.add(OPCElement.PACK_OP500_RecordData);//请求记录数据
89         lists.add(OPCElement.PACK_OP500_AngleResult);//请求记录数据
90
91         lists.add(OPCElement.PACK_OP280_RecordData);//请求记录数据
92         lists.add(OPCElement.PACK_OP320_RecordData);//请求记录数据
e70fb4 93         lists.add(OPCElement.PACK_OP340_RecordData);//请求记录数据
e2670e 94         lists.add(OPCElement.PACK_OP350_RecordData);//请求记录数据
H 95         lists.add(OPCElement.PACK_OP360_RecordData);//请求记录数据
96         lists.add(OPCElement.PACK_OP370_RecordData);//请求记录数据
97         lists.add(OPCElement.PACK_OP390_RecordData);//请求记录数据
98         lists.add(OPCElement.PACK_OP470_RecordData);//请求记录数据
89f416 99
a5b351 100         return lists;
C 101     }
102 }
103