From 8d58c40af40493bd5f066cbfdb1ffd9f113c22fc Mon Sep 17 00:00:00 2001
From: 严智鑫 <test>
Date: 星期三, 03 九月 2025 16:37:21 +0800
Subject: [PATCH] 1.前端推数据使用了最新的webSokect客户现场总是掉线,修改为接口方式 2.设备交互整体增加异常处理以及PLC连接方式改为短连接

---
 JiuMuMesParent/moduleService/DeviceInteractionModule/src/main/java/com/mes/yield/service/impl/YieldServiceImpl.java |   12 ++++--------
 1 files changed, 4 insertions(+), 8 deletions(-)

diff --git a/JiuMuMesParent/moduleService/DeviceInteractionModule/src/main/java/com/mes/yield/service/impl/YieldServiceImpl.java b/JiuMuMesParent/moduleService/DeviceInteractionModule/src/main/java/com/mes/yield/service/impl/YieldServiceImpl.java
index 43ece60..74b3492 100644
--- a/JiuMuMesParent/moduleService/DeviceInteractionModule/src/main/java/com/mes/yield/service/impl/YieldServiceImpl.java
+++ b/JiuMuMesParent/moduleService/DeviceInteractionModule/src/main/java/com/mes/yield/service/impl/YieldServiceImpl.java
@@ -1,18 +1,14 @@
 package com.mes.yield.service.impl;
 
-import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import cn.hutool.json.JSONObject;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.mes.websocket.WebSocketServer;
 import com.mes.yield.entity.Yield;
 import com.mes.yield.mapper.YieldMapper;
 import com.mes.yield.service.YieldService;
-import com.mes.tools.WebSocketServer;
-import cn.hutool.json.JSONObject;
 import org.springframework.stereotype.Service;
 
-import java.time.LocalDateTime;
-import java.util.ArrayList;
 import java.util.List;
-import java.util.Map;
 
 @Service
 public class YieldServiceImpl extends ServiceImpl<YieldMapper, Yield> implements YieldService {
@@ -23,10 +19,10 @@
         message.set("type", "yield_update");
         message.set("data", yield);
 
-        ArrayList<WebSocketServer> servers = WebSocketServer.sessionMap.get("yield");
+        List<WebSocketServer> servers = WebSocketServer.SESSIONMAP.get("yield");
         if (servers != null) {
             for (WebSocketServer server : servers) {
-                server.sendMessage(message.toString());
+                server.sendToWeb("",message.toString());
             }
         }
     }

--
Gitblit v1.8.0