From 42fa17d6209d10cbe4774388d0ff3fcf3329eb5a Mon Sep 17 00:00:00 2001 From: admin <weikou2014> Date: 星期三, 16 六月 2021 13:53:17 +0800 Subject: [PATCH] zookeeper地址修改 --- src/main/java/com/yeshi/buwan/util/SpringContext.java | 18 ++++++++++++++---- 1 files changed, 14 insertions(+), 4 deletions(-) diff --git a/src/main/java/com/yeshi/buwan/util/SpringContext.java b/src/main/java/com/yeshi/buwan/util/SpringContext.java index 1fecac7..abcd8df 100644 --- a/src/main/java/com/yeshi/buwan/util/SpringContext.java +++ b/src/main/java/com/yeshi/buwan/util/SpringContext.java @@ -1,5 +1,6 @@ package com.yeshi.buwan.util; +import com.alibaba.druid.pool.DruidDataSource; import com.yeshi.buwan.domain.ResourceVideo; import com.yeshi.buwan.domain.VideoInfo; import com.yeshi.buwan.domain.VideoResource; @@ -11,15 +12,18 @@ import com.yeshi.buwan.service.imp.JobThreadExecutorServiceImpl; import com.yeshi.buwan.service.imp.ResourceVideoService; import com.yeshi.buwan.service.imp.VideoInfoService; -import com.yeshi.buwan.service.inter.juhe.*; +import com.yeshi.buwan.service.inter.juhe.FunTV2Service; +import com.yeshi.buwan.service.inter.juhe.InternetSearchVideoService; +import com.yeshi.buwan.service.inter.juhe.Iqiyi2Service; +import com.yeshi.buwan.service.inter.juhe.PPTVService; import com.yeshi.buwan.service.manager.SolrAlbumVideoDataManager; import com.yeshi.buwan.service.manager.SolrInternetSearchVideoDataManager; -import com.yeshi.buwan.util.factory.InternetSearchVideoFactory; import com.yeshi.buwan.util.mq.CMQManager; -import com.yeshi.buwan.youku.entity.YouKuShowDetail; +import io.seata.rm.datasource.DataSourceProxy; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.context.ApplicationListener; +import org.springframework.context.annotation.Bean; import org.springframework.context.event.ContextRefreshedEvent; import org.springframework.stereotype.Component; @@ -64,6 +68,12 @@ } } + @Bean + public DataSourceProxy dataSourceProxy(DruidDataSource druidDataSource) { + return new DataSourceProxy(druidDataSource); + } + + private synchronized void onApplication(ContextRefreshedEvent context) { if (!isInited) { isInited = true; @@ -81,8 +91,8 @@ doAddPPTVVideo(); doDeleteVideoResource(); doUpdateVideoExtraInfo(); + doInternetSearchVideoUpdateJob(); } - doInternetSearchVideoUpdateJob(); } private void doSolrJob() { -- Gitblit v1.8.0