|
|
@@ -11,7 +11,7 @@ import (
|
|
|
"flag"
|
|
|
"fmt"
|
|
|
"github.com/ClickHouse/clickhouse-go/v2/lib/driver"
|
|
|
- "github.com/robfig/cron"
|
|
|
+ "github.com/robfig/cron/v3"
|
|
|
"log"
|
|
|
)
|
|
|
|
|
|
@@ -168,7 +168,7 @@ func main() {
|
|
|
//30分钟一次
|
|
|
go p.VarTimeTask.RunInTimeLoop("30分钟定时任务", "", "", db.CornExp1, true, true, nil, func() {
|
|
|
orders() //未支付订单
|
|
|
- messageSync() //聊天记录进线索
|
|
|
+ messageSync() //在线客服聊天记录进线索
|
|
|
userbase() //新绑定手机号进线索
|
|
|
customerButton()
|
|
|
})
|
|
|
@@ -206,14 +206,14 @@ func main() {
|
|
|
go p.VarTimeTask.RunInTimeLoop("5分钟定时任务2", "", "", db.CornExp5, true, true, nil, func() {
|
|
|
//go p.VarTimeTask.RunInTimeSection("5分钟定时任务2", startTime, endTime, db.CornExp5, func(dayFirst bool) {
|
|
|
everythingSync() //渠道
|
|
|
- ordersClue() //后台订单进线索
|
|
|
+ ordersClue() //后台已支付订单进线索
|
|
|
kcSync() //移交客成
|
|
|
kcAuto() //客成自动加入任务车
|
|
|
tagAddSync() //用户标签增量
|
|
|
autoExitSea() //自动退海
|
|
|
Thaw() //自动解冻处理
|
|
|
subscribeAddSync() //订阅增量
|
|
|
- CustomerChange()
|
|
|
+ CustomerChange() //客成人员变更
|
|
|
})
|
|
|
//5分钟一次
|
|
|
go p.VarTimeTask.RunInTimeLoop("5分钟定时任务3", "", "", db.CornExp6, true, true, nil, func() {
|
