From 80313593ea0f369d4ad6e28d5c9a1686817f7199 Mon Sep 17 00:00:00 2001
From: zhou zhou <3272660260@qq.com>
Date: 星期六, 27 九月 2025 14:33:10 +0800
Subject: [PATCH] #websocket
---
src/main/java/com/zy/asrs/webSocketConfig/LedWebsocket.java | 14 ++++++++++++++
1 files changed, 14 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/zy/asrs/webSocketConfig/LedWebsocket.java b/src/main/java/com/zy/asrs/webSocketConfig/LedWebsocket.java
index 9903216..5bf1e52 100644
--- a/src/main/java/com/zy/asrs/webSocketConfig/LedWebsocket.java
+++ b/src/main/java/com/zy/asrs/webSocketConfig/LedWebsocket.java
@@ -44,6 +44,8 @@
private WrkDetlService wrkDetlService;
@Autowired
private OrderDetlService orderDetlService;
+ @Autowired
+ private RedisUtil redisUtil;
@Scheduled(cron = "0/2 * * * * ? ")
private void send() {
@@ -158,8 +160,14 @@
if (basDevp == null ){
return;
}
+ String key = "wms_websocket_error";
+ Object object = redisUtil.get(key);
+ if (null != object && object.equals(basDevp.getDecDesc())){
+ return;
+ }
map.put("message",Cools.add("type", "error").add("errMsg",basDevp.getDecDesc()));
webSocketServer.onMessage(JSONObject.toJSONString(map),null,"1002");
+ redisUtil.set(key,basDevp.getDecDesc());
}
@@ -171,6 +179,11 @@
if (basDevp == null ){
return;
}
+ String key = "wms_websocket_task";
+ Object object = redisUtil.get(key);
+ if (null != object && object.equals(basDevp.getWrkNo())){
+ return;
+ }
List<LedCommand> commandList = new ArrayList<>();
if (basDevp.getWrkNo() != 0){
WrkMast wrkMast = wrkMastService.selectOne(new EntityWrapper<WrkMast>().eq("wrk_no", basDevp.getWrkNo()));
@@ -180,6 +193,7 @@
}
map.put("message",Cools.add("type", "task").add("taskList",commandList));
webSocketServer.onMessage(JSONObject.toJSONString(map),null,"1002");
+ redisUtil.set(key,basDevp.getWrkNo());
}
public List<LedCommand> getCommandList(String taskNo){
--
Gitblit v1.9.1