feat: winhc获取最新更新时间

- winhc更新时间查询
- 维度字段配置更新

handle/search_winhc_latest_date.py

@@ -0,0 +1,80 @@
+# -*- coding: utf-8 -*-
+# @Time : 2022/12/1 9:13
+# @Author : XuJiakai
+# @File : search_winhc_latest_date
+# @Software: PyCharm
+from sdk import get_es_sdk
+from utils import map_2_json_str
+from utils.dim_name_mapping import get_latest_date_map
+from sdk.WinhcAllClient import get_all_client
+
+all_client = get_all_client()
+hbase_client = all_client.get_hbase_client()
+
+es_sdk = get_es_sdk("new")
+
+
+def get_latest_date(index: str, company_id_f: str, company_id: str, latest_date_f: str):
+    dsl = {
+        "size": 1,
+        "_source": [latest_date_f],
+        "query": {
+            "term": {
+                company_id_f: {
+                    "value": company_id
+                }
+            }
+        }
+        , "sort": [
+            {
+                latest_date_f: {
+                    "order": "desc"
+                }
+            }
+        ]
+    }
+    res = es_sdk.query(index=index, doc_type='_doc', dsl=dsl)
+
+    if len(res) == 0:
+        return None
+    return res[0][latest_date_f]
+    pass
+
+
+latest_date_map = get_latest_date_map()
+
+
+def search_latest_date(company_id: str):
+    result_data = {}
+    for i in latest_date_map:
+        str = latest_date_map[i]
+        max_date = ''
+        for j in str.split(','):
+            tmp_str = j.split(':')
+            index = tmp_str[0]
+            company_id_f = tmp_str[1]
+            latest_date_f = tmp_str[2]
+            tmp_date = get_latest_date(index=index, company_id_f=company_id_f, company_id=company_id,
+                                       latest_date_f=latest_date_f)
+            max_date = max(max_date, tmp_date)
+            pass
+
+        result_data[i] = max_date
+        pass
+
+    tmp_res = hbase_client.get_record('ng_company', company_id)
+    if 'APPROVED_TIME' in tmp_res:
+        result_data['基本信息'] = tmp_res['APPROVED_TIME']
+    return result_data
+    pass
+
+
+if __name__ == '__main__':
+    # d = get_latest_date(index='winhc_index_rt_company_punishment_info', company_id_f='company_id',
+    #                     company_id='059f83641cc4df8b9577cb1e2d89939e', latest_date_f='decision_date')
+    # print(d)
+
+    d = search_latest_date(company_id='059f83641cc4df8b9577cb1e2d89939e')
+    print(map_2_json_str(d))
+
+    pass

utils/__init__.py

@@ -6,11 +6,12 @@
 from utils.clipboard_util import set_text
 from utils.base_utils import map_2_json_str
 from utils.base_utils import to_list
-from utils.base_utils import parse_env_and_name
+from utils.base_utils import parse_env_and_name, json_path
 
 __all__ = [
     'set_text'
     , 'map_2_json_str'
     , 'to_list'
     , 'parse_env_and_name'
+    , 'json_path'
 ]

utils/base_utils.py

@@ -4,6 +4,7 @@
 # @File : base_utils
 # @Software: PyCharm
 import json
+import jsonpath
 
 
 def to_list(string: str):
@@ -25,5 +26,31 @@ def map_2_json_str(m: map):
     pass
 
 
+def json_path(data: map, key):
+    if data is None:
+        return None
+
+    tmp_v = jsonpath.jsonpath(data, key)
+    if tmp_v:
+        return tmp_v[0]
+    else:
+        return None
+    pass
+
+
+def tuple_max(*tu: tuple):
+    result = None
+    for i in tu:
+        if result is None:
+            result = i
+            pass
+        else:
+            if i[0] is not None and i[0] >= result[0]:
+                result = i
+            pass
+        pass
+    return result
+
+
 if __name__ == '__main__':
     pass

utils/datetime_utils.py

@@ -0,0 +1,19 @@
+# -*- coding: utf-8 -*-
+# @Time : 2022/12/1 14:14
+# @Author : XuJiakai
+# @File : datetime_utils
+# @Software: PyCharm
+import time
+import datetime
+
+
+def get_ds():
+    return time.strftime("%Y%m%d")
+
+
+def get_now():
+    return datetime.datetime.now().strftime('%Y-%m-%d %H:%M:%S')
+
+
+if __name__ == '__main__':
+    pass

