ytapi/application/admin/common.php.bak.20201204

<?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 crc166($string, $length = 0) {
         $auchCRCHi = array(0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81,
             0x40, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0,
             0x80, 0x41, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x00, 0xC1, 0x81, 0x40, 0x01,
             0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0, 0x80, 0x41,
             0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x00, 0xC1, 0x81,
             0x40, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0,
             0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01,
             0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40,
             0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81,
             0x40, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0,
             0x80, 0x41, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x00, 0xC1, 0x81, 0x40, 0x01,
             0xC0, 0x80, 0x41, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41,
             0x00, 0xC1, 0x81, 0x40, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81,
             0x40, 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0,
             0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01,
             0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81, 0x40, 0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41,
             0x00, 0xC1, 0x81, 0x40, 0x01, 0xC0, 0x80, 0x41, 0x01, 0xC0, 0x80, 0x41, 0x00, 0xC1, 0x81,
             0x40);
         $auchCRCLo = array(0x00, 0xC0, 0xC1, 0x01, 0xC3, 0x03, 0x02, 0xC2, 0xC6, 0x06, 0x07, 0xC7, 0x05, 0xC5, 0xC4,
             0x04, 0xCC, 0x0C, 0x0D, 0xCD, 0x0F, 0xCF, 0xCE, 0x0E, 0x0A, 0xCA, 0xCB, 0x0B, 0xC9, 0x09,
             0x08, 0xC8, 0xD8, 0x18, 0x19, 0xD9, 0x1B, 0xDB, 0xDA, 0x1A, 0x1E, 0xDE, 0xDF, 0x1F, 0xDD,
             0x1D, 0x1C, 0xDC, 0x14, 0xD4, 0xD5, 0x15, 0xD7, 0x17, 0x16, 0xD6, 0xD2, 0x12, 0x13, 0xD3,
             0x11, 0xD1, 0xD0, 0x10, 0xF0, 0x30, 0x31, 0xF1, 0x33, 0xF3, 0xF2, 0x32, 0x36, 0xF6, 0xF7,
             0x37, 0xF5, 0x35, 0x34, 0xF4, 0x3C, 0xFC, 0xFD, 0x3D, 0xFF, 0x3F, 0x3E, 0xFE, 0xFA, 0x3A,
             0x3B, 0xFB, 0x39, 0xF9, 0xF8, 0x38, 0x28, 0xE8, 0xE9, 0x29, 0xEB, 0x2B, 0x2A, 0xEA, 0xEE,
             0x2E, 0x2F, 0xEF, 0x2D, 0xED, 0xEC, 0x2C, 0xE4, 0x24, 0x25, 0xE5, 0x27, 0xE7, 0xE6, 0x26,
             0x22, 0xE2, 0xE3, 0x23, 0xE1, 0x21, 0x20, 0xE0, 0xA0, 0x60, 0x61, 0xA1, 0x63, 0xA3, 0xA2,
             0x62, 0x66, 0xA6, 0xA7, 0x67, 0xA5, 0x65, 0x64, 0xA4, 0x6C, 0xAC, 0xAD, 0x6D, 0xAF, 0x6F,
             0x6E, 0xAE, 0xAA, 0x6A, 0x6B, 0xAB, 0x69, 0xA9, 0xA8, 0x68, 0x78, 0xB8, 0xB9, 0x79, 0xBB,
             0x7B, 0x7A, 0xBA, 0xBE, 0x7E, 0x7F, 0xBF, 0x7D, 0xBD, 0xBC, 0x7C, 0xB4, 0x74, 0x75, 0xB5,
             0x77, 0xB7, 0xB6, 0x76, 0x72, 0xB2, 0xB3, 0x73, 0xB1, 0x71, 0x70, 0xB0, 0x50, 0x90, 0x91,
             0x51, 0x93, 0x53, 0x52, 0x92, 0x96, 0x56, 0x57, 0x97, 0x55, 0x95, 0x94, 0x54, 0x9C, 0x5C,
             0x5D, 0x9D, 0x5F, 0x9F, 0x9E, 0x5E, 0x5A, 0x9A, 0x9B, 0x5B, 0x99, 0x59, 0x58, 0x98, 0x88,
             0x48, 0x49, 0x89, 0x4B, 0x8B, 0x8A, 0x4A, 0x4E, 0x8E, 0x8F, 0x4F, 0x8D, 0x4D, 0x4C, 0x8C,
             0x44, 0x84, 0x85, 0x45, 0x87, 0x47, 0x46, 0x86, 0x82, 0x42, 0x43, 0x83, 0x41, 0x81, 0x80,
             0x40);
         $length = ($length <= 0 ? strlen($string) : $length);
         $uchCRCHi = 0xFF;
         $uchCRCLo = 0xFF;
         $uIndex = 0;
         for ($i = 0; $i < $length; $i++) {
             $uIndex = $uchCRCLo ^ ord(substr($string, $i, 1));
             $uchCRCLo = $uchCRCHi ^ $auchCRCHi[$uIndex];
             $uchCRCHi = $auchCRCLo[$uIndex];
         }
         return(chr($uchCRCHi) . chr($uchCRCLo));
   }

/**
 * 将一个字符按比特位进行反转 eg: 65 (01000001) --> 130(10000010)
 * @param $char
 * @return $char
 */
function reverseChar($char) {
    $byte = ord($char);
    $tmp = 0;
    for ($i = 0; $i < 8; ++$i) {
        if ($byte & (1 << $i)) {
            $tmp |= (1 << (7 - $i));
        }
    }
    return chr($tmp);
}

/**
 * 将一个字节流按比特位反转 eg: 'AB'(01000001 01000010)  --> '\x42\x82'(01000010 10000010)
 * @param $str
 */
function reverseString($str) {
    $m = 0;
    $n = strlen($str) - 1;
    while ($m <= $n) {
        if ($m == $n) {
            $str{$m} = reverseChar($str{$m});
            break;
        }
        $ord1 = reverseChar($str{$m});
        $ord2 = reverseChar($str{$n});
        $str{$m} = $ord2;
        $str{$n} = $ord1;
        $m++;
        $n--;
    }
    return $str;
}

/**
 * @param string $str 待校验字符串
 * @param int $polynomial 二项式
 * @param int $initValue 初始值
 * @param int $xOrValue 输出结果前异或的值
 * @param bool $inputReverse 输入字符串是否每个字节按比特位反转
 * @param bool $outputReverse 输出是否整体按比特位反转
 * @return int
 */
function crc16($str, $polynomial, $initValue, $xOrValue, $inputReverse = false, $outputReverse = false) {
    $crc = $initValue;

    for ($i = 0; $i < strlen($str); $i++) {
        if ($inputReverse) {
            // 输入数据每个字节按比特位逆转
            $c = ord(reverseChar($str{$i}));
        } else {
            $c = ord($str{$i});
        }
        $crc ^= ($c << 8);
        for ($j = 0; $j < 8; ++$j) {
            if ($crc & 0x8000) {
                $crc = (($crc << 1) & 0xffff) ^ $polynomial;
            } else {
                $crc = ($crc << 1) & 0xffff;
            }
        }
    }
    if ($outputReverse) {
        // 把低地址存低位，即采用小端法将整数转换为字符串
        $ret = pack('cc', $crc & 0xff, ($crc >> 8) & 0xff);
        // 输出结果按比特位逆转整个字符串
        $ret = reverseString($ret);
        // 再把结果按小端法重新转换成整数
        $arr = unpack('vshort', $ret);
        $crc = $arr['short'];
    }
    return $crc ^ $xOrValue;
}


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);
    $list=array();
    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'];
//    }
//}