<?php
	// $Id$
	// $Author$
	// Modified: jc.boursiquot@b-mas.com 2007-03-09

// Class: FreeMED.Remitt
//
//	Communication and document creation class for interfacing with
//	a REMITT server.
//
class Remitt {

	var $ref; // references hash
	var $_cache; // result cache
	var $_connection; // XMLRPC connection

	function Remitt ( $server = '127.0.0.1' ) {
		$this->protocol = 'http';
		$this->server = $server;
		$this->port = freemed::config_value('remitt_port'); 
		if (!$this->port) { $this->port = '7688'; }
		$this->_connection = CreateObject('PHP.xmlrpc_client', '/RPC2', $this->server, $this->port);
		// TODO: set credentials ...
		
	} // end constructor

	// Method: GetFileList
	//
	// Parameters:
	//
	//	$type - Type of files
	//
	//	$criteria - Type of criteria (ex: years)
	//
	//	$value - Criteria
	//
	// Returns:
	//
	//	Array of files
	//
	function GetFileList ( $type, $criteria, $value ) {
		$results = $this->_call(
			'Remitt.Interface.FileList',
			array (
				CreateObject('PHP.xmlrpcval', $type, 'string'),
				CreateObject('PHP.xmlrpcval', $criteria, 'string'),
				CreateObject('PHP.xmlrpcval', $value, 'string')
			),
			false
		);
		return $results;
	} // end method GetFileList

	// Method: GetProtocolVersion
	//
	//	Retrieves the protocol revision being used by a REMITT
	//	server. Is supported from REMITT version 0.1+.
	//
	// Returns:
	//
	//	Version number.
	//
	function GetProtocolVersion ( ) {
		if (!$this->GetServerStatus()) { return NULL; }
		$this->_connection->SetCredentials(
			$_SESSION['remitt']['sessionid'],
			$_SESSION['remitt']['key']
		);
		$version = $this->_call( 'Remitt.Interface.ProtocolVersion' );
		return $version;
	} // end method GetProtocolVersion

	// Method: GetServerStatus
	//
	//	Determine if the REMITT server is up.
	//
	// Returns:
	//
	//	true if up, false if not
	//
	function GetServerStatus ( ) {
		if (@fsockopen($this->server, $this->port, $_err, $_str, 10)) {
			return true;
		} else {
			return false;
		}
	} // end method GetServerStatus

	// Method: GetStatus
	//
	//	Retrieves the current status of a REMITT billing run by
	//	its unique identifier.
	//
	// Parameters:
	//
	//	$unique - Unique identifier
	//
	// Returns:
	//
	//	NULL meaning still in process, or name of result file.
	//
	function GetStatus ( $unique ) {
		if (!$this->GetServerStatus()) {
			trigger_error(__("The REMITT server is not running."), E_USER_ERROR);
		}
		$this->_connection->SetCredentials(
			$_SESSION['remitt']['sessionid'],
			$_SESSION['remitt']['key']
		);
		$status = $this->_call(
			'Remitt.Interface.GetStatus',
			array(
				CreateObject('PHP.xmlrpcval', $unique, 'string')
			)
		);
		switch ($status) {
			case -1: return NULL;
			case -2: return NULL;
			default: return $status;
		} // end switch status
	} // end method GetStatus

	// Method: ListOptions
	//
	//	Wrapper for Remitt.Interface.ListOptions
	//
	// Parameters:
	//
	//	$type - Plugin type (Render, Translation, Transport)
	//
	//	$plugin - Name of the plugin to query
	//
	//	$media - (optional) Electronic or Paper. If neither is
	//	specified, defaults to all media forms. (Default is NULL)
	//
	//	$format - (optional) Input XML format. Defaults to
	//	NULL, which disables the qualification.
	//
	// Returns:
	//
	//	Array of available options for the specified plugin
	//
	function ListOptions ( $type, $plugin, $media = NULL, $format = NULL ) {
		$this->_connection->SetCredentials(
			$_SESSION['remitt']['sessionid'],
			$_SESSION['remitt']['key']
		);

		if (!isset($this->_cache['ListOptions'][$type][$plugin]['x_'.$format])) {
			if ($format) {
				$this->_cache['ListOptions'][$type][$plugin]['x_'.$format] = $this->_call(
					'Remitt.Interface.ListOptions',
					array(
						CreateObject('PHP.xmlrpcval', $type, 'string'),
						CreateObject('PHP.xmlrpcval', $plugin, 'string'),
						CreateObject('PHP.xmlrpcval', $format, 'string')
					)
				);
			} else {
				$this->_cache['ListOptions'][$type][$plugin]['x_'.$format] = $this->_call(
					'Remitt.Interface.ListOptions',
					array(
						CreateObject('PHP.xmlrpcval', $type, 'string'),
						CreateObject('PHP.xmlrpcval', $plugin, 'string')
					)
				);
			}
		}

		// Process into nice form for select widgets
		foreach ($this->_cache['ListOptions'][$type][$plugin]['x_'.$format] AS $k => $v) {
			if (($media == NULL) or ($v['Media'] == $media)) {
				$r[$v['Description']] = $k;
			}
		}
		return $r;
	} // end method ListOptions
			
	// Method: ListPlugins
	//
	//	Wrapper for Remitt.Interface.ListPlugins
	//
	// Parameters:
	//
	//	$type - Plugin type (Render, Translation, Transport)
	//
	// Returns:
	//
	//	Array of available plugins
	//
	function ListPlugins ( $type ) {
		$this->_connection->SetCredentials(
			$_SESSION['remitt']['sessionid'],
			$_SESSION['remitt']['key']
		);

		if (!isset($this->_cache['ListPlugins'][$type])) {
			$this->_cache['ListPlugins'][$type] = $this->_call(
				'Remitt.Interface.ListPlugins',
				array(
					CreateObject('PHP.xmlrpcval', $type, 'string')
				)
			);
		}
		return $this->_cache['ListPlugins'][$type];
	} // end method ListPlugins
			
