-
+
+ {error && !detailOpen && }
+ {
+ setCreating(true);
+ setDetailOpen(true);
+ }}
+ >
+ 新建自动研究
+
+ }
+ pagination={
+ <>
+ 共 {total} 次运行
+ {total > 0 && (
+
+ )}
+
+ }
+ >
+
+
+
+ | 研究名称 |
+ 状态 |
+ 轮次 |
+ 创建时间 |
+
+
+
+ {items.map((item) => (
+
+ |
+
+ |
+ {flowStatus[item.status]} |
+ {item.round} |
+ {formatTime(item.created_at)} |
+
+ ))}
+
+
+ {!items.length && (
+ 暂无研究运行，请新建自动研究。
+ )}
+
+ setDetailOpen(false)}
+ >
+ {error && }
{creating ? (
-
+
);
}
diff --git a/frontend/src/research/QuantFlowPage.tsx b/frontend/src/research/QuantFlowPage.tsx
index 4dd72b0..fdf0e4f 100644
--- a/frontend/src/research/QuantFlowPage.tsx
+++ b/frontend/src/research/QuantFlowPage.tsx
@@ -1,3 +1,4 @@
+import { ResearchList } from "./ResearchList";
import { useEffect, useState } from "react";
import {
Banner,
@@ -8,7 +9,7 @@ import {
TextArea,
Toast,
} from "@douyinfe/semi-ui-19";
-import { api, post } from "../api";
+import { api, post, formatTime } from "../api";
import type { PageContext, UIAction } from "../ai/types";
import { FlowCanvas, type NodeType } from "./FlowCanvas";
import { FlowLaunchForm } from "./FlowLaunchForm";
@@ -50,6 +51,18 @@ export function QuantFlowPage({
onContext: (c: PageContext) => void;
onAction: (a: UIAction) => void;
}) {
+ const [route, setRoute] = useState(() => location.hash);
+ const [query, setQuery] = useState("");
+ const detail = /^#quantflow\/(new|workflows\/[^/]+|runs\/[^/]+)$/.test(route);
+ useEffect(() => {
+ const changed = () => setRoute(location.hash);
+ window.addEventListener("hashchange", changed);
+ return () => window.removeEventListener("hashchange", changed);
+ }, []);
+ function navigate(path: string) {
+ location.hash = `quantflow${path}`;
+ setRoute(`#quantflow${path}`);
+ }
const [assets, setAssets] = useState
([]),
[total, setTotal] = useState(0),
[page, setPage] = useState(1);
@@ -106,7 +119,7 @@ export function QuantFlowPage({
const c = new AbortController();
Promise.all([
api<{ items: WorkflowAsset[]; total: number }>(
- `/research/assets?kind=workflow&offset=${(page - 1) * 25}`,
+ `/research/assets?kind=workflow&offset=${(page - 1) * 25}&q=${encodeURIComponent(query)}`,
{ signal: c.signal },
),
api<{ items: NodeType[] }>("/research/flows/nodes", { signal: c.signal }),
@@ -127,7 +140,7 @@ export function QuantFlowPage({
if (!c.signal.aborted) setError(e.message);
});
return () => c.abort();
- }, [active, page, revision]);
+ }, [active, page, revision, query]);
useEffect(() => {
if (!active || mode !== "runs") return;
const c = new AbortController();
@@ -156,6 +169,41 @@ export function QuantFlowPage({
clearTimeout(timer);
};
}, [active, mode, runId, runPage, revision]);
+ useEffect(() => {
+ if (!active) return;
+ const runMatch = route.match(/^#quantflow\/runs\/([^/]+)$/);
+ const workflowMatch = route.match(/^#quantflow\/workflows\/([^/]+)$/);
+ if (runMatch) {
+ setMode("runs");
+ if (runId !== runMatch[1]) {
+ setRun(null);
+ setRunId(runMatch[1]);
+ }
+ } else if (route === "#quantflow/runs") {
+ setMode("runs");
+ } else {
+ setMode("edit");
+ if (route === "#quantflow/new" && asset) {
+ setAsset(null);
+ setVersions([]);
+ change(readDraft("new", empty));
+ }
+ if (workflowMatch && asset?.id !== workflowMatch[1]) {
+ const controller = new AbortController();
+ void api(
+ `/research/assets/${encodeURIComponent(workflowMatch[1])}`,
+ { signal: controller.signal },
+ )
+ .then((item) => {
+ if (!controller.signal.aborted) void open(item);
+ })
+ .catch((e) => {
+ if (!controller.signal.aborted) setError(e.message);
+ });
+ return () => controller.abort();
+ }
+ }
+ }, [active, route]);
function change(value: Workflow) {
setGraph(value);
setValid(false);
@@ -179,6 +227,7 @@ export function QuantFlowPage({
/* Keep the server version when the local draft is unavailable. */
}
}
+ navigate(`/workflows/${item.id}`);
setAsset(baseline);
change(version ? loaded.content : readDraft(loaded.id, loaded.content));
setSelected(loaded.content.nodes[0]?.id || null);
@@ -208,6 +257,8 @@ export function QuantFlowPage({
}),
},
);
+ history.replaceState(null, "", `#quantflow/workflows/${result.id}`);
+ setRoute(`#quantflow/workflows/${result.id}`);
setAsset(result);
setGraph(result.content);
setValid(true);
@@ -288,488 +339,592 @@ export function QuantFlowPage({
change({ ...graph, edges: [...graph.edges, edge] });
}
return (
-
-
-
-
QuantFlow
-
组合原生研究节点，复用回测、评估与有限预算。
-
-
-
-
-
-
-
-
-
-
- {mode === "runs" ? (
- run ? (
- <>
-
- {selected && (
-
-
所选节点产物
- {run.steps
- .filter((s) => s.node_id === selected)
- .map((s) => (
-
-
- 第 {s.round} 轮 · {flowStatus[s.status]}
-
-
- {JSON.stringify(s.output, null, 2)}
-
-
- ))}
-
- )}
-
setRevision((v) => v + 1)}
- onAction={onAction}
- />
-
- ) : (
- 选择一条运行查看节点状态和产物。
- )
- ) : mode === "launch" && asset ? (
- <>
-
- {
- setRun(r);
- setRunId(r.id);
- localStorage.setItem("quantflow-selected-run", r.id);
- setMode("runs");
- }}
- />
-
- ) : (
- <>
-
-
-
change({ ...graph, name })}
- />
-
- {asset && (
-
-
-
-
setRevision((v) => v + 1)}
+ onAction={onAction}
+ />
+
+ ) : (
+
+ 选择一条运行查看节点状态和产物。
+
+ )
+ ) : mode === "launch" && asset ? (
+ <>
+
+ {
+ setRun(r);
+ setRunId(r.id);
+ localStorage.setItem("quantflow-selected-run", r.id);
+ setMode("runs");
+ navigate(`/runs/${r.id}`);
+ }}
/>
+
+ ) : (
+ <>
-
连线
-
-
- →
-
-
-
-
-
- {graph.edges.map((e, i) => (
-
-
- {graph.nodes.find((n) => n.id === e.source)?.label}{" "}
- →{" "}
- {graph.nodes.find((n) => n.id === e.target)?.label}{" "}
- {e.branch && `· ${e.branch}`}
-
-
-
- ))}
-
-
-