From 17055fd8d36504b79a5def28f5d4b4740faf012d Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期五, 25 三月 2022 13:47:35 +0800
Subject: [PATCH] TDMQ工具集成
---
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