From eb5d7885fa9e4bd20c0827eec9b4cdd48c47b509 Mon Sep 17 00:00:00 2001
From: puzhibing <393733352@qq.com>
Date: 星期二, 07 一月 2025 09:11:20 +0800
Subject: [PATCH] 修改bug

---
 ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/OrderServiceImpl.java |  234 ++++++++++++++++++++++++++++++++++++++++++++++++++++++----
 1 files changed, 216 insertions(+), 18 deletions(-)

diff --git a/ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/OrderServiceImpl.java b/ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/OrderServiceImpl.java
index e3bc81d..3a68b76 100644
--- a/ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/OrderServiceImpl.java
+++ b/ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/OrderServiceImpl.java
@@ -20,10 +20,15 @@
 import com.ruoyi.order.model.Order;
 import com.ruoyi.order.model.OrderBalancePayment;
 import com.ruoyi.order.model.OrderGood;
+import com.ruoyi.order.model.RefundPass;
 import com.ruoyi.order.service.CommissionService;
 import com.ruoyi.order.service.OrderBalancePaymentService;
 import com.ruoyi.order.service.OrderService;
+import com.ruoyi.order.service.RefundPassService;
 import com.ruoyi.order.util.ExpressDeliveryUtil;
+import com.ruoyi.order.util.payment.PaymentUtil;
+import com.ruoyi.order.util.payment.model.RefundCallbackResult;
+import com.ruoyi.order.util.payment.model.RefundResult;
 import com.ruoyi.order.util.vo.QueryKD100Vo;
 import com.ruoyi.order.vo.*;
 import com.ruoyi.other.api.domain.*;
@@ -89,6 +94,9 @@
     
     @Resource
     private GoodsClient goodsClient;
+
+    @Resource
+    private RefundPassService refundPassService;
     
     
 
@@ -339,9 +347,11 @@
             return R.fail("无效的操作");
         }
         order.setOrderStatus(5);
-        this.updateById(order);
-        refundPayMoney(order);
-        return R.ok();
+        R r = refundPayMoney(order);
+        if(200 == r.getCode()){
+            this.updateById(order);
+        }
+        return r;
     }
     
     
@@ -349,13 +359,20 @@
      * 返回订单支付金额和回退积分和会员等级
      * @param order
      */
