package one2one import ( "fmt" "git.sxidc.com/go-framework/baize/convenient/binding" "git.sxidc.com/go-framework/baize/convenient/binding/request" "git.sxidc.com/go-framework/baize/convenient/binding/response" "git.sxidc.com/go-framework/baize/framwork/domain" "git.sxidc.com/go-framework/baize/framwork/domain/entity" "github.com/iancoleman/strcase" ) // Simple 关联的Bind参数 // LI 为左边实体的Info类型 // RI 为右边实体的Info类型 type Simple[LI any, RI any] struct { // 左领域实体,注意是Entity类型 Left entity.Entity // 右领域实体,注意是Entity类型 Right entity.Entity // 数据库Schema Schema string // 更新左实体关联使用的请求参数 LeftUpdateJsonBody request.WithID // 查询左实体关联使用的请求参数,注意是WithID类型 LeftQueryQueryParams request.WithID // 查询左实体带右实体信息使用的请求参数,注意是WithID类型 LeftQueryWithRightQueryParams request.Query // 更新右实体关联使用的请求参数,注意是WithID类型 RightUpdateJsonBody request.WithID // 查询右实体关联使用的请求参数,注意是WithID类型 RightQueryQueryParams request.WithID // 查询右实体带左实体信息使用的请求参数,注意是WithID类型 RightQueryWithLeftQueryParams request.Query // 可选配置项,通过WithXXX配置 options *Options } func (simple *Simple[LI, RI]) bind(binder *binding.Binder) { options := simple.options leftDomainPath := entity.RelativeDomainPath(simple.Left) rightDomainPath := entity.RelativeDomainPath(simple.Right) leftRelationFieldName := fmt.Sprintf("%sID", simple.Right.DomainCamelName()) rightRelationFieldName := fmt.Sprintf("%sID", simple.Left.DomainCamelName()) leftTableName := entity.TableName(simple.Schema, simple.Left) leftRelationColumnName := fmt.Sprintf("%s_id", strcase.ToSnake(simple.Right.DomainCamelName())) rightTableName := entity.TableName(simple.Schema, simple.Right) rightRelationColumnName := fmt.Sprintf("%s_id", strcase.ToSnake(simple.Left.DomainCamelName())) if !options.disableLeft { if !options.disableLeftUpdate { // 左到右更新 binding.PostBind(binder, &binding.SimpleBindItem[any]{ Path: leftDomainPath + rightDomainPath + "/update", ResponseFunc: response.SendMsgResponse, RequestParams: simple.LeftUpdateJsonBody, Objects: []domain.Object{simple.Left}, ServiceFunc: Update(leftTableName, leftRelationFieldName, leftRelationColumnName, rightTableName, simple.Right.DomainCNName(), rightRelationColumnName), }) } if !options.disableLeftQuery { // 左到右查询 binding.GetBind(binder, &binding.SimpleBindItem[RI]{ Path: leftDomainPath + rightDomainPath + "/query", ResponseFunc: response.SendInfoResponse[RI], RequestParams: simple.LeftQueryQueryParams, Objects: []domain.Object{simple.Left}, ServiceFunc: Query[RI](leftTableName, rightTableName, rightRelationColumnName), }) } if !options.disableLeftWithRightQuery { // 左到右查询,携带右方信息 binding.GetBind(binder, &binding.SimpleBindItem[response.InfosData[map[string]any]]{ Path: leftDomainPath + rightDomainPath + "/queryWith", ResponseFunc: response.SendInfosResponse[map[string]any], RequestParams: simple.LeftQueryWithRightQueryParams, Objects: []domain.Object{simple.Left}, ServiceFunc: QueryWithOtherInfo[LI, RI](leftTableName, leftRelationColumnName, options.leftQueryWithConditionFieldCallback, rightTableName), }) } } if !options.disableRight { if !options.disableRightUpdate { // 右到左更新 binding.PostBind(binder, &binding.SimpleBindItem[any]{ Path: rightDomainPath + leftDomainPath + "/update", ResponseFunc: response.SendMsgResponse, RequestParams: simple.RightUpdateJsonBody, Objects: []domain.Object{simple.Right}, ServiceFunc: Update(rightTableName, rightRelationFieldName, rightRelationColumnName, leftTableName, simple.Left.DomainCNName(), leftRelationColumnName), }) } if !options.disableRightQuery { // 右到左查询 binding.GetBind(binder, &binding.SimpleBindItem[LI]{ Path: rightDomainPath + leftDomainPath + "/query", ResponseFunc: response.SendInfoResponse[LI], RequestParams: simple.RightQueryQueryParams, Objects: []domain.Object{simple.Right}, ServiceFunc: Query[LI](rightTableName, leftTableName, leftRelationColumnName), }) } if !options.disableRightWithLeftQuery { // 右到左查询,携带左方信息 binding.GetBind(binder, &binding.SimpleBindItem[response.InfosData[map[string]any]]{ Path: rightDomainPath + leftDomainPath + "/queryWith", ResponseFunc: response.SendInfosResponse[map[string]any], RequestParams: simple.RightQueryWithLeftQueryParams, Objects: []domain.Object{simple.Right}, ServiceFunc: QueryWithOtherInfo[RI, LI](rightTableName, rightRelationColumnName, options.rightQueryWithConditionFieldCallback, leftTableName), }) } } } func BindSimple[LI any, RI any](binder *binding.Binder, simple *Simple[LI, RI], opts ...Option) { options := new(Options) for _, opt := range opts { opt(options) } simple.options = options simple.bind(binder) } type Option func(options *Options) type Options struct { // 关闭左侧到右侧关联 disableLeft bool // 关闭右侧到左侧关联 disableRight bool // 关闭左侧更新 disableLeftUpdate bool // 关闭左侧查询 disableLeftQuery bool // 关闭右侧更新 disableRightUpdate bool // 关闭右侧查询 disableRightQuery bool // 关闭左实体带右实体信息查询 disableLeftWithRightQuery bool // 关闭右实体带左实体信息查询 disableRightWithLeftQuery bool // 左查询条件构造回调 leftQueryWithConditionFieldCallback ConditionFieldCallback // 右查询条件构造回调 rightQueryWithConditionFieldCallback ConditionFieldCallback } func WithDisableLeft() Option { return func(options *Options) { options.disableLeft = true } } func WithDisableRight() Option { return func(options *Options) { options.disableRight = true } } func WithDisableLeftUpdate() Option { return func(options *Options) { options.disableLeftUpdate = true } } func WithDisableLeftQuery() Option { return func(options *Options) { options.disableLeftQuery = true } } func WithDisableRightUpdate() Option { return func(options *Options) { options.disableRightUpdate = true } } func WithDisableRightQuery() Option { return func(options *Options) { options.disableRightQuery = true } } func WithDisableLeftWithRightQuery() Option { return func(options *Options) { options.disableLeftWithRightQuery = true } } func WithDisableRightWithLeftQuery() Option { return func(options *Options) { options.disableRightWithLeftQuery = true } } func WithLeftQueryWithConditionFieldCallback(callbacks ConditionFieldCallback) Option { return func(options *Options) { options.leftQueryWithConditionFieldCallback = callbacks } } func WithRightQueryWithConditionFieldCallback(callbacks ConditionFieldCallback) Option { return func(options *Options) { options.rightQueryWithConditionFieldCallback = callbacks } }