Modèle de données : De l'Achat au Paiement - Commande d'achat

/*
This is a conceptual SQL query representing the logic to be built in the SAP Ariba Analytical Reporting UI.
The final output is a single CSV file that is later transformed into an event log.
The Ariba UI does not use SQL directly; this query illustrates the required data structure and joins.
*/

-- Activity: Purchase Requisition Created
SELECT
  po.PO_NUMBER AS "PurchaseOrderNumber",
  'Purchase Requisition Created' AS "ActivityName",
  pr.CREATION_TIME AS "EventTime",
  pr_creator.USER_NAME AS "UserName",
  dept.DEPARTMENT_NAME AS "DepartmentName",
  vendor.VENDOR_NAME AS "VendorName",
  po.TOTAL_AMOUNT AS "PurchaseOrderAmount",
  po.REQUESTED_DELIVERY_DATE AS "RequestedDeliveryDate",
  NULL AS "GoodsReceiptDate"
FROM [Ariba.POHeader] po
LEFT JOIN [Ariba.PRHeader] pr ON po.PR_ID = pr.PR_ID
LEFT JOIN [Ariba.Users] pr_creator ON pr.CREATED_BY_USER_ID = pr_creator.USER_ID
LEFT JOIN [Ariba.Departments] dept ON po.DEPARTMENT_ID = dept.DEPT_ID
LEFT JOIN [Ariba.Vendors] vendor ON po.VENDOR_ID = vendor.VENDOR_ID
WHERE po.CREATION_TIME BETWEEN '[START_DATE]' AND '[END_DATE]' AND po.COMPANY_CODE IN ('[Your Company Code]')

UNION ALL

-- Activity: Purchase Requisition Approved
SELECT
  po.PO_NUMBER AS "PurchaseOrderNumber",
  'Purchase Requisition Approved' AS "ActivityName",
  pr.APPROVAL_TIME AS "EventTime",
  pr_approver.USER_NAME AS "UserName",
  dept.DEPARTMENT_NAME AS "DepartmentName",
  vendor.VENDOR_NAME AS "VendorName",
  po.TOTAL_AMOUNT AS "PurchaseOrderAmount",
  po.REQUESTED_DELIVERY_DATE AS "RequestedDeliveryDate",
  NULL AS "GoodsReceiptDate"
FROM [Ariba.POHeader] po
LEFT JOIN [Ariba.PRHeader] pr ON po.PR_ID = pr.PR_ID
LEFT JOIN [Ariba.Users] pr_approver ON pr.APPROVED_BY_USER_ID = pr_approver.USER_ID
LEFT JOIN [Ariba.Departments] dept ON po.DEPARTMENT_ID = dept.DEPT_ID
LEFT JOIN [Ariba.Vendors] vendor ON po.VENDOR_ID = vendor.VENDOR_ID
WHERE po.CREATION_TIME BETWEEN '[START_DATE]' AND '[END_DATE]' AND po.COMPANY_CODE IN ('[Your Company Code]') AND pr.APPROVAL_TIME IS NOT NULL

UNION ALL

-- Activity: Purchase Order Created
SELECT
  po.PO_NUMBER AS "PurchaseOrderNumber",
  'Purchase Order Created' AS "ActivityName",
  po.CREATION_TIME AS "EventTime",
  po_creator.USER_NAME AS "UserName",
  dept.DEPARTMENT_NAME AS "DepartmentName",
  vendor.VENDOR_NAME AS "VendorName",
  po.TOTAL_AMOUNT AS "PurchaseOrderAmount",
  po.REQUESTED_DELIVERY_DATE AS "RequestedDeliveryDate",
  NULL AS "GoodsReceiptDate"
FROM [Ariba.POHeader] po
LEFT JOIN [Ariba.Users] po_creator ON po.CREATED_BY_USER_ID = po_creator.USER_ID
LEFT JOIN [Ariba.Departments] dept ON po.DEPARTMENT_ID = dept.DEPT_ID
LEFT JOIN [Ariba.Vendors] vendor ON po.VENDOR_ID = vendor.VENDOR_ID
WHERE po.CREATION_TIME BETWEEN '[START_DATE]' AND '[END_DATE]' AND po.COMPANY_CODE IN ('[Your Company Code]')

