| | |
| | | @Override |
| | | public String caoZuo() { |
| | | log.info("开始执行操作CaoZuoServiceImpl......"); |
| | | String outStr = (String) redisUtils.get(instrumentsOutKey); |
| | | if (OrderParamEnums.OUT_YES.getValue().equals(outStr)){ |
| | | log.error("止损过了......冷静一下,等待下次入场......"); |
| | | return null; |
| | | } |
| | | |
| | | // 获取合约执行操作状态 |
| | | String state = (String) redisUtils.get(instrumentsStateKey); |
| | | String outStr = (String) redisUtils.get(instrumentsOutKey); |
| | | if (OrderParamEnums.OUT_YES.getValue().equals(outStr) && OrderParamEnums.STATE_3.getValue().equals(state)){ |
| | | log.error("止损过了......冷静一下,等待下次入场......"); |
| | | return null; |
| | | } |
| | | if (OrderParamEnums.STATE_4.getValue().equals(state)) { |
| | | log.error("操作下单中,等待......"); |
| | | return OrderParamEnums.ORDERING.getValue(); |
| | |
| | | log.info("加仓过程中发现持仓过小 :{}",isAddCang); |
| | | if (isAddCang){ |
| | | log.info("触发加仓......,持仓过小"); |
| | | redisUtils.set(positionsOrderPriceKey, String.valueOf(markPx), 0); |
| | | return OrderParamEnums.BUY.getValue(); |
| | | } |
| | | log.info("未触发加仓......,等待"); |
| | |
| | | log.info("减仓过程中发现持仓过小 :{}",isAddCang); |
| | | if (isAddCang){ |
| | | log.info("触发加仓......,持仓过小"); |
| | | redisUtils.set(positionsOrderPriceKey, String.valueOf(markPx), 0); |
| | | return OrderParamEnums.BUY.getValue(); |
| | | } |
| | | log.info("当前未实现盈亏:{}没有大于预计收益>{},钱在路上了", uplValue, imrValue); |
| | |
| | | log.info("减仓过程中发现持仓过小 :{}",isAddCang); |
| | | if (isAddCang){ |
| | | log.info("触发加仓......,持仓过小"); |
| | | redisUtils.set(positionsOrderPriceKey, String.valueOf(markPx), 0); |
| | | return OrderParamEnums.BUY.getValue(); |
| | | } |
| | | log.info("当前未实现盈亏:{}没有大于预计收益>{},钱在路上了", uplValue, imrValue); |