sccg_server.git

			@@ -1,37 +1,42 @@
			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.constant.BaseCaseStatus;
			import com.ycl.common.util.DateUtil;
			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.HashMap;
			import java.util.List;
			import java.util.Map;
			import java.util.stream.Collectors;

			/**
			@@ -75,6 +80,23 @@
			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;


			@Override
			public String uploadEvent(Integer caseId) {
			@@ -123,27 +145,30 @@
			@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());
			casePoolViolationVO.setStreet(dataDictionaryMapper.selectById(item.getStreetId()).getName());
			return casePoolViolationVO;
			}).collect(Collectors.toList());
			Page<CasePoolViolationVO> casePoolViolationVOPage = new Page<>();
			BeanUtils.copyProperties(violationsPage, casePoolViolationVOPage);
			casePoolViolationVOPage.setRecords(violationVOList);
			@@ -162,6 +187,7 @@
			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());
			@@ -172,24 +198,174 @@
			}

			@Override
			public Boolean saveViolationCase(ViolationParam violationParam, Integer id) {
			BaseCase baseCase = new BaseCase();
			public Boolean saveViolationCase(ViolationParam violationParam, Long id) {
			Violations violations = new Violations();
			BeanUtils.copyProperties(violationParam, baseCase);
			BeanUtils.copyProperties(violationParam, violations);
			violations.setId(id);
			Integer value = 1;
			violations.setId(id);
			setDisposeRecord(id);
			return violationsMapper.insert(violations) == value ? true : false;
			}

			private void setDisposeRecord(Long id) {
			String stepName = "调度";
			Integer state = 0;
			DisposeRecord disposeRecord = new DisposeRecord();
			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, Integer id) {
			BaseCase baseCase = new BaseCase();
			public Boolean saveIllegalBuildingCase(IllegalBuildingParam illegalBuildingParam, Long id) {
			IllegalBuilding illegalBuilding = new IllegalBuilding();
			BeanUtils.copyProperties(illegalBuilding, baseCase);
			BeanUtils.copyProperties(illegalBuilding, illegalBuildingParam);
			illegalBuilding.setBaseCaseId(id);
			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);
			}
			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查询处置流程环节配置
			Map mapWcs = new HashMap();
			mapWcs.put("workflowConfigId", ddlcId);
			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.getCreateTime() != null) {
			record.setLinkTime(
			DateUtil.getDistanceDateTime(
			DateUtil.fromLocalDateTime(baseCase.getAlarmTime()),
			DateUtil.fromLocalDateTime(record.getCreateTime())));
			}
			}
			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查询处置流程环节配置
			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);
			//设置调查取证
			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(Long caseId, String result) {
			AdminUserDetails user = (AdminUserDetails) SecurityContextHolder.getContext().getAuthentication().getPrincipal();
			Integer state = 1;
			String endCaseName = "结案";
			BaseCase baseCase = new BaseCase();
			baseCase.setState(BaseCaseStatus.CLOSING_REGISTER);
			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().longValue());
			disposeRecord.setResult(result);
			disposeRecord.setState(state);
			disposeRecord.setCreateTime(LocalDateTime.now());
			disposeRecordMapper.insert(disposeRecord);
			}
			}