package de.gedoplan.seminar.sbt.di.exercise.service;
|
|
import de.gedoplan.seminar.sbt.di.exercise.domain.Cocktail;
|
import de.gedoplan.seminar.sbt.di.exercise.domain.CocktailOrder;
|
import de.gedoplan.seminar.sbt.di.exercise.repository.CocktailOrderRepository;
|
import de.gedoplan.seminar.sbt.di.exercise.repository.CocktailRepository;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.context.ApplicationEventPublisher;
|
import org.springframework.stereotype.Component;
|
import org.springframework.transaction.annotation.Transactional;
|
|
@Component
|
public class CocktailOrderService {
|
|
@Autowired
|
CocktailOrderRepository cocktailOrderRepository;
|
|
@Autowired
|
CocktailRepository cocktailRepository;
|
|
@Autowired
|
private ApplicationEventPublisher eventPublisher;
|
|
public Integer createNewOrder() {
|
CocktailOrder cocktailOrder = new CocktailOrder();
|
this.cocktailOrderRepository.save(cocktailOrder);
|
this.cocktailOrderRepository.flush();
|
return cocktailOrder.getId();
|
}
|
|
@Transactional
|
public void addCocktail(Integer id, String cocktailId) {
|
CocktailOrder cocktailOrder = this.cocktailOrderRepository.findById(id)
|
.orElseThrow(() -> new IllegalArgumentException());
|
Cocktail cocktail = cocktailRepository.findById(cocktailId)
|
.orElseThrow(() -> new IllegalArgumentException());
|
|
eventPublisher.publishEvent(cocktail);
|
|
cocktailOrder.addCocktail(cocktailId);
|
}
|
|
@Transactional
|
public void placeOrder(Integer id) {
|
CocktailOrder cocktailOrder = this.cocktailOrderRepository.findById(id)
|
.orElseThrow(() -> new IllegalArgumentException());
|
|
if (!cocktailOrder.isPlaced()) {
|
cocktailOrder.place();
|
eventPublisher.publishEvent(cocktailOrder);
|
}
|
}
|
|
public void cancelOrder(Integer id) {
|
this.cocktailOrderRepository.deleteById(id);
|
}
|
|
}
|
