绿满筐商城java服务
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
peng
1 天以前 672637fa4a4914ec9667cb15f70b67482b8a0e5e 
 framework/src/main/java/cn/lili/modules/member/serviceimpl/FootprintServiceImpl.java


@@ -2,19 +2,18 @@




import cn.lili.base.Result;


import cn.lili.common.security.context.UserContext;


import cn.lili.common.utils.StringUtils;


import cn.lili.modules.goods.entity.dos.GoodsSku;


import cn.lili.modules.goods.service.GoodsSkuService;


import cn.lili.modules.lmk.domain.query.FootPrintQuery;


import cn.lili.modules.lmk.domain.vo.SimpleVideoTagVO;


import cn.lili.modules.lmk.domain.vo.VideoFootInfoVo;


import cn.lili.modules.lmk.domain.vo.VideoFootVO;


import cn.lili.modules.lmk.domain.vo.VideoVO;


import cn.lili.modules.lmk.domain.vo.*;


import cn.lili.modules.lmk.mapper.VideoMapper;


import cn.lili.modules.member.entity.dos.FootPrint;


import cn.lili.modules.member.entity.dto.FootPrintQueryParams;


import cn.lili.modules.member.mapper.FootprintMapper;


import cn.lili.modules.member.service.FootprintService;


import cn.lili.modules.search.entity.dos.EsGoodsIndex;


import cn.lili.modules.statistics.entity.dto.StatisticsQueryParam;


import cn.lili.mybatis.util.PageUtil;


import cn.lili.utils.COSUtil;


import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;


@@ -28,6 +27,7 @@




import java.math.BigDecimal;


import java.math.RoundingMode;


import java.text.SimpleDateFormat;


import java.util.*;


import java.util.stream.Collectors;


import java.util.stream.IntStream;


