作者 tangxvhui

日常保存

@@ -26,6 +26,7 @@ type Task struct { @@ -26,6 +26,7 @@ type Task struct {
26 RelatedUser []int `json:"relatedUser"` // 相关的员工id 26 RelatedUser []int `json:"relatedUser"` // 相关的员工id
27 RunAt int64 `json:"runAt"` // 启动的时间戳,秒 27 RunAt int64 `json:"runAt"` // 启动的时间戳,秒
28 StopAt int64 `json:"stopAt"` // 停止的时间戳,秒 28 StopAt int64 `json:"stopAt"` // 停止的时间戳,秒
  29 + Anomaly int `json:"anomaly"` //异常反馈的次数
29 } 30 }
30 31
31 type TaskLeader struct { 32 type TaskLeader struct {
@@ -23,4 +23,5 @@ type Task struct { @@ -23,4 +23,5 @@ type Task struct {
23 RelatedUser []int `pg:"related_user"` // 23 RelatedUser []int `pg:"related_user"` //
24 RunAt int64 `pg:"run_at"` // 启动的时间 24 RunAt int64 `pg:"run_at"` // 启动的时间
25 StopAt int64 `pg:"stop_at"` // 停止的时间 25 StopAt int64 `pg:"stop_at"` // 停止的时间
  26 + Anomaly int `json:"anomaly"` // 异常反馈的数量
26 } 27 }
@@ -29,6 +29,7 @@ func (repo *TaskRepository) TransformToDomain(d *models.Task) *domain.Task { @@ -29,6 +29,7 @@ func (repo *TaskRepository) TransformToDomain(d *models.Task) *domain.Task {
29 CreatedAt: d.CreatedAt, 29 CreatedAt: d.CreatedAt,
30 UpdatedAt: d.UpdatedAt, 30 UpdatedAt: d.UpdatedAt,
31 DeletedAt: d.DeletedAt, 31 DeletedAt: d.DeletedAt,
  32 + CompanyId: d.CompanyId,
32 Name: d.Name, 33 Name: d.Name,
33 Alias: d.Alias, 34 Alias: d.Alias,
34 Leader: d.Leader, 35 Leader: d.Leader,
@@ -38,7 +39,7 @@ func (repo *TaskRepository) TransformToDomain(d *models.Task) *domain.Task { @@ -38,7 +39,7 @@ func (repo *TaskRepository) TransformToDomain(d *models.Task) *domain.Task {
38 RelatedUser: d.RelatedUser, 39 RelatedUser: d.RelatedUser,
39 RunAt: d.RunAt, 40 RunAt: d.RunAt,
40 StopAt: d.StopAt, 41 StopAt: d.StopAt,
41 - CompanyId: d.CompanyId, 42 + Anomaly: d.Anomaly,
42 } 43 }
43 } 44 }
44 45
@@ -62,6 +63,7 @@ func (repo *TaskRepository) Save(param *domain.Task) error { @@ -62,6 +63,7 @@ func (repo *TaskRepository) Save(param *domain.Task) error {
62 RunAt: param.RunAt, 63 RunAt: param.RunAt,
63 CompanyId: param.CompanyId, 64 CompanyId: param.CompanyId,
64 StopAt: param.StopAt, 65 StopAt: param.StopAt,
  66 + Anomaly: param.Anomaly,
65 } 67 }
66 db := repo.transactionContext.PgTx 68 db := repo.transactionContext.PgTx
67 if m.Id == 0 { 69 if m.Id == 0 {