From 79f33da4df32fc139c3855a8ecca6545723e0815 Mon Sep 17 00:00:00 2001 From: wu <731351411@qq.com> Date: 星期二, 19 九月 2023 08:08:17 +0800 Subject: [PATCH] 删除不需要的代码,玻璃信息放入其他数据库 方便测试显示数据库连接的信息 --- springboot-vue3/src/main/java/com/example/springboot/component/PlcParameter.java | 65 ++++++++++++++++++++++++++++++++ 1 files changed, 65 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..d1109ac --- /dev/null +++ b/springboot-vue3/src/main/java/com/example/springboot/component/PlcParameter.java @@ -0,0 +1,65 @@ +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(500); + } catch (InterruptedException e) { + e.printStackTrace(); + } + + List<Short> arraylist = S7control.getinstance().ReadWord("DB100.0", 12); + List<Short> state = S7control.getinstance().ReadWord("DB103.0", 10); + JSONObject jsonObject = new JSONObject(); +// new short[]{1,1, 1, 1, 1, 1, 2, 33, 2,3, 4, 5} + // new short[]{0,0, 0, 0, 0, 0, 0, 0, 0, 0} + jsonObject.append("params", arraylist ); + jsonObject.append("state", state); + 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.0"; + + 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