Server : Apache System : Linux server2.corals.io 4.18.0-348.2.1.el8_5.x86_64 #1 SMP Mon Nov 15 09:17:08 EST 2021 x86_64 User : corals ( 1002) PHP Version : 7.4.33 Disable Function : exec,passthru,shell_exec,system Directory : /home/corals/cartforge.co/app/code/Magefan/Blog/Model/Import/ |
<?php
/**
* Copyright © Magefan ([email protected]). All rights reserved.
* Please visit Magefan.com for license details (https://magefan.com/end-user-license-agreement).
*
* Glory to Ukraine! Glory to the heroes!
*/
namespace Magefan\Blog\Model\Import;
use Magento\Framework\Config\ConfigOptionsListConstants;
/**
* Mirasvit import model
*/
class Mirasvit extends AbstractImport
{
protected $pref;
protected $entityTypeId = [];
protected $entityTypeAttributes = [];
public function execute()
{
$adapter = $this->getDbAdapter();
$_pref = $this->getPrefix();
$sql = 'SELECT * FROM ' . $_pref . 'mst_blog_post_entity LIMIT 1';
try {
$adapter->query($sql)->execute();
} catch (\Exception $e) {
throw new \Exception(__('Mirasvit Blog Extension not detected.'), 1);
}
$categories = [];
$oldCategories = [];
/* Import categories */
$sql = 'SELECT
t.entity_id as old_id,
t.position as position,
t.parent_id as parent_id
FROM ' . $_pref . 'mst_blog_category_entity t';
$result = $adapter->query($sql)->execute();
foreach ($result as $data) {
/* Prepare category data */
/* Get Stores */
$data['store_ids'] = [0];
$data['path'] = 0;
$map = [
//mirasvit_blog -> magefan_blog
'name' => 'title',
'meta_title' => 'meta_title',
'meta_keywords' => 'meta_keywords',
'meta_description' => 'meta_description',
'url_key' => 'identifier',
'content' => 'content',
'status' => 'is_active',
];
foreach ($map as $msField => $mfField) {
$data[$mfField] = $this->getAttributValue('blog_category', $data['old_id'], $msField);
}
$category = $this->_categoryFactory->create();
try {
/* Initial saving */
$category->setData($data)->save();
$this->_importedCategoriesCount++;
$categories[$category->getId()] = $category;
$oldCategories[$category->getOldId()] = $category;
} catch (\Magento\Framework\Exception\LocalizedException $e) {
unset($category);
$this->_skippedCategories[] = $data['title'];
$this->_logger->debug('Blog Category Import [' . $data['title'] . ']: '. $e->getMessage());
}
}
/* Reindexing parent categories */
foreach ($categories as $ct) {
if ($oldParentId = $ct->getData('parent_id')) {
if (isset($oldCategories[$oldParentId])) {
$ct->setPath(
$parentId = $oldCategories[$oldParentId]->getId()
);
}
}
}
for ($i = 0; $i < 4; $i++) {
$changed = false;
foreach ($categories as $ct) {
if ($ct->getPath()) {
$parentId = explode('/', $ct->getPath())[0];
$pt = $categories[$parentId];
if ($pt->getPath()) {
$ct->setPath($pt->getPath() . '/'. $ct->getPath());
$changed = true;
}
}
}
if (!$changed) {
break;
}
}
/* end*/
foreach ($categories as $ct) {
/* Final saving */
$ct->save();
}
/* Import tags */
$tags = [];
$oldTags = [];
$existingTags = [];
$sql = 'SELECT
t.tag_id as old_id,
t.name as title,
t.url_key as identifier,
1 as is_active
FROM ' . $_pref . 'mst_blog_tag t';
$result = $adapter->query($sql)->execute();
foreach ($result as $data) {
/* Prepare tag data */
/*
foreach (['title'] as $key) {
$data[$key] = mb_convert_encoding($data[$key], 'HTML-ENTITIES', 'UTF-8');
}
*/
if (!$data['title']) {
continue;
}
$data['title'] = trim($data['title']);
try {
/* Initial saving */
if (!isset($existingTags[$data['title']])) {
$tag = $this->_tagFactory->create();
$tag->setData($data)->save();
$this->_importedTagsCount++;
$tags[$tag->getId()] = $tag;
$oldTags[$tag->getOldId()] = $tag;
$existingTags[$tag->getTitle()] = $tag;
} else {
$tag = $existingTags[$data['title']];
$oldTags[$data['old_id']] = $tag;
}
} catch (\Magento\Framework\Exception\LocalizedException $e) {
$this->_skippedTags[] = $data['title'];
$this->_logger->debug('Blog Tag Import [' . $data['title'] . ']: '. $e->getMessage());
}
}
/* Import posts */
$sql = 'SELECT
t.entity_id as old_id,
t.author_id as author_id,
t.created_at as creation_time,
t.created_at as publish_time,
t.updated_at as update_time
FROM ' . $_pref . 'mst_blog_post_entity t WHERE type="post"';
$result = $adapter->query($sql)->execute();
foreach ($result as $data) {
$map = [
// mirasvit -> blog magefan_blog
//'featured_show_on_home' => '',
//'featured_show_on_home' => '',
'meta_description' => 'meta_description',
'meta_keywords' => 'meta_keywords',
'meta_title' => 'meta_title',
'featured_image' => 'featured_img',
'short_content' => 'short_content',
'content' => 'content',
'status' => 'is_active',
'url_key' => 'identifier',
'name' => 'title',
//'is_pinned' => '',
];
foreach ($map as $msField => $mfField) {
$data[$mfField] = $this->getAttributValue('blog_post', $data['old_id'], $msField);
}
if ($data['is_active'] == 2) {
$data['is_active'] = 1;
} else {
$data['is_active'] = 0;
}
if ($data['featured_img']) {
$data['featured_img'] = 'magefan_blog/' . $data['featured_img'];
}
/* Find post categories*/
$postCategories = [];
$c_sql = 'SELECT
category_id
FROM
' . $_pref . 'mst_blog_category_post
WHERE
post_id = "'.$data['old_id'].'"';
$c_result = $adapter->query($c_sql)->execute();
foreach ($c_result as $c_data) {
$oldId = $c_data['category_id'];
if (isset($oldCategories[$oldId])) {
$id = $oldCategories[$oldId]->getId();
$postCategories[$id] = $id;
}
}
$data['categories'] = $postCategories;
/* Find post tags*/
$postTags = [];
$t_sql = 'SELECT tag_id FROM ' . $_pref . 'mst_blog_tag_post WHERE post_id = "'.$data['old_id'].'"';
$t_result = $adapter->query($t_sql)->execute();
foreach ($t_result as $t_data) {
$oldId = $t_data['tag_id'];
if (isset($oldTags[$oldId])) {
$id = $oldTags[$oldId]->getId();
$postTags[$id] = $id;
}
}
$data['tags'] = $postTags;
/* Find post products*/
$data['links'] = [];
$postProducts = [];
$t_sql = 'SELECT product_id FROM ' . $_pref . 'mst_blog_post_product WHERE post_id = "'.$data['old_id'].'"';
$t_result = $adapter->query($t_sql)->execute();
foreach ($t_result as $t_data) {
$id = $t_data['product_id'];
$postProducts[$id] = $id;
}
if (count($postProducts)) {
$data['links']['product'] = $postProducts;
}
/* Find store ids */
$storeIds = [];
$sql2 = 'SELECT store_id FROM ' . $_pref . 'mst_blog_store_post WHERE post_id=' . $data['old_id'];
$result2 = $adapter->query($sql2)->execute();
foreach ($result2 as $data2) {
$storeIds[] = $data2['store_id'];
}
$data['store_ids'] = $storeIds;
$post = $this->_postFactory->create();
try {
/* Post saving */
$post->setData($data)->save();
$this->_importedPostsCount++;
} catch (\Magento\Framework\Exception\LocalizedException $e) {
$this->_skippedPosts[] = $data['title'];
$this->_logger->debug('Blog Post Import [' . $data['title'] . ']: '. $e->getMessage());
}
unset($post);
}
/* end */
$adapter->getDriver()->getConnection()->disconnect();
}
protected function getAttributValue($entitytTypeCode, $entitytId, $attributeCode)
{
$adapter = $this->getDbAdapter();
$_pref = $this->getPrefix();
if (!isset($this->entityTypeId[$entitytTypeCode])) {
$sql = 'SELECT
entity_type_id
FROM ' . $_pref . 'eav_entity_type WHERE entity_type_code="' . $entitytTypeCode . '"';
$result = $adapter->query($sql)->execute();
if (count($result)) {
foreach ($result as $data) {
$this->entityTypeId[$entitytTypeCode] = $data['entity_type_id'];
break;
}
} else {
$this->entityTypeId[$entitytTypeCode] = false;
}
}
$entityTypeId = $this->entityTypeId[$entitytTypeCode];
if (!$entityTypeId) {
return null;
}
if (!isset($this->entityTypeAttributes[$entitytTypeCode])) {
$this->entityTypeAttributes[$entitytTypeCode] = [];
$sql = 'SELECT
*
FROM ' . $_pref . 'eav_attribute WHERE entity_type_id=' . $entityTypeId;
$result = $adapter->query($sql)->execute();
foreach ($result as $data) {
$this->entityTypeAttributes[$entitytTypeCode][$data['attribute_code']] = $data;
}
}
if (empty($this->entityTypeAttributes[$entitytTypeCode][$attributeCode])) {
return null;
}
$attribute = $this->entityTypeAttributes[$entitytTypeCode][$attributeCode];
$sql = 'SELECT
value
FROM ' . $_pref . 'mst_'.$entitytTypeCode.'_entity_' . $attribute['backend_type'] . ' WHERE store_id = 0
AND attribute_id = ' . $attribute['attribute_id'] . '
AND entity_id=' . $entitytId;
$result = $adapter->query($sql)->execute();
if (count($result)) {
foreach ($result as $data) {
return $data['value'];
}
}
return null;
}
}