package com.ruoyi.energymeter.constant;

import java.time.ZoneId;

/**
 * 能耗表（水表/电表/气表）接入模块常量。
 *
 * <p>所有业务日期均按 Asia/Shanghai 计算，与服务器默认时区无关。</p>
 */
public final class EnergyMeterConstants {

    private EnergyMeterConstants() {
    }

    public static final ZoneId ZONE = ZoneId.of("Asia/Shanghai");

    /* ---------------- 能源类型 ---------------- */
    public static final String TYPE_WATER = "WATER";
    public static final String TYPE_ELECTRIC = "ELECTRIC";
    public static final String TYPE_GAS = "GAS";

    /* ---------------- 数据来源 ---------------- */
    /** 第三方接口接入，由定时任务/手动查表落库。 */
    public static final String SOURCE_TYPE_PROVIDER = "PROVIDER";
    /** 手工抄表，由用户在表具台账中录入表码，用量按期差计算。 */
    public static final String SOURCE_TYPE_MANUAL = "MANUAL";
    /** 手工抄表数据在采集表中的来源标识。 */
    public static final String SOURCE_MANUAL = "MANUAL";

    /* ---------------- 指标编码 ---------------- */
    public static final String METRIC_WATER_USAGE = "WATER_USAGE";
    public static final String METRIC_WATER_READING = "WATER_READING";
    public static final String METRIC_ELECTRIC_USAGE = "ELECTRIC_USAGE";
    public static final String METRIC_ELECTRIC_READING = "ELECTRIC_READING";
    public static final String METRIC_ELECTRIC_COST = "ELECTRIC_COST";
    public static final String METRIC_GAS_USAGE = "GAS_USAGE";
    public static final String METRIC_GAS_READING = "GAS_READING";

    /* ---------------- 粒度 ---------------- */
    public static final String GRANULARITY_DAY = "D";
    public static final String GRANULARITY_MONTH = "M";
    public static final String GRANULARITY_YEAR = "Y";
    public static final String GRANULARITY_POINT = "POINT";

    /* ---------------- 单位 ---------------- */
    public static final String UNIT_WATER = "m3";
    public static final String UNIT_ELECTRIC = "kWh";
    public static final String UNIT_GAS = "m3";
    public static final String UNIT_COST = "CNY";

    /* ---------------- 第三方接口标识 ---------------- */
    public static final String SOURCE_GET_USE_WATER = "GetUseWater";
    public static final String SOURCE_GET_WATER_RAW = "GetWaterRawData";
    public static final String SOURCE_FROZEN_ELECTRICITY = "FrozenElectricity";
    public static final String SOURCE_ELECTRIC_QUANTITY = "ElectricQuantity";
    public static final String SOURCE_GAS_USE = "GetGasUseData";
    public static final String SOURCE_GAS_RAW = "GetGasRawData";

    /* ---------------- 绑定与启用 ---------------- */
    public static final String BIND_VERIFIED = "VERIFIED";
    public static final String BIND_INVALID = "INVALID";

    /* ---------------- 批次类型 ---------------- */
    public static final String RUN_SCHEDULED = "SCHEDULED";
    public static final String RUN_MANUAL = "MANUAL";
    public static final String RUN_BACKFILL = "BACKFILL";

    /* ---------------- 批次状态 ---------------- */
    public static final String RUN_PENDING = "PENDING";
    public static final String RUN_RUNNING = "RUNNING";
    public static final String RUN_SUCCESS = "SUCCESS";
    public static final String RUN_PARTIAL = "PARTIAL";
    public static final String RUN_FAILED = "FAILED";

    /* ---------------- 任务状态 ---------------- */
    public static final String TASK_PENDING = "PENDING";
    public static final String TASK_RUNNING = "RUNNING";
    public static final String TASK_SUCCESS = "SUCCESS";
    public static final String TASK_EMPTY = "EMPTY";
    public static final String TASK_RETRY = "RETRY";
    public static final String TASK_FAILED = "FAILED";

