Ubilling/api/libs/api.pbxnum.php

<?php

/**
 * Universal PBX incoming calls processing class
 */
class PBXNum {

    /**
     * Telepathy object placeholder
     *
     * @var object
     */
    protected $telepathy = '';

    /**
     * Mobile number placeholder
     *
     * @var string
     */
    protected $number = '';

    /**
     * System cache object placeholder
     *
     * @var object
     */
    protected $cache = '';

    /**
     * Incoming calls database abstraction layer
     *
     * @var object
     */
    protected $callsDb = '';

    /**
     * Userdata cahe key name
     */
    const CACHE_KEY = 'PBXUSERDATA';

    /**
     * Userdata caching time in seconds
     */
    const CACHE_TIME = 3600;

    /**
     * Log path
     */
    const LOG_PATH = 'content/documents/incallsnum.log';

    /**
     * Default incoming calls logging table
     */
    const LOG_TABLE = 'callshist';

    /**
     * Creates new PBXNum instance
     * 
     * @return void
     */
    public function __construct() {
        $this->initTelepathy();
        $this->initCache();
        $this->initDb();
    }

    /**
     * Sets current mobile number
     * 
     * @param string $number
     * 
     * @return void
     */
    public function setNumber($number) {
        $this->number = $number;
    }

    /**
     * Inits telepathy object instance
     * 
     * @return void
     */
    protected function initTelepathy() {
        $this->telepathy = new Telepathy(false, true, false, true, false);
        $this->telepathy->usePhones();
    }

    /**
     * Inits system cache object instance for further usage
     * 
     * @return void
     */
    protected function initCache() {
        $this->cache = new UbillingCache();
    }

    /**
     * Inits incoming calls database abstraction layer
     * 
     * @return void
     */
    protected function initDb() {
        $this->callsDb = new NyanORM(self::LOG_TABLE);
    }

    /**
     * Saves incoming call into database
     * 
     * @return void
     */
    protected function saveCallsHist($date, $number, $login = '') {
        $login = ubRouting::filters($login, 'mres');
        $number = ubRouting::filters($number, 'mres');
        $number = trim($number);
        $login = trim($login);

        $this->callsDb->data('date', $date);
        $this->callsDb->data('number', $number);
        $this->callsDb->data('login', $login);
        $this->callsDb->create();
    }

    /**
     * Saves some data to log
     * 
     * @param int $reply
     * @param string $login
     * 
     * @return void
     */
    protected function log($reply, $login) {
        $curdateTime = curdatetime();
        $logData = $curdateTime . ' NUMBER: ' . $this->number . ' REPLY: ' . $reply . ' LOGIN: ' . $login . PHP_EOL;
        file_put_contents(self::LOG_PATH, $logData, FILE_APPEND);
        $this->saveCallsHist($curdateTime, $this->number, $login);
    }

    /**
     * Returns some state int for some user if he is detected by mobile phone
     * Can return cash balance also. In that case a serialized and base64 encoded array
     * with user acc state and acc cash balance is returned
     *
     * @param $ignoreCache
     * @param $getMoney
     *
     * 0 - user not found
     * 1 - user found and have positive balance
     * 2 - user found and have negative balance
     * 3 - user found and account is frozen or something like that
     * 
     * @return mixed
     */
    protected function getReply($ignoreCache = false, $getMoney = false) {
        $detectedLogin = $this->telepathy->getByPhone($this->number, true, true);
        $askReply = '0';
        $askReplyArr = array();
        $nonEncodedReply = '0';

        if (!empty($detectedLogin)) {
            $userData = $this->cache->get(self::CACHE_KEY, self::CACHE_TIME);

            if (empty($userData) or $ignoreCache) {
                $userData = array();
                $userDataRaw = simple_queryall("SELECT `login`,`Cash`,`Credit`,`Passive`,`Down`,`AlwaysOnline`,`Fee` from `users` LEFT JOIN (SELECT `name`,`Fee` FROM `tariffs`) as T on (`users`.`Tariff`=`T`.`name`)");
                if (!empty($userDataRaw)) {
                    foreach ($userDataRaw as $io => $each) {
                        $userData[$each['login']] = $each;
                    }
                }
                $this->cache->set(self::CACHE_KEY, $userData, self::CACHE_TIME);
            }

            if (isset($userData[$detectedLogin])) {
                $userData = $userData[$detectedLogin];

                if ($userData['Cash'] >= '-' . $userData['Credit']) {
                    $askReply = '1';
                } else {
                    $askReply = '2';
                }

                if (($userData['Passive'] == 1) OR ( $userData['Down'] == 1) OR ( $userData['AlwaysOnline'] == 0)) {
                    $askReply = '3';
                }

                $nonEncodedReply = $askReply;

                if ($getMoney) {
                    $askReplyArr[] = $askReply;
                    $askReplyArr[] = round($userData['Cash'], 2);
                    $askReplyArr[] = round($userData['Fee'], 2);
                    $askReply = base64_encode(serialize($askReplyArr));
                }
            }
        }


        $this->log($nonEncodedReply, $detectedLogin);

        return ($askReply);
    }

    /**
     * Returns parsed incoming calls log. 
     * 
     * Log format example:
     * 2023-01-18 11:42:42 NUMBER: 380931234567 REPLY: 0 LOGIN:
     * 2023-01-18 11:43:51 NUMBER: 380937654321 REPLY: 1 LOGIN: someuserlogin
     * 
     * @return array
     */
    public function parseLog() {
        $result = array();
        if (file_exists(self::LOG_PATH)) {
            $rawData = file_get_contents(self::LOG_PATH);
            $rawData = explodeRows($rawData);
            $count = 0;
            if (!empty($rawData)) {
                foreach ($rawData as $io => $line) {
                    if (!empty($line)) {
                        $line = explode(' ', $line);
                        $result[$count]['date'] = $line[0];
                        $result[$count]['time'] = $line[1];
                        $result[$count]['number'] = $line[3];
                        $result[$count]['reply'] = $line[5];
                        $result[$count]['login'] = @$line[7];
                        $count++;
                    }
                }
            }
        }
        return ($result);
    }

    /**
     * Renders reply for PBX external AGI application
     * 
     * @return void
     */
    public function renderReply($asteriskGet = false, $ignoreCache = false, $getMoney = false) {
        if (!$asteriskGet) {
            die($this->getReply($ignoreCache, $getMoney));
        } else {
            $this->getReply($ignoreCache, $getMoney);
        }
    }

}