	// Method: ListOutputMonths
	//
	//	Wrapper for Remitt.Interface.GetOutputMonths
	//
	// Parameters:
	//
	//	$year - (optional) Year to list months for
	//
	// Returns:
	//
	//	Hash of years => number of output files available.
	//
	function ListOutputMonths ( $year = NULL ) {
		$this->_connection->SetCredentials(
			$_SESSION['remitt']['sessionid'],
			$_SESSION['remitt']['key']
		);
		if ($year) {
			$months = $this->_call( 
				'Remitt.Interface.GetOutputMonths',
				array (
					CreateObject('PHP.xmlrpcval', $year, 'string'),
				)
			);
		} else {
			$months = $this->_call( 'Remitt.Interface.GetOutputMonths' );
		}
		if (!is_array($months)) { $months = array ( $months ); }
		return $months;
	} // end method ListOutputMonths
			
	// Method: ListOutputYears
	//
	//	Wrapper for Remitt.Interface.GetOutputYears
	//
	// Returns:
	//
	//	Hash of years => number of output files available.
	//
	function ListOutputYears ( ) {
		$this->_connection->SetCredentials(
			$_SESSION['remitt']['sessionid'],
			$_SESSION['remitt']['key']
		);
		$years = $this->_call( 'Remitt.Interface.GetOutputYears' );
		if (!is_array($years)) { $years = array ( $years ); }
		return $years;
	} // end method ListOutputYears
			
	// Method: Login
	//
	//	Logs into the Remitt server, and stores authentication
	//	data received in the session.
	//
	// Parameters:
	//
	//	$username - Username to be passed to the Remitt server
	//
	//	$password - Password to be passed to the Remitt server
	//
	function Login ( $username, $password ) {
/*
		// Check for session data
		if ($_SESSION['remitt']) { 
			// Set credentials properly
			$this->_connection->SetCredentials(
				$_SESSION['remitt']['sessionid'],
				$_SESSION['remitt']['key']
			);

			// Skip the rest
			return false; 
		}
*/

		// Otherwise, attempt to establish credentials
		//print "Logging in with $username and $password<br/>\n";
		$this->_connection->SetCredentials($username, $password);
		$message = CreateObject('PHP.xmlrpcmsg',
			'Remitt.Interface.SystemLogin',
			array(
				CreateObject('PHP.xmlrpcval', $username, 'string'),
				CreateObject('PHP.xmlrpcval', $password, 'string')
			)
		);
		$response_raw = $this->_connection->send(
			$message,
			0,
			$this->protocol
		);
		$response = $response_raw->deserialize();
		$_SESSION['remitt'] = $response;

		// Set credentials properly
		$this->_connection->SetCredentials(
			$_SESSION['remitt']['sessionid'],
			$_SESSION['remitt']['key']
		);
		//print "Got this: "; print_r($response); print "<br/>\n";

		// Return to program
		return true;
	} // end method Login

	// Method: ProcessBill
	function ProcessBill ( $billkey, $render, $transport ) {
		if (!$this->GetServerStatus()) {
			trigger_error(__("The REMITT server is not running."), E_USER_ERROR);
		}
		$billkey_hash = unserialize(freemed::get_link_field($billkey, 'billkey', 'billkey'));
		// For now, just use the first ones ... FIXME FIXME FIXME
		$bc = $bs = $ch = 1;
		$xml = $this->RenderPayerXML($billkey_hash['procedures'], $bc, $bs, $ch);
		//print "length of xml = ".strlen($xml)."<br/>\n";
		$this->_connection->SetCredentials(
			$_SESSION['remitt']['sessionid'],
			$_SESSION['remitt']['key']
		);
		//print "calling with ( ..., XSLT, $render, $transport ) <br/>\n";
		$output = $this->_call(
			'Remitt.Interface.Execute',
			array(
				CreateObject('PHP.xmlrpcval', $xml, 'base64'),
				CreateObject('PHP.xmlrpcval', 'XSLT', 'string'),
				CreateObject('PHP.xmlrpcval', $render, 'string'),
				CreateObject('PHP.xmlrpcval', $transport, 'string')
			)
		);
		return $output;
	} // end method ProcessBill

	// Method: ProcessStatement
	function ProcessStatement ( $procedures ) {
		if (!$this->GetServerStatus()) {
			trigger_error(__("The REMITT server is not running."), E_USER_ERROR);
		}
		// For now, just use the first ones ... FIXME FIXME FIXME
		$xml = $this->RenderStatementXML($procedures);
		//print "length of xml = ".strlen($xml)."<br/>\n";
		$this->_connection->SetCredentials(
			$_SESSION['remitt']['sessionid'],
			$_SESSION['remitt']['key']
		);
		//print "calling with ( ..., XSLT, $render, $transport ) <br/>\n";
		$output = $this->_call(
			'Remitt.Interface.Execute',
			array(
				CreateObject('PHP.xmlrpcval', $xml, 'base64'),
				CreateObject('PHP.xmlrpcval', 'XSLT', 'string'),
				CreateObject('PHP.xmlrpcval', 'statement', 'string'),
				CreateObject('PHP.xmlrpcval', 'PDF', 'string')
			)
		);
		return $output;
	} // end method ProcessStatement

