ytapi/application/admin/controller/Order.php

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

 	public function index(){

        $data_list =Db::name('order')->paginate();

        $pages = $data_list->render();
        $this->assign('data_list', $data_list);
        $this->assign('pages', $pages);
        return $this->fetch();
 	}

 	public function add(){
		$res=Db::name('order')->where('notifyType',input('notifyType'))->find();
        if(!$res){
        	 if ($this->request->isPost()) {
                $data=$_POST;

                //验证数据
                if(empty($data['notifyType'])||empty($data['callbackUrl'])){
                    return $this->error("请填写好必要内容");
                }

                $token=json_decode(gettoken(),true);
 		    	$sendata=[
                    "notifyType"=>$data['notifyType'],
                    "callbackUrl"=>$data['callbackUrl'],
                    "appId"=>$this->appId,
                 ];

                $header=[
                    "Content-Type:application/json",
                    "app_key:".$this->appId,
                    "Authorization:Bearer ".$token["accessToken"]
                    ];
			//https://server:port/iocm/app/sub/v1.2.0/subscriptions?ownerFlag={ownerFlag}
            $rescurl=curl($this->host."iocm/app/sub/v1.2.0/subscriptions",json_encode($sendata),$header);
           dump($rescurl);
            if($rescurl[0]==201){//成功

                    $res1=json_decode($rescurl[1],true);

                }else{//失败
                  //  $res2=json_decode($res1[1],true);
                    return $this->error($rescurl[1]);
                }
             //添加
                $list=array();
                $list['notifyType']= $data['notifyType'];
                $list['callbackUrl']= $data['callbackUrl'];
                $list['subscriptionId']= $res1['subscriptionId'];
                $list['addtime']= date('Y-m-d H:i:s');
                $list['updatetime']= date('Y-m-d H:i:s');
 				$res = Db::name('order')->insertGetId($list);
                if($res) {
                    return $this->success('添加成功','index');
                }else{
                    return $this->error("添加失败，请稍后再试");
                }
            }
        }else{
            return $this->error("该订阅类型已经填写");
        }

  		$notifyType=Db::table('notifyType')->select();
        $this->assign('notifyType', $notifyType);
 		return $this->fetch();
 	}

  /*	public function edit(){

  		if ($this->request->isPost()) {
                $data=$_POST;

                //验证数据
                if(empty($data['callbackUrl'])){
                    return $this->error("请填写好必要内容");
                }

                $token=json_decode(gettoken(),true);
 		    	$sendata=[
                    "notifyType"=>$data['notifyType'],
                    "callbackUrl"=>$data['callbackUrl'],
                    "appId"=>$this->appId,
                 ];

                $header=[
                    "Content-Type:application/json",
                    "app_key:".$this->appId,
                    "Authorization:Bearer ".$token["accessToken"]
                    ];
			//https://server:port/iocm/app/sub/v1.2.0/subscriptions?ownerFlag={ownerFlag}
            $res1=curl($this->host."iocm/app/sub/v1.2.0/subscriptions",json_encode($sendata),$header);
            $res1=json_decode($res1,true);

                $list=array();
                $list['notifyType']= $data['notifyType'];
                $list['callbackUrl']= $data['callbackUrl'];
                $list['subscriptionId']= $res1['subscriptionId'];
                $list['updatetime']= date('Y-m-d H:i:s');

				 $res = Db::name('order')->where('id',$data['id'])->update($list);
	            if($res) {
	                return $this->success('编辑成功','index');
	            }else{
	                return $this->error("编辑失败，请稍后再试");
	            }

        }

   		$notifyType=Db::table('notifyType')->select();
        $this->assign('notifyType', $notifyType);
  		$res=Db::name('order')->where('id',input('id'))->find();
        $this->assign('data', $res);
 		 return $this->fetch();
 	}*/
 	//删除订阅
 	public function delete(){
 		if ($this->request->isPost()) {
                $data=$_POST;

                $token=json_decode(gettoken(),true);

                $header=[
                    "Content-Type:application/json",
                    "app_key:".$this->appId,
                    "Authorization:Bearer ".$token["accessToken"]
                    ];
			//https://server:port/iocm/app/sub/v1.2.0/subscriptions/{subscriptionId}
            $rescurl=curl($this->host."iocm/app/sub/v1.2.0/subscriptions/".$data['subscriptionId'],"",$header,"DELETE");

            if($rescurl[0]==204){//成功
                Db::name('order')->where('subscriptionId',$data['subscriptionId'])->delete();
                return "1111";
                //将数据库的订阅数据也删掉
            }else{//失败

                return $this->error($rescurl[1]);//
            }


 		}
 	}



 	public function adddata(){
		if ($this->request->isPost()) {
            $data = input('');

            /*            $rand=rand(0,2);
                   $header=["Content-Type:application/json"];

                   //将数据分配给不同的服务
                   $httpserver=["http://47.98.153.212:1101","http://47.98.153.212:1102","http://47.98.153.212:1103"];
                   $server=$httpserver[$rand];

                   //将数据随机转发到别的平台做处理
                    $res=curltest($server,$data,$header);
             */
            $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;
            }
            //  $list['data']=11;
            $list['response'] = "111";

            $list['notifyType'] = $getdata["notifyType"];
            $list['deviceId'] = $getdata["deviceId"];
            $list['addtime'] = date('Y-m-d H:i:s');
            $res = Db::name('noticedata')->insertGetId($list);//将推送的数据存入总表
            Log::record('deviceId' . ':' . $getdata["service"]["eventTime"]);
            //在详细表里插入数据
            //根据设备id查找到device里的device_id
            if (trim($getdata["notifyType"]) == "deviceDataChanged") {
                $device = Db::name('device')->where('iot_id', trim($getdata["deviceId"]))->find();

                $datainfo = array();
                $datainfo['notifyType'] = $getdata["notifyType"];
                $datainfo['device_id'] = $device["device_id"];
                $datainfo['iot_id'] = $getdata["deviceId"];
                $datainfo['service'] = json_encode($getdata["service"]);
                $datainfo['addtime'] = date('Y-m-d H:i:s');

                $res1 = Db::table('dev_' . $device["device_id"])->insertGetId($datainfo);
                $data2=array();
                $data2['devicestatus'] = 0;
                $data2['true_status'] = '0';
                $data2['lastcommtime'] = date('Y-m-d H:i:s');
                $sql2="UPDATE sp_devices_status SET statustime = {$data2['lastcommtime']} devicestatus = {$data2['devicestatus']},true_status={$data2['true_status']},lastcommtime='{$data2['lastcommtime']}' WHERE deviceid='{$device['device_id']}'";
                $res2 = addDataInfo($sql2);
                if ($device['deviceType']=='Smoke') {
                    $data3 = array();
                    $data3['device_id'] = $device["device_id"];
                    $data3['RSRQ'] = $getdata["service"]['data']['RSRQ'];
                    $data3['CSQ'] = $getdata["service"]['data']["CSQ"];
                    $data3['DeviceType'] = $getdata["service"]['data']["DeviceType"];
                    $data3['DeviceStatus'] = $getdata["service"]['data']["DeviceStatus"];
                    $data3['BatteryLevel'] = $getdata["service"]['data']["BatteryLevel"];
                    $data3['SensorLevel'] = $getdata["service"]['data']["SensorLevel"];
                    $data3['eventTime'] = $getdata["service"]["eventTime"];
                    $data3['storeTime'] = date('Y-m-d H:i:s');
                    $sql = "INSERT INTO sp_y{$data3['device_id']} VALUES ('','{$data3['device_id']}',
'{$data3['RSRQ']}', '{$data3['CSQ']}', '{$data3['DeviceType']}','{$data3['DeviceStatus']}','{$data3['BatteryLevel']}','{$data3['SensorLevel']}','{$data3['eventTime']}','{$data3['storeTime']}')";
                    $res3 = addDataInfo($sql);
                } elseif($device['deviceType']=='MultiSensor') {

                    $data3 = array();
                    $data3['device_id'] = $device["device_id"];
                    $data3['port'] = 'tp_water_pressure';
                    $data3['storeTime'] = date('Y-m-d H:i:s');
                    $data3['unit'] =$getdata["service"]['data']["unit"];
//                    $data3['messageId'] = $getdata["service"]['data']["messageId"];
                    $data3['batteyValue'] = $getdata["service"]['data']["batteyValue"];
                    $data3['alarmBoolean'] = $getdata["service"]['data']["alarmBoolean"];
                    $unit=dechex($getdata["service"]['data']["unit"]);
                    Log::record('sql1234'.':'.$unit);
                    $sql11="SELECT dwtype FROM sp_owner WHERE owner_code ='{$device["device_id"]}'";
                    $dwtype = add($sql11);
                    $arr_y=array('10','11','20','21','22');
                    if ($dwtype[0]['dwtype'] == 5){
                        if ($data3['unit']== 1){
                            $data3['data1']='LL2';
                        }elseif($data3['unit']== 2){
                            $data3['data1']='LL1';
                        }else{
                            $data3['data1']='LL0';
                        }
                    }else {
                        if ($data3['unit']== 1){
                            $data3['data1']='WP2';
                        }elseif($data3['unit']== 2){
                            $data3['data1']='WP1';
                        }else{
                            $data3['data1']='WP0';
                        }
                    }
                    switch ($unit){
                        case '10':
                            $data3['data4'] = $getdata["service"]['data']["data"]*0.0001;
                            break;
                        case '11':
                            $data3['data4'] = $getdata["service"]['data']["data"]*0.001;
                            break;
                        case '20':
                            $data3['data4'] = $getdata["service"]['data']["data"]*0.01;
                            break;
                        case '21':
                            $data3['data4'] = $getdata["service"]['data']["data"]*0.1;
                            break;
                        case '22':
                            $data3['data4'] = $getdata["service"]['data']["data"];
                            break;
                        case '30':
                            $data3['data4'] = $getdata["service"]['data']["data"]*0.0000001;
                            break;
                        case '31':
                            $data3['data4'] = $getdata["service"]['data']["data"]*0.000001;
                            break;
                        case '40':
                            $data3['data4'] = $getdata["service"]['data']["data"]*0.00001;
                            break;
                        case '41':
                            $data3['data4'] = $getdata["service"]['data']["data"]*0.0001;
                            break;
                        case '42':
                            $data3['data4'] = $getdata["service"]['data']["data"]*0.001;
                            break;
                        case '50':
                            $data3['data4'] = $getdata["service"]['data']["data"]*0.01;
                            break;
                        case '51':
                            $data3['data4'] = $getdata["service"]['data']["data"]*0.1;
                            break;
                        case '52':
                            $data3['data4'] = $getdata["service"]['data']["data"];
                            break;
                        case '2':
                            $data3['data4'] = $getdata["service"]['data']["data"]*0.001;
                            break;
                        case '1':
                            $data3['data4'] = $getdata["service"]['data']["data"]*0.001;
                            break;
                    }
                    $data3['data'] = $getdata["service"]['data']["data"];
                    $sql = "INSERT INTO sp_d{$data3['device_id']} VALUES ('','{$data3['device_id']}','{$data3['port']}','{$data3['storeTime']}',
'','','','{$data3['data1']}','{$data3['batteyValue']}','5','{$data3['data4']}','11111111111')";
//                    Log::record('sql1234'.':'.$sql);
                    $res4 = addDataInfo($sql);
                }elseif ($device['deviceType']=='WaterMeter'){
                    //宇洁容情
                    Log::record('xinshuibiaozhi'.':'.$getdata["service"]['data']['data']);
                    $data3 = array();
                    $data3['device_id'] = $device["device_id"];
                    $data3['port'] = 'tp_water_pressure';
                    $data3['storeTime'] = date('Y-m-d H:i:s');
                    $data3['batteyValue'] = dechex($getdata["service"]['data']["battery"]);
                    $data3['unit'] =dechex($getdata["service"]['data']['data']);
                    $data3['device_type'] =dechex($getdata["service"]['data']['device_type']);
                    $data3['address'] = '180.101.147.89';
                    $data3['alarmBoolean'] = $getdata["service"]['data']["alarm"];
                    $alarm=dechex($data3['alarmBoolean']);
                    $data3['sign'] = round($getdata["service"]['data']["signal"]/6);
                    $data3['coeffice'] = dechex($getdata["service"]['data']["coeffice"]);
                    if ($data3['alarmBoolean']!== 0){
                        if ($data3['alarmBoolean']== 161){
                            $data3['data1']='WP1';
                        }else{
                            $data3['data1']='WP2';
                        }
                    }else {
                        $data3['data1'] = 'WP0';
                    }
                    if ($data3['device_type']=='ae'){
                    switch ($data3['coeffice']){
                        case 'd3':
                            $data3['data4'] = $data3['unit']*0.001;
                            break;
                        case 'd2':
                            $data3['data4'] = $data3['unit']*0.01;
                            break;
                        case 'd1':
                            $data3['data4'] = $data3['unit']*0.1;
                            break;
                        case 'e0':
                            $data3['data4'] = $data3['unit'];
                            break;
                        case 'e1':
                            $data3['data4'] = $data3['unit']*10;
                            break;
                        case 'e2':
                            $data3['data4'] = $data3['unit']*100;
                            break;
                      }

                    $sql = "INSERT INTO sp_d{$data3['device_id']} VALUES ('','{$data3['device_id']}','{$data3['port']}','{$data3['storeTime']}',
'','','','{$data3['data1']}','{$data3['batteyValue']}','{$data3['sign']}','{$data3['data4']}','11111111111')";
                    $res5 = addDataInfo($sql);
                    if ($data3['alarmBoolean']!== 0){
                        $sql = "INSERT INTO sp_sj2017 VALUES ('','tp_water_pressure','{$data3['device_id']}','{$data3['storeTime']}','$alarm','{$data3['address']}', ''
,'{$data3['data1']}','{$data3['batteyValue']}','{$data3['sign']}','{$data3['data4']}','','','','','','','','','','')";
                        $insert_id = addDataInfo($sql);
//                        $sql66="update sp_devices_status set statustime=".$data3['storeTime'];
                        Log::record('yujie'.':'.$insert_id);
//                        $update_id = addDataInfo($sql66);
                        $insert_id_sql="select id from sp_sj2017 where device_code='".$data3['device_id']."' and time='".$data3['storeTime']."'";
                        Log::record('sql987'.':'.$insert_id_sql);
                        $insert_id66=add($insert_id_sql);
                        Log::record('sql253232'.':'.$insert_id66[0]['id']);
                        if ($data3['alarmBoolean']== 161){
                            $msg['evt'] = "WP1";
                            $msg['msg'] = "低压";
                        }else{ // high
                            $msg['evt'] = "WP2";
                            $msg['msg'] = "高压";
                        }
                        if ( $msg['evt']=='WP1' || $msg['evt']=='WP2' ) {
                            $sql3="select s.owner_name,s.unitinfo,s.company,c.owner_address from sp_owner s ,sp_owner_company c where s.company=c.owner_id and s.owner_code ='{$device["device_id"]}'";
                            $company = add($sql3);
                            $sql4="select phone from sp_owner_phone  WHERE owner_code='".$company[0]['company']."' AND data2 like '%3%'  union select phone from sp_owner_phone  WHERE owner_code in (select other_code from sp_owner_fujin where owner_code='".$company[0]['company']."') AND data2 like '%3%'";
                            $union_sql=add($sql4);
//                            Log::record('sql12345'.':'.$sql4);
                            $openids=$this->array_column1($union_sql,"phone");
                            if (empty($openids))
                            {
                                echo 'open is null';
                                exit;
                            }
//                            Log::record('data666_phone'.':'.$openids);
                            $sql5="SELECT openid FROM sp_wx_customuser WHERE type='wx' and idphone in($openids)";
                            $op=add($sql5);
                            $access_token=GetAccess_Token();
                            $address='警报地址：'.$company[0]['owner_address'].$company[0]['unitinfo'];
                            $deviceid=$device["device_id"];
                            $type=$msg['msg'];
                            $time=$data3['storeTime'];
                            $remark='设备名称：'.$company[0]['owner_name'];

                            $url_wx_push2        = "https://iot.usky.cn/jdxf/wxapp2.php/Home/Waterwarn/message_water";
                            Log::record('data666_url_wx_push2'.':'. $url_wx_push2);
                            $data666['IMEI']=$device["device_id"];
                            Log::record('data666_IMET'.':'.$data666['IMEI']);
                            $data666['phone']=$openids;
                            Log::record('data666_phone'.':'.$data666['phone']);
                            $data666['evt']=$data3['data1'];
                            Log::record('data666_evt'.':'.$data666['evt']);
                            $data666['insert_id']=$insert_id66[0]['id'];
                            Log::record('data666_insert_id'.':'.$data666['insert_id']);
                            $data666['time']=$data3['storeTime'];
//                            Log::record('data666'.':'.$data666);
                            $sql88="UPDATE sp_devices_status SET statustime ='".$data3['storeTime']."' where deviceid='".$data666['IMEI']."'";
                            addDataInfo($sql88);
                            $this->curl($url_wx_push2,$data666);
                            $waterData["SubType"] = 2;
                            $waterData["DeviceId"] = $data666['IMEI'];
                            $waterData["InsertId"] = $insert_id66[0]['id'];
                            $waterData["Confirmed"] = false;
                            $data6 = json_encode($waterData);
                            $rep_url = "http://47.98.201.187:55335/report";
                            $res = $this->curl($rep_url, $data6);
//                            $url_wx_push2        = "http://www.jd-ioe.com/jdxf/wxapp2.php/Home/Waterwarn/bj";
                            foreach($op as $key => $o){
                                if (!empty($o['openid']))
                                {
//                                    $data88['openid']=$o['openid'];
//                                    $data88['address']=$address;
//                                    $data88['deviceid']=$deviceid;
//                                    $data88['type']=$type;
//                                    $data88['time']=$time;
//                                    $data88['remark']=$remark;
                                    //token，微信id，地址，设备号，类型，时间，设备名称（或者其他内容）
                                    //{{first.DATA}}$address
                                    //设备号：{{keyword1.DATA}}$deviceid
                                    //报警类型：{{keyword2.DATA}}$type
                                    //时间：{{keyword3.DATA}}$time
                                    //{{remark.DATA}}$remark
                                    $Message=$this->SendDeviceAlarm($access_token,$o['openid'],$address,$deviceid,$type,$time,$remark,$url='');
//                                    s_curl($url_wx_push2,$data88);
                                    $Message['openid']=$o['openid'];
                                    $arr[$key]=$Message;

                                }
                            }
                        }
                    }
                    }
                }elseif ($device['deviceType']=='topsailSensor'){
                    //拓普索尔
                    Log::record('tuopusuoershuibiao'.':'.$getdata["service"]['data']['Imei']);
                    $data3 = array();
                    $data4 = array();
                    $data5 = array();
                    $sensorList = array();
                    $sensorListArray = array();
                    $data4['provider'] = 'Usky';
                    $data3['device_id'] = $device["device_id"];
                    $data3['port'] = 'TuoPuSuoEr-TSM-04P';
                    $data3['storeTime'] = date('Y-m-d H:i:s');
                    $data3['batteyValue'] = $getdata["service"]['data']["batteryLevel"];
                    $data3['data'] =substr($getdata["service"]['data']["sampleData"],-5);
                    $data3['unit'] =substr($getdata["service"]['data']["sampleData"],0,1);
                    $data3['device_type'] =$getdata["service"]['data']['deviceType'];
                    $data3['sendTime'] =$getdata["service"]['data']['sendTime'];
                    $data3['address'] = '180.101.147.89';
                    $data3['alarmBoolean'] = $getdata["service"]['data']["alarmType"];
                    $data3['sign'] = round($getdata["service"]['data']["signalStrength"]/6);
                    $sql6="select * from sp_owner where owner_code ='{$device["device_id"]}'";
                    $longHuCompany = add($sql6);
                    $sensorList['sensorId'] = (int)$longHuCompany[0]['id'];
                    if($data3['device_type']==1 || $data3['device_type']==4){
                        if ($data3['alarmBoolean']!== '0'){
                            if ($data3['alarmBoolean']== '1'){
                                $data3['data1']='WP1';
                                $sensorList['status'] = 3;
                                $sensorList['desc'] = $longHuCompany[0]['unitinfo'].'-'.$longHuCompany[0]['owner_name'].'-压力低于下限';
                                $topic = 'mh/water/alert';
                                $ytTMhwater = Db::name('yt_t_mhwater')->where('device_code', trim($device["device_id"]))->find();
                                if (!empty($ytTMhwater)) {
                                    $mhMqtt['deviceCode']=$ytTMhwater['mh_device_code'];
                                    $mhMqtt['addr']='上海市';
                                    $mhMqtt['eventCode1']='02';
                                    $mhMqtt['eventName1']='预警事件';
                                    $mhMqtt['eventCode2']='02008';
                                    $mhMqtt['eventName2']='水压报警';
                                    $mhMqtt['description']='低压';
                                    $mhMqtt['lon']=(double)$ytTMhwater['longitude'];
                                    $mhMqtt['lat']=(double)$ytTMhwater['latitude'];
                                    $mhMqtt['createdTime']=time();
                                    $param = ["platform_cy"=>$ytTMhwater['platform_cy'],"scenetype_cy"=>$ytTMhwater['scenetype_cy']];
                                    $mhMqtt['param']=$param;
                                    $mhMqttJson = json_encode($mhMqtt);
                                    $this->message_push_mh($topic,$mhMqttJson,0);
                                }
                            }elseif ($data3['alarmBoolean']== '2'){
                                $data3['data1']='WP2';
                                $sensorList['status'] = 4;
                                $sensorList['desc'] = $longHuCompany[0]['unitinfo'].'-'.$longHuCompany[0]['owner_name'].'-压力超过上限';
                                $topic = 'mh/water/alert';
                                $ytTMhwater = Db::name('yt_t_mhwater')->where('device_code', trim($device["device_id"]))->find();
                                if (!empty($ytTMhwater)) {
                                    $mhMqtt['deviceCode']=$ytTMhwater['mh_device_code'];
                                    $mhMqtt['addr']='上海市';
                                    $mhMqtt['eventCode1']='02';
                                    $mhMqtt['eventName1']='预警事件';
                                    $mhMqtt['eventCode2']='02008';
                                    $mhMqtt['eventName2']='水压报警';
                                    $mhMqtt['description']='高压';
                                    $mhMqtt['lon']=(double)$ytTMhwater['longitude'];
                                    $mhMqtt['lat']=(double)$ytTMhwater['latitude'];
                                    $mhMqtt['createdTime']=time();
                                    $param = ["platform_cy"=>$ytTMhwater['platform_cy'],"scenetype_cy"=>$ytTMhwater['scenetype_cy']];
                                    $mhMqtt['param']=$param;
                                    $mhMqttJson = json_encode($mhMqtt);
                                    $this->message_push_mh($topic,$mhMqttJson,0);
                                }
                            }
                        }else {
                            $topic = 'mh/water/info';
                            $ytTMhwater = Db::name('yt_t_mhwater')->where('device_code', trim($device["device_id"]))->find();
                            if (!empty($ytTMhwater)) {
                                $mhMqtt['deviceCode']=$ytTMhwater['mh_device_code'];
                                $mhMqtt['signalLevel']=(int)$data3['sign']*20;
                                $mhMqtt['volt']=(int)$data3['batteyValue'];
                                $mhMqtt['lon']=(double)$ytTMhwater['longitude'];
                                $mhMqtt['lat']=(double)$ytTMhwater['latitude'];
                                $mhMqtt['createdTime']=time();
                                $param = ["platform_cy"=>$ytTMhwater['platform_cy'],"scenetype_cy"=>$ytTMhwater['scenetype_cy']];
                                $mhMqtt['param']=$param;
                                $mhMqttJson = json_encode($mhMqtt);
                                $this->message_push_mh($topic,$mhMqttJson,0);
                            }
                            $data3['data1'] = 'WP0';
                            $sensorList['status'] = 0;
                            $sensorList['desc'] = $longHuCompany[0]['unitinfo'].'-'.$longHuCompany[0]['owner_name'].'-压力正常';
                        }
                        $data4['deviceType'] = 'XiaoFangShuiYa';
                        $sensorList['unit'] = 'MPa';
                    }elseif ($data3['device_type']==2){
                        if ($data3['alarmBoolean']!== '0'){
                            if ($data3['alarmBoolean']== '1'){
                                $data3['data1']='LL1';
                                $sensorList['status'] = 3;
                                $sensorList['desc'] = $longHuCompany[0]['unitinfo'].'-'.$longHuCompany[0]['owner_name'].'-液位低于下限';
                            }elseif ($data3['alarmBoolean']== '2'){
                                $data3['data1']='LL2';
                                $sensorList['status'] = 4;
                                $sensorList['desc'] = $longHuCompany[0]['unitinfo'].'-'.$longHuCompany[0]['owner_name'].'-液位超过上限';
                            }
                        }else {
                            $data3['data1'] = 'LL0';
                            $sensorList['status'] = 0;
                            $sensorList['desc'] = $longHuCompany[0]['unitinfo'].'-'.$longHuCompany[0]['owner_name'].'-液位正常';
                        }
                        $data4['deviceType'] = 'YeWei';
                        $sensorList['unit'] = 'm-米';
                    }
                    if (!empty($data3['sendTime'])) {
                        switch ($data3['unit']) {
                            case '0':
                                $data3['data4'] = $data3['data'] * 1;
                                break;
                            case '1':
                                $data3['data4'] = $data3['data'] * 0.1;
                                break;
                            case '2':
                                $data3['data4'] = $data3['data'] * 0.01;
                                break;
                            case '3':
                                $data3['data4'] = $data3['data'] * 0.001;
                                break;
                            case '4':
                                $data3['data4'] = $data3['data'] * 0.0001;
                                break;
                        }
                        $sql = "INSERT INTO sp_d{$data3['device_id']} VALUES ('','{$data3['device_id']}','{$data3['port']}','{$data3['storeTime']}',
'','','','{$data3['data1']}','{$data3['batteyValue']}','{$data3['sign']}','{$data3['data4']}','11111111111')";
                        $res5 = addDataInfo($sql);
                        if ($data3['alarmBoolean']== '0'){
                            $json_data_qone = $this->mqqt_data_recombination("INFO", $data3['device_id'], $longHuCompany[0]['owner_name'], $data3['batteyValue'], $data3['sign'], $data3['data4'],$longHuCompany[0]['dwtype']);
                            if (!empty($json_data_qone)){
                                $topicYp_one = '/usky/ytDP0002/'.$longHuCompany[0]['company'].'/'.$data3['device_id'].'/info';
                                $this->message_push_mh($topicYp_one, $json_data_qone, 0);
                            }
                        }else{
                            $json_data_qtwo = $this->mqqt_data_recombination("ALARM", $data3['device_id'], $longHuCompany[0]['owner_name'], $data3['batteyValue'], $data3['sign'], $data3['data4'],$longHuCompany[0]['dwtype']);
                            if (!empty($json_data_qtwo)){
                                $topicYp_two = '/usky/ytDP0002/'.$longHuCompany[0]['company'].'/'.$data3['device_id'].'/alarm';
                                $this->message_push_mh($topicYp_two, $json_data_qtwo, 0);
                            }
                        }
                        if ($longHuCompany[0]['company']=='10232'|| $longHuCompany[0]['company']=='10318'){
                            $data4['dataType'] = 'deviceInfo';
                            $data4['softVersion'] = '1.00.00';
                            $data4['hardVersion'] = '0.1';
                            $sensorList['pointValue'] = $data3['data4'];
                            $deviceConfigure = Db::name('deviceConfigure')->where('device_code', trim($device["device_id"]))->find();
                            if(!empty($deviceConfigure)){
                                $sensorList['lowThreshold'] = (double)$deviceConfigure['low_threshold'];
                                $sensorList['highThreshold'] = (double)$deviceConfigure['high_threshold'];
                                $sensorList['sendTime'] = (int)$deviceConfigure['send_time'];
                            }else{
                                $sensorList['lowThreshold'] = 0;
                                $sensorList['highThreshold'] = 0;
                                $sensorList['sendTime'] = 1800;
                            }
                            $sensorListArray[0] = $sensorList;
                            $data4['sensorList'] = $sensorListArray;
                            if ($longHuCompany[0]['company']=='10232'){
                                $data5['mqttId'] = 'a71c40bb-5b02-4741-881b-24449f699db5';
                            }else{
                                $data5['mqttId'] = 'a71c40bb-5b02-4741-881b-24449f699db6';
                            }
                            $data5['action'] = 'transpush';
                            $data5['data'] = $data4;
                            $data6 = json_encode($data5);
                            $rep_url = "http://47.98.201.73:55126/report";
                            $res = $this->curl($rep_url,$data6);
                            Log::record('minhanglonghuduijie'.':'.$res);
                        }
                        if ($data3['alarmBoolean']!== '0'){
                            $sql = "INSERT INTO sp_sj2017 VALUES ('','TuoPuSuoEr-TSM-04P','{$data3['device_id']}','{$data3['storeTime']}','{$data3['alarmBoolean']}','{$data3['address']}', ''
,'{$data3['data1']}','{$data3['batteyValue']}','{$data3['sign']}','{$data3['data4']}','','','','','','','','','','')";
                            $insert_id = addDataInfo($sql);
//                        $sql66="update sp_devices_status set statustime=".$data3['storeTime'];
//                        Log::record('sql66'.':'.$sql66);
//                        $update_id = addDataInfo($sql66);
                            $insert_id_sql="select id from sp_sj2017 where device_code='".$data3['device_id']."' and time='".$data3['storeTime']."'";
                            Log::record('sql98725'.':'.$insert_id_sql);
                            $insert_id66=add($insert_id_sql);
                            if($data3['device_type']==1 || $data3['device_type']==4){
                                if ($data3['alarmBoolean']== '1'){
                                    $msg['evt'] = "WP1";
                                    $msg['msg'] = "低压";
                                }elseif ($data3['alarmBoolean']== '2'){ // high
                                    $msg['evt'] = "WP2";
                                    $msg['msg'] = "高压";
                                }
                            }elseif ($data3['device_type']==2){
                                if ($data3['alarmBoolean']== '1'){
                                    $msg['evt'] = "LL1";
                                    $msg['msg'] = "低水位";
                                }elseif ($data3['alarmBoolean']== '2'){ // high
                                    $msg['evt'] = "LL2";
                                    $msg['msg'] = "高水位";
                                }
                            }
                            if ( $msg['evt']=='WP1' || $msg['evt']=='WP2' || $msg['evt']=='LL2' || $msg['evt']=='LL1') {
                                $sql3="select s.owner_name,s.unitinfo,s.company,c.owner_address from sp_owner s ,sp_owner_company c where s.company=c.owner_id and s.owner_code ='{$device["device_id"]}'";
                                $company = add($sql3);
                                $sql4="select phone from sp_owner_phone  WHERE owner_code='".$company[0]['company']."' AND data2 like '%3%'  union select phone from sp_owner_phone  WHERE owner_code in (select other_code from sp_owner_fujin where owner_code='".$company[0]['company']."') AND data2 like '%3%'";
                                $union_sql=add($sql4);
//                            Log::record('sql12345'.':'.$sql4);
                                $openids=$this->array_column1($union_sql,"phone");
                                if (empty($openids))
                                {
                                    echo 'open is null';
                                    exit;
                                }
//                            Log::record('data666_phone'.':'.$openids);
                                $sql5="SELECT openid FROM sp_wx_customuser WHERE type='wx' and idphone in($openids)";
                                $op=add($sql5);
                                $access_token=GetAccess_Token();
                                $address='警报地址：'.$company[0]['owner_address'].$company[0]['unitinfo'];
                                $deviceid=$device["device_id"];
                                $type=$msg['msg'];
                                $time=$data3['storeTime'];
                                $remark='设备名称：'.$company[0]['owner_name'];

                                $url_wx_push2        = "https://iot.usky.cn/jdxf/wxapp2.php/Home/Waterwarn/message_water";
                                Log::record('data666_url_wx_push2'.':'. $url_wx_push2);
                                $data666['IMEI']=$device["device_id"];
                                Log::record('data666_IMET'.':'.$data666['IMEI']);
                                $data666['phone']=$openids;
                                Log::record('data666_phone'.':'.$data666['phone']);
                                $data666['evt']=$data3['data1'];
                                Log::record('data666_evt'.':'.$data666['evt']);
                                $data666['insert_id']=$insert_id66[0]['id'];
                                Log::record('data666_insert_id'.':'.$data666['insert_id']);
                                $data666['time']=$data3['storeTime'];
//                            Log::record('data666'.':'.$data666);
                                $sql88="UPDATE sp_devices_status SET statustime ='".$data3['storeTime']."' where deviceid='".$data666['IMEI']."'";
                                addDataInfo($sql88);
                                $this->curl($url_wx_push2,$data666);
                                $rep['SubType']=2;
                                $rep['DeviceId']=$device["device_id"];
                                $rep['InsertId']=$insert_id66[0]['id'];
                                $rep['Confirmed']=0;
                                $rep['CompanyCode']=$company[0]['company'];
                                $rep['evt_name']=$data3['data1'];
                                $rep['evt']=0;
                                $rep['alarm_time']=$data3['storeTime'];
                                $rep2 = json_encode($rep);
                                $rep_url = "http://47.98.201.73:55125/report";
                                $res = $this->curl($rep_url,$rep2);
                                Log::record('TuoPuSuoEr-TSM-04P'.':'.$res);
                                $waterData["SubType"] = 2;
                                $waterData["DeviceId"] = $data666['IMEI'];
                                $waterData["InsertId"] = $insert_id66[0]['id'];
                                $waterData["Confirmed"] = false;
                                $data6 = json_encode($waterData);
                                $rep_url = "http://47.98.201.187:55335/report";
                                $res = $this->curl($rep_url, $data6);

//                            $url_wx_push2        = "http://www.jd-ioe.com/jdxf/wxapp2.php/Home/Waterwarn/bj";
                                foreach($op as $key => $o){
                                    if (!empty($o['openid']))
                                    {
                                        $Message=$this->SendDeviceAlarm($access_token,$o['openid'],$address,$deviceid,$type,$time,$remark,$url='');
//                                    s_curl($url_wx_push2,$data88);
                                        $Message['openid']=$o['openid'];
                                        $arr[$key]=$Message;

                                    }
                                }
                            }
                      }
                    }
                }
                if ($device['deviceType']=='Smoke') {
                    if ($getdata["service"]['data']["DeviceStatus"]!== 7){
                        $arr_bit = array(
                            "","报警","报警静音","保留","低压","故障","保留"
                        );
                        $deviceStatus=$getdata["service"]['data']["DeviceStatus"];
                    $data3 = array();
                    $data3['device_code'] = $device["device_id"];
                    $data3['time'] = date('Y-m-d H:i:s');
                    $data3['status'] = 'y'.'0'.$deviceStatus;
                    $data3['address'] = '180.101.147.89';
                    $data3['compartment'] = '';
                    $data3['fireprocess'] = '';
                    $data3['flowendtime'] = '0000-00-00 00:00:00';
                    $data3['ncmd'] = 'y'.'0'.$deviceStatus;
                    $data3['data1'] = 'y'.'0'.$deviceStatus;
                    $data3['data2'] = $arr_bit["{$deviceStatus}"];
                    $data3['data3'] = '';
                    $data3['data4'] = '烟雾'.$arr_bit["{$deviceStatus}"];
                    $data3['data5'] = '';
                    $sql = "INSERT INTO sp_hj2017 VALUES ('','','{$data3['device_code']}','{$data3['time']}','{$data3['status']}','{$data3['address']}','{$data3['compartment']}',
'{$data3['fireprocess']}', '{$data3['flowendtime']}', '{$data3['ncmd']}','{$data3['data1']}','{$data3['data2']}','{$data3['data3']}','{$data3['data4']}','{$data3['data5']}','','',''
,'','','','','','')";

                    $res5 = addDataInfo($sql);
                        $insert_id_sql="select id from sp_hj2017 where device_code='".$data3['device_code']."' and time='".$data3['time']."'";
                        Log::record('sql66886688'.':'.$insert_id_sql);
                        $insert_id66=add($insert_id_sql);
//                        $sql66="update sp_devices_status set statustime=".$data3['time'];
//                        Log::record('sql66'.':'.$sql66);
//                        $update_id = addDataInfo($sql66);
                    }
                    $arr_h=array(1,2);
                    if (in_array($getdata["service"]['data']["DeviceStatus"],$arr_h)){
                        $sql3="select s.owner_name,s.unitinfo,s.company,c.owner_address from sp_owner s ,sp_owner_company c where s.company=c.owner_id and s.owner_code ='{$device["device_id"]}'";
                        Log::record('sql3'.':'.$sql3);
                        $company = add($sql3);
                        Log::record('company'.':'.$company[0]['company']);
                        $sql4="select phone from sp_owner_phone  WHERE owner_code='".$company[0]['company']."' AND data2 like '%6%'  union select phone from sp_owner_phone  WHERE owner_code in (select other_code from sp_owner_fujin where owner_code='".$company[0]['company']."') AND data2 like '%6%'";
                        Log::record('sql4'.':'.$sql4);
                        $union_sql=add($sql4);
                        $openids=$this->array_column1($union_sql,"phone");
                        if (empty($openids))
                        {
                            echo 'open is null';
                            exit;
                        }
                        $sql5="SELECT openid FROM sp_wx_customuser WHERE type='wx' and idphone in($openids)";
                        $op=add($sql5);
                        $access_token=GetAccess_Token();
                        $address='警报地址：'.$company[0]['owner_address'].$company[0]['unitinfo'];
                        $deviceid=$device["device_id"];
                        $type='烟雾';
                        $time=$data3['time'];
                        $remark='设备名称：'.$company[0]['owner_name'];

                        $url_wx_push2        = "https://iot.usky.cn/jdxf/wxapp2.php/Home/Waterwarn/bj";
                        Log::record('data666_url_wx_push2'.':'.$url_wx_push2);
                        $data666['phone']=$openids;
                        Log::record('data666_phone'.':'.$data666['phone']);
                        $data666['IMEI']=$device["device_id"];
                        Log::record('data666_IMEI'.':'.$data666['IMEI']);
                        $data666['time']=$data3['time'];
                        Log::record('data666_time'.':'.$data666['time']);
                        $data666['evt']=$data3['data1'];
                        Log::record('data666_evt'.':'.$data666['evt']);
                        $data666['insert_id']=$insert_id66[0]['id'];
                        Log::record('data666_insert_id'.':'.$data666['insert_id']);
                        $this->curl($url_wx_push2,$data666);

                        foreach($op as $key => $o){
                            if (!empty($o['openid']))
                            {

                                $Message=$this->SendDeviceAlarm($access_token,$o['openid'],$address,$deviceid,$type,$time,$remark,$url='');
//                                s_curl($url_wx_push2,$data88);
                                $Message['openid']=$o['openid'];
                                $arr[$key]=$Message;

                            }
                        }
                    }
                } elseif($device['deviceType']=='MultiSensor') {
                    if($getdata["service"]['data']["alarmBoolean"]== 17){
//                        $sql1="SELECT * from 'dev_' . {$device["device_id"]} where addtime=(select max(addtime) from 'dev_' . {$device["device_id"]})";
//                        $Model = M();
//                        $result = $Model->query($sql1);
//                        $service=json_decode($result['']['service']);
                        $unit=dechex($getdata["service"]['data']["unit"]);
                        $data3 = array();
                        $data3['device_code'] = $device["device_id"];
                        $data3['time'] = date('Y-m-d H:i:s');
                        $data3['status'] = $getdata["service"]['data']["alarmBoolean"];
                        $data3['address'] = '180.101.147.89';
                        $data3['ncmd'] = '';
                        $data3['unit'] =$getdata["service"]['data']["unit"];
                        $arr_y=array('10','11','20','21','22');
                        $sql11="SELECT dwtype FROM sp_owner WHERE owner_code ='{$device["device_id"]}'";
                        $dwtype = add($sql11);
                        if ($dwtype[0]['dwtype'] == 5){
                            if ($data3['unit']== 1){
                                $data3['data1']='LL2';
                            }elseif($data3['unit']== 2){
                                $data3['data1']='LL1';
                            }else{
                                $data3['data1']='LL0';
                            }
                        }else {
                            if ($data3['unit']== 1){
                                $data3['data1']='WP2';
                            }elseif($data3['unit']== 2){
                                $data3['data1']='WP1';
                            }else{
                                $data3['data1']='WP0';
                            }
                        }
                        $data3['data2'] = $getdata["service"]['data']["batteyValue"];
                        $data3['data3'] = '';
                        switch ($unit){
                            case '10':
                                $data3['data4'] = $getdata["service"]['data']["data"]*0.0001;
                                break;
                            case '11':
                                $data3['data4'] = $getdata["service"]['data']["data"]*0.001;
                                break;
                            case '20':
                                $data3['data4'] = $getdata["service"]['data']["data"]*0.01;
                                break;
                            case '21':
                                $data3['data4'] = $getdata["service"]['data']["data"]*0.1;
                                break;
                            case '22':
                                $data3['data4'] = $getdata["service"]['data']["data"];
                                break;
                            case '30':
                                $data3['data4'] = $getdata["service"]['data']["data"]*0.0000001;
                                break;
                            case '31':
                                $data3['data4'] = $getdata["service"]['data']["data"]*0.000001;
                                break;
                            case '40':
                                $data3['data4'] = $getdata["service"]['data']["data"]*0.00001;
                                break;
                            case '41':
                                $data3['data4'] = $getdata["service"]['data']["data"]*0.0001;
                                break;
                            case '42':
                                $data3['data4'] = $getdata["service"]['data']["data"]*0.001;
                                break;
                            case '50':
                                $data3['data4'] = $getdata["service"]['data']["data"]*0.01;
                                break;
                            case '51':
                                $data3['data4'] = $getdata["service"]['data']["data"]*0.1;
                                break;
                            case '52':
                                $data3['data4'] = $getdata["service"]['data']["data"];
                                break;
                            case '2':
                                $data3['data4'] = $getdata["service"]['data']["data"]*0.001;
                                break;
                            case '1':
                                $data3['data4'] = $getdata["service"]['data']["data"]*0.001;
                                break;
                        }
                        $data3['data5'] = '';
                        $sql = "INSERT INTO sp_sj2017 VALUES ('','tp_water_pressure','{$data3['device_code']}','{$data3['time']}','{$data3['status']}','{$data3['address']}', '{$data3['ncmd']}'
,'{$data3['data1']}','{$data3['data2']}','{$data3['data3']}','{$data3['data4']}','{$data3['data5']}','','','','','','','','','')";
//                        Log::record('sql123'.':'.$sql);
                        $insert_id = addDataInfo($sql);
                        $insert_id_sql="select id from sp_sj2017 where device_code='".$data3['device_id']."' and time='".$data3['time']."'";
                        Log::record('sql987253232'.':'.$insert_id_sql);
                        $insert_id66=add($insert_id_sql);

                        if ($dwtype[0]['dwtype'] == 5) {
                            if ($getdata["service"]['data']["unit"] == '1') {
                                $msg['evt'] = "WP2";
                                $msg['msg'] = "高水位";
                            } elseif ($getdata["service"]['data']["unit"] == '2') { // high
                                $msg['evt'] = "WP1";
                                $msg['msg'] = "低水位";
                            }
                        }else{
                            if ($getdata["service"]['data']["unit"] == '1') {
                                $msg['evt'] = "WP2";
                                $msg['msg'] = "高压";
                            } elseif ($getdata["service"]['data']["unit"] == '2') { // high
                                $msg['evt'] = "WP1";
                                $msg['msg'] = "低压";
                            }
                        }
                        if ( $msg['evt']=='WP1' || $msg['evt']=='WP2' ) {
                            $sql3="select s.owner_name,s.unitinfo,s.company,c.owner_address from sp_owner s ,sp_owner_company c where s.company=c.owner_id and s.owner_code ='{$device["device_id"]}'";
                            $company = add($sql3);
                            $sql4="select phone from sp_owner_phone  WHERE owner_code='".$company[0]['company']."' AND data2 like '%3%'  union select phone from sp_owner_phone  WHERE owner_code in (select other_code from sp_owner_fujin where owner_code='".$company[0]['company']."') AND data2 like '%3%'";
                            $union_sql=add($sql4);
                            Log::record('sql12345'.':'.$sql4);
                            $openids=$this->array_column1($union_sql,"phone");
                            if (empty($openids))
                            {
                                echo 'open is null';
                                exit;
                            }
                            Log::record('data666_phone'.':'.$openids);
                            $sql5="SELECT openid FROM sp_wx_customuser WHERE type='wx' and idphone in($openids)";
                            $op=add($sql5);
                            $access_token=GetAccess_Token();
                            $address='警报地址：'.$company[0]['owner_address'].$company[0]['unitinfo'];
                            $deviceid=$device["device_id"];
                            $type=$msg['msg'];
                            $time=$data3['time'];
                            $remark='设备名称：'.$company[0]['owner_name'];
//
                            $url_wx_push2        = "https://iot.usky.cn/jdxf/wxapp2.php/Home/Waterwarn/message_water";
                            Log::record('data666_url_wx_push2'.':'. $url_wx_push2);
                            $data666['IMEI']=$device["device_id"];
                            Log::record('data666_IMET'.':'.$data666['IMEI']);
                            $data666['phone']=$openids;
                            Log::record('data666_phone'.':'.$data666['phone']);
                            $data666['evt']=$data3['data1'];
                            Log::record('data666_evt'.':'.$data666['evt']);
                            $data666['insert_id']=$insert_id66[0]['id'];
                            Log::record('data666_insert_id'.':'.$data666['insert_id']);
                            $data666['time']=$data3['time'];
//                            Log::record('data666'.':'.$data666);
                            $sql88="UPDATE sp_devices_status SET statustime ='".$data3['time']."' where deviceid='".$data666['IMEI']."'";
                            addDataInfo($sql88);
                            $this->curl($url_wx_push2,$data666);

//                            $url_wx_push2        = "http://www.jd-ioe.com/jdxf/wxapp2.php/Home/Waterwarn/bj";
                            foreach($op as $key => $o){
                                if (!empty($o['openid']))
                                {
//                                    $data88['openid']=$o['openid'];
//                                    $data88['address']=$address;
//                                    $data88['deviceid']=$deviceid;
//                                    $data88['type']=$type;
//                                    $data88['time']=$time;
//                                    $data88['remark']=$remark;
                                    //token，微信id，地址，设备号，类型，时间，设备名称（或者其他内容）
                                    //{{first.DATA}}$address
                                    //设备号：{{keyword1.DATA}}$deviceid
                                    //报警类型：{{keyword2.DATA}}$type
                                    //时间：{{keyword3.DATA}}$time
                                    //{{remark.DATA}}$remark
                                    $Message=$this->SendDeviceAlarm($access_token,$o['openid'],$address,$deviceid,$type,$time,$remark,$url='');
//                                    s_curl($url_wx_push2,$data88);
                                    $Message['openid']=$o['openid'];
                                    $arr[$key]=$Message;

                                }
                            }
                        }
                     }
                }

            }


            return json_encode($data, 320);
        }
 	}

    public function addtuobaodata(){
        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;
            }
            //  $list['data']=11;
            $list['response'] = "222";
            $list['notifyType'] = $getdata["notifyType"];
            $list['deviceId'] = $getdata["deviceId"];
            $list['addtime'] = date('Y-m-d H:i:s');
            $res = Db::name('noticedata')->insertGetId($list);//将推送的数据存入总表
            if (trim($getdata["notifyType"]) == "deviceDataChanged") {
                $device = Db::name('device')->where('iot_id', trim($getdata["deviceId"]))->find();
                Log::record('tuobaoceshi123' . ':' . $device["device_id"]);
                $datainfo = array();
                $datainfo['notifyType'] = $getdata["notifyType"];
                $datainfo['device_id'] = $device["device_id"];
                $datainfo['iot_id'] = $getdata["deviceId"];
                $datainfo['service'] = json_encode($getdata["service"]);
                $datainfo['addtime'] = date('Y-m-d H:i:s');

                $res1 = Db::table('dev_' . $device["device_id"])->insertGetId($datainfo);
                if ($device['deviceType']=='SaiTeSmoke') {
                    $data3 = array();
                    $data3['device_id'] = $device["device_id"];
                    $data3['RSRQ'] = $getdata["service"]['data']['RSRP'];
                    $data3['CSQ'] = $getdata["service"]['data']["CSQ"];
                    $data3['DeviceType'] = 1;
                    if ($getdata["service"]['data']["Alarm_Status"]!== 7) {
                        $data3['DeviceStatus'] = 1;
                    }else{
                        $data3['DeviceStatus'] = 7;
                    }
                    $data3['BatteryLevel'] = $getdata["service"]['data']["Battery_Level"];
                    $data3['SensorLevel'] = $getdata["service"]['data']["AlarmLevel"];
                    $data3['TData'] = $getdata["service"]['data']["TData"];
                    $data3['eventTime'] = $getdata["service"]["eventTime"];
                    $data3['storeTime'] = date('Y-m-d H:i:s');
                    $sql = "INSERT INTO sp_y{$data3['device_id']} VALUES ('','{$data3['device_id']}',
'{$data3['RSRQ']}', '{$data3['CSQ']}', '{$data3['DeviceType']}','{$data3['DeviceStatus']}','{$data3['BatteryLevel']}','{$data3['SensorLevel']}','{$data3['eventTime']}','{$data3['storeTime']}','{$data3['TData']}')";
                    $res3 = addDataInfo($sql);

                    if ($getdata["service"]['data']["Alarm_Status"]!== 7){
                        $arr_bit = array(
                            "","报警","静音","保留","低压","故障","数据异常","","设备收到单次静音指令","设备收到连续静音指令","拆卸报警","拆卸恢复","","","模拟报警"
                        );
                        $deviceStatus=$getdata["service"]['data']["Alarm_Status"];
                        $data3 = array();
                        $data3['device_code'] = $device["device_id"];
                        $data3['time'] = date('Y-m-d H:i:s');
                        $data3['status'] = 'y'.'0'.$deviceStatus;
                        $data3['address'] = '180.101.147.89';
                        $data3['compartment'] = '';
                        $data3['fireprocess'] = '';
                        $data3['flowendtime'] = '0000-00-00 00:00:00';
                        $data3['ncmd'] = 'y'.'01';
                        $data3['data1'] = 'y'.'01';
                        $data3['data2'] = $arr_bit["{$deviceStatus}"];
                        $data3['data3'] = '';
                        $data3['data4'] = '烟雾'.$arr_bit["{$deviceStatus}"];
                        $data3['data5'] = '';
                        $sql = "INSERT INTO sp_hj2017 VALUES ('','','{$data3['device_code']}','{$data3['time']}','{$data3['status']}','{$data3['address']}','{$data3['compartment']}',
'{$data3['fireprocess']}', '{$data3['flowendtime']}', '{$data3['ncmd']}','{$data3['data1']}','{$data3['data2']}','{$data3['data3']}','{$data3['data4']}','{$data3['data5']}','','',''
,'','','','','','')";

                        $res5 = addDataInfo($sql);
                        $insert_id_sql="select id from sp_hj2017 where device_code='".$data3['device_code']."' and time='".$data3['time']."'";
                        Log::record('sql6688668866'.':'.$insert_id_sql);
                        $insert_id66=add($insert_id_sql);
                        $arr_h=array(1,2,6,8,9,10,11,14);
                        if (in_array($getdata["service"]['data']["Alarm_Status"],$arr_h)){
                            $sql3="select s.owner_name,s.unitinfo,s.company,c.owner_address from sp_owner s ,sp_owner_company c where s.company=c.owner_id and s.owner_code ='{$device["device_id"]}'";
                            Log::record('sql3'.':'.$sql3);
                            $company = add($sql3);
                            Log::record('company'.':'.$company[0]['company']);
                            $sql4="select phone from sp_owner_phone  WHERE owner_code='".$company[0]['company']."' AND data2 like '%6%'  union select phone from sp_owner_phone  WHERE owner_code in (select other_code from sp_owner_fujin where owner_code='".$company[0]['company']."') AND data2 like '%6%'";
                            Log::record('sql4'.':'.$sql4);
                            $union_sql=add($sql4);
                            $openids=$this->array_column1($union_sql,"phone");
                            if (empty($openids))
                            {
                                echo 'open is null';
                                exit;
                            }
                            $sql5="SELECT openid FROM sp_wx_customuser WHERE type='wx' and idphone in($openids)";
                            $op=add($sql5);
                            $access_token=GetAccess_Token();
                            $address='警报地址：'.$company[0]['owner_address'].$company[0]['unitinfo'];
                            $deviceid=$device["device_id"];
                            $type='烟雾';
                            $time=$data3['time'];
                            $remark='设备名称：'.$company[0]['owner_name'];
                            if($getdata["service"]['data']["Alarm_Status"]==5){
                                $deviceStatus1='y05';
                            }elseif ($getdata["service"]['data']["Alarm_Status"]==1){
                                $deviceStatus1='y01';
                            }elseif ($getdata["service"]['data']["Alarm_Status"]==10){
                                $deviceStatus1='y10';
                            }elseif ($getdata["service"]['data']["Alarm_Status"]==14){
                                $deviceStatus1='y12';
                            }
                            $url_wx_push2        = "https://iot.usky.cn/jdxf/wxapp2.php/Home/Waterwarn/bj";
                            Log::record('data666_url_wx_push2'.':'.$url_wx_push2);
                            $data666['phone']=$openids;
                            Log::record('data666_phone'.':'.$data666['phone']);
                            $data666['IMEI']=$device["device_id"];
                            Log::record('data666_IMEI'.':'.$data666['IMEI']);
                            $data666['time']=$data3['time'];
                            Log::record('data666_time'.':'.$data666['time']);
                            $data666['evt']=$deviceStatus1;
                            Log::record('data666_evt'.':'.$data666['evt']);
                            $data666['insert_id']=$insert_id66[0]['id'];
                            Log::record('data666_insert_id'.':'.$data666['insert_id']);
                            $this->curl($url_wx_push2,$data666);

                            foreach($op as $key => $o){
                                if (!empty($o['openid']))
                                {
                                    $Message=$this->SendDeviceAlarm($access_token,$o['openid'],$address,$deviceid,$type,$time,$remark,$url='');
//                                s_curl($url_wx_push2,$data88);
                                    $Message['openid']=$o['openid'];
                                    $arr[$key]=$Message;

                                }
                            }
                        }
                    }
                }
            }
        }
    }

    public function jingan(){
        if ($this->request->isPost()) {
            Log::record('jinganxiaofang' . ':ceshi');
            $data = input('');

            /*            $rand=rand(0,2);
                   $header=["Content-Type:application/json"];

                   //将数据分配给不同的服务
                   $httpserver=["http://47.98.153.212:1101","http://47.98.153.212:1102","http://47.98.153.212:1103"];
                   $server=$httpserver[$rand];

                   //将数据随机转发到别的平台做处理
                    $res=curltest($server,$data,$header);
             */
            $list = array();
            if (is_array($data)) {
                $list['data'] = json_encode($data, 320);
                $getdata = json_decode($list['data'], true);//转成数组
            } else {
                $list['data'] = $data;
                $getdata = json_decode($list['data'], true);//转成数组

            }
            //  $list['data']=11;
//            $list['response'] = "111";
//
//            $list['notifyType'] = $getdata["notifyType"];
//            $list['deviceId'] = $getdata["deviceId"];
//            $list['addtime'] = date('Y-m-d H:i:s');
            $res = Db::name('jingandata')->insertGetId($list);//将推送的数据存入总表
            Log::record('jinganxiaofang' . ':' . $res);
            $Data = array();
            $Data['app_key'] = $getdata["app_key"];
            $Data['timestamp'] = date('Y-m-d H:i:s',$getdata["timestamp"]);
            $Data['format'] = $getdata["format"];
            $Data['v'] = $getdata["v"];
            $Data['sign_method'] = $getdata["sign_method"];
            $Data['pid'] = $getdata["pid"];
            $Data['bid'] = $getdata["bid"];
            $Data['fid'] = $getdata["fid"];
            $Data['supervise_id'] = $getdata["supervise_id"];
            if (empty($getdata["supervise_code"])){
                $Data['supervise_code']="";
            }else{
                $Data['supervise_code'] = $getdata["supervise_code"];
            }
            $Data['status'] = $getdata["status"];
            $Data['content'] = $getdata["content"];
            $Data['type'] = $getdata["type"];
            if (empty($getdata["device_id"])){
                $Data['device_id']="";
            }else{
                $Data['device_id'] = $getdata["device_id"];
            }
            if (empty($getdata["aid"])){
                $Data['aid']="";
            }else{
                $Data['aid'] = $getdata["aid"];
            }
            if (empty($getdata["loop_number"])){
                $Data['loop_number']="";
            }else{
                $Data['loop_number'] = $getdata["loop_number"];
            }
            if (empty($getdata["position_number"])){
                $Data['position_number']="";
            }else{
                $Data['position_number'] = $getdata["position_number"];
            }
            if (empty($getdata["mainframe_id"])){
                $Data['mainframe_id']="";
            }else{
                $Data['mainframe_id'] = $getdata["mainframe_id"];
            }
            $Data['sign'] = $getdata["sign"];
            if ($Data['app_key']=="f8bdea7926bcc7cb827d2eccf67fa559"){
                $sql3="select device_name,company_code from sp_huangpu_share where pid='{$getdata["pid"]}' GROUP BY company_code";
            }else if ($Data['app_key']=="9e555b8b2244ebc1f59695824b86c5a0"){
                $sql3="select device_name,company_code from sp_jingan_share where pid='{$getdata["pid"]}' and bid='{$getdata["bid"]}' and fid='{$getdata["fid"]}' GROUP BY company_code";
            }
            $company = add($sql3);
            $Data['company_code'] = $company[0]['company_code'];
            $res1 = Db::name('jinganAnalysisData')->insertGetId($Data);
            $url_wx_data = "https://iot.usky.cn/jdxf/wxapp2.php/Home/WorkOrderNotice/message_workordernotice";
            $data_wx['company_code'] = $company[0]['company_code'];
            $data_wx['time']=$Data['timestamp'];
            $data_wx['title']=$Data['content'];
            $data_wx['id']=$res1;
            $data_wx['types']=2;
            if($getdata["status"]==0){
                $this->s_curl($url_wx_data,$data_wx);
            }
            return "success";
        }
    }

    public function jinganPerson(){
        if ($this->request->isPost()) {
            Log::record('jinganxiaofangren' . ':ceshi');
            $data = input('');

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

            }
            //  $list['data']=11;
//            $list['response'] = "111";

            $res = Db::name('jinganperson')->insertGetId($list);//将推送的数据存入总表
            Log::record('jinganxiaofangren' . ':' . $res);
            $data_list['app_key'] = $getdata["app_key"];
            $data_list['timestamp'] = date('Y-m-d H:i:s',$getdata["timestamp"]);
            $data_list['format'] = $getdata["format"];
            $data_list['version'] = $getdata["v"];
            $data_list['sign_method'] = $getdata["sign_method"];
            $data_list['artificial_id'] = $getdata["artificial_id"];
            $data_list['pid'] = $getdata["pid"];
            $data_list['artificial_code'] = $getdata["artificial_code"];
            $data_list['company_id'] = $getdata["company_id"];
            $data_list['content'] = $getdata["content"];
            $data_list['status'] = $getdata["status"];
            $data_list['sign'] = $getdata["sign"];
            $device = Db::name('person_data')->where('artificial_id', trim( $data_list['artificial_id']))->find();
            if($device){
                return "success";
            }else{
                if ($data_list['app_key']=="f8bdea7926bcc7cb827d2eccf67fa559"){
                    $sql3="select device_name,company_code from sp_huangpu_share where pid='{$getdata["pid"]}' GROUP BY company_code";
                }else if ($data_list['app_key']=="9e555b8b2244ebc1f59695824b86c5a0"){
                    $sql3="select device_name,company_code from sp_jingan_share where pid='{$getdata["pid"]}' GROUP BY company_code";
                }
                $company = add($sql3);
                $data_list['company_code'] = $company[0]['company_code'];
                $res1 = Db::name('person_data')->insertGetId($data_list);//将推送的数据存入解析表
                Log::record('person_data_list'.':'.$getdata["content"]);
                $url_wx_data = "https://iot.usky.cn/jdxf/wxapp2.php/Home/WorkOrderNotice/message_workordernotice";
                $data_wx['company_code']=$company[0]['company_code'];
                $data_wx['time']=$data_list['timestamp'];
                $data_wx['title']=$data_list['content'];
                $data_wx['id']=$res1;
                $data_wx['types']=1;
                $this->s_curl($url_wx_data,$data_wx);
                return "success";
            }

        }
    }

    public function aepceshi(){
        if ($this->request->isPost()) {
            Log::record('aep' . ':ceshi');
            $data = input('');

            /*            $rand=rand(0,2);
                   $header=["Content-Type:application/json"];

                   //将数据分配给不同的服务
                   $httpserver=["http://47.98.153.212:1101","http://47.98.153.212:1102","http://47.98.153.212:1103"];
                   $server=$httpserver[$rand];

                   //将数据随机转发到别的平台做处理
                    $res=curltest($server,$data,$header);
             */
            $list = array();
            if (is_array($data)) {
                $list['data'] = json_encode($data, 320);
                $getdata = json_decode($list['data'], true);//转成数组
            } else {
                $list['data'] = $data;
                $getdata = json_decode($list['data'], true);//转成数组

            }
            //  $list['data']=11;
//            $list['response'] = "111";
//
//            $list['notifyType'] = $getdata["notifyType"];
//            $list['deviceId'] = $getdata["deviceId"];
//            $list['addtime'] = date('Y-m-d H:i:s');
            $res = Db::name('nb_aep')->insertGetId($list);//将推送的数据存入总表
            Log::record('aep' . ':' . $res);
            return json_encode($data, 320);
        }
    }

    public function longHuConfigure(){
        if ($this->request->isPost()) {
            $data = input('');
            $list = array();
            $set_data = array();
            if (is_array($data)) {
                $list['data'] = json_encode($data, 320);
                $getdata = json_decode($list['data'], true);//转成数组
            } else {
                $list['data'] = $data;
                $getdata = json_decode($list['data'], true);//转成数组

            }
            if ($getdata["dataType"]=="setting"){
                $sql="SELECT owner_code FROM sp_owner WHERE id ={$getdata["sensorId"]}";
                $owner_code = add($sql);
                $imei='&imei='.$owner_code[0]['owner_code'];
                if ($getdata["deviceType"]=="XiaoFangShuiYa"){
                    $deviceType='&deviceType='.'1';
                }elseif ($getdata["deviceType"]=="YeWei"){
                    $deviceType='&deviceType='.'2';
                }
                $sendingGap = '';
                if (!empty($getdata["sendTime"])){
                    $sendingGap = '&sendingGap='.$getdata["sendTime"];
                }
                $unipathThresholdLimit = '';
                if (!empty($getdata["lowThreshold"])){
                    $unipathThresholdLimit = '&unipathThresholdLimit='.$getdata["lowThreshold"]*1000;
                }
                $unipathThresholdUpper = '';
                if (!empty($getdata["highThreshold"])){
                    $unipathThresholdUpper = '&unipathThresholdUpper='.$getdata["highThreshold"]*1000;
                }
                $data6 = json_encode($set_data);
                $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('longhu' . ':' . $rep_url);
                return $res;
            }else{
                $res_arr = array();
                $res_arr['code'] = 60001;
                $res_arr['msg'] = "dataType参数有误";
                $res_arr['data'] = "";
                $res = json_encode($res_arr);
                Log::record('longhuerror' . ':' . $res);
                return $res;
            }
        }
    }

    public function longhudata(){
        if ($this->request->isPost()) {
            $data = input('');
            $list = array();
            $set_data = array();
            if (is_array($data)) {
                $list['data'] = json_encode($data, 320);
                $getdata = json_decode($list['data'], true);//转成数组
            } else {
                $list['data'] = $data;
                $getdata = json_decode($list['data'], true);//转成数组

            }
            if ($getdata["user_from"]=="longHuWater"){
                $sql6="select * from sp_owner where owner_code ='{$getdata["device_code"]}'";
                $longHuCompany = add($sql6);
                $sensorList['sensorId'] = (int)$longHuCompany[0]['id'];
                $sensorList['status'] = 0;
                $sensorList['desc'] = $longHuCompany[0]['unitinfo'].'-'.$longHuCompany[0]['owner_name'].'-压力正常';
                $data4['deviceType'] = 'XiaoFangShuiYa';
                $sensorList['unit'] = 'MPa';
                $data4['dataType'] = 'deviceInfo';
                $data4['provider'] = 'Usky';
                $data4['softVersion'] = '1.00.00';
                $data4['hardVersion'] = '0.1';
                $sensorList['pointValue'] = (double)$getdata['device_value'];
                $deviceConfigure = Db::name('deviceConfigure')->where('device_code', trim($getdata["device_code"]))->find();
                if (!empty($deviceConfigure)) {
                    $sensorList['lowThreshold'] = (double)$deviceConfigure['low_threshold'];
                    $sensorList['highThreshold'] = (double)$deviceConfigure['high_threshold'];
                    $sensorList['sendTime'] = (int)$deviceConfigure['send_time'];
                } else {
                    $sensorList['lowThreshold'] = 0;
                    $sensorList['highThreshold'] = 0;
                    $sensorList['sendTime'] = 1800;
                }
                $sensorListArray[0] = $sensorList;
                $data4['sensorList'] = $sensorListArray;
                if ($longHuCompany[0]['company']=='10232'){
                    $data5['mqttId'] = 'a71c40bb-5b02-4741-881b-24449f699db5';
                }else{
                    $data5['mqttId'] = 'a71c40bb-5b02-4741-881b-24449f699db6';
                }
                $data5['action'] = 'transpush';
                $data5['data'] = $data4;
                $data6 = json_encode($data5);
                $rep_url = "http://47.98.201.73:55126/report";
                $res = $this->curl($rep_url, $data6);
                Log::record('minhanglonghuduijie' . ':' . $res);
                $res_arr = array();
                $res_arr['code'] = 200;
                $res_arr['msg'] = "操作成功";
                $res_arr['data'] = "";
                $res1 = json_encode($res_arr);
                return $res1;
            }else if ($getdata["user_from"]=="longHuWaterAlarm"){
                $sql6="select * from sp_owner where owner_code ='{$getdata["device_code"]}'";
                $longHuCompany = add($sql6);
                $sensorList['sensorId'] = (int)$longHuCompany[0]['id'];
                $sql7="select * from sp_sj2017 where id ={$getdata['device_value']}";
                $longHuAlarm = add($sql7);
                if ($longHuAlarm[0]['data1']=='WP1'){
                    $sensorList['status'] = 3;
                    $sensorList['desc'] = $longHuCompany[0]['unitinfo'].'-'.$longHuCompany[0]['owner_name'].'-压力低于下限';
                }elseif ($longHuAlarm[0]['data1']=='WP2'){
                    $sensorList['status'] = 4;
                    $sensorList['desc'] = $longHuCompany[0]['unitinfo'].'-'.$longHuCompany[0]['owner_name'].'-压力超过上限';
                }elseif ($longHuAlarm[0]['data1']=='WP3'){
                    $sensorList['status'] = 1;
                    $sensorList['desc'] = $longHuCompany[0]['unitinfo'].'-'.$longHuCompany[0]['owner_name'].'-设备故障';
                }
                $data4['deviceType'] = 'XiaoFangShuiYa';
                $sensorList['unit'] = 'MPa';
                $data4['dataType'] = 'deviceInfo';
                $data4['softVersion'] = '1.00.00';
                $data4['hardVersion'] = '0.1';
                $sensorList['pointValue'] = (double)$longHuAlarm[0]['data4'];
                $deviceConfigure = Db::name('deviceConfigure')->where('device_code', trim($getdata["device_code"]))->find();
                if (!empty($deviceConfigure)) {
                    $sensorList['lowThreshold'] = (double)$deviceConfigure['low_threshold'];
                    $sensorList['highThreshold'] = (double)$deviceConfigure['high_threshold'];
                    $sensorList['sendTime'] = (int)$deviceConfigure['send_time'];
                } else {
                    $sensorList['lowThreshold'] = 0;
                    $sensorList['highThreshold'] = 0;
                    $sensorList['sendTime'] = 1800;
                }
                $sensorListArray[0] = $sensorList;
                $data4['sensorList'] = $sensorListArray;
                $data5['mqttId'] = 'a71c40bb-5b02-4741-881b-24449f699db5';
                $data5['action'] = 'transpush';
                $data5['data'] = $data4;
                $data6 = json_encode($data5);
                $rep_url = "http://47.98.201.73:55126/report";
                $res = $this->curl($rep_url, $data6);
                Log::record('minhanglonghuduijie' . ':' . $res);
                $res_arr = array();
                $res_arr['code'] = 200;
                $res_arr['msg'] = "操作成功";
                $res_arr['data'] = "";
                $res1 = json_encode($res_arr);
                return $res1;
            }else if ($getdata["user_from"]=="xingYueHuiRtuWater"){
                Log::record('xingyuehui' . ':' . $getdata["device_code"]);
                $sql6="select * from sp_owner where owner_code ='{$getdata["device_code"]}'";
                $longHuCompany = add($sql6);
                if($getdata["device_type"]=="water"){
                    $sensorList['sensorId'] = (int)$longHuCompany[0]['id'];
                }else{
                    $sensorList['sensorId'] = (int)$longHuCompany[0]['id'].(int)$getdata["port"];
                }
                $sensorList['status'] = 0;
                $sensorList['desc'] = $longHuCompany[0]['unitinfo'].'-'.$getdata["port_name"].'-压力正常';
                $data4['deviceType'] = 'XiaoFangShuiYa';
                $sensorList['unit'] = 'MPa';
                $data4['dataType'] = 'deviceInfo';
                $data4['provider'] = 'Usky';
                $data4['softVersion'] = '1.00.00';
                $data4['hardVersion'] = '0.1';
                $sensorList['pointValue'] = (double)$getdata['device_value'];
                $deviceConfigure = Db::name('deviceConfigure')->where('device_code', trim($getdata["device_code"]))->find();
                if (!empty($deviceConfigure)) {
                    $sensorList['lowThreshold'] = (double)$deviceConfigure['low_threshold'];
                    $sensorList['highThreshold'] = (double)$deviceConfigure['high_threshold'];
                    $sensorList['sendTime'] = (int)$deviceConfigure['send_time'];
                } else {
                    $sensorList['lowThreshold'] = 0;
                    $sensorList['highThreshold'] = 0;
                    $sensorList['sendTime'] = 1800;
                }
                $sensorListArray[0] = $sensorList;
                $data4['sensorList'] = $sensorListArray;
                if ($longHuCompany[0]['company']=='10232'){
                    $data5['mqttId'] = 'a71c40bb-5b02-4741-881b-24449f699db5';
                }else{
                    $data5['mqttId'] = 'a71c40bb-5b02-4741-881b-24449f699db6';
                }
                $data5['action'] = 'transpush';
                $data5['data'] = $data4;
                $data6 = json_encode($data5);
                $rep_url = "http://47.98.201.73:55126/report";
                $res = $this->curl($rep_url, $data6);
                Log::record('minhanglonghuduijie' . ':' . $res);
                $res_arr = array();
                $res_arr['code'] = 200;
                $res_arr['msg'] = "操作成功";
                $res_arr['data'] = "";
                $res1 = json_encode($res_arr);
                return $res1;
            }else{
                $res_arr = array();
                $res_arr['code'] = 60001;
                $res_arr['msg'] = "user_from参数有误";
                $res_arr['data'] = "";
                $res = json_encode($res_arr);
                Log::record('longhuerror' . ':' . $res);
                return $res;
            }
        }
    }

    public function testdata1(){

            $rand=rand(0,2);
            $data=[
                '{"notifyType":"deviceDataChanged","deviceId":"a1d88da9-5156-4507-995a-bb20af09001a","gatewayId":"a1d88da9-5156-4507-995a-bb20af09001a","requestId":null,"service":{"serviceId":"hxkcnbdtu","serviceType":"hxkcnbdtu","data":{"deviceAddress":"868744030057305","framenumber":0,"framenum":0,"frameser":0,"voltage":3.6,"rsrp":-99.9,"snr":67,"ecl":0,"csq":11,"cellid":"0125145939","reportway":0,"cycle":1600,"setmode":3,"settime":"3-00","freezday":"28-02","nbtime":"18-09-21 10:30:15","pressure":0.7455,"alarm_en":0,"alarm_time":60,"down_alarm_pre":0,"up_alarm_pre":0,"pre_status":0,"log":"7E64E7834300000011395914250100064003030028021809211030151811112222011F1D0000003C00000000000000000000000000","eventTime":"2018-09-21 10:30:17"},"eventTime":"20180921T023017Z"}}',

               '{"notifyType":"deviceDataChanged","deviceId":"a1d88da9-5156-4507-995a-bb20af09001a","gatewayId":"a1d88da9-5156-4507-995a-bb20af09001a","requestId":null,"service":{"serviceId":"hxkcnbdtu","serviceType":"hxkcnbdtu","data":{"deviceAddress":"868744030057305","framenumber":0,"framenum":0,"frameser":0,"voltage":3.6,"rsrp":-99.9,"snr":67,"ecl":0,"csq":11,"cellid":"0125145939","reportway":0,"cycle":1600,"setmode":3,"settime":"3-00","freezday":"28-02","nbtime":"18-09-21 10:30:15","pressure":0.7455,"alarm_en":0,"alarm_time":60,"down_alarm_pre":0,"up_alarm_pre":0,"pre_status":0,"log":"7E64E7834300000011395914250100064003030028021809211030151811112222011F1D0000003C00000000000000000000000000","eventTime":"2018-09-21 10:30:17"},"eventTime":"20180921T023017Z"}}',

               '{"notifyType":"deviceDataChanged","deviceId":"a1d88da9-5156-4507-995a-bb20af09001a","gatewayId":"a1d88da9-5156-4507-995a-bb20af09001a","requestId":null,"service":{"serviceId":"hxkcnbdtu","serviceType":"hxkcnbdtu","data":{"deviceAddress":"868744030057305","framenumber":0,"framenum":0,"frameser":0,"voltage":3.6,"rsrp":-99.9,"snr":67,"ecl":0,"csq":11,"cellid":"0125145939","reportway":0,"cycle":1600,"setmode":3,"settime":"3-00","freezday":"28-02","nbtime":"18-09-21 10:30:15","pressure":0.7455,"alarm_en":0,"alarm_time":60,"down_alarm_pre":0,"up_alarm_pre":0,"pre_status":0,"log":"7E64E7834300000011395914250100064003030028021809211030151811112222011F1D0000003C00000000000000000000000000","eventTime":"2018-09-21 10:30:17"},"eventTime":"20180921T023017Z"}}',

            ];


            $header=["Content-Type:application/json"];

            //将数据分配给不同的服务
            $httpserver=["http://47.98.153.212:1101","http://47.98.153.212:1102","http://47.98.153.212:1103"];

            $senddata=$data[$rand];
            $server=$httpserver[$rand];


            $res=curltest($server,$senddata,$header);
            dump($res);

           /* //设备所属公司
             $owner=Db::name('device')->field("owner_id")->where('iot_id',$iot_id)->find();
            $ownerhost=Db::name('owner')->where('id',$owner["owner_id"])->find();
            $ipaddr=$ownerhost['host'].":".$ownerhost['port'];
             $res=curltest($ipaddr,$senddata);

            dump($res);*/

            //将数据转发到不同的接口中
          /* $sendapi="senddata".$rand;
           echo $this->$sendapi($data[$rand],$devies[$rand]);*/

    }

    public function tuoBaoUrl(){
        if ($this->request->isPost()) {
            $data = input('');
            $list = array();
            if (is_array($data)) {
                $list['data'] = json_encode($data, 320);
                $getdata = json_decode($list['data'], true);//转成数组
            } else {
                $list['data'] = $data;
                $getdata = json_decode($list['data'], true);//转成数组

            }
            $res = Db::name('tuobao_data')->insertGetId($list);//将推送的数据存入总表
            Log::record('tuoBaoLora' . ':' . $res);
            $tuoBaoData['deviceId'] = $getdata['deviceId'];
            if(!empty($getdata['parseMsg'])){
                Log::record('tuoBaoLoraParseMsg' . ':' . $getdata['parseMsg'][0]['method']);
            }
            $tuoBaoData['deviceId'] = $getdata['deviceId'];
            return json_encode($data, 320);
        }else{
            $msg = input('msg');
            return $msg;
        }
    }

 	public function senddata0($data){

            //将数据存到总表
            //将数据存到设备详细表
            //查看当前设备属于哪家业主


            //查找业主的服务器
            //给服务器发数据




 	}

    public function senddata1($data){
          echo "m2".$data;
    }

    public function senddata2($data){
          echo "m3".$data;
    }
    public function array_column1($rows, $column_key, $index_key = null) {
        $data = array();
        if (empty($index_key)) {
            foreach ($rows as $row) {
                $data[] = $row[$column_key];
            }
            $data=implode(",",$data);
        } else {
            foreach ($rows as $row) {
                $data[$row[$index_key]] = $row[$column_key];
            }
        }
        return $data;
    }
    public function SendDeviceAlarm($access_token,$openid,$address,$deviceid,$type,$time,$remark,$url){
        $data = array(
            "touser"=> $openid,
            "template_id"=>"JkQYUiScfIuH9O4vvUgtgYxPIOBOY7Zh9w2DcWTgm50",
            //"url" =>"http://zt-iot.com/ztxf/weixin.php/Home/Fire/water",
            "data"=> array(
                "first"=> array(
                    "value"=> $address,
                    "color"=>"#44b549"
                ),
                "keyword1"=>array(
                    "value"=> $deviceid,
                    "color"=>"#173177"
                ),
                "keyword2"=> array(
                    "value"=> $type,
                    "color"=>"#173177"
                ),
                "keyword3"=> array(
                    "value"=> $time,
                    "color"=>"#173177"
                ),
                "remark"=>array(
                    "value"=> $remark,
                    "color"=>"#aaaaaa"
                )
            )
        );
        //{{first.DATA}}
        //设备号：{{keyword1.DATA}}
        //报警类型：{{keyword2.DATA}}
        //时间：{{keyword3.DATA}}
        //{{remark.DATA}}
        $data = json_encode($data);
        $QUEST_URL = "https://api.weixin.qq.com/cgi-bin/message/template/send?access_token=".$access_token;
        $res = $this->curl($QUEST_URL,$data);
        return json_decode($res,true);
    }
    public function curl($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 s_curl($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 get_curl($url, $data = '')
    {
        $ch = curl_init();
        curl_setopt($ch, CURLOPT_URL, $url);
        curl_setopt($ch, CURLOPT_CUSTOMREQUEST, "GET");
        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 message_push_mh($topic,$msg,$qos){
        vendor('phpMQTT.phpMQTT');
        $server = '47.98.201.73';     // 服务器IP
        $port = 1883;            // 服务器端口
        $username = 'usky';              // 用户名
        $password = 'usky';              // 密码
        $client_id = 'pub_' . uniqid();
        $mqtt = new \phpMQTT($server, $port, $client_id);
        if ($mqtt->connect(true, NULL, $username, $password)) {
            $mqtt->publish($topic, $msg, $qos);
            usleep(100000);
            $mqtt->close();
            Log::record('MH—NB-MQTT-Push success!('.$topic.')['.date('Y-m-d H:i:s').']:'.json_encode($msg));
        } else {
            Log::record('MH—NB-MQTT-Time out!('.$topic.')['.date('Y-m-d H:i:s').']:'.json_encode($msg));
        }
    }

    public function mqqt_data_recombination($type, $device_code, $device_name, $electric_quantity, $signal, $water_gage,$dwtype)
    {
        if ($type == 'INFO') {
            $status_valie = "0";
        } else {
            $status_valie = "1";
        }

        if ($dwtype==2){
            $property = "水压";
        }else{
            $property = "水位";
        }

        $array = [
            "devId" => $device_code,
            "connType" => "G",
            "deviceName" => $device_name,
            "devs" => [
                [
                    "dp" => [
                        [
                            "property" => "电量",
                            "serial" => "201",
                            "value" => '' . $electric_quantity
                        ],
                        [
                            "property" => "信号",
                            "serial" => "202",
                            "value" => '' . $signal
                        ],
                        [
                            "property" => $property,
                            "serial" => "203",
                            "value" => '' . $water_gage
                        ],
                        [
                            "property" => "状态",
                            "serial" => "204",
                            "value" => $status_valie
                        ]
                    ],
                    "deviceName" => $device_name,
                    "timeStamp" => "".time(),
                    "deviceModel" => "",
                    "deviceType" => "".$dwtype,
                    "devId" => $device_code
                ]
            ],
            "type" => $type,
            "timeStamp" => "".time()
        ];

        $json_data = json_encode($array);
        return $json_data;
    }

}