|
|
@@ -112,17 +112,11 @@ func main() {
|
|
|
}
|
|
|
Base.Init()
|
|
|
BiService = &mysql.Mysql{
|
|
|
-
|
|
|
- Address: db.BiService.Host + ":" + fmt.Sprint(db.BiService.Port),
|
|
|
-
|
|
|
- UserName: db.BiService.User,
|
|
|
-
|
|
|
- PassWord: db.BiService.Password,
|
|
|
-
|
|
|
- DBName: db.BiService.Database,
|
|
|
-
|
|
|
+ Address: db.BiService.Host + ":" + fmt.Sprint(db.BiService.Port),
|
|
|
+ UserName: db.BiService.User,
|
|
|
+ PassWord: db.BiService.Password,
|
|
|
+ DBName: db.BiService.Database,
|
|
|
MaxOpenConns: db.BiService.PollSize,
|
|
|
-
|
|
|
MaxIdleConns: db.BiService.MaxIdle,
|
|
|
}
|
|
|
BiService.Init()
|
|
|
@@ -133,7 +127,7 @@ func main() {
|
|
|
MgoQyxy = mongodb.NewMgoWithUser(db.MgoQyxy.Address, db.MgoQyxy.DbName, db.MgoQyxy.User, db.MgoQyxy.Password, db.MgoQyxy.DbSize)
|
|
|
InitArea()
|
|
|
InitProduct(db.ProductArr)
|
|
|
- activeUsers() //取关重新关注处理
|
|
|
+ //activeUsers() //取关重新关注处理
|
|
|
if *mode == 1 {
|
|
|
//30分钟一次
|
|
|
go p.VarTimeTask.RunInTimeSection("30分钟定时任务", startTime, endTime, db.CornExp1, func(dayFirst bool) {
|
|
|
@@ -149,6 +143,7 @@ func main() {
|
|
|
bigCustomer() //大客户线索
|
|
|
marketCustomer() //市场部线索
|
|
|
rebind() //取关重新关注处理
|
|
|
+ activeUsers() //活跃用户处理
|
|
|
})
|
|
|
//每天8点30
|
|
|
c := cron.New()
|
WH01243