diff --git a/src/common/database/sqlalchemy_database_api.py b/src/common/database/sqlalchemy_database_api.py
index 7f740818c..210882dc8 100644
--- a/src/common/database/sqlalchemy_database_api.py
+++ b/src/common/database/sqlalchemy_database_api.py
@@ -124,6 +124,10 @@ async def db_query(
             raise ValueError("query_type must be 'get', 'create', 'update', 'delete' or 'count'")
 
         async with get_db_session() as session:
+            if not session:
+                logger.error("[SQLAlchemy] 无法获取数据库会话")
+                return None if single_result else []
+
             if query_type == "get":
                 query = select(model_class)
 
@@ -221,7 +225,7 @@ async def db_query(
                 # 删除记录
                 affected_rows = 0
                 for record in records_to_delete:
-                    session.delete(record)
+                    await session.delete(record)
                     affected_rows += 1
 
                 return affected_rows
@@ -274,6 +278,9 @@ async def db_save(
     """
     try:
         async with get_db_session() as session:
+            if not session:
+                logger.error("[SQLAlchemy] 无法获取数据库会话")
+                return None
             # 如果提供了key_field和key_value，尝试更新现有记录
             if key_field and key_value is not None:
                 if hasattr(model_class, key_field):
diff --git a/src/plugins/built_in/proactive_thinker/proactive_thinker_executor.py b/src/plugins/built_in/proactive_thinker/proactive_thinker_executor.py
index 4c61ce3e7..b5f280fee 100644
--- a/src/plugins/built_in/proactive_thinker/proactive_thinker_executor.py
+++ b/src/plugins/built_in/proactive_thinker/proactive_thinker_executor.py
@@ -128,7 +128,9 @@ class ProactiveThinkerExecutor:
             limit=3,
             order_by=["-time"]
         )
-        action_history_context = "\n".join([f"- {a['action_data']}" for a in action_history]) if action_history else "无"
+        action_history_context = "无"
+        if isinstance(action_history, list):
+            action_history_context = "\n".join([f"- {a['action_data']}" for a in action_history if isinstance(a, dict)]) or "无"
 
         return {
             "person_id": person_id,