|
...
|
...
|
@@ -5,11 +5,13 @@ import ( |
|
|
|
"github.com/linmadan/egglib-go/core/application"
|
|
|
|
"github.com/linmadan/egglib-go/utils/tool_funs"
|
|
|
|
"gitlab.fjmaimaimai.com/allied-creation/allied-creation-cooperation/pkg/application/cooperationContract/command"
|
|
|
|
"gitlab.fjmaimaimai.com/allied-creation/allied-creation-cooperation/pkg/application/cooperationContract/dto"
|
|
|
|
"gitlab.fjmaimaimai.com/allied-creation/allied-creation-cooperation/pkg/application/cooperationContract/query"
|
|
|
|
"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"
|
|
|
|
"gitlab.fjmaimaimai.com/allied-creation/allied-creation-cooperation/pkg/infrastructure/utils"
|
|
|
|
"strconv"
|
|
|
|
"time"
|
|
|
|
)
|
|
...
|
...
|
@@ -250,6 +252,7 @@ func (cooperationContractService *CooperationContractService) CreateCooperationC |
|
|
|
CooperationContractDescription: createCooperationContractCommand.CooperationContractDescription,
|
|
|
|
CooperationContractName: createCooperationContractCommand.CooperationContractName,
|
|
|
|
CooperationContractNumber: contractNumber,
|
|
|
|
CooperationProjectNumber: createCooperationContractCommand.CooperationProjectNumber,
|
|
|
|
CooperationContractUndertakerTypes: createCooperationContractCommand.CooperationContractUndertakerTypes,
|
|
|
|
CooperationContractSponsor: sponsor,
|
|
|
|
CooperationMode: cooperationMode,
|
|
...
|
...
|
@@ -319,10 +322,31 @@ func (cooperationContractService *CooperationContractService) GetCooperationCont |
|
|
|
if cooperationContract == nil {
|
|
|
|
return nil, application.ThrowError(application.RES_NO_FIND_ERROR, fmt.Sprintf("%s", strconv.FormatInt(getCooperationContractQuery.CooperationContractId, 10)))
|
|
|
|
} else {
|
|
|
|
// 共创合约DAO初始化
|
|
|
|
var cooperationContractDao *dao.CooperationContractDao
|
|
|
|
if value, err := factory.CreateCooperationContractDao(map[string]interface{}{
|
|
|
|
"transactionContext": transactionContext,
|
|
|
|
}); err != nil {
|
|
|
|
return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
|
|
|
|
} else {
|
|
|
|
cooperationContractDao = value
|
|
|
|
}
|
|
|
|
// 获取可删除的承接对象类型
|
|
|
|
undertakerTypesUncheckedAvailable, err := cooperationContractDao.CheckUndertakerTypesUncheckedAvailable(map[string]interface{}{
|
|
|
|
"cooperationContractNumber": cooperationContract.CooperationContractNumber,
|
|
|
|
"cooperationContractUndertakerTypes": cooperationContract.CooperationContractUndertakerTypes,
|
|
|
|
})
|
|
|
|
if err != nil {
|
|
|
|
return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
|
|
|
|
}
|
|
|
|
cooperationContractDto := &dto.CooperationContractDto{}
|
|
|
|
if err := cooperationContractDto.LoadDto(cooperationContract, undertakerTypesUncheckedAvailable); err != nil {
|
|
|
|
return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
|
|
|
|
}
|
|
|
|
if err := transactionContext.CommitTransaction(); err != nil {
|
|
|
|
return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
|
|
|
|
}
|
|
|
|
return cooperationContract, nil
|
|
|
|
return cooperationContractDto, nil
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
...
|
...
|
@@ -404,6 +428,142 @@ func (cooperationContractService *CooperationContractService) RemoveCooperationC |
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
// BatchRemoveCooperationContract 批量移除共创合约
|
|
|
|
func (cooperationContractService *CooperationContractService) BatchRemoveCooperationContract(batchRemoveCooperationContractCommand *command.BatchRemoveCooperationContractCommand) (interface{}, error) {
|
|
|
|
if err := batchRemoveCooperationContractCommand.ValidateCommand(); err != nil {
|
|
|
|
return nil, application.ThrowError(application.ARG_ERROR, err.Error())
|
|
|
|
}
|
|
|
|
transactionContext, err := factory.CreateTransactionContext(nil)
|
|
|
|
if err != nil {
|
|
|
|
return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
|
|
|
|
}
|
|
|
|
if err := transactionContext.StartTransaction(); err != nil {
|
|
|
|
return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
|
|
|
|
}
|
|
|
|
defer func() {
|
|
|
|
_ = transactionContext.RollbackTransaction()
|
|
|
|
}()
|
|
|
|
var cooperationContractRepository domain.CooperationContractRepository
|
|
|
|
if value, err := factory.CreateCooperationContractRepository(map[string]interface{}{
|
|
|
|
"transactionContext": transactionContext,
|
|
|
|
}); err != nil {
|
|
|
|
return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
|
|
|
|
} else {
|
|
|
|
cooperationContractRepository = value
|
|
|
|
}
|
|
|
|
cooperationContractIds, _ := utils.SliceAtoi(batchRemoveCooperationContractCommand.CooperationContractIds)
|
|
|
|
if count, cooperationContracts, err := cooperationContractRepository.Find(map[string]interface{}{
|
|
|
|
"cooperationContractIds": cooperationContractIds,
|
|
|
|
}); err != nil {
|
|
|
|
return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
|
|
|
|
} else {
|
|
|
|
if count > 0 {
|
|
|
|
cooperationContractsRemoved, err := cooperationContractRepository.BatchRemove(cooperationContracts)
|
|
|
|
if err != nil {
|
|
|
|
return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
|
|
|
|
}
|
|
|
|
if err := transactionContext.CommitTransaction(); err != nil {
|
|
|
|
return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
|
|
|
|
}
|
|
|
|
return cooperationContractsRemoved, nil
|
|
|
|
} else {
|
|
|
|
return map[string]interface{}{}, nil
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
// OperateCooperationContract 暂停或恢复共创合约
|
|
|
|
func (cooperationContractService *CooperationContractService) OperateCooperationContract(operateCooperationContractCommand *command.OperateCooperationContractCommand) (interface{}, error) {
|
|
|
|
if err := operateCooperationContractCommand.ValidateCommand(); err != nil {
|
|
|
|
return nil, application.ThrowError(application.ARG_ERROR, err.Error())
|
|
|
|
}
|
|
|
|
transactionContext, err := factory.CreateTransactionContext(nil)
|
|
|
|
if err != nil {
|
|
|
|
return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
|
|
|
|
}
|
|
|
|
if err := transactionContext.StartTransaction(); err != nil {
|
|
|
|
return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
|
|
|
|
}
|
|
|
|
defer func() {
|
|
|
|
_ = transactionContext.RollbackTransaction()
|
|
|
|
}()
|
|
|
|
var cooperationContractRepository domain.CooperationContractRepository
|
|
|
|
if value, err := factory.CreateCooperationContractRepository(map[string]interface{}{
|
|
|
|
"transactionContext": transactionContext,
|
|
|
|
}); err != nil {
|
|
|
|
return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
|
|
|
|
} else {
|
|
|
|
cooperationContractRepository = value
|
|
|
|
}
|
|
|
|
cooperationContract, err := cooperationContractRepository.FindOne(map[string]interface{}{"cooperationContractId": operateCooperationContractCommand.CooperationContractId})
|
|
|
|
if err != nil {
|
|
|
|
return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
|
|
|
|
}
|
|
|
|
if cooperationContract == nil {
|
|
|
|
return nil, application.ThrowError(application.RES_NO_FIND_ERROR, fmt.Sprintf("%s", string(operateCooperationContractCommand.CooperationContractId)))
|
|
|
|
}
|
|
|
|
if err := cooperationContract.Update(map[string]interface{}{
|
|
|
|
"action": operateCooperationContractCommand.Action,
|
|
|
|
}); err != nil {
|
|
|
|
return nil, application.ThrowError(application.BUSINESS_ERROR, err.Error())
|
|
|
|
}
|
|
|
|
if cooperationContract, err := cooperationContractRepository.Save(cooperationContract); err != nil {
|
|
|
|
return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
|
|
|
|
} else {
|
|
|
|
if err := transactionContext.CommitTransaction(); err != nil {
|
|
|
|
return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
|
|
|
|
}
|
|
|
|
return cooperationContract, nil
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
// BatchOperateCooperationContract 批量暂停或恢复共创合约
|
|
|
|
func (cooperationContractService *CooperationContractService) BatchOperateCooperationContract(batchOperateCooperationContractCommand *command.BatchOperateCooperationContractCommand) (interface{}, error) {
|
|
|
|
if err := batchOperateCooperationContractCommand.ValidateCommand(); err != nil {
|
|
|
|
return nil, application.ThrowError(application.ARG_ERROR, err.Error())
|
|
|
|
}
|
|
|
|
transactionContext, err := factory.CreateTransactionContext(nil)
|
|
|
|
if err != nil {
|
|
|
|
return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
|
|
|
|
}
|
|
|
|
if err := transactionContext.StartTransaction(); err != nil {
|
|
|
|
return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
|
|
|
|
}
|
|
|
|
defer func() {
|
|
|
|
_ = transactionContext.RollbackTransaction()
|
|
|
|
}()
|
|
|
|
var cooperationContractRepository domain.CooperationContractRepository
|
|
|
|
if value, err := factory.CreateCooperationContractRepository(map[string]interface{}{
|
|
|
|
"transactionContext": transactionContext,
|
|
|
|
}); err != nil {
|
|
|
|
return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
|
|
|
|
} else {
|
|
|
|
cooperationContractRepository = value
|
|
|
|
}
|
|
|
|
cooperationContractIds, _ := utils.SliceAtoi(batchOperateCooperationContractCommand.CooperationContractIds)
|
|
|
|
if count, cooperationContracts, err := cooperationContractRepository.Find(map[string]interface{}{
|
|
|
|
"cooperationContractIds": cooperationContractIds,
|
|
|
|
}); err != nil {
|
|
|
|
return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
|
|
|
|
} else {
|
|
|
|
if count > 0 {
|
|
|
|
for i, _ := range cooperationContracts {
|
|
|
|
cooperationContracts[i].Status = batchOperateCooperationContractCommand.Action
|
|
|
|
}
|
|
|
|
cooperationContractsOperated, err := cooperationContractRepository.UpdateMany(cooperationContracts)
|
|
|
|
if err != nil {
|
|
|
|
return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
|
|
|
|
}
|
|
|
|
if err := transactionContext.CommitTransaction(); err != nil {
|
|
|
|
return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error())
|
|
|
|
}
|
|
|
|
return cooperationContractsOperated, nil
|
|
|
|
} else {
|
|
|
|
return map[string]interface{}{}, nil
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
// SearchCooperationContract 查询共创合约
|
|
|
|
func (cooperationContractService *CooperationContractService) SearchCooperationContract(searchCooperationContractQuery *query.SearchCooperationContractQuery) (interface{}, error) {
|
|
|
|
if err := searchCooperationContractQuery.ValidateQuery(); err != nil {
|
|
...
|
...
|
@@ -478,6 +638,39 @@ func (cooperationContractService *CooperationContractService) UpdateCooperationC |
|
|
|
defer func() {
|
|
|
|
_ = transactionContext.RollbackTransaction()
|
|
|
|
}()
|
|
|
|
|
|
|
|
// 公司REST服务初始化
|
|
|
|
var companyService service.CompanyService
|
|
|
|
if value, err := factory.CreateCompanyService(map[string]interface{}{}); err != nil {
|
|
|
|
return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
|
|
|
|
} else {
|
|
|
|
companyService = value
|
|
|
|
}
|
|
|
|
|
|
|
|
// 获取公司信息
|
|
|
|
var company *domain.Company
|
|
|
|
if data, err := companyService.CompanyFrom(updateCooperationContractCommand.CompanyId); err != nil {
|
|
|
|
return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
|
|
|
|
} else {
|
|
|
|
company = data
|
|
|
|
}
|
|
|
|
|
|
|
|
// 组织机构REST服务初始化
|
|
|
|
var organizationService service.OrgService
|
|
|
|
if value, err := factory.CreateOrganizationService(map[string]interface{}{}); err != nil {
|
|
|
|
return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
|
|
|
|
} else {
|
|
|
|
organizationService = value
|
|
|
|
}
|
|
|
|
|
|
|
|
// 获取组织机构信息
|
|
|
|
var organization *domain.Org
|
|
|
|
if data, err := organizationService.OrgFrom(updateCooperationContractCommand.CompanyId, updateCooperationContractCommand.OrgId); err != nil {
|
|
|
|
return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
|
|
|
|
} else {
|
|
|
|
organization = data
|
|
|
|
}
|
|
|
|
|
|
|
|
var cooperationContractRepository domain.CooperationContractRepository
|
|
|
|
if value, err := factory.CreateCooperationContractRepository(map[string]interface{}{
|
|
|
|
"transactionContext": transactionContext,
|
|
...
|
...
|
@@ -493,9 +686,155 @@ func (cooperationContractService *CooperationContractService) UpdateCooperationC |
|
|
|
if cooperationContract == nil {
|
|
|
|
return nil, application.ThrowError(application.RES_NO_FIND_ERROR, fmt.Sprintf("%s", string(updateCooperationContractCommand.CooperationContractId)))
|
|
|
|
}
|
|
|
|
// 更新合约基础信息
|
|
|
|
if err := cooperationContract.Update(tool_funs.SimpleStructToMap(updateCooperationContractCommand)); err != nil {
|
|
|
|
return nil, application.ThrowError(application.BUSINESS_ERROR, err.Error())
|
|
|
|
}
|
|
|
|
// 用户REST服务初始化
|
|
|
|
var userService service.UserService
|
|
|
|
if value, err := factory.CreateUserService(map[string]interface{}{}); err != nil {
|
|
|
|
return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
|
|
|
|
} else {
|
|
|
|
userService = value
|
|
|
|
}
|
|
|
|
|
|
|
|
// 获取发起人
|
|
|
|
var sponsor *domain.User
|
|
|
|
sponsorUid, _ := strconv.ParseInt(updateCooperationContractCommand.SponsorUid, 10, 64)
|
|
|
|
if data, err := userService.OperatorFrom(updateCooperationContractCommand.CompanyId, updateCooperationContractCommand.OrgId, sponsorUid); err != nil {
|
|
|
|
return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
|
|
|
|
} else {
|
|
|
|
sponsor = data
|
|
|
|
}
|
|
|
|
|
|
|
|
// 更新发起人
|
|
|
|
cooperationContract.CooperationContractSponsor = sponsor
|
|
|
|
|
|
|
|
// 获取相关人
|
|
|
|
var relevantPeople []*domain.Relevant
|
|
|
|
for _, relevantPersonUid := range updateCooperationContractCommand.RelevantPeople {
|
|
|
|
var relevantDomain *domain.Relevant
|
|
|
|
relevantUid, _ := strconv.ParseInt(relevantPersonUid, 10, 64)
|
|
|
|
if data, err := userService.RelevantFrom(updateCooperationContractCommand.CompanyId, updateCooperationContractCommand.OrgId, relevantUid); err != nil {
|
|
|
|
return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
|
|
|
|
} else {
|
|
|
|
relevantDomain = data
|
|
|
|
}
|
|
|
|
relevantPeople = append(relevantPeople, &domain.Relevant{
|
|
|
|
RelevantId: relevantDomain.RelevantId,
|
|
|
|
CooperationContractNumber: cooperationContract.CooperationContractNumber,
|
|
|
|
UserId: relevantDomain.UserId,
|
|
|
|
UserBaseId: relevantDomain.UserBaseId,
|
|
|
|
Org: relevantDomain.Org,
|
|
|
|
Orgs: relevantDomain.Orgs,
|
|
|
|
Department: relevantDomain.Department,
|
|
|
|
Roles: relevantDomain.Roles,
|
|
|
|
UserInfo: relevantDomain.UserInfo,
|
|
|
|
UserType: relevantDomain.UserType,
|
|
|
|
Status: relevantDomain.Status,
|
|
|
|
Company: relevantDomain.Company,
|
|
|
|
})
|
|
|
|
}
|
|
|
|
// 更新合约相关人
|
|
|
|
cooperationContract.RelevantPeople = relevantPeople
|
|
|
|
|
|
|
|
// 获取承接人
|
|
|
|
var undertakers []*domain.Undertaker
|
|
|
|
for _, undertaker := range updateCooperationContractCommand.Undertakers {
|
|
|
|
var undertakerDomain *domain.Undertaker
|
|
|
|
undertakerUid, _ := strconv.ParseInt(undertaker.UserId, 10, 64)
|
|
|
|
if data, err := userService.UndertakerFrom(updateCooperationContractCommand.CompanyId, updateCooperationContractCommand.OrgId, undertakerUid); err != nil {
|
|
|
|
return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
|
|
|
|
} else {
|
|
|
|
undertakerDomain = data
|
|
|
|
}
|
|
|
|
|
|
|
|
// 获取推荐人
|
|
|
|
var referrerDomain *domain.Referrer
|
|
|
|
referrerUid, _ := strconv.ParseInt(undertaker.ReferrerId, 10, 64)
|
|
|
|
if data, err := userService.ReferrerFrom(updateCooperationContractCommand.CompanyId, updateCooperationContractCommand.OrgId, referrerUid); err != nil {
|
|
|
|
return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
|
|
|
|
} else {
|
|
|
|
referrerDomain = data
|
|
|
|
}
|
|
|
|
|
|
|
|
// 获取业务员
|
|
|
|
var salesmanDomain *domain.Salesman
|
|
|
|
salesmanUid, _ := strconv.ParseInt(undertaker.SalesmanId, 10, 64)
|
|
|
|
if data, err := userService.SalesmanFrom(updateCooperationContractCommand.CompanyId, updateCooperationContractCommand.OrgId, salesmanUid); err != nil {
|
|
|
|
return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
|
|
|
|
} else {
|
|
|
|
salesmanDomain = data
|
|
|
|
}
|
|
|
|
|
|
|
|
undertakers = append(undertakers, &domain.Undertaker{
|
|
|
|
UndertakerId: undertaker.UndertakerId,
|
|
|
|
UserId: undertakerDomain.UserId,
|
|
|
|
CooperationContractNumber: cooperationContract.CooperationContractNumber,
|
|
|
|
UserBaseId: undertakerDomain.UserBaseId,
|
|
|
|
Org: undertakerDomain.Org,
|
|
|
|
Orgs: undertakerDomain.Orgs,
|
|
|
|
Department: undertakerDomain.Department,
|
|
|
|
Roles: undertakerDomain.Roles,
|
|
|
|
UserInfo: undertakerDomain.UserInfo,
|
|
|
|
UserType: undertakerDomain.UserType,
|
|
|
|
Referrer: referrerDomain,
|
|
|
|
Salesman: salesmanDomain,
|
|
|
|
Status: undertakerDomain.Status,
|
|
|
|
Company: undertakerDomain.Company,
|
|
|
|
ContractAttachment: nil,
|
|
|
|
})
|
|
|
|
}
|
|
|
|
// 更新承接人
|
|
|
|
cooperationContract.Undertakers = undertakers
|
|
|
|
|
|
|
|
// 获取分红规则列表
|
|
|
|
var dividendsIncentivesRules []*domain.DividendsIncentivesRule
|
|
|
|
for _, dividendsIncentivesRule := range updateCooperationContractCommand.DividendsIncentivesRules {
|
|
|
|
dividendsIncentivesRuleId, _ := strconv.ParseInt(dividendsIncentivesRule.DividendsIncentivesRuleId, 10, 64)
|
|
|
|
dividendsIncentivesRules = append(dividendsIncentivesRules, &domain.DividendsIncentivesRule{
|
|
|
|
DividendsIncentivesRuleId: dividendsIncentivesRuleId,
|
|
|
|
CooperationContractNumber: cooperationContract.CooperationContractNumber,
|
|
|
|
ReferrerPercentage: dividendsIncentivesRule.ReferrerPercentage,
|
|
|
|
SalesmanPercentage: dividendsIncentivesRule.SalesmanPercentage,
|
|
|
|
DividendsIncentivesPercentage: dividendsIncentivesRule.DividendsIncentivesPercentage,
|
|
|
|
DividendsIncentivesStage: int64(dividendsIncentivesRule.DividendsIncentivesStage),
|
|
|
|
DividendsIncentivesStageEnd: dividendsIncentivesRule.DividendsIncentivesStageEnd,
|
|
|
|
DividendsIncentivesStageStart: dividendsIncentivesRule.DividendsIncentivesStageStart,
|
|
|
|
Org: organization,
|
|
|
|
Company: company,
|
|
|
|
UpdatedAt: time.Time{},
|
|
|
|
DeletedAt: time.Time{},
|
|
|
|
CreatedAt: time.Now(),
|
|
|
|
})
|
|
|
|
}
|
|
|
|
// 更新分红规则列表
|
|
|
|
cooperationContract.DividendsIncentivesRules = dividendsIncentivesRules
|
|
|
|
|
|
|
|
// 获取金额激励规则列表
|
|
|
|
var moneyIncentivesRules []*domain.MoneyIncentivesRule
|
|
|
|
for _, moneyIncentivesRule := range updateCooperationContractCommand.MoneyIncentivesRules {
|
|
|
|
moneyIncentivesRuleId, _ := strconv.ParseInt(moneyIncentivesRule.MoneyIncentivesRuleId, 10, 64)
|
|
|
|
moneyIncentivesRules = append(moneyIncentivesRules, &domain.MoneyIncentivesRule{
|
|
|
|
MoneyIncentivesRuleId: moneyIncentivesRuleId,
|
|
|
|
CooperationContractNumber: cooperationContract.CooperationContractNumber,
|
|
|
|
MoneyIncentivesAmount: float64(moneyIncentivesRule.MoneyIncentivesAmount),
|
|
|
|
MoneyIncentivesStage: int64(moneyIncentivesRule.MoneyIncentivesStage),
|
|
|
|
MoneyIncentivesStageEnd: moneyIncentivesRule.MoneyIncentivesStageEnd,
|
|
|
|
MoneyIncentivesStageStart: moneyIncentivesRule.MoneyIncentivesStageStart,
|
|
|
|
MoneyIncentivesTime: time.Now(),
|
|
|
|
ReferrerPercentage: moneyIncentivesRule.ReferrerPercentage,
|
|
|
|
SalesmanPercentage: moneyIncentivesRule.SalesmanPercentage,
|
|
|
|
Org: organization,
|
|
|
|
Company: company,
|
|
|
|
UpdatedAt: time.Time{},
|
|
|
|
DeletedAt: time.Time{},
|
|
|
|
CreatedAt: time.Now(),
|
|
|
|
})
|
|
|
|
}
|
|
|
|
// 更新金额激励规则列表
|
|
|
|
cooperationContract.MoneyIncentivesRules = moneyIncentivesRules
|
|
|
|
|
|
|
|
if cooperationContract, err := cooperationContractRepository.Save(cooperationContract); err != nil {
|
|
|
|
return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
|
|
|
|
} else {
|
...
|
...
|
|
