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 PlcManualonePosition2 extends Thread {
  private Configuration config;

  public PlcManualonePosition2() throws IOException {
    config = new Configuration("config.properties");
  }


  MessageHandler customS7Control = new MessageHandler();
  public static class PLCBooleanConverter {

    public static short[] convertListsToBinaryShortArray(List<Boolean>... lists) {
      // 计算所有列表中元素的总数
      int totalSize = 0;
      for (List<Boolean> list : lists) {
        totalSize += list.size();
      }

      // 创建一个足够大的数组来存放所有的二进制值
      short[] binaryShortArray = new short[totalSize];

      // 当前数组填充位置指针
      int currentIndex = 0;

      // 遍历所有的列表
      for (List<Boolean> list : lists) {
        // 将每个布尔值转换为 0 或 1 并填入数组
        for (Boolean value : list) {
          binaryShortArray[currentIndex++] = (short) (value ? 1 : 0);
        }
      }

      return binaryShortArray;
    }
  }




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

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

      List<String> addresses = new ArrayList<>();
      addresses.add("DB100.116");
      addresses.add("DB100.16");

      addresses.add("DB103.20");
      List<Short> arraylist = S7control.getinstance().readWords(addresses);
      // System.out.println(arraylist);

      List<String> addresses2 = new ArrayList<>();
      addresses2.add("DB100.118");
      addresses2.add("DB100.192");

      addresses2.add("DB103.22");
      List<Short> arraylist2 = S7control.getinstance().readWords(addresses2);

      List<String> addresses9 = new ArrayList<>();

      addresses9.add("DB104.1.2");
      addresses9.add("DB104.1.3");
      List<Boolean> arraylist9 = S7control.getinstance().readBits(addresses9);
      short[] params2 = new short[arraylist9.size()];
      for (int i = 0; i < arraylist9.size(); i++) {
        boolean value = arraylist9.get(i);
        params2[i] = value ? (short) 1 : (short) 0;
      }

      // Short[] values1 = { 1, 2, 3 };
      // List<Short> arraylist = new ArrayList<>(Arrays.asList(values1));
      // Short[] values2 = { 1, 2, 3 };
      // List<Short> arraylist2 = new ArrayList<>(Arrays.asList(values2));
      // Boolean[] values9 = { false, true };
      // List<Boolean> arraylist9 = new ArrayList<>(Arrays.asList(values9));
      // short[] params2 = new short[arraylist9.size()];
      // for (int i = 0; i < arraylist9.size(); i++) {
      // boolean value = arraylist9.get(i);
      // params2[i] = value ? (short) 1 : (short) 0;
      // }

      // Boolean[] values10 = { false, true };
      List<String> addresses10 = new ArrayList<>();

      addresses10.add("DB104.9.0");
      addresses10.add("DB104.9.1");
      List<Boolean> arraylist10 = S7control.getinstance().readBits(addresses10);
      short[] params3 = new short[arraylist10.size()];
      for (int i = 0; i < arraylist10.size(); i++) {
        boolean value = arraylist10.get(i);
        params3[i] = value ? (short) 1 : (short) 0;
      }



      //A01启动地址
      List<String> A01start = Arrays.asList(config.getProperty("mlp2.A01start"));
      //A02启动地址
      List<String> A02start = Arrays.asList(config.getProperty("mlp2.A02start"));



      List<Boolean> A01readstart = S7control.getinstance().readBits(A01start);
      List<Boolean> A02readstart = S7control.getinstance().readBits(A02start);


      short[] combinedBinaryShortArray = PLCBooleanConverter.convertListsToBinaryShortArray(
              A01readstart,  A02readstart
      );

      JSONObject jsonObject = new JSONObject();

      jsonObject.append("zuhe1", arraylist);
      jsonObject.append("zuhe2", arraylist2);
      jsonObject.append("guzhang", params2);
      jsonObject.append("weihuiling", params3);
      jsonObject.append("qidong", combinedBinaryShortArray);
      // System.out.println(jsonObject);
//      WebSocketServer sendwServer = WebSocketServer.sessionMap.get("ManualonePosition2");
//      if (sendwServer != null) {
//        sendwServer.sendMessage(jsonObject.toString());
//      }
      ArrayList<WebSocketServer> sendwServer = WebSocketServer.sessionMap.get("ManualonePosition2");
      if (sendwServer != null) {
        for (WebSocketServer webserver : sendwServer) {
          webserver.sendMessage(jsonObject.toString());

//      WebSocketServer webSocketServer = WebSocketServer.sessionMap.get("ManualonePosition2");
          if (webserver != null) {
            List<String> messages = webserver.getMessages();
            List<String> waddresses1 = new ArrayList<>();
            waddresses1.add("DB100.116");
            waddresses1.add("DB100.16");


            List<String> waddresses2 = new ArrayList<>();
            waddresses2.add("DB100.118");
            waddresses2.add("DB100.192");


            // 故障地址
            List<String> waddresses3 = new ArrayList<>();
            waddresses3.add("DB103.242");
            waddresses3.add("DB103.248");

            // 复位地址
            List<String> waddresses4 = new ArrayList<>();
            waddresses4.add("DB101.3.6");
            waddresses4.add("DB101.4.1");

            // 回零地址
            List<String> waddresses5 = new ArrayList<>();
            waddresses5.add("DB101.3.7");
            waddresses5.add("DB101.4.2");

            if (!messages.isEmpty()) {
              // 将最后一个消息转换为 short 类型的列表
              String lastMessage = messages.get(messages.size() - 1);
              // System.out.println("lastMessage：" + lastMessage);
              JSONArray messageArray = new JSONArray(lastMessage);

              // A01下发
              if (messageArray.getJSONArray(0).size() > 0) {
                JSONArray jsonArray = messageArray.getJSONArray(0);
                List<Short> 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-]", "");
                      short val = Short.parseShort(cleanedValue.trim());
                      sValue.add(val);
                      System.out.println("messageValue：" + Arrays.asList(val) + " added to the list");
                    } catch (NumberFormatException e) {
                      // 如果无法解析为 short 类型，则忽略该部分
                      System.err.println("Could not parse value: " + value);
                    }
                  }
                }
                if (!sValue.isEmpty()) {
                  S7control.getinstance().WriteWord(waddresses1, sValue);

                  System.out.println("Values " + sValue + " written to PLC at address " + waddresses1);
                }
              }

              // A02下发
              if (messageArray.getJSONArray(1).size() > 0) {
                JSONArray jsonArray = messageArray.getJSONArray(1);
                List<Short> sValue2 = 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-]", "");
                      short val = Short.parseShort(cleanedValue.trim());
                      sValue2.add(val);
                      System.out.println("messageValue：" + Arrays.asList(val) + " added to the list");
                    } catch (NumberFormatException e) {
                      // 如果无法解析为 short 类型，则忽略该部分
                      System.err.println("Could not parse value: " + value);
                    }
                  }
                }
                if (!sValue2.isEmpty()) {
                  S7control.getinstance().WriteWord(waddresses2, sValue2);

                  System.out.println("Values " + sValue2 + " written to PLC at address " + waddresses2);
                }
              }

              // 写入故障地址
              if (messageArray.getJSONArray(2).size() > 0) {
                JSONArray jsonArray = messageArray.getJSONArray(2);
                List<Short> sValue2 = 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-]", "");
                      short val = Short.parseShort(cleanedValue.trim());
                      sValue2.add(val);
                      System.out.println("messageValue：" + Arrays.asList(val) + " added to the list");
                    } catch (NumberFormatException e) {
                      // 如果无法解析为 short 类型，则忽略该部分
                      System.err.println("Could not parse value: " + value);
                    }
                  }
                }
                if (!sValue2.isEmpty()) {
                  S7control.getinstance().WriteWord(waddresses3, sValue2);
                  System.out.println("Values " + sValue2 + " written to PLC at address " + waddresses3);
                }
              }

              // 写入复位地址
              if (messageArray.getJSONArray(3).size() > 0) {
                JSONArray jsonArray3 = messageArray.getJSONArray(3);
                List<Boolean> sValue3 = new ArrayList<>();
                for (int i = 0; i < jsonArray3.size(); i++) {
                  Object value = jsonArray3.get(i);
                  if (value != null && !value.toString().equals("null")) {
                    try {
                      String cleanedValue = value.toString().replaceAll("[^0-9-]", "");
                      boolean val = "1".equals(cleanedValue.trim());
                      sValue3.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);
                    }
                  }
                }
                if (!sValue3.isEmpty()) {
                  S7control.getinstance().WriteBit(waddresses4, sValue3);
                  System.out.println("Values " + sValue3 + " written to PLC at address " + waddresses4);
                }
              }

              // 写入回零地址
              if (messageArray.getJSONArray(4).size() > 0) {
                JSONArray jsonArray3 = messageArray.getJSONArray(4);
                List<Boolean> sValue3 = new ArrayList<>();
                for (int i = 0; i < jsonArray3.size(); i++) {
                  Object value = jsonArray3.get(i);
                  if (value != null && !value.toString().equals("null")) {
                    try {
                      String cleanedValue = value.toString().replaceAll("[^0-9-]", "");
                      boolean val = "1".equals(cleanedValue.trim());
                      sValue3.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);
                    }
                  }
                }
                if (!sValue3.isEmpty()) {
                  S7control.getinstance().WriteBit(waddresses5, sValue3);
                  System.out.println("Values " + sValue3 + " written to PLC at address " + waddresses5);
                }
              }


              customS7Control.writeBitToPLC( messageArray, A01start,5);
              customS7Control.writeBitToPLC( messageArray, A02start,6);

              // 清空消息列表
              webserver.clearMessages();
            }
          }
        }
      }
    }
  }
}