您的员工入职 data 模板

The following describes the configuration for the export project. Since the Data Management Framework exports entities separately, you must create an export for each source entity listed below, then combine the outputs into a single event log file.

**Source 1: Worker Entity**
This entity is used to generate the 'HR Profile Created' event.
*   **Entity Name**: `Worker`
*   **Field Mapping**:
    *   `OnboardingCase`: Map from `PersonnelNumber`
    *   `ActivityName`: Set as a fixed value: "HR Profile Created"
    *   `EventTime`: Map from `CreatedDateTime`
    *   `EventEndTime`: Map from `CreatedDateTime`
    *   `DepartmentName`: Map from `PrimaryAddressLocation` or related party information.
    *   `HiringManagerName`: Map from `ReportsToPerson` or related worker information.
    *   `PositionTitle`: Map from primary position details linked to the worker.
    *   `OnboardingStatus`: Set as a fixed value: "In Progress"
    *   `ComplianceDueDate`: Set to null

**Source 2: Employment Entity**
This entity generates the 'Offer Accepted' event, typically using the employment start date as the timestamp.
*   **Entity Name**: `Employment`
*   **Field Mapping**:
    *   `OnboardingCase`: Map from `PersonnelNumber`
    *   `ActivityName`: Set as a fixed value: "Offer Accepted"
    *   `EventTime`: Map from `EmploymentStartDate`
    *   `EventEndTime`: Map from `EmploymentStartDate`
    *   `DepartmentName`: Map from `DepartmentNumber`
    *   `HiringManagerName`: Join to worker entity to find manager name.
    *   `PositionTitle`: Join to position entity to find position title.
    *   `OnboardingStatus`: Set as a fixed value: "Initiated"
    *   `ComplianceDueDate`: Set to null

**Source 3: Onboarding Checklist Task Entity**
This is the primary source for most task-based activities. One export from this entity will generate rows for multiple activity types. A transformation step will be needed to map the task name to the correct standard activity name.
*   **Entity Name**: `Onboarding checklist task` (or a similar custom name like `HcmOnboardingGuideTask`)
*   **Filter Logic**: Only include tasks with a `CompletionDateTime`.
*   **Field Mapping**:
    *   `OnboardingCase`: Map from `PersonnelNumber`
    *   `ActivityName`: Map from `TaskName`. You must then apply logic to transform source values (e.g., 'Initiate employee background check') into the required standard names (e.g., 'Background Check Initiated'). This mapping should cover:
        *   "Background Check Initiated"
        *   "Background Check Completed"
        *   "Paperwork Sent To New Hire"
        *   "Paperwork Completed By New Hire"
        *   "IT Account Provisioning Initiated"
        *   "Equipment Ordered"
        *   "Equipment Delivered"
        *   "Workspace Setup Completed"
        *   "First Day Orientation Conducted"
        *   "Team Introduction Completed"
        *   "Onboarding Plan Completed"
        *   "30-Day Check-in Performed"
    *   `EventTime`: Map from `CompletionDateTime` for completion events. For initiation events, map from `CreationDateTime` or `StartDate`.
    *   `EventEndTime`: Map from `CompletionDateTime`.
    *   `DepartmentName`: Join to worker or employment entities.
    *   `HiringManagerName`: Join to worker or employment entities.
    *   `PositionTitle`: Join to worker or employment entities.
    *   `OnboardingStatus`: Map from a status field on the checklist or task.
    *   `ComplianceDueDate`: Map from `DueDate`.

**Source 4: Course Tables Entity**
This source tracks training-related activities.
*   **Entity Name**: `Course tables` (or a similar learning management entity)
*   **Logic**: You will need to create two transformations from this source: one for assignment and one for completion.
*   **Field Mapping (Assignment Event)**:
    *   `OnboardingCase`: Map from `PersonnelNumber`
    *   `ActivityName`: Set as a fixed value: "Mandatory Training Assigned"
    *   `EventTime`: Map from `AssignmentDate`
    *   `EventEndTime`: Map from `AssignmentDate`
    *   Other Attributes: Populate from related entities as needed.
