绿满筐商城java服务
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
xiangpei
2025-06-03 95f8eda23ff06243e68d33769c5e68f6f6de2c4b 
 framework/src/main/java/cn/lili/modules/lmk/service/impl/VideoServiceImpl.java


@@ -1,17 +1,20 @@


package cn.lili.modules.lmk.service.impl;




import cn.lili.base.AbsQuery;


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


import cn.lili.modules.lmk.domain.entity.VideoAuditRecord;


import cn.lili.modules.lmk.domain.entity.VideoTag;


import cn.lili.modules.lmk.domain.entity.VideoTagRef;


import cn.lili.modules.lmk.domain.form.VideoAuditingForm;


import cn.lili.modules.lmk.domain.form.VideoDownForm;


import cn.lili.modules.lmk.domain.form.VideoRecommendForm;


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


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


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


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


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


import cn.lili.modules.lmk.enums.general.TagCreateTypeEnum;


import cn.lili.modules.lmk.enums.general.VideoStatusEnum;


import cn.lili.modules.lmk.enums.general.ViewTypeEnum;


import cn.lili.modules.lmk.service.*;


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


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


import cn.lili.utils.COSUtil;


import com.baomidou.mybatisplus.core.metadata.IPage;


import cn.lili.modules.lmk.domain.entity.Video;


@@ -20,9 +23,9 @@


import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper;


import com.baomidou.mybatisplus.extension.conditions.update.LambdaUpdateChainWrapper;


import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;


import cn.lili.modules.lmk.domain.form.VideoForm;


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


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


import org.apache.commons.collections4.CollectionUtils;


import org.apache.commons.collections4.ListUtils;


import org.apache.commons.lang3.StringUtils;


import org.springframework.stereotype.Service;


import lombok.RequiredArgsConstructor;


