Administrator
2025-12-20 1e800a4bd40a30bbec8440d129fc16a6cd01c309
feat(okxWs): 记录成交均价到账户映射中

- 在订单成交时将成交均价保存至账户映射
- 增加对多空方向及买卖方向的判断逻辑
- 确保仅在订单完全成交时更新成交价格
- 优化获取账户映射的方式以提高代码可读性
1 files modified
14 ■■■■ changed files
src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/OrderInfoWs.java 14 ●●●● patch | view | raw | blame | history
src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/OrderInfoWs.java
@@ -104,15 +104,25 @@
                        accFillSz, avgPx,state, fillFee,posSide
                );
                String clOrdIdStr = TradeOrderWs.getAccountMap(accountName).get("clOrdId");
                Map<String, String> accountMap = getAccountMap(accountName);
                String stateStr = TradeOrderWs.getAccountMap(accountName).get("state");
                boolean longSell = CoinEnums.POSSIDE_LONG.getCode().equals(posSide) && CoinEnums.SIDE_SELL.getCode().equals(side);
                boolean shortBuy = CoinEnums.POSSIDE_SHORT.getCode().equals(posSide) && CoinEnums.SIDE_BUY.getCode().equals(side);
                if (
                        CoinEnums.ORDER_FILLED.getCode().equals(state)
                            && (longSell || shortBuy)
                ){
                    WsMapBuild.saveStringToMap(accountMap, "orderPrice",avgPx);
                }
                String clOrdIdStr = TradeOrderWs.getAccountMap(accountName).get("clOrdId");
                if (
                        StrUtil.isNotBlank(clOrdIdStr)
                                && clOrdId.equals(clOrdIdStr)
                                && StrUtil.isNotBlank(stateStr)
                                && state.equals(stateStr)
                ){
                    Map<String, String> accountMap = getAccountMap(accountName);
                    //记录成交均价
                    if (accountMap.get("orderPrice") == null){
                        log.info("成交均价: {}", avgPx);