package src;

import beans.Korisnik;
import java.io.Serializable;
import javax.enterprise.context.SessionScoped;
import javax.inject.Named;
import org.hibernate.Query;
import org.hibernate.Session;
import org.hibernate.Transaction;
import tools.HibernateUtil;

/*
 * To change this license header, choose License Headers in Project Properties.
 * To change this template file, choose Tools | Templates
 * and open the template in the editor.
 */

/**
 *
 * @author Nikola
 */
@Named(value = "controllernovi")
@SessionScoped
public class Controller implements Serializable {

    //private String ime;
    private Session session = null;
    //private List<Korisnik> korisnici = new ArrayList<>();
    private Korisnik korisnik;
    private String username;
    private String password;
    //za registraciju
    private String ime;
    private String prezime;
    private String korIme;
    private String lozinka;
    private String ponLozinka;
    private String telefon;
    private String eposta;
    //za promenu lozinke
    private String korImepromena;
    private String lozinkastara;
    private String novalozinka;
    private String ponnovalozinka;

    public Controller() {
        this.session = HibernateUtil.getSessionFactory().getCurrentSession();
    }

    public String login() {
        if (!username.isEmpty() && !password.isEmpty()) {
            Transaction tx = session.beginTransaction();
            Query q = session.createQuery("from Korisnik where KorisnickoIme='" + username + "'");
            if (q.list().iterator().hasNext()) {
                q = session.createQuery("from Korisnik where KorisnickoIme='" + username + "' and Lozinka='" + password + "'");
                if (q.list().iterator().hasNext()) {
                    korisnik = (Korisnik) q.list().iterator().next();
                    //ovde dodati admin stvari
                    if (korisnik.getIsAdmin() == 1) {
                        return "admin";
                    } else {
                        return "korisnik";
                    }
                } else {
                    return "index";
                }
            }
        }
        return "index";
    }

    public String register() {
        Transaction tx = session.beginTransaction();
        Korisnik korisnik = new Korisnik(ime, prezime, korIme, lozinka, telefon, eposta, 0);
        session.save(korisnik);
        session.getTransaction().commit();
        session.close();
        return "index";
    }

    public String promeniLozinku() {
        if (!korImepromena.isEmpty() && !lozinkastara.isEmpty() && !novalozinka.isEmpty()) {
            Transaction tx = session.beginTransaction();
            Query q = session.createQuery("from Korisnik where KorisnickoIme='" + korImepromena + "'");
            if (q.list().iterator().hasNext()) {
                q = session.createQuery("from Korisnik where KorisnickoIme='" + korImepromena + "' and Lozinka='" + lozinkastara + "'");
                if (q.list().iterator().hasNext()) {
                    Korisnik korisnik = (Korisnik) q.list().iterator().next();
                    //ovde dodati admin stvari
                    korisnik.setLozinka(novalozinka);
                    session.saveOrUpdate(korisnik);
                    session.getTransaction().commit();
                }
            }
        }
        return "index";
    }

    //    public Korisnik test() {
    //        org.hibernate.Transaction tx = session.beginTransaction();;
    //        try {
    //            Query q = session.createQuery("from Korisnik");
    //            korisnici.clear();
    //            korisnici = (List<Korisnik>) q.list();
    //            dodaj();
    //            return korisnici.iterator().next();
    //        } catch (Exception e) {
    //            e.printStackTrace();
    //        }
    //        return null;
    //    }
    //
    //    public void dodaj() {
    //        org.hibernate.Transaction tx = session.beginTransaction();;
    //        try {
    //            Korisnik korisnik = new Korisnik("Milos", "Milosevic", "m12ilos", "123123", "16541644163", "admin@djerga.com");
    //            session.save(korisnik);
    //            session.getTransaction().commit();
    //        } catch (Exception e) {
    //            e.printStackTrace();
    //        }
    //    }
    public Session getSession() {
        return session;
    }

    public void setSession(Session session) {
        this.session = session;
    }

    public String getUsername() {
        return username;
    }

