feat:分红订单整合订单号生成功能，增加订单号唯一校验

@@ -9,6 +9,7 @@ import (
 	"gitlab.fjmaimaimai.com/allied-creation/allied-creation-cooperation/pkg/application/factory"
 	"gitlab.fjmaimaimai.com/allied-creation/allied-creation-cooperation/pkg/domain"
 	"gitlab.fjmaimaimai.com/allied-creation/allied-creation-cooperation/pkg/domain/service"
+	"gitlab.fjmaimaimai.com/allied-creation/allied-creation-cooperation/pkg/infrastructure/dao"
 	"strconv"
 	"time"
 )
@@ -90,6 +91,29 @@ func (dividendsOrderService *DividendsOrderService) CreateDividendsOrder(createD
 		salesman = data
 	}
 
+	// 分红订单DAO初始化
+	var dividendsOrderDao *dao.DividendsOrderDao
+	if value, err := factory.CreateDividendsOrderDao(map[string]interface{}{
+		"transactionContext": transactionContext,
+	}); err != nil {
+		return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
+	} else {
+		dividendsOrderDao = value
+	}
+	// 生成分红订单号
+	dividendsOrderNumber, err := dividendsOrderDao.GenerateDividendsOrderNumber()
+	if err != nil {
+		return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
+	}
+	// 校验分红订单编号是否唯一
+	numberAvailable, _ := dividendsOrderDao.CheckDividendsOrderNumberAvailable(map[string]interface{}{
+		"companyId":            createDividendsOrderCommand.CompanyId,
+		"orgId":                createDividendsOrderCommand.OrgId,
+		"dividendsOrderNumber": dividendsOrderNumber,
+	})
+	if !numberAvailable {
+		return nil, application.ThrowError(application.TRANSACTION_ERROR, "新增分红订单异常")
+	}
 	// 获取订单产品
 	var orderGoods []*domain.OrderGood
 	for _, orderGood := range createDividendsOrderCommand.OrderGoods {
@@ -99,7 +123,7 @@ func (dividendsOrderService *DividendsOrderService) CreateDividendsOrder(createD
 			OrderGoodName:                orderGood.OrderGoodName,
 			OrderGoodPrice:               orderGood.OrderGoodPrice,
 			OrderGoodQuantity:            orderGood.OrderGoodQuantity,
-			DividendsOrderNumber:         "", //TODO 分红订单号，规则生成
+			DividendsOrderNumber:         dividendsOrderNumber,
 			DividendsReturnedOrderNumber: "",
 			CooperationContractNumber:    orderGood.CooperationContractNumber,
 			OrderGoodExpense:             0,
@@ -113,7 +137,7 @@ func (dividendsOrderService *DividendsOrderService) CreateDividendsOrder(createD
 
 	newDividendsOrder := &domain.DividendsOrder{
 		DividendsOrderId:          0,
-		DividendsOrderNumber:      "", // TODO 分红订单号，规则生成
+		DividendsOrderNumber:      dividendsOrderNumber,
 		DividendsOriginalOrderNum: createDividendsOrderCommand.DividendsOriginalOrderNum,
 		DividendsOrderAmount:      createDividendsOrderCommand.DividendsOrderAmount,
 		OrderSalesman:             salesman,

@@ -35,6 +35,24 @@ func (dao *DividendsOrderDao) GenerateDividendsOrderNumber() (string, error) {
 	}
 }
 
+// CheckDividendsOrderNumberAvailable 校验分红订单是否唯一
+func (dao *DividendsOrderDao) CheckDividendsOrderNumberAvailable(queryOptions map[string]interface{}) (bool, error) {
+	tx := dao.transactionContext.PgTx
+	var dividendsOrderModels []*models.DividendsOrder
+	query := tx.Model(&dividendsOrderModels)
+	if dividendsOrderNumber, ok := queryOptions["dividendsOrderNumber"]; ok && dividendsOrderNumber != "" {
+		query = query.Where("dividends_order_number = ?", dividendsOrderNumber)
+	}
+	if companyId, ok := queryOptions["companyId"]; ok && companyId.(int64) != 0 {
+		query = query.Where(`cooperation_contract.company @> '{"companyId":"?"}'`, companyId)
+	}
+	if orgId, ok := queryOptions["orgId"]; ok && orgId.(int64) != 0 {
+		query = query.Where(`cooperation_contract.org @> '{"orgId":"?"}'`, orgId)
+	}
+	ok, err := query.Exists()
+	return !ok, err
+}
+
 func NewDividendsOrderDao(transactionContext *pgTransaction.TransactionContext) (*DividendsOrderDao, error) {
 	if transactionContext == nil {
 		return nil, fmt.Errorf("transactionContext参数不能未")

@@ -184,7 +184,7 @@ func (repository *CooperationApplicationRepository) Find(queryOptions map[string
 	if cooperationProjectNumber, ok := queryOptions["cooperationProjectNumber"]; ok && cooperationProjectNumber != "" {
 		query.Where("cooperation_project_number like ?", fmt.Sprintf("%%%s%%", cooperationProjectNumber))
 	}
-	//TODO 共创项目名称查询
+	// 共创项目名称查询
 	if cooperationProjectName, ok := queryOptions["cooperationProjectName"]; ok && cooperationProjectName != "" {
 		query.Join("LEFT JOIN cooperation_projects AS a").
 			JoinOn("a.cooperation_project_number = cooperation_application.cooperation_project_number").