From ab35ac8b769b2d9816dffb33a64f2c6f7bd5dd6e Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期四, 05 九月 2024 17:05:55 +0800
Subject: [PATCH] 风行网页版爬虫
---
src/main/java/com/yeshi/buwan/util/SpringContext.java | 22 ++++++++++++----------
1 files changed, 12 insertions(+), 10 deletions(-)
diff --git a/src/main/java/com/yeshi/buwan/util/SpringContext.java b/src/main/java/com/yeshi/buwan/util/SpringContext.java
index 63a2e29..2d0f49f 100644
--- a/src/main/java/com/yeshi/buwan/util/SpringContext.java
+++ b/src/main/java/com/yeshi/buwan/util/SpringContext.java
@@ -1,19 +1,18 @@
package com.yeshi.buwan.util;
import com.alibaba.druid.pool.DruidDataSource;
-import com.yeshi.buwan.dao.juhe.iqiyi.IqiyiAlbum2Dao;
import com.yeshi.buwan.dao.juhe.iqiyi.VideoIqiyi2Dao;
import com.yeshi.buwan.domain.ResourceVideo;
import com.yeshi.buwan.domain.VideoInfo;
import com.yeshi.buwan.domain.VideoResource;
import com.yeshi.buwan.domain.video.InternetSearchVideo;
import com.yeshi.buwan.dto.mq.*;
-import com.yeshi.buwan.funtv.entity.FunTVAlbum2;
-import com.yeshi.buwan.iqiyi.IqiYiNewAPI;
-import com.yeshi.buwan.iqiyi.entity.IqiyiAlbum2;
-import com.yeshi.buwan.iqiyi.entity.VideoIqiyi2;
-import com.yeshi.buwan.iqiyi.util.IqiyiUtil2;
-import com.yeshi.buwan.pptv.entity.PPTVSeries;
+import com.yeshi.buwan.videos.funtv.entity.FunTVAlbum2;
+import com.yeshi.buwan.videos.iqiyi.IqiYiNewAPI;
+import com.yeshi.buwan.videos.iqiyi.entity.IqiyiAlbum2;
+import com.yeshi.buwan.videos.iqiyi.entity.VideoIqiyi2;
+import com.yeshi.buwan.videos.iqiyi.util.IqiyiUtil2;
+import com.yeshi.buwan.videos.pptv.entity.PPTVSeries;
import com.yeshi.buwan.service.imp.JobThreadExecutorServiceImpl;
import com.yeshi.buwan.service.imp.ResourceVideoService;
import com.yeshi.buwan.service.imp.VideoInfoService;
@@ -93,7 +92,7 @@
private void init() {
logger.error("鍒濆鍖�");
- if (!Constant.JobTasker) {
+// if (!Constant.JobTasker) {
doSolrJob();
doAddIqiyi2Video();
doAddFunTV2Video();
@@ -102,7 +101,8 @@
doUpdateVideoExtraInfo();
doInternetSearchVideoUpdateJob();
doUpdateResourceVideoJob();
- }
+// }
+// doUpdateResourceVideoJob();
}
private void doSolrJob() {
@@ -183,7 +183,9 @@
new JobThreadExecutorServiceImpl().run(new Runnable() {
@Override
public void run() {
+ System.out.println("娑堣垂缁撴潫锛歞oUpdateResourceVideoJob");
List<UpdateResourceVideoMQMsg> msgList = CMQManager.getInstance().consumeUpdateResourceVideoMsg(16);
+ System.out.println("娑堣垂缁撴潫锛歞oUpdateResourceVideoJob");
if (msgList != null)
for (UpdateResourceVideoMQMsg videoMQMsg : msgList) {
try {
@@ -208,7 +210,7 @@
iqiyi2Service.offlineIqiyiAlbum(Long.parseLong(videoMQMsg.getId()));
} else {
//淇濆瓨
- iqiyiUtil2.syncByAid(iqiyiAlbum2.getId());
+ iqiyiUtil2.syncByAid(iqiyiAlbum2.getId(), false);
}
break;
}
--
Gitblit v1.8.0