From 4fb8255da2dcf6e3062a1e8f19319f42579a0c44 Mon Sep 17 00:00:00 2001
From: wanggongfeng <1305282856@qq.com>
Date: Mon, 24 Jan 2022 09:55:11 +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-24?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
.../project_related_personnel.ktr | 183 +++++++++++++++++-
1 file changed, 180 insertions(+), 3 deletions(-)
diff --git a/esua-epdc/kettle-Code/dcp_job/epmet_gov_project/project_related_personnel.ktr b/esua-epdc/kettle-Code/dcp_job/epmet_gov_project/project_related_personnel.ktr
index 131bf4012..30f5b47f1 100644
--- a/esua-epdc/kettle-Code/dcp_job/epmet_gov_project/project_related_personnel.ktr
+++ b/esua-epdc/kettle-Code/dcp_job/epmet_gov_project/project_related_personnel.ktr
@@ -589,6 +589,16 @@
插入 / 更新
Y
+
+ 获取市北项目相关人员 2
+ 插入 / 更新 2
+ Y
+
+
+ 获取项目人员关系最新更新时间
+ 获取市北项目相关人员 2
+ Y
+
插入 / 更新
@@ -616,7 +626,7 @@
ID
ID
- N
+ Y
PROJECT_ID
@@ -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 > ?
N
@@ -780,7 +792,7 @@ IFNULL( (SELECT UPDATED_TIME FROM project_related_personnel ORDER BY UPDATED_T
START_DATE
19
-1
- 获取项目最新更新时间
+ 获取项目人员关系最新更新时间
START_DATE
.
@@ -812,6 +824,171 @@ IFNULL( (SELECT UPDATED_TIME FROM project_related_personnel ORDER BY UPDATED_T
Y
+
+ 插入 / 更新 2
+ InsertUpdate
+
+ Y
+
+ 1
+
+ none
+
+
+ epmet_gov_project
+ 100
+ N
+
+
+ project_related_personnel
+
+ PROJECT_ID
+ PROJECT_ID
+ =
+
+
+
+ ID
+ ID
+ Y
+
+
+ PROJECT_ID
+ PROJECT_ID
+ Y
+
+
+ APP
+ APP
+ Y
+
+
+ GRID_ID
+ GRID_ID
+ Y
+
+
+ SOURCE_TYPE
+ SOURCE_TYPE
+ Y
+
+
+ SOURCE_ID
+ SOURCE_ID
+ Y
+
+
+ USER_ID
+ USER_ID
+ 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
+
+
+ CUSTOMER_ID
+ CUSTOMER_ID
+ Y
+
+
+
+
+
+
+
+
+
+
+ 832
+ 336
+ Y
+
+
+
+ 获取市北项目相关人员 2
+ DBJoin
+
+ Y
+
+ 1
+
+ none
+
+
+ esua_epdc_events
+ 0
+ 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 > ?
+
+ N
+ N
+
+
+ START_DATE
+ Date
+
+
+
+
+
+
+
+
+
+
+ 592
+ 336
+ Y
+
+