94 lines
2.9 KiB
Go
94 lines
2.9 KiB
Go
package haiyuapi
|
||
|
||
import (
|
||
"errors"
|
||
"fmt"
|
||
)
|
||
|
||
// 海宇API平台返回码
|
||
const (
|
||
CodeSuccess = 0 // 业务成功
|
||
CodeQueryEmpty = 1000 // 查询为空
|
||
CodeSystem = 1001 // 接口异常
|
||
CodeDecryptFail = 1002 // 参数解密失败
|
||
CodeRequestParam = 1003 // 基础参数校验不正确
|
||
CodeInvalidIP = 1004 // 未经授权的IP
|
||
CodeMissingAccessID = 1005 // 缺少Access-Id
|
||
CodeInvalidAccessID = 1006 // 未经授权的AccessId
|
||
CodeInsufficientBalance = 1007 // 账户余额不足，无法请求
|
||
CodeProductNotSubscribed = 1008 // 未开通此产品
|
||
CodeBusiness = 2001 // 业务失败
|
||
)
|
||
|
||
var (
|
||
ErrDatasource = errors.New("数据源异常")
|
||
ErrSystem = errors.New("系统异常")
|
||
ErrNotFound = errors.New("查询为空")
|
||
)
|
||
|
||
// haiyuapiAPIError 海宇API平台错误
|
||
type haiyuapiAPIError struct {
|
||
Code int
|
||
Message string
|
||
}
|
||
|
||
func (e *haiyuapiAPIError) Error() string {
|
||
return fmt.Sprintf("海宇API返回错误，code: %d，message: %s", e.Code, e.Message)
|
||
}
|
||
|
||
// NewHaiyuapiAPIError 创建平台错误
|
||
func NewHaiyuapiAPIError(code int, message string) *haiyuapiAPIError {
|
||
if message == "" {
|
||
if desc := GetPlatformCodeDesc(code); desc != "" {
|
||
message = desc
|
||
} else {
|
||
message = "海宇API返回未知错误"
|
||
}
|
||
}
|
||
return &haiyuapiAPIError{Code: code, Message: message}
|
||
}
|
||
|
||
// platformCodeDesc 平台 code -> 官方 message
|
||
var platformCodeDesc = map[int]string{
|
||
CodeSuccess: "业务成功",
|
||
CodeQueryEmpty: "查询为空",
|
||
CodeSystem: "接口异常",
|
||
CodeDecryptFail: "参数解密失败",
|
||
CodeRequestParam: "基础参数校验不正确",
|
||
CodeInvalidIP: "未经授权的IP",
|
||
CodeMissingAccessID: "缺少Access-Id",
|
||
CodeInvalidAccessID: "未经授权的AccessId",
|
||
CodeInsufficientBalance: "账户余额不足，无法请求",
|
||
CodeProductNotSubscribed: "未开通此产品",
|
||
CodeBusiness: "业务失败",
|
||
}
|
||
|
||
// GetPlatformCodeDesc 根据平台 code 获取描述
|
||
func GetPlatformCodeDesc(code int) string {
|
||
if desc, ok := platformCodeDesc[code]; ok {
|
||
return desc
|
||
}
|
||
return ""
|
||
}
|
||
|
||
// GetErrByCode 将海宇API code 映射为内部哨兵错误，供处理器 errors.Is 判断
|
||
//
|
||
// 1000 -> ErrNotFound（查询为空，可按产品约定当成功处理）
|
||
// 1001, 1002, 1003 -> ErrSystem（接口/解密/参数校验异常）
|
||
// 1004~1008, 2001 -> ErrDatasource（鉴权、余额、产品、业务类上游错误）
|
||
func GetErrByCode(code int) error {
|
||
switch code {
|
||
case CodeSuccess:
|
||
return nil
|
||
case CodeQueryEmpty:
|
||
return ErrNotFound
|
||
case CodeSystem, CodeDecryptFail, CodeRequestParam:
|
||
return ErrSystem
|
||
case CodeInvalidIP, CodeMissingAccessID, CodeInvalidAccessID,
|
||
CodeInsufficientBalance, CodeProductNotSubscribed, CodeBusiness:
|
||
return ErrDatasource
|
||
default:
|
||
return ErrDatasource
|
||
}
|
||
}
|