> 継続的なプロセス改善 > 給与処理 > UKG Pro > データテンプレート

給与処理データテンプレート

UKG Pro

給与処理の属性(19) 給与処理のアクティビティ(15) データ抽出ガイド(2)

給与処理データテンプレート

このテンプレートは、UKG Proの給与処理サイクルをマッピングし、分析に役立つインサイトを得るための基本構成を示します。詳細な分析に必要な属性、監視すべきプロセスのステップ、システム環境から情報を収集する方法をまとめています。データをテンプレートに合わせることで、非効率な箇所を特定し、給与処理のコンプライアンスを確保しやすくなります。

給与分析に使用する標準データ属性
UKG Proで追跡する主要なプロセスの節目
システム連携に必要なデータ抽出の手順

イベントログを初めて作成する方はこちら：プロセスマイニング用イベントログの作成方法.

テンプレートをダウンロード

給与処理の属性

この表では、給与処理の分析に必要なイベントログを作成するために推奨されるデータ項目と、コンテキストを示すメタデータを紹介します。

5 必須 11 推奨 3 任意

	名前	説明
	アクティビティ ActivityName	給与プロセスで実行される個々のイベントまたはステップです。
説明この属性には、タイムシート提出、総支給額の計算、支払い実行など、給与ワークフロー内で発生するステップの名前を記録します。プロセスマップの流れを定義する項目です。通常、UKG Pro環境の監査ログ、システムのステータス変更テーブル、またはタイムスタンプ付きのトランザクション更新から値を抽出します。プロセスグラフで読みやすく表示できるよう、データ変換時に命名規則を統一します。重要な理由プロセスマップのノードを定義する必須のアクティビティ属性です。入手先システム監査ログ、ワークフロー履歴、またはトランザクションのタイムスタンプ列例タイムシートを提出総支給額を計算支払いを実行
	タイムスタンプ EventTimestamp	アクティビティが発生した日時です。
説明この属性には、アクティビティが発生した正確な時刻を記録します。イベントを正しい順序に並べ、ステップ間の所要時間を計算するために必要です。短時間に連続して発生する自動処理を区別できるよう、精度の高いタイムスタンプが望まれます。給与プロセスでは、サイクルタイム分布やSLAコンプライアンスのダッシュボード分析に使用します。正確なタイムスタンプがなければ、総支給額から手取り額を算出する処理の所要時間や、タイムシート承認の遅延を測定できません。重要な理由イベントの順序付けに必要な必須のStartTime属性です。入手先トランザクションのステータス変更に関連付けられた日付／時刻列例 2023-10-01T09:15:00Z2023-10-01T14:30:45Z2023-10-03T08:00:00Z
	データソース SourceSystem	データの記録元となるシステムです。
説明この属性は、データレコードの発生元を示します。この場合、値はUKG Proに固定するか、複数の環境がある場合は特定のインスタンス名を設定します。給与データとERPの総勘定元帳データを組み合わせるような複数システムのプロセスマイニングでは、特に重要です。この属性を使うと、給与プラットフォーム内で発生したステップだけを表示するか、外部の勤怠管理システムから連携されたステップも含めるかを切り替えられます。重要な理由データリネージと複数システムの分析に必要な必須属性です。入手先固定値またはシステム設定テーブル例 UKG ProUltiPro Legacy勤怠管理システム
	最終更新日 LastUpdateDate	データ行が最後に変更された日時です。
説明この属性は、データベース内でレコードが最後に変更された日時を示します。イベントのタイムスタンプと似ていますが、主にデータの増分読み込みや整合性チェックに使用します。給与担当者による遅れて行われた調整や遡及修正も反映し、プロセスマイニングモデルに給与レコードの最新状態を反映できます。重要な理由データの増分更新に必要な必須属性です。入手先 LastModifiedDateなどのシステムメタデータ列例 2023-10-05T17:00:00Z2023-10-06T09:00:00Z
	給与レコード PayrollRecordId	特定の給与期間における従業員を一意に識別するIDです。
説明給与レコードは、プロセスマイニング分析における中心的なケースIDです。従業員IDと給与期間終了日（または給与グループのインスタンス）を組み合わせて作成します。これにより、従業員ごとの給与サイクルを個別のケースとして扱い、繰り返し発生するプロセスを時系列で分析できます。 UKG Proでは通常、給与ヘッダーテーブルなどのトランザクションレコードから複合キーを作成します。このIDでグループ化すると、タイムシートの提出から最終的な支払い、税務申告までの一連の流れを再構成できます。重要な理由すべての給与アクティビティをまとめ、1つのプロセスインスタンスとして扱うために必須のケースIDです。入手先 UKG Proの給与ヘッダーまたは従業員給与履歴テーブルから取得例 EMP001-20231015EMP492-20231031EMP883-20231115
	SLA期限 SlaProcessingDeadline	支払いの実行を完了する目標日時です。
説明この属性は、銀行振込を期日どおりに行うために給与プロセスを完了すべき社内または社外の期限を定義します。SLAコンプライアンスと期限監視のダッシュボードで中心となる属性です。実際の支払い実行時刻をこの期限と比較すると、期限内に処理できた割合を算出し、遅延のおそれがあるレコードを優先して確認できます。重要な理由 SLAの遵守状況を算出するための基準です。入手先給与カレンダー、または支給日から銀行処理日数を差し引いて算出例 2023-10-13T16:00:00Z2023-10-28T16:00:00Z
	SLA期限超過の有無 IsSlaBreached	期限後に支払いが実行されたことを示すフラグです。
説明このブール属性は、「支払い実行」のタイムスタンプと「SLA期限」を比較して算出する指標です。給与SLA遵守率を測るKPIに直接反映されます。あらかじめ算出しておくと、問題のあるケースだけをダッシュボードにすばやく表示でき、期限に間に合わなかった原因を分析しやすくなります。重要な理由コンプライアンス監視のKPI算出に使用します。入手先算出式：PaymentTime > SlaDeadline 例 truefalse
	原価センター CostCenter	財務上の配賦先を示す原価センターコードです。
説明原価センター属性は、給与費用を総勘定元帳のどこに配賦するかを示します。部門と似ていますが、より細かな財務分析に使われることがよくあります。勤怠承認パフォーマンスのダッシュボードでは、特定の原価センターで承認階層に時間がかかっていないかを確認できます。また、総支給額から手取り額を算出する段階で、給与費用が正しい財務項目に計上されているかの検証にも役立ちます。重要な理由財務分析を支援し、予算単位ごとのボトルネックを特定できます。入手先従業員職務または配賦テーブル例 CC-5001CC-9002Overhead-Corp
	監査例外の有無 HasAuditException	監査例外が発生したことを示すフラグです。
説明このブール属性は、ケース内で監査例外のフラグ設定アクティビティが発生したかどうかを示します。初回処理での給与精度を測るKPIに役立ちます。介入が不要だったケースと必要だったケースをすばやく分けられるため、監査例外と修正傾向のダッシュボードで手戻りの原因を分析しやすくなります。重要な理由介入が必要なケースを特定します。入手先「監査例外のフラグ設定」アクティビティの有無から算出例 truefalse
	給与グループ PayGroup	給与処理の対象となる従業員をまとめる論理的なグループです。
