diff --git a/Model/QueuedTask.php b/Model/QueuedTask.php index c303c05f..98a21d2c 100644 --- a/Model/QueuedTask.php +++ b/Model/QueuedTask.php @@ -114,9 +114,11 @@ public function createJob($jobName, $data = null, $notBefore = null, $group = nu $dupeKey = $data['company_id'] . '.' . $data['sub_service_id']; break; case 'SaveConnection': - $dupeKey = $data['bidId']; + $additionalKey = isset($data['isStatusChanged']) ? (int) $data['isStatusChanged'] : 0; + $dupeKey = $data['bidId'] . '.' . $additionalKey; break; case 'SaveSingleConnection': + $additionalKey = isset($data['isStatusChanged']) ? (int) $data['isStatusChanged'] : 0; $dupeKey = $data['provider'] . '.' . $data['bidId']; break; case 'SyncIntercomCompany': @@ -196,7 +198,6 @@ public function findAndRescheduleTasks() { 'created < ' => $backDate, 'fetched IS NULL', 'notbefore IS NULL', - ], 'contain' => false ]) as $queuedTask) {