Merge pull request #30 from marielestavel/stock_entries_new_model

Introduce `viz_operations__stock_entries_sources` and delete existing models

Author: marielestavel

dbt-models/models/schema.yml

@@ -123,11 +123,15 @@ models:
  - name: lifetime_visit_count
  description: The total number of visits of the member's family since they first visited
 
- - name: viz_operations__stock_entries_collection_dates
- description: Model containing stock entries by product on collection days
+ - name: viz_operations__stock_entries_sources
+ description: Model containing stock entries metrics by sources at the product-level.
  columns:
  - name: date_at
  description: The date when the operation occurred
+ - name: source
+ description: > 
+ The acquisition channel for this operation.
+ Either 'Pleins Courses', 'Collectes Supermarché' or 'Enlèvements BAPIF'
  - name: product_name
  description: The name of the product
  - name: unit_of_measure
@@ -149,30 +153,3 @@ models:
  description: > 
  The corresponding monetary value in euro of the products brought into stock
  calculated based on the average price of a product unit.
-
- - name: viz_operations__stock_entries_shopping_dates
- description: Model containing stock entries by product on grocery shopping days
- columns:
- - name: date_at
- description: The date when the operation occurred
- - name: product_name
- description: The name of the product
- - name: unit_of_measure
- description: >
- Unit of measure for a given product
- eg: 'Paquet' for 'Biscuits'
- - name: units_per_batch
- description: Number of product units given per batch
- - name: date_latest_shopping
- description: The date of the lastest grocery shopping
- - name: unit_entries
- description: The quantity of product units entered in stock
- - name: batch_quantity
- description: > 
- The corresponding quantity of product units in product batch.
- Eg: If diapers are given in batches of 10 to families, 
- then 10 unit entries correspond to 1 product batch stock entry.
- - name: monetary_value_eur
- description: > 
- The corresponding monetary value in euro of the products brought into stock
- calculated based on the average price of a product unit.

dbt-models/models/viz_operations__stock_entries_collection_dates.sql

@@ -0,0 +1,47 @@
+with product_operations as (
+
+ select * from {{ ref('stg_operations__product_operations') }}
+
+),
+
+dates_per_sources as (
+
+ select
+ *,
+ 'Collectes Supermarché' as source
+ from {{ ref('seed_collection_dates') }}
+ union
+ select 
+ *,
+ 'Pleins Courses' as source
+ from {{ ref('seed_grocery_shopping_dates') }}
+ union
+ select
+ *,
+ 'Enlèvements BAPIF' as source
+ from {{ ref('seed_bapif_collection_dates') }}
+
+),
+
+operations_dates_joined as (
+
+ select
+ product_operations.date_at,
+ dates_per_sources.source, 
+ product_operations.product_name,
+ product_operations.unit_of_measure,
+ product_operations.units_per_batch,
+ max(product_operations.date_at) over (partition by source) as date_latest_collection,
+ sum(product_operations.quantity_in_unit) as unit_entries,
+ sum(product_operations.batch_quantity) as batch_quantity,
+ sum(product_operations.monetary_value_eur) as monetary_value_eur
+ from product_operations
+ inner join dates_per_sources
+ on product_operations.date_at = dates_per_sources.date_at
+ where operation_type = 'in'
+ and flow_type = 'inventory'
+ group by 1,2,3,4,5
+
+)
+
+select * from operations_dates_joined

dbt-models/models/viz_operations__stock_entries_shopping_dates.sql

@@ -0,0 +1,2 @@
+ date_at
+ 2023-03-22