elink-star
/
epdc-cloud-property-yushan
9
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity
Browse Source

KT 5.0

hotfix/yujt_opt
zhangyuan 5 years ago
parent
bb7928e0d2
commit
6c219d0fb6
12 changed files with 10296 additions and 36 deletions
Whitespace
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Unified View
Diff Options
Show Stats Download Patch File Download Diff File
  1. 2981
      epdc-cloud-property/doc/kettle/screen-yushan/screen_totality_grid_query_all.ktr
  2. 2981
      epdc-cloud-property/doc/kettle/screen-yushan/screen_totality_grid_query_all_day.ktr
  3. 28
      epdc-cloud-property/doc/kettle/screen-yushan/screen_totality_grid_update.ktr
  4. 680
      epdc-cloud-property/doc/kettle/screen-yushan/screen_totality_grid_update_all.ktr
  5. 628
      epdc-cloud-property/doc/kettle/screen-yushan/screen_totality_grid_update_all_day.ktr
  6. 36
      epdc-cloud-property/doc/kettle/screen-yushan/screen_ys_grid_rank_month_update_day.ktr
  7. 4
      epdc-cloud-property/doc/kettle/screen-yushan/yushan_all.kjb
  8. 2
      epdc-cloud-property/doc/kettle/screen-yushan/yushan_comm_day_all.kjb
  9. 662
      epdc-cloud-property/doc/kettle/screen-yushan/yushan_grid_all_day.kjb
  10. 1164
      epdc-cloud-property/doc/kettle/screen-yushan/yushan_grid_day_all_grid.kjb
  11. 1164
      epdc-cloud-property/doc/kettle/screen-yushan/yushan_grid_month_all_grid.kjb
  12. 2
      epdc-cloud-property/doc/kettle/screen-yushan/yushan_street_all_day.kjb

2981
epdc-cloud-property/doc/kettle/screen-yushan/screen_totality_grid_query_all.ktr
View File

File diff suppressed because it is too large

2981
epdc-cloud-property/doc/kettle/screen-yushan/screen_totality_grid_query_all_day.ktr
View File

File diff suppressed because it is too large

28
epdc-cloud-property/doc/kettle/screen-yushan/screen_totality_grid_update.ktr
View File

@ -551,7 +551,7 @@
) )
VALUES 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
)</sql> )</sql>
<set_params>N</set_params> <set_params>N</set_params>
<insert_field/> <insert_field/>
@ -575,7 +575,7 @@ VALUES
</GUI> </GUI>
</step> </step>
<step> <step>
<name>网格排名表月度数据清空</name> <name>清空网格治理排行表</name>
<type>ExecSQL</type> <type>ExecSQL</type>
<description/> <description/>
<distribute>Y</distribute> <distribute>Y</distribute>
@ -590,7 +590,7 @@ VALUES
<single_statement>N</single_statement> <single_statement>N</single_statement>
<replace_variables>Y</replace_variables> <replace_variables>Y</replace_variables>
<quoteString>N</quoteString> <quoteString>N</quoteString>
<sql>delete from ys_grid_rank where grid_id = ${gridId} and cal_date = date_format(now(), '%Y-%m')</sql> <sql>delete from ys_grid_gov_rank where grid_id = ${gridId} and cal_date = date_format(now(), '%Y-%m')</sql>
<set_params>N</set_params> <set_params>N</set_params>
<insert_field/> <insert_field/>
<update_field/> <update_field/>
@ -607,13 +607,13 @@ VALUES
</output> </output>
</remotesteps> </remotesteps>
<GUI> <GUI>
<xloc>448</xloc> <xloc>656</xloc>
<yloc>240</yloc> <yloc>368</yloc>
<draw>Y</draw> <draw>Y</draw>
</GUI> </GUI>
</step> </step>
<step> <step>
<name>网格治理排行表月度数据清空</name> <name>网格排名表月度数据清空</name>
<type>ExecSQL</type> <type>ExecSQL</type>
<description/> <description/>
<distribute>Y</distribute> <distribute>Y</distribute>
@ -628,7 +628,7 @@ VALUES
<single_statement>N</single_statement> <single_statement>N</single_statement>
<replace_variables>Y</replace_variables> <replace_variables>Y</replace_variables>
<quoteString>N</quoteString> <quoteString>N</quoteString>
<sql>delete from ys_grid_gov_rank where grid_id = ${gridId} and cal_date = date_format(now(), '%Y-%m')</sql> <sql>delete from ys_grid_rank where grid_id = ${gridId} and cal_date = date_format(now(), '%Y-%m')</sql>
<set_params>N</set_params> <set_params>N</set_params>
<insert_field/> <insert_field/>
<update_field/> <update_field/>
@ -646,12 +646,12 @@ VALUES
</remotesteps> </remotesteps>
<GUI> <GUI>
<xloc>448</xloc> <xloc>448</xloc>
<yloc>496</yloc> <yloc>240</yloc>
<draw>Y</draw> <draw>Y</draw>
</GUI> </GUI>
</step> </step>
<step> <step>
<name>网格注册数统计月度数据清空</name> <name>网格治理排行表月度数据清空</name>
<type>ExecSQL</type> <type>ExecSQL</type>
<description/> <description/>
<distribute>Y</distribute> <distribute>Y</distribute>
@ -666,7 +666,7 @@ VALUES
<single_statement>N</single_statement> <single_statement>N</single_statement>
<replace_variables>Y</replace_variables> <replace_variables>Y</replace_variables>
<quoteString>N</quoteString> <quoteString>N</quoteString>
<sql>delete from ys_grid_reg where grid_id = ${gridId} and cal_date = date_format(now(), '%Y-%m')</sql> <sql>delete from ys_grid_gov_rank where grid_id = ${gridId} and cal_date = date_format(now(), '%Y-%m')</sql>
<set_params>N</set_params> <set_params>N</set_params>
<insert_field/> <insert_field/>
<update_field/> <update_field/>
@ -684,12 +684,12 @@ VALUES
</remotesteps> </remotesteps>
<GUI> <GUI>
<xloc>448</xloc> <xloc>448</xloc>
<yloc>368</yloc> <yloc>496</yloc>
<draw>Y</draw> <draw>Y</draw>
</GUI> </GUI>
</step> </step>
<step> <step>
<name>清空网格治理排行表</name> <name>网格注册数统计月度数据清空</name>
<type>ExecSQL</type> <type>ExecSQL</type>
<description/> <description/>
<distribute>Y</distribute> <distribute>Y</distribute>
@ -704,7 +704,7 @@ VALUES
<single_statement>N</single_statement> <single_statement>N</single_statement>
<replace_variables>Y</replace_variables> <replace_variables>Y</replace_variables>
<quoteString>N</quoteString> <quoteString>N</quoteString>
<sql>delete from ys_grid_gov_rank where grid_id = ${gridId} and cal_date = date_format(now(), '%Y-%m')</sql> <sql>delete from ys_grid_reg where grid_id = ${gridId} and cal_date = date_format(now(), '%Y-%m')</sql>
<set_params>N</set_params> <set_params>N</set_params>
<insert_field/> <insert_field/>
<update_field/> <update_field/>
@ -721,7 +721,7 @@ VALUES
</output> </output>
</remotesteps> </remotesteps>
<GUI> <GUI>
<xloc>656</xloc> <xloc>448</xloc>
<yloc>368</yloc> <yloc>368</yloc>
<draw>Y</draw> <draw>Y</draw>
</GUI> </GUI>

680
epdc-cloud-property/doc/kettle/screen-yushan/screen_totality_grid_update_all.ktr
View File

