更新理片笼逻辑

wu

2023-12-01 8a0ae6d19d78d2295a10b1cc97bfe17e651234ea

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

@@ -17,135 +17,131 @@
import org.apache.commons.io.FileUtils;



public class PlcPositioning1 extends Thread {

    String name = "";

    Integer count = 0;

  String name = "";

  Integer count = 0;



    public static String readFileToString(String filePath) throws IOException {

        File file = new File(filePath);

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

  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("Positioning1");

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

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



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

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

        System.out.println("messageValues：" + this.name);

        System.out.println("messageValues：" + this.count);

      }



    } catch (FileNotFoundException e) {

      e.printStackTrace();

    } catch (UnsupportedEncodingException e) {

      e.printStackTrace();

    } catch (IOException e) {

      e.printStackTrace();

    }

  }



    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;

            }

  @Override

  public void run() {

    while (this != null) {

      try {

        Thread.sleep(1000);



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

            JSONObject jsonObject = new JSONObject(str);

      } catch (InterruptedException e) {

        e.printStackTrace();

      }

      // this.readValue();

      // String PlcAddress = this.name;

      // Integer Plccount = this.count;



            // 获取json中的值

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

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

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

      // System.out.println(stt);

      List<Short> arraylist = S7control.getinstance().ReadWord("DB100.42", 23);



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

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

                System.out.println("messageValues：" + this.name);

                System.out.println("messageValues：" + this.count);

            }

      // Short[] 存片 = { 1 };

      // List<Short> 存片1 = new ArrayList<>(Arrays.asList(存片));

      // Short[] 接片 = { 1 };

      // List<Short> 接片1 = new ArrayList<>(Arrays.asList(接片));

      // Short[] 间距 = { 1 };

      // List<Short> 间距1 = new ArrayList<>(Arrays.asList(间距));

      // Short[] values1 = {1,1,1, 1,2, 3, 4, 5, 6, 7, 8, 9, 10,11,

      // 12,13,14,15,16,17,18,19,20 };

      // List<Short> arraylist = new ArrayList<>(Arrays.asList(values1));



        } catch (FileNotFoundException e) {

            e.printStackTrace();

        } catch (UnsupportedEncodingException e) {

            e.printStackTrace();

        } catch (IOException e) {

            e.printStackTrace();

        }

    }

      JSONObject jsonObject = new JSONObject();



    @Override

    public void run() {

        while (this != null) {

            try {

                Thread.sleep(1000);

      jsonObject.append("params", arraylist);



            } catch (InterruptedException e) {

                e.printStackTrace();

            }

//        this.readValue();

//            String PlcAddress = this.name;

//            Integer Plccount = this.count;

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

      if (sendwServer != null) {

        sendwServer.sendMessage(jsonObject.toString());

      }



            // System.out.println(stt);

  List<Short> arraylist = S7control.getinstance().ReadWord("DB100.42", 20);

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

      if (webSocketServer != null) {

        List<String> messages = webSocketServer.getMessages();



//            Short[] 存片 = { 1 };

//            List<Short> 存片1 = new ArrayList<>(Arrays.asList(存片));

//            Short[] 接片 = { 1 };

//            List<Short> 接片1 = new ArrayList<>(Arrays.asList(接片));

//            Short[] 间距 = { 1 };

//            List<Short> 间距1 = new ArrayList<>(Arrays.asList(间距));

//            Short[] values1 = {1,1,1, 1,2, 3, 4, 5, 6, 7, 8, 9, 10,11, 12,13,14,15,16,17,18,19,20 };

//            List<Short> arraylist = new ArrayList<>(Arrays.asList(values1));

        String addressList3 = "DB100.12";



        if (!messages.isEmpty()) {

          // 将最后一个消息转换为 short 类型的列表

          String lastMessage = messages.get(messages.size() - 1);

          // System.out.println("lastMessage：" + lastMessage);

          JSONArray messageArray = new JSONArray(lastMessage);



            JSONObject jsonObject = new JSONObject();





            jsonObject.append("params", arraylist);





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

            if (sendwServer != null) {

                sendwServer.sendMessage(jsonObject.toString());

            }



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

            if (webSocketServer != null) {

                List<String> messages = webSocketServer.getMessages();



                String addressList3 = "DB100.12";



                if (!messages.isEmpty()) {

                    // 将最后一个消息转换为 short 类型的列表

                    String lastMessage = messages.get(messages.size() - 1);

//        System.out.println("lastMessage：" + lastMessage);

                    JSONArray messageArray = new JSONArray(lastMessage);



                    // 整合第 1 到 3 个数组并去掉 null 元素

                    List<Short> mergedList = new ArrayList<>();

                    for (int i = 0; i < 5; 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);

                                }

                            }

                        }

                    }





                    // 写入第yi个地址

                    if (!mergedList.isEmpty()) {

//            S7control.getinstance().WriteWord(addressList3, mergedList);

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

                    }



                    // 清空消息列表

                    webSocketServer.clearMessages();

          // 整合第 1 到 3 个数组并去掉 null 元素

          List<Short> mergedList = new ArrayList<>();

          for (int i = 0; i < 5; 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);

                }





              }

            }

          }



          // 写入第yi个地址

          if (!mergedList.isEmpty()) {

            // S7control.getinstance().WriteWord(addressList3, mergedList);

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

          }



          // 清空消息列表

          webSocketServer.clearMessages();

        }



      }

    }

  }

}