Разработка уведомления о снижении цены для интернет-магазина

Разработка уведомления о снижении цены для интернет-магазина

Уведомление о снижении цены — инструмент возврата «неопределившихся» покупателей. Пользователь добавил товар в избранное или список желаний, но не купил — возможно, цена казалась высокой. Когда цена снижается, автоматическое письмо возвращает его в воронку. Разработка занимает 1–2 рабочих дня, при условии что wishlist уже реализован.

Схема данных

Подписки на снижение цены могут быть частью wishlist-системы или отдельной сущностью:

CREATE TABLE price_drop_subscriptions (
    id BIGSERIAL PRIMARY KEY,
    product_id BIGINT NOT NULL REFERENCES products(id) ON DELETE CASCADE,
    variant_id BIGINT REFERENCES product_variants(id) ON DELETE CASCADE,
    user_id BIGINT REFERENCES users(id) ON DELETE CASCADE,
    email VARCHAR(255) NOT NULL,
    price_at_subscription NUMERIC(12,2) NOT NULL,
    target_price NUMERIC(12,2),    -- желаемая цена (опционально)
    notified_at TIMESTAMP,
    notified_price NUMERIC(12,2),
    created_at TIMESTAMP DEFAULT NOW()
);

CREATE UNIQUE INDEX idx_pds_user_product
    ON price_drop_subscriptions(user_id, product_id, COALESCE(variant_id, 0));

price_at_subscription — цена в момент подписки. Уведомляем при снижении относительно неё, а не относительно последней известной цены.

Кнопка подписки на карточке товара

Показывается рядом с кнопкой «В корзину». Для авторизованных — один клик:

const PriceDropButton = ({ product, variant }: PriceDropProps) => {
  const { user } = useAuth();
  const [subscribed, setSubscribed] = useState(product.is_price_drop_subscribed ?? false);

  const toggle = async () => {
    if (!user) {
      // Редирект на логин с return_url
      router.push(`/login?redirect=${encodeURIComponent(window.location.pathname)}`);
      return;
    }

    if (subscribed) {
      await api.delete(`/price-drop-subscriptions/${product.id}`);
      setSubscribed(false);
      toast.success('Подписка отменена');
    } else {
      await api.post('/price-drop-subscriptions', {
        product_id: product.id,
        variant_id: variant?.id ?? null,
      });
      setSubscribed(true);
      toast.success('Уведомим при снижении цены');
    }
  };

  return (
    <button
      onClick={toggle}
      className={cn('flex items-center gap-1.5 text-sm', {
        'text-blue-600': subscribed,
        'text-gray-500 hover:text-gray-700': !subscribed,
      })}
    >
      <BellIcon className={cn('w-4 h-4', { 'fill-blue-600': subscribed })} />
      {subscribed ? 'Слежу за ценой' : 'Следить за ценой'}
    </button>
  );
};

API подписки

public function subscribe(Request $request): JsonResponse
{
    $request->validate([
        'product_id' => 'required|exists:products,id',
        'variant_id' => 'nullable|exists:product_variants,id',
        'target_price' => 'nullable|numeric|min:0',
    ]);

    $product = Product::find($request->product_id);
    $currentPrice = $product->sale_price ?? $product->price;

    PriceDropSubscription::updateOrCreate(
        [
            'user_id'    => $request->user()->id,
            'product_id' => $request->product_id,
            'variant_id' => $request->variant_id,
        ],
        [
            'email'                  => $request->user()->email,
            'price_at_subscription'  => $currentPrice,
            'target_price'           => $request->target_price,
            'notified_at'            => null,
            'notified_price'         => null,
        ]
    );

    return response()->json(['subscribed' => true, 'price_snapshot' => $currentPrice]);
}

Триггер при изменении цены

Проверка срабатывает при обновлении цены товара — в observer или после импорта из ERP:

class ProductObserver
{
    public function updated(Product $product): void
    {
        $priceChanged = $product->isDirty('price') || $product->isDirty('sale_price');
        if (!$priceChanged) return;

        $newPrice = $product->sale_price ?? $product->price;
        $oldPrice = $product->getOriginal('sale_price') ?? $product->getOriginal('price');

        if ($newPrice < $oldPrice) {
            CheckPriceDropSubscriptions::dispatch($product, $newPrice)->onQueue('notifications');
        }
    }
}

Job отправки уведомлений

class CheckPriceDropSubscriptions implements ShouldQueue
{
    public function __construct(
        private Product $product,
        private float $newPrice,
    ) {}

    public function handle(): void
    {
        $threshold = 0.05; // уведомляем при снижении от 5%

        PriceDropSubscription::where('product_id', $this->product->id)
            ->whereNull('notified_at')
            ->chunkById(100, function ($subscriptions) use ($threshold) {
                foreach ($subscriptions as $sub) {
                    $dropPercent = ($sub->price_at_subscription - $this->newPrice) / $sub->price_at_subscription;

                    if ($dropPercent < $threshold) continue;
                    if ($sub->target_price && $this->newPrice > $sub->target_price) continue;

                    Mail::to($sub->email)->queue(new PriceDropNotification($sub, $this->product, $this->newPrice));

                    $sub->update([
                        'notified_at'    => now(),
                        'notified_price' => $this->newPrice,
                    ]);
                }
            });
    }
}

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

Email с уведомлением о снижении цены

Письмо содержит:

• Фото товара, название
• Старая цена (зачёркнута) → новая цена
• Процент снижения: «Цена снизилась на 23%»
• Кнопка «Купить сейчас» с UTM-меткой utm_source=price_drop
• Срок акции (если снижение временное)
• Ссылка «Отписаться от уведомлений о цене»

Повторные уведомления

После notified_at подписка считается «использованной». Если цена продолжает падать — снова уведомлять или нет, определяется настройкой. Рекомендуется: повторное уведомление при снижении ещё на 10%+ относительно notified_price.

Список «слежу за ценой» в личном кабинете

В разделе /account/price-tracking пользователь видит все свои подписки: товар, цена при подписке, текущая цена, изменение. Это также мотивирует добавлять больше товаров — пользователь видит ценность сервиса.

const PriceTrackingList = ({ subscriptions }: { subscriptions: PriceDropSubscription[] }) => (
  <table className="w-full text-sm">
    <thead>
      <tr className="border-b">
        <th className="text-left py-2">Товар</th>
        <th>Цена при подписке</th>
        <th>Текущая цена</th>
        <th>Изменение</th>
        <th></th>
      </tr>
    </thead>
    <tbody>
      {subscriptions.map(sub => {
        const change = ((sub.current_price - sub.price_at_subscription) / sub.price_at_subscription) * 100;
        return (
          <tr key={sub.id} className="border-b">
            <td className="py-3">
              <a href={`/products/${sub.product.slug}`} className="font-medium hover:underline">
                {sub.product.name}
              </a>
            </td>
            <td className="text-center">{formatPrice(sub.price_at_subscription)}</td>
            <td className="text-center font-medium">{formatPrice(sub.current_price)}</td>
            <td className={cn('text-center text-sm', change < 0 ? 'text-green-600' : 'text-gray-400')}>
              {change < 0 ? `−${Math.abs(change).toFixed(1)}%` : `+${change.toFixed(1)}%`}
            </td>
            <td>
              <button onClick={() => unsubscribe(sub.id)} className="text-gray-400 hover:text-red-500">
                Отписаться
              </button>
            </td>
          </tr>
        );
      })}
    </tbody>
  </table>
);