调整私聊视频处理

app/endpoints/pipeline_endpoint.py

@@ -1020,13 +1020,18 @@ async def handle_video_async(request: Request,token_id,app_id, wxid,msg_data,fro
     logger.info('视频消息')
     try:
         msg_content_xml=msg_data["Content"]["string"]
-        video_url=await request.app.state.gewe_service.download_video_msg_async(token_id,app_id,msg_content_xml)
-        if not video_url:
-            logger.warning(f'处理视频消息异常')
+        wx_video_url=await request.app.state.gewe_service.download_video_msg_async(token_id,app_id,msg_content_xml)
+        if not wx_video_url:
+            logger.warning(f'处理微信视频消息异常')
             return 
         callback_to_user=from_wxid
-        print(video_url)
-        wx_content_dialogue_message = [{"type": "file", "file_url": {"url":video_url}}]
+        print(wx_video_url)
+
+        file_url=url_file_to_oss(wx_video_url)
+        if not file_url:
+            logger.warning(f'处理微信视频上传到oss异常')
+            return
+        wx_content_dialogue_message = [{"type": "file", "file_url": {"url":file_url}}]
         k_message = dialogue_message(callback_to_user,wxid, wx_content_dialogue_message)
         await request.app.state.kafka_service.send_message_async(k_message)
         logger.info("发送对话 %s",k_message)

common/utils.py

@@ -375,6 +375,22 @@ def download_video_and_get_thumbnail(url, thumbnail_path):
 
     return file_url, duration
 
+
+def url_file_to_oss(url):
+    try:
+        # OSS 配置（建议将凭证存储在安全的地方）
+        oss_access_key_id="LTAI5tRTG6pLhTpKACJYoPR5"
+        oss_access_key_secret="E7dMzeeMxq4VQvLg7Tq7uKf3XWpYfN"
+        oss_endpoint="http://oss-cn-shanghai.aliyuncs.com"
+        oss_bucket_name="cow-agent"
+        oss_prefix="cow"
+        file_url = upload_oss(oss_access_key_id, oss_access_key_secret, oss_endpoint, oss_bucket_name, url, oss_prefix)
+        return file_url
+    except Exception as e:
+        print(f"发生错误：{e}")
+        return None  # 发生错误时返回 None
+
+
 def contains_url(text):
     # 定义检测网址的正则表达式
     url_pattern = re.compile(