From 1f9b919d9eabf39f388b9827f2042dca3603152c Mon Sep 17 00:00:00 2001
From: wu <731351411@qq.com>
Date: 星期四, 26 九月 2024 10:54:47 +0800
Subject: [PATCH] 更新页面和后台推送数据

---
 JiuMuMesParent/moduleService/DeviceInteractionModule/src/main/java/com/mes/job/PLCCleaning.java |   24 ++++++++++++++++--------
 1 files changed, 16 insertions(+), 8 deletions(-)

diff --git a/JiuMuMesParent/moduleService/DeviceInteractionModule/src/main/java/com/mes/job/PLCRinse.java b/JiuMuMesParent/moduleService/DeviceInteractionModule/src/main/java/com/mes/job/PLCCleaning.java
similarity index 73%
rename from JiuMuMesParent/moduleService/DeviceInteractionModule/src/main/java/com/mes/job/PLCRinse.java
rename to JiuMuMesParent/moduleService/DeviceInteractionModule/src/main/java/com/mes/job/PLCCleaning.java
index e9b21d8..6b141cc 100644
--- a/JiuMuMesParent/moduleService/DeviceInteractionModule/src/main/java/com/mes/job/PLCRinse.java
+++ b/JiuMuMesParent/moduleService/DeviceInteractionModule/src/main/java/com/mes/job/PLCCleaning.java
@@ -3,7 +3,9 @@
 import cn.hutool.json.JSONObject;
 import com.mes.common.S7object;
 import com.mes.device.PlcParameterObject;
+import com.mes.md.entity.Machine;
 import com.mes.md.entity.Tasking;
+import com.mes.md.mapper.MachineMapper;
 import com.mes.md.service.TaskingService;
 import com.mes.tools.WebSocketServer;
 import lombok.extern.slf4j.Slf4j;
@@ -20,11 +22,13 @@
  */
 @Component
 @Slf4j
-public class PLCRinse {
+public class PLCCleaning {
 
     PlcParameterObject plcParameterObject = S7object.getinstance().PlcMesObject;
     @Autowired
     TaskingService taskingService;
+    @Autowired
+    MachineMapper machineMapper;
     //@Scheduled(fixedDelay = 500)
     public void plcRinse() {
         //纾ㄨ竟绾块�熷害
@@ -35,16 +39,20 @@
         }
 
     }
-    //@Scheduled(fixedDelay = 1000)
+    @Scheduled(fixedDelay = 1000)
     public void edgingWeb() {
         //鑾峰彇鎶ヨ鐘舵��
-        String warning = plcParameterObject.getPlcParameter("rinseWarning").getValue();
         JSONObject jsonObject = new JSONObject();
-        if (!Objects.equals(warning, "0")) {
-            //log.info("鎶ヨ淇℃伅锛�"+warning);
-            jsonObject.append("rinseWarning", warning);
-        }
-        ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("rinse");
+//        String warning = plcParameterObject.getPlcParameter("rinseWarning").getValue();
+//        if (!Objects.equals(warning, "0")) {
+//            //log.info("鎶ヨ淇℃伅锛�"+warning);
+//            jsonObject.append("rinseWarning", warning);
+//        }
+        Machine machine=machineMapper.selectById(7L);
+        List<Tasking> taskingList=taskingService.findMachineTask(machine);
+        jsonObject.append("taskingList", taskingList);
+        jsonObject.append("machine", machine);
+        ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("cleaning");
         if (sendwServer != null) {
             for (WebSocketServer webserver : sendwServer) {
                 if (webserver != null) {

--
Gitblit v1.8.0