软件著作权修改

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

@@ -297,16 +297,24 @@ object args_company_job {
     )
 
 
-    , args_company_job("company_copyright_reg", Seq("reg_num")
-      , rowkey_udf = "md5(cleanup(concat_ws('', reg_num)))"
+
+
+    , 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("company_copyright_reg", Seq("reg_num", "author_nationality_info")
+      , rowkey_udf = "md5(cleanup(concat_ws('', reg_num, get_text_from_json(author_nationality_info, 'name'))))"
       , is_super_filter = false
       , explode_args = Seq(
         explode_args("author_nationality_info", "$.keyno", "author_nationality_info_keyno_explode")
       )
     )
 
-    , args_company_job("company_copyright_works", Seq("reg_num")
-      , rowkey_udf = "md5(cleanup(concat_ws('', reg_num)))"
+    , args_company_job("company_copyright_works", Seq("reg_num", "author_info")
+      , rowkey_udf = "md5(cleanup(concat_ws('', reg_num, get_text_from_json(author_info, 'name'))))"
       , is_super_filter = false
       , explode_args = Seq(
         explode_args("author_info", "$.keyno", "author_info_keyno_explode")