datatools/clueSync/config.go

package main

import (
	"log"

	"app.yhyue.com/moapp/jybase/common"
)

type (
	Config struct {
		CornExp1           string `json:"cornexp1"`
		CornExp2           string `json:"cornexp2"`
		CornExp3           string `json:"cornexp3"`
		CornExp4           string `json:"cornexp4"`
		CornExp5           string `json:"cornexp5"`
		CornExp6           string `json:"cornexp6"`
		CornExp7           string `json:"cornexp7"`
		LastOrderId        int    `json:"lastOrderId"`
		LastOrderClueId    string `json:"lastOrderClueId"`
		LastUserId         string `json:"lastUserId"`
		LastId             string `json:"lastId"`
		LastOrderTime      string `json:"lastOrderTime"`
		LastUserTime       string `json:"lastUserTime"`
		LastSubscribeId    string `json:"lastSubscribeId"`
		LastMessageTime    string `json:"lastMessageTime"`
		LastkcTime         string `json:"lastkcTime"`
		LastEverythingTime string `json:"lastEverythingTime"`
		LastEventRegTime   string `json:"lastEventRegTime"`
		XlsxNum            string `json:"xlsxNum"`
		CountLimit         int64  `json:"countLimit"`
		RegTimes           int    `json:"regTimes"`
		RedisServer        string `json:"redisServer"`
		TiDb               struct {
			Host        string `json:"host"`
			Port        int    `json:"port"`
			Database    string `json:"database"`
			User        string `json:"user"`
			Password    string `json:"password"`
			PollSize    int    `json:"poolsize"`
			MaxIdle     int    `json:"maxidle"`
			MaxLeftTime int    `json:"maxleft"`
		} `json:"tiDb"`
		TiDbData struct {
			Host        string `json:"host"`
			Port        int    `json:"port"`
			Database    string `json:"database"`
			User        string `json:"user"`
			Password    string `json:"password"`
			PollSize    int    `json:"poolsize"`
			MaxIdle     int    `json:"maxidle"`
			MaxLeftTime int    `json:"maxleft"`
		} `json:"tiDbData"`
		TiDbPower struct {
			Host        string `json:"host"`
			Port        int    `json:"port"`
			Database    string `json:"database"`
			User        string `json:"user"`
			Password    string `json:"password"`
			PollSize    int    `json:"poolsize"`
			MaxIdle     int    `json:"maxidle"`
			MaxLeftTime int    `json:"maxleft"`
		} `json:"tiDbPower"`
		BaseService struct {
			Host        string `json:"host"`
			Port        int    `json:"port"`
			Database    string `json:"database"`
			User        string `json:"user"`
			Password    string `json:"password"`
			PollSize    int    `json:"poolsize"`
			MaxIdle     int    `json:"maxidle"`
			MaxLeftTime int    `json:"maxleft"`
		} `json:"baseService"`
		ThirdParty struct {
			Host        string `json:"host"`
			Port        int    `json:"port"`
			Database    string `json:"database"`
			User        string `json:"user"`
			Password    string `json:"password"`
			PollSize    int    `json:"poolsize"`
			MaxIdle     int    `json:"maxidle"`
			MaxLeftTime int    `json:"maxleft"`
		} `json:"thirdParty"`
		Jyactivities struct {
			Host        string `json:"host"`
			Port        int    `json:"port"`
			Database    string `json:"database"`
			User        string `json:"user"`
			Password    string `json:"password"`
			PollSize    int    `json:"poolsize"`
			MaxIdle     int    `json:"maxidle"`
			MaxLeftTime int    `json:"maxleft"`
		} `json:"jyactivities"`
		Mysql struct {
			Host        string `json:"host"`
			Port        int    `json:"port"`
			Database    string `json:"database"`
			User        string `json:"user"`
			Password    string `json:"password"`
			PollSize    int    `json:"poolsize"`
			MaxIdle     int    `json:"maxidle"`
			MaxLeftTime int    `json:"maxleft"`
		} `json:"mysql"`
		Mgo struct {
			Address string `json:"address"`
			DbName  string `json:"dbName"`
			DbSize  int    `json:"dbSize"`
		} `json:"mgo"`
		MgoLog struct {
			Address  string `json:"address"`
			DbName   string `json:"dbName"`
			DbSize   int    `json:"dbSize"`
			User     string `json:"user"`
			Password string `json:"password"`
		} `json:"mgoLog"`
		MgoQyxy struct {
			Address  string `json:"address"`
			DbName   string `json:"dbName"`
			DbSize   int    `json:"dbSize"`
			User     string `json:"user"`
			Password string `json:"password"`
		} `json:"mgoQyxy"`
		Es struct {
			Address  string `json:"address"`
			DbSize   int    `json:"dbSize"`
			Version  string `json:"version"`
			UserName string `json:"user	Name"`
			Password string `json:"password"`
		} `json:"es"`
	}
)

var AreaCode = map[string]string{}
var CodeArea = map[string]string{}
var CodeTrail = map[string]string{}
var DateMap = map[string]int{}

func InitArea() {
	info := TiDb.Find("d_area_code", nil, "", "", -1, -1)
	if info != nil && len(*info) > 0 {
		for _, m := range *info {
			AreaCode[common.ObjToString(m["name"])] = common.ObjToString(m["code"])
			CodeArea[common.ObjToString(m["code"])] = common.ObjToString(m["name"])
		}
	}
	log.Println("AreaCodeLen ", len(AreaCode))
	log.Println("CodeAreaLen ", len(CodeArea))
	trailData := TiDb.Find("dwd_d_crm_trailstatus_code", nil, "", "", -1, -1)
	if trailData != nil && len(*trailData) > 0 {
		for _, m := range *trailData {
			CodeTrail[common.ObjToString(m["code"])] = common.ObjToString(m["name"])
		}
	}
	holidayRecords := TiDb.Find("holiday_records", nil, "", "", -1, -1)
	if holidayRecords != nil && len(*holidayRecords) > 0 {
		for _, m := range *holidayRecords {
			DateMap[common.ObjToString(m["date"])] = common.IntAll(m["change"])
		}
	}
}