添加新中新二代证读取器支持

electron/idcard-worker.js

@@ -0,0 +1,170 @@
+const { parentPort } = require("worker_threads");
+const koffi = require("koffi");
+const path = require("path");
+const iconv = require("iconv-lite");
+
+// 定义结构体
+const IDCardData = koffi.struct("IDCardData", {
+  Name: koffi.array("char", 32),
+  Sex: koffi.array("char", 6),
+  Nation: koffi.array("char", 20),
+  Born: koffi.array("char", 18),
+  Address: koffi.array("char", 72),
+  IDCardNo: koffi.array("char", 38),
+  GrantDept: koffi.array("char", 32),
+  UserLifeBegin: koffi.array("char", 18),
+  UserLifeEnd: koffi.array("char", 18),
+  reserved: koffi.array("char", 38),
+  PhotoFileName: koffi.array("char", 255),
+});
+
+let lib = null;
+let running = false;
+
+// 解码 GBK 字符串
+function decodeGBK(buffer) {
+  // 找到第一个 null 字节 (0x00) 的位置
+  let nullIndex = -1;
+  for (let i = 0; i < buffer.length; i++) {
+    if (buffer[i] === 0) {
+      nullIndex = i;
+      break;
+    }
+  }
+  // 如果找到了 null，截取前面的部分；否则使用整个 buffer
+  const validBuffer = nullIndex !== -1 ? buffer.slice(0, nullIndex) : buffer;
+  return iconv.decode(validBuffer, "gbk").trim();
+}
+
+// 加载 DLL
+function loadDll() {
+  if (lib) return true;
+  try {
+    const fs = require("fs");
+    const dllNames = ["Syn_IDCardRead.dll", "SynIDCardRead.dll"];
+
+    // 确定 DLL 目录：优先检查生产环境 resources/xzx，否则使用开发环境 resources/xzx
+    let dllDir = path.join(process.cwd(), "resources", "xzx");
+    if (process.resourcesPath) {
+      const prodDir = path.join(process.resourcesPath, "xzx");
+      if (fs.existsSync(prodDir)) {
+        dllDir = prodDir;
+      }
+    }
+
+    let dllPath = null;
+    for (const name of dllNames) {
+      const p = path.join(dllDir, name);
+      if (fs.existsSync(p)) {
+        dllPath = p;
+        break;
+      }
+    }
+
+    if (!dllPath) {
+      throw new Error(`DLL not found in ${dllDir}`);
+    }
+
+    lib = koffi.load(dllPath);
+
+    return {
+      Syn_FindUSBReader: lib.func("int Syn_FindUSBReader()"),
+      Syn_USBOpenPort: lib.func("int Syn_USBOpenPort(int)"),
+      Syn_USBClosePort: lib.func("int Syn_USBClosePort(int)"),
+      Syn_USBStartFindIDCard: lib.func(
+        "int Syn_USBStartFindIDCard(int, uint8*, int)"
+      ),
+      Syn_USBSelectIDCard: lib.func(
+        "int Syn_USBSelectIDCard(int, uint8*, int)"
+      ),
+      Syn_ReadMsg: lib.func("int Syn_ReadMsg(int, int, _Out_ IDCardData*)"),
+    };
+  } catch (err) {
+    parentPort.postMessage({
+      type: "error",
+      payload: `Failed to load DLL: ${err.message}`,
+    });
+    return null;
+  }
+}
+
+async function startListen() {
+  if (running) return;
+  running = true;
+
+  const api = loadDll();
+  if (!api) {
+    running = false;
+    return;
+  }
+
+  try {
+    let port = api.Syn_FindUSBReader();
+    if (port <= 0) port = 1001;
+
+    const openRes = api.Syn_USBOpenPort(port);
+    if (openRes !== 0) {
+      parentPort.postMessage({
+        type: "error",
+        payload: `Open port ${port} failed: ${openRes}`,
+      });
+      running = false;
+      return;
+    }
+
+    const iin = Buffer.alloc(4);
+    const sn = Buffer.alloc(8);
+    // IDCardData 结构体大小计算: 32+6+20+18+72+38+32+18+18+38+255 = 547 字节
+    // koffi 会自动处理结构体内存分配
+
+    while (running) {
+      // 寻卡
+      api.Syn_USBStartFindIDCard(port, iin, 0);
+      // 选卡
+      api.Syn_USBSelectIDCard(port, sn, 0);
+
+      // 读卡
+      const data = {}; // koffi 输出对象
+      const ret = api.Syn_ReadMsg(port, 0, data);
+
+      if (ret === 0 && data) {
+        const payload = {
+          name: decodeGBK(Buffer.from(data.Name)),
+          sex: decodeGBK(Buffer.from(data.Sex)),
+          nation: decodeGBK(Buffer.from(data.Nation)),
+          born: decodeGBK(Buffer.from(data.Born)),
+          address: decodeGBK(Buffer.from(data.Address)),
+          id_card_no: decodeGBK(Buffer.from(data.IDCardNo)),
+          grant_dept: decodeGBK(Buffer.from(data.GrantDept)),
+          life_begin: decodeGBK(Buffer.from(data.UserLifeBegin)),
+          life_end: decodeGBK(Buffer.from(data.UserLifeEnd)),
+          photo_path: decodeGBK(Buffer.from(data.PhotoFileName)),
+        };
+
+        parentPort.postMessage({ type: "data", payload });
+
+        // 读到卡后暂停一下，避免重复读取太快
+        await new Promise((r) => setTimeout(r, 500));
+      } else {
+        // 没读到卡，稍微等待
+        await new Promise((r) => setTimeout(r, 150));
+      }
+    }
+
+    api.Syn_USBClosePort(port);
+  } catch (err) {
+    parentPort.postMessage({
+      type: "error",
+      payload: `Worker error: ${err.message}`,
+    });
+    running = false;
+  }
+}
+
+parentPort.on("message", (msg) => {
+  if (msg === "start") {
+    startListen();
+  } else if (msg === "stop") {
+    running = false;
+  }
+});