package com.ruoyi.business.aidetection.config;

import cn.hutool.json.JSONObject;
import cn.hutool.json.JSONUtil;
import lombok.Data;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Lazy;
import org.springframework.context.annotation.Primary;
import org.springframework.core.annotation.Order;
import org.springframework.stereotype.Component;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import javax.annotation.PostConstruct;
import java.io.BufferedReader;
import java.io.FileReader;
import java.io.IOException;

/**
/**
 * 配置读取类
 * 负责从 JSON 配置文件中读取相关配置信息
 */
@Data
@Component
@Order(1)
public class ReadConfig {

    private static final Logger logger = LoggerFactory.getLogger(ReadConfig.class);

    @Value("${config.file.path}")

    private String configFilePath;

    private String host;
    private String rootDir;
    private String mqttAddress;
    private String mqttUsername;
    private String mqttPassword;
    private String adminHost;
    private String analyzerHost;
    private String mediaHttpHost;
    private String mediaWsHost;
    private String mediaRtspHost;
    private String mediaSecret;
    @PostConstruct
    public void ReadConfig() {
        try {
            // 加载并解析配置文件
            JSONObject configData = loadConfig(configFilePath);

            // 从 JSON 数据中初始化配置
            initializeConfig(configData);

            logger.info("Configuration loaded successfully. Analyzer Host: {}", analyzerHost);
        } catch (Exception e) {
            logger.error("Failed to load configuration file from path: {}", configFilePath, e);
        }
    }

    /**
     * 加载配置文件并解析为 JSON 对象
     *
     * @param filePath 配置文件路径
     * @return 解析后的 JSON 数据
     * @throws IOException 如果文件读取失败
     */
    private JSONObject loadConfig(String filePath) throws IOException {
        StringBuilder content = new StringBuilder();

        // 使用 try-with-resources 确保资源自动关闭
        try (BufferedReader reader = new BufferedReader(new FileReader(filePath))) {
            String line;
            while ((line = reader.readLine()) != null) {
                content.append(line);
            }
        }

        return JSONUtil.parseObj(content.toString());
    }

    /**
     * 从 JSON 数据中初始化配置信息
     *
     * @param configData JSON 配置数据
     */
    private void initializeConfig(JSONObject configData) {
        this.host = configData.getStr("host");
        this.mqttAddress = configData.getStr("mqttAddress");
        this.mqttUsername = configData.getStr("mqttUsername");
        this.mqttPassword = configData.getStr("mqttPassword");
        this.rootDir = configData.getStr("rootDir");

        int adminPort = configData.getInt("adminPort");
        int analyzerPort = configData.getInt("analyzerPort");
        int mediaHttpPort = configData.getInt("mediaHttpPort");
        int mediaRtspPort = configData.getInt("mediaRtspPort");

        this.mediaSecret = configData.getStr("mediaSecret");

        this.adminHost = "http://" + host + ":" + adminPort;
        this.analyzerHost = "http://" + host + ":" + analyzerPort;
        this.mediaHttpHost = "http://" + host + ":" + mediaHttpPort;
        this.mediaWsHost = "ws://" + host + ":" + mediaHttpPort;
        this.mediaRtspHost = "rtsp://" + host + ":" + mediaRtspPort;
    }
}