refactor(okxNewPrice): 重构交易订单处理逻辑

Administrator

8 days ago 39252ec46c56c2f444b18af97180a9c07519bff6

 src/main/java/com/xcong/excoin/modules/okxNewPrice/okxWs/TradeOrderWs.java

@@ -13,6 +13,7 @@
import org.java_websocket.client.WebSocketClient;

import java.math.BigDecimal;
import java.util.List;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;

@@ -136,15 +137,16 @@
        }
    }

    public static void orderZhiYingZhiSunEventNoState(WebSocketClient webSocketClient, TradeRequestParam tradeRequestParam) {
    public static void orderZhiYingZhiSunEventNoState(WebSocketClient webSocketClient, List<TradeRequestParam> tradeRequestParams) {


        log.info("开始执行TradeOrderWs......");
        if (tradeRequestParam == null){
        if (tradeRequestParams == null){

            log.warn("下单{}参数缺失，取消发送",tradeRequestParam);
            log.warn("下单{}参数缺失，取消发送",tradeRequestParams);
            return;
        }
        for (TradeRequestParam tradeRequestParam : tradeRequestParams){
        String accountName = tradeRequestParam.getAccountName();
        String markPx = tradeRequestParam.getMarkPx();
        String instId = tradeRequestParam.getInstId();
@@ -174,14 +176,14 @@

        ){
            log.warn("下单参数缺失，取消发送");
            return;
                continue;
        }
        log.info("账户：{}，类型：{}，触发价格：{}，币种：{}，方向：{}，买卖：{}，数量：{}，是否允许下单：{}，编号：{}，",
                accountName,ordType, markPx, instId, posSide,side,  sz, tradeType, clOrdId);
        //验证是否允许下单
        if (StrUtil.isNotEmpty(tradeType) && OrderParamEnums.TRADE_NO.getValue().equals(tradeType)) {
            log.warn("账户{}不允许下单，取消发送", accountName);
            return;
                continue;
        }

        /**
@@ -215,6 +217,7 @@
            log.error("下单构建失败", e);
        }
    }
    }