<?php

namespace app\api\controller\reservoir;
use app\common\controller\Api;
use think\Request;
use think\Db;
use qx\Qx;
use addons\alisms\controller\Index;
/**
 * Class Equipment
 * @package app\api\controller\reservoir
 */


class Equipment extends Api{
    protected $model = '';
    protected $noNeedLogin = ['getRainEquipment','abnormal','day30','getQxList','equipmentType','getData','getDisplacement','getAllData','getIsotonic','getRainfall','getWaterLevel','getReservoirId','getSeepage'];
    protected $noNeedRight = '*';
    public function _initialize()
    {
        parent::_initialize(); // TODO: Change the autogenerated stub
        $this->model = new \app\admin\model\reservoir\Equipment;
    }
    
    public function getrianequipmentlist($ids=null)
    {
        $map = [];
        $map['reservoir_id'] = ['=',$ids];
        $type = $this->request->param('type',1);
        if (in_array($type,['1','2','3','4','5','6','7'])) {
            $map['type'] = ['=',$type];
        }
        $list = $this->model
            ->field('id,deviceId,name,status,from_unixtime(createtime,"%Y-%m-%d") as ctrs')
            ->where($map)
            ->select();
        $this->success('',$list);
    }
    
    public function day30()
    {
        $list = Db::name('reservoir_list')->field('id,name')->select();
        foreach ($list as $key=>$item){
            for($i=30;$i>=1;$i--){
                $k = $i-1;
                ${'predaystart'.$i} = strtotime(date('Y-m-d',strtotime("-$i day")));
                ${'predayend'.$i} = strtotime(date('Y-m-d',strtotime("-$k day")));
                
                ${'predaycount'.$i} = array_sum([
                    Db::name('reservoir_hkws_warning')->where('createtime','>=',${'predaystart'.$i})->where('createtime','<',${'predayend'.$i})->where('reservoir_id',$item['id'])->count(),
                    Db::name('reservoir_warning_crack')->where('createtime','>=',${'predaystart'.$i})->where('createtime','<',${'predayend'.$i})->where('reservoir_id',$item['id'])->count(),
                    Db::name('reservoir_warning_displacement')->where('createtime','>=',${'predaystart'.$i})->where('createtime','<',${'predayend'.$i})->where('reservoir_id',$item['id'])->count(),
                    Db::name('reservoir_warning_invade')->where('createtime','>=',${'predaystart'.$i})->where('createtime','<',${'predayend'.$i})->where('reservoir_id',$item['id'])->count(),
                    Db::name('reservoir_warning_rainfall')->where('createtime','>=',${'predaystart'.$i})->where('createtime','<',${'predayend'.$i})->where('reservoir_id',$item['id'])->count(),
                    Db::name('reservoir_warning_settlement')->where('createtime','>=',${'predaystart'.$i})->where('createtime','<',${'predayend'.$i})->where('reservoir_id',$item['id'])->count(),
                    Db::name('reservoir_warning_waterlevel')->where('createtime','>=',${'predaystart'.$i})->where('createtime','<',${'predayend'.$i})->where('reservoir_id',$item['id'])->count(),
                    Db::name('reservoir_warning_waterseepage')->where('createtime','>=',${'predaystart'.$i})->where('createtime','<',${'predayend'.$i})->where('reservoir_id',$item['id'])->count(),
                    Db::name('reservoir_warning_weather')->where('createtime','>=',${'predaystart'.$i})->where('createtime','<',${'predayend'.$i})->where('reservoir_id',$item['id'])->count()
                ]);
                
                $res[$item['id']]['date'][] = date('Y-m-d',strtotime("-$i day"));
                $res[$item['id']]['count'][] = ${'predaycount'.$i};
                $res[$item['id']]['name']=$item['name'];
            }
            $today = strtotime(date("Y-m-d",time()));
            $todaylist = array_sum([
                    Db::name('reservoir_hkws_warning')->where('createtime','>=',$today)->where('reservoir_id',$item['id'])->count(),
                    Db::name('reservoir_warning_crack')->where('createtime','>=',$today)->where('reservoir_id',$item['id'])->count(),
                    Db::name('reservoir_warning_displacement')->where('createtime','>=',$today)->where('reservoir_id',$item['id'])->count(),
                    Db::name('reservoir_warning_invade')->where('createtime','>=',$today)->where('reservoir_id',$item['id'])->count(),
                    Db::name('reservoir_warning_rainfall')->where('createtime','>=',$today)->where('reservoir_id',$item['id'])->count(),
                    Db::name('reservoir_warning_settlement')->where('createtime','>=',$today)->where('reservoir_id',$item['id'])->count(),
                    Db::name('reservoir_warning_waterlevel')->where('createtime','>=',$today)->where('reservoir_id',$item['id'])->count(),
                    Db::name('reservoir_warning_waterseepage')->where('createtime','>=',$today)->where('reservoir_id',$item['id'])->count(),
                    Db::name('reservoir_warning_weather')->where('createtime','>=',$today)->where('reservoir_id',$item['id'])->count()
                ]);
            $res[$item['id']]['date'][] = date("Y-m-d",time());
            $res[$item['id']]['count'][] = $todaylist;
           
        }
        //dump($res);
        foreach($res as $key=>$item){
            foreach($item['date'] as $key1=>$item1){
                $arr[] = [$item['count'][$key1],1,1,$item['name'],1920 ]; 
            }
        }
        $this->success('',$arr);   
    }
    // 异常
    public function abnormal()
    {
        $crack = Db::name('reservoir_dam_crack')->order('id desc')->value('warning');
        $displacement = Db::name('reservoir_dam_displacement')->order('id desc')->value('warning');
        $settlement = Db::name('reservoir_dam_settlement')->order('id desc')->value('warning');
        $th = Db::name('reservoir_dam_th')->order('id desc')->value('warning');
        $waterseepage = Db::name('reservoir_dam_waterseepage')->order('id desc')->value('warning');
        $count = 0;
        $data = [$crack,$displacement,$settlement,$th,$waterseepage];
        foreach ($data as $key=>$item){
            $item=='0' ? $count++ :'';
        }
        $error = count($data) - $count;
        $bili = ($count / count($data))*100;
        $this->success('',['zc'=>$count,'yc'=>$error,'bilv'=>$bili]);
    }
    //县市雨量计水位计统计
    public function getRainEquipment($id){
        $reservoirids = Db::name('reservoir_list')->where('county_id',$id)->field('id')->select();
        $ids = [];
        foreach ($reservoirids as $k => $v){
            $ids[] = $v['id'];
        }
        $res['equipment']['rain'] = Db::name('reservoir_equipment')->where('type','5')->where('reservoir_id','in',$ids)->count();//雨量计
        $res['equipment']['water'] = Db::name('reservoir_equipment')->where('type','1')->where('reservoir_id','in',$ids)->count();//水位计
        $res['warning']['rain'] = Db::name('reservoir_warning_rainfall')->where('deal',1)->where('reservoir_id','in',$ids)->count();//雨量不正常
        $res['warning']['water'] = Db::name('reservoir_warning_waterlevel')->where('deal',1)->where('reservoir_id','in',$ids)->count();//水位不正常
        $this->success('',$res);
    }
    
