import dxCommonUtils from "../../dxmodules/dxCommonUtils.js";
import dxos from "../../dxmodules/dxOs.js";
import config from "../../dxmodules/dxConfig.js";
import logger from "../../dxmodules/dxLogger.js";
import ota from "../../dxmodules/dxOta.js";
import std from "../../dxmodules/dxStd.js";
import driver from "../driver.js";
import configService from "./configService.js";
import sqliteService from "./sqliteService.js";
import faceService from "./faceService.js";
import dxMap from '../../dxmodules/dxMap.js'
import bus from "../../dxmodules/dxEventBus.js";
import api from './api.js'
import weComService from "./weComService.js";
const mqttService = {}

mqttService.receiveMsg = function (data) {
    // {"topic":"ddddd","payload":"{\n  \"msg\": \"world\"\n}"}
    logger.info('[mqttService] receiveMsg :' + JSON.stringify(data.topic))
    if (typeof mqttService[data.topic.match(/[^/]+$/)[0]] == 'function') {
        let payload = parsePayloadSafely(data)
        if (typeof payload == 'string') {
            return reply(data, payload, CODE.E_100)
        }
        mqttService[data.topic.match(/[^/]+$/)[0]](data)
    } else {
        logger.error("未实现的topic", data.topic)
    }
}

function parsePayloadSafely(event) {
    try {
        return JSON.parse(event.payload)
    } catch (error) {
        return "Invalid JSON format​​"
    }
}

// =================================权限增删改查=================================
/**
 * 添加权限
 */
mqttService.insertPermission = function (event) {
    let payload = JSON.parse(event.payload)
    let data = payload.payload && payload.payload.data ? payload.payload.data : payload.data
    if (data.length > 100) {
        return reply(event, "data length should not be greater than 100", CODE.E_100)
    }
    let res = api.insertPermission(data)
    if (Array.isArray(res)) {
        return reply(event, res, CODE.E_100)
    }
    return reply(event)
}

/**
 * 查询权限
 */
mqttService.getPermission = function (event) {
    let payload = JSON.parse(event.payload)
    let data = payload.payload && payload.payload.data ? payload.payload.data : payload.data
    let res = api.getPermission(data)
    return reply(event, res)
}

/**
 * 删除权限
 */
mqttService.delPermission = function (event) {
    let payload = JSON.parse(event.payload)
    let data = payload.payload && payload.payload.data ? payload.payload.data : payload.data
    let res = api.delPermission(data)
    if (Array.isArray(res)) {
        return reply(event, res, CODE.E_100)
    }
    return reply(event)
}

/**
 * 修改权限
 */
mqttService.modifyPermission = function (event) {
    let payload = JSON.parse(event.payload)
    let data = payload.payload && payload.payload.data ? payload.payload.data : payload.data
    if (data.length > 100) {
        return reply(event, "data length should not be greater than 100", CODE.E_100)
    }
    let res = api.modifyPermission(data)
    if (Array.isArray(res)) {
        return reply(event, res, CODE.E_100)
    }
    return reply(event)
}

/**
 * 清空权限
 */
mqttService.clearPermission = function (event) {
    let ret = api.clearPermission()
    if (typeof ret == "string") {
        return reply(event, "sql error ret:" + ret, CODE.E_100)
    } else {
        return reply(event)
    }
}


// =================================人员增删改查=================================
/**
 * 添加人员
 */
mqttService.insertUser = function (event) {
    let payload = JSON.parse(event.payload)
    let data = payload.payload && payload.payload.data ? payload.payload.data : payload.data
    if (data.length > 100) {
        return reply(event, "data length should not be greater than 100", CODE.E_100)
    }
    let res = api.insertUser(data)
    if (Array.isArray(res)) {
        return reply(event, res, CODE.E_100)
    }
    return reply(event)
}


/**
 * 查询人员
 */
mqttService.getUser = function (event) {
    let payload = JSON.parse(event.payload)
    let data = payload.payload && payload.payload.data ? payload.payload.data : payload.data
    let res = api.getUser(data)
    return reply(event, res)
}

