datatools/clueSync/config.go

package main

import (
	"log"

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

type (
	Config struct {
		LastOrderId        int     `json:"lastOrderId"`
		LastOrderClueId    string  `json:"lastOrderClueId"`
		LastUserId         string  `json:"lastUserId"`
		LastXcxUserId      string  `json:"lastXcxUserId"`
		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"`
		BigSaleTime        int64   `json:"bigSaleTime"`
		BigOrderTime       string  `json:"bigOrderTime"`
		MarketSaleTime     int64   `json:"marketSaleTime"`
		AllocationTime     string  `json:"allocationTime"`
		AllocationRatio    float64 `json:"allocationRatio"`
	}
	DB struct {
		CornExp1      int64  `json:"cornexp1"`
		CornExp2      int64  `json:"cornexp2"`
		CornExp2Start string `json:"cornexp2Strat"`
		CornExp2End   string `json:"cornexp2End"`
		CornExp3      string `json:"cornexp3"`
		CornExp4      string `json:"cornexp4"`
		CornExp5      int64  `json:"cornexp5"`
		CornExp6      int64  `json:"cornexp6"`
		CornExp7      string `json:"cornexp7"`
		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"`
		ProductArr     []string          `json:"productArr"`
		RedisServer    string            `json:"redisServer"`
		MarketSaleMail string            `json:"marketSaleMail"`
		AllocationCap  int64             `json:"allocationCap"`
		WarningValue   int64             `json:"warningValue"`
		CornMail       string            `json:"corn_mail"`
		RegTimes       int               `json:"regTimes"`
		NameToMail     map[string]string `json:"nameToMail"`
		ThawDay        int64             `json:"thawDay"`
		LoopType       int64             `json:"loopType"`
	}
)

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"
	}
}