From 2683a7ca96650541962c46b518d3dd7477ed7bfc Mon Sep 17 00:00:00 2001 From: H Vs Date: Thu, 24 Apr 2025 15:56:32 +0800 Subject: [PATCH] =?UTF-8?q?=E8=B0=83=E6=95=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- app/endpoints/pipeline_endpoint.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/app/endpoints/pipeline_endpoint.py b/app/endpoints/pipeline_endpoint.py index fdf29ad..2d8dcb3 100644 --- a/app/endpoints/pipeline_endpoint.py +++ b/app/endpoints/pipeline_endpoint.py @@ -966,12 +966,12 @@ async def handle_voice_async(request: Request,token_id,app_id, wxid,msg_data,fro else: # logger.info(f"回复内容包含网址，不发送语音,回复文字内容：{ai_res_content}") # ret,ret_msg,res=await request.app.state.gewe_service.post_text_async(token_id,app_id,callback_to_user,ai_res_content) - + message_lock=request.app.state.message_lock[app_id] reply_content=ai_res_content # 判断图片url img_urls,reply_content=extract_and_replace_image_urls(reply_content) if img_urls: - message_lock=request.app.state.message_lock[app_id] + #await request.app.state.gewe_service.post_text_async(token_id, app_id, callback_to_user, reply_content) async with message_lock: await ai_post_text_split_async_async(request, token_id, app_id, callback_to_user, reply_content)