From 984894d797ca2b5beb6046cc730584b8564d98b4 Mon Sep 17 00:00:00 2001
From: "tao.chen" <93983997+taochen-ct@users.noreply.github.com>
Date: Fri, 7 Aug 2026 14:40:46 +0800
Subject: [PATCH] refactor: SchedulesPageRoute.tsx, UserManagementPage.tsx,
 ProjectManagementPage.tsx

---
 .../admin/ProjectManagementPage.tsx           |  202 ++-
 .../components/admin/UserManagementPage.tsx   |  161 +--
 .../app/features/admin/SystemAdminRoute.tsx   |    4 -
 .../app/features/admin/state/adminStore.ts    |  476 +++++++
 .../app/features/schedules/SchedulePage.tsx   |   58 +-
 .../features/schedules/SchedulesPageRoute.tsx |    4 -
 .../schedules/state/schedulesStore.ts         | 1160 +++++++++++++++++
 frontend/app/routes/platform.tsx              |    6 +
 8 files changed, 1831 insertions(+), 240 deletions(-)
 create mode 100644 frontend/app/features/admin/state/adminStore.ts
 create mode 100644 frontend/app/features/schedules/state/schedulesStore.ts

diff --git a/frontend/app/components/admin/ProjectManagementPage.tsx b/frontend/app/components/admin/ProjectManagementPage.tsx
index 4560c97..728e8bf 100644
--- a/frontend/app/components/admin/ProjectManagementPage.tsx
+++ b/frontend/app/components/admin/ProjectManagementPage.tsx
@@ -1,79 +1,73 @@
-import { useEffect, useState } from "react";
+import { useEffect, type FormEvent } from "react";
 
-import { ApiRequestError, type Employee, type Workspace } from "../../services/api";
-import { useApi, useAuth } from "../../context/AuthContext";
+import { type Workspace } from "../../services/api";
+import { useAuth } from "../../context/AuthContext";
 import Icon from "../common/Icon";
+import { useAdminStore } from "../../features/admin/state/adminStore";
 
 import "../../styles/admin.css";
 import { UserMultiSelect } from "./UserMultiSelect";
 
-const EMPTY_PROJECT_FORM = {
-  workspace_code: "",
-  workspace_name: "",
-  quota_bytes: 0,
-  description: "",
+type Notice = {
+  tone: "success" | "error" | "info";
+  message: string;
 };
 
 export function ProjectManagementPage({
   onNotify,
   onConnectionChange,
 }: {
-  onNotify: (notice: { tone: "success" | "error" | "info"; message: string }) => void;
+  onNotify: (notice: Notice) => void;
   onConnectionChange: (online: boolean) => void;
 }) {
-  const api = useApi();
-  const { user } = useAuth();
-  const [projects, setProjects] = useState<Workspace[]>([]);
-  const [projectLoading, setProjectLoading] = useState(true);
-  const [projectDialogOpen, setProjectDialogOpen] = useState(false);
-  const [projectForm, setProjectForm] = useState(EMPTY_PROJECT_FORM);
-  const [editingProject, setEditingProject] = useState<Workspace | null>(null);
-  const [importMemberDialogOpen, setImportMemberDialogOpen] = useState(false);
-  const [selectedProject, setSelectedProject] = useState<Workspace | null>(null);
-  const [availableUsers, setAvailableUsers] = useState<Employee[]>([]);
-  const [selectedUserIds, setSelectedUserIds] = useState<string[]>([]);
-  const [selectedRoleCode, setSelectedRoleCode] = useState<"admin" | "developer">("developer");
-  const [projectSearchTerm, setProjectSearchTerm] = useState("");
-  const [saving, setSaving] = useState(false);
+  const { user, currentWorkspace } = useAuth();
+
+  const projects = useAdminStore((s) => s.projects);
+  const projectLoading = useAdminStore((s) => s.projectsLoading);
+  const saving = useAdminStore((s) => s.projectsSaving);
+  const editingProject = useAdminStore((s) => s.editingProject);
+  const projectDialogOpen = useAdminStore((s) => s.projectDialogOpen);
+  const projectForm = useAdminStore((s) => s.projectForm);
+  const importMemberDialogOpen = useAdminStore((s) => s.importMemberDialogOpen);
+  const selectedProject = useAdminStore((s) => s.selectedProject);
+  const availableUsers = useAdminStore((s) => s.availableUsers);
+  const selectedUserIds = useAdminStore((s) => s.selectedUserIds);
+  const selectedRoleCode = useAdminStore((s) => s.selectedRoleCode);
+  const projectSearchTerm = useAdminStore((s) => s.projectSearchTerm);
+
+  const setProjectDialogOpen = useAdminStore((s) => s.setProjectDialogOpen);
+  const setProjectForm = useAdminStore((s) => s.setProjectForm);
+  const setEditingProject = useAdminStore((s) => s.setEditingProject);
+  const setImportMemberDialogOpen = useAdminStore((s) => s.setImportMemberDialogOpen);
+  const setSelectedProject = useAdminStore((s) => s.setSelectedProject);
+  const setSelectedUserIds = useAdminStore((s) => s.setSelectedUserIds);
+  const setSelectedRoleCode = useAdminStore((s) => s.setSelectedRoleCode);
+  const setProjectSearchTerm = useAdminStore((s) => s.setProjectSearchTerm);
+
+  const loadProjects = useAdminStore((s) => s.loadProjects);
+  const createProject = useAdminStore((s) => s.createProject);
+  const updateProject = useAdminStore((s) => s.updateProject);
+  const deleteProject = useAdminStore((s) => s.deleteProject);
+  const openImportMembers = useAdminStore((s) => s.openImportMembers);
+  const importMembers = useAdminStore((s) => s.importMembers);
+  const reset = useAdminStore((s) => s.reset);
 
   const canManage = user?.role_code === "admin";
 
-  const loadProjects = async (): Promise<void> => {
-    setProjectLoading(true);
-    try {
-      const workspaceList = await api.listWorkspaces();
-      setProjects(workspaceList);
-      onConnectionChange(true);
-    } catch (error) {
-      onConnectionChange(false);
-      onNotify({
-        tone: "error",
-        message: error instanceof Error ? error.message : "项目列表加载失败",
-      });
-    } finally {
-      setProjectLoading(false);
-    }
-  };
-
-  const loadAvailableUsers = async (): Promise<void> => {
-    try {
-      const list = await api.listEmployees();
-      setAvailableUsers(list);
-    } catch (error) {
-      onNotify({
-        tone: "error",
-        message: error instanceof Error ? error.message : "用户列表加载失败",
-      });
-    }
-  };
-
+  const wsId = currentWorkspace?.workspace_id;
   useEffect(() => {
-    void loadProjects();
-  }, []);
+    reset();
+    void loadProjects(onNotify, onConnectionChange);
+  }, [loadProjects, reset, wsId, onNotify, onConnectionChange]);
 
   const openCreateProject = (): void => {
     setEditingProject(null);
-    setProjectForm(EMPTY_PROJECT_FORM);
+    setProjectForm({
+      workspace_code: "",
+      workspace_name: "",
+      quota_bytes: 0,
+      description: "",
+    });
     setProjectDialogOpen(true);
   };
 
