zhaoqingang
2025-01-02 b991b79b608e3b811399cb59b2776ce23ba6d1e0
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
 
 
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"