From 7687eb6cc76ab8ca20b39e7567255939abc4ff66 Mon Sep 17 00:00:00 2001
From: ZengTao <2773468879@qq.com>
Date: 星期一, 29 四月 2024 09:16:24 +0800
Subject: [PATCH] 修改进片逻辑判断,添加异常捕获

---
 springboot-vue3/src/main/java/com/example/springboot/component/PlcLayout.java |   95 +++++++++++++++++++++++------------------------
 1 files changed, 46 insertions(+), 49 deletions(-)

diff --git a/springboot-vue3/src/main/java/com/example/springboot/component/PlcLayout.java b/springboot-vue3/src/main/java/com/example/springboot/component/PlcLayout.java
index 9e9128f..d95370c 100644
--- a/springboot-vue3/src/main/java/com/example/springboot/component/PlcLayout.java
+++ b/springboot-vue3/src/main/java/com/example/springboot/component/PlcLayout.java
@@ -52,65 +52,62 @@
         while (this != null) {
             try {
                 Thread.sleep(1000);
+                JSONObject jsonObject = new JSONObject();
 
-            } catch (InterruptedException e) {
-                e.printStackTrace();
-            }
-            JSONObject jsonObject = new JSONObject();
+                // 娉ㄥ叆mapper
 
-            // 娉ㄥ叆mapper
+                homeMapper = WebSocketServer.applicationContext.getBean(HomeMapper.class);
 
-            homeMapper = WebSocketServer.applicationContext.getBean(HomeMapper.class);
+                if (S7control.getinstance().CheckConnected() == true) {
 
+                    // 鏌ヨ鎶ヨ淇℃伅
+                    List<alarmmg> alarmmg = homeMapper.SelectAlarmmgInfo();
+                    jsonObject.append("alarmmg", alarmmg);
 
-            if (S7control.getinstance().CheckConnected() == true) {
-                
-            
-               
-                // 鏌ヨ鎶ヨ淇℃伅
-            List<alarmmg> alarmmg = homeMapper.SelectAlarmmgInfo();
-            jsonObject.append("alarmmg", alarmmg);
+                    // 澶嶄綅鍊掕鏃�
+                    // 鍦板潃104.9.6
+                    List<Boolean> countdown = S7control.getinstance().ReadBits("DB104.9.6", 1);
+                    for (Boolean countdowns : countdown) {
+                        jsonObject.append("countdown", countdowns);
+                    }
+                    // jsonObject.append("countdown", true);
+                    // 澶嶄綅瀹屾垚淇″彿ss
+                    List<Boolean> resetss = S7control.getinstance().ReadBits("DB103.284", 1);
+                    for (Boolean reset : resetss) {
+                        jsonObject.append("reset", reset);
+                    }
 
-                // 澶嶄綅鍊掕鏃�
-                // 鍦板潃104.9.6
-                List<Boolean> countdown = S7control.getinstance().ReadBits("DB104.9.6", 1);
-                for (Boolean countdowns : countdown) {
-                    jsonObject.append("countdown", countdowns);
-                }
-                // jsonObject.append("countdown", true);
-                // 澶嶄綅瀹屾垚淇″彿ss
-                List<Boolean> resetss = S7control.getinstance().ReadBits("DB103.284", 1);
-                for (Boolean reset : resetss) {
-                    jsonObject.append("reset", reset);
-                }
-
-                // 鏄惁鎬ュ仠
-                List<Boolean> emergencystops = S7control.getinstance().ReadBits("DB104.5.1", 1);
-                for (Boolean emergencystop : emergencystops) {
-                    jsonObject.append("emergencystop", emergencystop);
-                }
-
-            }
-
-            // jsonObject.append("params", new short[] { 30, 40, });
-            ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("Layout");
-            if (sendwServer != null) {
-                for (WebSocketServer webserver : sendwServer) {
-                    webserver.sendMessage(jsonObject.toString());
-
-                    if (webserver != null) {
-
-                        List<String> messages = webserver.getMessages();
-
-                        if (!messages.isEmpty()) {
-                            // // 灏嗘渶鍚庝竴涓秷鎭浆鎹负鏁存暟绫诲瀷鐨勫垪琛�
-                            webserver.clearMessages();
-                        }
-
+                    // 鏄惁鎬ュ仠
+                    List<Boolean> emergencystops = S7control.getinstance().ReadBits("DB104.5.1", 1);
+                    for (Boolean emergencystop : emergencystops) {
+                        jsonObject.append("emergencystop", emergencystop);
                     }
 
                 }
+
+                // jsonObject.append("params", new short[] { 30, 40, });
+                ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("Layout");
+                if (sendwServer != null) {
+                    for (WebSocketServer webserver : sendwServer) {
+                        webserver.sendMessage(jsonObject.toString());
+
+                        if (webserver != null) {
+
+                            List<String> messages = webserver.getMessages();
+
+                            if (!messages.isEmpty()) {
+                                // // 灏嗘渶鍚庝竴涓秷鎭浆鎹负鏁存暟绫诲瀷鐨勫垪琛�
+                                webserver.clearMessages();
+                            }
+
+                        }
+
+                    }
+                }
+            } catch (InterruptedException e) {
+                e.printStackTrace();
             }
+
         }
     }
 }

--
Gitblit v1.8.0