Daten-Template: Kreditorenrechnungsverarbeitung

`config
# NetSuite Saved Search Configuration for Accounts Payable Event Log Extraction
# This configuration describes the settings for a single, comprehensive Saved Search.
# The output is a 'wide' file that must be unpivoted into an event log.

SearchType: "Transaction"

# ====================================================================
# CRITERIA
# ====================================================================
# Define the filters to select the base records
# --------------------------------------------------------------------

Filters: [
  {
    "field": "Type",
    "operator": "is",
    "value": "Vendor Bill"
  },
  {
    "field": "Main Line",
    "operator": "is",
    "value": "True"
  },
  {
    "field": "Date Created",
    "operator": "within",
    "value": "[Specify Date Range, e.g., thisfiscalquarter]"
  }
]

# ====================================================================
# RESULTS
# ====================================================================
# Define the columns for the output. The final CSV will have these columns.
# Common attributes are listed first, followed by pairs of columns for each activity.
# --------------------------------------------------------------------

Columns: [
  // --- Common Attributes ---
  { "field": "Document Number", "label": "Invoice" },
  { "field": "Entity", "label": "VendorName" },
  { "field": "Amount", "label": "InvoiceAmount" },
  { "field": "Applied To Transaction", "label": "PurchaseOrderNumber" },
  { "field": "Created By", "label": "ProcessorUser" },
  { "field": "Next Approver", "label": "Approver" },
  { "field": "Due Date", "label": "InvoiceDueDate" },
  { "formula": "'NetSuite'", "type": "Text", "label": "SourceSystem" },
  { "formula": "{today}", "type": "Date/Time", "label": "LastDataUpdate" },

  // --- Activity 1: Vendor Bill Created ---
  { "formula": "'Vendor Bill Created'", "type": "Text", "label": "ActivityName_Created" },
  { "field": "Date Created", "label": "EventTime_Created" },

  // --- Activity 2: PO Matching Attempted ---
  { "formula": "CASE WHEN {appliedtotransaction} IS NOT NULL THEN 'PO Matching Attempted' ELSE NULL END", "type": "Text", "label": "ActivityName_POMatched" },
  { "formula": "CASE WHEN {appliedtotransaction} IS NOT NULL THEN {datecreated} ELSE NULL END", "type": "Date/Time", "label": "EventTime_POMatched" },

  // --- Activity 3: Discrepancy Identified ---
  { "formula": "CASE WHEN {approvalstatus} = 'Rejected' THEN 'Discrepancy Identified' ELSE NULL END", "type": "Text", "label": "ActivityName_Discrepancy" },
  { "formula": "(SELECT MIN(systemnotes.date) FROM systemnote WHERE systemnote.recordid = {internalid} AND systemnote.field = 'TRANSACTION.APPROVALSTATUS' AND systemnote.newvalue = 'Rejected')", "type": "Date/Time", "label": "EventTime_Discrepancy" },

  // --- Activity 4: Approval Submitted ---
  { "formula": "CASE WHEN {approvalstatus} != 'Pending Approval' AND {approvalstatus} != 'Approved' THEN NULL ELSE 'Approval Submitted' END", "type": "Text", "label": "ActivityName_Submitted" },
  { "formula": "(SELECT MIN(systemnotes.date) FROM systemnote WHERE systemnote.recordid = {internalid} AND systemnote.field = 'TRANSACTION.APPROVALSTATUS' AND systemnote.newvalue = 'Pending Approval')", "type": "Date/Time", "label": "EventTime_Submitted" },

  // --- Activity 5: Invoice Re-Routed For Approval ---
  { "formula": "CASE WHEN (SELECT COUNT(systemnotes.date) FROM systemnote WHERE systemnote.recordid = {internalid} AND systemnote.field = 'TRANSACTION.APPROVALSTATUS' AND systemnote.newvalue = 'Pending Approval') > 1 THEN 'Invoice Re-Routed For Approval' ELSE NULL END", "type": "Text", "label": "ActivityName_ReRouted" },
  { "formula": "(SELECT MAX(systemnotes.date) FROM systemnote WHERE systemnote.recordid = {internalid} AND systemnote.field = 'TRANSACTION.APPROVALSTATUS' AND systemnote.newvalue = 'Pending Approval' AND systemnotes.date < (SELECT MAX(sub_notes.date) FROM systemnote sub_notes WHERE sub_notes.recordid = {internalid} AND sub_notes.field = 'TRANSACTION.APPROVALSTATUS' AND sub_notes.newvalue = 'Pending Approval'))", "type": "Date/Time", "label": "EventTime_ReRouted" },

  // --- Activity 6: Invoice Approved ---
  { "formula": "CASE WHEN {approvalstatus} = 'Approved' THEN 'Invoice Approved' ELSE NULL END", "type": "Text", "label": "ActivityName_Approved" },
  { "formula": "(SELECT MIN(systemnotes.date) FROM systemnote WHERE systemnote.recordid = {internalid} AND systemnote.field = 'TRANSACTION.APPROVALSTATUS' AND systemnote.newvalue = 'Approved')", "type": "Date/Time", "label": "EventTime_Approved" },

  // --- Activity 7: Invoice Rejected ---
  { "formula": "CASE WHEN {approvalstatus} = 'Rejected' THEN 'Invoice Rejected' ELSE NULL END", "type": "Text", "label": "ActivityName_Rejected" },
  { "formula": "(SELECT MAX(systemnotes.date) FROM systemnote WHERE systemnote.recordid = {internalid} AND systemnote.field = 'TRANSACTION.APPROVALSTATUS' AND systemnote.newvalue = 'Rejected')", "type": "Date/Time", "label": "EventTime_Rejected" },

  // --- Activity 8: Invoice Posted To GL ---
  { "formula": "CASE WHEN {posting} = 'Yes' THEN 'Invoice Posted To GL' ELSE NULL END", "type": "Text", "label": "ActivityName_Posted" },
  { "field": "Date", "label": "EventTime_Posted" },

  // --- Activity 9: Payment Scheduled ---
  { "formula": "CASE WHEN {payingtransaction.type} = 'Vendor Payment' AND {payingtransaction.trandate} > {today} THEN 'Payment Scheduled' ELSE NULL END", "type": "Text", "label": "ActivityName_Scheduled" },
  { "formula": "CASE WHEN {payingtransaction.type} = 'Vendor Payment' AND {payingtransaction.trandate} > {today} THEN {payingtransaction.datecreated} ELSE NULL END", "type": "Date/Time", "label": "EventTime_Scheduled" },

  // --- Activity 10: Payment Executed ---
  { "formula": "CASE WHEN {status} = 'Paid in Full' OR {status} = 'Pending Approval' THEN 'Payment Executed' ELSE NULL END", "type": "Text", "label": "ActivityName_Executed" },
  { "field": "Paying Transaction Date", "label": "EventTime_Executed" },

  // --- Activity 11: Invoice Closed ---
  { "formula": "CASE WHEN {status} = 'Paid in Full' THEN 'Invoice Closed' ELSE NULL END", "type": "Text", "label": "ActivityName_Closed" },
  { "field": "Paying Transaction Date", "label": "EventTime_Closed" },

  // --- Activity 12: Early Payment Captured ---
  { "formula": "CASE WHEN {payingtransaction.trandate} < {discountdate} AND {discountamount} IS NOT NULL THEN 'Early Payment Captured' ELSE NULL END", "type": "Text", "label": "ActivityName_EarlyPay" },
  { "formula": "CASE WHEN {payingtransaction.trandate} < {discountdate} AND {discountamount} IS NOT NULL THEN {payingtransaction.trandate} ELSE NULL END", "type": "Date/Time", "label": "EventTime_EarlyPay" },

  // --- Activity 13: Late Payment Identified ---
  { "formula": "CASE WHEN {daysoverdue} > 0 AND {status} = 'Paid in Full' THEN 'Late Payment Identified' ELSE NULL END", "type": "Text", "label": "ActivityName_LatePay" },
  { "formula": "CASE WHEN {daysoverdue} > 0 AND {status} = 'Paid in Full' THEN {payingtransaction.trandate} ELSE NULL END", "type": "Date/Time", "label": "EventTime_LatePay" },

  // --- Activity 14: Credit Memo Applied ---
  { "formula": "CASE WHEN {payingtransaction.type} = 'Vendor Credit' THEN 'Credit Memo Applied' ELSE NULL END", "type": "Text", "label": "ActivityName_CreditMemo" },
  { "formula": "CASE WHEN {payingtransaction.type} = 'Vendor Credit' THEN {payingtransaction.trandate} ELSE NULL END", "type": "Date/Time", "label": "EventTime_CreditMemo" }
]
`

