diff --git a/app/endpoints/pipeline_endpoint.py b/app/endpoints/pipeline_endpoint.py index 13ba073..f38a851 100644 --- a/app/endpoints/pipeline_endpoint.py +++ b/app/endpoints/pipeline_endpoint.py @@ -43,9 +43,9 @@ async def get_messages(request: Request, body: Dict[str, Any]): from_wxid = msg_data["FromUserName"]["string"] config=await request.app.state.redis_service.get_hash(f"__AI_OPS_WX__:WXCHAT_CONFIG") wxids=config.keys() - WX_BACKLIST.extend(wxids) + meged_backlist_wxids=wxids+WX_BACKLIST # 公众号ID已gh_开头 - if from_wxid in WX_BACKLIST or 'gh_' in from_wxid: + if from_wxid in meged_backlist_wxids or 'gh_' in from_wxid: logger.warning(f'来自微信ID {from_wxid} 在黑名单,发送给 {wxid} ,不处理') return {"message": "收到微信回调消息"}