Deleting inactive customers

Code: Select all

<?php
set_time_limit(0);
require_once('config.php');
require_once(DIR_SYSTEM . 'startup.php');

// Registry
$registry = new Registry();

// Loader
$loader = new Loader($registry);
$registry->set('load', $loader);

// Config
$config = new Config();
$registry->set('config', $config);

// Database 
$db = new DB(DB_DRIVER, DB_HOSTNAME, DB_USERNAME, DB_PASSWORD, DB_DATABASE);
$registry->set('db', $db);

// Create array of all customer IDs and array of customers to be deleted

$customers = array();
$customers_delete = array();

$query = $db->query("SELECT `customer_id` FROM `" . DB_PREFIX . "customer`");

foreach($query->rows as $c){
	$customers[] = $c['customer_id']; 
}


// Create array of customers who have ordered in last 5 years

$customers_5years = array();

$query = $db->query("SELECT DISTINCT `customer_id` FROM `" . DB_PREFIX . "order` WHERE date_added <= DATE_SUB(NOW(),INTERVAL 5 YEAR)");

foreach($query->rows as $c){
	$customers_5years[] = $c['customer_id']; 
}


// Work out which customers to delete

$customers_delete = array_diff($customers, $customers_5years);


foreach($customers_delete as $cid){
	$query = $db->query("DELETE FROM `" . DB_PREFIX . "address` WHERE `customer_id` = " . $cid);
	$query = $db->query("DELETE FROM `" . DB_PREFIX . "customer` WHERE `customer_id` = " . $cid);
	$query = $db->query("DELETE FROM `" . DB_PREFIX . "customer_activity` WHERE `customer_id` = " . $cid);
	$query = $db->query("DELETE FROM `" . DB_PREFIX . "customer_history` WHERE `customer_id` = " . $cid);
	$query = $db->query("DELETE FROM `" . DB_PREFIX . "customer_ip` WHERE `customer_id` = " . $cid);
	$query = $db->query("DELETE FROM `" . DB_PREFIX . "customer_online` WHERE `customer_id` = " . $cid);
	$query = $db->query("DELETE FROM `" . DB_PREFIX . "customer_reward` WHERE `customer_id` = " . $cid);
	$query = $db->query("DELETE FROM `" . DB_PREFIX . "customer_search` WHERE `customer_id` = " . $cid);
	$query = $db->query("DELETE FROM `" . DB_PREFIX . "customer_transaction` WHERE `customer_id` = " . $cid);
	$query = $db->query("DELETE FROM `" . DB_PREFIX . "customer_wishlist` WHERE `customer_id` = " . $cid);
	$query = $db->query("UPDATE `" . DB_PREFIX . "order` SET `customer_id` = '0' WHERE `customer_id` = " . $cid);
}