diff --git a/esua-epdc/kettle-Code/dcp_job/group_point/group_points.kjb b/esua-epdc/kettle-Code/dcp_job/group_point/group_points.kjb index e0203da09..038254813 100644 --- a/esua-epdc/kettle-Code/dcp_job/group_point/group_points.kjb +++ b/esua-epdc/kettle-Code/dcp_job/group_point/group_points.kjb @@ -304,8 +304,8 @@ N Y 0 - 192 - 560 + 160 + 608 @@ -574,6 +574,44 @@ 896 + + user_point_total + + TRANS + + filename + + ${Internal.Entry.Current.Directory}/user_point_total.ktr + + N + N + N + N + N + N + + + N + N + Basic + N + + N + Y + N + N + N + Pentaho local + + Y + + N + Y + 0 + 656 + 1008 + + @@ -639,6 +677,15 @@ Y Y + + Start + user_point_total + 0 + 0 + Y + Y + Y + diff --git a/esua-epdc/kettle-Code/dcp_job/group_point/user_point_total.ktr b/esua-epdc/kettle-Code/dcp_job/group_point/user_point_total.ktr new file mode 100644 index 000000000..387e97f5f --- /dev/null +++ b/esua-epdc/kettle-Code/dcp_job/group_point/user_point_total.ktr @@ -0,0 +1,792 @@ + + + + user_point_total + + + + Normal + 0 + / + + + + + + + + + + + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + TRANSNAME + Y + TRANSNAME + + + STATUS + Y + STATUS + + + LINES_READ + Y + LINES_READ + + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + + LINES_UPDATED + Y + LINES_UPDATED + + + + LINES_INPUT + Y + LINES_INPUT + + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + + LINES_REJECTED + Y + LINES_REJECTED + + + + ERRORS + Y + ERRORS + + + STARTDATE + Y + STARTDATE + + + ENDDATE + Y + ENDDATE + + + LOGDATE + Y + LOGDATE + + + DEPDATE + Y + DEPDATE + + + REPLAYDATE + Y + REPLAYDATE + + + LOG_FIELD + Y + LOG_FIELD + + + EXECUTING_SERVER + N + EXECUTING_SERVER + + + EXECUTING_USER + N + EXECUTING_USER + + + CLIENT + N + CLIENT + + + + + +
+ + + + ID_BATCH + Y + ID_BATCH + + + SEQ_NR + Y + SEQ_NR + + + LOGDATE + Y + LOGDATE + + + TRANSNAME + Y + TRANSNAME + + + STEPNAME + Y + STEPNAME + + + STEP_COPY + Y + STEP_COPY + + + LINES_READ + Y + LINES_READ + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + LINES_UPDATED + Y + LINES_UPDATED + + + LINES_INPUT + Y + LINES_INPUT + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + LINES_REJECTED + Y + LINES_REJECTED + + + ERRORS + Y + ERRORS + + + INPUT_BUFFER_ROWS + Y + INPUT_BUFFER_ROWS + + + OUTPUT_BUFFER_ROWS + Y + OUTPUT_BUFFER_ROWS + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + LOGGING_OBJECT_TYPE + Y + LOGGING_OBJECT_TYPE + + + OBJECT_NAME + Y + OBJECT_NAME + + + OBJECT_COPY + Y + OBJECT_COPY + + + REPOSITORY_DIRECTORY + Y + REPOSITORY_DIRECTORY + + + FILENAME + Y + FILENAME + + + OBJECT_ID + Y + OBJECT_ID + + + OBJECT_REVISION + Y + OBJECT_REVISION + + + PARENT_CHANNEL_ID + Y + PARENT_CHANNEL_ID + + + ROOT_CHANNEL_ID + Y + ROOT_CHANNEL_ID + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + TRANSNAME + Y + TRANSNAME + + + STEPNAME + Y + STEPNAME + + + STEP_COPY + Y + STEP_COPY + + + LINES_READ + Y + LINES_READ + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + LINES_UPDATED + Y + LINES_UPDATED + + + LINES_INPUT + Y + LINES_INPUT + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + LINES_REJECTED + Y + LINES_REJECTED + + + ERRORS + Y + ERRORS + + + LOG_FIELD + N + LOG_FIELD + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + METRICS_DATE + Y + METRICS_DATE + + + METRICS_CODE + Y + METRICS_CODE + + + METRICS_DESCRIPTION + Y + METRICS_DESCRIPTION + + + METRICS_SUBJECT + Y + METRICS_SUBJECT + + + METRICS_TYPE + Y + METRICS_TYPE + + + METRICS_VALUE + Y + METRICS_VALUE + + + + + +
+ + 0.0 + 0.0 + + 10000 + 50 + 50 + N + Y + 50000 + Y + + N + 1000 + 100 + + + + + + + + + - + 2021/12/22 17:26:29.140 + - + 2021/12/22 17:26:29.140 + H4sIAAAAAAAAAAMAAAAAAAAAAAA= + N + + + + + epdc_source_user + ${db.mysql.epdc.source.host} + MYSQL + Native + ${esua.epdc.user.database} + ${db.mysql.epdc.source.port} + ${db.mysql.epdc.source.username} + ${db.mysql.epdc.source.password} + + + + + + FORCE_IDENTIFIERS_TO_LOWERCASE + N + + + FORCE_IDENTIFIERS_TO_UPPERCASE + N + + + IS_CLUSTERED + N + + + PORT_NUMBER + ${db.mysql.epdc.source.port} + + + PRESERVE_RESERVED_WORD_CASE + Y + + + QUOTE_ALL_FIELDS + N + + + STREAM_RESULTS + Y + + + SUPPORTS_BOOLEAN_DATA_TYPE + Y + + + SUPPORTS_TIMESTAMP_DATA_TYPE + Y + + + USE_POOLING + N + + + + + epdc_target_epemt_point + ${db.mysql.epdc.target.host} + MYSQL + Native + ${epmet.points.database} + ${db.mysql.epdc.target.port} + ${db.mysql.epdc.target.username} + ${db.mysql.epdc.target.password} + + + + + + EXTRA_OPTION_MYSQL.allowMultiQueries + true + + + EXTRA_OPTION_MYSQL.characterEncoding + UTF-8 + + + EXTRA_OPTION_MYSQL.useSSL + false + + + EXTRA_OPTION_MYSQL.useUnicode + true + + + FORCE_IDENTIFIERS_TO_LOWERCASE + N + + + FORCE_IDENTIFIERS_TO_UPPERCASE + N + + + IS_CLUSTERED + N + + + PORT_NUMBER + ${db.mysql.epdc.target.port} + + + PRESERVE_RESERVED_WORD_CASE + Y + + + QUOTE_ALL_FIELDS + N + + + STREAM_RESULTS + Y + + + SUPPORTS_BOOLEAN_DATA_TYPE + Y + + + SUPPORTS_TIMESTAMP_DATA_TYPE + Y + + + USE_POOLING + N + + + + + + 表输入 + 数据库连接 + Y + + + 数据库连接 + 插入 / 更新 + Y + + + + 插入 / 更新 + InsertUpdate + + Y + + 1 + + none + + + epdc_target_epemt_point + 100 + N + + +
user_point_total
+ + USER_ID + USER_ID + = + + + + ID + ID + N + + + USER_ID + USER_ID + N + + + CUSTOMER_ID + CUSTOMER_ID + Y + + + USED_POINT + USED_POINT + Y + + + USABLE_POINT + USABLE_POINT + Y + + + TOTAL_POINT + TOTAL_POINT + 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 + 288 + Y + + + + 数据库连接 + DBJoin + + Y + + 1 + + none + + + epdc_source_user + 0 + select MD5(UUID()) as ID, + id as USER_ID, + (select dict_value from esua_epdc_admin.sys_dict + where dict_type='dcp' and dict_name='客户ID') as CUSTOMER_ID, + 0 as USED_POINT, + POINTS as USABLE_POINT, + POINTS as TOTAL_POINT, + DEL_FLAG, + REVISION, + CREATED_BY, + CREATED_TIME, + UPDATED_BY, + UPDATED_TIME +from esua_epdc_user.epdc_user +where state !='0' + and DEL_FLAG='0' + and UPDATED_TIME>? + N + N + + + START_TIME + Date + + + + + + + + + + + + 592 + 288 + Y + + + + 表输入 + TableInput + + Y + + 1 + + none + + + epdc_target_epemt_point + SELECT + IFNULL((SELECT UPDATED_TIME FROM user_point_total ORDER BY UPDATED_TIME DESC LIMIT 1),'2000-01-01 00:00:00') AS START_TIME + 0 + + N + N + N + N + + + String + normal + START_TIME + 19 + -1 + 表输入 + START_TIME + + . + , + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + + + + + + + + + + 336 + 288 + Y + + + + + + + N + +