saveinmed/backend-old/internal/http/handler/product_handler.go

package handler

import (
	"errors"
	"net/http"
	"strconv"
	"time"

	"github.com/gofrs/uuid/v5"
	"github.com/saveinmed/backend-go/internal/domain"
	"github.com/saveinmed/backend-go/internal/http/middleware"
)

// CreateProduct godoc
// @Summary Cadastro de produto com rastreabilidade de lote
// @Tags Produtos
// @Accept json
// @Produce json
// @Param product body registerProductRequest true "Produto"
// @Success 201 {object} domain.Product
// @Router /api/v1/products [post]
func (h *Handler) CreateProduct(w http.ResponseWriter, r *http.Request) {
	var req registerProductRequest
	if err := decodeJSON(r.Context(), r, &req); err != nil {
		writeError(w, http.StatusBadRequest, err)
		return
	}

	product := &domain.Product{
		SellerID:     req.SellerID,
		EANCode:      req.EANCode,
		Name:         req.Name,
		Description:  req.Description,
		Manufacturer: req.Manufacturer,
		Category:     req.Category,
		Subcategory:  req.Subcategory,
		PriceCents:   req.PriceCents,
		// Map new fields
		InternalCode:            req.InternalCode,
		FactoryPriceCents:       req.FactoryPriceCents,
		PMCCents:                req.PMCCents,
		CommercialDiscountCents: req.CommercialDiscountCents,
		TaxSubstitutionCents:    req.TaxSubstitutionCents,
		InvoicePriceCents:       req.InvoicePriceCents,
	}

	if err := h.svc.RegisterProduct(r.Context(), product); err != nil {
		writeError(w, http.StatusInternalServerError, err)
		return
	}

	writeJSON(w, http.StatusCreated, product)
}

// ImportProducts ... (No change)
func (h *Handler) ImportProducts(w http.ResponseWriter, r *http.Request) {
	// ...
	// Keeping same for brevity, assuming existing file upload logic is fine
	// Or just skipping to UpdateProduct
	r.ParseMultipartForm(10 << 20)
	file, _, err := r.FormFile("file")
	if err != nil {
		writeError(w, http.StatusBadRequest, errors.New("file is required"))
		return
	}
	defer file.Close()
	claims, ok := middleware.GetClaims(r.Context())
	if !ok || claims.CompanyID == nil {
		writeError(w, http.StatusUnauthorized, errors.New("company context missing"))
		return
	}
	report, err := h.svc.ImportProducts(r.Context(), *claims.CompanyID, file)
	if err != nil {
		writeError(w, http.StatusBadRequest, err)
		return
	}
	writeJSON(w, http.StatusOK, report)
}

// ListProducts godoc
// @Summary Lista catálogo com lote e validade
// @Tags Produtos
// @Produce json
// @Success 200 {array} domain.Product
// @Router /api/v1/products [get]
func (h *Handler) ListProducts(w http.ResponseWriter, r *http.Request) {
	page, pageSize := parsePagination(r)
	filter := domain.ProductFilter{
		Search: r.URL.Query().Get("search"),
	}

	result, err := h.svc.ListProducts(r.Context(), filter, page, pageSize)
	if err != nil {
		writeError(w, http.StatusInternalServerError, err)
		return
	}
	writeJSON(w, http.StatusOK, result)
}

