Merge pull request #11 from swishbi/dev

Dev

Author: phillem15

CHANGELOG.md

@@ -1,3 +1,17 @@
+# dbt_netsuite_source v0.3.0
+
+## 🚨 Breaking Changes 🚨:
+[PR #11](https://github.com/swishbi/dbt_netsuite_source/pull/11) includes the following breaking changes:
+- Re-introduces `quantity`, `rateamount`, and `voided` columns to `stg_netsuite__transaction_lines` model. If these have been added as pass through they will need to be removed from the pass through variable.
+
+## 🎉 Feature Updates 🎉
+[PR #11](https://github.com/swishbi/dbt_netsuite_source/pull/11) includes the following feature updates:
+- Incorporates `isinventoryaffecting` and `accountinglinetype` to the `stg_netsuite__transaction_lines` model as a feature via the `netsuite__inventory_management_enabled` variable.
+- Incorporates `bins` and `inventoryassignment` staging models as a feature via the `netsuite__advanced_inventory_management_enabled` variable.
+
+## Contributors
+- [phillem15](https://github.com/phillem15) ([#11](https://github.com/swishbi/dbt_netsuite_source/pull/11))
+
 # dbt_netsuite_source v0.2.3
 
 ## 🚨 Breaking Changes 🚨:

README.md

@@ -97,8 +97,10 @@ It's possible that your Netsuite connector does not sync every table that this p
 vars:
   netsuite_source:
     netsuite__advanced_billing_enabled: true # Enable `billingschedulemilestone`, `billingscheduletype`, and `billingschedule` if you are using the Advanced Billing featre
+    netsuite__advanced_invnetory_management_enabled: true # Enable `bins` and `inventoryassignment`` if you are using Advanced Inventory management features.
     netsuite__advanced_jobs_enabled: true # Enable `jobresources`, `projecttask` and `projecttaskassigneee` if you are using the Advanced Jobs feature
     netsuite__advanced_revenue_management_enabled: true # Enable `billingrevenueevent`, `billingschedulerecurrence`, `revenueelement`, `revenueplanplannedcost`, `revenueplanplannedrevenue`, `revenueplanstatus`, revenueplantype`, and `revenueplan` if you are using the Advanced Revenue Management feature
+    netsuite__inventory_management_enabled: true # Enable the necessary fields in `transactionline` to calculate inventory balances.
     netsuite__multibook_accounting_enabled: true # Enable `accountingbooksubsidiary` and `accountingbook` if you are using the Multi-Book Accounting feature
     netsuite__multiple_budgets_enabled: true # Enable `budgetcategory` if you are using the Multiple Budgets feature
     netsuite__multiple_calendars_enabled: true # Enable `accountingperiodfiscalcalendar` if you are using the Multiple Calendars feature

dbt_project.yml

@@ -1,7 +1,7 @@
 config-version: 2
 require-dbt-version: [">=1.3.0", "<2.0.0"]
 name: 'netsuite_source'
-version: '0.2.3'
+version: '0.3.0'
 
 models:
   netsuite_source:
@@ -21,6 +21,7 @@ vars:
     netsuite_billing_schedule_recurrences: "{{ source('netsuite', 'billing_schedule_recurrences') }}"
     netsuite_billing_schedule_types: "{{ source('netsuite', 'billing_schedule_types') }}"
     netsuite_billing_schedules: "{{ source('netsuite', 'billing_schedules') }}"
+    netsuite_bins: "{{ source('netsuite', 'bins') }}"
     netsuite_budget_categories: "{{ source('netsuite', 'budget_categories') }}"
     netsuite_budgets_machine: "{{ source('netsuite', 'budgets_machine') }}"
     netsuite_budgets: "{{ source('netsuite', 'budgets') }}"
@@ -37,6 +38,7 @@ vars:
     netsuite_employees: "{{ source('netsuite', 'employees') }}"
     netsuite_entities: "{{ source('netsuite', 'entity') }}"
     netsuite_entity_address: "{{ source('netsuite', 'entity_address') }}"
+    netsuite_inventory_assignments: "{{ source('netsuite', 'inventory_assignments') }}"
     netsuite_item_subtypes: "{{ source('netsuite', 'item_subtypes') }}"
     netsuite_item_types: "{{ source('netsuite', 'item_types') }}"
     netsuite_items: "{{ source('netsuite', 'item') }}"

models/stg_netsuite__bins.sql

@@ -0,0 +1,16 @@
+{{ config(enabled=(var('netsuite__advanced_inventory_management_enabled', false))) }}
+
+with source as (
+      select * from {{ var('netsuite_bins') }}
+),
+renamed as (
+    select
+        id as bin_id,
+        binnumber as bin_number,
+        location as location_id,
+        isinactive = "T" as is_inactive,
+        lastmodifieddate as last_modified_date
+
+    from source
+)
+select * from renamed

models/stg_netsuite__inventory_assignments.sql

@@ -0,0 +1,16 @@
+{{ config(enabled=(var('netsuite__advanced_inventory_management_enabled', false))) }}
+
+with source as (
+      select * from {{ var('netsuite_inventory_assignments') }}
+),
+renamed as (
+    select
+        id as inventory_assignment_id,
+        bin as bin_id,
+        transaction as transaction_id,
+        transactionline as transaction_line_id,
+        quantity
+
+    from source
+)
+select * from renamed

models/stg_netsuite__transaction_lines.sql

@@ -19,7 +19,13 @@ renamed as (
         isclosed = 'T' as is_closed,
         iscogs = 'T' as is_cogs,
         mainline = 'T' as is_main_line,
-        taxline = 'T' as is_tax_line
+        taxline = 'T' as is_tax_line,
+        quantity,
+        rateamount as rate_amount
+        {% if var('netsuite__inventory_management_enabled', false) %}
+        ,isinventoryaffecting = 'T' as is_inventory_affecting
+        ,accountinglinetype as accounting_line_type
+        {% endif %}
 
         --The below macro adds the fields defined within your transaction_lines_pass_through_columns variable into the staging model
         {{ fivetran_utils.fill_pass_through_columns('transaction_lines_pass_through_columns') }}

models/stg_netsuite__transactions.sql

@@ -22,6 +22,7 @@ renamed as (
         tranid as transaction_name,
         transactionnumber as transaction_number,
         type as transaction_type,
+        voided = 'T' as is_voided,
 
         concat('https://{{ var("netsuite_account_id", "123456") }}.app.netsuite.com/app/accounting/transactions/', lower(type), '.nl?id=', id) as transaction_url_link,
         concat(type,'_',id) as reference_id