/**
 * 删除人员
 */
mqttService.delUser = function (event) {
    let payload = JSON.parse(event.payload)
    let data = payload.payload && payload.payload.data ? payload.payload.data : payload.data
    let res = api.delUser(data)
    if (Array.isArray(res)) {
        return reply(event, res, CODE.E_100)
    }
    return reply(event)
}

/**
 * 清空人员
 */
mqttService.clearUser = function (event) {
    let ret = api.clearUser()
    if (typeof ret == "string") {
        return reply(event, "sql error ret:" + ret, CODE.E_100)
    } else {
        return reply(event)
    }
}

/**
 * 修改人员
 */
mqttService.modifyUser = function (event) {
    let payload = JSON.parse(event.payload)
    let data = payload.payload && payload.payload.data ? payload.payload.data : payload.data
    if (data.length > 100) {
        return reply(event, "data length should not be greater than 100", CODE.E_100)
    }
    let res = api.modifyUser(data)
    if (Array.isArray(res)) {
        return reply(event, res, CODE.E_100)
    }
    return reply(event)
}

// =================================凭证增删改查=================================
/**
 * 添加凭证
 */
mqttService.insertKey = function (event) {
    let payload = JSON.parse(event.payload)
    let data = payload.payload && payload.payload.data ? payload.payload.data : payload.data
    if (data.length > 100) {
        return reply(event, "data length should not be greater than 100", CODE.E_100)
    }
    let res = api.insertKey(data)
    if (Array.isArray(res)) {
        return reply(event, res, CODE.E_100)
    }
    return reply(event)
}

/**
 * 查询凭证
 */
mqttService.getKey = function (event) {
    let payload = JSON.parse(event.payload)
    let data = payload.payload && payload.payload.data ? payload.payload.data : payload.data
    let res = api.getKey(data)
    if (typeof res == 'string') {
        return reply(event, res, CODE.E_100)
    }
    return reply(event, res)
}

/**
 * 删除凭证
 */
mqttService.delKey = function (event) {
    let payload = JSON.parse(event.payload)
    let data = payload.payload && payload.payload.data ? payload.payload.data : payload.data
    let res = api.delKey(data)
    if (Array.isArray(res)) {
        return reply(event, res, CODE.E_100)
    }
    return reply(event)
}


/**
 * 清空凭证
 */
mqttService.clearKey = function (event) {
    let payload = JSON.parse(event.payload)
    let data = payload.payload && payload.payload.data ? payload.payload.data : payload.data
    let ret = api.clearKey(data)
    if (typeof ret == "string") {
        return reply(event, "sql error ret:" + ret, CODE.E_100)
    } else {
        return reply(event)
    }
}

/**
 * 修改凭证
 */
mqttService.modifyKey = function (event) {
    let payload = JSON.parse(event.payload)
    let data = payload.payload && payload.payload.data ? payload.payload.data : payload.data
    if (data.length > 100) {
        return reply(event, "data length should not be greater than 100", CODE.E_100)
    }
    let res = api.modifyKey(data)
    if (Array.isArray(res)) {
        return reply(event, res, CODE.E_100)
    }
    return reply(event)
}



// =================================应急开仓密码增删改查=================================
/**
 * 添加应急开仓密码
 * @param {object} event - MQTT事件对象
 */
mqttService.insertEmergencyPassword = function (event) {
    try {
        logger.info('[mqttService] 接收到insertEmergencyPassword命令:', JSON.stringify(event.topic))
        logger.info('[mqttService] 命令payload:', event.payload)
        let payload = JSON.parse(event.payload)
        let data = payload.payload && payload.payload.data ? payload.payload.data : {}
        logger.info('[mqttService] 解析后的参数:', JSON.stringify(data))
        let res = this.insertEmergencyPasswordAgreement(data)
        if (typeof res == 'string') {
            logger.error('[mqttService] insertEmergencyPassword失败:', res)
            return reply(event, res, CODE.E_100)
        }
        logger.info('[mqttService] insertEmergencyPassword成功')
        return reply(event)
    } catch (error) {
        logger.error('[mqttService] insertEmergencyPassword error:', error)
        return reply(event, { error: error.message }, CODE.E_100)
    }
}

