优化扫块速度

zainali5120

2021-03-17 cbcbaa6a1e96982b73091b0ac8927fafa27c6a39

 src/main/java/com/xcong/excoin/utils/CalculateUtil.java

@@ -4,6 +4,7 @@
import cn.hutool.core.collection.CollUtil;

import cn.hutool.core.util.StrUtil;

import com.alibaba.fastjson.JSONObject;

import com.xcong.excoin.common.contants.AppContants;

import com.xcong.excoin.common.enumerates.CoinTypeEnum;

import com.xcong.excoin.common.enumerates.RabbitPriceTypeEnum;

import com.xcong.excoin.common.exception.GlobalException;

@@ -14,6 +15,7 @@
import com.xcong.excoin.modules.member.entity.MemberEntity;

import com.xcong.excoin.modules.member.entity.MemberSettingEntity;

import com.xcong.excoin.modules.member.entity.MemberWalletContractEntity;

import com.xcong.excoin.modules.platform.dao.TradeSettingDao;

import com.xcong.excoin.modules.platform.entity.PlatformTradeSettingEntity;

import com.xcong.excoin.rabbit.pricequeue.OrderModel;

import com.xcong.excoin.rabbit.producer.OrderProducer;

@@ -78,7 +80,7 @@


    /**

     * 全仓模式 -- 预估强平价

     * 开仓价 - (权益 - 其他币种成本)/当前币种成本 * (开仓价 * 杠杆)

     * 开仓价 - (权益 - 其他币种成本)/当前币种成本 * (开仓价 * 1/杠杆)

     */

    public static BigDecimal getForceSetPriceForWhole(String currentSymbol, @NotNull MemberEntity memberEntity) {

        ContractHoldOrderDao holdOrderDao = SpringContextHolder.getBean(ContractHoldOrderDao.class);

@@ -95,8 +97,6 @@
            for (String symbol : symbols) {

                // 其他币种成本

                BigDecimal totalBondAmount = BigDecimal.ZERO;

                // 当前币种手续费

                BigDecimal symbolFeeAmount = BigDecimal.ZERO;

                // 当前币种保证金

                BigDecimal symbolBondAmount = BigDecimal.ZERO;



@@ -114,8 +114,7 @@
                        if (holdOrderEntity.getOpeningType() == ContractHoldOrderEntity.OPENING_TYPE_MORE) {

                            isAloneLess = false;

                        }

                        symbolFeeAmount = symbolFeeAmount.add(holdOrderEntity.getOpeningFeeAmount());

                        symbolBondAmount = symbolBondAmount.add(bondAmount);

                        symbolBondAmount = symbolBondAmount.add(bondAmount.subtract(holdOrderEntity.getOpeningFeeAmount()));



                        if (openPrice.compareTo(BigDecimal.ZERO) == 0) {

                            openPrice = holdOrderEntity.getOpeningPrice();

@@ -130,8 +129,8 @@
                }



//                log.info("{}, {}, {}, {}, {}, {}", totalBondAmount, symbolBondAmount, symbolFeeAmount, openPrice, profitOrLoss, leverRatio);

                BigDecimal equity = walletContract.getTotalBalance().add(profitOrLoss);

                BigDecimal sub = equity.subtract(symbolFeeAmount).subtract(totalBondAmount);

                BigDecimal equity = walletContract.getTotalBalance().add(profitOrLoss).subtract(walletContract.getFrozenBalance());

                BigDecimal sub = equity.subtract(totalBondAmount);

//                log.info("sub -- {}", sub);

                if (sub.compareTo(symbolBondAmount) <= 0) {

                    BigDecimal multi = BigDecimal.valueOf(10);

@@ -164,7 +163,7 @@
        return result;

    }



    private static BigDecimal calProfitOrLoss(ContractHoldOrderEntity holdOrderEntity, MemberEntity memberEntity) {

    public static BigDecimal calProfitOrLoss(ContractHoldOrderEntity holdOrderEntity, MemberEntity memberEntity) {

        CacheSettingUtils cacheSettingUtils = SpringContextHolder.getBean(CacheSettingUtils.class);

        RedisUtils redisUtils = SpringContextHolder.getBean(RedisUtils.class);

        BigDecimal lotNumber = cacheSettingUtils.getSymbolSku(holdOrderEntity.getSymbol());

@@ -269,4 +268,24 @@


        return profitOrLess;

    }





    /**

     * 全仓模式下，维持保证金

     * 维持保证金 = 持仓价值*维持保证金率= 面值*张数*开仓价格*维持保证金率

     * @param contractHoldOrder

     * @return

     */

    public static BigDecimal calMemberHoldBond(ContractHoldOrderEntity contractHoldOrder) {

        TradeSettingDao tradeSettingDao = SpringContextHolder.getBean(TradeSettingDao.class);

        RedisUtils redisUtils = SpringContextHolder.getBean(RedisUtils.class);

        PlatformTradeSettingEntity tradeSetting = tradeSettingDao.findTradeSetting();

        BigDecimal holdBondRatio = (BigDecimal) redisUtils.get(AppContants.HOLD_BOND_RATIO);

        if (holdBondRatio == null) {

            holdBondRatio = tradeSetting.getHoldBondRatio();

            redisUtils.set(AppContants.HOLD_BOND_RATIO, tradeSetting.getHoldBondRatio());

        }



        return contractHoldOrder.getOpeningPrice().multiply(new BigDecimal(contractHoldOrder.getSymbolCntSale())).multiply(holdBondRatio).multiply(contractHoldOrder.getSymbolSku());

    }

}