*   **Field Mapping (Completion Event)**:
    *   `OnboardingCase`: Map from `PersonnelNumber`
    *   `ActivityName`: Set as a fixed value: "Mandatory Training Completed"
    *   `EventTime`: Map from `CompletionDate`
    *   `EventEndTime`: Map from `CompletionDate`
    *   Other Attributes: Populate from related entities as needed.

-- The following query reconstructs the Employee Onboarding process by querying the Dataverse TDS endpoint.
-- It assumes that most onboarding activities are tracked in a task entity like 'msdyn_onboardingtaskbase'.
-- Placeholders to be reviewed and updated:
-- 1. Date filter: The 'WHERE emp.startdate >= ...' line should be set to your desired date range.
-- 2. Task Subjects: The text literals in the WHERE clauses (e.g., 'Background Check', 'Order Equipment') must match the subject lines used in your system's onboarding tasks.
-- 3. Table and Column Names: If your environment uses custom entities or fields, update the table and column names accordingly.

WITH WorkerInfo AS (
  SELECT
    w.hcmworkerid AS workerid,
    w.personnelnumber AS personnelnumber,
    emp.startdate AS employmentstartdate,
    d.name AS departmentname,
    pos.description AS positiontitle,
    mgr.fullname AS managername,
    w.createdon AS workercreatedon
  FROM hcmworkerbase AS w
  LEFT JOIN hcmemploymentbase AS emp ON w.hcmworkerid = emp._hcmworkerid_value
  LEFT JOIN hcmdepartmentbase AS d ON emp._hcmdepartmentid_value = d.hcmdepartmentid
  LEFT JOIN hcmpositionworkerassignmentbase AS pwa ON w.hcmworkerid = pwa._hcmworkerid_value AND pwa.isprimaryposition = 1
  LEFT JOIN hcmpositiondetailbase AS posd ON pwa._hcmpositionid_value = posd._hcmpositionid_value
  LEFT JOIN hcmpositionbase AS pos ON pwa._hcmpositionid_value = pos.hcmpositionid
  LEFT JOIN systemuserbase AS mgr ON pos.reports_to_position_id = mgr._hcmpositionid_value
  WHERE emp.startdate >= DATEADD(month, -6, GETUTCDATE()) -- Placeholder: Filter for the last 6 months
    AND emp.employmenttype = 0 -- Example: Filter for Employees, not Contractors
)
-- 1. Offer Accepted (proxied by employment record creation)
SELECT
  w.personnelnumber AS OnboardingCase,
  'Offer Accepted' AS ActivityName,
  w.employmentstartdate AS EventTime,
  w.employmentstartdate AS EventEndTime,
  w.departmentname AS DepartmentName,
  w.managername AS HiringManagerName,
  w.positiontitle AS PositionTitle,
  'In Progress' AS OnboardingStatus,
  NULL AS ComplianceDueDate
FROM WorkerInfo AS w

UNION ALL

-- 2. HR Profile Created
SELECT
  w.personnelnumber AS OnboardingCase,
  'HR Profile Created' AS ActivityName,
  w.workercreatedon AS EventTime,
  w.workercreatedon AS EventEndTime,
  w.departmentname AS DepartmentName,
  w.managername AS HiringManagerName,
  w.positiontitle AS PositionTitle,
  'In Progress' AS OnboardingStatus,
  NULL AS ComplianceDueDate
FROM WorkerInfo AS w

UNION ALL

-- 3. Background Check Initiated
SELECT
  w.personnelnumber AS OnboardingCase,
  'Background Check Initiated' AS ActivityName,
  t.createdon AS EventTime,
  NULL AS EventEndTime,
  w.departmentname AS DepartmentName,
  w.managername AS HiringManagerName,
  w.positiontitle AS PositionTitle,
  'In Progress' AS OnboardingStatus,
  t.scheduledend AS ComplianceDueDate
