mirror of
https://github.com/bdnugget/module-integration.git
synced 2026-11-07 08:17:27 +00:00
321329611b
* Abandoned carts fixed not updating in AC when cart is edited * Cron with delete capability 7 days previous entries * add logger in catch update event in events.xml checkout_onepage_controller_success_action for checkout_submit_all_after update Data.php type update OrderSync.php add doc and types update doc AbandonedCartSync.php update AbandonedCartSendData.php update AbandonedCartSendData.php add create customer in AC update PaymentInformationManagementPlugin.php delete black line update OrderSyncCron.php, update filter and add Logger in Exception rollback name events.xml update Curl.php add types delete logger debug in the code * DS Store removed Co-authored-by: YAIR GARCIA <yagator@MacBook-Air-de-YAIR.local> Co-authored-by: Yair García Torres <yagator@gmail.com>
93 lines
2.8 KiB
PHP
93 lines
2.8 KiB
PHP
<?php
|
|
|
|
namespace ActiveCampaign\Customer\Observer;
|
|
|
|
use ActiveCampaign\Core\Helper\Curl;
|
|
use ActiveCampaign\Customer\Model\Config\CronConfig;
|
|
use ActiveCampaign\Customer\Model\Customer;
|
|
use Magento\Framework\Event\Observer;
|
|
use Magento\Framework\Event\ObserverInterface;
|
|
use Psr\Log\LoggerInterface;
|
|
|
|
class CustomerSaveAfter implements ObserverInterface
|
|
{
|
|
const CONTACT_ENDPOINT = "contact/sync";
|
|
|
|
const METHOD = "POST";
|
|
|
|
const ECOM_CUSTOMER_ENDPOINT = "ecomCustomers";
|
|
|
|
/**
|
|
* @var Customer
|
|
*/
|
|
private $customer;
|
|
|
|
/**
|
|
* @var Curl
|
|
*/
|
|
protected $curl;
|
|
|
|
/**
|
|
* CustomerSaveAfter constructor.
|
|
* @param Customer $customer
|
|
* @param Curl $curl
|
|
* @param LoggerInterface $logger
|
|
*/
|
|
public function __construct(
|
|
Customer $customer,
|
|
Curl $curl,
|
|
LoggerInterface $logger
|
|
) {
|
|
$this->customer = $customer;
|
|
$this->curl = $curl;
|
|
$this->logger = $logger;
|
|
}
|
|
|
|
/**
|
|
* Upgrade order customer email when customer has changed email
|
|
*
|
|
* @param Observer $observer
|
|
* @return void
|
|
*/
|
|
public function execute(Observer $observer): void
|
|
{
|
|
/** @var Customer $originalCustomer */
|
|
$originalCustomer = $observer->getEvent()->getOrigCustomerDataObject();
|
|
if (!$originalCustomer) {
|
|
return;
|
|
}
|
|
|
|
/** @var Customer $customer */
|
|
$customer = $observer->getEvent()->getCustomerDataObject();
|
|
|
|
$contactId = 0;
|
|
$ecomCustomerId = 0;
|
|
$syncStatus = CronConfig::NOT_SYNCED;
|
|
$customerId = $customer->getId();
|
|
|
|
try {
|
|
$contactData = $this->customer->getContactData($customerId);
|
|
$isEcomCustomer = $contactData['contact']['isEcomCustomer'];
|
|
|
|
unset($contactData['contact']['isEcomCustomer']);
|
|
|
|
$contactResult = $this->curl->createContacts(self::METHOD, self::CONTACT_ENDPOINT, $contactData);
|
|
$contactId = isset($contactResult['data']['contact']['id']) ? $contactResult['data']['contact']['id'] : null;
|
|
$syncStatus = ($contactResult['success']) ? CronConfig::SYNCED : CronConfig::FAIL_SYNCED;
|
|
|
|
if ($contactResult['success'] && !$isEcomCustomer) {
|
|
$ecomCustomerData = $this->customer->getEcomCustomerData($customerId);
|
|
$ecomCustomerResult = $this->curl->createContacts(
|
|
self::METHOD,
|
|
self::ECOM_CUSTOMER_ENDPOINT,
|
|
$ecomCustomerData
|
|
);
|
|
$ecomCustomerId = isset($ecomCustomerResult['data']['ecomCustomer']['id']) ? $ecomCustomerResult['data']['ecomCustomer']['id'] : null;
|
|
}
|
|
$this->customer->saveResult($customerId, $syncStatus, $contactId, $ecomCustomerId);
|
|
} catch (\Exception $e) {
|
|
$this->logger->critical("MODULE: Customer " . $e);
|
|
}
|
|
}
|
|
}
|