From fd7b8fb7c89832c28a838b0449bbb8a392433ee2 Mon Sep 17 00:00:00 2001
From: Pu Zhibing <393733352@qq.com>
Date: 星期二, 22 四月 2025 14:33:02 +0800
Subject: [PATCH] 将华为云短信替换成阿里云短信

---
 ruoyi-service/ruoyi-other/src/main/java/com/ruoyi/other/service/impl/ShopPointServiceImpl.java |  221 +++++++++++++++++++++++++++++++++++++++++++-----------
 1 files changed, 174 insertions(+), 47 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 9e2354a..7d435f6 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
@@ -1,22 +1,35 @@
 package com.ruoyi.other.service.impl;
 
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
-import com.ruoyi.account.api.feignClient.AppUserClient;
-import com.ruoyi.account.api.model.AppUser;
 import com.ruoyi.common.core.utils.StringUtils;
+import com.ruoyi.common.core.web.page.PageInfo;
+import com.ruoyi.common.security.service.TokenService;
 import com.ruoyi.other.api.domain.Shop;
-import com.ruoyi.other.mapper.ShopPointMapper;
+import com.ruoyi.other.api.domain.ShopGiveawayTemporary;
 import com.ruoyi.other.api.domain.ShopPoint;
+import com.ruoyi.other.api.domain.ShopPointCopy;
+import com.ruoyi.other.api.enums.PointChangeType;
+import com.ruoyi.other.mapper.ShopGiveawayTemporaryMapper;
+import com.ruoyi.other.mapper.ShopPointCopyMapper;
+import com.ruoyi.other.mapper.ShopPointMapper;
 import com.ruoyi.other.service.ShopPointService;
 import com.ruoyi.other.service.ShopService;
 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 org.springframework.util.CollectionUtils;
 
 import javax.annotation.Resource;
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
+import java.util.ArrayList;
+import java.util.HashMap;
 import java.util.List;
+import java.util.Map;
 import java.util.stream.Collectors;
 
 /**
@@ -29,61 +42,175 @@
  */
 @Service
 public class ShopPointServiceImpl extends ServiceImpl<ShopPointMapper, ShopPoint> implements ShopPointService {
+
     @Resource
-    private ShopPointMapper shopPointMapper;
+    private TokenService tokenService;
+    @Resource
+    private SysUserClient sysUserClient;
     @Resource
     private ShopService shopService;
+    @Resource
+    private ShopGiveawayTemporaryMapper shopGiveawayTemporaryMapper;
+    
+    @Resource
+    private ShopPointCopyMapper shopPointCopyMapper;
+    
+
+
+
 
     @Override
     public ShopPointStatistics statistics(IPage<ShopPoint> page, ShopPoint shopPoint) {
+        Long userid = tokenService.getLoginUser().getUserid();
+        SysUser sysUser = sysUserClient.getSysUser(userid).getData();
+        if (sysUser.getRoleType()==1){
 
-        String shopName = shopPoint.getShopName();
-        String phone = shopPoint.getPhone();
-        String shopLeaderName = shopPoint.getShopLeaderName();
-        if (StringUtils.isNotEmpty(shopName) || StringUtils.isNotEmpty(phone) || StringUtils.isNotEmpty(shopLeaderName)) {
-            List<Integer> shopIds = shopService.listObjs(new LambdaQueryWrapper<Shop>()
-                            .select(Shop::getId)
-                            .like(StringUtils.isNotEmpty(shopName), Shop::getName, shopName)
-                            .like(StringUtils.isNotEmpty(phone), Shop::getPhone, phone)
-                            .like(StringUtils.isNotEmpty(shopLeaderName), Shop::getShopManager, shopLeaderName))
-                    .stream().map(o -> (Integer) o).collect(Collectors.toList());
+            ShopPointStatistics shopPointStatistics = new ShopPointStatistics();
+            shopPointStatistics.setTotalPoint(0);
+            shopPointStatistics.setSubShopCommissionPoint(0);
+            shopPointStatistics.setShopPoint(0);
+            shopPointStatistics.setShopCommissionPoint(0);
+            
+            IPage<ShopPoint> shopPointIPage = this.baseMapper.queryShpointPage(page, shopPoint);
+            shopPointIPage.getRecords().forEach(s->s.setVariablePoint(s.getVariablePoint() * s.getChangeDirection()));
+            shopPointStatistics.setShopPointIPage(shopPointIPage);
+    
+            IPage<ShopPoint> page1 = new PageInfo<>(0, 100000);
+            IPage<ShopPoint> shopPointIPage1 = this.baseMapper.queryShpointPage(page1, shopPoint);
+            List<ShopPoint> shopPointList = shopPointIPage1.getRecords();
+            shopPointList.forEach(s->s.setVariablePoint(s.getVariablePoint() * s.getChangeDirection()));
+            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;
+                    }
+                });
+            });
 
