diff options
| author | T-Aji <tolujbd2@gmail.com> | 2024-08-23 09:33:17 +0100 |
|---|---|---|
| committer | T-Aji <tolujbd2@gmail.com> | 2024-08-23 09:33:17 +0100 |
| commit | a8cadadfe2b96c84a29a252110822ec535a0da7e (patch) | |
| tree | 080dcdc4e29426437987a04aa257e3c2fe3bc8b8 /src/fact_sales_order.py | |
| parent | c5bc22b0e4e637eb20b1057af937c6eda1def4fa (diff) | |
| download | de-project-bentley-a8cadadfe2b96c84a29a252110822ec535a0da7e.tar.gz de-project-bentley-a8cadadfe2b96c84a29a252110822ec535a0da7e.zip | |
payment schema added
Diffstat (limited to 'src/fact_sales_order.py')
| -rw-r--r-- | src/fact_sales_order.py | 18 |
1 files changed, 16 insertions, 2 deletions
diff --git a/src/fact_sales_order.py b/src/fact_sales_order.py index b657d7d..425b144 100644 --- a/src/fact_sales_order.py +++ b/src/fact_sales_order.py @@ -44,7 +44,8 @@ def create_fact_sales_order(dict_of_df): df_sales["created_time"] = pd.to_datetime(df_sales["created_at"]).dt.time df_sales["last_updated_date"] = pd.to_datetime(df_sales["last_updated"]).dt.date df_sales["last_updated_time"] = pd.to_datetime(df_sales["last_updated"]).dt.time - df_sales.rename(columns={"staff_id": "sales_staff_id"}) + pd.merge(dict_of_df["staff"], df_sales["sales_staff_id"], on="staff_id", how="left") + # df_sales.rename(columns={"staff_id": "sales_staff_id"}) fact_sales_order = df_sales.loc[:,[ "sales_record_id", "sales_order_id", @@ -70,7 +71,20 @@ def create_fact_sales_order(dict_of_df): # remove duplicates # test dim_date and fact_sales_order - +def create_sales_star_schema(dict_of_df): + dim_design = create_dim_design(dict_of_df) + dim_staff = create_dim_staff(dict_of_df) + dim_currency = create_dim_currency(dict_of_df) + dim_date = create_dim_date(dict_of_df) + + fact_sales_order = create_fact_sales_order(dict_of_df) + + fact_sales_order = fact_sales_order.merge(dim_design, on='design_id', how='left') + fact_sales_order = fact_sales_order.merge(dim_staff, left_on='sales_staff_id', right_on='staff_id', how='left') + fact_sales_order = fact_sales_order.merge(dim_currency, on='currency_id', how='left') + fact_sales_order = fact_sales_order.merge(dim_date, left_on='agreed_delivery_date', right_on='date_id', how='left') + + return fact_sales_order |