| | |
| | | package com.xcong.excoin.modules.okxNewPrice.okxWs; |
| | | |
| | | import cn.hutool.core.util.StrUtil; |
| | | import cn.hutool.json.JSONUtil; |
| | | import com.alibaba.fastjson.JSONArray; |
| | | import com.alibaba.fastjson.JSONObject; |
| | | import com.xcong.excoin.modules.okxNewPrice.okxWs.enums.CoinEnums; |
| | |
| | | public static void orderEvent(WebSocketClient webSocketClient, TradeRequestParam tradeRequestParam) { |
| | | |
| | | |
| | | log.info("开始执行TradeOrderWs......"); |
| | | log.info("开始执行TradeOrderWs{}......", JSONUtil.parse(tradeRequestParam)); |
| | | String accountName = tradeRequestParam.getAccountName(); |
| | | String markPx = tradeRequestParam.getMarkPx(); |
| | | String instId = tradeRequestParam.getInstId(); |
| | |
| | | String clOrdId = tradeRequestParam.getClOrdId(); |
| | | String side = tradeRequestParam.getSide(); |
| | | String sz = tradeRequestParam.getSz(); |
| | | log.info("账户:{},触发价格:{},币种:{},方向:{},买卖:{},数量:{},是否允许下单:{},编号:{},", |
| | | accountName, markPx, instId, posSide,side, sz, tradeType, clOrdId); |
| | | log.info("账户:{},类型:{},触发价格:{},币种:{},方向:{},买卖:{},数量:{},是否允许下单:{},编号:{},", |
| | | accountName,ordType, markPx, instId, posSide,side, sz, tradeType, clOrdId); |
| | | //验证是否允许下单 |
| | | if (StrUtil.isNotEmpty(tradeType) && OrderParamEnums.TRADE_NO.getValue().equals(tradeType)) { |
| | | log.warn("账户{}不允许下单,取消发送", accountName); |
| | |
| | | log.warn("下单参数缺失,取消发送"); |
| | | return; |
| | | } |
| | | log.info("账户:{},触发价格:{},币种:{},方向:{},买卖:{},数量:{},是否允许下单:{},编号:{},", |
| | | accountName, markPx, instId, posSide,side, sz, tradeType, clOrdId); |
| | | log.info("账户:{},类型:{},触发价格:{},币种:{},方向:{},买卖:{},数量:{},是否允许下单:{},编号:{},", |
| | | accountName,ordType, markPx, instId, posSide,side, sz, tradeType, clOrdId); |
| | | //验证是否允许下单 |
| | | if (StrUtil.isNotEmpty(tradeType) && OrderParamEnums.TRADE_NO.getValue().equals(tradeType)) { |
| | | log.warn("账户{}不允许下单,取消发送", accountName); |