BookingService::bookNewCargo() - Code Metrics - codeliner/php-ddd-cargo-sample - Measure and Improve Code Quality continuously with Scrutinizer

BookingService::bookNewCargo() A
last analyzed 2016-03-14 22:33 UTC

↳ Parent: BookingService

Complexity

Conditions	2
Paths	4

Size

Total Lines	22
Code Lines	12

Duplication

Lines	0
Ratio	0 %

Metric	Value
dl	0
loc	22
rs	9.2
cc	2
eloc	12
nc	4
nop	2

<?php
/*
 * This file is part of the prooph/php-ddd-cargo-sample.
 * (c) Alexander Miertsch <[email protected]>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 * 
 * Date: 29.03.14 - 17:55
 */
declare(strict_types = 1);

namespace Codeliner\CargoBackend\Application\Booking;

use Codeliner\CargoBackend\Application\Booking\Assembler\CargoRoutingDtoAssembler;
use Codeliner\CargoBackend\Application\Booking\Assembler\RouteCandidateDtoAssembler;
use Codeliner\CargoBackend\Application\Booking\Dto\CargoRoutingDto;
use Codeliner\CargoBackend\Application\Booking\Dto\LocationDto;
use Codeliner\CargoBackend\Application\Booking\Dto\RouteCandidateDto;
use Codeliner\CargoBackend\Application\Exception\CargoNotFoundException;
use Codeliner\CargoBackend\Infrastructure\Persistence\Transaction\TransactionManager;
use Codeliner\CargoBackend\Model\Cargo\Cargo;
use Codeliner\CargoBackend\Model\Cargo\CargoRepositoryInterface;
use Codeliner\CargoBackend\Model\Cargo\RouteSpecification;
use Codeliner\CargoBackend\Model\Cargo\TrackingId;
use Codeliner\CargoBackend\Model\Routing\RoutingServiceInterface;

/**
 * Class BookingService
 *
 * @package Codeliner\CargoBackend\Application\Booking
 * @author Alexander Miertsch <[email protected]>
 */
class BookingService
{
    /**
     * @var CargoRepositoryInterface
     */
    private $cargoRepository;

    /**
     * @var TransactionManager
     */
    private $transactionManager;

    /**
     * @var RoutingServiceInterface
     */
    private $routingService;

    /**
     * @var array List of locations
     */
    private $locations;

    /**
     * @param CargoRepositoryInterface $aCargoRepository
     * @param TransactionManager $aTransactionManager
     * @param RoutingServiceInterface $aRoutingService
     * @param array $locations
     */
    public function __construct(
        CargoRepositoryInterface $aCargoRepository,
        TransactionManager $aTransactionManager,
        RoutingServiceInterface $aRoutingService,
        array $locations
    ) {
        $this->cargoRepository    = $aCargoRepository;
        $this->transactionManager = $aTransactionManager;
        $this->routingService     = $aRoutingService;
        $this->locations          = $locations;
    }

    /**
     * @param string $anOrigin
     * @param string $aDestination
     * @throws \Exception If booking fails
     * @return string
     */
    public function bookNewCargo(string $anOrigin, string $aDestination): string
    {
        $trackingId = $this->cargoRepository->getNextTrackingId();

        $routeSpecification = new RouteSpecification($anOrigin, $aDestination);

        $cargo = new Cargo($trackingId, $routeSpecification);

        $this->transactionManager->beginTransaction();

        try {
            $this->cargoRepository->store($cargo);

            $this->transactionManager->commit();

            return $trackingId->toString();
        } catch (\Exception $ex) {
            $this->transactionManager->rollback();

            throw $ex;
        }
    }

    /**
     * @param string $aTrackingId
     * @throws \Codeliner\CargoBackend\Application\Exception\CargoNotFoundException
     * @return CargoRoutingDto
     */
    public function loadCargoForRouting(string $aTrackingId): CargoRoutingDto
    {
        $aTrackingId = TrackingId::fromString($aTrackingId);

        $cargo = $this->cargoRepository->get($aTrackingId);

        if (! $cargo) {
            throw CargoNotFoundException::forTrackingId($aTrackingId);
        }

        $cargoRoutingDtoAssembler = new CargoRoutingDtoAssembler();

        return $cargoRoutingDtoAssembler->toDto($cargo);
    }

    /**
     * @param string $aTrackingId
     * @throws CargoNotFoundException
     * @return RouteCandidateDto[]
     */
    public function requestPossibleRoutesForCargo(string $aTrackingId): array
    {
        $aTrackingId = TrackingId::fromString($aTrackingId);

        $cargo = $this->cargoRepository->get($aTrackingId);

        if (! $cargo) {
            throw CargoNotFoundException::forTrackingId($aTrackingId);
        }

        $itineraries = $this->routingService->fetchRoutesForSpecification($cargo->routeSpecification());

        $routeCandidates = array();
        $routeCandidateAssembler = new RouteCandidateDtoAssembler();

        foreach ($itineraries as $itinerary) {
            $routeCandidates[] = $routeCandidateAssembler->toDto($itinerary);
        }

        return $routeCandidates;
    }

