From c2a0a337498445683f81e33597bf694e0dc9fb68 Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Thu, 15 Sep 2022 17:55:02 +0800
Subject: [PATCH] 20220902

---
 src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallTeamLeaderServiceImpl.java |  205 +++++++++++++++++++++++++++++++++++++-------------
 1 files changed, 150 insertions(+), 55 deletions(-)

diff --git a/src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallTeamLeaderServiceImpl.java b/src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallTeamLeaderServiceImpl.java
index 453bf97..52a049b 100644
--- a/src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallTeamLeaderServiceImpl.java
+++ b/src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallTeamLeaderServiceImpl.java
@@ -6,18 +6,17 @@
 import cc.mrbird.febs.common.utils.LoginUserUtil;
 import cc.mrbird.febs.common.utils.ShareCodeUtil;
 import cc.mrbird.febs.common.utils.SpringContextHolder;
+import cc.mrbird.febs.mall.conversion.MallLeaderAchieveConversion;
 import cc.mrbird.febs.mall.conversion.MallOrderInfoConversion;
 import cc.mrbird.febs.mall.conversion.MallTeamLeaderConversion;
 import cc.mrbird.febs.mall.dto.*;
 import cc.mrbird.febs.mall.entity.*;
 import cc.mrbird.febs.mall.mapper.*;
 import cc.mrbird.febs.mall.service.IAdminMallOrderService;
+import cc.mrbird.febs.mall.service.IApiMallMemberWalletService;
 import cc.mrbird.febs.mall.service.IApiMallTeamLeaderService;
 import cc.mrbird.febs.mall.service.IMallMoneyFlowService;
-import cc.mrbird.febs.mall.vo.ApiLeaderInfoVo;
-import cc.mrbird.febs.mall.vo.ApiLeaderListVo;
-import cc.mrbird.febs.mall.vo.ApiMallleaderStateVo;
-import cc.mrbird.febs.mall.vo.OrderListVo;
+import cc.mrbird.febs.mall.vo.*;
 import cc.mrbird.febs.pay.model.OrderStateDto;
 import cc.mrbird.febs.pay.service.IXcxPayService;
 import cc.mrbird.febs.pay.util.WechatConfigure;
@@ -56,6 +55,15 @@
     private final DataDictionaryCustomMapper dataDictionaryCustomMapper;
     private final MallOrderItemMapper mallOrderItemMapper;
     private final MallRefundMapper mallRefundMapper;
+    @Autowired
+    private WeixinServiceUtil weixinServiceUtil;
+    private final XcxProperties xcxProperties = SpringContextHolder.getBean(XcxProperties.class);
+    private final IMallMoneyFlowService mallMoneyFlowService;
+    private final IApiMallMemberWalletService memberWalletService;
+    private final MallLeaderAchieveMapper mallLeaderAchieveMapper;
+    private final MallMoneyFlowMapper mallMoneyFlowMapper;
+    private final MallGoodsMapper mallGoodsMapper;
+    private final MallGoodsSkuMapper mallGoodsSkuMapper;
 
     @Override
     @Transactional
@@ -74,6 +82,9 @@
         mallTeamLeader.setMemberId(memberId);
         mallTeamLeader.setState(MallTeamLeader.STATE_ING);
         mallTeamLeader.setUniqueCode(member.getInviteId());
+        //申请团长默认关闭返利,返利比例为0
+        mallTeamLeader.setProfitSwitch(2);
+        mallTeamLeader.setBonusPercent("0");
         this.baseMapper.insert(mallTeamLeader);
         return new FebsResponse().success().message("申请成功");
     }
@@ -160,11 +171,12 @@
             orderStateDto.setOrderNo(mallOrderInfo.getOrderNo());
             String productNames = getProductNames(mallOrderInfo.getMemberId(), mallOrderInfo.getId());
             orderStateDto.setGoodsName(StrUtil.sub(productNames,0,10)+"...");
-            orderStateDto.setOrderState("已送达");
+            orderStateDto.setOrderState("待自提");
             orderStateDto.setTakeCode(mallOrderInfo.getTakeCode());
             String takeUniqueCode = mallOrderInfo.getTakeUniqueCode();
             MallTeamLeader mallTeamLeader = mallTeamLeaderMapper.selectLeaderByUniqueCode(takeUniqueCode);
             orderStateDto.setAddressArea(StrUtil.sub(mallTeamLeader.getAddressArea(),0,10)+"...");
