瀏覽代碼

add:摘要数据终本案件加入历史和非历史

许家凯 4 年之前
父節點
當前提交
bed063ae85
共有 1 個文件被更改,包括 17 次插入0 次删除
  1. 17 0
      src/main/scala/com/winhc/bigdata/spark/utils/CompanySummaryPro.scala

+ 17 - 0
src/main/scala/com/winhc/bigdata/spark/utils/CompanySummaryPro.scala

@@ -241,7 +241,21 @@ object CompanySummaryPro {
     var csp: CompanySummaryPro = null
 
     tab match {
+      case "company_zxr_final_case" => {
+        //终本案件
+        csp = CompanySummaryPro(s = spark
+          , project = "winhc_eci_dev"
+          , tableName = "company_zxr_final_case"
+          , cidField = "split(rowkey,'_')[0]"
+          , where = "deleted = 0"
+          , groupByInfo = GroupByInfo(field = "status", value_alias = Seq(
+            ("0", "company_zxr_final_case_0")
+            , ("1", "company_zxr_final_case_1")
+          ))
+        )
+      }
       case "company_dishonest_info" => {
+        //失信人
         csp = CompanySummaryPro(s = spark
           , project = "winhc_eci_dev"
           , tableName = "company_dishonest_info"
@@ -254,6 +268,7 @@ object CompanySummaryPro {
         )
       }
       case "company_zxr_list" => {
+        //执行人
         csp = CompanySummaryPro(s = spark
           , project = "winhc_eci_dev"
           , tableName = "company_zxr_list"
@@ -266,6 +281,7 @@ object CompanySummaryPro {
         )
       }
       case "company_zxr_restrict" => {
+        //限制高消费
         csp = CompanySummaryPro(s = spark
           , project = "winhc_eci_dev"
           , tableName = "company_zxr_restrict"
@@ -315,6 +331,7 @@ object CompanySummaryPro {
           , project = "winhc_eci_dev"
           , tableName = tab
           , cidField = "split(rowkey,'_')[0]"
+          ,where = "instr(rowkey,'_') != 0"
         )
     }