李光春
3 years ago
parent
130895c22d
commit
efaaea0d40
@ -0,0 +1,21 @@
|
||||
MIT License
|
||||
|
||||
Copyright (c) 2021 李光春
|
||||
|
||||
Permission is hereby granted, free of charge, to any person obtaining a copy
|
||||
of this software and associated documentation files (the "Software"), to deal
|
||||
in the Software without restriction, including without limitation the rights
|
||||
to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
|
||||
copies of the Software, and to permit persons to whom the Software is
|
||||
furnished to do so, subject to the following conditions:
|
||||
|
||||
The above copyright notice and this permission notice shall be included in all
|
||||
copies or substantial portions of the Software.
|
||||
|
||||
THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
||||
IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
|
||||
FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
|
||||
AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
|
||||
LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
|
||||
OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
|
||||
SOFTWARE.
|
||||
@ -0,0 +1,8 @@
|
||||
package service
|
||||
|
||||
import "errors"
|
||||
|
||||
var (
|
||||
ErrTypeIsNil = errors.New("类型为Nil")
|
||||
ErrTypeUnknown = errors.New("未处理到的数据类型")
|
||||
)
|
||||
@ -0,0 +1,13 @@
|
||||
package uuid_test
|
||||
|
||||
import (
|
||||
"GoLibrary/helper/uuid"
|
||||
"fmt"
|
||||
"testing"
|
||||
)
|
||||
|
||||
func TestName(t *testing.T) {
|
||||
genUUID := uuid.GenUUID()
|
||||
fmt.Println("Hello World")
|
||||
fmt.Println(genUUID)
|
||||
}
|
||||
@ -0,0 +1,183 @@
|
||||
package jdk
|
||||
|
||||
import (
|
||||
"GoLibrary/excepyion/service"
|
||||
"bytes"
|
||||
"crypto/md5"
|
||||
"encoding/hex"
|
||||
"encoding/json"
|
||||
"errors"
|
||||
"fmt"
|
||||
"github.com/bitly/go-simplejson"
|
||||
"github.com/nilorg/sdk/convert"
|
||||
"io"
|
||||
"io/ioutil"
|
||||
"net/http"
|
||||
"net/url"
|
||||
"sort"
|
||||
"strings"
|
||||
"time"
|
||||
)
|
||||
|
||||
var (
|
||||
// AppKey 应用Key
|
||||
AppKey string
|
||||
// SecretKey 秘密
|
||||
SecretKey string
|
||||
// Router 环境请求地址
|
||||
Router = "https://api.jd.com/routerjson"
|
||||
// Timeout ...
|
||||
Timeout time.Duration
|
||||
)
|
||||
|
||||
// Parameter 参数
|
||||
type Parameter map[string]interface{}
|
||||
|
||||
// copyParameter 复制参数
|
||||
func copyParameter(srcParams Parameter) Parameter {
|
||||
newParams := make(Parameter)
|
||||
for key, value := range srcParams {
|
||||
newParams[key] = value
|
||||
}
|
||||
return newParams
|
||||
}
|
||||
|
||||
// execute 执行API接口
|
||||
func execute(param Parameter) (bytes []byte, err error) {
|
||||
err = checkConfig()
|
||||
if err != nil {
|
||||
return
|
||||
}
|
||||
|
||||
var req *http.Request
|
||||
req, err = http.NewRequest("POST", Router, strings.NewReader(param.getRequestData()))
|
||||
if err != nil {
|
||||
return
|
||||
}
|
||||
req.Header.Add("Content-Type", "application/x-www-form-urlencoded;charset=utf-8")
|
||||
httpClient := &http.Client{}
|
||||
httpClient.Timeout = Timeout
|
||||
var response *http.Response
|
||||
response, err = httpClient.Do(req)
|
||||
if err != nil {
|
||||
return
|
||||
}
|
||||
|
||||
if response.StatusCode != 200 {
|
||||
err = fmt.Errorf("请求错误:%d", response.StatusCode)
|
||||
return
|
||||
}
|
||||
defer response.Body.Close()
|
||||
bytes, err = ioutil.ReadAll(response.Body)
|
||||
return
|
||||
}
|
||||
|
||||
// Execute 执行API接口
|
||||
func Execute(method string, param Parameter) (res *simplejson.Json, err error) {
|
||||
param["method"] = method
|
||||
param.setRequestData()
|
||||
|
||||
var bodyBytes []byte
|
||||
bodyBytes, err = execute(param)
|
||||
if err != nil {
|
||||
return
|
||||
}
|
||||
|
||||
return bytesToResult(bodyBytes)
|
||||
}
|
||||
|
||||
func bytesToResult(bytes []byte) (res *simplejson.Json, err error) {
|
||||
res, err = simplejson.NewJson(bytes)
|
||||
if err != nil {
|
||||
return
|
||||
}
|
||||
|
||||
if responseError, ok := res.CheckGet("error_response"); ok {
|
||||
if subMsg, subOk := responseError.CheckGet("sub_msg"); subOk {
|
||||
err = errors.New(subMsg.MustString())
|
||||
} else {
|
||||
err = errors.New(responseError.Get("msg").MustString())
|
||||
}
|
||||
res = nil
|
||||
}
|
||||
return
|
||||
}
|
||||
|
||||
// 检查配置
|
||||
func checkConfig() error {
|
||||
if AppKey == "" {
|
||||
return errors.New("AppKey 不能为空")
|
||||
}
|
||||
if SecretKey == "" {
|
||||
return errors.New("SecretKey 不能为空")
|
||||
}
|
||||
if Router == "" {
|
||||
return errors.New("Router 不能为空")
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
func (p Parameter) setRequestData() {
|
||||
hh, _ := time.ParseDuration("8h")
|
||||
loc := time.Now().UTC().Add(hh)
|
||||
p["app_key"] = AppKey
|
||||
p["timestamp"] = loc.Format("2006-01-02 15:04:05")
|
||||
p["format"] = "json"
|
||||
p["v"] = "1.0"
|
||||
p["sign_method"] = "md5"
|
||||
// 设置签名
|
||||
p["sign"] = getSign(p)
|
||||
}
|
||||
|
||||
// 获取请求数据
|
||||
func (p Parameter) getRequestData() string {
|
||||
// 公共参数
|
||||
args := url.Values{}
|
||||
// 请求参数
|
||||
for key, val := range p {
|
||||
args.Set(key, interfaceToString(val))
|
||||
}
|
||||
return args.Encode()
|
||||
}
|
||||
|
||||
// 获取签名
|
||||
func getSign(params Parameter) string {
|
||||
// 获取Key
|
||||
keys := []string{}
|
||||
for k := range params {
|
||||
keys = append(keys, k)
|
||||
}
|
||||
// 排序asc
|
||||
sort.Strings(keys)
|
||||
// 把所有参数名和参数值串在一起
|
||||
query := bytes.NewBufferString(SecretKey)
|
||||
for _, k := range keys {
|
||||
query.WriteString(k)
|
||||
query.WriteString(interfaceToString(params[k]))
|
||||
}
|
||||
query.WriteString(SecretKey)
|
||||
// 使用MD5加密
|
||||
h := md5.New()
|
||||
io.Copy(h, query)
|
||||
// 把二进制转化为大写的十六进制
|
||||
return strings.ToUpper(hex.EncodeToString(h.Sum(nil)))
|
||||
}
|
||||
|
||||
func interfaceToString(src interface{}) string {
|
||||
if src == nil {
|
||||
panic(service.ErrTypeIsNil)
|
||||
}
|
||||
switch src.(type) {
|
||||
case string:
|
||||
return src.(string)
|
||||
case int, int8, int32, int64:
|
||||
case uint8, uint16, uint32, uint64:
|
||||
case float32, float64:
|
||||
return convert.ToString(src)
|
||||
}
|
||||
data, err := json.Marshal(src)
|
||||
if err != nil {
|
||||
panic(err)
|
||||
}
|
||||
return string(data)
|
||||
}
|
||||
Loading…
Reference in new issue