diff --git a/services/biz_service.py b/services/biz_service.py index 9801f70..591a4f1 100644 --- a/services/biz_service.py +++ b/services/biz_service.py @@ -129,7 +129,7 @@ class BizService(): async def send_text_message_async(self, token_id, app_id, agent_wxid, intersection_wxids, text): for t in intersection_wxids: # 发送文本消息 - ret,ret_msg,res = await self.wxchat.post_text(token_id, app_id, t, text) + ret,ret_msg,res = await self.wxchat.post_text_async(token_id, app_id, t, text) logger.info(f'{agent_wxid} 向 {t} 发送文字【{text}】') # 构造对话消息并发送到 Kafka