job.php

<?php
namespace Bitrix\Sender\Runtime;
 
abstract class Job
{
    public static function actualizeByCampaignId($campaignId)
    {
        (new SenderJob())->withCampaignId($campaignId)->actualize();
        (new ReiteratedJob())->actualize();
    }
 
    public static function actualizeByLetterId($letterId)
    {
        (new SenderJob())->withLetterId($letterId)->actualize();
        (new ReiteratedJob())->actualize();
    }
 
    public static function actualizeAll()
    {
        (new SenderJob())->actualize();
        (new ReiteratedJob())->actualize();
    }
 
    protected function addAgent($agentName, $interval = 60, $nextDateExec = '')
    {
        if (!$agentName || !is_string($agentName))
        {
            return;
        }
 
        $agent = new \CAllAgent();
        $agent->AddAgent(
            $agentName,
            "sender",
            "N",
            (int) $interval,
            null,
            "Y",
            (string) $nextDateExec
        );
    }
 
    protected function removeAgent($agentName)
    {
        if (!$agentName || !is_string($agentName))
        {
            return;
        }
 
        $agent = new \CAllAgent();
        $list = $agent->getList(
            ["ID" => "DESC"],
            ["MODULE_ID" => "sender", "NAME" => $agentName]
        );
        while ($row = $list->fetch())
        {
            $agent->delete($row["ID"]);
        }
    }
 
    protected function agentExists($agentName)
    {
        if (!$agentName || !is_string($agentName))
        {
            return false;
        }
 
        $agent = new \CAllAgent();
        return (bool)$agent->getList(
            ["ID" => "DESC"],
            ["MODULE_ID" => "sender", "NAME" => $agentName]
        )->fetch();
    }
}