@ -0,0 +1,680 @@
<?xml version="1.0" encoding="UTF-8"?>
<transformation>
<info>
<name>screen_totality_grid_update_all</name>
<description/>
<extended_description/>
<trans_version/>
<trans_type>Normal</trans_type>
<trans_status>0</trans_status>
<directory>/</directory>
<parameters>
</parameters>
<log>
<trans-log-table>
<connection/>
<schema/>
<table/>
<size_limit_lines/>
<interval/>
<timeout_days/>
<field>
<id>ID_BATCH</id>
<enabled>Y</enabled>
<name>ID_BATCH</name>
</field>
<field>
<id>CHANNEL_ID</id>
<enabled>Y</enabled>
<name>CHANNEL_ID</name>
</field>
<field>
<id>TRANSNAME</id>
<enabled>Y</enabled>
<name>TRANSNAME</name>
</field>
<field>
<id>STATUS</id>
<enabled>Y</enabled>
<name>STATUS</name>
</field>
<field>
<id>LINES_READ</id>
<enabled>Y</enabled>
<name>LINES_READ</name>
<subject/>
</field>
<field>
<id>LINES_WRITTEN</id>
<enabled>Y</enabled>
<name>LINES_WRITTEN</name>
<subject/>
</field>
<field>
<id>LINES_UPDATED</id>
<enabled>Y</enabled>
<name>LINES_UPDATED</name>
<subject/>
</field>
<field>
<id>LINES_INPUT</id>
<enabled>Y</enabled>
<name>LINES_INPUT</name>
<subject/>
</field>
<field>
<id>LINES_OUTPUT</id>
<enabled>Y</enabled>
<name>LINES_OUTPUT</name>
<subject/>
</field>
<field>
<id>LINES_REJECTED</id>
<enabled>Y</enabled>
<name>LINES_REJECTED</name>
<subject/>
</field>
<field>
<id>ERRORS</id>
<enabled>Y</enabled>
<name>ERRORS</name>
</field>
<field>
<id>STARTDATE</id>
<enabled>Y</enabled>
<name>STARTDATE</name>
</field>
<field>
<id>ENDDATE</id>
<enabled>Y</enabled>
<name>ENDDATE</name>
</field>
<field>
<id>LOGDATE</id>
<enabled>Y</enabled>
<name>LOGDATE</name>
</field>
<field>
<id>DEPDATE</id>
<enabled>Y</enabled>
<name>DEPDATE</name>
</field>
<field>
<id>REPLAYDATE</id>
<enabled>Y</enabled>
<name>REPLAYDATE</name>
</field>
<field>
<id>LOG_FIELD</id>
<enabled>Y</enabled>
<name>LOG_FIELD</name>
</field>
<field>
<id>EXECUTING_SERVER</id>
<enabled>N</enabled>
<name>EXECUTING_SERVER</name>
</field>
<field>
<id>EXECUTING_USER</id>
<enabled>N</enabled>
<name>EXECUTING_USER</name>
</field>
<field>
<id>CLIENT</id>
<enabled>N</enabled>
<name>CLIENT</name>
</field>
</trans-log-table>
<perf-log-table>
<connection/>
<schema/>
<table/>
<interval/>
<timeout_days/>
<field>
<id>ID_BATCH</id>
<enabled>Y</enabled>
<name>ID_BATCH</name>
</field>
<field>
<id>SEQ_NR</id>
<enabled>Y</enabled>
<name>SEQ_NR</name>
</field>
<field>
<id>LOGDATE</id>
<enabled>Y</enabled>
<name>LOGDATE</name>
</field>
<field>
<id>TRANSNAME</id>
<enabled>Y</enabled>
<name>TRANSNAME</name>
</field>
<field>
<id>STEPNAME</id>
<enabled>Y</enabled>
<name>STEPNAME</name>
</field>
<field>
<id>STEP_COPY</id>
<enabled>Y</enabled>
<name>STEP_COPY</name>
</field>
<field>
<id>LINES_READ</id>
<enabled>Y</enabled>
<name>LINES_READ</name>
</field>
<field>
<id>LINES_WRITTEN</id>
<enabled>Y</enabled>
<name>LINES_WRITTEN</name>
</field>
<field>
<id>LINES_UPDATED</id>
<enabled>Y</enabled>
<name>LINES_UPDATED</name>
</field>
<field>
<id>LINES_INPUT</id>
<enabled>Y</enabled>
<name>LINES_INPUT</name>
</field>
<field>
<id>LINES_OUTPUT</id>
<enabled>Y</enabled>
<name>LINES_OUTPUT</name>
</field>
<field>
<id>LINES_REJECTED</id>
<enabled>Y</enabled>
<name>LINES_REJECTED</name>
</field>
<field>
<id>ERRORS</id>
<enabled>Y</enabled>
<name>ERRORS</name>
</field>
<field>
<id>INPUT_BUFFER_ROWS</id>
<enabled>Y</enabled>
<name>INPUT_BUFFER_ROWS</name>
</field>
<field>
<id>OUTPUT_BUFFER_ROWS</id>
<enabled>Y</enabled>
<name>OUTPUT_BUFFER_ROWS</name>
</field>
</perf-log-table>
<channel-log-table>
<connection/>
<schema/>
<table/>
<timeout_days/>
<field>
<id>ID_BATCH</id>
<enabled>Y</enabled>
<name>ID_BATCH</name>
</field>
<field>
<id>CHANNEL_ID</id>
<enabled>Y</enabled>
<name>CHANNEL_ID</name>
</field>
<field>
<id>LOG_DATE</id>
<enabled>Y</enabled>
<name>LOG_DATE</name>
</field>
<field>
<id>LOGGING_OBJECT_TYPE</id>
<enabled>Y</enabled>
<name>LOGGING_OBJECT_TYPE</name>
</field>
<field>
<id>OBJECT_NAME</id>
<enabled>Y</enabled>
<name>OBJECT_NAME</name>
</field>
<field>
<id>OBJECT_COPY</id>
<enabled>Y</enabled>
<name>OBJECT_COPY</name>
</field>
<field>
<id>REPOSITORY_DIRECTORY</id>
<enabled>Y</enabled>
<name>REPOSITORY_DIRECTORY</name>
</field>
<field>
<id>FILENAME</id>
<enabled>Y</enabled>
<name>FILENAME</name>
</field>
<field>
<id>OBJECT_ID</id>
<enabled>Y</enabled>
<name>OBJECT_ID</name>
</field>
<field>
<id>OBJECT_REVISION</id>
<enabled>Y</enabled>
<name>OBJECT_REVISION</name>
</field>
<field>
<id>PARENT_CHANNEL_ID</id>
<enabled>Y</enabled>
<name>PARENT_CHANNEL_ID</name>
</field>
<field>
<id>ROOT_CHANNEL_ID</id>
<enabled>Y</enabled>
<name>ROOT_CHANNEL_ID</name>
</field>
</channel-log-table>
<step-log-table>
<connection/>
<schema/>
<table/>
<timeout_days/>
<field>
<id>ID_BATCH</id>
<enabled>Y</enabled>
<name>ID_BATCH</name>
</field>
<field>
<id>CHANNEL_ID</id>
<enabled>Y</enabled>
<name>CHANNEL_ID</name>
</field>
<field>
<id>LOG_DATE</id>
<enabled>Y</enabled>
<name>LOG_DATE</name>
</field>
<field>
<id>TRANSNAME</id>
<enabled>Y</enabled>
<name>TRANSNAME</name>
</field>
<field>
<id>STEPNAME</id>
<enabled>Y</enabled>
<name>STEPNAME</name>
</field>
<field>
<id>STEP_COPY</id>
<enabled>Y</enabled>
<name>STEP_COPY</name>
</field>
<field>
<id>LINES_READ</id>
<enabled>Y</enabled>
<name>LINES_READ</name>
</field>
<field>
<id>LINES_WRITTEN</id>
<enabled>Y</enabled>
<name>LINES_WRITTEN</name>
</field>
<field>
<id>LINES_UPDATED</id>
<enabled>Y</enabled>
<name>LINES_UPDATED</name>
</field>
<field>
<id>LINES_INPUT</id>
<enabled>Y</enabled>
<name>LINES_INPUT</name>
</field>
<field>
<id>LINES_OUTPUT</id>
<enabled>Y</enabled>
<name>LINES_OUTPUT</name>
</field>
<field>
<id>LINES_REJECTED</id>
<enabled>Y</enabled>
<name>LINES_REJECTED</name>
</field>
<field>
<id>ERRORS</id>
<enabled>Y</enabled>
<name>ERRORS</name>
</field>
<field>
<id>LOG_FIELD</id>
<enabled>N</enabled>
<name>LOG_FIELD</name>
</field>
</step-log-table>
<metrics-log-table>
<connection/>
<schema/>
<table/>
<timeout_days/>
<field>
<id>ID_BATCH</id>
<enabled>Y</enabled>
<name>ID_BATCH</name>
</field>
<field>
<id>CHANNEL_ID</id>
<enabled>Y</enabled>
<name>CHANNEL_ID</name>
</field>
<field>
<id>LOG_DATE</id>
<enabled>Y</enabled>
<name>LOG_DATE</name>
</field>
<field>
<id>METRICS_DATE</id>
<enabled>Y</enabled>
<name>METRICS_DATE</name>
</field>
<field>
<id>METRICS_CODE</id>
<enabled>Y</enabled>
<name>METRICS_CODE</name>
</field>
<field>
<id>METRICS_DESCRIPTION</id>
<enabled>Y</enabled>
<name>METRICS_DESCRIPTION</name>
</field>
<field>
<id>METRICS_SUBJECT</id>
<enabled>Y</enabled>
<name>METRICS_SUBJECT</name>
</field>
<field>
<id>METRICS_TYPE</id>
<enabled>Y</enabled>
<name>METRICS_TYPE</name>
</field>
<field>
<id>METRICS_VALUE</id>
<enabled>Y</enabled>
<name>METRICS_VALUE</name>
</field>
</metrics-log-table>
</log>
<maxdate>
<connection/>
<table/>
<field/>
<offset>0.0</offset>
<maxdiff>0.0</maxdiff>
</maxdate>
<size_rowset>10000</size_rowset>
<sleep_time_empty>50</sleep_time_empty>
<sleep_time_full>50</sleep_time_full>
<unique_connections>N</unique_connections>
<feedback_shown>Y</feedback_shown>
<feedback_size>50000</feedback_size>
<using_thread_priorities>Y</using_thread_priorities>
<shared_objects_file/>
<capture_step_performance>N</capture_step_performance>
<step_performance_capturing_delay>1000</step_performance_capturing_delay>
<step_performance_capturing_size_limit>100</step_performance_capturing_size_limit>
<dependencies>
</dependencies>
<partitionschemas>
</partitionschemas>
<slaveservers>
</slaveservers>
<clusterschemas>
</clusterschemas>
<created_user>-</created_user>
<created_date>2020/04/27 09:32:01.126</created_date>
<modified_user>-</modified_user>
<modified_date>2020/04/27 09:32:01.126</modified_date>
<key_for_session_key>H4sIAAAAAAAAAAMAAAAAAAAAAAA=</key_for_session_key>
<is_key_private>N</is_key_private>
</info>
<notepads>
</notepads>
<connection>
<name>target_yushan</name>
<server>${db.mysql.epdc.target.ys.host}</server>
<type>MYSQL</type>
<access>Native</access>
<database>${db.mysql.target.schema.yushandb}</database>
<port>${db.mysql.epdc.target.ys.port}</port>
<username>${db.mysql.epdc.target.ys.username}</username>
<password>${db.mysql.epdc.target.ys.password}</password>
<servername/>
<data_tablespace/>
<index_tablespace/>
<attributes>
<attribute>
<code>EXTRA_OPTION_MYSQL.allowMultiQueries</code>
<attribute>true</attribute>
</attribute>
<attribute>
<code>EXTRA_OPTION_MYSQL.characterEncoding</code>
<attribute>utf8</attribute>
</attribute>
<attribute>
<code>EXTRA_OPTION_MYSQL.serverTimezone</code>
<attribute>Asia/Shanghai</attribute>
</attribute>
<attribute>
<code>EXTRA_OPTION_MYSQL.useSSL</code>
<attribute>false</attribute>
</attribute>
<attribute>
<code>EXTRA_OPTION_MYSQL.useUnicode</code>
<attribute>true</attribute>
</attribute>
<attribute>
<code>FORCE_IDENTIFIERS_TO_LOWERCASE</code>
<attribute>N</attribute>
</attribute>
<attribute>
<code>FORCE_IDENTIFIERS_TO_UPPERCASE</code>
<attribute>N</attribute>
</attribute>
<attribute>
<code>IS_CLUSTERED</code>
<attribute>N</attribute>
</attribute>
<attribute>
<code>PORT_NUMBER</code>
<attribute>${db.mysql.epdc.target.ys.port}</attribute>
</attribute>
<attribute>
<code>PRESERVE_RESERVED_WORD_CASE</code>
<attribute>Y</attribute>
</attribute>
<attribute>
<code>QUOTE_ALL_FIELDS</code>
<attribute>N</attribute>
</attribute>
<attribute>
<code>STREAM_RESULTS</code>
<attribute>Y</attribute>
</attribute>
<attribute>
<code>SUPPORTS_BOOLEAN_DATA_TYPE</code>
<attribute>Y</attribute>
</attribute>
<attribute>
<code>SUPPORTS_TIMESTAMP_DATA_TYPE</code>
<attribute>Y</attribute>
</attribute>
<attribute>
<code>USE_POOLING</code>
<attribute>N</attribute>
</attribute>
</attributes>
</connection>
<order>
</order>
<step>
<name>网格排名表</name>
<type>ExecSQL</type>
<description/>
<distribute>Y</distribute>
<custom_distribution/>
<copies>1</copies>
<partitioning>
<method>none</method>
<schema_name/>
</partitioning>
<connection>target_yushan</connection>
<execute_each_row>N</execute_each_row>
<single_statement>N</single_statement>
<replace_variables>Y</replace_variables>
<quoteString>N</quoteString>
<sql>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
)</sql>
<set_params>N</set_params>
<insert_field/>
<update_field/>
<delete_field/>
<read_field/>
<arguments>
</arguments>
<attributes/>
<cluster_schema/>
<remotesteps>
<input>
</input>
<output>
</output>
</remotesteps>
<GUI>
<xloc>717</xloc>
<yloc>373</yloc>
<draw>Y</draw>
</GUI>
</step>
<step>
<name>网格治理排行表-月</name>
<type>ExecSQL</type>
<description/>
<distribute>Y</distribute>
<custom_distribution/>
<copies>1</copies>
<partitioning>
<method>none</method>
<schema_name/>
</partitioning>
<connection>target_yushan</connection>
<execute_each_row>N</execute_each_row>
<single_statement>N</single_statement>
<replace_variables>Y</replace_variables>
<quoteString>N</quoteString>
<sql>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
)</sql>
<set_params>N</set_params>
<insert_field/>
<update_field/>
<delete_field/>
<read_field/>
<arguments>
</arguments>
<attributes/>
<cluster_schema/>
<remotesteps>
<input>
</input>
<output>
</output>
</remotesteps>
<GUI>
<xloc>1023</xloc>
<yloc>633</yloc>
<draw>Y</draw>
</GUI>
</step>
<step>
<name>网格注册信息表-月</name>
<type>ExecSQL</type>
<description/>
<distribute>Y</distribute>
<custom_distribution/>
<copies>1</copies>
<partitioning>
<method>none</method>
<schema_name/>
</partitioning>
<connection>target_yushan</connection>
<execute_each_row>N</execute_each_row>
<single_statement>N</single_statement>
<replace_variables>Y</replace_variables>
<quoteString>N</quoteString>
<sql>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
)</sql>
<set_params>N</set_params>
<insert_field/>
<update_field/>
<delete_field/>
<read_field/>
<arguments>
</arguments>
<attributes/>
<cluster_schema/>
<remotesteps>
<input>
</input>
<output>
</output>
</remotesteps>
<GUI>
<xloc>617</xloc>
<yloc>540</yloc>
<draw>Y</draw>
</GUI>
</step>
<step_error_handling>
</step_error_handling>
<slave-step-copy-partition-distribution>
</slave-step-copy-partition-distribution>
<slave_transformation>N</slave_transformation>
<attributes/>
</transformation>

