Return Create Flow

Steps:

Create an ReturnCronJob to prepare Data for active steps of orders and push into queue.

Tables included :- app_steps, app_installation_step_config,app_install_connection,channels,.

extract connection id with connection data(ie_app_automation_steps_config,ie_appinstall_connection)

Query:

SELECT ie_app_automation_steps_config.connectionId,ie_app_automation_steps_config.latestSyncTimeStamp,ie_appinstall_connection.accessToken
FROM ie_app_automation_steps_config
LEFT JOIN ie_appinstall_connection
ON ie_app_automation_steps_config.connectionId=ie_appinstall_connection.id
WHERE ie_app_automation_steps_config.appAutomationStepId='5' AND ie_app_automation_steps_config.isActive='1' AND ie_app_automation_steps_config.latestSyncTimeStamp IS NOT NULL AND ie_appinstall_connection.accessToken IS NOT NULL;

extract unique connection id and map external channnel id against each connection id

tables: external_wms_channels,warehouses)

loop over the Result set of above Query and pass connection Id to a method if the connectionId exist in cache fetch data in the given format

{
	"externalChannelId" : "CLARKS",
	"connectionId": "48",
	"location":
  	{
  		"4253453464575":"Warehouse",
  		"67859":"BDGUR103"
  		
	}
}

else execute query and set in cache and return in same format.
channeldata_(connectionId);

Query:

SELECT channels.externalChannelId ,channels.connectionId,external_wms_channels.locationId,
warehouses.externalWarehouseId FROM channels
LEFT JOIN external_wms_channels
ON channels.id= external_wms_channels.channel_id
LEFT JOIN warehouses
ON warehouses.id = external_wms_channels.warehouse_id
WHERE channels.connectionId =48;

group records according to sales channel and then then map location id , external warehouse id
Associate above results into an object and pass into taskQueue in given format.
{ "externalChannelId" : "CLARKS", "connectionId": "48", "location": { "4253453464575":"Warehouse", "67859":"BDGUR103" }, "accessToken":"wertghjkhgfdsasdfghjkiuytr", "latestSyncTimeStamp":"2020-11-03 17:05:32" }

2. a. Create a Listener API to listen data in taskQueue and prepare request Data for flipkart API

update value of latestSyncTime with currentDate.

. Push detail data of flipkart to pubsub for transformation and call flipkart API

https://api.flipkart.net/sellers/v2/returns?source=customer_return&createdAfter=2020-11-30&locationId=LOC62a30c1d159845e09dfeef303f52cfb9
https://api.flipkart.net/sellers/v2/returns?source=courier_return&createdAfter=2020-11-30&locationId=LOC62a30c1d159845e09dfeef303f52cfb9

If order detail has (hasnext: true) ,push the nextpage Url to call the flipkat API with

previous request body and nextPage Url in params

Push detail data of flipkart to transformation and vise versa

4. a. Create Listener API’s to listen these topics and create data from them if detail

has (hasnext: true) ,push the nextpage Url to call the flipkart API with previous request

body and nextPage Url in params vise versa.

5. call wms API
http://wms.eshopbox.com/api/return; http://wms.eshopbox.com/api/return-status-update

Mapping (customer return):

	EshopBox keys	Flipkart Keys +Wms database

	EshopBox keys	Flipkart Keys +Wms database
1	`customerOrderNumber`	`orders.customerOrderNumber` (db)
2	`externalChannelID`	`channelData`.`externalChannelId`
3	`pickup_type`	`“reverse”`
4	`isCOD`	`orders.isCOD`(db)
5	`return_request_date`	`customerReturn.returnItems.createdDate`
6	`repaymentType`	`“originalPaymentMode”`
7	`optional`	`null`
8	`customerReturnNumber`	`customerReturn.returnItems`.`returnId`
9	`refundAmount`	null
10	`items`.`lineItemSequenceNumber`	`customerReturn.returnItems.orderItemId`
11	`items`.`itemID`	`order_items.itemId`(db)
12	`items.quantity`	1
13	`items.returnReason`	`customerReturn.returnItems.reason`
14	`items.itemImage`	““
15	`items.additionalInfo`	““
16	`pickupAddress`.`customerName`	`orders.shipping_customerName`(db)
17	`pickupAddress`.`addressLine1`	`orders.shipping_addressLine1`(db)
18	`pickupAddress`.`addressLine2`	`orders.shipping_addressLine2`(db)
19	`pickupAddress.city`	`orders.shipping_city(db)`
20	`pickupAddress`.`postalCode`	`orders.shipping_postalCode`(db)
21	`pickupAddress`.`countryCode`	`"IN"`
22	`pickupAddress`.`state`	`orders.shipping_state`(db)
23	`pickupAddress`.`countryName`	`“INDIA”`
24	`pickupAddress`.`contactPhone`	`orders.shipping_contactPhone`(db)
25	`pickupAddress.email`	`orders.shipping_email`(db)

Mapping (courier return):

EshopBox keys	Flipkart Keys

EshopBox keys	Flipkart Keys
`customerReturnNumber`	““
`customerOrderNumber`	`orders.customerOrderNumber` (db)
`type`	`“courier_return”`
`status`	`"RTO"`
`remarks`	`courierReturnItem`.`reason`
`courierName`	`courierReturnItem`.`courierName`
`trackingID`	`courierReturnItem`.`trackingId`
`items`.`itemId`	`order_items.itemId`
`items`.`orderItemId`	`order_items.OrderitemId`

Apps and Automations

Return Create Flow

Related content