zhaoqingang
2024-11-26 6ae19ce01dbdfdb1080802d854b13adda3982172
app/api/chat.py
@@ -339,6 +339,7 @@
                                    else:  # 正常输出
                                        answer = data.get("answer", "")
                                        if isinstance(answer, str):
                                            answer_str += answer
                                        elif isinstance(answer, dict):
@@ -348,14 +349,20 @@
                                        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: