|
|
@@ -9,10 +9,8 @@ import (
|
|
|
"bp.jydev.jianyu360.cn/BaseService/pushpkg/p"
|
|
|
"flag"
|
|
|
"fmt"
|
|
|
- "github.com/gogf/gf/util/gconv"
|
|
|
"github.com/robfig/cron"
|
|
|
"log"
|
|
|
- "time"
|
|
|
)
|
|
|
|
|
|
var (
|
|
|
@@ -125,7 +123,6 @@ func main() {
|
|
|
orders() //未支付订单
|
|
|
messageSync() //聊天记录进线索
|
|
|
userbase() //新绑定手机号进线索
|
|
|
- time.Sleep(gconv.Duration(db.CornExp1) * time.Minute)
|
|
|
})
|
|
|
//5分钟一次
|
|
|
go p.VarTimeTask.RunInTimeSection("5分钟定时任务", db.CornExp2Start, db.CornExp2End, db.CornExp2, func(dayFirst bool) {
|
|
|
@@ -166,7 +163,6 @@ func main() {
|
|
|
go p.VarTimeTask.RunInTimeSection("5分钟定时任务", startTime, endTime, db.CornExp6, func(dayFirst bool) {
|
|
|
subscribeAddSync() //订阅增量
|
|
|
rderAcceptance() //工单生成
|
|
|
- time.Sleep(gconv.Duration(db.CornExp6) * time.Minute)
|
|
|
})
|
|
|
//自动进入任务车 1天一次
|
|
|
g := cron.New()
|
WH01243