-            shopPoint.setShopIds(shopIds);
-        }
+            LocalDateTime startTime = shopPoint.getStartTime();
+            LocalDateTime endTime = shopPoint.getEndTime();
+            if(null != startTime){
+                List<ShopPoint> list = this.list(new LambdaUpdateWrapper<ShopPoint>()
+                        .eq(ShopPoint::getShopId, sysUser.getObjectId())
+                        .last(" and create_time between '" + startTime.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")) + "' and '" + endTime.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")) + "'"));
+                List<String> date = new ArrayList<>();
+                List<Map<String, Integer>> data = new ArrayList<>();
+                String format = "MM.dd";
+                while (true){
+                    if(startTime.isAfter(endTime)){
+                        break;
+                    }
+                    date.add(startTime.format(DateTimeFormatter.ofPattern(format)));
+                    Map<String, Integer> map = new HashMap<>();
+                    //返佣积分
+                    LocalDateTime finalStartTime = startTime;
+                    List<ShopPoint> collect = list.stream().filter(s -> s.getCreateTime().format(DateTimeFormatter.ofPattern("yyyy-MM-dd"))
+                            .equals(finalStartTime.format(DateTimeFormatter.ofPattern("yyyy-MM-dd"))) && s.getType() == 2).collect(Collectors.toList());
+                    map.put("fyjf", collect.stream().mapToInt(ShopPoint::getVariablePoint).sum());
 
-
-        ShopPointStatistics shopPointStatistics = new ShopPointStatistics();
-        List<ShopPoint> latestChangeByType = shopPointMapper.findLatestChangeByType(shopPoint);
-        for (ShopPoint sp : latestChangeByType) {
-            switch (sp.getType()) {
-                case 1:
-                    shopPointStatistics.setShopPoint(sp.getVariablePoint());
-                    break;
-                case 2:
-                    shopPointStatistics.setShopCommissionPoint(sp.getVariablePoint());
-                    break;
-                case 3:
-                    shopPointStatistics.setSubShopCommissionPoint(sp.getVariablePoint());
-                    break;
+                    //服务积分
+                    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() == 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"))
+                            .equals(finalStartTime.format(DateTimeFormatter.ofPattern("yyyy-MM-dd"))) && s.getType() == 3).collect(Collectors.toList());
+                    map.put("xjmdfyjf", collect2.stream().mapToInt(ShopPoint::getVariablePoint).sum());
+                    data.add(map);
+                    startTime = startTime.plusDays(1);
+                }
+                Map<String, Object> brokenLine = new HashMap<>();
+                brokenLine.put("date", date);
+                brokenLine.put("data", data);
+                shopPointStatistics.setBrokenLine(brokenLine);
             }
