增加配置

src/main/java/com/winhc/task/common/SummaryArgs.java

@@ -845,6 +845,104 @@ public class SummaryArgs {
                         , "company_annual_report_del_1"))
                 , (j) -> Collections.singletonList(j.getString("company_id"))
         ));
+
+        a.put("construction_qualification", new SummaryArgs(
+                "ng_rt_construction_qualification"
+                , Collections.singletonList(new ArgsInfo(
+                "company_id"
+                , ""
+                , "deleted"))
+                , Arrays.asList(new ValueAlias(
+                        ""
+                        , "0"
+                        , "construction_qualification_del_0"),
+                new ValueAlias(
+                        ""
+                        , "1"
+                        , "construction_qualification_del_1"))
+                , (j) -> Collections.singletonList(j.getString("company_id"))
+        ));
+        a.put("construction_person", new SummaryArgs(
+                "ng_rt_construction_person"
+                , Collections.singletonList(new ArgsInfo(
+                "company_id"
+                , ""
+                , "deleted"))
+                , Arrays.asList(new ValueAlias(
+                        ""
+                        , "0"
+                        , "construction_person_del_0"),
+                new ValueAlias(
+                        ""
+                        , "1"
+                        , "construction_person_del_1"))
+                , (j) -> Collections.singletonList(j.getString("company_id"))
+        ));
+        a.put("construction_project", new SummaryArgs(
+                "ng_rt_construction_project"
+                , Collections.singletonList(new ArgsInfo(
+                "company_id"
+                , ""
+                , "deleted"))
+                , Arrays.asList(new ValueAlias(
+                        ""
+                        , "0"
+                        , "construction_project_del_0"),
+                new ValueAlias(
+                        ""
+                        , "1"
+                        , "construction_project_del_1"))
+                , (j) -> Collections.singletonList(j.getString("company_id"))
+        ));
+        a.put("reduction_registered_capital_info", new SummaryArgs(
+                "ng_rt_reduction_registered_capital_info"
+                , Collections.singletonList(new ArgsInfo(
+                "company_id"
+                , ""
+                , "deleted"))
+                , Arrays.asList(new ValueAlias(
+                        ""
+                        , "0"
+                        , "reduction_registered_capital_info_del_0"),
+                new ValueAlias(
+                        ""
+                        , "1"
+                        , "reduction_registered_capital_info_del_1"))
+                , (j) -> Collections.singletonList(j.getString("company_id"))
+        ));
+
+        a.put("increase_registered_capital_info", new SummaryArgs(
+                "ng_rt_increase_registered_capital_info"
+                , Collections.singletonList(new ArgsInfo(
+                "company_id"
+                , ""
+                , "deleted"))
+                , Arrays.asList(new ValueAlias(
+                        ""
+                        , "0"
+                        , "increase_registered_capital_info_del_0"),
+                new ValueAlias(
+                        ""
+                        , "1"
+                        , "increase_registered_capital_info_del_1"))
+                , (j) -> Collections.singletonList(j.getString("company_id"))
+        ));
+        a.put("general_taxpayer", new SummaryArgs(
+                "ng_rt_general_taxpayer"
+                , Collections.singletonList(new ArgsInfo(
+                "company_id"
+                , ""
+                , "deleted"))
+                , Arrays.asList(new ValueAlias(
+                        ""
+                        , "0"
+                        , "general_taxpayer_del_0"),
+                new ValueAlias(
+                        ""
+                        , "1"
+                        , "general_taxpayer_del_1"))
+                , (j) -> Collections.singletonList(j.getString("company_id"))
+        ));
         return a;
     }
 

src/test/java/com/winhc/task/DataWorksSummaryJob.java

@@ -27,37 +27,14 @@ public class DataWorksSummaryJob {
 
         //是否同步数据
         Boolean synData = true;
-        //Boolean synData = false;
+        //synData = false;
         //过滤集合(集合为空跑全量)
         //List<String> filter = Arrays.asList("company_holder", "company_staff", "company_change");
         List<String> filter = new ArrayList<>();
 
         //确定重跑集合(集合为空跑全量)
-        //List<String> add = Arrays.asList("company_holder");
-        //List<String> add = Arrays.asList("high_tech_enterprise");
-        //List<String> add = Arrays.asList("company_brief_cancel_announcement");
-        //List<String> add = Arrays.asList("online_retailers");
-        //List<String> add = Arrays.asList("company_change");
-        //List<String> add = Arrays.asList("finance_info_v3", "private_enterprise");
-        //List<String> add = Arrays.asList("finance_info_v3");
-        List<String> add = Arrays.asList("private_enterprise");
-        //List<String> add = Arrays.asList("company_annual_report");
-        //List<String> add = Arrays.asList("cancellation_announcement");
-        //List<String> add = Arrays.asList("bankruptcy_open_case");
-        //List<String> add = Arrays.asList("company_double_random_check_info");
-        //List<String> add = Arrays.asList("company_license", "company_check_info", "company_punishment_info");
-        //List<String> add = Arrays.asList("company_liquidating_info");
-        //List<String> add = Arrays.asList("company_judicial_assistance", "company_brief_cancel_announcement");
-        //List<String> add = Arrays.asList("company_holder", "company_staff");
-        //List<String> add = Arrays.asList("company_holder", "company_staff", "auction_tracking", "restrictions_on_exit");
-        //List<String> add = Arrays.asList("company_equity_info", "company_abnormal_info");
-        //List<String> add = Arrays.asList("company_equity_info");
-        //List<String> add = Arrays.asList("company_illegal_info");
-        //List<String> add = Arrays.asList("company_holder", "company_staff", "company_change");
-        //List<String> add = new ArrayList<>();
-        //List<String> add = Arrays.asList("bankruptcy_open_case", "company_court_open_announcement", "company_court_announcement", "company_send_announcement"
-        //        , "company_court_register", "litigation_mediation", "restrictions_on_exit", "auction_tracking", "property_rights_transaction");
 
+        List<String> add = Arrays.asList("company_punishment_info");
 
         List<String> list = SummaryArgs.SUMMARY_ARGS.keySet().stream()
                 .filter(x -> {