Changeset d14176d for src/main/java/project/fmo/app/projcetfmo/Service/impl/KorisnikServiceImpl.java

Timestamp:

07/07/23 12:14:58 (12 months ago)

Author:

HristijanMitic00 <hristijan.mitic.01@…>

Branches:

main

Parents:

1dd9226

Message:

First commit

File:

• src/main/java/project/fmo/app/projcetfmo/Service/impl/KorisnikServiceImpl.java (modified) (1 diff)

src/main/java/project/fmo/app/projcetfmo/Service/impl/KorisnikServiceImpl.java

@@ -1 @@
-package project.fmo.app.projcetfmo.Service.impl;public class KorisnikServiceImpl {
+package project.fmo.app.projcetfmo.Service.impl;
+
+import org.springframework.security.core.authority.SimpleGrantedAuthority;
+import org.springframework.security.core.userdetails.User;
+import org.springframework.security.core.userdetails.UserDetails;
+import org.springframework.security.core.userdetails.UsernameNotFoundException;
+import org.springframework.security.crypto.password.PasswordEncoder;
+import org.springframework.stereotype.Service;
+import project.fmo.app.projcetfmo.Model.*;
+import project.fmo.app.projcetfmo.Repository.*;
+import project.fmo.app.projcetfmo.Service.KorisnikService;
+
+import java.sql.Timestamp;
+import java.time.LocalDateTime;
+import java.util.List;
+import java.util.Objects;
+import java.util.stream.Collectors;
+import java.util.stream.Stream;
+
+@Service
+public class KorisnikServiceImpl implements KorisnikService {
+
+    private final PasswordEncoder passwordEncoder;
+    private final AdminRepository adminRepository;
+    private final DostavuvacRepository dostavuvacRepository;
+
+    private final TelefnoskiBrojRepository telefnoskiBrojRepository;
+    private final KupuvacRepository kupuvacRepository;
+    private final KorisnikRepository korisnikRepository;
+
+    public KorisnikServiceImpl(PasswordEncoder passwordEncoder, AdminRepository adminRepository, DostavuvacRepository dostavuvacRepository, TelefnoskiBrojRepository telefnoskiBrojRepository, KupuvacRepository kupuvacRepository, KorisnikRepository korisnikRepository) {
+        this.passwordEncoder = passwordEncoder;
+        this.adminRepository = adminRepository;
+        this.dostavuvacRepository = dostavuvacRepository;
+        this.telefnoskiBrojRepository = telefnoskiBrojRepository;
+        this.kupuvacRepository = kupuvacRepository;
+        this.korisnikRepository = korisnikRepository;
+    }
+
+    @Override
+    public UserDetails loadUserByUsername(String username) throws UsernameNotFoundException {
+        Korisnik korisnik = korisnikRepository.findByImePrezime(username);
+        for (AdminKorisnik a: adminRepository.findAll()) {
+            if (a.getIdKorisnik() == korisnik.getIdKorisnik()) {
+                return new User(korisnik.getImePrezime(), korisnik.getPasswordKorisnik(), Stream.of(new SimpleGrantedAuthority("ROLE_ADMIN")).collect(Collectors.toList()));
+            }
+        }
+        for (Dostavuvac a: dostavuvacRepository.findAll()) {
+            if (a.getIdKorisnik() == korisnik.getIdKorisnik()) {
+                return new User(korisnik.getImePrezime(), korisnik.getPasswordKorisnik(), Stream.of(new SimpleGrantedAuthority("ROLE_DELIVER")).collect(Collectors.toList()));
+            }
+        }
+        for (Kupuvac a: kupuvacRepository.findAll()){
+            if (a.getIdKorisnik() == korisnik.getIdKorisnik()){
+                return new User(korisnik.getImePrezime(),korisnik.getPasswordKorisnik(), Stream.of(new SimpleGrantedAuthority("ROLE_USER")).collect(Collectors.toList()) );
+            }
+        }
+        return null;
+    }
+
+    @Override
+    public Korisnik findbyImePrezime(String ime) {
+        return korisnikRepository.findByImePrezime(ime);
+    }
+
+    @Override
+    public Korisnik findById(Integer id) {
+        return korisnikRepository.findById(id).orElse(null);
+    }
+
+    @Override
+    public Korisnik register(String username, String password, String repeatPassword, String mail, String number) {
+        if (username==null || username.isEmpty()  || password==null || password.isEmpty())
+            throw new RuntimeException();
+        if (!password.equals(repeatPassword))
+            throw new RuntimeException();
+
+        Korisnik korisnik = new Korisnik(username,password, Timestamp.valueOf(LocalDateTime.now()));
+        korisnikRepository.save(korisnik);
+        Kupuvac k = new Kupuvac(korisnik.getIdKorisnik(), mail);
+        kupuvacRepository.save(k);
+        Telefonskibroj t = new Telefonskibroj(new TelefonskibrojPK(korisnik.getIdKorisnik(),number));
+        telefnoskiBrojRepository.save(t);
+        return korisnik;
+
+    }
+
+    @Override
+    public List<Object> statistics2() {
+        return korisnikRepository.statistics2();
+    }
 }