mky-vent-base/src/views/ventAI/dataPicker/useDataPicker.ts

import { ref, h, createApp, Teleport, type Directive, type App } from 'vue';
import Antd from 'ant-design-vue';
import { fetchTunnelInterpretation, fetchDeviceInterpretation } from './api';
// [审计-第四轮 M2] 重放自我方 fix/base-agent-token（M1/M2/M3）：formatClickError 需要识别 StreamError 的 status
import { StreamError } from '/@/views/ventAI/manageAssistent/api/client';
import type { TodoItem, ToolCallRecord, SSERawEvent } from './types';
import DataPickerModal from './components/DataPickerModal.vue';
import aiCloseIcon from '@/assets/images/ventAI/dataPicker/AI-close.svg';
import aiOpenIcon from '@/assets/images/ventAI/dataPicker/AI-open.svg';
import { getActions } from '/@/qiankun/state';

// ─── 全局开关：控制悬停模式浮动按钮是否启用 ─────────────────────────────────
const STORAGE_KEY = 'dataPickerHoverEnabled';
const actions = getActions();

export const dataPickerHoverEnabled = ref(localStorage.getItem(STORAGE_KEY) !== 'false');

/** 记录所有活跃的悬停实例，以便全局开关关闭时立即隐藏按钮 */
const allHoverInstances = new Set<HoverInstance>();

export function setDataPickerHoverEnabled(val: boolean) {
  dataPickerHoverEnabled.value = val;
  localStorage.setItem(STORAGE_KEY, String(val));
  if (!val) {
    // 关闭时立即隐藏所有浮动按钮并清除定时器
    allHoverInstances.forEach((inst) => {
      inst.cancelLeave();
      inst.clearHideTimer();
      const btn = (inst as any)._btn as HTMLElement;
      if (btn) {
        btn.style.display = 'none';
        btn.style.transform = 'scale(0.9)';
        btn.style.opacity = '0';
      }
      // 重新挂载 mousemove 监听，以便开启后能正常触发
      inst.attachMove();
    });
  }
  actions.setGlobalState({ dataPickerHoverEnabled: val });
}

// ─── 按钮 DOM 构建（悬停模式专用）──────────────────────────────────────────
const BUTTON_CLASS = 'di-floating-btn';

function createButtonEl(): HTMLElement {
  const btn = document.createElement('div');
  btn.className = BUTTON_CLASS;
  btn.title = '数据解读';
  const img = document.createElement('img');
  img.src = aiCloseIcon;
  img.width = 24;
  img.height = 24;
  img.alt = '数据解读';
  btn.appendChild(img);
  Object.assign(btn.style, {
    position: 'fixed',
    zIndex: '99999',
    padding: '4px 6px 8px 6px',
    background: '#0E4F8D',
    borderRadius: '8px',
    cursor: 'pointer',
    display: 'none',
    pointerEvents: 'auto',
    transition: 'transform 0.15s ease-out, opacity 0.15s ease-out, border 0.15s ease-out',
    transform: 'scale(0.9)',
    opacity: '0',
    border: '2px solid transparent',
    boxSizing: 'border-box',
  });
  btn.addEventListener('mouseenter', () => {
    const owner = (btn as any).__di_owner;
    if (owner) {
      owner.cancelLeave();
      owner.clearHideTimer();
    }
    img.src = aiOpenIcon;
    btn.style.border = '2px solid #1e90ff';
  });
  btn.addEventListener('mouseleave', () => {
    const owner = (btn as any).__di_owner;
    if (owner) owner.startHideTimer();
    img.src = aiCloseIcon;
    btn.style.border = '2px solid transparent';
  });
  btn.addEventListener('mousedown', () => {
    img.src = aiOpenIcon;
    btn.style.border = '2px solid #1e90ff';
  });
  btn.addEventListener('mouseup', () => {
    img.src = aiOpenIcon;
    btn.style.border = '2px solid #1e90ff';
  });
  return btn;
}

// ─── 悬停触发器实例 ────────────────────────────────────────────────────────
const PAUSE_DELAY = 400;
const HIDE_DELAY = 3000;

