| | |
|---|
| | | |
|---|
| | | 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"); |
|---|
| | |
|---|
| | | buyCnt = ctval; |
|---|
| | | } |
|---|
| | | } else if (OrderParamEnums.OUT.getValue().equals(side)) { |
|---|
| | | log.info(OrderParamEnums.getNameByValue(OrderParamEnums.OUT.getValue())); |
|---|
| | | side = OrderParamEnums.SELL.getValue(); |
|---|
| | | buyCnt = pos; |
|---|
| | | } else if (OrderParamEnums.BUY.getValue().equals(side)){ |
|---|
