evyos-center-server
/
wag-managment-api-service-version-2
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

bank service update

This commit is contained in:
berkay 2024-11-26 11:35:00 +03:00
parent 77a57279f2
commit 193fca1248
1 changed files with 9 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
service_app_banks/isbank/isbank_sender.py
View File

@ -61,7 +61,7 @@ def sender_service():
def is_bank_retrieve_account_records(bank_data): def is_bank_retrieve_account_records(bank_data):
from databases import AccountRecords from databases import AccountRecords
from api_library.date_time_actions.date_functions import system_arrow
data_bulk = json.loads(bank_data) data_bulk = json.loads(bank_data)
print("data_bulk", data_bulk) print("data_bulk", data_bulk)
new_record_list = [] new_record_list = []
@ -69,15 +69,17 @@ def is_bank_retrieve_account_records(bank_data):
for data_dict in data_bulk[data_keys]: # data_bulk[data_keys] is a list for data_dict in data_bulk[data_keys]: # data_bulk[data_keys] is a list
data_dict["bank_balance"] = data_dict.pop("balance") data_dict["bank_balance"] = data_dict.pop("balance")
data_dict["import_file_name"] = str(data_keys) data_dict["import_file_name"] = str(data_keys)
print("data_dict before pyd", data_dict)
data_dict = BankReceive(**data_dict).model_dump() data_dict = BankReceive(**data_dict).model_dump()
print("data_dict after pyd", data_dict) bank_date = system_arrow.get(str(data_dict['bank_date']))
data_dict["bank_date_w"] = bank_date.weekday()
data_dict["bank_date_m"] = bank_date.month
data_dict["bank_date_d"] = bank_date.day
data_dict["bank_date_y"] = bank_date.year
data_dict["bank_date"] = str(bank_date)
new_account_record = AccountRecords.find_or_create(**data_dict) new_account_record = AccountRecords.find_or_create(**data_dict)
print("new_account_record.is_found", new_account_record.is_found) print("new_account_record", new_account_record)
new_record_list.append(new_account_record.get_dict()) new_record_list.append(new_account_record.get_dict())
if new_record_list: return new_record_list if new_record_list else []
return True
return False
# def send_request_to_api(data): # def send_request_to_api(data):