Merge branch 'test' of http://gitlab.fjmaimaimai.com/allied-creation/performance into test

@@ -2,6 +2,7 @@ package service
 
 
 import (
 import (
 	"fmt"
 	"fmt"
+	"gitlab.fjmaimaimai.com/allied-creation/performance/pkg/infrastructure/xredis"
 	"strconv"
 	"strconv"
 	"strings"
 	"strings"
 	"time"
 	"time"
@@ -501,6 +502,15 @@ func (rs *EvaluationProjectService) List(in *command.QueryProjectCommand) (inter
 }
 }
 
 
 func (rs *EvaluationProjectService) Activate(in *command.ActivateProjectCommand) (interface{}, error) {
 func (rs *EvaluationProjectService) Activate(in *command.ActivateProjectCommand) (interface{}, error) {
+	lock := xredis.NewLockProjectId(int(in.Id))
+	err := lock.Lock()
+	if err != nil {
+		return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
+	}
+	defer func() {
+		lock.UnLock()
+	}()
+
 	transactionContext, err := factory.ValidateStartTransaction(in)
 	transactionContext, err := factory.ValidateStartTransaction(in)
 	if err != nil {
 	if err != nil {
 		return nil, err
 		return nil, err
@@ -736,6 +746,9 @@ func (rs *EvaluationProjectService) Resume(in *command.ActivateProjectCommand) (
 	if project.State == domain.ProjectStateEnable {
 	if project.State == domain.ProjectStateEnable {
 		return nil, application.ThrowError(application.BUSINESS_ERROR, "项目已启动")
 		return nil, application.ThrowError(application.BUSINESS_ERROR, "项目已启动")
 	}
 	}
+	if project.State == domain.ProjectStatePause {
+		return nil, application.ThrowError(application.BUSINESS_ERROR, "项目暂停中，先进行恢复")
+	}
 
 
 	// 周期内的所有项目，已启用的员工不能重复被评估
 	// 周期内的所有项目，已启用的员工不能重复被评估
 	_, projects, err := projectRepository.Find(map[string]interface{}{"companyId": project.CompanyId, "cycleId": project.CycleId}, "template")
 	_, projects, err := projectRepository.Find(map[string]interface{}{"companyId": project.CompanyId, "cycleId": project.CycleId}, "template")

+package xredis
+
+import (
+	"fmt"
+
+	"github.com/go-redsync/redsync/v4"
+)
+
+type LockProjectId struct {
+	m *redsync.Mutex
+}
+
+func NewLockProjectId(id int) *LockProjectId {
+	key := fmt.Sprintf("performance:project_id:%d", id)
+	return &LockProjectId{
+		m: rsync.NewMutex(key),
+	}
+}
+
+func (lk *LockProjectId) Lock() error {
+	return lk.m.Lock()
+}
+
+func (lk *LockProjectId) UnLock() (bool, error) {
+	return lk.m.Unlock()
+}