<?php

namespace app\api\controller\reservoir;

use app\api\controller\v8\User;
use app\common\controller\Api;
use app\common\helper\HttpHelper;
use fast\Tree;
use think\Request;
use think\Db;

/**
 * Class Waterlevel
 * @package app\api\controller
 */
class Index extends Api
{
    protected $model = '';
    protected $noNeedLogin = ['list','reservoirinfo', 'playscore','getReiverorList', 'latest', 'latests', 'abnormal', 'latestdam', 'water_equipment'];
    protected $noNeedRight = '*';
    protected $sxjApiurl="http://124.71.107.128:9040/";

    public function _initialize()
    {
        parent::_initialize(); // TODO: Change the autogenerated stub
        $this->model = new \app\admin\model\reservoir\Reservoirlist;
    }

    /**
     * 17、大屏设备列表
     * 0:不限，1=水位计,2=渗流计,3=渗压计,4=GNSS,5=雨量计,6=位移检测,7=其他，8=摄像头
     */
    public function water_equipment()
    {
        $type = $this->request->param("type", 0);
        $type_list = [
            [
                "id" => "1", "name" => "水位计",
            ],
            [
                "id" => "5", "name" => "雨量计",
            ],
            [
                "id" => "3", "name" => "渗压计",
            ],
            [
                "id" => "2", "name" => "渗流计",
            ],
            [
                "id" => "6", "name" => "位移计",
            ],
            [
                "id" => "8", "name" => "摄像头",
            ]
        ];
        foreach ($type_list as $k => $v) {
            switch ($v['id']) {
                case 1:
                    //水位计
                    $where = [];
                    $where["type"] = ["=", $v['id']];
                    //水库硬件设备
                    $data = Db::name("reservoir_equipment")->where($where)->field("deviceId,name as equip_name,type,longitude,latitude,reservoir_id")->order("reservoir_id asc,id asc")->select();
                    if (empty($data)) {
                        unset($type_list[$k]);
                    } else {
                        foreach ($data as $dk => $dv) {
                            $record = Db::name("reservoir_rain_water_level")->where("number", $dv['deviceId'])->order("reporttime desc,id desc")->field('water_level,from_unixtime(createtime,"%m-%d %h:%i") as createtime')->find();
                            if (!empty($record)) {
                                $record["capacityof"] = Db::name("warterdata_capacityof")->where(["warterdata" => $record['water_level'], "reservoir_id" => $dv['reservoir_id']])->value("CapacityOf");
                            }
                            $data[$dk]["record"] = $record;
                        }
                        $type_list[$k]['equipment'] = $data;
                    }
                    if ($type == $v['id']) {
                        $this->success("设备获取成功", $data);
                    }
                    break;
                case 2:
                    //渗流计
                    $where = [];
                    $where["type"] = ["=", $v['id']];
                    //水库硬件设备
                    $data = Db::name("reservoir_equipment")->where($where)->field("deviceId,name as equip_name,type,longitude,latitude")->order("id asc")->select();
                    if (empty($data)) {
                        unset($type_list[$k]);
                    } else {
                        foreach ($data as $dk => $dv) {
                            $data[$dk]["record"] = Db::name("reservoir_dam_seepage")->where("equipment_id", $dv['deviceId'])->order("createtime desc")->field("value")->find();
                        }
                        $type_list[$k]['equipment'] = $data;
                    }
                    if ($type == $v['id']) {
                        $this->success("设备获取成功", $data);
                    }
                    break;
                case 3:
                    //渗压计
                    $where = [];
                    $where["type"] = ["=", $v['id']];
                    //水库硬件设备
                    $data = Db::name("reservoir_equipment")->where($where)->field("deviceId,name as equip_name,type,longitude,latitude")->order("id asc")->select();
                    if (empty($data)) {
                        unset($type_list[$k]);
                    } else {
                        foreach ($data as $dk => $dv) {
                            $data[$dk]["record"] = Db::name("reservoir_dam_isotonic")->where("equipment_id", $dv['deviceId'])->order("createtime desc")->field("value,dx_value")->find();
                        }
                        $type_list[$k]['equipment'] = $data;
                    }
                    if ($type == $v['id']) {
                        $this->success("设备获取成功", $data);
                    }
                    break;
                case 5:
                    //雨量计
                    $where = [];
                    $where["type"] = ["=", $v['id']];
                    //水库硬件设备
                    $data = Db::name("reservoir_equipment")->where($where)->field("deviceId,name as equip_name,type,longitude,latitude")->order("id asc")->select();
                    if (empty($data)) {
                        unset($type_list[$k]);
                    } else {
                        foreach ($data as $dk => $dv) {
                            $data[$dk]["record"] = Db::name("reservoir_rain_rainfall")->where("number", $dv['deviceId'])->order("reporttime desc,id desc")->field('total_rainfall,from_unixtime(createtime,"%m-%d %h:%i") as createtime')->find();
                        }
                        $type_list[$k]['equipment'] = $data;
                    }
                    if ($type == $v['id']) {
                        $this->success("设备获取成功", $data);
                    }
                    break;
                case 6:
                    //位移计
                    $where = [];
                    $where["type"] = ["=", $v['id']];
                    //水库硬件设备
                    $data = Db::name("reservoir_equipment")->where($where)->field("deviceId,name as equip_name,type,longitude,latitude")->order("id asc")->select();
                    if (empty($data)) {
                        unset($type_list[$k]);
                    } else {
                        foreach ($data as $dk => $dv) {
                            $data[$dk]["record"] = Db::name("reservoir_dam_displacement")->where("number", $dv['deviceId'])->order("createtime desc")->field("horizontal,horizontalY,vertical")->find();
                        }
                        $type_list[$k]['equipment'] = $data;
                    }
                    if ($type == $v['id']) {
                        $this->success("设备获取成功", $data);
                    }
                    break;
                case 8:
                    //摄像头
                    $where = [];
                    //水库硬件设备
                    $data = Db::name("reservoir_hkws_hardware")->where($where)->field("indexCode as deviceId,name as equip_name,longitude,latitude")->order("id asc")->select();
                    if (empty($data)) {
                        unset($type_list[$k]);
                    } else {
                        $type_list[$k]['equipment'] = $data;
                    }
                    if ($type == $v['id']) {
                        $this->success("设备获取成功", $data);
                    }
                    break;
            }

        }

        $this->success("设备获取成功", $type_list);

    }

