|
@@ -129,7 +129,7 @@ class BizService(): |
|
|
async def send_text_message_async(self, token_id, app_id, agent_wxid, intersection_wxids, text): |
|
|
async def send_text_message_async(self, token_id, app_id, agent_wxid, intersection_wxids, text): |
|
|
for t in intersection_wxids: |
|
|
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}】') |
|
|
logger.info(f'{agent_wxid} 向 {t} 发送文字【{text}】') |
|
|
|
|
|
|
|
|
# 构造对话消息并发送到 Kafka |
|
|
# 构造对话消息并发送到 Kafka |
|
|