diff --git a/tasks.py b/tasks.py index 4144934..b27d6e4 100644 --- a/tasks.py +++ b/tasks.py @@ -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'), f'我是群聊"{chatroom_nickname}"群的{nickname}') 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'): 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 history = AddGroupContactsHistory.model_validate({