Merge branch 'master' of gitlab.fusenpack.com:backend/proto

This commit is contained in:
menghaiwen@fusen.cn 2024-03-04 17:49:50 +08:00
commit 6ba91ea0f8

View File

@ -5,8 +5,10 @@ import (
"context" "context"
"sync" "sync"
"fmt" "fmt"
"runtime/debug"
"fusen-basic/env" "fusen-basic/env"
"fusen-basic/utils/log"
"{{.ProjectName}}/gen/go/service" "{{.ProjectName}}/gen/go/service"
"{{.ProjectName}}/server/config" "{{.ProjectName}}/server/config"
@ -53,6 +55,7 @@ func (lgrpc *{{.StructName}}Grpc) {{.MethodName}}({{range $index, $param := .Par
if _recoverErr := recover(); _recoverErr != nil { if _recoverErr := recover(); _recoverErr != nil {
_resp = nil _resp = nil
_err = fmt.Errorf("%v", _recoverErr) _err = fmt.Errorf("%v", _recoverErr)
log.Printf("recovered from panic: %v\n%s", _err, string(debug.Stack()))
} }
}() }()
return New{{.StructName}}(ctx).{{.MethodName}}Logic({{range $index, $param := .ParamsName}}{{if $index}}, {{end}}{{$param}}{{end}}) return New{{.StructName}}(ctx).{{.MethodName}}Logic({{range $index, $param := .ParamsName}}{{if $index}}, {{end}}{{$param}}{{end}})
@ -64,6 +67,7 @@ func (lgrpc *{{.StructName}}Grpc) {{.MethodName}}(stream {{range $index, $param
defer func() { defer func() {
if _recoverErr := recover(); _recoverErr != nil { if _recoverErr := recover(); _recoverErr != nil {
_err = fmt.Errorf("%v", _recoverErr) _err = fmt.Errorf("%v", _recoverErr)
log.Printf("recovered from panic: %v\n%s", _err, string(debug.Stack()))
} }
}() }()
return New{{.StructName}}(stream.Context()).{{.MethodName}}Logic(stream) return New{{.StructName}}(stream.Context()).{{.MethodName}}Logic(stream)