From ed4a907cddc31b940739d9c097ef6a0102b0cfcb Mon Sep 17 00:00:00 2001 From: Jeroen De Meerleer Date: Wed, 18 May 2022 17:16:39 +0200 Subject: [PATCH] ENHANCEMENT: islocked using doctrine --- src/Repository/JobRepository.php | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/src/Repository/JobRepository.php b/src/Repository/JobRepository.php index e1e9e37..0b00ca8 100644 --- a/src/Repository/JobRepository.php +++ b/src/Repository/JobRepository.php @@ -464,10 +464,8 @@ class JobRepository extends EntityRepository public function isLockedJob(int $id = 0): bool { - $jobsSql = "SELECT id FROM job WHERE id = :id AND running != :status"; - $params = [':status' => 0, ':id' => $id]; - - return count($this->getEntityManager()->getConnection()->prepare($jobsSql)->executeQuery($params)->fetchAllAssociative()) > 0; + $job = $this->find($id); + return $job->getRunning() != 0; } public function addJob(array $values)