From 47e3087067abd35e6337c011f96d2338c0bb1aae Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期四, 25 七月 2024 13:39:31 +0800
Subject: [PATCH] 优化自动化代码
---
src/main/java/org/yeshi/utils/mongo/MongodbBaseDao.java | 16 ++++++++++++++++
1 files changed, 16 insertions(+), 0 deletions(-)
diff --git a/src/main/java/org/yeshi/utils/mongo/MongodbBaseDao.java b/src/main/java/org/yeshi/utils/mongo/MongodbBaseDao.java
index 5226547..8a78a72 100644
--- a/src/main/java/org/yeshi/utils/mongo/MongodbBaseDao.java
+++ b/src/main/java/org/yeshi/utils/mongo/MongodbBaseDao.java
@@ -1,6 +1,9 @@
package org.yeshi.utils.mongo;
import org.springframework.data.mongodb.core.MongoTemplate;
+import org.springframework.data.mongodb.core.aggregation.Aggregation;
+import org.springframework.data.mongodb.core.aggregation.AggregationOperation;
+import org.springframework.data.mongodb.core.aggregation.AggregationResults;
import org.springframework.data.mongodb.core.query.Criteria;
import org.springframework.data.mongodb.core.query.Query;
import org.springframework.data.mongodb.core.query.Update;
@@ -82,6 +85,19 @@
return (T) mongoTemplate.findById(id, this.getEntityClass());
}
+
+ /**
+ * 鑱氬悎鏌ヨ
+ *
+ * @param opts
+ * @param output
+ * @return
+ */
+ public AggregationResults aggregate(List<? extends AggregationOperation> opts, Class output) {
+ Aggregation aggregation = Aggregation.newAggregation(opts);
+ return mongoTemplate.aggregate(aggregation, this.getEntityClass(), output);
+ }
+
/**
* 閫氳繃涓婚敭鍒犻櫎
*
--
Gitblit v1.8.0