You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
go-library/service/pinduoduo/client.go

115 lines
2.7 KiB

package pinduoduo
import (
"fmt"
2 years ago
"go.dtapp.net/library/utils/golog"
"go.dtapp.net/library/utils/gorequest"
"go.dtapp.net/library/utils/gostring"
"gorm.io/gorm"
"regexp"
"strconv"
"strings"
)
type ConfigClient struct {
ClientId string // POP分配给应用的client_id
ClientSecret string // POP分配给应用的client_secret
MediaId string // 媒体ID
Pid string // 推广位
PgsqlDb *gorm.DB // pgsql数据库
}
type Client struct {
client *gorequest.App // 请求客户端
log *golog.Api // 日志服务
logTableName string // 日志表名
logStatus bool // 日志状态
config *ConfigClient // 配置
}
func NewClient(config *ConfigClient) *Client {
c := &Client{config: config}
c.config = config
c.client = gorequest.NewHttp()
c.client.Uri = "https://gw-api.pinduoduo.com/api/router"
if c.config.PgsqlDb != nil {
c.logStatus = true
c.logTableName = "pinduoduo"
c.log = golog.NewApi(&golog.ApiConfig{
Db: c.config.PgsqlDb,
TableName: c.logTableName,
})
}
return c
}
type ErrResp struct {
ErrorResponse struct {
ErrorMsg string `json:"error_msg"`
SubMsg string `json:"sub_msg"`
SubCode interface{} `json:"sub_code"`
ErrorCode int `json:"error_code"`
RequestId string `json:"request_id"`
} `json:"error_response"`
}
type CustomParametersResult struct {
Sid string `json:"sid"`
Uid string `json:"uid"`
}
func (c *Client) request(params map[string]interface{}) (resp gorequest.Response, err error) {
// 签名
c.Sign(params)
// 创建请求
client := c.client
// 设置参数
client.SetParams(params)
// 发起请求
request, err := client.Get()
if err != nil {
return gorequest.Response{}, err
}
// 日志
if c.logStatus == true {
go c.postgresqlLog(gostring.ToString(params["type"]), request)
}
return request, err
}
func (c *Client) SalesTipParseInt64(salesTip string) int64 {
parseInt, err := strconv.ParseInt(salesTip, 10, 64)
if err != nil {
salesTipStr := salesTip
if strings.Contains(salesTip, "万+") {
salesTipStr = strings.Replace(salesTip, "万+", "0000", -1)
} else if strings.Contains(salesTip, "万") {
salesTipStr = strings.Replace(salesTip, "万", "000", -1)
}
re := regexp.MustCompile("[0-9]+")
SalesTipMap := re.FindAllString(salesTipStr, -1)
if len(SalesTipMap) == 2 {
return gostring.ToInt64(fmt.Sprintf("%s%s", SalesTipMap[0], SalesTipMap[1]))
} else if len(SalesTipMap) == 1 {
return gostring.ToInt64(SalesTipMap[0])
} else {
return 0
}
} else {
return parseInt
}
}
func (c *Client) CommissionIntegralToInt64(GoodsPrice, CouponProportion int64) int64 {
return (GoodsPrice * CouponProportion) / 1000
}