628
epdc-cloud-property/doc/kettle/screen-yushan/screen_totality_grid_update_all_day.ktr
View File

@ -0,0 +1,628 @@
<?xml version="1.0" encoding="UTF-8"?>
<transformation>
<info>
<name>screen_totality_grid_update_all_day</name>
<description/>
<extended_description/>
<trans_version/>
<trans_type>Normal</trans_type>
<trans_status>0</trans_status>
<directory>/</directory>
<parameters>
</parameters>
<log>
<trans-log-table>
<connection/>
<schema/>
<table/>
<size_limit_lines/>
<interval/>
<timeout_days/>
<field>
<id>ID_BATCH</id>
<enabled>Y</enabled>
<name>ID_BATCH</name>
</field>
<field>
<id>CHANNEL_ID</id>
<enabled>Y</enabled>
<name>CHANNEL_ID</name>
</field>
<field>
<id>TRANSNAME</id>
<enabled>Y</enabled>
<name>TRANSNAME</name>
</field>
<field>
<id>STATUS</id>
<enabled>Y</enabled>
<name>STATUS</name>
</field>
<field>
<id>LINES_READ</id>
<enabled>Y</enabled>
<name>LINES_READ</name>
<subject/>
</field>
<field>
<id>LINES_WRITTEN</id>
<enabled>Y</enabled>
<name>LINES_WRITTEN</name>
<subject/>
</field>
<field>
<id>LINES_UPDATED</id>
<enabled>Y</enabled>
<name>LINES_UPDATED</name>
<subject/>
</field>
<field>
<id>LINES_INPUT</id>
<enabled>Y</enabled>
<name>LINES_INPUT</name>
<subject/>
</field>
<field>
<id>LINES_OUTPUT</id>
<enabled>Y</enabled>
<name>LINES_OUTPUT</name>
<subject/>
</field>
<field>
<id>LINES_REJECTED</id>
<enabled>Y</enabled>
<name>LINES_REJECTED</name>
<subject/>
</field>
<field>
<id>ERRORS</id>
<enabled>Y</enabled>
<name>ERRORS</name>
</field>
<field>
<id>STARTDATE</id>
<enabled>Y</enabled>
<name>STARTDATE</name>
</field>
<field>
<id>ENDDATE</id>
<enabled>Y</enabled>
<name>ENDDATE</name>
</field>
<field>
<id>LOGDATE</id>
<enabled>Y</enabled>
<name>LOGDATE</name>
</field>
<field>
<id>DEPDATE</id>
<enabled>Y</enabled>
<name>DEPDATE</name>
</field>
<field>
<id>REPLAYDATE</id>
<enabled>Y</enabled>
<name>REPLAYDATE</name>
</field>
<field>
<id>LOG_FIELD</id>
<enabled>Y</enabled>
<name>LOG_FIELD</name>
</field>
<field>
<id>EXECUTING_SERVER</id>
<enabled>N</enabled>
<name>EXECUTING_SERVER</name>
</field>
<field>
<id>EXECUTING_USER</id>
<enabled>N</enabled>
<name>EXECUTING_USER</name>
</field>
<field>
<id>CLIENT</id>
<enabled>N</enabled>
<name>CLIENT</name>
</field>
</trans-log-table>
<perf-log-table>
<connection/>
<schema/>
<table/>
<interval/>
<timeout_days/>
<field>
<id>ID_BATCH</id>
<enabled>Y</enabled>
<name>ID_BATCH</name>
</field>
<field>
<id>SEQ_NR</id>
<enabled>Y</enabled>
<name>SEQ_NR</name>
</field>
<field>
<id>LOGDATE</id>
<enabled>Y</enabled>
<name>LOGDATE</name>
</field>
<field>
<id>TRANSNAME</id>
<enabled>Y</enabled>
<name>TRANSNAME</name>
</field>
<field>
<id>STEPNAME</id>
<enabled>Y</enabled>
<name>STEPNAME</name>
</field>
<field>
<id>STEP_COPY</id>
<enabled>Y</enabled>
<name>STEP_COPY</name>
</field>
<field>
<id>LINES_READ</id>
<enabled>Y</enabled>
<name>LINES_READ</name>
</field>
<field>
<id>LINES_WRITTEN</id>
<enabled>Y</enabled>
<name>LINES_WRITTEN</name>
</field>
<field>
<id>LINES_UPDATED</id>
<enabled>Y</enabled>
<name>LINES_UPDATED</name>
</field>
<field>
<id>LINES_INPUT</id>
<enabled>Y</enabled>
<name>LINES_INPUT</name>
</field>
<field>
<id>LINES_OUTPUT</id>
<enabled>Y</enabled>
<name>LINES_OUTPUT</name>
</field>
<field>
<id>LINES_REJECTED</id>
<enabled>Y</enabled>
<name>LINES_REJECTED</name>
</field>
<field>
<id>ERRORS</id>
<enabled>Y</enabled>
<name>ERRORS</name>
</field>
<field>
<id>INPUT_BUFFER_ROWS</id>
<enabled>Y</enabled>
<name>INPUT_BUFFER_ROWS</name>
</field>
<field>
<id>OUTPUT_BUFFER_ROWS</id>
<enabled>Y</enabled>
<name>OUTPUT_BUFFER_ROWS</name>
</field>
</perf-log-table>
<channel-log-table>
<connection/>
<schema/>
<table/>
<timeout_days/>
<field>
<id>ID_BATCH</id>
<enabled>Y</enabled>
<name>ID_BATCH</name>
</field>
<field>
<id>CHANNEL_ID</id>
<enabled>Y</enabled>
<name>CHANNEL_ID</name>
</field>
<field>
<id>LOG_DATE</id>
<enabled>Y</enabled>
<name>LOG_DATE</name>
</field>
<field>
<id>LOGGING_OBJECT_TYPE</id>
<enabled>Y</enabled>
<name>LOGGING_OBJECT_TYPE</name>
</field>
<field>
<id>OBJECT_NAME</id>
<enabled>Y</enabled>
<name>OBJECT_NAME</name>
</field>
<field>
<id>OBJECT_COPY</id>
<enabled>Y</enabled>
<name>OBJECT_COPY</name>
</field>
<field>
<id>REPOSITORY_DIRECTORY</id>
<enabled>Y</enabled>
<name>REPOSITORY_DIRECTORY</name>
</field>
<field>
<id>FILENAME</id>
<enabled>Y</enabled>
<name>FILENAME</name>
</field>
<field>
<id>OBJECT_ID</id>
<enabled>Y</enabled>
<name>OBJECT_ID</name>
</field>
<field>
<id>OBJECT_REVISION</id>
<enabled>Y</enabled>
<name>OBJECT_REVISION</name>
</field>
<field>
<id>PARENT_CHANNEL_ID</id>
<enabled>Y</enabled>
<name>PARENT_CHANNEL_ID</name>
</field>
<field>
<id>ROOT_CHANNEL_ID</id>
<enabled>Y</enabled>
<name>ROOT_CHANNEL_ID</name>
</field>
</channel-log-table>
<step-log-table>
<connection/>
<schema/>
<table/>
<timeout_days/>
<field>
<id>ID_BATCH</id>
<enabled>Y</enabled>
<name>ID_BATCH</name>
</field>
<field>
<id>CHANNEL_ID</id>
<enabled>Y</enabled>
<name>CHANNEL_ID</name>
</field>
<field>
<id>LOG_DATE</id>
<enabled>Y</enabled>
<name>LOG_DATE</name>
</field>
<field>
<id>TRANSNAME</id>
<enabled>Y</enabled>
<name>TRANSNAME</name>
</field>
<field>
<id>STEPNAME</id>
<enabled>Y</enabled>
<name>STEPNAME</name>
</field>
<field>
<id>STEP_COPY</id>
<enabled>Y</enabled>
<name>STEP_COPY</name>
</field>
<field>
<id>LINES_READ</id>
<enabled>Y</enabled>
<name>LINES_READ</name>
</field>
<field>
<id>LINES_WRITTEN</id>
<enabled>Y</enabled>
<name>LINES_WRITTEN</name>
</field>
<field>
<id>LINES_UPDATED</id>
<enabled>Y</enabled>
<name>LINES_UPDATED</name>
</field>
<field>
<id>LINES_INPUT</id>
<enabled>Y</enabled>
<name>LINES_INPUT</name>
</field>
<field>
<id>LINES_OUTPUT</id>
<enabled>Y</enabled>
<name>LINES_OUTPUT</name>
</field>
<field>
<id>LINES_REJECTED</id>
<enabled>Y</enabled>
<name>LINES_REJECTED</name>
</field>
<field>
<id>ERRORS</id>
<enabled>Y</enabled>
<name>ERRORS</name>
</field>
<field>
<id>LOG_FIELD</id>
<enabled>N</enabled>
<name>LOG_FIELD</name>
</field>
</step-log-table>
<metrics-log-table>
<connection/>
<schema/>
<table/>
<timeout_days/>
<field>
<id>ID_BATCH</id>
<enabled>Y</enabled>
<name>ID_BATCH</name>
</field>
<field>
<id>CHANNEL_ID</id>
<enabled>Y</enabled>
<name>CHANNEL_ID</name>
</field>
<field>
<id>LOG_DATE</id>
<enabled>Y</enabled>
<name>LOG_DATE</name>
</field>
<field>
<id>METRICS_DATE</id>
<enabled>Y</enabled>
<name>METRICS_DATE</name>
</field>
<field>
<id>METRICS_CODE</id>
<enabled>Y</enabled>
<name>METRICS_CODE</name>
</field>
<field>
<id>METRICS_DESCRIPTION</id>
<enabled>Y</enabled>
<name>METRICS_DESCRIPTION</name>
</field>
<field>
<id>METRICS_SUBJECT</id>
<enabled>Y</enabled>
<name>METRICS_SUBJECT</name>
</field>
<field>
<id>METRICS_TYPE</id>
<enabled>Y</enabled>
<name>METRICS_TYPE</name>
</field>
<field>
<id>METRICS_VALUE</id>
<enabled>Y</enabled>
<name>METRICS_VALUE</name>
</field>
</metrics-log-table>
</log>
<maxdate>
<connection/>
<table/>
<field/>
<offset>0.0</offset>
<maxdiff>0.0</maxdiff>
</maxdate>
<size_rowset>10000</size_rowset>
<sleep_time_empty>50</sleep_time_empty>
<sleep_time_full>50</sleep_time_full>
<unique_connections>N</unique_connections>
<feedback_shown>Y</feedback_shown>
<feedback_size>50000</feedback_size>
<using_thread_priorities>Y</using_thread_priorities>
<shared_objects_file/>
<capture_step_performance>N</capture_step_performance>
<step_performance_capturing_delay>1000</step_performance_capturing_delay>
<step_performance_capturing_size_limit>100</step_performance_capturing_size_limit>
<dependencies>
</dependencies>
<partitionschemas>
</partitionschemas>
<slaveservers>
</slaveservers>
<clusterschemas>
</clusterschemas>
<created_user>-</created_user>
<created_date>2020/04/27 09:32:01.126</created_date>
<modified_user>-</modified_user>
<modified_date>2020/04/27 09:32:01.126</modified_date>
<key_for_session_key>H4sIAAAAAAAAAAMAAAAAAAAAAAA=</key_for_session_key>
<is_key_private>N</is_key_private>
</info>
<notepads>
</notepads>
<connection>
<name>target_yushan</name>
<server>${db.mysql.epdc.target.ys.host}</server>
<type>MYSQL</type>
<access>Native</access>
<database>${db.mysql.target.schema.yushandb}</database>
<port>${db.mysql.epdc.target.ys.port}</port>
<username>${db.mysql.epdc.target.ys.username}</username>
<password>${db.mysql.epdc.target.ys.password}</password>
<servername/>
<data_tablespace/>
<index_tablespace/>
<attributes>
<attribute>
<code>EXTRA_OPTION_MYSQL.allowMultiQueries</code>
<attribute>true</attribute>
</attribute>
<attribute>
<code>EXTRA_OPTION_MYSQL.characterEncoding</code>
<attribute>utf8</attribute>
</attribute>
<attribute>
<code>EXTRA_OPTION_MYSQL.serverTimezone</code>
<attribute>Asia/Shanghai</attribute>
</attribute>
<attribute>
<code>EXTRA_OPTION_MYSQL.useSSL</code>
<attribute>false</attribute>
</attribute>
<attribute>
<code>EXTRA_OPTION_MYSQL.useUnicode</code>
<attribute>true</attribute>
</attribute>
<attribute>
<code>FORCE_IDENTIFIERS_TO_LOWERCASE</code>
<attribute>N</attribute>
</attribute>
<attribute>
<code>FORCE_IDENTIFIERS_TO_UPPERCASE</code>
<attribute>N</attribute>
</attribute>
<attribute>
<code>IS_CLUSTERED</code>
<attribute>N</attribute>
</attribute>
<attribute>
<code>PORT_NUMBER</code>
<attribute>${db.mysql.epdc.target.ys.port}</attribute>
</attribute>
<attribute>
<code>PRESERVE_RESERVED_WORD_CASE</code>
<attribute>Y</attribute>
</attribute>
<attribute>
<code>QUOTE_ALL_FIELDS</code>
<attribute>N</attribute>
</attribute>
<attribute>
<code>STREAM_RESULTS</code>
<attribute>Y</attribute>
</attribute>
<attribute>
<code>SUPPORTS_BOOLEAN_DATA_TYPE</code>
<attribute>Y</attribute>
</attribute>
<attribute>
<code>SUPPORTS_TIMESTAMP_DATA_TYPE</code>
<attribute>Y</attribute>
</attribute>
<attribute>
<code>USE_POOLING</code>
<attribute>N</attribute>
</attribute>
</attributes>
</connection>
<order>
</order>
<step>
<name>网格治理排行表-月</name>
<type>ExecSQL</type>
<description/>
<distribute>Y</distribute>
<custom_distribution/>
<copies>1</copies>
<partitioning>
<method>none</method>
<schema_name/>
</partitioning>
<connection>target_yushan</connection>
<execute_each_row>N</execute_each_row>
<single_statement>N</single_statement>
<replace_variables>Y</replace_variables>
<quoteString>N</quoteString>
<sql>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
)</sql>
<set_params>N</set_params>
<insert_field/>
<update_field/>
<delete_field/>
<read_field/>
<arguments>
</arguments>
<attributes/>
<cluster_schema/>
<remotesteps>
<input>
</input>
<output>
</output>
</remotesteps>
<GUI>
<xloc>1023</xloc>
<yloc>633</yloc>
<draw>Y</draw>
</GUI>
</step>
<step>
<name>网格注册信息表-月</name>
<type>ExecSQL</type>
<description/>
<distribute>Y</distribute>
<custom_distribution/>
<copies>1</copies>
<partitioning>
<method>none</method>
<schema_name/>
</partitioning>
<connection>target_yushan</connection>
<execute_each_row>N</execute_each_row>
<single_statement>N</single_statement>
<replace_variables>Y</replace_variables>
<quoteString>N</quoteString>
<sql>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
)</sql>
<set_params>N</set_params>
<insert_field/>
<update_field/>
<delete_field/>
<read_field/>
<arguments>
</arguments>
<attributes/>
<cluster_schema/>
<remotesteps>
<input>
</input>
<output>
</output>
</remotesteps>
<GUI>
<xloc>617</xloc>
<yloc>540</yloc>
<draw>Y</draw>
</GUI>
</step>
<step_error_handling>
</step_error_handling>
<slave-step-copy-partition-distribution>
</slave-step-copy-partition-distribution>
<slave_transformation>N</slave_transformation>
<attributes/>
</transformation>

