From a5f55c1fa8b7969de39e3916d669fd4f7bebba7a Mon Sep 17 00:00:00 2001
From: KKSU <15274802129@163.com>
Date: Fri, 05 Jan 2024 11:27:46 +0800
Subject: [PATCH] 团队列表

---
 src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallOrderInfoServiceImpl.java |  390 +++++++++++++++++++++++++++++++++++++++++--------------
 1 files changed, 287 insertions(+), 103 deletions(-)

diff --git a/src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallOrderInfoServiceImpl.java b/src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallOrderInfoServiceImpl.java
index e288e53..3d28d84 100644
--- a/src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallOrderInfoServiceImpl.java
+++ b/src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallOrderInfoServiceImpl.java
@@ -14,13 +14,14 @@
 import cc.mrbird.febs.mall.entity.*;
 import cc.mrbird.febs.mall.mapper.*;
 import cc.mrbird.febs.mall.service.*;
-import cc.mrbird.febs.mall.vo.OrderDetailVo;
-import cc.mrbird.febs.mall.vo.OrderListVo;
-import cc.mrbird.febs.mall.vo.OrderRefundVo;
+import cc.mrbird.febs.mall.vo.*;
 import cc.mrbird.febs.pay.model.AgreementPayDto;
 import cc.mrbird.febs.pay.model.AgreementSignDto;
+import cc.mrbird.febs.pay.model.LaKaLaCreateOrderReqDate;
 import cc.mrbird.febs.pay.model.UnipayDto;
+import cc.mrbird.febs.pay.service.IAliPayService;
 import cc.mrbird.febs.pay.service.IPayService;
+import cc.mrbird.febs.pay.service.LaKaLaService;
 import cc.mrbird.febs.pay.service.UnipayService;
 import cc.mrbird.febs.rabbit.producter.AgentProducer;
 import cn.hutool.core.collection.CollUtil;
@@ -41,6 +42,7 @@
 import org.springframework.transaction.annotation.Transactional;
 
 import java.math.BigDecimal;
+import java.math.BigInteger;
 import java.text.DecimalFormat;
 import java.util.*;
 
@@ -64,17 +66,28 @@
     private final MallOrderRefundMapper mallOrderRefundMapper;
     private final MallOrderRefundOperationMapper mallOrderRefundOperationMapper;
     private final MallShoppingCartMapper mallShoppingCartMapper;
-    private final IApiMallMemberService memberService;
     private final IMallMoneyFlowService mallMoneyFlowService;
     private final RedisUtils redisUtils;
 
     private final AgentProducer agentProducer;
-    private final IPayService payService;
+    private final IAliPayService payService;
     private final IMallAchieveService mallAchieveService;
     private final UnipayService unipayService;
+    private final IPayService wechatPayService;
+    private final LaKaLaService laKaLaService;
 
     private final MallMemberBankSignMapper mallMemberBankSignMapper;
     private final MallMemberBankMapper mallMemberBankMapper;
+    private final MallShopApplyMapper mallShopApplyMapper;
+    private final DataDictionaryCustomMapper dataDictionaryCustomMapper;
+    private final MallAchieveRecordMapper mallAchieveRecordMapper;
+    private final MallMemberWalletMapper mallMemberWalletMapper;
+    private final MallMqRecordMapper mallMqRecordMapper;
+    private final MallProductSellMapper mallProductSellMapper;
+    private final MallProductSellRecordMapper mallProductSellRecordMapper;
+
+    private final ICommonService commonService;
+    private final MallMemberAmountMapper mallMemberAmountMapper;
 
     @Override
     @Transactional(rollbackFor = Exception.class)
@@ -102,6 +115,22 @@
 
         if (CollUtil.isEmpty(addOrderDto.getItems())) {
             throw new FebsException("参数错误");
+        }
+
+        int deliverType = ObjectUtil.isEmpty(addOrderDto.getDeliverType()) ? 1 : addOrderDto.getDeliverType();
+        if(2 == deliverType){
+            if(ObjectUtil.isEmpty(addOrderDto.getShopId())){
+                throw new FebsException("请选择门店");
+            }
+            Long shopId = addOrderDto.getShopId();
+            MallShopApply mallShopApply = mallShopApplyMapper.selectById(shopId);
+            if(ObjectUtil.isEmpty(mallShopApply)){
+                throw new FebsException("请选择门店");
+            }
+            if(MallShopApply.APPLY_AGREE != mallShopApply.getStatus()){
+                throw new FebsException("请选择门店");
+            }
+            orderInfo.setShopId(shopId);
         }
 
         this.baseMapper.insert(orderInfo);