+            orderStateDto.setDetailAddress(StrUtil.sub(mallTeamLeader.getDetailAddress(),0,10)+"...");
             orderStateDto.setOpenId(mallMemberMapper.selectById(mallOrderInfo.getMemberId()).getOpenId());
             DataDictionaryCustom dataDictionaryCustom = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(DataDictionaryEnum.WX_TEMPLATE_ID_ONE.getType(), DataDictionaryEnum.WX_TEMPLATE_ID_ONE.getCode());
             orderStateDto.setTemplateId(dataDictionaryCustom.getValue());
@@ -253,7 +265,9 @@
         MallMember loginUser = LoginUserUtil.getLoginUser();
         Long memberId = loginUser.getId();
         MallMember mallMember = mallMemberMapper.selectById(memberId);
-
+        if(ObjectUtil.isEmpty(mallMember)){
+            return new FebsResponse().success();
+        }
         log.info(mallMember.getInviteId());
         MallTeamLeader mallTeamLeader = this.baseMapper.selectLeaderByUniqueCode(mallMember.getInviteId());
         if(ObjectUtil.isEmpty(mallTeamLeader)){
@@ -271,13 +285,6 @@
         result.put("order", orderCnt);
         return new FebsResponse().success().data(result);
     }
-
-
-
-    @Autowired
-    private WeixinServiceUtil weixinServiceUtil;
-    private final XcxProperties xcxProperties = SpringContextHolder.getBean(XcxProperties.class);
-    private final IMallMoneyFlowService mallMoneyFlowService;
 
     @Override
     @Transactional
@@ -303,54 +310,102 @@
             mallRefundEntity.setState(2);
             mallRefundEntity.setUpdatedTime(DateUtil.date());
             mallRefundMapper.updateById(mallRefundEntity);
