In this article, we will take a look at developing the integration of Magento 2 with any external ERP system. Magento 2.2.4 compatible syntax will be used to show the examples of code. The protocol of the interaction with ERP will be REST \/ JSON API, a two-way data exchange.<\/p>\n
<\/p>\n
Before starting to work on the integration, it is necessary to determine the functionality and set requirements for the system.<\/p>\n
Let us define what we need:<\/p>\n
In the context of this article, we omit the explanations to the components that are not directly related to the topic at hand.<\/p>\n
Let’s start implementing the integration of Magento 2 with ERP. The first step is to create a new module. To do this, create the following directory structure:<\/p>\n
app\/code\/BelVG\/ERPIntegration\/<\/em><\/p>\n app\/code\/BelVG\/ERPIntegration\/etc<\/em><\/p>\n app\/code\/BelVG\/ERPIntegration\/Setup<\/em><\/p>\n app\/code\/BelVG\/ERPIntegration\/Helper<\/em><\/p>\n app\/code\/BelVG\/ERPIntegration\/Controller<\/em><\/p>\n app\/code\/BelVG\/ERPIntegration\/Observer<\/em><\/p>\n Create an app\/code\/BelVG\/ERPIntegration\/registration.ph<\/em>p file:<\/p>\n Create an app\/code\/BelVG\/ERPIntegration\/etc\/module.xml<\/em> file:<\/p>\n Implement the installer of the module. It must add new attributes to entities, such as category, product, customer, order, and others that are exchanged. This attribute must be unique, as it will play the role of a common identifier for the site and ERP. We make it a string type, so as not to depend on the implementation of ERP.<\/p>\n Create an app\/code\/BelVG\/ERPIntegration\/Setup\/InstallData.php<\/em> file (here is an example of creating an attribute for a product).<\/p>\n We implement the component responsible for exchanging data with ERP. It should have a closed logic of sending requests to simplify working with the code. In the example below, we will use the CURL component for REST requests to the ERP API.<\/p>\n To do this, create an app\/code\/BelVG\/ERPIntegration\/Helper\/Requester.php<\/em> file:<\/p>\n In order to send to ERP the data that has been created or changed on the site, you must set the capture of the save events on the entities that the Site ➜ ERP<\/strong> exchange is carried out.<\/p>\n To implement this functionality, create an observer for the product_save_after<\/strong> event.<\/p>\n Create an app\/code\/BelVG\/ERPIntegration\/Observers\/ProductSaveAfterObserver.php<\/em> file. It also has logging implemented in it.<\/p>\n Also, create an app\/code\/BelVG\/ERPIntegration\/etc\/events.xml<\/em> file, where we assign this observer to the desired event.<\/p>\n To implement a relevance check and a scheduled data exchange, you can use CRON similarly to the method of event handling.<\/p>\n You can also implement external API integrations for direct calls from ERP if the data has been changed on the ERP side and requires immediate synchronization. The API of both the ERP and the Magento 2 module should be closed by authorization, or in some other way (for example, by an IP filter). When completed, the module should be installed. To do this, execute the following commands in the Magento console (from the Magento root directory):<\/p>\n php bin\/magento setup:upgrade<\/em> That is how you integrate Magento with ERP systems. Thank you for reading, hope everything was clear. Leave your comments and questions below and I will answer them ASAP.<\/p>\n","protected":false},"excerpt":{"rendered":"How to integrate Magento 2 with external ERP systems","protected":false},"author":58,"featured_media":16828,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"image","meta":{"_acf_changed":false,"footnotes":""},"categories":[491,389,535,524],"tags":[],"class_list":["post-16827","post","type-post","status-publish","format-image","has-post-thumbnail","hentry","category-magento-2","category-magento2-development","category-magento-erp-integration","category-magento-speed-optimization","post_format-image"],"acf":[],"aioseo_notices":[],"aioseo_head":"\n\t\t\n\t\n\t\n\t\n\t\n\t\t\n\t\t<?php\r\n\\Magento\\Framework\\Component\\ComponentRegistrar::register(\r\n \\Magento\\Framework\\Component\\ComponentRegistrar::MODULE,\r\n 'BelVG_ERPIntegration',\r\n __DIR__\r\n);<\/pre>\n
<?xml version=\"1.0\"?>\r\n<config xmlns:xsi=\"http:\/\/www.w3.org\/2001\/XMLSchema-instance\" xsi:noNamespaceSchemaLocation=\"urn:magento:framework:Module\/etc\/module.xsd\">\r\n <module name=\"BelVG_ERPIntegration\" setup_version=\"1.0.0\" \/>\r\n<\/config><\/pre>\n
<?php\r\nnamespace BelVG\\ERPIntegration\\Setup;\r\nuse Magento\\Catalog\\Api\\Data\\ProductAttributeInterface;\r\nuse Magento\\Framework\\Setup\\InstallDataInterface;\r\nuse Magento\\Framework\\Setup\\ModuleContextInterface;\r\nuse Magento\\Framework\\Setup\\ModuleDataSetupInterface;\r\nuse Magento\\Eav\\Setup\\EavSetupFactory;\r\nclass InstallData implements InstallDataInterface\r\n{\r\n private $eavSetupFactory;\r\n public function __construct(EavSetupFactory $eavSetupFactory)\r\n {\r\n $this->eavSetupFactory = $eavSetupFactory;\r\n }\r\n public function install(ModuleDataSetupInterface $setup, ModuleContextInterface $context)\r\n {\r\n $eavSetup = $this->eavSetupFactory->create(['setup' => $setup]); $eavSetup->removeAttribute(ProductAttributeInterface::ENTITY_TYPE_CODE,'product_erp_id');\r\n$eavSetup->addAttribute( ProductAttributeInterface::ENTITY_TYPE_CODE, 'product_erp_id', [\r\n 'type' => 'varchar',\r\n 'frontend' => '',\r\n 'label' => 'Product ERP ID',\r\n 'input' => 'multiselect',\r\n 'class' => '',\r\n 'global' => \\Magento\\Eav\\Model\\Entity\\Attribute\\ScopedAttributeInterface::SCOPE_GLOBAL,\r\n 'visible' => 1,\r\n 'required' => false,\r\n 'user_defined' => 1,\r\n 'default' => '',\r\n 'searchable' => true,\r\n 'filterable' => true,\r\n 'comparable' => false,\r\n 'visible_on_front' => false,\r\n 'used_in_product_listing' => false,\r\n 'unique' => true\r\n ]);\r\n }\r\n}\r\n<\/pre>\n<?php\r\nnamespace BelVG\\ERPIntegration\\Helper;\r\nuse \\Magento\\Framework\\App\\Helper\\AbstractHelper;\r\nuse \\Magento\\Framework\\App\\Helper\\Context;\r\nuse Magento\\Framework\\Exception\\LocalizedException;\r\nclass Requester extends AbstractHelper\r\n{\r\n protected $curl;\r\n const ERP_API_BASE_URL = 'https:\/\/127.0.0.1\/erp\/api\/';\r\n public function __construct(\r\n Context $context,\r\n \\Magento\\Framework\\HTTP\\Client\\Curl $curl\r\n ) {\r\n $this->curl = $curl;\r\n parent::__construct($context);\r\n }\r\n public function createProduct(array $product)\r\n {\r\n $url = self::ERP_API_BASE_URL . 'product\/create';\r\n $this->curl->post($url, $product);\r\n if ($this->curl->getStatus() !== 200) {\r\n throw new LocalizedException(__('ERP query fail!'));\r\n }\r\n $response = json_decode($this->curl->getBody(), true);\r\n if ($response['success']) {\r\n return $response['product_erp_id']; \r\n } else {\r\n throw new LocalizedException(__($response['error_message']));\r\n }\r\n }\r\n public function updateProduct(array $product)\r\n {\r\n $url = self::ERP_API_BASE_URL . 'product\/create';\r\n if (!$product['product_erp_id']) {\r\n throw new LocalizedException(__('Invalid product ERP ID!'));\r\n }\r\n $this->curl->post($url, $product);\r\n if ($this->curl->getStatus() !== 200) {\r\n throw new LocalizedException(__('ERP query fail!'));\r\n }\r\n $response = json_decode($this->curl->getBody(), true);\r\n if ($response['success']) {\r\n return $response['product_erp_id'];\r\n } else {\r\n throw new LocalizedException(__($response['error_message']));\r\n }\r\n }\r\n}<\/pre>\n<?php\r\nnamespace BelVG\\ERPIntegration\\Observer;\r\nuse Magento\\Catalog\\Model\\Product;\r\nuse Magento\\Framework\\Event\\ObserverInterface;\r\nuse Magento\\Framework\\Exception\\LocalizedException;\r\nuse Magento\\Catalog\\Model\\ProductRepository;\r\nclass ProductSaveAfterObserver implements ObserverInterface\r\n{\r\n protected $requester;\r\n protected $productRepository;\r\n protected $logger;\r\n public function __construct(\r\n \\BelVG\\ERPIntegration\\Helper\\Requester $requester,\r\n ProductRepository $productRepository,\r\n \\Psr\\Log\\LoggerInterface $logger\r\n ) {\r\n $this->requester = $requester;\r\n $this->productRepository = $productRepository;\r\n $this->logger = $logger;\r\n }\r\n public function execute(\\Magento\\Framework\\Event\\Observer $observer)\r\n {\r\n $product = $observer['product'];\r\n if (!$this->isProductChanged($product) && $product->getData('product_erp_id')) {\r\n return;\r\n }\r\n try {\r\n if ($product->getData('product_erp_id')) {\r\n $erpId = $this->requester->updateProduct([\r\n 'name' => $product->getName(),\r\n 'category_erp_id' => $product->getData('category_erp_id'),\r\n ]);\r\n } else {\r\n $erpId = $this->requester->createProduct([\r\n 'name' => $product->getName(),\r\n 'category_erp_id' => $product->getData('category_erp_id'),\r\n ]);\r\n }\r\n } catch (LocalizedException $e) {\r\n $this->logger->alert($e->getMessage());\r\n return;\r\n }\r\n $product->setData('category_erp_id'. $erpId);\r\n $this->productRepository->save($product);\r\n $this->logger->info('Product ' . $erpId . ' has been synchronized');\r\n }\r\n private function isProductChanged(Product $product)\r\n {\r\n return $product->getOrigData('name') != $product->getName();\r\n }\r\n}<\/pre>\n<?xml version=\"1.0\"?>\r\n<config xmlns:xsi=\"http:\/\/www.w3.org\/2001\/XMLSchema-instance\"\r\n xsi:noNamespaceSchemaLocation=\"urn:magento:framework:Event\/etc\/events.xsd\">\r\n <event name=\"product_save_after\">\r\n <observer name=\"setcustomerupdatedat\" instance=\"Belvg\\ERPIntegration\\Observer\\ProductSaveAfterObserver\"\/>\r\n <\/event>\r\n<\/config><\/pre>\n
\nIt remains to implement the error notifications. Let us enable email notifications. This component is an example, it can be used in a catch block along with logging:<\/p>\n<?php\r\nnamespace BelVG\\ERPIntegration\\Helper;\r\nuse \\Magento\\Framework\\App\\Helper\\AbstractHelper;\r\nuse Magento\\Framework\\Mail\\Template\\TransportBuilder;\r\nclass Notify extends AbstractHelper\r\n{\r\n \/** @var TransportBuilder $transportBuilder *\/\r\n private $transportBuilder;\r\n public function __construct(\r\n \\Magento\\Framework\\App\\Helper\\Context $context,\r\n TransportBuilder $transportBuilder\r\n )\r\n {\r\n $this->transportBuilder = $transportBuilder;\r\n parent::__construct($context);\r\n }\r\n public function reportingError($process, $message\r\n {\r\n try {\r\n $subject = 'ERP synchronize error';\r\n $this->sendEmail($subject, $process, $message);\r\n } catch (\\Exception $e) {}\r\n }\r\n private function sendEmail($subject, $process, $message)\r\n {\r\n $transport = $this->transportBuilder\r\n ->setTemplateIdentifier('erp_integration_error_notify_template')\r\n ->setTemplateOptions(\r\n ['area' => 'frontend', 'store' => \\Magento\\Store\\Model\\Store::DEFAULT_STORE_ID]\r\n )\r\n ->setTemplateVars([\r\n 'process' => $process,\r\n 'message' => $message,\r\n ])\r\n ->setFrom('general')\r\n ->addTo('erp-manager@example.com', 'Erp Manager')\r\n ->getTransport();\r\n $transport->sendMessage();\r\n }\r\n}<\/pre>\n
\nphp bin\/magento setup:di:compile<\/em><\/p>\n