    // 设备列表
    public function list($ids=null)
    {
        $res = Db::name('reservoir_hkws_hardware')
            ->field('name as DeviceName,case status when 1 then "在线" else "离线" end as EquipmentState,scode as EquipmentSerialNumber,from_unixtime(createtime,"%Y-%m-%d") as CreationTime')
            ->where('reservoir_id',$ids)
            ->select();
        $res2 = Db::name('reservoir_equipment')
            ->field('name as DeviceName,case status when 1 then "在线" else "离线" end as EquipmentState,deviceId as EquipmentSerialNumber,from_unixtime(createtime,"%Y-%m-%d") as CreationTime')
            ->where('reservoir_id',$ids)
            ->select();
        $list = array_merge($res,$res2);
        $data=['list'=>$list];
        $this->success('',$list);
    }
    //获取千寻设备
    public function getQxList(){
        $qx = new Qx();
        $info = json_decode($qx->geturl("http://openapi.qxwz.com/rest/linkx.devices.list/ack/U48c2jnr9901?pageNo=1&pageSize=2000"),true);
        foreach ($info['data']['items'] as $k => $v){
            $data[] = [
               'deviceId' => $v['deviceId'],
               'apiKey' => $v['apiKey'],
               'name' => $v['name'],
               'status' => '1',
               'reservoir_id' => $this->getReservoirId($v['name']),
               'type' =>  $this->equipmentType($v['name']),
               'createtime' => time()
            ];
        }
        Db::name('reservoir_equipment')->where('id','>=','0')->delete();
        Db::name('reservoir_equipment')->insertAll($data);
    }
    
