| | |
| | | else: # 正常输出 |
| | | answer = data.get("answer", "") |
| | | if isinstance(answer, str): |
| | | |
| | | answer_str += answer |
| | | |
| | | elif isinstance(answer, dict): |
| | |
| | | |
| | | result = {"message": answer_str, "type": "message"} |
| | | elif data.get("event") == "message_end": |
| | | result = {"message": answer_str, "type": "close"} |
| | | message_files = [] |
| | | res_msg = await dify_service.get_session_history(token, data.get("conversation_id"), str(current_user.id)) |
| | | if len(res_msg) > 0: |
| | | message_files = res_msg[0].get("message_files") |
| | | |
| | | result = {"message": answer_str, "type": "close", "message_files": message_files} |
| | | try: |
| | | SessionService(db).update_session(chat_id, |
| | | message={"role": "assistant", "content": data, "conversation_id": data.get("conversation_id")}) |
| | | message={"role": "assistant", "content": {"answer":answer_str, "images":[i.get("url") for i in message_files]}},conversation_id=data.get("conversation_id")) |
| | | except Exception as e: |
| | | logger.error("保存dify的会话异常!") |
| | | logger.error(e) |
| | | elif data.get("event") == "message_file": |
| | | |
| | | url = data.get("url", "") |
| | | result = {"message": url, "type": "image"} |
| | | else: |