From a4bf9d00069a557088f38d88c71e52726f303f7d Mon Sep 17 00:00:00 2001
From: zhangc <zc@123>
Date: 星期五, 11 四月 2025 13:40:54 +0800
Subject: [PATCH] 1
---
src/main/java/com/zy/core/thread/impl/FyDevpThread.java | 5 +++--
1 files changed, 3 insertions(+), 2 deletions(-)
diff --git a/src/main/java/com/zy/core/thread/impl/FyDevpThread.java b/src/main/java/com/zy/core/thread/impl/FyDevpThread.java
index 3625152..2461f15 100644
--- a/src/main/java/com/zy/core/thread/impl/FyDevpThread.java
+++ b/src/main/java/com/zy/core/thread/impl/FyDevpThread.java
@@ -78,7 +78,7 @@
@Override
@SuppressWarnings("InfiniteLoopStatement")
public void run() {
-// connect();
+ connect();
while (true) {
try {
int step = 1;
@@ -185,6 +185,8 @@
OutputQueue.DEVP.offer(MessageFormat.format("銆恵0}銆慬id:{1}] <<<<< 瀹炴椂鏁版嵁鏇存柊鎴愬姛", DateUtils.convert(new Date()), slave.getId()));
// 鏍规嵁瀹炴椂淇℃伅鏇存柊鏁版嵁搴�
try {
+ BasDevpService basConveyorStaService = SpringUtils.getBean(BasDevpService.class);
+
List<BasDevp> stations = new ArrayList<>();
for (Integer sta : staNos2) {
StaProtocol staProtocol = station.get(sta);
@@ -192,7 +194,6 @@
stations.add(sqlModel);
}
if (!stations.isEmpty()) {
- BasDevpService basConveyorStaService = SpringUtils.getBean(BasDevpService.class);
if (null != basConveyorStaService && !basConveyorStaService.updateBatchById(stations)) {
throw new Exception("鏇存柊鏁版嵁搴撴暟鎹け璐�");
}
--
Gitblit v1.9.1