FROM msdyn_onboardingtaskbase AS t
JOIN WorkerInfo AS w ON t._msdyn_workerid_value = w.workerid
WHERE t.subject LIKE '%Background Check%'

UNION ALL

-- 4. Background Check Completed
SELECT
  w.personnelnumber AS OnboardingCase,
  'Background Check Completed' AS ActivityName,
  t.actualend AS EventTime,
  t.actualend AS EventEndTime,
  w.departmentname AS DepartmentName,
  w.managername AS HiringManagerName,
  w.positiontitle AS PositionTitle,
  'In Progress' AS OnboardingStatus,
  NULL AS ComplianceDueDate
FROM msdyn_onboardingtaskbase AS t
JOIN WorkerInfo AS w ON t._msdyn_workerid_value = w.workerid
WHERE t.subject LIKE '%Background Check%' AND t.statecode = 1

UNION ALL

-- 5. Paperwork Sent To New Hire
SELECT
  w.personnelnumber AS OnboardingCase,
  'Paperwork Sent To New Hire' AS ActivityName,
  t.createdon AS EventTime,
  NULL AS EventEndTime,
  w.departmentname AS DepartmentName,
  w.managername AS HiringManagerName,
  w.positiontitle AS PositionTitle,
  'In Progress' AS OnboardingStatus,
  t.scheduledend AS ComplianceDueDate
FROM msdyn_onboardingtaskbase AS t
JOIN WorkerInfo AS w ON t._msdyn_workerid_value = w.workerid
WHERE t.subject LIKE '%Send Paperwork%'

UNION ALL

-- 6. Paperwork Completed By New Hire
SELECT
  w.personnelnumber AS OnboardingCase,
  'Paperwork Completed By New Hire' AS ActivityName,
  t.actualend AS EventTime,
  t.actualend AS EventEndTime,
  w.departmentname AS DepartmentName,
  w.managername AS HiringManagerName,
  w.positiontitle AS PositionTitle,
  'In Progress' AS OnboardingStatus,
  NULL AS ComplianceDueDate
FROM msdyn_onboardingtaskbase AS t
JOIN WorkerInfo AS w ON t._msdyn_workerid_value = w.workerid
WHERE t.subject LIKE '%Complete Paperwork%' AND t.statecode = 1

UNION ALL

-- 7. IT Account Provisioning Initiated
SELECT
  w.personnelnumber AS OnboardingCase,
  'IT Account Provisioning Initiated' AS ActivityName,
  t.createdon AS EventTime,
  NULL AS EventEndTime,
  w.departmentname AS DepartmentName,
  w.managername AS HiringManagerName,
  w.positiontitle AS PositionTitle,
  'In Progress' AS OnboardingStatus,
  t.scheduledend AS ComplianceDueDate
FROM msdyn_onboardingtaskbase AS t
JOIN WorkerInfo AS w ON t._msdyn_workerid_value = w.workerid
WHERE t.subject LIKE '%IT Account Provisioning%'

UNION ALL

-- 8. Equipment Ordered
SELECT
  w.personnelnumber AS OnboardingCase,
  'Equipment Ordered' AS ActivityName,
  t.actualend AS EventTime, -- Assuming task completion means ordered
  t.actualend AS EventEndTime,
  w.departmentname AS DepartmentName,
  w.managername AS HiringManagerName,
  w.positiontitle AS PositionTitle,
  'In Progress' AS OnboardingStatus,
  NULL AS ComplianceDueDate
FROM msdyn_onboardingtaskbase AS t
JOIN WorkerInfo AS w ON t._msdyn_workerid_value = w.workerid
WHERE t.subject LIKE '%Order Equipment%' AND t.statecode = 1

UNION ALL

