修复bug ，项目出现多次反复启动停止

@@ -506,7 +506,9 @@ func (rs *EvaluationProjectService) Activate(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")
 	if err != nil {
 	if err != nil {
@@ -599,7 +601,7 @@ func (rs *EvaluationProjectService) Activate(in *command.ActivateProjectCommand)
 			task.NextSentAt = nil
 			task.NextSentAt = nil
 		}
 		}
 
 
-		task, err := taskRepository.Insert(task)
+		_, err := taskRepository.Insert(task)
 		if err != nil {
 		if err != nil {
 			return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
 			return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
 		}
 		}
@@ -827,7 +829,17 @@ func (rs *EvaluationProjectService) CheckRecipients(in *command.CheckRecipientCo
 }
 }
 
 
 func (rs *EvaluationProjectService) generateEvaluationItemUsed(transactionContext application.TransactionContext, project *domain.EvaluationProject) error {
 func (rs *EvaluationProjectService) generateEvaluationItemUsed(transactionContext application.TransactionContext, project *domain.EvaluationProject) error {
-
+	itemUsedRepo := factory.CreateEvaluationItemUsedRepository(map[string]interface{}{
+		"transactionContext": transactionContext,
+	})
+	var err error
+	cnt, _, err := itemUsedRepo.Find(map[string]interface{}{"projectId": project.Id})
+	if err != nil {
+		return application.ThrowError(application.TRANSACTION_ERROR, "检查评估选项"+err.Error())
+	}
+	if cnt > 0 {
+		return nil
+	}
 	var itemUsedList []*domain.EvaluationItemUsed
 	var itemUsedList []*domain.EvaluationItemUsed
 	nowTime := time.Now()
 	nowTime := time.Now()
 	for _, v := range project.Template.LinkNodes {
 	for _, v := range project.Template.LinkNodes {
@@ -859,10 +871,8 @@ func (rs *EvaluationProjectService) generateEvaluationItemUsed(transactionContex
 			itemUsedList = append(itemUsedList, &item)
 			itemUsedList = append(itemUsedList, &item)
 		}
 		}
 	}
 	}
-	itemUsedRepo := factory.CreateEvaluationItemUsedRepository(map[string]interface{}{
-		"transactionContext": transactionContext,
-	})
-	err := itemUsedRepo.BatchInsert(itemUsedList)
+
+	err = itemUsedRepo.BatchInsert(itemUsedList)
 	if err != nil {
 	if err != nil {
 		return application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
 		return application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
 	}
 	}