n8n for HR Tech Companies: 5 Automations That Scale Product Ops Without Headcount (Free Workflow JSON)

{
  "nodes": [
    {"name": "New Customer Webhook", "type": "n8n-nodes-base.webhook", "parameters": {"path": "new-customer", "responseMode": "lastNode"}},
    {"name": "Extract Customer Data", "type": "n8n-nodes-base.code", "parameters": {"jsCode": "const d = $json.body || $json;\nreturn [{json: {email: d.email, name: d.name || d.first_name || 'there', company: d.company || '', plan: d.plan || 'starter', customer_id: d.customer_id || d.id, onboarded_at: new Date().toISOString()}}];"}},
    {"name": "Log to Sheets", "type": "n8n-nodes-base.googleSheets", "parameters": {"operation": "append", "sheetId": "YOUR_SHEET_ID", "range": "Onboarding!A:F"}},
    {"name": "Day 1 Welcome Email", "type": "n8n-nodes-base.gmail", "parameters": {"operation": "send", "to": "={{$json.email}}", "subject": "Welcome to [Platform], {{$json.name}} — start here", "message": "Hi {{$json.name}},\n\nYour account is live. Here's how to complete setup in 15 minutes:\n\n1. Connect your HRIS data source\n2. Import your employee roster\n3. Configure your first workflow\n\nFull quick-start guide: [DOCS_LINK]\n\nQuestions? Reply to this email — I read every one.\n\n— The [Platform] Team"}},
    {"name": "Wait 3 Days", "type": "n8n-nodes-base.wait", "parameters": {"amount": 3, "unit": "days"}},
    {"name": "Day 4 Integration Email", "type": "n8n-nodes-base.gmail", "parameters": {"operation": "send", "to": "={{$json.email}}", "subject": "{{$json.name}}, connect your first integration (5 min)", "message": "Hi {{$json.name}},\n\nMost teams unlock 80% of the value by connecting one integration first. The most popular for {{$json.plan}} accounts:\n\n- Slack (instant alerts for payroll events)\n- Google Sheets (export any report)\n- Your ATS of choice\n\nConnections guide: [INTEGRATION_DOCS]\n\nAny blockers? I'm here.\n\n— [Platform] Team"}},
    {"name": "Wait 4 Days", "type": "n8n-nodes-base.wait", "parameters": {"amount": 4, "unit": "days"}},
    {"name": "Day 8 Power User Tips", "type": "n8n-nodes-base.gmail", "parameters": {"operation": "send", "to": "={{$json.email}}", "subject": "3 things power users do differently on [Platform]", "message": "Hi {{$json.name}},\n\nTeams that get the most out of [Platform] do three things:\n\n1. Schedule a weekly automated report (takes 10 min to set up)\n2. Set threshold alerts for payroll anomalies\n3. Use the API to push data into their BI tool\n\nCase study: [CUSTOMER] cut payroll processing time by 60% — [LINK]\n\n— [Platform] Team"}},
    {"name": "Wait 6 Days", "type": "n8n-nodes-base.wait", "parameters": {"amount": 6, "unit": "days"}},
    {"name": "Day 14 Book a Call", "type": "n8n-nodes-base.gmail", "parameters": {"operation": "send", "to": "={{$json.email}}", "subject": "Quick check-in, {{$json.name}} — how's setup going?", "message": "Hi {{$json.name}},\n\nYou've been on [Platform] for two weeks. I want to make sure you're getting real value.\n\nIf you haven't connected your first integration yet, I can walk you through it in 15 minutes:\n[CALENDLY_LINK]\n\nIf things are going well — I'd love to hear what's working.\n\n— [Platform] CS Team"}}
  ]
}

