fix: CRUD dspy — move return outside async with, fix dbname underscore

This commit is contained in:
yumoqing 2026-08-03 17:40:30 +08:00
parent f86cce02f4
commit 958431d282
8 changed files with 63 additions and 0 deletions

View File

@ -0,0 +1,8 @@
db = DBPools()
dbname = get_module_dbname('pipeline_sdlc')
ns = dict(params_kw)
ns['id'] = getID()
ns['org_id'] = (await get_userorgid()) or '0'
async with db.sqlorContext(dbname) as sor:
await sor.C('sd_org_settings', ns)
return {'success': True}

View File

@ -0,0 +1,5 @@
db = DBPools()
dbname = get_module_dbname('pipeline_sdlc')
async with db.sqlorContext(dbname) as sor:
await sor.D('sd_org_settings', dict(params_kw))
return {'success': True}

View File

@ -0,0 +1,11 @@
db = DBPools()
dbname = get_module_dbname('pipeline_sdlc')
rows = []
total = 0
async with db.sqlorContext(dbname) as sor:
recs = await sor.sqlExe('SELECT * FROM sd_org_settings ORDER BY created_at DESC')
for r in (recs or []):
rows.append({'id': r.id, 'org_id': r.org_id, 'workspace_root': r.workspace_root,
'skills_dir': getattr(r, 'skills_dir', '') or ''})
total = len(rows)
return {'total': total, 'rows': rows}

View File

@ -0,0 +1,5 @@
db = DBPools()
dbname = get_module_dbname('pipeline_sdlc')
async with db.sqlorContext(dbname) as sor:
await sor.U('sd_org_settings', dict(params_kw))
return {'success': True}

View File

@ -0,0 +1,8 @@
db = DBPools()
dbname = get_module_dbname('pipeline_sdlc')
ns = dict(params_kw)
ns['id'] = getID()
ns['org_id'] = (await get_userorgid()) or '0'
async with db.sqlorContext(dbname) as sor:
await sor.C('sd_project_repos', ns)
return {'success': True}

View File

@ -0,0 +1,5 @@
db = DBPools()
dbname = get_module_dbname('pipeline_sdlc')
async with db.sqlorContext(dbname) as sor:
await sor.D('sd_project_repos', dict(params_kw))
return {'success': True}

View File

@ -0,0 +1,16 @@
db = DBPools()
dbname = get_module_dbname('pipeline_sdlc')
rows = []
total = 0
async with db.sqlorContext(dbname) as sor:
pid = params_kw.get('project_id', '')
if pid:
recs = await sor.sqlExe('SELECT * FROM sd_project_repos WHERE project_id=$ ORDER BY created_at DESC', {'pid': pid})
else:
recs = await sor.sqlExe('SELECT * FROM sd_project_repos ORDER BY created_at DESC')
for r in (recs or []):
rows.append({'id': r.id, 'project_id': r.project_id, 'repo_name': r.repo_name,
'repo_url': r.repo_url, 'default_branch': r.default_branch,
'local_path': getattr(r, 'local_path', '') or ''})
total = len(rows)
return {'total': total, 'rows': rows}

View File

@ -0,0 +1,5 @@
db = DBPools()
dbname = get_module_dbname('pipeline_sdlc')
async with db.sqlorContext(dbname) as sor:
await sor.U('sd_project_repos', dict(params_kw))
return {'success': True}