`sql
-- This query extracts an event log for the Accounts Payable Invoice Processing from NetSuite.
-- It uses a UNION ALL approach to gather 14 distinct activities into a single file.

WITH VendorBillsInScope AS (
    -- CTE to select the primary Vendor Bills to analyze.
    -- Filtering here is critical for performance.
    SELECT
        Transaction.ID AS BillID,
        Transaction.tranid AS Invoice,
        Transaction.trandate AS BillDate,
        Transaction.duedate AS InvoiceDueDate,
        Transaction.foreignTotal AS InvoiceAmount,
        Transaction.entity AS VendorID,
        Transaction.createdBy AS ProcessorUserID,
        Transaction.status AS BillStatus,
        Transaction.approvalStatus AS ApprovalStatus,
        Transaction.discountDate AS DiscountDate
    FROM
        Transaction
    WHERE
        Transaction.type = 'VendBill'
        -- CRITICAL: Define the date range for the extraction
        AND Transaction.trandate BETWEEN TO_DATE('[START_DATE]', 'YYYY-MM-DD') AND TO_DATE('[END_DATE]', 'YYYY-MM-DD')
        -- OPTIONAL: Filter by a specific subsidiary for NetSuite OneWorld accounts
        -- AND Transaction.subsidiary = [SUBSIDIARY_ID]
),

-- Base information for joins, including vendor, processor, and PO data.
BaseInfo AS (
    SELECT
        vb.BillID,
        vb.Invoice,
        vb.InvoiceAmount,
        vb.InvoiceDueDate,
        vb.DiscountDate,
        vendor.companyName AS VendorName,
        processor.entityId AS ProcessorUser,
        LISTAGG(DISTINCT po.tranid, ', ') WITHIN GROUP (ORDER BY po.tranid) AS PurchaseOrderNumber
    FROM
        VendorBillsInScope vb
    LEFT JOIN
        Entity vendor ON vb.VendorID = vendor.ID
    LEFT JOIN
        Employee processor ON vb.ProcessorUserID = processor.ID
    LEFT JOIN
        TransactionLine tl ON vb.BillID = tl.Transaction
    LEFT JOIN
        Transaction po ON tl.purchaseOrder = po.ID AND po.type = 'PurchOrd'
    GROUP BY
        vb.BillID, vb.Invoice, vb.InvoiceAmount, vb.InvoiceDueDate, vb.DiscountDate, vendor.companyName, processor.entityId
),

-- System Notes are used to track status changes for approvals, rejections, etc.
Notes AS (
    SELECT
        sn.transactionId AS BillID,
        sn.date AS NoteDate,
        sn.field AS NoteField,
        sn.newValue AS NoteNewValue,
        sn.oldValue AS NoteOldValue,
        approver.entityId AS Approver
    FROM
        SystemNote sn
    JOIN
        VendorBillsInScope vb ON sn.transactionId = vb.BillID
    LEFT JOIN
        Employee approver ON sn.author = approver.ID
    WHERE
        -- Filtering to relevant fields improves performance
        sn.field IN ('approvalstatus', 'status')
)

-- 1. Vendor Bill Created
SELECT
    bi.Invoice AS "Invoice",
    'Vendor Bill Created' AS "ActivityName",
    vb.BillDate AS "EventTime",
    'NetSuite' AS "SourceSystem",
    BUILTIN.CURRRENT_TIMESTAMP() AS "LastDataUpdate",
    bi.VendorName AS "VendorName",
    bi.InvoiceAmount AS "InvoiceAmount",
    bi.PurchaseOrderNumber AS "PurchaseOrderNumber",
    bi.ProcessorUser AS "ProcessorUser",
    NULL AS "Approver",
    bi.InvoiceDueDate AS "InvoiceDueDate"
FROM
    VendorBillsInScope vb
JOIN
    BaseInfo bi ON vb.BillID = bi.BillID

UNION ALL

-- 2. PO Matching Attempted (Inferred from PO link on creation date)
SELECT
    bi.Invoice,
    'PO Matching Attempted',
    vb.BillDate, -- Occurs at the same time as creation
    'NetSuite',
    BUILTIN.CURRRENT_TIMESTAMP(),
    bi.VendorName,
    bi.InvoiceAmount,
    bi.PurchaseOrderNumber,
    bi.ProcessorUser,
    NULL,
    bi.InvoiceDueDate
FROM
    VendorBillsInScope vb
JOIN
    BaseInfo bi ON vb.BillID = bi.BillID
WHERE
    bi.PurchaseOrderNumber IS NOT NULL

UNION ALL

-- 3. Discrepancy Identified (CUSTOMIZABLE: Inferred from status change to 'On Hold')
SELECT
    bi.Invoice,
    'Discrepancy Identified',
    n.NoteDate,
    'NetSuite',
    BUILTIN.CURRRENT_TIMESTAMP(),
    bi.VendorName,
    bi.InvoiceAmount,
    bi.PurchaseOrderNumber,
    bi.ProcessorUser,
    n.Approver, -- User who placed it on hold
    bi.InvoiceDueDate
FROM
    Notes n
JOIN
    BaseInfo bi ON n.BillID = bi.BillID
WHERE
    n.NoteField = 'approvalstatus' 
    -- CUSTOMIZABLE: Update 'On Hold' to match the status your company uses for discrepancies.
    AND n.NoteNewValue = 'On Hold'

UNION ALL

-- 4. Approval Submitted
SELECT
    bi.Invoice,
    'Approval Submitted',
    n.NoteDate,
    'NetSuite',
    BUILTIN.CURRRENT_TIMESTAMP(),
    bi.VendorName,
    bi.InvoiceAmount,
    bi.PurchaseOrderNumber,
    bi.ProcessorUser,
    n.Approver, -- User who submitted for approval
    bi.InvoiceDueDate
FROM
    Notes n
JOIN
    BaseInfo bi ON n.BillID = bi.BillID
WHERE
    n.NoteField = 'approvalstatus' AND n.NoteNewValue = 'Pending Approval'

UNION ALL

-- 5. Invoice Re-Routed For Approval (Inferred by status returning to Pending Approval)
SELECT
    bi.Invoice,
    'Invoice Re-Routed For Approval',
    n.NoteDate,
    'NetSuite',
    BUILTIN.CURRRENT_TIMESTAMP(),
    bi.VendorName,
    bi.InvoiceAmount,
    bi.PurchaseOrderNumber,
    bi.ProcessorUser,
    n.Approver,
    bi.InvoiceDueDate
FROM
    Notes n
JOIN
    BaseInfo bi ON n.BillID = bi.BillID
WHERE
    n.NoteField = 'approvalstatus' 
    AND n.NoteNewValue = 'Pending Approval'
    AND n.NoteOldValue IN ('Rejected', 'On Hold') -- Capture re-submission after rejection/hold

UNION ALL

-- 6. Invoice Approved
SELECT
    bi.Invoice,
    'Invoice Approved',
    n.NoteDate,
    'NetSuite',
    BUILTIN.CURRRENT_TIMESTAMP(),
    bi.VendorName,
    bi.InvoiceAmount,
    bi.PurchaseOrderNumber,
    bi.ProcessorUser,
    n.Approver,
    bi.InvoiceDueDate
FROM
    Notes n
JOIN
    BaseInfo bi ON n.BillID = bi.BillID
WHERE
    n.NoteField = 'approvalstatus' AND n.NoteNewValue = 'Approved'

UNION ALL

-- 7. Invoice Rejected
SELECT
    bi.Invoice,
    'Invoice Rejected',
    n.NoteDate,
    'NetSuite',
    BUILTIN.CURRRENT_TIMESTAMP(),
    bi.VendorName,
    bi.InvoiceAmount,
    bi.PurchaseOrderNumber,
    bi.ProcessorUser,
    n.Approver,
    bi.InvoiceDueDate
FROM
    Notes n
JOIN
    BaseInfo bi ON n.BillID = bi.BillID
WHERE
    n.NoteField = 'approvalstatus' AND n.NoteNewValue = 'Rejected'

UNION ALL

-- 8. Invoice Posted To GL (Happens upon approval)
SELECT
    bi.Invoice,
    'Invoice Posted To GL',
    n.NoteDate,
    'NetSuite',
    BUILTIN.CURRRENT_TIMESTAMP(),
    bi.VendorName,
    bi.InvoiceAmount,
    bi.PurchaseOrderNumber,
    bi.ProcessorUser,
    n.Approver,
    bi.InvoiceDueDate
FROM
    Notes n
JOIN
    BaseInfo bi ON n.BillID = bi.BillID
WHERE
    n.NoteField = 'approvalstatus' AND n.NoteNewValue = 'Approved'

UNION ALL

-- 9. Payment Scheduled & 10. Payment Executed & 12. Early & 13. Late Payments
WITH Payments AS (
    SELECT
        tp.previousDoc AS BillID,
        vp.trandate AS PaymentExecutionDate,
        vp.createdDate AS PaymentScheduledDate
    FROM
        TransactionPayment tp
    JOIN
        Transaction vp ON tp.nextDoc = vp.ID AND vp.type = 'VendPymt'
    WHERE
        tp.previousDoc IN (SELECT BillID FROM VendorBillsInScope)
)
SELECT p.Invoice, p.ActivityName, p.EventTime, p.SourceSystem, p.LastDataUpdate, p.VendorName, p.InvoiceAmount, p.PurchaseOrderNumber, p.ProcessorUser, p.Approver, p.InvoiceDueDate FROM (
    SELECT bi.Invoice, 'Payment Scheduled' AS ActivityName, p.PaymentScheduledDate AS EventTime, 'NetSuite' AS SourceSystem, BUILTIN.CURRRENT_TIMESTAMP() AS LastDataUpdate, bi.VendorName, bi.InvoiceAmount, bi.PurchaseOrderNumber, bi.ProcessorUser, NULL AS Approver, bi.InvoiceDueDate FROM Payments p JOIN BaseInfo bi ON p.BillID = bi.BillID
    UNION ALL
    SELECT bi.Invoice, 'Payment Executed', p.PaymentExecutionDate, 'NetSuite', BUILTIN.CURRRENT_TIMESTAMP(), bi.VendorName, bi.InvoiceAmount, bi.PurchaseOrderNumber, bi.ProcessorUser, NULL, bi.InvoiceDueDate FROM Payments p JOIN BaseInfo bi ON p.BillID = bi.BillID
    UNION ALL
    SELECT bi.Invoice, 'Early Payment Captured', p.PaymentExecutionDate, 'NetSuite', BUILTIN.CURRRENT_TIMESTAMP(), bi.VendorName, bi.InvoiceAmount, bi.PurchaseOrderNumber, bi.ProcessorUser, NULL, bi.InvoiceDueDate FROM Payments p JOIN BaseInfo bi ON p.BillID = bi.BillID WHERE p.PaymentExecutionDate <= bi.DiscountDate
    UNION ALL
    SELECT bi.Invoice, 'Late Payment Identified', p.PaymentExecutionDate, 'NetSuite', BUILTIN.CURRRENT_TIMESTAMP(), bi.VendorName, bi.InvoiceAmount, bi.PurchaseOrderNumber, bi.ProcessorUser, NULL, bi.InvoiceDueDate FROM Payments p JOIN BaseInfo bi ON p.BillID = bi.BillID WHERE p.PaymentExecutionDate > bi.InvoiceDueDate
) p

UNION ALL

-- 11. Invoice Closed (Paid in Full)
SELECT
    bi.Invoice,
    'Invoice Closed',
    n.NoteDate,
    'NetSuite',
    BUILTIN.CURRRENT_TIMESTAMP(),
    bi.VendorName,
    bi.InvoiceAmount,
    bi.PurchaseOrderNumber,
    bi.ProcessorUser,
    NULL,
    bi.InvoiceDueDate
FROM
    Notes n
JOIN
    BaseInfo bi ON n.BillID = bi.BillID
WHERE
    n.NoteField = 'status' AND n.NoteNewValue = 'Paid In Full'

UNION ALL

-- 14. Credit Memo Applied
SELECT 
    bi.Invoice,
    'Credit Memo Applied',
    vc.trandate AS EventTime,
    'NetSuite' AS SourceSystem,
    BUILTIN.CURRRENT_TIMESTAMP() AS LastDataUpdate,
    bi.VendorName,
    bi.InvoiceAmount,
    bi.PurchaseOrderNumber,
    bi.ProcessorUser,
    NULL AS Approver,
    bi.InvoiceDueDate
FROM 
    TransactionLink tl
JOIN 
    Transaction vc ON tl.previousDoc = vc.ID AND vc.type = 'VendCred'
JOIN 
    BaseInfo bi ON tl.nextDoc = bi.BillID;
`