@@ -184,9 +213,30 @@
             }
             mallOrderItemMapper.insert(orderItem);
         }
-
+        /**
+         * 使用积分折扣现金
+         */
+        DataDictionaryCustom scoreChangeDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+                DataDictionaryEnum.SCORE_CHANGE.getType(),
+                DataDictionaryEnum.SCORE_CHANGE.getCode()
+        );
+        BigDecimal score = ObjectUtil.isEmpty(addOrderDto.getScore()) ? BigDecimal.ZERO : addOrderDto.getScore();
+        orderInfo.setScoreCnt(score);
+        BigDecimal scoreChange = BigDecimal.ONE;
+        if(ObjectUtil.isNotEmpty(scoreChangeDic)){
+            scoreChange = new BigDecimal(scoreChangeDic.getValue()).abs().setScale(2,BigDecimal.ROUND_DOWN);
+        }
+        //折扣现金
+        BigDecimal scorePercentAmount = score.divide(scoreChange,BigDecimal.ROUND_DOWN).setScale(2,BigDecimal.ROUND_DOWN);
+        orderInfo.setScoreAmount(scorePercentAmount);
         orderInfo.setAmount(total);
-        orderInfo.setCarriage(carriage);
+        if(2 == deliverType){
+            orderInfo.setDeliverType(2);
+            orderInfo.setCarriage(BigDecimal.ZERO);
+        }else{
+            orderInfo.setDeliverType(1);
+            orderInfo.setCarriage(carriage);
+        }
         this.baseMapper.updateById(orderInfo);
 
         agentProducer.sendOrderCancelDelayMsg(orderInfo.getId(), 15 * 60 * 1000L);
