From 1825949df8995ed189e733a4882f13343041912f Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Fri, 05 Aug 2022 14:26:41 +0800
Subject: [PATCH] 20220805

---
 src/main/java/cc/mrbird/febs/mall/service/impl/ApiMallOrderInfoServiceImpl.java |  103 +++++++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 103 insertions(+), 0 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 9ac608f..dd09c75 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
@@ -1,7 +1,9 @@
 package cc.mrbird.febs.mall.service.impl;
 
+import cc.mrbird.febs.common.entity.FebsResponse;
 import cc.mrbird.febs.common.enumerates.*;
 import cc.mrbird.febs.common.exception.FebsException;
+import cc.mrbird.febs.common.properties.XcxProperties;
 import cc.mrbird.febs.common.utils.*;
 import cc.mrbird.febs.mall.conversion.MallGoodsCommentConversion;
 import cc.mrbird.febs.mall.conversion.MallOrderInfoConversion;
@@ -16,18 +18,22 @@
 import cc.mrbird.febs.pay.model.BrandWCPayRequestData;
 import cc.mrbird.febs.pay.service.IPayService;
 import cc.mrbird.febs.pay.service.IXcxPayService;
+import cc.mrbird.febs.pay.util.WeixinServiceUtil;
 import cc.mrbird.febs.rabbit.producter.AgentProducer;
 import cn.hutool.core.collection.CollUtil;
 import cn.hutool.core.date.DateUnit;
 import cn.hutool.core.date.DateUtil;
+import cn.hutool.core.util.ObjectUtil;
 import cn.hutool.core.util.StrUtil;
 import cn.hutool.crypto.SecureUtil;
 import cn.hutool.json.JSONUtil;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
@@ -62,6 +68,7 @@
     private final IPayService payService;
     private final IXcxPayService iXcxPayService;
     private final IMallAchieveService mallAchieveService;
+    private final MallRefundMapper mallRefundMapper;
 
     @Override
     @Transactional(rollbackFor = Exception.class)
@@ -560,4 +567,100 @@
         }
     }
 
+    @Autowired
+    private WeixinServiceUtil weixinServiceUtil;
+    private final XcxProperties xcxProperties = SpringContextHolder.getBean(XcxProperties.class);
+
+    @Override
+    @Transactional
+    public FebsResponse refundOrder(Long id) {
+        MallMember member = LoginUserUtil.getLoginUser();
+        MallOrderInfo mallOrderInfo = this.baseMapper.selectById(id);
+        if(ObjectUtil.isEmpty(mallOrderInfo)){
+            return new FebsResponse().fail().message("订单不存在");
+        }
+        Integer status = mallOrderInfo.getStatus();
+        if(OrderStatusEnum.WAIT_SHIPPING.getValue() != status){
+            return new FebsResponse().fail().message("订单不是待发货状态");
+        }
+        Integer deliveryState = mallOrderInfo.getDeliveryState();
+        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);
+        }
+        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());
+            mallRefundEntity.setState(3);
+            mallRefundEntity.setAmount(mallRefund.getAmount());
+            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();
+
+        //退款退款金额
+        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;
+        }
+
+        /**
+         * 更新退款表
+         * 更新订单表
+         */
+        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);
+        }else{
+            mallRefundOld.setState(2);
+            mallRefundMapper.updateById(mallRefundOld);
+            return new FebsResponse().fail().message("退款失败,请联系客服人员");
+        }
+        return new FebsResponse().success().message("退款成功");
+    }
+
 }

--
Gitblit v1.9.1