datatools/clueSync/main.go

package main

import (
	"flag"
	"fmt"
	"github.com/robfig/cron"
	"log"

	"app.yhyue.com/moapp/jybase/common"
	elastic "app.yhyue.com/moapp/jybase/es"
	"app.yhyue.com/moapp/jybase/mongodb"
	"app.yhyue.com/moapp/jybase/mysql"

	"app.yhyue.com/moapp/jybase/redis"
)

var (
	cfg          = new(Config)
	Mysql        *mysql.Mysql
	TiDb         *mysql.Mysql
	TiDbData     *mysql.Mysql
	TiDbPower    *mysql.Mysql
	ThirdParty   *mysql.Mysql
	Jyactivities *mysql.Mysql
	Base         *mysql.Mysql
	Es           elastic.Es
	Mgo          *mongodb.MongodbSim
	MgoLog       *mongodb.MongodbSim
	MgoQyxy      *mongodb.MongodbSim
	mode         = flag.Int("m", 1, "")
)

func main() {
	flag.Parse()
	common.ReadConfig(&cfg)
	log.Println("cfg ", cfg)
	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()
	TiDbData = &mysql.Mysql{
		Address:      cfg.TiDbData.Host + ":" + fmt.Sprint(cfg.TiDbData.Port),
		UserName:     cfg.TiDbData.User,
		PassWord:     cfg.TiDbData.Password,
		DBName:       cfg.TiDbData.Database,
		MaxOpenConns: cfg.TiDbData.PollSize,
		MaxIdleConns: cfg.TiDbData.MaxIdle,
	}
	TiDbData.Init()
	TiDbPower = &mysql.Mysql{
		Address:      cfg.TiDbPower.Host + ":" + fmt.Sprint(cfg.TiDbPower.Port),
		UserName:     cfg.TiDbPower.User,
		PassWord:     cfg.TiDbPower.Password,
		DBName:       cfg.TiDbPower.Database,
		MaxOpenConns: cfg.TiDbPower.PollSize,
		MaxIdleConns: cfg.TiDbPower.MaxIdle,
	}
	TiDbPower.Init()
	ThirdParty = &mysql.Mysql{
		Address:      cfg.ThirdParty.Host + ":" + fmt.Sprint(cfg.ThirdParty.Port),
		UserName:     cfg.ThirdParty.User,
		PassWord:     cfg.ThirdParty.Password,
		DBName:       cfg.ThirdParty.Database,
		MaxOpenConns: cfg.ThirdParty.PollSize,
		MaxIdleConns: cfg.ThirdParty.MaxIdle,
	}
	ThirdParty.Init()
	Jyactivities = &mysql.Mysql{
		Address:      cfg.Jyactivities.Host + ":" + fmt.Sprint(cfg.Jyactivities.Port),
		UserName:     cfg.Jyactivities.User,
		PassWord:     cfg.Jyactivities.Password,
		DBName:       cfg.Jyactivities.Database,
		MaxOpenConns: cfg.Jyactivities.PollSize,
		MaxIdleConns: cfg.Jyactivities.MaxIdle,
	}
	Jyactivities.Init()
	Mysql = &mysql.Mysql{
		Address:      cfg.Mysql.Host + ":" + fmt.Sprint(cfg.Mysql.Port),
		UserName:     cfg.Mysql.User,
		PassWord:     cfg.Mysql.Password,
		DBName:       cfg.Mysql.Database,
		MaxOpenConns: cfg.Mysql.PollSize,
		MaxIdleConns: cfg.Mysql.MaxIdle,
	}
	Mysql.Init()
	Base = &mysql.Mysql{
		Address:      cfg.BaseService.Host + ":" + fmt.Sprint(cfg.BaseService.Port),
		UserName:     cfg.BaseService.User,
		PassWord:     cfg.BaseService.Password,
		DBName:       cfg.BaseService.Database,
		MaxOpenConns: cfg.BaseService.PollSize,
		MaxIdleConns: cfg.BaseService.MaxIdle,
	}
	Base.Init()
	Es = elastic.NewEs(cfg.Es.Version, cfg.Es.Address, cfg.Es.DbSize, cfg.Es.UserName, cfg.Es.Password)
	redis.InitRedis(cfg.RedisServer)
	Mgo = mongodb.NewMgo(cfg.Mgo.Address, cfg.Mgo.DbName, cfg.Mgo.DbSize)
	MgoLog = mongodb.NewMgoWithUser(cfg.MgoLog.Address, cfg.MgoLog.DbName, cfg.MgoLog.User, cfg.MgoLog.Password, cfg.MgoLog.DbSize)
	MgoQyxy = mongodb.NewMgoWithUser(cfg.MgoQyxy.Address, cfg.MgoQyxy.DbName, cfg.MgoQyxy.User, cfg.MgoQyxy.Password, cfg.MgoQyxy.DbSize)
	InitArea()

	/*//自动释放处理1
	//UpperLimitAutoExitSea(cfg.AllocationCap)
	//订单成线索处理
	//ordersClue() //后台订单进线索
	//客成移交失败
	//refundAuto()
	//自动分配1
	//saleLeads()
	//解冻处理
	Thaw()
	//userbase()*/
	if *mode == 1 {
		//30分钟一次
		a := cron.New()
		a.AddFunc(cfg.CornExp1, func() {
			orders()      //未支付订单
			messageSync() //聊天记录进线索
			userbase()    //新绑定手机号进线索
		})
		a.Start()
		//5分钟一次
		b := cron.New()
		b.AddFunc(cfg.CornExp2, func() {
			users()     //新注册用户进线索
			saleLeads() //留资进线索
			eventReg()  //渠道
		})
		b.Start()
		//每天8点30
		c := cron.New()
		c.AddFunc(cfg.CornExp3, func() {
			bigCustomer() //大客户线索
			users()       //新注册用户进线索
			saleLeads()   //留资进线索
		})
		c.Start()
		// 一天一次
		// tagAllSync()
		d := cron.New()
		d.AddFunc(cfg.CornExp4, func() {
			tagAllSync() //用户标签
		})
		d.Start()
		// 5分钟一次
		go ordersClue() //后台订单进线索
		e := cron.New()
		e.AddFunc(cfg.CornExp5, func() {
			go everythingSync() //渠道
			go ordersClue()     //后台订单进线索
			go kcSync()         //移交客成
			go kcAuto()         //客成自动加入任务车
			go tagAddSync()     //用户标签增量
			go autoExitSea()    //自动退海
			go Thaw()           //自动解冻处理
		})
		e.Start()
		//5分钟一次
		f := cron.New()
		f.AddFunc(cfg.CornExp6, func() {
			subscribeAddSync() //订阅增量
		})
		f.Start()
		//自动进入任务车 1天一次
		g := cron.New()
		g.AddFunc(cfg.CornExp7, func() {
			readClue()   //读取中间表进线索
			refundAuto() //客成移交销售
			autoTask()   //超时未跟进加入任务车
			autoTasks()  //按照下次跟进时间提前一天加入任务车
			UpperLimitAutoExitSea(cfg.AllocationCap)
		})
		g.Start()
		h := cron.New()
		h.AddFunc(cfg.CornMail, func() {
			WarningPerl() // 个人
			WarningDm()   // 部门
		})
		h.Start()
		select {}
	} else {
		refundAutoHistory()
	}
}