| | |
|---|
| | | chat_history = message.get('chatHistory', []) |
|---|
| | | message["role"] = "user" |
|---|
| | | if len(chat_history) == 0: |
|---|
| | | print("----------------------", token) |
|---|
| | | chat_history = await ragflow_service.get_session_history(token, chat_id) |
|---|
| | | if len(chat_history) == 0: |
|---|
| | | chat_history = await ragflow_service.set_session(token, agent_id, |
|---|
| | | message, chat_id, True) |
|---|
| | | # print("chat_history------------------------", chat_history) |
|---|
| | | print("chat_history------------------------", chat_history) |
|---|
| | | if len(chat_history) == 0: |
|---|
| | | result = {"message": "内部错误：创建会话失败", "type": "close"} |
|---|
| | | await websocket.send_json(result) |
|---|
| | |
|---|
| | | # token = get_dify_token(db, current_user.id) |
|---|
| | | try: |
|---|
| | | async def forward_to_dify(): |
|---|
| | | if agent.type == "imageTalk": |
|---|
| | | if chat_type == "imageTalk": |
|---|
| | | token = DfTokenDao(db).get_token_by_id(IMAGE_TO_TEXT) |
|---|
| | | if not token: |
|---|
| | | await websocket.send_json({"message": "Invalid token", "type": "error"}) |
|---|
| | |
|---|
| | | result = {"message": f"内部错误： {e2}", "type": "close"} |
|---|
| | | await websocket.send_json(result) |
|---|
| | | print(f"Error process message of ragflow: {e2}") |
|---|
| | | elif agent.type == "reportWorkflow": |
|---|
| | | elif chat_type == "reportWorkflow": |
|---|
| | | |
|---|
| | | while True: |
|---|
| | | receive_message = await websocket.receive_json() |
|---|
