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

clll

2023-09-08 0b83163518f23e4571f3f510c38e9a25f46b6d07

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

@@ -6,46 +6,25 @@
import java.util.List;

public class PlcParameter extends Thread {
    private static final int SEND_INTERVAL = 10000;
    private static final int WRITE_INTERVAL = 100;

    @Override

    public void run() {
        while (this != null) {
        try {
            // 发送一次消息
            sendMessages();

            // 延迟一段时间
            Thread.sleep(SEND_INTERVAL);

            while (true) {
                // 写入PLC
                writeToPlc();
                Thread.sleep(WRITE_INTERVAL);

                // 发送消息
                sendMessages();
                Thread.sleep(SEND_INTERVAL);
            }

                Thread.sleep(1000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

    private void sendMessages() {
            List<Short> paramlist = S7control.getinstance().ReadWord("DB100.DBW", 12);
            List<Short> state = S7control.getinstance().ReadWord("DB103.DBW0", 10);
            JSONObject jsonObject = new JSONObject();
            jsonObject.append("params", new short[]{1111,121, 3232, 0, 1, 0, 1, 0, 1, 0, 1, 0});
            jsonObject.append("state", new short[]{0, 1, 0, 0, 0, 0, 0,0, 0, 0});
        WebSocketServer sendwServer = WebSocketServer.sessionMap.get("Parameter");
        if (sendwServer != null) {
            List<Short> paramlist = S7control.getinstance().ReadWord("DB100.DBW", 12);
            JSONObject jsonObject = new JSONObject();
//            new short[]{1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 1, 0}
            jsonObject.append("params", new short[]{1, 0, 1, 0, 1, 0, 1, 0, 1, 0, 1, 0});
            sendwServer.sendMessage(jsonObject.toString());
        }
    }

    private void writeToPlc() {
        WebSocketServer webSocketServer = WebSocketServer.sessionMap.get("Parameter");
        if (webSocketServer != null) {
            List<String> messages = webSocketServer.getMessages();
@@ -66,6 +45,7 @@
                        messageValues.add(value);
                    } catch (NumberFormatException e) {
                        // 如果无法解析为 short 类型，则忽略该部分

                        e.printStackTrace();
                    }
                }
@@ -80,3 +60,4 @@
        }
    }
}
}