#

Junjie

2025-11-27 2aaf47ead1a69ccbaf6a0167ae161aafd3622114

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

@@ -24,9 +24,7 @@
import com.zy.core.network.entity.ZyStationStatusEntity;

import java.text.MessageFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.*;

import lombok.Data;
import lombok.extern.slf4j.Slf4j;
@@ -53,6 +51,20 @@
    @SuppressWarnings("InfiniteLoopStatement")
    public void run() {
        this.connect();

        //设备读取
        Thread readThread = new Thread(() -> {
            while (true) {
                try {
                    readStatus();
                    Thread.sleep(200);
                } catch (Exception e) {
                    log.error("StationThread Fail", e);
                }
            }
        });
        readThread.start();

        while (true) {
            try {
                int step = 1;
@@ -61,10 +73,6 @@
                    step = task.getStep();
                }
                switch (step) {
                    // 读数据
                    case 1:
                        readStatus();
                        break;
                    case 2:
                        sendCommand((StationCommand) task.getData());
                        break;
@@ -172,4 +180,12 @@
       return commandResponse;
    }

    @Override
    public Map<Integer, StationProtocol> getStatusMap() {
        Map<Integer, StationProtocol> map = new HashMap<>();
        for (StationProtocol stationProtocol : statusList) {
            map.put(stationProtocol.getStationId(), stationProtocol);
        }
        return map;
    }
}