#!/usr/bin/env node
/**
 * 企业微信消息推送模拟测试
 * 模拟 29.237.253.1 服务器 OEM 诊断和 OEM 维修故障完整生命周期
 * 每条消息间隔 5 秒
 */

const WEBHOOK_URL = process.env.WECOM_WEBHOOK_URL || (() => { throw new Error('WECOM_WEBHOOK_URL not set') })()
const SERVER_IP = '29.237.253.1'
const SERVER_SN = '210235A4M7H241000098'
const RACK = 'D01-404-I02-3U'
const INTERVAL = 5000

// 随机故障内容
const OEM_DIAG_FAULTS = [
  'agent已经5分钟没有上报数据',
  'GPU温度传感器读数异常，超过阈值',
  '系统日志显示内核恐慌(Kernel Panic)',
  'NVMe硬盘SMART检测到坏块',
  '内存ECC错误计数超标',
]
const OEM_REPAIR_FAULTS = [
  'GPU缓存发生不可纠正错误',
  'RAID阵列降级，一块硬盘离线',
  '电源模块冗余失效，单电源运行',
  '主板BMC固件异常，无法远程管理',
  '网卡绑定故障，网络中断',
]

const randomFrom = (arr) => arr[Math.floor(Math.random() * arr.length)]
const sleep = (ms) => new Promise(resolve => setTimeout(resolve, ms))

// 北京时间格式化
function bjTime(date = new Date()) {
  const d = new Date(date.getTime() + 8 * 3600_000)
  return `${d.getUTCFullYear()}-${String(d.getUTCMonth() + 1).padStart(2, '0')}-${String(d.getUTCDate()).padStart(2, '0')} ${String(d.getUTCHours()).padStart(2, '0')}:${String(d.getUTCMinutes()).padStart(2, '0')}:${String(d.getUTCSeconds()).padStart(2, '0')}`
}

// 向前推算时间
function minusHours(date, hours) {
  return new Date(date.getTime() - hours * 3600_000)
}
function minusMinutes(date, minutes) {
  return new Date(date.getTime() - minutes * 60_000)
}

async function sendText(text) {
  const res = await fetch(WEBHOOK_URL, {
    method: 'POST',
    headers: { 'Content-Type': 'application/json' },
    body: JSON.stringify({ msgtype: 'text', text: { content: text } }),
  })
  const data = await res.json()
  return data.errcode === 0
}

async function send(label, text) {
  console.log(`\n📤 [${label}]`)
  console.log(text)
  console.log('─'.repeat(50))
  const ok = await sendText(text)
  console.log(ok ? '✅ 发送成功' : '❌ 发送失败')
  await sleep(INTERVAL)
}

