From 98a62d855284286fdcbf43118cae444d2bdcf49a Mon Sep 17 00:00:00 2001
From: wuyouming666 <2265557248@qq.com>
Date: 星期五, 08 九月 2023 16:52:12 +0800
Subject: [PATCH] 1、Plcaction.java  PlcParameter.java   改为循环外读写

---
 springboot-vue3/src/main/java/com/example/springboot/component/PlcParameter.java |  110 ++++++-----------
 CanadaMes-ui/src/views/Electrical/Parameter.vue                                  |   48 ++++---
 springboot-vue3/src/main/java/com/example/springboot/component/Plcalarm.java     |    4 
 CanadaMes-ui/src/layout/tag.vue                                                  |    2 
 CanadaMes-ui/src/layout/index.vue                                                |    8 
 springboot-vue3/src/main/java/com/example/springboot/component/Plcaction.java    |  142 ++++++++++-------------
 6 files changed, 138 insertions(+), 176 deletions(-)

diff --git a/CanadaMes-ui/src/layout/index.vue b/CanadaMes-ui/src/layout/index.vue
index 23af1e7..4e5d820 100644
--- a/CanadaMes-ui/src/layout/index.vue
+++ b/CanadaMes-ui/src/layout/index.vue
@@ -13,14 +13,14 @@
                       background-color="#222f3e" text-color="#fff" active-text-color="#ffd04b"
                       :collapse="isCollapse" :unique-opened="true"
                       :collapse-transition="false" :router="true">
-              <el-menu-item index="/" @click="goToHome">
+              <!-- <el-menu-item index="/" @click="goToHome">
                 <template slot="title">
-                  <!--鍥炬爣-->
+               
                   <i class="el-icon-menu"></i>
-                  <!--鏂囨湰-->
+                
                   <span>{{ $t('home') }}</span>
                 </template>
-              </el-menu-item>
+              </el-menu-item> -->
               <!--涓�绾ц彍鍗�-->
               <el-submenu :index="item.id.toString()" v-for="item in menuList" :key="item.id">
                 <!--涓�绾ц彍鍗曟ā鏉垮尯鍩�-->
diff --git a/CanadaMes-ui/src/layout/tag.vue b/CanadaMes-ui/src/layout/tag.vue
index 01a1b7d..63c425f 100644
--- a/CanadaMes-ui/src/layout/tag.vue
+++ b/CanadaMes-ui/src/layout/tag.vue
@@ -64,7 +64,7 @@
 
 .tag i {
   margin-left: 5px;
-  font-size: 12px;
+  font-size: 5px;
   cursor: pointer;
 }
 </style>
\ No newline at end of file
diff --git a/CanadaMes-ui/src/views/Electrical/Parameter.vue b/CanadaMes-ui/src/views/Electrical/Parameter.vue
index e9be395..d30361f 100644
--- a/CanadaMes-ui/src/views/Electrical/Parameter.vue
+++ b/CanadaMes-ui/src/views/Electrical/Parameter.vue
@@ -3,7 +3,7 @@
     <!-- 闈㈠寘灞戝鑸尯鍩� -->
     <el-breadcrumb separator-class="el-icon-arrow-right" class="el-breadcrumb">
       <router-link to="/home" tag="el-button" type="text">{{ $t('langHome') }}</router-link>
-      <el-button type="text">璁惧绠$悊</el-button>
+      <el-button type="text">Electrical</el-button>
       <router-link to="/Electrical/Parameter" tag="el-button" type="text">Parameter</router-link>
       <router-link to="/Electrical/Action" tag="el-button" type="text">Action</router-link>
       <router-link to="/Electrical/Sign" tag="el-button" type="text">Sign</router-link>
@@ -15,7 +15,8 @@
   
     <el-form label-width="100px" style="display: flex; flex-wrap: wrap;" :model="messagepack.data">
       <div id="btn_div">
-        <el-button type="primary" @click="send()">涓嬪彂鍙傛暟</el-button>
+        <el-button type="primary" @click="send()" id="xiafa"  :disabled="isButtonDisabled">涓嬪彂鍙傛暟</el-button>
+       
       </div>
       <div class="kuai_div" v-for="(item, index) in record.xyData" :key="index">
   <el-input style="width: 280px; border:none;" class="in_mc" v-model="item.name" readonly></el-input> 
