|
|
package controllers
|
|
|
|
|
|
import (
|
|
|
"github.com/astaxie/beego/context"
|
|
|
"github.com/linmadan/egglib-go/web/beego/utils"
|
|
|
"github.com/tiptok/godevp/pkg/application/users/command"
|
|
|
"github.com/tiptok/godevp/pkg/application/users/query"
|
...
|
...
|
@@ -8,53 +9,58 @@ import ( |
|
|
)
|
|
|
|
|
|
type UsersController struct {
|
|
|
utils.Controller
|
|
|
//utils.Controller
|
|
|
}
|
|
|
|
|
|
func (controller *UsersController) CreateUsers() {
|
|
|
func (controller *UsersController) CreateUsers(ctx *context.Context) {
|
|
|
contextController := utils.NewController(ctx)
|
|
|
usersService := service.NewUsersService(nil)
|
|
|
createUsersCommand := &command.CreateUsersCommand{}
|
|
|
controller.Unmarshal(createUsersCommand)
|
|
|
contextController.Unmarshal(createUsersCommand)
|
|
|
data, err := usersService.CreateUsers(createUsersCommand)
|
|
|
controller.Response(data, err)
|
|
|
contextController.Response(data, err)
|
|
|
}
|
|
|
|
|
|
func (controller *UsersController) UpdateUsers() {
|
|
|
func (controller *UsersController) UpdateUsers(ctx *context.Context) {
|
|
|
contextController := utils.NewController(ctx)
|
|
|
usersService := service.NewUsersService(nil)
|
|
|
updateUsersCommand := &command.UpdateUsersCommand{}
|
|
|
controller.Unmarshal(updateUsersCommand)
|
|
|
Id, _ := controller.GetInt64(":Id")
|
|
|
contextController.Unmarshal(updateUsersCommand)
|
|
|
Id, _ := contextController.GetInt64(":Id")
|
|
|
updateUsersCommand.UsersId = Id
|
|
|
data, err := usersService.UpdateUsers(updateUsersCommand)
|
|
|
controller.Response(data, err)
|
|
|
contextController.Response(data, err)
|
|
|
}
|
|
|
|
|
|
func (controller *UsersController) GetUsers() {
|
|
|
usersService := service.NewUsersService(map[string]interface{}{"context": controller.Ctx.Request.Context()})
|
|
|
func (controller *UsersController) GetUsers(ctx *context.Context) {
|
|
|
contextController := utils.NewController(ctx)
|
|
|
usersService := service.NewUsersService(map[string]interface{}{"context": ctx.Request.Context()})
|
|
|
getUsersQuery := &query.GetUsersQuery{}
|
|
|
Id, _ := controller.GetInt64(":Id")
|
|
|
Id, _ := contextController.GetInt64(":Id")
|
|
|
getUsersQuery.UsersId = Id
|
|
|
data, err := usersService.GetUsers(getUsersQuery)
|
|
|
controller.Response(data, err)
|
|
|
contextController.Response(data, err)
|
|
|
}
|
|
|
|
|
|
func (controller *UsersController) RemoveUsers() {
|
|
|
func (controller *UsersController) RemoveUsers(ctx *context.Context) {
|
|
|
contextController := utils.NewController(ctx)
|
|
|
usersService := service.NewUsersService(nil)
|
|
|
removeUsersCommand := &command.RemoveUsersCommand{}
|
|
|
controller.Unmarshal(removeUsersCommand)
|
|
|
Id, _ := controller.GetInt64(":Id")
|
|
|
contextController.Unmarshal(removeUsersCommand)
|
|
|
Id, _ := contextController.GetInt64(":Id")
|
|
|
removeUsersCommand.UsersId = Id
|
|
|
data, err := usersService.RemoveUsers(removeUsersCommand)
|
|
|
controller.Response(data, err)
|
|
|
contextController.Response(data, err)
|
|
|
}
|
|
|
|
|
|
func (controller *UsersController) ListUsers() {
|
|
|
func (controller *UsersController) ListUsers(ctx *context.Context) {
|
|
|
contextController := utils.NewController(ctx)
|
|
|
usersService := service.NewUsersService(nil)
|
|
|
listUsersQuery := &query.ListUsersQuery{}
|
|
|
offset, _ := controller.GetInt("offset")
|
|
|
offset, _ := contextController.GetInt("offset")
|
|
|
listUsersQuery.Offset = offset
|
|
|
limit, _ := controller.GetInt("limit")
|
|
|
limit, _ := contextController.GetInt("limit")
|
|
|
listUsersQuery.Limit = limit
|
|
|
data, err := usersService.ListUsers(listUsersQuery)
|
|
|
controller.Response(data, err)
|
|
|
contextController.Response(data, err)
|
|
|
} |
...
|
...
|
|