From 5d1df2b22fd4e0b31f80385664393cd3d73a21ed Mon Sep 17 00:00:00 2001
From: lsh <lsh@163.com>
Date: 星期二, 19 八月 2025 09:58:39 +0800
Subject: [PATCH] *
---
src/main/java/com/zy/core/thread/RgvThread.java | 39 ++++++++++++++-------------------------
1 files changed, 14 insertions(+), 25 deletions(-)
diff --git a/src/main/java/com/zy/core/thread/RgvThread.java b/src/main/java/com/zy/core/thread/RgvThread.java
index 3a0abbd..bc3d44d 100644
--- a/src/main/java/com/zy/core/thread/RgvThread.java
+++ b/src/main/java/com/zy/core/thread/RgvThread.java
@@ -13,6 +13,7 @@
import com.zy.asrs.service.BasRgvErrLogService;
import com.zy.asrs.service.BasRgvOptService;
import com.zy.asrs.service.BasRgvService;
+import com.zy.asrs.utils.NumUtils;
import com.zy.core.ThreadHandler;
import com.zy.core.cache.MessageQueue;
import com.zy.core.cache.OutputQueue;
@@ -223,31 +224,19 @@
rgvProtocol.setxDistance((short) 0);
rgvProtocol.setxDuration((short) 0);
log.error("杩炴帴涓柇锛歊GV鍙凤細"+slave.getId());
+ try {
+ // 鏍规嵁瀹炴椂淇℃伅鏇存柊鏁版嵁搴�
+ BasRgvService basRgvService = SpringUtils.getBean(BasRgvService.class);
+ BasRgv basRgv = new BasRgv();
+ basRgv.setRgvNo(slave.getId());
+ basRgv.setRgvSts((int)rgvProtocol.getMode());
+ basRgv.setLoaded2(rgvProtocol.getLoaded2().intValue());
+ if (!basRgvService.updateById(rgvProtocol.toSqlModel(basRgv))){
+ log.error("RGV plc鏁版嵁搴撴洿鏂板け璐� ===>> [id:{}] [ip:{}] [port:{}] [rack:{}] [slot:{}]", slave.getId(), slave.getIp(), slave.getPort(), slave.getRack(), slave.getSlot());
+ }
+ } catch (Exception ignore) {
+ }
}
-
-// /**
-// * 鍒濆鍖朢GV鐘舵��
-// */
-// private void initRgv() {
-// if (null == rgvProtocol) {
-// rgvProtocol = new RgvProtocol();
-// }
-// rgvProtocol.setRgvNo(slave.getId());
-// rgvProtocol.setMode((short) 3);
-// rgvProtocol.setStatus((short)0);
-// rgvProtocol.setTaskNo1((short)0);
-// rgvProtocol.setStatus1((short)0);
-// rgvProtocol.setLoaded1((short)0);
-// rgvProtocol.setWalkPos((short)0);
-// rgvProtocol.setRgvPos(slave.getId()*100000L);
-// rgvProtocol.setTaskNo2((short)0);
-// rgvProtocol.setStatus2((short)0);
-// rgvProtocol.setLoaded2((short)0);
-// rgvProtocol.setAlarm((short)0);
-// rgvProtocol.setxSpeed((short) 0);
-// rgvProtocol.setxDistance((short) 0);
-// rgvProtocol.setxDuration((short) 0);
-// }
@Override
public boolean connect() {
@@ -311,7 +300,7 @@
alarmChangeSign = new HashSet<>(alarmList).equals(new HashSet<>(rgvProtocol.getAlarmList()));
rgvProtocol.setAlarmList(alarmList);
-// rgvProtocol.setRgvPos((long)NumUtils.GetRandomIntInRange(1737000));
+// rgvProtocol.setRgvPos((long) NumUtils.GetRandomIntInRange(1737000));
OutputQueue.RGV.offer(MessageFormat.format("銆恵0}銆慬id:{1}] <<<<< 瀹炴椂鏁版嵁鏇存柊鎴愬姛",DateUtils.convert(new Date()), slave.getId()));
--
Gitblit v1.9.1