26 lines
768 B
Python
26 lines
768 B
Python
import logging
|
|
from azbankgateways import (
|
|
bankfactories,
|
|
models as bank_models,
|
|
default_settings as settings,
|
|
)
|
|
|
|
|
|
from celery import shared_task
|
|
|
|
@shared_task
|
|
def udpate_bank_status():
|
|
factory = bankfactories.BankFactory()
|
|
|
|
bank_models.Bank.objects.update_expire_records()
|
|
|
|
for item in bank_models.Bank.objects.filter_return_from_bank():
|
|
bank = factory.create(
|
|
bank_type=item.bank_type, identifier=item.bank_choose_identifier
|
|
)
|
|
bank.verify(item.tracking_code)
|
|
bank_record = bank_models.Bank.objects.get(tracking_code=item.tracking_code)
|
|
if bank_record.is_success:
|
|
logging.debug("This record is verify now.", extra={"pk": bank_record.pk})
|
|
|
|
return 'update bank record is done' |