fssy/application/api/controller/Kuaishou.php

<?php
namespace app\api\controller;
class Kuaishou extends Base
{
    public $appKey = 'ks698620896473026758';
    public $appSecret = 'cvbOgiVC6rSvPs0sBASfkg';
    public $signSecret = '71443462ca217e1c29425e7aabc257cc';
    public $msgSecret = '4fxDQv7tJKzIc1D7CNNe6A==';
    public $serverHost = "https://openapi.kwaixiaodian.com/";
    public $access_token = 'ChFvYXV0aC5hY2Nlc3NUb2tlbhJwJsfgEcw8cYbOARym_nQvgdOKc9-8eKn_0pLGJ5VMMOdq7ql_yEETn74H-BFNDeSPq1ujcKxf55SaRrJ4O0WfT86MY-oqzU79eysFt2AcgOOXc49AcscyjKm3I8RTjzC1CIBTmaNdrtYxDTyc_kjjNxoSIEH75Kg-RaqlrUNstFhsUg4wIiDQ_BkNN4qQCet_XmgzWrAJmuoISlLGlgM6WJh5djxTpigFMAE';
    public $debug = false;
    public $code = "ae727ca7a93aa4434335c4d3e9a1773d169a36f6c65b965a726a1d3c8b85699e62cfd671";

    public function notify()
    {
        $data = $this->request->param();
        $url = $this->serverHost . "oauth2/access_token?app_id={$this->appKey}&app_secret={$this->appSecret}&code={$data['code']}&grant_type=authorization_code";
        $s = $this->curl_https_get($url);
        $s = json_decode($s, true);
        var_dump($data,$s);
       // return  isset($s['access_token']) ? $s['access_token'] : '';

    }

    public function getAccessToken()
    {
       // $url = $this->serverHost . "oauth2/access_token?app_id={$this->appKey}&app_secret={$this->appSecret}&code={$this->code}&grant_type=authorization_code";
        $url = $this->serverHost . "oauth2/access_token?app_id={$this->appKey}&app_secret={$this->appSecret}&grant_type=client_credentials";
        $s = $this->curl_https_get($url);
        $s = json_decode($s, true);
        return  isset($s['access_token']) ? $s['access_token'] : '';
    }


    public static function getSelTime($sel = 3,$days =3)
    {
        $start = $sel;
        $end = $sel - $days;
        /*var_dump( [
            strtotime("- $start days") * 1000,
            strtotime("- $end days") * 1000,
            date("Y-m-d H:i:s",strtotime("- $start days")),
            date("Y-m-d H:i:s",strtotime("- $end days")),
        ]);*/
        return [
            strtotime("- $start days") * 1000,
            strtotime("- $end days") * 1000,
            date("Y-m-d H:i:s",strtotime("- $start days")),
            date("Y-m-d H:i:s",strtotime("- $end days")),
        ];
    }

    /**
     * @title 获取订单详情【商家自己的】
     * @desc  获取商家视角的订单详情
     * @author  qc
     * @url /api/Kuaishou/getOrderDetail
     * @method GET
     * @header name:Authorization require:1 desc:Token
     * @param  name:oid type:int  request:1 default:0 desc:id
     */
    public function getOrderDetail()
    {
        $apiType = "open.order.detail";
        $method = 'get';
        $param = ['oid'=>input('oid')];
        $arr['appkey'] = $this->appKey;
        $arr['version'] = 1;
        $arr['access_token'] = $this->access_token;
        $arr['timestamp'] = $this->getMillisecond();
        $arr['method'] = trim($apiType);
        $arr['param'] = $param ? json_encode($param) : '{}';
        $arr['signMethod'] = 'MD5';
        ksort($arr); // 排序
        $arr['sign'] = $this->getSign($arr, $this->signSecret);
        $apiInfo = str_replace('.', '/', $arr['method']);
        $url = $this->serverHost . $apiInfo;
        $s = static::apiSend($url,$arr,$method);
        $this->success('ok',[
            'res'=>$s,
            'token'=>$arr['access_token'],
            'param'=>$param,
            'api'=>$apiType ]);
    }

