Context Navigation

source: trunk/prototype/api/controller.php @ 6023

Revision 6023, 21.0 KB checked in by marcieli, 12 years ago (diff)
Ticket #2633 - Ao criar novo marcador, duplica na lista da tela de configuração

Rev	Line
[5136]	1	<?php
	2
[5514]	3
[5341]	4	if( !defined( 'ROOTPATH' ) )
	5	define( 'ROOTPATH', dirname(__FILE__).'/..' );
[5136]	6
[5399]	7	require_once(ROOTPATH.'/api/config.php');
[5341]	8
	9	/**
	10	TODO list:
	11
	12	* definir de forma centralizada os caminhos e as constantes necessÃ¡rias;
	13	* criar um User Agent detect e um OS server detect para customizaÃ§Ãµes espeÃ§Ãficas de cada browser / servidor;
	14	* criar um registrador para fallback handlers;
	15	* criar um dependency manager na configuraÃ§Ã£o dos serviÃ§os, para poder gerenciar os imports corretamente
	16	* criar um login e a recuperaÃ§Ã£o da sessÃ£o;
	17
	18	*/
	19
[5136]	20	class Controller {
	21
[5341]	22	static $cache;
	23	static $services = array();
	24	static $interceptors = array();
	25	static $config = array();
	26	static $includes = array();
	27	static $tx = array();
[5514]	28	static $isConcept = array();
[5715]	29	static $hasOne = array();
[5905]	30	static $fallbackHandlers = array();
[5341]	31	static $txID = 0;
	32	static $wallet;
[5136]	33
[5341]	34	public function __destruct()
[5136]	35	{
[5341]	36	// if( $this->service )
	37	// $this->service->close();
	38	// else
	39	self::closeAll();
[5136]	40	}
	41
[5341]	42	public static function closeAll()
[5136]	43	{
[5341]	44	if( self::$services )
	45	foreach( self::$services as $serviceName => $service )
	46	if( self::$config[ $serviceName ]['type'] === 'service' )
	47	$service->close();
	48	}
[5136]	49
[5341]	50	public static function clearAll()
[5136]	51	{
[5341]	52	return self::$cache->clearAll();
[5136]	53	}
	54
[5341]	55	public static function clear( $id )
	56	{
	57	return self::$cache->clear( $id );
	58	}
[5136]	59
[5341]	60	public static function check( $id )
	61	{
	62	return self::$cache->get( $id );
	63	}
[5136]	64
[5341]	65	public static function store( $id, $data, $expires, $compressed )
	66	{
	67	return self::$cache->put( $id, $data, $expires, $compressed );
	68	}
[5136]	69
[5341]	70	public static function find( $URI, $params = false, $criteria = false )
	71	{
	72	if( isset($URI['id']) && $URI['id'] )
	73	return self::read( $URI, $params, $criteria );
[5136]	74
[5341]	75	return self::call( 'find', $URI, $params, $criteria );
	76	}
[5136]	77
[5341]	78	public static function read( $URI, $params = false, $criteria = false )
	79	{
	80	if( !isset($URI['id']) \|\| !$URI['id'] )
	81	return self::find( $URI, $params, $criteria );
[5136]	82
[5341]	83	return self::call( 'read', $URI, $params, $criteria );
[5136]	84	}
	85
[5341]	86	public static function deleteAll( $URI, $params = false, $criteria = false )
[5136]	87	{
[5341]	88	if( isset($URI['id']) && $URI['id'] )
	89	return self::delete( $URI, $params, $criteria );
	90
	91	return self::call( 'deleteAll', $URI, $params, $criteria );
[5136]	92	}
	93
[5341]	94	public static function delete( $URI, $params = false, $criteria = false )
[5136]	95	{
[5341]	96	if( !isset($URI['id']) \|\| !$URI['id'] )
	97	return self::deleteAll( $URI, $params, $criteria );
	98
	99	return self::call( 'delete', $URI, $params, $criteria );
[5136]	100	}
	101
[5341]	102	public static function replace( $URI, $params, $criteria = false )
[5136]	103	{
[5341]	104	if( isset($URI['id']) && $URI['id'] )
	105	return self::update( $URI, $params, $criteria );
	106
	107	return self::call( 'replace', $URI, $params, $criteria );
[5136]	108	}
	109
[5341]	110	public static function update( $URI, $params, $criteria = false )
[5136]	111	{
[5341]	112	if( !isset($URI['id']) \|\| !$URI['id'] )
	113	return self::replace( $URI, $params, $criteria );
	114
	115	return self::call( 'update', $URI, $params, $criteria );
[5136]	116	}
	117
[5341]	118	public static function create( $URI, $params, $criteria = false )
[5136]	119	{
[5341]	120	return self::call( 'create', $URI, $params, $criteria );
	121	}
[5136]	122
[5341]	123	public static function begin( $URI, $params = false, $criteria = false )
	124	{
	125	return self::call( 'begin', $URI, $params, $criteria );
	126	}
[5136]	127
[5341]	128	public static function commit( $URI, $criteria = false )
[5136]	129	{
[5341]	130	return self::call( 'commit', $URI, false, $criteria );
	131	}
[5136]	132
[5341]	133	public static function rollback( $URI, $criteria = false )
	134	{
	135	return self::call( 'rollback', $URI, false, $criteria );
	136	}
[5136]	137
[5341]	138	public static function format( $URI, $params, $criteria = false )
	139	{
	140	return self::call( 'format', $URI, $params, $criteria );
	141	}
[5136]	142
[5341]	143	public static function parse( $URI, $data, $criteria = false )
	144	{
	145	return self::call( 'parse', $URI, $data, $criteria );
[5136]	146	}
	147
[5341]	148	public static function URI( $className, $id = false, $service = false )
	149	{
	150	return array( 'concept' => $className,
	151	'service' => $service ? $service : false,
	152	'id' => $id ? $id : '' );
[5136]	153	}
	154
[5399]	155	//TODO: Compatibilizar as configs relativas aos modulos, adicionando os mesmo nos parametros passados
[5514]	156	public static function links( $concept = false, $linkage = false )
[5136]	157	{
[5514]	158
	159
[5341]	160	if( !isset(self::$config[ $concept ]) )
	161	self::$config[ $concept ] = self::loadConfig( $concept );
[5136]	162
[5514]	163	$links = array();
	164	self::$isConcept[ $concept ] = array();
[5715]	165	self::$hasOne[ $concept ] = array();
[5514]	166
	167	if( isset(self::$config[ $concept ][ 'model.hasOne' ]) )
	168	foreach( self::$config[ $concept ][ 'model.hasOne' ] as $linkName => $linkTarget )
	169	{
	170	list( $target, $link ) = explode( '.', $linkTarget );
	171
	172	if( $linkage === $linkName )
	173	$return = $link;
	174
	175	$links[$linkName] = $target;
[5715]	176	self::$hasOne[ $concept ][ $linkName ] = true;
[5514]	177	}
	178	if( isset(self::$config[ $concept ][ 'model.depends' ]) )
	179	foreach( self::$config[ $concept ][ 'model.depends' ] as $linkName => $linkTarget )
	180	{
	181	list( $target, $link ) = explode( '.', $linkTarget );
	182
	183	if( $linkage === $linkName )
	184	$return = $link;
	185
	186	$links[$linkName] = $target;
[5715]	187	self::$hasOne[ $concept ][ $linkName ] = true;
[5514]	188	self::$isConcept[ $concept ][ $linkName ] = true;
	189	}
	190	if( isset(self::$config[ $concept ][ 'model.hasMany' ]) )
	191	foreach( self::$config[ $concept ][ 'model.hasMany' ] as $linkName => $linkTarget )
	192	{
	193	list( $target, $link ) = explode( '.', $linkTarget );
	194
	195	if( $linkage === $linkName )
	196	$return = $link;
	197
	198	$links[$linkName] = $target;
	199	}
	200
	201	return( isset($return) ? $return : $links );
[5341]	202	}
[5136]	203
[5514]	204	public static function isConcept( $concept, $linkName )
[5399]	205	{
[5514]	206	if( !isset( self::$isConcept[ $concept ] ) )
	207	self::links( $concept );
	208
	209	return( isset(self::$isConcept[ $concept ][ $linkName ]) );
[5341]	210	}
[5136]	211
[5715]	212	public static function hasOne( $concept, $linkName )
	213	{
	214	if( !isset( self::$hasOne[ $concept ] ) )
	215	self::links( $concept );
	216
	217	return( isset(self::$hasOne[ $concept ][ $linkName ]) );
	218	}
	219
[5399]	220	public static function getConcept( $concept, $moduleName = false )
[5341]	221	{
	222	if( isset( self::$config[ $concept ] ) )
	223	return( self::$config[ $concept ] );
	224
[5399]	225	return( self::$config[ $concept ] = self::loadConfig( $concept, $moduleName ) );
	226	}
[5136]	227
[5341]	228	public static function loadCache( $cacheType = 'Memory' )
	229	{
	230	include_once( "cache/MemoryCache.php" );
	231	return new MemoryCache();
	232	}
[5136]	233
[5399]	234	//TODO: Compatibilizar as configs relativas aos modulos, adicionando os mesmo nos parametros passados
	235	public static function loadConfig( $className, $isService = false)
[5341]	236	{
	237	$fileName = $className.'.'.($isService ? 'srv' : 'ini');
[5136]	238
[5341]	239	$config = self::$cache->get( $fileName );
[5399]	240
[5341]	241	if( !$config )
	242	{
[5399]	243	$config = parse_ini_file( ROOTPATH.'/config/'.$fileName, true );
[5341]	244
	245	self::$cache->put( $fileName, $config );
	246	}
	247
	248	return( $config );
[5136]	249	}
	250
[5341]	251	public static function import( $path, $ext = ".php" )
	252	{
	253	if( !isset(self::$includes[$path]) )
[5136]	254	{
[5341]	255	require_once( ROOTPATH.'/'.$path.$ext );
	256	self::$includes[$path] = false;
	257	}
[5136]	258
[5341]	259	return( self::$includes[$path] );
	260	}
[5136]	261
[5341]	262	public static function load( $path, $class = false )
[5136]	263	{
[5341]	264	if( $return = self::import( $path, "" ) )
	265	return( $return );
[5136]	266
[5341]	267	if( !$class ){
	268	preg_match( '/^\/?.*\/([^\/]+).php$/', $path, $class );
	269	$class = $class[1];
[5136]	270	}
	271
[5341]	272	$object = self::$cache->get( $class );
[5136]	273
[5341]	274	if( !$object )
	275	{
	276	$object = new $class();
	277	self::$cache->put( $class, $object );
	278	}
[5136]	279
[5341]	280	self::$includes[$path] = $object;
	281
	282	return( $object );
[5136]	283	}
	284
[5341]	285	public static function wallet( $serviceName )
[5136]	286	{
[5341]	287	if( !isset( self::$wallet ) )
	288	{
	289	//// Hack //// TODO: passar o init da sessÃ£o no login do expresso
	290	Config::init();
	291
	292	if(isset($_SESSION['wallet']))
	293	self::$wallet = $_SESSION['wallet'];
	294	/////////////
	295	}
	296
	297	return isset( self::$wallet[ $serviceName ] )? self::$wallet[ $serviceName ] : false;
	298	}
[5136]	299
[5341]	300	public static function connect( $service, $config )
[5136]	301	{
[5341]	302	$result = $service->open( $config );
[5136]	303
[5341]	304	if( is_string( $result ) )
	305	throw new Exception( $result );
	306
	307	return( true );
	308	}
	309
	310	public static function configure( $config, $newConfig )
	311	{
	312	foreach( $newConfig as $key => $value )
	313	$config[$key] = $value;
	314
	315	return( $config );
[5136]	316	}
	317
[5341]	318	public static function dispatch( $dispatcher, $data, $optionsMap = false )
	319	{
	320	// if( $mappedTo )
	321	// $data = array( $mappedTo => $data );
	322	//
	323	// foreach( $data as $method => $params )
	324	// {
	325	// // foreach( $data[ $method ] as $name => $value )
	326	// }
	327	//
	328	// self::import( "$dispatcher.php" );
	329	}
	330
[5399]	331	//TODO: Compatibilizar as configs relativas aos modulos, adicionando os mesmo nos parametros passados
[5341]	332	public static function service( $serviceName, $concept = false )
	333	{
	334	if( isset( self::$services[ $serviceName ] ) )
	335	return self::$services[ $serviceName ];
	336
	337	if( !isset(self::$config[ $serviceName ]) )
	338	self::$config[ $serviceName ] = self::loadConfig( $serviceName, true );
	339
	340	if( !isset(self::$config[ $serviceName ]) )
[5136]	341	return( false );
	342
[5341]	343	if( !isset(self::$config[ $serviceName ]['type']) )
	344	self::$config[ $serviceName ]['type'] = 'service';
[5136]	345
[5399]	346	self::import( 'api/'.self::$config[ $serviceName ]['type'] ); //TODO: Item 4
[5341]	347
	348	$service = self::load( self::$config[ $serviceName ]['path'],
	349	self::$config[ $serviceName ]['class'] );
	350
	351	$srvConfig = array();
	352
	353	if( isset(self::$config[ $serviceName ][ 'config' ]) )
	354	$srvConfig = self::configure( $srvConfig, self::$config[ $serviceName ][ 'config' ] );
	355	if( $wallet = self::wallet( $serviceName ) )
	356	$srvConfig = self::configure( $srvConfig, $wallet );
	357	if( $concept && isset(self::$config[ $concept ]['service.config']) )
	358	$srvConfig = self::configure( $srvConfig, self::$config[ $concept ]['service.config'] );
	359
	360	if( empty( $srvConfig ) )
	361	$srvConfig = false;
	362
	363	if( $service && self::$config[ $serviceName ]['type'] === 'service' )
	364	self::connect( $service, $srvConfig );
	365
	366	return( self::$services[ $serviceName ] = $service );
	367	}
	368
[5399]	369	//TODO: Compatibilizar as configs relativas aos modulos, adicionando os mesmo nos parametros passados
[5341]	370	public static function interceptor( $method, $concept = false, $serviceName = false, $isService = false )
	371	{
	372	if( $concept && !isset(self::$config[ $concept ]) )
	373	self::$config[ $concept ] = self::loadConfig( $concept );
	374
	375	if( !$concept ) $concept = 'global';
	376	if( !$isService \|\| !$serviceName ) $serviceName = 'global';
	377
	378	if( !isset( self::$interceptors[ $concept ] ) )
	379	self::$interceptors[ $concept ] = array();
	380
	381	if( !isset( self::$interceptors[ $concept ][ $serviceName ] ) )
	382	self::$interceptors[ $concept ][ $serviceName ] = array();
	383
	384	if( !isset( self::$interceptors[ $concept ][ $serviceName ][ $method ] ) )
	385	{
	386	$events = array( 'before', 'after' );
	387	$interceptors = array();
	388
	389	$prefix = ( $isService )? "$serviceName." : "";
	390
	391	foreach( $events as $i => $event )
	392	{
	393	$interceptors[$event] = array();
	394
	395	if( !isset(self::$config[$concept]["$prefix$event.$method"]) )
	396	continue;
	397
	398	foreach( self::$config[$concept]["$prefix$event.$method"] as $intercept => $interceptor )
	399	$interceptors[$event][$intercept] = self::load( $interceptor );
	400	}
	401
	402	self::$interceptors[ $concept ][ $serviceName ][ $method ] = $interceptors;
	403	}
	404
	405	return( self::$interceptors[ $concept ][ $serviceName ][ $method ] );
	406	}
	407
	408	public static function interceptorCommit( $eventType, $commitList, $isService = false )
	409	{
	410	$result = array( $eventType => array() );
	411
[5437]	412	if( is_array( $commitList ) )
[5341]	413	foreach( $commitList as $i => $tx )
	414	{
	415	$interceptors = self::interceptor( 'commit', $tx['concept'], $tx['service'], $isService );
	416
	417	$result[$eventType] = array_merge( $result[$eventType], $interceptors[$eventType] );
	418	}
	419
[5136]	420	return( $result );
	421	}
	422
[5341]	423	public static function fire( $eventType, $method, &$params, $original, $isService = false )
[5136]	424	{
[5341]	425	if( $method === 'commit' )
	426	$interceptors = self::interceptorCommit( $eventType, $params['criteria'], $isService );
	427
	428	else
	429	$interceptors = self::interceptor( $method,
	430	isset($original['URI']['concept']) ? $original['URI']['concept'] : false,
	431	isset($params['URI']['service']) ? $params['URI']['service'] : false, $isService );
	432
	433	if( $interceptors && isset($interceptors[ $eventType ]) )
	434	foreach( $interceptors[ $eventType ] as $intercept => $interceptor )
	435	{
[5539]	436	$return = $interceptor->$intercept( $params['URI'], $params['properties'], $params['criteria'], $original /, $params['service'] /);
[5341]	437
	438	if( $return === false )
[5136]	439	return( false );
	440
[5341]	441	if( isset($return) )
	442	$params['properties'] = $return;
	443	}
	444
	445	return( $params );
	446	}
	447
	448	/*
	449	* ex: array
	450	* (
	451	* [0] array( 'OR', array( array( '=', 'campo', 'valor' ),
	452	array( 'OR', array( array( '=', 'campo', 'valor' ) ) ) )
	453	* [1] array( '=', 'campo' , 'valor' )
	454	* [2] array( 'OR' , array( array( '=' , campo', 'valor' ) ) )
	455	* [3] array( 'IN', 'campo', array( '1' , '2' , '3' ) )
	456	* )
	457	* OR
	458	* array( '=' , 'campo' , 'valor' )
	459	*/
[5399]	460
	461	//TODO: Compatibilizar as configs relativas aos modulos, adicionando os mesmo nos parametros passados
[5341]	462	public static function serviceName( $URI, $original = false )
	463	{
	464	$concept = "";
	465
	466	if( $original && isset($original['concept']) && $original['concept'] )
	467	$concept = $original['concept'];
	468	elseif( isset($URI['concept']) && $URI['concept'] )
	469	$concept = $URI['concept'];
	470
	471	if( ( !isset($URI['service']) \|\| !$URI['service'] ) && $concept )
	472	{
	473	if( !isset(self::$config[ $concept ]) )
	474	self::$config[ $concept ] = self::loadConfig( $concept );
	475
	476	$URI['service'] = self::$config[ $concept ][ 'service' ];
	477	}
	478
	479	if( !isset($URI['service']) )
	480	throw new Exception( "CONFIGURATION ERROR: service name from concept '$concept' not found" );
	481
	482	return( $URI );
	483	}
	484
[5399]	485	//TODO: Compatibilizar as configs relativas aos modulos, adicionando os mesmos nas options passadas
[5437]	486	public static function call( $method, $URI, $properties = false, $options = false, $service = false )
[5341]	487	{
	488	try
	489	{
	490	if( !isset($URI['concept']) ) $URI['concept'] = false;
	491
	492	$original = $params = array( 'properties' => $properties,
	493	'criteria' => $options,
	494	'URI' => $URI,
	495	'service' => $service );
	496
	497	if( isset($params['URI']['concept']) && !self::fire( 'before', $method, $params, $original ) )
	498	return( empty($params['properties']) ? false : $params['properties'] );
	499
[5437]	500
	501
[5341]	502	if( $params && !$params['service'] )
	503	{
	504	$params['URI'] = self::serviceName( $params['URI'], $original['URI'] );
	505
	506	$params['service'] = self::service( $params['URI']['service'], $params['URI']['concept'] );
	507	}
	508
	509	if( isset($params['URI']['service']) )
	510	{
[5437]	511	if( $method === 'create' \|\| $method === 'update' \|\| $method === 'delete' )
[5341]	512	{
[5437]	513	if( $commit = !isset(self::$tx[ $params['URI']['service'] ]) )
	514	{
	515	self::call( 'begin', $params['URI'] );
	516	}
	517
	518	$TX = array();
[5341]	519	}
	520
	521	if( !self::fire( 'before', $method, $params, $original, true ) )
	522	return( empty($params['properties']) ? false : $params['properties'] );
	523	}
	524
	525	if( $params['service'] )
	526	switch( $method )
[5437]	527	{
[5341]	528	case 'find': $return = $params['service']->find( $params['URI'], $params['properties'], $params['criteria'] ); break;
[5136]	529
[5637]	530	case 'read': $return = $params['service']->read( $params['URI'], $params['properties'] , $params['criteria'] ); break;
[5341]	531
	532	case 'create': $return = $params['service']->create( $params['URI'], $params['properties']/, $criteria/ ); break;
	533
[5971]	534	case 'delete': $return = $params['service']->delete( $params['URI'], $params['properties'], $params['criteria'] ); break;
[5341]	535
	536	case 'deleteAll': $return = $params['service']->deleteAll( $params['URI'], $params['properties'], $params['criteria'] ); break;
	537
[6023]	538	case 'update': $return = $params['service']->update( $params['URI'], $params['properties'], $params['criteria'] ); break;
[5341]	539
	540	case 'replace': $return = $params['service']->replace( $params['URI'], $params['properties'], $params['criteria'] ); break;
	541
	542	case 'begin': $return = $params['service']->begin( $params['URI'] ); break;
	543
	544	case 'commit': $return = $params['service']->commit( $params['URI'], $params['criteria'] ); break;
	545
	546	case 'rollback': $return = $params['service']->rollback( $params['URI'], $params['criteria'] ); break;
	547
	548	case 'parse': $return = $params['service']->parse( $params['properties'], $params['criteria'] ); break;
	549
[5437]	550	case 'analize': $return = $params['service']->analize( $params['properties'], $params['criteria'] ); break;
	551
[5341]	552	case 'format': $return = $params['service']->format( $params['properties'], $params['criteria'] ); break;
[5136]	553
[5437]	554	default : $return = $params['service']->$method( $params['properties'], $params['criteria'] );
	555	}
	556
[5341]	557	if( isset($return) && $return !== false )
	558	$params['properties'] = $return;
	559
	560	if( isset($params['URI']['service']) )
	561	if( !self::fire( 'after', $method, $params, $original, true ) )
	562	return( empty($params['properties']) ? false : $params['properties'] );
	563
[5437]	564	if( isset($URI['concept']) )
	565	self::fire( 'after', $method, $params, $original );
	566
	567	if( empty($params['properties']) )
	568	$params['properties'] = false;
	569
	570	if( isset( $TX ) )
	571	{
	572	$TX['rollback'] = !!!$params['properties'];
	573
[5539]	574	if( $params['properties'] && is_array($params['properties']) && isset($params['properties']['id']) )
[5437]	575	$TX['id'] = $params['properties']['id'];
	576
	577	self::$tx[ $params['URI']['service'] ][] = array_merge( $TX, $original['URI'], array( 'service' => $params['URI']['service'], 'method' => $method ) );
	578
	579	if( isset($commit) && $commit )
[5341]	580	{
	581	if( !self::call( 'commit', $params['URI'], false, self::$tx[ $params['URI']['service'] ] ) )
	582	self::call( 'rollback', $params['URI'] , false, self::$tx[ $params['URI']['service'] ] );
	583
	584	unset( self::$tx[ $params['URI']['service'] ] );
	585	}
	586	}
	587	}
	588	catch( Exception $e )
	589	{
	590	if( !self::fallback( $e ) )
	591	self::closeAll();
	592
[5136]	593	return( false );
[5341]	594	}
[5136]	595
[5437]	596	return( $params['properties'] );
[5341]	597	}
[5136]	598
[5341]	599	public static function fallback( $exception )
	600	{
[5905]	601	$code = $exception->getCode();
	602
	603	if( isset( self::$fallbackHandlers[ $code ] ) )
[5908]	604	{
	605	$fn = self::$fallbackHandlers[ $code ];
	606	return $fn( $exception );
	607	}
[5905]	608
[5341]	609	error_log( $exception->getMessage() );
	610	return( true );
[5136]	611	}
[5905]	612
	613	public static function addFallbackHandler( $code, $function )
	614	{
	615	self::$fallbackHandlers[ $code ] = $function;
	616	}
[5811]	617	/*
	618	*NULL evita erros caso nÃ£o seja passado nenhuma variavel por referÃªncia
	619	*/
	620	public static function put( $URI, $data, &$txIds = NULL )
[5437]	621	{
	622	try
	623	{
	624	$URI = self::serviceName( $URI );
	625
	626	if( $commit = !$txIds )
	627	$txIds = array();
	628
	629	if( !isset( self::$tx[ $URI['service'] ] ) )
	630	{
	631	self::call( 'begin', $URI );
	632	self::$tx[ $txIds[] = $URI['service'] ] = array();
	633	}
	634
	635	$method = $data ? isset( $data['id'] ) ?
	636	'update' : 'create' : 'delete';
	637
	638	$links = self::links( $URI['concept'] );
	639
	640	$order = self::$txID++;
	641
	642	$postpone = array();
[5514]	643	$linkNames = array();
[5437]	644
	645	if( $data )
	646	{
	647	$URI['id'] = isset( $data['id'] ) ? $data['id'] : false;
	648
	649	foreach( $links as $linkName => $linkTarget )
	650	{
	651	if( isset( $data[$linkName] ) && is_array( $data[$linkName] ) )
	652	{
[5514]	653	if( self::isConcept( $URI['concept'], $linkName ) )
[5773]	654	$data[$linkName] = self::put( array( 'concept' => $linkTarget ), $data[$linkName], $txIds );
[5437]	655	else
[5514]	656	{
	657	$postpone[ $linkTarget ] = $data[$linkName];
	658	$linkNames[ $linkTarget ] = $linkName;
	659	}
[5437]	660	}
	661	}
	662	}
	663	else
	664	$URI['id'] = isset( $data['id'] ) ? $data['id'] : $URI['id'];
	665
	666	$result = Controller::call( $method, $URI, $data, false, false, true );
	667
[5539]	668	if( is_array( $result ) && isset( $result['id'] ) )
[5437]	669	$URI['id'] = $result['id'];
	670
	671	self::$tx[ $URI['service'] ][ count(self::$tx[ $URI['service'] ]) - 1 ]['order'] = $order;
	672	self::$tx[ $URI['service'] ][ count(self::$tx[ $URI['service'] ]) - 1 ]['id'] = $URI['id'];
	673
	674	foreach( $postpone as $linkTarget => $dt )
[5715]	675	{
	676	if( Controller::hasOne( $URI['concept'], $linkNames[ $linkTarget ] ) )
	677	$dt = array( $dt );
	678
[5437]	679	foreach( $dt as $ii => $value )
	680	{
	681	if( !is_array( $value ) )
	682	$value = array( 'id' => $value );
	683
[5514]	684	$value[ self::links( $URI['concept'], $linkNames[ $linkTarget ] ) ] = $URI['id'];
	685
[5773]	686	self::put( array( 'concept' => $linkTarget ), $value, $txIds );
[5437]	687	}
[5715]	688	}
[5437]	689	if( $commit )
	690	{
	691	$result = array();
	692
	693	for( $i = count( $txIds ) - 1; $i >= 0; $i-- )
	694	{
	695	$currentTx = self::$tx[ $txIds[$i] ];
	696	unset( self::$tx[ $txIds[$i] ] );
	697
	698	if( !self::commit( array( 'service' => $txIds[$i] ), $currentTx ) )
	699	{
	700	self::rollback( array( 'service' => $txIds[$i] ), $currentTx );
	701
	702	foreach( $currentTx as $i => $st )
	703	$currentTx[$i][ 'rollback' ] = true;
	704	}
	705
	706	$result = array_merge( $result, $currentTx );
	707	}
	708
	709	self::$txID = 0;
	710
	711	return( $result );
	712	}
	713
	714	}
	715	catch( Exception $e )
	716	{
	717	if( !self::fallback( $e ) )
	718	self::closeAll();
	719
	720	return( false );
	721	}
	722
	723	return( $URI['id'] );
	724	}
	725
	726	public static function get()
	727	{
	728
	729	}
[5136]	730	}
[5341]	731
	732	Controller::$cache = Controller::loadCache();
[5539]	733	// ?>

Note: See TracBrowser for help on using the repository browser.

Download in other formats: