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

ZengTao

2024-05-08 9472449b4ca46f482d13b6e628660c61101b443f

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

@@ -2,12 +2,13 @@

import cn.hutool.json.JSONArray;
import cn.hutool.json.JSONObject;
import lombok.extern.slf4j.Slf4j;

import java.io.IOException;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;

@Slf4j
public class PlcInteractionState extends Thread {
    private Configuration config;

@@ -15,95 +16,93 @@
        config = new Configuration("config.properties");
    }


    // 创建一个自定义的 S7 控制器消息处理器对象
    MessageHandler customS7Control = new MessageHandler();





    @Override
    public void run() {
        while (this != null) {
            try {
                Thread.sleep(100);
                // this.readValue();
                // String PlcAddress = this.name;
                // Integer Plccount = this.count;

                List<String> addresses = Arrays
                        .asList(config.getProperty("PlcInteractionState.MESImporttask").split(","));

                List<String> arraylist = S7control.getinstance().readStringsandword(addresses);
                // System.out.println(arraylist);
                List<String> addresses2 = Arrays
                        .asList(config.getProperty("PlcInteractionState.PLCImporttask").split(","));

                List<String> arraylist2 = S7control.getinstance().readStringsandword(addresses2);

                List<String> addresses3 = Arrays
                        .asList(config.getProperty("PlcInteractionState.MESProductiontask").split(","));

                List<String> arraylist3 = S7control.getinstance().readStringsandword(addresses3);

                List<String> addresses4 = Arrays
                        .asList(config.getProperty("PlcInteractionState.PLCProductiontask").split(","));

                List<String> arraylist4 = S7control.getinstance().readStringsandword(addresses4);

                List<String> addresses5 = Arrays
                        .asList(config.getProperty("PlcInteractionState.MEStaskinformation").split(","));
                List<String> arraylist5 = S7control.getinstance().readStringsandword(addresses5);

                List<String> addresses6 = Arrays
                        .asList(config.getProperty("PlcInteractionState.MEStaskinformation2").split(","));
                List<String> arraylist6 = S7control.getinstance().readStringsandword(addresses6);

                // String[] values = { ".x11","x21 ","x21 ","x21 ","x21 ","x21"};
                // List<String> arraylist = new ArrayList<>(Arrays.asList(values));
                // String[] values2 = { ".x11 ","x21 ","x21 ","x21 ","x21 ","x21 ","x21 "};
                // List<String> arraylist2 = new ArrayList<>(Arrays.asList(values2));
                // String[] values3 = { ".x11 ","x21 ","x21 ","x21 ","x21 ","x21 "};
                // List<String> arraylist3 = new ArrayList<>(Arrays.asList(values3));
                // String[] values4 = { ".x11 ","x21 ","x21 ","x21 "};
                // List<String> arraylist4 = new ArrayList<>(Arrays.asList(values4));
                // String[] values5 = { ".x11 ","x21 ","x21 ","b02","x21 ","x21 "};
                // List<String> arraylist5 = new ArrayList<>(Arrays.asList(values5));
                //
                // String[] values6 = { "x21 ","x21 ","x21 ","x21 ","x21 ","x21 ","x21 "};
                // List<String> arraylist6 = new ArrayList<>(Arrays.asList(values6));

                JSONObject jsonObject = new JSONObject();
                // System.out.println(arraylist6);
                JSONArray jsonArray = new JSONArray();
                jsonArray.put(arraylist);
                jsonArray.put(arraylist2);
                jsonArray.put(arraylist3);
                jsonArray.put(arraylist4);
                jsonArray.put(arraylist5);
                jsonArray.put(arraylist6);
                jsonObject.put("zuhe1", jsonArray);

                // WebSocketServer sendwServer =
                // WebSocketServer.sessionMap.get("ManualonePosition");
                // if (sendwServer != null) {
                // sendwServer.sendMessage(jsonObject.toString());
                // }

                ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("InteractionState");
                if (sendwServer != null) {
                    for (WebSocketServer webserver : sendwServer) {
                        if(webserver!=null&&webserver.session.isOpen()){
                            webserver.sendMessage(jsonObject.toString());
                        }else{
                            log.info("InteractionState is closed");
                        }
                        

                    }
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            // this.readValue();
            // String PlcAddress = this.name;
            // Integer Plccount = this.count;



            List<String> addresses = Arrays.asList(config.getProperty("PlcInteractionState.MESImporttask").split(","));

            List<String> arraylist = S7control.getinstance().readStringsandword(addresses);
            // System.out.println(arraylist);
            List<String> addresses2 = Arrays.asList(config.getProperty("PlcInteractionState.PLCImporttask").split(","));

            List<String> arraylist2 = S7control.getinstance().readStringsandword(addresses2);

            List<String> addresses3 = Arrays.asList(config.getProperty("PlcInteractionState.MESProductiontask").split(","));

            List<String> arraylist3 = S7control.getinstance().readStringsandword(addresses3);


            List<String> addresses4 = Arrays.asList(config.getProperty("PlcInteractionState.PLCProductiontask").split(","));

            List<String> arraylist4 = S7control.getinstance().readStringsandword(addresses4);


            List<String> addresses5 = Arrays.asList(config.getProperty("PlcInteractionState.MEStaskinformation").split(","));
            List<String> arraylist5 = S7control.getinstance().readStringsandword(addresses5);

            List<String> addresses6 = Arrays.asList(config.getProperty("PlcInteractionState.MEStaskinformation2").split(","));
            List<String> arraylist6 = S7control.getinstance().readStringsandword(addresses6);


//            String[] values = { ".x11","x21 ","x21 ","x21 ","x21 ","x21"};
//   List<String> arraylist = new ArrayList<>(Arrays.asList(values));
//            String[] values2 = { ".x11 ","x21 ","x21 ","x21 ","x21 ","x21 ","x21 "};
//            List<String> arraylist2 = new ArrayList<>(Arrays.asList(values2));
//            String[] values3 = { ".x11 ","x21 ","x21 ","x21 ","x21 ","x21 "};
//            List<String> arraylist3 = new ArrayList<>(Arrays.asList(values3));
//            String[] values4 = { ".x11 ","x21 ","x21 ","x21 "};
//            List<String> arraylist4 = new ArrayList<>(Arrays.asList(values4));
//            String[] values5 = { ".x11 ","x21 ","x21 ","b02","x21 ","x21 "};
//            List<String> arraylist5 = new ArrayList<>(Arrays.asList(values5));
//
//            String[] values6 = { "x21 ","x21 ","x21 ","x21 ","x21 ","x21 ","x21 "};
//            List<String> arraylist6 = new ArrayList<>(Arrays.asList(values6));



            JSONObject jsonObject = new JSONObject();
            // System.out.println(arraylist6);
            JSONArray jsonArray = new JSONArray();
            jsonArray.put(arraylist);
            jsonArray.put(arraylist2);
            jsonArray.put(arraylist3);
            jsonArray.put(arraylist4);
            jsonArray.put(arraylist5);
            jsonArray.put(arraylist6);
            jsonObject.put("zuhe1", jsonArray);


//      WebSocketServer sendwServer = WebSocketServer.sessionMap.get("ManualonePosition");
//      if (sendwServer != null) {
//        sendwServer.sendMessage(jsonObject.toString());
//      }

            ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("InteractionState");
            if (sendwServer != null) {
                for (WebSocketServer webserver : sendwServer) {
                    webserver.sendMessage(jsonObject.toString());


                }
            }
        }
    }
}