action 去除

wuyouming666

2023-12-14 84bb4d6cb579ee49e9a28c7507eabdf793a3a21e

 springboot-vue3/src/main/java/com/example/springboot/component/PlcManualonePosition2.java

@@ -10,296 +10,200 @@
import java.util.List;



public class PlcManualonePosition2 extends Thread {

  String name = "";

  Integer count = 0;

    private Configuration config;



  public static String readFileToString(String filePath) throws IOException {

    File file = new File(filePath);

    return FileUtils.readFileToString(file, "UTF-8");

  }



  public void readValue() {

    String str = "";

    BufferedReader bufferedReader = null;

    FileInputStream fileInputStream;

    try {

      // 从文件中读取字节数据存入 fileInputStream

      fileInputStream = new FileInputStream("CanadaMes-ui/src/configuration/address.json");

      // 读取 fileInputStream 中字节并将其解码为字符

      InputStreamReader inputStreamReader = new InputStreamReader(fileInputStream, "utf-8");

      // 提高读取效率，在 BufferedReader 内包装 InputStreamReader

      bufferedReader = new BufferedReader(inputStreamReader);

      String line = null;

      // 将 bufferedReader 内容一行一行赋值给str

      while ((line = bufferedReader.readLine()) != null) {

        str += line;

      }



      // 将str字符串格式转为json

      JSONObject jsonObject = new JSONObject(str);



      // 获取json中的值

      JSONArray address = jsonObject.getJSONArray("ServoManualone");

      for (int i = 0; i < address.size(); i++) {

        JSONObject ress = (JSONObject) address.get(i);



        this.name = ress.getStr("name");

        this.count = ress.getInt("count");



      }



    } catch (FileNotFoundException e) {

      e.printStackTrace();

    } catch (UnsupportedEncodingException e) {

      e.printStackTrace();

    } catch (IOException e) {

      e.printStackTrace();

    public PlcManualonePosition2() throws IOException {

        config = new Configuration("config.properties");

    }

  }



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

      }



      JSONObject jsonObject = new JSONObject();



      jsonObject.append("zuhe1", arraylist);

      jsonObject.append("zuhe2", arraylist2);

      jsonObject.append("guzhang", params2);

      jsonObject.append("weihuiling", params3);

      // System.out.println(jsonObject);

      WebSocketServer sendwServer = WebSocketServer.sessionMap.get("ManualonePosition2");

      if (sendwServer != null) {

        sendwServer.sendMessage(jsonObject.toString());

      }



      WebSocketServer webSocketServer = WebSocketServer.sessionMap.get("ManualonePosition2");

      if (webSocketServer != null) {

        List<String> messages = webSocketServer.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");

    MessageHandler customS7Control = new MessageHandler();



    public static class PLCBooleanConverter {



        // 故障地址

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

        waddresses3.add("DB103.242");

        waddresses3.add("DB103.248");

        public static short[] convertListsToBinaryShortArray(List<Boolean>... lists) {

            // 计算所有列表中元素的总数

            int totalSize = 0;

            for (List<Boolean> list : lists) {

                totalSize += list.size();

            }



        // 复位地址

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

        waddresses4.add("DB101.3.6");

        waddresses4.add("DB101.4.1");

            // 创建一个足够大的数组来存放所有的二进制值

            short[] binaryShortArray = new short[totalSize];



        // 回零地址

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

        waddresses5.add("DB101.3.7");

        waddresses5.add("DB101.4.2");

            // 当前数组填充位置指针

            int currentIndex = 0;



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

            // 遍历所有的列表

            for (List<Boolean> list : lists) {

                // 将每个布尔值转换为 0 或 1 并填入数组

                for (Boolean value : list) {

                    binaryShortArray[currentIndex++] = (short) (value ? 1 : 0);

                }

              }

            }

            if (!sValue.isEmpty()) {

              S7control.getinstance().WriteWord(waddresses1, sValue);

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

              A01start.add("DB101.2.0");

              Boolean[] a01values7 = { true};

              List<Boolean> a01startval = new ArrayList<>(Arrays.asList(a01values7));

              S7control.getinstance().WriteBit(A01start, a01startval);

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

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

              A02start.add("DB101.2.1");

              Boolean[] a02values7 = { true};

              List<Boolean> a01startval = new ArrayList<>(Arrays.asList(a02values7));

              S7control.getinstance().WriteBit(A02start, a01startval);

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

            }

          }



          // 清空消息列表

          webSocketServer.clearMessages();

            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下发

                            customS7Control.WriteWordToPLC(messageArray, waddresses1, 0);





                            // A02下发

                            customS7Control.WriteWordToPLC(messageArray, waddresses2, 1);





                            // 写入故障地址

                            customS7Control.WriteWordToPLC(messageArray, waddresses3, 2);





                            // 写入复位地址

                            customS7Control.writeBitToPLC(messageArray, waddresses4, 3);





                            // 写入回零地址

                            customS7Control.writeBitToPLC(messageArray, waddresses5, 4);



                            customS7Control.writeBitToPLC(messageArray, A01start, 5);

                            customS7Control.writeBitToPLC(messageArray, A02start, 6);



                            // 清空消息列表

                            webserver.clearMessages();

                        }

                    }

                }

            }

        }

    }

}