融资v8

src/main/scala/com/winhc/bigdata/spark/ng/jobs/args_company_job.scala

@@ -484,8 +484,53 @@ object args_company_job {
       , rowkey_udf = "concat_ws('_', main_id, md5(cleanup(concat_ws('',main_id))) )"
       , is_super_filter = false
     )
+//融资
+    , args_company_job("accounts_receivablae", Seq("company_name", "notice_date", "pledgee_info", "assignee_info", "deadline")
+      , rowkey_udf = "md5(cleanup(concat_ws('', company_name, split_date(cast(notice_date as String)), get_text_from_json(pledgee_info, 'pledgee'), get_text_from_json(assignee_info, 'assignee'), deadline)))"
+      , is_super_filter = false
+    )
+
+    , args_company_job("dcm_registration_limit", Seq("company_id", "fileno", "bond_lassify", "start_date")
+        , rowkey_udf = "md5(cleanup(concat_ws('', company_id, fileno, bond_lassify, split_date(cast(start_date as String)))))"
+        , is_super_filter = false
+    )
+
+    , args_company_job("bond_financing", Seq("company_id", "abbreviation", "symbol")
+      , rowkey_udf = "md5(cleanup(concat_ws('', company_id, abbreviation, symbol)))"
+      , is_super_filter = false
+    )
 
 
+    , args_company_job("overseas_bond_financing", Seq("company_id", "bond_simple_name", "issue_date")
+      , rowkey_udf = "md5(cleanup(concat_ws('', company_id, bond_simple_name, split_date(cast(issue_date as String)))))"
+      , is_super_filter = false
+    )
+
+    , args_company_job("bank_loan", Seq("company_id", "creditor", "amount_financed", "start_date")
+      , rowkey_udf = "md5(cleanup(concat_ws('', company_id, creditor, amount_financed, split_date(cast(start_date as String)))))"
+      , is_super_filter = false
+    )
+
+    , args_company_job("credit_line", Seq("company_id", "end_date", "discloure_date", "credit_line")
+      , rowkey_udf = "md5(cleanup(concat_ws('', company_id, split_date(cast(end_date as String)), split_date(cast(discloure_date as String)), credit_line)))"
+      , is_super_filter = false
+    )
+
+
+    , args_company_job("lease_financing", Seq("company_id", "leaser_info", "equity", "start_date")
+      , rowkey_udf = "md5(cleanup(concat_ws('', company_id, get_text_from_json(leaser_info, 'company_name'), equity, split_date(cast(start_date as String)))))"
+      , is_super_filter = false
+    )
+
+    , args_company_job("trust_financing", Seq("company_id", "consignee_name_list", "notice_date", "start_date")
+      , rowkey_udf = "md5(cleanup(concat_ws('', company_id, split_date(cast(notice_date as String)), get_text_from_json(consignee_name_list, 'company_name'), split_date(cast(start_date as String)))))"
+      , is_super_filter = false
+    )
+
+    , args_company_job("other_financing", Seq("company_id", "financing_amount", "declare_date")
+      , rowkey_udf = "md5(cleanup(concat_ws('', company_id, financing_amount, split_date(cast(declare_date as String)))))"
+      , is_super_filter = false
+    )
   )
 
   def get_args_company_job(tn: String): args_company_job = {

src/main/scala/com/winhc/bigdata/spark/ng/utils/CompanySummaryNg_new.scala

@@ -352,6 +352,19 @@ object CompanySummaryNg_new {
     , get_default_summary_args("company_wechat", "company_id")
     , get_default_summary_args("company_annual_report", "company_id")
 
+
+
+    , get_default_summary_args("accounts_receivablae", "company_id")
+    , get_default_summary_args("dcm_registration_limit", "company_id")
+    , get_default_summary_args("bond_financing", "company_id")
+    , get_default_summary_args("overseas_bond_financing", "company_id")
+    , get_default_summary_args("bank_loan", "company_id")
+    , get_default_summary_args("credit_line", "company_id")
+    , get_default_summary_args("lease_financing", "company_id")
+    , get_default_summary_args("trust_financing", "company_id")
+    , get_default_summary_args("other_financing", "company_id")
+
+
     , SummaryArgs(table_name = "auction_tracking_explode"
       , companyIdField = "company_info_id_explode"
       , distinctField = "rowkey,company_info_id_explode"
@@ -489,6 +502,9 @@ object CompanySummaryNg_new {
         , ("1", s"company_bid_del_1_supplier")
       ))
     )
+
+
+
   )
 
 