    public function details($ids = null)
    {
        $row = $this->model->get($ids);
        if (!$row) {
            $this->error('水库不存在');
        }
        $this->success('', $row);
    }


    public function latests($ids = null)
    {

        $crack = Db::name('reservoir_dam_crack')->field('horizontal,vertical')->where('reservoir_id', $ids)->order('createtime desc')->find();
        $isotonic = Db::name('reservoir_dam_isotonic')->where('reservoir_id', $ids)->order('createtime desc')->value('value');
        $seepage = Db::name('reservoir_dam_seepage')->where('reservoir_id', $ids)->order('createtime desc')->value('value');
        $water = Db::name('reservoir_rain_water_level')->where('reservoir_id', $ids)->field('water_level,water_level_warning')->order('createtime desc')->find();
        $rainfall = Db::name('reservoir_rain_rainfall')->where('reservoir_id', $ids)->field('rainfall,rainfall_warning')->order('createtime desc')->find();
        $under = Db::name('reservoir_list')->where('id', $ids)->value('under');
        $ruqin = Db::name('reservoir_hkws_warning')->where('reservoir_id', $ids)->count();
        $data = [
            ['name' => '水平位移', 'num' => $crack['horizontal']],  //
            ['name' => '垂直位移', 'num' => $crack['vertical']],
            ['name' => '渗压值', 'num' => $isotonic],
            ['name' => '渗流', 'num' => $seepage],
            ['name' => '水位', 'num' => $water['water_level']],
            ['name' => '水位预警 ', 'num' => $water['water_level_warning']],
            ['name' => '降雨量', 'num' => $rainfall['rainfall']],
            ['name' => '降雨量预警', 'num' => $rainfall['rainfall_warning']],
            ['name' => '库容量', 'num' => $under],
            ['name' => '入侵次数', 'num' => $ruqin]
        ];
        $this->success('', $data);
    }