    /**
     * @title 获取订单费用详情【商家自己的】
     * @desc  获取订单费用详情
     * @author  qc
     * @url /api/Kuaishou/getOrderFee
     * @method GET
     * @header name:Authorization require:1 desc:Token
     * @param  name:oid type:int  request:1 default:0 desc:id
     */
    public function getOrderFee()
    {
        $apiType = "open.seller.order.fee.detail";
        $method = 'get';
        $param = ['orderId'=>input('oid')];
        $arr['appkey'] = $this->appKey;
        $arr['version'] = 1;
        $arr['access_token'] = $this->access_token;
        $arr['timestamp'] = $this->getMillisecond();
        $arr['method'] = trim($apiType);
        $arr['param'] = $param ? json_encode($param) : '{}';
        $arr['signMethod'] = 'MD5';
        ksort($arr); // 排序
        $arr['sign'] = $this->getSign($arr, $this->signSecret);
        $apiInfo = str_replace('.', '/', $arr['method']);
        $url = $this->serverHost . $apiInfo;
        $s = static::apiSend($url,$arr,$method);
        $this->success('ok',[
            'res'=>$s,
            'token'=>$arr['access_token'],
            'param'=>$param,
            'api'=>$apiType ]);
    }

    /**
     * @title 获取分销订单详情
     * @desc  获取分销订单详情
     * @author  qc
     * @url /api/Kuaishou/getFxInfo
     * @method GET
     * @header name:Authorization require:1 desc:Token
     * @param  name:oid type:int  request:1 default:0 desc:id
     */
    public function getFxInfo()
    {
        $apiType = "open.seller.order.cps.detail";
        $method = 'get';
        $param = ['oid'=>[input('oid')]];
        $arr['appkey'] = $this->appKey;
        $arr['version'] = 1;
        $arr['access_token'] = $this->access_token;
        $arr['timestamp'] = $this->getMillisecond();
        $arr['method'] = trim($apiType);
        $arr['param'] = $param ? json_encode($param) : '{}';
        $arr['signMethod'] = 'MD5';
        ksort($arr); // 排序
        $arr['sign'] = $this->getSign($arr, $this->signSecret);
        $apiInfo = str_replace('.', '/', $arr['method']);
        $url = $this->serverHost . $apiInfo;
        $s = static::apiSend($url,$arr,$method);
        $this->success('ok',[
            'res'=>$s,
            'token'=>$arr['access_token'],
            'param'=>$param,
            'api'=>$apiType ]);
    }

    /**
     * @title 获取分销订单列表
     * @desc  获取分销订单列表
     * @author  qc
     * @url /api/Kuaishou/getFxList
     * @method GET
     * @header name:Authorization require:1 desc:Token
     * @param  name:oid type:int  request:1 default:0 desc:id
     */
    public function getFxList()
    {
        $apiType = "open.seller.order.cps.list";
        $method = 'get';
        $sel_time = static::getSelTime(input('from_day',3),input('days',3));
        $param = [
            'currentPage'=>1,
            'pageSize'=>20,
            'type'=>1,
            'pcursor'=>'',
            'beginTime'=>$sel_time[0],
            'endTime'=>$sel_time[1],
        ];
        $arr['appkey'] = $this->appKey;
        $arr['version'] = 1;
        $arr['access_token'] = $this->access_token;
        $arr['timestamp'] = $this->getMillisecond();
        $arr['method'] = trim($apiType);
        $arr['param'] = $param ? json_encode($param) : '{}';
        $arr['signMethod'] = 'MD5';
        ksort($arr); // 排序
        $arr['sign'] = $this->getSign($arr, $this->signSecret);
        $apiInfo = str_replace('.', '/', $arr['method']);
        $url = $this->serverHost . $apiInfo;
        $s = static::apiSend($url,$arr,$method);
        $this->success('ok',[
            'res'=>$s,
            'token'=>$arr['access_token'],
            'param'=>$param,
            'api'=>$apiType ,
            'time'=>$sel_time
        ]);
    }