utils/dim_name_mapping.py

@@ -35,7 +35,9 @@ _winhc_dim_map = {
     },
     "对外投资": {
         "dim_name": "",
-        "summary_key": "", "sort_field": ""
+        "summary_key": "company_holder_del_0_invest",
+        "history_summary_key": "company_holder_del_1_invest",
+        "sort_field": ""
     },
     # "总公司": {
     #     "dim_name": "",
@@ -43,11 +45,14 @@ _winhc_dim_map = {
     # },
     "分支机构": {
         "dim_name": "",
-        "summary_key": "", "sort_field": ""
+        "summary_key": "company_branch_del_0",
+        "history_summary_key": "company_branch_del_1",
+        "sort_field": ""
     },
     "历史变更": {
         "dim_name": "company_change",
-        "summary_key": "", "sort_field": ""
+        "summary_key": "",
+        "sort_field": "change_time"
     },
     "企业年报": {
         "dim_name": "company_annual_report",
@@ -346,7 +351,6 @@ _winhc_dim_map = {
 _summary_dim_2_name = {}
 list = ['行政处罚', '企业年报', '历史变更', '主要成员', '股东信息']
 
-
 _item_2_class = {}
 for i in _map_class:
     for j in _map_class[i]:
@@ -392,123 +396,54 @@ for i in _winhc_dim_map:
             pass
     pass
 
+_latest_date_map = { \
+    }
+
+for i in _winhc_dim_map:
+
+    if _winhc_dim_map[i]['sort_field'] is None or _winhc_dim_map[i]['sort_field'] == '':
+        continue
+    sort_field = _winhc_dim_map[i]['sort_field']
+    dim_name = _winhc_dim_map[i]['dim_name']
+    # index:company_id_f:sort_f
+
+    li = []
+
+    for j in sort_field.split(','):
+        format_str = j
+        num = j.count(':')
+        if num == 0:
+            if dim_name is None or dim_name == '':
+                raise ValueError("dim_name is null !")
+            format_str = 'winhc_index_rt_{}:company_id:'.format(dim_name) + j
+            pass
+        elif num == 1:
+            if dim_name is None or dim_name == '':
+                raise ValueError("dim_name is null !")
+            format_str = 'winhc_index_rt_{}:'.format(dim_name) + j
+            pass
+        elif num == 2:
+            tmp_str = j.split(":")
+            if tmp_str[1] == '':
+                tmp_str[1] = 'company_id'
+            format_str = ':'.join(tmp_str)
+            pass
+        else:
+            raise ValueError('sort_field: ' + j + ' error, format is index:company_id_f:sort_f')
+            pass
+        li.append(format_str)
+        pass
+    _latest_date_map[i] = ','.join(li)
+
+    pass
+
 
 def get_summary_map():
     return _summary_dim_2_name
 
 
-_map = {
-    "accounts_receivablae": "应收账款融资", "auction_tracking": "司法拍卖", "auction_tracking_explode": "司法拍卖-explode",
-    "auction_tracking_v9": "司法拍卖", "bank_loan": "银行借款", "bankruptcy_judgment_document": "破产文书",
-    "bankruptcy_judgment_document_v9": "破产文书", "bankruptcy_judgment_document_v9_backup": "破产文书",
-    "bankruptcy_open_announcement": "破产公告", "bankruptcy_open_announcement_v9": "破产公告",
-    "bankruptcy_open_announcement_v9_backup": "破产公告", "bankruptcy_open_case": "破产信息",
-    "bankruptcy_open_case_explode": "破产信息-explode", "bankruptcy_open_case_v9": "破产信息",
-    "bankruptcy_open_case_v9_backup": "破产信息", "bond_financing": "债券融资", "cancellation_announcement_v9": "注销备案",
-    "case_chance_element_good_news": "案源机会要素表", "case_chance_element_good_news_v9": "案源机会要素表",
-    "case_chance_good_news": "案源机会表", "case_chance_good_news_v9": "案源机会表", "case_id_big": "", "case_id_big_v2": "",
-    "company": "公司企业基本信息数据", "company_abnormal_info": "经营异常", "company_abnormal_info_v9": "经营异常",
-    "company_account_with_bank": "银行帐户", "company_annual_report": "年报主表", "company_annual_report_change": "年报-变更",
-    "company_annual_report_change_v9": "年报-变更", "company_annual_report_equity_change": "年报-股权变更",
-    "company_annual_report_equity_change_v9": "年报-股权变更", "company_annual_report_holder": "年报-股东",
-    "company_annual_report_holder_v9": "年报-股东", "company_annual_report_out_guarantee": "年报-对外担保",
-    "company_annual_report_out_guarantee_v9": "年报-对外担保", "company_annual_report_out_investment": "年报-对外投资",
-    "company_annual_report_out_investment_v9": "年报-对外投资", "company_annual_report_social_security": "年报-社保",
-    "company_annual_report_social_security_v9": "年报-社保", "company_annual_report_v9": "年报主表",
-    "company_annual_report_webinfo": "年报-网站", "company_annual_report_webinfo_v9": "年报-网站", "company_app_info": "产品信息",
-    "company_app_info_v9": "产品信息", "company_bak_20210804": "公司企业基本信息数据", "company_bid": "招投标",
-    "company_bid_explode": "招投标-explode", "company_bid_new_v9": "招投标", "company_bond": "债券信息",
-    "company_brief_cancel_announcement": "简易注销", "company_brief_cancel_announcement_objection": "简易注销-异议信息",
-    "company_brief_cancel_announcement_objection_v9": "简易注销-异议信息", "company_brief_cancel_announcement_pre": "",
-    "company_brief_cancel_announcement_result": "简易注销", "company_brief_cancel_announcement_result_v9": "简易注销",
-    "company_brief_cancel_announcement_v9": "简易注销", "company_certificate": "网站备案", "company_change": "变更信息",
-    "company_change_bak_20210804": "变更信息", "company_change_bak_20210805": "变更信息", "company_change_v9": "变更信息",
-    "company_change_v9_back_0408": "变更信息", "company_change_v9_tmp": "变更信息", "company_check_info": "抽查检查",
-    "company_check_info_v9": "抽查检查", "company_copyright_reg": "知识产权-软件著作权",
-    "company_copyright_reg_explode": "知识产权-软件著作权-炸开表", "company_copyright_reg_v9": "知识产权-软件著作权",
-    "company_copyright_works": "知识产权-作品著作权", "company_copyright_works_explode": "知识产权-作品著作权-炸开表",
-    "company_copyright_works_v9": "知识产权-作品著作权", "company_court_announcement": "法院公告初始化表",
-    "company_court_announcement_back": "法院公告初始化表", "company_court_announcement_explode": "法院公告炸开表",
-    "company_court_announcement_v9": "法院公告初始化表", "company_court_announcement_v9_back": "法院公告初始化表",
-    "company_court_open_announcement": "存量开庭公告", "company_court_open_announcement_explode": "存量开庭公告",
-    "company_court_open_announcement_v9": "存量开庭公告", "company_court_register": "立案信息初始化表",
-    "company_court_register_explode": "立案信息炸开表", "company_court_register_v9": "立案信息初始化表",
-    "company_customs_credit": "进出口信用", "company_customs_credit_administrative_penalty": "进出口信用-处罚信息",
-    "company_customs_credit_rating": "进出口信用-信用等级", "company_dishonest_info": "*", "company_dishonest_info_v9": "*",
-    "company_double_random_check_info": "双随机抽查", "company_double_random_check_info_v9": "双随机抽查",
-    "company_double_random_check_result_info": "双随机抽查-结果公示", "company_double_random_check_result_info_v9": "双随机抽查-结果公示",
-    "company_employment": "招聘信息", "company_env_punishment": "环保处罚", "company_env_punishment_v9": "环保处罚",
-    "company_equity_info": "股权出质", "company_equity_info_explode": "股权出质", "company_equity_info_v9": "股权出质",
-    "company_equity_pledge": "股权质押", "company_equity_pledge_holder": "重要股东质押明细",
-    "company_equity_pledge_holder_v9": "重要股东质押明细", "company_equity_pledge_v9": "股权质押", "company_finance": "融资信息",
-    "company_finance_v9": "融资信息", "company_holder": "公司股东信息", "company_holder_bak_20210804": "公司股东信息",
-    "company_holder_sponsor_v9": "公司股东信息", "company_holder_v9": "公司股东信息", "company_icp": "网站备案",
-    "company_icp_v9": "网站备案", "company_illegal_info": "严重违法", "company_illegal_info_v9": "严重违法",
-    "company_ipr_pledge": "股权出质", "company_ipr_pledge_explode": "知识产权出质炸开表", "company_judicial_assistance": "*",
-    "company_judicial_assistance_v9": "*", "company_land_announcement": "购地信息", "company_land_announcement_v9": "购地信息",
-    "company_land_mortgage": "*", "company_land_mortgage_v9": "*", "company_land_publicity": "购地信息",
-    "company_land_publicity_v9": "购地信息", "company_land_transfer": "土地转让", "company_land_transfer_v9": "土地转让",
-    "company_lawsuit": "裁判文书", "company_lawsuit_explode": "裁判文书-explode", "company_license": "行政处罚",
-    "company_license_creditchina": "行政处罚", "company_license_creditchina_v9": "行政处罚", "company_license_entpub": "行政处罚",
-    "company_license_entpub_v9": "行政处罚", "company_license_v9": "行政处罚", "company_liquidating_info": "清算信息",
-    "company_liquidating_info_v9": "清算信息", "company_monitor": "财产监控输出表", "company_monitor_dev": "财产监控输出表",
-    "company_monitor_v9": "财产监控输出表", "company_mortgage_change": "动产抵押-变更", "company_mortgage_change_v9": "动产抵押-变更",
-    "company_mortgage_info": "动产抵押-主表", "company_mortgage_info_v9": "动产抵押-主表", "company_mortgage_pawn": "动产抵押-抵押物",
-    "company_mortgage_pawn_v9": "动产抵押-抵押物", "company_mortgage_people": "动产抵押-抵押人",
-    "company_mortgage_people_back": "动产抵押-抵押人", "company_mortgage_people_v9": "动产抵押-抵押人", "company_own_tax": "欠税公告",
-    "company_own_tax_v9": "欠税公告", "company_patent": "专利信息", "company_patent_explode": "专利信息-炸开表",
-    "company_patent_v9": "专利信息", "company_phone_v9": "公司电话", "company_public_announcement": "公司催告",
-    "company_public_announcement_v9": "公司催告", "company_punishment_info": "行政处罚",
-    "company_punishment_info_creditchina": "行政处罚-信用中国", "company_punishment_info_creditchina_v9": "行政处罚-信用中国",
-    "company_punishment_info_v9": "行政处罚", "company_send_announcement": "送达公告初始化表",
-    "company_send_announcement_explode": "送达公告炸开表", "company_send_announcement_v9": "送达公告初始化表",
-    "company_staff": "公司主要成员", "company_staff_bak_20210804": "公司主要成员", "company_staff_v9": "公司主要成员",
-    "company_tags_v9": "公司标签", "company_tax": "税务评级", "company_tax_contravention": "*",
-    "company_tax_contravention_v9": "*", "company_tax_v9": "税务评级", "company_tele_license": "电信许可",
-    "company_tele_license_annual_report": "电信许可-年报", "company_tele_license_communication_badness": "电信许可-企业不良名单",
-    "company_tm": "商标", "company_tm_v9": "商标", "company_v9": "公司企业基本信息数据", "company_v9_back_20220531": "公司企业基本信息数据",
-    "company_wechat": "微信公众号", "company_weibo": "微博", "company_zxr": "被执行人", "company_zxr_final_case": "终本案件",
-    "company_zxr_final_case_v9": "终本案件", "company_zxr_restrict": "*", "company_zxr_restrict_bak_20210825": "*",
-    "company_zxr_restrict_bak_20210827": "*", "company_zxr_restrict_bak_20210913": "*",
-    "company_zxr_restrict_bak_20210916": "*", "company_zxr_restrict_v9": "*", "company_zxr_v9": "被执行人",
-    "construction_person": "建筑人员", "construction_person_v9": "建筑人员", "construction_project": "建筑项目",
-    "construction_project_v9": "建筑项目", "construction_qualification": "建筑资质", "construction_qualification_v9": "建筑资质",
-    "credit_line": "授信额度", "dcm_registration_limit": "DCM注册额度", "finance_info_v3": "财务数据",
-    "finance_info_v3_back1": "财务数据", "finance_info_v3_v9": "财务数据", "general_taxpayer_v9": "一般纳税人",
-    "high_tech_enterprise_v9": "高新技术企业", "increase_registered_capital_info": "",
-    "increase_registered_capital_info_v9": "增资记录", "judicial_case_id_mapping": "",
-    "judicial_case_id_mapping_r1_deleted": "主表移除", "judicial_case_id_mapping_r1_deleted_v2": "主表移除",
-    "judicial_case_id_mapping_r2_deleted": "明细表移除", "judicial_case_id_mapping_r3_deleted": "明细表移除",
-    "judicial_case_id_mapping_r3_deleted_v2": "明细表移除", "judicial_case_id_mapping_v2": "",
-    "judicial_case_id_update_kafka": "需要更新的子图ID", "judicial_case_id_update_kafka_v2": "需要更新的子图ID",
-    "judicial_case_node": "司法案件节点表", "judicial_case_node_kafka": "kafka案件node节点",
-    "judicial_case_node_kafka_v2": "kafka案件node节点", "judicial_case_node_v2": "司法案件节点表",
-    "judicial_case_relation": "kafka案件relation节点", "judicial_case_relation_case_amt": "",
-    "judicial_case_relation_id": "司法案件id组装", "judicial_case_relation_id_back": "司法案件id组装",
-    "judicial_case_relation_id_v2": "司法案件id组装", "judicial_case_relation_id_v9": "司法案件id组装",
-    "judicial_case_relation_kafka": "kafka案件relation节点", "judicial_case_relation_kafka_v2": "kafka案件relation节点",
-    "judicial_case_relation_pre": "司法案件预处理表", "judicial_case_relation_pre_v2": "司法案件预处理表",
-    "judicial_case_relation_pre_v9": "司法案件预处理表", "judicial_case_relation_r1": "司法案件主表",
-    "judicial_case_relation_r1_back": "司法案件主表", "judicial_case_relation_r1_test": "司法案件主表",
-    "judicial_case_relation_r1_tmp": "司法案件主表", "judicial_case_relation_r1_v2": "司法案件主表",
-    "judicial_case_relation_r1_v2_test": "司法案件主表", "judicial_case_relation_r1_v9": "司法案件主表",
-    "judicial_case_relation_r2": "司法案件明细表", "judicial_case_relation_r3": "司法案件明细表",
-    "judicial_case_relation_r3_back": "司法案件明细表", "judicial_case_relation_r3_test": "司法案件明细表",
-    "judicial_case_relation_r3_tmp": "司法案件明细表", "judicial_case_relation_r3_v2": "司法案件明细表",
-    "judicial_case_relation_r3_v2_test": "司法案件明细表", "judicial_case_relation_r3_v9": "司法案件明细表",
-    "judicial_case_relation_update_v2": "司法案件修复程序", "judicial_case_relation_v2": "kafka案件relation节点",
-    "lease_financing": "租赁融资", "legislation_info_v9": "法规数据", "legislation_info_v9_bak_20221129": "法规数据",
-    "legislation_info_v9_bak_20221129_2": "法规数据", "legislation_info_v9_test": "", "litigation_mediation": "诉前调解",
-    "litigation_mediation_explode": "诉前调解炸开表", "litigation_mediation_v9": "诉前调解", "online_retailers_v9": "电商数据",
-    "other_financing": "其他融资", "overseas_bond_financing": "境外债券融资", "private_enterprise": "社保人数",
-    "private_enterprise_v9": "社保人数", "property_rights_transaction": "公司股东信息",
-    "property_rights_transaction_v9": "公司股东信息", "reduction_registered_capital_info": "",
-    "reduction_registered_capital_info_v9": "减资记录", "restrictions_on_exit": "限制出镜",
-    "restrictions_on_exit_tmp20210426": "", "restrictions_on_exit_v9": "限制出镜", "trust_financing": "信托融资",
-    "wenshu_detail_v2": "新文书", "wenshu_detail_v2_explode": "裁判文书-explode", "wenshu_detail_v2_v9": "新文书",
-    "wenshu_detail_v2_v9_back_0824": "新文书", "zxr_evaluate": "选定评估机构", "zxr_evaluate_results": "询价评估结果",
-    "zxr_evaluate_results_v9": "询价评估结果", "zxr_evaluate_v9": "选定评估机构",
-}
+def get_latest_date_map():
+    return _latest_date_map
 
 
 def key_2_name(key: str):
@@ -521,113 +456,8 @@ def key_2_name(key: str):
     pass
 
 
-res = """
-ng_rt_summary_company_staff_20220217
-ng_rt_summary_company_annual_report_20220425
-ng_rt_summary_company_holder_20220221
-ng_rt_summary_company_change_20220407
-ng_rt_summary_company_license_creditchina_20220621
-ng_rt_summary_company_abnormal_info_20220124
-ng_rt_summary_finance_info_v3_20220426
-ng_rt_summary_company_license_20220224
-ng_rt_summary_private_enterprise_20220426
-ng_rt_summary_company_double_random_check_info_20220227
-ng_rt_summary_company_check_info_20220224
-ng_rt_summary_company_tm_20211223
-ng_rt_summary_company_brief_cancel_announcement_20220224
-ng_rt_summary_company_court_register_20220105
-ng_rt_summary_company_court_open_announcement_20220105
-ng_rt_summary_wenshu_detail_v2_20220614
-ng_rt_summary_general_taxpayer_20220518
-ng_rt_summary_company_tm_20220914
-ng_rt_summary_increase_registered_capital_info_20220519
-ng_rt_summary_company_punishment_info_20220523
-ng_rt_summary_company_zxr_20211223
-ng_rt_summary_company_punishment_info_creditchina_20220621
-ng_rt_summary_company_tax_20220818
-ng_rt_summary_company_liquidating_info_20220223
-ng_rt_summary_company_icp_20211223
-ng_rt_summary_online_retailers_20220329
-ng_rt_summary_company_illegal_info_20220125
-ng_rt_summary_company_patent_20220920
-ng_rt_summary_company_branch_20221019
-ng_rt_summary_company_zxr_restrict_20211223
-ng_rt_summary_company_license_entpub_20220621
-ng_rt_summary_company_zxr_final_case_20211223
-ng_rt_summary_cancellation_announcement_20220310
-ng_rt_summary_company_dishonest_info_20211223
-ng_rt_summary_company_court_announcement_20220105
-ng_rt_summary_reduction_registered_capital_info_20220519
-ng_rt_summary_company_copyright_reg_20220915
-ng_rt_summary_company_own_tax_20220621
-ng_rt_summary_company_send_announcement_20220105
-ng_rt_summary_company_judicial_assistance_20220221
-ng_rt_summary_company_equity_info_20220127
-ng_rt_summary_company_bid_new_20220512
-ng_rt_summary_construction_person_20220508
-ng_rt_summary_company_land_announcement_20220621
-ng_rt_summary_construction_qualification_20220508
-ng_rt_summary_company_copyright_works_20220915
-ng_rt_summary_company_land_publicity_20220621
-ng_rt_summary_company_env_punishment_20220621
-ng_rt_summary_high_tech_enterprise_20220222
-ng_rt_summary_company_mortgage_info_20220605
-ng_rt_summary_construction_project_20220508
-ng_rt_summary_bankruptcy_open_case_20220905
-ng_rt_summary_litigation_mediation_20220105
-ng_rt_summary_company_app_info_20211223
-ng_rt_summary_company_holder_sponsor_20220628
-ng_rt_summary_company_tax_contravention_20220818
-ng_rt_summary_auction_tracking_20220719
-ng_rt_summary_company_finance_20211223
-ng_rt_summary_company_land_mortgage_20220621
-ng_rt_summary_property_rights_transaction_20220105
-ng_rt_summary_company_public_announcement_20220621
-ng_rt_summary_zxr_evaluate_20211223
-ng_rt_summary_company_land_transfer_20220621
-ng_rt_summary_zxr_evaluate_results_20211223
-ng_rt_summary_company_patent_20220912
-ng_rt_summary_restrictions_on_exit_20220118
-ng_rt_summary_company_equity_pledge_holder_20220913
-ng_rt_summary_company_equity_pledge_20220913
-
-
-"""
-
-if __name__ == '1__main__':
-
-    from utils.base_utils import to_list
-    import re
-
-    part = re.compile("^ng_rt_summary_(.*?)_[0-9]+$")
-
-    li = to_list(res)
-    for i in li:
-        rr = part.findall(i)
-        name = rr[0]
-        tag_set = set()
-        tag_set_j = set()
-        for j in _map:
-            if name in j:
-                tag_set.add(_map[j])
-                tag_set_j.add(j)
-                pass
-            pass
-        print(name, tag_set, tag_set_j)
-        print()
-        pass
-    # out_map = ""
-    # for i in _map_class:
-    #     tm = _map_class[i]
-    #     for j in tm:
-    #         out_map += '"' + j + '": {\n        "dim_name": "",\n        "summary_key": "","sort_field": ""\n    },\n'
-    #         pass
-    # print(out_map)
-
-    pass
-
 if __name__ == '__main__':
     from utils import map_2_json_str
 
-    print(map_2_json_str(_summary_dim_2_name))
+    print(map_2_json_str(_latest_date_map))
     pass