package com.example.springboot.component;

import cn.hutool.json.JSONArray;
import cn.hutool.json.JSONObject;
import org.apache.commons.io.FileUtils;

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

public class PLCManualJog extends Thread {


    // 用于存储应用程序的配置信息
    private Configuration config;

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


    public PLCManualJog() throws IOException {
        config = new Configuration("config.properties");
    }
//    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 };
//    List<Boolean> arraylist = new ArrayList<>(Arrays.asList(values1));

    @Override
    public void run() {
        while (this != null) {
            try {
                Thread.sleep(500);

            } catch (InterruptedException e) {
                e.printStackTrace();
            }



           List<String> addressList21 = Arrays.asList(config.getProperty("PLCManualJog.button").split(","));
       List<Boolean> arraylist = S7control.getinstance().readBits(addressList21);


            JSONObject jsonObject = new JSONObject();

            short[] params = new short[arraylist.size()];
            for (int i = 0; i < arraylist.size(); i++) {
                boolean value = arraylist.get(i);
                params[i] = value ? (short) 1 : (short) 0;
            }
          //  System.out.println("messageValue："+ arraylist  );
            jsonObject.append("params", params);


            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) {


                        List<String> messages = webserver.getMessages();
                        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 == 1 ? true : false);
                            }
                            // System.out.println(messageBooleans);
                            List<Boolean> bolList = new ArrayList<>();


                            for (int i = 0; i < 28 && i < messageBooleans.size(); i++) {
                                bolList.add(messageBooleans.get(i));
                            }


                            if (!bolList.isEmpty()) {
                         S7control.getinstance().WriteBit(addressList21, bolList);
//                                arraylist.clear();
//                                arraylist.addAll(bolList);

                                System.out.println("messageValue：" + bolList + " written to PLC at address " + addressList21);
                            }

                            webserver.clearMessages();
                        }
                    }
                }

            }

        }
    }
}