-- 9. Equipment Delivered
SELECT
  w.personnelnumber AS OnboardingCase,
  'Equipment Delivered' AS ActivityName,
  t.actualend AS EventTime,
  t.actualend AS EventEndTime,
  w.departmentname AS DepartmentName,
  w.managername AS HiringManagerName,
  w.positiontitle AS PositionTitle,
  'In Progress' AS OnboardingStatus,
  NULL AS ComplianceDueDate
FROM msdyn_onboardingtaskbase AS t
JOIN WorkerInfo AS w ON t._msdyn_workerid_value = w.workerid
WHERE t.subject LIKE '%Confirm Equipment Delivery%' AND t.statecode = 1

UNION ALL

-- 10. Workspace Setup Completed
SELECT
  w.personnelnumber AS OnboardingCase,
  'Workspace Setup Completed' AS ActivityName,
  t.actualend AS EventTime,
  t.actualend AS EventEndTime,
  w.departmentname AS DepartmentName,
  w.managername AS HiringManagerName,
  w.positiontitle AS PositionTitle,
  'In Progress' AS OnboardingStatus,
  NULL AS ComplianceDueDate
FROM msdyn_onboardingtaskbase AS t
JOIN WorkerInfo AS w ON t._msdyn_workerid_value = w.workerid
WHERE t.subject LIKE '%Workspace Setup%' AND t.statecode = 1

UNION ALL

-- 11. First Day Orientation Conducted
SELECT
  w.personnelnumber AS OnboardingCase,
  'First Day Orientation Conducted' AS ActivityName,
  t.actualend AS EventTime,
  t.actualend AS EventEndTime,
  w.departmentname AS DepartmentName,
  w.managername AS HiringManagerName,
  w.positiontitle AS PositionTitle,
  'In Progress' AS OnboardingStatus,
  NULL AS ComplianceDueDate
FROM msdyn_onboardingtaskbase AS t
JOIN WorkerInfo AS w ON t._msdyn_workerid_value = w.workerid
WHERE t.subject LIKE '%First Day Orientation%' AND t.statecode = 1

UNION ALL

-- 12. Mandatory Training Assigned
SELECT
  w.personnelnumber AS OnboardingCase,
  'Mandatory Training Assigned' AS ActivityName,
  t.createdon AS EventTime,
  NULL AS EventEndTime,
  w.departmentname AS DepartmentName,
  w.managername AS HiringManagerName,
  w.positiontitle AS PositionTitle,
  'In Progress' AS OnboardingStatus,
  t.scheduledend AS ComplianceDueDate
FROM msdyn_onboardingtaskbase AS t
JOIN WorkerInfo AS w ON t._msdyn_workerid_value = w.workerid
WHERE t.subject LIKE '%Mandatory Training%'

UNION ALL

-- 13. Mandatory Training Completed
SELECT
  w.personnelnumber AS OnboardingCase,
  'Mandatory Training Completed' AS ActivityName,
  t.actualend AS EventTime,
  t.actualend AS EventEndTime,
  w.departmentname AS DepartmentName,
  w.managername AS HiringManagerName,
  w.positiontitle AS PositionTitle,
  'In Progress' AS OnboardingStatus,
  NULL AS ComplianceDueDate
FROM msdyn_onboardingtaskbase AS t
JOIN WorkerInfo AS w ON t._msdyn_workerid_value = w.workerid
WHERE t.subject LIKE '%Mandatory Training%' AND t.statecode = 1

UNION ALL

-- 14. Team Introduction Completed
SELECT
  w.personnelnumber AS OnboardingCase,
  'Team Introduction Completed' AS ActivityName,
  t.actualend AS EventTime,
  t.actualend AS EventEndTime,
  w.departmentname AS DepartmentName,
  w.managername AS HiringManagerName,
  w.positiontitle AS PositionTitle,
  'In Progress' AS OnboardingStatus,
  NULL AS ComplianceDueDate
