From 1632ba92d37e43baf671f7d465b67d644d545cf5 Mon Sep 17 00:00:00 2001 From: ZengTao <2773468879@qq.com> Date: 星期三, 03 一月 2024 08:06:57 +0800 Subject: [PATCH] 测试更新,添加出片队列排序 --- springboot-vue3/src/main/java/com/example/springboot/component/PlcParameter.java | 67 ++++++++++++++++++--------------- 1 files changed, 37 insertions(+), 30 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 0399888..c049feb 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 @@ -78,7 +78,7 @@ // Integer Plccount = this.count; // System.out.println(stt); - List<Short> arraylist = S7control.getinstance().ReadWord("DB100.0", 72); + List<Short> arraylist = S7control.getinstance().ReadWord("DB100.0", 60); List<Short> state = S7control.getinstance().ReadWord("DB103.0", 10); // Short[] values1 = { 1231, 1, 1, 1, 1, 1, 2, 33, 2, 3, 4, 5 ,1231, 1, 1, 1, 1, 1, 2, 33, 2, 3, 4, 5 }; // List<Short> arraylist = new ArrayList<>(Arrays.asList(values1)); @@ -106,42 +106,49 @@ jsonObject.append("params", arraylist); jsonObject.append("state", state); // jsonObject.append("action", sholist); - WebSocketServer sendwServer = WebSocketServer.sessionMap.get("Parameter"); +// WebSocketServer sendwServer = WebSocketServer.sessionMap.get("Parameter"); +// if (sendwServer != null) { +// sendwServer.sendMessage(jsonObject.toString()); +// } + + ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("Parameter"); if (sendwServer != null) { - sendwServer.sendMessage(jsonObject.toString()); - } + for (WebSocketServer webserver : sendwServer) { + webserver.sendMessage(jsonObject.toString()); - WebSocketServer webSocketServer = WebSocketServer.sessionMap.get("Parameter"); - if (webSocketServer != null) { - List<String> messages = webSocketServer.getMessages(); +// WebSocketServer webSocketServer = WebSocketServer.sessionMap.get("Parameter"); + if (webserver != null) { + List<String> messages = webserver.getMessages(); - String addressList = "DB100.0"; + 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 绫诲瀷锛屽垯蹇界暐璇ラ儴鍒� + 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(); + e.printStackTrace(); + } + } + + // 灏嗘秷鎭�煎啓鍏� PLC + S7control.getinstance().WriteWord(addressList, messageValues); + System.out.println("messageValues锛�" + messageValues); + System.out.println("addressList锛�" + addressList); + // 娓呯┖娑堟伅鍒楄〃 + webserver.clearMessages(); } } - - // 灏嗘秷鎭�煎啓鍏� PLC - S7control.getinstance().WriteWord(addressList, messageValues); - System.out.println("messageValues锛�" + messageValues); - System.out.println("addressList锛�" + addressList); - // 娓呯┖娑堟伅鍒楄〃 - webSocketServer.clearMessages(); } } } -- Gitblit v1.8.0