Code Coverage |
||||||||||
Lines |
Functions and Methods |
Classes and Traits |
||||||||
| Total | |
0.00% |
0 / 59 |
|
0.00% |
0 / 8 |
CRAP | |
0.00% |
0 / 1 |
| TransferTaskPickProductService | |
0.00% |
0 / 59 |
|
0.00% |
0 / 8 |
306 | |
0.00% |
0 / 1 |
| pick | |
0.00% |
0 / 9 |
|
0.00% |
0 / 1 |
12 | |||
| transfer | |
0.00% |
0 / 18 |
|
0.00% |
0 / 1 |
2 | |||
| checkStockAvailability | |
0.00% |
0 / 2 |
|
0.00% |
0 / 1 |
6 | |||
| findAddressItem | |
0.00% |
0 / 4 |
|
0.00% |
0 / 1 |
6 | |||
| populateItemToTransferDTO | |
0.00% |
0 / 5 |
|
0.00% |
0 / 1 |
2 | |||
| storePickedItem | |
0.00% |
0 / 10 |
|
0.00% |
0 / 1 |
6 | |||
| markItemAsPicked | |
0.00% |
0 / 3 |
|
0.00% |
0 / 1 |
6 | |||
| checkTransferTaskStatus | |
0.00% |
0 / 8 |
|
0.00% |
0 / 1 |
20 | |||
| 1 | <?php |
| 2 | |
| 3 | namespace Domain\TransferTask\Services; |
| 4 | |
| 5 | use App\Models\Address\Address; |
| 6 | use App\Models\Item\Item; |
| 7 | use App\Models\TransferTask\PickedTransferTaskProduct; |
| 8 | use App\Models\TransferTask\TransferTaskProduct; |
| 9 | use App\Models\User; |
| 10 | use App\Helper\AppHelper; |
| 11 | use Domain\Transaction\Enums\TransactionOutputReasonEnum; |
| 12 | use Domain\Transaction\Enums\TransactionTypeEnum; |
| 13 | use Domain\Transferable\DTOs\TransferItemDTO; |
| 14 | use Domain\Transferable\Exceptions\CantTransferItemException; |
| 15 | use Domain\Transferable\Services\TransferableTransferItemService; |
| 16 | use Domain\TransferTask\DTOs\TransferTaskPickProductDTO; |
| 17 | use Domain\TransferTask\Exceptions\TransferTaskStatusException; |
| 18 | use Illuminate\Support\Facades\DB; |
| 19 | use Illuminate\Support\ItemNotFoundException; |
| 20 | use Throwable; |
| 21 | |
| 22 | readonly class TransferTaskPickProductService |
| 23 | { |
| 24 | /** |
| 25 | * @param TransferTaskPickProductDTO $transferTaskProductDTO |
| 26 | * @param Address $sender |
| 27 | * @param Address $recipient |
| 28 | * @param User $user |
| 29 | * @return void |
| 30 | * @throws Throwable |
| 31 | */ |
| 32 | public function pick(TransferTaskPickProductDTO $transferTaskProductDTO, Address $sender, Address $recipient, User $user): void |
| 33 | { |
| 34 | try { |
| 35 | DB::beginTransaction(); |
| 36 | |
| 37 | $this->checkTransferTaskStatus($transferTaskProductDTO); |
| 38 | |
| 39 | if ($transferTaskProductDTO->transferTaskProduct->isPicked()) { |
| 40 | throw new CantTransferItemException(__('Product is already picked')); |
| 41 | } |
| 42 | |
| 43 | $this->transfer($transferTaskProductDTO, $sender, $recipient, $user); |
| 44 | |
| 45 | DB::commit(); |
| 46 | } catch (Throwable $throwable) { |
| 47 | DB::rollBack(); |
| 48 | throw $throwable; |
| 49 | } |
| 50 | } |
| 51 | |
| 52 | private function transfer(TransferTaskPickProductDTO $transferTaskProductDTO, Address $sender, Address $recipient, User $user): void |
| 53 | { |
| 54 | $itemOnAddress = $this->findAddressItem($sender, $transferTaskProductDTO); |
| 55 | $this->checkStockAvailability($itemOnAddress, $transferTaskProductDTO->amount); |
| 56 | |
| 57 | $itemToTransferDTO = $this->populateItemToTransferDTO( |
| 58 | $itemOnAddress, |
| 59 | $transferTaskProductDTO->amount, |
| 60 | ); |
| 61 | |
| 62 | $item = (new TransferableTransferItemService)->transferOne( |
| 63 | $itemToTransferDTO, |
| 64 | $sender, |
| 65 | $recipient, |
| 66 | TransactionTypeEnum::OUTPUT, |
| 67 | TransactionOutputReasonEnum::PRE_ORDER->value, |
| 68 | $user, |
| 69 | $transferTaskProductDTO->observation, |
| 70 | $sender->sector->value |
| 71 | ); |
| 72 | |
| 73 | $pickedItem = $this->storePickedItem($transferTaskProductDTO, $item, $user); |
| 74 | $this->markItemAsPicked($transferTaskProductDTO->transferTaskProduct, empty($pickedItem)); |
| 75 | } |
| 76 | |
| 77 | private function checkStockAvailability(Item $addressItem, float $amount): void |
| 78 | { |
| 79 | if ($addressItem->isAmountExceeded($amount)) { |
| 80 | throw new CantTransferItemException(__("Quantity not available at address")); |
| 81 | } |
| 82 | } |
| 83 | |
| 84 | private function findAddressItem(Address $address, TransferTaskPickProductDTO $transferTaskProductDTO): Item |
| 85 | { |
| 86 | |
| 87 | $itemToTransfer = $address->findItemByProductionOrder($transferTaskProductDTO->transferTaskProduct->product, $transferTaskProductDTO->productionOrder); |
| 88 | |
| 89 | if (!$itemToTransfer) { |
| 90 | throw new ItemNotFoundException(__('Product is not part of this address')); |
| 91 | } |
| 92 | |
| 93 | return $itemToTransfer; |
| 94 | } |
| 95 | |
| 96 | private function populateItemToTransferDTO(Item $itemToTransfer, float $amount, array $readingLogDTOs = []): TransferItemDTO |
| 97 | { |
| 98 | return new TransferItemDTO([ |
| 99 | 'item' => $itemToTransfer, |
| 100 | 'amount' => $amount, |
| 101 | 'reading_logs' => $readingLogDTOs, |
| 102 | ]); |
| 103 | } |
| 104 | |
| 105 | private function storePickedItem(TransferTaskPickProductDTO $transferTaskPickProductDTO, Item $item, User $user): PickedTransferTaskProduct |
| 106 | { |
| 107 | $transferTaskProduct = $transferTaskPickProductDTO->transferTaskProduct; |
| 108 | |
| 109 | $pickedTransferTaskProduct = $transferTaskProduct->pickedTransferTaskProduct()->exists() ? |
| 110 | $transferTaskProduct->pickedTransferTaskProduct()->first() : |
| 111 | new PickedTransferTaskProduct(); |
| 112 | |
| 113 | $pickedTransferTaskProduct->fill($transferTaskPickProductDTO->toArray()); |
| 114 | $pickedTransferTaskProduct->setAttribute('amount', round($pickedTransferTaskProduct->getAttribute('amount') + $transferTaskPickProductDTO->amount, 2)); |
| 115 | $pickedTransferTaskProduct->item()->associate($item); |
| 116 | $pickedTransferTaskProduct->transferTaskProduct()->associate($transferTaskPickProductDTO->transferTaskProduct); |
| 117 | $pickedTransferTaskProduct->save(); |
| 118 | return $pickedTransferTaskProduct; |
| 119 | } |
| 120 | |
| 121 | |
| 122 | /** |
| 123 | * @param TransferTaskProduct $transferTaskProduct |
| 124 | * @param bool $picked |
| 125 | * @return void |
| 126 | */ |
| 127 | private function markItemAsPicked(TransferTaskProduct $transferTaskProduct, bool $picked): void |
| 128 | { |
| 129 | if ($picked) { |
| 130 | $transferTaskProduct->pick(); |
| 131 | $transferTaskProduct->save(); |
| 132 | } |
| 133 | } |
| 134 | |
| 135 | /** |
| 136 | * @param TransferTaskPickProductDTO $transferTaskProductDTO |
| 137 | * @return void |
| 138 | */ |
| 139 | private function checkTransferTaskStatus(TransferTaskPickProductDTO $transferTaskProductDTO): void |
| 140 | { |
| 141 | $transferTask = $transferTaskProductDTO->transferTaskProduct->transferTask; |
| 142 | if ($transferTask->isPending()) { |
| 143 | $transferTask->start(); |
| 144 | $transferTask->save(); |
| 145 | } |
| 146 | |
| 147 | if ($transferTask->isCanceled()) { |
| 148 | throw new TransferTaskStatusException(__('Task is canceled')); |
| 149 | } |
| 150 | |
| 151 | if ($transferTask->isConcluded()) { |
| 152 | throw new TransferTaskStatusException(__('Task is concluded')); |
| 153 | } |
| 154 | } |
| 155 | } |