UNION ALL

-- Activity: Purchase Order Approved
SELECT
  po.PO_NUMBER AS "PurchaseOrderNumber",
  'Purchase Order Approved' AS "ActivityName",
  po.APPROVAL_TIME AS "EventTime",
  po_approver.USER_NAME AS "UserName",
  dept.DEPARTMENT_NAME AS "DepartmentName",
  vendor.VENDOR_NAME AS "VendorName",
  po.TOTAL_AMOUNT AS "PurchaseOrderAmount",
  po.REQUESTED_DELIVERY_DATE AS "RequestedDeliveryDate",
  NULL AS "GoodsReceiptDate"
FROM [Ariba.POHeader] po
LEFT JOIN [Ariba.Users] po_approver ON po.APPROVED_BY_USER_ID = po_approver.USER_ID
LEFT JOIN [Ariba.Departments] dept ON po.DEPARTMENT_ID = dept.DEPT_ID
LEFT JOIN [Ariba.Vendors] vendor ON po.VENDOR_ID = vendor.VENDOR_ID
WHERE po.CREATION_TIME BETWEEN '[START_DATE]' AND '[END_DATE]' AND po.COMPANY_CODE IN ('[Your Company Code]') AND po.APPROVAL_TIME IS NOT NULL

UNION ALL

-- Activity: Purchase Order Changed
SELECT
  po.PO_NUMBER AS "PurchaseOrderNumber",
  'Purchase Order Changed' AS "ActivityName",
  ver.VERSION_CREATION_TIME AS "EventTime",
  changer.USER_NAME AS "UserName",
  dept.DEPARTMENT_NAME AS "DepartmentName",
  vendor.VENDOR_NAME AS "VendorName",
  po.TOTAL_AMOUNT AS "PurchaseOrderAmount",
  po.REQUESTED_DELIVERY_DATE AS "RequestedDeliveryDate",
  NULL AS "GoodsReceiptDate"
FROM [Ariba.POHeader] po
INNER JOIN [Ariba.POVersions] ver ON po.PO_ID = ver.PO_ID AND ver.VERSION_NUMBER > 1
LEFT JOIN [Ariba.Users] changer ON ver.CHANGED_BY_USER_ID = changer.USER_ID
LEFT JOIN [Ariba.Departments] dept ON po.DEPARTMENT_ID = dept.DEPT_ID
LEFT JOIN [Ariba.Vendors] vendor ON po.VENDOR_ID = vendor.VENDOR_ID
WHERE po.CREATION_TIME BETWEEN '[START_DATE]' AND '[END_DATE]' AND po.COMPANY_CODE IN ('[Your Company Code]')

UNION ALL

-- Activity: Purchase Order Sent To Vendor
SELECT
  po.PO_NUMBER AS "PurchaseOrderNumber",
  'Purchase Order Sent To Vendor' AS "ActivityName",
  po.ORDERED_TIME AS "EventTime",
  sender.USER_NAME AS "UserName",
  dept.DEPARTMENT_NAME AS "DepartmentName",
  vendor.VENDOR_NAME AS "VendorName",
  po.TOTAL_AMOUNT AS "PurchaseOrderAmount",
  po.REQUESTED_DELIVERY_DATE AS "RequestedDeliveryDate",
  NULL AS "GoodsReceiptDate"
FROM [Ariba.POHeader] po
LEFT JOIN [Ariba.Users] sender ON po.ORDERED_BY_USER_ID = sender.USER_ID
LEFT JOIN [Ariba.Departments] dept ON po.DEPARTMENT_ID = dept.DEPT_ID
LEFT JOIN [Ariba.Vendors] vendor ON po.VENDOR_ID = vendor.VENDOR_ID
WHERE po.CREATION_TIME BETWEEN '[START_DATE]' AND '[END_DATE]' AND po.COMPANY_CODE IN ('[Your Company Code]') AND po.ORDERED_TIME IS NOT NULL

UNION ALL