@@ -236,91 +286,89 @@
         String rcResult = "";
         switch (payOrderDto.getType()) {
             case "1":
-//                orderInfo.setPayOrderNo(payOrderDto.getPayOrderNo());
-//                orderInfo.setPayImage(payOrderDto.getPayImage());
+                List<MallOrderItem> itemsWx = orderInfo.getItems();
+                if(CollUtil.isEmpty(itemsWx)){
+                    orderInfo.setName("商品");
+                }else{
+                    orderInfo.setName(itemsWx.get(0).getGoodsName());
+                }
+
+                payResultStr = wechatPayService.pay(orderInfo);
+                orderInfo.setPayOrderNo(payResultStr);
                 orderInfo.setPayMethod("微信支付");
-                agentProducer.sendOrderReturn(orderInfo.getId());
+                orderInfo.setPayResult("2");
                 break;
             case "2":
-//                if (StrUtil.isNotBlank(orderInfo.getPayOrderNo())) {
-//                    payResultStr = orderInfo.getPayOrderNo();
-//                } else {
-//                    payResultStr = payService.aliPay(orderInfo);
+                LaKaLaCreateOrderReqDate laKaLaCreateOrderReqDate = new LaKaLaCreateOrderReqDate();
+                //订单编号
+                laKaLaCreateOrderReqDate.setOut_order_no(orderInfo.getOrderNo());
+                //订单金额,分计
+                laKaLaCreateOrderReqDate.setTotal_amount(orderInfo.getAmount().multiply(new BigDecimal(100)).longValue());
+                List<MallOrderItem> itemsLKL = orderInfo.getItems();
+                //商品名称
+                if(CollUtil.isEmpty(itemsLKL)){
+                    laKaLaCreateOrderReqDate.setOrder_info("商品");
+                }else{
+                    laKaLaCreateOrderReqDate.setOrder_info(itemsLKL.get(0).getGoodsName());
+                }
+                payResultStr = laKaLaService.verifyCreateOrder(laKaLaCreateOrderReqDate);
+                JSONObject parseObj = JSONUtil.parseObj(payResultStr);
+                String code = parseObj.get("code").toString();
+                if (!"true".equals(code)) {
+                    throw new FebsException("跳转收银台失败");
+                }
+
+                orderInfo.setPayOrderNo(parseObj.get("payOrderNo").toString());
+                orderInfo.setPayMethod("拉卡拉支付");
+                orderInfo.setPayResult("2");
+//                UnipayDto unipayDto = new UnipayDto();
+//                unipayDto.setAmount(orderInfo.getAmount());
+//                unipayDto.setFrpCode("ALIPAY_H5");
+//                unipayDto.setTradeMerchantNo("777184100385821");
+//                unipayDto.setOrderNo(orderInfo.getOrderNo());
+//                List<MallOrderItem> items = orderInfo.getItems();
+//                if(CollUtil.isEmpty(items)){
+//                    unipayDto.setProductName("商品");
+//                }else{
+//                    unipayDto.setProductName(items.get(0).getGoodsName());
 //                }
-                UnipayDto unipayDto = new UnipayDto();
-//                unipayDto.setAmount(new BigDecimal("0.01"));
-                unipayDto.setAmount(orderInfo.getAmount());
-                unipayDto.setFrpCode("ALIPAY_H5");
-                unipayDto.setTradeMerchantNo("777184100385821");
-                unipayDto.setOrderNo(orderInfo.getOrderNo());
-                List<MallOrderItem> items = orderInfo.getItems();
-                if(CollUtil.isEmpty(items)){
-                    unipayDto.setProductName("商品");
-                }else{
-                    unipayDto.setProductName(items.get(0).getGoodsName());
-                }
-                String unipayStr = unipayService.unipay(unipayDto);
-                if("fail" == unipayStr){
-                    throw new FebsException("支付失败");
-                }else{
-//                    JSONUtil.parseObj(unipayStr);
-                    JSONObject jsonObject = JSONUtil.parseObj(unipayStr);
-                    payResultStr = (String) jsonObject.get("r7_TrxNo");
-                    rcResult = (String) jsonObject.get("rc_Result");
-                }
-                orderInfo.setPayOrderNo(payResultStr);
-                orderInfo.setPayMethod("支付宝支付");
-//                agentProducer.sendOrderReturn(orderInfo.getId());
+//                String unipayStr = unipayService.unipay(unipayDto);
+//                if("fail" == unipayStr){
+//                    throw new FebsException("支付失败");
+//                }else{
+//                    JSONObject jsonObject = JSONUtil.parseObj(unipayStr);
+//                    payResultStr = (String) jsonObject.get("r7_TrxNo");
+//                    rcResult = (String) jsonObject.get("rc_Result");
+//                }
+//                orderInfo.setPayOrderNo(payResultStr);
+//                orderInfo.setPayMethod("支付宝支付");
                 break;
             case "3":
-                payResultStr = balancePay(orderInfo, payOrderDto.getTradePwd(), "balance");
+                payResultStr = balancePayNew(orderInfo, payOrderDto.getTradePwd());
 
                 orderInfo.setPayOrderNo(orderInfo.getOrderNo());
-                orderInfo.setPayMethod("余额支付");
+                orderInfo.setPayMethod("积分支付");
                 orderInfo.setStatus(OrderStatusEnum.WAIT_SHIPPING.getValue());
                 orderInfo.setPayTime(new Date());
                 orderInfo.setPayResult("1");
+                this.baseMapper.updateById(orderInfo);
 
-                boolean hasTc = false;
-                // 静态倍数
-                List<MallOrderItem> orderItems = this.baseMapper.getMallOrderItemByOrderId(orderInfo.getId());
-                if (CollUtil.isNotEmpty(orderItems)) {
-                    for (MallOrderItem orderItem : orderItems) {
-                        MallGoods mallGoods = mallGoodsMapper.selectById(orderItem.getGoodsId());
-                        BigDecimal score = BigDecimal.ZERO;
-                        MallGoodsSku sku = mallGoodsSkuMapper.selectById(orderItem.getSkuId());
-                        if (mallGoods.getIsNormal() == 2) {
-                            hasTc = true;
-                            score = sku.getPresentPrice().multiply(mallGoods.getStaticMulti()).multiply(new BigDecimal(orderItem.getCnt()));
-//                            BigDecimal staticMulti = mallGoods.getStaticMulti() == null ? BigDecimal.ZERO : mallGoods.getStaticMulti();
-//                            score = sku.getPresentPrice().multiply(staticMulti);
-                            // 普通商品也及时结算,不再10天结算
-                        } else {
-                            score = sku.getPresentPrice();
-                        }
 
-                        if (score.compareTo(BigDecimal.ZERO) > 0) {
-                            memberWalletService.add(score, member.getId(), "score");
-                            mallMoneyFlowService.addMoneyFlow(member.getId(), score, MoneyFlowTypeEnum.STATIC_BONUS.getValue(), orderInfo.getOrderNo(), FlowTypeEnum.SCORE.getValue());
-
-                            // 添加业绩
-                            mallAchieveService.add(orderItem.getId());
-                        }
-                    }
-                }
-
-                // 购买套餐后,升级为普通会员
-                if (hasTc) {
-                    MallMember mallMember = memberMapper.selectById(member.getId());
-                    if (AgentLevelEnum.ZERO_LEVEL.name().equals(mallMember.getLevel())) {
-                        mallMember.setLevel(AgentLevelEnum.FIRST_LEVEL.name());
-                        memberMapper.updateById(mallMember);
-                    }
-                }
-
-                mallMoneyFlowService.addMoneyFlow(member.getId(), orderInfo.getAmount().negate(), MoneyFlowTypeEnum.PAY.getValue(), orderInfo.getOrderNo(), FlowTypeEnum.BALANCE.getValue());
-                agentProducer.sendAutoLevelUpMsg(member.getId());
-                agentProducer.sendOrderReturn(orderInfo.getId());
+//                commonService.changeWallet(orderInfo.getId(), FlowTypeEnum.BALANCE.getValue());
+                /**
+                 * 插入一条待处理记录
+                 * mq处理之后,更新状态
+                 */
+//                MallMqRecord mallMqRecord = new MallMqRecord();
+//                mallMqRecord.setOrderId(orderInfo.getId());
+//                mallMqRecord.setState(2);
+//                mallMqRecord.setRetryTimes(2);
+//                mallMqRecord.setCreateTime(orderInfo.getPayTime());
+//                mallMqRecordMapper.insert(mallMqRecord);
+//                //发送补贴消息
+//                agentProducer.sendPerkMoneyMsg(orderInfo.getId());
+//                //发送代理自动升级消息
+//                agentProducer.sendAutoLevelUpMsg(member.getId());
                 break;
             case "4":
                 if (orderInfo.getOrderType() != 2) {
@@ -337,28 +385,6 @@
                 mallMoneyFlowService.addMoneyFlow(member.getId(), orderInfo.getAmount().negate(), MoneyFlowTypeEnum.PAY.getValue(), orderInfo.getOrderNo(),  FlowTypeEnum.PRIZE_SCORE.getValue());
                 break;
             case "5":
-//                AgreementSignDto agreementSignDto = new AgreementSignDto();
-//                agreementSignDto.setOrderNo(orderInfo.getOrderNo());
-//                agreementSignDto.setSmsCode(payOrderDto.getSmsCode());
-//                String agreementSignStr = unipayService.agreementSign(agreementSignDto);
-//                if("fail".equals(agreementSignStr)){
-//                    throw new FebsException("支付失败");
-//                }else{
-//                    JSONObject jsonObject = JSONUtil.parseObj(agreementSignStr);
-//                    payResultStr = (String) jsonObject.get("biz_code");
-//                    String signData = (String) jsonObject.get("data");
-//                    String signBizMsg = (String) jsonObject.get("biz_msg");
-//
-//                    JSONObject signDatajsonObject = JSONUtil.parseObj(signData);
-//                    String err_msg = (String) signDatajsonObject.get("err_msg");
-//                    if(!"JS000000".equals(payResultStr)){
-//                        throw new FebsException(signBizMsg);
-//                    }
-//                    if(ObjectUtil.isNotNull(signDatajsonObject.get("err_code"))){
-//                        throw new FebsException(err_msg);
-//                    }
-//                }
-                
                 AgreementPayDto agreementPayDto = new AgreementPayDto();
                 agreementPayDto.setOrderNo(orderInfo.getOrderNo());
 
@@ -441,10 +467,33 @@
             throw new FebsException("支付密码错误");
         }
 
-        int reduce = memberWalletService.reduce(orderInfo.getAmount().add(orderInfo.getCarriage()), mallMember.getId(), field);
+        int reduce = memberWalletService.reduce(orderInfo.getAmount().subtract(orderInfo.getScoreAmount()).add(orderInfo.getCarriage()), mallMember.getId(), field);
         if (reduce == 2) {
             throw new FebsException("余额不足");
         }
+        return orderInfo.getOrderNo();
+    }
+    private String balancePayNew(MallOrderInfo orderInfo, String tradePwd) {
+        if (StrUtil.isBlank(tradePwd)) {
+            throw new FebsException("支付密码错误");
+        }
+
+        MallMember mallMember = memberMapper.selectById(orderInfo.getMemberId());
+        if (StrUtil.isBlank(mallMember.getTradePassword())) {
+            throw new FebsException("未设置支付密码");
+        }
+
+        if (!SecureUtil.md5(tradePwd).equals(mallMember.getTradePassword())) {
+            throw new FebsException("支付密码错误");
+        }
+        MallMemberAmount mallMemberAmount = mallMemberAmountMapper.selectByMemberId(mallMember.getId());
+
+        BigDecimal subtract = mallMemberAmount.getGsd().subtract(orderInfo.getAmount());
+        if(BigDecimal.ZERO.compareTo(subtract) > 0){
+            throw new FebsException("积分不足");
+        }
+        mallMemberAmount.setGsd(subtract);
+        mallMemberAmountMapper.updateGsdById(mallMemberAmount);
         return orderInfo.getOrderNo();
     }
 
