From c39cbcb00cbff39d50756a58e0e1c64dde160fc1 Mon Sep 17 00:00:00 2001
From: clll <1320612696@qq.com>
Date: 星期一, 27 十一月 2023 13:43:37 +0800
Subject: [PATCH] 更新

---
 .vscode/launch.json                                                                              |   28 ++++
 .vscode/settings.json                                                                            |    3 
 CanadaMes-ui/src/img/xmjclzh.png                                                                 |    0 
 springboot-vue3/src/main/java/com/example/springboot/component/PLCAutomaticParameterSetting.java |  199 ++++++++++++++++++++++++++++
 springboot-vue3/src/main/java/com/example/springboot/component/PlcManualonePosition.java         |  172 ++++++++++++++++++++++++
 5 files changed, 402 insertions(+), 0 deletions(-)

diff --git a/.vscode/launch.json b/.vscode/launch.json
new file mode 100644
index 0000000..9e59f51
--- /dev/null
+++ b/.vscode/launch.json
@@ -0,0 +1,28 @@
+{
+  // 浣跨敤 IntelliSense 浜嗚В鐩稿叧灞炴�с�� 
+  // 鎮仠浠ユ煡鐪嬬幇鏈夊睘鎬х殑鎻忚堪銆�
+  // 娆蹭簡瑙f洿澶氫俊鎭紝璇疯闂�: https://go.microsoft.com/fwlink/?linkid=830387
+  "version": "0.2.0",
+  "configurations": [
+    {
+      "type": "java",
+      "name": "Current File",
+      "request": "launch",
+      "mainClass": "${file}"
+    },
+    {
+      "type": "java",
+      "name": "MyGenerator",
+      "request": "launch",
+      "mainClass": "MyGenerator",
+      "projectName": "canadames"
+    },
+    {
+      "type": "java",
+      "name": "AuthorityApplication",
+      "request": "launch",
+      "mainClass": "com.example.springboot.AuthorityApplication",
+      "projectName": "canadames"
+    }
+  ]
+}
\ No newline at end of file
diff --git a/.vscode/settings.json b/.vscode/settings.json
new file mode 100644
index 0000000..dc3b895
--- /dev/null
+++ b/.vscode/settings.json
@@ -0,0 +1,3 @@
+{
+  "java.configuration.updateBuildConfiguration": "interactive"
+}
\ No newline at end of file
diff --git a/CanadaMes-ui/src/img/xmjclzh.png b/CanadaMes-ui/src/img/xmjclzh.png
new file mode 100644
index 0000000..5935f14
--- /dev/null
+++ b/CanadaMes-ui/src/img/xmjclzh.png
Binary files differ
diff --git a/springboot-vue3/src/main/java/com/example/springboot/component/PLCAutomaticParameterSetting.java b/springboot-vue3/src/main/java/com/example/springboot/component/PLCAutomaticParameterSetting.java
new file mode 100644
index 0000000..f5d262f
--- /dev/null
+++ b/springboot-vue3/src/main/java/com/example/springboot/component/PLCAutomaticParameterSetting.java
@@ -0,0 +1,199 @@
+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 PLCAutomaticParameterSetting extends Thread {
+  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 void readValue() {
+    String str = "";
+    BufferedReader bufferedReader = null;
+    FileInputStream fileInputStream;
+    try {
+      // 浠庢枃浠朵腑璇诲彇瀛楄妭鏁版嵁瀛樺叆 fileInputStream
+      fileInputStream = new FileInputStream("CanadaMes-ui/src/configuration/address.json");
+      // 璇诲彇 fileInputStream 涓瓧鑺傚苟灏嗗叾瑙g爜涓哄瓧绗�
+      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;
+      }
+
+      // 灏唖tr瀛楃涓叉牸寮忚浆涓簀son
+      JSONObject jsonObject = new JSONObject(str);
+
+      // 鑾峰彇json涓殑鍊�
+      JSONArray address = jsonObject.getJSONArray("address");
+      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();
+    }
+  }
+
+  @Override
+  public void run() {
+    while (this != null) {
+      try {
+        Thread.sleep(1000);
+
+      } catch (InterruptedException e) {
+        e.printStackTrace();
+      }
+      // this.readValue();
+      // String PlcAddress = this.name;
+      // Integer Plccount = this.count;
+
+      // System.out.println(stt);
+      // List<Short> arraylist = S7control.getinstance().ReadWord("DB100.120", 8);
+      // List<Short> dache1 = S7control.getinstance().ReadWord("DB100.18", 1);
+      // List<Short> xiaoche1 = S7control.getinstance().ReadWord("DB100.22", 1);
+      // List<Short> fanzhuan1 = S7control.getinstance().ReadWord("DB100.14", 1);
+      Short[] values1 = { 1, 2, 3, 4, 5, 6, 7, 8 };
+      List<Short> arraylist = new ArrayList<>(Arrays.asList(values1));
+      Short[] fanzhuan = { 4 };
+      List<Short> fanzhuan1 = new ArrayList<>(Arrays.asList(fanzhuan));
+      Short[] dache = { 5 };
+      List<Short> dache1 = new ArrayList<>(Arrays.asList(dache));
+      Short[] xiaoche = { 6 };
+      List<Short> xiaoche1 = new ArrayList<>(Arrays.asList(xiaoche));
+
+      JSONObject jsonObject = new JSONObject();
+      // new short[]{1,1, 1, 1, 1, 1, 2, 33, 2,3, 4, 5}
+      // new short[]{0,0, 0, 0, 0, 0, 0, 0, 0, 0}
+
+      jsonObject.append("params", arraylist);
+      jsonObject.append("dache1", dache1);
+      jsonObject.append("xiaoche", xiaoche1);
+      jsonObject.append("fanzhuan", fanzhuan1);
+
+      WebSocketServer sendwServer = WebSocketServer.sessionMap.get("AutomaticParameterSetting");
+      if (sendwServer != null) {
+        sendwServer.sendMessage(jsonObject.toString());
+      }
+
+      WebSocketServer webSocketServer = WebSocketServer.sessionMap.get("AutomaticParameterSetting");
+      if (webSocketServer != null) {
+        List<String> messages = webSocketServer.getMessages();
+        String addressList1 = "DB100.120";
+        String addressList2 = "DB100.18";
+        String addressList3 = "DB100.22";
+        String addressList4 = "DB100.14";
+
+        if (!messages.isEmpty()) {
+          // 灏嗘渶鍚庝竴涓秷鎭浆鎹负 short 绫诲瀷鐨勫垪琛�
+          String lastMessage = messages.get(messages.size() - 1);
+          // System.out.println("lastMessage锛�" + lastMessage);
+          JSONArray messageArray = new JSONArray(lastMessage);
+
+          // 鏁村悎绗� 1 鍒� 2 涓暟缁勫苟鍘绘帀 null 鍏冪礌
+          List<Short> mergedList = new ArrayList<>();
+          for (int i = 0; i < 2; 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) {
+                  // 濡傛灉鏃犳硶瑙f瀽涓� short 绫诲瀷锛屽垯蹇界暐璇ラ儴鍒�
+                  System.err.println("Could not parse value: " + value);
+                }
+              }
+            }
+          }
+          System.out.println(messageArray);
+          // 鍐欏叆绗竴涓湴鍧�
+          if (messageArray.getJSONArray(2).size() > 0) {
+            Object value = messageArray.getJSONArray(2).get(0);
+            if (value != null && !value.toString().equals("null")) {
+              try {
+                String cleanedValue = value.toString().replaceAll("[^0-9-]", "");
+                short sValue = Short.parseShort(cleanedValue.trim());
+                // S7control.getinstance().WriteWord(addressList1, Arrays.asList(sValue));
+                System.out
+                    .println("messageValue锛�" + Arrays.asList(sValue) + " written to PLC at address " + addressList2);
+              } catch (NumberFormatException e) {
+                // 濡傛灉鏃犳硶瑙f瀽涓� short 绫诲瀷锛屽垯蹇界暐璇ラ儴鍒�
+                System.err.println("Could not parse value: " + value);
+              }
+            }
+          }
+
+          // 鍐欏叆绗簩涓湴鍧�
+          if (messageArray.getJSONArray(3).size() > 0) {
+            Object value = messageArray.getJSONArray(3).get(0);
+            if (value != null && !value.toString().equals("null")) {
+              try {
+                String cleanedValue = value.toString().replaceAll("[^0-9-]", "");
+                short sValue = Short.parseShort(cleanedValue.trim());
+                // S7control.getinstance().WriteWord(addressList2, Arrays.asList(sValue));
+                System.out
+                    .println("messageValue锛�" + Arrays.asList(sValue) + " written to PLC at address " + addressList3);
+              } catch (NumberFormatException e) {
+                // 濡傛灉鏃犳硶瑙f瀽涓� short 绫诲瀷锛屽垯蹇界暐璇ラ儴鍒�
+                System.err.println("Could not parse value: " + value);
+              }
+            }
+          }
+
+          // 鍐欏叆绗簩涓湴鍧�
+          if (messageArray.getJSONArray(4).size() > 0) {
+            Object value = messageArray.getJSONArray(4).get(0);
+            if (value != null && !value.toString().equals("null")) {
+              try {
+                String cleanedValue = value.toString().replaceAll("[^0-9-]", "");
+                short sValue = Short.parseShort(cleanedValue.trim());
+                // S7control.getinstance().WriteWord(addressList2, Arrays.asList(sValue));
+                System.out
+                    .println("messageValue锛�" + Arrays.asList(sValue) + " written to PLC at address " + addressList4);
+              } catch (NumberFormatException e) {
+                // 濡傛灉鏃犳硶瑙f瀽涓� short 绫诲瀷锛屽垯蹇界暐璇ラ儴鍒�
+                System.err.println("Could not parse value: " + value);
+              }
+            }
+          }
+
+          // 鍐欏叆绗笁涓湴鍧�
+          if (!mergedList.isEmpty()) {
+            // S7control.getinstance().WriteWord(addressList3, mergedList);
+            System.out.println("messageValue锛�" + mergedList + " written to PLC at address " + addressList1);
+          }
+
+          // 娓呯┖娑堟伅鍒楄〃
+          webSocketServer.clearMessages();
+        }
+
+      }
+
+    }
+  }
+}
diff --git a/springboot-vue3/src/main/java/com/example/springboot/component/PlcManualonePosition.java b/springboot-vue3/src/main/java/com/example/springboot/component/PlcManualonePosition.java
new file mode 100644
index 0000000..eb3adf2
--- /dev/null
+++ b/springboot-vue3/src/main/java/com/example/springboot/component/PlcManualonePosition.java
@@ -0,0 +1,172 @@
+package com.example.springboot.component;
+
+import cn.hutool.json.JSONArray;
+import cn.hutool.json.JSONObject;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Arrays;
+import java.io.BufferedReader;
+import java.io.File;
+import java.io.FileInputStream;
+import java.io.FileNotFoundException;
+import java.io.IOException;
+import java.io.InputStreamReader;
+import java.io.UnsupportedEncodingException;
+
+import org.apache.commons.io.FileUtils;
+
+public class PlcManualonePosition extends Thread {
+  String name = "";
+  Integer count = 0;
+
+  public static String readFileToString(String filePath) throws IOException {
+    File file = new File(filePath);
+    return FileUtils.readFileToString(file, "UTF-8");
+  }
+
+  // 璇诲彇json鏂囦欢涓湴鍧�锛屽苟杩斿洖璇ュ湴鍧�闆嗗悎
+  public List<String> readValue() {
+    String str = "";
+    BufferedReader bufferedReader = null;
+    FileInputStream fileInputStream;
+    try {
+      // 浠庢枃浠朵腑璇诲彇瀛楄妭鏁版嵁瀛樺叆 fileInputStream
+      fileInputStream = new FileInputStream("CanadaMes-ui/src/configuration/address.json");
+      // 璇诲彇 fileInputStream 涓瓧鑺傚苟灏嗗叾瑙g爜涓哄瓧绗�
+      InputStreamReader inputStreamReader = new InputStreamReader(fileInputStream, "utf-8");
+      // 鎻愰珮璇诲彇鏁堢巼锛屽湪 BufferedReader 鍐呭寘瑁� InputStreamReader
+      bufferedReader = new BufferedReader(inputStreamReader);
+      // bufferedReader.close();
+      String line = null;
+      // 灏� bufferedReader 鍐呭涓�琛屼竴琛岃祴鍊肩粰str
+      while ((line = bufferedReader.readLine()) != null) {
+        str += line;
+      }
+
+      // 灏唖tr瀛楃涓叉牸寮忚浆涓簀son
+      JSONObject jsonObject = new JSONObject(str);
+
+      // 鑾峰彇json涓殑鍊�
+      JSONArray address = jsonObject.getJSONArray("Manualoneposition");
+
+      String[] result = new String[address.size()];
+
+      List<String> arraylistss = new ArrayList<>();
+
+      for (int i = 0; i < address.size(); i++) {
+        JSONObject ress = (JSONObject) address.get(i);
+
+        this.name = ress.getStr("name");
+        this.count = ress.getInt("count");
+        ;
+        result[i] = name + ',' + count.toString();
+        arraylistss.add(result[i]);
+
+      }
+      return arraylistss;
+    } catch (FileNotFoundException e) {
+      e.printStackTrace();
+    } catch (UnsupportedEncodingException e) {
+      e.printStackTrace();
+    } catch (IOException e) {
+      e.printStackTrace();
+    }
+    return null;
+
+  }
+
+  @Override
+  public void run() {
+    while (this != null) {
+      try {
+        Thread.sleep(500);
+
+      } catch (InterruptedException e) {
+        e.printStackTrace();
+      }
+      // this.readValue();
+      List<String> myCollection;
+      myCollection = readValue();
+      // System.out.println(myCollection);
+      List<Short> arraylist = new ArrayList<>();
+      for (String element : myCollection) {
+        String[] parts = element.split(",");
+        String PlcAddress = parts[0];
+        String count = parts[1];
+        Integer Plccount = new Integer(count);
+        // arraylist = S7control.getinstance().ReadWord(PlcAddress, Plccount);
+        System.out.println(PlcAddress);
+      }
+
+      // List<Short> arraylist = S7control.getinstance().ReadWord("DB100.0", 12);
+      // List<Short> state = S7control.getinstance().ReadWord("DB103.0", 10);
+      // parameter
+      // Short[] values1 = { 1231, 1, 1, 1, 1, 1, 2, 33, 2, 3, 4, 5 };
+      // List<Short> arraylist = new ArrayList<>(Arrays.asList(values1));
+
+      // state
+      Short[] values2 = { 0, 0, 0, 0, 0, 0, 0, 0, 0, 0 };
+      List<Short> state = new ArrayList<>(Arrays.asList(values2));
+
+      // action
+      Boolean[] values = { false, true, true, true, true, true, true, true, true,
+          true, true, true, true, true, true, true, true, true, true, true, true, true, true,
+          true, false, true };
+      List<Boolean> paramlist = new ArrayList<>(Arrays.asList(values));
+
+      short[] sholist = new short[paramlist.size()];
+
+      for (int i = 0; i < paramlist.size(); i++) {
+        boolean value = paramlist.get(i);
+        sholist[i] = value ? (short) 1 : (short) 0;
+      }
+
+      JSONObject jsonObject = new JSONObject();
+      // new short[]{1,1, 1, 1, 1, 1, 2, 33, 2,3, 4, 5}
+      // new short[]{0,0, 0, 0, 0, 0, 0, 0, 0, 0}
+
+      jsonObject.append("params", arraylist);
+      jsonObject.append("state", state);
+      jsonObject.append("action", sholist);
+      WebSocketServer sendwServer = WebSocketServer.sessionMap.get("Parameter");
+      if (sendwServer != null) {
+        sendwServer.sendMessage(jsonObject.toString());
+      }
+
+      WebSocketServer webSocketServer = WebSocketServer.sessionMap.get("Parameter");
+      if (webSocketServer != null) {
+        List<String> messages = webSocketServer.getMessages();
+
+        String addressList = "DB100.0";
+
+        if (!messages.isEmpty()) {
+          // 灏嗘渶鍚庝竴涓秷鎭浆鎹负 short 绫诲瀷鐨勫垪琛�
+          String lastMessage = messages.get(messages.size() - 1);
+          System.out.println("messages锛�" + messages);
+          String[] parts = lastMessage.split(",");
+          List<Short> messageValues = new ArrayList<>();
+          for (String part : parts) {
+            try {
+              // 浣跨敤姝e垯琛ㄨ揪寮忔竻闄ら潪鏁板瓧瀛楃
+              String cleanedPart = part.replaceAll("[^0-9-]", "");
+              short value = Short.parseShort(cleanedPart.trim());
+              messageValues.add(value);
+            } catch (NumberFormatException e) {
+              // 濡傛灉鏃犳硶瑙f瀽涓� short 绫诲瀷锛屽垯蹇界暐璇ラ儴鍒�
+
+              e.printStackTrace();
+            }
+          }
+
+          // 灏嗘秷鎭�煎啓鍏� PLC
+          S7control.getinstance().WriteWord(addressList, messageValues);
+          System.out.println("messageValues锛�" + messageValues);
+          System.out.println("addressList锛�" + addressList);
+          // 娓呯┖娑堟伅鍒楄〃
+          webSocketServer.clearMessages();
+        }
+      }
+    }
+  }
+}

--
Gitblit v1.8.0