first refonte

controllers/publics/Discussion.php

@@ -0,0 +1,239 @@
+<?php
+namespace controllers\publics;
+	/**
+	 * Page des discussions
+	 */
+	class Discussion extends \Controller
+	{
+		/**
+		 * Cette fonction est appelée avant toute les autres : 
+		 * Elle vérifie que l'utilisateur est bien connecté
+		 * @return void;
+		 */
+		public function _before()
+		{
+            global $bdd;
+            global $model;
+            $this->bdd = $bdd;
+            $this->model = $model;
+
+            $this->internalSended = new \controllers\internals\Sended($this->bdd);
+            $this->internalScheduled = new \controllers\internals\Scheduled($this->bdd);
+            $this->internalReceived = new \controllers\internals\Received($this->bdd);
+            $this->internalContact = new \controllers\internals\Contact($this->bdd);
+
+			\controllers\internals\Tool::verify_connect();
+		}
+
+		/**
+		 * Cette fonction retourne toutes les discussions, sous forme d'un tableau permettant l'administration de ces contacts
+		 */	
+		public function list ()
+		{
+			$discussions = $this->internalReceived->get_discussions();
+
+			foreach ($discussions as $key => $discussion)
+			{
+                if (!$contact = $this->internalContact->get_by_number($discussion['number']))
+				{
+					continue;
+				}
+
+				$discussions[$key]['contact'] = $contact['name'];
+			}
+
+			$this->render('discussion/list', array(
+				'discussions' => $discussions,
+			));
+		}
+		
+		/**
+		 * Cette fonction permet d'afficher la discussion avec un numero
+		 * @param string $number : La numéro de téléphone avec lequel on discute
+		 */
+		public function show ($number)
+		{
+            $contact = $this->internalContact->get_by_number($number);
+
+
+			$this->render('discussion/show', array(
+				'number' => $number,
+				'contact' => $contact,
+			));
+		}
+
+		/**
+		 * Cette fonction récupère l'ensemble des messages pour un numéro, recçus, envoyés, en cours
+		 * @param string $number : Le numéro cible
+		 * @param string $transaction_id : Le numéro unique de la transaction ajax (sert à vérifier si la requete doit être prise en compte)
+		 */
+		function get_messages($number, $transaction_id)
+		{
+			$now = new \DateTime();
+			$now = $now->format('Y-m-d H:i:s');
+
+            $sendeds = $this->internalSended->get_by_target($number);
+            $receiveds = $this->internalReceived->get_by_send_by($number);
+			$scheduleds = $this->internalScheduled->get_before_date_for_number($now, $number);
+
+			$messages = [];
+
+			foreach ($sendeds as $sended)
+			{
+				$messages[] = array(
+					'date' => htmlspecialchars($sended['at']),
+					'text' => htmlspecialchars($sended['content']),
+					'type' => 'sended',
+					'status' => ($sended['delivered'] ? 'delivered' : ($sended['failed'] ? 'failed' : '')),
+				);
+			}
+
+			foreach ($receiveds as $received)
+			{
+				$messages[] = array(
+					'date' => htmlspecialchars($received['at']),
+					'text' => htmlspecialchars($received['content']),
+					'type' => 'received',
+					'md5'  => md5($received['at'] . $received['content']),
+				);
+			}
+
+			foreach ($scheduleds as $scheduled)
+			{
+				$messages[] = array(
+					'date' => htmlspecialchars($scheduled['at']),
+					'text' => htmlspecialchars($scheduled['content']),
+					'type' => 'inprogress',
+				);
+			}
+
+			//On va trier le tableau des messages
+			usort($messages, function($a, $b) {
+				return strtotime($a["date"]) - strtotime($b["date"]);
+			});
+
+			//On récupère uniquement les 25 derniers messages sur l'ensemble
+			$messages = array_slice($messages, -25);
+
+			echo json_encode(['transaction_id' => $transaction_id, 'messages' => $messages]);
+			return true;
+		}
+
+		/**
+		 * Cette fonction permet d'envoyer facilement un sms à un numéro donné
+		 * @param string $csrf : Le jeton csrf
+		 * @param string $_POST['content'] : Le contenu du SMS
+		 * @param string $_POST['numbers'] : Un tableau avec le numero des gens auxquel envoyer le sms
+		 * @return json : Le statut de l'envoi
+		 */
+		function send ($csrf)
+		{
+            $return = ['success' => true, 'message' => ''];
+
+			//On vérifie que le jeton csrf est bon
+			if (!$this->verifyCSRF($csrf))
+			{
+				$return['success'] = false;
+				$return['message'] = 'Jeton CSRF invalide';
+				echo json_encode($return);
+				return false;
+			}	
+
+			$now = new \DateTime();
+			$now = $now->format('Y-m-d H:i:s');
+            
+            $scheduled = [];
+			$scheduled['at'] = $now;
+            $scheduled['content'] = $_POST['content'] ?? '';
+            $numbers = $_POST['numbers'] ?? false;
+
+            if (!$numbers)
+            {
+				$return['success'] = false;
+                $return['message'] = 'Vous devez renseigner un numéro valide';
+				echo json_encode($return);
+				return false;
+            }
+
+			if (!$this->internalScheduled->create($scheduled, $numbers))
+			{
+				$return['success'] = false;
+				$return['message'] = 'Impossible de créer le SMS';
+				echo json_encode($return);
+				return false;
+			}
+
+			echo json_encode($return);
+			return true;
+		}
+
+		/**
+		 * Cette fonction retourne les id des sms qui sont envoyés
+		 * @return json : Tableau des ids des sms qui sont envoyés
+		 */
+		function checksendeds ()
+		{
+			$_SESSION['discussion_wait_progress'] = isset($_SESSION['discussion_wait_progress']) ? $_SESSION['discussion_wait_progress'] : [];
+
+            $scheduleds = $this->internalScheduled->get_by_ids($_SESSION['discussion_wait_progress']);
+
+			//On va chercher à chaque fois si on a trouvé le sms. Si ce n'est pas le cas c'est qu'il a été envoyé
+			$sendeds = [];
+			foreach ($_SESSION['discussion_wait_progress'] as $key => $id_scheduled)
+			{
+				$found = false;
+				foreach ($scheduleds as $scheduled)
+				{
+					if ($id == $scheduled['id'])
+					{
+						$found = true;
+					}
+				}
+
+				if (!$found)
+				{
+					unset($_SESSION['discussion_wait_progress'][$key]);
+					$sendeds[] = $id;
+				}
+			}	
+
+			echo json_encode($sendeds);
+			return true;
+		}
+
+		/**
+		 * Cette fonction retourne les messages reçus pour un numéro après la date $_SESSION['discussion_last_checkreceiveds']
+		 * @param string $number : Le numéro de téléphone pour lequel on veux les messages
+		 * @return json : Un tableau avec les messages
+		 */
+		function checkreceiveds ($number)
+		{
+			$now = new \DateTime();
+			$now = $now->format('Y-m-d H:i');
+			
+			$_SESSION['discussion_last_checkreceiveds'] = isset($_SESSION['discussion_last_checkreceiveds']) ? $_SESSION['discussion_last_checkreceiveds'] : $now;
+
+			$receiveds = $internalReceived->get_since_for_number_by_date($_SESSION['discussion_last_checkreceiveds'], $number);
+
+			//On va gérer le cas des messages en double en stockant ceux déjà reçus et en eliminant les autres
+			$_SESSION['discussion_already_receiveds'] = isset($_SESSION['discussion_already_receiveds']) ? $_SESSION['discussion_already_receiveds'] : [];
+
+			foreach ($receiveds as $key => $received)
+			{
+				//Sms jamais recu
+				if (array_search($received['id'], $_SESSION['discussion_already_receiveds']) === false)
+				{
+					$_SESSION['discussion_already_receiveds'][] = $received['id'];
+					continue;
+				}
+
+				//Sms déjà reçu => on le supprime des resultats
+				unset($receiveds[$key]);
+			}
+
+			//On met à jour la date de dernière verif
+			$_SESSION['discussion_last_checkreceiveds'] = $now;
+			
+			echo json_encode($receiveds);
+		}
+	}