作者 tangxvhui

更新

@@ -84,6 +84,9 @@ func (t *Task) SetCurrentStage(stageList []*TaskStage) { @@ -84,6 +84,9 @@ func (t *Task) SetCurrentStage(stageList []*TaskStage) {
84 }) 84 })
85 t.CurrentStage = TaskStage{} 85 t.CurrentStage = TaskStage{}
86 for _, val := range stageList { 86 for _, val := range stageList {
  87 + if val.DeletedAt != nil {
  88 + continue
  89 + }
87 t.LastStage = t.CurrentStage 90 t.LastStage = t.CurrentStage
88 t.CurrentStage = *val 91 t.CurrentStage = *val
89 if val.RealCompletedAt == 0 { 92 if val.RealCompletedAt == 0 {
@@ -20,11 +20,11 @@ type Task struct { @@ -20,11 +20,11 @@ type Task struct {
20 Status int `pg:"status,use_zero"` // 任务的状态 20 Status int `pg:"status,use_zero"` // 任务的状态
21 Level int `pg:"level,use_zero"` // 优先级,值越小优先级越高 21 Level int `pg:"level,use_zero"` // 优先级,值越小优先级越高
22 LevelName string `pg:"level_name"` // 优先级名称 22 LevelName string `pg:"level_name"` // 优先级名称
23 - RelatedUser []int `pg:"related_user"` // 23 + RelatedUser []int `pg:"related_user"`
  24 + LastStage domain.TaskStage `pg:"last_stage"` // 上一个完成的里程碑
24 RunAt int64 `pg:"run_at,use_zero"` // 启动的时间 25 RunAt int64 `pg:"run_at,use_zero"` // 启动的时间
25 StopAt int64 `pg:"stop_at,use_zero" ` // 停止的时间 26 StopAt int64 `pg:"stop_at,use_zero" ` // 停止的时间
26 Anomaly int `pg:"anomaly,use_zero"` // 异常反馈的数量 27 Anomaly int `pg:"anomaly,use_zero"` // 异常反馈的数量
27 WarnFlag int `pg:"warn_flag,use_zero"` // 里程碑异常标记 28 WarnFlag int `pg:"warn_flag,use_zero"` // 里程碑异常标记
28 - CurrentStage domain.TaskStage `pg:"current_stage"` // 当前执行的里程碑  
29 - LastStage domain.TaskStage `pg:"lastStage"` // 上一个完成的里程碑 29 + CurrentStage domain.TaskStage `pg:"current_stage"`
30 } 30 }