	// Method: StoreBillKey
	//
	//	Stores billing data in a temporary key table.
	//
	// Parameters:
	//
	//	$billkey - Data to be serialized
	//
	// Returns:
	//
	//	Table key for billkey
	//
	function StoreBillKey ( $billkey ) {
		$b = $billkey;
		// Awful, awful hack for PHP misbehaving and inserting arrays into the procedure array
		// ... fixes Mac issues, but is so incredibly ugly.
		if (is_array($b['procedures'][0])) {
			foreach ($b['procedures'] AS $a) {
				$c[] = $a[0];
			}
			$b['procedures'] = $c;
		}

		$query = $GLOBALS['sql']->insert_query (
			'billkey',
			array(
				'billkeydate' => date('Y-m-d'),
				'billkey' => serialize($b)
			)
		);
		$result = $GLOBALS['sql']->query($query);
		//print "query= $query<br/>\n";
		$id = $GLOBALS['sql']->last_record($result, 'billkey');
		syslog(LOG_INFO, 'Remitt.StoreBillKey| created key '.$id);
		return $id;
	} // end method StoreBillKey
	
	// Method: RenderPayerXML
	//
	//	Renders procedure entries into XML file to be transmitted
	//	to REMITT server.
	//
	// Parameters:
	//
	//	$procedures - Array of procedure id keys to be processed.
	//
	//	$bc - Billing contact id. Defaults to 1.
	//
	//	$bs - Billing service id. Default to 1.
	//
	//	$ch - Clearinghouse id. Defaults to 1.
	//
	// Returns:
	//
	//	Text of XML file.
	//
	function RenderPayerXML ( $_procedures, $bc=1, $bs=1, $ch=1 ) {
		// Sanitize and fold procedures array
		if (is_array($_procedures)) {
			foreach ($_procedures AS $k => $v) {
				if (is_array($v)) {
					$procedures = array_merge($procedures, $v);
				} else {
					$procedures[] = $v;
				}
			}
		} else {
			$procedures = array ( $_procedures );
		}

		$buffer .= "<?xml version=\"1.0\"?>\n";

		// Create master document element
		$buffer .= "<remitt doctype=\"payerxml\">\n";

		// global information
		$buffer .= "\n\t<!-- global information -->\n\n";
		$buffer .= $this->_tag('global',
			$this->_tag('generator',
				$this->_tag('program', PACKAGENAME, true).
				$this->_tag('version', VERSION, true),
			false).
			$this->_date('currentdate', date('Y-m-d')).
			$this->_tag('currenttime',
				$this->_tag('hour', date('H'), true).
				$this->_tag('minute', date('i'), true),
			false),
			false);

		// Handle billing service
		$bcobj = freemed::get_link_rec($bc, 'bcontact');
		$buffer .= "\n\t<!-- billing contact $bc -->\n\n".
			"<billingcontact>\n".
			$this->_tag('name', $bcobj['bcname'], true).
			$this->_addr('address', $bcobj['bcaddr'], $bsobj['bccity'], $bsobj['bsctate'], $bsobj['bczip']).
			$this->_phone('phone', $bcobj['bcphone']).
			$this->_tag('tin', $bcobj['bctin'], true).
			$this->_tag('etin', $bcobj['bcetin'], true).
			"</billingcontact>\n\n";

		// Handle billing service
		$bsobj = freemed::get_link_rec($bs, 'bservice');
		$buffer .= "\n\t<!-- billing service $bs -->\n\n".
			"<billingservice>\n".
			$this->_tag('name', $bsobj['bsname'], true).
			$this->_addr('address', $bsobj['bsaddr'], $bsobj['bscity'], $bsobj['bsstate'], $bsobj['bszip']).
			$this->_phone('phone', $bsobj['bsphone']).
			$this->_tag('tin', $bsobj['bstin'], true).
			$this->_tag('etin', $bsobj['bsetin'], true).
			"</billingservice>\n\n";

		// Handle clearinghouse
		$chobj = freemed::get_link_rec($ch, 'clearinghouse');
		$buffer .= "\n\t<!-- clearinghouse $ch -->\n\n".
			"<clearinghouse>\n".
			$this->_tag('name', $chobj['chname'], true).
			$this->_addr('address', $chobj['chaddr'], $chobj['chcity'], $chobj['chstate'], $chobj['chzip']).
			$this->_phone('phone', $chobj['chphone']).
			$this->_tag('etin', $chobj['chetin'], true).
			$this->_tag('x12gssenderid', $chobj['chx12gssender'], true).
			$this->_tag('x12gsreceiverid', $chobj['chx12gsreceiver'], true).
			"</clearinghouse>\n\n";

		// Render all objects (from procedures on) to buffer,
		// and loop to check that they all have XML representations
		// in a hash before proceeding to generate

		$_proc = ( is_array($procedures) ? $procedures :
				array($procedures) );

		foreach ($_proc as $proc) {
			if ($proc) {
			$buffer .= "\n\t<!-- procedure $proc -->\n\n".
				$this->_RenderProcedure($proc).
				"\n";
			}
		}

		foreach ($this->ref['patient'] as $pat) {
			if ($pat) {
			$buffer .= "\n\t<!-- patient $pat -->\n\n".
				$this->_RenderPatient($pat).
				"\n";
			}
		}

		// Loop through all providers
		//$this->ref[$table][$id] = $id;
		foreach ($this->ref['physician'] as $prov) {
			if ($prov) {
			$buffer .= "\n\t<!-- provider $prov -->\n\n".
				$this->_RenderProvider($prov).
				"\n";
			}
		}

		foreach ($this->ref['facility'] as $fac) {
			if ($fac) {
			$buffer .= "\n\t<!-- facility $fac -->\n\n".
				$this->_RenderFacility($fac).
				"\n";
			}
		}

		//print "cov ref array = "; print_r($this->ref['coverage']); print "<br/>\n";
		foreach ($this->ref['coverage'] as $cov) {
			//print "Should have rendered $cov as coverage<br/>\n";
			if ($cov) {
			$buffer .= "\n\t<!-- insured $cov -->\n\n".
				$this->_RenderInsured($cov).
				"\n";
			}
		}

		foreach ($this->ref['insco'] as $pay) {
			if ($pay) {
			$buffer .= "\n\t<!-- payer $pay -->\n\n".
				$this->_RenderPayer($pay).
				"\n";
			}
		}

		foreach ($this->ref['practice'] as $prac) {
			$buffer .= "\n\t<!-- practice $prac -->\n\n".
				$this->_RenderPractice($prac).
				"\n";
		}

		foreach ($this->ref['diagnosis'] as $diag) {
			$buffer .= "\n\t<!-- diagnosis $diag -->\n\n".
				$this->_RenderDiagnosis($diag).
				"\n";
		}

		// Closing tag
		$buffer .= "</remitt>\n";

		return $buffer;
	} // end method RenderPayerXML

