From 8fee151ffae0c3818694b7318583814bf92663e2 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期五, 27 八月 2021 18:52:28 +0800
Subject: [PATCH] 聚合视频资源包调整,接入韩迷

---
 src/main/java/com/yeshi/buwan/job/video/TencentVideoUpdate.java |   31 ++++++++++++++++++++++---------
 1 files changed, 22 insertions(+), 9 deletions(-)

diff --git a/src/main/java/com/yeshi/buwan/job/video/TencentVideoUpdate.java b/src/main/java/com/yeshi/buwan/job/video/TencentVideoUpdate.java
index 77968de..386c236 100644
--- a/src/main/java/com/yeshi/buwan/job/video/TencentVideoUpdate.java
+++ b/src/main/java/com/yeshi/buwan/job/video/TencentVideoUpdate.java
@@ -2,15 +2,12 @@
 
 import com.xxl.job.core.biz.model.ReturnT;
 import com.xxl.job.core.handler.annotation.XxlJob;
-import com.yeshi.buwan.mogotv.MogoTVApiUtil;
-import com.yeshi.buwan.mogotv.entity.MogoTVClipInfo;
-import com.yeshi.buwan.mogotv.entity.MogoTVVideo;
-import com.yeshi.buwan.service.inter.juhe.MogoTVService;
 import com.yeshi.buwan.service.inter.juhe.TencentVideoService;
-import com.yeshi.buwan.tencent.TencentVideoApiUtil;
-import com.yeshi.buwan.tencent.TencentVideoUtil;
-import com.yeshi.buwan.tencent.entity.TencentCoverInfo;
+import com.yeshi.buwan.videos.tencent.TencentVideoApiUtil;
+import com.yeshi.buwan.videos.tencent.entity.TencentCoverInfo;
 import com.yeshi.buwan.util.StringUtil;
+import com.yeshi.buwan.util.video.web.TencentWebUtil;
+import net.sf.json.JSONObject;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.stereotype.Component;
@@ -36,15 +33,20 @@
         int totalPage = 50;
         for (int i = 0; i < totalPage; i++) {
             List<TencentCoverInfo> coverInfoList = TencentVideoApiUtil.getVideoListByCategory(channel, i + 1);
+            save(coverInfoList);
+        }
+    }
+
+    private void save(List<TencentCoverInfo> coverInfoList) {
+        if (coverInfoList != null)
             for (TencentCoverInfo coverInfo : coverInfoList) {
-                System.out.println(coverInfo.getTitle()+":"+coverInfo.getCover_id());
+                System.out.println(coverInfo.getTitle() + ":" + coverInfo.getCover_id());
                 try {
                     tencentVideoService.addToInternetSearch(coverInfo);
                 } catch (Exception e) {
                     e.printStackTrace();
                 }
             }
-        }
     }
 
     private String getChannel(String cate) throws Exception {
@@ -87,6 +89,17 @@
     }
 
 
+    @XxlJob("video-update-tencent-updateVideo-byweburl")
+    public ReturnT<String> updateLatestVideoByWebUrl(String param) throws Exception {
+        JSONObject json = JSONObject.fromObject(param);
+        int page = json.optInt("page");
+        String url = json.optString("url");
+        List<TencentCoverInfo> list = TencentVideoApiUtil.getVideoList(TencentWebUtil.getApiUrl(url, page));
+        save(list);
+        return ReturnT.SUCCESS;
+    }
+
+
     /**
      * 鏇存柊鍗曚釜瑙嗛
      *

--
Gitblit v1.8.0