luos/workflow/engine/methods/services/xpdl.php

<?php
function addNodox($obj, $padre, $indice, $contenido='', $atributos)
{ 
  if(is_object($padre))
   { 
   	 if($contenido=='')
  	 		$nodo = $obj->createElement($indice);
  	 else		
  	 		$nodo = $obj->createElement($indice, $contenido);  	 
  	 		
  	 $padre->appendChild($nodo);  	
   }
  else
   { if($contenido=='')
  	 		$nodo = $obj->createElement($indice);
  	 else		
  	 		$nodo = $obj->createElement($indice, $contenido);		
     
     $obj->appendChild($nodo); 
   }	
  if(is_array($atributos)) 
   {
  		foreach($atributos as $key => $value)
  			{  
  					$atributo = $obj->createAttribute($key);
						$nodo->appendChild($atributo);
						
						$texto = $obj->createTextNode($value);
						$atributo->appendChild($texto);   
  			}
   }			 
  return $nodo;
}

function derivationRules($aRoute, $doc, $nodo_derivationrule)
{   $tam = count($aRoute);
	  $c=0; 	  
		switch($aRoute[$c]['ROU_TYPE'])
		{
		 	case 'SEQUENTIAL':
		 		$nodo_routeType = addNodox($doc, $nodo_derivationrule, 'Sequential', '', '');
  			$nodo_nexttask  = addNodox($doc, $nodo_routeType, 'NextTask', '', '');  			
  			if($aRoute[$c]['ROU_NEXT_TASK'] != -1)
  					$nodo_taskref = addNodox($doc, $nodo_nexttask, 'TaskRef', '', array('TaskId'=> 'ID'.$aRoute[$c]['ROU_NEXT_TASK']));
  			else
  					$nodo_taskref = addNodox($doc, $nodo_nexttask, 'End', '', ''); 
  		  break;
		  case 'EVALUATE':		    
		    $nodo_routeType = addNodox($doc, $nodo_derivationrule, 'Evaluations', '', '');
		    while($c < $tam)
		    {
			    $nodo_evaluation= addNodox($doc, $nodo_routeType, 'Evaluation', '', array('Condition'=> $aRoute[$c]['ROU_CONDITION']));  			
	  			$nodo_nexttask  = addNodox($doc, $nodo_evaluation, 'NextTask', '', '');  			
	  			if($aRoute[$c]['ROU_NEXT_TASK'] != -1)
  					$nodo_taskref = addNodox($doc, $nodo_nexttask, 'TaskRef', '', array('TaskId'=> 'ID'.$aRoute[$c]['ROU_NEXT_TASK']));
  			  else
  					$nodo_taskref = addNodox($doc, $nodo_nexttask, 'End', '', ''); 
	  			$c++;
  		  }  		  
  			break;
		 	case 'SELECT':
		 		$nodo_routeType = addNodox($doc, $nodo_derivationrule, 'Selections', '', '');
		    while($c < $tam)
		    {
		    	$nodo_selection= addNodox($doc, $nodo_routeType, 'Selection', '', array('Description'=> $aRoute[$c]['ROU_CONDITION']));  			
  				$nodo_nexttask  = addNodox($doc, $nodo_selection, 'NextTask', '', '');  			
  				if($aRoute[$c]['ROU_NEXT_TASK'] != -1)
  					$nodo_taskref = addNodox($doc, $nodo_nexttask, 'TaskRef', '', array('TaskId'=> 'ID'.$aRoute[$c]['ROU_NEXT_TASK']));
  			  else
  					$nodo_taskref = addNodox($doc, $nodo_nexttask, 'End', '', ''); 
  				$c++;
  			}	  			
  			break;
		 	case 'PARALLEL':
		 		$nodo_routeType = addNodox($doc, $nodo_derivationrule, 'ParallelForks', '', '');
		    while($c < $tam)
		    {       
		    	$nodo_parallelfork= addNodox($doc, $nodo_routeType, 'ParallelFork', '', '');  			
  				$nodo_nexttask  = addNodox($doc, $nodo_parallelfork, 'NextTask', '', '');  			
  				if($aRoute[$c]['ROU_NEXT_TASK'] != -1)
  					$nodo_taskref = addNodox($doc, $nodo_nexttask, 'TaskRef', '', array('TaskId'=> 'ID'.$aRoute[$c]['ROU_NEXT_TASK']));
  			  else
  					$nodo_taskref = addNodox($doc, $nodo_nexttask, 'End', '', ''); 
  				$c++;
  			}	  			
  			break;
		 	case 'PARALLEL-BY-EVALUATION':
		 		$nodo_routeType = addNodox($doc, $nodo_derivationrule, 'ParallelForksByEvaluation', '', '');
		 		while($c < $tam)
		    {  
		    	$nodo_evaluation= addNodox($doc, $nodo_routeType, 'Evaluation', '', array('Condition'=> $aRoute[$c]['ROU_CONDITION']));  			
  			  $nodo_nexttask  = addNodox($doc, $nodo_evaluation, 'NextTask', '', '');  			  			
  			  if($aRoute[$c]['ROU_NEXT_TASK'] != -1)
  					$nodo_taskref = addNodox($doc, $nodo_nexttask, 'TaskRef', '', array('TaskId'=> 'ID'.$aRoute[$c]['ROU_NEXT_TASK']));
  			  else
  					$nodo_taskref = addNodox($doc, $nodo_nexttask, 'End', '', ''); 
  			  $c++;
  			}    			
		 	  break;		 	
		 	case 'SEC-JOIN':
		 		$nodo_routeType = addNodox($doc, $nodo_derivationrule, 'ParallelJoin', '', '');
  			$nodo_nexttask  = addNodox($doc, $nodo_routeType, 'NextTask', '', '');  			  			
  			if($aRoute[$c]['ROU_NEXT_TASK'] != -1)
  					$nodo_taskref = addNodox($doc, $nodo_nexttask, 'TaskRef', '', array('TaskId'=> 'ID'.$aRoute[$c]['ROU_NEXT_TASK']));
  			else
  					$nodo_taskref = addNodox($doc, $nodo_nexttask, 'End', '', ''); 
		 	  break;
		}							 		
}

