/
Update Inventory Sequence Diagram

Update Inventory Sequence Diagram

Owned by Prateek Kaushik (Unlicensed)
Last updated: Apr 17, 2023
4 min read

 

Steps

Step 1. FlipkartInventoryListener(Subscriber) POST API will receive data like below and will store this data into TaskQueue

{ "inventoryList": [ { "productId": "12334", "parentId": null, "sku": "32CVB3GJA87", "variantId": 12334, "inventory": "24", "locationInventory": "12", "changeInStock": 0, } ], "account_id": 124, "account_slug": "Account Slug", "externalWmsChannelName": "External WMS ChannelName", "externalWmsAccount": "External WMS Account", "externalWarehouseID": "FSL4", "externalChannelID": "CH0566", "connectionId":"12", "channelSlug": null, "locationId": "3425567898876543456786", "publishedAt": "2020-07-21 19:49:47" }

Step 2. Now use connectionId from the data to fetch accessToken and store it into the cache memory in the following format

Using the below query, accessToken can be generated

SELECT ie_appinstall_connection.accessToken, ie_appinstall_conneciton.isActive FROM ie_appinstall_connection WHERE ie_appinstall_connection.id =:connectionId

Step 2.1 IF the connection status is active then only the below process will begin otherwise it will not.

Once the accessToken is generated store it into the Cache Memory in the format given below.

{ "connectionAccessToken_{{connectionId}}":"{{ACCESS TOKEN}}" }

Step 3 Once the event is received and status is checked, push the data into TaskQueue - inventory-queue and Queue Listener - /_ah/api/esb/v1/listen/inventoryfromwms

 

Step 4. Once the data is received in Queue Listener, Now transform the Data

Request Body

{ "<sku>": { "product_id": "<product_id>", "locations": [ { "id": "<location-id>", "inventory": 0 } ] } }

Warehouse Keys

Flipkart Keys

Warehouse Keys

Flipkart Keys

inventoryList[].skuId

<sku>

inventoryList[].productId

<sku>.product_id

locationId

<sku>.locations[].id

inventoryList[].locationInventory

<sku>.locations[].inventory

Step 4. Now use the accessToken and push the Transformed Data to Flipkart in the following format

POST API URL

https://api.flipkart.net/sellers/listings/v3/update/inventory

Request Body

{ "inventoryList[].skuId": { "product_id": "{{inventoryList[].productId}}", "locations": [ { "id": "{{locationId}}", "inventory": {{inventoryList[].locationInventory}} } ] } }

Response Body

  1. 200 OK

{ "sku": { "status": "success|failure|warning", "errors": [ { "severity": "ERROR|WARNING", "code": "<code>", "description": "<description>" } ], "attribute_errors": [ { "severity": "ERROR|WARNING", "code": "<code>", "description": "<description>", "attribute": "<attribute>", "path": "<path-to-attribute>" } ] } }

  1.  

400 Bad Request

{ "errors": [ { "severity": "ERROR|WARNING", "code": "<code>", "description": "<description>", "path": "<path-to-failed-json-node>" } ] }

  1.  

500 Internal ServerError

{ "errors": [ { "severity": "ERROR|WARNING", "code": "<code>", "description": "<description>" } ] }

 

Handling Inventory Mismatch Issue On Flipkart

 

Step 1: we receive Inventory Event from WMS:

{ "account_slug": "warehouse", "externalWmsAccount": "eshopbox", "publishedAt": "2023-04-10 12:42:03", "message_id": "202304101242002410", "inventoryList": [ { "productId": "NDFG37HR5GAVM4TW", "parentId": "Makhana", "sellerSku": "FMLY-Gold-Makhana-250G", "sku": "20CSI3H0X8Z", "variantId": "NDFG37HR5GAVM4TW", "inventory": "187", "changeInStock": -183.0, "locationInventory": 0.0, "locationId": "LOCfd8bf10d30e948cd8b0dc0af6226c5de" } ], "message": "GOOD_INVENTORY_UPDATE", "externalWmsChannelName": "FLIPKART_FARMELY_XBLR_2174", "externalWarehouseID": "Bangalore_FC", "connectionId": 1036.0, "locationId": "LOCfd8bf10d30e948cd8b0dc0af6226c5de", "externalChannelID": "CH2001", "integrationType": "6" }

Step 2: Fetch inventoryList[].sellerSku AS sellerSku, also I will fetch EventLocationId = inventoryList[].locationId and eventLocationInventory = inventoryList[].locationInventory

Step 3: Call the below API to fetch Flipkart Listing Details By using the above sellerSku

curl --location --request GET 'https://api.flipkart.net/sellers/listings/v3/{sellerSku}' \ --header 'Authorization: Bearer 34d6a368-cd68-4813-8b06-135b6de36484'

Response:

