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"`
		AdvisoryCommitteeTime   int64   `json:"advisoryCommitteeTime"`
		SelectionDepartmentTime int64   `json:"selectionDepartmentTime"`
		AllocationTime          string  `json:"allocationTime"`
		AllocationRatio         float64 `json:"allocationRatio"`
		ActiveTime              string  `json:"activeTime"`
		RebindTime              string  `json:"rebindTime"`
		InviteTime              string  `json:"inviteTime"`
	}
	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"`
		CornExp8      int64  `json:"cornexp8"`
		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"`
		BiService 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:"biService"`
		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"`
		DebrisProduct struct {
			Host     string `json:"host"`
			Port     int    `json:"port"`
			Database string `json:"database"`
			User     string `json:"user"`
			Password string `json:"password"`
		} `json:"debrisProduct"`
		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"`
		DataAnalysis 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:"dataAnalysis"`
		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"`
		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"`
		Sourceid        string            `json:"sourceid"`
		AbhEmail        string            `json:"abhEmail"`
		AfEmail         string            `json:"afEmail"`
		NewRegistration int64             `json:"newRegistration"`
		OperationEmail  []string          `json:"operationEmail"`
	}
)

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