From 54fc241d1a44ec21a6994ce0ae37ec7b22d3e748 Mon Sep 17 00:00:00 2001
From: 1 <1>
Date: 星期四, 09 十月 2025 16:46:09 +0800
Subject: [PATCH] #和得服务器

---
 src/main/java/com/zy/core/thread/SiemensDevpThread.java |   27 +++++++++++++++++++++++++++
 1 files changed, 27 insertions(+), 0 deletions(-)

diff --git a/src/main/java/com/zy/core/thread/SiemensDevpThread.java b/src/main/java/com/zy/core/thread/SiemensDevpThread.java
index 8a804a7..45dafed 100644
--- a/src/main/java/com/zy/core/thread/SiemensDevpThread.java
+++ b/src/main/java/com/zy/core/thread/SiemensDevpThread.java
@@ -10,9 +10,13 @@
 import com.core.common.SpringUtils;
 import com.core.exception.CoolException;
 import com.zy.asrs.entity.BasDevp;
+import com.zy.asrs.entity.BasDevpOpt;
 import com.zy.asrs.entity.BasRgvMap;
+import com.zy.asrs.entity.BasRgvOpt;
+import com.zy.asrs.service.BasDevpOptService;
 import com.zy.asrs.service.BasDevpService;
 import com.zy.asrs.service.BasRgvMapService;
+import com.zy.asrs.service.BasRgvOptService;
 import com.zy.common.utils.News;
 import com.zy.core.DevpThread;
 import com.zy.core.cache.MessageQueue;
@@ -558,6 +562,29 @@
                 log.error("鍐欏叆杈撻�佺嚎鍛戒护澶辫触銆傝緭閫佺嚎plc缂栧彿={}锛岀珯鐐规暟鎹�={},鍐欏叆娆℃暟={}", slave.getId(), JSON.toJSON(staProtocol), writeCount);
             }
         }while (writeCount<5);
+        try {
+            // 鏃ュ織璁板綍
+            BasDevpOptService bean = SpringUtils.getBean(BasDevpOptService.class);
+            BasDevpOpt basDevpOpt = new BasDevpOpt(
+                    staProtocol.getWorkNo(),
+                    new Date(),
+                    staProtocol.getSiteId(),
+                    (int)staProtocol.getStaNo(),
+                    new Date(),
+                    String.valueOf(staProtocol.isLoading()),
+                    staProtocol.getBarcode(),
+                    staProtocol.isFrontErr()? 1L:0L,
+                    staProtocol.isBackErr()? 1L:0L,
+                    staProtocol.isHighErr()? 1L:0L,
+                    staProtocol.isLeftErr()? 1L:0L,
+                    staProtocol.isRightErr()? 1L:0L,
+                    staProtocol.isBarcodeErr()? 1L:0L
+
+            );
+            bean.insert(basDevpOpt);
+        } catch (Exception ignore) {
+            log.error(ignore.getMessage());
+        }
 
         if (!write.IsSuccess) {
             staProtocol = station.get(staProtocol.getSiteId());

--
Gitblit v1.9.1