package main

import (
	"field_purchasing/config"
	"fmt"
	"jygit.jydev.jianyu360.cn/data_processing/common_utils/log"
	"jygit.jydev.jianyu360.cn/data_processing/common_utils/mongodb"
	"jygit.jydev.jianyu360.cn/data_processing/common_utils/mysqldb"
	"os"
)

var (
	MongoTool *mongodb.MongodbSim
	Mysql     *mysqldb.Mysql
)

// InitLog @Description
// @Author J 2022/7/26 15:30
func InitLog() {
	logcfg := config.Conf.Log

	err := log.InitLog(
		log.Path(logcfg.LogPath),
		log.Level(logcfg.LogLevel),
		log.Compress(logcfg.Compress),
		log.MaxSize(logcfg.MaxSize),
		log.MaxBackups(logcfg.MaxBackups),
		log.MaxAge(logcfg.MaxAge),
		log.Format(logcfg.Format),
	)
	if err != nil {
		fmt.Printf("InitLog failed: %v\n", err)
		os.Exit(1)
	}
}

func InitMgo() {
	MongoTool = &mongodb.MongodbSim{
		MongodbAddr: config.Conf.DB.Mongo.Addr,
		Size:        config.Conf.DB.Mongo.Size,
		DbName:      config.Conf.DB.Mongo.Dbname,
		UserName:    config.Conf.DB.Mongo.User,
		Password:    config.Conf.DB.Mongo.Password,
	}
	MongoTool.InitPool()
}

func InitMysql() {
	dbcfg := config.Conf.DB.Mysql
	Mysql = &mysqldb.Mysql{
		Address:  dbcfg.Addr,
		DBName:   dbcfg.DbnameBasic,
		UserName: dbcfg.User,
		PassWord: dbcfg.Password,
	}
	Mysql.Init()

}

//
//func InitField() {
//	info := Mysql.Find("code_area", nil, "", "", -1, -1)
//	for _, m := range *info {
//		var key string
//		for i, v := range []string{"area", "city", "district"} {
//			if i == 0 && util.ObjToString(m[v]) != "" {
//				key = util.ObjToString(m[v])
//			} else if util.ObjToString(m[v]) != "" {
//				key += "," + util.ObjToString(m[v])
//			}
//		}
//		AreaCode[key] = util.ObjToString(m["code"])
//	}
//	log.Info("InitField", zap.Int("AreaCode", len(AreaCode)))
//}
//
//func InitPoCode() {
//	data_class := Mysql.Find("d_yl_productclass_code", nil, "", "", -1, -1)
//
//	for _, v := range *data_class {
//		name := util.ObjToString(v["name"])
//		code := util.ObjToString(v["code"])
//		pcode := util.ObjToString(v["pcode"])
//		level := util.IntAll(v["level"])
//		info := map[string]string{}
//		for key, value := range PclassCode[pcode] {
//			info[key] = value
//		}
//		new_key := "class_" + fmt.Sprintf("%d", level)
//		info[new_key] = name
//		PclassCode[code] = info
//
//	}
//
//}