Administrator
2025-12-10 93ac37e763872e5c2911daa343358ed0b1b29047
fix(okxNewPrice): 优化订单状态更新逻辑

- 增加自定义订单编号的获取与比对逻辑
- 添加详细的订单状态变更日志记录
- 完善Redis状态设置的结果判断及日志输出
- 修复订单状态匹配条件判断逻辑
- 提升订单状态同步的准确性与可追踪性
4 files deleted
1 files modified
17 ■■■■ changed files
lib/abi-0.4.0.jar patch | view | raw | blame | history
lib/client-0.4.0.jar patch | view | raw | blame | history
lib/tron-sdk.jar patch | view | raw | blame | history
lib/utils-0.4.0.jar patch | view | raw | blame | history
src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/OrderInfoWs.java 17 ●●●● patch | view | raw | blame | history
lib/abi-0.4.0.jar
Binary files differ
lib/client-0.4.0.jar
Binary files differ
lib/tron-sdk.jar
Binary files differ
lib/utils-0.4.0.jar
Binary files differ
src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/OrderInfoWs.java
@@ -80,12 +80,25 @@
                        accFillSz, avgPx,state
                );
                String clOrdIdStr = (String) redisUtils.get(TradeOrderWs.ORDERWS_CHANNEL + ":" + CoinEnums.HE_YUE.getCode() + ":clOrdId");
                String stateStr = (String) redisUtils.get(TradeOrderWs.ORDERWS_CHANNEL + ":" + CoinEnums.HE_YUE.getCode() + ":state");
                log.info("订单详情-币种: {}, 自定义编号: {}, 订单状态: {}", CoinEnums.HE_YUE.getCode(), clOrdIdStr, stateStr);
                log.info("订单详情-币种: {}, 响应编号: {}, 订单状态: {}", CoinEnums.HE_YUE.getCode(), clOrdId, state);
                log.info("订单详情-币种: {}, 下单状态是否能转换: {}",
                        StrUtil.isNotBlank(clOrdIdStr)
                        && clOrdId.equals(clOrdIdStr)
                        && StrUtil.isNotBlank(stateStr)
                        && state.equals(stateStr));
                if (
                                StrUtil.isNotBlank(stateStr)
                        StrUtil.isNotBlank(clOrdIdStr)
                                && clOrdId.equals(clOrdIdStr)
                                && StrUtil.isNotBlank(stateStr)
                                && state.equals(stateStr)
                ){
                    redisUtils.set(InstrumentsWs.INSTRUMENTSWS_CHANNEL + ":" + CoinEnums.HE_YUE.getCode() + ":state", OrderParamEnums.STATE_0.getValue(), 0);
                    boolean setResult = redisUtils.set(InstrumentsWs.INSTRUMENTSWS_CHANNEL + ":" + CoinEnums.HE_YUE.getCode() + ":state", OrderParamEnums.STATE_0.getValue(), 0);
                    if (setResult){
                        log.info("订单详情-币种: {}, 自定义编号: {}, 订单状态: {}", CoinEnums.HE_YUE.getCode(), clOrdId, OrderParamEnums.STATE_0.getValue());
                    }
                }
            }
        } catch (Exception e) {