-        }
-        //退款订单编号
-        String orderNo = mallOrderInfo.getOrderNo();
-        //退款退款编号
-        String refundNo = mallRefundEntity.getRefundNo();
-        //退款订单金额
-        BigDecimal orderAmount = mallOrderInfo.getAmount();
-        BigDecimal aa = new BigDecimal(100);
-        int orderMoney = orderAmount.multiply(aa).intValue();
+            return new FebsResponse().success().message("操作成功");
+        }else{//退款订单编号
+            String orderNo = mallOrderInfo.getOrderNo();
+            //退款退款编号
+            String refundNo = mallRefundEntity.getRefundNo();
+            //退款订单金额
+            BigDecimal orderAmount = mallOrderInfo.getAmount();
+            BigDecimal aa = new BigDecimal(100);
+            int orderMoney = orderAmount.multiply(aa).intValue();
 
-        //退款退款金额
-        BigDecimal refundAmount = mallRefundEntity.getAmount();
-        BigDecimal bb = new BigDecimal(100);
-        int refundMoney = refundAmount.multiply(bb).intValue();
+            //退款退款金额
+            BigDecimal refundAmount = mallRefundEntity.getAmount();
+            BigDecimal bb = new BigDecimal(100);
+            int refundMoney = refundAmount.multiply(bb).intValue();
 
-        Boolean flag = false;
-        Boolean debug = xcxProperties.getDebug();
-        if (debug) {
-            boolean b = weixinServiceUtil.comRefund(orderNo, refundNo, 1, 1, null);
-            flag = b;
-        } else {
-            log.info("开始调用退款接口。。。退款编号为{}", refundNo);
-            boolean b = weixinServiceUtil.comRefund(orderNo, refundNo, orderMoney, refundMoney, null);
-            flag = b;
-        }
+            //余额支付退款
+            if(mallRefundEntity.getType() == 3){
+                //更新订单详情
+                mallOrderItem.setState(3);
+                mallOrderItemMapper.updateById(mallOrderItem);
+                //更新库存信息
+                MallGoods mallGoods = mallGoodsMapper.selectById(mallOrderItem.getGoodsId());
+                mallGoods.setStock(mallGoods.getStock() + mallOrderItem.getCnt());
+                mallGoods.setVolume(mallGoods.getVolume() - mallOrderItem.getCnt());
+                mallGoodsMapper.updateById(mallGoods);
 
-        if(flag){
-            //更新订单详情
-            mallOrderItem.setState(3);
-            mallOrderItemMapper.updateById(mallOrderItem);
-            //更新退款订单
-            mallRefundEntity.setState(1);
-            mallRefundEntity.setUpdatedTime(DateUtil.date());
-            mallRefundMapper.updateById(mallRefundEntity);
-            mallMoneyFlowService.addMoneyFlow(mallOrderInfo.getMemberId(), refundAmount, MoneyFlowTypeEnum.REFUND.getValue(), mallOrderInfo.getOrderNo(), FlowTypeEnum.BALANCE.getValue());
+                MallGoodsSku mallGoodsSku = mallGoodsSkuMapper.selectById(mallOrderItem.getSkuId());
+                mallGoodsSku.setStock(mallGoodsSku.getStock() + mallOrderItem.getCnt());
+                mallGoodsSku.setSkuVolume(mallGoodsSku.getSkuVolume() - mallOrderItem.getCnt());
+                mallGoodsSkuMapper.updateById(mallGoodsSku);
+                //更新退款订单
+                mallRefundEntity.setState(1);
+                mallRefundEntity.setUpdatedTime(DateUtil.date());
+                mallRefundMapper.updateById(mallRefundEntity);
+                mallMoneyFlowService.addMoneyFlow(mallOrderInfo.getMemberId(), refundAmount, MoneyFlowTypeEnum.REFUND.getValue(), mallOrderInfo.getOrderNo(), FlowTypeEnum.BALANCE.getValue());
 
-            List<MallOrderItem> mallOrderItemList = mallOrderItemMapper.selectListByStateAndOrderId(1,orderId);
-            if(CollUtil.isEmpty(mallOrderItemList)){
-                MallOrderInfo mallOrderRefund = mallOrderInfoMapper.selectById(orderId);
-                mallOrderRefund.setStatus(6);
-                mallOrderInfoMapper.updateById(mallOrderRefund);
+                List<MallOrderItem> mallOrderItemList = mallOrderItemMapper.selectListByNotInStateAndOrderId(3,orderId);
+                if(CollUtil.isEmpty(mallOrderItemList)){
+                    MallOrderInfo mallOrderRefund = mallOrderInfoMapper.selectById(orderId);
+                    mallOrderRefund.setStatus(6);
+                    mallOrderInfoMapper.updateById(mallOrderRefund);
+                }
+                memberWalletService.add(refundAmount, mallOrderInfo.getMemberId(), "balance");
+                return new FebsResponse().success().message("退款成功");
             }
-        }else{
-            mallRefundEntity.setState(2);
-            mallRefundMapper.updateById(mallRefundEntity);
-            return new FebsResponse().fail().message("退款失败,请联系客服人员");
+
+            Boolean flag = false;
+            Boolean debug = xcxProperties.getDebug();
+            if (debug) {
+                boolean b = weixinServiceUtil.comRefund(orderNo, refundNo, 1, 1, null);
+                flag = b;
+            } else {
+                log.info("开始调用退款接口。。。退款编号为{}", refundNo);
+                boolean b = weixinServiceUtil.comRefund(orderNo, refundNo, orderMoney, refundMoney, null);
+                flag = b;
+            }
+
+            if(flag){
+                //更新订单详情
+                mallOrderItem.setState(3);
+                mallOrderItemMapper.updateById(mallOrderItem);
+                //更新库存信息
+                MallGoods mallGoods = mallGoodsMapper.selectById(mallOrderItem.getGoodsId());
+                mallGoods.setStock(mallGoods.getStock() + mallOrderItem.getCnt());
+                mallGoods.setVolume(mallGoods.getVolume() - mallOrderItem.getCnt());
+                mallGoodsMapper.updateById(mallGoods);
+
+                MallGoodsSku mallGoodsSku = mallGoodsSkuMapper.selectById(mallOrderItem.getSkuId());
+                mallGoodsSku.setStock(mallGoodsSku.getStock() + mallOrderItem.getCnt());
+                mallGoodsSku.setSkuVolume(mallGoodsSku.getSkuVolume() - mallOrderItem.getCnt());
+                mallGoodsSkuMapper.updateById(mallGoodsSku);
+
+                //更新退款订单
+                mallRefundEntity.setState(1);
+                mallRefundEntity.setUpdatedTime(DateUtil.date());
+                mallRefundMapper.updateById(mallRefundEntity);
+                mallMoneyFlowService.addMoneyFlow(mallOrderInfo.getMemberId(), refundAmount, MoneyFlowTypeEnum.REFUND.getValue(), mallOrderInfo.getOrderNo(), FlowTypeEnum.BALANCE.getValue());
+
+                List<MallOrderItem> mallOrderItemList = mallOrderItemMapper.selectListByNotInStateAndOrderId(3,orderId);
+                if(CollUtil.isEmpty(mallOrderItemList)){
+                    MallOrderInfo mallOrderRefund = mallOrderInfoMapper.selectById(orderId);
+                    mallOrderRefund.setStatus(6);
+                    mallOrderInfoMapper.updateById(mallOrderRefund);
+                }
+            }else{
+
+                //更新订单详情
+                mallOrderItem.setState(1);
+                mallOrderItemMapper.updateById(mallOrderItem);
+
+                mallRefundEntity.setState(2);
+                mallRefundMapper.updateById(mallRefundEntity);
+                return new FebsResponse().fail().message("退款失败,请联系客服人员");
+            }
+            return new FebsResponse().success().message("退款成功");
         }
-        return new FebsResponse().success().message("退款成功");
     }
 
     @Override
@@ -365,4 +420,44 @@
         return new FebsResponse().success().data(mallRefundEntities.get(0));
     }
 