{
  "nodes": [
    {"name": "Schedule 30min", "type": "n8n-nodes-base.scheduleTrigger", "parameters": {"rule": {"interval": [{"field": "minutes", "minutesInterval": 30}]}}},
    {"name": "Get Active Integrations", "type": "n8n-nodes-base.postgres", "parameters": {"operation": "executeQuery", "query": "SELECT integration_id, customer_id, customer_email, integration_type, health_endpoint, last_synced_at FROM integrations WHERE status = 'active' ORDER BY last_synced_at ASC LIMIT 100"}},
    {"name": "Ping Health Endpoints", "type": "n8n-nodes-base.httpRequest", "parameters": {"url": "={{$json.health_endpoint}}", "method": "GET", "timeout": 10000, "continueOnFail": true}},
    {"name": "Filter Failures", "type": "n8n-nodes-base.code", "parameters": {"jsCode": "const items = $input.all();\nreturn items.filter(item => {\n  const status = item.json.statusCode || item.json.$response?.statusCode;\n  return !status || status >= 400;\n}).map(item => ({json: {...item.json, failure_detected_at: new Date().toISOString()}}));"}},
    {"name": "Slack Alert", "type": "n8n-nodes-base.slack", "parameters": {"channel": "#integration-ops", "text": ":red_circle: Integration failure: {{$json.integration_type}} for customer {{$json.customer_id}} | Last synced: {{$json.last_synced_at}} | Health endpoint: {{$json.health_endpoint}}"}},
    {"name": "Log to Incident Tracker", "type": "n8n-nodes-base.googleSheets", "parameters": {"operation": "append", "sheetId": "YOUR_SHEET_ID", "range": "Integration Failures!A:F"}},
    {"name": "Wait 2 Hours", "type": "n8n-nodes-base.wait", "parameters": {"amount": 2, "unit": "hours"}},
    {"name": "Customer Heads-Up Email", "type": "n8n-nodes-base.gmail", "parameters": {"operation": "send", "to": "={{$json.customer_email}}", "subject": "Action needed: your {{$json.integration_type}} integration needs attention", "message": "Hi,\n\nWe detected an issue with your {{$json.integration_type}} integration. Our team is investigating, but you may want to check your API credentials or token expiry.\n\nStatus page: [STATUS_PAGE_LINK]\nSupport: [SUPPORT_LINK]\n\n— [Platform] Ops Team"}}
  ]
}

{
  "nodes": [
    {"name": "Payroll Sync Webhook", "type": "n8n-nodes-base.webhook", "parameters": {"path": "payroll-sync", "responseMode": "lastNode"}},
    {"name": "Run Anomaly Checks", "type": "n8n-nodes-base.code", "parameters": {"jsCode": "const records = $json.body.records || [];\nconst anomalies = [];\nconst seen_ids = new Set();\nfor (const r of records) {\n  if (r.status === 'active' && (!r.salary || r.salary === 0)) {\n    anomalies.push({...r, anomaly_type: 'CRITICAL', reason: 'Active employee with zero salary'});\n  }\n  if (seen_ids.has(r.employee_id)) {\n    anomalies.push({...r, anomaly_type: 'CRITICAL', reason: 'Duplicate employee_id in batch'});\n  }\n  seen_ids.add(r.employee_id);\n  if (r.previous_salary && Math.abs((r.salary - r.previous_salary) / r.previous_salary) > 0.20) {\n    anomalies.push({...r, anomaly_type: 'WARNING', reason: `Salary delta ${Math.round(((r.salary - r.previous_salary)/r.previous_salary)*100)}% MoM`});\n  }\n}\nif (anomalies.length === 0) return [{json: {status: 'clean', count: records.length}}];\nreturn anomalies.map(a => ({json: a}));"}},
    {"name": "Route by Severity", "type": "n8n-nodes-base.if", "parameters": {"conditions": {"string": [{"value1": "={{$json.anomaly_type}}", "operation": "equal", "value2": "CRITICAL"}]}}},
    {"name": "Slack Critical Alert", "type": "n8n-nodes-base.slack", "parameters": {"channel": "#payroll-ops", "text": ":fire: CRITICAL payroll anomaly: {{$json.reason}} | Employee: {{$json.employee_id}} | Salary: ${{$json.salary}} | Batch: {{$json.batch_id}}"}},
    {"name": "Log All Anomalies", "type": "n8n-nodes-base.googleSheets", "parameters": {"operation": "append", "sheetId": "YOUR_SHEET_ID", "range": "Payroll Anomalies!A:H"}}
  ]
}

