kettle修改-王公峰-2022-01-24

esua-epdc/kettle-Code/dcp_job/epmet_gov_project/project_related_personnel.ktr

@@ -589,6 +589,16 @@
       <to>插入 / 更新</to>
       <enabled>Y</enabled>
     </hop>
+    <hop>
+      <from>获取市北项目相关人员 2</from>
+      <to>插入 / 更新 2</to>
+      <enabled>Y</enabled>
+    </hop>
+    <hop>
+      <from>获取项目人员关系最新更新时间</from>
+      <to>获取市北项目相关人员 2</to>
+      <enabled>Y</enabled>
+    </hop>
   </order>
   <step>
     <name>插入 / 更新</name>
@@ -616,7 +626,7 @@
       <value>
         <name>ID</name>
         <rename>ID</rename>
-        <update>N</update>
+        <update>Y</update>
       </value>
       <value>
         <name>PROJECT_ID</name>
@@ -728,7 +738,9 @@ item.UPDATED_TIME,
 (select dct.dict_value from esua_epdc_admin.sys_dict dct where dct.del_flag = 0 and dct.dict_type = 'dcp' and dct.pid != 0) CUSTOMER_ID
 from epdc_item item 
 left join epdc_issue isu on isu.ID = item.ISSUE_ID and isu.del_flag = 0
-where item.DEL_FLAG = '0'
+where item.DEL_FLAG = '0' 
+and item.TOPIC_ID is not null
+and item.TOPIC_ID != ''
 and item.UPDATED_TIME > ? 
 </sql>
     <outer_join>N</outer_join>
@@ -780,7 +792,7 @@ IFNULL( (SELECT  UPDATED_TIME FROM project_related_personnel  ORDER BY UPDATED_T
         <name>START_DATE</name>
         <length>19</length>
         <precision>-1</precision>
-        <origin>获取项目最新更新时间</origin>
+        <origin>获取项目人员关系最新更新时间</origin>
         <comments>START_DATE</comments>
         <conversion_Mask/>
         <decimal_symbol>.</decimal_symbol>
@@ -812,6 +824,171 @@ IFNULL( (SELECT  UPDATED_TIME FROM project_related_personnel  ORDER BY UPDATED_T
       <draw>Y</draw>
     </GUI>
   </step>
+  <step>
+    <name>插入 / 更新 2</name>
+    <type>InsertUpdate</type>
+    <description/>
+    <distribute>Y</distribute>
+    <custom_distribution/>
+    <copies>1</copies>
+    <partitioning>
+      <method>none</method>
+      <schema_name/>
+    </partitioning>
+    <connection>epmet_gov_project</connection>
+    <commit>100</commit>
+    <update_bypassed>N</update_bypassed>
+    <lookup>
+      <schema/>
+      <table>project_related_personnel</table>
+      <key>
+        <name>PROJECT_ID</name>
+        <field>PROJECT_ID</field>
+        <condition>=</condition>
+        <name2/>
+      </key>
+      <value>
+        <name>ID</name>
+        <rename>ID</rename>
+        <update>Y</update>
+      </value>
+      <value>
+        <name>PROJECT_ID</name>
+        <rename>PROJECT_ID</rename>
+        <update>Y</update>
+      </value>
+      <value>
+        <name>APP</name>
+        <rename>APP</rename>
+        <update>Y</update>
+      </value>
+      <value>
+        <name>GRID_ID</name>
+        <rename>GRID_ID</rename>
+        <update>Y</update>
+      </value>
+      <value>
+        <name>SOURCE_TYPE</name>
+        <rename>SOURCE_TYPE</rename>
+        <update>Y</update>
+      </value>
+      <value>
+        <name>SOURCE_ID</name>
+        <rename>SOURCE_ID</rename>
+        <update>Y</update>
+      </value>
+      <value>
+        <name>USER_ID</name>
+        <rename>USER_ID</rename>
+        <update>Y</update>
+      </value>
+      <value>
+        <name>DEL_FLAG</name>
+        <rename>DEL_FLAG</rename>
+        <update>Y</update>
+      </value>
+      <value>
+        <name>REVISION</name>
+        <rename>REVISION</rename>
+        <update>Y</update>
+      </value>
+      <value>
+        <name>CREATED_BY</name>
+        <rename>CREATED_BY</rename>
+        <update>Y</update>
+      </value>
+      <value>
+        <name>CREATED_TIME</name>
+        <rename>CREATED_TIME</rename>
+        <update>Y</update>
+      </value>
+      <value>
+        <name>UPDATED_BY</name>
+        <rename>UPDATED_BY</rename>
+        <update>Y</update>
+      </value>
+      <value>
+        <name>UPDATED_TIME</name>
+        <rename>UPDATED_TIME</rename>
+        <update>Y</update>
+      </value>
+      <value>
+        <name>CUSTOMER_ID</name>
+        <rename>CUSTOMER_ID</rename>
+        <update>Y</update>
+      </value>
+    </lookup>
+    <attributes/>
+    <cluster_schema/>
+    <remotesteps>
+      <input>
+      </input>
+      <output>
+      </output>
+    </remotesteps>
+    <GUI>
+      <xloc>832</xloc>
+      <yloc>336</yloc>
+      <draw>Y</draw>
+    </GUI>
+  </step>
+  <step>
+    <name>获取市北项目相关人员 2</name>
+    <type>DBJoin</type>
+    <description/>
+    <distribute>Y</distribute>
+    <custom_distribution/>
+    <copies>1</copies>
+    <partitioning>
+      <method>none</method>
+      <schema_name/>
+    </partitioning>
+    <connection>esua_epdc_events</connection>
+    <rowlimit>0</rowlimit>
+    <sql>select
+MD5(UUID()) ID,
+item.ID PROJECT_ID,
+'resi' APP,
+item.GRID_ID ,
+'issue' SOURCE_TYPE,
+IFNULL(item.TOPIC_ID,'') SOURCE_ID,
+IFNULL(isu.USER_ID,'') USER_ID,
+item.DEL_FLAG,
+item.REVISION,
+item.CREATED_BY,
+item.CREATED_TIME,
+item.UPDATED_BY,
+item.UPDATED_TIME,
+(select dct.dict_value from esua_epdc_admin.sys_dict dct where dct.del_flag = 0 and dct.dict_type = 'dcp' and dct.pid != 0) CUSTOMER_ID
+from epdc_item item 
+left join epdc_issue isu on isu.ID = item.ISSUE_ID and isu.del_flag = 0
+where item.DEL_FLAG = '0' 
+and item.TOPIC_ID is not null
+and item.TOPIC_ID != ''
+and item.UPDATED_TIME > ? 
+</sql>
+    <outer_join>N</outer_join>
+    <replace_vars>N</replace_vars>
+    <parameter>
+      <field>
+        <name>START_DATE</name>
+        <type>Date</type>
+      </field>
+    </parameter>
+    <attributes/>
+    <cluster_schema/>
+    <remotesteps>
+      <input>
+      </input>
+      <output>
+      </output>
+    </remotesteps>
+    <GUI>
+      <xloc>592</xloc>
+      <yloc>336</yloc>
+      <draw>Y</draw>
+    </GUI>
+  </step>
   <step_error_handling>
   </step_error_handling>
   <slave-step-copy-partition-distribution>