Skip to content

Commit

Permalink
new
Browse files Browse the repository at this point in the history
  • Loading branch information
xxjwxc committed May 25, 2021
1 parent 853e2d5 commit ff5452d
Show file tree
Hide file tree
Showing 2 changed files with 24 additions and 34 deletions.
57 changes: 24 additions & 33 deletions message/message.go
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,6 @@ package message

import (
"fmt"
"sync"

"github.com/xxjwxc/public/mylog"
"google.golang.org/grpc/codes"
Expand All @@ -20,10 +19,10 @@ type MessageBody struct {
Data interface{} `json:"data,omitempty"`
}

func init() {
_tryRegisteryCode(NormalMessageID)
_tryRegisteryCode(NotFindError)
}
// func init() {
// _tryRegisteryCode(NormalMessageID)
// _tryRegisteryCode(NotFindError)
// }

//GetErrorMsg 获取错误消息 参数(int,string)
func GetErrorMsg(errorCode ...interface{}) (msg MessageBody) {
Expand All @@ -40,7 +39,6 @@ func GetErrorMsg(errorCode ...interface{}) (msg MessageBody) {
msg.Code = int(v)
msg.Error = ErrCode(v).String()
case ErrCode:
_tryRegisteryCode(v)
msg.Code = int(v)
msg.Error = v.String()
case string:
Expand All @@ -60,49 +58,42 @@ func GetSuccessMsg(codes ...ErrCode) (msg MessageBody) {
if len(codes) > 0 {
code = codes[0]
}
_tryRegisteryCode(code)

msg.State = true
msg.Code = int(code)
msg.Error = code.String()
return
}

// GetError 获取错误信息
// GetError 获取错误信息(grpc)
func GetError(code ErrCode) error {
go _tryRegisteryCode(code)
return fmt.Errorf(code.String())
}

// GetGrpcError 获取grpc错误信息
func GetGrpcError(code ErrCode) error {
go _tryRegisteryCode(code)
return status.Errorf(codes.Code(code), code.String())
}

//GetErrorStrMsg 获取错误消息 参数(int,string)
func GetErrorStrMsg(errorCode string) (msg MessageBody) {
// if k, ok := _MessageMap[errorCode]; ok {
// return GetErrorMsg(k)
// }

func GetErrorStrMsg(err error) (msg MessageBody) {
msg.State = false
msg.Code = _tryGetCodeID(errorCode)
msg.Error = errorCode
gerr := status.Convert(err)
if gerr != nil {
msg.Code = int(gerr.Code())
msg.Error = gerr.Message()
} else {
msg.Error = err.Error()
}
return
}

var _mp sync.Map
// var _mp sync.Map

func _tryRegisteryCode(code ErrCode) {
_mp.LoadOrStore(code.String(), int(code))
}
// func _tryRegisteryCode(code ErrCode) {
// _mp.LoadOrStore(code.String(), int(code))
// }

func _tryGetCodeID(codeStr string) int {
v, ok := _mp.Load(codeStr)
if ok {
return v.(int)
}
// func _tryGetCodeID(codeStr string) int {
// v, ok := _mp.Load(codeStr)
// if ok {
// return v.(int)
// }

return -1
}
// return -1
// }
1 change: 0 additions & 1 deletion message/msg_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -16,5 +16,4 @@ func Test_sing(t *testing.T) {
test.State = true
test.Error = ""
fmt.Println(GetSuccessMsg(NormalMessageID))
fmt.Println(GetErrorStrMsg("默认的返回值"))
}

0 comments on commit ff5452d

Please sign in to comment.