From 05e49980cd556d24239e00d028dc5efa25e0de14 Mon Sep 17 00:00:00 2001
From: zxl <763096477@qq.com>
Date: 星期三, 11 六月 2025 11:50:07 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/dev' into dev
---
framework/src/main/java/cn/lili/modules/lmk/service/impl/VideoServiceImpl.java | 94 +++++++++++++++++++++++++++++++++++++++++++----
1 files changed, 86 insertions(+), 8 deletions(-)
diff --git a/framework/src/main/java/cn/lili/modules/lmk/service/impl/VideoServiceImpl.java b/framework/src/main/java/cn/lili/modules/lmk/service/impl/VideoServiceImpl.java
index fcc57e9..fd8bf5d 100644
--- a/framework/src/main/java/cn/lili/modules/lmk/service/impl/VideoServiceImpl.java
+++ b/framework/src/main/java/cn/lili/modules/lmk/service/impl/VideoServiceImpl.java
@@ -1,23 +1,22 @@
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;
import cn.lili.modules.lmk.enums.general.VideoStatusEnum;
+import cn.lili.modules.lmk.enums.general.VideoSupportOpEnum;
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;
@@ -56,6 +55,9 @@
private final COSUtil cosUtil;
private final FootprintService footprintService;
private final MySubscribeService mySubscribeService;
+ private final MemberService memberService;
+ private final VideoAccountService videoAccountService;
+
/**
* 娣诲姞
@@ -154,6 +156,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 -> {
@@ -197,7 +200,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());
@@ -260,10 +263,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.getAuthorCollectVideoPage(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)
@@ -279,6 +298,8 @@
v.setTagList(tagMap.get(v.getId()));
v.setCollected(CollectionUtils.isNotEmpty(collectMap.get(v.getId())));
v.setVideoUrl(cosUtil.getPreviewUrl(v.getVideoFileKey()));
+// v.setVideoUrl("https://videos.pexels.com/video-files/13602965/13602965-hd_1920_1080_30fps.mp4");
+ v.setCoverUrl(cosUtil.getPreviewUrl(v.getCoverFileKey()));
v.setSubscribeThisAuthor(subscribes.contains(v.getAuthorId()));
});
}
@@ -334,7 +355,64 @@
@Override
public Result getAuthorVideoPage(AuthorVideoQuery query) {
IPage<WxVideoVO> page = PageUtil.getPage(query, WxVideoVO.class);
+ query.setAuthorSelf(UserContext.getCurrentUserId().equals(query.getAuthorId()));
baseMapper.getAuthorVideoPage(page, query);
+ for (WxVideoVO vo : page.getRecords()) {
+ vo.setCoverUrl(cosUtil.getPreviewUrl(vo.getCoverFileKey()));
+ vo.setVideoUrl(cosUtil.getPreviewUrl(vo.getVideoFileKey()));
+// vo.setVideoUrl("https://videos.pexels.com/video-files/13602965/13602965-hd_1920_1080_30fps.mp4");
+ vo.setOptions(VideoSupportOpEnum.getVideoOpByStatus(vo.getStatus()));
+ }
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.getVideoFileKey()));
+// vo.setVideoUrl("https://videos.pexels.com/video-files/13602965/13602965-hd_1920_1080_30fps.mp4");
+ 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("淇濆瓨鎴愬姛");
+ }
+
+ @Override
+ public Result wxDetail(String id) {
+ WxEditVideoVO vo = baseMapper.wxDetail(id);
+ if (Objects.isNull(vo)) {
+ return Result.error("瑙嗛涓嶅瓨鍦�");
+ }
+ vo.setCoverUrl(cosUtil.getPreviewUrl(vo.getCoverFileKey()));
+ vo.setVideoUrl(cosUtil.getPreviewUrl(vo.getVideoFileKey()));
+// vo.setVideoUrl("https://videos.pexels.com/video-files/13602965/13602965-hd_1920_1080_30fps.mp4");
+ List<WxVideoTagForm> tags = videoTagRefService.getTagsByVideoIds(Arrays.asList(vo.getId()))
+ .stream()
+ .map(i -> {
+ WxVideoTagForm tag = new WxVideoTagForm();
+ tag.setTagName(i.getTagName());
+ tag.setId(i.getId());
+ return tag;
+ })
+ .collect(Collectors.toList());
+ vo.setTags(tags);
+ return Result.ok().data(vo);
+ }
}
--
Gitblit v1.8.0