yfix/yf

<?php

class yf_payment_api__provider
{
    public $ENABLE = null;
    public $TEST_MODE = null;

    public $payment_api = null;

    public function _init()
    {
        if ( ! $this->ENABLE) {
            return  null;
        }
        $this->payment_api = _class('payment_api');
        ! empty($this->service_allow) && $this->description = implode(', ', $this->service_allow);
    }

    public function allow($value = null)
    {
        $result = &$this->ENABLE;
        if (isset($value)) {
            $value = (bool) $value;
            // init if enable
            if ( ! $result && $value) {
                $this->_init();
            }
            $result = $value;
        }
        return  $result;
    }

    public function is_test($options = null)
    {
        $result = false;
        // import options
        is_array($options) && extract($options, EXTR_PREFIX_ALL | EXTR_REFS, '');
        if ( ! empty($this->TEST_MODE) || ! empty($_test_mode)) {
            $result = true;
        }
        return  $result;
    }

    public function validate($options = null)
    {
        return  $this->result_success();
    }

    public function result_success()
    {
        return  ['status' => true];
    }

    public function result_fail($message)
    {
        return  ['status' => false, 'status_message' => $message];
    }

    public function deposition($options)
    {
        if ( ! $this->ENABLE) {
            return  null;
        }
        $result = $this->_transaction($options);
        return  $result;
    }

    public function payment($options)
    {
        if ( ! $this->ENABLE) {
            return  null;
        }
        $result = $this->_transaction($options);
        return  $result;
    }

    public function transfer($options)
    {
        if ( ! $this->ENABLE) {
            return  null;
        }
        $_options = [
            'options' => &$options['options'],
            'provider' => &$options['provider'],
            'operation_options' => [
                'from' => $options['options']['from'],
                'to' => $options['options']['to'],
                'amount' => $options['options']['amount'],
            ],
        ];
        $_options['operation_options']['from']['operation_id'] = &$options['data']['from']['operation_id'];
        $_options['operation_options']['to']['operation_id'] = &$options['data']['to']['operation_id'];
        // from
        $options_from = $_options + [
            'data' => &$options['data']['from'],
            'operation_data' => &$options['operation_data']['from'],
        ];
        $options_from['operation_options']['direction'] = 'out';
        $result_from = $this->_transaction($options_from);
        // to
        $options_to = $_options + [
            'data' => &$options['data']['to'],
            'operation_data' => &$options['operation_data']['to'],
        ];
        $options_from['operation_options']['direction'] = 'in';
        $result_to = $this->_transaction($options_to);
        $result = [
            'status' => $result_from['status'] & $result_to['status'],
            'status_message' => $result_from['status_message'],
            'from' => $result_from,
            'to' => $result_to,
        ];
        return  $result;
    }

    protected function _transaction($options)
    {
        if ( ! $this->ENABLE) {
            return  null;
        }
        $payment_api = $this->payment_api;
        $_ = $options;
        $is_transaction = isset( $_['is_transaction'] ) ? $_['is_transaction'] : true;
        $options = &$_['options'];
        $provider = &$_['provider'];
        $data = &$_['data'];
        $operation_data = &$_['operation_data'];
        $operation_options = &$_['operation_options'];
        // prepare data
        $operation_id = (int) $data['operation_id'];
        $account_id = (int) $data['account_id'];
        $type_name = &$operation_data['type']['name'];
        $direction = &$data['direction'];
        $amount = $payment_api->_number_float($data['amount']);
        // operation_id
        if (empty($operation_id)) {
            $result = [
                'status' => false,
                'status_message' => 'Не определен код операции',
            ];
            return  $result;
        }
        // update account balance
        $sql_datetime = $payment_api->sql_datetime();
        $sql_amount = $payment_api->_number_mysql($amount);
        switch (true) {
            case $type_name == 'payment':
            case $type_name == 'transfer' && $direction == 'out':
                $sql_sign = '-';
                break;
            case $type_name == 'deposition':
            case $type_name == 'transfer' && $direction == 'in':
            default:
                $sql_sign = '+';
                break;
        }
        $_data = [
            'account_id' => $account_id,
            'datetime_update' => db()->escape_val($sql_datetime),
            'balance' => "( balance $sql_sign $sql_amount )",
        ];
        $is_transaction && db()->begin();
        $_result = $payment_api->balance_update($_data, ['is_escape' => false]);
        if ( ! $_result['status']) {
            $is_transaction && db()->rollback();
            $result = [
                'status' => false,
                'status_message' => 'Ошибка при обновлении счета',
            ];
            return  $result;
        }
        $result = [
            'status' => true,
        ];
        // get status
        $object = $payment_api->get_status(['name' => 'success']);
        list($payment_status_id, $payment_status) = $object;
        if (empty($payment_status_id)) {
            $is_transaction && db()->rollback();
            return  $object;
        }
        $result['status_message'] = 'Выполнено: ' . $options['operation_title'] . ', сумма: ' . $amount;
        if ( ! empty($payment_api->currency['short'])) {
            $result['status_message'] .= ' ' . $payment_api->currency['short'];
        }
        // check account
        $account_result = $payment_api->get_account(['account_id' => $account_id]);
        if (empty($account_result)) {
            $status = false;
        }
        list($account_id, $account) = $account_result;
        // update operation status
        $_data = [
            'operation_id' => $operation_id,
            'status_id' => $payment_status_id,
            'balance' => $account['balance'],
            'options' => $operation_options,
            'datetime_update' => $sql_datetime,
            'datetime_finish' => $sql_datetime,
        ];
        $_result = $payment_api->operation_update($_data);
        if ( ! $_result['status']) {
            $is_transaction && db()->rollback();
            return  $_result;
        }
        $is_transaction && db()->commit();
        events()->fire('payment.balance_refresh', [$account]);
        return  $result;
    }
}