jy-data-extract/monitor/main.go

package main

import (
	"mongodb"
	"qfw/util"
	es "qfw/util/elastic"
)

var (
	Sysconfig                    map[string]interface{}
	Mgo                          *mongodb.MongodbSim
	Es                           *es.Elastic
	TaskTime					 int
	Index, Itype				 string
	BiddingBackSize				 int64		//biding_back	数据量
	LastStockId					 string		//上次统计存量id
	LastStockSize				 int64		//上次统计存量数据
	LastAddSize				 	 int64		//上次统计增量数据
	api, to						 string
)

func init() {
	util.ReadConfig(&Sysconfig)
	bidding := Sysconfig["bidding"].(map[string]interface{})
	Mgo = &mongodb.MongodbSim{
		MongodbAddr: bidding["mgodb"].(string),
		Size:        util.IntAllDef(bidding["dbsize"], 2),
		DbName:      bidding["dbname"].(string),
		UserName:    bidding["uname"].(string),
		Password:    bidding["upwd"].(string),
	}
	Mgo.InitPool()
	econf := Sysconfig["elastic"].(map[string]interface{})
	Es = &es.Elastic{
		S_esurl: econf["addr"].(string),
		I_size:  util.IntAllDef(econf["pool"], 12),
	}
	Es.InitElasticSize()
	TaskTime = util.IntAll(Sysconfig["tasktime"])
	Index = util.ObjToString(Sysconfig["index"])
	Itype = util.ObjToString(Sysconfig["itype"])
	count := Sysconfig["count"].(map[string]interface{})
	BiddingBackSize = util.Int64All(count["bidding_back_size"])
	LastStockId = util.ObjToString(count["last_stock_id"])
	LastStockSize = util.Int64All(count["last_stock_size"])
	LastAddSize = util.Int64All(count["last_add_size"])
	jkmail := Sysconfig["jkmail"].(map[string]interface{})
	to = util.ObjToString(jkmail["to"])
	api = util.ObjToString(jkmail["api"])
}

func main() {
	go TimeTask()
	ch := make(chan bool, 1)
	<-ch
}