package com.example.springboot.component;

import cn.hutool.json.JSONArray;
import cn.hutool.json.JSONObject;
import com.example.springboot.service.StorageCageService;

import org.springframework.beans.factory.annotation.Autowired;
import com.example.springboot.entity.device.PlcParameterObject;
import com.example.springboot.entity.device.PlcBitObject;

import org.springframework.stereotype.Component;

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

@Component
public class PLCAutomaticParameterSettingReview extends Thread {

    private StorageCageService storageCageService = new StorageCageService();
    private final PlcParameterObject plcParameterObject;
    private final PlcBitObject plcBitObject;
    MessageHandler customS7Control = new MessageHandler();
    @Autowired
    public PLCAutomaticParameterSettingReview() {
        this.storageCageService = storageCageService;
        this.plcParameterObject = new PlcParameterObject();
        this.plcBitObject = new PlcBitObject();
        // String jsonFilePath = "/JsonFile/PlcParameter.json";
        // InitUtil.initword(jsonFilePath); // 初始化 PlcParameterObject
        // String jsonFilePath2 = "/JsonFile/PlcSign.json";
        // InitUtil.initbit(jsonFilePath2); // 初始化 PlcSign


    }

    // 单例模式 线程安全
    public static PLCAutomaticParameterSettingReview getInstance(StorageCageService storageCageService) {
        return new PLCAutomaticParameterSettingReview();
    }

