Intelligent Operation Automation &
Workflow Orchestration.

# Temporal.io Durable Python Workflow with Exponential Retry & Saga Compensation
from datetime import timedelta
from temporalio import workflow
from temporalio.common import RetryPolicy

with workflow.unsafe.imports_passed_through():
    from activities import extract_pdf_data, reconcile_netsuite, schedule_payout, alert_human_slack

@workflow.defn
class InvoiceAutomationWorkflow:
    @workflow.run
    async def run(self, s3_file_uri: str, tenant_id: str) -> dict:
        retry_policy = RetryPolicy(
            initial_interval=timedelta(seconds=2),
            maximum_interval=timedelta(minutes=5),
            maximum_attempts=10
        )

        # Step 1: Extract unstructured PDF with Claude 3.5 Vision
        invoice = await workflow.execute_activity(
            extract_pdf_data, s3_file_uri, start_to_close_timeout=timedelta(minutes=2), retry_policy=retry_policy
        )

        # Step 2: Cross-check purchase order in NetSuite ERP
        match_status = await workflow.execute_activity(
            reconcile_netsuite, invoice, start_to_close_timeout=timedelta(seconds=45), retry_policy=retry_policy
        )

        # Step 3: High-Value Human-in-the-Loop Checkpoint (> $50,000)
        if invoice["total_amount"] > 50000 or not match_status["exact_match"]:
            approval = await workflow.execute_activity(
                alert_human_slack, invoice, start_to_close_timeout=timedelta(days=3)
            )
            if not approval["approved"]:
                return {"status": "REJECTED", "reason": approval["comments"]}

        # Step 4: Schedule ACH Wire Transfer
        payout_res = await workflow.execute_activity(
            schedule_payout, invoice, start_to_close_timeout=timedelta(seconds=30)
        )
        return {"status": "SETTLED", "payout_id": payout_res["id"]}

# Multi-Modal Vision Parser extracting strongly-typed Pydantic schemas
from pydantic import BaseModel, Field
import anthropic

client = anthropic.Anthropic()

class LineItem(BaseModel):
    sku: str
    description: str
    quantity: int
    unit_price: float
    total: float

class InvoiceSchema(BaseModel):
    vendor_name: str
    invoice_number: str
    total_amount: float
    line_items: list[LineItem]

def extract_invoice_from_image(image_b64: str) -> InvoiceSchema:
    response = client.messages.create(
        model="claude-3-5-sonnet-20241022",
        max_tokens=2048,
        messages=[{
            "role": "user",
            "content": [
                {"type": "image", "source": {"type": "base64", "media_type": "image/png", "data": image_b64}},
                {"type": "text", "text": "Extract all invoice metadata strictly into the specified JSON schema."}
            ]
        }],
        tools=[{"name": "submit_invoice", "description": "Schema validator", "input_schema": InvoiceSchema.model_json_schema()}]
    )
    tool_call = next(c for c in response.content if c.type == "tool_use")
    return InvoiceSchema(**tool_call.input)

// Enterprise NetSuite ERP Bidirectional Synchronization Module
import { NetSuiteClient } from "@/lib/netsuite";

export async function reconcilePurchaseOrder(poNumber: string, invoiceAmount: number) {
  const client = new NetSuiteClient({
    accountId: process.env.NETSUITE_ACCOUNT_ID!,
    tokenKey: process.env.NETSUITE_TOKEN_KEY!,
    tokenSecret: process.env.NETSUITE_TOKEN_SECRET!
  });

  // Query NetSuite via SuiteTalk REST API
  const poRecord = await client.get(`/record/v1/purchaseOrder?tranId=${poNumber}`);
  if (!poRecord.items || poRecord.items.length === 0) {
    return { exact_match: false, error: "PO not found in NetSuite" };
  }

  const poTotal = poRecord.items[0].total;
  const delta = Math.abs(poTotal - invoiceAmount);

  return {
    exact_match: delta < 0.01,
    po_id: poRecord.items[0].id,
    amount_variance: delta
  };
}

# Slack Interactive Human-in-the-Loop Approval BlockKit Dispatcher
from slack_sdk.webhook import WebhookClient

def post_approval_card(invoice: dict, webhook_url: str):
    client = WebhookClient(webhook_url)
    blocks = [
        {"type": "header", "text": {"type": "plain_text", "text": "⚠️ High-Value Invoice Approval Required"}},
        {"type": "section", "fields": [
            {"type": "mrkdwn", "text": f"*Vendor:* {invoice['vendor_name']}"},
            {"type": "mrkdwn", "text": f"*Total Amount:* ${invoice['total_amount']:,.2f}"},
            {"type": "mrkdwn", "text": f"*Invoice #:* {invoice['invoice_number']}"},
            {"type": "mrkdwn", "text": "*Audit Status:* NetSuite 3-Way Match Verified"}
        ]},
        {"type": "actions", "elements": [
            {"type": "button", "text": {"type": "plain_text", "text": "Approve Payout"}, "style": "primary", "value": "approve"},
            {"type": "button", "text": {"type": "plain_text", "text": "Reject / Escalate"}, "style": "danger", "value": "reject"}
        ]}
    ]
    return client.send(blocks=blocks)