function createHoverInstance(btn: HTMLElement) {
  let pauseTimer: ReturnType<typeof setTimeout> | null = null;
  let hideTimer: ReturnType<typeof setTimeout> | null = null;
  let leaveTimer: ReturnType<typeof setTimeout> | null = null;
  let visible = false;
  let raw: any = null;
  let hostEl: HTMLElement | null = null;

  function setPosition(x: number, y: number) {
    btn.style.left = x + 'px';
    btn.style.top = y + 'px';
  }

  function detachMove() {
    if (hostEl && inst.onMove) hostEl.removeEventListener('mousemove', inst.onMove);
  }

  function attachMove() {
    if (hostEl && inst.onMove) hostEl.addEventListener('mousemove', inst.onMove);
  }

  function show() {
    clearPauseTimer();
    detachMove();
    visible = true;
    btn.style.display = 'block';
    requestAnimationFrame(() => {
      btn.style.transform = 'scale(1)';
      btn.style.opacity = '1';
    });
    startHideTimer();
  }

  function hide() {
    visible = false;
    attachMove();
    btn.style.display = 'none';
    btn.style.transform = 'scale(0.9)';
    btn.style.opacity = '0';
  }

  function clearPauseTimer() {
    if (pauseTimer !== null) {
      clearTimeout(pauseTimer);
      pauseTimer = null;
    }
  }

  function clearHideTimer() {
    if (hideTimer !== null) {
      clearTimeout(hideTimer);
      hideTimer = null;
    }
  }

  function startHideTimer() {
    clearHideTimer();
    hideTimer = setTimeout(hide, HIDE_DELAY);
  }

  const inst = {
    get visible() {
      return visible;
    },
    get raw() {
      return raw;
    },
    setHost(el: HTMLElement) {
      hostEl = el;
    },
    onEnter(e: MouseEvent) {
      if (!dataPickerHoverEnabled.value) return;
      clearHideTimer();
      if (!visible) {
        setPosition(e.clientX - 36, e.clientY - 34);
        clearPauseTimer();
        pauseTimer = setTimeout(show, PAUSE_DELAY);
      } else {
        startHideTimer();
      }
    },
    onMove(e: MouseEvent) {
      if (!dataPickerHoverEnabled.value) return;
      setPosition(e.clientX - 36, e.clientY - 34);
      clearPauseTimer();
      pauseTimer = setTimeout(show, PAUSE_DELAY);
    },
    onLeave() {
      clearPauseTimer();
      clearHideTimer();
      leaveTimer = setTimeout(hide, 150);
    },
    cancelLeave() {
      if (leaveTimer !== null) {
        clearTimeout(leaveTimer);
        leaveTimer = null;
      }
    },
    setRaw(val: any) {
      raw = val;
    },
    clearHideTimer,
    startHideTimer,
    attachMove,
    destroy() {
      clearPauseTimer();
      clearHideTimer();
      if (leaveTimer !== null) {
        clearTimeout(leaveTimer);
        leaveTimer = null;
      }
      btn.remove();
    },
  };

  return inst;
}

type HoverInstance = ReturnType<typeof createHoverInstance>;

// ─── 钩子主函数 ─────────────────────────────────────────────────────────────
export interface DataPickerOptions {
  /** hover: 悬停出现浮动按钮；click: 点击元素直接触发 */
  mode?: 'hover' | 'click';
}

