From d043c31bbd34a01d6b3ab3f16e9404a7aca0bae4 Mon Sep 17 00:00:00 2001 From: ZengTao <2773468879@qq.com> Date: 星期三, 13 九月 2023 17:27:52 +0800 Subject: [PATCH] Merge branch 'master' of http://10.153.19.25:10101/r/CanadaMes --- springboot-vue3/src/main/java/com/example/springboot/component/PlcParameter.java | 112 +++++++++++++++++++++++++------------------------------ 1 files changed, 51 insertions(+), 61 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 index 47fd8f5..865c95f 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 @@ -6,70 +6,60 @@ import java.util.List; public class PlcParameter extends Thread { - @Override - public void run() { - while (this != null) { - try { - Thread.sleep(10000); - } catch (InterruptedException e) { - e.printStackTrace(); - } - - List<Short> paramlist = S7control.getinstance().ReadWord("DB100.DBW", 12); - - JSONObject jsonObject = new JSONObject(); - // jsonObject.append("params", paramlist); - jsonObject.append("params", new short[] { 0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, }); - 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"; - // addressList.add("DB100.DBW0"); - // addressList.add("DB100.DBW2"); - // addressList.add("DB100.DBW4"); - // addressList.add("DB100.DBW6"); - // addressList.add("DB100.DBW8"); - // addressList.add("DB100.DBW10"); - // addressList.add("DB100.DBW12"); - // addressList.add("DB100.DBW14"); - // addressList.add("DB100.DBW16"); - // addressList.add("DB100.DBW18"); - // addressList.add("DB100.DBW20"); - // addressList.add("DB100.DBW22"); - - 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) { + @Override + public void run() { + while (this != null) { try { - // 浣跨敤姝e垯琛ㄨ揪寮忔竻闄ら潪鏁板瓧瀛楃 - String cleanedPart = part.replaceAll("[^0-9-]", ""); - short value = Short.parseShort(cleanedPart.trim()); - messageValues.add(value); - } catch (NumberFormatException e) { - // 濡傛灉鏃犳硶瑙f瀽涓� short 绫诲瀷锛屽垯蹇界暐璇ラ儴鍒� - - e.printStackTrace(); + Thread.sleep(1000); + } catch (InterruptedException e) { + e.printStackTrace(); } - } - // 灏嗘秷鎭�煎啓鍏� PLC - // S7control.getinstance().WriteWord(addressList, messageValues); - System.out.println("messageValues锛�" + messageValues); - System.out.println("addressList锛�" + addressList); - // 娓呯┖娑堟伅鍒楄〃 - webSocketServer.clearMessages(); + List<Short> arraylist = S7control.getinstance().ReadWord("DB100.DBW0", 12); + List<Short> state = S7control.getinstance().ReadWord("DB103.DBW0", 10); + JSONObject jsonObject = new JSONObject(); +// new short[]{65545,65545, 65545, 65545, 65545, 65545, 65545, 65545, 65545,65545, 65545, 65545} + // new short[]{65545,65545, 65545, 65545, 65545, 65545, 65545, 65545, 65545, 65545} + 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.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