| | |
|---|
| | | public static void orderEvent(WebSocketClient webSocketClient, RedisUtils redisUtils, String side) { |
|---|
| | | |
|---|
| | | log.info("开始执行TradeOrderWs......"); |
|---|
| | | if (StrUtil.isBlank( side)){ |
|---|
| | | log.warn("止损了，下次再战..."); |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | |
|---|
| | | String buyCnt = null; |
|---|
| | | String ctval = getRedisValue(redisUtils, InstrumentsWs.INSTRUMENTSWS_CHANNEL, ":ctVal"); |
|---|
| | | String buyCntNormal = getRedisValue(redisUtils, PositionsWs.POSITIONSWS_CHANNEL, ":buyCnt"); |
|---|
| | | String pos = getRedisValue(redisUtils, PositionsWs.POSITIONSWS_CHANNEL, ":pos"); |
|---|
| | | if (OrderParamEnums.ORDERING.getValue().equals(side)) { |
|---|
| | | log.warn("正在下单中，等待下单结束..."); |
|---|
| | | return; |
|---|
| | | } else if (OrderParamEnums.HOLDING.getValue().equals(side)) { |
|---|
| | | return; |
|---|
