From 3d83fe59399df5f7c80749841b8d26851c016c18 Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Mon, 05 Sep 2022 16:16:41 +0800
Subject: [PATCH] 20220902

---
 src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallTeamLeaderServiceImpl.java |  151 ++++++++++++++++++++++++++++++++++++--------------
 1 files changed, 108 insertions(+), 43 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 929f6f4..43b641c 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
@@ -12,17 +12,16 @@
 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;
 import cc.mrbird.febs.pay.util.WeixinServiceUtil;
 import cn.hutool.core.collection.CollUtil;
+import cn.hutool.core.date.DateUtil;
 import cn.hutool.core.util.ObjectUtil;
 import cn.hutool.core.util.StrUtil;
 import com.baomidou.mybatisplus.core.metadata.IPage;
@@ -55,6 +54,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
@@ -271,19 +277,13 @@
         return new FebsResponse().success().data(result);
     }
 
-
-
-    @Autowired
-    private WeixinServiceUtil weixinServiceUtil;
-    private final XcxProperties xcxProperties = SpringContextHolder.getBean(XcxProperties.class);
-    private final IMallMoneyFlowService mallMoneyFlowService;
-
     @Override
     @Transactional
     public FebsResponse leaderRefundOrder(ApiLeaderRefundOrderDto apiLeaderRefundOrderDto) {
         //获取退款订单信息
         Long orderId = apiLeaderRefundOrderDto.getOrderId();
         Long itemId = apiLeaderRefundOrderDto.getItemId();
+
         MallOrderInfo mallOrderInfo = mallOrderInfoMapper.selectById(orderId);
         MallOrderItem mallOrderItem = mallOrderItemMapper.selectById(itemId);
         List<MallRefundEntity> mallRefundEntities = mallRefundMapper.selectByItemIdAndOrderIdAndState(itemId, orderId, 3);
@@ -291,45 +291,86 @@
             return new FebsResponse().fail().message("退款失败,请联系客服人员");
         }
         MallRefundEntity mallRefundEntity = mallRefundEntities.get(0);
-        //退款订单编号
-        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();
-
-        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){
+        Integer agreeState = apiLeaderRefundOrderDto.getAgreeState() == null? 2:apiLeaderRefundOrderDto.getAgreeState();
+        if(2 == agreeState){
             //更新订单详情
-            mallOrderItem.setState(3);
+            mallOrderItem.setState(1);
             mallOrderItemMapper.updateById(mallOrderItem);
             //更新退款订单
-            mallRefundEntity.setState(1);
-            mallRefundMapper.updateById(mallRefundEntity);
-            mallMoneyFlowService.addMoneyFlow(mallOrderInfo.getMemberId(), refundAmount, MoneyFlowTypeEnum.REFUND.getValue(), mallOrderInfo.getOrderNo(), FlowTypeEnum.BALANCE.getValue());
-        }else{
             mallRefundEntity.setState(2);
+            mallRefundEntity.setUpdatedTime(DateUtil.date());
             mallRefundMapper.updateById(mallRefundEntity);
-            return new FebsResponse().fail().message("退款失败,请联系客服人员");
+            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();
+
+            //余额支付退款
+            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());
+
+                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("退款成功");
+            }
+
+            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{
+                mallRefundEntity.setState(2);
+                mallRefundMapper.updateById(mallRefundEntity);
+                return new FebsResponse().fail().message("退款失败,请联系客服人员");
+            }
+            return new FebsResponse().success().message("退款成功");
         }
-        return new FebsResponse().success().message("退款成功");
     }
 
     @Override
@@ -344,4 +385,28 @@
         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);
+    }
+
 }

--
Gitblit v1.9.1