From 301017226e61aa39c8b40e780ca244eeddd073d4 Mon Sep 17 00:00:00 2001
From: cy <1664593601@qq.com>
Date: 星期日, 09 十月 2022 14:14:54 +0800
Subject: [PATCH] feat(schedule): 定时任务视频拉取
---
recommend-video/src/main/java/com/iplatform/recvideo/scheduler/VideoLoadScheduler.java | 11 +++++++----
1 files changed, 7 insertions(+), 4 deletions(-)
diff --git a/recommend-video/src/main/java/com/iplatform/recvideo/scheduler/VideoLoadScheduler.java b/recommend-video/src/main/java/com/iplatform/recvideo/scheduler/VideoLoadScheduler.java
index 2735f65..69be7b3 100644
--- a/recommend-video/src/main/java/com/iplatform/recvideo/scheduler/VideoLoadScheduler.java
+++ b/recommend-video/src/main/java/com/iplatform/recvideo/scheduler/VideoLoadScheduler.java
@@ -3,6 +3,7 @@
import com.iplatform.core.BeanContextAware;
import com.iplatform.recvideo.VideoLoader;
import com.iplatform.recvideo.VideoScheduler;
+import com.iplatform.recvideo.config.VideoSimilarProperties;
import com.iplatform.recvideo.service.VideoLoaderServiceImpl;
import com.iplatform.recvideo.support.DefaultVideoLoader;
import com.walker.connector.Address;
@@ -25,11 +26,13 @@
public VideoLoadScheduler(int id, String name){
super(id, name);
+ VideoSimilarProperties videoSimilarProperties = BeanContextAware.getBeanByType(VideoSimilarProperties.class);
srcAddress = new Address();
- srcAddress.setUrl("127.0.0.1");
- srcAddress.setPort(3306);
- srcAddress.setAuthentication("root");
- srcAddress.setCertification("123456");
+ srcAddress.setUrl(videoSimilarProperties.getBusinessDatasourceUrl());
+ srcAddress.setPort(videoSimilarProperties.getBusinessDatasourcePort());
+ srcAddress.setService(videoSimilarProperties.getBusinessDatasourceService());
+ srcAddress.setAuthentication(videoSimilarProperties.getBusinessDatasourceAuthentication());
+ srcAddress.setCertification(videoSimilarProperties.getBusinessDatasourceCertification());
}
@Override
--
Gitblit v1.9.1