array( 'description' => 'Cette commande permet d\'envoyer les SMS programmés qui doivent l\'êtres.', 'requireds' => array(), 'optionals' => array(), ), 'parseReceivedSMS' => array( 'description' => 'Cette commande permet d\'enregistrer un SMS, et de l\'analyser pour voir s\'il contient une commande. Pour cela, il analyse le dossier PWD_RECEIVEDS', 'requireds' => array( ), 'optionals' => array(), ), 'sendTransfers' => array( 'description' => 'Cette commande permet d\'envoyer par mails les sms à transférés.', 'requireds' => [], 'optionals' => [], ), ); $message = "Vous êtes ici dans l'aide de la console.\n"; $message .= "Voici la liste des commandes disponibles : \n"; //On écrit les texte pour la liste des commandes dispos foreach ($commands as $name => $value) { $requireds = isset($value['requireds']) ? $value['requireds'] : array(); $optionals = isset($value['optionals']) ? $value['optionals'] : array(); $message .= ' ' . $name . ' : ' . $value['description'] . "\n"; $message .= " Arguments obligatoires : \n"; if (!count($requireds)) { $message .= " Pas d'argument\n"; } else { foreach ($requireds as $argument => $desc) { $message .= ' - ' . $argument . ' : ' . $desc . "\n"; } } $message .= " Arguments optionnels : \n"; if (!count($optionals)) { $message .= " Pas d'argument\n"; } else { foreach ($optionals as $argument => $desc) { $message .= ' - ' . $argument . ' : ' . $desc . "\n"; } } } echo $message; } /** * Cette fonction envoie tous les SMS programmés qui doivent l'être */ public function sendScheduleds() { //On créé l'objet de base de données global $db; for ($i = 0; $i < 30; $i++) { $now = new DateTime(); $now = $now->format('Y-m-d H:i:s'); echo "Début de l'envoi des SMS programmés\n"; $scheduleds = $db->getScheduledsNotInProgressBefore($now); $ids_scheduleds = array(); //On passe en cours de progression tous les SMS foreach ($scheduleds as $scheduled) { $ids_scheduleds[] = $scheduled['id']; } echo count($ids_scheduleds) . " SMS à envoyer ont été trouvés et ajoutés à la liste des SMS en cours d'envoi.\n"; $db->updateProgressScheduledsIn($ids_scheduleds, true); //Pour chaque SMS à envoyer foreach ($scheduleds as $scheduled) { $id_scheduled = $scheduled['id']; $text_sms = escapeshellarg($scheduled['content']); //On initialise les numéros auxquelles envoyer le SMS $numbers = array(); //On récupère les numéros pour le SMS et on les ajoute $target_numbers = $db->getNumbersForScheduled($id_scheduled); foreach ($target_numbers as $target_number) { $numbers[] = $target_number['number']; } //On récupère les contacts, et on ajoute les numéros $contacts = $db->getContactsForScheduled($id_scheduled); foreach ($contacts as $contact) { $numbers[] = $contact['number']; } //On récupère les groupes $groups = $db->getGroupsForScheduled($id_scheduled); foreach ($groups as $group) { //On récupère les contacts du groupe et on les ajoute aux numéros $contacts = $db->getContactsForGroup($group['id']); foreach ($contacts as $contact) { $numbers[] = $contact['number']; } } $smsStops = $db->getFromTableWhere('sms_stop'); foreach ($numbers as $number) { //Si les SMS STOP sont activés, on passe au numéro suivant si le numéro actuelle fait parti des SMS STOP if (RASPISMS_SETTINGS_SMS_STOP) { foreach ($smsStops as $smsStop) { if (!($number == $smsStop['number'])) { continue; } echo "Un SMS destiné au " . $number . " a été bloqué par SMS STOP\n"; continue(2); //On passe au numéro suivant ! } } echo " Envoi d'un SMS au " . $number . "\n"; //On ajoute le SMS aux SMS envoyés //Pour plus de précision, on remet la date à jour en réinstanciant l'objet DateTime (et on reformatte la date, bien entendu) $now = new DateTime(); $now = $now->format('Y-m-d H:i:s'); //On peut maintenant ajouter le SMS if (!$db->insertIntoTable('sendeds', ['at' => $now, 'target' => $number, 'content' => $scheduled['content'], 'before_delivered' => ceil(mb_strlen($scheduled['content'])/160)])) { echo 'Impossible d\'inserer le sms pour le numero ' . $number . "\n"; } $id_sended = $db->lastId(); //Commande qui envoie le SMS $commande_send_sms = 'gammu-smsd-inject TEXT ' . escapeshellarg($number) . ' -report -len ' . mb_strlen($text_sms) . ' -text ' . $text_sms; //Commande qui s'assure de passer le SMS dans ceux envoyés, et de lui donner le bon statut //On va liée les deux commandes pour envoyer le SMS puis le passer en echec $commande = '(' . $commande_send_sms . ') >/dev/null 2>/dev/null &'; exec($commande); //On execute la commande d'envoie d'un SMS } } echo "Tous les SMS sont en cours d'envoi.\n"; //Tous les SMS ont été envoyés. $db->deleteScheduledsIn($ids_scheduleds); //On dors 2 secondes sleep(2); } } /** * Cette fonction reçoit un SMS, et l'enregistre, en essayant dde trouver une commande au passage. */ public function parseReceivedSMS() { //On créer l'objet de base de données global $db; for ($i = 0; $i < 30; $i++) { foreach (scandir(PWD_RECEIVEDS) as $dir) { //Si le fichier est un fichier système, on passe à l'itération suivante if ($dir == '.' || $dir == '..') { continue; } echo "Analyse du SMS " . $dir . "\n"; //On récupère la date du SMS à la seconde près grâce au nom du fichier (Cf. parseSMS.sh) //Il faut mettre la date au format Y-m-d H:i:s $date = substr($dir, 0, 4) . '-' . substr($dir, 4, 2) . '-' . substr($dir, 6, 2) . ' ' . substr($dir, 8, 2) . ':' . substr($dir, 10, 2) . ':' . substr($dir, 12, 2); //On récupère le fichier, et on récupère la chaine jusqu'au premier ':' pour le numéro de téléphone source, et la fin pour le message $content_file = file_get_contents(PWD_RECEIVEDS . $dir); //Si on peux pas ouvrir le fichier, on quitte en logant une erreur if ($content_file == false) { $this->wlog('Unable to read file "' . $dir); die(4); } //On supprime le fichier. Si on n'y arrive pas, alors on log if (!unlink(PWD_RECEIVEDS . $dir)) { $this->wlog('Unable to delete file "' . $dir); die(8); } $content_file = explode(':', $content_file, 2); //Si on a pas passé de numéro ou de message, alors on lève une erreur if (!isset($content_file[0], $content_file[1])) { $this->wlog('Missing params in file "' . $dir); die(5); } $number = $content_file[0]; $number = internalTools::parsePhone($number); $text = $content_file[1]; //On gère les SMS STOP if (trim($text) == 'STOP') { echo 'STOP SMS detected ' . $number . "\n"; $this->wlog('STOP SMS detected ' . $number); $db->insertIntoTable('sms_stop', ['number' => $number]); continue; } //On gère les accusés de reception if (trim($text) == 'Delivered' || trim($text) == 'Failed') { echo 'Delivered or Failed SMS for ' . $number . "\n"; $this->wlog('Delivered or Failed SMS for ' . $number); //On récupère les SMS pas encore validé, uniquement sur les dernières 12h $now = new DateTime(); $interval = new DateInterval('P12H'); $sinceDate = $now->sub($interval)->format('Y-m-d H:i:s'); if (!$sendeds = $db->getFromTableWhere('sendeds', ['target' => $number, 'delivered' => false, 'failed' => false, '>at' => $sinceDate], 'at', false, 1)) { continue; } $sended = $sendeds[0]; //On gère les echecs if (trim($text) == 'Failed') { $db->updateTableWhere('sendeds', ['before_delivered' => 0, 'failed' => true], ['id' => $sended['id']]); echo "Sended SMS id " . $sended['id'] . " pass to failed status\n"; continue; } //On gère le cas des messages de plus de 160 caractères, lesquels impliquent plusieurs accusés if ($sended['before_delivered'] > 1) { $db->updateTableWhere('sendeds', ['before_delivered' => $sended['before_delivered'] - 1], ['id' => $sended['id']]); echo "Sended SMS id " . $sended['id'] . " before_delivered decrement\n"; continue; } //Si tout est bon, que nous avons assez d'accusés, nous validons ! $db->updateTableWhere('sendeds', ['before_delivered' => 0, 'delivered' => true], ['id' => $sended['id']]); echo "Sended SMS id " . $sended['id'] . " to delivered status\n"; continue; } if (!$number) { $this->wlog('Invalid phone number in file "' . $dir); die(6); } //On va vérifier si on a reçu une commande, et des identifiants $flags = internalTools::parseForFlag($text); //On créer le tableau qui permettra de stocker les commandes trouvées $found_commands = array(); //Si on reçu des identifiants if (array_key_exists('LOGIN', $flags) && array_key_exists('PASSWORD', $flags)) { //Si on a bien un utilisateur avec les identifiants reçus $user = $db->getUserFromEmail($flags['LOGIN']); $this->wlog('We found ' . count($user) . ' users'); if ($user && $user['password'] == sha1($flags['PASSWORD'])) { $this->wlog('Password is valid'); //On va passer en revue toutes les commandes, pour voir si on en trouve dans ce message $commands = $db->getAll('commands'); $this->wlog('We found ' . count($commands) . ' commands'); foreach ($commands as $command) { $command_name = mb_strtoupper($command['name']); if (array_key_exists($command_name, $flags)) { $this->wlog('We found command ' . $command_name); //Si la commande ne nécessite pas d'être admin, ou si on est admin if (!$command['admin'] || $user['admin']) { $this->wlog('And the count is ok'); $found_commands[$command_name] = PWD_SCRIPTS . $command['script'] . escapeshellcmd($flags[$command_name]); } } } } } //On va supprimer le mot de passe du SMS pour pouvoir l'enregistrer sans danger if (isset($flags['PASSWORD'])) { $text = str_replace($flags['PASSWORD'], '*****', $text); } //On map les données et on créer le SMS reçu $send_by = $number; $content = $text; $is_command = count($found_commands); if (!$db->insertIntoTable('receiveds', ['at' => $date, 'send_by' => $send_by, 'content' => $content, 'is_command' => $is_command])) { echo "Erreur lors de l'enregistrement du SMS\n"; $this->wlog('Unable to process the SMS in file "' . $dir); die(7); } //On insert le SMS dans le tableau des sms à envoyer par mail $db->insertIntoTable('transfers', ['id_received' => $db->lastId(), 'progress' => false]); //Chaque commande sera executée. foreach ($found_commands as $command_name => $command) { echo 'Execution de la commande : ' . $command_name . ' :: ' . $command . "\n"; exec($command); } } //On attend 2 secondes sleep(2); } } /** * Cette fonction permet d'envoyer par mail les sms à transférer */ public function sendTransfers () { if (!RASPISMS_SETTINGS_TRANSFER) { echo "Le transfer de SMS est désactivé ! \n"; return false; } global $db; $transfers = $db->getFromTableWhere('transfers', ['progress' => false]); $ids_transfers = []; $ids_receiveds = []; foreach ($transfers as $transfer) { $ids_transfers[] = $transfer['id']; $ids_receiveds[] = $transfer['id_received']; } $db->updateProgressTransfersIn($ids_transfers, true); $receiveds = $db->getReceivedsIn($ids_receiveds); $users = $db->getFromTableWhere('users', ['transfer' => true]); foreach ($users as $user) { foreach ($receiveds as $received) { echo "Transfer d'un SMS du " . $received['send_by'] . " à l'email " . $user['email']; $to = $user['email']; $subject = '[RaspiSMS] - Transfert d\'un SMS du ' . $received['send_by']; $message = "Le numéro " . $received['send_by'] . " vous a envoyé un SMS : \n" . $received['content']; $ok = mail($to, $subject, $message); echo " ... " . ($ok ? 'OK' : 'KO') . "\n"; } } $db->deleteTransfersIn($ids_transfers); } }