    /**
     * @param string $aTrackingId
     * @param RouteCandidateDto $aRoute
     * @throws CargoNotFoundException
     * @throws \Exception
     * @return void
     */
    public function assignCargoToRoute(string $aTrackingId, RouteCandidateDto $aRoute)
    {
        $aTrackingId = TrackingId::fromString($aTrackingId);
        $cargo = $this->cargoRepository->get($aTrackingId);

        if (! $cargo) {
            throw CargoNotFoundException::forTrackingId($aTrackingId);
        }

        $routeCandidateAssembler = new RouteCandidateDtoAssembler();

        $itinerary = $routeCandidateAssembler->toItinerary($aRoute);

        $this->transactionManager->beginTransaction();

        try {

            $cargo->assignToRoute($itinerary);

            $this->cargoRepository->store($cargo);

            $this->transactionManager->commit();

        } catch (\Exception $ex) {

            $this->transactionManager->rollback();

            throw $ex;
        }
    }

    /**
     * @return LocationDto[]
     */
    public function listShippingLocations(): array
    {
        $locationDtos = array();

        foreach ($this->locations as $unLocode => $name) {
            $locationDto = new LocationDto();
            $locationDto->setUnLocode($unLocode);
            $locationDto->setName($name);

            $locationDtos[] = $locationDto;
        }

        return $locationDtos;
    }

    /**
     * @return CargoRoutingDto[]
     */
    public function listAllCargos(): array
    {
        $cargos = $this->cargoRepository->getAll();

        $cargoRoutingDtos = array();

        $cargoRoutingDtoAssembler = new CargoRoutingDtoAssembler();

        foreach ($cargos as $cargo) {
            $cargoRoutingDtos[] = $cargoRoutingDtoAssembler->toDto($cargo);
        }

        return $cargoRoutingDtos;
    }
}


