From b9e7a0261443ca41b80108b9fef555093f20bb8b Mon Sep 17 00:00:00 2001
From: mg <maokecheng@163.com>
Date: 星期五, 14 十月 2022 16:48:13 +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 |  385 ++++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 381 insertions(+), 4 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 f155201..ace3776 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,46 @@
 package com.ycl.service.caseHandler.impl;
 
-import com.ycl.entity.caseHandler.BaseCase;
-import com.ycl.mapper.caseHandler.BaseCaseMapper;
-import com.ycl.service.caseHandler.IBaseCaseService;
+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;
+import com.ycl.remote.dto.*;
+import com.ycl.remote.service.CityPlatformService;
+import com.ycl.service.caseHandler.IBaseCaseService;
+import com.ycl.service.caseHandler.IViolationsService;
+import com.ycl.service.video.IVideoAlarmReportService;
+import com.ycl.vo.casePool.*;
+import org.springframework.beans.BeanUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.security.core.context.SecurityContextHolder;
 import org.springframework.stereotype.Service;
+
+import javax.annotation.Resource;
+import java.time.Duration;
+import java.time.LocalDateTime;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.stream.Collectors;
 
 /**
  * <p>
@@ -17,4 +53,345 @@
 @Service
 public class BaseCaseServiceImpl extends ServiceImpl<BaseCaseMapper, BaseCase> implements IBaseCaseService {
 
-}
+    private CityPlatformService cityPlatformService;
+    private IViolationsService violationsService;
+    private IVideoAlarmReportService videoAlarmReportService;
+
+    @Value("${fdfs.fileUrl}")
+    private String fileUrl;
+
+    @Autowired
+    public void setCityPlatformService(CityPlatformService cityPlatformService) {
+        this.cityPlatformService = cityPlatformService;
+    }
+
+    @Autowired
+    public void setViolationsService(IViolationsService violationsService) {
+        this.violationsService = violationsService;
+    }
+
+    @Autowired
+    public void setVideoAlarmReportService(IVideoAlarmReportService videoAlarmReportService) {
+        this.videoAlarmReportService = videoAlarmReportService;
+    }
+
+    @Resource
+    BaseCaseMapper baseCaseMapper;
+    @Resource
+    DataDictionaryMapper dataDictionaryMapper;
+    @Resource
+    ViolationsMapper violationsMapper;
+    @Resource
+    IllegalBuildingMapper illegalBuildingMapper;
+
+    @Resource
+    ArrivalSituationMapper arrivalSituationMapper;
+    @Resource
+    InvestigationMapper investigationMapper;
+    @Resource
+    WritMapper writMapper;
+    @Resource
+    DisposeRecordMapper disposeRecordMapper;
+
+    @Resource
+    WorkflowConfigStepMapper workflowConfigStepMapper;
+    @Resource
+    WorkflowConfigMapper workflowConfigMapper;
+    @Resource
+    ImageResourcesMapper imageResourcesMapper;
+    @Resource
+    DispatchInfoMapper dispatchInfoMapper;
+    @Resource
+    PartyInfoMapper partyInfoMapper;
+
+
+    @Override
+    public String uploadEvent(Integer caseId) {
+        BaseCase baseCase = this.getById(caseId);
+        Violations violations = violationsService.getById(caseId);
+        String medias = "";
+        String eventDesc = "";
+        if (violations != null) {
+            eventDesc = violations.getDescription();
+            VideoAlarmReport videoAlarmReport = videoAlarmReportService.getById(violations.getVideoAlarmReportId());
+            if (videoAlarmReport != null) {
+                StringBuilder stringBuilder = new StringBuilder().append("[{'mediaURL':'").append(fileUrl).append(videoAlarmReport.getPicData()).append("'}]");
+                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();
+        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());
+            this.updateById(baseCase);
+            return null;
+        } else {
+            return result.getMsg();
+        }
+    }
+
+    @Override
+    public String processEvent(Integer caseId) {
+        BaseCase baseCase = this.getById(caseId);
+        EventProcessParamDto paramDto = EventProcessParamDto.builder().eventSign(baseCase.getCode()).taskcode(baseCase.getTaskCode()).build();
+        String msg = cityPlatformService.getEventProcess(paramDto);
+        ResultResponseDto responseDto = JSONObject.parseObject(msg, ResultResponseDto.class);
+        if (responseDto.getCode() == 0) {
+            EventProcessResponseDto eventProcessResponseDto = JSONObject.parseObject(responseDto.getResult(), EventProcessResponseDto.class);
+            /*********** 鏈鐞嗗競骞冲彴杩斿洖鏁版嵁 ***************/
+            return null;
+        } else {
+            return responseDto.getMsg();
+        }
+    }
+
+    @Override
+    public Page listViolationsPage(Page page, Integer state, Integer resource) {
+        Integer type = 01;
+        Integer hours = 60;
+        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 minutes = duration.toMinutes() - (duration.toHours() * hours);
+                        String continueTime = duration.toHours() + "鏃�" + minutes + "鍒嗛挓";
+                        casePoolViolationVO.setContinueTime(continueTime);
+                    } else {
+                        Duration duration = Duration.between(item.getAlarmTime(), item.getCloseTime());
+                        long minutes = duration.toMinutes() - (duration.toHours() * hours);
+                        String continueTime = duration.toHours() + "鏃�" + 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;
+    }
+
+    @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;
+    }
+
+    @Override
+    public Boolean saveViolationCase(ViolationParam violationParam, Long id) {
+        Violations violations = new Violations();
+        BeanUtils.copyProperties(violationParam, violations);
+        Integer value = 1;
+        violations.setId(id);
+        setDisposeRecord(id);
+        return violationsMapper.insert(violations) == value ? true : false;
+    }
+
+    private void setDisposeRecord(Long id) {
+        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());
+        AdminUserDetails userDetails = (AdminUserDetails) SecurityContextHolder.getContext().getAuthentication().getPrincipal();
+        disposeRecord.setCreateUser(userDetails.getUserId());
+        disposeRecord.setStartTime(LocalDateTime.now());
+        disposeRecord.setStepName(stepName);
+        disposeRecordMapper.insert(disposeRecord);
+    }
+
+    @Override
+    public Boolean saveIllegalBuildingCase(IllegalBuildingParam illegalBuildingParam, Long id) {
+        IllegalBuilding illegalBuilding = new IllegalBuilding();
+        BeanUtils.copyProperties(illegalBuildingParam, illegalBuilding);
+        setDisposeRecord(id);
+        Integer value = 1;
+        illegalBuilding.setBaseCaseId(id);
+        return illegalBuildingMapper.insert(illegalBuilding) == value ? true : false;
+    }
+
+    @Override
+    public BaseCaseDetail baseCaseDetail(String code) {
+        BaseCaseDetail bcd = new BaseCaseDetail();
+        //1.鏌ヨ妗堜欢鍩烘湰淇℃伅
+        Map map = new HashMap();
+        map.put("code", code);
+        BaseCase baseCase = baseCaseMapper.selectCondMap(map);
+        if (baseCase == null) {
+            return null;
+        }
+        //鏌ヨ妗堜欢杩濊淇℃伅
+        if (baseCase.getCategory() == 1) {
+            Map mapV = new HashMap();
+            mapV.put("id", baseCase.getId());
+            Violations violations = violationsMapper.selectCondMap(mapV);
+            baseCase.setViolations(violations);
+        } else {
+            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");
+        List<WorkflowConfig> wcs = workflowConfigMapper.selectList(wrapperWc);
+
+        //2.2鏌ヨ澶勭疆娴佺▼鐜妭閰嶇疆
+        Map mapWcs = new HashMap();
+        mapWcs.put("workflowConfigId", wcs.get(0).getId());
+        mapWcs.put("baseCaseId", baseCase.getId());
+        List<WorkflowConfigStep> listWcs = workflowConfigStepMapper.selectRecordByWorkflowConfigStepId(mapWcs);
+        //澶勭悊鐢ㄧ幆鑺傛椂闂�
+        for (WorkflowConfigStep step : listWcs) {
+            List<DisposeRecord> records = step.getDisposeRecords();
+            if (records == null) {
+                continue;
+            }
+            for (DisposeRecord record : records) {
+                if (record != null && record.getEndTime() != null) {
+                    record.setLinkTime(
+                            DateUtil.getDistanceDateTime(
+                                    DateUtil.fromLocalDateTime(baseCase.getAlarmTime()),
+                                    DateUtil.fromLocalDateTime(record.getEndTime())));
+                }
+            }
+            step.setDisposeRecords(records);
+        }
+        //2.3璁剧疆璋冨害娴佺▼
+        handlePassVo.setWorkflowConfigSteps(listWcs);
+        bcd.setHandlePassVo(handlePassVo);
+        //3.鏌ヨ妗堝嵎鍥剧墖淇℃伅
+        FilesPictureVo filesPictureVo = new FilesPictureVo();
+        QueryWrapper<ImageResources> wrapperIr = new QueryWrapper<>();
+        wrapperIr.lambda().eq(ImageResources::getType, "01").or().eq(ImageResources::getType, "02");
+        List<ImageResources> irs = imageResourcesMapper.selectList(wrapperIr);
+        filesPictureVo.setImageResources(irs);
+        bcd.setFilesPictureVo(filesPictureVo);
+        //4.鏌ヨ闂澶勭悊淇℃伅
+        /*ProblemProVo problemProVo = new ProblemProVo();
+        //4.2鏌ヨ澶勭疆娴佺▼鐜妭閰嶇疆
+        List<WorkflowConfigStep> listWcsPp = new ArrayList<>();
+        //4.3璁剧疆璋冨害娴佺▼
+        problemProVo.setWorkflowConfigSteps(listWcsPp);
+        bcd.setProblemProVo(problemProVo);*/
+
+        //5.鏌ヨ鐜板満鎯呭喌淇℃伅
+        CurrentSitVo currentSitVo = new CurrentSitVo();
+        QueryWrapper<ArrivalSituation> wrapperAs = new QueryWrapper<>();
+        wrapperAs.lambda().eq(ArrivalSituation::getBaseCaseId, baseCase.getId());
+        //璁剧疆鍒拌揪鐜板満鎯呭喌
+        ArrivalSituation as = arrivalSituationMapper.selectOne(wrapperAs);
+        currentSitVo.setArrivalSituation(as);
+        //璁剧疆璋冩煡鍙栬瘉
+        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<>();
+        wrapperW.lambda().eq(Writ::getBaseCaseId, baseCase.getId());
+        Writ writ = writMapper.selectOne(wrapperW);
+        currentSitVo.setWrit(writ);
+        bcd.setCurrentSitVo(currentSitVo);
+        return bcd;
+    }
+
+    @Override
+    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());
+        if (type == illegalBuildingType) {
+            Writ writ = writMapper.selectOne(new LambdaQueryWrapper<Writ>().eq(Writ::getBaseCaseId, id));
+            caseImages.add(writ.getWritPic());
+            caseImages.add(writ.getOriginalPic());
+            caseImages.add(writ.getOtherPic());
+            caseImages.add(writ.getRectifiedPic());
+        }
+        return caseImages;
+    }
+
+    @Override
+    public void endCase(Long caseId, String result,String opinion) {
+        //鑾峰彇褰撳墠鐧婚檰鐢ㄦ埛淇℃伅
+        AdminUserDetails user = (AdminUserDetails) SecurityContextHolder.getContext().getAuthentication().getPrincipal();
+        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.setHandlerId(user.getUserId().longValue());
+        //缁撴宸茬粨鏉�
+        disposeRecord.setState(1);
+        disposeRecord.setEndTime(LocalDateTime.now());
+        disposeRecordMapper.update(disposeRecord, updateWrapper);
+    }
+}
\ No newline at end of file

--
Gitblit v1.8.0