import { ref } from 'vue'
import { closeWarningException, getWarningExceptions, type WarningExceptionRecord } from '@/api/tests'
import { formatBusinessTime } from '@/utils/businessTime'

export type ExceptionStatus = '待处理' | '已处理'

export interface ExceptionRecord {
  id: number
  testId: number
  testName: string
  testTime: string
  source: string
  exceptionItem: string
  abnormalValue: string
  normalValue: string
  generatedAt: string
  processor: string
  handledAt: string
  status: ExceptionStatus
  handleRemark: string
}

const records = ref<ExceptionRecord[]>([])

function mapRecord(item: WarningExceptionRecord): ExceptionRecord {
  const offline = item.exceptionType === 'DEVICE_OFFLINE'
  let normalValue = '-'
  try { const rule = JSON.parse(item.ruleSnapshot || '{}'); normalValue = rule.maxValue != null ? `≤ ${rule.maxValue} ${item.unit}` : rule.minValue != null ? `≥ ${rule.minValue} ${item.unit}` : '-' } catch { /* 快照不可解析时仍展示异常事实 */ }
  const sourceLabel = ({ CABINET: '检测柜', CABINET_CHANNEL: '检测柜通道', COLLECTOR: '采集器' } as Record<string, string>)[item.sourceType] || item.sourceType
  return {
    id: item.exceptionId, testId: item.testId, testName: item.testName || `测试 #${item.testId}`,
    testTime: formatBusinessTime(item.firstOccurredAtUtc),
    source: `${sourceLabel}${item.sourceIdentity ? ` · ${item.sourceIdentity}` : ''}`,
    exceptionItem: offline ? '设备离线' : item.metricCode,
    abnormalValue: offline ? '离线' : item.abnormalValue == null ? '-' : `${item.abnormalValue} ${item.unit}`,
    normalValue: offline ? '在线' : normalValue,
    generatedAt: formatBusinessTime(item.lastOccurredAtUtc), processor: item.handledByName || '',
    handledAt: formatBusinessTime(item.handledAtUtc), status: item.exceptionStatus === 'OPEN' ? '待处理' : '已处理',
    handleRemark: item.handlingNote || '',
  }
}

export function useExceptions() {
  async function loadFromServer() {
    try { records.value = (await getWarningExceptions()).map(mapRecord); return true } catch { records.value = []; return false }
  }
  async function handleServerRecord(id: number, handleRemark: string) {
    const saved = await closeWarningException(id, handleRemark)
    const index = records.value.findIndex(item => item.id === id)
    if (index >= 0) records.value[index] = mapRecord(saved)
    return true
  }

  return { records, handleServerRecord, loadFromServer }
}