From bfb5dfa709ec55ab0cc57981b7d1504088d1bfac Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期一, 25 四月 2022 18:44:38 +0800
Subject: [PATCH] 应对DDOS攻击IP切换优化
---
src/main/java/com/yeshi/buwan/util/SpringContext.java | 18 ++++++++++--------
1 files changed, 10 insertions(+), 8 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..72dedcb 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;
@@ -103,6 +102,7 @@
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