package tech.powerjob.common.model;

import lombok.Data;
import lombok.NoArgsConstructor;
import tech.powerjob.common.PowerSerializable;

import java.util.List;

/**
 * Detailed info of job instances.
 *
 * @author tjq
 * @since 2020/4/11
 */
@Data
@NoArgsConstructor
public class InstanceDetail implements PowerSerializable {

    /**
     * Expected trigger time.
     */
    private Long expectedTriggerTime;
    /**
     * Actual trigger time of an instance.
     */
    private Long actualTriggerTime;
    /**
     * Finish time of an instance, which may be null.
     */
    private Long finishedTime;
    /**
     * Status of the task instance.
     */
    private Integer status;
    /**
     * Execution result, which may be null.
     */
    private String result;
    /**
     * Task tracker address.
     */
    private String taskTrackerAddress;
    /**
     * 任务参数
     */
    private String jobParams;
    /**
     * Param string that is passed to an instance when it is initialized.
     */
    private String instanceParams;

    /**
     * Task detail, used by MapReduce or Broadcast tasks.
     * 命名有点问题，实际是 task 统计信息
     */
    private TaskDetail taskDetail;

    /**
     * 查询出来的 Task 详细结果
     */
    private List<TaskDetailInfo> queriedTaskDetailInfoList;

    /**
     * Sub instance details, used by frequent tasks.
     */
    private List<SubInstanceDetail> subInstanceDetails;

    /**
     * Running times.
     */
    private Long runningTimes;

    /**
     * Extended fields. Middlewares are not supposed to update frequently.
     * Changes in PowerJob-common may lead to incompatible versions.
     * PowerJob-common packages should not be modified if not necessary.
     */
    private String extra;

    /**
     * Extra info for frequent tasks, return List<SubInstanceDetail>.
     */
    @Data
    @NoArgsConstructor
    public static class SubInstanceDetail implements PowerSerializable {
        private long subInstanceId;
        private Long startTime;
        private Long finishedTime;
        private String result;
        private int status;
    }

    /**
     * Extra info of {@code MapReduce} or {@code Broadcast} type of tasks.
     */
    @Data
    @NoArgsConstructor
    public static class TaskDetail implements PowerSerializable {
        private long totalTaskNum;
        private long succeedTaskNum;
        private long failedTaskNum;

        // 等待派发状态（仅存在 TaskTracker 数据库中）
        protected Long waitingDispatchTaskNum;
        // 已派发，但 ProcessorTracker 未确认，可能由于网络错误请求未送达，也有可能 ProcessorTracker 线程池满，拒绝执行
        protected Long workerUnreceivedTaskNum;
        // ProcessorTracker确认接收，存在与线程池队列中，排队执行
        protected Long receivedTaskNum;
        // ProcessorTracker正在执行
        protected Long runningTaskNum;
    }
}