|
|
@@ -1,4 +1,4 @@
|
|
|
-package entity_crud
|
|
|
+package entity
|
|
|
|
|
|
import (
|
|
|
"git.sxidc.com/go-framework/baize/api"
|
|
|
@@ -14,7 +14,7 @@ import (
|
|
|
"reflect"
|
|
|
)
|
|
|
|
|
|
-func CreateEntity(tableName string, dbExecutor database.Executor, callbacks *Callbacks[string]) binding.ServiceFunc[string] {
|
|
|
+func Create(tableName string, dbExecutor database.Executor, callbacks *Callbacks[string]) binding.ServiceFunc[string] {
|
|
|
return func(c *api.Context, dto request.DTO, objects []domain.Object, i *infrastructure.Infrastructure) (string, error) {
|
|
|
e, ok := objects[0].(domain.Entity)
|
|
|
if !ok {
|
|
|
@@ -54,7 +54,7 @@ func CreateEntity(tableName string, dbExecutor database.Executor, callbacks *Cal
|
|
|
}
|
|
|
}
|
|
|
|
|
|
-func DeleteEntity(tableName string, dbExecutor database.Executor, callbacks *Callbacks[any]) binding.ServiceFunc[any] {
|
|
|
+func Delete(tableName string, dbExecutor database.Executor, callbacks *Callbacks[any]) binding.ServiceFunc[any] {
|
|
|
return func(c *api.Context, dto request.DTO, objects []domain.Object, i *infrastructure.Infrastructure) (any, error) {
|
|
|
e, ok := objects[0].(domain.Entity)
|
|
|
if !ok {
|
|
|
@@ -85,7 +85,7 @@ func DeleteEntity(tableName string, dbExecutor database.Executor, callbacks *Cal
|
|
|
}
|
|
|
}
|
|
|
|
|
|
-func UpdateEntity(tableName string, dbExecutor database.Executor, callbacks *Callbacks[any]) binding.ServiceFunc[any] {
|
|
|
+func Update(tableName string, dbExecutor database.Executor, callbacks *Callbacks[any]) binding.ServiceFunc[any] {
|
|
|
return func(c *api.Context, dto request.DTO, objects []domain.Object, i *infrastructure.Infrastructure) (any, error) {
|
|
|
e, ok := objects[0].(domain.Entity)
|
|
|
if !ok {
|
|
|
@@ -131,7 +131,7 @@ func UpdateEntity(tableName string, dbExecutor database.Executor, callbacks *Cal
|
|
|
|
|
|
type ConditionFieldCallback func(conditions *sql.Conditions, fieldName string, columnName string, value any) (hasDeal bool)
|
|
|
|
|
|
-func QueryEntities[O any](tableName string, dbExecutor database.Executor, callbacks *Callbacks[response.InfosData[O]], conditionFieldCallback ConditionFieldCallback) binding.ServiceFunc[response.InfosData[O]] {
|
|
|
+func Query[O any](tableName string, dbExecutor database.Executor, callbacks *Callbacks[response.InfosData[O]], conditionFieldCallback ConditionFieldCallback) binding.ServiceFunc[response.InfosData[O]] {
|
|
|
return func(c *api.Context, dto request.DTO, objects []domain.Object, i *infrastructure.Infrastructure) (response.InfosData[O], error) {
|
|
|
queryDTO, ok := dto.(request.Query)
|
|
|
if !ok {
|
|
|
@@ -200,7 +200,7 @@ func QueryEntities[O any](tableName string, dbExecutor database.Executor, callba
|
|
|
}
|
|
|
}
|
|
|
|
|
|
-func GetEntityByID[O any](tableName string, dbExecutor database.Executor, callbacks *Callbacks[O]) binding.ServiceFunc[O] {
|
|
|
+func GetByID[O any](tableName string, dbExecutor database.Executor, callbacks *Callbacks[O]) binding.ServiceFunc[O] {
|
|
|
return func(c *api.Context, dto request.DTO, objects []domain.Object, i *infrastructure.Infrastructure) (O, error) {
|
|
|
var outputZero O
|
|
|
outputZeroValue := reflect.Zero(reflect.TypeOf(outputZero))
|
|
|
@@ -253,7 +253,7 @@ func GetEntityByID[O any](tableName string, dbExecutor database.Executor, callba
|
|
|
}
|
|
|
}
|
|
|
|
|
|
-func CreateEntityTx(tableName string, dbExecutor database.Executor, callbacks *Callbacks[string]) binding.ServiceFunc[string] {
|
|
|
+func CreateTx(tableName string, dbExecutor database.Executor, callbacks *Callbacks[string]) binding.ServiceFunc[string] {
|
|
|
return func(c *api.Context, dto request.DTO, objects []domain.Object, i *infrastructure.Infrastructure) (string, error) {
|
|
|
e, ok := objects[0].(domain.Entity)
|
|
|
if !ok {
|
|
|
@@ -300,7 +300,7 @@ func CreateEntityTx(tableName string, dbExecutor database.Executor, callbacks *C
|
|
|
}
|
|
|
}
|
|
|
|
|
|
-func DeleteEntityTx(tableName string, dbExecutor database.Executor, callbacks *Callbacks[any]) binding.ServiceFunc[any] {
|
|
|
+func DeleteTx(tableName string, dbExecutor database.Executor, callbacks *Callbacks[any]) binding.ServiceFunc[any] {
|
|
|
return func(c *api.Context, dto request.DTO, objects []domain.Object, i *infrastructure.Infrastructure) (any, error) {
|
|
|
e, ok := objects[0].(domain.Entity)
|
|
|
if !ok {
|
|
|
@@ -338,7 +338,7 @@ func DeleteEntityTx(tableName string, dbExecutor database.Executor, callbacks *C
|
|
|
}
|
|
|
}
|
|
|
|
|
|
-func UpdateEntityTx(tableName string, dbExecutor database.Executor, callbacks *Callbacks[any]) binding.ServiceFunc[any] {
|
|
|
+func UpdateTx(tableName string, dbExecutor database.Executor, callbacks *Callbacks[any]) binding.ServiceFunc[any] {
|
|
|
return func(c *api.Context, dto request.DTO, objects []domain.Object, i *infrastructure.Infrastructure) (any, error) {
|
|
|
e, ok := objects[0].(domain.Entity)
|
|
|
if !ok {
|