From 4806840ba4ed70fe064ebb34f94f2c81e4a1d57e Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Dalibor=20Markovi=C4=87?= Date: Tue, 30 Jun 2026 17:08:50 +0200 Subject: [PATCH 1/2] =?UTF-8?q?Zalihe:=20razlikovanje=20manjka=20i=20vi?= =?UTF-8?q?=C5=A1ka=20pri=20popisu=20(manjak=5Fpopis/visak=5Fpopis=20tip?= =?UTF-8?q?=20promene)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- internal/db/repository.go | 6 ++--- internal/db/sqlite/artikal.go | 7 +++--- internal/handler/izvestaji.go | 6 ++++- internal/handler/magacin_forma.go | 2 +- internal/model/magacin.go | 2 ++ migrations/089_magacin_manjak_visak.sql | 25 +++++++++++++++++++++ web/templates/stranice/magacin_kartica.html | 4 ++++ web/templates/stranice/prometni_list.html | 4 ++++ 8 files changed, 48 insertions(+), 8 deletions(-) create mode 100644 migrations/089_magacin_manjak_visak.sql diff --git a/internal/db/repository.go b/internal/db/repository.go index 69e89e1..b688d23 100644 --- a/internal/db/repository.go +++ b/internal/db/repository.go @@ -29,8 +29,8 @@ type ArtikalRepository interface { Vrati(ctx context.Context, id int64) error // SledecaSifra vraća predlog sledeće auto-šifre (npr. KOMP-0042 ili ART-0042) SledecaSifra(ctx context.Context, kategorijaID *int64) (string, error) - // KorigujKolicinu postavlja novu količinu artikla i upisuje korekciju u magacinske_promene - KorigujKolicinu(ctx context.Context, artikalID int64, novaKolicina int, korisnikID *int64, napomena string) error + // KorigujKolicinu postavlja novu količinu artikla i upisuje promenu u magacinske_promene + KorigujKolicinu(ctx context.Context, artikalID int64, novaKolicina int, korisnikID *int64, napomena, tipPromene string) error // DobavljaciArtikla vraća ID-jeve dobavljača vezanih za artikal DobavljaciArtikla(ctx context.Context, artikalID int64) ([]int64, error) // PostaviDobavljaceArtikla zamenjuje skup dobavljača artikla datim ID-jevima @@ -152,7 +152,7 @@ type NabavkaRepository interface { DohvatiStavke(ctx context.Context, nabavkaID int64) ([]model.StavkaSaArtiklom, error) DohvatiTroskove(ctx context.Context, nabavkaID int64) ([]model.NabavkaTrosak, error) Kreiraj(ctx context.Context, n *model.Nabavka, stavke []model.StavkaNabavke, troskovi []model.NabavkaTrosak, korisnikID *int64) (int64, error) - Obrisi(ctx context.Context, id int64, korisnikID *int64) error + Storno(ctx context.Context, id int64, razlog string, korisnikID *int64) error } // DobavljacRepository definiše operacije nad dobavljačima diff --git a/internal/db/sqlite/artikal.go b/internal/db/sqlite/artikal.go index 0bcc94b..9766297 100644 --- a/internal/db/sqlite/artikal.go +++ b/internal/db/sqlite/artikal.go @@ -397,8 +397,9 @@ func (r *ArtikalRepo) SveDobavljaceArtikala(ctx context.Context) (map[int64][]in return mapa, nil } -// KorigujKolicinu postavlja novu količinu i upisuje korekciju u magacinske_promene -func (r *ArtikalRepo) KorigujKolicinu(ctx context.Context, artikalID int64, novaKolicina int, korisnikID *int64, napomena string) error { +// KorigujKolicinu postavlja novu količinu i upisuje promenu u magacinske_promene; +// tipPromene određuje vrstu traga (korekcija, manjak_popis, visak_popis) +func (r *ArtikalRepo) KorigujKolicinu(ctx context.Context, artikalID int64, novaKolicina int, korisnikID *int64, napomena, tipPromene string) error { tx, err := r.db.BeginTx(ctx, nil) if err != nil { return fmt.Errorf("ntech: ArtikalRepo.KorigujKolicinu: begin: %w", err) @@ -418,7 +419,7 @@ func (r *ArtikalRepo) KorigujKolicinu(ctx context.Context, artikalID int64, nova } promena := novaKolicina - staraKolicina - if err = zabeleziMagacinPromenu(ctx, tx, artikalID, model.PromenaKorekcija, promena, + if err = zabeleziMagacinPromenu(ctx, tx, artikalID, tipPromene, promena, staraKolicina, novaKolicina, 0, korisnikID, napomena); err != nil { return fmt.Errorf("ntech: ArtikalRepo.KorigujKolicinu: %w", err) } diff --git a/internal/handler/izvestaji.go b/internal/handler/izvestaji.go index 5567b3f..5fe49fd 100644 --- a/internal/handler/izvestaji.go +++ b/internal/handler/izvestaji.go @@ -413,7 +413,11 @@ func (h *Handler) SacuvajPopis(w http.ResponseWriter, r *http.Request) { continue } povecano := nova > a.Kolicina - if err := h.Artikli.KorigujKolicinu(r.Context(), a.ID, nova, &k.ID, napomena); err != nil { + tipPromene := model.PromenaManjak + if povecano { + tipPromene = model.PromenaVisak + } + if err := h.Artikli.KorigujKolicinu(r.Context(), a.ID, nova, &k.ID, napomena, tipPromene); err != nil { slog.Error("popis: korekcija artikla", "id", a.ID, "error", err) greskaBroj++ continue diff --git a/internal/handler/magacin_forma.go b/internal/handler/magacin_forma.go index 8293fe0..6653d2a 100644 --- a/internal/handler/magacin_forma.go +++ b/internal/handler/magacin_forma.go @@ -264,7 +264,7 @@ func (h *Handler) SacuvajIzmenuArtikla(w http.ResponseWriter, r *http.Request) { // ako se količina promenila, koriguj stanje uz magacinski trag if novaKolicina != staraKolicina { - if e := h.Artikli.KorigujKolicinu(r.Context(), id, novaKolicina, &k.ID, "izmena artikla"); e != nil { + if e := h.Artikli.KorigujKolicinu(r.Context(), id, novaKolicina, &k.ID, "izmena artikla", model.PromenaKorekcija); e != nil { slog.Error("korekcija količine pri izmeni artikla nije uspela", "artikal_id", id, "error", e) } } diff --git a/internal/model/magacin.go b/internal/model/magacin.go index 8b382d9..1ca0b9d 100644 --- a/internal/model/magacin.go +++ b/internal/model/magacin.go @@ -9,6 +9,8 @@ const ( PromenaIzlazServis = "izlaz_servis" PromenaPovracaj = "povracaj" PromenaKorekcija = "korekcija" + PromenaManjak = "manjak_popis" + PromenaVisak = "visak_popis" ) // MagacinskaPromenaSaDetaljem je promena stanja artikla sa nazivom artikla diff --git a/migrations/089_magacin_manjak_visak.sql b/migrations/089_magacin_manjak_visak.sql new file mode 100644 index 0000000..ee3db8f --- /dev/null +++ b/migrations/089_magacin_manjak_visak.sql @@ -0,0 +1,25 @@ +-- Proširuje CHECK constraint na magacinske_promene da uključi manjak_popis i visak_popis +-- SQLite ne podržava ALTER TABLE za CHECK, pa rekreiramo tabelu +PRAGMA foreign_keys=OFF; + +CREATE TABLE magacinske_promene_nova ( + id INTEGER PRIMARY KEY AUTOINCREMENT, + artikal_id INTEGER NOT NULL REFERENCES artikli(id) ON DELETE RESTRICT, + tip_promene TEXT NOT NULL CHECK (tip_promene IN ( + 'ulaz_nabavka', 'izlaz_prodaja', 'izlaz_servis', + 'povracaj', 'korekcija', 'manjak_popis', 'visak_popis' + )), + referentni_id INTEGER NOT NULL, + promena_kolicine INTEGER NOT NULL, + stanje_pre INTEGER NOT NULL, + stanje_posle INTEGER NOT NULL, + korisnik_id INTEGER REFERENCES korisnici(id) ON DELETE SET NULL, + napomena TEXT, + datum DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP +); + +INSERT INTO magacinske_promene_nova SELECT * FROM magacinske_promene; +DROP TABLE magacinske_promene; +ALTER TABLE magacinske_promene_nova RENAME TO magacinske_promene; + +PRAGMA foreign_keys=ON; diff --git a/web/templates/stranice/magacin_kartica.html b/web/templates/stranice/magacin_kartica.html index 2e94d90..e7a706e 100644 --- a/web/templates/stranice/magacin_kartica.html +++ b/web/templates/stranice/magacin_kartica.html @@ -129,6 +129,10 @@ Povraćaj {{else if eq .TipPromene "korekcija"}} Korekcija + {{else if eq .TipPromene "manjak_popis"}} + Manjak (popis) + {{else if eq .TipPromene "visak_popis"}} + Višak (popis) {{else}} {{.TipPromene}} {{end}} diff --git a/web/templates/stranice/prometni_list.html b/web/templates/stranice/prometni_list.html index 8d21cae..27496a6 100644 --- a/web/templates/stranice/prometni_list.html +++ b/web/templates/stranice/prometni_list.html @@ -66,6 +66,10 @@ Povraćaj {{else if eq .TipPromene "korekcija"}} Korekcija + {{else if eq .TipPromene "manjak_popis"}} + Manjak (popis) + {{else if eq .TipPromene "visak_popis"}} + Višak (popis) {{else}} {{.TipPromene}} {{end}} From b79ca28b09e2d1af18f380bc4a49a5183da378ae Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Dalibor=20Markovi=C4=87?= Date: Tue, 30 Jun 2026 17:08:55 +0200 Subject: [PATCH 2/2] =?UTF-8?q?Zalihe:=20storno=20nabavke=20umesto=20brisa?= =?UTF-8?q?nja=20+=20ponderisana=20prose=C4=8Dna=20nabavna=20cena?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- cmd/ntech/main.go | 2 +- internal/db/sqlite/nabavka.go | 76 ++++++++++++++------- internal/handler/nabavka.go | 41 +++++------ internal/middleware/dozvole.go | 3 +- internal/model/nabavka.go | 14 ++-- migrations/090_nabavka_storno.sql | 3 + web/templates/stranice/nabavka_detalji.html | 37 +++++++--- web/templates/stranice/nabavke.html | 24 ++----- 8 files changed, 124 insertions(+), 76 deletions(-) create mode 100644 migrations/090_nabavka_storno.sql diff --git a/cmd/ntech/main.go b/cmd/ntech/main.go index 4ab3eb8..d602bd5 100644 --- a/cmd/ntech/main.go +++ b/cmd/ntech/main.go @@ -350,7 +350,7 @@ func main() { r.With(ntechmw.RequireDozvola(h.DozvoleRepo.ImaDozvolu, "nabavka.pregled")).Get("/nabavke/nova", h.NovaNabavka) r.With(doz("nabavka.dodaj")).Post("/nabavke/nova", h.SacuvajNabavku) r.With(ntechmw.RequireDozvola(h.DozvoleRepo.ImaDozvolu, "nabavka.pregled")).Get("/nabavke/{id}", h.DetaljiNabavke) - r.With(doz("nabavka.obrisi")).Post("/nabavke/obrisi/{id}", h.ObrisiNabavku) + r.With(doz("nabavka.storno")).Post("/nabavke/storno/{id}", h.StornoNabavke) r.With(ntechmw.RequireDozvola(h.DozvoleRepo.ImaDozvolu, "dobavljac.pregled")).Get("/dobavljaci", h.Dobavljaci) r.Get("/dobavljaci/novi", h.NoviDobavljac) r.With(doz("dobavljac.dodaj")).Post("/dobavljaci/novi", h.SacuvajDobavljaca) diff --git a/internal/db/sqlite/nabavka.go b/internal/db/sqlite/nabavka.go index 2224668..bb33ce7 100644 --- a/internal/db/sqlite/nabavka.go +++ b/internal/db/sqlite/nabavka.go @@ -22,7 +22,8 @@ func NoviNabavkaRepo(db *sql.DB) *NabavkaRepo { func (r *NabavkaRepo) Lista(ctx context.Context) ([]model.NabavkaSaDetaljem, error) { redovi, err := r.db.QueryContext(ctx, ` SELECT - n.id, n.dobavljac_id, n.napomena, n.ukupno, n.metod_raspodele, n.datum, + n.id, n.dobavljac_id, n.napomena, n.ukupno, n.metod_raspodele, + n.stornirano, n.razlog_storniranja, n.datum, COALESCE(d.naziv, '') AS dobavljac_naziv FROM nabavke n LEFT JOIN dobavljaci d ON n.dobavljac_id = d.id @@ -36,10 +37,11 @@ func (r *NabavkaRepo) Lista(ctx context.Context) ([]model.NabavkaSaDetaljem, err for redovi.Next() { var n model.NabavkaSaDetaljem var dobavljacID sql.NullInt64 - var napomena, metod sql.NullString + var napomena, metod, razlogStorniranja sql.NullString err := redovi.Scan( - &n.ID, &dobavljacID, &napomena, &n.Ukupno, &metod, &n.Datum, + &n.ID, &dobavljacID, &napomena, &n.Ukupno, &metod, + &n.Stornirano, &razlogStorniranja, &n.Datum, &n.DobavljacNaziv, ) if err != nil { @@ -51,6 +53,7 @@ func (r *NabavkaRepo) Lista(ctx context.Context) ([]model.NabavkaSaDetaljem, err } n.Napomena = napomena.String n.MetodRaspodele = metod.String + n.RazlogStorniranja = razlogStorniranja.String rezultat = append(rezultat, n) } @@ -62,12 +65,14 @@ func (r *NabavkaRepo) Lista(ctx context.Context) ([]model.NabavkaSaDetaljem, err func (r *NabavkaRepo) DohvatiID(ctx context.Context, id int64) (*model.Nabavka, error) { var n model.Nabavka var dobavljacID sql.NullInt64 - var napomena, metod sql.NullString + var napomena, metod, razlogStorniranja sql.NullString err := r.db.QueryRowContext(ctx, ` - SELECT id, dobavljac_id, napomena, ukupno, metod_raspodele, datum + SELECT id, dobavljac_id, napomena, ukupno, metod_raspodele, + stornirano, razlog_storniranja, datum FROM nabavke WHERE id = ?`, id).Scan( - &n.ID, &dobavljacID, &napomena, &n.Ukupno, &metod, &n.Datum, + &n.ID, &dobavljacID, &napomena, &n.Ukupno, &metod, + &n.Stornirano, &razlogStorniranja, &n.Datum, ) if err != nil { return nil, fmt.Errorf("ntech: NabavkaRepo.DohvatiID: %w", err) @@ -78,6 +83,7 @@ func (r *NabavkaRepo) DohvatiID(ctx context.Context, id int64) (*model.Nabavka, } n.Napomena = napomena.String n.MetodRaspodele = metod.String + n.RazlogStorniranja = razlogStorniranja.String return &n, nil } @@ -194,17 +200,26 @@ func (r *NabavkaRepo) Kreiraj(ctx context.Context, n *model.Nabavka, stavke []mo } var stanjePre int + var staraNabavnaCena float64 err = tx.QueryRowContext(ctx, - "SELECT kolicina FROM artikli WHERE id = ?", s.ArtikalID, - ).Scan(&stanjePre) + "SELECT kolicina, nabavna_cena FROM artikli WHERE id = ?", s.ArtikalID, + ).Scan(&stanjePre, &staraNabavnaCena) if err != nil { return 0, fmt.Errorf("ntech: NabavkaRepo.Kreiraj: dohvati stanje: %w", err) } + // ponderisana prosečna nabavna cena (MRS 2) stanjePosle := stanjePre + s.Kolicina + var novaProsecna float64 + if stanjePosle > 0 { + novaProsecna = (float64(stanjePre)*staraNabavnaCena + float64(s.Kolicina)*s.CenaPoKomadu) / float64(stanjePosle) + } else { + novaProsecna = s.CenaPoKomadu + } + _, err = tx.ExecContext(ctx, - "UPDATE artikli SET kolicina = ? WHERE id = ?", - stanjePosle, s.ArtikalID, + "UPDATE artikli SET kolicina = ?, nabavna_cena = ? WHERE id = ?", + stanjePosle, novaProsecna, s.ArtikalID, ) if err != nil { return 0, fmt.Errorf("ntech: NabavkaRepo.Kreiraj: update kolicina: %w", err) @@ -223,19 +238,31 @@ func (r *NabavkaRepo) Kreiraj(ctx context.Context, n *model.Nabavka, stavke []mo return nabavkaID, nil } -// Obrisi briše nabavku po ID-u, vraća količine artikala na stanje i beleži korekciju u magacinski trag. -func (r *NabavkaRepo) Obrisi(ctx context.Context, id int64, korisnikID *int64) error { +// Storno označava nabavku kao storniranu, vraća količine artikala na stanje i beleži +// korekciju u magacinski trag. Nabavna cena se NE računa unazad — ostaje kakva jeste. +func (r *NabavkaRepo) Storno(ctx context.Context, id int64, razlog string, korisnikID *int64) error { tx, err := r.db.BeginTx(ctx, nil) if err != nil { - return fmt.Errorf("ntech: NabavkaRepo.Obrisi: begin: %w", err) + return fmt.Errorf("ntech: NabavkaRepo.Storno: begin: %w", err) } defer tx.Rollback() - // učitaj stavke pre brisanja (CASCADE ih briše zajedno sa nabavkom) + // provera da li je već stornirano + var stornirano bool + if err := tx.QueryRowContext(ctx, + "SELECT stornirano FROM nabavke WHERE id = ?", id, + ).Scan(&stornirano); err != nil { + return fmt.Errorf("ntech: NabavkaRepo.Storno: provera: %w", err) + } + if stornirano { + return fmt.Errorf("ntech: NabavkaRepo.Storno: nabavka je već stornirana") + } + + // učitaj stavke redovi, err := tx.QueryContext(ctx, "SELECT artikal_id, kolicina FROM stavke_nabavke WHERE nabavka_id = ?", id) if err != nil { - return fmt.Errorf("ntech: NabavkaRepo.Obrisi: dohvati stavke: %w", err) + return fmt.Errorf("ntech: NabavkaRepo.Storno: dohvati stavke: %w", err) } type stavka struct { artikalID int64 @@ -246,7 +273,7 @@ func (r *NabavkaRepo) Obrisi(ctx context.Context, id int64, korisnikID *int64) e var s stavka if err := redovi.Scan(&s.artikalID, &s.kolicina); err != nil { redovi.Close() - return fmt.Errorf("ntech: NabavkaRepo.Obrisi: scan stavka: %w", err) + return fmt.Errorf("ntech: NabavkaRepo.Storno: scan stavka: %w", err) } stavke = append(stavke, s) } @@ -258,7 +285,7 @@ func (r *NabavkaRepo) Obrisi(ctx context.Context, id int64, korisnikID *int64) e if err := tx.QueryRowContext(ctx, "SELECT kolicina FROM artikli WHERE id = ?", s.artikalID, ).Scan(&stanjePre); err != nil { - return fmt.Errorf("ntech: NabavkaRepo.Obrisi: dohvati stanje: %w", err) + return fmt.Errorf("ntech: NabavkaRepo.Storno: dohvati stanje: %w", err) } stanjePosle := stanjePre - s.kolicina if stanjePosle < 0 { @@ -267,20 +294,23 @@ func (r *NabavkaRepo) Obrisi(ctx context.Context, id int64, korisnikID *int64) e if _, err := tx.ExecContext(ctx, "UPDATE artikli SET kolicina = ? WHERE id = ?", stanjePosle, s.artikalID, ); err != nil { - return fmt.Errorf("ntech: NabavkaRepo.Obrisi: update stanje: %w", err) + return fmt.Errorf("ntech: NabavkaRepo.Storno: update stanje: %w", err) } if err := zabeleziMagacinPromenu(ctx, tx, s.artikalID, model.PromenaKorekcija, - -s.kolicina, stanjePre, stanjePosle, id, korisnikID, "brisanje nabavke"); err != nil { - return fmt.Errorf("ntech: NabavkaRepo.Obrisi: magacin: %w", err) + -s.kolicina, stanjePre, stanjePosle, id, korisnikID, "storno nabavke: "+razlog); err != nil { + return fmt.Errorf("ntech: NabavkaRepo.Storno: magacin: %w", err) } } - if _, err := tx.ExecContext(ctx, "DELETE FROM nabavke WHERE id = ?", id); err != nil { - return fmt.Errorf("ntech: NabavkaRepo.Obrisi: delete: %w", err) + if _, err := tx.ExecContext(ctx, + "UPDATE nabavke SET stornirano = 1, razlog_storniranja = ? WHERE id = ?", + nullString(razlog), id, + ); err != nil { + return fmt.Errorf("ntech: NabavkaRepo.Storno: update nabavka: %w", err) } if err := tx.Commit(); err != nil { - return fmt.Errorf("ntech: NabavkaRepo.Obrisi: commit: %w", err) + return fmt.Errorf("ntech: NabavkaRepo.Storno: commit: %w", err) } return nil } diff --git a/internal/handler/nabavka.go b/internal/handler/nabavka.go index c3ac6e2..1706ea3 100644 --- a/internal/handler/nabavka.go +++ b/internal/handler/nabavka.go @@ -43,6 +43,7 @@ type PodaciDetaljiNabavke struct { Troskovi []model.NabavkaTrosak UkupanTrosak float64 DobavljacNaziv string + Sacuvano bool } // artikalUJSON pretvara listu artikala u template.JS vrednost bezbednu za umetanje u