|
|
@@ -10,7 +10,6 @@ import (
|
|
|
"bp.jydev.jianyu360.cn/BaseService/pushpkg/p"
|
|
|
"flag"
|
|
|
"fmt"
|
|
|
- "github.com/robfig/cron"
|
|
|
"log"
|
|
|
)
|
|
|
|
|
|
@@ -146,16 +145,13 @@ func main() {
|
|
|
MaxIdleConns: db.DataAnalysis.MaxIdle,
|
|
|
}
|
|
|
DataAnalysisService.Init()
|
|
|
- //Es = elastic.NewEs(db.Es.Version, db.Es.Address, db.Es.DbSize, db.Es.UserName, db.Es.Password)
|
|
|
+ Es = elastic.NewEs(db.Es.Version, db.Es.Address, db.Es.DbSize, db.Es.UserName, db.Es.Password)
|
|
|
redis.InitRedis(db.RedisServer)
|
|
|
Mgo = mongodb.NewMgo(db.Mgo.Address, db.Mgo.DbName, db.Mgo.DbSize)
|
|
|
MgoLog = mongodb.NewMgoWithUser(db.MgoLog.Address, db.MgoLog.DbName, db.MgoLog.User, db.MgoLog.Password, db.MgoLog.DbSize)
|
|
|
MgoQyxy = mongodb.NewMgoWithUser(db.MgoQyxy.Address, db.MgoQyxy.DbName, db.MgoQyxy.User, db.MgoQyxy.Password, db.MgoQyxy.DbSize)
|
|
|
- //InitArea()
|
|
|
- //InitProduct(db.ProductArr)
|
|
|
- //refundAuto()
|
|
|
- //kcSync() //移交客成
|
|
|
- //ordersClue()
|
|
|
+ InitArea()
|
|
|
+ InitProduct(db.ProductArr)
|
|
|
if *mode == 1 {
|
|
|
go ordersClue() //后台订单进线索
|
|
|
//一秒钟一次
|
WH01243