From e89de9319d8f771f8e53cb5f876d06465a580c57 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期一, 02 八月 2021 18:23:22 +0800
Subject: [PATCH] kafka日志集成
---
src/main/java/com/yeshi/buwan/service/imp/juhe/Iqiyi2ServiceImpl.java | 17 ++++++++---------
1 files changed, 8 insertions(+), 9 deletions(-)
diff --git a/src/main/java/com/yeshi/buwan/service/imp/juhe/Iqiyi2ServiceImpl.java b/src/main/java/com/yeshi/buwan/service/imp/juhe/Iqiyi2ServiceImpl.java
index 2ecec45..40e0f18 100644
--- a/src/main/java/com/yeshi/buwan/service/imp/juhe/Iqiyi2ServiceImpl.java
+++ b/src/main/java/com/yeshi/buwan/service/imp/juhe/Iqiyi2ServiceImpl.java
@@ -79,15 +79,14 @@
return null;
final IqiyiAlbum2 album = iqiyiAlbum2Dao.get(videoIqiyi2.getIqiyiId());
- if (album != null) {
- ThreadUtil.run(new Runnable() {
- @Override
- public void run() {
- CMQManager.getInstance().addUpdateResourceVideoMsg(new UpdateResourceVideoMQMsg(album.getId() + "", IqiyiUtil2.RESOURCE_ID, new Date()));
- }
- });
-
- }
+// if (album != null) {
+ ThreadUtil.run(new Runnable() {
+ @Override
+ public void run() {
+ CMQManager.getInstance().addUpdateResourceVideoMsg(new UpdateResourceVideoMQMsg(videoIqiyi2.getIqiyiId() + "", IqiyiUtil2.RESOURCE_ID, new Date()));
+ }
+ });
+// }
List<IqiyiAlbum2> album2List = new ArrayList<>();
if (album.getFeatureAlbumId() > 0) {//鍗曡棰�
--
Gitblit v1.8.0