qpapi/app/Http/Models/Common.php

<?php

namespace App\Http\Models;

use Illuminate\Database\Eloquent\Model;
use Illuminate\Support\Facades\Redis;
/**
 * 代理管理模型类
 */
class Common extends Model
{


    /**
     * 接口调用
     *
     * @access public
     * @param mixed $url 接口地址
     * @param mixed $where $params参数
     * @param mixed $timeout 请求时效
     * @return String
     */
    public function make_request($url, $params, $timeout=30)
    {
        set_time_limit(0);
        if (function_exists('curl_init') === true) {
            $ch = curl_init();
            $header = array(
                'Accept-Language: zh-cn',
                'Connection: Keep-Alive',
                'Cache-Control: no-cache'
            );
            curl_setopt($ch, CURLOPT_POST, 1);
            curl_setopt($ch, CURLOPT_URL, $url);
            curl_setopt($ch, CURLOPT_POSTFIELDS, $params);
            curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
            curl_setopt($ch, CURLOPT_HTTPHEADER, $header);
            if ($timeout > 0) curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, $timeout);
            $result = curl_exec($ch);
            $errno = curl_errno($ch);
            curl_close($ch);
            return $result;
        } else {
            $context = array(
                'http' => array(
                    'method' => 'POST',
                    'header' => 'Content-type: application/x-www-form-urlencoded' . "\r\n" .
                        'Content-length: ' . strlen($params),
                    'content' => $params));
            if ($timeout > 0) $context['http']['timeout'] = $timeout;
            $contextid = stream_context_create($context);
            $sock = @fopen($url, 'r', false, $contextid);
            if ($sock) {
                $result = '';
                while (!feof($sock)) {
                    $result .= fgets($sock, 8192);
                }
                fclose($sock);
            } else {
                return 'TimeOut';
            }
        }
        return $result;

    }//end make_request()


    /**
     * 接口调用
     *
     * @access public
     * @param mixed $paramsData 接口必要參數
     * @param mixed $url 接口地址
     * @return String
     */
    public function sportsAgentParams($paramsData, $url)
    {
        $paramsSting = '';
        $a = 0;
        foreach ($paramsData as $key => $value) {
            if ($a === 0) {
                $paramsSting .= $key . '=' . $value;
            } else {
                $paramsSting .= '&' . $key . '=' . $value;
            }
            $a++;
        }
        $params = base64_encode($paramsSting);
        $key = md5($params . session('sportsToken'));
        $loginUrl = $url . '?params=' . $params . '&Key=' . $key;

        return $loginUrl;

    }//end sportsAgentParams()

    /**
     * 添加系统通知
     *
     * @access public
     * @param array $msg 通知内容
     * @return
     */
    static public function addNotification(array $msg){
        foreach($msg as $k => $v){
           Redis::rpush('MSG_INDEX_QIPAI',$v);
        }
    }

    /**
     * 获取后删除栈内系统通知
     * @access public
     * @param array $msg 通知内容
     * @return
     */
    static public function getNotification(){
        $msg = Redis::lrange('MSG_INDEX_QIPAI',0,-1);
        if(!empty($msg)){
            Redis::ltrim('MSG_INDEX_QIPAI',1,0);
            return $msg;
        }
        return [];
    }
}