liwei_3d/go_dreamfactory
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

处理错误码附加信息为空情况

Browse Source
This commit is contained in:
liwei1dao 2022-07-01 14:19:56 +08:00
parent 76377b5e28
commit a4185295d8
2 changed files with 11 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
modules/gateway/agent.go
View File

@ -251,6 +251,5 @@ func (this *Agent) messageDistribution(msg *pb.UserMessage) (err error) {
} }
} }
} }
return nil return nil
} }

18
services/comp_gateroute.go
View File

@ -8,6 +8,7 @@ import (
"reflect" "reflect"
"runtime" "runtime"
"sync" "sync"
"time"
"go_dreamfactory/lego/base" "go_dreamfactory/lego/base"
"go_dreamfactory/lego/core" "go_dreamfactory/lego/core"
@ -117,27 +118,30 @@ func (this *SCompGateRoute) ReceiveMsg(ctx context.Context, args *pb.AgentMessag
//序列化用户消息对象 //序列化用户消息对象
var msg proto.Message var msg proto.Message
if msg, err = args.Message.UnmarshalNew(); err != nil { if msg, err = args.Message.UnmarshalNew(); err != nil {
log.Errorf("UserMessage:%s Unmarshal err:%v", method, err) log.Errorf("[Handle Api] UserMessage:%s Unmarshal err:%v", method, err)
return err return err
} }
//执行处理流 //执行处理流
log.Debugf("ReceiveMsg Message:[%s-%s]-%v user[%s-%s]", args.MainType, args.SubType, msg, args.UserSessionId, args.UserId) stime := time.Now()
handlereturn := msghandle.handle.Func.Call([]reflect.Value{msghandle.rcvr, reflect.ValueOf(session), reflect.ValueOf(msg)}) handlereturn := msghandle.handle.Func.Call([]reflect.Value{msghandle.rcvr, reflect.ValueOf(session), reflect.ValueOf(msg)})
log.Debugf("[Handle Api] consumetime:%v method:%s uid:%s msg:%v", time.Since(stime), method, args.UserId, msg)
errcode := pb.ErrorCode(handlereturn[0].Int()) errcode := pb.ErrorCode(handlereturn[0].Int())
errdata := handlereturn[0].Interface().(proto.Message) errdata := handlereturn[0].Interface()
data, _ := anypb.New(errdata)
if errcode != pb.ErrorCode_Success { //处理返货错误码 返回用户错误信息 if errcode != pb.ErrorCode_Success { //处理返货错误码 返回用户错误信息
log.Errorf("HandleUserMsg:%s msg:%v code:%d", method, msg, errcode) log.Errorf("[Handle Api] method:%s uid:%s msg:%v code:%d", method, msg, errcode)
reply.Code = errcode reply.Code = errcode
reply.ErrorMessage = pb.GetErrorCodeMsg(errcode) reply.ErrorMessage = pb.GetErrorCodeMsg(errcode)
reply.ErrorData = data if errdata != nil {
data, _ := anypb.New(errdata.(proto.Message))
reply.ErrorData = data
}
return nil return nil
} else { } else {
reply.Reply = session.Polls() reply.Reply = session.Polls()
} }
} else { //未找到消息处理函数 } else { //未找到消息处理函数
log.Errorf("no found handle %s", method) log.Errorf("[Handle Api] no found handle %s", method)
reply.Code = pb.ErrorCode_ReqParameterError reply.Code = pb.ErrorCode_ReqParameterError
} }
return nil return nil