package tech.powerjob.worker.pojo.converter;
|
|
import tech.powerjob.common.model.TaskDetailInfo;
|
import tech.powerjob.common.serialize.JsonUtils;
|
import tech.powerjob.common.serialize.SerializerUtils;
|
import tech.powerjob.worker.common.constants.TaskStatus;
|
import tech.powerjob.worker.persistence.TaskDO;
|
|
/**
|
* 任务相关的对象转换
|
*
|
* @author tjq
|
* @since 2024/2/25
|
*/
|
public class TaskConverter {
|
|
public static TaskDetailInfo taskDo2TaskDetail(TaskDO taskDO) {
|
TaskDetailInfo taskDetailInfo = new TaskDetailInfo();
|
taskDetailInfo.setTaskId(taskDO.getTaskId())
|
.setTaskName(taskDO.getTaskName())
|
.setStatus(taskDO.getStatus())
|
.setStatusStr(TaskStatus.of(taskDetailInfo.getStatus()).getSimplyDesc())
|
.setResult(taskDO.getResult())
|
.setFailedCnt(taskDO.getFailedCnt())
|
.setProcessorAddress(taskDO.getAddress())
|
.setCreatedTime(taskDO.getCreatedTime())
|
.setLastModifiedTime(taskDO.getLastModifiedTime())
|
.setLastReportTime(taskDO.getLastReportTime());
|
|
try {
|
taskDetailInfo.setTaskContent(JsonUtils.toJSONString(SerializerUtils.deSerialized(taskDO.getTaskContent())));
|
} catch (Exception ignore) {
|
}
|
|
return taskDetailInfo;
|
}
|
}
|