1 changed files with 2 additions and 2 deletions
+ 2
- 2
tasks.py
View File
| @@ -703,10 +703,10 @@ def scheduled_task_add_contacts_from_chatrooms(self, redis_config, kafka_config, | |||||
| ret, msg, data = await gewe_service.add_group_member_as_friend_async(token_id, app_id, chatroom_id, m.get('wxid'), | ret, msg, data = await gewe_service.add_group_member_as_friend_async(token_id, app_id, chatroom_id, m.get('wxid'), | ||||
| f'我是群聊"{chatroom_nickname}"群的{nickname}') | f'我是群聊"{chatroom_nickname}"群的{nickname}') | ||||
| if ret != 200: | if ret != 200: | ||||
| logger.warning(f'群好友邀请失败原因：{ret} {msg} {data}') | |||||
| logger.warning(f'{nickname}-{wxid} 在 {chatroom_nickname}-{chatroom_id} 群好友邀请失败原因：{ret} {msg} {data}') | |||||
| if '操作过于频繁' in data.get('msg'): | if '操作过于频繁' in data.get('msg'): | ||||
| await gewe_service.save_wx_expection_async(wxid, "addGroupMemberAsFriend", msg, today_seconds_remaining()) | await gewe_service.save_wx_expection_async(wxid, "addGroupMemberAsFriend", msg, today_seconds_remaining()) | ||||
| logger.warning(f'{nickname}-{wxid} 操作过于频繁，本次群好友邀请任务未完成跳过。') | |||||
| logger.warning(f'{nickname}-{wxid} 在 {chatroom_nickname}-{chatroom_id} 群的 {member_nickname}-{contact_wxid} 操作过于频繁，本次群好友邀请任务未完成跳过。当天不再处理该号群好友邀请任务') | |||||
| return | return | ||||
| history = AddGroupContactsHistory.model_validate({ | history = AddGroupContactsHistory.model_validate({ | ||||
Loading…