|
- package zhios_order_relate_logx
-
- import (
- "errors"
- "fmt"
- "strconv"
-
- "go.uber.org/zap"
- )
-
- type LogX struct {
- logger *zap.Logger
- atomLevel *zap.AtomicLevel
- }
-
- type Field = zap.Field
- type FieldMap map[string]interface{}
-
- // 判断其他类型--start
- func getFields(msg string, format bool, args ...interface{}) (string, []Field) {
- var str []interface{}
- var fields []zap.Field
- if len(args) > 0 {
- for _, v := range args {
- if f, ok := v.(Field); ok {
- fields = append(fields, f)
- } else if f, ok := v.(FieldMap); ok {
- fields = append(fields, formatFieldMap(f)...)
- } else {
- str = append(str, AnyToString(v))
- }
- }
- if format {
- return fmt.Sprintf(msg, str...), fields
- }
- str = append([]interface{}{msg}, str...)
- return fmt.Sprintln(str...), fields
- }
- return msg, []Field{}
- }
-
- func (l *LogX) Debug(s interface{}, args ...interface{}) error {
- es, e := checkErr(s)
- if es != "" {
- msg, field := getFields(es, false, args...)
- l.logger.Debug(msg, field...)
- }
- return e
- }
- func (l *LogX) Info(s interface{}, args ...interface{}) error {
- es, e := checkErr(s)
- if es != "" {
- msg, field := getFields(es, false, args...)
- l.logger.Info(msg, field...)
- }
- return e
- }
- func (l *LogX) Warn(s interface{}, args ...interface{}) error {
- es, e := checkErr(s)
- if es != "" {
- msg, field := getFields(es, false, args...)
- l.logger.Warn(msg, field...)
- }
- return e
- }
- func (l *LogX) Error(s interface{}, args ...interface{}) error {
- es, e := checkErr(s)
- if es != "" {
- msg, field := getFields(es, false, args...)
- l.logger.Error(msg, field...)
- }
- return e
- }
- func (l *LogX) DPanic(s interface{}, args ...interface{}) error {
- es, e := checkErr(s)
- if es != "" {
- msg, field := getFields(es, false, args...)
- l.logger.DPanic(msg, field...)
- }
- return e
- }
- func (l *LogX) Panic(s interface{}, args ...interface{}) error {
- es, e := checkErr(s)
- if es != "" {
- msg, field := getFields(es, false, args...)
- l.logger.Panic(msg, field...)
- }
- return e
- }
- func (l *LogX) Fatal(s interface{}, args ...interface{}) error {
- es, e := checkErr(s)
- if es != "" {
- msg, field := getFields(es, false, args...)
- l.logger.Fatal(msg, field...)
- }
- return e
- }
-
- func checkErr(s interface{}) (string, error) {
- switch e := s.(type) {
- case error:
- return e.Error(), e
- case string:
- return e, errors.New(e)
- case []byte:
- return string(e), nil
- default:
- return "", nil
- }
- }
-
- func (l *LogX) LogError(err error) error {
- return l.Error(err.Error())
- }
-
- func (l *LogX) Debugf(msg string, args ...interface{}) error {
- s, f := getFields(msg, true, args...)
- l.logger.Debug(s, f...)
- return errors.New(s)
- }
-
- func (l *LogX) Infof(msg string, args ...interface{}) error {
- s, f := getFields(msg, true, args...)
- l.logger.Info(s, f...)
- return errors.New(s)
- }
-
- func (l *LogX) Warnf(msg string, args ...interface{}) error {
- s, f := getFields(msg, true, args...)
- l.logger.Warn(s, f...)
- return errors.New(s)
- }
-
- func (l *LogX) Errorf(msg string, args ...interface{}) error {
- s, f := getFields(msg, true, args...)
- l.logger.Error(s, f...)
- return errors.New(s)
- }
-
- func (l *LogX) DPanicf(msg string, args ...interface{}) error {
- s, f := getFields(msg, true, args...)
- l.logger.DPanic(s, f...)
- return errors.New(s)
- }
-
- func (l *LogX) Panicf(msg string, args ...interface{}) error {
- s, f := getFields(msg, true, args...)
- l.logger.Panic(s, f...)
- return errors.New(s)
- }
-
- func (l *LogX) Fatalf(msg string, args ...interface{}) error {
- s, f := getFields(msg, true, args...)
- l.logger.Fatal(s, f...)
- return errors.New(s)
- }
-
- func AnyToString(raw interface{}) string {
- switch i := raw.(type) {
- case []byte:
- return string(i)
- case int:
- return strconv.FormatInt(int64(i), 10)
- case int64:
- return strconv.FormatInt(i, 10)
- case float32:
- return strconv.FormatFloat(float64(i), 'f', 2, 64)
- case float64:
- return strconv.FormatFloat(i, 'f', 2, 64)
- case uint:
- return strconv.FormatInt(int64(i), 10)
- case uint8:
- return strconv.FormatInt(int64(i), 10)
- case uint16:
- return strconv.FormatInt(int64(i), 10)
- case uint32:
- return strconv.FormatInt(int64(i), 10)
- case uint64:
- return strconv.FormatInt(int64(i), 10)
- case int8:
- return strconv.FormatInt(int64(i), 10)
- case int16:
- return strconv.FormatInt(int64(i), 10)
- case int32:
- return strconv.FormatInt(int64(i), 10)
- case string:
- return i
- case error:
- return i.Error()
- }
- return fmt.Sprintf("%#v", raw)
- }
|