-    public void refundPayMoney(Order order){
+    public R refundPayMoney(Order order){
         //开始退款
         Integer payMethod = order.getPayMethod();
         BigDecimal paymentAmount = order.getPaymentAmount();
         AppUser appUser = appUserClient.getAppUserById(order.getAppUserId());
         if(1 == payMethod){
             //微信退款
+            RefundResult refund = PaymentUtil.refund(order.getOrderNumber(), "R" + order.getOrderNumber(), paymentAmount.doubleValue(), "/order/order/refundPayMoneyCallback");
+            if("100".equals(refund.getRa_Status())){
+                order.setRefundStatus(1);
+                return R.ok();
+            }else{
+                return R.fail(refund.getRc_CodeMsg());
+            }
         }
         if(2 == payMethod){
             //余额退款
@@ -367,6 +384,13 @@
             }
             appUser.setBalance(balance.add(paymentAmount).setScale(2, RoundingMode.HALF_EVEN));
             appUser.setShopAmount(appUser.getShopAmount().subtract(paymentAmount).setScale(2, RoundingMode.HALF_EVEN));
+            //查询最后一次的消费订单
+            Order order1 = this.getOne(new LambdaQueryWrapper<Order>().eq(Order::getAppUserId, order.getAppUserId()).eq(Order::getPayStatus, 2).eq(Order::getDelFlag, 0).in(Order::getOrderStatus, Arrays.asList(2, 3, 4, 8)).ne(Order::getId, order.getId()).last(" order by create_time desc limit 0, 1"));
+            if(null != order1){
+                appUser.setLastShopTime(order1.getCreateTime());
+            }else{
+                appUser.setLastShopTime(LocalDateTime.MIN);
+            }
         
             //构建账户余额流水明细
             BalanceChangeRecord balanceChangeRecord = new BalanceChangeRecord();
@@ -380,16 +404,19 @@
             balanceChangeRecord.setCreateTime(LocalDateTime.now());
             balanceChangeRecordClient.saveBalanceChangeRecord(balanceChangeRecord);
         }
-        Integer lavePoint = appUser.getLavePoint();
         if(3 == payMethod){
-            //积分退款
-            appUser.setLavePoint(appUser.getLavePoint() + order.getPoint());
-        
             //开始运费退款,积分支付,运费是单独进行支付的,所以需要单独退款
             if(null != order.getExpressAmount() && BigDecimal.ZERO.compareTo(order.getExpressAmount()) < 0){
                 BigDecimal expressAmount = order.getExpressAmount();
                 if(1 == order.getExpressPayMethod()){
                     //微信退款
+                    RefundResult refund = PaymentUtil.refund(order.getOrderNumber(), "R" + order.getOrderNumber(), expressAmount.doubleValue(), "/order/order/refundExpressPayMoneyCallback");
+                    if("100".equals(refund.getRa_Status())){
+                        order.setRefundStatus(1);
+                        return R.ok();
+                    }else{
+                        return R.fail(refund.getRc_CodeMsg());
+                    }
                 }
                 if(2 == order.getExpressPayMethod()){
                     //余额退款
@@ -411,38 +438,209 @@
                     balanceChangeRecordClient.saveBalanceChangeRecord(balanceChangeRecord);
                 }
             }
+
+            Integer lavePoint = appUser.getLavePoint();
+            //积分退款
+            appUser.setLavePoint(appUser.getLavePoint() + order.getPoint());
+            appUser.setAvailablePoint(appUser.getAvailablePoint() + order.getPoint());
+            UserPoint userPoint1 = new UserPoint();
+            userPoint1.setType(11);
+            userPoint1.setObjectId(order.getId());
+            List<UserPoint> data = userPointClient.getUserPointList(userPoint1).getData();
+            Integer transferablePoint = order.getPoint();
+            if(data.size() > 0){
+                UserPoint userPoint = data.get(0);
+                transferablePoint = Integer.valueOf(userPoint.getExtention());
+            }
+            appUser.setTransferablePoint(appUser.getTransferablePoint() + transferablePoint);
+
+            //构建积分流水明细
+            UserPoint userPoint = new UserPoint();
+            userPoint.setType(11);
+            userPoint.setHistoricalPoint(lavePoint);
+            userPoint.setVariablePoint(order.getPoint());
+            userPoint.setBalance(appUser.getLavePoint());
+            userPoint.setCreateTime(LocalDateTime.now());
+            userPoint.setAppUserId(order.getAppUserId());
+            userPoint.setObjectId(order.getId());
+            userPointClient.saveUserPoint(userPoint);
         }
         //退回获得的消费积分
         //需要先检查会员等级时候回回退,使用回退后的会员等级查询配置
+        Integer lavePoint = appUser.getLavePoint();
         Integer getPoint = order.getGetPoint();
         boolean vipDemotion = vipDemotion(appUser.getShopPoint() - getPoint, appUser.getVipId());
         PointSetting pointSetting = pointSettingClient.getPointSetting(vipDemotion ? appUser.getVipId() - 1 : appUser.getVipId()).getData();
-        int earnPoint1 = getPoint;
+        int earnPoint1 = 0;
         if(null != pointSetting && 1 == pointSetting.getBuyPointOpen()){
             earnPoint1 = new BigDecimal(getPoint).divide(pointSetting.getBuyPoint().divide(new BigDecimal(100))).intValue();
         }
-        appUser.setLavePoint(lavePoint - getPoint);
-        appUser.setShopPoint(appUser.getShopPoint() - earnPoint1);
-        appUser.setTotalPoint(appUser.getTotalPoint() - earnPoint1);
+        appUser.setShopPoint(appUser.getShopPoint() - getPoint);
+        appUser.setLavePoint(appUser.getLavePoint() - getPoint);
+        appUser.setAvailablePoint(appUser.getAvailablePoint() - earnPoint1);
+        appUser.setTotalAvailablePoint(appUser.getTotalAvailablePoint() - earnPoint1);
+        if(null != pointSetting && 1 == pointSetting.getBuyPointGift()){
+            appUser.setTransferablePoint(appUser.getTransferablePoint() - earnPoint1);
+        }
+        appUser.setTotalPoint(appUser.getTotalPoint() - getPoint);
         if(vipDemotion){
             appUser.setVipId(appUser.getVipId() - 1);
         }
+
         //构建积分流水明细
         UserPoint userPoint = new UserPoint();
-        userPoint.setType(11);
+        userPoint.setType(1);
         userPoint.setHistoricalPoint(lavePoint);
-        Integer point = appUser.getLavePoint() - lavePoint;
-        userPoint.setVariablePoint(point >= 0 ? point : point * -1);
+        userPoint.setVariablePoint(getPoint);
         userPoint.setBalance(appUser.getLavePoint());
         userPoint.setCreateTime(LocalDateTime.now());
         userPoint.setAppUserId(order.getAppUserId());
         userPoint.setObjectId(order.getId());
         userPointClient.saveUserPoint(userPoint);
         appUserClient.editAppUserById(appUser);
+
+        order.setRefundStatus(2);
+        order.setRefundTime(LocalDateTime.now());
+        return R.ok();
     }
