From cd2781c1edd9b8b9fd3fd8b6365a65c07adcb109 Mon Sep 17 00:00:00 2001
From: Pu Zhibing <393733352@qq.com>
Date: 星期四, 02 一月 2025 16:42:34 +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/CommissionServiceImpl.java |   85 ++++++++++++------------------------------
 1 files changed, 24 insertions(+), 61 deletions(-)

diff --git a/ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/CommissionServiceImpl.java b/ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/CommissionServiceImpl.java
index 80bcb09..e4014b3 100644
--- a/ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/CommissionServiceImpl.java
+++ b/ruoyi-service/ruoyi-order/src/main/java/com/ruoyi/order/service/impl/CommissionServiceImpl.java
@@ -8,6 +8,7 @@
 import com.ruoyi.account.api.model.BalanceChangeRecord;
 import com.ruoyi.account.api.model.UserPoint;
 import com.ruoyi.common.core.domain.R;
+import com.ruoyi.common.core.utils.StringUtils;
 import com.ruoyi.order.service.CommissionService;
 import com.ruoyi.order.service.OrderGoodService;
 import com.ruoyi.order.service.OrderService;
@@ -97,26 +98,30 @@
                 BigDecimal superiorSubcommission = orderGood.getSuperiorSubcommission();
                 //上级获得分佣积分(直推上级|直帮上级)
                 Integer superiorRebatePoints = orderGood.getSuperiorRebatePoints();
