STR_TO_DATE(:date, '%Y-%m-%d') GROUP BY at_ymd "; $params = array( 'date' => $date, ); return $this->runQuery($query, $params); } /** * Récupère SMS envoyé à partir de son id * @param int $id = L'id du SMS * @return array : Retourne le SMS */ public function getSendedFromId($id) { $query = " SELECT * FROM sendeds WHERE id = :id"; $params = array( 'id' => $id ); return $this->runQuery($query, $params); } /** * Insert un nouveau SMS envoyé * @param string $date : La date d'envoie du message * @param string $target : Numéro auquel a été envoyé le message * @param string $content : Texte du message * @return int : le nombre de SMS créés */ public function createSended($date, $target, $content) { $query = ' INSERT INTO sendeds(at, target, content) VALUES (:date, :target, :content) '; $params = array( 'date' => $date, 'target' => $target, 'content' => $content, ); return $this->runQuery($query, $params, self::ROWCOUNT); //On retourne le nombre de lignes ajoutés } /** * update un sended * @param int $id : L'id du sended à modifier * @param string $date : La nouvelle date du SMS * @param string $target : La nouvelle cible du SMS * @param string $content : Le nouveau contenu du SMS * @param string $success : Le nouveau statut du SMS * @return void */ public function updateSended($id, $date, $target, $content) { $query = ' UPDATE sendeds SET at = :date, target = :target, content = :content, WHERE id = :id '; $params = array( 'id' => $id, 'date' => $date, 'target' => $target, 'content' => $content, ); return $this->runQuery($query, $params, self::ROWCOUNT); } /*********************************/ /* PARTIE DES REQUETES RECEIVEDS */ /*********************************/ /** * Insert un nouveau SMS reçu * @param string $date : La date d'envoie du message * @param string $send_by : Numéro auquel depuis lequel le message a ete envoye * @param string $content : Texte du message * @param string $is_command : Commande reconnue * @return int : le nombre de SMS créés */ public function createReceived($date, $send_by, $content, $is_command) { $query = ' INSERT INTO receiveds(at, send_by, content, is_command) VALUES (:date, :send_by, :content, :is_command) '; $params = array( 'date' => $date, 'send_by' => $send_by, 'content' => $content, 'is_command' => $is_command, ); return $this->runQuery($query, $params, self::ROWCOUNT); //On retourne le nombre de lignes ajoutés } /** * Récupère les SMS reçus depuis une date * @param $date : La date depuis laquelle on veux les SMS (au format 2014-10-25) * @return array : Tableau avec tous les SMS depuis la date */ public function getNbReceivedsSinceGroupDay($date) { $query = " SELECT COUNT(id) as nb, DATE_FORMAT(at, '%Y-%m-%d') as at_ymd FROM receiveds WHERE at > STR_TO_DATE(:date, '%Y-%m-%d') GROUP BY at_ymd "; $params = array( 'date' => $date, ); return $this->runQuery($query, $params); } /******************************/ /* PARTIE DES REQUETES EVENTS */ /******************************/ /** * Récupère les evenements enregistrés depuis une date * @param $date : La date depuis laquelle on veux les evenements (au format 2014-10-25) * @return array : Tableau avec tous les evenements depuis la date */ public function getEventsSince($date) { $query = " SELECT * FROM events WHERE at > STR_TO_DATE(:date, '%Y-%m-%d') "; $params = array( 'date' => $date, ); return $this->runQuery($query, $params); } /** * Enregistre un nouvel évenement * @param string $type = Type d'evenement enregistré * @param string $text = Texte de l'évenement (max 255chars) * @return int = Nombre de lignes insérées */ public function createEvent($type = '', $text = '') { $query = ' INSERT INTO events(type, at, text) VALUES (:type, NOW(), :text) '; $params = array( 'type' => $type, 'text' => $text ); return $this->runQuery($query, $params, self::ROWCOUNT); } /********************************/ /* PARTIE DES REQUETES CONTACTS */ /********************************/ /** * Supprime tous les contacts dont l'id fait partie du tableau fourni * @param $contacts_ids : Tableau des id des contacts à supprimer * @return int : Nombre de lignes supprimées */ public function deleteContactsIn($contacts_ids) { $query = " DELETE FROM contacts WHERE id "; //On génère la clause IN et les paramètres adaptés depuis le tableau des id $generted_in = $this->generateInFromArray($contacts_ids); $query .= $generted_in['QUERY']; $params = $generted_in['PARAMS']; return $this->runQuery($query, $params, self::ROWCOUNT); } /** * Compte le nombre de contacts * @return int : le nombre de contacts */ public function countContacts() { $query = ' SELECT COUNT(id) as nb FROM contacts '; $params = array(); $donnees = $this->runQuery($query, $params, self::FETCH); return $donnees['nb']; } /** * Insert un contact * @param string $nom : Le nom du nouveau contact * @param string $number : Le numéro du nouveau contact * @return int : le nombre de contacts */ public function createContact($name, $number) { $query = ' INSERT INTO contacts(name, number) VALUES (:name, :number) '; $params = array( 'name' => $name, 'number' => $number, ); return $this->runQuery($query, $params, self::ROWCOUNT); } /** * Récupère un contact à partir de son nom * @param string $name = Le nom du contact * @return array : Retourne le contact */ public function getContactFromName($name) { $query = " SELECT * FROM contacts WHERE name = :name"; $params = array( 'name' => $name ); return $this->runQuery($query, $params, self::FETCH); } /** * Récupère les contacts dont l'id fait partie de la liste fournie * @param array $contacts_ids = Tableau des id des contacts voulus * @return array : Retourne un tableau avec les contacts adaptés */ public function getContactsIn($contacts_ids) { $query = " SELECT * FROM contacts WHERE id "; //On génère la clause IN et les paramètres adaptés depuis le tableau des id $generted_in = $this->generateInFromArray($contacts_ids); $query .= $generted_in['QUERY']; $params = $generted_in['PARAMS']; return $this->runQuery($query, $params); } /** * update un contact * @param int $id : L'id du contact à modifier * @param string $name : Le nouveau nom du contact * @param string $number : Le nouveau numéro du contact * @return void */ public function updateContact($id, $name, $number) { $query = ' UPDATE contacts SET name = :name, number = :number WHERE id = :id '; $params = array( 'id' => $id, 'name' => $name, 'number' => $number, ); return $this->runQuery($query, $params, self::ROWCOUNT); } /******************************/ /* PARTIE DES REQUETES GROUPS */ /******************************/ /** * Récupère un group à partir de son nom * @param string $name = Le nom du group * @return array : Retourne le group */ public function getGroupFromName($name) { $query = " SELECT * FROM groups WHERE name = :name"; $params = array( 'name' => $name ); return $this->runQuery($query, $params, self::FETCH); } /** * Insert un group * @param string $nom : Le nom du nouveau group * @return int : le nombre de lignes crées */ public function createGroup($name) { $query = ' INSERT INTO groups(name) VALUES (:name) '; $params = array( 'name' => $name, ); return $this->runQuery($query, $params, self::ROWCOUNT); } /** * update un groupe * @param int $id : L'id du groupe à modifier * @param string $name : Le nouveau nom du groupe * @return int : Le nombre de lignes modifiés */ public function updateGroup($id, $name) { $query = ' UPDATE groups SET name = :name WHERE id = :id '; $params = array( 'id' => $id, 'name' => $name, ); return $this->runQuery($query, $params, self::ROWCOUNT); } /** * Compte le nombre de groups * @return int : le nombre de groups */ public function countGroups() { $query = ' SELECT COUNT(id) as nb FROM groups '; $params = array(); $donnees = $this->runQuery($query, $params, self::FETCH); return $donnees['nb']; } /** * Récupère les groupes dont l'id fait partie de la liste fournie * @param array $groups_ids = Tableau des id des groupes voulus * @return array : Retourne un tableau avec les groupes adaptés */ public function getGroupsIn($groups_ids) { $query = " SELECT * FROM groups WHERE id "; //On génère la clause IN et les paramètres adaptés depuis le tableau des id $generted_in = $this->generateInFromArray($groups_ids); $query .= $generted_in['QUERY']; $params = $generted_in['PARAMS']; return $this->runQuery($query, $params); } /** * Supprime tous les groupes dont l'id fait partie du tableau fourni * @param $contacts_ids : Tableau des id des groups à supprimer * @return int : Nombre de lignes supprimées */ public function deleteGroupsIn($groups_ids) { $query = " DELETE FROM groups WHERE id "; //On génère la clause IN et les paramètres adaptés depuis le tableau des id $generted_in = $this->generateInFromArray($groups_ids); $query .= $generted_in['QUERY']; $params = $generted_in['PARAMS']; return $this->runQuery($query, $params, self::ROWCOUNT); } /***************************************/ /* PARTIE DES REQUETES GROUPS_CONTACTS */ /***************************************/ /** * Retourne tous les contacts pour un groupe donnée * @param int $id_group : L'id du groupe * @return array : Tous les contacts compris dans le groupe */ public function getContactsForGroup($id_group) { $query = ' SELECT con.id as id, con.name as name, con.number as number FROM groups_contacts as g_c JOIN contacts as con ON (g_c.id_contact = con.id) WHERE(g_c.id_group = :id_group) '; $params = array( 'id_group' => $id_group, ); return $this->runQuery($query, $params); } /* Insert un groups_contacts * @param string $id_group : L'id du group * @param string $id_contact : L'id du contact * @return int : le nombre de lignes crées */ public function createGroups_contacts($id_group, $id_contact) { $query = ' INSERT INTO groups_contacts(id_group, id_contact) VALUES (:id_group, :id_contact) '; $params = array( 'id_group' => $id_group, 'id_contact' => $id_contact, ); return $this->runQuery($query, $params, self::ROWCOUNT); } /** * Récupère tout les groupes, avec le nombre de contact dans chacun * @return array : Tableau avec tous les groupes et le nombre de contacts liés */ public function getGroupsWithContactsNb($order_by = '', $desc = false, $limit = false, $offset = false) { $query = " SELECT gro.id as id, gro.name as name, COUNT(g_c.id) as nb_contacts FROM groups as gro LEFT JOIN groups_contacts as g_c ON (g_c.id_group = gro.id) GROUP BY id "; if ($order_by) { if($this->fieldExist($order_by, 'contacts')) { $query .= ' ORDER BY '. $order_by; if ($desc) { $query .= ' DESC'; } } } if ($limit !== false) { $query .= ' LIMIT :limit'; if ($offset !== false) { $query .= ' OFFSET :offset'; } } $req = $this->bdd->prepare($query); if ($limit !== false) { $req->bindParam(':limit', $limit, PDO::PARAM_INT); if ($offset !== false) { $req->bindParam(':offset', $offset, PDO::PARAM_INT); } } $req->execute(); return $req->fetchAll(); } /** * Supprime tous les groups_contacts pour un groupe donné * @param int $id : L'id du groupe pour lequel on doit supprimer les groups_contacts * @return int Le nombre de lignes supprimées */ public function deleteGroups_contactsForGroup($id_group) { $query = ' DELETE FROM groups_contacts WHERE id_group = :id_group '; $params = array( 'id_group' => $id_group ); return $this->runQuery($query, $params, self::ROWCOUNT); } /**********************************/ /* PARTIE DES REQUETES SCHEDULEDS */ /**********************************/ /** * Récupère SMS programmé à partir de son id * @param int $id = L'id du SMS programmé * @return array : Retourne le contact */ public function getScheduledFromId($id) { $query = " SELECT * FROM scheduleds WHERE id = :id"; $params = array( 'id' => $id ); return $this->runQuery($query, $params, self::FETCH); } /** * Récupère les sms programmés dont l'id fait partie de la liste fournie * @param array $scheduleds_ids = Tableau des id des sms voulus * @return array : Retourne un tableau avec les groupes adaptés */ public function getScheduledsIn($scheduleds_ids) { $query = " SELECT * FROM scheduleds WHERE id "; //On génère la clause IN et les paramètres adaptés depuis le tableau des id $generted_in = $this->generateInFromArray($scheduleds_ids); $query .= $generted_in['QUERY']; $params = $generted_in['PARAMS']; return $this->runQuery($query, $params); } /** * Récupère tout les sms programmés non en cours, et dont la date d'envoie inférieure à celle renseignée * @param string $date : Date avant laquelle on veux les sms * @return array : Tableau avec les sms programmés demandés */ public function getScheduledsNotInProgressBefore($date) { $query = " SELECT * FROM scheduleds WHERE progress = 0 AND at <= :date "; $params = array( 'date' => $date, ); return $this->runQuery($query, $params); } /** * Insert un sms * @param string $date : La date d'envoi du SMS * @param string $content : Le contenu du SMS * @return int : le nombre de lignes crées */ public function createScheduleds($date, $content) { $query = ' INSERT INTO scheduleds(at, content, progress) VALUES (:date, :content, :progress) '; $params = array( 'date' => $date, 'content' => $content, 'progress' => false, ); return $this->runQuery($query, $params, self::ROWCOUNT); } /** * update un sms programmé * @param int $id : L'id du sms à modifier * @param string $date : La nouvelle date du sms * @param string $content : Le nouveau contenu du sms * @param boolean $progress : Le nouveau statut de la progression du sms * @return int : Le nombre de lignes modifiées */ public function updateScheduled($id, $date, $content, $progress) { $query = ' UPDATE scheduleds SET at = :date, content = :content, progress = :progress WHERE id = :id '; $params = array( 'id' => $id, 'date' => $date, 'content' => $content, 'progress' => $progress, ); return $this->runQuery($query, $params, self::ROWCOUNT); } /** * Supprime tous les sms programmés dont l'id fait partie du tableau fourni * @param $contacts_ids : Tableau des id des sms à supprimer * @return int : Nombre de lignes supprimées */ public function deleteScheduledsIn($scheduleds_ids) { $query = " DELETE FROM scheduleds WHERE id "; //On génère la clause IN et les paramètres adaptés depuis le tableau des id $generted_in = $this->generateInFromArray($scheduleds_ids); $query .= $generted_in['QUERY']; $params = $generted_in['PARAMS']; return $this->runQuery($query, $params, self::ROWCOUNT); } /** * Compte le nombre de sms programmés * @return int : le nombre de sms programmés */ public function countScheduleds() { $query = ' SELECT COUNT(id) as nb FROM scheduleds '; $params = array(); $donnees = $this->runQuery($query, $params, self::FETCH); return $donnees['nb']; } /********************************/ /* PARTIE DES REQUETES COMMANDS */ /********************************/ /** * Récupère les commands dont l'id fait partie de la liste fournie * @param array $commands_ids = Tableau des id des commands voulus * @return array : Retourne un tableau avec les commands adaptés */ public function getCommandsIn($commands_ids) { $query = " SELECT * FROM commands WHERE id "; //On génère la clause IN et les paramètres adaptés depuis le tableau des id $generted_in = $this->generateInFromArray($commands_ids); $query .= $generted_in['QUERY']; $params = $generted_in['PARAMS']; return $this->runQuery($query, $params); } /** * Insert un commande * @param string $name : Le nom de la command * @param string $script : Le chemin du script à appeler * @param string $admin : Défini si il est nécessaire d'être admin * @return int : le nombre de commandes ajoutées */ public function createCommand($name, $script, $admin) { $query = ' INSERT INTO commands(name, script, admin) VALUES (:name, :script, :admin) '; $params = array( 'name' => $name, 'script' => $script, 'admin' => $admin, ); return $this->runQuery($query, $params, self::ROWCOUNT); } /** * update une commande * @param int $id : L'id de la commande à modifier * @param string $name : Le nouveau nom de la commande * @param string $script : Le nouveau script de la commande * @param string $name : Nouvel état de la necessité des droits administrateur * @return int : Le nombre de lignes modifiée */ public function updateCommand($id, $name, $script, $admin) { $query = ' UPDATE commands SET name = :name, script = :script, admin = :admin WHERE id = :id '; $params = array( 'id' => $id, 'name' => $name, 'script' => $script, 'admin' => $admin, ); return $this->runQuery($query, $params, self::ROWCOUNT); } /** * Supprime tous les commands dont l'id fait partie du tableau fourni * @param $commands_ids : Tableau des id des commands à supprimer * @return int : Nombre de lignes supprimées */ public function deleteCommandsIn($commands_ids) { $query = " DELETE FROM commands WHERE id "; //On génère la clause IN et les paramètres adaptés depuis le tableau des id $generted_in = $this->generateInFromArray($commands_ids); $query .= $generted_in['QUERY']; $params = $generted_in['PARAMS']; return $this->runQuery($query, $params, self::ROWCOUNT); } /** * Compte le nombre de commands * @return int : le nombre de commands */ public function countCommands() { $query = ' SELECT COUNT(id) as nb FROM commands '; $params = array(); $donnees = $this->runQuery($query, $params, self::FETCH); return $donnees['nb']; } /*******************************************/ /* PARTIE DES REQUETES SCHEDULEDS_CONTACTS */ /*******************************************/ /** * Créer un nouveau scheduleds_contacts * @param int $id_scheduled : L'id du SMS programmé lié * @param int $id_contact : L'id du contact lié * @return int : Le nombre de lignes insérées */ public function createScheduleds_contacts($id_scheduled, $id_contact) { $query = ' INSERT INTO scheduleds_contacts(id_scheduled, id_contact) VALUES (:id_scheduled, :id_contact) '; $params = array( 'id_scheduled' => $id_scheduled, 'id_contact' => $id_contact, ); return $this->runQuery($query, $params, self::ROWCOUNT); } /** * Retourne tous les contacts pour un sms programmé donnée * @param int $id_sms : L'id du sms * @return array : Tous les contacts compris dans le schedulede */ public function getContactsForScheduled($id_scheduled) { $query = ' SELECT con.id as id, con.name as name, con.number as number FROM scheduleds_contacts as s_c JOIN contacts as con ON (s_c.id_contact = con.id) WHERE(s_c.id_scheduled = :id_scheduled) '; $params = array( 'id_scheduled' => $id_scheduled, ); return $this->runQuery($query, $params); } /** * Supprime tous les scheduleds_contacts pour un sms donné * @param int $id_scheduled : L'id du sms pour lequel on doit supprimer les scheduleds_contacts * @return int Le nombre de lignes supprimées */ public function deleteScheduleds_contactsForScheduled($id_scheduled) { $query = ' DELETE FROM scheduleds_contacts WHERE id_scheduled = :id_scheduled '; $params = array( 'id_scheduled' => $id_scheduled ); return $this->runQuery($query, $params, self::ROWCOUNT); } /** * Change le statut des scheduleds dont l'id est fourni dans $scheduleds_id * @param array $scheduleds_ids = Tableau des id des sms voulus * @return int : Retourne le nombre de lignes mises à jour */ public function updateProgressScheduledsIn($scheduleds_ids, $progress) { $query = " UPDATE scheduleds SET progress = :progress WHERE id "; //On génère la clause IN et les paramètres adaptés depuis le tableau des id $generted_in = $this->generateInFromArray($scheduleds_ids); $query .= $generted_in['QUERY']; $params = $generted_in['PARAMS']; $params['progress'] = (boolean)$progress; return $this->runQuery($query, $params, self::ROWCOUNT); } /******************************************/ /* PARTIE DES REQUETES SCHEDULEDS_NUMBERS */ /******************************************/ /** * Créer un nouveau scheduleds_numbers * @param int $id_scheduled : L'id du SMS programmé lié * @param string $number : Le numéro de téléphone lié * @return int : Le nombre de lignes insérées */ public function createScheduleds_numbers($id_scheduled, $number) { $query = ' INSERT INTO scheduleds_numbers(id_scheduled, number) VALUES (:id_scheduled, :number) '; $params = array( 'id_scheduled' => $id_scheduled, 'number' => $number, ); return $this->runQuery($query, $params, self::ROWCOUNT); } /** * Supprime tous les scheduleds_numbers pour un sms donné * @param int $id_scheduled : L'id du sms pour lequel on doit supprimer les scheduleds_numbers * @return int Le nombre de lignes supprimées */ public function deleteScheduleds_numbersForScheduled($id_scheduled) { $query = ' DELETE FROM scheduleds_numbers WHERE id_scheduled = :id_scheduled '; $params = array( 'id_scheduled' => $id_scheduled ); return $this->runQuery($query, $params, self::ROWCOUNT); } /** * Retourne tous les numéros pour un scheduled donné * @param int $id_scheduled : L'id du scheduled * @return array : Tous les numéro compris dans le scheduled */ public function getNumbersForScheduled($id_scheduled) { $query = ' SELECT * FROM scheduleds_numbers WHERE id_scheduled = :id_scheduled '; $params = array( 'id_scheduled' => $id_scheduled, ); return $this->runQuery($query, $params); } /*****************************************/ /* PARTIE DES REQUETES SCHEDULEDS_GROUPS */ /*****************************************/ /** * Créer un nouveau scheduleds_groups * @param int $id_scheduled : L'id du SMS programmé lié * @param int $id_group : L'id du group lié * @return int : Le nombre de lignes insérées */ public function createScheduleds_groups($id_scheduled, $id_group) { $query = ' INSERT INTO scheduleds_groups(id_scheduled, id_group) VALUES (:id_scheduled, :id_group) '; $params = array( 'id_scheduled' => $id_scheduled, 'id_group' => $id_group, ); return $this->runQuery($query, $params, self::ROWCOUNT); } /** * Supprime tous les scheduleds_groups pour un sms donné * @param int $id_scheduled : L'id du sms pour lequel on doit supprimer les scheduleds_groups * @return int Le nombre de lignes supprimées */ public function deleteScheduleds_groupsForScheduled($id_scheduled) { $query = ' DELETE FROM scheduleds_groups WHERE id_scheduled = :id_scheduled '; $params = array( 'id_scheduled' => $id_scheduled ); return $this->runQuery($query, $params, self::ROWCOUNT); } /** * Retourne tous les groupes pour un scheduled donnée * @param int $id_scheduled : L'id du schedulede * @return array : Tous les groupes compris dans le scheduled */ public function getGroupsForScheduled($id_scheduled) { $query = ' SELECT gro.id as id, gro.name as name FROM scheduleds_groups as s_g JOIN groups as gro ON (s_g.id_group = gro.id) WHERE(s_g.id_scheduled = :id_scheduled) '; $params = array( 'id_scheduled' => $id_scheduled, ); return $this->runQuery($query, $params); } /*****************************/ /* PARTIE DES REQUETES USERS */ /*****************************/ /** * Récupère un utilisateur à partir de son email * @param string $email = L'email de l'utilisateur * @return array : Retourne l'utilisateur */ public function getUserFromEmail($email) { $query = " SELECT * FROM users WHERE email = :email"; $params = array( 'email' => $email ); return $this->runQuery($query, $params, self::FETCH); } /** * update un user * @param int $id : L'id du user à modifier * @param string $email : Le nouveau email du user * @param string $password : Le nouveau password du user * @param string $admin : Le nouveau statut admin du user * @return void */ public function updateUser($id, $email, $password, $admin) { $query = ' UPDATE users SET email = :email, password = :password, admin = :admin WHERE id = :id '; $params = array( 'id' => $id, 'email' => $email, 'password' => $password, 'admin' => $admin, ); return $this->runQuery($query, $params, self::ROWCOUNT); } /** * Insert un utilisateur * @param string $email : L'adresse email du nouvel utilisateur * @param string $password : Le mot de passe de l'utilisateur * @param boolean $admin : Le statut de l'utilisateur * @return int : le nombre d'utilisateurs ajoutés */ public function createUser($email, $password, $admin) { $query = ' INSERT INTO users(email, password, admin) VALUES (:email, :password, :admin) '; $params = array( 'email' => $email, 'password' => $password, 'admin' => $admin, ); return $this->runQuery($query, $params, self::ROWCOUNT); } /** * Supprime tous les users dont l'id fait partie du tableau fourni * @param $users_ids : Tableau des id des users à supprimer * @return int : Nombre de lignes supprimées */ public function deleteUsersIn($users_ids) { $query = " DELETE FROM users WHERE id "; //On génère la clause IN et les paramètres adaptés depuis le tableau des id $generted_in = $this->generateInFromArray($users_ids); $query .= $generted_in['QUERY']; $params = $generted_in['PARAMS']; return $this->runQuery($query, $params, self::ROWCOUNT); } }