説明給与グループは、UKG Proの基本的な設定項目です。対象従業員の給与支給頻度（週次、隔週など）や処理規則を定め、主なバッチ識別子として機能します。給与サイクルタイム分布のダッシュボードで重要な属性です。役員給与と工場の時給従業員など、グループごとの処理状況を比較し、特定の設定が継続的な遅延の原因になっていないかを確認できます。重要な理由給与処理の状況をグループ別に比較するための主要な分析軸です。入手先給与ヘッダーまたは給与グループ設定テーブル例 US-BiWeeklyCA-WeeklyExec-Monthly
	給与担当者 PayrollSpecialist	レコードを処理した担当者のユーザーIDまたは名前です。
説明この属性は、レコードの承認、データ修正、または給与支払いの実行を担当する給与管理者や専門担当者を示します。汎用ユーザー属性にマッピングされます。専門担当者の業務量と処理件数を示すダッシュボードに欠かせないデータです。チーム内の業務分担を可視化し、承認段階で特定の担当者に負荷が集中していないか、ボトルネックになっていないかを確認できます。重要な理由リソース分析や業務負荷の平準化に役立ちます。入手先監査ログまたはトランザクションテーブルの「ModifiedBy」列例 jsmithmdoesystem_admin
	給与期間終了日 PayPeriodEndDate	処理対象の給与期間の最終日です。
説明この属性は、給与サイクルの終了日を示します。提出が遅れたかどうかを判断する際の重要な基準です。「タイムシート提出」アクティビティのStartTimeとあわせて遅延時間を算出し、給与サイクルタイム分布のダッシュボードでグループ化に使用します。重要な理由給与サイクルの時間的な基準点です。入手先給与ヘッダーまたは給与期間設定例 2023-09-302023-10-15
	総支給額 GrossPayAmount	控除や税金を差し引く前に計算される給与の合計額です。
説明この属性は、レコードに対して計算された総支給額を金額で示します。コストに基づくプロセス分析を行うため、ActivityAmountにマッピングされます。総支給額を分析すると、総支給額から手取り額を算出する処理速度のダッシュボードに役立ちます。ダッシュボードでは主に所要時間を測定しますが、支払いの複雑さや金額と所要時間を照らし合わせることで、高額な支払いや複雑な歩合計算が処理上の問題につながっているかを把握できます。重要な理由価値の流れの分析や外れ値の検出に役立ちます。入手先給与結果または給与台帳テーブル例 2500.0010500.50480.00
	課税管轄区域 TaxJurisdiction	税務申告の対象となる主な州または地域です。
説明この属性は、給与レコードに関連付けられた主な課税管轄区域を示します。複数州の税務申告スケジュールを確認するダッシュボードに欠かせません。課税管轄区域ごとにプロセスの流れを分析すると、特定の州で申告完了までの時間が継続的に長くなっていないか、複数州で勤務する従業員の監査例外が単一州の従業員より多くないかを、コンプライアンス担当者が確認できます。重要な理由コンプライアンスの監視と地理分析に欠かせません。入手先税務所在地または従業員税務テーブル例 CANYTX
	通常サイクル外かどうか IsOffCycle	給与処理が通常のスケジュール外であることを示すフラグです。
説明このブール属性は、給与レコードが通常サイクル外の処理に属するかどうかを示します。通常サイクル外の給与処理件数を測るKPIの算出に使用します。通常サイクル外の処理は、一般にコストが高く、手作業も多くなります。プロセスバリアント経路分析のダッシュボードでこのフラグを使って絞り込むと、エラー修正や臨時支払いに伴う標準外の経路を確認できます。重要な理由プロセス逸脱や手戻りの分析に使う主要なフィルターです。入手先給与ヘッダーの「Check Date」と「Period End Date」のロジック例 truefalse
	部門 DepartmentCode	従業員に関連付けられた部門コードです。
説明この属性は、給与レコードを特定の組織単位に関連付けます。監査例外と修正傾向のダッシュボードで、エラーが繰り返し発生する部門や手作業での対応が必要な部門を把握するために欠かせません。部門別にデータを分けて分析すると、タイムシート承認の研修が必要な管理者や、複雑な給与規則によって計算が遅れている事業部門を特定できます。重要な理由組織別の分析と根本原因の特定に欠かせません。入手先従業員マスタまたは職務履歴テーブル例 DEPT-100FINANCE-01OPS-WEST
	インセンティブデータの取得元 IncentiveSource	インセンティブデータの取得元（SalesForce、Excelインポートなど）です。
説明この属性は、給与レコードに取り込まれたインセンティブや歩合データの取得元を示します。インセンティブデータのインポート精度を確認するダッシュボードで使用します。この属性とインセンティブデータの手戻り頻度を測るKPIを照合すると、特定の上流ファイル（北東地域の売上レポートなど）で書式エラーやデータ品質の問題が繰り返し発生していないかを確認できます。重要な理由品質上の問題を外部データ提供元までたどれます。入手先インポートログのファイル名またはバッチIDの説明例販売歩合データフィード手動ボーナスアップロード役員報酬システム
	修正区分 CorrectionCategory	実施したデータ修正の種類（時間、給与率、控除など）です。
説明データ修正アクティビティが発生すると、この属性に修正内容を記録します。手作業によるデータ修正率を測るKPIに欠かせません。修正の大半が「勤務時間の入力」に関するものか、「福利厚生控除」に関するものかを把握すると、上流のシステムや担当チームを絞ってプロセスを改善できます。重要な理由手戻りの理由を詳しく把握できます。入手先監査ログの「Field Changed」列例勤務時間の入力修正遡及給与税コードの更新
	従業員区分 EmployeeType	従業員の区分（正社員、パートタイム、契約社員など）です。
説明この属性は、給与レコードに関連付けられた従業員を区分します。勤怠承認パフォーマンスのダッシュボードで使用します。従業員の区分によって、タイムシートの提出状況や承認ワークフローが異なることがあります。この属性でデータを分けると、プロセス全体の問題と、特定の従業員層に固有の傾向を区別できます。重要な理由従業員区分ごとの分析に使用します。入手先従業員マスタテーブル例正社員パートタイム契約社員

必須推奨任意

給与処理のアクティビティ

プロセスを正確に把握し、ボトルネックを特定するために、イベントログに記録する主要なプロセスのステップと節目です。

4 推奨 11 任意

	アクティビティ	説明
	支払いを実行	支給日、または従業員への実際の資金振込を示します。報酬の支払い義務が履行されたことを表します。
重要な理由「SLA遵守」の確認と、従業員への支給が約束した日に行われたことの検証に使います。入手先確定済みのPay Header記録にある「Check Date」または「Advice Date」フィールドを使います。記録トランザクションpayment_postの実行時に記録イベントタイプ explicit
	税務申告を完了	連邦、州、地方など、該当する管轄地域に税務データを正常に提出する工程です。多くの場合、支払い後に行われます。
