From 68c92dc86cc15ca8d4982a73e7404bd479f2232c Mon Sep 17 00:00:00 2001
From: zhanghua <314079846@qq.com>
Date: 星期二, 22 十一月 2022 17:20:28 +0800
Subject: [PATCH] Merge branch 'master' of http://42.193.1.25:9521/r/sccg_server
---
ycl-platform/src/main/java/com/ycl/service/caseHandler/impl/BaseCaseServiceImpl.java | 114 ++++++++++++++++++++++----------------------------------
1 files changed, 45 insertions(+), 69 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 2b4c8d0..52b1d17 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
@@ -8,21 +8,20 @@
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.ycl.bo.AdminUserDetails;
-import com.ycl.bo.casePool.CasePoolIllegalBuildingDO;
-import com.ycl.bo.casePool.CasePoolViolationDO;
-import com.ycl.common.constant.BaseCaseStatus;
-import com.ycl.common.constant.StepName;
-import com.ycl.common.util.DateUtil;
+import com.ycl.controller.video.common.constant.BaseCaseStatus;
+import com.ycl.controller.video.common.constant.StepName;
+import com.ycl.controller.video.common.util.DateUtil;
+import com.ycl.dto.caseHandler.QueryForViolationParam;
import com.ycl.dto.casePool.IllegalBuildingParam;
import com.ycl.dto.casePool.ViolationParam;
import com.ycl.entity.caseHandler.*;
-import com.ycl.entity.common.ImageResources;
import com.ycl.entity.dict.DataDictionary;
+import com.ycl.entity.resources.ImageResources;
import com.ycl.entity.video.VideoAlarmReport;
import com.ycl.exception.ApiException;
import com.ycl.mapper.caseHandler.*;
-import com.ycl.mapper.common.ImageResourcesMapper;
import com.ycl.mapper.dict.DataDictionaryMapper;
+import com.ycl.mapper.resources.ImageResourcesMapper;
import com.ycl.remote.dto.*;
import com.ycl.remote.service.CityPlatformService;
import com.ycl.service.caseHandler.IBaseCaseService;
@@ -43,7 +42,6 @@
import java.util.HashMap;
import java.util.List;
import java.util.Map;
-import java.util.stream.Collectors;
/**
* <p>
@@ -122,9 +120,7 @@
medias = stringBuilder.toString();
}
}
- 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();
+ 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) {
@@ -157,57 +153,29 @@
Integer type = 01;
Integer hours = 60;
Integer day = 24;
- Page<CasePoolViolationDO> violationsPage = baseCaseMapper.listViolationsPage(page, state, type, resource);
- List<CasePoolViolationVO> violationVOList = violationsPage
- .getRecords()
- .stream()
- .map(item -> {
- CasePoolViolationVO casePoolViolationVO = new CasePoolViolationVO();
- BeanUtils.copyProperties(item, casePoolViolationVO);
- if (item.getCloseTime() == null) {
- Duration duration = Duration.between(item.getAlarmTime(), LocalDateTime.now());
- long continueHours = duration.toHours() - (duration.toDays() * day);
- long minutes = duration.toMinutes() - (duration.toHours() * hours);
- String continueTime = duration.toDays() + "澶�" + continueHours + "鏃�" + minutes + "鍒嗛挓";
- casePoolViolationVO.setContinueTime(continueTime);
- } else {
- Duration duration = Duration.between(item.getAlarmTime(), item.getCloseTime());
- long continueHours = duration.toHours() - (duration.toDays() * day);
- long minutes = duration.toMinutes() - (duration.toHours() * hours);
- String continueTime = duration.toDays() + "澶�" + continueHours + "鏃�" + minutes + "鍒嗛挓";
- casePoolViolationVO.setContinueTime(continueTime);
- }
- casePoolViolationVO.setCategory(dataDictionaryMapper.selectById(item.getCategoryId()).getName());
- casePoolViolationVO.setType(dataDictionaryMapper.selectById(item.getTypeId()).getName());
- casePoolViolationVO.setStreet(dataDictionaryMapper.selectById(item.getStreetId()).getName());
- return casePoolViolationVO;
- }).collect(Collectors.toList());
- Page<CasePoolViolationVO> casePoolViolationVOPage = new Page<>();
- BeanUtils.copyProperties(violationsPage, casePoolViolationVOPage);
- casePoolViolationVOPage.setRecords(violationVOList);
- return casePoolViolationVOPage;
+ Page<CasePoolViolationVO> violationsPage = baseCaseMapper.listViolationsPage(page, state, type, resource);
+ violationsPage.getRecords().stream().forEach(item -> {
+ if (item.getCloseTime() == null) {
+ Duration duration = Duration.between(item.getAlarmTime(), LocalDateTime.now());
+ long continueHours = duration.toHours() - (duration.toDays() * day);
+ long minutes = duration.toMinutes() - (duration.toHours() * hours);
+ String continueTime = duration.toDays() + "澶�" + continueHours + "鏃�" + minutes + "鍒嗛挓";
+ item.setContinueTime(continueTime);
+ } else {
+ Duration duration = Duration.between(item.getAlarmTime(), item.getCloseTime());
+ long continueHours = duration.toHours() - (duration.toDays() * day);
+ long minutes = duration.toMinutes() - (duration.toHours() * hours);
+ String continueTime = duration.toDays() + "澶�" + continueHours + "鏃�" + minutes + "鍒嗛挓";
+ item.setContinueTime(continueTime);
+ }
+ });
+ return violationsPage;
}
@Override
public Page listIllegalBuilding(Page page, Integer state, Integer resource) {
Integer type = 02;
- Page<CasePoolIllegalBuildingDO> casePoolIllegalBuildingDTOPage = baseCaseMapper.listIllegalBuildingsPage(page, state, type, resource);
- List<CasePoolIllegalBuildingVO> casePoolIllegalBuildingVOList = casePoolIllegalBuildingDTOPage
- .getRecords()
- .stream()
- .map(
- item -> {
- CasePoolIllegalBuildingVO casePoolIllegalBuildingVO = new CasePoolIllegalBuildingVO();
- BeanUtils.copyProperties(item, casePoolIllegalBuildingVO);
- casePoolIllegalBuildingVO.setCategory(dataDictionaryMapper.selectById(item.getCategoryId()).getName());
- casePoolIllegalBuildingVO.setCommunity(dataDictionaryMapper.selectById(item.getCommunityId()).getName());
- return casePoolIllegalBuildingVO;
- }
- ).collect(Collectors.toList());
- Page<CasePoolIllegalBuildingVO> casePoolViolationVOPage = new Page<>();
- BeanUtils.copyProperties(casePoolIllegalBuildingDTOPage, casePoolViolationVOPage);
- casePoolViolationVOPage.setRecords(casePoolIllegalBuildingVOList);
- return casePoolViolationVOPage;
+ return baseCaseMapper.listIllegalBuildingsPage(page, state, type, resource);
}
@Override
@@ -273,7 +241,7 @@
IllegalBuilding illegalBuilding = illegalBuildingMapper.selectById(baseCase.getId());
LambdaQueryWrapper<DataDictionary> dict = new LambdaQueryWrapper<>();
dict.eq(DataDictionary::getId, illegalBuilding.getCategoryId());
- DataDictionary dictionary = dataDictionaryMapper.selectOne(dict);
+ DataDictionary dictionary = dataDictionaryMapper.selectOne(dict);
if (dictionary != null) {
illegalBuilding.setCategoryText(dictionary.getName());
}
@@ -306,10 +274,7 @@
}
for (DisposeRecord record : records) {
if (record != null && record.getEndTime() != null && record.getStartTime() != null) {
- record.setLinkTime(
- DateUtil.getDistanceDateTime(
- DateUtil.fromLocalDateTime(record.getStartTime()),
- DateUtil.fromLocalDateTime(record.getEndTime())));
+ record.setLinkTime(DateUtil.getDistanceDateTime(DateUtil.fromLocalDateTime(record.getStartTime()), DateUtil.fromLocalDateTime(record.getEndTime())));
}
}
step.setDisposeRecords(records);
@@ -320,7 +285,7 @@
//3.鏌ヨ妗堝嵎鍥剧墖淇℃伅
FilesPictureVo filesPictureVo = new FilesPictureVo();
QueryWrapper<ImageResources> wrapperIr = new QueryWrapper<>();
- wrapperIr.lambda().eq(ImageResources::getType, "01").or().eq(ImageResources::getType, "02");
+ wrapperIr.lambda().eq(ImageResources::getBelongToId, baseCase.getId());
List<ImageResources> irs = imageResourcesMapper.selectList(wrapperIr);
filesPictureVo.setImageResources(irs);
bcd.setFilesPictureVo(filesPictureVo);
@@ -365,12 +330,8 @@
public ArrayList<String> listCaseImages(Integer id, Integer type) {
Integer illegalBuildingType = 02;
ArrayList<String> caseImages = new ArrayList<>();
- caseImages.add(investigationMapper
- .selectOne(new LambdaQueryWrapper<Investigation>()
- .eq(Investigation::getBaseCaseId, id)).getPic());
- caseImages.add(arrivalSituationMapper
- .selectOne(new LambdaQueryWrapper<ArrivalSituation>()
- .eq(ArrivalSituation::getBaseCaseId, id)).getSituationPic());
+ caseImages.add(investigationMapper.selectOne(new LambdaQueryWrapper<Investigation>().eq(Investigation::getBaseCaseId, id)).getPic());
+ caseImages.add(arrivalSituationMapper.selectOne(new LambdaQueryWrapper<ArrivalSituation>().eq(ArrivalSituation::getBaseCaseId, id)).getSituationPic());
if (type == illegalBuildingType) {
Writ writ = writMapper.selectOne(new LambdaQueryWrapper<Writ>().eq(Writ::getBaseCaseId, id));
caseImages.add(writ.getWritPic());
@@ -390,6 +351,7 @@
baseCase.setState(BaseCaseStatus.CLOSING_REGISTER);
baseCase.setId(caseId);
baseCase.setFinalOpinion(opinion);
+ baseCase.setCloseTime(LocalDateTime.now());
baseCaseMapper.updateById(baseCase);
QueryWrapper<WorkflowConfigStep> stepQurey = new QueryWrapper<>();
@@ -406,8 +368,22 @@
disposeRecord.setHandlerId(user.getUserId());
//缁撴宸茬粨鏉�
disposeRecord.setState(1);
+ disposeRecord.setResult(result);
disposeRecord.setEndTime(LocalDateTime.now());
disposeRecord.setHandlerId(user.getUserId());
disposeRecordMapper.update(disposeRecord, updateWrapper);
}
+
+ @Override
+ public List<BaseCase> selectPage(Page<BaseCase> page, String number, Integer communityId, Integer categories, String startTime, String endTime, String site) {
+ return baseCaseMapper.selectBaseCasePage(page, number, communityId, categories, startTime, endTime, site);
+ }
+
+ @Override
+ public Page<QueryForViolationVO> selectViolation(QueryForViolationParam queryForViolationParam) {
+ return baseCaseMapper.selectViolationPage(
+ new Page<QueryForViolationVO>()
+ .setSize(queryForViolationParam.getPageSize())
+ .setCurrent(queryForViolationParam.getCurrent()), queryForViolationParam);
+ }
}
\ No newline at end of file
--
Gitblit v1.8.0