-
Notifications
You must be signed in to change notification settings - Fork 3
/
Copy pathsemi.order.go
167 lines (156 loc) · 7.41 KB
/
semi.order.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
package temu
import (
"context"
"errors"
validation "github.com/go-ozzo/ozzo-validation/v4"
"github.com/hiscaler/temu-go/entity"
"github.com/hiscaler/temu-go/helpers"
"github.com/hiscaler/temu-go/normal"
"github.com/hiscaler/temu-go/validators/is"
"gopkg.in/guregu/null.v4"
"time"
)
// 订单服务（半托管专属，必须在 US/EU 网关调用）
type semiOrderService service
type SemiOrderQueryParams struct {
normal.ParameterWithPager
PageNumber int `json:"pageNumber"` // 第几页
// 父单状态，默认查全部枚举值如下
// 0-全部
// 1-”PENDING“，挂起中
// 2-"UN_SHIPPING"，待发货
// 3-"CANCELED",已取消
// 4-"SHIPPED"，已发货
// 5-“RECEIPTED”,已签收
// 备注：
// 本本订单还存在如下状态
// 41-部分取消
// 51-部分签收
ParentOrderStatus null.Int `json:"parentOrderStatus,omitempty"` // 父单状态
CreateBefore string `json:"createBefore,omitempty"` // 父单创建时间结束查询时间，格式是秒时间戳。查询时间需要同时入参开始和结束时间才生效
CreateAfter string `json:"createAfter,omitempty"` // 父单创建时间开始查询时间，格式是秒时间戳
ParentOrderSnList []string `json:"parentOrderSnList,omitempty"` // 父单号列表，单次请求最多 20 个
ExpectShipLatestTimeStart string `json:"expectShipLatestTimeStart,omitempty"` // 期望最晚发货时间开始查询时间，格式是秒时间戳
ExpectShipLatestTimeEnd string `json:"expectShipLatestTimeEnd,omitempty"` // 期望最晚发货时间结束查询时间，格式是秒时间戳。查询时间需要同时入参开始和结束时间才生效
UpdateAtStart string `json:"updateAtStart,omitempty"` // 订单更新时间开始查询时间，格式是秒时间戳
UpdateAtEnd string `json:"updateAtEnd,omitempty"` // 订单更新时间结束查询时间，格式是秒时间戳。查询时间需要同时入参开始和结束时间才生效
RegionId int `json:"regionId"` // 区域 ID，美国-211
// 子订单履约类型，具体枚举值如下：
// 1. 数组只传入 fulfillBySeller，只返回卖家履约子订单列表
// 2. 数组只传入 fulfillByCooperativeWarehouse，只返回合作仓履约子订单列表
// 3. 数组传入 fulfillBySeller 和 fulfillByCooperativeWarehouse，返回卖家履约子订单列表+合作仓履约子订单列表
// 4. fulfillmentTypeList不传或者传了为空，默认返回卖家履约子订单列表
FulfillmentTypeList []string `json:"fulfillmentTypeList,omitempty"` // 子订单履约类型
ParentOrderLabel []string `json:"parentOrderLabel,omitempty"` // PO 单订单状态标签
SortBy null.String `json:"sortby,omitempty"` // 排序依据，倒序输出。默认按照订单创建时间，对应枚举为：updateTime、createTime
}
func (m SemiOrderQueryParams) validate() error {
return validation.ValidateStruct(&m,
validation.Field(&m.ParentOrderStatus, validation.When(m.ParentOrderStatus.Valid, validation.By(func(value interface{}) error {
v, ok := value.(null.Int)
if !ok {
return errors.New("无效的父单状态")
}
return validation.Validate(int(v.Int64), validation.In(
entity.SemiParentOrderStatusAll,
entity.SemiParentOrderStatusPending,
entity.SemiParentOrderStatusUnShipping,
entity.SemiParentOrderStatusCanceled,
entity.SemiParentOrderStatusShipped,
entity.SemiParentOrderStatusReceipted,
entity.SemiParentOrderStatusPartialCanceled,
entity.SemiParentOrderStatusPartialReceipted,
).Error("无效的父单状态"))
}))),
validation.Field(&m.CreateBefore,
validation.When(m.CreateBefore != "" || m.CreateAfter != "", validation.By(is.TimeRange(m.CreateBefore, m.CreateAfter, time.DateTime))),
),
validation.Field(&m.ExpectShipLatestTimeStart,
validation.When(m.ExpectShipLatestTimeStart != "" || m.ExpectShipLatestTimeEnd != "", validation.By(is.TimeRange(m.ExpectShipLatestTimeStart, m.ExpectShipLatestTimeEnd, time.DateTime))),
),
validation.Field(&m.UpdateAtStart,
validation.When(m.UpdateAtStart != "" || m.UpdateAtEnd != "", validation.By(is.TimeRange(m.UpdateAtStart, m.UpdateAtEnd, time.DateTime))),
),
validation.Field(&m.RegionId, validation.By(is.RegionId(entity.RegionIds))),
validation.Field(&m.FulfillmentTypeList, validation.Each(validation.By(func(value interface{}) error {
v, ok := value.(string)
if !ok {
return errors.New("无效的子订单履约类型")
}
return validation.Validate(v, validation.In(
entity.SemiOrderFulfillmentTypeBySeller,
entity.SemiOrderFulfillmentTypeByCooperativeWarehouse,
).Error("无效的子订单履约类型"))
}))),
validation.Field(&m.ParentOrderLabel, validation.Each(validation.By(func(value interface{}) error {
v, ok := value.(string)
if !ok {
return errors.New("无效的 PO 单订单状态标签")
}
return validation.Validate(v, validation.In(
entity.SemiParentOrderLabelSoonToBeOverdue,
entity.SemiParentOrderLabelPastDue,
entity.SemiParentOrderLabelPendingBuyerCancellation,
entity.SemiParentOrderLabelPendingBuyerAddressChange,
).Error("无效的 PO 单订单状态标签"))
}))),
validation.Field(&m.SortBy, validation.When(m.SortBy.Valid, validation.By(func(value interface{}) error {
v, ok := value.(null.String)
if !ok {
return errors.New("无效的排序依据")
}
return validation.Validate(v.String, validation.In(
entity.SemiOrderOrderByCreateTime,
entity.SemiOrderOrderByUpdateTime,
).Error("无效的排序依据"))
}))),
)
}
// Query 订单列表查询接口
// https://seller.kuajingmaihuo.com/sop/view/867739977041685428#r2WKrz
func (s semiOrderService) Query(ctx context.Context, params SemiOrderQueryParams) (items []entity.ParentOrder, total, totalPages int, isLastPage bool, err error) {
params.TidyPager()
params.PageNumber = params.Pager.Page
if err = params.validate(); err != nil {
err = invalidInput(err)
return
}
if params.CreateBefore != "" && params.CreateAfter != "" {
if start, end, e := helpers.StrTime2UnixMilli(params.CreateBefore, params.CreateAfter); e == nil {
params.CreateBefore = start
params.CreateAfter = end
}
}
if params.ExpectShipLatestTimeStart != "" && params.ExpectShipLatestTimeEnd != "" {
if start, end, e := helpers.StrTime2UnixMilli(params.ExpectShipLatestTimeStart, params.ExpectShipLatestTimeEnd); e == nil {
params.ExpectShipLatestTimeStart = start
params.ExpectShipLatestTimeEnd = end
}
}
if params.UpdateAtStart != "" && params.UpdateAtEnd != "" {
if start, end, e := helpers.StrTime2UnixMilli(params.UpdateAtStart, params.UpdateAtEnd); e == nil {
params.UpdateAtStart = start
params.UpdateAtEnd = end
}
}
var result = struct {
normal.Response
Result struct {
Result struct {
TotalItemNum int `json:"totalItemNum"`
PageItems []entity.ParentOrder `json:"pageItems"`
} `json:"result"`
} `json:"result"`
}{}
resp, err := s.httpClient.R().
SetContext(ctx).
SetBody(params).
SetResult(&result).
Post("bg.order.list.get")
if err = recheckError(resp, result.Response, err); err != nil {
return
}
items = result.Result.Result.PageItems
total, totalPages, isLastPage = parseResponseTotal(params.Page, params.PageSize, result.Result.Result.TotalItemNum)
return
}