{ "edges": [ { "to": "a3fe994f-e782-4c55-8cdb-b8a256acdf37", "from": "c20eaa02-c1ce-4999-9aef-8c6a3fd959ee", "toPort": "0", "fromPort": "0" }, { "to": "c42fabc3-2180-49e2-8ea5-d24500dbdea0", "from": "55ffa452-f2c5-43c2-996d-0f0fb7c9bed4", "toPort": "0", "fromPort": "0" }, { "to": "c92398cf-70f4-4d93-a273-693bc3c1bbd5", "from": "55ffa452-f2c5-43c2-996d-0f0fb7c9bed4", "toPort": "0", "fromPort": "0" }, { "to": "c20eaa02-c1ce-4999-9aef-8c6a3fd959ee", "from": "f3651bdf-d90e-42f5-ba94-3bf4e4c55511", "toPort": "0", "fromPort": "0" }, { "to": "f3651bdf-d90e-42f5-ba94-3bf4e4c55511", "from": "7d9139ff-f51e-4017-8831-5f8c6c273f51", "toPort": "0", "fromPort": "0" }, { "to": "55ffa452-f2c5-43c2-996d-0f0fb7c9bed4", "from": "bc8d384a-c5d8-4864-a157-cb21f3643d84", "toPort": "0", "fromPort": "0" }, { "to": "2cf2065b-f235-4582-b439-4902a0097e10", "from": "a3fe994f-e782-4c55-8cdb-b8a256acdf37", "toPort": "0", "fromPort": "0" }, { "to": "bc8d384a-c5d8-4864-a157-cb21f3643d84", "from": "2cf2065b-f235-4582-b439-4902a0097e10", "toPort": "0", "fromPort": "0" } ], "nodes": [ { "id": "7d9139ff-f51e-4017-8831-5f8c6c273f51", "name": "Daily Inventory Check", "type": "trigger", "params": { "kind": "n8n-nodes-base.scheduleTrigger", "rule": { "interval": [ { "field": "cronExpression", "expression": "50 8 * * *" } ] } }, "position": [ -1860, 500 ] }, { "id": "bc8d384a-c5d8-4864-a157-cb21f3643d84", "name": "Check if Alerts Needed", "type": "if", "params": { "options": { "looseTypeValidation": true }, "conditions": { "options": { "version": 1, "leftValue": "", "caseSensitive": true, "typeValidation": "loose" }, "combinator": "and", "conditions": [ { "id": "condition-001", "operator": { "type": "number", "operation": "gt" }, "leftValue": "={{ $node[\"Process Stock Data and Identify Low Stock\"].json[\"lowStockAlerts\"].length > 0 }}", "rightValue": 0 } ] } }, "position": [ -780, 500 ] }, { "id": "c42fabc3-2180-49e2-8ea5-d24500dbdea0", "name": "Send Inventory Alert", "type": "integration", "params": { "text": "={{ $json.slackMessage }}", "select": "channel", "service": "slack", "channelId": { "__rl": true, "mode": "name", "value": "#magento-notifications" }, "operation": "read", "otherOptions": { "includeLinkToWorkflow": false } }, "position": [ -20, 340 ] }, { "id": "f3651bdf-d90e-42f5-ba94-3bf4e4c55511", "name": "Get All Product Skus", "type": "http", "params": { "url": "=https://magekwik.com/rest/V1/products?searchCriteria[pageSize]=0&searchCriteria[filterGroups][0][filters][0][field]=type_id&searchCriteria[filterGroups][0][filters][0][conditionType]=nin&searchCriteria[filterGroups][0][filters][0][value]=configurable,virtual,downloadable&fields=items[sku,extension_attributes[stock_item[manage_stock]]]", "options": {}, "authentication": "genericCredentialType", "genericAuthType": "httpBearerAuth" }, "position": [ -1420, 320 ] }, { "id": "c20eaa02-c1ce-4999-9aef-8c6a3fd959ee", "name": "Extract SKUs", "type": "code", "params": { "jsCode": "// Loop over input items and add a new field called 'myNewField' to the JSON of each one\nconst skus = [];\nfor (const item of $input.first().json.items) {\n skus.push(item.sku);\n}\nreturn [{ json: { skus: skus } }];" }, "position": [ -1180, 320 ] }, { "id": "a3fe994f-e782-4c55-8cdb-b8a256acdf37", "name": "Fetch MSI Stock Status", "type": "http", "params": { "url": "=https://magekwik.com/rest/V1/inventory/source-items?searchCriteria[filterGroups][0][filters][0][field]=sku&searchCriteria[filterGroups][0][filters][0][conditionType]=in&searchCriteria[filterGroups][0][filters][0][value]={{ encodeURIComponent($node[\"Extract SKUs\"].json[\"skus\"].join(',')) }}", "options": {}, "authentication": "genericCredentialType", "genericAuthType": "httpBearerAuth" }, "position": [ -1420, 680 ] }, { "id": "2cf2065b-f235-4582-b439-4902a0097e10", "name": "Process Stock Data and Identify Low Stock", "type": "code", "params": { "jsCode": "const lowStockItems = [];\nconst lowStockThreshold = 10; // Define your low stock threshold here\nconst minSourceQuantity = 5; // Define minimum quantity per source if applicable\n\n// Assuming the MSI stock data is in $json.items\nfor (const item of $input.first().json.items) {\n const sku = item.sku;\n const sourceCode = item.source_code;\n const quantity = item.quantity;\n const status = item.status; // 1 for In Stock, 0 for Out of Stock\n\n // Check if the item is in stock and below the overall low stock threshold\n // Or if a specific source is very low\n if (status === 1 && (quantity <= lowStockThreshold || quantity <= minSourceQuantity)) {\n lowStockItems.push({\n sku: sku,\n source: sourceCode,\n quantity: quantity,\n status: status === 1 ? 'In Stock' : 'Out of Stock'\n });\n }\n}\n\n// You can further process lowStockItems to group by SKU or format as needed\n// For now, we'll return a list of individual low stock entries.\nreturn [{ json: { lowStockAlerts: lowStockItems } }];" }, "position": [ -1180, 680 ] }, { "id": "c92398cf-70f4-4d93-a273-693bc3c1bbd5", "name": "Send a message", "type": "integration", "params": { "sendTo": "user@example.com", "message": "={{ $json.gmailHtml }}", "options": { "appendAttribution": false }, "service": "gmail", "subject": "={{ $json.subjectLine }}", "operation": "read" }, "position": [ -20, 620 ] }, { "id": "55ffa452-f2c5-43c2-996d-0f0fb7c9bed4", "name": "Format Message", "type": "code", "params": { "jsCode": "const lowStockAlerts = Array.isArray($input.first().json.lowStockAlerts) ? $input.first().json.lowStockAlerts : [];\n\nlet plainText = \"*📦 Low Stock Alert for Magento 2 Multi-Store (MSI)*\\n\\n\";\nlet htmlText = \"📦 Low Stock Alert for Magento 2 Multi-Store (MSI)

\";\n\nif (lowStockAlerts.length === 0) {\n plainText += \"_No low stock items found at this time._\";\n htmlText += \"No low stock items found at this time.\";\n} else {\n plainText += \"*The following products have low stock:*\\n\\n\";\n htmlText += \"The following products have low stock:

\";\n\n // Text version\n plainText += \"```\\nSKU Source Quantity Status\\n\";\n plainText += \"-------- --------- -------- --------\\n\";\n\n // HTML table version\n htmlText += `\n \n \n \n \n \n \n \n \n \n `;\n\n lowStockAlerts.forEach(item => {\n const sku = item.sku || 'N/A';\n const source = item.source || 'N/A';\n const quantity = item.quantity || 0;\n const status = item.status || 'Unknown';\n\n // Plain text table row\n plainText += `${sku.padEnd(10)}${source.padEnd(11)}${String(quantity).padEnd(9)}${status}\\n`;\n\n // HTML table row\n htmlText += `\n \n \n \n \n `;\n });\n\n plainText += \"```\\n\\n🔍 Please check your Magento 2 inventory.\";\n htmlText += \"

SKU	Source	Quantity	Status
${sku}	${source}	${quantity}	${status}

🔍 Please check your Magento 2 inventory.\";\n}\n\n// Output both formats\nreturn [{\n json: {\n slackMessage: plainText,\n gmailHtml: htmlText,\n subjectLine: `🔔 Magento 2 Low Stock Alert – ${new Date().toLocaleDateString('en-US', { year: 'numeric', month: 'long', day: 'numeric' })}`\n }\n}];\n" }, "position": [ -480, 500 ] } ] }

Magento 2 low stock alert via Slack & Gmail (MSI compatible)