| | |
| | | log.error("没有获取到网格参数......"); |
| | | return null; |
| | | } |
| | | log.info("当前网格: {}", gridByPrice.name()); |
| | | Map<String, String> accountMap = InstrumentsWs.getAccountMap(accountName); |
| | | String wanggeName = accountMap.get(CoinEnums.WANG_GE_OLD.name()); |
| | | /** |
| | |
| | | return OrderParamEnums.OUT.getValue(); |
| | | } |
| | | String posSide = gridByPrice.getFang_xiang(); |
| | | log.info("仓位方向: {}", posSide); |
| | | WsMapBuild.saveStringToMap(accountMap, CoinEnums.POSSIDE.name(), posSide); |
| | | String positionAccountName = PositionsWs.initAccountName(accountName, posSide); |
| | | BigDecimal positionsReadyState = PositionsWs.getAccountMap(positionAccountName).get(CoinEnums.READY_STATE.name()) == null |
| | |
| | | //判断当前价格和开仓价格直接间隔除以间距,取整,获取的数量是否大于等于0,如果大于0,则下单基础张数*倍数 |
| | | String buyCntTime = InstrumentsWs.getAccountMap(accountName).get(CoinEnums.BUY_CNT_TIME.name()); |
| | | BigDecimal subtract = avgPx.subtract(markPx); |
| | | BigDecimal divide = subtract.divide(new BigDecimal(buyCntTime), 0, RoundingMode.DOWN); |
| | | BigDecimal divide = subtract.divide(new BigDecimal(buyCntTime), 0, RoundingMode.DOWN).add(BigDecimal.ONE); |
| | | if (divide.compareTo(BigDecimal.ZERO) <= 0){ |
| | | log.warn("加仓次数间隔时间小于0,不加仓"); |
| | | return false; |
| | |
| | | //判断当前价格和开仓价格直接间隔除以间距,取整,获取的数量是否大于等于0,如果大于0,则下单基础张数*倍数 |
| | | String buyCntTime = InstrumentsWs.getAccountMap(accountName).get(CoinEnums.BUY_CNT_TIME.name()); |
| | | BigDecimal subtract = markPx.subtract(avgPx); |
| | | BigDecimal divide = subtract.divide(new BigDecimal(buyCntTime), 0, RoundingMode.DOWN); |
| | | BigDecimal divide = subtract.divide(new BigDecimal(buyCntTime), 0, RoundingMode.DOWN).add(BigDecimal.ONE); |
| | | if (divide.compareTo(BigDecimal.ZERO) <= 0){ |
| | | log.warn("加仓次数间隔时间小于0,不加仓"); |
| | | return false; |