fix(okx): 调整账户状态与保证金计算逻辑

Administrator

2025-12-11 87c31b6e2c11a82d92389194e190d6b2eefd939a

 src/main/java/com/xcong/excoin/modules/okxNewPrice/OkxQuantWebSocketClient.java

@@ -100,9 +100,9 @@
        }
        shutdownExecutorGracefully(sharedExecutor);

        if (reconnectScheduler != null) {
            reconnectScheduler.shutdownNow();
        }
//        if (reconnectScheduler != null) {
//            reconnectScheduler.shutdownNow();
//        }
    }

    private void shutdownExecutorGracefully(ExecutorService executor) {
@@ -299,19 +299,19 @@
        });

        heartbeatExecutor.scheduleWithFixedDelay(this::checkHeartbeatTimeout, 25, 25, TimeUnit.SECONDS);
        // 添加每小时重连的定时任务
        if (reconnectScheduler != null && !reconnectScheduler.isTerminated()) {
            reconnectScheduler.shutdownNow();
        }

        reconnectScheduler = Executors.newSingleThreadScheduledExecutor(r -> {
            Thread t = new Thread(r, "okx-scheduled-reconnect");
            t.setDaemon(true);
            return t;
        });

        // 每小时执行一次重连
        reconnectScheduler.scheduleWithFixedDelay(this::performScheduledReconnect, 60, 60, TimeUnit.MINUTES);
//        // 添加每小时重连的定时任务
//        if (reconnectScheduler != null && !reconnectScheduler.isTerminated()) {
//            reconnectScheduler.shutdownNow();
//        }
//
//        reconnectScheduler = Executors.newSingleThreadScheduledExecutor(r -> {
//            Thread t = new Thread(r, "okx-scheduled-reconnect");
//            t.setDaemon(true);
//            return t;
//        });
//
//        // 每小时执行一次重连
//        reconnectScheduler.scheduleWithFixedDelay(this::performScheduledReconnect, 60, 60, TimeUnit.MINUTES);
    }

    /**