Ayudita con fecha programada

[pilucho]

Hola a todos
El codigo es para enviar mensaje recordatorio.
Fuente

Indico la fecha en que llega el mensaje
pero siguen llegando dias antes de la fecha


Ejemplo estamos en el dia 4 (hoy) :

Fecha dia 8 en adelante aun no envia muy bien.
(BIEN POR QUE AUN NO ENVIA).
target_date ----- date_added ----- action_step1_date_sent --
2016-01-08 ------ 2016-01-01 09:00:00 -- 0000-00-00 00:00:00


Fecha dia 7 ó dia 6,5,4,3 si envia todo
los mensajes que tengan dichas fechas.
target_date ----- date_added ----- action_step1_date_sent --
2016-01-07 ------ 2016-01-01 09:00:00 -- 2016-01-04 09:07:16


Fecha dia 8 con anio 2015 si envia todo
los mensajes que tengan dichas fechas.
target_date ----- date_added ----- action_step1_date_sent --
2016-01-08 ------ 2015-11-01 09:00:00 -- 2016-01-04 09:07:16


Como me podrian brindar su ayuda con esto.

target_date (FECHA PROGRAMADA "Recordatorio")
date_added (FECHA CREADA del mesnaje)
action_step1_date_sent (FECHA DE ENVIO del mensaje)

NOTA: una vez que envia el mensaje ya no se vuelve
enviar el mensaje a los email hasta ahi todo bien.
Se hace un update creando una fecha en el DB para
que no se envie. disculpen la redundancia.

en cron esta programado para cada diez minutos
eso se puede cambiar no hay problema.

Código PHP:

<?php
date_default_timezone_set('America/New_York');
// How long in between each action step reminder.
// define(INTERVAL, 86400*2); // 2 days, in seconds.
// Interval is no longer constant -- it's now a function 
// of the target date. - Joel 2014/Jun/08
// Change these to match your actual address(es):
define(SENT_FROM_ADDR, '[email protected]');
define(REPLY_TO_ADDR, '[email protected]');
// Get command line argument; default to step 1.
//
// (This is probably overkill for a learning exercise, but I want to
//  demonstrate the importance of validating input here, because we here
//  use the input directly in our query, as part two column names we 
//  select; this is super-hazardous, so extra care is essential.)
//
$valid  = array(1, 2, 3);
$which_step = count($argv) > 1
           && $argv[1] == (integer) $argv[1]       // Is it a number?
           && in_array((integer) $argv[1], $valid) // Is it 1, 2 or 3?
            ? (integer) $argv[1] : 1;              // Legit? Or default to 1.
// Translate the integer number (1, 2 or 3) into a column name.
$step_col_name = 'action_step' . $which_step;
$step_date_col = $step_col_name . '_date_sent';
// Query to select only the action steps matching the 
// given number, that haven't already been sent out.
// NOTE: the date math can probably be done differently, 
//       but for now, we stick to UNIX epochs.
$select_query = "SELECT email_addr,$step_col_name,date_added,Names,"
              . "       (UNIX_TIMESTAMP(target_date) - "
              . "        UNIX_TIMESTAMP(date_added))/(4*86400) AS interval_size"
              . " FROM client_contact"
              . " WHERE $step_date_col=0"
              . " HAVING UNIX_TIMESTAMP(NOW()) >= "
              . "        UNIX_TIMESTAMP(date_added) + interval_size*$which_step*86400";
// Select matching rows.
$link = new mysqli('localhost', 'contactor', '7sdfa3w8', 'test');
$select_res = $link->query($select_query);
// Iterate over rows, send email, and update the sent 
// date column for the rows corresponding to the emails sent.
while ($row = $select_res->fetch_array()) {
    list($addr, $step_col_value, $date_added, $Names) = $row;
    // Send the email, and print out that this happened. (Another approach
    // instead of printing,  would be to blind carbon-copy yourself.)
    $headers = 'From: ' . SENT_FROM_ADDR . "\r\n" 
             . 'Reply-To: ' . REPLY_TO_ADDR . "\r\n";
    mail($addr,                                           // Mail-to address.
         "Action Step Reminder - ($Names) Step $which_step",       // Subject.
         "Your action step for today: $step_col_value.",  // Body.
         $headers);                                       // Additional headers.
    echo "Sent message to `$addr`, for action step `$which_step`,",
         " which was `$step_col_value`\n";
    // Record the timestamp that it was sent, so it won't get selected next time.
    $update_time = date('Y-m-d H:i:s');
    $update_query = "UPDATE client_contact SET $step_date_col=? "
                  . " WHERE email_addr=? AND $step_col_name=? AND date_added=?";
    $stmt = $link->prepare($update_query);
    $stmt->bind_param('ssss', $update_time, $addr, $step_col_value, $date_added);
    $update_res = $stmt->execute();
    // WUT? (This is for debugging; get rid of this, for production.)
    if (!$update_res) {
        echo "UPDATE FAILED:\n\n";
        var_dump($update_query);
        var_dump($update_time, $addr, $step_col_value, $date_added);
        exit;
    }
}
?>