ZengTao
2024-05-17 62718fb62a1fc92ee727ce31e0ca877f3e30f503
springboot-vue3/src/main/java/com/example/springboot/component/PLCManualJog.java
@@ -2,13 +2,15 @@
import cn.hutool.json.JSONArray;
import cn.hutool.json.JSONObject;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.io.FileUtils;
import java.io.*;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
@Slf4j
public class PLCManualJog extends Thread {
@@ -16,7 +18,7 @@
    private Configuration config;
    // 创建一个自定义的 S7 控制器消息处理器对象
    MessageHandler customS7Control = new MessageHandler();
    public PLCManualJog() throws IOException {
@@ -25,7 +27,7 @@
//    Boolean[] values1 = { false, true, true, true, false, false, true, false,
//            false, true, true, true, false, false,
//            true, false,false, true, true, true, false, false, true, false,
//            false, true, false, true };
//            false, true };
//    List<Boolean> arraylist = new ArrayList<>(Arrays.asList(values1));
    @Override
@@ -51,12 +53,12 @@
            ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("ManualJog");
            if (sendwServer != null) {
                for (WebSocketServer webserver : sendwServer) {
                    webserver.sendMessage(jsonObject.toString());
//      WebSocketServer webSocketServer = WebSocketServer.sessionMap.get("ManualJog");
                    if (webserver != null) {
                    if (webserver != null&&webserver.session.isOpen()) {
                        webserver.sendMessage(jsonObject.toString());
                        List<String> messages = webserver.getMessages();
                        if (!messages.isEmpty()) {
@@ -101,6 +103,8 @@
                            webserver.clearMessages();
                        }
                    }else{
                        log.info("ManualJog is closed");
                    }
                }