| | |
|---|
| | | 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 兜底 |
|---|
