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)