    /* ---------------- 错误类别 ---------------- */
    public static final String ERROR_UPSTREAM = "UPSTREAM_ERROR";
    public static final String ERROR_TIMEOUT = "UPSTREAM_TIMEOUT";
    public static final String ERROR_PARSE = "PARSE_ERROR";
    public static final String ERROR_PAGE_INCOMPLETE = "PAGE_INCOMPLETE";
    public static final String ERROR_ADDRESS_MISMATCH = "ADDRESS_MISMATCH";

    /** 自动批次 run_key 前缀。 */
    public static final String AUTO_RUN_KEY_PREFIX = "AUTO:";

    /** 重试间隔（分钟），下标对应第几次失败。 */
    public static final int[] RETRY_DELAY_MINUTES = {1, 5, 15};

    /** 一个设备最多支持的补采跨度（自然日），超出时按分片拆分。 */
    public static final int MAX_RANGE_DAYS = 366 * 3;

    public static boolean isWater(String meterType) {
        return TYPE_WATER.equalsIgnoreCase(meterType);
    }

    public static boolean isElectric(String meterType) {
        return TYPE_ELECTRIC.equalsIgnoreCase(meterType);
    }

    public static boolean isGas(String meterType) {
        return TYPE_GAS.equalsIgnoreCase(meterType);
    }

    public static boolean isManual(String sourceType) {
        return SOURCE_TYPE_MANUAL.equalsIgnoreCase(sourceType);
    }

    /**
     * 是否属于自动采集：第三方接入，或由系统每日自动生成数据的模拟表（如蒸汽表演示设备）。
     *
     * <p>模拟表的 source_type 仍是 MANUAL（不参与第三方查表），但业务上按自动采集展示与统计。</p>
     */
    public static boolean isAutoCollect(String sourceType, Integer simulated) {
        return SOURCE_TYPE_PROVIDER.equalsIgnoreCase(sourceType) || Integer.valueOf(1).equals(simulated);
    }

    public static boolean isSimulated(Integer simulated) {
        return Integer.valueOf(1).equals(simulated);
    }

    /** 规范化能源类型，未知类型返回 null，由调用方抛出业务异常。 */
    public static String canonicalType(String meterType) {
        String type = meterType == null ? null : meterType.trim();
        if (TYPE_WATER.equalsIgnoreCase(type)) {
            return TYPE_WATER;
        }
        if (TYPE_ELECTRIC.equalsIgnoreCase(type)) {
            return TYPE_ELECTRIC;
        }
        if (TYPE_GAS.equalsIgnoreCase(type)) {
            return TYPE_GAS;
        }
        return null;
    }

    public static String typeName(String meterType) {
        if (isWater(meterType)) {
            return "水表";
        }
        if (isGas(meterType)) {
            return "气表";
        }
        if (isElectric(meterType)) {
            return "电表";
        }
        return meterType;
    }

    public static String usageMetric(String meterType) {
        if (isWater(meterType)) {
            return METRIC_WATER_USAGE;
        }
        if (isGas(meterType)) {
            return METRIC_GAS_USAGE;
        }
        return METRIC_ELECTRIC_USAGE;
    }

    public static String readingMetric(String meterType) {
        if (isWater(meterType)) {
            return METRIC_WATER_READING;
        }
        if (isGas(meterType)) {
            return METRIC_GAS_READING;
        }
        return METRIC_ELECTRIC_READING;
    }

    public static String unit(String meterType) {
        if (isWater(meterType)) {
            return UNIT_WATER;
        }
        if (isGas(meterType)) {
            return UNIT_GAS;
        }
        return UNIT_ELECTRIC;
    }

    /** 期间用量的来源标识。 */
    public static String usageSource(String meterType) {
        if (isWater(meterType)) {
            return SOURCE_GET_USE_WATER;
        }
        if (isGas(meterType)) {
            return SOURCE_GAS_USE;
        }
        // 电表用量取 ElectricQuantity 的正向有功电量；FrozenElectricity 的 TotalKwh 可能恒为 null
        return SOURCE_ELECTRIC_QUANTITY;
    }

    /** 时点示值的来源标识。 */
    public static String readingSource(String meterType) {
        if (isWater(meterType)) {
            return SOURCE_GET_WATER_RAW;
        }
        if (isGas(meterType)) {
            return SOURCE_GAS_RAW;
        }
        return SOURCE_FROZEN_ELECTRICITY;
    }
}