/
repo_order_tag.go
115 lines (83 loc) · 2.35 KB
/
repo_order_tag.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
package go_shopware_admin_sdk
import (
"net/http"
)
type OrderTagRepository ClientService
func (t OrderTagRepository) Search(ctx ApiContext, criteria Criteria) (*OrderTagCollection, *http.Response, error) {
req, err := t.Client.NewRequest(ctx, "POST", "/api/search/order-tag", criteria)
if err != nil {
return nil, nil, err
}
uResp := new(OrderTagCollection)
resp, err := t.Client.Do(ctx.Context, req, uResp)
if err != nil {
return nil, resp, err
}
return uResp, resp, nil
}
func (t OrderTagRepository) SearchAll(ctx ApiContext, criteria Criteria) (*OrderTagCollection, *http.Response, error) {
if criteria.Limit == 0 {
criteria.Limit = 50
}
if criteria.Page == 0 {
criteria.Page = 1
}
c, resp, err := t.Search(ctx, criteria)
if err != nil {
return c, resp, err
}
for {
criteria.Page++
nextC, nextResp, nextErr := t.Search(ctx, criteria)
if nextErr != nil {
return c, nextResp, nextErr
}
if len(nextC.Data) == 0 {
break
}
c.Data = append(c.Data, nextC.Data...)
}
c.Total = int64(len(c.Data))
return c, resp, err
}
func (t OrderTagRepository) SearchIds(ctx ApiContext, criteria Criteria) (*SearchIdsResponse, *http.Response, error) {
req, err := t.Client.NewRequest(ctx, "POST", "/api/search-ids/order-tag", criteria)
if err != nil {
return nil, nil, err
}
uResp := new(SearchIdsResponse)
resp, err := t.Client.Do(ctx.Context, req, uResp)
if err != nil {
return nil, resp, err
}
return uResp, resp, nil
}
func (t OrderTagRepository) Upsert(ctx ApiContext, entity []OrderTag) (*http.Response, error) {
return t.Client.Bulk.Sync(ctx, map[string]SyncOperation{"order_tag": {
Entity: "order_tag",
Action: "upsert",
Payload: entity,
}})
}
func (t OrderTagRepository) Delete(ctx ApiContext, ids []string) (*http.Response, error) {
payload := make([]entityDelete, 0)
for _, id := range ids {
payload = append(payload, entityDelete{Id: id})
}
return t.Client.Bulk.Sync(ctx, map[string]SyncOperation{"order_tag": {
Entity: "order_tag",
Action: "delete",
Payload: payload,
}})
}
type OrderTag struct {
TagId string `json:"tagId,omitempty"`
Order *Order `json:"order,omitempty"`
Tag *Tag `json:"tag,omitempty"`
OrderId string `json:"orderId,omitempty"`
OrderVersionId string `json:"orderVersionId,omitempty"`
}
type OrderTagCollection struct {
EntityCollection
Data []OrderTag `json:"data"`
}