lmk-shop-java.git

			@@ -1,24 +1,30 @@
			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.LmkFile;
			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.*;
			import cn.lili.modules.lmk.domain.query.ManagerVideoQuery;
			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.service.LmkFileService;
			import cn.lili.modules.lmk.service.VideoTagRefService;
			import cn.lili.modules.lmk.service.VideoTagService;
			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 cn.lili.modules.lmk.mapper.VideoMapper;
			import cn.lili.modules.lmk.service.VideoService;
			import cn.lili.base.Result;
			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;
			@@ -27,8 +33,7 @@
			import org.springframework.transaction.annotation.Transactional;
			import org.springframework.util.Assert;

			import java.util.List;
			import java.util.Objects;
			import java.util.*;
			import java.util.stream.Collectors;

			/**
			@@ -45,6 +50,11 @@
			private final VideoTagService videoTagService;
			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;

			/**
			* 添加
			@@ -114,9 +124,12 @@
			* @return
			*/
			@Override
			public Result detail(Integer id) {
			public Result detail(String id) {
			VideoVO vo = baseMapper.getById(id);
			Assert.notNull(vo, "记录不存在");
			List<SimpleVideoTagVO> tags = videoTagRefService.getTagsByVideoIds(Arrays.asList(id));
			vo.setTagList(tags);
			vo.setVideoUrl(cosUtil.getPreviewUrl(vo.getVideoFileKey()));
			return Result.ok().data(vo);
			}

			@@ -168,4 +181,138 @@
			lmkFileService.addByForm(form.getFileInfo());
			return Result.ok("发布成功，视频审核中~");
			}


			@Override
			public Result managerPage(ManagerVideoQuery query) {
			IPage<VideoVO> page = PageUtil.getPage(query, VideoVO.class);
			// 1. 先查出视频信息
			baseMapper.managerPage(page, query);
			// 2. 单独查出标签信息
			if (page.getTotal() > 0) {
			Map<String, List<SimpleVideoTagVO>> tagMap = videoTagRefService.getTagsByVideoIds(
			page.getRecords().stream().map(VideoVO::getId).collect(Collectors.toList())
			).stream().collect(Collectors.groupingBy(SimpleVideoTagVO::getVideoId));;
			// 3. 获取视频临时访问地址、设置视频标签
			page.getRecords().forEach(v -> {
			v.setTagList(tagMap.get(v.getId()));
			// v.setVideoUrl(cosUtil.getPreviewUrl(v.getVideoFileKey()));
			});
			}
			return Result.ok().data(page.getRecords()).total(page.getTotal());
			}

			@Override
			public Result recommendSet(VideoRecommendForm form) {
			new LambdaUpdateChainWrapper<>(baseMapper)
			.eq(Video::getId, form.getId())
			.set(Video::getRecommend, form.getRecommend())
			.update();
			return Result.ok("设置成功");
			}

			@Override
			@Transactional(rollbackFor = Exception.class)
			public Result auditing(VideoAuditingForm form) {
			Video video = baseMapper.selectById(form.getId());
			if (Objects.isNull(video)) {
			throw new RuntimeException("视频不存在");
			}
			// 1. 添加审核记录
			VideoAuditRecord auditRecord = new VideoAuditRecord();
			auditRecord.setVideoId(form.getId());
			auditRecord.setAuditSuccess(form.getResult());
			if (!form.getResult()) {
			auditRecord.setEditSuggestion(form.getReason());
			}
			videoAuditRecordService.save(auditRecord);
			// 2. 修改视频状态
			if (form.getResult()) {
			video.setStatus(VideoStatusEnum.PUBLISHED.getValue());
			video.setAuditPassTime(new Date());
			} else {
			video.setStatus(VideoStatusEnum.REJECT.getValue());
			}
			baseMapper.updateById(video);
			return Result.ok();
			}


			@Override
			public Result up(String id) {
			new LambdaUpdateChainWrapper<>(baseMapper)
			.eq(Video::getId, id)
			.set(Video::getStatus, VideoStatusEnum.PUBLISHED.getValue())
			.update();
			return Result.ok("上架成功");
			}


			@Override
			public Result down(VideoDownForm form) {
			new LambdaUpdateChainWrapper<>(baseMapper)
			.eq(Video::getId, form.getId())
			.set(Video::getStatus, VideoStatusEnum.DISABLE.getValue())
			.update();
			// 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();
			}
			}