provider.php

<?php
 
namespace Bitrix\Scale;
 
use \Bitrix\Main\Localization\Loc;
Loc::loadMessages(__FILE__);
 
use \Bitrix\Main\ArgumentNullException;
 
class Provider {
 
    public static function getList($params = array())
    {
        $result = array();
        $shellAdapter = new ShellAdapter();
        $execRes = $shellAdapter->syncExec("sudo -u root /opt/webdir/bin/bx-provider -a list -o json");
        $jsonData = $shellAdapter->getLastOutput();
 
        if($execRes)
        {
            $arData = json_decode($jsonData, true);
 
            if(isset($arData["params"]) && isset($arData["params"]["providers"]) && is_array($arData["params"]["providers"]))
                $result = $arData["params"]["providers"];
 
            if(isset($params["filter"]) && is_array($params["filter"]))
            {
                foreach($params["filter"] as $filterKey => $filterValue)
                {
                    foreach($result as $providerId => $providerParams)
                    {
                        if(!array_key_exists($filterKey, $providerParams) || $providerParams[$filterKey] != $filterValue)
                        {
                            unset($result[$providerId]);
                        }
                    }
                }
            }
 
        }
 
        return $result;
    }
 
    public static function getStatus($providerId)
    {
        if($providerId == '' )
            throw new ArgumentNullException("providerId");
 
        $result = array();
 
        $shellAdapter = new ShellAdapter();
        $execRes = $shellAdapter->syncExec("sudo -u root /opt/webdir/bin/bx-provider -a status --provider ".$providerId." -o json");
        $jsonData = $shellAdapter->getLastOutput();
 
        if($execRes)
        {
            $arData = json_decode($jsonData, true);
 
            if(isset($arData["params"]["provider_options"][$providerId]) && is_array($arData["params"]["provider_options"][$providerId]))
                $result = $arData["params"]["provider_options"][$providerId];
        }
 
        return $result;
    }
 
    public static function getConfigs($providerId)
    {
        if($providerId == '' )
            throw new ArgumentNullException("providerId");
 
        $result = array();
        $shellAdapter = new ShellAdapter();
        $execRes = $shellAdapter->syncExec("sudo -u root /opt/webdir/bin/bx-provider -a configs --provider ".$providerId." -o json");
        $jsonData = $shellAdapter->getLastOutput();
 
        if($execRes)
        {
            $arData = json_decode($jsonData, true);
 
            if(isset($arData["params"]["provider_configs"][$providerId]["configurations"]) && is_array($arData["params"]["provider_configs"][$providerId]["configurations"]))
                $result = $arData["params"]["provider_configs"][$providerId]["configurations"];
        }
 
        return $result;
    }
 
    public static function sendOrder($providerId, $configId)
    {
        if($providerId == '' )
            throw new ArgumentNullException("providerId");
 
        if($configId == '' )
            throw new ArgumentNullException("configId");
 
        $result = "";
        $shellAdapter = new ShellAdapter();
        $execRes = $shellAdapter->syncExec("sudo -u root /opt/webdir/bin/bx-provider -a order --provider ".$providerId." --config_id ".$configId." -o json");
        $jsonData = $shellAdapter->getLastOutput();
 
        if($execRes)
        {
            $arData = json_decode($jsonData, true);
 
            if(isset($arData["params"]["provider_order"][$providerId]["task_id"]))
                $result = $arData["params"]["provider_order"][$providerId]["task_id"];
        }
 
        if($result <> '')
        {
            $logLevel = Logger::LOG_LEVEL_INFO;
            $description = Loc::getMessage("SCALE_PROVIDER_SEND_ORDER_SUCCESS");
        }
        else
        {
            $logLevel = Logger::LOG_LEVEL_ERROR;
            $description = Loc::getMessage("SCALE_PROVIDER_SEND_ORDER_ERROR");
        }
 
        $description = str_replace(
            array("##PROVIDER##", "##CONFIG_ID##", "##ORDER_ID##"),
            array($providerId, $configId, $result),
            $description
        );
 
        Logger::addRecord(
            $logLevel,
            "SCALE_PROVIDER_SEND_ORDER",
            $providerId."::".$configId,
            $description);
 
        return $result;
    }
 
 
    public static function getOrderStatus($providerId, $taskId)
    {
        if($providerId == '' )
            throw new ArgumentNullException("providerId");
 
        if($taskId == '' )
            throw new ArgumentNullException("taskId");
 
        $result = array();
        $shellAdapter = new ShellAdapter();
        $execRes = $shellAdapter->syncExec("sudo -u root /opt/webdir/bin/bx-provider -a order_status --provider ".$providerId." --task_id ".$taskId." -o json");
        $jsonData = $shellAdapter->getLastOutput();
 
        if($execRes)
        {
            $arData = json_decode($jsonData, true);
 
            if(isset($arData["params"]["provider_order"][$providerId]))
                $result = $arData["params"]["provider_order"][$providerId];
        }
 
        return $result;
    }
 
    public static function getOrdersList($providerId = "")
    {
        $result = array();
        $shellAdapter = new ShellAdapter();
        $execRes = $shellAdapter->syncExec("sudo -u root /opt/webdir/bin/bx-provider -a orders_list".($providerId <> '' ? " --provider ".$providerId : "")." -o json");
        $jsonData = $shellAdapter->getLastOutput();
 
        if($execRes)
        {
            $arData = json_decode($jsonData, true);
 
            if(isset($arData["params"]["provider_order_list"]))
                $result = $arData["params"]["provider_order_list"];
        }
 
        return $result;
    }
 
    public static function addToPullFromOrder($providerId, $taskId)
    {
        if($providerId == '' )
            throw new ArgumentNullException("providerId");
 
        if($taskId == '' )
            throw new ArgumentNullException("taskId");
 
        $result = false;
        $shellAdapter = new ShellAdapter();
        $execRes = $shellAdapter->syncExec("sudo -u root /opt/webdir/bin/bx-provider -a order_to_host --provider ".$providerId."  --task_id ".$taskId." -o json");
        $jsonData = $shellAdapter->getLastOutput();
 
        if($execRes)
        {
            $result = json_decode($jsonData, true);
        }
 
        return $result;
    }
}