package com.example.springboot.component;

import cn.hutool.json.JSONObject;

import java.util.ArrayList;
import java.util.List;

public class Plcaction extends Thread {
    @Override
    public void run() {
        while (this != null) {
            try {
                Thread.sleep(10000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }

            List<Short> paramlist = S7control.getinstance().ReadWord("DB100.DBW", 12);

            JSONObject jsonObject = new JSONObject();
            jsonObject.append("params", paramlist);
            WebSocketServer sendwServer = WebSocketServer.sessionMap.get("action");
            if (sendwServer != null) {
                sendwServer.sendMessage(jsonObject.toString());
            }

            WebSocketServer webSocketServer = WebSocketServer.sessionMap.get("action");
            if (webSocketServer != null) {
                List<String> messages = webSocketServer.getMessages();

                List<String> addressList = new ArrayList<>();
                addressList.add("DB100.DBW0");
                addressList.add("DB100.DBW2");
                addressList.add("DB100.DBW4");
                addressList.add("DB100.DBW6");
                addressList.add("DB100.DBW8");
                addressList.add("DB100.DBW10");
                addressList.add("DB100.DBW12");
                addressList.add("DB100.DBW14");
                addressList.add("DB100.DBW16");
                addressList.add("DB100.DBW18");
                addressList.add("DB100.DBW20");
                addressList.add("DB100.DBW22");

                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 {
                            // 使用正则表达式清除非数字字符
                            String cleanedPart = part.replaceAll("[^0-9-]", "");
                            short value = Short.parseShort(cleanedPart.trim());
                            messageValues.add(value);
                        } catch (NumberFormatException e) {
                            // 如果无法解析为 short 类型，则忽略该部分

                            e.printStackTrace();
                        }
                    }

                    // 将消息值写入 PLC
//                    S7control.getinstance().WriteWord(addressList, messageValues);
                    System.out.println("messageValues：" + messageValues);
                    // 清空消息列表
                    messages.clear();
                }
            }
        }
    }
}