From ec759e2c4e9340a1f447dec93ce4742c1c8c132a Mon Sep 17 00:00:00 2001
From: Pu Zhibing <393733352@qq.com>
Date: 星期五, 17 一月 2025 15:49:14 +0800
Subject: [PATCH] Merge branch 'master' of http://120.76.84.145:10101/gitblit/r/java/qijisheng

---
 ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/OrderServiceImpl.java |  126 ++++++++++++++++++++++-------------------
 1 files changed, 67 insertions(+), 59 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 1fd2ef1..dd54a11 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
@@ -6,10 +6,7 @@
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
-import com.ruoyi.account.api.feignClient.AppUserClient;
-import com.ruoyi.account.api.feignClient.BalanceChangeRecordClient;
-import com.ruoyi.account.api.feignClient.UserCouponClient;
-import com.ruoyi.account.api.feignClient.UserPointClient;
+import com.ruoyi.account.api.feignClient.*;
 import com.ruoyi.account.api.model.*;
 import com.ruoyi.common.core.domain.R;
 import com.ruoyi.common.core.exception.ServiceException;
@@ -89,9 +86,6 @@
     private UserPointClient userPointClient;
     
     @Resource
-    private PointSettingClient pointSettingClient;
-    
-    @Resource
     private OrderBalancePaymentService orderBalancePaymentService;
     
     @Resource
@@ -115,6 +109,9 @@
 
     @Resource
     private UserCouponClient userCouponClient;
+    
+    @Resource
+    private UserChangeLogClient userChangeLogClient;
     
     
 
@@ -205,7 +202,7 @@
         if(StringUtils.isNotEmpty(order.getExpressResult())){
             MapTrackKD100Vo mapTrackKD100Vo = JSON.parseObject(order.getExpressResult(), MapTrackKD100Vo.class);
             List<QueryKD100ListVo> data = mapTrackKD100Vo.getData();
-            orderDetailVO.setExpress(data.size() > 0 ? data.get(0).getContext() : "");
+            orderDetailVO.setExpress(null != data && data.size() > 0 ? data.get(0).getContext() : "");
         }
         
         if(order.getOrderType() == 1){
@@ -286,6 +283,7 @@
         if(StringUtils.isNotEmpty(technicianId) && !"null".equals(technicianId)){
             order.setTechnicianId(Integer.valueOf(technicianId));
         }
+        // TODO
         orderMapper.updateById(order);
     }
     
@@ -337,8 +335,7 @@
                 orderPageListVo.setUserName(appUser.getName());
                 orderPageListVo.setPhone(appUser.getPhone());
             }
-//            RefundPass one = refundPassService.getOne(new LambdaQueryWrapper<RefundPass>().eq(RefundPass::getOrderId, orderPageListVo.getId()).eq(RefundPass::getDelFlag, 0).last(" order by create_time desc limit 0,1"));
-            RefundPass one = refundPassService.lambdaQuery().eq(RefundPass::getOrderId, orderPageListVo.getId()).one();
+            RefundPass one = refundPassService.getOne(new LambdaQueryWrapper<RefundPass>().eq(RefundPass::getOrderId, orderPageListVo.getId()).eq(RefundPass::getDelFlag, 0).last(" order by create_time desc limit 0,1"));
             orderPageListVo.setRefundPassId(null != one ? one.getId().toString() : null);
 
             // 平台分佣
@@ -434,7 +431,7 @@
         if(Arrays.asList(5, 6, 7).contains(order.getOrderStatus())){
             return R.fail("无效的操作");
         }
-        if(LocalDateTime.now().isAfter(order.getAfterSaleTime())){
+        if(null != order.getAfterSaleTime() && LocalDateTime.now().isAfter(order.getAfterSaleTime())){
             return R.fail("订单取消失败");
         }
         order.setOrderStatus(5);
@@ -471,7 +468,7 @@
             BigDecimal balance = appUser.getBalance();
             if(null != orderBalancePayment){
                 appUser.setTotalRedPacketAmount(appUser.getTotalRedPacketAmount().add(orderBalancePayment.getRedPacketAmount()).setScale(2, RoundingMode.HALF_EVEN));
-                appUser.setTotalDistributionAmount(appUser.getTotalDistributionAmount().add(orderBalancePayment.getDistributionAmount()).setScale(2, RoundingMode.HALF_EVEN));
+//                appUser.setTotalDistributionAmount(appUser.getTotalDistributionAmount().add(orderBalancePayment.getDistributionAmount()).setScale(2, RoundingMode.HALF_EVEN));
             }
             appUser.setBalance(balance.add(paymentAmount).setScale(2, RoundingMode.HALF_EVEN));
             appUser.setShopAmount(appUser.getShopAmount().subtract(paymentAmount).setScale(2, RoundingMode.HALF_EVEN));
@@ -519,22 +516,25 @@
             }
             appUser.setTotalPoint(appUser.getTotalPoint() - shopPoint);
 
