// 帮助函数：按 protocol.md 构造测试数据帧

const net = require("net");
const config = require("../src/config");

/**
 * 构造公共头
 * @param {object} opts
 * @param {number} opts.frameType 0x1F/0x26/0x29
 * @param {number|string} [opts.deviceNumber] 机器号（5 字节小端整数，测试时可用数字或字符串）
 */
function buildHeader({ frameType, deviceNumber = 12345 }) {
  const header = Buffer.alloc(20);

  // 0-3: 帧头 0x55555555
  header[0] = 0x55;
  header[1] = 0x55;
  header[2] = 0x55;
  header[3] = 0x55;

  // 4: 机器类型（随便选一个：0x01=SWS-4000）
  header[4] = 0x01;

  // 5-9: 机器编号，协议为 5 字节无符号整数，小端在前
  let idNum = 0;
  if (typeof deviceNumber === "string") {
    // 字符串时按十进制解析
    idNum = parseInt(deviceNumber, 10) || 0;
  } else {
    idNum = Number(deviceNumber) || 0;
  }
  for (let i = 0; i < 5; i++) {
    header[5 + i] = idNum & 0xff;
    idNum = Math.floor(idNum / 256);
  }

  // 10: 机器运行模式（0x01=透析，参见 protocol.md 2.3）
  header[10] = 0x01;

  // 11: 数据帧类型
  header[11] = frameType;

  // 12: 协议版本，当前 V1.10 => 0x6E（见 protocol.md 2.5）
  header[12] = 0x6e;

  // 13-19: 保留 7 字节，全部置 0
  // Buffer.alloc 已经填 0，无需再写

  return header;
}

/**
 * 写入无符号整数（运行参数帧采用小端编码），与解析端 readUInt 对齐
 */
function writeUInt(buf, offset, value, length) {
  if (length === 1) return buf.writeUInt8(value, offset);
  if (length === 2) return buf.writeUInt16LE(value, offset);
  if (length === 4) return buf.writeUInt32LE(value, offset);
}

/**
 * 构造运行参数帧（0x1F），字段偏移参见 docs/protocol.md 3.2
 */
function buildRunParamsFrame(deviceNumber = 12345) {
  const data = Buffer.alloc(220);

  // 只是示例填一些看得见的值，便于验证解析
  writeUInt(data, 0, 3600, 4); // SetTreatmentTime: 3600s
  writeUInt(data, 4, 1200, 4); // K: 已治疗 1200s
  writeUInt(data, 8, 300, 2); // D: 血泵流量 300 ml/min
  writeUInt(data, 10, 1, 1); // xlyxbj: 血泵运行中
  writeUInt(data, 11, 1, 1); // klfs: 肝素抗凝
  writeUInt(data, 12, 1, 1); // z: 肝素泵运行
  writeUInt(data, 13, 500, 2); // E: 肝素泵流量 50.0 ml/h (×10)
  writeUInt(data, 17, 10, 2); // gstqjssj: 提前结束 10 min
  writeUInt(data, 21, 2000, 4); // A: 超滤总量 2000 ml
  writeUInt(data, 25, 500, 4); // B: 已超滤量 500 ml
  writeUInt(data, 29, 1, 1); // cllyxbj: 超滤泵运行
  writeUInt(data, 30, 0, 1); // plbj: 旁路关闭
  writeUInt(data, 31, 500, 2); // L: 透析液流量 500 ml/min
  writeUInt(data, 33, 370, 2); // F: 37.0℃ (×10)
  writeUInt(data, 35, 1450, 2); // G: 14.50 mS/cm (×100)
  writeUInt(data, 37, 100, 2); // C: 示例值
  writeUInt(data, 41, 1000, 4); // ypyzhyl: 已补入置换液量
  writeUInt(data, 45, 0, 1); // pyprfs: 前稀释
  writeUInt(data, 46, 100, 2); // ldslq
  writeUInt(data, 48, 50, 2); // ldslq2sysj
  writeUInt(data, 50, 600, 4); // jqzyxsj: 总运行 600min
  writeUInt(data, 54, 120, 2); // o: 动脉压 120 mmHg
  writeUInt(data, 56, 200, 2); // H: 静脉压 200 mmHg
  writeUInt(data, 58, 250, 2); // J: 跨膜压 250 mmHg
  writeUInt(data, 60, 150, 2); // I: 15.0 kPa (×10)
  writeUInt(data, 62, 20, 1); // lsxjl: 尿素下降率 20%
  writeUInt(data, 64, 3450, 2); // ssqclz: 34.50 (×100)
  writeUInt(data, 66, 365, 2); // jmyxh: 36.5℃ (×10)
  writeUInt(data, 68, 368, 2); // dmyxw: 36.8℃ (×10)
  writeUInt(data, 69, 80, 1); // xdxrl: 相对血容量 80%

  const header = buildHeader({ frameType: 0x1f, deviceNumber });
  return Buffer.concat([header, data]);
}