export function useDataPicker(
  mapParams: (
    item: any
  ) => { tun_id: string; tun_name: string; mode?: string } | { device_id: string; device_name: string; device_type: string; mode?: string },
  options: DataPickerOptions = {}
) {
  console.log('useDataPicker', mapParams);
  const { mode = 'hover' } = options;

  const loading = ref(false);
  const streamingText = ref('');
  const error = ref<string | null>(null);
  const thinking = ref(false);
  const todos = ref<TodoItem[]>([]);
  const executingTools = ref<string[]>([]);
  const toolCalls = ref<ToolCallRecord[]>([]);
  const latestMessage = ref('');
  const modalVisible = ref(false);
  const itemName = ref('');

  // 弹框容器 + 独立 Vue 应用
  const modalContainer = document.createElement('div');
  Object.assign(modalContainer.style, {
    position: 'fixed',
    top: '0',
    left: '0',
    width: '100%',
    height: '100%',
    pointerEvents: 'none',
    zIndex: '1000',
  });
  document.body.appendChild(modalContainer);

  let modalApp: App | null = null;

  function mountModal() {
    modalApp = createApp({
      setup: () => ({
        visible: modalVisible,
        loading,
        streamingText,
        error,
        thinking,
        todos,
        executingTools,
        toolCalls,
        latestMessage,
        itemName,
        onClose: () => {
          modalVisible.value = false;
          streamingText.value = '';
          error.value = null;
          thinking.value = false;
          todos.value = [];
          executingTools.value = [];
          toolCalls.value = [];
          latestMessage.value = '';
        },
      }),
      render() {
        return h(Teleport, { to: 'body' }, [
          h(DataPickerModal, {
            visible: this.visible,
            loading: this.loading,
            streamingText: this.streamingText,
            error: this.error,
            thinking: this.thinking,
            todos: this.todos,
            executingTools: this.executingTools,
            toolCalls: this.toolCalls,
            latestMessage: this.latestMessage,
            itemName: this.itemName,
            onClose: this.onClose,
          }),
        ]);
      },
    });
    modalApp.use(Antd);
    modalApp.mount(modalContainer);
  }

  mountModal();

  // SSE 事件处理
  function handleEvent(event: SSERawEvent) {
    switch (event.type) {
      case 'thinking':
        thinking.value = true;
        break;
      case 'executing':
        thinking.value = false;
        executingTools.value = event.tools || [];
        if (event.message) latestMessage.value = event.message;
        break;
      case 'tool_call':
        executingTools.value = [];
        toolCalls.value = [...toolCalls.value, { tool: event.tool || '', source: event.source || 'main', status: 'call' as const }];
        if (event.message) latestMessage.value = event.message;
        break;
      case 'tool_result':
        if (toolCalls.value.length > 0) {
          const last = toolCalls.value[toolCalls.value.length - 1];
          if (last.tool === event.tool && last.status === 'call') last.status = 'result';
        }
        if (event.message) latestMessage.value = event.message;
        break;
      case 'updated_todo_list':
        thinking.value = false;
        todos.value = event.todos || [];
        break;
      case 'token':
        thinking.value = false;
        if (event.content) streamingText.value += event.content;
        break;
    }
  }

  /**
   * 点击解读失败时，把「结构化错误」转成用户能看懂的中文文案。
   *
   * [审计-第四轮 M2] 重放自我方 fix/base-agent-token（M1/M2/M3）：
   * 背景：TfAgents 对失败请求返回结构化错误体，形如
   *   HTTP 429 → { "detail": { "code": "...", "message": "今日额度已用完…", "retry_after": 900 } }
   *   HTTP 413 → { "detail": { "code": "...", "message": "…" } }
   *   HTTP 404 → { "detail": { "code": "...", "message": "…" } }
   * 原行为：只有一行 `error.value = e?.message || '请求失败'`，429/413/404 只能显示 `HTTP错误: xxx`。
   * 现行为：复用 manageAssistent/api/client.ts 的 throwStreamHttpError（不新写一套解析器）
   *         + 本函数的兜底文案，得到可读提示。
   * 为什么：429 带 retryAfter 换算分钟、413/404 服务端无文案时用本地兜底。
   * 保守策略：只对「确认是 StreamError」的情况改写文案；普通 Error 一律走 fallback，
   * 保证行为不回归（例如网络中断、JSON 解析失败等仍显示原始 message）。
   */
  function formatClickError(e: any): string {
    const fallback = e?.message || '请求失败';
    // 429：额度用完 / 并发闸 / 每用户任务上限，服务端会给 retry_after（秒）
    if (e instanceof StreamError && e.status === 429) {
      if (typeof e.retryAfter === 'number') {
        const minutes = Math.ceil(e.retryAfter / 60);
        // 不足 1 分钟时不显示「0 分钟」
        return `${fallback}（约${minutes < 1 ? '不到 1 分钟' : `${minutes}分钟`}后恢复）`;
      }
      return `${fallback}（请稍后再试）`;
    }
    // 413：上传体积超限；仅当服务端没给出可读文案时才用本地兜底
    if (e instanceof StreamError && e.status === 413 && (!e.message || e.message === 'HTTP错误: 413')) {
      return '附件体积超过上限，请减小文件后重试';
    }
    // 404：会话不存在或无权访问（TfAgents 的会话归属校验）
    if (e instanceof StreamError && e.status === 404 && (!e.message || e.message === 'HTTP错误: 404')) {
      return '会话不存在或无权访问';
    }
    return fallback;
  }

  // 点击触发
  function handleClick(item: any) {
    modalVisible.value = true;
    loading.value = true;
    error.value = null;
    streamingText.value = '';
    thinking.value = false;
    todos.value = [];
    executingTools.value = [];
    toolCalls.value = [];
    latestMessage.value = '';

    const params = mapParams(item);
    itemName.value = 'tun_name' in params ? params.tun_name : params.device_name;
    const request = 'tun_id' in params ? fetchTunnelInterpretation(params, handleEvent) : fetchDeviceInterpretation(params, handleEvent);

    request
      .catch((e: any) => {
        // [审计-第四轮 M2] 重放自我方 fix/base-agent-token（M1/M2/M3）：结构化错误 → 可读文案
        error.value = formatClickError(e);
      })
      .finally(() => {
        loading.value = false;
        thinking.value = false;
        executingTools.value = [];
      });
  }

  // ── 悬停模式：按钮容器 + 触发器 ──
  let btnContainer: HTMLDivElement | null = null;
  const hoverMap = new Map<Element, HoverInstance>();

  if (mode === 'hover') {
    btnContainer = document.createElement('div');
    Object.assign(btnContainer.style, { position: 'fixed', top: '0', left: '0', zIndex: '99999', pointerEvents: 'none' });
    document.body.appendChild(btnContainer);
  }

  function createHoverTrigger(): HoverInstance {
    const btn = createButtonEl();
    btnContainer!.appendChild(btn);
    const inst = createHoverInstance(btn);
    (btn as any).__di_owner = inst;
    (inst as any)._btn = btn;
    allHoverInstances.add(inst);
    btn.addEventListener('click', (e) => {
      e.stopPropagation();
      const item = (inst as any).raw;
      if (item) handleClick(item);
    });
    return inst;
  }

  // ── 点击模式：元素映射 ──
  const clickRawMap = new Map<Element, any>();
  const clickHandlerMap = new Map<Element, (e: Event) => void>();

  // ── Vue 指令 ──
  const directive: Directive = {
    mounted(el, binding) {
      if (mode === 'hover') {
        const inst = createHoverTrigger();
        inst.setHost(el);
        inst.setRaw(binding.value);
        hoverMap.set(el, inst);
        el.addEventListener('mouseenter', inst.onEnter);
        el.addEventListener('mousemove', inst.onMove);
        el.addEventListener('mouseleave', inst.onLeave);
      } else {
        clickRawMap.set(el, binding.value);
        const handler = (e: Event) => {
          e.stopPropagation();
          const item = clickRawMap.get(el);
          if (item) handleClick(item);
        };
        clickHandlerMap.set(el, handler);
        el.addEventListener('click', handler);
      }
    },
    updated(el, binding) {
      if (mode === 'hover') {
        const inst = hoverMap.get(el);
        if (inst) inst.setRaw(binding.value);
      } else {
        clickRawMap.set(el, binding.value);
      }
    },
    unmounted(el) {
      if (mode === 'hover') {
        const inst = hoverMap.get(el);
        if (inst) {
          allHoverInstances.delete(inst);
          inst.destroy();
          hoverMap.delete(el);
        }
      } else {
        const handler = clickHandlerMap.get(el);
        if (handler) {
          el.removeEventListener('click', handler);
          clickHandlerMap.delete(el);
        }
        clickRawMap.delete(el);
      }
    },
  };

  function cleanup() {
    if (mode === 'hover') {
      hoverMap.forEach((inst) => inst.destroy());
      hoverMap.clear();
      if (btnContainer) {
        btnContainer.remove();
        btnContainer = null;
      }
    } else {
      clickRawMap.clear();
      clickHandlerMap.forEach((handler, el) => el.removeEventListener('click', handler));
      clickHandlerMap.clear();
    }
    if (modalApp) {
      modalApp.unmount();
      modalApp = null;
    }
    modalContainer.remove();
  }

  return { directive, cleanup, loading, streamingText, error, thinking, todos, executingTools, toolCalls, latestMessage, modalVisible };
}