const net = require('net');
const { info, warn, error } = require('./logger'); // 引入自定义的日志模块
const {calculateChecksum,funToModel,getFormattedDateTime,fetchServerList} =require('./jiexiData')
const iot = require('aliyun-iot-device-sdk');
const { publishMessage } = require('./mqttClient');



// 初始化阿里云物联网设备客户端
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)
                    mode.n=iotConfig.deviceName,
                    mode.IPAddress=server.host,
                    iotClient.postProps(mode)
                    console.log('发送消息到matt')
                    onDeviceDataReceived(mode,iotConfig.deviceName);
                    
                }catch(error){
                    console.log('数据解析有误')
                }
            }else{
                console.log('无效的数据')
                console.log(data[0],data[1],data[85])
            }
        });

        client.on('close', (hadError) => {
            clearInterval(sendInterval); // 清除定时发送
            error(`${getFormattedDateTime()} 连接到 ${server.host}:${server.port} 已关闭。发生错误: ${hadError}`);

            // 无限次重连
            const delay = Math.pow(2, server.retryCount++) * 1000; // 指数退避
            error(`${getFormattedDateTime()} 将在 60 秒后重试连接...`);
            setTimeout(attemptConnect, 60000);
        });

        client.on('error', (err) => {
            error(`${getFormattedDateTime()} 与 ${server.host}:${server.port} 的连接发生错误: ${err.message}`);
            client.destroy(); // 确保发生错误时关闭连接，以便触发重连
        });
    }

    attemptConnect();
}

async function start() {
    try {
        // const res = await fetchServerList();
        // const servers=res?.data?.设备列表
        fetchServerList().then(res => {
            // const servers=[
                // {
                    // '设备IMEI号': 'C35AD053',
                    // '设备名称': 'TQS88-HDF',
                    // '阿里云物联网平台ProductKey': 'k08fz9VK3Q8',
                    // 'IP设置': '{"isEnabled":"1","ip":"127.0.0.1","port":"6000","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'
                //   }
            // ]
            const servers=res.data.设备列表
            console.log('获取到客户设备信息')
            console.log(servers)
            servers.forEach(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(error => {
            console.error('错误:', error);
        });
        
    } catch (err) {
        error('启动失败:', err.message);
    }
}


start();


// 模拟设备接收到的数据
async function onDeviceDataReceived(data,deviceName) {
  const topic = `touxiji/${deviceName}`;
  const payload = JSON.stringify({
    ...data,
    timestamp: new Date().toISOString()
  });

  publishMessage(topic, payload);
}