<?php

  include('includes/application_top.php');

  echo "import batches running";

  $products_arr = array();  
if (($handle = fopen("batches2011.csv", "r")) !== FALSE) {
    while (($data = fgetcsv($handle, 1000, ",")) !== FALSE) {
      $num = count($data);
      $row++;

	  $productName = $data[0];
	  $batchID = $data[1];
	  $date = $data[2];
	  if (zen_not_null($productName) && zen_not_null($batchID) && zen_not_null($date)) {
		echo "Product Name: $productName Batch $batchID date: $date <br />";
		$timestamp = mktime(0,0,0, substr($date, 3,2), substr($date, 0, 2), 2011);
		if(!isset($products_arr[$productName])) {
		  $product_rs = $db->Execute("select products_id from ".TABLE_PRODUCTS_DESCRIPTION." where products_name = '".zen_db_input($productName)."'");
		  if (!$product_rs->EOF) {
			$products_arr[$productName] = $product_rs->fields['products_id'];
		  }
		}
		if (zen_not_null($products_arr[$productName])) {
		  $product_id = (int)$products_arr[$productName];
		  $orders_sql = "select op.orders_products_id ".
		  				"from ".TABLE_ORDERS_PRODUCTS." op, ".TABLE_ORDERS." o ".
		  				"where o.date_purchased >= '".date('Y-m-d', $timestamp)."' ".
						"and o.orders_id = op.orders_id ".
						"and op.products_id = '".(int)$product_id."'";
		  $orders_rs = $db->Execute($orders_sql);
		  while(!$orders_rs->EOF) {
			$check_rs = $db->Execute("select orders_products_id, products_id,batch_id, date_added from orders_products_batch_records where products_id = '".(int)$product_id."' and orders_products_id = '".(int)$orders_rs->fields['orders_products_id']."'");
			$update_arr = array(	'orders_products_id'		=>	(int)$orders_rs->fields['orders_products_id'],
									'products_id'				=>	(int)$product_id,
									'batch_id'					=>	(int)$batchID,
									'admin_id'					=>	0,
									'date_added'				=>	'now()'
								);
			if ($check_rs->EOF) {
			  zen_db_perform('orders_products_batch_records', $update_arr);
			} elseif (date('Y-m-d', strtotime($check_rs->fields['date_added'])) == date('Y-m-d') && $batchID != $check_rs->fields['batch_id']) {
			  zen_db_perform('orders_products_batch_records', $update_arr, 'update', "products_id = '".(int)$product_id."' and orders_products_id = '".(int)$orders_rs->fields['orders_products_id']."'");
			}
			$orders_rs->MoveNext();
		  }
		}
	  }
    }
    fclose($handle);
}