LAPP_GAAS_GFrame_BACKEND/web/models/task_log_model.go

package models

import (
	"LAPP_GAAS_GFrame_BACKEND/db"
	"time"
	"github.com/go-xorm/xorm"
)

type TaskType int8

// 任务执行日志
type TaskLog struct {
	Id         int64        `json:"id" xorm:"bigint pk autoincr"`
	TaskId     int          `json:"task_id" xorm:"int notnull index default 0"`       // 任务id
	Name       string       `json:"name" xorm:"varchar(32) notnull"`                  // 任务名称
	Spec       string       `json:"spec" xorm:"varchar(64) notnull"`                  // crontab
	Protocol   TaskProtocol `json:"protocol" xorm:"tinyint notnull index"`            // 协议 1:http 2:RPC
	Command    string       `json:"command" xorm:"varchar(256) notnull"`              // URL地址或shell命令
	Timeout    int          `json:"timeout" xorm:"mediumint notnull default 0"`       // 任务执行超时时间(单位秒),0不限制
	RetryTimes int8         `json:"retry_times" xorm:"tinyint notnull default 0"`     // 任务重试次数
	Hostname   string       `json:"hostname" xorm:"varchar(128) notnull default '' "` // RPC主机名，逗号分隔
	StartTime  time.Time    `json:"start_time" xorm:"datetime created"`               // 开始执行时间
	EndTime    time.Time    `json:"end_time" xorm:"datetime updated"`                 // 执行完成（失败）时间
	Status     Status       `json:"status" xorm:"tinyint notnull index default 1"`    // 状态 0:执行失败 1:执行中  2:执行完毕 3:任务取消(上次任务未执行完成) 4:异步执行
	Result     string       `json:"result" xorm:"mediumtext notnull "`                // 执行结果
	TotalTime  int          `json:"total_time" xorm:"-"`                              // 执行总时长
}

func (taskLog *TaskLog) Create() (insertId int64, err error) {
	e := db.Eloquent.Master()
	_, err = e.Insert(taskLog)
	if err == nil {
		insertId = taskLog.Id
	}

	return
}

// 更新
func (taskLog *TaskLog) Update(id int64, data CommonMap) (int64, error) {
	e := db.Eloquent.Master()
	return e.Table(taskLog).ID(id).Update(data)
}

func (taskLog *TaskLog) List(params CommonMap,pageSize int, pageIndex int) ([]TaskLog, error) {
	e := db.Eloquent.Master()
	Offset := (pageIndex - 1) * pageSize
	list := make([]TaskLog, 0)
	session := e.Desc("id")
	taskLog.parseWhere(session, params)
	err := session.Limit(pageSize, Offset).Find(&list)
	if len(list) > 0 {
		for i, item := range list {
			endTime := item.EndTime
			if item.Status == Running {
				endTime = time.Now()
			}
			execSeconds := endTime.Sub(item.StartTime).Seconds()
			list[i].TotalTime = int(execSeconds)
		}
	}

	return list, err
}

// 清空表
func (taskLog *TaskLog) Clear() (int64, error) {
	e := db.Eloquent.Master()
	return e.Where("1=1").Delete(taskLog)
}

// 删除N个月前的日志
func (taskLog *TaskLog) Remove(id int) (int64, error) {
	e := db.Eloquent.Master()
	t := time.Now().AddDate(0, -id, 0)
	return e.Where("start_time <= ?", t.Format(DefaultTimeFormat)).Delete(taskLog)
}

func (taskLog *TaskLog) Total(params CommonMap) (int64, error) {
	e := db.Eloquent.Master()
	session := e.NewSession()
	defer session.Close()
	taskLog.parseWhere(session, params)
	return session.Count(taskLog)
}

// 解析where
func (taskLog *TaskLog) parseWhere(session *xorm.Session, params CommonMap) {
	if len(params) == 0 {
		return
	}
	taskId, ok := params["TaskId"]
	if ok && taskId.(int) > 0 {
		session.And("task_id = ?", taskId)
	}
	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)
	}
}