update

gin/middleware/auth.go

@@ -2,6 +2,8 @@
 package middleware
 
 import (
+	"strings"
+
 	"github.com/gin-gonic/gin"
 	"gitlab.wanzhuangkj.com/tush/xpkg/errcode"
 	"gitlab.wanzhuangkj.com/tush/xpkg/gin/ctxUtils"
@@ -122,14 +124,7 @@ func AuthCustom(verify VerifyCustomFn, opts ...JwtOption) gin.HandlerFunc {
 
 	return func(c *gin.Context) {
 		authorization := c.GetHeader(HeaderAuthorizationKey)
-		if len(authorization) < 150 {
-			logger.Warn("authorization is illegal")
-			responseUnauthorized(c, o.isSwitchHTTPCode)
-			c.Abort()
-			return
-		}
-
-		token := authorization[7:] // remove Bearer prefix
+		token := strings.TrimPrefix(authorization, "Bearer ")
 		claims, err := jwt.ParseCustomToken(token)
 		if err != nil {
 			logger.Warn("ParseToken error", logger.Err(err))

third/alioss/oss.go

@@ -4,6 +4,7 @@ import (
 	"io"
 	"mime/multipart"
 
+	"gitlab.wanzhuangkj.com/tush/xpkg/logger"
 	"gitlab.wanzhuangkj.com/tush/xpkg/xerrors/xerror"
 
 	"github.com/aliyun/aliyun-oss-go-sdk/oss"
@@ -24,14 +25,12 @@ type AliOssConfig struct {
 }
 
 func NewClient(cfg *AliOssConfig) (bucket *oss.Bucket, err error) {
-	client, err := oss.New(cfg.Endpoint,
-		cfg.AccessKeyId,
-		cfg.AccessKeySecret,
-		oss.AuthVersion(oss.AuthV4),
-		oss.Region(cfg.Region))
+	// client, err := oss.New(cfg.Endpoint, cfg.AccessKeyId, cfg.AccessKeySecret, oss.AuthVersion(oss.AuthV4), oss.Region(cfg.Region))
+	client, err := oss.New(cfg.Endpoint, cfg.AccessKeyId, cfg.AccessKeySecret)
 	if err != nil {
 		return nil, xerror.New(err.Error())
 	}
+	logger.Info("bucker name" + cfg.BucketName)
 	bucket, err = client.Bucket(cfg.BucketName)
 	return
 }

utils/xtime/xtime.go

@@ -3,6 +3,7 @@ package xtime
 import (
 	"database/sql/driver"
 	"fmt"
+	"reflect"
 	"regexp"
 	"strconv"
 	"time"
@@ -19,12 +20,31 @@ const (
 // 定义time.Time的别名
 type DateTime time.Time
 
+func (ct *DateTime) UnmarshalParam(src string) error {
+	field, _ := reflect.TypeOf(ct).Elem().FieldByName("DateTime")
+	format := field.Tag.Get("format")
+	if format == "" {
+		format = time.DateTime
+	}
+	t, err := time.Parse(format, src)
+	if err != nil {
+		return fmt.Errorf("time format should be %s", format)
+	}
+	*ct = DateTime(t)
+	return nil
+}
+
 // 自定义json序列化
 func (x DateTime) MarshalJSON() ([]byte, error) {
 	if x.IsZero() {
 		return []byte(`""`), nil
 	}
-	var jsonTimeStr = fmt.Sprintf(`"%s"`, time.Time(x).Format("2006-01-02 15:04:05"))
+	field, _ := reflect.TypeOf(x).Elem().FieldByName("DateTime")
+	format := field.Tag.Get("format")
+	if format == "" {
+		format = "2006-01-02 15:04:05"
+	}
+	var jsonTimeStr = fmt.Sprintf(`"%s"`, time.Time(x).Format(format))
 	return []byte(jsonTimeStr), nil
 }
 
@@ -34,7 +54,12 @@ func (x *DateTime) UnmarshalJSON(data []byte) error {
 		*x = DateTime{}
 		return nil
 	}
-	t, err := time.Parse(`"2006-01-02 15:04:05"`, string(data))
+	field, _ := reflect.TypeOf(x).Elem().FieldByName("DateTime")
+	format := field.Tag.Get("format")
+	if format == "" {
+		format = "2006-01-02 15:04:05"
+	}
+	t, err := time.Parse(format, string(data))
 	if err != nil {
 		return err
 	}