ytapi/application/admin/common4.php.bak

<?php
use think\Log;
function allconfig()
{
	$config=array(
		"appId"=>"wvdOfp7JVe0ULwnFKwBF0edfbcAa",
		"secret"=>"Bihoe_rY9vebXMw6sFfpQy0jiRca",
		"host"=>"https://device.api.ct10649.com:8743/",
	);

	return $config;
}

function test()
{
  $token=json_encode(array("ji"=>"hdsj","ggdsc"=>"dcdf","jdfi"=>"hdsj","ggfddsc"=>"dcdf"));
  file_put_contents("./token11",$token);
  return file_get_contents("./token11");
}



//请求地址  参数  和 头部
function curl($url,$data='',$header="",$method="POST"){
  $ch = curl_init() ;
	    curl_setopt($ch, CURLOPT_URL, $url); 
       curl_setopt($ch, CURLOPT_HTTPHEADER,$header);
	   
     // curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, 4);
	    curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, 0); 
	    curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, 0);
	 /*   curl_setopt($ch, CURLOPT_USERAGENT, 'Mozilla/5.0 (compatible; MSIE 5.01; Windows NT 5.0)');*/
	//  curl_setopt($ch, CURLOPT_VERBOSE, 1); //debug模式 
		curl_setopt($ch, CURLOPT_SSLCERT, "./server.crt"); //client.crt文件路径 
		curl_setopt($ch, CURLOPT_SSLCERTPASSWD, "IoM@1234"); //client证书密码 
		curl_setopt($ch, CURLOPT_SSLKEY, "./server.key");
		if($method=="POST"||$method=="PUT"||$method=="DELETE"){
			curl_setopt($ch, CURLOPT_CUSTOMREQUEST, $method); 
	    	curl_setopt($ch, CURLOPT_POSTFIELDS, $data);
		}		
	    curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1); 
	    $info = curl_exec($ch);
	    $status = curl_getinfo($ch, CURLINFO_HTTP_CODE);
	    if (curl_errno($ch)) {
	    	return 'Errno'.curl_error($ch);
	    }else{ 
	    	return array($status,$info);
	    }
	    curl_close($ch);
}

//请求地址  参数  和 头部
function curltest($url,$data='',$header="",$method="POST"){
     $ch = curl_init() ;
    curl_setopt($ch, CURLOPT_URL, $url); 
    curl_setopt($ch, CURLOPT_HTTPHEADER,$header);
  
    if($method=="POST"||$method=="PUT"||$method=="DELETE"){
      curl_setopt($ch, CURLOPT_CUSTOMREQUEST, $method); 
        curl_setopt($ch, CURLOPT_POSTFIELDS, $data);
    }  


      curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1); 
      $info = curl_exec($ch);
      $status = curl_getinfo($ch, CURLINFO_HTTP_CODE);
      if (curl_errno($ch)) {
        return 'Errno'.curl_error($ch);
      }else{ 
        return array($status,$info);
      }
      curl_close($ch);
}

   //鉴权接口
	 function Auth()
    {
       	//	$config=     
            $data="appId=wvdOfp7JVe0ULwnFKwBF0edfbcAa&secret=Bihoe_rY9vebXMw6sFfpQy0jiRca";
            $header=[
                "Content-Type:application/x-www-form-urlencoded",       
           ];
              //  https://server:port/iocm/app/sec/v1.1.0/log
           $rescurl=curl("https://device.api.ct10649.com:8743/iocm/app/sec/v1.1.0/login",$data,$header);
         //  return $rescurl;
           if($rescurl[0]==200){
               $res=json_decode($rescurl[1],true);
               $res["token_time_out"]=$res['expiresIn']+time();
               $res["refresh_token_time_out"]=time()+86400*7;
               $result=json_encode($res);
                 file_put_contents("./token.json",$result);
                return $result;
           }else{
                return $rescurl[1];
           }
          
                      

    }

    //刷新token并返回新的token
    function refreshtoken(){
        $token=session("token");
        //查看刷新token是否过期，过期了调鉴权接口，没过期调刷新
        if($token["refresh_token_time_out"]>=time()){//刷新
        
            $data=[
                "appId"=>"wvdOfp7JVe0ULwnFKwBF0edfbcAa",
                "secret"=>"Bihoe_rY9vebXMw6sFfpQy0jiRca",
                "refreshToken"=>$token["refreshToken"],
             ];
            $header=[
                "Content-Type:application/json",       
                ];            
               $rescurl=curl("https://device.api.ct10649.com:8743/iocm/app/sec/v1.1.0/refreshToken",json_encode($data),$header);

              if($rescurl[0]==200){
                $res=json_decode($rescurl[1],true);             
                 $res["token_time_out"]=time()+$res['expiresIn'];
                 $res["refresh_token_time_out"]=time()+86400*7;
                 //session('token',$res);//
                 $result=json_encode($res);
                 file_put_contents("./token.json",$result);
                  return $result;
              }else{
                return $rescurl[1];
                
              }

               
             

        }else{//鉴权
            return Auth();

        }
                
    }

    //获取token
   function gettoken(){
        //判断是否设置session以及session里的token是否过期
        if(file_exists("./token.json")){
            $token=json_decode(file_get_contents('./token.json'),true);    
            if($token['token_time_out']>=time()){//还没有过期直接返回token；
                return json_encode($token);
            }else{
                return refreshtoken();
            }
        }else{

            return Auth();             
        }
    }
