yumoqing/reallife_asset
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: 修正 SQLor 插入方法调用，sor.I() 改为 sor.C()

Browse Source
This commit is contained in:
yumoqing 2026-05-29 19:24:58 +08:00
parent 9ada9a5a77
commit 2533e4f22e
1 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
reallife_asset/init.py
View File

@ -90,7 +90,7 @@ async def rl_create_validate_session(org_id, vendor, callback_url,
async with db.sqlorContext(dbname) as sor: async with db.sqlorContext(dbname) as sor:
gid = getID() gid = getID()
now = datetime.now().strftime("%Y-%m-%d %H:%M:%S") now = datetime.now().strftime("%Y-%m-%d %H:%M:%S")
await sor.I("rl_asset_group", { await sor.C("rl_asset_group", {
"id": gid, "id": gid,
"org_id": org_id, "org_id": org_id,
"vendor": vendor, "vendor": vendor,
@ -189,7 +189,7 @@ async def rl_create_asset(org_id, vendor_group_id, source_url,
asset_uri = f"asset://{vendor_asset_id}" if vendor_asset_id else "" asset_uri = f"asset://{vendor_asset_id}" if vendor_asset_id else ""
async with db.sqlorContext(dbname) as sor: async with db.sqlorContext(dbname) as sor:
await sor.I("rl_asset", { await sor.C("rl_asset", {
"id": asset_id, "id": asset_id,
"org_id": org_id, "org_id": org_id,
"group_id": local_group_id, "group_id": local_group_id,
@ -344,7 +344,7 @@ async def rl_sync_group_from_vendor(org_id, vendor, project_name="default"):
}, {"id": existing[0].id}) }, {"id": existing[0].id})
else: else:
gid = getID() gid = getID()
await sor.I("rl_asset_group", { await sor.C("rl_asset_group", {
"id": gid, "id": gid,
"org_id": org_id, "org_id": org_id,
"vendor": vendor, "vendor": vendor,
@ -408,7 +408,7 @@ async def rl_sync_assets_from_vendor(org_id, local_group_id):
}, {"id": existing[0].id}) }, {"id": existing[0].id})
else: else:
aid = getID() aid = getID()
await sor.I("rl_asset", { await sor.C("rl_asset", {
"id": aid, "id": aid,
"org_id": org_id, "org_id": org_id,
"group_id": local_group_id, "group_id": local_group_id,
@ -455,7 +455,7 @@ async def rl_verify_user(org_id, user_id, vendor, project_name="default"):
now = datetime.now().strftime("%Y-%m-%d %H:%M:%S") now = datetime.now().strftime("%Y-%m-%d %H:%M:%S")
db = DBPools() db = DBPools()
async with db.sqlorContext(_get_dbname()) as sor: async with db.sqlorContext(_get_dbname()) as sor:
await sor.I("rl_asset_group", { await sor.C("rl_asset_group", {
"id": gid, "id": gid,
"org_id": org_id, "org_id": org_id,
"vendor": vendor, "vendor": vendor,
@ -514,7 +514,7 @@ async def rl_upload_user(org_id, vendor_group_id, source_url, asset_type, name,
asset_uri = f"asset://{vendor_asset_id}" if vendor_asset_id else "" asset_uri = f"asset://{vendor_asset_id}" if vendor_asset_id else ""
async with db.sqlorContext(dbname) as sor: async with db.sqlorContext(dbname) as sor:
await sor.I("rl_asset", { await sor.C("rl_asset", {
"id": asset_id, "id": asset_id,
"org_id": org_id, "org_id": org_id,
"group_id": local_group_id, "group_id": local_group_id,
@ -638,7 +638,7 @@ async def rl_handle_callback(byted_token, project_name="default"):
"update_time": now, "update_time": now,
}, {"id": existing[0].id}) }, {"id": existing[0].id})
else: else:
await sor.I("rl_org_group", { await sor.C("rl_org_group", {
"id": mapping_id, "id": mapping_id,
"org_id": org_id, "org_id": org_id,
"vendor": vendor, "vendor": vendor,