Войти Регистрация
Код-ревью

30. Ночное продление подписки МТС

Средняя

Kotlin · 42 строк

Каждую ночь в 00:10 по Москве джоба списывает абонентскую плату за подписку: цена тарифа минус персональная скидка (discountPercent — целое, 0–50). После четырёх неудачных списаний подряд подписка приостанавливается, до этого её пробуют списать снова на следующую ночь.

Активных подписок 6,2 млн. JVM на серверах запущена в UTC, monthlyPrice — Double. Отметьте строки с ошибками.

В работе: Подписка с кино, музыкой и кешбэком: списание в ночь даты продления и SMS абоненту.

Как проверяем Нажмите на строку с ошибкой и коротко напишите, что не так. Баг засчитан, если отмечена хотя бы одна его строка. Зачёт — найдено не меньше 60 % багов с учётом серьёзности (критичный весит 3, обычный 2, мелкий 1), а лишних отметок не больше, чем багов в коде. Пустые строки, скобки и комментарии лишними не считаем. Ответ один на подход: после него показываем разбор.
Springпланировщикчасовые поясаденьгилоги

Источник: наша задача на данных МТС: подписки и списания со счёта. Условие пересказано своими словами.

  1. @Service
  2. class SubscriptionRenewalJob(
  3. private val subscriptions: SubscriptionRepository,
  4. private val billing: BillingClient,
  5. private val sms: SmsGateway,
  6. ) {
  7. private val log = LoggerFactory.getLogger(javaClass)
  9. @Scheduled(cron = "0 10 0 * * *", zone = "Europe/Moscow")
  10. fun renewAll() {
  11. val today = LocalDate.now()
  12. val due = subscriptions.findAll()
  13. .filter { it.nextChargeDate == today && it.status == Status.ACTIVE }
  14. for (sub in due) {
  15. renew(sub)
  16. }
  17. }
  19. fun renew(sub: Subscription) {
  20. if (sub.trialEndsAt != null && sub.trialEndsAt!!.isAfter(LocalDate.now())) {
  21. sub.nextChargeDate = sub.trialEndsAt!!
  22. subscriptions.save(sub)
  23. return
  24. }
  25. val discount = sub.discountPercent / 100
  26. val price = sub.tariff.monthlyPrice * (1 - discount)
  27. try {
  28. val result = billing.charge(sub.msisdn, price)
  29. if (result.status == "OK") {
  30. sub.nextChargeDate = sub.nextChargeDate.plusDays(30)
  31. sub.failedAttempts = 0
  32. } else {
  33. sub.failedAttempts++
  34. if (sub.failedAttempts > 3) sub.status = Status.SUSPENDED
  35. }
  36. } catch (e: Exception) {
  37. log.warn("charge failed for ${sub.msisdn}, auth=${billing.token}", e)
  38. }
  39. subscriptions.save(sub)
  40. sms.send(sub.msisdn, "Подписка ${sub.tariff.name} продлена, списано $price ₽")
  41. }
  42. }