遂昌综合执法平台服务端
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
mg
2022-10-08 630fcec2d5da618fe4ddd2bc0215c2f9017af00d 
 ycl-platform/src/main/java/com/ycl/service/caseHandler/impl/BaseCaseServiceImpl.java


@@ -1,11 +1,14 @@


package com.ycl.service.caseHandler.impl;




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.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.util.DateUtil;


import com.ycl.dto.casePool.IllegalBuildingParam;


import com.ycl.dto.casePool.ViolationParam;


import com.ycl.entity.caseHandler.*;


@@ -14,8 +17,8 @@


import com.ycl.mapper.caseHandler.*;


import com.ycl.mapper.common.ImageResourcesMapper;


import com.ycl.mapper.dict.DataDictionaryMapper;


import com.ycl.remote.dto.EventAddParamDto;


import com.ycl.remote.dto.EventProcessParamDto;


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;


@@ -23,14 +26,16 @@


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.Instant;


import java.time.Duration;


import java.time.LocalDateTime;


import java.time.ZoneOffset;


import java.util.ArrayList;


import java.util.HashMap;


import java.util.List;


import java.util.Map;


import java.util.stream.Collectors;




/**


@@ -44,17 +49,17 @@


@Service


public class BaseCaseServiceImpl extends ServiceImpl<BaseCaseMapper, BaseCase> implements IBaseCaseService {




    //    private CityPlatformService cityPlatformService;


    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 setCityPlatformService(CityPlatformService cityPlatformService) {


        this.cityPlatformService = cityPlatformService;


    }




    @Autowired


    public void setViolationsService(IViolationsService violationsService) {


@@ -81,6 +86,8 @@


    InvestigationMapper investigationMapper;


    @Resource


    WritMapper writMapper;


    @Resource


    DisposeRecordMapper disposeRecordMapper;




    @Resource


    WorkflowConfigStepMapper workflowConfigStepMapper;


@@ -88,8 +95,6 @@


    WorkflowConfigMapper workflowConfigMapper;


    @Resource


    ImageResourcesMapper imageResourcesMapper;










    @Override


@@ -106,59 +111,62 @@


                medias = stringBuilder.toString();


            }


        }


        EventAddParamDto dto = EventAddParamDto.builder().y84(baseCase.getLatitude().toString()).x84(baseCase.getLongitude().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();


//        ResultResponseDto<EventAddResponseDto> result = cityPlatformService.addEvent(dto);


//        if (result.getCode() == 0) {


//            EventAddResponseDto responseDto = result.getResult();


//            baseCase.setTaskCode(responseDto.getTaskcode());


//            this.updateById(baseCase);


//            return null;


//        } else {


//            return result.getMsg();


//        }


        return null;


        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();


//        ResultResponseDto<EventProcessResponseDto> responseDto = cityPlatformService.getEventProcess(paramDto);


//        if (responseDto.getCode() == 0) {


//            EventProcessResponseDto eventProcessResponseDto = responseDto.getResult();


//            /*********** 未处理市平台返回数据 ***************/


//            return null;


//        } else {


//            return responseDto.getMsg();


//        }


        return null;


        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) {


                long nowTime = System.currentTimeMillis();


                long alarmTime = item.getAlarmTime().toEpochSecond(ZoneOffset.ofHours(8));


                LocalDateTime continueTimes = Instant.ofEpochMilli(nowTime - alarmTime).atZone(ZoneOffset.ofHours(8)).toLocalDateTime();


                String continueTime = continueTimes.getHour() + "时" + continueTimes.getSecond() + "分钟";


                casePoolViolationVO.setContinueTime(continueTime);


            } else {


                long closeTime = item.getCloseTime().toEpochSecond(ZoneOffset.ofHours(8));


                long alarmTime = item.getAlarmTime().toEpochSecond(ZoneOffset.ofHours(8));


                LocalDateTime continueTimes = Instant.ofEpochMilli(closeTime - alarmTime).atZone(ZoneOffset.ofHours(8)).toLocalDateTime();


                String continueTime = continueTimes.getHour() + "时" + continueTimes.getSecond() + "分钟";


                casePoolViolationVO.setContinueTime(continueTime);


            }


            casePoolViolationVO.setCategory(dataDictionaryMapper.selectById(item.getCategoryId()).getName());


            casePoolViolationVO.setType(dataDictionaryMapper.selectById(item.getTypeId()).getName());


            return casePoolViolationVO;


        }).collect(Collectors.toList());


        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());


                    return casePoolViolationVO;


                }).collect(Collectors.toList());


        Page<CasePoolViolationVO> casePoolViolationVOPage = new Page<>();


        BeanUtils.copyProperties(violationsPage, casePoolViolationVOPage);


        casePoolViolationVOPage.setRecords(violationVOList);


