From 2ca2e51f3a838252ed9cd8989f4f5d6fe35d468c Mon Sep 17 00:00:00 2001 From: 罗元桥 <2376770955@qq.com> Date: 星期三, 30 六月 2021 18:02:00 +0800 Subject: [PATCH] Merge branch 'test' into 'master' --- springcloud_k8s_panzhihuazhihuishequ/service_grid/src/main/java/com/panzhihua/service_grid/service/impl/EventServiceImpl.java | 111 ++++++++++++++++++++++++++++++++++++++++++++++++++++++- 1 files changed, 108 insertions(+), 3 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 4074fdb..87a87c6 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 @@ -1,5 +1,7 @@ package com.panzhihua.service_grid.service.impl; +import cn.hutool.core.date.DateTime; +import cn.hutool.core.date.DateUtil; import cn.hutool.core.util.IdcardUtil; import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; @@ -17,7 +19,9 @@ 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.model.vos.screen.*; import com.panzhihua.common.service.community.CommunityService; +import com.panzhihua.common.utlis.DateUtils; import com.panzhihua.common.utlis.ExcelSelectListUtil; import com.panzhihua.common.utlis.LngLatUtils; import com.panzhihua.common.utlis.StringUtils; @@ -63,6 +67,10 @@ private EventGridDataService eventGridDataService; @Resource private EventResourceMapper eventResourceMapper; + + private final String moth_format_str = "yyyy-MM"; + + private final String[] monthStr = new String[]{"一","二","三","四","五","六","七","八","九","十","十一","十二"}; /** * 分页查找事件 @@ -162,6 +170,7 @@ EventGridDataDO eventGridDataDO = eventGridDataMapper.selectById(eventDO.getGridId()); if (eventGridDataDO != null) { eventDetailsVO.setGridName(eventGridDataDO.getGridName()); + eventDetailsVO.setCommunityId(eventGridDataDO.getGridCommunityId()); } //查询事件关联附件 @@ -1728,7 +1737,10 @@ public R getNearByGrid(PageEventGridNearbyDTO pageEventGridNearbyDTO) { Page page = new Page(pageEventGridNearbyDTO.getPageNum(), pageEventGridNearbyDTO.getPageSize()); String latLng = pageEventGridNearbyDTO.getHappentLatLng(); - if(!latLng.matches("^[\\-\\+]?(0(\\.\\d{1,10})?|([1-9](\\d)?)(\\.\\d{1,10})?|1[0-7]\\d{1}(\\.\\d{1,10})?|180\\.0{1,10}),[\\-\\+]?((0|([1-8]\\d?))(\\.\\d{1,10})?|90(\\.0{1,10})?)$")){ +// if(!latLng.matches("^[\\-\\+]?(0(\\.\\d{1,10})?|([1-9](\\d)?)(\\.\\d{1,10})?|1[0-7]\\d{1}(\\.\\d{1,10})?|180\\.0{1,10}),[\\-\\+]?((0|([1-8]\\d?))(\\.\\d{1,10})?|90(\\.0{1,10})?)$")){ +// return R.fail("经纬度参数错误"); +// } + if(!latLng.matches("[1-9][0-9](\\.[0-9]{1,6})?,[1-9][0-9]{2}(\\.[0-9]{1,6})?")){ return R.fail("经纬度参数错误"); } String latLngArr[] = latLng.split(","); @@ -2182,9 +2194,15 @@ * @return 社区人口数据列表 */ @Override - public R specialPopulationList(PageEventSpecialPopulationDTO specialPopulationDTO){ - IPage<EventSpecialPopulationVO> specialPopulationVOIPage = this.baseMapper.specialPopulationList(new Page(specialPopulationDTO.getPageNum(),specialPopulationDTO.getPageSize()),specialPopulationDTO); + public R specialPopulationList(PageEventSpecialPopulationDTO specialPopulationDTO) { + IPage<EventSpecialPopulationVO> specialPopulationVOIPage = this.baseMapper.specialPopulationList(new Page(specialPopulationDTO.getPageNum(), specialPopulationDTO.getPageSize()), specialPopulationDTO); + if(!specialPopulationVOIPage.getRecords().isEmpty()){ + specialPopulationVOIPage.getRecords().forEach(specialPopulation -> { + specialPopulation.setAge(IdcardUtil.getAgeByIdCard(specialPopulation.getIdCard())); + }); + } return R.ok(specialPopulationVOIPage); + } @Override public List<EventDetailsVO> getUnUploadEvent() { @@ -2192,6 +2210,7 @@ List<EventDO> unEventList = baseMapper.selectList( new QueryWrapper<EventDO>() .eq("upload", false) + .eq("event_process_status", 2) ); unEventList.forEach(eventDO -> { eventDetailsVOList.add(eventDetails(eventDO.getId()).getData()); @@ -2214,4 +2233,90 @@ } return false; } + + public R eventWork(Long communityId){ + EventWorkScreenVO workScreenVO = new EventWorkScreenVO(); + String date = DateUtils.getDateFormatString(new Date(),moth_format_str); + Map<String,Long> countMap = this.eventMapper.countByCommunityId(communityId,date); + if(!countMap.isEmpty()){ + workScreenVO.setResolvedNum(countMap.get("resolvedNum")== null ? 0L : Long.valueOf(countMap.get("resolvedNum").toString())); + workScreenVO.setPendingNum(countMap.get("pendingNum")== null ? 0L : Long.valueOf(countMap.get("pendingNum").toString())); + workScreenVO.setPropagandaNum(countMap.get("propagandaNum")== null ? 13L : Long.valueOf(countMap.get("propagandaNum").toString())); + workScreenVO.setCurrentNum(countMap.get("currentNum")== null ? 0L : Long.valueOf(countMap.get("currentNum").toString())); + } + + //计算处理时间消耗的时间 + DateScreenVO countAvg = this.eventMapper.countByAvgCommunityId(communityId); + if(countAvg != null){ + int second = (int) (countAvg.getEndTime().getTime() - countAvg.getStartTime().getTime())/1000; + if(second > 0){ + second = second/workScreenVO.getResolvedNum().intValue(); + workScreenVO.setAvgCost(second); + } + } + //查询最新事件轮播列表 + List<EventDetailWorkVO> eventList = this.eventMapper.getWorkScreenEventList(communityId); + if(!eventList.isEmpty()){ + workScreenVO.setEventList(eventList); + } + + //统计近半年数据 + List<EventWorkVO> list = new ArrayList<>(); + for(EventWorkVO eventWorkVO: listHalfYearByDyn()){ + EventWorkVO result = this.eventMapper.countByTime(eventWorkVO.getStart(),eventWorkVO.getEnd(),communityId); + result.setMonth(eventWorkVO.getMonth()); + list.add(result); + } + workScreenVO.setList(list); + + //查询完成事件统计 + EventTypeWorkVO complete = this.eventMapper.getComplete(communityId); + if(complete != null){ + workScreenVO.setComplete(complete); + } + //查询未完成事件统计 + EventTypeWorkVO noComplete = this.eventMapper.getNoComplete(communityId); + if(complete != null){ + workScreenVO.setNoComplete(noComplete); + } + return R.ok(workScreenVO); + } + + private List<EventWorkVO> listHalfYearByDyn() { + List<EventWorkVO> dateList = new ArrayList<>(); + Date now = new Date(); + for(int i= 6;i>=1;i--){ + Date date = DateUtils.getDateM(now,-i); + DateTime endDay = DateUtil.endOfMonth(date); + + int m = DateUtil.month(endDay); + m++; + if(m == 12){ + m = 0; + } + int day = DateUtil.dayOfMonth(endDay); + int half = day/2; + String month = DateUtil.format(date,moth_format_str); + EventWorkVO eventWorkVO = new EventWorkVO(); + eventWorkVO.setMonth(monthStr[m]+"月上旬"); + eventWorkVO.setStart(month+ "-01 00:00:00"); + eventWorkVO.setEnd(month+ "-"+half+" 23:59:58"); + dateList.add(eventWorkVO); + EventWorkVO eventWorkVO1 = new EventWorkVO(); + eventWorkVO1.setMonth(monthStr[m]+"月下旬"); + eventWorkVO1.setStart(month+ "-"+half+" 23:59:58"); + eventWorkVO1.setEnd(DateUtils.getDateFormatString(endDay,"yyyy-MM-dd HH:mm:ss")); + dateList.add(eventWorkVO1); + } + return dateList; + + } + + public static void main(String[] args) { + String content = "30,104"; + String re = "[1-9][0-9](\\.[0-9]{1,6})?,[1-9][0-9]{2}(\\.[0-9]{1,6})?"; + + System.out.println(content.matches(re)); + } + } -- Gitblit v1.7.1