-- Activity: Vendor Confirmed Purchase Order
SELECT
  po.PO_NUMBER AS "PurchaseOrderNumber",
  'Vendor Confirmed Purchase Order' AS "ActivityName",
  oc.CONFIRMATION_TIME AS "EventTime",
  'System/Vendor' AS "UserName",
  dept.DEPARTMENT_NAME AS "DepartmentName",
  vendor.VENDOR_NAME AS "VendorName",
  po.TOTAL_AMOUNT AS "PurchaseOrderAmount",
  po.REQUESTED_DELIVERY_DATE AS "RequestedDeliveryDate",
  NULL AS "GoodsReceiptDate"
FROM [Ariba.POHeader] po
INNER JOIN [Ariba.OrderConfirmations] oc ON po.PO_ID = oc.PO_ID
LEFT JOIN [Ariba.Departments] dept ON po.DEPARTMENT_ID = dept.DEPT_ID
LEFT JOIN [Ariba.Vendors] vendor ON po.VENDOR_ID = vendor.VENDOR_ID
WHERE po.CREATION_TIME BETWEEN '[START_DATE]' AND '[END_DATE]' AND po.COMPANY_CODE IN ('[Your Company Code]') AND oc.CONFIRMATION_TIME IS NOT NULL

UNION ALL

-- Activity: Advance Ship Notice Received
SELECT
  po.PO_NUMBER AS "PurchaseOrderNumber",
  'Advance Ship Notice Received' AS "ActivityName",
  asn.CREATION_TIME AS "EventTime",
  'System/Vendor' AS "UserName",
  dept.DEPARTMENT_NAME AS "DepartmentName",
  vendor.VENDOR_NAME AS "VendorName",
  po.TOTAL_AMOUNT AS "PurchaseOrderAmount",
  po.REQUESTED_DELIVERY_DATE AS "RequestedDeliveryDate",
  NULL AS "GoodsReceiptDate"
FROM [Ariba.POHeader] po
INNER JOIN [Ariba.ASNs] asn ON po.PO_ID = asn.PO_ID
LEFT JOIN [Ariba.Departments] dept ON po.DEPARTMENT_ID = dept.DEPT_ID
LEFT JOIN [Ariba.Vendors] vendor ON po.VENDOR_ID = vendor.VENDOR_ID
WHERE po.CREATION_TIME BETWEEN '[START_DATE]' AND '[END_DATE]' AND po.COMPANY_CODE IN ('[Your Company Code]') AND asn.CREATION_TIME IS NOT NULL

UNION ALL

-- Activity: Goods Receipt Posted
SELECT
  po.PO_NUMBER AS "PurchaseOrderNumber",
  'Goods Receipt Posted' AS "ActivityName",
  rcpt.RECEIPT_TIME AS "EventTime",
  receiver.USER_NAME AS "UserName",
  dept.DEPARTMENT_NAME AS "DepartmentName",
  vendor.VENDOR_NAME AS "VendorName",
  po.TOTAL_AMOUNT AS "PurchaseOrderAmount",
  po.REQUESTED_DELIVERY_DATE AS "RequestedDeliveryDate",
  rcpt.RECEIPT_TIME AS "GoodsReceiptDate"
FROM [Ariba.POHeader] po
INNER JOIN [Ariba.Receipts] rcpt ON po.PO_ID = rcpt.PO_ID
LEFT JOIN [Ariba.Users] receiver ON rcpt.CREATED_BY_USER_ID = receiver.USER_ID
LEFT JOIN [Ariba.Departments] dept ON po.DEPARTMENT_ID = dept.DEPT_ID
LEFT JOIN [Ariba.Vendors] vendor ON po.VENDOR_ID = vendor.VENDOR_ID
WHERE po.CREATION_TIME BETWEEN '[START_DATE]' AND '[END_DATE]' AND po.COMPANY_CODE IN ('[Your Company Code]') AND rcpt.RECEIPT_TYPE = 'Goods'

UNION ALL

-- Activity: Services Confirmation Entered
SELECT
  po.PO_NUMBER AS "PurchaseOrderNumber",
  'Services Confirmation Entered' AS "ActivityName",
  ss.APPROVAL_TIME AS "EventTime",
  ss_creator.USER_NAME AS "UserName",
  dept.DEPARTMENT_NAME AS "DepartmentName",
  vendor.VENDOR_NAME AS "VendorName",
  po.TOTAL_AMOUNT AS "PurchaseOrderAmount",
  po.REQUESTED_DELIVERY_DATE AS "RequestedDeliveryDate",
  ss.APPROVAL_TIME AS "GoodsReceiptDate"