	// Method: RenderStatementXML
	//
	//	Renders procedure entries into XML file to be transmitted
	//	to REMITT server for patient statement billing
	//
	// Parameters:
	//
	//	$procedures - Array of procedure id keys to be processed.
	//
	// Returns:
	//
	//	Text of XML file.
	//
	function RenderStatementXML ( $_procedures ) {
		// Sanitize and fold procedures array
		if (is_array($_procedures)) {
			foreach ($_procedures AS $k => $v) {
				if (is_array($v)) {
					$procedures = array_merge($procedures, $v);
				} else {
					$procedures[] = $v;
				}
			}
		} else {
			$procedures = array ( $_procedures );
		}

		$buffer .= "<?xml version=\"1.0\"?>\n";

		// Create master document element
		$buffer .= "<remitt doctype=\"statementxml\">\n";

		// global information
		$buffer .= "\n\t<!-- global information -->\n\n";
		$buffer .= $this->_tag('global',
			$this->_tag('generator',
				$this->_tag('program', PACKAGENAME, true).
				$this->_tag('version', VERSION, true),
			false).
			$this->_date('currentdate', date('Y-m-d')).
			$this->_tag('currenttime',
				$this->_tag('hour', date('H'), true).
				$this->_tag('minute', date('i'), true),
			false),
			false);

		// Render all objects (from procedures on) to buffer,
		// and loop to check that they all have XML representations
		// in a hash before proceeding to generate

		$_proc = ( is_array($procedures) ? $procedures :
				array($procedures) );

		foreach ($_proc as $proc) {
			if ($proc) {
			$buffer .= "\n\t<!-- procedure $proc -->\n\n".
				$this->_RenderProcedure($proc).
				"\n";
			}
		}

		foreach ($this->ref['patient'] as $pat) {
			if ($pat) {
			$buffer .= "\n\t<!-- patient $pat -->\n\n".
				$this->_RenderPatient($pat).
				"\n";
			}
		}

		// Loop through all providers
		//$this->ref[$table][$id] = $id;
		foreach ($this->ref['physician'] as $prov) {
			if ($prov) {
			$buffer .= "\n\t<!-- provider $prov -->\n\n".
				$this->_RenderProvider($prov).
				"\n";
			}
		}

		foreach ($this->ref['facility'] as $fac) {
			if ($fac) {
			$buffer .= "\n\t<!-- facility $fac -->\n\n".
				$this->_RenderFacility($fac).
				"\n";
			}
		}

		foreach ($this->ref['practice'] as $prac) {
			$buffer .= "\n\t<!-- practice $prac -->\n\n".
				$this->_RenderPractice($prac).
				"\n";
		}

		foreach ($this->ref['diagnosis'] as $diag) {
			$buffer .= "\n\t<!-- diagnosis $diag -->\n\n".
				$this->_RenderDiagnosis($diag).
				"\n";
		}

		// Closing tag
		$buffer .= "</remitt>\n";

		return $buffer;
	} // end method RenderStatementXML

	function _RenderDiagnosis ( $diagnosis ) {
		if (!(strpos($diagnosis, ',') === false)) {
			list ($eoc, $diag) = explode (',', $diagnosis);
		} else {
			// Fudge eoc for non-existing one
			$eoc = 0;
			$diag = $diagnosis;
		}

		// Get records from keys
		$e = freemed::get_link_rec($eoc, 'eoc');
		$d = freemed::get_link_rec($diag, 'icd9');

		$buffer .= "<diagnosis id=\"".htmlentities($diagnosis)."\">\n";

		$buffer .= $this->_tag('icd9code', $d['icd9code'], true);
		$buffer .= $this->_tag('icd10code', $d['icd10code'], true);
		$buffer .= $this->_tag('relatedtohcfa', $e['eocrelothercomment'], true);
		$buffer .= $this->_tag('isrelatedtoautoaccident', ($e['eocrelauto'] == 'yes'), true);
		$buffer .= $this->_tag('autoaccidentstate', $e['eocrelautostpr'], true);
		$buffer .= $this->_tag('isrelatedtootheraccident', ($e['eocrelother'] == 'yes'), true);
		$buffer .= $this->_tag('isrelatedtoemployment', ($e['eocrelemp'] == 'yes'), true);
		$buffer .= $this->_date('dateofonset', $e['eocstartdate']);
		$buffer .= $this->_date('dateoffirstoccurence', $e['eocstartdate']);

		$buffer .= "</diagnosis>\n";
		return $buffer;
	} // end method _RenderDiagnosis