/**
 * 添加应急开仓密码通用协议格式
 * @param {object} data - 应急开仓密码数据对象
 * @returns {boolean|string} true表示成功，string表示错误信息
 */
mqttService.insertEmergencyPasswordAgreement = function (data) {
    // 应急开仓密码在设备中仅有唯一的1个，所以先清空表
    let deleteRet = sqliteService.d1_emergency_password.deleteAll()
    if (deleteRet != 0) {
        return "清空旧密码失败: " + deleteRet
    }
    
    // 检查密码是否有效
    if (!data.password) {
        return "password cannot be empty"
    }
    
    // 检查密码长度是否大于等于8位
    if (data.password.length < 8) {
        return "Password length must be at least 8 digits"
    }
    
    // 构建密码记录
    let record = {}
    record.id = data.id || 'emergency_' + Date.now() // 如果没有id，自动生成
    record.password = data.password
    record.description = "云端下发" // 通过MQTT和HTTP接口设置的应急开仓密码，description填充为"云端下发"
    record.createTime = Date.now()
    record.updateTime = Date.now()
    record.status = data.status || 1
    
    // 保存密码
    let ret = sqliteService.d1_emergency_password.save(record)
    if (ret == 0) {
        return true
    } else {
        return "sql error ret:" + ret
    }
}

/**
 * 查询应急开仓密码
 * @param {object} event - MQTT事件对象
 */
mqttService.getEmergencyPassword = function (event) {
    try {
        logger.info('[mqttService] 接收到getEmergencyPassword命令:', JSON.stringify(event.topic))
        logger.info('[mqttService] 命令payload:', event.payload)
        let payload = JSON.parse(event.payload)
        let res = this.getEmergencyPasswordAgreement()
        logger.info('[mqttService] 查询结果:', JSON.stringify(res))
        return reply(event, res)
    } catch (error) {
        logger.error('[mqttService] getEmergencyPassword error:', error)
        return reply(event, { error: error.message }, CODE.E_100)
    }
}

/**
 * 查询应急开仓密码通用协议格式
 * @returns {object} 查询结果
 */
mqttService.getEmergencyPasswordAgreement = function () {
    let passwords = sqliteService.d1_emergency_password.findAll()
    if (passwords && passwords.length > 0) {
        let password = passwords[0];
        // 转换时间戳为字符串格式
        if (password.createTime) {
            // 尝试将createTime转换为数字
            const createTimeNum = Number(password.createTime);
            if (!isNaN(createTimeNum)) {
                // 检查时间戳是否为毫秒级（大于等于10位）
                if (createTimeNum.toString().length >= 10) {
                    // 已经是毫秒级，转换为秒级
                    password.createTime = timestampToDateString(createTimeNum / 1000);
                } else {
                    // 秒级，直接使用
                    password.createTime = timestampToDateString(createTimeNum);
                }
            }
        }
        if (password.updateTime) {
            // 尝试将updateTime转换为数字
            const updateTimeNum = Number(password.updateTime);
            if (!isNaN(updateTimeNum)) {
                // 检查时间戳是否为毫秒级（大于等于10位）
                if (updateTimeNum.toString().length >= 10) {
                    // 已经是毫秒级，转换为秒级
                    password.updateTime = timestampToDateString(updateTimeNum / 1000);
                } else {
                    // 秒级，直接使用
                    password.updateTime = timestampToDateString(updateTimeNum);
                }
            }
        }
        return password;
    }
    return {};
}


/**
 * 清空应急开仓密码
 * @param {object} event - MQTT事件对象
 */