FROM [Ariba.POHeader] po
INNER JOIN [Ariba.ServiceSheets] ss ON po.PO_ID = ss.PO_ID
LEFT JOIN [Ariba.Users] ss_creator ON ss.CREATED_BY_USER_ID = ss_creator.USER_ID
LEFT JOIN [Ariba.Departments] dept ON po.DEPARTMENT_ID = dept.DEPT_ID
LEFT JOIN [Ariba.Vendors] vendor ON po.VENDOR_ID = vendor.VENDOR_ID
WHERE po.CREATION_TIME BETWEEN '[START_DATE]' AND '[END_DATE]' AND po.COMPANY_CODE IN ('[Your Company Code]') AND ss.APPROVAL_TIME IS NOT NULL

UNION ALL

-- Activity: Goods Returned To Vendor
SELECT
  po.PO_NUMBER AS "PurchaseOrderNumber",
  'Goods Returned To Vendor' AS "ActivityName",
  rcpt.RECEIPT_TIME AS "EventTime",
  returner.USER_NAME AS "UserName",
  dept.DEPARTMENT_NAME AS "DepartmentName",
  vendor.VENDOR_NAME AS "VendorName",
  po.TOTAL_AMOUNT AS "PurchaseOrderAmount",
  po.REQUESTED_DELIVERY_DATE AS "RequestedDeliveryDate",
  NULL AS "GoodsReceiptDate"
FROM [Ariba.POHeader] po
INNER JOIN [Ariba.Receipts] rcpt ON po.PO_ID = rcpt.PO_ID AND rcpt.RECEIPT_TYPE = 'Return'
LEFT JOIN [Ariba.Users] returner ON rcpt.CREATED_BY_USER_ID = returner.USER_ID
LEFT JOIN [Ariba.Departments] dept ON po.DEPARTMENT_ID = dept.DEPT_ID
LEFT JOIN [Ariba.Vendors] vendor ON po.VENDOR_ID = vendor.VENDOR_ID
WHERE po.CREATION_TIME BETWEEN '[START_DATE]' AND '[END_DATE]' AND po.COMPANY_CODE IN ('[Your Company Code]')

UNION ALL

-- Activity: Invoice Received Against PO
SELECT
  po.PO_NUMBER AS "PurchaseOrderNumber",
  'Invoice Received Against PO' AS "ActivityName",
  inv.CREATION_TIME AS "EventTime",
  'System/AP' AS "UserName",
  dept.DEPARTMENT_NAME AS "DepartmentName",
  vendor.VENDOR_NAME AS "VendorName",
  po.TOTAL_AMOUNT AS "PurchaseOrderAmount",
  po.REQUESTED_DELIVERY_DATE AS "RequestedDeliveryDate",
  NULL AS "GoodsReceiptDate"
FROM [Ariba.POHeader] po
INNER JOIN [Ariba.Invoices] inv ON po.PO_ID = inv.PO_ID
LEFT JOIN [Ariba.Departments] dept ON po.DEPARTMENT_ID = dept.DEPT_ID
LEFT JOIN [Ariba.Vendors] vendor ON po.VENDOR_ID = vendor.VENDOR_ID
WHERE po.CREATION_TIME BETWEEN '[START_DATE]' AND '[END_DATE]' AND po.COMPANY_CODE IN ('[Your Company Code]')

UNION ALL

-- Activity: Purchase Order Completed
SELECT
  po.PO_NUMBER AS "PurchaseOrderNumber",
  'Purchase Order Completed' AS "ActivityName",
  po.COMPLETED_TIME AS "EventTime",
  'System' AS "UserName",
  dept.DEPARTMENT_NAME AS "DepartmentName",
  vendor.VENDOR_NAME AS "VendorName",
  po.TOTAL_AMOUNT AS "PurchaseOrderAmount",
  po.REQUESTED_DELIVERY_DATE AS "RequestedDeliveryDate",
  NULL AS "GoodsReceiptDate"
FROM [Ariba.POHeader] po
LEFT JOIN [Ariba.Departments] dept ON po.DEPARTMENT_ID = dept.DEPT_ID
LEFT JOIN [Ariba.Vendors] vendor ON po.VENDOR_ID = vendor.VENDOR_ID
WHERE po.CREATION_TIME BETWEEN '[START_DATE]' AND '[END_DATE]' AND po.COMPANY_CODE IN ('[Your Company Code]') AND po.STATUS = 'Completed'

