DataWorks-flow-touch/jobs/task-step02.yaml

# 公司基本信息、招投标、环保处罚、购地信息、地块公示、行政处罚-信用中国、行政处罚、土地抵押、土地转让
job:
  #------<公司基本信息
  - project: winhc_test
    flow: inc_company_spark
    task:
      - taskName: company_inc
        param:
          - _nodeId: 700003381602
            project: winhc_eci_dev
  #------>
  - project: winhc_test
    flow: company_judicial_human
    task:
      - taskName: company_judicial_human
        param:
          - _nodeId: 700003575645
            project: winhc_eci_dev
  - project: winhc_test
    flow: inc_company_annual_report
    task:
      - taskName: inc_company_annual_report
        param:
          - _nodeId: 700003490192
            project: winhc_eci_dev
  - project: winhc_test
    flow: inc_company_staff
    task:
      - taskName: inc_company_staff
        param:
          - _nodeId: 700003466743
            project: winhc_eci_dev
  # 招聘
  - project: winhc_test
    flow: incr_calc_intellectual
    task:
      - taskName: company_holder
        param:
          - _nodeId: 700003375026
            project: winhc_eci_dev
            tableName: company_holder
            dupliCols: new_cid,holder_id
            flag: cid
          - _nodeId: 700003380225
            project: winhc_eci_dev
            tableName: company_holder
            cidField: new_cid
            dupliCols: new_cid,holder_id
      - taskName: company_dishonest_info
        param:
          - _nodeId: 700003375026
            project: winhc_eci_dev
            tableName: company_dishonest_info
            dupliCols: new_cid,case_no
            flag: cid
          - _nodeId: 700003380225
            project: winhc_eci_dev
            tableName: company_dishonest_info
            cidField: new_cid
            dupliCols: new_cid,case_no
      - taskName: company_finance
        param:
          - _nodeId: 700003375026
            project: winhc_eci_dev
            tableName: company_finance
            dupliCols: new_cid,round,money
            flag: cid
          - _nodeId: 700003380225
            project: winhc_eci_dev
            tableName: company_finance
            cidField: new_cid
            dupliCols: new_cid,round,money
      - taskName: company_illegal_info
        param:
          - _nodeId: 700003375026
            project: winhc_eci_dev
            tableName: company_illegal_info
            dupliCols: new_cid,put_reason,put_date,put_department
            flag: cid
          - _nodeId: 700003380225
            project: winhc_eci_dev
            tableName: company_illegal_info
            cidField: new_cid
            dupliCols: new_cid,put_reason,put_date,put_department
      - taskName: company_change
        param:
          - _nodeId: 700003375026
            project: winhc_eci_dev
            tableName: company_change
            dupliCols: new_cid,change_item,change_time
            flag: cid
          - _nodeId: 700003380225
            project: winhc_eci_dev
            tableName: company_change
            cidField: new_cid
            dupliCols: new_cid,change_item,change_time
      - taskName: company_employment
        param:
          - _nodeId: 700003375026
            project: winhc_eci_dev
            tableName: company_employment
            dupliCols: title,new_cid,url_path
            flag: cid
          - _nodeId: 700003380225
            project: winhc_eci_dev
            tableName: company_employment
            cidField: new_cid
            dupliCols: title,new_cid,url_path
  #------<招投标:Spark
  - project: winhc_test
    flow: incr_calc_intellectual
    task:
      - taskName: company_bid
        param:
          - _nodeId: 700003375026
            project: winhc_eci_dev
            tableName: company_bid
            dupliCols: new_cid,title,link,publish_time
            flag: cids
          - _nodeId: 700003380225
            project: winhc_eci_dev
            tableName: company_bid_list
            cidField: new_cid
            dupliCols: new_cid,title,link,publish_time
      #------>
      #------<环保处罚
      - taskName: company_env_punishment
        param:
          - _nodeId: 700003375026
            project: winhc_eci_dev
            tableName: company_env_punishment
            dupliCols: new_cid,name,source_url,punish_number
            flag: cid
          - _nodeId: 700003380225
            project: winhc_eci_dev
            tableName: company_land_publicity
            cidField: new_cid
            dupliCols: new_cid,title,project_name,source_url
      #------>
      #------<购地信息:Spark
      - taskName: company_land_announcement
        param:
          - _nodeId: 700003375026
            project: winhc_eci_dev
            tableName: company_land_announcement
            dupliCols: new_cid,source_url,e_number,project_name
            flag: cid
          - _nodeId: 700003380225
            project: winhc_eci_dev
            tableName: company_land_announcement
            cidField: new_cid
            dupliCols: new_cid,source_url,e_number,project_name
      #------>
      #------<地块公示:Spark
      - taskName: company_land_publicity
        param:
          - _nodeId: 700003375026
            project: winhc_eci_dev
            tableName: company_land_publicity
            dupliCols: new_cid,title,project_name,source_url
            flag: cid
          - _nodeId: 700003380225
            project: winhc_eci_dev
            tableName: company_land_publicity
            cidField: new_cid
            dupliCols: new_cid,title,project_name,source_url
      #------>
      #------<行政处罚-信用中国:SPARK
      - taskName: company_punishment_info_creditchina
        param:
          - _nodeId: 700003375026
            project: winhc_eci_dev
            tableName: company_punishment_info_creditchina
            dupliCols: new_cid,company_name,source,punish_number
            flag: cid
          - _nodeId: 700003380225
            project: winhc_eci_dev
            tableName: company_punishment_info_creditchina
            cidField: new_cid
            dupliCols: new_cid,company_name,source,punish_number
      #------>
      #------<行政处罚:SPARK
      - taskName: company_punishment_info
        param:
          - _nodeId: 700003375026
            project: winhc_eci_dev
            tableName: company_punishment_info
            dupliCols: new_cid,name,source,desc_file_path,punish_number
            flag: cid
          - _nodeId: 700003380225
            project: winhc_eci_dev
            tableName: company_punishment_info
            cidField: new_cid
            dupliCols: new_cid,name,source,desc_file_path,punish_number
  #------>
  #------<土地抵押:ODPS SQL
  - project: winhc_test
    flow: inc_company_land_mortgage_sql
    task:
      - taskName: company_land_mortgage
        param:
          - _nodeId: 700003375909
            PROJECT: winhc_eci_dev
          #            DIM_TABLE: company_land_mortgage
          - _nodeId: 700003375910
            PROJECT: winhc_eci_dev
            DIM_TABLE: company_land_mortgage
            DIM_COLUMS: type,id,land_mark,land_num,land_aministrative_area,land_loc,land_area,other_item_num,use_right_num,mortgagor,mortgagee,nature,use_for,use_type,area,evaluate_amount,mortgage_amount,source_url,start_date,end_date,create_time,update_time,deleted
            DUPLI_COLS: new_cid,type,source_url,land_mark,land_num
            MD5_COLS: type,land_num,land_mark,source_url
          - _nodeId: 700003422526
            PROJECT: winhc_eci_dev
            DIM_TABLE: company_land_mortgage
            # todo
          - _nodeId: 700003532684
            project: winhc_eci_dev
            tableName: company_land_mortgage
            cidField: new_cid
            dupliCols: new_cid,type,source_url,land_mark,land_num
  #------>
  #------<土地转让:ODPS SQL
  - project: winhc_test
    flow: inc_company_land_transfer_sql
    task:
      - taskName: company_land_transfer
        param:
          - _nodeId: 700003377079
            PROJECT: winhc_eci_dev
            #            DIM_TABLE: company_land_transfer
            DS: 20200717
          - _nodeId: 700003377080
            PROJECT: winhc_eci_dev
            DIM_TABLE: company_land_transfer
            DIM_COLUMS: type,id,mark,num,location,aministrative_area,user_pre,user_now,area,use_for,use_type,years_of_use,situation,level,merchandise_type,merchandise_price,merchandise_time,url,create_time,update_time,deleted
            DUPLI_COLS: new_cid,type,num,location,url
            MD5_COLS: type,num,location,url
            DS: 20200717
          - _nodeId: 700003421692
            PROJECT: winhc_eci_dev
            DIM_TABLE: company_land_transfer
          # todo
          - _nodeId: 700003532680
            project: winhc_eci_dev
            tableName: company_land_transfer
            cidField: new_cid
            dupliCols: new_cid,type,num,location,url
  #------>
  #------<公示催告:Spark
  - project: winhc_test
    flow: incr_calc_intellectual
    task:
      - taskName: company_public_announcement2
        param:
          - _nodeId: 700003375026
            project: winhc_eci_dev
            tableName: company_public_announcement2
            dupliCols: new_cid,applicant_cid,owner_cid,drawer_cid,gather_name_cid,bill_num
            flag: cids
          - _nodeId: 700003380225
            project: winhc_eci_dev
            tableName: company_public_announcement2_list
            cidField: new_cid
            dupliCols: new_cid,applicant_cid,owner_cid,drawer_cid,gather_name_cid,bill_num
  #------>
  #------<动产抵押-抵押信息:Spark
  - project: winhc_test
    flow: incr_calc_intellectual_without_md5
    task:
      - taskName: company_mortgage_info
        param:
          - _nodeId: 700003483308
            project: winhc_eci_dev
            tableName: company_mortgage_info
            dupliCols: new_cid,id
            flag: cid
  #------>
  #------<动产抵押-抵押人:Spark
  - project: winhc_test
    flow: incr_calc_intellectual_without_md5
    task:
      - taskName: company_mortgage_people
        param:
          - _nodeId: 700003483308
            project: winhc_eci_dev
            tableName: company_mortgage_people
            dupliCols: new_cid,main_id,id
            flag: cid
  #------>
  #------<动产抵押-抵押物:Spark
  - project: winhc_test
    flow: incr_calc_intellectual_without_md5
    task:
      - taskName: company_mortgage_pawn
        param:
          - _nodeId: 700003483308
            project: winhc_eci_dev
            tableName: company_mortgage_pawn
            dupliCols: new_cid,main_id,id
            flag: cid
  #------>
  #------<企业公告:Spark
  - project: winhc_test
    flow: incr_calc_intellectual
    task:
      - taskName: company_stock_announcement
        param:
          - _nodeId: 700003375026
            project: winhc_eci_dev
            tableName: company_stock_announcement
            dupliCols: new_cid,title,time
            flag: cid
          - _nodeId: 700003380225
            project: winhc_eci_dev
            tableName: company_stock_announcement
            cidField: new_cid
            dupliCols: new_cid,title,time
  #------>
  #------<送达公告:Spark
  - project: winhc_test
    flow: incr_calc_intellectual
    task:
      - taskName: company_send_announcement
        param:
          - _nodeId: 700003375026
            project: winhc_eci_dev
            tableName: company_send_announcement
            dupliCols: new_cid,litigant_cids,start_date,case_no
            flag: cids
          - _nodeId: 700003380225
            project: winhc_eci_dev
            tableName: company_send_announcement_list
            cidField: new_cid
            dupliCols: new_cid,litigant_cids,start_date,case_no
  #------>
  #------<年报-对外担保:Spark
  - project: winhc_test
    flow: incr_calc_intellectual_without_md5
    task:
      - taskName: company_annual_report_out_guarantee
        param:
          - _nodeId: 700003483308
            project: winhc_eci_dev
            tableName: company_annual_report_out_guarantee
            dupliCols: new_cid,id
            flag: cid
  #------>
  #------<限制消费令(企业）:Spark
  - project: winhc_test
    flow: incr_calc_intellectual
    task:
      - taskName: company_zxr_restrict
        param:
          - _nodeId: 700003375026
            project: winhc_eci_dev
            tableName: company_zxr_restrict
            dupliCols: new_cid,name,case_no
            flag: cid
          - _nodeId: 700003380225
            project: winhc_eci_dev
            tableName: company_zxr_restrict
            cidField: new_cid
            dupliCols: new_cid,name,case_no
  #------<限制消费令(个人）:Spark
  - project: winhc_test
    flow: incr_calc_intellectual_person
    task:
      - taskName: company_zxr_restrict_person
        param:
          - _nodeId: 700003570682
            project: winhc_eci_dev
            tableName: company_zxr_restrict
            idCardCol: card
            dupliCols: name,case_no
            cidCol: cid
            updateCol: update_time
  #------<失信人(个人）:Spark
  - project: winhc_test
    flow: incr_calc_intellectual_person
    task:
      - taskName: company_dishonest_info_person
        param:
          - _nodeId: 700003570682
            project: winhc_eci_dev
            tableName: company_dishonest_info
            idCardCol: card_num
            dupliCols: name,case_no
            cidCol: cid
            updateCol: update_time
  #------>
  #------<简易注销:Spark
  - project: winhc_test
    flow: incr_calc_intellectual_without_md5
    task:
      - taskName: company_brief_cancel_announcement
        param:
          - _nodeId: 700003483308
            project: winhc_eci_dev
            tableName: company_brief_cancel_announcement
            dupliCols: new_cid,id
            flag: cid
  #------>
  #------<简易注销-结果:Spark
      - taskName: company_brief_cancel_announcement_result
        param:
          - _nodeId: 700003483308
            project: winhc_eci_dev
            tableName: company_brief_cancel_announcement_result
            dupliCols: new_cid,main_id,id
            flag: cid
  #------>
  #------<简易注销-异议:Spark
      - taskName: company_brief_cancel_announcement_objection
        param:
          - _nodeId: 700003483308
            project: winhc_eci_dev
            tableName: company_brief_cancel_announcement_objection
            dupliCols: new_cid,main_id,id
            flag: cid
  #------>
  #------<清算信息:Spark
      - taskName: company_liquidating_info
        param:
          - _nodeId: 700003483308
            project: winhc_eci_dev
            tableName: company_liquidating_info
            dupliCols: new_cid,id
            flag: cid
  #------>
  - project: winhc_test
    flow: inc_company_mapping
    task:
      #run-1
      - taskName: inc_company_mapping
        param:
          - _nodeId: 700003457354
            project: winhc_eci_dev
  - project: winhc_test
    flow: inc_company_equity_info
    task:
      #run-1
      - taskName: inc_company_equity_info
        param:
          - _nodeId: 700003452779
            project: winhc_eci_dev

  - project: winhc_test
    flow: incr_calc_intellectual
    task:
      - taskName: company_own_tax
        param:
          - _nodeId: 700003375026
            project: winhc_eci_dev
            tableName: company_own_tax
            dupliCols: new_cid,tax_balance,tax_category,tax_num
            flag: cid
          - _nodeId: 700003380225
            project: winhc_eci_dev
            tableName: company_own_tax
            cidField: new_cid
            dupliCols: new_cid,tax_balance,tax_category,tax_num
      #run-1
      - taskName: company_certificate
        param:
          - _nodeId: 700003375026
            project: winhc_eci_dev
            tableName: company_certificate
            dupliCols: new_cid,start_date,end_date,cert_no,type
            flag: cid
          - _nodeId: 700003380225
            project: winhc_eci_dev
            tableName: company_certificate
            cidField: new_cid
            dupliCols: new_cid,start_date,end_date,cert_no,type
      #run-1
      - taskName: company_abnormal_info
        param:
          - _nodeId: 700003375026
            project: winhc_eci_dev
            tableName: company_abnormal_info
            dupliCols: new_cid,put_reason,put_date
            flag: cid
          - _nodeId: 700003380225
            project: winhc_eci_dev
            tableName: company_abnormal_info
            cidField: new_cid
            dupliCols: new_cid,put_reason,put_date
      #run-1
      - taskName: company_icp
        param:
          - _nodeId: 700003375026
            project: winhc_eci_dev
            tableName: company_icp
            dupliCols: new_cid,liscense,domain
            flag: cid
          - _nodeId: 700003380225
            project: winhc_eci_dev
            tableName: company_icp
            cidField: new_cid
            dupliCols: new_cid,liscense,domain

      #run-1
      - taskName: company_app_info
        param:
          - _nodeId: 700003375026
            project: winhc_eci_dev
            tableName: company_app_info
            dupliCols: new_cid,name
            flag: cid
          - _nodeId: 700003380225
            project: winhc_eci_dev
            tableName: company_app_info
            cidField: new_cid
            dupliCols: new_cid,name

      #run -1
      - taskName: company_copyright_reg
        param:
          - _nodeId: 700003375026
            project: winhc_eci_dev
            tableName: company_copyright_reg
            dupliCols: new_cid,reg_num
            flag: cids
          - _nodeId: 700003380225
            project: winhc_eci_dev
            tableName: company_copyright_reg_list
            cidField: new_cid
            dupliCols: new_cid,reg_num

      #run-1
      - taskName: company_wechat
        param:
          - _nodeId: 700003375026
            project: winhc_eci_dev
            tableName: company_wechat
            dupliCols: new_cid,public_num
            flag: cid
          - _nodeId: 700003380225
            project: winhc_eci_dev
            tableName: company_wechat
            cidField: new_cid
            dupliCols: new_cid,public_num

      #run -1
      - taskName: company_tm
        param:
          - _nodeId: 700003375026
            project: winhc_eci_dev
            tableName: company_tm
            dupliCols: new_cid,reg_no
            flag: cid
          - _nodeId: 700003380225
            project: winhc_eci_dev
            tableName: company_tm
            cidField: new_cid
            dupliCols: new_cid,reg_no

        #run -1
      - taskName: company_patent
        param:
          - _nodeId: 700003375026
            project: winhc_eci_dev
            tableName: company_patent
            dupliCols: new_cid,pub_number,app_number
            flag: cids
          - _nodeId: 700003380225
            project: winhc_eci_dev
            tableName: company_patent_list
            cidField: new_cid
            dupliCols: new_cid,pub_number,app_number


      #run-1
      - taskName: company_copyright_works
        param:
          - _nodeId: 700003375026
            project: winhc_eci_dev
            tableName: company_copyright_works
            dupliCols: new_cid,reg_num
            flag: cids
          - _nodeId: 700003380225
            project: winhc_eci_dev
            tableName: company_copyright_works_list
            cidField: new_cid
            dupliCols: new_cid,reg_num

  - project: winhc_test
    flow: incr_calc_intellectual
    task:

      #裁判文书
      - taskName: wenshu_detail_combine
        param:
          - _nodeId: 700003375026
            project: winhc_eci_dev
            tableName: wenshu_detail_combine
            dupliCols: new_cid,case_no,cname
            flag: cid
          - _nodeId: 700003380225
            project: winhc_eci_dev
            tableName: wenshu_detail_combine
            cidField: new_cid
            dupliCols: new_cid,case_no,cname

      #行政许可
      - taskName: company_license
        param:
          - _nodeId: 700003375026
            project: winhc_eci_dev
            tableName: company_license
            dupliCols: new_cid,license_number
            flag: cid
          - _nodeId: 700003380225
            project: winhc_eci_dev
            tableName: company_license
            cidField: new_cid
            dupliCols: new_cid,license_number

      #行政许可-企业公示
      - taskName: company_license_entpub
        param:
          - _nodeId: 700003375026
            project: winhc_eci_dev
            tableName: company_license_entpub
            dupliCols: new_cid,license_number
            flag: cid
          - _nodeId: 700003380225
            project: winhc_eci_dev
            tableName: company_license_entpub
            cidField: new_cid
            dupliCols: new_cid,license_number

      #行政许可-信用中国
      - taskName: company_license_creditchina
        param:
          - _nodeId: 700003375026
            project: winhc_eci_dev
            tableName: company_license_creditchina
            dupliCols: new_cid,licence_number
            flag: cid
          - _nodeId: 700003380225
            project: winhc_eci_dev
            tableName: company_license_creditchina
            cidField: new_cid
            dupliCols: new_cid,licence_number

      #终本案件
      - taskName: company_zxr_final_case
        param:
          - _nodeId: 700003375026
            project: winhc_eci_dev
            tableName: company_zxr_final_case
            dupliCols: new_cid,case_no
            flag: cid
          - _nodeId: 700003380225
            project: winhc_eci_dev
            tableName: company_zxr_final_case
            cidField: new_cid
            dupliCols: new_cid,case_no

      #司法拍卖
      - taskName: company_judicial_sale_combine
        param:
          - _nodeId: 700003375026
            project: winhc_eci_dev
            tableName: company_judicial_sale_combine
            dupliCols: new_cid,main_id
            flag: cids
          - _nodeId: 700003380225
            project: winhc_eci_dev
            tableName: company_judicial_sale_combine_list
            cidField: new_cid
            dupliCols: new_cid,main_id

      #双随机抽查-结果公示
      - taskName: company_double_random_check_result_info
        param:
          - _nodeId: 700003375026
            project: winhc_eci_dev
            tableName: company_double_random_check_result_info
            dupliCols: new_cid,main_id,check_item
            flag: cid
          - _nodeId: 700003380225
            project: winhc_eci_dev
            tableName: company_double_random_check_result_info
            cidField: new_cid
            dupliCols: new_cid,main_id,check_item

      #双随机抽查
      - taskName: company_double_random_check_info
        param:
          - _nodeId: 700003375026
            project: winhc_eci_dev
            tableName: company_double_random_check_info
            dupliCols: new_cid,check_task_num
            flag: cid
          - _nodeId: 700003380225
            project: winhc_eci_dev
            tableName: company_double_random_check_info
            cidField: new_cid
            dupliCols: new_cid,check_task_num

      #抽查检查
      - taskName: company_check_info
        param:
          - _nodeId: 700003375026
            project: winhc_eci_dev
            tableName: company_check_info
            dupliCols: new_cid,check_org,check_date
            flag: cid
          - _nodeId: 700003380225
            project: winhc_eci_dev
            tableName: company_check_info
            cidField: new_cid
            dupliCols: new_cid,check_org,check_date

      #税收违法
      - taskName: company_tax_contravention
        param:
          - _nodeId: 700003375026
            project: winhc_eci_dev
            tableName: company_tax_contravention
            dupliCols: new_cid,taxpayer_number,case_info
            flag: cid
          - _nodeId: 700003380225
            project: winhc_eci_dev
            tableName: company_tax_contravention
            cidField: new_cid
            dupliCols: new_cid,taxpayer_number,case_info

      #法院公告
      - taskName: company_court_announcement
        param:
          - _nodeId: 700003375026
            project: winhc_eci_dev
            tableName: company_court_announcement
            dupliCols: new_cid,case_no,announcement_type,publish_date,court_name
            flag: cids
          - _nodeId: 700003380225
            project: winhc_eci_dev
            tableName: company_court_announcement_list
            cidField: new_cid
            dupliCols: new_cid,case_no,announcement_type,publish_date,court_name

      #立案信息
      - taskName: company_court_register
        param:
          - _nodeId: 700003375026
            project: winhc_eci_dev
            tableName: company_court_register
            dupliCols: new_cid,case_no,plaintiff,defendant
            flag: cids
          - _nodeId: 700003380225
            project: winhc_eci_dev
            tableName: company_court_register_list
            cidField: new_cid
            dupliCols: new_cid,case_no,plaintiff,defendant

      #开庭公告
      - taskName: company_court_open_announcement
        param:
          - _nodeId: 700003375026
            project: winhc_eci_dev
            tableName: company_court_open_announcement
            dupliCols: new_cid,case_no,start_date
            flag: cids
          - _nodeId: 700003380225
            project: winhc_eci_dev
            tableName: company_court_open_announcement_list
            cidField: new_cid
            dupliCols: new_cid,case_no,start_date


      #被执行人 增量 企业
  - project: winhc_test
    flow: incr_calc_intellectual
    task:
      - taskName: company_zxr
        param:
          - _nodeId: 700003375026
            project: winhc_eci_dev
            tableName: company_zxr
            dupliCols: cname,case_no
            flag: cids
          - _nodeId: 700003380225
            project: winhc_eci_dev
            tableName: company_zxr_list
            cidField: new_cid
            dupliCols: cname,case_no


  - project: winhc_test
    flow: incr_calc_intellectual_person
    task:
      - taskName: company_zxr_person
        param:
          - _nodeId: 700003570682
            project: winhc_eci_dev
            tableName: company_zxr
            idCardCol: card
            dupliCols: cname,case_no
            cidCol: cids
            updateCol: update_time


  - project: winhc_test
    flow: incr_calc_intellectual_person
    task:
      - taskName: company_zxr_final_case_person
        param:
          - _nodeId: 700003570682
            project: winhc_eci_dev
            tableName: company_zxr_final_case
            idCardCol: identity_num
            dupliCols: name,case_no
            cidCol: cid
            updateCol: update_time