Mascali
/
raspisms
mirror of https://github.com/RaspbianFrance/raspisms.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Ajout d'une boucle sur l'envoie des queries pour diminuer le temps d'attente

This commit is contained in:
OsaAjani 2016-01-22 16:56:28 +01:00
parent 57ef2d341c
commit 063f0c97a3
1 changed files with 26 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

46
controllers/internalConsole.php
View File

@ -444,30 +444,36 @@
{
global $db;
$webhookQueries = $db->getFromTableWhere('webhook_queries', ['progress' => false]);
$webhookQueriesIds = [];
foreach ($webhookQueries as $webhookQuerie)
{
$webhookQueriesIds[] = $webhookQuerie['id'];
}
for ($i = 0; $i < 30; $i++)
{
$webhookQueries = $db->getFromTableWhere('webhook_queries', ['progress' => false]);
$webhookQueriesIds = [];
foreach ($webhookQueries as $webhookQuerie)
{
$webhookQueriesIds[] = $webhookQuerie['id'];
}
$db->updateProgressWebhookQueriesIn($webhookQueriesIds, true);
$db->updateProgressWebhookQueriesIn($webhookQueriesIds, true);
foreach ($webhookQueries as $webhookQuerie)
{
//On remap les datas
$datas = json_decode($webhookQuerie['datas'], true);
$datas = http_build_query($datas);
foreach ($webhookQueries as $webhookQuerie)
{
//On remap les datas
$datas = json_decode($webhookQuerie['datas'], true);
$datas = http_build_query($datas);
//On fait la requete
$curl = curl_init();
curl_setopt($curl, CURLOPT_URL, $webhookQuerie['url']);
curl_setopt($curl, CURLOPT_POST, 1);
curl_setopt($curl, CURLOPT_POSTFIELDS, $datas);
curl_exec($curl);
curl_close($curl); //On ferme CURL
//On fait la requete
$curl = curl_init();
curl_setopt($curl, CURLOPT_URL, $webhookQuerie['url']);
curl_setopt($curl, CURLOPT_POST, 1);
curl_setopt($curl, CURLOPT_POSTFIELDS, $datas);
curl_exec($curl);
curl_close($curl); //On ferme CURL
echo "Query do to " . $webhookQuerie['url'] . " with datas " . $datas . "\n";
echo "Query do to " . $webhookQuerie['url'] . " with datas " . $datas . "\n";
}
//On attend 2 secondes
sleep(2);
}
}
}