@@ -168,7 +168,151 @@


        return this.count(lambdaQueryWrapper);


    }




    @Override


    public Result getViewAndCompletionRateCount(StatisticsQueryParam queryParam) {


        Date startTime = null;


        Date endTime = new Date(); // 结束时间默认是当前时间


        List<String> dateList = new ArrayList<>();




        Calendar calendar = Calendar.getInstance(); // 用于日期计算的日历实例


        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");


        int days = 0;


        switch (queryParam.getSearchType()) {


            case "TODAY":


                // 今天：从今天0点到现在


                calendar.setTime(new Date()); // 重置为当前时间


                calendar.set(Calendar.HOUR_OF_DAY, 0); // 小时设为0（24小时制）


                calendar.set(Calendar.MINUTE, 0);      // 分钟设为0


                calendar.set(Calendar.SECOND, 0);      // 秒设为0


                calendar.set(Calendar.MILLISECOND, 0); // 毫秒设为0


                startTime = calendar.getTime();        // 得到今天0点的Date对象


                dateList.add(sdf.format(startTime));


                break;


            case "YESTERDAY":


                // 昨天：从昨天0点到昨天23:59:59.999


                calendar.setTime(new Date());


                calendar.add(Calendar.DATE, -1); // 日期减1天（变为昨天）




                // 设置昨天0点


                calendar.set(Calendar.HOUR_OF_DAY, 0);


                calendar.set(Calendar.MINUTE, 0);


                calendar.set(Calendar.SECOND, 0);


                calendar.set(Calendar.MILLISECOND, 0);


                startTime = calendar.getTime();




                // 设置昨天23:59:59.999


                calendar.set(Calendar.HOUR_OF_DAY, 23);


                calendar.set(Calendar.MINUTE, 59);


                calendar.set(Calendar.SECOND, 59);


                calendar.set(Calendar.MILLISECOND, 999);


                endTime = calendar.getTime();




                dateList.add(sdf.format(startTime));


                break;


            case "LAST_SEVEN":


                // 过去七天：从7天前0点到现在（含今天共7天）


                calendar.setTime(new Date());


                calendar.add(Calendar.DATE, -6); // 日期减6天（7天前的今天）




                // 设置7天前0点


                calendar.set(Calendar.HOUR_OF_DAY, 0);


                calendar.set(Calendar.MINUTE, 0);


                calendar.set(Calendar.SECOND, 0);


                calendar.set(Calendar.MILLISECOND, 0);


                startTime = calendar.getTime();




                days = 7;


                // 循环生成7天的日期字符串


                Calendar tempCalendar = Calendar.getInstance();


                tempCalendar.setTime(startTime);


                for (int i = 0; i < days; i++) {


                    dateList.add(sdf.format(tempCalendar.getTime()));


                    tempCalendar.add(Calendar.DATE, 1); // 每天累加1天


                }


                break;


            case "LAST_THIRTY":


                // 过去30天：从30天前0点到现在（含今天共30天）


                calendar.setTime(new Date());


                calendar.add(Calendar.DATE, -29); // 日期减29天（30天前的今天）




                // 设置30天前0点


                calendar.set(Calendar.HOUR_OF_DAY, 0);


                calendar.set(Calendar.MINUTE, 0);


                calendar.set(Calendar.SECOND, 0);


                calendar.set(Calendar.MILLISECOND, 0);


                startTime = calendar.getTime();




                days = 30;


                // 循环生成30天的日期字符串


                Calendar tempCalendar30 = Calendar.getInstance();


                tempCalendar30.setTime(startTime);


                for (int i = 0; i < days; i++) {


                    dateList.add(sdf.format(tempCalendar30.getTime()));


                    tempCalendar30.add(Calendar.DATE, 1); // 每天累加1天


                }


                break;


            default:


                return Result.error("不支持的时间范围类型");


        }


        if ("goods".equals(queryParam.getCurrentType())){


            List<Map<String, Object>> maps = baseMapper.selectViewAndCompletionRateCountByDay(startTime, endTime,queryParam.getCurrentLimit());


            Map<String,Long> viewPrintMap = maps.stream()


                    .collect(Collectors.toMap(


                            map -> {


                                String goodsId = Objects.toString(map.get("GoodsId"), ""); // 空值处理


                                String goodsName = Objects.toString(map.get("GoodsName"), ""); // 空值处理


                                return goodsName + " | " + goodsId; // 用|分隔，方便后续拆分


                            },


                            map-> Long.valueOf(map.get("view_count").toString()),


                            (existing, replacement) -> existing,


                            LinkedHashMap::new  // 指定使用 LinkedHashMap，保留插入顺序


                    ));


            List<String> yData = new ArrayList<>();


            List<Long> xData = new ArrayList<>();




            for (Map.Entry<String, Long> entry : viewPrintMap.entrySet()){


                yData.add(entry.getKey());


                xData.add(entry.getValue());


            }


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


            data.put("yData", yData);


            data.put("xData", xData);


            return Result.ok().data(data);


        }else{


            List<Map<String, Object>> maps = baseMapper.selectEachVideoStats(startTime, endTime,queryParam.getCurrentLimit());


            Map<String, VideoViewCompletionRateVO> viewPrintMap = maps.stream()


                    .collect(Collectors.toMap(


                            map -> {


                                String videoId = Objects.toString(map.get("video_id"), ""); // 空值处理


                                String videoName = Objects.toString(map.get("title"), ""); // 空值处理


                                return videoName + " | " + videoId; // 用|分隔，方便后续拆分


                            },


                            map-> {


                                VideoViewCompletionRateVO vo = new VideoViewCompletionRateVO();


                                vo.setTotal_views(Long.valueOf(map.get("total_views").toString()));


                                vo.setComplete_rate(map.get("complete_rate").toString());


                                return vo;


                            },


                            (existing, replacement) -> existing,


                            LinkedHashMap::new  // 指定使用 LinkedHashMap，保留插入顺序


                    ));


            List<String> yData = new ArrayList<>();


            List<Long> xData = new ArrayList<>();


            List<String> rateData = new ArrayList<>();




            for (Map.Entry<String, VideoViewCompletionRateVO> entry : viewPrintMap.entrySet()){


                yData.add(entry.getKey());


                xData.add(entry.getValue().getTotal_views());


                rateData.add(entry.getValue().getComplete_rate());


            }


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


            data.put("yData", yData);


            data.put("xData", xData);


            data.put("rateData", rateData);


            return Result.ok().data(data);


        }




    }






}