| | |
| | | BigDecimal pos = PositionsWs.getAccountMap(positionAccountName).get("pos"); |
| | | if (BigDecimal.ZERO.compareTo( pos) >= 0) { |
| | | log.error("持仓数量为零,进行初始化订单"); |
| | | return OrderParamEnums.INIT.getValue(); |
| | | return null; |
| | | } |
| | | // 判断是否保证金超标 |
| | | if (PositionsWs.getAccountMap(positionAccountName).get("imr") == null){ |
| | |
| | | queueKaiCang.removeIf(item -> item.getValue().compareTo(priceDecimal) >= 0); |
| | | |
| | | // 打印开仓队列 |
| | | // 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()); |
| | | 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()); |
| | | |
| | | // 删除比该价格小的数据 |
| | | queuePingCang.removeIf(item -> item.getValue().compareTo(priceDecimal) <= 0); |
| | | |
| | | // 打印平仓队列 |
| | | // 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()); |
| | | 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()); |
| | | } |
| | | } |