|
|
@@ -14,7 +14,7 @@ import (
|
|
|
"reflect"
|
|
|
)
|
|
|
|
|
|
-func CreateValueObject(tableName string, dbExecutor database.Executor, callbacks *Callbacks[any]) binding.ServiceFunc[any] {
|
|
|
+func Create(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) {
|
|
|
valueObject, ok := objects[0].(domain.ValueObject)
|
|
|
if !ok {
|
|
|
@@ -44,7 +44,7 @@ func CreateValueObject(tableName string, dbExecutor database.Executor, callbacks
|
|
|
}
|
|
|
}
|
|
|
|
|
|
-func DeleteValueObject(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) {
|
|
|
valueObject, ok := objects[0].(domain.ValueObject)
|
|
|
if !ok {
|
|
|
@@ -77,7 +77,7 @@ func DeleteValueObject(tableName string, dbExecutor database.Executor, callbacks
|
|
|
|
|
|
type ConditionFieldCallback func(conditions *sql.Conditions, fieldName string, columnName string, value any) (hasDeal bool)
|
|
|
|
|
|
-func QueryValueObjects[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 {
|
|
|
@@ -146,7 +146,7 @@ func QueryValueObjects[O any](tableName string, dbExecutor database.Executor, ca
|
|
|
}
|
|
|
}
|
|
|
|
|
|
-func CreateValueObjectTx(tableName string, dbExecutor database.Executor, callbacks *Callbacks[any]) binding.ServiceFunc[any] {
|
|
|
+func CreateTx(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) {
|
|
|
valueObject, ok := objects[0].(domain.ValueObject)
|
|
|
if !ok {
|
|
|
@@ -183,7 +183,7 @@ func CreateValueObjectTx(tableName string, dbExecutor database.Executor, callbac
|
|
|
}
|
|
|
}
|
|
|
|
|
|
-func DeleteValueObjectTx(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) {
|
|
|
valueObject, ok := objects[0].(domain.ValueObject)
|
|
|
if !ok {
|