const SerialPort = require('serialport');
const { Readline } = require('@serialport/parser-readline'); // 可选：按行解析

// 配置你的串口（根据实际情况修改）
const PORT_NAME = 'COM5'; // Windows 示例，Linux/macOS 如 '/dev/ttyUSB0' 或 '/dev/ttyS0'
const BAUD_RATE = 9600;

// 要发送的指令（十六进制字符串数组）
const commands = [
  '16 2f 40 31 04 03',
  '16 31 3f 48 44 04 03',
  '16 31 3f 43 44 04 03'
];

// 将十六进制字符串转为 Buffer
function hexStringToBuffer(hexStr) {
  const hex = hexStr.replace(/\s+/g, '');
  const bytes = [];
  for (let i = 0; i < hex.length; i += 2) {
    bytes.push(parseInt(hex.substr(i, 2), 16));
  }
  return Buffer.from(bytes);
}

// 延迟函数
function delay(ms) {
  return new Promise(resolve => setTimeout(resolve, ms));
}

async function main() {
  try {
    console.log(`正在打开串口 ${PORT_NAME}...`);
    const port = new SerialPort({
      path: PORT_NAME,
      baudRate: BAUD_RATE,
      autoOpen: false
    });

    // 打开串口
    await new Promise((resolve, reject) => {
      port.open(err => {
        if (err) return reject(err);
        console.log('✅ 串口已打开');
        resolve();
      });
    });

    // 监听数据回传
    port.on('data', (data) => {
      console.log(`📥 收到回传 (${new Date().toISOString()}):`, data.toString('hex').match(/.{1,2}/g).join(' '));
      // 如果你想看原始字节或 ASCII，也可以打印 data.toString()
    });

    // 依次发送命令
    for (let i = 0; i < commands.length; i++) {
      const cmd = commands[i];
      const buffer = hexStringToBuffer(cmd);
      console.log(`📤 发送指令 ${i + 1}: ${cmd}`);
      port.write(buffer);

      // 等待 5 秒再发下一条
      await delay(5000);
    }

    console.log('✅ 所有指令已发送完毕');

    // 可选：5秒后关闭串口
    await delay(5000);
    port.close();
    console.log('🔌 串口已关闭');

  } catch (err) {
    console.error('❌ 错误:', err.message);
    process.exit(1);
  }
}

// 列出可用串口（调试用）
SerialPort.list().then(ports => {
  console.log('可用串口:');
  ports.forEach(p => console.log('-', p.path, p.manufacturer || ''));
});

// 启动主程序
main();