From 90c93dbe07d076d149011fa4b14641f768e57c3f Mon Sep 17 00:00:00 2001
From: yumoqing <yumoqing@gmail.com>
Date: Thu, 4 Jun 2026 15:12:29 +0800
Subject: [PATCH] =?UTF-8?q?feat:=20get=5Fmy=5Fasynctasks=20=E8=BF=94?=
 =?UTF-8?q?=E5=9B=9E=E8=AE=B0=E5=BD=95=E5=A2=9E=E5=8A=A0=20llmcatelogid=20?=
 =?UTF-8?q?=E5=B1=9E=E6=80=A7?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

通过 llmid 查询 llm_api_map 表获取对应的 llmcatelogid
---
 wwwroot/get_my_asynctasks.dspy | 16 +++++++++++++---
 1 file changed, 13 insertions(+), 3 deletions(-)

diff --git a/wwwroot/get_my_asynctasks.dspy b/wwwroot/get_my_asynctasks.dspy
index 3fb6738..7c2e09a 100644
--- a/wwwroot/get_my_asynctasks.dspy
+++ b/wwwroot/get_my_asynctasks.dspy
@@ -1,9 +1,19 @@
 userid = await get_user()
 tasks = await get_today_asynctask_list(userid)
 
-for t in tasks:
-	bin = await read_webpath(t.ioinfo)
-	t.ioinfo = json.loads(bin.decode('utf-8'))
+async with get_sor_context(request._run_ns, 'llmage') as sor:
+	for t in tasks:
+		bin = await read_webpath(t.ioinfo)
+		t.ioinfo = json.loads(bin.decode('utf-8'))
+		
+		# 查询 llmcatelogid
+		llmcatelogid = 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
 
 return {
 	'status': 'ok',