    public function getReservoirId($name){
        $name = strstr($name,'水库',true);
        $id = Db::name('reservoir_list')->where('name','like',"%$name%")->value('id');
        return $id;
    }

    //统一采集数据接口
    public function getAllData(){
        $this->getIsotonic();
        $this->getDisplacement();
        $this->getRainfall();
        $this->getWaterLevel();
        $this->getSeepage();
    }
    
    public function getSeepage(){
        $list = Db::name('reservoir_equipment')->where("reservoir_id","in","23,24,25")->where('type','2')->select();
        $data = [];
        $endTime = time()*1000;
        foreach($list as $k => $v){
            $startTime = Db::name('reservoir_dam_seepage')->where("equipment_id",$list[$k]['id'])->order('createtime desc')->value('createtime');
            $startTime = $startTime?($startTime+1)*1000:time()*1000-2592000000;

            $qx = new Qx();
                $url = "http://openapi.qxwz.com/rest/linkx.devices.data/ack/".$qx->AccessKey."?deviceId=".$v['deviceId']."&startTime=".$startTime."&endTime=".$endTime;
                $info = json_decode($qx->geturl($url),true);
                if(!isset($info['data'])){
                    continue;
                }
                $info = reset($info['data']);
                $info = end($info);
                if($info){
                $this->warning($v['deviceId'],$info);    
                foreach($info as $k2 => $v2){
                    $data[] = [
                      'reservoir_id' => $v['reservoir_id'],
                      'value' => $v2['value'],
                      'createtime' => $v2['reportTime']/1000,
                      'reporttime' => $v2['reportTime'],
                      'equipment_id' => $v['deviceId']
                    ];
                }
              }
        }
        Db::name('reservoir_dam_seepage')->insertAll($data);
    }

    public function getSeepage2(){
        $list = Db::name('reservoir_equipment')->where('type','2')->select();
        $data = [];
        $startTime = Db::name('reservoir_dam_seepage')->order('createtime desc')->value('createtime');
        $startTime = $startTime?($startTime+1)*1000:time()*1000-2592000000;
        $endTime = time()*1000;
        foreach($list as $k => $v){
            $qx = new Qx();
            $url = "http://openapi.qxwz.com/rest/linkx.devices.data/ack/".$qx->AccessKey."?deviceId=".$v['deviceId']."&startTime=".$startTime."&endTime=".$endTime;
            $info = json_decode($qx->geturl($url),true);
            if(!isset($info['data'])){
                continue;
            }
            $info = reset($info['data']);
            $info = end($info);
            if($info){
                $this->warning($v['deviceId'],$info);
                foreach($info as $k2 => $v2){
                    $data[] = [
                        'reservoir_id' => $v['reservoir_id'],
                        'value' => $v2['value'],
                        'createtime' => $v2['reportTime']/1000,
                        'reporttime' => $v2['reportTime'],
                        'equipment_id' => $v['deviceId']
                    ];
                }
            }
        }
        Db::name('reservoir_dam_seepage')->insertAll($data);
    }
    
    //采集渗压硬件数据
    public function getIsotonic(){
        $list = Db::name('reservoir_equipment')->where("reservoir_id","in","23,24,25")->where('type','3')->select();
        $data = [];

        $endTime = time()*1000;
        foreach($list as $k => $v){
            $startTime = Db::name('reservoir_dam_isotonic')->where("equipment_id",$list[$k]['id'])->order('createtime desc')->value('createtime');
            $startTime = $startTime?($startTime+1)*1000:time()*1000-2592000000;
            $qx = new Qx();
            $url = "http://openapi.qxwz.com/rest/linkx.devices.data/ack/".$qx->AccessKey."?deviceId=".$v['deviceId']."&startTime=".$startTime."&endTime=".$endTime;
            $info = json_decode($qx->geturl($url),true);
            if(!isset($info['data'])){
                continue;
            }
            //kevin 追加浸润性深度（根据reportTime）
            $dx_info =[];
            $dx_info = end($info['data']);
            $dx_info = end($dx_info);
            $dx_data =[];
            if(!empty($dx_info)){
                foreach ($dx_info as $dk=>$dv){
                    $dx_data[$dv['reportTime']] = $dv['value'];
                }
            }
            //渗压数据
            $info = reset($info['data']);
            $info = end($info);

            if($info){
                $this->warning($v['deviceId'],$info);
                foreach($info as $k2 => $v2){
                    $data[] = [
                        'reservoir_id' => $v['reservoir_id'],
                        'value' => $v2['value'],
                        "dx_value"=>$dx_data[$v2['reportTime']]?$dx_data[$v2['reportTime']]:0,//追加浸润性深度数据（根据渗压的reportTime与浸润性reportTime相同拿值）
                        'temp' => $v2['temp'],
                        'createtime' => $v2['reportTime']/1000,
                        'reporttime' => $v2['reportTime'],
                        'equipment_id' => $v['deviceId']
                    ];
                }
            }
        }
        Db::name('reservoir_dam_isotonic')->insertAll($data);
    }
    
