From 8439887c903fa52560af52b40e12a1baa8a123d3 Mon Sep 17 00:00:00 2001 From: zhanghua <314079846@qq.com> Date: 星期三, 05 七月 2023 10:27:43 +0800 Subject: [PATCH] 代码合并 --- ycl-platform/src/main/java/com/ycl/service/caseHandler/impl/BaseCaseServiceImpl.java | 43 ++++++++++++++++++++++++++++++++++++------- 1 files changed, 36 insertions(+), 7 deletions(-) diff --git a/ycl-platform/src/main/java/com/ycl/service/caseHandler/impl/BaseCaseServiceImpl.java b/ycl-platform/src/main/java/com/ycl/service/caseHandler/impl/BaseCaseServiceImpl.java index 64011a0..684cf46 100644 --- a/ycl-platform/src/main/java/com/ycl/service/caseHandler/impl/BaseCaseServiceImpl.java +++ b/ycl-platform/src/main/java/com/ycl/service/caseHandler/impl/BaseCaseServiceImpl.java @@ -1,5 +1,6 @@ package com.ycl.service.caseHandler.impl; +import cn.hutool.core.collection.CollUtil; import com.alibaba.druid.util.StringUtils; import com.alibaba.fastjson.JSONObject; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; @@ -32,6 +33,7 @@ import com.ycl.service.caseHandler.IBaseCaseService; import com.ycl.service.caseHandler.IDispatchHandleService; import com.ycl.service.caseHandler.IViolationsService; +import com.ycl.service.resources.IImageResourcesService; import com.ycl.service.video.IVideoAlarmReportService; import com.ycl.vo.casePool.*; import com.ycl.vo.cockpit.enforcementEvents.DelayVO; @@ -50,10 +52,8 @@ import java.time.Duration; import java.time.LocalDateTime; import java.time.format.DateTimeFormatter; -import java.util.ArrayList; -import java.util.HashMap; -import java.util.List; -import java.util.Map; +import java.util.*; +import java.util.stream.Collectors; /** * <p> @@ -126,7 +126,8 @@ @Resource IBaseCaseService baseCaseService; - + @Autowired + IImageResourcesService imageResourcesService; @Override public String uploadEvent(Long caseId) { @@ -397,11 +398,39 @@ disposeRecordMapper.update(disposeRecord, updateWrapper); } + @Override - public Page<BaseCase> selectPage(Page<BaseCase> page, String number, Integer streetId, Integer categories, String startTime, String endTime, String site) { - return baseCaseMapper.selectBaseCasePage(page, number, streetId, categories, startTime, endTime, site); + public Page<BaseCase> selectPage(Page<BaseCase> page, String number, Integer communityId, Integer categories, String startTime, String endTime, String site, Integer state, Integer streetId, Integer time) { + LocalDateTime start = null; + LocalDateTime end = null; + LocalDateTime now = LocalDateTime.now(); + if (Objects.nonNull(time) && time == 0) { + end = now; + start = now.plusWeeks(1); + + } + if (Objects.nonNull(time) && time == 1) { + end = now; + start = now.plusMonths(1); + + } + if (Objects.nonNull(time) && time == 2) { + end = now; + start = now.plusMonths(3); + } + Page<BaseCase> baseCasePage = baseCaseMapper.selectBaseCasePage(page, number, communityId, categories, start, end, site, state, streetId); + if (Objects.isNull(baseCasePage) && CollUtil.isNotEmpty(baseCasePage.getRecords())) { + List<BaseCase> records = baseCasePage.getRecords(); + Set<Long> caseIds = records.stream().map(BaseCase::getId).collect(Collectors.toSet()); + Map<Long, String> urlMap = imageResourcesService.getUrlMap(caseIds, "01"); + records.stream().forEach(item -> { + item.setUrl(urlMap.get(item.getId())); + }); + } + return baseCasePage; } + @Override public Page<QueryForViolationVO> selectViolation(QueryForViolationParam queryForViolationParam) { return baseCaseMapper.selectViolationPage( -- Gitblit v1.8.0