|
...
|
...
|
@@ -950,6 +950,9 @@ func (srv TaskService) ListTaskRecord(param *command.ListTaskRecordCommand) (map |
|
|
|
taskRecordRepo := factory.CreateTaskRecordRepository(map[string]interface{}{
|
|
|
|
"transactionContext": transactionContext,
|
|
|
|
})
|
|
|
|
assessContentRepo := factory.CreateStaffAssessContentRepository(map[string]interface{}{
|
|
|
|
"transactionContext": transactionContext,
|
|
|
|
})
|
|
|
|
cnt, taskRecordList, err := taskRecordRepo.Find(map[string]interface{}{
|
|
|
|
"companyId": param.CompanyId,
|
|
|
|
"taskId": param.TaskId,
|
|
...
|
...
|
@@ -970,8 +973,7 @@ func (srv TaskService) ListTaskRecord(param *command.ListTaskRecordCommand) (map |
|
|
|
TaskName: val.TaskName,
|
|
|
|
TaskAlias: val.TaskAlias,
|
|
|
|
TaskLeader: val.TaskLeader.Name,
|
|
|
|
AssistLevel: val.AssistLevel,
|
|
|
|
AssistContent: val.AssistContent,
|
|
|
|
AssistContent: "",
|
|
|
|
AnomalyState: val.AnomalyState,
|
|
|
|
TaskStageCheck: adapter.TaskStage{
|
|
|
|
Id: val.Id,
|
|
...
|
...
|
@@ -989,6 +991,19 @@ func (srv TaskService) ListTaskRecord(param *command.ListTaskRecordCommand) (map |
|
|
|
t2 := time.Unix(val.TaskStageCheck.RealCompletedAt, 0).Local().Format("2006-01-02")
|
|
|
|
item.TaskStageCheck.RealCompletedAt = t2
|
|
|
|
}
|
|
|
|
_, contentList, err := assessContentRepo.Find(map[string]interface{}{
|
|
|
|
"staffAssessId": val.StaffAssessId,
|
|
|
|
"category": val.TaskCategory,
|
|
|
|
"name": val.TaskName,
|
|
|
|
})
|
|
|
|
if err != nil {
|
|
|
|
return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, "获取评估反馈数据"+err.Error())
|
|
|
|
}
|
|
|
|
if len(contentList) > 0 {
|
|
|
|
for _, val2 := range contentList[0].Remark {
|
|
|
|
item.AssistContent = val2.RemarkText + "\n"
|
|
|
|
}
|
|
|
|
}
|
|
|
|
resultList = append(resultList, item)
|
|
|
|
}
|
|
|
|
result := tool_funs.SimpleWrapGridMap(int64(cnt), resultList)
|
...
|
...
|
|