// 模拟工业以太网/5G 网关数据接入与远程控制（前端造数）
// 设备围绕煤炭加工场景：带式输送机、破碎机、皮带秤、除尘风机、给煤机等

const DEFAULT_THRESHOLDS = {
  temperatureC: 85, // ℃
  pressureBar: 12, // bar
  currentA: 180, // A
  voltageV: 420, // V（三相线电压）
  powerFactor: 0.85 // cosφ
}

const STORAGE_KEYS = {
  thresholds: 'monitor_equipment_thresholds',
  channels: 'monitor_equipment_alarm_channels'
}

const DEFAULT_CHANNELS = {
  platform: true,
  sms: false,
  voice: false
}

const BASE_EQUIPMENTS = [
  { id: 'conv-01', name: '主煤流带式输送机#1', location: '筛分车间一线', type: 'conveyor' },
  { id: 'crusher-01', name: '齿辊破碎机#1', location: '破碎工段', type: 'crusher' },
  { id: 'feeder-01', name: '电机振动给煤机#1', location: '原煤仓下口', type: 'feeder' },
  { id: 'blower-01', name: '除尘离心风机#1', location: '装车除尘点', type: 'blower' },
  { id: 'scale-01', name: '皮带秤#1', location: '计量段', type: 'beltScale' }
]

function getRandomAround(base, fluct = 0.05) {
  const delta = base * fluct
  return +(base + (Math.random() * 2 - 1) * delta).toFixed(2)
}

function seededInitMetrics(type) {
  switch (type) {
    case 'conveyor':
      return { temperatureC: 55, pressureBar: 6.5, currentA: 95, voltageV: 400, powerFactor: 0.92 }
    case 'crusher':
      return { temperatureC: 65, pressureBar: 10.5, currentA: 140, voltageV: 405, powerFactor: 0.9 }
    case 'feeder':
      return { temperatureC: 50, pressureBar: 5.5, currentA: 60, voltageV: 398, powerFactor: 0.93 }
    case 'blower':
      return { temperatureC: 70, pressureBar: 8.2, currentA: 120, voltageV: 402, powerFactor: 0.88 }
    case 'beltScale':
      return { temperatureC: 48, pressureBar: 0.0, currentA: 35, voltageV: 401, powerFactor: 0.95 }
    default:
      return { temperatureC: 55, pressureBar: 6, currentA: 90, voltageV: 400, powerFactor: 0.9 }
  }
}

function nextMetrics(current, type) {
  const drift = {
    temperatureC: getRandomAround(current.temperatureC, 0.03),
    pressureBar: getRandomAround(current.pressureBar, 0.06),
    currentA: getRandomAround(current.currentA, 0.08),
    voltageV: getRandomAround(current.voltageV, 0.01),
    powerFactor: Math.max(0.6, Math.min(0.99, getRandomAround(current.powerFactor, 0.02)))
  }
  if (type === 'crusher') drift.currentA += Math.random() * 4 - 2
  if (type === 'blower') drift.powerFactor -= Math.random() * 0.01
  return {
    temperatureC: +drift.temperatureC.toFixed(2),
    pressureBar: +drift.pressureBar.toFixed(2),
    currentA: +drift.currentA.toFixed(2),
    voltageV: +drift.voltageV.toFixed(2),
    powerFactor: +drift.powerFactor.toFixed(2)
  }
}

export function getThresholds() {
  try {
    const raw = localStorage.getItem(STORAGE_KEYS.thresholds)
    if (!raw) return { ...DEFAULT_THRESHOLDS }
    const obj = JSON.parse(raw)
    return { ...DEFAULT_THRESHOLDS, ...obj }
  } catch (e) {
    return { ...DEFAULT_THRESHOLDS }
  }
}

export function saveThresholds(thresholds) {
  const merged = { ...DEFAULT_THRESHOLDS, ...thresholds }
  localStorage.setItem(STORAGE_KEYS.thresholds, JSON.stringify(merged))
  return merged
}

