From fd03e31f173ad9c52b15a30a9127e2b6a468538d Mon Sep 17 00:00:00 2001
From: shikeying <shikeying@163.com>
Date: 星期一, 26 九月 2022 18:50:33 +0800
Subject: [PATCH] 视频相似度分析2
---
recommend-video/src/main/java/com/iplatform/recvideo/service/VideoExecutorServiceImpl.java | 35 +++++++++++++++++++++++++++++++++++
1 files changed, 35 insertions(+), 0 deletions(-)
diff --git a/recommend-video/src/main/java/com/iplatform/recvideo/service/VideoExecutorServiceImpl.java b/recommend-video/src/main/java/com/iplatform/recvideo/service/VideoExecutorServiceImpl.java
index 9802597..6fe6174 100644
--- a/recommend-video/src/main/java/com/iplatform/recvideo/service/VideoExecutorServiceImpl.java
+++ b/recommend-video/src/main/java/com/iplatform/recvideo/service/VideoExecutorServiceImpl.java
@@ -2,6 +2,9 @@
import com.iplatform.model.po.Rc_video_t1;
import com.iplatform.model.po.Rc_video_t2;
+import com.iplatform.model.po.Rc_video_user;
+import com.walker.infrastructure.utils.DateUtils;
+import com.walker.infrastructure.utils.StringUtils;
import com.walker.jdbc.service.BaseServiceImpl;
import org.springframework.stereotype.Service;
@@ -14,6 +17,10 @@
private static final String SQL_CHECK_VIDEO_STATUS = "select * from milvus_video_status where id=?";
private static final String SQL_CLEAR_VIDEO_T1 = "delete from rc_video_t1 where src_img=?";
private static final String SQL_CLEAR_VIDEO_T2 = "delete from rc_video_t2 where src_video_id=?";
+
+ private static final String SQL_GET_BATCH_VIDEO = "select user_id, src_video_id from rc_video_batch where batch_id=?";
+
+ private static final String SQL_UPDATE_TASK_STATUS_LOAD = "update rc_task_status set status='1', end_time=? where last_value=? and status='0'";
/**
* 鍐欏叆瑙嗛鐩镐技搴︾涓�绾т复鏃舵暟鎹紝姣忎釜鍥惧儚鍖呭惈澶氫釜鐩镐技瑙嗛璁板綍銆�
@@ -37,6 +44,34 @@
}
/**
+ * 鍐欏叆鐢ㄦ埛鎺ㄨ崘瑙嗛璁板綍闆嗗悎锛屽苟鏇存柊鎵规浠诲姟鐘舵�佷负(宸插畬鎴�)
+ * @param videoUserList
+ * @param batchId
+ */
+ public void execBatchInsertVideoUser(List<Rc_video_user> videoUserList, String batchId){
+ this.insert(videoUserList);
+ Object[] param = new Object[2];
+ param[0] = Long.parseLong(DateUtils.getDateTimeSecondForShow());
+ param[1] = Long.parseLong(batchId);
+ this.execute(SQL_UPDATE_TASK_STATUS_LOAD, param);
+ }
+
+
+ /**
+ * 杩斿洖涓�涓壒娆＄敤鎴峰搴旇棰戣褰曢泦鍚堬紝鐢ㄤ簬鏈�鍚庢洿鏂扮敤鎴锋帹鑽愯棰戞暟鎹��
+ * @param batchId
+ * @return
+ * @date 2022-09-26
+ */
+ public List<Map<String, Object>> queryBatchUserVideoList(String batchId){
+ return this.select(SQL_GET_BATCH_VIDEO, new Object[]{batchId});
+ }
+
+ public List<Rc_video_t2> queryVideoT_2List(String batchId){
+ return this.select(new Rc_video_t2(), "where batch_id=?", new Object[]{batchId});
+ }
+
+ /**
* 鏍规嵁鍘熷瑙嗛ID杩斿洖鐩镐技璁板綍闆嗗悎銆�
* @param srcVideoId
* @return
--
Gitblit v1.9.1