techdivision /
import
Duplicate code is one of the most pungent code smells. A rule that is often used is to re-structure code once it is duplicated in three or more places.
Common duplication problems, and corresponding solutions are:
Complex classes like AbstractSubject often do a lot of different things. To break such a class down, we need to identify a cohesive component within that class. A common approach to find such a component is to look for fields/methods that share the same prefixes, or suffixes. You can also have a look at the cohesion graph to spot any un-connected, or weakly-connected components.
Once you have determined the fields that belong together, you can apply the Extract Class refactoring. If the component makes sense as a sub-class, Extract Subclass is also a candidate, and is often faster.
While breaking up the class, it is a good idea to analyze how other classes use AbstractSubject, and based on these observations, apply Extract Interface, too.
| 1 | <?php |
||
| 48 | abstract class AbstractSubject implements SubjectInterface |
||
| 49 | { |
||
| 50 | |||
| 51 | /** |
||
| 52 | * The trait that provides basic filesystem handling functionality. |
||
| 53 | * |
||
| 54 | * @var TechDivision\Import\Subjects\FilesystemTrait |
||
| 55 | */ |
||
| 56 | use FilesystemTrait; |
||
| 57 | |||
| 58 | /** |
||
| 59 | * The trait that provides basic filesystem handling functionality. |
||
| 60 | * |
||
| 61 | * @var TechDivision\Import\SystemLoggerTrait |
||
| 62 | */ |
||
| 63 | use SystemLoggerTrait; |
||
| 64 | |||
| 65 | /** |
||
| 66 | * The trait that provides header handling functionality. |
||
| 67 | * |
||
| 68 | * @var TechDivision\Import\HeaderTrait |
||
| 69 | */ |
||
| 70 | use HeaderTrait; |
||
| 71 | |||
| 72 | /** |
||
| 73 | * The trait that provides row handling functionality. |
||
| 74 | * |
||
| 75 | * @var TechDivision\Import\RowTrait |
||
| 76 | */ |
||
| 77 | use RowTrait; |
||
| 78 | |||
| 79 | /** |
||
| 80 | * The name of the file to be imported. |
||
| 81 | * |
||
| 82 | * @var string |
||
| 83 | */ |
||
| 84 | protected $filename; |
||
| 85 | |||
| 86 | /** |
||
| 87 | * The actual line number. |
||
| 88 | * |
||
| 89 | * @var integer |
||
| 90 | */ |
||
| 91 | protected $lineNumber = 0; |
||
| 92 | |||
| 93 | /** |
||
| 94 | * The actual operation name. |
||
| 95 | * |
||
| 96 | * @var string |
||
| 97 | */ |
||
| 98 | protected $operationName ; |
||
| 99 | |||
| 100 | /** |
||
| 101 | * The flag that stop's overserver execution on the actual row. |
||
| 102 | * |
||
| 103 | * @var boolean |
||
| 104 | */ |
||
| 105 | protected $skipRow = false; |
||
| 106 | |||
| 107 | /** |
||
| 108 | * The import adapter instance. |
||
| 109 | * |
||
| 110 | * @var \TechDivision\Import\Adapter\ImportAdapterInterface |
||
| 111 | */ |
||
| 112 | protected $importAdapter; |
||
| 113 | |||
| 114 | /** |
||
| 115 | * The system configuration. |
||
| 116 | * |
||
| 117 | * @var \TechDivision\Import\Configuration\SubjectConfigurationInterface |
||
| 118 | */ |
||
| 119 | protected $configuration; |
||
| 120 | |||
| 121 | /** |
||
| 122 | * The RegistryProcessor instance to handle running threads. |
||
| 123 | * |
||
| 124 | * @var \TechDivision\Import\Services\RegistryProcessorInterface |
||
| 125 | */ |
||
| 126 | protected $registryProcessor; |
||
| 127 | |||
| 128 | /** |
||
| 129 | * The actions unique serial. |
||
| 130 | * |
||
| 131 | * @var string |
||
| 132 | */ |
||
| 133 | protected $serial; |
||
| 134 | |||
| 135 | /** |
||
| 136 | * Array with the subject's observers. |
||
| 137 | * |
||
| 138 | * @var array |
||
| 139 | */ |
||
| 140 | protected $observers = array(); |
||
| 141 | |||
| 142 | /** |
||
| 143 | * Array with the subject's callbacks. |
||
| 144 | * |
||
| 145 | * @var array |
||
| 146 | */ |
||
| 147 | protected $callbacks = array(); |
||
| 148 | |||
| 149 | /** |
||
| 150 | * The subject's callback mappings. |
||
| 151 | * |
||
| 152 | * @var array |
||
| 153 | */ |
||
| 154 | protected $callbackMappings = array(); |
||
| 155 | |||
| 156 | /** |
||
| 157 | * The available root categories. |
||
| 158 | * |
||
| 159 | * @var array |
||
| 160 | */ |
||
| 161 | protected $rootCategories = array(); |
||
| 162 | |||
| 163 | /** |
||
| 164 | * The Magento configuration. |
||
| 165 | * |
||
| 166 | * @var array |
||
| 167 | */ |
||
| 168 | protected $coreConfigData = array(); |
||
| 169 | |||
| 170 | /** |
||
| 171 | * The available stores. |
||
| 172 | * |
||
| 173 | * @var array |
||
| 174 | */ |
||
| 175 | protected $stores = array(); |
||
| 176 | |||
| 177 | /** |
||
| 178 | * The available websites. |
||
| 179 | * |
||
| 180 | * @var array |
||
| 181 | */ |
||
| 182 | protected $storeWebsites = array(); |
||
| 183 | |||
| 184 | /** |
||
| 185 | * The default store. |
||
| 186 | * |
||
| 187 | * @var array |
||
| 188 | */ |
||
| 189 | protected $defaultStore; |
||
| 190 | |||
| 191 | /** |
||
| 192 | * The store view code the create the product/attributes for. |
||
| 193 | * |
||
| 194 | * @var string |
||
| 195 | */ |
||
| 196 | protected $storeViewCode; |
||
| 197 | |||
| 198 | /** |
||
| 199 | * The UID generator for the core config data. |
||
| 200 | * |
||
| 201 | * @var \TechDivision\Import\Utils\Generators\GeneratorInterface |
||
| 202 | */ |
||
| 203 | protected $coreConfigDataUidGenerator; |
||
| 204 | |||
| 205 | /** |
||
| 206 | * Initialize the subject instance. |
||
| 207 | * |
||
| 208 | * @param \TechDivision\Import\Services\RegistryProcessorInterface $registryProcessor The registry processor instance |
||
| 209 | * @param \TechDivision\Import\Utils\Generators\GeneratorInterface $coreConfigDataUidGenerator The UID generator for the core config data |
||
| 210 | * @param \Doctrine\Common\Collections\Collection $systemLoggers The array with the system loggers instances |
||
| 211 | */ |
||
| 212 | 77 | public function __construct( |
|
| 221 | |||
| 222 | /** |
||
| 223 | * Set's the name of the file to import |
||
| 224 | * |
||
| 225 | * @param string $filename The filename |
||
| 226 | * |
||
| 227 | * @return void |
||
| 228 | */ |
||
| 229 | 10 | public function setFilename($filename) |
|
| 233 | |||
| 234 | /** |
||
| 235 | * Return's the name of the file to import. |
||
| 236 | * |
||
| 237 | * @return string The filename |
||
| 238 | */ |
||
| 239 | 8 | public function getFilename() |
|
| 243 | |||
| 244 | /** |
||
| 245 | * Set's the actual operation name. |
||
| 246 | * |
||
| 247 | * @param string $operationName The actual operation name |
||
| 248 | * |
||
| 249 | * @return void |
||
| 250 | */ |
||
| 251 | 1 | public function setOperationName($operationName) |
|
| 255 | |||
| 256 | /** |
||
| 257 | * Return's the actual operation name. |
||
| 258 | * |
||
| 259 | * @return string |
||
| 260 | */ |
||
| 261 | 1 | public function getOperationName() |
|
| 265 | |||
| 266 | /** |
||
| 267 | * Set's the actual line number. |
||
| 268 | * |
||
| 269 | * @param integer $lineNumber The line number |
||
| 270 | * |
||
| 271 | * @return void |
||
| 272 | */ |
||
| 273 | 1 | public function setLineNumber($lineNumber) |
|
| 277 | |||
| 278 | /** |
||
| 279 | * Return's the actual line number. |
||
| 280 | * |
||
| 281 | * @return integer The line number |
||
| 282 | */ |
||
| 283 | 9 | public function getLineNumber() |
|
| 287 | |||
| 288 | /** |
||
| 289 | * Stop's observer execution on the actual row. |
||
| 290 | * |
||
| 291 | * @return void |
||
| 292 | */ |
||
| 293 | 1 | public function skipRow() |
|
| 297 | |||
| 298 | /** |
||
| 299 | * Return's the default callback mappings. |
||
| 300 | * |
||
| 301 | * @return array The default callback mappings |
||
| 302 | */ |
||
| 303 | 1 | public function getDefaultCallbackMappings() |
|
| 307 | |||
| 308 | /** |
||
| 309 | * Tries to format the passed value to a valid date with format 'Y-m-d H:i:s'. |
||
| 310 | * If the passed value is NOT a valid date, NULL will be returned. |
||
| 311 | * |
||
| 312 | * @param string $value The value to format |
||
| 313 | * |
||
| 314 | * @return string|null The formatted date or NULL if the date is not valid |
||
| 315 | */ |
||
| 316 | 2 | public function formatDate($value) |
|
| 327 | |||
| 328 | /** |
||
| 329 | * Extracts the elements of the passed value by exploding them |
||
| 330 | * with the also passed delimiter. |
||
| 331 | * |
||
| 332 | * @param string $value The value to extract |
||
| 333 | * @param string|null $delimiter The delimiter used to extrace the elements |
||
| 334 | * |
||
| 335 | * @return array The exploded values |
||
| 336 | */ |
||
| 337 | 2 | public function explode($value, $delimiter = null) |
|
| 350 | |||
| 351 | /** |
||
| 352 | * Queries whether or not debug mode is enabled or not, default is TRUE. |
||
| 353 | * |
||
| 354 | * @return boolean TRUE if debug mode is enabled, else FALSE |
||
| 355 | */ |
||
| 356 | 1 | public function isDebugMode() |
|
| 360 | |||
| 361 | /** |
||
| 362 | * Set's the subject configuration. |
||
| 363 | * |
||
| 364 | * @param \TechDivision\Import\Configuration\SubjectConfigurationInterface $configuration The subject configuration |
||
| 365 | * |
||
| 366 | * @return void |
||
| 367 | */ |
||
| 368 | 77 | public function setConfiguration(SubjectConfigurationInterface $configuration) |
|
| 372 | |||
| 373 | /** |
||
| 374 | * Return's the subject configuration. |
||
| 375 | * |
||
| 376 | * @return \TechDivision\Import\Configuration\SubjectConfigurationInterface The subject configuration |
||
| 377 | */ |
||
| 378 | 77 | public function getConfiguration() |
|
| 382 | |||
| 383 | /** |
||
| 384 | * Set's the import adapter instance. |
||
| 385 | * |
||
| 386 | * @param \TechDivision\Import\Adapter\ImportAdapterInterface $importAdapter The import adapter instance |
||
| 387 | * |
||
| 388 | * @return void |
||
| 389 | */ |
||
| 390 | 3 | public function setImportAdapter(ImportAdapterInterface $importAdapter) |
|
| 394 | |||
| 395 | /** |
||
| 396 | * Return's the import adapter instance. |
||
| 397 | * |
||
| 398 | * @return \TechDivision\Import\Adapter\ImportAdapterInterface The import adapter instance |
||
| 399 | */ |
||
| 400 | 3 | public function getImportAdapter() |
|
| 404 | |||
| 405 | /** |
||
| 406 | * Return's the RegistryProcessor instance to handle the running threads. |
||
| 407 | * |
||
| 408 | * @return \TechDivision\Import\Services\RegistryProcessorInterface The registry processor instance |
||
| 409 | */ |
||
| 410 | 77 | public function getRegistryProcessor() |
|
| 414 | |||
| 415 | /** |
||
| 416 | * Set's the unique serial for this import process. |
||
| 417 | * |
||
| 418 | * @param string $serial The unique serial |
||
| 419 | * |
||
| 420 | * @return void |
||
| 421 | */ |
||
| 422 | 9 | public function setSerial($serial) |
|
| 426 | |||
| 427 | /** |
||
| 428 | * Return's the unique serial for this import process. |
||
| 429 | * |
||
| 430 | * @return string The unique serial |
||
| 431 | */ |
||
| 432 | 4 | public function getSerial() |
|
| 436 | |||
| 437 | /** |
||
| 438 | * Return's the source date format to use. |
||
| 439 | * |
||
| 440 | * @return string The source date format |
||
| 441 | */ |
||
| 442 | 4 | public function getSourceDateFormat() |
|
| 446 | |||
| 447 | /** |
||
| 448 | * Return's the multiple field delimiter character to use, default value is comma (,). |
||
| 449 | * |
||
| 450 | * @return string The multiple field delimiter character |
||
| 451 | */ |
||
| 452 | 1 | public function getMultipleFieldDelimiter() |
|
| 456 | |||
| 457 | /** |
||
| 458 | * Return's the multiple value delimiter character to use, default value is comma (|). |
||
| 459 | * |
||
| 460 | * @return string The multiple value delimiter character |
||
| 461 | */ |
||
| 462 | 1 | public function getMultipleValueDelimiter() |
|
| 466 | |||
| 467 | /** |
||
| 468 | * Intializes the previously loaded global data for exactly one bunch. |
||
| 469 | * |
||
| 470 | * @param string $serial The serial of the actual import |
||
| 471 | * |
||
| 472 | * @return void |
||
| 473 | */ |
||
| 474 | 77 | public function setUp($serial) |
|
| 512 | |||
| 513 | /** |
||
| 514 | * Clean up the global data after importing the variants. |
||
| 515 | * |
||
| 516 | * @param string $serial The serial of the actual import |
||
| 517 | * |
||
| 518 | * @return void |
||
| 519 | */ |
||
| 520 | 1 | public function tearDown($serial) |
|
| 521 | { |
||
| 522 | |||
| 523 | // load the registry processor |
||
| 524 | 1 | $registryProcessor = $this->getRegistryProcessor(); |
|
| 525 | |||
| 526 | // update the source directory for the next subject |
||
| 527 | 1 | $registryProcessor->mergeAttributesRecursive( |
|
| 528 | $serial, |
||
| 529 | 1 | array(RegistryKeys::SOURCE_DIRECTORY => $newSourceDir = $this->getNewSourceDir($serial)) |
|
| 530 | ); |
||
| 531 | |||
| 532 | // log a debug message with the new source directory |
||
| 533 | 1 | $this->getSystemLogger()->debug( |
|
| 534 | 1 | sprintf('Subject %s successfully updated source directory to %s', get_class($this), $newSourceDir) |
|
| 535 | ); |
||
| 536 | 1 | } |
|
| 537 | |||
| 538 | /** |
||
| 539 | * Return's the target directory for the artefact export. |
||
| 540 | * |
||
| 541 | * @return string The target directory for the artefact export |
||
| 542 | */ |
||
| 543 | 1 | public function getTargetDir() |
|
| 547 | |||
| 548 | /** |
||
| 549 | * Return's the next source directory, which will be the target directory |
||
| 550 | * of this subject, in most cases. |
||
| 551 | * |
||
| 552 | * @param string $serial The serial of the actual import |
||
| 553 | * |
||
| 554 | * @return string The new source directory |
||
| 555 | */ |
||
| 556 | 4 | public function getNewSourceDir($serial) |
|
| 560 | |||
| 561 | /** |
||
| 562 | * Register the passed observer with the specific type. |
||
| 563 | * |
||
| 564 | * @param \TechDivision\Import\Observers\ObserverInterface $observer The observer to register |
||
| 565 | * @param string $type The type to register the observer with |
||
| 566 | * |
||
| 567 | * @return void |
||
| 568 | */ |
||
| 569 | 6 | public function registerObserver(ObserverInterface $observer, $type) |
|
| 581 | |||
| 582 | /** |
||
| 583 | * Register the passed callback with the specific type. |
||
| 584 | * |
||
| 585 | * @param \TechDivision\Import\Callbacks\CallbackInterface $callback The subject to register the callbacks for |
||
| 586 | * @param string $type The type to register the callback with |
||
| 587 | * |
||
| 588 | * @return void |
||
| 589 | */ |
||
| 590 | 2 | public function registerCallback(CallbackInterface $callback, $type) |
|
| 602 | |||
| 603 | /** |
||
| 604 | * Return's the array with callbacks for the passed type. |
||
| 605 | * |
||
| 606 | * @param string $type The type of the callbacks to return |
||
| 607 | * |
||
| 608 | * @return array The callbacks |
||
| 609 | */ |
||
| 610 | 1 | public function getCallbacksByType($type) |
|
| 624 | |||
| 625 | /** |
||
| 626 | * Return's the array with the available observers. |
||
| 627 | * |
||
| 628 | * @return array The observers |
||
| 629 | */ |
||
| 630 | 6 | public function getObservers() |
|
| 634 | |||
| 635 | /** |
||
| 636 | * Return's the array with the available callbacks. |
||
| 637 | * |
||
| 638 | * @return array The callbacks |
||
| 639 | */ |
||
| 640 | 1 | public function getCallbacks() |
|
| 644 | |||
| 645 | /** |
||
| 646 | * Return's the callback mappings for this subject. |
||
| 647 | * |
||
| 648 | * @return array The array with the subject's callback mappings |
||
| 649 | */ |
||
| 650 | 2 | public function getCallbackMappings() |
|
| 654 | |||
| 655 | /** |
||
| 656 | * Imports the content of the file with the passed filename. |
||
| 657 | * |
||
| 658 | * |
||
| 659 | * @param string $serial The serial of the actual import |
||
| 660 | * @param string $filename The filename to process |
||
| 661 | * |
||
| 662 | * @return void |
||
| 663 | * @throws \Exception Is thrown, if the import can't be processed |
||
| 664 | */ |
||
| 665 | 5 | public function import($serial, $filename) |
|
| 731 | |||
| 732 | /** |
||
| 733 | * This method queries whether or not the passed filename matches |
||
| 734 | * the pattern, based on the subjects configured prefix. |
||
| 735 | * |
||
| 736 | * @param string $filename The filename to match |
||
| 737 | * |
||
| 738 | * @return boolean TRUE if the filename matches, else FALSE |
||
| 739 | */ |
||
| 740 | 5 | protected function match($filename) |
|
| 753 | |||
| 754 | /** |
||
| 755 | * Imports the passed row into the database. If the import failed, the exception |
||
| 756 | * will be catched and logged, but the import process will be continued. |
||
| 757 | * |
||
| 758 | * @param array $row The row with the data to be imported |
||
| 759 | * |
||
| 760 | * @return void |
||
| 761 | */ |
||
| 762 | 7 | public function importRow(array $row) |
|
| 763 | { |
||
| 764 | |||
| 765 | // initialize the row |
||
| 766 | 7 | $this->row = $row; |
|
| 767 | |||
| 768 | // raise the line number and reset the skip row flag |
||
| 769 | 7 | $this->lineNumber++; |
|
| 770 | 7 | $this->skipRow = false; |
|
| 771 | |||
| 772 | // initialize the headers with the columns from the first line |
||
| 773 | 7 | if (sizeof($this->headers) === 0) { |
|
| 774 | 1 | foreach ($this->row as $value => $key) { |
|
| 775 | 1 | $this->headers[$this->mapAttributeCodeByHeaderMapping($key)] = $value; |
|
| 776 | } |
||
| 777 | 1 | return; |
|
| 778 | } |
||
| 779 | |||
| 780 | // process the observers |
||
| 781 | 6 | foreach ($this->getObservers() as $observers) { |
|
| 782 | // invoke the pre-import/import and post-import observers |
||
| 783 | 6 | foreach ($observers as $observer) { |
|
| 784 | // query whether or not we have to skip the row |
||
| 785 | 6 | if ($this->skipRow) { |
|
| 786 | 1 | break; |
|
| 787 | } |
||
| 788 | |||
| 789 | // if not, set the subject and process the observer |
||
| 790 | 6 | if ($observer instanceof ObserverInterface) { |
|
| 791 | 6 | $this->row = $observer->handle($this); |
|
| 792 | } |
||
| 793 | } |
||
| 794 | } |
||
| 795 | |||
| 796 | // log a debug message with the actual line nr/file information |
||
| 797 | 6 | $this->getSystemLogger()->debug( |
|
| 798 | sprintf( |
||
| 799 | 6 | 'Successfully processed operation %s on row %d in file %s', |
|
| 800 | 6 | $this->operationName, |
|
| 801 | 6 | $this->lineNumber, |
|
| 802 | 6 | $this->filename |
|
| 803 | ) |
||
| 804 | ); |
||
| 805 | 6 | } |
|
| 806 | |||
| 807 | /** |
||
| 808 | * Queries whether or not that the subject needs an OK file to be processed. |
||
| 809 | * |
||
| 810 | * @return boolean TRUE if the subject needs an OK file, else FALSE |
||
| 811 | */ |
||
| 812 | 1 | public function isOkFileNeeded() |
|
| 816 | |||
| 817 | /** |
||
| 818 | * Return's the default store. |
||
| 819 | * |
||
| 820 | * @return array The default store |
||
| 821 | */ |
||
| 822 | public function getDefaultStore() |
||
| 826 | |||
| 827 | /** |
||
| 828 | * Return's the default store view code. |
||
| 829 | * |
||
| 830 | * @return array The default store view code |
||
| 831 | */ |
||
| 832 | 5 | public function getDefaultStoreViewCode() |
|
| 836 | |||
| 837 | /** |
||
| 838 | * Set's the store view code the create the product/attributes for. |
||
| 839 | * |
||
| 840 | * @param string $storeViewCode The store view code |
||
| 841 | * |
||
| 842 | * @return void |
||
| 843 | */ |
||
| 844 | 4 | public function setStoreViewCode($storeViewCode) |
|
| 848 | |||
| 849 | /** |
||
| 850 | * Return's the store view code the create the product/attributes for. |
||
| 851 | * |
||
| 852 | * @param string|null $default The default value to return, if the store view code has not been set |
||
| 853 | * |
||
| 854 | * @return string The store view code |
||
| 855 | */ |
||
| 856 | 8 | public function getStoreViewCode($default = null) |
|
| 873 | |||
| 874 | /** |
||
| 875 | * Prepare's the store view code in the subject. If the store_view_code row doesn't contain |
||
| 876 | * any value, the default code of the default store view will be set. |
||
| 877 | * |
||
| 878 | * @return void |
||
| 879 | */ |
||
| 880 | 2 | public function prepareStoreViewCode() |
|
| 891 | |||
| 892 | /** |
||
| 893 | * Return's the store ID of the store with the passed store view code |
||
| 894 | * |
||
| 895 | * @param string $storeViewCode The store view code to return the store ID for |
||
| 896 | * |
||
| 897 | * @return integer The ID of the store with the passed ID |
||
| 898 | * @throws \Exception Is thrown, if the store with the actual code is not available |
||
| 899 | */ |
||
| 900 | 4 | public function getStoreId($storeViewCode) |
|
| 901 | { |
||
| 902 | |||
| 903 | // query whether or not, the requested store is available |
||
| 904 | 4 | if (isset($this->stores[$storeViewCode])) { |
|
| 905 | 3 | return (integer) $this->stores[$storeViewCode][MemberNames::STORE_ID]; |
|
| 906 | } |
||
| 907 | |||
| 908 | // throw an exception, if not |
||
| 909 | 1 | throw new \Exception( |
|
| 910 | sprintf( |
||
| 911 | 1 | 'Found invalid store view code %s in file %s on line %d', |
|
| 912 | $storeViewCode, |
||
| 913 | 1 | $this->getFilename(), |
|
| 914 | 1 | $this->getLineNumber() |
|
| 915 | ) |
||
| 916 | ); |
||
| 917 | } |
||
| 918 | |||
| 919 | /** |
||
| 920 | * Return's the store ID of the actual row, or of the default store |
||
| 921 | * if no store view code is set in the CSV file. |
||
| 922 | * |
||
| 923 | * @param string|null $default The default store view code to use, if no store view code is set in the CSV file |
||
| 924 | * |
||
| 925 | * @return integer The ID of the actual store |
||
| 926 | * @throws \Exception Is thrown, if the store with the actual code is not available |
||
| 927 | */ |
||
| 928 | 2 | public function getRowStoreId($default = null) |
|
| 939 | |||
| 940 | /** |
||
| 941 | * Return's the root category for the actual view store. |
||
| 942 | * |
||
| 943 | * @return array The store's root category |
||
| 944 | * @throws \Exception Is thrown if the root category for the passed store code is NOT available |
||
| 945 | */ |
||
| 946 | 2 | public function getRootCategory() |
|
| 960 | |||
| 961 | /** |
||
| 962 | * Return's the Magento configuration value. |
||
| 963 | * |
||
| 964 | * @param string $path The Magento path of the requested configuration value |
||
| 965 | * @param mixed $default The default value that has to be returned, if the requested configuration value is not set |
||
| 966 | * @param string $scope The scope the configuration value has been set |
||
| 967 | * @param integer $scopeId The scope ID the configuration value has been set |
||
| 968 | * |
||
| 969 | * @return mixed The configuration value |
||
| 970 | * @throws \Exception Is thrown, if nor a value can be found or a default value has been passed |
||
| 971 | */ |
||
| 972 | 5 | public function getCoreConfigData($path, $default = null, $scope = ScopeKeys::SCOPE_DEFAULT, $scopeId = 0) |
|
| 973 | { |
||
| 974 | |||
| 975 | // initialize the core config data |
||
| 976 | $coreConfigData = array( |
||
| 977 | 5 | MemberNames::PATH => $path, |
|
| 978 | 5 | MemberNames::SCOPE => $scope, |
|
| 979 | 5 | MemberNames::SCOPE_ID => $scopeId |
|
| 980 | ); |
||
| 981 | |||
| 982 | // generate the UID from the passed data |
||
| 983 | 5 | $uniqueIdentifier = $this->coreConfigDataUidGenerator->generate($coreConfigData); |
|
| 984 | |||
| 985 | // iterate over the core config data and try to find the requested configuration value |
||
| 986 | 5 | if (isset($this->coreConfigData[$uniqueIdentifier])) { |
|
| 987 | 1 | return $this->coreConfigData[$uniqueIdentifier][MemberNames::VALUE]; |
|
| 988 | } |
||
| 989 | |||
| 990 | // query whether or not we've to query for the configuration value on fallback level 'websites' also |
||
| 991 | 4 | if ($scope === ScopeKeys::SCOPE_STORES) { |
|
| 992 | // query whether or not the website with the passed ID is available |
||
| 993 | 2 | foreach ($this->storeWebsites as $storeWebsite) { |
|
| 994 | 2 | if ($storeWebsite[MemberNames::WEBSITE_ID] === $scopeId) { |
|
| 995 | // replace scope with 'websites' and website ID |
||
| 996 | 2 | $coreConfigData = array_merge( |
|
| 997 | $coreConfigData, |
||
| 998 | array( |
||
| 999 | 2 | MemberNames::SCOPE => ScopeKeys::SCOPE_WEBSITES, |
|
| 1000 | MemberNames::SCOPE_ID => $storeWebsite[MemberNames::WEBSITE_ID] |
||
| 1001 | ) |
||
| 1002 | ); |
||
| 1003 | |||
| 1004 | // generate the UID from the passed data, merged with the 'websites' scope and ID |
||
| 1005 | 2 | $uniqueIdentifier = $this->coreConfigDataUidGenerator->generate($coreConfigData); |
|
| 1006 | |||
| 1007 | // query whether or not, the configuration value on 'websites' level |
||
| 1008 | 2 | View Code Duplication | if (isset($this->coreConfigData[$uniqueIdentifier][MemberNames::VALUE])) { |
| 1009 | 2 | return $this->coreConfigData[$uniqueIdentifier][MemberNames::VALUE]; |
|
| 1010 | } |
||
| 1011 | } |
||
| 1012 | } |
||
| 1013 | } |
||
| 1014 | |||
| 1015 | // replace scope with 'default' and scope ID '0' |
||
| 1016 | 3 | $coreConfigData = array_merge( |
|
| 1017 | $coreConfigData, |
||
| 1018 | array( |
||
| 1019 | 3 | MemberNames::SCOPE => ScopeKeys::SCOPE_DEFAULT, |
|
| 1020 | MemberNames::SCOPE_ID => 0 |
||
| 1021 | ) |
||
| 1022 | ); |
||
| 1023 | |||
| 1024 | // generate the UID from the passed data, merged with the 'default' scope and ID 0 |
||
| 1025 | 3 | $uniqueIdentifier = $this->coreConfigDataUidGenerator->generate($coreConfigData); |
|
| 1026 | |||
| 1027 | // query whether or not, the configuration value on 'default' level |
||
| 1028 | 3 | View Code Duplication | if (isset($this->coreConfigData[$uniqueIdentifier][MemberNames::VALUE])) { |
| 1029 | 1 | return $this->coreConfigData[$uniqueIdentifier][MemberNames::VALUE]; |
|
| 1030 | } |
||
| 1031 | |||
| 1032 | // if not, return the passed default value |
||
| 1033 | 2 | if ($default !== null) { |
|
| 1034 | 1 | return $default; |
|
| 1035 | } |
||
| 1036 | |||
| 1037 | // throw an exception if no value can be found |
||
| 1038 | // in the Magento configuration |
||
| 1039 | 1 | throw new \Exception( |
|
| 1040 | sprintf( |
||
| 1041 | 1 | 'Can\'t find a value for configuration "%s-%s-%d" in "core_config_data"', |
|
| 1042 | $path, |
||
| 1043 | $scope, |
||
| 1044 | $scopeId |
||
| 1045 | ) |
||
| 1046 | ); |
||
| 1047 | } |
||
| 1048 | |||
| 1049 | /** |
||
| 1050 | * Resolve the original column name for the passed one. |
||
| 1051 | * |
||
| 1052 | * @param string $columnName The column name that has to be resolved |
||
| 1053 | * |
||
| 1054 | * @return string|null The original column name |
||
| 1055 | */ |
||
| 1056 | 2 | public function resolveOriginalColumnName($columnName) |
|
| 1078 | |||
| 1079 | /** |
||
| 1080 | * Return's the original data if available, or an empty array. |
||
| 1081 | * |
||
| 1082 | * @return array The original data |
||
| 1083 | */ |
||
| 1084 | 2 | public function getOriginalData() |
|
| 1099 | |||
| 1100 | /** |
||
| 1101 | * Query's whether or not the actual column contains original data like |
||
| 1102 | * filename, line number and column names. |
||
| 1103 | * |
||
| 1104 | * @return boolean TRUE if the actual column contains origin data, else FALSE |
||
| 1105 | */ |
||
| 1106 | 3 | public function hasOriginalData() |
|
| 1110 | |||
| 1111 | /** |
||
| 1112 | * Wraps the passed exeception into a new one by trying to resolve the original filname, |
||
| 1113 | * line number and column names and use it for a detailed exception message. |
||
| 1114 | * |
||
| 1115 | * @param array $columnNames The column names that should be resolved and wrapped |
||
| 1116 | * @param \Exception $parent The exception we want to wrap |
||
| 1117 | * @param string $className The class name of the exception type we want to wrap the parent one |
||
| 1118 | * |
||
| 1119 | * @return \Exception the wrapped exception |
||
| 1120 | */ |
||
| 1121 | 2 | public function wrapException( |
|
| 1166 | |||
| 1167 | /** |
||
| 1168 | * Strip's the exception suffix containing filename and line number from the |
||
| 1169 | * passed message. |
||
| 1170 | * |
||
| 1171 | * @param string $message The message to strip the exception suffix from |
||
| 1172 | * |
||
| 1173 | * @return mixed The message without the exception suffix |
||
| 1174 | */ |
||
| 1175 | 2 | public function stripExceptionSuffix($message) |
|
| 1179 | |||
| 1180 | /** |
||
| 1181 | * Append's the exception suffix containing filename and line number to the |
||
| 1182 | * passed message. If no message has been passed, only the suffix will be |
||
| 1183 | * returned |
||
| 1184 | * |
||
| 1185 | * @param string|null $message The message to append the exception suffix to |
||
| 1186 | * @param string|null $filename The filename used to create the suffix |
||
| 1187 | * @param string|null $lineNumber The line number used to create the suffx |
||
| 1188 | * |
||
| 1189 | * @return string The message with the appended exception suffix |
||
| 1190 | */ |
||
| 1191 | 7 | public function appendExceptionSuffix($message = null, $filename = null, $lineNumber = null) |
|
| 1212 | |||
| 1213 | /** |
||
| 1214 | * Raises the value for the counter with the passed key by one. |
||
| 1215 | * |
||
| 1216 | * @param mixed $counterName The name of the counter to raise |
||
| 1217 | * |
||
| 1218 | * @return integer The counter's new value |
||
| 1219 | */ |
||
| 1220 | 1 | public function raiseCounter($counterName) |
|
| 1229 | |||
| 1230 | /** |
||
| 1231 | * Merge the passed array into the status of the actual import. |
||
| 1232 | * |
||
| 1233 | * @param array $status The status information to be merged |
||
| 1234 | * |
||
| 1235 | * @return void |
||
| 1236 | */ |
||
| 1237 | 1 | public function mergeAttributesRecursive(array $status) |
|
| 1246 | } |
||
| 1247 |
Loading history...
Our type inference engine has found an assignment to a property that is incompatible with the declared type of that property.
Either this assignment is in error or the assigned type should be added to the documentation/type hint for that property..