| | |
|---|
| | | accFillSz, avgPx,state |
|---|
| | | ); |
|---|
| | | |
|---|
| | | String clOrdIdStr = (String) redisUtils.get(TradeOrderWs.ORDERWS_CHANNEL + ":" + CoinEnums.HE_YUE.getCode() + ":clOrdId"); |
|---|
| | | String stateStr = (String) redisUtils.get(TradeOrderWs.ORDERWS_CHANNEL + ":" + CoinEnums.HE_YUE.getCode() + ":state"); |
|---|
| | | if ( |
|---|
| | | StrUtil.isNotBlank(stateStr) |
|---|
| | | StrUtil.isNotBlank(clOrdIdStr) |
|---|
| | | && clOrdId.equals(clOrdIdStr) |
|---|
| | | && StrUtil.isNotBlank(stateStr) |
|---|
| | | && state.equals(stateStr) |
|---|
| | | ){ |
|---|
| | | redisUtils.set(InstrumentsWs.INSTRUMENTSWS_CHANNEL + ":" + CoinEnums.HE_YUE.getCode() + ":state", OrderParamEnums.STATE_0.getValue(), 0); |
|---|
| | | boolean setResult = false; |
|---|
| | | String outStr = (String) redisUtils.get(InstrumentsWs.INSTRUMENTSWS_CHANNEL + ":" + CoinEnums.HE_YUE.getCode() + ":out"); |
|---|
| | | if (OrderParamEnums.OUT_YES.getValue().equals(outStr)){ |
|---|
| | | setResult = redisUtils.set(InstrumentsWs.INSTRUMENTSWS_CHANNEL + ":" + CoinEnums.HE_YUE.getCode() + ":state", OrderParamEnums.STATE_3.getValue(), 0); |
|---|
| | | }else{ |
|---|
| | | setResult = redisUtils.set(InstrumentsWs.INSTRUMENTSWS_CHANNEL + ":" + CoinEnums.HE_YUE.getCode() + ":state", OrderParamEnums.STATE_0.getValue(), 0); |
|---|
| | | } |
|---|
| | | if (setResult){ |
|---|
| | | log.info("订单详情-币种: {}, 自定义编号: {}, 订单状态: {}", CoinEnums.HE_YUE.getCode(), clOrdId, OrderParamEnums.STATE_0.getValue()); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } catch (Exception e) { |
|---|
