抱歉，下面是完整的回答：
def api_data_list(self):
api_data_list = [
{
"name": "资质申请操作记录-审核中",
"api": "supplierManageCredentialsInfo/SupplierManageCredentialsInfoService/qualificationReview",
"processStatus": 0,
"auditStatus": "null"
},
{
"name": "合作合同申请操作记录-审核中",
"api": "supplierContractCooperate/SupplierContractCooperateService/queryPageAddOrEnd",
"processStatus": "null",
"auditStatus": 1
},
{
"name": "实施团队退出申请-审核中",
"api": "OperationImplTeam/OperationImplTeamService/quitApplyPage"
},
{
"name": "承揽协议台账-审核中",
"api": "acceptprotocol/AcceptprotocolService/getPage",
"auditStatus": 1
},
{
"name": "工人新增操作记录-审核中",
"api": "operationWorkerApply/OperationWorkerApplyService/querySaveWorkerLog"
},
{
"name": "团队信息变更操作记录-审核中",
"api": "operationWorkerApply/OperationWorkerApplyService/queryUpdateWorkerLog"
},
{
"name": "工人异动记录-审核中",
"api": "operationWorkerApply/OperationWorkerApplyService/queryAbnormalMovementLog"
},
{
"name": "意外险变更记录-审核中",
"api": "operationWorkerApply/OperationWorkerApplyService/queryInsuranceChangeLog"
},
{
"name": "工人岗位层级变更记录-审核中",
"api": "operationWorkerApply/OperationWorkerApplyService/queryUpdatePostLevelLog"
},
{
"name": "委托账号申请记录-审核中",
"api": "supplierTeamDelegatedPayment/SupplierTeamDelegatedPaymentService/page"
}
]
return api_data_list
def get_qualification_audit_status_num(self):
accessToken = self.worker_login()
api_data_list = self.api_data_list()
result_list = []
with multiprocessing.Pool() as pool:
results = pool.map(process_api_data, api_data_list)
result_list.extend(results)
return result_list
def process_api_data(api_data):
url = "https://worker.runjian.com:32001/workerApi/" + api_data.get("api")
headers = {
'Access-Token': accessToken
}
pageNum = 1
pageSize = 1000
item_list = []
oanumber_list = []
while True:
payload = {
"pageNum": pageNum,
"pageSize": pageSize
}
if api_data.get("processStatus") == 0:
payload['processStatus'] = api_data.get("processStatus")
elif api_data.get("auditStatus") == 1:
payload['auditStatus'] = api_data.get("auditStatus")
timeout = 10
try:
response = requests.post(url, json=payload, headers=headers, timeout=timeout)
if response.status_code == 200:
data = response.json()
records_list = data['data']['records']
for i in records_list:
item_list.append(i)
oaNumber = i.get('serialCode') or i.get('oaNumber')
processStatus = i.get('processStatus') or i.get('status')
if processStatus == 0:
processStatus = "待审核"
elif processStatus == 2:
processStatus = "驳回"
else:
processStatus = "未识别的状态"
processdict = {"oaNumber": oaNumber, "processStatus": processStatus}
oanumber_list.append(processdict)
total_pages = data['data']['pages']
if pageNum >= total_pages:
result = {"name": api_data.get("name"), "oanumber_list": oanumber_list}
print("当前查询模块：{0}, 存在审核中流程总数为：{1}".format(api_data.get("name"), len(oanumber_list)))
print("当前查询模块：{0}, 获取成功".format(api_data.get("name")))
return result
pageNum += 1