summaryrefslogtreecommitdiff
path: root/calculate_no_sales_stock.ktr
diff options
context:
space:
mode:
authorstephanchrst <stephanchrst@gmail.com>2025-07-05 10:05:51 +0700
committerstephanchrst <stephanchrst@gmail.com>2025-07-05 10:05:51 +0700
commite0baab61816dcc3309ebcfb574f01b3dcee65cce (patch)
tree1e1bc2e6c307f00559db689df974ee44abb31a1d /calculate_no_sales_stock.ktr
parent7e117f18ce8728ff0c39e9dc2f04b3a83af809bc (diff)
update combine deadstock
Diffstat (limited to 'calculate_no_sales_stock.ktr')
-rw-r--r--calculate_no_sales_stock.ktr1652
1 files changed, 805 insertions, 847 deletions
diff --git a/calculate_no_sales_stock.ktr b/calculate_no_sales_stock.ktr
index 0973a22..37943d8 100644
--- a/calculate_no_sales_stock.ktr
+++ b/calculate_no_sales_stock.ktr
@@ -659,11 +659,6 @@
<enabled>Y</enabled>
</hop>
<hop>
- <from>Merge join 2</from>
- <to>If field value is null</to>
- <enabled>Y</enabled>
- </hop>
- <hop>
<from>If field value is null</from>
<to>Calculator</to>
<enabled>Y</enabled>
@@ -678,8 +673,59 @@
<to>Insert / update</to>
<enabled>Y</enabled>
</hop>
+ <hop>
+ <from>Merge join 2</from>
+ <to>Calculator 2</to>
+ <enabled>Y</enabled>
+ </hop>
+ <hop>
+ <from>Calculator 2</from>
+ <to>If field value is null</to>
+ <enabled>Y</enabled>
+ </hop>
</order>
<step>
+ <name>Calculator</name>
+ <type>Calculator</type>
+ <description/>
+ <distribute>Y</distribute>
+ <custom_distribution/>
+ <copies>1</copies>
+ <partitioning>
+ <method>none</method>
+ <schema_name/>
+ </partitioning>
+ <failIfNoFile>Y</failIfNoFile>
+ <calculation>
+ <field_name>total_cost</field_name>
+ <calc_type>MULTIPLY</calc_type>
+ <field_a>new_qty</field_a>
+ <field_b>last_cost</field_b>
+ <field_c/>
+ <value_type>Number</value_type>
+ <value_length>-1</value_length>
+ <value_precision>-1</value_precision>
+ <remove>N</remove>
+ <conversion_mask/>
+ <decimal_symbol/>
+ <grouping_symbol/>
+ <currency_symbol/>
+ </calculation>
+ <attributes/>
+ <cluster_schema/>
+ <remotesteps>
+ <input>
+ </input>
+ <output>
+ </output>
+ </remotesteps>
+ <GUI>
+ <xloc>480</xloc>
+ <yloc>368</yloc>
+ <draw>Y</draw>
+ </GUI>
+ </step>
+ <step>
<name>Filter rows</name>
<type>FilterRows</type>
<description/>
@@ -750,8 +796,8 @@
</GUI>
</step>
<step>
- <name>Stream lookup</name>
- <type>StreamLookup</type>
+ <name>If field value is null</name>
+ <type>IfNull</type>
<description/>
<distribute>Y</distribute>
<custom_distribution/>
@@ -760,23 +806,39 @@
<method>none</method>
<schema_name/>
</partitioning>
- <from>dead stock</from>
- <input_sorted>N</input_sorted>
- <preserve_memory>Y</preserve_memory>
- <sorted_list>N</sorted_list>
- <integer_pair>N</integer_pair>
- <lookup>
- <key>
- <name>product_id</name>
- <field>product_id</field>
- </key>
- <value>
- <name>product_id</name>
- <rename>in_deadstock</rename>
- <default/>
- <type>Integer</type>
- </value>
- </lookup>
+ <replaceAllByValue>0</replaceAllByValue>
+ <replaceAllMask/>
+ <selectFields>Y</selectFields>
+ <selectValuesType>N</selectValuesType>
+ <setEmptyStringAll>N</setEmptyStringAll>
+ <valuetypes>
+ </valuetypes>
+ <fields>
+ <field>
+ <name>aging</name>
+ <value>0</value>
+ <mask/>
+ <set_empty_string>N</set_empty_string>
+ </field>
+ <field>
+ <name>last_cost</name>
+ <value>0</value>
+ <mask/>
+ <set_empty_string>N</set_empty_string>
+ </field>
+ <field>
+ <name>qty</name>
+ <value>0</value>
+ <mask/>
+ <set_empty_string>N</set_empty_string>
+ </field>
+ <field>
+ <name>qty_outgoing</name>
+ <value>0</value>
+ <mask/>
+ <set_empty_string>N</set_empty_string>
+ </field>
+ </fields>
<attributes/>
<cluster_schema/>
<remotesteps>
@@ -786,14 +848,14 @@
</output>
</remotesteps>
<GUI>
- <xloc>224</xloc>
- <yloc>144</yloc>
+ <xloc>608</xloc>
+ <yloc>368</yloc>
<draw>Y</draw>
</GUI>
</step>
<step>
- <name>Stream lookup 2</name>
- <type>StreamLookup</type>
+ <name>Insert / update</name>
+ <type>InsertUpdate</type>
<description/>
<distribute>Y</distribute>
<custom_distribution/>
@@ -802,21 +864,67 @@
<method>none</method>
<schema_name/>
</partitioning>
- <from>movement</from>
- <input_sorted>N</input_sorted>
- <preserve_memory>Y</preserve_memory>
- <sorted_list>N</sorted_list>
- <integer_pair>N</integer_pair>
+ <connection>dw bi indoteknik (localhost)</connection>
+ <commit>100</commit>
+ <update_bypassed>N</update_bypassed>
<lookup>
+ <schema>public</schema>
+ <table>list_new_deadstock</table>
<key>
<name>product_id</name>
<field>product_id</field>
+ <condition>=</condition>
+ <name2/>
</key>
<value>
<name>product_id</name>
- <rename>in_movement</rename>
- <default/>
- <type>None</type>
+ <rename>product_id</rename>
+ <update>N</update>
+ </value>
+ <value>
+ <name>item_code</name>
+ <rename>item_code</rename>
+ <update>Y</update>
+ </value>
+ <value>
+ <name>product_name</name>
+ <rename>product_name</rename>
+ <update>Y</update>
+ </value>
+ <value>
+ <name>brand</name>
+ <rename>brand</rename>
+ <update>Y</update>
+ </value>
+ <value>
+ <name>qty</name>
+ <rename>qty</rename>
+ <update>Y</update>
+ </value>
+ <value>
+ <name>date_added</name>
+ <rename>date_added</rename>
+ <update>N</update>
+ </value>
+ <value>
+ <name>last_in</name>
+ <rename>last_in</rename>
+ <update>Y</update>
+ </value>
+ <value>
+ <name>aging</name>
+ <rename>aging</rename>
+ <update>Y</update>
+ </value>
+ <value>
+ <name>last_cost</name>
+ <rename>last_cost</rename>
+ <update>Y</update>
+ </value>
+ <value>
+ <name>total_cost</name>
+ <rename>total_cost</rename>
+ <update>Y</update>
</value>
</lookup>
<attributes/>
@@ -828,46 +936,14 @@
</output>
</remotesteps>
<GUI>
- <xloc>560</xloc>
- <yloc>144</yloc>
- <draw>Y</draw>
- </GUI>
- </step>
- <step>
- <name>Write to log</name>
- <type>WriteToLog</type>
- <description/>
- <distribute>Y</distribute>
- <custom_distribution/>
- <copies>1</copies>
- <partitioning>
- <method>none</method>
- <schema_name/>
- </partitioning>
- <loglevel>log_level_basic</loglevel>
- <displayHeader>Y</displayHeader>
- <limitRows>N</limitRows>
- <limitRowsNumber>0</limitRowsNumber>
- <logmessage/>
- <fields>
- </fields>
- <attributes/>
- <cluster_schema/>
- <remotesteps>
- <input>
- </input>
- <output>
- </output>
- </remotesteps>
- <GUI>
- <xloc>400</xloc>
- <yloc>224</yloc>
+ <xloc>208</xloc>
+ <yloc>368</yloc>
<draw>Y</draw>
</GUI>
</step>
<step>
- <name>Write to log 2</name>
- <type>WriteToLog</type>
+ <name>Merge join</name>
+ <type>MergeJoin</type>
<description/>
<distribute>Y</distribute>
<custom_distribution/>
@@ -876,13 +952,15 @@
<method>none</method>
<schema_name/>
</partitioning>
- <loglevel>log_level_basic</loglevel>
- <displayHeader>Y</displayHeader>
- <limitRows>N</limitRows>
- <limitRowsNumber>0</limitRowsNumber>
- <logmessage/>
- <fields>
- </fields>
+ <join_type>LEFT OUTER</join_type>
+ <step1>Sort rows</step1>
+ <step2>Sort rows 2</step2>
+ <keys_1>
+ <key>product_id</key>
+ </keys_1>
+ <keys_2>
+ <key>product_id</key>
+ </keys_2>
<attributes/>
<cluster_schema/>
<remotesteps>
@@ -892,14 +970,14 @@
</output>
</remotesteps>
<GUI>
- <xloc>720</xloc>
- <yloc>224</yloc>
+ <xloc>1072</xloc>
+ <yloc>144</yloc>
<draw>Y</draw>
</GUI>
</step>
<step>
- <name>dead stock</name>
- <type>TableInput</type>
+ <name>Merge join 2</name>
+ <type>MergeJoin</type>
<description/>
<distribute>Y</distribute>
<custom_distribution/>
@@ -908,39 +986,15 @@
<method>none</method>
<schema_name/>
</partitioning>
- <connection>dw bi indoteknik (localhost)</connection>
- <sql>select distinct product_id from list_deadstock</sql>
- <limit>0</limit>
- <lookup/>
- <execute_each_row>N</execute_each_row>
- <variables_active>N</variables_active>
- <lazy_conversion_active>N</lazy_conversion_active>
- <cached_row_meta_active>N</cached_row_meta_active>
- <row-meta>
- <value-meta>
- <type>Integer</type>
- <storagetype>normal</storagetype>
- <name>product_id</name>
- <length>9</length>
- <precision>0</precision>
- <origin>Table input</origin>
- <comments>product_id</comments>
- <conversion_Mask>####0;-####0</conversion_Mask>
- <decimal_symbol>.</decimal_symbol>
- <grouping_symbol>,</grouping_symbol>
- <currency_symbol/>
- <trim_type>none</trim_type>
- <case_insensitive>N</case_insensitive>
- <collator_disabled>Y</collator_disabled>
- <collator_strength>0</collator_strength>
- <sort_descending>N</sort_descending>
- <output_padding>N</output_padding>
- <date_format_lenient>N</date_format_lenient>
- <date_format_locale>en_US</date_format_locale>
- <date_format_timezone>Asia/Bangkok</date_format_timezone>
- <lenient_string_to_number>N</lenient_string_to_number>
- </value-meta>
- </row-meta>
+ <join_type>LEFT OUTER</join_type>
+ <step1>Sort rows 3</step1>
+ <step2>Sort rows 4</step2>
+ <keys_1>
+ <key>product_id</key>
+ </keys_1>
+ <keys_2>
+ <key>product_id</key>
+ </keys_2>
<attributes/>
<cluster_schema/>
<remotesteps>
@@ -950,61 +1004,61 @@
</output>
</remotesteps>
<GUI>
- <xloc>224</xloc>
- <yloc>48</yloc>
+ <xloc>880</xloc>
+ <yloc>368</yloc>
<draw>Y</draw>
</GUI>
</step>
<step>
- <name>movement</name>
- <type>TableInput</type>
+ <name>Select values</name>
+ <type>SelectValues</type>
<description/>
- <distribute>Y</distribute>
+ <distribute>N</distribute>
<custom_distribution/>
<copies>1</copies>
<partitioning>
<method>none</method>
<schema_name/>
</partitioning>
- <connection>dw bi indoteknik (localhost)</connection>
- <sql>select distinct sm.product_id
-from stock_move sm
-join stock_location sl on sl.id = sm.location_dest_id
-where 1=1
-and sl.name in ('Customers', 'Production')
-and sm.state = 'done'
-and sm.create_date >= (now() - '180 days'::interval)</sql>
- <limit>0</limit>
- <lookup/>
- <execute_each_row>N</execute_each_row>
- <variables_active>N</variables_active>
- <lazy_conversion_active>N</lazy_conversion_active>
- <cached_row_meta_active>N</cached_row_meta_active>
- <row-meta>
- <value-meta>
- <type>Integer</type>
- <storagetype>normal</storagetype>
+ <fields>
+ <field>
<name>product_id</name>
- <length>9</length>
- <precision>0</precision>
- <origin>movement</origin>
- <comments>product_id</comments>
- <conversion_Mask>####0;-####0</conversion_Mask>
- <decimal_symbol>.</decimal_symbol>
- <grouping_symbol>,</grouping_symbol>
- <currency_symbol/>
- <trim_type>none</trim_type>
- <case_insensitive>N</case_insensitive>
- <collator_disabled>Y</collator_disabled>
- <collator_strength>0</collator_strength>
- <sort_descending>N</sort_descending>
- <output_padding>N</output_padding>
- <date_format_lenient>N</date_format_lenient>
- <date_format_locale>en_US</date_format_locale>
- <date_format_timezone>Asia/Bangkok</date_format_timezone>
- <lenient_string_to_number>N</lenient_string_to_number>
- </value-meta>
- </row-meta>
+ <rename/>
+ </field>
+ <field>
+ <name>item_code</name>
+ <rename/>
+ </field>
+ <field>
+ <name>product_name</name>
+ <rename/>
+ </field>
+ <field>
+ <name>brand</name>
+ <rename/>
+ </field>
+ <field>
+ <name>qty</name>
+ <rename/>
+ </field>
+ <field>
+ <name>date_added</name>
+ <rename/>
+ </field>
+ <field>
+ <name>in_deadstock</name>
+ <rename/>
+ </field>
+ <field>
+ <name>in_movement</name>
+ <rename/>
+ </field>
+ <field>
+ <name>qty_outgoing</name>
+ <rename/>
+ </field>
+ <select_unspecified>N</select_unspecified>
+ </fields>
<attributes/>
<cluster_schema/>
<remotesteps>
@@ -1014,14 +1068,14 @@ and sm.create_date >= (now() - '180 days'::interval)</sql>
</output>
</remotesteps>
<GUI>
- <xloc>560</xloc>
- <yloc>48</yloc>
+ <xloc>864</xloc>
+ <yloc>144</yloc>
<draw>Y</draw>
</GUI>
</step>
<step>
- <name>stock quant</name>
- <type>TableInput</type>
+ <name>Select values 2</name>
+ <type>SelectValues</type>
<description/>
<distribute>Y</distribute>
<custom_distribution/>
@@ -1030,144 +1084,45 @@ and sm.create_date >= (now() - '180 days'::interval)</sql>
<method>none</method>
<schema_name/>
</partitioning>
- <connection>erp indoteknik production (localhost)</connection>
- <sql>select sq.product_id, coalesce(pp.default_code, pt.default_code) as item_code, pt.name as product_name, xm.x_name as brand,
-sum(quantity) as qty, now()::timestamp as date_added
-from stock_quant sq
-join stock_location sl on sl.id = sq.location_id
-join product_product pp on pp.id = sq.product_id
-join product_template pt on pt.id = pp.product_tmpl_id
-left join x_manufactures xm on xm.id = pt.x_manufacture
-where 1=1
-and sq.location_id in(select id from stock_location where usage = 'internal' and active = true)
-and pt.name not ilike '%promotion%' and pt.name not ilike '%asset%mesin%peralatan%'
-and pt.name not ilike '%asset%inventaris%' and pt.name not ilike '%asset%kendaraan%'
-group by sq.product_id, pp.default_code, pt.default_code, pt.name, xm.x_name
-having sum(quantity) > 0
-order by sq.product_id</sql>
- <limit>0</limit>
- <lookup/>
- <execute_each_row>N</execute_each_row>
- <variables_active>N</variables_active>
- <lazy_conversion_active>N</lazy_conversion_active>
- <cached_row_meta_active>N</cached_row_meta_active>
- <row-meta>
- <value-meta>
- <type>Integer</type>
- <storagetype>normal</storagetype>
+ <fields>
+ <field>
<name>product_id</name>
- <length>9</length>
- <precision>0</precision>
- <origin>stock quant</origin>
- <comments>product_id</comments>
- <conversion_Mask>####0;-####0</conversion_Mask>
- <decimal_symbol>.</decimal_symbol>
- <grouping_symbol>,</grouping_symbol>
- <currency_symbol/>
- <trim_type>none</trim_type>
- <case_insensitive>N</case_insensitive>
- <collator_disabled>Y</collator_disabled>
- <collator_strength>0</collator_strength>
- <sort_descending>N</sort_descending>
- <output_padding>N</output_padding>
- <date_format_lenient>N</date_format_lenient>
- <date_format_locale>en_US</date_format_locale>
- <date_format_timezone>Asia/Bangkok</date_format_timezone>
- <lenient_string_to_number>N</lenient_string_to_number>
- </value-meta>
- <value-meta>
- <type>String</type>
- <storagetype>normal</storagetype>
+ <rename/>
+ </field>
+ <field>
<name>item_code</name>
- <length>2147483647</length>
- <precision>-1</precision>
- <origin>stock quant</origin>
- <comments>item_code</comments>
- <conversion_Mask/>
- <decimal_symbol>.</decimal_symbol>
- <grouping_symbol>,</grouping_symbol>
- <currency_symbol/>
- <trim_type>none</trim_type>
- <case_insensitive>N</case_insensitive>
- <collator_disabled>Y</collator_disabled>
- <collator_strength>0</collator_strength>
- <sort_descending>N</sort_descending>
- <output_padding>N</output_padding>
- <date_format_lenient>N</date_format_lenient>
- <date_format_locale>en_US</date_format_locale>
- <date_format_timezone>Asia/Bangkok</date_format_timezone>
- <lenient_string_to_number>N</lenient_string_to_number>
- </value-meta>
- <value-meta>
- <type>String</type>
- <storagetype>normal</storagetype>
+ <rename/>
+ </field>
+ <field>
<name>product_name</name>
- <length>2147483647</length>
- <precision>-1</precision>
- <origin>stock quant</origin>
- <comments>product_name</comments>
- <conversion_Mask/>
- <decimal_symbol>.</decimal_symbol>
- <grouping_symbol>,</grouping_symbol>
- <currency_symbol/>
- <trim_type>none</trim_type>
- <case_insensitive>N</case_insensitive>
- <collator_disabled>Y</collator_disabled>
- <collator_strength>0</collator_strength>
- <sort_descending>N</sort_descending>
- <output_padding>N</output_padding>
- <date_format_lenient>N</date_format_lenient>
- <date_format_locale>en_US</date_format_locale>
- <date_format_timezone>Asia/Bangkok</date_format_timezone>
- <lenient_string_to_number>N</lenient_string_to_number>
- </value-meta>
- <value-meta>
- <type>String</type>
- <storagetype>normal</storagetype>
+ <rename/>
+ </field>
+ <field>
<name>brand</name>
- <length>2147483647</length>
- <precision>-1</precision>
- <origin>stock quant</origin>
- <comments>brand</comments>
- <conversion_Mask/>
- <decimal_symbol>.</decimal_symbol>
- <grouping_symbol>,</grouping_symbol>
- <currency_symbol/>
- <trim_type>none</trim_type>
- <case_insensitive>N</case_insensitive>
- <collator_disabled>Y</collator_disabled>
- <collator_strength>0</collator_strength>
- <sort_descending>N</sort_descending>
- <output_padding>N</output_padding>
- <date_format_lenient>N</date_format_lenient>
- <date_format_locale>en_US</date_format_locale>
- <date_format_timezone>Asia/Bangkok</date_format_timezone>
- <lenient_string_to_number>N</lenient_string_to_number>
- </value-meta>
- <value-meta>
- <type>Number</type>
- <storagetype>normal</storagetype>
+ <rename/>
+ </field>
+ <field>
<name>qty</name>
- <length>-1</length>
- <precision>-1</precision>
- <origin>stock quant</origin>
- <comments>qty</comments>
- <conversion_Mask>####0.0#########;-####0.0#########</conversion_Mask>
- <decimal_symbol>.</decimal_symbol>
- <grouping_symbol>,</grouping_symbol>
- <currency_symbol/>
- <trim_type>none</trim_type>
- <case_insensitive>N</case_insensitive>
- <collator_disabled>Y</collator_disabled>
- <collator_strength>0</collator_strength>
- <sort_descending>N</sort_descending>
- <output_padding>N</output_padding>
- <date_format_lenient>N</date_format_lenient>
- <date_format_locale>en_US</date_format_locale>
- <date_format_timezone>Asia/Bangkok</date_format_timezone>
- <lenient_string_to_number>N</lenient_string_to_number>
- </value-meta>
- </row-meta>
+ <rename/>
+ </field>
+ <field>
+ <name>date_added</name>
+ <rename/>
+ </field>
+ <field>
+ <name>in_deadstock</name>
+ <rename/>
+ </field>
+ <field>
+ <name>in_movement</name>
+ <rename/>
+ </field>
+ <field>
+ <name>qty_outgoing</name>
+ <rename/>
+ </field>
+ <select_unspecified>N</select_unspecified>
+ </fields>
<attributes/>
<cluster_schema/>
<remotesteps>
@@ -1177,13 +1132,13 @@ order by sq.product_id</sql>
</output>
</remotesteps>
<GUI>
- <xloc>80</xloc>
- <yloc>144</yloc>
+ <xloc>864</xloc>
+ <yloc>256</yloc>
<draw>Y</draw>
</GUI>
</step>
<step>
- <name>Select values</name>
+ <name>Select values 3</name>
<type>SelectValues</type>
<description/>
<distribute>N</distribute>
@@ -1226,6 +1181,22 @@ order by sq.product_id</sql>
<name>in_movement</name>
<rename/>
</field>
+ <field>
+ <name>product_id_1</name>
+ <rename/>
+ </field>
+ <field>
+ <name>last_in</name>
+ <rename/>
+ </field>
+ <field>
+ <name>aging</name>
+ <rename/>
+ </field>
+ <field>
+ <name>qty_outgoing</name>
+ <rename/>
+ </field>
<select_unspecified>N</select_unspecified>
</fields>
<attributes/>
@@ -1237,13 +1208,13 @@ order by sq.product_id</sql>
</output>
</remotesteps>
<GUI>
- <xloc>864</xloc>
+ <xloc>1216</xloc>
<yloc>144</yloc>
<draw>Y</draw>
</GUI>
</step>
<step>
- <name>param product id</name>
+ <name>Select values 4</name>
<type>SelectValues</type>
<description/>
<distribute>Y</distribute>
@@ -1258,6 +1229,50 @@ order by sq.product_id</sql>
<name>product_id</name>
<rename/>
</field>
+ <field>
+ <name>item_code</name>
+ <rename/>
+ </field>
+ <field>
+ <name>product_name</name>
+ <rename/>
+ </field>
+ <field>
+ <name>brand</name>
+ <rename/>
+ </field>
+ <field>
+ <name>qty</name>
+ <rename/>
+ </field>
+ <field>
+ <name>date_added</name>
+ <rename/>
+ </field>
+ <field>
+ <name>in_deadstock</name>
+ <rename/>
+ </field>
+ <field>
+ <name>in_movement</name>
+ <rename/>
+ </field>
+ <field>
+ <name>product_id_1</name>
+ <rename/>
+ </field>
+ <field>
+ <name>last_in</name>
+ <rename/>
+ </field>
+ <field>
+ <name>aging</name>
+ <rename/>
+ </field>
+ <field>
+ <name>qty_outgoing</name>
+ <rename/>
+ </field>
<select_unspecified>N</select_unspecified>
</fields>
<attributes/>
@@ -1269,13 +1284,13 @@ order by sq.product_id</sql>
</output>
</remotesteps>
<GUI>
- <xloc>864</xloc>
- <yloc>48</yloc>
+ <xloc>1072</xloc>
+ <yloc>256</yloc>
<draw>Y</draw>
</GUI>
</step>
<step>
- <name>Select values 2</name>
+ <name>Select values 5</name>
<type>SelectValues</type>
<description/>
<distribute>Y</distribute>
@@ -1303,19 +1318,27 @@ order by sq.product_id</sql>
<rename/>
</field>
<field>
- <name>qty</name>
- <rename/>
+ <name>new_qty</name>
+ <rename>qty</rename>
</field>
<field>
<name>date_added</name>
<rename/>
</field>
<field>
- <name>in_deadstock</name>
+ <name>last_in</name>
<rename/>
</field>
<field>
- <name>in_movement</name>
+ <name>aging</name>
+ <rename/>
+ </field>
+ <field>
+ <name>last_cost</name>
+ <rename/>
+ </field>
+ <field>
+ <name>total_cost</name>
<rename/>
</field>
<select_unspecified>N</select_unspecified>
@@ -1329,14 +1352,14 @@ order by sq.product_id</sql>
</output>
</remotesteps>
<GUI>
- <xloc>864</xloc>
- <yloc>256</yloc>
+ <xloc>352</xloc>
+ <yloc>368</yloc>
<draw>Y</draw>
</GUI>
</step>
<step>
- <name>get last in</name>
- <type>TableInput</type>
+ <name>Sort rows</name>
+ <type>SortRows</type>
<description/>
<distribute>Y</distribute>
<custom_distribution/>
@@ -1345,94 +1368,23 @@ order by sq.product_id</sql>
<method>none</method>
<schema_name/>
</partitioning>
- <connection>dw bi indoteknik (localhost)</connection>
- <sql>select sm.product_id, sm.create_date as last_in,
-(date_part('epoch'::text, age(now()::timestamp, sm.create_date)) / 3600) / 24::numeric as aging
-from stock_move sm
-join stock_location sl on sl.id = sm.location_dest_id
-where 1=1
-and sl.name in ('Input', 'Stock')
-and sm.state = 'done'
-and sm.product_id = ?
-order by sm.create_date desc
-limit 1</sql>
- <limit>0</limit>
- <lookup>param product id</lookup>
- <execute_each_row>Y</execute_each_row>
- <variables_active>Y</variables_active>
- <lazy_conversion_active>N</lazy_conversion_active>
- <cached_row_meta_active>N</cached_row_meta_active>
- <row-meta>
- <value-meta>
- <type>Integer</type>
- <storagetype>normal</storagetype>
+ <directory>%%java.io.tmpdir%%</directory>
+ <prefix>out</prefix>
+ <sort_size>1000000</sort_size>
+ <free_memory/>
+ <compress>N</compress>
+ <compress_variable/>
+ <unique_rows>N</unique_rows>
+ <fields>
+ <field>
<name>product_id</name>
- <length>9</length>
- <precision>0</precision>
- <origin>get last in</origin>
- <comments>product_id</comments>
- <conversion_Mask>####0;-####0</conversion_Mask>
- <decimal_symbol>.</decimal_symbol>
- <grouping_symbol>,</grouping_symbol>
- <currency_symbol/>
- <trim_type>none</trim_type>
- <case_insensitive>N</case_insensitive>
- <collator_disabled>Y</collator_disabled>
- <collator_strength>0</collator_strength>
- <sort_descending>N</sort_descending>
- <output_padding>N</output_padding>
- <date_format_lenient>N</date_format_lenient>
- <date_format_locale>en_US</date_format_locale>
- <date_format_timezone>Asia/Bangkok</date_format_timezone>
- <lenient_string_to_number>N</lenient_string_to_number>
- </value-meta>
- <value-meta>
- <type>Timestamp</type>
- <storagetype>normal</storagetype>
- <name>last_in</name>
- <length>6</length>
- <precision>-1</precision>
- <origin>get last in</origin>
- <comments>last_in</comments>
- <conversion_Mask/>
- <decimal_symbol>.</decimal_symbol>
- <grouping_symbol>,</grouping_symbol>
- <currency_symbol/>
- <trim_type>none</trim_type>
- <case_insensitive>N</case_insensitive>
- <collator_disabled>Y</collator_disabled>
- <collator_strength>0</collator_strength>
- <sort_descending>N</sort_descending>
- <output_padding>N</output_padding>
- <date_format_lenient>N</date_format_lenient>
- <date_format_locale>en_US</date_format_locale>
- <date_format_timezone>Asia/Bangkok</date_format_timezone>
- <lenient_string_to_number>N</lenient_string_to_number>
- </value-meta>
- <value-meta>
- <type>Number</type>
- <storagetype>normal</storagetype>
- <name>aging</name>
- <length>-1</length>
- <precision>-1</precision>
- <origin>get last in</origin>
- <comments>aging</comments>
- <conversion_Mask>####0.0#########;-####0.0#########</conversion_Mask>
- <decimal_symbol>.</decimal_symbol>
- <grouping_symbol>,</grouping_symbol>
- <currency_symbol/>
- <trim_type>none</trim_type>
- <case_insensitive>N</case_insensitive>
- <collator_disabled>Y</collator_disabled>
+ <ascending>Y</ascending>
+ <case_sensitive>N</case_sensitive>
+ <collator_enabled>N</collator_enabled>
<collator_strength>0</collator_strength>
- <sort_descending>N</sort_descending>
- <output_padding>N</output_padding>
- <date_format_lenient>N</date_format_lenient>
- <date_format_locale>en_US</date_format_locale>
- <date_format_timezone>Asia/Bangkok</date_format_timezone>
- <lenient_string_to_number>N</lenient_string_to_number>
- </value-meta>
- </row-meta>
+ <presorted>N</presorted>
+ </field>
+ </fields>
<attributes/>
<cluster_schema/>
<remotesteps>
@@ -1443,12 +1395,12 @@ limit 1</sql>
</remotesteps>
<GUI>
<xloc>976</xloc>
- <yloc>48</yloc>
+ <yloc>144</yloc>
<draw>Y</draw>
</GUI>
</step>
<step>
- <name>Sort rows</name>
+ <name>Sort rows 2</name>
<type>SortRows</type>
<description/>
<distribute>Y</distribute>
@@ -1484,13 +1436,13 @@ limit 1</sql>
</output>
</remotesteps>
<GUI>
- <xloc>976</xloc>
- <yloc>144</yloc>
+ <xloc>1072</xloc>
+ <yloc>48</yloc>
<draw>Y</draw>
</GUI>
</step>
<step>
- <name>Sort rows 2</name>
+ <name>Sort rows 3</name>
<type>SortRows</type>
<description/>
<distribute>Y</distribute>
@@ -1508,14 +1460,6 @@ limit 1</sql>
<compress_variable/>
<unique_rows>N</unique_rows>
<fields>
- <field>
- <name>product_id</name>
- <ascending>Y</ascending>
- <case_sensitive>N</case_sensitive>
- <collator_enabled>N</collator_enabled>
- <collator_strength>0</collator_strength>
- <presorted>N</presorted>
- </field>
</fields>
<attributes/>
<cluster_schema/>
@@ -1526,14 +1470,14 @@ limit 1</sql>
</output>
</remotesteps>
<GUI>
- <xloc>1072</xloc>
- <yloc>48</yloc>
+ <xloc>1008</xloc>
+ <yloc>336</yloc>
<draw>Y</draw>
</GUI>
</step>
<step>
- <name>Merge join</name>
- <type>MergeJoin</type>
+ <name>Sort rows 4</name>
+ <type>SortRows</type>
<description/>
<distribute>Y</distribute>
<custom_distribution/>
@@ -1542,15 +1486,15 @@ limit 1</sql>
<method>none</method>
<schema_name/>
</partitioning>
- <join_type>LEFT OUTER</join_type>
- <step1>Sort rows</step1>
- <step2>Sort rows 2</step2>
- <keys_1>
- <key>product_id</key>
- </keys_1>
- <keys_2>
- <key>product_id</key>
- </keys_2>
+ <directory>%%java.io.tmpdir%%</directory>
+ <prefix>out</prefix>
+ <sort_size>1000000</sort_size>
+ <free_memory/>
+ <compress>N</compress>
+ <compress_variable/>
+ <unique_rows>N</unique_rows>
+ <fields>
+ </fields>
<attributes/>
<cluster_schema/>
<remotesteps>
@@ -1560,69 +1504,81 @@ limit 1</sql>
</output>
</remotesteps>
<GUI>
- <xloc>1072</xloc>
+ <xloc>1120</xloc>
+ <yloc>368</yloc>
+ <draw>Y</draw>
+ </GUI>
+ </step>
+ <step>
+ <name>Stream lookup</name>
+ <type>StreamLookup</type>
+ <description/>
+ <distribute>Y</distribute>
+ <custom_distribution/>
+ <copies>1</copies>
+ <partitioning>
+ <method>none</method>
+ <schema_name/>
+ </partitioning>
+ <from>dead stock</from>
+ <input_sorted>N</input_sorted>
+ <preserve_memory>Y</preserve_memory>
+ <sorted_list>N</sorted_list>
+ <integer_pair>N</integer_pair>
+ <lookup>
+ <key>
+ <name>product_id</name>
+ <field>product_id</field>
+ </key>
+ <value>
+ <name>product_id</name>
+ <rename>in_deadstock</rename>
+ <default/>
+ <type>Integer</type>
+ </value>
+ </lookup>
+ <attributes/>
+ <cluster_schema/>
+ <remotesteps>
+ <input>
+ </input>
+ <output>
+ </output>
+ </remotesteps>
+ <GUI>
+ <xloc>224</xloc>
<yloc>144</yloc>
<draw>Y</draw>
</GUI>
</step>
<step>
- <name>Select values 3</name>
- <type>SelectValues</type>
+ <name>Stream lookup 2</name>
+ <type>StreamLookup</type>
<description/>
- <distribute>N</distribute>
+ <distribute>Y</distribute>
<custom_distribution/>
<copies>1</copies>
<partitioning>
<method>none</method>
<schema_name/>
</partitioning>
- <fields>
- <field>
+ <from>movement</from>
+ <input_sorted>N</input_sorted>
+ <preserve_memory>Y</preserve_memory>
+ <sorted_list>N</sorted_list>
+ <integer_pair>N</integer_pair>
+ <lookup>
+ <key>
<name>product_id</name>
- <rename/>
- </field>
- <field>
- <name>item_code</name>
- <rename/>
- </field>
- <field>
- <name>product_name</name>
- <rename/>
- </field>
- <field>
- <name>brand</name>
- <rename/>
- </field>
- <field>
- <name>qty</name>
- <rename/>
- </field>
- <field>
- <name>date_added</name>
- <rename/>
- </field>
- <field>
- <name>in_deadstock</name>
- <rename/>
- </field>
- <field>
- <name>in_movement</name>
- <rename/>
- </field>
- <field>
- <name>product_id_1</name>
- <rename/>
- </field>
- <field>
- <name>last_in</name>
- <rename/>
- </field>
- <field>
- <name>aging</name>
- <rename/>
- </field>
- <select_unspecified>N</select_unspecified>
- </fields>
+ <field>product_id</field>
+ </key>
+ <value>
+ <name>product_id</name>
+ <rename>in_movement</rename>
+ <default/>
+ <type>None</type>
+ </value>
+ </lookup>
<attributes/>
<cluster_schema/>
<remotesteps>
@@ -1632,14 +1588,14 @@ limit 1</sql>
</output>
</remotesteps>
<GUI>
- <xloc>1216</xloc>
+ <xloc>560</xloc>
<yloc>144</yloc>
<draw>Y</draw>
</GUI>
</step>
<step>
- <name>param product id 2</name>
- <type>SelectValues</type>
+ <name>Write to log</name>
+ <type>WriteToLog</type>
<description/>
<distribute>Y</distribute>
<custom_distribution/>
@@ -1648,13 +1604,13 @@ limit 1</sql>
<method>none</method>
<schema_name/>
</partitioning>
+ <loglevel>log_level_basic</loglevel>
+ <displayHeader>Y</displayHeader>
+ <limitRows>N</limitRows>
+ <limitRowsNumber>0</limitRowsNumber>
+ <logmessage/>
<fields>
- <field>
- <name>product_id</name>
- <rename/>
- </field>
- <select_unspecified>N</select_unspecified>
- </fields>
+ </fields>
<attributes/>
<cluster_schema/>
<remotesteps>
@@ -1664,14 +1620,14 @@ limit 1</sql>
</output>
</remotesteps>
<GUI>
- <xloc>1216</xloc>
- <yloc>256</yloc>
+ <xloc>400</xloc>
+ <yloc>224</yloc>
<draw>Y</draw>
</GUI>
</step>
<step>
- <name>Select values 4</name>
- <type>SelectValues</type>
+ <name>Write to log 2</name>
+ <type>WriteToLog</type>
<description/>
<distribute>Y</distribute>
<custom_distribution/>
@@ -1680,53 +1636,13 @@ limit 1</sql>
<method>none</method>
<schema_name/>
</partitioning>
+ <loglevel>log_level_basic</loglevel>
+ <displayHeader>Y</displayHeader>
+ <limitRows>N</limitRows>
+ <limitRowsNumber>0</limitRowsNumber>
+ <logmessage/>
<fields>
- <field>
- <name>product_id</name>
- <rename/>
- </field>
- <field>
- <name>item_code</name>
- <rename/>
- </field>
- <field>
- <name>product_name</name>
- <rename/>
- </field>
- <field>
- <name>brand</name>
- <rename/>
- </field>
- <field>
- <name>qty</name>
- <rename/>
- </field>
- <field>
- <name>date_added</name>
- <rename/>
- </field>
- <field>
- <name>in_deadstock</name>
- <rename/>
- </field>
- <field>
- <name>in_movement</name>
- <rename/>
- </field>
- <field>
- <name>product_id_1</name>
- <rename/>
- </field>
- <field>
- <name>last_in</name>
- <rename/>
- </field>
- <field>
- <name>aging</name>
- <rename/>
- </field>
- <select_unspecified>N</select_unspecified>
- </fields>
+ </fields>
<attributes/>
<cluster_schema/>
<remotesteps>
@@ -1736,8 +1652,8 @@ limit 1</sql>
</output>
</remotesteps>
<GUI>
- <xloc>1072</xloc>
- <yloc>256</yloc>
+ <xloc>720</xloc>
+ <yloc>224</yloc>
<draw>Y</draw>
</GUI>
</step>
@@ -1781,59 +1697,13 @@ order by pp.id</sql>
<name>product_id</name>
<length>9</length>
<precision>0</precision>
- <origin>stock quant</origin>
+ <origin>avg hpp</origin>
<comments>product_id</comments>
<conversion_Mask>####0;-####0</conversion_Mask>
<decimal_symbol>.</decimal_symbol>
<grouping_symbol>,</grouping_symbol>
<currency_symbol/>
<trim_type>none</trim_type>
- <case_insensitive>Y</case_insensitive>
- <collator_disabled>Y</collator_disabled>
- <collator_strength>0</collator_strength>
- <sort_descending>N</sort_descending>
- <output_padding>N</output_padding>
- <date_format_lenient>N</date_format_lenient>
- <date_format_locale>en_US</date_format_locale>
- <date_format_timezone>Asia/Bangkok</date_format_timezone>
- <lenient_string_to_number>N</lenient_string_to_number>
- </value-meta>
- <value-meta>
- <type>String</type>
- <storagetype>normal</storagetype>
- <name>item_code</name>
- <length>2147483647</length>
- <precision>-1</precision>
- <origin>stock quant</origin>
- <comments>item_code</comments>
- <conversion_Mask/>
- <decimal_symbol>.</decimal_symbol>
- <grouping_symbol>,</grouping_symbol>
- <currency_symbol/>
- <trim_type>none</trim_type>
- <case_insensitive>N</case_insensitive>
- <collator_disabled>Y</collator_disabled>
- <collator_strength>0</collator_strength>
- <sort_descending>N</sort_descending>
- <output_padding>N</output_padding>
- <date_format_lenient>N</date_format_lenient>
- <date_format_locale>en_US</date_format_locale>
- <date_format_timezone>Asia/Bangkok</date_format_timezone>
- <lenient_string_to_number>N</lenient_string_to_number>
- </value-meta>
- <value-meta>
- <type>String</type>
- <storagetype>normal</storagetype>
- <name>product_name</name>
- <length>2147483647</length>
- <precision>-1</precision>
- <origin>stock quant</origin>
- <comments>product_name</comments>
- <conversion_Mask/>
- <decimal_symbol>.</decimal_symbol>
- <grouping_symbol>,</grouping_symbol>
- <currency_symbol/>
- <trim_type>none</trim_type>
<case_insensitive>N</case_insensitive>
<collator_disabled>Y</collator_disabled>
<collator_strength>0</collator_strength>
@@ -1845,39 +1715,16 @@ order by pp.id</sql>
<lenient_string_to_number>N</lenient_string_to_number>
</value-meta>
<value-meta>
- <type>String</type>
+ <type>BigNumber</type>
<storagetype>normal</storagetype>
- <name>brand</name>
- <length>2147483647</length>
- <precision>-1</precision>
- <origin>stock quant</origin>
- <comments>brand</comments>
- <conversion_Mask/>
- <decimal_symbol>.</decimal_symbol>
- <grouping_symbol>,</grouping_symbol>
- <currency_symbol/>
- <trim_type>none</trim_type>
- <case_insensitive>N</case_insensitive>
- <collator_disabled>Y</collator_disabled>
- <collator_strength>0</collator_strength>
- <sort_descending>N</sort_descending>
- <output_padding>N</output_padding>
- <date_format_lenient>N</date_format_lenient>
- <date_format_locale>en_US</date_format_locale>
- <date_format_timezone>Asia/Bangkok</date_format_timezone>
- <lenient_string_to_number>N</lenient_string_to_number>
- </value-meta>
- <value-meta>
- <type>Number</type>
- <storagetype>normal</storagetype>
- <name>qty</name>
+ <name>last_cost</name>
<length>-1</length>
<precision>-1</precision>
- <origin>stock quant</origin>
- <comments>qty</comments>
- <conversion_Mask>####0.0#########;-####0.0#########</conversion_Mask>
+ <origin>avg hpp</origin>
+ <comments>last_cost</comments>
+ <conversion_Mask>######0.0###################;-######0.0###################</conversion_Mask>
<decimal_symbol>.</decimal_symbol>
- <grouping_symbol>,</grouping_symbol>
+ <grouping_symbol/>
<currency_symbol/>
<trim_type>none</trim_type>
<case_insensitive>N</case_insensitive>
@@ -1890,13 +1737,48 @@ order by pp.id</sql>
<date_format_timezone>Asia/Bangkok</date_format_timezone>
<lenient_string_to_number>N</lenient_string_to_number>
</value-meta>
+ </row-meta>
+ <attributes/>
+ <cluster_schema/>
+ <remotesteps>
+ <input>
+ </input>
+ <output>
+ </output>
+ </remotesteps>
+ <GUI>
+ <xloc>1216</xloc>
+ <yloc>368</yloc>
+ <draw>Y</draw>
+ </GUI>
+ </step>
+ <step>
+ <name>dead stock</name>
+ <type>TableInput</type>
+ <description/>
+ <distribute>Y</distribute>
+ <custom_distribution/>
+ <copies>1</copies>
+ <partitioning>
+ <method>none</method>
+ <schema_name/>
+ </partitioning>
+ <connection>dw bi indoteknik (localhost)</connection>
+ <sql>select distinct product_id from list_deadstock</sql>
+ <limit>0</limit>
+ <lookup/>
+ <execute_each_row>N</execute_each_row>
+ <variables_active>N</variables_active>
+ <lazy_conversion_active>N</lazy_conversion_active>
+ <cached_row_meta_active>N</cached_row_meta_active>
+ <row-meta>
<value-meta>
<type>Integer</type>
<storagetype>normal</storagetype>
- <name>in_deadstock</name>
+ <name>product_id</name>
<length>9</length>
<precision>0</precision>
- <origin>Stream lookup</origin>
+ <origin>dead stock</origin>
<comments>product_id</comments>
<conversion_Mask>####0;-####0</conversion_Mask>
<decimal_symbol>.</decimal_symbol>
@@ -1913,13 +1795,57 @@ order by pp.id</sql>
<date_format_timezone>Asia/Bangkok</date_format_timezone>
<lenient_string_to_number>N</lenient_string_to_number>
</value-meta>
+ </row-meta>
+ <attributes/>
+ <cluster_schema/>
+ <remotesteps>
+ <input>
+ </input>
+ <output>
+ </output>
+ </remotesteps>
+ <GUI>
+ <xloc>224</xloc>
+ <yloc>48</yloc>
+ <draw>Y</draw>
+ </GUI>
+ </step>
+ <step>
+ <name>get last in</name>
+ <type>TableInput</type>
+ <description/>
+ <distribute>Y</distribute>
+ <custom_distribution/>
+ <copies>1</copies>
+ <partitioning>
+ <method>none</method>
+ <schema_name/>
+ </partitioning>
+ <connection>erp indoteknik production (localhost)</connection>
+ <sql>select sm.product_id, sm.create_date as last_in,
+(date_part('epoch'::text, age(now()::timestamp, sm.create_date)) / 3600) / 24::numeric as aging
+from stock_move sm
+join stock_location sl on sl.id = sm.location_dest_id
+where 1=1
+and sl.name in ('Input', 'Stock')
+and sm.state = 'done'
+and sm.product_id = ?
+order by sm.create_date desc
+limit 1</sql>
+ <limit>0</limit>
+ <lookup>param product id</lookup>
+ <execute_each_row>Y</execute_each_row>
+ <variables_active>Y</variables_active>
+ <lazy_conversion_active>N</lazy_conversion_active>
+ <cached_row_meta_active>N</cached_row_meta_active>
+ <row-meta>
<value-meta>
<type>Integer</type>
<storagetype>normal</storagetype>
- <name>in_movement</name>
+ <name>product_id</name>
<length>9</length>
<precision>0</precision>
- <origin>Stream lookup 2</origin>
+ <origin>get last in</origin>
<comments>product_id</comments>
<conversion_Mask>####0;-####0</conversion_Mask>
<decimal_symbol>.</decimal_symbol>
@@ -1937,19 +1863,19 @@ order by pp.id</sql>
<lenient_string_to_number>N</lenient_string_to_number>
</value-meta>
<value-meta>
- <type>Integer</type>
+ <type>Timestamp</type>
<storagetype>normal</storagetype>
- <name>product_id_1</name>
- <length>9</length>
- <precision>0</precision>
- <origin>Merge join</origin>
- <comments>product_id</comments>
- <conversion_Mask>####0;-####0</conversion_Mask>
+ <name>last_in</name>
+ <length>6</length>
+ <precision>-1</precision>
+ <origin>get last in</origin>
+ <comments>last_in</comments>
+ <conversion_Mask/>
<decimal_symbol>.</decimal_symbol>
<grouping_symbol>,</grouping_symbol>
<currency_symbol/>
<trim_type>none</trim_type>
- <case_insensitive>Y</case_insensitive>
+ <case_insensitive>N</case_insensitive>
<collator_disabled>Y</collator_disabled>
<collator_strength>0</collator_strength>
<sort_descending>N</sort_descending>
@@ -1960,14 +1886,14 @@ order by pp.id</sql>
<lenient_string_to_number>N</lenient_string_to_number>
</value-meta>
<value-meta>
- <type>Timestamp</type>
+ <type>Number</type>
<storagetype>normal</storagetype>
- <name>last_in</name>
- <length>6</length>
+ <name>aging</name>
+ <length>-1</length>
<precision>-1</precision>
<origin>get last in</origin>
- <comments>last_in</comments>
- <conversion_Mask/>
+ <comments>aging</comments>
+ <conversion_Mask>####0.0#########;-####0.0#########</conversion_Mask>
<decimal_symbol>.</decimal_symbol>
<grouping_symbol>,</grouping_symbol>
<currency_symbol/>
@@ -1992,14 +1918,14 @@ order by pp.id</sql>
</output>
</remotesteps>
<GUI>
- <xloc>1216</xloc>
- <yloc>368</yloc>
+ <xloc>976</xloc>
+ <yloc>48</yloc>
<draw>Y</draw>
</GUI>
</step>
<step>
- <name>Sort rows 3</name>
- <type>SortRows</type>
+ <name>movement</name>
+ <type>TableInput</type>
<description/>
<distribute>Y</distribute>
<custom_distribution/>
@@ -2008,15 +1934,45 @@ order by pp.id</sql>
<method>none</method>
<schema_name/>
</partitioning>
- <directory>%%java.io.tmpdir%%</directory>
- <prefix>out</prefix>
- <sort_size>1000000</sort_size>
- <free_memory/>
- <compress>N</compress>
- <compress_variable/>
- <unique_rows>N</unique_rows>
- <fields>
- </fields>
+ <connection>dw bi indoteknik (localhost)</connection>
+ <sql>select distinct sm.product_id
+from stock_move sm
+join stock_location sl on sl.id = sm.location_dest_id
+where 1=1
+and sl.name in ('Customers', 'Production')
+and sm.state = 'done'
+and sm.create_date >= (now() - '180 days'::interval)</sql>
+ <limit>0</limit>
+ <lookup/>
+ <execute_each_row>N</execute_each_row>
+ <variables_active>N</variables_active>
+ <lazy_conversion_active>N</lazy_conversion_active>
+ <cached_row_meta_active>N</cached_row_meta_active>
+ <row-meta>
+ <value-meta>
+ <type>Integer</type>
+ <storagetype>normal</storagetype>
+ <name>product_id</name>
+ <length>9</length>
+ <precision>0</precision>
+ <origin>movement</origin>
+ <comments>product_id</comments>
+ <conversion_Mask>####0;-####0</conversion_Mask>
+ <decimal_symbol>.</decimal_symbol>
+ <grouping_symbol>,</grouping_symbol>
+ <currency_symbol/>
+ <trim_type>none</trim_type>
+ <case_insensitive>N</case_insensitive>
+ <collator_disabled>Y</collator_disabled>
+ <collator_strength>0</collator_strength>
+ <sort_descending>N</sort_descending>
+ <output_padding>N</output_padding>
+ <date_format_lenient>N</date_format_lenient>
+ <date_format_locale>en_US</date_format_locale>
+ <date_format_timezone>Asia/Bangkok</date_format_timezone>
+ <lenient_string_to_number>N</lenient_string_to_number>
+ </value-meta>
+ </row-meta>
<attributes/>
<cluster_schema/>
<remotesteps>
@@ -2026,14 +1982,14 @@ order by pp.id</sql>
</output>
</remotesteps>
<GUI>
- <xloc>1008</xloc>
- <yloc>336</yloc>
+ <xloc>560</xloc>
+ <yloc>48</yloc>
<draw>Y</draw>
</GUI>
</step>
<step>
- <name>Sort rows 4</name>
- <type>SortRows</type>
+ <name>param product id</name>
+ <type>SelectValues</type>
<description/>
<distribute>Y</distribute>
<custom_distribution/>
@@ -2042,14 +1998,11 @@ order by pp.id</sql>
<method>none</method>
<schema_name/>
</partitioning>
- <directory>%%java.io.tmpdir%%</directory>
- <prefix>out</prefix>
- <sort_size>1000000</sort_size>
- <free_memory/>
- <compress>N</compress>
- <compress_variable/>
- <unique_rows>N</unique_rows>
<fields>
+ <field>
+ <name>product_id</name>
+ </field>
+ <select_unspecified>N</select_unspecified>
</fields>
<attributes/>
<cluster_schema/>
@@ -2060,47 +2013,13 @@ order by pp.id</sql>
</output>
</remotesteps>
<GUI>
- <xloc>1120</xloc>
- <yloc>368</yloc>
- <draw>Y</draw>
- </GUI>
- </step>
- <step>
- <name>Merge join 2</name>
- <type>MergeJoin</type>
- <description/>
- <distribute>Y</distribute>
- <custom_distribution/>
- <copies>1</copies>
- <partitioning>
- <method>none</method>
- <schema_name/>
- </partitioning>
- <join_type>LEFT OUTER</join_type>
- <step1>Sort rows 3</step1>
- <step2>Sort rows 4</step2>
- <keys_1>
- <key>product_id</key>
- </keys_1>
- <keys_2>
- <key>product_id</key>
- </keys_2>
- <attributes/>
- <cluster_schema/>
- <remotesteps>
- <input>
- </input>
- <output>
- </output>
- </remotesteps>
- <GUI>
- <xloc>880</xloc>
- <yloc>368</yloc>
+ <xloc>864</xloc>
+ <yloc>48</yloc>
<draw>Y</draw>
</GUI>
</step>
<step>
- <name>Select values 5</name>
+ <name>param product id 2</name>
<type>SelectValues</type>
<description/>
<distribute>Y</distribute>
@@ -2113,43 +2032,6 @@ order by pp.id</sql>
<fields>
<field>
<name>product_id</name>
- <rename/>
- </field>
- <field>
- <name>item_code</name>
- <rename/>
- </field>
- <field>
- <name>product_name</name>
- <rename/>
- </field>
- <field>
- <name>brand</name>
- <rename/>
- </field>
- <field>
- <name>qty</name>
- <rename/>
- </field>
- <field>
- <name>date_added</name>
- <rename/>
- </field>
- <field>
- <name>last_in</name>
- <rename/>
- </field>
- <field>
- <name>aging</name>
- <rename/>
- </field>
- <field>
- <name>last_cost</name>
- <rename/>
- </field>
- <field>
- <name>total_cost</name>
- <rename/>
</field>
<select_unspecified>N</select_unspecified>
</fields>
@@ -2162,14 +2044,14 @@ order by pp.id</sql>
</output>
</remotesteps>
<GUI>
- <xloc>432</xloc>
- <yloc>368</yloc>
+ <xloc>1216</xloc>
+ <yloc>256</yloc>
<draw>Y</draw>
</GUI>
</step>
<step>
- <name>If field value is null</name>
- <type>IfNull</type>
+ <name>stock quant</name>
+ <type>TableInput</type>
<description/>
<distribute>Y</distribute>
<custom_distribution/>
@@ -2178,27 +2060,191 @@ order by pp.id</sql>
<method>none</method>
<schema_name/>
</partitioning>
- <replaceAllByValue>0</replaceAllByValue>
- <replaceAllMask/>
- <selectFields>Y</selectFields>
- <selectValuesType>N</selectValuesType>
- <setEmptyStringAll>N</setEmptyStringAll>
- <valuetypes>
- </valuetypes>
- <fields>
- <field>
- <name>aging</name>
- <value>0</value>
- <mask/>
- <set_empty_string>N</set_empty_string>
- </field>
- <field>
- <name>last_cost</name>
- <value>0</value>
- <mask/>
- <set_empty_string>N</set_empty_string>
- </field>
- </fields>
+ <connection>erp indoteknik production (localhost)</connection>
+ <sql>select sq.product_id, coalesce(pp.default_code, pt.default_code) as item_code, pt.name as product_name, xm.x_name as brand,
+sum(quantity) as qty, now()::timestamp as date_added,
+get_qty_outgoing(sq.product_id) as qty_outgoing
+from stock_quant sq
+join stock_location sl on sl.id = sq.location_id
+join product_product pp on pp.id = sq.product_id
+join product_template pt on pt.id = pp.product_tmpl_id
+left join x_manufactures xm on xm.id = pt.x_manufacture
+where 1=1
+and sq.location_id in(select id from stock_location where usage = 'internal' and active = true)
+and pt.name not ilike '%promotion%' and pt.name not ilike '%asset%mesin%peralatan%'
+and pt.name not ilike '%asset%inventaris%' and pt.name not ilike '%asset%kendaraan%'
+group by sq.product_id, pp.default_code, pt.default_code, pt.name, xm.x_name
+having sum(quantity) > 0
+order by sq.product_id</sql>
+ <limit>0</limit>
+ <lookup/>
+ <execute_each_row>N</execute_each_row>
+ <variables_active>N</variables_active>
+ <lazy_conversion_active>N</lazy_conversion_active>
+ <cached_row_meta_active>N</cached_row_meta_active>
+ <row-meta>
+ <value-meta>
+ <type>Integer</type>
+ <storagetype>normal</storagetype>
+ <name>product_id</name>
+ <length>9</length>
+ <precision>0</precision>
+ <origin>stock quant</origin>
+ <comments>product_id</comments>
+ <conversion_Mask>####0;-####0</conversion_Mask>
+ <decimal_symbol>.</decimal_symbol>
+ <grouping_symbol>,</grouping_symbol>
+ <currency_symbol/>
+ <trim_type>none</trim_type>
+ <case_insensitive>N</case_insensitive>
+ <collator_disabled>Y</collator_disabled>
+ <collator_strength>0</collator_strength>
+ <sort_descending>N</sort_descending>
+ <output_padding>N</output_padding>
+ <date_format_lenient>N</date_format_lenient>
+ <date_format_locale>en_US</date_format_locale>
+ <date_format_timezone>Asia/Bangkok</date_format_timezone>
+ <lenient_string_to_number>N</lenient_string_to_number>
+ </value-meta>
+ <value-meta>
+ <type>String</type>
+ <storagetype>normal</storagetype>
+ <name>item_code</name>
+ <length>2147483647</length>
+ <precision>-1</precision>
+ <origin>stock quant</origin>
+ <comments>item_code</comments>
+ <conversion_Mask/>
+ <decimal_symbol>.</decimal_symbol>
+ <grouping_symbol>,</grouping_symbol>
+ <currency_symbol/>
+ <trim_type>none</trim_type>
+ <case_insensitive>N</case_insensitive>
+ <collator_disabled>Y</collator_disabled>
+ <collator_strength>0</collator_strength>
+ <sort_descending>N</sort_descending>
+ <output_padding>N</output_padding>
+ <date_format_lenient>N</date_format_lenient>
+ <date_format_locale>en_US</date_format_locale>
+ <date_format_timezone>Asia/Bangkok</date_format_timezone>
+ <lenient_string_to_number>N</lenient_string_to_number>
+ </value-meta>
+ <value-meta>
+ <type>String</type>
+ <storagetype>normal</storagetype>
+ <name>product_name</name>
+ <length>2147483647</length>
+ <precision>-1</precision>
+ <origin>stock quant</origin>
+ <comments>product_name</comments>
+ <conversion_Mask/>
+ <decimal_symbol>.</decimal_symbol>
+ <grouping_symbol>,</grouping_symbol>
+ <currency_symbol/>
+ <trim_type>none</trim_type>
+ <case_insensitive>N</case_insensitive>
+ <collator_disabled>Y</collator_disabled>
+ <collator_strength>0</collator_strength>
+ <sort_descending>N</sort_descending>
+ <output_padding>N</output_padding>
+ <date_format_lenient>N</date_format_lenient>
+ <date_format_locale>en_US</date_format_locale>
+ <date_format_timezone>Asia/Bangkok</date_format_timezone>
+ <lenient_string_to_number>N</lenient_string_to_number>
+ </value-meta>
+ <value-meta>
+ <type>String</type>
+ <storagetype>normal</storagetype>
+ <name>brand</name>
+ <length>2147483647</length>
+ <precision>-1</precision>
+ <origin>stock quant</origin>
+ <comments>brand</comments>
+ <conversion_Mask/>
+ <decimal_symbol>.</decimal_symbol>
+ <grouping_symbol>,</grouping_symbol>
+ <currency_symbol/>
+ <trim_type>none</trim_type>
+ <case_insensitive>N</case_insensitive>
+ <collator_disabled>Y</collator_disabled>
+ <collator_strength>0</collator_strength>
+ <sort_descending>N</sort_descending>
+ <output_padding>N</output_padding>
+ <date_format_lenient>N</date_format_lenient>
+ <date_format_locale>en_US</date_format_locale>
+ <date_format_timezone>Asia/Bangkok</date_format_timezone>
+ <lenient_string_to_number>N</lenient_string_to_number>
+ </value-meta>
+ <value-meta>
+ <type>Number</type>
+ <storagetype>normal</storagetype>
+ <name>qty</name>
+ <length>-1</length>
+ <precision>-1</precision>
+ <origin>stock quant</origin>
+ <comments>qty</comments>
+ <conversion_Mask>####0.0#########;-####0.0#########</conversion_Mask>
+ <decimal_symbol>.</decimal_symbol>
+ <grouping_symbol>,</grouping_symbol>
+ <currency_symbol/>
+ <trim_type>none</trim_type>
+ <case_insensitive>N</case_insensitive>
+ <collator_disabled>Y</collator_disabled>
+ <collator_strength>0</collator_strength>
+ <sort_descending>N</sort_descending>
+ <output_padding>N</output_padding>
+ <date_format_lenient>N</date_format_lenient>
+ <date_format_locale>en_US</date_format_locale>
+ <date_format_timezone>Asia/Bangkok</date_format_timezone>
+ <lenient_string_to_number>N</lenient_string_to_number>
+ </value-meta>
+ <value-meta>
+ <type>Timestamp</type>
+ <storagetype>normal</storagetype>
+ <name>date_added</name>
+ <length>6</length>
+ <precision>-1</precision>
+ <origin>stock quant</origin>
+ <comments>date_added</comments>
+ <conversion_Mask/>
+ <decimal_symbol>.</decimal_symbol>
+ <grouping_symbol>,</grouping_symbol>
+ <currency_symbol/>
+ <trim_type>none</trim_type>
+ <case_insensitive>N</case_insensitive>
+ <collator_disabled>Y</collator_disabled>
+ <collator_strength>0</collator_strength>
+ <sort_descending>N</sort_descending>
+ <output_padding>N</output_padding>
+ <date_format_lenient>N</date_format_lenient>
+ <date_format_locale>en_US</date_format_locale>
+ <date_format_timezone>Asia/Bangkok</date_format_timezone>
+ <lenient_string_to_number>N</lenient_string_to_number>
+ </value-meta>
+ <value-meta>
+ <type>BigNumber</type>
+ <storagetype>normal</storagetype>
+ <name>qty_outgoing</name>
+ <length>-1</length>
+ <precision>-1</precision>
+ <origin>stock quant</origin>
+ <comments>qty_outgoing</comments>
+ <conversion_Mask>######0.0###################;-######0.0###################</conversion_Mask>
+ <decimal_symbol>.</decimal_symbol>
+ <grouping_symbol/>
+ <currency_symbol/>
+ <trim_type>none</trim_type>
+ <case_insensitive>N</case_insensitive>
+ <collator_disabled>Y</collator_disabled>
+ <collator_strength>0</collator_strength>
+ <sort_descending>N</sort_descending>
+ <output_padding>N</output_padding>
+ <date_format_lenient>N</date_format_lenient>
+ <date_format_locale>en_US</date_format_locale>
+ <date_format_timezone>Asia/Bangkok</date_format_timezone>
+ <lenient_string_to_number>N</lenient_string_to_number>
+ </value-meta>
+ </row-meta>
<attributes/>
<cluster_schema/>
<remotesteps>
@@ -2208,13 +2254,13 @@ order by pp.id</sql>
</output>
</remotesteps>
<GUI>
- <xloc>752</xloc>
- <yloc>368</yloc>
+ <xloc>80</xloc>
+ <yloc>144</yloc>
<draw>Y</draw>
</GUI>
</step>
<step>
- <name>Calculator</name>
+ <name>Calculator 2</name>
<type>Calculator</type>
<description/>
<distribute>Y</distribute>
@@ -2226,12 +2272,12 @@ order by pp.id</sql>
</partitioning>
<failIfNoFile>Y</failIfNoFile>
<calculation>
- <field_name>total_cost</field_name>
- <calc_type>MULTIPLY</calc_type>
+ <field_name>new_qty</field_name>
+ <calc_type>SUBTRACT</calc_type>
<field_a>qty</field_a>
- <field_b>last_cost</field_b>
+ <field_b>qty_outgoing</field_b>
<field_c/>
- <value_type>Number</value_type>
+ <value_type>None</value_type>
<value_length>-1</value_length>
<value_precision>-1</value_precision>
<remove>N</remove>
@@ -2249,95 +2295,7 @@ order by pp.id</sql>
</output>
</remotesteps>
<GUI>
- <xloc>608</xloc>
- <yloc>368</yloc>
- <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>list_new_deadstock</table>
- <key>
- <name>product_id</name>
- <field>product_id</field>
- <condition>=</condition>
- <name2/>
- </key>
- <value>
- <name>product_id</name>
- <rename>product_id</rename>
- <update>N</update>
- </value>
- <value>
- <name>item_code</name>
- <rename>item_code</rename>
- <update>Y</update>
- </value>
- <value>
- <name>product_name</name>
- <rename>product_name</rename>
- <update>Y</update>
- </value>
- <value>
- <name>brand</name>
- <rename>brand</rename>
- <update>Y</update>
- </value>
- <value>
- <name>qty</name>
- <rename>qty</rename>
- <update>Y</update>
- </value>
- <value>
- <name>date_added</name>
- <rename>date_added</rename>
- <update>Y</update>
- </value>
- <value>
- <name>last_in</name>
- <rename>last_in</rename>
- <update>Y</update>
- </value>
- <value>
- <name>aging</name>
- <rename>aging</rename>
- <update>Y</update>
- </value>
- <value>
- <name>last_cost</name>
- <rename>last_cost</rename>
- <update>Y</update>
- </value>
- <value>
- <name>total_cost</name>
- <rename>total_cost</rename>
- <update>Y</update>
- </value>
- </lookup>
- <attributes/>
- <cluster_schema/>
- <remotesteps>
- <input>
- </input>
- <output>
- </output>
- </remotesteps>
- <GUI>
- <xloc>288</xloc>
+ <xloc>736</xloc>
<yloc>368</yloc>
<draw>Y</draw>
</GUI>