作者 郭文星

2312

... ... @@ -32,7 +32,6 @@ class Index extends Api
public function getCamera(){
$url="https://camera.ynzhsk.cn/api/reservoir/hkws/Hardware/getListByReservoir";
$info =HttpHelper::get($url);
$info = json_decode($info, true);
if($info['data']){
return $this->success("返回成功",$info);
... ... @@ -42,8 +41,10 @@ class Index extends Api
}
//获取token
public function tokenLogin(){
$appKey="waterPro_54989312";
$appSecret="bef381707451606b34c1f9b4b18bd5d7";
$appKey= $this->request->param('appKey',"");
$appSecret= $this->request->param('appSecret',"");
// $appKey="waterPro_54989312";
// $appSecret="bef381707451606b34c1f9b4b18bd5d7";
$url="https://tyuims.tenyes.cn/api/access_token";
$postdata=[
"appKey"=>$appKey,
... ... @@ -68,4 +69,73 @@ class Index extends Api
return $this->error("请求失败");
}
}
//获取水厂列表
public function getwaterworks(){
$token= $this->request->param('token',"");
$url="http://124.71.107.128:9040/data_api/v1/getWaterworksListData";
//$token="eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJ1c2VybmFtZSI6IjE5OTY5MTA2NzEwIiwicGFzc3dvcmQiOiJhMGUxNWM0NDRmOGNiY2NiNTAwM2U1MDk5OGI2OGZhNyIsImV4cCI6MTczMTY2ODA5MSwiaXNzIjoidWltcyJ9.W3RBwrFdidL9ERykKC_gHtjp911xrkNvUKglSes1w7c";
$res =HttpHelper::postheader($url,"","",$token);
$res=json_decode($res,true);
return $this->success($res['message'],$res['data']);
}
//获取水厂列表
public function getWaterworksDetailData(){
$id= $this->request->param('id',"");
$token= $this->request->param('token',"");
$url="http://124.71.107.128:9040/data_api/v1/getWaterworksDetailData";
$token="eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJ1c2VybmFtZSI6IjE5OTY5MTA2NzEwIiwicGFzc3dvcmQiOiJhMGUxNWM0NDRmOGNiY2NiNTAwM2U1MDk5OGI2OGZhNyIsImV4cCI6MTczMTY2ODA5MSwiaXNzIjoidWltcyJ9.W3RBwrFdidL9ERykKC_gHtjp911xrkNvUKglSes1w7c";
$data=['id'=>$id];
$res =HttpHelper::postheader($url,$data,"",$token);
$res=json_decode($res,true);
return $this->success($res['message'],$res['data']);
}
//获得净水设备列表
public function getWaterworksEquipmentListData(){
$token= $this->request->param('token',"");
$url="http://124.71.107.128:9040/data_api/v1/getWaterworksEquipmentListData";
$token="eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJ1c2VybmFtZSI6IjE5OTY5MTA2NzEwIiwicGFzc3dvcmQiOiJhMGUxNWM0NDRmOGNiY2NiNTAwM2U1MDk5OGI2OGZhNyIsImV4cCI6MTczMTY2ODA5MSwiaXNzIjoidWltcyJ9.W3RBwrFdidL9ERykKC_gHtjp911xrkNvUKglSes1w7c";
$res =HttpHelper::postheader($url,"","",$token);
$res=json_decode($res,true);
return $this->success($res['message'],$res['data']);
}
//获得净水设备列表
public function getWaterworksEquipmentDetailData(){
$id= $this->request->param('id',"");
$token= $this->request->param('token',"");
$url="http://124.71.107.128:9040/data_api/v1/getWaterworksEquipmentDetailData";
$token="eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJ1c2VybmFtZSI6IjE5OTY5MTA2NzEwIiwicGFzc3dvcmQiOiJhMGUxNWM0NDRmOGNiY2NiNTAwM2U1MDk5OGI2OGZhNyIsImV4cCI6MTczMTY2ODA5MSwiaXNzIjoidWltcyJ9.W3RBwrFdidL9ERykKC_gHtjp911xrkNvUKglSes1w7c";
$data=['id'=>$id];
$res =HttpHelper::postheader($url,$data,"",$token);
$res=json_decode($res,true);
return $this->success($res['message'],$res['data']);
}
//-获得净水设备数据列表
public function getWaterworksEquipmentDataListData(){
$token= $this->request->param('token',"");
$url="http://124.71.107.128:9040/data_api/v1/getWaterworksEquipmentDataListData";
$token="eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJ1c2VybmFtZSI6IjE5OTY5MTA2NzEwIiwicGFzc3dvcmQiOiJhMGUxNWM0NDRmOGNiY2NiNTAwM2U1MDk5OGI2OGZhNyIsImV4cCI6MTczMTY2ODA5MSwiaXNzIjoidWltcyJ9.W3RBwrFdidL9ERykKC_gHtjp911xrkNvUKglSes1w7c";
$res =HttpHelper::postheader($url,"","",$token);
$res=json_decode($res,true);
return $this->success($res['message'],$res['data']);
}
//-获得设备数据详情
public function getWaterworksEquipmentDataDetailData(){
$id= $this->request->param('id',"");
$token= $this->request->param('token',"");
$url="http://124.71.107.128:9040/data_api/v1/getWaterworksEquipmentDataDetailData";
$token="eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJ1c2VybmFtZSI6IjE5OTY5MTA2NzEwIiwicGFzc3dvcmQiOiJhMGUxNWM0NDRmOGNiY2NiNTAwM2U1MDk5OGI2OGZhNyIsImV4cCI6MTczMTY2ODA5MSwiaXNzIjoidWltcyJ9.W3RBwrFdidL9ERykKC_gHtjp911xrkNvUKglSes1w7c";
$data=['id'=>$id];
$res =HttpHelper::postheader($url,$data,"",$token);
$res=json_decode($res,true);
return $this->success($res['message'],$res['data']);
}
}
\ No newline at end of file
... ...
... ... @@ -35,6 +35,19 @@ class HttpHelper
* @param array $options 扩展参数
* @return mixed|string
*/
public static function postheader($url, $params = [], $options = [],$header)
{
$req = self::sendRequestheader($url, $params, 'POST', $options,$header);
return $req['ret'] ? $req['msg'] : '';
}
/**
* 发送一个POST请求
* @param string $url 请求URL
* @param array $params 请求参数
* @param array $options 扩展参数
* @return mixed|string
*/
public static function get($url, $params = [], $options = [])
{
$req = self::sendRequest($url, $params, 'GET', $options);
... ... @@ -75,7 +88,7 @@ class HttpHelper
* @param mixed $options CURL的参数
* @return array
*/
public static function sendRequest($url, $params = [], $method = 'POST', $options = [])
public static function sendRequestheader($url, $params = [], $method = 'POST', $options = [],$header)
{
$method = strtoupper($method);
$protocol = substr($url, 0, 5);
... ... @@ -104,7 +117,7 @@ class HttpHelper
$defaults[CURLOPT_TIMEOUT] =7;
// disable 100-continue
curl_setopt($ch, CURLOPT_HTTPHEADER, array('Expect:'));
curl_setopt($ch, CURLOPT_HTTPHEADER, array('Authorization:'.$header));
if ('https' == $protocol) {
$defaults[CURLOPT_SSL_VERIFYPEER] = false;
... ... @@ -134,6 +147,7 @@ class HttpHelper
];
}
/**
* 异步发送一个请求
* @param string $url 请求的链接
... ... @@ -219,35 +233,35 @@ class HttpHelper
}
public function curl($url,$method,$params=[],$auth=[]){
//初始化CURL句柄
//初始化CURL句柄
$curl = curl_init();
curl_setopt($curl, CURLOPT_URL, $url);//设置请求的URL
#curl_setopt($curl, CURLOPT_HEADER, false);// 不要http header 加快效率
#curl_setopt($curl, CURLOPT_HEADER, false);// 不要http header 加快效率
curl_setopt($curl, CURLOPT_RETURNTRANSFER,1); //设为TRUE把curl_exec()结果转化为字串,而不是直接输出
//SSL验证
//SSL验证
curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, FALSE); // https请求时要设置为false 不验证证书和hosts FALSE 禁止 cURL 验证对等证书(peer's certificate), 自cURL 7.10开始默认为 TRUE。从 cURL 7.10开始默认绑定安装。
curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, FALSE);//检查服务器SSL证书中是否存在一个公用名(common name)。
curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, FALSE);//检查服务器SSL证书中是否存在一个公用名(common name)。
$header[] = "Content-Type:application/json;charset=utf-8";
if(!empty($header)){
curl_setopt ( $curl, CURLOPT_HTTPHEADER, $header );//设置 HTTP 头字段的数组。格式: array('Content-type: text/plain', 'Content-length: 100')
}
if(!empty($header)){
curl_setopt ( $curl, CURLOPT_HTTPHEADER, $header );//设置 HTTP 头字段的数组。格式: array('Content-type: text/plain', 'Content-length: 100')
}
//请求时间
//请求时间
$timeout = 30;
curl_setopt ($curl, CURLOPT_CONNECTTIMEOUT, $timeout);//设置连接等待时间
curl_setopt ($curl, CURLOPT_CONNECTTIMEOUT, $timeout);//设置连接等待时间
//不同请求方法的数据提交
//不同请求方法的数据提交
switch ($method){
case "GET" :
curl_setopt($curl, CURLOPT_HTTPGET, true);//TRUE 时会设置 HTTP 的 method 为 GET,由于默认是 GET,所以只有 method 被修改时才需要这个选项。
break;
case "POST":
if(is_array($params)){
$params = json_encode($params,320);
}
$params = json_encode($params,320);
}
#curl_setopt($curl, CURLOPT_POST,true);//TRUE 时会发送 POST 请求,类型为:application/x-www-form-urlencoded,是 HTML 表单提交时最常见的一种。
#curl_setopt($curl, CURLOPT_NOBODY, true);//TRUE 时将不输出 BODY 部分。同时 Mehtod 变成了 HEAD。修改为 FALSE 时不会变成 GET。
curl_setopt($curl, CURLOPT_CUSTOMREQUEST, "POST");//HTTP 请求时,使用自定义的 Method 来代替"GET"或"HEAD"。对 "DELETE" 或者其他更隐蔽的 HTTP 请求有用。 有效值如 "GET","POST","CONNECT"等等;
... ... @@ -264,18 +278,77 @@ class HttpHelper
break;
}
//传递一个连接中需要的用户名和密码,格式为:"[username]:[password]"。
//传递一个连接中需要的用户名和密码,格式为:"[username]:[password]"。
if (!empty($auth) && isset($auth['username']) && isset($auth['password'])) {
curl_setopt($curl, CURLOPT_USERPWD, "{$auth['username']}:{$auth['password']}");
}
curl_setopt($curl, CURLOPT_USERPWD, "{$auth['username']}:{$auth['password']}");
}
$data = curl_exec($curl);//执行预定义的CURL
$status = curl_getinfo($curl, CURLINFO_HTTP_CODE);//获取http返回值,最后一个收到的HTTP代码
$data = curl_exec($curl);//执行预定义的CURL
$status = curl_getinfo($curl, CURLINFO_HTTP_CODE);//获取http返回值,最后一个收到的HTTP代码
curl_close($curl);//关闭cURL会话
// $res = json_decode($data,true);
return $data;
}
}
public function curlheader($url,$method,$params=[],$auth=[],$headers){
//初始化CURL句柄
$curl = curl_init();
curl_setopt($curl, CURLOPT_URL, $url);//设置请求的URL
curl_setopt($curl, CURLOPT_HEADER, false);// 不要http header 加快效率
curl_setopt($curl, CURLOPT_RETURNTRANSFER,1); //设为TRUE把curl_exec()结果转化为字串,而不是直接输出
//SSL验证
curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, FALSE); // https请求时要设置为false 不验证证书和hosts FALSE 禁止 cURL 验证对等证书(peer's certificate), 自cURL 7.10开始默认为 TRUE。从 cURL 7.10开始默认绑定安装。
curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, FALSE);//检查服务器SSL证书中是否存在一个公用名(common name)。
$header[] = "Content-Type:application/json;charset=utf-8;Authorization=eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJ1c2VybmFtZSI6IjE5OTY5MTA2NzEwIiwicGFzc3dvcmQiOiJhMGUxNWM0NDRmOGNiY2NiNTAwM2U1MDk5OGI2OGZhNyIsImV4cCI6MTczMTY2ODA5MSwiaXNzIjoidWltcyJ9.W3RBwrFdidL9ERykKC_gHtjp911xrkNvUKglSes1w7c";
if(!empty($header)){
curl_setopt ( $curl, CURLOPT_HTTPHEADER, $header );//设置 HTTP 头字段的数组。格式: array('Content-type: text/plain', 'Content-length: 100')
}
//请求时间
$timeout = 30;
curl_setopt ($curl, CURLOPT_CONNECTTIMEOUT, $timeout);//设置连接等待时间
//不同请求方法的数据提交
switch ($method){
case "GET" :
curl_setopt($curl, CURLOPT_HTTPGET, true);//TRUE 时会设置 HTTP 的 method 为 GET,由于默认是 GET,所以只有 method 被修改时才需要这个选项。
break;
case "POST":
if(is_array($params)){
$params = json_encode($params,320);
}
#curl_setopt($curl, CURLOPT_POST,true);//TRUE 时会发送 POST 请求,类型为:application/x-www-form-urlencoded,是 HTML 表单提交时最常见的一种。
#curl_setopt($curl, CURLOPT_NOBODY, true);//TRUE 时将不输出 BODY 部分。同时 Mehtod 变成了 HEAD。修改为 FALSE 时不会变成 GET。
curl_setopt($curl, CURLOPT_CUSTOMREQUEST, "POST");//HTTP 请求时,使用自定义的 Method 来代替"GET"或"HEAD"。对 "DELETE" 或者其他更隐蔽的 HTTP 请求有用。 有效值如 "GET","POST","CONNECT"等等;
//设置提交的信息
curl_setopt($curl, CURLOPT_POSTFIELDS,$params);//全部数据使用HTTP协议中的 "POST" 操作来发送。
break;
case "PUT" :
curl_setopt ($curl, CURLOPT_CUSTOMREQUEST, "PUT");
curl_setopt($curl, CURLOPT_POSTFIELDS,json_encode($params,320));
break;
case "DELETE":
curl_setopt ($curl, CURLOPT_CUSTOMREQUEST, "DELETE");
curl_setopt($curl, CURLOPT_POSTFIELDS,$params);
break;
}
//传递一个连接中需要的用户名和密码,格式为:"[username]:[password]"。
if (!empty($auth) && isset($auth['username']) && isset($auth['password'])) {
curl_setopt($curl, CURLOPT_USERPWD, "{$auth['username']}:{$auth['password']}");
}
$data = curl_exec($curl);//执行预定义的CURL
$status = curl_getinfo($curl, CURLINFO_HTTP_CODE);//获取http返回值,最后一个收到的HTTP代码
curl_close($curl);//关闭cURL会话
// $res = json_decode($data,true);
return $data;
}
}
... ...