cfs_at_sw_pulling_accounts.php

<?php
// cfs_at_sw.php
// version x
// GreenPages Technology Solutions, Inc.

define ('START_TIME', time());

// get command line arguments
for ($i=1; $i < $argc; $i++) {
	parse_str($argv[$i], $tmp);
	$_REQUEST = array_merge($_REQUEST, $tmp);
}

// need help ?
if(isset($_REQUEST['help'])) die(help_txt());

// check for required command line arguments
$required_cli_params = array(
//	'account',
	);

$missing_cli_params = array ();	
foreach($required_cli_params as $v) if(!isset($_REQUEST[$v])) $missing_cli_params[] = $v;
if(!empty($missing_cli_params))
	write_out ("ERROR: Missing command line parameter(s) \"" . implode(', ', $missing_cli_params) . "\"\n\n" . help_txt(), 1, 1, __FILE__, __LINE__);
//print_r ($_REQUEST); exit;

// did user specify an ini file? ... if not use default
if (!isset($_REQUEST['ini'])) $_REQUEST['ini'] = basename(__FILE__, 'php') . 'ini';

// parse the ini file
if (!$ini = @parse_ini_file($_REQUEST['ini']))
	write_out ("ERROR: Unable to parse {$_REQUEST['ini']}", 1, 1, __FILE__, __LINE__);

// check for required directives in parsed ini file
$required_ini_vars = array(
	'autotask_api_user',
	'autotask_api_password',
	'autotask_api_zone',
	'autotask_tracking_id',
	'invoices_account_id_field',
	'invoices_account_number_field',
	'invoices_autotask_dir',
	'invoices_autotask_archive_dir',
	'invoices_southware_dir',
	'accounts_southware_dir',
	'accounts_southware_archive_dir',
	'accounts_autotask_dir',
	);

$missing_ini_vars = array ();	
foreach($required_ini_vars as $v) if(!isset($ini[$v])) $missing_ini_vars[] = $v;
if(!empty($missing_ini_vars))
	write_out ("ERROR: Missing ini directive(s) \"" . implode(', ', $missing_ini_vars) . "\" in {$_REQUEST['ini']}", 1, 1, __FILE__, __LINE__);
//print_r ($ini); exit;

// timezone 
$timezone = 'America/New_York';
if (isset ($ini['timezone'])) $timezone = $ini['timezone'];
date_default_timezone_set ($timezone);

// now we can get to work ...
// set the autotask wsdl for the zone
$ini['autotask_api_wsdl'] = "https://webservices{$ini['autotask_api_zone']}.autotask.net/atservices/1.6/atws.wsdl";

// headers arrays of name, context, value
$meta = array (
	array ('Autotask Account ID', 'account', 'id'),
	array ('Customer Number', 'account', 'AccountNumber'),
//	array ('Customer Inactive?', 'account', 'Active'),
//	array ('Account Type', 'account', 'AccountType'),
	array ('Customer Name', 'account', 'AccountName'),
	array ('Address Line 1', 'account', 'Address1'),
	array ('Address Line 2', 'account', 'Address2'),
	array ('City', 'account', 'City'),
	array ('State', 'account', 'State'),
	array ('Zip Code', 'account', 'PostalCode'),
	array ('Contact', 'contact', 'name'),
	array ('EMail Address', 'contact', 'email'),
	array ('Phone Number', 'account', 'Phone'),
	array ('Fax No', 'account', 'Fax'),
	array ('Salesperson Number', 'account', 'OwnerResourceID'),
	array ('Salesperson Name', 'owner', 'name'),
	array ('Salesperson Initials', 'owner', 'initials'),
	array ('Customer Type', 'account', 'MarketSegmentID'),
//	array ('Balance Method [O,B]', 'literal', 'O'),
//	array ('Statement Frequency', 'literal', 'M'),
//	array ('Credit Limit', 'literal', ''),
//	array ('Credit Rating', 'literal', ''),
	array ('Apply Finance Chrgs?', 'literal', 'N'),
	array ('Ship Via Code', 'literal', 'DEL'),
//	array ('Requires P/O ? Y/N', 'literal', ''),
	array ('Group Number', 'account', 'ParentAccountID'),
//	array ('Price Level', 'literal', '1'),
//	array ('Terms Code', 'literal', ''),
	array ('Tax Code', 'literal', ''),
	array ('Date Customer Added', 'calc', "date('m/d/y')"),
//	array ('Allow Subs?', 'literal', 'N'),
//	array ('Allow B/Os?', 'literal', 'Y'),
//	array ('Tax #', 'literal', ''),
//	array ('Allow Partial Ship?', 'literal', 'N S'),
//	array ('Remind to Fax?', 'literal', 'N'),
//	array ('Bill Shipping?', 'literal', 'Y'),
	array ('Web Address', 'account', 'WebAddress'),
//	array ('Territory', 'account', 'TerritoryID'),
//	array ('Key Account Icon', 'account', 'KeyAccountIcon'),
	);

