| | |
| | | queueKaiCang.removeIf(item -> item.getValue().equals(priceDecimal)); |
| | | } |
| | | // 打印开仓队列 |
| | | log.info("开仓队列: {}", queueKaiCang); |
| | | StringBuilder kaiCangStr = new StringBuilder(); |
| | | kaiCangStr.append("开仓队列: ["); |
| | | boolean first = true; |
| | | for (DescBigDecimal item : queueKaiCang) { |
| | | if (!first) { |
| | | kaiCangStr.append(", "); |
| | | } |
| | | kaiCangStr.append(item.getValue()); |
| | | first = false; |
| | | } |
| | | kaiCangStr.append("]"); |
| | | log.info(kaiCangStr.toString()); |
| | | |
| | | boolean pingCangExists = queuePingCang.stream().anyMatch(item -> item.getValue().equals(priceDecimal)); |
| | | if (!pingCangExists) { |
| | |
| | | } else { |
| | | queuePingCang.removeIf(item -> item.getValue().equals(priceDecimal)); |
| | | } |
| | | |
| | | // 打印平仓队列 |
| | | log.info("平仓队列: {}", queuePingCang); |
| | | StringBuilder pingCangStr = new StringBuilder(); |
| | | pingCangStr.append("平仓队列: ["); |
| | | first = true; |
| | | for (AscBigDecimal item : queuePingCang) { |
| | | if (!first) { |
| | | pingCangStr.append(", "); |
| | | } |
| | | pingCangStr.append(item.getValue()); |
| | | first = false; |
| | | } |
| | | pingCangStr.append("]"); |
| | | log.info(pingCangStr.toString()); |
| | | } |
| | | } |
| | | |