diff --git a/app/Console/Commands/Services/Tasks/Alarm/AlarmStore.php b/app/Console/Commands/Services/Tasks/Alarm/AlarmStore.php index f02f58e6..faa5bd79 100644 --- a/app/Console/Commands/Services/Tasks/Alarm/AlarmStore.php +++ b/app/Console/Commands/Services/Tasks/Alarm/AlarmStore.php @@ -3,6 +3,7 @@ namespace App\Console\Commands\Services\Tasks\Alarm; use App\Models\EventBookmaker; +use PDOException; class AlarmStore { @@ -42,6 +43,23 @@ class AlarmStore } } - EventBookmaker::where('event_id', $event_id)->where('bookmaker_id', $client_bookmaker_id)->update($update_array); + $max_tries = 5; + $tries = 0; + do { + $retry = false; + try { + + $res = EventBookmaker::where('event_id', $event_id)->where('bookmaker_id', $client_bookmaker_id)->update($update_array); + + return $res; + } catch (PDOException $exc) { + if ($tries < $max_tries && $exc->errorInfo[0] == 40001 && $exc->errorInfo[1] == 1213) { + $retry = true; + sleep(1); + } else { + throw $exc; + } + } + } while ($retry); } } diff --git a/app/Console/Commands/Services/Tasks/NotifyAlarms.php b/app/Console/Commands/Services/Tasks/NotifyAlarms.php index 704ef3a1..52685efc 100644 --- a/app/Console/Commands/Services/Tasks/NotifyAlarms.php +++ b/app/Console/Commands/Services/Tasks/NotifyAlarms.php @@ -150,9 +150,8 @@ class NotifyAlarms } } } - dd($stored_alarms); if ($stored_alarms) { - // PersonalNotificationSend::whereNotIn('id', $stored_alarms)->delete(); + PersonalNotificationSend::whereNotIn('id', $stored_alarms)->delete(); } } } diff --git a/app/Console/Commands/Services/Tasks/TxoddsFlags.php b/app/Console/Commands/Services/Tasks/TxoddsFlags.php index f73f5f87..4218ac60 100644 --- a/app/Console/Commands/Services/Tasks/TxoddsFlags.php +++ b/app/Console/Commands/Services/Tasks/TxoddsFlags.php @@ -31,6 +31,9 @@ class TxoddsFlags $data = Xml::load($url); if (is_array($data)) { + + Supervisor::where('id', Nuh::$options['supervisor_id'])->update(['lastcall' => (int) $data['timestamp']]); + foreach ($data as $row) { foreach ($tables as $table) { DB::table($table)->where('offer_id', (int) $row['id'])->update(['last_updated' => $row['last_updated'], 'flags' => $row['flags']]); @@ -47,9 +50,8 @@ class TxoddsFlags $data = Xml::load($url); - Supervisor::where('id', Nuh::$options['supervisor_id'])->update(['lastcall' => (int) $data['timestamp']]); - if (is_array($data)) { + foreach ($data as $row) { foreach ($tables as $table) { DB::table($table)->where('offer_id', (int) $row['id'])->update(['last_updated' => $row['last_updated'], 'flags' => $row['flags']]);