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