package config

import (
	"encoding/json"
	"fmt"
	"log"
	"os"
)

func LoadConfigJson() map[string]string {
	//加载目录下所有文件
	allConfig := make(map[string]string)

	files, err := os.ReadDir("configFiles")
	if err != nil {
		log.Fatal(err)
	}

	for _, file := range files {
		log.Printf("加载配置文件:%s", file.Name())
		if file.IsDir() {
			log.Printf("非文件[%s]跳过", file.Name())
			continue
		}
		// 读取mqtt配置
		configMqttBytes, _ := os.ReadFile(fmt.Sprintf("configFiles/%s", file.Name()))
		consumer := new(Consumer)
		// 将 JSON 格式的数据解析到结构体中
		err = json.Unmarshal(configMqttBytes, &consumer)
		if err != nil {
			log.Printf("读取配置文件[%s]异常 err=%v", consumer.Consumer, err.Error())
			continue
		}
		allConfig[consumer.Consumer] = string(configMqttBytes)
		//// 读取sensor配置
		//configSensorBytes, _ := os.ReadFile("configSensor.json")
		//// 将 JSON 格式的数据解析到结构体中
		//err2 := json.Unmarshal(configSensorBytes, &userConfig.SensorConfig)
		//if err2 != nil {
		//	log.Printf("读取mqtt配置异常 err=%v", err2.Error())
		//}
		//allConfig[]
	}
	return allConfig
}
func LoadConfigJsonByPath(path string) map[string]string {
	//加载目录下所有文件
	allConfig := make(map[string]string)

	files, err := os.ReadDir(path)
	if err != nil {
		log.Fatal(err)
	}

	for _, file := range files {
		log.Printf("加载配置文件:%s", file.Name())
		if file.IsDir() {
			log.Printf("非文件[%s]跳过", file.Name())
			continue
		}
		// 读取mqtt配置
		filePath := fmt.Sprintf("%s/%s", path, file.Name())

		configMqttBytes, _ := os.ReadFile(filePath)
		consumer := new(Consumer)
		// 将 JSON 格式的数据解析到结构体中
		err = json.Unmarshal(configMqttBytes, &consumer)
		if err != nil {
			log.Printf("读取配置文件[%s]异常 err=%v", consumer.Consumer, err.Error())
			continue
		}
		allConfig[consumer.Consumer] = string(configMqttBytes)
		//// 读取sensor配置
		//configSensorBytes, _ := os.ReadFile("configSensor.json")
		//// 将 JSON 格式的数据解析到结构体中
		//err2 := json.Unmarshal(configSensorBytes, &userConfig.SensorConfig)
		//if err2 != nil {
		//	log.Printf("读取mqtt配置异常 err=%v", err2.Error())
		//}
		//allConfig[]
	}
	return allConfig
}