diff --git a/app/endpoints/pipeline_endpoint.py b/app/endpoints/pipeline_endpoint.py
index 241b80c..803ad94 100644
--- a/app/endpoints/pipeline_endpoint.py
+++ b/app/endpoints/pipeline_endpoint.py
@@ -641,7 +641,7 @@ async def handle_text_group_async(request: Request,token_id,app_id, wxid,msg_dat
     k,login_info=await request.app.state.gewe_service.get_login_info_by_app_id_async(app_id)
     nickname=login_info.get("nickName")
 
-    config=await request.aoo.state.gewe_service.get_wxchat_config_from_cache_async(wxid)
+    config=await request.app.state.gewe_service.get_wxchat_config_from_cache_async(wxid)
     validated_config = AgentConfig.model_validate(config)
     if not validated_config.privateGroupChatEnabled:
         logger.warning(f"微信号 {wxid} 关闭好友和群自动回复功能，{handle_text_group_async.__name__} 不回复消息")
@@ -836,7 +836,7 @@ async def handle_voice_async(request: Request,token_id,app_id, wxid,msg_data,fro
     msg_content=msg_data["Content"]["string"]
     msg_id=msg_data["MsgId"]
 
-    config=await request.aoo.state.gewe_service.get_wxchat_config_from_cache_async(wxid)
+    config=await request.app.state.gewe_service.get_wxchat_config_from_cache_async(wxid)
     validated_config = AgentConfig.model_validate(config)
     if not validated_config.privateGroupChatEnabled:
         logger.warning(f"微信号 {wxid} 关闭好友和群自动回复功能，{handle_voice_async.__name__} 不回复消息")