'commit'

AI/WxMini/Start.py

@@ -1,32 +1,23 @@
 import asyncio
+import base64
+import datetime
+import json
 import logging
 import uuid
 from contextlib import asynccontextmanager
 from datetime import datetime, timedelta
 from typing import Optional
 
+from alibabacloud_sts20150401 import models as sts_20150401_models
+from alibabacloud_sts20150401.client import Client as Sts20150401Client
+from alibabacloud_tea_openapi.models import Config
 from fastapi import Query, Depends, HTTPException, status, Form, FastAPI
 from fastapi.security import OAuth2PasswordBearer
 from jose import JWTError, jwt
 from openai import AsyncOpenAI
 from passlib.context import CryptContext
 from starlette.responses import StreamingResponse
-import json
-import oss2
-from alibabacloud_sts20150401 import models as sts_20150401_models
-from alibabacloud_sts20150401.client import Client as Sts20150401Client
-from alibabacloud_tea_openapi.models import Config
-from alibabacloud_tea_openapi.models import Config
-from alibabacloud_sts20150401.client import Client as Sts20150401Client
-from alibabacloud_sts20150401 import models as sts_20150401_models
-from alibabacloud_credentials.client import Client as CredentialClient
-import os
-import json
-import base64
-import hmac
-import datetime
-import time
-import hashlib
+
 from WxMini.Milvus.Config.MulvusConfig import *
 from WxMini.Milvus.Utils.MilvusCollectionManager import MilvusCollectionManager
 from WxMini.Milvus.Utils.MilvusConnectionPool import *
@@ -551,9 +542,9 @@ async def generate_upload_params(current_user: dict = Depends(get_current_user))
 
     now = int(time.time())
     # 将时间戳转换为datetime对象
-    dt_obj = datetime.datetime.utcfromtimestamp(now)
+    dt_obj = datetime.utcfromtimestamp(now)
     # 在当前时间增加3小时，设置为请求的过期时间
-    dt_obj_plus_3h = dt_obj + datetime.timedelta(hours=1)
+    dt_obj_plus_3h = dt_obj + timedelta(hours=1)
 
     # 请求时间
     dt_obj_1 = dt_obj.strftime('%Y%m%dT%H%M%S') + 'Z'

AI/WxMini/Utils/ImageUtil.py

@@ -76,7 +76,7 @@ async def recognize_text(client, pool, person_id, image_url):
 
     # 记录到数据库
     try:
-        await save_chat_to_mysql(pool, person_id, f'![]({image_url})', full_text, "", 0, 2, 2, 1)
+        await save_chat_to_mysql(pool, person_id, f'{image_url}', full_text, "", 0, 2, 2, 1)
     except Exception as e:
         print(f"记录到数据库时出错：{e}")
 
@@ -104,6 +104,6 @@ async def recognize_content(client, pool, person_id, image_url):
 
     # 记录到数据库
     try:
-        await save_chat_to_mysql(pool, person_id, f'![]({image_url})', full_text, "", 0, 2, 2, 2)
+        await save_chat_to_mysql(pool, person_id, f'{image_url}', full_text, "", 0, 2, 2, 2)
     except Exception as e:
         print(f"记录到数据库时出错：{e}")