smartor.git - Gitblit

			@@ -253,8 +253,8 @@
			for (ServiceTaskdept serviceTaskdept1 : serviceTaskdepts) {
			writeInSubTask(serviceTaskdept1.getTaskId(), true, patMedInhosp1, patArchive, 1, config);
			}
			patMedInhosp1.setDeptcheckFlag("1");
			patMedInhospMapper.updatePatMedInhosp(patMedInhosp1);
			// patMedInhosp1.setDeptcheckFlag("1");
			// patMedInhospMapper.updatePatMedInhosp(patMedInhosp1);
			}

			} catch (Exception e) {
			@@ -307,8 +307,8 @@
			for (ServiceTaskdept serviceTaskdept1 : serviceTaskdeptList) {
			writeInSubTask(serviceTaskdept1.getTaskId(), true, pmiBQ1, patArchive, 2, config);
			}
			pmiBQ1.setWardcheckFlag("1");
			patMedInhospMapper.updatePatMedInhosp(pmiBQ1);
			// pmiBQ1.setWardcheckFlag("1");
			// patMedInhospMapper.updatePatMedInhosp(pmiBQ1);
			}


			@@ -363,8 +363,8 @@
			for (ServiceTaskdiag serviceTaskdept1 : serviceTaskdiags) {
			writeInSubTask(serviceTaskdept1.getTaskId(), true, pmiJB, patArchive, 3, config);
			}
			pmiJB.setDiagcheckFlag("1");
			patMedInhospMapper.updatePatMedInhosp(pmiJB);
			// pmiJB.setDiagcheckFlag("1");
			// patMedInhospMapper.updatePatMedInhosp(pmiJB);
			}

			} catch (Exception e) {
			@@ -388,6 +388,149 @@
			}
			return 1;
			}

			/**
			* 多维度随访
			* @param config
			* @return
			*/
			public int dealOutHospInfoByDimension(String config) {
			// 一次性查出所有需要处理的出院患者（三个维度任意一个未完成）
			List<PatMedInhosp> patList = patMedInhospMapper.selectNeedProcessList();
			log.info("【统一扫描】待处理患者数：{}", patList.size());

			for (PatMedInhosp patMedInhosp1 : patList) {
			PatArchive patArchive = patArchiveMapper.selectPatArchiveByPatid(patMedInhosp1.getPatid());
			if (Objects.isNull(patArchive)) {
			// 三个维度都标记为失败
			markAllFlagsAsError(patMedInhosp1, "患者基本信息为空");
			continue;
			}

			// ── 维度1：科室 ──
			if ("0".equals(patMedInhosp1.getDeptcheckFlag())) {
			processTasksByDimension(patMedInhosp1, patArchive, config, 1);
			}

			// ── 维度2：病区 ──（新华医院跳过）
			if (!active.equals("xh") && "0".equals(patMedInhosp1.getWardcheckFlag())) {
			processTasksByDimension(patMedInhosp1, patArchive, config, 2);
			}

			// ── 维度3：疾病 ──（新华医院跳过）
			if (!active.equals("xh") && "0".equals(patMedInhosp1.getDiagcheckFlag())) {
			processTasksByDimension(patMedInhosp1, patArchive, config, 3);
			}
			}
			return 1;
			}

			/**
			* 按维度找到所有匹配长期任务，批量生成 subtask
			* type: 1=科室, 2=病区, 3=疾病
			*/
			private void processTasksByDimension(PatMedInhosp patMedInhosp1,
			PatArchive patArchive,
			String config, int type) {
			List<Long> matchedTaskIds = findMatchingTaskIds(patMedInhosp1, type);

			if (CollectionUtils.isEmpty(matchedTaskIds)) {
			String reason = getDimensionReason(type);
			markFlagAsNoConfig(patMedInhosp1, type, reason);
			return;
			}

			// 一条 inhosp 记录 → 多个匹配任务 → 多条 subtask
			for (Long taskId : matchedTaskIds) {
			writeInSubTask(taskId, true, patMedInhosp1, patArchive, type, config);
			}
			}

			private String getDimensionReason(int type){
			switch (type) {
			case 1: { // 科室
			return "未找到科室匹配的长期任务";
			}
			case 2: { // 病区
			return "未找到病区匹配的长期任务";
			}
			case 3: { // 疾病
			return "未找到疾病匹配的长期任务";
			}
			}
			return "多维长期任务-匹配类型为空";
			}

			private void markFlagAsNoConfig(PatMedInhosp patMedInhosp,
			int type,
			String reason){
			switch (type) {
			case 1: { // 科室
			patMedInhosp.setDeptcheckFlag("2");
			patMedInhosp.setRemark(reason);
			patMedInhospMapper.updatePatMedInhosp(patMedInhosp);
			break;
			}
			case 2: { // 病区
			patMedInhosp.setWardcheckFlag("2");
			patMedInhosp.setRemark(reason);
			patMedInhospMapper.updatePatMedInhosp(patMedInhosp);
			break;
			}
			case 3: { // 疾病
			patMedInhosp.setDiagcheckFlag("2");
			patMedInhosp.setRemark(reason);
			patMedInhospMapper.updatePatMedInhosp(patMedInhosp);
			break;
			}
			}

			}

			private void markAllFlagsAsError(PatMedInhosp patMedInhosp,
			String reason){
			patMedInhosp.setDeptcheckFlag("2");
			patMedInhosp.setWardcheckFlag("2");
			patMedInhosp.setDiagcheckFlag("2");
			patMedInhosp.setRemark(reason);
			patMedInhospMapper.updatePatMedInhosp(patMedInhosp);
			}
			/**
			* 根据维度类型查询匹配的长期任务 ID 列表
			*/
			private List<Long> findMatchingTaskIds(PatMedInhosp patMedInhosp1, int type) {
			switch (type) {
			case 1: { // 科室
			ServiceTaskdept query = new ServiceTaskdept();
			query.setLongtask(1L);
			query.setDeptCode(patMedInhosp1.getLeaveldeptcode());
			query.setDeptType("1");
			query.setOrgid(patMedInhosp1.getOrgid());
			return serviceTaskdeptMapper.selectServiceTaskdeptList(query)
			.stream().map(ServiceTaskdept::getTaskId).collect(Collectors.toList());
			}
			case 2: { // 病区
			ServiceTaskdept query = new ServiceTaskdept();
			query.setLongtask(1L);
			query.setDeptCode(patMedInhosp1.getLeavehospitaldistrictcode());
			query.setDeptType("2");
			query.setOrgid(patMedInhosp1.getOrgid());
			return serviceTaskdeptMapper.selectServiceTaskdeptList(query)
			.stream().map(ServiceTaskdept::getTaskId).collect(Collectors.toList());
			}
			case 3: { // 疾病
			if (StringUtils.isEmpty(patMedInhosp1.getLeaveicd10code())) return Collections.emptyList();
			ServiceTaskdiag query = new ServiceTaskdiag();
			query.setLongtask(1L);
			query.setIcd10code(patMedInhosp1.getLeaveicd10code());
			query.setOrgid(patMedInhosp1.getOrgid());
			return serviceTaskdiagMapper.selectServiceTaskdiagList(query)
			.stream().map(ServiceTaskdiag::getTaskId).collect(Collectors.toList());
			}
			}
			return Collections.emptyList();
			}


			//
			// @Override
			@@ -547,16 +690,26 @@
			return calendar.getTime();
			}

			/**
			*
			* @param taskid 任务id
			* @param check 是否需要校验
			* @param patMedInhosp1 病人出入院信息
			* @param patArchive 病人信息
			* @param type 随访类型(1-科室，2-病区，3-疾病）
			* @param config 配置信息 visit.early.day
			*/
			//将患者放到subtask中
			private void writeInSubTask(Long taskid, Boolean check, PatMedInhosp patMedInhosp1, PatArchive patArchive, Integer type, String config) {
			String longTaskReason = patMedInhosp1.getLongTaskReason();
			String orgId = patMedInhosp1.getOrgid();
			if (StringUtils.isEmpty(longTaskReason)) longTaskReason = "";
			ServiceTask st = new ServiceTask();
			st.setTaskid(taskid);
			st.setSendState(2L);
			List<ServiceTask> serviceTasks = serviceTaskMapper.selectServiceTaskList(st);
			ServiceTask serviceTask = null;
			if(CollectionUtils.isEmpty(serviceTasks)){
			if (CollectionUtils.isEmpty(serviceTasks)) {
			if (type == 1) {
			log.info("该患者出院随访长期任务不存在,任务ID为：{}", taskid);
			patMedInhosp1.setDeptcheckFlag("2");
			@@ -574,7 +727,7 @@
			patMedInhospMapper.updatePatMedInhosp(patMedInhosp1);
			return;
			}
			}else {
			} else {
			serviceTask = serviceTasks.get(0);
			}
			if (Objects.isNull(patMedInhosp1.getEndtime())) {
			@@ -582,7 +735,7 @@
			}
			//封装serviceSubtask
			ServiceSubtask serviceSubtask = boxedServiceSubtask(serviceTask, patMedInhosp1, patArchive, config);
			if(ObjectUtils.isEmpty(serviceSubtask)){
			if (ObjectUtils.isEmpty(serviceSubtask)) {
			return;
			}
			if (type != 2) {
			@@ -604,7 +757,7 @@
			subtask.setSendstate(2L);
			subtask.setTaskid(taskid);
			List<ServiceSubtask> selectServiceSubtaskList = serviceSubtaskMapper.selectServiceSubtaskList(subtask);
			log.info("该患者待执行的任务:{}", CollectionUtils.isNotEmpty(selectServiceSubtaskList) ? selectServiceSubtaskList.size() : null);
			// log.info("该患者待执行的任务:{}", CollectionUtils.isNotEmpty(selectServiceSubtaskList) ? selectServiceSubtaskList.size() : null);
			if (CollectionUtils.isNotEmpty(selectServiceSubtaskList) && selectServiceSubtaskList.size() > 0) {
			for (ServiceSubtask serviceSubtask1 : selectServiceSubtaskList) {
			if (Objects.isNull(serviceSubtask1.getLongSendTime())) {
			@@ -616,7 +769,7 @@
			Date endTime = serviceSubtask.getEndtime();
			Date endTime1 = serviceSubtask1.getEndtime();
			//出院时间判空，如果为空跳过
			if(ObjectUtils.isEmpty(endTime)){
			if (ObjectUtils.isEmpty(endTime)) {
			serviceSubtask.setResult("error");
			serviceSubtask.setRemark("出院时间为空，serviceSubtask的Id为" + serviceSubtask.getId());
			serviceSubtask.setUpdateBy(serviceTask.getUpdateBy());
			@@ -625,7 +778,7 @@
			if (aBoolean) i = 1;
			continue;
			}
			if(ObjectUtils.isEmpty(endTime1)){
			if (ObjectUtils.isEmpty(endTime1)) {
			serviceSubtask1.setResult("error");
			serviceSubtask1.setRemark("出院时间为空，serviceSubtask的Id为" + serviceSubtask1.getId());
			serviceSubtask1.setUpdateBy(serviceTask.getUpdateBy());
			@@ -634,27 +787,36 @@
			if (aBoolean) i = 1;
			continue;
			}
			if (endTime1.before(endTime) && serviceSubtask1.getServiceType().equals("2")) {
			//如果当前循环的子任务的出院时间在“准备新增的子任务”的出院时间之前，则将循环的子任务停掉
			serviceSubtask1.setSendstate(4L);
			if (StringUtils.isNotEmpty(serviceSubtask.getRemark()))
			serviceSubtask.setRemark(serviceSubtask.getRemark() + ",科室/病区患者再入院");
			else serviceSubtask.setRemark("科室/病区患者再入院");
			serviceSubtask1.setResult("error");
			serviceSubtask1.setUpdateBy(serviceTask.getUpdateBy());
			serviceSubtask1.setUpdateTime(new Date());
			Boolean aBoolean = serviceSubtaskMapper.updateServiceSubtask(serviceSubtask1);
			if (aBoolean) i = 1;
			} else {
			//相反,则将当有的数据停掉
			serviceSubtask.setResult("error");
			serviceSubtask.setSendstate(4L);
			if (StringUtils.isNotEmpty(serviceSubtask.getRemark()))
			serviceSubtask.setRemark(serviceSubtask.getRemark() + ",当前患者出院时间后有待执行的出院随访长期任务");
			else serviceSubtask.setRemark("当前患者出院时间后有待执行的出院随访长期任务");
			serviceSubtask.setCreateBy(serviceTask.getCreateBy());
			serviceSubtask.setCreateTime(new Date());
			i = serviceSubtaskMapper.insertServiceSubtask(serviceSubtask);
			//再入院逻辑
			//景宁出院首次（7天）随访一定要做
			boolean firstVisit = false;
			if (orgId.equals("47255004333112711A1001") && serviceSubtask1.getVisitCount() != null && serviceSubtask1.getVisitCount() == 1) {
			firstVisit = true;
			}
			if (!firstVisit) {
			//景宁的不需要将之前的任务停掉，全生成
			if (endTime1.before(endTime) && serviceSubtask1.getServiceType().equals("2")) {
			//如果当前循环的子任务的出院时间在“准备新增的子任务”的出院时间之前，则将循环的子任务停掉
			serviceSubtask1.setSendstate(4L);
			if (StringUtils.isNotEmpty(serviceSubtask.getRemark()))
			serviceSubtask.setRemark(serviceSubtask.getRemark() + ",科室/病区患者再入院");
			else serviceSubtask.setRemark("科室/病区患者再入院");
			serviceSubtask1.setResult("error");
			serviceSubtask1.setUpdateBy(serviceTask.getUpdateBy());
			serviceSubtask1.setUpdateTime(new Date());
			Boolean aBoolean = serviceSubtaskMapper.updateServiceSubtask(serviceSubtask1);
			if (aBoolean) i = 1;
			} else {
			//相反,则将当有的数据停掉
			serviceSubtask.setResult("error");
			serviceSubtask.setSendstate(4L);
			if (StringUtils.isNotEmpty(serviceSubtask.getRemark()))
			serviceSubtask.setRemark(serviceSubtask.getRemark() + ",当前患者出院时间后有待执行的出院随访长期任务");
			else serviceSubtask.setRemark("当前患者出院时间后有待执行的出院随访长期任务");
			serviceSubtask.setCreateBy(serviceTask.getCreateBy());
			serviceSubtask.setCreateTime(new Date());
			i = serviceSubtaskMapper.insertServiceSubtask(serviceSubtask);
			}
			}
			} else if (type == 3) {
			//type=3 表示疾病
			@@ -707,14 +869,14 @@
			}

			//将check_flag改成1（已处理）
			if(i == 1){
			if (i == 1) {
			PatMedInhosp patMedInhosp2 = new PatMedInhosp();
			patMedInhosp2.setInhospid(patMedInhosp1.getInhospid());
			if (type == 1) patMedInhosp2.setDeptcheckFlag("1");
			if (type == 2) patMedInhosp2.setWardcheckFlag("1");
			if (type == 3) patMedInhosp2.setDiagcheckFlag("1");
			patMedInhospMapper.updatePatMedInhosp(patMedInhosp2);
			}else {
			} else {
			//生成子任务失败，
			log.info("生成子任务失败serviceSubtask的taskid为：{},patid为：{}", serviceSubtask.getTaskid(), serviceSubtask.getPatid());
			PatMedInhosp patMedInhosp2 = new PatMedInhosp();
			@@ -824,6 +986,9 @@
			if (!Objects.isNull(patMedInhosp1.getEndtime())) {
			newDate = addDays(patMedInhosp1.getEndtime(), serviceTask.getSendDay().intValue());
			} else {
			patMedInhosp1.setDeptcheckFlag("2");
			patMedInhosp1.setRemark(patMedInhosp1.getRemark() + "& 该患者疾病出院时间为空,出院记录ID为:" + patMedInhosp1.getInhospid());
			patMedInhospMapper.updatePatMedInhosp(patMedInhosp1);
			//如果出院时间为空，则返回一个新对象
			return new ServiceSubtask();
			}
			@@ -835,13 +1000,11 @@
			if ("3".equals(serviceTask.getType())) {
			serviceSubtask.setVisitTime(minusDay(newDate, StringUtils.isNotEmpty(config) ? Integer.parseInt(config) : 0));
			//如果该出院记录有随访时间，则用他自己的随访时间
			if (patMedInhosp1.getFudate() != null){
			serviceSubtask.setVisitTime(minusDay(patMedInhosp1.getFudate(),
			StringUtils.isNotEmpty(config) ? Integer.parseInt(config) : 0));
			}else{
			if (patMedInhosp1.getFudate() != null) {
			serviceSubtask.setVisitTime(minusDay(patMedInhosp1.getFudate(), StringUtils.isNotEmpty(config) ? Integer.parseInt(config) : 0));
			} else {
			//判断是不是景宁
			if (patMedInhosp1.getOrgid().equals("47255004333112711A1001"))
			{
			if (patMedInhosp1.getOrgid().equals("47255004333112711A1001")) {
			serviceSubtask.setVisitTime(null);
			//不执行
			serviceSubtask.setSendstate(4L);