mqttService.clearEmergencyPassword = function (event) {
    try {
        logger.info('[mqttService] 接收到clearEmergencyPassword命令:', JSON.stringify(event.topic))
        logger.info('[mqttService] 命令payload:', event.payload)
        let ret = sqliteService.d1_emergency_password.deleteAll()
        if (ret == 0) {
            logger.info('[mqttService] clearEmergencyPassword成功')
            return reply(event)
        } else {
            logger.error('[mqttService] clearEmergencyPassword失败:', "sql error ret:" + ret)
            return reply(event, "sql error ret:" + ret, CODE.E_100)
        }
    } catch (error) {
        logger.error('[mqttService] clearEmergencyPassword error:', error)
        return reply(event, { error: error.message }, CODE.E_100)
    }
}


// =================================密钥增删改查=================================
/**
 * 添加密钥
 */
mqttService.insertSecurity = function (event) {
    let payload = JSON.parse(event.payload)
    let data = payload.payload && payload.payload.data ? payload.payload.data : payload.data
    if (data.length > 100) {
        return reply(event, "data length should not be greater than 100", CODE.E_100)
    }
    let res = api.insertSecurity(data)
    if (Array.isArray(res)) {
        return reply(event, res, CODE.E_100)
    }
    return reply(event)
}

/**
 * 查询密钥
 */
mqttService.getSecurity = function (event) {
    let payload = JSON.parse(event.payload)
    let data = payload.payload && payload.payload.data ? payload.payload.data : payload.data
    let res = api.getSecurity(data)
    if (typeof res == 'string') {
        return reply(event, res, CODE.E_100)
    }
    return reply(event, res)
}

/**
 * 删除密钥
 */
mqttService.delSecurity = function (event) {
    let payload = JSON.parse(event.payload)
    let data = payload.payload && payload.payload.data ? payload.payload.data : payload.data
    let res = api.delSecurity(data)
    if (Array.isArray(res)) {
        return reply(event, res, CODE.E_100)
    }
    return reply(event)
}

/**
 * 清空密钥
 */
mqttService.clearSecurity = function (event) {
    let ret = api.clearSecurity()
    if (typeof ret == "string") {
        return reply(event, "sql error ret:" + ret, CODE.E_100)
    } else {
        return reply(event)
    }
}


// =================================应急开仓密码增删改查=================================
/**
 * 添加应急开仓密码
 * @param {object} event - MQTT事件对象
 */
mqttService.insertEmergencyPassword = function (event) {
    try {
        logger.info('[mqttService] 接收到insertEmergencyPassword命令:', JSON.stringify(event.topic))
        logger.info('[mqttService] 命令payload:', event.payload)
        let payload = JSON.parse(event.payload)
        let data = payload.payload && payload.payload.data ? payload.payload.data : {}
        logger.info('[mqttService] 解析后的参数:', JSON.stringify(data))
        let res = this.insertEmergencyPasswordAgreement(data)
        if (typeof res == 'string') {
            logger.error('[mqttService] insertEmergencyPassword失败:', res)
            return reply(event, res, CODE.E_100)
        }
        logger.info('[mqttService] insertEmergencyPassword成功')
        return reply(event)
    } catch (error) {
        logger.error('[mqttService] insertEmergencyPassword error:', error)
        return reply(event, { error: error.message }, CODE.E_100)
    }
}

/**
 * 添加应急开仓密码通用协议格式
 * @param {object} data - 应急开仓密码数据对象
 * @returns {boolean|string} true表示成功，string表示错误信息
 */
mqttService.insertEmergencyPasswordAgreement = function (data) {
    // 应急开仓密码在设备中仅有唯一的1个，所以先清空表
    let deleteRet = sqliteService.d1_emergency_password.deleteAll()
    if (deleteRet != 0) {
        return "清空旧密码失败: " + deleteRet
    }
    
    // 检查密码是否有效
    if (!data.password) {
        return "password cannot be empty"
    }
    
    // 检查密码长度是否大于等于8位
    if (data.password.length < 8) {
        return "Password length must be at least 8 digits"
    }
    
    // 构建密码记录
    let record = {}
    record.id = data.id || 'emergency_' + Date.now() // 如果没有id，自动生成
    record.password = data.password
    record.description = "云端下发" // 通过MQTT和HTTP接口设置的应急开仓密码，description填充为"云端下发"
    record.createTime = Date.now()
    record.updateTime = Date.now()
    record.status = data.status || 1
    
    // 保存密码
    let ret = sqliteService.d1_emergency_password.save(record)
    if (ret == 0) {
        return true
    } else {
        return "sql error ret:" + ret
    }
}

