update

tcpserver.js

@@ -7,33 +7,53 @@ let mongourl = `mongodb://root:letian2024.@172.16.0.16:27017/letian?authSource=a
 
 const server = net.createServer((socket) => {
     socket.on('data', (data) => {
+        if(isHex(data)) {
+            let dataString = data.toString("hex");
+            console.log(dataString, "----");
+            socket.write(Buffer.from([0xD0, 0x00]));
+
+        }
         const gbkString = iconv.decode(data, 'gbk');
         console.log(`收到消息：${gbkString}`);
         if (gbkString.includes('MQTT')) {
             //登录
             console.log("登录， “=========================")
-            socket.write(Buffer.from([0x20,  0x02, 0x00, 0x00]))
+            socket.write(Buffer.from([0x20, 0x02, 0x00, 0x00]))
         }
-        if (gbkString.includes('C0')) {
-            console.log("ping “=========================")
+        // if (gbkString.includes('C0')) {
+        //     console.log("ping “=========================")
 
-            socket.write(Buffer.from([0xD0, 0x00]));
+        //     socket.write(Buffer.from([0xD0, 0x00]));
+        // }
+
+        if (gbkString.includes('N82V3VWYU84K36UH')) {
+            console.log(`N82V3VWYU84K36UH:${gbkString}`);
+            let obj = genInsertObj(gbkString, "N82V3VWYU84K36UH");
+            console.log(obj);
+            connectAndInsert(obj);
+        }
+        if (gbkString.includes('WO6936WQZ0L1Q4A1')) {
+            console.log(`WO6936WQZ0L1Q4A1:${gbkString}`);
+            let obj = genInsertObj(gbkString, "WO6936WQZ0L1Q4A1");
+            console.log(obj);
+            connectAndInsert(obj);
         }
-    });
 
-    socket.on('N82V3VWYU84K36UH', (data) => {
-        const gbkString = iconv.decode(data, 'gbk');
-        console.log(`N82V3VWYU84K36UH:${gbkString}`);
-        let obj = genInsertObj(gbkString, "N82V3VWYU84K36UH");
-        connectAndInsert(obj);
-    });
-    socket.on('WO6936WQZ0L1Q4A1', (data) => {
-        const gbkString = iconv.decode(data, 'gbk');
-        console.log(`WO6936WQZ0L1Q4A1:${gbkString}`);
-        let obj = genInsertObj(gbkString, "WO6936WQZ0L1Q4A1");
-        connectAndInsert(obj);
     });
 
+    // socket.on('N82V3VWYU84K36UH', (data) => {
+    //     const gbkString = iconv.decode(data, 'gbk');
+    //     console.log(`N82V3VWYU84K36UH:${gbkString}`);
+    //     let obj = genInsertObj(gbkString, "N82V3VWYU84K36UH");
+    //     connectAndInsert(obj);
+    // });
+    // socket.on('WO6936WQZ0L1Q4A1', (data) => {
+    //     const gbkString = iconv.decode(data, 'gbk');
+    //     console.log(`WO6936WQZ0L1Q4A1:${gbkString}`);
+    //     let obj = genInsertObj(gbkString, "WO6936WQZ0L1Q4A1");
+    //     connectAndInsert(obj);
+    // });
+
     socket.on('end', () => {
         console.log("客户端断开连接");
     });
@@ -44,6 +64,10 @@ server.listen(3001, () => {
     console.log(`tcp server启动，监听端口3001`);
 })
 
+function isHex(str) {
+  return /^[0-9A-Fa-f]+$/.test(str) && str.length  % 2 === 0;
+}
+
 
 function genInsertObj(gbkString, deviceNumber) {
     let retString = gbkString.slice(deviceNumber);