重要な理由規制要件を守り、罰則を避けるため、「複数州の税務申告スケジュール」ダッシュボードに必要なデータです。入手先 Tax Filing InterfaceまたはPayment Servicesのログで、ステータスが「Filed」または「Accepted」となった更新を取得します。記録トランザクションtax_file_transmitの実行時に記録イベントタイプ explicit
	給与記録を作成	新しい給与グループの処理単位で、従業員の給与明細項目を作成する工程です。従業員が有効で、現在の処理サイクルに含まれていることを示します。
重要な理由中核システムで給与処理段階が正式に始まった時点を示します。勤怠データの記録にかかった時間と、実際の給与処理時間を区別するために必要です。入手先対象の支給日について、Employee PayまたはCheck Headerテーブルに記録が追加された時刻を特定します。記録トランザクションpay_period_createの実行時に記録イベントタイプ explicit
	給与記録を承認	個別の給与記録または給与グループ全体を最終承認します。この操作により記録がロックされ、支払いデータの作成待ちになります。
重要な理由作業段階と確定段階を分ける重要な節目です。「銀行振込ファイルの作成リードタイム」の算出に使います。入手先 Pay Period Controlテーブルで、給与グループまたは個別のCheck記録のステータスが「Approved」または「Locked」に変わった時点を取得します。記録トランザクションapprove_pay_groupの実行時に記録イベントタイプ explicit
	インセンティブデータをインポート	歩合給、賞与、一時金などの外部報酬データを取り込む工程です。通常の労働時間データとは別に処理され、多くの場合、バッチファイルをアップロードします。
重要な理由このアクティビティの後に失敗や手戻りが多く発生する場合、データマッピングや外部ファイルの品質に問題がある可能性があります。給与処理が遅れる一般的な原因の1つです。入手先 System LogまたはBatch Import Historyで、ファイルの種類が「Incentives」または「Additional Pay」に該当する記録を取得します。記録トランザクションimport_batch_dataの実行時に記録イベントタイプ explicit
	タイムシートを承認	提出された労働時間を管理者が承認し、支払い処理に使えることを確認する工程です。この承認により、給与計算エンジンへのデータ取り込みが可能になります。
重要な理由この工程のボトルネック分析により、管理者の確認による遅れを特定できます。遅れは、給与担当者がデータを処理できる時間に直接影響します。入手先勤怠管理の履歴で、Statusが「Approved」または「Signed Off」に変わった時点を取得します。記録トランザクションtime_card_approveの実行時に記録イベントタイプ explicit
	タイムシートを提出	従業員または管理者が給与期間の勤怠記録を提出するイベントです。これにより、生の労働時間データが給与ワークフローに取り込まれます。データは給与の中核システムに送られる前に、勤怠管理モジュールで記録される場合があります。
重要な理由給与処理サイクル全体の開始時刻を特定するために使います。勤務実績の発生から給与データの取り込みまでの遅れを測るうえで重要です。入手先勤怠管理の監査ログまたはタイムカード履歴テーブルで、Statusフィールドが「Submitted」に変わった時点を取得します。記録トランザクションtime_card_submitの実行時に記録イベントタイプ explicit
	データを修正	最初の計算後、最終承認前に給与記録を手動で変更することです（例：労働時間の調整、税額の上書き）。
重要な理由手戻りを測る主な指標です。追跡することで、「手動データ修正率」の重要業績評価指標（KPI）を算出できます。入手先監査ログでEmployee Pay DetailまたはDeductionテーブルの更新を取得します。User IDが「System」以外の記録が対象です。記録トランザクションupdate_pay_detailの実行時に記録イベントタイプ explicit
	監査上の例外を検出	システムまたはユーザーが、マイナスの給与、税コードの欠落、SLAに関する警告などの不一致を特定します。この記録は対応が必要な状態になります。
重要な理由「監査上の例外と修正の傾向」ダッシュボードに直接反映されます。この件数が多い場合、上流工程のデータ品質に問題がある可能性があります。入手先 System Warning LogまたはPay Period messagesテーブルから、特定の従業員IDに関連する記録を特定します。記録トランザクションvalidation_warningの作成時に記録イベントタイプ explicit
	福利厚生控除を適用	システムが総支給額から、税引き前・税引き後の福利厚生控除（健康保険、401k）を差し引きます。通常、総支給額の確定直後に処理されます。
重要な理由この工程でエラーが起きると、手動修正が必要になることがあります。工程を切り分けて分析することで、遅延の原因が福利厚生計算エンジンにあるのか、設定にあるのかを判断できます。入手先計算バッチのタイムスタンプ、またはEmployee Deduction Historyテーブルの作成時刻から推定します。記録 calculation_stageフィールドを比較して特定イベントタイプ inferred
	税金を計算	計算エンジンの最終段階です。複数州にまたがる税務ルールを適用し、手取り額を算出します。これにより、自動計算の工程が完了します。
重要な理由「総支給額から手取り額まで」の計算が完了します。この工程に時間がかかる場合、税務計算エンジンのパフォーマンスや、複数の管轄地域にまたがる複雑な設定に問題がある可能性があります。入手先 System Job Logに記録された計算バッチ処理の「End Time」、またはEmployee Taxテーブルのタイムスタンプから推定します。記録計算ジョブの終了前後でステータスフィールドを比較イベントタイプ inferred
	給与明細を公開	セルフサービスポータルで従業員が給与明細を確認できるようになります。これにより、給与に関する情報共有が完了します。
重要な理由技術的に処理を止める工程ではありませんが、公開が遅れるとヘルプデスクへの問い合わせが増え、従業員の満足度にも影響します。入手先「Check Date」、またはPay Groupの設定にある「Self Service Release Date」から推定します。記録 check_dateフィールドとrelease_policyを比較して特定イベントタイプ inferred
	給与計算結果をプレビュー	ユーザーが給与台帳またはプレビューレポートを開き、計算結果を検証します。自動処理から人による確認へ移る段階です。
重要な理由検証段階の開始を示します。計算からプレビューまでに長い時間が空いている場合、人員の確保に問題がある可能性があります。入手先監査ログから、ユーザーが「Payroll Register」または「Pre-Check」レポートにアクセスした記録を取得します。記録トランザクションreport_view_previewの実行時に記録イベントタイプ explicit
	総支給額を計算	労働時間、賃率、インセンティブデータに基づいて、システムが総支給額を算出する最初の計算処理です。控除や税金を適用する前に行われます。
重要な理由ここから「Taxes Calculated」までの時間を測ると、システムのパフォーマンス分析に必要な「総支給額から手取り額までの計算速度」指標を算出できます。入手先 System Job Logに記録された計算バッチ処理の「Start Time」から推定します。記録計算ジョブの開始前後でステータスフィールドを比較イベントタイプ inferred
	銀行振込ファイルを作成	銀行への送信に使うNACHAファイルまたは口座振込ファイルを技術的に作成する工程です。資金を移動できる状態にします。