/**
 * 查询应急开仓密码
 * @param {object} event - MQTT事件对象
 */
mqttService.getEmergencyPassword = function (event) {
    try {
        logger.info('[mqttService] 接收到getEmergencyPassword命令:', JSON.stringify(event.topic))
        logger.info('[mqttService] 命令payload:', event.payload)
        let payload = JSON.parse(event.payload)
        let res = this.getEmergencyPasswordAgreement()
        logger.info('[mqttService] 查询结果:', JSON.stringify(res))
        return reply(event, res)
    } catch (error) {
        logger.error('[mqttService] getEmergencyPassword error:', error)
        return reply(event, { error: error.message }, CODE.E_100)
    }
}

/**
 * 查询应急开仓密码通用协议格式
 * @returns {object} 查询结果
 */
mqttService.getEmergencyPasswordAgreement = function () {
    let passwords = sqliteService.d1_emergency_password.findAll()
    if (passwords && passwords.length > 0) {
        let password = passwords[0];
        // 转换时间戳为字符串格式
        if (password.createTime) {
            // 尝试将createTime转换为数字
            const createTimeNum = Number(password.createTime);
            if (!isNaN(createTimeNum)) {
                // 检查时间戳是否为毫秒级（大于等于10位）
                if (createTimeNum.toString().length >= 10) {
                    // 已经是毫秒级，转换为秒级
                    password.createTime = timestampToDateString(createTimeNum / 1000);
                } else {
                    // 秒级，直接使用
                    password.createTime = timestampToDateString(createTimeNum);
                }
            }
        }
        if (password.updateTime) {
            // 尝试将updateTime转换为数字
            const updateTimeNum = Number(password.updateTime);
            if (!isNaN(updateTimeNum)) {
                // 检查时间戳是否为毫秒级（大于等于10位）
                if (updateTimeNum.toString().length >= 10) {
                    // 已经是毫秒级，转换为秒级
                    password.updateTime = timestampToDateString(updateTimeNum / 1000);
                } else {
                    // 秒级，直接使用
                    password.updateTime = timestampToDateString(updateTimeNum);
                }
            }
        }
        return password;
    }
    return {};
}


/**
 * 清空应急开仓密码
 * @param {object} event - MQTT事件对象
 */
mqttService.clearEmergencyPassword = function (event) {
    try {
        logger.info('[mqttService] 接收到clearEmergencyPassword命令:', JSON.stringify(event.topic))
        logger.info('[mqttService] 命令payload:', event.payload)
        let ret = sqliteService.d1_emergency_password.deleteAll()
        if (ret == 0) {
            logger.info('[mqttService] clearEmergencyPassword成功')
            return reply(event)
        } else {
            logger.error('[mqttService] clearEmergencyPassword失败:', "sql error ret:" + ret)
            return reply(event, "sql error ret:" + ret, CODE.E_100)
        }
    } catch (error) {
        logger.error('[mqttService] clearEmergencyPassword error:', error)
        return reply(event, { error: error.message }, CODE.E_100)
    }
}


/**
 * 远程控制
 * @param {object} event - MQTT事件对象
 */
