USKYZHAF/Home/Common/function.php.bak.2021-12-13

<?php
header('content-type:text/html;charset=utf-8');
//这里开始
function query_187_jdxf($sql)
{
    $link = mysqli_connect('47.98.201.187', 'root', 'Yt2018IoT', 'jdxf', 3306);
    mysqli_query($link, "set character set 'utf8'");
    $res1 = mysqli_query($link, $sql);
    if ($res1 == FALSE) {
        return $list = null;
    }
    $list = array();
    while ($row = $res1->fetch_assoc()) {
        $list[] = $row;
    }
    mysqli_free_result($res1);
    mysqli_close($link);
    return $list;
}

function insert_187_jdxf($sql)
{
    $link = mysqli_connect('47.98.201.187', 'root', 'Yt2018IoT', 'jdxf', 3306);
    mysqli_query($link, "set character set 'utf8'");
    $res1 = mysqli_query($link, $sql);
    mysqli_close($link);
    return $res1;

}

function query_187_ytapi($sql)
{
    $link = mysqli_connect('47.98.201.187', 'root', 'Yt2018IoT', 'ytapi', 3306);
    mysqli_query($link, "set character set 'utf8'");
    $res1 = mysqli_query($link, $sql);
    if ($res1 == FALSE) {
        return $list = null;
    }
    $list = array();
    while ($row = $res1->fetch_assoc()) {
        $list[] = $row;
    }
    mysqli_free_result($res1);
    mysqli_close($link);
    return $list;
}

function insert_187_ytapi($sql)
{
    $link = mysqli_connect('47.98.201.187', 'root', 'Yt2018IoT', 'ytapi', 3306);
    mysqli_query($link, "set character set 'utf8'");
    $res1 = mysqli_query($link, $sql);
    mysqli_close($link);
    return $res1;

}

function query_187_ytIoT($sql)
{
    $link = mysqli_connect('47.98.201.187', 'root', 'Yt2018IoT', 'ytIoT', 3306);
    mysqli_query($link, "set character set 'utf8'");
    $res1 = mysqli_query($link, $sql);
    if ($res1 == FALSE) {
        return $list = null;
    }
    $list = array();
    while ($row = $res1->fetch_assoc()) {
        $list[] = $row;
    }
    mysqli_free_result($res1);
    mysqli_close($link);
    return $list;
}

function insert_187_ytIoT($sql)
{
    $link = mysqli_connect('47.98.201.187', 'root', 'Yt2018IoT', 'ytIoT', 3306);
    mysqli_query($link, "set character set 'utf8'");
    $res1 = mysqli_query($link, $sql);
    mysqli_close($link);
    return $res1;

}

function http_post_advertise($url, $data)
{        //封装curl方法
    $ch = curl_init();     //初始化
    curl_setopt($ch, CURLOPT_URL, $url);      //请求地址
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
    curl_setopt($ch, CURLOPT_POST, true);
//https协议需要以下两行，否则请求不成功
    curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, FALSE);
    curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
//post方法所需要的参数
    curl_setopt($ch, CURLOPT_POSTFIELDS, $data);
//    curl_setopt($ch, CURLOPT_HTTPHEADER,array());
    $result = curl_exec($ch);
    curl_close($ch);
    return $result;        //返回所获取的方法
}

function ytapi187_query($sql)
{
    $link = mysqli_connect('47.98.201.187', 'root', 'Yt2018IoT', 'ytapi', 3306);
    mysqli_query($link, "set character set 'utf8'");
    $res1 = mysqli_query($link, $sql);
    if ($res1 == FALSE) {
        return $list = null;
    }
    $list = array();
    while ($row = $res1->fetch_assoc()) {
        $list[] = $row;
    }
    mysqli_free_result($res1);
    mysqli_close($link);
    return $list;

}

function ytapi187_inset($sql)
{
    $link = mysqli_connect('47.98.201.187', 'root', 'Yt2018IoT', 'ytapi', 3306);
    mysqli_query($link, "set character set 'utf8'");
    $res1 = mysqli_query($link, $sql);
    mysqli_close($link);
    return $res1;

}

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;
                        ";
    }
    return $create_sql;
}

//function sql_exec($sql){
//    $link = mysqli_connect('47.98.201.187', 'root', 'Yt2018IoT', 'jdxf', 3306);
//    mysqli_query($link,"set character set 'utf8'");
//    mysqli_query($link,$sql);
//    mysqli_close($link);
//}

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 gettoken()
{
    if (file_exists("./token.json")) {
        $token = json_decode(file_get_contents('./token.json'), true);

        if ($token['token_time_out'] >= time()) {
            return json_encode($token);
        } else {

            return refreshtoken();
        }
    } else {
        return Auth();
    }
}


function gettoken1()
{
    if (file_exists("./token1.json")) {
        $token = json_decode(file_get_contents('./token1.json'), true);

        if ($token['token_time_out'] >= time()) {
            return json_encode($token);
        } else {

            return refreshtoken1();
        }
    } else {
        return Auth1();
    }
}

