/**
 * BladeX Commercial License Agreement
 * Copyright (c) 2018-2099, https://bladex.cn. All rights reserved.
 * <p>
 * Use of this software is governed by the Commercial License Agreement
 * obtained after purchasing a license from BladeX.
 * <p>
 * 1. This software is for development use only under a valid license
 * from BladeX.
 * <p>
 * 2. Redistribution of this software's source code to any third party
 * without a commercial license is strictly prohibited.
 * <p>
 * 3. Licensees may copyright their own code but cannot use segments
 * from this software for such purposes. Copyright of this software
 * remains with BladeX.
 * <p>
 * Using this software signifies agreement to this License, and the software
 * must not be used for illegal purposes.
 * <p>
 * THIS SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY. The author is
 * not liable for any claims arising from secondary or illegal development.
 * <p>
 * Author: Chill Zhuang (bladejava@qq.com)
 */
package org.springblade.job.pojo.entity;

import com.baomidou.mybatisplus.annotation.TableName;
import io.swagger.v3.oas.annotations.media.Schema;
import lombok.Data;
import lombok.EqualsAndHashCode;
import org.springblade.core.mp.base.BaseEntity;

import java.io.Serial;
import java.math.BigDecimal;

/**
 * 任务信息表 实体类
 *
 * @author BladeX
 */
@Data
@TableName("blade_job_info")
@EqualsAndHashCode(callSuper = true)
@Schema(description = "任务信息表")
public class JobInfo extends BaseEntity {

	@Serial
	private static final long serialVersionUID = 1L;