    @Override
    public void run() {
        while (!Thread.currentThread().isInterrupted()) {
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
                e.printStackTrace();
            }

            byte[] getplcvlues = S7control.getinstance().ReadByte(plcParameterObject.getPlcAddressBegin(), plcParameterObject.getPlcAddressLength());

            //byte[] getplcvlues = {0x01, 0x02, 0x03, 0x04,0x01, 0x02, 0x03, 0x04,0x01, 0x02, 0x03, 0x04,0x01, 0x02};

            plcParameterObject.setPlcParameterList(getplcvlues);


//            List<String> addresses = new ArrayList<>();
//            addresses.add("A01turnAngle1");
//            addresses.add("A01turnAngle2");
//            addresses.add("A01turnAngle3");
//            addresses.add("A01turnAngle4");
//            addresses.add("A02turnAngle2");
//            addresses.add("A02turnAngle3");
//            addresses.add("A02turnAngle4");
//            addresses.add("Minimumglasslength");


            //Auto.addresses=DB100.0,DB100.2,DB100.4,DB100.6,DB100.26,DB100.28,DB100.30,DB100.32,DB100.34,DB100.36,DB100.38,DB100.40
            List<String> Autoaddresses = new ArrayList<>();
            Autoaddresses.add("conveyorVelocity(Max)");
            Autoaddresses.add("conveyorVelocity(AutoFAST)");
            Autoaddresses.add("conveyorVelocity(AutoSLOW)");
            Autoaddresses.add("conveyorVelocity(Manual)");
            Autoaddresses.add("A01A02conveyorVelocity(Max)");
            Autoaddresses.add("A01A02conveyorVelocity(AutoFAST)");
            Autoaddresses.add("A01A02conveyorVelocity(AutoSLOW)");
            Autoaddresses.add("B01B02conveyorVelocity(Manual)");
            Autoaddresses.add("B01B02conveyorVelocity(Max)");
            Autoaddresses.add("B01B02conveyorVelocity(AutoFAST)");
            Autoaddresses.add("B01B02conveyorVelocity(AutoSLOW)");
            Autoaddresses.add("B01B02conveyorVelocity(Manual)");







            String addressList1 = "DB100.120";
            String addressList2 = "DB100.18";
            String addressList3 = "DB100.22";
            String addressList4 = "DB100.14";
System.out.println(plcParameterObject.getPlcParameterValues(Autoaddresses));






          //  List<Short> dache1 = S7control.getinstance().ReadWord("DB100.18", 1);
          //  List<Short> xiaoche1 = S7control.getinstance().ReadWord("DB100.22", 1);
          //  List<Short> fanzhuan1 = S7control.getinstance().ReadWord("DB100.14", 1);
           // List<String> addresses = Arrays.asList(config.getProperty("Auto.addresses").split(","));
          //  List<Short> arraylist2 = S7control.getinstance().readWords(addresses);
            //System.out.println("lastMessage：" + arraylist2);
//翻转
            //List<Short> fanzhuan2 = S7control.getinstance().ReadWord("DB100.8", 1);
           // List<Short> xiaoche2 = S7control.getinstance().ReadWord("DB100.12", 1);
            JSONObject jsonObject = new JSONObject();
            // new short[]{1,1, 1, 1, 1, 1, 2, 33, 2,3, 4, 5}
            // new short[]{0,0, 0, 0, 0, 0, 0, 0, 0, 0}
//System.out.println(plcParameterObject.getPlcParameterValues(addresses));
          //  jsonObject.append("params",  plcParameterObject.getPlcParameterValues(addresses));
//            jsonObject.append("dache1", plcParameterObject.getPlcParameter("A01A02TRAVELPOSVelocityAUTO").getValue());
//            jsonObject.append("xiaoche", plcParameterObject.getPlcParameter("B01B02TRAVELPOSVelocityAUTO").getValue());
//            jsonObject.append("fanzhuan", plcParameterObject.getPlcParameter("A01A02TURNPOSVelocityAUTO").getValue());
//            jsonObject.append("params2", plcParameterObject.getPlcParameterValues(Autoaddresses));
//            jsonObject.append("fanzhuan2", plcParameterObject.getPlcParameter("A01A02TURNJOGVelocity").getValue());
//            jsonObject.append("xiaoche2",  plcParameterObject.getPlcParameter("B01B02TRAVELJOGVelocity").getValue());

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

//      WebSocketServer webSocketServer = WebSocketServer.sessionMap.get("AutomaticParameterSetting");
//                    if (webserver != null) {
//                        List<String> messages = webserver.getMessages();
//
//
//                        if (!messages.isEmpty()) {
//                            // 将最后一个消息转换为 short 类型的列表
//                            String lastMessage = messages.get(messages.size() - 1);
//                            // System.out.println("lastMessage：" + lastMessage);
//                            JSONArray messageArray = new JSONArray(lastMessage);
//
//                            // 整合第 1 到 2 个数组并去掉 null 元素
//                            List<Short> mergedList = new ArrayList<>();
//                            for (int i = 0; i < 2; i++) {
//                                JSONArray sublist = messageArray.getJSONArray(i);
//                                for (int j = 0; j < sublist.size(); j++) {
//                                    Object value = sublist.get(j);
//                                    if (value != null && !value.toString().equals("null")) {
//                                        try {
//                                            String cleanedValue = value.toString().replaceAll("[^0-9-]", "");
//                                            short sValue = Short.parseShort(cleanedValue.trim());
//                                            mergedList.add(sValue);
//                                        } catch (NumberFormatException e) {
//                                            // 如果无法解析为 short 类型，则忽略该部分
//                                            System.err.println("Could not parse value: " + value);
//                                        }
//                                    }
//                                }
//                            }
//                            System.out.println(messageArray);
//                            // 写入第一个地址
//                            customS7Control.WriteWordsToPLC(messageArray, addressList2,2);
//                            // 写入第二个地址
//                            customS7Control.WriteWordsToPLC(messageArray, addressList3,3);
//                            // 写入第三个地址
//                            customS7Control.WriteWordsToPLC(messageArray, addressList4,4);
//                            // 写入第四个地址
//                            if (!mergedList.isEmpty()) {
//                                S7control.getinstance().WriteWord(addressList1, mergedList);
//                                System.out.println("messageValue：" + mergedList + " written to PLC at address " + addressList1);
//                            }
//
//                            //List<String> waddresses1 = Arrays.asList(config.getProperty("Auto.shusong").split(","));
//                            String addressList22 = "DB100.8";
//                            String addressList33 = "DB100.12";
//                            if (!messages.isEmpty()) {
//                                // 将最后一个消息转换为 short 类型的列表
//                                // 整合第 1 到 3 个数组并去掉 null 元素
//                                List<Short> mergedList2 = new ArrayList<>();
//                                for (int i = 5; i < 8; i++) {
//                                    JSONArray sublist = messageArray.getJSONArray(i);
//                                    for (int j = 0; j < sublist.size(); j++) {
//                                        Object value = sublist.get(j);
//                                        if (value != null && !value.toString().equals("null")) {
//                                            try {
//                                                String cleanedValue = value.toString().replaceAll("[^0-9-]", "");
//                                                short sValue = Short.parseShort(cleanedValue.trim());
//                                                mergedList2.add(sValue);
//                                            } catch (NumberFormatException e) {
//                                                // 如果无法解析为 short 类型，则忽略该部分
//                                                System.err.println("Could not parse value: " + value);
//                                            }
//                                        }
//                                    }
//                                }
//
//                                // 写入第伍个地址
//                                customS7Control.WriteWordsToPLC(messageArray, addressList22,8);
//                                // 写入第六个地址
//                                customS7Control.WriteWordsToPLC(messageArray, addressList33,9);
//                                // 写入第七个地址
//                             //   plcParameterObject.getPlcParameter("conveyorVelocity(AutoFAST)").getAddress(index)
//                                if (!mergedList2.isEmpty()) {
//                                    //S7control.getinstance().WriteWord(plcParameterObject.getPlcParameter(Autoaddresses), mergedList2);
//                                  //  System.out.println("messageValue：" + mergedList2 + " written to PLC at address " + waddresses1);
//                                }
//                                // 清空消息列表
//                                webserver.clearMessages();
//                            }
//                        }
//                    }
//
//                }
//            }


        }
    }
}