import { computed, ref } from 'vue'
import { defineStore } from 'pinia'
import { getWelcomeMessage, type WelcomeMessageData } from '@/api/welcome'
import { isDeviceOnline } from '@/constants/deviceOnline'
import { SseService } from '@/utils/sse'

function formatRequestDate(date = new Date()) {
  const pad = (n: number) => String(n).padStart(2, '0')
  return `${date.getFullYear()}-${pad(date.getMonth() + 1)}-${pad(date.getDate())} ${pad(date.getHours())}:${pad(date.getMinutes())}:${pad(date.getSeconds())}`
}

/** 可通过 updateState 批量更新的字段 */
export interface AppStateUpdates {
  terminal?: string
  accessToken?: string
  familyId?: string
  deviceType?: string
  deviceCategory?: string
  deviceName?: string
  deviceId?: string
  deviceGuid?: string
  userId?: string
  machineOpenStatus?: boolean | null
  machinePowerStateReady?: boolean
}

export const useAppStore = defineStore('app', () => {
  /** 应用展示名，可在启动时由接口或配置覆盖 */
  const appName = ref('Roki H5')
  const terminal = ref('android')
  const deviceName = ref('燃气热水器·HT808-16')
  const familyId = ref('')
  const deviceId = ref('HT80888a68d0fb812')
  const deviceGuid = ref('HT80888a68d0fb812')
  const deviceType = ref('HT808')
  const deviceCategory = ref('RRSQ')
  const userId = ref('3243300064')

  /** 开发联调用 token，生产环境由 App 注入覆盖 */
  const accessToken = ref(
    'eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJleHAiOjE4MDI5Mjg0ODAsInVzZXJJZCI6MzI0MzMwMDA2NCwianRpIjoiMDI3ZjhiMGMtYmU5MS00NzA2LWI3ZDUtOGI5OTJlMjA0MzQ2IiwiY2xpZW50X2lkIjoicm9raV9jbGllbnQifQ.aW0hKvcv-k_4PocYNVWiml7IB15jZIcn24eXZFZCSz4',
  )

  /** `/rest/ops/ai/welcome` 的 data：prefix / speech */
  const welcomeCopy = ref<WelcomeMessageData>({})

  /** 设备是否开机（null 表示尚未从 shadow/SSE 同步） */
  const machineOpenStatus = ref<boolean | null>(null)
  /** 开关机状态是否已从 shadow/SSE 同步过 */
  const machinePowerStateReady = ref(false)
  /**
   * 设备在线状态码：info/state → data[0].status
   * 0 离线 / 1 在线；未拉取前为 null
   */
  const deviceOnlineStatusCode = ref<number | null>(null)
  /** 是否在线（未拉取前默认 true，避免首屏误显示离线） */
  const machineOnlineStatus = computed(() => {
    const status = deviceOnlineStatusCode.value
    if (status === null || status === undefined) return true
    return isDeviceOnline(status)
  })
  /** SSE 客户端 */
  const sseClient = ref<SseService | null>(null)

  function setAppName(name: string) {
    appName.value = name
  }

  function setAccessToken(token: string) {
    accessToken.value = token
  }

  function setDeviceOnlineStatus(status: number) {
    deviceOnlineStatusCode.value = status
  }

  function initSSEClient(url: string) {
    if (sseClient.value) {
      console.log('[SSE] 已存在连接，不重复创建')
      return sseClient.value
    }
    sseClient.value = new SseService(url)
    return sseClient.value
  }

  function resetWelcomeCopy() {
    welcomeCopy.value = {}
  }

  async function loadWelcomeMessage(params: Record<string, unknown> = {}) {
    try {
      const res = await getWelcomeMessage({
        date: formatRequestDate(),
        ...params,
      })
      welcomeCopy.value = res?.data ?? {}
    } catch (e) {
      welcomeCopy.value = {}
      if (import.meta.env.DEV) {
        console.warn('[App] loadWelcomeMessage failed', e)
      }
    }
  }

  function updateState(updates: AppStateUpdates) {
    const stateRefs = {
      terminal,
      accessToken,
      familyId,
      deviceType,
      deviceCategory,
      deviceName,
      deviceId,
      deviceGuid,
      userId,
      machineOpenStatus,
      machinePowerStateReady,
    } as const

    Object.entries(updates).forEach(([key, value]) => {
      if (key in stateRefs) {
        stateRefs[key as keyof typeof stateRefs].value = value as never
      } else if (import.meta.env.DEV) {
        console.warn(`[App] updateState: unknown key "${key}"`)
      }
    })
  }

  return {
    appName,
    terminal,
    deviceName,
    familyId,
    deviceId,
    deviceGuid,
    deviceType,
    deviceCategory,
    userId,
    accessToken,
    welcomeCopy,
    machineOpenStatus,
    machinePowerStateReady,
    deviceOnlineStatusCode,
    machineOnlineStatus,
    sseClient,
    setAppName,
    setAccessToken,
    setDeviceOnlineStatus,
    initSSEClient,
    resetWelcomeCopy,
    loadWelcomeMessage,
    updateState,
  }
})