zsy

monitor_intelligent/union_yuejuan_monitor/transfer/core.kjb

@@ -7,7 +7,7 @@
   <created_user>admin</created_user>
   <created_date>2021/03/03 10:49:37.387</created_date>
   <modified_user>admin</modified_user>
-  <modified_date>2021/03/12 14:35:42.282</modified_date>
+  <modified_date>2021/03/12 15:15:35.290</modified_date>
   <parameters>
     </parameters>
   <connection>
@@ -1074,7 +1074,7 @@ a.question_config_id,
 a.question_block_id,
 a.create_time,
 a.record_id,
-(case when to_date(${start_time},'yyyy-mm-dd')='2000-01-01' then 1 else 0 end) as is_execute
+(case when ${start_time}='2000-01-01' then 1 else 0 end) as is_execute
 from union_yuejuan_source.bus_exam_question_del_log a
 left join union_yuejuan_source_process.bus_exam_question_del_log b on a.id=b.id
 where b.id is null;</sql>

monitor_intelligent/union_yuejuan_monitor/transfer/total_control/gp_time/set_variable_start_time.ktr

@@ -428,7 +428,7 @@
     <created_user>admin</created_user>
     <created_date>2021/03/03 10:49:15.361</created_date>
     <modified_user>admin</modified_user>
-    <modified_date>2020/12/16 14:19:38.438</modified_date>
+    <modified_date>2021/03/12 15:14:09.696</modified_date>
     <key_for_session_key>H4sIAAAAAAAAAAMAAAAAAAAAAAA=</key_for_session_key>
     <is_key_private>N</is_key_private>
   </info>
@@ -488,11 +488,54 @@
   <order>
     <hop>
       <from>Table input</from>
+      <to>字段选择</to>
+      <enabled>Y</enabled>
+    </hop>
+    <hop>
+      <from>字段选择</from>
       <to>Set Variables</to>
       <enabled>Y</enabled>
     </hop>
   </order>
   <step>
+    <name>Table input</name>
+    <type>TableInput</type>
+    <description/>
+    <distribute>Y</distribute>
+    <custom_distribution/>
+    <copies>1</copies>
+    <partitioning>
+      <method>none</method>
+      <schema_name/>
+    </partitioning>
+    <connection>intelligent_monitor_greenplum_neiwang</connection>
+    <sql>select 
+(case when (select count(id) from union_yuejuan_source_process.gp_time_interval where status=1)>0
+then (select max(end_time)-interval '4 s' from union_yuejuan_source_process.gp_time_interval where status=1)
+else '2000-01-01 00:00:00' end) as start_time,
+(case when (select count(id) from union_yuejuan_source_process.gp_time_interval where status=1)>0
+then (select max(end_time)-interval '4 s' from union_yuejuan_source_process.gp_time_interval where status=1)
+else '2000-01-01 00:00:00' end) as start_time_date</sql>
+    <limit>0</limit>
+    <lookup/>
+    <execute_each_row>N</execute_each_row>
+    <variables_active>N</variables_active>
+    <lazy_conversion_active>N</lazy_conversion_active>
+    <attributes/>
+    <cluster_schema/>
+    <remotesteps>
+      <input>
+      </input>
+      <output>
+      </output>
+    </remotesteps>
+    <GUI>
+      <xloc>176</xloc>
+      <yloc>160</yloc>
+      <draw>Y</draw>
+    </GUI>
+  </step>
+  <step>
     <name>Set Variables</name>
     <type>SetVariable</type>
     <description/>
@@ -510,6 +553,12 @@
         <variable_type>ROOT_JOB</variable_type>
         <default_value/>
       </field>
+      <field>
+        <field_name>start_time_date</field_name>
+        <variable_name>start_time_date</variable_name>
+        <variable_type>ROOT_JOB</variable_type>
+        <default_value/>
+      </field>
     </fields>
     <use_formatting>Y</use_formatting>
     <attributes/>
@@ -521,14 +570,14 @@
       </output>
     </remotesteps>
     <GUI>
-      <xloc>336</xloc>
+      <xloc>480</xloc>
       <yloc>160</yloc>
       <draw>Y</draw>
     </GUI>
   </step>
   <step>
-    <name>Table input</name>
-    <type>TableInput</type>
+    <name>字段选择</name>
+    <type>SelectValues</type>
     <description/>
     <distribute>Y</distribute>
     <custom_distribution/>
@@ -537,16 +586,51 @@
       <method>none</method>
       <schema_name/>
     </partitioning>
-    <connection>intelligent_monitor_greenplum_neiwang</connection>
-    <sql>select 
-(case when (select count(id) from union_yuejuan_source_process.gp_time_interval where status=1)>0
-then (select max(end_time)-interval '4 s' from union_yuejuan_source_process.gp_time_interval where status=1)
-else '2000-01-01 00:00:00' end) as start_time</sql>
-    <limit>0</limit>
-    <lookup/>
-    <execute_each_row>N</execute_each_row>
-    <variables_active>N</variables_active>
-    <lazy_conversion_active>N</lazy_conversion_active>
+    <fields>
+      <field>
+        <name>start_time</name>
+        <rename/>
+      </field>
+      <field>
+        <name>start_time_date</name>
+        <rename/>
+      </field>
+      <select_unspecified>N</select_unspecified>
+      <meta>
+        <name>start_time</name>
+        <rename>start_time</rename>
+        <type>Timestamp</type>
+        <length>6</length>
+        <precision>-2</precision>
+        <conversion_mask/>
+        <date_format_lenient>false</date_format_lenient>
+        <date_format_locale/>
+        <date_format_timezone/>
+        <lenient_string_to_number>false</lenient_string_to_number>
+        <encoding/>
+        <decimal_symbol/>
+        <grouping_symbol/>
+        <currency_symbol/>
+        <storage_type/>
+      </meta>
+      <meta>
+        <name>start_time_date</name>
+        <rename>start_time_date</rename>
+        <type>Date</type>
+        <length>6</length>
+        <precision>-2</precision>
+        <conversion_mask/>
+        <date_format_lenient>false</date_format_lenient>
+        <date_format_locale/>
+        <date_format_timezone/>
+        <lenient_string_to_number>false</lenient_string_to_number>
+        <encoding/>
+        <decimal_symbol/>
+        <grouping_symbol/>
+        <currency_symbol/>
+        <storage_type/>
+      </meta>
+    </fields>
     <attributes/>
     <cluster_schema/>
     <remotesteps>
@@ -556,7 +640,7 @@ else '2000-01-01 00:00:00' end) as start_time</sql>
       </output>
     </remotesteps>
     <GUI>
-      <xloc>176</xloc>
+      <xloc>304</xloc>
       <yloc>160</yloc>
       <draw>Y</draw>
     </GUI>