Merge remote-tracking branch 'origin/test' into test

郑周
main.go
pkg/application/staff_assess/adapter/assess_info.go
pkg/application/staff_assess/query/get_assess_invite_user.go
pkg/application/staff_assess/service/service.go
pkg/domain/staff_assess_content.go
pkg/infrastructure/pg/init.go
pkg/infrastructure/pg/models/staff_assess_content.go
pkg/infrastructure/repository/pg_staff_assess_content_repository.go
pkg/port/beego/controllers/staff_assess_controller.go
pkg/port/beego/routers/staff_assess_router.go
--- a/main.go
查看文件 @109c8cc
+++ b/main.go
查看文件 @109c8cc
 package main
 import (
-	"fmt"
-
 	"github.com/beego/beego/v2/server/web"
 	_ "gitlab.fjmaimaimai.com/allied-creation/performance/pkg/port/beego"
 	"gitlab.fjmaimaimai.com/allied-creation/performance/pkg/port/consumer"
 )
 func main() {
-	tree := web.PrintTree()
-	methods := tree["Data"].(web.M)
-	for k, v := range methods {
-		fmt.Printf("%s => %v \n", k, v)
-	}
+	// tree := web.PrintTree()
+	// methods := tree["Data"].(web.M)
+	// for k, v := range methods {
+	// 	fmt.Printf("%s => %v \n", k, v)
+	// }
 	go consumer.Run()
 	web.Run()
 }
