From a8cadadfe2b96c84a29a252110822ec535a0da7e Mon Sep 17 00:00:00 2001
From: T-Aji <tolujbd2@gmail.com>
Date: Fri, 23 Aug 2024 09:33:17 +0100
Subject: payment schema added

---
 src/fact_payment.py | 30 ++++++++++++++++++++++++++++++
 1 file changed, 30 insertions(+)
 create mode 100644 src/fact_payment.py

(limited to 'src/fact_payment.py')

diff --git a/src/fact_payment.py b/src/fact_payment.py
new file mode 100644
index 0000000..92de67c
--- /dev/null
+++ b/src/fact_payment.py
@@ -0,0 +1,30 @@
+import pandas as pd
+
+def create_dim_payment_type(dict_of_df):
+    df_payment_type = dict_of_df["payment_type"]
+    dim_payment_type = df_payment_type.loc[:, ["payment_type_id", "payment_type_name"]]
+    return dim_payment_type
+
+def create_fact_payment(dict_of_df):
+    df_payment = dict_of_df["payment"]
+    df_payment.index.name = "payment_record_id"
+    df_payment["created_date"] = pd.to_datetime(df_payment["created_at"]).dt.date
+    df_payment["created_time"] = pd.to_datetime(df_payment["created_at"]).dt.time
+    df_payment["last_updated_date"] = pd.to_datetime(df_payment["last_updated"]).dt.date
+    df_payment["last_updated_time"] = pd.to_datetime(df_payment["last_updated"]).dt.time
+    fact_payment = df_payment.loc[:,[
+        "payment_record_id",
+        "payment_id",
+        "created_date",
+        "created_time",
+        "last_updated_date",
+        "last_updated_time",
+        "transaction_id",
+        "counterparty_id",
+        "payment_amount",
+        "currency_id",
+        "payment_type_id",
+        "paid",
+        "payment_date"
+    ]]
+    return fact_payment
-- 
cgit v1.2.3