@@ -65,6 +66,7 @@
  
   created() {
     this.initWebSocket();
+    this.isButtonDisabled = true;
   },
   methods: {
     initWebSocket() {
@@ -90,24 +92,30 @@
   
         // 鏀跺埌娑堟伅
         socket.onmessage = (msg) => {
-          if (!msg.data) {
-            return; // 濡傛灉鏀跺埌绌烘暟鎹紝鍒欑洿鎺ヨ繑鍥烇紝涓嶆墽琛屽悗缁�昏緫
-          }
-  
-          let obj = JSON.parse(msg.data);
-          this.record.params[0] = obj.params[0];
-  
-          for (let a = 0; a <= this.record.params[0].length - 1; a++) {
-            if (!this.record.xyData[a]) {
-              this.record.xyData[a] = { name: this.record.canshu[a], value: this.record.params[0][a] };
-            } else {
-              this.record.xyData[a].value = this.record.params[0][a];
-            }
-          }
-  
-          console.log(this.record.xyData);
-          this.$forceUpdate();
-        };
+  if (!msg.data) {
+    return; // 濡傛灉鏀跺埌绌烘暟鎹紝鍒欑洿鎺ヨ繑鍥烇紝涓嶆墽琛屽悗缁�昏緫
+  }
+
+  let obj = JSON.parse(msg.data);
+  this.record.params[0] = obj.params[0];
+  this.record.state = obj.state[0];
+
+  let isButtonDisabled = this.record.state.includes(1); 
+  // 鍒ゆ柇state涓槸鍚﹀瓨鍦�1
+  console.log(isButtonDisabled)
+  this.isButtonDisabled = isButtonDisabled; // 灏嗗垽鏂粨鏋滀繚瀛樺埌鍙橀噺isButtonDisabled涓�
+
+  for (let a = 0; a <= this.record.params[0].length - 1; a++) {
+    if (!this.record.xyData[a]) {
+      this.record.xyData[a] = { name: this.record.canshu[a], value: this.record.params[0][a] };
+    } else {
+      this.record.xyData[a].value = this.record.params[0][a];
+    }
+  }
+
+  console.log(this.record.xyData);
+  this.$forceUpdate();
+};
   
         // 鍏抽棴浜嬩欢
         socket.onclose = function () {
diff --git a/springboot-vue3/src/main/java/com/example/springboot/component/PlcParameter.java b/springboot-vue3/src/main/java/com/example/springboot/component/PlcParameter.java
index dd51397..d416822 100644
--- a/springboot-vue3/src/main/java/com/example/springboot/component/PlcParameter.java
+++ b/springboot-vue3/src/main/java/com/example/springboot/component/PlcParameter.java
@@ -1,92 +1,62 @@
 package com.example.springboot.component;
 
 import cn.hutool.json.JSONObject;
-import org.apache.shiro.authz.annotation.RequiresPermissions;
 
 import java.util.ArrayList;
 import java.util.List;
 
 public class PlcParameter extends Thread {
-    private static final int SEND_INTERVAL = 1000;
-    private static final int WRITE_INTERVAL = 100;
-
-    private short[] params = new short[]{1111, 121, 3232, 0, 1, 0, 1, 0, 1, 0, 1, 0};
-    List<Short> paramList = S7control.getinstance().ReadWord("DB100.DBW", 12);
-
-// 灏嗗垪琛ㄤ腑鐨勫�煎鍒跺埌 params 鏁扮粍涓�
-
-
     @Override
     public void run() {
-        try {
-            // 鍙戦�佷竴娆℃秷鎭�
-//            sendMessages();
-
-            // 寤惰繜涓�娈垫椂闂�
-
-
-            while (true) {
-                // 鍐欏叆PLC
-                writeToPlc();
-                Thread.sleep(WRITE_INTERVAL);
-
-                // 鍙戦�佹秷鎭�
-                sendMessages();
-                Thread.sleep(SEND_INTERVAL);
+        while (this != null) {
+            try {
+                Thread.sleep(1000);
+            } catch (InterruptedException e) {
+                e.printStackTrace();
             }
 
-        } catch (InterruptedException e) {
-            e.printStackTrace();
-        }
-    }
-
-    private void sendMessages() {
-        WebSocketServer sendwServer = WebSocketServer.sessionMap.get("Parameter");
-        if (sendwServer != null) {
+            List<Short> paramlist = S7control.getinstance().ReadWord("DB100.DBW", 12);
+            List<Short> state = S7control.getinstance().ReadWord("DB103.DBW0", 10);
             JSONObject jsonObject = new JSONObject();
-            jsonObject.append("params", params);
-            sendwServer.sendMessage(jsonObject.toString());
-        }
-    }
+            jsonObject.append("params", new short[]{1111,121, 3232, 0, 1, 0, 1, 0, 1, 0, 1, 0});
+            jsonObject.append("state", new short[]{0, 1, 0, 0, 0, 0, 0,0, 0, 0});
+            WebSocketServer sendwServer = WebSocketServer.sessionMap.get("Parameter");
+            if (sendwServer != null) {
+                sendwServer.sendMessage(jsonObject.toString());
+            }
 
-    private void writeToPlc() {
-        WebSocketServer webSocketServer = WebSocketServer.sessionMap.get("Parameter");
-        if (webSocketServer != null) {
-            List<String> messages = webSocketServer.getMessages();
+            WebSocketServer webSocketServer = WebSocketServer.sessionMap.get("Parameter");
+            if (webSocketServer != null) {
+                List<String> messages = webSocketServer.getMessages();
 
-            String addressList = "DB100.DBW0";
+                String addressList = "DB100.DBW0";
 
-            if (!messages.isEmpty()) {
-                // 灏嗘渶鍚庝竴涓秷鎭浆鎹负 short 绫诲瀷鐨勫垪琛�
-                String lastMessage = messages.get(messages.size() - 1);
-                System.out.println("messages锛�" + messages);
-                String[] parts = lastMessage.split(",");
-                List<Short> messageValues = new ArrayList<>();
-                for (String part : parts) {
-                    try {
-                        // 浣跨敤姝e垯琛ㄨ揪寮忔竻闄ら潪鏁板瓧瀛楃
-                        String cleanedPart = part.replaceAll("[^0-9-]", "");
-                        short value = Short.parseShort(cleanedPart.trim());
-                        messageValues.add(value);
-                    } catch (NumberFormatException e) {
-                        // 濡傛灉鏃犳硶瑙f瀽涓� short 绫诲瀷锛屽垯蹇界暐璇ラ儴鍒�
-                        e.printStackTrace();
+                if (!messages.isEmpty()) {
+                    // 灏嗘渶鍚庝竴涓秷鎭浆鎹负 short 绫诲瀷鐨勫垪琛�
+                    String lastMessage = messages.get(messages.size() - 1);
+                    System.out.println("messages锛�" + messages);
+                    String[] parts = lastMessage.split(",");
+                    List<Short> messageValues = new ArrayList<>();
+                    for (String part : parts) {
+                        try {
+                            // 浣跨敤姝e垯琛ㄨ揪寮忔竻闄ら潪鏁板瓧瀛楃
+                            String cleanedPart = part.replaceAll("[^0-9-]", "");
+                            short value = Short.parseShort(cleanedPart.trim());
+                            messageValues.add(value);
+                        } catch (NumberFormatException e) {
+                            // 濡傛灉鏃犳硶瑙f瀽涓� short 绫诲瀷锛屽垯蹇界暐璇ラ儴鍒�
+
+                            e.printStackTrace();
+                        }
                     }
-                }
 
-                // 鏇挎崲鍒濆鍙橀噺鐨勫��
-                for (int i = 0; i < messageValues.size(); i++) {
-                    if (i < params.length) {
-                        params[i] = messageValues.get(i);
-                    }
+                    // 灏嗘秷鎭�煎啓鍏� PLC
+                    S7control.getinstance().WriteWord(addressList, messageValues);
+                    System.out.println("messageValues锛�" + messageValues);
+                    System.out.println("addressList锛�" + addressList);
+                    // 娓呯┖娑堟伅鍒楄〃
+                    webSocketServer.clearMessages();
                 }
-
-                // 灏嗘秷鎭�煎啓鍏� PLC
-                S7control.getinstance().WriteWord(addressList, messageValues);
-                System.out.println("messageValues锛�" + messageValues);
-                System.out.println("addressList锛�" + addressList);
-                // 娓呯┖娑堟伅鍒楄〃
-                webSocketServer.clearMessages();
             }
         }
     }
diff --git a/springboot-vue3/src/main/java/com/example/springboot/component/Plcaction.java b/springboot-vue3/src/main/java/com/example/springboot/component/Plcaction.java
index bcd2cf9..5e4d59e 100644
--- a/springboot-vue3/src/main/java/com/example/springboot/component/Plcaction.java
+++ b/springboot-vue3/src/main/java/com/example/springboot/component/Plcaction.java
@@ -6,97 +6,81 @@
 import java.util.Arrays;
 import java.util.List;
 
-
 public class Plcaction extends Thread {
-  private static final long SEND_INTERVAL = 2000; // 鍙戦�佹秷鎭殑鏃堕棿闂撮殧
-  private static final long WRITE_INTERVAL = 100; // 鍐欏叆PLC鐨勬椂闂撮棿闅�
-
   @Override
   public void run() {
-    try {
-      // 鍙戦�佷竴娆℃秷鎭�
-      sendMessages();
-
-      // 寤惰繜涓�娈垫椂闂�
-      Thread.sleep(SEND_INTERVAL);
-
-      while (true) {
-        // 鍐欏叆PLC
-        writeToPlc();
-        Thread.sleep(WRITE_INTERVAL);
-
-        // 鍙戦�佹秷鎭�
-        sendMessages();
-        Thread.sleep(SEND_INTERVAL);
+    while (this != null) {
+      try {
+        Thread.sleep(1000);
+      } catch (InterruptedException e) {
+        e.printStackTrace();
       }
 
-    } catch (InterruptedException e) {
-      e.printStackTrace();
-    }
-  }
+//      List<Boolean> paramlist = S7control.getinstance().ReadBits("DB100.DBW", 12);
+////
+//      JSONObject jsonObject = new JSONObject();
+//      jsonObject.append("params", new short[]{1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 1, 0});
 
-  private void sendMessages() {
-    WebSocketServer sendwServer = WebSocketServer.sessionMap.get("action");
-    if (sendwServer != null) {
+//      List<Boolean> paramlist = S7control.getinstance().ReadBits("DB100.DBW", 12);
+      Boolean[] values = {false, true,false, true,false, true,false, true,false, true,false, true,false, true,false, true,false, true,false, true,false, true};
+      List<Boolean> paramlist = new ArrayList<>(Arrays.asList(values));
+      if (paramlist == null) {
 
-      List<Boolean> paramlist = S7control.getinstance().ReadBits("DB100.DBW", 12);
-      // new short[]{1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 1, 0,
-      // 1, 0}
-      JSONObject jsonObject = new JSONObject();
-      jsonObject.append("params",
-          new short[] { 1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 1, 0 });
+      } else {
+        short[] params = new short[paramlist.size()];
 
-      sendwServer.sendMessage(jsonObject.toString());
-    }
-
-  }
-
-  private void writeToPlc() {
-    WebSocketServer webSocketServer = WebSocketServer.sessionMap.get("action");
-    if (webSocketServer != null) {
-      List<String> messages = webSocketServer.getMessages();
-
-      String addressList = "DB100.DBW0";
-
-      if (!messages.isEmpty()) {
-        // 灏嗘渶鍚庝竴涓秷鎭浆鎹负鏁存暟绫诲瀷鐨勫垪琛�
-        String lastMessage = messages.get(messages.size() - 1);
-        System.out.println("messages锛�" + messages);
-        String[] parts = lastMessage.split(",");
-        List<Integer> messageValues = new ArrayList<>();
-        for (String part : parts) {
-          try {
-            // 浣跨敤姝e垯琛ㄨ揪寮忔竻闄ら潪鏁板瓧瀛楃
-            String cleanedPart = part.replaceAll("[^0-9-]", "");
-            Integer value = Integer.parseInt(cleanedPart.trim());
-            messageValues.add(value);
-          } catch (NumberFormatException e) {
-            // 濡傛灉鏃犳硶瑙f瀽涓烘暣鏁扮被鍨嬶紝鍒欏拷鐣ヨ閮ㄥ垎
-            e.printStackTrace();
-          }
+        for (int i = 0; i < paramlist.size(); i++) {
+          boolean value = paramlist.get(i);
+          params[i] = value ? (short) 1 : (short) 0;
         }
-
-
-        // 灏嗘秷鎭�艰浆鎹负甯冨皵鍒楄〃
-        List<Boolean> messageBooleans = new ArrayList<>();
-        for (Integer value : messageValues) {
-          messageBooleans.add(value == 0 ? true : false);
+        JSONObject jsonObject = new JSONObject();
+        jsonObject.append("params", params);
+        WebSocketServer sendwServer = WebSocketServer.sessionMap.get("action");
+        if (sendwServer != null) {
+          sendwServer.sendMessage(jsonObject.toString());
         }
+      }
 
-        // 灏嗗竷灏斿垪琛ㄥ啓鍏� PLC
-        S7control.getinstance().WriteBit(addressList, messageBooleans);
-        System.out.println("messageValues锛�" + messageBooleans);
-        System.out.println("addressList锛�" + addressList);
 
-        // 娓呯┖娑堟伅鍒楄〃
-        webSocketServer.clearMessages();
+      WebSocketServer webSocketServer = WebSocketServer.sessionMap.get("action");
+      if (webSocketServer != null) {
+
+          List<String> messages = webSocketServer.getMessages();
+
+          String addressList = "DB100.DBW0";
+
+          if (!messages.isEmpty()) {
+            // 灏嗘渶鍚庝竴涓秷鎭浆鎹负鏁存暟绫诲瀷鐨勫垪琛�
+            String lastMessage = messages.get(messages.size() - 1);
+            System.out.println("messages锛�" + messages);
+            String[] parts = lastMessage.split(",");
+            List<Integer> messageValues = new ArrayList<>();
+            for (String part : parts) {
+              try {
+                // 浣跨敤姝e垯琛ㄨ揪寮忔竻闄ら潪鏁板瓧瀛楃
+                String cleanedPart = part.replaceAll("[^0-9-]", "");
+                Integer value = Integer.parseInt(cleanedPart.trim());
+                messageValues.add(value);
+              } catch (NumberFormatException e) {
+                // 濡傛灉鏃犳硶瑙f瀽涓烘暣鏁扮被鍨嬶紝鍒欏拷鐣ヨ閮ㄥ垎
+                e.printStackTrace();
+              }
+            }
+
+            // 灏嗘秷鎭�艰浆鎹负甯冨皵鍒楄〃
+            List<Boolean> messageBooleans = new ArrayList<>();
+            for (Integer value : messageValues) {
+              messageBooleans.add(value == 0 ? true : false);
+            }
+
+            // 灏嗗竷灏斿垪琛ㄥ啓鍏� PLC
+            S7control.getinstance().WriteBit(addressList, messageBooleans);
+            System.out.println("messageValues锛�" + messageBooleans);
+            System.out.println("addressList锛�" + addressList);
+          // 娓呯┖娑堟伅鍒楄〃
+          webSocketServer.clearMessages();
+        }
       }
     }
   }
-
-  private List<Boolean> paramList() {
-    // 鑾峰彇鍙傛暟鍒楄〃鐨勯�昏緫
-
-    return new ArrayList<>(); // 鍋囪杩斿洖绌哄垪琛�
-  }
-}
\ No newline at end of file
+}
diff --git a/springboot-vue3/src/main/java/com/example/springboot/component/Plcalarm.java b/springboot-vue3/src/main/java/com/example/springboot/component/Plcalarm.java
index 3a3a9ec..9019dd1 100644
--- a/springboot-vue3/src/main/java/com/example/springboot/component/Plcalarm.java
+++ b/springboot-vue3/src/main/java/com/example/springboot/component/Plcalarm.java
@@ -91,9 +91,9 @@
       for (short i = 0; i < shuzu1.length; i++) {
         short result = alarmMapper.selectnullti(shuzu[i]);
         if (shuzu1[i] == 1 && result == 0) {
-          alarmMapper.Insertalarm(shuzu[i]);
+//          alarmMapper.Insertalarm(shuzu[i]);
         } else if (shuzu1[i] == 0 && result > 0) {
-          alarmMapper.updatealarm(shuzu[i]);
+//          alarmMapper.updatealarm(shuzu[i]);
         }
       }
 

--
Gitblit v1.8.0