amac/amac/amac_private_fund_registration_process_api.py

import json

import Utils
from Config import mysql_pool, conn, headers, page, size

start_time = Utils.data_time()
print("开始时间(精确到毫秒)[私募基金管理人登记办理流程]：", start_time)


# 因为这里数据一条人员信息amac_member_user中包含了对应的多个证书，所以需要先循环把证书拿出来
def savetodb(data):
    # 判断是否为空，为空则跳过直接返回
    if data is None: return

    person_record = []
    for item in data:
        # 构建人员信息记录
        this_data = {
            'id': item.get("id"),
            'apply_id': item.get("applyId"),
            'audit_id': item.get("auditId"),
            'org_name': item.get("orgName"),
            'org_status': item.get("orgStatus"),
            'org_status_name': item.get("orgStatusName"),
            'org_type': item.get("orgType"),
            'org_type_name': item.get("orgTypeName"),
            'register_address': item.get("registerAddress"),
            'office_address': item.get("officeAddress"),
            'latfirm_name': item.get("latfirmName"),
            'legaller_name': item.get("legallerName"),
            'first_submit_date': item.get("firstSubmitDate"),
            'last_submit_date': item.get("lastSubmitDate"),
            'last_update_date': item.get("lastUpdateDate"),
            'total_audit_day': item.get("totalAuditDay"),
            'total_fixed_day': item.get("totalFixedDay"),
            'last_fixed_count': item.get("lastFixedCount"),
            'audit_start_date': item.get("auditStartDate"),
            'new_total_fixed_day': item.get("newTotalFixedDay"),
            'first_return_no_list_date': item.get("firstReturnNoListDate"),
            'no_list_return_count': item.get("noListReturnCount"),
            'mark_star': item.get("markStar"),
            'suspend_date': item.get("suspendDate"),
            'regain_date': item.get("regainDate"),
            'terminate_date': item.get("terminateDate"),
            'interrupt_date': item.get("interruptDate"),
            'interrupt_duration': item.get("interruptDuration"),
            'office_province': item.get("officeProvince"),
            'office_city': item.get("officeCity"),
            'office_district': item.get("officeDistrict"),
            'office_adr_agg': item.get("officeAdrAgg"),
            'register_province': item.get("registerProvince"),
            'register_city': item.get("registerCity"),
            'register_district': item.get("registerDistrict"),
            'reg_adr_agg': item.get("regAdrAgg")
        }

        person_record.append(this_data)
    # 批量插入
    mysql_pool.insert('amac_private_fund_registration_process', person_record)


this_page = page
this_size = size
payload = json.dumps({"regiProvinceFsc": "province", "offiProvinceFsc": "province"})

# 私募基金管理人登记办理流程
http_url = "/amac-infodisc/api/pof/manager/register-flow"

Utils.get_page_result(http_url, this_page, this_size, payload, headers, conn, savetodb, __file__)

print(f"[私募基金管理人登记办理流程]结束时间(精确到毫秒)： {Utils.data_time()} - {start_time}")