// OK! Connect to AT:
// Go get authdata!
$options = array (
	'login' => $ini['autotask_api_user'],
	'password' => $ini['autotask_api_password'],
	);
try {
	set_time_limit (30);
	$soapClient = new SoapClient ($ini['autotask_api_wsdl'], $options);
	$soapHeader = new SoapHeader('http://autotask.net/ATWS/v1_6/','AutotaskIntegrations', array('IntegrationCode' => $ini['autotask_tracking_id']), false);
	$soapClient->__setSoapHeaders($soapHeader);
} catch (Exception $e) {  
	write_out ("ERROR: Failed connecting to Autotask: " . $e->getMessage(), 1, 1, __FILE__, __LINE__); 
}

// as we process invoices, we will be keeping track of the accounts we have matched and the ones needed!
$accts_matched = array ();
$accts_needed = array ();

// but first we need to update account numbers ... southware -> autotask ... ?
if (!is_dir ($ini['accounts_southware_dir'])) write_out ("ERROR: Cannot locate accounts_southware_dir @ \"{$ini['accounts_southware_dir']}\"", 1, 1, __FILE__, __LINE__);
if (!is_dir ($ini['accounts_southware_archive_dir'])) write_out ("ERROR: Cannot locate accounts_southware_archive_dir @ \"{$ini['accounts_southware_archive_dir']}\"", 1, 1, __FILE__, __LINE__);
write_out ("Checking for updated Southware accounts in {$ini['accounts_southware_dir']}");
$sw_files = scandir ($ini['accounts_southware_dir']);
foreach ($sw_files as $sw_file) {
	if (substr ($sw_file, 0, 1) == '.') continue;
	if (!is_file ($ini['accounts_southware_dir'] . '/' . $sw_file)) continue;
	if (!$sw_accounts = @file_get_contents ($ini['accounts_southware_dir'] . '/' . $sw_file)) write_out ("ERROR: Unable to read \"{$ini['accounts_southware_dir']}/{$sw_file}\"", 1, 1, __FILE__, __LINE__);
	write_out ("Updating accounts from  {$sw_file}");
	$sw_accounts = explode ("\r\n", $sw_accounts);
	$acct_cnt = 0;
	$acct_err = 0;
	foreach ($sw_accounts as $sw_account) {
		$sw_account_fields = explode ("\t", $sw_account);
		if (count ($sw_account_fields) != 2) continue;
		$acct_cnt++;
		// find account in autotask!		
		$xml = xmlwriter_open_memory();
		xmlwriter_start_document ($xml);
		xmlwriter_start_element($xml, 'queryxml');
			xmlwriter_start_element($xml, 'entity');
				xmlwriter_text ($xml, 'Account');
			xmlwriter_end_element($xml);
			xmlwriter_start_element($xml, 'query');
				xmlwriter_start_element($xml, 'condition');
					xmlwriter_start_element($xml, 'field');
						xmlwriter_text ($xml, 'id');
						xmlwriter_start_element($xml, 'expression');
							xmlwriter_write_attribute ($xml, 'op', 'equals');
							xmlwriter_text ($xml, $sw_account_fields[1]);
						xmlwriter_end_element($xml);
					xmlwriter_end_element($xml);
				xmlwriter_end_element($xml);
			xmlwriter_end_element($xml);
		xmlwriter_end_element($xml);
		xmlwriter_end_document ($xml);
		$xml = xmlwriter_output_memory ($xml);
		
		$params = array ('sXML' => $xml);
		
		try {
			set_time_limit (30);
			$soapResponse = $soapClient->query($params);
			// print_r ($soapResponse); exit;
		} catch (SoapFault $e) {
			write_out ("ERROR: SOAP fault on Autotask account query: " . $e->faultstring, 1, 1, __FILE__, __LINE__);
		}
		
		$entities_a = array ();
		if (isset ($soapResponse->queryResult->EntityResults->Entity)) $entities_a = $soapResponse->queryResult->EntityResults->Entity;
		if (!is_array ($entities_a)) $entities_a = array ($entities_a);
		// print_r ($entities_a); exit;
		
		// found account?
		if (empty ($entities_a)) {
			write_out ("WARNING: Account {$sw_account_fields[1]} not found in Autotask ... account update skipped!", 1, 0, __FILE__, __LINE__);
			$acct_err++;
			continue;
		}
		
		// update the account(s) (just 1 in this case)
		foreach ($entities_a as $er_a) {
		
			$aObj = new stdClass();
			$aObj->id = $sw_account_fields[1];
			$aObj->AccountNumber = new SoapVar($sw_account_fields[0], XSD_STRING);
			
			$vars = get_object_vars($er_a); // print_r ($vars); exit;
			foreach ($vars as $k => $v) {
				if (in_array ($k, array ('id', 'AccountNumber', 'CreateDate', 'LastActivityDate'))) continue;
				if (is_object ($er_a->$k)) continue;
				$v = trim ($v);
				if (strstr ($k, 'Active') !== false) {
					$aObj->$k = !empty ($er_a->$k);
				} elseif ($v == '') {
					$aObj->$k = null;
				} else {
					$aObj->$k = new SoapVar($v, XSD_STRING);
				}
			}
			
			$sObj = new SoapVar($aObj, SOAP_ENC_OBJECT, 'Account', 'http://autotask.net/ATWS/v1_6/');
			$entArray = array($sObj);
			$ents = new SoapVar($entArray, SOAP_ENC_OBJECT, 'ArrayOfEntity', 'http://autotask.net/ATWS/v1_6/');
			// print_r ($ents); exit;

			try {
				set_time_limit (30);
				$soapResponse = $soapClient->update(new SoapParam(array('Entities'=>$ents), 'Entities'));
			} catch (SoapFault $e) {
				write_out ("Error updating Autotask account info. Received SOAP Fault: " . $e->faultstring, 1, 1, __FILE__, __LINE__);
			}
			// print_r ($soapResponse); exit;
			
			$return = (int) $soapResponse->updateResult->ReturnCode;
			
			if ($return == 1) {
				write_out ("Updated {$er_a->AccountName}");
			} else {
				$errors = array ();
				foreach ($soapResponse->updateResult->Errors->ATWSError as $e) $errors[] = (string) $e->Message;
				write_out ("WARNING: Error updating {$sw_account_fields[1]}: " . implode (' / ', $errors), 1, 0, __FILE__, __LINE__);
				$acct_err++;
				continue;
			}
			// record the match!
			$accts_matched[$sw_account_fields[1]] = $sw_account_fields[0];
		} // end each account to update
	} // end each account in the southware file
	if ($acct_cnt == 0) {
		write_out ("No valid account records found in {$sw_file} ... Please validate its format. File NOT archived.", 1, 0, __FILE__, __LINE__);
	} elseif ($acct_err > 0) {
		write_out ("Errors encountered while processing {$sw_file} ... File NOT archived.", 1, 0, __FILE__, __LINE__);
	} else {
		write_out ("{$acct_cnt} account records updated with Southware account numbers from {$sw_file}");
		if (@rename ($ini['accounts_southware_dir'] . '/' . $sw_file, $ini['accounts_southware_archive_dir'] . '/' . $sw_file)) {
			write_out ("Archived {$sw_file} in {$ini['accounts_southware_archive_dir']}");
		} else {
			write_out ("Unable to archive/move {$sw_file} to {$ini['accounts_southware_archive_dir']}", 1, 0, __FILE__, __LINE__);
		}
	}
} // end each southware file

