退回公海自动加入任务车优化

clueSync/autoTask.go

@@ -78,10 +78,11 @@ func autoTask() {
 				args2 := []interface{}{clueId}
 				//获取跟进内容
 				// sql1 := `select COUNT(1) FROM dwd_f_crm_trail_content WHERE clue_id =?;`
-				sql2 := `SELECT COUNT(1) FROM dwd_f_crm_trail_content WHERE clue_id =? `
+				sql2 := `SELECT COUNT(1) FROM dwd_f_crm_trail_content WHERE clue_id = ? and position_id = ?`
 				if intime != "" {
 					sql2 += ` and createtime > ?`
 					args2 = append(args2, intime)
+					args2 = append(args2, position_id)
 				}
 				//保留未跟进线索
 				// if c1, c2 := TiDb.CountBySql(sql1, clueId), TiDb.CountBySql(sql2, args2...); (c1 != 0 && c2 > 0) || out_task_status == 1 {

clueSync/job.go

@@ -410,6 +410,7 @@ func UpdateClue(data map[string]interface{}, saleData []map[string]interface{},
 		}
 		seaUpdateData["seatNumber"] = seatNumber
 		seaUpdateData["position_id"] = positionId
+		seaUpdateData["comeintime"] = nowTime
 		insertSeaData["seatNumber"] = seatNumber
 		insertSeaData["position_id"] = positionId
 		for _, v := range saleData {

clueSync/main.go

@@ -75,19 +75,19 @@ func main() {
 		})
 		a.Start()
 		// 新注册用户 5分钟一次
-		users()
+		// users()
 		b := cron.New()
 		b.AddFunc(cfg.CornExp2, func() {
 			users()
+			saleLeads()
 		})
 		b.Start()
 		// 留资 5分钟一次
-		saleLeads()
-		c := cron.New()
-		c.AddFunc(cfg.CornExp3, func() {
-			saleLeads()
-		})
-		c.Start()
+		// c := cron.New()
+		// c.AddFunc(cfg.CornExp3, func() {
+		// 	saleLeads()
+		// })
+		// c.Start()
 		// 用户标签一天一次
 		// tagAllSync()
 		d := cron.New()

telemarketingEtl/entity/dwd_f_crm_open_sea.go

@@ -566,10 +566,11 @@ func ReturnOpenSea() {
 
 				args2 := []interface{}{id}
 				//获取跟进内容
-				sql2 := `SELECT COUNT(1) FROM dwd_f_crm_trail_content WHERE clue_id =? `
+				sql2 := `SELECT COUNT(1) FROM dwd_f_crm_trail_content WHERE clue_id = ? and position_id = ?`
 				if intime != "" {
 					sql2 += ` and createtime > ?`
 					args2 = append(args2, intime)
+					args2 = append(args2, position_id)
 				}
 				//保留未跟进线索
 				if config.JianyuSubjectdb.CountBySql(sql2, args2...) > 0 {