|
...
|
...
|
@@ -8,7 +8,9 @@ import ( |
|
|
|
"gitlab.fjmaimaimai.com/allied-creation/allied-creation-cooperation/pkg/application/cooperationApplication/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"
|
|
|
|
"strconv"
|
|
|
|
"time"
|
|
|
|
)
|
|
|
|
|
|
|
|
// CooperationApplicationService 共创申请服务
|
|
...
|
...
|
@@ -93,15 +95,92 @@ func (cooperationApplicationService *CooperationApplicationService) CreateCooper |
|
|
|
defer func() {
|
|
|
|
_ = transactionContext.RollbackTransaction()
|
|
|
|
}()
|
|
|
|
|
|
|
|
var cooperationProjectRepository domain.CooperationProjectRepository
|
|
|
|
if value, err := factory.CreateCooperationProjectRepository(map[string]interface{}{
|
|
|
|
"transactionContext": transactionContext,
|
|
|
|
}); err != nil {
|
|
|
|
return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
|
|
|
|
} else {
|
|
|
|
cooperationProjectRepository = value
|
|
|
|
}
|
|
|
|
cooperationProject, err := cooperationProjectRepository.FindOne(map[string]interface{}{"cooperationProjectNumber": createCooperationApplicationCommand.CooperationProjectNumber})
|
|
|
|
if err != nil {
|
|
|
|
return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
|
|
|
|
}
|
|
|
|
if cooperationProject == nil {
|
|
|
|
return nil, application.ThrowError(application.RES_NO_FIND_ERROR, fmt.Sprintf("%s", createCooperationApplicationCommand.CooperationProjectNumber))
|
|
|
|
} else {
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
//TODO 获取申请人
|
|
|
|
// 用户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 applicant *domain.User
|
|
|
|
if data, err := userService.UserFrom(createCooperationApplicationCommand.CompanyId, createCooperationApplicationCommand.OrgId, createCooperationApplicationCommand.UserId); err != nil {
|
|
|
|
return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
|
|
|
|
} else {
|
|
|
|
applicant = data
|
|
|
|
}
|
|
|
|
|
|
|
|
// 公司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(createCooperationApplicationCommand.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(createCooperationApplicationCommand.CompanyId, createCooperationApplicationCommand.OrgId); err != nil {
|
|
|
|
return nil, application.ThrowError(application.INTERNAL_SERVER_ERROR, err.Error())
|
|
|
|
} else {
|
|
|
|
organization = data
|
|
|
|
}
|
|
|
|
|
|
|
|
newCooperationApplication := &domain.CooperationApplication{
|
|
|
|
//ApplicantUid: createCooperationApplicationCommand.ApplicantUid,
|
|
|
|
CooperationApplicationDescription: createCooperationApplicationCommand.CooperationApplicationDescription,
|
|
|
|
CooperationApplicationAttachment: createCooperationApplicationCommand.CooperationApplicationAttachment,
|
|
|
|
//CooperationProjectNumber: createCooperationApplicationCommand.CooperationProjectNumber,
|
|
|
|
//CompanyId: createCooperationApplicationCommand.CompanyId,
|
|
|
|
//OrgId: createCooperationApplicationCommand.OrgId,
|
|
|
|
//UserId: createCooperationApplicationCommand.UserId,
|
|
|
|
CooperationApplicationApplicant: applicant,
|
|
|
|
CooperationApplicationAttachment: createCooperationApplicationCommand.CooperationApplicationAttachment,
|
|
|
|
CooperationApplicationDescription: createCooperationApplicationCommand.CooperationApplicationDescription,
|
|
|
|
CooperationApplicationStatus: 1,
|
|
|
|
CooperationApplicationVerifier: nil,
|
|
|
|
CooperationApplicationVerifyDescription: "",
|
|
|
|
CooperationApplicationVerifyTime: time.Time{},
|
|
|
|
CooperationApplyTime: time.Now(),
|
|
|
|
CooperationProject: cooperationProject,
|
|
|
|
Org: organization,
|
|
|
|
IsCanceled: false,
|
|
|
|
Company: company,
|
|
|
|
CreatedAt: time.Now(),
|
|
|
|
DeletedAt: time.Time{},
|
|
|
|
UpdatedAt: time.Time{},
|
|
|
|
}
|
|
|
|
|
|
|
|
var cooperationApplicationRepository domain.CooperationApplicationRepository
|
|
|
|
if value, err := factory.CreateCooperationApplicationRepository(map[string]interface{}{
|
|
|
|
"transactionContext": transactionContext,
|
...
|
...
|
|
