<?php
class Uber{
protected $token;
protected $scope;//token类型
protected $redis;
public $login_api = 'https://login.uber.com/oauth/v2/token';//登录验证
public $api_host = 'https://api.uber.com';
public $url_relation = [
//获取店铺状态
'getStoreStatus' => [
'method' => 'get',
'uri' => '/v1/eats/store/store_id/status',
'scope' => 'eats.store'
],
//获取店铺节假日休息时间
'getHolidayHours' => [
'method' => 'get',
'uri' => '/v1/eats/stores/store_id/holiday-hours',
'scope' => 'eats.store'
],
//设置节假日休息时间
'setHolidayHours' => [
'method' => 'post',
'uri' => '/v1/eats/stores/store_id/holiday-hours',
'scope' => 'eats.store'
],
//获取店铺菜单（全量）
'getMenus' => [
'method' => 'get',
'uri' => '/v2/eats/stores/store_id/menus',
'scope' => 'eats.store'
],
//上传店铺订单（全量）
'putMenus' => [
'method' => 'post',
'uri' => '/v2/eats/stores/store_id/menus',
'scope' => 'eats.store'
],
//更新店铺的商品信息
'setItem' => [
'method' => 'post',
'uri' => '/v2/eats/stores/store_id/menus/items/item_id',
'scope' => 'eats.store'
],
//更新店铺的状态
'setStoreStatus' => [
'method' => 'post',
'uri' => '/v1/eats/store/store_id/status',
'scope' => 'eats.store.status.write'
],
//获取已创建的订单【数组】
'getOrderList' => [
'method' => 'get',
'uri' => '/v1/eats/stores/store_id/created-orders',
'scope'=> 'eats.store.orders.read'
],
//获取已经取消的订单【数组】
'getCancelOrder' => [
'method' => 'get',
'uri' => '/v1/eats/stores/store_id/canceled-orders',
'scope'=> 'eats.store.orders.read'
],
//获取单个订单详情
'getOrderDetail' => [
'method' => 'get',
'uri' => '/v2/eats/order/order_id',
'scope' => 'eats.order'
],
//接单
'acceptOrder' => [
'method' => 'post',
'uri' => '/v1/eats/orders/order_id/accept_pos_order',
'scope' => 'eats.order'
],
//拒单
'denyOrder' => [
'method' => 'post',
'uri' => '/v1/eats/orders/order_id/deny_pos_order',
'scope' => 'eats.order'
],
//取消订单
'cancelOrder' => [
'method' => 'post',
'uri' => '/v1/eats/orders/order_id/cancel',
'scope' => 'eats.order'
]
];
/**
* 获取token
* Uber constructor.
* @param $uri $url_relation 中对应的key
* @param string $client_id 密钥
* @param string $client_secret 密匙
* @param string $grant_type
*/
public function __construct($uri, $client_id = '', $client_secret = '', $grant_type = 'client_credentials')
{
$this->redis = redis_cache(10);//redis链接，公共方法
$token = $this->getToken($uri, $client_id, $client_secret, $grant_type);
if(!$token){
$token = $this->getToken($uri, $client_id, $client_secret, $grant_type);
if(!$token){
//token获取失败
return false;
}
}
$this->token = $token;
}
/**
* 获取请求对应的token
* @param $uri
* @param $client_id
* @param $client_secret
* @param string $grant_type
* @return bool|string
*/
public function getToken($uri, $client_id, $client_secret, $grant_type = 'client_credentials'){
$uri_arr = $this->urlToArr($uri);
if(empty($uri_arr)){
//api错误
return false;
}
$this->scope = $uri_arr['scope'];
$token = $this->redis->get($this->scope);
if(!empty($token)){
return $token;
}
$params = [
'client_id' => $client_id,
'client_secret' => $client_secret,
'grant_type' => $grant_type,
'scope' => $this->scope,
];
$result = $this->requestUber($this->login_api, $query = [], $params);
if(empty($result) || !is_array($result) || empty($result['access_token'])){
//写日志记录，获取token失败
return false;
}
$token = $result['token_type'].' '.$result['access_token'];
$this->redis->set($this->scope, $token);
$this->redis->expire($this->scope, $result['expires_in'] - 24*3600);//设置过期时间29天
return $token;
}
/**
* 向uber发送请求
* @param $uri 登录为玩这个url，其他为$url_arr
* @param array $query
* @param array $params
* @return array|mixed
*/
public function requestUber($uri, $query = [], $params = []){
if(strpos($uri, 'login')){//登录
$res = $this->curlData($uri, $params, $header = [], $method = 'post', $type = '');
if(!empty($res['data'])){
return json_decode($res['data'], 1);
}
//写日志，请求返回的数据
}else{//重组url
$header = ['authorization:'.$this->token];
$uri_arr = $this->url_relation[$uri];
$uri = $uri_arr['uri'];
if(count($query) > 0){
foreach ($query as $key=>$item){
if(strpos($uri, $key)){
$uri = str_replace($key, $item, $uri);
}
}
}
$url = $this->api_host.$uri;
$res = $this->curlData($url, $params, $header, $uri_arr['method']);
if($res){
if(!empty($res['data'])){
$res['data'] = json_decode($res['data'], 1);
}
return $res;
}
}
return false;
}
/**
* 获取当前的url
* @param $uri
* @return array|string[]
*/
public function urlToArr($uri){
$api = [];
foreach ($this->url_relation as $key=>$item){
array_push($api, $key);
}
if(!in_array($uri, $api)){
return [];
}
return $this->url_relation[$uri];
}
/**
* 发送post请求
* @param $url
* @param $data
* @param $header
* @param string $method
* @param string $type
* @return array
*/
public function curlData($url, $data, $header, $method = 'get', $type = 'json')
{
$ch = curl_init();
if ($type == 'json') {
$headers = ['Content-Type: application/json'];
} else {
$headers = ['Content-Type: application/x-www-form-urlencoded'];
}
$headers = array_merge($headers, $header);
if ($method == 'GET' && !empty($data)) {
if ($type != 'json') {
$querystring = http_build_query($data);
$url = $url . '?' . $querystring;
} else {
$url = $url . '?' . $this->arrToStr($data);
}
}
curl_setopt($ch, CURLOPT_URL, $url);
curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);
curl_setopt($ch, CURLOPT_HEADER, false);
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true); // 执行后不直接打印出来
curl_setopt($ch, CURLOPT_FOLLOWLOCATION, 1);
curl_setopt($ch, CURLOPT_AUTOREFERER, 1);
curl_setopt($ch, CURLOPT_TIMEOUT, 10);
switch ($method) {
case 'post':
$data = json_encode($data);
if ($type == 'json') {
curl_setopt($ch, CURLOPT_CUSTOMREQUEST, 'POST'); // 请求方式
curl_setopt($ch, CURLOPT_POST, 1); // post提交
curl_setopt($ch, CURLOPT_POSTFIELDS, $data); // post的变量
} else {
curl_setopt($ch, CURLOPT_POST, 1); // post提交
$querystring = http_build_query($data);
curl_setopt($ch, CURLOPT_POSTFIELDS, $querystring); // post的变量
}
break;
case 'put':
$data = json_encode($data);
curl_setopt($ch, CURLOPT_CUSTOMREQUEST, "PUT");
curl_setopt($ch, CURLOPT_POSTFIELDS, $data);
break;
case 'delete':
curl_setopt($ch, CURLOPT_CUSTOMREQUEST, "DELETE");
curl_setopt($ch, CURLOPT_POSTFIELDS, $data);
break;
default:
curl_setopt($ch, CURLOPT_HTTPGET, true);
break;
}
curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
//curl_setopt($ch, CURLOPT_USERAGENT, $_SERVER['HTTP_USER_AGENT']); // 模拟用户使用的浏览器
if (!empty($cookie)) {
curl_setopt($ch, CURLOPT_COOKIE, $cookie);
}
curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false); // 跳过证书检查
curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false); // 不从证书中检查SSL加密算法是否存在
$output = curl_exec($ch);
$return_code = curl_getinfo($ch, CURLINFO_HTTP_CODE);
curl_close($ch);
return array('err_code' => $return_code, 'data' => $output);
}
/**
* 拼接get数据
* @param array $data
* @return false|string
*/
public function arrToStr($data = [])
{
ksort($data);
$str = '';
foreach ($data as $key => $item) {
$str .= $key . '=' . $item . '&';
}
$str = substr($str, 0, strlen($str) - 1);
return $str;
}
}
if(!function_exists('redis_cache')){
/**
* 连接redis
* @param int $db 数据库
* @return Redis
*/
function redis_cache($db = 0){
global $_W;
$redis_server = '127.0.0.1';
$redis_port = '3306';
$redis_auth = '';
$client = new Redis();
$client->connect($redis_server, $redis_port);
if(!empty($redis_auth)){
$client->auth($redis_auth);
}
if($db){
$client->select($db);
}
return $client;
}
}uber接口文档：https://developer.uber.com/docs/eats/api/v1/post-eats-store-storeid-status