	function _RenderFacility ( $facility ) {
		$f = freemed::get_link_rec($facility, 'facility');
		$buffer .= "<facility id=\"".htmlentities($facility)."\">\n";

		$buffer .= $this->_tag('name', $f['psrname'], true);
		$buffer .= $this->_addr('address', $f['psraddr1'],
			$f['psrcity'], $f['psrstate'], $f['psrzip']);
		$buffer .= $this->_phone('phone', $f['psrphone']);
		$buffer .= $this->_tag('description', $f['psrnote'], true);
		$buffer .= $this->_tag('hcfacode', !$f['psrpos'] ? 11 : freemed::get_link_field($f['psrpos'], 'pos', 'posname'), true);
		$buffer .= $this->_tag('x12code', !$f['psrpos'] ? 11 : freemed::get_link_field($f['psrpos'], 'pos', 'posname'), true);
		$buffer .= $this->_tag('ein', $f['psrein'], true);
		$buffer .= $this->_tag('npi', $f['psrnpi'], true);
		$buffer .= $this->_tag('taxonomy', $f['psrtaxonomy'], true);
		
		$buffer .= "</facility>\n";
		return $buffer;
	} // end method _RenderFacility

	function _RenderInsured ( $insured ) {
		$i = freemed::get_link_rec($insured, 'coverage');
		$buffer .= "<insured id=\"".htmlentities($insured)."\">\n";

		$p = freemed::get_link_rec($i['covpatient'], 'patient');

		// Handle not self covered
		$buffer .= $this->_tag('relationship', $i['covrel'], true);
		if ($i['covrel'] != 'S') {
			$buffer .= $this->_name('name', $i['covlname'], $i['covfname'], $i['covmname']);
			$buffer .= $this->_addr('address', $i['covaddr1'], $i['covcity'], $i['covstate'], $i['covzip']);
			$buffer .= $this->_phone('phone', $i['covphone']);
			$buffer .= $this->_date('dateofbirth', $i['covdob']);
			$buffer .= $this->_tag('sex', strtolower($i['covsex']), true);
		} else {
			// Self
			$buffer .= $this->_name('name', $p['ptlname'], $p['ptfname'], $p['ptmname']);
			$buffer .= $this->_addr('address', $p['ptaddr1'], $p['ptcity'], $p['ptstate'], $p['ptzip']);
			$buffer .= $this->_phone('phone', $p['pthphone']);
			$buffer .= $this->_date('dateofbirth', $p['ptdob']);
			$buffer .= $this->_tag('sex', strtolower($p['ptsex']), true);
		}

		// Common stuff
		$buffer .= $this->_tag('id', $i['covpatinsno'], true);
		$buffer .= $this->_tag('planname', $i['covplanname'], true);
		$buffer .= $this->_tag('groupname', $i['covplanname'], true);
		$buffer .= $this->_tag('groupnumber', $i['covpatgrpno'], true);
		$buffer .= $this->_tag('isemployed', (!empty($i['covemployer']))+0, true);
		$buffer .= $this->_tag('employername', $i['covemployer'], true);
		$buffer .= $this->_tag('isstudent', !empty($i['covschool']), true);
		$buffer .= $this->_tag('schoolname', $i['covschool'], true);
		$buffer .= $this->_tag('isassigning', ($i['covisassigning'] > 0), true);

		$buffer .= "</insured>\n";
		return $buffer;
	} // end method _RenderInsured

	function _RenderPatient ( $patient ) {
		$p = freemed::get_link_rec($patient, 'patient');
		$buffer .= "<patient id=\"".htmlentities($patient)."\">\n";

		$buffer .= $this->_name('name', $p['ptlname'], $p['ptfname'], $p['ptmname']);
		$buffer .= $this->_addr('address', $p['ptaddr1'],
			$p['ptcity'], $p['ptstate'], $p['ptzip']);
		$buffer .= $this->_phone('phone', $p['pthphone']);
		$buffer .= $this->_tag('sex', strtolower($p['ptsex']), true);
		$buffer .= $this->_tag('socialsecuritynumber', $p['ptssn'], true);
		$buffer .= $this->_tag('isdead', ($p['ptdead'] == 1)+0, true);
		$buffer .= $this->_date('dateofbirth', $p['ptdob']);
		$buffer .= $this->_date('dateofdeath', $p['ptdeaddt']);
		$buffer .= $this->_tag('ispregnant', ($p['ptpreg'] == 'pregnant')+0, true);
		$buffer .= $this->_tag('issingle', ($p['ptmarital'] == 'single')+0, true);
		$buffer .= $this->_tag('ismarried', ($p['ptmarital'] == 'married')+0, true);
		$buffer .= $this->_tag('ismaritalotherhcfa', ( ($p['ptmarital'] != 'married') and ($p['ptmarital'] != 'single') )+0, true);
		$buffer .= $this->_tag('isemployed', (
				( $p['ptempl'] != 'y' ) and
				( $p['ptempl'] != 'p' ) and
				( $p['ptempl'] != 'm' ) and
				( $p['ptempl'] != 's' ) )+0, true);
		$buffer .= $this->_tag('isfulltimestudent', 0, true); // fixme
		$buffer .= $this->_tag('isparttimestudent', 0, true); // fixme

		// fixme: coveragecount needs to be in procedure

		$buffer .= $this->_tag('referringprovider', $p['ptrefdoc'], true);
		$this->_AddDependency('physician', $p['ptrefdoc']);

		$buffer .= $this->_tag('account', $p['ptid'], true);

		$buffer .= "</patient>\n";
		return $buffer;
	} // end method _RenderPatient

