Samuele E. Locatelli
127 lines
4.3 KiB
PHP
127 lines
4.3 KiB
PHP
<?php
|
|
// Parse with sections
|
|
|
|
$ini = parse_ini_file("conf.ini", true);
|
|
mysql_connect($ini['db']['host'],$ini['db']['user'],$ini['db']['pass']);
|
|
mysql_select_db($ini['db']['db']);
|
|
|
|
if ($ini['db']['log']=="1"){
|
|
$arrival_time=microtime(true);
|
|
$filename=basename(__FILE__);
|
|
$filename="log_".$filename.".txt";
|
|
$chunck=strval($arrival_time)." ".$_SERVER['REQUEST_URI']."\r\n";
|
|
file_put_contents($filename,$chunck,FILE_APPEND);
|
|
}
|
|
|
|
$sql1=mysql_query("select count(*) as count_earthquakes from earthquakes where donotshow=0");
|
|
|
|
$sql2=mysql_query("select count(*) as count_green from notifications where latitude<>0 AND longitude<>0 AND enabled=1");
|
|
|
|
$count_red=0;
|
|
|
|
$sql4=mysql_query("select least(count(*),999) as count_manual_green from manual where magnitude=1 and ban<3 and donotshow=0 and date > date_sub(now(), interval 1440 minute)");
|
|
|
|
$sql5=mysql_query("select least(count(*),999) as count_manual_yellow from manual where magnitude=2 and ban<3 and donotshow=0 and date > date_sub(now(), interval 1440 minute)");
|
|
|
|
$sql6=mysql_query("select least(count(*),999) as count_manual_red from manual where magnitude=3 and ban<3 and donotshow=0 and date > date_sub(now(), interval 1440 minute)");
|
|
|
|
$dataArray = array('count_quakes'=>mysql_result($sql1,0,"count_earthquakes"),
|
|
'count_green'=>mysql_result($sql2,0,"count_green"),
|
|
'count_red'=>$count_red,
|
|
'count_manual_green'=>mysql_result($sql4,0,"count_manual_green"),
|
|
'count_manual_yellow'=>mysql_result($sql5,0,"count_manual_yellow"),
|
|
'count_manual_red'=>mysql_result($sql6,0,"count_manual_red"),
|
|
'type'=>'counts');
|
|
|
|
|
|
|
|
$sql=mysql_query("select user_id from gcm order by user_id limit 1");
|
|
$user_id_ref = mysql_result($sql, 0, "user_id");
|
|
$user_id_ref=$user_id_ref-1;
|
|
$row_limit=250000;
|
|
$keep_going=1;
|
|
|
|
$counter_block=1;
|
|
while ($keep_going){
|
|
print($counter_block."\r\n");
|
|
|
|
$sql2=mysql_query("select user_id,reg_id from gcm where reg_id<>'' and user_id>$user_id_ref order by user_id limit $row_limit");
|
|
$num_rows2 = mysql_num_rows($sql2);
|
|
|
|
if ($num_rows2>0){
|
|
while($data = mysql_fetch_assoc($sql2)){
|
|
$regidArray[] = $data['reg_id'];
|
|
$IDArray[] = $data['user_id'];
|
|
}
|
|
$user_id_ref=end($IDArray);
|
|
|
|
$block_size=999;
|
|
$iter=ceil($num_rows2/$block_size);
|
|
|
|
for ($i=0; $i<$iter; $i++){
|
|
$index_start=$i*$block_size;
|
|
$index_end=($i+1)*$block_size-1;
|
|
if ($index_end>$num_rows2-1){
|
|
$index_end=$num_rows2-1;
|
|
}
|
|
|
|
$regidArrayGCM = array_slice($regidArray,$index_start,$index_end-$index_start+1);
|
|
$IDArrayGCM = array_slice($IDArray,$index_start,$index_end-$index_start+1);
|
|
|
|
$headers = array(
|
|
'Authorization: key=AIzaSyAYaXDEapyd-mF9V9LNW1dmuoS-ea9GwWI',
|
|
'Content-Type: application/json');
|
|
$fields = array(
|
|
'registration_ids' => $regidArrayGCM,
|
|
'time_to_live' => 1500,
|
|
'collapse_key' => 'counts_widget',
|
|
'priority' => 'normal',
|
|
'data' => $dataArray);
|
|
|
|
$context = stream_context_create(array(
|
|
'http' => array(
|
|
'method' => 'POST',
|
|
'header' => $headers,
|
|
'content' => json_encode($fields))));
|
|
|
|
$response = file_get_contents('https://android.googleapis.com/gcm/send', FALSE, $context);
|
|
$response=json_decode($response);
|
|
$counter=0;
|
|
foreach ($response->results as $item)
|
|
{
|
|
if (array_key_exists('error', $item))
|
|
{
|
|
$error=$item->error;
|
|
if (strcmp($error,'NotRegistered')==0){
|
|
$ID=$IDArrayGCM[$counter];
|
|
$sql3=mysql_query("update gcm set to_be_deleted=1 where user_id=$ID");
|
|
print("Delete user_id ".$ID." at position ".$counter."\r\n");
|
|
}
|
|
}
|
|
if (array_key_exists('registration_id', $item))
|
|
{
|
|
$new_reg_id=$item->registration_id;
|
|
$ID=$IDArrayGCM[$counter];
|
|
$sql3=mysql_query("update gcm set reg_id='$new_reg_id' where user_id=$ID");
|
|
print("Replaced the reg_id of user with user_id".$ID." at array position ".$counter." with the new id ".$new_reg_id."\r\n");
|
|
}
|
|
$counter=$counter+1;
|
|
}
|
|
}
|
|
unset($regidArray);
|
|
unset($IDArray);
|
|
}
|
|
else{
|
|
$keep_going=0;
|
|
}
|
|
$counter_block=$counter_block+1;
|
|
}
|
|
$sql3=mysql_query("delete from gcm where to_be_deleted>=1");
|
|
|
|
|
|
$output[]="ok";
|
|
print(json_encode($output));
|
|
|
|
mysql_close();
|
|
?>
|