AI Workflow Automation Examples

An automated workflow that receives invoices, extracts data with AI, matches against purchase orders, routes for approval based on amount and category rules, and posts to the accounting system upon approval.

// Invoice approval workflow
async function invoiceWorkflow(invoice) {
  // Extract and validate
  const data = await extractInvoiceData(invoice);
  const poMatch = await matchPurchaseOrder(data);

  // Determine approval route
  const route = determineApprovalRoute(data.amount, data.category, poMatch);

  if (route.autoApprove && poMatch.confidence > 0.95) {
    await postToAccounting(data);
    return { status: "auto-approved" };
  }

  // Queue for human approval
  await approvalQueue.add({
    invoice: data,
    poMatch,
    approver: route.approver,
    deadline: route.sla,
  });
}

function determineApprovalRoute(amount, category, poMatch) {
  if (amount < 500 && poMatch.exact) return { autoApprove: true };
  if (amount < 5000) return { approver: "finance-team", sla: "24h" };
  return { approver: "cfo", sla: "48h" };
}

A workflow that orchestrates the entire employee onboarding process: provisioning accounts, assigning training modules based on role, scheduling introductions, generating welcome materials, and tracking completion of onboarding tasks.

// Employee onboarding workflow
async function onboardingWorkflow(newHire) {
  const roleConfig = await getRoleOnboardingConfig(newHire.role);

  // Parallel setup tasks
  await Promise.all([
    provisionAccounts(newHire, roleConfig.systems),
    assignTraining(newHire, roleConfig.courses),
    orderEquipment(newHire, roleConfig.equipment),
    scheduleIntroMeetings(newHire, roleConfig.stakeholders),
  ]);

  // Generate personalised welcome pack
  const welcomePack = await llm.chat({
    messages: [{
      role: "system",
      content: "Create a personalised welcome message covering first-week schedule, key contacts, and useful links."
    }, { role: "user", content: JSON.stringify({ name: newHire.name, role: newHire.role, team: newHire.team }) }]
  });

  await sendWelcomeEmail(newHire.email, welcomePack);
  await trackOnboardingProgress(newHire.id, roleConfig.milestones);
}

A workflow for content teams that accepts drafts, runs AI quality checks (grammar, brand voice, SEO), routes through approval stages, and publishes to the CMS. Includes rollback capability and version tracking.

// Content publishing pipeline
async function contentPipeline(draft) {
  // Automated quality checks
  const checks = await Promise.all([
    checkGrammar(draft.content),
    checkBrandVoice(draft.content),
    checkSEO(draft.content, draft.targetKeywords),
    checkAccessibility(draft.content),
  ]);

  const issues = checks.flatMap(c => c.issues);
  if (issues.filter(i => i.severity === "error").length > 0) {
    return { status: "needs-revision", issues };
  }

  // Route for approval
  await approvalQueue.add({
    content: draft,
    qualityScore: calculateScore(checks),
    reviewType: draft.type === "legal" ? "legal-review" : "editorial-review",
  });
}

A workflow that ingests customer complaints from multiple channels, categorises them, checks order/account history, generates resolution options, and routes to the appropriate handler with full context and suggested actions.

// Complaint resolution workflow
async function complaintWorkflow(complaint) {
  // Enrich with context
  const [customer, orders, history] = await Promise.all([
    crm.getCustomer(complaint.customerId),
    orders.getRecent(complaint.customerId),
    complaints.getHistory(complaint.customerId),
  ]);

  // Classify and suggest resolution
  const analysis = await llm.chat({
    messages: [{
      role: "system",
      content: "Classify this complaint and suggest 2-3 resolution options with estimated cost and likelihood of customer satisfaction."
    }, { role: "user", content: JSON.stringify({ complaint: complaint.text, customerValue: customer.ltv, orderHistory: orders, priorComplaints: history }) }]
  });

  // Route to handler
  await handlerQueue.add({
    complaint, customer, analysis,
    priority: customer.ltv > 10000 ? "high" : "normal",
    sla: analysis.category === "safety" ? "1h" : "24h",
  });
}

Automates vendor assessment: collecting required documents, running AI-powered due diligence checks, scoring risk, requesting missing information, and routing through compliance approval stages.

// Vendor onboarding workflow
async function vendorOnboarding(vendor) {
  // Check document completeness
  const required = getRequiredDocuments(vendor.category, vendor.country);
  const missing = required.filter(doc => !vendor.documents[doc]);
  if (missing.length > 0) {
    await requestDocuments(vendor.email, missing);
    return { status: "awaiting-documents", missing };
  }

  // AI due diligence
  const dueDiligence = await Promise.all([
    checkSanctionsList(vendor.name, vendor.country),
    analyseFinancials(vendor.documents.financials),
    reviewInsurance(vendor.documents.insurance),
    assessCyberRisk(vendor.domain),
  ]);

  const riskScore = calculateVendorRisk(dueDiligence);
  const approvalLevel = riskScore > 0.7 ? "board" : riskScore > 0.4 ? "compliance" : "procurement";

  await routeForApproval(vendor, { dueDiligence, riskScore, approvalLevel });
}