--- a/pkg/application/staff_assess/adapter/assess_info.go
查看文件 @109c8cc
+++ b/pkg/application/staff_assess/adapter/assess_info.go
查看文件 @109c8cc
@@ -4,6 +4,7 @@ import "gitlab.fjmaimaimai.com/allied-creation/performance/pkg/domain"
 //评估内容详情
 type AssessInfoResp struct {
+	AssessId              int                          `json:"assessId"`
 	CycleId               int64                        `json:"cycleId"`               //周期id
 	CycleName             string                       `json:"cycleName"`             //周期名称
 	EvaluationProjectId   int                          `json:"evaluationProjectId"`   //项目id
@@ -13,13 +14,21 @@ type AssessInfoResp struct {
 	Status                string                       `json:"status"`                //完成状态
 	TargetUserId          int                          `json:"targetUser"`            //
 	TargetUserName        string                       `json:"targetUserName"`        //
-	AssessContent         []AssessContent `json:"assessContent"`         //评估内容
+	AssessContent         []*domain.StaffAssessContent `json:"assessContent"`         //评估内容
 }
 type AssessContent struct {
-	Category    string              `json:"category" comment:"类别"`
-	Name        string              `json:"name" comment:"名称"`
-	PromptTitle string              `json:"promptTitle" comment:"提示项标题"`
-	PromptText  string              `json:"promptText" comment:"提示项正文"`
-	EntryItems  []*domain.EntryItem `json:"entryItems" comment:"填写项"`
+	Category    string                       `json:"category"`    //comment:"类别"
+	Name        string                       `json:"name"`        // comment:"名称"
+	PromptTitle string                       `json:"promptTitle"` //comment:"提示项标题"
+	PromptText  string                       `json:"promptText"`  // comment:"提示项正文"
+	Rule        AssessContentRule            `json:"rules"`       //评定规则
+	Value       string                       `json:"value"`       // 实际填写评定值
+	Remark      []domain.AssessContemtRemark `json:"entryItems"`  // comment:"填写反馈"
+}
+
+type AssessContentRule struct {
+	Types  int           `json:"types"`  //评估方式（0评级、1评分）
+	Rating domain.Rating `json:"rating"` //评级
+	Score  domain.Score  `json:"score"`  //评分
 }
--- a/pkg/application/staff_assess/query/get_assess_invite_user.go
查看文件 @109c8cc
+++ b/pkg/application/staff_assess/query/get_assess_invite_user.go
查看文件 @109c8cc
@@ -2,6 +2,6 @@ package query
 type GetAssessInviteUserQuery struct {
 	CompanyId    int `json:"companyId"`    //对公司
-	UsrId        int `json:"usrId"`        //被评估的员工id
+	UserId       int `json:"userId"`       //被评估的员工id
 	AssessTaskId int `json:"assessTaskId"` //评估任务的id
 }
--- a/pkg/application/staff_assess/service/service.go
查看文件 @109c8cc
+++ b/pkg/application/staff_assess/service/service.go
查看文件 @109c8cc
@@ -575,7 +575,7 @@ func (srv StaffAssessServeice) GetAssessInviteUser(param *query.GetAssessInviteU
 	_, assessList, err := assessReps.Find(map[string]interface{}{
 		"typesList":         []string{string(domain.AssessInviteDiffSuper), string(domain.AssessInviteSameSuper)},
 		"staffAssessTaskId": param.AssessTaskId,
-		"targetUserId":      param.UsrId,
+		"targetUserId":      param.UserId,
 	})
 	if err != nil {
 		return nil, application.ThrowError(application.ARG_ERROR, "获取个人评估任务"+err.Error())
@@ -586,6 +586,8 @@ func (srv StaffAssessServeice) GetAssessInviteUser(param *query.GetAssessInviteU
 	result := adapter.AssessInviteUserResp{
 		AssessTaskId:    assessTaskData.Id,
+		InviteDiffSuper: []domain.StaffDesc{},
+		InviteSameSuper: []domain.StaffDesc{},
 	}
 	for _, v := range assessTaskData.StepList {
 		if v.LinkNodeType != domain.LinkNodeAllInvite {
@@ -608,8 +610,8 @@ func (srv StaffAssessServeice) GetAssessInviteUser(param *query.GetAssessInviteU
 	return &result, nil
 }
-// 获取某个员工360邀请的人员
-func (srv StaffAssessServeice) SaveAssessInviteUser(param *command.SaveAssessInvite) (*adapter.AssessInviteUserResp, error) {
+// 保存某个员工360邀请的人员
+func (srv StaffAssessServeice) SaveAssessInviteUser(param *command.SaveAssessInvite) (map[string]interface{}, error) {
 	inviteSameSuperId := []int{}
 	InviteDiffSuperId := []int{}
 	for _, v := range param.InviteDiffSuper {
@@ -657,6 +659,19 @@ func (srv StaffAssessServeice) SaveAssessInviteUser(param *command.SaveAssessInv
 		return nil, application.ThrowError(application.ARG_ERROR, "获取评估任务"+err.Error())
 	}
+	//获取邀请评估的节点
+	var inviteNode *domain.AssessTaskStep
+	for _, v := range assessTaskData.StepList {
+		if v.LinkNodeType == domain.LinkNodeAllAssessment {
+			cp := v
+			inviteNode = &cp
+			break
+		}
+	}
+	if inviteNode == nil {
+		return nil, application.ThrowError(application.ARG_ERROR, "评估任务没有邀请评估的环节")
+	}
+
 	targetUser, err := userRepo.FindOne(map[string]interface{}{
 		"id": param.TargetUserId,
 	})
@@ -713,46 +728,104 @@ func (srv StaffAssessServeice) SaveAssessInviteUser(param *command.SaveAssessInv
 			})
 		}
 	}
-	_ = assessReps
-	_ = inviteSameSuper
-	_ = inviteDiffSuper
-	_ = targetUserDepartment
-	// _, assessList, err := assessReps.Find(map[string]interface{}{
-	// 	"typesList":         []string{string(domain.AssessInviteDiffSuper), string(domain.AssessInviteSameSuper)},
-	// 	"staffAssessTaskId": param.AssessTaskId,
-	// 	"targetUserId":      param.TargetUserId,
-	// })
-	// if err != nil {
-	// 	return nil, application.ThrowError(application.ARG_ERROR, "获取个人评估任务"+err.Error())
-	// }
-	// TODO
-
+	//获取员工邀请的人
+	_, assessList, err := assessReps.Find(map[string]interface{}{
+		"typesList":         []string{string(domain.AssessInviteDiffSuper), string(domain.AssessInviteSameSuper)},
+		"staffAssessTaskId": param.AssessTaskId,
+		"targetUserId":      param.TargetUserId,
+	})
+	if err != nil {
+		return nil, application.ThrowError(application.ARG_ERROR, "获取员工邀请的人"+err.Error())
+	}
+	//比对新旧数据
+	nowTime := time.Now()
+	assessMap := map[string]*domain.StaffAssess{}
+	for _, v := range assessList {
+		//假设为删除
+		v.DeletedAt = &nowTime
+		key := fmt.Sprintf("%s%d", string(v.Types), v.Executor.UserId)
+		assessMap[key] = v
+	}
+	newAssessList := []*domain.StaffAssess{}
+	//邀请同上级的员工
+	for _, v := range inviteSameSuper {
+		key := fmt.Sprintf("%s%d", string(domain.AssessInviteSameSuper), v.UserId)
+		if _, ok := assessMap[key]; ok {
+			assessMap[key].DeletedAt = nil
+		} else {
+			newAssessList = append(newAssessList, &domain.StaffAssess{
+				Id:                    0,
+				CompanyId:             assessTaskData.CompanyId,
+				EvaluationProjectId:   assessTaskData.EvaluationProjectId,
+				EvaluationProjectName: assessTaskData.EvaluationProjectName,
+				CycleId:               assessTaskData.CycleId,
+				CycleName:             assessTaskData.CycleName,
+				StaffAssessTaskId:     assessTaskData.Id,
+				TargetUser: domain.StaffDesc{
+					UserId:   int(targetUser.Id),
+					Account:  targetUser.Account,
+					UserName: targetUser.Name,
+				},
+				TargetDepartment: targetUserDepartment,
+				Executor:         v,
+				Types:            domain.AssessInviteSameSuper,
+				LinkNodeId:       inviteNode.LinkNodeId,
+				LinkNodeName:     inviteNode.LinkNodeName,
+				Status:           domain.StaffAssessUncompleted,
+				BeginTime:        inviteNode.BeginTime,
+				EndTime:          inviteNode.EndTime,
+				CreatedAt:        nowTime,
+				UpdatedAt:        nowTime,
+				DeletedAt:        nil,
+			})
+		}
+	}
+	for _, v := range inviteDiffSuper {
+		key := fmt.Sprintf("%s%d", string(domain.AssessInviteDiffSuper), v.UserId)
+		if _, ok := assessMap[key]; ok {
+			assessMap[key].DeletedAt = nil
+		} else {
+			newAssessList = append(newAssessList, &domain.StaffAssess{
+				Id:                    0,
+				CompanyId:             assessTaskData.CompanyId,
+				EvaluationProjectId:   assessTaskData.EvaluationProjectId,
+				EvaluationProjectName: assessTaskData.EvaluationProjectName,
+				CycleId:               assessTaskData.CycleId,
+				CycleName:             assessTaskData.CycleName,
+				StaffAssessTaskId:     assessTaskData.Id,
+				TargetUser: domain.StaffDesc{
+					UserId:   int(targetUser.Id),
+					Account:  targetUser.Account,
+					UserName: targetUser.Name,
+				},
+				TargetDepartment: targetUserDepartment,
+				Executor:         v,
+				Types:            domain.AssessInviteDiffSuper,
+				LinkNodeId:       inviteNode.LinkNodeId,
+				LinkNodeName:     inviteNode.LinkNodeName,
+				Status:           domain.StaffAssessUncompleted,
+				BeginTime:        inviteNode.BeginTime,
+				EndTime:          inviteNode.EndTime,
+				CreatedAt:        nowTime,
+				UpdatedAt:        nowTime,
+				DeletedAt:        nil,
+			})
+		}
+	}
+	assessList = append(assessList, newAssessList...)
+	for i := range assessList {
+		_, err = assessReps.Save(assessList[i])
+		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())
 	}
-
-	result := adapter.AssessInviteUserResp{
-		AssessTaskId: assessTaskData.Id,
+	result := map[string]interface{}{
+		"assessTaskId": assessTaskData.Id,
 	}
-	// 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.InviteDiffSuper, v.Executor)
-	// 	}
-	// }
-	return &result, nil
+	return result, nil
 }
 // 获取员工自评的评估内容详情
@@ -770,7 +843,6 @@ func (srv StaffAssessServeice) GetAssessSelfInfo(param *query.AssessInfoQuery) (
 	assessReps := factory.CreateStaffAssessRepository(map[string]interface{}{
 		"transactionContext": transactionContext,
 	})
-
 	//获取员工的评估
 	_, assessList, err := assessReps.Find(map[string]interface{}{
 		"companyId":         param.CompanyId,
@@ -785,43 +857,32 @@ func (srv StaffAssessServeice) GetAssessSelfInfo(param *query.AssessInfoQuery) (
 		return &adapter.AssessInfoResp{}, nil
 	}
 	assessData := assessList[0]
-	projectRepo := factory.CreateEvaluationProjectRepository(map[string]interface{}{
+
+	assessContentList := []*domain.StaffAssessContent{}
+	if assessData.Status == domain.StaffAssessCompleted {
+		//已完成
+		assessContentRepo := factory.CreateStaffAssessContentRepository(map[string]interface{}{
 			"transactionContext": transactionContext,
 		})
-	projectData, err := projectRepo.FindOne(map[string]interface{}{
-		"id": assessData.EvaluationProjectId,
+		_, assessContentList, err = assessContentRepo.Find(map[string]interface{}{
+			"staffAssessId": assessData.Id,
 		})
 		if err != nil {
-		return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, "获取项目评估配置"+err.Error())
-	}
-	if projectData.Template == nil {
-		return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, "未获取到项目评估配置模板")
-	}
-	var selfLinkNode *domain.LinkNode
-	for _, v := range projectData.Template.LinkNodes {
-		if v.Type == domain.LinkNodeSelfAssessment {
-			selfLinkNode = v
-			break
+			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 selfLinkNode == nil {
-		return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, "未获取到项目评估自评配置")
 	}
-	//获取员工评估的填写内容
-	// assessContentReps := factory.CreateStaffAssessContentRepository(map[string]interface{}{
-	// 	"transactionContext": transactionContext,
-	// })
-	// _, assessContentList, err := assessContentReps.Find(map[string]interface{}{
-	// 	"staffAssessId": assessData.Id,
-	// })
-	// 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())
 	}
 	result := adapter.AssessInfoResp{
+		AssessId:              assessData.Id,
 		CycleId:               assessData.CycleId,
 		CycleName:             assessData.CycleName,
 		EvaluationProjectId:   assessData.EvaluationProjectId,
@@ -831,18 +892,82 @@ func (srv StaffAssessServeice) GetAssessSelfInfo(param *query.AssessInfoQuery) (
 		Status:                string(assessData.Status),
 		TargetUserId:          assessData.TargetUser.UserId,
 		TargetUserName:        assessData.TargetUser.UserName,
-		AssessContent:         nil,
+		AssessContent:         assessContentList,
+	}
+	return &result, nil
+}
+
+// 获取未完成的员工评估内容
+func (srv StaffAssessServeice) getAssessSelfInfoUncompleted(transactionContext application.TransactionContext,
+	assess *domain.StaffAssess) ([]*domain.StaffAssessContent, error) {
+	projectRepo := factory.CreateEvaluationProjectRepository(map[string]interface{}{
+		"transactionContext": transactionContext,
+	})
+	projectData, err := projectRepo.FindOne(map[string]interface{}{
+		"id": assess.EvaluationProjectId,
+	})
+	if err != nil {
+		return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, "获取项目填写内容"+err.Error())
 	}
-	assessContent := make([]adapter.AssessContent, 0)
-	for _, v := range selfLinkNode.NodeContents {
-		assessContent = append(assessContent, adapter.AssessContent{
+	var linkNode *domain.LinkNode
+	for _, v := range projectData.Template.LinkNodes {
+		if v.Id == int64(assess.LinkNodeId) {
+			linkNode = v
+			break
+		}
+	}
+	if linkNode == nil {
+		return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, "未获得评估环节配置"+err.Error())
+	}
+	ruleRepo := factory.CreateEvaluationRuleRepository(map[string]interface{}{
+		"transactionContext": transactionContext,
+	})
+	ruleMap := map[int64]*domain.EvaluationRule{}
+	for _, v := range linkNode.NodeContents {
+		if _, ok := ruleMap[v.RuleId]; ok {
+			continue
+		}
+		ruleData, err := ruleRepo.FindOne(map[string]interface{}{
+			"id": v.RuleId,
+		})
+		if err == nil {
+			ruleMap[v.RuleId] = ruleData
+		}
+	}
+
+	var contentList []*domain.StaffAssessContent
+	nowTime := time.Now()
+	for i, v := range linkNode.NodeContents {
+		item := &domain.StaffAssessContent{
+			Id:            0,
+			StaffAssessId: assess.Id,
+			SortBy:        i + 1,
 			Category:      v.Category,
 			Name:          v.Name,
 			PromptTitle:   v.PromptTitle,
 			PromptText:    v.PromptText,
-			EntryItems:  v.EntryItems,
-		})
+			Remark:        nil,
+			Value:         "",
+			ReteResult:    "",
+			CreatedAt:     nowTime,
+			UpdatedAt:     nowTime,
+			DeletedAt:     nil,
+			// Rule: ,
 		}
-	result.AssessContent = assessContent
-	return &result, nil
+		if ruleVal, ok := ruleMap[v.RuleId]; ok {
+			item.Rule = *ruleVal
+		}
+		var remarks []domain.AssessContemtRemark
+		for _, vv := range v.EntryItems {
+			ritem := domain.AssessContemtRemark{
+				Title:      vv.Title,
+				HintText:   vv.HintText,
+				RemarkText: "",
+			}
+			remarks = append(remarks, ritem)
+		}
+		item.Remark = remarks
+		contentList = append(contentList, item)
+	}
+	return contentList, nil
 }
--- a/pkg/domain/staff_assess_content.go
查看文件 @109c8cc
+++ b/pkg/domain/staff_assess_content.go
查看文件 @109c8cc
@@ -8,18 +8,22 @@ type StaffAssessContent struct {
 	StaffAssessId int                   `json:"staffAssessId"` //用户需要的评估项id
 	SortBy        int                   `json:"sortBy"`        //排序
 	Category      string                `json:"category"`      //类别
-	Title         string    `json:"title"`         //问题标题
-	Remark        string    `json:"remark"`        //填写的反馈
-	Rate          string    `json:"rate"`          //评估填写的值
+	Name          string                `json:"name"`          //名称
+	PromptTitle   string                `json:"promptTitle"`   //提示项标题
+	PromptText    string                `json:"promptText"`    //提示项正文
+	Remark        []AssessContemtRemark `json:"remark"`        //填写的反馈
+	Value         string                `json:"value"`         //评估填写的值
 	ReteResult    string                `json:"reteResult"`    //评估的结果
+	Rule          EvaluationRule        `json:"rule"`          //评估的选项规则
 	CreatedAt     time.Time             `json:"createdAt"`     //数据创建时间
 	UpdatedAt     time.Time             `json:"updatedAt"`     //数据更新时间
-	//TODO
+	DeletedAt     *time.Time            `json:"deletedAt"`
 }
 type AssessContemtRemark struct {
 	Title      string `json:"title"`      //comment:"填写标题"
-	RemarkText string `json:"hintText"` // comment:"填写文本内容"
+	HintText   string `json:"hintText"`   // comment:"文本内容提示"
+	RemarkText string `json:"remarkText"` // comment:"填写文本内容"
 }
 type StaffAssessContentRepository interface {
--- a/pkg/infrastructure/pg/init.go
查看文件 @109c8cc
+++ b/pkg/infrastructure/pg/init.go
查看文件 @109c8cc
@@ -42,6 +42,7 @@ func init() {
 			&models.EvaluationProject{},
 			&models.StaffAssess{},
 			&models.StaffAssessTask{},
+			&models.StaffAssessContent{},
 		}
 		for _, model := range tables {
 			err := DB.Model(model).CreateTable(&orm.CreateTableOptions{
--- a/pkg/infrastructure/pg/models/staff_assess_content.go
查看文件 @109c8cc
+++ b/pkg/infrastructure/pg/models/staff_assess_content.go
查看文件 @109c8cc
 package models
-import "time"
+import (
+	"time"
-//填写的评估内容
+	"gitlab.fjmaimaimai.com/allied-creation/performance/pkg/domain"
+)
+
+// 填写的评估内容
 type StaffAssessContent struct {
 	tableName     struct{} `pg:"staff_assess_content" comment:"填写的评估项"`
 	Id            int      `pg:",pk"` //id
 	StaffAssessId int      //用户需要的评估项id
 	SortBy        int      //排序
 	Category      string   //类别
-	Title         string    //问题标题
-	Remark        string    //填写的反馈
-	Rate          string    //评估填写的值
+	Name          string   //名称
+	PromptTitle   string   //问题标题
+	PromptText    string   //提示项正文
+	Value         string   //评估填写的值
 	ReteResult    string   //评估的结果
+	Rule          domain.EvaluationRule
+	Remark        []domain.AssessContemtRemark
 	CreatedAt     time.Time //数据创建时间
 	UpdatedAt     time.Time //数据更新时间
+	DeletedAt     *time.Time
 }
 type StaffAssessContentRepository interface {
--- a/pkg/infrastructure/repository/pg_staff_assess_content_repository.go
查看文件 @109c8cc
+++ b/pkg/infrastructure/repository/pg_staff_assess_content_repository.go
查看文件 @109c8cc
@@ -22,12 +22,40 @@ func NewStaffAssessContentRepository(transactionContext *pgTransaction.Transacti
 }
 func (repo *StaffAssessContentRepository) TransformToDomain(d *models.StaffAssessContent) *domain.StaffAssessContent {
-	return &domain.StaffAssessContent{}
+	return &domain.StaffAssessContent{
+		Id:            d.Id,
+		StaffAssessId: d.StaffAssessId,
+		SortBy:        d.SortBy,
+		Category:      d.Category,
+		Name:          d.Name,
+		PromptTitle:   d.PromptTitle,
+		PromptText:    d.PromptText,
+		Remark:        d.Remark,
+		Value:         d.Value,
+		ReteResult:    d.ReteResult,
+		Rule:          d.Rule,
+		CreatedAt:     d.CreatedAt,
+		UpdatedAt:     d.UpdatedAt,
+		DeletedAt:     nil,
+	}
 }
 func (repo *StaffAssessContentRepository) Save(d *domain.StaffAssessContent) (*domain.StaffAssessContent, error) {
-	saveModel := models.StaffAssess{
+	saveModel := models.StaffAssessContent{
 		Id:            d.Id,
+		StaffAssessId: d.StaffAssessId,
+		SortBy:        d.SortBy,
+		Category:      d.Category,
+		Name:          d.Name,
+		PromptTitle:   d.PromptTitle,
+		PromptText:    d.PromptText,
+		Remark:        d.Remark,
+		Value:         d.Value,
+		ReteResult:    d.ReteResult,
+		Rule:          d.Rule,
+		CreatedAt:     d.CreatedAt,
+		UpdatedAt:     d.UpdatedAt,
+		DeletedAt:     nil,
 	}
 	tx := repo.transactionContext.PgTx
 	var err error
@@ -79,7 +107,7 @@ func (repo *StaffAssessContentRepository) Find(queryOptions map[string]interface
 	tx := repo.transactionContext.PgTx
 	var m []*models.StaffAssessContent
 	query := tx.Model(&m).
-		Where("deleted_at isnull").Limit(20)
+		Where("deleted_at isnull")
 	if companyId, ok := queryOptions["companyId"]; ok {
 		query.Where("company_id = ?", companyId)
 	}
--- a/pkg/port/beego/controllers/staff_assess_controller.go
查看文件 @109c8cc
+++ b/pkg/port/beego/controllers/staff_assess_controller.go
查看文件 @109c8cc
@@ -78,10 +78,55 @@ func (c *StaffAssessController) CreateStaffAssessTask() {
 	c.Response(data, err)
 }
-//获取员工自评详情
+// 获取员工自评详情
+func (c *StaffAssessController) GetAssessSelfInfo() {
+	srv := service.NewStaffAssessServeice()
+	paramReq := &query.AssessInfoQuery{}
+	err := c.BindJSON(paramReq)
+	if err != nil {
+		e := application.ThrowError(application.ARG_ERROR, "json 解析错误"+err.Error())
+		c.Response(nil, e)
+		return
+	}
+	//TODO 获取当前用户信息
+	paramReq.CompanyId = 1
+	paramReq.TargetUserId = 1
+	data, err := srv.GetAssessSelfInfo(paramReq)
+	c.Response(data, err)
+}
 //保存员工自评填写内容
-//获取员工邀请的人
+// 获取员工邀请的人
+func (c *StaffAssessController) GetAssessInviteUser() {
+	srv := service.NewStaffAssessServeice()
+	paramReq := &query.GetAssessInviteUserQuery{}
+	err := c.BindJSON(paramReq)
+	if err != nil {
+		e := application.ThrowError(application.ARG_ERROR, "json 解析错误"+err.Error())
+		c.Response(nil, e)
+		return
+	}
+	//TODO 获取当前用户信息
+	paramReq.CompanyId = 1
+	paramReq.UserId = 1
+	data, err := srv.GetAssessInviteUser(paramReq)
+	c.Response(data, err)
+}
-//保持员工邀请的人
+// 保持员工邀请的人
+func (c *StaffAssessController) SaveAssessInviteUser() {
+	srv := service.NewStaffAssessServeice()
+	paramReq := &command.SaveAssessInvite{}
+	err := c.BindJSON(paramReq)
+	if err != nil {
+		e := application.ThrowError(application.ARG_ERROR, "json 解析错误"+err.Error())
+		c.Response(nil, e)
+		return
+	}
+	//TODO 获取当前用户信息
+	// paramReq.CompanyId = 1
+	// paramReq.UserId = 1
+	data, err := srv.SaveAssessInviteUser(paramReq)
+	c.Response(data, err)
+}
--- a/pkg/port/beego/routers/staff_assess_router.go
查看文件 @109c8cc
+++ b/pkg/port/beego/routers/staff_assess_router.go
查看文件 @109c8cc
@@ -16,7 +16,9 @@ func init() {
 	assessNS := web.NewNamespace("/v1/staff-assess",
 		// web.NSBefore(filters.AllowCors(), middlewares.CheckToken()),
 		web.NSCtrlPost("/self/me/list", (*controllers.StaffAssessController).AssessSelfMeList),            //获取我的自评反馈列表
-		// web.NSCtrlPost("/self/me/info", (*controllers.StaffAssessController).AssessSelfMeList),
+		web.NSCtrlPost("/self/me/info", (*controllers.StaffAssessController).GetAssessSelfInfo),           //获取我的自评反馈详情
+		web.NSCtrlPost("/me/invite-user", (*controllers.StaffAssessController).GetAssessInviteUser),       //获取邀请的员工
+		web.NSCtrlPost("/me/save-invite-user", (*controllers.StaffAssessController).SaveAssessInviteUser), //保存邀请的员工
 	)
 	web.AddNamespace(assessTaskNS)
 	web.AddNamespace(assessNS)