OwlCyberSecurity - MANAGER

Edit File: WooCommerceSync.php

<?php declare(strict_types = 1);

namespace MailPoet\Cron\Workers;

if (!defined('ABSPATH')) exit;

use MailPoet\Entities\ScheduledTaskEntity;
use MailPoet\Segments\WooCommerce as WooCommerceSegment;
use MailPoet\WooCommerce\Helper as WooCommerceHelper;

class WooCommerceSync extends SimpleWorker {
  const TASK_TYPE = 'woocommerce_sync';
  const SUPPORT_MULTIPLE_INSTANCES = false;
  const AUTOMATIC_SCHEDULING = false;
  const BATCH_SIZE = 1000;

/** @var WooCommerceSegment */
  private $woocommerceSegment;

/** @var WooCommerceHelper */
  private $woocommerceHelper;

public function __construct(
    WooCommerceSegment $woocommerceSegment,
    WooCommerceHelper $woocommerceHelper
  ) {
    $this->woocommerceSegment = $woocommerceSegment;
    $this->woocommerceHelper = $woocommerceHelper;
    parent::__construct();
  }

public function checkProcessingRequirements() {
    return $this->woocommerceHelper->isWooCommerceActive();
  }

public function processTaskStrategy(ScheduledTaskEntity $task, $timer) {
    $meta = $task->getMeta();
    $highestOrderId = $this->getHighestOrderId();

if (!isset($meta['last_checked_order_id'])) {
      $meta['last_checked_order_id'] = 0;
    }

do {
      $this->cronHelper->enforceExecutionLimit($timer);
      $meta['last_checked_order_id'] = $this->woocommerceSegment->synchronizeCustomers(
        $meta['last_checked_order_id'],
        $highestOrderId,
        self::BATCH_SIZE
      );
      $task->setMeta($meta);
      $this->scheduledTasksRepository->persist($task);
      $this->scheduledTasksRepository->flush();
    } while ($meta['last_checked_order_id'] < $highestOrderId);

return true;
  }

private function getHighestOrderId(): int {
    $orders = $this->woocommerceHelper->wcGetOrders(
      [
        'status' => 'all',
        'type' => 'shop_order',
        'limit' => 1,
        'orderby' => 'ID',
        'order' => 'DESC',
        'return' => 'ids',
      ]
    );

return (!empty($orders)) ? $orders[0] : 0;
  }
}