数字社区-可视化平台数据同步kettle

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

@@ -775,7 +775,7 @@ evt.ID,
 (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,
 evt.GRID_ID ,
 SUBSTRING_INDEX(evt.PARENT_DEPT_IDS,',',-1) AGENCY_ID,
-evt.PARENT_DEPT_IDS PIDS,
+REPLACE(evt.PARENT_DEPT_IDS,',',':') PIDS,
 evt.USER_ID REPORT_USER_ID,
 evt.IS_PARTY_MEMBER IS_PARTY,
 evt.EVENT_CONTENT EVENT_CONTENT,

esua-epdc/kettle-Code/dcp_job/group_point/epdc_gr_grid_month_new.ktr

@@ -723,7 +723,7 @@
 			 CREATED_TIME,
 			 UPDATED_BY,
 			 UPDATED_TIME,
-			 SUBSTRING_INDEX(ALL_DEPT_IDS,',',3) as ALL_PARENT_IDS
+			 SUBSTRING_INDEX( REPLACE(ALL_DEPT_IDS,',',':'), ':', 3 ) as ALL_PARENT_IDS
 from esua_epdc_analysis.epdc_gr_grid_month_new
 where UPDATED_TIME>?</sql>
     <outer_join>N</outer_join>

esua-epdc/kettle-Code/dcp_job/user/volunteer_info.ktr

@@ -748,6 +748,11 @@
         <rename>PIDS</rename>
         <update>Y</update>
       </value>
+      <value>
+        <name>PID</name>
+        <rename>PID</rename>
+        <update>Y</update>
+      </value>
     </lookup>
     <attributes/>
     <cluster_schema/>
@@ -798,7 +803,8 @@
 	info.UPDATED_TIME,
 	info.GRID_ID GRID_ID,
 	SUBSTRING_INDEX(info.ALL_DEPT_NAMES, '-' ,- 1) GRID_NAME,
-	info.ALL_DEPT_IDS PIDS
+	SUBSTRING_INDEX(info.PARENT_DEPT_IDS, ',' ,- 1) PID,
+ 	REPLACE(info.PARENT_DEPT_IDS,',',':') PIDS
 FROM
 	epdc_volunteer_info info
 WHERE