@periodic_task(ignore_result=True, run_every=(crontab(minute='*/1')))
def _async_check_order_status():
    transaction_status = {"PAID": '1', "REJECTED": '2', "EXPIRED": '3', "CANCELLED": '4', "CANCELLED FOR REPEAT": '5'}
    checks = CustomerTransaction.objects.all().filter(source=1, processed=0)
    if len(checks) > 0:
        m = MerchantData.objects.filter(source=1).get()
        api = MerchantApi(m.merchant_password, m.merchant_login, m.merchant_endpoint)
        for check in checks:
            data = api.check_order_state(check.ext_id, check.id)
            response = json.loads(data)
            if response['status'] == 'NEW':
                pass
            else:
                status = response['status']
                logger.info(response)
                check.processed = transaction_status[status]
                check.save()

@receiver(post_save, sender=CustomerTransaction)
def replenish_account(sender, instance, **kwargs):
    if instance.processed == '1':
        owner = instance.customer
        owner.balance += instance.amount
        owner.threshold_notice = False
        owner.critical_notice = False
        if owner.email_verified and owner.billing_notification:
            owner.send_payment_success_email(instance)
        owner.save()