-                String[] split = orderGood.getSuperiorPriceType().split(",");
-                for (String s : split) {
-                    //直推上级
-                    if("1".equals(s)){
-                        ztsj_price = ztsj_price.add(superiorSubcommission);
-                    }
-                    //直帮上级
-                    if("2".equals(s)){
-                        zbsj_price = zbsj_price.add(superiorSubcommission);
+                if(StringUtils.isNotEmpty(orderGood.getSuperiorPriceType())){
+                    String[] split = orderGood.getSuperiorPriceType().split(",");
+                    for (String s : split) {
+                        //直推上级
+                        if("1".equals(s)){
+                            ztsj_price = ztsj_price.add(superiorSubcommission);
+                        }
+                        //直帮上级
+                        if("2".equals(s)){
+                            zbsj_price = zbsj_price.add(superiorSubcommission);
+                        }
                     }
                 }
-                split = orderGood.getSuperiorType().split(",");
-                for (String s : split) {
-                    //直推上级
-                    if("1".equals(s)){
-                        ztsj_point += superiorRebatePoints;
-                    }
-                    //直帮上级
-                    if("2".equals(s)){
-                        zbsj_point += superiorRebatePoints;
+                if(StringUtils.isNotEmpty(orderGood.getSuperiorType())){
+                    String[] split = orderGood.getSuperiorType().split(",");
+                    for (String s : split) {
+                        //直推上级
+                        if("1".equals(s)){
+                            ztsj_point += superiorRebatePoints;
+                        }
+                        //直帮上级
+                        if("2".equals(s)){
+                            zbsj_point += superiorRebatePoints;
+                        }
                     }
                 }
                 
@@ -252,7 +257,6 @@
             Shop shop = shopClient.getShopById(order.getShopId()).getData();
             AppUser shopAppUser = appUserClient.getAppUserById(shop.getAppUserId());
             if(null != shopAppUser){
-                BigDecimal balance = shopAppUser.getBalance();
                 BigDecimal shopBalance = shop.getBalance();
                 Integer lavePoint = shopAppUser.getLavePoint();
                 Integer shopLavePoint = shop.getLavePoint();
@@ -285,19 +289,6 @@
                 appUserClient.editAppUserById(shopAppUser);
                 shopClient.updateShop(shop);
                 //添加明细记录
-                if(!shopAppUser.getBalance().equals(balance)){
-                    BalanceChangeRecord balanceChangeRecord = new BalanceChangeRecord();
-                    balanceChangeRecord.setAppUserId(shopAppUser.getId());
-                    balanceChangeRecord.setOrderId(order.getId());
-                    balanceChangeRecord.setChangeType(4);
-                    balanceChangeRecord.setBeforeAmount(balance);
-                    balanceChangeRecord.setChangeAmount(hxmd_price);
-                    balanceChangeRecord.setAfterAmount(shopAppUser.getBalance());
-                    balanceChangeRecord.setDelFlag(0);
-                    balanceChangeRecord.setCreateTime(LocalDateTime.now());
-                    balanceChangeRecordClient.saveBalanceChangeRecord(balanceChangeRecord);
-                }
-                
                 if(!shop.getBalance().equals(shopBalance)){
                     ShopBalanceStatement shopBalanceStatement = new ShopBalanceStatement();
                     shopBalanceStatement.setShopId(shop.getId());
@@ -387,7 +378,6 @@
             if(null != shop1){
                 AppUser bdShopAppUser = appUserClient.getAppUserById(shop1.getAppUserId());
                 if(null != bdShopAppUser){
-                    BigDecimal balance = bdShopAppUser.getBalance();
                     BigDecimal shopBalance = shop1.getBalance();
                     Integer lavePoint = bdShopAppUser.getLavePoint();
                     Integer shopLavePoint = shop1.getLavePoint();
@@ -420,23 +410,10 @@
                     appUserClient.editAppUserById(bdShopAppUser);
                     shopClient.updateShop(shop1);
                     //添加明细记录
-                    if(!bdShopAppUser.getBalance().equals(balance)){
-                        BalanceChangeRecord balanceChangeRecord = new BalanceChangeRecord();
-                        balanceChangeRecord.setAppUserId(bdShopAppUser.getId());
-                        balanceChangeRecord.setOrderId(order.getId());
-                        balanceChangeRecord.setChangeType(4);
-                        balanceChangeRecord.setBeforeAmount(balance);
-                        balanceChangeRecord.setChangeAmount(bdmd_price);
-                        balanceChangeRecord.setAfterAmount(bdShopAppUser.getBalance());
-                        balanceChangeRecord.setDelFlag(0);
-                        balanceChangeRecord.setCreateTime(LocalDateTime.now());
-                        balanceChangeRecordClient.saveBalanceChangeRecord(balanceChangeRecord);
-                    }
-        
                     if(!shop1.getBalance().equals(shopBalance)){
                         ShopBalanceStatement shopBalanceStatement = new ShopBalanceStatement();
                         shopBalanceStatement.setShopId(shop1.getId());
-                        shopBalanceStatement.setType(4);
+                        shopBalanceStatement.setType(1);
                         shopBalanceStatement.setHistoricalBalance(shopBalance);
                         shopBalanceStatement.setVariableAmount(bdmd_price);
                         shopBalanceStatement.setBalance(shop1.getBalance());
@@ -484,7 +461,6 @@
             if(null != shop2){
                 AppUser sjShopAppUser = appUserClient.getAppUserById(shop2.getAppUserId());
                 if(null != sjShopAppUser){
-                    BigDecimal balance = sjShopAppUser.getBalance();
                     BigDecimal shopBalance = shop2.getBalance();
                     Integer lavePoint = sjShopAppUser.getLavePoint();
                     Integer shopLavePoint = shop2.getLavePoint();
@@ -517,19 +493,6 @@
                     appUserClient.editAppUserById(sjShopAppUser);
                     shopClient.updateShop(shop2);
                     //添加明细记录
-                    if(!sjShopAppUser.getBalance().equals(balance)){
-                        BalanceChangeRecord balanceChangeRecord = new BalanceChangeRecord();
-                        balanceChangeRecord.setAppUserId(sjShopAppUser.getId());
-                        balanceChangeRecord.setOrderId(order.getId());
-                        balanceChangeRecord.setChangeType(4);
-                        balanceChangeRecord.setBeforeAmount(balance);
-                        balanceChangeRecord.setChangeAmount(bdmdsj_price);
-                        balanceChangeRecord.setAfterAmount(sjShopAppUser.getBalance());
-                        balanceChangeRecord.setDelFlag(0);
-                        balanceChangeRecord.setCreateTime(LocalDateTime.now());
-                        balanceChangeRecordClient.saveBalanceChangeRecord(balanceChangeRecord);
-                    }
-        
                     if(!shop2.getBalance().equals(shopBalance)){
                         ShopBalanceStatement shopBalanceStatement = new ShopBalanceStatement();
                         shopBalanceStatement.setShopId(shop2.getId());

--
Gitblit v1.7.1