// any invoice files to process?
if (!is_dir ($ini['invoices_autotask_dir'])) write_out ("ERROR: Cannot locate invoices_autotask_dir @ \"{$ini['invoices_autotask_dir']}\"", 1, 1, __FILE__, __LINE__);
if (!is_dir ($ini['invoices_autotask_archive_dir'])) write_out ("ERROR: Cannot locate invoices_autotask_archive_dir @ \"{$ini['invoices_autotask_archive_dir']}\"", 1, 1, __FILE__, __LINE__);
write_out ("Checking for Autotask invoice exports in {$ini['invoices_autotask_dir']}");

// do I need to exclude any columns from my output?
$exclude_at_columns = '';
if (isset ($ini['invoice_skip_columns'])) $exclude_at_columns = $ini['invoice_skip_columns'];
if (isset ($_REQUEST['invoice_skip_columns'])) $exclude_at_columns = $_REQUEST['invoice_skip_columns'];
if (empty ($exclude_at_columns)) {
	$exclude_at_columns = array ();
} else {
	$exclude_at_columns = explode (',', $exclude_at_columns);
}

// now look for files
$at_files = scandir ($ini['invoices_autotask_dir']);
foreach ($at_files as $at_file) {
	if (substr ($at_file, 0, 1) == '.') continue;
	if (!is_file ($ini['invoices_autotask_dir'] . '/' . $at_file)) continue;
	if (!$fhi = @fopen ($ini['invoices_autotask_dir'] . '/' . $at_file, 'r')) write_out ("ERROR: Unable to read \"{$ini['invoices_autotask_dir']}/{$at_file}\"", 1, 1, __FILE__, __LINE__);
	
	// create temp output file in archive directory
	$tmp_at_out = tempnam($ini['invoices_autotask_archive_dir'], 'CFS');
	if (!$fho = @fopen ($tmp_at_out , 'w')) write_out ("ERROR: Unable to create temporary file in \"{$ini['invoices_autotask_archive_dir']}\"", 1, 1, __FILE__, __LINE__);

	write_out ("Processing invoices from  {$at_file} ...");
	// process header each time ... maybe the files are in different formats!?!
	$header = 0;
	$acct_id_fld = -1;
	$acct_no_fld = -1;
	$truncate_at_fld = -1;
	$exclude_at_flds = array ();
	$rows = 0;
	$incompletes = 0; // how many incomplete rows in _this_ file?

	while ( ($data = fgetcsv($fhi) ) !== FALSE ) {
		if ($header == 0) {
			$header = count ($data);
			foreach ($data as $k => $v) {
				if ($v == $ini['invoices_account_id_field']) $acct_id_fld = $k;
				if ($v == $ini['invoices_account_number_field']) $acct_no_fld = $k;
				if (isset ($ini['invoice_truncate_column']) and $v == $ini['invoice_truncate_column']) $truncate_at_fld = $k;
				if (in_array ($v, $exclude_at_columns)) $exclude_at_flds[] = $k;
			}
			if ($acct_id_fld == -1) write_out ("ERROR: Unable to locate {$ini['invoices_account_id_field']} header (set as invoices_account_id_field in \"{$_REQUEST['ini']}\") in \"{$ini['invoices_autotask_dir']}/{$at_file}\"", 1, 1, __FILE__, __LINE__);
			if ($acct_no_fld == -1) write_out ("ERROR: Unable to locate {$ini['invoices_account_number_field']} header (set as invoices_account_number_field in \"{$_REQUEST['ini']}\") in \"{$ini['invoices_autotask_dir']}/{$at_file}\"", 1, 1, __FILE__, __LINE__);
			// set up clean csv for southware
			foreach ($exclude_at_flds as $v) unset ($data[$v]);
			foreach ($data as $k => $v) $data[$k] = '_BEGFLD_' . $v . '_ENDFLD_';
			$data[] = '_ENDLIN_';
			fputcsv ($fho, $data);
			continue;
		}
		if (empty ($data)) continue;
		$rows++;
		if (count ($data) != $header) {
			// try the "self healing" technicque!
			if ($truncate_at_fld >=0 and count ($data) > $header) {
				$i = $truncate_at_fld;
				while (true) {
					$i++;
					unset ($data[$i]);
					if (count ($data) <= $header) break;
				}
			} else {
				write_out ("ERROR: Column count mismatch in data row {$rows} of \"{$ini['invoices_autotask_dir']}/{$at_file}\"", 1, 1, __FILE__, __LINE__);
			}
		}
		// now check for accounts in file!
		if (empty ($data[$acct_no_fld])) {
			if (isset ($accts_matched[$data[$acct_id_fld]])) {
				$data[$acct_no_fld] = $accts_matched[$data[$acct_id_fld]];
			} elseif (in_array ($data[$acct_id_fld], $accts_needed)) {
				// OK I already know I'm going to need to get this one
				$incompletes++;
			} else {
				// find account and see if it has an AccountNumber
				write_out ("Querying Autotask for account {$data[$acct_id_fld]} ...");
				$xml = xmlwriter_open_memory();
				xmlwriter_start_document ($xml);
				xmlwriter_start_element($xml, 'queryxml');
					xmlwriter_start_element($xml, 'entity');
						xmlwriter_text ($xml, 'Account');
					xmlwriter_end_element($xml);
					xmlwriter_start_element($xml, 'query');
						xmlwriter_start_element($xml, 'condition');
							xmlwriter_start_element($xml, 'field');
								xmlwriter_text ($xml, 'id');
								xmlwriter_start_element($xml, 'expression');
									xmlwriter_write_attribute ($xml, 'op', 'equals');
									xmlwriter_text ($xml, $data[$acct_id_fld]);
								xmlwriter_end_element($xml);
							xmlwriter_end_element($xml);
						xmlwriter_end_element($xml);
					xmlwriter_end_element($xml);
				xmlwriter_end_element($xml);
				xmlwriter_end_document ($xml);
				$xml = xmlwriter_output_memory ($xml);
				
				$params = array ('sXML' => $xml);
				
				try {
					set_time_limit (30);
					$soapResponse = $soapClient->query($params);
					// print_r ($soapResponse); exit;
				} catch (SoapFault $e) {
					write_out ("ERROR: SOAP fault on Autotask account query: " . $e->faultstring, 1, 1, __FILE__, __LINE__);
				}
				
				$entities_a = array ();
				if (isset ($soapResponse->queryResult->EntityResults->Entity)) $entities_a = $soapResponse->queryResult->EntityResults->Entity;
				if (!is_array ($entities_a)) $entities_a = array ($entities_a);
				
				// match it if I got it!
				foreach ($entities_a as $er_a) {
					$v = (string) $er_a->AccountNumber;
					if (empty ($v)) continue;
					$accts_matched[$data[$acct_id_fld]] = $v;
				}
				
				// did I get it?
				if (isset ($accts_matched[$data[$acct_id_fld]])) {
					$data[$acct_no_fld] = $accts_matched[$data[$acct_id_fld]];
				} else {
					$accts_needed[] = $data[$acct_id_fld];
					$incompletes++;
				}
			}
		} // end if need account
		// set up clean csv for southware
		foreach ($exclude_at_flds as $v) unset ($data[$v]);
		foreach ($data as $k => $v) $data[$k] = '_BEGFLD_' . $v . '_ENDFLD_';
		$data[] = '_ENDLIN_';
		fputcsv ($fho, $data);
	} // end while csv data
	
	// close file handles
	fclose ($fhi);
	fclose ($fho);
	
	// how did I do?
	if ($incompletes == 0) {
		// I don't need any accounts from this file!
		// Clean the csv & Spin the dates!
		$file_contents = file_get_contents ($tmp_at_out);
		@unlink($tmp_at_out);
		// southware-ize the csv!
		$file_contents = str_replace (array ("\"_BEGFLD_", "_ENDFLD_\"", "_BEGFLD_", "_ENDFLD_", ",_ENDLIN_"),  array ("\"", "\"", "\"", "\"", "\r"), $file_contents);
		// spin the dates!
		$file_contents = preg_replace_callback("|,\"(\d{1,2})/(\d{1,2})/(\d{4})\",|", "sql_date", $file_contents);
		if (@file_put_contents ($ini['invoices_southware_dir'] . '/' . $at_file, $file_contents) === false) write_out ("ERROR: Unable to create file \"{$ini['invoices_southware_dir']}/{$at_file}\"", 1, 1, __FILE__, __LINE__);
		// file written, now archive this file
		if (!@rename ($ini['invoices_autotask_dir'] . '/' . $at_file, $ini['invoices_autotask_archive_dir'] . '/' . $at_file)) write_out ("ERROR: Unable to move file \"{$at_file}\" into archive directory \"{$ini['invoices_autotask_archive_dir']}\"", 1, 1, __FILE__, __LINE__);
		write_out ("Successfully processed {$rows} invoice rows from {$at_file} ... file forwarded & original archived!");
	} else {
		@unlink($tmp_at_out);
		write_out ("{$rows} invoice rows from {$at_file} pending update of " . number_format($incompletes) . " line(s) with missing account info ... file retained for future processing!");
	}
	@unlink($tmp_at_out);
} // end each autotask invoice file

