From dacf749e3042afc5c964eaf06cd53ed6a32726a0 Mon Sep 17 00:00:00 2001 From: jinfeng.wang <jinfeng.wang@mobvista.com> Date: Thu, 18 Jul 2019 11:26:20 +0800 Subject: [PATCH] fix --- src/main/java/com/mobvista/apptag/utils/GetPackageFromMongo.java | 13 +++++++++---- 1 file changed, 9 insertions(+), 4 deletions(-) diff --git a/src/main/java/com/mobvista/apptag/utils/GetPackageFromMongo.java b/src/main/java/com/mobvista/apptag/utils/GetPackageFromMongo.java index 7b3a214..e1db1e3 100644 --- a/src/main/java/com/mobvista/apptag/utils/GetPackageFromMongo.java +++ b/src/main/java/com/mobvista/apptag/utils/GetPackageFromMongo.java @@ -7,9 +7,8 @@ import com.mongodb.client.model.Filters; import org.apache.commons.lang3.StringUtils; import org.bson.Document; -import java.util.Arrays; -import java.util.HashSet; -import java.util.Set; +import java.text.SimpleDateFormat; +import java.util.*; import java.util.concurrent.TimeUnit; /** @@ -25,6 +24,12 @@ public class GetPackageFromMongo { try { String mongoUrl = "internal-beijing-adServerMongo-virginia-1390640500.us-east-1.elb.amazonaws.com"; + Date date = new Date(); + SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMdd"); + Date dt = sdf.parse(sdf.format(date)); + Calendar rightNow = Calendar.getInstance(); + rightNow.setTime(dt); + rightNow.add(Calendar.DAY_OF_YEAR, -6); // MongoClientOptions.Builder builder = new MongoClientOptions.Builder() MongoClientSettings settings = MongoClientSettings.builder() .retryWrites(true) @@ -48,7 +53,7 @@ public class GetPackageFromMongo { System.out.println("Connect to database successfully"); MongoCollection<Document> collection = mongoDatabase.getCollection("campaign"); - MongoCursor<Document> findIterable = collection.find(Filters.eq("advertiserId", 903)).iterator(); + MongoCursor<Document> findIterable = collection.find(Filters.and(Filters.gt("startTime", rightNow.getTime().getTime() / 1000), Filters.eq("advertiserId", 903))).iterator(); Set<String> set = new HashSet<>(); -- libgit2 0.27.1