@@ -49,7 +52,10 @@


    private final VideoTagRefService videoTagRefService;


    private final LmkFileService lmkFileService;


    private final VideoAuditRecordService videoAuditRecordService;


    private final MyCollectService myCollectService;


    private final COSUtil cosUtil;


    private final FootprintService footprintService;


    private final MySubscribeService mySubscribeService;




    /**


     * 添加


@@ -148,6 +154,7 @@


        Video video = VideoForm.getEntityByForm(form, null);


        video.setAuthorId(UserContext.getCurrentUserId());


        video.setStatus(VideoStatusEnum.AUDITING.getValue());


        video.setCoverUrl(form.getCover());


        baseMapper.insert(video);


        // 2.处理标签


        List<VideoTagRef> videoTagRefs = form.getTags().stream().map(tag -> {


@@ -191,7 +198,7 @@


            // 3. 获取视频临时访问地址、设置视频标签


            page.getRecords().forEach(v -> {


                v.setTagList(tagMap.get(v.getId()));


//                v.setVideoUrl(cosUtil.getPreviewUrl(v.getVideoFileKey()));


                v.setCoverUrl(cosUtil.getPreviewUrl(v.getCoverUrl()));


            });


        }


        return Result.ok().data(page.getRecords()).total(page.getTotal());


@@ -252,4 +259,99 @@


        // TODO 将下架原因以通知的方式告知用户


        return Result.ok("下架成功");


    }




    @Override


    public Result recommendVideo(AbsQuery query) {


        // 推荐算法： 1. 根据用户的收藏视频的标签  2. 根据用户关注的作者的其它视频  3. 根据用户的观看记录（观看时长较长的、重复观看次数较多的） 4. 基于相似用户的观看行为来给该用户推荐


        IPage<WxVideoVO> page = PageUtil.getPage(query, WxVideoVO.class);


        baseMapper.recommendVideo(page);


        if (page.getTotal() > 0) {


            List<String> videoIds = page.getRecords().stream().map(WxVideoVO::getId).collect(Collectors.toList());


            Map<String, List<SimpleVideoTagVO>> tagMap = videoTagRefService.getTagsByVideoIds(videoIds)


                    .stream()


                    .collect(Collectors.groupingBy(SimpleVideoTagVO::getVideoId));


            Map<String, List<SimpleMyCollectVO>> collectMap =myCollectService.getCollectsByVideoIds(videoIds)


                    .stream()


                    .collect(Collectors.groupingBy(SimpleMyCollectVO::getRefId));


            List<String> subscribes = mySubscribeService.getSubscribesByUserId(UserContext.getCurrentUserId());


            // 3. 获取视频临时访问地址、设置视频标签、我是否收藏、作者是否关注


            page.getRecords().forEach(v -> {


                v.setGoods(new VideoGoodsVO());


                v.setTagList(tagMap.get(v.getId()));


                v.setCollected(CollectionUtils.isNotEmpty(collectMap.get(v.getId())));


                v.setVideoUrl(cosUtil.getPreviewUrl(v.getVideoFileKey()));


                v.setSubscribeThisAuthor(subscribes.contains(v.getAuthorId()));


            });


        }


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


    }




    @Override


    @Transactional(rollbackFor = Exception.class)


    public void updateCollectNumBatch(List<CollectTypeNumVO> numList) {


        // 按500条数据进行拆分


        List<List<CollectTypeNumVO>> chunks = ListUtils.partition(numList, 500);


        for (List<CollectTypeNumVO> chunk : chunks) {


            baseMapper.updateCollectNumBatch(chunk);


        }


    }




    @Override


    @Transactional(rollbackFor = Exception.class)


    public void updateCommentNumBatch(List<CollectTypeNumVO> numList) {


        // 按500条数据进行拆分


        List<List<CollectTypeNumVO>> chunks = ListUtils.partition(numList, 500);


        for (List<CollectTypeNumVO> chunk : chunks) {


            baseMapper.updateCommentNumBatch(chunk);


        }


    }




    @Override


    public Result saveViewRecord(VideoFootPrintForm form) {


        FootPrint footPrint = new FootPrint();


        footPrint.setViewType(ViewTypeEnum.VIDEO.getValue());


        footPrint.setRefId(form.getVideoId());


        footPrint.setMemberId(UserContext.getCurrentUserId());


        footPrint.setViewDuration(form.getViewDuration());


        footPrint.setPlayAt(form.getPlayAt());


        footprintService.saveFootprint(footPrint);


        return Result.ok();


    }




    @Override


    public Result getAuthorInfo(String authorId) {


        VideoAccountVO vo = baseMapper.getAuthorInfo(authorId, UserContext.getCurrentUserId());


        vo.setSelf(authorId.equals(UserContext.getCurrentUserId()));


        // 查询获赞数


        List<String> videoIds = baseMapper.getVideoIdsByAuthor(authorId);


        if (CollectionUtils.isNotEmpty(videoIds)) {


            vo.setLikeNum(baseMapper.countAuthorVideoCollectNum(videoIds));


        } else {


            vo.setLikeNum(0L);


        }


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


    }




    @Override


    public Result getAuthorVideoPage(AuthorVideoQuery query) {


        IPage<WxVideoVO> page = PageUtil.getPage(query, WxVideoVO.class);


        baseMapper.getAuthorVideoPage(page, query);


        for (WxVideoVO vo : page.getRecords()) {


            vo.setCoverUrl(cosUtil.getPreviewUrl(vo.getCoverUrl()));


            vo.setVideoUrl(cosUtil.getPreviewUrl(vo.getVideoUrl()));


        }


        return Result.ok().data(page.getRecords()).total(page.getTotal());


    }




    @Override


    public Result getAuthorCollectVideoPage(AuthorVideoQuery query) {


        IPage<WxVideoVO> page = PageUtil.getPage(query, WxVideoVO.class);


        baseMapper.getAuthorCollectVideoPage(page, query);


        for (WxVideoVO vo : page.getRecords()) {


            vo.setCoverUrl(cosUtil.getPreviewUrl(vo.getCoverUrl()));


            vo.setVideoUrl(cosUtil.getPreviewUrl(vo.getVideoUrl()));


            vo.setCollected(Boolean.TRUE);


        }


        return Result.ok().data(page.getRecords()).total(page.getTotal());


    }


}