diff --git a/wwwroot/api/bid_task_tree.dspy b/wwwroot/api/bid_task_tree.dspy index 7d53832..c1c5952 100644 --- a/wwwroot/api/bid_task_tree.dspy +++ b/wwwroot/api/bid_task_tree.dspy @@ -165,8 +165,9 @@ async with DBPools().sqlorContext(dbname) as sor: for t in role_tasks: key = (_params_of(t).get('analysis_dim') or '').strip() 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) for key in groups: groups[key].sort(key=lambda x: str(getattr(x, 'created_at', '') or '')) @@ -348,7 +349,8 @@ async with DBPools().sqlorContext(dbname) as sor: continue k = (_params_of2(t).get('analysis_dim') or '').strip() 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: ts.append(t) ts.sort(key=lambda x: str(getattr(x, 'created_at', '') or ''))