src/main/scala/com/winhc/bigdata/spark/ng/utils/export_company_index_2_es.scala

@@ -318,13 +318,26 @@ object export_company_index_2_es {
       , "rowkey,title,publish_time,purchaser_info,supplier_info,province,type,items,create_time,update_time,deleted".split(","))
     , export_2_es_args("company_annual_report"
       , "rowkey,company_id,report_year,create_time,update_time,deleted".split(","))
-    //    , export_2_es_args("wenshu_detail_v2"
-//      , ("rowkey,case_id,doc_id,case_type,case_no,doc_type,case_reason_level1,case_reason_level2,case_reason_level3,case_reason_level4,case_reason,case_reason_levelnum," +
-//        "case_stage,new_case_stage,case_amt,judge_amt,accept_amt,province_court_name,city_court_name,court_name,court_province_code,court_city_code,court_level,party_info," +
-//        "people_info,yg_info,yg_type,plaintiff_info,yg_wtdlr,yg_faren,yg_lawyer,bg_info,bg_type,defendant_info,bg_wtdlr,bg_faren,bg_lawyer,third_party,danbao,fact,court_view," +
-//        "judge,judge_name,clerk,clerk_name,judge_date_cn,judge_date,judge_year,judge_result,is_success,url,title,addenda,keywords,public_date,update_date,sample_type,judge_main," +
-//        "all_connect_case_no,connect_case_no,litigant_info,party_title,first_case_yg,first_case_bg,all_lawyer,trial_verify,debate_focus,judge_result_point,associate_party,argue_info," +
-//        "lawsuit_point,plead_point,quote_legislation,deleted").split(","))
+//    融资
+    , export_2_es_args("accounts_receivablae"
+      , "rowkey,company_id,company_name,notice_date,pledgee_info,assignee_info,finance_orig,finance_type,deadline,start_date,end_date,pledge_asset,source,create_time,update_time,deleted".split(","))
+    , export_2_es_args("dcm_registration_limit"
+      , "rowkey,company_id,company_name,bond_lassify,init_regist,sumissue_scale,sumocc_limit,start_date,fileno,underwriter_info,source,create_time,update_time,deleted".split(","))
+    , export_2_es_args("bond_financing"
+      , "rowkey,company_id,company_name,abbreviation,symbol,typedesc_1,issued_value,coupon,maturity_date,begin_date,source,create_time,update_time,deleted".split(","))
+    , export_2_es_args("overseas_bond_financing"
+      , "rowkey,company_id,company_name,bond_simple_name,teminal_amount,issue_volume,coupons_will,residual_maturity,face_value,currency,source,create_time,update_time,deleted".split(","))
+    , export_2_es_args("bank_loan"
+      , "rowkey,company_id,company_name,declare_date,creditor,amount_financed,annual_interest_rate,expire_date,start_date,end_date,file_url,source,create_time,update_time,deleted".split(","))
+    , export_2_es_args("credit_line"
+      , "rowkey,company_id,company_name,end_date,discloure_date,credit_line,credit_line_used,credit_line_unused,credit_entity_count,source,create_time,update_time,deleted".split(","))
+    , export_2_es_args("lease_financing"
+      , "rowkey,company_id,company_name,notice_date,leaser_info,guaranteelabel,finance,equity,rate,deadline,start_date,end_date,leasing_method,source,create_time,update_time,deleted".split(","))
+    , export_2_es_args("trust_financing"
+      , "rowkey,company_id,company_name,notice_date,consignee_name_list,guarantor_name_list,finance_orig,annual_rate,deadline,start_date,end_date,file_url,source,create_time,update_time,deleted".split(","))
+    , export_2_es_args("other_financing"
+      , "rowkey,company_id,company_name,declare_date,financing_type,financing_amount,interest_rate,client_info,begin_date,end_date,file_url,source,create_time,update_time,deleted".split(","))
+
   )