[dev] rich the InstanceDetail to support delay job

This commit is contained in:
朱八 2020-07-25 13:11:27 +08:00
parent 83ad854655
commit e9765ec1f2
6 changed files with 13 additions and 8 deletions

View File

@ -16,6 +16,8 @@ import java.util.List;
@NoArgsConstructor
public class InstanceDetail implements OmsSerializable {
// 任务预计执行时间
private Long expectedTriggerTime;
// 任务整体开始时间
private Long actualTriggerTime;
// 任务整体结束时间可能不存在

View File

@ -192,6 +192,6 @@ public class InstanceStatusCheckService {
instance.setResult(SystemInstanceResult.REPORT_TIMEOUT);
instanceInfoRepository.saveAndFlush(instance);
instanceManager.processFinishedInstance(instance.getInstanceId(), instance.getWfInstanceId(), InstanceStatus.FAILED, "timeout, maybe TaskTracker down!");
instanceManager.processFinishedInstance(instance.getInstanceId(), instance.getWfInstanceId(), InstanceStatus.FAILED, SystemInstanceResult.REPORT_TIMEOUT);
}
}

View File

@ -22,6 +22,8 @@ import java.util.List;
@NoArgsConstructor
public class InstanceDetailVO {
// 任务预计执行时间
private String expectedTriggerTime;
// 任务整体开始时间
private String actualTriggerTime;
// 任务整体结束时间可能不存在
@ -68,6 +70,7 @@ public class InstanceDetailVO {
// 格式化时间
vo.setFinishedTime(CommonUtils.formatTime(origin.getFinishedTime()));
vo.setActualTriggerTime(CommonUtils.formatTime(origin.getActualTriggerTime()));
vo.setExpectedTriggerTime(CommonUtils.formatTime(origin.getExpectedTriggerTime()));
// 拷贝 TaskDetail
if (origin.getTaskDetail() != null) {

File diff suppressed because one or more lines are too long

File diff suppressed because one or more lines are too long

File diff suppressed because one or more lines are too long