wuyouming666
2024-05-20 1ac37f17a1e674337ea924e9f930725575cee15d
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
@@ -33,18 +35,8 @@
        while (this != null) {
            try {
                Thread.sleep(500);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
           List<String> addressList21 = Arrays.asList(config.getProperty("PLCManualJog.button").split(","));
                List<String> addressList21 = Arrays.asList(config.getProperty("PLCManualJog.button").split(","));
       List<Boolean> arraylist = S7control.getinstance().readBits(addressList21);
            JSONObject jsonObject = new JSONObject();
@@ -57,21 +49,16 @@
          //  System.out.println("messageValue:"+ arraylist  );
            jsonObject.append("params", params);
//      System.out.println("messageValue:" + arraylist +"messageValue2:" + arraylist2 );
//      WebSocketServer sendwServer = WebSocketServer.sessionMap.get("ManualJog");
//      if (sendwServer != null) {
//        sendwServer.sendMessage(jsonObject.toString());
//      }
            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()) {
@@ -116,10 +103,19 @@
                            webserver.clearMessages();
                        }
                    }else{
                        log.info("ManualJog is closed");
                    }
                }
            }
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }