baize/convenient/gwtools/value_object_crud.go

package gwtools

import (
	"git.sxidc.com/go-framework/baize/framework/core/api"
	"git.sxidc.com/go-framework/baize/framework/gateway"
	"git.sxidc.com/go-tools/utils/template"
	"github.com/iancoleman/strcase"
	"net/http"
)

func ValueObjectCRUD(builder *gateway.Builder, params *ValueObjectCRUDParams, opts ...any) {
	globalOptions := new(ValueObjectCRUDGlobalOptions)
	createOptions := new(ValueObjectCRUDCreateOptions)
	deleteOptions := new(ValueObjectCRUDDeleteOptions)
	queryOptions := new(ValueObjectCRUDQueryOptions)

	for _, opt := range opts {
		switch o := opt.(type) {
		case ValueObjectCRUDGlobalOption:
			o(globalOptions)
		case ValueObjectCRUDCreateOption:
			o(createOptions)
		case ValueObjectCRUDDeleteOption:
			o(deleteOptions)
		case ValueObjectCRUDQueryOption:
			o(queryOptions)
		default:
			continue
		}
	}

	params.globalOptions = globalOptions
	params.createOptions = createOptions
	params.deleteOptions = deleteOptions
	params.queryOptions = queryOptions

	params.crud(builder)
}

type ValueObjectCRUDParams struct {
	// 除去后缀的服务URL，如http://localhost:8080/example/api/v1
	ServiceVersionedUrl string

	// 领域名称
	DomainCamelName string

	// 可选配置项，通过WithXXX配置
	globalOptions *ValueObjectCRUDGlobalOptions
	createOptions *ValueObjectCRUDCreateOptions
	deleteOptions *ValueObjectCRUDDeleteOptions
	queryOptions  *ValueObjectCRUDQueryOptions
}

func (params *ValueObjectCRUDParams) crud(builder *gateway.Builder) {
	globalOptions := params.globalOptions
	createOptions := params.createOptions
	deleteOptions := params.deleteOptions
	queryOptions := params.queryOptions

	domainPath := "/" + strcase.ToLowerCamel(template.Id(params.DomainCamelName))

	// 创建
	if !createOptions.disable {
		createMiddlewares := append(globalOptions.middlewares, createOptions.middlewares...)

		copyBuilder := builder.Url(http.MethodPost, domainPath+"/create")

		if createOptions.beforeBuilderCallback != nil {
			copyBuilder = createOptions.beforeBuilderCallback(copyBuilder)
		}

		copyBuilder = copyBuilder.Post(gateway.NewPostRequest(params.ServiceVersionedUrl+domainPath+"/create",
			gateway.PostRequestWithBodyForm(
				gateway.FormJsonBodyWithTenantIDAndUserIDFunc("tenantId", "createUserId"))),
			createOptions.requestResponseCallback)

		if createOptions.afterBuilderCallback != nil {
			copyBuilder = createOptions.afterBuilderCallback(copyBuilder)
		}

		copyBuilder.Build(createMiddlewares...)
	}

	// 删除
	if !deleteOptions.disable {
		deleteMiddlewares := append(globalOptions.middlewares, deleteOptions.middlewares...)

		copyBuilder := builder.Url(http.MethodPost, domainPath+"/delete")

		if deleteOptions.beforeBuilderCallback != nil {
			copyBuilder = deleteOptions.beforeBuilderCallback(copyBuilder)
		}

		copyBuilder = copyBuilder.Post(gateway.NewPostRequest(params.ServiceVersionedUrl+domainPath+"/delete"),
			deleteOptions.requestResponseCallback)

		if deleteOptions.afterBuilderCallback != nil {
			copyBuilder = deleteOptions.afterBuilderCallback(copyBuilder)
		}

		copyBuilder.Build(deleteMiddlewares...)
	}

	// 查询
	if !queryOptions.disable {
		queryMiddlewares := append(globalOptions.middlewares, queryOptions.middlewares...)

		copyBuilder := builder.Url(http.MethodGet, domainPath+"/query")

		if queryOptions.beforeBuilderCallback != nil {
			copyBuilder = queryOptions.beforeBuilderCallback(copyBuilder)
		}

		copyBuilder = copyBuilder.Get(gateway.NewGetRequest(params.ServiceVersionedUrl+domainPath+"/query",
			gateway.GetRequestWithQueryParamsForm(
				gateway.FormQueryParamsWithTenantIDAndUserIDFunc("tenantId", ""))),
			queryOptions.requestResponseCallback)

		if queryOptions.afterBuilderCallback != nil {
			copyBuilder = queryOptions.afterBuilderCallback(copyBuilder)
		}

		copyBuilder.Build(queryMiddlewares...)
	}
}

type ValueObjectCRUDBuilderCallback func(builder *gateway.Builder) *gateway.Builder

type ValueObjectCRUDGlobalOption func(options *ValueObjectCRUDGlobalOptions)
type ValueObjectCRUDCreateOption func(options *ValueObjectCRUDCreateOptions)
type ValueObjectCRUDDeleteOption func(options *ValueObjectCRUDDeleteOptions)
type ValueObjectCRUDQueryOption func(options *ValueObjectCRUDQueryOptions)

