ytapi/admin/controller/Order.php.yuanshi

<?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 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);
                    $arr_y=array('10','11','20','21','22');
                    if (in_array($unit,$arr_y)){
                        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;
                    }
                    $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'] =$getdata["service"]['data']['data'];
                    $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';
                    }
                    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);
                        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;
                            }
                            $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'];
                            foreach($op as $key => $o){
                                if (!empty($o['openid']))
                                {
                                    //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='');
                                    $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);
                    }
                    $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        = "http://www.jd-ioe.com/jdxf/wxapp2.php/Home/Waterwarn/bj";
                        foreach($op as $key => $o){
                            if (!empty($o['openid']))
                            {
                                //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='');
                                $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'] = '';
                        $arr_y=array('10','11','20','21','22');
                        if (in_array($unit,$arr_y)){
                            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;
                        }
                        $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);
                    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;
                            }
                            $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        = "http://www.jd-ioe.com/jdxf/wxapp2.php/Home/Waterwarn/bj";
                            foreach($op as $key => $o){
                                if (!empty($o['openid']))
                                {
                                    //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='');
                                    $Message['openid']=$o['openid'];
                                    $arr[$key]=$Message;

                                }
                            }
                        }
                }
                }

            }


            return json_encode($data, 320);
        }
 	}

    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 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)) {return 'Errno'.curl_error($ch);}else{ return $info;}
        curl_close($ch);
    }
    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;
    }

}