Changeset bde8b13 for src/main/java/mk/ukim/finki/busngo/service/impl/BiletServiceImpl.java

Timestamp:

01/09/24 01:26:08 (10 months ago)

Author:

ppaunovski <paunovskipavel@…>

Branches:

master

Children:

e272096

Parents:

b101b69

Message:

All 3 main use cases implemented.

1. Starting a commute
2. Writing a ticket
3. Starting an instance of a Bus Line

File:

• src/main/java/mk/ukim/finki/busngo/service/impl/BiletServiceImpl.java (modified) (5 diffs)

src/main/java/mk/ukim/finki/busngo/service/impl/BiletServiceImpl.java

@@ -3 +3 @@
 import mk.ukim.finki.busngo.model.entities.Bilet;
 import mk.ukim.finki.busngo.model.entities.Korisnik;
+import mk.ukim.finki.busngo.model.entities.Patnik;
 import mk.ukim.finki.busngo.model.entities.Tipbilet;
 import mk.ukim.finki.busngo.model.enums.BILET_STATUS;
+import mk.ukim.finki.busngo.model.exceptions.InvalidBiletIdException;
 import mk.ukim.finki.busngo.model.exceptions.InvalidTipBiletIdException;
 import mk.ukim.finki.busngo.repository.BiletRepository;
+import mk.ukim.finki.busngo.repository.KorisnikRepository;
 import mk.ukim.finki.busngo.repository.TipBIletRepository;
 import mk.ukim.finki.busngo.service.BiletService;
 import mk.ukim.finki.busngo.service.KorisnikService;
 import mk.ukim.finki.busngo.service.PatnikService;
+import org.springframework.security.crypto.password.PasswordEncoder;
 import org.springframework.stereotype.Service;
 
@@ -24 +28 @@
     private final TipBIletRepository tipBIletRepository;
     private final PatnikService patnikService;
+    private final PasswordEncoder passwordEncoder;
+    private final KorisnikRepository korisnikRepository;
 
-    public BiletServiceImpl(BiletRepository biletRepository, KorisnikService korisnikService, TipBIletRepository tipBIletRepository, PatnikService patnikService) {
+    public BiletServiceImpl(BiletRepository biletRepository, KorisnikService korisnikService, TipBIletRepository tipBIletRepository, PatnikService patnikService, PasswordEncoder passwordEncoder, KorisnikRepository korisnikRepository) {
         this.biletRepository = biletRepository;
         this.korisnikService = korisnikService;
         this.tipBIletRepository = tipBIletRepository;
         this.patnikService = patnikService;
+        this.passwordEncoder = passwordEncoder;
+        this.korisnikRepository = korisnikRepository;
     }
 
@@ -39 +47 @@
     @Override
     public List<Bilet> findAllByPatnikId(Long id) {
-        Korisnik korisnik = korisnikService.findById(id);
-        return new ArrayList<>();
+        Patnik patnik = patnikService.findById(id);
+        return patnik.getBiletsByKId();
     }
 
@@ -52 +60 @@
     public Bilet buy(Long tipbilet, LocalDateTime now, BILET_STATUS biletStatus, String name) {
         Tipbilet tipbilet1 = tipBIletRepository.findById(tipbilet).orElseThrow(InvalidTipBiletIdException::new);
-        Korisnik korisnik = korisnikService.loadUserByEmail(name);
+        Patnik korisnik = patnikService.loadUserByEmail(name);
         Bilet bilet = new Bilet();
         bilet.setBStatus(biletStatus);
@@ -60 +68 @@
         return biletRepository.save(bilet);
     }
+
+    @Override
+    public List<Bilet> findAllByPatnikEmail(String email) {
+        Patnik patnik = patnikService.loadUserByEmail(email);
+        return patnik.getBiletsByKId();
+    }
+
+    @Override
+    public Bilet findBybIdAndPatnikEmail(Long bId, String email) {
+        Patnik patnik = patnikService.loadUserByEmail(email);
+        return biletRepository.findByBIdAndAndKorisnikByPatnikKId(bId, patnik).orElseThrow(InvalidBiletIdException::new);
+    }
+
+    @Override
+    public Bilet activate(Long bId) {
+        Bilet bilet = this.findById(bId);
+        bilet.setBStatus(BILET_STATUS.ACTIVE);
+        return biletRepository.save(bilet);
+    }
+
+    @Override
+    public Bilet findById(Long bId) {
+        return biletRepository.findById(bId).orElseThrow(RuntimeException::new);
+    }
+
+    @Override
+    public Bilet finish(Long bId) {
+        Bilet bilet = this.findById(bId);
+        bilet.setBStatus(BILET_STATUS.EXPIRED);
+        return biletRepository.save(bilet);
+    }
+
+    @Override
+    public boolean checkExpiration(Long bId) {
+        Bilet bilet = this.findById(bId);
+        LocalDateTime timeBought = bilet.getBDatumNaKupuvanje().toLocalDateTime();
+
+        if(timeBought.plusSeconds(bilet.getTipbiletByTbId().getTbTrajnost()).isBefore(LocalDateTime.now())){
+            bilet.setBStatus(BILET_STATUS.EXPIRED);
+            biletRepository.save(bilet);
+            return true;
+        }
+
+        return false;
+    }
+
+//    @Override
+//    public void encode(){
+//        List<Korisnik> all = korisnikRepository.findAll();
+//        all.forEach(p -> p.setKLozinka(passwordEncoder.encode(p.getKLozinka())));
+//        korisnikRepository.saveAll(all);
+//        System.out.println("DONE!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!");
+//    }
+
+
 }