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

40. Еженедельная выплата продавцам Wildberries

Сложная

Go · 57 строк

Каждый понедельник утром отчёт считает выплату продавцу за прошлую неделю с понедельника 00:00 до воскресенья 24:00 по Москве: продажи минус возвраты, комиссия 15,5 % от продаж и логистика. Если вышел минус, он переносится долгом на следующую неделю.

Активных продавцов 80 тыс. Отчёт иногда перезапускают вручную в воскресенье вечером. Серверы и база в UTC, sold_at — timestamptz. Отметьте строки с ошибками.

В работе: Финансовый отчёт в кабинете продавца и платёжное поручение на выплату по понедельникам.

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

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

  1. package payout
  3. import (
  4. "context"
  5. "database/sql"
  6. "math"
  7. "time"
  8. )
  10. type Line struct {
  11. SellerID int64
  12. Sales float64
  13. Returns float64
  14. Commission float64
  15. Logistics float64
  16. Payout float64
  17. }
  19. const commissionRate = 0.155
  21. // WeeklyReport собирает выплату продавцам за прошлую неделю (пн 00:00 — вс 24:00 МСК).
  22. func WeeklyReport(ctx context.Context, db *sql.DB, now time.Time) ([]Line, error) {
  23. weekday := int(now.Weekday())
  24. monday := now.AddDate(0, 0, -weekday-6)
  25. start := monday.Truncate(24 * time.Hour)
  26. end := start.AddDate(0, 0, 7)
  28. sellers, err := db.QueryContext(ctx, "SELECT id FROM sellers WHERE active")
  29. if err != nil {
  30. return nil, err
  31. }
  32. defer sellers.Close()
  34. var report []Line
  35. for sellers.Next() {
  36. var l Line
  37. sellers.Scan(&l.SellerID)
  38. err := db.QueryRowContext(ctx,
  39. "SELECT coalesce(sum(price), 0) FROM sales WHERE seller_id = $1 AND sold_at BETWEEN $2 AND $3",
  40. l.SellerID, start, end).Scan(&l.Sales)
  41. if err != nil {
  42. return nil, err
  43. }
  44. db.QueryRowContext(ctx,
  45. "SELECT coalesce(sum(price), 0) FROM returns WHERE seller_id = $1 AND returned_at >= $2 AND returned_at < $3",
  46. l.SellerID, start, end).Scan(&l.Returns)
  47. db.QueryRowContext(ctx, "SELECT coalesce(sum(cost), 0) FROM logistics WHERE seller_id = $1 AND week_start = $2",
  48. l.SellerID, start).Scan(&l.Logistics)
  49. l.Commission = l.Sales * commissionRate
  50. l.Payout = math.Round(l.Sales - l.Returns - l.Commission - l.Logistics)
  51. if l.Payout < 0 {
  52. l.Payout = 0
  53. }
  54. report = append(report, l)
  55. }
  56. return report, nil
  57. }