ytapi/application/admin/controller/Manage.php.bak.20220227

<?php
namespace app\admin\controller;
use think\Controller;
use think\Session;
use think\Db;
use think\Request;
use think\Log;
class Manage extends Controller
{  
 	private $host="https://device.api.ct10649.com:8743/";
    private $appId="wvdOfp7JVe0ULwnFKwBF0edfbcAa";
    private $secret="Bihoe_rY9vebXMw6sFfpQy0jiRca";

 	public function index(){
 		$data_list =Db::table('managelog')->paginate();
        $pages = $data_list->render();        
        $this->assign('data_list', $data_list);
        $this->assign('pages', $pages); 


        	//所有的服务类型
        $SetType=[
        	1=>"读取模块信息",
        	2=>"读取参数",
        	3=>"设置IOT平台IP地址",
        	4=>"设置参数",
        	5=>"复位模块",
        	6=>"配置下行波特率",
        	7=>"读取下行波特率配置",
        	8=>"设置DTU自动采集指令",
        	9=>"读取DTU自动采集指令",
        	10=>"设置APN",
        	11=>"读取APN设置",
        	12=>"AT指令",

   /*     		[1,"读取模块信息"],[2,"读取参数"],[3,"设置IOT平台IP地址"],[4,"设置参数"],[5,"复位模块"],[6,"配置下行波特率"],
        		[7,"读取下行波特率配置"],[8,"设置DTU自动采集指令"],[9,"读取DTU自动采集指令"],[10,"设置APN"],[11,"读取APN设置"],
        		[12,"AT指令"]*/
        ];

        $this->assign('SetType',$SetType);
        
        return $this->fetch();


 	}
 	//下发命令
 	public function add(){

 		if ($this->request->isPost()) {
            $data=input('');
            $list = array();
            if (is_array($data)) {
                $list['data'] = json_encode($data, 320);
                $getdata = json_decode($list['data'], true);//转成数组
                $list['type'] = 1;
            } else {
                $list['data'] = $data;
                $getdata = json_decode($list['data'], true);//转成数组
                $list['type'] = 2;
            }
            $json_string = json_encode($getdata, JSON_FORCE_OBJECT);
            Log::record('rawData:' .$list['data'] );
            $paras = array();
            $upData = array();
            if(!empty($getdata["dataType"])){
                if($getdata['dataType']=="setting"){
                    $sql6="select * from sp_owner where id ={$getdata['sensorId']}";
                    $longHuOwner = add($sql6);
                    if ($longHuOwner[0]['s_interval']==7){
                        $imei='&imei='.$longHuOwner[0]['owner_code'];
                        if($longHuOwner[0]['dwtype']==2){
                            $deviceType=1;
                        }elseif ($longHuOwner[0]['dwtype']==5){
                            $deviceType=2;
                        }
                        $sendata['imei']=$longHuOwner[0]['owner_code'];
                        $sendata['deviceType']=$deviceType;
                        $sendingGap = '';
                        if (!empty($getdata["sendTime"])){
                            if($getdata['sendTime']<1800) {
                                $sendingGap = '&sendingGap=1800';
                                $upData['send_time'] = 1800;
                                $sendata['sendingGap']=1800;
                            }else{
                                $sendingGap = '&sendingGap='.$getdata["sendTime"];
                                $upData['send_time'] = $getdata["sendTime"];
                                $sendata['sendingGap']=$getdata["sendTime"];
                            }
                        }
                        $unipathThresholdLimit = '';
                        if (!empty($getdata["lowThreshold"])){
                            $sendata['unipathThresholdLimit'] = $getdata["lowThreshold"]*1000;
                            $upData['low_threshold'] = $getdata['lowThreshold'];
                        }
                        $unipathThresholdUpper = '';
                        if (!empty($getdata["highThreshold"])){
                            $sendata['unipathThresholdUpper'] = $getdata["highThreshold"]*1000;
                            $upData['high_threshold'] = $getdata['highThreshold'];
                        }

                        $header=[
                            "Content-Type:application/json"
                        ];
                        $rescurl=$this->s_curl("https://api.topsailiot.com/dmp/deviceConfig?appkey=3a3e533818a9604dfec0388b2d817dbc2f9f7b05dd4b153c403897cd93a9c04d0edfe3d86ebd3ad0&userid=TS2020120110122980052",json_encode($sendata),$header);
//                        $rep_url = "https://api.topsailiot.com/dmp/deviceConfig?appkey=3a3e533818a9604dfec0388b2d817dbc2f9f7b05dd4b153c403897cd93a9c04d0edfe3d86ebd3ad0&userid=TS2020120110122980052".$imei.$deviceType.$sendingGap.$unipathThresholdLimit.$unipathThresholdUpper;
//                        $res = $this->s_curl($rep_url,'');
                        Log::record('longhulorasend' . ':' . json_encode($sendata));
                        Log::record('longhuloraresult' . ':' . $rescurl);
//                        if (is_array($rescurl)) {
//
//                        }else{}
                        $resArr = json_decode($rescurl,true);
                        if ($resArr['code']==0){
                            $deviceConfigure = Db::name('deviceConfigure')->where('device_code', trim($longHuOwner[0]['owner_code']))->find();
                            if (!empty($deviceConfigure['device_code'])) {
                                sleep(1);
                                $upDataRes = Db::name('deviceConfigure')->where('device_code', trim($longHuOwner[0]['owner_code']))->update($upData);
                            }else{
                                sleep(1);
                                $upData['device_code'] = $longHuOwner[0]['owner_code'];
                                $insertRes = Db::name('deviceConfigure')->insertGetId($upData);
                            }
                        }
                        return $rescurl;
                    }else{
                        $deviceCode = '';
                        $deviceArr = str_split($longHuOwner[0]['owner_code'],1);
                        for ($i=0;$i<count($deviceArr);$i++){
                            $deviceCode.='3'.$deviceArr[$i];
                        }
                        $deviceCode = $deviceCode.'30';
                        $sendingInterval = "";//发送间隔
                        if (!empty($getdata['sendTime'])) {
                            if($getdata['sendTime']<1800){
                                $sendingInterval = "020400000708";
                                $upData['send_time'] = 1800;
                            }else{
                                $liuSendTime1 = dechex($getdata['sendTime']);
                                $liuSendTime = str_pad($liuSendTime1,8,0,STR_PAD_LEFT);
                                $sendingInterval = "0204".$liuSendTime;
                                $upData['send_time'] = $getdata['sendTime'];
                            }
                        }
                        $lowThreshold = "";//告警下限
                        if (!empty($getdata['lowThreshold'])) {
                            $shiLowThreshold = $getdata['lowThreshold']*1000;
                            $liuLowThreshold1 = dechex($shiLowThreshold);
                            $liuLowThreshold = str_pad($liuLowThreshold1,4,0,STR_PAD_LEFT);
                            $lowThreshold = "0602".$liuLowThreshold;
                            $upData['low_threshold'] = $getdata['lowThreshold'];
                        }
                        $highThreshold = "";//告警上限
                        if (!empty($getdata['highThreshold'])) {
                            $shiHighThreshold = $getdata['highThreshold']*1000;
                            $liuHighThreshold1 = dechex($shiHighThreshold);
                            $liuHighThreshold = str_pad($liuHighThreshold1,4,0,STR_PAD_LEFT);
                            $highThreshold = "0702".$liuHighThreshold;
                            $upData['high_threshold'] = $getdata['highThreshold'];
                        }
                        if($longHuOwner[0]['dwtype']==2){
                            $dwType = "01";
                        }elseif ($longHuOwner[0]['dwtype']==5){
                            $dwType = "02";
                        }
                        $shiLength = strlen($dwType.$deviceCode.$sendingInterval.$lowThreshold.$highThreshold)/2;
                        $liuLength = dechex($shiLength);
                        $length = str_pad($liuLength,4,0,STR_PAD_LEFT);
                        //调用电信接口
                        $token=json_decode(gettoken(),true);
                        $a = "7470736c04".$length.$dwType.$deviceCode.$sendingInterval.$lowThreshold.$highThreshold;
                        $s = pack('H*',$a);
                        $t = crc166($s);
                        $t = unpack("H*", $s.$t);
                        $paras['value'] = $t[1]."696f74";
                        //            $t = crc16($paras['value'],0X1021,0Xffff,0X0000,false,false);
                        $device = Db::name('device')->where('device_id', trim($longHuOwner[0]['owner_code']))->find();
                        $sendata=[
                            "appId"=>$this->appId,
                            "deviceId"=>$device['iot_id'],//  c448d5e3-2ec5-4e42-99d7-0ad27668614f  137effbe-4980-4719-a768-0ae301fc5000
                            "command"=>[
                                "serviceId"=>"topsailSensorData",
                                "method"=>"SET_DEVICE_LEVEL",
                                "paras"=>$paras
                            ],
                            "callbackUrl"=>"http://iot.usky.cn:80/ytapi/admin/Manage/status",
                        ];
                        $header=[
                            "Content-Type:application/json",
                            "app_key:".$this->appId,
                            "Authorization:Bearer ".$token["accessToken"]
                        ];
                        $rescurl=curl($this->host."iocm/app/cmd/v1.4.0/deviceCommands",json_encode($sendata),$header);
//                var_dump($rescurl);
                        Log::record('nbmanage1:' .$rescurl[0].$sendata['command']['paras']['value'] );
                        if($rescurl[0]==201){//成功
                            $res1=json_decode($rescurl[1],true);
//                    var_dump($res1);
                        }else{//失败
                            //  $res2=json_decode($res1[1],true);
//                    return $this->error($rescurl[1]);
                            Log::record('nbmanageerror:' .json_encode($this->error($rescurl[1])));
                            $returnInformation['code'] = 60001;
                            $returnInformation['msg'] = "操作失败，请联系管理员";
                            return json_encode($returnInformation);
                        }
                    }
                }else if($getdata['dataType']=="bendi"){
                    $deviceCode = '';
                    $deviceArr = str_split($getdata['IMEI'],1);
                    for ($i=0;$i<count($deviceArr);$i++){
                        $deviceCode.='3'.$deviceArr[$i];
                    }
                    $deviceCode = $deviceCode.'30';
                    //调用电信接口
                    $collectionInterval = "";//发送间隔
                    if (!empty($getdata['collectionTime'])) {
                        $liuCollectionTime1 = dechex($getdata['collectionTime']);
                        $liuCollectionTime = str_pad($liuCollectionTime1,8,0,STR_PAD_LEFT);
                        $collectionInterval = "0104".$liuCollectionTime;
                    }
                    $sendingInterval = "";//发送间隔
                    if (!empty($getdata['sendTime'])) {
                        $liuSendTime1 = dechex($getdata['sendTime']);
                        $liuSendTime = str_pad($liuSendTime1,8,0,STR_PAD_LEFT);
                        $sendingInterval = "0204".$liuSendTime;
                    }
                    $lowThreshold = "";//告警下限
                    if (!empty($getdata['alarmLowerLimit'])) {
                        $shiLowThreshold = $getdata['alarmLowerLimit']*1000;
                        $liuLowThreshold1 = dechex($shiLowThreshold);
                        $liuLowThreshold = str_pad($liuLowThreshold1,4,0,STR_PAD_LEFT);
                        $lowThreshold = "0602".$liuLowThreshold;
                    }
                    $highThreshold = "";//告警上限
                    if (!empty($getdata['alarmUpperLimit'])) {
                        $shiHighThreshold = $getdata['alarmUpperLimit']*1000;
                        $liuHighThreshold1 = dechex($shiHighThreshold);
                        $liuHighThreshold = str_pad($liuHighThreshold1,4,0,STR_PAD_LEFT);
                        $highThreshold = "0702".$liuHighThreshold;
                    }
                    if($getdata['deviceType']==2){
                        $dwType = "01";
                    }elseif ($getdata['deviceType']==5){
                        $dwType = "02";
                    }
                    $shiLength = strlen($dwType.$deviceCode.$collectionInterval.$sendingInterval.$lowThreshold.$highThreshold)/2;
                    $liuLength = dechex($shiLength);
                    $length = str_pad($liuLength,4,0,STR_PAD_LEFT);
                    //调用电信接口
                    $token=json_decode(gettoken(),true);
                    $a = "7470736c04".$length.$dwType.$deviceCode.$collectionInterval.$sendingInterval.$lowThreshold.$highThreshold;
                    $s = pack('H*',$a);
                    $t = crc166($s);
                    $t = unpack("H*", $s.$t);
                    $paras['value'] = $t[1]."696f74";
                    $sendata=[
                        "appId"=>$this->appId,
                        "deviceId"=>$getdata['deviceId'],//  c448d5e3-2ec5-4e42-99d7-0ad27668614f  137effbe-4980-4719-a768-0ae301fc5000
                        "command"=>[
                            "serviceId"=>"topsailSensorData",
                            "method"=>"SET_DEVICE_LEVEL",
                            "paras"=>$paras
                        ],
                        "callbackUrl"=>"http://iot.usky.cn:80/ytapi/admin/Manage/status",
                    ];
                    $header=[
                        "Content-Type:application/json",
                        "app_key:".$this->appId,
                        "Authorization:Bearer ".$token["accessToken"]
                    ];
                    $rescurl=curl($this->host."iocm/app/cmd/v1.4.0/deviceCommands",json_encode($sendata),$header);
                    var_dump($rescurl);
                    Log::record('nbmanage1:' .$rescurl[0].$sendata['command']['paras']['value'] );
                    if($rescurl[0]==201){//成功
                        $res1=json_decode($rescurl[1],true);
//                    var_dump($res1);
                    }else{//失败
                        //  $res2=json_decode($res1[1],true);
                        return $this->error($rescurl[1]);
                    }
                }else{
                    $returnInformation['code'] = 60001;
                    $returnInformation['msg'] = "操作失败，请联系管理员";
                    return json_encode($returnInformation);
                }
            }else{
                $returnInformation['code'] = 60001;
                $returnInformation['msg'] = "操作失败，请联系管理员";
                return json_encode($returnInformation);
            }
          //将请求的结果存入managelog中

            $list=array();
            $list['commandId']=$res1['commandId'];
            $list['deviceId']=$res1['deviceId'];
            $list['status']=$res1['status'];
            $list['command']= json_encode($res1['command'],320) ;
            if($getdata['dataType']=="setting"){
                $list['IMEI']=$longHuOwner[0]['owner_code'];
            }else{
                $list['IMEI']=$getdata['IMEI'];
            }
            $list['HexStr']=json_encode($upData,320) ;;
            $list['settype']="";
            $list['addtime']= date('Y-m-d H:i:s');
            $res = Db::name('managelog')->insertGetId($list);//将推送的数据存入总表
            if($res) {
                $returnInformation['code'] = 200;
                $returnInformation['msg'] = "操作成功";
                if($getdata['dataType']=="setting"){
                    return json_encode($returnInformation);
                }else{
                    return $this->success('添加成功','index');
                }
            }else{
                $returnInformation['code'] = 60001;
                $returnInformation['msg'] = "操作失败，请联系管理员";
                if($getdata['dataType']=="setting"){
                    return json_encode($returnInformation);
                }else{
                    return $this->error("添加失败，请稍后再试");
                }
            }
         }

        if($this->request->isGet()){
        	$deviceId=input('deviceId');
        	$IMEI=input('IMEI');


        	//所有的服务类型
        	$SetType=[
        		[1,"读取模块信息"],[2,"读取参数"],[3,"设置IOT平台IP地址"],[4,"设置参数"],[5,"复位模块"],[6,"配置下行波特率"],
        		[7,"读取下行波特率配置"],[8,"设置DTU自动采集指令"],[9,"读取DTU自动采集指令"],[10,"设置APN"],[11,"读取APN设置"],
        		[12,"AT指令"]
        	];

        	$this->assign('SetType',$SetType);
        	$this->assign('deviceId',$deviceId);
       		$this->assign('IMEI', $IMEI); 
        	return $this->fetch();
        }
 	}

