# sync-basalam/1.10.18/includes/Queue/QueueManager.php

ووسلام – همگام سازی ووکامرس و باسلام, version 1.10.18. 81 lines.

- Page: https://pluginprobe.com/plugins/sync-basalam/1.10.18/code/includes/Queue/QueueManager.php
- Raw: https://pluginprobe.com/plugins/sync-basalam/1.10.18/raw/includes/Queue/QueueManager.php
- Modified: 2026-09-12T12:46:38+00:00

Line numbers below start at 1. Link to a line or a range by appending a fragment to the
page URL, for example `https://pluginprobe.com/plugins/sync-basalam/1.10.18/code/includes/Queue/QueueManager.php#L10-L20`.

```php
<?php

namespace SyncBasalam\Queue;

defined('ABSPATH') || exit;
class QueueManager
{
    private const GROUP_NAME = 'sync-basalam';

    public $taskName;

    public function __construct($taskName)
    {
        $this->taskName = $taskName;
    }

    public function scheduleSingleTask($args = [], $delay = 0)
    {
        $timestamp = time() + $delay;

        $this->setLastRunTimestamp($timestamp);

        return \WC()->queue()->schedule_single(
            $timestamp,
            $this->taskName,
            [$args],
            self::GROUP_NAME
        );
    }

    public function scheduleRecurringTask($intervalInSeconds, $args = [])
    {
        if (self::hasPendingTasks($this->taskName)) return false;

        $startTimestamp = time();

        $this->setLastRunTimestamp($startTimestamp);

        return \WC()->queue()->schedule_recurring(
            $startTimestamp,
            $intervalInSeconds,
            $this->taskName,
            [$args],
            self::GROUP_NAME
        );
    }

    protected function setLastRunTimestamp($timestamp)
    {
        return update_option($this->taskName . '_last_run', $timestamp);
    }

    public static function hasPendingTasks($taskName)
    {
        $pendingTasks = \WC()->queue()->search([
            'hook'   => $taskName,
            'status' => 'pending',
        ]);

        return !empty($pendingTasks);
    }

    public static function cancelAllTasksGroup($taskName)
    {
        \WC()->queue()->cancel_all($taskName);

        delete_option($taskName . '_last_run');
    }

    public static function countOfPendingTasks($taskName)
    {
        $pendingTasks = \WC()->queue()->search([
            'hook'     => $taskName,
            'status'   => 'pending',
            'per_page' => 5000,
        ]);

        return count($pendingTasks);
    }
}

```