datatools/csrSync/main.go

package main

import (
	"flag"
	"fmt"
	monitor "github.com/tencentcloud/tencentcloud-sdk-go/tencentcloud/asr/v20190614"
	"log"

	"app.yhyue.com/moapp/jybase/common"
	"app.yhyue.com/moapp/jybase/mysql"
	"github.com/robfig/cron"
)

var (
	cfg    = new(Config)
	TiDb   *mysql.Mysql
	mode   = flag.Int("m", 1, "")
	client *monitor.Client
	ch     chan bool
)

func main() {
	flag.Parse()
	common.ReadConfig(&cfg)
	log.Println("cfg ", cfg)
	//
	ch = make(chan bool, cfg.Chan)
	//
	TiDb = &mysql.Mysql{
		Address:      cfg.TiDb.Host + ":" + fmt.Sprint(cfg.TiDb.Port),
		UserName:     cfg.TiDb.User,
		PassWord:     cfg.TiDb.Password,
		DBName:       cfg.TiDb.Database,
		MaxOpenConns: cfg.TiDb.PollSize,
		MaxIdleConns: cfg.TiDb.MaxIdle,
	}
	TiDb.Init()
	if *mode == 1 {
		job()
		a := cron.New()
		a.AddFunc(cfg.CornExp1, func() {
			job()
		})
		a.Start()
		select {}
	}
}