KIR: PostojiZaIzvor + backfill iz prodaje (dugme u KIR listi)

cmd/ntech/main.go

@@ -311,6 +311,7 @@ func main() {
 		r.With(modul("pdv")).Get("/pdv/kir/nova", h.NoviPdvKir)
 		r.With(modul("pdv"), doz("pdv.dodaj")).Post("/pdv/kir/nova", h.SacuvajPdvKir)
 		r.With(modul("pdv"), doz("pdv.obrisi")).Post("/pdv/kir/obrisi/{id}", h.ObrisiPdvKir)
+		r.With(modul("pdv"), doz("pdv.dodaj")).Post("/pdv/kir/backfill-prodaje", h.KirBackfillProdaje)
 		r.With(modul("pdv")).Get("/pdv/kpr", h.PdvKpr)
 		r.With(modul("pdv")).Get("/pdv/kpr/nova", h.NoviPdvKpr)
 		r.With(modul("pdv"), doz("pdv.dodaj")).Post("/pdv/kpr/nova", h.SacuvajPdvKpr)

internal/db/repository.go

@@ -68,6 +68,8 @@ type PdvKirRepository interface {
 	Obrisi(ctx context.Context, id int64) error
 	// ObrisiPoIzvoru briše zapise vezane za dati izvor (npr. pri stornu prodaje)
 	ObrisiPoIzvoru(ctx context.Context, izvor string, izvorID int64) error
+	// PostojiZaIzvor vraća true ako postoji bar jedan zapis za dati izvor i izvorID
+	PostojiZaIzvor(ctx context.Context, izvor string, izvorID int64) (bool, error)
 }
 
 // PdvKprRepository definiše operacije nad knjigom primljenih računa (KPR)

internal/db/sqlite/pdv_evidencija.go

@@ -136,6 +136,18 @@ func (r *PdvKirRepo) ObrisiPoIzvoru(ctx context.Context, izvor string, izvorID i
 	return nil
 }
 
+// PostojiZaIzvor vraća true ako postoji bar jedan KIR zapis za dati izvor i izvorID
+func (r *PdvKirRepo) PostojiZaIzvor(ctx context.Context, izvor string, izvorID int64) (bool, error) {
+	var n int
+	err := r.db.QueryRowContext(ctx,
+		"SELECT COUNT(*) FROM pdv_kir WHERE izvor = ? AND izvor_id = ?", izvor, izvorID,
+	).Scan(&n)
+	if err != nil {
+		return false, fmt.Errorf("ntech: PdvKirRepo.PostojiZaIzvor: %w", err)
+	}
+	return n > 0, nil
+}
+
 // izvorIliRucno vraća izvor ili podrazumevano „rucno" (izvor kolona je NOT NULL)
 func izvorIliRucno(izvor string) string {
 	if izvor == "" {

internal/handler/pdv_kir.go

@@ -1,6 +1,8 @@
 package handler
 
 import (
+	"fmt"
+	"log/slog"
 	"net/http"
 	"strconv"
 	"strings"
@@ -188,3 +190,58 @@ func (h *Handler) ObrisiPdvKir(w http.ResponseWriter, r *http.Request) {
 	}
 	http.Redirect(w, r, "/pdv/kir?obrisan=1", http.StatusSeeOther)
 }
+
+// KirBackfillProdaje kreira KIR zapise za sve B2B prodaje koje ih nemaju.
+// Namenjen za jednokratno popunjavanje starih podataka.
+func (h *Handler) KirBackfillProdaje(w http.ResponseWriter, r *http.Request) {
+	if _, ok := h.zahtevajDozvolu(w, r, "pdv.dodaj"); !ok {
+		return
+	}
+	ctx := r.Context()
+
+	nalozi, err := h.ProdajaRepo.Lista(ctx, "")
+	if err != nil {
+		http.Error(w, "Greška pri učitavanju prodaje", http.StatusInternalServerError)
+		return
+	}
+
+	var kreirano, preskoceno int
+	for _, nd := range nalozi {
+		if nd.KlijentID == nil {
+			preskoceno++
+			continue
+		}
+		postoji, _ := h.PdvKirRepo.PostojiZaIzvor(ctx, "prodaja", nd.ID)
+		if postoji {
+			preskoceno++
+			continue
+		}
+		stavke, err := h.ProdajaRepo.DohvatiStavke(ctx, nd.ID)
+		if err != nil {
+			slog.Error("backfill KIR: greška pri čitanju stavki", "prodaja_id", nd.ID, "error", err)
+			continue
+		}
+		var ss []model.StavkaProdaje
+		for _, s := range stavke {
+			ss = append(ss, s.StavkaProdaje)
+		}
+		klijent, err := h.KlijentiRepo.DohvatiID(ctx, *nd.KlijentID)
+		if err != nil {
+			slog.Error("backfill KIR: greška pri čitanju klijenta", "prodaja_id", nd.ID, "error", err)
+			continue
+		}
+		pib := klijent.PIB
+		if klijent.Tip != "pravno" {
+			pib = klijent.JMBG
+		}
+		kir := model.KirIzProdaje(nd.ProdajniNalog, ss, klijent.PunoIme(), pib, klijent.Mesto)
+		if _, e := h.PdvKirRepo.Kreiraj(ctx, &kir); e != nil {
+			slog.Error("backfill KIR: greška pri kreiranju zapisa", "prodaja_id", nd.ID, "error", e)
+			continue
+		}
+		kreirano++
+	}
+
+	middleware.SetFlash(w, r, h.DB, "uspeh", fmt.Sprintf("Backfill završen: %d novih KIR zapisa, %d preskočeno.", kreirano, preskoceno))
+	http.Redirect(w, r, "/pdv/kir", http.StatusSeeOther)
+}

web/templates/stranice/pdv_kir.html

@@ -20,7 +20,18 @@
                 <button type="submit" style="padding:8px 16px;background:var(--sb-aktivan);color:var(--tekst-jak);border:0.5px solid var(--ivica);border-radius:8px;font-size:13px;cursor:pointer;">Prikaži</button>
                 {{if or .Od .Do}}<a href="/pdv/kir" class="nazad-link" hx-boost="true" hx-target="#glavni-sadrzaj" hx-select="#glavni-sadrzaj" hx-swap="outerHTML" style="margin-bottom:0;">Poništi filter</a>{{end}}
             </form>
-            <a hx-boost="true" hx-target="#glavni-sadrzaj" hx-select="#glavni-sadrzaj" hx-swap="outerHTML" href="/pdv/kir/nova" class="btn-primarno" style="font-size:13px;padding:8px 16px;white-space:nowrap;">+ Nov izlazni račun</a>
+            <div style="display:flex;gap:8px;flex-wrap:wrap;align-items:center;">
+                {{if index .Dozvole "pdv.dodaj"}}
+                <form method="POST" action="/pdv/kir/backfill-prodaje" data-full-reload>
+                    <input type="hidden" name="csrf_token" value="{{.CsrfToken}}">
+                    <button type="submit" class="btn-sekundarno" style="font-size:13px;padding:8px 16px;white-space:nowrap;"
+                        data-potvrda="Uvesti sve B2B prodaje koje još nisu u KIR-u?">
+                        Uvezi iz prodaje
+                    </button>
+                </form>
+                {{end}}
+                <a hx-boost="true" hx-target="#glavni-sadrzaj" hx-select="#glavni-sadrzaj" hx-swap="outerHTML" href="/pdv/kir/nova" class="btn-primarno" style="font-size:13px;padding:8px 16px;white-space:nowrap;">+ Nov izlazni račun</a>
+            </div>
         </div>
     </div>