#

Junjie

2025-07-14 920d87ad2ca03711af3683237efbb8f7ef5f53ea

 src/main/java/com/zy/core/thread/impl/NyShuttleThread.java

@@ -17,8 +17,8 @@

import java.io.*;
import java.net.InetAddress;
import java.net.ServerSocket;
import java.net.Socket;
import java.net.SocketException;
import java.text.MessageFormat;
import java.util.*;

@@ -29,21 +29,17 @@
    private DeviceConfig deviceConfig;
    private RedisUtil redisUtil;
    private Socket socket;
    private ServerSocket serverSocket;

    private boolean fake = false;
    private boolean stopThread = false;
    private HashMap<Integer, String> resultKeyMap = new HashMap<Integer, String>();

    public NyShuttleThread(DeviceConfig deviceConfig, RedisUtil redisUtil) {
        this.deviceConfig = deviceConfig;
        this.redisUtil = redisUtil;
        this.fake = deviceConfig.getFake();
    }

    @Override
    public void run() {
        News.info("{}号四向车线程启动", deviceConfig.getDeviceNo());
        this.connect();

        //监听消息
        Thread innerThread = new Thread(() -> {
@@ -52,9 +48,8 @@
                    break;
                }

                System.out.println("read");

                try {
                    this.connect();
                    Thread.sleep(200);
                    listenSocketMessage();
                } catch (Exception e) {
@@ -71,7 +66,6 @@
                    break;
                }

                System.out.println("executeThread");
                try {
                    DeviceMsgUtils deviceMsgUtils = null;
                    try {
@@ -93,35 +87,6 @@
            }
        });
        executeThread.start();

        if (this.fake) {
            Thread fakeThread = new Thread(() -> {
                try {
                    serverSocket = new ServerSocket(deviceConfig.getPort());

                    while (true) {
                        if(stopThread) {
                            break;
                        }

                        System.out.println("fakeThread");
                        Socket accept = serverSocket.accept();
                        handleClient(accept);
                    }
                }catch (Exception e){
                    e.printStackTrace();
                }
            });
            fakeThread.start();
        }
    }

    private void handleClient(Socket socket) throws IOException {
        InputStream inputStream = socket.getInputStream();
        OutputStream outputStream = socket.getOutputStream();
        outputStream.write("test".getBytes());
        outputStream.flush();
        socket.close();
    }

    private void executeCommand(DeviceCommandMsgModel deviceCommandMsg) {
@@ -130,14 +95,22 @@
                return;
            }

            Object command = deviceCommandMsg.getCommand();
            String command = JSON.toJSONString(deviceCommandMsg.getCommand());
            JSONObject commandObj = JSON.parseObject(command);
            JSONObject request = commandObj.getJSONObject("request");
            JSONObject header = request.getJSONObject("header");
            Integer requestId = header.getInteger("requestId");
            resultKeyMap.put(requestId, deviceCommandMsg.getResultKey());

            // 获取输出流
            OutputStreamWriter writer = new OutputStreamWriter(this.socket.getOutputStream());
            writer.write(JSON.toJSONString(command) + "\r\n");
            writer.write(command + "\r\n");
            writer.flush();
//            System.out.println("Sent message to server: " + JSON.toJSONString(httpCommand));
        }catch (Exception e) {
        }catch (SocketException e) {
            this.socket = null;
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
@@ -151,9 +124,9 @@
            DeviceMsgUtils deviceMsgUtils = null;
            try {
                deviceMsgUtils = SpringUtils.getBean(DeviceMsgUtils.class);
            }catch (Exception e){
            } catch (Exception e) {
            }
            if(deviceMsgUtils == null) {
            if (deviceMsgUtils == null) {
                return;
            }

@@ -171,13 +144,28 @@
                }
            }

            JSONObject result = JSON.parseObject(sb.toString());//得到响应结果集
            JSONObject result = null;
            try {
                result = JSON.parseObject(sb.toString());//得到响应结果集
            }catch (Exception e){}

            if(result == null) {
                return;
            }

            JSONObject response = result.getJSONObject("response");
            JSONObject header = response.getJSONObject("header");
            JSONObject body = response.getJSONObject("body");

            String msgType = result.getString("msgType");

