From ade2f4d8c25334d01724169eadc0b3f0aba75dc8 Mon Sep 17 00:00:00 2001 From: Tiger Ren Date: Tue, 19 Nov 2024 12:26:50 +0800 Subject: [PATCH] =?UTF-8?q?=E5=88=86=E6=AE=B5=E8=BE=93=E5=87=BAfollowup=5F?= =?UTF-8?q?info=E4=B8=AD=E7=9A=84=E4=BF=A1=E6=81=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- app/api/v2/zhipu_controller_v2.py | 13 ++++++++++--- 1 file changed, 10 insertions(+), 3 deletions(-) diff --git a/app/api/v2/zhipu_controller_v2.py b/app/api/v2/zhipu_controller_v2.py index 988b0e0..c27433a 100644 --- a/app/api/v2/zhipu_controller_v2.py +++ b/app/api/v2/zhipu_controller_v2.py @@ -281,11 +281,18 @@ def analysis_stream(): chunk_out = format_chunk(chunk, None, None) yield json.dumps(chunk_out) + '\n' - followup_info = get_analysis_followup_info(message, accumulated_result,"1843318172036575232") - followup_info += "如有新的销售进展，请补充相关信息，我会为您做进一步分析" - yield json.dumps(format_chunk("", followup_info, "")) + '\n' logger.info(f'accumulated_result: {accumulated_result}') + + followup_info = get_analysis_followup_info(message, accumulated_result, "1843318172036575232") + followup_info += "如有新的销售进展，请补充相关信息，我会为您做进一步分析" logger.info(f'followup_info: {followup_info}') + # Split followup_info into chunks of approximately 15 characters + chunk_size = 15 + chunks = [followup_info[i:i+chunk_size] for i in range(0, len(followup_info), chunk_size)] + + # Yield each chunk separately + for chunk in chunks: + yield json.dumps(format_chunk("", chunk, "")) + '\n' return Response(event_stream(), mimetype='text/event-stream', headers=response_headers)