From 248a0fa97990da9ec7f571375f50477013aa72ae Mon Sep 17 00:00:00 2001
From: yumoqing <yumoqing@gmail.com>
Date: Fri, 8 May 2026 15:17:19 +0800
Subject: [PATCH] fix: DBPools Singleton - manually set db.databases after
 getting instance

---
 customer_management/core.py | 32 ++++++++++++++++++++++++--------
 1 file changed, 24 insertions(+), 8 deletions(-)

diff --git a/customer_management/core.py b/customer_management/core.py
index cb8af3f..09d02b9 100644
--- a/customer_management/core.py
+++ b/customer_management/core.py
@@ -24,7 +24,9 @@ async def create_customer(
     """创建客户档案"""
     config = getConfig()
 
-    db = DBPools(config.databases)
+    db = DBPools()
+
+    db.databases = config.databases
     async with db.sqlorContext('customer_management') as sor:
         customer_id = str(uuid.uuid4()).replace('-', '')
         
@@ -78,7 +80,9 @@ async def initiate_handover(
     """发起客户交接流程"""
     config = getConfig()
 
-    db = DBPools(config.databases)
+    db = DBPools()
+
+    db.databases = config.databases
     async with db.sqlorContext('customer_management') as sor:
         # 获取客户信息
         customer_records = await sor.R("customers", {"filters": [{"field": "id", "op": "=", "value": customer_id}]})
@@ -210,7 +214,9 @@ async def complete_handover_preparation(handover_id: str) -> Dict:
     """完成交接准备阶段"""
     config = getConfig()
 
-    db = DBPools(config.databases)
+    db = DBPools()
+
+    db.databases = config.databases
     async with db.sqlorContext('customer_management') as sor:
         handover_records = await sor.R("customer_handover", {"filters": [{"field": "id", "op": "=", "value": handover_id}]})
         if not handover_records or len(handover_records) == 0:
@@ -238,7 +244,9 @@ async def approve_handover(handover_id: str, approver_id: str = None) -> Dict:
     """审核交接清单"""
     config = getConfig()
 
-    db = DBPools(config.databases)
+    db = DBPools()
+
+    db.databases = config.databases
     async with db.sqlorContext('customer_management') as sor:
         approver_id = approver_id or get_current_user_id()
         
@@ -268,7 +276,9 @@ async def confirm_handover(handover_id: str, confirm_by: str = None) -> Dict:
     """确认接收客户"""
     config = getConfig()
 
-    db = DBPools(config.databases)
+    db = DBPools()
+
+    db.databases = config.databases
     async with db.sqlorContext('customer_management') as sor:
         confirm_by = confirm_by or get_current_user_id()
         
@@ -329,7 +339,9 @@ async def recycle_to_pool(customer_id: str, inactive_days: int = None, reason: s
     """回收客户到公海池"""
     config = getConfig()
 
-    db = DBPools(config.databases)
+    db = DBPools()
+
+    db.databases = config.databases
     async with db.sqlorContext('customer_management') as sor:
         customer_records = await sor.R("customers", {"filters": [{"field": "id", "op": "=", "value": customer_id}]})
         if not customer_records or len(customer_records) == 0:
@@ -372,7 +384,9 @@ async def claim_from_pool(pool_id: str, new_owner_id: str = None):
     """从公海池认领客户"""
     config = getConfig()
 
-    db = DBPools(config.databases)
+    db = DBPools()
+
+    db.databases = config.databases
     async with db.sqlorContext('customer_management') as sor:
         new_owner_id = new_owner_id or get_current_user_id()
         
@@ -415,7 +429,9 @@ async def get_customer_360_view(customer_id: str) -> Dict:
     """获取客户360度视图"""
     config = getConfig()
 
-    db = DBPools(config.databases)
+    db = DBPools()
+
+    db.databases = config.databases
     async with db.sqlorContext('customer_management') as sor:
         # 客户基本信息
         customer_records = await sor.R("customers", {"filters": [{"field": "id", "op": "=", "value": customer_id}]})