    public function latest($ids = null)
    {

        $crack = Db::name('reservoir_dam_crack')->field('horizontal,vertical')->where('reservoir_id', $ids)->order('createtime desc')->find();
        $isotonic = Db::name('reservoir_dam_isotonic')->where('reservoir_id', $ids)->order('createtime desc')->value('value');
        $seepage = Db::name('reservoir_dam_seepage')->where('reservoir_id', $ids)->order('createtime desc')->value('value');
        $water = Db::name('reservoir_rain_water_level')->where('reservoir_id', $ids)->field('water_level,water_level_warning')->order('createtime desc')->find();
        $rainfall = Db::name('reservoir_rain_rainfall')->where('reservoir_id', $ids)->field('rainfall,rainfall_warning')->order('createtime desc')->find();
        $under = Db::name('reservoir_list')->where('id', $ids)->value('under');
        $ruqin = Db::name('reservoir_hkws_warning')->where('reservoir_id', $ids)->count();
        $data = [
            'horizontal' => $crack['horizontal'],   // 水平位移
            'vertical' => $crack['vertical'],    // 垂直位移
            'isotonic' => $isotonic,  // 渗压值
            'seepage' => $seepage,  // 渗流
            'waterlevel' => $water['water_level'],//  水位
            'water_level_warning' => $water['water_level_warning'], // 水位预警
            'rainfall' => $rainfall['rainfall'], // 降雨量
            'rainfall_warning' => $rainfall['rainfall_warning'], // 降雨量预警
            'under' => $under, // 库容量
            'ruqin' => $ruqin // 入侵次数
        ];
        $this->success('', $data);
    }

    public function latestdam($ids = null)
    {
        $crack = Db::name('reservoir_dam_displacement')->field('vertical,horizontal,horizontalY')->where('reservoir_id', $ids)->order('createtime desc')->find();
        //  $crack = Db::name('reservoir_dam_crack')->field('horizontal,vertical')->where('reservoir_id',$ids)->order('createtime desc')->find();
        $isotonic = Db::name('reservoir_dam_isotonic')->where('reservoir_id', $ids)->order('createtime desc')->value('value');
        $seepage = Db::name('reservoir_dam_seepage')->where('reservoir_id', $ids)->order('createtime desc')->value('value');
        $water = Db::name('reservoir_rain_water_level')->where('reservoir_id', $ids)->field('water_level,water_level_warning')->order('createtime desc')->find();
        $rainfall = Db::name('reservoir_rain_rainfall')->where('reservoir_id', $ids)->field('rainfall,rainfall_warning')->order('createtime desc')->find();
        $under = Db::name('reservoir_list')->where('id', $ids)->value('under');
        $ruqin = Db::name('reservoir_hkws_warning')->where('reservoir_id', $ids)->count();
        $data = [
            ['name' => '水平位移', 'num' => $crack['horizontal']],  //
            ['name' => '垂直位移', 'num' => $crack['vertical']],
            ['name' => '渗压值', 'num' => $isotonic],
            ['name' => '渗流', 'num' => $seepage],
            ['name' => '水位', 'num' => $water['water_level']],
            ['name' => '水位预警 ', 'num' => $water['water_level_warning']],
            ['name' => '降雨量', 'num' => $rainfall['rainfall']],
            ['name' => '降雨量预警', 'num' => $rainfall['rainfall_warning']],
            ['name' => '库容量', 'num' => $under],
            ['name' => '入侵次数', 'num' => $ruqin]
        ];
        $this->success('', $data);
    }


    public function playscore($ids = null)
    {
        if (!$ids) {
            $this->error('参数错误');
        }
        $count = Db::name('reservoir_hkws_warning')->where('reservoir_id', $ids)->whereTime('createtime', 'week')->count();
        $score = 20;
        $score -= $count;
        if ($count >= $score) {
            $videoscore = 0;
        }
        $data = [
            'videoscore' => $videoscore
        ];
        $this->success('', $data);
    }

    // 水库列表
    public function list()
    {
        $user=new User();
        $token=$user->uimsApitoken();
        $url=$this->sxjApiurl."data_api/v1/getWaterworksListData";
        $res =HttpHelper::postheader($url,"","",$token);
        $res=json_decode($res,true);
        foreach ($res['data']['list'] as $k=>$v){
            $res['data']['list'][$k]['thumbnail_images']="https://yysw.ynzhsk.cn/image_jg/work.png";
        }
        return $this->success($res['message'],$res['data']);
    }

