From 9afb9d343b2ef7ac1c47030f25a9298089478177 Mon Sep 17 00:00:00 2001 From: HibiKier <45528451+HibiKier@users.noreply.github.com> Date: Thu, 12 Dec 2024 16:42:10 +0800 Subject: [PATCH] Bugfix/fix create user a (#1766) MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit * 🐛 群组用户信息批量报错时使用逐个创建 * 💬 添加报错用户信息 --- .../admin/group_member_update/_data_source.py | 26 ++++++++++++++----- 1 file changed, 20 insertions(+), 6 deletions(-) diff --git a/zhenxun/builtin_plugins/admin/group_member_update/_data_source.py b/zhenxun/builtin_plugins/admin/group_member_update/_data_source.py index 778fdcf1..5239857f 100644 --- a/zhenxun/builtin_plugins/admin/group_member_update/_data_source.py +++ b/zhenxun/builtin_plugins/admin/group_member_update/_data_source.py @@ -100,12 +100,26 @@ class MemberUpdateManage: await cls.__handle_user(member, db_user, group_id, data_list, platform) exist_member_list.append(member.id) if data_list[0]: - await GroupInfoUser.bulk_create(data_list[0], 30) - logger.debug( - f"创建用户数据 {len(data_list[0])} 条", - "更新群组成员信息", - target=group_id, - ) + try: + await GroupInfoUser.bulk_create(data_list[0], 30) + logger.debug( + f"创建用户数据 {len(data_list[0])} 条", + "更新群组成员信息", + target=group_id, + ) + except Exception as e: + logger.error( + f"批量创建用户数据失败: {e}，开始进行逐个存储", + "更新群组成员信息", + ) + for u in data_list[0]: + try: + await u.save() + except Exception as e: + logger.error( + f"创建用户 {u.user_name}({u.user_id}) 数据失败: {e}", + "更新群组成员信息", + ) if data_list[1]: await GroupInfoUser.bulk_update(data_list[1], ["user_name"], 30) logger.debug(