const https = require('https');
const { info, warn, error } = require('./logger'); // 引入自定义的日志模块
const path = require('path');
const fs = require('fs');
const url = require('url');
const querystring = require('querystring');
// 读取配置文件
// 使用 pkg 特定的方式访问打包进来的资产
const configPath = path.join(__dirname, 'config.json');
const config = JSON.parse(fs.readFileSync(configPath, 'utf8'));

info(`获取文件 ${configPath}地址，${JSON.stringify(config)}`);
/**解析数据1 */
const parseData=(buf,index1,index2,index3,index4)=> {
    let data5 = (buf[index1] << 24) | (buf[index2] << 16) | (buf[index3] << 8) | buf[index4];
    return data5;
  }

  /**
   * 
   * @param {*} data：buff 
   * @returns 数据对象
   */
const funToModel=(data)=>{
    const row=data
    const msgBody={
        A: parseData(row,5,6,7,8),
        B: parseData(row,9,10,11,12),
        //脱水速率
        C: parseData(row,13,14,15,16),
        //血泵流量设定
        xlllsd: parseData(row,17,18,19,20),
        //透析液流量
        L: parseData(row,21,22,23,24),
        //透析液温度
        F: parseData(row,25,26,27,28),
        //电导度
        G: parseData(row,29,30,31,32),
        //静脉压
        H: parseData(row,33,34,35,36),
        //透析液压
        I: parseData(row,37,38,39,40),
        //跨膜压
        J: parseData(row,41,42,43,44),
        //透析时间
        K: parseData(row,45,46,47,48),
        //肝素泵流量
        E: parseData(row,49,50,51,52),
        //累计注射量
        X: parseData(row,53,54,55,56),
        //报警编号
        bjbh: parseData(row,57,58,59,60),
        //剩余时间
        sysj: parseData(row,61,62,63,64),
        //血流量
        U: parseData(row,65,66,67,68),
        //动脉压
        o: parseData(row,69,70,71,72),
        //收缩压
        ssy: parseData(row,73,74,75,76),
        //舒张压
        szy: parseData(row,77,78,79,80),
        //脉搏
        mb: parseData(row,81,82,83,84),
        suedtime:getFormattedDateTime()
    }
    // console.log(msgBody)
    return msgBody

}

/**数据校验 校验贝恩透析器 */
const calculateChecksum=(buf)=> {
    let checkSum = 0;
    for (let i =0;i<=84;i++) {
        if(i!==2&&i!==3&&i!==4){
            checkSum += buf[i];
        }
    }
    return  checkSum & 0xFF; 
}


const getFormattedDateTime=()=> {
    const now = new Date();
    
    // 获取各个部分
    const year = now.getFullYear();
    const month = String(now.getMonth() + 1).padStart(2, '0'); // 月份从0开始，所以需要加1
    const day = String(now.getDate()).padStart(2, '0');
    const hours = String(now.getHours()).padStart(2, '0');
    const minutes = String(now.getMinutes()).padStart(2, '0');
    const seconds = String(now.getSeconds()).padStart(2, '0');

    // 组合成所需格式
    return `${year}-${month}-${day} ${hours}:${minutes}:${seconds}`;
}

const  fetchServerList= async()=>{
    return new Promise((resolve, reject) => {
        // 构建完整的URL，包括查询参数
        const baseUrl = config.http.url;
        const params = querystring.stringify(config.http.params);
        const fullUrl = `${baseUrl}?${params}`;
        // 解析URL以获取hostname、path等信息
        const parsedUrl = new URL(fullUrl);
        // 配置选项
        const options = {
            hostname: parsedUrl.hostname,
            port: 443, // HTTPS 默认端口
            path: parsedUrl.pathname + parsedUrl.search,
            method: config.http.method.toUpperCase(),
            headers: {
                ...config.http.headers,
                'Content-Type': 'application/json',
                'Content-Length': 0 // 对于POST请求，如果不需要发送请求体，设置为0
            }
        };

        // 发送请求
        const req = https.request(options, (res) => {
            let data = '';

            // 接收数据
            res.on('data', (chunk) => {
                data += chunk;
            });

            // 请求完成
            res.on('end', () => {
                try {
                    resolve(JSON.parse(data));
                } catch (err) {
                    console.error(`解析服务器列表失败: ${err.message}`);
                    reject(err);
                }
            });
        }).on("error", (err) => {
            console.error(`获取服务器列表失败: ${err.message}`);
            reject(err);
        });

        // 结束请求
        req.end();
    });
}
// 导出日志函数
module.exports = {
    funToModel,
    calculateChecksum,
    getFormattedDateTime,
    fetchServerList
    
};