	function _RenderPayer ( $payer ) {
		$p = freemed::get_link_rec($payer, 'insco');
		$buffer .= "<payer id=\"".htmlentities($payer)."\">\n";

		$buffer .= $this->_tag('name', $p['inscoalias'], true);
		$buffer .= $this->_addr('address', $p['inscoaddr1'], $p['inscocity'], $p['inscostate'], $p['inscozip']);
		$buffer .= $this->_phone('phone', $p['inscophone']);
		$buffer .= $this->_tag('x12claimtype', 'HM', true); // fix
		$buffer .= $this->_tag('x12id', $p['inscox12id'], true);

		// IsX functions for payer types
		$x = false;
		$buffer .= $this->_tag('ismedicare', ($this->_isPayerX($payer, 'MA') or $this->_isPayerX($payer, 'MB')) + 0, true);
		$x |= ($this->_isPayerX($payer, 'MA') or $this->_isPayerX($payer, 'MB'));
		$buffer .= $this->_tag('ischampus', ($this->_isPayerX($payer, 'CH') + 0), true);
		$x |= ($this->_isPayerX($payer, 'CH'));
		$buffer .= $this->_tag('ischampusva', ($this->_isPayerX($payer, 'CH') + 0), true);
		$x += ($this->_isPayerX($payer, 'CH'));
		$buffer .= $this->_tag('ismedicaid', ($this->_isPayerX($payer, 'MC') + 0), true);
		$x |= ($this->_isPayerX($payer, 'MC'));
		$buffer .= $this->_tag('isbcbs', ($this->_isPayerX($payer, 'BL') + 0), true);
		$x |= ($this->_isPayerX($payer, 'BL'));
		$buffer .= $this->_tag('isfeca', ($this->_isPayerX($payer, 'FI') + 0), true);
		$x |= ($this->_isPayerX($payer, 'FI'));
		$buffer .= $this->_tag('isotherhcfa', ((!$x) + 0), true);
	
		$buffer .= "</payer>\n";
		return $buffer;		
	} // end method _RenderPayer

	function _RenderPractice ( $facility ) {
		$f = freemed::get_link_rec($facility, 'physician');
		$buffer .= "<practice id=\"".htmlentities($facility)."\">\n";

		// loop through payers that are in the system
		foreach ($this->ref['insco'] as $i) {
			// loop through providers
			$_i = freemed::get_link_rec($i, 'insco');
			$map = unserialize($_i['inscoidmap']);
			foreach ($this->ref['physician'] as $p) {
				if ($p and $i) {
				$buffer .= "<id payer=\"".htmlentities($i).
					"\" ".
					"physician=\"".htmlentities($p)."\">".
					htmlentities($map[$p]['id']).
					"</id>\n";
				$buffer .= "<groupid ".
					"payer=\"".htmlentities($i)."\" ".
					"physician=\"".htmlentities($p)."\">".
					htmlentities($map[$p]['group']).
					"</groupid>\n";
				}
			}
		}

		$buffer .= $this->_tag('name', $f['phypracname'], true);
		$buffer .= $this->_addr('address', $f['phyaddr1a'],
			$f['phycitya'], $f['phystatea'], $f['phyzipa']);
		$buffer .= $this->_phone('phone', $f['phyphonea']);
			// FIXME: THESE ARE NOT RIGHT ANYMORE
		$buffer .= $this->_tag('x12id', $f['psrx12id'], true);
		$buffer .= $this->_tag('x12idtype', $f['psrx12idtype'], true);
		$buffer .= $this->_tag('ein', ( $f['phypracein'] ? $f['phypracein'] : $f['physsn'] ), true);

		$buffer .= "</practice>\n";
		return $buffer;
	} // end method _RenderPractice

	function _RenderProvider ( $provider ) {
		$p = freemed::get_link_rec($provider, 'physician');
		$buffer .= "<provider id=\"".htmlentities($provider)."\">\n";

		$buffer .= $this->_name('name', $p['phylname'], $p['phyfname'], $p['phymname']);
		$buffer .= $this->_addr('address', $p['phyaddr1a'], $p['phycitya'], $p['phystatea'], $p['phyzipa']);
		$buffer .= $this->_phone('phone', $p['phyphonea']);
		$buffer .= $this->_tag('socialsecuritynumber', $p['physsn'], true);
		$buffer .= $this->_tag('tin', $p['physsn'], true);
		$buffer .= $this->_tag('ipn', $p['phyupin'], true);
		$buffer .= $this->_tag('clia', $p['phyclia'], true);
		$buffer .= $this->_tag('npi', $p['phynpi'], true);
		$buffer .= $this->_tag('dea', $p['phydea'], true);
		$buffer .= $this->_tag('taxonomy', $p['phytaxonomy'], true);
	
		$buffer .= "</provider>\n";
		return $buffer;		
	} // end method _RenderProvider

