diff --git a/event_smart/src/main/java/com/njcn/gather/event/transientes/pojo/vo/UserLedgerStatisticVO.java b/event_smart/src/main/java/com/njcn/gather/event/transientes/pojo/vo/UserLedgerStatisticVO.java index 9957dde5..3d73a65b 100644 --- a/event_smart/src/main/java/com/njcn/gather/event/transientes/pojo/vo/UserLedgerStatisticVO.java +++ b/event_smart/src/main/java/com/njcn/gather/event/transientes/pojo/vo/UserLedgerStatisticVO.java @@ -31,6 +31,9 @@ public class UserLedgerStatisticVO { @Data public static class Inner{ + + private String customId; + private String name; private String code; diff --git a/event_smart/src/main/java/com/njcn/gather/event/transientes/security/MyUserDetailsService.java b/event_smart/src/main/java/com/njcn/gather/event/transientes/security/MyUserDetailsService.java index fcb001f6..ff6eb0b5 100644 --- a/event_smart/src/main/java/com/njcn/gather/event/transientes/security/MyUserDetailsService.java +++ b/event_smart/src/main/java/com/njcn/gather/event/transientes/security/MyUserDetailsService.java @@ -37,6 +37,10 @@ public class MyUserDetailsService implements UserDetailsService { public MyUserDetails loadUserByUsername(String username) throws UsernameNotFoundException { + if(username.equals("system_event")){ + return new MyUserDetails("12345678910","system_event", "@#001njcnpqs","10001", + new ArrayList<>()); + } if(redisUtil.hasKey("event_smart_"+username)){ diff --git a/event_smart/src/main/java/com/njcn/gather/event/transientes/service/impl/EventRightServiceImpl.java b/event_smart/src/main/java/com/njcn/gather/event/transientes/service/impl/EventRightServiceImpl.java index 37c2ab1a..4861ef45 100644 --- a/event_smart/src/main/java/com/njcn/gather/event/transientes/service/impl/EventRightServiceImpl.java +++ b/event_smart/src/main/java/com/njcn/gather/event/transientes/service/impl/EventRightServiceImpl.java @@ -157,6 +157,7 @@ public class EventRightServiceImpl implements EventRightService { Page result = new Page<>(PageFactory.getPageNum(param),PageFactory.getPageSize(param)); List deptLineIds = commGeneralService.getLineIdsByRedis(param.getDeptId()); + //获取用户监测点关系符合部门监测点的 List assList = pqUserLineAssMapper.selectList(new LambdaQueryWrapper().in(PqUserLineAssPO::getLineIndex,deptLineIds)); List userIds = assList.stream().map(PqUserLineAssPO::getUserIndex).distinct().collect(Collectors.toList()); @@ -170,10 +171,12 @@ public class EventRightServiceImpl implements EventRightService { //对象大类不为空 lambdaQueryWrapper.eq(PqUserLedgerPO::getSmallObjType,param.getSmallObjType()); } + //获取符合条件的用户 List pqUserLedgerPOList = pqUserLedgerMapper.selectList(lambdaQueryWrapper); Map pqMap = pqUserLedgerPOList.stream().collect(Collectors.toMap(PqUserLedgerPO::getId,Function.identity())); List pUserIds = pqUserLedgerPOList.stream().map(PqUserLedgerPO::getId).collect(Collectors.toList()); - List lineUseList = assList.stream().filter(it->pUserIds.contains(it.getUserIndex())).map(PqUserLineAssPO::getLineIndex).distinct().collect(Collectors.toList()); + List assListLast = assList.stream().filter(it->pUserIds.contains(it.getUserIndex())).collect(Collectors.toList()); + List lineUseList = assListLast.stream().map(PqUserLineAssPO::getLineIndex).distinct().collect(Collectors.toList()); //查询时间段的暂降事件 LambdaQueryWrapper eventQuery = new LambdaQueryWrapper<>(); @@ -199,18 +202,20 @@ public class EventRightServiceImpl implements EventRightService { List ids = temResultList.stream().map(PqsEventdetail::getLineid).distinct().collect(Collectors.toList()); List dtoList = pqLineService.getBaseLineInfo(ids); Map lineMap = dtoList.stream().collect(Collectors.toMap(LedgerBaseInfoDTO::getLineId,Function.identity())); - Map> temMap = assList.stream().filter(it->ids.contains(it.getLineIndex())).collect(Collectors.groupingBy(PqUserLineAssPO::getLineIndex,Collectors.mapping(PqUserLineAssPO::getUserIndex,Collectors.toList()))); + Map> temMap = assListLast.stream().filter(it->ids.contains(it.getLineIndex())).collect(Collectors.groupingBy(PqUserLineAssPO::getLineIndex,Collectors.mapping(PqUserLineAssPO::getUserIndex,Collectors.toList()))); List resultList = new ArrayList<>(); for(PqsEventdetail pqsEventdetail : temResultList){ EventDetailVO eventDetailVO = new EventDetailVO(); BeanUtil.copyProperties(pqsEventdetail,eventDetailVO); List userTemIds = temMap.get(pqsEventdetail.getLineid()); - String objName = userTemIds.stream().peek(it->pqMap.get(it).getCustomerName()).collect(Collectors.joining(StrUtil.COMMA)); + String objName = userTemIds.stream().map(it->pqMap.get(it).getCustomerName()).collect(Collectors.joining(StrUtil.COMMA)); eventDetailVO.setObjName(objName); LedgerBaseInfoDTO dto = lineMap.get(pqsEventdetail.getLineid()); eventDetailVO.setBdname(dto.getStationName()); eventDetailVO.setLineid(dto.getLineId()); + eventDetailVO.setPointname(dto.getLineName()); + eventDetailVO.setEventdetail_index(pqsEventdetail.getEventdetailIndex()); resultList.add(eventDetailVO); } result.setTotal(page.getTotal()); @@ -244,6 +249,7 @@ public class EventRightServiceImpl implements EventRightService { if(CollUtil.isEmpty(eventList)){ poList.forEach(item->{ UserLedgerStatisticVO.Inner inner = new UserLedgerStatisticVO.Inner(); + inner.setCustomId(item.getId()); inner.setName(item.getCustomerName()); inner.setCount(0); result.add(inner); @@ -254,6 +260,7 @@ public class EventRightServiceImpl implements EventRightService { Map> assMap = assPOList.stream().collect(Collectors.groupingBy(PqUserLineAssPO::getUserIndex,Collectors.mapping(PqUserLineAssPO::getLineIndex,Collectors.toList()))); poList.forEach(item->{ UserLedgerStatisticVO.Inner inner = new UserLedgerStatisticVO.Inner(); + inner.setCustomId(item.getId()); inner.setName(item.getCustomerName()); List LIds = assMap.get(item.getId()); long count = eventList.stream().filter(it->LIds.contains(it.getLineid())).count();