mqttService.control = function (event) {
    try {
            logger.info('[mqttService] 接收到control命令:', JSON.stringify(event.topic))
            logger.info('[mqttService] 命令payload:', event.payload)
            let payload = JSON.parse(event.payload)
            let data = payload.payload.data || {}
            switch (data.command) {
                case 0:
                    //重启
                    logger.info('[mqttService] 执行重启命令')
                    reply(event)
                    common.asyncReboot(2)
                    return
                case 1:
                    //远程开门
                    logger.info('[mqttService] 执行远程开门命令')
                    driver.gpio.open()
                    break
                case 4:
                    //重置
                    logger.info('[mqttService] 执行重置命令')
                    common.systemBrief("rm -rf /app/data/config/*")
                    common.systemBrief("rm -rf /app/data/db/*")
                    common.systemBrief("rm -rf /app/data/user/*")
                    common.systemBrief("rm -rf /app/data/user/*")
                    common.systemBrief("rm -rf /vgmj.db")
                    reply(event)
                    common.asyncReboot(2)
                    return
                case 5:
                    //播放语音
                    logger.info('[mqttService] 执行播放语音命令')
                    if (data.extra) {
                        let res = common.systemWithRes(`test -e "/app/code/resource/wav/${data.extra.wav}.wav" && echo "OK" || echo "NO"`, 2)
                        if (res.includes('OK')) {
                            driver.alsa.play(`/app/code/resource/wav/${data.extra.wav}.wav`)
                        }
                    }
                    break
                case 6:
                    // 6：屏幕展示图片
                    // TODO
                    logger.info('[mqttService] 执行屏幕展示图片命令')
                    break
                case 7:
                    // 7：屏幕展示文字
                    // TODO
                    logger.info('[mqttService] 执行屏幕展示文字命令')
                    break
                case 10:
                    logger.info('[mqttService] 执行二维码展示命令')
                    if (!isEmpty(data.extra.qrCodeBase64) && typeof data.extra.qrCodeBase64 == 'string') {
                        //base64转图片保存
                        let src = `/app/code/resource/image/app_qrcode.png`
                        std.ensurePathExists(src)
                        common.base64_2binfile(src, data.extra.qrCodeBase64)
                        logger.info('[mqttService] 二维码保存成功')
                        return reply(event)
                    }
                    break
                default:
                    logger.info('[mqttService] 未知命令:', data.command)
                    break
            }
            logger.info('[mqttService] control命令执行完成')
            return reply(event)
        } catch (error) {
            logger.error('[mqttService] control error:', error)
            return reply(event, { error: error.message }, CODE.E_100)
        }
}

/**
 * 查询配置
 */
mqttService.getConfig = function (event) {
    let payload = JSON.parse(event.payload)
    let data = payload.data
    let res = api.getConfig(data)
    if (typeof res == "string") {
        return reply(event, res, CODE.E_100)
    } else {
        return reply(event, res)
    }
}

/**
 * 修改配置
 */
mqttService.setConfig = function (event) {
    let payload = JSON.parse(event.payload)
    let data = payload.payload && payload.payload.data ? payload.payload.data : payload.data
    let res = api.setConfig(data)
    if (typeof res == "string") {
        return reply(event, res, CODE.E_100)
    } else {
        return reply(event)
    }
}

/**
 * 升级固件
 */
mqttService.upgradeFirmware = function (event) {
    logger.info('[mqttService] 接收到升级固件命令:', JSON.stringify(event.topic))
    let payload = JSON.parse(event.payload)
    let data = payload.payload && payload.payload.data ? payload.payload.data : payload.data
    let res = api.upgradeFirmware(data)
    if (typeof res == "string") {
        return reply(event, res, CODE.E_100)
    } else {
        return reply(event)
    }
}

/**
 * 查询识别记录
 */
mqttService.getRecords = function (event) {
    let payload = JSON.parse(event.payload)
    let data = payload.payload && payload.payload.data ? payload.payload.data : payload.data
    let res = api.getRecords(data, true)
    return reply(event, res)
}


/**
 * 删除记录
 */
mqttService.delRecords = function (event) {
    let payload = JSON.parse(event.payload)
    let data = payload.payload && payload.payload.data ? payload.payload.data : payload.data
    let res = api.delRecords(data)
    if (typeof res == 'string') {
        return reply(event, res, CODE.E_100)
    }
    return reply(event)
}

/**
 * 通行上报回复
 */
