dtapps
/
wechatunion
1
0
Fork 0
Code Issues Pull Requests Projects Releases 13 Wiki Activity

- update request
continuous-integration/drone/push Build is failing Details
continuous-integration/drone/tag Build is failing Details

Browse Source
master v1.0.3
李光春 2 years ago
parent 00b03662d1
commit 6a954bc67f
20 changed files with 71 additions and 52 deletions
Show Stats Download Patch File Download Diff File

8
cgi-bin.token.monitor.go
Unescape View File

@ -6,14 +6,14 @@ import (
"time"
)
func (c *Client) GetAccessTokenMonitor() (string, error) {
func (c *Client) GetAccessTokenMonitor(ctx context.Context) (string, error) {
if c.config.RedisClient.Db == nil {
return "", errors.New("驱动没有初始化")
}
result := c.GetCallBackIp()
result := c.GetCallBackIp(ctx)
if len(result.Result.IpList) <= 0 {
token := c.CgiBinToken()
c.config.RedisClient.Db.Set(context.Background(), c.getAccessTokenCacheKeyName(), token.Result.AccessToken, time.Second*7000)
token := c.CgiBinToken(ctx)
c.config.RedisClient.Set(ctx, c.getAccessTokenCacheKeyName(), token.Result.AccessToken, time.Second*7000)
return token.Result.AccessToken, nil
}
return c.config.AccessToken, nil

5
cgi-bin.token.rdb.go
Unescape View File

@ -1,17 +1,18 @@
package wechatunion
import (
"context"
"fmt"
"time"
)
func (c *Client) GetAccessToken() string {
func (c *Client) GetAccessToken(ctx context.Context) string {
if c.config.RedisClient.Db == nil {
return c.config.AccessToken
}
newCache := c.config.RedisClient.NewSimpleStringCache(c.config.RedisClient.NewStringOperation(), time.Second*7000)
newCache.DBGetter = func() string {
token := c.CgiBinToken()
token := c.CgiBinToken(ctx)
return token.Result.AccessToken
}
return newCache.GetCache(c.getAccessTokenCacheKeyName())

5
cgi_bin.token.go
Unescape View File

@ -1,6 +1,7 @@
package wechatunion
import (
"context"
"encoding/json"
"fmt"
"go.dtapp.net/gorequest"
@ -28,9 +29,9 @@ func newCgiBinTokenResult(result CgiBinTokenResponse, byte []byte, http goreques
// CgiBinToken
// 接口调用凭证
// https://developers.weixin.qq.com/miniprogram/dev/api-backend/open-api/access-token/auth.getAccessToken.html
func (c *Client) CgiBinToken() *CgiBinTokenResult {
func (c *Client) CgiBinToken(ctx context.Context) *CgiBinTokenResult {
// 请求
request, err := c.request(fmt.Sprintf("https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=%s&secret=%s", c.getAppId(), c.getAppSecret()), map[string]interface{}{}, http.MethodGet)
request, err := c.request(ctx, fmt.Sprintf("https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=%s&secret=%s", c.getAppId(), c.getAppSecret()), map[string]interface{}{}, http.MethodGet)
// 定义
var response CgiBinTokenResponse
err = json.Unmarshal(request.ResponseBody, &response)

2
const.go
Unescape View File

@ -8,4 +8,4 @@ const (
logTable = "wechatunion"
)
const Version = "1.0.2"
const Version = "1.0.3"

6
get.go
Unescape View File

@ -1,5 +1,7 @@
package wechatunion
import "context"
func (c *Client) getAppId() string {
return c.config.AppId
}
@ -8,8 +10,8 @@ func (c *Client) getAppSecret() string {
return c.config.AppSecret
}
func (c *Client) getAccessToken() string {
c.config.AccessToken = c.GetAccessToken()
func (c *Client) getAccessToken(ctx context.Context) string {
c.config.AccessToken = c.GetAccessToken(ctx)
return c.config.AccessToken
}

5
getcallbackip.go
Unescape View File

@ -1,6 +1,7 @@
package wechatunion
import (
"context"
"encoding/json"
"fmt"
"go.dtapp.net/gorequest"
@ -24,9 +25,9 @@ func newGetCallBackIpResult(result GetCallBackIpResponse, byte []byte, http gore
// GetCallBackIp 获取微信callback IP地址
// callback IP即微信调用开发者服务器所使用的出口IP。
// https://developers.weixin.qq.com/doc/offiaccount/Basic_Information/Get_the_WeChat_server_IP_address.html#2.%20%E8%8E%B7%E5%8F%96%E5%BE%AE%E4%BF%A1callback%20IP%E5%9C%B0%E5%9D%80
func (c *Client) GetCallBackIp() *GetCallBackIpResult {
func (c *Client) GetCallBackIp(ctx context.Context) *GetCallBackIpResult {
// 请求
request, err := c.request(fmt.Sprintf("https://api.weixin.qq.com/cgi-bin/getcallbackip?access_token=%s", c.getAccessToken()), map[string]interface{}{}, "GET")
request, err := c.request(ctx, fmt.Sprintf("https://api.weixin.qq.com/cgi-bin/getcallbackip?access_token=%s", c.getAccessToken(ctx)), map[string]interface{}{}, "GET")
// 定义
var response GetCallBackIpResponse
err = json.Unmarshal(request.ResponseBody, &response)

10
go.mod
Unescape View File

@ -3,8 +3,8 @@ module go.dtapp.net/wechatunion
go 1.19
require (
go.dtapp.net/dorm v1.0.14
go.dtapp.net/golog v1.0.21
go.dtapp.net/dorm v1.0.17
go.dtapp.net/golog v1.0.22
go.dtapp.net/gorequest v1.0.24
go.dtapp.net/gotime v1.0.5
gorm.io/gorm v1.23.8
@ -68,14 +68,14 @@ require (
go.dtapp.net/gostring v1.0.6 // indirect
go.dtapp.net/goxml v1.0.1 // indirect
go.mongodb.org/mongo-driver v1.10.1 // indirect
go.uber.org/atomic v1.9.0 // indirect
go.uber.org/atomic v1.10.0 // indirect
go.uber.org/multierr v1.8.0 // indirect
go.uber.org/zap v1.22.0 // indirect
golang.org/x/crypto v0.0.0-20220722155217-630584e8d5aa // indirect
golang.org/x/mod v0.6.0-dev.0.20220419223038-86c51ed26bb4 // indirect
golang.org/x/net v0.0.0-20220809184613-07c6da5e1ced // indirect
golang.org/x/net v0.0.0-20220811182439-13a9a731de15 // indirect
golang.org/x/sync v0.0.0-20220722155255-886fb9371eb4 // indirect
golang.org/x/sys v0.0.0-20220808155132-1c4a2a72c664 // indirect
golang.org/x/sys v0.0.0-20220811171246-fbc7d0a398ab // indirect
golang.org/x/text v0.3.7 // indirect
google.golang.org/protobuf v1.28.1 // indirect
gopkg.in/yaml.v2 v2.4.0 // indirect

20
go.sum
Unescape View File

@ -499,14 +499,14 @@ github.com/youmark/pkcs8 v0.0.0-20201027041543-1326539a0a0a/go.mod h1:ul22v+Nro/
github.com/yuin/goldmark v1.2.1/go.mod h1:3hX8gzYuyVAZsxl0MRgGTJEmQBFcNTphYh9decYSb74=
github.com/zenazn/goji v0.9.0/go.mod h1:7S9M489iMyHBNxwZnk9/EHS098H4/F6TATF2mIxtB1Q=
github.com/ziutek/mymysql v1.5.4/go.mod h1:LMSpPZ6DbqWFxNCHW77HeMg9I646SAhApZ/wKdgO/C0=
go.dtapp.net/dorm v1.0.14 h1:HDsaMwKGlKFKt59Y3hPI9aVnSjfXOyjoHw2uoXErKEo=
go.dtapp.net/dorm v1.0.14/go.mod h1:bHG7BmgeLaAlc56myYF63lwZAIuMeWRAqHBb/L84dLM=
go.dtapp.net/dorm v1.0.17 h1:3VQKUl05CDxFg3T1c/M8wYf2I+H+oVGBDh4NCV30nn0=
go.dtapp.net/dorm v1.0.17/go.mod h1:bHG7BmgeLaAlc56myYF63lwZAIuMeWRAqHBb/L84dLM=
go.dtapp.net/goip v1.0.24 h1:62k3xt9I/YLUwA5tLp7YC8XPskkswc4RJrvxRRxjwIY=
go.dtapp.net/goip v1.0.24/go.mod h1:tps0yoq5kSykLGDb01vuai47hzAQ6nYUPFWLdlQA2Oo=
go.dtapp.net/gojson v1.0.1 h1:MHeSGlq1KxzL7rCkm18fhwW4GNORHohdDMmxY5PupKY=
go.dtapp.net/gojson v1.0.1/go.mod h1:TkkpTNxHBKxul0e7gC5MrL1K4ICFB9mQ7wHzjBah3/k=
go.dtapp.net/golog v1.0.21 h1:pSGmDz3SJTH7M/NvVLZb+YJd8uNl5g18aORibuaY2JU=
go.dtapp.net/golog v1.0.21/go.mod h1:Wxm2Kh77JN5zFDZ72el9E9c/YkoJnOvHVusB7SqvoC8=
go.dtapp.net/golog v1.0.22 h1:sOJr5f/iLk/6irT/RuwTQSTwvL2DR8SIhzMsKdHo0Ic=
go.dtapp.net/golog v1.0.22/go.mod h1:sbn2WQXmlukcZ4T3Kz9iWOSznL8H3RCkD+1nicZHMfI=
go.dtapp.net/gorandom v1.0.1 h1:IWfMClh1ECPvyUjlqD7MwLq4mZdUusD1qAwAdsvEJBs=
go.dtapp.net/gorandom v1.0.1/go.mod h1:ZPdgalKpvFV/ATQqR0k4ns/F/IpITAZpx6WkWirr5Y8=
go.dtapp.net/gorequest v1.0.24 h1:N2RJOpCXPWbsjfQ8iYJI1EYC2se3I4QhK1l94DSJsuE=
@ -529,8 +529,8 @@ go.uber.org/atomic v1.4.0/go.mod h1:gD2HeocX3+yG+ygLZcrzQJaqmWj9AIm7n08wl/qW/PE=
go.uber.org/atomic v1.5.0/go.mod h1:sABNBOSYdrvTF6hTgEIbc7YasKWGhgEQZyfxyTvoXHQ=
go.uber.org/atomic v1.6.0/go.mod h1:sABNBOSYdrvTF6hTgEIbc7YasKWGhgEQZyfxyTvoXHQ=
go.uber.org/atomic v1.7.0/go.mod h1:fEN4uk6kAWBTFdckzkM89CLk9XfWZrxpCo0nPH17wJc=
go.uber.org/atomic v1.9.0 h1:ECmE8Bn/WFTYwEW/bpKD3M8VtR/zQVbavAoalC1PYyE=
go.uber.org/atomic v1.9.0/go.mod h1:fEN4uk6kAWBTFdckzkM89CLk9XfWZrxpCo0nPH17wJc=
go.uber.org/atomic v1.10.0 h1:9qC72Qh0+3MqyJbAn8YU5xVq1frD8bn3JtD2oXtafVQ=
go.uber.org/atomic v1.10.0/go.mod h1:LUxbIzbOniOlMKjJjyPfpl4v+PKK2cNJn91OQbhoJI0=
go.uber.org/goleak v1.1.11 h1:wy28qYRKZgnJTxGxvye5/wgWr1EKjmUDGYox5mGlRlI=
go.uber.org/multierr v1.1.0/go.mod h1:wR5kodmAFQ0UK8QlbwjlSNy0Z68gJhDJUG5sjR94q/0=
go.uber.org/multierr v1.3.0/go.mod h1:VgVr7evmIr6uPjLBxg28wmKNXyqE9akIJ5XnfpiKl+4=
@ -601,8 +601,8 @@ golang.org/x/net v0.0.0-20201021035429-f5854403a974/go.mod h1:sp8m0HH+o8qH0wwXwY
golang.org/x/net v0.0.0-20210226172049-e18ecbb05110/go.mod h1:m0MpNAwzfU5UDzcl9v0D8zg8gWTRqZa9RBIspLL5mdg=
golang.org/x/net v0.0.0-20210610132358-84b48f89b13b/go.mod h1:9nx3DQGgdP8bBQD5qxJ1jj9UTztislL4KSBs9R2vV5Y=
golang.org/x/net v0.0.0-20211112202133-69e39bad7dc2/go.mod h1:9nx3DQGgdP8bBQD5qxJ1jj9UTztislL4KSBs9R2vV5Y=
golang.org/x/net v0.0.0-20220809184613-07c6da5e1ced h1:3dYNDff0VT5xj+mbj2XucFst9WKk6PdGOrb9n+SbIvw=
golang.org/x/net v0.0.0-20220809184613-07c6da5e1ced/go.mod h1:YDH+HFinaLZZlnHAfSS6ZXJJ9M9t4Dl22yv3iI2vPwk=
golang.org/x/net v0.0.0-20220811182439-13a9a731de15 h1:cik0bxZUSJVDyaHf1hZPSDsU8SZHGQZQMeueXCE7yBQ=
golang.org/x/net v0.0.0-20220811182439-13a9a731de15/go.mod h1:YDH+HFinaLZZlnHAfSS6ZXJJ9M9t4Dl22yv3iI2vPwk=
golang.org/x/oauth2 v0.0.0-20180821212333-d2e6202438be/go.mod h1:N/0e6XlmueqKjAGxoOufVs8QHGRruUQn6yWY3a++T0U=
golang.org/x/oauth2 v0.0.0-20190226205417-e64efc72b421/go.mod h1:gOpvHmFTYa4IltrdGE7lF6nIHvwfUNPOp7c8zoXwtLw=
golang.org/x/sync v0.0.0-20180314180146-1d60e4601c6f/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
@ -647,8 +647,8 @@ golang.org/x/sys v0.0.0-20210902050250-f475640dd07b/go.mod h1:oPkhp1MJrh7nUepCBc
golang.org/x/sys v0.0.0-20211007075335-d3039528d8ac/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
golang.org/x/sys v0.0.0-20211210111614-af8b64212486/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
golang.org/x/sys v0.0.0-20220715151400-c0bba94af5f8/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
golang.org/x/sys v0.0.0-20220808155132-1c4a2a72c664 h1:v1W7bwXHsnLLloWYTVEdvGvA7BHMeBYsPcF0GLDxIRs=
golang.org/x/sys v0.0.0-20220808155132-1c4a2a72c664/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
golang.org/x/sys v0.0.0-20220811171246-fbc7d0a398ab h1:2QkjZIsXupsJbJIdSjjUOgWK3aEtzyuh2mPt3l/CkeU=
golang.org/x/sys v0.0.0-20220811171246-fbc7d0a398ab/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
golang.org/x/term v0.0.0-20201117132131-f5c789dd3221/go.mod h1:Nr5EML6q2oocZ2LXRh80K7BxOlk5/8JxuGnuhpl+muw=
golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1/go.mod h1:bj7SfCRtBDWHUb9snDiAeCFNEtKQo2Wmx5Cou7ajbmo=
golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ=

3
order.go
Unescape View File

@ -1,6 +1,7 @@
package wechatunion
import (
"context"
"errors"
"go.dtapp.net/gorequest"
)
@ -51,7 +52,7 @@ type OrderSearchResult struct {
}
// OrderSearch 根据订单支付时间、订单分佣状态拉取订单详情 https://developers.weixin.qq.com/doc/ministore/union/access-guidelines/promoter/api/order/order-info.html
func (c *Client) OrderSearch(notMustParams ...gorequest.Params) (result OrderSearchResult, err error) {
func (c *Client) OrderSearch(ctx context.Context, notMustParams ...gorequest.Params) (result OrderSearchResult, err error) {
if len(c.getAccessToken()) <= 0 {
return result, errors.New("调用凭证异常")
}

5
promoter.order.info.go
Unescape View File

@ -1,6 +1,7 @@
package wechatunion
import (
"context"
"encoding/json"
"fmt"
"go.dtapp.net/gorequest"
@ -55,7 +56,7 @@ func newPromoterOrderInfoResult(result PromoterOrderInfoResponse, body []byte, h
// PromoterOrderInfo 根据订单ID查询订单详情
// https://developers.weixin.qq.com/doc/ministore/union/access-guidelines/promoter/api/order/order-info.html#_1-%E6%A0%B9%E6%8D%AE%E8%AE%A2%E5%8D%95ID%E6%9F%A5%E8%AF%A2%E8%AE%A2%E5%8D%95%E8%AF%A6%E6%83%85
func (c *Client) PromoterOrderInfo(orderId ...string) *PromoterOrderInfoResult {
func (c *Client) PromoterOrderInfo(ctx context.Context, orderId ...string) *PromoterOrderInfoResult {
// 参数
params := gorequest.NewParamsWith()
var orderIdList []any
@ -64,7 +65,7 @@ func (c *Client) PromoterOrderInfo(orderId ...string) *PromoterOrderInfoResult {
}
params.Set("orderIdList", orderIdList)
// 请求
request, err := c.request(apiUrl+fmt.Sprintf("/promoter/order/info?access_token=%s", c.getAccessToken()), params, http.MethodPost)
request, err := c.request(ctx, apiUrl+fmt.Sprintf("/promoter/order/info?access_token=%s", c.getAccessToken(ctx)), params, http.MethodPost)
// 定义
var response PromoterOrderInfoResponse
err = json.Unmarshal(request.ResponseBody, &response)

5
promoter.order.search.go
Unescape View File

@ -1,6 +1,7 @@
package wechatunion
import (
"context"
"encoding/json"
"fmt"
"go.dtapp.net/gorequest"
@ -57,11 +58,11 @@ func newPromoterOrderSearchResult(result PromoterOrderSearchResponse, body []byt
// PromoterOrderSearch 根据订单支付时间、订单分佣状态拉取订单详情
// https://developers.weixin.qq.com/doc/ministore/union/access-guidelines/promoter/api/order/order-info.html#_2-%E6%A0%B9%E6%8D%AE%E8%AE%A2%E5%8D%95%E6%94%AF%E4%BB%98%E6%97%B6%E9%97%B4%E3%80%81%E8%AE%A2%E5%8D%95%E5%88%86%E4%BD%A3%E7%8A%B6%E6%80%81%E6%8B%89%E5%8F%96%E8%AE%A2%E5%8D%95%E8%AF%A6%E6%83%85
func (c *Client) PromoterOrderSearch(notMustParams ...gorequest.Params) *PromoterOrderSearchResult {
func (c *Client) PromoterOrderSearch(ctx context.Context, notMustParams ...gorequest.Params) *PromoterOrderSearchResult {
// 参数
params := gorequest.NewParamsWith(notMustParams...)
// 请求
request, err := c.request(apiUrl+fmt.Sprintf("/promoter/order/search?access_token=%s", c.getAccessToken()), params, http.MethodGet)
request, err := c.request(ctx, apiUrl+fmt.Sprintf("/promoter/order/search?access_token=%s", c.getAccessToken(ctx)), params, http.MethodGet)
// 定义
var response PromoterOrderSearchResponse
err = json.Unmarshal(request.ResponseBody, &response)

5
promoter.product.category.go
Unescape View File

@ -1,6 +1,7 @@
package wechatunion
import (
"context"
"encoding/json"
"fmt"
"go.dtapp.net/gorequest"
@ -29,9 +30,9 @@ func newPromoterProductCategoryResult(result PromoterProductCategoryResponse, bo
// PromoterProductCategory 获取联盟商品类目列表及类目ID
// https://developers.weixin.qq.com/doc/ministore/union/access-guidelines/promoter/api/product/category.html#_1-%E8%8E%B7%E5%8F%96%E8%81%94%E7%9B%9F%E5%95%86%E5%93%81%E7%B1%BB%E7%9B%AE%E5%88%97%E8%A1%A8%E5%8F%8A%E7%B1%BB%E7%9B%AEID
func (c *Client) PromoterProductCategory() *PromoterProductCategoryResult {
func (c *Client) PromoterProductCategory(ctx context.Context) *PromoterProductCategoryResult {
// 请求
request, err := c.request(apiUrl+fmt.Sprintf("/promoter/product/category?access_token=%s", c.getAccessToken()), map[string]interface{}{}, http.MethodGet)
request, err := c.request(ctx, apiUrl+fmt.Sprintf("/promoter/product/category?access_token=%s", c.getAccessToken(ctx)), map[string]interface{}{}, http.MethodGet)
// 定义
var response PromoterProductCategoryResponse
err = json.Unmarshal(request.ResponseBody, &response)

5
promoter.product.generate.go
Unescape View File

@ -1,6 +1,7 @@
package wechatunion
import (
"context"
"encoding/json"
"fmt"
"go.dtapp.net/gorequest"
@ -55,12 +56,12 @@ func newPromoterProductGenerateResult(result PromoterProductGenerateResponse, bo
// PromoterProductGenerate 获取商品推广素材
// https://developers.weixin.qq.com/doc/ministore/union/access-guidelines/promoter/api/product/category.html#_4-%E8%8E%B7%E5%8F%96%E5%95%86%E5%93%81%E6%8E%A8%E5%B9%BF%E7%B4%A0%E6%9D%90
func (c *Client) PromoterProductGenerate(notMustParams ...gorequest.Params) *PromoterProductGenerateResult {
func (c *Client) PromoterProductGenerate(ctx context.Context, notMustParams ...gorequest.Params) *PromoterProductGenerateResult {
// 参数
params := gorequest.NewParamsWith(notMustParams...)
params.Set("pid", c.getPid())
// 请求
request, err := c.request(apiUrl+fmt.Sprintf("/promoter/product/generate?access_token=%s", c.getAccessToken()), params, http.MethodPost)
request, err := c.request(ctx, apiUrl+fmt.Sprintf("/promoter/product/generate?access_token=%s", c.getAccessToken(ctx)), params, http.MethodPost)
// 定义
var response PromoterProductGenerateResponse
err = json.Unmarshal(request.ResponseBody, &response)

5
promoter.product.list.go
Unescape View File

@ -1,6 +1,7 @@
package wechatunion
import (
"context"
"encoding/json"
"fmt"
"go.dtapp.net/gorequest"
@ -139,11 +140,11 @@ func newPromoterProductListResult(result PromoterProductListResponse, body []byt
// PromoterProductList 查询全量商品
// https://developers.weixin.qq.com/doc/ministore/union/access-guidelines/promoter/api/product/category.html#_2-%E6%9F%A5%E8%AF%A2%E5%85%A8%E9%87%8F%E5%95%86%E5%93%81
func (c *Client) PromoterProductList(notMustParams ...gorequest.Params) *PromoterProductListResult {
func (c *Client) PromoterProductList(ctx context.Context, notMustParams ...gorequest.Params) *PromoterProductListResult {
// 参数
params := gorequest.NewParamsWith(notMustParams...)
// 请求
request, err := c.request(apiUrl+fmt.Sprintf("/promoter/product/list?access_token=%s", c.getAccessToken()), params, http.MethodGet)
request, err := c.request(ctx, apiUrl+fmt.Sprintf("/promoter/product/list?access_token=%s", c.getAccessToken(ctx)), params, http.MethodGet)
// 定义
var response PromoterProductListResponse
err = json.Unmarshal(request.ResponseBody, &response)

5
promoter.product.select.go
Unescape View File

@ -1,6 +1,7 @@
package wechatunion
import (
"context"
"encoding/json"
"fmt"
"go.dtapp.net/gorequest"
@ -140,11 +141,11 @@ func newPromoterProductSelectResult(result PromoterProductSelectResponse, body [
// 查询联盟精选商品
// 支持开发者根据多种筛选条件获取联盟精选的商品列表及详情，筛选条件包括商品价格、商品佣金、商品累计销量、佣金比例、是否含有联盟券、配送方式、发货地区
// https://developers.weixin.qq.com/doc/ministore/union/access-guidelines/promoter/api/product/category.html#3.%E6%9F%A5%E8%AF%A2%E8%81%94%E7%9B%9F%E7%B2%BE%E9%80%89%E5%95%86%E5%93%81
func (c *Client) PromoterProductSelect(notMustParams ...gorequest.Params) *PromoterProductSelectResult {
func (c *Client) PromoterProductSelect(ctx context.Context, notMustParams ...gorequest.Params) *PromoterProductSelectResult {
// 参数
params := gorequest.NewParamsWith(notMustParams...)
// 请求
request, err := c.request(apiUrl+fmt.Sprintf("/promoter/product/select?access_token=%s", c.getAccessToken()), params, http.MethodGet)
request, err := c.request(ctx, apiUrl+fmt.Sprintf("/promoter/product/select?access_token=%s", c.getAccessToken(ctx)), params, http.MethodGet)
// 定义
var response PromoterProductSelectResponse
err = json.Unmarshal(request.ResponseBody, &response)

5
promoter.promotion.add.go
Unescape View File

@ -1,6 +1,7 @@
package wechatunion
import (
"context"
"encoding/json"
"fmt"
"go.dtapp.net/gorequest"
@ -26,12 +27,12 @@ func newPromotionAddResult(result PromotionAddResponse, body []byte, http gorequ
// PromotionAdd 添加推广位
// https://developers.weixin.qq.com/doc/ministore/union/access-guidelines/promoter/api/promotion.html#_1-%E6%B7%BB%E5%8A%A0%E6%8E%A8%E5%B9%BF%E4%BD%8D
func (c *Client) PromotionAdd(promotionSourceName string) *PromotionAddResult {
func (c *Client) PromotionAdd(ctx context.Context, promotionSourceName string) *PromotionAddResult {
// 参数
params := gorequest.NewParams()
params.Set("promotionSourceName", promotionSourceName) // 推广位名称
// 请求
request, err := c.request(apiUrl+fmt.Sprintf("/promoter/promotion/add?access_token%s", c.getAccessToken()), params, http.MethodPost)
request, err := c.request(ctx, apiUrl+fmt.Sprintf("/promoter/promotion/add?access_token%s", c.getAccessToken(ctx)), params, http.MethodPost)
// 定义
var response PromotionAddResponse
err = json.Unmarshal(request.ResponseBody, &response)

5
promoter.promotion.del.go
Unescape View File

@ -1,6 +1,7 @@
package wechatunion
import (
"context"
"encoding/json"
"fmt"
"go.dtapp.net/gorequest"
@ -25,13 +26,13 @@ func newPromotionDelResult(result PromotionDelResponse, body []byte, http gorequ
// PromotionDel 删除某个推广位
// https://developers.weixin.qq.com/doc/ministore/union/access-guidelines/promoter/api/promotion.html#_3-%E7%BC%96%E8%BE%91%E6%8E%A8%E5%B9%BF%E4%BD%8D
func (c *Client) PromotionDel(promotionSourcePid, promotionSourceName string) *PromotionDelResult {
func (c *Client) PromotionDel(ctx context.Context, promotionSourcePid, promotionSourceName string) *PromotionDelResult {
// 参数
params := gorequest.NewParams()
params.Set("promotionSourcePid", promotionSourcePid) // 推广位PID
params.Set("promotionSourceName", promotionSourceName) // 推广位名称
// 请求
request, err := c.request(apiUrl+fmt.Sprintf("/promoter/promotion/del?access_token%s", c.getAccessToken()), params, http.MethodPost)
request, err := c.request(ctx, apiUrl+fmt.Sprintf("/promoter/promotion/del?access_token%s", c.getAccessToken(ctx)), params, http.MethodPost)
// 定义
var response PromotionDelResponse
err = json.Unmarshal(request.ResponseBody, &response)

5
promoter.promotion.list.go
Unescape View File

@ -1,6 +1,7 @@
package wechatunion
import (
"context"
"encoding/json"
"fmt"
"go.dtapp.net/gorequest"
@ -33,13 +34,13 @@ func newPromotionListResult(result PromotionListResponse, body []byte, http gore
// PromotionList 获取推广位列表
// https://developers.weixin.qq.com/doc/ministore/union/access-guidelines/promoter/api/promotion.html#_4-%E8%8E%B7%E5%8F%96%E6%8E%A8%E5%B9%BF%E4%BD%8D%E5%88%97%E8%A1%A8
func (c *Client) PromotionList(start int, limit int) *PromotionListResult {
func (c *Client) PromotionList(ctx context.Context, start int, limit int) *PromotionListResult {
// 参数
params := gorequest.NewParams()
params.Set("start", start) // 偏移
params.Set("limit", limit) // 每页条数
// 请求
request, err := c.request(apiUrl+fmt.Sprintf("/promoter/promotion/list?access_token%s", c.getAccessToken()), params, http.MethodGet)
request, err := c.request(ctx, apiUrl+fmt.Sprintf("/promoter/promotion/list?access_token%s", c.getAccessToken(ctx)), params, http.MethodGet)
// 定义
var response PromotionListResponse
err = json.Unmarshal(request.ResponseBody, &response)

5
promoter.promotion.upd.go
Unescape View File

@ -1,6 +1,7 @@
package wechatunion
import (
"context"
"encoding/json"
"fmt"
"go.dtapp.net/gorequest"
@ -25,11 +26,11 @@ func newPromotionUpdResult(result PromotionUpdResponse, body []byte, http gorequ
// PromotionUpd 编辑推广位
// https://developers.weixin.qq.com/doc/ministore/union/access-guidelines/promoter/api/promotion.html#_3-%E7%BC%96%E8%BE%91%E6%8E%A8%E5%B9%BF%E4%BD%8D
func (c *Client) PromotionUpd(notMustParams ...gorequest.Params) *PromotionUpdResult {
func (c *Client) PromotionUpd(ctx context.Context, notMustParams ...gorequest.Params) *PromotionUpdResult {
// 参数
params := gorequest.NewParamsWith(notMustParams...)
// 请求
request, err := c.request(apiUrl+fmt.Sprintf("/promoter/promotion/upd?access_token%s", c.getAccessToken()), params, http.MethodPost)
request, err := c.request(ctx, apiUrl+fmt.Sprintf("/promoter/promotion/upd?access_token%s", c.getAccessToken(ctx)), params, http.MethodPost)
// 定义
var response PromotionUpdResponse
err = json.Unmarshal(request.ResponseBody, &response)

9
request.go
Unescape View File

@ -1,9 +1,12 @@
package wechatunion
import "go.dtapp.net/gorequest"
import (
"context"
"go.dtapp.net/gorequest"
)
// 请求
func (c *Client) request(url string, params map[string]interface{}, method string) (gorequest.Response, error) {
func (c *Client) request(ctx context.Context, url string, params map[string]interface{}, method string) (gorequest.Response, error) {
// 创建请求
client := c.client
@ -28,7 +31,7 @@ func (c *Client) request(url string, params map[string]interface{}, method strin
// 日志
if c.config.PgsqlDb != nil {
go c.log.GormMiddleware(request, Version)
go c.log.GormMiddleware(ctx, request, Version)
}
if c.config.MongoDb != nil {
go c.log.MongoMiddleware(request)

Write Preview
Loading…
Cancel
Save