bin/WorkerAmoHTTP.php - master - mikopbx/ModuleAmoCrm

bin/WorkerAmoHTTP.php
206 строк7 KB
Alexey Portnov
Fix: 6 issues из Sentry (AmoCRM)
14 апр 2026, 15:10
14 апр 2026, 15:107443b06
<?php
/*
 * MikoPBX - free phone system for small business
 * Copyright © 2017-2022 Alexey Portnov and Nikolay Beketov
 *
 * This program is free software: you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 3 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License along with this program.
 * If not, see <https://www.gnu.org/licenses/>.
 */

namespace Modules\ModuleAmoCrm\bin;
require_once 'Globals.php';

use MikoPBX\Core\System\BeanstalkClient;
use MikoPBX\Core\System\Util;
use MikoPBX\Core\Workers\WorkerBase;
use MikoPBX\PBXCoreREST\Lib\PBXApiResult;
use Modules\ModuleAmoCrm\Lib\AmoCrmMain;
use Modules\ModuleAmoCrm\Lib\MikoPBXVersion;
use Modules\ModuleAmoCrm\Lib\PBXAmoResult;

class WorkerAmoHTTP extends WorkerBase
{
    public  AmoCrmMain $amoApi;
    public int $countReq = 0;
    public float $counterStartTime = 0;

    /**
     * Handles the received signal.
     *
     * @param int $signal The signal to handle.
     *
     * @return void
     */
    public function signalHandler(int $signal): void
    {
        parent::signalHandler($signal);
        cli_set_process_title('SHUTDOWN_'.cli_get_process_title());
    }

    /**
     * Старт работы листнера.
     *
     * @param $argv
     */
    public function start($argv):void
    {
        $this->amoApi   = new AmoCrmMain();
        $beanstalk      = new BeanstalkClient(self::class);
        $beanstalk->subscribe(self::class, [$this, 'onEvents']);
        $beanstalk->subscribe($this->makePingTubeName(self::class), [$this, 'pingCallBack']);
        while ($this->needRestart === false) {
            try {
                $beanstalk->wait();
            } catch (\Pheanstalk\Exception\JobNotFoundException $e) {
                // Job уже снят с резерва (TTR истёк) — продолжаем цикл.
                Util::sysLogMsg(self::class, 'JobNotFound: ' . $e->getMessage(), LOG_WARNING);
            } catch (\Throwable $e) {
                Util::sysLogMsg(self::class, 'beanstalk wait error: ' . $e->getMessage(), LOG_WARNING);
            }
        }
    }

    /**
     * Получение запросов на идентификацию номера телефона.
     * @param $tube
     * @return void
     */
    public function onEvents($tube): void
    {
        try {
            $data = json_decode($tube->getBody(), true);
        }catch (\Throwable $e){
            return;
        }
        $res_data = '';
        $funcName = $data['function']??'';
        if(method_exists($this->amoApi, $funcName) && $this->amoApi->isInitDone()){
            $this->needSleep();
            $this->amoApi->refreshToken();
            if(count($data['args']) === 0){
                $res_data = $this->amoApi->$funcName();
            }else{
                $res_data = $this->amoApi->$funcName(...$data['args']??[]);
            }
            $res_data = serialize($res_data);
            $res_data = $this->saveResultInTmpFile($res_data);
        }
        $tube->reply($res_data);
    }

    /**
     * Сериализует данные и сохраняет их во временный файл.
     * @param $data
     * @return string
     */
    private function saveResultInTmpFile($data):string
    {
        try {
            $res_data = json_encode($data, JSON_THROW_ON_ERROR);
        }catch (\JsonException $e){
            return '';
        }
        $downloadCacheDir = '/tmp/';
        $tmpDir = '/tmp/';
        $di = MikoPBXVersion::getDefaultDi();
        if ($di) {
            $dirsConfig = $di->getShared('config');
            $tmoDirName = $dirsConfig->path('core.tempDir') . '/ModuleAmoCrm';
            Util::mwMkdir($tmoDirName);
            chown($tmoDirName, 'www');
            if (file_exists($tmoDirName)) {
                $tmpDir = $tmoDirName;
            }

            $downloadCacheDir = $dirsConfig->path('www.downloadCacheDir');
            if (!file_exists($downloadCacheDir)) {
                $downloadCacheDir = '';
            }
        }
        $fileBaseName = md5(microtime(true));
        // "temp-" in the filename is necessary for the file to be automatically deleted after 5 minutes.
        $filename = $tmpDir . '/temp-' . $fileBaseName;
        file_put_contents($filename, $res_data);
        if (!empty($downloadCacheDir)) {
            $linkName = $downloadCacheDir . '/' . $fileBaseName;
            // For automatic file deletion.
            // A file with such a symlink will be deleted after 5 minutes by cron.
            Util::createUpdateSymlink($filename, $linkName, true);
        }
        chown($filename, 'www');
        return $filename;
    }

    /**
     * Выполнение метода API через свойство worker $this->AmoCrmMain
     * Метод следует вызывать при работе с API из прочих процессов.
     * @param $function
     * @param $args
     * @return mixed|PBXAmoResult
     */
    public static function invokeAmoApi($function, $args){
        $req = [
            'function' => $function,
            'args' => $args
        ];
        $client = new BeanstalkClient(self::class);
        $object = null;
        try {
            $result = $client->request(json_encode($req, JSON_THROW_ON_ERROR), 20);
            if(is_string($result) && $result !== '' && file_exists($result)){
                $filename = $result;
                $result = json_decode(file_get_contents($result), true, 512, JSON_THROW_ON_ERROR);
                unlink($filename);
                unset($filename);
            }
            if(is_string($result) && $result !== ''){
                $object = @unserialize($result, ['allowed_classes' => [PBXAmoResult::class, PBXApiResult::class]]);
            }
        } catch (\Throwable $e) {
            $object = new PBXAmoResult();
            $object->success = false;
            $object->messages[] = $e->getMessage();
        }
        if(!($object instanceof PBXAmoResult) && !($object instanceof PBXApiResult)){
            $object = new PBXAmoResult();
            $object->success = false;
            $object->messages[] = 'Empty or invalid response from WorkerAmoHTTP';
        }
        return $object;
    }

    /**
     * Разерешо только 7 запросов в секунду. Принудительное ожидание.
     * @return void
     */
    public function needSleep():void{
        $nowTime   = microtime(true);
        $deltaTime = $nowTime - $this->counterStartTime;
        if( $deltaTime > 1 ){
            $this->countReq = 0;
            $deltaTime = 0;
            $this->counterStartTime = $nowTime;
        }
        $this->countReq++;
        if($deltaTime>0 && $this->countReq>7){
            usleep($deltaTime * 1000000);
            $this->countReq = 0;
        }
    }

}

if(isset($argv) && count($argv) !== 1
    && Util::getFilePathByClassName(WorkerAmoHTTP::class) === $argv[0]){
    WorkerAmoHTTP::startWorker($argv??[]);
}