dtapps
/
go-library
1
0
Fork 0
Code Issues Pull Requests Projects Releases 40 Wiki Activity

- update jd

Browse Source 
- update kashangwl
master
李光春 2 years ago
parent 8ec67ae83d
commit dbf9f53dbe
15 changed files with 138 additions and 134 deletions
Show Stats Download Patch File Download Diff File

2
service/jd/request.go
Unescape View File

@ -6,7 +6,7 @@ import (
)
// 请求接口
func (c *Client) request(params map[string]interface{}) (resp gorequest.Response, err error) {
func (c *Client) request(params map[string]interface{}) (gorequest.Response, error) {
// 签名
c.Sign(params)

10
service/kashangwl/api.buy.go
Unescape View File

@ -32,19 +32,19 @@ type ApiBuyResult struct {
Err error // 错误
}
func NewApiBuyResult(result ApiBuyResponse, body []byte, http gorequest.Response, err error) *ApiBuyResult {
func newApiBuyResult(result ApiBuyResponse, body []byte, http gorequest.Response, err error) *ApiBuyResult {
return &ApiBuyResult{Result: result, Body: body, Http: http, Err: err}
}
// ApiBuy 购买商品
// http://doc.cqmeihu.cn/sales/buy.html
func (app *App) ApiBuy(notMustParams ...Params) *ApiBuyResult {
func (c *Client) ApiBuy(notMustParams ...gorequest.Params) *ApiBuyResult {
// 参数
params := app.NewParamsWith(notMustParams...)
params := gorequest.NewParamsWith(notMustParams...)
// 请求
request, err := app.request("http://www.kashangwl.com/api/buy", params)
request, err := c.request(apiUrl+"/api/buy", params)
// 定义
var response ApiBuyResponse
err = json.Unmarshal(request.ResponseBody, &response)
return NewApiBuyResult(response, request.ResponseBody, request, err)
return newApiBuyResult(response, request.ResponseBody, request, err)
}

8
service/kashangwl/api.customer.go
Unescape View File

@ -22,17 +22,17 @@ type ApiCustomerResult struct {
Err error // 错误
}
func NewApiCustomerResult(result ApiCustomerResponse, body []byte, http gorequest.Response, err error) *ApiCustomerResult {
func newApiCustomerResult(result ApiCustomerResponse, body []byte, http gorequest.Response, err error) *ApiCustomerResult {
return &ApiCustomerResult{Result: result, Body: body, Http: http, Err: err}
}
// ApiCustomer 获取商家信息
// http://doc.cqmeihu.cn/sales/merchant-info.html
func (app *App) ApiCustomer() *ApiCustomerResult {
func (c *Client) ApiCustomer() *ApiCustomerResult {
// 请求
request, err := app.request("http://www.kashangwl.com/api/customer", map[string]interface{}{})
request, err := c.request(apiUrl+"/api/customer", map[string]interface{}{})
// 定义
var response ApiCustomerResponse
err = json.Unmarshal(request.ResponseBody, &response)
return NewApiCustomerResult(response, request.ResponseBody, request, err)
return newApiCustomerResult(response, request.ResponseBody, request, err)
}

12
service/kashangwl/api.order.go
Unescape View File

@ -45,22 +45,22 @@ type ApiOrderResult struct {
Err error // 错误
}
func NewApiOrderResult(result ApiOrderResponse, body []byte, http gorequest.Response, err error) *ApiOrderResult {
func newApiOrderResult(result ApiOrderResponse, body []byte, http gorequest.Response, err error) *ApiOrderResult {
return &ApiOrderResult{Result: result, Body: body, Http: http, Err: err}
}
// ApiOrder 获取单个订单信息。
// 仅能获取自己购买的订单。
// http://doc.cqmeihu.cn/sales/order-info.html
func (app App) ApiOrder(orderId string) *ApiOrderResult {
func (c *Client) ApiOrder(orderId string) *ApiOrderResult {
// 参数
param := NewParams()
param := gorequest.NewParams()
param.Set("order_id", orderId)
params := app.NewParamsWith(param)
params := gorequest.NewParamsWith(param)
// 请求
request, err := app.request("http://www.kashangwl.com/api/order", params)
request, err := c.request(apiUrl+"/api/order", params)
// 定义
var response ApiOrderResponse
err = json.Unmarshal(request.ResponseBody, &response)
return NewApiOrderResult(response, request.ResponseBody, request, err)
return newApiOrderResult(response, request.ResponseBody, request, err)
}

12
service/kashangwl/api.outer-order.go
Unescape View File

@ -45,22 +45,22 @@ type ApiOuterOrderResult struct {
Err error // 错误
}
func NewApiOuterOrderResult(result ApiOuterOrderResponse, body []byte, http gorequest.Response, err error) *ApiOuterOrderResult {
func newApiOuterOrderResult(result ApiOuterOrderResponse, body []byte, http gorequest.Response, err error) *ApiOuterOrderResult {
return &ApiOuterOrderResult{Result: result, Body: body, Http: http, Err: err}
}
// ApiOuterOrder 使用外部订单号获取单个订单信息
// 仅能获取自己购买的订单
// http://doc.cqmeihu.cn/sales/outer-order-info.html
func (app App) ApiOuterOrder(orderId string) *ApiOuterOrderResult {
func (c *Client) ApiOuterOrder(orderId string) *ApiOuterOrderResult {
// 参数
param := NewParams()
param := gorequest.NewParams()
param.Set("outer_order_id", orderId)
params := app.NewParamsWith(param)
params := gorequest.NewParamsWith(param)
// 请求
request, err := app.request("http://www.kashangwl.com/api/outer-order", params)
request, err := c.request(apiUrl+"/api/outer-order", params)
// 定义
var response ApiOuterOrderResponse
err = json.Unmarshal(request.ResponseBody, &response)
return NewApiOuterOrderResult(response, request.ResponseBody, request, err)
return newApiOuterOrderResult(response, request.ResponseBody, request, err)
}

10
service/kashangwl/api.product.go
Unescape View File

@ -30,20 +30,20 @@ type ApiProductResult struct {
Err error // 错误
}
func NewApiProductResult(result ApiProductResponse, body []byte, http gorequest.Response, err error) *ApiProductResult {
func newApiProductResult(result ApiProductResponse, body []byte, http gorequest.Response, err error) *ApiProductResult {
return &ApiProductResult{Result: result, Body: body, Http: http, Err: err}
}
// ApiProduct 获取单个商品信息
// http://doc.cqmeihu.cn/sales/product-info.html
func (app App) ApiProduct(productId int64) *ApiProductResult {
func (c *Client) ApiProduct(productId int64) *ApiProductResult {
// 参数
params := NewParams()
params := gorequest.NewParams()
params.Set("product_id", productId)
// 请求
request, err := app.request("http://www.kashangwl.com/api/product", params)
request, err := c.request(apiUrl+"/api/product", params)
// 定义
var response ApiProductResponse
err = json.Unmarshal(request.ResponseBody, &response)
return NewApiProductResult(response, request.ResponseBody, request, err)
return newApiProductResult(response, request.ResponseBody, request, err)
}

10
service/kashangwl/api.product.recharge-params.go
Unescape View File

@ -25,20 +25,20 @@ type ApiProductRechargeParamsResult struct {
Err error // 错误
}
func NewApiProductRechargeParamsResult(result ApiProductRechargeParamsResponse, body []byte, http gorequest.Response, err error) *ApiProductRechargeParamsResult {
func newApiProductRechargeParamsResult(result ApiProductRechargeParamsResponse, body []byte, http gorequest.Response, err error) *ApiProductRechargeParamsResult {
return &ApiProductRechargeParamsResult{Result: result, Body: body, Http: http, Err: err}
}
// ApiProductRechargeParams 接口说明
// 获取商品的充值参数（仅支持充值类商品）
// http://doc.cqmeihu.cn/sales/ProductParams.html
func (app App) ApiProductRechargeParams(notMustParams ...Params) *ApiProductRechargeParamsResult {
func (c *Client) ApiProductRechargeParams(notMustParams ...gorequest.Params) *ApiProductRechargeParamsResult {
// 参数
params := app.NewParamsWith(notMustParams...)
params := gorequest.NewParamsWith(notMustParams...)
// 请求
request, err := app.request("http://www.kashangwl.com/api/product/recharge-params", params)
request, err := c.request(apiUrl+"/api/product/recharge-params", params)
// 定义
var response ApiProductRechargeParamsResponse
err = json.Unmarshal(request.ResponseBody, &response)
return NewApiProductRechargeParamsResult(response, request.ResponseBody, request, err)
return newApiProductRechargeParamsResult(response, request.ResponseBody, request, err)
}

69
service/kashangwl/app.go
Unescape View File

@ -1,69 +0,0 @@
package kashangwl
import (
"go.dtapp.net/library/utils/golog"
"go.dtapp.net/library/utils/gorequest"
"gorm.io/gorm"
"time"
)
// App 卡商网服务
type App struct {
customerId int // 商家编号
customerKey string // 商家密钥
pgsql *gorm.DB // pgsql数据库
client *gorequest.App // 请求客户端
log *golog.Api // 日志服务
logTableName string // 日志表名
logStatus bool // 日志状态
}
func NewApp(customerId int, customerKey string, pgsql *gorm.DB) *App {
app := &App{customerId: customerId, customerKey: customerKey}
app.client = gorequest.NewHttp()
if pgsql != nil {
app.pgsql = pgsql
app.logStatus = true
app.logTableName = "kashangwl"
app.log = golog.NewApi(&golog.ApiConfig{
Db: pgsql,
TableName: app.logTableName,
})
}
return app
}
func (app *App) request(url string, params map[string]interface{}) (resp gorequest.Response, err error) {
// 公共参数
params["timestamp"] = time.Now().UnixNano() / 1e6
params["customer_id"] = app.customerId
// 签名参数
params["sign"] = app.getSign(app.customerKey, params)
// 创建请求
client := app.client
// 设置请求地址
client.SetUri(url)
// 设置格式
client.SetContentTypeJson()
// 设置参数
client.SetParams(params)
// 发起请求
request, err := client.Post()
if err != nil {
return gorequest.Response{}, err
}
// 日志
if app.logStatus == true {
go app.postgresqlLog(request)
}
return request, err
}

41
service/kashangwl/client.go
Unescape View File

@ -0,0 +1,41 @@
package kashangwl
import (
"go.dtapp.net/library/utils/golog"
"go.dtapp.net/library/utils/gorequest"
"gorm.io/gorm"
)
type ConfigClient struct {
CustomerId int // 商家编号
CustomerKey string // 商家密钥
PgsqlDb *gorm.DB // pgsql数据库
}
// Client 卡商网服务
type Client struct {
client *gorequest.App // 请求客户端
log *golog.ApiClient // 日志服务
logStatus bool // 日志状态
config *ConfigClient // 配置
}
func NewClient(config *ConfigClient) (*Client, error) {
var err error
c := &Client{config: config}
c.client = gorequest.NewHttp()
if c.config.PgsqlDb != nil {
c.logStatus = true
c.log, err = golog.NewApiClient(&golog.ConfigApiClient{
Db: c.config.PgsqlDb,
TableName: logTable,
})
if err != nil {
return nil, err
}
}
return c, nil
}

9
service/kashangwl/const.go
Unescape View File

@ -0,0 +1,9 @@
package kashangwl
const (
apiUrl = "http://www.kashangwl.com"
)
const (
logTable = "kashangwl"
)

9
service/kashangwl/get.go
Unescape View File

@ -0,0 +1,9 @@
package kashangwl
func (c *Client) GetCustomerId() int {
return c.config.CustomerId
}
func (c *Client) GetCustomerKey() string {
return c.config.CustomerKey
}

4
service/kashangwl/pgsql.go → service/kashangwl/log.go
Unescape View File

@ -8,8 +8,8 @@ import (
)
// 记录日志
func (app *App) postgresqlLog(request gorequest.Response) {
app.log.Record(golog.ApiPostgresqlLog{
func (c *Client) postgresqlLog(request gorequest.Response) {
c.log.Record(golog.ApiPostgresqlLog{
RequestTime: golog.TimeString{Time: request.RequestTime}, //【请求】时间
RequestUri: request.RequestUri, //【请求】链接
RequestUrl: gorequest.UriParse(request.RequestUri).Url, //【请求】链接

27
service/kashangwl/params.go
Unescape View File

@ -1,27 +0,0 @@
package kashangwl
// Params 请求参数
type Params map[string]interface{}
func NewParams() Params {
p := make(Params)
return p
}
func (app *App) NewParamsWith(params ...Params) Params {
p := make(Params)
for _, v := range params {
p.SetParams(v)
}
return p
}
func (p Params) Set(key string, value interface{}) {
p[key] = value
}
func (p Params) SetParams(params Params) {
for key, value := range params {
p[key] = value
}
}

41
service/kashangwl/request.go
Unescape View File

@ -0,0 +1,41 @@
package kashangwl
import (
"go.dtapp.net/library/utils/gorequest"
"time"
)
func (c *Client) request(url string, params map[string]interface{}) (gorequest.Response, error) {
// 公共参数
params["timestamp"] = time.Now().UnixNano() / 1e6
params["customer_id"] = c.GetCustomerId()
// 签名参数
params["sign"] = c.getSign(c.GetCustomerKey(), params)
// 创建请求
client := c.client
// 设置请求地址
client.SetUri(url)
// 设置格式
client.SetContentTypeJson()
// 设置参数
client.SetParams(params)
// 发起请求
request, err := client.Post()
if err != nil {
return gorequest.Response{}, err
}
// 日志
if c.logStatus == true {
go c.postgresqlLog(request)
}
return request, err
}

8
service/kashangwl/sign.go
Unescape View File

@ -14,7 +14,7 @@ import (
)
// md5(key + 参数1名称 + 参数1值 + 参数2名称 + 参数2值...) 加密源串应为{key}customer_id1192442order_id827669582783timestamp1626845767
func (app *App) getSign(customerKey string, params map[string]interface{}) string {
func (c *Client) getSign(customerKey string, params map[string]interface{}) string {
// 参数按照参数名的字典升序排列
var keys []string
for k := range params {
@ -34,17 +34,17 @@ func (app *App) getSign(customerKey string, params map[string]interface{}) strin
}
// 获取请求数据
func (app *App) getRequestData(params map[string]interface{}) string {
func (c *Client) getRequestData(params map[string]interface{}) string {
// 公共参数
args := url.Values{}
// 请求参数
for key, val := range params {
args.Set(key, app.getString(val))
args.Set(key, c.getString(val))
}
return args.Encode()
}
func (app *App) getString(i interface{}) string {
func (c *Client) getString(i interface{}) string {
switch v := i.(type) {
case string:
return v

Write Preview
Loading…
Cancel
Save