From 76706e083e2f5d91b4d3346ffead2e6bce2d09c5 Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Tue, 15 Aug 2023 17:00:28 +0800
Subject: [PATCH] 后台修改

---
 src/main/java/cc/mrbird/febs/dapp/service/impl/DappMemberServiceImpl.java |  351 +++++++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 346 insertions(+), 5 deletions(-)

diff --git a/src/main/java/cc/mrbird/febs/dapp/service/impl/DappMemberServiceImpl.java b/src/main/java/cc/mrbird/febs/dapp/service/impl/DappMemberServiceImpl.java
index 9ccf8d8..da79277 100644
--- a/src/main/java/cc/mrbird/febs/dapp/service/impl/DappMemberServiceImpl.java
+++ b/src/main/java/cc/mrbird/febs/dapp/service/impl/DappMemberServiceImpl.java
@@ -11,10 +11,7 @@
 import cc.mrbird.febs.dapp.contract.andao.AndaoContractMain;
 import cc.mrbird.febs.dapp.dto.*;
 import cc.mrbird.febs.dapp.entity.*;
-import cc.mrbird.febs.dapp.enumerate.DataDictionaryEnum;
-import cc.mrbird.febs.dapp.enumerate.FundFlowEnum;
-import cc.mrbird.febs.dapp.enumerate.MemberLevelEnum;
-import cc.mrbird.febs.dapp.enumerate.PoolEnum;
+import cc.mrbird.febs.dapp.enumerate.*;
 import cc.mrbird.febs.dapp.mapper.*;
 import cc.mrbird.febs.dapp.service.DappMemberService;
 import cc.mrbird.febs.dapp.vo.*;
@@ -69,6 +66,9 @@
     private final MallOrderInfoMapper mallOrderInfoMapper;
     private final MallOrderItemMapper mallOrderItemMapper;
     private final MallAchieveRecordMapper mallAchieveRecordMapper;
+    private final DappAccountMoneyChangeDao dappAccountMoneyChangeDao;
+    private final MallAddressInfoMapper mallAddressInfoMapper;
+    private final MallGoodsCategoryMapper mallGoodsCategoryMapper;
 
     @Override
     @Transactional(rollbackFor = Exception.class)
@@ -522,6 +522,10 @@
 
         DappWalletMineEntity dappWalletMineEntity = dappWalletMineDao.selectByMemberId(member.getId());
         dappMemberInfoVo.setScore(ObjectUtil.isEmpty(dappWalletMineEntity) ? BigDecimal.ZERO : dappWalletMineEntity.getTotalAmount());
+        QueryWrapper<MallOrderInfo> objectQueryWrapper = new QueryWrapper<>();
+        objectQueryWrapper.eq("status", 1);
+        Integer selectCount = mallOrderInfoMapper.selectCount(objectQueryWrapper);
+        dappMemberInfoVo.setWaitPayCnt(selectCount);
         return new FebsResponse().success().data(dappMemberInfoVo);
     }
 
@@ -597,6 +601,14 @@
         MallOrderListVo mallOrderListVo = dappMemberDao.selectMallOrderListVoById(id);
         List<MallOrderItemVo> mallOrderItemVoList = dappMemberDao.selectMallOrderItemVoByOrderId(id);
         mallOrderListVo.setItems(mallOrderItemVoList);
+        long addressId = ObjectUtil.isEmpty(mallOrderListVo.getAddressId()) ? 0L : mallOrderListVo.getAddressId();
+        MallAddressInfo mallAddressInfo = mallAddressInfoMapper.selectById(addressId);
+        if(ObjectUtil.isNotEmpty(mallAddressInfo)){
+            mallOrderListVo.setName(mallAddressInfo.getName());
+            mallOrderListVo.setPhone(mallAddressInfo.getPhone());
+            mallOrderListVo.setArea(mallAddressInfo.getArea());
+            mallOrderListVo.setAddress(mallAddressInfo.getAddress());
+        }
         return mallOrderListVo;
     }
 
@@ -647,6 +659,10 @@
         mallOrderInfo.setOrderTime(DateUtil.date());
         mallOrderInfo.setAmount(totalAmount);
         mallOrderInfo.setStatus(MallOrderInfo.STATUS_WAIT);
