定时任务修改

clueSync/jobutil.go

@@ -1311,14 +1311,13 @@ func rebind() {
 				}
 			}
 		}
-		cfg.AllocationTime = rebindTimeEnd
+		cfg.RebindTime = rebindTimeEnd
 		common.WriteSysConfig(&cfg)
 	}
 	log.Println("重新关注用户处理结束")
 }
 
 // 活跃用户处理
-
 func activeUsers() {
 	log.Println("活跃用户处理开始")
 	//判断节假日

clueSync/main.go

@@ -130,12 +130,13 @@ func main() {
 	//activeUsers() //取关重新关注处理
 	if *mode == 1 {
 		//30分钟一次
-		go p.VarTimeTask.RunInTimeSection("30分钟定时任务", startTime, endTime, db.CornExp1, func(dayFirst bool) {
+		go p.VarTimeTask.RunInTimeLoop("30分钟定时任务", "", "", db.CornExp1, true, true, nil, func() {
 			orders()      //未支付订单
 			messageSync() //聊天记录进线索
 			userbase()    //新绑定手机号进线索
 		})
 		//5分钟一次
+
 		go p.VarTimeTask.RunInTimeSection("5分钟定时任务1", db.CornExp2Start, db.CornExp2End, db.CornExp2, func(dayFirst bool) {
 			users()          //新注册用户进线索
 			saleLeads()      //留资进线索
@@ -162,7 +163,8 @@ func main() {
 		d.Start()
 		// 5分钟一次
 		go ordersClue() //后台订单进线索
-		go p.VarTimeTask.RunInTimeSection("5分钟定时任务2", startTime, endTime, db.CornExp5, func(dayFirst bool) {
+		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()       //后台订单进线索
 			kcSync()           //移交客成
@@ -174,7 +176,8 @@ func main() {
 			rderAcceptance()   //工单生成
 		})
 		//5分钟一次
-		go p.VarTimeTask.RunInTimeSection("5分钟定时任务3", startTime, endTime, db.CornExp6, func(dayFirst bool) {
+		go p.VarTimeTask.RunInTimeLoop("5分钟定时任务3", "", "", db.CornExp6, true, true, nil, func() {
+			//go p.VarTimeTask.RunInTimeSection("5分钟定时任务3", startTime, endTime, db.CornExp6, func(dayFirst bool) {
 			subscribeAddSync() //订阅增量
 			rderAcceptance()   //工单生成
 		})