UNION ALL

-- Activity: Purchase Order Cancelled
SELECT
  po.PO_NUMBER AS "PurchaseOrderNumber",
  'Purchase Order Cancelled' AS "ActivityName",
  po.CANCELLED_TIME AS "EventTime",
  canceller.USER_NAME AS "UserName",
  dept.DEPARTMENT_NAME AS "DepartmentName",
  vendor.VENDOR_NAME AS "VendorName",
  po.TOTAL_AMOUNT AS "PurchaseOrderAmount",
  po.REQUESTED_DELIVERY_DATE AS "RequestedDeliveryDate",
  NULL AS "GoodsReceiptDate"
FROM [Ariba.POHeader] po
LEFT JOIN [Ariba.Users] canceller ON po.CANCELLED_BY_USER_ID = canceller.USER_ID
LEFT JOIN [Ariba.Departments] dept ON po.DEPARTMENT_ID = dept.DEPT_ID
LEFT JOIN [Ariba.Vendors] vendor ON po.VENDOR_ID = vendor.VENDOR_ID
WHERE po.CREATION_TIME BETWEEN '[START_DATE]' AND '[END_DATE]' AND po.COMPANY_CODE IN ('[Your Company Code]') AND po.STATUS = 'Cancelled'

import requests
import pandas as pd
import json
import time
import gzip
import io

class=class="hl-string">"hl-comment"># --- Configuration Settings --- #
class=class="hl-string">"hl-comment"># Replace with your SAP Ariba Developer Portal application credentials
API_KEY = class="hl-string">'[Your_API_Key]'
CLIENT_ID = class="hl-string">'[Your_OAuth_Client_ID]'
CLIENT_SECRET = class="hl-string">'[Your_OAuth_Client_Secret]'

class=class="hl-string">"hl-comment"># Replace with your company's Ariba realm information
REALM = class="hl-string">'[Your_Company_Ariba_Realm]'

class=class="hl-string">"hl-comment"># Replace with the exact name of your pre-configured reporting view in Ariba
VIEW_TEMPLATE_NAME = class="hl-string">'[Your_P2P_View_Template]'

class=class="hl-string">"hl-comment"># --- API Endpoints --- #
AUTH_URL = class="hl-string">'https://api.ariba.com/v2/oauth/token'
API_BASE_URL = fclass="hl-string">'https://{REALM}.ariba.com/api/analytics-reporting-view/v1'

class=class="hl-string">"hl-comment"># --- Helper Functions --- #
def get_access_token():
    class="hl-string">"""Authenticates with Ariba and returns an access token."""
    auth_payload = {
        class="hl-string">'grant_type': class="hl-string">'client_credentials',
        class="hl-string">'client_id': CLIENT_ID,
        class="hl-string">'client_secret': CLIENT_SECRET
    }
    try:
        response = requests.post(AUTH_URL, data=auth_payload)
        response.raise_for_status()
        return response.json()[class="hl-string">'access_token']
    except requests.exceptions.RequestException as e:
        print(fclass="hl-string">"Error getting access token: {e}")
        print(fclass="hl-string">"Response body: {response.text}")
        return None

