|
|
@@ -3,6 +3,7 @@ package main
|
|
|
import (
|
|
|
"app.yhyue.com/moapp/jybase/common"
|
|
|
elastic "app.yhyue.com/moapp/jybase/es"
|
|
|
+ "app.yhyue.com/moapp/jybase/mail"
|
|
|
"app.yhyue.com/moapp/jybase/mongodb"
|
|
|
"app.yhyue.com/moapp/jybase/mysql"
|
|
|
"app.yhyue.com/moapp/jybase/redis"
|
|
|
@@ -33,6 +34,7 @@ var (
|
|
|
MgoQyxy *mongodb.MongodbSim
|
|
|
mode = flag.Int("m", 1, "")
|
|
|
startTime, endTime = "00:00", "23:59"
|
|
|
+ Gmail mail.GmailAuth
|
|
|
)
|
|
|
|
|
|
func main() {
|
|
|
@@ -41,6 +43,12 @@ func main() {
|
|
|
log.Println("cfg ", cfg)
|
|
|
common.ReadConfig("./db.json", &db)
|
|
|
log.Println("db ", db)
|
|
|
+ Gmail = mail.GmailAuth{
|
|
|
+ SmtpHost: db.Mail.SmtpHost,
|
|
|
+ SmtpPort: db.Mail.SmtpPort,
|
|
|
+ User: db.Mail.User,
|
|
|
+ Pwd: db.Mail.Pwd,
|
|
|
+ }
|
|
|
TiDb = &mysql.Mysql{
|
|
|
Address: db.TiDb.Host + ":" + fmt.Sprint(db.TiDb.Port),
|
|
|
UserName: db.TiDb.User,
|
|
|
@@ -145,8 +153,9 @@ func main() {
|
|
|
MgoQyxy = mongodb.NewMgoWithUser(db.MgoQyxy.Address, db.MgoQyxy.DbName, db.MgoQyxy.User, db.MgoQyxy.Password, db.MgoQyxy.DbSize)
|
|
|
InitArea()
|
|
|
InitProduct(db.ProductArr)
|
|
|
- //kcSync()
|
|
|
- //refundAuto() //客成移交销售
|
|
|
+ //kcSync() //移交客成
|
|
|
+ //refundAuto()
|
|
|
+
|
|
|
if *mode == 1 {
|
|
|
go ordersClue() //后台订单进线索
|
|
|
//一秒钟一次
|
|
|
@@ -161,6 +170,7 @@ func main() {
|
|
|
})
|
|
|
//5分钟一次
|
|
|
go p.VarTimeTask.RunInTimeSection("5分钟定时任务1", db.CornExp2Start, db.CornExp2End, db.CornExp2, func(dayFirst bool) {
|
|
|
+
|
|
|
users() //新注册用户进线索
|
|
|
saleLeads() //留资进线索
|
|
|
eventReg() //渠道
|
|
|
@@ -171,6 +181,7 @@ func main() {
|
|
|
rebind() //取关重新关注处理
|
|
|
activeUsers() //活跃用户处理
|
|
|
inviteUser() //邀请用户
|
|
|
+ nextYearActivity() //开年活动
|
|
|
})
|
|
|
//每天8点30
|
|
|
c := cron.New()
|
|
|
@@ -214,6 +225,7 @@ func main() {
|
|
|
autoTask() //超时未跟进加入任务车
|
|
|
autoTasks() //按照下次跟进时间提前一天加入任务车
|
|
|
ClueToDxTask()
|
|
|
+ CustomerChange()
|
|
|
})
|
|
|
g.Start()
|
|
|
log.Println("个人邮件告警查询开始")
|
WH01243