日常保存

tangxvhui
pkg/application/summary_evaluation/service/scheduled.go
pkg/domain/evaluation_project.go
pkg/infrastructure/pg/models/evaluation_project.go
pkg/infrastructure/repository/pg_evaluation_project_repository.go
pkg/port/beego/controllers/summary_evaluation_controller.go
pkg/port/beego/routers/summary_evaluation_router.go
--- a/pkg/application/summary_evaluation/service/scheduled.go
查看文件 @149c0cd
+++ b/pkg/application/summary_evaluation/service/scheduled.go
查看文件 @149c0cd
 package service
-//定时扫描评估项目表，确认是否下发评估任务
+import (
+	"gitlab.fjmaimaimai.com/allied-creation/performance/pkg/application/factory"
+	"gitlab.fjmaimaimai.com/allied-creation/performance/pkg/domain"
+)
-func SendSummaryEvaluationTask() {}
+// sendSummaryEvaluafionTask 根据评估项目设置，确认是否下发评估任务
+func sendSummaryEvaluafionTask(param *domain.EvaluationProject) error {
+	transactionContext, err := factory.CreateTransactionContext(nil)
+	if err != nil {
+		return err
+	}
+	if err := transactionContext.StartTransaction(); err != nil {
+		return err
+	}
+	defer func() {
+		_ = transactionContext.RollbackTransaction()
+	}()
+	//确定 被评估的人
+
+	//确定 被评估人的 上级评估
+
+	//确定 被评估人的 人资评估
+
+	//确定 被评估人的 360 评估
+
+	//回填 项目的状态
+
+	if err := transactionContext.CommitTransaction(); err != nil {
+		return err
+	}
+	return nil
+}
--- a/pkg/domain/evaluation_project.go
查看文件 @149c0cd
+++ b/pkg/domain/evaluation_project.go
查看文件 @149c0cd
@@ -20,6 +20,7 @@ type EvaluationProject struct {
 	CycleId      int64               `json:"cycleId,string" comment:"周期ID"`
 	CreatorId    int64               `json:"creatorId,string" comment:"创建人ID"`
 	State        int                 `json:"state" comment:"状态（0待完成配置、1待启用、2启用、3结束）"`
+	SummaryState ProjectSummaryState `json:"summaryState" comment:"周期评估是否下发"`
 	HrBp         int                 `json:"hrBp" comment:"HR角色权限"`
 	Pmp          int                 `json:"pmp" comment:"PM角色权限"`
 	PmpIds       []string            `json:"pmpIds" comment:"项目管理员ID"`
@@ -32,6 +33,13 @@ type EvaluationProject struct {
 	DeletedAt    *time.Time          `json:"deletedAt" comment:"删除时间"`
 }
+type ProjectSummaryState int
+
+const (
+	ProjectSummaryStateNo  int = 0 //未下发
+	ProjectSummaryStateYes int = 1 //已经下发
+)
+
 type EvaluationProjectRepository interface {
 	Insert(project *EvaluationProject) (*EvaluationProject, error)
 	Remove(project *EvaluationProject) (*EvaluationProject, error)
--- a/pkg/infrastructure/pg/models/evaluation_project.go
查看文件 @149c0cd
+++ b/pkg/infrastructure/pg/models/evaluation_project.go
查看文件 @149c0cd
 package models
 import (
-	"gitlab.fjmaimaimai.com/allied-creation/performance/pkg/domain"
 	"time"
+
+	"gitlab.fjmaimaimai.com/allied-creation/performance/pkg/domain"
 )
 type EvaluationProject struct {
@@ -14,6 +15,7 @@ type EvaluationProject struct {
 	CycleId      int64                      `comment:"周期ID"`
 	CreatorId    int64                      `comment:"创建人ID"`
 	State        int                        `comment:"状态（0待完成配置、1待启用、2启用、3停用）" pg:",use_zero"`
+	SummaryState int                        `comment:"周期评估是否下发" pg:",use_zero"`
 	HrBp         int                        `comment:"HR角色权限" pg:",use_zero"`
 	Pmp          int                        `comment:"PM角色权限" pg:",use_zero"`
 	PmpIds       []string                   `comment:"项目管理员ID"`
--- a/pkg/infrastructure/repository/pg_evaluation_project_repository.go
查看文件 @149c0cd
+++ b/pkg/infrastructure/repository/pg_evaluation_project_repository.go
查看文件 @149c0cd
@@ -3,13 +3,14 @@ package repository
 import (
 	"errors"
 	"fmt"
+	"time"
+
 	"github.com/go-pg/pg/v10"
 	"github.com/linmadan/egglib-go/persistent/pg/sqlbuilder"
 	pgTransaction "github.com/linmadan/egglib-go/transaction/pg"
 	"gitlab.fjmaimaimai.com/allied-creation/performance/pkg/domain"
 	"gitlab.fjmaimaimai.com/allied-creation/performance/pkg/infrastructure/pg/models"
 	"gitlab.fjmaimaimai.com/allied-creation/performance/pkg/utils"
-	"time"
 )
 type EvaluationProjectRepository struct {
@@ -41,6 +42,7 @@ func (repo *EvaluationProjectRepository) TransformToDomain(m *models.EvaluationP
 		CycleId:      m.CycleId,
 		CreatorId:    m.CreatorId,
 		State:        m.State,
+		SummaryState: domain.ProjectSummaryState(m.SummaryState),
 		HrBp:         m.HrBp,
 		Pmp:          m.Pmp,
 		PmpIds:       m.PmpIds,
@@ -63,6 +65,7 @@ func (repo *EvaluationProjectRepository) TransformToModel(d *domain.EvaluationPr
 		CycleId:      d.CycleId,
 		CreatorId:    d.CreatorId,
 		State:        d.State,
+		SummaryState: int(d.SummaryState),
 		HrBp:         d.HrBp,
 		Pmp:          d.Pmp,
 		PmpIds:       d.PmpIds,
--- a/pkg/port/beego/controllers/summary_evaluation_controller.go
查看文件 @149c0cd
+++ b/pkg/port/beego/controllers/summary_evaluation_controller.go
查看文件 @149c0cd
@@ -175,6 +175,7 @@ func (c *SummaryEvaluationController) EditEvaluationHRBP() {
 	c.Response(data, err)
 }
+// 获取上级评估
 func (c *SummaryEvaluationController) GetEvaluationSuper() {
 	srv := service.NewSummaryEvaluationService()
 	param := &command.QueryEvaluationSuper{}
@@ -190,6 +191,7 @@ func (c *SummaryEvaluationController) GetEvaluationSuper() {
 	c.Response(data, err)
 }
+// 编辑上级评估
 func (c *SummaryEvaluationController) EditEvaluationSuper() {
 	srv := service.NewSummaryEvaluationService()
 	param := &command.EditEvaluationValue{}
@@ -206,6 +208,7 @@ func (c *SummaryEvaluationController) EditEvaluationSuper() {
 	c.Response(data, err)
 }
+// 上级评估列表
 func (c *SummaryEvaluationController) ListEvaluationSuper() {
 	srv := service.NewSummaryEvaluationService()
 	param := &command.QueryEvaluationList{}
@@ -221,3 +224,19 @@ func (c *SummaryEvaluationController) ListEvaluationSuper() {
 	data, err := srv.ListEvaluationSuper(param)
 	c.Response(data, err)
 }
+
+// 员工确认评估分数
+func (c *SummaryEvaluationController) ConfirmScoreSuperEvaluation() {
+	srv := service.NewSummaryEvaluationService()
+	param := &command.ConfirmScore{}
+	err := c.BindJSON(param)
+	if err != nil {
+		e := application.ThrowError(application.ARG_ERROR, "json 解析错误"+err.Error())
+		c.Response(nil, e)
+		return
+	}
+	userReq := middlewares.GetUser(c.Ctx)
+	param.UserId = int(userReq.UserId)
+	err = srv.ConfirmScoreSuperEvaluation(param)
+	c.Response(nil, err)
+}
--- a/pkg/port/beego/routers/summary_evaluation_router.go
查看文件 @149c0cd
+++ b/pkg/port/beego/routers/summary_evaluation_router.go
查看文件 @149c0cd
@@ -23,6 +23,8 @@ func init() {
 		web.NSCtrlPost("/evaluation-super", (*controllers.SummaryEvaluationController).GetEvaluationSuper),
 		web.NSCtrlPost("/evaluation-super/edit", (*controllers.SummaryEvaluationController).EditEvaluationSuper),
 		web.NSCtrlPost("/evaluation-super/list", (*controllers.SummaryEvaluationController).ListEvaluationSuper),
+		web.NSCtrlPost("/evaluation-super/confirm", (*controllers.SummaryEvaluationController).ConfirmScoreSuperEvaluation),
+		//
 	)
 	web.AddNamespace(summaryNS)
 }