    public function test()
    {
        $xml = file_get_contents('php://input');//监听是否有数据传入
        if ($xml != '') {//如果有数据传入，则将传入的数据写入到xml.txt文件
            libxml_disable_entity_loader(true);
            $xml = json_encode(simplexml_load_string($xml, 'SimpleXMLElement', LIBXML_NOCDATA));
            $fp = fopen('xml.txt', 'w');
            fwrite($fp, $xml);
            fclose($fp);
            exit('OK');//写入成功后返回成功信息
        }
        die('Fail');//没有数据则直接返回失败信息
    }

    /**
     * 获取水库信息
     * Class Reservoir
     * @package app\api\controller\reservoir
     */
    public function getInfo()
    {
        $id = input('get.id');
        $info = $this->model->get($id);
        if (!$info) {
            $this->error('参数错误');
        }
        //水库信息
        $res['info'] = $info;
        //风力
        $wind = Db::name('reservoir_rain_wind')->where('reservoir_id', '=', $id)->field('wind,wind_warning')->order('createtime desc')->limit(1)->find();
        $res['wind'] = $wind;
        //水位
        $waterlevel = Db::name('reservoir_rain_water_level')->where('reservoir_id', '=', $id)->field('water_level,water_level_warning')->order('createtime desc')->limit(1)->find();
        $res['waterlevel'] = $waterlevel;
        //降雨量
        $rainfall = Db::name('reservoir_rain_rainfall')->where('reservoir_id', '=', $id)->field('rainfall,rainfall_warning')->order('createtime desc')->limit(1)->find();
        $res['rainfall'] = $rainfall;
        //坝体气象
        $meteorological = Db::name('reservoir_dam_meteorological')->where('reservoir_id', '=', $id)->field('temperature,upstream_flow,downstream_flow')->order('createtime desc')->limit(1)->find();
        $res['meteorological'] = $meteorological;
        $this->success('获取成功', $res);
    }

    /**
     * 雨水情可视化接口
     */

    public function abnormal()
    {


        // 水库降雨量
        $res = Db::name('reservoir_list')->alias('a')
            ->join('reservoir_rain_rainfall b', 'a.id = b.reservoir_id')
            ->where('b.rainfall_warning', '1')
            ->field('a.name, b.rainfall_warning')
            ->select();

        // 水库水位    
        $res1 = Db::name('reservoir_list')->alias('a')
            ->join('reservoir_rain_water_level b', 'a.id = b.reservoir_id')
            ->where('b.water_level_warning', '1')
            ->field('a.name, b.water_level_warning')
            ->select();


        $data = array_merge($res, $res1);
        $namelist = [];

        foreach ($data as $d) {
            if (!in_array($d['name'], $namelist)) {
                $namelist[] = $d['name'];
            }
        }

        $data1 = [];
        foreach ($namelist as $n) {
            $name = $n;
            $value = 0;
            foreach ($data as $v) {
                if ($v['name'] == $name) {
                    $value++;
                }
            }
            $data2 = [
                'name' => $name,
                'value' => $value
            ];
            $data1[] = $data2;
        }


        $this->success('获取成功', $data1);


    }


    //@pcl 合并版本添加的
    //按区域获得水库列表
    public function getReiverorList()
    {
        $serach = $this->request->param('search', '');
        if (!empty($serach)) {
            $wh['name'] = ['like', '%' . $serach . '%'];
        } else {
            $wh = ' 1=1 ';
        }

        $list = Db::name('reservoir_list')
            ->where($wh)
            ->field('id,name,thumbnail_images,completetime,user_name,address,under,normal_water_level,dead_water_level,lat,lng')
            ->select();

        if (!empty($list)) {
            foreach ($list as $k => $v) {
                //当前水位
                $leval = Db::name('reservoir_rain_water_level')
                    ->where(['reservoir_id' => $v['id']])
                    ->order('id', 'desc')
                    ->find();
                $list[$k]['thumbnail_images'] = full_image_kevin($v['thumbnail_images']);
                $list[$k]['completetime_text'] = date('Y年m月d日', $v['completetime']);
                $list[$k]['now_capacityof'] = getWarterdataCapacityof($v['id'], $leval['water_level']);
                $list[$k]['dead_capacityof'] = getWarterdataCapacityof($v['id'], $v['dead_water_level']);
            }
        }
        $data = [
            'ReservoirList' => $list,
        ];
        $this->success('获取成功', $data);
    }

