| | |
| | | package com.ycl.service.caseHandler.impl; |
| | | |
| | | 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.casePool.CasePoolIllegalBuildingDO; |
| | | import com.ycl.bo.casePool.CasePoolViolationDO; |
| | | import com.ycl.bo.casePool.CurrentSitVo; |
| | | import com.ycl.dto.casePool.IllegalBuildingParam; |
| | | import com.ycl.dto.casePool.ViolationParam; |
| | | import com.ycl.entity.caseHandler.BaseCase; |
| | | import com.ycl.entity.caseHandler.IllegalBuilding; |
| | | import com.ycl.entity.caseHandler.Violations; |
| | | import com.ycl.entity.caseHandler.*; |
| | | import com.ycl.entity.video.VideoAlarmReport; |
| | | import com.ycl.mapper.caseHandler.BaseCaseMapper; |
| | | import com.ycl.mapper.caseHandler.IllegalBuildingMapper; |
| | | import com.ycl.mapper.caseHandler.ViolationsMapper; |
| | | import com.ycl.mapper.caseHandler.*; |
| | | import com.ycl.mapper.dict.DataDictionaryMapper; |
| | | import com.ycl.remote.dto.*; |
| | | import com.ycl.remote.service.CityPlatformService; |
| | | import com.ycl.remote.dto.EventAddParamDto; |
| | | import com.ycl.remote.dto.EventProcessParamDto; |
| | | import com.ycl.service.caseHandler.IBaseCaseService; |
| | | import com.ycl.service.caseHandler.IViolationsService; |
| | | import com.ycl.service.video.IVideoAlarmReportService; |
| | |
| | | @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) { |
| | |
| | | @Resource |
| | | IllegalBuildingMapper illegalBuildingMapper; |
| | | |
| | | @Resource |
| | | ArrivalSituationMapper arrivalSituationMapper; |
| | | @Resource |
| | | InvestigationMapper investigationMapper; |
| | | @Resource |
| | | WritMapper writMapper; |
| | | |
| | | |
| | | @Override |
| | | public String uploadEvent(Integer caseId) { |
| | | BaseCase baseCase = this.getById(caseId); |
| | |
| | | } |
| | | EventAddParamDto dto = EventAddParamDto.builder().y84(baseCase.getLatitude().toString()).x84(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(); |
| | | } |
| | | // 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; |
| | | } |
| | | |
| | | @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(); |
| | | } |
| | | // ResultResponseDto<EventProcessResponseDto> responseDto = cityPlatformService.getEventProcess(paramDto); |
| | | // if (responseDto.getCode() == 0) { |
| | | // EventProcessResponseDto eventProcessResponseDto = responseDto.getResult(); |
| | | // /*********** 未处理市平台返回数据 ***************/ |
| | | // return null; |
| | | // } else { |
| | | // return responseDto.getMsg(); |
| | | // } |
| | | return null; |
| | | } |
| | | |
| | | @Override |
| | |
| | | Integer value = 1; |
| | | return illegalBuildingMapper.insert(illegalBuilding) == value ? true : false; |
| | | } |
| | | |
| | | @Override |
| | | public BaseCaseDetail baseCaseDetail(String code) { |
| | | BaseCaseDetail bcd = new BaseCaseDetail(); |
| | | //1.查询案件基本信息 |
| | | QueryWrapper<BaseCase> wrapper = new QueryWrapper<>(); |
| | | wrapper.lambda().eq(BaseCase::getCode, code); |
| | | BaseCase baseCase = baseCaseMapper.selectOne(wrapper); |
| | | bcd.setBaseCase(baseCase); |
| | | //2.查询办理经过信息 |
| | | //3.查询案卷图片信息 |
| | | //4.查询问题处理信息 |
| | | //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); |
| | | 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; |
| | | } |
| | | } |