fix(gateApi): 解决止损追单时持仓查询缓存竞态问题

Administrator

2026-09-23 9abc4be3b929dc5504b230f007081536d75c19d8

 src/main/java/com/xcong/excoin/modules/gateApi/HeartbeatScheduler.java

@@ -3,6 +3,7 @@
import com.xcong.excoin.modules.station.model.GateStatsEvent;
import com.xcong.excoin.modules.station.model.HeartbeatMsg;
import lombok.extern.slf4j.Slf4j;
import org.springframework.core.env.Environment;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
@@ -24,6 +25,9 @@

    @Resource
    private GateWebSocketClientManager manager;

    @Resource
    private Environment environment;

    private String apiKeyMd5;
    private String hostPort;
@@ -61,7 +65,7 @@
            GateStatsEvent event = statsProducer.newHeartbeat(apiKeyMd5, hb);
            statsProducer.sendHeartbeat(event);

            log.info("[Gate] 心跳已发送, state={}, apiKeyMd5={}", state, apiKeyMd5);
//            log.info("[Gate] 心跳已发送, state={}, apiKeyMd5={}", state, apiKeyMd5);
        } catch (Exception e) {
            log.warn("[Gate] 心跳发送失败", e);
        }
@@ -70,8 +74,8 @@
    private String resolveHostPort() {
        try {
            String host = InetAddress.getLocalHost().getHostAddress();
            // port 从 Spring 环境变量获取，默认 8888
            String port = System.getProperty("server.port", "8888");
            // port 从 Spring Environment 获取（兼容 --server.port=xxx 命令行参数），默认 8888
            String port = environment.getProperty("server.port", "8888");
            return host + ":" + port;
        } catch (Exception e) {
            return "unknown";