@@ -468,7 +517,8 @@
 
         OrderDetailVo orderDetailVo = MallOrderInfoConversion.INSTANCE.entityToDetailVo(orderInfo);
 
-        if (orderInfo.getStatus() == OrderStatusEnum.WAIT_FINISH.getValue()) {
+        Integer deliverType = (ObjectUtil.isEmpty(orderInfo.getDeliverType()) ? new Integer(0):orderInfo.getDeliverType());
+        if (orderInfo.getStatus() == OrderStatusEnum.WAIT_FINISH.getValue() && 2 != deliverType) {
             MallExpressInfo expressInfo = expressInfoMapper.selectByOrderId(orderInfo.getId());
             orderDetailVo.setExpressNo(expressInfo.getExpressNo());
             orderDetailVo.setExpressCom(expressInfo.getExpressCom());
@@ -485,6 +535,20 @@
 
             long remainTime = DateUtil.between(new Date(), endTime, DateUnit.SECOND, false);
             orderDetailVo.setRemainTime(remainTime);
+        }
+        if(2 == deliverType){
+            MallShopApply mallShopApply = mallShopApplyMapper.selectById(orderInfo.getShopId());
+            if(ObjectUtil.isNotEmpty(mallShopApply)){
+                ApiShopApplyVo apiShopApplyVo = new ApiShopApplyVo();
+                apiShopApplyVo.setName(mallShopApply.getName());
+                apiShopApplyVo.setPhone(mallShopApply.getPhone());
+                apiShopApplyVo.setSaleArea(mallShopApply.getSaleArea());
+                apiShopApplyVo.setLatitude(mallShopApply.getLatitude());
+                apiShopApplyVo.setLongitude(mallShopApply.getLongitude());
+                apiShopApplyVo.setShopName(mallShopApply.getShopName());
+                apiShopApplyVo.setAddress(mallShopApply.getAddress());
+                orderDetailVo.setApiShopApplyVo(apiShopApplyVo);
+            }
         }
         return orderDetailVo;
     }
