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