diff --git a/photo_review/photo_review.py b/photo_review/photo_review.py index 7c19bb5..1346330 100644 --- a/photo_review/photo_review.py +++ b/photo_review/photo_review.py @@ -1,3 +1,4 @@ +import concurrent.futures import json import logging import math @@ -337,7 +338,7 @@ def settlement_task(pk_phhd, settlement_list): def discharge_task(pk_phhd, discharge_record): - discharge_record_ie_result = request_ie_result(DISCHARGE_IE, discharge_record) + discharge_record_ie_result = information_extraction(DISCHARGE_IE, discharge_record) discharge_data = { "pk_phhd": pk_phhd, "hospital": handle_hospital(get_best_value_in_keys(discharge_record_ie_result, HOSPITAL)), @@ -378,7 +379,7 @@ def discharge_task(pk_phhd, discharge_record): def cost_task(pk_phhd, cost_list): - cost_list_ie_result = request_ie_result(COST_IE, cost_list) + cost_list_ie_result = information_extraction(COST_IE, cost_list) cost_data = { "pk_phhd": pk_phhd, "name": handle_name(get_best_value_in_keys(cost_list_ie_result, PATIENT_NAME)), @@ -415,14 +416,14 @@ def photo_review(pk_phhd): elif phrec.cRectype == "4": cost_list.append(phrec) - # with concurrent.futures.ThreadPoolExecutor() as executor: - # executor.submit(settlement_task, pk_phhd, settlement_list) - # executor.submit(discharge_task, pk_phhd, discharge_record) - # # executor.submit(settlement_and_discharge_task, pk_phhd, settlement_list, discharge_record) - # executor.submit(cost_task, pk_phhd, cost_list) - settlement_task(pk_phhd, settlement_list) - discharge_task(pk_phhd, discharge_record) - cost_task(pk_phhd, cost_list) + with concurrent.futures.ThreadPoolExecutor() as executor: + executor.submit(settlement_task, pk_phhd, settlement_list) + executor.submit(discharge_task, pk_phhd, discharge_record) + # executor.submit(settlement_and_discharge_task, pk_phhd, settlement_list, discharge_record) + executor.submit(cost_task, pk_phhd, cost_list) + # settlement_task(pk_phhd, settlement_list) + # discharge_task(pk_phhd, discharge_record) + # cost_task(pk_phhd, cost_list) def main():