Skip to content

L
library
提交 ec5fe1a2 authored 作者: zhanglibo's avatar zhanglibo
浏览文件
操作

淘特

上级 2fa89b3f
全部展开 隐藏空白字符变更
内嵌 并排
正在显示 包含 602 行增加 和 184 行删除
upstream/itao/itao.go
浏览文件 @ ec5fe1a2
......@@ -8,9 +8,10 @@ import (
"github.com/gogf/gf/encoding/gjson"
"github.com/gogf/gf/errors/gerror"
"github.com/gogf/gf/frame/g"
"github.com/gogf/gf/os/gctx"
"github.com/gogf/gf/os/gtime"
"github.com/gogf/gf/os/gtimer"
"github.com/gogf/gf/util/gconv"
"github.com/gogf/gf/util/gutil"
"net/url"
"sort"
"strings"
......@@ -31,13 +32,17 @@ const Host = "https://open.huoju6.com/openapi/param2/1/com.huoju6.open/"
func New(req *Config) {
server = req
gtimer.Add(time.Hour, func() {
var ctx = gctx.New()
_, _ = server.accessToken(ctx)
})
return
}
type CommonRes struct {
Success bool `json:"success"`
ErrorCode string `json:"errorCode"`
ErrorMessage string `json:"errorMessage"`
Success bool `json:"success"`
ErrCode string `json:"errCode"`
ErrMsg string `json:"errMsg"`
}
func generate(req string) (res string) {
......@@ -73,7 +78,7 @@ func sign(method string, req g.Map) (err error) {
}
func (s *Config) Post(ctx context.Context, method string, params g.Map) (str string, err error) {
params["access_token"], err = s.AccessToken(ctx)
params["access_token"], err = s.GetAccessToken(ctx)
if err != nil {
return
}
......@@ -96,7 +101,7 @@ func Post(ctx context.Context, method string, params g.Map) (str string, err err
defer func() {
_ = resp.Close()
paramStr := gjson.New(params).MustToJsonString()
ctx = context.WithValue(ctx, "Method", "GET")
ctx = context.WithValue(ctx, "Method", "POST")
ctx = context.WithValue(ctx, "URI", Url)
if err != nil {
g.Log().Cat(PkgName).Ctx(ctx).Infof("参数【%v】错误【%v】响应时间【%vms】", paramStr, err.Error(), gtime.TimestampMilli()-Start)
......@@ -111,7 +116,7 @@ func Post(ctx context.Context, method string, params g.Map) (str string, err err
}
func (s *Config) Get(ctx context.Context, method string, params g.Map) (str string, err error) {
params["access_token"], err = s.AccessToken(ctx)
params["access_token"], err = s.GetAccessToken(ctx)
if err != nil {
return
}
......@@ -152,7 +157,7 @@ func Get(ctx context.Context, method string, params g.Map) (str string, err erro
}
func (s *Config) AccessToken(ctx context.Context) (res string, err error) {
func (s *Config) GetAccessToken(ctx context.Context) (res string, err error) {
var conn = g.Redis().Conn()
defer func() {
_ = conn.Close()
......@@ -163,28 +168,46 @@ func (s *Config) AccessToken(ctx context.Context) (res string, err error) {
err = gerror.New("获取token 失败")
return
}
var token *AuthTokenRes
_ = gjson.New(cache).Scan(&token)
if token == nil {
var result *AuthTokenRes
_ = gjson.New(cache).Scan(&result)
if result == nil || result.AccessToken == "" {
err = gerror.New("获取token 失败")
return
}
if token.AccessTokenExpireTime < gtime.Now().TimestampMilli() {
if token.RefreshTokenExpireTime < gtime.Now().TimestampMilli() {
err = gerror.New("获取token 失败")
return
}
token, err = Auth.Token(ctx, token.RefreshToken, 2)
if result.AccessTokenExpireTime < gtime.TimestampMilli() {
result, err = s.accessToken(ctx)
if err != nil {
return
}
if token.Code != "success" {
err = gerror.New("获取token 失败")
return
}
_, _ = conn.Do("HMSET", append(g.Slice{CacheKey}, gutil.StructToSlice(token)...)...)
}
res = result.AccessToken
return
}
//accessToken 刷新
func (s *Config) accessToken(ctx context.Context) (res *AuthTokenRes, err error) {
var conn = g.Redis().Conn()
defer func() {
_ = conn.Close()
}()
_, _ = conn.DoVar("SELECT", 10)
cache, _ := conn.DoVar("HGETALL", CacheKey)
if cache.IsEmpty() {
err = gerror.New("获取token 失败")
return
}
_ = gjson.New(cache).Scan(&res)
if res.AccessTokenExpireTime > gtime.Now().Add(time.Hour).TimestampMilli() {
return
}
res, err = Auth.Token(ctx, res.RefreshToken, 2)
if err != nil {
return
}
if res.Code != "success" {
err = gerror.New("获取token 失败")
return
}
res = token.AccessToken
_, _ = conn.Do("HMSET", CacheKey, "accessToken", res.AccessToken, "accessTokenExpireTime", res.AccessTokenExpireTime)
return
}
upstream/itao/itao_address.go
浏览文件 @ ec5fe1a2
......@@ -64,18 +64,16 @@ type AddressParseReq struct {
type AddressParseRes struct {
Result struct {
Result struct {
City string `json:"city"`
CityId int `json:"cityId"`
District string `json:"district"`
DistrictId int `json:"districtId"`
Prov string `json:"prov"`
ProvId int `json:"provId"`
Town string `json:"town"`
TownId int `json:"townId"`
} `json:"result"`
Success bool `json:"success"`
City string `json:"city"`
CityId int `json:"cityId"`
District string `json:"district"`
DistrictId int `json:"districtId"`
Prov string `json:"prov"`
ProvId int `json:"provId"`
Town string `json:"town"`
TownId int `json:"townId"`
} `json:"result"`
Success bool `json:"success"`
}
//Parse 地址解析
......
upstream/itao/itao_auth.go
浏览文件 @ ec5fe1a2
......@@ -40,7 +40,7 @@ type AuthQrCodeRes struct {
func (s auth) QrCode(ctx context.Context) (res *AuthQrCodeRes, err error) {
method := "tt.authority.generateQrCode"
result, err := server.Get(ctx, method, g.Map{
result, err := Get(ctx, method, g.Map{
"bId": server.AppKey,
})
_ = gjson.New(result).Scan(&res)
......@@ -75,7 +75,7 @@ func (s auth) Token(ctx context.Context, code string, Type int) (res *AuthTokenR
request["grantType"] = "refreshToken"
}
result, err := server.Get(ctx, method, request)
result, err := Get(ctx, method, request)
_ = gjson.New(result).Scan(&res)
return
}
......
upstream/itao/itao_goods.go
浏览文件 @ ec5fe1a2
......@@ -7,43 +7,76 @@ import (
"github.com/gogf/gf/util/gconv"
)
type goodsItao struct {
type goods struct {
}
var Goods = goodsItao{}
var Goods = goods{}
type GoodsListReq struct {
Q string `json:"q,omitempty"` //关键词
Sort string `json:"sort,omitempty"` //排序参数 价格降序:sort=price:des 价格升序:sort=price:asc 综合排序:sort=popular:des 销量降序:sort=sales:des
Price string `json:"price,omitempty"`
Cate string `json:"cate,omitempty"`
S int `json:"s,omitempty"`
N int `json:"n,omitempty"`
Feature string `json:"feature,omitempty"`
Q string `json:"q,omitempty"` //关键词
SessionId string `json:"sessionId,omitempty"` //长度不要超过32位，用来分页去重，当前请求只是翻页，则这个值不要改变
Sort string `json:"sort,omitempty"` //排序参数
// 价格降序:sort=price:des
//价格升序:sort=price:asc
//综合排序:sort=popular:des
//销量降序:sort=sales:des
//客户响应率倒序 sort=cst_reply_rate:des
//客户响应率正序 sort=cst_reply_rate:acs
//好评率倒序 sort=pos_review_all_rate_30d:des
//好评率正序 sort=pos_review_all_rate:acs
//退货率倒序 sort=tj_pinzhi_rfd_rate:des
//退货率正序 sort=tj_pinzhi_rfd_rate:acs
//发货时效倒序 sort=ship_ord_rate_7d_104:des
//发货时效正序 sort=ship_ord_rate_7d_104:acs
Price string `json:"price,omitempty"` //价格筛选
//89~248 从89元到248元
//89~ 大于89元
//~248 小于248元
Cate string `json:"cate,omitempty"` //一级类目筛选
S int `json:"s"` //默认0，不是页码，是每次查询的起始位置，相当于 页码x每页数量
N int `json:"n"` //默认20， 每页数量，建议值10，不宜过大
Feature string `json:"feature,omitempty"` //字符串，不是json 请求示例 ：{\"poolId\":\"1001\"}
//目前支持的key
//精选商品池映射 poolId
//退货率 refundRateBegin
//退货率 refundRateEnd
//好评率 posReviewRateBegin
//好评率 posReviewRateEnd
//客服响应率 cstRateBegin
//客服响应率 cstRateEnd
//发货时效 shipRateBegin
//发货时效 shipRateEnd
}
type GoodsListRes struct {
ErrorMessage string `json:"error_message"`
ErrorCode string `json:"error_code"`
TotalCount int `json:"totalCount"`
PageIndex int `json:"pageIndex"`
PageSize int `json:"pageSize"`
Auctions []struct {
Nid string `json:"nid"`
Title string `json:"title"`
ReservePrice string `json:"reservePrice"`
ZkFinalPrice string `json:"zkFinalPrice"`
TejiaTotalSoldQuantity string `json:"tejiaTotalSoldQuantity"`
PictUrl string `json:"pictUrl"`
LevelOneCat string `json:"levelOneCat"`
Category string `json:"category"`
} `json:"auctions"`
Result struct {
Auctions []struct {
Category string `json:"category"`
CstRate string `json:"cstRate"`
LevelOneCat string `json:"levelOneCat"`
Nid string `json:"nid"`
PictUrl string `json:"pictUrl"`
PosReviewRate string `json:"posReviewRate"`
RefundRate string `json:"refundRate"`
ReservePrice string `json:"reservePrice"`
ShipIn24 string `json:"shipIn24"`
ShipRate string `json:"shipRate"`
TejiaTotalSoldQuantity string `json:"tejiaTotalSoldQuantity"`
Title string `json:"title"`
ZkFinalPrice string `json:"zkFinalPrice"`
} `json:"auctions"`
PageIndex int `json:"pageIndex"`
PageSize int `json:"pageSize"`
TotalCount int `json:"totalCount"`
} `json:"result"`
}
func (goodsItao) List(ctx context.Context, req GoodsListReq) (res *GoodsListRes, err error) {
method := "tt.item.list"
func (goods) List(ctx context.Context, req GoodsListReq) (res *GoodsListRes, err error) {
method := "tt.item.list.v2"
result, err := server.Get(ctx, method, gconv.Map(req))
result, err := server.Get(ctx, method, g.Map{
"request": req,
})
_ = gjson.New(result).Scan(&res)
return
}
......@@ -121,7 +154,7 @@ type GoodsItem struct {
}
//Detail 详情
func (goodsItao) Detail(ctx context.Context, GoodsID string) (res *GoodsDetailRes, err error) {
func (goods) Detail(ctx context.Context, GoodsID string) (res *GoodsDetailRes, err error) {
method := "tt.item.detail.v2"
var request = GoodsDetailReq{
AppKey: gconv.Int(server.AppKey),
......@@ -317,7 +350,7 @@ type GoodsDescItem struct {
}
//Desc 详情描述
func (goodsItao) Desc(ctx context.Context, GoodsID string) (res *GoodsDescRes, err error) {
func (goods) Desc(ctx context.Context, GoodsID string) (res *GoodsDescRes, err error) {
method := "tt.item.desc"
result, err := server.Get(ctx, method, g.Map{
......@@ -348,7 +381,7 @@ type GoodsCategoryRes struct {
}
//Category 商品类目
func (goodsItao) Category(ctx context.Context, GoodsID string) (res *GoodsCategoryRes, err error) {
func (goods) Category(ctx context.Context, GoodsID string) (res *GoodsCategoryRes, err error) {
method := "tt.item.cateInfo"
result, err := server.Get(ctx, method, g.Map{
......
upstream/itao/itao_logistics.go
浏览文件 @ ec5fe1a2
......@@ -6,10 +6,10 @@ import (
"github.com/gogf/gf/frame/g"
)
type logisticsItao struct {
type logistics struct {
}
var Logistics = logisticsItao{}
var Logistics = logistics{}
type LogisticsTraceRes struct {
Result struct {
......@@ -45,7 +45,7 @@ type LogisticsTraceRes struct {
}
//Trace 物流轨迹
func (logisticsItao) Trace(ctx context.Context, req string) (res *LogisticsTraceRes, err error) {
func (logistics) Trace(ctx context.Context, req string) (res *LogisticsTraceRes, err error) {
method := "tt.logistics.detail"
result, err := server.Post(ctx, method, g.Map{
......@@ -56,3 +56,43 @@ func (logisticsItao) Trace(ctx context.Context, req string) (res *LogisticsTrace
_ = gjson.New(result).Scan(&res)
return
}
type LogisticsCompanyRes struct {
Result []LogisticsCompanyItem `json:"result"`
Success bool `json:"success"`
}
type LogisticsCompanyItem struct {
Code string `json:"code"`
Name string `json:"name"`
Id int64 `json:"id"`
Type int `json:"type"`
}
type LogisticsCompany struct {
Result map[string][]interface{} `json:"result"`
Success bool `json:"success"`
}
//Company 物流公司
func (logistics) Company(ctx context.Context, req string) (res *LogisticsCompanyRes, err error) {
method := "tt.refund.queryLogisticList"
result, err := server.Post(ctx, method, g.Map{
"request": g.Map{
"bizOrderId": req,
},
})
var data *LogisticsCompany
_ = gjson.New(result).Scan(&data)
res = new(LogisticsCompanyRes)
res.Success = data.Success
for _, item := range data.Result {
for _, val := range item {
var value []LogisticsCompanyItem
_ = gjson.New(val).Scan(&value)
res.Result = append(res.Result, value...)
}
}
return
}
upstream/itao/itao_pay.go 0 → 100644
浏览文件 @ ec5fe1a2
package itao
import (
"context"
"github.com/gogf/gf/encoding/gjson"
"github.com/gogf/gf/frame/g"
)
type pay struct {
}
var Pay = pay{}
type PayAuthRes struct {
}
func (s pay) Auth(ctx context.Context) (res *PayAuthRes, err error) {
method := "tt.agreementpay.genersignurl"
result, err := server.Post(ctx, method, g.Map{
"request": g.Map{},
})
_ = gjson.NewWithOptions(result, gjson.Options{
StrNumber: true,
}).Scan(&res)
return
}
upstream/itao/itao_refund.go
浏览文件 @ ec5fe1a2
package itao
import (
"context"
"github.com/gogf/gf/encoding/gjson"
"github.com/gogf/gf/frame/g"
)
type refund struct {
}
var Refund = refund{}
type RefundPic struct {
MessagePic string `json:"messagePic"`
}
type RefundBeforeRes struct {
CommonRes
Result struct {
BizClaimTypeVOList []struct {
BizClaimType string `json:"bizClaimType"` //refund 仅退款 return_and_refund 退货退款
RefundTypeTitle string `json:"refundTypeTitle"`
} `json:"bizClaimTypeVOList"`
} `json:"result"`
}
//Before 退款类型
func (s refund) Before(ctx context.Context, req string) (res *RefundBeforeRes, err error) {
method := "tt.refund.refundApplyType"
result, err := server.Post(ctx, method, g.Map{
"request": g.Map{
"bizOrderId": req,
},
})
_ = gjson.NewWithOptions(result, gjson.Options{
StrNumber: true,
}).Scan(&res)
return
}
type RefundReasonReq struct {
BizOrderId string `json:"bizOrderId"`
BizClaimType string `json:"bizClaimType"`
GoodsStatus string `json:"goodsStatus,omitempty"`
}
type RefundReasonRes struct {
CommonRes
Result struct {
MaxRefundFee int `json:"maxRefundFee"`
MinRefundFee int `json:"minRefundFee"`
MustProof bool `json:"mustProof"`
RefundTextWrapperVOList []struct {
Name string `json:"name"`
ReasonGroup int `json:"reasonGroup"`
TextId int `json:"textId"`
} `json:"refundTextWrapperVOList"`
} `json:"result"`
}
//Reason 原因
func (s refund) Reason(ctx context.Context, req RefundReasonReq) (res *RefundReasonRes, err error) {
method := "tt.refund.refundApplyInit"
result, err := server.Post(ctx, method, g.Map{
"request": req,
})
_ = gjson.NewWithOptions(result, gjson.Options{
StrNumber: true,
}).Scan(&res)
return
}
type RefundCreateReq struct {
BizOrderId string `json:"bizOrderId"` //子订单号
BizClaimType string `json:"bizClaimType"` //refund 仅退款 return_and_refund 退货退款
GoodsStatus string `json:"goodsStatus,omitempty"` //"1"：未收到货 "2"：未已收到货 未发货情况下，千万不要传
RefundFee string `json:"refundFee"` //退款金额，单位是分
ApplyRefundTextId string `json:"applyRefundTextId"` //原因ID
LeaveMessagePics []RefundPic `json:"leaveMessagePics,omitempty"`
}
type RefundCreateRess struct {
CommonRes
Result struct {
DisputeId string `json:"disputeId"`
} `json:"result"`
}
//Create 申请
func (s refund) Create(ctx context.Context, req RefundCreateReq, image ...string) (res *RefundCreateRess, err error) {
method := "tt.refund.refundSubmit"
if len(image) > 0 {
for _, item := range image {
req.LeaveMessagePics = append(req.LeaveMessagePics, RefundPic{MessagePic: item})
}
}
result, err := server.Post(ctx, method, g.Map{
"request": req,
})
_ = gjson.NewWithOptions(result, gjson.Options{
StrNumber: true,
}).Scan(&res)
return
}
//Cancle 取消售后
//`bizOrderId` 子订单号
//`disputeId` 售后单号
func (s refund) Cancle(ctx context.Context, bizOrderId, disputeId string) (res *CommonRes, err error) {
method := "tt.refund.refundRevoke"
result, err := server.Post(ctx, method, g.Map{
"request": g.Map{
"bizOrderId": bizOrderId,
"disputeId": disputeId,
},
})
_ = gjson.NewWithOptions(result, gjson.Options{
StrNumber: true,
}).Scan(&res)
return
}
type RefundSubmitReq struct {
DisputeId string `json:"disputeId"`
BizOrderId string `json:"bizOrderId"`
CompanyCode string `json:"logisticsCompanyCode"`
CompanyId string `json:"logisticsCompanyId"`
CompanyName string `json:"logisticsCompanyName"`
LogisticsNo string `json:"logisticsNo"`
MobileNum string `json:"mobileNum"`
LeaveMessagePics []RefundPic `json:"leaveMessagePics"`
}
type RefundSubmitRes struct {
CommonRes
Result struct {
DisputeStatus string `json:"disputeStatus"`
//REFUND_WAIT_SELLER_AGREE："买家已经申请退款，等待卖家同意"；
//REFUND_WAIT_BUYER_RETURN_GOODS："卖家已经同意退款，等待买家退货"；
//REFUND_WAIT_SELLER_CONFIRM_GOODS："买家已经退货，等待卖家确认收货"；
//REFUND_CLOSED："退款关闭"；
//REFUND_SUCCESS："退款成功"；
//REFUND_SELLER_REFUSE_BUYER："卖家拒绝退款"；
//REFUND_WAIT_BUYER_CONFIRM_REDO_SEND_GOODS："等待买家确认重新邮寄的货物"；
//REFUND_WAIT_SELLER_CONFIRM_RETURN_ADDRESS："等待卖家确认退货地址"
} `json:"result"`
}
//Submit 提交物流信息
func (s refund) Submit(ctx context.Context, req RefundSubmitReq, image ...string) (res *CommonRes, err error) {
method := "tt.refund.refundSubmit"
if len(image) > 0 {
for _, item := range image {
req.LeaveMessagePics = append(req.LeaveMessagePics, RefundPic{MessagePic: item})
}
}
result, err := server.Post(ctx, method, g.Map{
"request": req,
})
_ = gjson.NewWithOptions(result, gjson.Options{
StrNumber: true,
}).Scan(&res)
return
}
type RefundDetailRes struct {
CommonRes
Result struct {
DisputeId int64 `json:"disputeId"` //退款编号
DisputeStatus string `json:"disputeStatus"`
//退款状态
//REFUND_WAIT_SELLER_AGREE："买家已经申请退款，等待卖家同意"；
//REFUND_WAIT_BUYER_RETURN_GOODS："卖家已经同意退款，等待买家退货"；
//REFUND_WAIT_SELLER_CONFIRM_GOODS："买家已经退货，等待卖家确认收货"；
//REFUND_CLOSED："退款关闭"；
//REFUND_SUCCESS："退款成功"；
//REFUND_SELLER_REFUSE_BUYER："卖家拒绝退款"；
//REFUND_WAIT_BUYER_CONFIRM_REDO_SEND_GOODS："等待买家确认重新邮寄的货物"；
//REFUND_WAIT_SELLER_CONFIRM_RETURN_ADDRESS："等待卖家确认退货地址"
DisputeTimeOut struct {
Duration int `json:"duration"`
GmtCreate int64 `json:"gmtCreate"`
Running bool `json:"running"`
TimeoutActionType string `json:"timeoutActionType"`
} `json:"disputeTimeOut"`
ReasonName string `json:"reasonName"` //退款原因名称
RefundFee int `json:"refundFee"` //退款金额，单位分
ShippingAddressWrapperDTO struct {
AddressDetail string `json:"addressDetail"`
AreaName string `json:"areaName"`
CityName string `json:"cityName"`
ConsigneeFullName string `json:"consigneeFullName"`
DivisionCode string `json:"divisionCode"`
Mobile string `json:"mobile"`
PostCode string `json:"postCode"`
ProvinceName string `json:"provinceName"`
TownName string `json:"townName"`
} `json:"shippingAddressWrapperDTO"`
} `json:"result"`
}
//Detail 详情
func (s refund) Detail(ctx context.Context, bizOrderId, disputeId string) (res *RefundDetailRes, err error) {
method := "tt.refund.queryRefundDetail"
result, err := server.Post(ctx, method, g.Map{
"request": g.Map{
"bizOrderId": bizOrderId,
"disputeId": disputeId,
},
})
_ = gjson.NewWithOptions(result, gjson.Options{
StrNumber: true,
}).Scan(&res)
return
}
upstream/itao/itao_upload.go 0 → 100644
浏览文件 @ ec5fe1a2
package itao
import (
"context"
"github.com/gogf/gf/encoding/gjson"
"github.com/gogf/gf/frame/g"
"github.com/gogf/gf/os/gtime"
"github.com/gogf/gf/util/gconv"
"net/url"
"time"
)
type upload struct {
}
var Upload = upload{}
type UploadImageReq struct {
FileName string `json:"fileName"`
FileContent string `json:"fileContent"`
ImageData string `json:"imageData"`
}
type UploadImageRes struct {
Code string `json:"code"`
Message string `json:"message"`
FileUrl string `json:"fileUrl"`
}
func (s upload) Image(ctx context.Context, req UploadImageReq) (res *UploadImageRes, err error) {
method := "tt.upload.image"
req.FileContent = "base64"
var request = g.Map{}
request["access_token"], err = server.GetAccessToken(ctx)
if err != nil {
return
}
result, err := s.post(ctx, method, request, gconv.Map(req))
_ = gjson.New(result).Scan(&res)
return
}
func (upload) post(ctx context.Context, method string, params, req g.Map) (str string, err error) {
Start := gtime.TimestampMilli()
err = sign(method, params)
if err != nil {
return
}
Url := Host + method + "/" + server.AppKey
Values := url.Values{}
for k, v := range params {
Values.Add(k, gconv.String(v))
}
resp, err := g.Client().ContentJson().Timeout(time.Second*5).Post(Url+"?"+Values.Encode(), req)
defer func() {
_ = resp.Close()
paramStr := gjson.New(params).MustToJsonString()
ctx = context.WithValue(ctx, "Method", "POST")
ctx = context.WithValue(ctx, "URI", Url)
if err != nil {
g.Log().Cat(PkgName).Ctx(ctx).Infof("参数【%v】错误【%v】响应时间【%vms】", paramStr, err.Error(), gtime.TimestampMilli()-Start)
} else {
g.Log().Cat(PkgName).Ctx(ctx).Infof("参数【%v】响应【%v】响应时间【%vms】", paramStr, str, gtime.TimestampMilli()-Start)
}
}()
str = resp.ReadAllString()
return
}
Markdown 格式
0% 或
您添加了 0 人 到此讨论。请谨慎行事。
请先完成此评论的编辑！
请 注册 或者 后发表评论