作者 yangfu

fix: 微调

... ... @@ -23,7 +23,7 @@ func (this *AccessController) CreateAccess() {
this.Resp(msg)
}()
if err := this.JsonUnmarshal(&request); err != nil {
msg = protocol.BadRequestParam(1)
msg = protocol.NewResponseMessage(2, "")
return
}
header := this.GetRequestHeader(this.Ctx)
... ... @@ -31,7 +31,7 @@ func (this *AccessController) CreateAccess() {
if err != nil {
log.Error(err)
}
msg = protocol.NewReturnResponse(data, err)
msg = protocol.NewResponseMessageData(data, err)
}
// UpdateAccess
... ... @@ -46,7 +46,7 @@ func (this *AccessController) UpdateAccess() {
this.Resp(msg)
}()
if err := this.JsonUnmarshal(&request); err != nil {
msg = protocol.BadRequestParam(1)
msg = protocol.NewResponseMessage(2, "")
return
}
header := this.GetRequestHeader(this.Ctx)
... ... @@ -54,7 +54,7 @@ func (this *AccessController) UpdateAccess() {
if err != nil {
log.Error(err)
}
msg = protocol.NewReturnResponse(data, err)
msg = protocol.NewResponseMessageData(data, err)
}
// GetAccess
... ... @@ -69,7 +69,7 @@ func (this *AccessController) GetAccess() {
this.Resp(msg)
}()
if err := this.JsonUnmarshal(&request); err != nil {
msg = protocol.BadRequestParam(1)
msg = protocol.NewResponseMessage(2, "")
return
}
header := this.GetRequestHeader(this.Ctx)
... ... @@ -77,7 +77,7 @@ func (this *AccessController) GetAccess() {
if err != nil {
log.Error(err)
}
msg = protocol.NewReturnResponse(data, err)
msg = protocol.NewResponseMessageData(data, err)
}
// DeleteAccess
... ... @@ -92,7 +92,7 @@ func (this *AccessController) DeleteAccess() {
this.Resp(msg)
}()
if err := this.JsonUnmarshal(&request); err != nil {
msg = protocol.BadRequestParam(1)
msg = protocol.NewResponseMessage(2, "")
return
}
header := this.GetRequestHeader(this.Ctx)
... ... @@ -100,7 +100,7 @@ func (this *AccessController) DeleteAccess() {
if err != nil {
log.Error(err)
}
msg = protocol.NewReturnResponse(data, err)
msg = protocol.NewResponseMessageData(data, err)
}
// ListAccess
... ... @@ -115,7 +115,7 @@ func (this *AccessController) ListAccess() {
this.Resp(msg)
}()
if err := this.JsonUnmarshal(&request); err != nil {
msg = protocol.BadRequestParam(1)
msg = protocol.NewResponseMessage(2, "")
return
}
header := this.GetRequestHeader(this.Ctx)
... ... @@ -123,5 +123,5 @@ func (this *AccessController) ListAccess() {
if err != nil {
log.Error(err)
}
msg = protocol.NewReturnResponse(data, err)
msg = protocol.NewResponseMessageData(data, err)
}
... ...
... ... @@ -23,7 +23,7 @@ func (this *AuthController) Login() {
this.Resp(msg)
}()
if err := this.JsonUnmarshal(&request); err != nil {
msg = protocol.BadRequestParam(1)
msg = protocol.NewResponseMessage(2, "")
return
}
header := this.GetRequestHeader(this.Ctx)
... ... @@ -31,7 +31,7 @@ func (this *AuthController) Login() {
if err != nil {
log.Error(err)
}
msg = protocol.NewReturnResponse(data, err)
msg = protocol.NewResponseMessageData(data, err)
}
// Logout
... ... @@ -46,7 +46,7 @@ func (this *AuthController) Logout() {
this.Resp(msg)
}()
if err := this.JsonUnmarshal(&request); err != nil {
msg = protocol.BadRequestParam(1)
msg = protocol.NewResponseMessage(2, "")
return
}
header := this.GetRequestHeader(this.Ctx)
... ... @@ -54,7 +54,7 @@ func (this *AuthController) Logout() {
if err != nil {
log.Error(err)
}
msg = protocol.NewReturnResponse(data, err)
msg = protocol.NewResponseMessageData(data, err)
}
// Profile
... ... @@ -69,7 +69,7 @@ func (this *AuthController) Profile() {
this.Resp(msg)
}()
if err := this.JsonUnmarshal(&request); err != nil {
msg = protocol.BadRequestParam(1)
msg = protocol.NewResponseMessage(2, "")
return
}
header := this.GetRequestHeader(this.Ctx)
... ... @@ -77,7 +77,7 @@ func (this *AuthController) Profile() {
if err != nil {
log.Error(err)
}
msg = protocol.NewReturnResponse(data, err)
msg = protocol.NewResponseMessageData(data, err)
}
// CaptchaInit
... ... @@ -97,7 +97,7 @@ func (this *AuthController) CaptchaInit() {
if err != nil {
log.Error(err)
}
msg = protocol.NewReturnResponse(data, err)
msg = protocol.NewResponseMessageData(data, err)
}
// ChangePassword
... ... @@ -112,7 +112,7 @@ func (this *AuthController) ChangePassword() {
this.Resp(msg)
}()
if err := this.JsonUnmarshal(&request); err != nil {
msg = protocol.BadRequestParam(1)
msg = protocol.NewResponseMessage(2, "")
return
}
header := this.GetRequestHeader(this.Ctx)
... ... @@ -120,5 +120,5 @@ func (this *AuthController) ChangePassword() {
if err != nil {
log.Error(err)
}
msg = protocol.NewReturnResponse(data, err)
msg = protocol.NewResponseMessageData(data, err)
}
... ...
package controllers
import (
"bytes"
"encoding/json"
"github.com/astaxie/beego"
"github.com/astaxie/beego/context"
"github.com/astaxie/beego/validation"
"gitlab.fjmaimaimai.com/mmm-go/godevp/pkg/protocol"
"strconv"
)
... ... @@ -18,7 +18,19 @@ func (controller BaseController) JsonUnmarshal(v interface{}) error {
if len(body) == 0 {
body = []byte("{}")
}
return json.Unmarshal(body, v)
newDecoder := json.NewDecoder(bytes.NewReader(body))
newDecoder.UseNumber()
err := newDecoder.Decode(v)
return err
}
func (controller *BaseController) Resp(msg *protocol.ResponseMessage) {
if msg.Errno != 0 {
msg.Errno = -1
}
controller.Data["json"] = msg
controller.Ctx.Input.SetData("outputData", msg)
controller.ServeJSON()
}
func (controller BaseController) GetLimitInfo() (offset int, limit int) {
... ... @@ -27,39 +39,8 @@ func (controller BaseController) GetLimitInfo() (offset int, limit int) {
return
}
//Valid valid struct
func (controller *BaseController) Valid(obj interface{}) (result bool, msg *protocol.ResponseMessage) {
/*校验*/
var err error
valid := validation.Validation{}
result, err = valid.Valid(obj)
if err != nil {
}
if !result {
msg = protocol.BadRequestParam(2)
return
}
return
}
func (this *BaseController) Resp(msg *protocol.ResponseMessage) {
this.Data["json"] = msg
this.Ctx.Input.SetData("outputData", msg)
this.ServeJSON()
}
func (this *BaseController) RespH5(msg *protocol.ResponseMessage) {
if msg.Errno != 0 {
msg.Errno = -1
}
this.Data["json"] = msg
this.Ctx.Input.SetData("outputData", msg)
this.ServeJSON()
}
//获取请求头信息
func (this *BaseController) GetRequestHeader(ctx *context.Context) *protocol.RequestHeader {
func (controller *BaseController) GetRequestHeader(ctx *context.Context) *protocol.RequestHeader {
h := &protocol.RequestHeader{}
h.UserId, _ = strconv.ParseInt(ctx.Input.Header("x-mmm-id"), 10, 64)
return h
... ...
... ... @@ -23,7 +23,7 @@ func (this *MenuController) CreateMenu() {
this.Resp(msg)
}()
if err := this.JsonUnmarshal(&request); err != nil {
msg = protocol.BadRequestParam(1)
msg = protocol.NewResponseMessage(2, "")
return
}
header := this.GetRequestHeader(this.Ctx)
... ... @@ -31,7 +31,7 @@ func (this *MenuController) CreateMenu() {
if err != nil {
log.Error(err)
}
msg = protocol.NewReturnResponse(data, err)
msg = protocol.NewResponseMessageData(data, err)
}
// UpdateMenu
... ... @@ -46,7 +46,7 @@ func (this *MenuController) UpdateMenu() {
this.Resp(msg)
}()
if err := this.JsonUnmarshal(&request); err != nil {
msg = protocol.BadRequestParam(1)
msg = protocol.NewResponseMessage(2, "")
return
}
header := this.GetRequestHeader(this.Ctx)
... ... @@ -54,7 +54,7 @@ func (this *MenuController) UpdateMenu() {
if err != nil {
log.Error(err)
}
msg = protocol.NewReturnResponse(data, err)
msg = protocol.NewResponseMessageData(data, err)
}
// GetMenu
... ... @@ -69,7 +69,7 @@ func (this *MenuController) GetMenu() {
this.Resp(msg)
}()
if err := this.JsonUnmarshal(&request); err != nil {
msg = protocol.BadRequestParam(1)
msg = protocol.NewResponseMessage(2, "")
return
}
header := this.GetRequestHeader(this.Ctx)
... ... @@ -77,7 +77,7 @@ func (this *MenuController) GetMenu() {
if err != nil {
log.Error(err)
}
msg = protocol.NewReturnResponse(data, err)
msg = protocol.NewResponseMessageData(data, err)
}
// DeleteMenu
... ... @@ -92,7 +92,7 @@ func (this *MenuController) DeleteMenu() {
this.Resp(msg)
}()
if err := this.JsonUnmarshal(&request); err != nil {
msg = protocol.BadRequestParam(1)
msg = protocol.NewResponseMessage(2, "")
return
}
header := this.GetRequestHeader(this.Ctx)
... ... @@ -100,7 +100,7 @@ func (this *MenuController) DeleteMenu() {
if err != nil {
log.Error(err)
}
msg = protocol.NewReturnResponse(data, err)
msg = protocol.NewResponseMessageData(data, err)
}
// ListMenu
... ... @@ -115,7 +115,7 @@ func (this *MenuController) ListMenu() {
this.Resp(msg)
}()
if err := this.JsonUnmarshal(&request); err != nil {
msg = protocol.BadRequestParam(1)
msg = protocol.NewResponseMessage(2, "")
return
}
header := this.GetRequestHeader(this.Ctx)
... ... @@ -123,5 +123,5 @@ func (this *MenuController) ListMenu() {
if err != nil {
log.Error(err)
}
msg = protocol.NewReturnResponse(data, err)
msg = protocol.NewResponseMessageData(data, err)
}
... ...
... ... @@ -23,7 +23,7 @@ func (this *ProjectModuleController) CreateProjectModule() {
this.Resp(msg)
}()
if err := this.JsonUnmarshal(&request); err != nil {
msg = protocol.BadRequestParam(1)
msg = protocol.NewResponseMessage(2, "")
return
}
header := this.GetRequestHeader(this.Ctx)
... ... @@ -31,7 +31,7 @@ func (this *ProjectModuleController) CreateProjectModule() {
if err != nil {
log.Error(err)
}
msg = protocol.NewReturnResponse(data, err)
msg = protocol.NewResponseMessageData(data, err)
}
// UpdateProjectModule
... ... @@ -46,7 +46,7 @@ func (this *ProjectModuleController) UpdateProjectModule() {
this.Resp(msg)
}()
if err := this.JsonUnmarshal(&request); err != nil {
msg = protocol.BadRequestParam(1)
msg = protocol.NewResponseMessage(2, "")
return
}
header := this.GetRequestHeader(this.Ctx)
... ... @@ -54,7 +54,7 @@ func (this *ProjectModuleController) UpdateProjectModule() {
if err != nil {
log.Error(err)
}
msg = protocol.NewReturnResponse(data, err)
msg = protocol.NewResponseMessageData(data, err)
}
// GetProjectModule
... ... @@ -74,7 +74,7 @@ func (this *ProjectModuleController) GetProjectModule() {
if err != nil {
log.Error(err)
}
msg = protocol.NewReturnResponse(data, err)
msg = protocol.NewResponseMessageData(data, err)
}
// DeleteProjectModule
... ... @@ -89,7 +89,7 @@ func (this *ProjectModuleController) DeleteProjectModule() {
this.Resp(msg)
}()
if err := this.JsonUnmarshal(&request); err != nil {
msg = protocol.BadRequestParam(1)
msg = protocol.NewResponseMessage(2, "")
return
}
header := this.GetRequestHeader(this.Ctx)
... ... @@ -97,7 +97,7 @@ func (this *ProjectModuleController) DeleteProjectModule() {
if err != nil {
log.Error(err)
}
msg = protocol.NewReturnResponse(data, err)
msg = protocol.NewResponseMessageData(data, err)
}
// ListProjectModule
... ... @@ -112,7 +112,7 @@ func (this *ProjectModuleController) ListProjectModule() {
this.Resp(msg)
}()
if err := this.JsonUnmarshal(&request); err != nil {
msg = protocol.BadRequestParam(1)
msg = protocol.NewResponseMessage(2, "")
return
}
header := this.GetRequestHeader(this.Ctx)
... ... @@ -120,5 +120,5 @@ func (this *ProjectModuleController) ListProjectModule() {
if err != nil {
log.Error(err)
}
msg = protocol.NewReturnResponse(data, err)
msg = protocol.NewResponseMessageData(data, err)
}
... ...
... ... @@ -23,7 +23,7 @@ func (this *ProjectModuleFilesController) CreateProjectModuleFiles() {
this.Resp(msg)
}()
if err := this.JsonUnmarshal(&request); err != nil {
msg = protocol.BadRequestParam(1)
msg = protocol.NewResponseMessage(2, "")
return
}
header := this.GetRequestHeader(this.Ctx)
... ... @@ -31,7 +31,7 @@ func (this *ProjectModuleFilesController) CreateProjectModuleFiles() {
if err != nil {
log.Error(err)
}
msg = protocol.NewReturnResponse(data, err)
msg = protocol.NewResponseMessageData(data, err)
}
// UpdateProjectModuleFiles
... ... @@ -46,7 +46,7 @@ func (this *ProjectModuleFilesController) UpdateProjectModuleFiles() {
this.Resp(msg)
}()
if err := this.JsonUnmarshal(&request); err != nil {
msg = protocol.BadRequestParam(1)
msg = protocol.NewResponseMessage(2, "")
return
}
header := this.GetRequestHeader(this.Ctx)
... ... @@ -54,7 +54,7 @@ func (this *ProjectModuleFilesController) UpdateProjectModuleFiles() {
if err != nil {
log.Error(err)
}
msg = protocol.NewReturnResponse(data, err)
msg = protocol.NewResponseMessageData(data, err)
}
// GetProjectModuleFiles
... ... @@ -69,7 +69,7 @@ func (this *ProjectModuleFilesController) GetProjectModuleFiles() {
this.Resp(msg)
}()
if err := this.JsonUnmarshal(&request); err != nil {
msg = protocol.BadRequestParam(1)
msg = protocol.NewResponseMessage(2, "")
return
}
header := this.GetRequestHeader(this.Ctx)
... ... @@ -77,7 +77,7 @@ func (this *ProjectModuleFilesController) GetProjectModuleFiles() {
if err != nil {
log.Error(err)
}
msg = protocol.NewReturnResponse(data, err)
msg = protocol.NewResponseMessageData(data, err)
}
// DeleteProjectModuleFiles
... ... @@ -92,7 +92,7 @@ func (this *ProjectModuleFilesController) DeleteProjectModuleFiles() {
this.Resp(msg)
}()
if err := this.JsonUnmarshal(&request); err != nil {
msg = protocol.BadRequestParam(1)
msg = protocol.NewResponseMessage(2, "")
return
}
header := this.GetRequestHeader(this.Ctx)
... ... @@ -100,7 +100,7 @@ func (this *ProjectModuleFilesController) DeleteProjectModuleFiles() {
if err != nil {
log.Error(err)
}
msg = protocol.NewReturnResponse(data, err)
msg = protocol.NewResponseMessageData(data, err)
}
// ListProjectModuleFiles
... ... @@ -121,5 +121,5 @@ func (this *ProjectModuleFilesController) ListProjectModuleFiles() {
if err != nil {
log.Error(err)
}
msg = protocol.NewReturnResponse(data, err)
msg = protocol.NewResponseMessageData(data, err)
}
... ...
... ... @@ -23,7 +23,7 @@ func (this *ProjectModuleVersionController) CreateProjectModuleVersion() {
this.Resp(msg)
}()
if err := this.JsonUnmarshal(&request); err != nil {
msg = protocol.BadRequestParam(1)
msg = protocol.NewResponseMessage(2, "")
return
}
header := this.GetRequestHeader(this.Ctx)
... ... @@ -31,7 +31,7 @@ func (this *ProjectModuleVersionController) CreateProjectModuleVersion() {
if err != nil {
log.Error(err)
}
msg = protocol.NewReturnResponse(data, err)
msg = protocol.NewResponseMessageData(data, err)
}
// UpdateProjectModuleVersion
... ... @@ -46,7 +46,7 @@ func (this *ProjectModuleVersionController) UpdateProjectModuleVersion() {
this.Resp(msg)
}()
if err := this.JsonUnmarshal(&request); err != nil {
msg = protocol.BadRequestParam(1)
msg = protocol.NewResponseMessage(2, "")
return
}
request.ProjectModuleVersionId, _ = this.GetInt64(":projectModuleVersionId")
... ... @@ -55,7 +55,7 @@ func (this *ProjectModuleVersionController) UpdateProjectModuleVersion() {
if err != nil {
log.Error(err)
}
msg = protocol.NewReturnResponse(data, err)
msg = protocol.NewResponseMessageData(data, err)
}
// GetProjectModuleVersion
... ... @@ -75,7 +75,7 @@ func (this *ProjectModuleVersionController) GetProjectModuleVersion() {
if err != nil {
log.Error(err)
}
msg = protocol.NewReturnResponse(data, err)
msg = protocol.NewResponseMessageData(data, err)
}
// DeleteProjectModuleVersion
... ... @@ -95,7 +95,7 @@ func (this *ProjectModuleVersionController) DeleteProjectModuleVersion() {
if err != nil {
log.Error(err)
}
msg = protocol.NewReturnResponse(data, err)
msg = protocol.NewResponseMessageData(data, err)
}
// ListProjectModuleVersion
... ... @@ -115,5 +115,5 @@ func (this *ProjectModuleVersionController) ListProjectModuleVersion() {
if err != nil {
log.Error(err)
}
msg = protocol.NewReturnResponse(data, err)
msg = protocol.NewResponseMessageData(data, err)
}
... ...
... ... @@ -27,7 +27,7 @@ func (this *RbacController) Access() {
if err != nil {
log.Error(err)
}
msg = protocol.NewReturnResponse(data, err)
msg = protocol.NewResponseMessageData(data, err)
}
// RoleAccess
... ... @@ -47,7 +47,7 @@ func (this *RbacController) RoleAccess() {
if err != nil {
log.Error(err)
}
msg = protocol.NewReturnResponse(data, err)
msg = protocol.NewResponseMessageData(data, err)
}
// SetRoleAccess
... ... @@ -62,7 +62,7 @@ func (this *RbacController) SetRoleAccess() {
this.Resp(msg)
}()
if err := this.JsonUnmarshal(&request); err != nil {
msg = protocol.BadRequestParam(1)
msg = protocol.NewResponseMessage(2, "")
return
}
header := this.GetRequestHeader(this.Ctx)
... ... @@ -70,5 +70,5 @@ func (this *RbacController) SetRoleAccess() {
if err != nil {
log.Error(err)
}
msg = protocol.NewReturnResponse(data, err)
msg = protocol.NewResponseMessageData(data, err)
}
... ...
... ... @@ -23,7 +23,7 @@ func (this *RoleController) CreateRole() {
this.Resp(msg)
}()
if err := this.JsonUnmarshal(&request); err != nil {
msg = protocol.BadRequestParam(1)
msg = protocol.NewResponseMessage(2, "")
return
}
header := this.GetRequestHeader(this.Ctx)
... ... @@ -31,7 +31,7 @@ func (this *RoleController) CreateRole() {
if err != nil {
log.Error(err)
}
msg = protocol.NewReturnResponse(data, err)
msg = protocol.NewResponseMessageData(data, err)
}
// UpdateRole
... ... @@ -46,7 +46,7 @@ func (this *RoleController) UpdateRole() {
this.Resp(msg)
}()
if err := this.JsonUnmarshal(&request); err != nil {
msg = protocol.BadRequestParam(1)
msg = protocol.NewResponseMessage(2, "")
return
}
request.Id, _ = this.GetInt64(":roleId")
... ... @@ -55,7 +55,7 @@ func (this *RoleController) UpdateRole() {
if err != nil {
log.Error(err)
}
msg = protocol.NewReturnResponse(data, err)
msg = protocol.NewResponseMessageData(data, err)
}
// GetRole
... ... @@ -70,7 +70,7 @@ func (this *RoleController) GetRole() {
this.Resp(msg)
}()
if err := this.JsonUnmarshal(&request); err != nil {
msg = protocol.BadRequestParam(1)
msg = protocol.NewResponseMessage(2, "")
return
}
request.Id, _ = this.GetInt64(":roleId")
... ... @@ -79,7 +79,7 @@ func (this *RoleController) GetRole() {
if err != nil {
log.Error(err)
}
msg = protocol.NewReturnResponse(data, err)
msg = protocol.NewResponseMessageData(data, err)
}
// DeleteRole
... ... @@ -99,7 +99,7 @@ func (this *RoleController) DeleteRole() {
if err != nil {
log.Error(err)
}
msg = protocol.NewReturnResponse(data, err)
msg = protocol.NewResponseMessageData(data, err)
}
// ListRole
... ... @@ -114,7 +114,7 @@ func (this *RoleController) ListRole() {
this.Resp(msg)
}()
if err := this.JsonUnmarshal(&request); err != nil {
msg = protocol.BadRequestParam(1)
msg = protocol.NewResponseMessage(2, "")
return
}
header := this.GetRequestHeader(this.Ctx)
... ... @@ -122,5 +122,5 @@ func (this *RoleController) ListRole() {
if err != nil {
log.Error(err)
}
msg = protocol.NewReturnResponse(data, err)
msg = protocol.NewResponseMessageData(data, err)
}
... ...
... ... @@ -13,110 +13,110 @@ type UserController struct {
// CreateUser
// CreateUser execute command create User
func (this *UserController) CreateUser() {
func (controller *UserController) CreateUser() {
var (
msg *protocol.ResponseMessage
svr = user.NewUserService(nil)
request *protocolx.CreateUserRequest
)
defer func() {
this.Resp(msg)
controller.Resp(msg)
}()
if err := this.JsonUnmarshal(&request); err != nil {
msg = protocol.BadRequestParam(1)
if err := controller.JsonUnmarshal(&request); err != nil {
msg = protocol.NewResponseMessage(2, "")
return
}
header := this.GetRequestHeader(this.Ctx)
header := controller.GetRequestHeader(controller.Ctx)
data, err := svr.CreateUser(header, request)
if err != nil {
log.Error(err)
}
msg = protocol.NewReturnResponse(data, err)
msg = protocol.NewResponseMessageData(data, err)
}
// UpdateUser
// UpdateUser execute command update User
func (this *UserController) UpdateUser() {
func (controller *UserController) UpdateUser() {
var (
msg *protocol.ResponseMessage
svr = user.NewUserService(nil)
request *protocolx.UpdateUserRequest
)
defer func() {
this.Resp(msg)
controller.Resp(msg)
}()
if err := this.JsonUnmarshal(&request); err != nil {
msg = protocol.BadRequestParam(1)
if err := controller.JsonUnmarshal(&request); err != nil {
msg = protocol.NewResponseMessage(2, "")
return
}
request.Id, _ = this.GetInt64(":userId")
header := this.GetRequestHeader(this.Ctx)
request.Id, _ = controller.GetInt64(":userId")
header := controller.GetRequestHeader(controller.Ctx)
data, err := svr.UpdateUser(header, request)
if err != nil {
log.Error(err)
}
msg = protocol.NewReturnResponse(data, err)
msg = protocol.NewResponseMessageData(data, err)
}
// GetUser
// GetUser execute query get User
func (this *UserController) GetUser() {
func (controller *UserController) GetUser() {
var (
msg *protocol.ResponseMessage
svr = user.NewUserService(nil)
request = &protocolx.GetUserRequest{}
)
defer func() {
this.Resp(msg)
controller.Resp(msg)
}()
request.Id, _ = this.GetInt64(":userId")
header := this.GetRequestHeader(this.Ctx)
request.Id, _ = controller.GetInt64(":userId")
header := controller.GetRequestHeader(controller.Ctx)
data, err := svr.GetUser(header, request)
if err != nil {
log.Error(err)
}
msg = protocol.NewReturnResponse(data, err)
msg = protocol.NewResponseMessageData(data, err)
}
// DeleteUser
// DeleteUser execute command delete User
func (this *UserController) DeleteUser() {
func (controller *UserController) DeleteUser() {
var (
msg *protocol.ResponseMessage
svr = user.NewUserService(nil)
request = &protocolx.DeleteUserRequest{}
)
defer func() {
this.Resp(msg)
controller.Resp(msg)
}()
request.Id, _ = this.GetInt64(":userId")
header := this.GetRequestHeader(this.Ctx)
request.Id, _ = controller.GetInt64(":userId")
header := controller.GetRequestHeader(controller.Ctx)
data, err := svr.DeleteUser(header, request)
if err != nil {
log.Error(err)
}
msg = protocol.NewReturnResponse(data, err)
msg = protocol.NewResponseMessageData(data, err)
}
// ListUser
// ListUser execute query list User
func (this *UserController) ListUser() {
func (controller *UserController) ListUser() {
var (
msg *protocol.ResponseMessage
svr = user.NewUserService(nil)
request *protocolx.ListUserRequest
)
defer func() {
this.Resp(msg)
controller.Resp(msg)
}()
if err := this.JsonUnmarshal(&request); err != nil {
msg = protocol.BadRequestParam(1)
if err := controller.JsonUnmarshal(&request); err != nil {
msg = protocol.NewResponseMessage(2, "")
return
}
header := this.GetRequestHeader(this.Ctx)
header := controller.GetRequestHeader(controller.Ctx)
data, err := svr.ListUser(header, request)
if err != nil {
log.Error(err)
}
msg = protocol.NewReturnResponse(data, err)
msg = protocol.NewResponseMessageData(data, err)
}
... ...
... ... @@ -36,18 +36,6 @@ var (
_ error = new(ErrWithMessage)
)
//NewErrWithMessage 构建错误返回
//code:用于匹配统一消息错误编码 eRR:填充嵌套错误
func NewErrWithMessage(code int, eRR ...error) *ErrWithMessage {
r := &ErrWithMessage{
ErrorCode: SearchErr(code),
}
if len(eRR) > 0 {
r.Err = eRR[0]
}
return r
}
//Error 实现接口error 中的方法
//将ErrorCode转为json数据,建议用于日志记录
func (e ErrWithMessage) Error() string {
... ... @@ -71,15 +59,15 @@ func (e ErrWithMessage) ParseToMessage() *ResponseMessage {
func SearchErr(code int) ErrorCode {
return errmessge.Search(code)
}
func NewReturnResponse(data interface{}, eRR error) *ResponseMessage {
func NewResponseMessageData(data interface{}, err error) *ResponseMessage {
var msg *ResponseMessage
if eRR == nil {
if err == nil {
msg = NewMesage(0)
msg.Data = data
return msg
}
//log.Error("服务错误:" + eRR.Error())
if x, ok := eRR.(CustomErrParse); ok {
if x, ok := err.(CustomErrParse); ok {
msg = x.ParseToMessage()
msg.Data = data
return msg
... ... @@ -98,17 +86,6 @@ func NewResponseMessage(code int, err string) *ResponseMessage {
}
}
func BadRequestParam(code int) *ResponseMessage {
return NewMesage(code)
}
func NewSuccessWithMessage(msg string) *ErrWithMessage {
return &ErrWithMessage{
Err: nil,
ErrorCode: ErrorCode{0, msg},
}
}
func NewCustomMessage(code int, msg string) *ErrWithMessage {
return &ErrWithMessage{
Err: nil,
... ... @@ -138,7 +115,6 @@ var errmessge ErrorMap = map[int]string{
0: "成功",
1: "系统异常",
2: "参数错误",
113: "签名验证失败",
}
type RequestHeader struct {
... ...