  	public function status(){
 		$data=input('');

 		
        	if(is_array($data)){
                	$getdata= json_encode($data,320);
                	$getdata=json_decode($getdata,true);//转成数组
                	$list['type']=1;
         
                }else{
                	$getdata=$data;
              		$getdata=json_decode($getdata,true);//转成数组
                	$list['type']=2;

                }
             	$list=array();
                $list['deviceId']=$getdata['deviceId'];
                $list['commandId']=$getdata['commandId']; 
                $list['resultCode']=$getdata['result']['resultCode']; 
                $list['result']= json_encode($getdata['result'],320) ;
                $list['addtime']= date('Y-m-d H:i:s');
 				$res = Db::name('managedata')->insertGetId($list);//将推送的数据存入总表
        if($getdata['result']['resultCode']=='SENT'||$getdata['result']['resultCode']=='TIMEOUT'||$getdata['result']['resultCode']=='DELIVERED'||$getdata['result']['resultCode']=='SUCCESSFUL'){
            $device = Db::name('device')->where('iot_id', trim($getdata['deviceId']))->find();
            $deviceConfigure = Db::name('deviceConfigure')->where('device_code', trim($device['device_id']))->find();
            $managelog = Db::name('managelog')->where('commandId', trim($getdata['commandId']))->find();
            $upData = json_decode($managelog['HexStr'],true);
            if (!empty($deviceConfigure['device_code'])) {
                sleep(1);
                $upDataRes = Db::name('deviceConfigure')->where('device_code', trim($device['device_id']))->update($upData);
            }else{
                sleep(1);
                $upData['device_code'] = $device['device_id'];
                $insertRes = Db::name('deviceConfigure')->insertGetId($upData);
            }
        }
 		echo    111;

 	}

 	public function delete(){
 			echo   111;
 	}