重要な理由この工程で遅延すると、銀行の受付期限に間に合わないリスクが高まります。「銀行振込ファイルの作成速度」ダッシュボードで確認できます。入手先 System Job Logで、ACH／口座振込ファイルの作成ジョブが完了した時刻を取得します。記録トランザクションcreate_ach_fileの実行時に記録イベントタイプ explicit

推奨任意

データ抽出ガイド

UKG Proからデータを取得する方法

ステップ

ビジネスインテリジェンス（BI）のレポート作成権限を持つアカウントでUKG Proにログインします。
「Administration」に移動し、「Business Intelligence」を選択してIBM Cognos Analyticsを起動します。
新しいレポートを作成し、「Blank」テンプレートを選択します。まず「List」ビジュアライゼーションを選びます。
データモジュールを追加します。データが複数の領域にまたがるため、複数のクエリを組み合わせる構成が必要です。Cognosの「Query Explorer」ビューを開きます。
各アクティビティに対応するクエリサブジェクトを15個作成します（例：Query_TimeSubmit、Query_PayCalc）。それぞれのソースパッケージを割り当てます。時間関連のアクティビティには「Time Management」、計算・支払い関連には「Payroll」、変更・承認には「System Audit」を使用します。
各クエリサブジェクトで、該当するタイムスタンプと識別子を「Data Items」ペインにドラッグします。各クエリにActivityNameという計算データ項目を作成し、「Time Sheet Submitted」などの文字列を固定値として設定します。
すべてのクエリで、PayrollRecordId（EmployeeIDとPayDateを連結）、ActivityName、EventTimestamp、およびその他の必須属性を含む、まったく同じ列を出力するようにします。特定のステップに関係しない指標には0またはNULLを設定し、列の構成をそろえます。
「Query Explorer」でUnion Queryを作成し、15個の個別クエリをすべて追加します。これにより「UNION ALL」処理が実行され、データが縦方向に結合されます。
レポートページのデザインビューに戻り、Listオブジェクトの参照先として作成したUnion Queryを指定します。
レポートにフィルターを追加し、「Pay Period End Date」を希望する抽出期間（例：直近90日間）に絞り込みます。レポートの処理性能を保つために必要です。
まずHTML形式でレポートを実行し、データ行を確認します。アクティビティの種類が異なっても、列が正しくそろっていることを確認してください。
レポートを「ProcessMind_Extraction_Report」という名前で保存します。週次で実行するようスケジュールし、出力をCSVファイルとしてSFTPサーバーに送信し、ProcessMindに取り込めるようにします。

設定

データパッケージ：UKG Business Intelligence内のPayroll、Time Management、System Auditの各データパッケージへのアクセスが必要です。
権限：レポートを実行するユーザーには、機密性の高い給与データ（Gross Pay）と監査ログを閲覧する権限が必要です。
日付範囲：「Transaction Date」ではなく「Pay Period End Date」で絞り込むことを推奨します。ケースの履歴全体を保持できます。まずは直近6か月を対象にしてください。
識別子の作成：ケースID（PayrollRecordId）は一貫した形式にする必要があります。サイクルを一意に識別するため、従業員番号と給与期間終了日を連結します（形式：EMP123-20231031）。
処理性能：System Auditのテーブルは非常に大きくなる場合があります。タイムアウトを防ぐため、監査クエリには特に厳密な日付フィルターを適用してください。
タイムゾーン：UKG Proでは、時刻がUTCまたはサーバー時刻で保存されることがよくあります。イベントログで現地時刻が必要な場合は、時差を確認し、必要に応じて計算（例：_add_hours）を適用してください。

クエリの例 sql

/* 
   UKG PRO COGNOS ANALYTICS - REPORT SPECIFICATION LOGIC 
   Language: Cognos Expression / Pseudo-SQL Configuration
   NOTE: This logic represents the 15 segments required in the Union Query.
   Each block represents a separate Query Subject in Cognos that must be Unioned.
*/

/* 1. Time Sheet Submitted */
SELECT
  ([TimeMgmt].[EmployeeID] + '-' + [TimeMgmt].[PayPeriodEnd]) AS PayrollRecordId,
  'Time Sheet Submitted' AS ActivityName,
  [TimeMgmt].[Timecard_Submission_Date] AS EventTimestamp,
  'UKG Time' AS SourceSystem,
  [TimeMgmt].[Last_Updated] AS LastUpdateDate,
  [TimeMgmt].[Approver_ID] AS PayrollSpecialist,
  [TimeMgmt].[Gross_Pay_Est] AS GrossPayAmount,
  [TimeMgmt].[Department] AS DepartmentCode,
  [TimeMgmt].[PayGroup] AS PayGroup
FROM [Time Management Package]
WHERE [TimeMgmt].[Status] = 'Submitted'

UNION ALL

/* 2. Time Sheet Approved */
SELECT
  ([TimeMgmt].[EmployeeID] + '-' + [TimeMgmt].[PayPeriodEnd]) AS PayrollRecordId,
  'Time Sheet Approved' AS ActivityName,
  [TimeMgmt].[Timecard_Approval_Date] AS EventTimestamp,
  'UKG Time' AS SourceSystem,
  [TimeMgmt].[Last_Updated] AS LastUpdateDate,
  [TimeMgmt].[Manager_ID] AS PayrollSpecialist,
  [TimeMgmt].[Gross_Pay_Est] AS GrossPayAmount,
  [TimeMgmt].[Department] AS DepartmentCode,
  [TimeMgmt].[PayGroup] AS PayGroup
FROM [Time Management Package]
WHERE [TimeMgmt].[Status] = 'Approved'

UNION ALL

/* 3. Payroll Record Initialized */
SELECT
  ([PayRegister].[EmployeeID] + '-' + [PayRegister].[PeriodEndDate]) AS PayrollRecordId,
  'Payroll Record Initialized' AS ActivityName,
  [PayRegister].[Record_Creation_Date] AS EventTimestamp,
  'UKG Payroll' AS SourceSystem,
  [PayRegister].[Last_Mod_Date] AS LastUpdateDate,
  'System' AS PayrollSpecialist,
  0 AS GrossPayAmount,
  [PayRegister].[Home_Dept] AS DepartmentCode,
  [PayRegister].[PayGroup] AS PayGroup
FROM [Payroll Data Package]

UNION ALL

/* 4. Incentive Data Imported */
SELECT
  ([PayDetail].[EmployeeID] + '-' + [PayDetail].[PeriodEndDate]) AS PayrollRecordId,
  'Incentive Data Imported' AS ActivityName,
  [PayDetail].[Import_Date] AS EventTimestamp,
  'UKG Payroll' AS SourceSystem,
  [PayDetail].[Import_Date] AS LastUpdateDate,
  [PayDetail].[User_ID] AS PayrollSpecialist,
  [PayDetail].[Amount] AS GrossPayAmount,
  [PayDetail].[Department] AS DepartmentCode,
  [PayDetail].[PayGroup] AS PayGroup