@@ -671,4 +735,124 @@
         }
     }
 
+    @Override
+    public FebsResponse judgeCreateOrder(AddOrderDto addOrderDto) {
+        Long memberId = LoginUserUtil.getLoginUser().getId();
+        if (CollUtil.isEmpty(addOrderDto.getItems())) {
+            throw new FebsException("请选择购买商品");
+        }
+
+        boolean hasTc = false;
+        //总的折扣积分数量
+        BigDecimal total = BigDecimal.ZERO;
+        for (AddOrderItemDto item : addOrderDto.getItems()) {
+            MallGoodsSku sku = mallGoodsSkuMapper.selectSkuInfoById(item.getSkuId());
+            if(ObjectUtil.isEmpty(sku)){
+                throw new FebsException("商品已更新,请重新下单");
+            }
+            MallGoods mallGoods = mallGoodsMapper.selectById(sku.getGoodsId());
+            if(ObjectUtil.isEmpty(mallGoods)){
+                throw new FebsException("商品已更新,请重新下单");
+            }
+            /**
+             * 贡献点判断
+             */
+            if (mallGoods.getIsNormal() == 2) {
+                hasTc = true;
+            }
+                /*
+                获取单个商品的折扣积分数量
+                    = 现价 * 数量 * 折扣现金比例
+                 */
+            BigDecimal scorePercent = new BigDecimal(mallGoods.getScorePercent()).multiply(new BigDecimal(0.01));
+            BigDecimal amount = sku.getPresentPrice().multiply(BigDecimal.valueOf(item.getCnt())).multiply(scorePercent);
+            total = total.add(amount);
+        }
+
+        BigDecimal score = ObjectUtil.isEmpty(addOrderDto.getScore()) ? BigDecimal.ZERO : addOrderDto.getScore();
+
+        MallMemberWallet mallMemberWallet = mallMemberWalletMapper.selectWalletByMemberId(memberId);
+        BigDecimal prizeScore = mallMemberWallet.getPrizeScore();
+        if(prizeScore.compareTo(score) < 0){
+            throw new FebsException("积分不足");
+        }
+        /**
+         * 使用积分折扣现金
+         */
+        DataDictionaryCustom scoreChangeDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+                DataDictionaryEnum.SCORE_CHANGE.getType(),
+                DataDictionaryEnum.SCORE_CHANGE.getCode()
+        );
+
+        //最大折扣金额对应需要的总积分数目
+        BigDecimal scorePercentMaxAmount = total;
+        BigDecimal scoreChange = BigDecimal.ONE;
+        if(ObjectUtil.isNotEmpty(scoreChangeDic)){
+            scoreChange = new BigDecimal(scoreChangeDic.getValue()).abs().setScale(2,BigDecimal.ROUND_DOWN);
+        }
+        scorePercentMaxAmount = scorePercentMaxAmount.multiply(scoreChange).setScale(2,BigDecimal.ROUND_DOWN);
+        if(scorePercentMaxAmount.compareTo(score) < 0){
+            throw new FebsException("最多可使用"+scorePercentMaxAmount+"积分");
+        }
+
+        if(hasTc){
+            //系统设置的个人贡献点最大值
+            DataDictionaryCustom starGetDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+                    DataDictionaryEnum.STAR_GET.getType(),
+                    DataDictionaryEnum.STAR_GET.getCode());
+            if(ObjectUtil.isNotEmpty(starGetDic)){
+                String starGetStr = StrUtil.isEmpty(starGetDic.getValue()) ? "0" : starGetDic.getValue();
+                BigDecimal starGet = new BigDecimal(starGetStr);
+                BigDecimal star = new BigDecimal(mallMemberWallet.getStar());
+                if(starGet.compareTo(BigDecimal.ZERO) != 0 && starGet.compareTo(star) <= 0){
+
+                    return new FebsResponse().success().message("购买套餐不会获得贡献点");
+//                    throw new FebsException("无法购买套餐");
+                }
+            }
+        }
+        return new FebsResponse().success();
+    }
+
+    @Override
+    public ApiScoreSetVo myScoreSet() {
+        ApiScoreSetVo apiScoreSetVo = new ApiScoreSetVo();
+        DataDictionaryCustom scorePercentDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+                DataDictionaryEnum.SCORE_PERCENT.getType(),
+                DataDictionaryEnum.SCORE_PERCENT.getCode()
+        );
+        DataDictionaryCustom scoreChangeDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
+                DataDictionaryEnum.SCORE_CHANGE.getType(),
+                DataDictionaryEnum.SCORE_CHANGE.getCode()
+        );
+        apiScoreSetVo.setScorePercent(new BigDecimal(scorePercentDic.getValue()).multiply(BigDecimal.valueOf(0.01)).setScale(2,BigDecimal.ROUND_DOWN));
+        apiScoreSetVo.setScoreChange(new BigDecimal(scoreChangeDic.getValue()).setScale(2,BigDecimal.ROUND_DOWN));
+        return apiScoreSetVo;
+    }
+
+    @Override
+    public void fcmPayBuyTimeTTLMsg(Long id) {
+        /**
+         * 卖方
+         * 1:冻结账户
+         */
+        MallProductSellRecord mallProductSellRecord = mallProductSellRecordMapper.selectById(id);
+        if(ObjectUtil.isEmpty(mallProductSellRecord)){
+            return;
+        }
+        if(ProductEnum.PRODUCT_MATE_STATE_PAY.getValue() != mallProductSellRecord.getState()){
+            return;
+        }
+        MallProductSell mallProductSell = mallProductSellMapper.selectById(mallProductSellRecord.getSellId());
+        if(ObjectUtil.isEmpty(mallProductSell)){
+            return;
+        }
+        MallMember mallMember = memberMapper.selectById(mallProductSell.getMemberId());
+        if(ObjectUtil.isEmpty(mallMember)){
+            return;
+        }
+        mallMember.setIsFrozen(ProductEnum.MEMBER_FROZEN.getValue());
+        memberMapper.updateById(mallMember);
+    }
+
 }

--
Gitblit v1.9.1