    public function manualPush(){
        $data=input('');
        if(is_array($data)){
            $getdata= json_encode($data,320);
            $getdata=json_decode($getdata,true);//转成数组
            $list['type']=1;

        }else{
            $getdata=$data;
            $getdata=json_decode($getdata,true);//转成数组
            $list['type']=2;

        }
        if ($getdata['deviceType']==2){
            $sql6="select * from sp_sj2017 where device_code ='{$getdata["deviceCode"]}'";
            $longHuOwner = add($sql6);
            Log::record('yangpuxiaoyuan12' . ':' . $longHuOwner[0]["id"]);
            foreach ($longHuOwner as $row) {
                $waterData["SubType"] = 2;
                $waterData["DeviceId"] = $getdata["deviceCode"];
                $waterData["InsertId"] = $row["id"];
                $waterData["Confirmed"] = false;
                $data6 = json_encode($waterData);
                $rep_url = "http://47.98.201.187:55335/report";
                $res = $this->ypxycurl($rep_url, $data6);
                Log::record('yangpuxiaoyuan' . ':' . $res);
                sleep(1);
            }
        }
        echo    111;

    }

    public function deviceList(){
        $data=input('');
        if(is_array($data)){
            $getDataJson= json_encode($data,320);
            $getdata=json_decode($getDataJson,true);//转成数组
        }else{
            $getDataJson=$data;
            $getdata=json_decode($getDataJson,true);//转成数组
        }
        $clientIp=$this->ip();
        Log::record('yangpuerqi_deviceList' . ':' .'<<<'.$clientIp.'>>>'.$getDataJson);
        $allowIp = ['222.69.148.83','120.253.238.34','114.86.176.11','120.253.238.37','218.242.51.14'];
//        if (!in_array($clientIp, $allowIp)){
//            $returnInformation['code'] = 60001;
//            $returnInformation['msg'] = "操作失败，IP地址不在白名单中";
//            $returnInformation['data']=null;
//            return json_encode($returnInformation);
//        }else{
            if (!empty($getdata['userName']) && !empty($getdata['userPassword'])){
                if ($getdata["userName"]=="sgec68" && $getdata["userPassword"]=="sgec68123"){
                    if(!empty($getdata['commandType'])){
                        if($getdata['commandType']=="FRONTPAGE"){
                            $sql="select device_code as deviceCode,device_name as deviceName,CONVERT(type, UNSIGNED INTEGER) as deviceType,type_name as deviceTypeName,unitinfo as deviceAddress,CONVERT(louyu, UNSIGNED INTEGER) as deviceFloor,company_name as companyName,company_code as companyCode,contacts,contacts_phone as contactsPhone,address as detailedAddress,street,posistion,time as dataTime,'在线' as status from sp_v_yp_device";
                            $res=add($sql);
                            if (!empty($res)){
                                $returnInformation['code'] = 0;
                                $returnInformation['msg'] = "操作成功";
                                $returnInformation['data']=$res;
                                return json_encode($returnInformation);
                            }else{
                                $returnInformation['code'] = 60001;
                                $returnInformation['msg'] = "操作失败";
                                $returnInformation['data']=null;
                                return json_encode($returnInformation);
                            }
                        }else{
                            $returnInformation['code'] = 60001;
                            $returnInformation['msg'] = "操作失败，参数错误";
                            $returnInformation['data']=null;
                            return json_encode($returnInformation);
                        }
                    }else{
                        $returnInformation['code'] = 60001;
                        $returnInformation['msg'] = "操作失败，参数为空";
                        $returnInformation['data']=null;
                        return json_encode($returnInformation);
                    }
                }else{
                    $returnInformation['code'] = 60002;
                    $returnInformation['msg'] = "操作失败，用户名或密码错误";
                    $returnInformation['data']=null;
                    return json_encode($returnInformation);
                }
            }else{
                $returnInformation['code'] = 60002;
                $returnInformation['msg'] = "操作失败，用户名或密码为空";
                $returnInformation['data']=null;
                return json_encode($returnInformation);
            }
//        }
    }

    //杨浦城运中心设备基础信息注册
    public function deviceInfoRegister()
    {
        $data = input('');
        if (is_array($data)) {
            $getDataJson = json_encode($data, 320);
            $getdata = json_decode($getDataJson, true);//转成数组
        } else {
            $getDataJson = $data;
            $getdata = json_decode($getDataJson, true);//转成数组
        }
        $data1 = Db::query("select sensorId,sensorType,sensorName,CONCAT(companyName,address) AS address,wsLng,wsLat,dataCode,applyId,cityId,areaId,regionId,projectCode from yp_ywtg_configure where id >{$getdata["id"]}");
//        $rep_url = "http://220.196.241.22:8000/api-projectdatamanage/equipmentsync/sync";
//        $header=[
//            "Content-Type:application/json",
//            "Authenticator:eyJhbGciOiJIUzI1NiJ9.eyJyZWFsTmFtZSI6Iumfqeato-S5iSIsInJvbGVJZHMiOiIxMSIsIm9yZ0NvZGUiOiJYIiwibG9naW5OYW1lIjoiaGFuenkiLCJwbGF0Zm9ybUlkIjpudWxsLCJleHAiOjE2Mzc2NjQ1MDMsInVzZXJJZCI6MTAwNiwib3JnSWQiOjF9.H_xzdQ9jdcndOCsYU9z3cZ-oBk4FtdxJk9wxC0AaZvE"
//        ];
//        $res = $this->ywManagementCurl($rep_url,$header,json_encode($data1));
        return json_encode($data1);
    }

    public function alarmHandling(){
        $data=input('');
        if(is_array($data)){
            $getDataJson= json_encode($data,320);
            $getdata=json_decode($getDataJson,true);//转成数组
//            $list['type']=1;

        }else{
            $getDataJson=$data;
            $getdata=json_decode($getDataJson,true);//转成数组
//            $list['type']=2;

        }
        Log::record('yangpuerqi_alarmHandling' . ':' .$getDataJson);
        if ($getdata['confirmAll']==""){
            $getdata['confirmAll']=0;
        }

        if ($getdata['misinformation']==""){
            $getdata['misinformation']=0;
        }


        if (!empty($getdata['userName']) && !empty($getdata['userPassword'])){
            if ($getdata["userName"]=="ypsgec" && $getdata["userPassword"]=="ypsgec123"){
                if (empty($getdata['recordId'])){
                    $returnInformation['code'] = 60001;
                    $returnInformation['msg'] = "操作失败，缺少记录Id";
                    return json_encode($returnInformation);
                }elseif (empty($getdata['deviceCode'])){
                    $returnInformation['code'] = 60001;
                    $returnInformation['msg'] = "操作失败，缺少设备编号";
                    return json_encode($returnInformation);
                }elseif (empty($getdata['deviceType'])){
                    $returnInformation['code'] = 60001;
                    $returnInformation['msg'] = "操作失败，缺少设备类型";
                    return json_encode($returnInformation);
                }elseif ($getdata['confirmAll']!=0&&$getdata['confirmAll']!=1){
                    $returnInformation['code'] = 60001;
                    $returnInformation['msg'] = "操作失败，缺少是否批量处理类型";
                    return json_encode($returnInformation);
                }elseif ($getdata['misinformation']!=0&&$getdata['misinformation']!=1){
                    $returnInformation['code'] = 60001;
                    $returnInformation['msg'] = "操作失败，缺少是否误报字段";
                    return json_encode($returnInformation);
                }elseif (empty($getdata['handlerName'])){
                    $returnInformation['code'] = 60001;
                    $returnInformation['msg'] = "操作失败，缺少处理人姓名";
                    return json_encode($returnInformation);
                }elseif (empty($getdata['handlerPhone'])){
                    $returnInformation['code'] = 60001;
                    $returnInformation['msg'] = "操作失败，缺少处理人联系方式";
                    return json_encode($returnInformation);
                }
//                else{
//                    $returnInformation['code'] = 0;
//                    $returnInformation['msg'] = "操作成功";
//                    return json_encode($returnInformation);
//                }


//                echo 'aaaaaaa';
//                exit();
                switch ($getdata['deviceType']) {
                    case '1':
                        $tab="sp_hj2017";
                        break;
                    case '2':
                        $tab="sp_sj2017";
                        break;
                    case '6':
                        $tab="sp_rtu2017";
                        break;
                    case '7':
                        $tab="sp_ef2017";
                        break;
//                    case '16':
//                        $tab="sp_video2017";
//                        break;
                    default:
                        $returnInformation['code'] = 60001;
                        $returnInformation['msg'] = "操作失败，缺少设备类型";
                        return json_encode($returnInformation);
                        break;
                }

                $time = date('Y-m-d h:i:s', time());

                if ($getdata['confirmAll']==0){
                    $where = " where id=".$getdata['recordId']." and device_code='".$getdata['deviceCode']."' and clzt='0'";
                }else{
                    $where = " where device_code='".$getdata['deviceCode']."' and clzt='0'";
                }
                $sql="UPDATE ".$tab." SET clsj='".$time."',clr='".$getdata['handlerName']."',clnr='".$getdata['processingContent']."',clwb='".$getdata['misinformation']."',cldh='".$getdata['handlerPhone']."',clzt=1 ".$where;
//                echo $sql;
//               print_r($sql);
//               exit();
                $res=addDataInfo($sql);
                if ($res){
                    $returnInformation['code'] = 0;
                    $returnInformation['msg'] = "操作成功";
                    return json_encode($returnInformation);
                }else{
                    $returnInformation['code'] = 60001;
                    $returnInformation['msg'] = "操作失败，参数错误";
                    return json_encode($returnInformation);
                }
            }else{
                $returnInformation['code'] = 60002;
                $returnInformation['msg'] = "操作失败，用户名或密码错误";
                return json_encode($returnInformation);
            }
        }else{
            $returnInformation['code'] = 60002;
            $returnInformation['msg'] = "操作失败，用户名或密码为空";
            return json_encode($returnInformation);
        }
    }

