<?xml version="1.0" encoding="UTF-8"?> <transformation> <info> <name>bigdata_parking</name> <description/> <extended_description/> <trans_version/> <trans_type>Normal</trans_type> <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>2021/04/09 14:11:24.197</created_date> <modified_user>-</modified_user> <modified_date>2021/04/09 14:11:24.197</modified_date> <key_for_session_key>H4sIAAAAAAAAAAMAAAAAAAAAAAA=</key_for_session_key> <is_key_private>N</is_key_private> </info> <notepads> </notepads> <connection> <name>opt-monitoring-11.100.6.163</name> <server>11.100.6.163</server> <type>MYSQL</type> <access>Native</access> <database>casic_optmonitoring</database> <port>3306</port> <username>root</username> <password>Encrypted 2be98afc86aa7f2e48818bd79ddc0ff89</password> <servername/> <data_tablespace/> <index_tablespace/> <attributes> <attribute> <code>EXTRA_OPTION_MYSQL.characterEncoding</code> <attribute>utf8</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>3306</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> <connection> <name>target-people-livelihood-callcenter</name> <server>casic.callcenter.com</server> <type>MYSQL</type> <access>Native</access> <database>casic_people_livelihood</database> <port>3306</port> <username>root</username> <password>Encrypted 2be98afc86aa7f2e48818bd79ddc0ff89</password> <servername/> <data_tablespace/> <index_tablespace/> <attributes> <attribute> <code>EXTRA_OPTION_MYSQL.characterEncoding</code> <attribute>utf8</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>3306</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> <hop> <from>车场json转换</from> <to>车场ID不为空</to> <enabled>Y</enabled> </hop> <hop> <from>车场ID不为空</from> <to>车场同步更新</to> <enabled>Y</enabled> </hop> <hop> <from>车场同步更新</from> <to>更新增量时间(偏移1小时)</to> <enabled>Y</enabled> </hop> <hop> <from>月订单服务转换</from> <to>月订单ID不为空</to> <enabled>Y</enabled> </hop> <hop> <from>月订单ID不为空</from> <to>月订单同步更新</to> <enabled>Y</enabled> </hop> <hop> <from>月订单同步更新</from> <to>月订单更新增量时间(偏移1小时)</to> <enabled>Y</enabled> </hop> <hop> <from>日订单服务转换</from> <to>日订单ID不为</to> <enabled>Y</enabled> </hop> <hop> <from>日订单ID不为</from> <to>日订单同步更新</to> <enabled>Y</enabled> </hop> <hop> <from>日订单同步更新</from> <to>日订单更新增量时间(偏移1小时) </to> <enabled>Y</enabled> </hop> <hop> <from>读取车场日订单信息</from> <to>日订单参数转换</to> <enabled>Y</enabled> </hop> <hop> <from>周订单ID不为空</from> <to>周订单同步更新</to> <enabled>Y</enabled> </hop> <hop> <from>周订单同步更新</from> <to>周订单更新增量时间(偏移1小时) </to> <enabled>Y</enabled> </hop> <hop> <from>周订单服务转换</from> <to>周订单ID不为空</to> <enabled>Y</enabled> </hop> <hop> <from>订单ID不为空</from> <to>订单同步更新</to> <enabled>Y</enabled> </hop> <hop> <from>订单同步更新</from> <to>订单更新增量时间(偏移1小时)</to> <enabled>Y</enabled> </hop> <hop> <from>订单服务转换</from> <to>订单ID不为空</to> <enabled>Y</enabled> </hop> <hop> <from>日订单参数转换</from> <to>交换服务调用</to> <enabled>Y</enabled> </hop> <hop> <from>交换服务调用</from> <to>服务转发判断</to> <enabled>Y</enabled> </hop> <hop> <from>服务转发判断</from> <to>日订单服务转换</to> <enabled>Y</enabled> </hop> <hop> <from>服务转发判断</from> <to>周订单服务转换</to> <enabled>Y</enabled> </hop> <hop> <from>服务转发判断</from> <to>订单服务转换</to> <enabled>Y</enabled> </hop> <hop> <from>服务转发判断</from> <to>月订单服务转换</to> <enabled>Y</enabled> </hop> <hop> <from>服务转发判断</from> <to>车场json转换</to> <enabled>Y</enabled> </hop> <hop> <from>运营公司转换ID不为空</from> <to>运营公司同步更新</to> <enabled>Y</enabled> </hop> <hop> <from>运营公司同步更新</from> <to>运营公司更新增量时间(偏移1小时) </to> <enabled>Y</enabled> </hop> <hop> <from>运营公司转换</from> <to>运营公司转换ID不为空</to> <enabled>Y</enabled> </hop> <hop> <from>服务转发判断</from> <to>运营公司转换</to> <enabled>Y</enabled> </hop> <hop> <from>会员管理ID不能为空</from> <to>会员管理同步更新</to> <enabled>Y</enabled> </hop> <hop> <from>会员管理同步更新</from> <to>会员信息更新增量时间(偏移1小时)</to> <enabled>Y</enabled> </hop> <hop> <from>会员管理转换</from> <to>会员管理ID不能为空</to> <enabled>Y</enabled> </hop> <hop> <from>服务转发判断</from> <to>会员管理转换</to> <enabled>Y</enabled> </hop> <hop> <from>日车流量ID不能为空</from> <to>日车流量同步更新</to> <enabled>Y</enabled> </hop> <hop> <from>日车流量同步更新</from> <to>日车流量更新增量时间(偏移1小时)</to> <enabled>Y</enabled> </hop> <hop> <from>日车流量数据转换</from> <to>日车流量ID不能为空</to> <enabled>Y</enabled> </hop> <hop> <from>服务转发判断</from> <to>日车流量数据转换</to> <enabled>Y</enabled> </hop> <hop> <from>周车流量ID不能为空</from> <to>周车流量同步更新</to> <enabled>Y</enabled> </hop> <hop> <from>周车流量同步更新</from> <to>周车流量更新增量时间(偏移1小时)</to> <enabled>Y</enabled> </hop> <hop> <from>服务转发判断</from> <to>周车流量数据转换</to> <enabled>Y</enabled> </hop> <hop> <from>周车流量数据转换</from> <to>周车流量ID不能为空</to> <enabled>Y</enabled> </hop> <hop> <from>月车流量ID不能为空</from> <to>月车流量同步更新</to> <enabled>Y</enabled> </hop> <hop> <from>月车流量同步更新</from> <to>月车流量更新增量时间(偏移1小时)</to> <enabled>Y</enabled> </hop> <hop> <from>月车流量数据转换</from> <to>月车流量ID不能为空</to> <enabled>Y</enabled> </hop> <hop> <from>服务转发判断</from> <to>月车流量数据转换</to> <enabled>Y</enabled> </hop> <hop> <from>平台用户ID不为空</from> <to>平台用户同步更新</to> <enabled>Y</enabled> </hop> <hop> <from>平台用户同步更新</from> <to>平台用户更新增量时间(偏移1小时)</to> <enabled>Y</enabled> </hop> <hop> <from>服务转发判断</from> <to>平台用户数据转换</to> <enabled>Y</enabled> </hop> <hop> <from>平台用户数据转换</from> <to>平台用户ID不为空</to> <enabled>Y</enabled> </hop> <hop> <from>订单支付ID不为空</from> <to>订单支付同步更新</to> <enabled>Y</enabled> </hop> <hop> <from>订单支付同步更新</from> <to>订单支付更新增量时间(偏移1小时)</to> <enabled>Y</enabled> </hop> <hop> <from>服务转发判断</from> <to>订单支付数据转换</to> <enabled>Y</enabled> </hop> <hop> <from>订单支付数据转换</from> <to>订单支付ID不为空</to> <enabled>Y</enabled> </hop> </order> <step> <name>交换服务调用</name> <type>Rest</type> <description/> <distribute>Y</distribute> <custom_distribution/> <copies>1</copies> <partitioning> <method>none</method> <schema_name/> </partitioning> <applicationType>TEXT PLAIN</applicationType> <method>GET</method> <url>${bigdataHost}${bigdataParams}&param_dsid=1137</url> <urlInField>Y</urlInField> <dynamicMethod>N</dynamicMethod> <methodFieldName/> <urlField>HOST</urlField> <bodyField/> <httpLogin/> <httpPassword>Encrypted </httpPassword> <proxyHost/> <proxyPort/> <preemptive>N</preemptive> <trustStoreFile/> <trustStorePassword>Encrypted </trustStorePassword> <headers> </headers> <parameters> </parameters> <matrixParameters> </matrixParameters> <result> <name>result</name> <code/> <response_time/> <response_header/> </result> <attributes/> <cluster_schema/> <remotesteps> <input> </input> <output> </output> </remotesteps> <GUI> <xloc>368</xloc> <yloc>240</yloc> <draw>Y</draw> </GUI> </step> <step> <name>会员信息更新增量时间(偏移1小时)</name> <type>ExecSQL</type> <description/> <distribute>Y</distribute> <custom_distribution/> <copies>1</copies> <partitioning> <method>none</method> <schema_name/> </partitioning> <connection>opt-monitoring-11.100.6.163</connection> <execute_each_row>Y</execute_each_row> <single_statement>N</single_statement> <replace_variables>N</replace_variables> <quoteString>N</quoteString> <sql>update kettle_increment_config set REST_PARAMS=DATE_FORMAT(date_sub(now(), interval 1 hour) ,'%Y-%m-%d %H:%i:%s') where code ='parking_recent_car_user'</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>1184</xloc> <yloc>352</yloc> <draw>Y</draw> </GUI> </step> <step> <name>会员管理ID不能为空</name> <type>FilterRows</type> <description/> <distribute>Y</distribute> <custom_distribution/> <copies>1</copies> <partitioning> <method>none</method> <schema_name/> </partitioning> <send_true_to>会员管理同步更新</send_true_to> <send_false_to/> <compare> <condition> <negated>N</negated> <leftvalue>id</leftvalue> <function>IS NOT NULL</function> <rightvalue/> </condition> </compare> <attributes/> <cluster_schema/> <remotesteps> <input> </input> <output> </output> </remotesteps> <GUI> <xloc>880</xloc> <yloc>352</yloc> <draw>Y</draw> </GUI> </step> <step> <name>会员管理同步更新</name> <type>InsertUpdate</type> <description/> <distribute>Y</distribute> <custom_distribution/> <copies>1</copies> <partitioning> <method>none</method> <schema_name/> </partitioning> <connection>target-people-livelihood-callcenter</connection> <commit>100</commit> <update_bypassed>N</update_bypassed> <lookup> <schema>casic_people_livelihood</schema> <table>parking_ths_recent_car_user</table> <key> <name>id</name> <field>ID</field> <condition>=</condition> <name2/> </key> <value> <name>id</name> <rename>id</rename> <update>N</update> </value> <value> <name>park_id</name> <rename>park_id</rename> <update>Y</update> </value> <value> <name>car_space_id</name> <rename>car_space_id</rename> <update>Y</update> </value> <value> <name>start_time</name> <rename>start_time</rename> <update>Y</update> </value> <value> <name>end_time</name> <rename>end_time</rename> <update>Y</update> </value> <value> <name>user_id</name> <rename>user_id</rename> <update>Y</update> </value> <value> <name>member_price_id</name> <rename>member_price_id</rename> <update>Y</update> </value> <value> <name>version</name> <rename>version</rename> <update>Y</update> </value> <value> <name>open_name</name> <rename>open_name</rename> <update>Y</update> </value> <value> <name>open_car_no</name> <rename>open_car_no</rename> <update>Y</update> </value> <value> <name>way</name> <rename>way</rename> <update>Y</update> </value> <value> <name>remark</name> <rename>remark</rename> <update>Y</update> </value> <value> <name>status</name> <rename>status</rename> <update>Y</update> </value> <value> <name>sign</name> <rename>sign</rename> <update>Y</update> </value> <value> <name>type</name> <rename>type</rename> <update>Y</update> </value> <value> <name>create_time</name> <rename>create_time</rename> <update>Y</update> </value> <value> <name>update_time</name> <rename>update_time</rename> <update>Y</update> </value> <value> <name>updatestatus</name> <rename>updatestatus</rename> <update>Y</update> </value> <value> <name>updatetime</name> <rename>updatetime</rename> <update>Y</update> </value> </lookup> <attributes/> <cluster_schema/> <remotesteps> <input> </input> <output> </output> </remotesteps> <GUI> <xloc>1040</xloc> <yloc>352</yloc> <draw>Y</draw> </GUI> </step> <step> <name>会员管理转换</name> <type>JsonInput</type> <description/> <distribute>Y</distribute> <custom_distribution/> <copies>1</copies> <partitioning> <method>none</method> <schema_name/> </partitioning> <include>N</include> <include_field/> <rownum>N</rownum> <addresultfile>N</addresultfile> <readurl>N</readurl> <removeSourceField>N</removeSourceField> <IsIgnoreEmptyFile>N</IsIgnoreEmptyFile> <doNotFailIfNoFile>Y</doNotFailIfNoFile> <ignoreMissingPath>Y</ignoreMissingPath> <defaultPathLeafToNull>Y</defaultPathLeafToNull> <rownum_field/> <file> <name/> <filemask/> <exclude_filemask/> <file_required>N</file_required> <include_subfolders>N</include_subfolders> </file> <fields> <field> <name>id</name> <path>$..ID</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>park_id</name> <path>$..PARK_ID</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>car_space_id</name> <path>$..CAR_SPACE_ID</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>start_time</name> <path>$..START_TIME</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>end_time</name> <path>$..END_TIME</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>user_id</name> <path>$..USER_ID</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>member_price_id</name> <path>$..MEMBER_PRICE_ID</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>version</name> <path>$..VERSION</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>open_name</name> <path>$..OPEN_NAME</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>open_car_no</name> <path>$..OPEN_CAR_NO</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>way</name> <path>$..WAY</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>remark</name> <path>$..REMARK</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>status</name> <path>$..STATUS</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>sign</name> <path>$..SIGN</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>type</name> <path>$..TYPE</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>create_time</name> <path>$..CREATE_TIME</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>update_time</name> <path>$..UPDATE_TIME</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>updatestatus</name> <path>$..UPDATESTATUS</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>updatetime</name> <path>$..UPDATETIME</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> </fields> <limit>0</limit> <IsInFields>Y</IsInFields> <IsAFile>N</IsAFile> <valueField>result</valueField> <shortFileFieldName/> <pathFieldName/> <hiddenFieldName/> <lastModificationTimeFieldName/> <uriNameFieldName/> <rootUriNameFieldName/> <extensionFieldName/> <sizeFieldName/> <attributes/> <cluster_schema/> <remotesteps> <input> </input> <output> </output> </remotesteps> <GUI> <xloc>736</xloc> <yloc>352</yloc> <draw>Y</draw> </GUI> </step> <step> <name>周订单ID不为空</name> <type>FilterRows</type> <description/> <distribute>Y</distribute> <custom_distribution/> <copies>1</copies> <partitioning> <method>none</method> <schema_name/> </partitioning> <send_true_to>周订单同步更新</send_true_to> <send_false_to/> <compare> <condition> <negated>N</negated> <leftvalue>id</leftvalue> <function>IS NOT NULL</function> <rightvalue/> </condition> </compare> <attributes/> <cluster_schema/> <remotesteps> <input> </input> <output> </output> </remotesteps> <GUI> <xloc>864</xloc> <yloc>112</yloc> <draw>Y</draw> </GUI> </step> <step> <name>周订单同步更新</name> <type>InsertUpdate</type> <description/> <distribute>Y</distribute> <custom_distribution/> <copies>1</copies> <partitioning> <method>none</method> <schema_name/> </partitioning> <connection>target-people-livelihood-callcenter</connection> <commit>100</commit> <update_bypassed>N</update_bypassed> <lookup> <schema>casic_people_livelihood</schema> <table>parking_order_count_createtime_business_week_new</table> <key> <name>ID</name> <field>ID</field> <condition>=</condition> <name2/> </key> <value> <name>id</name> <rename>id</rename> <update>N</update> </value> <value> <name>park_id</name> <rename>park_id</rename> <update>Y</update> </value> <value> <name>year</name> <rename>year</rename> <update>Y</update> </value> <value> <name>week</name> <rename>week</rename> <update>Y</update> </value> <value> <name>count</name> <rename>count</rename> <update>Y</update> </value> <value> <name>type</name> <rename>type</rename> <update>Y</update> </value> <value> <name>start_time</name> <rename>start_time</rename> <update>Y</update> </value> <value> <name>end_time</name> <rename>end_time</rename> <update>Y</update> </value> <value> <name>updatestatus</name> <rename>updatestatus</rename> <update>Y</update> </value> <value> <name>updatetime</name> <rename>updatetime</rename> <update>Y</update> </value> </lookup> <attributes/> <cluster_schema/> <remotesteps> <input> </input> <output> </output> </remotesteps> <GUI> <xloc>1008</xloc> <yloc>112</yloc> <draw>Y</draw> </GUI> </step> <step> <name>周订单更新增量时间(偏移1小时) </name> <type>ExecSQL</type> <description/> <distribute>Y</distribute> <custom_distribution/> <copies>1</copies> <partitioning> <method>none</method> <schema_name/> </partitioning> <connection>opt-monitoring-11.100.6.163</connection> <execute_each_row>Y</execute_each_row> <single_statement>N</single_statement> <replace_variables>N</replace_variables> <quoteString>N</quoteString> <sql>update kettle_increment_config set REST_PARAMS=DATE_FORMAT(date_sub(now(), interval 1 hour) ,'%Y-%m-%d %H:%i:%s') where code ='parking_order_count_week'</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>1152</xloc> <yloc>112</yloc> <draw>Y</draw> </GUI> </step> <step> <name>周订单服务转换</name> <type>JsonInput</type> <description/> <distribute>Y</distribute> <custom_distribution/> <copies>1</copies> <partitioning> <method>none</method> <schema_name/> </partitioning> <include>N</include> <include_field/> <rownum>N</rownum> <addresultfile>N</addresultfile> <readurl>N</readurl> <removeSourceField>N</removeSourceField> <IsIgnoreEmptyFile>N</IsIgnoreEmptyFile> <doNotFailIfNoFile>Y</doNotFailIfNoFile> <ignoreMissingPath>Y</ignoreMissingPath> <defaultPathLeafToNull>Y</defaultPathLeafToNull> <rownum_field/> <file> <name/> <filemask/> <exclude_filemask/> <file_required>N</file_required> <include_subfolders>N</include_subfolders> </file> <fields> <field> <name>id</name> <path>$..ID</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>park_id</name> <path>$..PARK_ID</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>year</name> <path>$..YEAR</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>week</name> <path>$..WEEK</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>count</name> <path>$..COUNT</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>type</name> <path>$..TYPE</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>start_time</name> <path>$..START_TIME</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>end_time</name> <path>$..END_TIME</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>updatestatus</name> <path>$..UPDATESTATUS</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>updatetime</name> <path>$..UPDATETIME</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> </fields> <limit>0</limit> <IsInFields>Y</IsInFields> <IsAFile>N</IsAFile> <valueField>result</valueField> <shortFileFieldName/> <pathFieldName/> <hiddenFieldName/> <lastModificationTimeFieldName/> <uriNameFieldName/> <rootUriNameFieldName/> <extensionFieldName/> <sizeFieldName/> <attributes/> <cluster_schema/> <remotesteps> <input> </input> <output> </output> </remotesteps> <GUI> <xloc>752</xloc> <yloc>112</yloc> <draw>Y</draw> </GUI> </step> <step> <name>周车流量ID不能为空</name> <type>FilterRows</type> <description/> <distribute>Y</distribute> <custom_distribution/> <copies>1</copies> <partitioning> <method>none</method> <schema_name/> </partitioning> <send_true_to>周车流量同步更新</send_true_to> <send_false_to/> <compare> <condition> <negated>N</negated> <leftvalue>id</leftvalue> <function>IS NOT NULL</function> <rightvalue/> </condition> </compare> <attributes/> <cluster_schema/> <remotesteps> <input> </input> <output> </output> </remotesteps> <GUI> <xloc>880</xloc> <yloc>512</yloc> <draw>Y</draw> </GUI> </step> <step> <name>周车流量同步更新</name> <type>InsertUpdate</type> <description/> <distribute>Y</distribute> <custom_distribution/> <copies>1</copies> <partitioning> <method>none</method> <schema_name/> </partitioning> <connection>target-people-livelihood-callcenter</connection> <commit>100</commit> <update_bypassed>N</update_bypassed> <lookup> <schema>casic_people_livelihood</schema> <table>parking_flow_count_week_new</table> <key> <name>id</name> <field>ID</field> <condition>=</condition> <name2/> </key> <value> <name>count</name> <rename>count</rename> <update>Y</update> </value> <value> <name>end_time</name> <rename>end_time</rename> <update>Y</update> </value> <value> <name>id</name> <rename>id</rename> <update>N</update> </value> <value> <name>park_id</name> <rename>park_id</rename> <update>Y</update> </value> <value> <name>start_time</name> <rename>start_time</rename> <update>Y</update> </value> <value> <name>type</name> <rename>type</rename> <update>Y</update> </value> <value> <name>updatestatus</name> <rename>updatestatus</rename> <update>Y</update> </value> <value> <name>updatetime</name> <rename>updatetime</rename> <update>Y</update> </value> <value> <name>weekw</name> <rename>weekw</rename> <update>Y</update> </value> <value> <name>yearw</name> <rename>yearw</rename> <update>Y</update> </value> </lookup> <attributes/> <cluster_schema/> <remotesteps> <input> </input> <output> </output> </remotesteps> <GUI> <xloc>1040</xloc> <yloc>512</yloc> <draw>Y</draw> </GUI> </step> <step> <name>周车流量数据转换</name> <type>JsonInput</type> <description/> <distribute>Y</distribute> <custom_distribution/> <copies>1</copies> <partitioning> <method>none</method> <schema_name/> </partitioning> <include>N</include> <include_field/> <rownum>N</rownum> <addresultfile>N</addresultfile> <readurl>N</readurl> <removeSourceField>N</removeSourceField> <IsIgnoreEmptyFile>N</IsIgnoreEmptyFile> <doNotFailIfNoFile>Y</doNotFailIfNoFile> <ignoreMissingPath>Y</ignoreMissingPath> <defaultPathLeafToNull>Y</defaultPathLeafToNull> <rownum_field/> <file> <name/> <filemask/> <exclude_filemask/> <file_required>N</file_required> <include_subfolders>N</include_subfolders> </file> <fields> <field> <name>count</name> <path>$..COUNT</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>end_time</name> <path>$..END_TIME</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>id</name> <path>$..ID</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>park_id</name> <path>$..PARK_ID</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>start_time</name> <path>$..START_TIME</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>type</name> <path>$..TYPE</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>updatestatus</name> <path>$..UPDATESTATUS</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>updatetime</name> <path>$..UPDATETIME</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>weekw</name> <path>$..WEEKW</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>yearw</name> <path>$..YEARW</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> </fields> <limit>0</limit> <IsInFields>Y</IsInFields> <IsAFile>N</IsAFile> <valueField>result</valueField> <shortFileFieldName/> <pathFieldName/> <hiddenFieldName/> <lastModificationTimeFieldName/> <uriNameFieldName/> <rootUriNameFieldName/> <extensionFieldName/> <sizeFieldName/> <attributes/> <cluster_schema/> <remotesteps> <input> </input> <output> </output> </remotesteps> <GUI> <xloc>736</xloc> <yloc>512</yloc> <draw>Y</draw> </GUI> </step> <step> <name>周车流量更新增量时间(偏移1小时)</name> <type>ExecSQL</type> <description/> <distribute>Y</distribute> <custom_distribution/> <copies>1</copies> <partitioning> <method>none</method> <schema_name/> </partitioning> <connection>opt-monitoring-11.100.6.163</connection> <execute_each_row>Y</execute_each_row> <single_statement>N</single_statement> <replace_variables>N</replace_variables> <quoteString>N</quoteString> <sql>update kettle_increment_config set REST_PARAMS=DATE_FORMAT(date_sub(now(), interval 1 hour) ,'%Y-%m-%d %H:%i:%s') where code ='?'</sql> <set_params>N</set_params> <insert_field/> <update_field/> <delete_field/> <read_field/> <arguments> <argument> <name>ROUTE_CODE</name> </argument> </arguments> <attributes/> <cluster_schema/> <remotesteps> <input> </input> <output> </output> </remotesteps> <GUI> <xloc>1216</xloc> <yloc>512</yloc> <draw>Y</draw> </GUI> </step> <step> <name>平台用户ID不为空</name> <type>FilterRows</type> <description/> <distribute>Y</distribute> <custom_distribution/> <copies>1</copies> <partitioning> <method>none</method> <schema_name/> </partitioning> <send_true_to>平台用户同步更新</send_true_to> <send_false_to/> <compare> <condition> <negated>N</negated> <leftvalue>id</leftvalue> <function>IS NOT NULL</function> <rightvalue/> </condition> </compare> <attributes/> <cluster_schema/> <remotesteps> <input> </input> <output> </output> </remotesteps> <GUI> <xloc>368</xloc> <yloc>320</yloc> <draw>Y</draw> </GUI> </step> <step> <name>平台用户同步更新</name> <type>InsertUpdate</type> <description/> <distribute>Y</distribute> <custom_distribution/> <copies>1</copies> <partitioning> <method>none</method> <schema_name/> </partitioning> <connection>target-people-livelihood-callcenter</connection> <commit>100</commit> <update_bypassed>N</update_bypassed> <lookup> <schema>casic_people_livelihood</schema> <table>parking_car_user</table> <key> <name>ID</name> <field>ID</field> <condition>=</condition> <name2/> </key> <value> <name>id</name> <rename>id</rename> <update>N</update> </value> <value> <name>mobile</name> <rename>mobile</rename> <update>Y</update> </value> <value> <name>plate_number</name> <rename>plate_number</rename> <update>Y</update> </value> <value> <name>openid</name> <rename>openid</rename> <update>Y</update> </value> <value> <name>source</name> <rename>source</rename> <update>Y</update> </value> <value> <name>register_time</name> <rename>register_time</rename> <update>Y</update> </value> <value> <name>name</name> <rename>name</rename> <update>Y</update> </value> <value> <name>updatestatus</name> <rename>updatestatus</rename> <update>Y</update> </value> <value> <name>updatetime</name> <rename>updatetime</rename> <update>Y</update> </value> </lookup> <attributes/> <cluster_schema/> <remotesteps> <input> </input> <output> </output> </remotesteps> <GUI> <xloc>256</xloc> <yloc>320</yloc> <draw>Y</draw> </GUI> </step> <step> <name>平台用户数据转换</name> <type>JsonInput</type> <description/> <distribute>Y</distribute> <custom_distribution/> <copies>1</copies> <partitioning> <method>none</method> <schema_name/> </partitioning> <include>N</include> <include_field/> <rownum>N</rownum> <addresultfile>N</addresultfile> <readurl>N</readurl> <removeSourceField>N</removeSourceField> <IsIgnoreEmptyFile>N</IsIgnoreEmptyFile> <doNotFailIfNoFile>Y</doNotFailIfNoFile> <ignoreMissingPath>Y</ignoreMissingPath> <defaultPathLeafToNull>Y</defaultPathLeafToNull> <rownum_field/> <file> <name/> <filemask/> <exclude_filemask/> <file_required>N</file_required> <include_subfolders>N</include_subfolders> </file> <fields> <field> <name>id</name> <path>$..ID</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>mobile</name> <path>$..MOBILE</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>plate_number</name> <path>$..PLATE_NUMBER</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>openid</name> <path>$..OPENID</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>source</name> <path>$..SOURCE</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>register_time</name> <path>$..REGISTER_TIME</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>name</name> <path>$..NAME</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>updatestatus</name> <path>$..UPDATESTATUS</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>updatetime</name> <path>$..UPDATETIME</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> </fields> <limit>0</limit> <IsInFields>Y</IsInFields> <IsAFile>N</IsAFile> <valueField>result</valueField> <shortFileFieldName/> <pathFieldName/> <hiddenFieldName/> <lastModificationTimeFieldName/> <uriNameFieldName/> <rootUriNameFieldName/> <extensionFieldName/> <sizeFieldName/> <attributes/> <cluster_schema/> <remotesteps> <input> </input> <output> </output> </remotesteps> <GUI> <xloc>496</xloc> <yloc>320</yloc> <draw>Y</draw> </GUI> </step> <step> <name>平台用户更新增量时间(偏移1小时)</name> <type>ExecSQL</type> <description/> <distribute>Y</distribute> <custom_distribution/> <copies>1</copies> <partitioning> <method>none</method> <schema_name/> </partitioning> <connection>opt-monitoring-11.100.6.163</connection> <execute_each_row>Y</execute_each_row> <single_statement>N</single_statement> <replace_variables>N</replace_variables> <quoteString>N</quoteString> <sql>update kettle_increment_config set REST_PARAMS=DATE_FORMAT(date_sub(now(), interval 1 hour) ,'%Y-%m-%d %H:%i:%s') where code ='?'</sql> <set_params>N</set_params> <insert_field/> <update_field/> <delete_field/> <read_field/> <arguments> <argument> <name>ROUTE_CODE</name> </argument> </arguments> <attributes/> <cluster_schema/> <remotesteps> <input> </input> <output> </output> </remotesteps> <GUI> <xloc>96</xloc> <yloc>320</yloc> <draw>Y</draw> </GUI> </step> <step> <name>日订单ID不为</name> <type>FilterRows</type> <description/> <distribute>Y</distribute> <custom_distribution/> <copies>1</copies> <partitioning> <method>none</method> <schema_name/> </partitioning> <send_true_to>日订单同步更新</send_true_to> <send_false_to/> <compare> <condition> <negated>N</negated> <leftvalue>id</leftvalue> <function>IS NOT NULL</function> <rightvalue/> </condition> </compare> <attributes/> <cluster_schema/> <remotesteps> <input> </input> <output> </output> </remotesteps> <GUI> <xloc>848</xloc> <yloc>32</yloc> <draw>Y</draw> </GUI> </step> <step> <name>日订单参数转换</name> <type>UserDefinedJavaClass</type> <description/> <distribute>Y</distribute> <custom_distribution/> <copies>1</copies> <partitioning> <method>none</method> <schema_name/> </partitioning> <definitions> <definition> <class_type>TRANSFORM_CLASS</class_type> <class_name>Processor</class_name> <class_source>// 生成的代码片段 public boolean processRow(StepMetaInterface smi, StepDataInterface sdi) throws Exception { if (first) { first = false; } Object[] r = getRow(); if (r == null) { setOutputDone(); return false; } r = createOutputRow(r, data.outputRowMeta.size()); //读取参数 String condition= get(Fields.In, "REST_RULE").getString(r); String host= get(Fields.In, "HOST").getString(r); String value= get(Fields.In, "REST_PARAMS").getString(r); String isEncode = get(Fields.In, "IS_ENCODE").getString(r); String outcondition =host; //是否需要动态设置参数 if(org.apache.commons.lang3.StringUtils.isNotEmpty(condition)){ Object[] params = value.split(","); if("1".equals(isEncode)){ outcondition=host+"&"+java.net.URLEncoder.encode(String.format(condition,params),"UTF-8"); }else{ outcondition=host+"&"+String.format(condition,params); } } get(Fields.Out,"HOST").setValue(r,outcondition); putRow(data.outputRowMeta, r); return true; } </class_source> </definition> </definitions> <fields> </fields> <clear_result_fields>N</clear_result_fields> <info_steps/> <target_steps/> <usage_parameters/> <attributes/> <cluster_schema/> <remotesteps> <input> </input> <output> </output> </remotesteps> <GUI> <xloc>272</xloc> <yloc>240</yloc> <draw>Y</draw> </GUI> </step> <step> <name>日订单同步更新</name> <type>InsertUpdate</type> <description/> <distribute>Y</distribute> <custom_distribution/> <copies>1</copies> <partitioning> <method>none</method> <schema_name/> </partitioning> <connection>target-people-livelihood-callcenter</connection> <commit>100</commit> <update_bypassed>N</update_bypassed> <lookup> <schema>casic_people_livelihood</schema> <table>parking_order_count_createtime_business_day_new</table> <key> <name>ID</name> <field>ID</field> <condition>=</condition> <name2/> </key> <value> <name>id</name> <rename>id</rename> <update>N</update> </value> <value> <name>park_id</name> <rename>park_id</rename> <update>Y</update> </value> <value> <name>date</name> <rename>date</rename> <update>Y</update> </value> <value> <name>count</name> <rename>count</rename> <update>Y</update> </value> <value> <name>type</name> <rename>type</rename> <update>Y</update> </value> <value> <name>updatestatus</name> <rename>updatestatus</rename> <update>Y</update> </value> <value> <name>updatetime</name> <rename>updatetime</rename> <update>Y</update> </value> </lookup> <attributes/> <cluster_schema/> <remotesteps> <input> </input> <output> </output> </remotesteps> <GUI> <xloc>992</xloc> <yloc>32</yloc> <draw>Y</draw> </GUI> </step> <step> <name>日订单更新增量时间(偏移1小时) </name> <type>ExecSQL</type> <description/> <distribute>Y</distribute> <custom_distribution/> <copies>1</copies> <partitioning> <method>none</method> <schema_name/> </partitioning> <connection>opt-monitoring-11.100.6.163</connection> <execute_each_row>Y</execute_each_row> <single_statement>N</single_statement> <replace_variables>N</replace_variables> <quoteString>N</quoteString> <sql>update kettle_increment_config set REST_PARAMS=DATE_FORMAT(date_sub(now(), interval 1 hour) ,'%Y-%m-%d %H:%i:%s') where code ='parking_order_count_day'</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>1152</xloc> <yloc>32</yloc> <draw>Y</draw> </GUI> </step> <step> <name>日订单服务转换</name> <type>JsonInput</type> <description/> <distribute>Y</distribute> <custom_distribution/> <copies>1</copies> <partitioning> <method>none</method> <schema_name/> </partitioning> <include>N</include> <include_field/> <rownum>N</rownum> <addresultfile>N</addresultfile> <readurl>N</readurl> <removeSourceField>N</removeSourceField> <IsIgnoreEmptyFile>N</IsIgnoreEmptyFile> <doNotFailIfNoFile>Y</doNotFailIfNoFile> <ignoreMissingPath>Y</ignoreMissingPath> <defaultPathLeafToNull>Y</defaultPathLeafToNull> <rownum_field/> <file> <name/> <filemask/> <exclude_filemask/> <file_required>N</file_required> <include_subfolders>N</include_subfolders> </file> <fields> <field> <name>id</name> <path>$..ID</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>park_id</name> <path>$..PARK_ID</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>date</name> <path>$..DATE</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>count</name> <path>$..COUNT</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>type</name> <path>$..TYPE</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>updatestatus</name> <path>$..UPDATESTATUS</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>updatetime</name> <path>$..UPDATETIME</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> </fields> <limit>0</limit> <IsInFields>Y</IsInFields> <IsAFile>N</IsAFile> <valueField>result</valueField> <shortFileFieldName/> <pathFieldName/> <hiddenFieldName/> <lastModificationTimeFieldName/> <uriNameFieldName/> <rootUriNameFieldName/> <extensionFieldName/> <sizeFieldName/> <attributes/> <cluster_schema/> <remotesteps> <input> </input> <output> </output> </remotesteps> <GUI> <xloc>704</xloc> <yloc>32</yloc> <draw>Y</draw> </GUI> </step> <step> <name>日车流量ID不能为空</name> <type>FilterRows</type> <description/> <distribute>Y</distribute> <custom_distribution/> <copies>1</copies> <partitioning> <method>none</method> <schema_name/> </partitioning> <send_true_to>日车流量同步更新</send_true_to> <send_false_to/> <compare> <condition> <negated>N</negated> <leftvalue>id</leftvalue> <function>IS NOT NULL</function> <rightvalue/> </condition> </compare> <attributes/> <cluster_schema/> <remotesteps> <input> </input> <output> </output> </remotesteps> <GUI> <xloc>848</xloc> <yloc>432</yloc> <draw>Y</draw> </GUI> </step> <step> <name>日车流量同步更新</name> <type>InsertUpdate</type> <description/> <distribute>Y</distribute> <custom_distribution/> <copies>1</copies> <partitioning> <method>none</method> <schema_name/> </partitioning> <connection>target-people-livelihood-callcenter</connection> <commit>100</commit> <update_bypassed>N</update_bypassed> <lookup> <schema>casic_people_livelihood</schema> <table>parking_flow_count_day_new</table> <key> <name>id</name> <field>ID</field> <condition>=</condition> <name2/> </key> <value> <name>id</name> <rename>id</rename> <update>N</update> </value> <value> <name>park_id</name> <rename>park_id</rename> <update>Y</update> </value> <value> <name>type</name> <rename>type</rename> <update>Y</update> </value> <value> <name>updatestatus</name> <rename>updatestatus</rename> <update>Y</update> </value> <value> <name>updatetime</name> <rename>updatetime</rename> <update>Y</update> </value> <value> <name>time_day</name> <rename>time_day</rename> <update>Y</update> </value> <value> <name>count</name> <rename>count</rename> <update>Y</update> </value> </lookup> <attributes/> <cluster_schema/> <remotesteps> <input> </input> <output> </output> </remotesteps> <GUI> <xloc>1008</xloc> <yloc>432</yloc> <draw>Y</draw> </GUI> </step> <step> <name>日车流量数据转换</name> <type>JsonInput</type> <description/> <distribute>Y</distribute> <custom_distribution/> <copies>1</copies> <partitioning> <method>none</method> <schema_name/> </partitioning> <include>N</include> <include_field/> <rownum>N</rownum> <addresultfile>N</addresultfile> <readurl>N</readurl> <removeSourceField>N</removeSourceField> <IsIgnoreEmptyFile>N</IsIgnoreEmptyFile> <doNotFailIfNoFile>Y</doNotFailIfNoFile> <ignoreMissingPath>Y</ignoreMissingPath> <defaultPathLeafToNull>Y</defaultPathLeafToNull> <rownum_field/> <file> <name/> <filemask/> <exclude_filemask/> <file_required>N</file_required> <include_subfolders>N</include_subfolders> </file> <fields> <field> <name>id</name> <path>$..ID</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>park_id</name> <path>$..PARK_ID</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>type</name> <path>$..TYPE</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>updatestatus</name> <path>$..UPDATESTATUS</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>updatetime</name> <path>$..UPDATETIME</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>time_day</name> <path>$..TIME_DAY</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>count</name> <path>$..COUNT</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> </fields> <limit>0</limit> <IsInFields>Y</IsInFields> <IsAFile>N</IsAFile> <valueField>result</valueField> <shortFileFieldName/> <pathFieldName/> <hiddenFieldName/> <lastModificationTimeFieldName/> <uriNameFieldName/> <rootUriNameFieldName/> <extensionFieldName/> <sizeFieldName/> <attributes/> <cluster_schema/> <remotesteps> <input> </input> <output> </output> </remotesteps> <GUI> <xloc>736</xloc> <yloc>432</yloc> <draw>Y</draw> </GUI> </step> <step> <name>日车流量更新增量时间(偏移1小时)</name> <type>ExecSQL</type> <description/> <distribute>Y</distribute> <custom_distribution/> <copies>1</copies> <partitioning> <method>none</method> <schema_name/> </partitioning> <connection>opt-monitoring-11.100.6.163</connection> <execute_each_row>Y</execute_each_row> <single_statement>N</single_statement> <replace_variables>N</replace_variables> <quoteString>N</quoteString> <sql>update kettle_increment_config set REST_PARAMS=DATE_FORMAT(date_sub(now(), interval 1 hour) ,'%Y-%m-%d %H:%i:%s') where code ='?'</sql> <set_params>N</set_params> <insert_field/> <update_field/> <delete_field/> <read_field/> <arguments> <argument> <name>ROUTE_CODE</name> </argument> </arguments> <attributes/> <cluster_schema/> <remotesteps> <input> </input> <output> </output> </remotesteps> <GUI> <xloc>1168</xloc> <yloc>432</yloc> <draw>Y</draw> </GUI> </step> <step> <name>更新增量时间(偏移1小时)</name> <type>ExecSQL</type> <description/> <distribute>Y</distribute> <custom_distribution/> <copies>1</copies> <partitioning> <method>none</method> <schema_name/> </partitioning> <connection>opt-monitoring-11.100.6.163</connection> <execute_each_row>Y</execute_each_row> <single_statement>N</single_statement> <replace_variables>N</replace_variables> <quoteString>N</quoteString> <sql>update kettle_increment_config set REST_PARAMS=DATE_FORMAT(date_sub(now(), interval 1 hour) ,'%Y-%m-%d %H:%i:%s') where code ='parking_park'</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>160</xloc> <yloc>128</yloc> <draw>Y</draw> </GUI> </step> <step> <name>月订单ID不为空</name> <type>FilterRows</type> <description/> <distribute>Y</distribute> <custom_distribution/> <copies>1</copies> <partitioning> <method>none</method> <schema_name/> </partitioning> <send_true_to>月订单同步更新</send_true_to> <send_false_to/> <compare> <condition> <negated>N</negated> <leftvalue>id</leftvalue> <function>IS NOT NULL</function> <rightvalue/> </condition> </compare> <attributes/> <cluster_schema/> <remotesteps> <input> </input> <output> </output> </remotesteps> <GUI> <xloc>416</xloc> <yloc>32</yloc> <draw>Y</draw> </GUI> </step> <step> <name>月订单同步更新</name> <type>InsertUpdate</type> <description/> <distribute>Y</distribute> <custom_distribution/> <copies>1</copies> <partitioning> <method>none</method> <schema_name/> </partitioning> <connection>target-people-livelihood-callcenter</connection> <commit>100</commit> <update_bypassed>N</update_bypassed> <lookup> <schema>casic_people_livelihood</schema> <table>parking_order_count_createtime_business_month_new</table> <key> <name>ID</name> <field>ID</field> <condition>=</condition> <name2/> </key> <value> <name>park_id</name> <rename>park_id</rename> <update>Y</update> </value> <value> <name>year</name> <rename>year</rename> <update>Y</update> </value> <value> <name>month</name> <rename>month</rename> <update>Y</update> </value> <value> <name>count</name> <rename>count</rename> <update>Y</update> </value> <value> <name>type</name> <rename>type</rename> <update>Y</update> </value> <value> <name>start_time</name> <rename>start_time</rename> <update>Y</update> </value> <value> <name>end_time</name> <rename>end_time</rename> <update>Y</update> </value> <value> <name>updatestatus</name> <rename>updatestatus</rename> <update>Y</update> </value> <value> <name>updatetime</name> <rename>updatetime</rename> <update>Y</update> </value> <value> <name>id</name> <rename>id</rename> <update>N</update> </value> </lookup> <attributes/> <cluster_schema/> <remotesteps> <input> </input> <output> </output> </remotesteps> <GUI> <xloc>288</xloc> <yloc>32</yloc> <draw>Y</draw> </GUI> </step> <step> <name>月订单更新增量时间(偏移1小时)</name> <type>ExecSQL</type> <description/> <distribute>Y</distribute> <custom_distribution/> <copies>1</copies> <partitioning> <method>none</method> <schema_name/> </partitioning> <connection>opt-monitoring-11.100.6.163</connection> <execute_each_row>Y</execute_each_row> <single_statement>N</single_statement> <replace_variables>N</replace_variables> <quoteString>N</quoteString> <sql>update kettle_increment_config set REST_PARAMS=DATE_FORMAT(date_sub(now(), interval 1 hour) ,'%Y-%m-%d %H:%i:%s') where code ='parking_order_count_month'</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>160</xloc> <yloc>32</yloc> <draw>Y</draw> </GUI> </step> <step> <name>月订单服务转换</name> <type>JsonInput</type> <description/> <distribute>Y</distribute> <custom_distribution/> <copies>1</copies> <partitioning> <method>none</method> <schema_name/> </partitioning> <include>N</include> <include_field/> <rownum>N</rownum> <addresultfile>N</addresultfile> <readurl>N</readurl> <removeSourceField>N</removeSourceField> <IsIgnoreEmptyFile>N</IsIgnoreEmptyFile> <doNotFailIfNoFile>Y</doNotFailIfNoFile> <ignoreMissingPath>Y</ignoreMissingPath> <defaultPathLeafToNull>Y</defaultPathLeafToNull> <rownum_field/> <file> <name/> <filemask/> <exclude_filemask/> <file_required>N</file_required> <include_subfolders>N</include_subfolders> </file> <fields> <field> <name>park_id</name> <path>$..PARK_ID</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>year</name> <path>$..YEAR</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>month</name> <path>$..MONTH</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>count</name> <path>$..COUNT</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>type</name> <path>$..TYPE</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>start_time</name> <path>$..START_TIME</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>end_time</name> <path>$..END_TIME</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>updatestatus</name> <path>$..UPDATESTATUS</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>updatetime</name> <path>$..UPDATETIME</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>id</name> <path>$..ID</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> </fields> <limit>0</limit> <IsInFields>Y</IsInFields> <IsAFile>N</IsAFile> <valueField>result</valueField> <shortFileFieldName/> <pathFieldName/> <hiddenFieldName/> <lastModificationTimeFieldName/> <uriNameFieldName/> <rootUriNameFieldName/> <extensionFieldName/> <sizeFieldName/> <attributes/> <cluster_schema/> <remotesteps> <input> </input> <output> </output> </remotesteps> <GUI> <xloc>528</xloc> <yloc>32</yloc> <draw>Y</draw> </GUI> </step> <step> <name>月车流量ID不能为空</name> <type>FilterRows</type> <description/> <distribute>Y</distribute> <custom_distribution/> <copies>1</copies> <partitioning> <method>none</method> <schema_name/> </partitioning> <send_true_to>月车流量同步更新</send_true_to> <send_false_to/> <compare> <condition> <negated>N</negated> <leftvalue>id</leftvalue> <function>IS NOT NULL</function> <rightvalue/> </condition> </compare> <attributes/> <cluster_schema/> <remotesteps> <input> </input> <output> </output> </remotesteps> <GUI> <xloc>848</xloc> <yloc>592</yloc> <draw>Y</draw> </GUI> </step> <step> <name>月车流量同步更新</name> <type>InsertUpdate</type> <description/> <distribute>Y</distribute> <custom_distribution/> <copies>1</copies> <partitioning> <method>none</method> <schema_name/> </partitioning> <connection>target-people-livelihood-callcenter</connection> <commit>100</commit> <update_bypassed>N</update_bypassed> <lookup> <schema>casic_people_livelihood</schema> <table>parking_flow_count_month_new</table> <key> <name>id</name> <field>ID</field> <condition>=</condition> <name2/> </key> <value> <name>id</name> <rename>id</rename> <update>N</update> </value> <value> <name>yearw</name> <rename>yearw</rename> <update>Y</update> </value> <value> <name>monthw</name> <rename>monthw</rename> <update>Y</update> </value> <value> <name>park_id</name> <rename>park_id</rename> <update>Y</update> </value> <value> <name>count</name> <rename>count</rename> <update>Y</update> </value> <value> <name>start_time</name> <rename>start_time</rename> <update>Y</update> </value> <value> <name>end_time</name> <rename>end_time</rename> <update>Y</update> </value> <value> <name>type</name> <rename>type</rename> <update>Y</update> </value> <value> <name>updatestatus</name> <rename>updatestatus</rename> <update>Y</update> </value> <value> <name>updatetime</name> <rename>updatetime</rename> <update>Y</update> </value> </lookup> <attributes/> <cluster_schema/> <remotesteps> <input> </input> <output> </output> </remotesteps> <GUI> <xloc>1008</xloc> <yloc>592</yloc> <draw>Y</draw> </GUI> </step> <step> <name>月车流量数据转换</name> <type>JsonInput</type> <description/> <distribute>Y</distribute> <custom_distribution/> <copies>1</copies> <partitioning> <method>none</method> <schema_name/> </partitioning> <include>N</include> <include_field/> <rownum>N</rownum> <addresultfile>N</addresultfile> <readurl>N</readurl> <removeSourceField>N</removeSourceField> <IsIgnoreEmptyFile>N</IsIgnoreEmptyFile> <doNotFailIfNoFile>Y</doNotFailIfNoFile> <ignoreMissingPath>Y</ignoreMissingPath> <defaultPathLeafToNull>Y</defaultPathLeafToNull> <rownum_field/> <file> <name/> <filemask/> <exclude_filemask/> <file_required>N</file_required> <include_subfolders>N</include_subfolders> </file> <fields> <field> <name>id</name> <path>$..ID</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>yearw</name> <path>$..YEARW</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>monthw</name> <path>$..MONTHW</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>park_id</name> <path>$..PARK_ID</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>count</name> <path>$..COUNT</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>start_time</name> <path>$..START_TIME</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>end_time</name> <path>$..END_TIME</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>type</name> <path>$..TYPE</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>updatestatus</name> <path>$..UPDATESTATUS</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>updatetime</name> <path>$..UPDATETIME</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> </fields> <limit>0</limit> <IsInFields>Y</IsInFields> <IsAFile>N</IsAFile> <valueField>result</valueField> <shortFileFieldName/> <pathFieldName/> <hiddenFieldName/> <lastModificationTimeFieldName/> <uriNameFieldName/> <rootUriNameFieldName/> <extensionFieldName/> <sizeFieldName/> <attributes/> <cluster_schema/> <remotesteps> <input> </input> <output> </output> </remotesteps> <GUI> <xloc>720</xloc> <yloc>592</yloc> <draw>Y</draw> </GUI> </step> <step> <name>月车流量更新增量时间(偏移1小时)</name> <type>ExecSQL</type> <description/> <distribute>Y</distribute> <custom_distribution/> <copies>1</copies> <partitioning> <method>none</method> <schema_name/> </partitioning> <connection>opt-monitoring-11.100.6.163</connection> <execute_each_row>Y</execute_each_row> <single_statement>N</single_statement> <replace_variables>N</replace_variables> <quoteString>N</quoteString> <sql>update kettle_increment_config set REST_PARAMS=DATE_FORMAT(date_sub(now(), interval 1 hour) ,'%Y-%m-%d %H:%i:%s') where code ='?'</sql> <set_params>N</set_params> <insert_field/> <update_field/> <delete_field/> <read_field/> <arguments> <argument> <name>ROUTE_CODE</name> </argument> </arguments> <attributes/> <cluster_schema/> <remotesteps> <input> </input> <output> </output> </remotesteps> <GUI> <xloc>1184</xloc> <yloc>592</yloc> <draw>Y</draw> </GUI> </step> <step> <name>服务转发判断</name> <type>SwitchCase</type> <description/> <distribute>Y</distribute> <custom_distribution/> <copies>1</copies> <partitioning> <method>none</method> <schema_name/> </partitioning> <fieldname>ROUTE_CODE</fieldname> <use_contains>N</use_contains> <case_value_type>None</case_value_type> <case_value_format/> <case_value_decimal/> <case_value_group/> <default_target_step>会员管理转换</default_target_step> <cases> <case> <value>parking_order_count_day</value> <target_step>日订单服务转换</target_step> </case> <case> <value>parking_order_count_week</value> <target_step>周订单服务转换</target_step> </case> <case> <value>parking_order_biz</value> <target_step>订单服务转换</target_step> </case> <case> <value>parking_order_count_month</value> <target_step>月订单服务转换</target_step> </case> <case> <value>parking_park</value> <target_step>车场json转换</target_step> </case> <case> <value>parking_operation_company</value> <target_step>运营公司转换</target_step> </case> <case> <value>parking_recent_car_user</value> <target_step>会员管理转换</target_step> </case> <case> <value>parking_flow_count_day_new</value> <target_step>日车流量数据转换</target_step> </case> <case> <value>parking_flow_count_week_new</value> <target_step>周车流量数据转换</target_step> </case> <case> <value>parking_flow_count_month_new</value> <target_step>月车流量数据转换</target_step> </case> <case> <value>parking_car_user</value> <target_step>平台用户数据转换</target_step> </case> <case> <value>parking_zh_order_record</value> <target_step>订单支付数据转换</target_step> </case> </cases> <attributes/> <cluster_schema/> <remotesteps> <input> </input> <output> </output> </remotesteps> <GUI> <xloc>640</xloc> <yloc>240</yloc> <draw>Y</draw> </GUI> </step> <step> <name>订单ID不为空</name> <type>FilterRows</type> <description/> <distribute>Y</distribute> <custom_distribution/> <copies>1</copies> <partitioning> <method>none</method> <schema_name/> </partitioning> <send_true_to>订单同步更新</send_true_to> <send_false_to/> <compare> <condition> <negated>N</negated> <leftvalue>id</leftvalue> <function>IS NOT NULL</function> <rightvalue/> </condition> </compare> <attributes/> <cluster_schema/> <remotesteps> <input> </input> <output> </output> </remotesteps> <GUI> <xloc>864</xloc> <yloc>192</yloc> <draw>Y</draw> </GUI> </step> <step> <name>订单同步更新</name> <type>InsertUpdate</type> <description/> <distribute>Y</distribute> <custom_distribution/> <copies>1</copies> <partitioning> <method>none</method> <schema_name/> </partitioning> <connection>target-people-livelihood-callcenter</connection> <commit>100</commit> <update_bypassed>N</update_bypassed> <lookup> <schema>casic_people_livelihood</schema> <table>parking_zh_order_biz</table> <key> <name>ID</name> <field>ID</field> <condition>=</condition> <name2/> </key> <value> <name>id</name> <rename>id</rename> <update>N</update> </value> <value> <name>biz_code</name> <rename>biz_code</rename> <update>Y</update> </value> <value> <name>car_no</name> <rename>car_no</rename> <update>Y</update> </value> <value> <name>park_id</name> <rename>park_id</rename> <update>Y</update> </value> <value> <name>car_user_id</name> <rename>car_user_id</rename> <update>Y</update> </value> <value> <name>in_time</name> <rename>in_time</rename> <update>Y</update> </value> <value> <name>out_time</name> <rename>out_time</rename> <update>Y</update> </value> <value> <name>card_type</name> <rename>card_type</rename> <update>Y</update> </value> <value> <name>client_type</name> <rename>client_type</rename> <update>Y</update> </value> <value> <name>create_time</name> <rename>create_time</rename> <update>Y</update> </value> <value> <name>update_time</name> <rename>update_time</rename> <update>Y</update> </value> <value> <name>receivable</name> <rename>receivable</rename> <update>Y</update> </value> <value> <name>ths_biz_code</name> <rename>ths_biz_code</rename> <update>Y</update> </value> <value> <name>status</name> <rename>status</rename> <update>Y</update> </value> <value> <name>car_no_type</name> <rename>car_no_type</rename> <update>Y</update> </value> <value> <name>version</name> <rename>version</rename> <update>Y</update> </value> <value> <name>in_channel_id</name> <rename>in_channel_id</rename> <update>Y</update> </value> <value> <name>out_channel_id</name> <rename>out_channel_id</rename> <update>Y</update> </value> <value> <name>car_in_img_url</name> <rename>car_in_img_url</rename> <update>Y</update> </value> <value> <name>car_out_img_url</name> <rename>car_out_img_url</rename> <update>Y</update> </value> <value> <name>car_in_channel_name</name> <rename>car_in_channel_name</rename> <update>Y</update> </value> <value> <name>car_out_channel_name</name> <rename>car_out_channel_name</rename> <update>Y</update> </value> <value> <name>car_in_channel_no</name> <rename>car_in_channel_no</rename> <update>Y</update> </value> <value> <name>car_out_channel_no</name> <rename>car_out_channel_no</rename> <update>Y</update> </value> <value> <name>car_in_operate_user</name> <rename>car_in_operate_user</rename> <update>Y</update> </value> <value> <name>car_out_operate_user</name> <rename>car_out_operate_user</rename> <update>Y</update> </value> <value> <name>total_receivable</name> <rename>total_receivable</rename> <update>Y</update> </value> <value> <name>total_received</name> <rename>total_received</rename> <update>Y</update> </value> <value> <name>biz_type</name> <rename>biz_type</rename> <update>Y</update> </value> <value> <name>car_no_sign_type</name> <rename>car_no_sign_type</rename> <update>Y</update> </value> <value> <name>third_party_serial_no</name> <rename>third_party_serial_no</rename> <update>Y</update> </value> <value> <name>updatestatus</name> <rename>updatestatus</rename> <update>Y</update> </value> <value> <name>updatetime</name> <rename>updatetime</rename> <update>Y</update> </value> </lookup> <attributes/> <cluster_schema/> <remotesteps> <input> </input> <output> </output> </remotesteps> <GUI> <xloc>1008</xloc> <yloc>192</yloc> <draw>Y</draw> </GUI> </step> <step> <name>订单支付ID不为空</name> <type>FilterRows</type> <description/> <distribute>Y</distribute> <custom_distribution/> <copies>1</copies> <partitioning> <method>none</method> <schema_name/> </partitioning> <send_true_to>订单支付同步更新</send_true_to> <send_false_to/> <compare> <condition> <negated>N</negated> <leftvalue>id</leftvalue> <function>IS NOT NULL</function> <rightvalue/> </condition> </compare> <attributes/> <cluster_schema/> <remotesteps> <input> </input> <output> </output> </remotesteps> <GUI> <xloc>416</xloc> <yloc>448</yloc> <draw>Y</draw> </GUI> </step> <step> <name>订单支付同步更新</name> <type>InsertUpdate</type> <description/> <distribute>Y</distribute> <custom_distribution/> <copies>1</copies> <partitioning> <method>none</method> <schema_name/> </partitioning> <connection>target-people-livelihood-callcenter</connection> <commit>100</commit> <update_bypassed>N</update_bypassed> <lookup> <schema>casic_people_livelihood</schema> <table>parking_zh_order_record</table> <key> <name>ID</name> <field>ID</field> <condition>=</condition> <name2/> </key> <value> <name>id</name> <rename>id</rename> <update>Y</update> </value> <value> <name>order_no</name> <rename>order_no</rename> <update>Y</update> </value> <value> <name>park_id</name> <rename>park_id</rename> <update>Y</update> </value> <value> <name>car_no</name> <rename>car_no</rename> <update>Y</update> </value> <value> <name>car_user_id</name> <rename>car_user_id</rename> <update>Y</update> </value> <value> <name>biz_code</name> <rename>biz_code</rename> <update>Y</update> </value> <value> <name>order_type</name> <rename>order_type</rename> <update>Y</update> </value> <value> <name>coupon_detail_id</name> <rename>coupon_detail_id</rename> <update>Y</update> </value> <value> <name>pay_type</name> <rename>pay_type</rename> <update>Y</update> </value> <value> <name>pay_code</name> <rename>pay_code</rename> <update>Y</update> </value> <value> <name>trade_no</name> <rename>trade_no</rename> <update>Y</update> </value> <value> <name>receivable_amount</name> <rename>receivable_amount</rename> <update>Y</update> </value> <value> <name>receive_amount</name> <rename>receive_amount</rename> <update>Y</update> </value> <value> <name>local_receive_amount</name> <rename>local_receive_amount</rename> <update>Y</update> </value> <value> <name>online_receive_amount</name> <rename>online_receive_amount</rename> <update>Y</update> </value> <value> <name>create_time</name> <rename>create_time</rename> <update>Y</update> </value> <value> <name>update_time</name> <rename>update_time</rename> <update>Y</update> </value> <value> <name>version</name> <rename>version</rename> <update>Y</update> </value> <value> <name>status</name> <rename>status</rename> <update>Y</update> </value> <value> <name>sync_status</name> <rename>sync_status</rename> <update>Y</update> </value> <value> <name>updatestatus</name> <rename>updatestatus</rename> <update>Y</update> </value> <value> <name>updatetime</name> <rename>updatetime</rename> <update>Y</update> </value> </lookup> <attributes/> <cluster_schema/> <remotesteps> <input> </input> <output> </output> </remotesteps> <GUI> <xloc>240</xloc> <yloc>448</yloc> <draw>Y</draw> </GUI> </step> <step> <name>订单支付数据转换</name> <type>JsonInput</type> <description/> <distribute>Y</distribute> <custom_distribution/> <copies>1</copies> <partitioning> <method>none</method> <schema_name/> </partitioning> <include>N</include> <include_field/> <rownum>N</rownum> <addresultfile>N</addresultfile> <readurl>N</readurl> <removeSourceField>N</removeSourceField> <IsIgnoreEmptyFile>N</IsIgnoreEmptyFile> <doNotFailIfNoFile>Y</doNotFailIfNoFile> <ignoreMissingPath>Y</ignoreMissingPath> <defaultPathLeafToNull>Y</defaultPathLeafToNull> <rownum_field/> <file> <name/> <filemask/> <exclude_filemask/> <file_required>N</file_required> <include_subfolders>N</include_subfolders> </file> <fields> <field> <name>id</name> <path>$..ID</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>order_no</name> <path>$..ORDER_NO</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>park_id</name> <path>$..PARK_ID</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>car_no</name> <path>$..CAR_NO</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>car_user_id</name> <path>$..CAR_USER_ID</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>biz_code</name> <path>$..BIZ_CODE</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>order_type</name> <path>$..ORDER_TYPE</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>coupon_detail_id</name> <path>$..COUPON_DETAIL_ID</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>pay_type</name> <path>$..PAY_TYPE</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>pay_code</name> <path>$..PAY_CODE</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>trade_no</name> <path>$..TRADE_NO</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>receivable_amount</name> <path>$..RECEIVABLE_AMOUNT</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>receive_amount</name> <path>$..RECEIVE_AMOUNT</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>local_receive_amount</name> <path>$..LOCAL_RECEIVE_AMOUNT</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>online_receive_amount</name> <path>$..ONLINE_RECEIVE_AMOUNT</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>create_time</name> <path>$..CREATE_TIME</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>update_time</name> <path>$..UPDATE_TIME</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>version</name> <path>$..VERSION</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>status</name> <path>$..STATUS</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>sync_status</name> <path>$..SYNC_STATUS</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>updatestatus</name> <path>$..UPDATESTATUS</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>updatetime</name> <path>$..UPDATETIME</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> </fields> <limit>0</limit> <IsInFields>Y</IsInFields> <IsAFile>N</IsAFile> <valueField>result</valueField> <shortFileFieldName/> <pathFieldName/> <hiddenFieldName/> <lastModificationTimeFieldName/> <uriNameFieldName/> <rootUriNameFieldName/> <extensionFieldName/> <sizeFieldName/> <attributes/> <cluster_schema/> <remotesteps> <input> </input> <output> </output> </remotesteps> <GUI> <xloc>544</xloc> <yloc>448</yloc> <draw>Y</draw> </GUI> </step> <step> <name>订单支付更新增量时间(偏移1小时)</name> <type>ExecSQL</type> <description/> <distribute>Y</distribute> <custom_distribution/> <copies>1</copies> <partitioning> <method>none</method> <schema_name/> </partitioning> <connection>opt-monitoring-11.100.6.163</connection> <execute_each_row>Y</execute_each_row> <single_statement>N</single_statement> <replace_variables>N</replace_variables> <quoteString>N</quoteString> <sql>update kettle_increment_config set REST_PARAMS=DATE_FORMAT(date_sub(now(), interval 1 hour) ,'%Y-%m-%d %H:%i:%s') where code ='?'</sql> <set_params>N</set_params> <insert_field/> <update_field/> <delete_field/> <read_field/> <arguments> <argument> <name>ROUTE_CODE</name> </argument> </arguments> <attributes/> <cluster_schema/> <remotesteps> <input> </input> <output> </output> </remotesteps> <GUI> <xloc>80</xloc> <yloc>448</yloc> <draw>Y</draw> </GUI> </step> <step> <name>订单更新增量时间(偏移1小时)</name> <type>ExecSQL</type> <description/> <distribute>Y</distribute> <custom_distribution/> <copies>1</copies> <partitioning> <method>none</method> <schema_name/> </partitioning> <connection>opt-monitoring-11.100.6.163</connection> <execute_each_row>Y</execute_each_row> <single_statement>N</single_statement> <replace_variables>N</replace_variables> <quoteString>N</quoteString> <sql>update kettle_increment_config set REST_PARAMS=DATE_FORMAT(date_sub(now(), interval 1 hour) ,'%Y-%m-%d %H:%i:%s') where code ='parking_order_biz'</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>1120</xloc> <yloc>192</yloc> <draw>Y</draw> </GUI> </step> <step> <name>订单服务转换</name> <type>JsonInput</type> <description/> <distribute>Y</distribute> <custom_distribution/> <copies>1</copies> <partitioning> <method>none</method> <schema_name/> </partitioning> <include>N</include> <include_field/> <rownum>N</rownum> <addresultfile>N</addresultfile> <readurl>N</readurl> <removeSourceField>N</removeSourceField> <IsIgnoreEmptyFile>N</IsIgnoreEmptyFile> <doNotFailIfNoFile>Y</doNotFailIfNoFile> <ignoreMissingPath>Y</ignoreMissingPath> <defaultPathLeafToNull>Y</defaultPathLeafToNull> <rownum_field/> <file> <name/> <filemask/> <exclude_filemask/> <file_required>N</file_required> <include_subfolders>N</include_subfolders> </file> <fields> <field> <name>id</name> <path>$..ID</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>biz_code</name> <path>$..BIZ_CODE</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>car_no</name> <path>$..CAR_NO</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>park_id</name> <path>$..PARK_ID</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>car_user_id</name> <path>$..CAR_USER_ID</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>in_time</name> <path>$..IN_TIME</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>out_time</name> <path>$..OUT_TIME</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>card_type</name> <path>$..CARD_TYPE</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>client_type</name> <path>$..CLIENT_TYPE</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>create_time</name> <path>$..CREATE_TIME</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>update_time</name> <path>$..UPDATE_TIME</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>19</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>receivable</name> <path>$..RECEIVABLE</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>ths_biz_code</name> <path>$..THS_BIZ_CODE</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>status</name> <path>$..STATUS</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>car_no_type</name> <path>$..CAR_NO_TYPE</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>version</name> <path>$..VERSION</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>in_channel_id</name> <path>$..IN_CHANNEL_ID</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>out_channel_id</name> <path>$..OUT_CHANNEL_ID</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>car_in_img_url</name> <path>$..CAR_IN_IMG_URL</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>car_out_img_url</name> <path>$..CAR_OUT_IMG_URL</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>car_in_channel_name</name> <path>$..CAR_IN_CHANNEL_NAME</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>car_out_channel_name</name> <path>$..CAR_OUT_CHANNEL_NAME</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>car_in_channel_no</name> <path>$..CAR_IN_CHANNEL_NO</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>car_out_channel_no</name> <path>$..CAR_OUT_CHANNEL_NO</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>car_in_operate_user</name> <path>$..CAR_IN_OPERATE_USER</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>car_out_operate_user</name> <path>$..CAR_OUT_OPERATE_USER</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>total_receivable</name> <path>$..TOTAL_RECEIVABLE</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>total_received</name> <path>$..TOTAL_RECEIVED</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>biz_type</name> <path>$..BIZ_TYPE</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>car_no_sign_type</name> <path>$..CAR_NO_SIGN_TYPE</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>third_party_serial_no</name> <path>$..THIRD_PARTY_SERIAL_NO</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>updatestatus</name> <path>$..UPDATESTATUS</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>updatetime</name> <path>$..UPDATETIME</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> </fields> <limit>0</limit> <IsInFields>Y</IsInFields> <IsAFile>N</IsAFile> <valueField>result</valueField> <shortFileFieldName/> <pathFieldName/> <hiddenFieldName/> <lastModificationTimeFieldName/> <uriNameFieldName/> <rootUriNameFieldName/> <extensionFieldName/> <sizeFieldName/> <attributes/> <cluster_schema/> <remotesteps> <input> </input> <output> </output> </remotesteps> <GUI> <xloc>752</xloc> <yloc>192</yloc> <draw>Y</draw> </GUI> </step> <step> <name>读取车场日订单信息</name> <type>TableInput</type> <description/> <distribute>Y</distribute> <custom_distribution/> <copies>1</copies> <partitioning> <method>none</method> <schema_name/> </partitioning> <connection>opt-monitoring-11.100.6.163</connection> <sql>SELECT REST_RULE ,IS_ENCODE ,REST_PARAMS ,concat(HOST,DEFAULT_PARAMS) as HOST ,DATE_FORMAT(NOW(),'%Y-%m-%d %H:%i:%s') as CURR_INCREMENT_DATE ,code as ROUTE_CODE FROM casic_optmonitoring.kettle_increment_config where code like 'parking_%' and host !=''</sql> <limit>0</limit> <lookup/> <execute_each_row>N</execute_each_row> <variables_active>N</variables_active> <lazy_conversion_active>N</lazy_conversion_active> <cached_row_meta_active>N</cached_row_meta_active> <row-meta> <value-meta> <type>String</type> <storagetype>normal</storagetype> <name>REST_RULE</name> <length>255</length> <precision>-1</precision> <origin>读取车场日订单信息</origin> <comments>REST_RULE</comments> <conversion_Mask/> <decimal_symbol>.</decimal_symbol> <grouping_symbol>,</grouping_symbol> <currency_symbol/> <trim_type>none</trim_type> <case_insensitive>N</case_insensitive> <collator_disabled>Y</collator_disabled> <collator_strength>0</collator_strength> <sort_descending>N</sort_descending> <output_padding>N</output_padding> <date_format_lenient>N</date_format_lenient> <date_format_locale>zh_CN</date_format_locale> <date_format_timezone>Asia/Shanghai</date_format_timezone> <lenient_string_to_number>N</lenient_string_to_number> </value-meta> <value-meta> <type>String</type> <storagetype>normal</storagetype> <name>IS_ENCODE</name> <length>1</length> <precision>-1</precision> <origin>读取车场日订单信息</origin> <comments>IS_ENCODE</comments> <conversion_Mask/> <decimal_symbol>.</decimal_symbol> <grouping_symbol>,</grouping_symbol> <currency_symbol/> <trim_type>none</trim_type> <case_insensitive>N</case_insensitive> <collator_disabled>Y</collator_disabled> <collator_strength>0</collator_strength> <sort_descending>N</sort_descending> <output_padding>N</output_padding> <date_format_lenient>N</date_format_lenient> <date_format_locale>zh_CN</date_format_locale> <date_format_timezone>Asia/Shanghai</date_format_timezone> <lenient_string_to_number>N</lenient_string_to_number> </value-meta> <value-meta> <type>String</type> <storagetype>normal</storagetype> <name>REST_PARAMS</name> <length>255</length> <precision>-1</precision> <origin>读取车场日订单信息</origin> <comments>REST_PARAMS</comments> <conversion_Mask/> <decimal_symbol>.</decimal_symbol> <grouping_symbol>,</grouping_symbol> <currency_symbol/> <trim_type>none</trim_type> <case_insensitive>N</case_insensitive> <collator_disabled>Y</collator_disabled> <collator_strength>0</collator_strength> <sort_descending>N</sort_descending> <output_padding>N</output_padding> <date_format_lenient>N</date_format_lenient> <date_format_locale>zh_CN</date_format_locale> <date_format_timezone>Asia/Shanghai</date_format_timezone> <lenient_string_to_number>N</lenient_string_to_number> </value-meta> <value-meta> <type>String</type> <storagetype>normal</storagetype> <name>HOST</name> <length>319</length> <precision>-1</precision> <origin>读取车场日订单信息</origin> <comments>HOST</comments> <conversion_Mask/> <decimal_symbol>.</decimal_symbol> <grouping_symbol>,</grouping_symbol> <currency_symbol/> <trim_type>none</trim_type> <case_insensitive>N</case_insensitive> <collator_disabled>Y</collator_disabled> <collator_strength>0</collator_strength> <sort_descending>N</sort_descending> <output_padding>N</output_padding> <date_format_lenient>N</date_format_lenient> <date_format_locale>zh_CN</date_format_locale> <date_format_timezone>Asia/Shanghai</date_format_timezone> <lenient_string_to_number>N</lenient_string_to_number> </value-meta> <value-meta> <type>String</type> <storagetype>normal</storagetype> <name>CURR_INCREMENT_DATE</name> <length>24</length> <precision>-1</precision> <origin>读取车场日订单信息</origin> <comments>CURR_INCREMENT_DATE</comments> <conversion_Mask/> <decimal_symbol>.</decimal_symbol> <grouping_symbol>,</grouping_symbol> <currency_symbol/> <trim_type>none</trim_type> <case_insensitive>N</case_insensitive> <collator_disabled>Y</collator_disabled> <collator_strength>0</collator_strength> <sort_descending>N</sort_descending> <output_padding>N</output_padding> <date_format_lenient>N</date_format_lenient> <date_format_locale>zh_CN</date_format_locale> <date_format_timezone>Asia/Shanghai</date_format_timezone> <lenient_string_to_number>N</lenient_string_to_number> </value-meta> <value-meta> <type>String</type> <storagetype>normal</storagetype> <name>ROUTE_CODE</name> <length>32</length> <precision>-1</precision> <origin>读取车场日订单信息</origin> <comments>ROUTE_CODE</comments> <conversion_Mask/> <decimal_symbol>.</decimal_symbol> <grouping_symbol>,</grouping_symbol> <currency_symbol/> <trim_type>none</trim_type> <case_insensitive>N</case_insensitive> <collator_disabled>Y</collator_disabled> <collator_strength>0</collator_strength> <sort_descending>N</sort_descending> <output_padding>N</output_padding> <date_format_lenient>N</date_format_lenient> <date_format_locale>zh_CN</date_format_locale> <date_format_timezone>Asia/Shanghai</date_format_timezone> <lenient_string_to_number>N</lenient_string_to_number> </value-meta> </row-meta> <attributes/> <cluster_schema/> <remotesteps> <input> </input> <output> </output> </remotesteps> <GUI> <xloc>160</xloc> <yloc>240</yloc> <draw>Y</draw> </GUI> </step> <step> <name>车场ID不为空</name> <type>FilterRows</type> <description/> <distribute>Y</distribute> <custom_distribution/> <copies>1</copies> <partitioning> <method>none</method> <schema_name/> </partitioning> <send_true_to>车场同步更新</send_true_to> <send_false_to/> <compare> <condition> <negated>N</negated> <leftvalue>id</leftvalue> <function>IS NOT NULL</function> <rightvalue/> </condition> </compare> <attributes/> <cluster_schema/> <remotesteps> <input> </input> <output> </output> </remotesteps> <GUI> <xloc>384</xloc> <yloc>128</yloc> <draw>Y</draw> </GUI> </step> <step> <name>车场json转换</name> <type>JsonInput</type> <description/> <distribute>Y</distribute> <custom_distribution/> <copies>1</copies> <partitioning> <method>none</method> <schema_name/> </partitioning> <include>N</include> <include_field/> <rownum>N</rownum> <addresultfile>N</addresultfile> <readurl>N</readurl> <removeSourceField>N</removeSourceField> <IsIgnoreEmptyFile>N</IsIgnoreEmptyFile> <doNotFailIfNoFile>Y</doNotFailIfNoFile> <ignoreMissingPath>Y</ignoreMissingPath> <defaultPathLeafToNull>Y</defaultPathLeafToNull> <rownum_field/> <file> <name/> <filemask/> <exclude_filemask/> <file_required>N</file_required> <include_subfolders>N</include_subfolders> </file> <fields> <field> <name>code</name> <path>$..CODE</path> <type>String</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>id</name> <path>$..ID</path> <type>String</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>name</name> <path>$..NAME</path> <type>String</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>flag</name> <path>$..FLAG</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>total</name> <path>$..TOTAL</path> <type>String</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>empty</name> <path>$..EMPTY</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> </fields> <limit>0</limit> <IsInFields>Y</IsInFields> <IsAFile>N</IsAFile> <valueField>result</valueField> <shortFileFieldName/> <pathFieldName/> <hiddenFieldName/> <lastModificationTimeFieldName/> <uriNameFieldName/> <rootUriNameFieldName/> <extensionFieldName/> <sizeFieldName/> <attributes/> <cluster_schema/> <remotesteps> <input> </input> <output> </output> </remotesteps> <GUI> <xloc>480</xloc> <yloc>128</yloc> <draw>Y</draw> </GUI> </step> <step> <name>车场同步更新</name> <type>InsertUpdate</type> <description/> <distribute>Y</distribute> <custom_distribution/> <copies>1</copies> <partitioning> <method>none</method> <schema_name/> </partitioning> <connection>target-people-livelihood-callcenter</connection> <commit>100</commit> <update_bypassed>N</update_bypassed> <lookup> <schema>casic_people_livelihood</schema> <table>parking_park</table> <key> <name>ID</name> <field>ID</field> <condition>=</condition> <name2/> </key> <value> <name>code</name> <rename>code</rename> <update>N</update> </value> <value> <name>id</name> <rename>id</rename> <update>Y</update> </value> <value> <name>name</name> <rename>name</rename> <update>Y</update> </value> <value> <name>flag</name> <rename>flag</rename> <update>Y</update> </value> <value> <name>total</name> <rename>total</rename> <update>Y</update> </value> <value> <name>empty</name> <rename>empty</rename> <update>Y</update> </value> </lookup> <attributes/> <cluster_schema/> <remotesteps> <input> </input> <output> </output> </remotesteps> <GUI> <xloc>272</xloc> <yloc>128</yloc> <draw>Y</draw> </GUI> </step> <step> <name>运营公司同步更新</name> <type>InsertUpdate</type> <description/> <distribute>Y</distribute> <custom_distribution/> <copies>1</copies> <partitioning> <method>none</method> <schema_name/> </partitioning> <connection>target-people-livelihood-callcenter</connection> <commit>100</commit> <update_bypassed>N</update_bypassed> <lookup> <schema>casic_people_livelihood</schema> <table>parking_ths_operation_company</table> <key> <name>ID</name> <field>ID</field> <condition>=</condition> <name2/> </key> <value> <name>id</name> <rename>id</rename> <update>N</update> </value> <value> <name>operation_id</name> <rename>operation_id</rename> <update>Y</update> </value> <value> <name>linkman</name> <rename>linkman</rename> <update>Y</update> </value> <value> <name>linkmobile</name> <rename>linkmobile</rename> <update>Y</update> </value> <value> <name>legalpersonname</name> <rename>legalpersonname</rename> <update>Y</update> </value> <value> <name>legalmobile</name> <rename>legalmobile</rename> <update>Y</update> </value> <value> <name>incity</name> <rename>incity</rename> <update>Y</update> </value> <value> <name>parkingcount</name> <rename>parkingcount</rename> <update>Y</update> </value> <value> <name>managecitycount</name> <rename>managecitycount</rename> <update>Y</update> </value> <value> <name>companyname</name> <rename>companyname</rename> <update>Y</update> </value> <value> <name>originalstock</name> <rename>originalstock</rename> <update>Y</update> </value> <value> <name>existingstock</name> <rename>existingstock</rename> <update>Y</update> </value> <value> <name>updatestatus</name> <rename>updatestatus</rename> <update>Y</update> </value> <value> <name>updatetime</name> <rename>updatetime</rename> <update>Y</update> </value> </lookup> <attributes/> <cluster_schema/> <remotesteps> <input> </input> <output> </output> </remotesteps> <GUI> <xloc>1008</xloc> <yloc>272</yloc> <draw>Y</draw> </GUI> </step> <step> <name>运营公司更新增量时间(偏移1小时) </name> <type>ExecSQL</type> <description/> <distribute>Y</distribute> <custom_distribution/> <copies>1</copies> <partitioning> <method>none</method> <schema_name/> </partitioning> <connection>opt-monitoring-11.100.6.163</connection> <execute_each_row>Y</execute_each_row> <single_statement>N</single_statement> <replace_variables>N</replace_variables> <quoteString>N</quoteString> <sql>update kettle_increment_config set REST_PARAMS=DATE_FORMAT(date_sub(now(), interval 1 hour) ,'%Y-%m-%d %H:%i:%s') where code ='parking_operation_company'</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>1136</xloc> <yloc>272</yloc> <draw>Y</draw> </GUI> </step> <step> <name>运营公司转换</name> <type>JsonInput</type> <description/> <distribute>Y</distribute> <custom_distribution/> <copies>1</copies> <partitioning> <method>none</method> <schema_name/> </partitioning> <include>N</include> <include_field/> <rownum>N</rownum> <addresultfile>N</addresultfile> <readurl>N</readurl> <removeSourceField>N</removeSourceField> <IsIgnoreEmptyFile>N</IsIgnoreEmptyFile> <doNotFailIfNoFile>Y</doNotFailIfNoFile> <ignoreMissingPath>Y</ignoreMissingPath> <defaultPathLeafToNull>Y</defaultPathLeafToNull> <rownum_field/> <file> <name/> <filemask/> <exclude_filemask/> <file_required>N</file_required> <include_subfolders>N</include_subfolders> </file> <fields> <field> <name>id</name> <path>$..ID</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>operation_id</name> <path>$..OPERATION_ID</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>linkman</name> <path>$..LINKMAN</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>linkmobile</name> <path>$..LINKMOBILE</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>legalpersonname</name> <path>$..LEGALPERSONNAME</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>legalmobile</name> <path>$..LEGALMOBILE</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>incity</name> <path>$..INCITY</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>parkingcount</name> <path>$..PARKINGCOUNT</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>managecitycount</name> <path>$..MANAGECITYCOUNT</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>companyname</name> <path>$..COMPANYNAME</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>originalstock</name> <path>$..ORIGINALSTOCK</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>existingstock</name> <path>$..EXISTINGSTOCK</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>updatestatus</name> <path>$..UPDATESTATUS</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> <field> <name>updatetime</name> <path>$..UPDATETIME</path> <type>None</type> <format/> <currency/> <decimal/> <group/> <length>-1</length> <precision>-1</precision> <trim_type>none</trim_type> <repeat>N</repeat> </field> </fields> <limit>0</limit> <IsInFields>Y</IsInFields> <IsAFile>N</IsAFile> <valueField>result</valueField> <shortFileFieldName/> <pathFieldName/> <hiddenFieldName/> <lastModificationTimeFieldName/> <uriNameFieldName/> <rootUriNameFieldName/> <extensionFieldName/> <sizeFieldName/> <attributes/> <cluster_schema/> <remotesteps> <input> </input> <output> </output> </remotesteps> <GUI> <xloc>752</xloc> <yloc>272</yloc> <draw>Y</draw> </GUI> </step> <step> <name>运营公司转换ID不为空</name> <type>FilterRows</type> <description/> <distribute>Y</distribute> <custom_distribution/> <copies>1</copies> <partitioning> <method>none</method> <schema_name/> </partitioning> <send_true_to>运营公司同步更新</send_true_to> <send_false_to/> <compare> <condition> <negated>N</negated> <leftvalue>id</leftvalue> <function>IS NOT NULL</function> <rightvalue/> </condition> </compare> <attributes/> <cluster_schema/> <remotesteps> <input> </input> <output> </output> </remotesteps> <GUI> <xloc>864</xloc> <yloc>272</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>