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


@@ -1,11 +1,9 @@


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


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


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


@@ -13,10 +11,11 @@


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.entity.dos.Member;


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


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


import cn.lili.utils.COSUtil;


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


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


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


import cn.lili.base.Result;


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


@@ -55,6 +54,8 @@


    private final COSUtil cosUtil;


    private final FootprintService footprintService;


    private final MySubscribeService mySubscribeService;


    private final MemberService memberService;


    private final VideoAccountService videoAccountService;




    /**


     * 添加


@@ -153,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 -> {


@@ -196,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());


@@ -259,10 +261,26 @@


    }




    @Override


    public Result recommendVideo(AbsQuery query) {


    public Result recommendVideo(VideoQuery query) {


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


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


        baseMapper.recommendVideo(page);


        switch (query.getVideoFrom()) {


            case "recommend":


                baseMapper.recommendVideo(page);


                break;


            case "author":


                AuthorVideoQuery query1 = new AuthorVideoQuery();


                query1.setAuthorId(query.getAuthorId());


                baseMapper.getAuthorVideoPage(page, query1);


                break;


            case "collect":


                AuthorVideoQuery query2 = new AuthorVideoQuery();


                query2.setAuthorId(query.getAuthorId());


                baseMapper.getAuthorVideoPage(page, query2);


                break;


            default:


                break;


        }


        if (page.getTotal() > 0) {


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


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


@@ -278,6 +296,7 @@


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


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


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


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


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


            });


        }


@@ -315,4 +334,56 @@


        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.getCoverFileKey()));


            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.getCoverFileKey()));


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


            vo.setCollected(Boolean.TRUE);


        }


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


    }




    @Override


    @Transactional(rollbackFor = Exception.class)


    public Result homePageInfoEdit(VideoHomePageInfoForm form) {


        new LambdaUpdateChainWrapper<>(memberService.getBaseMapper())


                .eq(Member::getId, UserContext.getCurrentUserId())


                .set(Member::getNickName, form.getNickName())


                .set(Member::getFace, form.getAvatar())


                .update();


        new LambdaUpdateChainWrapper<>(videoAccountService.getBaseMapper())


                .eq(VideoAccount::getUserId, UserContext.getCurrentUserId())


                .set(VideoAccount::getMotto, form.getMotto())


                .update();


        return Result.ok("保存成功");


    }


}