From cc134fa83edea4865b48d7afc1acda5ad70e7465 Mon Sep 17 00:00:00 2001
From: luodangjia <luodangjia>
Date: 星期一, 13 一月 2025 11:20:05 +0800
Subject: [PATCH] 12.18

---
 ruoyi-service/ruoyi-other/src/main/java/com/ruoyi/other/service/impl/ShopPointServiceImpl.java |   56 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 56 insertions(+), 0 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 f9e435f..883a4c3 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,14 +1,23 @@
 package com.ruoyi.other.service.impl;
 
+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.common.security.service.TokenService;
 import com.ruoyi.other.api.domain.ShopPoint;
 import com.ruoyi.other.api.enums.PointChangeType;
 import com.ruoyi.other.mapper.ShopPointMapper;
 import com.ruoyi.other.service.ShopPointService;
 import com.ruoyi.other.vo.ShopPointStatistics;
+import com.ruoyi.system.api.domain.SysUser;
+import com.ruoyi.system.api.feignClient.SysUserClient;
 import org.springframework.stereotype.Service;
 
+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;
@@ -24,8 +33,18 @@
 @Service
 public class ShopPointServiceImpl extends ServiceImpl<ShopPointMapper, ShopPoint> implements ShopPointService {
 
+    @Resource
+    private TokenService tokenService;
+    @Resource
+    private SysUserClient sysUserClient;
+
+
+
+
     @Override
     public ShopPointStatistics statistics(IPage<ShopPoint> page, ShopPoint shopPoint) {
+        Long userid = tokenService.getLoginUser().getUserid();
+        SysUser sysUser = sysUserClient.getSysUser(userid).getData();
         List<ShopPoint> shopPoints = this.baseMapper.selectShopPointList(shopPoint);
         Map<Integer, Integer> shopPointMap = shopPoints.stream()
                 .collect(Collectors.groupingBy(
@@ -45,6 +64,43 @@
         IPage<ShopPoint> shopPointIPage = this.baseMapper.queryShpointPage(page, shopPoint);
         shopPointStatistics.setShopPointIPage(shopPointIPage);
 
+        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() == 4).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;
     }
 }

--
Gitblit v1.7.1