function Auth()
{


    $data = "appId=wvdOfp7JVe0ULwnFKwBF0edfbcAa&secret=Bihoe_rY9vebXMw6sFfpQy0jiRca";
    $header = [
        "Content-Type:application/x-www-form-urlencoded",
    ];
    $rescurl = curl("https://device.api.ct10649.com:8743/iocm/app/sec/v1.1.0/login", $data, $header);
//    echo $rescurl;
//    exit();
//    echo '第一'.$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];
    }
}

function Auth1()
{


    $data = "appId=bIS92ndpAf_fhmPdLaNuTidbFfka&secret=NZMe1G42OdSmzlEuDpR_3ywKPhIa";
    $header = [
        "Content-Type:application/x-www-form-urlencoded",
    ];
    $rescurl = curl("https://device.api.ct10649.com:8743/iocm/app/sec/v1.1.0/login", $data, $header);
//    echo $rescurl;
//    exit();
//    echo '第一'.$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("./token1.json", $result);
        return $result;
    } else {
        return $rescurl[1];
    }
}

function refreshtoken()
{

    $token = session("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();
    }

}

function refreshtoken1()
{

    $token = session("token");
    if ($token["refresh_token_time_out"] >= time()) {
        $data = [
            "appId" => "bIS92ndpAf_fhmPdLaNuTidbFfka",
            "secret" => "NZMe1G42OdSmzlEuDpR_3ywKPhIa",
            "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("./token1.json", $result);
            return $result;
        } else {
            return $rescurl[1];
        }
    } else {

        return Auth1();
    }

}

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");
    curl_setopt($ch, CURLOPT_SSLCERTPASSWD, "IoM@1234");
    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)) {
        $infores = 'Errno' . curl_error($ch);
    } else {
        $infores = array($status, $info);
    }
    curl_close($ch);
    return $infores;
}

function http_post($url, $post, $timeout)
{
    $curl = curl_init();
    curl_setopt($curl, CURLOPT_URL, $url);
    curl_setopt($curl, CURLOPT_POST, 1);
    curl_setopt($curl, CURLOPT_POSTFIELDS, $post);
//    curl_setopt($curl, CURLOPT_TIMEOUT, $timeout);
    curl_setopt($curl, CURLOPT_RETURNTRANSFER, 1);
    $output = curl_exec($curl);
    $code = curl_getinfo($curl, CURLINFO_HTTP_CODE);
    $errMsg = curl_multi_getcontent($curl);
    if (curl_errno($curl)) {
        $infores = 'Errno' . curl_error($curl);
    } else {
        $infores = array($code, $output);
    }
    curl_close($curl);
    return $infores;
}

function json_post($url, $data)
{

    $curl = curl_init();
    curl_setopt($curl, CURLOPT_URL, $url);
    curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, false);
    curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, false);
    if (!$data) {
        return 'data is null';
    }
    if (is_array($data)) {
        $data = json_encode($data);
    }
    curl_setopt($curl, CURLOPT_POST, 1);
    curl_setopt($curl, CURLOPT_POSTFIELDS, $data);
    curl_setopt($curl, CURLOPT_HEADER, 0);
    curl_setopt($curl, CURLOPT_HTTPHEADER, array(
        'Content-Type: application/json; charset=utf-8',
        'Content-Length:' . strlen($data),
        'Cache-Control: no-cache',
        'Pragma: no-cache'
    ));
    curl_setopt($curl, CURLOPT_RETURNTRANSFER, 1);
    $res = curl_exec($curl);
    $errorno = curl_errno($curl);
    if ($errorno) {
        return $errorno;
    }
    curl_close($curl);
    return $res;
}

function curl_get($url)
{

    $header = array(
        'Accept: application/json',
    );
    $curl = curl_init();
    //设置抓取的url
    curl_setopt($curl, CURLOPT_URL, $url);
    //设置头文件的信息作为数据流输出
    curl_setopt($curl, CURLOPT_HEADER, 0);
    // 超时设置,以秒为单位
    curl_setopt($curl, CURLOPT_TIMEOUT, 1);

    // 超时设置，以毫秒为单位
    // curl_setopt($curl, CURLOPT_TIMEOUT_MS, 500);

    // 设置请求头
    curl_setopt($curl, CURLOPT_HTTPHEADER, $header);
    //设置获取的信息以文件流的形式返回，而不是直接输出。
    curl_setopt($curl, CURLOPT_RETURNTRANSFER, 1);
    curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, false);
    curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, false);
    //执行命令
    $data = curl_exec($curl);
    $errorno=curl_error($curl);

    // 显示错误信息
    if ($errorno) {
        return $errorno;
    }
    curl_close($curl);
    return $data;
}

function array_column($arr2, $column_key) {
    $data = [];
    foreach ($arr2 as $key => $value) {
        $data[] = $value[$column_key];
    }
    return $data;
}