123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041 |
- <?xml version="1.0" encoding="UTF-8"?>
- <transformation>
- <info>
- <name>mem_memberext_temp_etl_nojava</name>
- <description/>
- <extended_description/>
- <trans_version/>
- <trans_type>Normal</trans_type>
- <trans_status>0</trans_status>
- <directory>/</directory>
- <parameters>
- </parameters>
- <log>
- <trans-log-table>
- <connection/>
- <schema/>
- <table/>
- <size_limit_lines/>
- <interval/>
- <timeout_days/>
- <field>
- <id>ID_BATCH</id>
- <enabled>Y</enabled>
- <name>ID_BATCH</name>
- </field>
- <field>
- <id>CHANNEL_ID</id>
- <enabled>Y</enabled>
- <name>CHANNEL_ID</name>
- </field>
- <field>
- <id>TRANSNAME</id>
- <enabled>Y</enabled>
- <name>TRANSNAME</name>
- </field>
- <field>
- <id>STATUS</id>
- <enabled>Y</enabled>
- <name>STATUS</name>
- </field>
- <field>
- <id>LINES_READ</id>
- <enabled>Y</enabled>
- <name>LINES_READ</name>
- <subject/>
- </field>
- <field>
- <id>LINES_WRITTEN</id>
- <enabled>Y</enabled>
- <name>LINES_WRITTEN</name>
- <subject/>
- </field>
- <field>
- <id>LINES_UPDATED</id>
- <enabled>Y</enabled>
- <name>LINES_UPDATED</name>
- <subject/>
- </field>
- <field>
- <id>LINES_INPUT</id>
- <enabled>Y</enabled>
- <name>LINES_INPUT</name>
- <subject/>
- </field>
- <field>
- <id>LINES_OUTPUT</id>
- <enabled>Y</enabled>
- <name>LINES_OUTPUT</name>
- <subject/>
- </field>
- <field>
- <id>LINES_REJECTED</id>
- <enabled>Y</enabled>
- <name>LINES_REJECTED</name>
- <subject/>
- </field>
- <field>
- <id>ERRORS</id>
- <enabled>Y</enabled>
- <name>ERRORS</name>
- </field>
- <field>
- <id>STARTDATE</id>
- <enabled>Y</enabled>
- <name>STARTDATE</name>
- </field>
- <field>
- <id>ENDDATE</id>
- <enabled>Y</enabled>
- <name>ENDDATE</name>
- </field>
- <field>
- <id>LOGDATE</id>
- <enabled>Y</enabled>
- <name>LOGDATE</name>
- </field>
- <field>
- <id>DEPDATE</id>
- <enabled>Y</enabled>
- <name>DEPDATE</name>
- </field>
- <field>
- <id>REPLAYDATE</id>
- <enabled>Y</enabled>
- <name>REPLAYDATE</name>
- </field>
- <field>
- <id>LOG_FIELD</id>
- <enabled>Y</enabled>
- <name>LOG_FIELD</name>
- </field>
- <field>
- <id>EXECUTING_SERVER</id>
- <enabled>N</enabled>
- <name>EXECUTING_SERVER</name>
- </field>
- <field>
- <id>EXECUTING_USER</id>
- <enabled>N</enabled>
- <name>EXECUTING_USER</name>
- </field>
- <field>
- <id>CLIENT</id>
- <enabled>N</enabled>
- <name>CLIENT</name>
- </field>
- </trans-log-table>
- <perf-log-table>
- <connection/>
- <schema/>
- <table/>
- <interval/>
- <timeout_days/>
- <field>
- <id>ID_BATCH</id>
- <enabled>Y</enabled>
- <name>ID_BATCH</name>
- </field>
- <field>
- <id>SEQ_NR</id>
- <enabled>Y</enabled>
- <name>SEQ_NR</name>
- </field>
- <field>
- <id>LOGDATE</id>
- <enabled>Y</enabled>
- <name>LOGDATE</name>
- </field>
- <field>
- <id>TRANSNAME</id>
- <enabled>Y</enabled>
- <name>TRANSNAME</name>
- </field>
- <field>
- <id>STEPNAME</id>
- <enabled>Y</enabled>
- <name>STEPNAME</name>
- </field>
- <field>
- <id>STEP_COPY</id>
- <enabled>Y</enabled>
- <name>STEP_COPY</name>
- </field>
- <field>
- <id>LINES_READ</id>
- <enabled>Y</enabled>
- <name>LINES_READ</name>
- </field>
- <field>
- <id>LINES_WRITTEN</id>
- <enabled>Y</enabled>
- <name>LINES_WRITTEN</name>
- </field>
- <field>
- <id>LINES_UPDATED</id>
- <enabled>Y</enabled>
- <name>LINES_UPDATED</name>
- </field>
- <field>
- <id>LINES_INPUT</id>
- <enabled>Y</enabled>
- <name>LINES_INPUT</name>
- </field>
- <field>
- <id>LINES_OUTPUT</id>
- <enabled>Y</enabled>
- <name>LINES_OUTPUT</name>
- </field>
- <field>
- <id>LINES_REJECTED</id>
- <enabled>Y</enabled>
- <name>LINES_REJECTED</name>
- </field>
- <field>
- <id>ERRORS</id>
- <enabled>Y</enabled>
- <name>ERRORS</name>
- </field>
- <field>
- <id>INPUT_BUFFER_ROWS</id>
- <enabled>Y</enabled>
- <name>INPUT_BUFFER_ROWS</name>
- </field>
- <field>
- <id>OUTPUT_BUFFER_ROWS</id>
- <enabled>Y</enabled>
- <name>OUTPUT_BUFFER_ROWS</name>
- </field>
- </perf-log-table>
- <channel-log-table>
- <connection/>
- <schema/>
- <table/>
- <timeout_days/>
- <field>
- <id>ID_BATCH</id>
- <enabled>Y</enabled>
- <name>ID_BATCH</name>
- </field>
- <field>
- <id>CHANNEL_ID</id>
- <enabled>Y</enabled>
- <name>CHANNEL_ID</name>
- </field>
- <field>
- <id>LOG_DATE</id>
- <enabled>Y</enabled>
- <name>LOG_DATE</name>
- </field>
- <field>
- <id>LOGGING_OBJECT_TYPE</id>
- <enabled>Y</enabled>
- <name>LOGGING_OBJECT_TYPE</name>
- </field>
- <field>
- <id>OBJECT_NAME</id>
- <enabled>Y</enabled>
- <name>OBJECT_NAME</name>
- </field>
- <field>
- <id>OBJECT_COPY</id>
- <enabled>Y</enabled>
- <name>OBJECT_COPY</name>
- </field>
- <field>
- <id>REPOSITORY_DIRECTORY</id>
- <enabled>Y</enabled>
- <name>REPOSITORY_DIRECTORY</name>
- </field>
- <field>
- <id>FILENAME</id>
- <enabled>Y</enabled>
- <name>FILENAME</name>
- </field>
- <field>
- <id>OBJECT_ID</id>
- <enabled>Y</enabled>
- <name>OBJECT_ID</name>
- </field>
- <field>
- <id>OBJECT_REVISION</id>
- <enabled>Y</enabled>
- <name>OBJECT_REVISION</name>
- </field>
- <field>
- <id>PARENT_CHANNEL_ID</id>
- <enabled>Y</enabled>
- <name>PARENT_CHANNEL_ID</name>
- </field>
- <field>
- <id>ROOT_CHANNEL_ID</id>
- <enabled>Y</enabled>
- <name>ROOT_CHANNEL_ID</name>
- </field>
- </channel-log-table>
- <step-log-table>
- <connection/>
- <schema/>
- <table/>
- <timeout_days/>
- <field>
- <id>ID_BATCH</id>
- <enabled>Y</enabled>
- <name>ID_BATCH</name>
- </field>
- <field>
- <id>CHANNEL_ID</id>
- <enabled>Y</enabled>
- <name>CHANNEL_ID</name>
- </field>
- <field>
- <id>LOG_DATE</id>
- <enabled>Y</enabled>
- <name>LOG_DATE</name>
- </field>
- <field>
- <id>TRANSNAME</id>
- <enabled>Y</enabled>
- <name>TRANSNAME</name>
- </field>
- <field>
- <id>STEPNAME</id>
- <enabled>Y</enabled>
- <name>STEPNAME</name>
- </field>
- <field>
- <id>STEP_COPY</id>
- <enabled>Y</enabled>
- <name>STEP_COPY</name>
- </field>
- <field>
- <id>LINES_READ</id>
- <enabled>Y</enabled>
- <name>LINES_READ</name>
- </field>
- <field>
- <id>LINES_WRITTEN</id>
- <enabled>Y</enabled>
- <name>LINES_WRITTEN</name>
- </field>
- <field>
- <id>LINES_UPDATED</id>
- <enabled>Y</enabled>
- <name>LINES_UPDATED</name>
- </field>
- <field>
- <id>LINES_INPUT</id>
- <enabled>Y</enabled>
- <name>LINES_INPUT</name>
- </field>
- <field>
- <id>LINES_OUTPUT</id>
- <enabled>Y</enabled>
- <name>LINES_OUTPUT</name>
- </field>
- <field>
- <id>LINES_REJECTED</id>
- <enabled>Y</enabled>
- <name>LINES_REJECTED</name>
- </field>
- <field>
- <id>ERRORS</id>
- <enabled>Y</enabled>
- <name>ERRORS</name>
- </field>
- <field>
- <id>LOG_FIELD</id>
- <enabled>N</enabled>
- <name>LOG_FIELD</name>
- </field>
- </step-log-table>
- <metrics-log-table>
- <connection/>
- <schema/>
- <table/>
- <timeout_days/>
- <field>
- <id>ID_BATCH</id>
- <enabled>Y</enabled>
- <name>ID_BATCH</name>
- </field>
- <field>
- <id>CHANNEL_ID</id>
- <enabled>Y</enabled>
- <name>CHANNEL_ID</name>
- </field>
- <field>
- <id>LOG_DATE</id>
- <enabled>Y</enabled>
- <name>LOG_DATE</name>
- </field>
- <field>
- <id>METRICS_DATE</id>
- <enabled>Y</enabled>
- <name>METRICS_DATE</name>
- </field>
- <field>
- <id>METRICS_CODE</id>
- <enabled>Y</enabled>
- <name>METRICS_CODE</name>
- </field>
- <field>
- <id>METRICS_DESCRIPTION</id>
- <enabled>Y</enabled>
- <name>METRICS_DESCRIPTION</name>
- </field>
- <field>
- <id>METRICS_SUBJECT</id>
- <enabled>Y</enabled>
- <name>METRICS_SUBJECT</name>
- </field>
- <field>
- <id>METRICS_TYPE</id>
- <enabled>Y</enabled>
- <name>METRICS_TYPE</name>
- </field>
- <field>
- <id>METRICS_VALUE</id>
- <enabled>Y</enabled>
- <name>METRICS_VALUE</name>
- </field>
- </metrics-log-table>
- </log>
- <maxdate>
- <connection/>
- <table/>
- <field/>
- <offset>0.0</offset>
- <maxdiff>0.0</maxdiff>
- </maxdate>
- <size_rowset>2</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>2019/05/21 19:06:33.293</created_date>
- <modified_user>-</modified_user>
- <modified_date>2019/05/21 19:06:33.293</modified_date>
- <key_for_session_key>H4sIAAAAAAAAAAMAAAAAAAAAAAA=</key_for_session_key>
- <is_key_private>N</is_key_private>
- </info>
- <notepads>
- </notepads>
- <connection>
- <name>MallSqlserver</name>
- <server>192.168.50.32</server>
- <type>MSSQLNATIVE</type>
- <access>Native</access>
- <database>Mall</database>
- <port>1433</port>
- <username>sa</username>
- <password>Encrypted 2be98afc819c69e8ea300ff228dd38f99</password>
- <servername/>
- <data_tablespace/>
- <index_tablespace/>
- <attributes>
- <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>MSSQLUseIntegratedSecurity</code>
- <attribute>false</attribute>
- </attribute>
- <attribute>
- <code>MSSQL_DOUBLE_DECIMAL_SEPARATOR</code>
- <attribute>N</attribute>
- </attribute>
- <attribute>
- <code>PORT_NUMBER</code>
- <attribute>1433</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>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>表输入 2</from>
- <to>Elasticsearch bulk insert 2</to>
- <enabled>Y</enabled>
- </hop>
- </order>
- <step>
- <name>Elasticsearch bulk insert 2</name>
- <type>ElasticSearchBulk</type>
- <description/>
- <distribute>Y</distribute>
- <custom_distribution/>
- <copies>30</copies>
- <partitioning>
- <method>none</method>
- <schema_name/>
- </partitioning>
- <general>
- <index>crm_memberext_temp</index>
- <type>_doc</type>
- <batchSize>3</batchSize>
- <timeout>100</timeout>
- <timeoutUnit>SECONDS</timeoutUnit>
- <isJson>N</isJson>
- <idField>MemKey</idField>
- <overwriteIfExists>Y</overwriteIfExists>
- <useOutput>N</useOutput>
- <stopOnError>Y</stopOnError>
- </general>
- <fields>
- <field>
- <columnName>AConsigneePhone1</columnName>
- <targetName>AConsigneePhone1</targetName>
- </field>
- <field>
- <columnName>AConsigneePhone2</columnName>
- <targetName>AConsigneePhone2</targetName>
- </field>
- <field>
- <columnName>AConsigneePhone3</columnName>
- <targetName>AConsigneePhone3</targetName>
- </field>
- <field>
- <columnName>ADeliveryAddress</columnName>
- <targetName>ADeliveryAddress</targetName>
- </field>
- <field>
- <columnName>AccountId</columnName>
- <targetName>AccountId</targetName>
- </field>
- <field>
- <columnName>AccountName</columnName>
- <targetName>AccountName</targetName>
- </field>
- <field>
- <columnName>AdvancePayType</columnName>
- <targetName>AdvancePayType</targetName>
- </field>
- <field>
- <columnName>AgainOrderCount</columnName>
- <targetName>AgainOrderCount</targetName>
- </field>
- <field>
- <columnName>Age</columnName>
- <targetName>Age</targetName>
- </field>
- <field>
- <columnName>BusinessId</columnName>
- <targetName>BusinessId</targetName>
- </field>
- <field>
- <columnName>BuyUserId</columnName>
- <targetName>BuyUserId</targetName>
- </field>
- <field>
- <columnName>ConfimLevel</columnName>
- <targetName>ConfimLevel</targetName>
- </field>
- <field>
- <columnName>ConfirmId</columnName>
- <targetName>ConfirmId</targetName>
- </field>
- <field>
- <columnName>ConsigneeType</columnName>
- <targetName>ConsigneeType</targetName>
- </field>
- <field>
- <columnName>CreationDate</columnName>
- <targetName>CreationDate</targetName>
- </field>
- <field>
- <columnName>CustomerCode</columnName>
- <targetName>CustomerCode</targetName>
- </field>
- <field>
- <columnName>CustomerDataId</columnName>
- <targetName>CustomerDataId</targetName>
- </field>
- <field>
- <columnName>CustomerName</columnName>
- <targetName>CustomerName</targetName>
- </field>
- <field>
- <columnName>DataId</columnName>
- <targetName>DataId</targetName>
- </field>
- <field>
- <columnName>DataName</columnName>
- <targetName>DataName</targetName>
- </field>
- <field>
- <columnName>DeliveryType</columnName>
- <targetName>DeliveryType</targetName>
- </field>
- <field>
- <columnName>DeliveryZipCode</columnName>
- <targetName>DeliveryZipCode</targetName>
- </field>
- <field>
- <columnName>DeptCode</columnName>
- <targetName>DeptCode</targetName>
- </field>
- <field>
- <columnName>DeptId</columnName>
- <targetName>DeptId</targetName>
- </field>
- <field>
- <columnName>DeviceType</columnName>
- <targetName>DeviceType</targetName>
- </field>
- <field>
- <columnName>Discountprice</columnName>
- <targetName>Discountprice</targetName>
- </field>
- <field>
- <columnName>DiseaseClassCode</columnName>
- <targetName>DiseaseClassCode</targetName>
- </field>
- <field>
- <columnName>HuaWuOriginType</columnName>
- <targetName>HuaWuOriginType</targetName>
- </field>
- <field>
- <columnName>Id</columnName>
- <targetName>Id</targetName>
- </field>
- <field>
- <columnName>InitSum</columnName>
- <targetName>InitSum</targetName>
- </field>
- <field>
- <columnName>InventoryAuditDate</columnName>
- <targetName>InventoryAuditDate</targetName>
- </field>
- <field>
- <columnName>Invoice</columnName>
- <targetName>Invoice</targetName>
- </field>
- <field>
- <columnName>InvoiceContent</columnName>
- <targetName>InvoiceContent</targetName>
- </field>
- <field>
- <columnName>InvoiceContentType</columnName>
- <targetName>InvoiceContentType</targetName>
- </field>
- <field>
- <columnName>InvoiceNo</columnName>
- <targetName>InvoiceNo</targetName>
- </field>
- <field>
- <columnName>IsDealWith</columnName>
- <targetName>IsDealWith</targetName>
- </field>
- <field>
- <columnName>IsDrug</columnName>
- <targetName>IsDrug</targetName>
- </field>
- <field>
- <columnName>IsEmailmark</columnName>
- <targetName>IsEmailmark</targetName>
- </field>
- <field>
- <columnName>IsNewOrder</columnName>
- <targetName>IsNewOrder</targetName>
- </field>
- <field>
- <columnName>IsO2O</columnName>
- <targetName>IsO2O</targetName>
- </field>
- <field>
- <columnName>IsPayByCard</columnName>
- <targetName>IsPayByCard</targetName>
- </field>
- <field>
- <columnName>IsPrescription</columnName>
- <targetName>IsPrescription</targetName>
- </field>
- <field>
- <columnName>IsReturn</columnName>
- <targetName>IsReturn</targetName>
- </field>
- <field>
- <columnName>IsReward</columnName>
- <targetName>IsReward</targetName>
- </field>
- <field>
- <columnName>IsRxDrug</columnName>
- <targetName>IsRxDrug</targetName>
- </field>
- <field>
- <columnName>IsToERP</columnName>
- <targetName>IsToERP</targetName>
- </field>
- <field>
- <columnName>IsVisible</columnName>
- <targetName>IsVisible</targetName>
- </field>
- <field>
- <columnName>LastModified</columnName>
- <targetName>LastModified</targetName>
- </field>
- <field>
- <columnName>LeverNumber</columnName>
- <targetName>LeverNumber</targetName>
- </field>
- <field>
- <columnName>MemKey</columnName>
- <targetName>MemKey</targetName>
- </field>
- <field>
- <columnName>MemUsualAreaCode</columnName>
- <targetName>MemUsualAreaCode</targetName>
- </field>
- <field>
- <columnName>MemUsualCityCode</columnName>
- <targetName>MemUsualCityCode</targetName>
- </field>
- <field>
- <columnName>MemUsualPhone</columnName>
- <targetName>MemUsualPhone</targetName>
- </field>
- <field>
- <columnName>MemUsualProvinceCode</columnName>
- <targetName>MemUsualProvinceCode</targetName>
- </field>
- <field>
- <columnName>MemberGender</columnName>
- <targetName>MemberGender</targetName>
- </field>
- <field>
- <columnName>MemberNickName</columnName>
- <targetName>MemberNickName</targetName>
- </field>
- <field>
- <columnName>MerchantNote</columnName>
- <targetName>MerchantNote</targetName>
- </field>
- <field>
- <columnName>OperateID</columnName>
- <targetName>OperateID</targetName>
- </field>
- <field>
- <columnName>OrderKey</columnName>
- <targetName>OrderKey</targetName>
- </field>
- <field>
- <columnName>OrderNotes</columnName>
- <targetName>OrderNotes</targetName>
- </field>
- <field>
- <columnName>OrderProcessDate</columnName>
- <targetName>OrderProcessDate</targetName>
- </field>
- <field>
- <columnName>OrderStatus</columnName>
- <targetName>OrderStatus</targetName>
- </field>
- <field>
- <columnName>OrderTime</columnName>
- <targetName>OrderTime</targetName>
- </field>
- <field>
- <columnName>OrdersCode</columnName>
- <targetName>OrdersCode</targetName>
- </field>
- <field>
- <columnName>OrdersType</columnName>
- <targetName>OrdersType</targetName>
- </field>
- <field>
- <columnName>OriginType</columnName>
- <targetName>OriginType</targetName>
- </field>
- <field>
- <columnName>OtherNote</columnName>
- <targetName>OtherNote</targetName>
- </field>
- <field>
- <columnName>PaymentType</columnName>
- <targetName>PaymentType</targetName>
- </field>
- <field>
- <columnName>PreferentialRate</columnName>
- <targetName>PreferentialRate</targetName>
- </field>
- <field>
- <columnName>ProductCost</columnName>
- <targetName>ProductCost</targetName>
- </field>
- <field>
- <columnName>ProductLine</columnName>
- <targetName>ProductLine</targetName>
- </field>
- <field>
- <columnName>ReceivingTime</columnName>
- <targetName>ReceivingTime</targetName>
- </field>
- <field>
- <columnName>Reducing</columnName>
- <targetName>Reducing</targetName>
- </field>
- <field>
- <columnName>RegionCode</columnName>
- <targetName>RegionCode</targetName>
- </field>
- <field>
- <columnName>SDataId</columnName>
- <targetName>SDataId</targetName>
- </field>
- <field>
- <columnName>ShippingNo</columnName>
- <targetName>ShippingNo</targetName>
- </field>
- <field>
- <columnName>ShippingTime</columnName>
- <targetName>ShippingTime</targetName>
- </field>
- <field>
- <columnName>SourcePlatforms</columnName>
- <targetName>SourcePlatforms</targetName>
- </field>
- <field>
- <columnName>SubProductLine</columnName>
- <targetName>SubProductLine</targetName>
- </field>
- <field>
- <columnName>Sum</columnName>
- <targetName>Sum</targetName>
- </field>
- <field>
- <columnName>SyncStatus</columnName>
- <targetName>SyncStatus</targetName>
- </field>
- <field>
- <columnName>TransportCosts</columnName>
- <targetName>TransportCosts</targetName>
- </field>
- </fields>
- <servers>
- <server>
- <address>192.168.50.32</address>
- <port>9300</port>
- </server>
- </servers>
- <settings>
- <setting>
- <name>cluster.name</name>
- <value>es</value>
- </setting>
- <setting>
- <name>custom.aliase.source</name>
- <value>mem_memberext_temp</value>
- </setting>
- <setting>
- <name>custom.fields.HasOrder</name>
- <value>{"type":"boolean"}</value>
- </setting>
- <setting>
- <name>custom.fields.MemDesc</name>
- <value>{"type":"text","analyzer": "ik_smart",
- "search_analyzer":"ik_smart","index":true}</value>
- </setting>
- <setting>
- <name>custom.fields.MemberBirthday</name>
- <value>{"type":"date","format":"yyyy-MM-dd HH:mm:ss||yyyy-MM-dd||strict_date_optional_time||epoch_millis"}</value>
- </setting>
- <setting>
- <name>custom.fields.RegisterTime</name>
- <value>{"type":"date","format":"yyyy-MM-dd HH:mm:ss||yyyy-MM-dd||strict_date_optional_time||epoch_millis"}</value>
- </setting>
- <setting>
- <name>custom.index.number_of_replicas</name>
- <value>1</value>
- </setting>
- <setting>
- <name>custom.index.number_of_shards</name>
- <value>11</value>
- </setting>
- </settings>
- <attributes/>
- <cluster_schema/>
- <remotesteps>
- <input>
- </input>
- <output>
- </output>
- </remotesteps>
- <GUI>
- <xloc>240</xloc>
- <yloc>272</yloc>
- <draw>Y</draw>
- </GUI>
- </step>
- <step>
- <name>表输入 2</name>
- <type>TableInput</type>
- <description/>
- <distribute>Y</distribute>
- <custom_distribution/>
- <copies>1</copies>
- <partitioning>
- <method>none</method>
- <schema_name/>
- </partitioning>
- <connection>MallSqlserver</connection>
- <sql>
- SELECT top 1
- row_number() over (order by AConsigneePhone2 asc ) as MemKey,
- OrdersCode as OrderKey,
- OrdersCode
- ,case when AConsigneePhone2= '' then
- (case
- when AconsigneePhone1!='' then dbo.DesDecryptFixKey('123456','123456e10adc3949ba59abbe56e057f20f883e',AConsigneePhone1)
- else ''end)
- ELSE dbo.DesDecryptFixKey('123456','123456e10adc3949ba59abbe56e057f20f883e',AConsigneePhone2) end as MemUsualPhone
- , convert(varchar(19),[CreationDate],120) as [CreationDate]
- , convert(varchar(19),[LastModified],120) as [LastModified]
- , AccountId
- , AccountName
- , Consignee as MemberNickName
- , DeliveryZipCode
- , Invoice
- , InvoiceNo
- , OrderNotes
- , PaymentType
- , DeliveryType
- , convert(varchar(19),[OrderTime],120) as [OrderTime]
- , convert(varchar(19),[ShippingTime],120) as [ShippingTime]
- , convert(varchar(19),[ReceivingTime],120) as [ReceivingTime]
- , ShippingNo
- , OrderStatus
- , IsReturn
- , TransportCosts
- , RegionCode
- , IsRxDrug
- , OriginType
- , OperateID
- , DeptId
- , DeptCode
- , BuyUserId
- , ProductLine
- , SubProductLine
- , DiseaseClassCode
- , convert(varchar(19),[Age],120) as [Age]
- , Sex as MemberGender
- , SyncStatus
- , IsVisible
- , SourcePlatforms
- , DeviceType
- , IsReward
- , IsEmailmark
- , CustomerDataId
- , IsDrug
- , HuaWuOriginType
- , AgainOrderCount
- , ConfimLevel
- , BusinessId
- , IsPayByCard
- , PreferentialRate
- , dbo.DesDecryptFixKey('123456','123456e10adc3949ba59abbe56e057f20f883e',AConsigneePhone1) as AConsigneePhone1
- , dbo.DesDecryptFixKey('123456','123456e10adc3949ba59abbe56e057f20f883e',AConsigneePhone2) as AConsigneePhone2
- , dbo.DesDecryptFixKey('123456','123456e10adc3949ba59abbe56e057f20f883e',AConsigneePhone3) as AConsigneePhone3
- , dbo.DesDecryptFixKey('123456','123456e10adc3949ba59abbe56e057f20f883e',ADeliveryAddress) as ADeliveryAddress
- , IsDealWith
- , IsNewOrder
- , ConsigneeType
- , CustomerCode
- , CustomerName
- , InvoiceContent
- , InvoiceContentType
- , OrdersType
- , LeverNumber
- , IsO2O
- , AdvancePayType
- , convert(varchar(19),[InventoryAuditDate],120) as [InventoryAuditDate]
- , convert(varchar(19),[OrderProcessDate],120) as [OrderProcessDate]
- , IsToERP
- , MerchantNote
- , OtherNote
- , IsPrescription
- , ConfirmId
- ,
- case when b0.Level= 3 then a.RegionCode else null end as MemUsualAreaCode,
- case when b1.Level= 2 then b.ParentCode else b.AreaCode end as MemUsualCityCode,
- case when c1.Level= 1 then c.ParentCode else c.AreaCode end as MemUsualProvinceCode
- FROM Orders a
- left join Areamap b0 on b0.MappingCode=a.RegionCode
- left join AreaRegion b on b.AreaCode=a.RegionCode left join Areamap b1 on b1.MappingCode=b.ParentCode
- left join AreaRegion c on c.AreaCode=b.ParentCode left join Areamap c1 on c1.MappingCode=c.ParentCode
- where 1=1 and (AconsigneePhone1!='' or AconsigneePhone2!='')
- --order by AConsigneePhone2 asc
- --offset 0 rows fetch NEXT 2 rows only
- order by AConsigneePhone2 asc
- --offset ((524-1)*5000) rows --fetch next (10) rows only</sql>
- <limit>0</limit>
- <lookup/>
- <execute_each_row>N</execute_each_row>
- <variables_active>N</variables_active>
- <lazy_conversion_active>N</lazy_conversion_active>
- <attributes/>
- <cluster_schema/>
- <remotesteps>
- <input>
- </input>
- <output>
- </output>
- </remotesteps>
- <GUI>
- <xloc>256</xloc>
- <yloc>112</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>
|