From ed76f62db481ab1a8c125cf01d5122d1e1606266 Mon Sep 17 00:00:00 2001
From: Pu Zhibing <393733352@qq.com>
Date: 星期三, 26 二月 2025 01:25:09 +0800
Subject: [PATCH] 修改分佣逻辑

---
 ruoyi-service/ruoyi-other/src/main/java/com/ruoyi/other/service/impl/ShopPointServiceImpl.java |   73 +++++++++++++++++-------------------
 1 files changed, 35 insertions(+), 38 deletions(-)

diff --git a/ruoyi-service/ruoyi-other/src/main/java/com/ruoyi/other/service/impl/ShopPointServiceImpl.java b/ruoyi-service/ruoyi-other/src/main/java/com/ruoyi/other/service/impl/ShopPointServiceImpl.java
index 18b4501..31f1e1d 100644
--- a/ruoyi-service/ruoyi-other/src/main/java/com/ruoyi/other/service/impl/ShopPointServiceImpl.java
+++ b/ruoyi-service/ruoyi-other/src/main/java/com/ruoyi/other/service/impl/ShopPointServiceImpl.java
@@ -15,6 +15,7 @@
 import com.ruoyi.other.vo.ShopPointStatistics;
 import com.ruoyi.system.api.domain.SysUser;
 import com.ruoyi.system.api.feignClient.SysUserClient;
+import io.swagger.models.auth.In;
 import org.springframework.stereotype.Service;
 
 import javax.annotation.Resource;
