| | |
|---|
| | | |
|---|
| | | |
|---|
| | | async def service_chat_dialog(question: str, session_id: str): |
|---|
| | | |
|---|
| | | if session_id: |
|---|
| | | ... |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | try: |
|---|
| | | for ans in chat(dia, msg, True, **req): |
|---|
| | | |
|---|
| | | yield "data:" + json.dumps({"code": 0, "message": "", "data": ans}, ensure_ascii=False) + "\n\n" |
|---|
| | | ConversationService.update_by_id(conv.id, conv.to_dict()) |
|---|
| | | except Exception as e: |
|---|
| | | yield "data:" + json.dumps({"code": 500, "message": str(e), |
|---|
| | | "data": {"answer": "**ERROR**: " + str(e), "reference": []}}, |
|---|
| | | ensure_ascii=False) + "\n\n" |
|---|
| | | yield "data:" + json.dumps({"code": 0, "message": "", "data": True}, ensure_ascii=False) + "\n\n" |
|---|
