From 6bfa0cb27ca19758d7869d9826d2b065d0e2f865 Mon Sep 17 00:00:00 2001 From: yumoqing Date: Thu, 4 Jun 2026 17:01:29 +0800 Subject: [PATCH] feat: add llmcatelogid filter param (default t2t) to get_my_asynctasks API --- wwwroot/get_my_asynctasks.dspy | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) diff --git a/wwwroot/get_my_asynctasks.dspy b/wwwroot/get_my_asynctasks.dspy index 7c2e09a..e8d6929 100644 --- a/wwwroot/get_my_asynctasks.dspy +++ b/wwwroot/get_my_asynctasks.dspy @@ -1,4 +1,5 @@ userid = await get_user() +llmcatelogid = params_kw.get('llmcatelogid', 't2t') tasks = await get_today_asynctask_list(userid) async with get_sor_context(request._run_ns, 'llmage') as sor: @@ -7,13 +8,16 @@ async with get_sor_context(request._run_ns, 'llmage') as sor: t.ioinfo = json.loads(bin.decode('utf-8')) # 查询 llmcatelogid - llmcatelogid = None + catid = None if hasattr(t, 'llmid') and t.llmid: sql = '''select m.llmcatelogid from llm_api_map m where m.llmid = ${llmid}$ limit 1''' recs = await sor.sqlExe(sql, {'llmid': t.llmid}) if recs: - llmcatelogid = recs[0].llmcatelogid - t.llmcatelogid = llmcatelogid + catid = recs[0].llmcatelogid + t.llmcatelogid = catid + +# 按 llmcatelogid 过滤 +tasks = [t for t in tasks if t.llmcatelogid == llmcatelogid] return { 'status': 'ok',