{ "available": { "FMLY-Gold-Makhana-250G": { "listing_id": "LSTNDFG37HR5GAVM4TWVNFXBC", "product_id": "NDFG37HR5GAVM4TW", "price": { "mrp": 300, "selling_price": 159, "currency": "INR" }, "tax": { "hsn": "08028090", "tax_code": "GST_5" }, "listing_status": "ACTIVE", "shipping_fees": { "local": 0, "zonal": 0, "national": 0, "currency": "INR" }, "fulfillment_profile": "NON_FBF", "packages": [ { "id": "PKGNDFG37HR5GAVM4TWVNFXBC", "name": "FMLY-Gold-Makhana-250G", "dimensions": { "length": 38.0, "breadth": 24.5, "height": 15.0 }, "weight": 0.75, "handling": { "fragile": false } } ], "locations": [ { "id": "LOC646cc805b2954766bce11c10dbe9d34e", "status": "ENABLED", "inventory": 0 }, { "id": "LOC930e37ebe34d48e08adf8af97ed9ba7c", "status": "ENABLED", "inventory": 0 }, { "id": "LOCa0baf894c29f437792a3025ae4903a79", "status": "ENABLED", "inventory": 1 }, { "id": "LOCb80ad9978c7d425cbff278c67c3c7008", "status": "ENABLED", "inventory": 0 }, { "id": "LOCe0211a2e3bc644eaa676c2e8bab34919", "status": "ENABLED", "inventory": 0 }, { "id": "LOCfd8bf10d30e948cd8b0dc0af6226c5de", "status": "ENABLED", "inventory": 0 } ], "archived_status": "NONE" } } }

Step 4: Filter out FlipkartLocationInventory (available.locations.inventory) from the above response for that particular Location received From event i.e ( available.locations.id = EventLocationId)

Step 5: Compare FlipkartLocationInventory and eventLocationInventory

5.1: IF FlipkartLocationInventory == eventLocationInventory use the quantity(eventLocationInventory) and Update Inventory.

5.2: If FlipkartLocationInventory < eventLocationInventory use the lower quantity ( FlipkartLocationInventory) then Update Inventory

5.3: If FlipkartLocationInventory > eventLocationInventory use the lower Quantity ( eventLocationInventory ) then Update Inventory.

Handling Inventory Mismatch Issue On Flipkart 2nd Approach

Step1: we receive Inventory Event from WMS:

{ "account_slug": "warehouse", "externalWmsAccount": "eshopbox", "publishedAt": "2023-04-10 12:42:03", "message_id": "202304101242002410", "inventoryList": [ { "productId": "NDFG37HR5GAVM4TW", "parentId": "Makhana", "sellerSku": "FMLY-Gold-Makhana-250G", "sku": "20CSI3H0X8Z", "variantId": "NDFG37HR5GAVM4TW", "inventory": "187", "changeInStock": -183.0, "locationInventory": 0.0, "locationId": "LOCfd8bf10d30e948cd8b0dc0af6226c5de" } ], "message": "GOOD_INVENTORY_UPDATE", "externalWmsChannelName": "FLIPKART_FARMELY_XBLR_2174", "externalWarehouseID": "Bangalore_FC", "connectionId": 1036.0, "locationId": "LOCfd8bf10d30e948cd8b0dc0af6226c5de", "externalChannelID": "CH2001", "integrationType": "6" }

Step 2: We will call a Real-time API where we will put inventoryList[].sku AS sku and externalWarehouseID as an input parameter:

GET URL

http://localhost:8080/_ah/api/esb/v1/getInventoryCount?sku=20CSI3H0X8Z&externalWarehouseId=Bangalore_FC

Step3: in the Service File of the Given EndPoint: I will fetch the count of items from DataBase satisfying the below condition:

SELECT COUNT(order_items.sku) ,order_items.sku, order_items.warehouse_id FROM order_items LEFT JOIN warehouses ON warehouses.id = order_items.warehouse_id WHERE order_items.sku = '20CSI3H0X8Z' AND warehouses.externalWarehouseID = 'Bangalore_FC' AND order_items.shipment_id='0' AND order_items.status NOT IN ('CANCELLED')

Step4: check the count of current inventory for that SKU and

externalWarehouseId on inventory DB and warehouse_inventory_table (only for the non-virtual kit).

SELECT COUNT(warehouse_inventories.sku), warehouse_inventories.sku, warehouse_inventories.warehouse FROM warehouse_inventories WHERE warehouse_inventories.sku = '20CSI3H0X8Z' AND warehouse_inventories.warehouse = 'Bangalore_FC'

Step5: send the above quantities fetched from two DB as a Response to the above Real-Time API
Response of Real-Time API:

{ CreatedQuanity: " ", currentQuanity: " ", sku: "20CSI3H0X8Z", warehouseId: "Bangalore_FC" }

Step 6: For virtual-kit Item: fetch the components sku’s using the product API.

Step 7: Repeat Step 4 for all components SKUs and Send the minimum count among all component sku’s to Response API in Step 5.

 

 

 

Related content