공급망 관리 데이터 템플릿

WITH sales_orders AS (
  SELECT
    dha.order_number,
    dha.header_id,
    dha.source_doc_id,
    dha.creation_date
  FROM
    doo_headers_all dha
  WHERE
    dha.creation_date BETWEEN TO_DATE(:P_START_DATE, 'YYYY-MM-DD') AND TO_DATE(:P_END_DATE, 'YYYY-MM-DD')
    -- Optional: Add filters for specific Business Units or Order Types
    -- AND dha.org_id = [Your Organization ID]
)
-- 1. Customer Order Created
SELECT
  so.order_number AS "LogisticsOrder",
  'Customer Order Created' AS "ActivityName",
  dha.creation_date AS "EventTime",
  dha.request_ship_date AS "RequestedDeliveryDate",
  NULL AS "ActualDeliveryDate",
  mc.category_name AS "ProductCategory",
  NULL AS "SupplierName",
  NULL AS "ModeOfTransport",
  dha.status_code AS "LogisticsOrderStatus",
  dha.created_by AS "User",
  NULL AS "PurchaseOrderNumber",
  msi.item_number AS "ItemNumber"
FROM
  sales_orders so
  JOIN doo_headers_all dha ON so.header_id = dha.header_id
  JOIN doo_fulfill_lines_all dfla ON dha.header_id = dfla.header_id
  LEFT JOIN egp_system_items_b msi ON dfla.inventory_item_id = msi.inventory_item_id AND dfla.inventory_organization_id = msi.organization_id
  LEFT JOIN egp_item_cat_assign_b mca ON msi.inventory_item_id = mca.inventory_item_id
  LEFT JOIN egp_categories_tl mc ON mca.category_id = mc.category_id
WHERE mc.language = 'US'

UNION ALL

-- 2. Inventory Availability Checked
SELECT
  so.order_number AS "LogisticsOrder",
  'Inventory Availability Checked' AS "ActivityName",
  dfla.last_update_date AS "EventTime",
  dha.request_ship_date AS "RequestedDeliveryDate",
  NULL AS "ActualDeliveryDate",
  NULL AS "ProductCategory",
  NULL AS "SupplierName",
  NULL AS "ModeOfTransport",
  dha.status_code AS "LogisticsOrderStatus",
  dfla.last_updated_by AS "User",
  NULL AS "PurchaseOrderNumber",
  msi.item_number AS "ItemNumber"
FROM
  sales_orders so
  JOIN doo_headers_all dha ON so.header_id = dha.header_id
  JOIN doo_fulfill_lines_all dfla ON so.header_id = dfla.header_id
  LEFT JOIN egp_system_items_b msi ON dfla.inventory_item_id = msi.inventory_item_id AND dfla.inventory_organization_id = msi.organization_id
WHERE
  dfla.status_code = 'AWAIT_SHIP'

UNION ALL

-- 3. Purchase Requisition Created
SELECT
  so.order_number AS "LogisticsOrder",
  'Purchase Requisition Created' AS "ActivityName",
  prh.creation_date AS "EventTime",
  NULL AS "RequestedDeliveryDate",
  NULL AS "ActualDeliveryDate",
  NULL AS "ProductCategory",
  NULL AS "SupplierName",
  NULL AS "ModeOfTransport",
  prh.document_status AS "LogisticsOrderStatus",
  prh.created_by AS "User",
  NULL AS "PurchaseOrderNumber",
  prl.item_number AS "ItemNumber"
FROM
  sales_orders so
  JOIN por_requisition_lines_all prl ON so.source_doc_id = prl.doo_source_doc_id
  JOIN por_requisition_headers_all prh ON prl.requisition_header_id = prh.requisition_header_id

UNION ALL

-- 4. Purchase Order Issued
SELECT
  so.order_number AS "LogisticsOrder",
  'Purchase Order Issued' AS "ActivityName",
  pha.approved_date AS "EventTime",
  NULL AS "RequestedDeliveryDate",
  NULL AS "ActualDeliveryDate",
  NULL AS "ProductCategory",
  pv.vendor_name AS "SupplierName",
  NULL AS "ModeOfTransport",
  pha.document_status AS "LogisticsOrderStatus",
  pha.created_by AS "User",
  pha.segment1 AS "PurchaseOrderNumber",
  pla.item_number AS "ItemNumber"
FROM
  sales_orders so
  JOIN por_requisition_lines_all prl ON so.source_doc_id = prl.doo_source_doc_id
  JOIN po_distributions_all pda ON prl.requisition_line_id = pda.requisition_line_id
  JOIN po_lines_all pla ON pda.po_line_id = pla.po_line_id
  JOIN po_headers_all pha ON pla.po_header_id = pha.po_header_id
  JOIN poz_suppliers_v pv ON pha.vendor_id = pv.vendor_id
