2024-11-04 12:10:36 +08:00
|
|
|
package bopx
|
|
|
|
|
|
|
|
|
|
import (
|
2025-10-12 18:41:05 +08:00
|
|
|
"context"
|
2024-11-04 12:10:36 +08:00
|
|
|
"crypto/md5"
|
|
|
|
|
"fmt"
|
|
|
|
|
"sort"
|
|
|
|
|
"strings"
|
|
|
|
|
|
|
|
|
|
"code.yun.ink/pkg/convx"
|
2025-10-12 18:41:05 +08:00
|
|
|
"github.com/yuninks/loggerx"
|
2024-11-04 12:10:36 +08:00
|
|
|
)
|
|
|
|
|
|
2025-10-12 18:41:05 +08:00
|
|
|
// 签名规则
|
|
|
|
|
// 1.除掉不参与签名的用户参数
|
|
|
|
|
// 1.所有参数的key根据字典排序
|
|
|
|
|
// 2.根据key=val&key2=val2的格式组装字符串
|
|
|
|
|
// 3.后面拼接用户签名key `&key=xxxx`得道新字符串
|
|
|
|
|
// 4.把新字符串用md5加密并转大写的道签名的值
|
|
|
|
|
|
2024-11-04 12:10:36 +08:00
|
|
|
// 缺点
|
|
|
|
|
// 1.值必须是字符串,数组/对象这些不允许,或者需要通过一定规则转成字符串
|
|
|
|
|
|
|
|
|
|
type apix struct {
|
2025-10-12 18:41:05 +08:00
|
|
|
logger loggerx.LoggerInterface
|
|
|
|
|
ignoreKeys []string
|
2024-11-04 12:10:36 +08:00
|
|
|
}
|
|
|
|
|
|
2025-10-12 18:41:05 +08:00
|
|
|
func NewApi(opts ...Option) *apix {
|
|
|
|
|
options := newOptions(opts...)
|
2024-11-04 12:10:36 +08:00
|
|
|
return &apix{
|
2025-10-12 18:41:05 +08:00
|
|
|
logger: options.logger,
|
|
|
|
|
ignoreKeys: options.ignoreKeys,
|
2024-11-04 12:10:36 +08:00
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
|
2025-10-12 18:41:05 +08:00
|
|
|
// 计算签名值
|
|
|
|
|
func (l *apix) GetSign(ctx context.Context, signKey string, params map[string]any) (sign string, err error) {
|
|
|
|
|
if signKey == "" {
|
|
|
|
|
return "", ErrorSignKeyIsEmpty
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
for _, val := range l.ignoreKeys {
|
2024-11-04 12:10:36 +08:00
|
|
|
delete(params, val)
|
|
|
|
|
}
|
|
|
|
|
|
2025-10-12 20:45:07 +08:00
|
|
|
if len(params) == 0 {
|
|
|
|
|
return "", ErrorSignParamIsEmpty
|
|
|
|
|
}
|
|
|
|
|
|
2024-11-04 12:10:36 +08:00
|
|
|
// 排序
|
|
|
|
|
keys := make([]string, len(params))
|
|
|
|
|
i := 0
|
|
|
|
|
for k := range params {
|
|
|
|
|
keys[i] = k
|
|
|
|
|
i++
|
|
|
|
|
}
|
|
|
|
|
sort.Strings(keys)
|
|
|
|
|
var str string
|
|
|
|
|
for k, v := range keys {
|
|
|
|
|
if k > 0 {
|
|
|
|
|
str = str + "&"
|
|
|
|
|
}
|
2025-10-12 18:41:05 +08:00
|
|
|
val := convx.ToString(params[v])
|
2024-11-04 12:10:36 +08:00
|
|
|
str = str + v + "=" + val
|
|
|
|
|
}
|
2025-10-12 18:41:05 +08:00
|
|
|
str = str + "&key=" + signKey
|
2024-11-04 12:10:36 +08:00
|
|
|
data := []byte(str)
|
|
|
|
|
has := md5.Sum(data)
|
|
|
|
|
md5str1 := fmt.Sprintf("%x", has) // []byte转16进制
|
|
|
|
|
sign = strings.ToUpper(md5str1)
|
2025-10-12 18:41:05 +08:00
|
|
|
l.logger.Infof(ctx, "bopx sign Str:%s sign:%s", str, sign)
|
2024-11-04 12:10:36 +08:00
|
|
|
return sign, nil
|
|
|
|
|
}
|
|
|
|
|
|
2025-10-12 18:41:05 +08:00
|
|
|
func (l *apix) Verify(ctx context.Context, signKey string, params map[string]interface{}) error {
|
2024-11-04 12:10:36 +08:00
|
|
|
|
|
|
|
|
sign, ok := params["sign"]
|
|
|
|
|
if !ok {
|
|
|
|
|
return ErrorSignParamNotExist
|
|
|
|
|
}
|
|
|
|
|
sitn_str, ok := sign.(string)
|
|
|
|
|
if !ok {
|
|
|
|
|
return ErrorSignMustBeString
|
|
|
|
|
}
|
2025-10-12 18:41:05 +08:00
|
|
|
g_sign, err := l.GetSign(ctx, signKey, params)
|
2024-11-04 12:10:36 +08:00
|
|
|
if err != nil {
|
|
|
|
|
return err
|
|
|
|
|
}
|
|
|
|
|
if sitn_str != g_sign {
|
|
|
|
|
return ErrorSignFail
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
return nil
|
|
|
|
|
}
|