function addtable($device_id,$deviceType){

    if ($deviceType=='Smoke') {
        $device_table = "sp_" . "y" . $device_id;
        $create_sql = "
                            CREATE TABLE `" . $device_table . "` (
                              `id` int(11) unsigned NOT NULL AUTO_INCREMENT,
                              `device_id` varchar(200) DEFAULT NULL,
                              `RSRQ` varchar(255) DEFAULT NULL,
                              `CSQ` varchar(255) DEFAULT NULL,
                              `DeviceType` varchar(50) DEFAULT NULL,
                              `DeviceStatus` varchar(50) DEFAULT NULL,
                              `BatteryLevel` varchar(50) DEFAULT NULL,
                              `SensorLevel` varchar(50) DEFAULT NULL,
                              `eventTime` varchar(50) DEFAULT NULL,
                              `storeTime` varchar(50) DEFAULT NULL,
                              PRIMARY KEY (`id`)
                            ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
                        ";


    }else{
        $device_table="sp_"."s".$device_id;
        $create_sql="
                            CREATE TABLE `".$device_table."` (
                              `id` int(11) unsigned NOT NULL AUTO_INCREMENT,
                              `device_id` varchar(200) DEFAULT NULL,
                              `messageId` varchar(255) DEFAULT NULL,
                              `batteyValue` varchar(255) DEFAULT NULL,
                              `sensorIdStart` varchar(50) DEFAULT NULL,
                              `sensorid` varchar(50) DEFAULT NULL,
                              `alarmBoolean` varchar(50) DEFAULT NULL,
                              `unit` varchar(50) DEFAULT NULL,
                              `data` varchar(50) DEFAULT NULL,
                              `eventTime` varchar(255) DEFAULT NULL,
                              `storeTime` varchar(50) DEFAULT NULL,
                              PRIMARY KEY (`id`)
                            ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
                        ";
//        $result = mysqli_query($link,$create_sql);
    }
    sql_exec($create_sql);
}

function sql_exec($sql){
    $link = mysqli_connect('47.98.201.187', 'root', 'Yt2018IoT', 'jdxf', 3306);
    if (!$link) { die("连接失败: " . mysqli_connect_error()); }
    $result = mysqli_query($link,$sql);
    //mysqli_free_result($result);
    mysqli_close($link);
}
function addDataInfo($sql)
{
    Log::record('sql123'.':'.$sql);
    $link = mysqli_connect('47.98.201.187', 'root', 'Yt2018IoT', 'jdxf', 3306);
    mysqli_query($link,"set character set 'utf8'");
            $res1 = mysqli_query($link,$sql);
    Log::record('res123'.':'.$res1);
        //mysqli_free_result($res1);
        mysqli_close($link);
        return $res1;

}
function add($sql)
{
    $link = mysqli_connect('47.98.201.187', 'root', 'Yt2018IoT', 'jdxf', 3306);
    mysqli_query($link,"set character set 'utf8'");
    $res1 = mysqli_query($link,$sql);
//    Log::record('res'.':'.$res1);
    while ($row = $res1->fetch_assoc()) {
        $list[]=$row;
        //print_r($row);
    }
    mysqli_free_result($res1);
    mysqli_close($link);
    return $list;

}
function address()
{
    $link = mysqli_connect('47.98.201.187', 'root', 'Yt2018IoT', 'jdxf', 3306);
    mysqli_query($link,"set character set 'utf8'");
    $sql="SELECT owner_name,owner_id FROM sp_owner_company";
    $res1 = mysqli_query($link,$sql);
    while ($row = $res1->fetch_assoc()) {
        $list[]=$row;
        //print_r($row);
    }
    mysqli_free_result($res1);
    mysqli_close($link);
    return $list;

}
function owner($device_id)
{
    $link = mysqli_connect('47.98.201.187', 'root', 'Yt2018IoT', 'jdxf', 3306);
    mysqli_query($link,"set character set 'utf8'");
    $sql="SELECT company,louyu,unitinfo FROM sp_owner WHERE owner_code = '$device_id'";
    $res1 = mysqli_query($link,$sql);
    $row = $res1->fetch_assoc();
    mysqli_free_result($res1);
    mysqli_close($link);
    return $row;

}
function deviceStatus($device_id)
{
    $link = mysqli_connect('47.98.201.187', 'root', 'Yt2018IoT', 'jdxf', 3306);
    mysqli_query($link,"set character set 'utf8'");
    $sql="SELECT statustime FROM sp_devices_status WHERE deviceid = '$device_id'";
    $res1 = mysqli_query($link,$sql);
    $row = $res1->fetch_assoc();
    mysqli_free_result($res1);
    mysqli_close($link);
    return $row;

}
function GetAccess_Token(){
    $link = mysqli_connect('47.98.201.187', 'root', 'Yt2018IoT', 'jdxf', 3306);
    mysqli_query($link,"set character set 'utf8'");
    $sql="SELECT time,access_token FROM sp_access_token";
    $time= mysqli_query($link,$sql);
//    $User = M('access_token');
//    $time=$User->field('time,access_token')->select();
    while ($row = $time->fetch_assoc()) {
        $list[]=$row;
        //print_r($row);
    }
    $s=floor(strtotime(date('Y-m-d H:i:s'))-strtotime($list[0]['time']));
    if($s > 5400){
        $token=SetAccess_Token();
        $access=json_decode($token,true);
        $sql2="UPDATE sp_access_token SET 'access_token' = {$access['access_token']},'time'=date('Y-m-d H:i:s') WHERE id = 1";
        $a=mysqli_query($link,$sql2);
        Log::record('res789'.':'.$a);
//        $a=$User->where('id=1')->save(array('access_token'=> $access['access_token'],'time'=> date('Y-m-d H:i:s')));
//        mysqli_free_result($time);
        mysqli_close($link);
        return  $access['access_token'];
    }else{
//        mysqli_free_result($time);
        mysqli_close($link);
        return  $list[0]['access_token'];
    }
}