// ============================================================
// OEM 诊断完整生命周期
// ============================================================
async function runOemDiag() {
  const now = new Date()
  const faultTime = minusHours(now, 2)
  const orderNum = 'S' + Date.now().toString().slice(-10)
  const fault = randomFrom(OEM_DIAG_FAULTS)
  const oemDeadline = minusHours(faultTime, -6) // 故障后6小时到期

  console.log('\n' + '═'.repeat(60))
  console.log('  OEM 诊断 — 完整生命周期模拟')
  console.log('═'.repeat(60))
  console.log(`工单号: ${orderNum}`)
  console.log(`故障时间: ${bjTime(faultTime)}`)
  console.log(`到期时间: ${bjTime(oemDeadline)}`)

  // 1. 初始故障通知
  await send('初始通知', [
    `【服务器故障单】 - OEM诊断`,
    '',
    `工单号：${orderNum}`,
    `服务器IP：${SERVER_IP}`,
    `服务器SN：${SERVER_SN}`,
    `机架位置：${RACK}`,
    `故障时间：${bjTime(faultTime)}`,
    `到期时间：${bjTime(oemDeadline)}`,
    `故障信息：${fault}`,
  ].join('\n'))

  // 2. 每小时提醒（剩余4小时）
  const t4h = minusMinutes(oemDeadline, 240)
  await send('每小时提醒（剩余4小时0分）', [
    `⏰ OEM诊断工单提醒（剩余4小时0分）`,
    '',
    `工单号：${orderNum}`,
    `服务器IP：${SERVER_IP}`,
    `服务器SN：${SERVER_SN}`,
    `机架位置：${RACK}`,
    `到期时间：${bjTime(oemDeadline)}`,
    '',
    `服务器尚未录入恢复时间，请及时处理！`,
  ].join('\n'))

  // 3. 30分钟到期提醒
  await send('30分钟到期提醒', [
    `⚠️ OEM诊断工单即将到期（剩余30分钟）`,
    '',
    `工单号：${orderNum}`,
    `服务器IP：${SERVER_IP}`,
    `服务器SN：${SERVER_SN}`,
    `机架位置：${RACK}`,
    `到期时间：${bjTime(oemDeadline)}`,
    '',
    `服务器尚未录入恢复时间，请尽快处理！`,
  ].join('\n'))

  // 4. 超时提醒
  await send('超时提醒', [
    `⚠️ OEM诊断工单已超时`,
    '',
    `工单号：${orderNum}`,
    `服务器IP：${SERVER_IP}`,
    `服务器SN：${SERVER_SN}`,
    `机架位置：${RACK}`,
    `到期时间：${bjTime(oemDeadline)}`,
    '',
    `服务器尚未录入恢复时间，请尽快处理！`,
  ].join('\n'))

  // 5. 结单消息
  const closeTime = minusMinutes(now, -30)
  const durationMin = Math.floor((closeTime.getTime() - faultTime.getTime()) / 60000)
  const durH = Math.floor(durationMin / 60)
  const durM = durationMin % 60
  await send('结单消息', [
    `✅ ${orderNum}工单已结单`,
    '',
    `服务器IP：${SERVER_IP}`,
    `服务器SN：${SERVER_SN}`,
    `机架位置：${RACK}`,
    `故障类型：OEM诊断`,
    `故障时间：${bjTime(faultTime)}`,
    `结单时间：${bjTime(closeTime)}`,
    `本次处理时长：${durH}小时${durM}分钟`,
  ].join('\n'))
}

