From b170eafc797dd558c704d6b0be18445b0ac4ebec Mon Sep 17 00:00:00 2001 From: wanggongfeng <1305282856@qq.com> Date: Thu, 20 Jan 2022 18:01:40 +0800 Subject: [PATCH] =?UTF-8?q?kettle=E4=BF=AE=E6=94=B9-=E7=8E=8B=E5=85=AC?= =?UTF-8?q?=E5=B3=B0-2022-01-20?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../epmet_gov_project/project_staff.ktr | 699 +++++++++++++----- 1 file changed, 517 insertions(+), 182 deletions(-) diff --git a/esua-epdc/kettle-Code/dcp_job/epmet_gov_project/project_staff.ktr b/esua-epdc/kettle-Code/dcp_job/epmet_gov_project/project_staff.ktr index 0e72e5be7..ecec56329 100644 --- a/esua-epdc/kettle-Code/dcp_job/epmet_gov_project/project_staff.ktr +++ b/esua-epdc/kettle-Code/dcp_job/epmet_gov_project/project_staff.ktr @@ -580,142 +580,14 @@ - 获取项目节点相关人员最新更新时间 - 获取市北项目节点相关人员 - Y - - - 获取市北项目节点相关人员 - 插入 / 更新 + 获取项目节点相关人员信息 + 表输出 Y - 插入 / 更新 - InsertUpdate - - Y - - 1 - - none - - - epmet_gov_project - 100 - N - - - project_staff
- - PROCESS_ID - PROCESS_ID - = - - - - ID - ID - N - - - PROJECT_ID - PROJECT_ID - Y - - - PROCESS_ID - PROCESS_ID - Y - - - CUSTOMER_ID - CUSTOMER_ID - Y - - - ORG_ID - ORG_ID - Y - - - DEPARTMENT_ID - DEPARTMENT_ID - Y - - - GRID_ID - GRID_ID - Y - - - ORG_ID_PATH - ORG_ID_PATH - Y - - - STAFF_ID - STAFF_ID - Y - - - DEPARTMENT_NAME - DEPARTMENT_NAME - Y - - - IS_HANDLE - IS_HANDLE - Y - - - DEL_FLAG - DEL_FLAG - Y - - - REVISION - REVISION - Y - - - CREATED_BY - CREATED_BY - Y - - - CREATED_TIME - CREATED_TIME - Y - - - UPDATED_BY - UPDATED_BY - Y - - - UPDATED_TIME - UPDATED_TIME - Y - - - - - - - - - - - - 832 - 176 - Y - - - - 获取市北项目节点相关人员 - DBJoin + 获取项目节点相关人员信息 + TableInput Y @@ -725,66 +597,49 @@ esua_epdc_events - 0 - select + SELECT MD5(UUID()) ID, ip.ITEM_ID PROJECT_ID, ip.ID PROCESS_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, -IF(dept.type_key like '%_party' and dept.type_key != 'grid_party' ,ip.HANDLER_DEPT_ID,'') as ORG_ID, -IF(dept.type_key like '%_dept' ,ip.HANDLER_DEPT_ID,'') as DEPARTMENT_ID, -IF(dept.type_key = 'grid_party' ,ip.HANDLER_DEPT_ID,'') as GRID_ID, -concat(REPLACE(dept.pids,',',':'),':',ip.HANDLER_DEPT_ID) as ORG_ID_PATH, +IF(dept.type_key like '%_party' and dept.type_key != 'grid_party' ,pro.HANDLER_DEPT_ID,'') as ORG_ID, +IF(dept.type_key like '%_dept' ,pro.HANDLER_DEPT_ID,'') as DEPARTMENT_ID, +IF(dept.type_key = 'grid_party' ,pro.HANDLER_DEPT_ID,'') as GRID_ID, +concat(REPLACE(dept.pids,',',':'),':',pro.HANDLER_DEPT_ID) as ORG_ID_PATH, ip.CREATED_BY STAFF_ID, ip.HANDLER_DEPT DEPARTMENT_NAME, -'handle' IS_HANDLE, +'unhandled' IS_HANDLE, ip.DEL_FLAG, ip.REVISION, ip.CREATED_BY, ip.CREATED_TIME, ip.UPDATED_BY, ip.UPDATED_TIME -from epdc_item_handle_process ip -left join esua_epdc_admin.sys_dept dept on dept.ID = ip.HANDLER_DEPT_ID and dept.del_flag = 0 -where ip.DEL_FLAG = 0 -and ip.UPDATED_TIME > ? +from ( + select + t.processId, + (case when t.DEPT_ID is null then t.HANDLER_DEPT_ID else t.DEPT_ID end) as HANDLER_DEPT_ID + from ( + SELECT + it.ID, + ip.ITEM_ID, + ip.CREATED_TIME, + ip.ID processId, + ip.HANDLER_DEPT_ID, + (select max(CREATED_TIME) from epdc_item_handle_process where DEL_FLAG = 0 and STATE = 0 and ITEM_ID = ip.ITEM_ID ) maxTime, + id.DEPT_ID + from epdc_item it + left join epdc_item_handle_process ip on ip.ITEM_ID = it.ID and ip.DEL_FLAG = 0 + left join epdc_item_dept id on id.ITEM_HANDLE_ID = ip.id and id.DEL_FLAG = 0 + where it.DEL_FLAG = 0 + and it.ITEM_STATE = 0 + and ip.STATE = 0 + group by ip.CREATED_TIME + ) t where t.CREATED_TIME = t.maxTime +) pro +left join epdc_item_handle_process ip on ip.ID = pro.processId and ip.DEL_FLAG = 0 +left join esua_epdc_admin.sys_dept dept on dept.ID = pro.HANDLER_DEPT_ID and dept.del_flag = 0 - N - N - - - START_DATE - Date - - - - - - - - - - - - 592 - 176 - Y - - - - 获取项目节点相关人员最新更新时间 - TableInput - - Y - - 1 - - none - - - epmet_gov_project - select -IFNULL( (SELECT UPDATED_TIME FROM project_staff ORDER BY UPDATED_TIME DESC LIMIT 1),'2000-01-01 00:00:00') START_DATE 0 N @@ -795,11 +650,379 @@ IFNULL( (SELECT UPDATED_TIME FROM project_staff ORDER BY UPDATED_TIME DESC LI String normal - START_DATE - 19 + ID + 32 + -1 + 获取项目节点相关人员最新更新时间 + ID + + . + , + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + String + normal + PROJECT_ID + 32 + -1 + 获取项目节点相关人员最新更新时间 + PROJECT_ID + + . + , + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + String + normal + PROCESS_ID + 32 + -1 + 获取项目节点相关人员最新更新时间 + PROCESS_ID + + . + , + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + String + normal + CUSTOMER_ID + 255 + -1 + 获取项目节点相关人员最新更新时间 + CUSTOMER_ID + + . + , + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + String + normal + ORG_ID + 20 + -1 + 获取项目节点相关人员最新更新时间 + ORG_ID + + . + , + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + String + normal + DEPARTMENT_ID + 20 + -1 + 获取项目节点相关人员最新更新时间 + DEPARTMENT_ID + + . + , + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + String + normal + GRID_ID + 20 + -1 + 获取项目节点相关人员最新更新时间 + GRID_ID + + . + , + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + String + normal + ORG_ID_PATH + 521 + -1 + 获取项目节点相关人员最新更新时间 + ORG_ID_PATH + + . + , + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + String + normal + STAFF_ID + 32 + -1 + 获取项目节点相关人员最新更新时间 + STAFF_ID + + . + , + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + String + normal + DEPARTMENT_NAME + 255 + -1 + 获取项目节点相关人员最新更新时间 + DEPARTMENT_NAME + + . + , + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + String + normal + IS_HANDLE + 9 + -1 + 获取项目节点相关人员最新更新时间 + IS_HANDLE + + . + , + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + String + normal + DEL_FLAG + 1 + -1 + 获取项目节点相关人员最新更新时间 + DEL_FLAG + + . + , + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + Integer + normal + REVISION + 9 + 0 + 获取项目节点相关人员最新更新时间 + REVISION + ####0;-####0 + . + , + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + String + normal + CREATED_BY + 32 + -1 + 获取项目节点相关人员最新更新时间 + CREATED_BY + + . + , + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + Timestamp + normal + CREATED_TIME + 0 + -1 + 获取项目节点相关人员最新更新时间 + CREATED_TIME + + . + , + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + String + normal + UPDATED_BY + 32 + -1 + 获取项目节点相关人员最新更新时间 + UPDATED_BY + + . + , + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + Timestamp + normal + UPDATED_TIME + 0 -1 获取项目节点相关人员最新更新时间 - START_DATE + UPDATED_TIME . , @@ -830,6 +1053,118 @@ IFNULL( (SELECT UPDATED_TIME FROM project_staff ORDER BY UPDATED_TIME DESC LI Y + + 表输出 + TableOutput + + Y + + 1 + + none + + + epmet_gov_project + + project_staff
+ 1000 + Y + N + Y + Y + N + + N + Y + N + + Y + N + + + + ID + ID + + + PROJECT_ID + PROJECT_ID + + + PROCESS_ID + PROCESS_ID + + + CUSTOMER_ID + CUSTOMER_ID + + + ORG_ID + ORG_ID + + + DEPARTMENT_ID + DEPARTMENT_ID + + + GRID_ID + GRID_ID + + + ORG_ID_PATH + ORG_ID_PATH + + + STAFF_ID + STAFF_ID + + + DEPARTMENT_NAME + DEPARTMENT_NAME + + + IS_HANDLE + IS_HANDLE + + + DEL_FLAG + DEL_FLAG + + + REVISION + REVISION + + + CREATED_BY + CREATED_BY + + + CREATED_TIME + CREATED_TIME + + + UPDATED_BY + UPDATED_BY + + + UPDATED_TIME + UPDATED_TIME + + + + + + + + + + + + 576 + 176 + Y + +