From d3ebf5b103d4deebd6ffb75f4471a6fddab8d764 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期六, 05 九月 2020 17:30:30 +0800
Subject: [PATCH] '微信登录'
---
src/main/java/com/yeshi/buwan/util/SpringContext.java | 73 +++++++++++++++++++++++++++++++++++-
1 files changed, 70 insertions(+), 3 deletions(-)
diff --git a/src/main/java/com/yeshi/buwan/util/SpringContext.java b/src/main/java/com/yeshi/buwan/util/SpringContext.java
index 074f17b..8597f2f 100644
--- a/src/main/java/com/yeshi/buwan/util/SpringContext.java
+++ b/src/main/java/com/yeshi/buwan/util/SpringContext.java
@@ -1,11 +1,22 @@
package com.yeshi.buwan.util;
+import com.yeshi.buwan.dao.juhe.iqiyi.IqiyiAlbum2Dao;
+import com.yeshi.buwan.domain.VideoInfo;
+import com.yeshi.buwan.dto.mq.IqiyiAlbum2MQMsg;
+import com.yeshi.buwan.dto.mq.SolrVideoMQMsg;
import com.yeshi.buwan.funtv.FunTVUtil;
+import com.yeshi.buwan.iqiyi.entity.IqiyiAlbum2;
+import com.yeshi.buwan.iqiyi.util.IqiyiUtil2;
+import com.yeshi.buwan.service.imp.JobThreadExecutorServiceImpl;
+import com.yeshi.buwan.service.imp.VideoInfoService;
+import com.yeshi.buwan.service.manager.SolrDataManager;
+import com.yeshi.buwan.util.mq.CMQManager;
import org.springframework.context.ApplicationListener;
import org.springframework.context.event.ContextRefreshedEvent;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
+import java.util.List;
/**
* 系统初始化
@@ -14,8 +25,19 @@
*/
@Component
public class SpringContext implements ApplicationListener<ContextRefreshedEvent> {
+
@Resource
- private FunTVUtil funTVUtil;
+ private VideoInfoService videoInfoService;
+
+ @Resource
+ private SolrDataManager solrDataManager;
+
+ @Resource
+ private IqiyiUtil2 iqiyiUtil2;
+
+ @Resource
+ private IqiyiAlbum2Dao iqiyiAlbum2Dao;
+
private static boolean isInited = false;
@@ -34,8 +56,53 @@
}
}
- private void init(){
-// funTVUtil.startParseShortVideo();
+ private void init() {
+ doSolrJob();
+ doAddIqiyi2Video();
+ }
+
+ private void doSolrJob() {
+ new JobThreadExecutorServiceImpl().run(new Runnable() {
+ @Override
+ public void run() {
+ List<SolrVideoMQMsg> solrMsgList = CMQManager.getInstance().consumeSolrMsg(16);
+ if (solrMsgList != null)
+ for (SolrVideoMQMsg solrVideo : solrMsgList) {
+ try {
+ VideoInfo videoInfo = videoInfoService.getVideoInfo(solrVideo.getId());
+ if (videoInfo != null)
+ solrDataManager.saveOrUpdate(videoInfo);
+ CMQManager.getInstance().deleteSolrMsg(solrVideo.getHandler());
+ } catch (Exception e) {
+
+ }
+ }
+ }
+ });
+ }
+
+
+ private void doAddIqiyi2Video() {
+ new JobThreadExecutorServiceImpl().run(new Runnable() {
+ @Override
+ public void run() {
+ List<IqiyiAlbum2MQMsg> iqiyiAlbumMsgList = CMQManager.getInstance().consumeAlbumUpdateMsg(16);
+ if (iqiyiAlbumMsgList != null)
+ for (IqiyiAlbum2MQMsg iqiyiAlbum2MQMsg : iqiyiAlbumMsgList) {
+ try {
+ Long qikuID = iqiyiAlbum2MQMsg.getId();
+ IqiyiAlbum2 album2 = iqiyiAlbum2Dao.get(qikuID);
+ if (album2 != null) {
+ iqiyiUtil2.addToVideoInfo(album2);
+ }
+ CMQManager.getInstance().deleteAlbumUpdateMsg(iqiyiAlbum2MQMsg.getHandler());
+ } catch (Exception e) {
+
+ }
+ }
+ }
+ });
+
}
}
--
Gitblit v1.8.0