1 | <?php |
||
44 | class UrlKeyAndPathObserver extends AbstractCategoryImportObserver |
||
45 | { |
||
46 | |||
47 | /** |
||
48 | * The trait that provides string => URL key conversion functionality. |
||
49 | * |
||
50 | * @var \TechDivision\Import\Utils\Filter\UrlKeyFilterTrait |
||
51 | */ |
||
52 | use UrlKeyFilterTrait; |
||
53 | |||
54 | /** |
||
55 | * The URL key utility instance. |
||
56 | * |
||
57 | * @var \TechDivision\Import\Utils\UrlKeyUtilInterface |
||
58 | */ |
||
59 | protected $urlKeyUtil; |
||
60 | |||
61 | /** |
||
62 | * The category bunch processor instance. |
||
63 | * |
||
64 | * @var \TechDivision\Import\Category\Services\CategoryBunchProcessorInterface |
||
65 | */ |
||
66 | protected $categoryBunchProcessor; |
||
67 | |||
68 | /** |
||
69 | * The reverse sequence generator instance. |
||
70 | * |
||
71 | * @var \TechDivision\Import\Utils\Generators\GeneratorInterface |
||
72 | */ |
||
73 | protected $reverseSequenceGenerator; |
||
74 | |||
75 | /** |
||
76 | * Initialize the observer with the passed product bunch processor instance. |
||
77 | * |
||
78 | * @param \TechDivision\Import\Category\Services\CategoryBunchProcessorInterface $categoryBunchProcessor The category bunch processor instance |
||
79 | * @param \Zend\Filter\FilterInterface $convertLiteralUrlFilter The URL filter instance |
||
80 | * @param \TechDivision\Import\Utils\UrlKeyUtilInterface $urlKeyUtil The URL key utility instance |
||
81 | * @param \TechDivision\Import\Utils\Generators\GeneratorInterface $reverseSequenceGenerator The reverse sequence generator instance |
||
82 | */ |
||
83 | public function __construct( |
||
96 | |||
97 | /** |
||
98 | * Process the observer's business logic. |
||
99 | * |
||
100 | * @return void |
||
101 | */ |
||
102 | protected function process() |
||
103 | { |
||
104 | |||
105 | // initialize the URL key, the entity and the category |
||
106 | $urlKey = null; |
||
107 | $entity = null; |
||
108 | $category = array(); |
||
109 | |||
110 | // prepare the store view code |
||
111 | $this->prepareStoreViewCode(); |
||
112 | |||
113 | // set the entity ID for the category with the passed path |
||
114 | try { |
||
115 | $entity = $this->getCategoryByPath($path = $this->getValue(ColumnKeys::PATH)); |
||
116 | $this->setIds($category = $entity); |
||
117 | } catch (\Exception $e) { |
||
118 | $this->setIds(array()); |
||
119 | $category[MemberNames::ENTITY_ID] = $this->getReverseSequenceGenerator()->generate(); |
||
|
|||
120 | } |
||
121 | |||
122 | // query whether or not the URL key column has a value |
||
123 | if ($this->hasValue(ColumnKeys::URL_KEY)) { |
||
124 | $urlKey = $this->getValue(ColumnKeys::URL_KEY); |
||
125 | } else { |
||
126 | // query whether or not the existing category `url_key` should be re-created from the category name |
||
127 | if (is_array($entity) && !$this->getSubject()->getConfiguration()->getParam(ConfigurationKeys::UPDATE_URL_KEY_FROM_NAME, true)) { |
||
128 | // if the category already exists and NO re-creation from the category name has to |
||
129 | // be done, load the original `url_key`from the category and use that to proceed |
||
130 | $urlKey = $this->loadUrlKey($this->getSubject(), $this->getPrimaryKey()); |
||
131 | } |
||
132 | |||
133 | // try to load the value from column `name` if URL key is still |
||
134 | // empty, because we need it to process the the rewrites later on |
||
135 | if ($urlKey === null || $urlKey === '' && $this->hasValue(ColumnKeys::NAME)) { |
||
136 | $urlKey = $this->convertNameToUrlKey($this->getValue(ColumnKeys::NAME)); |
||
137 | } |
||
138 | } |
||
139 | |||
140 | // stop processing, if no URL key is available |
||
141 | if ($urlKey === null || $urlKey === '') { |
||
142 | // throw an exception, that the URL key can not be |
||
143 | // initialized and we're in the default store view |
||
144 | if ($this->getStoreViewCode(StoreViewCodes::ADMIN) === StoreViewCodes::ADMIN) { |
||
145 | throw new \Exception(sprintf('Can\'t initialize the URL key for category "%s" because columns "url_key" or "name" have a value set for default store view', $path)); |
||
146 | } |
||
147 | // stop processing, because we're in a store |
||
148 | // view row and a URL key is not mandatory |
||
149 | return; |
||
150 | } |
||
151 | |||
152 | // load ID of the actual store view |
||
153 | $storeId = $this->getRowStoreId(StoreViewCodes::ADMIN); |
||
154 | |||
155 | // explode the path into the category names |
||
156 | if ($categories = $this->explode($this->getValue(ColumnKeys::PATH), '/')) { |
||
157 | // initialize the array for the category paths |
||
158 | $categoryPaths = array(); |
||
159 | // iterate over the parent category names and try |
||
160 | // to load the categories to build the URL path |
||
161 | for ($i = sizeof($categories) - 1; $i > 1; $i--) { |
||
162 | try { |
||
163 | // prepare the expected category name |
||
164 | $categoryPath = implode('/', array_slice($categories, 0, $i)); |
||
165 | // load the existing category and prepend the URL key the array with the category URL keys |
||
166 | $existingCategory = $this->getCategoryByPkAndStoreId($this->mapPath($categoryPath), $storeId); |
||
167 | // query whether or not an URL key is available or not |
||
168 | if (isset($existingCategory[MemberNames::URL_KEY])) { |
||
169 | array_unshift($categoryPaths, $existingCategory[MemberNames::URL_KEY]); |
||
170 | } else { |
||
171 | $this->getSystemLogger()->debug(sprintf('Can\'t find URL key for category "%s"', $categoryPath)); |
||
172 | } |
||
173 | } catch (\Exception $e) { |
||
174 | $this->getSystemLogger()->debug(sprintf('Can\'t load parent category "%s"', $categoryPath)); |
||
175 | } |
||
176 | } |
||
177 | } |
||
178 | |||
179 | // update the URL key with the unique value |
||
180 | $this->setValue( |
||
181 | ColumnKeys::URL_KEY, |
||
182 | $urlKey = $this->makeUnique($this->getSubject(), $category, $urlKey, sizeof($categoryPaths) > 0 ? array(implode('/', $categoryPaths)) : array()) |
||
183 | ); |
||
184 | |||
185 | // finally, append the URL key as last element to the path |
||
186 | array_push($categoryPaths, $urlKey); |
||
187 | |||
188 | // create the virtual column for the URL path |
||
189 | if ($this->hasHeader(ColumnKeys::URL_PATH) === false) { |
||
190 | $this->addHeader(ColumnKeys::URL_PATH); |
||
191 | } |
||
192 | |||
193 | // set the URL path |
||
194 | $this->setValue(ColumnKeys::URL_PATH, implode('/', $categoryPaths)); |
||
195 | } |
||
196 | |||
197 | /** |
||
198 | * Return the primary key member name. |
||
199 | * |
||
200 | * @return string The primary key member name |
||
201 | */ |
||
202 | protected function getPkMemberName() |
||
206 | |||
207 | /** |
||
208 | * Returns the category bunch processor instance. |
||
209 | * |
||
210 | * @return \TechDivision\Import\Category\Services\CategoryBunchProcessorInterface The category bunch processor instance |
||
211 | */ |
||
212 | protected function getCategoryBunchProcessor() |
||
216 | |||
217 | /** |
||
218 | * Returns the URL key utility instance. |
||
219 | * |
||
220 | * @return \TechDivision\Import\Utils\UrlKeyUtilInterface The URL key utility instance |
||
221 | */ |
||
222 | protected function getUrlKeyUtil() |
||
226 | |||
227 | /** |
||
228 | * Returns the reverse sequence generator instance. |
||
229 | * |
||
230 | * @return \TechDivision\Import\Utils\Generators\GeneratorInterface The reverse sequence generator |
||
231 | */ |
||
232 | protected function getReverseSequenceGenerator() : GeneratorInterface |
||
236 | |||
237 | /** |
||
238 | * Return's the category with the passed path. |
||
239 | * |
||
240 | * @param string $path The path of the category to return |
||
241 | * |
||
242 | * @return array The category |
||
243 | * @throws \Exception Is thrown, if the requested category is not available |
||
244 | */ |
||
245 | protected function getCategoryByPath($path) |
||
249 | |||
250 | /** |
||
251 | * Returns the category with the passed primary key and the attribute values for the passed store ID. |
||
252 | * |
||
253 | * @param string $pk The primary key of the category to return |
||
254 | * @param integer $storeId The store ID of the category values |
||
255 | * |
||
256 | * @return array|null The category data |
||
257 | */ |
||
258 | protected function getCategoryByPkAndStoreId($pk, $storeId) |
||
262 | |||
263 | /** |
||
264 | * Temporarily persist's the IDs of the passed category. |
||
265 | * |
||
266 | * @param array $category The category to temporarily persist the IDs for |
||
267 | * |
||
268 | * @return void |
||
269 | */ |
||
270 | protected function setIds(array $category) |
||
274 | |||
275 | /** |
||
276 | * Set's the ID of the category that has been created recently. |
||
277 | * |
||
278 | * @param string $lastEntityId The entity ID |
||
279 | * |
||
280 | * @return void |
||
281 | */ |
||
282 | protected function setLastEntityId($lastEntityId) |
||
286 | |||
287 | /** |
||
288 | * Return's the PK to of the product. |
||
289 | * |
||
290 | * @return integer The PK to create the relation with |
||
291 | */ |
||
292 | protected function getPrimaryKey() |
||
296 | |||
297 | /** |
||
298 | * Load's and return's the url_key with the passed primary ID. |
||
299 | * |
||
300 | * @param \TechDivision\Import\Subjects\UrlKeyAwareSubjectInterface $subject The subject to load the URL key |
||
301 | * @param int $primaryKeyId The ID from category |
||
302 | * |
||
303 | * @return string|null url_key or null |
||
304 | */ |
||
305 | protected function loadUrlKey(UrlKeyAwareSubjectInterface $subject, $primaryKeyId) |
||
309 | |||
310 | /** |
||
311 | * Make's the passed URL key unique by adding the next number to the end. |
||
312 | * |
||
313 | * @param \TechDivision\Import\Subjects\UrlKeyAwareSubjectInterface $subject The subject to make the URL key unique for |
||
314 | * @param array $entity The entity to make the URL key unique for |
||
315 | * @param string $urlKey The URL key to make unique |
||
316 | * @param array $urlPaths The URL paths to make unique |
||
317 | * |
||
318 | * @return string The unique URL key |
||
319 | */ |
||
320 | protected function makeUnique(UrlKeyAwareSubjectInterface $subject, array $entity, string $urlKey, array $urlPaths = array()) |
||
324 | } |
||
325 |
This check looks for function calls that miss required arguments.