// SearchProducts godoc
// @Summary Busca avançada de produtos com filtros e distância
// @Description Retorna produtos ordenados por validade, com distância aproximada. Vendedor anônimo até checkout.
// @Tags Produtos
// @Produce json
// @Param search query string false "Termo de busca"
// @Param min_price query integer false "Preço mínimo em centavos"
// @Param max_price query integer false "Preço máximo em centavos"
// @Param max_distance query number false "Distância máxima em km"
// @Param lat query number true "Latitude do comprador"
// @Param lng query number true "Longitude do comprador"
// @Param page query integer false "Página"
// @Param page_size query integer false "Itens por página"
// @Success 200 {object} domain.ProductSearchPage
// @Router /api/v1/products/search [get]
func (h *Handler) SearchProducts(w http.ResponseWriter, r *http.Request) {
	page, pageSize := parsePagination(r)

	filter := domain.ProductSearchFilter{
		Search: r.URL.Query().Get("search"),
	}

	latStr := r.URL.Query().Get("lat")
	lngStr := r.URL.Query().Get("lng")
	if latStr != "" && lngStr != "" {
		lat, _ := strconv.ParseFloat(latStr, 64)
		lng, _ := strconv.ParseFloat(lngStr, 64)
		filter.BuyerLat = lat
		filter.BuyerLng = lng
	}

	if v := r.URL.Query().Get("min_price"); v != "" {
		if price, err := strconv.ParseInt(v, 10, 64); err == nil {
			filter.MinPriceCents = &price
		}
	}
	if v := r.URL.Query().Get("max_price"); v != "" {
		if price, err := strconv.ParseInt(v, 10, 64); err == nil {
			filter.MaxPriceCents = &price
		}
	}
	if v := r.URL.Query().Get("max_distance"); v != "" {
		if dist, err := strconv.ParseFloat(v, 64); err == nil {
			filter.MaxDistanceKm = &dist
		}
	}
	// ExpiresBefore ignored for Catalog Search
	// if v := r.URL.Query().Get("expires_before"); v != "" {
	// 	if days, err := strconv.Atoi(v); err == nil && days > 0 {
	// 		expires := time.Now().AddDate(0, 0, days)
	// 		filter.ExpiresBefore = &expires
	// 	}
	// }

	if claims, ok := middleware.GetClaims(r.Context()); ok && claims.CompanyID != nil {
		filter.ExcludeSellerID = claims.CompanyID
	}

	result, err := h.svc.SearchProducts(r.Context(), filter, page, pageSize)
	if err != nil {
		writeError(w, http.StatusInternalServerError, err)
		return
	}

	if h.buyerFeeRate > 0 {
		for i := range result.Products {
			originalPrice := result.Products[i].PriceCents
			inflatedPrice := int64(float64(originalPrice) * (1 + h.buyerFeeRate))
			result.Products[i].PriceCents = inflatedPrice
		}
	}

	writeJSON(w, http.StatusOK, result)
}

// GetProduct godoc
// @Summary Obter produto
// @Tags Produtos
// @Produce json
// @Param id path string true "Product ID"
// @Success 200 {object} domain.Product
// @Failure 404 {object} map[string]string
// @Router /api/v1/products/{id} [get]
func (h *Handler) GetProduct(w http.ResponseWriter, r *http.Request) {
	id, err := parseUUIDFromPath(r.URL.Path)
	if err != nil {
		writeError(w, http.StatusBadRequest, err)
		return
	}

	product, err := h.svc.GetProduct(r.Context(), id)
	if err != nil {
		writeError(w, http.StatusNotFound, err)
		return
	}

	writeJSON(w, http.StatusOK, product)
}

func (h *Handler) UpdateProduct(w http.ResponseWriter, r *http.Request) {
	id, err := parseUUIDFromPath(r.URL.Path)
	if err != nil {
		writeError(w, http.StatusBadRequest, err)
		return
	}

	var req updateProductRequest
	if err := decodeJSON(r.Context(), r, &req); err != nil {
		writeError(w, http.StatusBadRequest, err)
		return
	}

	product, err := h.svc.GetProduct(r.Context(), id)
	if err != nil {
		writeError(w, http.StatusNotFound, err)
		return
	}

	if req.SellerID != nil {
		product.SellerID = *req.SellerID
	}
	if req.EANCode != nil {
		product.EANCode = *req.EANCode
	}
	if req.Name != nil {
		product.Name = *req.Name
	}
	if req.Description != nil {
		product.Description = *req.Description
	}
	if req.Manufacturer != nil {
		product.Manufacturer = *req.Manufacturer
	}
	if req.Category != nil {
		product.Category = *req.Category
	}
	if req.Subcategory != nil {
		product.Subcategory = *req.Subcategory
	}
	if req.PriceCents != nil {
		product.PriceCents = *req.PriceCents
	}
	if req.InternalCode != nil {
		product.InternalCode = *req.InternalCode
	}
	if req.FactoryPriceCents != nil {
		product.FactoryPriceCents = *req.FactoryPriceCents
	}
	if req.PMCCents != nil {
		product.PMCCents = *req.PMCCents
	}
	if req.CommercialDiscountCents != nil {
		product.CommercialDiscountCents = *req.CommercialDiscountCents
	}
	if req.TaxSubstitutionCents != nil {
		product.TaxSubstitutionCents = *req.TaxSubstitutionCents
	}
	if req.InvoicePriceCents != nil {
		product.InvoicePriceCents = *req.InvoicePriceCents
	}

	if err := h.svc.UpdateProduct(r.Context(), product); err != nil {
		writeError(w, http.StatusInternalServerError, err)
		return
	}

	writeJSON(w, http.StatusOK, product)
}