die ('HALT PROCESS');

if (empty ($accts_needed)) write_out ('DONE!', 0, 1);

// Get account parameter
if (!isset ($_REQUEST['account'])) write_out ('DONE! (No account parameter supplied.)', 0, 1);

// find account(s)!
write_out ('Querying Autotask accounts ...');
$xml = xmlwriter_open_memory();
xmlwriter_start_document ($xml);
xmlwriter_start_element($xml, 'queryxml');
	xmlwriter_start_element($xml, 'entity');
		xmlwriter_text ($xml, 'Account');
	xmlwriter_end_element($xml);
	xmlwriter_start_element($xml, 'query');
	
	if ($_REQUEST['account'] != 'all') {
		xmlwriter_start_element($xml, 'condition');
			xmlwriter_start_element($xml, 'field');
				xmlwriter_text ($xml, 'id');
				xmlwriter_start_element($xml, 'expression');
					xmlwriter_write_attribute ($xml, 'op', 'equals');
					xmlwriter_text ($xml, $_REQUEST['account']);
				xmlwriter_end_element($xml);
			xmlwriter_end_element($xml);
		xmlwriter_end_element($xml);
	} // end if not all accounts

		xmlwriter_start_element($xml, 'condition');
			xmlwriter_start_element($xml, 'field');
				xmlwriter_text ($xml, 'AccountNumber');
				xmlwriter_start_element($xml, 'expression');
					xmlwriter_write_attribute ($xml, 'op', 'equals');
					xmlwriter_text ($xml, '');
				xmlwriter_end_element($xml);
			xmlwriter_end_element($xml);
		xmlwriter_end_element($xml);
	xmlwriter_end_element($xml);
