package config

import (
	"bytes"
	"encoding/json"
	"fmt"
	"io/ioutil"
	"os"
)

type Config struct {
	WebPort        string `json:"web_port"`        // 本地web服务绑定接口
	SqlAddr        string `json:"sql_addr"`        // 数据库ip地址, 不加端口号, 默认使用1433端口
	SqlDBName      string `json:"sql_db_name"`     // 数据库名称
	SqlUsername    string `json:"sql_username"`    // 数据库用户
	SqlPassword    string `json:"sql_password"`    // 数据库密码
	NsqServer      string `json:"nsq_server"`      // nsq TCP服务端地址
	NsqWebApi      string `json:"nsq_webapi"`      // nsq HTTP接口地址
	OrderTopic     string `json:"order_topic"`     // 订单上报的topic
	BomTopic       string `json:"bom_topic"`       // bom上报的topic
	BomQueryTopic  string `json:"bom_query_topic"` // bom上报的topic
	BomChildTopic  string `json:"bom_child_topic"` // bom子项上报的topic
	InventoryTopic string `json:"inventory_topic"` // 库存上报的topic
	SqlQueryTopic  string `json:"query_topic"`     // 金蝶查询接口的topic
	SqlReplyTopic  string `json:"reply_topic"`     // 金蝶响应查询接口的topic
	CSTWebApi      string `json:"cst_webapi"`      // 生产任务单提交地址
	CSTQueryTopic  string `json:"cst_query_topic"` // 提交生产任务单主题
	CSTReplyTopic  string `json:"cst_reply_topic"` // 响应生产任务单主题
	SyncInterval   int    `json:"interval"`        // 同步的时间间隔, 单位/秒
}

const configPath = "config.json"

var Options Config

func DefaultConfig() {
	Options.WebPort = "10210"
	Options.SqlAddr = "127.0.0.1"
	Options.SqlDBName = "dbname"
	Options.SqlUsername = "sa"
	Options.SqlPassword = "123456"
	Options.NsqServer = "fai365.com:4150"
	Options.NsqWebApi = "http://121.31.232.83:9080/api/nsq/pub?topic=your_topic"
	Options.OrderTopic = "aps.factory.erp.seorder"
	Options.BomTopic = "aps.factory.erp.icBom"
	Options.BomChildTopic = "aps.factory.erp.icBomChild"
	Options.BomQueryTopic = "aps.factory.erp.icBomQuery"
	Options.InventoryTopic = "aps.factory.erp.inventory"
	Options.SqlQueryTopic = "aps.factory.erp.k3resource"
	Options.SqlReplyTopic = "aps.factory.erp.k3reply"
	Options.CSTQueryTopic = "aps.factory.erp.cstApply"
	Options.CSTReplyTopic = "aps.factory.erp.cstReply"
	Options.SyncInterval = 60
}

func Load() {
	if !pathExists(configPath) {
		DefaultConfig()
		SaveConfig()
	} else {
		file, _ := os.Open(configPath)
		defer file.Close()

		fd := json.NewDecoder(file)

		fd.Decode(&Options)
	}
}

func SaveConfig() error {
	b, err := json.Marshal(Options)
	if err == nil {
		var out bytes.Buffer

		err = json.Indent(&out, b, "", "    ")
		if err == nil {
			err = ioutil.WriteFile(configPath, out.Bytes(), 0644)
		}
	}

	return err
}

func pathExists(path string) bool {
	_, err := os.Stat(path)
	if err == nil {
		return true
	}

	fmt.Printf("%v", err.Error())
	return false
}