定时任务调整

clueSync/kc.go

@@ -289,7 +289,7 @@ func kcJob(data map[string]interface{}) int {
 }
 
 func cAutoDraw(entId int) (positionId int64, name string) {
-	query := `SELECT name,position_id FROM dwd_d_crm_department_level_succbi WHERE bi_pcode = (SELECT bi_code FROM dwd_d_crm_department_level_succbi WHERE name = "客户成功组") and resign = 0`
+	query := `SELECT name,position_id FROM dwd_d_crm_department_level_succbi WHERE bi_pcode = (SELECT bi_code FROM dwd_d_crm_department_level_succbi WHERE name = "客户成功组" and resign=0) and resign = 0`
 	data := TiDb.SelectBySql(query)
 	if data != nil && len(*data) > 0 {
 		if entId > 0 {

clueSync/main.go

@@ -144,21 +144,20 @@ func main() {
 			bigCustomer()    //大客户线索
 			marketCustomer() //市场部线索
 			rebind()         //取关重新关注处理
-			activeUsers()    //活跃用户处理
 		})
 		//每天8点30
 		c := cron.New()
 		c.AddFunc(db.CornExp3, func() {
-			users()     //新注册用户进线索
-			saleLeads() //留资进线索
+			users()       //新注册用户进线索
+			saleLeads()   //留资进线索
+			activeUsers() //活跃用户处理
 		})
 		c.Start()
 		// 一天一次
 		// tagAllSync()
 		d := cron.New()
 		d.AddFunc(db.CornExp4, func() {
-			tagAllSync()  //用户标签
-			activeUsers() //活跃用户处理
+			tagAllSync() //用户标签
 		})
 		d.Start()
 		// 5分钟一次