From 756740a2d7e451c54b1df484a1869a6d9eba1d23 Mon Sep 17 00:00:00 2001 From: sinhluu Date: Wed, 8 May 2024 07:26:17 +0000 Subject: [PATCH] feat(onpoint): get inventories (#17) Co-authored-by: Sinh Reviewed-on: https://git.selly.red/Selly-Modules/3pl/pulls/17 --- partnerapi/onpoint/const.go | 3 +- partnerapi/onpoint/model_request.go | 19 +++++--- partnerapi/onpoint/model_response.go | 33 +++++++++++++ partnerapi/onpoint/onpoint.go | 69 ++++++++++++++++++++++++++-- 4 files changed, 112 insertions(+), 12 deletions(-) diff --git a/partnerapi/onpoint/const.go b/partnerapi/onpoint/const.go index d45efac..5c406a6 100644 --- a/partnerapi/onpoint/const.go +++ b/partnerapi/onpoint/const.go @@ -21,13 +21,14 @@ const ( apiPathUpdateDelivery = "/v1/orders/update_delivery" apiPathCancelOrder = "/v1/orders/cancel" apiPathGetChannels = "/v1/channels" + apiPathGetInventories = "/v1/inventories" headerXAPIKey = "x-api-key" headerXTimestamp = "x-timestamp" headerXSignature = "x-signature" webhookEventUpdateOrderStatus = "UPDATE_ORDER_STATUS" - webhookEventUpdateInventory = "update_inventory" + webhookEventUpdateInventory = "UPDATE_INVENTORY" ) var ( diff --git a/partnerapi/onpoint/model_request.go b/partnerapi/onpoint/model_request.go index aca58b3..7f5f11c 100644 --- a/partnerapi/onpoint/model_request.go +++ b/partnerapi/onpoint/model_request.go @@ -50,19 +50,24 @@ type CancelOrderRequest struct { OrderNo string `json:"order_code"` } +type ListInventoriesReq struct { + UpdatedFrom time.Time + UpdatedTo time.Time + SKUList []string + Size int + Page int +} + /** * WEBHOOK ONPOINT */ // WebhookDataUpdateInventory ... type WebhookDataUpdateInventory struct { - Sku string `json:"sku"` - PartnerSku string `json:"partner_sku"` - WarehouseCode string `json:"warehouse_code"` - AvailableQuantity int `json:"available_quantity"` - CommittedQuantity int `json:"committed_quantity"` - TotalQuantity int `json:"total_quantity"` - UpdatedAt string `json:"updated_at"` + Sku string `json:"sku"` + AvailableQuantity int `json:"available_quantity"` + PickupLocationCode string `json:"pickup_location_code"` + UpdatedAt time.Time `json:"updated_at"` } // WebhookDataUpdateOrderStatus ... diff --git a/partnerapi/onpoint/model_response.go b/partnerapi/onpoint/model_response.go index 6ed84e0..237543a 100644 --- a/partnerapi/onpoint/model_response.go +++ b/partnerapi/onpoint/model_response.go @@ -1,5 +1,7 @@ package onpoint +import "time" + // CreateOrderResponse ... type CreateOrderResponse struct { OrderCode string `json:"order_code"` @@ -34,3 +36,34 @@ type ChannelResponse struct { Code string `json:"code"` Name string `json:"name"` } + +type ListInventoriesRes struct { + Code string `json:"code"` + Data struct { + Entries []InventoryEntry `json:"entries"` + Page int `json:"page"` + Size int `json:"size"` + TotalEntries int `json:"total_entries"` + TotalPages int `json:"total_pages"` + } `json:"data"` +} + +type InventoryEntry struct { + AvailableQuantity int `json:"available_quantity"` + PickupLocation Pickup `json:"pickup_location"` + Product Product `json:"product"` + UpdatedAt time.Time `json:"updated_at"` +} + +type Product struct { + Name string `json:"name"` + OriginalPrice int `json:"original_price"` + SellingPrice int `json:"selling_price"` + Sku string `json:"sku"` + Uom interface{} `json:"uom"` +} + +type Pickup struct { + Code string `json:"code"` + Name string `json:"name"` +} diff --git a/partnerapi/onpoint/onpoint.go b/partnerapi/onpoint/onpoint.go index c1f0cf1..a05a079 100644 --- a/partnerapi/onpoint/onpoint.go +++ b/partnerapi/onpoint/onpoint.go @@ -4,6 +4,7 @@ import ( "errors" "fmt" "net/http" + "net/url" "strconv" "strings" "time" @@ -152,19 +153,77 @@ func (c *Client) CancelOrder(p CancelOrderRequest) (*CancelOrderResponse, error) return &dataRes.Data, nil } +// GetInventories ... +func (c *Client) GetInventories(req ListInventoriesReq) (*ListInventoriesRes, error) { + url := c.getBaseURL() + apiPathGetInventories + q := map[string]string{} + if !req.UpdatedFrom.IsZero() { + q["updated_from"] = req.UpdatedFrom.Format(TimeLayout) + } + if !req.UpdatedTo.IsZero() { + q["updated_to"] = req.UpdatedTo.Format(TimeLayout) + } + if len(req.SKUList) > 0 { + q["sku_list"] = strings.Join(req.SKUList, ",") + } + if req.Page > 0 { + q["page"] = strconv.Itoa(req.Page) + } + if req.Size > 0 { + q["size"] = strconv.Itoa(req.Size) + } + natsPayload := model.CommunicationRequestHttp{ + ResponseImmediately: true, + Payload: model.HttpRequest{ + URL: url, + Method: http.MethodGet, + Query: q, + }, + } + var ( + r model.CommunicationHttpResponse + errRes Error + dataRes ListInventoriesRes + ) + if err := c.requestHttpViaNats(natsPayload, &r); err != nil { + return nil, err + } + res := r.Response + if res == nil { + return nil, fmt.Errorf("onpoint.Client.GetInventories: empty_response") + } + if res.StatusCode >= http.StatusBadRequest { + if err := r.ParseResponseData(&errRes); err != nil { + return nil, fmt.Errorf("onpoint.Client.GetInventories: parse_response_err: %v", err) + } + return nil, errRes + } + if err := r.ParseResponseData(&dataRes); err != nil { + return nil, fmt.Errorf("onpoint.Client.GetInventories: parse_response_data: %v", err) + } + + return &dataRes, nil +} + func (c *Client) requestHttpViaNats(data model.CommunicationRequestHttp, res interface{}) error { ec, err := c.natsClient.NewJSONEncodedConn() if err != nil { return fmt.Errorf("onpoint: request via nats %v", err) } - qs := "" - for k, v := range data.Payload.Query { - qs += k + "=" + v + u, err := url.ParseRequestURI(data.Payload.URL) + if err != nil { + return fmt.Errorf("onpoint: request via nats %v", err) } + q := u.Query() + for k, v := range data.Payload.Query { + q.Set(k, v) + } + u.RawQuery = q.Encode() + now := time.Now().Unix() ts := strconv.FormatInt(now, 10) arr := []string{ - qs, + u.RawQuery, data.Payload.Data, ts, } @@ -177,6 +236,8 @@ func (c *Client) requestHttpViaNats(data model.CommunicationRequestHttp, res int headerXTimestamp: ts, httputil.HeaderKeyContentType: httputil.HeaderValueApplicationJSON, } + data.Payload.Query = map[string]string{} + data.Payload.URL = u.String() return ec.Request(subject.Communication.RequestHTTP, data, res) }