baize/examples/binding/main.go

package main

import (
	"git.sxidc.com/go-framework/baize"
	"git.sxidc.com/go-framework/baize/api"
	"git.sxidc.com/go-framework/baize/application"
	"git.sxidc.com/go-framework/baize/binding"
	"git.sxidc.com/go-framework/baize/binding/request"
	"git.sxidc.com/go-framework/baize/binding/response"
	"git.sxidc.com/go-framework/baize/domain"
	"git.sxidc.com/go-framework/baize/infrastructure"
	"git.sxidc.com/go-framework/baize/infrastructure/database"
	"git.sxidc.com/go-framework/baize/infrastructure/database/operations"
	"git.sxidc.com/go-framework/baize/infrastructure/database/sql"
	"git.sxidc.com/go-tools/utils/strutils"
	DEATH "github.com/vrecan/death"
	"syscall"
	"time"
)

// curl -X POST -H "Content-Type: application/json" -d '{"name":"test"}' "http://localhost:10100/test/v1/class/create"
// curl -X PUT -H "Content-Type: application/json" -d '{"id":"ab0d4a9acce44ddd91ad4746ecd34392", "name":"test-new"}' "http://localhost:10100/test/v1/class/update"
// curl -X GET "http://localhost:10100/test/v1/class/query?name=test-new&pageNo=0&pageSize=1"
// curl -X GET "http://localhost:10100/test/v1/class/get?id=ab0d4a9acce44ddd91ad4746ecd34392"
// curl -X DELETE "http://localhost:10100/test/v1/class/ab0d4a9acce44ddd91ad4746ecd34392/delete"

type CreateClassJsonBody struct {
	Name string `json:"name" binding:"required" assign:"toField:Name"`
}

type DeleteClassPathParams struct {
	ID string `uri:"id" binding:"required" assign:"toField:ID"`
}

type UpdateClassJsonBody struct {
	ID   string `json:"id" binding:"required" assign:"toField:ID"`
	Name string `json:"name" assign:"toField:Name"`
}

type QueryClassesQueryParams struct {
	Name     string `form:"name" assign:"toField:Name"`
	PageNo   int    `form:"pageNo" assign:"-"`
	PageSize int    `form:"pageSize" assign:"-"`
}

type GetClassQueryParams struct {
	ID string `form:"id" binding:"required" assign:"toField:ID"`
}

type DomainIDField struct {
	ID string `sqlmapping:"column:id"`
}

type Class struct {
	*DomainIDField
	Name            string `sqlmapping:"column:name"`
	CreatedTime     time.Time
	LastUpdatedTime *time.Time
}

type InfoIDField struct {
	ID string `json:"id" sqlresult:"column:id"`
}

type ClassInfo struct {
	*InfoIDField
	Name            string `json:"name" sqlresult:"column:name"`
	CreatedTime     string `sqlresult:"parseTime:'2006-01-02 15:04:05'"`
	LastUpdatedTime string `sqlresult:"parseTime:'2006-01-02 15:04:05'"`
}

const (
	tableName = "test.classes"
)

