#!/usr/local/bin/php

<?php

/*
 * 
 * (c) 2014 Christopher Olsen <cwolsen@uBixOS.com>
 * 
 * $Id: broadcast_dialer_cron.php 2230 2015-06-17 19:03:56Z reddawg $
 * 
 * This script will align all calls to 6 seconds and update daily total for the broadcast dialer
 * 
 */

if (file_exists("/tmp/broadcast_dialer_cron.lock")) {
  print "Script is already running.\n";
  exit(0);
}

$working_dir =  dirname(__FILE__);

$log_file = fopen($working_dir . "/../../log/cron/broadcast_dialer_cron.log", "a");

fwrite($log_file, "Script Started: " . date("Y-m-d H:i:s") . "\n");

system("/usr/bin/touch /tmp/broadcast_dialer_cron.lock");

/* Connect To The Required Databases */
$data['ubix_db']   = new mysqli("10.0.10.59", "ubixcube", "5558585", "ubixcube");
$data['press1_db'] = new mysqli("10.0.10.59", "dialer", "5558585", "as_dialer_002");
/* End of Database Connections */

/* Get The Last Time This Script Ran */
$query = "SELECT value FROM system_var WHERE name = 'broadcast_dialer_cron_last_run'";

if (($result = $data['ubix_db']->query($query)) === false) {
  fwrite($log_file, "MySQL Error: Line " . __LINE__ . "\n");
  exit(1);
}

if ($result->num_rows == 0) {
  $query = "INSERT INTO system_var (name,value) VALUES('broadcast_dialer_cron_last_run',0)";
  $data['ubix_db']->query($query);
  $last_run = 0;	
}
else {
  $qData = $result->fetch_row();
  $last_run = intval($qData[0]);
  $result->free();
}

$bTime = time();
  
$sdate = date("Y-m-d", $last_run);
$sdate = "2016-02-01";
$edate = date("Y-m-d", $bTime);

fwrite($log_file, "Info - sdate: " . $sdate . ", edate: " . $edate . ", last_run: " . $last_run . ", bTime: " . $bTime . "\n");

/*
 * 
 * Align Broadcast Campaign Calls To 6 Seconds
 * 
 */ 

$query = "UPDATE vicidial_log set length_in_sec = CEIL(length_in_sec/6)*6 WHERE length_in_sec > 0 AND call_date >= '$sdate 00:00:00' and call_date <= '$edate 23:59:59' AND end_epoch IS NOT NULL AND MOD(length_in_sec,6) != 0";
if ($data['press1_db']->query($query) === true)
  fwrite($log_file, "Broadcast Campaign Calls 6 Second Aligned: " . $data['press1_db']->affected_rows . " Affected Rows\n");
else
  fwrite($log_file, "MySQL Error: Line " . __LINE__ . "\n");

/*
 * 
 * Calculate Daily Spending 
 * 
 * Update Each Campaign
 * Update Account Record
 * 
 */

$query = "SELECT aid, first_name, email, press1_group, press1_prepay, press1_cpm, company FROM accounts WHERE press1_group != 'NA'";

if (($aResult = $data['ubix_db']->query($query)) === false) {
  fwrite($log_file, "MySQL Error: Line - " . __LINE__ . ", Query - [$query]\n");
  exit(1);
}

while ($aData = $aResult->fetch_assoc()) {  
  $query = "SELECT campaign_id, campaign_name, daily_limit, daily_total, daily_notification, active FROM vicidial_campaigns WHERE user_group = '" . $aData['press1_group'] . "'";
  
  if (($vcResult = $data['press1_db']->query($query)) === false) {
  	fwrite($log_file, "MySQL Error: Line - " . __LINE__ . ", Query - [$query]\n");
  	exit(1);
  }

  /* Spending For All Campaigns On Account */
  $broadcast_daily_total = 0.0000;
  
  while ($vcData = $vcResult->fetch_assoc()) {
    $query = "SELECT SUM(length_in_sec) as total_time, COUNT(*) as total_records FROM vicidial_log WHERE campaign_id = " . $vcData['campaign_id'] . " AND call_date >= '$sdate 00:00:00' and call_date <= '$edate 23:59:59'";

    $vlResult = $data['press1_db']->query($query);
    $vlData = $vlResult->fetch_assoc();

    if ($vlData['total_time'] > 0) { 
      $daily_total = ($vlData['total_time']/60) * $aData['press1_cpm'];
      $broadcast_daily_total += $daily_total;
      
      $aData['press1_prepay'] -= $daily_total;

      fwrite($log_file, "TT: [" . $vlData['total_time'] . ":" . $aData['press1_cpm'] . "][" . $vcData['daily_total'] . ":" . $daily_total . "][" . $vlData['total_records'] . "]\n");
        
      if ($daily_total > $vcData['daily_limit']) {
        $query = "UPDATE vicidial_campaigns SET daily_total = " . $daily_total . ", active = 'N' WHERE campaign_id = '" . $vcData['campaign_id'] . "'";
        if ($vcData['active'] == "Y") 
          sendNotification($aData['email'], $aData['first_name'], $vcData['campaign_name'], $vcData['campaign_id'], $vcData['daily_limit'], $daily_total, 100);
      }
      else {
        $lP = floor(($daily_total / $vcData['daily_limit']) / .25) * 25;
        $query = "UPDATE vicidial_campaigns SET daily_total = " . $daily_total . ", daily_notification = " . $lP . " WHERE campaign_id = '" . $vcData['campaign_id'] . "'";
        
        if ($vcData['daily_notification'] < $lP)
          sendNotification($aData['email'], $aData['first_name'], $vcData['campaign_name'], $vcData['campaign_id'], $vcData['daily_limit'], $daily_total, $lP);
      }
        
      if ($data['press1_db']->query($query) === false)
        fwrite($log_file, "MySQL Error - [$query][$cost] on line " . __LINE__ . "\n");
    }  
    $vlResult->free();
  }
    
  $query = "UPDATE accounts SET broadcast_daily_total = " . $broadcast_daily_total . " WHERE aid = " . $aData['aid'];
  
  if ($data['ubix_db']->query($query) === false)
    fwrite($log_file, "MySQL Error - [$query] on line " . __LINE__ . "\n");
     
  fwrite($log_file, "Adjusted Broadcast Daily Total to " . $broadcast_daily_total . " for " . $aData['company'] . " with bTime - $bTime\n");

  $vcResult->free();
}

