From b95722ec0144e560848b4a75e27bdcf0166add5a Mon Sep 17 00:00:00 2001
From: yumoqing <yumoqing@gmail.com>
Date: Wed, 20 Aug 2025 15:46:34 +0800
Subject: [PATCH] bugfix

---
 wwwroot/program_selected.dspy | 33 +++++++++++++++++++++++++++++++++
 wwwroot/test_fusesearch.dspy  |  6 ++++++
 2 files changed, 39 insertions(+)
 create mode 100644 wwwroot/program_selected.dspy
 create mode 100644 wwwroot/test_fusesearch.dspy

diff --git a/wwwroot/program_selected.dspy b/wwwroot/program_selected.dspy
new file mode 100644
index 0000000..997dddc
--- /dev/null
+++ b/wwwroot/program_selected.dspy
@@ -0,0 +1,33 @@
+
+db = DBPools()
+dbname = get_module_dbname('rag')
+async with db.sqlorContext(dbname) as sor:
+	u = await get_session_userinfo(request)
+	sql="select * from ragquote where orgid = ${orgid}$ order by enabled_date"
+	qs = await sor.sqlExe(sql, {'orgid': u.userorgid})
+	today = curDateString()
+	if len(qs) == 0:
+		if params_kw.program_type == 'free':
+			expired_date = dateadd(today, months=1)
+		else:
+			expired_date = '9999-12-31'
+		ns = {
+			"id": uuid(),
+			"orgid": u.userorgid,
+			"enabled_date": today,
+			"expired_date": expired_date,
+			'quota': params_kw.quota
+		}
+		await sor.C('ragquota', ns)
+	else:
+		lastq = qs[-1]
+		lastq.expired_date = today
+		await sor.U('ragquote', lastq.copy())
+		ns = {
+			"id": uuid(),
+			"orgid": u.userorgid,
+			"enabled_date": today,
+			"expired_date": expired_date,
+			'quota': params_kw.quota
+		}
+		await sor.C('ragquota', ns)
diff --git a/wwwroot/test_fusesearch.dspy b/wwwroot/test_fusesearch.dspy
new file mode 100644
index 0000000..9c274ef
--- /dev/null
+++ b/wwwroot/test_fusesearch.dspy
@@ -0,0 +1,6 @@
+debug(f'{params=}')
+fiid = params_kw.ffid
+query = params_kw.query
+rf = RegisteFunction('fusedsearch')
+x = await rf.exe('fusedsearch', params_kw, DictObject(**globals()))
+return x