| | |
|---|
| | | |
|---|
| | | import cn.hutool.json.JSONArray; |
|---|
| | | import cn.hutool.json.JSONObject; |
|---|
| | | |
|---|
| | | import java.util.ArrayList; |
|---|
| | | import java.util.List; |
|---|
| | | import java.util.Arrays; |
|---|
| | | import java.io.BufferedReader; |
|---|
| | | import java.io.File; |
|---|
| | | import java.io.FileInputStream; |
|---|
| | | import java.io.FileNotFoundException; |
|---|
| | | import java.io.IOException; |
|---|
| | | import java.io.InputStreamReader; |
|---|
| | | import java.io.UnsupportedEncodingException; |
|---|
| | | |
|---|
| | | 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 { |
|---|
| | | String name = ""; |
|---|
| | | Integer count = 0; |
|---|
| | | private Configuration config; |
|---|
| | | |
|---|
| | | public static String readFileToString(String filePath) throws IOException { |
|---|
| | | File file = new File(filePath); |
|---|
| | | return FileUtils.readFileToString(file, "UTF-8"); |
|---|
| | | } |
|---|
| | | |
|---|
| | | // 读取json文件中地址，并返回该地址集合 |
|---|
| | | public List<String> readValue() { |
|---|
| | | String str = ""; |
|---|
| | | BufferedReader bufferedReader = null; |
|---|
| | | FileInputStream fileInputStream; |
|---|
| | | try { |
|---|
| | | // 从文件中读取字节数据存入 fileInputStream |
|---|
| | | fileInputStream = new FileInputStream("CanadaMes-ui/src/configuration/address.json"); |
|---|
| | | // 读取 fileInputStream 中字节并将其解码为字符 |
|---|
| | | InputStreamReader inputStreamReader = new InputStreamReader(fileInputStream, "utf-8"); |
|---|
| | | // 提高读取效率，在 BufferedReader 内包装 InputStreamReader |
|---|
| | | bufferedReader = new BufferedReader(inputStreamReader); |
|---|
| | | // bufferedReader.close(); |
|---|
| | | String line = null; |
|---|
| | | // 将 bufferedReader 内容一行一行赋值给str |
|---|
| | | while ((line = bufferedReader.readLine()) != null) { |
|---|
| | | str += line; |
|---|
| | | } |
|---|
| | | |
|---|
| | | // 将str字符串格式转为json |
|---|
| | | JSONObject jsonObject = new JSONObject(str); |
|---|
| | | |
|---|
| | | // 获取json中的值 |
|---|
| | | JSONArray address = jsonObject.getJSONArray("Manualoneposition"); |
|---|
| | | |
|---|
| | | String[] result = new String[address.size()]; |
|---|
| | | |
|---|
| | | List<String> arraylistss = new ArrayList<>(); |
|---|
| | | |
|---|
| | | for (int i = 0; i < address.size(); i++) { |
|---|
| | | JSONObject ress = (JSONObject) address.get(i); |
|---|
| | | |
|---|
| | | this.name = ress.getStr("name"); |
|---|
| | | this.count = ress.getInt("count"); |
|---|
| | | ; |
|---|
| | | result[i] = name + ',' + count.toString(); |
|---|
| | | arraylistss.add(result[i]); |
|---|
| | | |
|---|
| | | } |
|---|
| | | return arraylistss; |
|---|
| | | } catch (FileNotFoundException e) { |
|---|
| | | e.printStackTrace(); |
|---|
| | | } catch (UnsupportedEncodingException e) { |
|---|
| | | e.printStackTrace(); |
|---|
| | | } catch (IOException e) { |
|---|
| | | e.printStackTrace(); |
|---|
| | | public PlcManualonePosition() throws IOException { |
|---|
| | | config = new Configuration("config.properties"); |
|---|
| | | } |
|---|
| | | return null; |
|---|
| | | |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public void run() { |
|---|
| | | while (this != null) { |
|---|
| | | try { |
|---|
| | | Thread.sleep(500); |
|---|
| | | // 创建一个自定义的 S7 控制器消息处理器对象 |
|---|
| | | MessageHandler customS7Control = new MessageHandler(); |
|---|
| | | |
|---|
| | | } catch (InterruptedException e) { |
|---|
| | | e.printStackTrace(); |
|---|
| | | } |
|---|
| | | // this.readValue(); |
|---|
| | | List<String> myCollection; |
|---|
| | | myCollection = readValue(); |
|---|
| | | // System.out.println(myCollection); |
|---|
| | | List<Short> arraylist = new ArrayList<>(); |
|---|
| | | for (String element : myCollection) { |
|---|
| | | String[] parts = element.split(","); |
|---|
| | | String PlcAddress = parts[0]; |
|---|
| | | String count = parts[1]; |
|---|
| | | Integer Plccount = new Integer(count); |
|---|
| | | // arraylist = S7control.getinstance().ReadWord(PlcAddress, Plccount); |
|---|
| | | System.out.println(PlcAddress); |
|---|
| | | } |
|---|
| | | |
|---|
| | | // List<Short> arraylist = S7control.getinstance().ReadWord("DB100.0", 12); |
|---|
| | | // List<Short> state = S7control.getinstance().ReadWord("DB103.0", 10); |
|---|
| | | // parameter |
|---|
| | | // Short[] values1 = { 1231, 1, 1, 1, 1, 1, 2, 33, 2, 3, 4, 5 }; |
|---|
| | | // List<Short> arraylist = new ArrayList<>(Arrays.asList(values1)); |
|---|
| | | public static class PLCBooleanConverter { |
|---|
| | | |
|---|
| | | // state |
|---|
| | | Short[] values2 = { 0, 0, 0, 0, 0, 0, 0, 0, 0, 0 }; |
|---|
| | | List<Short> state = new ArrayList<>(Arrays.asList(values2)); |
|---|
| | | |
|---|
| | | // action |
|---|
| | | Boolean[] values = { false, true, true, true, true, true, true, true, true, |
|---|
| | | true, true, true, true, true, true, true, true, true, true, true, true, true, true, |
|---|
| | | true, false, true }; |
|---|
| | | List<Boolean> paramlist = new ArrayList<>(Arrays.asList(values)); |
|---|
| | | |
|---|
| | | short[] sholist = new short[paramlist.size()]; |
|---|
| | | |
|---|
| | | for (int i = 0; i < paramlist.size(); i++) { |
|---|
| | | boolean value = paramlist.get(i); |
|---|
| | | sholist[i] = value ? (short) 1 : (short) 0; |
|---|
| | | } |
|---|
| | | |
|---|
| | | 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); |
|---|
| | | jsonObject.append("action", sholist); |
|---|
| | | 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 { |
|---|
| | | // 使用正则表达式清除非数字字符 |
|---|
| | | String cleanedPart = part.replaceAll("[^0-9-]", ""); |
|---|
| | | short value = Short.parseShort(cleanedPart.trim()); |
|---|
| | | messageValues.add(value); |
|---|
| | | } catch (NumberFormatException e) { |
|---|
| | | // 如果无法解析为 short 类型，则忽略该部分 |
|---|
| | | |
|---|
| | | e.printStackTrace(); |
|---|
| | | public static short[] convertListsToBinaryShortArray(List<Boolean>... lists) { |
|---|
| | | // 计算所有列表中元素的总数 |
|---|
| | | int totalSize = 0; |
|---|
| | | for (List<Boolean> list : lists) { |
|---|
| | | totalSize += list.size(); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | // 将消息值写入 PLC |
|---|
| | | S7control.getinstance().WriteWord(addressList, messageValues); |
|---|
| | | System.out.println("messageValues：" + messageValues); |
|---|
| | | System.out.println("addressList：" + addressList); |
|---|
| | | // 清空消息列表 |
|---|
| | | webSocketServer.clearMessages(); |
|---|
| | | // 创建一个足够大的数组来存放所有的二进制值 |
|---|
| | | short[] binaryShortArray = new short[totalSize]; |
|---|
| | | |
|---|
| | | // 当前数组填充位置指针 |
|---|
| | | int currentIndex = 0; |
|---|
| | | |
|---|
| | | // 遍历所有的列表 |
|---|
| | | for (List<Boolean> 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<String> addresses = Arrays.asList(config.getProperty("PlcManualonePosition.addresses").split(",")); |
|---|
| | | |
|---|
| | | List<Short> arraylist = S7control.getinstance().readWords(addresses); |
|---|
| | | // System.out.println(arraylist); |
|---|
| | | List<String> addresses2 = Arrays.asList(config.getProperty("PlcManualonePosition.addresses2").split(",")); |
|---|
| | | |
|---|
| | | List<Short> arraylist2 = S7control.getinstance().readWords(addresses2); |
|---|
| | | |
|---|
| | | List<String> addresses3 = Arrays.asList(config.getProperty("PlcManualonePosition.addresses3").split(",")); |
|---|
| | | |
|---|
| | | List<Short> arraylist3 = S7control.getinstance().readWords(addresses3); |
|---|
| | | |
|---|
| | | |
|---|
| | | List<String> addresses4 = Arrays.asList(config.getProperty("PlcManualonePosition.addresses4").split(",")); |
|---|
| | | |
|---|
| | | List<Short> arraylist4 = S7control.getinstance().readWords(addresses4); |
|---|
| | | |
|---|
| | | |
|---|
| | | List<Short> arraylist5 = S7control.getinstance().ReadWord("DB106.0", 1); |
|---|
| | | List<Short> arraylist6 = S7control.getinstance().ReadWord("DB106.12", 1); |
|---|
| | | List<Short> arraylist7 = S7control.getinstance().ReadWord("DB106.40", 1); |
|---|
| | | List<Short> arraylist8 = S7control.getinstance().ReadWord("DB106.50", 1); |
|---|
| | | //故障 |
|---|
| | | |
|---|
| | | List<String> addresses9 = Arrays.asList(config.getProperty("PlcManualonePosition.fault").split(",")); |
|---|
| | | |
|---|
| | | List<Boolean> arraylist9 = S7control.getinstance().readBits(addresses9); |
|---|
| | | |
|---|
| | | //未回零 |
|---|
| | | |
|---|
| | | List<String> addresses10 = Arrays.asList(config.getProperty("PlcManualonePosition.Notzero").split(",")); |
|---|
| | | |
|---|
| | | List<Boolean> arraylist10 = S7control.getinstance().readBits(addresses10); |
|---|
| | | |
|---|
| | | //A01启动地址 |
|---|
| | | List<String> A01start = Arrays.asList(config.getProperty("mlp.A01start")); |
|---|
| | | //A02启动地址 |
|---|
| | | List<String> A02start = Arrays.asList(config.getProperty("mlp.A02start")); |
|---|
| | | |
|---|
| | | List<String> B01start = Arrays.asList(config.getProperty("mlp.B01start")); |
|---|
| | | |
|---|
| | | List<String> B02start = Arrays.asList(config.getProperty("mlp.B02start")); |
|---|
| | | |
|---|
| | | // 故障地址 |
|---|
| | | List<String> waddresses5 = Arrays.asList(config.getProperty("PlcManualonePosition.fault2").split(",")); |
|---|
| | | |
|---|
| | | |
|---|
| | | // 复位地址 |
|---|
| | | List<String> waddresses6 = Arrays.asList(config.getProperty("PlcManualonePosition.Reset").split(",")); |
|---|
| | | List<Boolean> readreast = S7control.getinstance().readBits(waddresses6); |
|---|
| | | short[] reast6 = PLCBooleanConverter.convertListsToBinaryShortArray(readreast); |
|---|
| | | |
|---|
| | | // 回零地址 |
|---|
| | | List<String> waddresses7 = Arrays.asList(config.getProperty("PlcManualonePosition.Zero").split(",")); |
|---|
| | | List<Boolean> readhuiling = S7control.getinstance().readBits(waddresses7); |
|---|
| | | short[] huiling7 = PLCBooleanConverter.convertListsToBinaryShortArray(readhuiling); |
|---|
| | | |
|---|
| | | List<Boolean> A01readstart = S7control.getinstance().readBits(A01start); |
|---|
| | | List<Boolean> A02readstart = S7control.getinstance().readBits(A02start); |
|---|
| | | List<Boolean> B01readstart = S7control.getinstance().readBits(B01start); |
|---|
| | | List<Boolean> B02readstart = S7control.getinstance().readBits(B02start); |
|---|
| | | |
|---|
| | | short[] combinedBinaryShortArray = PLCBooleanConverter.convertListsToBinaryShortArray( |
|---|
| | | A01readstart, A02readstart, B01readstart, B02readstart |
|---|
| | | ); |
|---|
| | | |
|---|
| | | // Short[] values1 = { 1, 2, 3 }; |
|---|
| | | // List<Short> arraylist = new ArrayList<>(Arrays.asList(values1)); |
|---|
| | | // Short[] values2 = { 1, 2, 3 }; |
|---|
| | | // List<Short> arraylist2 = new ArrayList<>(Arrays.asList(values2)); |
|---|
| | | // Short[] values3 = { 1, 2, 3 }; |
|---|
| | | // List<Short> arraylist3 = new ArrayList<>(Arrays.asList(values3)); |
|---|
| | | // Short[] values4 = { 1, 2, 3 }; |
|---|
| | | // List<Short> arraylist4 = new ArrayList<>(Arrays.asList(values4)); |
|---|
| | | // Short[] values5 = { 5 }; |
|---|
| | | // List<Short> arraylist5 = new ArrayList<>(Arrays.asList(values5)); |
|---|
| | | // Short[] values6 = { 6 }; |
|---|
| | | // List<Short> arraylist6 = new ArrayList<>(Arrays.asList(values6)); |
|---|
| | | // Short[] values7 = { 7 }; |
|---|
| | | // List<Short> arraylist7 = new ArrayList<>(Arrays.asList(values7)); |
|---|
| | | // Short[] values8 = { 8 }; |
|---|
| | | // List<Short> arraylist8 = new ArrayList<>(Arrays.asList(values8)); |
|---|
| | | // Boolean[] values9 = { false, false, true, true }; |
|---|
| | | // List<Boolean> arraylist9 = new ArrayList<>(Arrays.asList(values9)); |
|---|
| | | 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<Boolean> 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<Short> 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<WebSocketServer> 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<String> 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(); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