36
epdc-cloud-property/doc/kettle/screen-yushan/screen_ys_grid_rank_month_update_day.ktr
View File

@ -566,7 +566,7 @@ VALUES
</GUI> </GUI>
</step> </step>
<step> <step>
<name>网格注册信息表-月</name> <name>网格治理排行表-月</name>
<type>ExecSQL</type> <type>ExecSQL</type>
<description/> <description/>
<distribute>Y</distribute> <distribute>Y</distribute>
@ -581,21 +581,21 @@ VALUES
<single_statement>N</single_statement> <single_statement>N</single_statement>
<replace_variables>Y</replace_variables> <replace_variables>Y</replace_variables>
<quoteString>N</quoteString> <quoteString>N</quoteString>
<sql>INSERT INTO ys_grid_reg ( <sql>INSERT INTO ys_grid_gov_rank (
comm_id, comm_id,
comm_name, comm_name,
cal_date, cal_date,
name, grid_name,
grid_id, grid_id,
reg_user_num, project_num,
reg_party_num, project_finish_num,
reg_group_num, finish_rate,
create_time, create_time,
update_time update_time
) )
VALUES 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
)</sql> )</sql>
<set_params>N</set_params> <set_params>N</set_params>
<insert_field/> <insert_field/>
@ -613,13 +613,13 @@ VALUES
</output> </output>
</remotesteps> </remotesteps>
<GUI> <GUI>
<xloc>443</xloc> <xloc>656</xloc>
<yloc>360</yloc> <yloc>352</yloc>
<draw>Y</draw> <draw>Y</draw>
</GUI> </GUI>
</step> </step>
<step> <step>
<name>网格治理排行表-月</name> <name>网格注册信息表-月</name>
<type>ExecSQL</type> <type>ExecSQL</type>
<description/> <description/>
<distribute>Y</distribute> <distribute>Y</distribute>
@ -634,21 +634,21 @@ VALUES
<single_statement>N</single_statement> <single_statement>N</single_statement>
<replace_variables>Y</replace_variables> <replace_variables>Y</replace_variables>
<quoteString>N</quoteString> <quoteString>N</quoteString>
<sql>INSERT INTO ys_grid_gov_rank ( <sql>INSERT INTO ys_grid_reg (
comm_id, comm_id,
comm_name, comm_name,
cal_date, cal_date,
grid_name, name,
grid_id, grid_id,
project_num, reg_user_num,
project_finish_num, reg_party_num,
finish_rate, reg_group_num,
create_time, create_time,
update_time update_time
) )
VALUES 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
)</sql> )</sql>
<set_params>N</set_params> <set_params>N</set_params>
<insert_field/> <insert_field/>
@ -666,8 +666,8 @@ VALUES
</output> </output>
</remotesteps> </remotesteps>
<GUI> <GUI>
<xloc>849</xloc> <xloc>432</xloc>
<yloc>453</yloc> <yloc>352</yloc>
<draw>Y</draw> <draw>Y</draw>
</GUI> </GUI>
</step> </step>