FROM [Payroll Detail Package]
WHERE [PayDetail].[Source_Type] = 'Import' AND [PayDetail].[Earn_Ded_Type] = 'Earning'

UNION ALL

/* 5. Gross Pay Calculated */
SELECT
  ([PayHistory].[EmployeeID] + '-' + [PayHistory].[PeriodEndDate]) AS PayrollRecordId,
  'Gross Pay Calculated' AS ActivityName,
  [PayHistory].[Calculation_Time] AS EventTimestamp,
  'UKG Calc Engine' AS SourceSystem,
  [PayHistory].[Calculation_Time] AS LastUpdateDate,
  'System' AS PayrollSpecialist,
  [PayHistory].[Total_Gross] AS GrossPayAmount,
  [PayHistory].[Department] AS DepartmentCode,
  [PayHistory].[PayGroup] AS PayGroup
FROM [Payroll History Package]

UNION ALL

/* 6. Benefits Deductions Applied */
SELECT
  ([PayHistory].[EmployeeID] + '-' + [PayHistory].[PeriodEndDate]) AS PayrollRecordId,
  'Benefits Deductions Applied' AS ActivityName,
  _add_seconds([PayHistory].[Calculation_Time], 5) AS EventTimestamp,
  'UKG Calc Engine' AS SourceSystem,
  [PayHistory].[Calculation_Time] AS LastUpdateDate,
  'System' AS PayrollSpecialist,
  [PayHistory].[Total_Gross] AS GrossPayAmount,
  [PayHistory].[Department] AS DepartmentCode,
  [PayHistory].[PayGroup] AS PayGroup
FROM [Payroll History Package]
WHERE [PayHistory].[Total_Deductions] > 0

UNION ALL

/* 7. Taxes Calculated */
SELECT
  ([PayHistory].[EmployeeID] + '-' + [PayHistory].[PeriodEndDate]) AS PayrollRecordId,
  'Taxes Calculated' AS ActivityName,
  _add_seconds([PayHistory].[Calculation_Time], 10) AS EventTimestamp,
  'UKG Tax Engine' AS SourceSystem,
  [PayHistory].[Calculation_Time] AS LastUpdateDate,
  'System' AS PayrollSpecialist,
  [PayHistory].[Total_Gross] AS GrossPayAmount,
  [PayHistory].[Department] AS DepartmentCode,
  [PayHistory].[PayGroup] AS PayGroup
FROM [Payroll History Package]
WHERE [PayHistory].[Total_Taxes] > 0

UNION ALL

/* 8. Payroll Result Previewed */
SELECT
  ([AuditLog].[Target_EmployeeID] + '-' + [AuditLog].[Context_Date]) AS PayrollRecordId,
  'Payroll Result Previewed' AS ActivityName,
  [AuditLog].[Access_Time] AS EventTimestamp,
  'UKG Audit' AS SourceSystem,
  [AuditLog].[Access_Time] AS LastUpdateDate,
  [AuditLog].[User_Name] AS PayrollSpecialist,
  0 AS GrossPayAmount,
  [AuditLog].[Department] AS DepartmentCode,
  [AuditLog].[PayGroup] AS PayGroup
FROM [System Audit Package]
WHERE [AuditLog].[Action] = 'View Report' AND [AuditLog].[Report_Name] LIKE '%Pay Register%'

UNION ALL

/* 9. Audit Exception Flagged */
SELECT
  ([PayMessages].[EmployeeID] + '-' + [PayMessages].[PeriodEndDate]) AS PayrollRecordId,
  'Audit Exception Flagged' AS ActivityName,
  [PayMessages].[Message_Time] AS EventTimestamp,
  'UKG Payroll' AS SourceSystem,
  [PayMessages].[Message_Time] AS LastUpdateDate,
  'System' AS PayrollSpecialist,
  0 AS GrossPayAmount,
  [PayMessages].[Department] AS DepartmentCode,
  [PayMessages].[PayGroup] AS PayGroup
FROM [Payroll Messages Package]
WHERE [PayMessages].[Severity] IN ('Warning', 'Error')

UNION ALL

/* 10. Data Correction Performed */
SELECT
  ([AuditData].[EmployeeID] + '-' + [AuditData].[Target_Period_End]) AS PayrollRecordId,
  'Data Correction Performed' AS ActivityName,
  [AuditData].[Change_Time] AS EventTimestamp,
  'UKG Audit' AS SourceSystem,
  [AuditData].[Change_Time] AS LastUpdateDate,
  [AuditData].[User_Changed_By] AS PayrollSpecialist,
  0 AS GrossPayAmount,
  [AuditData].[Department] AS DepartmentCode,
  [AuditData].[PayGroup] AS PayGroup
FROM [Data Audit Package]
WHERE [AuditData].[Table_Name] = 'PayData' AND [AuditData].[Operation] = 'Update'

UNION ALL

/* 11. Payroll Record Approved */
SELECT
  ([PayControl].[EmployeeID] + '-' + [PayControl].[PeriodEndDate]) AS PayrollRecordId,
  'Payroll Record Approved' AS ActivityName,
  [PayControl].[Approval_Time] AS EventTimestamp,
  'UKG Payroll' AS SourceSystem,
  [PayControl].[Approval_Time] AS LastUpdateDate,
  [PayControl].[Approver_ID] AS PayrollSpecialist,
  [PayControl].[Final_Gross] AS GrossPayAmount,
  [PayControl].[Department] AS DepartmentCode,
  [PayControl].[PayGroup] AS PayGroup
FROM [Payroll Control Package]
WHERE [PayControl].[Status] = 'Finalized'

UNION ALL

/* 12. Bank Transfer File Generated */
SELECT
  ([AchFile].[EmployeeID] + '-' + [AchFile].[PeriodEndDate]) AS PayrollRecordId,
  'Bank Transfer File Generated' AS ActivityName,
  [AchFile].[File_Creation_Timestamp] AS EventTimestamp,
  'UKG Banking' AS SourceSystem,
  [AchFile].[File_Creation_Timestamp] AS LastUpdateDate,
  [AchFile].[Generated_By] AS PayrollSpecialist,
  [AchFile].[Net_Pay] AS GrossPayAmount,
  [AchFile].[Department] AS DepartmentCode,
  [AchFile].[PayGroup] AS PayGroup
FROM [Banking / ACH Package]

UNION ALL

/* 13. Payment Executed */
SELECT
  ([CheckRegister].[EmployeeID] + '-' + [CheckRegister].[PeriodEndDate]) AS PayrollRecordId,
  'Payment Executed' AS ActivityName,
  [CheckRegister].[Check_Date] AS EventTimestamp,
  'UKG Payment' AS SourceSystem,
  [CheckRegister].[Check_Date] AS LastUpdateDate,
  'System' AS PayrollSpecialist,
  [CheckRegister].[Gross_Amount] AS GrossPayAmount,
  [CheckRegister].[Department] AS DepartmentCode,
  [CheckRegister].[PayGroup] AS PayGroup