WHERE
  pha.approved_date IS NOT NULL

UNION ALL

-- 5. Raw Materials Received
SELECT
  so.order_number AS "LogisticsOrder",
  'Raw Materials Received' AS "ActivityName",
  rt.transaction_date AS "EventTime",
  NULL AS "RequestedDeliveryDate",
  NULL AS "ActualDeliveryDate",
  NULL AS "ProductCategory",
  pv.vendor_name AS "SupplierName",
  NULL AS "ModeOfTransport",
  pha.document_status AS "LogisticsOrderStatus",
  rt.created_by AS "User",
  pha.segment1 AS "PurchaseOrderNumber",
  pla.item_number AS "ItemNumber"
FROM
  sales_orders so
  JOIN doo_fulfill_lines_all dfla ON so.header_id = dfla.header_id
  JOIN po_distributions_all pda ON dfla.fulfill_line_id = pda.fulfill_line_id
  JOIN po_lines_all pla ON pda.po_line_id = pla.po_line_id
  JOIN po_headers_all pha ON pla.po_header_id = pha.po_header_id
  JOIN poz_suppliers_v pv ON pha.vendor_id = pv.vendor_id
  JOIN rcv_transactions rt ON pha.po_header_id = rt.po_header_id AND rt.transaction_type = 'RECEIVE'

UNION ALL

-- 6. Production Scheduled
SELECT
  so.order_number AS "LogisticsOrder",
  'Production Scheduled' AS "ActivityName",
  wdj.scheduled_start_date AS "EventTime",
  NULL AS "RequestedDeliveryDate",
  NULL AS "ActualDeliveryDate",
  NULL AS "ProductCategory",
  NULL AS "SupplierName",
  NULL AS "ModeOfTransport",
  wdj.status_type_disp AS "LogisticsOrderStatus",
  wdj.created_by AS "User",
  NULL AS "PurchaseOrderNumber",
  msi.item_number AS "ItemNumber"
FROM
  sales_orders so
  JOIN wip_discrete_jobs wdj ON so.source_doc_id = wdj.source_header_id
  JOIN egp_system_items_b msi ON wdj.primary_item_id = msi.inventory_item_id AND wdj.organization_id = msi.organization_id
WHERE
  wdj.status_type IN (3, 4) -- Released, Complete

UNION ALL

-- 7. Goods Produced
SELECT
  so.order_number AS "LogisticsOrder",
  'Goods Produced' AS "ActivityName",
  wdj.completed_quantity_date AS "EventTime",
  NULL AS "RequestedDeliveryDate",
  NULL AS "ActualDeliveryDate",
  NULL AS "ProductCategory",
  NULL AS "SupplierName",
  NULL AS "ModeOfTransport",
  wdj.status_type_disp AS "LogisticsOrderStatus",
  wdj.last_updated_by AS "User",
  NULL AS "PurchaseOrderNumber",
  msi.item_number AS "ItemNumber"
FROM
  sales_orders so
  JOIN wip_discrete_jobs wdj ON so.source_doc_id = wdj.source_header_id
  JOIN egp_system_items_b msi ON wdj.primary_item_id = msi.inventory_item_id AND wdj.organization_id = msi.organization_id
WHERE
  wdj.status_type = 4 -- Complete
  AND wdj.completed_quantity_date IS NOT NULL

UNION ALL

-- 8. Quality Control Performed
SELECT
  so.order_number AS "LogisticsOrder",
  'Quality Control Performed' AS "ActivityName",
  qir.creation_date AS "EventTime",
  NULL AS "RequestedDeliveryDate",
  NULL AS "ActualDeliveryDate",
  NULL AS "ProductCategory",
  NULL AS "SupplierName",
  NULL AS "ModeOfTransport",
  qi.validation_result_code AS "LogisticsOrderStatus",
  qir.created_by AS "User",
  NULL AS "PurchaseOrderNumber",
  msi.item_number AS "ItemNumber"
FROM
  sales_orders so
  JOIN wip_discrete_jobs wdj ON so.source_doc_id = wdj.source_header_id
  JOIN egp_system_items_b msi ON wdj.primary_item_id = msi.inventory_item_id AND wdj.organization_id = msi.organization_id
  JOIN qa_inspection_results_v qir ON wdj.work_order_id = qir.work_order_id
  JOIN qa_inspections_b qi ON qir.inspection_id = qi.inspection_id

UNION ALL

