package com.example.springboot.component; import cn.hutool.json.JSONArray; import cn.hutool.json.JSONObject; import org.apache.commons.io.FileUtils; import java.io.*; import java.util.ArrayList; import java.util.Arrays; import java.util.List; public class PlcManualonePosition extends Thread { private Configuration config; public PlcManualonePosition() throws IOException { config = new Configuration("config.properties"); } // 创建一个自定义的 S7 控制器消息处理器对象 MessageHandler customS7Control = new MessageHandler(); public static class PLCBooleanConverter { public static short[] convertListsToBinaryShortArray(List... lists) { // 计算所有列表中元素的总数 int totalSize = 0; for (List list : lists) { totalSize += list.size(); } // 创建一个足够大的数组来存放所有的二进制值 short[] binaryShortArray = new short[totalSize]; // 当前数组填充位置指针 int currentIndex = 0; // 遍历所有的列表 for (List list : lists) { // 将每个布尔值转换为 0 或 1 并填入数组 for (Boolean value : list) { binaryShortArray[currentIndex++] = (short) (value ? 1 : 0); } } return binaryShortArray; } } @Override public void run() { while (this != null) { try { Thread.sleep(500); } catch (InterruptedException e) { e.printStackTrace(); } // this.readValue(); // String PlcAddress = this.name; // Integer Plccount = this.count; //B01组合中地址 // String b01Address = config.getProperty("B01.address"); List addresses = Arrays.asList(config.getProperty("PlcManualonePosition.addresses").split(",")); List arraylist = S7control.getinstance().readWords(addresses); // System.out.println(arraylist); List addresses2 = Arrays.asList(config.getProperty("PlcManualonePosition.addresses2").split(",")); List arraylist2 = S7control.getinstance().readWords(addresses2); List addresses3 = Arrays.asList(config.getProperty("PlcManualonePosition.addresses3").split(",")); List arraylist3 = S7control.getinstance().readWords(addresses3); List addresses4 = Arrays.asList(config.getProperty("PlcManualonePosition.addresses4").split(",")); List arraylist4 = S7control.getinstance().readWords(addresses4); List arraylist5 = S7control.getinstance().ReadWord("DB106.0", 1); List arraylist6 = S7control.getinstance().ReadWord("DB106.12", 1); List arraylist7 = S7control.getinstance().ReadWord("DB106.40", 1); List arraylist8 = S7control.getinstance().ReadWord("DB106.50", 1); //故障 List addresses9 = Arrays.asList(config.getProperty("PlcManualonePosition.fault").split(",")); List arraylist9 = S7control.getinstance().readBits(addresses9); //未回零 List addresses10 = Arrays.asList(config.getProperty("PlcManualonePosition.Notzero").split(",")); List arraylist10 = S7control.getinstance().readBits(addresses10); //A01启动地址 List A01start = Arrays.asList(config.getProperty("mlp.A01start")); //A02启动地址 List A02start = Arrays.asList(config.getProperty("mlp.A02start")); List B01start = Arrays.asList(config.getProperty("mlp.B01start")); List B02start = Arrays.asList(config.getProperty("mlp.B02start")); // 故障地址 List waddresses5 = Arrays.asList(config.getProperty("PlcManualonePosition.fault2").split(",")); // 复位地址 List waddresses6 = Arrays.asList(config.getProperty("PlcManualonePosition.Reset").split(",")); List readreast = S7control.getinstance().readBits(waddresses6); short[] reast6 = PLCBooleanConverter.convertListsToBinaryShortArray(readreast); // 回零地址 List waddresses7 = Arrays.asList(config.getProperty("PlcManualonePosition.Zero").split(",")); List readhuiling = S7control.getinstance().readBits(waddresses7); short[] huiling7 = PLCBooleanConverter.convertListsToBinaryShortArray(readhuiling); List A01readstart = S7control.getinstance().readBits(A01start); List A02readstart = S7control.getinstance().readBits(A02start); List B01readstart = S7control.getinstance().readBits(B01start); List B02readstart = S7control.getinstance().readBits(B02start); short[] combinedBinaryShortArray = PLCBooleanConverter.convertListsToBinaryShortArray( A01readstart, A02readstart, B01readstart, B02readstart ); short[] params2 = new short[arraylist9.size()]; for (int i = 0; i < arraylist9.size(); i++) { boolean value = arraylist9.get(i); params2[i] = value ? (short) 1 : (short) 0; } // Boolean[] values10 = { false, false, true, true }; // List arraylist10 = new ArrayList<>(Arrays.asList(values10)); short[] params3 = new short[arraylist10.size()]; for (int i = 0; i < arraylist10.size(); i++) { boolean value = arraylist10.get(i); params3[i] = value ? (short) 1 : (short) 0; } // List arraylist9 = S7control.getinstance().readWords(addresses9); arraylist5.addAll(arraylist6); arraylist5.addAll(arraylist7); arraylist5.addAll(arraylist8); JSONObject jsonObject = new JSONObject(); // System.out.println(arraylist6); jsonObject.append("zuhe1", arraylist); jsonObject.append("zuhe2", arraylist2); jsonObject.append("zuhe3", arraylist3); jsonObject.append("zuhe4", arraylist4); jsonObject.append("shishi1", arraylist5); jsonObject.append("guzhang", params2); jsonObject.append("weihuiling", params3); jsonObject.append("qidong", combinedBinaryShortArray); jsonObject.append("fuwei", reast6); jsonObject.append("huiling", huiling7); // WebSocketServer sendwServer = WebSocketServer.sessionMap.get("ManualonePosition"); // if (sendwServer != null) { // sendwServer.sendMessage(jsonObject.toString()); // } ArrayList sendwServer = WebSocketServer.sessionMap.get("ManualonePosition"); if (sendwServer != null) { for (WebSocketServer webserver : sendwServer) { webserver.sendMessage(jsonObject.toString()); // WebSocketServer webSocketServer = WebSocketServer.sessionMap.get("ManualonePosition"); if (webserver != null) { List messages = webserver.getMessages(); // System.out.println(messages.isEmpty()); if (!messages.isEmpty()) { // 将最后一个消息转换为 short 类型的列表 String lastMessage = messages.get(messages.size() - 1); // System.out.println("lastMessage：" + lastMessage); JSONArray messageArray = new JSONArray(lastMessage); // 写入A01 customS7Control.WriteWordToPLC(messageArray, addresses, 0); // 写入A02 customS7Control.WriteWordToPLC(messageArray, addresses2, 1); // 写入B01 customS7Control.WriteWordToPLC(messageArray, addresses3, 2); // 写入B02 customS7Control.WriteWordToPLC(messageArray, addresses4, 3); // 写入故障地址 customS7Control.writeBitToPLC(messageArray, waddresses5, 4); // 写入复位地址 customS7Control.writeBitToPLC(messageArray, waddresses6, 5); // 写入回零地址 customS7Control.writeBitToPLC(messageArray, waddresses7, 6); //A01启动 customS7Control.writeBitToPLC(messageArray, A01start, 7); //A02启动 customS7Control.writeBitToPLC(messageArray, A02start, 8); //B01启动 customS7Control.writeBitToPLC(messageArray, B01start, 9); //B02启动 customS7Control.writeBitToPLC(messageArray, B02start, 10); // 清空消息列表 webserver.clearMessages(); } } } } } } }