update_cogs_fixco.ktr

1 files changed, 96 insertions, 10 deletions

diff --git a/update_cogs_fixco.ktr b/update_cogs_fixco.ktr
index f26d5e0..9be8f7e 100644
--- a/update_cogs_fixco.ktr
+++ b/update_cogs_fixco.ktr
@@ -436,12 +436,12 @@
   <notepads>
   </notepads>
   <connection>
-    <name>dw bi fixco</name>
+    <name>dw bi fixco (localhost)</name>
     <server>localhost</server>
     <type>POSTGRESQL</type>
     <access>Native</access>
     <database>dw_bi_fixco</database>
-    <port>5703</port>
+    <port>5432</port>
     <username>pdi</username>
     <password>Encrypted 2be989bb20084ca95810197629d9ea18e</password>
     <servername/>
@@ -462,7 +462,7 @@
       </attribute>
       <attribute>
         <code>PORT_NUMBER</code>
-        <attribute>5703</attribute>
+        <attribute>5432</attribute>
       </attribute>
       <attribute>
         <code>PRESERVE_RESERVED_WORD_CASE</code>
@@ -503,13 +503,23 @@
       <enabled>Y</enabled>
     </hop>
     <hop>
+      <from>Select values</from>
+      <to>Update</to>
+      <enabled>Y</enabled>
+    </hop>
+    <hop>
       <from>Calculator</from>
+      <to>Filter rows</to>
+      <enabled>Y</enabled>
+    </hop>
+    <hop>
+      <from>Filter rows</from>
       <to>Select values</to>
       <enabled>Y</enabled>
     </hop>
     <hop>
-      <from>Select values</from>
-      <to>Update</to>
+      <from>Filter rows</from>
+      <to>Write to log</to>
       <enabled>Y</enabled>
     </hop>
   </order>
@@ -583,7 +593,7 @@
       </output>
     </remotesteps>
     <GUI>
-      <xloc>528</xloc>
+      <xloc>656</xloc>
       <yloc>64</yloc>
       <draw>Y</draw>
     </GUI>
@@ -641,7 +651,7 @@
       <method>none</method>
       <schema_name/>
     </partitioning>
-    <connection>dw bi fixco</connection>
+    <connection>dw bi fixco (localhost)</connection>
     <skip_lookup>N</skip_lookup>
     <commit>100</commit>
     <use_batch>N</use_batch>
@@ -670,7 +680,7 @@
       </output>
     </remotesteps>
     <GUI>
-      <xloc>672</xloc>
+      <xloc>816</xloc>
       <yloc>64</yloc>
       <draw>Y</draw>
     </GUI>
@@ -686,7 +696,7 @@
       <method>none</method>
       <schema_name/>
     </partitioning>
-    <connection>dw bi fixco</connection>
+    <connection>dw bi fixco (localhost)</connection>
     <sql>select item_code, cost_with_tax, cost, tax 
 from product_cost where year = 2025</sql>
     <limit>0</limit>
@@ -814,7 +824,7 @@ from product_cost where year = 2025</sql>
       <method>none</method>
       <schema_name/>
     </partitioning>
-    <connection>dw bi fixco</connection>
+    <connection>dw bi fixco (localhost)</connection>
     <sql>select id, item_code, qty, harga, total_harga, ppn, dpp 
 from total_omzet_by_product 
 where 1=1
@@ -1003,6 +1013,82 @@ and cogs &lt;= 0</sql>
       <draw>Y</draw>
     </GUI>
   </step>
+  <step>
+    <name>Filter rows</name>
+    <type>FilterRows</type>
+    <description/>
+    <distribute>Y</distribute>
+    <custom_distribution/>
+    <copies>1</copies>
+    <partitioning>
+      <method>none</method>
+      <schema_name/>
+    </partitioning>
+    <send_true_to>Select values</send_true_to>
+    <send_false_to>Write to log</send_false_to>
+    <compare>
+      <condition>
+        <negated>N</negated>
+        <leftvalue>total_cogs</leftvalue>
+        <function>&gt;</function>
+        <rightvalue/>
+        <value>
+          <name>constant</name>
+          <type>BigNumber</type>
+          <text>0.0</text>
+          <length>-1</length>
+          <precision>-1</precision>
+          <isnull>N</isnull>
+          <mask>######0.0###################;-######0.0###################</mask>
+        </value>
+      </condition>
+    </compare>
+    <attributes/>
+    <cluster_schema/>
+    <remotesteps>
+      <input>
+      </input>
+      <output>
+      </output>
+    </remotesteps>
+    <GUI>
+      <xloc>512</xloc>
+      <yloc>64</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>512</xloc>
+      <yloc>160</yloc>
+      <draw>Y</draw>
+    </GUI>
+  </step>
   <step_error_handling>
   </step_error_handling>
   <slave-step-copy-partition-distribution>