| | |
|---|
| | | |
|---|
| | | 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"); |
|---|
| | | public PlcManualonePosition() throws IOException { |
|---|
| | | config = new Configuration("config.properties"); |
|---|
| | | } |
|---|
| | | |
|---|
| | | // 读取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; |
|---|
| | | |
|---|
| | | |
|---|
| | | // 创建一个自定义的 S7 控制器消息处理器对象 |
|---|
| | | MessageHandler customS7Control = new MessageHandler(); |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | public static class PLCBooleanConverter { |
|---|
| | | |
|---|
| | | public static short[] convertListsToBinaryShortArray(List<Boolean>... lists) { |
|---|
| | | // 计算所有列表中元素的总数 |
|---|
| | | int totalSize = 0; |
|---|
| | | for (List<Boolean> list : lists) { |
|---|
| | | totalSize += list.size(); |
|---|
| | | } |
|---|
| | | |
|---|
| | | // 将str字符串格式转为json |
|---|
| | | JSONObject jsonObject = new JSONObject(str); |
|---|
| | | // 创建一个足够大的数组来存放所有的二进制值 |
|---|
| | | short[] binaryShortArray = new short[totalSize]; |
|---|
| | | |
|---|
| | | // 获取json中的值 |
|---|
| | | JSONArray address = jsonObject.getJSONArray("Manualoneposition"); |
|---|
| | | // 当前数组填充位置指针 |
|---|
| | | int currentIndex = 0; |
|---|
| | | |
|---|
| | | 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]); |
|---|
| | | |
|---|
| | | // 遍历所有的列表 |
|---|
| | | for (List<Boolean> list : lists) { |
|---|
| | | // 将每个布尔值转换为 0 或 1 并填入数组 |
|---|
| | | for (Boolean value : list) { |
|---|
| | | binaryShortArray[currentIndex++] = (short) (value ? 1 : 0); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | return arraylistss; |
|---|
| | | } catch (FileNotFoundException e) { |
|---|
| | | e.printStackTrace(); |
|---|
| | | } catch (UnsupportedEncodingException e) { |
|---|
| | | e.printStackTrace(); |
|---|
| | | } catch (IOException e) { |
|---|
| | | e.printStackTrace(); |
|---|
| | | |
|---|
| | | return binaryShortArray; |
|---|
| | | } |
|---|
| | | return null; |
|---|
| | | |
|---|
| | | } |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public void run() { |
|---|
| | |
|---|
| | | 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); |
|---|
| | | } |
|---|
| | | // String PlcAddress = this.name; |
|---|
| | | // Integer Plccount = this.count; |
|---|
| | | |
|---|
| | | // 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<String> addresses = new ArrayList<>(); |
|---|
| | | addresses.add("DB100.108"); |
|---|
| | | addresses.add("DB100.20"); |
|---|
| | | addresses.add("DB103.32"); |
|---|
| | | List<Short> arraylist = S7control.getinstance().readWords(addresses); |
|---|
| | | // System.out.println(arraylist); |
|---|
| | | |
|---|
| | | List<String> addresses2 = new ArrayList<>(); |
|---|
| | | addresses2.add("DB100.110"); |
|---|
| | | addresses2.add("DB100.176"); |
|---|
| | | addresses2.add("DB103.34"); |
|---|
| | | List<Short> arraylist2 = S7control.getinstance().readWords(addresses2); |
|---|
| | | |
|---|
| | | List<String> addresses3 = new ArrayList<>(); |
|---|
| | | addresses3.add("DB100.112"); |
|---|
| | | addresses3.add("DB100.24"); |
|---|
| | | addresses3.add("DB103.36"); |
|---|
| | | List<Short> arraylist3 = S7control.getinstance().readWords(addresses3); |
|---|
| | | |
|---|
| | | List<String> addresses4 = new ArrayList<>(); |
|---|
| | | addresses4.add("DB100.114"); |
|---|
| | | addresses4.add("DB100.178"); |
|---|
| | | addresses4.add("DB103.40"); |
|---|
| | | 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 = new ArrayList<>(); |
|---|
| | | addresses9.add("DB104.1.2"); |
|---|
| | | addresses9.add("DB104.1.3"); |
|---|
| | | addresses9.add("DB104.1.6"); |
|---|
| | | addresses9.add("DB104.1.7"); |
|---|
| | | List<Boolean> arraylist9 = S7control.getinstance().readBits(addresses9); |
|---|
| | | |
|---|
| | | List<String> addresses10 = new ArrayList<>(); |
|---|
| | | addresses10.add("DB104.9.4"); |
|---|
| | | addresses10.add("DB104.9.5"); |
|---|
| | | addresses10.add("DB104.9.4"); |
|---|
| | | addresses10.add("DB104.9.5"); |
|---|
| | | 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<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)); |
|---|
| | | |
|---|
| | | // 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; |
|---|
| | | // 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(); |
|---|
| | | // 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} |
|---|
| | | // 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("params", arraylist); |
|---|
| | | jsonObject.append("state", state); |
|---|
| | | jsonObject.append("action", sholist); |
|---|
| | | WebSocketServer sendwServer = WebSocketServer.sessionMap.get("Parameter"); |
|---|
| | | // WebSocketServer sendwServer = WebSocketServer.sessionMap.get("ManualonePosition"); |
|---|
| | | // if (sendwServer != null) { |
|---|
| | | // sendwServer.sendMessage(jsonObject.toString()); |
|---|
| | | // } |
|---|
| | | |
|---|
| | | ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("ManualonePosition"); |
|---|
| | | 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("ManualonePosition"); |
|---|
| | | if (webserver != null) { |
|---|
| | | List<String> messages = webserver.getMessages(); |
|---|
| | | List<String> waddresses1 = new ArrayList<>(); |
|---|
| | | waddresses1.add("DB100.108"); |
|---|
| | | waddresses1.add("DB100.20"); |
|---|
| | | waddresses1.add("DB103.32"); |
|---|
| | | |
|---|
| | | String addressList = "DB100.0"; |
|---|
| | | List<String> waddresses2 = new ArrayList<>(); |
|---|
| | | waddresses2.add("DB100.110"); |
|---|
| | | waddresses2.add("DB100.176"); |
|---|
| | | waddresses2.add("DB103.34"); |
|---|
| | | |
|---|
| | | List<String> waddresses3 = new ArrayList<>(); |
|---|
| | | waddresses3.add("DB100.112"); |
|---|
| | | waddresses3.add("DB100.24"); |
|---|
| | | waddresses3.add("DB103.36"); |
|---|
| | | |
|---|
| | | List<String> waddresses4 = new ArrayList<>(); |
|---|
| | | waddresses4.add("DB100.114"); |
|---|
| | | waddresses4.add("DB100.178"); |
|---|
| | | waddresses4.add("DB103.40"); |
|---|
| | | |
|---|
| | | // 故障地址 |
|---|
| | | List<String> waddresses5 = new ArrayList<>(); |
|---|
| | | // waddresses5.add("DB103.244"); |
|---|
| | | // waddresses5.add("DB103.250"); |
|---|
| | | waddresses5.add("DB103.252"); |
|---|
| | | waddresses5.add("DB103.254"); |
|---|
| | | |
|---|
| | | // 复位地址 |
|---|
| | | List<String> waddresses6 = new ArrayList<>(); |
|---|
| | | waddresses6.add("DB101.4.0"); |
|---|
| | | waddresses6.add("DB101.4.3"); |
|---|
| | | waddresses6.add("DB101.4.4"); |
|---|
| | | waddresses6.add("DB101.4.6"); |
|---|
| | | |
|---|
| | | // 回零地址 |
|---|
| | | List<String> waddresses7 = new ArrayList<>(); |
|---|
| | | |
|---|
| | | waddresses7.add("DB101.4.5"); |
|---|
| | | waddresses7.add("DB101.4.7"); |
|---|
| | | |
|---|
| | | |
|---|
| | | // System.out.println(messages.isEmpty()); |
|---|
| | | 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 类型，则忽略该部分 |
|---|
| | | // System.out.println("lastMessage：" + lastMessage); |
|---|
| | | JSONArray messageArray = new JSONArray(lastMessage); |
|---|
| | | // 写入A01 |
|---|
| | | if (messageArray.getJSONArray(0).size() > 0) { |
|---|
| | | JSONArray jsonArray = messageArray.getJSONArray(0); |
|---|
| | | List<Short> 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-]", ""); |
|---|
| | | short val = Short.parseShort(cleanedValue.trim()); |
|---|
| | | sValue.add(val); |
|---|
| | | System.out.println("messageValue：" + Arrays.asList(val) + " added to the list"); |
|---|
| | | } catch (NumberFormatException e) { |
|---|
| | | // 如果无法解析为 short 类型，则忽略该部分 |
|---|
| | | System.err.println("Could not parse value: " + value); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | if (!sValue.isEmpty()) { |
|---|
| | | S7control.getinstance().WriteWord(waddresses1, sValue); |
|---|
| | | |
|---|
| | | e.printStackTrace(); |
|---|
| | | |
|---|
| | | System.out.println("Values " + sValue + " written to PLC at address " + waddresses1); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | // 将消息值写入 PLC |
|---|
| | | S7control.getinstance().WriteWord(addressList, messageValues); |
|---|
| | | System.out.println("messageValues：" + messageValues); |
|---|
| | | System.out.println("addressList：" + addressList); |
|---|
| | | // 写入A02 |
|---|
| | | |
|---|
| | | if (messageArray.getJSONArray(1).size() > 0) { |
|---|
| | | JSONArray jsonArray = messageArray.getJSONArray(1); |
|---|
| | | List<Short> sValue2 = 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-]", ""); |
|---|
| | | short val = Short.parseShort(cleanedValue.trim()); |
|---|
| | | sValue2.add(val); |
|---|
| | | System.out.println("messageValue：" + Arrays.asList(val) + " added to the list"); |
|---|
| | | } catch (NumberFormatException e) { |
|---|
| | | // 如果无法解析为 short 类型，则忽略该部分 |
|---|
| | | System.err.println("Could not parse value: " + value); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | if (!sValue2.isEmpty()) { |
|---|
| | | S7control.getinstance().WriteWord(waddresses2, sValue2); |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | System.out.println("Values " + sValue2 + " written to PLC at address " + waddresses2); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | // 写入B01 |
|---|
| | | if (messageArray.getJSONArray(2).size() > 0) { |
|---|
| | | JSONArray jsonArray = messageArray.getJSONArray(2); |
|---|
| | | List<Short> sValue2 = 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-]", ""); |
|---|
| | | short val = Short.parseShort(cleanedValue.trim()); |
|---|
| | | sValue2.add(val); |
|---|
| | | System.out.println("messageValue：" + Arrays.asList(val) + " added to the list"); |
|---|
| | | } catch (NumberFormatException e) { |
|---|
| | | // 如果无法解析为 short 类型，则忽略该部分 |
|---|
| | | System.err.println("Could not parse value: " + value); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | if (!sValue2.isEmpty()) { |
|---|
| | | S7control.getinstance().WriteWord(waddresses3, sValue2); |
|---|
| | | |
|---|
| | | System.out.println("Values " + sValue2 + " written to PLC at address " + waddresses3); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | // 写入B02 |
|---|
| | | if (messageArray.getJSONArray(3).size() > 0) { |
|---|
| | | JSONArray jsonArray = messageArray.getJSONArray(3); |
|---|
| | | List<Short> sValue2 = 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-]", ""); |
|---|
| | | short val = Short.parseShort(cleanedValue.trim()); |
|---|
| | | sValue2.add(val); |
|---|
| | | System.out.println("messageValue：" + Arrays.asList(val) + " added to the list"); |
|---|
| | | } catch (NumberFormatException e) { |
|---|
| | | // 如果无法解析为 short 类型，则忽略该部分 |
|---|
| | | System.err.println("Could not parse value: " + value); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | if (!sValue2.isEmpty()) { |
|---|
| | | S7control.getinstance().WriteWord(waddresses4, sValue2); |
|---|
| | | |
|---|
| | | System.out.println("Values " + sValue2 + " written to PLC at address " + waddresses4); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | // 写入故障地址 |
|---|
| | | if (messageArray.getJSONArray(4).size() > 0) { |
|---|
| | | JSONArray jsonArray = messageArray.getJSONArray(4); |
|---|
| | | List<Short> sValue2 = 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-]", ""); |
|---|
| | | short val = Short.parseShort(cleanedValue.trim()); |
|---|
| | | sValue2.add(val); |
|---|
| | | System.out.println("messageValue：" + Arrays.asList(val) + " added to the list"); |
|---|
| | | } catch (NumberFormatException e) { |
|---|
| | | // 如果无法解析为 short 类型，则忽略该部分 |
|---|
| | | System.err.println("Could not parse value: " + value); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | if (!sValue2.isEmpty()) { |
|---|
| | | S7control.getinstance().WriteWord(waddresses5, sValue2); |
|---|
| | | System.out.println("Values " + sValue2 + " written to PLC at address " + waddresses5); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | // 写入复位地址 |
|---|
| | | if (messageArray.getJSONArray(5).size() > 0) { |
|---|
| | | JSONArray jsonArray3 = messageArray.getJSONArray(5); |
|---|
| | | List<Boolean> sValue3 = new ArrayList<>(); |
|---|
| | | for (int i = 0; i < jsonArray3.size(); i++) { |
|---|
| | | Object value = jsonArray3.get(i); |
|---|
| | | if (value != null && !value.toString().equals("null")) { |
|---|
| | | try { |
|---|
| | | String cleanedValue = value.toString().replaceAll("[^0-9-]", ""); |
|---|
| | | boolean val = "1".equals(cleanedValue.trim()); |
|---|
| | | sValue3.add(val); |
|---|
| | | System.out.println("messageValue: " + Arrays.asList(val) + " added to the list"); |
|---|
| | | } catch (NumberFormatException e) { |
|---|
| | | // 如果无法解析为 boolean 类型，则忽略该部分 |
|---|
| | | System.err.println("Could not parse value: " + value); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | if (!sValue3.isEmpty()) { |
|---|
| | | S7control.getinstance().WriteBit(waddresses6, sValue3); |
|---|
| | | System.out.println("Values " + sValue3 + " written to PLC at address " + waddresses6); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | // 写入回零地址 |
|---|
| | | if (messageArray.getJSONArray(6).size() > 0) { |
|---|
| | | JSONArray jsonArray3 = messageArray.getJSONArray(6); |
|---|
| | | List<Boolean> sValue3 = new ArrayList<>(); |
|---|
| | | for (int i = 0; i < jsonArray3.size(); i++) { |
|---|
| | | Object value = jsonArray3.get(i); |
|---|
| | | if (value != null && !value.toString().equals("null")) { |
|---|
| | | try { |
|---|
| | | String cleanedValue = value.toString().replaceAll("[^0-9-]", ""); |
|---|
| | | boolean val = "1".equals(cleanedValue.trim()); |
|---|
| | | sValue3.add(val); |
|---|
| | | System.out.println("messageValue: " + Arrays.asList(val) + " added to the list"); |
|---|
| | | } catch (NumberFormatException e) { |
|---|
| | | // 如果无法解析为 boolean 类型，则忽略该部分 |
|---|
| | | System.err.println("Could not parse value: " + value); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | if (!sValue3.isEmpty()) { |
|---|
| | | S7control.getinstance().WriteBit(waddresses7, sValue3); |
|---|
| | | System.out.println("Values " + sValue3 + " written to PLC at address " + waddresses7); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | customS7Control.writeBitToPLC( messageArray, A01start,7); |
|---|
| | | customS7Control.writeBitToPLC( messageArray, A02start,8); |
|---|
| | | customS7Control.writeBitToPLC( messageArray,B01start,9); |
|---|
| | | customS7Control.writeBitToPLC( messageArray, B02start,10); |
|---|
| | | |
|---|
| | | // 清空消息列表 |
|---|
| | | webSocketServer.clearMessages(); |
|---|
| | | webserver.clearMessages(); |
|---|
| | | } |
|---|
| | | }} |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