@@ -188,9 +196,7 @@




    @Override


    public Boolean saveViolationCase(ViolationParam violationParam, Integer id) {


        BaseCase baseCase = new BaseCase();


        Violations violations = new Violations();


        BeanUtils.copyProperties(violationParam, baseCase);


        BeanUtils.copyProperties(violationParam, violations);


        violations.setId(id);


        Integer value = 1;


@@ -199,9 +205,7 @@




    @Override


    public Boolean saveIllegalBuildingCase(IllegalBuildingParam illegalBuildingParam, Integer id) {


        BaseCase baseCase = new BaseCase();


        IllegalBuilding illegalBuilding = new IllegalBuilding();


        BeanUtils.copyProperties(illegalBuilding, baseCase);


        BeanUtils.copyProperties(illegalBuilding, illegalBuildingParam);


        illegalBuilding.setBaseCaseId(id);


        Integer value = 1;


@@ -215,6 +219,9 @@


        QueryWrapper<BaseCase> wrapper = new QueryWrapper<>();


        wrapper.lambda().eq(BaseCase::getCode, code);


        BaseCase baseCase = baseCaseMapper.selectOne(wrapper);


        if (baseCase == null) {


            return null;


        }


        bcd.setBaseCase(baseCase);


        //2.查询办理经过信息


        //2.1查询处置流程配置


@@ -222,7 +229,7 @@


        QueryWrapper<WorkflowConfig> wrapperWc = new QueryWrapper<>();


        wrapperWc.lambda().eq(WorkflowConfig::getCode, "ddlc").or().eq(WorkflowConfig::getCode, "wtcllc");


        List<WorkflowConfig> wcs = workflowConfigMapper.selectList(wrapperWc);


        Integer ddlcId=0,wtcllcId=0;


        Integer ddlcId = 0, wtcllcId = 0;


        for (WorkflowConfig wc : wcs) {


            if ("ddlc".equals(wc.getCode())) {


                ddlcId = wc.getId();


@@ -232,7 +239,24 @@


            }


        }


        //2.2查询处置流程环节配置


        List<WorkflowConfigStep> listWcs = workflowConfigStepMapper.selectRecordByWorkflowConfigStepId(ddlcId);


        Map mapWcs = new HashMap();


        mapWcs.put("workflowConfigId", ddlcId);


        mapWcs.put("baseCaseId", ddlcId);


        List<WorkflowConfigStep> listWcs = workflowConfigStepMapper.selectRecordByWorkflowConfigStepId(mapWcs);


        //处理用环节时间


        for (WorkflowConfigStep step : listWcs) {


            List<DisposeRecord> records = step.getDisposeRecords();


            if (records == null) {


                continue;


            }


            for (DisposeRecord record : records) {


                record.setLinkTime(


                        DateUtil.getDistanceDateTime(


                                DateUtil.fromLocalDateTime(baseCase.getAlarmTime()),


                                DateUtil.fromLocalDateTime(record.getCreateTime())));


            }


            step.setDisposeRecords(records);


        }


        //2.3设置调度流程


        handlePassVo.setWorkflowConfigSteps(listWcs);


        bcd.setHandlePassVo(handlePassVo);


@@ -246,13 +270,15 @@


        //4.查询问题处理信息


        ProblemProVo problemProVo = new ProblemProVo();


        //4.2查询处置流程环节配置


        List<WorkflowConfigStep> listWcsPp = workflowConfigStepMapper.selectRecordByWorkflowConfigStepId(wtcllcId);


        mapWcs.put("workflowConfigId", wtcllcId);


        List<WorkflowConfigStep> listWcsPp = workflowConfigStepMapper.selectRecordByWorkflowConfigStepId(mapWcs);


        //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);


@@ -289,4 +315,26 @@


        }


        return caseImages;


    }




    @Override


    public void endCase(Integer caseId, String result) {


        AdminUserDetails user = (AdminUserDetails) SecurityContextHolder.getContext().getAuthentication().getPrincipal();


        Integer endCaseState = 6;


        Integer state = 2;


        String endCaseName = "结案";


        BaseCase baseCase = new BaseCase();


        baseCase.setState(endCaseState);


        baseCase.setId(caseId);


        baseCaseMapper.updateById(baseCase);


        DisposeRecord disposeRecord = new DisposeRecord();


        disposeRecord.setBaseCaseId(caseId);


        disposeRecord.setWorkflowConfigStepId(workflowConfigStepMapper


                .selectOne(new LambdaQueryWrapper<WorkflowConfigStep>().eq(WorkflowConfigStep::getName, endCaseName))


                .getWorkflowConfigId());


        disposeRecord.setCreateUser(user.getUserId().intValue());


        disposeRecord.setResult(result);


        disposeRecord.setState(state);


        disposeRecord.setCreateTime(LocalDateTime.now());


        disposeRecordMapper.insert(disposeRecord);


    }


}