定时任务修改

clueSync/everything.go

@@ -368,6 +368,7 @@ func bigCustomer() {
 	}
 	abhList := []map[string]interface{}{}
 	data := FindBatchData("dk")
+	bigSaleTime = gconv.Int64("1729505486")
 	saleleadsData, ok := Mgo.Find("saleLeads", map[string]interface{}{"createtime": map[string]interface{}{"$gte": bigSaleTime}}, `{"phone":1,"createtime":1}`, nil, false, -1, -1)
 	if ok && saleleadsData != nil && len(*saleleadsData) > 0 {
 		for _, v := range *saleleadsData {
@@ -426,6 +427,9 @@ func bigCustomer() {
 						"interest":         interest,
 						"data_requirement": data_requirement,
 					})
+					if gconv.Int64(v["createtime"]) > bigSaleTime {
+						bigSaleTime = gconv.Int64(v["createtime"])
+					}
 					continue
 				}
 				dataArr = append(dataArr, map[string]interface{}{
@@ -526,6 +530,7 @@ func bigCustomer() {
 					"unpayorderinfo": unpayorderinfo,
 					"payorderinfo":   payorderinfo, //增加客户需求
 				})
+				bigOrderTime = gconv.Time(gconv.String(v["create_time"])).Format(date.Date_Full_Layout)
 				continue
 			}
 			dataArr = append(dataArr, map[string]interface{}{
@@ -726,6 +731,9 @@ func AdvisoryCommittee() {
 						"branch":           v["branch"],
 						"email":            email,
 					})
+					if gconv.Int64(v["createtime"]) > advisoryCommitteeTime {
+						advisoryCommitteeTime = gconv.Int64(v["createtime"])
+					}
 					continue
 				}
 				dataArr = append(dataArr, map[string]interface{}{
@@ -743,9 +751,7 @@ func AdvisoryCommittee() {
 				})
 
 			}
-			if gconv.Int64(v["createtime"]) > advisoryCommitteeTime {
-				advisoryCommitteeTime = gconv.Int64(v["createtime"])
-			}
+
 		}
 		keyContent := fmt.Sprintf("data_%s_%s", time.Now().Format("2006-01-02"), "zx")
 		redis.Put("newother", keyContent, data, 86400)
@@ -899,6 +905,9 @@ func marketCustomer() {
 						"branch":           v["branch"],
 						"s_sourceid":       s_sourceid,
 					})
+					if gconv.Int64(v["createtime"]) > marketSaleTime {
+						marketSaleTime = gconv.Int64(v["createtime"])
+					}
 					continue
 				}
 				dataArr = append(dataArr, map[string]interface{}{