ソースを参照

定时任务 winner buyer

wcc 2 年 前
コミット
45e38c66bd
2 ファイル変更4 行追加3 行削除
  1. 2 2
      createEsIndex/buyertask.go
  2. 2 1
      createEsIndex/winnertask.go

+ 2 - 2
createEsIndex/buyertask.go

@@ -29,8 +29,8 @@ func buyerEsTaskOnce() {
 	//区间id
 	q := map[string]interface{}{
 		"_id": map[string]interface{}{
-			//"$gte": mongodb.StringTOBsonId(task_sid),
-			"$lt": mongodb.StringTOBsonId(task_eid),
+			"$gte": mongodb.StringTOBsonId(task_sid),
+			"$lt":  mongodb.StringTOBsonId(task_eid),
 		},
 	}
 	//mongo

+ 2 - 1
createEsIndex/winnertask.go

@@ -27,7 +27,8 @@ func winnerEsTaskOnce() {
 	//区间id
 	q := map[string]interface{}{
 		"_id": map[string]interface{}{
-			"$lt": mongodb.StringTOBsonId(task_eid),
+			"$gte": mongodb.StringTOBsonId(task_sid),
+			"$lt":  mongodb.StringTOBsonId(task_eid),
 		},
 	}
 	//mongo