xmlwriter_end_element($xml);
xmlwriter_end_document ($xml);
$xml = xmlwriter_output_memory ($xml);

$params = array ('sXML' => $xml);

try {
	set_time_limit (30);
	$soapResponse = $soapClient->query($params);
	// print_r ($soapResponse); exit;
} catch (SoapFault $e) {
	write_out ("ERROR: SOAP fault on Autotask account query: " . $e->faultstring, 1, 1, __FILE__, __LINE__);
}

$entities_a = array ();
if (isset ($soapResponse->queryResult->EntityResults->Entity)) $entities_a = $soapResponse->queryResult->EntityResults->Entity;
if (!is_array ($entities_a)) $entities_a = array ($entities_a);

if (empty ($entities_a)) write_out ("No accounts require import to Southware at this time!", 0, 1);
write_out (count ($entities_a) . " account(s) found with no Southware account number ...");

// outfile
if (!is_dir ($ini['accounts_autotask_dir'])) write_out ("ERROR: Cannot locate accounts_autotask_dir @ \"{$ini['accounts_autotask_dir']}\"", 1, 1, __FILE__, __LINE__);

// create file in temp initially ...
$account_export_file = 'AT_Accounts_' . date ('YmdHis') . '.tab';
if (!$fho = @fopen (sys_get_temp_dir () . '/' . $account_export_file, 'w')) write_out ("ERROR: Unable to open file \"" . sys_get_temp_dir () . "/{$account_export_file}\"", 1, 1, __FILE__, __LINE__);
// write headers?
$headers = array ();
foreach ($meta as $v) $headers[] = $v[0];
fwrite ($fho, implode ("\t", $headers) . "\n");

