正在显示
6 个修改的文件
包含
63 行增加
和
74 行删除
| @@ -27,6 +27,7 @@ type StaffAssess struct { | @@ -27,6 +27,7 @@ type StaffAssess struct { | ||
| 27 | CompanyId int `json:"companyId"` //公司id | 27 | CompanyId int `json:"companyId"` //公司id |
| 28 | EvaluationProjectId int `json:"evaluationProjectId"` //对应的项目id | 28 | EvaluationProjectId int `json:"evaluationProjectId"` //对应的项目id |
| 29 | CycleId int64 `json:"cycleId"` //对应的周期id | 29 | CycleId int64 `json:"cycleId"` //对应的周期id |
| 30 | + StaffAssessTaskId int `json:"staffAssessTaskId"` //执行评估的任务id | ||
| 30 | TargetUser StaffDesc `json:"targetUser"` //被评估的目标用户 | 31 | TargetUser StaffDesc `json:"targetUser"` //被评估的目标用户 |
| 31 | TargetDepartment []StaffDepartment `json:"targetDepartment"` //被评估的目标用户所在的部门 | 32 | TargetDepartment []StaffDepartment `json:"targetDepartment"` //被评估的目标用户所在的部门 |
| 32 | Executor StaffDesc `json:"executor"` //填写评估的用户 | 33 | Executor StaffDesc `json:"executor"` //填写评估的用户 |
| @@ -4,16 +4,16 @@ import "time" | @@ -4,16 +4,16 @@ import "time" | ||
| 4 | 4 | ||
| 5 | //填写的评估内容 | 5 | //填写的评估内容 |
| 6 | type StaffAssessContent struct { | 6 | type StaffAssessContent struct { |
| 7 | - Id int //id | ||
| 8 | - StaffAssessId int //用户需要的评估项id | ||
| 9 | - SortBy int //排序 | ||
| 10 | - Category string //类别 | ||
| 11 | - Title string //问题标题 | ||
| 12 | - Remark string //填写的反馈 | ||
| 13 | - Rate string //评估填写的值 | ||
| 14 | - ReteResult string //评估的结果 | ||
| 15 | - CreatedAt time.Time //数据创建时间 | ||
| 16 | - UpdatedAt time.Time //数据更新时间 | 7 | + Id int `json:"id"` //id |
| 8 | + StaffAssessId int `json:"staffAssessId"` //用户需要的评估项id | ||
| 9 | + SortBy int `json:"sortBy"` //排序 | ||
| 10 | + Category string `json:"category"` //类别 | ||
| 11 | + Title string `json:"title"` //问题标题 | ||
| 12 | + Remark string `json:"remark"` //填写的反馈 | ||
| 13 | + Rate string `json:"rate"` //评估填写的值 | ||
| 14 | + ReteResult string `json:"reteResult"` //评估的结果 | ||
| 15 | + CreatedAt time.Time `json:"createdAt"` //数据创建时间 | ||
| 16 | + UpdatedAt time.Time `json:"updatedAt"` //数据更新时间 | ||
| 17 | //TODO | 17 | //TODO |
| 18 | } | 18 | } |
| 19 | 19 |
| @@ -17,19 +17,17 @@ const ( | @@ -17,19 +17,17 @@ const ( | ||
| 17 | 17 | ||
| 18 | // 执行评估的任务列表 | 18 | // 执行评估的任务列表 |
| 19 | type StaffAssessTask struct { | 19 | type StaffAssessTask struct { |
| 20 | - Id int `json:"id"` | ||
| 21 | - CompanyId int `json:"companyId"` //公司id | ||
| 22 | - EvaluationProjectId int `json:"evaluationProjectId"` //项目id | ||
| 23 | - CycleId int64 `json:"cycleId"` //对应的周期id | ||
| 24 | - Types StaffAssessType `json:"types"` //填写评估对应的类型 | ||
| 25 | - LinkNodeId int `json:"linkNodeId"` //评估环节id | ||
| 26 | - BeginTime time.Time `json:"beginTime"` //开始时间 | ||
| 27 | - EndTime time.Time `json:"endTime"` //截止时间 | ||
| 28 | - RepeatWay AssessTaskRepeatWay `json:"repeatWay"` //重复执行的方式 | ||
| 29 | - NextActiveTime int64 `json:"nextActveTime"` //下一次执行的任务的时间 | ||
| 30 | - CreatedAt time.Time `json:"createdAt"` //数据创建时间 | ||
| 31 | - UpdatedAt time.Time `json:"updatedAt"` //数据更新时间 | ||
| 32 | - DeletedAt time.Time `json:"deletedAt"` //数据删除时间 | 20 | + Id int `json:"id"` |
| 21 | + CompanyId int `json:"companyId"` //公司id | ||
| 22 | + EvaluationProjectId int `json:"evaluationProjectId"` //项目id | ||
| 23 | + EvaluationProjectName string `json:"evaluationProjectName"` //项目名称 | ||
| 24 | + CycleId int64 `json:"cycleId"` //对应的周期id | ||
| 25 | + CycleName string `json:"cycleName"` //对应周期的名称 | ||
| 26 | + BeginTime time.Time `json:"beginTime"` //绩效考核开始时间 | ||
| 27 | + EndTime time.Time `json:"endTime"` //绩效考核截止时间 | ||
| 28 | + CreatedAt time.Time `json:"createdAt"` //数据创建时间 | ||
| 29 | + UpdatedAt time.Time `json:"updatedAt"` //数据更新时间 | ||
| 30 | + DeletedAt time.Time `json:"deletedAt"` //数据删除时间 | ||
| 33 | } | 31 | } |
| 34 | 32 | ||
| 35 | type StaffAssessTaskRepository interface { | 33 | type StaffAssessTaskRepository interface { |
| @@ -38,11 +36,3 @@ type StaffAssessTaskRepository interface { | @@ -38,11 +36,3 @@ type StaffAssessTaskRepository interface { | ||
| 38 | FindOne(queryOptions map[string]interface{}) (*StaffAssessTask, error) | 36 | FindOne(queryOptions map[string]interface{}) (*StaffAssessTask, error) |
| 39 | Find(queryOptions map[string]interface{}) (int, []*StaffAssessTask, error) | 37 | Find(queryOptions map[string]interface{}) (int, []*StaffAssessTask, error) |
| 40 | } | 38 | } |
| 41 | - | ||
| 42 | -//计算下一次执行任务的时间 | ||
| 43 | -func (task *StaffAssessTask) NewNextActveTime() { | ||
| 44 | - if task.NextActiveTime == 0 { | ||
| 45 | - task.NextActiveTime = task.BeginTime.Unix() | ||
| 46 | - } | ||
| 47 | - //Todo 根据重复执行的方式,计算下一次执行的时间点 | ||
| 48 | -} |
| @@ -17,10 +17,11 @@ type StaffAssess struct { | @@ -17,10 +17,11 @@ type StaffAssess struct { | ||
| 17 | TargetDepartment []domain.StaffDepartment `comment:"被评估的用户所在的部门"` //被评估的用户所在的部门 | 17 | TargetDepartment []domain.StaffDepartment `comment:"被评估的用户所在的部门"` //被评估的用户所在的部门 |
| 18 | Executor domain.StaffDesc `comment:"填写评估的用户"` //填写评估的用户 | 18 | Executor domain.StaffDesc `comment:"填写评估的用户"` //填写评估的用户 |
| 19 | Types string `comment:"填写评估对应的类型"` //填写评估对应的类型 | 19 | Types string `comment:"填写评估对应的类型"` //填写评估对应的类型 |
| 20 | - Status string `comment:"评估的填写状态"` //评估的填写状态 | ||
| 21 | - BeginTime time.Time `comment:"开始时间"` //开始时间 | ||
| 22 | - EndTime time.Time `comment:"截止时间"` //截止时间 | ||
| 23 | - CreatedAt time.Time `comment:"数据创建时间"` //数据创建时间 | ||
| 24 | - UpdatedAt time.Time `comment:"数据更新时间"` //数据更新时间 | ||
| 25 | - DeletedAt *time.Time `comment:"数据删除时间"` //数据删除时间 | 20 | + LinkNodeId int `comment:"评估环节id"` |
| 21 | + Status string `comment:"评估的填写状态"` //评估的填写状态 | ||
| 22 | + BeginTime time.Time `comment:"开始时间"` //开始时间 | ||
| 23 | + EndTime time.Time `comment:"截止时间"` //截止时间 | ||
| 24 | + CreatedAt time.Time `comment:"数据创建时间"` //数据创建时间 | ||
| 25 | + UpdatedAt time.Time `comment:"数据更新时间"` //数据更新时间 | ||
| 26 | + DeletedAt *time.Time `comment:"数据删除时间"` //数据删除时间 | ||
| 26 | } | 27 | } |
| @@ -4,17 +4,16 @@ import "time" | @@ -4,17 +4,16 @@ import "time" | ||
| 4 | 4 | ||
| 5 | // 执行评估的任务列表 | 5 | // 执行评估的任务列表 |
| 6 | type StaffAssessTask struct { | 6 | type StaffAssessTask struct { |
| 7 | - tableName struct{} `pg:"staff_assess_task" comment:"执行评估的任务列表"` | ||
| 8 | - Id int `pg:",pk"` | ||
| 9 | - CompanyId int `` //公司id | ||
| 10 | - EvaluationProjectId int //项目id | ||
| 11 | - CycleId int64 //对应的周期id | ||
| 12 | - Types string //填写评估对应的类型 | ||
| 13 | - BeginTime time.Time //开始时间 | ||
| 14 | - EndTime time.Time //截止时间 | ||
| 15 | - RepeatWay string //重复执行的方式 | ||
| 16 | - NextActiveTime int64 //下一次执行的任务的时间,时间戳(秒) | ||
| 17 | - CreatedAt time.Time //数据创建时间 | ||
| 18 | - UpdatedAt time.Time //数据更新时间 | ||
| 19 | - DeletedAt time.Time //数据删除时间 | 7 | + tableName struct{} `pg:"staff_assess_task" comment:"执行评估的任务列表"` |
| 8 | + Id int `pg:",pk"` | ||
| 9 | + CompanyId int `` //公司id | ||
| 10 | + EvaluationProjectId int `` //项目id | ||
| 11 | + EvaluationProjectName string `` //项目名称 | ||
| 12 | + CycleId int64 //对应的周期id | ||
| 13 | + CycleName string //对应周期的名称 | ||
| 14 | + BeginTime time.Time //开始时间 | ||
| 15 | + EndTime time.Time //截止时间 | ||
| 16 | + CreatedAt time.Time //数据创建时间 | ||
| 17 | + UpdatedAt time.Time //数据更新时间 | ||
| 18 | + DeletedAt time.Time //数据删除时间 | ||
| 20 | } | 19 | } |
| @@ -23,35 +23,33 @@ func NewStaffAssessTaskRepository(transactionContext *pgTransaction.TransactionC | @@ -23,35 +23,33 @@ func NewStaffAssessTaskRepository(transactionContext *pgTransaction.TransactionC | ||
| 23 | 23 | ||
| 24 | func (repo *StaffAssessTaskRepository) TransformToDomain(d *models.StaffAssessTask) *domain.StaffAssessTask { | 24 | func (repo *StaffAssessTaskRepository) TransformToDomain(d *models.StaffAssessTask) *domain.StaffAssessTask { |
| 25 | return &domain.StaffAssessTask{ | 25 | return &domain.StaffAssessTask{ |
| 26 | - Id: d.Id, | ||
| 27 | - CompanyId: d.CompanyId, | ||
| 28 | - EvaluationProjectId: d.EvaluationProjectId, | ||
| 29 | - CycleId: d.CycleId, | ||
| 30 | - Types: domain.StaffAssessType(d.Types), | ||
| 31 | - BeginTime: d.BeginTime, | ||
| 32 | - EndTime: d.EndTime, | ||
| 33 | - RepeatWay: domain.AssessTaskRepeatWay(d.RepeatWay), | ||
| 34 | - NextActiveTime: d.NextActiveTime, | ||
| 35 | - CreatedAt: d.EndTime, | ||
| 36 | - UpdatedAt: d.CreatedAt, | ||
| 37 | - DeletedAt: d.DeletedAt, | 26 | + Id: d.Id, |
| 27 | + CompanyId: d.CompanyId, | ||
| 28 | + EvaluationProjectId: d.EvaluationProjectId, | ||
| 29 | + EvaluationProjectName: d.EvaluationProjectName, | ||
| 30 | + CycleId: d.CycleId, | ||
| 31 | + CycleName: d.CycleName, | ||
| 32 | + BeginTime: d.BeginTime, | ||
| 33 | + EndTime: d.EndTime, | ||
| 34 | + CreatedAt: d.EndTime, | ||
| 35 | + UpdatedAt: d.CreatedAt, | ||
| 36 | + DeletedAt: d.DeletedAt, | ||
| 38 | } | 37 | } |
| 39 | } | 38 | } |
| 40 | 39 | ||
| 41 | func (repo *StaffAssessTaskRepository) Save(d *domain.StaffAssessTask) (*domain.StaffAssessTask, error) { | 40 | func (repo *StaffAssessTaskRepository) Save(d *domain.StaffAssessTask) (*domain.StaffAssessTask, error) { |
| 42 | saveModel := models.StaffAssessTask{ | 41 | saveModel := models.StaffAssessTask{ |
| 43 | - Id: d.Id, | ||
| 44 | - CompanyId: d.CompanyId, | ||
| 45 | - EvaluationProjectId: d.EvaluationProjectId, | ||
| 46 | - CycleId: d.CycleId, | ||
| 47 | - Types: string(d.Types), | ||
| 48 | - BeginTime: d.BeginTime, | ||
| 49 | - EndTime: d.EndTime, | ||
| 50 | - RepeatWay: string(d.RepeatWay), | ||
| 51 | - NextActiveTime: d.NextActiveTime, | ||
| 52 | - CreatedAt: d.EndTime, | ||
| 53 | - UpdatedAt: d.CreatedAt, | ||
| 54 | - DeletedAt: d.DeletedAt, | 42 | + Id: d.Id, |
| 43 | + CompanyId: d.CompanyId, | ||
| 44 | + EvaluationProjectId: d.EvaluationProjectId, | ||
| 45 | + EvaluationProjectName: d.EvaluationProjectName, | ||
| 46 | + CycleId: d.CycleId, | ||
| 47 | + CycleName: d.CycleName, | ||
| 48 | + BeginTime: d.BeginTime, | ||
| 49 | + EndTime: d.EndTime, | ||
| 50 | + CreatedAt: d.EndTime, | ||
| 51 | + UpdatedAt: d.CreatedAt, | ||
| 52 | + DeletedAt: d.DeletedAt, | ||
| 55 | } | 53 | } |
| 56 | tx := repo.transactionContext.PgTx | 54 | tx := repo.transactionContext.PgTx |
| 57 | var err error | 55 | var err error |
-
请 注册 或 登录 后发表评论