Standard::location()   A
last analyzed

Complexity

Conditions 1
Paths 1

Size

Total Lines 18
Code Lines 1

Duplication

Lines 0
Ratio 0 %

Importance

Changes 0
Metric Value
cc 1
eloc 1
c 0
b 0
f 0
nc 1
nop 0
dl 0
loc 18
rs 10
1
<?php
2
3
/**
4
 * @license LGPLv3, http://opensource.org/licenses/LGPL-3.0
5
 * @copyright Aimeos (aimeos.org), 2019-2025
6
 * @package Controller
7
 * @subpackage Jobs
8
 */
9
10
11
namespace Aimeos\Controller\Jobs\Group\Import\Xml;
12
13
14
/**
15
 * Job controller for XML group imports
16
 *
17
 * @package Controller
18
 * @subpackage Jobs
19
 */
20
class Standard
21
	extends \Aimeos\Controller\Jobs\Base
22
	implements \Aimeos\Controller\Jobs\Iface
23
{
24
	/** controller/jobs/group/import/xml/name
25
	 * Class name of the used group suggestions scheduler controller implementation
26
	 *
27
	 * Each default job controller can be replace by an alternative imlementation.
28
	 * To use this implementation, you have to set the last part of the class
29
	 * name as configuration value so the controller factory knows which class it
30
	 * has to instantiate.
31
	 *
32
	 * For example, if the name of the default class is
33
	 *
34
	 *  \Aimeos\Controller\Jobs\Group\Import\Xml\Standard
35
	 *
36
	 * and you want to replace it with your own version named
37
	 *
38
	 *  \Aimeos\Controller\Jobs\Group\Import\Xml\Myxml
39
	 *
40
	 * then you have to set the this configuration option:
41
	 *
42
	 *  controller/jobs/group/import/xml/name = Myxml
43
	 *
44
	 * The value is the last part of your own class name and it's case sensitive,
45
	 * so take care that the configuration value is exactly named like the last
46
	 * part of the class name.
47
	 *
48
	 * The allowed characters of the class name are A-Z, a-z and 0-9. No other
49
	 * characters are possible! You should always start the last part of the class
50
	 * name with an upper case character and continue only with lower case characters
51
	 * or numbers. Avoid chamel case names like "MyXml"!
52
	 *
53
	 * @param string Last part of the class name
54
	 * @since 2019.04
55
	 */
56
57
	/** controller/jobs/group/import/xml/decorators/excludes
58
	 * Excludes decorators added by the "common" option from the group import CSV job controller
59
	 *
60
	 * Decorators extend the functionality of a class by adding new aspects
61
	 * (e.g. log what is currently done), executing the methods of the underlying
62
	 * class only in certain conditions (e.g. only for logged in users) or
63
	 * modify what is returned to the caller.
64
	 *
65
	 * This option allows you to remove a decorator added via
66
	 * "controller/jobs/common/decorators/default" before they are wrapped
67
	 * around the job controller.
68
	 *
69
	 *  controller/jobs/group/import/xml/decorators/excludes = array( 'decorator1' )
70
	 *
71
	 * This would remove the decorator named "decorator1" from the list of
72
	 * common decorators ("\Aimeos\Controller\Jobs\Common\Decorator\*") added via
73
	 * "controller/jobs/common/decorators/default" to the job controller.
74
	 *
75
	 * @param array List of decorator names
76
	 * @since 2019.04
77
	 * @see controller/jobs/common/decorators/default
78
	 * @see controller/jobs/group/import/xml/decorators/global
79
	 * @see controller/jobs/group/import/xml/decorators/local
80
	 */
81
82
	/** controller/jobs/group/import/xml/decorators/global
83
	 * Adds a list of globally available decorators only to the group import CSV job controller
84
	 *
85
	 * Decorators extend the functionality of a class by adding new aspects
86
	 * (e.g. log what is currently done), executing the methods of the underlying
87
	 * class only in certain conditions (e.g. only for logged in users) or
88
	 * modify what is returned to the caller.
89
	 *
90
	 * This option allows you to wrap global decorators
91
	 * ("\Aimeos\Controller\Jobs\Common\Decorator\*") around the job controller.
92
	 *
93
	 *  controller/jobs/group/import/xml/decorators/global = array( 'decorator1' )
94
	 *
95
	 * This would add the decorator named "decorator1" defined by
96
	 * "\Aimeos\Controller\Jobs\Common\Decorator\Decorator1" only to the job controller.
97
	 *
98
	 * @param array List of decorator names
99
	 * @since 2019.04
100
	 * @see controller/jobs/common/decorators/default
101
	 * @see controller/jobs/group/import/xml/decorators/excludes
102
	 * @see controller/jobs/group/import/xml/decorators/local
103
	 */
104
105
	/** controller/jobs/group/import/xml/decorators/local
106
	 * Adds a list of local decorators only to the group import CSV job controller
107
	 *
108
	 * Decorators extend the functionality of a class by adding new aspects
109
	 * (e.g. log what is currently done), executing the methods of the underlying
110
	 * class only in certain conditions (e.g. only for logged in users) or
111
	 * modify what is returned to the caller.
112
	 *
113
	 * This option allows you to wrap local decorators
114
	 * ("\Aimeos\Controller\Jobs\Group\Import\Xml\Decorator\*") around the job
115
	 * controller.
116
	 *
117
	 *  controller/jobs/group/import/xml/decorators/local = array( 'decorator2' )
118
	 *
119
	 * This would add the decorator named "decorator2" defined by
120
	 * "\Aimeos\Controller\Jobs\Group\Import\Xml\Decorator\Decorator2"
121
	 * only to the job controller.
122
	 *
123
	 * @param array List of decorator names
124
	 * @since 2019.04
125
	 * @see controller/jobs/common/decorators/default
126
	 * @see controller/jobs/group/import/xml/decorators/excludes
127
	 * @see controller/jobs/group/import/xml/decorators/global
128
	 */
129
130
131
	use \Aimeos\Controller\Jobs\Common\Import\Xml\Traits;
132
133
134
	/**
135
	 * Returns the localized name of the job.
136
	 *
137
	 * @return string Name of the job
138
	 */
139
	public function getName() : string
140
	{
141
		return $this->context()->translate( 'controller/jobs', 'Groups import XML' );
142
	}
143
144
145
	/**
146
	 * Returns the localized description of the job.
147
	 *
148
	 * @return string Description of the job
149
	 */
150
	public function getDescription() : string
151
	{
152
		return $this->context()->translate( 'controller/jobs', 'Imports new and updates existing groups from XML files' );
153
	}
154
155
156
	/**
157
	 * Executes the job.
158
	 *
159
	 * @throws \Aimeos\Controller\Jobs\Exception If an error occurs
160
	 */
161
	public function run()
162
	{
163
		$context = $this->context();
164
		$logger = $context->logger();
165
		$process = $context->process();
166
167
		try
168
		{
169
			$fs = $context->fs( 'fs-import' );
170
			$site = $context->locale()->getSiteItem()->getCode();
171
			$location = $this->location() . '/' . $site;
172
173
			if( $fs->isDir( $location ) === false ) {
174
				return;
175
			}
176
177
			$logger->info( sprintf( 'Started group import from "%1$s"', $location ), 'import/xml/group' );
178
179
			$fcn = function( \Aimeos\MShop\ContextIface $context, string $path ) {
180
				$this->import( $context, $path );
181
			};
182
183
			foreach( map( $fs->scan( $location ) )->sort() as $filename )
184
			{
185
				$path = $location . '/' . $filename;
186
187
				if( $filename[0] === '.' || $fs instanceof \Aimeos\Base\Filesystem\DirIface && $fs->isDir( $path ) ) {
188
					continue;
189
				}
190
191
				$process->start( $fcn, [$context, $path] );
192
			}
193
194
			$process->wait();
195
196
			$logger->info( sprintf( 'Finished group import from "%1$s"', $location ), 'import/xml/group' );
197
		}
198
		catch( \Exception $e )
199
		{
200
			$logger->error( 'Customer group import error: ' . $e->getMessage() . "\n" . $e->getTraceAsString(), 'import/xml/group' );
201
			$this->mail( 'Customer group XML import error', $e->getMessage() . "\n" . $e->getTraceAsString() );
202
			throw $e;
203
		}
204
	}
205
206
207
	/**
208
	 * Returns the directory for storing imported files
209
	 *
210
	 * @return string Directory for storing imported files
211
	 */
212
	protected function backup() : string
213
	{
214
		/** controller/jobs/group/import/xml/backup
215
		 * Name of the backup for sucessfully imported files
216
		 *
217
		 * After a XML file was imported successfully, you can move it to another
218
		 * location, so it won't be imported again and isn't overwritten by the
219
		 * next file that is stored at the same location in the file system.
220
		 *
221
		 * You should use an absolute path to be sure but can be relative path
222
		 * if you absolutely know from where the job will be executed from. The
223
		 * name of the new backup location can contain placeholders understood
224
		 * by the PHP DateTime::format() method (with percent signs prefix) to
225
		 * create dynamic paths, e.g. "backup/%Y-%m-%d" which would create
226
		 * "backup/2000-01-01". For more information about the date() placeholders,
227
		 * please have a look  into the PHP documentation of the
228
		 * {@link https://www.php.net/manual/en/datetime.format.php format() method}.
229
		 *
230
		 * **Note:** If no backup name is configured, the file will be removed!
231
		 *
232
		 * @param integer Name of the backup file, optionally with date/time placeholders
233
		 * @since 2019.04
234
		 * @see controller/jobs/group/import/xml/domains
235
		 * @see controller/jobs/group/import/xml/location
236
		 * @see controller/jobs/group/import/xml/max-query
237
		 */
238
		$backup = $this->context()->config()->get( 'controller/jobs/group/import/xml/backup' );
239
		return \Aimeos\Base\Str::strtime( (string) $backup );
240
	}
241
242
243
	/**
244
	 * Imports the XML file given by its path
245
	 *
246
	 * @param \Aimeos\MShop\ContextIface $context Context object
247
	 * @param string $path Relative path to the XML file in the file system
248
	 */
249
	protected function import( \Aimeos\MShop\ContextIface $context, string $path )
250
	{
251
		$slice = 0;
252
		$nodes = [];
253
254
		$xml = new \XMLReader();
255
		$maxquery = $this->max();
256
257
		$logger = $context->logger();
258
		$fs = $context->fs( 'fs-import' );
259
		$tmpfile = $fs->readf( $path );
260
261
		if( $xml->open( $tmpfile, null, LIBXML_COMPACT | LIBXML_PARSEHUGE ) === false ) {
262
			throw new \Aimeos\Controller\Jobs\Exception( sprintf( 'No XML file "%1$s" found', $tmpfile ) );
263
		}
264
265
		$logger->info( sprintf( 'Started group import from file "%1$s"', $path ), 'import/xml/group' );
266
267
		while( $xml->read() === true )
268
		{
269
			if( $xml->depth === 1 && $xml->nodeType === \XMLReader::ELEMENT && $xml->name === 'groupitem' )
270
			{
271
				if( ( $dom = $xml->expand() ) === false )
272
				{
273
					$msg = sprintf( 'Expanding "%1$s" node failed', 'groupitem' );
274
					throw new \Aimeos\Controller\Jobs\Exception( $msg );
275
				}
276
277
				$nodes[] = $dom;
278
279
				if( $slice++ >= $maxquery )
280
				{
281
					$this->importNodes( $nodes );
282
					unset( $nodes );
283
					$nodes = [];
284
					$slice = 0;
285
				}
286
			}
287
		}
288
289
		$this->importNodes( $nodes );
290
		unset( $nodes );
291
292
		foreach( $this->getProcessors() as $proc ) {
293
			$proc->finish();
294
		}
295
296
		unlink( $tmpfile );
297
298
		if( !empty( $backup = $this->backup() ) ) {
299
			$fs->move( $path, $backup );
300
		} else {
301
			$fs->rm( $path );
302
		}
303
304
		$logger->info( sprintf( 'Finished group import from file "%1$s"', $path ), 'import/xml/group' );
305
	}
306
307
308
	/**
309
	 * Imports the given DOM nodes
310
	 *
311
	 * @param string[] $ref List of domain names whose referenced items will be updated in the group items
312
	 */
313
	protected function importNodes( array $nodes )
314
	{
315
		$codes = $map = [];
316
317
		foreach( $nodes as $node )
318
		{
319
			if( ( $attr = $node->attributes->getNamedItem( 'ref' ) ) !== null ) {
320
				$codes[$attr->nodeValue] = null;
321
			}
322
		}
323
324
		$manager = \Aimeos\MShop::create( $this->context(), 'group' );
325
		$search = $manager->filter()->slice( 0, count( $codes ) );
326
		$search->setConditions( $search->compare( '==', 'group.code', array_keys( $codes ) ) );
327
328
		foreach( $manager->search( $search ) as $item ) {
329
			$map[$item->getCode()] = $item;
330
		}
331
332
		foreach( $nodes as $node )
333
		{
334
			if( ( $attr = $node->attributes->getNamedItem( 'ref' ) ) !== null && isset( $map[$attr->nodeValue] ) ) {
335
				$item = $this->process( $map[$attr->nodeValue], $node );
336
			} else {
337
				$item = $this->process( $manager->create(), $node );
338
			}
339
340
			$manager->save( $item );
341
		}
342
	}
343
344
345
	/**
346
	 * Returns the path to the directory with the XML file
347
	 *
348
	 * @return string Path to the directory with the XML file
349
	 */
350
	protected function location() : string
351
	{
352
		/** controller/jobs/group/import/xml/location
353
		 * Directory where the CSV files are stored which should be imported
354
		 *
355
		 * It's the relative path inside the "fs-import" virtual file system
356
		 * configuration. The default location of the "fs-import" file system is:
357
		 *
358
		 * * Laravel: ./storage/import/
359
		 * * TYPO3: /uploads/tx_aimeos/.secure/import/
360
		 *
361
		 * @param string Relative path to the XML files
362
		 * @since 2019.04
363
		 * @see controller/jobs/group/import/xml/backup
364
		 * @see controller/jobs/group/import/xml/domains
365
		 * @see controller/jobs/group/import/xml/max-query
366
		 */
367
		return (string) $this->context()->config()->get( 'controller/jobs/group/import/xml/location', 'group' );
368
	}
369
370
371
	/**
372
	 * Returns the maximum number of XML nodes processed at once
373
	 *
374
	 * @return int Maximum number of XML nodes
375
	 */
376
	protected function max() : int
377
	{
378
		/** controller/jobs/group/import/xml/max-query
379
		 * Maximum number of XML nodes processed at once
380
		 *
381
		 * Processing and fetching several attribute items at once speeds up importing
382
		 * the XML files. The more items can be processed at once, the faster the
383
		 * import. More items also increases the memory usage of the importer and
384
		 * thus, this parameter should be low enough to avoid reaching the memory
385
		 * limit of the PHP process.
386
		 *
387
		 * @param integer Number of XML nodes
388
		 * @since 2019.04
389
		 * @see controller/jobs/group/import/xml/domains
390
		 * @see controller/jobs/group/import/xml/location
391
		 * @see controller/jobs/group/import/xml/backup
392
		 */
393
		return $this->context()->config()->get( 'controller/jobs/group/import/xml/max-query', 100 );
394
	}
395
396
397
	/**
398
	 * Updates the group item and its referenced items using the given DOM node
399
	 *
400
	 * @param \Aimeos\MShop\Group\Item\Iface $item Customer group item object to update
401
	 * @param \DomElement $node DOM node used for updating the group item
402
	 * @return \Aimeos\MShop\Group\Item\Iface $item Updated group item object
403
	 */
404
	protected function process( \Aimeos\MShop\Group\Item\Iface $item, \DomElement $node ) : \Aimeos\MShop\Group\Item\Iface
405
	{
406
		$list = [];
407
408
		foreach( $node->attributes as $attr ) {
409
			$list[$attr->nodeName] = $attr->nodeValue;
410
		}
411
412
		foreach( $node->childNodes as $tag ) {
413
			$list[$tag->nodeName] = $tag->nodeValue;
414
		}
415
416
		return $item->fromArray( $list, true );
417
	}
418
}
419