/
repo_sales_channel_country.go
113 lines (82 loc) · 2.56 KB
/
repo_sales_channel_country.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
package go_shopware_admin_sdk
import (
"net/http"
)
type SalesChannelCountryRepository ClientService
func (t SalesChannelCountryRepository) Search(ctx ApiContext, criteria Criteria) (*SalesChannelCountryCollection, *http.Response, error) {
req, err := t.Client.NewRequest(ctx, "POST", "/api/search/sales-channel-country", criteria)
if err != nil {
return nil, nil, err
}
uResp := new(SalesChannelCountryCollection)
resp, err := t.Client.Do(ctx.Context, req, uResp)
if err != nil {
return nil, resp, err
}
return uResp, resp, nil
}
func (t SalesChannelCountryRepository) SearchAll(ctx ApiContext, criteria Criteria) (*SalesChannelCountryCollection, *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 SalesChannelCountryRepository) SearchIds(ctx ApiContext, criteria Criteria) (*SearchIdsResponse, *http.Response, error) {
req, err := t.Client.NewRequest(ctx, "POST", "/api/search-ids/sales-channel-country", 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 SalesChannelCountryRepository) Upsert(ctx ApiContext, entity []SalesChannelCountry) (*http.Response, error) {
return t.Client.Bulk.Sync(ctx, map[string]SyncOperation{"sales_channel_country": {
Entity: "sales_channel_country",
Action: "upsert",
Payload: entity,
}})
}
func (t SalesChannelCountryRepository) 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{"sales_channel_country": {
Entity: "sales_channel_country",
Action: "delete",
Payload: payload,
}})
}
type SalesChannelCountry struct {
SalesChannelId string `json:"salesChannelId,omitempty"`
CountryId string `json:"countryId,omitempty"`
SalesChannel *SalesChannel `json:"salesChannel,omitempty"`
Country *Country `json:"country,omitempty"`
}
type SalesChannelCountryCollection struct {
EntityCollection
Data []SalesChannelCountry `json:"data"`
}