$resource = array();
$accounts = 0;
foreach ($entities_a as $er_a) {

	write_out ('Exporting ' . $er_a->AccountName);
	
	// contacts! ... only setting if 1 active contact!
	$xml = xmlwriter_open_memory();
	xmlwriter_start_document ($xml);
	xmlwriter_start_element($xml, 'queryxml');
		xmlwriter_start_element($xml, 'entity');
			xmlwriter_text ($xml, 'Contact');
		xmlwriter_end_element($xml);
		xmlwriter_start_element($xml, 'query');
			xmlwriter_start_element($xml, 'condition');
				xmlwriter_start_element($xml, 'field');
					xmlwriter_text ($xml, 'AccountID');
					xmlwriter_start_element($xml, 'expression');
						xmlwriter_write_attribute ($xml, 'op', 'equals');
						xmlwriter_text ($xml, $er_a->id);
					xmlwriter_end_element($xml);
				xmlwriter_end_element($xml);
			xmlwriter_end_element($xml);
			xmlwriter_start_element($xml, 'condition');
				xmlwriter_start_element($xml, 'field');
					xmlwriter_text ($xml, 'Active');
					xmlwriter_start_element($xml, 'expression');
						xmlwriter_write_attribute ($xml, 'op', 'equals');
						xmlwriter_text ($xml, 1);
					xmlwriter_end_element($xml);
				xmlwriter_end_element($xml);
			xmlwriter_end_element($xml);
		xmlwriter_end_element($xml);
	xmlwriter_end_element($xml);
	xmlwriter_end_document ($xml);
	$xml = xmlwriter_output_memory ($xml);
	
	$params = array ('sXML' => $xml);
	
	try {
		set_time_limit (30);
		$soapResponse = $soapClient->query($params);
		// print_r ($soapResponse); exit;
	} catch (SoapFault $e) {
		write_out ("ERROR: SOAP fault on Autotask contact query: " . $e->faultstring, 1, 1, __FILE__, __LINE__);
	}
	
	$entities_c = array ();
	if (isset ($soapResponse->queryResult->EntityResults->Entity)) $entities_c = $soapResponse->queryResult->EntityResults->Entity;
	if (!is_array ($entities_c)) $entities_c = array ($entities_c);
	
	// if there is one active contact, set it as primary, otherwise bail out!
	$contact = array('name' => '', 'email' => '');
	foreach ($entities_c as $er_c) {
		if (!empty ($contact['name'])) {
			$contact = array('name' => '', 'email' => '');
			break;
		}
		$contact['name'] = (string) $er_c->LastName . ', ' . (string) $er_c->FirstName;
		if (isset ($er_c->EMailAddress)) $contact['email'] .= (string) $er_c->EMailAddress;		
	}
		
	// owner ... might have already grabbed it!
	if(!isset($resource[$er_a->OwnerResourceID])) {
	
		$resource[$er_a->OwnerResourceID] = array (
			'name' => '',
			'initials' => '',
			);
	
		$xml = xmlwriter_open_memory();
		xmlwriter_start_document ($xml);
		xmlwriter_start_element($xml, 'queryxml');
			xmlwriter_start_element($xml, 'entity');
				xmlwriter_text ($xml, 'Resource');
			xmlwriter_end_element($xml);
			xmlwriter_start_element($xml, 'query');
				xmlwriter_start_element($xml, 'condition');
					xmlwriter_start_element($xml, 'field');
						xmlwriter_text ($xml, 'id');
						xmlwriter_start_element($xml, 'expression');
							xmlwriter_write_attribute ($xml, 'op', 'equals');
							xmlwriter_text ($xml, $er_a->OwnerResourceID);
						xmlwriter_end_element($xml);
					xmlwriter_end_element($xml);
				xmlwriter_end_element($xml);
			xmlwriter_end_element($xml);
		xmlwriter_end_element($xml);
		xmlwriter_end_document ($xml);
		$xml = xmlwriter_output_memory ($xml);
		
		$params = array ('sXML' => $xml);
		
		try {
			set_time_limit (30);
			$soapResponse = $soapClient->query($params);
			// print_r ($soapResponse); exit;
		} catch (SoapFault $e) {
			write_out ("ERROR: SOAP fault on Autotask resource query: " . $e->faultstring, 1, 1, __FILE__, __LINE__);
		}
		
		$entities_o = array ();
		if (isset ($soapResponse->queryResult->EntityResults->Entity)) $entities_o = $soapResponse->queryResult->EntityResults->Entity;
		if (!is_array ($entities_o)) $entities_o = array ($entities_o);
		
		foreach ($entities_o as $er_o) {
			$resource[$er_a->OwnerResourceID]['name'] = (string) $er_o->LastName . ', ' . (string) $er_o->FirstName;
			if (isset ($er_o->Initials)) $resource[$er_a->OwnerResourceID]['initials'] .= (string) $er_o->Initials;
			break;
		}
		
	} // end if resource doesn't exist
	
	$data = array ();
	foreach ($meta as $v) {
		$fld = '';
		switch ($v[1]) {
			case 'account':
				if (isset ($er_a->$v[2])) $fld = (string) $er_a->$v[2];
				break;
			case 'contact':
				$fld = $contact[$v[2]];
				break;
			case 'owner':
				$fld = $resource[$er_a->OwnerResourceID][$v[2]];
				break;
			case 'literal':
				$fld = $v[2];
				break;
			case 'calc':
				eval ('$fld = ' . $v[2] . ';');
				break;
			default:
				write_out ("ERROR: Unknown context {$v[1]}", 1, 1, __FILE__, __LINE__);
		}
		$data[] = data_clean($fld);
	}
	fwrite ($fho, implode ("\t", $data) . "\n");
	$accounts++;
}

