log

Author: myxy99

xcode/status.go

@@ -9,6 +9,7 @@ import (
 	"errors"
 	"fmt"
 	"github.com/coder2z/g-saber/xjson"
+	"github.com/coder2z/g-saber/xlog"
 	"github.com/golang/protobuf/proto"
 	"github.com/golang/protobuf/ptypes/any"
 	spb "google.golang.org/genproto/googleapis/rpc/status"
@@ -47,7 +48,7 @@ func (s *spbStatus) IsOk() bool {
 // GetMessage ...
 func (s *spbStatus) GetMessage(exts ...interface{}) string {
 	if len(exts)%2 != 0 {
-		panic("parameter must be odd")
+		xlog.Panic("parameter must be odd")
 	}
 
 	var buf bytes.Buffer
@@ -107,11 +108,11 @@ func (s *spbStatus) Proto() *spb.Status {
 
 // MustWithDetails ...
 func (s *spbStatus) MustWithDetails(details ...interface{}) *spbStatus {
-	status, err := s.WithDetails(details...)
+	withDetails, err := s.WithDetails(details...)
 	if err != nil {
-		panic(err)
+		xlog.Panic("MustWithDetails", xlog.FieldErr(err))
 	}
-	return status
+	return withDetails
 }
 
 // WithDetails returns a new status with the provided details messages appended to the status.

xcode/xcode.go

@@ -6,6 +6,7 @@ package xcode
 
 import (
 	"github.com/coder2z/g-saber/xjson"
+	"github.com/coder2z/g-saber/xlog"
 	"net/http"
 	"sync"
 
@@ -86,15 +87,15 @@ func BusinessCode(code uint32) (spb *spbStatus) {
 
 func SystemCodeAdd(code uint32, message string) *spbStatus {
 	if code > CodeBreakUp {
-		panic("customize code must less than 9999")
+		xlog.Panic("customize code must less than 9999")
 	}
 
 	return add(SystemType, aid*10000+code, message)
 }
 
 func BusinessCodeAdd(code uint32, message string) *spbStatus {
 	if code < CodeBreakUp {
-		panic("customize code must less than 9999")
+		xlog.Panic("customize code must less than 9999")
 	}
 	return add(BusinessType, code, message)
 }

xinvoker/email/invoker.go

@@ -6,8 +6,8 @@
 package xemail
 
 import (
-	"fmt"
 	"github.com/coder2z/component/xinvoker"
+	"github.com/coder2z/g-saber/xlog"
 	"sync"
 )
 
@@ -22,7 +22,8 @@ func Invoker(key string) *Email {
 	if val, ok := email.instances.Load(key); ok {
 		return val.(*Email)
 	}
-	panic(fmt.Sprintf("no email(%s) invoker found", key))
+	xlog.Panicf("no email(%s) invoker found", key)
+	return nil
 }
 
 type emailInvoker struct {

xinvoker/gorm/gorm.go

@@ -2,6 +2,7 @@ package xgorm
 
 import (
 	"github.com/coder2z/g-saber/xcfg"
+	"github.com/coder2z/g-saber/xlog"
 	"gorm.io/gorm"
 	"gorm.io/gorm/schema"
 )
@@ -15,14 +16,14 @@ func (i *dbInvoker) newDatabaseClient(o *options) (db *gorm.DB) {
 		},
 	})
 	if err != nil {
-		panic(err)
+		xlog.Panic("NewDatabaseClient OpenDB", xlog.FieldErr(err))
 	}
 	if o.Debug {
 		db = db.Debug()
 	}
 	d, err := db.DB()
 	if err != nil {
-		panic(err)
+		xlog.Panic("NewDatabaseClient db.DB()", xlog.FieldErr(err))
 	}
 	d.SetMaxOpenConns(o.MaxOpenConnections)
 	d.SetMaxIdleConns(o.MaxIdleConn)

xinvoker/gorm/invoker.go

@@ -6,8 +6,8 @@
 package xgorm
 
 import (
-	"fmt"
 	"github.com/coder2z/component/xinvoker"
+	"github.com/coder2z/g-saber/xlog"
 	"gorm.io/gorm"
 	"sync"
 )
@@ -23,7 +23,8 @@ func Invoker(key string) *gorm.DB {
 	if val, ok := db.instances.Load(key); ok {
 		return val.(*gorm.DB)
 	}
-	panic(fmt.Sprintf("no db(%s) invoker found", key))
+	xlog.Panicf("no db(%s) invoker found", key)
+	return nil
 }
 
 type dbInvoker struct {

xinvoker/mongo/invoker.go

@@ -6,8 +6,8 @@
 package xmongo
 
 import (
-	"fmt"
 	"github.com/coder2z/component/xinvoker"
+	"github.com/coder2z/g-saber/xlog"
 	"sync"
 )
 
@@ -22,7 +22,8 @@ func Invoker(key string) MongoImp {
 	if val, ok := mongoI.instances.Load(key); ok {
 		return val.(MongoImp)
 	}
-	panic(fmt.Sprintf("no xlog(%s) invoker found", key))
+	xlog.Panicf("no mongo(%s) invoker found", key)
+	return nil
 }
 
 type mongoInvoker struct {

xinvoker/mongo/mongo.go

@@ -7,6 +7,7 @@ package xmongo
 
 import (
 	"github.com/coder2z/g-saber/xcfg"
+	"github.com/coder2z/g-saber/xlog"
 	"github.com/globalsign/mgo"
 )
 
@@ -78,7 +79,7 @@ func (i *mongoInvoker) new(o *options) MongoImp {
 	}
 	resp, err := mgo.DialWithInfo(dialInfo)
 	if err != nil {
-		panic(err)
+		xlog.Panic("new mongo", xlog.FieldErr(err))
 	}
 	mgo.SetDebug(o.Debug)
 	// Optional. Switch the session to a monotonic behavior.

xinvoker/oss/invoker.go

@@ -6,9 +6,9 @@
 package xoss
 
 import (
-	"fmt"
 	"github.com/coder2z/component/xinvoker"
 	"github.com/coder2z/component/xinvoker/oss/standard"
+	"github.com/coder2z/g-saber/xlog"
 	"sync"
 )
 
@@ -23,7 +23,8 @@ func Invoker(key string) standard.Oss {
 	if val, ok := ossI.instances.Load(key); ok {
 		return val.(standard.Oss)
 	}
-	panic(fmt.Sprintf("no oss(%s) invoker found", key))
+	xlog.Panicf("no oss(%s) invoker found", key)
+	return nil
 }
 
 type ossInvoker struct {

xinvoker/oss/oss.go

@@ -7,10 +7,11 @@ package xoss
 
 import (
 	"errors"
-	"github.com/coder2z/g-saber/xcfg"
 	"github.com/coder2z/component/xinvoker/oss/alioss"
 	"github.com/coder2z/component/xinvoker/oss/file"
 	"github.com/coder2z/component/xinvoker/oss/standard"
+	"github.com/coder2z/g-saber/xcfg"
+	"github.com/coder2z/g-saber/xlog"
 )
 
 func (i *ossInvoker) loadConfig() map[string]*options {
@@ -35,7 +36,7 @@ func (i *ossInvoker) new(o *options) (client standard.Oss) {
 		err = errors.New("oss mode not exist")
 	}
 	if err != nil {
-		panic(err)
+		xlog.Panic("new oss", xlog.FieldErr(err))
 	}
 	return
 }

xinvoker/redis/invoker.go

@@ -6,9 +6,9 @@
 package xredis
 
 import (
-	"fmt"
-	"github.com/go-redis/redis/v8"
 	"github.com/coder2z/component/xinvoker"
+	"github.com/coder2z/g-saber/xlog"
+	"github.com/go-redis/redis/v8"
 	"sync"
 )
 
@@ -23,7 +23,8 @@ func Invoker(key string) *redis.Client {
 	if val, ok := redisI.instances.Load(key); ok {
 		return val.(*redis.Client)
 	}
-	panic(fmt.Sprintf("no redis(%s) invoker found", key))
+	xlog.Panicf("no redis(%s) invoker found", key)
+	return nil
 }
 
 type redisInvoker struct {