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(