Long running process with notifications

// how many emails to send per step
var recCount = pageObj.proxy["recCount"], mail_per_step = 10;

// basic HTML code for the progress popup window
var html = "<div class><b>Sent mails: <span class='sent'>0</span> of <span>" + recCount + "</span></b></div>" + "<br><div>Mailed: <span class='mailed'>0</span>, Errors: <span class='errors'>0</span></div>";

// showing the progress in a popup
var popup = Runner.displayPopup({
html: html,
header: 'Sending...',
afterCreate: function (win) {
// starting sending emails, ajaxStep is a secursive function
ajaxStep(0, mail_per_step);
}
});

function ajaxStep(step, mail_per_step) {
$.get("", { ajaxMail: true, ajaxstep: step, mail_per_step: mail_per_step }, function (response) {
var json = JSON.parse(response);

// using the response data to update the progress popup

$(".sent").html(parseInt($(".sent").html()) + json["totalSent"]);
$(".mailed").html(parseInt($(".mailed").html()) + json["mailed"]);
$(".errors").html(parseInt($(".errors").html()) + json["errors"])

if (parseInt(json["totalSent"]) < mail_per_step) {
// time to exit the recursion. The number of processed records is less than
// number of records per step which means we ran out of data to process
swal("Done");
} else {
// otherwise proceed to the next step
step++;
ajaxStep(step, mail_per_step);
};
});
}
return false;

$sql = "select count(*) from customers";
$recCount = DB::DBLookup($sql);
$pageObject->setProxyValue("recCount",$recCount);

dynamic recCount = null, sql = null;
sql = new XVar("select count(*) from customers");
recCount = XVar.Clone(DB.DBLookup((XVar)(sql)));
pageObject.setProxyValue(new XVar("recCount"), (XVar)(recCount));

if( postvalue("ajaxMail") != false ){
$response = array("totalSent" => 0, "errors" => 0,"mailed" => 0);

// number of records to process per step
$recCount = postvalue("mail_per_step");

// starting record
$startRecord = intval(postvalue("ajaxstep"))*$recCount;

// name of the email field
$email_field = "email";

// sql query
$sql = "select * from customers limit ".$startRecord.",".$recCount;
$rs = DB::Query($sql);

// the main cycle where we perform our tasks

while($data = $rs->fetchAssoc()){
$mail_params = array('to' => $data[$email_field], 'subject' => "Ajax notification", 'htmlbody' => "body text");

$mailed = runner_mail($mail_params);
if($mailed["mailed"])
$response["mailed"]++;
else
$response["errors"]++;
$response["totalSent"]++;
}
// return the response
echo my_json_encode($response);
exit();
}

if (MVCFunctions.postvalue(new XVar("ajaxMail")) != false) {
dynamic data, rs, email_field = null, mail_params = null, mailed = XVar.Array(), recCount = null, sql = null, startRecord = null, var_response = XVar.Array();
var_response = XVar.Clone(new XVar("totalSent", 0, "errors", 0, "mailed", 0));
recCount = XVar.Clone(MVCFunctions.postvalue(new XVar("mail_per_step")));
startRecord = XVar.Clone((int) MVCFunctions.postvalue(new XVar("ajaxstep")) * recCount);
email_field = new XVar("email");
sql = XVar.Clone(MVCFunctions.Concat("select * from customers limit ", startRecord, ",", recCount));
rs = XVar.Clone(DB.Query((XVar)(sql)));
while (XVar.Pack(data = XVar.Clone(rs.fetchAssoc()))) {
mail_params = XVar.Clone(new XVar("to", data[email_field], "subject", "Ajax notification", "htmlbody", "body text"));
mailed = XVar.Clone(MVCFunctions.runner_mail((XVar)(mail_params)));
if (XVar.Pack(mailed["mailed"])) {
var_response["mailed"]++;
} else {
var_response["errors"]++;
}
var_response["totalSent"]++;
}
MVCFunctions.Echo(MVCFunctions.my_json_encode((XVar)(var_response)));
MVCFunctions.ob_flush();
HttpContext.Current.Response.End();
throw new RunnerInlineOutputException();
}