ytapi/application/admin/common7.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_d".$device_id;
        $create_sql="
                            CREATE TABLE `".$device_table."` (
                              `id` int(11) unsigned NOT NULL AUTO_INCREMENT,
                              `device_code` varchar(30) DEFAULT NULL,
                              `port` varchar(55) DEFAULT NULL,
                              `time` datetime DEFAULT '2012-01-01',
                              `status` varchar(50) DEFAULT NULL,
                              `address` varchar(50) DEFAULT NULL,
                              `ncmd` varchar(50) DEFAULT NULL,
                              `data1` varchar(50) DEFAULT NULL,
                              `data2` varchar(255) DEFAULT NULL,
                              `data3` varchar(255) DEFAULT NULL,
                              `data4` varchar(255) DEFAULT NULL,
                              `data5` varchar(255) 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 SetAccess_Token(){

//    $url = 'https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid='.C('APPID').'&secret='.C('SECRET');
    $url = 'https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=wx9887f3618c8f2f6a&secret=5244b8cf7473c48fa546e436f28bad51';

    $curl = curl_init();

    curl_setopt($curl, CURLOPT_URL, $url);
    curl_setopt($curl, CURLOPT_RETURNTRANSFER, 1);
    curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, false);
    curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, false);
    $res= curl_exec($curl);
    curl_close($curl);
    return $res;
}

//function SetAccess_Token2(){
//
////    $url = 'https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid='.C('APPID').'&secret='.C('SECRET');
//    $url = 'https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=wx41e478e592f9e04a&secret=fc165de4aa5cd24b628baa30b100e146';
//
//    $curl = curl_init();
//
//    curl_setopt($curl, CURLOPT_URL, $url);
//    curl_setopt($curl, CURLOPT_RETURNTRANSFER, 1);
//    curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, false);
//    curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, false);
//    $res= curl_exec($curl);
//    curl_close($curl);
//    return $res;
//}

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'];
    }
}



//function GetAccess_Token2(){
//    $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);
//    while ($row = $time->fetch_assoc()) {
//        $list[]=$row;
//    }
//    $s=floor(strtotime(date('Y-m-d H:i:s'))-strtotime($list[1]['time']));
//    if($s > 5400){
//        $token=SetAccess_Token2();
//        $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 = 2";
//        $a=mysqli_query($link,$sql2);
//        Log::record('res789'.':'.$a);
//        mysqli_close($link);
//        return  $access['access_token'];
//    }else{
//        mysqli_close($link);
//        return  $list[1]['access_token'];
//    }
//}