Merge branch 'backend/michael' into backend/max

This commit is contained in:
Maximilian Leopold 2019-04-15 16:25:45 +02:00
commit 81c2b19f09

View File

@ -163,6 +163,100 @@ public class Controller {
} }
} }
/**
* Checkt, ob die eingescannte Station die Nachfolgestation der zuletzt
* besuchten Stationen des aktuell durchgeführten Caches ist
*/
@CrossOrigin(origins = "http://localhost:8081") // only for dev purpose
@RequestMapping("/api/checkStation")
@ResponseBody
public ResponseEntity checkStation(@RequestParam String token,
@RequestParam String cacheID,
@RequestParam String stationID,
@RequestParam String durchgefuehrterCacheID) {
try {
Claims claims = Jwts.parser() //Parse JWT
.setSigningKey(key)
.parseClaimsJws(token).getBody();
User user = userRepository.findByUsername(claims.getSubject());
if (user == null) {
return ResponseEntity.status(404).body("User was not found");
}
Optional<Cache> cacheOptional = cacheRepository.findById(Integer.valueOf(cacheID));
Cache cache;
if (cacheOptional.isPresent()) {
cache = cacheOptional.get();
} else {
return ResponseEntity.status(404).body("Couldnt find Cache " + cacheID);
}
Optional<Cache> durchgefuehrterCacheIDOptional = cacheRepository.findById(Integer.valueOf(durchgefuehrterCacheID));
Cache durchgefuehrterCache;
if (durchgefuehrterCacheIDOptional.isPresent()) {
durchgefuehrterCache = cacheOptional.get();
} else {
return ResponseEntity.status(404).body("Couldnt find Cache " + durchgefuehrterCacheID);
}
Optional<Station> stationOptional = stationRepository.findById(Integer.valueOf(stationID));
Station station;
if (stationOptional.isPresent()) {
station = stationOptional.get();
} else {
return ResponseEntity.status(404).body("Couldnt find Station " + stationID);
}
if (cache != durchgefuehrterCache) {
return ResponseEntity.status(400).body("The scanned station isn´t the correct following station");
}
Bearbeitet bearbeitet;
if (bearbeitetRepository.findByUserAndCache(user, cache) != null) {
bearbeitet = bearbeitetRepository.findByUserAndCache(user, cache);
} else {
return ResponseEntity.status(400).body("The user has not started this cache yet");
}
Station aktuelleStation = bearbeitet.getAktuelleStation();
if (!cache.getStationen().contains(station)) {
return ResponseEntity.status(400).body("The scanned station isnt a part of the cache");
}
int i = 0;
for (Station station1 : cache.getStationen()) {
if (station1.equals(station)) {
break;
}
i++;
}
if (cache.getStationen().get(i - 1).equals(aktuelleStation)) {
bearbeitet.setAktuelleStation(station);
if (i == cache.getStationen().size() - 1) { // letze Station erreicht
Optional<CacheAccesDefinition> cacheAccesDefinitionOptional =
cacheAccesDefinitionRepository.findById(1); // abgeschlossen
if (cacheAccesDefinitionOptional.isPresent()) {
CacheAccesDefinition cacheAccesDefinition = cacheAccesDefinitionOptional.get();
bearbeitet.setCacheAccesDefinition(cacheAccesDefinition);
} else {
return ResponseEntity.status(404).body("There is no cacheAccesDefinition with the ID " + 1);
}
}
return ResponseEntity.status(200).body(new Gson().toJson(station));
} else {
return ResponseEntity.status(400).body("The scanned station isn´t the correct following station");
}
} catch (ExpiredJwtException e) {
return ResponseEntity.status(400).body("JWT Token expired");
} catch (Exception e) {
return ResponseEntity.status(400).body("JWT Token invalid");
}
}
@CrossOrigin(origins = "http://localhost:8081") // only for dev purpose @CrossOrigin(origins = "http://localhost:8081") // only for dev purpose
@RequestMapping("/api/createCache") @RequestMapping("/api/createCache")
@ResponseBody @ResponseBody