|
|
@@ -297,9 +297,9 @@ class AiAssistantMcp {
|
|
|
return asJson({ list: rows.map(mapLepaoRecord), pagination: pagination(page, totalRows) })
|
|
|
}
|
|
|
|
|
|
- async list_lepao_count_ledger(args) {
|
|
|
- const { sender, biz_type, remark, start_time, end_time, current, pagesize } = args
|
|
|
- if (required([sender])) return '缺少 sender'
|
|
|
+ async list_lepao_count_ledger(args) {
|
|
|
+ const { sender, biz_type, remark, start_time, end_time, current, pagesize } = args
|
|
|
+ if (required([sender])) return '缺少 sender'
|
|
|
const page = pageArgs({ current, pagesize })
|
|
|
const where = ['user_uuid = ?']
|
|
|
const params = [sender]
|
|
|
@@ -337,8 +337,24 @@ class AiAssistantMcp {
|
|
|
if (!rows || !totalRows) return '查询失败'
|
|
|
return asJson({ list: rows.map(mapCountLedger), pagination: pagination(page, totalRows) })
|
|
|
}
|
|
|
-
|
|
|
- async list_goods(args) {
|
|
|
+
|
|
|
+ async get_lepao_count_balance(args) {
|
|
|
+ const { sender } = args
|
|
|
+ if (required([sender])) return '缺少 sender'
|
|
|
+
|
|
|
+ const rows = await db.query(
|
|
|
+ 'SELECT username, lepao_count FROM users WHERE uuid = ? LIMIT 1',
|
|
|
+ [sender]
|
|
|
+ )
|
|
|
+ if (!rows || rows.length !== 1) return '获取用户乐跑次数余额失败'
|
|
|
+
|
|
|
+ return asJson({
|
|
|
+ username: rows[0].username,
|
|
|
+ lepao_count: Number(rows[0].lepao_count || 0)
|
|
|
+ })
|
|
|
+ }
|
|
|
+
|
|
|
+ async list_goods(args) {
|
|
|
const { keyword, category, current, pagesize } = args
|
|
|
const page = pageArgs({ current, pagesize })
|
|
|
const where = ['state = 1']
|