root/broadcast/broadcast_send.php

<?php

// Run includes
require_once("../../includes.php");
include($CFG->dirroot . "mod/broadcast/broadcast.config.php");

global $CFG, $template, $PAGE;
$template['css'] .= file_get_contents($CFG->dirroot . "mod/broadcast/css");

define("context", "broadcast");

$cid = optional_param('cid');
$message_subject = optional_param('message_subject');
$message_text = optional_param('message_text');
$profile_field = optional_param('profile_field','');
$profile_value = optional_param('profile_value','');

$thesql='SELECT * FROM ' . $CFG->prefix . 'users
        WHERE ident =' . intval($_SESSION['userid']);
$from=get_record_sql($thesql);

templates_page_setup();

$body = "";
$title = "";
$output = "";
$description = '';
$error = false;

if (isloggedin()) {            
    if ($cid != '*') {
        $community=get_record('users','ident',intval($cid)); //get the community from the ident...    
        if ($community) {        
            $description = __gettext("Sent emails to").': ' . $community->name;        
            if (isadmin($_SESSION['userid']) || $broadcast_allow_owners && $community->owner == $_SESSION['userid']) {
                // only admins and community owners can do this                  
                $recipients = broadcast_get_community_users($community,$profile_field,$profile_value);
            } else {
                $error = true;
                $body = __gettext("You are not allowed to contact this community.");
            }
        } else {
            $error = true;
            $body = __gettext("The specified community does not exist.");
        }
            
    } else {
        $description = __gettext("Sent emails to users");
        $recipients = broadcast_get_all_users($profile_field,$profile_value);
    }
    
} else { 
    $error = true;
    $body = __gettext("You need to be logged-in to do this action.");
}

if (!$error) {
    /*if ($profile_value) {
        $description .= ' '.__gettext("where"). ' "' . $profile_field . '" = "'.$profile_value.'".';
    } else {
        $description .= '.';
    }*/
    $description .= '.';
    $description .= ' <br /><br /><a href="'.$CFG->wwwroot.'mod/broadcast/broadcast_start.php">';
    $description .= __gettext("Return to broadcast form").'</a>';
    $problems = array();
    if ($recipients) {
        foreach ($recipients as $recipient) {
            $result = broadcast_to_user($recipient, $from, $message_subject, $message_text) ;
            if ($result != 1) {
                $p = new stdClass;
                $p->result = $result;
                $p->recipient = $recipient;
                $problems[] = $p;
            }
        }
    }
    if ($problems) {
        $body .= __gettext("There was a problem mailing to the following users:");
        $body .= "<table width=100%><tr><th>Name</th><th>Status</th></tr>";
        foreach($problems as $p) {
            $body .= "<tr><td>" . $p->recipient->name . "</td>";
            $result_message = '<span style="color:red;">'. $p->result . "</font>";
            $body .= "</td><td>" . $result_message . "</td></tr>\n";
        }
        $body .= "</table>";
    }
        
}

// Draw page
$title = __gettext("Broadcast");

$body = templates_draw(array(
                'context' => 'contentholder',
                'title' => $title,
                'body' => '<p>'.$description.'</p>'.$body
            )
            );

echo templates_page_draw( array(
                $title, $body
            )
            );

function broadcast_to_user($recipient, $from, $message_subject, $message_text) {
    
    global $CFG;
    
    //TODO: this should really be in a background cron job
    // I don't use message_user from userlib because that does not support HTML
    
    $extra_text = '<br /><br />----<br /><br />'.sprintf(__gettext('If you prefer not to receive direct email updates from %s, '
    .'you can log in and set your Email Notification (under Account Preferences) to "No".'),$CFG->sitename) 
    . '<br /><br /><a href="'.$CFG->wwwroot.'">'.$CFG->sitename.'</a>';
    
    if ($recipient->email_flag) {
        $result=email_to_user($recipient, $from, $message_subject, format_text_email($message_text.$extra_text, FORMAT_HTML), '<html><body>' . $message_text . $extra_text. '</body></html>', "","", true,$from->email, $from->name);
    } else {
        $result = 1;
    }
    
    $m = new StdClass;
    $m->title = $message_subject;
    $m->body = $message_text;
    //$m->from_id = $from->ident;
    // avoid putting lots of messages in sent folder
    $m->from_id = -1;
    $m->to_id = $recipient->ident;
    $m->posted = time();
    $m->status = 'unread';
    
    if (!insert_record('messages',$m)) {
        trigger_error(__FUNCTION__.": Failed to send message from {$from->ident} to {$recipient->ident}. An unknown error occurred.", E_ERROR);
    } else {
        plugin_hook("message", "publish", $m);
    }
    
    return $result;
}
        
?>