@@ -777,7 +777,7 @@ func processLeads(saleLeadsMap map[string]interface{}, sourceMap map[string]map[
batch := gconv.String(saleLeadsMap["groupCode"])
lastTime := gconv.Int64(saleLeadsMap["lastTime"])
dataArr := []map[string]interface{}{}
- endtime := int64(0)
+ endtime := lastTime
saleleadsData, ok := Mgo.Find("saleLeads", map[string]interface{}{"createtime": map[string]interface{}{"$gt": lastTime}}, `{"phone":1,"createtime":1}`, nil, false, -1, -1)
if ok && saleleadsData != nil {
data := FindBatchData(batch)
