{ "edges": [ { "to": "fd0b451b-f5ef-48d7-9292-033f4ae5359c", "from": "98c25fd5-ca8b-4396-bd51-f1b97c03c1cc", "toPort": "0", "fromPort": "0" }, { "to": "6a235f60-3a14-465b-a2db-5b886fad0b2f", "from": "f9113ab3-eaba-4490-92cf-b7a0d493a372", "toPort": "0", "fromPort": "0" }, { "to": "6fec4e7b-ff3e-42eb-a3e6-d78e9d503795", "from": "970049ae-8c6a-4b21-b96d-b50941f17055", "toPort": "0", "fromPort": "0" }, { "to": "33ccb61b-820f-400b-b155-43ce073b9748", "from": "6fec4e7b-ff3e-42eb-a3e6-d78e9d503795", "toPort": "0", "fromPort": "0" }, { "to": "970049ae-8c6a-4b21-b96d-b50941f17055", "from": "2c0a7dad-a579-40f4-b94d-d6d3b348dc32", "toPort": "0", "fromPort": "0" }, { "to": "b17d66ab-47eb-4d2b-a8a9-81c3608ea176", "from": "6be3a895-046d-439c-b173-a4a640b727b9", "toPort": "0", "fromPort": "0" }, { "to": "98c25fd5-ca8b-4396-bd51-f1b97c03c1cc", "from": "140c559c-0d24-4085-8360-212b307ad6d5", "toPort": "0", "fromPort": "0" }, { "to": "f9113ab3-eaba-4490-92cf-b7a0d493a372", "from": "33ccb61b-820f-400b-b155-43ce073b9748", "toPort": "0", "fromPort": "0" }, { "to": "2c0a7dad-a579-40f4-b94d-d6d3b348dc32", "from": "fd0b451b-f5ef-48d7-9292-033f4ae5359c", "toPort": "0", "fromPort": "0" }, { "to": "6be3a895-046d-439c-b173-a4a640b727b9", "from": "6a235f60-3a14-465b-a2db-5b886fad0b2f", "toPort": "0", "fromPort": "0" } ], "nodes": [ { "id": "98c25fd5-ca8b-4396-bd51-f1b97c03c1cc", "name": "Fetch Zoho CRM Records", "type": "integration", "params": { "options": {}, "service": "zohocrm", "resource": "lead", "operation": "getAll", "returnAll": true, "__originalType": "n8n-nodes-base.zohoCrm" }, "position": [ 3264, 976 ] }, { "id": "fd0b451b-f5ef-48d7-9292-033f4ae5359c", "name": "Split Records for Processing", "type": "code", "params": { "jsCode": "const records = JSON.parse($json.records || '[]');\nreturn records.map(r => ({ json: r }));" }, "position": [ 3584, 976 ] }, { "id": "2c0a7dad-a579-40f4-b94d-d6d3b348dc32", "name": "Validate Email Addresses", "type": "code", "params": { "jsCode": "return items.map(item => {\nconst email = (item.json.email || '').trim().toLowerCase();\n\nconst email_valid =\n/^[^\\s@]+@[^\\s@]+\\.[^\\s@]+$/.test(email) &&\n!email.includes('..');\n\nreturn {\njson:{\n...item.json,\nemail,\nemail_valid\n}\n};\n});" }, "position": [ 3920, 976 ] }, { "id": "970049ae-8c6a-4b21-b96d-b50941f17055", "name": "Normalize Phone Numbers", "type": "code", "params": { "jsCode": "return items.map(item => {\n\nlet phone = (item.json.phone || '')\n.toString()\n.replace(/\\D/g,'');\n\nlet country='unknown';\n\nif(phone.length===10){\nphone='91'+phone;\ncountry='IN';\n}\nelse if(phone.startsWith('1')) country='US';\nelse if(phone.startsWith('44')) country='UK';\nelse if(phone.startsWith('971')) country='UAE';\nelse if(phone.startsWith('49')) country='DE';\nelse if(phone.startsWith('61')) country='AU';\n\nif(phone.length < 10 || phone.length > 15){\nphone='';\n}\n\nreturn {\njson:{\n...item.json,\nphone_standardized: phone,\ncountry\n}\n};\n});" }, "position": [ 4128, 976 ] }, { "id": "6fec4e7b-ff3e-42eb-a3e6-d78e9d503795", "name": "Detect Duplicate Records", "type": "code", "params": { "jsCode": "const seen = {};\n\nreturn items.map(item => {\n\nconst email = item.json.email;\nconst phone = item.json.phone_standardized;\n\nconst key = email + \"|\" + phone;\n\nlet is_duplicate = false;\n\nif(seen[key]){\nis_duplicate = true;\n}else{\nseen[key] = true;\n}\n\nreturn {\njson:{\n...item.json,\nis_duplicate\n}\n};\n\n});" }, "position": [ 4448, 976 ] }, { "id": "33ccb61b-820f-400b-b155-43ce073b9748", "name": "Enrich Missing Company Data", "type": "code", "params": { "jsCode": "return items.map(item => {\n\nlet company = item.json.company;\n\nif(!company || company.trim()===''){\n\nconst email = item.json.email || '';\n\nif(email.includes('@')){\ncompany = email.split('@')[1].split('.')[0];\ncompany =\ncompany.charAt(0).toUpperCase() +\ncompany.slice(1);\n}else{\ncompany='Unknown Company';\n}\n\n}\n\nreturn {\njson:{\n...item.json,\ncompany_enriched: company\n}\n};\n\n});" }, "position": [ 4624, 976 ] }, { "id": "f9113ab3-eaba-4490-92cf-b7a0d493a372", "name": "Generate Quality Flags", "type": "code", "params": { "jsCode": "return items.map(item => {\n\nconst flags=[];\n\nif(!item.json.email_valid)\nflags.push('Invalid Email');\n\nif(!item.json.phone_standardized)\nflags.push('Invalid Phone');\n\nif(item.json.is_duplicate)\nflags.push('Duplicate');\n\nif(!item.json.company || item.json.company==='')\nflags.push('Missing Company');\n\nreturn {\njson:{\n...item.json,\ndata_quality_flags: flags,\nquality_score: 100 - (flags.length * 25)\n}\n};\n\n});" }, "position": [ 4944, 976 ] }, { "id": "6a235f60-3a14-465b-a2db-5b886fad0b2f", "name": "Generate Quality Summary Report", "type": "code", "params": { "jsCode": "let total = items.length;\n\nlet summary = {\n total_records: total,\n valid_records: 0,\n invalid_email: 0,\n invalid_phone: 0,\n duplicates: 0,\n missing_company: 0\n};\n\nlet report = [];\n\nfor (const item of items) {\n const d = item.json;\n\n let isValid = true;\n\n // Email validation\n if (!d.email_valid) {\n summary.invalid_email++;\n isValid = false;\n }\n\n // Phone validation\n if (!d.phone_standardized) {\n summary.invalid_phone++;\n isValid = false;\n }\n\n // Duplicate check\n if (d.is_duplicate) {\n summary.duplicates++;\n isValid = false;\n }\n\n // Company check\n if (!d.company || d.company === '' || d.company === null) {\n summary.missing_company++;\n isValid = false;\n }\n\n if (isValid) {\n summary.valid_records++;\n }\n\n report.push({\n id: d.id,\n name: d.name,\n email: d.email,\n country: d.country || 'unknown',\n status: isValid ? 'VALID' : 'INVALID',\n flags: d.data_quality_flags || []\n });\n}\n\nreturn [\n {\n json: {\n summary,\n report\n }\n }\n];" }, "position": [ 5296, 976 ] }, { "id": "140c559c-0d24-4085-8360-212b307ad6d5", "name": "Automated Schedule Trigger", "type": "trigger", "params": { "kind": "n8n-nodes-base.scheduleTrigger", "rule": { "interval": [ { "field": "hours", "triggerAtMinute": 5 } ] } }, "position": [ 3040, 976 ] }, { "id": "6be3a895-046d-439c-b173-a4a640b727b9", "name": "Format CRM Report to HTML", "type": "code", "params": { "jsCode": "const { summary, report } = items[0].json;\n\nlet rows = report.map(r => {\n const statusColor = r.status === 'VALID' ? '#16a34a' : '#dc2626';\n\n return `\n \n ${r.id || ''}\n ${r.name || ''}\n ${r.email || ''}\n ${r.country || ''}\n \n ${r.status}\n \n \n ${(r.flags || []).join(', ') || '-'}\n \n \n `;\n}).join('');\n\nconst html = `\n

\n \n

📊 CRM Data Quality Report

\n\n

Summary

Total Records: ${summary.total_records}

Valid Records: ${summary.valid_records}

Invalid Emails: ${summary.invalid_email}

Invalid Phones: ${summary.invalid_phone}

Duplicates: ${summary.duplicates}

Missing Company: ${summary.missing_company}

\n\n

Details

\n\n \n \n \n \n \n \n \n \n \n \n \n \n ${rows}\n \n

ID	Name	Email	Country	Status	Flags

\n\n

\n Generated automatically by n8n workflow\n

\n\n

\n`;\n\nreturn [{ json: { html } }];" }, "position": [ 5712, 976 ] }, { "id": "b17d66ab-47eb-4d2b-a8a9-81c3608ea176", "name": "Send Data Quality Report Email", "type": "integration", "params": { "sendTo": "user@example.com", "message": "={{$json.html}}", "options": { "appendAttribution": false }, "service": "gmail", "subject": "Zoho CRM Data Quality Report", "operation": "read" }, "position": [ 6128, 976 ] } ] }

Audit Zoho CRM lead data quality and email HTML reports with Gmail