From 423e9bfb73d7f55156eb4996a13911972b1fb665 Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Wed, 07 Sep 2022 15:17:22 +0800
Subject: [PATCH] 20220902

---
 src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallOrderInfoServiceImpl.java |  293 +++++++++++++++++++++++++++++++++++++--------------------
 1 files changed, 189 insertions(+), 104 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 616e4c3..3b7b6ca 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
@@ -74,6 +74,8 @@
     private final MallTeamLeaderMapper mallTeamLeaderMapper;
     private final MallMemberMapper mallMemberMapper;
     private final DataDictionaryCustomMapper dataDictionaryCustomMapper;
+    private final MallLeaderAchieveMapper mallLeaderAchieveMapper;
+    private final IApiMallTeamLeaderService iApiMallTeamLeaderService;
 
     @Override
     @Transactional(rollbackFor = Exception.class)
@@ -82,6 +84,11 @@
         String takeUniqueCode = addOrderDto.getTakeUniqueCode();
         if(StrUtil.isEmpty(takeUniqueCode)){
             throw new FebsException("请选择自提点");
+        }
+
+        MallTeamLeader mallTeamLeader = mallTeamLeaderMapper.selectLeaderByUniqueCode(takeUniqueCode);
+        if(ObjectUtil.isEmpty(mallTeamLeader)){
+            throw new FebsException("请重新选择团长");
         }
 
         String orderNo = MallUtils.getOrderNum();
@@ -127,6 +134,7 @@
                 orderItem.setStyleName(mallGoods.getGoodsName());
                 orderItem.setSkuName(mallGoods.getGoodsName());
                 orderItem.setSkuImage(mallGoods.getThumb());
+                orderItem.setState(1);
 
                 total = total.add(amount);
             } else {
@@ -161,6 +169,7 @@
                 orderItem.setGoodsId(sku.getGoodsId());
                 orderItem.setGoodsName(sku.getGoodsName());
                 orderItem.setSkuId(sku.getId());
+                orderItem.setState(1);
                 orderItem.setStyleName(sku.getStyleName());
                 orderItem.setSkuName(sku.getSkuName());
                 orderItem.setSkuImage(sku.getSkuImage());
@@ -180,9 +189,13 @@
             }
             mallOrderItemMapper.insert(orderItem);
         }
-
+        //配送费
+        BigDecimal delivaryAmount = addOrderDto.getDeliveryAmount() == null ? BigDecimal.ZERO : addOrderDto.getDeliveryAmount();
+        if(BigDecimal.ZERO.compareTo(delivaryAmount) < 0 && 1 == addOrderDto.getIsHome()){
+            total = total.add(delivaryAmount);
+            orderInfo.setCarriage(delivaryAmount);
+        }
         orderInfo.setAmount(total);
-        orderInfo.setCarriage(carriage);
 
         MallAddressInfo address = mallAddressInfoMapper.selectAddressInfoByMemberIdAndId(member.getId(), addOrderDto.getAddressId());
         orderInfo.setName(address.getName());
@@ -220,6 +233,23 @@
         orderInfo.setStatus(OrderStatusEnum.CANCEL.getValue());
         orderInfo.setCancelType(MallOrderInfo.CANCEL_BY_SELF);
         this.baseMapper.updateById(orderInfo);