export function getAlarmChannels() {
  try {
    const raw = localStorage.getItem(STORAGE_KEYS.channels)
    if (!raw) return { ...DEFAULT_CHANNELS }
    const obj = JSON.parse(raw)
    return { ...DEFAULT_CHANNELS, ...obj }
  } catch (e) {
    return { ...DEFAULT_CHANNELS }
  }
}

export function saveAlarmChannels(channels) {
  const merged = { ...DEFAULT_CHANNELS, ...channels }
  localStorage.setItem(STORAGE_KEYS.channels, JSON.stringify(merged))
  return merged
}

// 订阅实时数据（模拟低时延、高可靠链路）
export function subscribeEquipmentData(callback, options = {}) {
  const { intervalMs = 1000, streaming = true } = options
  let isStopped = false

  const equipmentStates = BASE_EQUIPMENTS.map(e => ({
    ...e,
    status: 'RUNNING',
    metrics: seededInitMetrics(e.type)
  }))

  // 非流模式：仅推送一次快照
  if (!streaming) {
    const now = Date.now()
    equipmentStates.forEach(es => {
      callback({
        ts: now,
        equipmentId: es.id,
        name: es.name,
        location: es.location,
        status: es.status,
        metrics: { ...es.metrics }
      })
    })
    return () => {}
  }

  function tick() {
    if (isStopped) return
    const now = Date.now()
    equipmentStates.forEach(es => {
      if (Math.random() < 0.01) {
        es.status = es.status === 'RUNNING' ? 'STOPPED' : 'RUNNING'
      }
      if (es.status === 'RUNNING') {
        es.metrics = nextMetrics(es.metrics, es.type)
      } else {
        es.metrics = {
          ...es.metrics,
          currentA: +(es.metrics.currentA * 0.1).toFixed(2),
          powerFactor: Math.max(0.5, +(es.metrics.powerFactor * 0.8).toFixed(2))
        }
      }
      callback({
        ts: now,
        equipmentId: es.id,
        name: es.name,
        location: es.location,
        status: es.status,
        metrics: { ...es.metrics }
      })
    })
    timer = setTimeout(tick, intervalMs)
  }

  let timer = setTimeout(tick, intervalMs)
  return () => {
    isStopped = true
    if (timer) clearTimeout(timer)
  }
}

export function sendControlCommand(equipmentId, action) {
  return new Promise(resolve => {
    const delay = 50 + Math.round(Math.random() * 70)
    setTimeout(() => {
      resolve({ code: 200, msg: 'OK', data: { equipmentId, action, acceptedAt: Date.now() } })
      /* eslint-disable no-console */
      console.log(`[CONTROL] equipment=${equipmentId} action=${action}`)
    }, delay)
  })
}

export function detectAlarms(metrics, thresholds) {
  const over = []
  if (metrics.temperatureC > thresholds.temperatureC) over.push({ field: 'temperatureC', value: metrics.temperatureC, threshold: thresholds.temperatureC })
  if (metrics.pressureBar > thresholds.pressureBar) over.push({ field: 'pressureBar', value: metrics.pressureBar, threshold: thresholds.pressureBar })
  if (metrics.currentA > thresholds.currentA) over.push({ field: 'currentA', value: metrics.currentA, threshold: thresholds.currentA })
  if (metrics.voltageV > thresholds.voltageV) over.push({ field: 'voltageV', value: metrics.voltageV, threshold: thresholds.voltageV })
  if (metrics.powerFactor < thresholds.powerFactor) over.push({ field: 'powerFactor', value: metrics.powerFactor, threshold: thresholds.powerFactor })
  return over
}

export function listEquipments() {
  return BASE_EQUIPMENTS.map(e => ({ id: e.id, name: e.name, location: e.location, type: e.type }))
}

export default {
  subscribeEquipmentData,
  sendControlCommand,
  detectAlarms,
  getThresholds,
  saveThresholds,
  getAlarmChannels,
  saveAlarmChannels,
  listEquipments
}