Merge branch 'dev' of http://gitlab.fjmaimaimai.com/allied-creation/allied-creat…

…ion-cooperation into dev

@@ -175,11 +175,20 @@ func (cooperationProjectService *CooperationProjectService) CreateCooperationPro
 			"orgId":                    createCooperationProjectCommand.OrgId,
 			"orgId":                    createCooperationProjectCommand.OrgId,
 			"cooperationProjectNumber": projectNumber,
 			"cooperationProjectNumber": projectNumber,
 		})
 		})
-		// TODO 校验共创项目名称是否唯一
-
 		if !numberAvailable {
 		if !numberAvailable {
 			return nil, application.ThrowError(application.TRANSACTION_ERROR, "新增共创项目异常")
 			return nil, application.ThrowError(application.TRANSACTION_ERROR, "新增共创项目异常")
 		}
 		}
+
+		// 校验共创项目名称是否唯一
+		nameAvailable, _ := cooperationProjectDao.CheckProjectNameAvailable(map[string]interface{}{
+			"companyId":              createCooperationProjectCommand.CompanyId,
+			"orgId":                  createCooperationProjectCommand.OrgId,
+			"cooperationProjectName": createCooperationProjectCommand.CooperationProjectName,
+		})
+		if !nameAvailable {
+			return nil, application.ThrowError(application.TRANSACTION_ERROR, "共创项目名称重复")
+		}
+
 		newCooperationProject := &domain.CooperationProject{
 		newCooperationProject := &domain.CooperationProject{
 			CooperationProjectNumber:          projectNumber,
 			CooperationProjectNumber:          projectNumber,
 			CooperationProjectName:            createCooperationProjectCommand.CooperationProjectName,
 			CooperationProjectName:            createCooperationProjectCommand.CooperationProjectName,
@@ -489,6 +498,16 @@ func (cooperationProjectService *CooperationProjectService) UpdateCooperationPro
 		operator = data
 		operator = data
 	}
 	}
 
 
+	// 共创项目DAO初始化
+	var cooperationProjectDao *dao.CooperationProjectDao
+	if value, err := factory.CreateCooperationProjectDao(map[string]interface{}{
+		"transactionContext": transactionContext,
+	}); err != nil {
+		return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
+	} else {
+		cooperationProjectDao = value
+	}
+
 	// 获取发起人
 	// 获取发起人
 	var sponsor *domain.User
 	var sponsor *domain.User
 	// sponsorUid类型转换
 	// sponsorUid类型转换
@@ -520,6 +539,18 @@ func (cooperationProjectService *CooperationProjectService) UpdateCooperationPro
 		return nil, application.ThrowError(application.RES_NO_FIND_ERROR, fmt.Sprintf("%s", string(updateCooperationProjectCommand.CooperationProjectId)))
 		return nil, application.ThrowError(application.RES_NO_FIND_ERROR, fmt.Sprintf("%s", string(updateCooperationProjectCommand.CooperationProjectId)))
 	}
 	}
 
 
+	// 校验共创项目名称是否唯一
+	if cooperationProject.CooperationProjectName != updateCooperationProjectCommand.CooperationProjectName {
+		nameAvailable, _ := cooperationProjectDao.CheckProjectNameAvailable(map[string]interface{}{
+			"companyId":              updateCooperationProjectCommand.CompanyId,
+			"orgId":                  updateCooperationProjectCommand.OrgId,
+			"cooperationProjectName": updateCooperationProjectCommand.CooperationProjectName,
+		})
+		if !nameAvailable {
+			return nil, application.ThrowError(application.TRANSACTION_ERROR, "共创项目名称重复")
+		}
+	}
+
 	applicantTypes := make(map[int32]interface{})
 	applicantTypes := make(map[int32]interface{})
 
 
 	// 获取所有申请人
 	// 获取所有申请人

@@ -104,6 +104,24 @@ func (dao *CooperationProjectDao) CheckProjectNumberAvailable(queryOptions map[s
 	return !ok, err
 	return !ok, err
 }
 }
 
 
