Merge branch 'test' of http://gitlab.fjmaimaimai.com/allied-creation/allied-crea…

…tion-cooperation into test

Merge branch 'test' of http://gitlab.fjmaimaimai.com/allied-creation/allied-crea…
…tion-cooperation into test
yangfu
pkg/application/creditAccount/service/credit_account.go
pkg/application/dividendsEstimate/service/dividends_estimate.go
pkg/domain/account_detail.go
pkg/infrastructure/domain_service/pg_confirm_dividends_incentives_estimate_service.go
pkg/infrastructure/pg/transform/dividends_estimate.go
pkg/infrastructure/pg/transform/money_incentives_rule.go
pkg/infrastructure/pg/transform/order_good.go
--- a/pkg/application/creditAccount/service/credit_account.go
查看文件 @c953744
+++ b/pkg/application/creditAccount/service/credit_account.go
查看文件 @c953744
@@ -150,6 +150,7 @@ func (creditAccountService *CreditAccountService) CreateCreditAccount(createCred
 		var goodAmountCount float64
 		for _, dividendsEstimate := range dividendsEstimates {
 			accountDetail = append(accountDetail, &domain.AccountDetail{
+				DividendsEstimateOrderId:     dividendsEstimate.DividendsEstimateId,
 				DividendsEstimateOrderNumber: dividendsEstimate.DividendsEstimateOrderNumber,
 				DividendsType:                dividendsEstimate.DividendsType,
 				DividendsAmount:              dividendsEstimate.DividendsAmount,
@@ -393,6 +394,7 @@ func (creditAccountService *CreditAccountService) RemoveCreditAccount(removeCred
 	defer func() {
 		_ = transactionContext.RollbackTransaction()
 	}()
+	// 账期结算单仓储初始化
 	var creditAccountRepository domain.CreditAccountRepository
 	if value, err := factory.CreateCreditAccountRepository(map[string]interface{}{
 		"transactionContext": transactionContext,
@@ -401,20 +403,55 @@ func (creditAccountService *CreditAccountService) RemoveCreditAccount(removeCred
 	} else {
 		creditAccountRepository = value
 	}
-	creditAccount, err := creditAccountRepository.FindOne(map[string]interface{}{"creditAccountId": removeCreditAccountCommand.CreditAccountId})
+
+	// 分红预算单仓储初始化
+	var dividendsEstimateRepository domain.DividendsEstimateRepository
+	if value, err := factory.CreateDividendsEstimateRepository(map[string]interface{}{
+		"transactionContext": transactionContext,
+	}); err != nil {
+		return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
+	} else {
+		dividendsEstimateRepository = value
+	}
+
+	// 获取账期阶段单
+	creditAccount, err := creditAccountRepository.FindOne(map[string]interface{}{
+		"creditAccountId": removeCreditAccountCommand.CreditAccountId,
+	})
 	if err != nil {
 		return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
 	}
 	if creditAccount == nil {
 		return nil, application.ThrowError(application.RES_NO_FIND_ERROR, fmt.Sprintf("%s", strconv.FormatInt(removeCreditAccountCommand.CreditAccountId, 10)))
 	}
-	if creditAccount, err := creditAccountRepository.Remove(creditAccount); err != nil {
+	if creditAccountRemoved, err := creditAccountRepository.Remove(creditAccount); err != nil {
 		return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
 	} else {
+		// 更新相关分红预算单结算状态
+		dividendsEstimateIds := make([]int64, 0)
+		if count, dividendsEstimates, err := dividendsEstimateRepository.Find(map[string]interface{}{
+			"dividendsEstimateIds": dividendsEstimateIds,
+		}); err != nil {
+			return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
+		} else {
+			if count > 0 {
+				for i, dividendsEstimate := range dividendsEstimates {
+					if !dividendsEstimate.IsCanceled {
+						dividendsEstimates[i].DividendsAccountStatus = int32(1)
+					}
+				}
+				// 保存分红预算单
+				_, err3 := dividendsEstimateRepository.UpdateMany(dividendsEstimates)
+				if err3 != nil {
+					return nil, err3
+				}
+			}
+		}
+
 		if err := transactionContext.CommitTransaction(); err != nil {
 			return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
 		}
-		return creditAccount, nil
+		return creditAccountRemoved, nil
 	}
 }
--- a/pkg/application/dividendsEstimate/service/dividends_estimate.go
查看文件 @c953744
+++ b/pkg/application/dividendsEstimate/service/dividends_estimate.go
查看文件 @c953744
@@ -237,7 +237,11 @@ func (dividendsEstimateService *DividendsEstimateService) CancelDividendsEstimat
 	// 校验是否能够取消
 	if dividendsEstimate.DividendsType == domain.ORDER_DIVIDENDS || dividendsEstimate.DividendsType == domain.RETURN_WRITE_OFF { // 订单分红、退货冲销
-		if count, dividendsEstimatesRelative, err2 := dividendsEstimateRepository.Find(map[string]interface{}{"orderOrReturnedOrderNum": dividendsEstimate.OrderOrReturnedOrderNum}); err2 != nil {
+		if count, dividendsEstimatesRelative, err2 := dividendsEstimateRepository.Find(map[string]interface{}{
+			"orderOrReturnedOrderNum": dividendsEstimate.OrderOrReturnedOrderNum,
+			"companyId":               dividendsEstimate.Company.CompanyId,
+			"orgId":                   dividendsEstimate.Org.OrgId,
+		}); err2 != nil {
 			return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err2.Error())
 		} else {
 			if count > 0 {
@@ -249,7 +253,11 @@ func (dividendsEstimateService *DividendsEstimateService) CancelDividendsEstimat
 			}
 		}
 	} else if dividendsEstimate.DividendsType == domain.MONEY_INCENTIVES { // 金额激励分红
-		if count, dividendsEstimatesRelative, err3 := dividendsEstimateRepository.Find(map[string]interface{}{"cooperationContractNumber": dividendsEstimate.CooperationContractNumber}); err3 != nil {
+		if count, dividendsEstimatesRelative, err3 := dividendsEstimateRepository.Find(map[string]interface{}{
+			"cooperationContractNumber": dividendsEstimate.CooperationContractNumber,
+			"companyId":                 dividendsEstimate.Company.CompanyId,
+			"orgId":                     dividendsEstimate.Org.OrgId,
+		}); err3 != nil {
 			return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err3.Error())
 		} else {
 			if count > 0 {
@@ -347,10 +355,14 @@ func (dividendsEstimateService *DividendsEstimateService) BatchCancelDividendsEs
 				// 校验是否能够取消
 				if dividendsEstimate.DividendsType == domain.ORDER_DIVIDENDS || dividendsEstimate.DividendsType == domain.RETURN_WRITE_OFF { // 订单分红、退货冲销
-					if count, dividendsEstimatesRelative, err2 := dividendsEstimateRepository.Find(map[string]interface{}{"orderOrReturnedOrderNum": dividendsEstimate.OrderOrReturnedOrderNum}); err2 != nil {
+					if countRelativeDividendsEstimates, dividendsEstimatesRelative, err2 := dividendsEstimateRepository.Find(map[string]interface{}{
+						"orderOrReturnedOrderNum": dividendsEstimate.OrderOrReturnedOrderNum,
+						"companyId":               dividendsEstimate.Company.CompanyId,
+						"orgId":                   dividendsEstimate.Org.OrgId,
+					}); err2 != nil {
 						return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err2.Error())
 					} else {
-						if count > 0 {
+						if countRelativeDividendsEstimates > 0 {
 							for _, dividendsEstimateRelative := range dividendsEstimatesRelative {
 								if dividendsEstimateRelative.DividendsAccountStatus == domain.ACCOUNTED {
 									return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, "已有相关分红预算单已结算，无法取消")
@@ -359,10 +371,14 @@ func (dividendsEstimateService *DividendsEstimateService) BatchCancelDividendsEs
 						}
 					}
 				} else if dividendsEstimate.DividendsType == domain.MONEY_INCENTIVES { // 金额激励分红
-					if count, dividendsEstimatesRelative, err3 := dividendsEstimateRepository.Find(map[string]interface{}{"cooperationContractNumber": dividendsEstimate.CooperationContractNumber}); err3 != nil {
+					if countRelativeDividendsEstimates, dividendsEstimatesRelative, err3 := dividendsEstimateRepository.Find(map[string]interface{}{
+						"cooperationContractNumber": dividendsEstimate.CooperationContractNumber,
+						"companyId":                 dividendsEstimate.Company.CompanyId,
+						"orgId":                     dividendsEstimate.Org.OrgId,
+					}); err3 != nil {
 						return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err3.Error())
 					} else {
-						if count > 0 {
+						if countRelativeDividendsEstimates > 0 {
 							for _, dividendsEstimateRelative := range dividendsEstimatesRelative {
 								if dividendsEstimateRelative.DividendsAccountStatus == domain.ACCOUNTED {
 									return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, "已有相关分红预算单已结算，无法取消")
@@ -1420,12 +1436,10 @@ func (dividendsEstimateService *DividendsEstimateService) SearchMoneyIncentivesE
 								stageUndertakerMap[dividendsEstimate.DividendsStage] = append(stageUndertakerMap[dividendsEstimate.DividendsStage], undertaker)
 							}
 						}
-						break
 					} else if countDividendsEstimates == 0 { // 未分红，可以加入任意阶段进行金额激励
 						for i, _ := range stageUndertakerMap {
 							stageUndertakerMap[i] = append(stageUndertakerMap[i], undertaker)
 						}
-						break
 					}
 				}
 			}
--- a/pkg/domain/account_detail.go
查看文件 @c953744
+++ b/pkg/domain/account_detail.go
查看文件 @c953744
 package domain
 type AccountDetail struct {
-	// 分红预算单号
+	// 分红预算单号ID
+	DividendsEstimateOrderId int64 `json:"dividendsEstimateOrderId"`
+	// 分红预算单编号
 	DividendsEstimateOrderNumber string `json:"dividendsEstimateOrderNumber"`
 	// 分红类型，1订单分红，2退货冲销，3金额激励
 	DividendsType int32 `json:"dividendsType"`
--- a/pkg/infrastructure/domain_service/pg_confirm_dividends_incentives_estimate_service.go
查看文件 @c953744
+++ b/pkg/infrastructure/domain_service/pg_confirm_dividends_incentives_estimate_service.go
查看文件 @c953744
@@ -117,21 +117,6 @@ func (domainService *ConfirmDividendsIncentivesEstimateService) Confirm(orderGoo
 			continue
 		}
-		// 校验合约关联的项目是否已结束
-		//if cooperationProject.Status == 2 {
-		//	dividendsEstimateDetails = append(dividendsEstimateDetails, &service.DividendsEstimateDetail{
-		//		DividendsUser:              nil,
-		//		DividendsParticipateType:   0,
-		//		DividendsStage:             0,
-		//		DividendsAmount:            0,
-		//		OrderOrReturnedOrderNumber: orderGood.DividendsOrderNumber,
-		//		IsSuccessfully:             false,
-		//		Reason:                     "共创项目" + orderGood.CooperationContractNumber + "已结束",
-		//	})
-		//	continue
-		//	//return nil, application.ThrowError(application.RES_NO_FIND_ERROR, fmt.Sprintf("共创项目%s已结束", cooperationContract.CooperationProjectNumber))
-		//}
-
 		if orderGood.DividendsOrderNumber != "" { // 获取分红订单
 			// 获取分红订单
 			dividendsOrder, err2 := dividendsOrderRepository.FindOne(map[string]interface{}{
@@ -190,6 +175,7 @@ func (domainService *ConfirmDividendsIncentivesEstimateService) Confirm(orderGoo
 			if dividendsIncentivesRuleMatched != nil {
 				for _, undertaker := range cooperationContract.Undertakers {
 					// 添加承接人分红预算信息详情
+					if dividendsIncentivesRuleMatched.DividendsIncentivesPercentage > 0 {
 						undertakerDividendsAmount, _ := decimal.NewFromFloat(orderGood.OrderGoodAmount).Mul(decimal.NewFromFloat(dividendsIncentivesRuleMatched.DividendsIncentivesPercentage).Div(decimal.NewFromFloat(100))).Float64()
 						dividendsEstimateDetails = append(dividendsEstimateDetails, &service.DividendsEstimateDetail{
 							DividendsUser: &domain.User{
@@ -212,8 +198,11 @@ func (domainService *ConfirmDividendsIncentivesEstimateService) Confirm(orderGoo
 							OrderOrReturnedOrderNumber: dividendsOrder.DividendsOrderNumber,
 							IsSuccessfully:             true,
 						})
+					}
+
 					//	添加推荐人分红预算信息详情
 					if undertaker.Referrer != nil {
+						if dividendsIncentivesRuleMatched.ReferrerPercentage > 0 {
 							referrerDividendsAmount, _ := decimal.NewFromFloat(orderGood.OrderGoodAmount).Mul(decimal.NewFromFloat(dividendsIncentivesRuleMatched.ReferrerPercentage).Div(decimal.NewFromFloat(100))).Float64()
 							dividendsEstimateDetails = append(dividendsEstimateDetails, &service.DividendsEstimateDetail{
 								DividendsUser: &domain.User{
@@ -236,8 +225,10 @@ func (domainService *ConfirmDividendsIncentivesEstimateService) Confirm(orderGoo
 								IsSuccessfully:             true,
 							})
 						}
+					}
 					//	添加关联业务员分红预算信息详情
 					if undertaker.Salesman != nil {
+						if dividendsIncentivesRuleMatched.SalesmanPercentage > 0 {
 							salesmanDividendsAmount, _ := decimal.NewFromFloat(orderGood.OrderGoodAmount).Mul(decimal.NewFromFloat(dividendsIncentivesRuleMatched.SalesmanPercentage).Div(decimal.NewFromFloat(100))).Float64()
 							dividendsEstimateDetails = append(dividendsEstimateDetails, &service.DividendsEstimateDetail{
 								DividendsUser: &domain.User{
@@ -262,6 +253,7 @@ func (domainService *ConfirmDividendsIncentivesEstimateService) Confirm(orderGoo
 						}
 					}
 				}
+			}
 		} else if orderGood.DividendsReturnedOrderNumber != "" { // 获取退货单
 			dividendsReturnedOrder, err3 := dividendsReturnedOrderRepository.FindOne(map[string]interface{}{
 				"dividendsReturnedOrderNumber": orderGood.DividendsReturnedOrderNumber,
@@ -304,6 +296,7 @@ func (domainService *ConfirmDividendsIncentivesEstimateService) Confirm(orderGoo
 			//	计算分红
 			for _, undertaker := range cooperationContract.Undertakers {
 				// 添加承接人分红退货预算信息详情
+				if dividendsIncentivesRuleMatched.DividendsIncentivesPercentage > 0 {
 					undertakerDividendsAmount, _ := decimal.NewFromFloat(orderGood.OrderGoodAmount).Mul(decimal.NewFromFloat(dividendsIncentivesRuleMatched.DividendsIncentivesPercentage).Div(decimal.NewFromFloat(100))).Float64()
 					dividendsEstimateDetails = append(dividendsEstimateDetails, &service.DividendsEstimateDetail{
 						DividendsUser: &domain.User{
@@ -326,8 +319,11 @@ func (domainService *ConfirmDividendsIncentivesEstimateService) Confirm(orderGoo
 						OrderOrReturnedOrderNumber: dividendsReturnedOrder.DividendsOrderNumber,
 						IsSuccessfully:             true,
 					})
+				}
+
 				//	添加推荐人分红退货预算信息详情
 				if undertaker.Referrer != nil {
+					if dividendsIncentivesRuleMatched.ReferrerPercentage > 0 {
 						referrerDividendsAmount, _ := decimal.NewFromFloat(orderGood.OrderGoodAmount).Mul(decimal.NewFromFloat(dividendsIncentivesRuleMatched.ReferrerPercentage).Div(decimal.NewFromFloat(100))).Float64()
 						dividendsEstimateDetails = append(dividendsEstimateDetails, &service.DividendsEstimateDetail{
 							DividendsUser: &domain.User{
@@ -350,8 +346,11 @@ func (domainService *ConfirmDividendsIncentivesEstimateService) Confirm(orderGoo
 							IsSuccessfully:             true,
 						})
 					}
+				}
+
 				//	添加关联业务员分红退货预算信息详情
 				if undertaker.Salesman != nil {
+					if dividendsIncentivesRuleMatched.SalesmanPercentage > 0 {
 						salesmanDividendsAmount, _ := decimal.NewFromFloat(orderGood.OrderGoodAmount).Mul(decimal.NewFromFloat(dividendsIncentivesRuleMatched.SalesmanPercentage).Div(decimal.NewFromFloat(100))).Float64()
 						dividendsEstimateDetails = append(dividendsEstimateDetails, &service.DividendsEstimateDetail{
 							DividendsUser: &domain.User{
@@ -374,6 +373,8 @@ func (domainService *ConfirmDividendsIncentivesEstimateService) Confirm(orderGoo
 							IsSuccessfully:             true,
 						})
 					}
+
+				}
 			}
 		}
 	}
--- a/pkg/infrastructure/pg/transform/dividends_estimate.go
查看文件 @c953744
+++ b/pkg/infrastructure/pg/transform/dividends_estimate.go
查看文件 @c953744
 package transform
 import (
+	"github.com/shopspring/decimal"
 	"gitlab.fjmaimaimai.com/allied-creation/allied-creation-cooperation/pkg/domain"
 	"gitlab.fjmaimaimai.com/allied-creation/allied-creation-cooperation/pkg/infrastructure/pg/models"
 )
 func TransformToDividendsEstimateDomainModelFromPgModels(dividendsEstimateModel *models.DividendsEstimate) (*domain.DividendsEstimate, error) {
+	dividendsAmount, _ := decimal.NewFromFloatWithExponent(dividendsEstimateModel.DividendsAmount, -2).Float64()
 	return &domain.DividendsEstimate{
 		DividendsEstimateId:          dividendsEstimateModel.DividendsEstimateId,
 		DividendsAccountStatus:       dividendsEstimateModel.DividendsAccountStatus,
-		DividendsAmount:              dividendsEstimateModel.DividendsAmount,
+		DividendsAmount:              dividendsAmount,
 		DividendsEstimateOrderNumber: dividendsEstimateModel.DividendsEstimateOrderNumber,
 		DividendsEstimateTime:        dividendsEstimateModel.DividendsEstimateTime,
 		DividendsParticipateType:     dividendsEstimateModel.DividendsParticipateType,
--- a/pkg/infrastructure/pg/transform/money_incentives_rule.go
查看文件 @c953744
+++ b/pkg/infrastructure/pg/transform/money_incentives_rule.go
查看文件 @c953744
 package transform
 import (
+	"github.com/shopspring/decimal"
 	"gitlab.fjmaimaimai.com/allied-creation/allied-creation-cooperation/pkg/domain"
 	"gitlab.fjmaimaimai.com/allied-creation/allied-creation-cooperation/pkg/infrastructure/pg/models"
 	"gitlab.fjmaimaimai.com/allied-creation/allied-creation-cooperation/pkg/infrastructure/utils"
@@ -8,10 +9,11 @@ import (
 func TransformToMoneyIncentivesRuleDomainModelFromPgModels(moneyIncentivesRuleModel *models.MoneyIncentivesRule) (*domain.MoneyIncentivesRule, error) {
 	stageString := utils.NumberToCNNumber(int(moneyIncentivesRuleModel.MoneyIncentivesStage))
+	moneyIncentivesAmount, _ := decimal.NewFromFloatWithExponent(moneyIncentivesRuleModel.MoneyIncentivesAmount, -2).Float64()
 	return &domain.MoneyIncentivesRule{
 		MoneyIncentivesRuleId:     moneyIncentivesRuleModel.MoneyIncentivesRuleId,
 		CooperationContractNumber: moneyIncentivesRuleModel.CooperationContractNumber,
-		MoneyIncentivesAmount:     moneyIncentivesRuleModel.MoneyIncentivesAmount,
+		MoneyIncentivesAmount:     moneyIncentivesAmount,
 		MoneyIncentivesStage:      moneyIncentivesRuleModel.MoneyIncentivesStage,
 		MoneyIncentivesStageCN:    stageString,
 		MoneyIncentivesStageEnd:   moneyIncentivesRuleModel.MoneyIncentivesStageEnd,
--- a/pkg/infrastructure/pg/transform/order_good.go
查看文件 @c953744
+++ b/pkg/infrastructure/pg/transform/order_good.go
查看文件 @c953744
 package transform
 import (
+	"github.com/shopspring/decimal"
 	"gitlab.fjmaimaimai.com/allied-creation/allied-creation-cooperation/pkg/domain"
 	"gitlab.fjmaimaimai.com/allied-creation/allied-creation-cooperation/pkg/infrastructure/pg/models"
 )
 func TransformToOrderGoodDomainModelFromPgModels(orderGoodModel *models.OrderGood) (*domain.OrderGood, error) {
+	orderGoodAmount, _ := decimal.NewFromFloatWithExponent(orderGoodModel.OrderGoodAmount, -2).Float64()
 	return &domain.OrderGood{
 		OrderGoodId:                  orderGoodModel.OrderGoodId,
-		OrderGoodAmount:              orderGoodModel.OrderGoodAmount,
+		OrderGoodAmount:              orderGoodAmount,
 		OrderGoodName:                orderGoodModel.OrderGoodName,
 		OrderGoodPrice:               orderGoodModel.OrderGoodPrice,
 		OrderGoodQuantity:            orderGoodModel.OrderGoodQuantity,