From ab6603d889f482459c1812e52ce2c5c04fe8e3e7 Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Thu, 08 Sep 2022 09:53:10 +0800
Subject: [PATCH] 20220902

---
 src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallTeamLeaderServiceImpl.java |  171 ++++++++++++++++++++++++++++++++++++++------------------
 1 files changed, 116 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..d127eb4 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,13 @@
     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;
 
     @Override
     @Transactional
@@ -253,7 +259,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 +279,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 +304,81 @@
             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);
+                //更新退款订单
+                mallRefundEntity.setState(1);
+                mallRefundEntity.setUpdatedTime(DateUtil.date());
+                mallRefundMapper.updateById(mallRefundEntity);
+                mallMoneyFlowService.addMoneyFlow(mallOrderInfo.getMemberId(), refundAmount, MoneyFlowTypeEnum.REFUND.getValue(), mallOrderInfo.getOrderNo(), FlowTypeEnum.BALANCE.getValue());
 
-        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());
-
-            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);
+                //更新退款订单
+                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 +393,37 @@
         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);
+        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