[bde8b13] | 1 | package mk.ukim.finki.busngo.service.impl;
|
---|
| 2 |
|
---|
| 3 | import mk.ukim.finki.busngo.model.entities.*;
|
---|
| 4 | import mk.ukim.finki.busngo.model.exceptions.InvalidInstancaNaLinijaIdException;
|
---|
| 5 | import mk.ukim.finki.busngo.repository.InstancaNaLinijaRepository;
|
---|
| 6 | import mk.ukim.finki.busngo.service.*;
|
---|
| 7 | import org.springframework.stereotype.Service;
|
---|
| 8 |
|
---|
| 9 | import java.sql.Timestamp;
|
---|
| 10 | import java.time.LocalDateTime;
|
---|
| 11 | import java.util.List;
|
---|
| 12 |
|
---|
| 13 | @Service
|
---|
| 14 | public class InstancaNaLinijaServiceImpl implements InstancaNaLinijaService{
|
---|
| 15 | private final InstancaNaLinijaRepository instancaNaLinijaRepository;
|
---|
| 16 | private final VozacService vozacService;
|
---|
| 17 | private final AvtobusService avtobusService;
|
---|
| 18 | private final LinijaService linijaService;
|
---|
| 19 | private final PostojkaNaLinijaService postojkaNaLinijaService;
|
---|
| 20 |
|
---|
| 21 | public InstancaNaLinijaServiceImpl(InstancaNaLinijaRepository instancaNaLinijaRepository, VozacService vozacService, AvtobusService avtobusService, LinijaService linijaService, PostojkaNaLinijaService postojkaNaLinijaService) {
|
---|
| 22 | this.instancaNaLinijaRepository = instancaNaLinijaRepository;
|
---|
| 23 | this.vozacService = vozacService;
|
---|
| 24 | this.avtobusService = avtobusService;
|
---|
| 25 | this.linijaService = linijaService;
|
---|
| 26 | this.postojkaNaLinijaService = postojkaNaLinijaService;
|
---|
| 27 | }
|
---|
| 28 |
|
---|
| 29 | @Override
|
---|
| 30 | public List<Instancanalinija> findAll() {
|
---|
| 31 | return instancaNaLinijaRepository.findAll();
|
---|
| 32 | }
|
---|
| 33 |
|
---|
| 34 | @Override
|
---|
| 35 | public Instancanalinija findById(Long inlId) {
|
---|
| 36 | return instancaNaLinijaRepository.findById(inlId).orElseThrow(InvalidInstancaNaLinijaIdException::new);
|
---|
| 37 | }
|
---|
| 38 |
|
---|
| 39 | @Override
|
---|
| 40 | public Instancanalinija start(Long liId, String a_registracija, String email) {
|
---|
| 41 | Linija linija = linijaService.findById(liId);
|
---|
| 42 | Avtobus avtobus = avtobusService.findById(a_registracija);
|
---|
| 43 | Vozac vozac = vozacService.findByEmail(email);
|
---|
| 44 | Instancanalinija instancanalinija = new Instancanalinija();
|
---|
| 45 | instancanalinija.setLinijaByLiId(linija);
|
---|
| 46 | instancanalinija.setAvtobusByARegistracija(avtobus);
|
---|
| 47 | instancanalinija.setKorisnikByVozacKId(vozac);
|
---|
| 48 | instancanalinija.setInlDatumStart(Timestamp.valueOf(LocalDateTime.now()));
|
---|
| 49 |
|
---|
| 50 | return instancaNaLinijaRepository.save(instancanalinija);
|
---|
| 51 | }
|
---|
| 52 |
|
---|
| 53 | @Override
|
---|
| 54 | public Instancanalinija end(Long inlId) {
|
---|
| 55 | Instancanalinija instancanalinija = this.findById(inlId);
|
---|
| 56 | instancanalinija.setInlDatumEnd(Timestamp.valueOf(LocalDateTime.now()));
|
---|
| 57 | return instancaNaLinijaRepository.save(instancanalinija);
|
---|
| 58 | }
|
---|
| 59 |
|
---|
| 60 | @Override
|
---|
| 61 | public List<Instancanalinija> findAllActive() {
|
---|
| 62 | return instancaNaLinijaRepository.findAllByInlDatumEndIsNull();
|
---|
| 63 | }
|
---|
| 64 |
|
---|
| 65 | @Override
|
---|
| 66 | public List<Instancanalinija> findByPnlId(Long pnlId) {
|
---|
| 67 | Postojkanalinija postojkanalinija = postojkaNaLinijaService.findById(pnlId);
|
---|
| 68 | Linija linijaByLiId = postojkanalinija.getLinijaByLiId();
|
---|
| 69 | return instancaNaLinijaRepository.findAllByLinijaByLiIdAndInlDatumEndIsNull(linijaByLiId);
|
---|
| 70 | }
|
---|
| 71 | }
|
---|