4
epdc-cloud-property/doc/kettle/screen-yushan/yushan_all.kjb
View File

@ -502,7 +502,7 @@ true;
<attributes/> <attributes/>
<specification_method>filename</specification_method> <specification_method>filename</specification_method>
<job_object_id/> <job_object_id/>
<filename>${Internal.Entry.Current.Directory}/yushan_grid_day.kjb</filename> <filename>${Internal.Entry.Current.Directory}/yushan_grid_all_day.kjb</filename>
<jobname/> <jobname/>
<directory/> <directory/>
<arg_from_previous>N</arg_from_previous> <arg_from_previous>N</arg_from_previous>
@ -1000,7 +1000,7 @@ true;
<to>网格下标</to> <to>网格下标</to>
<from_nr>0</from_nr> <from_nr>0</from_nr>
<to_nr>0</to_nr> <to_nr>0</to_nr>
<enabled>N</enabled> <enabled>Y</enabled>
<evaluation>Y</evaluation> <evaluation>Y</evaluation>
<unconditional>N</unconditional> <unconditional>N</unconditional>
</hop> </hop>

2
epdc-cloud-property/doc/kettle/screen-yushan/yushan_comm_day_all.kjb
View File

@ -552,7 +552,7 @@ true;
<to>天数下标</to> <to>天数下标</to>
<from_nr>0</from_nr> <from_nr>0</from_nr>
<to_nr>0</to_nr> <to_nr>0</to_nr>
<enabled>N</enabled> <enabled>Y</enabled>
<evaluation>Y</evaluation> <evaluation>Y</evaluation>
<unconditional>Y</unconditional> <unconditional>Y</unconditional>
</hop> </hop>

