Skip to content

Commit 41f76db

Browse files
committed
Removed loadForRouting() from domain service layer, since it only delegated to repository. Remote facade in application layer now calls repository directly.
Also, there's no "load for routing" in the ubiquitous language as it's a technical aspect.
1 parent b3350cd commit 41f76db

File tree

3 files changed

+5
-27
lines changed

3 files changed

+5
-27
lines changed

dddsample/src/main/java/se/citerus/dddsample/application/remoting/BookingServiceFacadeImpl.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -47,14 +47,16 @@ public String registerNewCargo(String origin, String destination) {
4747
}
4848

4949
public CargoRoutingDTO loadCargoForRouting(String trackingId) {
50-
final Cargo cargo = bookingService.loadCargoForRouting(new TrackingId(trackingId));
50+
// TODO lock
51+
final Cargo cargo = cargoRepository.find(new TrackingId(trackingId));
5152
final CargoRoutingDTOAssembler assembler = new CargoRoutingDTOAssembler();
5253
return assembler.toDTO(cargo);
5354
}
5455

5556
public void assignCargoToRoute(String trackingId, ItineraryCandidateDTO itineraryCandidateDTO) {
5657
final Itinerary itinerary = new ItineraryCandidateDTOAssembler().fromDTO(itineraryCandidateDTO, carrierMovementRepository, locationRepository);
5758
bookingService.assignCargoToRoute(new TrackingId(trackingId), itinerary);
59+
// TODO unlock
5860
}
5961

6062
public List<CargoRoutingDTO> listAllCargos() {

dddsample/src/main/java/se/citerus/dddsample/domain/service/BookingService.java

Lines changed: 0 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,5 @@
11
package se.citerus.dddsample.domain.service;
22

3-
import se.citerus.dddsample.domain.model.cargo.Cargo;
43
import se.citerus.dddsample.domain.model.cargo.Itinerary;
54
import se.citerus.dddsample.domain.model.cargo.TrackingId;
65
import se.citerus.dddsample.domain.model.location.UnLocode;
@@ -21,14 +20,6 @@ public interface BookingService {
2120
*/
2221
TrackingId bookNewCargo(UnLocode origin, UnLocode destination);
2322

24-
/**
25-
* Loads a cargo for routing operations.
26-
*
27-
* @param trackingId cargo tracking id
28-
* @return A cargo with it's itinerary, or null if none found.
29-
*/
30-
Cargo loadCargoForRouting(TrackingId trackingId);
31-
3223
/**
3324
* Requests a list of itineraries describing possible routes for this cargo.
3425
*

dddsample/src/main/java/se/citerus/dddsample/domain/service/impl/BookingServiceImpl.java

Lines changed: 2 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -19,8 +19,6 @@ public final class BookingServiceImpl implements BookingService {
1919
private CargoRepository cargoRepository;
2020
private LocationRepository locationRepository;
2121
private RoutingService routingService;
22-
// TODO
23-
//private LockManager lockManager;
2422

2523
private final Log logger = LogFactory.getLog(getClass());
2624

@@ -41,20 +39,10 @@ public TrackingId bookNewCargo(final UnLocode originUnLocode, final UnLocode des
4139
}
4240

4341
@Transactional(readOnly = true)
44-
public Cargo loadCargoForRouting(final TrackingId trackingId) {
42+
public List<Itinerary> requestPossibleRoutesForCargo(TrackingId trackingId) {
4543
Validate.notNull(trackingId);
46-
47-
// TODO
48-
//CargoLock cargoLock = lockManager.lockCargo(trackingId);
49-
44+
5045
final Cargo cargo = cargoRepository.find(trackingId);
51-
52-
return cargo;
53-
}
54-
55-
@Transactional(readOnly = true)
56-
public List<Itinerary> requestPossibleRoutesForCargo(TrackingId trackingId) {
57-
final Cargo cargo = loadCargoForRouting(trackingId);
5846
final RouteSpecification routeSpecification = RouteSpecification.forCargo(cargo, new Date());
5947

6048
return routingService.fetchRoutesForSpecification(routeSpecification);
@@ -74,9 +62,6 @@ public void assignCargoToRoute(final TrackingId trackingId, final Itinerary newI
7462
cargoRepository.save(cargo);
7563

7664
logger.info("Assigned cargo " + trackingId + " to new route");
77-
78-
// TODO
79-
//lockManager.unlockCargo(cargoLock, trackingId);
8065
}
8166

8267
public void setCargoRepository(final CargoRepository cargoRepository) {

0 commit comments

Comments
 (0)