//            log.info("收到Server Data: {}", JSON.toJSONString(result));
            if ("responseMsg".equals(msgType)) {
                JSONObject response = result.getJSONObject("response");
                JSONObject body = response.getJSONObject("body");
                if (body.containsKey("workingMode")) {
                Integer responseId = header.getInteger("responseId");
                String resultKey = resultKeyMap.get(responseId);

                String responseType = body.getString("responseType");
                if (responseType.equals("state")) {
                    //read
                    JSONObject data = parseSocketResult(body);

@@ -186,19 +174,32 @@
                    deviceMsgModel.setDeviceMsgType("status");
                    deviceMsgModel.setDeviceMsg(data);
                    deviceMsgModel.setDeviceOriginMsg(sb.toString());
                    deviceMsgModel.setResultKey(resultKey);
                    deviceMsgUtils.sendDeviceMsg(SlaveType.Shuttle, deviceConfig.getDeviceNo(), deviceMsgModel);
                    return;
                }else {
                    log.info("收到Rcs Shuttle Command Data: {}", JSON.toJSONString(result));
                    DeviceMsgModel deviceMsgModel = new DeviceMsgModel();
                    deviceMsgModel.setDeviceId(deviceConfig.getDeviceNo());
                    deviceMsgModel.setDeviceMsgType("command");
                    deviceMsgModel.setDeviceMsg(result);
                    deviceMsgModel.setDeviceOriginMsg(sb.toString());
                    deviceMsgModel.setResultKey(resultKey);
                    deviceMsgUtils.sendDeviceMsg(SlaveType.Shuttle, deviceConfig.getDeviceNo(), deviceMsgModel);
                }
            } else if ("requestMsg".equals(msgType)) {
                log.info("收到Shuttle Init Data: {}", JSON.toJSONString(result));
                String requestType = body.getString("requestType");
                if (requestType.equals("init")) {
                    DeviceMsgModel deviceMsgModel = new DeviceMsgModel();
                    deviceMsgModel.setDeviceId(deviceConfig.getDeviceNo());
                    deviceMsgModel.setDeviceMsgType("shuttleInit");
                    deviceMsgModel.setDeviceMsg(result);
                    deviceMsgModel.setDeviceOriginMsg(sb.toString());
                    deviceMsgUtils.sendDeviceMsg(SlaveType.Shuttle, deviceConfig.getDeviceNo(), deviceMsgModel);
                }
            }

            DeviceMsgModel deviceMsgModel = new DeviceMsgModel();
            deviceMsgModel.setDeviceId(deviceConfig.getDeviceNo());
            deviceMsgModel.setDeviceMsgType("command");
            deviceMsgModel.setDeviceMsg(result);
            deviceMsgModel.setDeviceOriginMsg(sb.toString());
            deviceMsgUtils.sendDeviceMsg(SlaveType.Shuttle, deviceConfig.getDeviceNo(), deviceMsgModel);
        } catch (Exception e) {
            e.printStackTrace();
//            e.printStackTrace();
        }
    }

@@ -254,12 +255,62 @@
    @Override
    public boolean connect() {
        try {
            if(this.socket != null) {
                return true;
            }

            InetAddress address = InetAddress.getByName(deviceConfig.getIp());
            if (address.isReachable(10000)) {
                Socket socket = new Socket(deviceConfig.getIp(), deviceConfig.getPort());
                socket.setSoTimeout(10000);
                socket.setKeepAlive(true);
                this.socket = socket;
                Socket deviceSocket = new Socket(deviceConfig.getIp(), deviceConfig.getPort());
                deviceSocket.setSoTimeout(10000);
                deviceSocket.setKeepAlive(true);

                if (this.deviceConfig.getFake()) {
                    //虚拟设备需要上报设备信息
                    HashMap<String, Object> map = new HashMap<>();
                    map.put("msgType", "fakeDeviceFirstConnect");
                    map.put("deviceConfig", this.deviceConfig);

                    // 获取输出流
                    OutputStreamWriter writer = new OutputStreamWriter(deviceSocket.getOutputStream());
                    writer.write(JSON.toJSONString(map) + "\r\n");
                    writer.flush();

                    // 获取输入流
                    BufferedReader reader = new BufferedReader(new InputStreamReader(deviceSocket.getInputStream()));
                    // 读取服务器的响应
                    StringBuffer sb = new StringBuffer();
                    char[] chars = new char[2048];//缓冲区
                    while (true) {
                        reader.read(chars);
                        String trim = new String(chars);
                        sb.append(trim);
                        if (trim.lastIndexOf("\r\n") != -1) {
                            break;
                        }
                    }

                    JSONObject result = null;
                    try {
                        result = JSON.parseObject(sb.toString());//得到响应结果集
                    }catch (Exception e){}

                    if(result == null) {
                        return false;
                    }

                    if(result.getInteger("deviceNo") != deviceConfig.getDeviceNo()) {
                        return false;
                    }

                    if(!result.getString("status").equals("success")) {
                        return false;
                    }

                    this.socket = deviceSocket;
                }else {
                    this.socket = deviceSocket;
                }
                log.info(MessageFormat.format("【{0}】四向穿梭车Socket链接成功 ===>> [id:{1}] [ip:{2}] [port:{3}]", DateUtils.convert(new Date()), deviceConfig.getDeviceNo(), deviceConfig.getIp(), deviceConfig.getPort()));
            }
        } catch (Exception e) {
@@ -285,8 +336,4 @@
        this.stopThread = true;
    }

    @Override
    public boolean isFake() {
        return this.fake;
    }
}