	function _RenderProcedure ( $procedure ) {
		$p = freemed::get_link_rec($procedure, 'procrec');

		$buffer .= "<procedure id=\"".htmlentities($procedure)."\">\n".
			$this->_tag('cpt4code', freemed::get_link_field($p['proccpt'], 'cpt', 'cptcode'), true).
			$this->_tag('cpt5code', freemed::get_link_field($p['proccpt'], 'cpt', 'cptcode'), true).
			$this->_tag('cptdescription', freemed::get_link_field($p['proccpt'], 'cpt', 'cptnameint'), true).
			$this->_tag('cptcob', '0', true).
			$this->_tag('cptcharges', $p['proccharges'], true).
			$this->_tag('cptcount', 1, true).
			$this->_tag('cptemergency', '0', true).
			$this->_tag('cptepsdt', '0', true).
			$this->_tag('cptmodifier', freemed::get_link_field($p['proccptmod'], 'cptmod', 'cptmod'), true).
			// Optional extra cpt modifiers
			$this->_tag('cptmodifier2', freemed::get_link_field($p['proccptmod2'], 'cptmod', 'cptmod'), true).
			$this->_tag('cptmodifier3', freemed::get_link_field($p['proccptmod3'], 'cptmod', 'cptmod'), true).
			$this->_tag('cptunits', $p['procunits'], true).
			$this->_tag('weightgrams', '0', true);
		$this->_AddDependency('cpt', $p['proccpt']);

		// Handle "array" of diagnoses/eoc
		$e = explode (':', $p['proceoc']);
		$eoc = $e[0];	
		for ($i=1; $i<=4; $i++) {
			if ($p['procdiag'.$i] > 0) {
				$buffer .= $this->_tag('diagnosiskey', $eoc.','.$p['procdiag'.$i], true); 
				$this->_AddDependency('diagnosis', $eoc.','.$p['procdiag'.$i]);
			}
		}
		$buffer .= $this->_tag('patientkey', $p['procpatient'], true);
		$this->_AddDependency('patient', $p['procpatient']);
	
		// Handle payer key
		switch ($p['proccurcovtp']) {
			case '1': $covnum = 1; break;
			case '2': $covnum = 2; break;
			case '3': $covnum = 3; break;
			case '4': $covnum = 4; break;
			default:  $covnum = 0; break;
		}
		$coverage = freemed::get_link_rec($p['proccov'.$covnum], 'coverage');
		$buffer .= $this->_tag('insuredkey', $p['proccov'.$covnum], true);
		//print "Should have added $coverage as coverage<br/>\n";
		$this->_AddDependency('coverage', $p['proccov'.$covnum]);
		$buffer .= $this->_tag('payerkey', $coverage['covinsco'], true);
		$this->_AddDependency('insco', $coverage['covinsco']);

		// Get id map (while we still have the primary coverage)
		$map = unserialize(freemed::get_link_field($coverage['covinsco'], 'insco', 'inscoidmap'));

		// Handle second key
		if ($covnum != 0) {
			$covnum++; 
			if ($covnum < 1 or $covnum > 4) { $covnum = 0; }
		}
		$buffer .= $this->_tag('secondinsuredkey', $p['proccov'.$covnum], true);
		$this->_AddDependency('coverage', $p['proccov'.$covnum]);
		$coverage = freemed::get_link_rec($p['proccov'.$covnum], 'coverage');
		$buffer .= $this->_tag('secondpayerkey', $coverage['covinsco'], true);
		$this->_AddDependency('insco', $coverage['covinsco']);

		// Get other insured key
		switch ($p['proccurcovtp']) {
			case '2': $covnum = 3; break;
			case '3': $covnum = 4; break;
			case '4': $covnum = 0; break;
			case '1': default: $covnum = 2; break;
		}
		$buffer .= $this->_tag('otherinsuredkey', $coverage['covinsco'], 'coverage');
		$this->_AddDependency('insco', $coverage['covinsco']);

		// Figure out type of service
		$cptobj = freemed::get_link_rec($p['proccpt'], 'cpt');
		$hash = unserialize($cptobj['cpttos']);
		if ($hash[$coverage['covinsco']] > 0) {
			$tos = freemed::get_link_field($hash[$coverage['covinsco']], 'tos', 'tosname');
		} else {
			$tos = freemed::get_link_field($cptobj['cptdeftos'], 'tos', 'tosname');
		}

		// Check for TOS override from procedure record
		if ($p['proctosoverride'] > 0) { $tos = $p['proctosoverride']; }

		// Various resubmission codes, etc
		$buffer .=
			$this->_tag('medicaidresubmissioncode', $p['procmedicaidresub'], true).
			$this->_tag('medicaidoriginalreference', $p['procmedicaidresub'], true).
			$this->_tag('hcfalocaluse19', $map[$p['procphysician']]['local19'], true).
			$this->_tag('hcfalocaluse10d', $map[$p['procphysician']]['local10d'], true).
			$this->_tag('hcfalocaluse24k', $map[$p['procphysician']]['local24k'], true).
			$this->_tag('amountpaid', $p['procamtpaid'], true).
			$this->_tag('providerkey', $p['procphysician'], true).
			$this->_tag('referringproviderkey', $p['procrefdoc'], true).
			$this->_tag('facilitykey', $p['procpos'], true).
			$this->_tag('practicekey', $p['procphysician'], true).
			$this->_tag('typeofservice', $tos, true).
			'';
		$this->_AddDependency('physician', $p['procphysician']);
		$this->_AddDependency('physician', $p['procrefdoc']);
		$this->_AddDependency('practice', $p['procphysician']);
		$this->_AddDependency('facility', $p['procpos']);

		// Authorizations
		$buffer .= $this->_tag('priorauth', freemed::get_link_field($p['procauth'], 'authorizations', 'authnum'), true);
		$this->_AddDependency('authorizations', $p['procauth']);

		// isOutsideLab
		$buffer .= $this->_tag('isoutsidelab', ( $p['proclabcharges'] > 0 ? '1' : '0' ), true);
		$buffer .= $this->_tag('outsidelabcharges', $p['proclabcharges'] + 0, true);

		$buffer .= $this->_date('dateofservicestart', $p['procdt']);
		$buffer .= $this->_date('dateofserviceend', $p['procdt']);
		$buffer .= $this->_tag('aging', (strtotime(date("Y-m-d")) - strtotime($p['procdt'])) / (60 * 60 * 24), true);

		$e = freemed::get_link_rec($eoc, 'eoc');
		$buffer .= $this->_tag('ishospitalized', $e['eochospital'] == 1 ? '1' : '0', true);
		$buffer .= $this->_date('dateofhospitalstart', $e['eochosadmdt']);
		$buffer .= $this->_date('dateofhospitalend', $e['eochosdischrgdt']);

		$buffer .= "</procedure>\n";
		return $buffer;
	} // end method RenderProcedure