+        List<MallOrderItem> mallOrderItemList = mallOrderItemMapper.selectListByOrderId(id);
+        if(CollUtil.isNotEmpty(mallOrderItemList)){
+            for(MallOrderItem mallOrderItem : mallOrderItemList){
+                Long goodsId = mallOrderItem.getGoodsId();
+                Long skuId = mallOrderItem.getSkuId();
+                Integer cnt = mallOrderItem.getCnt();
+                MallGoods mallGoods = mallGoodsMapper.selectById(goodsId);
+                mallGoods.setVolume(mallGoods.getVolume() - cnt);
+                mallGoods.setStock(mallGoods.getStock() + cnt);
+                mallGoodsMapper.updateById(mallGoods);
+
+                MallGoodsSku mallGoodsSku = mallGoodsSkuMapper.selectById(skuId);
+                mallGoodsSku.setSkuVolume(mallGoodsSku.getSkuVolume() - cnt);
+                mallGoodsSku.setStock(mallGoodsSku.getStock() + cnt);
+                mallGoodsSkuMapper.updateById(mallGoodsSku);
+            }
+        }
     }
 
     /**
@@ -288,7 +318,7 @@
                 wxResultStr = JSONUtil.toJsonStr(brandWCPayRequestData);
                 payResultStr = brandWCPayRequestData.getPrepay_id();
                 orderInfo.setPayMethod("微信支付");
-                agentProducer.sendOrderReturn(orderInfo.getId());
+//                agentProducer.sendOrderReturn(orderInfo.getId());
                 break;
             case "2":
                 if (StrUtil.isNotBlank(orderInfo.getPayOrderNo())) {
@@ -309,44 +339,45 @@
                 orderInfo.setStatus(OrderStatusEnum.WAIT_SHIPPING.getValue());
                 orderInfo.setPayTime(new Date());
                 orderInfo.setPayResult("1");
+                orderInfo.setDeliveryState(OrderDeliveryStateEnum.DELIVERY_WAIT.getValue());
 
-                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);
-                        }
-
-                        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());
-                        }
-                    }
-                }
+//                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);
+//                        }
+//
+//                        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);
-                    }
-                }
+//                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());
+//                agentProducer.sendAutoLevelUpMsg(member.getId());
+//                agentProducer.sendOrderReturn(orderInfo.getId());
                 break;
             case "4":
                 if (orderInfo.getOrderType() != 2) {
@@ -475,9 +506,38 @@
             throw new FebsException("还未送至自提点");
         }
 
+        List<MallRefundEntity> mallRefundEntities = mallRefundMapper.selectByItemIdAndOrderIdAndState(null, orderInfo.getId(), 3);
+        if(CollUtil.isNotEmpty(mallRefundEntities)){
+            throw new FebsException("请先处理退款商品");
+        }
+
         orderInfo.setStatus(OrderStatusEnum.FINISH.getValue());
         orderInfo.setReceivingTime(new Date());
         this.baseMapper.updateById(orderInfo);
+
+        //生成一条团长提成记录
+        Long orderInfoId = orderInfo.getId();
+        List<MallOrderItem> mallOrderItemList = mallOrderItemMapper.selectListByOrderId(orderInfoId);
+        if(CollUtil.isNotEmpty(mallOrderItemList)){
+            DataDictionaryCustom dicBonusPercent = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(DataDictionaryEnum.BONUS_PERCENT.getType(), DataDictionaryEnum.BONUS_PERCENT.getCode());
+            BigDecimal bonusPercent = new BigDecimal(dicBonusPercent.getValue()).setScale(2,BigDecimal.ROUND_DOWN);
+            for(MallOrderItem mallOrderItem : mallOrderItemList){
+                Integer state = mallOrderItem.getState() == null ? 1 : mallOrderItem.getState();
+                if(1 == state){
+                    MallLeaderAchieve mallLeaderAchieve = new MallLeaderAchieve();
+                    mallLeaderAchieve.setMemberId(orderInfo.getMemberId());
+                    mallLeaderAchieve.setOrderNo(orderInfo.getOrderNo());
+                    mallLeaderAchieve.setOrderItemId(mallOrderItem.getId());
+                    BigDecimal itemAmount = mallOrderItem.getAmount();
+                    mallLeaderAchieve.setAmount(itemAmount);
+                    BigDecimal bigDecimal = bonusPercent.multiply(itemAmount).setScale(2, BigDecimal.ROUND_DOWN);
+                    mallLeaderAchieve.setProfitAmount(bigDecimal);
+                    mallLeaderAchieve.setUniqueCode(orderInfo.getTakeUniqueCode());
+                    mallLeaderAchieve.setState(MallLeaderAchieve.STATE_ONE);
+                    mallLeaderAchieveMapper.insert(mallLeaderAchieve);
+                }
+            }
+        }
     }
 
     @Override
@@ -651,82 +711,107 @@
         if(1 != deliveryState){
             return new FebsResponse().fail().message("订单不是待配送状态");
         }
-        QueryWrapper<MallRefundEntity> objectQueryWrapper = new QueryWrapper<>();
-        objectQueryWrapper.eq("member_id",member.getId());
-        objectQueryWrapper.eq("order_id",mallOrderInfo.getId());
-        MallRefundEntity mallRefund = mallRefundMapper.selectOne(objectQueryWrapper);
-        MallRefundEntity mallRefundEntity = new MallRefundEntity();
-        if(ObjectUtil.isEmpty(mallRefund)){
-            mallRefundEntity.setRefundNo(mallOrderInfo.getOrderNo()+"_r");
-            mallRefundEntity.setMemberId(member.getId());
-            mallRefundEntity.setOrderId(mallOrderInfo.getId());
-            mallRefundEntity.setType(1);
-            mallRefundEntity.setState(3);
-            mallRefundEntity.setAmount(mallOrderInfo.getAmount());
-            mallRefundMapper.insert(mallRefundEntity);
-        }else{
-            if(mallRefund.getState() == 1){
-                return new FebsResponse().fail().message("订单已退款");
-            }
-            if(mallRefund.getState() == 3){
-                return new FebsResponse().fail().message("订单退款中");
-            }
-            if(mallRefund.getState() == 2){
-                mallRefundEntity.setId(mallRefund.getId());
-                mallRefundEntity.setRefundNo(mallRefund.getRefundNo());
-                mallRefundEntity.setMemberId(mallRefund.getMemberId());
-                mallRefundEntity.setOrderId(mallRefund.getOrderId());
-                mallRefundEntity.setType(mallRefund.getType());
+        //根据子订单生成退款记录
+        List<MallOrderItem> mallOrderItemList = mallOrderItemMapper.selectListByOrderId(id);
+        if(CollUtil.isEmpty(mallOrderItemList)){
+            return new FebsResponse().fail().message("订单不存在");
+        }
+        for(MallOrderItem mallOrderItem : mallOrderItemList){
+            QueryWrapper<MallRefundEntity> objectQueryWrapper = new QueryWrapper<>();
+            objectQueryWrapper.eq("member_id",member.getId());
+            objectQueryWrapper.eq("order_id",mallOrderInfo.getId());
+            objectQueryWrapper.eq("item_id",mallOrderItem.getId());
+            MallRefundEntity mallRefund = mallRefundMapper.selectOne(objectQueryWrapper);
+            MallRefundEntity mallRefundEntity = new MallRefundEntity();
+            if(ObjectUtil.isEmpty(mallRefund)){
+                mallRefundEntity.setRefundNo(mallOrderInfo.getOrderNo()+"_RITEM"+mallOrderItem.getId());
+                mallRefundEntity.setMemberId(member.getId());
+                mallRefundEntity.setOrderId(mallOrderInfo.getId());
+                mallRefundEntity.setItemId(mallOrderItem.getId());
+                if("余额支付".equals(mallOrderInfo.getPayMethod())){
+                    mallRefundEntity.setType(3);
+                }else if("微信支付".equals(mallOrderInfo.getPayMethod())){
+                    mallRefundEntity.setType(1);
+                }else{
+                    mallRefundEntity.setType(3);
+                }
                 mallRefundEntity.setState(3);
-                mallRefundEntity.setAmount(mallRefund.getAmount());
-                mallRefundMapper.updateById(mallRefundEntity);
+                mallRefundEntity.setAmount(mallOrderItem.getAmount());
+                mallRefundMapper.insert(mallRefundEntity);
+            }else{
+                if(mallRefund.getState() == 1){
+                    return new FebsResponse().fail().message("订单已退款");
+                }
+                if(mallRefund.getState() == 2 || mallRefund.getState() == 3){
+                    mallRefundEntity.setId(mallRefund.getId());
+                    mallRefundEntity.setRefundNo(mallRefund.getRefundNo());
+                    mallRefundEntity.setMemberId(mallRefund.getMemberId());
+                    mallRefundEntity.setOrderId(mallRefund.getOrderId());
+                    mallRefundEntity.setItemId(mallRefund.getItemId());
+                    mallRefundEntity.setType(mallRefund.getType());
+                    mallRefundEntity.setState(3);
+                    mallRefundEntity.setAmount(mallRefund.getAmount());
+                    mallRefundMapper.updateById(mallRefundEntity);
+                }
             }
+            ApiLeaderRefundOrderDto apiLeaderRefundOrderDto = new ApiLeaderRefundOrderDto();
+            apiLeaderRefundOrderDto.setOrderId(mallOrderInfo.getId());
+            apiLeaderRefundOrderDto.setItemId(mallOrderItem.getId());
+            apiLeaderRefundOrderDto.setAgreeState(1);
+            iApiMallTeamLeaderService.leaderRefundOrder(apiLeaderRefundOrderDto);
+        }
+        return new FebsResponse().success();
+    }
+
+    @Override
+    public FebsResponse applyRefundOrder(ApplyRefundOrderDto applyRefundOrderDto) {
+        Long orderId = applyRefundOrderDto.getOrderId();
+        Long itemId = applyRefundOrderDto.getItemId();
+        MallMember member = LoginUserUtil.getLoginUser();
+        MallOrderInfo mallOrderInfo = this.baseMapper.selectById(orderId);
+        if(ObjectUtil.isEmpty(mallOrderInfo)){
+            return new FebsResponse().fail().message("订单不存在");
         }
 
-        //退款订单编号
-        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;
+        List<MallRefundEntity> mallRefundEntitieSuccess = mallRefundMapper.selectByItemIdAndOrderIdAndState(itemId,orderId,1);
+        List<MallRefundEntity> mallRefundEntitiesIng = mallRefundMapper.selectByItemIdAndOrderIdAndState(itemId,orderId,3);
+        if(CollUtil.isNotEmpty(mallRefundEntitieSuccess) || CollUtil.isNotEmpty(mallRefundEntitiesIng)){
+            return new FebsResponse().fail().message("该订单无法申请退款");
         }
 
-        /**
-         * 更新退款表
-         * 更新订单表
-         */
-        Long refundId = mallRefundEntity.getId();
-        MallRefundEntity mallRefundOld = mallRefundMapper.selectById(refundId);
-        MallOrderInfo mallOrderInfoOld = this.baseMapper.selectByOrderNo(orderNo);
-        if(flag){
-            mallRefundOld.setState(1);
-            mallRefundMapper.updateById(mallRefundOld);
-            mallOrderInfoOld.setStatus(OrderStatusEnum.REFUNDED.getValue());
-            this.baseMapper.updateById(mallOrderInfoOld);
-            mallMoneyFlowService.addMoneyFlow(mallOrderInfoOld.getMemberId(), mallOrderInfoOld.getAmount(), MoneyFlowTypeEnum.REFUND.getValue(), mallOrderInfo.getOrderNo(), FlowTypeEnum.BALANCE.getValue());
+        MallRefundEntity mallRefundEntity = new MallRefundEntity();
+        MallOrderItem mallOrderItem = mallOrderItemMapper.selectById(itemId);
+        if(ObjectUtil.isNotEmpty(mallOrderItem)){
+            mallOrderItem.setState(2);
+            mallOrderItemMapper.updateById(mallOrderItem);
+            mallRefundEntity.setRefundNo(mallOrderInfo.getOrderNo()+"_RITEM"+itemId);
+            mallRefundEntity.setItemId(itemId);
         }else{
-            mallRefundOld.setState(2);
-            mallRefundMapper.updateById(mallRefundOld);
-            return new FebsResponse().fail().message("退款失败,请联系客服人员");
+
+            mallRefundEntity.setRefundNo(mallOrderInfo.getOrderNo()+"_R"+orderId);
         }
-        return new FebsResponse().success().message("退款成功");
+        mallRefundEntity.setRefundReason(applyRefundOrderDto.getRefundReason());
+        mallRefundEntity.setRefundRemark(applyRefundOrderDto.getRefundRemark());
+        mallRefundEntity.setRefundPic(applyRefundOrderDto.getRefundPic());
+        mallRefundEntity.setMemberId(member.getId());
+        mallRefundEntity.setState(3);
+        mallRefundEntity.setType(applyRefundOrderDto.getType());
+        mallRefundEntity.setOrderId(orderId);
+        mallRefundEntity.setAmount(mallOrderItem.getAmount());
+        mallRefundMapper.insert(mallRefundEntity);
+        return new FebsResponse().success().message("已申请");
+    }
+
+    @Override
+    public FebsResponse cancelRefundOrder(Long id) {
+        MallRefundEntity mallRefundEntity = mallRefundMapper.selectById(id);
+        mallRefundEntity.setState(2);
+        mallRefundMapper.updateById(mallRefundEntity);
+        Long itemId = mallRefundEntity.getItemId();
+        MallOrderItem mallOrderItem = mallOrderItemMapper.selectById(itemId);
+        mallOrderItem.setState(1);
+        mallOrderItemMapper.updateById(mallOrderItem);
+        return new FebsResponse().success().message("已取消");
     }
 
 }

--
Gitblit v1.9.1