221 lines
8.5 KiB
Go
221 lines
8.5 KiB
Go
package client
|
||
|
||
import (
|
||
"context"
|
||
"encoding/json"
|
||
"errors"
|
||
"time"
|
||
|
||
"repository.lenntc.com/lenntc/third-platform-sdk/sdk/dunion-go-sdk/const"
|
||
"repository.lenntc.com/lenntc/third-platform-sdk/sdk/dunion-go-sdk/model"
|
||
"repository.lenntc.com/lenntc/third-platform-sdk/sdk/dunion-go-sdk/util"
|
||
)
|
||
|
||
type client struct {
|
||
AppKey string
|
||
AccessKey string
|
||
}
|
||
|
||
type UnionClient interface {
|
||
GenerateH5Link(ctx context.Context, activityID, promotionID int64, sourceID string, opt ...model.Option) (*model.LinkResponse, error)
|
||
GenerateMiniLink(ctx context.Context, activityID, promotionID int64, sourceID string, opt ...model.Option) (*model.LinkResponse, error)
|
||
GenerateAlipayMiniLink(ctx context.Context, activityID, promotionID int64, sourceID string, opt ...model.Option) (*model.LinkResponse, error)
|
||
GenerateH5Code(ctx context.Context, dsi, sourceID string, opt ...model.Option) (*model.QrcodeResponse, error)
|
||
GenerateMiniCode(ctx context.Context, dsi, sourceID string, opt ...model.Option) (*model.QrcodeResponse, error)
|
||
GeneratePoster(ctx context.Context, dsi, sourceID string, opt ...model.Option) (*model.PosterResponse, error)
|
||
QueryOrderList(ctx context.Context, startTime, endTime time.Time, type_ string, page, size int, opt ...model.Option) (*model.OrderResponse, error)
|
||
GenerateH5CodeDirectly(ctx context.Context, activityID, promotionID int64, sourceID string, opt ...model.Option) (*model.QrcodeResponse, error)
|
||
MockOrderCallback(ctx context.Context, dsi string, sourceID string, type_ int, opt ...model.Option) (*model.OrderCallbackResponse, error)
|
||
GenerateMiniCodeDirectly(ctx context.Context, activityID, promotionID int64, sourceID string, opt ...model.Option) (*model.QrcodeResponse, error)
|
||
GeneratePosterDirectly(ctx context.Context, activityID, promotionID int64, sourceID string, opt ...model.Option) (*model.PosterResponse, error)
|
||
SelfQueryOrder(ctx context.Context, orderID string, opt ...model.Option) (*model.SelfQueryResponse, error)
|
||
}
|
||
|
||
func NewUnionClient(appKey string, accessKey string) UnionClient {
|
||
return &client{
|
||
AppKey: appKey,
|
||
AccessKey: accessKey,
|
||
}
|
||
}
|
||
|
||
// GenerateH5Link 生成h5推广链接
|
||
func (s client) GenerateH5Link(ctx context.Context, activityID, promotionID int64, sourceID string, opt ...model.Option) (*model.LinkResponse, error) {
|
||
body := map[string]interface{}{
|
||
"activity_id": activityID,
|
||
"link_type": "h5",
|
||
"promotion_id": promotionID,
|
||
"source_id": sourceID,
|
||
}
|
||
response, err := util.Post(ctx, s.AppKey, s.AccessKey, consts.GenerateLinkUrl, body, opt...)
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
result := &model.LinkResponse{}
|
||
err = json.Unmarshal(response, result)
|
||
return result, err
|
||
}
|
||
|
||
// GenerateMiniLink 生成小程序页面推广路径
|
||
func (s client) GenerateMiniLink(ctx context.Context, activityID, promotionID int64, sourceID string, opt ...model.Option) (*model.LinkResponse, error) {
|
||
body := map[string]interface{}{
|
||
"activity_id": activityID,
|
||
"link_type": "mini",
|
||
"promotion_id": promotionID,
|
||
"source_id": sourceID,
|
||
}
|
||
response, err := util.Post(ctx, s.AppKey, s.AccessKey, consts.GenerateLinkUrl, body, opt...)
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
result := &model.LinkResponse{}
|
||
err = json.Unmarshal(response, result)
|
||
return result, err
|
||
}
|
||
|
||
// GenerateAlipayMiniLink 生成支付宝小程序页面推广路径
|
||
func (s client) GenerateAlipayMiniLink(ctx context.Context, activityID, promotionID int64, sourceID string, opt ...model.Option) (*model.LinkResponse, error) {
|
||
body := map[string]interface{}{
|
||
"activity_id": activityID,
|
||
"link_type": "alipay_mini",
|
||
"promotion_id": promotionID,
|
||
"source_id": sourceID,
|
||
}
|
||
response, err := util.Post(ctx, s.AppKey, s.AccessKey, consts.GenerateLinkUrl, body, opt...)
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
result := &model.LinkResponse{}
|
||
err = json.Unmarshal(response, result)
|
||
return result, err
|
||
}
|
||
|
||
// GenerateH5Code 生成h5二维码，需先取链得到dsi
|
||
func (s client) GenerateH5Code(ctx context.Context, dsi, sourceID string, opt ...model.Option) (*model.QrcodeResponse, error) {
|
||
param := map[string]interface{}{
|
||
"dsi": dsi,
|
||
"source_id": sourceID,
|
||
"type": "h5",
|
||
}
|
||
response, err := util.Get(ctx, s.AppKey, s.AccessKey, consts.GenerateQrCodeUrl, param, opt...)
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
result := &model.QrcodeResponse{}
|
||
err = json.Unmarshal(response, result)
|
||
return result, err
|
||
}
|
||
|
||
// GenerateMiniCode 生成小程序太阳码，需先取链得到dsi
|
||
func (s client) GenerateMiniCode(ctx context.Context, dsi, sourceID string, opt ...model.Option) (*model.QrcodeResponse, error) {
|
||
param := map[string]interface{}{
|
||
"dsi": dsi,
|
||
"source_id": sourceID,
|
||
"type": "mini",
|
||
}
|
||
response, err := util.Get(ctx, s.AppKey, s.AccessKey, consts.GenerateQrCodeUrl, param, opt...)
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
result := &model.QrcodeResponse{}
|
||
err = json.Unmarshal(response, result)
|
||
return result, err
|
||
}
|
||
|
||
// GeneratePoster 生成推广海报，需先取链得到dsi
|
||
func (s client) GeneratePoster(ctx context.Context, dsi, sourceID string, opt ...model.Option) (*model.PosterResponse, error) {
|
||
param := map[string]interface{}{
|
||
"dsi": dsi,
|
||
"source_id": sourceID,
|
||
}
|
||
response, err := util.Get(ctx, s.AppKey, s.AccessKey, consts.GeneratePosterUrl, param, opt...)
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
result := &model.PosterResponse{}
|
||
err = json.Unmarshal(response, result)
|
||
return result, err
|
||
}
|
||
|
||
// QueryOrderList 查询订单列表，type_可用枚举见 const.OrderTypeEnergy等
|
||
func (s client) QueryOrderList(ctx context.Context, startTime, endTime time.Time, type_ string, page, size int, opt ...model.Option) (*model.OrderResponse, error) {
|
||
if page < 0 || page > 100 || size < 0 || size > 100 {
|
||
return nil, errors.New("分页参数不合法")
|
||
}
|
||
param := map[string]interface{}{
|
||
"pay_start_time": startTime.Unix(),
|
||
"pay_end_time": endTime.Unix(),
|
||
"page": page,
|
||
"size": size,
|
||
}
|
||
if len(type_) > 0 {
|
||
param["type"] = type_
|
||
}
|
||
response, err := util.Get(ctx, s.AppKey, s.AccessKey, consts.QueryOrderUrl, param, opt...)
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
result := &model.OrderResponse{}
|
||
err = json.Unmarshal(response, result)
|
||
return result, err
|
||
}
|
||
|
||
// MockOrderCallback 模拟订单回调，需先取链得到 dsi，type_ 可取 consts.MockPay 或 consts.MockRefund; 需在后台配置回调地址
|
||
func (s client) MockOrderCallback(ctx context.Context, dsi string, sourceID string, type_ int, opt ...model.Option) (*model.OrderCallbackResponse, error) {
|
||
param := map[string]interface{}{
|
||
"dsi": dsi,
|
||
"source_id": sourceID,
|
||
"type": type_,
|
||
}
|
||
response, err := util.Get(ctx, s.AppKey, s.AccessKey, consts.MockOrderUrl, param, opt...)
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
result := &model.OrderCallbackResponse{}
|
||
err = json.Unmarshal(response, result)
|
||
return result, err
|
||
}
|
||
|
||
// GenerateH5CodeDirectly 直接生成h5推广二维码，会内置请求一次取链接口
|
||
func (s client) GenerateH5CodeDirectly(ctx context.Context, activityID, promotionID int64, sourceID string, opt ...model.Option) (*model.QrcodeResponse, error) {
|
||
link, err := s.GenerateMiniLink(ctx, activityID, promotionID, sourceID, opt...)
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
dsi := link.Data.DSI
|
||
return s.GenerateH5Code(ctx, dsi, sourceID, opt...)
|
||
}
|
||
|
||
// GenerateMiniCodeDirectly 直接生成小程序推广太阳码，会内置请求一次取链接口
|
||
func (s client) GenerateMiniCodeDirectly(ctx context.Context, activityID, promotionID int64, sourceID string, opt ...model.Option) (*model.QrcodeResponse, error) {
|
||
link, err := s.GenerateMiniLink(ctx, activityID, promotionID, sourceID, opt...)
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
dsi := link.Data.DSI
|
||
return s.GenerateMiniCode(ctx, dsi, sourceID, opt...)
|
||
}
|
||
|
||
// GeneratePosterDirectly 直接生成推广海报，会内置请求一次取链接口
|
||
func (s client) GeneratePosterDirectly(ctx context.Context, activityID, promotionID int64, sourceID string, opt ...model.Option) (*model.PosterResponse, error) {
|
||
link, err := s.GenerateMiniLink(ctx, activityID, promotionID, sourceID, opt...)
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
dsi := link.Data.DSI
|
||
return s.GeneratePoster(ctx, dsi, sourceID, opt...)
|
||
}
|
||
|
||
// SelfQueryOrder 订单归因问题自查询
|
||
func (s client) SelfQueryOrder(ctx context.Context, orderID string, opt ...model.Option) (*model.SelfQueryResponse, error) {
|
||
param := map[string]interface{}{
|
||
"order_id": orderID,
|
||
}
|
||
response, err := util.Get(ctx, s.AppKey, s.AccessKey, consts.SelfQueryUrl, param, opt...)
|
||
if err != nil {
|
||
return nil, err
|
||
}
|
||
result := &model.SelfQueryResponse{}
|
||
err = json.Unmarshal(response, result)
|
||
return result, err
|
||
}
|