func main() {
	app := baize.NewApplication(application.Config{
		ApiConfig: application.ApiConfig{
			UrlPrefix: "test",
			Port:      "10100",
		},
		InfrastructureConfig: application.InfrastructureConfig{
			Database: infrastructure.DatabaseConfig{
				Operations: &operations.Config{
					UserName:           "test",
					Password:           "123456",
					Address:            "localhost",
					Port:               "30432",
					Database:           "test",
					MaxConnections:     40,
					MaxIdleConnections: 10,
				},
			},
		},
	})

	defer func() {
		baize.DestroyApplication(app)
	}()

	dbOperations := app.Infrastructure().DBOperations()
	err := dbOperations.AutoMigrate(operations.Table{
		TableName: tableName,
		Columns: []operations.TableColumn{
			{
				Name:       "id",
				Type:       "varchar(32)",
				Comment:    "id",
				PrimaryKey: true,
			},
			{
				Name:    "name",
				Type:    "varchar(128)",
				Comment: "名称",
				NotNull: true,
				Index:   true,
			},
			{
				Name:    "created_time",
				Type:    "timestamp with time zone",
				Comment: "创建时间",
				NotNull: true,
				Index:   true,
			},
			{
				Name:    "last_updated_time",
				Type:    "timestamp with time zone",
				Comment: "更新时间",
				NotNull: true,
				Index:   true,
			},
		},
	})
	if err != nil {
		panic(err)
	}

	app.Api().
		PrefixRouter().
		RegisterVersionedRouter("v1")

	binder := app.Binder("v1")

	// 创建班级
	binding.PostBind(binder, &binding.SimpleBindItem[string]{
		Path:         "/class/create",
		ResponseFunc: response.SendIDResponse[string],
		DTO:          &CreateClassJsonBody{},
		Objects:      []domain.Object{&Class{}},
		ServiceFunc: func(c *api.Context, dto request.DTO, objects []domain.Object, i *infrastructure.Infrastructure) (string, error) {
			e := domain.ToConcrete[*Class](objects[0])
			e.ID = strutils.SimpleUUID()

			err := database.InsertEntity(i.DBOperations(), tableName, e)
			if err != nil {
				return "", err
			}

			return e.ID, nil
		},
	})

	// 删除班级
	binding.DeleteBind(binder, &binding.SimpleBindItem[any]{
		Path:         "/class/:id/delete",
		ResponseFunc: response.SendMsgResponse,
		DTO:          &DeleteClassPathParams{},
		Objects:      []domain.Object{&Class{}},
		ServiceFunc: func(c *api.Context, dto request.DTO, objects []domain.Object, i *infrastructure.Infrastructure) (any, error) {
			e := domain.ToConcrete[*Class](objects[0])

			err := database.DeleteEntity(i.DBOperations(), tableName, e)
			if err != nil {
				return "", err
			}

			return nil, nil
		},
	})

	// 修改班级
	binding.PutBind(binder, &binding.SimpleBindItem[any]{
		Path:         "/class/update",
		ResponseFunc: response.SendMsgResponse,
		DTO:          &UpdateClassJsonBody{},
		Objects:      []domain.Object{&Class{}},
		ServiceFunc: func(c *api.Context, dto request.DTO, objects []domain.Object, i *infrastructure.Infrastructure) (any, error) {
			e := domain.ToConcrete[*Class](objects[0])

			result, err := database.QueryOne(i.DBOperations(), &sql.QueryOneExecuteParams{
				TableName:  tableName,
				Conditions: sql.NewConditions().Equal("id", e.ID),
			})
			if err != nil {
				return nil, err
			}

			existClass := new(Class)
			err = sql.ParseSqlResult(result, existClass)
			if err != nil {
				return nil, err
			}

			newEntity := &Class{
				DomainIDField: &DomainIDField{ID: existClass.ID},
			}

			if strutils.IsStringNotEmpty(e.Name) && e.Name != existClass.Name {
				newEntity.Name = e.Name
			}

			err = database.UpdateEntity(i.DBOperations(), tableName, newEntity)
			if err != nil {
				return "", err
			}

			return nil, nil
		},
	})

	// 查询班级
	binding.GetBind(binder, &binding.SimpleBindItem[response.InfosData[ClassInfo]]{
		Path:         "/class/query",
		ResponseFunc: response.SendInfosResponse[ClassInfo],
		DTO:          &QueryClassesQueryParams{},
		Objects:      []domain.Object{&Class{}},
		ServiceFunc: func(c *api.Context, dto request.DTO, objects []domain.Object, i *infrastructure.Infrastructure) (response.InfosData[ClassInfo], error) {
			e := domain.ToConcrete[*Class](objects[0])
			pageNo := dto.Field[int](dto, "PageNo")
			pageSize := dto.Field[int](dto, "PageSize")

			conditions := sql.NewConditions()

			if strutils.IsStringNotEmpty(e.Name) {
				conditions.Equal("name", e.Name)
			}

			results, totalCount, err := database.Query(i.DBOperations(), &sql.QueryExecuteParams{
				TableName:  tableName,
				Conditions: conditions,
				PageNo:     pageNo,
				PageSize:   pageSize,
			})
			if err != nil {
				return response.InfosData[ClassInfo]{
					Infos: make([]ClassInfo, 0),
				}, nil
			}

			classInfos := make([]ClassInfo, 0)
			err = sql.ParseSqlResult(results, &classInfos)
			if err != nil {
				return response.InfosData[ClassInfo]{
					Infos: make([]ClassInfo, 0),
				}, nil
			}

			return response.InfosData[ClassInfo]{
				Infos:      classInfos,
				TotalCount: totalCount,
				PageNo:     pageNo,
			}, nil
		},
	})

	// 通过ID获取班级
	binding.GetBind(binder, &binding.SimpleBindItem[*ClassInfo]{
		Path:         "/class/get",
		ResponseFunc: response.SendInfoResponse[*ClassInfo],
		DTO:          &GetClassQueryParams{},
		Objects:      []domain.Object{&Class{}},
		ServiceFunc: func(c *api.Context, dto request.DTO, objects []domain.Object, i *infrastructure.Infrastructure) (*ClassInfo, error) {
			e := domain.ToConcrete[*Class](objects[0])

			result, err := database.QueryOne(i.DBOperations(), &sql.QueryOneExecuteParams{
				TableName:  tableName,
				Conditions: sql.NewConditions().Equal("id", e.ID),
			})
			if err != nil {
				return nil, err
			}

			info := new(ClassInfo)
			err = sql.ParseSqlResult(result, info)
			if err != nil {
				return nil, err
			}

			return info, nil
		},
	})

	go func() {
		err := app.Start()
		if err != nil {
			panic(err)
		}
	}()

	defer func() {
		err := app.Finish()
		if err != nil {
			panic(err)
		}
	}()

	death := DEATH.NewDeath(syscall.SIGINT, syscall.SIGTERM)
	_ = death.WaitForDeath()
}