    //采集偏移硬件数据
    public function getDisplacement(){
        $list = Db::name('reservoir_equipment')->where("reservoir_id","in","23,24,25")->where('type','4')->select();
        $data = [];
        $endTime = time()*1000;
        foreach($list as $k => $v){
            $startTime = Db::name('reservoir_dam_displacement')->where("number",$list[$k]['id'])->order('createtime desc')->value('createtime');
            $startTime = $startTime?($startTime+1)*1000:time()*1000-2592000000;
                $qx = new Qx();
                $url = "http://openapi.qxwz.com/rest/linkx.devices.data/ack/".$qx->AccessKey."?deviceId=".$v['deviceId']."&startTime=".$startTime."&endTime=".$endTime;
                $info = json_decode($qx->geturl($url),true);
            if(!isset($info['data'])){
                    continue;
                }
                $info = end($info['data']);
                $info = end($info);
                if($info){
                $this->warning($v['deviceId'],$info);
                foreach($info as $k2 => $v2){
                    $data[] = [
                      'reservoir_id' => $v['reservoir_id'],
                      'vertical' => $v2['gpsTotalZ'],
                      'horizontal' => $v2['gpsTotalX'],
                      'horizontalY' => $v2['gpsTotalY'],
                      'createtime' => $v2['reportTime']/1000,
                      'reporttime' => $v2['reportTime'],
                      'number' => $v['deviceId']
                    ];
                }
            }
        }
            Db::name('reservoir_dam_displacement')->insertAll($data);
    }
    
    //采集降雨量硬件数据
    public function getRainfall(){
        $list = Db::name('reservoir_equipment')->where("reservoir_id","in","23,24,25")->where('type','5')->select();
        $data = [];
        $endTime = time()*1000;
        foreach($list as $k => $v){
            $startTime = Db::name('reservoir_rain_rainfall')->where("number",$list[$k]['id'])->order('createtime desc')->value('createtime');
            $startTime = $startTime?($startTime+1)*1000:time()*1000-2592000000;

            $qx = new Qx();
                $url = "http://openapi.qxwz.com/rest/linkx.devices.data/ack/".$qx->AccessKey."?deviceId=".$v['deviceId']."&startTime=".$startTime."&endTime=".$endTime;
                $info = json_decode($qx->geturl($url),true);
                if(!isset($info['data'])){
                    continue;
                }
                $info = end($info['data']);
                $info = end($info);
                if($info){
                $this->warning($v['deviceId'],$info); 
                foreach($info as $k2 => $v2){
                    $data[] = [
                      'reservoir_id' => $v['reservoir_id'],
                      'rainfall' => $v2['value'],
                      'total_rainfall' => $v2['totalValue'],
                      'createtime' => $v2['reportTime']/1000,
                      'reporttime' => $v2['reportTime'],
                      'number' => $v['deviceId']
                    ];
                }
            }
        }
            Db::name('reservoir_rain_rainfall')->insertAll($data);
    }
    
    //采集水位硬件数据
    public function getWaterLevel(){
        $list = Db::name('reservoir_equipment')->where("reservoir_id","in","25")->where('type','1')->select();

        $data = [];
         $endTime = time()*1000;
        foreach($list as $k => $v){
            $startTime = Db::name('reservoir_rain_water_level')->where("number",$list[$k]['deviceId'])->order('createtime desc')->value('createtime');
            $startTime = $startTime?($startTime+1)*1000:time()*1000-2592000000;
            $qx = new Qx();
                $url = "http://openapi.qxwz.com/rest/linkx.devices.data/ack/".$qx->AccessKey."?deviceId=".$v['deviceId']."&startTime=".$startTime."&endTime=".$endTime;
                $info = json_decode($qx->geturl($url),true);
                if(!isset($info['data'])){
                    continue;
                }
                $info = end($info['data']);
                $info = end($info);
                if($info){
                $this->warning($v['deviceId'],$info);

                foreach($info as $k2 => $v2){
                    $data[] = [
                      'reservoir_id' => $v['reservoir_id'],
                      'water_level' => $v2['value'],
                      'createtime' => $v2['reportTime']/1000,
                      'reporttime' => $v2['reportTime'],
                      'number' => $v['deviceId']
                    ];
                }
            }
        }

        $res=Db::name('reservoir_rain_water_level')->insertAll($data);
    }
    
