|
...
|
...
|
@@ -341,6 +341,9 @@ func (srv StaffAssessServeice) CreateStaffAssessTask(transactionContext applicat |
|
|
|
// defer func() {
|
|
|
|
// _ = transactionContext.RollbackTransaction()
|
|
|
|
// }()
|
|
|
|
log.Logger.Debug("CreateStaffAssessTask 获取参数", map[string]interface{}{
|
|
|
|
"param": param,
|
|
|
|
})
|
|
|
|
assessTaskRepo := factory.CreateStaffAssessTaskRepository(map[string]interface{}{
|
|
|
|
"transactionContext": transactionContext,
|
|
|
|
})
|
|
...
|
...
|
@@ -372,6 +375,7 @@ func (srv StaffAssessServeice) CreateStaffAssessTask(transactionContext applicat |
|
|
|
CreatedAt: nowTime,
|
|
|
|
UpdatedAt: nowTime,
|
|
|
|
DeletedAt: nil,
|
|
|
|
BeginDay: taskBeginTime.Local().Format("2006-01-02"),
|
|
|
|
}
|
|
|
|
// }
|
|
|
|
|
|
...
|
...
|
@@ -425,6 +429,7 @@ func (srv StaffAssessServeice) CreateStaffAssessTask(transactionContext applicat |
|
|
|
|
|
|
|
if len(assassessTaskList) > 0 {
|
|
|
|
//过滤就数据
|
|
|
|
assessTaskData.Id = assassessTaskList[0].Id
|
|
|
|
for _, v := range assassessTaskList[0].ExecutorId {
|
|
|
|
if _, ok := executorIdMap[v]; ok {
|
|
|
|
continue
|
|
...
|
...
|
@@ -432,7 +437,6 @@ func (srv StaffAssessServeice) CreateStaffAssessTask(transactionContext applicat |
|
|
|
executorIds = append(executorIds, v)
|
|
|
|
}
|
|
|
|
assessTaskData.ExecutorId = executorIds
|
|
|
|
assessTaskData.Id = assassessTaskList[0].Id
|
|
|
|
assessTaskData.StepList = append(assassessTaskList[0].StepList, assessTaskData.StepList...)
|
|
|
|
|
|
|
|
}
|
...
|
...
|
|
