|
|
@@ -102,9 +102,10 @@ func main() {
|
|
|
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()
|
|
|
+
|
|
|
go kcSync() //移交客成
|
|
|
go refundAuto() //客成移交销售
|
|
|
+ go UpperLimitAutoExitSea(cfg.AllocationCap)
|
|
|
if *mode == 1 {
|
|
|
//30分钟一次
|
|
|
a := cron.New()
|
|
|
@@ -163,7 +164,7 @@ func main() {
|
|
|
refundAuto() //客成移交销售
|
|
|
autoTask() //超时未跟进加入任务车
|
|
|
autoTasks() //按照下次跟进时间提前一天加入任务车
|
|
|
- UpperLimitAutoExitSea(cfg.AllocationCap)
|
|
|
+
|
|
|
})
|
|
|
g.Start()
|
|
|
|
|
|
@@ -179,6 +180,7 @@ func main() {
|
|
|
log.Println("部门邮件告警查询开始")
|
|
|
WarningDm() // 部门
|
|
|
log.Println("个人/部门邮件告警查询结束")
|
|
|
+ UpperLimitAutoExitSea(cfg.AllocationCap)
|
|
|
})
|
|
|
h.Start()
|
|
|
select {}
|
WH01243