xiugai

jyinfomatch/src/main.go

@@ -1,6 +1,3 @@
-/**
- *推送服务
- */
 package main
 
 import (

jyinfomatch/src/qyfw/job.go

@@ -59,7 +59,7 @@ func (j *Job) Start(list *[]map[string]interface{}) {
 		count++
 	}
 	j.WaitGroup.Wait()
-	j.Save(nil, "", true)
+	j.Save(nil, j.Appid, true)
 	log.Println("脚本", j.Name, "执行完毕！")
 }
 
@@ -115,6 +115,11 @@ func (j *Job) Save(result *map[string]interface{}, appid string, flag bool) {
 		return
 	}
 	if length >= SaveSize || flag {
+		thisSaveSize := SaveSize
+		if flag {
+			thisSaveSize = len(*j.Results)
+		}
+		log.Println(appid, "save", thisSaveSize)
 		mongodb.SaveBulk(Collection, *j.Results...)
 		j.Results = &[]map[string]interface{}{}
 	}

jyinfomatch/src/qyfw/loadDatas.go

@@ -77,7 +77,7 @@ func initBiddingCache(_id, lastid string, lastTime int64, startTime, endTime int
 	//testquery := `{"terms":{"_id":["596f21935d11e1c7455ddc7f"]}}`
 	//c_query = fmt.Sprintf(FilterQuery, testquery)
 	count := int(elastic.Count(DB, DB, c_query))
-	log.Println("本次推送共查到数据", count, "条")
+	log.Println("本次共查到数据", count, "条")
 	var res []map[string]interface{}
 	if count == 0 {
 		return false, res