From f48c38125956578611832f6017b0cb2ffdbe3725 Mon Sep 17 00:00:00 2001
From: 吴健 <14790700720@163.com>
Date: 星期二, 15 四月 2025 09:00:32 +0800
Subject: [PATCH] add
---
billion-main/src/main/java/com/billion/main/plc/CustomRunner.java | 122 ++++++++++++++++++++--------------------
1 files changed, 61 insertions(+), 61 deletions(-)
diff --git a/billion-main/src/main/java/com/billion/main/plc/CustomRunner.java b/billion-main/src/main/java/com/billion/main/plc/CustomRunner.java
index 3adedfa..3abd2bc 100644
--- a/billion-main/src/main/java/com/billion/main/plc/CustomRunner.java
+++ b/billion-main/src/main/java/com/billion/main/plc/CustomRunner.java
@@ -1,61 +1,61 @@
-package com.billion.main.plc;
-
-
-import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
-import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper;
-import com.billion.main.da.service.IDaParamCollectionService;
-import com.billion.main.da.service.IDaStationCollectionService;
-import com.billion.main.plc.constant.Constants;
-import com.billion.main.plc.sub.OPCUaSubscription;
-import com.billion.main.sc.domain.ScOpcConf;
-import com.billion.main.sc.service.IScCollectionParamConfService;
-import com.billion.main.sc.service.IScOpcConfService;
-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 java.util.List;
-import java.util.stream.Collectors;
-
-@Component
-public class CustomRunner implements ApplicationRunner {
-
- @Autowired
- private MiloService miloService;
- @Autowired
- private IScOpcConfService opcConfService;
- @Autowired
- private IScCollectionParamConfService collectionParamConfService;
- @Autowired
- private IDaParamCollectionService paramCollectionService;
- @Autowired
- private IDaStationCollectionService stationCollectionService;
-
- @Override
- public void run(ApplicationArguments args) throws Exception {
-
- OPCUaSubscription opcUaSubscription = new OPCUaSubscription(
- miloService,
- collectionParamConfService,
- paramCollectionService,
- stationCollectionService);
-
- List<String> lists = getSubList();
- System.out.println("璁㈤槄鍐呭锛�"+lists);
- miloService.subscriptionFromOpcUa(lists,50,opcUaSubscription);
-
- }
-
- /**
- * 璁㈤槄鍐呭
- */
- public List<String> getSubList(){
- List<String> lists = opcConfService.list(new LambdaQueryWrapper<ScOpcConf>()
- .eq(ScOpcConf::getSubscribe,Constants.YES))
- .stream().map(ScOpcConf::getNode).collect(Collectors.toList());
- return lists;
- }
-}
-
+//package com.billion.main.plc;
+//
+//
+//import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+//import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper;
+//import com.billion.main.da.service.IDaParamCollectionService;
+//import com.billion.main.da.service.IDaStationCollectionService;
+//import com.billion.main.plc.constant.Constants;
+//import com.billion.main.plc.sub.OPCUaSubscription;
+//import com.billion.main.sc.domain.ScOpcConf;
+//import com.billion.main.sc.service.IScCollectionParamConfService;
+//import com.billion.main.sc.service.IScOpcConfService;
+//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 java.util.List;
+//import java.util.stream.Collectors;
+//
+//@Component
+//public class CustomRunner implements ApplicationRunner {
+//
+// @Autowired
+// private MiloService miloService;
+// @Autowired
+// private IScOpcConfService opcConfService;
+// @Autowired
+// private IScCollectionParamConfService collectionParamConfService;
+// @Autowired
+// private IDaParamCollectionService paramCollectionService;
+// @Autowired
+// private IDaStationCollectionService stationCollectionService;
+//
+// @Override
+// public void run(ApplicationArguments args) throws Exception {
+//
+// OPCUaSubscription opcUaSubscription = new OPCUaSubscription(
+// miloService,
+// collectionParamConfService,
+// paramCollectionService,
+// stationCollectionService);
+//
+// List<String> lists = getSubList();
+// System.out.println("璁㈤槄鍐呭锛�"+lists);
+// miloService.subscriptionFromOpcUa(lists,50,opcUaSubscription);
+//
+// }
+//
+// /**
+// * 璁㈤槄鍐呭
+// */
+// public List<String> getSubList(){
+// List<String> lists = opcConfService.list(new LambdaQueryWrapper<ScOpcConf>()
+// .eq(ScOpcConf::getSubscribe,Constants.YES))
+// .stream().map(ScOpcConf::getNode).collect(Collectors.toList());
+// return lists;
+// }
+//}
+//
--
Gitblit v1.9.3