去重处理

clueSync/everything.go

@@ -815,7 +815,7 @@ func processLead(v map[string]interface{}, sourceMap map[string]map[string]inter
 	if userData == nil || isUserInBlackList(userData) {
 		return nil, lastTime
 	}
-	key := fmt.Sprintf("%s_%s_%s", sourceMap[sources], phone, common.ObjToString(v["interest"]))
+	key := fmt.Sprintf("%s_%s_%s", sources, phone, common.ObjToString(v["interest"]))
 	if _, exists := data[key]; exists {
 		return nil, lastTime
 	}