+// CheckProjectNameAvailable 校验共创项目名称唯一
+func (dao *CooperationProjectDao) CheckProjectNameAvailable(queryOptions map[string]interface{}) (bool, error) {
+	tx := dao.transactionContext.PgTx
+	var cooperationProjectModels []*models.CooperationProject
+	query := tx.Model(&cooperationProjectModels)
+	if cooperationProjectName, ok := queryOptions["cooperationProjectName"]; ok && cooperationProjectName != "" {
+		query = query.Where("cooperation_project_name = ?", cooperationProjectName)
+	}
+	if companyId, ok := queryOptions["companyId"]; ok && companyId.(int64) != 0 {
+		query = query.Where(`cooperation_project.company @> '{"companyId":"?"}'`, companyId)
+	}
+	if orgId, ok := queryOptions["orgId"]; ok && orgId.(int64) != 0 {
+		query = query.Where(`cooperation_project.org @> '{"orgId":"?"}'`, orgId)
+	}
+	ok, err := query.Exists()
+	return !ok, err
+}
+
 func NewCooperationProjectDao(transactionContext *pgTransaction.TransactionContext) (*CooperationProjectDao, error) {
 func NewCooperationProjectDao(transactionContext *pgTransaction.TransactionContext) (*CooperationProjectDao, error) {
 	if transactionContext == nil {
 	if transactionContext == nil {
 		return nil, fmt.Errorf("transactionContext参数不能为nil")
 		return nil, fmt.Errorf("transactionContext参数不能为nil")

@@ -8,7 +8,7 @@ import (
 type CooperationContractUndertaker struct {
 type CooperationContractUndertaker struct {
 	tableName string `comment:"共创合约承接人" pg:"cooperation_contract_undertakers,alias:cooperation_contract_undertaker"`
 	tableName string `comment:"共创合约承接人" pg:"cooperation_contract_undertakers,alias:cooperation_contract_undertaker"`
 	// 共创合约承接人id
 	// 共创合约承接人id
-	CooperationContractUndertakerId int64 `comment:"共创合约承接人id" pg:",pk,unique"`
+	CooperationContractUndertakerId int64 `comment:"共创合约承接人id" pg:",pk"`
 	// 共创合约编号
 	// 共创合约编号
 	CooperationContractNumber string `comment:"共创合约编号"`
 	CooperationContractNumber string `comment:"共创合约编号"`
 	// 共创合约承接人uid
 	// 共创合约承接人uid

@@ -8,7 +8,7 @@ import (
 type DividendsIncentivesRule struct {
 type DividendsIncentivesRule struct {
 	tableName string `comment:"金额激励规则实体" pg:"dividends_incentives_rules,alias:dividends_incentives_rule"`
 	tableName string `comment:"金额激励规则实体" pg:"dividends_incentives_rules,alias:dividends_incentives_rule"`
 	// 分红规则ID
 	// 分红规则ID
-	DividendsIncentivesRuleId int64 `comment:"分红规则ID" pg:",pk,unique"`
+	DividendsIncentivesRuleId int64 `comment:"分红规则ID" pg:",pk"`
 	// 关联的项目合约编号
 	// 关联的项目合约编号
 	CooperationContractNumber string `comment:"关联的项目合约编号"`
 	CooperationContractNumber string `comment:"关联的项目合约编号"`
 	// 推荐人抽成比例
 	// 推荐人抽成比例

@@ -10,7 +10,7 @@ type DividendsOrder struct {
 	// 分红订单ID
 	// 分红订单ID
 	DividendsOrderId int64 `comment:"分红订单ID" pg:",pk"`
 	DividendsOrderId int64 `comment:"分红订单ID" pg:",pk"`
 	// 分红订单号
 	// 分红订单号
-	DividendsOrderNumber string `comment:"分红订单号" pg:",unique"`
+	DividendsOrderNumber string `comment:"分红订单号"`
 	// 分红订单原单号
 	// 分红订单原单号
 	DividendsOriginalOrderNum string `comment:"分红订单原单号"`
 	DividendsOriginalOrderNum string `comment:"分红订单原单号"`
 	// 分红订单金额
 	// 分红订单金额

@@ -10,7 +10,7 @@ type DividendsReturnedOrder struct {
 	// 分红退货单记录ID
 	// 分红退货单记录ID
 	DividendsReturnedOrderId int64 `comment:"分红退货单记录ID" pg:",pk"`
 	DividendsReturnedOrderId int64 `comment:"分红退货单记录ID" pg:",pk"`
 	// 分红退货单号
 	// 分红退货单号
-	DividendsReturnedOrderNumber string `comment:"分红退货单号" pg:",unique"`
+	DividendsReturnedOrderNumber string `comment:"分红退货单号"`
 	// 退货金额
 	// 退货金额
 	DividendsReturnedOrderRefund float64 `comment:"退货金额"`
 	DividendsReturnedOrderRefund float64 `comment:"退货金额"`
 	// 源单号（原始订单号）
 	// 源单号（原始订单号）

@@ -8,7 +8,7 @@ import (
 type MoneyIncentivesRule struct {
 type MoneyIncentivesRule struct {
 	tableName string `comment:"金额激励规则实体" pg:"money_incentives_rules,alias:money_incentives_rule"`
 	tableName string `comment:"金额激励规则实体" pg:"money_incentives_rules,alias:money_incentives_rule"`
 	// 金额激励规则ID
 	// 金额激励规则ID
-	MoneyIncentivesRuleId int64 `comment:"金额激励规则ID" pg:",pk,unique"`
+	MoneyIncentivesRuleId int64 `comment:"金额激励规则ID" pg:",pk"`
 	// 关联的共创合约编号
 	// 关联的共创合约编号
 	CooperationContractNumber string `comment:"关联的共创合约编号"`
 	CooperationContractNumber string `comment:"关联的共创合约编号"`
 	// 激励金额
 	// 激励金额