def main():
    class="hl-string">"""Main function to run the extraction process."""
    access_token = get_access_token()
    if not access_token:
        return

    headers = {
        class="hl-string">'Authorization': fclass="hl-string">'Bearer {access_token}',
        class="hl-string">'apiKey': API_KEY,
        class="hl-string">'Content-Type': class="hl-string">'application/json'
    }

    class=class="hl-string">"hl-comment"># Define the reporting job with filters
    report_job_payload = {
        class="hl-string">"viewTemplateName": VIEW_TEMPLATE_NAME,
        class="hl-string">"filters": {
            class="hl-string">"createdDateFrom": class="hl-string">"2023-01-01T00:00:00Z",
            class="hl-string">"createdDateTo": class="hl-string">"2023-12-31T23:59:59Z"
        },
        class="hl-string">"outputFormat": class="hl-string">"csv"
    }

    class=class="hl-string">"hl-comment"># 1. Submit the report generation job
    print(class="hl-string">"Submitting report job...")
    try:
        submit_response = requests.post(fclass="hl-string">'{API_BASE_URL}/jobs', headers=headers, json=report_job_payload)
        submit_response.raise_for_status()
        job_id = submit_response.json()[class="hl-string">'jobId']
        print(fclass="hl-string">"Job submitted successfully. Job ID: {job_id}")
    except requests.exceptions.RequestException as e:
        print(fclass="hl-string">"Error submitting job: {e}")
        print(fclass="hl-string">"Response body: {submit_response.text}")
        return

    class=class="hl-string">"hl-comment"># 2. Poll for job completion
    while True:
        print(class="hl-string">"Checking job status...")
        try:
            status_response = requests.get(fclass="hl-string">'{API_BASE_URL}/jobs/{job_id}', headers=headers)
            status_response.raise_for_status()
            status = status_response.json()[class="hl-string">'status']
            print(fclass="hl-string">"Current job status: {status}")
            if status == class="hl-string">'COMPLETED':
                download_url = status_response.json()[class="hl-string">'downloadUrl']
                break
            elif status in [class="hl-string">'FAILED', class="hl-string">'NO_DATA']:
                print(fclass="hl-string">"Job finished with status: {status}")
                return
            time.sleep(30)  class=class="hl-string">"hl-comment"># Wait for 30 seconds before polling again
        except requests.exceptions.RequestException as e:
            print(fclass="hl-string">"Error checking job status: {e}")
            return

    class=class="hl-string">"hl-comment"># 3. Download the report data
    print(fclass="hl-string">"Job completed. Downloading data from: {download_url}")
    try:
        download_headers = {class="hl-string">'Authorization': fclass="hl-string">'Bearer {access_token}', class="hl-string">'apiKey': API_KEY}
        data_response = requests.get(download_url, headers=download_headers)
        data_response.raise_for_status()
        class=class="hl-string">"hl-comment"># Decompress the gzipped content
        gzip_file = gzip.GzipFile(fileobj=io.BytesIO(data_response.content))
        df_raw = pd.read_csv(gzip_file)
    except requests.exceptions.RequestException as e:
        print(fclass="hl-string">"Error downloading data: {e}")
        return

    class=class="hl-string">"hl-comment"># 4. Transform data into event log
    print(class="hl-string">"Transforming data into event log format...")
    event_log = []

    class=class="hl-string">"hl-comment"># Rename columns for clarity, assuming view template field names like class="hl-string">'Purchase Order Id',
    class=class="hl-string">"hl-comment"># class="hl-string">'Requisition TimeCreated', class="hl-string">'PO ApprovedDate', etc. Adjust these to match your view template.
    class=class="hl-string">"hl-comment"># Placeholder names are used here.
    column_mapping = {
        class="hl-string">'[Purchase Order Id]': class="hl-string">'PurchaseOrderNumber',
        class="hl-string">'[Requisition TimeCreated]': class="hl-string">'pr_created_time',
        class="hl-string">'[Requisition ApprovedDate]': class="hl-string">'pr_approved_time',
        class="hl-string">'[PO TimeCreated]': class="hl-string">'po_created_time',
        class="hl-string">'[PO ApprovedDate]': class="hl-string">'po_approved_time',
        class="hl-string">'[PO LastModifiedDate]': class="hl-string">'po_changed_time',
        class="hl-string">'[PO OrderedDate]': class="hl-string">'po_sent_time',
        class="hl-string">'[PO ConfirmedDate]': class="hl-string">'po_confirmed_time',
        class="hl-string">'[ASN TimeCreated]': class="hl-string">'asn_received_time',
        class="hl-string">'[Receipt Date]': class="hl-string">'goods_receipt_time',
        class="hl-string">'[Service Sheet End Date]': class="hl-string">'service_confirmed_time',
        class="hl-string">'[Return Date]': class="hl-string">'goods_returned_time',
        class="hl-string">'[Invoice Date]': class="hl-string">'invoice_received_time',
        class="hl-string">'[PO CompletedDate]': class="hl-string">'po_completed_time',
        class="hl-string">'[PO CancelledDate]': class="hl-string">'po_cancelled_time',
        class="hl-string">'[PO Submitter]': class="hl-string">'UserName',
        class="hl-string">'[Department Name]': class="hl-string">'DepartmentName',
        class="hl-string">'[Vendor Name]': class="hl-string">'VendorName',
        class="hl-string">'[PO TotalAmount]': class="hl-string">'PurchaseOrderAmount',
        class="hl-string">'[PO DeliveryDate]': class="hl-string">'RequestedDeliveryDate',
        class="hl-string">'[Receipt Date]': class="hl-string">'GoodsReceiptDate'
    }
    df_raw.rename(columns=column_mapping, inplace=True)

    class=class="hl-string">"hl-comment"># Define activities and their corresponding timestamp columns
    activities = {
        class="hl-string">'Purchase Requisition Created': class="hl-string">'pr_created_time',
        class="hl-string">'Purchase Requisition Approved': class="hl-string">'pr_approved_time',
        class="hl-string">'Purchase Order Created': class="hl-string">'po_created_time',
        class="hl-string">'Purchase Order Approved': class="hl-string">'po_approved_time',
        class="hl-string">'Purchase Order Changed': class="hl-string">'po_changed_time',
        class="hl-string">'Purchase Order Sent To Vendor': class="hl-string">'po_sent_time',
        class="hl-string">'Vendor Confirmed Purchase Order': class="hl-string">'po_confirmed_time',
        class="hl-string">'Advance Ship Notice Received': class="hl-string">'asn_received_time',
        class="hl-string">'Goods Receipt Posted': class="hl-string">'goods_receipt_time',
        class="hl-string">'Services Confirmation Entered': class="hl-string">'service_confirmed_time',
        class="hl-string">'Goods Returned To Vendor': class="hl-string">'goods_returned_time',
        class="hl-string">'Invoice Received Against PO': class="hl-string">'invoice_received_time',
        class="hl-string">'Purchase Order Completed': class="hl-string">'po_completed_time',
        class="hl-string">'Purchase Order Cancelled': class="hl-string">'po_cancelled_time'
    }

    for index, row in df_raw.iterrows():
        base_event = {
            class="hl-string">'PurchaseOrderNumber': row.get(class="hl-string">'PurchaseOrderNumber'),
            class="hl-string">'UserName': row.get(class="hl-string">'UserName'),
            class="hl-string">'DepartmentName': row.get(class="hl-string">'DepartmentName'),
            class="hl-string">'VendorName': row.get(class="hl-string">'VendorName'),
            class="hl-string">'PurchaseOrderAmount': row.get(class="hl-string">'PurchaseOrderAmount'),
            class="hl-string">'RequestedDeliveryDate': row.get(class="hl-string">'RequestedDeliveryDate'),
            class="hl-string">'GoodsReceiptDate': row.get(class="hl-string">'GoodsReceiptDate')
        }

        for activity_name, time_col in activities.items():
            if time_col in row and pd.notna(row[time_col]):
                event = base_event.copy()
                event[class="hl-string">'ActivityName'] = activity_name
                event[class="hl-string">'EventTime'] = row[time_col]
                
                class=class="hl-string">"hl-comment"># Special handling for class="hl-string">'Purchase Order Changed'
                class=class="hl-string">"hl-comment"># This event should only be created if it's after the PO creation time
                if activity_name == class="hl-string">'Purchase Order Changed':
                    if pd.notna(row.get(class="hl-string">'po_created_time')) and pd.to_datetime(row[time_col]) > pd.to_datetime(row[class="hl-string">'po_created_time']):
                        event_log.append(event)
                else:
                    event_log.append(event)

    df_event_log = pd.DataFrame(event_log)
    df_event_log[class="hl-string">'EventTime'] = pd.to_datetime(df_event_log[class="hl-string">'EventTime'])
    df_event_log.sort_values(by=[class="hl-string">'PurchaseOrderNumber', class="hl-string">'EventTime'], inplace=True)

    class=class="hl-string">"hl-comment"># 5. Save the final event log
    output_filename = class="hl-string">'ariba_p2p_event_log.csv'
    df_event_log.to_csv(output_filename, index=False, date_format=class="hl-string">'%Y-%m-%dT%H:%M:%SZ')
    print(fclass="hl-string">"Event log successfully created and saved to {output_filename}")

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