From bbe76086f95dfb34e942d9f2801e17db38391c68 Mon Sep 17 00:00:00 2001 From: zhanghua <314079846@qq.com> Date: 星期二, 21 十一月 2023 21:34:05 +0800 Subject: [PATCH] 接口测试 --- ycl-platform/src/main/java/com/ycl/service/caseHandler/impl/BaseCaseServiceImpl.java | 84 +++++++++++++++++++++++++++++++----------- 1 files changed, 62 insertions(+), 22 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 d317117..5bb0fa8 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,10 +1,12 @@ 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; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; +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.ycl.bo.AdminUserDetails; @@ -31,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; @@ -49,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> @@ -125,7 +126,8 @@ @Resource IBaseCaseService baseCaseService; - + @Autowired + IImageResourcesService imageResourcesService; @Override public String uploadEvent(Long caseId) { @@ -141,12 +143,13 @@ medias = stringBuilder.toString(); } } + eventDesc += "[澶у崕瑙嗛鎺ュ叆娴嬭瘯]"; EventAddParamDto dto = EventAddParamDto.builder().y84(baseCase.getLatitude() != null ? baseCase.getLatitude().toString() : "").x84(baseCase.getLongitude() != null ? baseCase.getLongitude().toString() : "").source(11).address(baseCase.getSite()).eventDesc(eventDesc).eventSign(baseCase.getCode()).medias(medias).build(); String msg = cityPlatformService.addEvent(dto); ResultResponseDto result = JSONObject.parseObject(msg, ResultResponseDto.class); if (result.getCode() == 0) { - EventAddResponseDto responseDto = JSONObject.parseObject(result.getResult(), EventAddResponseDto.class); - baseCase.setTaskCode(responseDto.getTaskcode()); +// EventAddResponseDto responseDto = JSONObject.parseObject(result.getResult(), EventAddResponseDto.class); + baseCase.setTaskCode(result.getResult()); this.updateById(baseCase); return null; } else { @@ -170,11 +173,12 @@ } @Override - public Page listViolationsPage(Page page, Integer state, Integer resource, String code, String categoryBig, String categorySmall, Integer street, String site, String startTime, String endTime) { + public Page listViolationsPage(Integer current, Integer size, Integer state, Integer resource, String code, String categoryBig, String categorySmall, Integer street, String site, String startTime, String endTime, Integer violationsTypeId, Integer videoId) { Integer type = 01; Integer hours = 60; Integer day = 24; - Page<CasePoolViolationVO> violationsPage = baseCaseMapper.listViolationsPage(page, state, type, resource, code, categoryBig, categorySmall, street, site, startTime, endTime); + Page page = new Page<>().setCurrent(current).setSize(size); + Page<CasePoolViolationVO> violationsPage = baseCaseMapper.listViolationsPage(page, state, type, resource, code, categoryBig, categorySmall, street, site, startTime, endTime, violationsTypeId, videoId); violationsPage.getRecords().stream().forEach(item -> { if (item.getCloseTime() == null) { Duration duration = Duration.between(item.getAlarmTime(), LocalDateTime.now()); @@ -194,8 +198,9 @@ } @Override - public Page listIllegalBuilding(Page page, Integer state, Integer resource) { + public Page listIllegalBuilding(Integer current, Integer size, Integer state, Integer resource) { Integer type = 02; + Page page = new Page<>().setCurrent(current).setSize(size); return baseCaseMapper.listIllegalBuildingsPage(page, state, type, resource); } @@ -206,7 +211,7 @@ Integer value = 1; violations.setId(id); setDisposeRecord(id, violationParam.getLimitTime()); - return violationsMapper.insert(violations) == value ? true : false; + return violationsMapper.insert(violations) == value; } private void setDisposeRecord(Long id, String limitTime) { @@ -394,10 +399,38 @@ 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) { @@ -413,8 +446,8 @@ } @Override - public Page<BaseCaseVO> selectVideoInspection(Integer current) { - return baseCaseMapper.selectVideoInspection(new Page<>(current, 1)); + public Page<BaseCaseVO> selectVideoInspection(Integer current, Integer pageSize, Long gradeId, Long videoId, String beginTime, String endTime) { + return baseCaseMapper.selectVideoInspection(new Page<>(current, pageSize), gradeId, videoId, beginTime, endTime); } @Override @@ -476,15 +509,22 @@ } @Override - public List<EventVO> selectEventList(String beginTime, String endTime) { - return baseCaseMapper.selectEventList(beginTime, endTime); + public IPage<EventVO> selectEventList(String beginTime, String endTime, Integer pageIndex, Integer pageSize) { + if (pageIndex == null) { + pageIndex = 1; + } + if (pageSize == null) { + pageSize = 50; + } + IPage<EventVO> page = new Page<>(pageIndex, pageSize); + return baseCaseMapper.selectEventList(page, beginTime, endTime); } @Override public List<VideoAndAreaVO> areaCount() { List<VideoAndAreaVO> areaCountList = baseCaseMapper.areaCount(); Long allCount = baseCaseMapper.selectCount(new LambdaQueryWrapper<>()); - areaCountList.stream().forEach(item -> item.setRatio(new BigDecimal(item.getCount() * 1.0 / allCount).setScale(2, BigDecimal.ROUND_HALF_UP))); + areaCountList.stream().forEach(item -> item.setRatio(new BigDecimal(item.getCount() * 1.0 / allCount).setScale(4, BigDecimal.ROUND_HALF_UP))); return areaCountList; } @@ -524,7 +564,7 @@ if (reportLastMonthCount == 0) { report.setRatio(null); } else { - report.setRatio(new BigDecimal(v).setScale(2, BigDecimal.ROUND_HALF_UP).abs()); + report.setRatio(new BigDecimal(v).setScale(4, BigDecimal.ROUND_HALF_UP).abs()); } if (v < 0) { report.setUp(false); @@ -546,7 +586,7 @@ if (disposeLastMonthCount == 0) { dispose.setRatio(null); } else { - dispose.setRatio(new BigDecimal(v1).setScale(2, BigDecimal.ROUND_HALF_UP).abs()); + dispose.setRatio(new BigDecimal(v1).setScale(4, BigDecimal.ROUND_HALF_UP).abs()); } if (v1 < 0) { dispose.setUp(false); @@ -562,7 +602,7 @@ if (onTimeCaseLastMonthCount == 0) { onTimeDispose.setRatio(null); } else { - onTimeDispose.setRatio(new BigDecimal(v2).setScale(2, BigDecimal.ROUND_HALF_UP).abs()); + onTimeDispose.setRatio(new BigDecimal(v2).setScale(4, BigDecimal.ROUND_HALF_UP).abs()); } if (v2 < 0) { onTimeDispose.setUp(false); @@ -586,7 +626,7 @@ if (disposeLastMonthCount == 0) { register.setRatio(null); } else { - register.setRatio(new BigDecimal(v3).setScale(2, BigDecimal.ROUND_HALF_UP).abs()); + register.setRatio(new BigDecimal(v3).setScale(4, BigDecimal.ROUND_HALF_UP).abs()); } if (v3 < 0) { register.setUp(false); -- Gitblit v1.8.0