src/JanusHercules/HighVolumeProcess/Domain/Entity/HighVolumeProcessTask.php line 22

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 ValueError;
  13. #[ORM\Entity]
  14. #[ORM\Table(name: 'high_volume_process_tasks')]
  15. #[ORM\UniqueConstraint(
  16. name : 'unique_process_item',
  17. columns: ['high_volume_processes_id', 'item_id']
  18. )]
  19. #[ORM\Index(columns: ['high_volume_processes_id'], name: 'IDX_D76C3F96CE20091')]
  20. #[ORM\Index(columns: ['high_volume_processes_id', 'finished_at', 'error_message'], name: 'idx_task_status')]
  21. #[ORM\Index(columns: ['finished_at'], name: 'idx_task_finished')]
  22. class HighVolumeProcessTask
  23. {
  24. /**
  25. * @throws Exception
  26. */
  27. public function __construct(
  28. HighVolumeProcess $process,
  29. string $itemId
  30. ) {
  31. if (mb_strlen($itemId) > 128) {
  32. throw new ValueError('The itemId cannot exceed 128 characters.');
  33. }
  35. $this->process = $process;
  36. $this->itemId = $itemId;
  37. $this->createdAt = DateTimeUtility::createDateTimeUtc();
  38. }
  40. #[ORM\Id]
  41. #[ORM\GeneratedValue(strategy: 'CUSTOM')]
  42. #[ORM\CustomIdGenerator(class: DatabaseIdGenerator::class)]
  43. #[ORM\Column(
  44. type : Types::GUID,
  45. unique: true
  46. )]
  47. private ?string $id = null;
  49. public function getId(): ?string
  50. {
  51. return $this->id;
  52. }
  54. #[ORM\ManyToOne(
  55. targetEntity: HighVolumeProcess::class
  56. )]
  57. #[ORM\JoinColumn(
  58. name : 'high_volume_processes_id',
  59. referencedColumnName: 'id',
  60. nullable : false,
  61. onDelete : 'CASCADE'
  62. )]
  63. private HighVolumeProcess $process;
  65. public function getProcess(): HighVolumeProcess
  66. {
  67. return $this->process;
  68. }
  70. #[ORM\Column(
  71. type: Types::DATETIME_MUTABLE
  72. )]
  73. private DateTime $createdAt;
  75. public function getCreatedAt(): DateTime
  76. {
  77. return $this->createdAt;
  78. }
  80. #[ORM\Column(
  81. type : Types::DATETIME_MUTABLE,
  82. nullable: true
  83. )]
  84. private ?DateTime $finishedAt = null;
  86. public function getFinishedAt(): ?DateTime
  87. {
  88. return $this->finishedAt;
  89. }
  91. public function setFinishedAt(DateTime $finishedAt): void
  92. {
  93. $this->finishedAt = $finishedAt;
  94. }
  96. #[ORM\Column(
  97. type : Types::TEXT,
  98. nullable: true
  99. )]
  100. private ?string $errorMessage = null;
  102. public function getErrorMessage(): ?string
  103. {
  104. return $this->errorMessage;
  105. }
  107. public function setErrorMessage(string $errorMessage): void
  108. {
  109. $this->errorMessage = mb_substr($errorMessage, 0, 1024);
  110. }
  112. #[ORM\Column(
  113. type : Types::STRING,
  114. length : 128,
  115. nullable: false
  116. )]
  117. private string $itemId;
  119. public function getItemId(): string
  120. {
  121. return $this->itemId;
  122. }
  124. #[ORM\Column(
  125. type : Types::STRING,
  126. length : 512,
  127. nullable: true
  128. )]
  129. private ?string $resultValue = null;
  131. public function getResultValue(): ?string
  132. {
  133. return $this->resultValue;
  134. }
  136. public function setResultValue(string $resultValue): void
  137. {
  138. if (mb_strlen($resultValue) > 512) {
  139. throw new ValueError('The resultValue cannot exceed 512 characters.');
  140. }
  142. $this->resultValue = $resultValue;
  143. }
  144. }