+        mallOrderInfo.setDeliverType(addOrderDto.getDeliverType());
+        if(1 == addOrderDto.getDeliverType()){
+            mallOrderInfo.setAddressId(addOrderDto.getAddressId());
+        }
         mallOrderInfo.setOrderType(1);
         mallOrderInfoMapper.insert(mallOrderInfo);
         MallOrderItem mallOrderItem = new MallOrderItem();
@@ -741,12 +757,14 @@
         orderInfo.setPayMethod("余额支付");
         orderInfo.setPayResult(1);
         orderInfo.setStatus(MallOrderInfo.STATUS_PAY);
+        orderInfo.setDeliverState(MallOrderInfo.DELIVER_STATUS_WAIT);
         mallOrderInfoMapper.updateById(orderInfo);
         /**
          * 更新用户余额
          */
         dappWalletCoinDao.reduceTotalAndAvailableByMemberId(member.getId(),totalAmount);
         DappFundFlowEntity donateScoreFlow = new DappFundFlowEntity(
+                AccountFlowEnum.AMOUNT.getCode(),
                 member.getId(),
                 totalAmount.negate(),
                 FundFlowEnum.PAY_ORDER.getCode(),
@@ -879,7 +897,330 @@
 
     @Override
     public IPage<MemberMoneyFlowVo> memberMoneyFlow(QueryRequest request, DappMemberEntity dappMemberEntity) {
-        return null;
+        Page<MemberMoneyFlowVo> page = new Page<>(request.getPageNum(), request.getPageSize());
+        IPage<MemberMoneyFlowVo> memberMoneyFlowVos = dappAccountMoneyChangeDao.selectMemberMoneyFlowInPage(page, dappMemberEntity);
+        return memberMoneyFlowVos;
+    }
+
+    @Override
+    public void delOrder(Long id) {
+        Long memberId = LoginUserUtil.getAppUser().getId();
+
+        mallOrderInfoMapper.deleteById(id);
+        QueryWrapper<MallOrderItem> objectQueryWrapper = new QueryWrapper<>();
+        objectQueryWrapper.eq("order_id", id);
+        List<MallOrderItem> mallOrderItems = mallOrderItemMapper.selectList(objectQueryWrapper);
+        if(CollUtil.isNotEmpty(mallOrderItems)){
+            for(MallOrderItem mallOrderItem : mallOrderItems){
+                mallOrderItemMapper.deleteById(mallOrderItem.getId());
+            }
+        }
+    }
+
+    @Override
+    public void createAddress(CreateAddressDto createAddressDto) {
+        Long memberId = LoginUserUtil.getAppUser().getId();
+        MallAddressInfo mallAddressInfo = new MallAddressInfo();
+        mallAddressInfo.setMemberId(memberId);
+        mallAddressInfo.setName(createAddressDto.getName());
+        mallAddressInfo.setPhone(createAddressDto.getPhone());
+        mallAddressInfo.setArea(createAddressDto.getArea());
+        mallAddressInfo.setAddress(createAddressDto.getAddress());
+        mallAddressInfo.setIsDefault(1);
+        mallAddressInfoMapper.insert(mallAddressInfo);
+    }
+
+    @Override
+    public void delAddress(Long id) {
+        Long memberId = LoginUserUtil.getAppUser().getId();
+        MallAddressInfo mallAddressInfo = mallAddressInfoMapper.selectById(id);
+        if(ObjectUtil.isEmpty(mallAddressInfo)){
+            throw new FebsException("地址不存在");
+        }
+        mallAddressInfo.setIsDefault(2);
+        mallAddressInfoMapper.updateById(mallAddressInfo);
+    }
+
+    @Override
+    public IPage<MallAddressInfo> findAddressList(MallGoodsQueryDto queryDto) {
+        Long memberId = LoginUserUtil.getAppUser().getId();
+        Page<MallAddressInfo> page = new Page<>(queryDto.getPageNow(), queryDto.getPageSize());
+        return dappMemberDao.selectAddressListInPage(queryDto, page);
+    }
+
+    @Override
+    public MallAddressInfo addressDetails(Long id) {
+        Long memberId = LoginUserUtil.getAppUser().getId();
+        MallAddressInfo mallAddressInfo = mallAddressInfoMapper.selectById(id);
+        return mallAddressInfo;
+    }
+
+    @Override
+    public void updateAddress(CreateAddressDto createAddressDto) {
+        Long memberId = LoginUserUtil.getAppUser().getId();
+
+        MallAddressInfo mallAddressInfo = mallAddressInfoMapper.selectById(createAddressDto.getId());
+        if(ObjectUtil.isEmpty(mallAddressInfo)){
+            throw new FebsException("地址不存在");
+        }
+        mallAddressInfo.setName(createAddressDto.getName());
+        mallAddressInfo.setPhone(createAddressDto.getPhone());
+        mallAddressInfo.setArea(createAddressDto.getArea());
+        mallAddressInfo.setAddress(createAddressDto.getAddress());
+        mallAddressInfoMapper.updateById(mallAddressInfo);
+    }
+
+    @Override
+    public List<MallGoodsCategory> categoryList() {
+        return mallGoodsCategoryMapper.selectRecommendCategoryList();
+    }
+
+    @Override
+    public FebsResponse balanceSystem() {
+
+        List<DappMemberEntity> dappMemberEntities = dappMemberDao.selectAllMemberForInCome();
+        if(CollUtil.isNotEmpty(dappMemberEntities)){
+            if(dappMemberEntities.size() <= 100){
+                for(DappMemberEntity dappMemberEntity : dappMemberEntities){
+                    Long memberId = dappMemberEntity.getId();
+                    BigDecimal balance = dappMemberEntity.getBalance();
+
+                    BigDecimal cnt = balance.divide(new BigDecimal(2) , 2 ,BigDecimal.ROUND_DOWN);
+                    dappMemberEntity.setBalance(balance.subtract(cnt));
+                    dappMemberDao.updateById(dappMemberEntity);
+
+                    DataDictionaryCustom packageScorePriceDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+                            DataDictionaryEnum.PACKAGE_SCORE_PRICE.getType(),
+                            DataDictionaryEnum.PACKAGE_SCORE_PRICE.getCode()
+                    );
+                    BigDecimal packageScorePrice = new BigDecimal(ObjectUtil.isEmpty(packageScorePriceDic) ? "0" : packageScorePriceDic.getValue()).setScale(2, BigDecimal.ROUND_DOWN);
+                    //卖出资产乘以价格获取到预期获取的总额
+                    BigDecimal totalAmount = cnt.multiply(packageScorePrice).setScale(2, BigDecimal.ROUND_DOWN);
+                    //资产包卖出划入底池比例
+                    DataDictionaryCustom packageToPoorPercentDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+                            DataDictionaryEnum.PACKAGE_SALE_TO_POOR_PERCENT.getType(),
+                            DataDictionaryEnum.PACKAGE_SALE_TO_POOR_PERCENT.getCode()
+                    );
+                    BigDecimal packageToPoorPercent = new BigDecimal(ObjectUtil.isEmpty(packageToPoorPercentDic) ? "0.1" : packageToPoorPercentDic.getValue()).setScale(2, BigDecimal.ROUND_DOWN);
+                    //划入底池的金额
+                    BigDecimal poorAmount = totalAmount.multiply(packageToPoorPercent).setScale(2, BigDecimal.ROUND_DOWN);
+                    //实际获取的金额
+                    BigDecimal realAmount = totalAmount.subtract(poorAmount);
+                    //生成一条资金流水
+                    DappFundFlowEntity scoreFlow = new DappFundFlowEntity(
+                            memberId,
+                            realAmount,
+                            FundFlowEnum.SYSTEM_PACKAGE_SALE.getCode(),
+                            DappFundFlowEntity.WITHDRAW_STATUS_AGREE,
+                            BigDecimal.ZERO);
+                    dappFundFlowDao.insert(scoreFlow);
+                    dappWalletCoinDao.addTotalAndaddAvailableByMemberId(memberId,realAmount);
+                    DappFundFlowEntity feeFlow = new DappFundFlowEntity(
+                            memberId,
+                            poorAmount.negate(),
+                            FundFlowEnum.SYSTEM_PACKAGE_SALE.getCode(),
+                            DappFundFlowEntity.WITHDRAW_STATUS_AGREE,
+                            BigDecimal.ZERO);
+                    dappFundFlowDao.insert(feeFlow);
+
+                    //卖出积分直接销毁。
+                    DataDictionaryCustom packageTotalScoreDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+                            DataDictionaryEnum.PACKAGE_TOTAL_SCORE.getType(),
+                            DataDictionaryEnum.PACKAGE_TOTAL_SCORE.getCode()
+                    );
+                    BigDecimal avaPackageTotalScore = new BigDecimal(ObjectUtil.isEmpty(packageTotalScoreDic) ? "21000" : packageTotalScoreDic.getValue()).setScale(2, BigDecimal.ROUND_DOWN);
+                    //更新USDT底池
+                    DataDictionaryCustom packagePoorDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+                            DataDictionaryEnum.PACKAGE_POOR.getType(),
+                            DataDictionaryEnum.PACKAGE_POOR.getCode()
+                    );
+                    BigDecimal packagePoor = new BigDecimal(ObjectUtil.isEmpty(packagePoorDic) ? "0" : packagePoorDic.getValue()).setScale(2, BigDecimal.ROUND_DOWN);
+                    BigDecimal avaPackagePoor = packagePoor.add(poorAmount);
+                    packagePoorDic.setValue(avaPackagePoor.toString());
+                    dataDictionaryCustomMapper.updateById(packagePoorDic);
+                    //计算当前价格
+                    BigDecimal divide = avaPackagePoor.divide(avaPackageTotalScore, 8, BigDecimal.ROUND_DOWN);
+                    packageScorePriceDic.setValue(divide.toString());
+                    dataDictionaryCustomMapper.updateById(packageScorePriceDic);
+                }
+                return new FebsResponse().success();
+            }
+            List<MallAchieveRecord> mallAchieveRecordList = new ArrayList<>();
+            for(DappMemberEntity dappMemberEntity : dappMemberEntities){
+                //获取每个人的业绩
+                //业绩集合
+                List<BigDecimal> list = new ArrayList<>();
+                //总业绩
+                BigDecimal teamIncomeMax = BigDecimal.ZERO;
+                //所有直推团队,就是这个会员的所有区域的业绩。
+
+                // 直推用户
+                List<DappMemberEntity> childs = dappMemberDao.selectMemberInfoByRefererId(dappMemberEntity.getInviteId());
+                List<String> childsInviteIds = childs.stream().map(DappMemberEntity::getInviteId).collect(Collectors.toList());
+                if(CollUtil.isNotEmpty(childsInviteIds)){
+                    for(String inviteId : childsInviteIds){
+                        BigDecimal totalIncomeMember = dappMemberDao.selectAchieveRecordByInviteId(inviteId);
+                        teamIncomeMax = teamIncomeMax.add(totalIncomeMember);
+                        list.add(totalIncomeMember);
+                    }
+                    //去掉一个最大区的业绩
+                    BigDecimal bigMax = list.stream().max(BigDecimal::compareTo).get();
+                    teamIncomeMax = teamIncomeMax.subtract(bigMax);
+
+                    MallAchieveRecord mallAchieveRecord = new MallAchieveRecord();
+                    mallAchieveRecord.setMemberId(dappMemberEntity.getId());
+                    mallAchieveRecord.setAmount(teamIncomeMax);
+                    mallAchieveRecordList.add(mallAchieveRecord);
+                }
+            }
+            if(CollUtil.isNotEmpty(mallAchieveRecordList)){
+                //按照小区业绩的多少排名
+                List<MallAchieveRecord> collect = mallAchieveRecordList
+                        .stream()
+                        .sorted(Comparator.comparing(MallAchieveRecord::getAmount))
+                        .collect(Collectors.toList());
+
+                List<MallAchieveRecord> top100Performances = collect.stream()
+                        .limit(100)
+                        .collect(Collectors.toList());
+                if(CollUtil.isNotEmpty(top100Performances)){
+                    for(MallAchieveRecord mallAchieveRecord : top100Performances){
+                        Long memberId = mallAchieveRecord.getMemberId();
+                        DappMemberEntity dappMemberEntity = dappMemberDao.selectById(memberId);
+                        BigDecimal balance = dappMemberEntity.getBalance();
+
+                        BigDecimal cnt = balance.divide(new BigDecimal(2) , 2 ,BigDecimal.ROUND_DOWN);
+                        dappMemberEntity.setBalance(balance.subtract(cnt));
+                        dappMemberDao.updateById(dappMemberEntity);
+                        DataDictionaryCustom packageScorePriceDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+                                DataDictionaryEnum.PACKAGE_SCORE_PRICE.getType(),
+                                DataDictionaryEnum.PACKAGE_SCORE_PRICE.getCode()
+                        );
+                        BigDecimal packageScorePrice = new BigDecimal(ObjectUtil.isEmpty(packageScorePriceDic) ? "0" : packageScorePriceDic.getValue()).setScale(2, BigDecimal.ROUND_DOWN);
+                        //卖出资产乘以价格获取到预期获取的总额
+                        BigDecimal totalAmount = cnt.multiply(packageScorePrice).setScale(2, BigDecimal.ROUND_DOWN);
+                        //资产包卖出划入底池比例
+                        DataDictionaryCustom packageToPoorPercentDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+                                DataDictionaryEnum.PACKAGE_SALE_TO_POOR_PERCENT.getType(),
+                                DataDictionaryEnum.PACKAGE_SALE_TO_POOR_PERCENT.getCode()
+                        );
+                        BigDecimal packageToPoorPercent = new BigDecimal(ObjectUtil.isEmpty(packageToPoorPercentDic) ? "0.1" : packageToPoorPercentDic.getValue()).setScale(2, BigDecimal.ROUND_DOWN);
+                        //划入底池的金额
+                        BigDecimal poorAmount = totalAmount.multiply(packageToPoorPercent).setScale(2, BigDecimal.ROUND_DOWN);
+                        //实际获取的金额
+                        BigDecimal realAmount = totalAmount.subtract(poorAmount);
+                        //生成一条资金流水
+                        DappFundFlowEntity scoreFlow = new DappFundFlowEntity(
+                                memberId,
+                                realAmount,
+                                FundFlowEnum.SYSTEM_PACKAGE_SALE.getCode(),
+                                DappFundFlowEntity.WITHDRAW_STATUS_AGREE,
+                                BigDecimal.ZERO);
+                        dappFundFlowDao.insert(scoreFlow);
+                        dappWalletCoinDao.addTotalAndaddAvailableByMemberId(memberId,realAmount);
+                        DappFundFlowEntity feeFlow = new DappFundFlowEntity(
+                                memberId,
+                                poorAmount.negate(),
+                                FundFlowEnum.SYSTEM_PACKAGE_SALE.getCode(),
+                                DappFundFlowEntity.WITHDRAW_STATUS_AGREE,
+                                BigDecimal.ZERO);
+                        dappFundFlowDao.insert(feeFlow);
+
+                        //卖出积分直接销毁。
+                        DataDictionaryCustom packageTotalScoreDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+                                DataDictionaryEnum.PACKAGE_TOTAL_SCORE.getType(),
+                                DataDictionaryEnum.PACKAGE_TOTAL_SCORE.getCode()
+                        );
+                        BigDecimal avaPackageTotalScore = new BigDecimal(ObjectUtil.isEmpty(packageTotalScoreDic) ? "21000" : packageTotalScoreDic.getValue()).setScale(2, BigDecimal.ROUND_DOWN);
+                        //更新USDT底池
+                        DataDictionaryCustom packagePoorDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+                                DataDictionaryEnum.PACKAGE_POOR.getType(),
+                                DataDictionaryEnum.PACKAGE_POOR.getCode()
+                        );
+                        BigDecimal packagePoor = new BigDecimal(ObjectUtil.isEmpty(packagePoorDic) ? "0" : packagePoorDic.getValue()).setScale(2, BigDecimal.ROUND_DOWN);
+                        BigDecimal avaPackagePoor = packagePoor.add(poorAmount);
+                        packagePoorDic.setValue(avaPackagePoor.toString());
+                        dataDictionaryCustomMapper.updateById(packagePoorDic);
+                        //计算当前价格
+                        BigDecimal divide = avaPackagePoor.divide(avaPackageTotalScore, 8, BigDecimal.ROUND_DOWN);
+                        packageScorePriceDic.setValue(divide.toString());
+                        dataDictionaryCustomMapper.updateById(packageScorePriceDic);
+                    }
+                }
+
+                List<MallAchieveRecord> remainingUsers = mallAchieveRecordList
+                        .stream()
+                        .sorted(Comparator.comparing(MallAchieveRecord::getAmount).reversed())
+                        .skip(100)
+                        .collect(Collectors.toList());
+                if(CollUtil.isNotEmpty(remainingUsers)){
+                    for(MallAchieveRecord mallAchieveRecord : remainingUsers){
+                        Long memberId = mallAchieveRecord.getMemberId();
+                        DappMemberEntity dappMemberEntity = dappMemberDao.selectById(memberId);
+                        BigDecimal balance = dappMemberEntity.getBalance();
+
+                        BigDecimal cnt = balance;
+                        dappMemberEntity.setBalance(balance.subtract(cnt));
+                        dappMemberDao.updateById(dappMemberEntity);
+                        DataDictionaryCustom packageScorePriceDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+                                DataDictionaryEnum.PACKAGE_SCORE_PRICE.getType(),
+                                DataDictionaryEnum.PACKAGE_SCORE_PRICE.getCode()
+                        );
+                        BigDecimal packageScorePrice = new BigDecimal(ObjectUtil.isEmpty(packageScorePriceDic) ? "0" : packageScorePriceDic.getValue()).setScale(2, BigDecimal.ROUND_DOWN);
+                        //卖出资产乘以价格获取到预期获取的总额
+                        BigDecimal totalAmount = cnt.multiply(packageScorePrice).setScale(2, BigDecimal.ROUND_DOWN);
+                        //资产包卖出划入底池比例
+                        DataDictionaryCustom packageToPoorPercentDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+                                DataDictionaryEnum.PACKAGE_SALE_TO_POOR_PERCENT.getType(),
+                                DataDictionaryEnum.PACKAGE_SALE_TO_POOR_PERCENT.getCode()
+                        );
+                        BigDecimal packageToPoorPercent = new BigDecimal(ObjectUtil.isEmpty(packageToPoorPercentDic) ? "0.1" : packageToPoorPercentDic.getValue()).setScale(2, BigDecimal.ROUND_DOWN);
+                        //划入底池的金额
+                        BigDecimal poorAmount = totalAmount.multiply(packageToPoorPercent).setScale(2, BigDecimal.ROUND_DOWN);
+                        //实际获取的金额
+                        BigDecimal realAmount = totalAmount.subtract(poorAmount);
+                        //生成一条资金流水
+                        DappFundFlowEntity scoreFlow = new DappFundFlowEntity(
+                                memberId,
+                                realAmount,
+                                FundFlowEnum.SYSTEM_PACKAGE_SALE.getCode(),
+                                DappFundFlowEntity.WITHDRAW_STATUS_AGREE,
+                                BigDecimal.ZERO);
+                        dappFundFlowDao.insert(scoreFlow);
+                        dappWalletCoinDao.addTotalAndaddAvailableByMemberId(memberId,realAmount);
+                        DappFundFlowEntity feeFlow = new DappFundFlowEntity(
+                                memberId,
+                                poorAmount.negate(),
+                                FundFlowEnum.SYSTEM_PACKAGE_SALE.getCode(),
+                                DappFundFlowEntity.WITHDRAW_STATUS_AGREE,
+                                BigDecimal.ZERO);
+                        dappFundFlowDao.insert(feeFlow);
+
+                        //卖出积分回收。
+                        DataDictionaryCustom packageTotalScoreDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+                                DataDictionaryEnum.PACKAGE_TOTAL_SCORE.getType(),
+                                DataDictionaryEnum.PACKAGE_TOTAL_SCORE.getCode()
+                        );
+                        BigDecimal avaPackageTotalScore = new BigDecimal(ObjectUtil.isEmpty(packageTotalScoreDic) ? "21000" : packageTotalScoreDic.getValue()).setScale(2, BigDecimal.ROUND_DOWN);
+                        //更新USDT底池
+                        DataDictionaryCustom packagePoorDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+                                DataDictionaryEnum.PACKAGE_POOR.getType(),
+                                DataDictionaryEnum.PACKAGE_POOR.getCode()
+                        );
+                        BigDecimal packagePoor = new BigDecimal(ObjectUtil.isEmpty(packagePoorDic) ? "0" : packagePoorDic.getValue()).setScale(2, BigDecimal.ROUND_DOWN);
+                        BigDecimal avaPackagePoor = packagePoor.add(poorAmount);
+                        packagePoorDic.setValue(avaPackagePoor.toString());
+                        dataDictionaryCustomMapper.updateById(packagePoorDic);
+                        //计算当前价格
+                        BigDecimal divide = avaPackagePoor.divide(avaPackageTotalScore, 8, BigDecimal.ROUND_DOWN);
+                        packageScorePriceDic.setValue(divide.toString());
+                        dataDictionaryCustomMapper.updateById(packageScorePriceDic);
+                    }
+                }
+            }
+
+        }
+        return new FebsResponse().success();
     }
 
     public static List<List<String>> partitionList(List<String> originalList, int partitionSize) {

--
Gitblit v1.9.1