modify force price

Helius

2021-04-02 a7bb19097114e06e43de10f41ad546bce114f552

 src/main/java/com/xcong/excoin/modules/documentary/service/impl/FollowOrderOperationServiceImpl.java

@@ -125,7 +125,7 @@
            for (FollowFollowerSettingEntity followerSetting : followerSettings) {
                // 加redis锁，同一个用户不能同时触发两个跟单任务，否则会出现金额问题
                while (true) {
                    boolean flag = redisUtils.setNotExist(AppContants.MEMBER_HAS_FOLLOW + "_" + followerSetting.getMemberId(), "1", 1);
                    boolean flag = redisUtils.setNotExist(AppContants.MEMBER_HAS_FOLLOW + "_" + followerSetting.getMemberId(), "1", 5);
//                    List<Object> followerMemberId = redisUtils.lGet(AppContants.MEMBER_HAS_FOLLOW, 0, -1);
//                    log.info("#跟单用户任务已存在:{}, 当前:{}#", followerMemberId, followerSetting.getMemberId());
//                    log.info("#------->{}#", followerMemberId.contains(followerSetting.getMemberId().intValue()));
@@ -210,6 +210,31 @@
                    continue;
                }

                boolean flag = false;
                while(true) {
                    MemberWalletContractEntity updateEntity = new MemberWalletContractEntity();
                    updateEntity.setAvailableBalance(prePaymentAmount.negate());
                    updateEntity.setTotalBalance(openFeePrice.negate());
                    updateEntity.setId(walletContract.getId());
                    updateEntity.setVersion(walletContract.getVersion());
                    int i = memberWalletContractDao.updateWalletContractWithVersion(updateEntity);
                    if (i > 0) {
                        break;
                    }

                    walletContract = memberWalletContractDao.findWalletContractByMemberIdAndSymbol(followerSetting.getMemberId(), CoinTypeEnum.USDT.name());
                    if (prePaymentAmount.compareTo(walletContract.getAvailableBalance()) > -1) {
                        log.info("可用金额不足");
                        LogRecordUtils.insertFollowerNotice(followerSetting.getMemberId(), NoticeConstant.MONEY_NOT_ENOUGH_TITLE, StrUtil.format(NoticeConstant.MONEY_NOT_ENOUGH_CONTENT, followTraderInfoEntity.getNickname()));
                        flag = true;
                        break;
                    }
                }

                if (flag) {
                    continue;
                }

                MemberEntity memberEntity = memberDao.selectById(followerSetting.getMemberId());
                // 强平价
                BigDecimal forceClosingPrice = CalculateUtil.getForceSetPrice(bondAmount, openPrice, symbolCnt, lotNumber, holdOrderEntity.getOpeningType(), memberEntity);
@@ -240,7 +265,7 @@
                contractHoldOrderDao.insert(followHoldOrder);
                int i = contractOrderDao.insert(contractOrderEntity);
                if (i > 0) {
                    memberWalletContractDao.increaseWalletContractBalanceById(prePaymentAmount.negate(), openFeePrice.negate(), null, walletContract.getId());
//                    memberWalletContractDao.increaseWalletContractBalanceById(prePaymentAmount.negate(), openFeePrice.negate(), null, walletContract.getId());

                    FollowFollowerOrderRelationEntity relationEntity = new FollowFollowerOrderRelationEntity();
                    relationEntity.setIsShow(FollowFollowerOrderRelationEntity.IS_SHOW_Y);