From 26f5dd8ef80e5671cda8fc0e6c0d0298c4e678ff Mon Sep 17 00:00:00 2001
From: shikeying <shikeying@163.com>
Date: 星期二, 27 九月 2022 16:31:33 +0800
Subject: [PATCH] 视频相似度分析3
---
recommend-video/src/main/java/com/iplatform/recvideo/api/DemoDebug.java | 28 ++++++++++++++++++++++++++++
1 files changed, 28 insertions(+), 0 deletions(-)
diff --git a/recommend-video/src/main/java/com/iplatform/recvideo/api/DemoDebug.java b/recommend-video/src/main/java/com/iplatform/recvideo/api/DemoDebug.java
index 4c36014..307f478 100644
--- a/recommend-video/src/main/java/com/iplatform/recvideo/api/DemoDebug.java
+++ b/recommend-video/src/main/java/com/iplatform/recvideo/api/DemoDebug.java
@@ -1,12 +1,19 @@
package com.iplatform.recvideo.api;
+import com.iplatform.core.BeanContextAware;
import com.iplatform.recvideo.config.VideoSimilarProperties;
+import com.iplatform.recvideo.scheduler.VideoSearchScheduler;
import com.iplatform.recvideo.service.VideoExecutorServiceImpl;
import com.iplatform.recvideo.support.DefaultSimilarExecutor;
+import com.walker.scheduler.ScheduleEngine;
+import com.walker.scheduler.util.OptionUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;
+
+import java.util.ArrayList;
+import java.util.List;
@RestController
@RequestMapping("/debug/video")
@@ -15,6 +22,8 @@
private RestTemplate restTemplate;
private VideoSimilarProperties videoSimilarProperties;
private VideoExecutorServiceImpl videoExecutorService;
+
+ private VideoSearchScheduler videoSearchScheduler = null;
private DefaultSimilarExecutor similarExecutor = null;
@@ -27,6 +36,25 @@
this.videoExecutorService = videoExecutorService;
}
+ @RequestMapping("/start_scheduler_1")
+ public String testStartVideoSearchScheduler(){
+ if(this.videoSearchScheduler != null){
+ this.videoSearchScheduler.stop();
+ this.videoSearchScheduler = null;
+ }
+
+ List<Integer[]> timeRanges = new ArrayList<Integer[]>(1);
+ timeRanges.add(new Integer[]{10,11});
+ timeRanges.add(new Integer[]{12,12});
+
+ this.videoSearchScheduler = new VideoSearchScheduler(100, "瑙嗛鐩镐技搴﹀垎鏋愯皟搴︿换鍔�");
+ this.videoSearchScheduler.setOption(OptionUtils.combineEveryDayHourRange(timeRanges));
+ this.videoSearchScheduler.setScheduleEngine(BeanContextAware.getBeanByType(ScheduleEngine.class));
+ this.videoSearchScheduler.setMaxFailedTimes(10);
+ this.videoSearchScheduler.start();
+ return this.videoSearchScheduler.getName() + " 鍚姩";
+ }
+
/**
* 璇ユ祴璇曠敤浜庢ā鎷熻皟搴︿换鍔★紝姣忔璋冪敤涓�娆℃墽琛屽櫒鏂规硶锛屾壒閲忓鐞嗕竴寮犲浘鐗囨暟鎹��<p></p>
* 鏈�缁堝畬鎴愪竴鎵瑰涓棰戠殑鐩镐技搴︽绱㈠苟鍐欏叆鏁版嵁搴撲腑銆�
--
Gitblit v1.9.1