+            //构建积分流水明细
+            if(shopPoint > 0){
+                UserPoint userPoint = new UserPoint();
+                userPoint.setType(1);
+                userPoint.setHistoricalPoint(lavePoint);
+                userPoint.setVariablePoint(shopPoint);
+                userPoint.setBalance(appUser.getLavePoint());
+                userPoint.setCreateTime(LocalDateTime.now());
+                userPoint.setAppUserId(order.getAppUserId());
+                userPoint.setObjectId(order.getId());
+                userPointClient.saveUserPoint(userPoint);
+            }
+            appUserClient.editAppUserById(appUser);
+    
+            //降级检测
             boolean vipDemotion = vipDemotion(appUser.getShopPoint(), appUser.getVipId());
             if(vipDemotion){
-                appUser.setVipId(appUser.getVipId() - 1);
+                appUserClient.vipDemotion(appUser.getId());
             }
-
-            //构建积分流水明细
-            UserPoint userPoint = new UserPoint();
-            userPoint.setType(1);
-            userPoint.setHistoricalPoint(lavePoint);
-            userPoint.setVariablePoint(shopPoint);
-            userPoint.setBalance(appUser.getLavePoint());
-            userPoint.setCreateTime(LocalDateTime.now());
-            userPoint.setAppUserId(order.getAppUserId());
-            userPoint.setObjectId(order.getId());
-            userPointClient.saveUserPoint(userPoint);
-            appUserClient.editAppUserById(appUser);
             //回退优惠券状态
             if(null != order.getUserCouponId()){
                 UserCoupon userCoupon = userCouponClient.getUserCoupon(order.getUserCouponId()).getData();
@@ -562,7 +562,7 @@
                     BigDecimal balance = appUser.getBalance();
                     if(null != orderBalancePayment){
                         appUser.setTotalRedPacketAmount(appUser.getTotalRedPacketAmount().add(orderBalancePayment.getRedPacketAmount()).setScale(2, RoundingMode.HALF_EVEN));
-                        appUser.setTotalDistributionAmount(appUser.getTotalDistributionAmount().add(orderBalancePayment.getDistributionAmount()).setScale(2, RoundingMode.HALF_EVEN));
+//                        appUser.setTotalDistributionAmount(appUser.getTotalDistributionAmount().add(orderBalancePayment.getDistributionAmount()).setScale(2, RoundingMode.HALF_EVEN));
                     }
                     appUser.setBalance(balance.add(expressAmount).setScale(2, RoundingMode.HALF_EVEN));
                     //构建账户余额流水明细
@@ -596,15 +596,17 @@
             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);
+            if(order.getPoint() > 0){
+                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);
+            }
             appUserClient.editAppUserById(appUser);
         }
 
@@ -651,22 +653,25 @@
         }
         appUser.setTotalPoint(appUser.getTotalPoint() - shopPoint);
 
+        //构建积分流水明细
+        if(shopPoint > 0){
+            UserPoint userPoint = new UserPoint();
+            userPoint.setType(1);
+            userPoint.setHistoricalPoint(lavePoint);
+            userPoint.setVariablePoint(shopPoint);
+            userPoint.setBalance(appUser.getLavePoint());
+            userPoint.setCreateTime(LocalDateTime.now());
+            userPoint.setAppUserId(order.getAppUserId());
+            userPoint.setObjectId(order.getId());
+            userPointClient.saveUserPoint(userPoint);
+        }
+        appUserClient.editAppUserById(appUser);
+    
+        //降级检测
         boolean vipDemotion = vipDemotion(appUser.getShopPoint(), appUser.getVipId());
         if(vipDemotion){
-            appUser.setVipId(appUser.getVipId() - 1);
+            appUserClient.vipDemotion(appUser.getId());
         }
-
-        //构建积分流水明细
-        UserPoint userPoint = new UserPoint();
-        userPoint.setType(1);
-        userPoint.setHistoricalPoint(lavePoint);
-        userPoint.setVariablePoint(shopPoint);
-        userPoint.setBalance(appUser.getLavePoint());
-        userPoint.setCreateTime(LocalDateTime.now());
-        userPoint.setAppUserId(order.getAppUserId());
-        userPoint.setObjectId(order.getId());
-        userPointClient.saveUserPoint(userPoint);
-        appUserClient.editAppUserById(appUser);
 
         //回退优惠券状态
         if(null != order.getUserCouponId()){
@@ -711,15 +716,17 @@
         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);
+        if(order.getPoint() > 0){
+            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);
+        }
         return R.ok();
     }
 
@@ -809,6 +816,7 @@
         }
         List<OrderGood> orderGoods = orderGoodMapper.selectList(new LambdaQueryWrapper<OrderGood>().eq(OrderGood::getOrderId, orderId).eq(OrderGood::getDelFlag, 0));
         int sum = orderGoods.stream().mapToInt(OrderGood::getNum).sum();
+        System.out.println("111111111111222");
         orderInfo.setGoodsNum(sum);
         List<Object> goodsJson = new ArrayList<>();
         for (OrderGood orderGood : orderGoods) {
@@ -854,8 +862,8 @@
      * @return
      */
     @Override
-    public Integer getGoodsSaleNum(Integer goodsId, Integer type) {
-        return this.baseMapper.getGoodsSaleNum(goodsId, type);
+    public Integer getGoodsSaleNum(Integer goodsId, Integer type, Long userId) {
+        return this.baseMapper.getGoodsSaleNum(goodsId, type, userId);
     }
 
 

--
Gitblit v1.7.1