正在显示
14 个修改的文件
包含
33 行增加
和
51 行删除
| @@ -5,8 +5,8 @@ import "gitlab.fjmaimaimai.com/allied-creation/allied-creation-gateway/pkg/domai | @@ -5,8 +5,8 @@ import "gitlab.fjmaimaimai.com/allied-creation/allied-creation-gateway/pkg/domai | ||
| 5 | type ListContractChangeLogQuery struct { | 5 | type ListContractChangeLogQuery struct { |
| 6 | //操作人 | 6 | //操作人 |
| 7 | Operator domain.Operator `json:"-"` | 7 | Operator domain.Operator `json:"-"` |
| 8 | - PageNumber int `json:"pageNumber,omitempty"` // 页码 | ||
| 9 | - PageSize int `json:"pageSize,omitempty"` // 页面大小 | 8 | + PageNumber int `json:"pageNumber"` // 页码 |
| 9 | + PageSize int `json:"pageSize"` // 页面大小 | ||
| 10 | OperationType int `json:"operationType,"` // 合约变更操作类型,1编辑、2暂停、3恢复 | 10 | OperationType int `json:"operationType,"` // 合约变更操作类型,1编辑、2暂停、3恢复 |
| 11 | CooperationContractNumber string `json:"cooperationContractNumber"` // 共创合约编号 | 11 | CooperationContractNumber string `json:"cooperationContractNumber"` // 共创合约编号 |
| 12 | } | 12 | } |
| @@ -213,7 +213,7 @@ func (cooperationContractService *CooperationContractService) SearchCooperationC | @@ -213,7 +213,7 @@ func (cooperationContractService *CooperationContractService) SearchCooperationC | ||
| 213 | CooperationContractName: queryParam.CooperationContractName, | 213 | CooperationContractName: queryParam.CooperationContractName, |
| 214 | SponsorName: queryParam.ContractSponsor, | 214 | SponsorName: queryParam.ContractSponsor, |
| 215 | PageNumber: queryParam.PageNumber, | 215 | PageNumber: queryParam.PageNumber, |
| 216 | - PageIndex: queryParam.PageSize, | 216 | + PageSize: queryParam.PageSize, |
| 217 | CompanyId: queryParam.Operator.CompanyId, | 217 | CompanyId: queryParam.Operator.CompanyId, |
| 218 | OrgIds: queryParam.Operator.OrgIds, | 218 | OrgIds: queryParam.Operator.OrgIds, |
| 219 | }) | 219 | }) |
| 1 | package query | 1 | package query |
| 2 | 2 | ||
| 3 | import ( | 3 | import ( |
| 4 | - "fmt" | ||
| 5 | - | ||
| 6 | - "github.com/beego/beego/v2/core/validation" | ||
| 7 | "gitlab.fjmaimaimai.com/allied-creation/allied-creation-gateway/pkg/domain" | 4 | "gitlab.fjmaimaimai.com/allied-creation/allied-creation-gateway/pkg/domain" |
| 8 | ) | 5 | ) |
| 9 | 6 | ||
| @@ -11,24 +8,7 @@ type GetCooperationProjectQuery struct { | @@ -11,24 +8,7 @@ type GetCooperationProjectQuery struct { | ||
| 11 | //操作人 | 8 | //操作人 |
| 12 | Operator domain.Operator `json:"-"` | 9 | Operator domain.Operator `json:"-"` |
| 13 | // 共创项目ID | 10 | // 共创项目ID |
| 14 | - CooperationProjectId int `json:"cooperationProjectId"` | ||
| 15 | - CooperationProjectNumber string `json:"cooperationProjectNumber"` | ||
| 16 | -} | ||
| 17 | - | ||
| 18 | -func (getCooperationProjectQuery *GetCooperationProjectQuery) Valid(validation *validation.Validation) { | ||
| 19 | - | ||
| 20 | -} | ||
| 21 | - | ||
| 22 | -func (getCooperationProjectQuery *GetCooperationProjectQuery) ValidateQuery() error { | ||
| 23 | - valid := validation.Validation{} | ||
| 24 | - b, err := valid.Valid(getCooperationProjectQuery) | ||
| 25 | - if err != nil { | ||
| 26 | - return err | ||
| 27 | - } | ||
| 28 | - if !b { | ||
| 29 | - for _, validErr := range valid.Errors { | ||
| 30 | - return fmt.Errorf("%s %s", validErr.Key, validErr.Message) | ||
| 31 | - } | ||
| 32 | - } | ||
| 33 | - return nil | 11 | + CooperationProjectId int `json:"-"` |
| 12 | + CooperationProjectNumber string `json:"-"` | ||
| 13 | + OrgId int `json:"-"` | ||
| 34 | } | 14 | } |
| @@ -63,6 +63,8 @@ func (cooperationProjectService *CooperationProjectService) GetCooperationProjec | @@ -63,6 +63,8 @@ func (cooperationProjectService *CooperationProjectService) GetCooperationProjec | ||
| 63 | resultProject, err := creationCooperationGateway.CooperationProjectGet(allied_creation_cooperation.ReqCooperationProjectGet{ | 63 | resultProject, err := creationCooperationGateway.CooperationProjectGet(allied_creation_cooperation.ReqCooperationProjectGet{ |
| 64 | CooperationProjectId: getCooperationProjectQuery.CooperationProjectId, | 64 | CooperationProjectId: getCooperationProjectQuery.CooperationProjectId, |
| 65 | CooperationProjectNumber: getCooperationProjectQuery.CooperationProjectNumber, | 65 | CooperationProjectNumber: getCooperationProjectQuery.CooperationProjectNumber, |
| 66 | + OrgId: getCooperationProjectQuery.OrgId, | ||
| 67 | + CompanyId: int(getCooperationProjectQuery.Operator.CompanyId), | ||
| 66 | }) | 68 | }) |
| 67 | if err != nil { | 69 | if err != nil { |
| 68 | return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error()) | 70 | return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error()) |
| @@ -72,6 +74,7 @@ func (cooperationProjectService *CooperationProjectService) GetCooperationProjec | @@ -72,6 +74,7 @@ func (cooperationProjectService *CooperationProjectService) GetCooperationProjec | ||
| 72 | PageNumber: 0, | 74 | PageNumber: 0, |
| 73 | PageSize: 0, | 75 | PageSize: 0, |
| 74 | CompanyId: resultProject.Company.CompanyId, | 76 | CompanyId: resultProject.Company.CompanyId, |
| 77 | + OrgId: int64(resultProject.Org.OrgId), | ||
| 75 | }) | 78 | }) |
| 76 | if err != nil { | 79 | if err != nil { |
| 77 | return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error()) | 80 | return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error()) |
| @@ -8,24 +8,7 @@ type GetDividendsOrderQuery struct { | @@ -8,24 +8,7 @@ type GetDividendsOrderQuery struct { | ||
| 8 | //操作人 | 8 | //操作人 |
| 9 | Operator domain.Operator `json:"-"` | 9 | Operator domain.Operator `json:"-"` |
| 10 | // 分红订单ID | 10 | // 分红订单ID |
| 11 | - DividendsOrderId int `json:"dividendsOrderId,string" valid:"Required"` | ||
| 12 | - DividendsOrderNumber string `json:"dividendsOrderNumber"` | 11 | + DividendsOrderId int `json:"-" ` |
| 12 | + DividendsOrderNumber string `json:"-"` | ||
| 13 | + OrgId int `json:"-"` | ||
| 13 | } | 14 | } |
| 14 | - | ||
| 15 | -// func (getDividendsOrderQuery *GetDividendsOrderQuery) Valid(validation *validation.Validation) { | ||
| 16 | - | ||
| 17 | -// } | ||
| 18 | - | ||
| 19 | -// func (getDividendsOrderQuery *GetDividendsOrderQuery) ValidateQuery() error { | ||
| 20 | -// valid := validation.Validation{} | ||
| 21 | -// b, err := valid.Valid(getDividendsOrderQuery) | ||
| 22 | -// if err != nil { | ||
| 23 | -// return err | ||
| 24 | -// } | ||
| 25 | -// if !b { | ||
| 26 | -// for _, validErr := range valid.Errors { | ||
| 27 | -// return fmt.Errorf("%s %s", validErr.Key, validErr.Message) | ||
| 28 | -// } | ||
| 29 | -// } | ||
| 30 | -// return nil | ||
| 31 | -// } |
| @@ -57,6 +57,8 @@ func (dividendsOrderService *DividendsOrderService) GetDividendsOrder(getDividen | @@ -57,6 +57,8 @@ func (dividendsOrderService *DividendsOrderService) GetDividendsOrder(getDividen | ||
| 57 | result, err := creationCooperationGateway.DividendsOrderGet(allied_creation_cooperation.ReqDividendsOrderGet{ | 57 | result, err := creationCooperationGateway.DividendsOrderGet(allied_creation_cooperation.ReqDividendsOrderGet{ |
| 58 | DividendsOrderId: getDividendsOrderQuery.DividendsOrderId, | 58 | DividendsOrderId: getDividendsOrderQuery.DividendsOrderId, |
| 59 | DividendsOrderNumber: getDividendsOrderQuery.DividendsOrderNumber, | 59 | DividendsOrderNumber: getDividendsOrderQuery.DividendsOrderNumber, |
| 60 | + OrgId: getDividendsOrderQuery.OrgId, | ||
| 61 | + CompanyId: int(getDividendsOrderQuery.Operator.CompanyId), | ||
| 60 | }) | 62 | }) |
| 61 | if err != nil { | 63 | if err != nil { |
| 62 | return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error()) | 64 | return nil, application.ThrowError(application.TRANSACTION_ERROR, err.Error()) |
| 1 | package service | 1 | package service |
| 2 | 2 | ||
| 3 | import ( | 3 | import ( |
| 4 | - "gitlab.fjmaimaimai.com/allied-creation/allied-creation-gateway/pkg/domain" | ||
| 5 | "strconv" | 4 | "strconv" |
| 6 | 5 | ||
| 6 | + "gitlab.fjmaimaimai.com/allied-creation/allied-creation-gateway/pkg/domain" | ||
| 7 | + | ||
| 7 | "github.com/linmadan/egglib-go/core/application" | 8 | "github.com/linmadan/egglib-go/core/application" |
| 8 | "gitlab.fjmaimaimai.com/allied-creation/allied-creation-gateway/pkg/application/web/orgs/command" | 9 | "gitlab.fjmaimaimai.com/allied-creation/allied-creation-gateway/pkg/application/web/orgs/command" |
| 9 | "gitlab.fjmaimaimai.com/allied-creation/allied-creation-gateway/pkg/application/web/orgs/dto" | 10 | "gitlab.fjmaimaimai.com/allied-creation/allied-creation-gateway/pkg/application/web/orgs/dto" |
| @@ -164,7 +165,7 @@ func (orgsService OrgsService) DepartmentsUsers(departmentsUsersQuery *query.Dep | @@ -164,7 +165,7 @@ func (orgsService OrgsService) DepartmentsUsers(departmentsUsersQuery *query.Dep | ||
| 164 | CompanyId: departmentsUsersQuery.Operator.CompanyId, | 165 | CompanyId: departmentsUsersQuery.Operator.CompanyId, |
| 165 | OrganizationId: departmentsUsersQuery.Operator.OrgId, | 166 | OrganizationId: departmentsUsersQuery.Operator.OrgId, |
| 166 | Limit: 1000, | 167 | Limit: 1000, |
| 167 | - InEnableStatus: []int{domain.UserStatusEnable, domain.UserStatusDisable}, | 168 | + InEnableStatus: []int{domain.UserStatusEnable}, |
| 168 | }) | 169 | }) |
| 169 | if err != nil { | 170 | if err != nil { |
| 170 | return nil, application.ThrowError(application.BUSINESS_ERROR, err.Error()) | 171 | return nil, application.ThrowError(application.BUSINESS_ERROR, err.Error()) |
| @@ -78,7 +78,10 @@ func (gateway HttplibAlliedCreationCooperation) CooperationProjectGet(param ReqC | @@ -78,7 +78,10 @@ func (gateway HttplibAlliedCreationCooperation) CooperationProjectGet(param ReqC | ||
| 78 | req := gateway.CreateRequest(url, method) | 78 | req := gateway.CreateRequest(url, method) |
| 79 | if len(param.CooperationProjectNumber) > 0 { | 79 | if len(param.CooperationProjectNumber) > 0 { |
| 80 | req.Param("cooperationProjectNumber", param.CooperationProjectNumber) | 80 | req.Param("cooperationProjectNumber", param.CooperationProjectNumber) |
| 81 | + req.Param("orgId", strconv.Itoa(param.OrgId)) | ||
| 82 | + req.Param("companyId", strconv.Itoa(param.CompanyId)) | ||
| 81 | } | 83 | } |
| 84 | + | ||
| 82 | log.Logger.Debug("向业务模块请求数据:返回共创项目详情。", map[string]interface{}{ | 85 | log.Logger.Debug("向业务模块请求数据:返回共创项目详情。", map[string]interface{}{ |
| 83 | "api": method + ":" + url, | 86 | "api": method + ":" + url, |
| 84 | "param": param, | 87 | "param": param, |
| @@ -205,6 +205,8 @@ func (gateway HttplibAlliedCreationCooperation) DividendsOrderGet(param ReqDivid | @@ -205,6 +205,8 @@ func (gateway HttplibAlliedCreationCooperation) DividendsOrderGet(param ReqDivid | ||
| 205 | req := gateway.CreateRequest(url, method) | 205 | req := gateway.CreateRequest(url, method) |
| 206 | if len(param.DividendsOrderNumber) > 0 { | 206 | if len(param.DividendsOrderNumber) > 0 { |
| 207 | req.Param("dividendsOrderNumber", param.DividendsOrderNumber) | 207 | req.Param("dividendsOrderNumber", param.DividendsOrderNumber) |
| 208 | + req.Param("orgId", strconv.Itoa(param.OrgId)) | ||
| 209 | + req.Param("companyId", strconv.Itoa(param.CompanyId)) | ||
| 208 | } | 210 | } |
| 209 | fmt.Printf("=========>param %+v", param) | 211 | fmt.Printf("=========>param %+v", param) |
| 210 | log.Logger.Debug("向业务模块请求数据:返回分红订单详情。", map[string]interface{}{ | 212 | log.Logger.Debug("向业务模块请求数据:返回分红订单详情。", map[string]interface{}{ |
| @@ -254,7 +254,7 @@ type ( | @@ -254,7 +254,7 @@ type ( | ||
| 254 | CooperationContractName string `json:"cooperationContractName"` //合约名称 | 254 | CooperationContractName string `json:"cooperationContractName"` //合约名称 |
| 255 | SponsorName string `json:"sponsorName"` //项目发起人姓名 | 255 | SponsorName string `json:"sponsorName"` //项目发起人姓名 |
| 256 | PageNumber int `json:"pageNumber"` | 256 | PageNumber int `json:"pageNumber"` |
| 257 | - PageIndex int `json:"pageIndex"` | 257 | + PageSize int `json:"pageSize"` |
| 258 | CompanyId int64 ` json:"companyId"` | 258 | CompanyId int64 ` json:"companyId"` |
| 259 | OrgId int64 ` json:"orgId"` | 259 | OrgId int64 ` json:"orgId"` |
| 260 | UserBaseId int64 `json:"userBaseId"` | 260 | UserBaseId int64 `json:"userBaseId"` |
| @@ -118,6 +118,8 @@ type ( | @@ -118,6 +118,8 @@ type ( | ||
| 118 | ReqCooperationProjectGet struct { | 118 | ReqCooperationProjectGet struct { |
| 119 | CooperationProjectId int | 119 | CooperationProjectId int |
| 120 | CooperationProjectNumber string | 120 | CooperationProjectNumber string |
| 121 | + OrgId int | ||
| 122 | + CompanyId int | ||
| 121 | } | 123 | } |
| 122 | 124 | ||
| 123 | DataCooperationProjectGet struct { | 125 | DataCooperationProjectGet struct { |
| @@ -173,8 +173,10 @@ type ( | @@ -173,8 +173,10 @@ type ( | ||
| 173 | //返回分红订单详情 | 173 | //返回分红订单详情 |
| 174 | type ( | 174 | type ( |
| 175 | ReqDividendsOrderGet struct { | 175 | ReqDividendsOrderGet struct { |
| 176 | - DividendsOrderId int `json:"dividendsOrderId"` | ||
| 177 | - DividendsOrderNumber string `json:"dividendsOrderNumber"` | 176 | + DividendsOrderId int |
| 177 | + DividendsOrderNumber string | ||
| 178 | + OrgId int | ||
| 179 | + CompanyId int | ||
| 178 | } | 180 | } |
| 179 | 181 | ||
| 180 | DataDividendsOrderGet struct { | 182 | DataDividendsOrderGet struct { |
| @@ -46,8 +46,10 @@ func (controller *CooperationProjectController) GetCooperationProject() { | @@ -46,8 +46,10 @@ func (controller *CooperationProjectController) GetCooperationProject() { | ||
| 46 | getCooperationProjectQuery := &query.GetCooperationProjectQuery{} | 46 | getCooperationProjectQuery := &query.GetCooperationProjectQuery{} |
| 47 | projectId, _ := controller.GetInt(":projectId") | 47 | projectId, _ := controller.GetInt(":projectId") |
| 48 | projectNumber := controller.GetString("cooperationProjectNumber") | 48 | projectNumber := controller.GetString("cooperationProjectNumber") |
| 49 | + orgId, _ := controller.GetInt("orgId") | ||
| 49 | getCooperationProjectQuery.CooperationProjectId = projectId | 50 | getCooperationProjectQuery.CooperationProjectId = projectId |
| 50 | getCooperationProjectQuery.CooperationProjectNumber = projectNumber | 51 | getCooperationProjectQuery.CooperationProjectNumber = projectNumber |
| 52 | + getCooperationProjectQuery.OrgId = orgId | ||
| 51 | getCooperationProjectQuery.Operator = controller.GetOperator() | 53 | getCooperationProjectQuery.Operator = controller.GetOperator() |
| 52 | data, err := cooperationProjectService.GetCooperationProject(getCooperationProjectQuery) | 54 | data, err := cooperationProjectService.GetCooperationProject(getCooperationProjectQuery) |
| 53 | controller.Response(data, err) | 55 | controller.Response(data, err) |
| @@ -61,7 +61,9 @@ func (controller *DividendsOrderController) GetDividendsOrder() { | @@ -61,7 +61,9 @@ func (controller *DividendsOrderController) GetDividendsOrder() { | ||
| 61 | getDividendsOrderQuery := &query.GetDividendsOrderQuery{} | 61 | getDividendsOrderQuery := &query.GetDividendsOrderQuery{} |
| 62 | orderId, _ := controller.GetInt(":orderId") | 62 | orderId, _ := controller.GetInt(":orderId") |
| 63 | dividendsOrderNumber := controller.GetString("dividendsOrderNumber") | 63 | dividendsOrderNumber := controller.GetString("dividendsOrderNumber") |
| 64 | + orgId, _ := controller.GetInt("orgId") | ||
| 64 | getDividendsOrderQuery.DividendsOrderId = orderId | 65 | getDividendsOrderQuery.DividendsOrderId = orderId |
| 66 | + getDividendsOrderQuery.OrgId = orgId | ||
| 65 | getDividendsOrderQuery.DividendsOrderNumber = dividendsOrderNumber | 67 | getDividendsOrderQuery.DividendsOrderNumber = dividendsOrderNumber |
| 66 | getDividendsOrderQuery.Operator = controller.GetOperator() | 68 | getDividendsOrderQuery.Operator = controller.GetOperator() |
| 67 | data, err := dividendsOrderService.GetDividendsOrder(getDividendsOrderQuery) | 69 | data, err := dividendsOrderService.GetDividendsOrder(getDividendsOrderQuery) |
-
请 注册 或 登录 后发表评论