Merge branch 'master' of http://10.153.19.25:10101/r/CanadaMes

clll

2023-11-27 1ebc598658f85c07c7cbabaf289ab89838a8acc9

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

New file
@@ -0,0 +1,151 @@
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 PlcPositioning1 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 中字节并将其解码为字符

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

        }

    }



    @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.0", 12);

            // List<Short> state = S7control.getinstance().ReadWord("DB103.0", 10);

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





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

                }





            }

        }

    }

}