data_field_dispose/data_mgo_to_tidb_project/main.go

package main

import (
	"data_mgo_to_tidb_project/config"

	"github.com/robfig/cron"

	"jygit.jydev.jianyu360.cn/data_processing/common_utils/log"
	"jygit.jydev.jianyu360.cn/data_processing/common_utils/udp"
)

var (
	UdpClient udp.UdpClient
)

func init() {
	config.Init("./common.toml")
	InitLog()
	InitMgo()
	InitMysql()
	InitField()
	InitCode()
	InitRedis()
	InitNsq()
	log.Info("init success")
}

func main() {
	//存量
	// Projectset("", "")

	// return
	//增量
	cr := cron.New()
	cr.AddFunc(config.Conf.Info.Crontab, func() {
		if gteid, ltid := GetCurTimePiInfo(); gteid != "" && ltid != "" {
			Projectset(gteid, ltid)
		}
	})
	cr.Start()

	select {}
}