DEV Community

Alex Kane
Alex Kane

Posted on

n8n for LogisticsTech SaaS: 5 Automations That Scale Freight Ops and Keep Shipment Data Compliant (Free Workflow JSON)

#n8n #automation #devops #programming

If you're building logistics SaaS — freight management, WMS, last-mile delivery, 3PL software, or supply chain visibility — your customers trust you with data that regulators treat as sensitive.

ELD (Electronic Logging Device) data contains driver hours of service under 49 CFR §395. DOT drug test records under 49 CFR Part 40 have strict access controls — only the Medical Review Officer and Designated Employer Representative can view them. C-TPAT partner vetting data requires a documented audit trail for CBP. EU shipper/consignee addresses are personal data under GDPR Article 28.

If your platform routes any of this through Zapier, every task log is a potential compliance exposure. At 50 million tracking events per month, Zapier costs $50,000+/mo. A $500 VPS running self-hosted n8n handles the same load — with data staying in your infrastructure.

Here are 5 production-ready n8n workflows for LogisticsTech SaaS vendors.

Workflow 1: New Shipper/3PL Client Onboarding Drip

When a new logistics client signs up, they need different onboarding depending on whether they're an enterprise 3PL with 500+ trailers or an SMB shipper. This workflow triggers on a new row in your CRM sheet, classifies the client by tier (ENTERPRISE_3PL / MID_CARRIER / SMB_LOGISTICS / STARTER), and sends tiered day-0 email + CSM Slack notification.

The compliance hook: every onboarding event appends to a SOC2 CC7.1 audit sheet — evidence for enterprise 3PL customers who request your SOC2 report. FMCSA ELD data-scope clients get flagged so your DPA process starts before any driver data flows.

