change limitDailyRelancesByRequest #2181

.env

@@ -53,6 +53,7 @@ MAINTENANCE_ENABLE=0
 MAINTENANCE_BANNER_ENABLE=0
 MAINTENANCE_BANNER_MESSAGE="Une opération de maintenance est prévu le XX/XX/XXXX à XX:XX. Le site sera indisponible pendant la durée de l'opération."
 AXIOS_TIMEOUT=30000
+LIMIT_DAILY_RELANCES_BY_REQUEST=275
 ### histologe ###
 
 ### object storage S3 ###

.env.sample

@@ -42,6 +42,7 @@ MAINTENANCE_ENABLE=0
 MAINTENANCE_BANNER_ENABLE=0
 MAINTENANCE_BANNER_MESSAGE="Une opération de maintenance est prévu le XX/XX/XXXX à XX:XX. Le site sera indisponible pendant la durée de l'opération."
 AXIOS_TIMEOUT=30000
+LIMIT_DAILY_RELANCES_BY_REQUEST=275
 
 ###> knplabs/knp-snappy-bundle ###
 WKHTMLTOPDF_PATH=wkhtmltopdf

Makefile

@@ -163,6 +163,10 @@ clear-pool: ## Clear cache pool: make clear-pool pool=[pool_name]
 console: ## Execute application command
 	@echo $(SYMFONY) app:$(app)
 	@$(DOCKER_COMP) exec -it histologe_phpfpm $(SYMFONY) app:$(app)
+
+console-profile: ## Execute application command
+	@echo $(SYMFONY) app:$(app)
+	@$(DOCKER_COMP) exec -it histologe_phpfpm $(SYMFONY) --profile app:$(app)
 
 upload: ## Push objects to S3 Bucket
 	./scripts/upload-s3.sh $(action) $(zip) $(debug)

src/Entity/Suivi.php

@@ -18,7 +18,6 @@ class Suivi
 
     public const DEFAULT_PERIOD_INACTIVITY = 30;
     public const DEFAULT_PERIOD_RELANCE = 45;
-    public const LIMIT_DAILY_RELANCES = 200;
 
     public const DESCRIPTION_MOTIF_CLOTURE_ALL = 'Le signalement a été cloturé pour tous';
     public const DESCRIPTION_MOTIF_CLOTURE_PARTNER = 'Le signalement a été cloturé pour';

src/Repository/SuiviRepository.php

@@ -12,6 +12,7 @@
 use Doctrine\ORM\NonUniqueResultException;
 use Doctrine\ORM\NoResultException;
 use Doctrine\Persistence\ManagerRegistry;
+use Symfony\Component\DependencyInjection\Attribute\Autowire;
 
 /**
  * @method Suivi|null find($id, $lockMode = null, $lockVersion = null)
@@ -21,8 +22,11 @@
  */
 class SuiviRepository extends ServiceEntityRepository
 {
-    public function __construct(ManagerRegistry $registry)
-    {
+    public function __construct(
+        ManagerRegistry $registry,
+        #[Autowire(env: 'LIMIT_DAILY_RELANCES_BY_REQUEST')]
+        private int $limitDailyRelancesByRequest
+        ) {
         parent::__construct($registry, Suivi::class);
     }
 
@@ -199,7 +203,6 @@ private function getSignalementsQuery(
 
     public function findSignalementsLastSuiviPublic(
         int $period = Suivi::DEFAULT_PERIOD_RELANCE,
-        int $limit = Suivi::LIMIT_DAILY_RELANCES,
     ): array {
         $connection = $this->getEntityManager()->getConnection();
 
@@ -226,7 +229,7 @@ public function findSignalementsLastSuiviPublic(
         GROUP BY s.id
         HAVING DATEDIFF(NOW(), IFNULL(last_posted_at, s.created_at)) > :day_period
         ORDER BY last_posted_at
-        LIMIT '.$limit;
+        LIMIT '.$this->limitDailyRelancesByRequest;
 
         $statement = $connection->prepare($sql);
 
@@ -235,7 +238,6 @@ public function findSignalementsLastSuiviPublic(
 
     public function findSignalementsLastSuiviTechnical(
         int $period = Suivi::DEFAULT_PERIOD_INACTIVITY,
-        int $limit = Suivi::LIMIT_DAILY_RELANCES,
     ): array {
         $connection = $this->getEntityManager()->getConnection();
 
@@ -261,8 +263,7 @@ public function findSignalementsLastSuiviTechnical(
                 AND s.statut NOT IN (:status_need_validation, :status_closed, :status_archived, :status_refused)
                 AND s.is_imported != 1
                 AND (s.is_usager_abandon_procedure != 1 OR s.is_usager_abandon_procedure IS NULL)
-                LIMIT '.$limit;
-
+                LIMIT '.$this->limitDailyRelancesByRequest;
         $statement = $connection->prepare($sql);
 
         return $statement->executeQuery($parameters)->fetchFirstColumn();
@@ -283,7 +284,7 @@ public function findSignalementsForThirdRelance(
         ];
 
         $sql = $this->getSignalementsLastSuivisTechnicalsQuery(excludeUsagerAbandonProcedure: true, dayPeriod: $period);
-
+        $sql .= ' LIMIT '.$this->limitDailyRelancesByRequest;
         $statement = $connection->prepare($sql);
 
         return $statement->executeQuery($parameters)->fetchFirstColumn();