+    @Override
+    public FebsResponse leaderProfit() {
+        MallMember loginUser = LoginUserUtil.getLoginUser();
+        ApiLeaderProfitVo apiLeaderProfitVo = new ApiLeaderProfitVo();
+
+        BigDecimal totalProfit = mallMoneyFlowMapper.selectAmountByFlowtypeAndType(loginUser.getId(),FlowTypeEnum.BALANCE.getValue(),MoneyFlowTypeEnum.LEADERACHIEVE.getValue(),null,null,null);
+        apiLeaderProfitVo.setTotalProfit(totalProfit);
+        BigDecimal todayProfit = mallMoneyFlowMapper.selectAmountByFlowtypeAndType(loginUser.getId(),FlowTypeEnum.BALANCE.getValue(),
+                MoneyFlowTypeEnum.LEADERACHIEVE.getValue(),
+                null,DateUtil.date(),
+                null);
+        apiLeaderProfitVo.setTodayProfit(todayProfit);
+
+        BigDecimal monthProfit = mallMoneyFlowMapper.selectAmountByFlowtypeAndType(loginUser.getId(),FlowTypeEnum.BALANCE.getValue(),
+                MoneyFlowTypeEnum.LEADERACHIEVE.getValue(),
+                null,null,
+                DateUtil.date());
+        apiLeaderProfitVo.setMonthProfit(monthProfit);
+        String inviteId = loginUser.getInviteId();
+        MallTeamLeader mallTeamLeader = mallTeamLeaderMapper.selectLeaderByUniqueCode(inviteId);
+        Integer profitSwitch = mallTeamLeader.getProfitSwitch() == null ? 2:mallTeamLeader.getProfitSwitch();
+        if(2 == profitSwitch){
+            apiLeaderProfitVo.setWaitProfit(BigDecimal.ZERO);
+        }else{
+            BigDecimal waitProfit = mallLeaderAchieveMapper.selectProfitByStateAndDateTimeAndUniqueCode(1,null,loginUser.getInviteId()).setScale(2,BigDecimal.ROUND_DOWN);
+            apiLeaderProfitVo.setWaitProfit(waitProfit);
+        }
+
+        return new FebsResponse().success().data(apiLeaderProfitVo);
+    }
+
+    @Override
+    public List<ApiOrderProfitVo> findLeaderProfitListInPage(ApiOrderProfitDto apiOrderProfitDto) {
+        MallMember member = LoginUserUtil.getLoginUser();
+        IPage<MallLeaderAchieve> page = new Page<>(apiOrderProfitDto.getPageNum(), apiOrderProfitDto.getPageSize());
+        apiOrderProfitDto.setInvitedId(member.getInviteId());
+        IPage<MallLeaderAchieve> mallLeaderAchieves = mallLeaderAchieveMapper.selectApiLeaderProfitListInPage(page, apiOrderProfitDto);
+        return MallLeaderAchieveConversion.INSTANCE.entitysToVos(mallLeaderAchieves.getRecords());
+    }
+
 }

--
Gitblit v1.9.1