Merge branch 'master' of http://10.153.19.150:10101/r/CanadaMes

clll

2023-09-06 ee84c191faa2c235703eaa8cdc765729bed71a4f

 springboot-vue3/src/main/java/com/example/springboot/component/Plcaction.java

@@ -6,70 +6,96 @@
import java.util.List;



public class Plcaction extends Thread {

  @Override

  public void run() {

    while (this != null) {

      try {

        Thread.sleep(10000);

      } catch (InterruptedException e) {

        e.printStackTrace();

      }

    private static final long SEND_INTERVAL = 2000; // 发送消息的时间间隔

    private static final long WRITE_INTERVAL = 100; // 写入PLC的时间间隔



      List<Short> paramlist = S7control.getinstance().ReadWord("DB100.DBW", 12);

    @Override

    public void run() {

        try {

            // 发送一次消息

            sendMessages();



      JSONObject jsonObject = new JSONObject();

      jsonObject.append("params", new short[] { 1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 1, 0

      });

      WebSocketServer sendwServer = WebSocketServer.sessionMap.get("action");

      if (sendwServer != null) {

        sendwServer.sendMessage(jsonObject.toString());

      }

            // 延迟一段时间

            Thread.sleep(SEND_INTERVAL);



      WebSocketServer webSocketServer = WebSocketServer.sessionMap.get("action");

      if (webSocketServer != null) {

        List<String> messages = webSocketServer.getMessages();

            while (true) {

                // 写入PLC

                writeToPlc();

                Thread.sleep(WRITE_INTERVAL);



        String addressList = "DB100.DBW0";

        // addressList.add("DB100.DBW0");

        // addressList.add("DB100.DBW2");

        // addressList.add("DB100.DBW4");

        // addressList.add("DB100.DBW6");

        // addressList.add("DB100.DBW8");

        // addressList.add("DB100.DBW10");

        // addressList.add("DB100.DBW12");

        // addressList.add("DB100.DBW14");

        // addressList.add("DB100.DBW16");

        // addressList.add("DB100.DBW18");

        // addressList.add("DB100.DBW20");

        // addressList.add("DB100.DBW22");



        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();

                // 发送消息

                sendMessages();

                Thread.sleep(SEND_INTERVAL);

            }

          }



          // 将消息值写入 PLC

          // S7control.getinstance().WriteWord(addressList, messageValues);

          System.out.println("messageValues：" + messageValues);

          System.out.println("addressList：" + addressList);

          // 清空消息列表

          webSocketServer.clearMessages();

        } catch (InterruptedException e) {

            e.printStackTrace();

        }

      }

    }

  }

}





    private void sendMessages() {

        WebSocketServer sendwServer = WebSocketServer.sessionMap.get("action");

        if (sendwServer != null) {



            List<Boolean> paramlist = S7control.getinstance().ReadBits("DB100.DBW", 12);

            //        new short[]{1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 1, 0}

            JSONObject jsonObject = new JSONObject();

            jsonObject.append("params", new short[]{1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 1, 0});



            sendwServer.sendMessage(jsonObject.toString());

        }









    }



    private void writeToPlc() {

        WebSocketServer webSocketServer = WebSocketServer.sessionMap.get("action");

        if (webSocketServer != null) {

            List<String> messages = webSocketServer.getMessages();



            String addressList = "DB100.DBW0";



            if (!messages.isEmpty()) {

                // 将最后一个消息转换为整数类型的列表

                String lastMessage = messages.get(messages.size() - 1);

                System.out.println("messages：" + messages);

                String[] parts = lastMessage.split(",");

                List<Integer> messageValues = new ArrayList<>();

                for (String part : parts) {

                    try {

                        // 使用正则表达式清除非数字字符

                        String cleanedPart = part.replaceAll("[^0-9-]", "");

                        Integer value = Integer.parseInt(cleanedPart.trim());

                        messageValues.add(value);

                    } catch (NumberFormatException e) {

                        // 如果无法解析为整数类型，则忽略该部分

                        e.printStackTrace();

                    }

                }



                // 将消息值转换为布尔列表

                List<Boolean> messageBooleans = new ArrayList<>();

                for (Integer value : messageValues) {

                    messageBooleans.add(value == 0 ? true : false);

                }



                // 将布尔列表写入 PLC

                S7control.getinstance().WriteBit(addressList, messageBooleans);

                System.out.println("messageValues：" + messageBooleans);

                System.out.println("addressList：" + addressList);



                // 清空消息列表

                webSocketServer.clearMessages();

            }

        }

    }



    private List<Boolean> paramList() {

        // 获取参数列表的逻辑



        return new ArrayList<>(); // 假设返回空列表

    }

}