	/**
	 * 任务服务ID
	 */
	@Schema(description = "任务服务ID")
	private Long jobServerId;
	/**
	 * 任务 ID，可选，null 代表创建任务，否则填写需要修改的任务 ID
	 */
	@Schema(description = "任务 ID，可选，null 代表创建任务，否则填写需要修改的任务 ID")
	private Long jobId;
	/**
	 * 任务名称
	 */
	@Schema(description = "任务名称")
	private String jobName;
	/**
	 * 任务描述
	 */
	@Schema(description = "任务描述")
	private String jobDescription;
	/**
	 * 任务参数，Processor#process 方法入参 TaskContext 对象的 jobParams 字段
	 */
	@Schema(description = "任务参数，Processor#process 方法入参 TaskContext 对象的 jobParams 字段")
	private String jobParams;
	/**
	 * 时间表达式类型，枚举值
	 */
	@Schema(description = "时间表达式类型，枚举值")
	private Integer timeExpressionType;
	/**
	 * 时间表达式，填写类型由 timeExpressionType 决定，比如 CRON 需要填写 CRON 表达式
	 */
	@Schema(description = "时间表达式，填写类型由 timeExpressionType 决定，比如 CRON 需要填写 CRON 表达式")
	private String timeExpression;
	/**
	 * 执行类型，枚举值
	 */
	@Schema(description = "执行类型，枚举值")
	private Integer executeType;
	/**
	 * 处理器类型，枚举值
	 */
	@Schema(description = "处理器类型，枚举值")
	private Integer processorType;
	/**
	 * 处理器参数，填写类型由 processorType 决定，如Java 处理器需要填写全限定类名，如：com.github.kfcfans.oms.processors.demo.MapReduceProcessorDemo
	 */
	@Schema(description = "处理器参数，填写类型由 processorType 决定，如Java 处理器需要填写全限定类名，如：com.github.kfcfans.oms.processors.demo.MapReduceProcessorDemo")
	private String processorInfo;
	/**
	 * 最大实例数，该任务同时执行的数量（任务和实例就像是类和对象的关系，任务被调度执行后被称为实例）
	 */
	@Schema(description = "最大实例数，该任务同时执行的数量（任务和实例就像是类和对象的关系，任务被调度执行后被称为实例）")
	private Integer maxInstanceNum;
	/**
	 * 单机线程并发数，表示该实例执行过程中每个Worker 使用的线程数量
	 */
	@Schema(description = "单机线程并发数，表示该实例执行过程中每个Worker 使用的线程数量")
	private Integer concurrency;
	/**
	 * 任务实例运行时间限制，0 代表无任何限制，超时会被打断并判定为执行失败
	 */
	@Schema(description = "任务实例运行时间限制，0 代表无任何限制，超时会被打断并判定为执行失败")
	private Long instanceTimeLimit;
	/**
	 * instanceRetryNum	任务实例重试次数，整个任务失败时重试，代价大，不推荐使用
	 */
	@Schema(description = "instanceRetryNum	任务实例重试次数，整个任务失败时重试，代价大，不推荐使用")
	private Integer instanceRetryNum;
	/**
	 * taskRetryNum	Task 重试次数，每个子 Task 失败后单独重试，代价小，推荐使用
	 */
	@Schema(description = "taskRetryNum	Task 重试次数，每个子 Task 失败后单独重试，代价小，推荐使用")
	private Integer taskRetryNum;
	/**
	 * minCpuCores	最小可用 CPU 核心数，CPU 可用核心数小于该值的 Worker 将不会执行该任务，0 代表无任何限制
	 */
	@Schema(description = "minCpuCores	最小可用 CPU 核心数，CPU 可用核心数小于该值的 Worker 将不会执行该任务，0 代表无任何限制")
	private BigDecimal minCpuCores;
	/**
	 * 最小内存大小（GB），可用内存小于该值的Worker 将不会执行该任务，0 代表无任何限制
	 */
	@Schema(description = "最小内存大小（GB），可用内存小于该值的Worker 将不会执行该任务，0 代表无任何限制")
	private BigDecimal minMemorySpace;
	/**
	 * 最小磁盘大小（GB），可用磁盘空间小于该值的Worker 将不会执行该任务，0 代表无任何限制
	 */
	@Schema(description = "最小磁盘大小（GB），可用磁盘空间小于该值的Worker 将不会执行该任务，0 代表无任何限制")
	private BigDecimal minDiskSpace;
	/**
	 * 指定机器执行，设置该参数后只有列表中的机器允许执行该任务，空代表不指定机器
	 */
	@Schema(description = "指定机器执行，设置该参数后只有列表中的机器允许执行该任务，空代表不指定机器")
	private String designatedWorkers;
	/**
	 * 最大执行机器数量，限定调动执行的机器数量，0代表无限制
	 */
	@Schema(description = "最大执行机器数量，限定调动执行的机器数量，0代表无限制")
	private Integer maxWorkerCount;
	/**
	 * 接收报警的用户 ID 列表
	 */
	@Schema(description = "接收报警的用户 ID 列表")
	private String notifyUserIds;
	/**
	 * 是否启用该任务，未启用的任务不会被调度
	 */
	@Schema(description = "是否启用该任务，未启用的任务不会被调度")
	private Integer enable;
	/**
	 * 调度策略，枚举，目前支持随机（RANDOM）和 健康度优先（HEALTH_FIRST）
	 */
	@Schema(description = "调度策略，枚举，目前支持随机（RANDOM）和 健康度优先（HEALTH_FIRST）")
	private Integer dispatchStrategy;
	/**
	 * lifecycle	生命周期（预留，用于指定定时调度任务的生效时间范围）
	 */
	@Schema(description = "lifecycle	生命周期（预留，用于指定定时调度任务的生效时间范围）")
	private String lifecycle;
	/**
	 * 错误阈值，0代表不限制
	 */
	@Schema(description = "错误阈值，0代表不限制")
	private Integer alertThreshold;
	/**
	 * 统计的窗口长度(s)，0代表不限制
	 */
	@Schema(description = "统计的窗口长度(s)，0代表不限制")
	private Integer statisticWindowLen;
	/**
	 * 沉默时间窗口(s)，0代表不限制
	 */
	@Schema(description = "沉默时间窗口(s)，0代表不限制")
	private Integer silenceWindowLen;
	/**
	 * 日志配置
	 */
	@Schema(description = "日志配置")
	private Integer logType;
	/**
	 * 日志配置
	 */
	@Schema(description = "日志级别")
	private Integer logLevel;
	/**
	 * 扩展字段（供开发者使用，用于功能扩展，powerjob 自身不会使用该字段）
	 */
	@Schema(description = "扩展字段（供开发者使用，用于功能扩展，powerjob 自身不会使用该字段）")
	private String extra;

}