-- 9. Goods Picked and Packed
SELECT
  so.order_number AS "LogisticsOrder",
  'Goods Picked and Packed' AS "ActivityName",
  wdd.last_update_date AS "EventTime",
  dha.request_ship_date AS "RequestedDeliveryDate",
  NULL AS "ActualDeliveryDate",
  NULL AS "ProductCategory",
  NULL AS "SupplierName",
  wnd.shipping_method_code AS "ModeOfTransport",
  wdd.released_status_name AS "LogisticsOrderStatus",
  wdd.last_updated_by AS "User",
  NULL AS "PurchaseOrderNumber",
  wdd.item_number AS "ItemNumber"
FROM
  sales_orders so
  JOIN doo_headers_all dha ON so.header_id = dha.header_id
  JOIN wsh_delivery_details wdd ON dha.header_id = wdd.source_header_id
  JOIN wsh_delivery_assignments wda ON wdd.delivery_detail_id = wda.delivery_detail_id
  JOIN wsh_new_deliveries wnd ON wda.delivery_id = wnd.delivery_id
WHERE
  wdd.released_status = 'Y' -- 'Ready to Release', can be adjusted to 'S' for 'Released to Warehouse'

UNION ALL

-- 10. Shipment Confirmed
SELECT
  so.order_number AS "LogisticsOrder",
  'Shipment Confirmed' AS "ActivityName",
  wnd.confirmed_date AS "EventTime",
  dha.request_ship_date AS "RequestedDeliveryDate",
  NULL AS "ActualDeliveryDate",
  NULL AS "ProductCategory",
  NULL AS "SupplierName",
  wnd.shipping_method_code AS "ModeOfTransport",
  wnd.status_code_name AS "LogisticsOrderStatus",
  wnd.last_updated_by AS "User",
  NULL AS "PurchaseOrderNumber",
  NULL AS "ItemNumber"
FROM
  sales_orders so
  JOIN doo_headers_all dha ON so.header_id = dha.header_id
  JOIN wsh_delivery_details wdd ON dha.header_id = wdd.source_header_id
  JOIN wsh_delivery_assignments wda ON wdd.delivery_detail_id = wda.delivery_detail_id
  JOIN wsh_new_deliveries wnd ON wda.delivery_id = wnd.delivery_id
WHERE wnd.confirmed_date IS NOT NULL

UNION ALL

-- 11. Goods Loaded for Transport
SELECT
  so.order_number AS "LogisticsOrder",
  'Goods Loaded for Transport' AS "ActivityName",
  wts.actual_departure_date AS "EventTime",
  dha.request_ship_date AS "RequestedDeliveryDate",
  NULL AS "ActualDeliveryDate",
  NULL AS "ProductCategory",
  NULL AS "SupplierName",
  wt.mode_of_transport AS "ModeOfTransport",
  wts.status_code_name AS "LogisticsOrderStatus",
  wts.last_updated_by AS "User",
  NULL AS "PurchaseOrderNumber",
  NULL AS "ItemNumber"
FROM
  sales_orders so
  JOIN doo_headers_all dha ON so.header_id = dha.header_id
  JOIN wsh_delivery_details wdd ON dha.header_id = wdd.source_header_id
  JOIN wsh_delivery_assignments wda ON wdd.delivery_detail_id = wda.delivery_detail_id
  JOIN wsh_new_deliveries wnd ON wda.delivery_id = wnd.delivery_id
  JOIN wsh_delivery_legs wdl ON wnd.delivery_id = wdl.delivery_id
  JOIN wsh_trip_stops wts ON wdl.pick_up_stop_id = wts.stop_id
  JOIN wsh_trips wt ON wts.trip_id = wt.trip_id
WHERE wts.actual_departure_date IS NOT NULL

UNION ALL

-- 12. Goods Unloaded at Destination
SELECT
  so.order_number AS "LogisticsOrder",
  'Goods Unloaded at Destination' AS "ActivityName",
  wts.actual_arrival_date AS "EventTime",
  dha.request_ship_date AS "RequestedDeliveryDate",
  wts.actual_arrival_date AS "ActualDeliveryDate",
  NULL AS "ProductCategory",
  NULL AS "SupplierName",
  wt.mode_of_transport AS "ModeOfTransport",
  wts.status_code_name AS "LogisticsOrderStatus",
  wts.last_updated_by AS "User",
  NULL AS "PurchaseOrderNumber",
  NULL AS "ItemNumber"
