smartor.git - Gitblit

			@@ -36,6 +36,7 @@
			import lombok.extern.slf4j.Slf4j;
			import org.apache.commons.collections4.CollectionUtils;
			import org.apache.commons.lang3.ObjectUtils;
			import org.apache.commons.lang3.math.NumberUtils;
			import org.springframework.beans.factory.annotation.Autowired;
			import org.springframework.beans.factory.annotation.Value;
			import org.springframework.stereotype.Component;
			@@ -940,6 +941,25 @@
			Optional<Long> currentSort = serviceSubtaskPreachforms.stream().filter(item -> serviceSubtask.getCurrentPreachform().equals(item.getPreachform())).map(ServiceSubtaskPreachform::getSort).findFirst();
			Optional<Long> id = serviceSubtaskPreachforms.stream().filter(item -> serviceSubtask.getCurrentPreachform().equals(item.getPreachform())).map(ServiceSubtaskPreachform::getId).findFirst();
			if (currentSort.isPresent()) {
			// 方案B：只处理当前子任务——公众号已领取(service_subtask.sendstate=1 + current_preachform=5)
			// 且未填写时，按默认选项完成，避免进入下一种发送方式或最后一步超时。
			// 先用内存字段快速过滤，其他医院/任务/发送方式不会进入下面的默认完成逻辑。
			if (IServiceSubtaskService.WECHAT_DEFAULT_COMPLETE_ORGID.equals(serviceSubtask.getOrgid())
			&& "2".equals(serviceSubtask.getType())
			&& "5".equals(serviceSubtask.getCurrentPreachform())
			&& Long.valueOf(1L).equals(serviceSubtask.getSendstate())
			&& !Long.valueOf(1L).equals(serviceSubtask.getSubmit())) {
			try {
			if (iServiceSubtaskService.completeWechatClaimedByDefault(serviceSubtask)) {
			log.info("【compensateTask】subid：{}，微信公众号已领取未填写，按默认选项完成", serviceSubtask.getId());
			continue;
			}
			} catch (Exception e) {
			// 单个子任务失败不影响其他任务，回滚后继续原补偿流程
			log.error("【compensateTask】微信公众号默认完成失败，subid：{}，继续原补偿流程", serviceSubtask.getId(), e);
			}
			}

			//1先检查一下，是不是有执行状态是完成的（怕之前已经有完的了，没有将servuce_subtask的状态改成功，这里再检查一下）
			boolean finishState = serviceSubtaskPreachforms.stream().allMatch(item -> item.getSendstate().equals("9"));
			if (finishState) {
			@@ -1414,6 +1434,7 @@
			//任务发送记录
			ServiceSubtaskRecord serviceSubtaskRecord = new ServiceSubtaskRecord();
			serviceSubtaskRecord.setTaskid(serviceSubtask.getTaskid().toString());
			serviceSubtaskRecord.setSubtaskId(serviceSubtask.getId());
			serviceSubtaskRecord.setUuid(UUID.randomUUID().toString());
			serviceSubtaskRecord.setTasktype(serviceSubtask.getType());
			serviceSubtaskRecord.setPreachform("4");
			@@ -1892,11 +1913,15 @@
			return false;
			}
			// 基准时刻：出院时间 + 发送日（sendDay 缺省按 1），并兜底避免 NPE/脏数据
			if (serviceSubtask.getEndtime() == null) {
			log.warn("【isSubtaskDeadline】subid：{} endtime为空，无法计算超时，按未超时处理", serviceSubtask.getId());
			return false;
			}
			ServiceTask serviceTask = serviceTaskMapper.selectServiceTaskByTaskid(serviceSubtask.getTaskid());
			int sendDay = serviceTask != null && serviceTask.getSendDay() != null ? serviceTask.getSendDay().intValue() : 1;
			Date deadline = DateUtils.addDays(serviceSubtask.getEndtime(), sendDay);
			int sumCompensateTime = CollectionUtils.isEmpty(serviceSubtaskPreachforms) ? 0 : serviceSubtaskPreachforms.stream()
			.mapToInt(x -> x.getCompensateTime() == null ? 0 : Integer.parseInt(x.getCompensateTime()))
			.mapToInt(x -> NumberUtils.toInt(x.getCompensateTime(), 0))
			.sum();
			sumCompensateTime = sumCompensateTime + 1;
			// 只补偿最后一步自身的补偿时间（天），脏值一律按 0 兜底
			@@ -1909,7 +1934,7 @@
			* 处理超时随访任务
			* <p>
			* 扫描「出院满 deadlineDay 天仍未完成」的首次随访任务（sendstate=7 + visit_count=1），
			* 按当前任务的 nexttaskid 生成再次随访任务并转到随访中心。
			* 按当前任务的 nexttaskid 生成再次随访任务，科室固定为随访中心科室。
			* <p>
			* 注意：截止时间必须在循环外计算一次。历史实现把 {@code deadlineDay = -deadlineDay}
			* 写在循环体内，每轮取反一次，导致偶数轮用「今天 + deadlineDay」做截止时间，