12 Commits

Author SHA1 Message Date
Kirill
7d8f43540f Update February 8, 2024 (#69) 2024-02-11 13:55:36 +03:00
diPhantxm
114a5b90b9 fix typo 2024-02-06 16:41:46 +03:00
Kirill
a0995a79e1 Update January 26, 2024 (#66)
add new status to fbo returns
2024-01-29 23:31:46 +03:00
Kirill
2f94b8c774 Reimplement default values (#65) 2024-01-29 23:22:57 +03:00
Kirill
35832e6269 remove default values temporarily (#64) 2024-01-29 18:51:12 +03:00
Kirill
965c83ba85 Make fields optional in method params (#62) 2024-01-25 15:41:30 +03:00
Zloy_Leshiy
a3c9d93adc Golang version to 19 and not required fields #60 (#61)
Co-authored-by: o.tyurin <o.tyurin@corp.mail.ru>
2024-01-23 03:14:18 +03:00
Kirill
549a2b9b41 Update readme example (#59) 2024-01-08 15:55:49 +03:00
Kirill
c36446bb59 Update December 25, 2023 (#57) 2023-12-27 00:04:03 +03:00
Kirill
ebafb17c9d Update December 15, 2023 (#55) 2023-12-16 15:52:35 +03:00
Kirill
178fd7086a Update December 11, 2023 (#54) 2023-12-12 23:29:03 +03:00
Kirill
de08ee28c0 Client options (#53) 2023-12-11 21:30:36 +03:00
31 changed files with 604 additions and 215 deletions

View File

@@ -25,7 +25,7 @@ jobs:
- name: Setup go - name: Setup go
uses: actions/setup-go@v2 uses: actions/setup-go@v2
with: with:
go-version: '1.19' go-version: '1.20'
- name: Setup - name: Setup
run: | run: |
go install github.com/mattn/goveralls@latest go install github.com/mattn/goveralls@latest

View File

@@ -23,6 +23,7 @@ A simple example on how to use this library:
package main package main
import ( import (
"context"
"fmt" "fmt"
"log" "log"
"net/http" "net/http"
@@ -33,11 +34,14 @@ import (
func main() { func main() {
// Create a client with your Client-Id and Api-Key // Create a client with your Client-Id and Api-Key
// [Documentation]: https://docs.ozon.ru/api/seller/en/#tag/Auth // [Documentation]: https://docs.ozon.ru/api/seller/en/#tag/Auth
client := ozon.NewClient("my-client-id", "my-api-key") opts := []ozon.ClientOption{
ozon.WithAPIKey("api-key"),
ozon.WithClientId("client-id"),
}
c := ozon.NewClient(opts...)
// Send request with parameters // Send request with parameters
ctx, _ := context.WithTimeout(context.Background(), testTimeout) resp, err := client.Products().GetProductDetails(context.Background(), &ozon.GetProductDetailsParams{
resp, err := client.Products().GetProductDetails(&ozon.GetProductDetailsParams{
ProductId: 123456789, ProductId: 123456789,
}) })
if err != nil || resp.StatusCode != http.StatusOK { if err != nil || resp.StatusCode != http.StatusOK {

View File

@@ -7,6 +7,8 @@ import (
"io/ioutil" "io/ioutil"
"net/http" "net/http"
"net/http/httptest" "net/http/httptest"
"net/url"
"reflect"
) )
type HttpClient interface { type HttpClient interface {
@@ -34,14 +36,25 @@ func NewMockClient(handler http.HandlerFunc) *Client {
} }
} }
func (c Client) newRequest(ctx context.Context, method string, url string, body interface{}) (*http.Request, error) { func (c Client) newRequest(ctx context.Context, method string, uri string, body interface{}) (*http.Request, error) {
// Set default values for empty fields if `default` tag is present
// And body is not nil
if body != nil {
if err := getDefaultValues(reflect.ValueOf(body)); err != nil {
return nil, err
}
}
bodyJson, err := json.Marshal(body) bodyJson, err := json.Marshal(body)
if err != nil { if err != nil {
return nil, err return nil, err
} }
url = c.baseUrl + url uri, err = url.JoinPath(c.baseUrl, uri)
req, err := http.NewRequestWithContext(ctx, method, url, bytes.NewBuffer(bodyJson)) if err != nil {
return nil, err
}
req, err := http.NewRequestWithContext(ctx, method, uri, bytes.NewBuffer(bodyJson))
if err != nil { if err != nil {
return nil, err return nil, err
} }
@@ -58,11 +71,6 @@ func (c Client) Request(ctx context.Context, method string, path string, req, re
if err != nil { if err != nil {
return nil, err return nil, err
} }
rawQuery, err := buildRawQuery(httpReq, req)
if err != nil {
return nil, err
}
httpReq.URL.RawQuery = rawQuery
httpResp, err := c.client.Do(httpReq) httpResp, err := c.client.Do(httpReq)
if err != nil { if err != nil {

130
core.go
View File

@@ -4,6 +4,7 @@ import (
"fmt" "fmt"
"net/http" "net/http"
"reflect" "reflect"
"strconv"
"testing" "testing"
"time" "time"
) )
@@ -32,51 +33,103 @@ func (r Response) CopyCommonResponse(rhs *CommonResponse) {
rhs.Message = r.Message rhs.Message = r.Message
} }
func getDefaultValues(v interface{}) (map[string]string, error) { func getDefaultValues(v reflect.Value) error {
isNil, err := isZero(v) vValue := v.Elem()
if err != nil { vType := vValue.Type()
return make(map[string]string), err
}
if isNil {
return make(map[string]string), nil
}
out := make(map[string]string)
vType := reflect.TypeOf(v).Elem()
vValue := reflect.ValueOf(v).Elem()
for i := 0; i < vType.NumField(); i++ { for i := 0; i < vType.NumField(); i++ {
field := vType.Field(i) field := vType.Field(i)
tag := field.Tag.Get("json")
defaultValue := field.Tag.Get("default")
if field.Type.Kind() == reflect.Slice { switch field.Type.Kind() {
// Attach any slices as query params case reflect.Slice:
fieldVal := vValue.Field(i) for j := 0; j < vValue.Field(i).Len(); j++ {
for j := 0; j < fieldVal.Len(); j++ { // skip if slice type is primitive
out[tag] = fmt.Sprintf("%v", fieldVal.Index(j)) if vValue.Field(i).Index(j).Kind() != reflect.Struct {
}
} else {
// Add any scalar values as query params
fieldVal := fmt.Sprintf("%v", vValue.Field(i))
// If no value was set by the user, use the default
// value specified in the struct tag.
if fieldVal == "" || fieldVal == "0" {
if defaultValue == "" {
continue continue
} }
fieldVal = defaultValue // Attach any slices as query params
err := getDefaultValues(vValue.Field(i).Index(j).Addr())
if err != nil {
return err
}
}
case reflect.String:
isNil, err := isZero(vValue.Field(i).Addr())
if err != nil {
return err
}
if !isNil {
continue
} }
out[tag] = fmt.Sprintf("%v", fieldVal) defaultValue, ok := field.Tag.Lookup("default")
if !ok {
continue
}
vValue.Field(i).SetString(defaultValue)
case reflect.Int, reflect.Int8, reflect.Int16, reflect.Int32, reflect.Int64:
isNil, err := isZero(vValue.Field(i).Addr())
if err != nil {
return err
}
if !isNil {
continue
}
defaultValue, ok := field.Tag.Lookup("default")
if !ok {
continue
}
defaultValueInt, err := strconv.Atoi(defaultValue)
if err != nil {
return err
}
vValue.Field(i).SetInt(int64(defaultValueInt))
case reflect.Uint, reflect.Uint8, reflect.Uint16, reflect.Uint32, reflect.Uint64:
isNil, err := isZero(vValue.Field(i).Addr())
if err != nil {
return err
}
if !isNil {
continue
}
defaultValue, ok := field.Tag.Lookup("default")
if !ok {
continue
}
defaultValueUint, err := strconv.ParseUint(defaultValue, 10, 64)
if err != nil {
return err
}
vValue.Field(i).SetUint(uint64(defaultValueUint))
case reflect.Struct:
err := getDefaultValues(vValue.Field(i).Addr())
if err != nil {
return err
}
case reflect.Ptr:
isNil, err := isZero(vValue.Field(i).Addr())
if err != nil {
return err
}
if isNil {
continue
}
if err := getDefaultValues(vValue.Field(i)); err != nil {
return err
}
default:
continue
} }
} }
return out, nil return nil
} }
func buildRawQuery(req *http.Request, v interface{}) (string, error) { func buildRawQuery(req *http.Request, v interface{}) (string, error) {
@@ -86,23 +139,20 @@ func buildRawQuery(req *http.Request, v interface{}) (string, error) {
return query.Encode(), nil return query.Encode(), nil
} }
values, err := getDefaultValues(v) err := getDefaultValues(reflect.ValueOf(v))
if err != nil { if err != nil {
return "", err return "", err
} }
for k, v := range values {
query.Add(k, v)
}
return query.Encode(), nil return query.Encode(), nil
} }
func isZero(v interface{}) (bool, error) { func isZero(v reflect.Value) (bool, error) {
t := reflect.TypeOf(v) t := v.Elem().Type()
if !t.Comparable() { if !t.Comparable() {
return false, fmt.Errorf("type is not comparable: %v", t) return false, fmt.Errorf("type is not comparable: %v", t)
} }
return v == reflect.Zero(t).Interface(), nil return reflect.Zero(t).Equal(v.Elem()), nil
} }
func TimeFromString(t *testing.T, format, datetime string) time.Time { func TimeFromString(t *testing.T, format, datetime string) time.Time {

View File

@@ -1,34 +1,56 @@
package core package core
import ( import (
"log" "reflect"
"testing" "testing"
"github.com/stretchr/testify/assert"
) )
type TestTagDefaultValueStruct struct { type DefaultStructure struct {
TestString string `json:"test_string" default:"something"` EmptyField string `json:"empty_field" default:"empty_string"`
TestNumber int `json:"test_number" default:"12"` Field string `json:"field" default:"string"`
} }
func TestTagDefaultValue(t *testing.T) { type DefaultRequest struct {
testStruct := &TestTagDefaultValueStruct{} Field int `json:"field" default:"100"`
EmptyField int `json:"empty_field" default:"14"`
values, err := getDefaultValues(testStruct) Structure DefaultStructure `json:"structure"`
if err != nil { Slice []DefaultStructure `json:"slice"`
log.Fatalf("error when getting default values from tags: %s", err) OptionalStructure *DefaultStructure `json:"optional_structure"`
EmptyOptionalStructure *DefaultStructure `json:"empty_optional_structure"`
} }
expected := map[string]string{ func TestDefaultValues(t *testing.T) {
"test_string": "something", req := &DefaultRequest{
"test_number": "12", Field: 50,
Structure: DefaultStructure{
Field: "something",
},
Slice: []DefaultStructure{
{
Field: "something",
},
{
Field: "something",
},
},
OptionalStructure: &DefaultStructure{
Field: "something",
},
} }
err := getDefaultValues(reflect.ValueOf(req))
assert.Nil(t, err)
if len(values) != len(expected) { assert.Equal(t, 50, req.Field)
log.Fatalf("expected equal length of values and expected: expected: %d, got: %d", len(expected), len(values)) assert.Equal(t, 14, req.EmptyField)
} assert.Equal(t, "something", req.Structure.Field)
for expKey, expValue := range expected { assert.Equal(t, "empty_string", req.Structure.EmptyField)
if expValue != values[expKey] { assert.Equal(t, "something", req.Slice[0].Field)
log.Fatalf("not equal values for key %s", expKey) assert.Equal(t, "something", req.Slice[1].Field)
} assert.Equal(t, "empty_string", req.Slice[1].EmptyField)
} assert.Equal(t, "empty_string", req.Slice[1].EmptyField)
assert.Equal(t, "something", req.OptionalStructure.Field)
assert.Equal(t, "empty_string", req.OptionalStructure.EmptyField)
assert.Equal(t, (*DefaultStructure)(nil), req.EmptyOptionalStructure)
} }

10
go.mod
View File

@@ -1,3 +1,11 @@
module github.com/diphantxm/ozon-api-client module github.com/diphantxm/ozon-api-client
go 1.18 go 1.20
require (
github.com/davecgh/go-spew v1.1.1 // indirect
github.com/pmezard/go-difflib v1.0.0 // indirect
github.com/stretchr/objx v0.5.0 // indirect
github.com/stretchr/testify v1.8.4 // indirect
gopkg.in/yaml.v3 v3.0.1 // indirect
)

17
go.sum Normal file
View File

@@ -0,0 +1,17 @@
github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
github.com/stretchr/objx v0.4.0/go.mod h1:YvHI0jy2hoMjB+UWwv71VJQ9isScKT/TqJzVSSt89Yw=
github.com/stretchr/objx v0.5.0 h1:1zr/of2m5FGMsad5YfcqgdqdWrIhu+EBEJRhR1U7z/c=
github.com/stretchr/objx v0.5.0/go.mod h1:Yh+to48EsGEfYuaHDzXPcE3xhTkx73EhmCGUpEOglKo=
github.com/stretchr/testify v1.7.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
github.com/stretchr/testify v1.8.0/go.mod h1:yNjHg4UonilssWZ8iaSj1OCr/vHnekPRkoO+kdMU+MU=
github.com/stretchr/testify v1.8.4 h1:CcVxjf3Q8PM0mHUKJCdn+eZZtm5yQwehR5yeSVQQcUk=
github.com/stretchr/testify v1.8.4/go.mod h1:sz/lmYIOXD/1dqDmKjjqLyZ2RngseejIcXlSw2iwfAo=
gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=

View File

@@ -165,7 +165,7 @@ type GetStocksOnWarehousesParams struct {
Offset int64 `json:"offset"` Offset int64 `json:"offset"`
// Warehouse type filter: // Warehouse type filter:
WarehouseType WarehouseType `json:"warehouse_type"` WarehouseType WarehouseType `json:"warehouse_type" default:"ALL"`
} }
type GetStocksOnWarehousesResponse struct { type GetStocksOnWarehousesResponse struct {

View File

@@ -83,7 +83,7 @@ type CancellationInfoState struct {
// Method for getting information about a rFBS cancellation request // Method for getting information about a rFBS cancellation request
func (c Cancellations) GetInfo(ctx context.Context, params *GetCancellationInfoParams) (*GetCancellationInfoResponse, error) { func (c Cancellations) GetInfo(ctx context.Context, params *GetCancellationInfoParams) (*GetCancellationInfoResponse, error) {
url := "/v1/delivery-method/list" url := "/v1/conditional-cancellation/get"
resp := &GetCancellationInfoResponse{} resp := &GetCancellationInfoResponse{}
@@ -98,17 +98,17 @@ func (c Cancellations) GetInfo(ctx context.Context, params *GetCancellationInfoP
type ListCancellationsParams struct { type ListCancellationsParams struct {
// Filters // Filters
Filter ListCancellationsFilter `json:"filter"` Filter *ListCancellationsFilter `json:"filter,omitempty"`
// Number of cancellation requests in the response // Number of cancellation requests in the response
Limit int32 `json:"limit"` Limit int32 `json:"limit,omitempty"`
// Number of elements that will be skipped in the response. // Number of elements that will be skipped in the response.
// For example, if offset=10, the response will start with the 11th element found // For example, if offset=10, the response will start with the 11th element found
Offset int32 `json:"offset"` Offset int32 `json:"offset,omitempty"`
// Additional information // Additional information
With ListCancellationWith `json:"with"` With *ListCancellationWith `json:"with,omitempty"`
} }
type ListCancellationsFilter struct { type ListCancellationsFilter struct {
@@ -173,7 +173,7 @@ type ApproveRejectCancellationsParams struct {
CancellationId int64 `json:"cancellation_id"` CancellationId int64 `json:"cancellation_id"`
// Comment // Comment
Comment string `json:"comment"` Comment string `json:"comment,omitempty"`
} }
type ApproveRejectCancellationsResponse struct { type ApproveRejectCancellationsResponse struct {

View File

@@ -98,13 +98,13 @@ func TestListCancellations(t *testing.T) {
http.StatusOK, http.StatusOK,
map[string]string{"Client-Id": "my-client-id", "Api-Key": "my-api-key"}, map[string]string{"Client-Id": "my-client-id", "Api-Key": "my-api-key"},
&ListCancellationsParams{ &ListCancellationsParams{
Filter: ListCancellationsFilter{ Filter: &ListCancellationsFilter{
CancellationInitiator: []string{"CLIENT"}, CancellationInitiator: []string{"CLIENT"},
State: "ALL", State: "ALL",
}, },
Limit: 2, Limit: 2,
Offset: 0, Offset: 0,
With: ListCancellationWith{ With: &ListCancellationWith{
Counters: true, Counters: true,
}, },
}, },

View File

@@ -13,7 +13,7 @@ type Categories struct {
type GetProductTreeParams struct { type GetProductTreeParams struct {
// Response language // Response language
Language Language `json:"language"` Language Language `json:"language,omitempty"`
} }
type GetProductTreeResponse struct { type GetProductTreeResponse struct {
@@ -25,7 +25,7 @@ type GetProductTreeResponse struct {
type GetProductTreeResult struct { type GetProductTreeResult struct {
// Category identifier // Category identifier
CategoryId int64 `json:"category_id"` DescriptionCategoryId int64 `json:"description_category_id"`
// Category name // Category name
CategoryName string `json:"category_name"` CategoryName string `json:"category_name"`
@@ -64,10 +64,10 @@ func (c *Categories) Tree(ctx context.Context, params *GetProductTreeParams) (*G
type GetCategoryAttributesParams struct { type GetCategoryAttributesParams struct {
// Category identifier // Category identifier
CategoryId int64 `json:"category_id"` DescriptionCategoryId int64 `json:"description_category_id"`
// Response language // Response language
Language Language `json:"language"` Language Language `json:"language,omitempty"`
// Product type identifier // Product type identifier
TypeId int64 `json:"type_id"` TypeId int64 `json:"type_id"`
@@ -123,6 +123,12 @@ type GetCategoryAttributesResult struct {
// Characteristic type // Characteristic type
Type string `json:"type"` Type string `json:"type"`
// Complex attribute identifier
AttributeComplexId int64 `json:"attribute_complex_id"`
// Maximum number of values for attribute
MaxValueCount int64 `json:"max_value_count"`
} }
// Getting characteristics for specified product category and type. // Getting characteristics for specified product category and type.
@@ -149,10 +155,10 @@ type GetAttributeDictionaryParams struct {
AttributeId int64 `json:"attribute_id"` AttributeId int64 `json:"attribute_id"`
// Category identifier // Category identifier
CategoryId int64 `json:"category_id"` DescriptionCategoryId int64 `json:"description_category_id"`
// Response language // Response language
Language Language `json:"language"` Language Language `json:"language,omitempty"`
// Identifier of the directory to start the response with. // Identifier of the directory to start the response with.
// If `last_value_id` is 10, the response will contain directories starting from the 11th // If `last_value_id` is 10, the response will contain directories starting from the 11th
@@ -162,7 +168,7 @@ type GetAttributeDictionaryParams struct {
// //
// - maximum—5000, // - maximum—5000,
// - minimum—1. // - minimum—1.
Limit int64 `json:"limit"` Limit int64 `json:"limit,omitempty"`
// Product type identifier // Product type identifier
TypeId int64 `json:"type_id"` TypeId int64 `json:"type_id"`
@@ -200,7 +206,7 @@ type GetAttributeDictionaryResult struct {
// To check if an attribute has a nested directory, // To check if an attribute has a nested directory,
// use the `/v1/description-category/attribute` method. // use the `/v1/description-category/attribute` method.
func (c *Categories) AttributesDictionary(ctx context.Context, params *GetAttributeDictionaryParams) (*GetAttributeDictionaryResponse, error) { func (c *Categories) AttributesDictionary(ctx context.Context, params *GetAttributeDictionaryParams) (*GetAttributeDictionaryResponse, error) {
url := "/v1/description-category/attribute" url := "/v1/description-category/attribute/values"
resp := &GetAttributeDictionaryResponse{} resp := &GetAttributeDictionaryResponse{}

View File

@@ -27,7 +27,7 @@ func TestGetProductTree(t *testing.T) {
`{ `{
"result": [ "result": [
{ {
"category_id": 0, "description_category_id": 0,
"category_name": "string", "category_name": "string",
"children": [], "children": [],
"disabled": true, "disabled": true,
@@ -81,7 +81,7 @@ func TestGetCategoryAttributes(t *testing.T) {
http.StatusOK, http.StatusOK,
map[string]string{"Client-Id": "my-client-id", "Api-Key": "my-api-key"}, map[string]string{"Client-Id": "my-client-id", "Api-Key": "my-api-key"},
&GetCategoryAttributesParams{ &GetCategoryAttributesParams{
CategoryId: 12345, DescriptionCategoryId: 12345,
Language: English, Language: English,
TypeId: 2, TypeId: 2,
}, },
@@ -97,7 +97,9 @@ func TestGetCategoryAttributes(t *testing.T) {
"is_collection": true, "is_collection": true,
"is_required": true, "is_required": true,
"name": "string", "name": "string",
"type": "string" "type": "string",
"attribute_complex_id": 0,
"max_value_count": 0
} }
] ]
}`, }`,
@@ -147,7 +149,7 @@ func TestGetAttributeDictionary(t *testing.T) {
map[string]string{"Client-Id": "my-client-id", "Api-Key": "my-api-key"}, map[string]string{"Client-Id": "my-client-id", "Api-Key": "my-api-key"},
&GetAttributeDictionaryParams{ &GetAttributeDictionaryParams{
AttributeId: 123456, AttributeId: 123456,
CategoryId: 12, DescriptionCategoryId: 12,
Language: English, Language: English,
LastValueId: 1, LastValueId: 1,
Limit: 5, Limit: 5,

View File

@@ -121,7 +121,7 @@ type ListOfCertifiedCategoriesResultCert struct {
// List of certified categories // List of certified categories
func (c Certificates) ListOfCertifiedCategories(ctx context.Context, params *ListOfCertifiedCategoriesParams) (*ListOfCertifiedCategoriesResponse, error) { func (c Certificates) ListOfCertifiedCategories(ctx context.Context, params *ListOfCertifiedCategoriesParams) (*ListOfCertifiedCategoriesResponse, error) {
url := "/v1/product/certificate/types" url := "/v1/product/certification/list"
resp := &ListOfCertifiedCategoriesResponse{} resp := &ListOfCertifiedCategoriesResponse{}

View File

@@ -14,14 +14,14 @@ type Chats struct {
type ListChatsParams struct { type ListChatsParams struct {
// Chats filter // Chats filter
Filter ListChatsFilter `json:"filter"` Filter *ListChatsFilter `json:"filter,omitempty"`
// Number of values in the response. Default value is 1 // Number of values in the response. The default value is 30. The maximum value is 1000
Limit int64 `json:"limit" default:"1"` Limit int64 `json:"limit" default:"30"`
// Number of elements that will be skipped in the response. // Number of elements that will be skipped in the response.
// For example, if offset=10, the response will start with the 11th element found // For example, if offset=10, the response will start with the 11th element found
Offset int64 `json:"offset"` Offset int64 `json:"offset,omitempty"`
} }
type ListChatsFilter struct { type ListChatsFilter struct {
@@ -173,7 +173,7 @@ type ChatHistoryParams struct {
// Default value is the last visible message // Default value is the last visible message
FromMessageId string `json:"from_message_id"` FromMessageId string `json:"from_message_id"`
// Number of messages in the response. The default value is 50 // Number of messages in the response. The default value is 50. The maximum value is 1000
Limit int64 `json:"limit" default:"50"` Limit int64 `json:"limit" default:"50"`
} }
@@ -240,7 +240,7 @@ type UpdateChatParams struct {
FromMessageId uint64 `json:"from_message_id"` FromMessageId uint64 `json:"from_message_id"`
// Number of messages in the response // Number of messages in the response
Limit int64 `json:"limit"` Limit int64 `json:"limit,omitempty"`
} }
type UpdateChatResponse struct { type UpdateChatResponse struct {

View File

@@ -22,7 +22,7 @@ func TestListChats(t *testing.T) {
http.StatusOK, http.StatusOK,
map[string]string{"Client-Id": "my-client-id", "Api-Key": "my-api-key"}, map[string]string{"Client-Id": "my-client-id", "Api-Key": "my-api-key"},
&ListChatsParams{ &ListChatsParams{
Filter: ListChatsFilter{ Filter: &ListChatsFilter{
ChatStatus: "Opened", ChatStatus: "Opened",
UnreadOnly: true, UnreadOnly: true,
}, },

View File

@@ -468,8 +468,10 @@ const (
type GetFBOReturnsFilterStatus string type GetFBOReturnsFilterStatus string
const ( const (
GetFBOReturnsFilterStatusCreated GetFBOReturnsFilterStatus = "Created"
GetFBOReturnsFilterStatusReturnedToOzon GetFBOReturnsFilterStatus = "ReturnedToOzon" GetFBOReturnsFilterStatusReturnedToOzon GetFBOReturnsFilterStatus = "ReturnedToOzon"
GetFBOReturnsFilterStatusCancelled GetFBOReturnsFilterStatus = "Cancelled" GetFBOReturnsFilterStatusCancelled GetFBOReturnsFilterStatus = "Cancelled"
GetFBOReturnsFilterStatusCancelledWithCompensation GetFBOReturnsFilterStatus = "CancelledWithCompensation"
) )
type GetFBOReturnsReturnStatus string type GetFBOReturnsReturnStatus string

View File

@@ -14,7 +14,7 @@ type FBO struct {
type GetFBOShipmentsListParams struct { type GetFBOShipmentsListParams struct {
// Sorting direction // Sorting direction
Direction string `json:"dir"` Direction string `json:"dir,omitempty"`
// Shipment search filter // Shipment search filter
Filter GetFBOShipmentsListFilter `json:"filter"` Filter GetFBOShipmentsListFilter `json:"filter"`
@@ -23,13 +23,13 @@ type GetFBOShipmentsListParams struct {
Limit int64 `json:"limit"` Limit int64 `json:"limit"`
// Number of elements that will be skipped in the response. For example, if offset=10, the response will start with the 11th element found // Number of elements that will be skipped in the response. For example, if offset=10, the response will start with the 11th element found
Offset int64 `json:"offset"` Offset int64 `json:"offset,omitempty"`
// true if the address transliteration from Cyrillic to Latin is enabled // true if the address transliteration from Cyrillic to Latin is enabled
Translit bool `json:"translit"` Translit bool `json:"translit,omitempty"`
// Additional fields to add to the response // Additional fields to add to the response
With GetFBOShipmentsListWith `json:"with"` With *GetFBOShipmentsListWith `json:"with,omitempty"`
} }
// Shipment search filter // Shipment search filter
@@ -185,10 +185,10 @@ type GetShipmentDetailsParams struct {
PostingNumber string `json:"posting_number"` PostingNumber string `json:"posting_number"`
// true if the address transliteration from Cyrillic to Latin is enabled // true if the address transliteration from Cyrillic to Latin is enabled
Translit bool `json:"translit"` Translit bool `json:"translit,omitempty"`
// Additional fields to add to the response // Additional fields to add to the response
With GetShipmentDetailsWith `json:"with"` With *GetShipmentDetailsWith `json:"with,omitempty"`
} }
type GetShipmentDetailsWith struct { type GetShipmentDetailsWith struct {

View File

@@ -31,7 +31,7 @@ func TestGetFBOShipmentsList(t *testing.T) {
Limit: 5, Limit: 5,
Offset: 0, Offset: 0,
Translit: true, Translit: true,
With: GetFBOShipmentsListWith{ With: &GetFBOShipmentsListWith{
AnalyticsData: true, AnalyticsData: true,
FinancialData: true, FinancialData: true,
}, },
@@ -165,7 +165,7 @@ func TestGetShipmentDetails(t *testing.T) {
&GetShipmentDetailsParams{ &GetShipmentDetailsParams{
PostingNumber: "50520644-0012-7", PostingNumber: "50520644-0012-7",
Translit: true, Translit: true,
With: GetShipmentDetailsWith{ With: &GetShipmentDetailsWith{
AnalyticsData: true, AnalyticsData: true,
FinancialData: true, FinancialData: true,
}, },

View File

@@ -14,7 +14,7 @@ type FBS struct {
type ListUnprocessedShipmentsParams struct { type ListUnprocessedShipmentsParams struct {
// Sorting direction // Sorting direction
Direction Order `json:"dir"` Direction Order `json:"dir,omitempty"`
// Request filter // Request filter
Filter ListUnprocessedShipmentsFilter `json:"filter"` Filter ListUnprocessedShipmentsFilter `json:"filter"`
@@ -27,10 +27,10 @@ type ListUnprocessedShipmentsParams struct {
// Number of elements that will be skipped in the response. // Number of elements that will be skipped in the response.
// For example, if `offset` = 10, the response will start with the 11th element found // For example, if `offset` = 10, the response will start with the 11th element found
Offset int64 `json:"offset"` Offset int64 `json:"offset,omitempty"`
// Additional fields that should be added to the response // Additional fields that should be added to the response
With ListUnprocessedShipmentsWith `json:"with"` With *ListUnprocessedShipmentsWith `json:"with,omitempty"`
} }
type ListUnprocessedShipmentsFilter struct { type ListUnprocessedShipmentsFilter struct {
@@ -511,7 +511,7 @@ func (c FBS) ListUnprocessedShipments(ctx context.Context, params *ListUnprocess
type GetFBSShipmentsListParams struct { type GetFBSShipmentsListParams struct {
// Sorting direction // Sorting direction
Direction string `json:"direction"` Direction string `json:"dir,omitempty"`
// Filter // Filter
Filter GetFBSShipmentsListFilter `json:"filter"` Filter GetFBSShipmentsListFilter `json:"filter"`
@@ -522,10 +522,10 @@ type GetFBSShipmentsListParams struct {
Limit int64 `json:"limit"` Limit int64 `json:"limit"`
// Number of elements that will be skipped in the response. For example, if offset=10, the response will start with the 11th element found // Number of elements that will be skipped in the response. For example, if offset=10, the response will start with the 11th element found
Offset int64 `json:"offset"` Offset int64 `json:"offset,omitempty"`
// Additional fields that should be added to the response // Additional fields that should be added to the response
With GetFBSShipmentsListWith `json:"with"` With *GetFBSShipmentsListWith `json:"with,omitempty"`
} }
type GetFBSShipmentsListFilter struct { type GetFBSShipmentsListFilter struct {
@@ -625,7 +625,7 @@ type PackOrderParams struct {
PostingNumber string `json:"posting_number"` PostingNumber string `json:"posting_number"`
// Additional information // Additional information
With PackOrderWith `json:"with"` With *PackOrderWith `json:"with,omitempty"`
} }
type PackOrderPackage struct { type PackOrderPackage struct {
@@ -865,7 +865,7 @@ type GetShipmentDataByIdentifierParams struct {
PostingNumber string `json:"posting_number"` PostingNumber string `json:"posting_number"`
// Additional fields that should be added to the response // Additional fields that should be added to the response
With GetShipmentDataByIdentifierWith `json:"with"` With *GetShipmentDataByIdentifierWith `json:"with,omitempty"`
} }
type GetShipmentDataByIdentifierWith struct { type GetShipmentDataByIdentifierWith struct {
@@ -1750,18 +1750,76 @@ func (c FBS) GetDropOffPointRestrictions(ctx context.Context, params *GetDropOff
} }
type CheckProductItemsDataParams struct { type CheckProductItemsDataParams struct {
// Quantity of boxes the product is packed in
MultiBoxQuantity int32 `json:"multi_box_qty"`
// Shipment number // Shipment number
PostingNumber string `json:"posting_number"` PostingNumber string `json:"posting_number"`
Products CheckProductItemsDataProduct `json:"products"` // Product list
Products []CheckProductItemsDataProduct `json:"products"`
} }
type CheckProductItemsDataProduct struct { type CheckProductItemsDataProduct struct {
// Product items data // Product items data
Exemplars []FBSProductExemplar `json:"exemplars"` Exemplars []CheckProductItemsDataProductExemplar `json:"exemplars"`
// SKU, FBS product identifier in the Ozon system // Indication that you need to pass the сustoms cargo declaration
// (CCD) number for the product and shipment
IsGTDNeeded bool `json:"is_gtd_needed"`
// Indication that you need to pass the "Chestny ZNAK" labeling
IsMandatoryMarkNeeded bool `json:"is_mandatory_mark_needed"`
// Indication that you need to pass the product batch registration number
IsRNPTNeeded bool `json:"is_rnpt_needed"`
// Product ID
ProductId int64 `json:"product_id"` ProductId int64 `json:"product_id"`
// Items quantity
Quantity int32 `json:"quantity"`
}
type CheckProductItemsDataProductExemplar struct {
// Item identifier
ExemplarId int64 `json:"exemplar_id"`
// Customs cargo declaration (CCD) number
GTD string `json:"gtd"`
// Сustoms cargo declaration (CCD) check status
GTDCheckStatus string `json:"gtd_check_status"`
// Сustoms cargo declaration (CCD) check error codes
GTDErrorCodes []string `json:"gtd_error_codes"`
// Indication that the customs cargo declaration (CCD) number isn't specified
IsGTDAbsent bool `json:"is_gtd_absent"`
// "Chestny ZNAK" labeling check status
MandatoryMarkCheckStatus MandatoryMarkStatus `json:"mandatory_mark_check_status"`
// "Chestny ZNAK" labeling check error codes
MandatoryMarkErrorCodes []string `json:"mandatory_mark_error_codes"`
// Indication that the product batch registration number isn't specified
IsRNPTAbsent bool `json:"is_rnpt_absent"`
// Mandatory "Chestny ZNAK" labeling
MandatoryMark string `json:"mandatory_mark"`
// Product batch registration number
RNPT string `json:"rnpt"`
// Product batch registration number check status
RNPTCheckStatus string `json:"rnpt_check_status"`
// Product batch registration number check error codes
RNPTErrorCodes []string `json:"rnpt_error_codes"`
// Unique identifier of charges of the jewelry
JWUIN string `json:"jw_uin"`
} }
type CheckProductItemsDataResponse struct { type CheckProductItemsDataResponse struct {
@@ -1772,20 +1830,23 @@ type CheckProductItemsDataResponse struct {
} }
// Asynchronous method: // Asynchronous method:
// - for checking the availability of product items in the “Chestny ZNAK” labeling system
// - for saving product items data
// //
// To get the checks results, use the `/v4/fbs/posting/product/exemplar/status method` // for checking the availability of product items in the “Chestny ZNAK” labeling system;
// for saving product items data.
// To get the checks results, use the `/v4/fbs/posting/product/exemplar/status` method.
// To get data about created items, use the `/v5/fbs/fbs/posting/product/exemplar/create-or-get` method.
// //
// If necessary, specify the number of the cargo customs declaration in the gtd parameter. If it is missing, pass the value `is_gtd_absent` = true // If necessary, specify the number of the cargo customs declaration in the gtd parameter.
// If it is missing, pass the value `is_gtd_absent` = true.
// //
// If you have multiple identical products in a shipment, specify one `product_id` and `exemplars` array for each product in the shipment // If you have multiple identical products in a shipment, specify one `product_id` and exemplars array for each product in the shipment.
// //
// # Always pass a complete set of product items data // Always pass a complete set of product items data.
// //
// For example, you have 10 product items in your system. // For example, you have 10 product items in your system.
// You have passed them for checking and saving. Then they added another 60 product items to your system. // You've passed them for checking and saving.
// When you pass product items for checking and saving again, pass all of them: both old and newly added // Then you added another 60 product items to your system.
// When you pass product items for checking and saving again, pass all of them: both old and newly added.
func (c FBS) CheckProductItemsData(ctx context.Context, params *CheckProductItemsDataParams) (*CheckProductItemsDataResponse, error) { func (c FBS) CheckProductItemsData(ctx context.Context, params *CheckProductItemsDataParams) (*CheckProductItemsDataResponse, error) {
url := "/v4/fbs/posting/product/exemplar/set" url := "/v4/fbs/posting/product/exemplar/set"
@@ -1996,8 +2057,8 @@ type PartialPackOrderParams struct {
} }
type PartialPackOrderProduct struct { type PartialPackOrderProduct struct {
// Data array on product items // Product item identifiers
ExemplarInfo []FBSProductExemplar `json:"exemplar_info"` ExemplarIds []string `json:"exemplarIds"`
// FBS product identifier in the Ozon system, SKU // FBS product identifier in the Ozon system, SKU
ProductId int64 `json:"product_id"` ProductId int64 `json:"product_id"`
@@ -2009,11 +2070,8 @@ type PartialPackOrderProduct struct {
type PartialPackOrderResponse struct { type PartialPackOrderResponse struct {
core.CommonResponse core.CommonResponse
// Additional data about shipments // Shipments numbers formed after packaging
AdditionalData []PartialPackOrderAdditionalData `json:"additional_data"` Result string `json:"result"`
// Identifiers of shipments that were created after package
Result []string `json:"result"`
} }
type PartialPackOrderAdditionalData struct { type PartialPackOrderAdditionalData struct {
@@ -2029,7 +2087,7 @@ type PartialPackOrderAdditionalData struct {
// //
// The status of the original shipment will only change when the split shipments status changes // The status of the original shipment will only change when the split shipments status changes
func (c FBS) PartialPackOrder(ctx context.Context, params *PartialPackOrderParams) (*PartialPackOrderResponse, error) { func (c FBS) PartialPackOrder(ctx context.Context, params *PartialPackOrderParams) (*PartialPackOrderResponse, error) {
url := "/v3/posting/fbs/ship/package" url := "/v4/posting/fbs/ship/package"
resp := &PartialPackOrderResponse{} resp := &PartialPackOrderResponse{}
@@ -2791,3 +2849,36 @@ func (c FBS) GetActPDF(ctx context.Context, params *GetActPDFParams) (*GetActPDF
return resp, nil return resp, nil
} }
type CreateOrGetProductExemplarParams struct {
// Shipment number
PostingNumber string `json:"posting_number"`
}
type CreateOrGetProductExemplarResponse struct {
core.CommonResponse
// Quantity of boxes the product is packed in
MultiBoxQuantity int32 `json:"multi_box_qty"`
// Shipment number
PostingNumber string `json:"posting_number"`
// Product list
Products []CheckProductItemsDataProduct `json:"products"`
}
// Method returns the created items data passed in the `/v5/fbs/posting/product/exemplar/set` method.
func (c FBS) CreateOrGetProductExemplar(ctx context.Context, params *CreateOrGetProductExemplarParams) (*CreateOrGetProductExemplarResponse, error) {
url := "/v5/fbs/posting/product/exemplar/create-or-get"
resp := &CreateOrGetProductExemplarResponse{}
response, err := c.client.Request(ctx, http.MethodPost, url, params, resp, nil)
if err != nil {
return nil, err
}
response.CopyCommonResponse(&resp.CommonResponse)
return resp, nil
}

View File

@@ -29,7 +29,7 @@ func TestListUnprocessedShipments(t *testing.T) {
Status: "awaiting_packaging", Status: "awaiting_packaging",
}, },
Limit: 100, Limit: 100,
With: ListUnprocessedShipmentsWith{ With: &ListUnprocessedShipmentsWith{
AnalyticsData: true, AnalyticsData: true,
Barcodes: true, Barcodes: true,
FinancialData: true, FinancialData: true,
@@ -210,7 +210,7 @@ func TestGetFBSShipmentsList(t *testing.T) {
}, },
Limit: 0, Limit: 0,
Offset: 0, Offset: 0,
With: GetFBSShipmentsListWith{ With: &GetFBSShipmentsListWith{
AnalyticsData: true, AnalyticsData: true,
FinancialData: true, FinancialData: true,
Translit: true, Translit: true,
@@ -330,7 +330,7 @@ func TestPackOrder(t *testing.T) {
}, },
}, },
PostingNumber: "89491381-0072-1", PostingNumber: "89491381-0072-1",
With: PackOrderWith{ With: &PackOrderWith{
AdditionalData: true, AdditionalData: true,
}, },
}, },
@@ -556,7 +556,7 @@ func TestGetShipmentDataByIdentifier(t *testing.T) {
map[string]string{"Client-Id": "my-client-id", "Api-Key": "my-api-key"}, map[string]string{"Client-Id": "my-client-id", "Api-Key": "my-api-key"},
&GetShipmentDataByIdentifierParams{ &GetShipmentDataByIdentifierParams{
PostingNumber: "57195475-0050-3", PostingNumber: "57195475-0050-3",
With: GetShipmentDataByIdentifierWith{}, With: &GetShipmentDataByIdentifierWith{},
}, },
`{ `{
"result": { "result": {
@@ -1395,15 +1395,27 @@ func TestCheckProductItemsData(t *testing.T) {
http.StatusOK, http.StatusOK,
map[string]string{"Client-Id": "my-client-id", "Api-Key": "my-api-key"}, map[string]string{"Client-Id": "my-client-id", "Api-Key": "my-api-key"},
&CheckProductItemsDataParams{ &CheckProductItemsDataParams{
PostingNumber: "48173252-0034-4", MultiBoxQuantity: 0,
Products: CheckProductItemsDataProduct{ PostingNumber: "1234",
Exemplars: []FBSProductExemplar{ Products: []CheckProductItemsDataProduct{
{ {
IsGTDAbsest: true, Exemplars: []CheckProductItemsDataProductExemplar{
MandatoryMark: "010290000151642731tVMohkbfFgunB", {
ExemplarId: 1,
GTD: "string",
IsGTDAbsent: true,
IsRNPTAbsent: true,
MandatoryMark: "string",
RNPT: "string",
JWUIN: "string",
}, },
}, },
ProductId: 476925391, IsGTDNeeded: true,
IsMandatoryMarkNeeded: true,
IsRNPTNeeded: true,
ProductId: 22,
Quantity: 11,
},
}, },
}, },
`{ `{
@@ -1784,22 +1796,15 @@ func TestPartialPackOrder(t *testing.T) {
PostingNumber: "48173252-0034-4", PostingNumber: "48173252-0034-4",
Products: []PartialPackOrderProduct{ Products: []PartialPackOrderProduct{
{ {
ExemplarInfo: []FBSProductExemplar{ ExemplarIds: []string{"string"},
{
MandatoryMark: "mark",
GTD: "gtd",
IsGTDAbsest: true,
},
},
ProductId: 247508873, ProductId: 247508873,
Quantity: 1, Quantity: 1,
}, },
}, },
}, },
`{ `
"result": [ {
"48173252-0034-9" "result": "48173252-0034-9"
]
}`, }`,
}, },
// Test No Client-Id or Api-Key // Test No Client-Id or Api-Key
@@ -2843,3 +2848,74 @@ func TestGetActPDF(t *testing.T) {
} }
} }
} }
func TestCreateOrGetProductExemplar(t *testing.T) {
t.Parallel()
tests := []struct {
statusCode int
headers map[string]string
params *CreateOrGetProductExemplarParams
response string
}{
// Test Ok
{
http.StatusOK,
map[string]string{"Client-Id": "my-client-id", "Api-Key": "my-api-key"},
&CreateOrGetProductExemplarParams{
PostingNumber: "string",
},
`{
"multi_box_qty": 0,
"posting_number": "string",
"products": [
{
"exemplars": [
{
"exemplar_id": 0,
"gtd": "string",
"is_gtd_absent": true,
"is_rnpt_absent": true,
"mandatory_mark": "string",
"rnpt": "string",
"jw_uin": "string"
}
],
"is_gtd_needed": true,
"is_mandatory_mark_needed": true,
"is_rnpt_needed": true,
"product_id": 0,
"quantity": 0
}
]
}`,
},
// Test No Client-Id or Api-Key
{
http.StatusUnauthorized,
map[string]string{},
&CreateOrGetProductExemplarParams{},
`{
"code": 16,
"message": "Client-Id and Api-Key headers are required"
}`,
},
}
for _, test := range tests {
c := NewMockClient(core.NewMockHttpHandler(test.statusCode, test.response, test.headers))
ctx, _ := context.WithTimeout(context.Background(), testTimeout)
resp, err := c.FBS().CreateOrGetProductExemplar(ctx, test.params)
if err != nil {
t.Error(err)
continue
}
compareJsonResponse(t, test.response, &CreateOrGetProductExemplarResponse{})
if resp.StatusCode != test.statusCode {
t.Errorf("got wrong status code: got: %d, expected: %d", resp.StatusCode, test.statusCode)
}
}
}

View File

@@ -10,6 +10,15 @@ const (
DefaultAPIBaseUrl = "https://api-seller.ozon.ru" DefaultAPIBaseUrl = "https://api-seller.ozon.ru"
) )
type ClientOptions struct {
client core.HttpClient
baseUri string
apiKey string
clientId string
}
type Client struct { type Client struct {
client *core.Client client *core.Client
@@ -110,10 +119,46 @@ func (c Client) Barcodes() *Barcodes {
return c.barcodes return c.barcodes
} }
func NewClient(httpClient core.HttpClient, clientId, apiKey string) *Client { type ClientOption func(c *ClientOptions)
coreClient := core.NewClient(httpClient, DefaultAPIBaseUrl, map[string]string{
"Client-Id": clientId, func WithHttpClient(httpClient core.HttpClient) ClientOption {
"Api-Key": apiKey, return func(c *ClientOptions) {
c.client = httpClient
}
}
func WithURI(uri string) ClientOption {
return func(c *ClientOptions) {
c.baseUri = uri
}
}
func WithClientId(clientId string) ClientOption {
return func(c *ClientOptions) {
c.clientId = clientId
}
}
func WithAPIKey(apiKey string) ClientOption {
return func(c *ClientOptions) {
c.apiKey = apiKey
}
}
func NewClient(opts ...ClientOption) *Client {
// default values
options := &ClientOptions{
client: http.DefaultClient,
baseUri: DefaultAPIBaseUrl,
}
for _, opt := range opts {
opt(options)
}
coreClient := core.NewClient(options.client, options.baseUri, map[string]string{
"Client-Id": options.clientId,
"Api-Key": options.apiKey,
}) })
return &Client{ return &Client{

27
ozon/ozon_test.go Normal file
View File

@@ -0,0 +1,27 @@
package ozon
import (
"net/http"
"testing"
)
const (
apiKey = "some_key"
clientId = "some_client_id"
)
func TestNewClient(t *testing.T) {
client := NewClient(
WithAPIKey(apiKey),
WithClientId(clientId),
WithURI(DefaultAPIBaseUrl),
WithHttpClient(http.DefaultClient),
)
if client.client.Options["Api-Key"] != apiKey {
t.Errorf("expected api key: %s, but got: %s", apiKey, client.client.Options["Api-Key"])
}
if client.client.Options["Client-Id"] != clientId {
t.Errorf("expected client id: %s, but got: %s", clientId, client.client.Options["Client-Id"])
}
}

View File

@@ -27,13 +27,13 @@ type GetStocksInfoParams struct {
type GetStocksInfoFilter struct { type GetStocksInfoFilter struct {
// Filter by the offer_id parameter. It is possible to pass a list of values // Filter by the offer_id parameter. It is possible to pass a list of values
OfferId string `json:"offer_id"` OfferId string `json:"offer_id,omitempty"`
// Filter by the product_id parameter. It is possible to pass a list of values // Filter by the product_id parameter. It is possible to pass a list of values
ProductId int64 `json:"product_id"` ProductId int64 `json:"product_id,omitempty"`
// Filter by product visibility // Filter by product visibility
Visibility string `json:"visibility"` Visibility string `json:"visibility,omitempty"`
} }
type GetStocksInfoResponse struct { type GetStocksInfoResponse struct {
@@ -130,6 +130,9 @@ type ProductDetails struct {
// Category identifier // Category identifier
DescriptionCategoryId int64 `json:"description_category_id"` DescriptionCategoryId int64 `json:"description_category_id"`
// Product type identifier
TypeId int64 `json:"type_id"`
// Marketing color // Marketing color
ColorImage string `json:"color_image"` ColorImage string `json:"color_image"`
@@ -142,6 +145,12 @@ type ProductDetails struct {
// Product SKU // Product SKU
SKU int64 `json:"sku"` SKU int64 `json:"sku"`
// SKU of the product that is sold from the Ozon warehouse (FBO)
FBOSKU int64 `json:"fbo_sku,omitempty"`
// SKU of the product that is sold from the seller's warehouse (FBS and rFBS)
FBSSKU int64 `json:"fbs_sku,omitempty"`
// Document generation task number // Document generation task number
Id int64 `json:"id"` Id int64 `json:"id"`
@@ -853,7 +862,7 @@ type CreateOrUpdateAttribute struct {
type CreateOrUpdateAttributeValue struct { type CreateOrUpdateAttributeValue struct {
// Directory identifier // Directory identifier
DictionaryValueId int64 `json:"dictrionary_value_id"` DictionaryValueId int64 `json:"dictionary_value_id"`
// Value from the directory // Value from the directory
Value string `json:"value"` Value string `json:"value"`
@@ -888,7 +897,7 @@ type CreateOrUpdateProductResult struct {
// This method allows you to create products and update their details // This method allows you to create products and update their details
func (c Products) CreateOrUpdateProduct(ctx context.Context, params *CreateOrUpdateProductParams) (*CreateOrUpdateProductResponse, error) { func (c Products) CreateOrUpdateProduct(ctx context.Context, params *CreateOrUpdateProductParams) (*CreateOrUpdateProductResponse, error) {
url := "/v2/product/import" url := "/v3/product/import"
resp := &CreateOrUpdateProductResponse{} resp := &CreateOrUpdateProductResponse{}
@@ -1347,10 +1356,10 @@ type GetDescriptionOfProductParams struct {
Limit int64 `json:"limit"` Limit int64 `json:"limit"`
// The parameter by which the products will be sorted // The parameter by which the products will be sorted
SortBy string `json:"sort_by"` SortBy string `json:"sort_by,omitempty"`
// Sorting direction // Sorting direction
SortDirection string `json:"sort_direction"` SortDirection string `json:"sort_dir,omitempty"`
} }
type GetDescriptionOfProductFilter struct { type GetDescriptionOfProductFilter struct {
@@ -1609,7 +1618,7 @@ func (c Products) GetProductRangeLimit(ctx context.Context) (*GetProductRangeLim
resp := &GetProductRangeLimitResponse{} resp := &GetProductRangeLimitResponse{}
response, err := c.client.Request(ctx, http.MethodPost, url, &struct{}{}, resp, nil) response, err := c.client.Request(ctx, http.MethodPost, url, nil, resp, nil)
if err != nil { if err != nil {
return nil, err return nil, err
} }
@@ -1937,7 +1946,7 @@ type GetPRoductPriceInfoResultItem struct {
Commissions GetProductPriceInfoResultItemCommission `json:"commissions"` Commissions GetProductPriceInfoResultItemCommission `json:"commissions"`
// Promotions information // Promotions information
MarketingActions []GetProductPriceInfoResultItemMarketingActions `json:"marketing_actions"` MarketingActions *GetProductPriceInfoResultItemMarketingActions `json:"marketing_actions"`
// Seller product identifier // Seller product identifier
OfferId string `json:"offer_id"` OfferId string `json:"offer_id"`

View File

@@ -127,7 +127,7 @@ func TestGetProductDetails(t *testing.T) {
"7533900005" "7533900005"
], ],
"buybox_price": "", "buybox_price": "",
"description_category_id": 17038062, "type_id": 0,
"created_at": "2021-10-21T15:48:03.529178Z", "created_at": "2021-10-21T15:48:03.529178Z",
"images": [ "images": [
"https://cdn1.ozone.ru/s3/multimedia-5/6088931525.jpg", "https://cdn1.ozone.ru/s3/multimedia-5/6088931525.jpg",
@@ -141,6 +141,7 @@ func TestGetProductDetails(t *testing.T) {
"reserved": 0 "reserved": 0
}, },
"currency_code": "RUB", "currency_code": "RUB",
"description_category_id": 12,
"marketing_price": "", "marketing_price": "",
"min_price": "", "min_price": "",
"old_price": "", "old_price": "",
@@ -1378,6 +1379,7 @@ func TestListProductsByIDs(t *testing.T) {
], ],
"buybox_price": "", "buybox_price": "",
"description_category_id": 93726157, "description_category_id": 93726157,
"type_id": 0,
"created_at": "2021-06-03T03:40:05.871465Z", "created_at": "2021-06-03T03:40:05.871465Z",
"images": [], "images": [],
"has_discounted_item": true, "has_discounted_item": true,
@@ -1420,7 +1422,24 @@ func TestListProductsByIDs(t *testing.T) {
"active_product": false, "active_product": false,
"reasons": {} "reasons": {}
}, },
"price_index": "0.00", "price_indexes": {
"external_index_data": {
"minimal_price": "string",
"minimal_price_currency": "string",
"price_index_value": 0
},
"ozon_index_data": {
"minimal_price": "string",
"minimal_price_currency": "string",
"price_index_value": 0
},
"price_index": "WITHOUT_INDEX",
"self_marketplaces_index_data": {
"minimal_price": "string",
"minimal_price_currency": "string",
"price_index_value": 0
}
},
"images360": [], "images360": [],
"is_kgt": false, "is_kgt": false,
"color_image": "", "color_image": "",

View File

@@ -154,7 +154,7 @@ type ProductsAvailableForPromotionParams struct {
// Number of elements that will be skipped in the response. // Number of elements that will be skipped in the response.
// For example, if offset=10, the response will start with the 11th element found // For example, if offset=10, the response will start with the 11th element found
Offset float64 `json:"offset"` Offset float64 `json:"offset,omitempty"`
} }
type ProductsAvailableForPromotionResponse struct { type ProductsAvailableForPromotionResponse struct {
@@ -218,7 +218,7 @@ type ProductsInPromotionParams struct {
Limit float64 `json:"limit"` Limit float64 `json:"limit"`
// Number of elements that will be skipped in the response. For example, if offset=10, the response will start with the 11th element found // Number of elements that will be skipped in the response. For example, if offset=10, the response will start with the 11th element found
Offset float64 `json:"offset"` Offset float64 `json:"offset,omitempty"`
} }
type ProductsInPromotionResponse struct { type ProductsInPromotionResponse struct {
@@ -355,7 +355,7 @@ type ProductsAvailableForHotSalePromotionParams struct {
Limit float64 `json:"limit"` Limit float64 `json:"limit"`
// Number of elements that will be skipped in the response. For example, if offset=10, the response will start with the 11th element found // Number of elements that will be skipped in the response. For example, if offset=10, the response will start with the 11th element found
Offset float64 `json:"offset"` Offset float64 `json:"offset,omitempty"`
} }
type ProductsAvailableForHotSalePromotionResponse struct { type ProductsAvailableForHotSalePromotionResponse struct {

View File

@@ -450,7 +450,7 @@ func (c Reports) GetProducts(ctx context.Context, params *GetProductsReportParam
type GetReturnsReportParams struct { type GetReturnsReportParams struct {
// Filter // Filter
Filter GetReturnsReportsFilter `json:"filter"` Filter *GetReturnsReportsFilter `json:"filter,omitempty"`
// Default: "DEFAULT" // Default: "DEFAULT"
// Response language: // Response language:
@@ -501,7 +501,7 @@ func (c Reports) GetReturns(ctx context.Context, params *GetReturnsReportParams)
type GetShipmentReportParams struct { type GetShipmentReportParams struct {
// Filter // Filter
Filter GetShipmentReportFilter `json:"filter"` Filter *GetShipmentReportFilter `json:"filter,omitempty"`
// Default: "DEFAULT" // Default: "DEFAULT"
// Response language: // Response language:

View File

@@ -375,7 +375,7 @@ func TestGetReturnsReport(t *testing.T) {
http.StatusOK, http.StatusOK,
map[string]string{"Client-Id": "my-client-id", "Api-Key": "my-api-key"}, map[string]string{"Client-Id": "my-client-id", "Api-Key": "my-api-key"},
&GetReturnsReportParams{ &GetReturnsReportParams{
Filter: GetReturnsReportsFilter{ Filter: &GetReturnsReportsFilter{
DeliverySchema: "fbs", DeliverySchema: "fbs",
}, },
}, },
@@ -435,7 +435,7 @@ func TestGetShipmentReport(t *testing.T) {
http.StatusOK, http.StatusOK,
map[string]string{"Client-Id": "my-client-id", "Api-Key": "my-api-key"}, map[string]string{"Client-Id": "my-client-id", "Api-Key": "my-api-key"},
&GetShipmentReportParams{ &GetShipmentReportParams{
Filter: GetShipmentReportFilter{ Filter: &GetShipmentReportFilter{
DeliverySchema: []string{"fbs", "fbo", "crossborder"}, DeliverySchema: []string{"fbs", "fbo", "crossborder"},
ProcessedAtFrom: core.TimeFromString(t, "2006-01-02T15:04:05Z", "2021-09-02T17:10:54.861Z"), ProcessedAtFrom: core.TimeFromString(t, "2006-01-02T15:04:05Z", "2021-09-02T17:10:54.861Z"),
ProcessedAtTo: core.TimeFromString(t, "2006-01-02T15:04:05Z", "2021-11-02T17:10:54.861Z"), ProcessedAtTo: core.TimeFromString(t, "2006-01-02T15:04:05Z", "2021-11-02T17:10:54.861Z"),

View File

@@ -14,7 +14,7 @@ type Returns struct {
type GetFBOReturnsParams struct { type GetFBOReturnsParams struct {
// Filter // Filter
Filter GetFBOReturnsFilter `json:"filter"` Filter *GetFBOReturnsFilter `json:"filter,omitempty"`
// Identifier of the last value on the page. Leave this field blank in the first request. // Identifier of the last value on the page. Leave this field blank in the first request.
// //
@@ -56,7 +56,7 @@ type GetFBOReturnsReturn struct {
// Return destination // Return destination
DestinationPlaceName string `json:"dst_place_name"` DestinationPlaceName string `json:"dst_place_name"`
// Return identifier // Return shipment identifier
Id int64 `json:"id"` Id int64 `json:"id"`
// Indication that the package has been opened. true, if it has been // Indication that the package has been opened. true, if it has been
@@ -65,6 +65,9 @@ type GetFBOReturnsReturn struct {
// Shipment number // Shipment number
PostingNumber string `json:"posting_number"` PostingNumber string `json:"posting_number"`
// Unique return record identifier
ReturnId int64 `json:"return_id"`
// Return reason // Return reason
ReturnReasonName string `json:"return_reason_name"` ReturnReasonName string `json:"return_reason_name"`
@@ -95,7 +98,7 @@ func (c Returns) GetFBOReturns(ctx context.Context, params *GetFBOReturnsParams)
type GetFBSReturnsParams struct { type GetFBSReturnsParams struct {
// Filter // Filter
Filter GetFBSReturnsFilter `json:"filter"` Filter *GetFBSReturnsFilter `json:"filter,omitempty"`
// Number of values in the response: // Number of values in the response:
// - maximum — 1000, // - maximum — 1000,
@@ -264,7 +267,7 @@ func (c Returns) GetFBSReturns(ctx context.Context, params *GetFBSReturnsParams)
type GetRFBSReturnsParams struct { type GetRFBSReturnsParams struct {
// Filter // Filter
Filter GetRFBSReturnsFilter `json:"filter"` Filter *GetRFBSReturnsFilter `json:"filter,omitempty"`
// Identifier of the last value on the page. // Identifier of the last value on the page.
// Leave this field blank in the first request // Leave this field blank in the first request
@@ -667,7 +670,7 @@ func (c Returns) IsGiveoutEnabled(ctx context.Context) (*IsGiveoutEnabledRespons
resp := &IsGiveoutEnabledResponse{} resp := &IsGiveoutEnabledResponse{}
response, err := c.client.Request(ctx, http.MethodPost, url, struct{}{}, resp, nil) response, err := c.client.Request(ctx, http.MethodPost, url, nil, resp, nil)
if err != nil { if err != nil {
return nil, err return nil, err
} }
@@ -697,7 +700,7 @@ func (c Returns) GetGiveoutPDF(ctx context.Context) (*GetGiveoutResponse, error)
resp := &GetGiveoutResponse{} resp := &GetGiveoutResponse{}
response, err := c.client.Request(ctx, http.MethodPost, url, struct{}{}, resp, nil) response, err := c.client.Request(ctx, http.MethodPost, url, nil, resp, nil)
if err != nil { if err != nil {
return nil, err return nil, err
} }
@@ -714,7 +717,7 @@ func (c Returns) GetGiveoutPNG(ctx context.Context) (*GetGiveoutResponse, error)
resp := &GetGiveoutResponse{} resp := &GetGiveoutResponse{}
response, err := c.client.Request(ctx, http.MethodPost, url, struct{}{}, resp, nil) response, err := c.client.Request(ctx, http.MethodPost, url, nil, resp, nil)
if err != nil { if err != nil {
return nil, err return nil, err
} }
@@ -739,7 +742,7 @@ func (c Returns) GetGiveoutBarcode(ctx context.Context) (*GetGiveoutBarcodeRespo
resp := &GetGiveoutBarcodeResponse{} resp := &GetGiveoutBarcodeResponse{}
response, err := c.client.Request(ctx, http.MethodPost, url, struct{}{}, resp, nil) response, err := c.client.Request(ctx, http.MethodPost, url, nil, resp, nil)
if err != nil { if err != nil {
return nil, err return nil, err
} }
@@ -758,7 +761,7 @@ func (c Returns) ResetGiveoutBarcode(ctx context.Context) (*GetGiveoutResponse,
resp := &GetGiveoutResponse{} resp := &GetGiveoutResponse{}
response, err := c.client.Request(ctx, http.MethodPost, url, struct{}{}, resp, nil) response, err := c.client.Request(ctx, http.MethodPost, url, nil, resp, nil)
if err != nil { if err != nil {
return nil, err return nil, err
} }
@@ -814,7 +817,7 @@ func (c Returns) GetGiveoutList(ctx context.Context, params *GetGiveoutListParam
resp := &GetGiveoutListResponse{} resp := &GetGiveoutListResponse{}
response, err := c.client.Request(ctx, http.MethodPost, url, struct{}{}, resp, nil) response, err := c.client.Request(ctx, http.MethodPost, url, nil, resp, nil)
if err != nil { if err != nil {
return nil, err return nil, err
} }
@@ -867,7 +870,7 @@ func (c Returns) GetGiveoutInfo(ctx context.Context, params *GetGiveoutInfoParam
resp := &GetGiveoutInfoResponse{} resp := &GetGiveoutInfoResponse{}
response, err := c.client.Request(ctx, http.MethodPost, url, struct{}{}, resp, nil) response, err := c.client.Request(ctx, http.MethodPost, url, nil, resp, nil)
if err != nil { if err != nil {
return nil, err return nil, err
} }

View File

@@ -22,7 +22,7 @@ func TestGetFBOReturns(t *testing.T) {
http.StatusOK, http.StatusOK,
map[string]string{"Client-Id": "my-client-id", "Api-Key": "my-api-key"}, map[string]string{"Client-Id": "my-client-id", "Api-Key": "my-api-key"},
&GetFBOReturnsParams{ &GetFBOReturnsParams{
Filter: GetFBOReturnsFilter{ Filter: &GetFBOReturnsFilter{
PostingNumber: "some number", PostingNumber: "some number",
}, },
LastId: 123, LastId: 123,
@@ -105,7 +105,7 @@ func TestGetFBSReturns(t *testing.T) {
http.StatusOK, http.StatusOK,
map[string]string{"Client-Id": "my-client-id", "Api-Key": "my-api-key"}, map[string]string{"Client-Id": "my-client-id", "Api-Key": "my-api-key"},
&GetFBSReturnsParams{ &GetFBSReturnsParams{
Filter: GetFBSReturnsFilter{ Filter: &GetFBSReturnsFilter{
PostingNumber: []string{"07402477-0022-2"}, PostingNumber: []string{"07402477-0022-2"},
Status: "returned_to_seller", Status: "returned_to_seller",
}, },
@@ -212,7 +212,7 @@ func TestGetRFBSReturns(t *testing.T) {
&GetRFBSReturnsParams{ &GetRFBSReturnsParams{
LastId: 999, LastId: 999,
Limit: 555, Limit: 555,
Filter: GetRFBSReturnsFilter{ Filter: &GetRFBSReturnsFilter{
OfferId: "123", OfferId: "123",
PostingNumber: "111", PostingNumber: "111",
GroupState: []RFBSReturnsGroupState{RFBSReturnsGroupStateAll}, GroupState: []RFBSReturnsGroupState{RFBSReturnsGroupStateAll},

View File

@@ -102,7 +102,7 @@ func (c Warehouses) GetListOfWarehouses(ctx context.Context) (*GetListOfWarehous
type GetListOfDeliveryMethodsParams struct { type GetListOfDeliveryMethodsParams struct {
// Search filter for delivery methods // Search filter for delivery methods
Filter GetListOfDeliveryMethodsFilter `json:"filter"` Filter *GetListOfDeliveryMethodsFilter `json:"filter,omitempty"`
// Number of items in a response. Maximum is 50, minimum is 1 // Number of items in a response. Maximum is 50, minimum is 1
Limit int64 `json:"limit"` Limit int64 `json:"limit"`
@@ -181,7 +181,7 @@ func (c Warehouses) GetListOfDeliveryMethods(ctx context.Context, params *GetLis
resp := &GetListOfDeliveryMethodsResponse{} resp := &GetListOfDeliveryMethodsResponse{}
response, err := c.client.Request(ctx, http.MethodPost, url, nil, resp, nil) response, err := c.client.Request(ctx, http.MethodPost, url, params, resp, nil)
if err != nil { if err != nil {
return nil, err return nil, err
} }

View File

@@ -99,7 +99,7 @@ func TestGetListOfDeliveryMethods(t *testing.T) {
http.StatusOK, http.StatusOK,
map[string]string{"Client-Id": "my-client-id", "Api-Key": "my-api-key"}, map[string]string{"Client-Id": "my-client-id", "Api-Key": "my-api-key"},
&GetListOfDeliveryMethodsParams{ &GetListOfDeliveryMethodsParams{
Filter: GetListOfDeliveryMethodsFilter{ Filter: &GetListOfDeliveryMethodsFilter{
WarehouseId: 15588127982000, WarehouseId: 15588127982000,
}, },
Limit: 100, Limit: 100,