Correction problème sur les tweetnews

This commit is contained in:
hugol
2024-11-17 18:36:41 +01:00
parent 14ebf0149c
commit 1e1037e118
3 changed files with 64 additions and 71 deletions

View File

@@ -2,8 +2,11 @@
namespace App\Http\Controllers;
use App\Jobs\ProcessTweet;
use App\Models\Account;
use Illuminate\Support\Facades\Cache;
use Illuminate\Support\Facades\Http;
use Illuminate\Support\Facades\Queue;
use Webklex\PHPIMAP\ClientManager;
class AccountController extends Controller
@@ -269,4 +272,23 @@ class AccountController extends Controller
return null;
}
public function tweetnews()
{
// Vérifier si la queue est vide (en fonction de votre driver)
$queue = Queue::getDefaultDriver(); // Par défaut, c'est 'default'
$jobsCount = Queue::size($queue);
if ($jobsCount === 0) {
$accounts = Account::where('enable', true)->get();
foreach($accounts as $user){
ProcessTweet::dispatch($user->id, 0);
}
}
}
}