From 9b349c7dcf31ed234c78869b23187bc3f2364a15 Mon Sep 17 00:00:00 2001 From: martsforever Date: Sat, 23 Aug 2025 09:34:46 +0800 Subject: [PATCH] =?UTF-8?q?feat:=20insert=20=E5=92=8Cupdate=E7=BB=93?= =?UTF-8?q?=E6=9D=9F=E4=B9=8B=E5=90=8E=E9=9C=80=E8=A6=81=E8=B0=83=E7=94=A8?= =?UTF-8?q?=20query=5Fitem=E9=87=8D=E6=96=B0=E6=9F=A5=E4=B8=80=E9=81=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- app/utils/create_module_service.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/app/utils/create_module_service.py b/app/utils/create_module_service.py index d572842..0823d7e 100644 --- a/app/utils/create_module_service.py +++ b/app/utils/create_module_service.py @@ -286,7 +286,7 @@ def create_model_service( # 提交事务(保存到数据库) await session.commit() # 刷新实例,获取数据库生成的最新数据(如自动更新的时间字段) - await session.refresh(insert_cls) + insert_cls = await self.query_item(session, {"id": insert_cls.id}) if after_insert is not None: await after_insert(insert_cls, row_dict, session) @@ -361,7 +361,7 @@ def create_model_service( # 提交事务 await session.commit() # 刷新实例,获取最新数据 - await session.refresh(update_cls) + update_cls = await self.query_item(session, {"id": update_cls.id}) if after_update is not None: await after_update(update_cls, row_dict, session)