FROM msdyn_onboardingtaskbase AS t
JOIN WorkerInfo AS w ON t._msdyn_workerid_value = w.workerid
WHERE t.subject LIKE '%Team Introduction%' AND t.statecode = 1

UNION ALL

-- 15. Onboarding Plan Completed
SELECT
  w.personnelnumber AS OnboardingCase,
  'Onboarding Plan Completed' AS ActivityName,
  g.actualend AS EventTime,
  g.actualend AS EventEndTime,
  w.departmentname AS DepartmentName,
  w.managername AS HiringManagerName,
  w.positiontitle AS PositionTitle,
  'Completed' AS OnboardingStatus,
  NULL AS ComplianceDueDate
FROM msdyn_onboardingguidebase AS g
JOIN WorkerInfo AS w ON g._msdyn_workerid_value = w.workerid
WHERE g.statecode = 1

UNION ALL

-- 16. 30-Day Check-in Performed
SELECT
  w.personnelnumber AS OnboardingCase,
  '30-Day Check-in Performed' AS ActivityName,
  t.actualend AS EventTime,
  t.actualend AS EventEndTime,
  w.departmentname AS DepartmentName,
  w.managername AS HiringManagerName,
  w.positiontitle AS PositionTitle,
  'Completed' AS OnboardingStatus,
  NULL AS ComplianceDueDate
FROM msdyn_onboardingtaskbase AS t
JOIN WorkerInfo AS w ON t._msdyn_workerid_value = w.workerid
WHERE t.subject LIKE '%30-Day Check-in%' AND t.statecode = 1

ORDER BY OnboardingCase, EventTime;

import requests
import pandas as pd
import msal
import datetime

class=class="hl-string">"hl-comment"># --- CONFIGURATION ---
class=class="hl-string">"hl-comment"># Replace with your Azure AD and Dynamics 365 environment details
TENANT_ID = class="hl-string">"your_tenant_id"
CLIENT_ID = class="hl-string">"your_client_id"
CLIENT_SECRET = class="hl-string">"your_client_secret"
RESOURCE_URL = class="hl-string">"https://your-org.hr.d365.dynamics.com" class=class="hl-string">"hl-comment"># Base D365 HR URL
API_ENDPOINT = fclass="hl-string">"{RESOURCE_URL}/data"

class=class="hl-string">"hl-comment"># Define the date range for the extraction
start_date_str = class="hl-string">"2023-01-01"
end_date_str = class="hl-string">"2023-12-31"

class=class="hl-string">"hl-comment"># CRITICAL: Map standard activity names to the exact task names in your D365 Onboarding Checklists
class=class="hl-string">"hl-comment"># The script will query OnboardingChecklistItems based on the class="hl-string">'Task' field values.
activity_task_mapping = {
    class="hl-string">"Background Check Initiated": class="hl-string">"[Background Check Task Name]",
    class="hl-string">"Background Check Completed": class="hl-string">"[Background Check Completed Task Name]",
    class="hl-string">"Paperwork Sent To New Hire": class="hl-string">"[Send Paperwork Task Name]",
    class="hl-string">"Paperwork Completed By New Hire": class="hl-string">"[Complete Paperwork Task Name]",
    class="hl-string">"IT Account Provisioning Initiated": class="hl-string">"[Request IT Account Task Name]",
    class="hl-string">"Equipment Ordered": class="hl-string">"[Order Laptop and Equipment]",
    class="hl-string">"Equipment Delivered": class="hl-string">"[Confirm Equipment Delivery]",
    class="hl-string">"Workspace Setup Completed": class="hl-string">"[Complete Workspace Setup]",
    class="hl-string">"First Day Orientation Conducted": class="hl-string">"[Complete First Day Orientation]",
    class="hl-string">"Mandatory Training Assigned": class="hl-string">"[Assign Mandatory Training]",
    class="hl-string">"Mandatory Training Completed": class="hl-string">"[Confirm Mandatory Training Completion]",
    class="hl-string">"Team Introduction Completed": class="hl-string">"[Introduce New Hire to Team]",
    class="hl-string">"Onboarding Plan Completed": class="hl-string">"[Complete Full Onboarding Plan]",
    class="hl-string">"30-Day Check-in Performed": class="hl-string">"[Conduct 30-Day Check-in]"
}

