From c6512655e722d9ca80dd8c34b79f6d3923ecf86c Mon Sep 17 00:00:00 2001 From: 罗元桥 <2376770955@qq.com> Date: 星期二, 22 六月 2021 16:07:50 +0800 Subject: [PATCH] Merge branch 'test' into 'test_screen' --- springcloud_k8s_panzhihuazhihuishequ/service_grid/src/main/java/com/panzhihua/service_grid/service/impl/EventServiceImpl.java | 68 ++++++++++++++++++++++++++++++--- 1 files changed, 61 insertions(+), 7 deletions(-) diff --git a/springcloud_k8s_panzhihuazhihuishequ/service_grid/src/main/java/com/panzhihua/service_grid/service/impl/EventServiceImpl.java b/springcloud_k8s_panzhihuazhihuishequ/service_grid/src/main/java/com/panzhihua/service_grid/service/impl/EventServiceImpl.java index d7fff02..f87f7fb 100644 --- a/springcloud_k8s_panzhihuazhihuishequ/service_grid/src/main/java/com/panzhihua/service_grid/service/impl/EventServiceImpl.java +++ b/springcloud_k8s_panzhihuazhihuishequ/service_grid/src/main/java/com/panzhihua/service_grid/service/impl/EventServiceImpl.java @@ -2,17 +2,21 @@ import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; +import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.panzhihua.common.enums.EventType; import com.panzhihua.common.exceptions.ServiceException; import com.panzhihua.common.model.dtos.community.ComMngPopulationDTO; +import com.panzhihua.common.model.dtos.community.bigscreen.event.ScreenEventListDTO; import com.panzhihua.common.model.dtos.grid.*; import com.panzhihua.common.model.vos.R; import com.panzhihua.common.model.vos.community.ComActVO; +import com.panzhihua.common.model.vos.community.screen.event.EventListVO; import com.panzhihua.common.model.vos.grid.*; import com.panzhihua.common.service.community.CommunityService; +import com.panzhihua.common.utlis.ExcelSelectListUtil; import com.panzhihua.common.utlis.LngLatUtils; import com.panzhihua.common.utlis.StringUtils; import com.panzhihua.service_grid.dao.*; @@ -25,12 +29,11 @@ import org.springframework.stereotype.Service; import org.springframework.beans.BeanUtils; import org.springframework.transaction.annotation.Transactional; +import org.springframework.util.CollectionUtils; import javax.annotation.Resource; import java.text.SimpleDateFormat; -import java.util.ArrayList; -import java.util.Date; -import java.util.List; +import java.util.*; /** * @author cedoo @@ -55,6 +58,8 @@ private EventGridMemberRelationMapper eventGridMemberRelationMapper; @Resource private EventGridDataService eventGridDataService; + @Resource + private EventResourceMapper eventResourceMapper; /** * 分页查找事件 @@ -234,10 +239,17 @@ } eventDetailsVO.setTrans(eventTransferRecordVOS); - //查询事件发布人头像 - String imageUrl = eventMapper.getGridMemberImageUrl(eventDO.getGridMemberId()); - if (StringUtils.isNotEmpty(imageUrl)) { - eventDetailsVO.setGridMemberImageUrl(imageUrl); + //查询网格员头像,姓名 + Map<String,Object> gridMember = eventMapper.getUserBaseInfo(eventDO.getGridMemberId()); + if (!CollectionUtils.isEmpty(gridMember)) { + eventDetailsVO.setGridMemberName(gridMember.get("name") == null ? "" : gridMember.get("name").toString()); + eventDetailsVO.setGridMemberImageUrl(gridMember.get("image_url") == null ? "" : gridMember.get("image_url").toString()); + } + if(Objects.equals(eventDO.getGridMemberId(),eventDO.getCreateBy())){ + eventDetailsVO.setCreator(eventDetailsVO.getGridMemberName()); + }else{ + Map<String,Object> createUser = eventMapper.getUserBaseInfo(eventDO.getCreateBy()); + eventDetailsVO.setCreator(createUser.get("name") == null ? "" : createUser.get("name").toString()); } return R.ok(eventDetailsVO); @@ -2050,4 +2062,46 @@ return R.fail(); } + + /** + * 事件大屏查询事件列表 + * @param eventListDTO 请求参数 + * @return 事件列表 + */ + @Override + public R getScreenEventList(ScreenEventListDTO eventListDTO){ + if( eventListDTO.getEventType() != null && eventListDTO.getEventType().equals(ScreenEventListDTO.eventType.xc)){ + eventListDTO.setEventCategory(2); + } + IPage<EventListVO> eventPageList = this.baseMapper.getScreenEventList(new Page(eventListDTO.getPageNum(),eventListDTO.getPageSize()),eventListDTO); + return R.ok(eventPageList); + + @Override + public List<EventDetailsVO> getUnUploadEvent() { + List<EventDetailsVO> eventDetailsVOList =new ArrayList<>(); + List<EventDO> unEventList = baseMapper.selectList( + new QueryWrapper<EventDO>() + .eq("upload", false) + ); + unEventList.forEach(eventDO -> { + eventDetailsVOList.add(eventDetails(eventDO.getId()).getData()); + }); + return eventDetailsVOList; + } + + @Override + @Transactional(rollbackFor = Exception.class) + public Boolean updateLcUploadFlag(Long id) { + EventDO event = baseMapper.selectById(id); + event.setUpload(true); + baseMapper.updateById(event); + EventResourceDO eventResourceDO =new EventResourceDO(); + eventResourceDO.setUpload(true); + int flag = eventResourceMapper.update(eventResourceDO, new QueryWrapper<EventResourceDO>() + .eq("ref_id", id)); + if(flag>0){ + return true; + } + return false; + } } -- Gitblit v1.7.1