From caefe9a9cc486247f831e46356b0b03ca450fdf9 Mon Sep 17 00:00:00 2001 From: 101captain <237651143@qq.com> Date: 星期五, 25 二月 2022 10:14:36 +0800 Subject: [PATCH] Merge branch 'dev' of http://gitlab.nhys.cdnhxx.com/root/zhihuishequ into dev --- springcloud_k8s_panzhihuazhihuishequ/service_grid/src/main/java/com/panzhihua/service_grid/service/impl/EventGridMemberRelationServiceImpl.java | 139 +++++++++++++++++++++++++++++++++++----------- 1 files changed, 106 insertions(+), 33 deletions(-) diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_grid/src/main/java/com/panzhihua/service_grid/service/impl/EventGridMemberRelationServiceImpl.java b/springcloud_k8s_panzhihuazhihuishequ/service_grid/src/main/java/com/panzhihua/service_grid/service/impl/EventGridMemberRelationServiceImpl.java index 2370ba7..d45b591 100644 --- a/springcloud_k8s_panzhihuazhihuishequ/service_grid/src/main/java/com/panzhihua/service_grid/service/impl/EventGridMemberRelationServiceImpl.java +++ b/springcloud_k8s_panzhihuazhihuishequ/service_grid/src/main/java/com/panzhihua/service_grid/service/impl/EventGridMemberRelationServiceImpl.java @@ -1,5 +1,14 @@ package com.panzhihua.service_grid.service.impl; +import java.util.ArrayList; +import java.util.List; + +import javax.annotation.Resource; + +import com.panzhihua.common.model.vos.screen.GridMemberTrajectoryVo; +import org.springframework.beans.BeanUtils; +import org.springframework.stereotype.Service; + import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; @@ -8,19 +17,14 @@ import com.panzhihua.common.model.vos.R; import com.panzhihua.common.model.vos.grid.EventGridMemberRelationDetailsVO; import com.panzhihua.common.model.vos.grid.EventGridMemberRelationVO; +import com.panzhihua.common.model.vos.grid.EventMapGridCascadeVO; import com.panzhihua.common.model.vos.grid.admin.GridMemberCascadeVO; import com.panzhihua.common.service.user.UserService; -import com.panzhihua.service_grid.dao.*; -import com.panzhihua.service_grid.model.dos.*; +import com.panzhihua.service_grid.dao.EventGridMemberRelationMapper; +import com.panzhihua.service_grid.model.dos.EventGridMemberRelationDO; import com.panzhihua.service_grid.service.EventGridMemberRelationService; -import lombok.extern.slf4j.Slf4j; -import org.springframework.stereotype.Service; -import org.springframework.beans.BeanUtils; -import javax.annotation.Resource; -import java.util.ArrayList; -import java.util.Date; -import java.util.List; +import lombok.extern.slf4j.Slf4j; /** * @auther lyq @@ -29,7 +33,8 @@ */ @Slf4j @Service -public class EventGridMemberRelationServiceImpl extends ServiceImpl<EventGridMemberRelationMapper, EventGridMemberRelationDO> implements EventGridMemberRelationService { +public class EventGridMemberRelationServiceImpl extends + ServiceImpl<EventGridMemberRelationMapper, EventGridMemberRelationDO> implements EventGridMemberRelationService { @Resource private EventGridMemberRelationMapper eventGridMemberRelationMapper; @@ -38,18 +43,17 @@ /** * 新增网格和网格员的关联关系 + * * @param eventGridMemberAddDTO * @return 新增结果 */ - public R add(EventGridMemberAddDTO eventGridMemberAddDTO){ + public R add(EventGridMemberAddDTO eventGridMemberAddDTO) { userService.addGridUser(eventGridMemberAddDTO); - - EventGridMemberRelationDO eventGridMemberRelationDO = new EventGridMemberRelationDO(); eventGridMemberRelationDO.setCreateBy(eventGridMemberAddDTO.getUserId()); - if(eventGridMemberRelationMapper.insert(eventGridMemberRelationDO)>0){ + if (eventGridMemberRelationMapper.insert(eventGridMemberRelationDO) > 0) { return R.ok(); } return R.fail(); @@ -57,14 +61,15 @@ /** * 修改网格和网格员的关联关系 + * * @param eventGridMemberEditDTO * @return 维护结果 */ - public R edit(EventGridMemberEditDTO eventGridMemberEditDTO){ + public R edit(EventGridMemberEditDTO eventGridMemberEditDTO) { EventGridMemberRelationDO eventGridMemberRelationDO = new EventGridMemberRelationDO(); BeanUtils.copyProperties(eventGridMemberEditDTO, eventGridMemberRelationDO); - //eventGridMemberRelationDO.setUpdateAt(new Date()); - if(eventGridMemberRelationMapper.updateById(eventGridMemberRelationDO)>0){ + // eventGridMemberRelationDO.setUpdateAt(new Date()); + if (eventGridMemberRelationMapper.updateById(eventGridMemberRelationDO) > 0) { return R.ok(); } return R.fail(); @@ -72,15 +77,16 @@ /** * 分页查找网格和网格员的关联关系 + * * @param pageEventGridMemberRelationDTO * @return 维护结果 */ - public R<IPage<EventGridMemberRelationVO>> query(PageEventGridMemberRelationDTO pageEventGridMemberRelationDTO){ - Page page = new Page(1,10); - if(pageEventGridMemberRelationDTO.getPageNum()!=null) { + public R<IPage<EventGridMemberRelationVO>> query(PageEventGridMemberRelationDTO pageEventGridMemberRelationDTO) { + Page page = new Page(1, 10); + if (pageEventGridMemberRelationDTO.getPageNum() != null) { page.setCurrent(pageEventGridMemberRelationDTO.getPageNum()); } - if(pageEventGridMemberRelationDTO.getPageSize()!=null) { + if (pageEventGridMemberRelationDTO.getPageSize() != null) { page.setSize(pageEventGridMemberRelationDTO.getPageSize()); } return R.ok(eventGridMemberRelationMapper.findByPage(page, pageEventGridMemberRelationDTO)); @@ -88,21 +94,24 @@ /** * 删除网格和网格员的关联关系 + * * @param EventGridMemberRelationDeleteDTO * @return 平台用户信息 */ - public R delete(EventGridMemberRelationDeleteDTO EventGridMemberRelationDeleteDTO){ + public R delete(EventGridMemberRelationDeleteDTO EventGridMemberRelationDeleteDTO) { return R.fail(); } /** * 查询网格和网格员的关联关系详细信息 - * @param id 网格和网格员的关联关系 id + * + * @param id + * 网格和网格员的关联关系 id * @return 查找结果 */ - public R<EventGridMemberRelationDetailsVO> eventGridMemberRelationDetails(Long id){ + public R<EventGridMemberRelationDetailsVO> eventGridMemberRelationDetails(Long id) { EventGridMemberRelationDO eventGridMemberRelationDO = eventGridMemberRelationMapper.selectById(id); - if(eventGridMemberRelationDO!=null) { + if (eventGridMemberRelationDO != null) { EventGridMemberRelationDetailsVO eventGridMemberRelationDetailsVO = new EventGridMemberRelationDetailsVO(); BeanUtils.copyProperties(eventGridMemberRelationDO, eventGridMemberRelationDetailsVO); return R.ok(eventGridMemberRelationDetailsVO); @@ -112,29 +121,93 @@ /** * 根据网格员id查询关联网格列表 - * @param userId 网格员id - * @return 网格列表 + * + * @param userId + * 网格员id + * @return 网格列表 */ @Override - public R getMapGridListByApp(Long userId){ + public R getMapGridListByApp(Long userId) { return R.ok(this.baseMapper.getMapGridListByApp(userId)); } /** * 查询市平台网格员列表 - * @return 市平台网格员列表 + * + * @return 市平台网格员列表 */ @Override - public R lcList(){ + public R lcList() { return R.ok(this.baseMapper.getGridMemberLcList()); } @Override - public R gridMemberCascadeList(EventGridMemberCascadeAddDTO memberCascadeAddDTO){ - if(memberCascadeAddDTO.getType() == null){ + public R gridMemberCascadeList(EventGridMemberCascadeAddDTO memberCascadeAddDTO) { + if (memberCascadeAddDTO.getType() == null) { return R.fail("参数错误"); } - return R.ok(this.baseMapper.getGridMemberCascade(memberCascadeAddDTO.getType(),memberCascadeAddDTO.getSuperiorId())); + List<GridMemberCascadeVO> memberCascadeList = + this.baseMapper.getGridMemberCascade(memberCascadeAddDTO.getType(), memberCascadeAddDTO.getSuperiorId()); + + List<GridMemberCascadeVO> result = new ArrayList<>(); + if (!memberCascadeList.isEmpty()) { + memberCascadeList.forEach(cascade -> { + if (memberCascadeAddDTO.getType().equals(1)) {// 过滤无小区的社区 + Integer count = this.baseMapper.getVillageCount(cascade.getId()); + if (count > 0) { + result.add(cascade); + } + } else if (memberCascadeAddDTO.getType().equals(2)) {// 过滤无楼栋的小区 + Integer count = this.baseMapper.getBuildingCount(cascade.getId()); + if (count > 0) { + result.add(cascade); + } + } else { + if (!cascade.getName().contains("栋")) { + cascade.setName(cascade.getName() + "栋"); + } + result.add(cascade); + } + }); + } + return R.ok(result); + } + + @Override + public R getMapGridListsByApp(EventGridCascadeListDTO cascadeListDTO) { + return R.ok(eventGridMemberRelationMapper.getMapGridListsByApp(cascadeListDTO)); + } + + @Override + public R getMapGridsListsByApp(Long userId) { + List<EventMapGridCascadeVO> resultList = new ArrayList<>(); + List<EventMapGridCascadeVO> list = this.eventGridMemberRelationMapper.getMapGridsListsByApp(userId, 1, null); + if (!list.isEmpty()) { + list.forEach(gridCascadeVO -> { + List<EventMapGridCascadeVO> childList = + this.eventGridMemberRelationMapper.getMapGridsListsByApp(userId, 2, gridCascadeVO.getGridId()); + if (!childList.isEmpty()) { + gridCascadeVO.setChildList(childList); + resultList.add(gridCascadeVO); + } + }); + } + return R.ok(resultList); + } + + /** + * 查询社区网格员运动轨迹 + * @param communityId 社区id + * @return 社区网格员运动轨迹 + */ + @Override + public R getGridsMemberTrajectory(Long communityId){ + //查询社区所有网格员 + List<GridMemberTrajectoryVo> memberTrajectoryList = eventGridMemberRelationMapper.getGridsMemberList(communityId); + memberTrajectoryList.forEach(member -> { + member.setLngLatList(eventGridMemberRelationMapper.getGridsMemberTrajectory(member.getUserId())); + }); + return R.ok(memberTrajectoryList); } } -- Gitblit v1.7.1