1
|
|
|
<?php |
2
|
|
|
|
3
|
|
|
declare(strict_types = 1); |
4
|
|
|
|
5
|
|
|
namespace SyliusCart\Domain\Model; |
6
|
|
|
|
7
|
|
|
use Broadway\EventSourcing\EventSourcedAggregateRoot; |
8
|
|
|
use Money\Currency; |
9
|
|
|
use Money\Money; |
10
|
|
|
use Ramsey\Uuid\UuidInterface; |
11
|
|
|
use SyliusCart\Domain\Adapter\AvailableCurrencies\AvailableCurrenciesProviderInterface; |
12
|
|
|
use SyliusCart\Domain\Event\CartCleared; |
13
|
|
|
use SyliusCart\Domain\Event\CartInitialized; |
14
|
|
|
use SyliusCart\Domain\Event\CartItemAdded; |
15
|
|
|
use SyliusCart\Domain\Event\CartItemQuantityChanged; |
16
|
|
|
use SyliusCart\Domain\Event\CartItemRemoved; |
17
|
|
|
use SyliusCart\Domain\Exception\CartCurrencyMismatchException; |
18
|
|
|
use SyliusCart\Domain\Exception\CartCurrencyNotSupportedException; |
19
|
|
|
use SyliusCart\Domain\Exception\InvalidCartItemUnitPriceException; |
20
|
|
|
use SyliusCart\Domain\ModelCollection\CartItemCollection; |
21
|
|
|
use SyliusCart\Domain\ModelCollection\CartItems; |
22
|
|
|
use SyliusCart\Domain\ValueObject\CartItemQuantity; |
23
|
|
|
use SyliusCart\Domain\ValueObject\ProductCode; |
24
|
|
|
|
25
|
|
|
/** |
26
|
|
|
* @author Arkadiusz Krakowiak <[email protected]> |
27
|
|
|
*/ |
28
|
|
|
final class Cart extends EventSourcedAggregateRoot implements CartContract |
29
|
|
|
{ |
30
|
|
|
/** |
31
|
|
|
* @var UuidInterface |
32
|
|
|
*/ |
33
|
|
|
private $cartId; |
34
|
|
|
|
35
|
|
|
/** |
36
|
|
|
* @var CartItemCollection |
37
|
|
|
*/ |
38
|
|
|
private $cartItems; |
39
|
|
|
|
40
|
|
|
/** |
41
|
|
|
* @var Currency |
42
|
|
|
*/ |
43
|
|
|
private $cartCurrency; |
44
|
|
|
|
45
|
|
|
/** |
46
|
|
|
* @var AvailableCurrenciesProviderInterface |
47
|
|
|
*/ |
48
|
|
|
private $availableCurrenciesProvider; |
49
|
|
|
|
50
|
|
|
/** |
51
|
|
|
* @param AvailableCurrenciesProviderInterface $availableCurrenciesProvider |
52
|
|
|
*/ |
53
|
|
|
private function __construct(AvailableCurrenciesProviderInterface $availableCurrenciesProvider) |
54
|
|
|
{ |
55
|
|
|
$this->availableCurrenciesProvider = $availableCurrenciesProvider; |
56
|
|
|
} |
57
|
|
|
|
58
|
|
|
/** |
59
|
|
|
* @param UuidInterface $cartId |
60
|
|
|
* @param string $currencyCode |
61
|
|
|
* @param AvailableCurrenciesProviderInterface $availableCurrenciesProvider |
62
|
|
|
* |
63
|
|
|
* @return CartContract |
64
|
|
|
*/ |
65
|
|
|
public static function initialize( |
66
|
|
|
UuidInterface $cartId, |
67
|
|
|
string $currencyCode, |
68
|
|
|
AvailableCurrenciesProviderInterface $availableCurrenciesProvider |
69
|
|
|
): CartContract { |
70
|
|
|
$cart = new self($availableCurrenciesProvider); |
71
|
|
|
|
72
|
|
|
$cartCurrency = new Currency($currencyCode); |
73
|
|
|
|
74
|
|
|
if (!$cartCurrency->isAvailableWithin($cart->availableCurrenciesProvider->provideAvailableCurrencies())) { |
75
|
|
|
throw new CartCurrencyNotSupportedException(); |
76
|
|
|
} |
77
|
|
|
|
78
|
|
|
$cart->apply(CartInitialized::occur($cartId, $cartCurrency)); |
79
|
|
|
|
80
|
|
|
return $cart; |
81
|
|
|
} |
82
|
|
|
|
83
|
|
|
/** |
84
|
|
|
* @param AvailableCurrenciesProviderInterface $availableCurrenciesProvider |
85
|
|
|
* |
86
|
|
|
* @return CartContract |
87
|
|
|
*/ |
88
|
|
|
public static function createWithAdapters( |
89
|
|
|
AvailableCurrenciesProviderInterface $availableCurrenciesProvider |
90
|
|
|
): CartContract { |
91
|
|
|
return new self($availableCurrenciesProvider); |
92
|
|
|
} |
93
|
|
|
|
94
|
|
|
/** |
95
|
|
|
* @param string $productCode |
96
|
|
|
* @param int $quantity |
97
|
|
|
* @param int $price |
98
|
|
|
* @param string $productCurrencyCode |
99
|
|
|
*/ |
100
|
|
|
public function addProductToCart(string $productCode, int $quantity, int $price, string $productCurrencyCode): void |
101
|
|
|
{ |
102
|
|
|
$price = new Money($price, new Currency($productCurrencyCode)); |
103
|
|
|
$quantity = CartItemQuantity::create($quantity); |
104
|
|
|
$productCode = ProductCode::fromString($productCode); |
105
|
|
|
|
106
|
|
|
if ($price->isNegative()) { |
107
|
|
|
throw new InvalidCartItemUnitPriceException('Cart item unit price cannot be below zero.'); |
108
|
|
|
} |
109
|
|
|
|
110
|
|
|
if (!$this->cartCurrency->equals($price->getCurrency())) { |
111
|
|
|
throw new CartCurrencyMismatchException($this->cartCurrency, $price->getCurrency()); |
112
|
|
|
} |
113
|
|
|
|
114
|
|
|
$cartItem = CartItem::create( |
115
|
|
|
$productCode, |
116
|
|
|
$quantity, |
117
|
|
|
$price |
118
|
|
|
); |
119
|
|
|
|
120
|
|
|
$this->apply(CartItemAdded::occur($this->cartId, $cartItem)); |
121
|
|
|
} |
122
|
|
|
|
123
|
|
|
/** |
124
|
|
|
* @param string $productCode |
125
|
|
|
*/ |
126
|
|
|
public function removeProductFromCart(string $productCode): void |
127
|
|
|
{ |
128
|
|
|
$cartItem = $this->cartItems->findOneByProductCode(ProductCode::fromString($productCode)); |
129
|
|
|
|
130
|
|
|
$this->apply(CartItemRemoved::occur($this->cartId, $cartItem->productCode())); |
131
|
|
|
} |
132
|
|
|
|
133
|
|
|
public function clear(): void |
134
|
|
|
{ |
135
|
|
|
if (!$this->cartItems->isEmpty()) { |
136
|
|
|
$this->apply(CartCleared::occur($this->cartId)); |
137
|
|
|
} |
138
|
|
|
} |
139
|
|
|
|
140
|
|
|
/** |
141
|
|
|
* @param string $productCode |
142
|
|
|
* @param int $quantity |
143
|
|
|
*/ |
144
|
|
|
public function changeProductQuantity(string $productCode, int $quantity): void |
145
|
|
|
{ |
146
|
|
|
$productCode = ProductCode::fromString($productCode); |
147
|
|
|
$cartItem = $this->cartItems->findOneByProductCode($productCode); |
148
|
|
|
$newQuantity = CartItemQuantity::create($quantity); |
149
|
|
|
|
150
|
|
|
$this->apply(CartItemQuantityChanged::occur($this->cartId, $productCode, $cartItem->quantity(), $newQuantity)); |
151
|
|
|
} |
152
|
|
|
|
153
|
|
|
/** |
154
|
|
|
* {@inheritdoc} |
155
|
|
|
*/ |
156
|
|
|
public function getAggregateRootId(): UuidInterface |
157
|
|
|
{ |
158
|
|
|
return $this->cartId; |
159
|
|
|
} |
160
|
|
|
|
161
|
|
|
/** |
162
|
|
|
* @param CartInitialized $event |
163
|
|
|
*/ |
164
|
|
|
protected function applyCartInitialized(CartInitialized $event): void |
165
|
|
|
{ |
166
|
|
|
$this->cartId = $event->getCartId(); |
167
|
|
|
$this->cartCurrency = $event->getCartCurrency(); |
168
|
|
|
$this->cartItems = CartItems::createEmpty(); |
169
|
|
|
} |
170
|
|
|
|
171
|
|
|
/** |
172
|
|
|
* @param CartItemAdded $event |
173
|
|
|
*/ |
174
|
|
|
protected function applyCartItemAdded(CartItemAdded $event): void |
175
|
|
|
{ |
176
|
|
|
$this->cartItems->add($event->getCartItem()); |
177
|
|
|
} |
178
|
|
|
|
179
|
|
|
/** |
180
|
|
|
* @param CartItemRemoved $event |
181
|
|
|
*/ |
182
|
|
|
protected function applyCartItemRemoved(CartItemRemoved $event): void |
183
|
|
|
{ |
184
|
|
|
$cartItem = $this->cartItems->findOneByProductCode($event->getProductCode()); |
185
|
|
|
$this->cartItems->remove($cartItem); |
186
|
|
|
} |
187
|
|
|
|
188
|
|
|
/** |
189
|
|
|
* @param CartCleared $event |
190
|
|
|
*/ |
191
|
|
|
protected function applyCartCleared(CartCleared $event): void |
|
|
|
|
192
|
|
|
{ |
193
|
|
|
$this->cartItems->clear(); |
194
|
|
|
} |
195
|
|
|
} |
196
|
|
|
|
This check looks from parameters that have been defined for a function or method, but which are not used in the method body.