| | |
|---|
| | | const message = buffer.substring(startIdx, endIdx).trim(); |
|---|
| | | buffer = buffer.substring(endIdx + 2); // 移除已处理部分（含 \r\n） |
|---|
| | | |
|---|
| | | logger.info(`${deviceId} 接收到完整消息: ${message}`); |
|---|
| | | logger.info(`${deviceId} 接收到完整消息: q1261A00.00B00.00C00.00D0DSDASDSADSADSADSew5w5${message}nq4ds65g6m6767m`); |
|---|
| | | this.handleData(deviceId, message); |
|---|
| | | } |
|---|
| | | }); |
|---|
| | |
|---|
| | | if (deviceInfo.status === 'pending' || deviceInfo.status === 'invalid') { |
|---|
| | | // 握手阶段：在 'K' 和 'K0000' 之间切换（你的原始逻辑） |
|---|
| | | deviceInfo.lastSignal = deviceInfo.lastSignal === 'K' ? 'K0000' : 'K'; |
|---|
| | | logger.info(`重试发送 '${deviceInfo.lastSignal}' 给设备 ${deviceId}`); |
|---|
| | | logger.info(`重试发送 'abc${deviceInfo.lastSignal==='K'?'1':'0000'}abc' 给设备 ${deviceId}`); |
|---|
| | | this.sendKeepAliveToDevice(deviceId); |
|---|
| | | } |
|---|
| | | }, RETRY_INTERVAL_MS); |
|---|
| | |
|---|
| | | if (!deviceInfo || !deviceInfo.socket.writable) return; |
|---|
| | | |
|---|
| | | try { |
|---|
| | | deviceInfo.socket.write(`${deviceInfo.lastSignal}\r\n`); |
|---|
| | | logger.info(`发送信号 '${deviceInfo.lastSignal}' 给设备 ${deviceId}`); |
|---|
| | | deviceInfo.socket.write(`abc${deviceInfo.lastSignal}abc\r\n`); |
|---|
| | | logger.info(`发送信号 'abc${deviceInfo.lastSignal==='K'?'1':'0000'}abc' 给设备 ${deviceId}`); |
|---|
| | | } catch (err) { |
|---|
| | | logger.error(`发送信号失败 ${deviceId}:`, err.message); |
|---|
| | | this.removeDevice(deviceId); |
|---|