{
  "nodes": [
    {"name": "Daily 8AM Schedule", "type": "n8n-nodes-base.scheduleTrigger", "parameters": {"rule": {"interval": [{"field": "cronExpression", "expression": "0 8 * * 1-5"}]}}},
    {"name": "Get All Accounts", "type": "n8n-nodes-base.postgres", "parameters": {"operation": "executeQuery", "query": "SELECT account_id, company, csm_email, plan, mrr, logins_last_30d, api_calls_last_30d, open_tickets, days_since_last_feature_use FROM account_health_view WHERE status = 'active'"}},
    {"name": "Score Accounts", "type": "n8n-nodes-base.code", "parameters": {"jsCode": "return $input.all().map(item => {\n  const d = item.json;\n  let score = 0;\n  if (d.logins_last_30d >= 20) score += 30;\n  else if (d.logins_last_30d >= 10) score += 15;\n  if (d.api_calls_last_30d >= 1000) score += 30;\n  else if (d.api_calls_last_30d >= 100) score += 15;\n  if (d.open_tickets === 0) score += 20;\n  else if (d.open_tickets <= 2) score += 10;\n  if (d.days_since_last_feature_use <= 7) score += 20;\n  else if (d.days_since_last_feature_use <= 14) score += 10;\n  const health = score >= 70 ? 'GREEN' : score >= 40 ? 'AMBER' : 'RED';\n  return {json: {...d, health_score: score, health: health}};\n});"}},
    {"name": "Filter At-Risk", "type": "n8n-nodes-base.code", "parameters": {"jsCode": "return $input.all().filter(i => i.json.health === 'RED' || i.json.health === 'AMBER');"}},
    {"name": "Route by Health", "type": "n8n-nodes-base.if", "parameters": {"conditions": {"string": [{"value1": "={{$json.health}}", "operation": "equal", "value2": "RED"}]}}},
    {"name": "Slack Urgent", "type": "n8n-nodes-base.slack", "parameters": {"channel": "#cs-urgent", "text": ":rotating_light: RED health: {{$json.company}} | Score: {{$json.health_score}}/100 | MRR: ${{$json.mrr}} | Logins: {{$json.logins_last_30d}} | CSM: {{$json.csm_email}}"}},
    {"name": "Churn Risk Email", "type": "n8n-nodes-base.gmail", "parameters": {"operation": "send", "from": "={{$json.csm_email}}", "to": "={{$json.primary_contact_email}}", "subject": "Quick check-in from [Platform]", "message": "Hi,\n\nI noticed your team hasn't logged in recently — I want to make sure [Platform] is still working well for you.\n\nAre there any blockers I can help with? I'm available for a 15-minute call: [CALENDLY_LINK]\n\nBest,\n[CSM_NAME]"}},
    {"name": "Slack Watch-List", "type": "n8n-nodes-base.slack", "parameters": {"channel": "#cs-watch-list", "text": ":yellow_circle: AMBER health: {{$json.company}} | Score: {{$json.health_score}}/100 | MRR: ${{$json.mrr}} | Days since feature use: {{$json.days_since_last_feature_use}}"}}
  ]
}

{
  "nodes": [
    {"name": "Monday 8AM", "type": "n8n-nodes-base.scheduleTrigger", "parameters": {"rule": {"interval": [{"field": "cronExpression", "expression": "0 8 * * 1"}]}}},
    {"name": "Pull Platform Metrics", "type": "n8n-nodes-base.postgres", "parameters": {"operation": "executeQuery", "query": "SELECT SUM(mrr) as total_mrr, COUNT(*) FILTER (WHERE status='active') as active_accounts, COUNT(*) FILTER (WHERE status='trial') as trial_accounts, COUNT(*) FILTER (WHERE created_at >= NOW() - INTERVAL '7 days' AND status='active') as new_this_week, AVG(health_score) as avg_health_score FROM accounts"}},
    {"name": "Pull Integration Metrics", "type": "n8n-nodes-base.postgres", "parameters": {"operation": "executeQuery", "query": "SELECT COUNT(*) as total_integrations, COUNT(*) FILTER (WHERE status='active') as healthy, COUNT(*) FILTER (WHERE status='failed') as failed, ROUND(COUNT(*) FILTER (WHERE status='active')::numeric / NULLIF(COUNT(*),0) * 100, 1) as health_pct FROM integrations"}},
    {"name": "Build HTML Report", "type": "n8n-nodes-base.code", "parameters": {"jsCode": "const m = $('Pull Platform Metrics').first().json;\nconst i = $('Pull Integration Metrics').first().json;\nconst html = `<h2>Weekly Platform Briefing</h2><table border=1 cellpadding=6 style='border-collapse:collapse'><tr><th>Metric</th><th>Value</th></tr><tr><td>Total MRR</td><td>$${Number(m.total_mrr||0).toLocaleString()}</td></tr><tr><td>Active Accounts</td><td>${m.active_accounts}</td></tr><tr><td>Trial Accounts</td><td>${m.trial_accounts}</td></tr><tr><td>New This Week</td><td>${m.new_this_week}</td></tr><tr><td>Avg Health Score</td><td>${Math.round(m.avg_health_score||0)}/100</td></tr><tr><td>Integration Health</td><td>${i.health_pct}% (${i.failed} failed)</td></tr></table>`;\nreturn [{json: {html, total_mrr: m.total_mrr, new_this_week: m.new_this_week, health_pct: i.health_pct}}];"}},
    {"name": "Email Leadership", "type": "n8n-nodes-base.gmail", "parameters": {"operation": "send", "to": "ceo@yourcompany.com", "bcc": "cto@yourcompany.com,cso@yourcompany.com", "subject": "Weekly Platform Briefing — {{new Date().toLocaleDateString('en-US', {month:'short', day:'numeric'})}}", "message": "={{$json.html}}", "options": {"appendAttribution": false}}},
    {"name": "Slack One-Liner", "type": "n8n-nodes-base.slack", "parameters": {"channel": "#management", "text": "Weekly platform briefing sent. MRR: ${{$json.total_mrr}} | New accounts: {{$json.new_this_week}} | Integration health: {{$json.health_pct}}%"}}
  ]
}