FROM
  sales_orders so
  JOIN doo_headers_all dha ON so.header_id = dha.header_id
  JOIN wsh_delivery_details wdd ON dha.header_id = wdd.source_header_id
  JOIN wsh_delivery_assignments wda ON wdd.delivery_detail_id = wda.delivery_detail_id
  JOIN wsh_new_deliveries wnd ON wda.delivery_id = wnd.delivery_id
  JOIN wsh_delivery_legs wdl ON wnd.delivery_id = wdl.delivery_id
  JOIN wsh_trip_stops wts ON wdl.drop_off_stop_id = wts.stop_id
  JOIN wsh_trips wt ON wts.trip_id = wt.trip_id
WHERE wts.actual_arrival_date IS NOT NULL

UNION ALL

-- 13. Proof of Delivery Signed
SELECT
  so.order_number AS "LogisticsOrder",
  'Proof of Delivery Signed' AS "ActivityName",
  wnd.pod_date AS "EventTime",
  dha.request_ship_date AS "RequestedDeliveryDate",
  wnd.pod_date AS "ActualDeliveryDate",
  NULL AS "ProductCategory",
  NULL AS "SupplierName",
  wnd.shipping_method_code AS "ModeOfTransport",
  wnd.status_code_name AS "LogisticsOrderStatus",
  wnd.last_updated_by AS "User",
  NULL AS "PurchaseOrderNumber",
  NULL AS "ItemNumber"
FROM
  sales_orders so
  JOIN doo_headers_all dha ON so.header_id = dha.header_id
  JOIN wsh_delivery_details wdd ON dha.header_id = wdd.source_header_id
  JOIN wsh_delivery_assignments wda ON wdd.delivery_detail_id = wda.delivery_detail_id
  JOIN wsh_new_deliveries wnd ON wda.delivery_id = wnd.delivery_id
WHERE wnd.pod_flag = 'Y' AND wnd.pod_date IS NOT NULL

UNION ALL

-- 14. Order Canceled
SELECT
  so.order_number AS "LogisticsOrder",
  'Order Canceled' AS "ActivityName",
  dha.last_update_date AS "EventTime",
  dha.request_ship_date AS "RequestedDeliveryDate",
  NULL AS "ActualDeliveryDate",
  NULL AS "ProductCategory",
  NULL AS "SupplierName",
  NULL AS "ModeOfTransport",
  dha.status_code AS "LogisticsOrderStatus",
  dha.last_updated_by AS "User",
  NULL AS "PurchaseOrderNumber",
  NULL AS "ItemNumber"
FROM
  sales_orders so
  JOIN doo_headers_all dha ON so.header_id = dha.header_id
WHERE
  dha.cancelled_flag = 'Y'

The following Public View Objects (PVOs) must be selected and configured within the BI Cloud Connector extraction job. This is not a runnable script but a list of objects to add to the extraction configuration.

**Order Management PVOs:**
*   `FscmTopModelAM.DooTopAM.Header` (For Customer Order Created, Order Canceled)
*   `FscmTopModelAM.DooTopAM.FulfilledLine` (For Inventory Availability Checked)

**Procurement PVOs:**
*   `FscmTopModelAM.ScmPoTopAM.ReqHeader` (For Purchase Requisition Created)
*   `FscmTopModelAM.ScmPoTopAM.PoHeader` (For Purchase Order Issued)

**Inventory and Receiving PVOs:**
*   `FscmTopModelAM.ScmRcvTopAM.RcvTransaction` (For Raw Materials Received)

**Manufacturing PVOs:**
*   `FscmTopModelAM.WisTopAM.WorkOrderHeader` (For Production Scheduled, Goods Produced)

**Quality Management PVOs:**
*   `FscmTopModelAM.ScmQamTopAM.QualityInspectionResult` (For Quality Control Performed)

**Shipping and Warehouse Management PVOs:**
*   `FscmTopModelAM.ScmWmsShippingTopAM.ShipmentLine` (For Goods Picked and Packed)
*   `FscmTopModelAM.ScmWmsShippingTopAM.ShipmentHeader` (For Shipment Confirmed)
*   `FscmTopModelAM.ScmWmsShippingTopAM.DeliveryTrip` (For Goods Loaded for Transport)
*   `FscmTopModelAM.ScmWmsShippingTopAM.DeliveryHeader` (For Goods Unloaded at Destination, Proof of Delivery Signed)

import requests
import pandas as pd
from datetime import datetime

class=class="hl-string">"hl-comment"># --- Configuration Settings ---
class=class="hl-string">"hl-comment"># Replace with your Oracle SCM Cloud instance details
ORACLE_SCM_HOST = class="hl-string">"[Your Oracle SCM Host e.g., xyz.fa.us2.oraclecloud.com]"
USERNAME = class="hl-string">"[Your Username]"
PASSWORD = class="hl-string">"[Your Password]"

