src/JanusHercules/HighVolumeProcess/Domain/Entity/HighVolumeProcess.php line 19

Open in your IDE?
  1. <?php
  3. namespace JanusHercules\HighVolumeProcess\Domain\Entity;
  5. use App\Utility\DatabaseIdGenerator;
  6. use App\Utility\DateTimeUtility;
  7. use DateTime;
  8. use Doctrine\DBAL\Types\Types;
  9. use Doctrine\ORM\Mapping as ORM;
  10. use Exception;
  11. use JanusHercules\HighVolumeProcess\Domain\Enum\ProcessStatus;
  12. use JanusHercules\HighVolumeProcess\Domain\Enum\ProcessType;
  13. use ValueError;
  15. #[ORM\Entity]
  16. #[ORM\Table(name: 'high_volume_processes')]
  17. #[ORM\Index(columns: ['process_status', 'finalization_started_at'], name: 'idx_process_status')]
  18. #[ORM\Index(columns: ['process_type', 'process_status'], name: 'idx_process_type_status')]
  19. class HighVolumeProcess
  20. {
  21. /**
  22. * @throws Exception
  23. */
  24. public function __construct(
  25. ProcessType $processType,
  26. string $processInfo = ''
  27. ) {
  28. if (mb_strlen($processInfo) > 255) {
  29. throw new ValueError('The processInfo cannot exceed 255 characters.');
  30. }
  31. $this->processType = $processType;
  32. $this->processStatus = ProcessStatus::CREATED;
  33. $this->createdAt = DateTimeUtility::createDateTimeUtc();
  34. $this->processInfo = $processInfo;
  35. }
  37. #[ORM\Id]
  38. #[ORM\GeneratedValue(strategy: 'CUSTOM')]
  39. #[ORM\CustomIdGenerator(class: DatabaseIdGenerator::class)]
  40. #[ORM\Column(
  41. type: Types::GUID,
  42. unique: true
  43. )]
  44. private ?string $id = null;
  46. public function getId(): ?string
  47. {
  48. return $this->id;
  49. }
  51. #[ORM\Column(
  52. type: Types::STRING,
  53. enumType: ProcessType::class
  54. )]
  55. private ProcessType $processType;
  57. public function getProcessType(): ProcessType
  58. {
  59. return $this->processType;
  60. }
  62. #[ORM\Column(
  63. type: Types::DATETIME_MUTABLE
  64. )]
  65. private DateTime $createdAt;
  67. public function getCreatedAt(): DateTime
  68. {
  69. return $this->createdAt;
  70. }
  72. #[ORM\Column(
  73. type : Types::DATETIME_MUTABLE,
  74. nullable: true
  75. )]
  76. private ?DateTime $lastUpdatedAt = null;
  78. public function setLastUpdatedAt(DateTime $lastUpdatedAt): void
  79. {
  80. $this->lastUpdatedAt = $lastUpdatedAt;
  81. }
  83. public function getLastUpdatedAt(): ?DateTime
  84. {
  85. return $this->lastUpdatedAt;
  86. }
  88. #[ORM\Column(
  89. type : Types::DATETIME_MUTABLE,
  90. nullable: true
  91. )]
  92. private ?DateTime $finishedAt = null;
  94. public function getFinishedAt(): ?DateTime
  95. {
  96. return $this->finishedAt;
  97. }
  99. public function setFinishedAt(?DateTime $finishedAt): void
  100. {
  101. $this->finishedAt = $finishedAt;
  102. }
  104. #[ORM\Column(
  105. type: Types::STRING,
  106. length: 255,
  107. )]
  108. private string $processInfo;
  110. public function getProcessInfo(): string
  111. {
  112. return $this->processInfo;
  113. }
  115. #[ORM\Column(
  116. type: Types::STRING,
  117. enumType: ProcessStatus::class
  118. )]
  119. private ProcessStatus $processStatus;
  121. public function getProcessStatus(): ProcessStatus
  122. {
  123. return $this->processStatus;
  124. }
  126. public function setProcessStatus(ProcessStatus $processStatus): void
  127. {
  128. $this->processStatus = $processStatus;
  129. }
  131. #[ORM\Column(
  132. type : Types::TEXT,
  133. nullable: true
  134. )]
  135. private ?string $errorMessage = null;
  137. public function getErrorMessage(): ?string
  138. {
  139. return $this->errorMessage;
  140. }
  142. public function setErrorMessage(string $errorMessage): void
  143. {
  144. $this->errorMessage = mb_substr($errorMessage, 0, 1024);
  145. }
  147. #[ORM\Column(
  148. type : Types::INTEGER,
  149. nullable: false
  150. )]
  151. private int $numberOfItemsToProcess = 0;
  153. public function getNumberOfItemsToProcess(): int
  154. {
  155. return $this->numberOfItemsToProcess;
  156. }
  158. public function setNumberOfItemsToProcess(
  159. int $numberOfItemsToProcess
  160. ): void {
  161. if ($numberOfItemsToProcess < 0) {
  162. throw new ValueError('numberOfItemsToProcess must be greater than 0.');
  163. }
  164. $this->numberOfItemsToProcess = $numberOfItemsToProcess;
  165. }
  167. #[ORM\Column(
  168. type : Types::INTEGER,
  169. nullable: false
  170. )]
  171. private int $numberOfEnqueuedItems = 0;
  173. public function getNumberOfEnqueuedItems(): int
  174. {
  175. return $this->numberOfEnqueuedItems;
  176. }
  178. #[ORM\Column(
  179. type : Types::INTEGER,
  180. nullable: false
  181. )]
  182. private int $numberOfSuccessfullyProcessedItems = 0;
  184. public function getNumberOfSuccessfullyProcessedItems(): int
  185. {
  186. return $this->numberOfSuccessfullyProcessedItems;
  187. }
  189. #[ORM\Column(
  190. type : Types::INTEGER,
  191. nullable: false
  192. )]
  193. private int $numberOfUnsuccessfullyProcessedItems = 0;
  195. public function getNumberOfUnsuccessfullyProcessedItems(): int
  196. {
  197. return $this->numberOfUnsuccessfullyProcessedItems;
  198. }
  200. #[ORM\Column(
  201. type : Types::DATETIME_MUTABLE,
  202. nullable: true
  203. )]
  204. private ?DateTime $finalizationStartedAt = null;
  206. public function getFinalizationStartedAt(): ?DateTime
  207. {
  208. return $this->finalizationStartedAt;
  209. }
  211. #[ORM\Column(
  212. type: Types::DATETIME_MUTABLE,
  213. nullable: true
  214. )]
  215. private ?DateTime $markedForDeletionAfter = null;
  217. public function getMarkedForDeletionAfter(): ?DateTime
  218. {
  219. return $this->markedForDeletionAfter;
  220. }
  222. public function setMarkedForDeletionAfter(?DateTime $markedForDeletionAfter): void
  223. {
  224. $this->markedForDeletionAfter = $markedForDeletionAfter;
  225. }
  226. }