| | |
|---|
| | | 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; |
|---|
| | |
|---|
| | | //任务发送记录 |
|---|
| | | 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"); |
|---|
| | |
|---|
| | | 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 兜底 |
|---|
| | |
|---|
| | | * 处理超时随访任务 |
|---|
| | | * <p> |
|---|
| | | * 扫描「出院满 deadlineDay 天仍未完成」的首次随访任务（sendstate=7 + visit_count=1）， |
|---|
| | | * 按当前任务的 nexttaskid 生成再次随访任务，科室按源任务 visitType 选择。 |
|---|
| | | * 按当前任务的 nexttaskid 生成再次随访任务，科室固定为随访中心科室。 |
|---|
| | | * <p> |
|---|
| | | * 注意：截止时间必须在循环外计算一次。历史实现把 {@code deadlineDay = -deadlineDay} |
|---|
| | | * 写在循环体内，每轮取反一次，导致偶数轮用「今天 + deadlineDay」做截止时间， |
|---|