662
epdc-cloud-property/doc/kettle/screen-yushan/yushan_grid_all_day.kjb
View File

@ -0,0 +1,662 @@
<?xml version="1.0" encoding="UTF-8"?>
<job>
<name>yushan_grid_all_day</name>
<description/>
<extended_description/>
<job_version/>
<job_status>0</job_status>
<directory>/</directory>
<created_user>-</created_user>
<created_date>2020/04/23 21:11:25.317</created_date>
<modified_user>-</modified_user>
<modified_date>2020/04/23 21:11:25.317</modified_date>
<parameters>
</parameters>
<slaveservers>
</slaveservers>
<job-log-table>
<connection/>
<schema/>
<table/>
<size_limit_lines/>
<interval/>
<timeout_days/>
<field>
<id>ID_JOB</id>
<enabled>Y</enabled>
<name>ID_JOB</name>
</field>
<field>
<id>CHANNEL_ID</id>
<enabled>Y</enabled>
<name>CHANNEL_ID</name>
</field>
<field>
<id>JOBNAME</id>
<enabled>Y</enabled>
<name>JOBNAME</name>
</field>
<field>
<id>STATUS</id>
<enabled>Y</enabled>
<name>STATUS</name>
</field>
<field>
<id>LINES_READ</id>
<enabled>Y</enabled>
<name>LINES_READ</name>
</field>
<field>
<id>LINES_WRITTEN</id>
<enabled>Y</enabled>
<name>LINES_WRITTEN</name>
</field>
<field>
<id>LINES_UPDATED</id>
<enabled>Y</enabled>
<name>LINES_UPDATED</name>
</field>
<field>
<id>LINES_INPUT</id>
<enabled>Y</enabled>
<name>LINES_INPUT</name>
</field>
<field>
<id>LINES_OUTPUT</id>
<enabled>Y</enabled>
<name>LINES_OUTPUT</name>
</field>
<field>
<id>LINES_REJECTED</id>
<enabled>Y</enabled>
<name>LINES_REJECTED</name>
</field>
<field>
<id>ERRORS</id>
<enabled>Y</enabled>
<name>ERRORS</name>
</field>
<field>
<id>STARTDATE</id>
<enabled>Y</enabled>
<name>STARTDATE</name>
</field>
<field>
<id>ENDDATE</id>
<enabled>Y</enabled>
<name>ENDDATE</name>
</field>
<field>
<id>LOGDATE</id>
<enabled>Y</enabled>
<name>LOGDATE</name>
</field>
<field>
<id>DEPDATE</id>
<enabled>Y</enabled>
<name>DEPDATE</name>
</field>
<field>
<id>REPLAYDATE</id>
<enabled>Y</enabled>
<name>REPLAYDATE</name>
</field>
<field>
<id>LOG_FIELD</id>
<enabled>Y</enabled>
<name>LOG_FIELD</name>
</field>
<field>
<id>EXECUTING_SERVER</id>
<enabled>N</enabled>
<name>EXECUTING_SERVER</name>
</field>
<field>
<id>EXECUTING_USER</id>
<enabled>N</enabled>
<name>EXECUTING_USER</name>
</field>
<field>
<id>START_JOB_ENTRY</id>
<enabled>N</enabled>
<name>START_JOB_ENTRY</name>
</field>
<field>
<id>CLIENT</id>
<enabled>N</enabled>
<name>CLIENT</name>
</field>
</job-log-table>
<jobentry-log-table>
<connection/>
<schema/>
<table/>
<timeout_days/>
<field>
<id>ID_BATCH</id>
<enabled>Y</enabled>
<name>ID_BATCH</name>
</field>
<field>
<id>CHANNEL_ID</id>
<enabled>Y</enabled>
<name>CHANNEL_ID</name>
</field>
<field>
<id>LOG_DATE</id>
<enabled>Y</enabled>
<name>LOG_DATE</name>
</field>
<field>
<id>JOBNAME</id>
<enabled>Y</enabled>
<name>TRANSNAME</name>
</field>
<field>
<id>JOBENTRYNAME</id>
<enabled>Y</enabled>
<name>STEPNAME</name>
</field>
<field>
<id>LINES_READ</id>
<enabled>Y</enabled>
<name>LINES_READ</name>
</field>
<field>
<id>LINES_WRITTEN</id>
<enabled>Y</enabled>
<name>LINES_WRITTEN</name>
</field>
<field>
<id>LINES_UPDATED</id>
<enabled>Y</enabled>
<name>LINES_UPDATED</name>
</field>
<field>
<id>LINES_INPUT</id>
<enabled>Y</enabled>
<name>LINES_INPUT</name>
</field>
<field>
<id>LINES_OUTPUT</id>
<enabled>Y</enabled>
<name>LINES_OUTPUT</name>
</field>
<field>
<id>LINES_REJECTED</id>
<enabled>Y</enabled>
<name>LINES_REJECTED</name>
</field>
<field>
<id>ERRORS</id>
<enabled>Y</enabled>
<name>ERRORS</name>
</field>
<field>
<id>RESULT</id>
<enabled>Y</enabled>
<name>RESULT</name>
</field>
<field>
<id>NR_RESULT_ROWS</id>
<enabled>Y</enabled>
<name>NR_RESULT_ROWS</name>
</field>
<field>
<id>NR_RESULT_FILES</id>
<enabled>Y</enabled>
<name>NR_RESULT_FILES</name>
</field>
<field>
<id>LOG_FIELD</id>
<enabled>N</enabled>
<name>LOG_FIELD</name>
</field>
<field>
<id>COPY_NR</id>
<enabled>N</enabled>
<name>COPY_NR</name>
</field>
</jobentry-log-table>
<channel-log-table>
<connection/>
<schema/>
<table/>
<timeout_days/>
<field>
<id>ID_BATCH</id>
<enabled>Y</enabled>
<name>ID_BATCH</name>
</field>
<field>
<id>CHANNEL_ID</id>
<enabled>Y</enabled>
<name>CHANNEL_ID</name>
</field>
<field>
<id>LOG_DATE</id>
<enabled>Y</enabled>
<name>LOG_DATE</name>
</field>
<field>
<id>LOGGING_OBJECT_TYPE</id>
<enabled>Y</enabled>
<name>LOGGING_OBJECT_TYPE</name>
</field>
<field>
<id>OBJECT_NAME</id>
<enabled>Y</enabled>
<name>OBJECT_NAME</name>
</field>
<field>
<id>OBJECT_COPY</id>
<enabled>Y</enabled>
<name>OBJECT_COPY</name>
</field>
<field>
<id>REPOSITORY_DIRECTORY</id>
<enabled>Y</enabled>
<name>REPOSITORY_DIRECTORY</name>
</field>
<field>
<id>FILENAME</id>
<enabled>Y</enabled>
<name>FILENAME</name>
</field>
<field>
<id>OBJECT_ID</id>
<enabled>Y</enabled>
<name>OBJECT_ID</name>
</field>
<field>
<id>OBJECT_REVISION</id>
<enabled>Y</enabled>
<name>OBJECT_REVISION</name>
</field>
<field>
<id>PARENT_CHANNEL_ID</id>
<enabled>Y</enabled>
<name>PARENT_CHANNEL_ID</name>
</field>
<field>
<id>ROOT_CHANNEL_ID</id>
<enabled>Y</enabled>
<name>ROOT_CHANNEL_ID</name>
</field>
</channel-log-table>
<pass_batchid>N</pass_batchid>
<shared_objects_file/>
<entries>
<entry>
<name>Start</name>
<description/>
<type>SPECIAL</type>
<attributes/>
<start>Y</start>
<dummy>N</dummy>
<repeat>N</repeat>
<schedulerType>0</schedulerType>
<intervalSeconds>0</intervalSeconds>
<intervalMinutes>60</intervalMinutes>
<hour>12</hour>
<minutes>0</minutes>
<weekDay>1</weekDay>
<DayOfMonth>1</DayOfMonth>
<parallel>N</parallel>
<draw>Y</draw>
<nr>0</nr>
<xloc>96</xloc>
<yloc>224</yloc>
<attributes_kjc/>
</entry>
<entry>
<name>天数下标</name>
<description/>
<type>SET_VARIABLES</type>
<attributes/>
<replacevars>Y</replacevars>
<filename/>
<file_variable_type>CURRENT_JOB</file_variable_type>
<fields>
<field>
<variable_name>dayIndex</variable_name>
<variable_value>0</variable_value>
<variable_type>CURRENT_JOB</variable_type>
</field>
<field>
<variable_name>days</variable_name>
<variable_value>30</variable_value>
<variable_type>CURRENT_JOB</variable_type>
</field>
</fields>
<parallel>N</parallel>
<draw>Y</draw>
<nr>0</nr>
<xloc>368</xloc>
<yloc>368</yloc>
<attributes_kjc/>
</entry>
<entry>
<name>if(dayIndex&lt;days)</name>
<description/>
<type>SIMPLE_EVAL</type>
<attributes/>
<valuetype>variable</valuetype>
<fieldname/>
<variablename>${dayIndex}</variablename>
<fieldtype>number</fieldtype>
<mask/>
<comparevalue>${days}</comparevalue>
<minvalue/>
<maxvalue/>
<successcondition>equal</successcondition>
<successnumbercondition>smaller</successnumbercondition>
<successbooleancondition>false</successbooleancondition>
<successwhenvarset>N</successwhenvarset>
<parallel>N</parallel>
<draw>Y</draw>
<nr>0</nr>
<xloc>752</xloc>
<yloc>368</yloc>
<attributes_kjc/>
</entry>
<entry>
<name>网格操作</name>
<description/>
<type>JOB</type>
<attributes/>
<specification_method>filename</specification_method>
<job_object_id/>
<filename>${Internal.Entry.Current.Directory}/yushan_grid_day_all_grid.kjb</filename>
<jobname/>
<directory/>
<arg_from_previous>N</arg_from_previous>
<params_from_previous>N</params_from_previous>
<exec_per_row>N</exec_per_row>
<set_logfile>N</set_logfile>
<logfile/>
<logext/>
<add_date>N</add_date>
<add_time>N</add_time>
<loglevel>Nothing</loglevel>
<slave_server_name/>
<wait_until_finished>Y</wait_until_finished>
<follow_abort_remote>N</follow_abort_remote>
<expand_remote_job>N</expand_remote_job>
<create_parent_folder>N</create_parent_folder>
<pass_export>N</pass_export>
<run_configuration>Pentaho local</run_configuration>
<parameters>
<pass_all_parameters>Y</pass_all_parameters>
</parameters>
<set_append_logfile>N</set_append_logfile>
<parallel>N</parallel>
<draw>Y</draw>
<nr>0</nr>
<xloc>976</xloc>
<yloc>496</yloc>
<attributes_kjc/>
</entry>
<entry>
<name>day下标加一，处理下个day</name>
<description/>
<type>EVAL</type>
<attributes/>
<script>var dayIndex = parseInt(parent_job.getVariable("dayIndex"));
dayIndex = dayIndex + 1;
parent_job.setVariable("dayIndex",dayIndex);
true;
</script>
<parallel>N</parallel>
<draw>Y</draw>
<nr>0</nr>
<xloc>752</xloc>
<yloc>496</yloc>
<attributes_kjc/>
</entry>
<entry>
<name>成功</name>
<description/>
<type>SUCCESS</type>
<attributes/>
<parallel>N</parallel>
<draw>Y</draw>
<nr>0</nr>
<xloc>976</xloc>
<yloc>368</yloc>
<attributes_kjc/>
</entry>
<entry>
<name>月数下标</name>
<description/>
<type>SET_VARIABLES</type>
<attributes/>
<replacevars>Y</replacevars>
<filename/>
<file_variable_type>CURRENT_JOB</file_variable_type>
<fields>
<field>
<variable_name>monthIndex</variable_name>
<variable_value>0</variable_value>
<variable_type>CURRENT_JOB</variable_type>
</field>
<field>
<variable_name>months</variable_name>
<variable_value>2</variable_value>
<variable_type>CURRENT_JOB</variable_type>
</field>
</fields>
<parallel>N</parallel>
<draw>Y</draw>
<nr>0</nr>
<xloc>368</xloc>
<yloc>80</yloc>
<attributes_kjc/>
</entry>
<entry>
<name>if(monthIndex&lt;months) 2</name>
<description/>
<type>SIMPLE_EVAL</type>
<attributes/>
<valuetype>variable</valuetype>
<fieldname/>
<variablename>${monthIndex}</variablename>
<fieldtype>number</fieldtype>
<mask/>
<comparevalue>${months}</comparevalue>
<minvalue/>
<maxvalue/>
<successcondition>equal</successcondition>
<successnumbercondition>smaller</successnumbercondition>
<successbooleancondition>false</successbooleancondition>
<successwhenvarset>N</successwhenvarset>
<parallel>N</parallel>
<draw>Y</draw>
<nr>0</nr>
<xloc>752</xloc>
<yloc>80</yloc>
<attributes_kjc/>
</entry>
<entry>
<name>网格操作 2</name>
<description/>
<type>JOB</type>
<attributes/>
<specification_method>filename</specification_method>
<job_object_id/>
<filename>${Internal.Entry.Current.Directory}/yushan_grid_month_all_grid.kjb</filename>
<jobname/>
<directory/>
<arg_from_previous>N</arg_from_previous>
<params_from_previous>N</params_from_previous>
<exec_per_row>N</exec_per_row>
<set_logfile>N</set_logfile>
<logfile/>
<logext/>
<add_date>N</add_date>
<add_time>N</add_time>
<loglevel>Nothing</loglevel>
<slave_server_name/>
<wait_until_finished>Y</wait_until_finished>
<follow_abort_remote>N</follow_abort_remote>
<expand_remote_job>N</expand_remote_job>
<create_parent_folder>N</create_parent_folder>
<pass_export>N</pass_export>
<run_configuration>Pentaho local</run_configuration>
<parameters>
<pass_all_parameters>Y</pass_all_parameters>
</parameters>
<set_append_logfile>N</set_append_logfile>
<parallel>N</parallel>
<draw>Y</draw>
<nr>0</nr>
<xloc>976</xloc>
<yloc>208</yloc>
<attributes_kjc/>
</entry>
<entry>
<name>month下标加一，处理下个month</name>
<description/>
<type>EVAL</type>
<attributes/>
<script>var monthIndex = parseInt(parent_job.getVariable("monthIndex"));
monthIndex = monthIndex + 1;
parent_job.setVariable("monthIndex",monthIndex);
true;
</script>
<parallel>N</parallel>
<draw>Y</draw>
<nr>0</nr>
<xloc>752</xloc>
<yloc>208</yloc>
<attributes_kjc/>
</entry>
<entry>
<name>成功 2</name>
<description/>
<type>SUCCESS</type>
<attributes/>
<parallel>N</parallel>
<draw>Y</draw>
<nr>0</nr>
<xloc>976</xloc>
<yloc>80</yloc>
<attributes_kjc/>
</entry>
</entries>
<hops>
<hop>
<from>Start</from>
<to>天数下标</to>
<from_nr>0</from_nr>
<to_nr>0</to_nr>
<enabled>N</enabled>
<evaluation>Y</evaluation>
<unconditional>Y</unconditional>
</hop>
<hop>
<from>网格操作</from>
<to>day下标加一，处理下个day</to>
<from_nr>0</from_nr>
<to_nr>0</to_nr>
<enabled>Y</enabled>
<evaluation>Y</evaluation>
<unconditional>N</unconditional>
</hop>
<hop>
<from>day下标加一，处理下个day</from>
<to>if(dayIndex&lt;days)</to>
<from_nr>0</from_nr>
<to_nr>0</to_nr>
<enabled>Y</enabled>
<evaluation>Y</evaluation>
<unconditional>N</unconditional>
</hop>
<hop>
<from>天数下标</from>
<to>if(dayIndex&lt;days)</to>
<from_nr>0</from_nr>
<to_nr>0</to_nr>
<enabled>Y</enabled>
<evaluation>Y</evaluation>
<unconditional>N</unconditional>
</hop>
<hop>
<from>if(dayIndex&lt;days)</from>
<to>网格操作</to>
<from_nr>0</from_nr>
<to_nr>0</to_nr>
<enabled>Y</enabled>
<evaluation>Y</evaluation>
<unconditional>N</unconditional>
</hop>
<hop>
<from>if(dayIndex&lt;days)</from>
<to>成功</to>
<from_nr>0</from_nr>
<to_nr>0</to_nr>
<enabled>Y</enabled>
<evaluation>N</evaluation>
<unconditional>N</unconditional>
</hop>
<hop>
<from>Start</from>
<to>月数下标</to>
<from_nr>0</from_nr>
<to_nr>0</to_nr>
<enabled>Y</enabled>
<evaluation>Y</evaluation>
<unconditional>Y</unconditional>
</hop>
<hop>
<from>月数下标</from>
<to>if(monthIndex&lt;months) 2</to>
<from_nr>0</from_nr>
<to_nr>0</to_nr>
<enabled>Y</enabled>
<evaluation>Y</evaluation>
<unconditional>N</unconditional>
</hop>
<hop>
<from>if(monthIndex&lt;months) 2</from>
<to>网格操作 2</to>
<from_nr>0</from_nr>
<to_nr>0</to_nr>
<enabled>Y</enabled>
<evaluation>Y</evaluation>
<unconditional>N</unconditional>
</hop>
<hop>
<from>网格操作 2</from>
<to>month下标加一，处理下个month</to>
<from_nr>0</from_nr>
<to_nr>0</to_nr>
<enabled>Y</enabled>
<evaluation>Y</evaluation>
<unconditional>N</unconditional>
</hop>
<hop>
<from>month下标加一，处理下个month</from>
<to>if(monthIndex&lt;months) 2</to>
<from_nr>0</from_nr>
<to_nr>0</to_nr>
<enabled>Y</enabled>
<evaluation>Y</evaluation>
<unconditional>N</unconditional>
</hop>
<hop>
<from>if(monthIndex&lt;months) 2</from>
<to>成功 2</to>
<from_nr>0</from_nr>
<to_nr>0</to_nr>
<enabled>Y</enabled>
<evaluation>N</evaluation>
<unconditional>N</unconditional>
</hop>
</hops>
<notepads>
</notepads>
<attributes/>
</job>

1164
epdc-cloud-property/doc/kettle/screen-yushan/yushan_grid_day_all_grid.kjb
View File

File diff suppressed because it is too large

1164
epdc-cloud-property/doc/kettle/screen-yushan/yushan_grid_month_all_grid.kjb
View File

File diff suppressed because it is too large

2
epdc-cloud-property/doc/kettle/screen-yushan/yushan_street_all_day.kjb
View File

@ -552,7 +552,7 @@ true;
<to>天数下标</to> <to>天数下标</to>
<from_nr>0</from_nr> <from_nr>0</from_nr>
<to_nr>0</to_nr> <to_nr>0</to_nr>
<enabled>N</enabled> <enabled>Y</enabled>
<evaluation>Y</evaluation> <evaluation>Y</evaluation>
<unconditional>Y</unconditional> <unconditional>Y</unconditional>
</hop> </hop>

Write Preview
Loading…
Cancel
Save