|
const net = require('net');
|
const { info, warn, error } = require('./logger'); // 引入自定义的日志模块
|
const {calculateChecksum,funToModel,getFormattedDateTime} =require('./jiexiData')
|
const iot = require('aliyun-iot-device-sdk');
|
const path = require('path');
|
const fs = require('fs');
|
const axios = require('axios');
|
|
// 读取配置文件
|
// 使用 pkg 特定的方式访问打包进来的资产
|
const configPath = path.join(__dirname, 'config.json');
|
const config = JSON.parse(fs.readFileSync(configPath, 'utf8'));
|
|
info(`获取文件 ${configPath}地址，${JSON.stringify(config)}`);
|
async function fetchServerList() {
|
try {
|
const response = await axios({
|
method: config.http.method,
|
url: config.http.url,
|
headers: config.http.headers,
|
params: config.http.params
|
});
|
return response.data;
|
} catch (err) {
|
error(`获取服务器列表失败: ${err.message}`);
|
throw err;
|
}
|
}
|
|
// 初始化阿里云物联网设备客户端
|
function createIotClient(config) {
|
const client = iot.device({
|
productKey: config.productKey,
|
deviceName: config.deviceName,
|
deviceSecret: config.deviceSecret,
|
region: 'cn-shanghai' // 根据实际情况选择区域
|
});
|
|
client.on('connect', () => {
|
info(`阿里云物联网设备 ${config.deviceName} 已连接`);
|
});
|
|
client.on('error', (err) => {
|
error(`阿里云物联网设备 ${config.deviceName} 连接发生错误: ${err.message}`);
|
});
|
|
return client;
|
}
|
function connectToServer(server, iotConfig) {
|
let client;
|
let sendInterval;
|
const iotClient = createIotClient(iotConfig);
|
|
function attemptConnect() {
|
if (client) {
|
client.destroy(); // 确保旧的Socket实例被销毁
|
}
|
client = new net.Socket();
|
info(`${getFormattedDateTime()} 正在尝试连接到 ${server.host}:${server.port}`);
|
client.connect(server.port, server.host, () => {
|
info(`${getFormattedDateTime()} 已成功连接到 ${server.host}:${server.port}`);
|
|
// 定时发送数据
|
sendInterval = setInterval(() => {
|
if (client.writable) {
|
client.write(Buffer.from([0xFF, 0x55, 0x00, 0x50, 0xEE, 0x42]));
|
info(`${getFormattedDateTime()} 向 ${server.host}:${server.port} 发送数据`);
|
}
|
}, server.interval);
|
});
|
|
client.on('data', (data) => {
|
// 将接收到的 Buffer 数据转换为 16 进制字符串
|
const hexData = data.toString('hex').toUpperCase();
|
info(`${getFormattedDateTime()} 从 ${server.host}:${server.port} 接收到数据（16进制）: ${hexData}`);
|
|
// 将接收到的数据发送到阿里云物联网平台
|
console.log(data)
|
//计算校验码
|
const jyma= calculateChecksum(data)
|
console.log(jyma,data.length)
|
// 将接收到的数据发送到阿里云物联网平台
|
//数据头 67 89 长度86 做校验 贝朗的透析机
|
if(data[0]==103&&data[1]===137&&data.length===86&&jyma===data[85]){
|
try{
|
const mode=funToModel(data)
|
iotClient?.postProps(mode)
|
}catch(error){
|
console.log('数据解析有误')
|
}
|
}else{
|
console.log('无效的数据')
|
console.log(data[0],data[1],data[85])
|
}
|
});
|
|
client.on('close', (hadError) => {
|
clearInterval(sendInterval); // 清除定时发送
|
warn(`${getFormattedDateTime()} 连接到 ${server.host}:${server.port} 已关闭。发生错误: ${hadError}`);
|
|
// 无限次重连
|
const delay = Math.pow(2, server.retryCount++) * 1000; // 指数退避
|
warn(`${getFormattedDateTime()} 将在 60 秒后重试连接...`);
|
setTimeout(attemptConnect, 60000);
|
});
|
|
client.on('error', (err) => {
|
error(`${getFormattedDateTime()} 与 ${server.host}:${server.port} 的连接发生错误: ${err.message}`);
|
client.destroy(); // 确保发生错误时关闭连接，以便触发重连
|
});
|
}
|
|
attemptConnect();
|
}
|
|
// function connectToServer(server, iotConfig) {
|
// const client = new net.Socket();
|
// let sendInterval;
|
// const iotClient = createIotClient(iotConfig);
|
|
// function attemptConnect() {
|
// info(`正在尝试连接到 ${server.host}:${server.port}`);
|
// client.connect(server.port, server.host, () => {
|
// info(`已成功连接到 ${server.host}:${server.port}`);
|
// server.retryCount = 0; // 重置重试次数
|
|
// // 定时发送数据
|
// sendInterval = setInterval(() => {
|
// if (client.writable) {
|
// client.write(Buffer.from([0xFF, 0x55, 0x00, 0x50, 0xEE, 0x42]));
|
// info(`向 ${server.host}:${server.port} 发送数据`);
|
// }
|
// }, server.interval);
|
// });
|
|
// client.on('data', (data) => {
|
// // 将接收到的 Buffer 数据转换为 16 进制字符串
|
// const hexData = data.toString('hex').toUpperCase();
|
// info(`从 ${server.host}:${server.port} 接收到数据:${hexData}`);
|
// console.log(data)
|
// //计算校验码
|
// const jyma= calculateChecksum(data)
|
// console.log(jyma,data.length)
|
// // 将接收到的数据发送到阿里云物联网平台
|
// //数据头 67 89 长度86 做校验 贝朗的透析机
|
// if(data[0]==103&&data[1]===137&&data.length===86&&jyma===data[85]){
|
// try{
|
// const mode=funToModel(data)
|
// iotClient?.postProps(mode)
|
// }catch(error){
|
// console.log('数据解析有误')
|
// }
|
// }else{
|
// console.log('无效的数据')
|
// console.log(data[0],data[1],data[85])
|
// }
|
|
// });
|
|
// client.on('close', (hadError) => {
|
// warn(`连接到 ${server.host}:${server.port} 已关闭。发生错误: ${hadError}`);
|
// clearInterval(sendInterval); // 清除定时发送
|
// // 无限次重连
|
// warn(`${getFormattedDateTime()} 将在 10 秒后重试连接...`);
|
// setTimeout(attemptConnect, 10000);
|
// // if (hadError && server.retryCount < server.maxRetries) {
|
// // server.retryCount++;
|
// // const delay = Math.pow(2, server.retryCount) * 1000; // 指数退避
|
// // warn(`将在 ${delay / 1000} 秒后重试连接...`);
|
// // setTimeout(attemptConnect, delay);
|
// // } else if (server.retryCount >= server.maxRetries) {
|
// // error(`达到最大重试次数 (${server.maxRetries}) 对于 ${server.host}:${server.port}。不再尝试重连。`);
|
// // // 在这里可以加入通知机制，例如发送邮件或短信给管理员
|
// // }
|
// });
|
|
// client.on('error', (err) => {
|
// error(`与 ${server.host}:${server.port} 的连接发生错误: ${err.message}`);
|
// client.destroy(); // 确保发生错误时关闭连接，以便触发重连
|
// });
|
// }
|
|
// attemptConnect();
|
// }
|
|
async function start() {
|
try {
|
const res = await fetchServerList();
|
const servers=res?.data?.设备列表
|
// const servers=[
|
// {
|
// '设备IMEI号': 'C35AD053',
|
// '设备名称': 'TQS88-HDF',
|
// '阿里云物联网平台ProductKey': 'k08fz9VK3Q8',
|
// 'IP设置': '{"isEnabled":"1","ip":"127.0.0.1","port":"60000","work_mode":"client","interval":"30"}',
|
// '设备SIM号': '',
|
// '阿里云物联网信息': {
|
// owner: true,
|
// utcCreate: '2024-09-02T06:33:38.000Z',
|
// gmtActive: '2024-09-19 11:10:26',
|
// utcActive: '2024-09-19T03:10:26.617Z',
|
// ipAddress: '123.146.28.7',
|
// gmtOnline: '2024-09-20 10:14:19',
|
// gmtCreate: '2024-09-02 14:33:38',
|
// nodeType: 0,
|
// productKey: 'k08fz9VK3Q8',
|
// deviceName: 'C35AD053',
|
// productName: 'DORA6000',
|
// utcOnline: '2024-09-20T02:14:19.902Z',
|
// deviceSecret: '7dd8aaabae652f10ff7ab4410eda05dd',
|
// iotId: 'VCTmJy29VI1A62dfYlVsk08fz0',
|
// region: 'cn-shanghai',
|
// status: 'OFFLINE'
|
// },
|
// '设备编号': 'DEVICE1332405137464',
|
// '设备序列号': 'C35AD053',
|
// '设备医院编号': 'C35AD053',
|
// '阿里云物联网平台DeviceName': 'C35AD053',
|
// '阿里云物联网平台Secrect': '7dd8aaabae652f10ff7ab4410eda05dd'
|
// }
|
// ]
|
console.log('获取到客户设备信息')
|
console.log(servers)
|
servers.forEach(server => {
|
console.log(server)
|
if(server.阿里云物联网平台ProductKey==='k08fz9VK3Q8'){
|
const IP设置=JSON.parse(server.IP设置)
|
const ser={
|
host: IP设置?.ip,
|
port: IP设置?.port,
|
interval: IP设置?.interval*1000,
|
retryCount: 0,
|
maxRetries: 5,
|
iotConfig: {
|
productKey: server.阿里云物联网平台ProductKey,
|
deviceName: server.阿里云物联网平台DeviceName,
|
deviceSecret: server.阿里云物联网平台Secrect
|
}
|
}
|
connectToServer(ser, ser.iotConfig);
|
}
|
|
});
|
} catch (err) {
|
error('启动失败:', err.message);
|
}
|
}
|
|
|
start();
|