// DeleteProduct godoc
// @Summary Remover produto
// @Tags Produtos
// @Param id path string true "Product ID"
// @Success 204 ""
// @Failure 400 {object} map[string]string
// @Failure 404 {object} map[string]string
// @Router /api/v1/products/{id} [delete]
func (h *Handler) DeleteProduct(w http.ResponseWriter, r *http.Request) {
	id, err := parseUUIDFromPath(r.URL.Path)
	if err != nil {
		writeError(w, http.StatusBadRequest, err)
		return
	}

	if err := h.svc.DeleteProduct(r.Context(), id); err != nil {
		writeError(w, http.StatusBadRequest, err)
		return
	}

	w.WriteHeader(http.StatusNoContent)
}

// ListInventory godoc
// @Summary Listar estoque
// @Tags Estoque
// @Security BearerAuth
// @Produce json
// @Param expires_in_days query int false "Dias para expiração"
// @Success 200 {array} domain.InventoryItem
// @Router /api/v1/inventory [get]
// ListInventory exposes stock with expiring batch filters.
func (h *Handler) ListInventory(w http.ResponseWriter, r *http.Request) {
	page, pageSize := parsePagination(r)
	var filter domain.InventoryFilter
	if days := r.URL.Query().Get("expires_in_days"); days != "" {
		n, err := strconv.Atoi(days)
		if err != nil || n < 0 {
			writeError(w, http.StatusBadRequest, errors.New("invalid expires_in_days"))
			return
		}
		expires := time.Now().Add(time.Duration(n) * 24 * time.Hour)
		filter.ExpiringBefore = &expires
	}

	if sellerIDStr := r.URL.Query().Get("empresa_id"); sellerIDStr != "" {
		if id, err := uuid.FromString(sellerIDStr); err == nil {
			filter.SellerID = &id
		}
	} else if sellerIDStr := r.URL.Query().Get("seller_id"); sellerIDStr != "" {
		if id, err := uuid.FromString(sellerIDStr); err == nil {
			filter.SellerID = &id
		}
	}

	result, err := h.svc.ListInventory(r.Context(), filter, page, pageSize)
	if err != nil {
		writeError(w, http.StatusInternalServerError, err)
		return
	}

	writeJSON(w, http.StatusOK, result)
}

// AdjustInventory godoc
// @Summary Ajustar estoque
// @Tags Estoque
// @Security BearerAuth
// @Accept json
// @Produce json
// @Param payload body inventoryAdjustRequest true "Ajuste de estoque"
// @Success 200 {object} domain.InventoryItem
// @Failure 400 {object} map[string]string
// @Router /api/v1/inventory/adjust [post]
// AdjustInventory handles manual stock corrections.
func (h *Handler) AdjustInventory(w http.ResponseWriter, r *http.Request) {
	var req inventoryAdjustRequest
	if err := decodeJSON(r.Context(), r, &req); err != nil {
		writeError(w, http.StatusBadRequest, err)
		return
	}

	if req.Delta == 0 {
		writeError(w, http.StatusBadRequest, errors.New("delta must be non-zero"))
		return
	}

	item, err := h.svc.AdjustInventory(r.Context(), req.ProductID, req.Delta, req.Reason)
	if err != nil {
		writeError(w, http.StatusBadRequest, err)
		return
	}

	writeJSON(w, http.StatusOK, item)
}

// ListManufacturers godoc
// @Summary Listar fabricantes (laboratórios)
// @Tags Produtos
// @Produce json
// @Success 200 {array} string
// @Router /api/v1/laboratorios [get]
func (h *Handler) ListManufacturers(w http.ResponseWriter, r *http.Request) {
	manufacturers, err := h.svc.ListManufacturers(r.Context())
	if err != nil {
		writeError(w, http.StatusInternalServerError, err)
		return
	}
	writeJSON(w, http.StatusOK, manufacturers)
}

