source: sources/app/src/main/java/parkup/services/ParkingSessionService.java@ b519b38

Last change on this file since b519b38 was b519b38, checked in by andrejTavchioski <andrej.tavchioski@…>, 2 years ago

fix
  • Property mode set to 100644
File size: 9.9 KB
Line 
1package parkup.services;
2
3import org.springframework.beans.factory.annotation.Autowired;
4import org.springframework.security.core.Authentication;
5import org.springframework.stereotype.Service;
6import parkup.ParkUpApplication;
7import parkup.data.Plate;
8import parkup.data.enumarations.SessionStatus;
9import parkup.entities.*;
10import parkup.repositories.*;
11
12import javax.transaction.Transactional;
13import java.time.Duration;
14import java.time.LocalDateTime;
15import java.util.List;
16import java.util.Optional;
17import java.util.stream.Collectors;
18
19@Service
20public class ParkingSessionService {
21 private final ParkingSessionRepository parkingSessionRepository;
22 private final ParkingZoneRepository parkingZoneRepository;
23 private final ParkingSpaceRepository parkingSpaceRepository;
24 private final RegisteredUserRepository registeredUserRepository;
25 private final PlateRepository plateRepository;
26 private final GuestRepository guestRepository;
27
28 @Autowired
29 public ParkingSessionService(ParkingSessionRepository parkingSessionRepository, ParkingZoneRepository parkingZoneRepository, ParkingSpaceRepository parkingSpaceRepository, RegisteredUserRepository registeredUserRepository, PlateRepository plateRepository, GuestRepository guestRepository) {
30 this.parkingSessionRepository = parkingSessionRepository;
31 this.parkingZoneRepository = parkingZoneRepository;
32 this.parkingSpaceRepository = parkingSpaceRepository;
33 this.registeredUserRepository = registeredUserRepository;
34 this.plateRepository = plateRepository;
35 this.guestRepository = guestRepository;
36 }
37
38 //TODO add getMethod for paid sessions or all sessions
39
40 public List<ParkingSession> getAllParkingSessions() {
41 //Get all sessions that arent paid
42 return parkingSessionRepository.findAll().stream()
43 .filter(s->!s.getStatus().equals(SessionStatus.ENDED_PAID))
44 .collect(Collectors.toList());
45 }
46
47 public List<ParkingSession> getAllParkingSessionsFromZone(Integer pzId) {
48 //Get all sessions that arent paid
49
50 return parkingSessionRepository.findAll().stream()
51 .filter(s->!s.getStatus().equals(SessionStatus.ENDED_PAID) && s.getParkingZone()!=null && s.getParkingZone().getId()==pzId)
52 .collect(Collectors.toList());
53 }
54
55 public ParkingSession findById(int parkingSessionId) {
56 Optional<ParkingSession> parkingSessionOpt = Optional.ofNullable(parkingSessionRepository.findByPssId(parkingSessionId));
57 return parkingSessionOpt.orElse(null);
58 }
59
60 @Transactional
61 public Optional<ParkingSession> deleteParkingSession(int parkingSessionId) {
62 Optional<ParkingSession> parkingSessionOpt = Optional.ofNullable(parkingSessionRepository.findByPssId(parkingSessionId));
63 if (parkingSessionOpt.isPresent()) {
64 if(parkingSessionOpt.get().getStatus()!=SessionStatus.STARTED_UNVERIFIED)
65 parkingSessionOpt.get().getParkingSpace().setTaken(false);
66 parkingSessionOpt.get().setPlate(null);
67 registeredUserRepository.findAll().stream().filter(u->u.getSession().equals(parkingSessionOpt.get())).forEach(u->u.setSession(null));
68 guestRepository.findAll().stream().filter(u->u.getSession().equals(parkingSessionOpt.get())).forEach(u->u.setSession(null));
69 parkingSessionRepository.deleteByPssId(parkingSessionId);
70 return parkingSessionOpt;
71 } else {
72 throw new IllegalStateException("ParkingSpace doesn't exist, therefore can't be deleted");
73 }
74 }
75
76 @Transactional
77 public Optional<ParkingSession> startParkingSession(String tablica, String parkingZoneName) {
78 ParkingZone parkingZone = parkingZoneRepository.findByPzName(parkingZoneName);
79 Authentication token = ParkUpApplication.getToken();
80 Plate plate = plateRepository.findByPlate(tablica);
81 ParkingSession sessionToAdd = new ParkingSession(plate);
82 sessionToAdd.setParkingZone(parkingZone);
83 parkingSessionRepository.save(sessionToAdd);
84 String role =token.getAuthorities().stream().findFirst().get().getAuthority();
85 String email =token.getName();
86 if(role.equals("ROLE_REG_USER")){
87 RegisteredUser user = registeredUserRepository.findRegisteredUserByEmail(email).get();
88 user.setSession(sessionToAdd);
89 }
90 else{
91 Guest user = guestRepository.findGuestByEmail(email).get();
92 user.setSession(sessionToAdd);
93 }
94 return Optional.of(sessionToAdd);
95
96 }
97 public int calculatePayment(){
98 ParkingSession session = getParkingSession();
99 if(session==null){
100 throw new IllegalStateException("No such session exists");
101 }
102 else if(session.getStatus()!= SessionStatus.ENDED_UNPAID){
103 throw new IllegalStateException("Cannot calculate payment on a session that is not ended");
104 }
105 int price = session.getParkingZone().getPrice();
106 return (int) (Math.ceil(Duration.between(session.getTimeStart(),session.getTimeEnd()).toMinutes()/60.0)*price);
107 }
108 @Transactional
109 public ParkingSession verifyParkingSession(int id,String parkingSpaceName){
110 ParkingSession parkingSession = parkingSessionRepository.findByPssId(id);
111 if(parkingSession==null){
112 throw new IllegalStateException("No such session exists");
113 }
114 else if(parkingSession.getStatus()==SessionStatus.STARTED_VERIFIED){
115 throw new IllegalStateException("The session you are trying to verify has already been verified");
116 }
117 ParkingZone parkingZone = parkingSession.getParkingZone();
118// else if(parkingSession.getStatus()!=SessionStatus.STARTED_)
119 if(!parkingZone.getParkingSpaces().contains(parkingSpaceRepository.findByPsName(parkingSpaceName))){
120 throw new IllegalStateException("Ivalid parking space inserted. Type in a new parking space or let the admin know that they should add the parking space to this zone");
121 }
122 if(parkingSpaceRepository.findByPsName(parkingSpaceName).isTaken()){
123 throw new IllegalStateException("Ivalid parking space inserted. Type in a new parking space, this space is already in a session");
124 }
125 parkingSession.setStatus(SessionStatus.STARTED_VERIFIED);
126 ParkingSpace parkingSpace = parkingZoneRepository.findByPzId(parkingZone.getId()).getParkingSpaces().stream().filter(ps->ps.getPsName().equals(parkingSpaceName)).findFirst().get();
127 parkingSpace.setTaken(true);
128 parkingSession.setParkingSpace(parkingSpace);
129 return parkingSession;
130 }
131 @Transactional
132 public ParkingSession endParkingSession(){
133 ParkingSession parkingSession=getParkingSession();
134 if(parkingSession==null){
135 throw new IllegalStateException("No such session exists");
136 }
137 else if(parkingSession.getStatus()==SessionStatus.ENDED_UNPAID){
138 throw new IllegalStateException("The session you are trying to end has already been ended");
139 }
140 parkingSession.setStatus(SessionStatus.ENDED_UNPAID);
141 parkingSession.setTimeEnd(LocalDateTime.now());
142 return parkingSession;
143 }
144 @Transactional
145 public boolean payParkingSession(String date){
146 if(!date.isEmpty()){
147 String expMonthString=date.split("/")[0];
148 String expYearString=date.split("/")[1];
149 if(expMonthString.startsWith("0"))
150 expMonthString=expMonthString.substring(1);
151 if(expYearString.startsWith("0"))
152 expYearString=expYearString.substring(1);
153 int expMonth=Integer.parseInt(expMonthString);
154 int expYear=Integer.parseInt(expYearString);
155 int month = LocalDateTime.now().getMonth().getValue();
156 int year = LocalDateTime.now().getYear()%100;
157 if(year>expYear){
158 throw new IllegalStateException("Your card has expired or the date that you have entered is incorrect");
159 }
160 else if(year==expYear){
161 if(month>=expMonth)
162 throw new IllegalStateException("Your card has expired or the date that you have entered is incorrect");
163 }
164 }
165 ParkingSession parkingSession=getParkingSession();
166 if(parkingSession==null){
167 throw new IllegalStateException("No such session exists");
168 }
169 else if(parkingSession.getStatus()==SessionStatus.ENDED_PAID){
170 throw new IllegalStateException("The session has already been paid for");
171 }
172 parkingSession.setStatus(SessionStatus.ENDED_PAID);
173 if(parkingSession.getParkingSpace()!=null)
174 parkingSession.getParkingSpace().setTaken(false);
175 parkingSession.setPlate(null);
176 registeredUserRepository.findAll().stream().filter(rp->rp.getSession().getStatus().equals(SessionStatus.ENDED_PAID)).forEach(rp->rp.setSession(null));
177 guestRepository.findAll().stream().filter(g->g.getSession().getStatus().equals(SessionStatus.ENDED_PAID)).forEach(g->g.setSession(null));
178 guestRepository.deleteAll(guestRepository.findAll().stream().filter(g-> g.getSession() == null).collect(Collectors.toList()));
179 parkingSessionRepository.deleteByPssId(parkingSession.getPssId());
180 return true;
181 }
182
183 public SessionStatus getStatusOfParkirac(){
184 ParkingSession session=getParkingSession();
185 return session == null ? null : session.getStatus();
186 }
187
188 public ParkingSession getParkingSession() {
189 Authentication token = ParkUpApplication.getToken();
190 String role =token.getAuthorities().stream().findFirst().get().getAuthority();
191 String email =token.getName();
192 ParkingSession parkingSession;
193 if(role.equals("ROLE_REG_USER")){
194 RegisteredUser user = registeredUserRepository.findRegisteredUserByEmail(email).get();
195 parkingSession=user.getSession();
196 }
197 else{
198 Guest user = guestRepository.findGuestByEmail(email).get();
199 parkingSession=user.getSession();
200 }
201 return parkingSession;
202 }
203}
Note: See TracBrowser for help on using the repository browser.