fclose ($fho);
if (!@rename (sys_get_temp_dir () . '/' . $account_export_file, $ini['accounts_autotask_dir'] . '/' . $account_export_file)) write_out ("Unable to archive/move {$account_export_file} to {$ini['accounts_autotask_dir']}", 1, 1, __FILE__, __LINE__);
write_out ("SUCCESS: {$accounts} account(s) written to {$ini['accounts_autotask_dir']}/{$account_export_file}", 0, 1);

function data_clean ($d) {
	$d = trim ($d);
	$d = str_replace (array ("\t", "\n", "\r"), array ('', ' ', ''), $d);
	return $d;
}

function write_out ($message, $error = 0, $fatal = 0, $file = '', $line = '') {

	if (!isset ($GLOBALS['exec_errors'])) $GLOBALS['exec_errors'] = array ();
	if (!empty ($error)) {
		if (!empty ($file)) $message .= " ({$file} Line {$line})";
		$GLOBALS['exec_errors'][] = $message;
	}
	if (!empty ($message)) echo $message . "\n";
	
	if (empty ($fatal)) return;

	echo "================================================\n";
	echo "Run Time = " . number_format (time() - START_TIME) . " seconds\n";
	echo number_format (count ($GLOBALS['exec_errors'])) . " errors\n";
	echo "DONE\n";
	if (count ($GLOBALS['exec_errors']) > 0) {
		// mail (MAIL_ERRORS, 'AccuStandard Magento / FileMaker Sync ERROR', "The following error(s) occurred:\n\n" . implode ("\n", $GLOBALS['exec_errors']), 'From: sync@accustandard.com');
	}
	exit;

}

function sql_date ($matches) {
	$date = $matches[3] . '-' . str_pad($matches[1], 2, '0', STR_PAD_LEFT) . '-' . str_pad($matches[2], 2, '0', STR_PAD_LEFT);
	$date = strtotime ($date);
	if (empty ($date)) return $matches[0];
	return ',' . date ('m/d/y', $date) . ',';	
}

function help_txt() {
	return <<<EOD

Usage Example:
    PROMPT>php cfs_at_sw.php

OPTIONAL COMMAND LINE PARAMETERS
ini - Path to an ini file
    Usage: ini=foo.ini
    Usage: ini=c:/temp/foo.ini
    Usage: ini="c:/dir name with spaces/file name with spaces.ini"

Note: if no ini file specified, any ini file in the same directory and having the same base name as this script will be used!

EOD;
}

?>