$aResult->free();

$query = "UPDATE system_var SET value = '" . $bTime . "' WHERE name = 'broadcast_dialer_cron_last_run'";
if ($data['ubix_db']->query($query) === false)
  fwrite($log_file, "MySQL Error - [$query] on line " . __LINE__ . "\n");

fwrite($log_file, "Adjust System Var: [$query]\n");
fwrite($log_file, "Finish: " . date("Y-m-d H:i:s") . "\n\n");

fclose($log_file);

system("/bin/rm /tmp/broadcast_dialer_cron.lock");

function sendNotification($recipient, $first_name, $campaign_name, $campaign_id, $limit, $total, $lP = 100) {
  $random_hash = md5(date('r', time()));

  $message_body = "--PHP-alt-" . $random_hash . "\nContent-Type: text/plain; charset=\"iso-8859-1\"\nContent-Transfer-Encoding: 7bit\n\n";

  if ($lP == 100) {
    $subject = "uBix Dialer Notification - Daily Spending Limit Has Been Reached";

    $message_body .= "Dear $first_name,\n\nWe wanted to let you know that daily spending on " . $campaign_name . " has reached $" . number_format($total, 2) . "\n\n"; 
    $message_body .= "Your daily limit for this campaign is $" . number_format($limit, 2) . "\n\nYour campaign has been automatically disabled.\n\nYou may want to consider adjusting your daily spending limit to reactivate your campaign.\n\nSincerely,\n\nuBix Technologies Support\n516-986-UBIX (8249)\n\n";
      
    $message_body .= "--PHP-alt-" . $random_hash . "\nContent-Type: text/html; charset=\"iso-8859-1\"\nContent-Transfer-Encoding: 7bit\n\n";

    $message_body .= "Dear $first_name,<br><br>\n\nWe wanted to let you know that daily spending on " . $campaign_name . " has reached $" . number_format($total, 2) . "<br>\n<br>\n"; 
    $message_body .= "Your daily limit for this campaign is $" . number_format($limit, 2) . "<br>\n<br>\nYour campaign has been automatically disabled.<br>\n<br>\nYou may want to consider adjusting your <a href=\"https://manage.ubixtechnologies.net/dialer/edit.php?data[cid]=" . $campaign_id . "\">daily spending limit</a> to reactivate your campaign.<br>\n<br>\nSincerely,<br>\n<br>\nuBix Technologies Support<br>\n516-986-UBIX (8249)<br>\n\n";
    } 
  else {
    $subject = "uBix Dialer Notification - Daily Spending Has Reached " . $lP . "%";

    $message_body .= "Dear $first_name,\n\nWe wanted to let you know that daily spending on " . $campaign_name . " has reached $" . number_format($total, 2) . "\n\n"; 
    $message_body .= "Your daily limit for this campaign is $" . number_format($limit, 2) . "\n\nYou may want to consider adjusting your dial speed if you feel this has been reached to fast or slow.\n\nSincerely,\n\nuBix Technologies Support\n516-986-UBIX (8249)\n\n";
      
    $message_body .= "--PHP-alt-" . $random_hash . "\nContent-Type: text/html; charset=\"iso-8859-1\"\nContent-Transfer-Encoding: 7bit\n\n";

    $message_body .= "Dear $first_name,<br><br>\n\nWe wanted to let you know that daily spending on " . $campaign_name . " has reached $" . number_format($total, 2) . "<br>\n<br>\n"; 
    $message_body .= "Your daily limit for this campaign is $" . number_format($limit, 2) . "<br>\n<br>\nYou may want to consider adjusting your <a href=\"https://manage.ubixtechnologies.net/dialer/edit.php?data[cid]=" . $campaign_id . "\">dial speed</a> if you feel this has been reached to fast or slow.<br>\n<br>\nSincerely,<br>\n<br>\nuBix Technologies Support<br>\n516-986-UBIX (8249)<br>\n\n";
    }

  $message_body .= "--PHP-alt-" . $random_hash . "--\n";

  $header = "From: uBix Technologies <support@ubixtechnologies.com>\r\n";
  $header .= "MIME-Version: 1.0\r\nContent-Type: multipart/alternative; boundary=\"PHP-alt-" . $random_hash . "\"\n";

  mail($recipient, $subject, $message_body, $header);
  
  mail("cwolsen@uBixOS.com", $subject, $message_body, $header);
}

?>