Middle+

Implementujte metodu grpc-server AddItemAndOrder: 1. Přidejte položky do košíku 2. Je povinné informovat potenciální spotřebitele o vytvoření košíku prostřednictvím message brokeru. 3. Při změně složení košíku je třeba přepočítat basket.Total=sum(počet*cena) 4. Všechny prvky košíku musí být unikátní podle klíče ProductID 5. Pro dokončení košíku je nutné změnit jeho stav na ordered 6. Úpravy již objednaných košíků nejsou povoleny

sobes.tech AI

Odpověď od AI

Ниже пример реализации метода AddItemAndOrder для gRPC-сервера на Go с учетом требований:

Корзина (Basket) содержит уникальные товары по ProductID.
При добавлении товаров пересчитывается сумма Total.
При оформлении корзины меняется статус на ordered.
После оформления изменения запрещены.
После оформления отправляется сообщение через брокер (например, через интерфейс MessageBroker).

package service

import (
    "context"
    "errors"
    "sync"
)

// Пример структур

type BasketStatus string

const (
    StatusOpen    BasketStatus = "open"
    StatusOrdered BasketStatus = "ordered"
)

type BasketItem struct {
    ProductID string
    Count     int
    Price     float64
}

type Basket struct {
    ID     string
    Items  map[string]*BasketItem // ключ - ProductID
    Total  float64
    Status BasketStatus
    mu     sync.Mutex
}

// Интерфейс брокера сообщений

type MessageBroker interface {
    Publish(topic string, message interface{}) error
}

// Сервис с корзинами и брокером

type BasketService struct {
    baskets map[string]*Basket
    broker  MessageBroker
}

func NewBasketService(broker MessageBroker) *BasketService {
    return &BasketService{
        baskets: make(map[string]*Basket),
        broker:  broker,
    }
}

// AddItemAndOrderRequest и Response - protobuf-сгенерированные структуры

func (s *BasketService) AddItemAndOrder(ctx context.Context, req *AddItemAndOrderRequest) (*AddItemAndOrderResponse, error) {
    basket, ok := s.baskets[req.BasketId]
    if !ok {
        return nil, errors.New("basket not found")
    }

    basket.mu.Lock()
    defer basket.mu.Unlock()

    if basket.Status == StatusOrdered {
        return nil, errors.New("cannot modify ordered basket")
    }

    // Добавляем или обновляем товары
    for _, item := range req.Items {
        if existing, exists := basket.Items[item.ProductId]; exists {
            existing.Count += int(item.Count)
            existing.Price = item.Price // обновляем цену, если нужно
        } else {
            basket.Items[item.ProductId] = &BasketItem{
                ProductID: item.ProductId,
                Count:     int(item.Count),
                Price:     item.Price,
            }
        }
    }

    // Пересчет суммы
    var total float64
    for _, item := range basket.Items {
        total += float64(item.Count) * item.Price
    }
    basket.Total = total

    // Если в запросе есть флаг оформления корзины
    if req.Order { // предположим, что есть булево поле Order
        basket.Status = StatusOrdered

        // Отправляем сообщение в брокер
        err := s.broker.Publish("basket_ordered", map[string]interface{}{
            "basket_id": basket.ID,
            "total":     basket.Total,
            "items":     basket.Items,
        })
        if err != nil {
            return nil, err
        }
    }

    return &AddItemAndOrderResponse{
        Total:  basket.Total,
        Status: string(basket.Status),
    }, nil
}

В этом примере:

Используется мьютекс для защиты данных корзины от гонок.
Товары хранятся в мапе для уникальности по ProductID.
При оформлении меняется статус и отправляется событие через брокер.
После оформления любые изменения запрещены.

Для реального приложения нужно добавить валидацию, обработку ошибок и интеграцию с реальным брокером сообщений.

Předchozí Další