fix: insert default time
This commit is contained in:
@@ -43,6 +43,7 @@ func (s *TaskLogService) CreateEmptyLog(taskID string, command string) (*models.
|
||||
Command: command,
|
||||
Status: "running",
|
||||
StartTime: &startTime,
|
||||
CreatedAt: models.Now(),
|
||||
}
|
||||
if err := database.DB.Create(taskLog).Error; err != nil {
|
||||
return nil, err
|
||||
@@ -57,6 +58,9 @@ func (s *TaskLogService) SaveTaskLog(taskLog *models.TaskLog) error {
|
||||
err = database.DB.Model(taskLog).Where("id = ?", taskLog.ID).Updates(taskLog).Error
|
||||
} else {
|
||||
taskLog.ID = utils.GenerateID()
|
||||
if taskLog.CreatedAt.Time().IsZero() {
|
||||
taskLog.CreatedAt = models.Now()
|
||||
}
|
||||
err = database.DB.Create(taskLog).Error
|
||||
}
|
||||
|
||||
@@ -155,15 +159,16 @@ func (s *TaskLogService) CreateTaskLogFromAgentResult(result *models.AgentTaskRe
|
||||
}
|
||||
|
||||
taskLog := &models.TaskLog{
|
||||
ID: utils.GenerateID(),
|
||||
TaskID: result.TaskID,
|
||||
AgentID: &result.AgentID,
|
||||
Command: result.Command,
|
||||
Output: compressed,
|
||||
Error: result.Error,
|
||||
Status: result.Status,
|
||||
Duration: result.Duration,
|
||||
ExitCode: result.ExitCode,
|
||||
ID: utils.GenerateID(),
|
||||
TaskID: result.TaskID,
|
||||
AgentID: &result.AgentID,
|
||||
Command: result.Command,
|
||||
Output: compressed,
|
||||
Error: result.Error,
|
||||
Status: result.Status,
|
||||
Duration: result.Duration,
|
||||
ExitCode: result.ExitCode,
|
||||
CreatedAt: models.Now(),
|
||||
}
|
||||
|
||||
// 处理开始和结束时间
|
||||
@@ -209,6 +214,7 @@ func (s *TaskLogService) CreateTaskLogFromLocalExecution(taskID string, command,
|
||||
ExitCode: exitCode,
|
||||
StartTime: &startTime,
|
||||
EndTime: &endTime,
|
||||
CreatedAt: models.Now(),
|
||||
}
|
||||
|
||||
return taskLog, nil
|
||||
|
||||
@@ -21,24 +21,26 @@ func (ts *TaskService) CreateTask(name, command, schedule string, timeout int, w
|
||||
triggerType = constant.TriggerTypeCron
|
||||
}
|
||||
task := &models.Task{
|
||||
ID: utils.GenerateID(),
|
||||
Name: name,
|
||||
Command: command,
|
||||
Tags: tags,
|
||||
Type: taskType,
|
||||
TriggerType: triggerType,
|
||||
Config: config,
|
||||
Schedule: schedule,
|
||||
Timeout: timeout,
|
||||
WorkDir: workDir,
|
||||
CleanConfig: cleanConfig,
|
||||
Envs: envs,
|
||||
ID: utils.GenerateID(),
|
||||
Name: name,
|
||||
Command: command,
|
||||
Tags: tags,
|
||||
Type: taskType,
|
||||
TriggerType: triggerType,
|
||||
Config: config,
|
||||
Schedule: schedule,
|
||||
Timeout: timeout,
|
||||
WorkDir: workDir,
|
||||
CleanConfig: cleanConfig,
|
||||
Envs: envs,
|
||||
Languages: languages,
|
||||
AgentID: agentID,
|
||||
Enabled: true,
|
||||
RetryCount: retryCount,
|
||||
RetryInterval: retryInterval,
|
||||
RandomRange: randomRange,
|
||||
CreatedAt: models.Now(),
|
||||
UpdatedAt: models.Now(),
|
||||
}
|
||||
if triggerType != constant.TriggerTypeCron {
|
||||
task.NextRun = nil
|
||||
@@ -111,11 +113,27 @@ func (ts *TaskService) UpdateTask(id string, name, command, schedule string, tim
|
||||
if triggerType != "" {
|
||||
task.TriggerType = triggerType
|
||||
}
|
||||
if task.TriggerType != constant.TriggerTypeCron {
|
||||
task.NextRun = nil
|
||||
updates := map[string]interface{}{
|
||||
"name": name,
|
||||
"command": command,
|
||||
"tags": tags,
|
||||
"schedule": schedule,
|
||||
"timeout": timeout,
|
||||
"work_dir": workDir,
|
||||
"clean_config": cleanConfig,
|
||||
"envs": envs,
|
||||
"enabled": enabled,
|
||||
"agent_id": agentID,
|
||||
"languages": languages,
|
||||
"retry_count": retryCount,
|
||||
"retry_interval": retryInterval,
|
||||
"random_range": randomRange,
|
||||
"type": task.Type,
|
||||
"trigger_type": task.TriggerType,
|
||||
"next_run": task.NextRun,
|
||||
"config": config,
|
||||
}
|
||||
task.Config = config
|
||||
database.DB.Save(&task)
|
||||
database.DB.Model(&task).Updates(updates)
|
||||
return &task
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user