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 java.io.BufferedReader;
import java.io.FileReader;
import java.io.IOException;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import com.example.springboot.entity.device.PlcParameterObject;
import com.example.springboot.entity.device.PlcParameterInfo;
import org.springframework.core.io.ResourceLoader;


public class PlcParameter2Review extends Thread {

    @Autowired

    StorageCageService storageCageService;
    private ResourceLoader resourceLoader;
    private volatile static PlcParameter2Review instance = null;

    private PlcParameter2Review() {
        init();
    }

    // 单例模式 线程安全
    public static PlcParameter2Review getInstance() {
        if (instance == null) {
            synchronized (PlcParameter1Review.class) {
                if (instance == null) {
                    instance = new PlcParameter2Review();
                }
            }
        }
        return instance;
    }

    PlcParameterObject plcParameterObject = new PlcParameterObject();//该DB区数据实例

    private void init() {
        try {
            String jsonfilename = PlcParameter1Review.class.getResource("/JsonFile/PlcParameter.json").getFile();
            FileReader fileReader = new FileReader(jsonfilename);
            BufferedReader bufferedReader = new BufferedReader(fileReader);

            StringBuilder content = new StringBuilder();
            String line;

            while ((line = bufferedReader.readLine()) != null) {
                content.append(line);
            }

            bufferedReader.close();
            fileReader.close();

            JSONObject jsonfileobj = new JSONObject(content.toString());
            JSONArray jsonArray = jsonfileobj.getJSONArray("parameteInfor");
            plcParameterObject.setPlcAddressBegin(jsonfileobj.getStr("plcAddressBegin"));//设置起始位地址
            plcParameterObject.setPlcAddressLength(Integer.valueOf(jsonfileobj.getStr("plcAddressLenght")));//设置地址长度


            for (int i = 0; i < jsonArray.size(); i++) {
                JSONObject parameterObj = jsonArray.getJSONObject(i);

                PlcParameterInfo plcParameterInfo = new PlcParameterInfo(jsonfileobj.getStr("plcAddressBegin")); //参数实例
                String codeid = parameterObj.getStr("codeId");
                plcParameterInfo.setCodeId(codeid);
                plcParameterInfo.setAddressIndex(Integer.valueOf(parameterObj.getStr("addressIndex")));
                plcParameterInfo.setRatio(Integer.valueOf(parameterObj.getStr("ratio")));
                plcParameterInfo.setAddressLength(Integer.valueOf(parameterObj.getStr("addressLenght")));
                plcParameterInfo.setUnit(parameterObj.getStr("unit"));
                plcParameterObject.addPlcParameter(plcParameterInfo);
            }
            System.out.println("");
        } catch (IOException e) {
            e.printStackTrace();
        }

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

            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            storageCageService = WebSocketServer.applicationContext.getBean(StorageCageService.class);

            byte[] getplcvlues = S7control.getinstance().ReadByte(plcParameterObject.getPlcAddressBegin(), plcParameterObject.getPlcAddressLength());
            plcParameterObject.setPlcParameterList(getplcvlues);
            int index = plcParameterObject.getPlcParameter("conveyorVelocity(AutoFAST)").getAddressIndex();
            S7control.getinstance().WriteWord(plcParameterObject.getPlcParameter("conveyorVelocity(AutoFAST)").getAddress(index), (short) 100);

            List<String> addresses = new ArrayList<>();
            addresses.add("conveyorVelocity(AutoFAST)");
            addresses.add("conveyorVelocity(AutoSLOW)");
            addresses.add("conveyorVelocity(Manual)");
            addresses.add("A01A02TURNJOGVelocity");
            addresses.add("A01A02TRAVELJOGVelocity");
            //  id
//            List<String> addressList1 = Arrays.asList(config.getProperty("Parameter2.id").split(","));
//            List<String> paramlist = S7control.getinstance().readStrings(addressList1);
//            // System.out.println(paramlist);
//            //手动状态
//            List<String> addresses = Arrays.asList(config.getProperty("Parameter2.state").split(","));
//            List<Short> data = S7control.getinstance().readWords(addresses);
//            //清除id
//            List<String> addressList0 = Arrays.asList(config.getProperty("Parameter2.cleanid").split(","));
//            // 扫码枪
//            List<Boolean> data2 = S7control.getinstance().readBits(addressList0);
//            List<String> addressList3 = Arrays.asList(config.getProperty("Parameter2.scanner").split(","));
//
////急停按钮
//            List<String> niuanaddressList3 = Arrays.asList(config.getProperty("Parameter2.stop").split(","));
//            List<String> timeout = Arrays.asList(config.getProperty("Parameter2.timeout").split(","));
//            String timeout2 = config.getProperty("Parameter2.timeout");
//
//            Long readtimeout = S7control.getinstance().readtime(timeout2);
//            List<Boolean> anniuread = S7control.getinstance().readBits(niuanaddressList3);
//            List<String> data3 = S7control.getinstance().readStrings(addressList3);
//// A01 A02 B01 B02
//            List<String> addresses4 = Arrays.asList(config.getProperty("Parameter2.Currentcell").split(","));
//            List<Short> data4 = S7control.getinstance().readWords(addresses4);
            //System.out.println(data);



            //


//
//      String[] values6 = { ".x1 ","x2 ","x3",";;x4","x5","x6","x7","x8","x9","x10","x11"};
//      List<String> paramlist = new ArrayList<>(Arrays.asList(values6));
//      Short[] values1 = { 0, 1, 1, 1, 1, 1, 1, 1, 1, 1};
//     List<Short> data = new ArrayList<>(Arrays.asList(values1));
//      Boolean[] value4 = { false, false, false, false, false, false, false, false, false,
//              false};
//     List<Boolean> data2 = new ArrayList<>(Arrays.asList(value4));
//      String[] values3 = { ".x11 ","x21 "};
//      List<String> data3 = new ArrayList<>(Arrays.asList(values3));
//      Short[] values4 = { 2,2,3,4};
//      List<Short> data4 = new ArrayList<>(Arrays.asList(values4));
//
//
//            JSONObject jsonObject = new JSONObject();
//            short[] params = new short[data2.size()];
//            for (int i = 0; i < data2.size(); i++) {
//                boolean value = data2.get(i);
//                params[i] = value ? (short) 1 : (short) 0;
//            }
////
//            short[] anniuparams = new short[anniuread.size()];
//            for (int i = 0; i < anniuread.size(); i++) {
//                boolean value = anniuread.get(i);
//                anniuparams[i] = value ? (short) 1 : (short) 0;
//            }
            //boolean转为0 1
//            short[] params = customS7Control.convertBooleanListToShortArray(data2);
//            short[] anniuparams = customS7Control.convertBooleanListToShortArray(anniuread);
//            JSONObject jsonObject = new JSONObject();
//            jsonObject.append("params", params);
//            jsonObject.append("params", paramlist);
//            jsonObject.append("params", data);
//            jsonObject.append("params", data3);
//            jsonObject.append("params", data4);
//            jsonObject.append("jiting", anniuparams);
//            jsonObject.append("timeout", readtimeout);


//      WebSocketServer sendwServer = WebSocketServer.getWebSocketServer("Parameter2");
//      if (sendwServer != null) {
//        JSONObject jsonObject = new JSONObject();
//        jsonObject.set("message", "Hello, Parameter2!");
//        sendwServer.sendMessage(jsonObject.toString());
//      }
//            HomeController controller = new HomeController();
//            ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("Parameter2");
//            if (sendwServer != null) {
//                for (WebSocketServer webserver : sendwServer) {
//
//                    webserver.sendMessage(jsonObject.toString());
//
//
//                    if (webserver != null) {
//
//                        List<String> messages = webserver.getMessages();
//
//                        if (!messages.isEmpty()) {
//                            // 将最后一个消息转换为整数类型的列表
//                            String lastMessage = messages.get(messages.size() - 1);
////        System.out.println("lastMessage：" + lastMessage);
//                            JSONArray messageArray = new JSONArray(lastMessage);
//                            //清除ID
//                            // customS7Control.writeBitToPLC(messageArray, addressList0, 0);
//
//
//                            try {
//                                // 检查索引是否有效
//                                if (messageArray.getJSONArray(0).size() > 0) {
//                                    // 获取消息数组
//                                    JSONArray jsonArray = messageArray.getJSONArray(0);
//                                    // 创建一个布尔值列表
//                                    List<Boolean> sValue = new ArrayList<>();
//                                    // 遍历消息数组
//                                    for (int i = 0; i < jsonArray.size(); i++) {
//                                        // 获取消息数组中的值
//                                        Object value = jsonArray.get(i);
//                                        // 检查值是否有效
//                                        if (value != null && !value.toString().equals("null")) {
//                                            try {
//                                                // 移除非数字和数字字符
//                                                String cleanedValue = value.toString().replaceAll("[^0-9-]", "");
//                                                // 解析为布尔值
//                                                boolean val = "1".equals(cleanedValue.trim());
//                                                // 将布尔值添加到布尔值列表中
//                                                sValue.add(val);
//                                                System.out.println("messageValue: " + Arrays.asList(val) + " added to the list");
//
//
//                                            } catch (NumberFormatException e) {
//                                                // 如果无法解析为 boolean 类型，则忽略该部分
//                                                System.err.println("Could not parse value: " + value);
//                                            }
//                                        }
//                                    }
////完成出片
//                                    boolean containsOne = data.stream().anyMatch(number -> number == 1);
//                                    for (int i = 1; i <= 5; i++) {
//                                        boolean value = sValue.get(i);
//                                        String id = paramlist.get(i);
//                                        //判断是否自动状态
//                                        if (!containsOne) {
//                                            //判断id是否包含数字
//                                            if (id.matches(".*\\d.*")) {
//                                                //判断清楚id是否true
//                                                if (value) {
//                                                    System.out.println(id);
//                                                    switch (i) {
//                                                        case 1:
//                                                            storageCageService.UpdateTask(2, 0, paramlist.get(i));
//                                                            break;
//                                                        case 2:
//                                                        case 3:
//                                                        case 4:
//                                                        case 5:
//                                                            storageCageService.UpdateTask(3, 0, paramlist.get(i));
//                                                            break;
//                                                        default:
//                                                            // 处理索引值不在范围内的情况
//                                                            break;
//                                                    }
//                                                }
//                                            }
//
//                                        }
//                                        // 检查布尔值列表是否为空
//                                        if (!sValue.isEmpty()) {
//
//                                            // 调用 S7control.getinstance().WriteBit 方法将布尔值列表写入地址列表
//                                            S7control.getinstance().WriteBit(addressList0, sValue);
//                                            System.out.println("Values " + sValue + " written to PLC at address " + addressList0);
//                                        }
//                                    }
//                                }
//                            } catch (Exception e) {
//                                System.err.println("An error occurred while writing bit to PLC: " + e.getMessage());
//                            }
//
//
//                            //急停
////                            customS7Control.writeBitToPLC(messageArray, niuanaddressList3, 1);
//
//                            try {
//                                // 检查索引是否有效
//                                if (messageArray.getJSONArray(1).size() > 0) {
//                                    // 获取消息数组
//                                    JSONArray jsonArray = messageArray.getJSONArray(1);
//                                    // 创建一个布尔值列表
//                                    List<Boolean> sValue = new ArrayList<>();
//                                    // 遍历消息数组
//                                    for (int i = 0; i < jsonArray.size(); i++) {
//                                        // 获取消息数组中的值
//                                        Object value = jsonArray.get(i);
//                                        // 检查值是否有效
//                                        if (value != null && !value.toString().equals("null")) {
//                                            try {
//                                                // 移除非数字和数字字符
//                                                String cleanedValue = value.toString().replaceAll("[^0-9-]", "");
//                                                // 解析为布尔值
//                                                boolean val = "1".equals(cleanedValue.trim());
//                                                // 将布尔值添加到布尔值列表中
//                                                sValue.add(val);
//                                                System.out.println("messageValue: " + Arrays.asList(val) + " added to the list");
//
//
//                                            } catch (NumberFormatException e) {
//                                                // 如果无法解析为 boolean 类型，则忽略该部分
//                                                System.err.println("Could not parse value: " + value);
//                                            }
//                                        }
//                                    }
//// 终止进片任务
//                                    boolean Value1 = sValue.get(0);
//                                    boolean Value2 = sValue.get(1);
//
//                                    if (Value1) {
//                                        storageCageService.EndTask(0);
//
//                                    }
//                                    if (Value2) {
//                                        storageCageService.EndTask(1);
//
//                                    }
//                                    // 检查布尔值列表是否为空
//                                    if (!sValue.isEmpty()) {
//
//                                        // 调用 S7control.getinstance().WriteBit 方法将布尔值列表写入地址列表
//                                        S7control.getinstance().WriteBit(niuanaddressList3, sValue);
//                                        System.out.println("Values " + sValue + " written to PLC at address " + niuanaddressList3);
//                                    }
//                                }
//                            } catch (Exception e) {
//                                System.err.println("An error occurred while writing bit to PLC: " + e.getMessage());
//                            }
//
//
//                            //存片等待延迟
//                            customS7Control.Writetime(messageArray, timeout2, 2);
//
//
//                            // 清空消息列表
//                            webserver.clearMessages();
//                        }
//                    }
//                }
//            }
        }
    }
}