作者 陈志颖

feat:调整分红预算相关业务

正在显示 23 个修改的文件 包含 77 行增加50 行删除
@@ -8,6 +8,7 @@ import ( @@ -8,6 +8,7 @@ import (
8 "github.com/beego/beego/v2/core/validation" 8 "github.com/beego/beego/v2/core/validation"
9 ) 9 )
10 10
  11 +// CancelDividendsEstimateCommand 取消分红预算
11 type CancelDividendsEstimateCommand struct { 12 type CancelDividendsEstimateCommand struct {
12 // 承接人分红预算记录ID 13 // 承接人分红预算记录ID
13 DividendsEstimateId string `cname:"承接人分红预算记录ID" json:"dividendsEstimateId" valid:"Required"` 14 DividendsEstimateId string `cname:"承接人分红预算记录ID" json:"dividendsEstimateId" valid:"Required"`
@@ -8,7 +8,8 @@ import ( @@ -8,7 +8,8 @@ import (
8 "github.com/beego/beego/v2/core/validation" 8 "github.com/beego/beego/v2/core/validation"
9 ) 9 )
10 10
11 -type EstimateDividendsIncentivesCommand struct { 11 +// ConfirmDividendsIncentivesEstimateCommand 确定业绩分红预算
  12 +type ConfirmDividendsIncentivesEstimateCommand struct {
12 // 分红订单号/退货单号 13 // 分红订单号/退货单号
13 OrderOrReturnedOrderNum string `cname:"分红订单号/退货单号" json:"orderOrReturnedOrderNum" valid:"Required"` 14 OrderOrReturnedOrderNum string `cname:"分红订单号/退货单号" json:"orderOrReturnedOrderNum" valid:"Required"`
14 // 合约编号 15 // 合约编号
@@ -23,11 +24,11 @@ type EstimateDividendsIncentivesCommand struct { @@ -23,11 +24,11 @@ type EstimateDividendsIncentivesCommand struct {
23 UserBaseId int64 `cname:"用户基础数据ID" json:"userBaseId,string" valid:"Required"` 24 UserBaseId int64 `cname:"用户基础数据ID" json:"userBaseId,string" valid:"Required"`
24 } 25 }
25 26
26 -func (estimateDividendsIncentivesCommand *EstimateDividendsIncentivesCommand) Valid(validation *validation.Validation) { 27 +func (estimateDividendsIncentivesCommand *ConfirmDividendsIncentivesEstimateCommand) Valid(validation *validation.Validation) {
27 //validation.SetError("CustomValid", "未实现的自定义认证") 28 //validation.SetError("CustomValid", "未实现的自定义认证")
28 } 29 }
29 30
30 -func (estimateDividendsIncentivesCommand *EstimateDividendsIncentivesCommand) ValidateCommand() error { 31 +func (estimateDividendsIncentivesCommand *ConfirmDividendsIncentivesEstimateCommand) ValidateCommand() error {
31 valid := validation.Validation{} 32 valid := validation.Validation{}
32 b, err := valid.Valid(estimateDividendsIncentivesCommand) 33 b, err := valid.Valid(estimateDividendsIncentivesCommand)
33 if err != nil { 34 if err != nil {
@@ -8,7 +8,8 @@ import ( @@ -8,7 +8,8 @@ import (
8 "github.com/beego/beego/v2/core/validation" 8 "github.com/beego/beego/v2/core/validation"
9 ) 9 )
10 10
11 -type EstimateMoneyIncentivesCommand struct { 11 +// ConfirmMoneyIncentivesEstimateCommand 确定金额激励分红预算
  12 +type ConfirmMoneyIncentivesEstimateCommand struct {
12 // 共创项目合约编号 13 // 共创项目合约编号
13 CooperationContractNumber string `cname:"共创项目合约编号" json:"cooperationContractNumber" valid:"Required"` 14 CooperationContractNumber string `cname:"共创项目合约编号" json:"cooperationContractNumber" valid:"Required"`
14 // 分红阶段 15 // 分红阶段
@@ -25,11 +26,11 @@ type EstimateMoneyIncentivesCommand struct { @@ -25,11 +26,11 @@ type EstimateMoneyIncentivesCommand struct {
25 UserBaseId int64 `cname:"用户基础数据ID" json:"userBaseId,string" valid:"Required"` 26 UserBaseId int64 `cname:"用户基础数据ID" json:"userBaseId,string" valid:"Required"`
26 } 27 }
27 28
28 -func (estimateMoneyIncentivesCommand *EstimateMoneyIncentivesCommand) Valid(validation *validation.Validation) { 29 +func (estimateMoneyIncentivesCommand *ConfirmMoneyIncentivesEstimateCommand) Valid(validation *validation.Validation) {
29 //validation.SetError("CustomValid", "未实现的自定义认证") 30 //validation.SetError("CustomValid", "未实现的自定义认证")
30 } 31 }
31 32
32 -func (estimateMoneyIncentivesCommand *EstimateMoneyIncentivesCommand) ValidateCommand() error { 33 +func (estimateMoneyIncentivesCommand *ConfirmMoneyIncentivesEstimateCommand) ValidateCommand() error {
33 valid := validation.Validation{} 34 valid := validation.Validation{}
34 b, err := valid.Valid(estimateMoneyIncentivesCommand) 35 b, err := valid.Valid(estimateMoneyIncentivesCommand)
35 if err != nil { 36 if err != nil {
@@ -8,6 +8,7 @@ import ( @@ -8,6 +8,7 @@ import (
8 "github.com/beego/beego/v2/core/validation" 8 "github.com/beego/beego/v2/core/validation"
9 ) 9 )
10 10
  11 +// CreateDividendsEstimateCommand 创建分红预算(预留)
11 type CreateDividendsEstimateCommand struct { 12 type CreateDividendsEstimateCommand struct {
12 // 公司ID,通过集成REST上下文获取 13 // 公司ID,通过集成REST上下文获取
13 CompanyId int64 `cname:"公司ID" json:"companyId,string" valid:"Required"` 14 CompanyId int64 `cname:"公司ID" json:"companyId,string" valid:"Required"`
@@ -8,6 +8,7 @@ import ( @@ -8,6 +8,7 @@ import (
8 "github.com/beego/beego/v2/core/validation" 8 "github.com/beego/beego/v2/core/validation"
9 ) 9 )
10 10
  11 +// RemoveDividendsEstimateCommand 移除分红预算单 (预留)
11 type RemoveDividendsEstimateCommand struct { 12 type RemoveDividendsEstimateCommand struct {
12 // 承接人分红预算记录ID 13 // 承接人分红预算记录ID
13 DividendsEstimateId int64 `cname:"承接人分红预算记录ID" json:"dividendsEstimateId,string" valid:"Required"` 14 DividendsEstimateId int64 `cname:"承接人分红预算记录ID" json:"dividendsEstimateId,string" valid:"Required"`
@@ -8,6 +8,7 @@ import ( @@ -8,6 +8,7 @@ import (
8 "github.com/beego/beego/v2/core/validation" 8 "github.com/beego/beego/v2/core/validation"
9 ) 9 )
10 10
  11 +// UpdateDividendsEstimateCommand 编辑分红预算单(预留)
11 type UpdateDividendsEstimateCommand struct { 12 type UpdateDividendsEstimateCommand struct {
12 // 承接人分红预算记录ID 13 // 承接人分红预算记录ID
13 DividendsEstimateId int64 `cname:"承接人分红预算记录ID" json:"dividendsEstimateId,string" valid:"Required"` 14 DividendsEstimateId int64 `cname:"承接人分红预算记录ID" json:"dividendsEstimateId,string" valid:"Required"`
  1 +package dto
  2 +
  3 +type DividendsIncentivesEstimateDto struct {
  4 +}
  1 +package dto
  2 +
  3 +type MoneyIncentivesEstimateDto struct {
  4 +}
@@ -8,6 +8,7 @@ import ( @@ -8,6 +8,7 @@ import (
8 "github.com/beego/beego/v2/core/validation" 8 "github.com/beego/beego/v2/core/validation"
9 ) 9 )
10 10
  11 +// GetDividendsEstimateQuery 获取分红预算单详情
11 type GetDividendsEstimateQuery struct { 12 type GetDividendsEstimateQuery struct {
12 // 承接人分红预算记录ID 13 // 承接人分红预算记录ID
13 DividendsEstimateId string `cname:"承接人分红预算记录ID" json:"dividendsEstimateId" valid:"Required"` 14 DividendsEstimateId string `cname:"承接人分红预算记录ID" json:"dividendsEstimateId" valid:"Required"`
@@ -8,6 +8,7 @@ import ( @@ -8,6 +8,7 @@ import (
8 "github.com/beego/beego/v2/core/validation" 8 "github.com/beego/beego/v2/core/validation"
9 ) 9 )
10 10
  11 +// ListDividendsEstimateQuery 返回分红预算列表
11 type ListDividendsEstimateQuery struct { 12 type ListDividendsEstimateQuery struct {
12 // 页面大小 13 // 页面大小
13 PageNumber int64 `cname:"页码" json:"pageNumber,omitempty"` 14 PageNumber int64 `cname:"页码" json:"pageNumber,omitempty"`
@@ -8,7 +8,8 @@ import ( @@ -8,7 +8,8 @@ import (
8 "github.com/beego/beego/v2/core/validation" 8 "github.com/beego/beego/v2/core/validation"
9 ) 9 )
10 10
11 -type ListDividendsIncentivesQuery struct { 11 +// ListDividendsIncentivesEstimateQuery 返回业绩分红预算列表
  12 +type ListDividendsIncentivesEstimateQuery struct {
12 // 页面大小 13 // 页面大小
13 PageNumber int64 `cname:"页码" json:"pageNumber,omitempty"` 14 PageNumber int64 `cname:"页码" json:"pageNumber,omitempty"`
14 // 页面大小 15 // 页面大小
@@ -23,18 +24,18 @@ type ListDividendsIncentivesQuery struct { @@ -23,18 +24,18 @@ type ListDividendsIncentivesQuery struct {
23 UserBaseId int64 `cname:"用户基础数据ID" json:"userBaseId,string" valid:"Required"` 24 UserBaseId int64 `cname:"用户基础数据ID" json:"userBaseId,string" valid:"Required"`
24 } 25 }
25 26
26 -func (listDividendsIncentivesQuery *ListDividendsIncentivesQuery) Valid(validation *validation.Validation) { 27 +func (listDividendsIncentivesEstimateQuery *ListDividendsIncentivesEstimateQuery) Valid(validation *validation.Validation) {
27 //validation.SetError("CustomValid", "未实现的自定义认证") 28 //validation.SetError("CustomValid", "未实现的自定义认证")
28 } 29 }
29 30
30 -func (listDividendsIncentivesQuery *ListDividendsIncentivesQuery) ValidateQuery() error { 31 +func (listDividendsIncentivesEstimateQuery *ListDividendsIncentivesEstimateQuery) ValidateQuery() error {
31 valid := validation.Validation{} 32 valid := validation.Validation{}
32 - b, err := valid.Valid(listDividendsIncentivesQuery) 33 + b, err := valid.Valid(listDividendsIncentivesEstimateQuery)
33 if err != nil { 34 if err != nil {
34 return err 35 return err
35 } 36 }
36 if !b { 37 if !b {
37 - elem := reflect.TypeOf(listDividendsIncentivesQuery).Elem() 38 + elem := reflect.TypeOf(listDividendsIncentivesEstimateQuery).Elem()
38 for _, validErr := range valid.Errors { 39 for _, validErr := range valid.Errors {
39 field, isExist := elem.FieldByName(validErr.Field) 40 field, isExist := elem.FieldByName(validErr.Field)
40 if isExist { 41 if isExist {
@@ -8,7 +8,8 @@ import ( @@ -8,7 +8,8 @@ import (
8 "github.com/beego/beego/v2/core/validation" 8 "github.com/beego/beego/v2/core/validation"
9 ) 9 )
10 10
11 -type ListMoneyIncentivesQuery struct { 11 +// ListMoneyIncentivesEstimateQuery 返回金额分红预算列表
  12 +type ListMoneyIncentivesEstimateQuery struct {
12 // 页面大小 13 // 页面大小
13 PageNumber int64 `cname:"页码" json:"pageNumber,omitempty"` 14 PageNumber int64 `cname:"页码" json:"pageNumber,omitempty"`
14 // 页面大小 15 // 页面大小
@@ -23,18 +24,18 @@ type ListMoneyIncentivesQuery struct { @@ -23,18 +24,18 @@ type ListMoneyIncentivesQuery struct {
23 UserBaseId int64 `cname:"用户基础数据ID" json:"userBaseId,string" valid:"Required"` 24 UserBaseId int64 `cname:"用户基础数据ID" json:"userBaseId,string" valid:"Required"`
24 } 25 }
25 26
26 -func (listMoneyIncentivesQuery *ListMoneyIncentivesQuery) Valid(validation *validation.Validation) { 27 +func (listMoneyIncentivesEstimateQuery *ListMoneyIncentivesEstimateQuery) Valid(validation *validation.Validation) {
27 //validation.SetError("CustomValid", "未实现的自定义认证") 28 //validation.SetError("CustomValid", "未实现的自定义认证")
28 } 29 }
29 30
30 -func (listMoneyIncentivesQuery *ListMoneyIncentivesQuery) ValidateQuery() error { 31 +func (listMoneyIncentivesEstimateQuery *ListMoneyIncentivesEstimateQuery) ValidateQuery() error {
31 valid := validation.Validation{} 32 valid := validation.Validation{}
32 - b, err := valid.Valid(listMoneyIncentivesQuery) 33 + b, err := valid.Valid(listMoneyIncentivesEstimateQuery)
33 if err != nil { 34 if err != nil {
34 return err 35 return err
35 } 36 }
36 if !b { 37 if !b {
37 - elem := reflect.TypeOf(listMoneyIncentivesQuery).Elem() 38 + elem := reflect.TypeOf(listMoneyIncentivesEstimateQuery).Elem()
38 for _, validErr := range valid.Errors { 39 for _, validErr := range valid.Errors {
39 field, isExist := elem.FieldByName(validErr.Field) 40 field, isExist := elem.FieldByName(validErr.Field)
40 if isExist { 41 if isExist {
@@ -8,6 +8,7 @@ import ( @@ -8,6 +8,7 @@ import (
8 "github.com/beego/beego/v2/core/validation" 8 "github.com/beego/beego/v2/core/validation"
9 ) 9 )
10 10
  11 +// SearchDividendsEstimateQuery 查询分红预算单
11 type SearchDividendsEstimateQuery struct { 12 type SearchDividendsEstimateQuery struct {
12 // 承接人分红预算单号 13 // 承接人分红预算单号
13 DividendsEstimateOrderNumber string `cname:"承接人分红预算单号" json:"dividendsEstimateOrderNumber" valid:"Required"` 14 DividendsEstimateOrderNumber string `cname:"承接人分红预算单号" json:"dividendsEstimateOrderNumber" valid:"Required"`
@@ -8,7 +8,8 @@ import ( @@ -8,7 +8,8 @@ import (
8 "github.com/beego/beego/v2/core/validation" 8 "github.com/beego/beego/v2/core/validation"
9 ) 9 )
10 10
11 -type SearchDividendsIncentivesQuery struct { 11 +// SearchDividendsIncentivesEstimateQuery 查找业绩分红预算
  12 +type SearchDividendsIncentivesEstimateQuery struct {
12 // 合约编号 13 // 合约编号
13 CooperationContractNumber string `cname:"合约编号" json:"cooperationContractNumber,omitempty"` 14 CooperationContractNumber string `cname:"合约编号" json:"cooperationContractNumber,omitempty"`
14 // 分红订单号/退货单号 15 // 分红订单号/退货单号
@@ -27,18 +28,18 @@ type SearchDividendsIncentivesQuery struct { @@ -27,18 +28,18 @@ type SearchDividendsIncentivesQuery struct {
27 PageSize int64 `cname:"页面大小" json:"pageSize,omitempty"` 28 PageSize int64 `cname:"页面大小" json:"pageSize,omitempty"`
28 } 29 }
29 30
30 -func (searchDividendsIncentivesQuery *SearchDividendsIncentivesQuery) Valid(validation *validation.Validation) { 31 +func (searchDividendsIncentivesEstimateQuery *SearchDividendsIncentivesEstimateQuery) Valid(validation *validation.Validation) {
31 //validation.SetError("CustomValid", "未实现的自定义认证") 32 //validation.SetError("CustomValid", "未实现的自定义认证")
32 } 33 }
33 34
34 -func (searchDividendsIncentivesQuery *SearchDividendsIncentivesQuery) ValidateQuery() error { 35 +func (searchDividendsIncentivesEstimateQuery *SearchDividendsIncentivesEstimateQuery) ValidateQuery() error {
35 valid := validation.Validation{} 36 valid := validation.Validation{}
36 - b, err := valid.Valid(searchDividendsIncentivesQuery) 37 + b, err := valid.Valid(searchDividendsIncentivesEstimateQuery)
37 if err != nil { 38 if err != nil {
38 return err 39 return err
39 } 40 }
40 if !b { 41 if !b {
41 - elem := reflect.TypeOf(searchDividendsIncentivesQuery).Elem() 42 + elem := reflect.TypeOf(searchDividendsIncentivesEstimateQuery).Elem()
42 for _, validErr := range valid.Errors { 43 for _, validErr := range valid.Errors {
43 field, isExist := elem.FieldByName(validErr.Field) 44 field, isExist := elem.FieldByName(validErr.Field)
44 if isExist { 45 if isExist {
@@ -8,7 +8,8 @@ import ( @@ -8,7 +8,8 @@ import (
8 "github.com/beego/beego/v2/core/validation" 8 "github.com/beego/beego/v2/core/validation"
9 ) 9 )
10 10
11 -type SearchMoneyIncentivesQuery struct { 11 +// SearchMoneyIncentivesEstimateQuery 查找金额激励预算
  12 +type SearchMoneyIncentivesEstimateQuery struct {
12 // 共创合约名称 13 // 共创合约名称
13 CooperationContractName string `cname:"共创合约名称" json:"cooperationContractName,omitempty"` 14 CooperationContractName string `cname:"共创合约名称" json:"cooperationContractName,omitempty"`
14 // 发起部门名称 15 // 发起部门名称
@@ -27,18 +28,18 @@ type SearchMoneyIncentivesQuery struct { @@ -27,18 +28,18 @@ type SearchMoneyIncentivesQuery struct {
27 PageSize int64 `cname:"页面大小" json:"pageSize,omitempty"` 28 PageSize int64 `cname:"页面大小" json:"pageSize,omitempty"`
28 } 29 }
29 30
30 -func (searchMoneyIncentivesQuery *SearchMoneyIncentivesQuery) Valid(validation *validation.Validation) { 31 +func (searchMoneyIncentivesEstimateQuery *SearchMoneyIncentivesEstimateQuery) Valid(validation *validation.Validation) {
31 //validation.SetError("CustomValid", "未实现的自定义认证") 32 //validation.SetError("CustomValid", "未实现的自定义认证")
32 } 33 }
33 34
34 -func (searchMoneyIncentivesQuery *SearchMoneyIncentivesQuery) ValidateQuery() error { 35 +func (searchMoneyIncentivesEstimateQuery *SearchMoneyIncentivesEstimateQuery) ValidateQuery() error {
35 valid := validation.Validation{} 36 valid := validation.Validation{}
36 - b, err := valid.Valid(searchMoneyIncentivesQuery) 37 + b, err := valid.Valid(searchMoneyIncentivesEstimateQuery)
37 if err != nil { 38 if err != nil {
38 return err 39 return err
39 } 40 }
40 if !b { 41 if !b {
41 - elem := reflect.TypeOf(searchMoneyIncentivesQuery).Elem() 42 + elem := reflect.TypeOf(searchMoneyIncentivesEstimateQuery).Elem()
42 for _, validErr := range valid.Errors { 43 for _, validErr := range valid.Errors {
43 field, isExist := elem.FieldByName(validErr.Field) 44 field, isExist := elem.FieldByName(validErr.Field)
44 if isExist { 45 if isExist {
@@ -111,7 +111,7 @@ func (dividendsEstimateService *DividendsEstimateService) CreateDividendsEstimat @@ -111,7 +111,7 @@ func (dividendsEstimateService *DividendsEstimateService) CreateDividendsEstimat
111 DividendsParticipateType: 0, 111 DividendsParticipateType: 0,
112 DividendsType: 0, 112 DividendsType: 0,
113 OrderOrReturnedOrderNum: "", 113 OrderOrReturnedOrderNum: "",
114 - CooperationProjectNumber: "", 114 + CooperationContractNumber: "",
115 DividendsUser: nil, 115 DividendsUser: nil,
116 Org: organization, 116 Org: organization,
117 Company: company, 117 Company: company,
@@ -141,7 +141,7 @@ func (dividendsEstimateService *DividendsEstimateService) CreateDividendsEstimat @@ -141,7 +141,7 @@ func (dividendsEstimateService *DividendsEstimateService) CreateDividendsEstimat
141 } 141 }
142 142
143 // EstimateDividendsIncentives 确定预算分红激励 143 // EstimateDividendsIncentives 确定预算分红激励
144 -func (dividendsEstimateService *DividendsEstimateService) EstimateDividendsIncentives(estimateDividendsIncentivesCommand *command.EstimateDividendsIncentivesCommand) (interface{}, error) { 144 +func (dividendsEstimateService *DividendsEstimateService) EstimateDividendsIncentives(estimateDividendsIncentivesCommand *command.ConfirmDividendsIncentivesEstimateCommand) (interface{}, error) {
145 if err := estimateDividendsIncentivesCommand.ValidateCommand(); err != nil { 145 if err := estimateDividendsIncentivesCommand.ValidateCommand(); err != nil {
146 return nil, application.ThrowError(application.ARG_ERROR, err.Error()) 146 return nil, application.ThrowError(application.ARG_ERROR, err.Error())
147 } 147 }
@@ -162,7 +162,7 @@ func (dividendsEstimateService *DividendsEstimateService) EstimateDividendsIncen @@ -162,7 +162,7 @@ func (dividendsEstimateService *DividendsEstimateService) EstimateDividendsIncen
162 } 162 }
163 163
164 // EstimateMoneyIncentives 确定预算金额激励分红 164 // EstimateMoneyIncentives 确定预算金额激励分红
165 -func (dividendsEstimateService *DividendsEstimateService) EstimateMoneyIncentives(estimateMoneyIncentivesCommand *command.EstimateMoneyIncentivesCommand) (interface{}, error) { 165 +func (dividendsEstimateService *DividendsEstimateService) EstimateMoneyIncentives(estimateMoneyIncentivesCommand *command.ConfirmMoneyIncentivesEstimateCommand) (interface{}, error) {
166 if err := estimateMoneyIncentivesCommand.ValidateCommand(); err != nil { 166 if err := estimateMoneyIncentivesCommand.ValidateCommand(); err != nil {
167 return nil, application.ThrowError(application.ARG_ERROR, err.Error()) 167 return nil, application.ThrowError(application.ARG_ERROR, err.Error())
168 } 168 }
@@ -258,7 +258,7 @@ func (dividendsEstimateService *DividendsEstimateService) ListDividendsEstimate( @@ -258,7 +258,7 @@ func (dividendsEstimateService *DividendsEstimateService) ListDividendsEstimate(
258 } 258 }
259 259
260 // ListDividendsIncentives 返回业绩激励分红 260 // ListDividendsIncentives 返回业绩激励分红
261 -func (dividendsEstimateService *DividendsEstimateService) ListDividendsIncentives(listDividendsIncentivesQuery *query.ListDividendsIncentivesQuery) (interface{}, error) { 261 +func (dividendsEstimateService *DividendsEstimateService) ListDividendsIncentives(listDividendsIncentivesQuery *query.ListDividendsIncentivesEstimateQuery) (interface{}, error) {
262 if err := listDividendsIncentivesQuery.ValidateQuery(); err != nil { 262 if err := listDividendsIncentivesQuery.ValidateQuery(); err != nil {
263 return nil, application.ThrowError(application.ARG_ERROR, err.Error()) 263 return nil, application.ThrowError(application.ARG_ERROR, err.Error())
264 } 264 }
@@ -279,7 +279,7 @@ func (dividendsEstimateService *DividendsEstimateService) ListDividendsIncentive @@ -279,7 +279,7 @@ func (dividendsEstimateService *DividendsEstimateService) ListDividendsIncentive
279 } 279 }
280 280
281 // ListMoneyIncentives 返回金额激励分红 281 // ListMoneyIncentives 返回金额激励分红
282 -func (dividendsEstimateService *DividendsEstimateService) ListMoneyIncentives(listMoneyIncentivesQuery *query.ListMoneyIncentivesQuery) (interface{}, error) { 282 +func (dividendsEstimateService *DividendsEstimateService) ListMoneyIncentives(listMoneyIncentivesQuery *query.ListMoneyIncentivesEstimateQuery) (interface{}, error) {
283 if err := listMoneyIncentivesQuery.ValidateQuery(); err != nil { 283 if err := listMoneyIncentivesQuery.ValidateQuery(); err != nil {
284 return nil, application.ThrowError(application.ARG_ERROR, err.Error()) 284 return nil, application.ThrowError(application.ARG_ERROR, err.Error())
285 } 285 }
@@ -361,7 +361,7 @@ func (dividendsEstimateService *DividendsEstimateService) SearchDividendsEstimat @@ -361,7 +361,7 @@ func (dividendsEstimateService *DividendsEstimateService) SearchDividendsEstimat
361 } 361 }
362 362
363 // SearchDividendsIncentives 查询业绩分红 363 // SearchDividendsIncentives 查询业绩分红
364 -func (dividendsEstimateService *DividendsEstimateService) SearchDividendsIncentives(searchDividendsIncentivesQuery *query.SearchDividendsIncentivesQuery) (interface{}, error) { 364 +func (dividendsEstimateService *DividendsEstimateService) SearchDividendsIncentives(searchDividendsIncentivesQuery *query.SearchDividendsIncentivesEstimateQuery) (interface{}, error) {
365 if err := searchDividendsIncentivesQuery.ValidateQuery(); err != nil { 365 if err := searchDividendsIncentivesQuery.ValidateQuery(); err != nil {
366 return nil, application.ThrowError(application.ARG_ERROR, err.Error()) 366 return nil, application.ThrowError(application.ARG_ERROR, err.Error())
367 } 367 }
@@ -382,7 +382,7 @@ func (dividendsEstimateService *DividendsEstimateService) SearchDividendsIncenti @@ -382,7 +382,7 @@ func (dividendsEstimateService *DividendsEstimateService) SearchDividendsIncenti
382 } 382 }
383 383
384 // SearchMoneyIncentives 查询金额激励分红 384 // SearchMoneyIncentives 查询金额激励分红
385 -func (dividendsEstimateService *DividendsEstimateService) SearchMoneyIncentives(searchMoneyIncentivesQuery *query.SearchMoneyIncentivesQuery) (interface{}, error) { 385 +func (dividendsEstimateService *DividendsEstimateService) SearchMoneyIncentives(searchMoneyIncentivesQuery *query.SearchMoneyIncentivesEstimateQuery) (interface{}, error) {
386 if err := searchMoneyIncentivesQuery.ValidateQuery(); err != nil { 386 if err := searchMoneyIncentivesQuery.ValidateQuery(); err != nil {
387 return nil, application.ThrowError(application.ARG_ERROR, err.Error()) 387 return nil, application.ThrowError(application.ARG_ERROR, err.Error())
388 } 388 }
@@ -20,8 +20,8 @@ type DividendsEstimate struct { @@ -20,8 +20,8 @@ type DividendsEstimate struct {
20 DividendsType int32 `json:"dividendsType"` 20 DividendsType int32 `json:"dividendsType"`
21 // 分红订单号或退货单号 21 // 分红订单号或退货单号
22 OrderOrReturnedOrderNum string `json:"orderOrReturnedOrderNum"` 22 OrderOrReturnedOrderNum string `json:"orderOrReturnedOrderNum"`
23 - // 共创项目编号,自生成,生成规则:XM+6位年月日+#+3位流水,例XM210601#001  
24 - CooperationProjectNumber string `json:"cooperationProjectNumber"` 23 + // 共创项目合约编号,自生成,生成规则:XM+6位年月日+#+3位流水,例XM210601#001
  24 + CooperationContractNumber string `json:"cooperationContractNumber"`
25 // 分红用户 25 // 分红用户
26 DividendsUser *User `json:"dividendsUser"` 26 DividendsUser *User `json:"dividendsUser"`
27 // 数据所属组织机构 27 // 数据所属组织机构
@@ -80,7 +80,7 @@ func (dividendsEstimate *DividendsEstimate) Update(data map[string]interface{}) @@ -80,7 +80,7 @@ func (dividendsEstimate *DividendsEstimate) Update(data map[string]interface{})
80 dividendsEstimate.OrderOrReturnedOrderNum = orderOrReturnedOrderNum.(string) 80 dividendsEstimate.OrderOrReturnedOrderNum = orderOrReturnedOrderNum.(string)
81 } 81 }
82 if cooperationProjectNumber, ok := data["cooperationProjectNumber"]; ok { 82 if cooperationProjectNumber, ok := data["cooperationProjectNumber"]; ok {
83 - dividendsEstimate.CooperationProjectNumber = cooperationProjectNumber.(string) 83 + dividendsEstimate.CooperationContractNumber = cooperationProjectNumber.(string)
84 } 84 }
85 if userId, ok := data["userId"]; ok { 85 if userId, ok := data["userId"]; ok {
86 dividendsEstimate.DividendsUser.UserId = userId.(int64) 86 dividendsEstimate.DividendsUser.UserId = userId.(int64)
@@ -23,8 +23,8 @@ type DividendsEstimate struct { @@ -23,8 +23,8 @@ type DividendsEstimate struct {
23 DividendsType int32 `comment:"分红类型,1订单分红,2退货冲销,3金额激励"` 23 DividendsType int32 `comment:"分红类型,1订单分红,2退货冲销,3金额激励"`
24 // 分红订单号或退货单号 24 // 分红订单号或退货单号
25 OrderOrReturnedOrderNum string `comment:"分红订单号或退货单号"` 25 OrderOrReturnedOrderNum string `comment:"分红订单号或退货单号"`
26 - // 共创项目编号,自生成,生成规则:XM+6位年月日+#+3位流水,例XM210601#001  
27 - CooperationProjectNumber string `comment:"共创项目编号,自生成,生成规则:XM+6位年月日+#+3位流水,例XM210601#001"` 26 + // 共创项目合约编号
  27 + CooperationContractNumber string `comment:"共创项目合约编号"`
28 // 分红用户 28 // 分红用户
29 DividendsUser *domain.User `comment:"分红用户"` 29 DividendsUser *domain.User `comment:"分红用户"`
30 // 数据所属组织机构 30 // 数据所属组织机构
@@ -15,7 +15,7 @@ func TransformToDividendsEstimateDomainModelFromPgModels(dividendsEstimateModel @@ -15,7 +15,7 @@ func TransformToDividendsEstimateDomainModelFromPgModels(dividendsEstimateModel
15 DividendsParticipateType: dividendsEstimateModel.DividendsParticipateType, 15 DividendsParticipateType: dividendsEstimateModel.DividendsParticipateType,
16 DividendsType: dividendsEstimateModel.DividendsType, 16 DividendsType: dividendsEstimateModel.DividendsType,
17 OrderOrReturnedOrderNum: dividendsEstimateModel.OrderOrReturnedOrderNum, 17 OrderOrReturnedOrderNum: dividendsEstimateModel.OrderOrReturnedOrderNum,
18 - CooperationProjectNumber: dividendsEstimateModel.CooperationProjectNumber, 18 + CooperationContractNumber: dividendsEstimateModel.CooperationContractNumber,
19 DividendsUser: dividendsEstimateModel.DividendsUser, 19 DividendsUser: dividendsEstimateModel.DividendsUser,
20 Org: dividendsEstimateModel.Org, 20 Org: dividendsEstimateModel.Org,
21 Company: dividendsEstimateModel.Company, 21 Company: dividendsEstimateModel.Company,
@@ -24,6 +24,7 @@ func (repository *CreditAccountRepository) nextIdentify() (int64, error) { @@ -24,6 +24,7 @@ func (repository *CreditAccountRepository) nextIdentify() (int64, error) {
24 id, err := IdWorker.NextId() 24 id, err := IdWorker.NextId()
25 return id, err 25 return id, err
26 } 26 }
  27 +
27 func (repository *CreditAccountRepository) Save(creditAccount *domain.CreditAccount) (*domain.CreditAccount, error) { 28 func (repository *CreditAccountRepository) Save(creditAccount *domain.CreditAccount) (*domain.CreditAccount, error) {
28 sqlBuildFields := []string{ 29 sqlBuildFields := []string{
29 "credit_account_id", 30 "credit_account_id",
@@ -154,6 +155,7 @@ func (repository *CreditAccountRepository) Save(creditAccount *domain.CreditAcco @@ -154,6 +155,7 @@ func (repository *CreditAccountRepository) Save(creditAccount *domain.CreditAcco
154 } 155 }
155 return creditAccount, nil 156 return creditAccount, nil
156 } 157 }
  158 +
157 func (repository *CreditAccountRepository) Remove(creditAccount *domain.CreditAccount) (*domain.CreditAccount, error) { 159 func (repository *CreditAccountRepository) Remove(creditAccount *domain.CreditAccount) (*domain.CreditAccount, error) {
158 tx := repository.transactionContext.PgTx 160 tx := repository.transactionContext.PgTx
159 creditAccountModel := new(models.CreditAccount) 161 creditAccountModel := new(models.CreditAccount)
@@ -163,6 +165,7 @@ func (repository *CreditAccountRepository) Remove(creditAccount *domain.CreditAc @@ -163,6 +165,7 @@ func (repository *CreditAccountRepository) Remove(creditAccount *domain.CreditAc
163 } 165 }
164 return creditAccount, nil 166 return creditAccount, nil
165 } 167 }
  168 +
166 func (repository *CreditAccountRepository) FindOne(queryOptions map[string]interface{}) (*domain.CreditAccount, error) { 169 func (repository *CreditAccountRepository) FindOne(queryOptions map[string]interface{}) (*domain.CreditAccount, error) {
167 tx := repository.transactionContext.PgTx 170 tx := repository.transactionContext.PgTx
168 creditAccountModel := new(models.CreditAccount) 171 creditAccountModel := new(models.CreditAccount)
@@ -181,6 +184,7 @@ func (repository *CreditAccountRepository) FindOne(queryOptions map[string]inter @@ -181,6 +184,7 @@ func (repository *CreditAccountRepository) FindOne(queryOptions map[string]inter
181 return transform.TransformToCreditAccountDomainModelFromPgModels(creditAccountModel) 184 return transform.TransformToCreditAccountDomainModelFromPgModels(creditAccountModel)
182 } 185 }
183 } 186 }
  187 +
184 func (repository *CreditAccountRepository) Find(queryOptions map[string]interface{}) (int64, []*domain.CreditAccount, error) { 188 func (repository *CreditAccountRepository) Find(queryOptions map[string]interface{}) (int64, []*domain.CreditAccount, error) {
185 tx := repository.transactionContext.PgTx 189 tx := repository.transactionContext.PgTx
186 var creditAccountModels []*models.CreditAccount 190 var creditAccountModels []*models.CreditAccount
@@ -207,6 +211,7 @@ func (repository *CreditAccountRepository) Find(queryOptions map[string]interfac @@ -207,6 +211,7 @@ func (repository *CreditAccountRepository) Find(queryOptions map[string]interfac
207 return int64(count), creditAccounts, nil 211 return int64(count), creditAccounts, nil
208 } 212 }
209 } 213 }
  214 +
210 func NewCreditAccountRepository(transactionContext *pgTransaction.TransactionContext) (*CreditAccountRepository, error) { 215 func NewCreditAccountRepository(transactionContext *pgTransaction.TransactionContext) (*CreditAccountRepository, error) {
211 if transactionContext == nil { 216 if transactionContext == nil {
212 return nil, fmt.Errorf("transactionContext参数不能为nil") 217 return nil, fmt.Errorf("transactionContext参数不能为nil")
@@ -34,7 +34,7 @@ func (repository *DividendsEstimateRepository) Save(dividendsEstimate *domain.Di @@ -34,7 +34,7 @@ func (repository *DividendsEstimateRepository) Save(dividendsEstimate *domain.Di
34 "dividends_participate_type", 34 "dividends_participate_type",
35 "dividends_type", 35 "dividends_type",
36 "order_or_returned_order_num", 36 "order_or_returned_order_num",
37 - "cooperation_project_number", 37 + "cooperation_contract_number",
38 "dividends_user", 38 "dividends_user",
39 "org", 39 "org",
40 "company", 40 "company",
@@ -67,7 +67,7 @@ func (repository *DividendsEstimateRepository) Save(dividendsEstimate *domain.Di @@ -67,7 +67,7 @@ func (repository *DividendsEstimateRepository) Save(dividendsEstimate *domain.Di
67 &dividendsEstimate.DividendsParticipateType, 67 &dividendsEstimate.DividendsParticipateType,
68 &dividendsEstimate.DividendsType, 68 &dividendsEstimate.DividendsType,
69 &dividendsEstimate.OrderOrReturnedOrderNum, 69 &dividendsEstimate.OrderOrReturnedOrderNum,
70 - &dividendsEstimate.CooperationProjectNumber, 70 + &dividendsEstimate.CooperationContractNumber,
71 &dividendsEstimate.DividendsUser, 71 &dividendsEstimate.DividendsUser,
72 &dividendsEstimate.Org, 72 &dividendsEstimate.Org,
73 &dividendsEstimate.Company, 73 &dividendsEstimate.Company,
@@ -86,7 +86,7 @@ func (repository *DividendsEstimateRepository) Save(dividendsEstimate *domain.Di @@ -86,7 +86,7 @@ func (repository *DividendsEstimateRepository) Save(dividendsEstimate *domain.Di
86 dividendsEstimate.DividendsParticipateType, 86 dividendsEstimate.DividendsParticipateType,
87 dividendsEstimate.DividendsType, 87 dividendsEstimate.DividendsType,
88 dividendsEstimate.OrderOrReturnedOrderNum, 88 dividendsEstimate.OrderOrReturnedOrderNum,
89 - dividendsEstimate.CooperationProjectNumber, 89 + dividendsEstimate.CooperationContractNumber,
90 dividendsEstimate.DividendsUser, 90 dividendsEstimate.DividendsUser,
91 dividendsEstimate.Org, 91 dividendsEstimate.Org,
92 dividendsEstimate.Company, 92 dividendsEstimate.Company,
@@ -109,7 +109,7 @@ func (repository *DividendsEstimateRepository) Save(dividendsEstimate *domain.Di @@ -109,7 +109,7 @@ func (repository *DividendsEstimateRepository) Save(dividendsEstimate *domain.Di
109 &dividendsEstimate.DividendsParticipateType, 109 &dividendsEstimate.DividendsParticipateType,
110 &dividendsEstimate.DividendsType, 110 &dividendsEstimate.DividendsType,
111 &dividendsEstimate.OrderOrReturnedOrderNum, 111 &dividendsEstimate.OrderOrReturnedOrderNum,
112 - &dividendsEstimate.CooperationProjectNumber, 112 + &dividendsEstimate.CooperationContractNumber,
113 &dividendsEstimate.DividendsUser, 113 &dividendsEstimate.DividendsUser,
114 &dividendsEstimate.Org, 114 &dividendsEstimate.Org,
115 &dividendsEstimate.Company, 115 &dividendsEstimate.Company,
@@ -128,7 +128,7 @@ func (repository *DividendsEstimateRepository) Save(dividendsEstimate *domain.Di @@ -128,7 +128,7 @@ func (repository *DividendsEstimateRepository) Save(dividendsEstimate *domain.Di
128 dividendsEstimate.DividendsParticipateType, 128 dividendsEstimate.DividendsParticipateType,
129 dividendsEstimate.DividendsType, 129 dividendsEstimate.DividendsType,
130 dividendsEstimate.OrderOrReturnedOrderNum, 130 dividendsEstimate.OrderOrReturnedOrderNum,
131 - dividendsEstimate.CooperationProjectNumber, 131 + dividendsEstimate.CooperationContractNumber,
132 dividendsEstimate.DividendsUser, 132 dividendsEstimate.DividendsUser,
133 dividendsEstimate.Org, 133 dividendsEstimate.Org,
134 dividendsEstimate.Company, 134 dividendsEstimate.Company,
@@ -26,6 +26,7 @@ func (repository *DividendsReturnedOrderRepository) nextIdentify() (int64, error @@ -26,6 +26,7 @@ func (repository *DividendsReturnedOrderRepository) nextIdentify() (int64, error
26 id, err := IdWorker.NextId() 26 id, err := IdWorker.NextId()
27 return id, err 27 return id, err
28 } 28 }
  29 +
29 func (repository *DividendsReturnedOrderRepository) Save(dividendsReturnedOrder *domain.DividendsReturnedOrder) (*domain.DividendsReturnedOrder, error) { 30 func (repository *DividendsReturnedOrderRepository) Save(dividendsReturnedOrder *domain.DividendsReturnedOrder) (*domain.DividendsReturnedOrder, error) {
30 sqlBuildFields := []string{ 31 sqlBuildFields := []string{
31 "dividends_returned_order_id", 32 "dividends_returned_order_id",
@@ -97,7 +97,7 @@ func (controller *DividendsEstimateController) SearchDividendsEstimate() { @@ -97,7 +97,7 @@ func (controller *DividendsEstimateController) SearchDividendsEstimate() {
97 97
98 func (controller *DividendsEstimateController) EstimateDividendsIncentives() { 98 func (controller *DividendsEstimateController) EstimateDividendsIncentives() {
99 dividendsEstimateService := service.NewDividendsEstimateService(nil) 99 dividendsEstimateService := service.NewDividendsEstimateService(nil)
100 - estimateDividendsIncentivesCommand := &command.EstimateDividendsIncentivesCommand{} 100 + estimateDividendsIncentivesCommand := &command.ConfirmDividendsIncentivesEstimateCommand{}
101 _ = controller.Unmarshal(estimateDividendsIncentivesCommand) 101 _ = controller.Unmarshal(estimateDividendsIncentivesCommand)
102 header := controller.GetRequestHeader(controller.Ctx) 102 header := controller.GetRequestHeader(controller.Ctx)
103 estimateDividendsIncentivesCommand.CompanyId = header.CompanyId 103 estimateDividendsIncentivesCommand.CompanyId = header.CompanyId
@@ -110,7 +110,7 @@ func (controller *DividendsEstimateController) EstimateDividendsIncentives() { @@ -110,7 +110,7 @@ func (controller *DividendsEstimateController) EstimateDividendsIncentives() {
110 110
111 func (controller *DividendsEstimateController) EstimateMoneyIncentives() { 111 func (controller *DividendsEstimateController) EstimateMoneyIncentives() {
112 dividendsEstimateService := service.NewDividendsEstimateService(nil) 112 dividendsEstimateService := service.NewDividendsEstimateService(nil)
113 - estimateMoneyIncentivesCommand := &command.EstimateMoneyIncentivesCommand{} 113 + estimateMoneyIncentivesCommand := &command.ConfirmMoneyIncentivesEstimateCommand{}
114 _ = controller.Unmarshal(estimateMoneyIncentivesCommand) 114 _ = controller.Unmarshal(estimateMoneyIncentivesCommand)
115 header := controller.GetRequestHeader(controller.Ctx) 115 header := controller.GetRequestHeader(controller.Ctx)
116 estimateMoneyIncentivesCommand.CompanyId = header.CompanyId 116 estimateMoneyIncentivesCommand.CompanyId = header.CompanyId
@@ -123,7 +123,7 @@ func (controller *DividendsEstimateController) EstimateMoneyIncentives() { @@ -123,7 +123,7 @@ func (controller *DividendsEstimateController) EstimateMoneyIncentives() {
123 123
124 func (controller *DividendsEstimateController) ListMoneyIncentives() { 124 func (controller *DividendsEstimateController) ListMoneyIncentives() {
125 dividendsEstimateService := service.NewDividendsEstimateService(nil) 125 dividendsEstimateService := service.NewDividendsEstimateService(nil)
126 - listMoneyIncentivesQuery := &query.ListMoneyIncentivesQuery{} 126 + listMoneyIncentivesQuery := &query.ListMoneyIncentivesEstimateQuery{}
127 header := controller.GetRequestHeader(controller.Ctx) 127 header := controller.GetRequestHeader(controller.Ctx)
128 listMoneyIncentivesQuery.CompanyId = header.CompanyId 128 listMoneyIncentivesQuery.CompanyId = header.CompanyId
129 listMoneyIncentivesQuery.OrgId = header.OrgId 129 listMoneyIncentivesQuery.OrgId = header.OrgId
@@ -135,7 +135,7 @@ func (controller *DividendsEstimateController) ListMoneyIncentives() { @@ -135,7 +135,7 @@ func (controller *DividendsEstimateController) ListMoneyIncentives() {
135 135
136 func (controller *DividendsEstimateController) SearchMoneyIncentives() { 136 func (controller *DividendsEstimateController) SearchMoneyIncentives() {
137 dividendsEstimateService := service.NewDividendsEstimateService(nil) 137 dividendsEstimateService := service.NewDividendsEstimateService(nil)
138 - searchMoneyIncentivesQuery := &query.SearchMoneyIncentivesQuery{} 138 + searchMoneyIncentivesQuery := &query.SearchMoneyIncentivesEstimateQuery{}
139 header := controller.GetRequestHeader(controller.Ctx) 139 header := controller.GetRequestHeader(controller.Ctx)
140 searchMoneyIncentivesQuery.CompanyId = header.CompanyId 140 searchMoneyIncentivesQuery.CompanyId = header.CompanyId
141 searchMoneyIncentivesQuery.OrgId = header.OrgId 141 searchMoneyIncentivesQuery.OrgId = header.OrgId
@@ -147,7 +147,7 @@ func (controller *DividendsEstimateController) SearchMoneyIncentives() { @@ -147,7 +147,7 @@ func (controller *DividendsEstimateController) SearchMoneyIncentives() {
147 147
148 func (controller *DividendsEstimateController) ListDividendsIncentives() { 148 func (controller *DividendsEstimateController) ListDividendsIncentives() {
149 dividendsEstimateService := service.NewDividendsEstimateService(nil) 149 dividendsEstimateService := service.NewDividendsEstimateService(nil)
150 - listDividendsIncentivesQuery := &query.ListDividendsIncentivesQuery{} 150 + listDividendsIncentivesQuery := &query.ListDividendsIncentivesEstimateQuery{}
151 header := controller.GetRequestHeader(controller.Ctx) 151 header := controller.GetRequestHeader(controller.Ctx)
152 listDividendsIncentivesQuery.CompanyId = header.CompanyId 152 listDividendsIncentivesQuery.CompanyId = header.CompanyId
153 listDividendsIncentivesQuery.OrgId = header.OrgId 153 listDividendsIncentivesQuery.OrgId = header.OrgId
@@ -159,7 +159,7 @@ func (controller *DividendsEstimateController) ListDividendsIncentives() { @@ -159,7 +159,7 @@ func (controller *DividendsEstimateController) ListDividendsIncentives() {
159 159
160 func (controller *DividendsEstimateController) SearchDividendsIncentives() { 160 func (controller *DividendsEstimateController) SearchDividendsIncentives() {
161 dividendsEstimateService := service.NewDividendsEstimateService(nil) 161 dividendsEstimateService := service.NewDividendsEstimateService(nil)
162 - searchDividendsIncentivesQuery := &query.SearchDividendsIncentivesQuery{} 162 + searchDividendsIncentivesQuery := &query.SearchDividendsIncentivesEstimateQuery{}
163 header := controller.GetRequestHeader(controller.Ctx) 163 header := controller.GetRequestHeader(controller.Ctx)
164 searchDividendsIncentivesQuery.CompanyId = header.CompanyId 164 searchDividendsIncentivesQuery.CompanyId = header.CompanyId
165 searchDividendsIncentivesQuery.OrgId = header.OrgId 165 searchDividendsIncentivesQuery.OrgId = header.OrgId