package com.example.springboot.component;

import cn.hutool.json.JSONObject;
import com.example.springboot.entity.device.PlcBitObject;
import static com.example.springboot.component.InitUtil.readAndUpdateBitValues;
import static com.example.springboot.component.InitUtil.readAndUpdateWordValues;

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

public class PLCManualJogReview extends Thread {


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

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

    // 单例实例
    private static PLCManualJogReview instance;



    public PLCManualJogReview() throws IOException {
        config = new Configuration("config.properties");
        initUtil = new InitUtil();
    }

    // 获取单例实例
    public static synchronized PLCManualJogReview getInstance() throws IOException {
        if (instance == null) {
            instance = new PLCManualJogReview();
        }
        return instance;
    }
    String jsonFilePath = PLCManualJogReview.class.getResource("/JsonFile/PlcTest.json").getPath();

    PlcBitObject plcTestObject = initUtil.initbit(jsonFilePath);

    @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);


            readAndUpdateBitValues(plcTestObject);

            List<String> codeidlist = Arrays.asList(
                    "D01VFDconveyor", "D02VFDconveyor", "D03VFDconveyor", "D04VFDconveyor",
                    "D05VFDconveyor", "D06VFDconveyor","A01VFDconveyor", "A01VFDconveyorreverse", "A01SERVETRAVEL",
                    "A01SERVETURN", "A01oilpump", "A02VFDconveyor", "A02VFDconveyorreverse",
                    "A02SERVETRAVEL", "A02SERVETURN", "A02oilpump", "B01VFDconveyor", "B01SERVETRAVEL",
                    "B01YVTURN", "B01YVUPDOWN", "B01YVGassing", "B02VFDconveyor", "B02SERVETRAVEL",
                    "B02YVTURN", "B02YVUPDOWN", "B02YVGassing", "A01SERVETRAVELhome", "A02SERVETRAVELhome"
            );



//PLCManualJog.button=DB101.0.0,DB101.0.1,DB101.0.2,DB101.0.3,DB101.0.4,DB101.0.5,DB101.0.6,DB101.3.4,DB101.1.4,DB101.1.2,DB101.5.2,DB101.0.7,DB101.3.5,DB101.1.5,DB101.1.3,DB101.5.3,DB101.1.0,DB101.1.6,DB101.2.6,DB101.2.7,DB101.3.2,DB101.1.1,DB101.1.7,DB101.3.0,DB101.3.1,DB101.3.3,DB101.10.5,DB101.10.6

            List<String> address =  plcTestObject.getAddressListByCodeId(codeidlist);
         System.out.println(address);

//
//            int index2 = plcTestObject.getPlcBit("B01YVUPDOWN").getAddressIndex();
//            System.out.println(index2);
//
//            System.out.println(plcTestObject.getPlcBit("B01YVUPDOWN").getAddress(index2));
            List<Boolean> arraylist = plcTestObject.getPlcBitValues(codeidlist);


            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;
            }

            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(address, bolList);
//

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

                            webserver.clearMessages();
                        }
                    }
                }

            }

        }
    }
}