From ad71edbf0f9d2cf2bc46cd2ba1e0239f80949e68 Mon Sep 17 00:00:00 2001 From: wuyouming666 <2265557248@qq.com> Date: 星期四, 21 十二月 2023 15:12:56 +0800 Subject: [PATCH] 增加清除id调用终止出片任务 --- springboot-vue3/src/main/java/com/example/springboot/component/PlcParameter2.java | 141 ++++++++++++++++++++++++++++++++++++++++++++++- 1 files changed, 138 insertions(+), 3 deletions(-) diff --git a/springboot-vue3/src/main/java/com/example/springboot/component/PlcParameter2.java b/springboot-vue3/src/main/java/com/example/springboot/component/PlcParameter2.java index 3033682..73192ce 100644 --- a/springboot-vue3/src/main/java/com/example/springboot/component/PlcParameter2.java +++ b/springboot-vue3/src/main/java/com/example/springboot/component/PlcParameter2.java @@ -2,13 +2,19 @@ import cn.hutool.json.JSONArray; import cn.hutool.json.JSONObject; +import com.example.springboot.controller.HomeController; import org.apache.commons.io.FileUtils; +import org.springframework.beans.factory.annotation.Autowired; import java.io.*; import java.util.ArrayList; import java.util.Arrays; import java.util.Collections; import java.util.List; + + + + public class PlcParameter2 extends Thread { @@ -121,7 +127,7 @@ // jsonObject.set("message", "Hello, Parameter2!"); // sendwServer.sendMessage(jsonObject.toString()); // } - + HomeController controller = new HomeController(); ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("Parameter2"); if (sendwServer != null) { for (WebSocketServer webserver : sendwServer) { @@ -140,9 +146,138 @@ // System.out.println("lastMessage锛�" + lastMessage); JSONArray messageArray = new JSONArray(lastMessage); //娓呴櫎ID - customS7Control.writeBitToPLC(messageArray, addressList0, 0); + // customS7Control.writeBitToPLC(messageArray, addressList0, 0); + + + try { + // 妫�鏌ョ储寮曟槸鍚︽湁鏁� + if (messageArray.getJSONArray(0).size() > 0) { + // 鑾峰彇娑堟伅鏁扮粍 + JSONArray jsonArray = messageArray.getJSONArray(0); + // 鍒涘缓涓�涓竷灏斿�煎垪琛� + List<Boolean> sValue = new ArrayList<>(); + // 閬嶅巻娑堟伅鏁扮粍 + for (int i = 0; i < jsonArray.size(); i++) { + // 鑾峰彇娑堟伅鏁扮粍涓殑鍊� + Object value = jsonArray.get(i); + // 妫�鏌ュ�兼槸鍚︽湁鏁� + if (value != null && !value.toString().equals("null")) { + try { + // 绉婚櫎闈炴暟瀛楀拰鏁板瓧瀛楃 + String cleanedValue = value.toString().replaceAll("[^0-9-]", ""); + // 瑙f瀽涓哄竷灏斿�� + boolean val = "1".equals(cleanedValue.trim()); + // 灏嗗竷灏斿�兼坊鍔犲埌甯冨皵鍊煎垪琛ㄤ腑 + sValue.add(val); + System.out.println("messageValue: " + Arrays.asList(val) + " added to the list"); + + + + + + + } catch (NumberFormatException e) { + // 濡傛灉鏃犳硶瑙f瀽涓� boolean 绫诲瀷锛屽垯蹇界暐璇ラ儴鍒� + System.err.println("Could not parse value: " + value); + } + } + } + + for (int i = 1; i <= 5; i++) { + boolean value = sValue.get(i); + if (value) { + switch (i) { + case 1: + controller.UpdateTask(0, 0, paramlist.get(i)); + break; + case 2: + case 3: + case 4: + case 5: + controller.UpdateTask(1, 0, paramlist.get(i)); + break; + default: + // 澶勭悊绱㈠紩鍊间笉鍦ㄨ寖鍥村唴鐨勬儏鍐� + break; + } + } + } + + // 妫�鏌ュ竷灏斿�煎垪琛ㄦ槸鍚︿负绌� + if (!sValue.isEmpty()) { + + // 璋冪敤 S7control.getinstance().WriteBit 鏂规硶灏嗗竷灏斿�煎垪琛ㄥ啓鍏ュ湴鍧�鍒楄〃 + S7control.getinstance().WriteBit(addressList0, sValue); + System.out.println("Values " + sValue + " written to PLC at address " + addressList0); + } + } + } catch (Exception e) { + System.err.println("An error occurred while writing bit to PLC: " + e.getMessage()); + } + + + + + //鎬ュ仠 - customS7Control.writeBitToPLC(messageArray, niuanaddressList3, 1); +// customS7Control.writeBitToPLC(messageArray, niuanaddressList3, 1); + + try { + // 妫�鏌ョ储寮曟槸鍚︽湁鏁� + if (messageArray.getJSONArray(1).size() > 0) { + // 鑾峰彇娑堟伅鏁扮粍 + JSONArray jsonArray = messageArray.getJSONArray(1); + // 鍒涘缓涓�涓竷灏斿�煎垪琛� + List<Boolean> sValue = new ArrayList<>(); + // 閬嶅巻娑堟伅鏁扮粍 + for (int i = 0; i < jsonArray.size(); i++) { + // 鑾峰彇娑堟伅鏁扮粍涓殑鍊� + Object value = jsonArray.get(i); + // 妫�鏌ュ�兼槸鍚︽湁鏁� + if (value != null && !value.toString().equals("null")) { + try { + // 绉婚櫎闈炴暟瀛楀拰鏁板瓧瀛楃 + String cleanedValue = value.toString().replaceAll("[^0-9-]", ""); + // 瑙f瀽涓哄竷灏斿�� + boolean val = "1".equals(cleanedValue.trim()); + // 灏嗗竷灏斿�兼坊鍔犲埌甯冨皵鍊煎垪琛ㄤ腑 + sValue.add(val); + System.out.println("messageValue: " + Arrays.asList(val) + " added to the list"); + + + } catch (NumberFormatException e) { + // 濡傛灉鏃犳硶瑙f瀽涓� boolean 绫诲瀷锛屽垯蹇界暐璇ラ儴鍒� + System.err.println("Could not parse value: " + value); + } + } + } + + boolean Value1 = sValue.get(0); + boolean Value2 = sValue.get(1); + + if (Value1) { + controller.EndTask(0); + + } + if (Value2) { + controller.EndTask(0); + + } + // 妫�鏌ュ竷灏斿�煎垪琛ㄦ槸鍚︿负绌� + if (!sValue.isEmpty()) { + + // 璋冪敤 S7control.getinstance().WriteBit 鏂规硶灏嗗竷灏斿�煎垪琛ㄥ啓鍏ュ湴鍧�鍒楄〃 + S7control.getinstance().WriteBit(addressList0, sValue); + System.out.println("Values " + sValue + " written to PLC at address " + addressList0); + } + } + } catch (Exception e) { + System.err.println("An error occurred while writing bit to PLC: " + e.getMessage()); + } + + + + //瀛樼墖绛夊緟寤惰繜 customS7Control.Writetime(messageArray, timeout2, 2); -- Gitblit v1.8.0