Merge pull request #81 from jorgeeurekalabs/main

DEVREL-52 DEVREL-40

Author: jorgeeurekalabs

AbandonedCart/Helper/Data.php

@@ -10,7 +10,7 @@ class Data extends AbstractHelper
 {
     const ACTIVE_CAMPAIGN_ABANDONED_CART_SYNC = "active_campaign/abandoned_cart/sync";
     const ABANDONED_CART_NUMBER_OF_ABANDONED_CART = "active_campaign/abandoned_cart/number_of_abandoned_cart";
-
+    const ABANDONED_CART_MIN_INACTIVE_TIME = "active_campaign/abandoned_cart/min_inactive_time";
     /**
      * @param null $scopeCode
      * @return bool
@@ -49,4 +49,18 @@ public function getNumberOfAbandonedCart($scopeCode = null)
             $scopeCode
         );
     }
+
+    /**
+     * @param null $scopeCode
+     * @return mixed
+     */
+    public function getMinInactiveTime($scopeCode = null)
+    {
+        return $this->scopeConfig->getValue(
+            self::ABANDONED_CART_MIN_INACTIVE_TIME,
+            ScopeInterface::SCOPE_STORES,
+            $scopeCode
+        );
+    }
+
 }

AbandonedCart/Model/AbandonedCartSendData.php

@@ -222,12 +222,16 @@ public function sendAbandonedCartData($quoteId = null): array
     {
         $result = [];
         $numberOfAbandonedCart = (int)$this->abandonedCartHelper->getNumberOfAbandonedCart();
+        $minInactiveTime = (int) $this->abandonedCartHelper->getMinInactiveTime();
         $abandonedCarts = $this->quoteResourceCollectionFactory->create()
             ->addFieldToSelect('*')
             ->addFieldToFilter('ac_synced_date', [
                 ['lt' => new \Zend_Db_Expr('main_table.updated_at')],
-                ['null' => true]
+                ['null' =>  true]
             ])
+            ->addFieldToFilter('main_table.updated_at',
+                ['eq' => new \Zend_Db_Expr('IF( ac_synced_date is not null or main_table.updated_at < DATE_SUB(NOW(), INTERVAL '.$minInactiveTime.' minute), main_table.updated_at,-1)')]
+            )
             ->addFieldToFilter(
                 'is_active',
                 '1'

AbandonedCart/composer.json

@@ -9,7 +9,7 @@
     "config": {
         "sort-packages": true
     },
-    "version": "2.1.9",
+    "version": "2.1.10",
     "require": {
         "php": "~7.3.0||~7.4.0||~8.0||~8.1||~8.2",
         "activecampaign/core": "2.1.*"

AbandonedCart/etc/adminhtml/system.xml

@@ -52,13 +52,19 @@
                         <field id="sync">1</field>
                     </depends>
                 </field>
-                <field id="ac_abandoned_cart_syncing" translate="label comment" type="button" sortOrder="40" showInDefault="1">
+                <field id="min_inactive_time" translate="label comment" type="text" sortOrder="40" showInDefault="1">
+                    <label>Minimum inactivity time</label>
+                    <comment><![CDATA[Minimum inactivity time in minutes]]></comment>
+                </field>
+                <field id="ac_abandoned_cart_syncing" translate="label comment" type="button" sortOrder="50" showInDefault="1">
                     <frontend_model>ActiveCampaign\AbandonedCart\Block\System\Config\SyncAbandonedCartData</frontend_model>
                     <label>Sync Abandoned Cart Data</label>
                     <depends>
                         <field id="active_campaign/abandoned_cart/sync">1</field>
                     </depends>
                 </field>
+
+
             </group>
         </section>
     </system>

AbandonedCart/etc/config.xml

@@ -11,6 +11,7 @@
                 <cron_day>*</cron_day>
                 <cron_month>*</cron_month>
                 <cron_weekday>*</cron_weekday>
+                <min_inactive_time>60</min_inactive_time>
             </abandoned_cart>
         </active_campaign>
     </default>

AbandonedCart/etc/module.xml

@@ -6,7 +6,7 @@
  */
 -->
 <config xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:noNamespaceSchemaLocation="urn:magento:framework:Module/etc/module.xsd">
-    <module name="ActiveCampaign_AbandonedCart" setup_version="2.1.9">
+    <module name="ActiveCampaign_AbandonedCart" setup_version="2.1.10">
         <sequence>
             <module name="Magento_Product"/>
             <module name="Magento_Sales"/>

Customer/Model/Customer.php

@@ -292,7 +292,7 @@ public function createGuestCustomer($data, $storeId){
             $ecomCustomerData=[];
             $data['connectionid'] = $this->coreHelper->getConnectionId($storeId);
             $data['externalid'] = $data['email'];
-            $data['acceptsMarketing'] = (int)$this->subscriberFactory->create()->loadBySubscriberEmail($data['email'],$this->storeManager->getStore()->getWebsiteId())->isSubscribed();
+            $data['acceptsMarketing'] = (int)$this->subscriberFactory->create()->loadBySubscriberEmail($data['email'],$this->storeManager->getStore($storeId)->getWebsiteId())->isSubscribed();
             $ecomCustomerData['ecomCustomer'] = $data;
             if (!$acCustomer) {
                 $result = $this->curl->createContacts(self::METHOD, self::ECOM_CUSTOMER_ENDPOINT, $ecomCustomerData);

Customer/composer.json

@@ -9,7 +9,7 @@
     "config": {
         "sort-packages": true
     },
-    "version": "2.1.10",
+    "version": "2.1.11",
     "require": {
         "php": "~7.3.0||~7.4.0||~8.0||~8.1||~8.2",
         "activecampaign/core": "2.1.*"

Customer/etc/module.xml

@@ -1,6 +1,6 @@
 <?xml version="1.0"?>
 <config xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:noNamespaceSchemaLocation="urn:magento:framework:Module/etc/module.xsd">
-	<module name="ActiveCampaign_Customer" setup_version="2.1.10">
+	<module name="ActiveCampaign_Customer" setup_version="2.1.11">
         <sequence>
             <module name="ActiveCampaign_Core"/>
         </sequence>

Newsletter/Cron/NewsletterSyncCron.php

@@ -135,10 +135,8 @@ public function execute(): void
                     ->setOrder('change_status_at', 'desc')
                     ->setPageSize($newsletterSyncNum)
                     ->setCurPage(1);
-
                 foreach ($newsletterCollection as $news) {
                     $acContact=NULL;
-
                     try {
                         $contactData = [
                                 'email' => $news->getSubscriberEmail()
@@ -147,16 +145,8 @@ public function execute(): void
                             $result = $this->customer->updateCustomer($this->getCustomer($news->getCustomerId()));
                             $acContact = $result['ac_contact_id'];
                         }else{
-                            $orders = $this->orderCollectionFactory->create()->addAttributeToFilter('customer_email', $news->getEmail())->setOrder('entity_id','desc');
-
-
-                            if($orders->getSize()>0){
-                                $store = $orders->getFirstItem()->getStoreId();
-                                $this->customer->createGuestCustomer($contactData,$store);
-                            }else{
                                 $acContact = $this->customer->createGuestContact($contactData);
-                            }
-
+                                 $this->customer->createGuestCustomer($contactData,$news->getStoreId());
                         }
 
                         if ($acContact) {