// ============================================================
// OEM 维修完整生命周期
// ============================================================
async function runOemRepair() {
  const now = new Date()
  const faultTime = minusHours(now, 4)
  const orderNum = 'S' + Date.now().toString().slice(-10)
  const fault = randomFrom(OEM_REPAIR_FAULTS)

  // 五档截止时间
  const tiers = [
    { name: '第一档', desc: '99%（含）以上（不扣费）', hours: 8, penalty: '10%' },
    { name: '第二档', desc: '99%-97%（含）（扣10%）', hours: 24, penalty: '25%' },
    { name: '第三档', desc: '97%-95%（含）（扣25%）', hours: 48, penalty: '50%' },
    { name: '第四档', desc: '95%-90%（含）（扣50%）', hours: 72, penalty: '100%' },
    { name: '第五档', desc: '90%（不含）以下（扣100%）', hours: 168, penalty: '' },
  ]

  const deadlines = tiers.map(t => ({
    ...t,
    deadline: new Date(faultTime.getTime() + t.hours * 3600_000),
  }))

  console.log('\n' + '═'.repeat(60))
  console.log('  OEM 维修 — 完整生命周期模拟')
  console.log('═'.repeat(60))
  console.log(`工单号: ${orderNum}`)
  console.log(`故障时间: ${bjTime(faultTime)}`)
  deadlines.forEach(d => console.log(`  ${d.name}截止: ${bjTime(d.deadline)} (${d.hours}h)`))

  // 1. 初始故障通知（含5档截止时间）
  const tierLines = deadlines.map((d, i) => {
    const emojis = ['1️⃣', '2️⃣', '3️⃣', '4️⃣', '5️⃣']
    return `${emojis[i]} ${d.desc}\n   截止时间：${bjTime(d.deadline)}（${d.hours}小时）`
  }).join('\n\n')

  await send('初始通知', [
    `【服务器故障单】 - OEM维修`,
    '',
    `工单号：${orderNum}`,
    `服务器IP：${SERVER_IP}`,
    `服务器SN：${SERVER_SN}`,
    `机架位置：${RACK}`,
    `故障时间：${bjTime(faultTime)}`,
    `故障信息：${fault}`,
    '',
    `📊 服务可用性各档位截止时间（基于月度内累计故障时长计算）：`,
    '',
    tierLines,
  ].join('\n'))

  // 2-5. 每个档位的提前1小时提醒
  for (let i = 0; i < 4; i++) {
    const t = deadlines[i]
    const isFinalTier = t.name === '第四档'
    const tierLabel = isFinalTier ? '全额扣费（100%）' : `${t.name}（${t.penalty}）`
    await send(`${t.name}提前1小时提醒`, [
      `OEM维修工单超时提醒（距离${tierLabel}还剩1小时）`,
      '',
      `工单号：${orderNum}`,
      `服务器IP：${SERVER_IP}`,
      `服务器SN：${SERVER_SN}`,
      `机架位置：${RACK}`,
      `${t.name}到期时间：${bjTime(t.deadline)}`,
      '',
      `服务器尚未录入恢复时间，请及时处理！`,
    ].join('\n'))
  }

  // 6-9. 每个档位的超时提醒
  for (let i = 0; i < 4; i++) {
    const t = deadlines[i]
    const isFinalTier = t.name === '第四档'
    const title = isFinalTier
      ? `OEM维修工单超时提醒（${t.name}已超时，已触发全额扣费（100%））`
      : `OEM维修工单超时提醒（${t.name}已超时，达到${t.name}扣${t.penalty}）`
    await send(`${t.name}超时提醒`, [
      title,
      '',
      `工单号：${orderNum}`,
      `服务器IP：${SERVER_IP}`,
      `服务器SN：${SERVER_SN}`,
      `机架位置：${RACK}`,
      `${t.name}到期时间：${bjTime(t.deadline)}`,
      '',
      `服务器尚未录入恢复时间，请尽快处理！`,
    ].join('\n'))
  }

  // 10. 结单消息（含本月统计）
  const closeTime = minusMinutes(now, -30)
  const durationMin = Math.floor((closeTime.getTime() - faultTime.getTime()) / 60000)
  const durH = Math.floor(durationMin / 60)
  const durM = durationMin % 60
  await send('结单消息', [
    `✅ ${orderNum}工单已结单`,
    '',
    `服务器IP：${SERVER_IP}`,
    `服务器SN：${SERVER_SN}`,
    `机架位置：${RACK}`,
    `故障类型：OEM维修`,
    `故障时间：${bjTime(faultTime)}`,
    `结单时间：${bjTime(closeTime)}`,
    `本次处理时长：${durH}小时${durM}分钟`,
    `本月故障次数：3次`,
    `本月总处理时长：18小时30分钟`,
  ].join('\n'))
}

// ============================================================
// 主流程
// ============================================================
async function main() {
  console.log('🚀 开始模拟企业微信消息推送')
  console.log(`Webhook: ${WEBHOOK_URL.slice(0, 50)}...`)
  console.log(`服务器: ${SERVER_IP} (${SERVER_SN})`)
  console.log(`机架: ${RACK}`)
  console.log(`间隔: ${INTERVAL / 1000}s`)

  console.log('\n' + '═'.repeat(60))
  console.log('  第一部分：OEM 诊断（5 条消息）')
  console.log('═'.repeat(60))
  await runOemDiag()

  console.log('\n⏸️  等待 10 秒...\n')
  await sleep(10000)

  console.log('═'.repeat(60))
  console.log('  第二部分：OEM 维修（10 条消息）')
  console.log('═'.repeat(60))
  await runOemRepair()

  console.log('\n' + '═'.repeat(60))
  console.log('✅ 全部消息发送完成（共 15 条）')
  console.log('═'.repeat(60))
}

main().catch(e => { console.error(e); process.exit(1) })