From 2b1f542577dd8dfc54d3433dff3615796ceab0af Mon Sep 17 00:00:00 2001
From: shikeying <shikeying@163.com>
Date: 星期二, 11 十月 2022 17:17:50 +0800
Subject: [PATCH] 视频下载，解析分析调度跑通
---
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