mem_memberbase_query_perday_page.ktr 60 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227
  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <transformation>
  3. <info>
  4. <name>mem_memberbase_query_perday_page</name>
  5. <description/>
  6. <extended_description/>
  7. <trans_version/>
  8. <trans_type>Normal</trans_type>
  9. <trans_status>0</trans_status>
  10. <directory>/</directory>
  11. <parameters>
  12. </parameters>
  13. <log>
  14. <trans-log-table>
  15. <connection/>
  16. <schema/>
  17. <table/>
  18. <size_limit_lines/>
  19. <interval/>
  20. <timeout_days/>
  21. <field>
  22. <id>ID_BATCH</id>
  23. <enabled>Y</enabled>
  24. <name>ID_BATCH</name>
  25. </field>
  26. <field>
  27. <id>CHANNEL_ID</id>
  28. <enabled>Y</enabled>
  29. <name>CHANNEL_ID</name>
  30. </field>
  31. <field>
  32. <id>TRANSNAME</id>
  33. <enabled>Y</enabled>
  34. <name>TRANSNAME</name>
  35. </field>
  36. <field>
  37. <id>STATUS</id>
  38. <enabled>Y</enabled>
  39. <name>STATUS</name>
  40. </field>
  41. <field>
  42. <id>LINES_READ</id>
  43. <enabled>Y</enabled>
  44. <name>LINES_READ</name>
  45. <subject/>
  46. </field>
  47. <field>
  48. <id>LINES_WRITTEN</id>
  49. <enabled>Y</enabled>
  50. <name>LINES_WRITTEN</name>
  51. <subject/>
  52. </field>
  53. <field>
  54. <id>LINES_UPDATED</id>
  55. <enabled>Y</enabled>
  56. <name>LINES_UPDATED</name>
  57. <subject/>
  58. </field>
  59. <field>
  60. <id>LINES_INPUT</id>
  61. <enabled>Y</enabled>
  62. <name>LINES_INPUT</name>
  63. <subject/>
  64. </field>
  65. <field>
  66. <id>LINES_OUTPUT</id>
  67. <enabled>Y</enabled>
  68. <name>LINES_OUTPUT</name>
  69. <subject/>
  70. </field>
  71. <field>
  72. <id>LINES_REJECTED</id>
  73. <enabled>Y</enabled>
  74. <name>LINES_REJECTED</name>
  75. <subject/>
  76. </field>
  77. <field>
  78. <id>ERRORS</id>
  79. <enabled>Y</enabled>
  80. <name>ERRORS</name>
  81. </field>
  82. <field>
  83. <id>STARTDATE</id>
  84. <enabled>Y</enabled>
  85. <name>STARTDATE</name>
  86. </field>
  87. <field>
  88. <id>ENDDATE</id>
  89. <enabled>Y</enabled>
  90. <name>ENDDATE</name>
  91. </field>
  92. <field>
  93. <id>LOGDATE</id>
  94. <enabled>Y</enabled>
  95. <name>LOGDATE</name>
  96. </field>
  97. <field>
  98. <id>DEPDATE</id>
  99. <enabled>Y</enabled>
  100. <name>DEPDATE</name>
  101. </field>
  102. <field>
  103. <id>REPLAYDATE</id>
  104. <enabled>Y</enabled>
  105. <name>REPLAYDATE</name>
  106. </field>
  107. <field>
  108. <id>LOG_FIELD</id>
  109. <enabled>Y</enabled>
  110. <name>LOG_FIELD</name>
  111. </field>
  112. <field>
  113. <id>EXECUTING_SERVER</id>
  114. <enabled>N</enabled>
  115. <name>EXECUTING_SERVER</name>
  116. </field>
  117. <field>
  118. <id>EXECUTING_USER</id>
  119. <enabled>N</enabled>
  120. <name>EXECUTING_USER</name>
  121. </field>
  122. <field>
  123. <id>CLIENT</id>
  124. <enabled>N</enabled>
  125. <name>CLIENT</name>
  126. </field>
  127. </trans-log-table>
  128. <perf-log-table>
  129. <connection/>
  130. <schema/>
  131. <table/>
  132. <interval/>
  133. <timeout_days/>
  134. <field>
  135. <id>ID_BATCH</id>
  136. <enabled>Y</enabled>
  137. <name>ID_BATCH</name>
  138. </field>
  139. <field>
  140. <id>SEQ_NR</id>
  141. <enabled>Y</enabled>
  142. <name>SEQ_NR</name>
  143. </field>
  144. <field>
  145. <id>LOGDATE</id>
  146. <enabled>Y</enabled>
  147. <name>LOGDATE</name>
  148. </field>
  149. <field>
  150. <id>TRANSNAME</id>
  151. <enabled>Y</enabled>
  152. <name>TRANSNAME</name>
  153. </field>
  154. <field>
  155. <id>STEPNAME</id>
  156. <enabled>Y</enabled>
  157. <name>STEPNAME</name>
  158. </field>
  159. <field>
  160. <id>STEP_COPY</id>
  161. <enabled>Y</enabled>
  162. <name>STEP_COPY</name>
  163. </field>
  164. <field>
  165. <id>LINES_READ</id>
  166. <enabled>Y</enabled>
  167. <name>LINES_READ</name>
  168. </field>
  169. <field>
  170. <id>LINES_WRITTEN</id>
  171. <enabled>Y</enabled>
  172. <name>LINES_WRITTEN</name>
  173. </field>
  174. <field>
  175. <id>LINES_UPDATED</id>
  176. <enabled>Y</enabled>
  177. <name>LINES_UPDATED</name>
  178. </field>
  179. <field>
  180. <id>LINES_INPUT</id>
  181. <enabled>Y</enabled>
  182. <name>LINES_INPUT</name>
  183. </field>
  184. <field>
  185. <id>LINES_OUTPUT</id>
  186. <enabled>Y</enabled>
  187. <name>LINES_OUTPUT</name>
  188. </field>
  189. <field>
  190. <id>LINES_REJECTED</id>
  191. <enabled>Y</enabled>
  192. <name>LINES_REJECTED</name>
  193. </field>
  194. <field>
  195. <id>ERRORS</id>
  196. <enabled>Y</enabled>
  197. <name>ERRORS</name>
  198. </field>
  199. <field>
  200. <id>INPUT_BUFFER_ROWS</id>
  201. <enabled>Y</enabled>
  202. <name>INPUT_BUFFER_ROWS</name>
  203. </field>
  204. <field>
  205. <id>OUTPUT_BUFFER_ROWS</id>
  206. <enabled>Y</enabled>
  207. <name>OUTPUT_BUFFER_ROWS</name>
  208. </field>
  209. </perf-log-table>
  210. <channel-log-table>
  211. <connection/>
  212. <schema/>
  213. <table/>
  214. <timeout_days/>
  215. <field>
  216. <id>ID_BATCH</id>
  217. <enabled>Y</enabled>
  218. <name>ID_BATCH</name>
  219. </field>
  220. <field>
  221. <id>CHANNEL_ID</id>
  222. <enabled>Y</enabled>
  223. <name>CHANNEL_ID</name>
  224. </field>
  225. <field>
  226. <id>LOG_DATE</id>
  227. <enabled>Y</enabled>
  228. <name>LOG_DATE</name>
  229. </field>
  230. <field>
  231. <id>LOGGING_OBJECT_TYPE</id>
  232. <enabled>Y</enabled>
  233. <name>LOGGING_OBJECT_TYPE</name>
  234. </field>
  235. <field>
  236. <id>OBJECT_NAME</id>
  237. <enabled>Y</enabled>
  238. <name>OBJECT_NAME</name>
  239. </field>
  240. <field>
  241. <id>OBJECT_COPY</id>
  242. <enabled>Y</enabled>
  243. <name>OBJECT_COPY</name>
  244. </field>
  245. <field>
  246. <id>REPOSITORY_DIRECTORY</id>
  247. <enabled>Y</enabled>
  248. <name>REPOSITORY_DIRECTORY</name>
  249. </field>
  250. <field>
  251. <id>FILENAME</id>
  252. <enabled>Y</enabled>
  253. <name>FILENAME</name>
  254. </field>
  255. <field>
  256. <id>OBJECT_ID</id>
  257. <enabled>Y</enabled>
  258. <name>OBJECT_ID</name>
  259. </field>
  260. <field>
  261. <id>OBJECT_REVISION</id>
  262. <enabled>Y</enabled>
  263. <name>OBJECT_REVISION</name>
  264. </field>
  265. <field>
  266. <id>PARENT_CHANNEL_ID</id>
  267. <enabled>Y</enabled>
  268. <name>PARENT_CHANNEL_ID</name>
  269. </field>
  270. <field>
  271. <id>ROOT_CHANNEL_ID</id>
  272. <enabled>Y</enabled>
  273. <name>ROOT_CHANNEL_ID</name>
  274. </field>
  275. </channel-log-table>
  276. <step-log-table>
  277. <connection/>
  278. <schema/>
  279. <table/>
  280. <timeout_days/>
  281. <field>
  282. <id>ID_BATCH</id>
  283. <enabled>Y</enabled>
  284. <name>ID_BATCH</name>
  285. </field>
  286. <field>
  287. <id>CHANNEL_ID</id>
  288. <enabled>Y</enabled>
  289. <name>CHANNEL_ID</name>
  290. </field>
  291. <field>
  292. <id>LOG_DATE</id>
  293. <enabled>Y</enabled>
  294. <name>LOG_DATE</name>
  295. </field>
  296. <field>
  297. <id>TRANSNAME</id>
  298. <enabled>Y</enabled>
  299. <name>TRANSNAME</name>
  300. </field>
  301. <field>
  302. <id>STEPNAME</id>
  303. <enabled>Y</enabled>
  304. <name>STEPNAME</name>
  305. </field>
  306. <field>
  307. <id>STEP_COPY</id>
  308. <enabled>Y</enabled>
  309. <name>STEP_COPY</name>
  310. </field>
  311. <field>
  312. <id>LINES_READ</id>
  313. <enabled>Y</enabled>
  314. <name>LINES_READ</name>
  315. </field>
  316. <field>
  317. <id>LINES_WRITTEN</id>
  318. <enabled>Y</enabled>
  319. <name>LINES_WRITTEN</name>
  320. </field>
  321. <field>
  322. <id>LINES_UPDATED</id>
  323. <enabled>Y</enabled>
  324. <name>LINES_UPDATED</name>
  325. </field>
  326. <field>
  327. <id>LINES_INPUT</id>
  328. <enabled>Y</enabled>
  329. <name>LINES_INPUT</name>
  330. </field>
  331. <field>
  332. <id>LINES_OUTPUT</id>
  333. <enabled>Y</enabled>
  334. <name>LINES_OUTPUT</name>
  335. </field>
  336. <field>
  337. <id>LINES_REJECTED</id>
  338. <enabled>Y</enabled>
  339. <name>LINES_REJECTED</name>
  340. </field>
  341. <field>
  342. <id>ERRORS</id>
  343. <enabled>Y</enabled>
  344. <name>ERRORS</name>
  345. </field>
  346. <field>
  347. <id>LOG_FIELD</id>
  348. <enabled>N</enabled>
  349. <name>LOG_FIELD</name>
  350. </field>
  351. </step-log-table>
  352. <metrics-log-table>
  353. <connection/>
  354. <schema/>
  355. <table/>
  356. <timeout_days/>
  357. <field>
  358. <id>ID_BATCH</id>
  359. <enabled>Y</enabled>
  360. <name>ID_BATCH</name>
  361. </field>
  362. <field>
  363. <id>CHANNEL_ID</id>
  364. <enabled>Y</enabled>
  365. <name>CHANNEL_ID</name>
  366. </field>
  367. <field>
  368. <id>LOG_DATE</id>
  369. <enabled>Y</enabled>
  370. <name>LOG_DATE</name>
  371. </field>
  372. <field>
  373. <id>METRICS_DATE</id>
  374. <enabled>Y</enabled>
  375. <name>METRICS_DATE</name>
  376. </field>
  377. <field>
  378. <id>METRICS_CODE</id>
  379. <enabled>Y</enabled>
  380. <name>METRICS_CODE</name>
  381. </field>
  382. <field>
  383. <id>METRICS_DESCRIPTION</id>
  384. <enabled>Y</enabled>
  385. <name>METRICS_DESCRIPTION</name>
  386. </field>
  387. <field>
  388. <id>METRICS_SUBJECT</id>
  389. <enabled>Y</enabled>
  390. <name>METRICS_SUBJECT</name>
  391. </field>
  392. <field>
  393. <id>METRICS_TYPE</id>
  394. <enabled>Y</enabled>
  395. <name>METRICS_TYPE</name>
  396. </field>
  397. <field>
  398. <id>METRICS_VALUE</id>
  399. <enabled>Y</enabled>
  400. <name>METRICS_VALUE</name>
  401. </field>
  402. </metrics-log-table>
  403. </log>
  404. <maxdate>
  405. <connection/>
  406. <table/>
  407. <field/>
  408. <offset>0.0</offset>
  409. <maxdiff>0.0</maxdiff>
  410. </maxdate>
  411. <size_rowset>2</size_rowset>
  412. <sleep_time_empty>50</sleep_time_empty>
  413. <sleep_time_full>50</sleep_time_full>
  414. <unique_connections>N</unique_connections>
  415. <feedback_shown>Y</feedback_shown>
  416. <feedback_size>50000</feedback_size>
  417. <using_thread_priorities>Y</using_thread_priorities>
  418. <shared_objects_file/>
  419. <capture_step_performance>N</capture_step_performance>
  420. <step_performance_capturing_delay>1000</step_performance_capturing_delay>
  421. <step_performance_capturing_size_limit>100</step_performance_capturing_size_limit>
  422. <dependencies>
  423. </dependencies>
  424. <partitionschemas>
  425. </partitionschemas>
  426. <slaveservers>
  427. </slaveservers>
  428. <clusterschemas>
  429. </clusterschemas>
  430. <created_user>-</created_user>
  431. <created_date>2019/05/26 19:55:18.893</created_date>
  432. <modified_user>-</modified_user>
  433. <modified_date>2019/05/26 19:55:18.893</modified_date>
  434. <key_for_session_key>H4sIAAAAAAAAAAMAAAAAAAAAAAA=</key_for_session_key>
  435. <is_key_private>N</is_key_private>
  436. </info>
  437. <notepads>
  438. </notepads>
  439. <connection>
  440. <name>mall</name>
  441. <server>192.168.50.32</server>
  442. <type>MSSQLNATIVE</type>
  443. <access>Native</access>
  444. <database>Mall</database>
  445. <port>1433</port>
  446. <username>sa</username>
  447. <password>Encrypted 2be98afc86aa7f297aa15a478c7d38f99</password>
  448. <servername/>
  449. <data_tablespace/>
  450. <index_tablespace/>
  451. <attributes>
  452. <attribute>
  453. <code>FORCE_IDENTIFIERS_TO_LOWERCASE</code>
  454. <attribute>N</attribute>
  455. </attribute>
  456. <attribute>
  457. <code>FORCE_IDENTIFIERS_TO_UPPERCASE</code>
  458. <attribute>N</attribute>
  459. </attribute>
  460. <attribute>
  461. <code>INITIAL_POOL_SIZE</code>
  462. <attribute>30</attribute>
  463. </attribute>
  464. <attribute>
  465. <code>IS_CLUSTERED</code>
  466. <attribute>N</attribute>
  467. </attribute>
  468. <attribute>
  469. <code>MAXIMUM_POOL_SIZE</code>
  470. <attribute>1000</attribute>
  471. </attribute>
  472. <attribute>
  473. <code>MSSQLUseIntegratedSecurity</code>
  474. <attribute>false</attribute>
  475. </attribute>
  476. <attribute>
  477. <code>MSSQL_DOUBLE_DECIMAL_SEPARATOR</code>
  478. <attribute>N</attribute>
  479. </attribute>
  480. <attribute>
  481. <code>PORT_NUMBER</code>
  482. <attribute>1433</attribute>
  483. </attribute>
  484. <attribute>
  485. <code>PRESERVE_RESERVED_WORD_CASE</code>
  486. <attribute>Y</attribute>
  487. </attribute>
  488. <attribute>
  489. <code>QUOTE_ALL_FIELDS</code>
  490. <attribute>N</attribute>
  491. </attribute>
  492. <attribute>
  493. <code>SUPPORTS_BOOLEAN_DATA_TYPE</code>
  494. <attribute>Y</attribute>
  495. </attribute>
  496. <attribute>
  497. <code>SUPPORTS_TIMESTAMP_DATA_TYPE</code>
  498. <attribute>Y</attribute>
  499. </attribute>
  500. <attribute>
  501. <code>USE_POOLING</code>
  502. <attribute>Y</attribute>
  503. </attribute>
  504. </attributes>
  505. </connection>
  506. <order>
  507. <hop>
  508. <from>表输入</from>
  509. <to>Java 代码</to>
  510. <enabled>Y</enabled>
  511. </hop>
  512. <hop>
  513. <from>Java 代码</from>
  514. <to>Elasticsearch bulk insert 2</to>
  515. <enabled>Y</enabled>
  516. </hop>
  517. <hop>
  518. <from>表输入 2</from>
  519. <to>Java 代码</to>
  520. <enabled>Y</enabled>
  521. </hop>
  522. <hop>
  523. <from>表输入 3</from>
  524. <to>Java 代码</to>
  525. <enabled>Y</enabled>
  526. </hop>
  527. </order>
  528. <step>
  529. <name>Elasticsearch bulk insert 2</name>
  530. <type>ElasticSearchBulk</type>
  531. <description/>
  532. <distribute>Y</distribute>
  533. <custom_distribution/>
  534. <copies>1</copies>
  535. <partitioning>
  536. <method>none</method>
  537. <schema_name/>
  538. </partitioning>
  539. <general>
  540. <index>crm_memberbase_phoneid</index>
  541. <type>_doc</type>
  542. <batchSize>150</batchSize>
  543. <timeout>100</timeout>
  544. <timeoutUnit>SECONDS</timeoutUnit>
  545. <isJson>N</isJson>
  546. <idField>PhoneId</idField>
  547. <overwriteIfExists>N</overwriteIfExists>
  548. <useOutput>N</useOutput>
  549. <stopOnError>N</stopOnError>
  550. </general>
  551. <fields>
  552. <field>
  553. <columnName>HasOrder</columnName>
  554. <targetName>HasOrder</targetName>
  555. </field>
  556. <field>
  557. <columnName>MemDesc</columnName>
  558. <targetName>MemDesc</targetName>
  559. </field>
  560. <field>
  561. <columnName>MemEmail</columnName>
  562. <targetName>MemEmail</targetName>
  563. </field>
  564. <field>
  565. <columnName>MemPhone1</columnName>
  566. <targetName>MemPhone1</targetName>
  567. </field>
  568. <field>
  569. <columnName>MemPhone2</columnName>
  570. <targetName>MemPhone2</targetName>
  571. </field>
  572. <field>
  573. <columnName>MemPhone3</columnName>
  574. <targetName>MemPhone3</targetName>
  575. </field>
  576. <field>
  577. <columnName>MemUsualAddress</columnName>
  578. <targetName>MemUsualAddress</targetName>
  579. </field>
  580. <field>
  581. <columnName>MemUsualAreaCode</columnName>
  582. <targetName>MemUsualAreaCode</targetName>
  583. </field>
  584. <field>
  585. <columnName>MemUsualCityCode</columnName>
  586. <targetName>MemUsualCityCode</targetName>
  587. </field>
  588. <field>
  589. <columnName>MemUsualPhone</columnName>
  590. <targetName>MemUsualPhone</targetName>
  591. </field>
  592. <field>
  593. <columnName>MemUsualProvinceCode</columnName>
  594. <targetName>MemUsualProvinceCode</targetName>
  595. </field>
  596. <field>
  597. <columnName>MemberBirthday</columnName>
  598. <targetName>MemberBirthday</targetName>
  599. </field>
  600. <field>
  601. <columnName>MemberGender</columnName>
  602. <targetName>MemberGender</targetName>
  603. </field>
  604. <field>
  605. <columnName>MemberHeaPic</columnName>
  606. <targetName>MemberHeaPic</targetName>
  607. </field>
  608. <field>
  609. <columnName>MemberId</columnName>
  610. <targetName>MemberId</targetName>
  611. </field>
  612. <field>
  613. <columnName>MemberKey</columnName>
  614. <targetName>MemberKey</targetName>
  615. </field>
  616. <field>
  617. <columnName>MemberNickName</columnName>
  618. <targetName>MemberNickName</targetName>
  619. </field>
  620. <field>
  621. <columnName>OrdersCode</columnName>
  622. <targetName>OrdersCode</targetName>
  623. </field>
  624. <field>
  625. <columnName>OriginType</columnName>
  626. <targetName>OriginType</targetName>
  627. </field>
  628. <field>
  629. <columnName>PhoneId</columnName>
  630. <targetName>PhoneId</targetName>
  631. </field>
  632. <field>
  633. <columnName>RegisterDay</columnName>
  634. <targetName>RegisterDay</targetName>
  635. </field>
  636. <field>
  637. <columnName>RegisterMonth</columnName>
  638. <targetName>RegisterMonth</targetName>
  639. </field>
  640. <field>
  641. <columnName>RegisterTime</columnName>
  642. <targetName>RegisterTime</targetName>
  643. </field>
  644. <field>
  645. <columnName>RegisterYear</columnName>
  646. <targetName>RegisterYear</targetName>
  647. </field>
  648. <field>
  649. <columnName>order_join_field</columnName>
  650. <targetName>order_join_field</targetName>
  651. </field>
  652. </fields>
  653. <servers>
  654. <server>
  655. <address>192.168.50.34</address>
  656. <port>9300</port>
  657. </server>
  658. </servers>
  659. <settings>
  660. <setting>
  661. <name>cluster.name</name>
  662. <value>es</value>
  663. </setting>
  664. <setting>
  665. <name>custom.aliase.source</name>
  666. <value>mem_memberbase_phoneid</value>
  667. </setting>
  668. <setting>
  669. <name>custom.fields.HasOrder</name>
  670. <value>{"type":"boolean"}</value>
  671. </setting>
  672. <setting>
  673. <name>custom.fields.MemDesc</name>
  674. <value>{"type":"text","analyzer": "ik_smart",
  675. "search_analyzer":"ik_smart","index":true}</value>
  676. </setting>
  677. <setting>
  678. <name>custom.fields.MemberBirthday</name>
  679. <value>{"type":"date","format":"yyyy-MM-dd HH:mm:ss||yyyy-MM-dd||strict_date_optional_time||epoch_millis"}</value>
  680. </setting>
  681. <setting>
  682. <name>custom.fields.RegisterTime</name>
  683. <value>{"type":"date","format":"yyyy-MM-dd HH:mm:ss||yyyy-MM-dd||strict_date_optional_time||epoch_millis"}</value>
  684. </setting>
  685. <setting>
  686. <name>custom.index.number_of_replicas</name>
  687. <value>1</value>
  688. </setting>
  689. <setting>
  690. <name>custom.index.number_of_shards</name>
  691. <value>11</value>
  692. </setting>
  693. </settings>
  694. <attributes/>
  695. <cluster_schema/>
  696. <remotesteps>
  697. <input>
  698. </input>
  699. <output>
  700. </output>
  701. </remotesteps>
  702. <GUI>
  703. <xloc>464</xloc>
  704. <yloc>32</yloc>
  705. <draw>Y</draw>
  706. </GUI>
  707. </step>
  708. <step>
  709. <name>Java 代码</name>
  710. <type>UserDefinedJavaClass</type>
  711. <description/>
  712. <distribute>Y</distribute>
  713. <custom_distribution/>
  714. <copies>1</copies>
  715. <partitioning>
  716. <method>none</method>
  717. <schema_name/>
  718. </partitioning>
  719. <definitions>
  720. <definition>
  721. <class_type>TRANSFORM_CLASS</class_type>
  722. <class_name>Processor</class_name>
  723. <class_source>import java.sql.*;
  724. import org.pentaho.di.core.database.*;
  725. import org.apache.http.HttpHost;
  726. import org.elasticsearch.ElasticsearchException;
  727. import org.elasticsearch.action.get.GetRequest;
  728. import org.elasticsearch.action.get.GetResponse;
  729. import org.elasticsearch.client.RestHighLevelClient;
  730. import org.elasticsearch.client.RequestOptions;
  731. import org.elasticsearch.client.RestClient;
  732. import org.elasticsearch.common.Strings;
  733. import org.elasticsearch.rest.RestStatus;
  734. import org.elasticsearch.search.fetch.subphase.FetchSourceContext;
  735. import org.elasticsearch.action.update.UpdateRequest;
  736. import org.elasticsearch.action.update.UpdateResponse;
  737. import org.elasticsearch.common.xcontent.XContentBuilder;
  738. import org.elasticsearch.common.xcontent.XContentFactory;
  739. import org.elasticsearch.script.Script;
  740. import java.lang.reflect.InvocationTargetException;
  741. import java.lang.reflect.Method;
  742. import com.microsoft.sqlserver.jdbc.SQLServerException;
  743. Database database = null;
  744. PreparedStatement stat = null;
  745. PreparedStatement stat1 = null;
  746. RestHighLevelClient client = new RestHighLevelClient(
  747. RestClient.builder(
  748. new HttpHost[]{new HttpHost("192.168.50.34", 9200, "http")}));
  749. Integer index = 0;
  750. public boolean processRow(StepMetaInterface smi, StepDataInterface sdi) throws KettleException
  751. {
  752. //logBasic("start---");
  753. String type = getVariable("type");
  754. String indexs = getVariable("index");
  755. //if (indexs != null) index = Integer.parseInt(indexs);
  756. Object[] r = getRow();
  757. if (r == null) {
  758. try {
  759. if (stat!=null) {
  760. stat.close();
  761. }
  762. if (stat1!=null) {
  763. stat1.close();
  764. }
  765. if (database!=null) {
  766. database.disconnect();
  767. }
  768. if(client!=null){
  769. client.close();
  770. }
  771. }
  772. catch(Exception e) {
  773. throw new KettleException(e);
  774. }
  775. setOutputDone();
  776. return false;
  777. }
  778. synchronized(this) {
  779. r = createOutputRow(r, data.outputRowMeta.size());
  780. //获取数据库名和表名
  781. String dbName = "MemberSqlServer";//getInputRowMeta().getString(r, "conname", null );
  782. String tablename = "DataImport_membase";//getInputRowMeta().getString(r, "tablename", null );
  783. String idname = "MemberKey";//getInputRowMeta().getString(r, "idname", null );
  784. String idname1 = "MemPhone1";//getInputRowMeta().getString(r, "idname", null );
  785. String idname2 = "MemPhone2";//getInputRowMeta().getString(r, "idname", null );
  786. String idname3 = "MemPhone3";//getInputRowMeta().getString(r, "idname", null );
  787. String sourceidname = "PhoneId";//getInputRowMeta().getString(r, "sourceidname", null );
  788. String sourcetablename = "Orders";//getInputRowMeta().getString(r, "sourcetablename", null );
  789. if (dbName==null||tablename==null) {
  790. throw new KettleException("Unable to find field with name "+tablename+" in the input row.");
  791. }
  792. //logBasic("table---"+tablename);
  793. if(database == null){
  794. //数据库连接
  795. DatabaseMeta databaseMeta=null;
  796. try {
  797. databaseMeta = getTransMeta().findDatabase(dbName);
  798. if (databaseMeta==null) {
  799. logError("A connection with name "+dbName+" could not be found!");
  800. setErrors(1);
  801. return false;
  802. }
  803. database = new Database(getTrans(), databaseMeta);
  804. database.connect();
  805. //logBasic("success!");
  806. } catch(Exception e) {
  807. logError("Connecting to database "+dbName+" failed.", e);
  808. setErrors(1);
  809. return false;
  810. }
  811. }
  812. //查询表数据
  813. try {
  814. RowMetaInterface idxRowMeta =data.outputRowMeta;
  815. int i=0;
  816. r = createOutputRow(r, data.outputRowMeta.size());
  817. //int index = getInputRowMeta().size();
  818. // Add the index name
  819. //
  820. String Id = idxRowMeta.getString(r, idname, null);
  821. String Id1 = idxRowMeta.getString(r, idname1, null);
  822. String Id2 = idxRowMeta.getString(r, idname2, null);
  823. String Id3 = idxRowMeta.getString(r, idname3, null);
  824. // Add the column name
  825. String DataId = idxRowMeta.getString(r, sourceidname, null);
  826. /*String sqlSelect = "select Id from "+tablename + " where DataId = '"+ DataId +"'";
  827. ResultSet resultSet = null;
  828. resultSet = database.openQuery(sqlSelect);
  829. Object[] idxRow = database.getRow(resultSet);
  830. if (database!=null) {
  831. database.closeQuery(resultSet);
  832. resultSet = null;
  833. }
  834. //if(idxRow != null){
  835. // return true;
  836. //}
  837. */
  838. Thread.sleep(100);
  839. /*
  840. //logBasic("idxRow--Id"+Id);
  841. //logBasic("idxRow--sourcetablename"+sourcetablename);
  842. //logBasic("idxRow--DataId"+DataId);
  843. GetRequest getRequest = new GetRequest(
  844. "crm_memberbase_phoneid", // Index
  845. "_doc", // /Type
  846. DataId); // Document id
  847. getRequest.fetchSourceContext(new FetchSourceContext(false)); // 禁用 _source 字段
  848. getRequest.storedFields(new String[]{"_none_"}); // 禁止存储任何字段
  849. boolean exists = client.exists(getRequest,RequestOptions.DEFAULT);
  850. //client.close();
  851. if(exists ){
  852. return true;
  853. }
  854. */
  855. //if(!exists &amp;&amp; idxRow == null){
  856. // return true;
  857. //}
  858. /*
  859. //3.获得预处理对象
  860. String sql="insert into "+tablename+" values (?,?,?,?);";//begin tran t2; commit tran t2
  861. //logBasic("idxRow--database"+ database);
  862. index = index + 1;
  863. if(stat == null)
  864. stat = database.prepareSQL(sql);
  865. //logBasic("idxRow--database"+ stat);
  866. //stat.addBatch(sql);
  867. //4.SQL语句占位符设置实际参数
  868. stat.setString(1, Id);//索引参数1代表着sql中的第一个?号,也就是我需要将条件sid所对应的sname数据更新为“儿童玩具测试”
  869. stat.setString(2, sourcetablename);//索引参数2代表着sql中的第二个?号,也就是条件是sid为3
  870. stat.setString(3, DataId);//索引参数2代表着sql中的第二个?号,也就是条件是sid为3
  871. stat.setString(4, "phone1");
  872. //stat.setInt(5, index);
  873. //5.执行SQL语句
  874. boolean line = stat.execute();
  875. //int[] line = stat.executeBatch();
  876. //System.out.println("更新记录数"+ line);
  877. //6.释放资源
  878. //stat.close();
  879. setVariable("index",String.valueOf(index));
  880. */
  881. //Integer pn = Integer.parseInt(Id);
  882. //Integer curpageNum = Integer.parseInt(Id) % pagesize;
  883. //if(pn > 0 &amp;&amp; curpageNum == 0){
  884. // setVariable("page",String.valueOf(page));
  885. //}
  886. //logBasic("idxRow--getVariable"+getVariable("page"));
  887. //logBasic("idxRow--curpageNum"+curpageNum);
  888. //logBasic("idxRow--length"+i);
  889. }
  890. catch(SQLServerException e) {
  891. return true;
  892. }catch(Exception e) {
  893. throw new KettleException(e);
  894. }
  895. //释放连接
  896. //if (database!=null) {
  897. // database.disconnect();
  898. //}
  899. // Send the row on to the next step.
  900. }
  901. putRow(data.outputRowMeta, r);
  902. return true;
  903. }</class_source>
  904. </definition>
  905. </definitions>
  906. <fields>
  907. </fields>
  908. <clear_result_fields>N</clear_result_fields>
  909. <info_steps/>
  910. <target_steps/>
  911. <usage_parameters/>
  912. <attributes/>
  913. <cluster_schema/>
  914. <remotesteps>
  915. <input>
  916. </input>
  917. <output>
  918. </output>
  919. </remotesteps>
  920. <GUI>
  921. <xloc>352</xloc>
  922. <yloc>16</yloc>
  923. <draw>Y</draw>
  924. </GUI>
  925. </step>
  926. <step>
  927. <name>表输入</name>
  928. <type>TableInput</type>
  929. <description/>
  930. <distribute>Y</distribute>
  931. <custom_distribution/>
  932. <copies>1</copies>
  933. <partitioning>
  934. <method>none</method>
  935. <schema_name/>
  936. </partitioning>
  937. <connection>mall</connection>
  938. <sql>select
  939. --ROW_NUMBER() over (order by OrderTime asc ) as MemberKey,
  940. 1 as MemberKey,
  941. case when sex= ''then 1 else sex end as MemberGender,
  942. '' as MemberHeaPic,
  943. Consignee as MemberNickName,
  944. null as MemberBirthday,
  945. dbo.DesDecryptFixKey('123456','123456e10adc3949ba59abbe56e057f20f883e',AConsigneePhone1) as PhoneId,
  946. dbo.DesDecryptFixKey('123456','123456e10adc3949ba59abbe56e057f20f883e',AConsigneePhone1) as MemUsualPhone,--电话号码
  947. case when AConsigneePhone1= '' then ''
  948. ELSE dbo.DesDecryptFixKey('123456','123456e10adc3949ba59abbe56e057f20f883e',AConsigneePhone1) end as MemPhone1,--
  949. case when AConsigneePhone2= '' then ''
  950. ELSE dbo.DesDecryptFixKey('123456','123456e10adc3949ba59abbe56e057f20f883e',AConsigneePhone2) end as MemPhone2,--
  951. case when AConsigneePhone3= '' then ''
  952. ELSE dbo.DesDecryptFixKey('123456','123456e10adc3949ba59abbe56e057f20f883e',AConsigneePhone3) end as MemPhone3,--
  953. case when ADeliveryAddress= '' then ''
  954. ELSE dbo.DesDecryptFixKey('123456','123456e10adc3949ba59abbe56e057f20f883e',ADeliveryAddress) end as MemUsualAddress,
  955. OriginType,
  956. ( select CONVERT(varchar(100), min(b.OrderTime), 20) from orders b where b.AConsigneePhone1=a.AConsigneePhone1
  957. and b.OrderTime!='1800/01/01 00:00:00'
  958. group by b.AConsigneePhone1
  959. )
  960. as RegisterTime,
  961. case when b0.Level= 3 then a.RegionCode else null end as MemUsualAreaCode,
  962. case when b1.Level= 2 then b.ParentCode else b.AreaCode end as MemUsualCityCode,
  963. case when c1.Level= 1 then c.ParentCode else c.AreaCode end as MemUsualProvinceCode
  964. ,'true' as HasOrder
  965. ,convert(varchar,datepart(year,getdate())) as RegisterYear
  966. ,convert(varchar,datepart(month,getdate())) as RegisterMonth
  967. ,convert(varchar,datepart(day,getdate())) as RegisterDay
  968. ,BuyUserId as MemberId
  969. ,OrdersCode
  970. ,'' as MemEmail
  971. ,'' as MemDesc
  972. ,'Member' as order_join_field
  973. from orders a
  974. left join Areamap b0 on b0.MappingCode=a.RegionCode
  975. left join AreaRegion b on b.AreaCode=a.RegionCode left join Areamap b1 on b1.MappingCode=b.ParentCode
  976. left join AreaRegion c on c.AreaCode=b.ParentCode left join Areamap c1 on c1.MappingCode=c.ParentCode
  977. where 1=1 and (a.AConsigneePhone1!= '' and a.AConsigneePhone1 is not null)
  978. and OrderTime>'2019-05-01 00:22:10'
  979. --and datediff(day,DATEADD(d,0,DATEDIFF(d,0,getdate())-21),OrderTime )>0
  980. --and AConsigneePhone1 in (
  981. --'0423F752B2D2AD0B473550BFE5FEA0AE','EEB4AB98536F6545C6CFDB35F978DAA2','996518B300E7E45E451BC4244799FFC9','18AAFDA225E18079D96E4B555C6FA0B3','818DA68D37C2918969736CF2A237C4A9','81F4601D958BE83AAD8616100C79108F','6D7361DB47D1E2EEE496C87DF06A0EC8','4E86D0A542AC090BBC25A111DC0666A0','18AF11B2567BA9C7AD6245626BB31BC9','F27A57F07A32709CFE74B6E7FA786FD3','086A73009D0013EBB1C478CC7B0FD12F','D07995C56FAF6397D1DB98F76204EB52','0E24B79BA1581333B9F06D3676C0CA64','67EF37A11980D8413374E138472F805B','64E6CCD18DA5488A474B6818AC00931D','ECF0974FD1AB5E5DFE761ED131FAA3E3','2B8D52A56FC4C2C4236F7C8CD01292BE','8D3314F80A83EAF8175ABB3672CBD7CC','F262784DB9E9252176A4B60AF654A2EC','D459D762D9E70F33194721F3FC2486B2','277375616683F8898B53DA4BB6C00438','00F902BE87871C2ADA10433144CB9F26','8097B72D91A133AF69C14EC181F4AB22','B412BCFF3767351B83C32484CD02F9C1','FA5108C230E3086603F226714B9C9AF2','C5DD26477A9CAAB3F01651233C272653','353FFD94515CD446D0DD22F3FC2E597E','7CED8EDDC54963E3139F14BD6B0F8641','8FC52187EA6A110ACCD4CB39EB3C5818','2EC8ED672FFBDEEA180DA466B76B38AC','DD31E235A35AAED95AF888D435F3DC47','3089BDEB1302CCA3619A9F49569F7B48','A39C6623271ABDB9F7F590543FC8057E','C529CE9490E26DD701539043E97E4BF8','EA35ED41C5A518715634ABFADE13B418','AE3ACFB96CC4EAC7D078AC09A6800FDC','3871D053F065EFBEAD600F33C636CDED','706BA31B06FE76728E001BCD47FD20BA','874C74568946B69D7FFB8AB335B65C33','ABC5625667D92349F1D7C5508FB975A9','64D7ED72C3EFBC0FE84D60EA24732417','4A39414F3F8BD22193D171A8ACC85B2C','7BDD4F56B12A818A5C173A17B1A6FB61','582E44926B1FBE3F0829348753F5BE24','EEA9F999433FC0EFB14B8F2FF393A3D6','E0DA009E7C441E1CC67AD7C3BC9E5927','2D037E57BFFABDF351EA646E7172A83F','E88D865B9E0C23448707C48F097FAFFA','8C4CC92F44D318DE27ED1803CDE0719A','9C0244F33187F34EA2B4AA8837EE2407','25E56D031E41BAA2585561E863AE3240','D62B7285ABD69A325866666FE8B1A211','041F49A973274CD46D88340492610836','55CC616C6267F7FFE6476E476A683B5B','D5F8294754A75ADA7F342254BECD8A36','72FEDECEC3573A85F1EF1E6D9168459F','A03BA4E861E08C2BD79014AACEB3457B','4F6D0500A89FB68AF57685751BF9FDD5','BB7A4324E327A17AC89E15A7E33B97D1','934DCB5E2CEDBE2F1BE2DF38E6B6FD21','CEAA74AD1FDBDF008D9303E8FAC9E58C','1DAE4B4EAB277D5C936F30D343669E8C','1E30EC2DB596EEA3F4075345313AD115','BB1F3A29FB1A7103B8456C6CCB4976C0','2EA2E7DC32064F9D2EBF9169B3B8B591','15FC5E0B1A7EA452E7850A941510B300','34950773FE2BB7AC1D238EFD747587DA','6698177B8F7DAEBA75FC9C74C7801082','486F95FCFF8784742535C89EECE12800','148B9F9220250C2D1AF3F18E8F4A7EFC','B5533EB90812BEC93350A70270A03543','3752A63527286C9549A5CDF0865FFFC8','1E7C72D95C9B3FD402C6705744AB19D7','36AC5937A03787B184BDE307231E2C45','661A29270751F08C48FA6ECBAB098668','97A8506E3BC4B9775E84ABF24FA8B5DF','5FDAB53E2C22942E71310FB030F00B7D','4093D2E26F44CD9E40D77BEBCAEA0E93','436E378BF7F5A53056B5900B67B49F62','832308EE1C5342C61B7C7F93152B4F6E','DA59338AF9229DE962CD20389F105F2D','57CB937F384116AC307430E400A5AB44','26922708241922654E119401117B1B94','25A811E19CC2E073909566BCD9D41361','EA3CB0E0ACBAFD16F50DB15602306E34','9901F0F13917C8CCE0352270BF2D0CD3','A39307DE9F3FB0190B98C527724F3B82','B8EDBB84091CC49A9AAFD251FCBDE7AF','4696EB55E911B7C24FFE7C3E65440072','3FCD315847A2F51E431857223432325E','201BD119927B3E06E39C05E75B3D9226','22B469D36AE35B57066305D87EFF8EA5','8B5F0F92E9E4B056B81D03519B7444C0','DEB97DEDBD570BEB7582F0E2AA03CC39','BD15992218632192AD7AFC515D9362FE','FC453359CA5378B600B36DA52F211251','663F850B4278422E5F8297179D1A576F','8696585F2EF20708D6EF342E294B8C1D','A395D12AF277D10EDAD439AC9AB08BCB','B7B2CD4DAA5DD09750ACD284D1992AA8','1779A33F6DA916B374FD714ABAE3FC18','3D28AC24BFC99A1550C75A4723FD46ECDE3E1974C7C408D872C1ABB463746192','0497493705B32E10CA97AD6C18710732','F270173F75C5DE0115062743D2EB7162','4FB7249A845C037D135FAFAA4F4C8035','E680E60C7BEE8A4E543E5641C5E7C802','3926C52407492CD87D7B957850C3EA3A','DB1EE0E9AB2D3E69E7C1522F169784DF','753BAF2406D831F3669E2D3A9D1D7F50','32D4F9F5ABAED2D54B6AFD9A5DDA3603','A92B24983AFF869AFCCB72BE4272FA20','B12D34376DA5676FB1188F1FB79D0E68','6EE25308B2AC781C3C1A728583DE2B27','39F4EAF971B477340CC238BD3129FA4A','631CEA72973147B759FDFFDFCF729558','6FF9FFCB9AB44C82C0ACCAD494549864','C40E83730FC4F81A33DA4A18DBD68A3B','6542F359BABB789F5CCE77325C609E8A','C69BDD440A2E1C55D21502DF8A66427A','1A819713BCF646541CBECC1887F5BF12','7245A7DDB91FC534BC2D0A4124DC115A','3466B4251F2B5B0EDED1A930405A9347','7B5A2B66DE344621B40882E1130CB0A2','E44DE94ECC5AF45103D2816BD557DACF','20DA5D3F0ED8B8361953876CAA7E618F','86896C4B29FC01CB20929AD02D1694C1','02E84A91CCCADD6BD315F6B1D86238C8','C0690FCB609433CC5338542019815072','FC8CC4CF43F997D0857C686CBA19BB78','8B79072AD66767252167F927A72A2ECB','E7BA3AFE24E5C46B2880B20EDF9F2814','D089136B015BFE0D6962C30A76B30397','DB167261B3048798706EB6FBCC2FC39A','F2C5ABD1FA6998E84B268718E2ECDE4E','3140AEE561B1B02B86D1149D871257DE','E787B20F2FA0441C3A337E9A8969A782','115DBE25E8A5CD08A28969A70E854034','61CB07B4C8D9C00FEC1BBA23DEC7894B','D4DBC7436582AD61B2F8709123D7B174','1613E515EE8D065C24001A8D4465FCA7','4F716E96C278C161AC984D5EE50CB9E9','1EE556430825950A2E9DDC81E4CE0857','A3AF63C59E2E37F4C4D3E5C8310F56D9','81A7D2CFC350FC946081CE1053844D8D','86B385A605CD471360C8BC118D7471E5','84AA28BB7153C39A4BFF0FF2E6CC9396','6D127E26B0280C66FFA70D4125371B7E','1674EC0D2026A13632CA672F2040D2A9','AAE4878B1960C904D8A19CF5221042E4','AF08B36889547EECD36D10CF20536279','4B7A89350213C12C0060B9AA8E06ECBE','7E907FEC97B8E10C4FEB77E2C92BE994','E93FE4F8AC12512BFF7E1307C18D483D','936CACC27696E6FED3CD47ED7C92E21C','30F64AD746EAE514D67A6B6C4CDECDBD','A065ADA7618F0560C2FCDB3A5703F4ED','F56F2D8477E79C9314B8E6CFBB516991','951C82B57831ADA7E30B34433B3D8648','9066B9B45E07E8DEC530DC808C73E8C9','1ED0B0E1EDF5D297C630D328AD7A323B','2EDCEB4B3369B08B3C67B66CBAD40116','3DA87AD9C4CD2B40EAC8EC27FCCF9408','9D7D1E92D68B24CB23B1BFD72C869B76','801FD14FB8F87640ED9C33193E30D983','D59E92E2F73A76DAE4D113FEC840BDE5','27EE2BB311B4209EBCF45A7E63D4028D','BFD94D45219AE8BFDFCC4C00E38B1CEE','6ABEDE3C15D40A8BB41B24170DFC765E','A0D798043917CA269ED76ADA26A20044','58F13DBC5CF59EEC90F19E70EBF8F4BC','7FB75D08E52EC0D379BC922749EC85EC','7F5097158F2882EA71A7B797B9718F08','312B3D5FC9B8B700424D6CAEDFD91E7E','E8722AED71CC6DD5A33DC9585BA80344','B9CC021D61995349476F46E8FFEB4E0D','B25FFAD1DDC8542A7CAAD0331C405C71','B1A1343DDDE78FE613C0C5A158F7C1C4','A53ADC4B9F1AC8618CBEA77BAACAC7F3','6C18608EC7A8BA88D0496A00CF711156','C767C3E9506F6E69ABEDD3A4F0E659F1','7F0A22B95B9A68B30D17DB07B1061EA1','CE1B88A69B7438D2231A74BACE309F12','E23CE33E9A39B32A1AACFB22BF943DE6','5ED3C490D43C210CC71A6A9AD75AA07C','66E793FF38F70C25D4E2F71CD2C15FA8','19A1E6D9411368BB808576246338172A','3D85B4F59411D2C1966451D7D169C4B4','3ADAF372B66AEB24E812BD0DFA40BDDC','1B1461AF3520DBB94F365BCF6C58DBEC','C9F14AF81CAB0766E5F385F76D9CC8E5','24C83A54492F7F92BC929E9CE2522161','4C6533B63414F3AB134C0F54C93FFC79','B672DD905B7337D7C8C165CC0B7F6282','EC2DC1B7285B63E95B7A9A1A586E00B5','D9D6F7CC155A3F01AF074AC32762E962','43E7A04E0260628DB2D923E6F2809F80','163F326D62390FE832C7DC7D31DFD0FE','7EF0F9855D9E5A2239672ED9D6CBD465','2F48FD445A7FB33D8CB9775D5B729B46','FEB6FD71EB9DA705687446BCF2380BF7','41663401F7E0096AE11E4760623CECC2','2032C9EADC95D3E915471052077A89CF','E3C6C365F30B112008CAE9DCBAEEC4C4','148B579D9F2C0E088431AE5A9C17F5FB','FECDCD7495FC501B706592B6C8FF92CE','3826222895D2DC548898560312666719','C60E8FD859276624C59BD9D8D7AEA56E','94D09FC7877AD3E0E476A3D43E9F90D6','BFBA3FA0B1114FB852432D5F953D77BB','183BC8E3D3452C2613D8BDF8F6E77BC5','D551CE55697416308D33E2F665FED2D426C9591C5C08933B15CC3D501B3B46E2','B1DC9AF9C1B2183A21F97E9DD119028D','8F25B71D6B9DED5107C600E5D4A4CCA8','6A1A3DC59F2B5CBFDF2038EAE704806B','16CB35A6A919B6A12B323928580277C4','D6EBD67E8BEEC2B442D475B0E753409E','9A3C1601FE78A76C13C97910A9E49FA6','4FB68069901C08B0502E5364965664CB','16559DC7CF7F430E4546740DFD4BB0F3','9FE33A926F39766B494E7D8299132455','7CB5B2BC8DA9E8FE6611E4A271D3069D','04262222623544E24457A3DB49F7287F','C2834F63C479220F76B7C3699839C3B3','0EC038F7C7F940DD23A391B69BD4D2CC','4C0CFBAE9095C1172A796DDC1C6EB0CB','50336EF5A905804B0FDA6CB5A30E2B1A','193BC933DECCFE1C5D2B4EA7FCCD4CFF','3D3A9F44184661254DA89F187B4B5EA6','29F066003D11A658D7E14335572D7E79','183BEC6770471275ABA7F1DF641A4A36','F5891A19FEE5EDA105702FDA96B0F9F2','F2D8152E78EA863E83521BB5BB165D28','B73728233E8311694FFA0357AC436874'
  982. --)
  983. order by OrderTime asc
  984. offset ((${mem_membase_page1}-1)*${mem_membase_pagesize1}) rows fetch NEXT (${mem_membase_pagesize1}) rows only
  985. --offset ((${page}-1)*${pagesize}) rows fetch NEXT (${pagesize}) rows only 60000
  986. --offset 25650 rows --fetch NEXT 10 rows only
  987. </sql>
  988. <limit>0</limit>
  989. <lookup/>
  990. <execute_each_row>N</execute_each_row>
  991. <variables_active>Y</variables_active>
  992. <lazy_conversion_active>N</lazy_conversion_active>
  993. <attributes/>
  994. <cluster_schema/>
  995. <remotesteps>
  996. <input>
  997. </input>
  998. <output>
  999. </output>
  1000. </remotesteps>
  1001. <GUI>
  1002. <xloc>176</xloc>
  1003. <yloc>32</yloc>
  1004. <draw>Y</draw>
  1005. </GUI>
  1006. </step>
  1007. <step>
  1008. <name>表输入 2</name>
  1009. <type>TableInput</type>
  1010. <description/>
  1011. <distribute>Y</distribute>
  1012. <custom_distribution/>
  1013. <copies>1</copies>
  1014. <partitioning>
  1015. <method>none</method>
  1016. <schema_name/>
  1017. </partitioning>
  1018. <connection>mall</connection>
  1019. <sql>select --ROW_NUMBER() over (order by OrderTime asc ) as MemberKey,
  1020. 1 as MemberKey,
  1021. case when sex= ''then 1 else sex end as MemberGender,
  1022. '' as MemberHeaPic,
  1023. Consignee as MemberNickName,
  1024. null as MemberBirthday,
  1025. dbo.DesDecryptFixKey('123456','123456e10adc3949ba59abbe56e057f20f883e',AConsigneePhone2) as PhoneId,
  1026. dbo.DesDecryptFixKey('123456','123456e10adc3949ba59abbe56e057f20f883e',AConsigneePhone2) as MemUsualPhone,--电话号码
  1027. case when AConsigneePhone1= '' then ''
  1028. ELSE dbo.DesDecryptFixKey('123456','123456e10adc3949ba59abbe56e057f20f883e',AConsigneePhone1) end as MemPhone1,--
  1029. case when AConsigneePhone2= '' then ''
  1030. ELSE dbo.DesDecryptFixKey('123456','123456e10adc3949ba59abbe56e057f20f883e',AConsigneePhone2) end as MemPhone2,--
  1031. case when AConsigneePhone3= '' then ''
  1032. ELSE dbo.DesDecryptFixKey('123456','123456e10adc3949ba59abbe56e057f20f883e',AConsigneePhone3) end as MemPhone3,--
  1033. case when ADeliveryAddress= '' then ''
  1034. ELSE dbo.DesDecryptFixKey('123456','123456e10adc3949ba59abbe56e057f20f883e',ADeliveryAddress) end as MemUsualAddress,
  1035. OriginType,
  1036. ( select CONVERT(varchar(100), min(b.OrderTime), 20) from orders b where b.AConsigneePhone2=a.AConsigneePhone2
  1037. and b.OrderTime!='1800/01/01 00:00:00'
  1038. group by b.AConsigneePhone2
  1039. )
  1040. as RegisterTime,
  1041. case when b0.Level= 3 then a.RegionCode else null end as MemUsualAreaCode,
  1042. case when b1.Level= 2 then b.ParentCode else b.AreaCode end as MemUsualCityCode,
  1043. case when c1.Level= 1 then c.ParentCode else c.AreaCode end as MemUsualProvinceCode
  1044. ,'true' as HasOrder
  1045. ,convert(varchar,datepart(year,getdate())) as RegisterYear
  1046. ,convert(varchar,datepart(month,getdate())) as RegisterMonth
  1047. ,convert(varchar,datepart(day,getdate())) as RegisterDay
  1048. ,BuyUserId as MemberId
  1049. ,OrdersCode
  1050. ,'' as MemEmail
  1051. ,'' as MemDesc
  1052. ,'Member' as order_join_field
  1053. from orders a
  1054. left join Areamap b0 on b0.MappingCode=a.RegionCode
  1055. left join AreaRegion b on b.AreaCode=a.RegionCode left join Areamap b1 on b1.MappingCode=b.ParentCode
  1056. left join AreaRegion c on c.AreaCode=b.ParentCode left join Areamap c1 on c1.MappingCode=c.ParentCode
  1057. where 1=1 and (a.AConsigneePhone2!= '' and a.AConsigneePhone2 is not null)
  1058. and OrderTime>'2019-05-01 00:22:10'
  1059. --and datediff(day,DATEADD(d,0,DATEDIFF(d,0,getdate())-21),OrderTime )>0
  1060. --and a.AConsigneePhone2='642E18F7DA186FA6B34D9054C9B8F5A2'--mall.dbo.DesEncryptFixKey('123456','123456e10adc3949ba59abbe56e057f20f883e','15962631520')
  1061. --and AConsigneePhone2 in (
  1062. --'0423F752B2D2AD0B473550BFE5FEA0AE','EEB4AB98536F6545C6CFDB35F978DAA2','996518B300E7E45E451BC4244799FFC9','18AAFDA225E18079D96E4B555C6FA0B3','818DA68D37C2918969736CF2A237C4A9','81F4601D958BE83AAD8616100C79108F','6D7361DB47D1E2EEE496C87DF06A0EC8','4E86D0A542AC090BBC25A111DC0666A0','18AF11B2567BA9C7AD6245626BB31BC9','F27A57F07A32709CFE74B6E7FA786FD3','086A73009D0013EBB1C478CC7B0FD12F','D07995C56FAF6397D1DB98F76204EB52','0E24B79BA1581333B9F06D3676C0CA64','67EF37A11980D8413374E138472F805B','64E6CCD18DA5488A474B6818AC00931D','ECF0974FD1AB5E5DFE761ED131FAA3E3','2B8D52A56FC4C2C4236F7C8CD01292BE','8D3314F80A83EAF8175ABB3672CBD7CC','F262784DB9E9252176A4B60AF654A2EC','D459D762D9E70F33194721F3FC2486B2','277375616683F8898B53DA4BB6C00438','00F902BE87871C2ADA10433144CB9F26','8097B72D91A133AF69C14EC181F4AB22','B412BCFF3767351B83C32484CD02F9C1','FA5108C230E3086603F226714B9C9AF2','C5DD26477A9CAAB3F01651233C272653','353FFD94515CD446D0DD22F3FC2E597E','7CED8EDDC54963E3139F14BD6B0F8641','8FC52187EA6A110ACCD4CB39EB3C5818','2EC8ED672FFBDEEA180DA466B76B38AC','DD31E235A35AAED95AF888D435F3DC47','3089BDEB1302CCA3619A9F49569F7B48','A39C6623271ABDB9F7F590543FC8057E','C529CE9490E26DD701539043E97E4BF8','EA35ED41C5A518715634ABFADE13B418','AE3ACFB96CC4EAC7D078AC09A6800FDC','3871D053F065EFBEAD600F33C636CDED','706BA31B06FE76728E001BCD47FD20BA','874C74568946B69D7FFB8AB335B65C33','ABC5625667D92349F1D7C5508FB975A9','64D7ED72C3EFBC0FE84D60EA24732417','4A39414F3F8BD22193D171A8ACC85B2C','7BDD4F56B12A818A5C173A17B1A6FB61','582E44926B1FBE3F0829348753F5BE24','EEA9F999433FC0EFB14B8F2FF393A3D6','E0DA009E7C441E1CC67AD7C3BC9E5927','2D037E57BFFABDF351EA646E7172A83F','E88D865B9E0C23448707C48F097FAFFA','8C4CC92F44D318DE27ED1803CDE0719A','9C0244F33187F34EA2B4AA8837EE2407','25E56D031E41BAA2585561E863AE3240','D62B7285ABD69A325866666FE8B1A211','041F49A973274CD46D88340492610836','55CC616C6267F7FFE6476E476A683B5B','D5F8294754A75ADA7F342254BECD8A36','72FEDECEC3573A85F1EF1E6D9168459F','A03BA4E861E08C2BD79014AACEB3457B','4F6D0500A89FB68AF57685751BF9FDD5','BB7A4324E327A17AC89E15A7E33B97D1','934DCB5E2CEDBE2F1BE2DF38E6B6FD21','CEAA74AD1FDBDF008D9303E8FAC9E58C','1DAE4B4EAB277D5C936F30D343669E8C','1E30EC2DB596EEA3F4075345313AD115','BB1F3A29FB1A7103B8456C6CCB4976C0','2EA2E7DC32064F9D2EBF9169B3B8B591','15FC5E0B1A7EA452E7850A941510B300','34950773FE2BB7AC1D238EFD747587DA','6698177B8F7DAEBA75FC9C74C7801082','486F95FCFF8784742535C89EECE12800','148B9F9220250C2D1AF3F18E8F4A7EFC','B5533EB90812BEC93350A70270A03543','3752A63527286C9549A5CDF0865FFFC8','1E7C72D95C9B3FD402C6705744AB19D7','36AC5937A03787B184BDE307231E2C45','661A29270751F08C48FA6ECBAB098668','97A8506E3BC4B9775E84ABF24FA8B5DF','5FDAB53E2C22942E71310FB030F00B7D','4093D2E26F44CD9E40D77BEBCAEA0E93','436E378BF7F5A53056B5900B67B49F62','832308EE1C5342C61B7C7F93152B4F6E','DA59338AF9229DE962CD20389F105F2D','57CB937F384116AC307430E400A5AB44','26922708241922654E119401117B1B94','25A811E19CC2E073909566BCD9D41361','EA3CB0E0ACBAFD16F50DB15602306E34','9901F0F13917C8CCE0352270BF2D0CD3','A39307DE9F3FB0190B98C527724F3B82','B8EDBB84091CC49A9AAFD251FCBDE7AF','4696EB55E911B7C24FFE7C3E65440072','3FCD315847A2F51E431857223432325E','201BD119927B3E06E39C05E75B3D9226','22B469D36AE35B57066305D87EFF8EA5','8B5F0F92E9E4B056B81D03519B7444C0','DEB97DEDBD570BEB7582F0E2AA03CC39','BD15992218632192AD7AFC515D9362FE','FC453359CA5378B600B36DA52F211251','663F850B4278422E5F8297179D1A576F','8696585F2EF20708D6EF342E294B8C1D','A395D12AF277D10EDAD439AC9AB08BCB','B7B2CD4DAA5DD09750ACD284D1992AA8','1779A33F6DA916B374FD714ABAE3FC18','3D28AC24BFC99A1550C75A4723FD46ECDE3E1974C7C408D872C1ABB463746192','0497493705B32E10CA97AD6C18710732','F270173F75C5DE0115062743D2EB7162','4FB7249A845C037D135FAFAA4F4C8035','E680E60C7BEE8A4E543E5641C5E7C802','3926C52407492CD87D7B957850C3EA3A','DB1EE0E9AB2D3E69E7C1522F169784DF','753BAF2406D831F3669E2D3A9D1D7F50','32D4F9F5ABAED2D54B6AFD9A5DDA3603','A92B24983AFF869AFCCB72BE4272FA20','B12D34376DA5676FB1188F1FB79D0E68','6EE25308B2AC781C3C1A728583DE2B27','39F4EAF971B477340CC238BD3129FA4A','631CEA72973147B759FDFFDFCF729558','6FF9FFCB9AB44C82C0ACCAD494549864','C40E83730FC4F81A33DA4A18DBD68A3B','6542F359BABB789F5CCE77325C609E8A','C69BDD440A2E1C55D21502DF8A66427A','1A819713BCF646541CBECC1887F5BF12','7245A7DDB91FC534BC2D0A4124DC115A','3466B4251F2B5B0EDED1A930405A9347','7B5A2B66DE344621B40882E1130CB0A2','E44DE94ECC5AF45103D2816BD557DACF','20DA5D3F0ED8B8361953876CAA7E618F','86896C4B29FC01CB20929AD02D1694C1','02E84A91CCCADD6BD315F6B1D86238C8','C0690FCB609433CC5338542019815072','FC8CC4CF43F997D0857C686CBA19BB78','8B79072AD66767252167F927A72A2ECB','E7BA3AFE24E5C46B2880B20EDF9F2814','D089136B015BFE0D6962C30A76B30397','DB167261B3048798706EB6FBCC2FC39A','F2C5ABD1FA6998E84B268718E2ECDE4E','3140AEE561B1B02B86D1149D871257DE','E787B20F2FA0441C3A337E9A8969A782','115DBE25E8A5CD08A28969A70E854034','61CB07B4C8D9C00FEC1BBA23DEC7894B','D4DBC7436582AD61B2F8709123D7B174','1613E515EE8D065C24001A8D4465FCA7','4F716E96C278C161AC984D5EE50CB9E9','1EE556430825950A2E9DDC81E4CE0857','A3AF63C59E2E37F4C4D3E5C8310F56D9','81A7D2CFC350FC946081CE1053844D8D','86B385A605CD471360C8BC118D7471E5','84AA28BB7153C39A4BFF0FF2E6CC9396','6D127E26B0280C66FFA70D4125371B7E','1674EC0D2026A13632CA672F2040D2A9','AAE4878B1960C904D8A19CF5221042E4','AF08B36889547EECD36D10CF20536279','4B7A89350213C12C0060B9AA8E06ECBE','7E907FEC97B8E10C4FEB77E2C92BE994','E93FE4F8AC12512BFF7E1307C18D483D','936CACC27696E6FED3CD47ED7C92E21C','30F64AD746EAE514D67A6B6C4CDECDBD','A065ADA7618F0560C2FCDB3A5703F4ED','F56F2D8477E79C9314B8E6CFBB516991','951C82B57831ADA7E30B34433B3D8648','9066B9B45E07E8DEC530DC808C73E8C9','1ED0B0E1EDF5D297C630D328AD7A323B','2EDCEB4B3369B08B3C67B66CBAD40116','3DA87AD9C4CD2B40EAC8EC27FCCF9408','9D7D1E92D68B24CB23B1BFD72C869B76','801FD14FB8F87640ED9C33193E30D983','D59E92E2F73A76DAE4D113FEC840BDE5','27EE2BB311B4209EBCF45A7E63D4028D','BFD94D45219AE8BFDFCC4C00E38B1CEE','6ABEDE3C15D40A8BB41B24170DFC765E','A0D798043917CA269ED76ADA26A20044','58F13DBC5CF59EEC90F19E70EBF8F4BC','7FB75D08E52EC0D379BC922749EC85EC','7F5097158F2882EA71A7B797B9718F08','312B3D5FC9B8B700424D6CAEDFD91E7E','E8722AED71CC6DD5A33DC9585BA80344','B9CC021D61995349476F46E8FFEB4E0D','B25FFAD1DDC8542A7CAAD0331C405C71','B1A1343DDDE78FE613C0C5A158F7C1C4','A53ADC4B9F1AC8618CBEA77BAACAC7F3','6C18608EC7A8BA88D0496A00CF711156','C767C3E9506F6E69ABEDD3A4F0E659F1','7F0A22B95B9A68B30D17DB07B1061EA1','CE1B88A69B7438D2231A74BACE309F12','E23CE33E9A39B32A1AACFB22BF943DE6','5ED3C490D43C210CC71A6A9AD75AA07C','66E793FF38F70C25D4E2F71CD2C15FA8','19A1E6D9411368BB808576246338172A','3D85B4F59411D2C1966451D7D169C4B4','3ADAF372B66AEB24E812BD0DFA40BDDC','1B1461AF3520DBB94F365BCF6C58DBEC','C9F14AF81CAB0766E5F385F76D9CC8E5','24C83A54492F7F92BC929E9CE2522161','4C6533B63414F3AB134C0F54C93FFC79','B672DD905B7337D7C8C165CC0B7F6282','EC2DC1B7285B63E95B7A9A1A586E00B5','D9D6F7CC155A3F01AF074AC32762E962','43E7A04E0260628DB2D923E6F2809F80','163F326D62390FE832C7DC7D31DFD0FE','7EF0F9855D9E5A2239672ED9D6CBD465','2F48FD445A7FB33D8CB9775D5B729B46','FEB6FD71EB9DA705687446BCF2380BF7','41663401F7E0096AE11E4760623CECC2','2032C9EADC95D3E915471052077A89CF','E3C6C365F30B112008CAE9DCBAEEC4C4','148B579D9F2C0E088431AE5A9C17F5FB','FECDCD7495FC501B706592B6C8FF92CE','3826222895D2DC548898560312666719','C60E8FD859276624C59BD9D8D7AEA56E','94D09FC7877AD3E0E476A3D43E9F90D6','BFBA3FA0B1114FB852432D5F953D77BB','183BC8E3D3452C2613D8BDF8F6E77BC5','D551CE55697416308D33E2F665FED2D426C9591C5C08933B15CC3D501B3B46E2','B1DC9AF9C1B2183A21F97E9DD119028D','8F25B71D6B9DED5107C600E5D4A4CCA8','6A1A3DC59F2B5CBFDF2038EAE704806B','16CB35A6A919B6A12B323928580277C4','D6EBD67E8BEEC2B442D475B0E753409E','9A3C1601FE78A76C13C97910A9E49FA6','4FB68069901C08B0502E5364965664CB','16559DC7CF7F430E4546740DFD4BB0F3','9FE33A926F39766B494E7D8299132455','7CB5B2BC8DA9E8FE6611E4A271D3069D','04262222623544E24457A3DB49F7287F','C2834F63C479220F76B7C3699839C3B3','0EC038F7C7F940DD23A391B69BD4D2CC','4C0CFBAE9095C1172A796DDC1C6EB0CB','50336EF5A905804B0FDA6CB5A30E2B1A','193BC933DECCFE1C5D2B4EA7FCCD4CFF','3D3A9F44184661254DA89F187B4B5EA6','29F066003D11A658D7E14335572D7E79','183BEC6770471275ABA7F1DF641A4A36','F5891A19FEE5EDA105702FDA96B0F9F2','F2D8152E78EA863E83521BB5BB165D28','B73728233E8311694FFA0357AC436874'
  1063. --)
  1064. order by OrderTime asc
  1065. offset ((${mem_membase_page2}-1)*${mem_membase_pagesize2}) rows fetch NEXT (${mem_membase_pagesize2}) rows only
  1066. --offset ((${page}-1)*${pagesize}) rows fetch NEXT (${pagesize}) rows only 1680000
  1067. --offset 23700 rows --fetch NEXT 10 rows only</sql>
  1068. <limit>0</limit>
  1069. <lookup/>
  1070. <execute_each_row>N</execute_each_row>
  1071. <variables_active>Y</variables_active>
  1072. <lazy_conversion_active>N</lazy_conversion_active>
  1073. <attributes/>
  1074. <cluster_schema/>
  1075. <remotesteps>
  1076. <input>
  1077. </input>
  1078. <output>
  1079. </output>
  1080. </remotesteps>
  1081. <GUI>
  1082. <xloc>144</xloc>
  1083. <yloc>96</yloc>
  1084. <draw>Y</draw>
  1085. </GUI>
  1086. </step>
  1087. <step>
  1088. <name>表输入 3</name>
  1089. <type>TableInput</type>
  1090. <description/>
  1091. <distribute>Y</distribute>
  1092. <custom_distribution/>
  1093. <copies>1</copies>
  1094. <partitioning>
  1095. <method>none</method>
  1096. <schema_name/>
  1097. </partitioning>
  1098. <connection>mall</connection>
  1099. <sql>select --ROW_NUMBER() over (order by OrderTime asc ) as MemberKey,
  1100. 1 as MemberKey,
  1101. case when sex= ''then 1 else sex end as MemberGender,
  1102. '' as MemberHeaPic,
  1103. Consignee as MemberNickName,
  1104. null as MemberBirthday,
  1105. dbo.DesDecryptFixKey('123456','123456e10adc3949ba59abbe56e057f20f883e',AConsigneePhone3) as PhoneId,
  1106. dbo.DesDecryptFixKey('123456','123456e10adc3949ba59abbe56e057f20f883e',AConsigneePhone3) as MemUsualPhone,--电话号码
  1107. case when AConsigneePhone1= '' then ''
  1108. ELSE dbo.DesDecryptFixKey('123456','123456e10adc3949ba59abbe56e057f20f883e',AConsigneePhone1) end as MemPhone1,--
  1109. case when AConsigneePhone2= '' then ''
  1110. ELSE dbo.DesDecryptFixKey('123456','123456e10adc3949ba59abbe56e057f20f883e',AConsigneePhone2) end as MemPhone2,--
  1111. case when AConsigneePhone3= '' then ''
  1112. ELSE dbo.DesDecryptFixKey('123456','123456e10adc3949ba59abbe56e057f20f883e',AConsigneePhone3) end as MemPhone3,--
  1113. case when ADeliveryAddress= '' then ''
  1114. ELSE dbo.DesDecryptFixKey('123456','123456e10adc3949ba59abbe56e057f20f883e',ADeliveryAddress) end as MemUsualAddress,
  1115. OriginType,
  1116. ( select CONVERT(varchar(100), min(b.OrderTime), 20) from orders b where b.AConsigneePhone3=a.AConsigneePhone3
  1117. and b.OrderTime!='1800/01/01 00:00:00'
  1118. group by b.AConsigneePhone3
  1119. )
  1120. as RegisterTime,
  1121. case when b0.Level= 3 then a.RegionCode else null end as MemUsualAreaCode,
  1122. case when b1.Level= 2 then b.ParentCode else b.AreaCode end as MemUsualCityCode,
  1123. case when c1.Level= 1 then c.ParentCode else c.AreaCode end as MemUsualProvinceCode
  1124. ,'true' as HasOrder
  1125. ,convert(varchar,datepart(year,getdate())) as RegisterYear
  1126. ,convert(varchar,datepart(month,getdate())) as RegisterMonth
  1127. ,convert(varchar,datepart(day,getdate())) as RegisterDay
  1128. ,BuyUserId as MemberId
  1129. ,OrdersCode
  1130. ,'' as MemEmail
  1131. ,'' as MemDesc
  1132. ,'Member' as order_join_field
  1133. from orders a
  1134. left join Areamap b0 on b0.MappingCode=a.RegionCode
  1135. left join AreaRegion b on b.AreaCode=a.RegionCode left join Areamap b1 on b1.MappingCode=b.ParentCode
  1136. left join AreaRegion c on c.AreaCode=b.ParentCode left join Areamap c1 on c1.MappingCode=c.ParentCode
  1137. where 1=1 and (a.AConsigneePhone3!= '' and a.AConsigneePhone3 is not null)
  1138. and OrderTime>'2019-05-01 00:22:10'
  1139. --and datediff(day,DATEADD(d,0,DATEDIFF(d,0,getdate())-21),OrderTime )>0
  1140. --and AConsigneePhone3 in (
  1141. --'0423F752B2D2AD0B473550BFE5FEA0AE','EEB4AB98536F6545C6CFDB35F978DAA2','996518B300E7E45E451BC4244799FFC9','18AAFDA225E18079D96E4B555C6FA0B3','818DA68D37C2918969736CF2A237C4A9','81F4601D958BE83AAD8616100C79108F','6D7361DB47D1E2EEE496C87DF06A0EC8','4E86D0A542AC090BBC25A111DC0666A0','18AF11B2567BA9C7AD6245626BB31BC9','F27A57F07A32709CFE74B6E7FA786FD3','086A73009D0013EBB1C478CC7B0FD12F','D07995C56FAF6397D1DB98F76204EB52','0E24B79BA1581333B9F06D3676C0CA64','67EF37A11980D8413374E138472F805B','64E6CCD18DA5488A474B6818AC00931D','ECF0974FD1AB5E5DFE761ED131FAA3E3','2B8D52A56FC4C2C4236F7C8CD01292BE','8D3314F80A83EAF8175ABB3672CBD7CC','F262784DB9E9252176A4B60AF654A2EC','D459D762D9E70F33194721F3FC2486B2','277375616683F8898B53DA4BB6C00438','00F902BE87871C2ADA10433144CB9F26','8097B72D91A133AF69C14EC181F4AB22','B412BCFF3767351B83C32484CD02F9C1','FA5108C230E3086603F226714B9C9AF2','C5DD26477A9CAAB3F01651233C272653','353FFD94515CD446D0DD22F3FC2E597E','7CED8EDDC54963E3139F14BD6B0F8641','8FC52187EA6A110ACCD4CB39EB3C5818','2EC8ED672FFBDEEA180DA466B76B38AC','DD31E235A35AAED95AF888D435F3DC47','3089BDEB1302CCA3619A9F49569F7B48','A39C6623271ABDB9F7F590543FC8057E','C529CE9490E26DD701539043E97E4BF8','EA35ED41C5A518715634ABFADE13B418','AE3ACFB96CC4EAC7D078AC09A6800FDC','3871D053F065EFBEAD600F33C636CDED','706BA31B06FE76728E001BCD47FD20BA','874C74568946B69D7FFB8AB335B65C33','ABC5625667D92349F1D7C5508FB975A9','64D7ED72C3EFBC0FE84D60EA24732417','4A39414F3F8BD22193D171A8ACC85B2C','7BDD4F56B12A818A5C173A17B1A6FB61','582E44926B1FBE3F0829348753F5BE24','EEA9F999433FC0EFB14B8F2FF393A3D6','E0DA009E7C441E1CC67AD7C3BC9E5927','2D037E57BFFABDF351EA646E7172A83F','E88D865B9E0C23448707C48F097FAFFA','8C4CC92F44D318DE27ED1803CDE0719A','9C0244F33187F34EA2B4AA8837EE2407','25E56D031E41BAA2585561E863AE3240','D62B7285ABD69A325866666FE8B1A211','041F49A973274CD46D88340492610836','55CC616C6267F7FFE6476E476A683B5B','D5F8294754A75ADA7F342254BECD8A36','72FEDECEC3573A85F1EF1E6D9168459F','A03BA4E861E08C2BD79014AACEB3457B','4F6D0500A89FB68AF57685751BF9FDD5','BB7A4324E327A17AC89E15A7E33B97D1','934DCB5E2CEDBE2F1BE2DF38E6B6FD21','CEAA74AD1FDBDF008D9303E8FAC9E58C','1DAE4B4EAB277D5C936F30D343669E8C','1E30EC2DB596EEA3F4075345313AD115','BB1F3A29FB1A7103B8456C6CCB4976C0','2EA2E7DC32064F9D2EBF9169B3B8B591','15FC5E0B1A7EA452E7850A941510B300','34950773FE2BB7AC1D238EFD747587DA','6698177B8F7DAEBA75FC9C74C7801082','486F95FCFF8784742535C89EECE12800','148B9F9220250C2D1AF3F18E8F4A7EFC','B5533EB90812BEC93350A70270A03543','3752A63527286C9549A5CDF0865FFFC8','1E7C72D95C9B3FD402C6705744AB19D7','36AC5937A03787B184BDE307231E2C45','661A29270751F08C48FA6ECBAB098668','97A8506E3BC4B9775E84ABF24FA8B5DF','5FDAB53E2C22942E71310FB030F00B7D','4093D2E26F44CD9E40D77BEBCAEA0E93','436E378BF7F5A53056B5900B67B49F62','832308EE1C5342C61B7C7F93152B4F6E','DA59338AF9229DE962CD20389F105F2D','57CB937F384116AC307430E400A5AB44','26922708241922654E119401117B1B94','25A811E19CC2E073909566BCD9D41361','EA3CB0E0ACBAFD16F50DB15602306E34','9901F0F13917C8CCE0352270BF2D0CD3','A39307DE9F3FB0190B98C527724F3B82','B8EDBB84091CC49A9AAFD251FCBDE7AF','4696EB55E911B7C24FFE7C3E65440072','3FCD315847A2F51E431857223432325E','201BD119927B3E06E39C05E75B3D9226','22B469D36AE35B57066305D87EFF8EA5','8B5F0F92E9E4B056B81D03519B7444C0','DEB97DEDBD570BEB7582F0E2AA03CC39','BD15992218632192AD7AFC515D9362FE','FC453359CA5378B600B36DA52F211251','663F850B4278422E5F8297179D1A576F','8696585F2EF20708D6EF342E294B8C1D','A395D12AF277D10EDAD439AC9AB08BCB','B7B2CD4DAA5DD09750ACD284D1992AA8','1779A33F6DA916B374FD714ABAE3FC18','3D28AC24BFC99A1550C75A4723FD46ECDE3E1974C7C408D872C1ABB463746192','0497493705B32E10CA97AD6C18710732','F270173F75C5DE0115062743D2EB7162','4FB7249A845C037D135FAFAA4F4C8035','E680E60C7BEE8A4E543E5641C5E7C802','3926C52407492CD87D7B957850C3EA3A','DB1EE0E9AB2D3E69E7C1522F169784DF','753BAF2406D831F3669E2D3A9D1D7F50','32D4F9F5ABAED2D54B6AFD9A5DDA3603','A92B24983AFF869AFCCB72BE4272FA20','B12D34376DA5676FB1188F1FB79D0E68','6EE25308B2AC781C3C1A728583DE2B27','39F4EAF971B477340CC238BD3129FA4A','631CEA72973147B759FDFFDFCF729558','6FF9FFCB9AB44C82C0ACCAD494549864','C40E83730FC4F81A33DA4A18DBD68A3B','6542F359BABB789F5CCE77325C609E8A','C69BDD440A2E1C55D21502DF8A66427A','1A819713BCF646541CBECC1887F5BF12','7245A7DDB91FC534BC2D0A4124DC115A','3466B4251F2B5B0EDED1A930405A9347','7B5A2B66DE344621B40882E1130CB0A2','E44DE94ECC5AF45103D2816BD557DACF','20DA5D3F0ED8B8361953876CAA7E618F','86896C4B29FC01CB20929AD02D1694C1','02E84A91CCCADD6BD315F6B1D86238C8','C0690FCB609433CC5338542019815072','FC8CC4CF43F997D0857C686CBA19BB78','8B79072AD66767252167F927A72A2ECB','E7BA3AFE24E5C46B2880B20EDF9F2814','D089136B015BFE0D6962C30A76B30397','DB167261B3048798706EB6FBCC2FC39A','F2C5ABD1FA6998E84B268718E2ECDE4E','3140AEE561B1B02B86D1149D871257DE','E787B20F2FA0441C3A337E9A8969A782','115DBE25E8A5CD08A28969A70E854034','61CB07B4C8D9C00FEC1BBA23DEC7894B','D4DBC7436582AD61B2F8709123D7B174','1613E515EE8D065C24001A8D4465FCA7','4F716E96C278C161AC984D5EE50CB9E9','1EE556430825950A2E9DDC81E4CE0857','A3AF63C59E2E37F4C4D3E5C8310F56D9','81A7D2CFC350FC946081CE1053844D8D','86B385A605CD471360C8BC118D7471E5','84AA28BB7153C39A4BFF0FF2E6CC9396','6D127E26B0280C66FFA70D4125371B7E','1674EC0D2026A13632CA672F2040D2A9','AAE4878B1960C904D8A19CF5221042E4','AF08B36889547EECD36D10CF20536279','4B7A89350213C12C0060B9AA8E06ECBE','7E907FEC97B8E10C4FEB77E2C92BE994','E93FE4F8AC12512BFF7E1307C18D483D','936CACC27696E6FED3CD47ED7C92E21C','30F64AD746EAE514D67A6B6C4CDECDBD','A065ADA7618F0560C2FCDB3A5703F4ED','F56F2D8477E79C9314B8E6CFBB516991','951C82B57831ADA7E30B34433B3D8648','9066B9B45E07E8DEC530DC808C73E8C9','1ED0B0E1EDF5D297C630D328AD7A323B','2EDCEB4B3369B08B3C67B66CBAD40116','3DA87AD9C4CD2B40EAC8EC27FCCF9408','9D7D1E92D68B24CB23B1BFD72C869B76','801FD14FB8F87640ED9C33193E30D983','D59E92E2F73A76DAE4D113FEC840BDE5','27EE2BB311B4209EBCF45A7E63D4028D','BFD94D45219AE8BFDFCC4C00E38B1CEE','6ABEDE3C15D40A8BB41B24170DFC765E','A0D798043917CA269ED76ADA26A20044','58F13DBC5CF59EEC90F19E70EBF8F4BC','7FB75D08E52EC0D379BC922749EC85EC','7F5097158F2882EA71A7B797B9718F08','312B3D5FC9B8B700424D6CAEDFD91E7E','E8722AED71CC6DD5A33DC9585BA80344','B9CC021D61995349476F46E8FFEB4E0D','B25FFAD1DDC8542A7CAAD0331C405C71','B1A1343DDDE78FE613C0C5A158F7C1C4','A53ADC4B9F1AC8618CBEA77BAACAC7F3','6C18608EC7A8BA88D0496A00CF711156','C767C3E9506F6E69ABEDD3A4F0E659F1','7F0A22B95B9A68B30D17DB07B1061EA1','CE1B88A69B7438D2231A74BACE309F12','E23CE33E9A39B32A1AACFB22BF943DE6','5ED3C490D43C210CC71A6A9AD75AA07C','66E793FF38F70C25D4E2F71CD2C15FA8','19A1E6D9411368BB808576246338172A','3D85B4F59411D2C1966451D7D169C4B4','3ADAF372B66AEB24E812BD0DFA40BDDC','1B1461AF3520DBB94F365BCF6C58DBEC','C9F14AF81CAB0766E5F385F76D9CC8E5','24C83A54492F7F92BC929E9CE2522161','4C6533B63414F3AB134C0F54C93FFC79','B672DD905B7337D7C8C165CC0B7F6282','EC2DC1B7285B63E95B7A9A1A586E00B5','D9D6F7CC155A3F01AF074AC32762E962','43E7A04E0260628DB2D923E6F2809F80','163F326D62390FE832C7DC7D31DFD0FE','7EF0F9855D9E5A2239672ED9D6CBD465','2F48FD445A7FB33D8CB9775D5B729B46','FEB6FD71EB9DA705687446BCF2380BF7','41663401F7E0096AE11E4760623CECC2','2032C9EADC95D3E915471052077A89CF','E3C6C365F30B112008CAE9DCBAEEC4C4','148B579D9F2C0E088431AE5A9C17F5FB','FECDCD7495FC501B706592B6C8FF92CE','3826222895D2DC548898560312666719','C60E8FD859276624C59BD9D8D7AEA56E','94D09FC7877AD3E0E476A3D43E9F90D6','BFBA3FA0B1114FB852432D5F953D77BB','183BC8E3D3452C2613D8BDF8F6E77BC5','D551CE55697416308D33E2F665FED2D426C9591C5C08933B15CC3D501B3B46E2','B1DC9AF9C1B2183A21F97E9DD119028D','8F25B71D6B9DED5107C600E5D4A4CCA8','6A1A3DC59F2B5CBFDF2038EAE704806B','16CB35A6A919B6A12B323928580277C4','D6EBD67E8BEEC2B442D475B0E753409E','9A3C1601FE78A76C13C97910A9E49FA6','4FB68069901C08B0502E5364965664CB','16559DC7CF7F430E4546740DFD4BB0F3','9FE33A926F39766B494E7D8299132455','7CB5B2BC8DA9E8FE6611E4A271D3069D','04262222623544E24457A3DB49F7287F','C2834F63C479220F76B7C3699839C3B3','0EC038F7C7F940DD23A391B69BD4D2CC','4C0CFBAE9095C1172A796DDC1C6EB0CB','50336EF5A905804B0FDA6CB5A30E2B1A','193BC933DECCFE1C5D2B4EA7FCCD4CFF','3D3A9F44184661254DA89F187B4B5EA6','29F066003D11A658D7E14335572D7E79','183BEC6770471275ABA7F1DF641A4A36','F5891A19FEE5EDA105702FDA96B0F9F2','F2D8152E78EA863E83521BB5BB165D28','B73728233E8311694FFA0357AC436874'
  1142. --)
  1143. order by OrderTime asc
  1144. offset ((${mem_membase_page3}-1)*${mem_membase_pagesize3}) rows fetch NEXT (${mem_membase_pagesize3}) rows only
  1145. --offset ((${page}-1)*${pagesize}) rows fetch NEXT (${pagesize}) rows only 200000
  1146. --offset 8750 rows --fetch NEXT 10 rows only</sql>
  1147. <limit>0</limit>
  1148. <lookup/>
  1149. <execute_each_row>N</execute_each_row>
  1150. <variables_active>Y</variables_active>
  1151. <lazy_conversion_active>N</lazy_conversion_active>
  1152. <attributes/>
  1153. <cluster_schema/>
  1154. <remotesteps>
  1155. <input>
  1156. </input>
  1157. <output>
  1158. </output>
  1159. </remotesteps>
  1160. <GUI>
  1161. <xloc>176</xloc>
  1162. <yloc>176</yloc>
  1163. <draw>Y</draw>
  1164. </GUI>
  1165. </step>
  1166. <step_error_handling>
  1167. </step_error_handling>
  1168. <slave-step-copy-partition-distribution>
  1169. </slave-step-copy-partition-distribution>
  1170. <slave_transformation>N</slave_transformation>
  1171. <attributes/>
  1172. </transformation>