class=class="hl-string">"hl-comment"># --- AUTHENTICATION ---
def get_access_token():
    authority = fclass="hl-string">"https://login.microsoftonline.com/{TENANT_ID}"
    app = msal.ConfidentialClientApplication(
        CLIENT_ID,
        authority=authority,
        client_credential=CLIENT_SECRET
    )
    result = app.acquire_token_for_client(scopes=[fclass="hl-string">"{RESOURCE_URL}/.default"])
    if class="hl-string">"access_token" in result:
        return result[class="hl-string">'access_token']
    else:
        print(result.get(class="hl-string">"error"))
        print(result.get(class="hl-string">"error_description"))
        raise Exception(class="hl-string">"Could not obtain access token")

class=class="hl-string">"hl-comment"># --- DATA FETCHING AND PROCESSING ---
def fetch_data(access_token, entity_url):
    headers = {
        class="hl-string">'Authorization': fclass="hl-string">'Bearer {access_token}',
        class="hl-string">'Content-Type': class="hl-string">'application/json'
    }
    full_url = fclass="hl-string">"{API_ENDPOINT}/{entity_url}"
    response = requests.get(full_url, headers=headers)
    if response.status_code == 200:
        return response.json()[class="hl-string">'value']
    else:
        print(fclass="hl-string">"Error fetching {entity_url}: {response.status_code} - {response.text}")
        return []

