You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
60 lines
2.4 KiB
60 lines
2.4 KiB
import logging
|
|
import os
|
|
|
|
import requests
|
|
from django.conf import settings
|
|
from django.db import transaction
|
|
from django.utils import timezone
|
|
from yandex_money.models import Payment
|
|
|
|
from finance.loggers import FinanceLogger
|
|
from finance.models import InvoiceRebilling
|
|
from lms import celery_app
|
|
|
|
finance_logger = FinanceLogger()
|
|
|
|
@celery_app.task
|
|
def periodic_billing():
|
|
finance_logger.info("start periodic billing task")
|
|
invoices = InvoiceRebilling.objects.filter(method='Y').exclude(status='F')
|
|
for invoice in invoices.filter(expected_date__lt=timezone.now()):
|
|
# выбираем все необработанные из прошлого
|
|
with transaction.atomic():
|
|
try:
|
|
_yandex_repeat_card_payment(invoice)
|
|
except Exception as exc:
|
|
finance_logger.exception('YandexMoney repeatCardPayment Exception', invoice_id=invoice.id)
|
|
invoice.comment = 'Ошибка при попытке повторного платежа, свяжитесь с клиентской службой'
|
|
invoice.save()
|
|
|
|
|
|
def _yandex_repeat_card_payment(invoice):
|
|
user = invoice.bill.user
|
|
yandex_pay = Payment.objects.create(
|
|
order_amount=invoice.price,
|
|
customer_number=user.id,
|
|
user=user,
|
|
cps_email=user.email,
|
|
shop_id=settings.YANDEX_MONEY_REBILLING_SHOP_ID,
|
|
scid=settings.YANDEX_MONEY_REBILLING_SCID
|
|
)
|
|
invoice.yandex_pay = yandex_pay
|
|
|
|
finance_logger.info('YandexMoney repeatCardPayment start', invoice_id=invoice.id)
|
|
resp = requests.post(
|
|
url=settings.YANDEX_MONEY_MWS_URL + 'repeatCardPayment',
|
|
data={
|
|
'clientOrderId': invoice.id, # уникальное возрастающее целое число
|
|
'invoiceId': invoice.key,
|
|
'amount': invoice.price,
|
|
'orderNumber': invoice.yandex_pay.order_number
|
|
},
|
|
cert=(
|
|
os.path.join(settings.SSL_ROOT, 'skillbox.cer'),
|
|
os.path.join(settings.SSL_ROOT, 'skillbox.key')
|
|
),
|
|
verify=os.path.join(settings.SSL_ROOT, 'yamoney_chain.cer')
|
|
)
|
|
# TODO тут проверять нет ли ошибки яндекса (даже при 200 ответе)
|
|
finance_logger.info('YandexMoney repeatCardPayment ended',
|
|
invoice_id=invoice.id, response=resp.text, code=resp.status_code, )
|
|
|