diff --git a/pbl_assessment/seed.py b/pbl_assessment/seed.py index 8f0527e..a6d35d3 100644 --- a/pbl_assessment/seed.py +++ b/pbl_assessment/seed.py @@ -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)