feat: dodata podrška za servise
Dodana osnovna funkcionalnost za upravljanje servisima: - Novi model (`internal/model/service.go`) - SQLite repository (`internal/db/sqlite/service.go`) - Handler (`internal/handler/service.go`) - Tri nove stranice (lista, detalji, forma) Izmenjeni: - main.go - repository.go - utils.go - handler.go
This commit is contained in:
@@ -0,0 +1,201 @@
|
||||
package sqlite
|
||||
|
||||
import (
|
||||
"context"
|
||||
"database/sql"
|
||||
"fmt"
|
||||
"time"
|
||||
|
||||
"ntech/internal/model"
|
||||
)
|
||||
|
||||
// ServisRepo je SQLite implementacija ServisRepository interfejsa
|
||||
type ServisRepo struct {
|
||||
db *sql.DB
|
||||
}
|
||||
|
||||
// NoviServisRepo kreira novi ServisRepo
|
||||
func NoviServisRepo(db *sql.DB) *ServisRepo {
|
||||
return &ServisRepo{db: db}
|
||||
}
|
||||
|
||||
// SledeciBroj generiše sledeći broj naloga u formatu SN-GGGG-NNNN
|
||||
func (r *ServisRepo) SledeciBroj(ctx context.Context) (string, error) {
|
||||
godina := time.Now().Year()
|
||||
uzorak := fmt.Sprintf("SN-%d-%%", godina)
|
||||
|
||||
var sledeci int
|
||||
err := r.db.QueryRowContext(ctx, `
|
||||
SELECT COALESCE(MAX(CAST(SUBSTR(broj_naloga, 9) AS INTEGER)), 0) + 1
|
||||
FROM servisni_nalozi
|
||||
WHERE broj_naloga LIKE ?`, uzorak).Scan(&sledeci)
|
||||
if err != nil {
|
||||
return "", fmt.Errorf("ntech: ServisRepo.SledeciBroj: %w", err)
|
||||
}
|
||||
|
||||
return fmt.Sprintf("SN-%d-%04d", godina, sledeci), nil
|
||||
}
|
||||
|
||||
// Lista vraća listu servisnih naloga sa imenom klijenta, opcionim filterima
|
||||
func (r *ServisRepo) Lista(ctx context.Context, pretraga, status string) ([]model.ServisniNalogSaKlijentom, error) {
|
||||
upit := `
|
||||
SELECT
|
||||
sn.id, sn.klijent_id, sn.broj_naloga, sn.uredjaj, sn.serijski_broj,
|
||||
sn.opis_kvara, sn.status, sn.cena_od, sn.cena_do, sn.cena_konacna,
|
||||
sn.avans, sn.napomena, sn.datum_prijema, sn.datum_zavrsetka,
|
||||
COALESCE(NULLIF(k.naziv_firme, ''), TRIM(COALESCE(k.ime, '') || ' ' || COALESCE(k.prezime, '')), '') AS klijent_naziv
|
||||
FROM servisni_nalozi sn
|
||||
LEFT JOIN klijenti k ON k.id = sn.klijent_id
|
||||
WHERE 1=1`
|
||||
|
||||
args := []any{}
|
||||
|
||||
if pretraga != "" {
|
||||
upit += " AND (sn.broj_naloga LIKE ? OR sn.uredjaj LIKE ?)"
|
||||
p := "%" + pretraga + "%"
|
||||
args = append(args, p, p)
|
||||
}
|
||||
|
||||
if status != "" {
|
||||
upit += " AND sn.status = ?"
|
||||
args = append(args, status)
|
||||
}
|
||||
|
||||
upit += " ORDER BY sn.datum_prijema DESC"
|
||||
|
||||
redovi, err := r.db.QueryContext(ctx, upit, args...)
|
||||
if err != nil {
|
||||
return nil, fmt.Errorf("ntech: ServisRepo.Lista: %w", err)
|
||||
}
|
||||
defer redovi.Close()
|
||||
|
||||
var rezultat []model.ServisniNalogSaKlijentom
|
||||
for redovi.Next() {
|
||||
var n model.ServisniNalogSaKlijentom
|
||||
err := scanNalog(redovi.Scan, &n.ServisniNalog, &n.KlijentNaziv)
|
||||
if err != nil {
|
||||
return nil, fmt.Errorf("ntech: ServisRepo.Lista: scan: %w", err)
|
||||
}
|
||||
rezultat = append(rezultat, n)
|
||||
}
|
||||
|
||||
return rezultat, nil
|
||||
}
|
||||
|
||||
// DohvatiID vraća jedan servisni nalog po ID-u
|
||||
func (r *ServisRepo) DohvatiID(ctx context.Context, id int64) (*model.ServisniNalog, error) {
|
||||
red := r.db.QueryRowContext(ctx, `
|
||||
SELECT
|
||||
id, klijent_id, broj_naloga, uredjaj, serijski_broj,
|
||||
opis_kvara, status, cena_od, cena_do, cena_konacna,
|
||||
avans, napomena, datum_prijema, datum_zavrsetka
|
||||
FROM servisni_nalozi WHERE id = ?`, id)
|
||||
|
||||
var n model.ServisniNalog
|
||||
err := scanNalog(red.Scan, &n, nil)
|
||||
if err != nil {
|
||||
return nil, fmt.Errorf("ntech: ServisRepo.DohvatiID: %w", err)
|
||||
}
|
||||
|
||||
return &n, nil
|
||||
}
|
||||
|
||||
// Kreiraj upisuje novi servisni nalog u bazu
|
||||
func (r *ServisRepo) Kreiraj(ctx context.Context, n *model.ServisniNalog) (int64, error) {
|
||||
rezultat, err := r.db.ExecContext(ctx, `
|
||||
INSERT INTO servisni_nalozi
|
||||
(klijent_id, broj_naloga, uredjaj, serijski_broj, opis_kvara,
|
||||
status, cena_od, cena_do, cena_konacna, avans, napomena, datum_zavrsetka)
|
||||
VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,
|
||||
nullInt64(n.KlijentID), n.BrojNaloga, n.Uredjaj, nullString(n.SerijskiBroj),
|
||||
n.OpisKvara, n.Status, nullFloat64(n.CenaOd), nullFloat64(n.CenaDo),
|
||||
nullFloat64(n.CenaKonacna), nullFloat64(n.Avans), nullString(n.Napomena),
|
||||
nullTime(n.DatumZavrsetka),
|
||||
)
|
||||
if err != nil {
|
||||
return 0, fmt.Errorf("ntech: ServisRepo.Kreiraj: %w", err)
|
||||
}
|
||||
|
||||
id, err := rezultat.LastInsertId()
|
||||
if err != nil {
|
||||
return 0, fmt.Errorf("ntech: ServisRepo.Kreiraj: last insert id: %w", err)
|
||||
}
|
||||
|
||||
return id, nil
|
||||
}
|
||||
|
||||
// Izmeni ažurira postojeći servisni nalog — broj_naloga i datum_prijema se ne menjaju
|
||||
func (r *ServisRepo) Izmeni(ctx context.Context, n *model.ServisniNalog) error {
|
||||
_, err := r.db.ExecContext(ctx, `
|
||||
UPDATE servisni_nalozi SET
|
||||
klijent_id = ?, uredjaj = ?, serijski_broj = ?, opis_kvara = ?,
|
||||
status = ?, cena_od = ?, cena_do = ?, cena_konacna = ?,
|
||||
avans = ?, napomena = ?, datum_zavrsetka = ?
|
||||
WHERE id = ?`,
|
||||
nullInt64(n.KlijentID), n.Uredjaj, nullString(n.SerijskiBroj), n.OpisKvara,
|
||||
n.Status, nullFloat64(n.CenaOd), nullFloat64(n.CenaDo), nullFloat64(n.CenaKonacna),
|
||||
nullFloat64(n.Avans), nullString(n.Napomena), nullTime(n.DatumZavrsetka),
|
||||
n.ID,
|
||||
)
|
||||
if err != nil {
|
||||
return fmt.Errorf("ntech: ServisRepo.Izmeni: %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)
|
||||
if err != nil {
|
||||
return fmt.Errorf("ntech: ServisRepo.Obrisi: %w", err)
|
||||
}
|
||||
|
||||
return nil
|
||||
}
|
||||
|
||||
// scanNalog čita redove iz upita u ServisniNalog struct —
|
||||
// klijentNaziv je opcioni pokazivač, nil kada se čita bez JOIN-a
|
||||
func scanNalog(scan func(...any) error, n *model.ServisniNalog, klijentNaziv *string) error {
|
||||
var klijentID sql.NullInt64
|
||||
var serijskiBroj, napomena sql.NullString
|
||||
var cenaOd, cenaDo, cenaKonacna, avans sql.NullFloat64
|
||||
var datumZavrsetka sql.NullTime
|
||||
|
||||
args := []any{
|
||||
&n.ID, &klijentID, &n.BrojNaloga, &n.Uredjaj, &serijskiBroj,
|
||||
&n.OpisKvara, &n.Status, &cenaOd, &cenaDo, &cenaKonacna,
|
||||
&avans, &napomena, &n.DatumPrijema, &datumZavrsetka,
|
||||
}
|
||||
|
||||
if klijentNaziv != nil {
|
||||
args = append(args, klijentNaziv)
|
||||
}
|
||||
|
||||
if err := scan(args...); err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
if klijentID.Valid {
|
||||
n.KlijentID = &klijentID.Int64
|
||||
}
|
||||
n.SerijskiBroj = serijskiBroj.String
|
||||
n.Napomena = napomena.String
|
||||
if cenaOd.Valid {
|
||||
n.CenaOd = &cenaOd.Float64
|
||||
}
|
||||
if cenaDo.Valid {
|
||||
n.CenaDo = &cenaDo.Float64
|
||||
}
|
||||
if cenaKonacna.Valid {
|
||||
n.CenaKonacna = &cenaKonacna.Float64
|
||||
}
|
||||
if avans.Valid {
|
||||
n.Avans = &avans.Float64
|
||||
}
|
||||
if datumZavrsetka.Valid {
|
||||
n.DatumZavrsetka = &datumZavrsetka.Time
|
||||
}
|
||||
|
||||
return nil
|
||||
}
|
||||
Reference in New Issue
Block a user