mqttService.access_reply = function (event) {
    let payload = JSON.parse(event.payload)
    if (payload.serialNo && payload.code == '000000') {
        let record = sqliteService.d1_pass_record.findAllById(payload.serialNo)
        if (record.length > 0) {
            dxos.systemBrief(`rm -rf ${record[0].code}`)
        }
        sqliteService.d1_pass_record.deleteByid(payload.serialNo)
    }
}

/**
 * 在线验证回复
 */
mqttService.access_online_reply = function (data) {
    driver.sync.response("mqtt.getOnlinecheck", JSON.parse(data.payload))
}

// 设备绑定二维码回复
mqttService.wecom_reply = function (data) {
    let payload = JSON.parse(data.payload)
    data = payload.data
    bus.fire("showQrCode", data)
}

const CODE = {
    // 成功
    S_000: "000000",
    // 未知错误
    E_100: "100000",
    // 设备已被禁用	
    E_101: "100001",
    // 设备正忙，请稍后再试	
    E_102: "100002",
    // 签名检验失败	
    E_103: "100003",
    // 超时错误
    E_104: "100004",
    // 设备离线	
    E_105: "100005",
}
mqttService.CODE = CODE
mqttService.report = function () {
    // 在线上报
    let payloadReply = mqttReply(std.genRandomStr(10), {
        appVersion: config.get("sys.version") || '',
        mac: config.get("sys.mac") || '',
        clientId: dxMap.get("CLIENT").get("CLIENT_ID") || '',
        name: config.get("sys.deviceName") || '',
        type: config.get("net.type") || 1,
        ssid: config.get("net.ssid") || '',
        psk: config.get("net.psk") || '',
        dhcp: config.get("net.dhcp") || 2,
        ip: config.get("net.ip") || '',
        gateway: config.get("net.gateway") || '',
        dns: config.get("net.dns") || '',
        subnetMask: config.get("net.mask") || '',
        netMac: config.get("net.mac") || ''
    }, CODE.S_000)
    driver.mqtt.send("access_device/v2/event/connect", JSON.stringify(payloadReply))

    // 企微绑定状态获取
    if (weComService.isWeCom()) {
        driver.mqtt.send("access_device/v2/event/wecom", JSON.stringify(mqttReply(std.genRandomStr(10), { type: 0 }, CODE.S_000)))
    }
}

// mqtt请求统一回复
function reply(event, data, code) {
    let topic = getReplyTopic(event)
    let reply = JSON.stringify(mqttReply(JSON.parse(event.payload).serialNo, data, isEmpty(code) ? CODE.S_000 : code))
    driver.mqtt.send(topic, reply)
}

/**
 * 获取回复主题
 */
function getReplyTopic(data) {
    return data.topic.replace("/" + config.get("sys.sn"), '') + "_reply";
}

// mqtt回复格式构建
function mqttReply(serialNo, data, code) {
    return {
        serialNo: serialNo,
        uuid: config.get("sys.uuid"),
        sign: '',
        code: code,
        data: data,
        time: Math.floor(Date.parse(new Date()) / 1000)
    }
}
mqttService.mqttReply = mqttReply

/**
 * 时间戳转日期字符串
 * @param {number} timestamp - 时间戳（秒级）
 * @returns {string} 日期字符串，格式：YYYY-MM-DD HH:MM:SS
 */
function timestampToDateString(timestamp) {
    const date = new Date(timestamp * 1000);
    const year = date.getFullYear();
    const month = String(date.getMonth() + 1).padStart(2, '0');
    const day = String(date.getDate()).padStart(2, '0');
    const hours = String(date.getHours()).padStart(2, '0');
    const minutes = String(date.getMinutes()).padStart(2, '0');
    const seconds = String(date.getSeconds()).padStart(2, '0');
    return `${year}-${month}-${day} ${hours}:${minutes}:${seconds}`;
}
mqttService.timestampToDateString = timestampToDateString

// 判空
function isEmpty(value) {
    return value === undefined || value === null || value === ""
}

export default mqttService