feat: 失信被执限高划分移除和非移除

src/main/scala/com/winhc/bigdata/spark/utils/CompanyIncSummary.scala

@@ -31,6 +31,50 @@ case class CompanyIncSummary(s: SparkSession,
   )
 
   def calc(): Unit = {
+    tableName match {
+      case "company_dishonest_info" => {
+        CompanySummaryPro(s = spark
+          , project = "winhc_eci_dev"
+          , tableName = "company_dishonest_info"
+          , cidField = "split(rowkey,'_')[0]"
+          , where = "deleted = 0"
+          , groupByInfo = GroupByInfo(field = "status", value_alias = Seq(
+            ("0", "company_dishonest_info_0")
+            , ("1", "company_dishonest_info_1")
+          ))
+        ).calc()
+      }
+      case "company_zxr_list"=>{
+        CompanySummaryPro(s = spark
+          , project = "winhc_eci_dev"
+          , tableName = "company_zxr_list"
+          , cidField = "split(rowkey,'_')[0]"
+          , where = "deleted = 0"
+          , groupByInfo = GroupByInfo(field = "status", value_alias = Seq(
+            ("0", "company_zxr_list_0")
+            ,("1", "company_zxr_list_1")
+          ))
+        ).calc()
+      }
+      case "company_zxr_restrict"=>{
+        CompanySummaryPro(s = spark
+          , project = "winhc_eci_dev"
+          , tableName = "company_zxr_restrict"
+          , cidField = "split(rowkey,'_')[0]"
+          , where = "deleted = 0"
+          , groupByInfo = GroupByInfo(field = "status", value_alias = Seq(
+            ("0", "company_zxr_restrict_0")
+            ,("1", "company_zxr_restrict_1")
+          ))
+        ).calc()
+      }
+      case _ => {
+        my_calc()
+      }
+    }
+  }
+
+  def my_calc(): Unit = {
     cleanup()
     val ads_table = s"${project}.ads_$tableName" //存量ads表
     val inc_ads_table = s"${project}.inc_ads_$tableName"