From 71848bcfc8b64663e5b0e3f80c70d3d4801c0bb4 Mon Sep 17 00:00:00 2001
From: Junjie <540245094@qq.com>
Date: 星期三, 22 十月 2025 09:50:39 +0800
Subject: [PATCH] #
---
src/main/java/com/zy/core/thread/SiemensDevpThread.java | 35 +++++++++++++++++++++++++++++------
1 files changed, 29 insertions(+), 6 deletions(-)
diff --git a/src/main/java/com/zy/core/thread/SiemensDevpThread.java b/src/main/java/com/zy/core/thread/SiemensDevpThread.java
index 3643134..4afe80f 100644
--- a/src/main/java/com/zy/core/thread/SiemensDevpThread.java
+++ b/src/main/java/com/zy/core/thread/SiemensDevpThread.java
@@ -10,7 +10,9 @@
import com.core.common.SpringUtils;
import com.core.exception.CoolException;
import com.zy.asrs.entity.BasDevp;
+import com.zy.asrs.entity.DeviceDataLog;
import com.zy.asrs.service.BasDevpService;
+import com.zy.asrs.service.DeviceDataLogService;
import com.zy.common.utils.News;
import com.zy.core.DevpThread;
import com.zy.core.cache.MessageQueue;
@@ -25,10 +27,7 @@
import lombok.extern.slf4j.Slf4j;
import java.text.MessageFormat;
-import java.util.ArrayList;
-import java.util.Date;
-import java.util.List;
-import java.util.Map;
+import java.util.*;
import java.util.concurrent.ConcurrentHashMap;
/**
@@ -44,6 +43,11 @@
private Map<Integer, StaProtocol> station = new ConcurrentHashMap<>();
private short heartBeatVal = 1;
+ /**
+ * 鏃ュ織閲囬泦鏃堕棿
+ */
+ private Long deviceDataLogTime = System.currentTimeMillis();
+
public static final ArrayList<Integer> staNos1 = new ArrayList<Integer>() {{
add(1008);add(1009);add(1010);add(1011);add(1012);add(1013);add(1014);add(1015);
add(1016);add(1017);add(1018);add(1019);add(1020);add(1021);add(1022);add(1023);
@@ -55,11 +59,11 @@
add(1064);add(1065);add(1066);add(1067);add(1068);add(1069);add(1070);add(1071);
add(1072);add(1073);add(1074);add(1075);add(1076);add(1077);add(1078);add(1079);
add(1080);add(1081);add(1082);add(1083);add(1084);add(1085);add(1086);add(1087);
- add(1088);add(1089);add(1090);
+ add(1088);add(1089);add(1090);add(2003);
}};
public static final ArrayList<Integer> staNos2 = new ArrayList<Integer>() {{
- add(2001);add(2002);add(2003);add(2004);
+ add(2000);add(2001);add(2002);add(1001);add(1002);add(1003);add(1004);add(1005);add(1006);add(1007);
}};
@@ -245,6 +249,9 @@
staProtocol.setWeightError(statusError[5]); // 瓒呴噸鎶ヨ
staProtocol.setBarcodeError(statusError[6]); // 鎵爜鎶ヨ
+ short emptyInType = siemensS7Net.getByteTransform().TransInt16(result.Content, (i * 18) + 14);//棰勭暀1-绌烘墭鍏ュ簱绫诲瀷锛�1:绔嬪簱鏂瑰悜 2:浜х嚎鏂瑰悜
+ staProtocol.setEmptyInType(emptyInType);
+
if (!staProtocol.isPakMk() && !staProtocol.isLoading()) {
staProtocol.setPakMk(true);
}
@@ -268,6 +275,22 @@
}
+ if (System.currentTimeMillis() - deviceDataLogTime > 1000 * 1) {
+ //閲囬泦鏃堕棿瓒呰繃5s锛屼繚瀛樹竴娆℃暟鎹褰�
+ //淇濆瓨鏁版嵁璁板綍
+ DeviceDataLogService deviceDataLogService = SpringUtils.getBean(DeviceDataLogService.class);
+ DeviceDataLog deviceDataLog = new DeviceDataLog();
+ deviceDataLog.setOriginData(Base64.getEncoder().encodeToString(result.Content));
+ deviceDataLog.setWcsData(JSON.toJSONString(station));
+ deviceDataLog.setType("devp");
+ deviceDataLog.setDeviceNo(slave.getId());
+ deviceDataLog.setCreateTime(new Date());
+ deviceDataLogService.insert(deviceDataLog);
+
+ //鏇存柊閲囬泦鏃堕棿
+ deviceDataLogTime = System.currentTimeMillis();
+ }
+
if (result.IsSuccess && result2.IsSuccess) {
OutputQueue.DEVP.offer(MessageFormat.format("銆恵0}銆慬id:{1}] <<<<< 瀹炴椂鏁版嵁鏇存柊鎴愬姛",DateUtils.convert(new Date()), slave.getId()));
--
Gitblit v1.9.1