| | |
| | | return null; |
| | | } |
| | | log.info("当前网格: {}", gridByPrice.name()); |
| | | Map<String, String> accountMap = InstrumentsWs.getAccountMap(accountName); |
| | | String wanggeName = accountMap.get(CoinEnums.WANG_GE_OLD.name()); |
| | | |
| | | PriorityBlockingQueue<AscBigDecimal> ascBigDecimals = wangGeListService.initWangGe(markPx); |
| | | if (ascBigDecimals == null){ |
| | |
| | | /** |
| | | * 如果下单的网格不属于同一个网格,则先止损掉老的网格的仓位 |
| | | */ |
| | | Map<String, String> accountMap = InstrumentsWs.getAccountMap(accountName); |
| | | String wanggeName = accountMap.get(CoinEnums.WANG_GE_OLD.name()); |
| | | if (StrUtil.isNotEmpty(wanggeName) && !wanggeName.equals(gridByPrice.name())){ |
| | | log.error("正在止损老的网格仓位......"); |
| | | WangGeListEnum oldWangge = WangGeListEnum.getByName(wanggeName); |
| | |
| | | if (pingCang != null && avgPx.compareTo(pingCang.getValue()) < 0) { |
| | | log.info("开始减仓...上限队列价格大于开仓价格{}>{}", pingCang.getValue(), avgPx); |
| | | // 手续费 |
| | | BigDecimal feeValue = PositionsWs.getAccountMap(positionAccountName).get("fee").multiply(new BigDecimal("2")); |
| | | BigDecimal feeValue = PositionsWs.getAccountMap(positionAccountName).get("fee"); |
| | | //未实现收益 |
| | | BigDecimal uplValue = PositionsWs.getAccountMap(positionAccountName).get("upl"); |
| | | //已实现收益 |
| | |
| | | log.info("开始减仓...下限队列价格小于开仓价格{}<{}", kaiCang.getValue(), avgPx); |
| | | |
| | | // 手续费 |
| | | BigDecimal feeValue = PositionsWs.getAccountMap(positionAccountName).get("fee").multiply(new BigDecimal("2")); |
| | | BigDecimal feeValue = PositionsWs.getAccountMap(positionAccountName).get("fee"); |
| | | //未实现收益 |
| | | BigDecimal uplValue = PositionsWs.getAccountMap(positionAccountName).get("upl"); |
| | | //已实现收益 |