class=class="hl-string">"hl-comment"># --- Date Range for Extraction ---
class=class="hl-string">"hl-comment"># Format: YYYY-MM-DD
START_DATE = class="hl-string">"2023-01-01"
END_DATE = class="hl-string">"2023-12-31"

class=class="hl-string">"hl-comment"># --- API Request Helper Function ---
def make_api_request(endpoint, params={}):
    class="hl-string">"""Handles authentication and pagination for Oracle SCM REST API calls."""
    all_items = []
    session = requests.Session()
    session.auth = (USERNAME, PASSWORD)
    url = fclass="hl-string">"https://{ORACLE_SCM_HOST}{endpoint}"

    class=class="hl-string">"hl-comment"># Set default limit and offset for pagination
    params.setdefault(class="hl-string">'limit', 100)
    params.setdefault(class="hl-string">'offset', 0)
    params.setdefault(class="hl-string">'onlyData', class="hl-string">'true')

    while True:
        try:
            response = session.get(url, params=params)
            response.raise_for_status()  class=class="hl-string">"hl-comment"># Raise an exception for bad status codes (4xx or 5xx)
            data = response.json()
            items = data.get(class="hl-string">'items', [])
            all_items.extend(items)

            if not data.get(class="hl-string">'hasMore', False):
                break
            
            params[class="hl-string">'offset'] += params[class="hl-string">'limit']

        except requests.exceptions.RequestException as e:
            print(fclass="hl-string">"Error fetching data from {url}: {e}")
            break

    return all_items

