From 4833a836e3c180275bc72d7023477c407e2e43f2 Mon Sep 17 00:00:00 2001
From: xiangpei <xiangpei@timesnew.cn>
Date: 星期二, 03 六月 2025 19:16:54 +0800
Subject: [PATCH] 注册用户时同时增加一个视频账户

---
 framework/src/main/java/cn/lili/modules/lmk/service/impl/VideoServiceImpl.java |   40 ++++++++++++++++++++++++++++++++++++----
 1 files changed, 36 insertions(+), 4 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..ef88f79 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,6 +1,5 @@
 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;
@@ -154,6 +153,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 +197,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 +260,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)
@@ -335,6 +351,22 @@
     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());
     }
 }

--
Gitblit v1.8.0