From 6b0c99943f1ae73a55f54a721473b7cc8ddd1c24 Mon Sep 17 00:00:00 2001
From: wl <173@qq.com>
Date: 星期三, 26 十月 2022 14:13:18 +0800
Subject: [PATCH] 我的待办处置人查询 上传处置重构

---
 ycl-platform/src/main/java/com/ycl/service/caseHandler/impl/DisposeRecordServiceImpl.java |  108 +++++++++++++++++++++++++++++++++++++++++++++---------
 1 files changed, 90 insertions(+), 18 deletions(-)

diff --git a/ycl-platform/src/main/java/com/ycl/service/caseHandler/impl/DisposeRecordServiceImpl.java b/ycl-platform/src/main/java/com/ycl/service/caseHandler/impl/DisposeRecordServiceImpl.java
index 627cebf..5c2ef5e 100644
--- a/ycl-platform/src/main/java/com/ycl/service/caseHandler/impl/DisposeRecordServiceImpl.java
+++ b/ycl-platform/src/main/java/com/ycl/service/caseHandler/impl/DisposeRecordServiceImpl.java
@@ -1,30 +1,30 @@
 package com.ycl.service.caseHandler.impl;
 
-import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
-import com.baomidou.mybatisplus.core.toolkit.StringUtils;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.ycl.bo.AdminUserDetails;
+import com.ycl.common.constant.BaseCaseStatus;
 import com.ycl.common.constant.StepName;
-import com.ycl.entity.caseHandler.BaseCase;
-import com.ycl.entity.caseHandler.DisposeRecord;
-import com.ycl.entity.caseHandler.WorkflowConfigStep;
-import com.ycl.entity.user.UmsAdminRoleRelation;
+import com.ycl.dto.dispatch.UploadDisposingResultParam;
+import com.ycl.entity.caseHandler.*;
 import com.ycl.exception.ApiException;
 import com.ycl.mapper.caseHandler.BaseCaseMapper;
 import com.ycl.mapper.caseHandler.DisposeRecordMapper;
 import com.ycl.mapper.caseHandler.WorkflowConfigStepMapper;
-import com.ycl.mapper.user.UmsAdminRoleRelationMapper;
-import com.ycl.service.caseHandler.IDisposeRecordService;
+import com.ycl.service.caseHandler.*;
 import com.ycl.vo.MyBacklogVO;
+import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.BeanUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.security.core.context.SecurityContextHolder;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
 import javax.annotation.Resource;
 import java.time.LocalDateTime;
-import java.util.ArrayList;
 import java.util.List;
