yumoqing/pipeline-bidding
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: 人工修正组识别补'补录'（title+params联合匹配）

Browse Source
This commit is contained in:
yumoqing 2026-09-03 17:12:19 +08:00
parent 1679c76fd4
commit 3c1960b749
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
wwwroot/api/bid_task_tree.dspy
View File

@ -165,8 +165,9 @@ async with DBPools().sqlorContext(dbname) as sor:
for t in role_tasks: for t in role_tasks:
key = (_params_of(t).get('analysis_dim') or '').strip() key = (_params_of(t).get('analysis_dim') or '').strip()
if not key: if not key:
# 无维度：人工定向修正任务单独成组，其余归遗留全量解析 # 无维度：人工定向修正/补录任务单独成组，其余归遗留全量解析
key = '__manual__' if '修正' in (getattr(t, 'title', '') or '') else '__legacy__' blob = (getattr(t, 'title', '') or '') + (getattr(t, 'params', '') or '')
key = '__manual__' if ('修正' in blob or '补录' in blob) else '__legacy__'
groups.setdefault(key, []).append(t) groups.setdefault(key, []).append(t)
for key in groups: for key in groups:
groups[key].sort(key=lambda x: str(getattr(x, 'created_at', '') or '')) groups[key].sort(key=lambda x: str(getattr(x, 'created_at', '') or ''))
@ -348,7 +349,8 @@ async with DBPools().sqlorContext(dbname) as sor:
continue continue
k = (_params_of2(t).get('analysis_dim') or '').strip() k = (_params_of2(t).get('analysis_dim') or '').strip()
if not k: if not k:
k = '__manual__' if '修正' in (getattr(t, 'title', '') or '') else '__legacy__' blob = (getattr(t, 'title', '') or '') + (getattr(t, 'params', '') or '')
k = '__manual__' if ('修正' in blob or '补录' in blob) else '__legacy__'
if k == key: if k == key:
ts.append(t) ts.append(t)
ts.sort(key=lambda x: str(getattr(x, 'created_at', '') or '')) ts.sort(key=lambda x: str(getattr(x, 'created_at', '') or ''))