{
  "name": "LogisticsTech Client Onboarding Drip",
  "nodes": [
    {
      "id": "1",
      "name": "New Client Row",
      "type": "n8n-nodes-base.googleSheetsTrigger",
      "typeVersion": 4,
      "position": [
        250,
        300
      ],
      "parameters": {
        "sheetId": "YOUR_SHEET_ID",
        "event": "rowAdded"
      }
    },
    {
      "id": "2",
      "name": "Classify Client Tier",
      "type": "n8n-nodes-base.code",
      "typeVersion": 2,
      "position": [
        470,
        300
      ],
      "parameters": {
        "jsCode": "const r=items[0].json;const trailers=parseInt(r.trailer_count||0);const freight=parseFloat(r.annual_freight_usd||0);let tier,csm,sla;if(trailers>=500||freight>=10000000){tier='ENTERPRISE_3PL';csm='#csm-enterprise';sla=4;}else if(trailers>=100||freight>=2000000){tier='MID_CARRIER';csm='#csm-mid-market';sla=8;}else if(freight>=200000){tier='SMB_LOGISTICS';csm='#csm-smb';sla=24;}else{tier='STARTER';csm='#csm-starter';sla=48;}const log={event:'CLIENT_ONBOARDED',client_id:r.client_id,tier,sla,soc2:'CC7.1',ts:new Date().toISOString()};return[{json:{...r,tier,csm,sla,log}}];"
      }
    },
    {
      "id": "3",
      "name": "Day 0 Email",
      "type": "n8n-nodes-base.gmail",
      "typeVersion": 2,
      "position": [
        690,
        200
      ],
      "parameters": {
        "toEmail": "={{$json.contact_email}}",
        "subject": "Welcome to [Platform]",
        "message": "Hi {{$json.company_name}},\n\nYour account is live. Your CSM will reach out within {{$json.sla}} hours.\n\nBest,\nThe [Platform] Team"
      }
    },
    {
      "id": "4",
      "name": "Notify CSM",
      "type": "n8n-nodes-base.slack",
      "typeVersion": 2,
      "position": [
        690,
        400
      ],
      "parameters": {
        "channel": "={{$json.csm}}",
        "text": "New {{$json.tier}} client: *{{$json.company_name}}* | Freight: ${{$json.annual_freight_usd}} | SLA: {{$json.sla}}h"
      }
    },
    {
      "id": "5",
      "name": "SOC2 Audit Log",
      "type": "n8n-nodes-base.googleSheets",
      "typeVersion": 4,
      "position": [
        910,
        300
      ],
      "parameters": {
        "operation": "append",
        "sheetId": "AUDIT_SHEET_ID",
        "columns": {
          "mappingMode": "defineBelow",
          "value": {
            "A": "={{$json.client_id}}",
            "B": "={{$json.tier}}",
            "C": "={{new Date().toISOString()}}",
            "D": "CLIENT_ONBOARDED",
            "E": "SOC2_CC7.1"
          }
        }
      }
    }
  ],
  "connections": {
    "New Client Row": {
      "main": [
        [
          {
            "node": "Classify Client Tier",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Classify Client Tier": {
      "main": [
        [
          {
            "node": "Day 0 Email",
            "type": "main",
            "index": 0
          },
          {
            "node": "Notify CSM",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Day 0 Email": {
      "main": [
        [
          {
            "node": "SOC2 Audit Log",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Notify CSM": {
      "main": [
        [
          {
            "node": "SOC2 Audit Log",
            "type": "main",
            "index": 0
          }
        ]
      ]
    }
  }
}
Enter fullscreen mode Exit fullscreen mode

Workflow 2: Freight API & Carrier Health Monitor

Your platform depends on carrier APIs — FedEx, UPS, regional LTL carriers, customs brokers. When one goes down, shipments miss cutoffs. This workflow pings every carrier endpoint every 3 minutes. When a carrier is DOWN or STALE_DATA, you get one Slack alert — not 480 per day.

$getWorkflowStaticData stores last-alert timestamps per endpoint (30-min cooldown). Incidents log to Postgres with ON CONFLICT DO NOTHING for a clean on-call timeline.

{
  "name": "Freight API & Carrier Health Monitor",
  "nodes": [
    {
      "id": "1",
      "name": "Every 3 Minutes",
      "type": "n8n-nodes-base.scheduleTrigger",
      "typeVersion": 1,
      "position": [
        250,
        300
      ],
      "parameters": {
        "rule": {
          "interval": [
            {
              "field": "minutes",
              "minutesInterval": 3
            }
          ]
        }
      }
    },
    {
      "id": "2",
      "name": "Fetch Endpoints",
      "type": "n8n-nodes-base.postgres",
      "typeVersion": 2,
      "position": [
        470,
        300
      ],
      "parameters": {
        "operation": "executeQuery",
        "query": "SELECT id, carrier_name, endpoint_url, timeout_ms FROM carrier_endpoints WHERE active=true"
      }
    },
    {
      "id": "3",
      "name": "Split",
      "type": "n8n-nodes-base.splitInBatches",
      "typeVersion": 3,
      "position": [
        690,
        300
      ],
      "parameters": {
        "batchSize": 1
      }
    },
    {
      "id": "4",
      "name": "Ping Carrier",
      "type": "n8n-nodes-base.httpRequest",
      "typeVersion": 4,
      "position": [
        910,
        300
      ],
      "parameters": {
        "method": "GET",
        "url": "={{$json.endpoint_url}}",
        "timeout": 5000,
        "continueOnFail": true
      }
    },
    {
      "id": "5",
      "name": "Classify & Dedup",
      "type": "n8n-nodes-base.code",
      "typeVersion": 2,
      "position": [
        1130,
        300
      ],
      "parameters": {
        "jsCode": "const r=items[0].json;const state=JSON.parse($getWorkflowStaticData('global').s||'{}');const now=Date.now();const k=r.id;const cool=30*60*1000;let status='OK';if(r.error||r.statusCode>=500)status='DOWN';else if(!r.lastDataAt||(now-new Date(r.lastDataAt).getTime())>900000)status='STALE_DATA';else if(r.statusCode>=400)status='DEGRADED';const alert=status!=='OK'&&(now-(state[k]||0))>cool;if(alert){state[k]=now;$setWorkflowStaticData('global',{s:JSON.stringify(state)});}return[{json:{...r,status,should_alert:alert}}];"
      }
    },
    {
      "id": "6",
      "name": "Filter Alerts",
      "type": "n8n-nodes-base.filter",
      "typeVersion": 2,
      "position": [
        1350,
        300
      ],
      "parameters": {
        "conditions": {
          "conditions": [
            {
              "leftValue": "={{$json.should_alert}}",
              "rightValue": true,
              "operator": {
                "type": "boolean",
                "operation": "equals"
              }
            }
          ]
        }
      }
    },
    {
      "id": "7",
      "name": "Slack Alert",
      "type": "n8n-nodes-base.slack",
      "typeVersion": 2,
      "position": [
        1570,
        200
      ],
      "parameters": {
        "channel": "#platform-ops",
        "text": "Carrier {{$json.status}}: *{{$json.carrier_name}}* | {{$json.endpoint_url}}"
      }
    },
    {
      "id": "8",
      "name": "Log Incident",
      "type": "n8n-nodes-base.postgres",
      "typeVersion": 2,
      "position": [
        1570,
        400
      ],
      "parameters": {
        "operation": "executeQuery",
        "query": "INSERT INTO carrier_incidents(carrier_id,status,detected_at) VALUES($1,$2,NOW()) ON CONFLICT DO NOTHING",
        "queryParams": "={{[$json.id,$json.status]}}"
      }
    }
  ],
  "connections": {
    "Every 3 Minutes": {
      "main": [
        [
          {
            "node": "Fetch Endpoints",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Fetch Endpoints": {
      "main": [
        [
          {
            "node": "Split",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Split": {
      "main": [
        [
          {
            "node": "Ping Carrier",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Ping Carrier": {
      "main": [
        [
          {
            "node": "Classify & Dedup",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Classify & Dedup": {
      "main": [
        [
          {
            "node": "Filter Alerts",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Filter Alerts": {
      "main": [
        [
          {
            "node": "Slack Alert",
            "type": "main",
            "index": 0
          },
          {
            "node": "Log Incident",
            "type": "main",
            "index": 0
          }
        ]
      ]
    }
  }
}
Enter fullscreen mode Exit fullscreen mode

Workflow 3: Logistics Compliance Deadline Tracker

LogisticsTech SaaS operates under a compliance calendar most teams ignore:

  • FMCSA ELD annual certification — 49 CFR §395, driver data retention 6 months minimum
  • DOT drug/alcohol test batches — 49 CFR Part 40, quarterly, strict access control (MRO and DER only — §40.331 violation if others view)
  • C-TPAT annual security profile — CBP requires documented annual review for partner vetting
  • FMC tariff filing — 46 CFR Part 520, rate publication deadlines
  • TSA known shipper renewal — 49 CFR Part 1548, indirect air carrier requirements
  • GDPR Article 30 register — EU shipper/consignee name+address = personal data, sub-processor documentation required
  • CCPA data inventory — California resident shipper/consignee = personal information under Cal. Civ. Code §1798.100
  • CBP ISF 10+2 review — 19 CFR §149, import security filing

Missing any of these isn't operational slippage — it's a regulatory violation.

{
  "name": "Logistics Compliance Deadline Tracker",
  "nodes": [
    {
      "id": "1",
      "name": "Weekdays 8AM",
      "type": "n8n-nodes-base.scheduleTrigger",
      "typeVersion": 1,
      "position": [
        250,
        300
      ],
      "parameters": {
        "rule": {
          "interval": [
            {
              "field": "cronExpression",
              "expression": "0 8 * * 1-5"
            }
          ]
        }
      }
    },
    {
      "id": "2",
      "name": "Fetch Deadlines",
      "type": "n8n-nodes-base.googleSheets",
      "typeVersion": 4,
      "position": [
        470,
        300
      ],
      "parameters": {
        "operation": "getAll",
        "sheetId": "COMPLIANCE_SHEET_ID"
      }
    },
    {
      "id": "3",
      "name": "Classify Urgency",
      "type": "n8n-nodes-base.code",
      "typeVersion": 2,
      "position": [
        690,
        300
      ],
      "parameters": {
        "jsCode": "const actionMap={FMCSA_ELD_ANNUAL:{owner:'compliance@co.com',ch:'#compliance-ops',action:'FMCSA ELD cert \u2014 49 CFR 395 \u2014 6mo retention'},DOT_DRUG_TEST_Q:{owner:'hr@co.com',ch:'#hr-compliance',action:'DOT drug/alcohol batch \u2014 49 CFR Part 40 \u2014 restricted access'},CTPAT_REVIEW:{owner:'security@co.com',ch:'#compliance-ops',action:'C-TPAT annual review \u2014 CBP partner vetting doc'},FMC_TARIFF:{owner:'compliance@co.com',ch:'#compliance-ops',action:'FMC tariff filing \u2014 46 CFR Part 520'},TSA_CARGO:{owner:'ops@co.com',ch:'#ops-compliance',action:'TSA known shipper renewal \u2014 49 CFR Part 1548'},SOC2_TYPE2:{owner:'ciso@co.com',ch:'#security',action:'SOC2 Type II audit window'},GDPR_ART30:{owner:'privacy@co.com',ch:'#legal',action:'GDPR Art.30 register \u2014 EU shipper/consignee data'},CCPA_INVENTORY:{owner:'privacy@co.com',ch:'#legal',action:'CCPA data inventory \u2014 CA shipper purchase history'},CBP_ISF:{owner:'trade@co.com',ch:'#compliance-ops',action:'CBP ISF 10+2 review \u2014 19 CFR 149'}};return items.map(item=>{const d=item.json;const days=Math.floor((new Date(d.due_date)-new Date())/86400000);let urg=days<0?'OVERDUE':days<=3?'CRITICAL':days<=7?'URGENT':days<=21?'WARNING':'NOTICE';const m=actionMap[d.compliance_type]||{owner:'compliance@co.com',ch:'#compliance-ops',action:d.compliance_type};return{json:{...d,...m,days,urg,alert:urg!=='NOTICE'}};});"
      }
    },
    {
      "id": "4",
      "name": "Filter Actionable",
      "type": "n8n-nodes-base.filter",
      "typeVersion": 2,
      "position": [
        910,
        300
      ],
      "parameters": {
        "conditions": {
          "conditions": [
            {
              "leftValue": "={{$json.alert}}",
              "rightValue": true,
              "operator": {
                "type": "boolean",
                "operation": "equals"
              }
            }
          ]
        }
      }
    },
    {
      "id": "5",
      "name": "Route",
      "type": "n8n-nodes-base.switch",
      "typeVersion": 3,
      "position": [
        1130,
        300
      ],
      "parameters": {
        "mode": "rules",
        "rules": {
          "values": [
            {
              "conditions": {
                "conditions": [
                  {
                    "leftValue": "={{$json.urg}}",
                    "rightValue": "OVERDUE",
                    "operator": {
                      "type": "string",
                      "operation": "equals"
                    }
                  }
                ]
              }
            },
            {
              "conditions": {
                "conditions": [
                  {
                    "leftValue": "={{$json.urg}}",
                    "rightValue": "CRITICAL",
                    "operator": {
                      "type": "string",
                      "operation": "equals"
                    }
                  }
                ]
              }
            }
          ]
        }
      }
    },
    {
      "id": "6",
      "name": "Slack Urgent",
      "type": "n8n-nodes-base.slack",
      "typeVersion": 2,
      "position": [
        1350,
        200
      ],
      "parameters": {
        "channel": "={{$json.ch}}",
        "text": "{{$json.urg}} {{$json.compliance_type}} due {{$json.due_date}} ({{$json.days}}d) | @here {{$json.action}}"
      }
    },
    {
      "id": "7",
      "name": "Email Owner",
      "type": "n8n-nodes-base.gmail",
      "typeVersion": 2,
      "position": [
        1350,
        400
      ],
      "parameters": {
        "toEmail": "={{$json.owner}}",
        "subject": "[{{$json.urg}}] {{$json.compliance_type}}",
        "message": "Due: {{$json.due_date}} ({{$json.days}} days)\nAction: {{$json.action}}"
      }
    }
  ],
  "connections": {
    "Weekdays 8AM": {
      "main": [
        [
          {
            "node": "Fetch Deadlines",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Fetch Deadlines": {
      "main": [
        [
          {
            "node": "Classify Urgency",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Classify Urgency": {
      "main": [
        [
          {
            "node": "Filter Actionable",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Filter Actionable": {
      "main": [
        [
          {
            "node": "Route",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Route": {
      "main": [
        [
          {
            "node": "Slack Urgent",
            "type": "main",
            "index": 0
          }
        ],
        [
          {
            "node": "Email Owner",
            "type": "main",
            "index": 0
          }
        ]
      ]
    }
  }
}
Enter fullscreen mode Exit fullscreen mode

Workflow 4: Shipment Exception & Delay Alert Pipeline

Lost packages, customs holds, carrier delays — these need to reach the right team within minutes. This webhook-driven workflow classifies each exception type, sets resolution SLAs, and routes to the correct Slack channel.

Compliance angle: Lost shipments containing hazmat or controlled goods trigger mandatory DOT/IATA reporting timelines. The Postgres log creates the paper trail. The webhook responds immediately with {received: true, severity, resolution} so the upstream event emitter doesn't timeout.

{
  "name": "Shipment Exception & Delay Alert Pipeline",
  "nodes": [
    {
      "id": "1",
      "name": "Webhook Exception",
      "type": "n8n-nodes-base.webhook",
      "typeVersion": 2,
      "position": [
        250,
        300
      ],
      "parameters": {
        "httpMethod": "POST",
        "path": "shipment-exception",
        "responseMode": "responseNode"
      }
    },
    {
      "id": "2",
      "name": "Classify Exception",
      "type": "n8n-nodes-base.code",
      "typeVersion": 2,
      "position": [
        470,
        300
      ],
      "parameters": {
        "jsCode": "const e=items[0].json;const map={LOST_SHIPMENT:{sev:'CRITICAL',ch:'#ops-critical',mention:'@channel',slaH:1,action:'Initiate tracer + carrier claim'},CUSTOMS_HOLD:{sev:'CRITICAL',ch:'#trade-compliance',mention:'@channel',slaH:2,action:'Engage customs broker'},CARRIER_DELAY_4H:{sev:'HIGH',ch:'#logistics-ops',mention:'@here',slaH:4,action:'Re-route or notify consignee'},WEATHER_DELAY:{sev:'MEDIUM',ch:'#logistics-ops',mention:'',slaH:8,action:'Monitor and update ETA'},DELIVERY_EXCEPTION:{sev:'MEDIUM',ch:'#logistics-ops',mention:'',slaH:4,action:'Attempt redelivery'}};const m=map[e.exception_type]||{sev:'INFO',ch:'#logistics-ops',mention:'',slaH:48,action:'Review and action'};const resolution=new Date(Date.now()+m.slaH*3600000).toISOString();return[{json:{...e,...m,resolution}}];"
      }
    },
    {
      "id": "3",
      "name": "Slack Alert",
      "type": "n8n-nodes-base.slack",
      "typeVersion": 2,
      "position": [
        690,
        200
      ],
      "parameters": {
        "channel": "={{$json.ch}}",
        "text": "{{$json.mention}} {{$json.sev}} \u2014 {{$json.exception_type}} | Tracking: {{$json.tracking_number}} | Carrier: {{$json.carrier}} | Resolve by: {{$json.resolution}} | Action: {{$json.action}}"
      }
    },
    {
      "id": "4",
      "name": "Log Incident",
      "type": "n8n-nodes-base.postgres",
      "typeVersion": 2,
      "position": [
        690,
        400
      ],
      "parameters": {
        "operation": "executeQuery",
        "query": "INSERT INTO shipment_exceptions(tracking_number,exception_type,severity,carrier,detected_at,expected_resolution) VALUES($1,$2,$3,$4,NOW(),$5) ON CONFLICT(tracking_number,exception_type) DO UPDATE SET detected_at=NOW()",
        "queryParams": "={{[$json.tracking_number,$json.exception_type,$json.sev,$json.carrier,$json.resolution]}}"
      }
    },
    {
      "id": "5",
      "name": "Respond 200",
      "type": "n8n-nodes-base.respondToWebhook",
      "typeVersion": 1,
      "position": [
        910,
        300
      ],
      "parameters": {
        "respondWith": "json",
        "responseBody": "={\"received\":true,\"severity\":\"{{$json.sev}}\",\"resolution\":\"{{$json.resolution}}\"}"
      }
    }
  ],
  "connections": {
    "Webhook Exception": {
      "main": [
        [
          {
            "node": "Classify Exception",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Classify Exception": {
      "main": [
        [
          {
            "node": "Slack Alert",
            "type": "main",
            "index": 0
          },
          {
            "node": "Log Incident",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Log Incident": {
      "main": [
        [
          {
            "node": "Respond 200",
            "type": "main",
            "index": 0
          }
        ]
      ]
    }
  }
}
Enter fullscreen mode Exit fullscreen mode

Workflow 5: Weekly LogisticsTech KPI Dashboard

Every Monday at 8AM: active clients, weekly shipments processed, on-time delivery rate (color-coded: green ≥95%, orange ≥90%, red below), MRR with week-over-week delta, and at-risk account count. Two parallel Postgres queries, merged in n8n, built into an HTML email to the exec team, posted to Slack.

No Looker license. No data leaving your VPC. No Zapier task history capturing GMV figures.

{
  "name": "Weekly LogisticsTech KPI Dashboard",
  "nodes": [
    {
      "id": "1",
      "name": "Monday 8AM",
      "type": "n8n-nodes-base.scheduleTrigger",
      "typeVersion": 1,
      "position": [
        250,
        300
      ],
      "parameters": {
        "rule": {
          "interval": [
            {
              "field": "cronExpression",
              "expression": "0 8 * * 1"
            }
          ]
        }
      }
    },
    {
      "id": "2",
      "name": "Platform Metrics",
      "type": "n8n-nodes-base.postgres",
      "typeVersion": 2,
      "position": [
        470,
        200
      ],
      "parameters": {
        "operation": "executeQuery",
        "query": "SELECT COUNT(DISTINCT client_id) as clients, SUM(shipments_last_7d) as shipments, AVG(on_time_pct) as on_time, SUM(mrr_usd) as mrr FROM platform_metrics WHERE week_start=DATE_TRUNC('week',NOW()-INTERVAL '7 days')"
      }
    },
    {
      "id": "3",
      "name": "Account Health",
      "type": "n8n-nodes-base.postgres",
      "typeVersion": 2,
      "position": [
        470,
        400
      ],
      "parameters": {
        "operation": "executeQuery",
        "query": "SELECT SUM(CASE WHEN health='RED' THEN 1 ELSE 0 END) as at_risk, SUM(CASE WHEN health='AMBER' THEN 1 ELSE 0 END) as watch FROM account_health WHERE checked_at>=NOW()-INTERVAL '7 days'"
      }
    },
    {
      "id": "4",
      "name": "Merge",
      "type": "n8n-nodes-base.merge",
      "typeVersion": 3,
      "position": [
        690,
        300
      ],
      "parameters": {
        "mode": "combine",
        "combinationMode": "mergeByPosition"
      }
    },
    {
      "id": "5",
      "name": "Build Report",
      "type": "n8n-nodes-base.code",
      "typeVersion": 2,
      "position": [
        910,
        300
      ],
      "parameters": {
        "jsCode": "const d=items[0].json;const prev=JSON.parse($getWorkflowStaticData('global').prev||'{}');const mrr=parseFloat(d.mrr||0);const prevMrr=parseFloat(prev.mrr||mrr);const wow=prevMrr>0?((mrr-prevMrr)/prevMrr*100).toFixed(1):'N/A';const ot=parseFloat(d.on_time||0);const col=ot>=95?'green':ot>=90?'orange':'red';$setWorkflowStaticData('global',{prev:JSON.stringify({mrr})});const html='<h2>LogisticsTech KPI</h2><table border=1 cellpadding=8><tr><th>Metric</th><th>Value</th><th>WoW</th></tr><tr><td>Clients</td><td>'+d.clients+'</td><td>-</td></tr><tr><td>Shipments</td><td>'+parseInt(d.shipments||0)+'</td><td>-</td></tr><tr><td>On-Time</td><td style=color:'+col+'>'+ot.toFixed(1)+'%</td><td>-</td></tr><tr><td>MRR</td><td>$'+mrr+'</td><td>'+wow+'%</td></tr><tr><td>At-Risk</td><td style=color:red>'+d.at_risk+'</td><td>-</td></tr></table>';return[{json:{...d,html,wow}}];"
      }
    },
    {
      "id": "6",
      "name": "Email Execs",
      "type": "n8n-nodes-base.gmail",
      "typeVersion": 2,
      "position": [
        1130,
        200
      ],
      "parameters": {
        "toEmail": "ceo@company.com",
        "ccEmail": "cto@company.com",
        "subject": "Weekly LogisticsTech KPI",
        "message": "={{$json.html}}"
      }
    },
    {
      "id": "7",
      "name": "Slack Summary",
      "type": "n8n-nodes-base.slack",
      "typeVersion": 2,
      "position": [
        1130,
        400
      ],
      "parameters": {
        "channel": "#exec-kpis",
        "text": "Weekly KPI: MRR ${{$json.mrr}} ({{$json.wow}}% WoW) | On-Time: {{$json.on_time}}% | At-Risk: {{$json.at_risk}}"
      }
    }
  ],
  "connections": {
    "Monday 8AM": {
      "main": [
        [
          {
            "node": "Platform Metrics",
            "type": "main",
            "index": 0
          },
          {
            "node": "Account Health",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Platform Metrics": {
      "main": [
        [
          {
            "node": "Merge",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Account Health": {
      "main": [
        [
          {
            "node": "Merge",
            "type": "main",
            "index": 1
          }
        ]
      ]
    },
    "Merge": {
      "main": [
        [
          {
            "node": "Build Report",
            "type": "main",
            "index": 0
          }
        ]
      ]
    },
    "Build Report": {
      "main": [
        [
          {
            "node": "Email Execs",
            "type": "main",
            "index": 0
          },
          {
            "node": "Slack Summary",
            "type": "main",
            "index": 0
          }
        ]
      ]
    }
  }
}
Enter fullscreen mode Exit fullscreen mode

The LogisticsTech Data Risk Nobody Talks About

Zapier's task history stores every field of every record. For LogisticsTech SaaS, that means:

  • ELD records (driver name, hours, location): FMCSA requires controlled access — Zapier's multi-tenant task log is uncontrolled
  • DOT drug test results: legally restricted to MRO and DER — any team member viewing Zapier logs is a §40.331 violation
  • C-TPAT partner data: CBP requires you to document who accessed partner security info — Zapier logs aren't auditable at that level
  • GDPR Art.28: EU shipper/consignee name+address through Zapier = sub-processor requiring signed DPA, sub-processor audit rights, data location documentation

n8n self-hosted keeps all of this in your VPC. Your customers' compliance auditors see your infrastructure — not a third-party SaaS task log.

Cost Reality

Scale Zapier n8n self-hosted
1M events/mo ~$1,000/mo ~$20/mo
10M events/mo ~$10,000/mo ~$60/mo
50M events/mo ~$50,000/mo ~$500/mo

At enterprise LogisticsTech scale, n8n pays for itself in the first hour of the first month.

Get All 5 Workflows (Import-Ready)

All 5 workflows are in the FlowKit n8n Automation Template Library at stripeai.gumroad.com — import-ready JSON, pre-wired logic, production-tested.

Individual templates: $12–$29. Full library bundle (15 templates): $97.

Which shipment exception type causes the most escalations at your logistics platform? Drop it in the comments — I'll show you the n8n workflow for it.

Top comments (0)