    public function equipmentType($type){
        if(strstr($type,'水位计')){
            return '1';
        }
        elseif(strstr($type,'量水堰')){
            return '2';
        }
        elseif(strstr($type,'渗压计')){
            return '3';
        }
        elseif(strstr($type,'雨量计')){
            return '5';
        }
        elseif(strstr($type,'监测点')){
            return '6';
        }
        else{
            return '7';
        }
    }
    
    public function warning($deviceid,$data){
        $type = $this->model->where('deviceId',$deviceid)->value('type');
        $threshold = Db::name('reservoir_threshold')->where('deviceId',$deviceid)->field('config,reservoir_id')->find();
        $config = json_decode($threshold['config'],true);
        $reservoir = Db::name('reservoir_list')->where('id',$threshold['reservoir_id'])->field('user_mobile,name')->find();
        
        if(!$config){
            return;
        }
        //水位
        if($type == '1'){
            $arr = explode(',',$config['value']);
            sort($arr);
            foreach($data as $k => $v){
            if($v['value'] < $arr[0] || $v['value'] > $arr[1]){
                $insert = [
                  'value' => $v['value'],
                  'warning' => $arr[0].','.$arr[1],
                  'equipment_id' => $deviceid,
                  'reservoir_id' => $threshold['reservoir_id'],
                  'createtime' => time(),
                  'reporttime' =>$v['reportTime']
                ];
                Db::name('reservoir_warning_waterlevel')->insert($insert);
                // $sms = new Index();
                // $res = $sms->send_param($reservoir['user_mobile'],'SMS_227742188','云南智慧水库安全云平台',array('password'=>$reservoir['name']));
            }
          }
        }
        //渗压
        if($type == '3'){
            $arr = explode(',',$config['value']);
            sort($arr);
            foreach($data as $k => $v){
            if($v['value'] < $arr[0] || $v['value'] > $arr[1]){
                $insert = [
                  'value' => $v['value'],
                  'warning' => $arr[0].','.$arr[1],
                  'equipment_id' => $deviceid,
                  'reservoir_id' => $threshold['reservoir_id'],
                  'createtime' => time(),
                  'reporttime' =>$v['reportTime']
                ];
                Db::name('reservoir_warning_isotonic')->insert($insert);
                // $sms = new Index();
                // $res = $sms->send_param($reservoir['user_mobile'],'SMS_227742188','云南智慧水库安全云平台',array('password'=>$reservoir['name']));
            }
          }
        }
        //雨量
        elseif($type == '5'){
            $arr = explode(',',$config['value']);
            sort($arr);
            foreach($data as $k => $v){
            if($v['value'] < $arr[0] || $v['value'] > $arr[1]){
                $insert = [
                  'value' => $v['value'],
                  'warning' => $arr[0].','.$arr[1],
                  'equipment_id' => $deviceid,
                  'reservoir_id' => $threshold['reservoir_id'],
                  'createtime' => time(),
                  'reporttime' =>$v['reportTime']
                ];
                Db::name('reservoir_warning_rainfall')->insert($insert);
                // $sms = new Index();
                // $res = $sms->send_param($reservoir['user_mobile'],'SMS_227742188','云南智慧水库安全云平台',array('password'=>$reservoir['name']));
            }
          }
        }
        //位移
        elseif($type == '6'){
            foreach($data as $key => $val){
            foreach($config as $k => $v){
                $arr = explode(',',$v);
                sort($arr);
                $value = $val['gpsTotal'.strtoupper($k)];
                if($value < $arr[0] || $value > $arr[1]){
                    $insert = [
                  'value' => $value,
                  'warning' => $arr[0].','.$arr[1],
                  'equipment_id' => $deviceid,
                  'reservoir_id' => $threshold['reservoir_id'],
                  'createtime' => time(),
                  'reporttime' =>$val['reportTime'],
                  'shaft' => $k
                ];
                Db::name('reservoir_warning_displacement')->insert($insert);
                    // $sms = new Index();
                    // $res = $sms->send_param($reservoir['user_mobile'],'SMS_227742188','云南智慧水库安全云平台',array('password'=>$reservoir['name']));
                }
            }
          }
        }
    }
    
}