|
|
@@ -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": "收到微信回调消息"} |
|
|
|
|
|
|
|