MongoDB 聚合查询 - 时间范围、服务类型和天数过滤 - 常规

{"$addFields":{"days":{"$ceil":{"$divide":[{" $subtract":[back, front] },1000 * 60 * 60 * 24]}}}}},{"$match":{"trace_inbound.trace_time":{"$gte":start,"$lte":end},"service_type":service_type}},{"$match":{"sinoex_no":{"$regex":"SE"},"days":day}},{"$sort":{"_id":1}},{"$skip":1},{"$limit":10},{"$project":{"_id":0,"eawbsyscode":"$eawb_syscode","eawbprintcode":"$sinoex_no","eawbreference":"$tracking_no","fcinbound":"$trace_inbound.trace_time","fcoutbound":"$trace_outbound.trace_time","ass":"$trace_ass.trace_time","adc":"$trace_ata.trace_time","roe":"$trace_a_scan.trace_time","delivery":"$trace_delivery_success.trace_time","eawbservicetype":"$service_type","eawbsocode":"$so_code","eawbpostcode":"$dest_post_code"}}] import com.mongodb.client.MongoClients;import com.mongodb.client.MongoCursor;import com.mongodb.client.MongoClient;import com.mongodb.client.MongoDatabase;import com.mongodb.client.MongoCollection;import org.bson.Document;import java.util.Arrays;import java.util.Date;public class Main {public static void main(String[] args) {MongoClient mongoClient = MongoClients.create("mongodb://localhost:27017");MongoDatabase database = mongoClient.getDatabase("your_database_name");MongoCollection collection = database.getCollection("ceos_order");Date start = new Date("2023-06-1T00:00:00.000+08:00");Date end = new Date("2023-06-8T00:00:00.000+08:00");String serviceType = "DISTRIBUTOR_KOREA_SEA";String front = "$trace_inbound.trace_time";String back = "$trace_delivery_success.trace_time";int day = 3;Document addFields = new Document("$addFields", new Document("days",new Document("$ceil", new Document("$divide", Arrays.asList(new Document("$subtract", Arrays.asList(back, front)),1000 * 60 * 60 * 24)))));Document match1 = new Document("$match", new Document("trace_inbound.trace_time",new Document("$gte", start).append("$lte", end)).append("service_type", serviceType));Document match2 = new Document("$match", new Document("sinoex_no",new Document("$regex", "SE")).append("days", day));Document sort = new Document("$sort", new Document("_id", 1));Document skip = new Document("$skip", 1);Document limit = new Document("$limit", 10);Document project = new Document("$project", new Document("_id", 0).append("eawbsyscode", "$eawb_syscode").append("eawbprintcode", "$sinoex_no").append("eawbreference", "$tracking_no").append("fcinbound", "$trace_inbound.trace_time").append("fcoutbound", "$trace_outbound.trace_time").append("ass", "$trace_ass.trace_time").append("adc", "$trace_ata.trace_time").append("roe", "$trace_a_scan.trace_time").append("delivery", "$trace_delivery_success.trace_time").append("eawbservicetype", "$service_type").append("eawbsocode", "$so_code").append("eawbpostcode", "$dest_post_code"));MongoCursor cursor = collection.aggregate(Arrays.asList(addFields, match1, match2, sort, skip, limit, project)).iterator();while (cursor.hasNext()) {Document document = cursor.next();System.out.println(document.toJson());}mongoClient.close();