`python
import pandas as pd
import requests
from requests_oauthlib import OAuth1
import time
import datetime
import json

class=class="hl-string">"hl-comment"># --- Configuration ---
class=class="hl-string">"hl-comment"># Replace with your NetSuite Token-Based Authentication credentials
NETSUITE_CREDENTIALS = {
    class="hl-string">"account": class="hl-string">"[Your_NetSuite_Account_ID]", class=class="hl-string">"hl-comment"># e.g., 1234567_SB1
    class="hl-string">"consumer_key": class="hl-string">"[Your_Consumer_Key]",
    class="hl-string">"consumer_secret": class="hl-string">"[Your_Consumer_Secret]",
    class="hl-string">"token_id": class="hl-string">"[Your_Token_ID]",
    class="hl-string">"token_secret": class="hl-string">"[Your_Token_Secret]"
}

class=class="hl-string">"hl-comment"># Set the date range for the extraction
START_DATE = class="hl-string">'2023-01-01'
END_DATE = class="hl-string">'2023-12-31'

class=class="hl-string">"hl-comment"># --- NetSuite API Client ---
def get_netsuite_api_url(account_id):
    class=class="hl-string">"hl-comment"># Replace class="hl-string">'-' with class="hl-string">'_' for sandbox/release preview accounts
    account_id_formatted = account_id.replace(class="hl-string">'-', class="hl-string">'_').lower()
    return fclass="hl-string">"https://{account_id_formatted}.suitetalk.api.netsuite.com/services/rest/query/v1/suiteql"

def execute_suiteql(query):
    class="hl-string">"""Executes a SuiteQL query against the NetSuite REST API with pagination."""
    url = get_netsuite_api_url(NETSUITE_CREDENTIALS[class="hl-string">"account"])
    auth = OAuth1(
        client_key=NETSUITE_CREDENTIALS[class="hl-string">"consumer_key"],
        client_secret=NETSUITE_CREDENTIALS[class="hl-string">"consumer_secret"],
        resource_owner_key=NETSUITE_CREDENTIALS[class="hl-string">"token_id"],
        resource_owner_secret=NETSUITE_CREDENTIALS[class="hl-string">"token_secret"],
        realm=NETSUITE_CREDENTIALS[class="hl-string">"account"]
    )
    headers = {
        class="hl-string">'Content-Type': class="hl-string">'application/json',
        class="hl-string">'Prefer': class="hl-string">'transient'
    }
    
    all_results = []
    offset = 0
    limit = 1000 class=class="hl-string">"hl-comment"># Max limit per page

    while True:
        paginated_query = fclass="hl-string">"{query} LIMIT {limit} OFFSET {offset}"
        payload = json.dumps({class="hl-string">'q': paginated_query})
        
        try:
            response = requests.post(url, headers=headers, data=payload, auth=auth)
            response.raise_for_status() class=class="hl-string">"hl-comment"># Raise an exception for bad status codes
            
            data = response.json()
            items = data.get(class="hl-string">'items', [])
            all_results.extend(items)
            
            if not data.get(class="hl-string">'hasMore', False):
                break
            
            offset += limit
            print(fclass="hl-string">"Fetched {len(all_results)} records...")
            time.sleep(1) class=class="hl-string">"hl-comment"># Be respectful to the API

        except requests.exceptions.RequestException as e:
            print(fclass="hl-string">"API Request Error: {e}")
            if e.response is not None:
                print(fclass="hl-string">"Response Body: {e.response.text}")
            break

    return pd.DataFrame(all_results)

class=class="hl-string">"hl-comment"># --- Main Extraction Logic ---
def main():
    print(class="hl-string">"Starting NetSuite AP Data Extraction...")
    
    class=class="hl-string">"hl-comment"># 1. Fetch Vendor Bills
    print(class="hl-string">"\n--- Step 1: Fetching Vendor Bills ---")
    vendor_bill_query = fclass="hl-string">"""
        SELECT
            tran.ID as TransactionId,
            tran.tranId as Invoice,
            tran.entity as VendorId,
            BUILTIN.DF(tran.entity) as VendorName,
            tran.tranDate as TransactionDate,
            tran.dueDate as InvoiceDueDate,
            tran.createdDate as CreatedDate,
            tran.lastModifiedDate as LastDataUpdate,
            tran.total as InvoiceAmount,
            BUILTIN.DF(tran.createdBy) as ProcessorUser,
            BUILTIN.DF(tran.approvalStatus) as ApprovalStatusText,
            tran.approvalStatus as ApprovalStatusId,
            tran.status as StatusId,
            tran.terms as TermsId,
            BUILTIN.DF(tran.terms) as TermsName
        FROM
            Transaction AS tran
        WHERE
            tran.type = 'VendBill'
            AND tran.lastModifiedDate BETWEEN TO_DATE('{START_DATE}', 'YYYY-MM-DD') AND TO_DATE('{END_DATE}', 'YYYY-MM-DD')
    """
    df_bills = execute_suiteql(vendor_bill_query)
    if df_bills.empty:
        print(class="hl-string">"No vendor bills found for the specified date range. Exiting.")
        return
    
    bill_ids = class="hl-string">','.join(df_bills[class="hl-string">'TransactionId'].astype(str).tolist())
    print(fclass="hl-string">"Found {len(df_bills)} vendor bills.")

    class=class="hl-string">"hl-comment"># 2. Fetch System Notes for status changes
    print(class="hl-string">"\n--- Step 2: Fetching System Notes for status changes ---")
    system_notes_query = fclass="hl-string">"""
        SELECT
            transactionId,
            field,
            newValue,
            oldValue,
            date as EventTime
        FROM
            SystemNote
        WHERE
            transactionId IN ({bill_ids})
            AND field IN ('transaction.approvalstatus', 'transaction.status')
    """
    df_notes = execute_suiteql(system_notes_query)
    print(fclass="hl-string">"Found {len(df_notes)} relevant system notes.")

    class=class="hl-string">"hl-comment"># 3. Fetch PO Links
    print(class="hl-string">"\n--- Step 3: Fetching Purchase Order Links ---")
    po_link_query = fclass="hl-string">"""
        SELECT DISTINCT
            vb.ID as BillId,
            po.tranId as PurchaseOrderNumber
        FROM
            Transaction AS vb
            JOIN TransactionLine AS vbl ON vb.ID = vbl.Transaction
            JOIN Transaction AS po ON vbl.purchaseOrder = po.ID
        WHERE
            vb.ID IN ({bill_ids})
    """
    df_po = execute_suiteql(po_link_query)
    df_po.rename(columns={class="hl-string">'BillId': class="hl-string">'TransactionId'}, inplace=True)
    print(fclass="hl-string">"Found {len(df_po)} PO links.")

    class=class="hl-string">"hl-comment"># 4. Fetch Payments
    print(class="hl-string">"\n--- Step 4: Fetching Payment Information ---")
    payment_query = fclass="hl-string">"""
        SELECT
            link.prevtranid AS BillId,
            pymt.tranDate AS PaymentDate,
            pymt.ID AS PaymentId
        FROM
            NextTransactionLineLink AS link
            JOIN Transaction AS pymt ON link.nexttranid = pymt.ID
        WHERE
            link.prevtranid IN ({bill_ids})
            AND pymt.type = 'VendPymt'
    """
    df_payments = execute_suiteql(payment_query)
    df_payments.rename(columns={class="hl-string">'BillId': class="hl-string">'TransactionId'}, inplace=True)
    print(fclass="hl-string">"Found {len(df_payments)} payment applications.")

    class=class="hl-string">"hl-comment"># 5. Fetch Credit Memo Applications
    print(class="hl-string">"\n--- Step 5: Fetching Credit Memo Applications ---")
    credit_query = fclass="hl-string">"""
        SELECT
            link.prevtranid AS BillId,
            credit.tranDate AS CreditApplyDate
        FROM
            NextTransactionLineLink AS link
            JOIN Transaction AS credit ON link.nexttranid = credit.ID
        WHERE
            link.prevtranid IN ({bill_ids})
            AND credit.type = 'VendCred'
    """
    df_credits = execute_suiteql(credit_query)
    df_credits.rename(columns={class="hl-string">'BillId': class="hl-string">'TransactionId'}, inplace=True)
    print(fclass="hl-string">"Found {len(df_credits)} credit memo applications.")

    class=class="hl-string">"hl-comment"># --- Event Log Generation ---
    print(class="hl-string">"\n--- Step 6: Generating Event Log ---")
    event_log = []
    source_system = class="hl-string">"NetSuite SuiteTalk API"

    for _, bill in df_bills.iterrows():
        base_event = {
            class="hl-string">'Invoice': bill[class="hl-string">'Invoice'],
            class="hl-string">'SourceSystem': source_system,
            class="hl-string">'LastDataUpdate': bill[class="hl-string">'LastDataUpdate'],
            class="hl-string">'VendorName': bill[class="hl-string">'VendorName'],
            class="hl-string">'InvoiceAmount': bill[class="hl-string">'InvoiceAmount'],
            class="hl-string">'InvoiceDueDate': bill[class="hl-string">'InvoiceDueDate'],
            class="hl-string">'ProcessorUser': bill[class="hl-string">'ProcessorUser'],
            class="hl-string">'Approver': None, class=class="hl-string">"hl-comment"># Placeholder, can be enriched from workflow data if available
        }

        po_info = df_po[df_po[class="hl-string">'TransactionId'] == bill[class="hl-string">'TransactionId']]
        base_event[class="hl-string">'PurchaseOrderNumber'] = po_info[class="hl-string">'PurchaseOrderNumber'].iloc[0] if not po_info.empty else None

        class=class="hl-string">"hl-comment"># Activity: Vendor Bill Created
        event_log.append({**base_event, class="hl-string">'ActivityName': class="hl-string">'Vendor Bill Created', class="hl-string">'EventTime': bill[class="hl-string">'CreatedDate']})

        class=class="hl-string">"hl-comment"># Activity: PO Matching Attempted (inferred at creation if PO exists)
        if base_event[class="hl-string">'PurchaseOrderNumber'] is not None:
            event_log.append({**base_event, class="hl-string">'ActivityName': class="hl-string">'PO Matching Attempted', class="hl-string">'EventTime': bill[class="hl-string">'CreatedDate']})

        class=class="hl-string">"hl-comment"># Activities from System Notes
        notes = df_notes[df_notes[class="hl-string">'transactionId'] == bill[class="hl-string">'TransactionId']].sort_values(class="hl-string">'EventTime')
        for _, note in notes.iterrows():
            activity = None
            if note[class="hl-string">'field'] == class="hl-string">'transaction.approvalstatus':
                if note[class="hl-string">'newValue'] == class="hl-string">'Pending Approval': activity = class="hl-string">'Approval Submitted'
                elif note[class="hl-string">'newValue'] == class="hl-string">'Approved': 
                    activity = class="hl-string">'Invoice Approved'
                    event_log.append({**base_event, class="hl-string">'ActivityName': class="hl-string">'Invoice Posted To GL', class="hl-string">'EventTime': note[class="hl-string">'EventTime']})
                elif note[class="hl-string">'newValue'] == class="hl-string">'Rejected': activity = class="hl-string">'Invoice Rejected'
                elif note[class="hl-string">'oldValue'] == class="hl-string">'Pending Approval' and note[class="hl-string">'newValue'] != class="hl-string">'Approved': activity = class="hl-string">'Invoice Re-Routed For Approval'
            
            if note[class="hl-string">'field'] == class="hl-string">'transaction.status' and note[class="hl-string">'newValue'] == class="hl-string">'Paid In Full':
                activity = class="hl-string">'Invoice Closed'

            class=class="hl-string">"hl-comment"># Logic for discrepancy is highly custom. We infer it from a move to a non-standard approval status like class="hl-string">'On Hold'.
            class=class="hl-string">"hl-comment"># This requires knowing the specific numeric ID for such a status.
            class=class="hl-string">"hl-comment"># Example: elif note[class="hl-string">'field'] == class="hl-string">'transaction.approvalstatus' and note[class="hl-string">'newValueId'] == class="hl-string">'[Your_On_Hold_Status_ID]': activity = class="hl-string">'Discrepancy Identified'

            if activity:
                event_log.append({**base_event, class="hl-string">'ActivityName': activity, class="hl-string">'EventTime': note[class="hl-string">'EventTime']})

        class=class="hl-string">"hl-comment"># Payment Activities
        payments = df_payments[df_payments[class="hl-string">'TransactionId'] == bill[class="hl-string">'TransactionId']]
        if not payments.empty:
            first_payment = payments.sort_values(class="hl-string">'PaymentDate').iloc[0]
            event_log.append({**base_event, class="hl-string">'ActivityName': class="hl-string">'Payment Scheduled', class="hl-string">'EventTime': first_payment[class="hl-string">'PaymentDate']}) class=class="hl-string">"hl-comment"># Simplified: using payment date for schedule
            event_log.append({**base_event, class="hl-string">'ActivityName': class="hl-string">'Payment Executed', class="hl-string">'EventTime': first_payment[class="hl-string">'PaymentDate']})

            class=class="hl-string">"hl-comment"># Derived Payment Events
            payment_date = pd.to_datetime(first_payment[class="hl-string">'PaymentDate'])
            due_date = pd.to_datetime(bill[class="hl-string">'InvoiceDueDate'])
            if due_date and payment_date > due_date:
                event_log.append({**base_event, class="hl-string">'ActivityName': class="hl-string">'Late Payment Identified', class="hl-string">'EventTime': first_payment[class="hl-string">'PaymentDate']})
            
            class=class="hl-string">"hl-comment"># Early payment requires discount date from terms, which needs another join. Simplified for this example.
            class=class="hl-string">"hl-comment"># If you query class="hl-string">'discountdate' from the transaction you can compare it here.
            class=class="hl-string">"hl-comment"># For example: if pd.to_datetime(bill[class="hl-string">'discountdate']) and payment_date <= pd.to_datetime(bill[class="hl-string">'discountdate']):
            class=class="hl-string">"hl-comment">#    event_log.append({**base_event, class="hl-string">'ActivityName': class="hl-string">'Early Payment Captured', class="hl-string">'EventTime': first_payment[class="hl-string">'PaymentDate']})

        class=class="hl-string">"hl-comment"># Credit Memo Activity
        credits = df_credits[df_credits[class="hl-string">'TransactionId'] == bill[class="hl-string">'TransactionId']]
        for _, credit in credits.iterrows():
            event_log.append({**base_event, class="hl-string">'ActivityName': class="hl-string">'Credit Memo Applied', class="hl-string">'EventTime': credit[class="hl-string">'CreditApplyDate']})

    class=class="hl-string">"hl-comment"># Finalize DataFrame
    df_event_log = pd.DataFrame(event_log)
    df_event_log.sort_values(by=[class="hl-string">'Invoice', class="hl-string">'EventTime'], inplace=True)
    
    class=class="hl-string">"hl-comment"># Save to CSV
    output_filename = class="hl-string">'netsuite_ap_event_log.csv'
    df_event_log.to_csv(output_filename, index=False)
    print(fclass="hl-string">"\nExtraction complete. Event log saved to {output_filename}")

if __name__ == class="hl-string">"__main__":
    main()

`

