feat(web): Legion前端

Cargo.toml

@@ -36,6 +36,28 @@ members = [
     "src/crates/contracts/core-types",
     "src/crates/contracts/events",
     "src/crates/contracts/runtime-ports",
+    # taiji-quant 量化引擎 crates
+    "src/crates/taiji/taiji-abnormal",
+    "src/crates/taiji/taiji-alert",
+    "src/crates/taiji/taiji-backtest",
+    "src/crates/taiji/taiji-bar",
+    "src/crates/taiji/taiji-blog-gen",
+    "src/crates/taiji/taiji-cli",
+    "src/crates/taiji/taiji-content",
+    "src/crates/taiji/taiji-engine",
+    "src/crates/taiji/taiji-engine-py",
+    "src/crates/taiji/taiji-example",
+    "src/crates/taiji/taiji-executor",
+    "src/crates/taiji/taiji-growth",
+    "src/crates/taiji/taiji-knowledge-graph",
+    "src/crates/taiji/taiji-llm",
+    "src/crates/taiji/taiji-orderflow",
+    "src/crates/taiji/taiji-pattern",
+    "src/crates/taiji/taiji-publisher",
+    "src/crates/taiji/taiji-realtime",
+    "src/crates/taiji/taiji-sentiment",
+    "src/crates/taiji/taiji-strategen",
+    "src/crates/taiji/taiji-strategy-template",
 ]
 
 exclude = [
@@ -49,6 +71,7 @@ resolver = "2"
 version = "0.2.14" # x-release-please-version
 authors = ["BitFun Team"]
 edition = "2021"
+license = "MIT"
 
 [workspace.lints.rust]
 unsafe_op_in_unsafe_fn = "warn"
@@ -118,6 +141,21 @@ chardetng = "0.1.17"
 encoding_rs = "0.8.35"
 url = "2"
 
+# taiji-quant 量化引擎依赖
+rayon = "1.10"
+csv = "1.3"
+parking_lot = "0.12"
+petgraph = { version = "0.6", features = ["serde-1"] }
+jieba-rs = "0.7"
+candle-core = "0.7"
+candle-nn = "0.7"
+ndarray = { version = "0.16", features = ["serde"] }
+pyo3 = { version = "0.23", features = ["extension-module"] }
+statrs = "0.17"
+lettre = { version = "0.11", default-features = false, features = ["builder", "smtp-transport", "tokio1-rustls-tls"] }
+tera = "1.20"
+crossbeam = "0.8"
+
 # HTTP client
 reqwest = { version = "0.13.4", default-features = false, features = ["native-tls", "rustls", "http2", "json", "stream", "multipart", "query", "form"] }
 

src/web-ui/src/app/layout/BeeColonyMonitor.tsx

@@ -0,0 +1,147 @@
+/**
+ * BeeColonyMonitor — fixed floating panel that renders the bee-colony-dag
+ * MiniApp DAG visualization. Always accessible via a nav button; stays
+ * visible alongside other content without taking a full scene tab.
+ *
+ * Pattern: FloatingMiniChat-style floating panel with MiniAppRunner inside.
+ */
+import React, { useState, useCallback, useEffect, useMemo } from 'react';
+import { GitBranch, X, Minimize2, Maximize2 } from 'lucide-react';
+import { miniAppAPI } from '@/infrastructure/api/service-api/MiniAppAPI';
+import type { MiniApp } from '@/infrastructure/api/service-api/MiniAppAPI';
+import { useTheme } from '@/infrastructure/theme/hooks/useTheme';
+import { useCurrentWorkspace } from '@/infrastructure/contexts/WorkspaceContext';
+import { createLogger } from '@/shared/utils/logger';
+import MiniAppRunner from '@/app/scenes/miniapps/components/MiniAppRunner';
+import { useSceneStore } from '@/app/stores/sceneStore';
+import './BeeColonyMonitor.scss';
+
+const log = createLogger('BeeColonyMonitor');
+
+const BEE_COLONY_APP_ID = 'bee-colony-dag';
+
+export const BeeColonyMonitor: React.FC = () => {
+  const { themeType } = useTheme();
+  const { workspacePath } = useCurrentWorkspace();
+  const activeTabId = useSceneStore((s) => s.activeTabId);
+
+  const [isOpen, setIsOpen] = useState(false);
+  const [app, setApp] = useState<MiniApp | null>(null);
+  const [loading, setLoading] = useState(false);
+  const [error, setError] = useState<string | null>(null);
+  const [maximized, setMaximized] = useState(false);
+
+  // Only show in agent scene (where the DAG is relevant)
+  const isAgentScene = useMemo(
+    () => typeof activeTabId === 'string' && activeTabId.startsWith('agentic:'),
+    [activeTabId],
+  );
+
+  const loadApp = useCallback(async () => {
+    setLoading(true);
+    setError(null);
+    try {
+      const loaded = await miniAppAPI.getMiniApp(
+        BEE_COLONY_APP_ID,
+        themeType ?? 'dark',
+        workspacePath || undefined,
+      );
+      if (!loaded?.compiled_html?.trim()) {
+        setError('MiniApp not compiled');
+        setApp(null);
+        return;
+      }
+      setApp(loaded);
+    } catch (err) {
+      log.error('Failed to load bee colony MiniApp', err);
+      setError(String(err));
+      setApp(null);
+    } finally {
+      setLoading(false);
+    }
+  }, [themeType, workspacePath]);
+
+  // Load app when panel opens
+  useEffect(() => {
+    if (isOpen && !app && !loading) {
+      void loadApp();
+    }
+  }, [isOpen, app, loading, loadApp]);
+
+  const handleToggle = useCallback(() => {
+    setIsOpen((prev) => !prev);
+  }, []);
+
+  const handleClose = useCallback(() => {
+    setIsOpen(false);
+  }, []);
+
+  // Don't render in non-agent scenes
+  if (!isAgentScene) return null;
+
+  return (
+    <div className={['bee-monitor', isOpen && 'bee-monitor--open'].filter(Boolean).join(' ')}>
+      {/* Backdrop */}
+      {isOpen && <div className="bee-monitor__backdrop" onClick={handleClose} />}
+
+      {/* Trigger button — always visible in agent scenes */}
+      <button
+        type="button"
+        className="bee-monitor__button"
+        onClick={handleToggle}
+        title="蜂群架构监控"
+        aria-label="蜂群架构监控"
+      >
+        <GitBranch size={18} />
+      </button>
+
+      {/* Floating panel */}
+      <div
+        className={[
+          'bee-monitor__panel',
+          isOpen && 'bee-monitor__panel--open',
+          maximized && 'bee-monitor__panel--maximized',
+        ].filter(Boolean).join(' ')}
+      >
+        {/* Header */}
+        <div className="bee-monitor__header">
+          <span className="bee-monitor__title">蜂群架构监控</span>
+          <div className="bee-monitor__header-actions">
+            <button
+              type="button"
+              className="bee-monitor__header-btn"
+              onClick={() => setMaximized((v) => !v)}
+              title={maximized ? '还原' : '最大化'}
+            >
+              {maximized ? <Minimize2 size={14} /> : <Maximize2 size={14} />}
+            </button>
+            <button
+              type="button"
+              className="bee-monitor__header-btn bee-monitor__header-btn--close"
+              onClick={handleClose}
+              title="关闭"
+            >
+              <X size={14} />
+            </button>
+          </div>
+        </div>
+
+        {/* Body */}
+        <div className="bee-monitor__body">
+          {loading && (
+            <div className="bee-monitor__loading">加载中...</div>
+          )}
+          {error && !app && (
+            <div className="bee-monitor__error">
+              <p>蜂群 MiniApp 未就绪</p>
+              <small>{error}. 请确保已编译部署。</small>
+            </div>
+          )}
+          {app && <MiniAppRunner key={app.id} app={app} />}
+        </div>
+      </div>
+    </div>
+  );
+};
+
+export default BeeColonyMonitor;

src/web-ui/src/app/scenes/agents/components/CreateLegionPage.tsx

@@ -0,0 +1,177 @@
+import React, { useCallback, useState } from 'react';
+import { ArrowLeft, GitBranch, Network } from 'lucide-react';
+import { useTranslation } from 'react-i18next';
+import { Button, IconButton } from '@/component-library';
+import { useNotification } from '@/shared/notification-system';
+import PATTERNS, {
+  type LegionPatternNode,
+  type LegionPatternEdge,
+} from '../data/orchestration-patterns';
+import { LegionPresetAPI } from '@/infrastructure/api/service-api/LegionPresetAPI';
+import '../AgentsView.scss';
+
+interface CreateLegionPageProps {
+  onBack: () => void;
+}
+
+const CreateLegionPage: React.FC<CreateLegionPageProps> = ({ onBack }) => {
+  const { t } = useTranslation('scenes/agents');
+  const { success: notifySuccess, error: notifyError } = useNotification();
+  const [selectedPatternId, setSelectedPatternId] = useState<string>(PATTERNS[0]?.id ?? '');
+  const [saving, setSaving] = useState(false);
+
+  const selectedPattern = PATTERNS.find((p) => p.id === selectedPatternId) ?? null;
+
+  const handleSelectPattern = useCallback((id: string) => {
+    setSelectedPatternId(id);
+  }, []);
+
+  const handleSave = useCallback(async () => {
+    if (!selectedPattern || saving) return;
+    setSaving(true);
+    try {
+      await LegionPresetAPI.createPreset({
+        id: selectedPattern.id,
+        name: selectedPattern.name,
+        description: selectedPattern.description,
+        nodes: selectedPattern.nodes.map((n) => ({
+          id: n.id,
+          agent: n.agent,
+          role: n.role,
+          prompt: n.prompt,
+          gate: n.gate,
+        })),
+        edges: selectedPattern.edges.map((e) => ({
+          from: e.from,
+          to: e.to,
+          condition: e.condition,
+        })),
+      });
+      notifySuccess(`Legion preset "${selectedPattern.name}" saved`);
+      onBack();
+    } catch (err) {
+      notifyError(`Failed to save legion preset: ${err}`);
+    } finally {
+      setSaving(false);
+    }
+  }, [selectedPattern, saving, onBack, notifySuccess, notifyError]);
+
+  const renderNodeList = (nodes: LegionPatternNode[]) => (
+    <div className="legion-node-list">
+      {nodes.map((node, i) => (
+        <div key={node.id} className="legion-node-item">
+          <span className="legion-node-index">{i + 1}</span>
+          <div className="legion-node-info">
+            <span className="legion-node-role">{node.role}</span>
+            <span className="legion-node-agent">{node.agent}</span>
+          </div>
+          {node.gate ? <span className="legion-node-gate">{t('legionPattern.gate')}</span> : null}
+        </div>
+      ))}
+    </div>
+  );
+
+  const renderEdgeList = (edges: LegionPatternEdge[], nodes: LegionPatternNode[]) => (
+    <div className="legion-edge-list">
+      {edges.map((edge) => {
+        const fromNode = nodes.find((n) => n.id === edge.from);
+        const toNode = nodes.find((n) => n.id === edge.to);
+        return (
+          <div key={`${edge.from}->${edge.to}`} className="legion-edge-item">
+            <span className="legion-edge-from">{fromNode?.role ?? edge.from}</span>
+            <GitBranch size={12} className="legion-edge-arrow" />
+            <span className="legion-edge-to">{toNode?.role ?? edge.to}</span>
+            {edge.condition ? (
+              <span className="legion-edge-condition">[{edge.condition}]</span>
+            ) : null}
+          </div>
+        );
+      })}
+    </div>
+  );
+
+  return (
+    <div className="create-agent-page" data-testid="create-legion-page">
+      <div className="create-agent-page__header">
+        <IconButton
+          onClick={onBack}
+          aria-label={t('legionPattern.back')}
+          data-testid="create-legion-back"
+        >
+          <ArrowLeft size={18} />
+        </IconButton>
+        <h1 className="create-agent-page__title">
+          {selectedPattern ? selectedPattern.name : t('legionPattern.choosePattern')}
+        </h1>
+      </div>
+
+      {/* Pattern selector */}
+      <section className="create-agent-page__section">
+        <h2 className="create-agent-page__section-title">{t('legionPattern.orchestrationPatterns')}</h2>
+        <div className="legion-pattern-grid">
+          {PATTERNS.map((pattern) => (
+            <div
+              key={pattern.id}
+              className={`legion-pattern-chip ${pattern.id === selectedPatternId ? 'legion-pattern-chip--active' : ''}`}
+              onClick={() => handleSelectPattern(pattern.id)}
+              role="button"
+              tabIndex={0}
+              aria-pressed={pattern.id === selectedPatternId}
+              onKeyDown={(e) => e.key === 'Enter' && handleSelectPattern(pattern.id)}
+              data-testid="legion-pattern-option"
+              data-pattern-id={pattern.id}
+            >
+              <Network size={14} />
+              <span>{pattern.name}</span>
+            </div>
+          ))}
+        </div>
+      </section>
+
+      {selectedPattern ? (
+        <>
+          {/* Summary */}
+          <section className="create-agent-page__section">
+            <h2 className="create-agent-page__section-title">{t('legionPattern.overview')}</h2>
+            <p className="legion-summary-desc">{selectedPattern.description}</p>
+            <div className="legion-summary-meta">
+              <span>{t('legionPattern.complexity', { level: selectedPattern.complexityLevel })}</span>
+              <span>{t('legionPattern.nodesCount', { count: selectedPattern.nodes.length })}</span>
+              <span>{t('legionPattern.edgesCount', { count: selectedPattern.edges.length })}</span>
+            </div>
+          </section>
+
+          {/* Nodes */}
+          <section className="create-agent-page__section">
+            <h2 className="create-agent-page__section-title">
+              {t('legionPattern.nodes', { count: selectedPattern.nodes.length })}
+            </h2>
+            {renderNodeList(selectedPattern.nodes)}
+          </section>
+
+          {/* Edges */}
+          <section className="create-agent-page__section">
+            <h2 className="create-agent-page__section-title">
+              {t('legionPattern.edges', { count: selectedPattern.edges.length })}
+            </h2>
+            {selectedPattern.edges.length > 0
+              ? renderEdgeList(selectedPattern.edges, selectedPattern.nodes)
+              : <p className="legion-empty-hint">{t('legionPattern.noEdges')}</p>}
+          </section>
+
+          {/* Actions */}
+          <div className="create-agent-page__actions">
+            <Button variant="secondary" onClick={onBack}>
+              {t('legionPattern.back')}
+            </Button>
+            <Button variant="primary" onClick={handleSave} disabled={saving} data-testid="create-legion-save">
+              {saving ? t('loading') : t('legionPattern.usePattern')}
+            </Button>
+          </div>
+        </>
+      ) : null}
+    </div>
+  );
+};
+
+export default CreateLegionPage;