From 46fba982020fa546c5e6cc8b5e7e11e8c4152075 Mon Sep 17 00:00:00 2001
From: H3CoF6 <1707889225@qq.com>
Date: Sat, 28 Mar 2026 04:33:07 +0800
Subject: [PATCH] fix(biz): fix database_error

---
 frontend/components/BizMessages.vue    |  3 +++
 frontend/composables/useApi.js         | 26 ++++++++++++++++++++------
 src/wechat_decrypt_tool/routers/biz.py | 10 +++++-----
 3 files changed, 28 insertions(+), 11 deletions(-)

diff --git a/frontend/components/BizMessages.vue b/frontend/components/BizMessages.vue
index 473d141..4fea9e6 100644
--- a/frontend/components/BizMessages.vue
+++ b/frontend/components/BizMessages.vue
@@ -132,6 +132,9 @@
 <script setup>
 import { ref, computed, onMounted } from 'vue'
 
+import { useApi } from '~/composables/useApi'
+const api = useApi()
+
 // 状态
 const accounts = ref([])
 const loadingAccounts = ref(false)
diff --git a/frontend/composables/useApi.js b/frontend/composables/useApi.js
index ee75f15..c3585e8 100644
--- a/frontend/composables/useApi.js
+++ b/frontend/composables/useApi.js
@@ -562,18 +562,32 @@ export const useApi = () => {
   }
 
   // 枚举服务号信息
-  const listBizAccounts = async (params) => {
-    return await request('/biz/list', params)
+  const listBizAccounts = async (params = {}) => {
+    const query = new URLSearchParams()
+    if (params && params.account) query.set('account', params.account)
+    const url = '/biz/list' + (query.toString() ? `?${query.toString()}` : '')
+    return await request(url)
   }
 
   // 获取普通服务号消息
-  const listBizMessages = async (params) => {
-    return await request('/biz/messages', params)
+  const listBizMessages = async (params = {}) => {
+    const query = new URLSearchParams()
+    if (params && params.account) query.set('account', params.account)
+    if (params && params.username) query.set('username', params.username)
+    if (params && params.limit != null) query.set('limit', String(params.limit))
+    if (params && params.offset != null) query.set('offset', String(params.offset))
+    const url = '/biz/messages' + (query.toString() ? `?${query.toString()}` : '')
+    return await request(url)
   }
 
   // 获取微信支付记录
-  const listBizPayRecords = async (params) => {
-    return await request('/biz/pay_records', params)
+  const listBizPayRecords = async (params = {}) => {
+    const query = new URLSearchParams()
+    if (params && params.account) query.set('account', params.account)
+    if (params && params.limit != null) query.set('limit', String(params.limit))
+    if (params && params.offset != null) query.set('offset', String(params.offset))
+    const url = '/biz/pay_records' + (query.toString() ? `?${query.toString()}` : '')
+    return await request(url)
   }
 
   return {
diff --git a/src/wechat_decrypt_tool/routers/biz.py b/src/wechat_decrypt_tool/routers/biz.py
index 3f91c34..8c87810 100644
--- a/src/wechat_decrypt_tool/routers/biz.py
+++ b/src/wechat_decrypt_tool/routers/biz.py
@@ -188,8 +188,8 @@ def get_biz_account_list(account: Optional[str] = None):
     for uid in biz_ids:
         if uid in contact_info:
             result.append(contact_info[uid])
-        else:
-            result.append({"username": uid, "name": uid, "avatar": ""})
+        # else:
+        #     result.append({"username": uid, "name": uid, "avatar": ""})
 
     return {"status": "success", "total": len(result), "data": result}
 
@@ -209,7 +209,7 @@ def get_biz_messages(username: str, account: Optional[str] = None, limit: int =
         conn = sqlite3.connect(str(db_file))
         try:
             res = conn.execute("SELECT name FROM sqlite_master WHERE type='table' AND lower(name)=?",
-                               (table_name,)).fetchone()
+                               (table_name.lower(),)).fetchone()
             if res:
                 target_db = db_file
                 break
@@ -254,7 +254,6 @@ def get_biz_messages(username: str, account: Optional[str] = None, limit: int =
     return {"status": "success", "data": messages}
 
 
-# 接口 3：返回微信支付的 json 消息
 @router.get("/api/biz/pay_records", summary="获取微信支付记录")
 def get_wechat_pay_records(account: Optional[str] = None, limit: int = 50, offset: int = 0):
     username = "gh_3dfda90e39d6"
@@ -264,10 +263,11 @@ def get_wechat_pay_records(account: Optional[str] = None, limit: int = 50, offse
 
     target_db = None
     for db_file in account_dir.glob("biz_message*.db"):
+        # print(db_file)
         conn = sqlite3.connect(str(db_file))
         try:
             res = conn.execute("SELECT name FROM sqlite_master WHERE type='table' AND lower(name)=?",
-                               (table_name,)).fetchone()
+                               (table_name.lower(),)).fetchone()
             if res:
                 target_db = db_file
                 break