import dxCommonUtils from '../../dxmodules/dxCommonUtils.js';
import dxOs from "../../dxmodules/dxOs.js";
import log from '../../dxmodules/dxLogger.js'
import qrRule from '../../dxmodules/dxQrRule.js'
import config from '../../dxmodules/dxConfig.js'
import dxMap from '../../dxmodules/dxMap.js'
import ota from "../../dxmodules/dxOta.js";
import sqliteService from "./sqliteService.js";
import driver from '../driver.js';
import utils from '../common/utils/utils.js';
import configConst from '../common/consts/configConst.js';
import configService from './configService.js';
import accessService from './accessService.js';
const codeService = {}

codeService.receiveMsg = function (data) {
    log.info('[codeService] receiveMsg :' + JSON.stringify(data.data))
    let str = dxCommonUtils.codec.utf8HexToStr(dxCommonUtils.codec.arrayBufferToHex(data.data))
    this.code(str)
}

codeService.code = function (data) {
    log.info('[codeService] code :' + data)
    data = qrRule.formatCode(data, sqliteService)
    if (data.type == 'config' || data.code.startsWith("___VF102_CONFIG_V1.1.0___") || data.code.startsWith("___VBAR_ID_ACTIVE_V")) {
        handleSpecialCodes(data);
    } else {
        log.info("access:" + JSON.stringify(data))
        accessService.access(data);
    }
}

function handleSpecialCodes (data) {
    if (data.code.startsWith("___VBAR_ID_ACTIVE_V")) {
        //云证激活
        let activeResute = driver.nfc.eidActive(data.code);
        if (activeResute === 0) {
            log.info("[codeService] code: activeResute " + activeResute + " 云证激活成功")
        } else {
            log.info("[codeService] code: activeResute " + activeResute + " 云证激活失败")
        }
    } else {
        // 配置码
        configCode(data.code);
    }
}

// 配置码处理
function configCode (code) {
    // 1. 校验签名
    if (!checkConfigCode(code)) {
        log.error("[codeService] configCode: 配置码校验失败")
        return
    }
    // 2. 解析JSON
    let json = utils.parseString(code)
    if (Object.keys(json).length <= 0) {
        try {
            json = JSON.parse(code.slice(code.indexOf("{"), code.lastIndexOf("}") + 1))
        } catch (error) {
            log.error(error)
        }
    }
    log.info("[codeService] configCode: 解析配置码 ", JSON.stringify(json))
    // 3. 执行各类操作
    if (json.update_flag === 1) { // ota升级
        return handleOtaUpdate(json);
    }
    // 4. 设备配置相关
    processDeviceConfig(json)
    
}

function processDeviceConfig(json) {
    let configData = {}
    for (const [key, value] of Object.entries(json)) {
        let transKey = configConst.getValueByKey(key);
        if (!transKey) continue;
        const [parentKey, childKey] = transKey.split('.');
        if (!configData[parentKey]) {
            configData[parentKey] = {};
        }
        configData[parentKey][childKey] = json[key];
    }
    const handleConfigResult = (success) => {
        if (success) {
            log.info("[codeService] configCode: 配置成功");
        } else {
            log.error("[codeService] configCode: 配置失败");
        }
    };
    if (Object.keys(configData).length > 0) {
        const result = configService.configVerifyAndSave(configData)
        if (typeof result != 'boolean') {
            log.error(result)
            return
        }
        handleConfigResult(result);
    } else {
        handleConfigResult(false);
    }
}

// ota升级
function handleOtaUpdate (json) {
    const net_map = dxMap.get("NET")
    let map = dxMap.get("UPDATE")
    if (net_map.get("NET_STATUS") != "connected") {
        codeService.showUpdateStatus('failed', "Please check the network")
        return
    }
    if (map.get("updateFlag")) return
    map.put("updateFlag", true)
    try {
        codeService.showUpdateStatus('begin')
        ota.updateHttp(json.update_addr, json.update_md5, 300)
        codeService.showUpdateStatus('success')
        dxOs.asyncReboot(1)
    } catch (error) {
        codeService.showUpdateStatus('failed', error.message);
    } finally {
        map.del("updateFlag")
    }
}

//校验配置码
function checkConfigCode (code) {
    let password = config.get('sysInfo.com_passwd') || '1234567887654321'
    let lastIndex = code.lastIndexOf("--");
    let DELIMITER = "--"
    if (lastIndex < 0) {
        lastIndex = code.lastIndexOf("__");
        DELIMITER = "__"
    }
    // 分隔符未找到
    if (lastIndex === -1) {
        log.error(`Delimiter "${DELIMITER}" not found in code: ${code}`);
        return false;
    }
    const dataPart = code.substring(0, lastIndex);
    const signaturePart = code.substring(lastIndex + DELIMITER.length);
    let expectedSignature
    try {

        expectedSignature = dxCommonUtils.codec.arrayBufferToBase64(dxCommonUtils.codec.hexToArrayBuffer(dxCommonUtils.crypto.hmacMd5(dataPart, password)))
    } catch (error) {
        log.error(error)
        return false
    }
    return expectedSignature == signaturePart;
}

const UPDATE_MESSAGES = {
    begin: {
        en: "Start Upgrading",
        zh: "开始升级"
    },
    success: {
        en: "Upgrade Successfully",
        zh: "升级成功"
    },
    failed: {
        en: (detail) => `Upgrade Failed: ${detail || "Upgrade package download failed"}`,
        zh: (detail) => `升级失败: ${codeService.errorMsgMap[detail] || "下载失败，请检查网址"}`
    }
};

/**
 * 显示升级状态提示
 * @param {string} status - 状态类型: 'begin' | 'success' | 'failed'
 * @param {string} [errorMsg] - 失败时的错误信息（仅 status='failed' 时有效）
 */
codeService.showUpdateStatus = function (status, errorMsg) {
    let defaultErrorMsg = 'Upgrade package download failed';
    if (status !== 'failed') {
        errorMsg = null;
    }
    // 获取当前语言
    const isEn = config.get("base.language") === "EN";
    const langKey = isEn ? 'en' : 'zh';
    // 获取对应状态的消息模板或文本
    const msgConfig = UPDATE_MESSAGES[status];
    if (!msgConfig) {
        return;
    }
    let message;
    if (typeof msgConfig[langKey] === 'function') {
        // 对于 failed，使用函数生成动态消息
        const displayError = errorMsg && errorMsg.includes("Download failed")
            ? defaultErrorMsg
            : errorMsg;
        message = msgConfig[langKey](displayError);
    } else {
        // 其他状态直接取文本
        message = msgConfig[langKey];
    }
};

codeService.errorMsgMap = {
    "The 'url' and 'md5' param should not be null": "“url”和“md5”参数不能为空",
    "The 'size' param should be a number": "“size” 参数应该是一个数字",
    "The upgrade package is too large, and not be enough space on the disk to download it": "升级包过大，磁盘空间不足，无法下载",
    "Download failed, please check the url:": "下载失败，请检查网址",
    "Download failed with wrong md5 value": "下载失败，md5 值错误",
    "Build shell file failed": "构建 shell 文件失败",
    "Upgrade package download failed": "升级包下载失败",
    "Please check the network": "请检查网络"
}

export default codeService