summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--import_account_move_line.ktr670
-rw-r--r--import_all_data_bi_indoteknik.kjb96
2 files changed, 431 insertions, 335 deletions
diff --git a/import_account_move_line.ktr b/import_account_move_line.ktr
index c7c6040..383d05f 100644
--- a/import_account_move_line.ktr
+++ b/import_account_move_line.ktr
@@ -430,7 +430,7 @@
<created_date>2023/09/25 17:01:19.768</created_date>
<modified_user>-</modified_user>
<modified_date>2023/09/25 17:01:19.768</modified_date>
- <key_for_session_key/>
+ <key_for_session_key>H4sIAAAAAAAAAAMAAAAAAAAAAAA=</key_for_session_key>
<is_key_private>N</is_key_private>
</info>
<notepads>
@@ -545,6 +545,339 @@
</hop>
</order>
<step>
+ <name>Insert / update</name>
+ <type>InsertUpdate</type>
+ <description/>
+ <distribute>Y</distribute>
+ <custom_distribution/>
+ <copies>1</copies>
+ <partitioning>
+ <method>none</method>
+ <schema_name/>
+ </partitioning>
+ <connection>dw bi indoteknik (localhost)</connection>
+ <commit>100</commit>
+ <update_bypassed>N</update_bypassed>
+ <lookup>
+ <schema>public</schema>
+ <table>account_move_line</table>
+ <key>
+ <name>id</name>
+ <field>id</field>
+ <condition>=</condition>
+ <name2/>
+ </key>
+ <value>
+ <name>id</name>
+ <rename>id</rename>
+ <update>N</update>
+ </value>
+ <value>
+ <name>move_id</name>
+ <rename>move_id</rename>
+ <update>Y</update>
+ </value>
+ <value>
+ <name>move_name</name>
+ <rename>move_name</rename>
+ <update>Y</update>
+ </value>
+ <value>
+ <name>date</name>
+ <rename>date</rename>
+ <update>Y</update>
+ </value>
+ <value>
+ <name>ref</name>
+ <rename>ref</rename>
+ <update>Y</update>
+ </value>
+ <value>
+ <name>parent_state</name>
+ <rename>parent_state</rename>
+ <update>Y</update>
+ </value>
+ <value>
+ <name>journal_id</name>
+ <rename>journal_id</rename>
+ <update>Y</update>
+ </value>
+ <value>
+ <name>company_id</name>
+ <rename>company_id</rename>
+ <update>Y</update>
+ </value>
+ <value>
+ <name>company_currency_id</name>
+ <rename>company_currency_id</rename>
+ <update>Y</update>
+ </value>
+ <value>
+ <name>account_id</name>
+ <rename>account_id</rename>
+ <update>Y</update>
+ </value>
+ <value>
+ <name>account_root_id</name>
+ <rename>account_root_id</rename>
+ <update>Y</update>
+ </value>
+ <value>
+ <name>sequence</name>
+ <rename>sequence</rename>
+ <update>Y</update>
+ </value>
+ <value>
+ <name>name</name>
+ <rename>name</rename>
+ <update>Y</update>
+ </value>
+ <value>
+ <name>quantity</name>
+ <rename>quantity</rename>
+ <update>Y</update>
+ </value>
+ <value>
+ <name>price_unit</name>
+ <rename>price_unit</rename>
+ <update>Y</update>
+ </value>
+ <value>
+ <name>discount</name>
+ <rename>discount</rename>
+ <update>Y</update>
+ </value>
+ <value>
+ <name>debit</name>
+ <rename>debit</rename>
+ <update>Y</update>
+ </value>
+ <value>
+ <name>credit</name>
+ <rename>credit</rename>
+ <update>Y</update>
+ </value>
+ <value>
+ <name>balance</name>
+ <rename>balance</rename>
+ <update>Y</update>
+ </value>
+ <value>
+ <name>amount_currency</name>
+ <rename>amount_currency</rename>
+ <update>Y</update>
+ </value>
+ <value>
+ <name>price_subtotal</name>
+ <rename>price_subtotal</rename>
+ <update>Y</update>
+ </value>
+ <value>
+ <name>price_total</name>
+ <rename>price_total</rename>
+ <update>Y</update>
+ </value>
+ <value>
+ <name>reconciled</name>
+ <rename>reconciled</rename>
+ <update>Y</update>
+ </value>
+ <value>
+ <name>blocked</name>
+ <rename>blocked</rename>
+ <update>Y</update>
+ </value>
+ <value>
+ <name>date_maturity</name>
+ <rename>date_maturity</rename>
+ <update>Y</update>
+ </value>
+ <value>
+ <name>currency_id</name>
+ <rename>currency_id</rename>
+ <update>Y</update>
+ </value>
+ <value>
+ <name>partner_id</name>
+ <rename>partner_id</rename>
+ <update>Y</update>
+ </value>
+ <value>
+ <name>product_uom_id</name>
+ <rename>product_uom_id</rename>
+ <update>Y</update>
+ </value>
+ <value>
+ <name>product_id</name>
+ <rename>product_id</rename>
+ <update>Y</update>
+ </value>
+ <value>
+ <name>reconcile_model_id</name>
+ <rename>reconcile_model_id</rename>
+ <update>Y</update>
+ </value>
+ <value>
+ <name>payment_id</name>
+ <rename>payment_id</rename>
+ <update>Y</update>
+ </value>
+ <value>
+ <name>statement_line_id</name>
+ <rename>statement_line_id</rename>
+ <update>Y</update>
+ </value>
+ <value>
+ <name>statement_id</name>
+ <rename>statement_id</rename>
+ <update>Y</update>
+ </value>
+ <value>
+ <name>tax_line_id</name>
+ <rename>tax_line_id</rename>
+ <update>Y</update>
+ </value>
+ <value>
+ <name>tax_group_id</name>
+ <rename>tax_group_id</rename>
+ <update>Y</update>
+ </value>
+ <value>
+ <name>tax_base_amount</name>
+ <rename>tax_base_amount</rename>
+ <update>Y</update>
+ </value>
+ <value>
+ <name>tax_exigible</name>
+ <rename>tax_exigible</rename>
+ <update>Y</update>
+ </value>
+ <value>
+ <name>tax_repartition_line_id</name>
+ <rename>tax_repartition_line_id</rename>
+ <update>Y</update>
+ </value>
+ <value>
+ <name>tax_audit</name>
+ <rename>tax_audit</rename>
+ <update>Y</update>
+ </value>
+ <value>
+ <name>amount_residual</name>
+ <rename>amount_residual</rename>
+ <update>Y</update>
+ </value>
+ <value>
+ <name>amount_residual_currency</name>
+ <rename>amount_residual_currency</rename>
+ <update>Y</update>
+ </value>
+ <value>
+ <name>full_reconcile_id</name>
+ <rename>full_reconcile_id</rename>
+ <update>Y</update>
+ </value>
+ <value>
+ <name>matching_number</name>
+ <rename>matching_number</rename>
+ <update>Y</update>
+ </value>
+ <value>
+ <name>analytic_account_id</name>
+ <rename>analytic_account_id</rename>
+ <update>Y</update>
+ </value>
+ <value>
+ <name>display_type</name>
+ <rename>display_type</rename>
+ <update>Y</update>
+ </value>
+ <value>
+ <name>is_rounding_line</name>
+ <rename>is_rounding_line</rename>
+ <update>Y</update>
+ </value>
+ <value>
+ <name>exclude_from_invoice_tab</name>
+ <rename>exclude_from_invoice_tab</rename>
+ <update>Y</update>
+ </value>
+ <value>
+ <name>create_uid</name>
+ <rename>create_uid</rename>
+ <update>Y</update>
+ </value>
+ <value>
+ <name>create_date</name>
+ <rename>create_date</rename>
+ <update>Y</update>
+ </value>
+ <value>
+ <name>write_uid</name>
+ <rename>write_uid</rename>
+ <update>Y</update>
+ </value>
+ <value>
+ <name>write_date</name>
+ <rename>write_date</rename>
+ <update>Y</update>
+ </value>
+ <value>
+ <name>is_anglo_saxon_line</name>
+ <rename>is_anglo_saxon_line</rename>
+ <update>Y</update>
+ </value>
+ <value>
+ <name>purchase_line_id</name>
+ <rename>purchase_line_id</rename>
+ <update>Y</update>
+ </value>
+ <value>
+ <name>asset_category_id</name>
+ <rename>asset_category_id</rename>
+ <update>Y</update>
+ </value>
+ <value>
+ <name>asset_start_date</name>
+ <rename>asset_start_date</rename>
+ <update>Y</update>
+ </value>
+ <value>
+ <name>asset_end_date</name>
+ <rename>asset_end_date</rename>
+ <update>Y</update>
+ </value>
+ <value>
+ <name>asset_mrr</name>
+ <rename>asset_mrr</rename>
+ <update>Y</update>
+ </value>
+ <value>
+ <name>is_landed_costs_line</name>
+ <rename>is_landed_costs_line</rename>
+ <update>Y</update>
+ </value>
+ <value>
+ <name>cost_centre_id</name>
+ <rename>cost_centre_id</rename>
+ <update>Y</update>
+ </value>
+ </lookup>
+ <attributes/>
+ <cluster_schema/>
+ <remotesteps>
+ <input>
+ </input>
+ <output>
+ </output>
+ </remotesteps>
+ <GUI>
+ <xloc>288</xloc>
+ <yloc>80</yloc>
+ <draw>Y</draw>
+ </GUI>
+ </step>
+ <step>
<name>Table input</name>
<type>TableInput</type>
<description/>
@@ -556,7 +889,7 @@
<schema_name/>
</partitioning>
<connection>erp indoteknik production (localhost)</connection>
- <sql>select * from account_move_line</sql>
+ <sql>select * from account_move_line where write_date >= (now() - '5 days'::interval)</sql>
<limit>0</limit>
<lookup/>
<execute_each_row>N</execute_each_row>
@@ -1936,339 +2269,6 @@
<draw>Y</draw>
</GUI>
</step>
- <step>
- <name>Insert / update</name>
- <type>InsertUpdate</type>
- <description/>
- <distribute>Y</distribute>
- <custom_distribution/>
- <copies>1</copies>
- <partitioning>
- <method>none</method>
- <schema_name/>
- </partitioning>
- <connection>dw bi indoteknik (localhost)</connection>
- <commit>100</commit>
- <update_bypassed>N</update_bypassed>
- <lookup>
- <schema>public</schema>
- <table>account_move_line</table>
- <key>
- <name>id</name>
- <field>id</field>
- <condition>=</condition>
- <name2/>
- </key>
- <value>
- <name>id</name>
- <rename>id</rename>
- <update>N</update>
- </value>
- <value>
- <name>move_id</name>
- <rename>move_id</rename>
- <update>Y</update>
- </value>
- <value>
- <name>move_name</name>
- <rename>move_name</rename>
- <update>Y</update>
- </value>
- <value>
- <name>date</name>
- <rename>date</rename>
- <update>Y</update>
- </value>
- <value>
- <name>ref</name>
- <rename>ref</rename>
- <update>Y</update>
- </value>
- <value>
- <name>parent_state</name>
- <rename>parent_state</rename>
- <update>Y</update>
- </value>
- <value>
- <name>journal_id</name>
- <rename>journal_id</rename>
- <update>Y</update>
- </value>
- <value>
- <name>company_id</name>
- <rename>company_id</rename>
- <update>Y</update>
- </value>
- <value>
- <name>company_currency_id</name>
- <rename>company_currency_id</rename>
- <update>Y</update>
- </value>
- <value>
- <name>account_id</name>
- <rename>account_id</rename>
- <update>Y</update>
- </value>
- <value>
- <name>account_root_id</name>
- <rename>account_root_id</rename>
- <update>Y</update>
- </value>
- <value>
- <name>sequence</name>
- <rename>sequence</rename>
- <update>Y</update>
- </value>
- <value>
- <name>name</name>
- <rename>name</rename>
- <update>Y</update>
- </value>
- <value>
- <name>quantity</name>
- <rename>quantity</rename>
- <update>Y</update>
- </value>
- <value>
- <name>price_unit</name>
- <rename>price_unit</rename>
- <update>Y</update>
- </value>
- <value>
- <name>discount</name>
- <rename>discount</rename>
- <update>Y</update>
- </value>
- <value>
- <name>debit</name>
- <rename>debit</rename>
- <update>Y</update>
- </value>
- <value>
- <name>credit</name>
- <rename>credit</rename>
- <update>Y</update>
- </value>
- <value>
- <name>balance</name>
- <rename>balance</rename>
- <update>Y</update>
- </value>
- <value>
- <name>amount_currency</name>
- <rename>amount_currency</rename>
- <update>Y</update>
- </value>
- <value>
- <name>price_subtotal</name>
- <rename>price_subtotal</rename>
- <update>Y</update>
- </value>
- <value>
- <name>price_total</name>
- <rename>price_total</rename>
- <update>Y</update>
- </value>
- <value>
- <name>reconciled</name>
- <rename>reconciled</rename>
- <update>Y</update>
- </value>
- <value>
- <name>blocked</name>
- <rename>blocked</rename>
- <update>Y</update>
- </value>
- <value>
- <name>date_maturity</name>
- <rename>date_maturity</rename>
- <update>Y</update>
- </value>
- <value>
- <name>currency_id</name>
- <rename>currency_id</rename>
- <update>Y</update>
- </value>
- <value>
- <name>partner_id</name>
- <rename>partner_id</rename>
- <update>Y</update>
- </value>
- <value>
- <name>product_uom_id</name>
- <rename>product_uom_id</rename>
- <update>Y</update>
- </value>
- <value>
- <name>product_id</name>
- <rename>product_id</rename>
- <update>Y</update>
- </value>
- <value>
- <name>reconcile_model_id</name>
- <rename>reconcile_model_id</rename>
- <update>Y</update>
- </value>
- <value>
- <name>payment_id</name>
- <rename>payment_id</rename>
- <update>Y</update>
- </value>
- <value>
- <name>statement_line_id</name>
- <rename>statement_line_id</rename>
- <update>Y</update>
- </value>
- <value>
- <name>statement_id</name>
- <rename>statement_id</rename>
- <update>Y</update>
- </value>
- <value>
- <name>tax_line_id</name>
- <rename>tax_line_id</rename>
- <update>Y</update>
- </value>
- <value>
- <name>tax_group_id</name>
- <rename>tax_group_id</rename>
- <update>Y</update>
- </value>
- <value>
- <name>tax_base_amount</name>
- <rename>tax_base_amount</rename>
- <update>Y</update>
- </value>
- <value>
- <name>tax_exigible</name>
- <rename>tax_exigible</rename>
- <update>Y</update>
- </value>
- <value>
- <name>tax_repartition_line_id</name>
- <rename>tax_repartition_line_id</rename>
- <update>Y</update>
- </value>
- <value>
- <name>tax_audit</name>
- <rename>tax_audit</rename>
- <update>Y</update>
- </value>
- <value>
- <name>amount_residual</name>
- <rename>amount_residual</rename>
- <update>Y</update>
- </value>
- <value>
- <name>amount_residual_currency</name>
- <rename>amount_residual_currency</rename>
- <update>Y</update>
- </value>
- <value>
- <name>full_reconcile_id</name>
- <rename>full_reconcile_id</rename>
- <update>Y</update>
- </value>
- <value>
- <name>matching_number</name>
- <rename>matching_number</rename>
- <update>Y</update>
- </value>
- <value>
- <name>analytic_account_id</name>
- <rename>analytic_account_id</rename>
- <update>Y</update>
- </value>
- <value>
- <name>display_type</name>
- <rename>display_type</rename>
- <update>Y</update>
- </value>
- <value>
- <name>is_rounding_line</name>
- <rename>is_rounding_line</rename>
- <update>Y</update>
- </value>
- <value>
- <name>exclude_from_invoice_tab</name>
- <rename>exclude_from_invoice_tab</rename>
- <update>Y</update>
- </value>
- <value>
- <name>create_uid</name>
- <rename>create_uid</rename>
- <update>Y</update>
- </value>
- <value>
- <name>create_date</name>
- <rename>create_date</rename>
- <update>Y</update>
- </value>
- <value>
- <name>write_uid</name>
- <rename>write_uid</rename>
- <update>Y</update>
- </value>
- <value>
- <name>write_date</name>
- <rename>write_date</rename>
- <update>Y</update>
- </value>
- <value>
- <name>is_anglo_saxon_line</name>
- <rename>is_anglo_saxon_line</rename>
- <update>Y</update>
- </value>
- <value>
- <name>purchase_line_id</name>
- <rename>purchase_line_id</rename>
- <update>Y</update>
- </value>
- <value>
- <name>asset_category_id</name>
- <rename>asset_category_id</rename>
- <update>Y</update>
- </value>
- <value>
- <name>asset_start_date</name>
- <rename>asset_start_date</rename>
- <update>Y</update>
- </value>
- <value>
- <name>asset_end_date</name>
- <rename>asset_end_date</rename>
- <update>Y</update>
- </value>
- <value>
- <name>asset_mrr</name>
- <rename>asset_mrr</rename>
- <update>Y</update>
- </value>
- <value>
- <name>is_landed_costs_line</name>
- <rename>is_landed_costs_line</rename>
- <update>Y</update>
- </value>
- <value>
- <name>cost_centre_id</name>
- <rename>cost_centre_id</rename>
- <update>Y</update>
- </value>
- </lookup>
- <attributes/>
- <cluster_schema/>
- <remotesteps>
- <input>
- </input>
- <output>
- </output>
- </remotesteps>
- <GUI>
- <xloc>288</xloc>
- <yloc>80</yloc>
- <draw>Y</draw>
- </GUI>
- </step>
<step_error_handling>
</step_error_handling>
<slave-step-copy-partition-distribution>
diff --git a/import_all_data_bi_indoteknik.kjb b/import_all_data_bi_indoteknik.kjb
index 25c7ce6..83fc5fd 100644
--- a/import_all_data_bi_indoteknik.kjb
+++ b/import_all_data_bi_indoteknik.kjb
@@ -800,6 +800,84 @@
<yloc>416</yloc>
<attributes_kjc/>
</entry>
+ <entry>
+ <name>import account move</name>
+ <description/>
+ <type>TRANS</type>
+ <attributes/>
+ <specification_method>filename</specification_method>
+ <trans_object_id/>
+ <filename>/home/stephan/transformation-job-bi/import_account_move.ktr</filename>
+ <transname/>
+ <arg_from_previous>N</arg_from_previous>
+ <params_from_previous>N</params_from_previous>
+ <exec_per_row>N</exec_per_row>
+ <clear_rows>N</clear_rows>
+ <clear_files>N</clear_files>
+ <set_logfile>N</set_logfile>
+ <logfile/>
+ <logext/>
+ <add_date>N</add_date>
+ <add_time>N</add_time>
+ <loglevel>Basic</loglevel>
+ <cluster>N</cluster>
+ <slave_server_name/>
+ <set_append_logfile>N</set_append_logfile>
+ <wait_until_finished>Y</wait_until_finished>
+ <follow_abort_remote>N</follow_abort_remote>
+ <create_parent_folder>N</create_parent_folder>
+ <logging_remote_work>N</logging_remote_work>
+ <run_configuration>Pentaho local</run_configuration>
+ <suppress_result_data>N</suppress_result_data>
+ <parameters>
+ <pass_all_parameters>Y</pass_all_parameters>
+ </parameters>
+ <parallel>N</parallel>
+ <draw>Y</draw>
+ <nr>0</nr>
+ <xloc>928</xloc>
+ <yloc>416</yloc>
+ <attributes_kjc/>
+ </entry>
+ <entry>
+ <name>import account move line</name>
+ <description/>
+ <type>TRANS</type>
+ <attributes/>
+ <specification_method>filename</specification_method>
+ <trans_object_id/>
+ <filename>/home/stephan/transformation-job-bi/import_account_move_line.ktr</filename>
+ <transname/>
+ <arg_from_previous>N</arg_from_previous>
+ <params_from_previous>N</params_from_previous>
+ <exec_per_row>N</exec_per_row>
+ <clear_rows>N</clear_rows>
+ <clear_files>N</clear_files>
+ <set_logfile>N</set_logfile>
+ <logfile/>
+ <logext/>
+ <add_date>N</add_date>
+ <add_time>N</add_time>
+ <loglevel>Basic</loglevel>
+ <cluster>N</cluster>
+ <slave_server_name/>
+ <set_append_logfile>N</set_append_logfile>
+ <wait_until_finished>Y</wait_until_finished>
+ <follow_abort_remote>N</follow_abort_remote>
+ <create_parent_folder>N</create_parent_folder>
+ <logging_remote_work>N</logging_remote_work>
+ <run_configuration>Pentaho local</run_configuration>
+ <suppress_result_data>N</suppress_result_data>
+ <parameters>
+ <pass_all_parameters>Y</pass_all_parameters>
+ </parameters>
+ <parallel>N</parallel>
+ <draw>Y</draw>
+ <nr>0</nr>
+ <xloc>1152</xloc>
+ <yloc>416</yloc>
+ <attributes_kjc/>
+ </entry>
</entries>
<hops>
<hop>
@@ -919,6 +997,24 @@
<evaluation>Y</evaluation>
<unconditional>N</unconditional>
</hop>
+ <hop>
+ <from>import sale order</from>
+ <to>import account move</to>
+ <from_nr>0</from_nr>
+ <to_nr>0</to_nr>
+ <enabled>Y</enabled>
+ <evaluation>Y</evaluation>
+ <unconditional>N</unconditional>
+ </hop>
+ <hop>
+ <from>import account move</from>
+ <to>import account move line</to>
+ <from_nr>0</from_nr>
+ <to_nr>0</to_nr>
+ <enabled>Y</enabled>
+ <evaluation>Y</evaluation>
+ <unconditional>N</unconditional>
+ </hop>
</hops>
<notepads>
</notepads>