sccg_server.git

			@@ -1,35 +1,37 @@
			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.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.common.ImageResources;
			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.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.CasePoolIllegalBuildingVO;
			import com.ycl.vo.casePool.CasePoolViolationVO;
			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.Instant;
			import java.time.Duration;
			import java.time.LocalDateTime;
			import java.time.ZoneOffset;
			import java.util.ArrayList;
			import java.util.List;
			import java.util.stream.Collectors;

			@@ -75,6 +77,23 @@
			@Resource
			IllegalBuildingMapper illegalBuildingMapper;

			@Resource
			ArrivalSituationMapper arrivalSituationMapper;
			@Resource
			InvestigationMapper investigationMapper;
			@Resource
			WritMapper writMapper;
			@Resource
			DisposeRecordMapper disposeRecordMapper;

			@Resource
			WorkflowConfigStepMapper workflowConfigStepMapper;
			@Resource
			WorkflowConfigMapper workflowConfigMapper;
			@Resource
			ImageResourcesMapper imageResourcesMapper;


			@Override
			public String uploadEvent(Integer caseId) {
			BaseCase baseCase = this.getById(caseId);
			@@ -89,11 +108,13 @@
			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);
			String msg = cityPlatformService.addEvent(dto);
			ResultResponseDto result = JSONObject.parseObject(msg, ResultResponseDto.class);
			if (result.getCode() == 0) {
			EventAddResponseDto responseDto = result.getResult();
			EventAddResponseDto responseDto = JSONObject.parseObject(result.getResult(), EventAddResponseDto.class);
			baseCase.setTaskCode(responseDto.getTaskcode());
			this.updateById(baseCase);
			return null;
			@@ -106,9 +127,10 @@
			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);
			String msg = cityPlatformService.getEventProcess(paramDto);
			ResultResponseDto responseDto = JSONObject.parseObject(msg, ResultResponseDto.class);
			if (responseDto.getCode() == 0) {
			EventProcessResponseDto eventProcessResponseDto = responseDto.getResult();
			EventProcessResponseDto eventProcessResponseDto = JSONObject.parseObject(responseDto.getResult(), EventProcessResponseDto.class);
			/********* 未处理市平台返回数据 *************/
			return null;
			} else {
			@@ -119,21 +141,20 @@
			@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() + "分钟";
			Duration duration = Duration.between(item.getAlarmTime(), LocalDateTime.now());
			long minutes = duration.toMinutes() - (duration.toHours() * hours);
			String continueTime = duration.toHours() + "时" + minutes + "分钟";
			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() + "分钟";
			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());
			@@ -169,9 +190,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;
			@@ -180,12 +199,114 @@

			@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;
			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.查询办理经过信息
			//2.1查询处置流程配置
			HandlePassVo handlePassVo = new HandlePassVo();
			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;
			for (WorkflowConfig wc : wcs) {
			if ("ddlc".equals(wc.getCode())) {
			ddlcId = wc.getId();
			}
			if ("wtcllc".equals(wc.getCode())) {
			wtcllcId = wc.getId();
			}
			}
			//2.2查询处置流程环节配置
			List<WorkflowConfigStep> listWcs = workflowConfigStepMapper.selectRecordByWorkflowConfigStepId(ddlcId);
			//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 = workflowConfigStepMapper.selectRecordByWorkflowConfigStepId(wtcllcId);
			//4.3设置调度流程
			problemProVo.setWorkflowConfigSteps(listWcsPp);
			bcd.setProblemProVo(problemProVo);
			//5.查询现场情况信息
			CurrentSitVo currentSitVo = new CurrentSitVo();
			QueryWrapper<ArrivalSituation> wrapperAs = new QueryWrapper<>();
			//设置到达现场情况
			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;
			}

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