	function _isPayerX ( $payer, $mod ) {
		$i = freemed::get_link_rec($payer, 'insco');
		$mods = explode (':', $i['inscomod']);
		if (!is_array($mods)) { $mods = array ( $mods ); }
		$q = $GLOBALS['sql']->query('SELECT * FROM insmod '.
			'WHERE insmod = \''.addslashes($mod).'\'');
		$r = $GLOBALS['sql']->fetch_array($q);
		foreach ($mods AS $k => $v) {
			if ($v == $r['id']) {
				return true;
			}
		} 
		return false;
	} // end method _isPayerX

	function _AddDependency($table, $id) {
		// Make sure no duplicates
		$this->ref[$table][$id] = $id;
	}

	function _addr ( $tag, $a, $c, $s, $z) {
		return $this->_tag($tag,
			"\t".$this->_tag('streetaddress', $a, true).
			"\t".$this->_tag('city', $c, true).
			"\t".$this->_tag('state', $s, true).
			"\t".$this->_tag('zipcode', $z, true),
			false);
	} // end method _addr

	function _date ( $name, $sqlvalue ) {
		list ($y, $m, $d) = explode ('-', $sqlvalue);
		if (strlen($y) != 4) { $y = '0000'; $m = '00'; $d = '00'; }
		return $this->_tag($name,
			$this->_tag('year', $y, true).
			$this->_tag('month', $m, true).
			$this->_tag('day', $d, true),
			false);
	} // end method _date

	function _name ( $tag, $l, $f, $m = '' ) {
		return $this->_tag($tag,
			"\t".$this->_tag('last', $l, true).
			"\t".$this->_tag('first', $f, true).
			"\t".$this->_tag('middle', $m, true),
			false);
	} // end method _name

	function _phone ( $tag, $phone ) {
		$a = substr($phone, 0, 3);
		$n = substr($phone, 3, 7);
		$e = substr($phone, 10, 4);
		return $this->_tag($tag,
			"\t".$this->_tag('country', '1', true).
			"\t".$this->_tag('area', $a, true).
			"\t".$this->_tag('number', $n, true).
			"\t".$this->_tag('extension', $e, true),
			false);
	} // end method _phone

	function _tag ( $tag, $value, $inner = false ) {
		return "<".htmlentities($tag).">". ( !$inner ? "\n" : "" ) .
			( $inner ?  trim(htmlentities(stripslashes($value))) : stripslashes($value) ).
			"</".htmlentities($tag).">\n";
	} // end method _tag

	// Method: _autoserialize
	//
	//	Automagically determines what kind of resource this is
	//	supposed to be and creates a PHP.xmlrpcval object to
	//	wrap it in.
	//
	// Parameters:
	//
	//	$mixed - Original object, any type
	//
	// Returns:
	//
	//	PHP.xmlrpcval object
	//
	function _autoserialize ( $mixed ) {
		// Handle already serialized
		if (is_object($mixed) and method_exists($mixed, 'serialize')) {
			return $mixed;
		}

		if (is_array($mixed)) {
			// If dealing with an array, recursively figure out
			@reset($mixed);
			while(list($k, $v) = @each($mixed)) {
				$ele[$k] = $this->_autoserialize($v);
			}
			// Determine if struct or array as we return it
			return CreateObject (
				'PHP.xmlrpcval',
				$ele,
				$this->_is_struct($ele) ? 'struct' : 'array'
			);
		} elseif (strpos($mixed, '<') !== false) {
			// This is an *awful* way to check for binary data,
			// and is probably broken in a thousand ways.
			return CreateObject (
				'PHP.xmlrpcval',
				$mixed,
				'base64'
			);
		} else {
			// Otherwise, use PHP auto-typing
			$type = (is_integer($mixed) ? 'int' : gettype($mixed));
			return CreateObject (
				'PHP.xmlrpcval',
				$mixed,
				$type
			);
		}
	} // end method _autoserialize

	// Method: _call
	//
	//	Call Remitt server with the specified parameters. This
	//	should only be used by internal Remitt methods to
	//	complete abstraction.
	//
	// Parameters:
	//
	//	$method - Method on the Remitt server to call
	//
	//	$parameters - (optional) Array of parameters to call
	//	$method with. Defaults to NULL.
	//
	//	$debug - (optional) Whether debug code should be shown.
	//	Defaults to false.
	//
	// Returns:
	//
	//	Reply to call as PHP variable.
	//
	function _call ( $method, $parameters = NULL, $debug = false ) {
		// Form proper message object
		if ($parameters != NULL) {
			$message = CreateObject(
				'PHP.xmlrpcmsg',
				$method,
				( is_array($parameters) ? $parameters : array($parameters) )
			);
		} else {
			$message = CreateObject(
				'PHP.xmlrpcmsg',
				$method
			);
		}
		if ($debug) { print_r($message); }

		// If we're debugging, we set the debug flag
		$this->_connection->setDebug ( $debug );

		// Dispatch message to server
		$response = $this->_connection->send (
			$message,
			0,
			$this->protocol
		);
		if ($debug) { print_r($response); }

		// Deserialize response
		$d = $response->deserialize();

		// Handle faults
		if ($response->fn) {
			trigger_error(__("XML-RPC Fault:")." ".$d['faultCode']." (".$d['faultString'].")", E_USER_ERROR);
		} else {
			// If there is no fault, return as usual
			return $d;
		}
	} // end method _call

	// Method: _is_struct
	//
	//	Determines if in an array is a structure (associative array)
	//	or a regular array.
	//
	// Parameters:
	//
	//	$var - Variable to be typed
	//
	// Returns:
	//
	//	Boolean, true if $var is an associative array, false if it
	//	is not.
	//
	function _is_struct ( $var ) {
		// Catch non-array instance
		if (!is_array($var)) return false;

		// If there are non-numeric keys, it is a structure, otherwise
		// default to false.
		foreach ($var AS $k => $v) {
			if (!is_integer($k)) return true;
		}
		return false;
	} // end method _is_struct

} // end class Remitt

?>