Servis: potrazivani delovi, garancija, zakljucavanje statusa

Nova tabela servisni_potrazivani_delovi — visak preko stanja ide u potrazivane, lager NE ide u minus. Merge istog artikla na nalogu. Vizuelni indikator prekoracenja u tabeli (crveno). Status zakljucan na Ceka delove dok ima potrazivanih. Garancija: kalendar sa default vrednoscu. data-refresh podrzava vise selektora. Brisanje dela brise i potrazivane. Inline animation:none za AJAX refresh.

internal/db/sqlite/servis.go

@@ -207,6 +207,28 @@ func (r *ServisRepo) AzurirajStatus(ctx context.Context, id int64, status string
 	return nil
 }
 
+// AzurirajGaranciju postavlja ili briše datum garancije na servisnom nalogu.
+// garancijaDo == nil → bez garancije.
+func (r *ServisRepo) AzurirajGaranciju(ctx context.Context, id int64, garancijaDo *time.Time) error {
+	if garancijaDo != nil {
+		_, err := r.db.ExecContext(ctx,
+			"UPDATE servisni_nalozi SET garancija_do = ? WHERE id = ?",
+			garancijaDo.Format("2006-01-02"), id,
+		)
+		if err != nil {
+			return fmt.Errorf("ntech: ServisRepo.AzurirajGaranciju: %w", err)
+		}
+	} else {
+		_, err := r.db.ExecContext(ctx,
+			"UPDATE servisni_nalozi SET garancija_do = NULL WHERE id = ?", id,
+		)
+		if err != nil {
+			return fmt.Errorf("ntech: ServisRepo.AzurirajGaranciju: %w", err)
+		}
+	}
+	return nil
+}
+
 // Obrisi briše servisni nalog po ID-u
 func (r *ServisRepo) Obrisi(ctx context.Context, id int64) error {
 	_, err := r.db.ExecContext(ctx, "DELETE FROM servisni_nalozi WHERE id = ?", id)

internal/db/sqlite/servisni_delovi.go

@@ -180,3 +180,15 @@ func (r *ServisniDeloviRepo) Obrisi(ctx context.Context, id int64, korisnikID *i
 
 	return nil
 }
+
+// DohvatiArtikalID vraća artikal_id za dati servisni deo (pre brisanja)
+func (r *ServisniDeloviRepo) DohvatiArtikalID(ctx context.Context, deoID int64) (int64, error) {
+	var artikalID int64
+	err := r.db.QueryRowContext(ctx,
+		"SELECT artikal_id FROM servisni_delovi WHERE id = ?", deoID,
+	).Scan(&artikalID)
+	if err != nil {
+		return 0, fmt.Errorf("ntech: ServisniDeloviRepo.DohvatiArtikalID: %w", err)
+	}
+	return artikalID, nil
+}

internal/db/sqlite/servisni_potrazivani_delovi.go

@@ -0,0 +1,107 @@
+package sqlite
+
+import (
+	"context"
+	"database/sql"
+	"errors"
+	"fmt"
+
+	"ntech/internal/model"
+)
+
+// ServisniPotrazivaniDeloviRepo je SQLite implementacija ServisniPotrazivaniDeloviRepository
+type ServisniPotrazivaniDeloviRepo struct {
+	db *sql.DB
+}
+
+// NoviServisniPotrazivaniDeloviRepo kreira novi repo
+func NoviServisniPotrazivaniDeloviRepo(db *sql.DB) *ServisniPotrazivaniDeloviRepo {
+	return &ServisniPotrazivaniDeloviRepo{db: db}
+}
+
+// DohvatiZaNalog vraća sve potraživane delove za dati servisni nalog
+func (r *ServisniPotrazivaniDeloviRepo) DohvatiZaNalog(ctx context.Context, nalogID int64) ([]model.ServisniPotrazivaniDeo, error) {
+	redovi, err := r.db.QueryContext(ctx, `
+		SELECT spd.id, spd.nalog_id, spd.artikal_id, spd.kolicina, spd.datum,
+		       a.naziv
+		FROM servisni_potrazivani_delovi spd
+		JOIN artikli a ON a.id = spd.artikal_id
+		WHERE spd.nalog_id = ?
+		ORDER BY spd.datum`, nalogID)
+	if err != nil {
+		return nil, fmt.Errorf("ntech: ServisniPotrazivaniDeloviRepo.DohvatiZaNalog: %w", err)
+	}
+	defer redovi.Close()
+
+	var rezultat []model.ServisniPotrazivaniDeo
+	for redovi.Next() {
+		var d model.ServisniPotrazivaniDeo
+		err := redovi.Scan(&d.ID, &d.NalogID, &d.ArtikalID, &d.Kolicina, &d.Datum, &d.ArtikalNaziv)
+		if err != nil {
+			return nil, fmt.Errorf("ntech: ServisniPotrazivaniDeloviRepo.DohvatiZaNalog: scan: %w", err)
+		}
+		rezultat = append(rezultat, d)
+	}
+	return rezultat, nil
+}
+
+// DodajIliUvecaj dodaje novi potraživani deo ili uvećava količinu ako već postoji.
+// Vraća ID reda (novog ili postojećeg).
+func (r *ServisniPotrazivaniDeloviRepo) DodajIliUvecaj(ctx context.Context, nalogID, artikalID int64, kolicina int) (int64, error) {
+	var postojeciID int64
+	var postojeciKol int
+	err := r.db.QueryRowContext(ctx,
+		"SELECT id, kolicina FROM servisni_potrazivani_delovi WHERE nalog_id = ? AND artikal_id = ?",
+		nalogID, artikalID,
+	).Scan(&postojeciID, &postojeciKol)
+
+	if err == nil {
+		novaKol := postojeciKol + kolicina
+		_, err = r.db.ExecContext(ctx,
+			"UPDATE servisni_potrazivani_delovi SET kolicina = ? WHERE id = ?",
+			novaKol, postojeciID,
+		)
+		if err != nil {
+			return 0, fmt.Errorf("ntech: ServisniPotrazivaniDeloviRepo.DodajIliUvecaj: update: %w", err)
+		}
+		return postojeciID, nil
+	}
+
+	if errors.Is(err, sql.ErrNoRows) {
+		rez, err := r.db.ExecContext(ctx,
+			"INSERT INTO servisni_potrazivani_delovi (nalog_id, artikal_id, kolicina) VALUES (?, ?, ?)",
+			nalogID, artikalID, kolicina,
+		)
+		if err != nil {
+			return 0, fmt.Errorf("ntech: ServisniPotrazivaniDeloviRepo.DodajIliUvecaj: insert: %w", err)
+		}
+		id, err := rez.LastInsertId()
+		if err != nil {
+			return 0, fmt.Errorf("ntech: ServisniPotrazivaniDeloviRepo.DodajIliUvecaj: last insert id: %w", err)
+		}
+		return id, nil
+	}
+
+	return 0, fmt.Errorf("ntech: ServisniPotrazivaniDeloviRepo.DodajIliUvecaj: proveri: %w", err)
+}
+
+// Obrisi uklanja potraživani deo po ID-u
+func (r *ServisniPotrazivaniDeloviRepo) Obrisi(ctx context.Context, id int64) error {
+	_, err := r.db.ExecContext(ctx, "DELETE FROM servisni_potrazivani_delovi WHERE id = ?", id)
+	if err != nil {
+		return fmt.Errorf("ntech: ServisniPotrazivaniDeloviRepo.Obrisi: %w", err)
+	}
+	return nil
+}
+
+// ObrisiZaArtikal briše sve potraživane delove za dati artikal na datom nalogu
+func (r *ServisniPotrazivaniDeloviRepo) ObrisiZaArtikal(ctx context.Context, nalogID, artikalID int64) error {
+	_, err := r.db.ExecContext(ctx,
+		"DELETE FROM servisni_potrazivani_delovi WHERE nalog_id = ? AND artikal_id = ?",
+		nalogID, artikalID,
+	)
+	if err != nil {
+		return fmt.Errorf("ntech: ServisniPotrazivaniDeloviRepo.ObrisiZaArtikal: %w", err)
+	}
+	return nil
+}