task-step01.yaml 3.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102
  1. # 公司基本信息、招投标、环保处罚、购地信息、地块公示、行政处罚-信用中国、行政处罚、土地抵押、土地转让
  2. job:
  3. #------<公示催告:ODPS SQL
  4. - project: winhc_test
  5. flow: inc_company_public_announcement_sql
  6. task:
  7. - taskName: company_public_announcement2
  8. param:
  9. - _nodeId: 700003471556
  10. PROJECT: winhc_eci_dev
  11. #------>
  12. - project: winhc_eci
  13. flow: company_judicial_sale
  14. task:
  15. #run-1 司法拍卖前置任务
  16. - taskName: company_judicial_sale
  17. param:
  18. - _nodeId: 700003485951
  19. project: winhc_eci_dev
  20. tableName: company_judicial_sale
  21. - project: winhc_eci
  22. flow: wenshu_detail_combine
  23. task:
  24. #run-1 文书前置任务
  25. - taskName: wenshu_detail_combine
  26. param:
  27. - _nodeId: 700003495086
  28. project: winhc_eci_dev
  29. tableName: wenshu_detail_combine
  30. - project: winhc_eci
  31. flow: company_incr_combine
  32. task:
  33. #专利增量合并
  34. - taskName: inc_company_patent_pre
  35. param:
  36. - _nodeId: 700003517752
  37. project: winhc_eci_dev
  38. source: winhc_eci.inc_ods_company_patent_pre
  39. target: winhc_eci_dev.inc_ods_company_patent
  40. flag: 0
  41. #终本案件增量合并
  42. - taskName: inc_ods_company_zxr_final_case_pre
  43. param:
  44. - _nodeId: 700003517752
  45. project: winhc_eci_dev
  46. source: winhc_eci.inc_ods_company_zxr_final_case_pre
  47. target: winhc_eci_dev.inc_ods_company_zxr_final_case
  48. flag: 0
  49. #失信人增量合并
  50. - taskName: inc_ods_company_dishonest_info_pre
  51. param:
  52. - _nodeId: 700003517752
  53. project: winhc_eci_dev
  54. source: winhc_eci.inc_ods_company_dishonest_info_pre
  55. target: winhc_eci_dev.inc_ods_company_dishonest_info
  56. flag: 0
  57. #执行人增量合并
  58. - taskName: inc_ods_company_zxr_pre
  59. param:
  60. - _nodeId: 700003517752
  61. project: winhc_eci_dev
  62. source: winhc_eci.inc_ods_company_zxr_pre
  63. target: winhc_eci_dev.inc_ods_company_zxr
  64. flag: 0
  65. #开庭公告增量合并
  66. - taskName: inc_ods_company_court_open_announcement_pre
  67. param:
  68. - _nodeId: 700003517752
  69. project: winhc_eci_dev
  70. source: winhc_eci.inc_ods_company_court_open_announcement_pre
  71. target: winhc_eci_dev.inc_ods_company_court_open_announcement
  72. flag: 0
  73. #企业银行帐户增量合并
  74. - taskName: inc_ods_company_account_with_bank_pre
  75. param:
  76. - _nodeId: 700003517752
  77. project: winhc_eci_dev
  78. source: winhc_eci.inc_ods_company_account_with_bank_pre
  79. target: winhc_eci_dev.inc_ods_company_account_with_bank
  80. flag: 1
  81. #------<企业cid、自然人身份证补全:Spark
  82. - project: winhc_test
  83. flow: company_person_info_completion
  84. task:
  85. - taskName: company_cloze
  86. param:
  87. - _nodeId: 700003580841
  88. project: winhc_eci_dev
  89. flag: false
  90. - _nodeId: 700003578968
  91. project: winhc_eci_dev
  92. flag: false
  93. #------>