/****-_--__---___----___---__--_-****/

G::LoadClass('tasks');
require_once 'classes/model/Process.php';		  	

$doc = new DOMDocument('1.0', 'UTF-8');
$nodo_padre = addNodox($doc, '', 'Processes', '', array('xmlns:xsi'=>'http://www.w3.org/2001/XMLSchema-instance','xsi:noNamespaceSchemaLocation'=>'ColosaSchema.xsd'));

$aProcesses   = array();
$oCriteria = new Criteria('workflow');
$oCriteria->addSelectColumn(ProcessPeer::PRO_UID);
//$oCriteria->add(ProcessPeer::PRO_STATUS, 'DISABLED', Criteria::NOT_EQUAL);
//$oCriteria->add(ProcessPeer::PRO_UID, '946679494980c3d0ba0814088444708');
$oDataset = ProcessPeer::doSelectRS($oCriteria);
$oDataset->setFetchmode(ResultSet::FETCHMODE_ASSOC);
$oDataset->next();
$oProcess = new Process();    

while ($aRow = $oDataset->getRow()) {
  $aProcess     = $oProcess->load($aRow['PRO_UID']);    
  $nodo_process = addNodox($doc, $nodo_padre, 'Process', '', array('Title'=> $aProcess['PRO_TITLE'],'Description'=> $aProcess['PRO_DESCRIPTION']));  
  $nodo_tasks = addNodox($doc, $nodo_process, 'Tasks', '', '');
  
  $oTask = new Tasks();  
  $aTasks= $oTask->getAllTasks($aProcess['PRO_UID']);
  foreach($aTasks as $key => $value)
  { //print_r($value); echo "<br>";  	
  	$aRoute = $oTask->getRoute($aProcess['PRO_UID'], $value['TAS_UID']);  	  	
  	//print_r($aRoute[0]['ROU_UID']); echo "<hr>";  	
  	/*foreach($aRoute as $k => $v)
  			echo $k."-->".$v."<br>";
  	*/
  	if($value['TAS_TYPE']=='NORMAL')
  	 { 
  			$ini = ($value['TAS_START']=='TRUE') ? 'true' : 'false';
  					
  			$nodo_task = addNodox($doc, $nodo_tasks, 'Task', '', array('Title'=> $value['TAS_TITLE'],'Description'=> $value['TAS_DESCRIPTION'],'Id'=> 'ID'.$value['TAS_UID'],'StartingTask'=> $ini));    	
  			$nodo_coordinates = addNodox($doc, $nodo_task, 'Coordinates', '', array('XCoordinate'=> $value['TAS_POSX'],'YCoordinate'=> $value['TAS_POSY']));
  			$nodo_derivationrule = addNodox($doc, $nodo_task, 'DerivationRule', '', '');  			
  			  			  			
  			derivationRules($aRoute, $doc, $nodo_derivationrule);
  			
  			$nodo_assignmentrules = addNodox($doc, $nodo_task, 'AssignmentRules', '', '');
  			$nodo_cyclicalassignment = addNodox($doc, $nodo_assignmentrules, 'CyclicalAssignment', '', '');
  			$nodo_timingcontrol = addNodox($doc, $nodo_task, 'TimingControl', '', array('TaskDuration'=> $value['TAS_DURATION']));
  			$nodo_permissions = addNodox($doc, $nodo_task, 'Permissions', '', '');
  			$nodo_caselabels = addNodox($doc, $nodo_task, 'CaseLabels', '', '');
  			$nodo_notifications = addNodox($doc, $nodo_task, 'Notifications', '', '');  		
  	 } 
  	 else
  	 {	require_once ( "classes/model/SubProcess.php" );  	 	
				$oCriteria = new Criteria('workflow');			
				$oCriteria->add(SubProcessPeer::PRO_PARENT, $value['PRO_UID']);
				$oCriteria->add(SubProcessPeer::TAS_PARENT, $value['TAS_UID']);
				$oDataset = SubProcessPeer::doSelectRS($oCriteria);
				$oDataset->setFetchmode(ResultSet::FETCHMODE_ASSOC);
				$oDataset->next();
			  $aRow = $oDataset->getRow();  	 	  
  	 	  $nodo_task = addNodox($doc, $nodo_tasks, 'SubProcess', '', array('Title'=> $value['TAS_TITLE'],'Description'=> $value['TAS_DESCRIPTION'],'Id'=> 'ID'.$value['TAS_UID'], 'ProcessRef'=>$aRow['PRO_UID']));    		 	  	 	  
  	 	  $nodo_coordinates = addNodox($doc, $nodo_task, 'Coordinates', '', array('XCoordinate'=> $value['TAS_POSX'],'YCoordinate'=> $value['TAS_POSY']));
  			$nodo_derivationrule = addNodox($doc, $nodo_task, 'DerivationRule', '', '');
  			
  			derivationRules($aRoute, $doc, $nodo_derivationrule);
  	 }
  }  
	$oDataset->next();
}
//die;
$doc->preserveWhiteSpace = false;
$doc->formatOutput   = true;
$doc->save(PATH_METHODS.'services/test_xpdl.xml');
echo "xml for xpdl creado!!!<br>";
		
?>