@@ -51,44 +52,40 @@
     public ShopPointStatistics statistics(IPage<ShopPoint> page, ShopPoint shopPoint) {
         Long userid = tokenService.getLoginUser().getUserid();
         SysUser sysUser = sysUserClient.getSysUser(userid).getData();
-        Integer sPoint = 0;
-        Integer shopCommissionPoint = 0;
-        Integer subShopCommissionPoint = 0;
-        Integer serverCommissionPoint = 0;
         if (sysUser.getRoleType()==1){
-            if (StringUtils.isNotEmpty(shopPoint.getShopName())){
 
-            }
-            if (StringUtils.isNotEmpty(shopPoint.getShopLeaderName())){
-
-            }
             ShopPointStatistics shopPointStatistics = new ShopPointStatistics();
             IPage<ShopPoint> shopPointIPage = this.baseMapper.queryShpointPage(page, shopPoint);
             shopPointStatistics.setShopPointIPage(shopPointIPage);
 
-            for (ShopPoint record : shopPointIPage.getRecords()) {
-                switch (record.getType()){
-                    case 1:
-                        sPoint += record.getVariablePoint();
 
-                        break;
-                    case 2:
-                        shopCommissionPoint += record.getVariablePoint();
+            List<ShopPoint> shopPointList = list();
+            Map<Integer, List<ShopPoint>> shopPointByTypeMap = shopPointList.stream().collect(Collectors.groupingBy(ShopPoint::getType));
+            shopPointByTypeMap.forEach((type, shopPoints) -> {
+                shopPoints.stream().map(ShopPoint::getVariablePoint).reduce(Integer::sum).ifPresent(sum -> {
+                    switch (type) {
+                        case 1:
+                            shopPointStatistics.setShopPoint(sum);
+                            break;
+                        case 2:
+                            shopPointStatistics.setShopCommissionPoint(sum);
+                            break;
+                        case 3:
+                            shopPointStatistics.setSubShopCommissionPoint(sum);
+                            break;
+                        default:
+                            break;
+                    }
+                });
+            });
 
-                        break;
-                    case 3:
-                        subShopCommissionPoint += record.getVariablePoint();
+            Integer point = shopPointStatistics.getShopPoint() == null ? 0 : shopPointStatistics.getShopPoint();
+            Integer shopCommissionPoint = shopPointStatistics.getShopCommissionPoint() == null ? 0 : shopPointStatistics.getShopCommissionPoint();
+            Integer setSubShopCommissionPoint = shopPointStatistics.getSubShopCommissionPoint() == null ? 0 : shopPointStatistics.getSubShopCommissionPoint();
+            Integer totalPoint = point + shopCommissionPoint + setSubShopCommissionPoint;
+            shopPointStatistics.setTotalPoint(totalPoint);
 
-                        break;
-                    case 4:
-                        serverCommissionPoint+= record.getVariablePoint();
-                        break;
-                }
-            }
-            shopPointStatistics.setTotalPoint(sPoint + shopCommissionPoint + subShopCommissionPoint+serverCommissionPoint);
-            shopPointStatistics.setShopPoint(sPoint);
-            shopPointStatistics.setShopCommissionPoint(shopCommissionPoint);
-            shopPointStatistics.setSubShopCommissionPoint(subShopCommissionPoint);
+
             LocalDateTime startTime = shopPoint.getStartTime();
             LocalDateTime endTime = shopPoint.getEndTime();
             if(null != startTime){
@@ -112,7 +109,7 @@
 
                     //服务积分
                     List<ShopPoint> collect1 = list.stream().filter(s -> s.getCreateTime().format(DateTimeFormatter.ofPattern("yyyy-MM-dd"))
-                            .equals(finalStartTime.format(DateTimeFormatter.ofPattern("yyyy-MM-dd"))) && s.getType() == 4).collect(Collectors.toList());
+                            .equals(finalStartTime.format(DateTimeFormatter.ofPattern("yyyy-MM-dd"))) && s.getType() == 1).collect(Collectors.toList());
                     map.put("fwjf", collect1.stream().mapToInt(ShopPoint::getVariablePoint).sum());
                     //绑定下级门店返佣积分
                     List<ShopPoint> collect2 = list.stream().filter(s -> s.getCreateTime().format(DateTimeFormatter.ofPattern("yyyy-MM-dd"))
@@ -129,14 +126,14 @@
             return shopPointStatistics;
         }else{
             Shop shop = shopService.getById(sysUser.getObjectId());
-            sPoint += shop.getServerPoint();
-            shopCommissionPoint += shop.getSharePoint();
-            subShopCommissionPoint += shop.getLowerLevelSharePoint();
+            Integer serverPoint = shop.getServerPoint();
+            Integer sharePoint = shop.getSharePoint();
+            Integer lowerLevelSharePoint = shop.getLowerLevelSharePoint();
             ShopPointStatistics shopPointStatistics = new ShopPointStatistics();
-            shopPointStatistics.setTotalPoint(sPoint + shopCommissionPoint + subShopCommissionPoint);
-            shopPointStatistics.setShopPoint(sPoint);
-            shopPointStatistics.setShopCommissionPoint(shopCommissionPoint);
-            shopPointStatistics.setSubShopCommissionPoint(subShopCommissionPoint);
+            shopPointStatistics.setTotalPoint(serverPoint + sharePoint + lowerLevelSharePoint);
+            shopPointStatistics.setShopPoint(serverPoint);
+            shopPointStatistics.setShopCommissionPoint(sharePoint);
+            shopPointStatistics.setSubShopCommissionPoint(lowerLevelSharePoint);
 
             IPage<ShopPoint> shopPointIPage = this.baseMapper.queryShpointPage(page, shopPoint);
             shopPointStatistics.setShopPointIPage(shopPointIPage);
@@ -164,7 +161,7 @@
 
                     //服务积分
                     List<ShopPoint> collect1 = list.stream().filter(s -> s.getCreateTime().format(DateTimeFormatter.ofPattern("yyyy-MM-dd"))
-                            .equals(finalStartTime.format(DateTimeFormatter.ofPattern("yyyy-MM-dd"))) && s.getType() == 4).collect(Collectors.toList());
+                            .equals(finalStartTime.format(DateTimeFormatter.ofPattern("yyyy-MM-dd"))) && s.getType() == 1).collect(Collectors.toList());
                     map.put("fwjf", collect1.stream().mapToInt(ShopPoint::getVariablePoint).sum());
                     //绑定下级门店返佣积分
                     List<ShopPoint> collect2 = list.stream().filter(s -> s.getCreateTime().format(DateTimeFormatter.ofPattern("yyyy-MM-dd"))

--
Gitblit v1.7.1