    public void setUsername(String username) {
        this.username = username;
    }

    public String getPassword() {
        return password;
    }

    public void setPassword(String password) {
        this.password = password;
    }

    public Korisnik getKorisnik() {
        return korisnik;
    }

    public void setKorisnik(Korisnik korisnik) {
        this.korisnik = korisnik;
    }

    public String getIme() {
        return ime;
    }

    public void setIme(String ime) {
        this.ime = ime;
    }

    public String getPrezime() {
        return prezime;
    }

    public void setPrezime(String prezime) {
        this.prezime = prezime;
    }

    public String getKorIme() {
        return korIme;
    }

    public void setKorIme(String korIme) {
        this.korIme = korIme;
    }

    public String getLozinka() {
        return lozinka;
    }

    public void setLozinka(String lozinka) {
        this.lozinka = lozinka;
    }

    public String getPonLozinka() {
        return ponLozinka;
    }

    public void setPonLozinka(String ponLozinka) {
        this.ponLozinka = ponLozinka;
    }

    public String getTelefon() {
        return telefon;
    }

    public void setTelefon(String telefon) {
        this.telefon = telefon;
    }

    public String getEposta() {
        return eposta;
    }

    public void setEposta(String eposta) {
        this.eposta = eposta;
    }

    public String getKorImepromena() {
        return korImepromena;
    }

    public void setKorImepromena(String korImepromena) {
        this.korImepromena = korImepromena;
    }

    public String getLozinkastara() {
        return lozinkastara;
    }

    public void setLozinkastara(String lozinkastara) {
        this.lozinkastara = lozinkastara;
    }

    public String getNovalozinka() {
        return novalozinka;
    }

    public void setNovalozinka(String novalozinka) {
        this.novalozinka = novalozinka;
    }

    public String getPonnovalozinka() {
        return ponnovalozinka;
    }

    public void setPonnovalozinka(String ponnovalozinka) {
        this.ponnovalozinka = ponnovalozinka;
    }

    //test
    //private Part image;

//    public String uploadImage() throws IOException {
//        //InputStream input = image.getInputStream();
//        //Files.copy(input, new File("C:\\Users\\Nikola\\Desktop\\projekatPIA file.jpg").toPath());
//        String appPath = "/resources";
//        // constructs path of the directory to save uploaded file
//        String savePath = appPath + File.separator + "uploadFiles";
//
//        // creates the save directory if it does not exists
//        File fileSaveDir = new File(savePath);
//        if (!fileSaveDir.exists()) {
//            fileSaveDir.mkdir();
//        }
//
//        String fileName = "fajl.jpg";
//        // refines the fileName in case it is an absolute path
//        fileName = new File(fileName).getName();
//        image.write(savePath + File.separator + fileName);
//        return "korisnik";
//    }
//    private String destination = "D:\\tmp\\";
//
//    public void upload(FileUploadEvent event) {
//        FacesMessage msg = new FacesMessage("Success! ", event.getFile().getFileName() + " is uploaded.");
//        FacesContext.getCurrentInstance().addMessage(null, msg);
//        // Do what you want with the file
//        try {
//            uploadImage(event.getFile().getFileName(), event.getFile().getInputstream());
//        } catch (IOException e) {
//            e.printStackTrace();
//        }
//
//    }
//
//    public void uploadImage(String fileName, InputStream in) throws IOException {
//        try {
//            // write the inputStream to a FileOutputStream
//            OutputStream out = new FileOutputStream(new File(destination + fileName));
//
//            int read = 0;
//            byte[] bytes = new byte[1024];
//
//            while ((read = in.read(bytes)) != -1) {
//                out.write(bytes, 0, read);
//            }
//
//            in.close();
//            out.flush();
//            out.close();
//
//            System.out.println("New file created!");
//        } catch (IOException e) {
//            System.out.println(e.getMessage());
//        }
//    }

//    public Part getImage() {
//        return image;
//    }
//
//    public void setImage(Part image) {
//        this.image = image;
//    }
}