feat: videoPath字段修改

utils/piaoquan.py

@@ -103,9 +103,10 @@ class PQ:
                     data = response['data']
                     # 优先使用转码后的视频路径
                     video_path = data.get("videoPath")
+                    transed_video_path = data.get("transedVideoPath")
                     video_title = data.get("title", "")
 
-                    return video_title, video_path
+                    return video_title, video_path, transed_video_path
             return None
         except Exception as e:
             return None

workers/video_insight_select_work.py

@@ -31,7 +31,7 @@ def requirement_insight():
         logger.error(f"[R] 写入Redis写入失败，失败信息{e}")
 
 def schedule_tasks():
-    schedule.every().day.at("01:00").do(requirement_insight)
+    schedule.every().day.at("13:40").do(requirement_insight)
 
 
 if __name__ == "__main__":

workers/video_insight_trigger_work.py

@@ -47,11 +47,14 @@ class ConsumptionRecommend(object):
                 logger.info(f"[处理 - trigger] 视频ID {video_id} 重复过滤，继续获取下一个任务")
 
         logger.info(f"[处理 - trigger] 开始获取原视频OSS地址")
-        video_title, video_path = PQ.get_pq_oss(video_id)
+        video_title, video_path, transed_video_path = PQ.get_pq_oss(video_id)
+        # 优先使用transed_video_path，没有则使用video_path
+        if not transed_video_path:
+            transed_video_path = video_path
         if not video_path:
             return
-        logger.info(f"[处理 - trigger] 获取原视频OSS地址，视频链接:{video_path}")
-        video_url = f"http://rescdn.yishihui.com/{video_path}"
+        logger.info(f"[处理 - trigger] 获取原视频OSS地址，视频链接:{transed_video_path}")
+        video_url = f"http://rescdn.yishihui.com/{transed_video_path}"
         logger.info(f"[处理 - trigger] 开始分析视频")
         api_key = os.getenv("VIDEO_INSIGHT_GEMINI_API_KEY")
         logger.info(f"[处理 - trigger] 使用的API_KEY:{api_key}")