| | |
| | | log.info("开始加仓..."); |
| | | if (queueKaiCang.isEmpty()) { |
| | | // 队列为空 |
| | | // log.info("开始加仓,但是超出了网格设置..."); |
| | | log.info("开始加仓,但是超出了网格设置..."); |
| | | return OrderParamEnums.HOLDING.getValue(); |
| | | } |
| | | DescBigDecimal kaiCang = queueKaiCang.peek(); |
| | | log.info("下限队列价格{}", kaiCang); |
| | | log.info("下限队列价格{}", kaiCang.getValue()); |
| | | if (kaiCang != null && markPx.compareTo(kaiCang.getValue()) <= 0 && avgPx.compareTo(kaiCang.getValue()) >= 0) { |
| | | log.info("开始加仓...下限队列价格大于当前价格{}>{}", kaiCang.getValue(), markPx); |
| | | WsMapBuild.saveStringToMap(OrderInfoWs.getAccountMap(accountName), "orderPrice", String.valueOf(markPx)); |
| | |
| | | log.info("开始减仓..."); |
| | | if (queueKaiCang.isEmpty()) { |
| | | // 队列为空 |
| | | // log.info("开始加仓,但是超出了网格设置..."); |
| | | log.info("开始减仓,但是超出了网格设置..."); |
| | | return OrderParamEnums.HOLDING.getValue(); |
| | | } |
| | | DescBigDecimal kaiCang = queueKaiCang.peek(); |
| | | log.info("下限队列价格{}", kaiCang); |
| | | log.info("下限队列价格{}", kaiCang.getValue()); |
| | | if (kaiCang != null && avgPx.compareTo(kaiCang.getValue()) >= 0) { |
| | | log.info("开始减仓...下限队列价格小于开仓价格{}<{}", kaiCang.getValue(), avgPx); |
| | | |
| | |
| | | return OrderParamEnums.HOLDING.getValue(); |
| | | } |
| | | AscBigDecimal pingCang = queuePingCang.peek(); |
| | | log.info("上限队列价格: {}", pingCang); |
| | | log.info("上限队列价格: {}", pingCang.getValue()); |
| | | if (pingCang != null && markPx.compareTo(pingCang.getValue()) >= 0 && avgPx.compareTo(pingCang.getValue()) < 0) { |
| | | log.info("开始加仓...上限队列价格小于当前价格{}<={}", pingCang.getValue(), markPx); |
| | | WsMapBuild.saveStringToMap(OrderInfoWs.getAccountMap(accountName), "orderPrice", String.valueOf(markPx)); |