-import java.util.stream.Collectors;
 
 /**
  * <p>
@@ -45,21 +45,94 @@
     @Resource
     WorkflowConfigStepMapper workflowConfigStepMapper;
 
-    @Resource
-    UmsAdminRoleRelationMapper umsAdminRoleRelationMapper;
+    @Autowired
+    IInvestigationService iInvestigationService;
+    @Autowired
+    IArrivalSituationService iArrivalSituationService;
+    @Autowired
+    IPartyInfoService iPartyInfoService;
+    @Autowired
+    IWritService iWritService;
+    @Autowired
+    IBaseCaseService baseCaseService;
+    @Autowired
+    IDisposeRecordService iDisposeRecordService;
+    @Autowired
+    IImageResourcesService iImageResourcesService;
 
     @Override
     public List<MyBacklogVO> listMyTask(String num, Long userId) {
-        return disposeRecordMapper.selectMyBackList(userId,num);
+        return disposeRecordMapper.selectMyBackList(userId, num);
     }
 
     @Override
-    public Boolean addRecord(DisposeRecord disposeRecord) {
+    @Transactional(rollbackFor = Exception.class)
+    public Boolean saveUpload(Long caseId, Integer type, UploadDisposingResultParam uploadDisposingResultParam) {
+        AdminUserDetails user = (AdminUserDetails) SecurityContextHolder.getContext().getAuthentication().getPrincipal();
+        //褰撲簨浜�
+        PartyInfo partyInfo = new PartyInfo();
+        BeanUtils.copyProperties(uploadDisposingResultParam, partyInfo);
+        partyInfo.setCreateUser(user.getUserId().intValue());
+        partyInfo.setCreateTime(LocalDateTime.now());
+        iPartyInfoService.save(partyInfo);
+        //璋冩煡鍙栬瘉
+        Investigation investigation = new Investigation();
+        BeanUtils.copyProperties(uploadDisposingResultParam, investigation);
+        investigation.setBaseCaseId(caseId);
+        investigation.setCreateTime(LocalDateTime.now());
+        investigation.setCreateUser(user.getUserId());
+        investigation.setPartyId(partyInfo.getId());
+        iInvestigationService.save(investigation);
+        //鍒拌揪
+        ArrivalSituation arrivalSituation = new ArrivalSituation();
+        BeanUtils.copyProperties(uploadDisposingResultParam, arrivalSituation);
+        arrivalSituation.setBaseCaseId(caseId);
+        arrivalSituation.setCreateTime(LocalDateTime.now());
+        arrivalSituation.setCreateUser(user.getUserId());
+        iArrivalSituationService.save(arrivalSituation);
+        //鏂囦功
+        Integer illegalBuildingType = 2;
+        Integer violation = 1;
+        String handType = "02";
+        ImageResources imageResources = new ImageResources();
+        imageResources.setType(handType);
+        imageResources.setBelongToId(caseId);
+        imageResources.setCreateTime(LocalDateTime.now());
+        imageResources.setCreateUser(user.getUserId());
+        if (type == violation) {
+            imageResources.setUrl(StringUtils.joinWith(",", uploadDisposingResultParam.getPic(), uploadDisposingResultParam.getSituationPic()));
+            iImageResourcesService.save(imageResources);
+        }
+        if (type == illegalBuildingType) {
+            Writ writ = new Writ();
+            BeanUtils.copyProperties(uploadDisposingResultParam, writ);
+            writ.setBaseCaseId(caseId);
+            writ.setIllegalBuildingId(caseId);
+            writ.setCreateTime(LocalDateTime.now());
+            writ.setCreateUser(user.getUserId());
+            iWritService.save(writ);
+            imageResources.setUrl(StringUtils
+                    .joinWith(",", uploadDisposingResultParam.getPic()
+                            , uploadDisposingResultParam.getSituationPic()
+                            , uploadDisposingResultParam.getOriginalPic()
+                            , uploadDisposingResultParam.getOtherPic()
+                            , uploadDisposingResultParam.getRectifiedPic()
+                            , uploadDisposingResultParam.getWritPic()));
+            iImageResourcesService.save(imageResources);
+        }
+        baseCaseService.update(new LambdaUpdateWrapper<BaseCase>().eq(BaseCase::getId, caseId).set(BaseCase::getState, BaseCaseStatus.DISPOSE));
+        String stepName = StepName.CHECK.getName();
+        DisposeRecord disposeRecord = new DisposeRecord();
+        disposeRecord.setBaseCaseId(caseId);
+        disposeRecord.setState(0);
+        disposeRecord.setCreateTime(LocalDateTime.now());
+        disposeRecord.setCreateUser(user.getUserId());
+        disposeRecord.setStepName(stepName);
+        disposeRecord.setStartTime(LocalDateTime.now());
 
         //缁撴潫涓婁紶澶勭疆娴佺▼
-        String stepName = StepName.DISPOSE.getName();
         QueryWrapper<WorkflowConfigStep> qureyDispatch = new QueryWrapper<>();
-        qureyDispatch.eq("name", stepName);
+        qureyDispatch.eq("name", StepName.DISPOSE.getName());
         WorkflowConfigStep dispatchStep = workflowConfigStepMapper.selectOne(qureyDispatch);
 
         UpdateWrapper<DisposeRecord> updateWrapper = new UpdateWrapper<>();
@@ -80,7 +153,6 @@
         //璁剧疆娴佺▼鐜妭鏁版嵁
         disposeRecord.setWorkflowConfigStepId(workflowConfigStep.getId());
         disposeRecord.setHandlerRoleId(workflowConfigStep.getRoleId());
-        baseMapper.insert(disposeRecord);
-        return true;
+        return baseMapper.insert(disposeRecord) == 1 ? true : false;
     }
 }

--
Gitblit v1.8.0