From 2c2413760b6467bf62402dba7338bd3bbcbd7341 Mon Sep 17 00:00:00 2001
From: huang <1532065656@qq.com>
Date: 星期二, 20 五月 2025 14:20:38 +0800
Subject: [PATCH] 添加产量报表功能页面

---
 JiuMuMesParent/moduleService/DeviceInteractionModule/src/main/java/com/mes/job/PLCCleaning.java |   61 ++++++++++++++++++++----------
 1 files changed, 40 insertions(+), 21 deletions(-)

diff --git a/JiuMuMesParent/moduleService/DeviceInteractionModule/src/main/java/com/mes/job/PLCCleaning.java b/JiuMuMesParent/moduleService/DeviceInteractionModule/src/main/java/com/mes/job/PLCCleaning.java
index 6b141cc..3c04855 100644
--- a/JiuMuMesParent/moduleService/DeviceInteractionModule/src/main/java/com/mes/job/PLCCleaning.java
+++ b/JiuMuMesParent/moduleService/DeviceInteractionModule/src/main/java/com/mes/job/PLCCleaning.java
@@ -1,7 +1,12 @@
 package com.mes.job;
 
 import cn.hutool.json.JSONObject;
+import com.github.xingshuangs.iot.protocol.s7.enums.EPlcType;
 import com.mes.common.S7object;
+import com.mes.common.S7objectCleaning;
+import com.mes.common.S7objectMachine;
+import com.mes.common.S7objectMarking;
+import com.mes.device.PlcParameterInfo;
 import com.mes.device.PlcParameterObject;
 import com.mes.md.entity.Machine;
 import com.mes.md.entity.Tasking;
@@ -24,30 +29,40 @@
 @Slf4j
 public class PLCCleaning {
 
-    PlcParameterObject plcParameterObject = S7object.getinstance().PlcMesObject;
+    PlcParameterObject plcParameterObject =null;
     @Autowired
     TaskingService taskingService;
     @Autowired
     MachineMapper machineMapper;
-    //@Scheduled(fixedDelay = 500)
-    public void plcRinse() {
-        //纾ㄨ竟绾块�熷害
-        String edgingSpeed = plcParameterObject.getPlcParameter("edgingSpeed").getValue();
-        if(!Objects.equals(edgingSpeed, "")){
-            //缁欐竻娲楁満鍣ㄥ彂閫佺(杈规満閫熷害
-            S7object.getinstance().plccontrol.writeWord(plcParameterObject.getPlcParameter("rinseSpeed").getAddress(), Integer.parseInt(edgingSpeed));
-        }
+    public S7objectMachine s7objectMachine;
 
+    //@Scheduled(fixedDelay = 500)
+    public void cleaning() {
+        //纾ㄨ竟绾块�熷害  10.36.164.200
+        Long machineId=8L;
+        Machine machine=machineMapper.selectById(machineId);
+        if (s7objectMachine==null){
+            s7objectMachine=new S7objectMachine(machine.getIp(),machine.getPort(),"PlcCleaning", EPlcType.S200_SMART);
+            s7objectMachine.start();
+        }
+        PlcParameterObject plcParameterObject = s7objectMachine.PlcMesObject;
+        PlcParameterInfo edgSpeed =plcParameterObject.getPlcParameter("edgSpeed");//纾ㄨ竟鏈洪�熷害
+        PlcParameterInfo thinness =plcParameterObject.getPlcParameter("thinness");//鍘氬害
+        if (machine.getIsLog()>0){
+            s7objectMachine.consoleLogInfo();
+        }
+        int edgSpeedInt=0;
+        int edgThinnessInt=0;
+        if(!(edgSpeedInt+"").equals(edgSpeed.getValue())||!(edgThinnessInt+"").equals(thinness.getValue())){
+            //缁欐竻娲楁満鍣ㄥ彂閫佺(杈规満閫熷害
+            S7objectCleaning.getinstance().plccontrol.writeWord(edgSpeed.getAddress(), edgSpeedInt);
+            S7objectCleaning.getinstance().plccontrol.writeWord(thinness.getAddress(), edgThinnessInt);
+        }
     }
-    @Scheduled(fixedDelay = 1000)
-    public void edgingWeb() {
+    //@Scheduled(fixedDelay = 1000)
+    public void cleaningTask() {
         //鑾峰彇鎶ヨ鐘舵��
         JSONObject jsonObject = new JSONObject();
-//        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);
@@ -56,11 +71,15 @@
         if (sendwServer != null) {
             for (WebSocketServer webserver : sendwServer) {
                 if (webserver != null) {
-                    webserver.sendMessage(jsonObject.toString());
-                    List<String> messages = webserver.getMessages();
-                    if (!messages.isEmpty()) {
-                        // // 灏嗘渶鍚庝竴涓秷鎭浆鎹负鏁存暟绫诲瀷鐨勫垪琛�
-                        webserver.clearMessages();
+                    try {
+                        webserver.sendMessage(jsonObject.toString());
+                        List<String> messages = webserver.getMessages();
+                        if (!messages.isEmpty()) {
+                            // // 灏嗘渶鍚庝竴涓秷鎭浆鎹负鏁存暟绫诲瀷鐨勫垪琛�
+                            webserver.clearMessages();
+                        }
+                    }catch (Exception e) {
+
                     }
                 } else {
                     log.info("Home is closed");

--
Gitblit v1.8.0