is_bank_retrieve_account_records updated

This commit is contained in:
berkay 2024-12-20 12:58:54 +03:00
parent b61f00d61c
commit de9af544bb
1 changed files with 1 additions and 4 deletions

View File

@ -52,7 +52,6 @@ def sender_service():
if not parsed_data: if not parsed_data:
print("Parsed data can not found") print("Parsed data can not found")
return return
if is_bank_retrieve_account_records(bank_data=json.dumps(parsed_data)): if is_bank_retrieve_account_records(bank_data=json.dumps(parsed_data)):
print("is_bank_retrieve_account_records is successful") print("is_bank_retrieve_account_records is successful")
today_date = str(arrow.now("GMT+0")) today_date = str(arrow.now("GMT+0"))
@ -63,7 +62,6 @@ def sender_service():
write_json_file(Config.PARSED_PATH, {}) write_json_file(Config.PARSED_PATH, {})
else: else:
print("is_bank_retrieve_account_records is failed") print("is_bank_retrieve_account_records is failed")
return
def is_bank_retrieve_account_records(bank_data): def is_bank_retrieve_account_records(bank_data):
@ -81,7 +79,7 @@ def is_bank_retrieve_account_records(bank_data):
data_dict["bank_date_y"] = bank_date.year data_dict["bank_date_y"] = bank_date.year
data_dict["bank_date"] = str(bank_date) data_dict["bank_date"] = str(bank_date)
if build_iban := BuildIbans.filter_by_one(iban=data_dict["iban"], system=True).data: if build_iban := BuildIbans.filter_by_one(iban=data_dict["iban"], system=True).data:
data_dict = {"build_id": build_iban.build_id, "build_uu_id": build_iban.build_uu_id} data_dict.update({"build_id": build_iban.build_id, "build_uu_id": build_iban.build_uu_id})
if found_record := AccountRecords.filter_one( if found_record := AccountRecords.filter_one(
AccountRecords.bank_date == data_dict["bank_date"], AccountRecords.bank_date == data_dict["bank_date"],
AccountRecords.iban == data_dict["iban"], AccountRecords.iban == data_dict["iban"],
@ -94,7 +92,6 @@ def is_bank_retrieve_account_records(bank_data):
new_account_record = AccountRecords.find_or_create(**data_dict) new_account_record = AccountRecords.find_or_create(**data_dict)
new_account_record.save_and_confirm() new_account_record.save_and_confirm()
new_record_list.append(new_account_record.get_dict()) new_record_list.append(new_account_record.get_dict())
print("new_account_record is created", new_account_record.uu_id)
return new_record_list if new_record_list else [] return new_record_list if new_record_list else []