baize/convenient/relation/one2one/simple.go

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

	// 查询左实体带右实体信息使用的请求参数，注意是Query类型
	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, leftRelationColumnName, 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, rightRelationColumnName, 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
	}
}