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

package main

import (
	"mongodb"
	"qfw/util"
	"regexp"
)

var (
	Sysconfig        map[string]interface{}
	MgoMix, Mgo      *mongodb.MongodbSim
	dbname           string
	CollQy, CollSave string
	lastId           int64
	ChangeMap        []map[string]interface{}

	timeReg, _ = regexp.Compile(`^[\d]{4}-[\d]{1,2}-[\d]{1,2}`)
)

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

	dbname := util.ObjToString(Sysconfig["dbName"])
	MgoMix = &mongodb.MongodbSim{
		MongodbAddr: util.ObjToString(Sysconfig["dbServer"]),
		Size:        util.IntAll(Sysconfig["dbSize"]),
		DbName:      dbname,
		UserName:    util.ObjToString(Sysconfig["uname"]),
		Password:    util.ObjToString(Sysconfig["upwd"]),
	}
	MgoMix.InitPool()
	Mgo = &mongodb.MongodbSim{
		MongodbAddr: "172.17.4.181:27001", // 172.17.4.181:27001
		Size:        10,
		DbName:      "mixdata",
	}
	Mgo.InitPool()

	CollQy = Sysconfig["coll_qy"].(string)
	CollSave = Sysconfig["coll_change"].(string)
	lastId = util.Int64All(Sysconfig["lastId"])

	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 updateMethod()

	//go TimeTask()
	go GetData()
	//go TaskAll()
	//ch := make(chan bool, 1)
	//<-ch

	//var id string
	//flag.StringVar(&id, "id", "", "公司id")
	//flag.Parse()
	//if id == "" {
	//	flag.PrintDefaults()
	//	log.Println("参数错误.")
	//} else {
	//	taskInfo(id)
	//}

}