diff --git a/epdc-cloud-property/doc/kettle/screen-yushan/screen_totality_grid_query_all.ktr b/epdc-cloud-property/doc/kettle/screen-yushan/screen_totality_grid_query_all.ktr new file mode 100644 index 0000000..669bae1 --- /dev/null +++ b/epdc-cloud-property/doc/kettle/screen-yushan/screen_totality_grid_query_all.ktr @@ -0,0 +1,2981 @@ + + + + screen_totality_grid_query_all + + + + 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 + + + + + + + + + - + 2020/04/27 09:32:01.126 + - + 2020/04/27 09:32:01.126 + H4sIAAAAAAAAAAMAAAAAAAAAAAA= + N + + + + + source_ys_admin + ${db.mysql.epdc.source.ys.host} + MYSQL + Native + ${db.mysql.source.schema.ys.admin} + ${db.mysql.epdc.source.ys.port} + ${db.mysql.epdc.source.ys.username} + ${db.mysql.epdc.source.ys.password} + + + + + + EXTRA_OPTION_MYSQL.allowMultiQueries + true + + + EXTRA_OPTION_MYSQL.characterEncoding + utf8 + + + EXTRA_OPTION_MYSQL.serverTimezone + Asia/Shanghai + + + 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.source.ys.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 + + + + + source_ys_events + ${db.mysql.epdc.source.ys.host} + MYSQL + Native + ${db.mysql.source.schema.ys.events} + ${db.mysql.epdc.source.ys.port} + ${db.mysql.epdc.source.ys.username} + ${db.mysql.epdc.source.ys.password} + + + + + + EXTRA_OPTION_MYSQL.allowMultiQueries + true + + + EXTRA_OPTION_MYSQL.characterEncoding + utf8 + + + EXTRA_OPTION_MYSQL.serverTimezone + Asia/Shanghai + + + 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.source.ys.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 + + + + + source_ys_group + ${db.mysql.epdc.source.ys.host} + MYSQL + Native + ${db.mysql.source.schema.ys.group} + ${db.mysql.epdc.source.ys.port} + ${db.mysql.epdc.source.ys.username} + ${db.mysql.epdc.source.ys.password} + + + + + + EXTRA_OPTION_MYSQL.allowMultiQueries + true + + + EXTRA_OPTION_MYSQL.characterEncoding + utf8 + + + EXTRA_OPTION_MYSQL.serverTimezone + Asia/Shanghai + + + 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.source.ys.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 + + + + + source_ys_user + ${db.mysql.epdc.source.ys.host} + MYSQL + Native + ${db.mysql.source.schema.ys.user} + ${db.mysql.epdc.source.ys.port} + ${db.mysql.epdc.source.ys.username} + ${db.mysql.epdc.source.ys.password} + + + + + + EXTRA_OPTION_MYSQL.allowMultiQueries + true + + + EXTRA_OPTION_MYSQL.characterEncoding + utf8 + + + EXTRA_OPTION_MYSQL.serverTimezone + Asia/Shanghai + + + 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.source.ys.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 + + + 项目数 + 设置项目数变量 + Y + + + 社区ID，社区name + 设置社区ID，社区name + Y + + + 本月用户注册党员数 + 设置本月用户注册党员数 + Y + + + 本月用户注册数 + 设置本月用户注册数 + Y + + + 当月用户注册社群数 + 设置本月用户注册社群数 + Y + + + 设置变量 3 + 本月用户注册数 + Y + + + 设置变量 4 + 本月用户注册党员数 + Y + + + 设置变量 5 + 当月用户注册社群数 + Y + + + 当月总议题数项目数 + 设置上月总议题数项目数变量 + Y + + + 设置变量 + 当月总议题数项目数 + Y + + + 已关闭议题数 + 设置已关闭议题数 + Y + + + 已办结项目数 + 设置已办结项目数 + Y + + + 网格长数 + 设置网格长数变量 + Y + + + 注册党员数 + 设置注册党员数变量 + Y + + + 当月项目数 + 设置当月项目数变量 + Y + + + 当月已办结项目数 + 设置当月已办结项目数 + Y + + + + 已关闭议题数 + TableInput + + Y + + 1 + + none + + + source_ys_events + SELECT + count(id) AS close_case_num +FROM + epdc_issue +WHERE + DEL_FLAG = '0' +AND ISSUE_STATE = '2' +AND CREATED_TIME < DATE_SUB(CURDATE(), INTERVAL ${monthIndex} MONTH) + AND find_in_set(${gridId}, ALL_DEPT_IDS); + 0 + + N + Y + N + N + + + BigNumber + normal + participate_of_news + 34 + 0 + 新闻参与量阅读量点赞量 + participate_of_news + ######0.0###################;-######0.0################### + . + + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + BigNumber + normal + read_of_news + 32 + 0 + 新闻参与量阅读量点赞量 + read_of_news + ######0.0###################;-######0.0################### + . + + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + BigNumber + normal + like_of_news + 32 + 0 + 新闻参与量阅读量点赞量 + like_of_news + ######0.0###################;-######0.0################### + . + + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + + + + + + + + + + 352 + 496 + Y + + + + 已办结项目数 + TableInput + + Y + + 1 + + none + + + source_ys_events + SELECT + count(id) AS finish_project_num +FROM + epdc_item +WHERE + DEL_FLAG = '0' +AND ITEM_STATE = '10' +AND CREATED_TIME < DATE_SUB(CURDATE(), INTERVAL ${monthIndex} MONTH) + AND find_in_set(${gridId}, ALL_DEPT_IDS); + 0 + + N + Y + N + N + + + BigNumber + normal + participate_of_news + 34 + 0 + 新闻参与量阅读量点赞量 + participate_of_news + ######0.0###################;-######0.0################### + . + + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + BigNumber + normal + read_of_news + 32 + 0 + 新闻参与量阅读量点赞量 + read_of_news + ######0.0###################;-######0.0################### + . + + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + BigNumber + normal + like_of_news + 32 + 0 + 新闻参与量阅读量点赞量 + like_of_news + ######0.0###################;-######0.0################### + . + + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + + + + + + + + + + 352 + 576 + Y + + + + 当月已办结项目数 + TableInput + + Y + + 1 + + none + + + source_ys_events + SELECT + count(id) AS finish_project_num +FROM + epdc_item +WHERE + DEL_FLAG = '0' +AND ITEM_STATE = '10' +AND DATE_FORMAT(CREATED_TIME, '%Y%m') = DATE_FORMAT(DATE_SUB(CURDATE(), INTERVAL ${monthIndex} MONTH), '%Y%m') + AND find_in_set(${gridId}, ALL_DEPT_IDS); + 0 + + N + Y + N + N + + + BigNumber + normal + participate_of_news + 34 + 0 + 新闻参与量阅读量点赞量 + participate_of_news + ######0.0###################;-######0.0################### + . + + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + BigNumber + normal + read_of_news + 32 + 0 + 新闻参与量阅读量点赞量 + read_of_news + ######0.0###################;-######0.0################### + . + + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + BigNumber + normal + like_of_news + 32 + 0 + 新闻参与量阅读量点赞量 + like_of_news + ######0.0###################;-######0.0################### + . + + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + + + + + + + + + + 784 + 656 + Y + + + + 当月总议题数项目数 + TableInput + + Y + + 1 + + none + + + source_ys_events + SELECT + SUM(topic_num) AS topic_num_month, + SUM(project_num) AS project_num_month, + GRID_ID AS grid_id, + DATE_FORMAT(NOW(),'%Y-%m') AS cal_date +FROM + ( + SELECT + COUNT(id) AS topic_num, + 0 AS project_num, + GRID_ID + FROM + epdc_issue + WHERE + DEL_FLAG = '0' + AND DATE_FORMAT(CREATED_TIME, '%Y%m') = DATE_FORMAT(DATE_SUB(CURDATE(), INTERVAL ${monthIndex} MONTH), '%Y%m') + AND GRID_ID = ${gridId} + GROUP BY + GRID_ID + UNION ALL + SELECT + 0 AS topic_num, + COUNT(id) AS project_num, + GRID_ID + FROM + epdc_item + WHERE + DEL_FLAG = '0' + AND DATE_FORMAT(CREATED_TIME, '%Y%m') = DATE_FORMAT(DATE_SUB(CURDATE(), INTERVAL ${monthIndex} MONTH), '%Y%m') + AND GRID_ID = ${gridId} + GROUP BY + GRID_ID + ) t +GROUP BY + t.GRID_ID + 0 + + N + Y + N + N + + + BigNumber + normal + topic_num + 42 + 0 + 上月总议题数 + topic_num + ######0.0###################;-######0.0################### + . + + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + BigNumber + normal + project_num + 41 + 0 + 上月总议题数 + project_num + ######0.0###################;-######0.0################### + . + + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + Integer + normal + grid_id + 15 + 0 + 上月总议题数 + grid_id + ####0;-####0 + . + , + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + String + normal + cal_date + 7 + -1 + 上月总议题数 + cal_date + + . + , + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + + + + + + + + + + 352 + 416 + Y + + + + 当月用户注册社群数 + TableInput + + Y + + 1 + + none + + + source_ys_group + SELECT + COUNT(id) as reg_group_num +FROM + epdc_group +WHERE + DEL_FLAG = '0' +AND DATE_FORMAT(CREATED_TIME, '%Y%m') = DATE_FORMAT(DATE_SUB(CURDATE(), INTERVAL ${monthIndex} MONTH), '%Y%m') + AND find_in_set(${gridId}, ALL_DEPT_IDS); + 0 + + N + Y + N + N + + + BigNumber + normal + topic_num + 42 + 0 + 今年总议题数 + topic_num + ######0.0###################;-######0.0################### + . + + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + BigNumber + normal + project_num + 41 + 0 + 今年总议题数 + project_num + ######0.0###################;-######0.0################### + . + + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + Integer + normal + grid_id + 15 + 0 + 今年总议题数 + grid_id + ####0;-####0 + . + , + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + String + normal + cal_date + 7 + -1 + 今年总议题数 + cal_date + + . + , + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + + + + + + + + + + 928 + 256 + Y + + + + 当月项目数 + TableInput + + Y + + 1 + + none + + + source_ys_events + SELECT + COUNT(i.ID) AS project_num +FROM + epdc_item i +WHERE + i.DEL_FLAG = '0' +AND DATE_FORMAT(i.CREATED_TIME, '%Y%m') = DATE_FORMAT(DATE_SUB(CURDATE(), INTERVAL ${monthIndex} MONTH), '%Y%m') + AND find_in_set(${gridId}, i.ALL_DEPT_IDS); + 0 + + N + Y + N + N + + + BigNumber + normal + participate_of_news + 34 + 0 + 新闻参与量阅读量点赞量 + participate_of_news + ######0.0###################;-######0.0################### + . + + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + BigNumber + normal + read_of_news + 32 + 0 + 新闻参与量阅读量点赞量 + read_of_news + ######0.0###################;-######0.0################### + . + + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + BigNumber + normal + like_of_news + 32 + 0 + 新闻参与量阅读量点赞量 + like_of_news + ######0.0###################;-######0.0################### + . + + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + + + + + + + + + + 784 + 576 + Y + + + + 总议题数 + TableInput + + Y + + 1 + + none + + + source_ys_events + SELECT + COUNT(i.ID) AS case_num +FROM + epdc_issue i +WHERE + i.DEL_FLAG = '0' +AND i.CREATED_TIME < DATE_SUB(CURDATE(), INTERVAL ${monthIndex} MONTH) + AND find_in_set(${gridId}, i.ALL_DEPT_IDS); + 0 + + N + Y + N + N + + + BigNumber + normal + participate_of_news + 34 + 0 + 新闻参与量阅读量点赞量 + participate_of_news + ######0.0###################;-######0.0################### + . + + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + BigNumber + normal + read_of_news + 32 + 0 + 新闻参与量阅读量点赞量 + read_of_news + ######0.0###################;-######0.0################### + . + + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + BigNumber + normal + like_of_news + 32 + 0 + 新闻参与量阅读量点赞量 + like_of_news + ######0.0###################;-######0.0################### + . + + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + + + + + + + + + + 352 + 176 + Y + + + + 本月用户注册党员数 + TableInput + + Y + + 1 + + none + + + source_ys_user + SELECT + COUNT(u.ID) as reg_party_num +FROM + epdc_user u +WHERE + u.DEL_FLAG = '0' +AND u.PARTY_FLAG = '1' +AND DATE_FORMAT(CREATED_TIME, '%Y%m') = DATE_FORMAT(DATE_SUB(CURDATE(), INTERVAL ${monthIndex} MONTH), '%Y%m') +AND find_in_set(${gridId}, u.ALL_DEPT_IDS); + 0 + + N + Y + N + N + + + BigNumber + normal + topic_num + 42 + 0 + 今年总议题数 + topic_num + ######0.0###################;-######0.0################### + . + + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + BigNumber + normal + project_num + 41 + 0 + 今年总议题数 + project_num + ######0.0###################;-######0.0################### + . + + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + Integer + normal + grid_id + 15 + 0 + 今年总议题数 + grid_id + ####0;-####0 + . + , + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + String + normal + cal_date + 7 + -1 + 今年总议题数 + cal_date + + . + , + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + + + + + + + + + + 928 + 176 + Y + + + + 本月用户注册数 + TableInput + + Y + + 1 + + none + + + source_ys_user + SELECT + COUNT(u.ID) as reg_user_num +FROM + epdc_user u +WHERE + u.DEL_FLAG = '0' + AND DATE_FORMAT(CREATED_TIME, '%Y%m') = DATE_FORMAT(DATE_SUB(CURDATE(), INTERVAL ${monthIndex} MONTH), '%Y%m') + AND find_in_set(${gridId}, u.ALL_DEPT_IDS); + 0 + + N + Y + N + N + + + BigNumber + normal + topic_num + 42 + 0 + 今年总议题数 + topic_num + ######0.0###################;-######0.0################### + . + + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + BigNumber + normal + project_num + 41 + 0 + 今年总议题数 + project_num + ######0.0###################;-######0.0################### + . + + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + Integer + normal + grid_id + 15 + 0 + 今年总议题数 + grid_id + ####0;-####0 + . + , + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + String + normal + cal_date + 7 + -1 + 今年总议题数 + cal_date + + . + , + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + + + + + + + + + + 928 + 96 + Y + + + + 注册党员数 + TableInput + + Y + + 1 + + none + + + source_ys_user + SELECT + COUNT(ID) AS reg_party_num +FROM + epdc_party_members +WHERE + DEL_FLAG = '0' +AND CREATED_TIME < DATE_SUB(CURDATE(), INTERVAL ${monthIndex} MONTH) +AND find_in_set(${gridId}, ALL_DEPT_IDS); + 0 + + N + Y + N + N + + + + + + + + + + + 352 + 736 + Y + + + + 注册用户数 + TableInput + + Y + + 1 + + none + + + source_ys_user + SELECT + COUNT(u.id) register_num +FROM + epdc_user u +WHERE + u.DEL_FLAG = '0' +AND u.REGISTER_TIME < DATE_SUB(CURDATE(), INTERVAL ${monthIndex} MONTH) +AND find_in_set(${gridId}, u.ALL_DEPT_IDS); + 0 + + N + Y + N + N + + + + + + + + + + + 352 + 256 + Y + + + + 社区ID，社区name + TableInput + + Y + + 1 + + none + + + source_ys_admin + SELECT + id AS commId, + NAME AS commName +FROM + sys_dept +WHERE + id = ( + SELECT + pid + FROM + sys_dept + WHERE + del_flag = '0' + AND id = ${gridId} + ) +AND del_flag = '0' + 0 + + N + Y + N + N + + + BigNumber + normal + topic_num + 42 + 0 + 上月总议题数 + topic_num + ######0.0###################;-######0.0################### + . + + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + BigNumber + normal + project_num + 41 + 0 + 上月总议题数 + project_num + ######0.0###################;-######0.0################### + . + + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + Integer + normal + grid_id + 15 + 0 + 上月总议题数 + grid_id + ####0;-####0 + . + , + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + String + normal + cal_date + 7 + -1 + 上月总议题数 + cal_date + + . + , + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + + + + + + + + + + 352 + 96 + Y + + + + 网格长数 + TableInput + + Y + + 1 + + none + + + source_ys_admin + SELECT + count(u.id) AS gridmaster +FROM + sys_user u +LEFT JOIN sys_role_user ru ON u.id = ru.user_id +LEFT JOIN sys_role r ON r.id = ru.role_id +WHERE + r.type_key = 'gridLeader' +AND u.DEL_FLAG = '0' +AND r.DEL_FLAG = '0' +AND u.create_date < DATE_SUB(CURDATE(), INTERVAL ${monthIndex} MONTH) +AND u.dept_id = ${gridId}; + 0 + + N + Y + N + N + + + + + + + + + + + 352 + 656 + Y + + + + 设置上月总议题数项目数变量 + SetVariable + + Y + + 1 + + none + + + + + cal_date + cal_date + PARENT_JOB + + + + grid_id + grid_id + PARENT_JOB + + + + project_num_month + project_num_month + PARENT_JOB + + + + topic_num_month + topic_num_month + PARENT_JOB + + + + Y + + + + + + + + + + 592 + 416 + Y + + + + 设置变量 + SetVariable + + Y + + 1 + + none + + + + + topic_num_month + topic_num_month + PARENT_JOB + 0 + + + project_num_month + project_num_month + PARENT_JOB + 0 + + + Y + + + + + + + + + + 144 + 416 + Y + + + + 设置变量 3 + SetVariable + + Y + + 1 + + none + + + + + reg_user_num + reg_user_num + PARENT_JOB + 0 + + + Y + + + + + + + + + + 784 + 96 + Y + + + + 设置变量 4 + SetVariable + + Y + + 1 + + none + + + + + reg_party_num + reg_party_num + PARENT_JOB + 0 + + + Y + + + + + + + + + + 784 + 176 + Y + + + + 设置变量 5 + SetVariable + + Y + + 1 + + none + + + + + reg_group_num + reg_group_num + PARENT_JOB + 0 + + + Y + + + + + + + + + + 784 + 256 + Y + + + + 设置已关闭议题数 + SetVariable + + Y + + 1 + + none + + + + + close_case_num + close_case_num + PARENT_JOB + + + + Y + + + + + + + + + + 592 + 496 + Y + + + + 设置已办结项目数 + SetVariable + + Y + + 1 + + none + + + + + finish_project_num + finish_project_num + PARENT_JOB + + + + Y + + + + + + + + + + 592 + 576 + Y + + + + 设置当月已办结项目数 + SetVariable + + Y + + 1 + + none + + + + + finish_project_num + finish_project_num_month + PARENT_JOB + + + + Y + + + + + + + + + + 1024 + 656 + Y + + + + 设置当月项目数变量 + SetVariable + + Y + + 1 + + none + + + + + project_num + project_num_month + PARENT_JOB + + + + Y + + + + + + + + + + 1024 + 576 + Y + + + + 设置本月用户注册党员数 + SetVariable + + Y + + 1 + + none + + + + + reg_party_num + reg_party_num + PARENT_JOB + + + + Y + + + + + + + + + + 1168 + 176 + Y + + + + 设置本月用户注册数 + SetVariable + + Y + + 1 + + none + + + + + reg_user_num + reg_user_num + PARENT_JOB + + + + Y + + + + + + + + + + 1168 + 96 + Y + + + + 设置本月用户注册社群数 + SetVariable + + Y + + 1 + + none + + + + + reg_group_num + reg_group_num + PARENT_JOB + + + + Y + + + + + + + + + + 1168 + 256 + Y + + + + 设置注册党员数变量 + SetVariable + + Y + + 1 + + none + + + + + reg_party_num + reg_party_num + PARENT_JOB + + + + Y + + + + + + + + + + 592 + 736 + Y + + + + 设置注册用户数变量 + SetVariable + + Y + + 1 + + none + + + + + register_num + register_num + PARENT_JOB + + + + Y + + + + + + + + + + 592 + 256 + Y + + + + 设置社区ID，社区name + SetVariable + + Y + + 1 + + none + + + + + commId + commId + PARENT_JOB + + + + commName + commName + PARENT_JOB + + + + Y + + + + + + + + + + 592 + 96 + Y + + + + 设置网格长数变量 + SetVariable + + Y + + 1 + + none + + + + + gridmaster + gridmaster0 + PARENT_JOB + + + + Y + + + + + + + + + + 592 + 656 + Y + + + + 设置议题数变量 + SetVariable + + Y + + 1 + + none + + + + + case_num + case_num + PARENT_JOB + + + + Y + + + + + + + + + + 592 + 176 + Y + + + + 设置项目数变量 + SetVariable + + Y + + 1 + + none + + + + + project_num + project_num + PARENT_JOB + + + + Y + + + + + + + + + + 592 + 336 + Y + + + + 项目数 + TableInput + + Y + + 1 + + none + + + source_ys_events + SELECT + COUNT(i.ID) AS project_num +FROM + epdc_item i +WHERE + i.DEL_FLAG = '0' +AND i.CREATED_TIME < DATE_SUB(CURDATE(), INTERVAL ${monthIndex} MONTH) + AND find_in_set(${gridId}, i.ALL_DEPT_IDS); + 0 + + N + Y + N + N + + + BigNumber + normal + participate_of_news + 34 + 0 + 新闻参与量阅读量点赞量 + participate_of_news + ######0.0###################;-######0.0################### + . + + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + BigNumber + normal + read_of_news + 32 + 0 + 新闻参与量阅读量点赞量 + read_of_news + ######0.0###################;-######0.0################### + . + + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + BigNumber + normal + like_of_news + 32 + 0 + 新闻参与量阅读量点赞量 + like_of_news + ######0.0###################;-######0.0################### + . + + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + + + + + + + + + + 352 + 336 + Y + + + + + + + N + + diff --git a/epdc-cloud-property/doc/kettle/screen-yushan/screen_totality_grid_query_all_day.ktr b/epdc-cloud-property/doc/kettle/screen-yushan/screen_totality_grid_query_all_day.ktr new file mode 100644 index 0000000..c8fa4ee --- /dev/null +++ b/epdc-cloud-property/doc/kettle/screen-yushan/screen_totality_grid_query_all_day.ktr @@ -0,0 +1,2981 @@ + + + + screen_totality_grid_query_all_day + + + + 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 + + + + + + + + + - + 2020/04/27 09:32:01.126 + - + 2020/04/27 09:32:01.126 + H4sIAAAAAAAAAAMAAAAAAAAAAAA= + N + + + + + source_ys_admin + ${db.mysql.epdc.source.ys.host} + MYSQL + Native + ${db.mysql.source.schema.ys.admin} + ${db.mysql.epdc.source.ys.port} + ${db.mysql.epdc.source.ys.username} + ${db.mysql.epdc.source.ys.password} + + + + + + EXTRA_OPTION_MYSQL.allowMultiQueries + true + + + EXTRA_OPTION_MYSQL.characterEncoding + utf8 + + + EXTRA_OPTION_MYSQL.serverTimezone + Asia/Shanghai + + + 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.source.ys.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 + + + + + source_ys_events + ${db.mysql.epdc.source.ys.host} + MYSQL + Native + ${db.mysql.source.schema.ys.events} + ${db.mysql.epdc.source.ys.port} + ${db.mysql.epdc.source.ys.username} + ${db.mysql.epdc.source.ys.password} + + + + + + EXTRA_OPTION_MYSQL.allowMultiQueries + true + + + EXTRA_OPTION_MYSQL.characterEncoding + utf8 + + + EXTRA_OPTION_MYSQL.serverTimezone + Asia/Shanghai + + + 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.source.ys.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 + + + + + source_ys_group + ${db.mysql.epdc.source.ys.host} + MYSQL + Native + ${db.mysql.source.schema.ys.group} + ${db.mysql.epdc.source.ys.port} + ${db.mysql.epdc.source.ys.username} + ${db.mysql.epdc.source.ys.password} + + + + + + EXTRA_OPTION_MYSQL.allowMultiQueries + true + + + EXTRA_OPTION_MYSQL.characterEncoding + utf8 + + + EXTRA_OPTION_MYSQL.serverTimezone + Asia/Shanghai + + + 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.source.ys.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 + + + + + source_ys_user + ${db.mysql.epdc.source.ys.host} + MYSQL + Native + ${db.mysql.source.schema.ys.user} + ${db.mysql.epdc.source.ys.port} + ${db.mysql.epdc.source.ys.username} + ${db.mysql.epdc.source.ys.password} + + + + + + EXTRA_OPTION_MYSQL.allowMultiQueries + true + + + EXTRA_OPTION_MYSQL.characterEncoding + utf8 + + + EXTRA_OPTION_MYSQL.serverTimezone + Asia/Shanghai + + + 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.source.ys.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 + + + 项目数 + 设置项目数变量 + Y + + + 社区ID，社区name + 设置社区ID，社区name + Y + + + 本月用户注册党员数 + 设置本月用户注册党员数 + Y + + + 本月用户注册数 + 设置本月用户注册数 + Y + + + 当月用户注册社群数 + 设置本月用户注册社群数 + Y + + + 设置变量 3 + 本月用户注册数 + Y + + + 设置变量 4 + 本月用户注册党员数 + Y + + + 设置变量 5 + 当月用户注册社群数 + Y + + + 当月总议题数项目数 + 设置上月总议题数项目数变量 + Y + + + 设置变量 + 当月总议题数项目数 + Y + + + 已关闭议题数 + 设置已关闭议题数 + Y + + + 已办结项目数 + 设置已办结项目数 + Y + + + 网格长数 + 设置网格长数变量 + Y + + + 注册党员数 + 设置注册党员数变量 + Y + + + 当月项目数 + 设置当月项目数变量 + Y + + + 当月已办结项目数 + 设置当月已办结项目数 + Y + + + + 已关闭议题数 + TableInput + + Y + + 1 + + none + + + source_ys_events + SELECT + count(id) AS close_case_num +FROM + epdc_issue +WHERE + DEL_FLAG = '0' +AND ISSUE_STATE = '2' +AND CREATED_TIME < DATE_SUB(CURDATE(), INTERVAL ${dayIndex} DAY) + AND find_in_set(${gridId}, ALL_DEPT_IDS); + 0 + + N + Y + N + N + + + BigNumber + normal + participate_of_news + 34 + 0 + 新闻参与量阅读量点赞量 + participate_of_news + ######0.0###################;-######0.0################### + . + + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + BigNumber + normal + read_of_news + 32 + 0 + 新闻参与量阅读量点赞量 + read_of_news + ######0.0###################;-######0.0################### + . + + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + BigNumber + normal + like_of_news + 32 + 0 + 新闻参与量阅读量点赞量 + like_of_news + ######0.0###################;-######0.0################### + . + + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + + + + + + + + + + 352 + 496 + Y + + + + 已办结项目数 + TableInput + + Y + + 1 + + none + + + source_ys_events + SELECT + count(id) AS finish_project_num +FROM + epdc_item +WHERE + DEL_FLAG = '0' +AND ITEM_STATE = '10' +AND CREATED_TIME < DATE_SUB(CURDATE(), INTERVAL ${dayIndex} DAY) + AND find_in_set(${gridId}, ALL_DEPT_IDS); + 0 + + N + Y + N + N + + + BigNumber + normal + participate_of_news + 34 + 0 + 新闻参与量阅读量点赞量 + participate_of_news + ######0.0###################;-######0.0################### + . + + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + BigNumber + normal + read_of_news + 32 + 0 + 新闻参与量阅读量点赞量 + read_of_news + ######0.0###################;-######0.0################### + . + + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + BigNumber + normal + like_of_news + 32 + 0 + 新闻参与量阅读量点赞量 + like_of_news + ######0.0###################;-######0.0################### + . + + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + + + + + + + + + + 352 + 576 + Y + + + + 当月已办结项目数 + TableInput + + Y + + 1 + + none + + + source_ys_events + SELECT + count(id) AS finish_project_num +FROM + epdc_item +WHERE + DEL_FLAG = '0' +AND ITEM_STATE = '10' +AND DATE_FORMAT(CREATED_TIME, '%Y%m') = DATE_FORMAT(DATE_SUB(CURDATE(), INTERVAL ${dayIndex} DAY), '%Y%m') + AND find_in_set(${gridId}, ALL_DEPT_IDS); + 0 + + N + Y + N + N + + + BigNumber + normal + participate_of_news + 34 + 0 + 新闻参与量阅读量点赞量 + participate_of_news + ######0.0###################;-######0.0################### + . + + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + BigNumber + normal + read_of_news + 32 + 0 + 新闻参与量阅读量点赞量 + read_of_news + ######0.0###################;-######0.0################### + . + + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + BigNumber + normal + like_of_news + 32 + 0 + 新闻参与量阅读量点赞量 + like_of_news + ######0.0###################;-######0.0################### + . + + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + + + + + + + + + + 784 + 656 + Y + + + + 当月总议题数项目数 + TableInput + + Y + + 1 + + none + + + source_ys_events + SELECT + SUM(topic_num) AS topic_num_month, + SUM(project_num) AS project_num_month, + GRID_ID AS grid_id, + DATE_FORMAT(NOW(),'%Y-%m') AS cal_date +FROM + ( + SELECT + COUNT(id) AS topic_num, + 0 AS project_num, + GRID_ID + FROM + epdc_issue + WHERE + DEL_FLAG = '0' + AND DATE_FORMAT(CREATED_TIME, '%Y%m') = DATE_FORMAT(DATE_SUB(CURDATE(), INTERVAL ${dayIndex} DAY), '%Y%m') + AND GRID_ID = ${gridId} + GROUP BY + GRID_ID + UNION ALL + SELECT + 0 AS topic_num, + COUNT(id) AS project_num, + GRID_ID + FROM + epdc_item + WHERE + DEL_FLAG = '0' + AND DATE_FORMAT(CREATED_TIME, '%Y%m') = DATE_FORMAT(DATE_SUB(CURDATE(), INTERVAL ${dayIndex} DAY), '%Y%m') + AND GRID_ID = ${gridId} + GROUP BY + GRID_ID + ) t +GROUP BY + t.GRID_ID + 0 + + N + Y + N + N + + + BigNumber + normal + topic_num + 42 + 0 + 上月总议题数 + topic_num + ######0.0###################;-######0.0################### + . + + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + BigNumber + normal + project_num + 41 + 0 + 上月总议题数 + project_num + ######0.0###################;-######0.0################### + . + + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + Integer + normal + grid_id + 15 + 0 + 上月总议题数 + grid_id + ####0;-####0 + . + , + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + String + normal + cal_date + 7 + -1 + 上月总议题数 + cal_date + + . + , + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + + + + + + + + + + 352 + 416 + Y + + + + 当月用户注册社群数 + TableInput + + Y + + 1 + + none + + + source_ys_group + SELECT + COUNT(id) as reg_group_num +FROM + epdc_group +WHERE + DEL_FLAG = '0' +AND DATE_FORMAT(CREATED_TIME, '%Y%m') = DATE_FORMAT(DATE_SUB(CURDATE(), INTERVAL ${dayIndex} DAY), '%Y%m') + AND find_in_set(${gridId}, ALL_DEPT_IDS); + 0 + + N + Y + N + N + + + BigNumber + normal + topic_num + 42 + 0 + 今年总议题数 + topic_num + ######0.0###################;-######0.0################### + . + + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + BigNumber + normal + project_num + 41 + 0 + 今年总议题数 + project_num + ######0.0###################;-######0.0################### + . + + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + Integer + normal + grid_id + 15 + 0 + 今年总议题数 + grid_id + ####0;-####0 + . + , + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + String + normal + cal_date + 7 + -1 + 今年总议题数 + cal_date + + . + , + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + + + + + + + + + + 928 + 256 + Y + + + + 当月项目数 + TableInput + + Y + + 1 + + none + + + source_ys_events + SELECT + COUNT(i.ID) AS project_num +FROM + epdc_item i +WHERE + i.DEL_FLAG = '0' +AND DATE_FORMAT(i.CREATED_TIME, '%Y%m') = DATE_FORMAT(DATE_SUB(CURDATE(), INTERVAL ${dayIndex} DAY), '%Y%m') + AND find_in_set(${gridId}, i.ALL_DEPT_IDS); + 0 + + N + Y + N + N + + + BigNumber + normal + participate_of_news + 34 + 0 + 新闻参与量阅读量点赞量 + participate_of_news + ######0.0###################;-######0.0################### + . + + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + BigNumber + normal + read_of_news + 32 + 0 + 新闻参与量阅读量点赞量 + read_of_news + ######0.0###################;-######0.0################### + . + + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + BigNumber + normal + like_of_news + 32 + 0 + 新闻参与量阅读量点赞量 + like_of_news + ######0.0###################;-######0.0################### + . + + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + + + + + + + + + + 784 + 576 + Y + + + + 总议题数 + TableInput + + Y + + 1 + + none + + + source_ys_events + SELECT + COUNT(i.ID) AS case_num +FROM + epdc_issue i +WHERE + i.DEL_FLAG = '0' +AND i.CREATED_TIME < DATE_SUB(CURDATE(), INTERVAL ${dayIndex} DAY) + AND find_in_set(${gridId}, i.ALL_DEPT_IDS); + 0 + + N + Y + N + N + + + BigNumber + normal + participate_of_news + 34 + 0 + 新闻参与量阅读量点赞量 + participate_of_news + ######0.0###################;-######0.0################### + . + + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + BigNumber + normal + read_of_news + 32 + 0 + 新闻参与量阅读量点赞量 + read_of_news + ######0.0###################;-######0.0################### + . + + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + BigNumber + normal + like_of_news + 32 + 0 + 新闻参与量阅读量点赞量 + like_of_news + ######0.0###################;-######0.0################### + . + + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + + + + + + + + + + 352 + 176 + Y + + + + 本月用户注册党员数 + TableInput + + Y + + 1 + + none + + + source_ys_user + SELECT + COUNT(u.ID) as reg_party_num +FROM + epdc_user u +WHERE + u.DEL_FLAG = '0' +AND u.PARTY_FLAG = '1' +AND DATE_FORMAT(CREATED_TIME, '%Y%m') = DATE_FORMAT(DATE_SUB(CURDATE(), INTERVAL ${dayIndex} DAY), '%Y%m') +AND find_in_set(${gridId}, u.ALL_DEPT_IDS); + 0 + + N + Y + N + N + + + BigNumber + normal + topic_num + 42 + 0 + 今年总议题数 + topic_num + ######0.0###################;-######0.0################### + . + + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + BigNumber + normal + project_num + 41 + 0 + 今年总议题数 + project_num + ######0.0###################;-######0.0################### + . + + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + Integer + normal + grid_id + 15 + 0 + 今年总议题数 + grid_id + ####0;-####0 + . + , + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + String + normal + cal_date + 7 + -1 + 今年总议题数 + cal_date + + . + , + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + + + + + + + + + + 928 + 176 + Y + + + + 本月用户注册数 + TableInput + + Y + + 1 + + none + + + source_ys_user + SELECT + COUNT(u.ID) as reg_user_num +FROM + epdc_user u +WHERE + u.DEL_FLAG = '0' + AND DATE_FORMAT(CREATED_TIME, '%Y%m') = DATE_FORMAT(DATE_SUB(CURDATE(), INTERVAL ${dayIndex} DAY), '%Y%m') + AND find_in_set(${gridId}, u.ALL_DEPT_IDS); + 0 + + N + Y + N + N + + + BigNumber + normal + topic_num + 42 + 0 + 今年总议题数 + topic_num + ######0.0###################;-######0.0################### + . + + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + BigNumber + normal + project_num + 41 + 0 + 今年总议题数 + project_num + ######0.0###################;-######0.0################### + . + + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + Integer + normal + grid_id + 15 + 0 + 今年总议题数 + grid_id + ####0;-####0 + . + , + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + String + normal + cal_date + 7 + -1 + 今年总议题数 + cal_date + + . + , + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + + + + + + + + + + 928 + 96 + Y + + + + 注册党员数 + TableInput + + Y + + 1 + + none + + + source_ys_user + SELECT + COUNT(ID) AS reg_party_num +FROM + epdc_party_members +WHERE + DEL_FLAG = '0' +AND CREATED_TIME < DATE_SUB(CURDATE(), INTERVAL ${dayIndex} DAY) +AND find_in_set(${gridId}, ALL_DEPT_IDS); + 0 + + N + Y + N + N + + + + + + + + + + + 352 + 736 + Y + + + + 注册用户数 + TableInput + + Y + + 1 + + none + + + source_ys_user + SELECT + COUNT(u.id) register_num +FROM + epdc_user u +WHERE + u.DEL_FLAG = '0' +AND u.REGISTER_TIME < DATE_SUB(CURDATE(), INTERVAL ${dayIndex} DAY) +AND find_in_set(${gridId}, u.ALL_DEPT_IDS); + 0 + + N + Y + N + N + + + + + + + + + + + 352 + 256 + Y + + + + 社区ID，社区name + TableInput + + Y + + 1 + + none + + + source_ys_admin + SELECT + id AS commId, + NAME AS commName +FROM + sys_dept +WHERE + id = ( + SELECT + pid + FROM + sys_dept + WHERE + del_flag = '0' + AND id = ${gridId} + ) +AND del_flag = '0' + 0 + + N + Y + N + N + + + BigNumber + normal + topic_num + 42 + 0 + 上月总议题数 + topic_num + ######0.0###################;-######0.0################### + . + + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + BigNumber + normal + project_num + 41 + 0 + 上月总议题数 + project_num + ######0.0###################;-######0.0################### + . + + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + Integer + normal + grid_id + 15 + 0 + 上月总议题数 + grid_id + ####0;-####0 + . + , + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + String + normal + cal_date + 7 + -1 + 上月总议题数 + cal_date + + . + , + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + + + + + + + + + + 352 + 96 + Y + + + + 网格长数 + TableInput + + Y + + 1 + + none + + + source_ys_admin + SELECT + count(u.id) AS gridmaster +FROM + sys_user u +LEFT JOIN sys_role_user ru ON u.id = ru.user_id +LEFT JOIN sys_role r ON r.id = ru.role_id +WHERE + r.type_key = 'gridLeader' +AND u.DEL_FLAG = '0' +AND r.DEL_FLAG = '0' +AND u.create_date < DATE_SUB(CURDATE(), INTERVAL ${dayIndex} DAY) +AND u.dept_id = ${gridId}; + 0 + + N + Y + N + N + + + + + + + + + + + 352 + 656 + Y + + + + 设置上月总议题数项目数变量 + SetVariable + + Y + + 1 + + none + + + + + cal_date + cal_date + PARENT_JOB + + + + grid_id + grid_id + PARENT_JOB + + + + project_num_month + project_num_month + PARENT_JOB + + + + topic_num_month + topic_num_month + PARENT_JOB + + + + Y + + + + + + + + + + 592 + 416 + Y + + + + 设置变量 + SetVariable + + Y + + 1 + + none + + + + + topic_num_month + topic_num_month + PARENT_JOB + 0 + + + project_num_month + project_num_month + PARENT_JOB + 0 + + + Y + + + + + + + + + + 144 + 416 + Y + + + + 设置变量 3 + SetVariable + + Y + + 1 + + none + + + + + reg_user_num + reg_user_num + PARENT_JOB + 0 + + + Y + + + + + + + + + + 784 + 96 + Y + + + + 设置变量 4 + SetVariable + + Y + + 1 + + none + + + + + reg_party_num + reg_party_num + PARENT_JOB + 0 + + + Y + + + + + + + + + + 784 + 176 + Y + + + + 设置变量 5 + SetVariable + + Y + + 1 + + none + + + + + reg_group_num + reg_group_num + PARENT_JOB + 0 + + + Y + + + + + + + + + + 784 + 256 + Y + + + + 设置已关闭议题数 + SetVariable + + Y + + 1 + + none + + + + + close_case_num + close_case_num + PARENT_JOB + + + + Y + + + + + + + + + + 592 + 496 + Y + + + + 设置已办结项目数 + SetVariable + + Y + + 1 + + none + + + + + finish_project_num + finish_project_num + PARENT_JOB + + + + Y + + + + + + + + + + 592 + 576 + Y + + + + 设置当月已办结项目数 + SetVariable + + Y + + 1 + + none + + + + + finish_project_num + finish_project_num_month + PARENT_JOB + + + + Y + + + + + + + + + + 1024 + 656 + Y + + + + 设置当月项目数变量 + SetVariable + + Y + + 1 + + none + + + + + project_num + project_num_month + PARENT_JOB + + + + Y + + + + + + + + + + 1024 + 576 + Y + + + + 设置本月用户注册党员数 + SetVariable + + Y + + 1 + + none + + + + + reg_party_num + reg_party_num + PARENT_JOB + + + + Y + + + + + + + + + + 1168 + 176 + Y + + + + 设置本月用户注册数 + SetVariable + + Y + + 1 + + none + + + + + reg_user_num + reg_user_num + PARENT_JOB + + + + Y + + + + + + + + + + 1168 + 96 + Y + + + + 设置本月用户注册社群数 + SetVariable + + Y + + 1 + + none + + + + + reg_group_num + reg_group_num + PARENT_JOB + + + + Y + + + + + + + + + + 1168 + 256 + Y + + + + 设置注册党员数变量 + SetVariable + + Y + + 1 + + none + + + + + reg_party_num + reg_party_num + PARENT_JOB + + + + Y + + + + + + + + + + 592 + 736 + Y + + + + 设置注册用户数变量 + SetVariable + + Y + + 1 + + none + + + + + register_num + register_num + PARENT_JOB + + + + Y + + + + + + + + + + 592 + 256 + Y + + + + 设置社区ID，社区name + SetVariable + + Y + + 1 + + none + + + + + commId + commId + PARENT_JOB + + + + commName + commName + PARENT_JOB + + + + Y + + + + + + + + + + 592 + 96 + Y + + + + 设置网格长数变量 + SetVariable + + Y + + 1 + + none + + + + + gridmaster + gridmaster0 + PARENT_JOB + + + + Y + + + + + + + + + + 592 + 656 + Y + + + + 设置议题数变量 + SetVariable + + Y + + 1 + + none + + + + + case_num + case_num + PARENT_JOB + + + + Y + + + + + + + + + + 592 + 176 + Y + + + + 设置项目数变量 + SetVariable + + Y + + 1 + + none + + + + + project_num + project_num + PARENT_JOB + + + + Y + + + + + + + + + + 592 + 336 + Y + + + + 项目数 + TableInput + + Y + + 1 + + none + + + source_ys_events + SELECT + COUNT(i.ID) AS project_num +FROM + epdc_item i +WHERE + i.DEL_FLAG = '0' +AND i.CREATED_TIME < DATE_SUB(CURDATE(), INTERVAL ${dayIndex} DAY) + AND find_in_set(${gridId}, i.ALL_DEPT_IDS); + 0 + + N + Y + N + N + + + BigNumber + normal + participate_of_news + 34 + 0 + 新闻参与量阅读量点赞量 + participate_of_news + ######0.0###################;-######0.0################### + . + + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + BigNumber + normal + read_of_news + 32 + 0 + 新闻参与量阅读量点赞量 + read_of_news + ######0.0###################;-######0.0################### + . + + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + BigNumber + normal + like_of_news + 32 + 0 + 新闻参与量阅读量点赞量 + like_of_news + ######0.0###################;-######0.0################### + . + + + none + N + Y + 0 + N + N + N + zh_CN + Asia/Shanghai + N + + + + + + + + + + + + 352 + 336 + Y + + + + + + + N + + diff --git a/epdc-cloud-property/doc/kettle/screen-yushan/screen_totality_grid_update.ktr b/epdc-cloud-property/doc/kettle/screen-yushan/screen_totality_grid_update.ktr index a6aaf4e..ad8a664 100644 --- a/epdc-cloud-property/doc/kettle/screen-yushan/screen_totality_grid_update.ktr +++ b/epdc-cloud-property/doc/kettle/screen-yushan/screen_totality_grid_update.ktr @@ -551,7 +551,7 @@ ) VALUES ( - ${commId}, '${commName}', ${gridId}, '${communityGrid}', ${register_num}, ${case_num}, ${project_num}, ${village_num}, ${building_num}, ${housemaster_num}, ${focus_groups_num}, ${party_num}, ${reg_party_num}, ${close_case_num}, ${finish_project_num}, ${gridmaster}, NOW(), null + ${commId}, '${commName}', ${gridId}, '${communityGrid}', ${register_num}, ${case_num}, ${project_num}, ${village_num}, ${building_num}, ${housemaster_num}, ${focus_groups_num}, ${party_num}, ${reg_party_num}, ${close_case_num}, ${finish_project_num}, '${gridmaster}', NOW(), null ) N @@ -575,7 +575,7 @@ VALUES - 网格排名表月度数据清空 + 清空网格治理排行表 ExecSQL Y @@ -590,7 +590,7 @@ VALUES N Y N - delete from ys_grid_rank where grid_id = ${gridId} and cal_date = date_format(now(), '%Y-%m') + delete from ys_grid_gov_rank where grid_id = ${gridId} and cal_date = date_format(now(), '%Y-%m') N @@ -607,13 +607,13 @@ VALUES - 448 - 240 + 656 + 368 Y - 网格治理排行表月度数据清空 + 网格排名表月度数据清空 ExecSQL Y @@ -628,7 +628,7 @@ VALUES N Y N - delete from ys_grid_gov_rank where grid_id = ${gridId} and cal_date = date_format(now(), '%Y-%m') + delete from ys_grid_rank where grid_id = ${gridId} and cal_date = date_format(now(), '%Y-%m') N @@ -646,12 +646,12 @@ VALUES 448 - 496 + 240 Y - 网格注册数统计月度数据清空 + 网格治理排行表月度数据清空 ExecSQL Y @@ -666,7 +666,7 @@ VALUES N Y N - delete from ys_grid_reg where grid_id = ${gridId} and cal_date = date_format(now(), '%Y-%m') + delete from ys_grid_gov_rank where grid_id = ${gridId} and cal_date = date_format(now(), '%Y-%m') N @@ -684,12 +684,12 @@ VALUES 448 - 368 + 496 Y - 清空网格治理排行表 + 网格注册数统计月度数据清空 ExecSQL Y @@ -704,7 +704,7 @@ VALUES N Y N - delete from ys_grid_gov_rank where grid_id = ${gridId} and cal_date = date_format(now(), '%Y-%m') + delete from ys_grid_reg where grid_id = ${gridId} and cal_date = date_format(now(), '%Y-%m') N @@ -721,7 +721,7 @@ VALUES - 656 + 448 368 Y diff --git a/epdc-cloud-property/doc/kettle/screen-yushan/screen_totality_grid_update_all.ktr b/epdc-cloud-property/doc/kettle/screen-yushan/screen_totality_grid_update_all.ktr new file mode 100644 index 0000000..d6b4a86 --- /dev/null +++ b/epdc-cloud-property/doc/kettle/screen-yushan/screen_totality_grid_update_all.ktr @@ -0,0 +1,680 @@ + + + + screen_totality_grid_update_all + + + + 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 + + + + + + + + + - + 2020/04/27 09:32:01.126 + - + 2020/04/27 09:32:01.126 + H4sIAAAAAAAAAAMAAAAAAAAAAAA= + N + + + + + target_yushan + ${db.mysql.epdc.target.ys.host} + MYSQL + Native + ${db.mysql.target.schema.yushandb} + ${db.mysql.epdc.target.ys.port} + ${db.mysql.epdc.target.ys.username} + ${db.mysql.epdc.target.ys.password} + + + + + + EXTRA_OPTION_MYSQL.allowMultiQueries + true + + + EXTRA_OPTION_MYSQL.characterEncoding + utf8 + + + EXTRA_OPTION_MYSQL.serverTimezone + Asia/Shanghai + + + 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.ys.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 + + + + + + + 网格排名表 + ExecSQL + + Y + + 1 + + none + + + target_yushan + N + N + Y + N + INSERT INTO ys_grid_rank ( + cal_date, + name, + grid_id, + comm_id, + comm_name, + topic_num, + project_num, + create_time, + update_time +) +VALUES + ( + DATE_FORMAT(DATE_SUB(CURDATE(), INTERVAL ${monthIndex} MONTH), '%Y-%m'), '${communityGrid}', ${gridId}, ${commId}, '${commName}', ${topic_num_month}, ${project_num_month}, NOW(), null + ) + N + + + + + + + + + + + + + + + + 717 + 373 + Y + + + + 网格治理排行表-月 + ExecSQL + + Y + + 1 + + none + + + target_yushan + N + N + Y + N + INSERT INTO ys_grid_gov_rank ( + comm_id, + comm_name, + cal_date, + grid_name, + grid_id, + project_num, + project_finish_num, + finish_rate, + create_time, + update_time +) +VALUES + ( + ${commId}, '${commName}', DATE_FORMAT(CURDATE(), '%Y-%m'), '${communityGrid}', ${gridId}, ${project_num_month}, ${finish_project_num_month}, IFNULL(${finish_project_num_month} / ${project_num_month}, 0), NOW(), null + ) + N + + + + + + + + + + + + + + + + 1023 + 633 + Y + + + + 网格注册信息表-月 + ExecSQL + + Y + + 1 + + none + + + target_yushan + N + N + Y + N + INSERT INTO ys_grid_reg ( + comm_id, + comm_name, + cal_date, + name, + grid_id, + reg_user_num, + reg_party_num, + reg_group_num, + create_time, + update_time +) +VALUES + ( + ${commId}, '${commName}', DATE_FORMAT(CURDATE(), '%Y-%m'), '${communityGrid}', ${gridId}, ${reg_user_num}, ${reg_party_num}, ${reg_group_num}, NOW(), null + ) + N + + + + + + + + + + + + + + + + 617 + 540 + Y + + + + + + + N + + diff --git a/epdc-cloud-property/doc/kettle/screen-yushan/screen_totality_grid_update_all_day.ktr b/epdc-cloud-property/doc/kettle/screen-yushan/screen_totality_grid_update_all_day.ktr new file mode 100644 index 0000000..df39f83 --- /dev/null +++ b/epdc-cloud-property/doc/kettle/screen-yushan/screen_totality_grid_update_all_day.ktr @@ -0,0 +1,628 @@ + + + + screen_totality_grid_update_all_day + + + + 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 + + + + + + + + + - + 2020/04/27 09:32:01.126 + - + 2020/04/27 09:32:01.126 + H4sIAAAAAAAAAAMAAAAAAAAAAAA= + N + + + + + target_yushan + ${db.mysql.epdc.target.ys.host} + MYSQL + Native + ${db.mysql.target.schema.yushandb} + ${db.mysql.epdc.target.ys.port} + ${db.mysql.epdc.target.ys.username} + ${db.mysql.epdc.target.ys.password} + + + + + + EXTRA_OPTION_MYSQL.allowMultiQueries + true + + + EXTRA_OPTION_MYSQL.characterEncoding + utf8 + + + EXTRA_OPTION_MYSQL.serverTimezone + Asia/Shanghai + + + 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.ys.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 + + + + + + + 网格治理排行表-月 + ExecSQL + + Y + + 1 + + none + + + target_yushan + N + N + Y + N + INSERT INTO ys_grid_gov_rank ( + comm_id, + comm_name, + cal_date, + grid_name, + grid_id, + project_num, + project_finish_num, + finish_rate, + create_time, + update_time +) +VALUES + ( + ${commId}, '${commName}', DATE_FORMAT(CURDATE(), '%Y-%m'), '${communityGrid}', ${gridId}, ${project_num_month}, ${finish_project_num_month}, IFNULL(${finish_project_num_month} / ${project_num_month}, 0), NOW(), null + ) + N + + + + + + + + + + + + + + + + 1023 + 633 + Y + + + + 网格注册信息表-月 + ExecSQL + + Y + + 1 + + none + + + target_yushan + N + N + Y + N + INSERT INTO ys_grid_reg ( + comm_id, + comm_name, + cal_date, + name, + grid_id, + reg_user_num, + reg_party_num, + reg_group_num, + create_time, + update_time +) +VALUES + ( + ${commId}, '${commName}', DATE_FORMAT(CURDATE(), '%Y-%m'), '${communityGrid}', ${gridId}, ${reg_user_num}, ${reg_party_num}, ${reg_group_num}, NOW(), null + ) + N + + + + + + + + + + + + + + + + 617 + 540 + Y + + + + + + + N + + diff --git a/epdc-cloud-property/doc/kettle/screen-yushan/screen_ys_grid_rank_month_update_day.ktr b/epdc-cloud-property/doc/kettle/screen-yushan/screen_ys_grid_rank_month_update_day.ktr index d597463..de047df 100644 --- a/epdc-cloud-property/doc/kettle/screen-yushan/screen_ys_grid_rank_month_update_day.ktr +++ b/epdc-cloud-property/doc/kettle/screen-yushan/screen_ys_grid_rank_month_update_day.ktr @@ -566,7 +566,7 @@ VALUES - 网格注册信息表-月 + 网格治理排行表-月 ExecSQL Y @@ -581,21 +581,21 @@ VALUES N Y N - INSERT INTO ys_grid_reg ( + INSERT INTO ys_grid_gov_rank ( comm_id, comm_name, cal_date, - name, + grid_name, grid_id, - reg_user_num, - reg_party_num, - reg_group_num, + project_num, + project_finish_num, + finish_rate, create_time, update_time ) VALUES ( - ${commId}, '${commName}', DATE_FORMAT(CURDATE(), '%Y-%m'), '${communityGrid}', ${gridId}, ${reg_user_num}, ${reg_party_num}, ${reg_group_num}, NOW(), null + ${commId}, '${commName}', DATE_FORMAT(CURDATE(), '%Y-%m'), '${communityGrid}', ${gridId}, ${project_num_month}, ${finish_project_num_month}, IFNULL(${finish_project_num_month} / ${project_num_month}, 0), NOW(), null ) N @@ -613,13 +613,13 @@ VALUES - 443 - 360 + 656 + 352 Y - 网格治理排行表-月 + 网格注册信息表-月 ExecSQL Y @@ -634,21 +634,21 @@ VALUES N Y N - INSERT INTO ys_grid_gov_rank ( + INSERT INTO ys_grid_reg ( comm_id, comm_name, cal_date, - grid_name, + name, grid_id, - project_num, - project_finish_num, - finish_rate, + reg_user_num, + reg_party_num, + reg_group_num, create_time, update_time ) VALUES ( - ${commId}, '${commName}', DATE_FORMAT(CURDATE(), '%Y-%m'), '${communityGrid}', ${gridId}, ${project_num_month}, ${finish_project_num_month}, IFNULL(${finish_project_num_month} / ${project_num_month}, 0), NOW(), null + ${commId}, '${commName}', DATE_FORMAT(CURDATE(), '%Y-%m'), '${communityGrid}', ${gridId}, ${reg_user_num}, ${reg_party_num}, ${reg_group_num}, NOW(), null ) N @@ -666,8 +666,8 @@ VALUES - 849 - 453 + 432 + 352 Y diff --git a/epdc-cloud-property/doc/kettle/screen-yushan/yushan_all.kjb b/epdc-cloud-property/doc/kettle/screen-yushan/yushan_all.kjb index 6f1983f..ac5552b 100644 --- a/epdc-cloud-property/doc/kettle/screen-yushan/yushan_all.kjb +++ b/epdc-cloud-property/doc/kettle/screen-yushan/yushan_all.kjb @@ -502,7 +502,7 @@ true; filename - ${Internal.Entry.Current.Directory}/yushan_grid_day.kjb + ${Internal.Entry.Current.Directory}/yushan_grid_all_day.kjb N @@ -1000,7 +1000,7 @@ true; 网格下标 0 0 - N + Y Y N diff --git a/epdc-cloud-property/doc/kettle/screen-yushan/yushan_comm_day_all.kjb b/epdc-cloud-property/doc/kettle/screen-yushan/yushan_comm_day_all.kjb index 1a0836f..7b9e607 100644 --- a/epdc-cloud-property/doc/kettle/screen-yushan/yushan_comm_day_all.kjb +++ b/epdc-cloud-property/doc/kettle/screen-yushan/yushan_comm_day_all.kjb @@ -552,7 +552,7 @@ true; 天数下标 0 0 - N + Y Y Y diff --git a/epdc-cloud-property/doc/kettle/screen-yushan/yushan_grid_all_day.kjb b/epdc-cloud-property/doc/kettle/screen-yushan/yushan_grid_all_day.kjb new file mode 100644 index 0000000..3058206 --- /dev/null +++ b/epdc-cloud-property/doc/kettle/screen-yushan/yushan_grid_all_day.kjb @@ -0,0 +1,662 @@ + + + yushan_grid_all_day + + + + 0 + / + - + 2020/04/23 21:11:25.317 + - + 2020/04/23 21:11:25.317 + + + + + + + +
+ + + + + ID_JOB + Y + ID_JOB + + + CHANNEL_ID + Y + CHANNEL_ID + + + JOBNAME + Y + JOBNAME + + + 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 + + + START_JOB_ENTRY + N + START_JOB_ENTRY + + + CLIENT + N + CLIENT + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + JOBNAME + Y + TRANSNAME + + + JOBENTRYNAME + Y + STEPNAME + + + 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 + + + RESULT + Y + RESULT + + + NR_RESULT_ROWS + Y + NR_RESULT_ROWS + + + NR_RESULT_FILES + Y + NR_RESULT_FILES + + + LOG_FIELD + N + LOG_FIELD + + + COPY_NR + N + COPY_NR + + + + + +
+ + + 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 + + + N + + + + Start + + SPECIAL + + Y + N + N + 0 + 0 + 60 + 12 + 0 + 1 + 1 + N + Y + 0 + 96 + 224 + + + + 天数下标 + + SET_VARIABLES + + Y + + CURRENT_JOB + + + dayIndex + 0 + CURRENT_JOB + + + days + 30 + CURRENT_JOB + + + N + Y + 0 + 368 + 368 + + + + if(dayIndex<days) + + SIMPLE_EVAL + + variable + + ${dayIndex} + number + + ${days} + + + equal + smaller + false + N + N + Y + 0 + 752 + 368 + + + + 网格操作 + + JOB + + filename + + ${Internal.Entry.Current.Directory}/yushan_grid_day_all_grid.kjb + + + N + N + N + N + + + N + N + Nothing + + Y + N + N + N + N + Pentaho local + + Y + + N + N + Y + 0 + 976 + 496 + + + + day下标加一，处理下个day + + EVAL + + + N + Y + 0 + 752 + 496 + + + + 成功 + + SUCCESS + + N + Y + 0 + 976 + 368 + + + + 月数下标 + + SET_VARIABLES + + Y + + CURRENT_JOB + + + monthIndex + 0 + CURRENT_JOB + + + months + 2 + CURRENT_JOB + + + N + Y + 0 + 368 + 80 + + + + if(monthIndex<months) 2 + + SIMPLE_EVAL + + variable + + ${monthIndex} + number + + ${months} + + + equal + smaller + false + N + N + Y + 0 + 752 + 80 + + + + 网格操作 2 + + JOB + + filename + + ${Internal.Entry.Current.Directory}/yushan_grid_month_all_grid.kjb + + + N + N + N + N + + + N + N + Nothing + + Y + N + N + N + N + Pentaho local + + Y + + N + N + Y + 0 + 976 + 208 + + + + month下标加一，处理下个month + + EVAL + + + N + Y + 0 + 752 + 208 + + + + 成功 2 + + SUCCESS + + N + Y + 0 + 976 + 80 + + + + + + Start + 天数下标 + 0 + 0 + N + Y + Y + + + 网格操作 + day下标加一，处理下个day + 0 + 0 + Y + Y + N + + + day下标加一，处理下个day + if(dayIndex<days) + 0 + 0 + Y + Y + N + + + 天数下标 + if(dayIndex<days) + 0 + 0 + Y + Y + N + + + if(dayIndex<days) + 网格操作 + 0 + 0 + Y + Y + N + + + if(dayIndex<days) + 成功 + 0 + 0 + Y + N + N + + + Start + 月数下标 + 0 + 0 + Y + Y + Y + + + 月数下标 + if(monthIndex<months) 2 + 0 + 0 + Y + Y + N + + + if(monthIndex<months) 2 + 网格操作 2 + 0 + 0 + Y + Y + N + + + 网格操作 2 + month下标加一，处理下个month + 0 + 0 + Y + Y + N + + + month下标加一，处理下个month + if(monthIndex<months) 2 + 0 + 0 + Y + Y + N + + + if(monthIndex<months) 2 + 成功 2 + 0 + 0 + Y + N + N + + + + + + diff --git a/epdc-cloud-property/doc/kettle/screen-yushan/yushan_grid_day_all_grid.kjb b/epdc-cloud-property/doc/kettle/screen-yushan/yushan_grid_day_all_grid.kjb new file mode 100644 index 0000000..5e09945 --- /dev/null +++ b/epdc-cloud-property/doc/kettle/screen-yushan/yushan_grid_day_all_grid.kjb @@ -0,0 +1,1164 @@ + + + yushan_grid_day_all_grid + + + + 0 + / + - + 2020/04/23 21:11:25.317 + - + 2020/04/23 21:11:25.317 + + + + + + + +
+ + + + + ID_JOB + Y + ID_JOB + + + CHANNEL_ID + Y + CHANNEL_ID + + + JOBNAME + Y + JOBNAME + + + 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 + + + START_JOB_ENTRY + N + START_JOB_ENTRY + + + CLIENT + N + CLIENT + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + JOBNAME + Y + TRANSNAME + + + JOBENTRYNAME + Y + STEPNAME + + + 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 + + + RESULT + Y + RESULT + + + NR_RESULT_ROWS + Y + NR_RESULT_ROWS + + + NR_RESULT_FILES + Y + NR_RESULT_FILES + + + LOG_FIELD + N + LOG_FIELD + + + COPY_NR + N + COPY_NR + + + + + +
+ + + 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 + + + N + + + + 网格ID,NAME + + TRANS + + filename + + ${Internal.Entry.Current.Directory}/screen_totality_grid_query_grid.ktr + + N + N + N + N + N + N + + + N + N + Basic + N + + N + Y + N + N + N + Pentaho local + + Y + + N + Y + 0 + 240 + 320 + + + + 获取网格信息变量 + + TRANS + + filename + + ${Internal.Entry.Current.Directory}/screen_totality_grid_query_all_day.ktr + + N + N + N + N + N + N + + + N + N + Basic + N + + N + Y + N + N + N + Pentaho local + + Y + + N + Y + 0 + 704 + 320 + + + + 写入网格数据表-清空月度数据 + + TRANS + + filename + + ${Internal.Entry.Current.Directory}/screen_totality_grid_update_all_day.ktr + + N + N + N + N + N + N + + + N + N + Basic + N + + N + Y + N + N + N + Pentaho local + + Y + + N + Y + 0 + 896 + 320 + + + + Start + + SPECIAL + + Y + N + N + 0 + 0 + 60 + 12 + 0 + 1 + 1 + N + Y + 0 + 112 + 320 + + + + 检验字段的值 + + SIMPLE_EVAL + + variable + + ${communityGrid} + string + + 第一网格 + + + contains + equal + false + N + N + Y + 0 + 384 + 128 + + + + 检验字段的值 2 + + SIMPLE_EVAL + + variable + + ${communityGrid} + string + + 第二网格 + + + contains + equal + false + N + N + Y + 0 + 384 + 208 + + + + 检验字段的值 3 + + SIMPLE_EVAL + + variable + + ${communityGrid} + string + + 第三网格 + + + contains + equal + false + N + N + Y + 0 + 384 + 288 + + + + 检验字段的值 4 + + SIMPLE_EVAL + + variable + + ${communityGrid} + string + + 第四网格 + + + contains + equal + false + N + N + Y + 0 + 384 + 368 + + + + 检验字段的值 5 + + SIMPLE_EVAL + + variable + + ${communityGrid} + string + + 第五网格 + + + contains + equal + false + N + N + Y + 0 + 384 + 448 + + + + 检验字段的值 6 + + SIMPLE_EVAL + + variable + + ${communityGrid} + string + + 第六网格 + + + contains + equal + false + N + N + Y + 0 + 384 + 528 + + + + 设置变量 + + SET_VARIABLES + + Y + + CURRENT_JOB + + + village_num + 1 + CURRENT_JOB + + + building_num + 8 + CURRENT_JOB + + + housemaster_num + 7 + CURRENT_JOB + + + focus_groups_num + -1 + CURRENT_JOB + + + party_num + 100 + CURRENT_JOB + + + gridmaster + 赵泽诗 + CURRENT_JOB + + + N + Y + 0 + 528 + 128 + + + + 设置变量 2 + + SET_VARIABLES + + Y + + CURRENT_JOB + + + village_num + 6 + CURRENT_JOB + + + building_num + 11 + CURRENT_JOB + + + housemaster_num + 8 + CURRENT_JOB + + + focus_groups_num + -1 + CURRENT_JOB + + + party_num + 113 + CURRENT_JOB + + + gridmaster + 刘东军 + CURRENT_JOB + + + N + Y + 0 + 528 + 208 + + + + 设置变量 3 + + SET_VARIABLES + + Y + + CURRENT_JOB + + + village_num + 2 + CURRENT_JOB + + + building_num + 8 + CURRENT_JOB + + + housemaster_num + 8 + CURRENT_JOB + + + focus_groups_num + -1 + CURRENT_JOB + + + party_num + 41 + CURRENT_JOB + + + gridmaster + 孔凡代 + CURRENT_JOB + + + N + Y + 0 + 528 + 288 + + + + 设置变量 4 + + SET_VARIABLES + + Y + + CURRENT_JOB + + + village_num + 1 + CURRENT_JOB + + + building_num + 10 + CURRENT_JOB + + + housemaster_num + 7 + CURRENT_JOB + + + focus_groups_num + -1 + CURRENT_JOB + + + party_num + 174 + CURRENT_JOB + + + gridmaster + 朱向阳 + CURRENT_JOB + + + N + Y + 0 + 528 + 368 + + + + 设置变量 5 + + SET_VARIABLES + + Y + + CURRENT_JOB + + + village_num + 0 + CURRENT_JOB + + + building_num + 0 + CURRENT_JOB + + + housemaster_num + 2 + CURRENT_JOB + + + focus_groups_num + -1 + CURRENT_JOB + + + party_num + 0 + CURRENT_JOB + + + gridmaster + 李玉锋 + CURRENT_JOB + + + N + Y + 0 + 528 + 448 + + + + 设置变量 6 + + SET_VARIABLES + + Y + + CURRENT_JOB + + + village_num + 1 + CURRENT_JOB + + + building_num + 16 + CURRENT_JOB + + + housemaster_num + 6 + CURRENT_JOB + + + focus_groups_num + -1 + CURRENT_JOB + + + party_num + 18 + CURRENT_JOB + + + gridmaster + 王坤 + CURRENT_JOB + + + N + Y + 0 + 528 + 528 + + + + 成功 + + SUCCESS + + N + Y + 0 + 464 + 80 + + + + 成功 2 + + SUCCESS + + N + Y + 0 + 464 + 160 + + + + 成功 3 + + SUCCESS + + N + Y + 0 + 464 + 240 + + + + 成功 4 + + SUCCESS + + N + Y + 0 + 464 + 320 + + + + 成功 5 + + SUCCESS + + N + Y + 0 + 464 + 400 + + + + 成功 6 + + SUCCESS + + N + Y + 0 + 464 + 480 + + + + + + 获取网格信息变量 + 写入网格数据表-清空月度数据 + 0 + 0 + Y + Y + N + + + Start + 网格ID,NAME + 0 + 0 + Y + Y + Y + + + 网格ID,NAME + 检验字段的值 2 + 0 + 0 + Y + Y + N + + + 网格ID,NAME + 检验字段的值 3 + 0 + 0 + Y + Y + N + + + 网格ID,NAME + 检验字段的值 4 + 0 + 0 + Y + Y + N + + + 网格ID,NAME + 检验字段的值 5 + 0 + 0 + Y + Y + N + + + 网格ID,NAME + 检验字段的值 6 + 0 + 0 + Y + Y + N + + + 检验字段的值 + 设置变量 + 0 + 0 + Y + Y + N + + + 设置变量 + 获取网格信息变量 + 0 + 0 + Y + Y + N + + + 检验字段的值 2 + 设置变量 2 + 0 + 0 + Y + Y + N + + + 检验字段的值 3 + 设置变量 3 + 0 + 0 + Y + Y + N + + + 检验字段的值 4 + 设置变量 4 + 0 + 0 + Y + Y + N + + + 检验字段的值 5 + 设置变量 5 + 0 + 0 + Y + Y + N + + + 检验字段的值 6 + 设置变量 6 + 0 + 0 + Y + Y + N + + + 设置变量 2 + 获取网格信息变量 + 0 + 0 + Y + Y + N + + + 设置变量 3 + 获取网格信息变量 + 0 + 0 + Y + Y + N + + + 设置变量 4 + 获取网格信息变量 + 0 + 0 + Y + Y + N + + + 设置变量 5 + 获取网格信息变量 + 0 + 0 + Y + Y + N + + + 设置变量 6 + 获取网格信息变量 + 0 + 0 + Y + Y + N + + + 检验字段的值 + 成功 + 0 + 0 + Y + N + N + + + 检验字段的值 2 + 成功 2 + 0 + 0 + Y + N + N + + + 检验字段的值 3 + 成功 3 + 0 + 0 + Y + N + N + + + 检验字段的值 4 + 成功 4 + 0 + 0 + Y + N + N + + + 检验字段的值 5 + 成功 5 + 0 + 0 + Y + N + N + + + 检验字段的值 6 + 成功 6 + 0 + 0 + Y + N + N + + + 网格ID,NAME + 检验字段的值 + 0 + 0 + Y + Y + N + + + + + + diff --git a/epdc-cloud-property/doc/kettle/screen-yushan/yushan_grid_month_all_grid.kjb b/epdc-cloud-property/doc/kettle/screen-yushan/yushan_grid_month_all_grid.kjb new file mode 100644 index 0000000..04f925f --- /dev/null +++ b/epdc-cloud-property/doc/kettle/screen-yushan/yushan_grid_month_all_grid.kjb @@ -0,0 +1,1164 @@ + + + yushan_grid_month_all_grid + + + + 0 + / + - + 2020/04/23 21:11:25.317 + - + 2020/04/23 21:11:25.317 + + + + + + + +
+ + + + + ID_JOB + Y + ID_JOB + + + CHANNEL_ID + Y + CHANNEL_ID + + + JOBNAME + Y + JOBNAME + + + 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 + + + START_JOB_ENTRY + N + START_JOB_ENTRY + + + CLIENT + N + CLIENT + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + JOBNAME + Y + TRANSNAME + + + JOBENTRYNAME + Y + STEPNAME + + + 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 + + + RESULT + Y + RESULT + + + NR_RESULT_ROWS + Y + NR_RESULT_ROWS + + + NR_RESULT_FILES + Y + NR_RESULT_FILES + + + LOG_FIELD + N + LOG_FIELD + + + COPY_NR + N + COPY_NR + + + + + +
+ + + 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 + + + N + + + + 网格ID,NAME + + TRANS + + filename + + ${Internal.Entry.Current.Directory}/screen_totality_grid_query_grid.ktr + + N + N + N + N + N + N + + + N + N + Basic + N + + N + Y + N + N + N + Pentaho local + + Y + + N + Y + 0 + 240 + 320 + + + + 获取网格信息变量 + + TRANS + + filename + + ${Internal.Entry.Current.Directory}/screen_totality_grid_query_all.ktr + + N + N + N + N + N + N + + + N + N + Basic + N + + N + Y + N + N + N + Pentaho local + + Y + + N + Y + 0 + 704 + 320 + + + + 写入网格数据表-清空月度数据 + + TRANS + + filename + + ${Internal.Entry.Current.Directory}/screen_totality_grid_update_all.ktr + + N + N + N + N + N + N + + + N + N + Basic + N + + N + Y + N + N + N + Pentaho local + + Y + + N + Y + 0 + 896 + 320 + + + + Start + + SPECIAL + + Y + N + N + 0 + 0 + 60 + 12 + 0 + 1 + 1 + N + Y + 0 + 112 + 320 + + + + 检验字段的值 + + SIMPLE_EVAL + + variable + + ${communityGrid} + string + + 第一网格 + + + contains + equal + false + N + N + Y + 0 + 384 + 128 + + + + 检验字段的值 2 + + SIMPLE_EVAL + + variable + + ${communityGrid} + string + + 第二网格 + + + contains + equal + false + N + N + Y + 0 + 384 + 208 + + + + 检验字段的值 3 + + SIMPLE_EVAL + + variable + + ${communityGrid} + string + + 第三网格 + + + contains + equal + false + N + N + Y + 0 + 384 + 288 + + + + 检验字段的值 4 + + SIMPLE_EVAL + + variable + + ${communityGrid} + string + + 第四网格 + + + contains + equal + false + N + N + Y + 0 + 384 + 368 + + + + 检验字段的值 5 + + SIMPLE_EVAL + + variable + + ${communityGrid} + string + + 第五网格 + + + contains + equal + false + N + N + Y + 0 + 384 + 448 + + + + 检验字段的值 6 + + SIMPLE_EVAL + + variable + + ${communityGrid} + string + + 第六网格 + + + contains + equal + false + N + N + Y + 0 + 384 + 528 + + + + 设置变量 + + SET_VARIABLES + + Y + + CURRENT_JOB + + + village_num + 1 + CURRENT_JOB + + + building_num + 8 + CURRENT_JOB + + + housemaster_num + 7 + CURRENT_JOB + + + focus_groups_num + -1 + CURRENT_JOB + + + party_num + 100 + CURRENT_JOB + + + gridmaster + 赵泽诗 + CURRENT_JOB + + + N + Y + 0 + 528 + 128 + + + + 设置变量 2 + + SET_VARIABLES + + Y + + CURRENT_JOB + + + village_num + 6 + CURRENT_JOB + + + building_num + 11 + CURRENT_JOB + + + housemaster_num + 8 + CURRENT_JOB + + + focus_groups_num + -1 + CURRENT_JOB + + + party_num + 113 + CURRENT_JOB + + + gridmaster + 刘东军 + CURRENT_JOB + + + N + Y + 0 + 528 + 208 + + + + 设置变量 3 + + SET_VARIABLES + + Y + + CURRENT_JOB + + + village_num + 2 + CURRENT_JOB + + + building_num + 8 + CURRENT_JOB + + + housemaster_num + 8 + CURRENT_JOB + + + focus_groups_num + -1 + CURRENT_JOB + + + party_num + 41 + CURRENT_JOB + + + gridmaster + 孔凡代 + CURRENT_JOB + + + N + Y + 0 + 528 + 288 + + + + 设置变量 4 + + SET_VARIABLES + + Y + + CURRENT_JOB + + + village_num + 1 + CURRENT_JOB + + + building_num + 10 + CURRENT_JOB + + + housemaster_num + 7 + CURRENT_JOB + + + focus_groups_num + -1 + CURRENT_JOB + + + party_num + 174 + CURRENT_JOB + + + gridmaster + 朱向阳 + CURRENT_JOB + + + N + Y + 0 + 528 + 368 + + + + 设置变量 5 + + SET_VARIABLES + + Y + + CURRENT_JOB + + + village_num + 0 + CURRENT_JOB + + + building_num + 0 + CURRENT_JOB + + + housemaster_num + 2 + CURRENT_JOB + + + focus_groups_num + -1 + CURRENT_JOB + + + party_num + 0 + CURRENT_JOB + + + gridmaster + 李玉锋 + CURRENT_JOB + + + N + Y + 0 + 528 + 448 + + + + 设置变量 6 + + SET_VARIABLES + + Y + + CURRENT_JOB + + + village_num + 1 + CURRENT_JOB + + + building_num + 16 + CURRENT_JOB + + + housemaster_num + 6 + CURRENT_JOB + + + focus_groups_num + -1 + CURRENT_JOB + + + party_num + 18 + CURRENT_JOB + + + gridmaster + 王坤 + CURRENT_JOB + + + N + Y + 0 + 528 + 528 + + + + 成功 + + SUCCESS + + N + Y + 0 + 464 + 80 + + + + 成功 2 + + SUCCESS + + N + Y + 0 + 464 + 160 + + + + 成功 3 + + SUCCESS + + N + Y + 0 + 464 + 240 + + + + 成功 4 + + SUCCESS + + N + Y + 0 + 464 + 320 + + + + 成功 5 + + SUCCESS + + N + Y + 0 + 464 + 400 + + + + 成功 6 + + SUCCESS + + N + Y + 0 + 464 + 480 + + + + + + 获取网格信息变量 + 写入网格数据表-清空月度数据 + 0 + 0 + Y + Y + N + + + Start + 网格ID,NAME + 0 + 0 + Y + Y + Y + + + 网格ID,NAME + 检验字段的值 2 + 0 + 0 + Y + Y + N + + + 网格ID,NAME + 检验字段的值 3 + 0 + 0 + Y + Y + N + + + 网格ID,NAME + 检验字段的值 4 + 0 + 0 + Y + Y + N + + + 网格ID,NAME + 检验字段的值 5 + 0 + 0 + Y + Y + N + + + 网格ID,NAME + 检验字段的值 6 + 0 + 0 + Y + Y + N + + + 检验字段的值 + 设置变量 + 0 + 0 + Y + Y + N + + + 设置变量 + 获取网格信息变量 + 0 + 0 + Y + Y + N + + + 检验字段的值 2 + 设置变量 2 + 0 + 0 + Y + Y + N + + + 检验字段的值 3 + 设置变量 3 + 0 + 0 + Y + Y + N + + + 检验字段的值 4 + 设置变量 4 + 0 + 0 + Y + Y + N + + + 检验字段的值 5 + 设置变量 5 + 0 + 0 + Y + Y + N + + + 检验字段的值 6 + 设置变量 6 + 0 + 0 + Y + Y + N + + + 设置变量 2 + 获取网格信息变量 + 0 + 0 + Y + Y + N + + + 设置变量 3 + 获取网格信息变量 + 0 + 0 + Y + Y + N + + + 设置变量 4 + 获取网格信息变量 + 0 + 0 + Y + Y + N + + + 设置变量 5 + 获取网格信息变量 + 0 + 0 + Y + Y + N + + + 设置变量 6 + 获取网格信息变量 + 0 + 0 + Y + Y + N + + + 检验字段的值 + 成功 + 0 + 0 + Y + N + N + + + 检验字段的值 2 + 成功 2 + 0 + 0 + Y + N + N + + + 检验字段的值 3 + 成功 3 + 0 + 0 + Y + N + N + + + 检验字段的值 4 + 成功 4 + 0 + 0 + Y + N + N + + + 检验字段的值 5 + 成功 5 + 0 + 0 + Y + N + N + + + 检验字段的值 6 + 成功 6 + 0 + 0 + Y + N + N + + + 网格ID,NAME + 检验字段的值 + 0 + 0 + Y + Y + N + + + + + + diff --git a/epdc-cloud-property/doc/kettle/screen-yushan/yushan_street_all_day.kjb b/epdc-cloud-property/doc/kettle/screen-yushan/yushan_street_all_day.kjb index 07ec2c2..3bf8736 100644 --- a/epdc-cloud-property/doc/kettle/screen-yushan/yushan_street_all_day.kjb +++ b/epdc-cloud-property/doc/kettle/screen-yushan/yushan_street_all_day.kjb @@ -552,7 +552,7 @@ true; 天数下标 0 0 - N + Y Y Y