391 lines
8.8 KiB
Go
391 lines
8.8 KiB
Go
package ozon
|
|
|
|
import (
|
|
"net/http"
|
|
"time"
|
|
|
|
core "github.com/diphantxm/ozon-api-client"
|
|
)
|
|
|
|
type Chats struct {
|
|
client *core.Client
|
|
}
|
|
|
|
type ListChatsParams struct {
|
|
// Chats filter
|
|
Filter ListChatsFilter `json:"filter"`
|
|
|
|
// Number of values in the response. Default value is 1
|
|
Limit int64 `json:"limit" default:"1"`
|
|
|
|
// 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"`
|
|
}
|
|
|
|
type ListChatsFilter struct {
|
|
// Filter by chat status:
|
|
// - All
|
|
// - Opened
|
|
// - Closed
|
|
ChatStatus string `json:"chat_status" default:"ALL"`
|
|
|
|
// Filter by chats with unread messages
|
|
UnreadOnly bool `json:"unread_only"`
|
|
}
|
|
|
|
type ListChatsResponse struct {
|
|
core.CommonResponse
|
|
|
|
// Chats data
|
|
Chats []struct {
|
|
// Chat data
|
|
Chat struct {
|
|
// Chat identifier
|
|
ChatId string `json:"chat_id"`
|
|
|
|
// Chat status:
|
|
// - All
|
|
// - Opened
|
|
// - Closed
|
|
ChatStatus string `json:"chat_status"`
|
|
|
|
// Chat type:
|
|
// - Seller_Support — support chat
|
|
// - Buyer_Seller — chat with a customer
|
|
ChatType string `json:"chat_type"`
|
|
|
|
// Chat creation date
|
|
CreatedAt time.Time `json:"created_at"`
|
|
} `json:"chat"`
|
|
|
|
// Identifier of the first unread chat message
|
|
FirstUnreadMessageId string `json:"first_unread_message_id"`
|
|
|
|
// Identifier of the last message in the chat
|
|
LastMessageId string `json:"last_message_id"`
|
|
|
|
// Number of unread messages in the chat
|
|
UnreadCount int64 `json:"unread_count"`
|
|
} `json:"chats"`
|
|
|
|
// Total number of chats
|
|
TotalChatsCount int64 `json:"total_chats_count"`
|
|
|
|
// Total number of unread messages
|
|
TotalUnreadCount int64 `json:"total_unread_count"`
|
|
}
|
|
|
|
// Returns information about chats by specified filters
|
|
func (c Chats) List(params *ListChatsParams) (*ListChatsResponse, error) {
|
|
url := "/v2/chat/list"
|
|
|
|
resp := &ListChatsResponse{}
|
|
|
|
response, err := c.client.Request(http.MethodPost, url, params, resp, nil)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
response.CopyCommonResponse(&resp.CommonResponse)
|
|
|
|
return resp, nil
|
|
}
|
|
|
|
type SendMessageParams struct {
|
|
// Chat identifier
|
|
ChatId string `json:"chat_id"`
|
|
|
|
// Message text in the plain text format
|
|
Text string `json:"text"`
|
|
}
|
|
|
|
type SendMessageResponse struct {
|
|
core.CommonResponse
|
|
|
|
// Method result
|
|
Result string `json:"result"`
|
|
}
|
|
|
|
// Sends a message to an existing chat by its identifier
|
|
func (c Chats) SendMessage(params *SendMessageParams) (*SendMessageResponse, error) {
|
|
url := "/v1/chat/send/message"
|
|
|
|
resp := &SendMessageResponse{}
|
|
|
|
response, err := c.client.Request(http.MethodPost, url, params, resp, nil)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
response.CopyCommonResponse(&resp.CommonResponse)
|
|
|
|
return resp, nil
|
|
}
|
|
|
|
type SendFileParams struct {
|
|
// File as a base64 string
|
|
Base64Content string `json:"base64_content"`
|
|
|
|
// Chat identifier
|
|
ChatId string `json:"chat_id"`
|
|
|
|
// File name with extension
|
|
Name string `json:"name"`
|
|
}
|
|
|
|
type SendFileResponse struct {
|
|
core.CommonResponse
|
|
|
|
// Method result
|
|
Result string `json:"result"`
|
|
}
|
|
|
|
// Sends a file to an existing chat by its identifier
|
|
func (c Chats) SendFile(params *SendFileParams) (*SendFileResponse, error) {
|
|
url := "/v1/chat/send/file"
|
|
|
|
resp := &SendFileResponse{}
|
|
|
|
response, err := c.client.Request(http.MethodPost, url, params, resp, nil)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
response.CopyCommonResponse(&resp.CommonResponse)
|
|
|
|
return resp, nil
|
|
}
|
|
|
|
type ChatHistoryParams struct {
|
|
// Chat idenitifier
|
|
ChatId string `json:"chat_id"`
|
|
|
|
// Messages sorting direction:
|
|
// - Forward—from old messages to new ones.
|
|
// - Backward—from new messages to old ones.
|
|
// The default value is `Backward`. You can set the number of messages in the limit parameter
|
|
Direction string `json:"direction" default:"Backward"`
|
|
|
|
// Identifier of the message from which the chat history will be displayed.
|
|
// Default value is the last visible message
|
|
FromMessageId string `json:"from_message_id"`
|
|
|
|
// Number of messages in the response. The default value is 50
|
|
Limit int64 `json:"limit" default:"50"`
|
|
}
|
|
|
|
type ChatHistoryResponse struct {
|
|
core.CommonResponse
|
|
|
|
// Indicates that the response returned only a part of messages
|
|
HasNext bool `json:"has_next"`
|
|
|
|
// An array of messages sorted according to the direction parameter in the request body
|
|
Messages []struct {
|
|
// Message creation date
|
|
CreatedAt time.Time `json:"created_at"`
|
|
|
|
// Array with message content in Markdown format
|
|
Data []string `json:"data"`
|
|
|
|
// Indication of the read message
|
|
IsRead bool `json:"is_read"`
|
|
|
|
// Message identifier
|
|
MessageId string `json:"message_id"`
|
|
|
|
// Chat participant identifier
|
|
User struct {
|
|
// Chat participant identifier
|
|
Id string `json:"id"`
|
|
|
|
// Chat participant type:
|
|
// - customer
|
|
// - seller
|
|
// - crm—system messages
|
|
// - courier
|
|
// - support
|
|
Type string `json:"type"`
|
|
} `json:"user"`
|
|
} `json:"messages"`
|
|
}
|
|
|
|
// Chat history
|
|
func (c Chats) History(params *ChatHistoryParams) (*ChatHistoryResponse, error) {
|
|
url := "/v2/chat/history"
|
|
|
|
resp := &ChatHistoryResponse{}
|
|
|
|
response, err := c.client.Request(http.MethodPost, url, params, resp, nil)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
response.CopyCommonResponse(&resp.CommonResponse)
|
|
|
|
return resp, nil
|
|
}
|
|
|
|
type UpdateChatParams struct {
|
|
// Chat identifier
|
|
ChatId string `json:"chat_id"`
|
|
|
|
// Message identifier
|
|
FromMessageId uint64 `json:"from_message_id"`
|
|
|
|
// Number of messages in the response
|
|
Limit int64 `json:"limit"`
|
|
}
|
|
|
|
type UpdateChatResponse struct {
|
|
core.CommonResponse
|
|
|
|
// Method result
|
|
Result []struct {
|
|
// An order or a product user wrote about in the chat
|
|
Context struct {
|
|
// Product inforamtion
|
|
Item struct {
|
|
// Product identifier in the Ozon system, SKU
|
|
SKU int64 `json:"sku"`
|
|
} `json:"item"`
|
|
|
|
// Order information
|
|
Order struct {
|
|
// Order number
|
|
OrderNumber string `json:"order_number"`
|
|
|
|
// Shipment information
|
|
Postings []struct {
|
|
// Delivery scheme:
|
|
// - FBO
|
|
// - FBS
|
|
// - RFBS
|
|
// - Crossborder
|
|
DeliverySchema string `json:"delivery_schema"`
|
|
|
|
// Shipment number
|
|
PostingNumber string `json:"posting_number"`
|
|
|
|
// List of product identifiers in the shipment
|
|
SKUList []int64 `json:"sku_list"`
|
|
} `json:"postings"`
|
|
} `json:"order"`
|
|
} `json:"context"`
|
|
|
|
// Creation date and time
|
|
CreatedAt time.Time `json:"created_at"`
|
|
|
|
// Information about the file in the chat. Displayed only for `type = file`
|
|
File struct {
|
|
// File type
|
|
Mime string `json:"mime"`
|
|
|
|
// File name
|
|
Name string `json:"name"`
|
|
|
|
// File size in bytes
|
|
Size int64 `json:"size"`
|
|
|
|
// File URL
|
|
URL string `json:"url"`
|
|
} `json:"file"`
|
|
|
|
// File identifier
|
|
Id uint64 `json:"id"`
|
|
|
|
// Message. Displayed only for `type = text`
|
|
Text string `json:"text"`
|
|
|
|
// Message type:
|
|
// - text
|
|
// - file
|
|
Type string `json:"type"`
|
|
|
|
// Chat participant information
|
|
User struct {
|
|
// Chat participant identifier
|
|
Id string `json:"id"`
|
|
|
|
// Chat participant chat:
|
|
// - customer
|
|
// - seller
|
|
// - crm—system messages
|
|
// - courier
|
|
Type string `json:"type"`
|
|
} `json:"user"`
|
|
} `json:"result"`
|
|
}
|
|
|
|
// Update chat
|
|
func (c Chats) Update(params *UpdateChatParams) (*UpdateChatResponse, error) {
|
|
url := "/v1/chat/updates"
|
|
|
|
resp := &UpdateChatResponse{}
|
|
|
|
response, err := c.client.Request(http.MethodPost, url, params, resp, nil)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
response.CopyCommonResponse(&resp.CommonResponse)
|
|
|
|
return resp, nil
|
|
}
|
|
|
|
type CreateNewChatParams struct {
|
|
// Shipment identifier
|
|
PostingNumber string `json:"posting_number"`
|
|
}
|
|
|
|
type CreateNewChatResponse struct {
|
|
core.CommonResponse
|
|
|
|
//Method result
|
|
Result struct {
|
|
// Chat identifier
|
|
ChatId string `json:"chat_id"`
|
|
} `json:"result"`
|
|
}
|
|
|
|
// Creates a new chat on the shipment with the customer. For example, to clarify the address or the product model
|
|
func (c Chats) Create(params *CreateNewChatParams) (*CreateNewChatResponse, error) {
|
|
url := "/v1/chat/start"
|
|
|
|
resp := &CreateNewChatResponse{}
|
|
|
|
response, err := c.client.Request(http.MethodPost, url, params, resp, nil)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
response.CopyCommonResponse(&resp.CommonResponse)
|
|
|
|
return resp, nil
|
|
}
|
|
|
|
type MarkAsReadParams struct {
|
|
// Chat identifier
|
|
Chatid string `json:"chat_id"`
|
|
|
|
// Message identifier
|
|
FromMessageId uint64 `json:"from_message_id"`
|
|
}
|
|
|
|
type MarkAsReadResponse struct {
|
|
core.CommonResponse
|
|
|
|
// Number of unread messages in the chat
|
|
UnreadCount int64 `json:"unread_count"`
|
|
}
|
|
|
|
// A method for marking the selected message and messages before it as read
|
|
func (c Chats) MarkAsRead(params *MarkAsReadParams) (*MarkAsReadResponse, error) {
|
|
url := "/v2/chat/read"
|
|
|
|
resp := &MarkAsReadResponse{}
|
|
|
|
response, err := c.client.Request(http.MethodPost, url, params, resp, nil)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
response.CopyCommonResponse(&resp.CommonResponse)
|
|
|
|
return resp, nil
|
|
}
|