Probleme sur la gestion queue
This commit is contained in:
@@ -8,6 +8,7 @@ use App\Models\Account;
|
|||||||
use Illuminate\Support\Facades\Cache;
|
use Illuminate\Support\Facades\Cache;
|
||||||
use Illuminate\Support\Facades\Http;
|
use Illuminate\Support\Facades\Http;
|
||||||
use Illuminate\Support\Facades\Queue;
|
use Illuminate\Support\Facades\Queue;
|
||||||
|
use Illuminate\Support\Facades\DB;
|
||||||
use Webklex\PHPIMAP\ClientManager;
|
use Webklex\PHPIMAP\ClientManager;
|
||||||
|
|
||||||
class AccountController extends Controller
|
class AccountController extends Controller
|
||||||
@@ -97,7 +98,7 @@ class AccountController extends Controller
|
|||||||
$twitterHeaders['att'] = $task1->header('att');
|
$twitterHeaders['att'] = $task1->header('att');
|
||||||
|
|
||||||
sleep(5);
|
sleep(5);
|
||||||
\DB::reconnect();
|
DB::reconnect();
|
||||||
|
|
||||||
// Étape 2 : Saisie du nom d'utilisateur
|
// Étape 2 : Saisie du nom d'utilisateur
|
||||||
$task2 = Http::withOptions([
|
$task2 = Http::withOptions([
|
||||||
@@ -137,7 +138,7 @@ class AccountController extends Controller
|
|||||||
}
|
}
|
||||||
|
|
||||||
sleep(5);
|
sleep(5);
|
||||||
\DB::reconnect();
|
DB::reconnect();
|
||||||
|
|
||||||
// Étape 3 : Saisie du mot de passe
|
// Étape 3 : Saisie du mot de passe
|
||||||
$task3 = Http::withOptions([
|
$task3 = Http::withOptions([
|
||||||
@@ -279,9 +280,7 @@ class AccountController extends Controller
|
|||||||
public function tweetnews()
|
public function tweetnews()
|
||||||
{
|
{
|
||||||
// Vérifier si la queue est vide (en fonction de votre driver)
|
// Vérifier si la queue est vide (en fonction de votre driver)
|
||||||
$queue = Queue::getDefaultDriver(); // Par défaut, c'est 'default'
|
$jobsCount = Queue::size('default');
|
||||||
|
|
||||||
$jobsCount = Queue::size($queue);
|
|
||||||
|
|
||||||
if ($jobsCount === 0) {
|
if ($jobsCount === 0) {
|
||||||
|
|
||||||
@@ -294,4 +293,4 @@ class AccountController extends Controller
|
|||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
}
|
}
|
||||||
Reference in New Issue
Block a user