zhangxinlei1996 2 жил өмнө
parent
commit
c6ee809df6

+ 3 - 3
telemarketingEtl/entity/dwd_f_crm_open_sea.go

@@ -466,14 +466,14 @@ func ReturnOpenSea() {
 				args2 := []interface{}{id}
 				args2 := []interface{}{id}
 				//获取跟进内容
 				//获取跟进内容
 				sql1 := `SELECT COUNT(1) FROM dwd_f_crm_trail_content WHERE clue_id =?;`
 				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 =? `
 				if intime != "" {
 				if intime != "" {
-					sql2 += ` AND createtime < ?`
+					sql2 += ` and createtime > ?`
 					args2 = append(args2, intime)
 					args2 = append(args2, intime)
 				}
 				}
 				//保留未跟进线索
 				//保留未跟进线索
 				if c1, c2 := config.JianyuSubjectdb.CountBySql(sql1, id),
 				if c1, c2 := config.JianyuSubjectdb.CountBySql(sql1, id),
-					config.JianyuSubjectdb.CountBySql(sql2, args2...); c1 != 0 && c2 <= 0 {
+					config.JianyuSubjectdb.CountBySql(sql2, args2...); c1 != 0 && c2 > 0 {
 					log.Println("不满足线索过滤", id)
 					log.Println("不满足线索过滤", id)
 					continue
 					continue
 				}
 				}