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)