融资信息

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

@@ -287,7 +287,10 @@ object args_company_job {
         )
     )
 
-
+    , args_company_job("company_finance", Seq("company_id", "round")
+      , rowkey_udf = "md5(cleanup(concat_ws('', company_id, round)))"
+      , 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

@@ -43,6 +43,7 @@ object CompanySummaryNg_new {
     , get_default_summary_args("company_app_info")
     , get_default_summary_args("finance_info_v3", "company_id")
     , get_default_summary_args("private_enterprise", "company_id")
+    , get_default_summary_args("company_finance", "company_id")
 
     , SummaryArgs(table_name = "company_court_open_announcement_explode"
       , companyIdField = "plaintiff_info_id_explode"

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

@@ -260,6 +260,8 @@ object export_company_index_2_es {
       , "rowkey,company_id,company_name,year,assgro,assgro_dis,liagro,liagro_dis,vendinc,vendinc_dis,maibusinc,maibusinc_dis,progro,progro_dis,netinc,netinc_dis,ratgro,ratgro_dis,totequ,totequ_dis,create_time,update_time,deleted".split(","))
     , export_2_es_args("private_enterprise"
       , "rowkey,company_id,company_name,year,so110,so210,so310,so410,so510,empnum,empnum_dis,create_time,update_time,deleted".split(","))
+    , export_2_es_args("company_finance"
+      , "rowkey,company_id,company_name,report_date,finance_time,invest_id,money,news_title,news_url,round,percent,inverstors,inverstor_json,valuation,create_time,update_time,deleted".split(","))
   )