1			<?php
2			/*
3			* This file is part of the prooph/php-ddd-cargo-sample.
4			* (c) Alexander Miertsch <[email protected]>
5			*
6			* For the full copyright and license information, please view the LICENSE
7			* file that was distributed with this source code.
8			*
9			* Date: 29.03.14 - 17:55
10			*/
11			declare(strict_types = 1);
12
13			namespace Codeliner\CargoBackend\Application\Booking;
14
15			use Codeliner\CargoBackend\Application\Booking\Assembler\CargoRoutingDtoAssembler;
16			use Codeliner\CargoBackend\Application\Booking\Assembler\RouteCandidateDtoAssembler;
17			use Codeliner\CargoBackend\Application\Booking\Dto\CargoRoutingDto;
18			use Codeliner\CargoBackend\Application\Booking\Dto\LocationDto;
19			use Codeliner\CargoBackend\Application\Booking\Dto\RouteCandidateDto;
20			use Codeliner\CargoBackend\Application\Exception\CargoNotFoundException;
21			use Codeliner\CargoBackend\Infrastructure\Persistence\Transaction\TransactionManager;
22			use Codeliner\CargoBackend\Model\Cargo\Cargo;
23			use Codeliner\CargoBackend\Model\Cargo\CargoRepositoryInterface;
24			use Codeliner\CargoBackend\Model\Cargo\RouteSpecification;
25			use Codeliner\CargoBackend\Model\Cargo\TrackingId;
26			use Codeliner\CargoBackend\Model\Routing\RoutingServiceInterface;
27
28			/**
29			* Class BookingService
30			*
31			* @package Codeliner\CargoBackend\Application\Booking
32			* @author Alexander Miertsch <[email protected]>
33			*/
34			class BookingService
35			{
36			/**
37			* @var CargoRepositoryInterface
38			*/
39			private $cargoRepository;
40
41			/**
42			* @var TransactionManager
43			*/
44			private $transactionManager;
45
46			/**
47			* @var RoutingServiceInterface
48			*/
49			private $routingService;
50
51			/**
52			* @var array List of locations
53			*/
54			private $locations;
55
56			/**
57			* @param CargoRepositoryInterface $aCargoRepository
58			* @param TransactionManager $aTransactionManager
59			* @param RoutingServiceInterface $aRoutingService
60			* @param array $locations
61			*/
62			public function __construct(
63			CargoRepositoryInterface $aCargoRepository,
64			TransactionManager $aTransactionManager,
65			RoutingServiceInterface $aRoutingService,
66			array $locations
67			) {
68			$this->cargoRepository = $aCargoRepository;
69			$this->transactionManager = $aTransactionManager;
70			$this->routingService = $aRoutingService;
71			$this->locations = $locations;
72			}
73
74			/**
75			* @param string $anOrigin
76			* @param string $aDestination
77			* @throws \Exception If booking fails
78			* @return string
79			*/
80			public function bookNewCargo(string $anOrigin, string $aDestination): string
81			{
82			$trackingId = $this->cargoRepository->getNextTrackingId();
83
84			$routeSpecification = new RouteSpecification($anOrigin, $aDestination);
85
86			$cargo = new Cargo($trackingId, $routeSpecification);
87
88			$this->transactionManager->beginTransaction();
89
90			try {
91			$this->cargoRepository->store($cargo);
92
93			$this->transactionManager->commit();
94
95			return $trackingId->toString();
96			} catch (\Exception $ex) {
97			$this->transactionManager->rollback();
98
99			throw $ex;
100			}
101			}
102
103			/**
104			* @param string $aTrackingId
105			* @throws \Codeliner\CargoBackend\Application\Exception\CargoNotFoundException
106			* @return CargoRoutingDto
107			*/
108			public function loadCargoForRouting(string $aTrackingId): CargoRoutingDto
109			{
110			$aTrackingId = TrackingId::fromString($aTrackingId);
111
112			$cargo = $this->cargoRepository->get($aTrackingId);
113
114			if (! $cargo) {
115			throw CargoNotFoundException::forTrackingId($aTrackingId);
116			}
117
118			$cargoRoutingDtoAssembler = new CargoRoutingDtoAssembler();
119
120			return $cargoRoutingDtoAssembler->toDto($cargo);
121			}
122
123			/**
124			* @param string $aTrackingId
125			* @throws CargoNotFoundException
126			* @return RouteCandidateDto[]
127			*/
128			public function requestPossibleRoutesForCargo(string $aTrackingId): array
129			{
130			$aTrackingId = TrackingId::fromString($aTrackingId);
131
132			$cargo = $this->cargoRepository->get($aTrackingId);
133
134			if (! $cargo) {
135			throw CargoNotFoundException::forTrackingId($aTrackingId);
136			}
137
138			$itineraries = $this->routingService->fetchRoutesForSpecification($cargo->routeSpecification());
139
140			$routeCandidates = array();
141			$routeCandidateAssembler = new RouteCandidateDtoAssembler();
142
143			foreach ($itineraries as $itinerary) {
144			$routeCandidates[] = $routeCandidateAssembler->toDto($itinerary);
145			}
146
147			return $routeCandidates;
148			}
149
150			/**
151			* @param string $aTrackingId
152			* @param RouteCandidateDto $aRoute
153			* @throws CargoNotFoundException
154			* @throws \Exception
155			* @return void
156			*/
157			public function assignCargoToRoute(string $aTrackingId, RouteCandidateDto $aRoute)
158			{
159			$aTrackingId = TrackingId::fromString($aTrackingId);
160			$cargo = $this->cargoRepository->get($aTrackingId);
161
162			if (! $cargo) {
163			throw CargoNotFoundException::forTrackingId($aTrackingId);
164			}
165
166			$routeCandidateAssembler = new RouteCandidateDtoAssembler();
167
168			$itinerary = $routeCandidateAssembler->toItinerary($aRoute);
169
170			$this->transactionManager->beginTransaction();
171
172			try {
173
174			$cargo->assignToRoute($itinerary);
175
176			$this->cargoRepository->store($cargo);
177
178			$this->transactionManager->commit();
179
180			} catch (\Exception $ex) {
181
182			$this->transactionManager->rollback();
183
184			throw $ex;
185			}
186			}
187
188			/**
189			* @return LocationDto[]
190			*/
191			public function listShippingLocations(): array
192			{
193			$locationDtos = array();
194
195			foreach ($this->locations as $unLocode => $name) {
196			$locationDto = new LocationDto();
197			$locationDto->setUnLocode($unLocode);
198			$locationDto->setName($name);
199
200			$locationDtos[] = $locationDto;
201			}
202
203			return $locationDtos;
204			}
205
206			/**
207			* @return CargoRoutingDto[]
208			*/
209			public function listAllCargos(): array
210			{
211			$cargos = $this->cargoRepository->getAll();
212
213			$cargoRoutingDtos = array();
214
215			$cargoRoutingDtoAssembler = new CargoRoutingDtoAssembler();
216
217			foreach ($cargos as $cargo) {
218			$cargoRoutingDtos[] = $cargoRoutingDtoAssembler->toDto($cargo);
219			}
220
221			return $cargoRoutingDtos;
222			}
223			}
224

codeliner / php-ddd-cargo-sample

GitHub Access Token became invalid

BookingService::bookNewCargo() A last analyzed 2016-03-14 22:33 UTC

Complexity

Size

Duplication

Duplication Side-by-Side

Filter issues like

BookingService::bookNewCargo() A
last analyzed 2016-03-14 22:33 UTC