-    
-    
-    
+
+
+    /**
+     * 取消订单后回调处理
+     * @return
+     */
+    @Override
+    public R refundPayMoneyCallback(RefundCallbackResult refundCallbackResult) {
+        String code = refundCallbackResult.getR3_RefundOrderNo().substring(1);
+        Order order = this.getOne(new LambdaQueryWrapper<Order>().eq(Order::getOrderNumber, code));
+        if(null == order || order.getPayStatus() == 1 || order.getOrderStatus() == 6){
+            return R.ok();
+        }
+        order.setRefundCode(refundCallbackResult.getR5_RefundTrxNo());
+        order.setRefundStatus(2);
+        order.setRefundTime(LocalDateTime.now());
+        this.updateById(order);
+
+        //退回获得的消费积分
+        //需要先检查会员等级时候回回退,使用回退后的会员等级查询配置
+        AppUser appUser = appUserClient.getAppUserById(order.getAppUserId());
+        Integer lavePoint = appUser.getLavePoint();
+        Integer getPoint = order.getGetPoint();
+        boolean vipDemotion = vipDemotion(appUser.getShopPoint() - getPoint, appUser.getVipId());
+        PointSetting pointSetting = pointSettingClient.getPointSetting(vipDemotion ? appUser.getVipId() - 1 : appUser.getVipId()).getData();
+        int earnPoint1 = 0;
+        if(null != pointSetting && 1 == pointSetting.getBuyPointOpen()){
+            earnPoint1 = new BigDecimal(getPoint).divide(pointSetting.getBuyPoint().divide(new BigDecimal(100))).intValue();
+        }
+        appUser.setShopPoint(appUser.getShopPoint() - getPoint);
+        appUser.setLavePoint(appUser.getLavePoint() - getPoint);
+        appUser.setAvailablePoint(appUser.getAvailablePoint() - earnPoint1);
+        appUser.setTotalAvailablePoint(appUser.getTotalAvailablePoint() - earnPoint1);
+        if(null != pointSetting && 1 == pointSetting.getBuyPointGift()){
+            appUser.setTransferablePoint(appUser.getTransferablePoint() - earnPoint1);
+        }
+        appUser.setTotalPoint(appUser.getTotalPoint() - getPoint);
+        if(vipDemotion){
+            appUser.setVipId(appUser.getVipId() - 1);
+        }
+
+        //构建积分流水明细
+        UserPoint userPoint = new UserPoint();
+        userPoint.setType(1);
+        userPoint.setHistoricalPoint(lavePoint);
+        userPoint.setVariablePoint(getPoint);
+        userPoint.setBalance(appUser.getLavePoint());
+        userPoint.setCreateTime(LocalDateTime.now());
+        userPoint.setAppUserId(order.getAppUserId());
+        userPoint.setObjectId(order.getId());
+        userPointClient.saveUserPoint(userPoint);
+        appUserClient.editAppUserById(appUser);
+        return R.ok();
+    }
+
+
+    /**
+     * 取消订单快递费回退
+     * @return
+     */
+    @Override
+    public R refundExpressPayMoneyCallback(RefundCallbackResult refundCallbackResult) {
+        String code = refundCallbackResult.getR3_RefundOrderNo().substring(1);
+        Order order = this.getOne(new LambdaQueryWrapper<Order>().eq(Order::getOrderNumber, code));
+        if(null == order || order.getPayStatus() == 1 || order.getOrderStatus() == 6){
+            return R.ok();
+        }
+        order.setRefundCode(refundCallbackResult.getR5_RefundTrxNo());
+        order.setRefundStatus(2);
+        order.setRefundTime(LocalDateTime.now());
+        this.updateById(order);
+
+        AppUser appUser = appUserClient.getAppUserById(order.getAppUserId());
+        Integer lavePoint = appUser.getLavePoint();
+        //积分退款
+        appUser.setLavePoint(appUser.getLavePoint() + order.getPoint());
+        appUser.setAvailablePoint(appUser.getAvailablePoint() + order.getPoint());
+        UserPoint userPoint1 = new UserPoint();
+        userPoint1.setType(11);
+        userPoint1.setObjectId(order.getId());
+        List<UserPoint> data = userPointClient.getUserPointList(userPoint1).getData();
+        Integer transferablePoint = order.getPoint();
+        if(data.size() > 0){
+            UserPoint userPoint = data.get(0);
+            transferablePoint = Integer.valueOf(userPoint.getExtention());
+        }
+        appUser.setTransferablePoint(appUser.getTransferablePoint() + transferablePoint);
+
+        //构建积分流水明细
+        UserPoint userPoint = new UserPoint();
+        userPoint.setType(11);
+        userPoint.setHistoricalPoint(lavePoint);
+        userPoint.setVariablePoint(order.getPoint());
+        userPoint.setBalance(appUser.getLavePoint());
+        userPoint.setCreateTime(LocalDateTime.now());
+        userPoint.setAppUserId(order.getAppUserId());
+        userPoint.setObjectId(order.getId());
+        userPointClient.saveUserPoint(userPoint);
+
+        //退回获得的消费积分
+        //需要先检查会员等级时候回回退,使用回退后的会员等级查询配置
+        lavePoint = appUser.getLavePoint();
+        Integer getPoint = order.getGetPoint();
+        boolean vipDemotion = vipDemotion(appUser.getShopPoint() - getPoint, appUser.getVipId());
+        PointSetting pointSetting = pointSettingClient.getPointSetting(vipDemotion ? appUser.getVipId() - 1 : appUser.getVipId()).getData();
+        int earnPoint1 = 0;
+        if(null != pointSetting && 1 == pointSetting.getBuyPointOpen()){
+            earnPoint1 = new BigDecimal(getPoint).divide(pointSetting.getBuyPoint().divide(new BigDecimal(100))).intValue();
+        }
+        appUser.setShopPoint(appUser.getShopPoint() - getPoint);
+        appUser.setLavePoint(appUser.getLavePoint() - getPoint);
+        appUser.setAvailablePoint(appUser.getAvailablePoint() - earnPoint1);
+        appUser.setTotalAvailablePoint(appUser.getTotalAvailablePoint() - earnPoint1);
+        if(null != pointSetting && 1 == pointSetting.getBuyPointGift()){
+            appUser.setTransferablePoint(appUser.getTransferablePoint() - earnPoint1);
+        }
+        appUser.setTotalPoint(appUser.getTotalPoint() - getPoint);
+        if(vipDemotion){
+            appUser.setVipId(appUser.getVipId() - 1);
+        }
+
+        //构建积分流水明细
+        userPoint = new UserPoint();
+        userPoint.setType(1);
+        userPoint.setHistoricalPoint(lavePoint);
+        userPoint.setVariablePoint(getPoint);
+        userPoint.setBalance(appUser.getLavePoint());
+        userPoint.setCreateTime(LocalDateTime.now());
+        userPoint.setAppUserId(order.getAppUserId());
+        userPoint.setObjectId(order.getId());
+        userPointClient.saveUserPoint(userPoint);
+        appUserClient.editAppUserById(appUser);
+
+        order.setRefundStatus(2);
+        order.setRefundTime(LocalDateTime.now());
+        return null;
+    }
+
     /**
      * 会员降级检测
      */

--
Gitblit v1.7.1