FROM [Check Register Package]

UNION ALL

/* 14. Pay Slip Published */
SELECT
  ([CheckRegister].[EmployeeID] + '-' + [CheckRegister].[PeriodEndDate]) AS PayrollRecordId,
  'Pay Slip Published' AS ActivityName,
  [CheckRegister].[Advice_Available_Date] AS EventTimestamp,
  'UKG Self Service' AS SourceSystem,
  [CheckRegister].[Advice_Available_Date] AS LastUpdateDate,
  'System' AS PayrollSpecialist,
  0 AS GrossPayAmount,
  [CheckRegister].[Department] AS DepartmentCode,
  [CheckRegister].[PayGroup] AS PayGroup
FROM [Check Register Package]
WHERE [CheckRegister].[Is_Void] = 'False'

UNION ALL

/* 15. Tax Filing Completed */
SELECT
  ([TaxHistory].[EmployeeID] + '-' + [TaxHistory].[PeriodEndDate]) AS PayrollRecordId,
  'Tax Filing Completed' AS ActivityName,
  [TaxHistory].[Filing_Submission_Date] AS EventTimestamp,
  'UKG Tax' AS SourceSystem,
  [TaxHistory].[Last_Update] AS LastUpdateDate,
  'System' AS PayrollSpecialist,
  0 AS GrossPayAmount,
  [TaxHistory].[Department] AS DepartmentCode,
  [TaxHistory].[PayGroup] AS PayGroup
FROM [Tax Filing Package]
WHERE [TaxHistory].[Status] = 'Filed'

ステップ

前提条件と認証：UKG Pro管理者から、Client ID、Client Secret、API KeyなどのUKG Pro Web Services API認証情報を取得します。関連するサービスアカウントにPayrollとAudit APIのスコープへの権限があることを確認してください。対象となるエンドポイントには、/payroll/pay-history/pay-summaries、/payroll/pay-statements、/platform/v1/audit/logsなどがあります。
Python環境の準備：端末にPythonをインストールします。ターミナルでpip install requests pandasを実行し、APIリクエストとデータ処理に必要なライブラリをインストールします。
Pythonスクリプトの作成：「query」セクションにあるPythonコードをextract_ukg_payroll.pyという名前のファイルに保存します。同じディレクトリに.envファイルを作成してAPI認証情報を安全に保存するか、システムの環境変数として設定します。
スクリプトパラメーターの設定：スクリプトを開き、プレースホルダーの値を変更します。API_BASE_URLには組織のUKG ProインスタンスのURLを設定します。START_DATEとEND_DATEを変更し、直近3～6か月など、希望する抽出期間を指定します。
スクリプトの実行：ターミナルでpython extract_ukg_payroll.pyを実行します。スクリプトが認証を行い、該当するUKG Proエンドポイントからデータを取得して、ページネーションを自動的に処理します。
データの取得と変換：スクリプトはまずアクセストークンを取得します。次に、指定した日付範囲の給与サマリーデータと監査ログを取得し、各レコードを処理して必要なアクティビティに対応するイベント一覧を作成します。
アクティビティ行の作成：各給与レコードについて、15種類のアクティビティごとに個別の行を作成します。ステータス変更やタイムスタンプなどのAPIデータ項目を、「Gross Pay Calculated」「Payroll Record Approved」「Payment Executed」などのアクティビティに対応付けます。
派生属性の計算：初期イベントログの作成後、追加の属性を計算します。給与処理の開始から支払いまでのCycleTimeDaysを算出し、支払日とSLA期限を比較してIsSlaBreachedフラグを設定します。
イベントログのエクスポート：作成したすべてのイベントをpandasのDataFrameにまとめ、ukg_payroll_event_log.csvという名前のCSVファイルに保存します。このファイルはProcessMindに直接アップロードできる形式です。
確認とアップロード：作成したCSVファイルを開き、データの完全性と正確性を確認します。検証が完了したら、ProcessMindのプロジェクトにアップロードしてプロセスマイニング分析を開始します。

設定

前提条件：APIアクセス権を持つUKG Proサービスアカウントが必要です。このアカウントには、/payroll/と/platform/v1/audit/のスコープに対する読み取り権限が必要です。
API認証情報：Client ID、Client Secret、API Key、APIホスト名（ベースURL）を環境変数またはスクリプト内に設定します。
日付範囲：スクリプトではSTART_DATEとEND_DATEの設定が必要です。初回の分析では、データ量と処理性能のバランスを考慮し、3～6か月の範囲を推奨します。
フィルタリング：APIリクエストURL内のcompanyIdやpayGroupなどのパラメーターを指定し、対象となる従業員に絞り込むようスクリプトを変更できます。
ページネーションの処理：スクリプトはAPIのページネーションを自動的に処理します。通常は1回の呼び出しで100件という上限を超える場合も、指定した日付範囲内のすべてのレコードを取得できます。
エンドポイントへの依存：抽出データの品質は、特に承認や修正などのワークフロー上のアクティビティについて、/platform/v1/audit/logsエンドポイントの利用可否とデータの充実度に大きく左右されます。UKG Proの環境でこのエンドポイントが有効になっており、関連イベントを記録するよう設定されていることを確認してください。

クエリの例 python

import requests
import pandas as pd
import os
import json
from datetime import datetime, timedelta

class=class="hl-string">"hl-comment"># --- Configuration ---
class=class="hl-string">"hl-comment"># Load credentials from environment variables for security
CLIENT_ID = os.environ.get(class="hl-string">'UKG_CLIENT_ID', class="hl-string">'YOUR_CLIENT_ID')
CLIENT_SECRET = os.environ.get(class="hl-string">'UKG_CLIENT_SECRET', class="hl-string">'YOUR_CLIENT_SECRET')
API_KEY = os.environ.get(class="hl-string">'UKG_API_KEY', class="hl-string">'YOUR_API_KEY')
API_BASE_URL = os.environ.get(class="hl-string">'UKG_BASE_URL', class="hl-string">'https://api.ukg.com') class=class="hl-string">"hl-comment"># Adjust if you have a different base URL

class=class="hl-string">"hl-comment"># Set the desired date range for the extraction
START_DATE = class="hl-string">'2023-01-01T00:00:00Z'
END_DATE = class="hl-string">'2023-06-30T23:59:59Z'

def get_access_token():
    class="hl-string">"""Authenticates with UKG Pro and retrieves a bearer token."""
    auth_url = fclass="hl-string">"{API_BASE_URL}/auth/token"
    headers = {class="hl-string">'Content-Type': class="hl-string">'application/json', class="hl-string">'x-api-key': API_KEY}
    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,
        class="hl-string">'scope': class="hl-string">'payroll'
    }
    try:
        response = requests.post(auth_url, headers=headers, data=json.dumps(payload))
        response.raise_for_status()
        return response.json().get(class="hl-string">'access_token')
    except requests.exceptions.RequestException as e:
        print(fclass="hl-string">"Error getting access token: {e}")
        return None

