From 1d9317aaf0364cb10d365166cb7696811e14d1d2 Mon Sep 17 00:00:00 2001
From: wuyouming666 <2265557248@qq.com>
Date: 星期五, 08 九月 2023 17:22:57 +0800
Subject: [PATCH] 补充删除的文件

---
 springboot-vue3/src/main/java/com/example/springboot/component/PlcParameter.java |   63 +++++++++++++++++++++++++++++++
 1 files changed, 63 insertions(+), 0 deletions(-)

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
new file mode 100644
index 0000000..d416822
--- /dev/null
+++ b/springboot-vue3/src/main/java/com/example/springboot/component/PlcParameter.java
@@ -0,0 +1,63 @@
+package com.example.springboot.component;
+
+import cn.hutool.json.JSONObject;
+
+import java.util.ArrayList;
+import java.util.List;
+
+public class PlcParameter extends Thread {
+    @Override
+    public void run() {
+        while (this != null) {
+            try {
+                Thread.sleep(1000);
+            } catch (InterruptedException e) {
+                e.printStackTrace();
+            }
+
+            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", 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());
+            }
+
+            WebSocketServer webSocketServer = WebSocketServer.sessionMap.get("Parameter");
+            if (webSocketServer != null) {
+                List<String> messages = webSocketServer.getMessages();
+
+                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();
+                        }
+                    }
+
+                    // 灏嗘秷鎭�煎啓鍏� PLC
+                    S7control.getinstance().WriteWord(addressList, messageValues);
+                    System.out.println("messageValues锛�" + messageValues);
+                    System.out.println("addressList锛�" + addressList);
+                    // 娓呯┖娑堟伅鍒楄〃
+                    webSocketServer.clearMessages();
+                }
+            }
+        }
+    }
+}

--
Gitblit v1.8.0