Helius
2020-08-29 5677479567a47c14ee091770170e4c7e01bbf31c
src/main/java/com/xcong/excoin/utils/CalculateUtil.java
@@ -86,20 +86,89 @@
    /**
     * 全仓模式 -- 预估强平价
     * 面值*(多单张数*多单开仓价-空单张数*空单开仓价)-余额-已实现盈亏 / 面值*(多单张数-空单张数)-(维持保证金率+TAKER手续费)*面值*(开多张数+开空张数)
     *
     */
    public static void getForceSetPriceForWhole(@NotNull String symbol, @NotNull MemberEntity memberEntity) {
        ContractHoldOrderDao holdOrderDao = SpringContextHolder.getBean(ContractHoldOrderDao.class);
        MemberWalletContractDao walletContractDao = SpringContextHolder.getBean(MemberWalletContractDao.class);
        CacheSettingUtils cacheSettingUtils = SpringContextHolder.getBean(CacheSettingUtils.class);
        Long memberId = memberEntity.getId();
        BigDecimal lotNumber = cacheSettingUtils.getSymbolSku(symbol);
        PlatformTradeSettingEntity tradeSettingEntity = cacheSettingUtils.getTradeSetting();
        MemberWalletContractEntity walletContract = walletContractDao.findWalletContractByMemberIdAndSymbol(memberId, CoinTypeConvert.convertContractTypeToCoin(symbol));
        List<ContractHoldOrderEntity> holdOrderEntities = holdOrderDao.selectHoldOrderListForWholeByMemberIdAndSymbol(memberId, symbol);
        if (CollUtil.isNotEmpty(holdOrderEntities)) {
            // 多单开仓价
            int maxCnt = 0;
            int subCnt = 0;
            BigDecimal openPrice = BigDecimal.ZERO;
            int type = 1;
            BigDecimal feeAmount = BigDecimal.ZERO;
            BigDecimal sku = BigDecimal.ZERO;
            Long id = 0L;
            int operateNo = 0;
            for (ContractHoldOrderEntity holdOrderEntity : holdOrderEntities) {
                if (holdOrderEntity.getSymbolCntSale() >= maxCnt) {
                    int temp = maxCnt;
                    maxCnt = holdOrderEntity.getSymbolCntSale();
                    subCnt = holdOrderEntity.getSymbolCntSale() - temp;
                    openPrice = holdOrderEntity.getOpeningPrice();
                    type = holdOrderEntity.getOpeningType();
                    id = holdOrderEntity.getId();
                    operateNo = holdOrderEntity.getOperateNo() + 1;
                } else {
                    subCnt = maxCnt - holdOrderEntity.getSymbolCntSale();
                }
                feeAmount = feeAmount.add(holdOrderEntity.getOpeningFeeAmount());
                sku = holdOrderEntity.getSymbolSku();
            }
            BigDecimal forceSetPrice = BigDecimal.ZERO;
            if (subCnt != 0) {
                forceSetPrice = getForceSetPrice(walletContract.getTotalBalance().subtract(feeAmount), openPrice, subCnt, sku, type, memberEntity);
            }
            log.info("强平价:{}", forceSetPrice);
            for (ContractHoldOrderEntity updateHoldOrder : holdOrderEntities) {
                updateHoldOrder.setForceClosingPrice(forceSetPrice);
                updateHoldOrder.setIsCanClosing(ContractHoldOrderEntity.ORDER_CAN_CLOSING_Y);
                updateHoldOrder.setOperateNo(operateNo);
                holdOrderDao.updateById(updateHoldOrder);
            }
            if (forceSetPrice.compareTo(BigDecimal.ZERO) > 0) {
                log.info("id:{}, type:{}, forceSetPrice:{}, symbol:{}, operateNo:{}", id, type, forceSetPrice, symbol, operateNo);
                sendOrderBombMsg(id, type, forceSetPrice, symbol, operateNo);
            }
        }
    }
    /*
    BigDecimal totalSetPrice = BigDecimal.ZERO;
            int totalCnt = 0;
            for (ContractHoldOrderEntity holdOrderEntity : holdOrderEntities) {
                BigDecimal forceSetPrice = getForceSetPrice(walletContract.getTotalBalance().subtract(holdOrderEntity.getOpeningFeeAmount()), holdOrderEntity.getOpeningPrice(), holdOrderEntity.getSymbolCntSale(), holdOrderEntity.getSymbolSku(), holdOrderEntity.getOpeningType(), memberEntity);
                log.info("订单强平价 : {}, 订单ID : {}, {}", forceSetPrice, holdOrderEntity.getId(), holdOrderEntity.getSymbolCntSale());
                totalSetPrice = totalSetPrice.add(forceSetPrice.multiply(BigDecimal.valueOf(holdOrderEntity.getSymbolCntSale())));
                totalCnt += holdOrderEntity.getSymbolCntSale();
                log.info("-->{}", totalCnt);
            }
            BigDecimal forceSetPrice = totalSetPrice.divide(BigDecimal.valueOf(totalCnt), 8, BigDecimal.ROUND_DOWN);
            log.info("强平价 : {}", forceSetPrice);
            for (ContractHoldOrderEntity updateHoldOrder : holdOrderEntities) {
                updateHoldOrder.setForceClosingPrice(forceSetPrice);
                updateHoldOrder.setIsCanClosing(ContractHoldOrderEntity.ORDER_CAN_CLOSING_Y);
                holdOrderDao.updateById(updateHoldOrder);
                if (forceSetPrice.compareTo(BigDecimal.ZERO) >= 0) {
                    sendOrderBombMsg(updateHoldOrder.getId(), updateHoldOrder.getOpeningType(), forceSetPrice, updateHoldOrder.getSymbol(), updateHoldOrder.getOperateNo());
                }
            }
     */
    /*
// 多单开仓价
            BigDecimal moreOpenPrice = BigDecimal.ZERO;
            // 多单张数
            int moreCnt = 0;
@@ -148,8 +217,9 @@
                    sendOrderBombMsg(updateHoldOrder.getId(), updateHoldOrder.getOpeningType(), forceSetPrice, updateHoldOrder.getSymbol(), updateHoldOrder.getOperateNo());
                }
            }
        }
    }
     */
    private static void sendOrderBombMsg(Long id, int type, BigDecimal forceClosingPrice, String symbol, int operateNo) {
        OrderModel model = null;