|
|
@@ -799,7 +799,10 @@ async def handle_client(websocket: WebSocket,
|
|
|
inputs["key_words"] = receive_message["key_words"]
|
|
|
upload_files = receive_message.get('upload_files', [])
|
|
|
question = receive_message.get('message', "")
|
|
|
-
|
|
|
+ session_log = SessionService(db).get_session_by_id(chat_id)
|
|
|
+ if not session_log and not upload_files:
|
|
|
+ await websocket.send_json({"message": "需要上传文档!", "type": "error"})
|
|
|
+ continue
|
|
|
try:
|
|
|
session = SessionService(db).create_session(
|
|
|
chat_id,
|