feat: 开庭公告当事人加入移除空名称

data_clean/handle/company_court_open_announcement.py

@@ -13,7 +13,7 @@ from data_clean.exception.ruler_validation_exception import RulerValidationExcep
 from data_clean.utils.base_utils import *
 from data_clean.utils.case_utils import case_no_year_datetime
 from data_clean.utils.date_utils import str_2_date_time, get_update_time, establish_state_time
-from data_clean.utils.party_name_verify_utils import person_name_list_verify
+from data_clean.utils.party_name_verify_utils import person_name_list_verify, remove_null_party
 from data_clean.utils.str_utils import json_str_2_list
 from data_clean.utils.case_utils import get_case_party
 
@@ -129,6 +129,9 @@ async def open_ann_date(row_data: dict) -> dict:
 @dim_handle.registry_row_func
 async def party_unknown(row_data: dict) -> dict:
     # 过滤当事人名字异常，Z某某、xxx
+    row_data['plaintiff_info'] = remove_null_party(row_data['plaintiff_info'])
+    row_data['defendant_info'] = remove_null_party(row_data['defendant_info'])
+
     plaintiff_info = json_str_2_list(row_data['plaintiff_info'], "name")
     defendant_info = json_str_2_list(row_data['defendant_info'], "name")
     li = plaintiff_info + defendant_info
@@ -136,9 +139,9 @@ async def party_unknown(row_data: dict) -> dict:
     if not flag:
         result = await get_case_party(row_data['case_no'], source='open_court')
         if result:
-            row_data['plaintiff_info'] = result['plaintiff_info']
-            row_data['defendant_info'] = result['defendant_info']
-            row_data['litigant_info'] = result['litigant_info']
+            row_data['plaintiff_info'] = remove_null_party(result['plaintiff_info'])
+            row_data['defendant_info'] = remove_null_party(result['defendant_info'])
+            row_data['litigant_info'] = remove_null_party(result['litigant_info'])
             row_data['plaintiff'] = result['plaintiff']
             row_data['defendant'] = result['defendant']
             row_data['litigant'] = result['litigant']

data_clean/utils/party_name_verify_utils.py

@@ -27,6 +27,15 @@ def person_name_verify(name: str):
     return __anonymity_name.match(name) is None
 
 
+def remove_null_party(party: list, key: str = "litigant_id"):
+    if party:
+        party = [i for i in party if key in i and i[key]]
+        pass
+    return party
+    pass
+
+
 if __name__ == '__main__':
-    print(person_name_verify("Z某某"))
+    # print(person_name_verify("Z某某"))
+    print(remove_null_party([{"name": "", "litigant_id": ""}], "litigant_id"))
     pass