    /**
     * 水库信息接口
     * @return void
     */
    public function reservoirinfo(){
        $endtime=time();
        $startime=$endtime-86400;
        $where["createtime"] = ["between", [$startime, $endtime]];
        $weather=Db::name("weatherinfo")->where($where)->sum("precipitation_value");
        $weatherinfo=Db::name("weatherinfo")->order("id desc")->find();
        $reservoir_list=Db::name("reservoir_list")->find();
        $dam_seepage=Db::name("reservoir_dam_seepage")->order("id desc")->find();
        $rain_water_level=Db::name("reservoir_rain_water_level")->where('number',1)->order("id desc")->find();
        //当前库容
        $now_capacityof = getWarterdataCapacityof(40, round($rain_water_level['water_level'],2));
        $storage_capacity_ratio=bcmul(bcdiv($now_capacityof,$reservoir_list['under'],4),100,2)."%";
        //雨情监测
        $rain=[
            "0"=>['name'=>"状态","value"=>"正常"],//状态
            "1"=> ['name'=>"降水状态","value"=>$weatherinfo['skycon_value']],//降雨情况
            "2"=> ['name'=>"累计降水量(24h/mm)","value"=>$weatherinfo['day_precipitation_value']],   //累计雨量
            "3"=>['name'=>"瞬时降水量(h/mm)","value"=>$weatherinfo['precipitation_value']],  //瞬时雨量
            "4"=> ['name'=>"未来降水量(24h/mm)","value"=>$weather],//预告雨量
        ];


        //水情监测
        $water=[
            "0"=>['name'=>"状态","value"=>"正常"],//状态
            "1"=>['name'=>"库容比(%)","value"=>$storage_capacity_ratio],//库容比
            "2"=>['name'=>"库水位(m)","value"=>$reservoir_list['normal_water_level']],//正常水位
            "3"=>['name'=>"警戒水位(m)","value"=>$reservoir_list['warning_water_level']],//警戒水位
            "4"=>['name'=>"库容量(万m³)","value"=>$now_capacityof],//库容量
            "5"=>['name'=>"排水量(m³/s)","value"=>"/"],//排水量
        ];
        //渗流监测
        $transfusion=[
            "0"=>['name'=>"状态","value"=>"正常"],//状态
            "1"=>['name'=>"瞬时流量(L/s)","value"=>$dam_seepage['value']],//瞬时流量
            "2"=>['name'=>"预警流量(L/s)","value"=>"2"],//预警流量
            "3"=>['name'=>"水位差(m)","value"=>"5"],//水位差
            "4"=>['name'=>"预警水位差(m)","value"=>"3",]//预警水位差
        ];
        //获取河流的信息
        $reservoir_equipment=Db::name("reservoir_equipment")->where("type",5)->select();
        //查询数据
        //阿子田
        $azitian_rain_water_level=Db::name("reservoir_rain_water_level")->where("number",80235810)->order("id desc")->find();
        //矣维河
        $aiweihe_rain_water_level=Db::name("reservoir_rain_water_level")->where("number",80235820)->order("id desc")->find();
        $water_level=[
            "azitian"=>[
                "0"=>['name'=>"日雨量(L)","value"=>"0"],//状态
                "1"=>['name'=>"水位(m)","value"=>$azitian_rain_water_level['water_level']],//水位
                "2"=>['name'=>"流量(L/s)","value"=>$azitian_rain_water_level['flow']],//流量
            ],"aiweihe"=>[
                "0"=>['name'=>"日雨量(L)","value"=>"0(L)"],//状态
                "1"=>['name'=>"水位(m)","value"=>$aiweihe_rain_water_level['water_level']],//水位
                "2"=>['name'=>"流量(L/s)","value"=>$aiweihe_rain_water_level['flow']],//流量
            ]
        ];
        $data['rain']=$rain;//雨情监测
        $data['water']=$water;//水情监测
        $data['transfusion']=$transfusion;//渗流监测
        $data['water_level']=$water_level;//河流数据
        $this->success('获取成功', $data);
    }
}