Ajio catalog sync
- nilam.nerlekar (Unlicensed)
We will create a cron for catalog sync. We will fetch ajio product (for PUBLISHED status) in batches of pageSize 50. Then we will call eshopbox getProduct api to fetch existing products. If product is already created then we will mark it available. If product is not created then first we will create the product at eshopbox then we will mark the product available.
Step 1. To fetch all the active connections of Ajio from eshopbox_wms_production.channels table using the following Query:
SELECT
DISTINCT connectionId AS connectionIds
FROM
channels
WHERE
integrationType ='16'AND channels.status='0'
Step 2 : Now fetch the connectionConfigData using the following Query for all the active connections using following query :
SELECT
ie_appinstall_connection.accessToken AS accessToken,
ie_appinstall_connection.id AS connectionId,
ie_app_automation_steps.id AS appAutomationStepId,
ie_app_automation_steps.appId AS appId,
ie_app_automation_steps_config.isActive,
ie_appinstall_connection.isActive AS appIsActive,
ie_app_automation_steps_config.otherDetails AS otherDetails,
ie_app_automation_steps_config.latestSyncTimeStamp AS latestSyncTimeStamp,
ie_app.clientId AS appClientId,
ie_app.userName AS appWmsUserName,
ie_app.password AS appWmsPassword,
ie_appinstall_connection.inputFields AS inputFields,
ie_app_credential.clientSecret as clientSecret,
GROUP_CONCAT(ie_app_type_scope.scope) AS scope
FROM
ie_appinstall_connection
LEFT JOIN
ie_app_installation
ON ie_app_installation.appInstallationId = ie_appinstall_connection.appInstallationId
LEFT JOIN
ie_app
ON ie_app.appId = ie_app_installation.appId
LEFT JOIN
ie_app_automation_steps
ON ie_app_automation_steps.appId = ie_app.appId
LEFT JOIN
ie_app_automation_steps_config
ON ie_app_automation_steps_config.connectionId = ie_appinstall_connection.id
AND ie_app_automation_steps_config.appAutomationStepId = ie_app_automation_steps.id
LEFT JOIN
ie_app_credential
ON ie_app_credential.appId = ie_app_installation.appId
LEFT JOIN
ie_app_type_scope
ON ie_app_type_scope.appType = ie_app.appType
WHERE
ie_appinstall_connection.id IN (:connectionIds) AND
ie_app_automation_steps.appAutomationStepId = (:appAutomationStepId) AND
ie_app_automation_steps_config.isActive = '1'
Step 3 : Push the Data Into TaskQueue so that it can fetch the Products for each connection parallelly and push them onto a PubSub topic where Ajio Transformation Service will create those products into WMS
SELECT
accounts.account_slug AS accountSlug,
channels.connectionId AS connectionId,
channels.externalChannelId AS externalChannelId,
external_wms_channels.locationId AS locationId,
warehouses.externalWarehouseId AS 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
LEFT JOIN
accounts
ON channels.account_id = accounts.id
LEFT JOIN
channel_account_mapping
ON channel_account_mapping.external_wms_channel_id = external_wms_channels.id
WHERE
channels.connectionId =:connectionId
AND channel_account_mapping.enrollmentStatus = 'ACTIVE'
Step 4 : Now listen to each connectionConfigData from TaskQueue and Prepare the GET /productsCount API URL to fetch the productCount from AJIO. Then GET /products api to fetch products
Product count api :
http://116.50.64.106:8080/ds/eshopbox/productsCount?publishedStatus=PUBLISHEDHeaders :
Keys | Values |
|---|---|
apiKey | ajioAccessToken |
Response :
{
"count": 0
}
get products api :
http://116.50.64.106:8080/ds/eshopbox/productsHeaders :
Keys | Values |
|---|---|
apiKey | ajioAccessToken |
QueryParams :
Keys | Values |
|---|---|
publishedStatus | PUBLISHED |
pageNumber | 1 |
pageSize | 50 |
Response :
{
"products": [
{
"id": "string",
"brand": "string",
"variants": [
{
"variantId": "string",
"sku": "string",
"size": "string",
"color": "string",
"live": true,
"productDescription": "string"
}
]
}
]
}
Step 5 : Process the products fetched from ajio
Check if product already exists in EshopBox Workspace:
https://eshop.gitbook.io/eshopbox-developers/product/products/get-all-products
Case 1: If the product is present mark it available:
https://eshop.gitbook.io/eshopbox-developers/product/product-availability/mark-product-availability
Case 2: If product is not present:
Check the configuration of product sync for that connection:
If enableProductCreation = 1 then create product:
https://eshop.gitbook.io/eshopbox-developers/product/products/create-a-product