| | |
|---|
| | | 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.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; |
|---|
| | |
|---|
| | | 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; |
|---|
| | |
|---|
| | | private final VideoTagRefService videoTagRefService; |
|---|
| | | private final LmkFileService lmkFileService; |
|---|
| | | private final VideoAuditRecordService videoAuditRecordService; |
|---|
| | | private final MyCollectService myCollectService; |
|---|
| | | private final COSUtil cosUtil; |
|---|
| | | private final FootprintService footprintService; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * 添加 |
|---|
| | |
|---|
| | | // 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)); |
|---|
| | | // 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())); |
|---|
| | | }); |
|---|
| | | } |
|---|
| | | 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 |
|---|
| | | 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()); |
|---|
| | | footprintService.saveFootprint(footPrint); |
|---|
| | | return Result.ok(); |
|---|
| | | } |
|---|
| | | } |
|---|
