财务数据

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

@@ -257,6 +257,37 @@ object args_company_job {
       , is_super_filter = false
       , verify_company_id = false
     )
+
+    , args_company_job("company_env_punishment", Seq("name", "punish_number")
+      , rowkey_udf = "md5(cleanup(concat_ws('', name, punish_number)))"
+      , is_super_filter = false
+    )
+
+    , args_company_job("company_liquidating_info", Seq("company_id")
+      , rowkey_udf = "md5(cleanup(concat_ws('', company_id)))"
+      , is_super_filter = false
+    )
+
+    , args_company_job("finance_info_v3", Seq("company_id", "year")
+      , rowkey_udf = "md5(cleanup(concat_ws('', company_id, year)))"
+      , is_super_filter = false
+    )
+
+    , args_company_job("private_enterprise", Seq("company_id", "year")
+      , rowkey_udf = "md5(cleanup(concat_ws('', company_id, year)))"
+      , is_super_filter = false
+    )
+
+    , args_company_job("company_ipr_pledge", Seq("reg_number", "pledgor_info", "pledgee_info", "related_company_name")
+      , rowkey_udf = "md5(cleanup(concat_ws('', reg_number, equity_info_rowkey(pledgor_info, pledgee_info), related_company_name )))"
+      , is_super_filter = false
+      , explode_args = Seq(
+        explode_args("pledgor_info", "$.pledgor_id", "pledgor_keyno_explode")
+        , explode_args("pledgee_info", "$.pledgee_id", "pledgee_keyno_explode")
+        )
+    )
+
+
   )
 
   def get_args_company_job(tn: String): args_company_job = {

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

@@ -41,6 +41,8 @@ object CompanySummaryNg_new {
     , get_default_summary_args("company_icp")
     , get_default_summary_args("company_tm")
     , get_default_summary_args("company_app_info")
+    , get_default_summary_args("finance_info_v3", "company_id")
+    , get_default_summary_args("private_enterprise", "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

@@ -252,6 +252,14 @@ object export_company_index_2_es {
       , "rowkey,company_name,company_id,stock_code,stock_abbreviation,transaction_date,pledged_ratio,pledged_shares,pledged_value,pledged_num,unlimited_pledged_shares,restricted_pledged_shares,one_year_change,industry,create_time,update_time,deleted".split(","))
     , export_2_es_args("company_equity_pledge_holder"
       , "rowkey,company_name,company_id,holder_name,holder_id,sharefrozennum,sz,pledgee,pledgee_id,yjx_pcx_type,ndate,scode,sname,create_time,update_time,deleted".split(","))
+    , export_2_es_args("company_env_punishment"
+      , "rowkey,company_id,name,department,publish_time,punish_number,create_time,update_time,deleted".split(","))
+    , export_2_es_args("company_liquidating_info"
+      , "rowkey,company_id,company_name,manager,member,create_time,update_time,deleted".split(","))
+    , export_2_es_args("finance_info_v3"
+      , "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(","))
   )