`javascript
/**
 * @NApiVersion 2.1
 * @NScriptType ScheduledScript
 * @NModuleScope SameAccount
 */

/*

ProcessMind NetSuite AP Invoice Extraction Script

This script extracts Accounts Payable invoice processing events from NetSuite.
It queries Vendor Bill and related transaction data, formats it into a single event log, and saves it as a CSV file in the File Cabinet.

Script Parameters:
- custscript_pm_start_date: (Date) The start date for the query window (based on bill creation date).
- custscript_pm_end_date: (Date) The end date for the query window.
- custscript_pm_folder_id: (Integer) The internal ID of the File Cabinet folder to save the CSV file in.
- custscript_pm_subsidiary_id: (Integer, Optional) The internal ID of the subsidiary to filter on.

*/

define(['N/search', 'N/runtime', 'N/file', 'N/format', 'N/log'], (search, runtime, file, format, log) => {

    const execute = (context) => {
        log.debug('Script Execution Started', 'Starting AP Invoice event log extraction.');

        const script = runtime.getCurrentScript();
        const startDate = script.getParameter({ name: 'custscript_pm_start_date' });
        const endDate = script.getParameter({ name: 'custscript_pm_end_date' });
        const folderId = script.getParameter({ name: 'custscript_pm_folder_id' });
        const subsidiaryId = script.getParameter({ name: 'custscript_pm_subsidiary_id' });

        if (!startDate || !endDate || !folderId) {
            log.error('Missing Parameters', 'Start Date, End Date, and Folder ID are required.');
            return;
        }

        let allEvents = [];
        const now = new Date();

        // Helper to format date/time for CSV
        const formatDateTime = (dateStr) => {
            if (!dateStr) return '';
            try {
                const parsedDate = format.parse({ value: dateStr, type: format.Type.DATETIME });
                return format.format({ value: parsedDate, type: format.Type.DATETIMETZ });
            } catch (e) {
                return dateStr; // Fallback for simple date strings
            }
        };

        // Helper function to run a search and format results
        const runSearchAndCollectEvents = (config) => {
            log.debug('Running Search', Activity: ${config.activityName});
            const searchObj = search.create({
                type: config.type,
                filters: config.filters,
                columns: config.columns
            });

            const pagedData = searchObj.runPaged({ pageSize: 1000 });
            pagedData.pageRanges.forEach(pageRange => {
                const page = pagedData.fetch({ index: pageRange.index });
                page.data.forEach(result => {
                    allEvents.push({
                        'Invoice': result.getValue(config.mapping.Invoice) || '',
                        'ActivityName': config.activityName,
                        'EventTime': formatDateTime(result.getValue(config.mapping.EventTime)) || '',
                        'SourceSystem': 'NetSuite',
                        'LastDataUpdate': format.format({ value: now, type: format.Type.DATETIMETZ }),
                        'VendorName': result.getText(config.mapping.VendorName) || result.getValue(config.mapping.VendorName) || '',
                        'InvoiceAmount': result.getValue(config.mapping.InvoiceAmount) || '',
                        'PurchaseOrderNumber': result.getText(config.mapping.PurchaseOrderNumber) || result.getValue(config.mapping.PurchaseOrderNumber) || '',
                        'ProcessorUser': result.getText(config.mapping.ProcessorUser) || '',
                        'Approver': result.getText(config.mapping.Approver) || '',
                        'InvoiceDueDate': result.getValue(config.mapping.InvoiceDueDate) || ''
                    });
                });
            });
            log.debug('Search Complete', Found ${allEvents.length} total events so far.);
        };

        // Common filters
        let baseBillFilters = [
            ['mainline', 'is', 'T'], 'AND',
            ['type', 'anyof', 'VendBill'], 'AND',
            ['datecreated', 'within', startDate, endDate]
        ];
        if (subsidiaryId) {
            baseBillFilters.push('AND', ['subsidiary', 'anyof', subsidiaryId]);
        }

        // --- Define Search Configurations for each Activity ---

        const searchConfigs = [
            // 1. Vendor Bill Created
            {
                activityName: 'Vendor Bill Created',
                type: 'vendorbill',
                filters: baseBillFilters,
                columns: [
                    search.createColumn({ name: 'tranid', label: 'Invoice' }),
                    search.createColumn({ name: 'datecreated', label: 'EventTime' }),
                    search.createColumn({ name: 'entity', label: 'VendorName' }),
                    search.createColumn({ name: 'total', label: 'InvoiceAmount' }),
                    search.createColumn({ name: 'createdby', label: 'ProcessorUser' }),
                    search.createColumn({ name: 'duedate', label: 'InvoiceDueDate' })
                ],
                mapping: { Invoice: 'tranid', EventTime: 'datecreated', VendorName: 'entity', InvoiceAmount: 'total', ProcessorUser: 'createdby', InvoiceDueDate: 'duedate' }
            },
            // 2. PO Matching Attempted (Inferred from System Notes on first PO application)
            {
                activityName: 'PO Matching Attempted',
                type: 'vendorbill',
                filters: baseBillFilters.concat(['AND', ['systemnotes.field', 'is', 'appliedtotransaction'], 'AND', ['systemnotes.newvalue', 'contains', 'Purchase Order']]),
                columns: [
                    search.createColumn({ name: 'tranid', label: 'Invoice' }),
                    search.createColumn({ name: 'date', join: 'systemNotes', sort: search.Sort.ASC, label: 'EventTime' }),
                    search.createColumn({ name: 'entity', label: 'VendorName' }),
                    search.createColumn({ name: 'total', label: 'InvoiceAmount' }),
                    search.createColumn({ name: 'createdby', label: 'ProcessorUser' }),
                    search.createColumn({ name: 'duedate', label: 'InvoiceDueDate' }),
                    search.createColumn({ name: 'appliedtotransaction', label: 'PurchaseOrderNumber' })
                ],
                mapping: { Invoice: 'tranid', EventTime: search.createColumn({name: 'date', join: 'systemNotes'}), VendorName: 'entity', InvoiceAmount: 'total', ProcessorUser: 'createdby', InvoiceDueDate: 'duedate', PurchaseOrderNumber: 'appliedtotransaction' }
            },
            // 3. Discrepancy Identified (Uses a placeholder for custom status, e.g., 'On Hold')
            {
                activityName: 'Discrepancy Identified',
                type: 'vendorbill',
                filters: baseBillFilters.concat(['AND', ['systemnotes.field', 'is', 'approvalstatus'], 'AND', ['systemnotes.newvalue', 'is', '[On Hold]']]), // Placeholder: Replace '[On Hold]' with your actual status text
                columns: [
                    search.createColumn({ name: 'tranid', label: 'Invoice' }),
                    search.createColumn({ name: 'date', join: 'systemNotes', label: 'EventTime' }),
                    search.createColumn({ name: 'entity', label: 'VendorName' }),
                    search.createColumn({ name: 'total', label: 'InvoiceAmount' }),
                    search.createColumn({ name: 'name', join: 'systemNotes', label: 'ProcessorUser' }),
                    search.createColumn({ name: 'duedate', label: 'InvoiceDueDate' })
                ],
                mapping: { Invoice: 'tranid', EventTime: search.createColumn({name: 'date', join: 'systemNotes'}), VendorName: 'entity', InvoiceAmount: 'total', ProcessorUser: search.createColumn({name: 'name', join: 'systemNotes'}), InvoiceDueDate: 'duedate' }
            },
            // 4. Approval Submitted & 5. Invoice Re-Routed For Approval
            {
                activityName: 'Approval Submitted', // This will capture initial and subsequent submissions
                type: 'vendorbill',
                filters: baseBillFilters.concat(['AND', ['systemnotes.field', 'is', 'approvalstatus'], 'AND', ['systemnotes.newvalue', 'is', 'Pending Approval']]),
                columns: [
                    search.createColumn({ name: 'tranid', label: 'Invoice' }),
                    search.createColumn({ name: 'date', join: 'systemNotes', label: 'EventTime' }),
                    search.createColumn({ name: 'entity', label: 'VendorName' }),
                    search.createColumn({ name: 'total', label: 'InvoiceAmount' }),
                    search.createColumn({ name: 'name', join: 'systemNotes', label: 'ProcessorUser' }),
                    search.createColumn({ name: 'duedate', label: 'InvoiceDueDate' })
                ],
                mapping: { Invoice: 'tranid', EventTime: search.createColumn({name: 'date', join: 'systemNotes'}), VendorName: 'entity', InvoiceAmount: 'total', ProcessorUser: search.createColumn({name: 'name', join: 'systemNotes'}), InvoiceDueDate: 'duedate' }
            },
            // 6. Invoice Approved & 8. Invoice Posted to GL
            {
                activityName: 'Invoice Approved', // Approval event often coincides with posting
                type: 'vendorbill',
                filters: baseBillFilters.concat(['AND', ['systemnotes.field', 'is', 'approvalstatus'], 'AND', ['systemnotes.newvalue', 'is', 'Approved']]),
                columns: [
                    search.createColumn({ name: 'tranid', label: 'Invoice' }),
                    search.createColumn({ name: 'date', join: 'systemNotes', label: 'EventTime' }),
                    search.createColumn({ name: 'entity', label: 'VendorName' }),
                    search.createColumn({ name: 'total', label: 'InvoiceAmount' }),
                    search.createColumn({ name: 'name', join: 'systemNotes', label: 'Approver' }),
                    search.createColumn({ name: 'duedate', label: 'InvoiceDueDate' })
                ],
                mapping: { Invoice: 'tranid', EventTime: search.createColumn({name: 'date', join: 'systemNotes'}), VendorName: 'entity', InvoiceAmount: 'total', Approver: search.createColumn({name: 'name', join: 'systemNotes'}), InvoiceDueDate: 'duedate' }
            },
            // 7. Invoice Rejected
            {
                activityName: 'Invoice Rejected',
                type: 'vendorbill',
                filters: baseBillFilters.concat(['AND', ['systemnotes.field', 'is', 'approvalstatus'], 'AND', ['systemnotes.newvalue', 'is', 'Rejected']]),
                columns: [
                    search.createColumn({ name: 'tranid', label: 'Invoice' }),
                    search.createColumn({ name: 'date', join: 'systemNotes', label: 'EventTime' }),
                    search.createColumn({ name: 'entity', label: 'VendorName' }),
                    search.createColumn({ name: 'total', label: 'InvoiceAmount' }),
                    search.createColumn({ name: 'name', join: 'systemNotes', label: 'Approver' }),
                    search.createColumn({ name: 'duedate', label: 'InvoiceDueDate' })
                ],
                mapping: { Invoice: 'tranid', EventTime: search.createColumn({name: 'date', join: 'systemNotes'}), VendorName: 'entity', InvoiceAmount: 'total', Approver: search.createColumn({name: 'name', join: 'systemNotes'}), InvoiceDueDate: 'duedate' }
            },
            // 9. Payment Scheduled
            {
                activityName: 'Payment Scheduled',
                type: 'vendorpayment',
                filters: [['mainline', 'is', 'T'], 'AND', ['type', 'anyof', 'VendPymt'], 'AND', ['appliedtotransaction.type', 'anyof', 'VendBill'], 'AND', ['appliedToTransaction.datecreated', 'within', startDate, endDate]],
                columns: [
                    search.createColumn({ name: 'tranid', join: 'appliedToTransaction', label: 'Invoice' }),
                    search.createColumn({ name: 'datecreated', label: 'EventTime' }),
                    search.createColumn({ name: 'entity', label: 'VendorName' }),
                    search.createColumn({ name: 'total', join: 'appliedToTransaction', label: 'InvoiceAmount' }),
                    search.createColumn({ name: 'createdby', label: 'ProcessorUser' }),
                    search.createColumn({ name: 'duedate', join: 'appliedToTransaction', label: 'InvoiceDueDate' })
                ],
                mapping: { Invoice: search.createColumn({name: 'tranid', join: 'appliedToTransaction'}), EventTime: 'datecreated', VendorName: 'entity', InvoiceAmount: search.createColumn({name: 'total', join: 'appliedToTransaction'}), ProcessorUser: 'createdby', InvoiceDueDate: search.createColumn({name: 'duedate', join: 'appliedToTransaction'}) }
            },
            // 10. Payment Executed
            {
                activityName: 'Payment Executed',
                type: 'vendorbill',
                filters: baseBillFilters.concat(['AND', ['payingtransaction.trandate', 'isnotempty', '']]),
                columns: [
                    search.createColumn({ name: 'tranid', label: 'Invoice' }),
                    search.createColumn({ name: 'trandate', join: 'payingTransaction', label: 'EventTime' }),
                    search.createColumn({ name: 'entity', label: 'VendorName' }),
                    search.createColumn({ name: 'total', label: 'InvoiceAmount' }),
                    search.createColumn({ name: 'createdby', join: 'payingTransaction', label: 'ProcessorUser' }),
                    search.createColumn({ name: 'duedate', label: 'InvoiceDueDate' })
                ],
                mapping: { Invoice: 'tranid', EventTime: search.createColumn({name: 'trandate', join: 'payingTransaction'}), VendorName: 'entity', InvoiceAmount: 'total', ProcessorUser: search.createColumn({name: 'createdby', join: 'payingTransaction'}), InvoiceDueDate: 'duedate' }
            },
            // 11. Invoice Closed
            {
                activityName: 'Invoice Closed',
                type: 'vendorbill',
                filters: baseBillFilters.concat(['AND', ['systemnotes.field', 'is', 'Status'], 'AND', ['systemnotes.newvalue', 'is', 'Vendor Bill : Paid in Full']]),
                columns: [
                    search.createColumn({ name: 'tranid', label: 'Invoice' }),
                    search.createColumn({ name: 'date', join: 'systemNotes', label: 'EventTime' }),
                    search.createColumn({ name: 'entity', label: 'VendorName' }),
                    search.createColumn({ name: 'total', label: 'InvoiceAmount' }),
                    search.createColumn({ name: 'name', join: 'systemNotes', label: 'ProcessorUser' }),
                    search.createColumn({ name: 'duedate', label: 'InvoiceDueDate' })
                ],
                mapping: { Invoice: 'tranid', EventTime: search.createColumn({name: 'date', join: 'systemNotes'}), VendorName: 'entity', InvoiceAmount: 'total', ProcessorUser: search.createColumn({name: 'name', join: 'systemNotes'}), InvoiceDueDate: 'duedate' }
            },
            // 12. Early Payment Captured
            {
                activityName: 'Early Payment Captured',
                type: 'vendorbill',
                filters: baseBillFilters.concat(['AND', ['payingtransaction.trandate', 'isnotempty', ''], 'AND', ['formuladate: {payingtransaction.trandate} <= {discountdate}', 'is', '1']]),
                columns: [
                    search.createColumn({ name: 'tranid', label: 'Invoice' }),
                    search.createColumn({ name: 'trandate', join: 'payingTransaction', label: 'EventTime' }),
                    search.createColumn({ name: 'entity', label: 'VendorName' }),
                    search.createColumn({ name: 'total', label: 'InvoiceAmount' }),
                    search.createColumn({ name: 'duedate', label: 'InvoiceDueDate' })
                ],
                mapping: { Invoice: 'tranid', EventTime: search.createColumn({name: 'trandate', join: 'payingTransaction'}), VendorName: 'entity', InvoiceAmount: 'total', InvoiceDueDate: 'duedate' }
            },
            // 13. Late Payment Identified
            {
                activityName: 'Late Payment Identified',
                type: 'vendorbill',
                filters: baseBillFilters.concat(['AND', ['payingtransaction.trandate', 'isnotempty', ''], 'AND', ['formuladate: {payingtransaction.trandate} > {duedate}', 'is', '1']]),
                columns: [
                    search.createColumn({ name: 'tranid', label: 'Invoice' }),
                    search.createColumn({ name: 'trandate', join: 'payingTransaction', label: 'EventTime' }),
                    search.createColumn({ name: 'entity', label: 'VendorName' }),
                    search.createColumn({ name: 'total', label: 'InvoiceAmount' }),
                    search.createColumn({ name: 'duedate', label: 'InvoiceDueDate' })
                ],
                mapping: { Invoice: 'tranid', EventTime: search.createColumn({name: 'trandate', join: 'payingTransaction'}), VendorName: 'entity', InvoiceAmount: 'total', InvoiceDueDate: 'duedate' }
            },
            // 14. Credit Memo Applied
            {
                activityName: 'Credit Memo Applied',
                type: 'vendorbill',
                filters: baseBillFilters.concat(['AND', ['applyingtransaction.type', 'anyof', 'VendCred']]),
                columns: [
                    search.createColumn({ name: 'tranid', label: 'Invoice' }),
                    search.createColumn({ name: 'trandate', join: 'applyingTransaction', label: 'EventTime' }),
                    search.createColumn({ name: 'entity', label: 'VendorName' }),
                    search.createColumn({ name: 'total', label: 'InvoiceAmount' }),
                    search.createColumn({ name: 'createdby', join: 'applyingTransaction', label: 'ProcessorUser' }),
                    search.createColumn({ name: 'duedate', label: 'InvoiceDueDate' })
                ],
                mapping: { Invoice: 'tranid', EventTime: search.createColumn({name: 'trandate', join: 'applyingTransaction'}), VendorName: 'entity', InvoiceAmount: 'total', ProcessorUser: search.createColumn({name: 'createdby', join: 'applyingTransaction'}), InvoiceDueDate: 'duedate' }
            },
        ];

        // Execute all searches
        searchConfigs.forEach(config => {
            try {
                runSearchAndCollectEvents(config);
            } catch (e) {
                log.error(Search Failed for ${config.activityName}, e);
            }
        });

        // Convert to CSV and save
        if (allEvents.length > 0) {
            const headers = Object.keys(allEvents[0]);
            let csvContent = headers.join(',') + '\n';
            allEvents.forEach(event => {
                const row = headers.map(header => {
                    let value = event[header] ? event[header].toString() : '';
                    // Escape commas and quotes
                    if (value.includes(',') || value.includes('"') || value.includes('\n')) {
                        value = '"' + value.replace(/"/g, '""') + '"';
                    }
                    return value;
                });
                csvContent += row.join(',') + '\n';
            });

            const fileName = ProcessMind_AP_EventLog_${new Date().toISOString().slice(0, 10)}.csv;
            const csvFile = file.create({
                name: fileName,
                fileType: file.Type.CSV,
                contents: csvContent,
                folder: folderId
            });
            const fileId = csvFile.save();
            log.audit('File Created', Successfully created file ${fileName} with ID ${fileId} in folder ${folderId}.);
        } else {
            log.audit('No Events Found', 'No events found for the specified criteria.');
        }

        log.debug('Script Execution Finished', Processed a total of ${allEvents.length} events.);
    };

    return { execute };
});
`