jy-data-extract/qyxy_change/qy_foucs/main.go

package main

import (
	"mongodb"
	"qfw/util"
)

var (
	Sysconfig                  map[string]interface{}
	MgoJy, MgoQy               *mongodb.MongodbSim
	JyDb					   string
	CollJy, CollQy, CollSave   string
	LastTime                   int64
	TaskTime                   int64
	ChangeMap                  []map[string]interface{}
)

func init() {
	util.ReadConfig(&Sysconfig)

	focusQy := util.ObjToMap(Sysconfig["qy_focus"])
	JyDb = util.ObjToString((*focusQy)["dbName"])
	MgoJy = &mongodb.MongodbSim{
		MongodbAddr: util.ObjToString((*focusQy)["dbServer"]),
		Size:        util.IntAll((*focusQy)["dbSize"]),
		DbName:      JyDb,
	}
	MgoJy.InitPool()
	qyxy := util.ObjToMap(Sysconfig["qy_change"])
	MgoQy = &mongodb.MongodbSim{
		MongodbAddr: util.ObjToString((*qyxy)["dbServer"]),
		Size:        util.IntAll((*qyxy)["dbSize"]),
		DbName:      util.ObjToString((*qyxy)["dbName"]),
	}
	MgoQy.InitPool()

	CollJy = util.ObjToString((*focusQy)["dbColl"])
	CollQy = util.ObjToString((*qyxy)["dbCollQy"])
	CollSave = util.ObjToString((*qyxy)["dbColl"])
	LastTime = util.Int64All(Sysconfig["lasttime"])
	TaskTime = util.Int64All(Sysconfig["tasktime"])

	ChangeMap = util.ObjArrToMapArr(Sysconfig["changeType"].([]interface{}))
	initChangeMap()
}

func initChangeMap() {
	for _, v := range ChangeMap {
		list := v["change_keyword"].([]interface{})
		var regList []string
		if len(list) > 0 {
			for _, v1 := range list {
				reg := ".*" + util.ObjToString(v1) + ".*"
				regList = append(regList, reg)
			}
			v["change_key_reg"] = regList
		} else {
			v["change_key_reg"] = []string{".*"}
		}
	}
}

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