Diuse/zhenxun_bot
1
0
Fork 0
mirror of https://github.com/zhenxun-org/zhenxun_bot.git synced 2025-12-14 21:52:56 +08:00
Code Issues Actions 7 Packages Projects Releases Wiki Activity

Bugfix/fix create user a (#1766)

Browse Source 
* 🐛 群组用户信息批量报错时使用逐个创建

* 💬 添加报错用户信息
This commit is contained in:
HibiKier 2024-12-12 16:42:10 +08:00 committed by GitHub
parent a421902bc7
commit 9afb9d343b
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 20 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
zhenxun/builtin_plugins/admin/group_member_update/_data_source.py
View File

@ -100,12 +100,26 @@ class MemberUpdateManage:
await cls.__handle_user(member, db_user, group_id, data_list, platform) await cls.__handle_user(member, db_user, group_id, data_list, platform)
exist_member_list.append(member.id) exist_member_list.append(member.id)
if data_list[0]: if data_list[0]:
await GroupInfoUser.bulk_create(data_list[0], 30) try:
logger.debug( await GroupInfoUser.bulk_create(data_list[0], 30)
f"创建用户数据 {len(data_list[0])} 条", logger.debug(
"更新群组成员信息", f"创建用户数据 {len(data_list[0])} 条",
target=group_id, "更新群组成员信息",
) 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]: if data_list[1]:
await GroupInfoUser.bulk_update(data_list[1], ["user_name"], 30) await GroupInfoUser.bulk_update(data_list[1], ["user_name"], 30)
logger.debug( logger.debug(