class=class="hl-string">"hl-comment"># --- Main Extraction Logic ---
def extract_scm_event_log():
    events = []
    date_filter = fclass="hl-string">"LastUpdateDate between '{START_DATE}' and '{END_DATE}'"
    creation_date_filter = fclass="hl-string">"CreationDate between '{START_DATE}' and '{END_DATE}'"

    print(class="hl-string">"Fetching Sales Orders for 'Customer Order Created' and 'Order Canceled'...")
    so_data = make_api_request(class="hl-string">"/fscmRestApi/resources/11.13.18.05/salesOrdersForOrderHub", {class="hl-string">'q': date_filter})
    for so in so_data:
        order_number = so.get(class="hl-string">'OrderNumber')
        if not order_number: continue

        class=class="hl-string">"hl-comment"># Activity: Customer Order Created
        events.append({
            class="hl-string">'LogisticsOrder': order_number,
            class="hl-string">'ActivityName': class="hl-string">'Customer Order Created',
            class="hl-string">'EventTime': so.get(class="hl-string">'CreationDate'),
            class="hl-string">'RequestedDeliveryDate': so.get(class="hl-string">'RequestShipDate'),
            class="hl-string">'ActualDeliveryDate': None,
            class="hl-string">'ProductCategory': so.get(class="hl-string">'lines', [{}])[0].get(class="hl-string">'ProductGroup'),
            class="hl-string">'SupplierName': None,
            class="hl-string">'ModeOfTransport': so.get(class="hl-string">'ShippingMethodCode'),
            class="hl-string">'LogisticsOrderStatus': so.get(class="hl-string">'Status'),
            class="hl-string">'User': so.get(class="hl-string">'CreatedBy'),
            class="hl-string">'PurchaseOrderNumber': None,
            class="hl-string">'ItemNumber': so.get(class="hl-string">'lines', [{}])[0].get(class="hl-string">'ProductNumber')
        })

        class=class="hl-string">"hl-comment"># Activity: Order Canceled
        if so.get(class="hl-string">'Status') == class="hl-string">'CANCELED':
            events.append({
                class="hl-string">'LogisticsOrder': order_number,
                class="hl-string">'ActivityName': class="hl-string">'Order Canceled',
                class="hl-string">'EventTime': so.get(class="hl-string">'LastUpdateDate'),
                class="hl-string">'RequestedDeliveryDate': so.get(class="hl-string">'RequestShipDate'),
                class="hl-string">'ActualDeliveryDate': None, class="hl-string">'ProductCategory': None, class="hl-string">'SupplierName': None,
                class="hl-string">'ModeOfTransport': so.get(class="hl-string">'ShippingMethodCode'),
                class="hl-string">'LogisticsOrderStatus': so.get(class="hl-string">'Status'), class="hl-string">'User': so.get(class="hl-string">'LastUpdatedBy'),
                class="hl-string">'PurchaseOrderNumber': None, class="hl-string">'ItemNumber': None
            })

    print(class="hl-string">"Fetching Purchase Requisitions for 'Purchase Requisition Created'...")
    pr_data = make_api_request(class="hl-string">"/fscmRestApi/resources/11.13.18.05/purchaseRequisitions", {class="hl-string">'q': creation_date_filter})
    for pr in pr_data:
        class=class="hl-string">"hl-comment"># Note: Linking PR to a specific sales order requires custom logic or configuration.
        class=class="hl-string">"hl-comment"># Here we assume a link can be inferred or is not strictly required for this event.
        events.append({
            class="hl-string">'LogisticsOrder': pr.get(class="hl-string">'SourceOrderNumber', class="hl-string">'[Not Linked]'), class=class="hl-string">"hl-comment"># Placeholder if no direct link
            class="hl-string">'ActivityName': class="hl-string">'Purchase Requisition Created',
            class="hl-string">'EventTime': pr.get(class="hl-string">'CreationDate'),
            class="hl-string">'RequestedDeliveryDate': None, class="hl-string">'ActualDeliveryDate': None, class="hl-string">'ProductCategory': None,
            class="hl-string">'SupplierName': None, class="hl-string">'ModeOfTransport': None, class="hl-string">'LogisticsOrderStatus': pr.get(class="hl-string">'RequisitioningBU'),
            class="hl-string">'User': pr.get(class="hl-string">'CreatedBy'),
            class="hl-string">'PurchaseOrderNumber': None,
            class="hl-string">'ItemNumber': pr.get(class="hl-string">'lines', [{}])[0].get(class="hl-string">'ItemNumber')
        })

    print(class="hl-string">"Fetching Purchase Orders for 'Purchase Order Issued'...")
    po_data = make_api_request(class="hl-string">"/fscmRestApi/resources/11.13.18.05/purchaseOrders", {class="hl-string">'q': fclass="hl-string">"ApprovedDate between '{START_DATE}' and '{END_DATE}'"})
    for po in po_data:
        events.append({
            class="hl-string">'LogisticsOrder': po.get(class="hl-string">'SourceOrderNumber', class="hl-string">'[Not Linked]'), class=class="hl-string">"hl-comment"># Placeholder if no direct link
            class="hl-string">'ActivityName': class="hl-string">'Purchase Order Issued',
            class="hl-string">'EventTime': po.get(class="hl-string">'ApprovedDate'),
            class="hl-string">'RequestedDeliveryDate': None, class="hl-string">'ActualDeliveryDate': None, class="hl-string">'ProductCategory': None,
            class="hl-string">'SupplierName': po.get(class="hl-string">'Supplier'),
            class="hl-string">'ModeOfTransport': None,
            class="hl-string">'LogisticsOrderStatus': po.get(class="hl-string">'DocumentStatus'),
            class="hl-string">'User': po.get(class="hl-string">'Buyer'),
            class="hl-string">'PurchaseOrderNumber': po.get(class="hl-string">'OrderNumber'),
            class="hl-string">'ItemNumber': po.get(class="hl-string">'lines', [{}])[0].get(class="hl-string">'ItemNumber')
        })

    print(class="hl-string">"Fetching Receipts for 'Raw Materials Received'...")
    rcv_data = make_api_request(class="hl-string">"/fscmRestApi/resources/11.13.18.05/receivingReceipts", {class="hl-string">'q': fclass="hl-string">"ReceiptDate between '{START_DATE}' and '{END_DATE}'"})
    for rcv in rcv_data:
        events.append({
            class="hl-string">'LogisticsOrder': rcv.get(class="hl-string">'OrderNumber'), class=class="hl-string">"hl-comment"># Assuming PO is the key link
            class="hl-string">'ActivityName': class="hl-string">'Raw Materials Received',
            class="hl-string">'EventTime': rcv.get(class="hl-string">'ReceiptDate'),
            class="hl-string">'RequestedDeliveryDate': None, class="hl-string">'ActualDeliveryDate': None, class="hl-string">'ProductCategory': None,
            class="hl-string">'SupplierName': rcv.get(class="hl-string">'SupplierName'), class="hl-string">'ModeOfTransport': None, 
            class="hl-string">'LogisticsOrderStatus': class="hl-string">'Received', class="hl-string">'User': rcv.get(class="hl-string">'CreatedBy'),
            class="hl-string">'PurchaseOrderNumber': rcv.get(class="hl-string">'POHeaderNumber'),
            class="hl-string">'ItemNumber': rcv.get(class="hl-string">'ItemNumber')
        })
        
    print(class="hl-string">"Fetching Work Orders for 'Production Scheduled' and 'Goods Produced'...")
    wo_data = make_api_request(class="hl-string">"/fscmRestApi/resources/11.13.18.05/workOrders", {class="hl-string">'q': date_filter})
    for wo in wo_data:
        class=class="hl-string">"hl-comment"># Activity: Production Scheduled
        if wo.get(class="hl-string">'ReleasedDate'):
            events.append({
                class="hl-string">'LogisticsOrder': wo.get(class="hl-string">'SalesOrderNumber', wo.get(class="hl-string">'WorkOrderNumber')), 
                class="hl-string">'ActivityName': class="hl-string">'Production Scheduled',
                class="hl-string">'EventTime': wo.get(class="hl-string">'ReleasedDate'),
                class="hl-string">'RequestedDeliveryDate': None, class="hl-string">'ActualDeliveryDate': None, class="hl-string">'ProductCategory': None, class="hl-string">'SupplierName': None,
                class="hl-string">'ModeOfTransport': None, class="hl-string">'LogisticsOrderStatus': wo.get(class="hl-string">'WorkOrderStatus'),
                class="hl-string">'User': wo.get(class="hl-string">'LastUpdatedBy'), class="hl-string">'PurchaseOrderNumber': None, class="hl-string">'ItemNumber': wo.get(class="hl-string">'ProductName')
            })
        class=class="hl-string">"hl-comment"># Activity: Goods Produced
        if wo.get(class="hl-string">'CompletedDate'):
            events.append({
                class="hl-string">'LogisticsOrder': wo.get(class="hl-string">'SalesOrderNumber', wo.get(class="hl-string">'WorkOrderNumber')),
                class="hl-string">'ActivityName': class="hl-string">'Goods Produced',
                class="hl-string">'EventTime': wo.get(class="hl-string">'CompletedDate'),
                class="hl-string">'RequestedDeliveryDate': None, class="hl-string">'ActualDeliveryDate': None, class="hl-string">'ProductCategory': None, class="hl-string">'SupplierName': None,
                class="hl-string">'ModeOfTransport': None, class="hl-string">'LogisticsOrderStatus': wo.get(class="hl-string">'WorkOrderStatus'),
                class="hl-string">'User': wo.get(class="hl-string">'LastUpdatedBy'), class="hl-string">'PurchaseOrderNumber': None, class="hl-string">'ItemNumber': wo.get(class="hl-string">'ProductName')
            })
            
    print(class="hl-string">"Fetching Shipments for shipping activities...")
    ship_data = make_api_request(class="hl-string">"/fscmRestApi/resources/11.13.18.05/shipments", {class="hl-string">'q': date_filter})
    for ship in ship_data:
        order_number = ship.get(class="hl-string">'SourceSalesOrderNumber', ship.get(class="hl-string">'ShipmentNumber'))
        
        class=class="hl-string">"hl-comment"># Activities: Goods Picked and Packed (using shipment creation as proxy), Shipment Confirmed, Goods Loaded
        events.append({
            class="hl-string">'LogisticsOrder': order_number, class="hl-string">'ActivityName': class="hl-string">'Goods Picked and Packed',
            class="hl-string">'EventTime': ship.get(class="hl-string">'CreationDate'), class="hl-string">'RequestedDeliveryDate': None,
            class="hl-string">'ActualDeliveryDate': ship.get(class="hl-string">'ActualDeliveryDate'), class="hl-string">'ProductCategory': None, class="hl-string">'SupplierName': None, 
            class="hl-string">'ModeOfTransport': ship.get(class="hl-string">'ModeOfTransport'), class="hl-string">'LogisticsOrderStatus': class="hl-string">'Packing', 
            class="hl-string">'User': ship.get(class="hl-string">'CreatedBy'), class="hl-string">'PurchaseOrderNumber': None, class="hl-string">'ItemNumber': None
        })
        if ship.get(class="hl-string">'ShippedDate'):
            events.append({
                class="hl-string">'LogisticsOrder': order_number, class="hl-string">'ActivityName': class="hl-string">'Shipment Confirmed',
                class="hl-string">'EventTime': ship.get(class="hl-string">'ShippedDate'), class="hl-string">'RequestedDeliveryDate': None,
                class="hl-string">'ActualDeliveryDate': ship.get(class="hl-string">'ActualDeliveryDate'), class="hl-string">'ProductCategory': None, class="hl-string">'SupplierName': None, 
                class="hl-string">'ModeOfTransport': ship.get(class="hl-string">'ModeOfTransport'), class="hl-string">'LogisticsOrderStatus': class="hl-string">'Shipped', 
                class="hl-string">'User': ship.get(class="hl-string">'LastUpdatedBy'), class="hl-string">'PurchaseOrderNumber': None, class="hl-string">'ItemNumber': None
            })
            events.append({
                class="hl-string">'LogisticsOrder': order_number, class="hl-string">'ActivityName': class="hl-string">'Goods Loaded for Transport',
                class="hl-string">'EventTime': ship.get(class="hl-string">'ShippedDate'), class="hl-string">'RequestedDeliveryDate': None, 
                class="hl-string">'ActualDeliveryDate': ship.get(class="hl-string">'ActualDeliveryDate'), class="hl-string">'ProductCategory': None, class="hl-string">'SupplierName': None, 
                class="hl-string">'ModeOfTransport': ship.get(class="hl-string">'ModeOfTransport'), class="hl-string">'LogisticsOrderStatus': class="hl-string">'In Transit', 
                class="hl-string">'User': ship.get(class="hl-string">'LastUpdatedBy'), class="hl-string">'PurchaseOrderNumber': None, class="hl-string">'ItemNumber': None
            })

        class=class="hl-string">"hl-comment"># Activity: Goods Unloaded at Destination (if data available)
        if ship.get(class="hl-string">'ActualArrivalDate'):
             events.append({
                class="hl-string">'LogisticsOrder': order_number, class="hl-string">'ActivityName': class="hl-string">'Goods Unloaded at Destination',
                class="hl-string">'EventTime': ship.get(class="hl-string">'ActualArrivalDate'), class="hl-string">'RequestedDeliveryDate': None, 
                class="hl-string">'ActualDeliveryDate': ship.get(class="hl-string">'ActualDeliveryDate'), class="hl-string">'ProductCategory': None, class="hl-string">'SupplierName': None, 
                class="hl-string">'ModeOfTransport': ship.get(class="hl-string">'ModeOfTransport'), class="hl-string">'LogisticsOrderStatus': class="hl-string">'Arrived', 
                class="hl-string">'User': ship.get(class="hl-string">'LastUpdatedBy'), class="hl-string">'PurchaseOrderNumber': None, class="hl-string">'ItemNumber': None
            })

        class=class="hl-string">"hl-comment"># Activity: Proof of Delivery Signed
        if ship.get(class="hl-string">'ProofOfDeliveryDate'):
             events.append({
                class="hl-string">'LogisticsOrder': order_number, class="hl-string">'ActivityName': class="hl-string">'Proof of Delivery Signed',
                class="hl-string">'EventTime': ship.get(class="hl-string">'ProofOfDeliveryDate'), class="hl-string">'RequestedDeliveryDate': None, 
                class="hl-string">'ActualDeliveryDate': ship.get(class="hl-string">'ProofOfDeliveryDate'), class="hl-string">'ProductCategory': None, class="hl-string">'SupplierName': None, 
                class="hl-string">'ModeOfTransport': ship.get(class="hl-string">'ModeOfTransport'), class="hl-string">'LogisticsOrderStatus': class="hl-string">'Delivered', 
                class="hl-string">'User': ship.get(class="hl-string">'LastUpdatedBy'), class="hl-string">'PurchaseOrderNumber': None, class="hl-string">'ItemNumber': None
            })

    class=class="hl-string">"hl-comment"># The following activities are often implicit or require more complex queries.
    class=class="hl-string">"hl-comment"># For this script, we are not fetching them directly, but stubs could be added here.
    print(class="hl-string">"Skipping 'Inventory Availability Checked' and 'Quality Control Performed' due to complexity...")
    class=class="hl-string">"hl-comment"># Note: To capture these, you would query order line status changes or the qualityInspections API.

    print(fclass="hl-string">"Total events extracted: {len(events)}")
    return pd.DataFrame(events)

class=class="hl-string">"hl-comment"># --- Script Execution ---
if __name__ == class="hl-string">"__main__":
    event_log_df = extract_scm_event_log()
    if not event_log_df.empty:
        class=class="hl-string">"hl-comment"># Sort by case and time for chronological order
        event_log_df[class="hl-string">'EventTime'] = pd.to_datetime(event_log_df[class="hl-string">'EventTime'], errors=class="hl-string">'coerce')
        event_log_df.dropna(subset=[class="hl-string">'EventTime'], inplace=True)
        event_log_df.sort_values(by=[class="hl-string">'LogisticsOrder', class="hl-string">'EventTime'], inplace=True)
        
        class=class="hl-string">"hl-comment"># Save to CSV
        output_file = class="hl-string">'oracle_scm_event_log.csv'
        event_log_df.to_csv(output_file, index=False)
        print(fclass="hl-string">"Event log successfully saved to {output_file}")
    else:
        print(class="hl-string">"No events were extracted. Check your configuration and date range.")