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/support/DefaultSimilarExecutor.java |    9 ++++++++-
 1 files changed, 8 insertions(+), 1 deletions(-)

diff --git a/recommend-video/src/main/java/com/iplatform/recvideo/support/DefaultSimilarExecutor.java b/recommend-video/src/main/java/com/iplatform/recvideo/support/DefaultSimilarExecutor.java
index ceec831..10876e8 100644
--- a/recommend-video/src/main/java/com/iplatform/recvideo/support/DefaultSimilarExecutor.java
+++ b/recommend-video/src/main/java/com/iplatform/recvideo/support/DefaultSimilarExecutor.java
@@ -52,7 +52,9 @@
     @Override
     protected String requestStartPythonLoadVideo(String batchId) throws Exception {
         logger.info("寮�濮嬭姹俻ython鏈嶅姟:" + Constants.AI_SERVICE_VIDEO_LOAD);
-        return null;
+        String url = this.remoteUrl + Constants.AI_SERVICE_VIDEO_LOAD;
+        boolean success = PythonInvokeUtils.postLoadVideoGather(batchId, url, this.restTemplate);
+        return success? null : "python 鍔犺浇瑙嗛璋冪敤澶辫触";
     }
 
     @Override
@@ -138,6 +140,11 @@
         logger.debug("鎵规浠诲姟鐘舵�佸凡鏇存柊鎴愬姛! " + batchId);
     }
 
+    @Override
+    protected void ignoreTaskStatus(String batchId) {
+        this.videoExecutorService.execIgnoreTaskStatus(batchId);
+    }
+
     private List<Rc_video_user> toRcVideoUserList(List<SimilarVideoUser> similarVideoUserList){
         if(StringUtils.isEmptyList(similarVideoUserList)){
             return null;

--
Gitblit v1.9.1