/**
 * 构造报警信息帧（0x26）
 *
 * 数据区字段偏移对应 src/protocol.js::parseAlarm：
 *  - 0:2 报警编号 alarmCode
 *  - 2:1 报警类型 bjlx (0=解除,1=产生)
 *  - 3:2 年, 5:1 月,6:1 日,7:1 时,8:1 分,9:1 秒
 */
function buildAlarmFrame(deviceNumber = 12345, { alarmType = 1, alarmCode = 283 } = {}) {
  const data = Buffer.alloc(150);

  // 报警编号在实际帧中为小端编码，这里按小端写入，
  // 确保抓包看到的字节序与透析机一致，例如 0x011B = 283 → 1B 01。
  data.writeUInt16LE(alarmCode, 0); // alarmCode: 示例编号

  writeUInt(data, 2, alarmType, 1); // bjlx: 0/1=解除/产生

  const now = new Date();
  const year = now.getFullYear();
  const month = now.getMonth() + 1;
  const day = now.getDate();
  const hour = now.getHours();
  const minute = now.getMinutes();
  const second = now.getSeconds();

  // 时间中的年份在协议中也是小端编码
  data.writeUInt16LE(year, 3);
  writeUInt(data, 5, month, 1);
  writeUInt(data, 6, day, 1);
  writeUInt(data, 7, hour, 1);
  writeUInt(data, 8, minute, 1);
  writeUInt(data, 9, second, 1);

  const header = buildHeader({ frameType: 0x26, deviceNumber });
  return Buffer.concat([header, data]);
}

/**
 * 构造血压测量数据帧（0x29）
 *
 * 注意：血压帧的数据区多字节字段使用小端序，
 * 与运行参数帧/报警帧不同，因此这里直接用 Buffer 的 writeUInt16LE 写入。
 *
 * 数据区字段偏移对应 src/protocol.js::parseBloodPressure：
 *  - 0:1  测量模式 bpMode (0/1=手动/自动)
 *  - 1:1  测量结果 bpResult (0/1=出错/成功)
 *  - 2 起 年/月/日/时/分/秒（年为 2 字节小端）
 *  - 9:2  收缩压 N (mmHg，小端)
 *  - 11:2 舒张压 O (mmHg，小端)
 *  - 13:2 脉搏 P (bpm，小端)
 *  - 15:2 平均动脉压 BPMPJDMY (mmHg，小端)
 */
function buildBloodPressureFrame(
  deviceNumber = 12345,
  { bpMode = 1, bpResult = 1, systolic = 129, diastolic = 93, heartRate = 86, map = 105 } = {}
) {
  const data = Buffer.alloc(150);

  // 单字节字段
  data.writeUInt8(bpMode, 0);
  data.writeUInt8(bpResult, 1);

  const now = new Date();
  const year = now.getFullYear();
  const month = now.getMonth() + 1;
  const day = now.getDate();
  const hour = now.getHours();
  const minute = now.getMinutes();
  const second = now.getSeconds();

  // 时间：年为 2 字节小端，其它为 1 字节
  data.writeUInt16LE(year, 2);
  data.writeUInt8(month, 4);
  data.writeUInt8(day, 5);
  data.writeUInt8(hour, 6);
  data.writeUInt8(minute, 7);
  data.writeUInt8(second, 8);

  // 血压相关字段，小端写入
  data.writeUInt16LE(systolic, 9);
  data.writeUInt16LE(diastolic, 11);
  data.writeUInt16LE(heartRate, 13);
  data.writeUInt16LE(map, 15);

  const header = buildHeader({ frameType: 0x29, deviceNumber });
  return Buffer.concat([header, data]);
}

/**
 * 通用发送函数：连上 TCP -> 发送一帧 -> 关闭
 */
function sendFrameOnce(label, buildFn) {
  const client = new net.Socket();

  client.connect(config.tcp.port, "192.168.220.1", () => {
    console.log(`[CLIENT] Connected to server ${config.tcp.port} for ${label}`);
    const frame = buildFn(12345);
    client.write(frame, () => {
      console.log(`[CLIENT] ${label} frame sent, length=`, frame.length);
      setTimeout(() => client.end(), 500);
    });
  });

  client.on("error", (err) => {
    console.error(`[CLIENT] ${label} socket error:`, err.message || err);
  });

  client.on("close", () => {
    console.log(`[CLIENT] ${label} connection closed`);
  });
}

function sendRunParamsOnce() {
  sendFrameOnce("RunParams(0x1F)", buildRunParamsFrame);
}

function sendAlarmOnce() {
  sendFrameOnce("Alarm(0x26)", buildAlarmFrame);
}

function sendBloodPressureOnce() {
  sendFrameOnce("BloodPressure(0x29)", buildBloodPressureFrame);
}

if (require.main === module) {
  // 直接运行本文件时，按顺序各发一帧三种类型，方便联调
  sendRunParamsOnce();
  setTimeout(() => sendAlarmOnce(), 800);
  setTimeout(() => sendBloodPressureOnce(), 1600);
}

module.exports = {
  buildRunParamsFrame,
  buildAlarmFrame,
  buildBloodPressureFrame,
  sendRunParamsOnce,
  sendAlarmOnce,
  sendBloodPressureOnce
};