def main():
    print(class="hl-string">"Acquiring access token...")
    token = get_access_token()
    all_events = []

    class=class="hl-string">"hl-comment"># Fetch base worker and onboarding guide data for enrichment
    print(class="hl-string">"Fetching base worker and onboarding data...")
    worker_details_url = fclass="hl-string">"Workers?$select=PersonnelNumber,Name,PrimaryContactEmail,PersonBirthDate&$expand=Employments($select=DepartmentNumber,HiringManagerPersonnelNumber,PositionId),Positions($select=PositionId,Title)"
    workers_data = fetch_data(token, worker_details_url)
    workers_df = pd.json_normalize(workers_data)

    class=class="hl-string">"hl-comment"># A simplified enrichment lookup dictionary
    enrichment_map = {}
    for _, row in workers_df.iterrows():
        enrichment_map[row[class="hl-string">'PersonnelNumber']] = {
            class="hl-string">'DepartmentName': row.get(class="hl-string">'Employments.DepartmentNumber', None),
            class="hl-string">'HiringManagerName': row.get(class="hl-string">'Employments.HiringManagerPersonnelNumber', None),
            class="hl-string">'PositionTitle': row.get(class="hl-string">'Positions.Title', None)
        }

    print(class="hl-string">"Processing activities...")
    
    class=class="hl-string">"hl-comment"># 1. Offer Accepted / HR Profile Created (approximated by worker creation date)
    print(class="hl-string">"Extracting 'Offer Accepted' and 'HR Profile Created'...")
    offer_accepted_url = fclass="hl-string">"Workers?$filter=createdDateTime ge {start_date_str}T00:00:00Z and createdDateTime le {end_date_str}T23:59:59Z&$select=PersonnelNumber,createdDateTime"
    offer_data = fetch_data(token, offer_accepted_url)
    for item in offer_data:
        personnel_number = item.get(class="hl-string">'PersonnelNumber')
        event_time = item.get(class="hl-string">'createdDateTime')
        enrich_data = enrichment_map.get(personnel_number, {})
        all_events.append({class="hl-string">'OnboardingCase': personnel_number, class="hl-string">'ActivityName': class="hl-string">'Offer Accepted', class="hl-string">'EventTime': event_time, **enrich_data})
        all_events.append({class="hl-string">'OnboardingCase': personnel_number, class="hl-string">'ActivityName': class="hl-string">'HR Profile Created', class="hl-string">'EventTime': event_time, **enrich_data})

    class=class="hl-string">"hl-comment"># 2. Checklist-based activities
    for activity_name, task_name in activity_task_mapping.items():
        print(fclass="hl-string">"Extracting '{activity_name}'...")
        checklist_items_url = fclass="hl-string">"OnboardingChecklistItems?$filter=Task eq '{task_name}' and CompletedDateTime ge {start_date_str}T00:00:00Z and CompletedDateTime le {end_date_str}T23:59:59Z&$select=OnboardingGuidePersonnelNumber,CompletedDateTime,DueDate&$expand=OnboardingGuide($select=OverallStatus)"
        checklist_data = fetch_data(token, checklist_items_url)
        for item in checklist_data:
            personnel_number = item.get(class="hl-string">'OnboardingGuidePersonnelNumber')
            event_time = item.get(class="hl-string">'CompletedDateTime')
            enrich_data = enrichment_map.get(personnel_number, {})
            all_events.append({
                class="hl-string">'OnboardingCase': personnel_number,
                class="hl-string">'ActivityName': activity_name,
                class="hl-string">'EventTime': event_time,
                class="hl-string">'EventEndTime': event_time,
                class="hl-string">'ComplianceDueDate': item.get(class="hl-string">'DueDate'),
                class="hl-string">'OnboardingStatus': item.get(class="hl-string">'OnboardingGuide', {}).get(class="hl-string">'OverallStatus'),
                **enrich_data
            })

    class=class="hl-string">"hl-comment"># Convert to DataFrame
    if not all_events:
        print(class="hl-string">"No events found for the specified period.")
        return

    event_log_df = pd.DataFrame(all_events)

    class=class="hl-string">"hl-comment"># Final data transformation
    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 = event_log_df.dropna(subset=[class="hl-string">'OnboardingCase', class="hl-string">'EventTime'])
    event_log_df = event_log_df.sort_values(by=[class="hl-string">'OnboardingCase', class="hl-string">'EventTime'], ascending=[True, True])
    
    class=class="hl-string">"hl-comment"># Ensure all required and recommended columns exist
    final_columns = [
        class="hl-string">'OnboardingCase', class="hl-string">'ActivityName', class="hl-string">'EventTime', class="hl-string">'EventEndTime',
        class="hl-string">'DepartmentName', class="hl-string">'HiringManagerName', class="hl-string">'PositionTitle',
        class="hl-string">'OnboardingStatus', class="hl-string">'ComplianceDueDate'
    ]
    for col in final_columns:
        if col not in event_log_df.columns:
            event_log_df[col] = None
    
    event_log_df = event_log_df[final_columns]

    class=class="hl-string">"hl-comment"># Export to CSV
    output_filename = class="hl-string">'d365_onboarding_event_log.csv'
    event_log_df.to_csv(output_filename, index=False, date_format=class="hl-string">'%Y-%m-%dT%H:%M:%S.%fZ')
    print(fclass="hl-string">"Extraction complete. Event log saved to {output_filename}")

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

The following describes the configuration for the export project. Since the Data Management Framework exports entities separately, you must create an export for each source entity listed below, then combine the outputs into a single event log file.

