ClientApps/CN_Gather
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

初始版本提交

Browse Source
This commit is contained in:
hzj
2025-06-27 14:16:42 +08:00
parent b2bb7c3901
commit 072a2b6bfc
1 changed files with 7 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
event_smart/src/main/java/com/njcn/gather/event/transientes/service/impl/LargeScreenCountServiceImpl.java
View File

@@ -334,14 +334,13 @@ public class LargeScreenCountServiceImpl implements LargeScreenCountService {
for(List<Integer> pList: idPartitions){ for(List<Integer> pList: idPartitions){
ew.or(w->w.in(PqsEventdetail::getLineid, pList)); ew.or(w->w.in(PqsEventdetail::getLineid, pList));
} }
}).orderByAsc(PqsEventdetail::getLookFlag) }).orderByDesc(PqsEventdetail::getTimeid);
.orderByDesc(PqsEventdetail::getTimeid);
} else { } else {
queryWrapper.lambda() queryWrapper.lambda()
.between(PqsEventdetail::getTimeid, startTime, endTime) .between(PqsEventdetail::getTimeid, startTime, endTime)
.in(PqsEventdetail::getLineid, deptslineIds) .in(PqsEventdetail::getLineid, deptslineIds)
.orderByAsc(PqsEventdetail::getLookFlag)
.orderByDesc(PqsEventdetail::getTimeid); .orderByDesc(PqsEventdetail::getTimeid);
} }
//查询需要发送短息处理的部门反推监测点 //查询需要发送短息处理的部门反推监测点
@@ -355,8 +354,11 @@ public class LargeScreenCountServiceImpl implements LargeScreenCountService {
return pqsDeptsService.findDeptAndChildren(temp.getDeptsIndex()); return pqsDeptsService.findDeptAndChildren(temp.getDeptsIndex());
}).flatMap(Collection::stream).distinct().collect(Collectors.toList()); }).flatMap(Collection::stream).distinct().collect(Collectors.toList());
//获取对应监测点id //获取对应监测点id
List<PqsDeptsline> noticeLine = pqsDeptslineService.lambdaQuery().in(PqsDeptsline::getDeptsIndex, noticeDept).eq(PqsDeptsline::getSystype, sysTypeZt).list(); if(!CollectionUtils.isEmpty(noticeDept)){
noticeLineIds = deptslines.stream().map(PqsDeptsline::getLineIndex).collect(Collectors.toList()); List<PqsDeptsline> noticeLine = pqsDeptslineService.lambdaQuery().in(PqsDeptsline::getDeptsIndex, noticeDept).eq(PqsDeptsline::getSystype, sysTypeZt).list();
noticeLineIds = noticeLine.stream().map(PqsDeptsline::getLineIndex).collect(Collectors.toList());
}
} }