fusionpbx-app-messages/resources/classes/messages.php

<?php

//define the messages classs
if (!class_exists('messages')) {
	class messages {

						/**
		* declare public variables
		*/
		public $destinations;
		public $domain_uuid;
		public $message_date_begin;
		public $message_date_end;
		public $quick_select;

		/**
		 * declare private variables
		 */
		private $app_name;
		private $app_uuid;
		private $permission_prefix;
		private $list_page;
		private $table;
		private $uuid_prefix;
		private $settings;

		/**
		 * called when the object is created
		 */
		public function __construct($settings = null) {
			if (is_null($this->domain_uuid)) {
				$this->domain_uuid = $_SESSION['domain_uuid'];
			}

			if (!isset($settings)) {
				$this->settings = new settings();
			}

			//assign private variables
				$this->app_name = 'messages';
				$this->app_uuid = '4a20815d-042c-47c8-85df-085333e79b87';
				$this->permission_prefix = 'message_';
				$this->list_page = 'messages_log.php';
				$this->table = 'messages';
				$this->uuid_prefix = 'message_';

		}

		/**
		 * called when there are no references to a particular object
		 * unset the variables used in the class
		 */
		public function __destruct() {
			foreach ($this as $key => $value) {
				unset($this->$key);
			}
		}

		/**
		 * delete records
		 */
		public function delete($records) {
			if (permission_exists($this->permission_prefix.'delete')) {

				//add multi-lingual support
					$language = new text;
					$text = $language->get();

				//validate the token
					$token = new token;
					if (!$token->validate($_SERVER['PHP_SELF'])) {
						message::add($text['message-invalid_token'],'negative');
						header('Location: '.$this->list_page);
						exit;
					}

				//delete multiple records
					if (is_array($records) && @sizeof($records) != 0) {

						//build the delete array
							foreach ($records as $x => $record) {
								if ($record['checked'] == 'true' && is_uuid($record['uuid'])) {
									$array[$this->table][$x][$this->uuid_prefix.'uuid'] = $record['uuid'];
									$array[$this->table][$x]['domain_uuid'] = $_SESSION['domain_uuid'];
									$array['message_media'][$x][$this->uuid_prefix.'uuid'] = $record['uuid'];
									$array['message_media'][$x]['domain_uuid'] = $_SESSION['domain_uuid'];
								}
							}

						//delete the checked rows
							if (is_array($array) && @sizeof($array) != 0) {

								//grant temporary permissions
									$p = permissions::new();
									$p->add('message_media_delete', 'temp');

								//execute delete
									$database = new database;
									$database->app_name = $this->app_name;
									$database->app_uuid = $this->app_uuid;
									$database->delete($array);
									unset($array);

								//revoke temporary permissions
									$p->delete('message_media_delete', 'temp');

								//set message
									message::add($text['message-delete']);
							}
							unset($records);
					}
			}
		} //method

		/**
		 * send a message
		 */
		public function send($message_type, $message_from, $message_to, $message_text, $message_media = '') {

			//santize the data
				$message_type = 'sms';
				$message_from = preg_replace("/[^\+?0-9]/", "", $message_from);
				$message_to = preg_replace('/[^\+?0-9]/', '', $message_to);

			//error check
				if (!is_numeric($message_from) || !is_numeric($message_to)) {
					exit;
				}

			//handle media (if any)
				if (!empty($message_media) && is_array($message_media) && @sizeof($message_media) != 0) {
					// reorganize media array, ignore errored files
					$f = 0;
					foreach ($message_media['error'] as $index => $error) {
						if ($error == 0) {
							$tmp_media[$f]['uuid'] = uuid();
							$tmp_media[$f]['name'] = $message_media['name'][$index];
							$tmp_media[$f]['type'] = $message_media['type'][$index];
							$tmp_media[$f]['tmp_name'] = $message_media['tmp_name'][$index];
							$tmp_media[$f]['size'] = $message_media['size'][$index];
							$f++;
						}
					}
					$message_media = $tmp_media;
					unset($tmp_media, $f);
				}
				$message_type = is_array($message_media) && @sizeof($message_media) != 0 ? 'mms' : 'sms';

			//get the contact uuid
				//$sql = "select c.contact_uuid ";
				//$sql .= "from v_contacts as c, v_contact_phones as p ";
				//$sql .= "where p.contact_uuid = c.contact_uuid ";
				//$sql .= "and p.phone_number like :phone_number ";
				//$sql .= "and c.domain_uuid = :domain_uuid ";
				//$parameters['phone_number'] = '%'.$message_to.'%';
				//$parameters['domain_uuid'] = $domain_uuid;
				//$database = new database;
				//$contact_uuid = $database->select($sql, $parameters, 'column');
				//unset($sql, $parameters);

			//prepare message to send
				$message['to'] = $message_to;
				$message['text'] = $message_text;
				//if (is_array($message_media) && @sizeof($message_media) != 0) {
				//	$protocol = (!empty($_SERVER['HTTPS']) && $_SERVER['HTTPS'] !== 'off' || $_SERVER['SERVER_PORT'] == 443) ? 'https://' : 'http://';
				//	foreach ($message_media as $index => $media) {
				//		$path = $protocol.$_SERVER['HTTP_HOST'].'/app/messages/message_media.php?id='.$media['uuid'].'&action=download&.'.strtolower(pathinfo($media['name'], PATHINFO_EXTENSION));
				//		$message['media'][] = $path;
				//	}
				//}
				$http_content = json_encode($message);

			//use the phone number to get the destination details
				$sql = "SELECT * FROM v_destinations ";
				$sql .= "WHERE ( ";
				$sql .= "	destination_prefix || destination_area_code || destination_number = :destination_number ";
				$sql .= "	OR destination_trunk_prefix || destination_area_code || destination_number = :destination_number ";
				$sql .= "	OR destination_prefix || destination_number = :destination_number ";
				$sql .= "	OR '+' || destination_prefix || destination_number = :destination_number ";
				$sql .= "	OR '+' || destination_prefix || destination_area_code || destination_number = :destination_number ";
				$sql .= "	OR destination_area_code || destination_number = :destination_number ";
				$sql .= "	OR destination_number = :destination_number ";
				$sql .= ") ";
				$sql .= "and provider_uuid is not null ";
				$sql .= "and destination_enabled = 'true'; ";
				$parameters['destination_number'] = $message_from;
				// if (!empty($debug)) {
				// 	file_put_contents($log_file, "sql: ".$sql."\n", FILE_APPEND);
				// 	//echo $sql."\n";
				// 	file_put_contents($log_file, print_r($parameters, true)."\n", FILE_APPEND);
				// }
				$database = new database;
				$row = $database->select($sql, $parameters, 'row');
				//view_array($row, false);
				if (isset($row)) {
					$domain_uuid = $row['domain_uuid'];
					$provider_uuid = $row['provider_uuid'];
					$user_uuid = $row['user_uuid'];
					$group_uuid = $row['group_uuid'];
					unset($row);
				}
				//if (!empty($debug)) {
					// view_array($row,false);
					//file_put_contents($log_file, print_r($row, true)."\n", FILE_APPEND);
				//}
				unset($sql, $parameters);

			//debug
				//echo "provider_uuid: ".$provider_uuid."\n";

			//get the provider settings
				$sql = "select provider_setting_category, provider_setting_subcategory, ";
				$sql .= "provider_setting_name, provider_setting_value, provider_setting_order \n";
				$sql .= "from v_provider_settings \n";
				$sql .= "where provider_uuid = :provider_uuid \n";
				$sql .= "and provider_setting_category = 'outbound' \n";
				$sql .= "and provider_setting_enabled = 'true'; \n";
				$parameters['provider_uuid'] = $provider_uuid;
				$database = new database;
				$provider_settings = $database->select($sql, $parameters, 'all');
				unset($parameters);
				//echo $sql;
				//print_r($parameters);
				//print_r($provider_settings);
				//
				//echo "\n";

			//process the provider settings array
				foreach ($provider_settings as $row) {
					//format the phone numbers
					if ($row['provider_setting_subcategory'] == 'format') {
						if ($row['provider_setting_name'] == 'message_from') {
							$message_from = format_string($row['provider_setting_value'], $message_from);
						}
						if ($row['provider_setting_name'] == 'message_to') {
							$message_to = format_string($row['provider_setting_value'], $message_to);
						}
					}
				}

			//continue only if message from and to have a value
				if (!isset($message_from) || !isset($message_to)) {
					return false;
				}

			//add the permission
				$p = permissions::new();
				$p->add('message_queue_add', 'temp');

			//build the message array
				$message_queue_uuid = uuid();
				$array['message_queue'][0]['domain_uuid'] = $_SESSION["domain_uuid"];
				$array['message_queue'][0]['message_queue_uuid'] = $message_queue_uuid;
				$array['message_queue'][0]['user_uuid'] = $_SESSION["user_uuid"];
				$array['message_queue'][0]['group_uuid'] = $group_uuid;
				//$array['message_queue'][0]['contact_uuid'] = $contact_uuid;
				$array['message_queue'][0]['provider_uuid'] = $provider_uuid;
				$array['message_queue'][0]['hostname'] = system('hostname');
				$array['message_queue'][0]['message_status'] = 'waiting';
				$array['message_queue'][0]['message_type'] = $message_type;
				$array['message_queue'][0]['message_direction'] = 'outbound';
				$array['message_queue'][0]['message_date'] = 'now()';
				$array['message_queue'][0]['message_from'] = $message_from;
				$array['message_queue'][0]['message_to'] = $message_to;
				$array['message_queue'][0]['message_text'] = $message_text;
				//view_array($array);

			//build message media array (if necessary)
				$media_exists = false;
				if (is_array($message_media) && @sizeof($message_media) != 0) {
					$protocol = (!empty($_SERVER['HTTPS']) && $_SERVER['HTTPS'] !== 'off' || $_SERVER['SERVER_PORT'] == 443) ? 'https://' : 'http://';
					foreach($message_media as $index => $media) {
						//create the media path
						$media_url = $protocol.$_SERVER['HTTP_HOST'].'/app/messages/media/'.$media['uuid'].'/'.$media['name'];

						//add the media to the array
						$array['message_media'][$index]['message_media_uuid'] = $media['uuid'];
						$array['message_media'][$index]['message_uuid'] = $message_queue_uuid;
						$array['message_media'][$index]['domain_uuid'] = $_SESSION["domain_uuid"];
						$array['message_media'][$index]['user_uuid'] = $_SESSION["user_uuid"];
						$array['message_media'][$index]['message_media_name'] = $media['name'];
						$array['message_media'][$index]['message_media_type'] = strtolower(pathinfo($media['name'], PATHINFO_EXTENSION));
						$array['message_media'][$index]['message_media_date'] = 'now()';
						$array['message_media'][$index]['message_media_url'] = $media_url;
						$array['message_media'][$index]['message_media_content'] = base64_encode(file_get_contents($media['tmp_name']));
					}
					$p->add('message_media_add', 'temp');
					$media_exists = true;
				}

			//no message or media to send - do not send
				//if ($message_text == '' && !$media_exists) {
				//	return;
				//}

			//save to the data
				$database = new database;
				$database->app_name = 'messages';
				$database->app_uuid = '4a20815d-042c-47c8-85df-085333e79b87';
				$database->save($array, false);
				//$message = $database->message;
				//view_array($message, true);
				unset($array);

			//remove the permission
				$p->delete('message_queue_add', 'temp');
				$p->delete('message_media_add', 'temp');

		} //method

		public function message_summary() {
			//set the time zone
				if (!empty($this->settings->get('domain', 'time_zone'))) {
					$time_zone = $this->settings->get('domain', 'time_zone');
				}
				else {
					$time_zone = date_default_timezone_get();
				}

			//set the time zone for php
				date_default_timezone_set($time_zone);
				
			//build the date range
				if (!empty($this->message_date_begin) || !empty($this->message_date_end)) {
					unset($this->quick_select);
					if (strlen($this->message_date_begin) > 0 && !empty($this->message_date_end)) {
						$sql_date_range = " and message_date between :message_date_begin::timestamptz and :message_date_end::timestamptz \n";
						$parameters['message_date_begin'] = $this->message_date_begin.':00.000 '.$time_zone;
						$parameters['message_date_end'] = $this->message_date_end.':59.999 '.$time_zone;
					}
					else {
						if (!empty($this->message_date_begin)) {
							$sql_date_range = "and message_date >= :message_date_begin::timestamptz \n";
							$parameters['message_date_begin'] = $this->message_date_begin.':00.000 '.$time_zone;
						}
						if (!empty($this->message_date_end)) {
							$sql_date_range .= "and message_date <= :message_date_end::timestamptz \n";
							$parameters['message_date_end'] = $this->message_date_end.':59.999 '.$time_zone;
						}
					}
				}
				else {
					switch ($this->quick_select) {
						case 1: $sql_date_range = "and message_date >= '".date('Y-m-d H:i:s.000', strtotime("-1 week"))." ".$time_zone."'::timestamptz \n"; break; //last 7 days
						case 2: $sql_date_range = "and message_date >= '".date('Y-m-d H:i:s.000', strtotime("-1 hour"))." ".$time_zone."'::timestamptz \n"; break; //last hour
						case 3: $sql_date_range = "and message_date >= '".date('Y-m-d')." "."00:00:00.000 ".$time_zone."'::timestamptz \n"; break; //today
						case 4: $sql_date_range = "and message_date between '".date('Y-m-d',strtotime("-1 day"))." "."00:00:00.000 ".$time_zone."'::timestamptz and '".date('Y-m-d',strtotime("-1 day"))." "."23:59:59.999 ".$time_zone."'::timestamptz \n"; break; //yesterday
						case 5: $sql_date_range = "and message_date >= '".date('Y-m-d',strtotime("this week"))." "."00:00:00.000 ".$time_zone."' \n"; break; //this week
						case 6: $sql_date_range = "and message_date >= '".date('Y-m-')."01 "."00:00:00.000 ".$time_zone."'::timestamptz \n"; break; //this month
						case 7: $sql_date_range = "and message_date >= '".date('Y-')."01-01 "."00:00:00.000 ".$time_zone."'::timestamptz \n"; break; //this year
					}
				}

				$sql  = "with \n"; 
				$sql .= "message_inbound as ( \n";
				$sql .= "select \n"; 
				$sql .= "m.domain_uuid as domain_uuid, \n";
				$sql .= "d.destination_uuid as destination_uuid, \n";
				$sql .= "m.message_to as destination, \n";

				//message_read
				$sql .= "count(*) \n";
				$sql .= "filter (where m.message_read IS TRUE) \n";
				$sql .= "as message_read, \n";

				//message_unread
				$sql .= "count(*) \n";
				$sql .= "filter (where m.message_read IS NOT TRUE) \n";
				$sql .= "as message_unread, \n";

				//message_received
				$sql .= "count(*) \n";
				$sql .= "as message_received, \n";

				$sql .= "0 as message_sent \n";

				$sql .= "from v_messages m, v_destinations d \n";
				
				if (!(!empty($_GET['show']) && $_GET['show'] === 'all' && permission_exists('message_summary_all'))) {
					$sql .= "where m.domain_uuid = :domain_uuid \n";
				}
				else {
					$sql .= "where true \n";
				}
				$sql .= $sql_date_range ?? '';
				$sql .= "and m.message_direction = 'inbound' \n";
				$sql .= "and m.message_to in (d.destination_number, concat(d.destination_prefix, d.destination_number), concat('+', d.destination_prefix, d.destination_number)) \n";
				$sql .= "group by m.domain_uuid, d.destination_uuid, m.message_to \n";

				$sql .= "), message_outbound as ( \n";

				$sql .= "select \n"; 
				$sql .= "m.domain_uuid as domain_uuid, \n";
				$sql .= "d.destination_uuid as destination_uuid, \n";
				$sql .= "m.message_from as destination, \n"; 
				$sql .= "0 as message_read, \n";
				$sql .= "0 as message_unread, \n";
				$sql .= "0 as message_received, \n";

				//message_sent
				$sql .= "count(*) \n";
				$sql .= "as message_sent \n";

				$sql .= "from v_messages m, v_destinations d \n";
				if (!(!empty($_GET['show']) && $_GET['show'] === 'all' && permission_exists('message_summary_all'))) {
					$sql .= "where m.domain_uuid = :domain_uuid \n";
				}
				else {
					$sql .= "where true \n";
				}
				$sql .= $sql_date_range ?? '';
				$sql .= "and m.message_direction = 'outbound' \n";
				$sql .= "and m.message_from in (d.destination_number, concat(d.destination_prefix, d.destination_number), concat('+', d.destination_prefix, d.destination_number)) \n";
				$sql .= "group by m.domain_uuid, d.destination_uuid, m.message_from \n";
				$sql .= ") \n";

				$sql .= "select \n";
				$sql .= "n.domain_uuid, \n"; 
				$sql .= "d.destination_uuid, \n";
				$sql .= "d.destination_description, \n";
				$sql .= "n.domain_name, \n"; 
				$sql .= "t.destination, \n"; 
				$sql .= "sum(t.message_read) as message_read, \n"; 
				$sql .= "sum(t.message_unread) as message_unread, \n"; 
				$sql .= "sum(t.message_received) as message_received, \n"; 
				$sql .= "sum(t.message_sent) as message_sent \n"; 
				$sql .= "from ( \n";
				$sql .= "select * from message_inbound \n";
				$sql .= "union \n";
				$sql .= "select * from message_outbound \n";
				$sql .= ") as t, v_domains n, v_destinations d \n";
				$sql .= "where \n";
				$sql .= "n.domain_uuid = t.domain_uuid \n";
				$sql .= "and d.destination_uuid = t.destination_uuid \n";
				$sql .= "group by n.domain_uuid, d.destination_uuid, d.destination_description, n.domain_name, t.destination \n";
				$sql .= "order by t.destination asc \n";

				if (!(!empty($_GET['show']) && $_GET['show'] === 'all' && permission_exists('message_summary_all'))) {
					$parameters['domain_uuid'] = $this->domain_uuid;
				}

				$database = database::new();
				$summary = $database->select($sql, $parameters, 'all');
				unset($parameters);
				//view_array($database->message); 
				
				//return the array
				return $summary;
				
		} //method
		
	} //class
}

?>