package models import ( "LAPP_GAAS_GFrame_BACKEND/db" "errors" "strings" "time" "github.com/go-xorm/xorm" ) type TaskProtocol int8 const ( TaskHTTP TaskProtocol = iota + 1 // HTTP协议 TaskRPC // RPC方式执行命令 ) type TaskLevel int8 const ( TaskLevelParent TaskLevel = 1 // 父任务 TaskLevelChild TaskLevel = 2 // 子任务(依赖任务) ) type TaskDependencyStatus int8 const ( TaskDependencyStatusStrong TaskDependencyStatus = 1 // 强依赖 TaskDependencyStatusWeak TaskDependencyStatus = 2 // 弱依赖 ) type TaskHTTPMethod int8 const ( TaskHTTPMethodGet TaskHTTPMethod = 1 TaskHttpMethodPost TaskHTTPMethod = 2 ) type Status int8 type CommonMap map[string]interface{} const ( Disabled Status = 0 // 禁用 Failure Status = 0 // 失败 Enabled Status = 1 // 启用 Running Status = 1 // 运行中 Finish Status = 2 // 完成 Cancel Status = 3 // 取消 ) const DefaultTimeFormat = "2006-01-02 15:04:05" // 任务 type Task struct { Id int `json:"id" xorm:"int pk autoincr"` Name string `json:"name" xorm:"varchar(32) notnull"` // 任务名称 Level TaskLevel `json:"level" xorm:"tinyint notnull index default 1"` // 任务等级 1: 主任务 2: 依赖任务 DependencyTaskId string `json:"dependency_task_id" xorm:"varchar(64) notnull default ''"` // 依赖任务ID,多个ID逗号分隔 DependencyStatus TaskDependencyStatus `json:"dependency_status" xorm:"tinyint notnull default 1"` // 依赖关系 1:强依赖 主任务执行成功, 依赖任务才会被执行 2:弱依赖 Spec string `json:"spec" xorm:"varchar(64) notnull"` // crontab Protocol TaskProtocol `json:"protocol" xorm:"tinyint notnull index"` // 协议 1:http 2:系统命令 Command string `json:"command" xorm:"varchar(256) notnull"` // URL地址或shell命令 HttpMethod TaskHTTPMethod `json:"http_method" xorm:"tinyint notnull default 1"` // http请求方法 Timeout int `json:"timeout" xorm:"mediumint notnull default 0"` // 任务执行超时时间(单位秒),0不限制 Multi int8 `json:"multi" xorm:"tinyint notnull default 1"` // 是否允许多实例运行 RetryTimes int8 `json:"retry_times" xorm:"tinyint notnull default 0"` // 重试次数 RetryInterval int16 `json:"retry_interval" xorm:"smallint notnull default 0"` // 重试间隔时间 NotifyStatus int8 `json:"notify_status" xorm:"tinyint notnull default 1"` // 任务执行结束是否通知 0: 不通知 1: 失败通知 2: 执行结束通知 3: 任务执行结果关键字匹配通知 NotifyType int8 `json:"notify_type" xorm:"tinyint notnull default 0"` // 通知类型 1: 邮件 2: slack 3: webhook NotifyReceiverId string `json:"notify_receiver_id" xorm:"varchar(256) notnull default '' "` // 通知接受者ID, setting表主键ID,多个ID逗号分隔 NotifyKeyword string `json:"notify_keyword" xorm:"varchar(128) notnull default '' "` Tag string `json:"tag" xorm:"varchar(32) notnull default ''"` Remark string `json:"remark" xorm:"varchar(100) notnull default ''"` // 备注 Status Status `json:"status" xorm:"tinyint notnull index default 0"` // 状态 1:正常 0:停止 Created time.Time `json:"created" xorm:"datetime notnull created"` // 创建时间 Deleted time.Time `json:"deleted" xorm:"datetime deleted"` // 删除时间 Hosts []TaskHostDetail `json:"hosts" xorm:"-"` NextRunTime time.Time `json:"next_run_time" xorm:"-"` } func taskHostTableName() []string { return []string{"task_host", "th"} } // 新增 func (t *Task) Create() (insertId int, err error) { e := db.Eloquent.Master() _, err = e.Table("task").Insert(t) if err == nil { insertId = t.Id } return } func (t *Task) UpdateBean(id int) (int64, error) { e := db.Eloquent.Master() return e.ID(id). Cols(`name,spec,protocol,command,timeout,multi, retry_times,retry_interval,remark,notify_status, notify_type,notify_receiver_id, dependency_task_id, dependency_status, tag,http_method, notify_keyword`). Update(t) } // 更新 func (t *Task) Update(id int, data CommonMap) (int64, error) { e := db.Eloquent.Master() return e.Table(t).ID(id).Update(data) } // 删除 func (t *Task) Delete(id int) (int64, error) { e := db.Eloquent.Master() return e.Id(id).Delete(t) } // 禁用 func (t *Task) Disable(id int) (int64, error) { return t.Update(id, CommonMap{"status": Disabled}) } // 激活 func (t *Task) Enable(id int) (int64, error) { return t.Update(id, CommonMap{"status": Enabled}) } // 获取所有激活任务 func (t *Task) ActiveList(pageSize int, pageIndex int) ([]Task, error) { e := db.Eloquent.Master() Offset := (pageIndex - 1) * pageSize list := make([]Task, 0) err := e.Where("status = ? AND level = ?", Enabled, TaskLevelParent).Limit(pageSize, Offset). Find(&list) if err != nil { return list, err } return t.setHostsForTasks(list) } // 获取某个主机下的所有激活任务 func (t *Task) ActiveListByHostId(hostId int16) ([]Task, error) { e := db.Eloquent.Master() taskHostModel := new(TaskHost) taskIds, err := taskHostModel.GetTaskIdsByHostId(hostId) if err != nil { return nil, err } if len(taskIds) == 0 { return nil, nil } list := make([]Task, 0) err = e.Where("status = ? AND level = ?", Enabled, TaskLevelParent). In("id", taskIds...). Find(&list) if err != nil { return list, err } return t.setHostsForTasks(list) } func (t *Task) setHostsForTasks(tasks []Task) ([]Task, error) { taskHostModel := new(TaskHost) var err error for i, value := range tasks { taskHostDetails, err := taskHostModel.GetHostIdsByTaskId(value.Id) if err != nil { return nil, err } tasks[i].Hosts = taskHostDetails } return tasks, err } // 判断任务名称是否存在 func (t *Task) NameExist(name string, id int) (bool, error) { e := db.Eloquent.Master() if id > 0 { count, err := e.Where("name = ? AND status = ? AND id != ?", name, Enabled, id).Count(t) return count > 0, err } count, err := e.Where("name = ? AND status = ?", name, Enabled).Count(t) return count > 0, err } func (t *Task) GetStatus(id int) (Status, error) { e := db.Eloquent.Master() exist, err := e.Id(id).Get(t) if err != nil { return 0, err } if !exist { return 0, errors.New("not exist") } return t.Status, nil } func (t *Task) Detail(id int) (Task, error) { result := Task{} e := db.Eloquent.Master() _, err := e.Where("id=?", id).Get(&result) if err != nil { return result, err } taskHostModel := new(TaskHost) result.Hosts, err = taskHostModel.GetHostIdsByTaskId(id) return result, err } func (task *Task) List(params CommonMap,pageSize int, pageIndex int) ([]Task, error) { e := db.Eloquent.Master() Offset := (pageIndex - 1) * pageSize list := make([]Task, 0) session := e.Alias("t").Join("LEFT", taskHostTableName(), "t.id = th.task_id") task.parseWhere(session, params) err := session.GroupBy("t.id").Desc("t.id").Cols("t.*").Limit(pageSize, Offset).Find(&list) if err != nil { return nil, err } return task.setHostsForTasks(list) } // 获取依赖任务列表 func (task *Task) GetDependencyTaskList(ids string) ([]Task, error) { e := db.Eloquent.Master() list := make([]Task, 0) if ids == "" { return list, nil } idList := strings.Split(ids, ",") taskIds := make([]interface{}, len(idList)) for i, v := range idList { taskIds[i] = v } fields := "t.*" err := e.Alias("t"). Where("t.level = ?", TaskLevelChild). In("t.id", taskIds). Cols(fields). Find(&list) if err != nil { return list, err } return task.setHostsForTasks(list) } func (task *Task) Total(params CommonMap) (int64, error) { e := db.Eloquent.Master() session := e.Alias("t").Join("LEFT", taskHostTableName(), "t.id = th.task_id") task.parseWhere(session, params) list := make([]Task, 0) err := session.GroupBy("t.id").Find(&list) return int64(len(list)), err } // 解析where func (task *Task) parseWhere(session *xorm.Session, params CommonMap) { if len(params) == 0 { return } id, ok := params["Id"] if ok && id.(int) > 0 { session.And("t.id = ?", id) } hostId, ok := params["HostId"] if ok && hostId.(int) > 0 { session.And("th.host_id = ?", hostId) } name, ok := params["Name"] if ok && name.(string) != "" { session.And("t.name LIKE ?", "%"+name.(string)+"%") } protocol, ok := params["Protocol"] if ok && protocol.(int) > 0 { session.And("protocol = ?", protocol) } status, ok := params["Status"] if ok && status.(int) > -1 { session.And("status = ?", status) } tag, ok := params["Tag"] if ok && tag.(string) != "" { session.And("tag = ? ", tag) } }