|
...
|
...
|
@@ -13,7 +13,6 @@ import ( |
|
|
|
"gitlab.fjmaimaimai.com/allied-creation/performance/pkg/application/staff_assess/command"
|
|
|
|
"gitlab.fjmaimaimai.com/allied-creation/performance/pkg/application/staff_assess/query"
|
|
|
|
"gitlab.fjmaimaimai.com/allied-creation/performance/pkg/domain"
|
|
|
|
"gitlab.fjmaimaimai.com/allied-creation/performance/pkg/infrastructure/dao"
|
|
|
|
"gitlab.fjmaimaimai.com/allied-creation/performance/pkg/log"
|
|
|
|
)
|
|
|
|
|
|
...
|
...
|
@@ -27,195 +26,195 @@ func NewStaffAssessServeice() *StaffAssessServeice { |
|
|
|
}
|
|
|
|
|
|
|
|
// 获取我参与过的评估任务列表
|
|
|
|
func (srv StaffAssessServeice) SearchAssessTaskMe(param *query.SearchAssessMeQuery) (map[string]interface{}, error) {
|
|
|
|
transactionContext, err := factory.CreateTransactionContext(nil)
|
|
|
|
if err != nil {
|
|
|
|
return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
|
|
|
|
}
|
|
|
|
if err := transactionContext.StartTransaction(); err != nil {
|
|
|
|
return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
|
|
|
|
}
|
|
|
|
defer func() {
|
|
|
|
_ = transactionContext.RollbackTransaction()
|
|
|
|
}()
|
|
|
|
|
|
|
|
staffAssessTaskRepo := dao.NewStaffAssessDao(map[string]interface{}{
|
|
|
|
"transactionContext": transactionContext,
|
|
|
|
})
|
|
|
|
|
|
|
|
var limit int = 200
|
|
|
|
var offset int = 0
|
|
|
|
if param.PageSize > 0 {
|
|
|
|
limit = param.PageSize
|
|
|
|
}
|
|
|
|
offset = (param.PageNumber - 1) * param.PageSize
|
|
|
|
assessTaskList, err := staffAssessTaskRepo.SearchAssessTaskMe(param.UserId, param.CompanyId, limit, offset)
|
|
|
|
if err != nil {
|
|
|
|
return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, "查询评估任务"+err.Error())
|
|
|
|
}
|
|
|
|
cnt, err := staffAssessTaskRepo.CountAssessTaskMe(param.UserId, param.CompanyId)
|
|
|
|
if err != nil {
|
|
|
|
return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, "查询评估任务"+err.Error())
|
|
|
|
}
|
|
|
|
|
|
|
|
if err := transactionContext.CommitTransaction(); err != nil {
|
|
|
|
return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
|
|
|
|
}
|
|
|
|
listData := make([]adapter.SearchAssessMeResp, 0, len(assessTaskList))
|
|
|
|
var temp adapter.SearchAssessMeResp
|
|
|
|
for _, v := range assessTaskList {
|
|
|
|
temp = adapter.SearchAssessMeResp{
|
|
|
|
AssessTaskId: v.Id,
|
|
|
|
BeginTime: v.BeginTime.Local().Format("2006-01-02 15:04:05"),
|
|
|
|
EndTime: v.EndTime.Local().Format("2006-01-02 15:04:05"),
|
|
|
|
CycleId: v.CycleId,
|
|
|
|
CycleName: v.CycleName,
|
|
|
|
EvaluationProjectId: v.EvaluationProjectId,
|
|
|
|
EvaluationProjectName: v.EvaluationProjectName,
|
|
|
|
}
|
|
|
|
listData = append(listData, temp)
|
|
|
|
}
|
|
|
|
return tool_funs.SimpleWrapGridMap(int64(cnt), listData), nil
|
|
|
|
}
|
|
|
|
// func (srv StaffAssessServeice) SearchAssessTaskMe(param *query.SearchAssessMeQuery) (map[string]interface{}, error) {
|
|
|
|
// transactionContext, err := factory.CreateTransactionContext(nil)
|
|
|
|
// if err != nil {
|
|
|
|
// return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
|
|
|
|
// }
|
|
|
|
// if err := transactionContext.StartTransaction(); err != nil {
|
|
|
|
// return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
|
|
|
|
// }
|
|
|
|
// defer func() {
|
|
|
|
// _ = transactionContext.RollbackTransaction()
|
|
|
|
// }()
|
|
|
|
|
|
|
|
// staffAssessTaskRepo := dao.NewStaffAssessDao(map[string]interface{}{
|
|
|
|
// "transactionContext": transactionContext,
|
|
|
|
// })
|
|
|
|
|
|
|
|
// var limit int = 200
|
|
|
|
// var offset int = 0
|
|
|
|
// if param.PageSize > 0 {
|
|
|
|
// limit = param.PageSize
|
|
|
|
// }
|
|
|
|
// offset = (param.PageNumber - 1) * param.PageSize
|
|
|
|
// assessTaskList, err := staffAssessTaskRepo.SearchAssessTaskMe(param.UserId, param.CompanyId, limit, offset)
|
|
|
|
// if err != nil {
|
|
|
|
// return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, "查询评估任务"+err.Error())
|
|
|
|
// }
|
|
|
|
// cnt, err := staffAssessTaskRepo.CountAssessTaskMe(param.UserId, param.CompanyId)
|
|
|
|
// if err != nil {
|
|
|
|
// return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, "查询评估任务"+err.Error())
|
|
|
|
// }
|
|
|
|
|
|
|
|
// if err := transactionContext.CommitTransaction(); err != nil {
|
|
|
|
// return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
|
|
|
|
// }
|
|
|
|
// listData := make([]adapter.SearchAssessMeResp, 0, len(assessTaskList))
|
|
|
|
// var temp adapter.SearchAssessMeResp
|
|
|
|
// for _, v := range assessTaskList {
|
|
|
|
// temp = adapter.SearchAssessMeResp{
|
|
|
|
// AssessTaskId: v.Id,
|
|
|
|
// BeginTime: v.BeginTime.Local().Format("2006-01-02 15:04:05"),
|
|
|
|
// EndTime: v.EndTime.Local().Format("2006-01-02 15:04:05"),
|
|
|
|
// CycleId: v.CycleId,
|
|
|
|
// CycleName: v.CycleName,
|
|
|
|
// EvaluationProjectId: v.EvaluationProjectId,
|
|
|
|
// EvaluationProjectName: v.EvaluationProjectName,
|
|
|
|
// }
|
|
|
|
// listData = append(listData, temp)
|
|
|
|
// }
|
|
|
|
// return tool_funs.SimpleWrapGridMap(int64(cnt), listData), nil
|
|
|
|
// }
|
|
|
|
|
|
|
|
// 获取项目评估进度描述
|
|
|
|
func (srv StaffAssessServeice) AssessTaskDesc(param *query.AssessTaskDescQuery) (*adapter.AssessTaskDescResp, error) {
|
|
|
|
transactionContext, err := factory.CreateTransactionContext(nil)
|
|
|
|
if err != nil {
|
|
|
|
return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
|
|
|
|
}
|
|
|
|
if err := transactionContext.StartTransaction(); err != nil {
|
|
|
|
return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
|
|
|
|
}
|
|
|
|
defer func() {
|
|
|
|
_ = transactionContext.RollbackTransaction()
|
|
|
|
}()
|
|
|
|
// 获取评估任务
|
|
|
|
staffAssessTaskRepo := factory.CreateStaffAssessTaskRepository(map[string]interface{}{
|
|
|
|
"transactionContext": transactionContext,
|
|
|
|
})
|
|
|
|
//获取个人参与的评估流程
|
|
|
|
staffAssessRepo := factory.CreateStaffAssessRepository(map[string]interface{}{
|
|
|
|
"transactionContext": transactionContext,
|
|
|
|
})
|
|
|
|
assessTaskData, err := staffAssessTaskRepo.FindOne(map[string]interface{}{
|
|
|
|
"id": param.AssessTaskId,
|
|
|
|
})
|
|
|
|
if err != nil {
|
|
|
|
return nil, application.ThrowError(application.TRANSACTION_ERROR, "评估任务不存在，"+err.Error())
|
|
|
|
}
|
|
|
|
//返回的数据结果
|
|
|
|
result := adapter.AssessTaskDescResp{
|
|
|
|
AssessTaskId: assessTaskData.Id,
|
|
|
|
EvaluationProjectId: assessTaskData.EvaluationProjectId,
|
|
|
|
EvaluationProjectName: assessTaskData.EvaluationProjectName,
|
|
|
|
CycleName: assessTaskData.CycleName,
|
|
|
|
BeginTime: assessTaskData.BeginTime.Local().Format("2006-01-02 15:04-05"),
|
|
|
|
EndTime: assessTaskData.EndTime.Local().Format("2006-01-02 15:04-05"),
|
|
|
|
StepList: []adapter.AssessTaskStep{},
|
|
|
|
}
|
|
|
|
|
|
|
|
for _, v := range assessTaskData.StepList {
|
|
|
|
stepItem := adapter.AssessTaskStep{
|
|
|
|
SortBy: v.SortBy,
|
|
|
|
LinkNodeName: v.LinkNodeName,
|
|
|
|
LinkNodeId: v.LinkNodeId,
|
|
|
|
BeginTime: v.BeginTime.Local().Format("2006-01-02 15:04:05"),
|
|
|
|
EndTime: v.EndTime.Local().Format("2006-01-02 15:04:05"),
|
|
|
|
LinkNodeType: v.LinkNodeType,
|
|
|
|
Desc: fmt.Sprintf("截止日期：%s", v.EndTime.Local().Format("2006-01-02 15:04:05")),
|
|
|
|
Status: "",
|
|
|
|
}
|
|
|
|
switch v.LinkNodeType {
|
|
|
|
case domain.LinkNodeSelfAssessment:
|
|
|
|
//个人自评完成情况
|
|
|
|
_, assessSelfData, err := staffAssessRepo.Find(map[string]interface{}{
|
|
|
|
"staffAssessTaskId": assessTaskData.Id,
|
|
|
|
"executorId": param.UserId,
|
|
|
|
"typesList": []string{string(domain.AssessSelf)},
|
|
|
|
})
|
|
|
|
if err != nil {
|
|
|
|
return nil, application.ThrowError(application.TRANSACTION_ERROR, "获取个人的评估环节"+err.Error())
|
|
|
|
}
|
|
|
|
if len(assessSelfData) > 0 {
|
|
|
|
stepItem.Status = string(assessSelfData[0].Status)
|
|
|
|
}
|
|
|
|
stepItem.Desc = fmt.Sprintf("截止日期：%s", stepItem.EndTime)
|
|
|
|
case domain.LinkNodeAllInvite:
|
|
|
|
//邀请别人评估自己
|
|
|
|
_, assessInviteData, err := staffAssessRepo.Find(map[string]interface{}{
|
|
|
|
"staffAssessTaskId": assessTaskData.Id,
|
|
|
|
"targetUserId": param.UserId,
|
|
|
|
"typesList": []string{string(domain.AssessInviteDiffSuper), string(domain.AssessInviteSameSuper)},
|
|
|
|
"limit": 5,
|
|
|
|
})
|
|
|
|
if err != nil {
|
|
|
|
return nil, application.ThrowError(application.TRANSACTION_ERROR, "获取个人的评估环节"+err.Error())
|
|
|
|
}
|
|
|
|
if len(assessInviteData) > 0 {
|
|
|
|
stepItem.Status = string(domain.StaffAssessCompleted)
|
|
|
|
} else {
|
|
|
|
stepItem.Status = string(domain.StaffAssessUncompleted)
|
|
|
|
}
|
|
|
|
//待邀请人数，为5人减去已邀请的人数。若邀请人数已等于或大于5人，则只显示截止日期即可
|
|
|
|
if len(assessInviteData) > 5 {
|
|
|
|
stepItem.Desc = fmt.Sprintf("截止日期：%s", stepItem.EndTime)
|
|
|
|
} else {
|
|
|
|
stepItem.Desc = fmt.Sprintf("截止日期：%s 待邀请%d人", stepItem.EndTime, 5-len(assessInviteData))
|
|
|
|
}
|
|
|
|
case domain.LinkNodeAllAssessment:
|
|
|
|
//我评估别人，被邀请评估
|
|
|
|
_, assessInviteList, err := staffAssessRepo.Find(map[string]interface{}{
|
|
|
|
"staffAssessTaskId": assessTaskData.Id,
|
|
|
|
"executorId": param.UserId,
|
|
|
|
"typesList": []string{string(domain.AssessInviteDiffSuper), string(domain.AssessInviteSameSuper)},
|
|
|
|
})
|
|
|
|
if err != nil {
|
|
|
|
return nil, application.ThrowError(application.TRANSACTION_ERROR, "获取个人的评估环节"+err.Error())
|
|
|
|
}
|
|
|
|
|
|
|
|
if len(assessInviteList) > 0 {
|
|
|
|
stepItem.Status = string(domain.StaffAssessCompleted)
|
|
|
|
stepItem.Desc = fmt.Sprintf("截止日期：%s", stepItem.EndTime)
|
|
|
|
for _, v := range assessInviteList {
|
|
|
|
if v.Status == domain.StaffAssessUncompleted {
|
|
|
|
stepItem.Status = string(domain.StaffAssessUncompleted)
|
|
|
|
break
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
case domain.LinkNodeSuperiorAssessment:
|
|
|
|
//我评估别人，上级评估
|
|
|
|
_, assessSupperList, err := staffAssessRepo.Find(map[string]interface{}{
|
|
|
|
"staffAssessTaskId": assessTaskData.Id,
|
|
|
|
"executorId": param.UserId,
|
|
|
|
"typesList": []string{string(domain.AssessSuper)},
|
|
|
|
})
|
|
|
|
if err != nil {
|
|
|
|
return nil, application.ThrowError(application.TRANSACTION_ERROR, "获取个人的评估环节"+err.Error())
|
|
|
|
}
|
|
|
|
if len(assessSupperList) > 0 {
|
|
|
|
stepItem.Status = string(domain.StaffAssessCompleted)
|
|
|
|
stepItem.Desc = fmt.Sprintf("截止日期：%s", stepItem.EndTime)
|
|
|
|
uncompletedNum := 0
|
|
|
|
for _, v := range assessSupperList {
|
|
|
|
if v.Status == domain.StaffAssessUncompleted {
|
|
|
|
uncompletedNum += 1
|
|
|
|
}
|
|
|
|
}
|
|
|
|
if uncompletedNum > 0 {
|
|
|
|
stepItem.Status = string(domain.StaffAssessUncompleted)
|
|
|
|
stepItem.Desc = fmt.Sprintf("截止日期：%s 待评估%d人", stepItem.EndTime, uncompletedNum)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
result.StepList = append(result.StepList, stepItem)
|
|
|
|
}
|
|
|
|
if err := transactionContext.CommitTransaction(); err != nil {
|
|
|
|
return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
|
|
|
|
}
|
|
|
|
return &result, nil
|
|
|
|
}
|
|
|
|
// func (srv StaffAssessServeice) AssessTaskDesc(param *query.AssessTaskDescQuery) (*adapter.AssessTaskDescResp, error) {
|
|
|
|
// transactionContext, err := factory.CreateTransactionContext(nil)
|
|
|
|
// if err != nil {
|
|
|
|
// return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
|
|
|
|
// }
|
|
|
|
// if err := transactionContext.StartTransaction(); err != nil {
|
|
|
|
// return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
|
|
|
|
// }
|
|
|
|
// defer func() {
|
|
|
|
// _ = transactionContext.RollbackTransaction()
|
|
|
|
// }()
|
|
|
|
// // 获取评估任务
|
|
|
|
// staffAssessTaskRepo := factory.CreateStaffAssessTaskRepository(map[string]interface{}{
|
|
|
|
// "transactionContext": transactionContext,
|
|
|
|
// })
|
|
|
|
// //获取个人参与的评估流程
|
|
|
|
// staffAssessRepo := factory.CreateStaffAssessRepository(map[string]interface{}{
|
|
|
|
// "transactionContext": transactionContext,
|
|
|
|
// })
|
|
|
|
// assessTaskData, err := staffAssessTaskRepo.FindOne(map[string]interface{}{
|
|
|
|
// "id": param.AssessTaskId,
|
|
|
|
// })
|
|
|
|
// if err != nil {
|
|
|
|
// return nil, application.ThrowError(application.TRANSACTION_ERROR, "评估任务不存在，"+err.Error())
|
|
|
|
// }
|
|
|
|
// //返回的数据结果
|
|
|
|
// result := adapter.AssessTaskDescResp{
|
|
|
|
// AssessTaskId: assessTaskData.Id,
|
|
|
|
// EvaluationProjectId: assessTaskData.EvaluationProjectId,
|
|
|
|
// EvaluationProjectName: assessTaskData.EvaluationProjectName,
|
|
|
|
// CycleName: assessTaskData.CycleName,
|
|
|
|
// BeginTime: assessTaskData.BeginTime.Local().Format("2006-01-02 15:04-05"),
|
|
|
|
// EndTime: assessTaskData.EndTime.Local().Format("2006-01-02 15:04-05"),
|
|
|
|
// StepList: []adapter.AssessTaskStep{},
|
|
|
|
// }
|
|
|
|
|
|
|
|
// for _, v := range assessTaskData.StepList {
|
|
|
|
// stepItem := adapter.AssessTaskStep{
|
|
|
|
// SortBy: v.SortBy,
|
|
|
|
// LinkNodeName: v.LinkNodeName,
|
|
|
|
// LinkNodeId: v.LinkNodeId,
|
|
|
|
// BeginTime: v.BeginTime.Local().Format("2006-01-02 15:04:05"),
|
|
|
|
// EndTime: v.EndTime.Local().Format("2006-01-02 15:04:05"),
|
|
|
|
// LinkNodeType: v.LinkNodeType,
|
|
|
|
// Desc: fmt.Sprintf("截止日期：%s", v.EndTime.Local().Format("2006-01-02 15:04:05")),
|
|
|
|
// Status: "",
|
|
|
|
// }
|
|
|
|
// switch v.LinkNodeType {
|
|
|
|
// case domain.LinkNodeSelfAssessment:
|
|
|
|
// //个人自评完成情况
|
|
|
|
// _, assessSelfData, err := staffAssessRepo.Find(map[string]interface{}{
|
|
|
|
// "staffAssessTaskId": assessTaskData.Id,
|
|
|
|
// "executorId": param.UserId,
|
|
|
|
// "typesList": []string{string(domain.AssessSelf)},
|
|
|
|
// })
|
|
|
|
// if err != nil {
|
|
|
|
// return nil, application.ThrowError(application.TRANSACTION_ERROR, "获取个人的评估环节"+err.Error())
|
|
|
|
// }
|
|
|
|
// if len(assessSelfData) > 0 {
|
|
|
|
// stepItem.Status = string(assessSelfData[0].Status)
|
|
|
|
// }
|
|
|
|
// stepItem.Desc = fmt.Sprintf("截止日期：%s", stepItem.EndTime)
|
|
|
|
// case domain.LinkNodeAllInvite:
|
|
|
|
// //邀请别人评估自己
|
|
|
|
// _, assessInviteData, err := staffAssessRepo.Find(map[string]interface{}{
|
|
|
|
// "staffAssessTaskId": assessTaskData.Id,
|
|
|
|
// "targetUserId": param.UserId,
|
|
|
|
// "typesList": []string{string(domain.AssessInviteDiffSuper), string(domain.AssessInviteSameSuper)},
|
|
|
|
// "limit": 5,
|
|
|
|
// })
|
|
|
|
// if err != nil {
|
|
|
|
// return nil, application.ThrowError(application.TRANSACTION_ERROR, "获取个人的评估环节"+err.Error())
|
|
|
|
// }
|
|
|
|
// if len(assessInviteData) > 0 {
|
|
|
|
// stepItem.Status = string(domain.StaffAssessCompleted)
|
|
|
|
// } else {
|
|
|
|
// stepItem.Status = string(domain.StaffAssessUncompleted)
|
|
|
|
// }
|
|
|
|
// //待邀请人数，为5人减去已邀请的人数。若邀请人数已等于或大于5人，则只显示截止日期即可
|
|
|
|
// if len(assessInviteData) > 5 {
|
|
|
|
// stepItem.Desc = fmt.Sprintf("截止日期：%s", stepItem.EndTime)
|
|
|
|
// } else {
|
|
|
|
// stepItem.Desc = fmt.Sprintf("截止日期：%s 待邀请%d人", stepItem.EndTime, 5-len(assessInviteData))
|
|
|
|
// }
|
|
|
|
// case domain.LinkNodeAllAssessment:
|
|
|
|
// //我评估别人，被邀请评估
|
|
|
|
// _, assessInviteList, err := staffAssessRepo.Find(map[string]interface{}{
|
|
|
|
// "staffAssessTaskId": assessTaskData.Id,
|
|
|
|
// "executorId": param.UserId,
|
|
|
|
// "typesList": []string{string(domain.AssessInviteDiffSuper), string(domain.AssessInviteSameSuper)},
|
|
|
|
// })
|
|
|
|
// if err != nil {
|
|
|
|
// return nil, application.ThrowError(application.TRANSACTION_ERROR, "获取个人的评估环节"+err.Error())
|
|
|
|
// }
|
|
|
|
|
|
|
|
// if len(assessInviteList) > 0 {
|
|
|
|
// stepItem.Status = string(domain.StaffAssessCompleted)
|
|
|
|
// stepItem.Desc = fmt.Sprintf("截止日期：%s", stepItem.EndTime)
|
|
|
|
// for _, v := range assessInviteList {
|
|
|
|
// if v.Status == domain.StaffAssessUncompleted {
|
|
|
|
// stepItem.Status = string(domain.StaffAssessUncompleted)
|
|
|
|
// break
|
|
|
|
// }
|
|
|
|
// }
|
|
|
|
// }
|
|
|
|
// case domain.LinkNodeSuperiorAssessment:
|
|
|
|
// //我评估别人，上级评估
|
|
|
|
// _, assessSupperList, err := staffAssessRepo.Find(map[string]interface{}{
|
|
|
|
// "staffAssessTaskId": assessTaskData.Id,
|
|
|
|
// "executorId": param.UserId,
|
|
|
|
// "typesList": []string{string(domain.AssessSuper)},
|
|
|
|
// })
|
|
|
|
// if err != nil {
|
|
|
|
// return nil, application.ThrowError(application.TRANSACTION_ERROR, "获取个人的评估环节"+err.Error())
|
|
|
|
// }
|
|
|
|
// if len(assessSupperList) > 0 {
|
|
|
|
// stepItem.Status = string(domain.StaffAssessCompleted)
|
|
|
|
// stepItem.Desc = fmt.Sprintf("截止日期：%s", stepItem.EndTime)
|
|
|
|
// uncompletedNum := 0
|
|
|
|
// for _, v := range assessSupperList {
|
|
|
|
// if v.Status == domain.StaffAssessUncompleted {
|
|
|
|
// uncompletedNum += 1
|
|
|
|
// }
|
|
|
|
// }
|
|
|
|
// if uncompletedNum > 0 {
|
|
|
|
// stepItem.Status = string(domain.StaffAssessUncompleted)
|
|
|
|
// stepItem.Desc = fmt.Sprintf("截止日期：%s 待评估%d人", stepItem.EndTime, uncompletedNum)
|
|
|
|
// }
|
|
|
|
// }
|
|
|
|
// }
|
|
|
|
// result.StepList = append(result.StepList, stepItem)
|
|
|
|
// }
|
|
|
|
// if err := transactionContext.CommitTransaction(); err != nil {
|
|
|
|
// return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
|
|
|
|
// }
|
|
|
|
// return &result, nil
|
|
|
|
// }
|
|
|
|
|
|
|
|
// 获取个人的自评反馈历史记录列表
|
|
|
|
func (srv StaffAssessServeice) AssessSelfList(param *query.AssessSelfListQuery) (map[string]interface{}, error) {
|
|
...
|
...
|
@@ -601,68 +600,68 @@ func (srv StaffAssessServeice) createStaffAssessSupper( |
|
|
|
}
|
|
|
|
|
|
|
|
// 获取某个员工360评估邀请的人员
|
|
|
|
func (srv StaffAssessServeice) GetAssessInviteUser(param *query.GetAssessInviteUserQuery) (*adapter.AssessInviteUserResp, error) {
|
|
|
|
transactionContext, err := factory.CreateTransactionContext(nil)
|
|
|
|
if err != nil {
|
|
|
|
return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
|
|
|
|
}
|
|
|
|
if err := transactionContext.StartTransaction(); err != nil {
|
|
|
|
return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
|
|
|
|
}
|
|
|
|
defer func() {
|
|
|
|
_ = transactionContext.RollbackTransaction()
|
|
|
|
}()
|
|
|
|
|
|
|
|
assessReps := factory.CreateStaffAssessRepository(map[string]interface{}{
|
|
|
|
"transactionContext": transactionContext,
|
|
|
|
})
|
|
|
|
|
|
|
|
assessTaskReps := factory.CreateStaffAssessTaskRepository(map[string]interface{}{
|
|
|
|
"transactionContext": transactionContext,
|
|
|
|
})
|
|
|
|
assessTaskData, err := assessTaskReps.FindOne(map[string]interface{}{
|
|
|
|
"id": param.AssessTaskId,
|
|
|
|
})
|
|
|
|
if err != nil {
|
|
|
|
return nil, application.ThrowError(application.ARG_ERROR, "获取评估任务"+err.Error())
|
|
|
|
}
|
|
|
|
_, assessList, err := assessReps.Find(map[string]interface{}{
|
|
|
|
"typesList": []string{string(domain.AssessInviteDiffSuper), string(domain.AssessInviteSameSuper)},
|
|
|
|
"staffAssessTaskId": param.AssessTaskId,
|
|
|
|
"targetUserId": param.UserId,
|
|
|
|
})
|
|
|
|
if err != nil {
|
|
|
|
return nil, application.ThrowError(application.ARG_ERROR, "获取个人评估任务"+err.Error())
|
|
|
|
}
|
|
|
|
if err := transactionContext.CommitTransaction(); err != nil {
|
|
|
|
return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
|
|
|
|
}
|
|
|
|
|
|
|
|
result := adapter.AssessInviteUserResp{
|
|
|
|
AssessTaskId: assessTaskData.Id,
|
|
|
|
InviteDiffSuper: []domain.StaffDesc{},
|
|
|
|
InviteSameSuper: []domain.StaffDesc{},
|
|
|
|
}
|
|
|
|
for _, v := range assessTaskData.StepList {
|
|
|
|
if v.LinkNodeType != domain.LinkNodeAllInvite {
|
|
|
|
continue
|
|
|
|
}
|
|
|
|
result.LinkNodeId = v.LinkNodeId
|
|
|
|
result.LinkNodeName = v.LinkNodeName
|
|
|
|
result.BeginTime = v.BeginTime.Local().Format("2006-01-02 15:04:05")
|
|
|
|
result.EndTime = v.EndTime.Local().Format("2006-01-02 15:04:05")
|
|
|
|
break
|
|
|
|
}
|
|
|
|
for _, v := range assessList {
|
|
|
|
if v.Types == domain.AssessInviteDiffSuper {
|
|
|
|
result.InviteDiffSuper = append(result.InviteDiffSuper, v.Executor)
|
|
|
|
}
|
|
|
|
if v.Types == domain.AssessInviteSameSuper {
|
|
|
|
result.InviteSameSuper = append(result.InviteSameSuper, v.Executor)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
return &result, nil
|
|
|
|
}
|
|
|
|
// func (srv StaffAssessServeice) GetAssessInviteUser(param *query.GetAssessInviteUserQuery) (*adapter.AssessInviteUserResp, error) {
|
|
|
|
// transactionContext, err := factory.CreateTransactionContext(nil)
|
|
|
|
// if err != nil {
|
|
|
|
// return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
|
|
|
|
// }
|
|
|
|
// if err := transactionContext.StartTransaction(); err != nil {
|
|
|
|
// return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
|
|
|
|
// }
|
|
|
|
// defer func() {
|
|
|
|
// _ = transactionContext.RollbackTransaction()
|
|
|
|
// }()
|
|
|
|
|
|
|
|
// assessReps := factory.CreateStaffAssessRepository(map[string]interface{}{
|
|
|
|
// "transactionContext": transactionContext,
|
|
|
|
// })
|
|
|
|
|
|
|
|
// assessTaskReps := factory.CreateStaffAssessTaskRepository(map[string]interface{}{
|
|
|
|
// "transactionContext": transactionContext,
|
|
|
|
// })
|
|
|
|
// assessTaskData, err := assessTaskReps.FindOne(map[string]interface{}{
|
|
|
|
// "id": param.AssessTaskId,
|
|
|
|
// })
|
|
|
|
// if err != nil {
|
|
|
|
// return nil, application.ThrowError(application.ARG_ERROR, "获取评估任务"+err.Error())
|
|
|
|
// }
|
|
|
|
// _, assessList, err := assessReps.Find(map[string]interface{}{
|
|
|
|
// "typesList": []string{string(domain.AssessInviteDiffSuper), string(domain.AssessInviteSameSuper)},
|
|
|
|
// "staffAssessTaskId": param.AssessTaskId,
|
|
|
|
// "targetUserId": param.UserId,
|
|
|
|
// })
|
|
|
|
// if err != nil {
|
|
|
|
// return nil, application.ThrowError(application.ARG_ERROR, "获取个人评估任务"+err.Error())
|
|
|
|
// }
|
|
|
|
// if err := transactionContext.CommitTransaction(); err != nil {
|
|
|
|
// return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
|
|
|
|
// }
|
|
|
|
|
|
|
|
// result := adapter.AssessInviteUserResp{
|
|
|
|
// AssessTaskId: assessTaskData.Id,
|
|
|
|
// InviteDiffSuper: []domain.StaffDesc{},
|
|
|
|
// InviteSameSuper: []domain.StaffDesc{},
|
|
|
|
// }
|
|
|
|
// for _, v := range assessTaskData.StepList {
|
|
|
|
// if v.LinkNodeType != domain.LinkNodeAllInvite {
|
|
|
|
// continue
|
|
|
|
// }
|
|
|
|
// result.LinkNodeId = v.LinkNodeId
|
|
|
|
// result.LinkNodeName = v.LinkNodeName
|
|
|
|
// result.BeginTime = v.BeginTime.Local().Format("2006-01-02 15:04:05")
|
|
|
|
// result.EndTime = v.EndTime.Local().Format("2006-01-02 15:04:05")
|
|
|
|
// break
|
|
|
|
// }
|
|
|
|
// for _, v := range assessList {
|
|
|
|
// if v.Types == domain.AssessInviteDiffSuper {
|
|
|
|
// result.InviteDiffSuper = append(result.InviteDiffSuper, v.Executor)
|
|
|
|
// }
|
|
|
|
// if v.Types == domain.AssessInviteSameSuper {
|
|
|
|
// result.InviteSameSuper = append(result.InviteSameSuper, v.Executor)
|
|
|
|
// }
|
|
|
|
// }
|
|
|
|
// return &result, nil
|
|
|
|
// }
|
|
|
|
|
|
|
|
// 保存某个员工360邀请的人员
|
|
|
|
func (srv StaffAssessServeice) SaveAssessInviteUser(param *command.SaveAssessInvite) (map[string]interface{}, error) {
|
|
...
|
...
|
@@ -899,91 +898,91 @@ func (srv StaffAssessServeice) SaveAssessInviteUser(param *command.SaveAssessInv |
|
|
|
}
|
|
|
|
|
|
|
|
// 获取员工自评的评估内容详情
|
|
|
|
func (srv StaffAssessServeice) GetAssessSelfInfo(param *query.AssessSelfInfoQuery) (*adapter.AssessInfoResp, error) {
|
|
|
|
transactionContext, err := factory.CreateTransactionContext(nil)
|
|
|
|
if err != nil {
|
|
|
|
return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
|
|
|
|
}
|
|
|
|
if err := transactionContext.StartTransaction(); err != nil {
|
|
|
|
return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
|
|
|
|
}
|
|
|
|
defer func() {
|
|
|
|
_ = transactionContext.RollbackTransaction()
|
|
|
|
}()
|
|
|
|
assessReps := factory.CreateStaffAssessRepository(map[string]interface{}{
|
|
|
|
"transactionContext": transactionContext,
|
|
|
|
})
|
|
|
|
//获取员工的评估
|
|
|
|
_, assessList, err := assessReps.Find(map[string]interface{}{
|
|
|
|
"companyId": param.CompanyId,
|
|
|
|
"staffAssessTaskId": param.AssessTaskId,
|
|
|
|
"targetUserId": param.TargetUserId,
|
|
|
|
"typesList": []string{string(domain.AssessSelf)},
|
|
|
|
})
|
|
|
|
if err != nil {
|
|
|
|
return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, "获取员工的评估"+err.Error())
|
|
|
|
}
|
|
|
|
if len(assessList) == 0 {
|
|
|
|
return &adapter.AssessInfoResp{}, nil
|
|
|
|
}
|
|
|
|
assessData := assessList[0]
|
|
|
|
|
|
|
|
assessContentList := []*domain.StaffAssessContent{}
|
|
|
|
if assessData.Status == domain.StaffAssessCompleted {
|
|
|
|
//已完成
|
|
|
|
assessContentRepo := factory.CreateStaffAssessContentRepository(map[string]interface{}{
|
|
|
|
"transactionContext": transactionContext,
|
|
|
|
})
|
|
|
|
_, assessContentList, err = assessContentRepo.Find(map[string]interface{}{
|
|
|
|
"staffAssessId": assessData.Id,
|
|
|
|
})
|
|
|
|
if err != nil {
|
|
|
|
return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, "获取项目填写内容"+err.Error())
|
|
|
|
}
|
|
|
|
} else if assessData.Status == domain.StaffAssessUncompleted {
|
|
|
|
//未完成
|
|
|
|
assessContentList, err = srv.getAssessSelfInfoUncompleted(transactionContext, assessData)
|
|
|
|
if err != nil {
|
|
|
|
return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, "获取项目填写内容"+err.Error())
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
// 恢复缓存数据
|
|
|
|
if param.AcquireCache != 0 {
|
|
|
|
srv.recoverAssessCache(transactionContext, assessData.Id, assessContentList)
|
|
|
|
}
|
|
|
|
|
|
|
|
//获取员工描述
|
|
|
|
staffDesc, _ := srv.getStaffDescrip(transactionContext, int64(param.TargetUserId))
|
|
|
|
if err := transactionContext.CommitTransaction(); err != nil {
|
|
|
|
return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
|
|
|
|
}
|
|
|
|
result := adapter.AssessInfoResp{
|
|
|
|
AssessId: assessData.Id,
|
|
|
|
CycleId: assessData.CycleId,
|
|
|
|
CycleName: assessData.CycleName,
|
|
|
|
LinkNodeId: assessData.LinkNodeId,
|
|
|
|
LinkNodeName: assessData.LinkNodeName,
|
|
|
|
EvaluationProjectId: assessData.EvaluationProjectId,
|
|
|
|
EvaluationProjectName: assessData.EvaluationProjectName,
|
|
|
|
BeginTime: assessData.BeginTime.Local().Format("2006-01-02 15:04:05"),
|
|
|
|
EndTime: assessData.EndTime.Local().Format("2006-01-02 15:04:05"),
|
|
|
|
Status: string(assessData.Status),
|
|
|
|
TargetUserId: assessData.TargetUser.UserId,
|
|
|
|
TargetUserName: assessData.TargetUser.UserName,
|
|
|
|
CompanyId: assessData.CompanyId,
|
|
|
|
CompanyName: "",
|
|
|
|
SupperUser: "",
|
|
|
|
DutyTime: "",
|
|
|
|
AssessContent: assessContentList,
|
|
|
|
}
|
|
|
|
if staffDesc != nil {
|
|
|
|
result.CompanyName = staffDesc.CompanyName
|
|
|
|
result.SupperUser = staffDesc.SupperUserName
|
|
|
|
result.DutyTime = staffDesc.DutyTime
|
|
|
|
}
|
|
|
|
return &result, nil
|
|
|
|
}
|
|
|
|
// func (srv StaffAssessServeice) GetAssessSelfInfo(param *query.AssessSelfInfoQuery) (*adapter.AssessInfoResp, error) {
|
|
|
|
// transactionContext, err := factory.CreateTransactionContext(nil)
|
|
|
|
// if err != nil {
|
|
|
|
// return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
|
|
|
|
// }
|
|
|
|
// if err := transactionContext.StartTransaction(); err != nil {
|
|
|
|
// return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
|
|
|
|
// }
|
|
|
|
// defer func() {
|
|
|
|
// _ = transactionContext.RollbackTransaction()
|
|
|
|
// }()
|
|
|
|
// assessReps := factory.CreateStaffAssessRepository(map[string]interface{}{
|
|
|
|
// "transactionContext": transactionContext,
|
|
|
|
// })
|
|
|
|
// //获取员工的评估
|
|
|
|
// _, assessList, err := assessReps.Find(map[string]interface{}{
|
|
|
|
// "companyId": param.CompanyId,
|
|
|
|
// "staffAssessTaskId": param.AssessTaskId,
|
|
|
|
// "targetUserId": param.TargetUserId,
|
|
|
|
// "typesList": []string{string(domain.AssessSelf)},
|
|
|
|
// })
|
|
|
|
// if err != nil {
|
|
|
|
// return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, "获取员工的评估"+err.Error())
|
|
|
|
// }
|
|
|
|
// if len(assessList) == 0 {
|
|
|
|
// return &adapter.AssessInfoResp{}, nil
|
|
|
|
// }
|
|
|
|
// assessData := assessList[0]
|
|
|
|
|
|
|
|
// assessContentList := []*domain.StaffAssessContent{}
|
|
|
|
// if assessData.Status == domain.StaffAssessCompleted {
|
|
|
|
// //已完成
|
|
|
|
// assessContentRepo := factory.CreateStaffAssessContentRepository(map[string]interface{}{
|
|
|
|
// "transactionContext": transactionContext,
|
|
|
|
// })
|
|
|
|
// _, assessContentList, err = assessContentRepo.Find(map[string]interface{}{
|
|
|
|
// "staffAssessId": assessData.Id,
|
|
|
|
// })
|
|
|
|
// if err != nil {
|
|
|
|
// return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, "获取项目填写内容"+err.Error())
|
|
|
|
// }
|
|
|
|
// } else if assessData.Status == domain.StaffAssessUncompleted {
|
|
|
|
// //未完成
|
|
|
|
// assessContentList, err = srv.getAssessSelfInfoUncompleted(transactionContext, assessData)
|
|
|
|
// if err != nil {
|
|
|
|
// return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, "获取项目填写内容"+err.Error())
|
|
|
|
// }
|
|
|
|
// }
|
|
|
|
|
|
|
|
// // 恢复缓存数据
|
|
|
|
// if param.AcquireCache != 0 {
|
|
|
|
// srv.recoverAssessCache(transactionContext, assessData.Id, assessContentList)
|
|
|
|
// }
|
|
|
|
|
|
|
|
// //获取员工描述
|
|
|
|
// staffDesc, _ := srv.getStaffDescrip(transactionContext, int64(param.TargetUserId))
|
|
|
|
// if err := transactionContext.CommitTransaction(); err != nil {
|
|
|
|
// return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
|
|
|
|
// }
|
|
|
|
// result := adapter.AssessInfoResp{
|
|
|
|
// AssessId: assessData.Id,
|
|
|
|
// CycleId: assessData.CycleId,
|
|
|
|
// CycleName: assessData.CycleName,
|
|
|
|
// LinkNodeId: assessData.LinkNodeId,
|
|
|
|
// LinkNodeName: assessData.LinkNodeName,
|
|
|
|
// EvaluationProjectId: assessData.EvaluationProjectId,
|
|
|
|
// EvaluationProjectName: assessData.EvaluationProjectName,
|
|
|
|
// BeginTime: assessData.BeginTime.Local().Format("2006-01-02 15:04:05"),
|
|
|
|
// EndTime: assessData.EndTime.Local().Format("2006-01-02 15:04:05"),
|
|
|
|
// Status: string(assessData.Status),
|
|
|
|
// TargetUserId: assessData.TargetUser.UserId,
|
|
|
|
// TargetUserName: assessData.TargetUser.UserName,
|
|
|
|
// CompanyId: assessData.CompanyId,
|
|
|
|
// CompanyName: "",
|
|
|
|
// SupperUser: "",
|
|
|
|
// DutyTime: "",
|
|
|
|
// AssessContent: assessContentList,
|
|
|
|
// }
|
|
|
|
// if staffDesc != nil {
|
|
|
|
// result.CompanyName = staffDesc.CompanyName
|
|
|
|
// result.SupperUser = staffDesc.SupperUserName
|
|
|
|
// result.DutyTime = staffDesc.DutyTime
|
|
|
|
// }
|
|
|
|
// return &result, nil
|
|
|
|
// }
|
|
|
|
|
|
|
|
// 获取未完成的员工评估内容
|
|
|
|
func (srv StaffAssessServeice) getAssessSelfInfoUncompleted(transactionContext application.TransactionContext,
|
|
...
|
...
|
@@ -1169,322 +1168,322 @@ func (srv StaffAssessServeice) SelectAssessInviteUser(param *query.SelectAssessI |
|
|
|
}
|
|
|
|
|
|
|
|
// 获取我要执行的的360评估，用户列表和评估填写的值
|
|
|
|
func (srv StaffAssessServeice) ListExecutorInviteAssess(param *query.ListInviteUserAssessQuery) (
|
|
|
|
*adapter.ListInviteUserAssessResp, error) {
|
|
|
|
transactionContext, err := factory.CreateTransactionContext(nil)
|
|
|
|
if err != nil {
|
|
|
|
return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
|
|
|
|
}
|
|
|
|
if err := transactionContext.StartTransaction(); err != nil {
|
|
|
|
return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
|
|
|
|
}
|
|
|
|
defer func() {
|
|
|
|
_ = transactionContext.RollbackTransaction()
|
|
|
|
}()
|
|
|
|
//获取对应的评估任务
|
|
|
|
assessRepo := factory.CreateStaffAssessRepository(map[string]interface{}{
|
|
|
|
"transactionContext": transactionContext,
|
|
|
|
})
|
|
|
|
assessTaskRepo := factory.CreateStaffAssessTaskRepository(map[string]interface{}{
|
|
|
|
"transactionContext": transactionContext,
|
|
|
|
})
|
|
|
|
|
|
|
|
//获取 executorId 对应的360评估任务 用户
|
|
|
|
condition := map[string]interface{}{
|
|
|
|
"staffAssessTaskId": param.AssessTaskId,
|
|
|
|
"executorId": param.ExecutorId,
|
|
|
|
"typesList": []string{string(domain.AssessInviteDiffSuper), string(domain.AssessInviteSameSuper)},
|
|
|
|
"limit": 20,
|
|
|
|
}
|
|
|
|
if param.PageSize > 0 {
|
|
|
|
condition["limit"] = param.PageSize
|
|
|
|
}
|
|
|
|
offset := (param.PageNumber - 1) * param.PageSize
|
|
|
|
if offset > 0 {
|
|
|
|
condition["offset"] = offset
|
|
|
|
}
|
|
|
|
|
|
|
|
cnt, assessList, err := assessRepo.Find(condition)
|
|
|
|
if err != nil {
|
|
|
|
return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
|
|
|
|
}
|
|
|
|
var assessContentList []*domain.StaffAssessContent
|
|
|
|
if len(assessList) > 0 {
|
|
|
|
//获取评估用的所有评估项
|
|
|
|
assessContentList, err = srv.getAssessSelfInfoUncompleted(transactionContext, assessList[0])
|
|
|
|
if err != nil {
|
|
|
|
return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, "获取评估任务"+err.Error())
|
|
|
|
}
|
|
|
|
}
|
|
|
|
//可变的表格列
|
|
|
|
changeableHeader := []adapter.ListTableHeader{}
|
|
|
|
//列名与字段对应
|
|
|
|
keyMap := map[string]string{}
|
|
|
|
for i, v := range assessContentList {
|
|
|
|
name := fmt.Sprintf("%s-%s", v.Category, v.Name)
|
|
|
|
key := fmt.Sprintf("k%d", i)
|
|
|
|
keyMap[name] = key
|
|
|
|
changeableHeader = append(changeableHeader, adapter.ListTableHeader{
|
|
|
|
Key: key,
|
|
|
|
Name: name,
|
|
|
|
})
|
|
|
|
}
|
|
|
|
assessContentRepo := factory.CreateStaffAssessContentRepository(map[string]interface{}{
|
|
|
|
"transactionContext": transactionContext,
|
|
|
|
})
|
|
|
|
// 获取已经填报的内容
|
|
|
|
changeableRows := map[int]map[string]string{}
|
|
|
|
for _, v := range assessList {
|
|
|
|
_, contentList, err := assessContentRepo.Find(map[string]interface{}{
|
|
|
|
"staffAssessId": v.Id,
|
|
|
|
})
|
|
|
|
if err != nil {
|
|
|
|
return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, "获取评估内容"+err.Error())
|
|
|
|
}
|
|
|
|
row := map[string]string{}
|
|
|
|
for _, vv := range contentList {
|
|
|
|
name := fmt.Sprintf("%s-%s", vv.Category, vv.Name)
|
|
|
|
if kk, ok := keyMap[name]; ok {
|
|
|
|
row[kk] = vv.Value
|
|
|
|
}
|
|
|
|
}
|
|
|
|
changeableRows[v.TargetUser.UserId] = row
|
|
|
|
}
|
|
|
|
|
|
|
|
//获取360邀请评估完成情况
|
|
|
|
//我评估别人，被邀请评估
|
|
|
|
cnnt, _, err := assessRepo.Find(map[string]interface{}{
|
|
|
|
"staffAssessTaskId": param.AssessTaskId,
|
|
|
|
"executorId": param.ExecutorId,
|
|
|
|
"typesList": []string{string(domain.AssessInviteDiffSuper), string(domain.AssessInviteSameSuper)},
|
|
|
|
"status": domain.StaffAssessUncompleted,
|
|
|
|
})
|
|
|
|
if err != nil {
|
|
|
|
return nil, application.ThrowError(application.TRANSACTION_ERROR, "获取个人的评估环节"+err.Error())
|
|
|
|
}
|
|
|
|
|
|
|
|
assessTaskData, err := assessTaskRepo.FindOne(map[string]interface{}{
|
|
|
|
"id": param.AssessTaskId,
|
|
|
|
})
|
|
|
|
if err != nil {
|
|
|
|
return nil, application.ThrowError(application.TRANSACTION_ERROR, "获取评估任务"+err.Error())
|
|
|
|
}
|
|
|
|
if err := transactionContext.CommitTransaction(); err != nil {
|
|
|
|
return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
|
|
|
|
}
|
|
|
|
|
|
|
|
//评估填写数据行转列
|
|
|
|
tableHeader := []adapter.ListTableHeader{
|
|
|
|
{Key: "userName", Name: "姓名"},
|
|
|
|
{Key: "status", Name: "状态"},
|
|
|
|
{Key: "types", Name: "360°评估关系"},
|
|
|
|
{Key: "endTime", Name: "360°评估截止日期"},
|
|
|
|
}
|
|
|
|
tableHeader = append(tableHeader, changeableHeader...)
|
|
|
|
listData := []map[string]interface{}{}
|
|
|
|
for _, v := range assessList {
|
|
|
|
m := map[string]interface{}{
|
|
|
|
"userName": v.TargetUser.UserName,
|
|
|
|
"userId": strconv.Itoa(v.TargetUser.UserId),
|
|
|
|
"status": string(v.Status),
|
|
|
|
"types": string(v.Types),
|
|
|
|
"endTime": v.EndTime.Local().Format("2006-01-02 15:04:05"),
|
|
|
|
"assessId": strconv.Itoa(v.Id),
|
|
|
|
}
|
|
|
|
switch v.Status {
|
|
|
|
case domain.StaffAssessCompleted:
|
|
|
|
m["status"] = "已经完成"
|
|
|
|
case domain.StaffAssessUncompleted:
|
|
|
|
m["status"] = "未完成"
|
|
|
|
}
|
|
|
|
|
|
|
|
switch v.Types {
|
|
|
|
case domain.AssessInviteDiffSuper:
|
|
|
|
m["types"] = "不同上级同事"
|
|
|
|
case domain.AssessInviteSameSuper:
|
|
|
|
m["types"] = "相同上级同事"
|
|
|
|
}
|
|
|
|
if row, ok := changeableRows[v.TargetUser.UserId]; ok {
|
|
|
|
for k, v := range row {
|
|
|
|
m[k] = v
|
|
|
|
}
|
|
|
|
} else {
|
|
|
|
for _, v := range changeableHeader {
|
|
|
|
m[v.Key] = ""
|
|
|
|
}
|
|
|
|
}
|
|
|
|
listData = append(listData, m)
|
|
|
|
}
|
|
|
|
result := adapter.ListInviteUserAssessResp{
|
|
|
|
TableHeader: tableHeader,
|
|
|
|
List: listData,
|
|
|
|
Total: cnt,
|
|
|
|
}
|
|
|
|
for _, v := range assessTaskData.StepList {
|
|
|
|
if v.LinkNodeType == domain.LinkNodeAllAssessment {
|
|
|
|
result.LinkNodeId = v.LinkNodeId
|
|
|
|
result.LinkNodeName = v.LinkNodeName
|
|
|
|
result.LintNodeDesc = fmt.Sprintf("截止时间 %s 待评估%d人", v.EndTime.Local().Format("2006-01-02 15:04:05"), cnnt)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
return &result, nil
|
|
|
|
}
|
|
|
|
// func (srv StaffAssessServeice) ListExecutorInviteAssess(param *query.ListInviteUserAssessQuery) (
|
|
|
|
// *adapter.ListInviteUserAssessResp, error) {
|
|
|
|
// transactionContext, err := factory.CreateTransactionContext(nil)
|
|
|
|
// if err != nil {
|
|
|
|
// return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
|
|
|
|
// }
|
|
|
|
// if err := transactionContext.StartTransaction(); err != nil {
|
|
|
|
// return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
|
|
|
|
// }
|
|
|
|
// defer func() {
|
|
|
|
// _ = transactionContext.RollbackTransaction()
|
|
|
|
// }()
|
|
|
|
// //获取对应的评估任务
|
|
|
|
// assessRepo := factory.CreateStaffAssessRepository(map[string]interface{}{
|
|
|
|
// "transactionContext": transactionContext,
|
|
|
|
// })
|
|
|
|
// assessTaskRepo := factory.CreateStaffAssessTaskRepository(map[string]interface{}{
|
|
|
|
// "transactionContext": transactionContext,
|
|
|
|
// })
|
|
|
|
|
|
|
|
// //获取 executorId 对应的360评估任务 用户
|
|
|
|
// condition := map[string]interface{}{
|
|
|
|
// "staffAssessTaskId": param.AssessTaskId,
|
|
|
|
// "executorId": param.ExecutorId,
|
|
|
|
// "typesList": []string{string(domain.AssessInviteDiffSuper), string(domain.AssessInviteSameSuper)},
|
|
|
|
// "limit": 20,
|
|
|
|
// }
|
|
|
|
// if param.PageSize > 0 {
|
|
|
|
// condition["limit"] = param.PageSize
|
|
|
|
// }
|
|
|
|
// offset := (param.PageNumber - 1) * param.PageSize
|
|
|
|
// if offset > 0 {
|
|
|
|
// condition["offset"] = offset
|
|
|
|
// }
|
|
|
|
|
|
|
|
// cnt, assessList, err := assessRepo.Find(condition)
|
|
|
|
// if err != nil {
|
|
|
|
// return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
|
|
|
|
// }
|
|
|
|
// var assessContentList []*domain.StaffAssessContent
|
|
|
|
// if len(assessList) > 0 {
|
|
|
|
// //获取评估用的所有评估项
|
|
|
|
// assessContentList, err = srv.getAssessSelfInfoUncompleted(transactionContext, assessList[0])
|
|
|
|
// if err != nil {
|
|
|
|
// return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, "获取评估任务"+err.Error())
|
|
|
|
// }
|
|
|
|
// }
|
|
|
|
// //可变的表格列
|
|
|
|
// changeableHeader := []adapter.ListTableHeader{}
|
|
|
|
// //列名与字段对应
|
|
|
|
// keyMap := map[string]string{}
|
|
|
|
// for i, v := range assessContentList {
|
|
|
|
// name := fmt.Sprintf("%s-%s", v.Category, v.Name)
|
|
|
|
// key := fmt.Sprintf("k%d", i)
|
|
|
|
// keyMap[name] = key
|
|
|
|
// changeableHeader = append(changeableHeader, adapter.ListTableHeader{
|
|
|
|
// Key: key,
|
|
|
|
// Name: name,
|
|
|
|
// })
|
|
|
|
// }
|
|
|
|
// assessContentRepo := factory.CreateStaffAssessContentRepository(map[string]interface{}{
|
|
|
|
// "transactionContext": transactionContext,
|
|
|
|
// })
|
|
|
|
// // 获取已经填报的内容
|
|
|
|
// changeableRows := map[int]map[string]string{}
|
|
|
|
// for _, v := range assessList {
|
|
|
|
// _, contentList, err := assessContentRepo.Find(map[string]interface{}{
|
|
|
|
// "staffAssessId": v.Id,
|
|
|
|
// })
|
|
|
|
// if err != nil {
|
|
|
|
// return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, "获取评估内容"+err.Error())
|
|
|
|
// }
|
|
|
|
// row := map[string]string{}
|
|
|
|
// for _, vv := range contentList {
|
|
|
|
// name := fmt.Sprintf("%s-%s", vv.Category, vv.Name)
|
|
|
|
// if kk, ok := keyMap[name]; ok {
|
|
|
|
// row[kk] = vv.Value
|
|
|
|
// }
|
|
|
|
// }
|
|
|
|
// changeableRows[v.TargetUser.UserId] = row
|
|
|
|
// }
|
|
|
|
|
|
|
|
// //获取360邀请评估完成情况
|
|
|
|
// //我评估别人，被邀请评估
|
|
|
|
// cnnt, _, err := assessRepo.Find(map[string]interface{}{
|
|
|
|
// "staffAssessTaskId": param.AssessTaskId,
|
|
|
|
// "executorId": param.ExecutorId,
|
|
|
|
// "typesList": []string{string(domain.AssessInviteDiffSuper), string(domain.AssessInviteSameSuper)},
|
|
|
|
// "status": domain.StaffAssessUncompleted,
|
|
|
|
// })
|
|
|
|
// if err != nil {
|
|
|
|
// return nil, application.ThrowError(application.TRANSACTION_ERROR, "获取个人的评估环节"+err.Error())
|
|
|
|
// }
|
|
|
|
|
|
|
|
// assessTaskData, err := assessTaskRepo.FindOne(map[string]interface{}{
|
|
|
|
// "id": param.AssessTaskId,
|
|
|
|
// })
|
|
|
|
// if err != nil {
|
|
|
|
// return nil, application.ThrowError(application.TRANSACTION_ERROR, "获取评估任务"+err.Error())
|
|
|
|
// }
|
|
|
|
// if err := transactionContext.CommitTransaction(); err != nil {
|
|
|
|
// return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
|
|
|
|
// }
|
|
|
|
|
|
|
|
// //评估填写数据行转列
|
|
|
|
// tableHeader := []adapter.ListTableHeader{
|
|
|
|
// {Key: "userName", Name: "姓名"},
|
|
|
|
// {Key: "status", Name: "状态"},
|
|
|
|
// {Key: "types", Name: "360°评估关系"},
|
|
|
|
// {Key: "endTime", Name: "360°评估截止日期"},
|
|
|
|
// }
|
|
|
|
// tableHeader = append(tableHeader, changeableHeader...)
|
|
|
|
// listData := []map[string]interface{}{}
|
|
|
|
// for _, v := range assessList {
|
|
|
|
// m := map[string]interface{}{
|
|
|
|
// "userName": v.TargetUser.UserName,
|
|
|
|
// "userId": strconv.Itoa(v.TargetUser.UserId),
|
|
|
|
// "status": string(v.Status),
|
|
|
|
// "types": string(v.Types),
|
|
|
|
// "endTime": v.EndTime.Local().Format("2006-01-02 15:04:05"),
|
|
|
|
// "assessId": strconv.Itoa(v.Id),
|
|
|
|
// }
|
|
|
|
// switch v.Status {
|
|
|
|
// case domain.StaffAssessCompleted:
|
|
|
|
// m["status"] = "已经完成"
|
|
|
|
// case domain.StaffAssessUncompleted:
|
|
|
|
// m["status"] = "未完成"
|
|
|
|
// }
|
|
|
|
|
|
|
|
// switch v.Types {
|
|
|
|
// case domain.AssessInviteDiffSuper:
|
|
|
|
// m["types"] = "不同上级同事"
|
|
|
|
// case domain.AssessInviteSameSuper:
|
|
|
|
// m["types"] = "相同上级同事"
|
|
|
|
// }
|
|
|
|
// if row, ok := changeableRows[v.TargetUser.UserId]; ok {
|
|
|
|
// for k, v := range row {
|
|
|
|
// m[k] = v
|
|
|
|
// }
|
|
|
|
// } else {
|
|
|
|
// for _, v := range changeableHeader {
|
|
|
|
// m[v.Key] = ""
|
|
|
|
// }
|
|
|
|
// }
|
|
|
|
// listData = append(listData, m)
|
|
|
|
// }
|
|
|
|
// result := adapter.ListInviteUserAssessResp{
|
|
|
|
// TableHeader: tableHeader,
|
|
|
|
// List: listData,
|
|
|
|
// Total: cnt,
|
|
|
|
// }
|
|
|
|
// for _, v := range assessTaskData.StepList {
|
|
|
|
// if v.LinkNodeType == domain.LinkNodeAllAssessment {
|
|
|
|
// result.LinkNodeId = v.LinkNodeId
|
|
|
|
// result.LinkNodeName = v.LinkNodeName
|
|
|
|
// result.LintNodeDesc = fmt.Sprintf("截止时间 %s 待评估%d人", v.EndTime.Local().Format("2006-01-02 15:04:05"), cnnt)
|
|
|
|
// }
|
|
|
|
// }
|
|
|
|
// return &result, nil
|
|
|
|
// }
|
|
|
|
|
|
|
|
// 获取我需要执行的上级评估成员列表
|
|
|
|
func (srv StaffAssessServeice) ListExecutorSupperAssess(param *query.ListSupperAssessQuery) (map[string]interface{}, error) {
|
|
|
|
transactionContext, err := factory.CreateTransactionContext(nil)
|
|
|
|
if err != nil {
|
|
|
|
return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
|
|
|
|
}
|
|
|
|
if err := transactionContext.StartTransaction(); err != nil {
|
|
|
|
return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
|
|
|
|
}
|
|
|
|
defer func() {
|
|
|
|
_ = transactionContext.RollbackTransaction()
|
|
|
|
}()
|
|
|
|
//获取对应的评估任务
|
|
|
|
assessRepo := factory.CreateStaffAssessRepository(map[string]interface{}{
|
|
|
|
"transactionContext": transactionContext,
|
|
|
|
})
|
|
|
|
|
|
|
|
limit := 20
|
|
|
|
if param.PageSize > 0 {
|
|
|
|
limit = param.PageSize
|
|
|
|
}
|
|
|
|
condition := map[string]interface{}{
|
|
|
|
"staffAssessTaskId": param.AssessTaskId,
|
|
|
|
"executorId": param.ExecutorId,
|
|
|
|
"typesList": []string{string(domain.AssessSuper)},
|
|
|
|
"limit": limit,
|
|
|
|
"targetUserName": param.UserName,
|
|
|
|
}
|
|
|
|
offset := (param.PageNumber - 1) * param.PageSize
|
|
|
|
if offset > 0 {
|
|
|
|
condition["offset"] = offset
|
|
|
|
}
|
|
|
|
//获取 executorId 对应的上级评估列表
|
|
|
|
cnt, assessList, err := assessRepo.Find(condition)
|
|
|
|
if err != nil {
|
|
|
|
return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
|
|
|
|
}
|
|
|
|
|
|
|
|
userIds := []int{}
|
|
|
|
for _, v := range assessList {
|
|
|
|
userIds = append(userIds, v.TargetUser.UserId)
|
|
|
|
}
|
|
|
|
//获取员工信息
|
|
|
|
userRepo := factory.CreateUserRepository(map[string]interface{}{
|
|
|
|
"transactionContext": transactionContext,
|
|
|
|
})
|
|
|
|
var targetUserList []*domain.User
|
|
|
|
if len(userIds) > 0 {
|
|
|
|
_, targetUserList, _ = userRepo.Find(map[string]interface{}{
|
|
|
|
"ids": userIds,
|
|
|
|
})
|
|
|
|
}
|
|
|
|
//获取职位信息
|
|
|
|
positionRepo := factory.CreatePositionRepository(map[string]interface{}{
|
|
|
|
"transactionContext": transactionContext,
|
|
|
|
})
|
|
|
|
//获取员工的职位
|
|
|
|
userPositionMap := map[int64][]*domain.Position{}
|
|
|
|
for _, v := range targetUserList {
|
|
|
|
if len(v.PositionId) == 0 {
|
|
|
|
continue
|
|
|
|
}
|
|
|
|
_, positionList, _ := positionRepo.Find(map[string]interface{}{
|
|
|
|
"ids": v.PositionId,
|
|
|
|
})
|
|
|
|
userPositionMap[v.Id] = positionList
|
|
|
|
}
|
|
|
|
|
|
|
|
//获取员工邀请的人完成360评估的数量
|
|
|
|
var inviteCompletedCount []dao.CountData
|
|
|
|
if len(userIds) > 0 {
|
|
|
|
d := dao.NewStaffAssessDao(map[string]interface{}{
|
|
|
|
"transactionContext": transactionContext,
|
|
|
|
})
|
|
|
|
inviteCompletedCount, err = d.CountInviteAssessByTargetUser(userIds, param.AssessTaskId)
|
|
|
|
if err != nil {
|
|
|
|
log.Logger.Error("获取员工邀请的人完成情况" + err.Error())
|
|
|
|
}
|
|
|
|
}
|
|
|
|
assessTaskRepo := factory.CreateStaffAssessTaskRepository(map[string]interface{}{
|
|
|
|
"transactionContext": transactionContext,
|
|
|
|
})
|
|
|
|
assessTaskData, err := assessTaskRepo.FindOne(map[string]interface{}{
|
|
|
|
"id": param.AssessTaskId,
|
|
|
|
})
|
|
|
|
if err != nil {
|
|
|
|
return nil, application.ThrowError(application.TRANSACTION_ERROR, "获取评估任务"+err.Error())
|
|
|
|
}
|
|
|
|
//我评估别人，被邀请评估
|
|
|
|
cnnt, _, err := assessRepo.Find(map[string]interface{}{
|
|
|
|
"staffAssessTaskId": param.AssessTaskId,
|
|
|
|
"executorId": param.ExecutorId,
|
|
|
|
"typesList": []string{string(domain.AssessSuper)},
|
|
|
|
"status": string(domain.StaffAssessUncompleted),
|
|
|
|
})
|
|
|
|
if err != nil {
|
|
|
|
return nil, application.ThrowError(application.TRANSACTION_ERROR, "获取个人的评估环节"+err.Error())
|
|
|
|
}
|
|
|
|
if err := transactionContext.CommitTransaction(); err != nil {
|
|
|
|
return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
|
|
|
|
}
|
|
|
|
|
|
|
|
resultList := []adapter.ListSupperAssessResp{}
|
|
|
|
for _, v := range assessList {
|
|
|
|
item := adapter.ListSupperAssessResp{
|
|
|
|
AssessId: v.Id,
|
|
|
|
UserId: v.TargetUser.UserId,
|
|
|
|
UserName: v.TargetUser.UserName,
|
|
|
|
EndTime: v.EndTime.Local().Format("2006-01-02 15:04:05"),
|
|
|
|
InviteCompleted: 0,
|
|
|
|
Status: string(v.Status),
|
|
|
|
InviteTotal: 5,
|
|
|
|
Department: "",
|
|
|
|
Position: "",
|
|
|
|
DutyTime: "",
|
|
|
|
}
|
|
|
|
//填入部门
|
|
|
|
for _, vv := range v.TargetDepartment {
|
|
|
|
item.Department += vv.DepartmentName + " "
|
|
|
|
}
|
|
|
|
for _, vv := range targetUserList {
|
|
|
|
if vv.Id != int64(v.TargetUser.UserId) {
|
|
|
|
continue
|
|
|
|
}
|
|
|
|
//填入入职时间
|
|
|
|
item.DutyTime = vv.CreatedAt.Local().Format("2006-01-02 15:04:05")
|
|
|
|
//填入职位
|
|
|
|
for _, vvv := range userPositionMap[vv.Id] {
|
|
|
|
item.Position += vvv.Name + " "
|
|
|
|
}
|
|
|
|
break
|
|
|
|
}
|
|
|
|
//
|
|
|
|
for _, vv := range inviteCompletedCount {
|
|
|
|
if v.TargetUser.UserId == vv.TargetUserId {
|
|
|
|
item.InviteCompleted = vv.InviteCompleted
|
|
|
|
item.InviteTotal = vv.InviteTotal
|
|
|
|
break
|
|
|
|
}
|
|
|
|
}
|
|
|
|
resultList = append(resultList, item)
|
|
|
|
}
|
|
|
|
result := tool_funs.SimpleWrapGridMap(int64(cnt), resultList)
|
|
|
|
result["linkNodeName"] = ""
|
|
|
|
result["linkNodeId"] = ""
|
|
|
|
result["lintNodeDesc"] = ""
|
|
|
|
for _, v := range assessTaskData.StepList {
|
|
|
|
if v.LinkNodeType == domain.LinkNodeSuperiorAssessment {
|
|
|
|
result["linkNodeName"] = v.LinkNodeName
|
|
|
|
result["linkNodeId"] = fmt.Sprintf("%d", v.LinkNodeId)
|
|
|
|
result["lintNodeDesc"] = fmt.Sprintf("截止时间 %s 待评估 %d 人", v.EndTime.Local().Format("2006-01-02 15:04:05"), cnnt)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
return result, nil
|
|
|
|
}
|
|
|
|
// func (srv StaffAssessServeice) ListExecutorSupperAssess(param *query.ListSupperAssessQuery) (map[string]interface{}, error) {
|
|
|
|
// transactionContext, err := factory.CreateTransactionContext(nil)
|
|
|
|
// if err != nil {
|
|
|
|
// return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
|
|
|
|
// }
|
|
|
|
// if err := transactionContext.StartTransaction(); err != nil {
|
|
|
|
// return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
|
|
|
|
// }
|
|
|
|
// defer func() {
|
|
|
|
// _ = transactionContext.RollbackTransaction()
|
|
|
|
// }()
|
|
|
|
// //获取对应的评估任务
|
|
|
|
// assessRepo := factory.CreateStaffAssessRepository(map[string]interface{}{
|
|
|
|
// "transactionContext": transactionContext,
|
|
|
|
// })
|
|
|
|
|
|
|
|
// limit := 20
|
|
|
|
// if param.PageSize > 0 {
|
|
|
|
// limit = param.PageSize
|
|
|
|
// }
|
|
|
|
// condition := map[string]interface{}{
|
|
|
|
// "staffAssessTaskId": param.AssessTaskId,
|
|
|
|
// "executorId": param.ExecutorId,
|
|
|
|
// "typesList": []string{string(domain.AssessSuper)},
|
|
|
|
// "limit": limit,
|
|
|
|
// "targetUserName": param.UserName,
|
|
|
|
// }
|
|
|
|
// offset := (param.PageNumber - 1) * param.PageSize
|
|
|
|
// if offset > 0 {
|
|
|
|
// condition["offset"] = offset
|
|
|
|
// }
|
|
|
|
// //获取 executorId 对应的上级评估列表
|
|
|
|
// cnt, assessList, err := assessRepo.Find(condition)
|
|
|
|
// if err != nil {
|
|
|
|
// return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
|
|
|
|
// }
|
|
|
|
|
|
|
|
// userIds := []int{}
|
|
|
|
// for _, v := range assessList {
|
|
|
|
// userIds = append(userIds, v.TargetUser.UserId)
|
|
|
|
// }
|
|
|
|
// //获取员工信息
|
|
|
|
// userRepo := factory.CreateUserRepository(map[string]interface{}{
|
|
|
|
// "transactionContext": transactionContext,
|
|
|
|
// })
|
|
|
|
// var targetUserList []*domain.User
|
|
|
|
// if len(userIds) > 0 {
|
|
|
|
// _, targetUserList, _ = userRepo.Find(map[string]interface{}{
|
|
|
|
// "ids": userIds,
|
|
|
|
// })
|
|
|
|
// }
|
|
|
|
// //获取职位信息
|
|
|
|
// positionRepo := factory.CreatePositionRepository(map[string]interface{}{
|
|
|
|
// "transactionContext": transactionContext,
|
|
|
|
// })
|
|
|
|
// //获取员工的职位
|
|
|
|
// userPositionMap := map[int64][]*domain.Position{}
|
|
|
|
// for _, v := range targetUserList {
|
|
|
|
// if len(v.PositionId) == 0 {
|
|
|
|
// continue
|
|
|
|
// }
|
|
|
|
// _, positionList, _ := positionRepo.Find(map[string]interface{}{
|
|
|
|
// "ids": v.PositionId,
|
|
|
|
// })
|
|
|
|
// userPositionMap[v.Id] = positionList
|
|
|
|
// }
|
|
|
|
|
|
|
|
// //获取员工邀请的人完成360评估的数量
|
|
|
|
// var inviteCompletedCount []dao.CountData
|
|
|
|
// if len(userIds) > 0 {
|
|
|
|
// d := dao.NewStaffAssessDao(map[string]interface{}{
|
|
|
|
// "transactionContext": transactionContext,
|
|
|
|
// })
|
|
|
|
// inviteCompletedCount, err = d.CountInviteAssessByTargetUser(userIds, param.AssessTaskId)
|
|
|
|
// if err != nil {
|
|
|
|
// log.Logger.Error("获取员工邀请的人完成情况" + err.Error())
|
|
|
|
// }
|
|
|
|
// }
|
|
|
|
// assessTaskRepo := factory.CreateStaffAssessTaskRepository(map[string]interface{}{
|
|
|
|
// "transactionContext": transactionContext,
|
|
|
|
// })
|
|
|
|
// assessTaskData, err := assessTaskRepo.FindOne(map[string]interface{}{
|
|
|
|
// "id": param.AssessTaskId,
|
|
|
|
// })
|
|
|
|
// if err != nil {
|
|
|
|
// return nil, application.ThrowError(application.TRANSACTION_ERROR, "获取评估任务"+err.Error())
|
|
|
|
// }
|
|
|
|
// //我评估别人，被邀请评估
|
|
|
|
// cnnt, _, err := assessRepo.Find(map[string]interface{}{
|
|
|
|
// "staffAssessTaskId": param.AssessTaskId,
|
|
|
|
// "executorId": param.ExecutorId,
|
|
|
|
// "typesList": []string{string(domain.AssessSuper)},
|
|
|
|
// "status": string(domain.StaffAssessUncompleted),
|
|
|
|
// })
|
|
|
|
// if err != nil {
|
|
|
|
// return nil, application.ThrowError(application.TRANSACTION_ERROR, "获取个人的评估环节"+err.Error())
|
|
|
|
// }
|
|
|
|
// if err := transactionContext.CommitTransaction(); err != nil {
|
|
|
|
// return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
|
|
|
|
// }
|
|
|
|
|
|
|
|
// resultList := []adapter.ListSupperAssessResp{}
|
|
|
|
// for _, v := range assessList {
|
|
|
|
// item := adapter.ListSupperAssessResp{
|
|
|
|
// AssessId: v.Id,
|
|
|
|
// UserId: v.TargetUser.UserId,
|
|
|
|
// UserName: v.TargetUser.UserName,
|
|
|
|
// EndTime: v.EndTime.Local().Format("2006-01-02 15:04:05"),
|
|
|
|
// InviteCompleted: 0,
|
|
|
|
// Status: string(v.Status),
|
|
|
|
// InviteTotal: 5,
|
|
|
|
// Department: "",
|
|
|
|
// Position: "",
|
|
|
|
// DutyTime: "",
|
|
|
|
// }
|
|
|
|
// //填入部门
|
|
|
|
// for _, vv := range v.TargetDepartment {
|
|
|
|
// item.Department += vv.DepartmentName + " "
|
|
|
|
// }
|
|
|
|
// for _, vv := range targetUserList {
|
|
|
|
// if vv.Id != int64(v.TargetUser.UserId) {
|
|
|
|
// continue
|
|
|
|
// }
|
|
|
|
// //填入入职时间
|
|
|
|
// item.DutyTime = vv.CreatedAt.Local().Format("2006-01-02 15:04:05")
|
|
|
|
// //填入职位
|
|
|
|
// for _, vvv := range userPositionMap[vv.Id] {
|
|
|
|
// item.Position += vvv.Name + " "
|
|
|
|
// }
|
|
|
|
// break
|
|
|
|
// }
|
|
|
|
// //
|
|
|
|
// for _, vv := range inviteCompletedCount {
|
|
|
|
// if v.TargetUser.UserId == vv.TargetUserId {
|
|
|
|
// item.InviteCompleted = vv.InviteCompleted
|
|
|
|
// item.InviteTotal = vv.InviteTotal
|
|
|
|
// break
|
|
|
|
// }
|
|
|
|
// }
|
|
|
|
// resultList = append(resultList, item)
|
|
|
|
// }
|
|
|
|
// result := tool_funs.SimpleWrapGridMap(int64(cnt), resultList)
|
|
|
|
// result["linkNodeName"] = ""
|
|
|
|
// result["linkNodeId"] = ""
|
|
|
|
// result["lintNodeDesc"] = ""
|
|
|
|
// for _, v := range assessTaskData.StepList {
|
|
|
|
// if v.LinkNodeType == domain.LinkNodeSuperiorAssessment {
|
|
|
|
// result["linkNodeName"] = v.LinkNodeName
|
|
|
|
// result["linkNodeId"] = fmt.Sprintf("%d", v.LinkNodeId)
|
|
|
|
// result["lintNodeDesc"] = fmt.Sprintf("截止时间 %s 待评估 %d 人", v.EndTime.Local().Format("2006-01-02 15:04:05"), cnnt)
|
|
|
|
// }
|
|
|
|
// }
|
|
|
|
// return result, nil
|
|
|
|
// }
|
|
|
|
|
|
|
|
// 根据staffAssessId 获取评估的填写信息
|
|
|
|
func (srv StaffAssessServeice) GetAssessInfo(param *query.AssessInfoQuery) (*adapter.AssessInfoResp, error) {
|
|
...
|
...
|
@@ -1764,38 +1763,38 @@ func (srv StaffAssessServeice) SaveAssessInfo(param *command.SaveAssessInfoComma |
|
|
|
}
|
|
|
|
|
|
|
|
// 获取员工被评估的列表
|
|
|
|
func (srv StaffAssessServeice) ListTargetUserAssess(param *query.ListTargetUserAssessQuery) (map[string]interface{}, error) {
|
|
|
|
transactionContext, err := factory.CreateTransactionContext(nil)
|
|
|
|
if err != nil {
|
|
|
|
return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
|
|
|
|
}
|
|
|
|
if err := transactionContext.StartTransaction(); err != nil {
|
|
|
|
return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
|
|
|
|
}
|
|
|
|
defer func() {
|
|
|
|
_ = transactionContext.RollbackTransaction()
|
|
|
|
}()
|
|
|
|
assessReps := factory.CreateStaffAssessRepository(map[string]interface{}{
|
|
|
|
"transactionContext": transactionContext,
|
|
|
|
})
|
|
|
|
//获取员工的评估
|
|
|
|
cnt, assessList, err := assessReps.Find(map[string]interface{}{
|
|
|
|
"staffAssessTaskId": param.AssessTaskId,
|
|
|
|
"companyId": param.CompanyId,
|
|
|
|
"targetUserId": param.TargetUserId,
|
|
|
|
"typesList": param.Types,
|
|
|
|
})
|
|
|
|
if err != nil {
|
|
|
|
return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, "获取员工的评估"+err.Error())
|
|
|
|
}
|
|
|
|
if err := transactionContext.CommitTransaction(); err != nil {
|
|
|
|
return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
|
|
|
|
}
|
|
|
|
|
|
|
|
return tool_funs.SimpleWrapGridMap(int64(cnt), assessList), nil
|
|
|
|
}
|
|
|
|
|
|
|
|
//获取员工的上级是谁 ，TODO
|
|
|
|
// func (srv StaffAssessServeice) ListTargetUserAssess(param *query.ListTargetUserAssessQuery) (map[string]interface{}, error) {
|
|
|
|
// transactionContext, err := factory.CreateTransactionContext(nil)
|
|
|
|
// if err != nil {
|
|
|
|
// return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
|
|
|
|
// }
|
|
|
|
// if err := transactionContext.StartTransaction(); err != nil {
|
|
|
|
// return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
|
|
|
|
// }
|
|
|
|
// defer func() {
|
|
|
|
// _ = transactionContext.RollbackTransaction()
|
|
|
|
// }()
|
|
|
|
// assessReps := factory.CreateStaffAssessRepository(map[string]interface{}{
|
|
|
|
// "transactionContext": transactionContext,
|
|
|
|
// })
|
|
|
|
// //获取员工的评估
|
|
|
|
// cnt, assessList, err := assessReps.Find(map[string]interface{}{
|
|
|
|
// "staffAssessTaskId": param.AssessTaskId,
|
|
|
|
// "companyId": param.CompanyId,
|
|
|
|
// "targetUserId": param.TargetUserId,
|
|
|
|
// "typesList": param.Types,
|
|
|
|
// })
|
|
|
|
// if err != nil {
|
|
|
|
// return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, "获取员工的评估"+err.Error())
|
|
|
|
// }
|
|
|
|
// if err := transactionContext.CommitTransaction(); err != nil {
|
|
|
|
// return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
|
|
|
|
// }
|
|
|
|
|
|
|
|
// return tool_funs.SimpleWrapGridMap(int64(cnt), assessList), nil
|
|
|
|
// }
|
|
|
|
|
|
|
|
// 获取员工的上级是谁 ，TODO
|
|
|
|
func (srv StaffAssessServeice) getStaffSuper(transactionContext application.TransactionContext, targetUser domain.User) ([]*domain.User, error) {
|
|
|
|
departmentRepo := factory.CreateDepartmentRepository(map[string]interface{}{
|
|
|
|
"transactionContext": transactionContext,
|
...
|
...
|
|
