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

21. Пакетная обработка возвратов

Сложная

Java · 45 строк

Раз в 10 минут приходит пачка принятых возвратов: позиции из разных заказов, бывает по 3–4 позиции одного заказа. Сервис возвращает деньги через платёжный шлюз в пуле на 8 потоков и считает сумму возвратов по продавцу за день.

Если пачка упала, её обрабатывают повторно целиком. Отметьте строки с ошибками.

В работе: Возвраты денег покупателям: ошибка здесь — либо деньги не вернулись, либо вернулись дважды.

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

Источник: на задачах Wildberries: возвраты товаров и денег. Условие пересказано своими словами.

Давали на собеседовании? Ответов пока мало — ваш поможет.
  1. @Service
  2. public class RefundService {
  3. private final OrderRepository orders;
  4. private final PaymentGateway gateway;
  5. private final ExecutorService pool = Executors.newFixedThreadPool(8);
  6. private final Map<Long, BigDecimal> refundedToday = new ConcurrentHashMap<>();
  8. public RefundService(OrderRepository orders, PaymentGateway gateway) {
  9. this.orders = orders;
  10. this.gateway = gateway;
  11. }
  13. public List<RefundResult> processReturns(List<ReturnItem> items) {
  14. List<Future<RefundResult>> futures = new ArrayList<>();
  15. for (ReturnItem item : items) {
  16. futures.add(pool.submit(() -> refund(item)));
  17. }
  18. List<RefundResult> results = new ArrayList<>();
  19. for (Future<RefundResult> f : futures) {
  20. try {
  21. results.add(f.get());
  22. } catch (Exception e) {
  23. results.add(RefundResult.failed());
  24. }
  25. }
  26. return results;
  27. }
  29. private RefundResult refund(ReturnItem item) {
  30. Order order = orders.findById(item.getOrderId());
  31. BigDecimal amount = order.getItemPrice(item.getSku())
  32. .multiply(BigDecimal.valueOf(item.getQuantity()));
  33. if (order.getRefunded().add(amount).compareTo(order.getTotal()) > 0) {
  34. return RefundResult.rejected("Сумма возврата больше суммы заказа");
  35. }
  36. if (amount.equals(BigDecimal.ZERO)) {
  37. return RefundResult.rejected("Нулевая сумма");
  38. }
  39. gateway.refund(order.getPaymentId(), amount);
  40. order.setRefunded(order.getRefunded().add(amount));
  41. orders.save(order);
  42. refundedToday.merge(order.getSellerId(), amount, BigDecimal::add);
  43. return RefundResult.ok(amount);
  44. }
  45. }