-        }
-        shopPointStatistics.setTotalPoint(shopPointStatistics.getShopPoint() + shopPointStatistics.getShopCommissionPoint() + shopPointStatistics.getSubShopCommissionPoint());
+    
+            Integer shopPoint1 = shopPointStatistics.getShopPoint();
+            Integer shopCommissionPoint = shopPointStatistics.getShopCommissionPoint();
+            Integer subShopCommissionPoint = shopPointStatistics.getSubShopCommissionPoint();
+            shopPointStatistics.setTotalPoint(shopPoint1 + shopCommissionPoint + subShopCommissionPoint);
+            return shopPointStatistics;
+        }else{
+            Shop shop = shopService.getById(sysUser.getObjectId());
+            List<ShopGiveawayTemporary> list1 = shopGiveawayTemporaryMapper.selectList(new LambdaQueryWrapper<ShopGiveawayTemporary>().eq(ShopGiveawayTemporary::getShopId, shop.getId()));
+            int serverPointCopy = list1.stream().mapToInt(ShopGiveawayTemporary::getServerPoint).sum();
+            int sharePointCopy = list1.stream().mapToInt(ShopGiveawayTemporary::getSharePoint).sum();
+            int lowerLevelSharePointCopy = list1.stream().mapToInt(ShopGiveawayTemporary::getLowerLevelSharePoint).sum();
+            shopPoint.setShopId(shop.getId());
+            Integer serverPoint = shop.getServerPoint() + serverPointCopy;
+            Integer sharePoint = shop.getSharePoint() + sharePointCopy;
+            Integer lowerLevelSharePoint = shop.getLowerLevelSharePoint() + lowerLevelSharePointCopy;
+            ShopPointStatistics shopPointStatistics = new ShopPointStatistics();
+            shopPointStatistics.setTotalPoint(serverPoint + sharePoint + lowerLevelSharePoint);
+            shopPointStatistics.setShopPoint(serverPoint);
+            shopPointStatistics.setShopCommissionPoint(sharePoint);
+            shopPointStatistics.setSubShopCommissionPoint(lowerLevelSharePoint);
 
+            IPage<ShopPoint> shopPointIPage = this.baseMapper.queryShpointPage(page, shopPoint);
+            shopPointIPage.getRecords().forEach(s->s.setVariablePoint(s.getVariablePoint() * s.getChangeDirection()));
+            shopPointStatistics.setShopPointIPage(shopPointIPage);
 
-        boolean condition = shopPoint.getStartTime() != null && shopPoint.getEndTime() != null;
-        IPage<ShopPoint> shopPointIPage = page(page, new LambdaQueryWrapper<ShopPoint>()
-                .in(!CollectionUtils.isEmpty(shopPoint.getShopIds()), ShopPoint::getShopId, shopPoint.getShopIds())
-                .eq(shopPoint.getType() != null, ShopPoint::getType, shopPoint.getType())
-                .between(condition, ShopPoint::getCreateTime, shopPoint.getStartTime(), shopPoint.getEndTime())
-                .orderByDesc(ShopPoint::getCreateTime));
-        List<ShopPoint> shopPoints = shopPointIPage.getRecords();
-        for (ShopPoint sp : shopPoints) {
-            Shop shop = shopService.getById(sp.getShopId());
-            sp.setShopName(shop.getName());
-            sp.setShopLeaderName(shop.getShopManager());
-            sp.setPhone(shop.getPhone());
+            LocalDateTime startTime = shopPoint.getStartTime();
+            LocalDateTime endTime = shopPoint.getEndTime();
+            if(null != startTime){
+                List<ShopPoint> list = this.list(new LambdaUpdateWrapper<ShopPoint>()
+                        .eq(ShopPoint::getShopId, sysUser.getObjectId())
+                        .last(" and create_time between '" + startTime.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")) + "' and '" + endTime.format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")) + "'"));
+                List<String> date = new ArrayList<>();
+                List<Map<String, Integer>> data = new ArrayList<>();
+                String format = "MM.dd";
+                while (true){
+                    if(startTime.isAfter(endTime)){
+                        break;
+                    }
+                    date.add(startTime.format(DateTimeFormatter.ofPattern(format)));
+                    Map<String, Integer> map = new HashMap<>();
+                    //返佣积分
+                    LocalDateTime finalStartTime = startTime;
+                    List<ShopPoint> collect = list.stream().filter(s -> s.getCreateTime().format(DateTimeFormatter.ofPattern("yyyy-MM-dd"))
+                            .equals(finalStartTime.format(DateTimeFormatter.ofPattern("yyyy-MM-dd"))) && s.getType() == 2).collect(Collectors.toList());
+                    map.put("fyjf", collect.stream().mapToInt(ShopPoint::getVariablePoint).sum());
+
+                    //服务积分
+                    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() == 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"))
+                            .equals(finalStartTime.format(DateTimeFormatter.ofPattern("yyyy-MM-dd"))) && s.getType() == 3).collect(Collectors.toList());
+                    map.put("xjmdfyjf", collect2.stream().mapToInt(ShopPoint::getVariablePoint).sum());
+                    data.add(map);
+                    startTime = startTime.plusDays(1);
+                }
+                Map<String, Object> brokenLine = new HashMap<>();
+                brokenLine.put("date", date);
+                brokenLine.put("data", data);
+                shopPointStatistics.setBrokenLine(brokenLine);
+            }
+            return shopPointStatistics;
         }
-        shopPointStatistics.setShopPointIPage(shopPointIPage);
-        return shopPointStatistics;
+    }
+    
+    
+    /**
+     * 获取门店积分流水
+     * @param page
+     * @param shopPoint
+     * @return
+     */
+    @Override
+    public IPage<ShopPoint> getShopPointPage(IPage<ShopPoint> page, ShopPoint shopPoint) {
+        return this.baseMapper.queryShpointPage(page, shopPoint);
     }
 }

--
Gitblit v1.7.1