From b61f00d61c616cf1d826b28ad919ab2aa786414d Mon Sep 17 00:00:00 2001 From: berkay Date: Fri, 20 Dec 2024 12:48:04 +0300 Subject: [PATCH] yaml updated --- service_app_banks/isbank/isbank_sender.py | 16 +++++++--------- service_app_banks/isbank/main_single_thread.py | 4 ++-- 2 files changed, 9 insertions(+), 11 deletions(-) diff --git a/service_app_banks/isbank/isbank_sender.py b/service_app_banks/isbank/isbank_sender.py index 8979d98..c46cf4f 100644 --- a/service_app_banks/isbank/isbank_sender.py +++ b/service_app_banks/isbank/isbank_sender.py @@ -55,16 +55,14 @@ def sender_service(): if is_bank_retrieve_account_records(bank_data=json.dumps(parsed_data)): print("is_bank_retrieve_account_records is successful") + today_date = str(arrow.now("GMT+0")) + archive_path = str(Config.ARCHIVE_PATH + today_date + ".json").replace(" ", "") + already_archived = read_json_file(archive_path) + already_archived[today_date] = parsed_data + write_json_file(archive_path, already_archived) + write_json_file(Config.PARSED_PATH, {}) else: print("is_bank_retrieve_account_records is failed") - return - - today_date = str(arrow.now("GMT+0")) - archive_path = str(Config.ARCHIVE_PATH + today_date + ".json").replace(" ", "") - already_archived = read_json_file(archive_path) - already_archived[today_date] = parsed_data - write_json_file(archive_path, already_archived) - write_json_file(Config.PARSED_PATH, {}) return @@ -96,7 +94,7 @@ def is_bank_retrieve_account_records(bank_data): new_account_record = AccountRecords.find_or_create(**data_dict) new_account_record.save_and_confirm() new_record_list.append(new_account_record.get_dict()) - print("new_account_record is created", new_account_record.id) + print("new_account_record is created", new_account_record.uu_id) return new_record_list if new_record_list else [] diff --git a/service_app_banks/isbank/main_single_thread.py b/service_app_banks/isbank/main_single_thread.py index 905ace4..fe85be9 100644 --- a/service_app_banks/isbank/main_single_thread.py +++ b/service_app_banks/isbank/main_single_thread.py @@ -19,13 +19,13 @@ if __name__ == "__main__": time.sleep(1) except Exception as e: err = e - print("Reader Service : ", err) + print("Parser Service : ", err) try: sender_service() time.sleep(1) except Exception as e: err = e - print("Reader Service : ", err) + print("Sender Service : ", err) print( datetime.datetime.now().__str__(), " : system completed a cycle without error...",