    /**
     * @title 获取卖家对应买家的订单列表
     * @desc  获取分销订单详情
     * @author  qc
     * @url /api/Kuaishou/getOrderList
     * @method GET
     * @header name:Authorization require:1 desc:Token
     * @param  name:buyerOpenId type:string  request:1 default:0 desc:buyerOpenId
     * @param  name:cursor type:string  request:1 default:0 desc:游标
     * @param  name:orderStatus type:int  request:1 default:0 desc:[0,10,30,40,50,70,80]
     */
    public  function getOrderList()
    {
        $apiType = "open.order.buyer.order.list";
        $method = 'get';
        $param = [
            'buyerOpenId'=>input('buyerOpenId'),
            'cursor'=>input('cursor','0'),
            'limit'=> 20,
            'orderStatus'=> [],
            'orderSourceType'=> [],
        ];
        $arr['appkey'] = $this->appKey;
        $arr['version'] = 1;
        $arr['access_token'] = $this->access_token;
        $arr['timestamp'] = $this->getMillisecond();
        $arr['method'] = trim($apiType);
        $arr['param'] = $param ? json_encode($param) : '{}';
        $arr['signMethod'] = 'MD5';
        ksort($arr); // 排序
        $arr['sign'] = $this->getSign($arr, $this->signSecret);
        $apiInfo = str_replace('.', '/', $arr['method']);
        $url = $this->serverHost . $apiInfo;
        $s = static::apiSend($url,$arr,$method);
        $this->success('ok',['res'=>$s]);
    }




    private function apiSend($url,$arr,$method)
    {
        if ($method == 'get') {
            $s = $this->curl_https_get($url. '?' . http_build_query($arr, '', '&'), array());
        } else {
            $s = $this->curl_https_post($url, $arr);
        }
       return json_decode($s, true);
    }

    public function getSign($params, $key) {
        $unSignParaString = $this->formatQueryParaMap($params, false);
        $signStr = (md5($unSignParaString . "&signSecret=" . $this->signSecret));
        return $signStr;
    }

    public function formatQueryParaMap(array $paraMap, $urlEncode = false) {
        $buff = "";
        ksort($paraMap);
        foreach ($paraMap as $k => $v) {
            if (null != $v && "null" != $v) {
                if ($urlEncode) {
                    $v = urlencode($v);
                }
                $buff.= $k . "=" . $v . "&";
            }
        }
        $reqPar = '';
        if (strlen($buff) > 0) {
            $reqPar = substr($buff, 0, strlen($buff) - 1);
        }
        return $reqPar;
    }

    /*获取13位时间戳*/
    private static function getMillisecond() {
        list($t1, $t2) = explode(' ', microtime());
        return sprintf('%.0f', (floatval($t1) + floatval($t2)) * 1000);
    }

    private function curl_get_contents($url, $data = array(), $https = false) {
        $results['error'] = '';
        $results['status'] = 0;
        $results['data'] = array();
        $user_agent = $_SERVER['HTTP_USER_AGENT'];
        $curl = curl_init(); // 启动一个CURL会话
        if (!empty($data) && is_array($data)) {
            curl_setopt($curl, CURLOPT_POST, TRUE);
            curl_setopt($curl, CURLOPT_POSTFIELDS, http_build_query($data));
            curl_setopt($curl, CURLOPT_HTTPHEADER, array('Content-Type: application/x-www-form-urlencoded'));
        }
        if ($https) {
            curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, 0); // 对认证证书来源的检查
            curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, 2); // 从证书中检查SSL加密算法是否存在
            curl_setopt($curl, CURLOPT_FOLLOWLOCATION, 1); // 使用自动跳转

        }
        curl_setopt($curl, CURLOPT_URL, $url); // 要访问的地址
        curl_setopt($curl, CURLOPT_TIMEOUT, 30); // 设置超时限制防止死循环
        curl_setopt($curl, CURLOPT_HEADER, 0); // 显示返回的Header区域内容
        curl_setopt($curl, CURLOPT_RETURNTRANSFER, 1); // 获取的信息以文件流的形式返回
        curl_setopt($curl, CURLOPT_USERAGENT, $user_agent); // 模拟用户使用的浏览器
        curl_setopt($curl, CURLOPT_AUTOREFERER, 1); // 自动设置Referer
        $results['data'] = curl_exec($curl); // 执行操作
        if (curl_errno($curl)) {
            $results['error'] = curl_error($curl); //捕抓异常

        }
        curl_close($curl); // 关闭CURL会话
        return $results['data']; // 返回数据

    }

    private function curl_https_post($url, $data) {
        return $this->curl_get_contents($url, $data, true);
    }

    private function curl_https_get($url) {
        return $this->curl_get_contents($url, array(), true);
    }

}