岐济生
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
Pu Zhibing
2025-03-25 d3e9a09cb54017a8063e5bfe3ace5012f66f3130 
 ruoyi-service/ruoyi-other/src/main/java/com/ruoyi/other/service/impl/ShopPointServiceImpl.java


@@ -1,15 +1,24 @@


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.common.core.utils.StringUtils;


import com.ruoyi.common.security.service.TokenService;


import com.ruoyi.other.api.domain.Shop;


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.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 javax.annotation.Resource;


import java.time.LocalDateTime;


import java.time.format.DateTimeFormatter;


import java.util.ArrayList;


@@ -29,63 +38,144 @@


@Service


public class ShopPointServiceImpl extends ServiceImpl<ShopPointMapper, ShopPoint> implements ShopPointService {




    @Resource


    private TokenService tokenService;


    @Resource


    private SysUserClient sysUserClient;


    @Resource


    private ShopService shopService;










    @Override


    public ShopPointStatistics statistics(IPage<ShopPoint> page, ShopPoint shopPoint) {


        List<ShopPoint> shopPoints = this.baseMapper.selectShopPointList(shopPoint);


        Map<Integer, Integer> shopPointMap = shopPoints.stream()


                .collect(Collectors.groupingBy(


                        ShopPoint::getType,


                        Collectors.summingInt(ShopPoint::getVariablePoint)


                ));


        Long userid = tokenService.getLoginUser().getUserid();


        SysUser sysUser = sysUserClient.getSysUser(userid).getData();


        if (sysUser.getRoleType()==1){




        ShopPointStatistics shopPointStatistics = new ShopPointStatistics();


        int sPoint = shopPointMap.getOrDefault(PointChangeType.SHOP_ACHIEVEMENT.getCode(), 0);


        int shopCommissionPoint = shopPointMap.getOrDefault(PointChangeType.SHOP_REBATE.getCode(), 0);


        int subShopCommissionPoint = shopPointMap.getOrDefault(PointChangeType.JUNIOR_SHOP_REBATE.getCode(), 0);


        shopPointStatistics.setTotalPoint(sPoint + shopCommissionPoint + subShopCommissionPoint);


        shopPointStatistics.setShopPoint(sPoint);


        shopPointStatistics.setShopCommissionPoint(shopCommissionPoint);


        shopPointStatistics.setSubShopCommissionPoint(subShopCommissionPoint);


            ShopPointStatistics shopPointStatistics = new ShopPointStatistics();


            IPage<ShopPoint> shopPointIPage = this.baseMapper.queryShpointPage(page, shopPoint);


            shopPointStatistics.setShopPointIPage(shopPointIPage);




        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, shopPoint.getShopId())


                    .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;


            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;


                    }


                });


            });




            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);






            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);


                }


                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);


            }


            Map<String, Object> brokenLine = new HashMap<>();


            brokenLine.put("date", date);


            brokenLine.put("data", data);


            shopPointStatistics.setBrokenLine(brokenLine);


            return shopPointStatistics;


        }else{


            Shop shop = shopService.getById(sysUser.getObjectId());


            Integer serverPoint = shop.getServerPoint();


            Integer sharePoint = shop.getSharePoint();


            Integer lowerLevelSharePoint = shop.getLowerLevelSharePoint();


            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);


            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() == 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;


        }


        return shopPointStatistics;


    }


}