def fetch_paginated_data(url, headers):
    class="hl-string">"""Fetches all pages of data from a UKG Pro API endpoint."""
    all_records = []
    while url:
        try:
            response = requests.get(url, headers=headers)
            response.raise_for_status()
            data = response.json()
            all_records.extend(data)

            class=class="hl-string">"hl-comment"># UKG Pro uses a class="hl-string">'Link' header for pagination
            next_link = response.headers.get(class="hl-string">'Link')
            url = None
            if next_link:
                links = next_link.split(class="hl-string">',')
                for link in links:
                    if class="hl-string">'rel="next"' in link:
                        url = link[link.find(class="hl-string">'<')+1:link.find(class="hl-string">'>')]
                        break
        except requests.exceptions.RequestException as e:
            print(fclass="hl-string">"Error fetching data from {url}: {e}")
            break
    return all_records

def main():
    class="hl-string">"""Main function to extract, transform, and save payroll data."""
    token = get_access_token()
    if not token:
        print(class="hl-string">"Failed to authenticate. Exiting.")
        return

    headers = {
        class="hl-string">'Authorization': fclass="hl-string">'Bearer {token}',
        class="hl-string">'x-api-key': API_KEY
    }

    print(class="hl-string">"Fetching payroll history summaries...")
    class=class="hl-string">"hl-comment"># This endpoint provides core pay calculation and payment data.
    class=class="hl-string">"hl-comment"># We filter by payPeriodEndDate for a relevant time slice.
    pay_history_url = fclass="hl-string">"{API_BASE_URL}/v1/payroll/pay-history/pay-summaries?payPeriodEndDate_from={START_DATE}&payPeriodEndDate_to={END_DATE}&per_page=100"
    pay_records = fetch_paginated_data(pay_history_url, headers)

    class=class="hl-string">"hl-comment"># Note: A comprehensive audit log endpoint is assumed for workflow steps.
    class=class="hl-string">"hl-comment"># The exact endpoint and filter parameters may vary. This is a representative example.
    print(class="hl-string">"Fetching audit log data for workflow events...")
    audit_log_url = fclass="hl-string">"{API_BASE_URL}/platform/v1/audit/logs?startTime={START_DATE}&endTime={END_DATE}&per_page=100"
    audit_logs = fetch_paginated_data(audit_log_url, headers)

    class=class="hl-string">"hl-comment"># Process audit logs into a dictionary for easy lookup
    audit_events_by_record = {}
    for log in audit_logs:
        class=class="hl-string">"hl-comment"># Assumption: The audit log contains a reference to the payroll record ID
        record_id = log.get(class="hl-string">'entityId')
        if record_id:
            if record_id not in audit_events_by_record:
                audit_events_by_record[record_id] = []
            audit_events_by_record[record_id].append(log)

    events = []
    print(fclass="hl-string">"Processing {len(pay_records)} payroll records...")
    for record in pay_records:
        payroll_record_id = fclass="hl-string">"{record.get('employeeId')}-{record.get('payPeriodEndDate')}"
        pay_date = datetime.fromisoformat(record.get(class="hl-string">'checkDate').replace(class="hl-string">'Z', class="hl-string">'+00:00'))
        pay_period_end_date = datetime.fromisoformat(record.get(class="hl-string">'payPeriodEndDate').replace(class="hl-string">'Z', class="hl-string">'+00:00'))
        class=class="hl-string">"hl-comment"># Heuristic: Assume initialization happens 1 day after period end
        initialized_ts = pay_period_end_date + timedelta(days=1)
        class=class="hl-string">"hl-comment"># Heuristic: Assume calculation happens 3 days after period end
        calculated_ts = pay_period_end_date + timedelta(days=3)
        
        class=class="hl-string">"hl-comment"># Use a placeholder for SLA deadline, e.g., 1 day before pay date
        sla_deadline = pay_date - timedelta(days=1)

        common_attributes = {
            class="hl-string">'PayrollRecordId': payroll_record_id,
            class="hl-string">'SourceSystem': class="hl-string">'UKG Pro',
            class="hl-string">'PayrollSpecialist': record.get(class="hl-string">'processingUser', class="hl-string">'System'),
            class="hl-string">'DepartmentCode': record.get(class="hl-string">'department'),
            class="hl-string">'CostCenter': record.get(class="hl-string">'costCenter'),
            class="hl-string">'PayGroup': record.get(class="hl-string">'payGroup'),
            class="hl-string">'GrossPayAmount': record.get(class="hl-string">'grossEarnings'),
            class="hl-string">'TaxJurisdiction': record.get(class="hl-string">'primaryTaxState'),
            class="hl-string">'SlaProcessingDeadline': sla_deadline.isoformat(),
            class="hl-string">'IsOffCycle': record.get(class="hl-string">'isOffCycle', False),
            class="hl-string">'PayPeriodEndDate': pay_period_end_date.isoformat(),
            class="hl-string">'HasAuditException': False, class=class="hl-string">"hl-comment"># To be updated by audit events
        }

        class=class="hl-string">"hl-comment"># 1. Time Sheet Submitted (from audit)
        class=class="hl-string">"hl-comment"># 2. Time Sheet Approved (from audit)
        class=class="hl-string">"hl-comment"># These events are highly dependent on audit log content. Using placeholders.
        events.append({**common_attributes, class="hl-string">'ActivityName': class="hl-string">'Time Sheet Submitted', class="hl-string">'EventTimestamp': (initialized_ts - timedelta(hours=12)).isoformat()})
        events.append({**common_attributes, class="hl-string">'ActivityName': class="hl-string">'Time Sheet Approved', class="hl-string">'EventTimestamp': (initialized_ts - timedelta(hours=6)).isoformat()})

        class=class="hl-string">"hl-comment"># 3. Payroll Record Initialized
        events.append({**common_attributes, class="hl-string">'ActivityName': class="hl-string">'Payroll Record Initialized', class="hl-string">'EventTimestamp': initialized_ts.isoformat()})

        class=class="hl-string">"hl-comment"># 4. Incentive Data Imported (from audit)
        events.append({**common_attributes, class="hl-string">'ActivityName': class="hl-string">'Incentive Data Imported', class="hl-string">'EventTimestamp': (initialized_ts + timedelta(days=1)).isoformat()})

        class=class="hl-string">"hl-comment"># 5-7. Calculation Steps
        events.append({**common_attributes, class="hl-string">'ActivityName': class="hl-string">'Gross Pay Calculated', class="hl-string">'EventTimestamp': calculated_ts.isoformat()})
        events.append({**common_attributes, class="hl-string">'ActivityName': class="hl-string">'Benefits Deductions Applied', class="hl-string">'EventTimestamp': (calculated_ts + timedelta(seconds=10)).isoformat()})
        events.append({**common_attributes, class="hl-string">'ActivityName': class="hl-string">'Taxes Calculated', class="hl-string">'EventTimestamp': (calculated_ts + timedelta(seconds=20)).isoformat()})

        class=class="hl-string">"hl-comment"># 8. Payroll Result Previewed (from audit)
        events.append({**common_attributes, class="hl-string">'ActivityName': class="hl-string">'Payroll Result Previewed', class="hl-string">'EventTimestamp': (calculated_ts + timedelta(hours=1)).isoformat()})

        class=class="hl-string">"hl-comment"># 9-10. Audit/Correction Events (from audit log)
        record_audits = audit_events_by_record.get(payroll_record_id, [])
        for audit_event in record_audits:
            event_ts = audit_event.get(class="hl-string">'eventDateTime')
            if class="hl-string">'Exception' in audit_event.get(class="hl-string">'eventName', class="hl-string">''):
                events.append({**common_attributes, class="hl-string">'ActivityName': class="hl-string">'Audit Exception Flagged', class="hl-string">'EventTimestamp': event_ts, class="hl-string">'HasAuditException': True})
            if class="hl-string">'Correction' in audit_event.get(class="hl-string">'eventName', class="hl-string">''):
                events.append({**common_attributes, class="hl-string">'ActivityName': class="hl-string">'Data Correction Performed', class="hl-string">'EventTimestamp': event_ts})

        class=class="hl-string">"hl-comment"># 11. Payroll Record Approved
        class=class="hl-string">"hl-comment"># Heuristic: Approval happens 2 days before pay date
        approved_ts = pay_date - timedelta(days=2)
        events.append({**common_attributes, class="hl-string">'ActivityName': class="hl-string">'Payroll Record Approved', class="hl-string">'EventTimestamp': approved_ts.isoformat()})

        class=class="hl-string">"hl-comment"># 12. Bank Transfer File Generated
        class=class="hl-string">"hl-comment"># Heuristic: File is generated the day before pay date
        bank_file_ts = pay_date - timedelta(days=1, hours=4)
        events.append({**common_attributes, class="hl-string">'ActivityName': class="hl-string">'Bank Transfer File Generated', class="hl-string">'EventTimestamp': bank_file_ts.isoformat()})
        
        class=class="hl-string">"hl-comment"># 13. Payment Executed
        events.append({**common_attributes, class="hl-string">'ActivityName': class="hl-string">'Payment Executed', class="hl-string">'EventTimestamp': pay_date.isoformat()})

        class=class="hl-string">"hl-comment"># 14. Pay Slip Published
        class=class="hl-string">"hl-comment"># Assumption: Published on the pay date
        events.append({**common_attributes, class="hl-string">'ActivityName': class="hl-string">'Pay Slip Published', class="hl-string">'EventTimestamp': (pay_date + timedelta(hours=8)).isoformat()})

        class=class="hl-string">"hl-comment"># 15. Tax Filing Completed
        class=class="hl-string">"hl-comment"># Heuristic: Filing completed 2 days after pay date
        tax_filed_ts = pay_date + timedelta(days=2)
        events.append({**common_attributes, class="hl-string">'ActivityName': class="hl-string">'Tax Filing Completed', class="hl-string">'EventTimestamp': tax_filed_ts.isoformat()})

    if not events:
        print(class="hl-string">"No events generated. Check API response or date range.")
        return

    class=class="hl-string">"hl-comment"># Create DataFrame and add final attributes
    df = pd.DataFrame(events)
    df[class="hl-string">'EventTimestamp'] = pd.to_datetime(df[class="hl-string">'EventTimestamp'])
    df = df.sort_values(by=[class="hl-string">'PayrollRecordId', class="hl-string">'EventTimestamp']).reset_index(drop=True)

    df[class="hl-string">'LastUpdateDate'] = datetime.now().isoformat()

    class=class="hl-string">"hl-comment"># Calculate cycle time and SLA breach
    start_times = df[df[class="hl-string">'ActivityName'] == class="hl-string">'Payroll Record Initialized'][[class="hl-string">'PayrollRecordId', class="hl-string">'EventTimestamp']].rename(columns={class="hl-string">'EventTimestamp': class="hl-string">'StartTime'})
    end_times = df[df[class="hl-string">'ActivityName'] == class="hl-string">'Payment Executed'][[class="hl-string">'PayrollRecordId', class="hl-string">'EventTimestamp']].rename(columns={class="hl-string">'EventTimestamp': class="hl-string">'EndTime'})
    sla_deadlines = df[[class="hl-string">'PayrollRecordId', class="hl-string">'SlaProcessingDeadline']].drop_duplicates()

    df = df.merge(start_times, on=class="hl-string">'PayrollRecordId', how=class="hl-string">'left')
    df = df.merge(end_times, on=class="hl-string">'PayrollRecordId', how=class="hl-string">'left')
    df = df.merge(sla_deadlines, on=class="hl-string">'PayrollRecordId', how=class="hl-string">'left')

    df[class="hl-string">'CycleTimeDays'] = (df[class="hl-string">'EndTime'] - df[class="hl-string">'StartTime']).dt.total_seconds() / (24 * 3600)
    df[class="hl-string">'IsSlaBreached'] = df[class="hl-string">'EndTime'] > pd.to_datetime(df[class="hl-string">'SlaProcessingDeadline'])
    
    df.drop(columns=[class="hl-string">'StartTime', class="hl-string">'EndTime'], inplace=True)

    class=class="hl-string">"hl-comment"># Reorder columns to match requirements
    final_columns = [
        class="hl-string">'PayrollRecordId', class="hl-string">'ActivityName', class="hl-string">'EventTimestamp', class="hl-string">'SourceSystem', class="hl-string">'LastUpdateDate',
        class="hl-string">'PayrollSpecialist', class="hl-string">'DepartmentCode', class="hl-string">'CostCenter', class="hl-string">'PayGroup', class="hl-string">'GrossPayAmount',
        class="hl-string">'TaxJurisdiction', class="hl-string">'SlaProcessingDeadline', class="hl-string">'IsOffCycle', class="hl-string">'HasAuditException',
        class="hl-string">'PayPeriodEndDate', class="hl-string">'IsSlaBreached', class="hl-string">'CycleTimeDays'
    ]
    df = df[final_columns]

    class=class="hl-string">"hl-comment"># Save to CSV
    output_filename = class="hl-string">'ukg_payroll_event_log.csv'
    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()

準備はよろしいですか？

このテンプレートを使って、UKG Proの生のデータをプロセスマップに変換できます。複雑な給与処理環境からのデータ抽出設定でお困りの場合は、サポートチームにご相談ください。

改善ガイドに戻る

テンプレートをダウンロード

今すぐUKG Proの給与処理を最適化

給与処理のサイクルタイムを30％短縮し、ボトルネックを解消します。

無料トライアルを開始しましょう。

クレジットカード不要。5分で設定できます。

給与処理データテンプレート

給与処理データテンプレート

給与処理の属性

給与処理のアクティビティ

データ抽出ガイド

UKG Proのビジネスインテリジェンスレポートのエクスポート

ステップ

設定

クエリの例 sql

UKG Pro Web Services APIからのPythonデータ抽出

ステップ

設定

クエリの例 python

準備はよろしいですか？

今すぐUKG Proの給与処理を最適化