**Source 1: Worker Entity**
This entity is used to generate the 'HR Profile Created' event.
*   **Entity Name**: `Worker`
*   **Field Mapping**:
    *   `OnboardingCase`: Map from `PersonnelNumber`
    *   `ActivityName`: Set as a fixed value: "HR Profile Created"
    *   `EventTime`: Map from `CreatedDateTime`
    *   `EventEndTime`: Map from `CreatedDateTime`
    *   `DepartmentName`: Map from `PrimaryAddressLocation` or related party information.
    *   `HiringManagerName`: Map from `ReportsToPerson` or related worker information.
    *   `PositionTitle`: Map from primary position details linked to the worker.
    *   `OnboardingStatus`: Set as a fixed value: "In Progress"
    *   `ComplianceDueDate`: Set to null

**Source 2: Employment Entity**
This entity generates the 'Offer Accepted' event, typically using the employment start date as the timestamp.
*   **Entity Name**: `Employment`
*   **Field Mapping**:
    *   `OnboardingCase`: Map from `PersonnelNumber`
    *   `ActivityName`: Set as a fixed value: "Offer Accepted"
    *   `EventTime`: Map from `EmploymentStartDate`
    *   `EventEndTime`: Map from `EmploymentStartDate`
    *   `DepartmentName`: Map from `DepartmentNumber`
    *   `HiringManagerName`: Join to worker entity to find manager name.
    *   `PositionTitle`: Join to position entity to find position title.
    *   `OnboardingStatus`: Set as a fixed value: "Initiated"
    *   `ComplianceDueDate`: Set to null

**Source 3: Onboarding Checklist Task Entity**
This is the primary source for most task-based activities. One export from this entity will generate rows for multiple activity types. A transformation step will be needed to map the task name to the correct standard activity name.
*   **Entity Name**: `Onboarding checklist task` (or a similar custom name like `HcmOnboardingGuideTask`)
*   **Filter Logic**: Only include tasks with a `CompletionDateTime`.
*   **Field Mapping**:
    *   `OnboardingCase`: Map from `PersonnelNumber`
    *   `ActivityName`: Map from `TaskName`. You must then apply logic to transform source values (e.g., 'Initiate employee background check') into the required standard names (e.g., 'Background Check Initiated'). This mapping should cover:
        *   "Background Check Initiated"
        *   "Background Check Completed"
        *   "Paperwork Sent To New Hire"
        *   "Paperwork Completed By New Hire"
        *   "IT Account Provisioning Initiated"
        *   "Equipment Ordered"
        *   "Equipment Delivered"
        *   "Workspace Setup Completed"
        *   "First Day Orientation Conducted"
        *   "Team Introduction Completed"
        *   "Onboarding Plan Completed"
        *   "30-Day Check-in Performed"
    *   `EventTime`: Map from `CompletionDateTime` for completion events. For initiation events, map from `CreationDateTime` or `StartDate`.
    *   `EventEndTime`: Map from `CompletionDateTime`.
    *   `DepartmentName`: Join to worker or employment entities.
    *   `HiringManagerName`: Join to worker or employment entities.
    *   `PositionTitle`: Join to worker or employment entities.
    *   `OnboardingStatus`: Map from a status field on the checklist or task.
    *   `ComplianceDueDate`: Map from `DueDate`.

**Source 4: Course Tables Entity**
This source tracks training-related activities.
*   **Entity Name**: `Course tables` (or a similar learning management entity)
*   **Logic**: You will need to create two transformations from this source: one for assignment and one for completion.
*   **Field Mapping (Assignment Event)**:
    *   `OnboardingCase`: Map from `PersonnelNumber`
    *   `ActivityName`: Set as a fixed value: "Mandatory Training Assigned"
    *   `EventTime`: Map from `AssignmentDate`
    *   `EventEndTime`: Map from `AssignmentDate`
    *   Other Attributes: Populate from related entities as needed.
*   **Field Mapping (Completion Event)**:
    *   `OnboardingCase`: Map from `PersonnelNumber`
    *   `ActivityName`: Set as a fixed value: "Mandatory Training Completed"
    *   `EventTime`: Map from `CompletionDate`
    *   `EventEndTime`: Map from `CompletionDate`
    *   Other Attributes: Populate from related entities as needed.