Compare commits
No commits in common. "1dd8756d3b99d5e2bd475092121122bc9f698b8e" and "48b2ba5684d1461b00b19d1e63b9f0bc382a9af0" have entirely different histories.
1dd8756d3b
...
48b2ba5684
|
@ -274,11 +274,11 @@ namespace controllers\internals;
|
|||
/**
|
||||
* Get all messages to send and the number to use to send theme.
|
||||
*
|
||||
* @return array : List of smss to send at this time per scheduled id ['1' => [['id_scheduled', 'text', 'id_phone', 'destination', 'flash', 'mms', 'medias'], ...], ...]
|
||||
* @return array : [['id_scheduled', 'text', 'id_phone', 'destination', 'flash', 'mms', 'medias'], ...]
|
||||
*/
|
||||
public function get_smss_to_send()
|
||||
{
|
||||
$smss_to_send_per_scheduled = [];
|
||||
$smss_to_send = [];
|
||||
|
||||
$internal_templating = new \controllers\internals\Templating();
|
||||
$internal_setting = new \controllers\internals\Setting($this->bdd);
|
||||
|
@ -297,8 +297,6 @@ namespace controllers\internals;
|
|||
$scheduleds = $this->get_model()->gets_before_date($now);
|
||||
foreach ($scheduleds as $scheduled)
|
||||
{
|
||||
$smss_to_send_per_scheduled[$scheduled['id']] = [];
|
||||
|
||||
if (!isset($users_settings[$scheduled['id_user']]))
|
||||
{
|
||||
$users_settings[$scheduled['id_user']] = [];
|
||||
|
@ -330,7 +328,6 @@ namespace controllers\internals;
|
|||
}
|
||||
|
||||
//Add medias to mms
|
||||
$scheduled['medias'] = [];
|
||||
if ($scheduled['mms'])
|
||||
{
|
||||
$internal_media = new Media($this->bdd);
|
||||
|
@ -484,16 +481,16 @@ namespace controllers\internals;
|
|||
}
|
||||
|
||||
//Remove messages to smsstops numbers
|
||||
if (($users_smsstops[$scheduled['id_user']] ?? false) && in_array($message['destination'], $users_smsstops[$scheduled['id_user']]))
|
||||
if (in_array($message['destination'], $users_smsstops[$scheduled['id_user']]))
|
||||
{
|
||||
continue;
|
||||
}
|
||||
|
||||
$smss_to_send_per_scheduled[$scheduled['id']][] = $message;
|
||||
$smss_to_send[] = $message;
|
||||
}
|
||||
}
|
||||
|
||||
return $smss_to_send_per_scheduled;
|
||||
return $smss_to_send;
|
||||
}
|
||||
|
||||
/**
|
||||
|
|
|
@ -47,8 +47,8 @@ class Sender extends AbstractDaemon
|
|||
$this->internal_scheduled = new \controllers\internals\Scheduled($this->bdd);
|
||||
|
||||
//Get smss and transmit order to send to appropriate phone daemon
|
||||
$smss_per_scheduled = $this->internal_scheduled->get_smss_to_send();
|
||||
$this->transmit_smss($smss_per_scheduled); //Add new queue to array of queues
|
||||
$smss = $this->internal_scheduled->get_smss_to_send();
|
||||
$this->transmit_smss($smss); //Add new queue to array of queues
|
||||
|
||||
usleep(0.5 * 1000000);
|
||||
}
|
||||
|
@ -56,11 +56,9 @@ class Sender extends AbstractDaemon
|
|||
/**
|
||||
* Function to transfer smss to send to phones daemons.
|
||||
*
|
||||
* @param array $smss_per_scheduled : Smss to send per scheduled id
|
||||
* @param array $smss : Smss to send
|
||||
*/
|
||||
public function transmit_smss(array $smss_per_scheduled): void
|
||||
{
|
||||
foreach ($smss_per_scheduled as $id_scheduled => $smss)
|
||||
public function transmit_smss(array $smss): void
|
||||
{
|
||||
foreach ($smss as $sms)
|
||||
{
|
||||
|
@ -83,11 +81,9 @@ class Sender extends AbstractDaemon
|
|||
];
|
||||
|
||||
msg_send($this->queues[$queue_id], QUEUE_TYPE_SEND_MSG, $msg);
|
||||
$this->logger->info('Transmit sms send signal to phone ' . $sms['id_phone'] . ' on queue ' . $queue_id . '.');
|
||||
}
|
||||
|
||||
$this->logger->info('Scheduled ' . $id_scheduled . ' treated and deleted.');
|
||||
$this->internal_scheduled->delete($id_scheduled);
|
||||
$this->logger->info('Transmit sms send signal to phone ' . $sms['id_phone'] . ' on queue ' . $queue_id . '.');
|
||||
$this->internal_scheduled->delete($sms['id_scheduled']);
|
||||
}
|
||||
}
|
||||
|
||||
|
|
Loading…
Reference in New Issue