司法案件剔除状态判断

src/main/scala/com/winhc/bigdata/spark/jobs/judicial/JudicialCaseRelationPreNew.scala

@@ -469,7 +469,7 @@ case class JudicialCaseRelationPreNew(s: SparkSession, project: String, ds: Stri
              |                                cname
              |                                ,concat_ws(',',collect_set(new_cid)) AS new_cid
              |                        FROM    $project.$t5
-             |                        WHERE   ds = '$t5_ds' AND length(cleanup(cname)) >4 AND company_type not in ('2','8') AND deleted = '0'
+             |                        WHERE   ds = '$t5_ds' AND length(cleanup(cname)) >4 AND company_type not in ('2','8')
              |                        GROUP BY cname
              |                     ) f
              |                ON      cleanup(e.name) = cleanup(f.cname)