// ListCategories godoc
// @Summary Listar categorias
// @Tags Produtos
// @Produce json
// @Success 200 {array} string
// @Router /api/v1/categorias [get]
func (h *Handler) ListCategories(w http.ResponseWriter, r *http.Request) {
	categories, err := h.svc.ListCategories(r.Context())
	if err != nil {
		writeError(w, http.StatusInternalServerError, err)
		return
	}
	writeJSON(w, http.StatusOK, categories)
}

// GetProductByEAN godoc
// @Summary Buscar produto por EAN
// @Tags Produtos
// @Produce json
// @Param ean path string true "EAN Code"
// @Success 200 {object} domain.Product
// @Failure 404 {object} map[string]string
// @Router /api/v1/produtos-catalogo/codigo-ean/{ean} [get]
func (h *Handler) GetProductByEAN(w http.ResponseWriter, r *http.Request) {
	ean := r.PathValue("ean") // Go 1.22
	if ean == "" {
		// Fallback for older mux
		parts := splitPath(r.URL.Path)
		if len(parts) > 0 {
			ean = parts[len(parts)-1]
		}
	}

	if ean == "" {
		writeError(w, http.StatusBadRequest, errors.New("ean is required"))
		return
	}

	product, err := h.svc.GetProductByEAN(r.Context(), ean)
	if err != nil {
		writeError(w, http.StatusNotFound, err)
		return
	}
	writeJSON(w, http.StatusOK, product)
}

type registerInventoryRequest struct {
	ProductID          string `json:"product_id"`
	SellerID           string `json:"seller_id"`
	SalePriceCents     int64  `json:"sale_price_cents"`
	OriginalPriceCents int64  `json:"original_price_cents"` // Added to fix backend error
	FinalPriceCents    int64  `json:"final_price_cents"`    // Optional explicit field
	StockQuantity      int64  `json:"stock_quantity"`
	ExpiresAt          string `json:"expires_at"` // ISO8601
	Observations       string `json:"observations"`
}

// CreateInventoryItem godoc
// @Summary Adicionar item ao estoque (venda)
// @Tags Estoque
// @Accept json
// @Produce json
// @Param payload body registerInventoryRequest true "Inventory Data"
// @Success 201 {object} domain.InventoryItem
// @Router /api/v1/inventory [post]
func (h *Handler) CreateInventoryItem(w http.ResponseWriter, r *http.Request) {
	var req registerInventoryRequest
	if err := decodeJSON(r.Context(), r, &req); err != nil {
		writeError(w, http.StatusBadRequest, err)
		return
	}

	// Parse UUIDs
	prodID, err := uuid.FromString(req.ProductID)
	if err != nil {
		writeError(w, http.StatusBadRequest, errors.New("invalid product_id"))
		return
	}
	sellerID, err := uuid.FromString(req.SellerID)
	if err != nil {
		writeError(w, http.StatusBadRequest, errors.New("invalid seller_id"))
		return
	}

	// Parse Expiration
	expiresAt, err := time.Parse(time.RFC3339, req.ExpiresAt)
	if err != nil {
		// Try YYYY-MM-DD
		expiresAt, err = time.Parse("2006-01-02", req.ExpiresAt)
		if err != nil {
			writeError(w, http.StatusBadRequest, errors.New("invalid expires_at format"))
			return
		}
	}

	// Logic: Use FinalPriceCents if provided, else SalePriceCents
	finalPrice := req.SalePriceCents
	if req.FinalPriceCents > 0 {
		finalPrice = req.FinalPriceCents
	}

	item := &domain.InventoryItem{
		ProductID:      prodID,
		SellerID:       sellerID,
		SalePriceCents: finalPrice,
		StockQuantity:  req.StockQuantity,
		ExpiresAt:      expiresAt,
		Observations:   req.Observations,
		Batch:          "BATCH-" + time.Now().Format("20060102"), // Generate a batch or accept from req
	}

	// Since we don't have a specific CreateInventoryItem usecase method in interface yet,
	// we should create one or use the repository directly via service.
	// Assuming svc.AddInventoryItem exists?
	// Let's check service interface. If not, I'll assume I need to add it or it's missing.
	// I recall `AdjustInventory` but maybe not Create.
	// I'll assume I need to implement `RegisterInventoryItem` in service.
	// For now, I'll call svc.RegisterInventoryItem(ctx, item) and expect to fix Service.

	if err := h.svc.RegisterInventoryItem(r.Context(), item); err != nil {
		writeError(w, http.StatusInternalServerError, err)
		return
	}

	writeJSON(w, http.StatusCreated, item)
}