From de6afc2ec06724885de7cc0eb8b8cad61f8c0b3b Mon Sep 17 00:00:00 2001
From: ZengTao <2773468879@qq.com>
Date: 星期四, 07 十二月 2023 08:32:41 +0800
Subject: [PATCH] Merge branch 'master' of http://10.153.19.25:10101/r/CanadaMes

---
 springboot-vue3/src/main/java/com/example/springboot/component/PlcManualonePosition2.java |  324 ++++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 324 insertions(+), 0 deletions(-)

diff --git a/springboot-vue3/src/main/java/com/example/springboot/component/PlcManualonePosition2.java b/springboot-vue3/src/main/java/com/example/springboot/component/PlcManualonePosition2.java
new file mode 100644
index 0000000..9fd9c89
--- /dev/null
+++ b/springboot-vue3/src/main/java/com/example/springboot/component/PlcManualonePosition2.java
@@ -0,0 +1,324 @@
+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");
+  }
+
+  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 = PlcManualonePosition2.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());
+      }
+
+      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");
+
+
+        // 鏁呴殰鍦板潃
+        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) {
+                  // 濡傛灉鏃犳硶瑙f瀽涓� short 绫诲瀷锛屽垯蹇界暐璇ラ儴鍒�
+                  System.err.println("Could not parse value: " + value);
+                }
+              }
+            }
+            if (!sValue.isEmpty()) {
+              S7control.getinstance().WriteWord(waddresses1, sValue);
+              if (A01readstart != null && !A01readstart.isEmpty()) {
+                // 鍒涘缓涓�涓柊鐨勫垪琛ㄧ敤浜庡啓鍏ユ柊鍊�
+                List<Boolean> a01startval = new ArrayList<>();
+                // 閬嶅巻鎵�鏈夎鍙栧埌鐨勪綅鍊�
+                for (Boolean bit : A01readstart) {
+                  // 鍙栧弽褰撳墠浣嶇殑鍊煎苟娣诲姞鍒版柊鐨勫垪琛ㄤ腑
+                  a01startval.add(!bit);
+                }
+                // 鍐欏叆鏂扮殑浣嶅�煎垪琛�
+                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) {
+                  // 濡傛灉鏃犳硶瑙f瀽涓� short 绫诲瀷锛屽垯蹇界暐璇ラ儴鍒�
+                  System.err.println("Could not parse value: " + value);
+                }
+              }
+            }
+            if (!sValue2.isEmpty()) {
+              S7control.getinstance().WriteWord(waddresses2, sValue2);
+              if (A02readstart != null && !A02readstart.isEmpty()) {
+                // 鍒涘缓涓�涓柊鐨勫垪琛ㄧ敤浜庡啓鍏ユ柊鍊�
+                List<Boolean> a02startval = new ArrayList<>();
+                // 閬嶅巻鎵�鏈夎鍙栧埌鐨勪綅鍊�
+                for (Boolean bit : A02readstart) {
+                  // 鍙栧弽褰撳墠浣嶇殑鍊煎苟娣诲姞鍒版柊鐨勫垪琛ㄤ腑
+                  a02startval.add(!bit);
+                }
+                // 鍐欏叆鏂扮殑浣嶅�煎垪琛�
+                S7control.getinstance().WriteBit(A02start, a02startval);
+              }
+              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) {
+                  // 濡傛灉鏃犳硶瑙f瀽涓� 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) {
+                  // 濡傛灉鏃犳硶瑙f瀽涓� 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) {
+                  // 濡傛灉鏃犳硶瑙f瀽涓� 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();
+        }
+      }
+    }
+  }
+}

--
Gitblit v1.8.0