Skip to content
切换导航条
切换导航条
当前项目
正在载入...
登录
孙克
/
smf-core
转到一个项目
切换导航栏
切换导航栏固定状态
项目
群组
代码片段
帮助
项目
活动
版本库
流水线
图表
问题
0
合并请求
0
维基
网络
创建新的问题
作业
提交
问题看板
文件
提交
网络
比较
分支
标签
Commit d1d25e7a
由
LN
编写于
2025-04-22 13:41:01 +0800
浏览文件
选项
浏览文件
标签
下载
电子邮件补丁
差异文件
工单出库修改。
1 个父辈
face64b8
隐藏空白字符变更
内嵌
并排
正在显示
1 个修改的文件
包含
22 行增加
和
2 行删除
src/main/java/com/neotel/smfcore/core/order/service/dao/impl/LiteOrderDaoImpl.java
src/main/java/com/neotel/smfcore/core/order/service/dao/impl/LiteOrderDaoImpl.java
查看文件 @
d1d25e7
package
com
.
neotel
.
smfcore
.
core
.
order
.
service
.
dao
.
impl
;
package
com
.
neotel
.
smfcore
.
core
.
order
.
service
.
dao
.
impl
;
import
cn.hutool.core.util.ObjectUtil
;
import
com.neotel.smfcore.common.base.AbstractBaseDao
;
import
com.neotel.smfcore.common.base.AbstractBaseDao
;
import
com.neotel.smfcore.core.order.service.dao.ILiteOrderDao
;
import
com.neotel.smfcore.core.order.service.dao.ILiteOrderDao
;
import
com.neotel.smfcore.core.order.service.po.LiteOrder
;
import
com.neotel.smfcore.core.order.service.po.LiteOrder
;
import
lombok.Data
;
import
org.springframework.data.mongodb.core.aggregation.Aggregation
;
import
org.springframework.data.mongodb.core.aggregation.Aggregation
;
import
org.springframework.data.mongodb.core.aggregation.AggregationResults
;
import
org.springframework.data.mongodb.core.aggregation.AggregationResults
;
import
org.springframework.data.mongodb.core.query.Criteria
;
import
org.springframework.data.mongodb.core.query.Criteria
;
import
org.springframework.stereotype.Service
;
import
org.springframework.stereotype.Service
;
import
java.io.Serializable
;
import
java.util.ArrayList
;
import
java.util.List
;
import
java.util.List
;
@Service
@Service
...
@@ -24,8 +28,24 @@ public class LiteOrderDaoImpl extends AbstractBaseDao implements ILiteOrderDao {
...
@@ -24,8 +28,24 @@ public class LiteOrderDaoImpl extends AbstractBaseDao implements ILiteOrderDao {
Aggregation
.
match
(
criteria
),
Aggregation
.
match
(
criteria
),
Aggregation
.
group
(
"line"
)
Aggregation
.
group
(
"line"
)
);
);
AggregationResults
<
String
>
results
=
getMongoTemplate
().
aggregate
(
agg
,
getEntityClass
(),
String
.
class
);
AggregationResults
<
LineInfo
>
results
=
getMongoTemplate
().
aggregate
(
agg
,
getEntityClass
(),
LineInfo
.
class
);
return
results
.
getMappedResults
();
List
<
LineInfo
>
selList
=
results
.
getMappedResults
();
List
<
String
>
result
=
new
ArrayList
<>();
for
(
LineInfo
lineInfo
:
selList
)
{
if
(
ObjectUtil
.
isEmpty
(
lineInfo
.
_id
))
{
continue
;
}
result
.
add
(
lineInfo
.
_id
);
}
return
result
;
}
}
@Data
private
class
LineInfo
implements
Serializable
{
private
String
_id
;
}
}
}
编写
预览
支持
Markdown
格式
附加文件
你添加了
0
人
到此讨论。请谨慎行事。
Finish editing this message first!
Cancel
请
注册
或
登录
后发表评论