deliver: 交付收口(引擎代为提交)

This commit is contained in:
agent.develop 2026-10-13 14:49:41 +08:00
parent a9a938a260
commit e96511dae9

View File

@ -125,7 +125,7 @@ async def seed_rubrics(dbname=None, tenant_id=None):
:param tenant_id: 可选,租户 ID(缺省使用 __system__)
:return: dict {ok, rubrics_inserted, criteria_inserted, errors}
"""
from pbl_common.api import sql_exe, sql_rows
from pbl_common.api import sql_exec, sql_rows
import time as _time
tid = tenant_id or SYSTEM_TENANT
@ -144,7 +144,7 @@ async def seed_rubrics(dbname=None, tenant_id=None):
row.setdefault('update_time', now)
cols = ','.join('`%s`' % k for k in row)
vals = ','.join('${%s}$' % k for k in row)
await sql_exe('INSERT INTO `%s` (%s) VALUES (%s)' % (TBL_RUBRIC, cols, vals), row)
await sql_exec('INSERT INTO `%s` (%s) VALUES (%s)' % (TBL_RUBRIC, cols, vals), row)
result['rubrics_inserted'] = 1
except Exception as exc:
err = '默认量规写入失败: %s' % exc
@ -166,7 +166,7 @@ async def seed_rubrics(dbname=None, tenant_id=None):
row.setdefault('update_time', now)
cols = ','.join('`%s`' % k for k in row)
vals = ','.join('${%s}$' % k for k in row)
await sql_exe('INSERT INTO `%s` (%s) VALUES (%s)' % (TBL_RUBRIC_CRITERION, cols, vals), row)
await sql_exec('INSERT INTO `%s` (%s) VALUES (%s)' % (TBL_RUBRIC_CRITERION, cols, vals), row)
result['criteria_inserted'] += 1
except Exception as exc:
err = '准则 %s 写入失败: %s' % (crit.get('code'), exc)