    public function ip() {
        //strcasecmp 比较两个字符，不区分大小写。返回0，>0，<0。
        if (getenv('HTTP_CLIENT_IP') && strcasecmp(getenv('HTTP_CLIENT_IP'), 'unknown')) {
            $ip = getenv('HTTP_CLIENT_IP');
        } else if (getenv('HTTP_X_FORWARDED_FOR') && strcasecmp(getenv('HTTP_X_FORWARDED_FOR'), 'unknown')) {
            $ip = getenv('HTTP_X_FORWARDED_FOR');
        } else if (getenv('REMOTE_ADDR') && strcasecmp(getenv('REMOTE_ADDR'), 'unknown')) {
            $ip = getenv('REMOTE_ADDR');
        } else if (isset($_SERVER['REMOTE_ADDR']) && $_SERVER['REMOTE_ADDR'] && strcasecmp($_SERVER['REMOTE_ADDR'], 'unknown')) {
            $ip = $_SERVER['REMOTE_ADDR'];
        }
        $res =  preg_match ( '/[\d\.]{7,15}/', $ip, $matches ) ? $matches [0] : '';
        return $res;
        //dump(phpinfo());//所有PHP配置信息
    }

    public function http_post_advertise1($url,$data){        //封装curl方法
        $header  = array(
            'appKey:'.'850404889644236801',
            'Content-Type:'.'application/json'
        );
        $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,$header);
        $result = curl_exec($ch);
        curl_close($ch);
        return $result;        //返回所获取的方法
    }

    public function ytapi_query($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;
    }

    public function dianQiCeShiUrl(){
        $data=input('');
        if(is_array($data)){
            $getDataJson= json_encode($data,320);
            $getdata=json_decode($getDataJson,true);//转成数组
//            $list['type']=1;

        }else{
            $getDataJson=$data;
            $getdata=json_decode($getDataJson,true);//转成数组
//            $list['type']=2;

        }
        $number=$getdata['number'];
        $start_number=$getdata['start_number'];
        $arr=$this->ytapi_query("select * from a_fire_brigade limit ".$start_number.",".$number);
//$arr=ytapi_query("select * from a_yc_point_register limit 200,10");
        $array=[];
        foreach ($arr as $key=>$value){
            $array[$key]['descript']=$arr[$key]['descript'];
            $array[$key]['deviceName']=$arr[$key]['device_name'];
//    $array[$key]['deviceNo']=$arr[$key]['device_code'].str_replace(',','',$arr[$key]['port']);
            $array[$key]['deviceNo']=$arr[$key]['device_code'].str_replace(',','',$arr[$key]['port']).$arr[$key]['data'];
            $array[$key]['deviceType']=$arr[$key]['device_type'];
            $array[$key]['deviceTypeName']=$arr[$key]['device_type_name'];
            $array[$key]['openProjectId']=$arr[$key]['open_project_id'];
        }

        $url1='http://iot.shxf-119.com/access/device/point/register';//新正式路径
        foreach ($array as $key=>$value){
//            sleep(2);
            $data1=[];
            $data1  = $array[$key];
            Log::record('fireBrigadeAfferent:' .json_encode($data1));
            $output= $this->http_post_advertise1($url1,json_encode($data1));
            echo $output."\n";
            Log::record('fireBrigadeOutput:' .$output);
        }
    }

    public function mt_rand_float($min, $max){
        return $min +  abs($max-$min) * mt_rand(0,mt_getrandmax())/mt_getrandmax();
 	}

    public function randomDate() {
        $begin = strtotime("now");
        $end = strtotime("-1 Month");
        $timestamp = rand($begin, $end);
        return date("Y-m-d H:i:s", $timestamp);
    }

    public function ceShiUrl(){
        header("Access-Control-Allow-Origin:*");
// 响应类型
        header('Access-Control-Allow-Methods:POST');
// 响应头设置
        header('Access-Control-Allow-Headers:x-requested-with, content-type');
        $data=input('');
        if(is_array($data)){
            $getDataJson= json_encode($data,320);
            $getdata=json_decode($getDataJson,true);//转成数组
        }else{
            $getDataJson=$data;
            $getdata=json_decode($getDataJson,true);//转成数组
        }
        Log::record('zhanyejunceshi:' .$getDataJson);
        return $getDataJson;
//        $data1 = array();
//        $data2 = array();
//        $data4 = array();
//        $data5 = array();
//        $data6 = array();
//        $data7 = array();
//        $data8 = array();
//        $data9 = array();
//        $data10 = array();
//        $data11 = array();
//        $data12 = array();
//        $data15 = array();
//        $data16 = array();
//        $data18 = array();
//        $data19 = array();
//        for ($i=0;$i<=14;$i++){
//            $data1['standard_deviation']=round($this->mt_rand_float(1,5),2);
//            $data1['variance']=round($data1['standard_deviation']*$data1['standard_deviation'],2);
//            $data1['average_value']=round($this->mt_rand_float(220,227),2);
//            $j=$i+1;
//            if($j>=10){
//                $data1['data_time']="2021-03-".$j;
//            }
//            $data2[$i]=$data1;
//            $data4['standard_deviation']=round($this->mt_rand_float(3,8),2);
//            $data4['variance']=round($data4['standard_deviation']*$data4['standard_deviation'],2);
//            $data4['average_value']=round($this->mt_rand_float(7,15),2);
//            if($j>=10){
//                $data4['data_time']="2021-03-".$j;
//            }
//            $data5[$i]=$data4;
//            $data6['standard_deviation']=round($this->mt_rand_float(0,2),2);
//            $data6['variance']=round($data6['standard_deviation']*$data6['standard_deviation'],2);
//            $data6['average_value']=round($this->mt_rand_float(17,25),2);
//            if($j>=10){
//                $data6['data_time']="2021-03-".$j;
//            }
//            $data7[$i]=$data6;
//            $data8['standard_deviation']=round($this->mt_rand_float(30,70),2);
//            $data8['variance']=round($data8['standard_deviation']*$data8['standard_deviation'],2);
//            $data8['average_value']=round($this->mt_rand_float(30,60),2);
//            if($j>=10){
//                $data8['data_time']="2021-03-".$j;
//            }
//            $data9[$i]=$data8;
//            $data11['electric_current']=round($this->mt_rand_float(8,18),2);
//            $data11['voltage']=round($this->mt_rand_float(220,225),2);
//            $data11['data_time']=$this->randomDate();
//            $data12[$i]=$data11;
//            $data15['electric_current']=round($this->mt_rand_float(20,100),2);
//            $data15['voltage']=round($this->mt_rand_float(220,225),2);
//            $data15['data_time']=$this->randomDate();
//            $data16[$i]=$data15;
//            $data18['ambient_temperature']=round($this->mt_rand_float(20,25),2);
//            $data18['Cable_temperature']=round($this->mt_rand_float(10,20),2);
//            $data18['generation_temperature']=round($data18['ambient_temperature']-$data18['Cable_temperature'],2);
//            $data18['data_time']=$this->randomDate();
//            $data19[$i]=$data18;
//        }
//        $data10['conclusion1']="因数据量未达到暂无法分析";
//        $data3['voltage']=$data2;
//        $data3['electric_current']=$data5;
//        $data3['temperature']=$data7;
//        $data3['leakage_current']=$data9;
//        $data3['conclusion']=$data10;
//        $data14['abnormal_equipment']=$data12;
//        $data14['leakage_alarm']=$data16;
//        $data14['conclusion']=$data10;
//        $data20['visualization']=$data19;
//        $data20['conclusion']=$data10;
//        $data13['dispersion_rate']=$data3;
//        $data13['electrical_aging']=$data14;
//        $data13['thermal_aging']=$data20;
////        $data1['alarm_number']=$this->mt_rand_float(100,500);
////        $sensorList['productId'] = round($this->mt_rand_float(3,5),2);
//        $data17 = json_encode($data13);
//        return $data17;
    }

    //水系统电气火灾算法测试API
    public function algorithmApi(){
        header("Access-Control-Allow-Origin:*");
// 响应类型
        header('Access-Control-Allow-Methods:POST');
// 响应头设置
        header('Access-Control-Allow-Headers:x-requested-with, content-type');
        $data=input('');
        if(is_array($data)){
            $getDataJson= json_encode($data,320);
            $getdata=json_decode($getDataJson,true);//转成数组
        }else{
            $getDataJson=$data;
            $getdata=json_decode($getDataJson,true);//转成数组
        }
        if(!empty($getdata["dataType"])){
            if($getdata["dataType"]==1||$getdata["dataType"]==2){
                if($getdata["dataType"]==1){
                    if (!empty($getdata["apiType"])){
                        if ($getdata["apiType"]==4){
                            if(!empty($getdata["timeType"])){
                                if (!empty($getdata["companyCode"])){
                                    $sql6="select dispersion_rate from sp_water_analysis where company_code ='{$getdata["companyCode"]}' and data_type ={$getdata["timeType"]}";
                                    $longHuOwner = add($sql6);
                                    $returnInformation['code'] = 200;
                                    $returnInformation['msg'] = "success";
                                    $returnInformation['data']=$longHuOwner[0]['dispersion_rate'];
                                    return stripslashes(json_encode($returnInformation));
                                }else{
                                    $returnInformation['code'] = 60001;
                                    $returnInformation['msg'] = "操作失败，单位编号不能为空";
                                    return json_encode($returnInformation);
                                }
                            }else{
                                $returnInformation['code'] = 60001;
                                $returnInformation['msg'] = "操作失败，时间类型不能为空";
                                return json_encode($returnInformation);
                            }

                        }elseif ($getdata["apiType"]==5){
                            if(!empty($getdata["timeType"])){
                                if (!empty($getdata["companyCode"])){
                                    $sql6="select leakage_investigation from sp_water_analysis where company_code ='{$getdata["companyCode"]}' and data_type ={$getdata["timeType"]}";
                                    $longHuOwner = add($sql6);
                                    $returnInformation['code'] = 200;
                                    $returnInformation['msg'] = "success";
                                    $returnInformation['data']=$longHuOwner[0]['leakage_investigation'];
                                    return stripslashes(json_encode($returnInformation));
                                }else{
                                    $returnInformation['code'] = 60001;
                                    $returnInformation['msg'] = "操作失败，单位编号不能为空";
                                    return json_encode($returnInformation);
                                }
                            }else{
                                $returnInformation['code'] = 60001;
                                $returnInformation['msg'] = "操作失败，时间类型不能为空";
                                return json_encode($returnInformation);
                            }
                        }elseif ($getdata["apiType"]==6){
                            if(!empty($getdata["timeType"])){
                                if (!empty($getdata["companyCode"])){
                                    $sql6="select device_association from sp_water_analysis where company_code ='{$getdata["companyCode"]}' and data_type ={$getdata["timeType"]}";
                                    $longHuOwner = add($sql6);
                                    $returnInformation['code'] = 200;
                                    $returnInformation['msg'] = "success";
                                    $returnInformation['data']=$longHuOwner[0]['device_association'];
                                    return stripslashes(json_encode($returnInformation));
                                }else{
                                    $returnInformation['code'] = 60001;
                                    $returnInformation['msg'] = "操作失败，单位编号不能为空";
                                    return json_encode($returnInformation);
                                }
                            }else{
                                $returnInformation['code'] = 60001;
                                $returnInformation['msg'] = "操作失败，时间类型不能为空";
                                return json_encode($returnInformation);
                            }
                        }elseif ($getdata["apiType"]==7){
                            if(!empty($getdata["timeType"])){
                                if (!empty($getdata["companyCode"])){
                                    $sql6="select data_fluctuation from sp_water_analysis where company_code ='{$getdata["companyCode"]}' and data_type ={$getdata["timeType"]}";
                                    $longHuOwner = add($sql6);
                                    $returnInformation['code'] = 200;
                                    $returnInformation['msg'] = "success";
                                    $returnInformation['data']=$longHuOwner[0]['data_fluctuation'];
                                    return stripslashes(json_encode($returnInformation));
                                }else{
                                    $returnInformation['code'] = 60001;
                                    $returnInformation['msg'] = "操作失败，单位编号不能为空";
                                    return json_encode($returnInformation);
                                }
                            }else{
                                $returnInformation['code'] = 60001;
                                $returnInformation['msg'] = "操作失败，时间类型不能为空";
                                return json_encode($returnInformation);
                            }
                        }elseif ($getdata["apiType"]==2){
                            if(!empty($getdata["timeType"])){
                                if (!empty($getdata["companyCode"])){
                                    $sql6="select data_statistics from sp_water_analysis where company_code ='{$getdata["companyCode"]}' and data_type ={$getdata["timeType"]}";
                                    $longHuOwner = add($sql6);
                                    $returnInformation['code'] = 200;
                                    $returnInformation['msg'] = "success";
                                    $returnInformation['data']=$longHuOwner[0]['data_statistics'];
                                    return stripslashes(json_encode($returnInformation));
                                }else{
                                    $returnInformation['code'] = 60001;
                                    $returnInformation['msg'] = "操作失败，单位编号不能为空";
                                    return json_encode($returnInformation);
                                }
                            }else{
                                $returnInformation['code'] = 60001;
                                $returnInformation['msg'] = "操作失败，时间类型不能为空";
                                return json_encode($returnInformation);
                            }
                        }elseif ($getdata["apiType"]==3){
                            if(!empty($getdata["timeType"])){
                                if (!empty($getdata["companyCode"])){
                                    if($getdata["timeType"]==1) {
                                        $sql6 = "select data4,data1,`time`as dataTime from sp_d864016058809717 where `time` between '2021-07-20 00:00:00' and '2021-07-20 15:00:00'";
                                        $longHuOwner = add($sql6);
                                        $returnInformation['code'] = 200;
                                        $returnInformation['msg'] = "success";
                                        $returnInformation['data'] = $longHuOwner;
                                        return stripslashes(json_encode($returnInformation));
                                    }elseif ($getdata["timeType"]==2){
                                        $sql6 = "select data4,data1,`time`as dataTime from sp_d864016058809717 where `time` between '2021-07-13 00:00:00' and '2021-07-20 15:00:00'";
                                        $longHuOwner = add($sql6);
                                        $returnInformation['code'] = 200;
                                        $returnInformation['msg'] = "success";
                                        $returnInformation['data'] = $longHuOwner;
                                        return stripslashes(json_encode($returnInformation));
                                    }elseif ($getdata["timeType"]==3){
                                        $sql6 = "select data4,data1,`time`as dataTime from sp_d864016058809717 where `time` between '2021-06-20 00:00:00' and '2021-07-20 15:00:00'";
                                        $longHuOwner = add($sql6);
                                        $returnInformation['code'] = 200;
                                        $returnInformation['msg'] = "success";
                                        $returnInformation['data'] = $longHuOwner;
                                        return stripslashes(json_encode($returnInformation));
                                    }
                                }else{
                                    $returnInformation['code'] = 60001;
                                    $returnInformation['msg'] = "操作失败，单位编号不能为空";
                                    return json_encode($returnInformation);
                                }
                            }else{
                                $returnInformation['code'] = 60001;
                                $returnInformation['msg'] = "操作失败，时间类型不能为空";
                                return json_encode($returnInformation);
                            }
                        }
                    }else{
                        $returnInformation['code'] = 60001;
                        $returnInformation['msg'] = "操作失败，api类型不能为空";
                        return json_encode($returnInformation);
                    }
                }else{
                    if (!empty($getdata["apiType"])){
                        if ($getdata["apiType"]==4){
                            if(!empty($getdata["timeType"])){
                                if (!empty($getdata["companyCode"])){
                                    $sql6="select dispersion_rate from sp_ef_analysis where company_code ='{$getdata["companyCode"]}' and data_type ={$getdata["timeType"]}";
                                    $longHuOwner = add($sql6);
                                    $returnInformation['code'] = 200;
                                    $returnInformation['msg'] = "success";
                                    $returnInformation['data']=$longHuOwner[0]['dispersion_rate'];
                                    return stripslashes(json_encode($returnInformation));
                                }else{
                                    $returnInformation['code'] = 60001;
                                    $returnInformation['msg'] = "操作失败，单位编号不能为空";
                                    return json_encode($returnInformation);
                                }
                            }else{
                                $returnInformation['code'] = 60001;
                                $returnInformation['msg'] = "操作失败，时间类型不能为空";
                                return json_encode($returnInformation);
                            }

                        }elseif ($getdata["apiType"]==5){
                            if(!empty($getdata["timeType"])){
                                if (!empty($getdata["companyCode"])){
                                    $sql6="select electrical_aging from sp_ef_analysis where company_code ='{$getdata["companyCode"]}' and data_type ={$getdata["timeType"]}";
                                    $longHuOwner = add($sql6);
                                    $returnInformation['code'] = 200;
                                    $returnInformation['msg'] = "success";
                                    $returnInformation['data']=$longHuOwner[0]['electrical_aging'];
                                    return stripslashes(json_encode($returnInformation));
                                }else{
                                    $returnInformation['code'] = 60001;
                                    $returnInformation['msg'] = "操作失败，单位编号不能为空";
                                    return json_encode($returnInformation);
                                }
                            }else{
                                $returnInformation['code'] = 60001;
                                $returnInformation['msg'] = "操作失败，时间类型不能为空";
                                return json_encode($returnInformation);
                            }
                        }elseif ($getdata["apiType"]==6){
                            if(!empty($getdata["timeType"])){
                                if (!empty($getdata["companyCode"])){
                                    $sql6="select thermal_aging from sp_ef_analysis where company_code ='{$getdata["companyCode"]}' and data_type ={$getdata["timeType"]}";
                                    $longHuOwner = add($sql6);
                                    $returnInformation['code'] = 200;
                                    $returnInformation['msg'] = "success";
                                    $returnInformation['data']=$longHuOwner[0]['thermal_aging'];
                                    return stripslashes(json_encode($returnInformation));
                                }else{
                                    $returnInformation['code'] = 60001;
                                    $returnInformation['msg'] = "操作失败，单位编号不能为空";
                                    return json_encode($returnInformation);
                                }
                            }else{
                                $returnInformation['code'] = 60001;
                                $returnInformation['msg'] = "操作失败，时间类型不能为空";
                                return json_encode($returnInformation);
                            }
                        }elseif ($getdata["apiType"]==7){
                            if(!empty($getdata["timeType"])){
                                if (!empty($getdata["companyCode"])){
                                    $sql6="select data_fluctuation from sp_water_analysis where company_code ='{$getdata["companyCode"]}' and data_type ={$getdata["timeType"]}";
                                    $longHuOwner = add($sql6);
                                    $returnInformation['code'] = 200;
                                    $returnInformation['msg'] = "success";
                                    $returnInformation['data']=$longHuOwner[0]['data_fluctuation'];
                                    return stripslashes(json_encode($returnInformation));
                                }else{
                                    $returnInformation['code'] = 60001;
                                    $returnInformation['msg'] = "操作失败，单位编号不能为空";
                                    return json_encode($returnInformation);
                                }
                            }else{
                                $returnInformation['code'] = 60001;
                                $returnInformation['msg'] = "操作失败，时间类型不能为空";
                                return json_encode($returnInformation);
                            }
                        }elseif ($getdata["apiType"]==2){
                            if(!empty($getdata["timeType"])){
                                if (!empty($getdata["companyCode"])){
                                    $sql6="select data_statistics from sp_water_analysis where company_code ='{$getdata["companyCode"]}' and data_type ={$getdata["timeType"]}";
                                    $longHuOwner = add($sql6);
                                    $returnInformation['code'] = 200;
                                    $returnInformation['msg'] = "success";
                                    $returnInformation['data']=$longHuOwner[0]['data_statistics'];
                                    return stripslashes(json_encode($returnInformation));
                                }else{
                                    $returnInformation['code'] = 60001;
                                    $returnInformation['msg'] = "操作失败，单位编号不能为空";
                                    return json_encode($returnInformation);
                                }
                            }else{
                                $returnInformation['code'] = 60001;
                                $returnInformation['msg'] = "操作失败，时间类型不能为空";
                                return json_encode($returnInformation);
                            }
                        }elseif ($getdata["apiType"]==3){
                            if(!empty($getdata["timeType"])){
                                if (!empty($getdata["companyCode"])){
                                    if($getdata["timeType"]==1) {
                                        $sql6 = "select point_data,point_code,data_time from sp_e00003215010144 where data_time between '2021-07-20 00:00:00' and '2021-07-20 15:00:00'";
                                        $longHuOwner = add($sql6);
                                        $returnInformation['code'] = 200;
                                        $returnInformation['msg'] = "success";
                                        $returnInformation['data'] = $longHuOwner;
                                        return stripslashes(json_encode($returnInformation));
                                    }elseif ($getdata["timeType"]==2){
                                        $sql6 = "select point_data,point_code,data_time from sp_e00003215010144 where data_time between '2021-07-13 00:00:00' and '2021-07-20 15:00:00'";
                                        $longHuOwner = add($sql6);
                                        $returnInformation['code'] = 200;
                                        $returnInformation['msg'] = "success";
                                        $returnInformation['data'] = $longHuOwner;
                                        return stripslashes(json_encode($returnInformation));
                                    }elseif ($getdata["timeType"]==3){
                                        $sql6 = "select point_data,point_code,data_time from sp_e00003215010144 where data_time between '2021-06-20 00:00:00' and '2021-07-20 15:00:00'";
                                        $longHuOwner = add($sql6);
                                        $returnInformation['code'] = 200;
                                        $returnInformation['msg'] = "success";
                                        $returnInformation['data'] = $longHuOwner;
                                        return stripslashes(json_encode($returnInformation));
                                    }
                                }else{
                                    $returnInformation['code'] = 60001;
                                    $returnInformation['msg'] = "操作失败，单位编号不能为空";
                                    return json_encode($returnInformation);
                                }
                            }else{
                                $returnInformation['code'] = 60001;
                                $returnInformation['msg'] = "操作失败，时间类型不能为空";
                                return json_encode($returnInformation);
                            }
                        }
                    }else{
                        $returnInformation['code'] = 60001;
                        $returnInformation['msg'] = "操作失败，api类型不能为空";
                        return json_encode($returnInformation);
                    }
                }
            }else{
                $returnInformation['code'] = 60001;
                $returnInformation['msg'] = "操作失败，数据范围超出限制";
                return json_encode($returnInformation);
            }
        }else{
            $returnInformation['code'] = 60001;
            $returnInformation['msg'] = "操作失败，数据类型不能为空";
            return json_encode($returnInformation);
        }
    }

    public function ceshiApi()
    {
        header("Access-Control-Allow-Origin:*");
// 响应类型
        header('Access-Control-Allow-Methods:POST');
// 响应头设置
        header('Access-Control-Allow-Headers:x-requested-with, content-type');
        $data = input('');
        if (is_array($data)) {
            $getDataJson = json_encode($data, 320);
            $getdata = json_decode($getDataJson, true);//转成数组
        } else {
            $getDataJson = $data;
            $getdata = json_decode($getDataJson, true);//转成数组
        }
        $data1 = array();
        $data2 = array();
        $data3 = array();
        $data4 = array();
        if ($getdata['status']=="getnewslist"){
            $data1['status']=0;
            for ($i=0;$i<2;$i++){
                $data2['id']=$i+1;
                $data2['title']="测试高房价结果回复的合法化觉得很简单的事";
                $data2['add_time']="2021-08-05 16:48:17";
                $data2['zhaiyao']="的就是但是绝大多数公开大量上市价格第四季度睡个好觉了";
                $data2['click']=1;
                $data2['img_url']="https://gimg2.baidu.com/image_search/src=http%3A%2F%2Fs10.sinaimg.cn%2Forignal%2F4a8a8049ga9eae999a909&refer=http%3A%2F%2Fs10.sinaimg.cn&app=2002&size=f9999,10000&q=a80&n=0&g=0n&fmt=jpeg?sec=1631010162&t=f95e7303fda34bef3751916ee036b4a9";
                $data3[$i]=$data2;
            }
            $data1['message']=$data3;
            return json_encode($data1);
        }elseif($getdata['status']=="getnew"){
            $data1['status']=0;
            $data2['id']=1;
            $data2['title']="测试高房价结果回复的合法化觉得很简单的事";
            $data2['add_time']="2021-08-05 16:48:17";
            $data2['content']="的就是但是绝大多数公开大量上市价格第四季度睡个好觉了";
            $data2['click']=2;
            $data3[0]=$data2;
            $data1['message']=$data3;
            return json_encode($data1);
        }elseif($getdata['status']=="getimages"){
            $data1['status']=0;
            for ($i=0;$i<2;$i++){
                $data2['id']=$i+1;
                $data2['title']="测试高房价结果回复的合法化觉得很简单的事";
                $data2['zhaiyao']="的就是但是绝大多数公开大量上市价格第四季度睡个好觉了";
                $data2['img_url']="https://gimg2.baidu.com/image_search/src=http%3A%2F%2Fn.sinaimg.cn%2Fsinacn08%2F336%2Fw501h635%2F20180630%2F9d76-hespqrx2645109.jpg&refer=http%3A%2F%2Fn.sinaimg.cn&app=2002&size=f9999,10000&q=a80&n=0&g=0n&fmt=jpeg?sec=1631010162&t=384680be0388ea4c8bd06dfed25d9da3";
                $data3[$i]=$data2;
            }
            $data1['message']=$data3;
            return json_encode($data1);
        }elseif($getdata['status']=="getimgcategory"){
            $data1['status']=0;
            for ($i=0;$i<2;$i++){
                $data2['id']=$i+1;
                $data2['title']="测试".$i;
                $data3[$i]=$data2;
            }
            $data1['message']=$data3;
            return json_encode($data1);
        }elseif($getdata['status']=="getthumimages"){
            $data1['status']=0;
            for ($i=0;$i<3;$i++){
                $data2['src']="https://gimg2.baidu.com/image_search/src=http%3A%2F%2Fimg.article.pchome.net%2F00%2F40%2F91%2F79%2Fpic_lib%2Fs960x639%2Fcountry_field_landscape_photo_EA52058s960x639.jpg&refer=http%3A%2F%2Fimg.article.pchome.net&app=2002&size=f9999,10000&q=a80&n=0&g=0n&fmt=jpeg?sec=1631010162&t=0fe6c4c3d1a111f5e848695687261303";
            }
            $data1['message']=$data3;
            return json_encode($data1);
        }elseif($getdata['status']=="getimageInfo"){
            $data1['status']=0;
            for ($i=0;$i<1;$i++){
                $data2['id']=$i+1;
                $data2['title']="测试高房价结果回复的合法化觉得很简单的事";
                $data2['add_time']="2021-08-05 16:48:17";
                $data2['click']=3;
                $data2['content']="解释的机会就是进口关税打开撒酒疯还是";
            }
            $data1['message']=$data3;
            return json_encode($data1);
        }elseif($getdata['status']=="getcomments"){
            $data1['status']=0;
            for ($i=0;$i<1;$i++){
                $data2['user_name']="djsjf";
                $data2['add_time']="2021-08-05 16:48:17";
                $data2['content']="快速减肥健身看江户时代";
            }
            $data1['message']=$data3;
            return json_encode($data1);
        }elseif($getdata['status']=="postcomment"){
            $data1['status']=0;
            $data1['message']="啊附加符号方式";
            return json_encode($data1);
        }elseif($getdata['status']=="getgoods"){
            $data1['status']=0;
            for ($i=0;$i<2;$i++){
                $data2['id']=$i+1;
                $data2['title']="测试高房价结果回复的合法化觉得很简单的事";
                $data2['add_time']="2021-08-05 16:48:17";
                $data2['zhaiyao']="的就是但是绝大多数公开大量上市价格第四季度睡个好觉了";
                $data2['click']=0;
                $data2['img_url']="https://gimg2.baidu.com/image_search/src=http%3A%2F%2Fup.enterdesk.com%2Fedpic_360_360%2F5b%2F71%2F3b%2F5b713b0d8f5fb4e4f8759c417b42eefb.jpg&refer=http%3A%2F%2Fup.enterdesk.com&app=2002&size=f9999,10000&q=a80&n=0&g=0n&fmt=jpeg?sec=1631010162&t=699aab395bae994606f72becd4cbb90d";
                $data2['sell_price']=214;
                $data2['market_price']=3446;
                $data2['stock_quantity']=3446;
            }
            $data1['message']=$data3;
            return json_encode($data1);
        }elseif($getdata['status']=="getdesc"){
            $data1['status']=0;
            for ($i=0;$i<2;$i++){
                $data2['title']="测试高房价结果回复的合法化觉得很简单的事";
                $data2['content']="<p>的实际开工的开始</p><p align='center'></p>";
            }
            $data1['message']=$data3;
            return json_encode($data1);
        }
    }

    //杨浦一网通管各类设备数量
    public function deviceNumber(){
        header("Access-Control-Allow-Origin:*");
// 响应类型
        header('Access-Control-Allow-Methods:POST');
// 响应头设置
        header('Access-Control-Allow-Headers:x-requested-with, content-type');
        $data=input('');
        if(is_array($data)){
            $getDataJson= json_encode($data,320);
            $getdata=json_decode($getDataJson,true);//转成数组
        }else{
            $getDataJson=$data;
            $getdata=json_decode($getDataJson,true);//转成数组
        }
        $data6 = array();
        if ($getdata['userName']=="ypywtg"){
            $sql="SELECT COUNT(*) AS waterNumber FROM sp_owner WHERE dwtype = 2 AND company in ('10309', '10308', '10307', '10306', '10305', '10304', '10303', '10302', '10301', '10300', '10299', '10298', '10297', '10296', '10295', '10294', '10293', '10292', '10291', '10290', '10289', '10288', '10287', '10286', '10285', '10284', '10283', '10282', '10281', '10280', '10279', '10278', '10277', '10276', '10275', '10274', '10273', '10272', '10271', '10270', '10269', '10268', '10267', '10266', '10265', '10264', '10263', '10262', '10261', '10260', '10259', '10258', '10257', '10256', '10255', '10254', '10253', '10252', '10251', '10250', '10249', '10248', '10246', '10245', '10244', '10243', '10242', '10241', '10240', '10239', '10238', '10237', '10236', '10234');";
            $res=add($sql);
            $sql1="SELECT COUNT(*) AS levelNumber FROM sp_owner WHERE dwtype = 5 AND company in ('10309', '10308', '10307', '10306', '10305', '10304', '10303', '10302', '10301', '10300', '10299', '10298', '10297', '10296', '10295', '10294', '10293', '10292', '10291', '10290', '10289', '10288', '10287', '10286', '10285', '10284', '10283', '10282', '10281', '10280', '10279', '10278', '10277', '10276', '10275', '10274', '10273', '10272', '10271', '10270', '10269', '10268', '10267', '10266', '10265', '10264', '10263', '10262', '10261', '10260', '10259', '10258', '10257', '10256', '10255', '10254', '10253', '10252', '10251', '10250', '10249', '10248', '10246', '10245', '10244', '10243', '10242', '10241', '10240', '10239', '10238', '10237', '10236', '10234');";
            $res1=add($sql1);
            $sql2="SELECT COUNT(*) AS smokeSensationNumber FROM sp_owner WHERE dwtype = 3 AND company in ('10309', '10308', '10307', '10306', '10305', '10304', '10303', '10302', '10301', '10300', '10299', '10298', '10297', '10296', '10295', '10294', '10293', '10292', '10291', '10290', '10289', '10288', '10287', '10286', '10285', '10284', '10283', '10282', '10281', '10280', '10279', '10278', '10277', '10276', '10275', '10274', '10273', '10272', '10271', '10270', '10269', '10268', '10267', '10266', '10265', '10264', '10263', '10262', '10261', '10260', '10259', '10258', '10257', '10256', '10255', '10254', '10253', '10252', '10251', '10250', '10249', '10248', '10246', '10245', '10244', '10243', '10242', '10241', '10240', '10239', '10238', '10237', '10236', '10234');";
            $res2=add($sql2);
            $sql3="SELECT COUNT(*) AS rtuNumber FROM sp_owner WHERE dwtype = 6 AND company in ('10309', '10308', '10307', '10306', '10305', '10304', '10303', '10302', '10301', '10300', '10299', '10298', '10297', '10296', '10295', '10294', '10293', '10292', '10291', '10290', '10289', '10288', '10287', '10286', '10285', '10284', '10283', '10282', '10281', '10280', '10279', '10278', '10277', '10276', '10275', '10274', '10273', '10272', '10271', '10270', '10269', '10268', '10267', '10266', '10265', '10264', '10263', '10262', '10261', '10260', '10259', '10258', '10257', '10256', '10255', '10254', '10253', '10252', '10251', '10250', '10249', '10248', '10246', '10245', '10244', '10243', '10242', '10241', '10240', '10239', '10238', '10237', '10236', '10234');";
            $res3=add($sql3);
            $sql4="SELECT COUNT(*) AS videoNumber FROM sp_owner WHERE dwtype = 16 AND company in ('10309', '10308', '10307', '10306', '10305', '10304', '10303', '10302', '10301', '10300', '10299', '10298', '10297', '10296', '10295', '10294', '10293', '10292', '10291', '10290', '10289', '10288', '10287', '10286', '10285', '10284', '10283', '10282', '10281', '10280', '10279', '10278', '10277', '10276', '10275', '10274', '10273', '10272', '10271', '10270', '10269', '10268', '10267', '10266', '10265', '10264', '10263', '10262', '10261', '10260', '10259', '10258', '10257', '10256', '10255', '10254', '10253', '10252', '10251', '10250', '10249', '10248', '10246', '10245', '10244', '10243', '10242', '10241', '10240', '10239', '10238', '10237', '10236', '10234');";
            $res4=add($sql4);
            $sql5="SELECT COUNT(*) AS electricalFireNumber FROM sp_owner WHERE dwtype = 7 AND company in ('10309', '10308', '10307', '10306', '10305', '10304', '10303', '10302', '10301', '10300', '10299', '10298', '10297', '10296', '10295', '10294', '10293', '10292', '10291', '10290', '10289', '10288', '10287', '10286', '10285', '10284', '10283', '10282', '10281', '10280', '10279', '10278', '10277', '10276', '10275', '10274', '10273', '10272', '10271', '10270', '10269', '10268', '10267', '10266', '10265', '10264', '10263', '10262', '10261', '10260', '10259', '10258', '10257', '10256', '10255', '10254', '10253', '10252', '10251', '10250', '10249', '10248', '10246', '10245', '10244', '10243', '10242', '10241', '10240', '10239', '10238', '10237', '10236', '10234');";
            $res5=add($sql5);
            $sensorList['waterNumber'] =$res[0]['waterNumber'];
            $sensorList['levelNumber'] =$res1[0]['levelNumber'];
            $sensorList['smokeSensationNumber'] =$res2[0]['smokeSensationNumber'];
            $sensorList['rtuNumber'] =$res3[0]['rtuNumber'];
            $sensorList['videoNumber'] =$res4[0]['videoNumber'];
            $sensorList['electricalFireNumber'] =$res5[0]['electricalFireNumber'];
            $data6 = json_encode($sensorList);
        }
        return $data6;
    }

    //伍继电力程序校验机制api
    public function wooGiApi(){
        $data=input('');
        if(is_array($data)){
            $getDataJson= json_encode($data,320);
            $getdata=json_decode($getDataJson,true);//转成数组
        }else{
            $getDataJson=$data;
            $getdata=json_decode($getDataJson,true);//转成数组
        }
        $clientIp=$this->ip();
        Log::record('wooGiApi_deviceList' . ':' .'<<<'.$clientIp.'>>>'.$getDataJson);
        $allowIp = ['101.133.214.75','124.71.174.104','124.71.175.91','124.70.160.158','222.69.148.83','114.95.161.247'];
//        if (!in_array($clientIp, $allowIp)){
//            $returnInformation['code'] = 60001;
//            $returnInformation['msg'] = "操作失败，IP地址不在白名单中";
//            $returnInformation['data']=null;
//            return json_encode($returnInformation);
//        }else{
            $redis = new \Redis();
            $redis->connect('127.0.0.1', 6379);
            $result = $redis->auth("usky2021");
            $redis->select(1);
            if ($result == 1) {
                $check =$redis->exists($clientIp);
                if ($check){
                    // +1
                    $redis->incr($clientIp);
                    $count =$redis->get($clientIp);
                    // 限制每小时1次
                    if($count > 500){
                        $returnInformation['code'] = 60003;
                        $returnInformation['msg'] = "操作失败，当前ip请求频率过高";
                        $returnInformation['data']=null;
                        return json_encode($returnInformation);
                    }else{
                        if (!empty($getdata['publicKey'])){
                            $publicKey = $getdata['publicKey'];
                            $timeStamp = time();
                            if (!empty($getdata['requestType'])){
                                if($getdata['requestType']==1){
                                    $publicKey1 = md5("usky".$getdata['timeStamp']."9bcbc5d723cb9bae394d3a097deb6695");
                                    $publicKey2 = md5("usky".$timeStamp."9bcbc5d723cb9bae394d3a097deb6695");
                                }else if ($getdata['requestType']==2){
                                    $publicKey1 = md5("usky".$getdata['timeStamp']."b9848b4fe4647e380fd1367a4f34ced9");
                                    $publicKey2 = md5("usky".$timeStamp."b9848b4fe4647e380fd1367a4f34ced9");
                                }else if ($getdata['requestType']==3){
                                    $publicKey1 = md5("usky".$getdata['timeStamp']."056ac8fae059c9c9e700b734922edfc8");
                                    $publicKey2 = md5("usky".$timeStamp."056ac8fae059c9c9e700b734922edfc8");
                                }else{
                                    $returnInformation['code'] = 60004;
                                    $returnInformation['msg'] = "操作失败，requestType不在范围内";
                                    $returnInformation['data']=null;
                                    return json_encode($returnInformation);
                                }
                            }else{
                                $returnInformation['code'] = 60004;
                                $returnInformation['msg'] = "操作失败，requestType不能为空";
                                $returnInformation['data']=null;
                                return json_encode($returnInformation);
                            }
                            if ($publicKey==$publicKey1){
                                $sensorList['publicKey'] =$publicKey2;
                                $sensorList['timeStamp'] =$timeStamp;
                                $returnInformation['code'] = 200;
                                $returnInformation['msg'] = "操作成功";
                                $returnInformation['data']=$sensorList;
                                return json_encode($returnInformation);
                            }else{
                                $returnInformation['code'] = 60002;
                                $returnInformation['msg'] = "操作失败，publicKey错误";
                                $returnInformation['data']=null;
                                return json_encode($returnInformation);
                            }
                        }else{
                            $returnInformation['code'] = 60004;
                            $returnInformation['msg'] = "操作失败，publicKey不能为空";
                            $returnInformation['data']=null;
                            return json_encode($returnInformation);
                        }
                    }
                } else {
                    $redis->set($clientIp, 1,3300);//初始值1
                    if (!empty($getdata['publicKey'])){
                        $publicKey = $getdata['publicKey'];
                        $timeStamp = time();
                        if (!empty($getdata['requestType'])){
                            if($getdata['requestType']==1){
                                $publicKey1 = md5("usky".$getdata['timeStamp']."9bcbc5d723cb9bae394d3a097deb6695");
                                $publicKey2 = md5("usky".$timeStamp."9bcbc5d723cb9bae394d3a097deb6695");
                            }else if ($getdata['requestType']==2){
                                $publicKey1 = md5("usky".$getdata['timeStamp']."b9848b4fe4647e380fd1367a4f34ced9");
                                $publicKey2 = md5("usky".$timeStamp."b9848b4fe4647e380fd1367a4f34ced9");
                            }else if ($getdata['requestType']==3){
                                $publicKey1 = md5("usky".$getdata['timeStamp']."056ac8fae059c9c9e700b734922edfc8");
                                $publicKey2 = md5("usky".$timeStamp."056ac8fae059c9c9e700b734922edfc8");
                            }else{
                                $returnInformation['code'] = 60004;
                                $returnInformation['msg'] = "操作失败，requestType不在范围内";
                                $returnInformation['data']=null;
                                return json_encode($returnInformation);
                            }
                        }else{
                            $returnInformation['code'] = 60004;
                            $returnInformation['msg'] = "操作失败，requestType不能为空";
                            $returnInformation['data']=null;
                            return json_encode($returnInformation);
                        }
                        if ($publicKey==$publicKey1){
                            $sensorList['publicKey'] =$publicKey2;
                            $sensorList['timeStamp'] =$timeStamp;
                            $returnInformation['code'] = 200;
                            $returnInformation['msg'] = "操作成功";
                            $returnInformation['data']=$sensorList;
                            return json_encode($returnInformation);
                        }else{
                            $returnInformation['code'] = 60002;
                            $returnInformation['msg'] = "操作失败，publicKey错误";
                            $returnInformation['data']=null;
                            return json_encode($returnInformation);
                        }
                    }else{
                        $returnInformation['code'] = 60004;
                        $returnInformation['msg'] = "操作失败，publicKey不能为空";
                        $returnInformation['data']=null;
                        return json_encode($returnInformation);
                    }
                }
            }
//        }
    }

    //伍继电力java程序校验机制api
    public function wooGiJavaApi(){
        $data=input('');
        if(is_array($data)){
            $getDataJson= json_encode($data,320);
            $getdata=json_decode($getDataJson,true);//转成数组
        }else{
            $getDataJson=$data;
            $getdata=json_decode($getDataJson,true);//转成数组
        }
        $clientIp=$this->ip();
        Log::record('wooGiJavaApi_deviceList' . ':' .'<<<'.$clientIp.'>>>'.$getDataJson);
        $code = 1;
        if ($code==1){
            return 1;
        }else{
            return 0;
        }
    }

    public function s_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)) {
            $infores =  curl_error($ch);
        }else{
            $infores = $info;
        }
        curl_close($ch);
        return $infores;
    }

    public function ypxycurl($url,$data=''){
        $ch = curl_init();
        curl_setopt($ch, CURLOPT_URL, $url);
        curl_setopt($ch, CURLOPT_CUSTOMREQUEST, "POST");
        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, FALSE);
        curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, FALSE);
        curl_setopt($ch, CURLOPT_USERAGENT, 'Mozilla/5.0 (compatible; MSIE 5.01; Windows NT 5.0)');
        curl_setopt($ch, CURLOPT_FOLLOWLOCATION, 1);
        curl_setopt($ch, CURLOPT_AUTOREFERER, 1);
        curl_setopt($ch, CURLOPT_POSTFIELDS, $data);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
        $info = curl_exec($ch);
        if (curl_errno($ch)) {
            $info = 'ERROR: ' . curl_error($ch);
        }
        curl_close($ch);
        return $info;
    }

    public function ywManagementCurl($url,$header,$data=''){
        $ch = curl_init();
        curl_setopt($ch, CURLOPT_URL, $url);
        curl_setopt($ch, CURLOPT_HTTPHEADER,$header);
        curl_setopt($ch, CURLOPT_CUSTOMREQUEST, "POST");
        curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, FALSE);
        curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, FALSE);
//        curl_setopt($ch, CURLOPT_USERAGENT, 'Mozilla/5.0 (compatible; MSIE 5.01; Windows NT 5.0)');
        curl_setopt($ch, CURLOPT_FOLLOWLOCATION, 1);
        curl_setopt($ch, CURLOPT_AUTOREFERER, 1);
        curl_setopt($ch, CURLOPT_POSTFIELDS, $data);
        curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
        $info = curl_exec($ch);
        if (curl_errno($ch)) {
            $info = 'ERROR: ' . curl_error($ch);
        }
        curl_close($ch);
        return $info;
    }
}