planningalerts/trunk/tools/application_mailer.php

<?php

    require_once('tools_ini.php'); 
    require_once('application.php'); 
    require_once('DB.php');

    //initialise
    $application_mailer = new application_mailer();
    $application_mailer->run();

    //class
    class application_mailer {
        
    //Properties
    var $log = array();
	var $application_count = 0;
	var $email_count = 0;

    //Run
     function run (){

        $db = DB::connect(DB_CONNECTION_STRING);
                 
         //Grab all the users
         $sql = "select user_id, email, postcode, bottom_left_x, bottom_left_y, top_right_x, top_right_y, alert_area_size, confirm_id
            from user
            where confirmed = 1 and last_sent < " . $db->quote(mysql_date(time() - (20 * 60 * 60)));  

        $this->store_log("Grabbing users");
             
         $user_results = $db->getAll($sql);
         
         $this->store_log("Found " . sizeof($user_results) . " who havnt been checked since " . mysql_date(time() - (20 * 60 * 60)));
                      
         if(sizeof($user_results) > 0){
             
             //Loop though users
             for ($i=0; $i < sizeof($user_results); $i++){ 

                 //Find applications for that user
                 $sql = "select distinct council_reference, address, 
                            postcode, description, info_tinyurl, 
                            comment_tinyurl, map_url, full_name
                        from application
                            inner join authority on application.authority_id = authority.authority_id 
                         where date_scraped > " . $db->quote(mysql_date(time() - (24 * 60 * 60))) . 
                            " and (application.x > " .  $user_results[$i][3] . " and application.x < " . $user_results[$i][5] . ")
                              and (application.y > " .  $user_results[$i][4] . " and application.y < " . $user_results[$i][6] .       ") and (application.y <> 0  and application.y <> 0 )";

                $application_results = $db->getAll($sql);

                //Send email if we have any 
                if(sizeof($application_results) > 0){
                    
                    //Setup applications array (bit pikey this)
                    $applications = array();
                    for ($ii=0; $ii < sizeof($application_results); $ii++){ 
       
                        $application = new application();
                        $application->council_reference = $application_results[$ii][0];
                        $application->address = $application_results[$ii][1]; 
                        $application->postcode = $application_results[$ii][2];
                        $application->description= $application_results[$ii][3];
                        $application->info_tinyurl= $application_results[$ii][4];
                        $application->comment_tinyurl= $application_results[$ii][5];
                        $application->map_url = $application_results[$ii][6];
                        $application->authority_name = $application_results[$ii][7];                        
                        
                        array_push($applications, $application);
                    }

					$this->application_count += sizeof($applications); 
                    
                    //Smarty template
                    $smarty = new Smarty;
                    $smarty->force_compile = true;
                    $smarty->compile_dir = SMARTY_COMPILE_DIRECTORY;
                    $smarty->assign("applications", $applications);
                    $smarty->assign("base_url", BASE_URL);
                    $smarty->assign("confirm_id", $user_results[$i][8]);      
                    $smarty->assign("alert_area_size", $user_results[$i][7]);                          
                    $smarty->assign("alert_postcode", $user_results[$i][2]);                                              
                    
                    //Get the email text
                    $email_text = $smarty->fetch(SMARTY_TEMPLATE_DIRECTORY . 'alert_email_text.tpl');
                    
                    //Send the email
                    if($email_text !=""){
                        send_text_email($user_results[$i][1], EMAIL_FROM_NAME, EMAIL_FROM_ADDRESS, "Planning applications near " . strtoupper($user_results[$i][2]),  $email_text);
						$this->email_count +=1;
                    }else{
                        $this->store_log("BLANK EMAIL TEXT !!! EMAIL NOT SENT");
                    }

                    //Update last sent
                    $sql = "update user set last_sent = " . $db->quote(mysql_date(time())) . " where user_id = " . $user_results[$i][0];
                    $db->query($sql);   
                    $this->store_log("Updating last checked date/time");
                }

             }

         }

      $this->store_log("Sent " . $this->application_count . " applications  to " . $this->email_count . " people!");	

	 //update the number of apps sent
	  $sql = "select `key`, `value` from stats";
	  $stats_results = $db->getAll($sql);
	  $new_application_total = 0;	
	  $new_email_total = 0;	
	  for ($i=0; $i < sizeof($stats_results); $i++){ 
			if($stats_results[$i][0] == 'applications_sent'){
				$new_application_total = $stats_results[$i][1] + $this->application_count;
				$new_email_total = $stats_results[$i][1] + $this->email_count;
			}	
	  }
	
	//add stats to email
	 $this->store_log("Total applications ever sent:  " . $new_application_total);	
	 $this->store_log("Total emails ever sent:  " . $new_email_total);
	
	//update stats in DB
	 $sql = "update stats set `value` = " . $new_application_total . " where `key` = 'applications_sent'";
	 $db->query($sql);	
	
	 $sql = "update stats set `value` = " . $new_email_total . " where `key` = 'emails_sent'";
	 $db->query($sql);
		
      //Send the log
      send_text_email(LOG_EMAIL, "mailer@" . DOMAIN, "mailer@" . DOMAIN, "Planning mailer log", print_r($this->log, true));
         
     }
     
     function store_log($text){
            array_push($this->log, $text);
            print $text . "\n\n";
     }  
        
    }

?>