@@ -88,7 +82,7 @@ export function ProjectManagementPage({
     setProjectDialogOpen(true);
   };
 
-  const submitProject = async (event: React.FormEvent): Promise<void> => {
+  const submitProject = async (event: FormEvent): Promise<void> => {
     event.preventDefault();
     if (!projectForm.workspace_name.trim()) {
       onNotify({ tone: "error", message: "请输入项目名称" });
@@ -98,87 +92,57 @@ export function ProjectManagementPage({
       onNotify({ tone: "error", message: "请输入项目编码" });
       return;
     }
-    setSaving(true);
-    try {
-      if (editingProject) {
-        const updated = await api.updateWorkspace(editingProject.workspace_id, {
+    if (editingProject) {
+      await updateProject(
+        editingProject,
+        {
           workspace_name: projectForm.workspace_name.trim(),
           quota_bytes: projectForm.quota_bytes,
-          description: projectForm.description.trim() || undefined,
-        });
-        setProjects((current) =>
-          current.map((p) => (p.workspace_id === updated.workspace_id ? updated : p))
-        );
-        onNotify({ tone: "success", message: "项目信息已更新" });
-      } else {
-        const generatedCode = projectForm.workspace_code.trim() || projectForm.workspace_name.trim().toLowerCase().replace(/[^a-z0-9-]/g, "-").slice(0, 32);
-        const created = await api.createWorkspace({
+          description: projectForm.description.trim() || "",
+        },
+        onNotify,
+        onConnectionChange,
+      );
+    } else {
+      const generatedCode = projectForm.workspace_code.trim()
+        || projectForm.workspace_name.trim().toLowerCase().replace(/[^a-z0-9-]/g, "-").slice(0, 32);
+      await createProject(
+        {
           workspace_code: generatedCode,
           workspace_name: projectForm.workspace_name.trim(),
           quota_bytes: projectForm.quota_bytes,
-          description: projectForm.description.trim() || undefined,
-        });
-        setProjects((current) => [...current, created]);
-        onNotify({ tone: "success", message: "项目已创建" });
-      }
-      setProjectDialogOpen(false);
-    } catch (error) {
-      onNotify({
-        tone: "error",
-        message: error instanceof ApiRequestError ? error.message : (editingProject ? "更新项目失败" : "创建项目失败"),
-      });
-    } finally {
-      setSaving(false);
+          description: projectForm.description.trim() || "",
+        },
+        onNotify,
+        onConnectionChange,
+      );
     }
   };
 
-  const deleteProject = async (project: Workspace): Promise<void> => {
+  const handleDelete = async (project: Workspace): Promise<void> => {
     if (!window.confirm(`确定要删除项目"${project.workspace_name}"吗？此操作将级联软删所有成员。`)) return;
-    try {
-      await api.deleteWorkspace(project.workspace_id);
-      setProjects((current) => current.filter((p) => p.workspace_id !== project.workspace_id));
-      onNotify({ tone: "success", message: "项目已删除" });
-    } catch (error) {
-      onNotify({
-        tone: "error",
-        message: error instanceof Error ? error.message : "删除项目失败",
-      });
-    }
+    await deleteProject(project, onNotify, onConnectionChange);
   };
 
   const openImportMemberDialog = (project: Workspace): void => {
     setSelectedProject(project);
     setSelectedUserIds([]);
     setSelectedRoleCode("developer");
-    void loadAvailableUsers();
-    setImportMemberDialogOpen(true);
+    void openImportMembers(project, onNotify);
   };
 
-  const importMember = async (): Promise<void> => {
+  const handleImportMember = async (): Promise<void> => {
     if (!selectedProject || selectedUserIds.length === 0) {
       onNotify({ tone: "error", message: "请选择要添加的用户" });
       return;
     }
-    setSaving(true);
-    try {
-      await Promise.all(
-        selectedUserIds.map((userId) =>
-          api.addWorkspaceMember(selectedProject.workspace_id, {
-            user_id: userId,
-            role_code: selectedRoleCode,
-          })
-        )
-      );
-      setImportMemberDialogOpen(false);
-      onNotify({ tone: "success", message: `已添加 ${selectedUserIds.length} 名成员` });
-    } catch (error) {
-      onNotify({
-        tone: "error",
-        message: error instanceof ApiRequestError ? error.message : "添加成员失败",
-      });
-    } finally {
-      setSaving(false);
-    }
+    if (!selectedProject) return;
+    await importMembers(
+      selectedProject,
+      selectedUserIds,
+      selectedRoleCode,
+      onNotify,
+    );
   };
 
   return (
@@ -253,7 +217,7 @@ export function ProjectManagementPage({
                     className="is-danger"
                     disabled={!canManage || project.status === "disabled"}
                     title={project.status === "disabled" ? "已删除的项目不能操作" : "删除项目"}
-                    onClick={() => void deleteProject(project)}
+                    onClick={() => void handleDelete(project)}
                   >
                     删除
                   </button>
@@ -354,7 +318,7 @@ export function ProjectManagementPage({
             </div>
             <div style={{ display: "flex", justifyContent: "flex-end", gap: "8px", padding: "16px 24px", borderTop: "1px solid #e8e8e8" }}>
               <button className="secondary-button" type="button" onClick={() => setImportMemberDialogOpen(false)}>取消</button>
-              <button className="primary-button" type="button" disabled={saving || selectedUserIds.length === 0} onClick={() => void importMember()}>
+              <button className="primary-button" type="button" disabled={saving || selectedUserIds.length === 0} onClick={() => void handleImportMember()}>
                 {saving ? "添加中…" : `添加 (${selectedUserIds.length})`}
               </button>
             </div>
@@ -363,4 +327,4 @@ export function ProjectManagementPage({
       )}
     </section>
   );
-}
+}
\ No newline at end of file
diff --git a/frontend/app/components/admin/UserManagementPage.tsx b/frontend/app/components/admin/UserManagementPage.tsx
index 42a88cd..f69bbf9 100644
--- a/frontend/app/components/admin/UserManagementPage.tsx
+++ b/frontend/app/components/admin/UserManagementPage.tsx
@@ -1,68 +1,69 @@
-import { useEffect, useState } from "react";
+import { useEffect, type FormEvent } from "react";
 
-import { ApiRequestError, type Employee } from "../../services/api";
-import { useApi, useAuth } from "../../context/AuthContext";
+import { type Employee } from "../../services/api";
+import { useAuth } from "../../context/AuthContext";
 import Icon from "../../components/common/Icon";
+import { useAdminStore } from "../../features/admin/state/adminStore";
 
 import "../../styles/admin.css";
 
-const EMPTY_FORM = {
-  username: "",
-  display_name: "",
-  email: "",
-  role_code: "developer" as "admin" | "developer",
-  password: "",
-  status: "active" as "active" | "disabled" | "locked",
+type Notice = {
+  tone: "success" | "error" | "info";
+  message: string;
 };
 
 export function UserManagementPage({
   onNotify,
   onConnectionChange,
 }: {
-  onNotify: (notice: { tone: "success" | "error" | "info"; message: string }) => void;
+  onNotify: (notice: Notice) => void;
   onConnectionChange: (online: boolean) => void;
 }) {
-  const api = useApi();
-  const { user } = useAuth();
-  const [employees, setEmployees] = useState<Employee[]>([]);
-  const [loading, setLoading] = useState(true);
-  const [saving, setSaving] = useState(false);
-  const [editing, setEditing] = useState<Employee | null>(null);
-  const [dialogOpen, setDialogOpen] = useState(false);
-  const [form, setForm] = useState(EMPTY_FORM);
-  const [userSearchTerm, setUserSearchTerm] = useState("");
+  const { user, currentWorkspace } = useAuth();
+
+  const employees = useAdminStore((s) => s.employees);
+  const loading = useAdminStore((s) => s.usersLoading);
+  const saving = useAdminStore((s) => s.usersSaving);
+  const editing = useAdminStore((s) => s.editingUser);
+  const dialogOpen = useAdminStore((s) => s.userDialogOpen);
+  const form = useAdminStore((s) => s.userForm);
+  const userSearchTerm = useAdminStore((s) => s.userSearchTerm);
+
+  const setEditingUser = useAdminStore((s) => s.setEditingUser);
+  const setUserDialogOpen = useAdminStore((s) => s.setUserDialogOpen);
+  const setUserForm = useAdminStore((s) => s.setUserForm);
+  const setUserSearchTerm = useAdminStore((s) => s.setUserSearchTerm);
+
+  const loadEmployees = useAdminStore((s) => s.loadEmployees);
+  const createEmployee = useAdminStore((s) => s.createEmployee);
+  const updateEmployee = useAdminStore((s) => s.updateEmployee);
+  const deleteEmployee = useAdminStore((s) => s.deleteEmployee);
+  const reset = useAdminStore((s) => s.reset);
 
   const canManage = user?.role_code === "admin";
 
-  const load = async (): Promise<void> => {
-    setLoading(true);
-    try {
-      setEmployees(await api.listEmployees());
-      onConnectionChange(true);
-    } catch (error) {
-      onConnectionChange(false);
-      onNotify({
-        tone: "error",
-        message: error instanceof Error ? error.message : "用户列表加载失败",
-      });
-    } finally {
-      setLoading(false);
-    }
-  };
-
+  const wsId = currentWorkspace?.workspace_id;
   useEffect(() => {
-    void load();
-  }, []);
+    reset();
+    void loadEmployees();
+  }, [loadEmployees, reset, wsId]);
 
   const openCreate = (): void => {
-    setEditing(null);
-    setForm(EMPTY_FORM);
-    setDialogOpen(true);
+    setEditingUser(null);
+    setUserForm({
+      username: "",
+      display_name: "",
+      email: "",
+      role_code: "developer",
+      password: "",
+      status: "active",
+    });
+    setUserDialogOpen(true);
   };
 
   const openEdit = (employee: Employee): void => {
-    setEditing(employee);
-    setForm({
+    setEditingUser(employee);
+    setUserForm({
       username: employee.username,
       display_name: employee.display_name,
       email: employee.email ?? "",
@@ -70,18 +71,16 @@ export function UserManagementPage({
       password: "",
       status: employee.status,
     });
-    setDialogOpen(true);
+    setUserDialogOpen(true);
   };
 
-  const submit = async (event: React.FormEvent): Promise<void> => {
+  const submit = async (event: FormEvent): Promise<void> => {
     event.preventDefault();
     if (!form.display_name.trim() || (!editing && !form.username.trim())) return;
-    // 新建用户时密码必填
     if (!editing && !form.password.trim()) {
       onNotify({ tone: "error", message: "请输入密码" });
       return;
     }
-    // 编辑自身或管理员时,前端二次拦截禁用 status / role_code 的修改
     if (editing) {
       const editingSelf = editing.user_id === user?.user_id;
       const targetIsAdmin = editing.role_code === "admin";
@@ -102,58 +101,40 @@ export function UserManagementPage({
         return;
       }
     }
-    // 密码长度校验 8~72 字符
     if (form.password && (form.password.length < 8 || form.password.length > 72)) {
       onNotify({ tone: "error", message: "密码长度必须在 8~72 字符之间" });
       return;
     }
-    setSaving(true);
-    try {
-      if (editing) {
-        const updated = await api.updateEmployee(editing.user_id, {
+    if (editing) {
+      await updateEmployee(
+        editing,
+        {
           display_name: form.display_name.trim(),
           email: form.email.trim() || null,
           role_code: form.role_code,
           status: form.status,
-        });
-        setEmployees((current) => current.map(
-          (item) => item.user_id === updated.user_id ? updated : item,
-        ));
-        onNotify({ tone: "success", message: "用户信息已更新" });
-      } else {
-        const created = await api.createEmployee({
+        },
+        onNotify,
+        onConnectionChange,
+      );
+    } else {
+      await createEmployee(
+        {
           username: form.username.trim(),
           display_name: form.display_name.trim(),
           email: form.email.trim() || null,
           role_code: form.role_code,
           password: form.password,
-        });
-        setEmployees((current) => [...current, created]);
-        onNotify({ tone: "success", message: "用户已添加" });
-      }
-      setDialogOpen(false);
-    } catch (error) {
-      onNotify({
-        tone: "error",
-        message: error instanceof ApiRequestError ? error.message : "保存用户失败",
-      });
-    } finally {
-      setSaving(false);
+        },
+        onNotify,
+        onConnectionChange,
+      );
     }
   };
 
   const remove = async (employee: Employee): Promise<void> => {
     if (!window.confirm(`确定从当前 Workspace 删除用户"${employee.display_name}"吗？`)) return;
-    try {
-      await api.deleteEmployee(employee.user_id);
-      setEmployees((current) => current.filter((item) => item.user_id !== employee.user_id));
-      onNotify({ tone: "success", message: "用户已删除" });
-    } catch (error) {
-      onNotify({
-        tone: "error",
-        message: error instanceof Error ? error.message : "删除用户失败",
-      });
-    }
+    await deleteEmployee(employee, onNotify, onConnectionChange);
   };
 
   return (
@@ -222,7 +203,7 @@ export function UserManagementPage({
                 <span className="modal__eyebrow">EMPLOYEE</span>
                 <h2>{editing ? "编辑用户" : "添加用户"}</h2>
               </div>
-              <button className="icon-button" type="button" onClick={() => setDialogOpen(false)}><Icon name="close" /></button>
+              <button className="icon-button" type="button" onClick={() => setUserDialogOpen(false)}><Icon name="close" /></button>
             </div>
             <form onSubmit={(event) => void submit(event)}>
               <label className="form-field">
@@ -230,7 +211,7 @@ export function UserManagementPage({
                 <input
                   autoFocus={!editing}
                   value={form.display_name}
-                  onChange={(event) => setForm({ ...form, display_name: event.target.value })}
+                  onChange={(event) => setUserForm({ ...form, display_name: event.target.value })}
                   placeholder="请输入姓名"
                 />
               </label>
@@ -239,7 +220,7 @@ export function UserManagementPage({
                 <input
                   disabled={Boolean(editing)}
                   value={form.username}
-                  onChange={(event) => setForm({ ...form, username: event.target.value })}
+                  onChange={(event) => setUserForm({ ...form, username: event.target.value })}
                   placeholder="请输入登录账号"
                   autoComplete="username"
                 />
@@ -251,7 +232,7 @@ export function UserManagementPage({
                     type="password"
                     autoComplete="new-password"
                     value={form.password}
-                    onChange={(event) => setForm({ ...form, password: event.target.value })}
+                    onChange={(event) => setUserForm({ ...form, password: event.target.value })}
                     placeholder="请输入密码（8~72 字符）"
                   />
                 </label>
@@ -262,13 +243,13 @@ export function UserManagementPage({
                   type="email"
                   autoComplete="email"
                   value={form.email}
-                  onChange={(event) => setForm({ ...form, email: event.target.value })}
+                  onChange={(event) => setUserForm({ ...form, email: event.target.value })}
                   placeholder="请输入邮箱（可选）"
                 />
               </label>
               <label className="form-field">
                 <span>角色</span>
-                <select value={form.role_code} disabled={Boolean(editing) && ((editing as Employee).user_id === user?.user_id || (editing as Employee).role_code === "admin")} onChange={(event) => setForm({ ...form, role_code: event.target.value as "admin" | "developer" })}>
+                <select value={form.role_code} disabled={Boolean(editing) && ((editing as Employee).user_id === user?.user_id || (editing as Employee).role_code === "admin")} onChange={(event) => setUserForm({ ...form, role_code: event.target.value as "admin" | "developer" })}>
                   <option value="developer">开发人员</option>
                   <option value="admin">管理员</option>
                 </select>
@@ -276,7 +257,7 @@ export function UserManagementPage({
               {editing && (
                 <label className="form-field">
                   <span>状态</span>
-                  <select value={form.status} disabled={Boolean(editing) && ((editing as Employee).user_id === user?.user_id || (editing as Employee).role_code === "admin")} onChange={(event) => setForm({ ...form, status: event.target.value as typeof form.status })}>
+                  <select value={form.status} disabled={Boolean(editing) && ((editing as Employee).user_id === user?.user_id || (editing as Employee).role_code === "admin")} onChange={(event) => setUserForm({ ...form, status: event.target.value as typeof form.status })}>
                     <option value="active">正常</option>
                     <option value="disabled">停用</option>
                     <option value="locked">锁定</option>
@@ -284,7 +265,7 @@ export function UserManagementPage({
                 </label>
               )}
               <div className="modal__footer">
-                <button className="secondary-button" type="button" onClick={() => setDialogOpen(false)}>取消</button>
+                <button className="secondary-button" type="button" onClick={() => setUserDialogOpen(false)}>取消</button>
                 <button className="primary-button" type="submit" disabled={saving}>{saving ? "保存中…" : "保存"}</button>
               </div>
             </form>
@@ -293,4 +274,4 @@ export function UserManagementPage({
       )}
     </section>
   );
-}
+}
\ No newline at end of file
diff --git a/frontend/app/features/admin/SystemAdminRoute.tsx b/frontend/app/features/admin/SystemAdminRoute.tsx
index 4fb9cd6..e70ea5b 100644
--- a/frontend/app/features/admin/SystemAdminRoute.tsx
+++ b/frontend/app/features/admin/SystemAdminRoute.tsx
@@ -1,17 +1,13 @@
-import { useAuth } from "../../context/AuthContext";
 import { useScriptWorkspaceStore } from "../platform/state/scriptWorkspaceStore";
 import { useUiStore } from "../platform/state/uiStore";
 import { SystemAdminPage } from "./SystemAdminPage";
 
 export default function SystemAdminRoute() {
-  const { currentWorkspace, user } = useAuth();
   const setApiOnline = useScriptWorkspaceStore((s) => s.setApiOnline);
   const pushToast = useUiStore((s) => s.pushToast);
 
   return (
     <SystemAdminPage
-      // 切换 workspace / 用户时强制重 mount,清空内部 state 并重新拉取
-      key={`${user?.user_id ?? "anon"}-${currentWorkspace?.workspace_id ?? "none"}`}
       onNotify={pushToast}
       onConnectionChange={setApiOnline}
     />
diff --git a/frontend/app/features/admin/state/adminStore.ts b/frontend/app/features/admin/state/adminStore.ts
new file mode 100644
index 0000000..8fbd3b3
--- /dev/null
+++ b/frontend/app/features/admin/state/adminStore.ts
@@ -0,0 +1,476 @@
+import { create } from "zustand";
+
+import {
+  ApiRequestError,
+  type Employee,
+  type Workspace,
+  type WorkspaceBoundApi,
+} from "../../../services/api";
+
+import { useScriptWorkspaceStore } from "../../platform/state/scriptWorkspaceStore";
+import { useUiStore } from "../../platform/state/uiStore";
+
+type Notice = {
+  tone: "success" | "error" | "info";
+  message: string;
+};
+
+// ---- Users domain ----
+
+export type UserForm = {
+  username: string;
+  display_name: string;
+  email: string;
+  role_code: "admin" | "developer";
+  password: string;
+  status: "active" | "disabled" | "locked";
+};
+
+export const EMPTY_USER_FORM: UserForm = {
+  username: "",
+  display_name: "",
+  email: "",
+  role_code: "developer",
+  password: "",
+  status: "active",
+};
+
+// ---- Projects domain ----
+
+export type ProjectForm = {
+  workspace_code: string;
+  workspace_name: string;
+  quota_bytes: number;
+  description: string;
+};
+
+export const EMPTY_PROJECT_FORM: ProjectForm = {
+  workspace_code: "",
+  workspace_name: "",
+  quota_bytes: 0,
+  description: "",
+};
+
+// ---- Module-level non-reactive holder ----
+
+let _api: WorkspaceBoundApi | null = null;
+
+export const bindAdminApi = (api: WorkspaceBoundApi | null) => {
+  _api = api;
+};
+
+function requireApi(): WorkspaceBoundApi {
+  if (!_api) throw new Error("admin API 未绑定");
+  return _api;
+}
+
+function pushToast(notice: Notice) {
+  useUiStore.getState().pushToast(notice);
+}
+
+function setApiOnline(online: boolean) {
+  useScriptWorkspaceStore.getState().setApiOnline(online);
+}
+
+// ---- Store ----
+
+type State = {
+  // users
+  employees: Employee[];
+  usersLoading: boolean;
+  usersSaving: boolean;
+  editingUser: Employee | null;
+  userDialogOpen: boolean;
+  userForm: UserForm;
+  userSearchTerm: string;
+
+  // projects
+  projects: Workspace[];
+  projectsLoading: boolean;
+  projectsSaving: boolean;
+  editingProject: Workspace | null;
+  projectDialogOpen: boolean;
+  projectForm: ProjectForm;
+  selectedProject: Workspace | null;
+  availableUsers: Employee[];
+  selectedUserIds: string[];
+  selectedRoleCode: "admin" | "developer";
+  projectSearchTerm: string;
+  importMemberDialogOpen: boolean;
+};
+
+type Actions = {
+  bindApi: (api: WorkspaceBoundApi | null) => void;
+  reset: () => void;
+
+  // users setters
+  setEmployees: (updater: (current: Employee[]) => Employee[]) => void;
+  setUsersLoading: (loading: boolean) => void;
+  setUsersSaving: (saving: boolean) => void;
+  setEditingUser: (e: Employee | null) => void;
+  setUserDialogOpen: (open: boolean) => void;
+  setUserForm: (form: UserForm) => void;
+  setUserSearchTerm: (k: string) => void;
+
+  // projects setters
+  setProjects: (updater: (current: Workspace[]) => Workspace[]) => void;
+  setProjectsLoading: (loading: boolean) => void;
+  setProjectsSaving: (saving: boolean) => void;
+  setEditingProject: (p: Workspace | null) => void;
+  setProjectDialogOpen: (open: boolean) => void;
+  setProjectForm: (form: ProjectForm) => void;
+  setSelectedProject: (p: Workspace | null) => void;
+  setAvailableUsers: (users: Employee[]) => void;
+  setSelectedUserIds: (ids: string[]) => void;
+  setSelectedRoleCode: (r: "admin" | "developer") => void;
+  setProjectSearchTerm: (k: string) => void;
+  setImportMemberDialogOpen: (open: boolean) => void;
+
+  // users actions
+  loadEmployees: () => Promise<void>;
+  createEmployee: (
+    input: {
+      username: string;
+      display_name: string;
+      email?: string | null;
+      role_code: "admin" | "developer";
+      password: string;
+      status?: "active" | "disabled" | "locked";
+    },
+    onNotify: (n: Notice) => void,
+    onConnectionChange: (online: boolean) => void,
+  ) => Promise<void>;
+  updateEmployee: (
+    employee: Employee,
+    input: {
+      display_name: string;
+      email?: string | null;
+      role_code: "admin" | "developer";
+      status: "active" | "disabled" | "locked";
+    },
+    onNotify: (n: Notice) => void,
+    onConnectionChange: (online: boolean) => void,
+  ) => Promise<void>;
+  deleteEmployee: (
+    employee: Employee,
+    onNotify: (n: Notice) => void,
+    onConnectionChange: (online: boolean) => void,
+  ) => Promise<void>;
+
+  // projects actions
+  loadProjects: (
+    onNotify: (n: Notice) => void,
+    onConnectionChange: (online: boolean) => void,
+  ) => Promise<void>;
+  createProject: (
+    input: {
+      workspace_code: string;
+      workspace_name: string;
+      quota_bytes: number;
+      description?: string;
+    },
+    onNotify: (n: Notice) => void,
+    onConnectionChange: (online: boolean) => void,
+  ) => Promise<void>;
+  updateProject: (
+    workspace: Workspace,
+    input: {
+      workspace_name: string;
+      quota_bytes: number;
+      description?: string;
+    },
+    onNotify: (n: Notice) => void,
+    onConnectionChange: (online: boolean) => void,
+  ) => Promise<void>;
+  deleteProject: (
+    workspace: Workspace,
+    onNotify: (n: Notice) => void,
+    onConnectionChange: (online: boolean) => void,
+  ) => Promise<void>;
+  openImportMembers: (
+    workspace: Workspace,
+    onNotify: (n: Notice) => void,
+  ) => Promise<void>;
+  importMembers: (
+    workspace: Workspace,
+    user_ids: string[],
+    role_code: "admin" | "developer",
+    onNotify: (n: Notice) => void,
+  ) => Promise<void>;
+};
+
+const initial: State = {
+  employees: [],
+  usersLoading: true,
+  usersSaving: false,
+  editingUser: null,
+  userDialogOpen: false,
+  userForm: EMPTY_USER_FORM,
+  userSearchTerm: "",
+
+  projects: [],
+  projectsLoading: true,
+  projectsSaving: false,
+  editingProject: null,
+  projectDialogOpen: false,
+  projectForm: EMPTY_PROJECT_FORM,
+  selectedProject: null,
+  availableUsers: [],
+  selectedUserIds: [],
+  selectedRoleCode: "developer",
+  projectSearchTerm: "",
+  importMemberDialogOpen: false,
+};
+
+async function handleError(
+  error: unknown,
+  fallback: string,
+  onNotify: (n: Notice) => void,
+): Promise<void> {
+  if (error instanceof ApiRequestError && error.status === 401) {
+    onNotify({ tone: "error", message: "登录已失效,请重新登录" });
+    return;
+  }
+  if (error instanceof ApiRequestError && error.status === 403) {
+    onNotify({ tone: "error", message: "没有权限执行该操作" });
+    return;
+  }
+  if (error instanceof ApiRequestError && error.status === 409) {
+    onNotify({
+      tone: "error",
+      message:
+        error.message
+        || "操作冲突,目标资源可能已存在或状态不一致",
+    });
+    return;
+  }
+  onNotify({
+    tone: "error",
+    message: error instanceof Error ? error.message : fallback,
+  });
+}
+
+export const useAdminStore = create<State & Actions>((set, get) => ({
+  ...initial,
+
+  bindApi: bindAdminApi,
+
+  reset: () => set({ ...initial, usersLoading: true, projectsLoading: true }),
+
+  // ---- users setters ----
+
+  setEmployees: (updater) =>
+    set((state) => ({ employees: updater(state.employees) })),
+  setUsersLoading: (loading) => set({ usersLoading: loading }),
+  setUsersSaving: (saving) => set({ usersSaving: saving }),
+  setEditingUser: (e) => set({ editingUser: e }),
+  setUserDialogOpen: (open) => set({ userDialogOpen: open }),
+  setUserForm: (form) => set({ userForm: form }),
+  setUserSearchTerm: (k) => set({ userSearchTerm: k }),
+
+  // ---- projects setters ----
+
+  setProjects: (updater) =>
+    set((state) => ({ projects: updater(state.projects) })),
+  setProjectsLoading: (loading) => set({ projectsLoading: loading }),
+  setProjectsSaving: (saving) => set({ projectsSaving: saving }),
+  setEditingProject: (p) => set({ editingProject: p }),
+  setProjectDialogOpen: (open) => set({ projectDialogOpen: open }),
+  setProjectForm: (form) => set({ projectForm: form }),
+  setSelectedProject: (p) => set({ selectedProject: p }),
+  setAvailableUsers: (users) => set({ availableUsers: users }),
+  setSelectedUserIds: (ids) => set({ selectedUserIds: ids }),
+  setSelectedRoleCode: (r) => set({ selectedRoleCode: r }),
+  setProjectSearchTerm: (k) => set({ projectSearchTerm: k }),
+  setImportMemberDialogOpen: (open) => set({ importMemberDialogOpen: open }),
+
+  // ---- users actions ----
+
+  loadEmployees: async () => {
+    const api = requireApi();
+    set({ usersLoading: true });
+    try {
+      const list = await api.listEmployees();
+      set({ employees: list });
+      setApiOnline(true);
+    } catch (error) {
+      setApiOnline(false);
+      pushToast({
+        tone: "error",
+        message: error instanceof Error ? error.message : "用户列表加载失败",
+      });
+    } finally {
+      set({ usersLoading: false });
+    }
+  },
+
+  createEmployee: async (form, onNotify, onConnectionChange) => {
+    const api = requireApi();
+    if (get().usersSaving) return;
+    set({ usersSaving: true });
+    try {
+      const created = await api.createEmployee(form);
+      set((state) => ({ employees: [created, ...state.employees] }));
+      set({ userDialogOpen: false, editingUser: null });
+      onConnectionChange(true);
+      onNotify({ tone: "success", message: "用户已创建" });
+    } catch (error) {
+      await handleError(error, "创建用户失败", onNotify);
+    } finally {
+      set({ usersSaving: false });
+    }
+  },
+
+  updateEmployee: async (employee, form, onNotify, onConnectionChange) => {
+    const api = requireApi();
+    if (get().usersSaving) return;
+    set({ usersSaving: true });
+    try {
+      const updated = await api.updateEmployee(employee.user_id, form);
+      set((state) => ({
+        employees: state.employees.map((e) =>
+          e.user_id === updated.user_id ? updated : e
+        ),
+      }));
+      set({ userDialogOpen: false, editingUser: null });
+      onConnectionChange(true);
+      onNotify({ tone: "success", message: "用户已更新" });
+    } catch (error) {
+      await handleError(error, "更新用户失败", onNotify);
+    } finally {
+      set({ usersSaving: false });
+    }
+  },
+
+  deleteEmployee: async (employee, onNotify, onConnectionChange) => {
+    const api = requireApi();
+    if (get().usersSaving) return;
+    set({ usersSaving: true });
+    try {
+      await api.deleteEmployee(employee.user_id);
+      set((state) => ({
+        employees: state.employees.filter((e) => e.user_id !== employee.user_id),
+      }));
+      onConnectionChange(true);
+      onNotify({ tone: "success", message: "用户已删除" });
+    } catch (error) {
+      await handleError(error, "删除用户失败", onNotify);
+    } finally {
+      set({ usersSaving: false });
+    }
+  },
+
+  // ---- projects actions ----
+
+  loadProjects: async (onNotify, onConnectionChange) => {
+    const api = requireApi();
+    set({ projectsLoading: true });
+    try {
+      const list = await api.listWorkspaces();
+      set({ projects: list });
+      onConnectionChange(true);
+    } catch (error) {
+      onConnectionChange(false);
+      await handleError(error, "项目列表加载失败", onNotify);
+    } finally {
+      set({ projectsLoading: false });
+    }
+  },
+
+  createProject: async (form, onNotify, onConnectionChange) => {
+    const api = requireApi();
+    if (get().projectsSaving) return;
+    set({ projectsSaving: true });
+    try {
+      const created = await api.createWorkspace(form);
+      set((state) => ({ projects: [created, ...state.projects] }));
+      set({ projectDialogOpen: false, editingProject: null });
+      onConnectionChange(true);
+      onNotify({ tone: "success", message: "项目已创建" });
+    } catch (error) {
+      await handleError(error, "创建项目失败", onNotify);
+    } finally {
+      set({ projectsSaving: false });
+    }
+  },
+
+  updateProject: async (workspace, form, onNotify, onConnectionChange) => {
+    const api = requireApi();
+    if (get().projectsSaving) return;
+    set({ projectsSaving: true });
+    try {
+      const updated = await api.updateWorkspace(workspace.workspace_id, form);
+      set((state) => ({
+        projects: state.projects.map((p) =>
+          p.workspace_id === updated.workspace_id ? updated : p
+        ),
+      }));
+      set({ projectDialogOpen: false, editingProject: null });
+      onConnectionChange(true);
+      onNotify({ tone: "success", message: "项目已更新" });
+    } catch (error) {
+      await handleError(error, "更新项目失败", onNotify);
+    } finally {
+      set({ projectsSaving: false });
+    }
+  },
+
+  deleteProject: async (workspace, onNotify, onConnectionChange) => {
+    const api = requireApi();
+    if (get().projectsSaving) return;
+    set({ projectsSaving: true });
+    try {
+      await api.deleteWorkspace(workspace.workspace_id);
+      set((state) => ({
+        projects: state.projects.filter(
+          (p) => p.workspace_id !== workspace.workspace_id,
+        ),
+      }));
+      onConnectionChange(true);
+      onNotify({ tone: "success", message: "项目已删除" });
+    } catch (error) {
+      await handleError(error, "删除项目失败", onNotify);
+    } finally {
+      set({ projectsSaving: false });
+    }
+  },
+
+  openImportMembers: async (workspace, onNotify) => {
+    const api = requireApi();
+    set({ selectedProject: workspace, importMemberDialogOpen: true });
+    try {
+      const all = await api.listEmployees();
+      const existing = await api.listWorkspaceMembers(workspace.workspace_id);
+      const taken = new Set(existing.map((m) => m.user_id));
+      set({
+        availableUsers: all.filter((u) => !taken.has(u.user_id)),
+        selectedUserIds: [],
+        selectedRoleCode: "developer",
+      });
+    } catch (error) {
+      await handleError(error, "加载成员候选失败", onNotify);
+      set({ importMemberDialogOpen: false });
+    }
+  },
+
+  importMembers: async (workspace, user_ids, role_code, onNotify) => {
+    const api = requireApi();
+    try {
+      await Promise.all(
+        user_ids.map((uid) =>
+          api.addWorkspaceMember(workspace.workspace_id, {
+            user_id: uid,
+            role_code,
+          }),
+        ),
+      );
+      set({ importMemberDialogOpen: false });
+      onNotify({
+        tone: "success",
+        message: `已添加 ${user_ids.length} 名成员`,
+      });
+    } catch (error) {
+      await handleError(error, "导入成员失败", onNotify);
+    }
+  },
+}));
\ No newline at end of file
diff --git a/frontend/app/features/schedules/SchedulePage.tsx b/frontend/app/features/schedules/SchedulePage.tsx
index 1b9629c..c2ab6ee 100644
--- a/frontend/app/features/schedules/SchedulePage.tsx
+++ b/frontend/app/features/schedules/SchedulePage.tsx
@@ -21,11 +21,12 @@ import {
   type ScheduleRunSummary,
 } from "../../services/api";
 
-import { useApi } from "../../context/AuthContext";
+import { useApi, useAuth } from "../../context/AuthContext";
 import Icon from "../../components/common/Icon";
 import { ScheduleList } from "./ScheduleList";
 import { ArtifactList } from "./ArtifactList";
 import { ScheduleCanvasHeader } from "./ScheduleCanvasHeader";
+import { useSchedulesStore } from "./state/schedulesStore";
 import "../../styles/schedule.css";
 
 type Notice = {
@@ -231,17 +232,26 @@ export default function SchedulePage({
   onNotify: (notice: Notice) => void;
   onConnectionChange: (online: boolean) => void;
 }) {
-  const [schedules, setSchedules] = useState<Schedule[]>([]);
-  const [artifacts, setArtifacts] = useState<ScheduleArtifact[]>([]);
-  const [schedule, setSchedule] = useState<Schedule | null>(null);
-  const scheduleRef = useRef<Schedule | null>(null);
+  const { currentWorkspace } = useAuth();
+  const workspaceId = currentWorkspace?.workspace_id;
+
+  // 核心数据 state 迁 store(其余 form/dialog/selected/runs 仍用 useState)
+  const schedules = useSchedulesStore((s) => s.schedules);
+  const artifacts = useSchedulesStore((s) => s.artifacts);
+  const schedule = useSchedulesStore((s) => s.schedule);
+  const loading = useSchedulesStore((s) => s.loading);
+  const busy = useSchedulesStore((s) => s.busy);
+  const setSchedules = useSchedulesStore((s) => s.setSchedules);
+  const setArtifacts = useSchedulesStore((s) => s.setArtifacts);
+  const setSchedule = useSchedulesStore((s) => s.setSchedule);
+  const setLoading = useSchedulesStore((s) => s.setLoading);
+  const setBusy = useSchedulesStore((s) => s.setBusy);
+
   const [selectedNodeId, setSelectedNodeId] = useState<string | null>(null);
   const [selectedEdgeId, setSelectedEdgeId] = useState<string | null>(null);
   const [linkSourceId, setLinkSourceId] = useState<string | null>(null);
   const [scheduleKeyword, setScheduleKeyword] = useState("");
   const [artifactKeyword, setArtifactKeyword] = useState("");
-  const [loading, setLoading] = useState(true);
-  const [busy, setBusy] = useState<string | null>(null);
   const [createDialogOpen, setCreateDialogOpen] = useState(false);
   const [newScheduleName, setNewScheduleName] = useState("");
   const [contextMenu, setContextMenu] = useState<ScheduleContextMenu | null>(null);
@@ -263,10 +273,6 @@ export default function SchedulePage({
     (item) => item.edge_id === selectedEdgeId,
   ) ?? null;
 
-  useEffect(() => {
-    scheduleRef.current = schedule;
-  }, [schedule]);
-
   useEffect(() => {
     if (schedule) setScheduleForm(scheduleToForm(schedule));
   }, [schedule?.schedule_id, schedule?.workflow_version]);
@@ -337,7 +343,7 @@ export default function SchedulePage({
         scheduleId,
         limit: 20,
       });
-      if (scheduleRef.current?.schedule_id === scheduleId) {
+      if (useSchedulesStore.getState().schedule?.schedule_id === scheduleId) {
         setRuns(items);
       }
       onConnectionChange(true);
@@ -360,7 +366,7 @@ export default function SchedulePage({
     setSchedules(scheduleItems);
     setArtifacts(artifactItems);
     const targetId = preferredScheduleId
-      ?? scheduleRef.current?.schedule_id
+      ?? useSchedulesStore.getState().schedule?.schedule_id
       ?? scheduleItems[0]?.schedule_id
       ?? null;
     if (!targetId) {
@@ -401,6 +407,17 @@ export default function SchedulePage({
     };
   }, []);
 
+  // 切 workspace 时清空 store 与 local state 并重新加载
+  useEffect(() => {
+    if (!workspaceId) return;
+    setSchedules([]);
+    setArtifacts([]);
+    setSchedule(null);
+    setRuns([]);
+    setRunsLoading(true);
+    void useSchedulesStore.getState().loadInitial();
+  }, [workspaceId, setSchedules, setArtifacts, setSchedule]);
+
   useEffect(() => {
     const scheduleId = schedule?.schedule_id;
     if (!scheduleId) {
@@ -443,7 +460,7 @@ export default function SchedulePage({
     fallback: string,
   ): Promise<void> => {
     if (error instanceof ApiRequestError && error.status === 412) {
-      const currentId = scheduleRef.current?.schedule_id;
+      const currentId = useSchedulesStore.getState().schedule?.schedule_id;
       if (currentId) {
         withSuppressedError(() => refreshLists(currentId));
       }
@@ -648,7 +665,7 @@ export default function SchedulePage({
       return;
     }
     setBusy("save-schedule");
-    let updated = scheduleRef.current ?? schedule;
+    let updated = useSchedulesStore.getState().schedule ?? schedule;
     try {
       for (const [nodeId, position] of Object.entries(
         positionDraftsRef.current,
@@ -682,7 +699,6 @@ export default function SchedulePage({
       onNotify({ tone: "success", message: "调度配置已保存" });
     } catch (error) {
       const localDraft = applyPositionDrafts(updated);
-      scheduleRef.current = localDraft;
       setSchedule(localDraft);
       await handleError(error, "调度配置保存失败");
     } finally {
@@ -830,7 +846,7 @@ export default function SchedulePage({
     if (Math.abs(deltaX) + Math.abs(deltaY) > 3) drag.moved = true;
     setSchedule((current) => {
       if (!current) return current;
-      const next = {
+      return {
         ...current,
         nodes: current.nodes.map((item) => (
           item.node_id === drag.nodeId
@@ -842,8 +858,6 @@ export default function SchedulePage({
             : item
         )),
       };
-      scheduleRef.current = next;
-      return next;
     });
   };
 
@@ -854,7 +868,7 @@ export default function SchedulePage({
     if (!drag || drag.pointerId !== event.pointerId) return;
     dragRef.current = null;
     if (!drag.moved) return;
-    const current = scheduleRef.current;
+    const current = useSchedulesStore.getState().schedule;
     const node = current?.nodes.find((item) => item.node_id === drag.nodeId);
     if (!current || !node) return;
     const position = {
@@ -868,14 +882,12 @@ export default function SchedulePage({
     setPositionDraftCount(Object.keys(positionDraftsRef.current).length);
     setSchedule((value) => {
       if (!value) return value;
-      const next = {
+      return {
         ...value,
         nodes: value.nodes.map((item) => (
           item.node_id === node.node_id ? { ...item, ...position } : item
         )),
       };
-      scheduleRef.current = next;
-      return next;
     });
   };
 
diff --git a/frontend/app/features/schedules/SchedulesPageRoute.tsx b/frontend/app/features/schedules/SchedulesPageRoute.tsx
index dcd6129..854819c 100644
--- a/frontend/app/features/schedules/SchedulesPageRoute.tsx
+++ b/frontend/app/features/schedules/SchedulesPageRoute.tsx
@@ -1,17 +1,13 @@
-import { useAuth } from "../../context/AuthContext";
 import { useScriptWorkspaceStore } from "../platform/state/scriptWorkspaceStore";
 import { useUiStore } from "../platform/state/uiStore";
 import SchedulePage from "./SchedulePage";
 
 export default function SchedulesPageRoute() {
-  const { currentWorkspace, user } = useAuth();
   const setApiOnline = useScriptWorkspaceStore((s) => s.setApiOnline);
   const pushToast = useUiStore((s) => s.pushToast);
 
   return (
     <SchedulePage
-      // 切换 workspace / 用户时强制重 mount,清空内部 state 并重新拉取
-      key={`${user?.user_id ?? "anon"}-${currentWorkspace?.workspace_id ?? "none"}`}
       onNotify={pushToast}
       onConnectionChange={setApiOnline}
     />
diff --git a/frontend/app/features/schedules/state/schedulesStore.ts b/frontend/app/features/schedules/state/schedulesStore.ts
new file mode 100644
index 0000000..ead9ef0
--- /dev/null
+++ b/frontend/app/features/schedules/state/schedulesStore.ts
@@ -0,0 +1,1160 @@
+import { create } from "zustand";
+
+import {
+  ApiRequestError,
+  type CronPreview,
+  type Schedule,
+  type ScheduleArtifact,
+  type ScheduleEdge,
+  type ScheduleNode,
+  type ScheduleRunDetail,
+  type ScheduleRunSummary,
+  type WorkspaceBoundApi,
+} from "../../../services/api";
+
+import { useScriptWorkspaceStore } from "../../platform/state/scriptWorkspaceStore";
+import { useUiStore } from "../../platform/state/uiStore";
+
+type Notice = {
+  tone: "success" | "error" | "info";
+  message: string;
+};
+
+// ---- Types ----
+
+export type ScheduleForm = {
+  scheduleName: string;
+  description: string;
+  triggerType: "manual" | "cron" | "api";
+  cronExpression: string;
+  timezone: string;
+  enabled: boolean;
+  maxConcurrency: string;
+  failurePolicy: "stop" | "continue";
+};
+
+export type NodeForm = {
+  nodeName: string;
+  timeoutSeconds: string;
+  retryCount: string;
+  retryIntervalSec: string;
+  argumentsJson: string;
+  envRefsJson: string;
+};
+
+export type NodePositionDraft = {
+  position_x: number;
+  position_y: number;
+};
+
+export type ScheduleContextMenu = {
+  x: number;
+  y: number;
+  kind: "schedule" | "node" | "edge";
+  schedule_id: string;
+  node_id?: string;
+  edge_id?: string;
+};
+
+export const EMPTY_SCHEDULE_FORM: ScheduleForm = {
+  scheduleName: "",
+  description: "",
+  triggerType: "manual",
+  cronExpression: "",
+  timezone: "Asia/Shanghai",
+  enabled: false,
+  maxConcurrency: "1",
+  failurePolicy: "stop",
+};
+
+export const EMPTY_NODE_FORM: NodeForm = {
+  nodeName: "",
+  timeoutSeconds: "600",
+  retryCount: "0",
+  retryIntervalSec: "5",
+  argumentsJson: "{}",
+  envRefsJson: "{}",
+};
+
+// ---- Module-level non-reactive holders ----
+
+let _api: WorkspaceBoundApi | null = null;
+const positionDrafts = new Map<string, NodePositionDraft>();
+
+export const bindSchedulesApi = (api: WorkspaceBoundApi | null) => {
+  _api = api;
+};
+
+function requireApi(): WorkspaceBoundApi {
+  if (!_api) throw new Error("schedules API 未绑定");
+  return _api;
+}
+
+function notify(notice: Notice) {
+  useUiStore.getState().pushToast(notice);
+}
+
+function setApiOnline(online: boolean) {
+  useScriptWorkspaceStore.getState().setApiOnline(online);
+}
+
+// ---- Helpers ----
+
+function scheduleToForm(schedule: Schedule): ScheduleForm {
+  return {
+    scheduleName: schedule.schedule_name,
+    description: schedule.description ?? "",
+    triggerType: schedule.trigger_type,
+    cronExpression: schedule.cron_expression ?? "",
+    timezone: schedule.timezone,
+    enabled: schedule.enabled,
+    maxConcurrency: String(schedule.max_concurrency),
+    failurePolicy: schedule.failure_policy,
+  };
+}
+
+function nodeToForm(node: ScheduleNode): NodeForm {
+  return {
+    nodeName: node.node_name,
+    timeoutSeconds: String(node.timeout_seconds),
+    retryCount: String(node.retry_count),
+    retryIntervalSec: String(node.retry_interval_sec),
+    argumentsJson: JSON.stringify(node.arguments_json ?? {}, null, 2),
+    envRefsJson: JSON.stringify(node.env_refs_json ?? {}, null, 2),
+  };
+}
+
+function parseObject(text: string, label: string): Record<string, unknown> {
+  const trimmed = text.trim();
+  if (!trimmed) return {};
+  try {
+    const parsed = JSON.parse(trimmed);
+    if (parsed === null || typeof parsed !== "object" || Array.isArray(parsed)) {
+      throw new Error(`${label} 必须是 JSON 对象`);
+    }
+    return parsed as Record<string, unknown>;
+  } catch (error) {
+    if (error instanceof SyntaxError) {
+      throw new Error(`${label} JSON 格式不正确`);
+    }
+    throw error;
+  }
+}
+
+function applyPositionDrafts(schedule: Schedule): Schedule {
+  if (positionDrafts.size === 0) return schedule;
+  return {
+    ...schedule,
+    nodes: schedule.nodes.map((node) => {
+      const draft = positionDrafts.get(node.node_id);
+      return draft ? { ...node, ...draft } : node;
+    }),
+  };
+}
+
+function clearPositionDrafts() {
+  positionDrafts.clear();
+}
+
+// ---- Store ----
+
+type LogState = {
+  loading: boolean;
+  content: string | null;
+  fileName: string | null;
+  error: string | null;
+};
+
+type State = {
+  schedules: Schedule[];
+  artifacts: ScheduleArtifact[];
+  schedule: Schedule | null;
+
+  loading: boolean;
+  busy: string | null;
+
+  selectedNodeId: string | null;
+  selectedEdgeId: string | null;
+  linkSourceId: string | null;
+
+  scheduleKeyword: string;
+  artifactKeyword: string;
+
+  createDialogOpen: boolean;
+  newScheduleName: string;
+
+  scheduleForm: ScheduleForm;
+  nodeForm: NodeForm;
+  cronResult: CronPreview | null;
+  contextMenu: ScheduleContextMenu | null;
+
+  runs: ScheduleRunSummary[];
+  runsLoading: boolean;
+
+  expandedRunId: string | null;
+  runDetails: Record<string, ScheduleRunDetail>;
+  detailLoadingId: string | null;
+  detailErrors: Record<string, string>;
+  openLogNodeRunIds: Set<string>;
+  logStates: Record<string, LogState>;
+  artifactBusyKey: string | null;
+  artifactErrors: Record<string, string>;
+  positionDraftCount: number;
+};
+
+type Actions = {
+  bindApi: (api: WorkspaceBoundApi | null) => void;
+  reset: () => void;
+
+  // pure setters (mostly used by canvas/drag/inspector)
+  setSchedule: (
+    value: Schedule | null | ((current: Schedule | null) => Schedule | null),
+  ) => void;
+  setSchedules: (
+    value: Schedule[] | ((current: Schedule[]) => Schedule[]),
+  ) => void;
+  setArtifacts: (
+    value: ScheduleArtifact[]
+    | ((current: ScheduleArtifact[]) => ScheduleArtifact[]),
+  ) => void;
+  setLoading: (loading: boolean) => void;
+  setBusy: (busy: string | null) => void;
+  setRuns: (updater: (current: ScheduleRunSummary[]) => ScheduleRunSummary[]) => void;
+  setRunDetails: (
+    updater: (current: Record<string, ScheduleRunDetail>) => Record<string, ScheduleRunDetail>,
+  ) => void;
+  setOpenLogNodeRunIds: (updater: (current: Set<string>) => Set<string>) => void;
+  setLogStates: (
+    updater: (current: Record<string, {
+      loading: boolean;
+      content: string | null;
+      fileName: string | null;
+      error: string | null;
+    }>) => Record<string, {
+      loading: boolean;
+      content: string | null;
+      fileName: string | null;
+      error: string | null;
+    }>,
+  ) => void;
+  setArtifactBusyKey: (key: string | null) => void;
+  setArtifactErrors: (
+    updater: (current: Record<string, string>) => Record<string, string>,
+  ) => void;
+  setDetailLoadingId: (id: string | null) => void;
+  setDetailErrors: (
+    updater: (current: Record<string, string>) => Record<string, string>,
+  ) => void;
+  setSelectedNodeId: (id: string | null) => void;
+  setSelectedEdgeId: (id: string | null) => void;
+  setLinkSourceId: (id: string | null) => void;
+  setScheduleKeyword: (k: string) => void;
+  setArtifactKeyword: (k: string) => void;
+  setCreateDialogOpen: (open: boolean) => void;
+  setNewScheduleName: (name: string) => void;
+  setScheduleForm: (form: ScheduleForm) => void;
+  setNodeForm: (form: NodeForm) => void;
+  setCronResult: (result: CronPreview | null) => void;
+  setContextMenu: (menu: ScheduleContextMenu | null) => void;
+  closeContextMenu: () => void;
+
+  // data loaders
+  loadInitial: () => Promise<void>;
+  refreshLists: (preferredScheduleId?: string | null) => Promise<void>;
+  refreshRuns: (scheduleId: string, showLoading?: boolean) => Promise<void>;
+  chooseSchedule: (scheduleId: string) => Promise<void>;
+
+  // mutations
+  openCreateDialog: () => void;
+  addSchedule: (name: string) => Promise<void>;
+  removeSchedule: (target?: Schedule) => Promise<void>;
+  renameSchedule: (target: Schedule) => Promise<void>;
+  removeArtifact: (artifact: ScheduleArtifact) => Promise<void>;
+  saveSchedule: () => Promise<void>;
+  runCronPreview: () => Promise<void>;
+  runNow: () => Promise<void>;
+  addArtifactAt: (
+    artifact: ScheduleArtifact,
+    positionX: number,
+    positionY: number,
+  ) => Promise<void>;
+  saveNode: (selectedNode: ScheduleNode | null) => Promise<void>;
+  removeNode: (target?: ScheduleNode) => Promise<void>;
+  removeEdge: (target?: ScheduleEdge) => Promise<void>;
+  checkDag: () => Promise<void>;
+  connectTo: (targetNodeId: string) => Promise<void>;
+
+  // runs / log helpers
+  toggleRun: (runId: string) => void;
+  toggleLog: (runId: string, nodeRunId: string) => Promise<void>;
+  downloadResult: (runId: string, nodeRunId: string) => Promise<void>;
+  downloadLog: (runId: string, nodeRunId: string) => Promise<void>;
+  setExpandedRunId: (id: string | null) => void;
+
+  // drag helpers
+  setPositionDraft: (nodeId: string, draft: NodePositionDraft) => void;
+  getPositionDrafts: () => Map<string, NodePositionDraft>;
+};
+
+const initial: State = {
+  schedules: [],
+  artifacts: [],
+  schedule: null,
+  loading: true,
+  busy: null,
+  selectedNodeId: null,
+  selectedEdgeId: null,
+  linkSourceId: null,
+  scheduleKeyword: "",
+  artifactKeyword: "",
+  createDialogOpen: false,
+  newScheduleName: "",
+  scheduleForm: EMPTY_SCHEDULE_FORM,
+  nodeForm: EMPTY_NODE_FORM,
+  cronResult: null,
+  contextMenu: null,
+  runs: [],
+  runsLoading: false,
+  expandedRunId: null,
+  runDetails: {},
+  detailLoadingId: null,
+  detailErrors: {},
+  openLogNodeRunIds: new Set(),
+  logStates: {},
+  artifactBusyKey: null,
+  artifactErrors: {},
+  positionDraftCount: 0,
+};
+
+export const useSchedulesStore = create<State & Actions>((set, get) => {
+  // Generic error handler with 412 (concurrent update) awareness
+  async function handleError(error: unknown, fallback: string): Promise<void> {
+    if (error instanceof ApiRequestError && error.status === 412) {
+      const currentId = get().schedule?.schedule_id;
+      if (currentId) {
+        get().refreshLists(currentId).catch(() => undefined);
+      }
+      notify({ tone: "error", message: "调度已被其他操作更新，已重新加载最新版本" });
+      return;
+    }
+    notify({
+      tone: "error",
+      message: error instanceof Error ? error.message : fallback,
+    });
+  }
+
+  // Generic mutation wrapper: busy + try/catch + 412 + positionDraft cleanup + schedules list update
+  async function withMutation(
+    label: string,
+    action: () => Promise<Schedule>,
+    successMessage: string,
+  ): Promise<Schedule | null> {
+    const api = requireApi();
+    if (get().busy) return null;
+    set({ busy: label });
+    try {
+      const serverUpdated = await action();
+      const validNodeIds = new Set(
+        serverUpdated.nodes.map((node) => node.node_id),
+      );
+      for (const nodeId of [...positionDrafts.keys()]) {
+        if (!validNodeIds.has(nodeId)) positionDrafts.delete(nodeId);
+      }
+      const updated = applyPositionDrafts(serverUpdated);
+      set((state) => ({
+        schedule: updated,
+        schedules: (() => {
+          const summary = { ...updated, nodes: [], edges: [] };
+          const index = state.schedules.findIndex(
+            (item) => item.schedule_id === updated.schedule_id,
+          );
+          if (index < 0) return [summary, ...state.schedules];
+          return state.schedules.map((item) =>
+            item.schedule_id === updated.schedule_id ? summary : item
+          );
+        })(),
+        positionDraftCount: positionDrafts.size,
+      }));
+      notify({ tone: "success", message: successMessage });
+      return updated;
+    } catch (error) {
+      await handleError(error, `${successMessage}失败`);
+      return null;
+    } finally {
+      set({ busy: null });
+    }
+  }
+
+  return {
+    ...initial,
+
+    bindApi: bindSchedulesApi,
+
+    reset: () => {
+      clearPositionDrafts();
+      set({ ...initial, loading: true });
+    },
+
+    // ---- pure setters ----
+
+    setSchedule: (value) =>
+      set((state) => ({
+        schedule:
+          typeof value === "function"
+            ? (value as (current: Schedule | null) => Schedule | null)(state.schedule)
+            : value,
+      })),
+    setSchedules: (value) =>
+      set((state) => ({
+        schedules:
+          typeof value === "function"
+            ? (value as (current: Schedule[]) => Schedule[])(state.schedules)
+            : value,
+      })),
+    setArtifacts: (value) =>
+      set((state) => ({
+        artifacts:
+          typeof value === "function"
+            ? (value as (current: ScheduleArtifact[]) => ScheduleArtifact[])(
+                state.artifacts,
+              )
+            : value,
+      })),
+    setLoading: (loading) => set({ loading }),
+    setBusy: (busy) => set({ busy }),
+    setRuns: (updater) =>
+      set((state) => ({ runs: updater(state.runs) })),
+    setRunDetails: (updater) =>
+      set((state) => ({ runDetails: updater(state.runDetails) })),
+    setOpenLogNodeRunIds: (updater) =>
+      set((state) => ({ openLogNodeRunIds: updater(state.openLogNodeRunIds) })),
+    setLogStates: (updater) =>
+      set((state) => ({ logStates: updater(state.logStates) })),
+    setArtifactBusyKey: (key) => set({ artifactBusyKey: key }),
+    setArtifactErrors: (updater) =>
+      set((state) => ({ artifactErrors: updater(state.artifactErrors) })),
+    setDetailLoadingId: (id) => set({ detailLoadingId: id }),
+    setDetailErrors: (updater) =>
+      set((state) => ({ detailErrors: updater(state.detailErrors) })),
+    setSelectedNodeId: (id) => set({ selectedNodeId: id }),
+    setSelectedEdgeId: (id) => set({ selectedEdgeId: id }),
+    setLinkSourceId: (id) => set({ linkSourceId: id }),
+    setScheduleKeyword: (k) => set({ scheduleKeyword: k }),
+    setArtifactKeyword: (k) => set({ artifactKeyword: k }),
+    setCreateDialogOpen: (open) => set({ createDialogOpen: open }),
+    setNewScheduleName: (name) => set({ newScheduleName: name }),
+    setScheduleForm: (form) => set({ scheduleForm: form }),
+    setNodeForm: (form) => set({ nodeForm: form }),
+    setCronResult: (result) => set({ cronResult: result }),
+    setContextMenu: (menu) => set({ contextMenu: menu }),
+    closeContextMenu: () => set({ contextMenu: null }),
+
+    // ---- data loaders ----
+
+    loadInitial: async () => {
+      const api = requireApi();
+      let cancelled = false;
+      set({ loading: true });
+      try {
+        const [scheduleItems, artifactItems] = await Promise.all([
+          api.listSchedules(),
+          api.listScheduleArtifacts(),
+        ]);
+        if (cancelled) return;
+        set({ schedules: scheduleItems, artifacts: artifactItems });
+        if (scheduleItems[0]) {
+          const detail = await api.getSchedule(scheduleItems[0].schedule_id);
+          if (!cancelled) {
+            set({ schedule: applyPositionDrafts(detail) });
+          }
+        }
+        setApiOnline(true);
+      } catch (error) {
+        if (cancelled) return;
+        setApiOnline(false);
+        notify({
+          tone: "error",
+          message: error instanceof Error ? error.message : "调度数据加载失败",
+        });
+      } finally {
+        if (!cancelled) set({ loading: false });
+      }
+    },
+
+    refreshLists: async (preferredScheduleId) => {
+      const api = requireApi();
+      const [scheduleItems, artifactItems] = await Promise.all([
+        api.listSchedules(),
+        api.listScheduleArtifacts(),
+      ]);
+      set({ schedules: scheduleItems, artifacts: artifactItems });
+      const targetId =
+        preferredScheduleId
+        ?? get().schedule?.schedule_id
+        ?? scheduleItems[0]?.schedule_id
+        ?? null;
+      if (!targetId) {
+        set({ schedule: null });
+        return;
+      }
+      const detail = await api.getSchedule(targetId);
+      set({ schedule: applyPositionDrafts(detail) });
+    },
+
+    refreshRuns: async (scheduleId, showLoading = false) => {
+      const api = requireApi();
+      if (showLoading) set({ runsLoading: true });
+      try {
+        const items = await api.listScheduleRuns({ scheduleId, limit: 20 });
+        if (get().schedule?.schedule_id === scheduleId) {
+          set({ runs: items });
+        }
+        setApiOnline(true);
+      } catch (error) {
+        if (showLoading) await handleError(error, "运行记录加载失败");
+      } finally {
+        if (showLoading) set({ runsLoading: false });
+      }
+    },
+
+    chooseSchedule: async (scheduleId) => {
+      const api = requireApi();
+      const current = get().schedule;
+      if (scheduleId === current?.schedule_id || get().busy) return;
+      set({ busy: "load-schedule" });
+      clearPositionDrafts();
+      set({
+        selectedNodeId: null,
+        selectedEdgeId: null,
+        linkSourceId: null,
+        cronResult: null,
+        positionDraftCount: 0,
+      });
+      try {
+        set({ schedule: await api.getSchedule(scheduleId) });
+        setApiOnline(true);
+      } catch (error) {
+        await handleError(error, "调度详情加载失败");
+      } finally {
+        set({ busy: null });
+      }
+    },
+
+    // ---- mutations ----
+
+    openCreateDialog: () => {
+      if (get().busy) return;
+      set((state) => ({
+        contextMenu: null,
+        newScheduleName: `新建调度 ${state.schedules.length + 1}`,
+        createDialogOpen: true,
+      }));
+    },
+
+    addSchedule: async (name) => {
+      const api = requireApi();
+      const scheduleName = name.trim();
+      if (get().busy || !scheduleName) return;
+      set({ busy: "create-schedule" });
+      try {
+        const created = await api.createSchedule({
+          schedule_name: scheduleName,
+          description: "在画布中拖入稳定版本并配置执行顺序",
+          trigger_type: "manual",
+          timezone: "Asia/Shanghai",
+          enabled: false,
+        });
+        set((state) => ({
+          schedules: [created, ...state.schedules],
+          schedule: created,
+          createDialogOpen: false,
+          newScheduleName: "",
+        }));
+        clearPositionDrafts();
+        set({ positionDraftCount: 0, selectedNodeId: null, selectedEdgeId: null });
+        notify({ tone: "success", message: "调度方案已创建" });
+      } catch (error) {
+        await handleError(error, "创建调度失败");
+      } finally {
+        set({ busy: null });
+      }
+    },
+
+    removeSchedule: async (target) => {
+      const api = requireApi();
+      const target_ = target ?? get().schedule;
+      if (!target_ || get().busy) return;
+      set({ contextMenu: null });
+      if (!window.confirm(`确定删除调度"${target_.schedule_name}"吗？`)) return;
+      set({ busy: "delete-schedule" });
+      try {
+        await api.deleteSchedule(target_.schedule_id, target_.workflow_version);
+        const remaining = get().schedules.filter(
+          (item) => item.schedule_id !== target_.schedule_id,
+        );
+        set({ schedules: remaining });
+        if (get().schedule?.schedule_id === target_.schedule_id) {
+          clearPositionDrafts();
+          set({
+            schedule: null,
+            selectedNodeId: null,
+            selectedEdgeId: null,
+            positionDraftCount: 0,
+          });
+          if (remaining[0]) {
+            const detail = await api.getSchedule(remaining[0].schedule_id);
+            set({ schedule: detail });
+          }
+        }
+        notify({ tone: "success", message: "调度方案已删除" });
+      } catch (error) {
+        await handleError(error, "删除调度失败");
+      } finally {
+        set({ busy: null });
+      }
+    },
+
+    renameSchedule: async (target) => {
+      const api = requireApi();
+      if (get().busy) return;
+      set({ contextMenu: null });
+      const scheduleName = window
+        .prompt("请输入新的调度方案名称", target.schedule_name)
+        ?.trim();
+      if (!scheduleName || scheduleName === target.schedule_name) return;
+      set({ busy: "rename-schedule" });
+      try {
+        const updated = await api.updateSchedule(target.schedule_id, {
+          workflow_version: target.workflow_version,
+          schedule_name: scheduleName,
+        });
+        set((state) => ({
+          schedules: state.schedules.map((item) =>
+            item.schedule_id === updated.schedule_id
+              ? { ...updated, nodes: [], edges: [] }
+              : item
+          ),
+          schedule:
+            state.schedule?.schedule_id === updated.schedule_id
+              ? updated
+              : state.schedule,
+        }));
+        notify({ tone: "success", message: "调度方案已改名" });
+      } catch (error) {
+        await handleError(error, "调度方案改名失败");
+      } finally {
+        set({ busy: null });
+      }
+    },
+
+    removeArtifact: async (artifact) => {
+      const api = requireApi();
+      if (get().busy) return;
+      set({ contextMenu: null });
+      if (
+        !window.confirm(
+          `确定将"${artifact.script_name} ${artifact.version_label}"移出调度列表吗？\n`
+          + "稳定版本本身和历史运行记录不会被删除。",
+        )
+      ) return;
+      set({ busy: "delete-artifact" });
+      try {
+        await api.hideScheduleArtifact(artifact.versions_id);
+        set((state) => ({
+          artifacts: state.artifacts.filter(
+            (item) => item.versions_id !== artifact.versions_id,
+          ),
+        }));
+        notify({
+          tone: "success",
+          message: "已移出调度列表，稳定版本和历史记录保持不变",
+        });
+      } catch (error) {
+        await handleError(error, "移出调度列表失败");
+      } finally {
+        set({ busy: null });
+      }
+    },
+
+    saveSchedule: async () => {
+      const api = requireApi();
+      const state = get();
+      const { schedule, scheduleForm } = state;
+      if (!schedule || state.busy) return;
+      const maxConcurrency = Number(scheduleForm.maxConcurrency);
+      if (!scheduleForm.scheduleName.trim()) {
+        notify({ tone: "error", message: "调度名称不能为空" });
+        return;
+      }
+      if (!Number.isInteger(maxConcurrency) || maxConcurrency < 1) {
+        notify({ tone: "error", message: "最大并发数必须是正整数" });
+        return;
+      }
+      set({ busy: "save-schedule" });
+      let updated: Schedule = schedule;
+      try {
+        for (const [nodeId, position] of positionDrafts.entries()) {
+          updated = await api.updateScheduleNode(updated.schedule_id, nodeId, {
+            workflow_version: updated.workflow_version,
+            position_x: position.position_x,
+            position_y: position.position_y,
+          });
+        }
+        updated = await api.updateSchedule(updated.schedule_id, {
+          workflow_version: updated.workflow_version,
+          schedule_name: scheduleForm.scheduleName.trim(),
+          description: scheduleForm.description.trim() || null,
+          trigger_type: scheduleForm.triggerType,
+          cron_expression:
+            scheduleForm.triggerType === "cron"
+              ? scheduleForm.cronExpression.trim()
+              : null,
+          timezone: scheduleForm.timezone.trim(),
+          enabled: scheduleForm.enabled,
+          max_concurrency: maxConcurrency,
+          failure_policy: scheduleForm.failurePolicy,
+        });
+        clearPositionDrafts();
+        set((s) => ({
+          schedule: updated,
+          schedules: s.schedules.map((item) =>
+            item.schedule_id === updated.schedule_id
+              ? { ...updated, nodes: [], edges: [] }
+              : item
+          ),
+          positionDraftCount: 0,
+        }));
+        notify({ tone: "success", message: "调度配置已保存" });
+      } catch (error) {
+        const localDraft = applyPositionDrafts(updated);
+        set({ schedule: localDraft });
+        await handleError(error, "调度配置保存失败");
+      } finally {
+        set({ busy: null });
+      }
+    },
+
+    runCronPreview: async () => {
+      const api = requireApi();
+      const { scheduleForm } = get();
+      if (scheduleForm.triggerType !== "cron") return;
+      if (get().busy) return;
+      set({ busy: "cron-preview" });
+      try {
+        const result = await api.previewCron({
+          cron_expression: scheduleForm.cronExpression.trim(),
+          timezone: scheduleForm.timezone.trim(),
+          count: 5,
+        });
+        set({ cronResult: result });
+        notify({ tone: "success", message: "Cron 表达式校验通过" });
+      } catch (error) {
+        set({ cronResult: null });
+        await handleError(error, "Cron 预览失败");
+      } finally {
+        set({ busy: null });
+      }
+    },
+
+    runNow: async () => {
+      const api = requireApi();
+      const state = get();
+      const { schedule, positionDraftCount } = state;
+      if (!schedule || state.busy) return;
+      if (positionDraftCount > 0) {
+        notify({
+          tone: "info",
+          message: "还有节点位置未保存，请先点击'保存配置'再运行",
+        });
+        return;
+      }
+      if (!schedule.dag_validation.valid || schedule.nodes.length === 0) {
+        notify({
+          tone: "error",
+          message: "当前调度必须包含有效的非空 DAG 才能运行",
+        });
+        return;
+      }
+      set({ busy: "run-now" });
+      try {
+        const created = await api.runScheduleNow(schedule.schedule_id);
+        set((s) => ({
+          runs: [
+            created,
+            ...s.runs.filter((item) => item.run_id !== created.run_id),
+          ].slice(0, 20),
+          schedule:
+            s.schedule
+              ? { ...s.schedule, last_run_at: created.queued_at }
+              : s.schedule,
+          schedules: s.schedules.map((item) =>
+            item.schedule_id === schedule.schedule_id
+              ? { ...item, last_run_at: created.queued_at }
+              : item
+          ),
+        }));
+        notify({
+          tone: "success",
+          message: `运行 ${created.run_id.slice(-8)} 已进入队列`,
+        });
+      } catch (error) {
+        await handleError(error, "立即运行失败");
+      } finally {
+        set({ busy: null });
+      }
+    },
+
+    addArtifactAt: async (artifact, positionX, positionY) => {
+      const state = get();
+      const { schedule } = state;
+      if (!schedule) {
+        notify({ tone: "info", message: "请先新建或选择一个调度方案" });
+        return;
+      }
+      const nodeKey = artifactNodeKey(artifact, schedule);
+      const updated = await withMutation(
+        "add-node",
+        () => requireApi().createScheduleNode(schedule.schedule_id, {
+          workflow_version: schedule.workflow_version,
+          node_key: nodeKey,
+          node_name: artifact.script_name,
+          versions_id: artifact.versions_id,
+          timeout_seconds: 600,
+          retry_count: 0,
+          retry_interval_sec: 5,
+          position_x: Math.max(20, Math.round(positionX)),
+          position_y: Math.max(20, Math.round(positionY)),
+          arguments_json: {},
+          env_refs_json: {},
+        }),
+        `${artifact.script_name} 已加入画布`,
+      );
+      if (updated) {
+        const created = updated.nodes.find((item) => item.node_key === nodeKey);
+        set({ selectedNodeId: created?.node_id ?? null });
+      }
+    },
+
+    saveNode: async (selectedNode) => {
+      const api = requireApi();
+      const state = get();
+      const { schedule, nodeForm } = state;
+      if (!schedule || !selectedNode) return;
+      try {
+        const timeoutSeconds = Number(nodeForm.timeoutSeconds);
+        const retryCount = Number(nodeForm.retryCount);
+        const retryIntervalSec = Number(nodeForm.retryIntervalSec);
+        if (!nodeForm.nodeName.trim()) throw new Error("节点名称不能为空");
+        if (!Number.isInteger(timeoutSeconds) || timeoutSeconds < 1) {
+          throw new Error("超时时间必须是正整数");
+        }
+        if (!Number.isInteger(retryCount) || retryCount < 0) {
+          throw new Error("重试次数必须是非负整数");
+        }
+        if (!Number.isInteger(retryIntervalSec) || retryIntervalSec < 0) {
+          throw new Error("重试间隔必须是非负整数");
+        }
+        const argumentsJson = parseObject(nodeForm.argumentsJson, "运行参数");
+        const rawEnv = parseObject(nodeForm.envRefsJson, "环境引用");
+        const envRefsJson = Object.fromEntries(
+          Object.entries(rawEnv).map(([key, value]) => {
+            if (typeof value !== "string") {
+              throw new Error("环境引用的值必须是字符串");
+            }
+            return [key, value];
+          }),
+        );
+        await withMutation(
+          "save-node",
+          () =>
+            api.updateScheduleNode(
+              schedule.schedule_id,
+              selectedNode.node_id,
+              {
+                workflow_version: schedule.workflow_version,
+                node_name: nodeForm.nodeName.trim(),
+                timeout_seconds: timeoutSeconds,
+                retry_count: retryCount,
+                retry_interval_sec: retryIntervalSec,
+                arguments_json: argumentsJson,
+                env_refs_json: envRefsJson,
+              },
+            ),
+          "节点配置已保存",
+        );
+      } catch (error) {
+        await handleError(error, "节点配置保存失败");
+      }
+    },
+
+    removeNode: async (target) => {
+      const api = requireApi();
+      const state = get();
+      const { schedule, selectedNodeId } = state;
+      const node = target
+        ?? schedule?.nodes.find((item) => item.node_id === selectedNodeId)
+        ?? null;
+      if (!schedule || !node || state.busy) return;
+      set({ contextMenu: null });
+      if (!window.confirm(`确定删除节点"${node.node_name}"吗？`)) return;
+      const updated = await withMutation(
+        "delete-node",
+        () =>
+          api.deleteScheduleNode(
+            schedule.schedule_id,
+            node.node_id,
+            schedule.workflow_version,
+          ),
+        "节点已删除",
+      );
+      if (updated && selectedNodeId === node.node_id) {
+        set({ selectedNodeId: null });
+      }
+    },
+
+    removeEdge: async (target) => {
+      const api = requireApi();
+      const state = get();
+      const { schedule, selectedEdgeId } = state;
+      const edge = target
+        ?? schedule?.edges.find((item) => item.edge_id === selectedEdgeId)
+        ?? null;
+      if (!schedule || !edge || state.busy) return;
+      set({ contextMenu: null });
+      const updated = await withMutation(
+        "delete-edge",
+        () =>
+          api.deleteScheduleEdge(
+            schedule.schedule_id,
+            edge.edge_id,
+            schedule.workflow_version,
+          ),
+        "连线已删除",
+      );
+      if (updated && selectedEdgeId === edge.edge_id) {
+        set({ selectedEdgeId: null });
+      }
+    },
+
+    checkDag: async () => {
+      const api = requireApi();
+      const { schedule } = get();
+      if (!schedule || get().busy) return;
+      set({ busy: "validate" });
+      try {
+        const result = await api.validateSchedule(schedule.schedule_id);
+        set((state) => ({
+          schedule: state.schedule
+            ? { ...state.schedule, dag_validation: result }
+            : state.schedule,
+        }));
+        notify({
+          tone: result.valid ? "success" : "error",
+          message: result.valid
+            ? "当前 DAG 通过校验"
+            : "当前 DAG 存在校验问题",
+        });
+      } catch (error) {
+        await handleError(error, "DAG 校验失败");
+      } finally {
+        set({ busy: null });
+      }
+    },
+
+    connectTo: async (targetNodeId) => {
+      const state = get();
+      const { schedule, linkSourceId } = state;
+      if (!schedule || !linkSourceId || state.busy) return;
+      if (linkSourceId === targetNodeId) {
+        set({ linkSourceId: null });
+        notify({ tone: "info", message: "已取消连线" });
+        return;
+      }
+      const sourceId = linkSourceId;
+      set({ linkSourceId: null });
+      await withMutation(
+        "create-edge",
+        () =>
+          requireApi().createScheduleEdge(schedule.schedule_id, {
+            workflow_version: schedule.workflow_version,
+            source_node_id: sourceId,
+            target_node_id: targetNodeId,
+          }),
+        "节点连线已创建",
+      );
+    },
+
+    // ---- runs / logs ----
+
+    toggleRun: (runId) => {
+      const expanded = get().expandedRunId;
+      if (expanded === runId) {
+        set({ expandedRunId: null });
+      } else {
+        set({ expandedRunId: runId });
+      }
+    },
+    setExpandedRunId: (id) => set({ expandedRunId: id }),
+
+    toggleLog: async (runId, nodeRunId) => {
+      const api = requireApi();
+      const state = get();
+      const open = state.openLogNodeRunIds;
+      if (open.has(nodeRunId)) {
+        const next = new Set(open);
+        next.delete(nodeRunId);
+        set({ openLogNodeRunIds: next });
+        return;
+      }
+      const next = new Set(open);
+      next.add(nodeRunId);
+      set({ openLogNodeRunIds: next });
+      if (state.logStates[nodeRunId]?.content) return;
+      set((s) => ({
+        logStates: {
+          ...s.logStates,
+          [nodeRunId]: {
+            loading: true,
+            content: null,
+            fileName: null,
+            error: null,
+          },
+        },
+      }));
+      try {
+        const artifacts = await api.getScheduleNodeRunArtifacts(runId, nodeRunId);
+        if (!artifacts.log) throw new Error("本次节点执行没有可用日志");
+        const response = await fetch(artifacts.log.url, {
+          credentials: "same-origin",
+          cache: "no-store",
+        });
+        if (!response.ok) {
+          throw new Error(`日志读取失败（HTTP ${response.status}）`);
+        }
+        const content = await response.text();
+        set((s) => ({
+          logStates: {
+            ...s.logStates,
+            [nodeRunId]: {
+              loading: false,
+              content,
+              fileName: artifacts.log?.file_name ?? null,
+              error: null,
+            },
+          },
+        }));
+      } catch (error) {
+        set((s) => ({
+          logStates: {
+            ...s.logStates,
+            [nodeRunId]: {
+              loading: false,
+              content: null,
+              fileName: null,
+              error: error instanceof Error ? error.message : "日志读取失败",
+            },
+          },
+        }));
+      }
+    },
+
+    downloadResult: async (runId, nodeRunId) => {
+      const api = requireApi();
+      const busyKey = `${nodeRunId}:result`;
+      set({
+        artifactBusyKey: busyKey,
+        artifactErrors: (() => {
+          const next = { ...get().artifactErrors };
+          delete next[nodeRunId];
+          return next;
+        })(),
+      });
+      try {
+        const artifacts = await api.getScheduleNodeRunArtifacts(runId, nodeRunId);
+        if (!artifacts.result) throw new Error("本次节点执行没有可下载结果");
+        const link = document.createElement("a");
+        link.href = artifacts.result.url;
+        link.download = artifacts.result.file_name;
+        document.body.appendChild(link);
+        link.click();
+        link.remove();
+      } catch (error) {
+        set((state) => ({
+          artifactErrors: {
+            ...state.artifactErrors,
+            [nodeRunId]: error instanceof Error ? error.message : "结果下载失败",
+          },
+        }));
+      } finally {
+        set({ artifactBusyKey: null });
+      }
+    },
+
+    downloadLog: async (runId, nodeRunId) => {
+      const api = requireApi();
+      const busyKey = `${nodeRunId}:log-download`;
+      set({
+        artifactBusyKey: busyKey,
+        artifactErrors: (() => {
+          const next = { ...get().artifactErrors };
+          delete next[nodeRunId];
+          return next;
+        })(),
+      });
+      try {
+        const artifacts = await api.getScheduleNodeRunArtifacts(runId, nodeRunId);
+        if (!artifacts.log) throw new Error("本次节点执行没有可下载日志");
+        const response = await fetch(artifacts.log.url, {
+          credentials: "same-origin",
+          cache: "no-store",
+        });
+        if (!response.ok) {
+          throw new Error(`日志下载失败（HTTP ${response.status}）`);
+        }
+        const objectUrl = URL.createObjectURL(await response.blob());
+        const link = document.createElement("a");
+        link.href = objectUrl;
+        link.download = artifacts.log.file_name;
+        document.body.appendChild(link);
+        link.click();
+        link.remove();
+        URL.revokeObjectURL(objectUrl);
+      } catch (error) {
+        set((state) => ({
+          artifactErrors: {
+            ...state.artifactErrors,
+            [nodeRunId]:
+              error instanceof Error ? error.message : "日志下载失败",
+          },
+        }));
+      } finally {
+        set({ artifactBusyKey: null });
+      }
+    },
+
+    // ---- drag helpers ----
+
+    setPositionDraft: (nodeId, draft) => {
+      positionDrafts.set(nodeId, draft);
+      set({ positionDraftCount: positionDrafts.size });
+    },
+    getPositionDrafts: () => positionDrafts,
+  };
+});
+
+// 顶层 pure helper (scheduleNodeKey needs schedule, so it's defined outside the store closure)
+function artifactNodeKey(artifact: ScheduleArtifact, schedule: Schedule): string {
+  const ascii = artifact.script_name
+    .toLowerCase()
+    .replace(/[^a-z0-9_]+/g, "_")
+    .replace(/^_+|_+$/g, "")
+    .slice(0, 24);
+  const base = ascii || `node_${artifact.versions_id.slice(-6).toLowerCase()}`;
+  const existing = new Set(schedule.nodes.map((item) => item.node_key));
+  if (!existing.has(base)) return base;
+  for (let i = 2; i < 1000; i++) {
+    const candidate = `${base}_${i}`;
+    if (!existing.has(candidate)) return candidate;
+  }
+  return `${base}_${Date.now().toString(36)}`;
+}
\ No newline at end of file
diff --git a/frontend/app/routes/platform.tsx b/frontend/app/routes/platform.tsx
index 6ba81f5..4cec09b 100644
--- a/frontend/app/routes/platform.tsx
+++ b/frontend/app/routes/platform.tsx
@@ -13,6 +13,8 @@ import {
   useScriptWorkspaceStore,
 } from "../features/platform/state/scriptWorkspaceStore";
 import { useUiStore } from "../features/platform/state/uiStore";
+import { bindAdminApi } from "../features/admin/state/adminStore";
+import { bindSchedulesApi } from "../features/schedules/state/schedulesStore";
 
 import "../styles/platform.css";
 
@@ -83,9 +85,13 @@ function AuthenticatedLayout() {
   // 后者会在 deps 变化时先 cleanup(null),再让 ScriptsPage 的 useEffect 跑,
   // 此时 _api 为 null,load() 抛 "script workspace API 未绑定"。
   bindScriptWorkspaceApi(api);
+  bindSchedulesApi(api);
+  bindAdminApi(api);
   useEffect(() => {
     return () => {
       bindScriptWorkspaceApi(null);
+      bindSchedulesApi(null);
+      bindAdminApi(null);
     };
   }, []);