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"`
		CornMail           string `json:"corn_mail"`
		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"`
		LastReadClueTime   string `json:"lastReadClueTime"`
		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"`
		WorderOrder 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:"workOrder"`
		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"`
		AllocationCap   int64             `json:"allocationCap"`
		WarningValue    int64             `json:"warningValue"`
		NameToMail      map[string]string `json:"nameToMail"`
		ThawDay         int64             `json:"thawDay"`
		ProductArr      []string          `json:"productArr"`
		LoopType        int64             `json:"loopType"`
		BigSaleTime     int64             `json:"bigSaleTime"`
		BigOrderTime    string            `json:"bigOrderTime"`
		MarketSaleTime  int64             `json:"marketSaleTime"`
		MarketSaleMail  string            `json:"marketSaleMail"`
		AllocationTime  string            `json:"allocationTime"`
		AllocationRatio float64           `json:"allocationRatio"`
	}
)

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

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"])
		}
	}
}
func InitProduct(product []string) {
	for _, v := range product {
		ProductMap[v] = "dk"
	}
}