update

apps/airs_tasks.py

@@ -91,58 +91,58 @@ class Tasks(Base): # Tasks 类继承自 Base 类
             except Exception as e:
                 return {"success": False, "error": str(e)}
 
-        @self.mcp.tool()
-        def get_tasks(
-            status: Optional[str] = None, 
-            priority: Optional[str] = None
-        ) -> dict:
-            """
-            获取数据库中的任务列表（可选状态/优先级过滤）
-            Get a list of tasks from the database, with optional filtering by status or priority.
+        # @self.mcp.tool()
+        # def get_tasks(
+        #     status: Optional[str] = None, 
+        #     priority: Optional[str] = None
+        # ) -> dict:
+        #     """
+        #     获取数据库中的任务列表（可选状态/优先级过滤）
+        #     Get a list of tasks from the database, with optional filtering by status or priority.
     
-            Args:
-                status: 任务状态过滤值（可选）
-                priority: 任务优先级过滤值（可选）
+        #     Args:
+        #         status: 任务状态过滤值（可选）
+        #         priority: 任务优先级过滤值（可选）
     
-            Returns:
-            {
-                "success": True, 
-                "tasks": [...]   # 成功时返回任务列表
-            } or {
-                "success": False, 
-                "error": "错误描述"  # 失败时返回错误原因
-            }
-            """
-            try:
-                # 构造基础查询
-                query = self.supabase.table('tasks').select('*')
+        #     Returns:
+        #     {
+        #         "success": True, 
+        #         "tasks": [...]   # 成功时返回任务列表
+        #     } or {
+        #         "success": False, 
+        #         "error": "错误描述"  # 失败时返回错误原因
+        #     }
+        #     """
+        #     try:
+        #         # 构造基础查询
+        #         query = self.supabase.table('tasks').select('*')
         
-                # 动态添加过滤条件
-                if status:
-                    query = query.eq('status', status.lower())  # 添加状态小写转换保证一致性
-                if priority:
-                    query = query.eq('priority', priority.lower())
+        #         # 动态添加过滤条件
+        #         if status:
+        #             query = query.eq('status', status.lower())  # 添加状态小写转换保证一致性
+        #         if priority:
+        #             query = query.eq('priority', priority.lower())
         
-                print("正在执行 Supabase 查询...")
-                response = query.execute()
-                print("Supabase 查询执行完成。")
+        #         print("正在执行 Supabase 查询...")
+        #         response = query.execute()
+        #         print("Supabase 查询执行完成。")
         
-                # 明确处理空结果（非错误状态）
-                if not response.data:
-                    print("未找到任务。")
-                    return {"success": True, "tasks": []}
+        #         # 明确处理空结果（非错误状态）
+        #         if not response.data:
+        #             print("未找到任务。")
+        #             return {"success": True, "tasks": []}
         
-                print(f"找到 {len(response.data)} 个任务。")
+        #         print(f"找到 {len(response.data)} 个任务。")
         
-                return {"success": True, "tasks": response.data}
+        #         return {"success": True, "tasks": response.data}
         
-            except Exception as e:
-                # 捕获具体异常类型
-                error_msg = (
-                    f"Database query failed: {str(e)}. "
-                    f"Params: status={status}, priority={priority}"
-                )
-                return {"success": False, "error": error_msg}
+        #     except Exception as e:
+        #         # 捕获具体异常类型
+        #         error_msg = (
+        #             f"Database query failed: {str(e)}. "
+        #             f"Params: status={status}, priority={priority}"
+        #         )
+        #         return {"success": False, "error": error_msg}
 
 
         @self.mcp.tool()
@@ -178,3 +178,46 @@ class Tasks(Base): # Tasks 类继承自 Base 类
                     return {"success": False, "error": response.error.message if response.error else "Task not found or unknown error"}
             except Exception as e:
                 return {"success": False, "error": str(e)}
+
+
+
+
+        @self.mcp.tool()
+        def get_tasks(
+            status: Optional[str] = None, 
+            priority: Optional[str] = None
+        ) -> dict:
+            """
+            获取数据库中的任务列表（可选状态/优先级过滤）
+            """
+            try:
+                return {"success": True, "tasks": [{"title": "示例任务", "description": "这是一个示例任务"}]}
+                # 构造基础查询
+                query = self.supabase.table('tasks').select('*')
+        
+                # 动态添加过滤条件
+                if status:
+                    query = query.eq('status', status.lower())  # 添加状态小写转换保证一致性
+                if priority:
+                    query = query.eq('priority', priority.lower())
+        
+                print("正在执行 Supabase 查询...")
+                response = query.execute()
+                print("Supabase 查询执行完成。")
+        
+                # 明确处理空结果（非错误状态）
+                if not response.data:
+                    print("未找到任务。")
+                    return {"success": True, "tasks": []}
+        
+                print(f"找到 {len(response.data)} 个任务。")
+        
+                return {"success": True, "tasks": response.data}
+        
+            except Exception as e:
+                # 捕获具体异常类型
+                error_msg = (
+                    f"Database query failed: {str(e)}. "
+                    f"Params: status={status}, priority={priority}"
+                )
+                return {"success": False, "error": error_msg}

memory-bank/progress.md

@@ -18,3 +18,4 @@
 
 **已知问题:**
 - 在服务重启后，可能需要短暂等待才能成功调用新添加的工具（可能是初始化时间）。
+- `get_tasks`工具在n8n环境中出现错误。