From d46beba25ccb64a1047a98d642b6ce45e82f0bee Mon Sep 17 00:00:00 2001
From: wl <173@qq.com>
Date: 星期一, 17 十月 2022 18:07:28 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master' into master
---
ycl-platform/src/main/java/com/ycl/service/caseHandler/impl/BaseCaseServiceImpl.java | 87 ++++++++++++++++++++++++++++---------------
1 files changed, 57 insertions(+), 30 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 f4069a2..8510dd5 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
@@ -3,18 +3,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.conditions.update.UpdateWrapper;
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.dto.casePool.IllegalBuildingParam;
import com.ycl.dto.casePool.ViolationParam;
import com.ycl.entity.caseHandler.*;
import com.ycl.entity.common.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;
@@ -96,6 +99,10 @@
WorkflowConfigMapper workflowConfigMapper;
@Resource
ImageResourcesMapper imageResourcesMapper;
+ @Resource
+ DispatchInfoMapper dispatchInfoMapper;
+ @Resource
+ PartyInfoMapper partyInfoMapper;
@Override
@@ -208,9 +215,15 @@
}
private void setDisposeRecord(Long id) {
- String stepName = "璋冨害";
+ String stepName = StepName.DISPATCH.getName();
+ QueryWrapper<WorkflowConfigStep> stepqurey = new QueryWrapper<>();
+ stepqurey.eq("name", stepName);
+ WorkflowConfigStep workflowConfigStep = workflowConfigStepMapper.selectOne(stepqurey);
+
Integer state = 0;
DisposeRecord disposeRecord = new DisposeRecord();
+ disposeRecord.setWorkflowConfigStepId(workflowConfigStep.getId());
+ disposeRecord.setHandlerRoleId(workflowConfigStep.getRoleId());
disposeRecord.setBaseCaseId(id);
disposeRecord.setState(state);
disposeRecord.setCreateTime(LocalDateTime.now());
@@ -251,26 +264,23 @@
IllegalBuilding illegalBuilding = illegalBuildingMapper.selectById(baseCase.getId());
baseCase.setIllegalBuilding(illegalBuilding);
}
+ //鑾峰彇璋冨害淇℃伅
+ Map mapD = new HashMap();
+ mapD.put("baseCaseId",baseCase.getId());
+ DispatchInfo dispatchInfo = dispatchInfoMapper.selectCondMap(mapD);
+ baseCase.setDispatchInfo(dispatchInfo);
bcd.setBaseCase(baseCase);
//妗堜欢鐩稿叧淇℃伅
//2.鏌ヨ鍔炵悊缁忚繃淇℃伅
//2.1鏌ヨ澶勭疆娴佺▼閰嶇疆
HandlePassVo handlePassVo = new HandlePassVo();
QueryWrapper<WorkflowConfig> wrapperWc = new QueryWrapper<>();
- wrapperWc.lambda().eq(WorkflowConfig::getCode, "ddlc").or().eq(WorkflowConfig::getCode, "wtcllc");
+ wrapperWc.lambda().eq(WorkflowConfig::getCode, "ddlc");
List<WorkflowConfig> wcs = workflowConfigMapper.selectList(wrapperWc);
- Integer ddlcId = 0, wtcllcId = 0;
- for (WorkflowConfig wc : wcs) {
- if ("ddlc".equals(wc.getCode())) {
- ddlcId = wc.getId();
- }
- if ("wtcllc".equals(wc.getCode())) {
- wtcllcId = wc.getId();
- }
- }
+
//2.2鏌ヨ澶勭疆娴佺▼鐜妭閰嶇疆
Map mapWcs = new HashMap();
- mapWcs.put("workflowConfigId", ddlcId);
+ mapWcs.put("workflowConfigId", wcs.get(0).getId());
mapWcs.put("baseCaseId", baseCase.getId());
List<WorkflowConfigStep> listWcs = workflowConfigStepMapper.selectRecordByWorkflowConfigStepId(mapWcs);
//澶勭悊鐢ㄧ幆鑺傛椂闂�
@@ -280,11 +290,11 @@
continue;
}
for (DisposeRecord record : records) {
- if (record != null && record.getCreateTime() != null) {
+ if (record != null && record.getEndTime() != null) {
record.setLinkTime(
DateUtil.getDistanceDateTime(
DateUtil.fromLocalDateTime(baseCase.getAlarmTime()),
- DateUtil.fromLocalDateTime(record.getCreateTime())));
+ DateUtil.fromLocalDateTime(record.getEndTime())));
}
}
step.setDisposeRecords(records);
@@ -300,13 +310,13 @@
filesPictureVo.setImageResources(irs);
bcd.setFilesPictureVo(filesPictureVo);
//4.鏌ヨ闂澶勭悊淇℃伅
- ProblemProVo problemProVo = new ProblemProVo();
+ /*ProblemProVo problemProVo = new ProblemProVo();
//4.2鏌ヨ澶勭疆娴佺▼鐜妭閰嶇疆
- mapWcs.put("workflowConfigId", wtcllcId);
- List<WorkflowConfigStep> listWcsPp = workflowConfigStepMapper.selectRecordByWorkflowConfigStepId(mapWcs);
+ List<WorkflowConfigStep> listWcsPp = new ArrayList<>();
//4.3璁剧疆璋冨害娴佺▼
problemProVo.setWorkflowConfigSteps(listWcsPp);
- bcd.setProblemProVo(problemProVo);
+ bcd.setProblemProVo(problemProVo);*/
+
//5.鏌ヨ鐜板満鎯呭喌淇℃伅
CurrentSitVo currentSitVo = new CurrentSitVo();
QueryWrapper<ArrivalSituation> wrapperAs = new QueryWrapper<>();
@@ -318,6 +328,14 @@
QueryWrapper<Investigation> wrapperI = new QueryWrapper<>();
wrapperI.lambda().eq(Investigation::getBaseCaseId, baseCase.getId());
Investigation investigation = investigationMapper.selectOne(wrapperI);
+ if (investigation != null && investigation.getPartyId() != null) {
+ //鑾峰彇褰撲簨浜轰俊鎭�
+ Map mapP = new HashMap();
+ mapP.put("id", investigation.getPartyId());
+ PartyInfo partyInfo = partyInfoMapper.selectCondMap(mapP);
+ //濉厖褰撲簨浜�
+ investigation.setPartyInfo(partyInfo);
+ }
currentSitVo.setInvestigation(investigation);
//璁剧疆鍛婄煡杩濇硶
QueryWrapper<Writ> wrapperW = new QueryWrapper<>();
@@ -349,23 +367,32 @@
}
@Override
- public void endCase(Long caseId, String result) {
+ public void endCase(Long caseId, String result,String opinion) {
+ //鑾峰彇褰撳墠鐧婚檰鐢ㄦ埛淇℃伅
AdminUserDetails user = (AdminUserDetails) SecurityContextHolder.getContext().getAuthentication().getPrincipal();
- Integer state = 1;
- String endCaseName = "缁撴";
+ String endCaseName = StepName.CLOSING_REGISTER.getName();
BaseCase baseCase = new BaseCase();
baseCase.setState(BaseCaseStatus.CLOSING_REGISTER);
baseCase.setId(caseId);
+ baseCase.setFinalOpinion(opinion);
baseCaseMapper.updateById(baseCase);
+
+ QueryWrapper<WorkflowConfigStep> stepQurey = new QueryWrapper<>();
+ stepQurey.eq("name", endCaseName);
+ WorkflowConfigStep workflowConfigStep = workflowConfigStepMapper.selectOne(stepQurey);
+ if (workflowConfigStep == null) {
+ throw new ApiException("鏈煡璇㈠埌璇ユ祦绋嬬幆鑺�");
+ }
+ UpdateWrapper<DisposeRecord> updateWrapper = new UpdateWrapper<>();
+ updateWrapper.eq("base_case_id", baseCase.getId()).eq("workflow_config_step_id",workflowConfigStep.getId());
+
+ //淇敼缁撴璁板綍
DisposeRecord disposeRecord = new DisposeRecord();
- disposeRecord.setBaseCaseId(caseId);
- disposeRecord.setWorkflowConfigStepId(workflowConfigStepMapper
- .selectOne(new LambdaQueryWrapper<WorkflowConfigStep>().eq(WorkflowConfigStep::getName, endCaseName))
- .getWorkflowConfigId());
- disposeRecord.setCreateUser(user.getUserId().longValue());
- disposeRecord.setResult(result);
- disposeRecord.setState(state);
- disposeRecord.setCreateTime(LocalDateTime.now());
- disposeRecordMapper.insert(disposeRecord);
+ disposeRecord.setHandlerId(user.getUserId());
+ //缁撴宸茬粨鏉�
+ disposeRecord.setState(1);
+ disposeRecord.setEndTime(LocalDateTime.now());
+ disposeRecord.setHandlerId(user.getUserId());
+ disposeRecordMapper.update(disposeRecord, updateWrapper);
}
}
\ No newline at end of file
--
Gitblit v1.8.0