type ValueObjectCRUDGlobalOptions struct {
	middlewares []api.Handler
}

type ValueObjectCRUDCreateOptions struct {
	// 关闭创建
	disable bool

	// 创建请求前回调
	beforeBuilderCallback ValueObjectCRUDBuilderCallback

	// 创建请求响应回调
	requestResponseCallback gateway.RequestResponseCallback

	// 创建请求后回调
	afterBuilderCallback ValueObjectCRUDBuilderCallback

	// 创建中间件
	middlewares []api.Handler
}

type ValueObjectCRUDDeleteOptions struct {
	// 关闭删除
	disable bool

	// 删除请求前回调
	beforeBuilderCallback ValueObjectCRUDBuilderCallback

	// 删除请求响应回调
	requestResponseCallback gateway.RequestResponseCallback

	// 删除请求后回调
	afterBuilderCallback ValueObjectCRUDBuilderCallback

	// 删除中间件
	middlewares []api.Handler
}

type ValueObjectCRUDQueryOptions struct {
	// 关闭查询
	disable bool

	// 查询请求前回调
	beforeBuilderCallback ValueObjectCRUDBuilderCallback

	// 查询请求响应回调
	requestResponseCallback gateway.RequestResponseCallback

	// 查询请求后回调
	afterBuilderCallback ValueObjectCRUDBuilderCallback

	// 查询中间件
	middlewares []api.Handler
}

func WithValueObjectCRUDGlobalMiddlewares(middlewares ...api.Handler) ValueObjectCRUDGlobalOption {
	return func(options *ValueObjectCRUDGlobalOptions) {
		options.middlewares = middlewares
	}
}

func WithValueObjectCRUDBeforeCreateBuilderCallback(callbacks ValueObjectCRUDBuilderCallback) ValueObjectCRUDCreateOption {
	return func(options *ValueObjectCRUDCreateOptions) {
		options.beforeBuilderCallback = callbacks
	}
}

func WithValueObjectCRUDCreateCallbacks(callbacks gateway.RequestResponseCallback) ValueObjectCRUDCreateOption {
	return func(options *ValueObjectCRUDCreateOptions) {
		options.requestResponseCallback = callbacks
	}
}

func WithValueObjectCRUDAfterCreateBuilderCallback(callbacks ValueObjectCRUDBuilderCallback) ValueObjectCRUDCreateOption {
	return func(options *ValueObjectCRUDCreateOptions) {
		options.afterBuilderCallback = callbacks
	}
}

func WithValueObjectCRUDCreateMiddlewares(middlewares []api.Handler) ValueObjectCRUDCreateOption {
	return func(options *ValueObjectCRUDCreateOptions) {
		options.middlewares = middlewares
	}
}

func WithValueObjectCRUDDisableDelete() ValueObjectCRUDDeleteOption {
	return func(options *ValueObjectCRUDDeleteOptions) {
		options.disable = true
	}
}

func WithValueObjectCRUDBeforeDeleteBuilderCallback(callbacks ValueObjectCRUDBuilderCallback) ValueObjectCRUDDeleteOption {
	return func(options *ValueObjectCRUDDeleteOptions) {
		options.beforeBuilderCallback = callbacks
	}
}

func WithValueObjectCRUDDeleteCallbacks(callbacks gateway.RequestResponseCallback) ValueObjectCRUDDeleteOption {
	return func(options *ValueObjectCRUDDeleteOptions) {
		options.requestResponseCallback = callbacks
	}
}

func WithValueObjectCRUDAfterDeleteBuilderCallback(callbacks ValueObjectCRUDBuilderCallback) ValueObjectCRUDDeleteOption {
	return func(options *ValueObjectCRUDDeleteOptions) {
		options.afterBuilderCallback = callbacks
	}
}

func WithValueObjectCRUDDeleteMiddlewares(middlewares []api.Handler) ValueObjectCRUDDeleteOption {
	return func(options *ValueObjectCRUDDeleteOptions) {
		options.middlewares = middlewares
	}
}

func WithValueObjectCRUDDisableQuery() ValueObjectCRUDQueryOption {
	return func(options *ValueObjectCRUDQueryOptions) {
		options.disable = true
	}
}

func WithValueObjectCRUDBeforeQueryBuilderCallback(callbacks ValueObjectCRUDBuilderCallback) ValueObjectCRUDQueryOption {
	return func(options *ValueObjectCRUDQueryOptions) {
		options.beforeBuilderCallback = callbacks
	}
}

func WithValueObjectCRUDQueryCallbacks(callbacks gateway.RequestResponseCallback) ValueObjectCRUDQueryOption {
	return func(options *ValueObjectCRUDQueryOptions) {
		options.requestResponseCallback = callbacks
	}
}

func WithValueObjectCRUDAfterQueryBuilderCallback(callbacks ValueObjectCRUDBuilderCallback) ValueObjectCRUDQueryOption {
	return func(options *ValueObjectCRUDQueryOptions) {
		options.afterBuilderCallback = callbacks
	}
}

func WithValueObjectCRUDQueryMiddlewares(middlewares []api.Handler) ValueObjectCRUDQueryOption {
	return func(options *ValueObjectCRUDQueryOptions) {
		options.middlewares = middlewares
	}
}