Se han modificado 1 ficheros con 1 adiciones y 1 borrados
+ 1
- 1
tasks.py
Ver fichero
| @@ -721,7 +721,7 @@ def scheduled_task_add_contacts_from_chatrooms(self, redis_config, kafka_config, | |||||
| await gewe_service.save_group_add_contacts_history_async(wxid, chatroom_id, contact_wxid, history) | await gewe_service.save_group_add_contacts_history_async(wxid, chatroom_id, contact_wxid, history) | ||||
| wixd_add_contacts_from_chatrooms_times[wxid] += 1 | wixd_add_contacts_from_chatrooms_times[wxid] += 1 | ||||
| logger.info(f'{nickname} 向 {chatroom_nickname}-{chatroom_id} 群的 {m.get("nickName")}-{m.get("wxid")} 发送好友邀请 {msg}') | |||||
| logger.info(f'{nickname} 向 {chatroom_nickname}-{chatroom_id} 群的 {m.get("nickName")}-{m.get("wxid")} 发送好友邀请 {msg} \n {data} \n 当前已邀请好友数:{wixd_add_contacts_from_chatrooms_times[wxid]}') | |||||
| # 推送到kafka | # 推送到kafka | ||||
| k_message = wx_add_contacts_from_chatroom_message(history.wxid, history.chatroomId, history.contactWixd, history.addTime) | k_message = wx_add_contacts_from_chatroom_message(history.wxid, history.chatroomId, history.contactWixd, history.addTime) | ||||
| await kafka_service.send_message_async(k_message) | await kafka_service.send_message_async(k_message) | ||||
Cargando…