<?php

namespace app\api\controller\reservoir;

use app\admin\model\wrp\rsr\Dnst;
use app\common\controller\Api;
use fast\Date;
use think\Request;
use think\Db;

/**
 * 蒙自智慧水库安全监测指挥平台
 */
class CommandScreenv2 extends Api
{

    protected $model = '';
    protected $noNeedLogin = '*';
    protected $noNeedRight = '*';

    public function _initialize()
    {
        parent::_initialize();
        $this->reservoirlist = new \app\admin\model\reservoir\Reservoirlist;

    }

    /**
     * 2、【左顶1-2】水库列表
     */
    public function reservoir_list()
    {
        $field = "id,name";
        $data = Db::name("reservoir_list")->field($field)->order("id asc")->select();
        $this->success("水库列表数据获取成功", $data);
    }

    /**
     * 2、【左顶1-2】水库列表
     */
    public function search_reservoir_list()
    {
        $searchkey=$this->request->param('searchkey');
        $field = "id,name,lat,lng";
        $where["name"] = ["LIKE", "%{$searchkey}%"];

        $data = Db::name("reservoir_list")->where($where)->field($field)->order("id asc")->select();
        $this->success("水库搜索列表数据获取成功", $data);
    }

    /**
     * 3、【左顶1-1】水库注册信息【水库类型及其占比】
     */
    public function reservoir_type_proportion()
    {
        $type_list = [
            "小（1）型水库",
            "小（2）型水库",
            "中型水库"
        ];
        $type_count1 = Db::name("reservoir_list")->where("reservoir_level", $type_list[0])->count();
        $type_count2 = Db::name("reservoir_list")->where("reservoir_level", $type_list[1])->count();
        $type_count3 = Db::name("reservoir_list")->where("reservoir_level", $type_list[2])->count();
        $all = $type_count1 + $type_count2 + $type_count3;
        $return_data = [];
        $bili1 = 0;
        $bili2 = 0;
        $bili3 = 0;
        if ($all > 0) {
            $bili1 = bcdiv($type_count1, $all, 2);
            $bili2 = bcdiv($type_count2, $all, 2);
            $bili3 = bcsub(1, $bili1 + $bili2, 2);
        }
        $return_data = [
            [
                "name" => $type_list[0],
                "number" => $type_count1 . "座",
                "bili" => $bili1 * 100,
            ],
            [
                "name" => $type_list[1],
                "number" => $type_count2 . "座",
                "bili" => $bili2 * 100,
            ],
            [
                "name" => $type_list[2],
                "number" => $type_count3 . "座",
                "bili" => $bili3 * 100,
            ]
        ];
        $this->success("数据获取成功", $return_data);
    }

    /**
     * 4、【左中】监测设备情况
     */
    public function equipment_list()
    {
        //设备类型:1=水位计,2=渗流计,3=渗压计,5=雨量计,6=位移检测
        $data = [
            [
                "type" => 1,
                "name" => "水位计",
                "number" => Db::name("reservoir_equipment")->where("type", 1)->count(),
            ],
            [
                "type" => 5,
                "name" => "雨量计",
                "number" => Db::name("reservoir_equipment")->where("type", 5)->count(),
            ],
            [
                "type" => 3,
                "name" => "渗压计",
                "number" => Db::name("reservoir_equipment")->where("type", 3)->count(),
            ],
            [
                "type" => 2,
                "name" => "渗流计",
                "number" => Db::name("reservoir_equipment")->where("type", 2)->count(),
            ],
            [
                "type" => 6,
                "name" => "位移检测",
                "number" => Db::name("reservoir_equipment")->where("type", 6)->count(),
            ],
        ];
        $this->success("监测设备数据获取成功", $data);

    }

    /**
     * 6、【右上】当天巡检动态
     */
    public function today_inspection_project()
    {
        $projectModel = new \app\admin\model\inspection\Project();

        $today_start = strtotime(date("Y-m-d"));
        $today_end = $today_start + 3600 * 24 - 1;

        $where = [];
        $where["project.begintime"] = ["egt", $today_start];
        $where["project.endtime"] = ["elt", $today_end];

        $total = $projectModel
            ->alias('project')
            ->where($where)
            ->count();

        //巡检异常
        $where["status"] = ["=", "0"];
        $yc_count = $projectModel
            ->alias('project')
            ->where($where)
            ->where(["status" => 1, "state" => "2"])
            ->count();
        //巡检正常
        $zc_count = $projectModel
            ->alias('project')
            ->where($where)
            ->where(["status" => 1, "state" => "1"])
            ->count();
        $return_data = [
            "total" => $total,
            "yc_count" => $yc_count,
            "zc_count" => $zc_count,
            "all" => $total+$zc_count+$yc_count,

        ];
        $this->success('当天巡检动态数据获取成功', $return_data);
    }

    /**
     * 6、【右上】单个水库当天巡检动态
     */
    public function today_inspection_projectbyreservoir_id()
    {
        $reservoir_id = $this->request->param("reservoir_id");
        $projectModel = new \app\admin\model\inspection\Project();
        $area=Db::name("inspection_area")->where("reservoir_id",$reservoir_id)->field('id')->select();


        $area_id = implode(',', array_map(function($a) {

            return implode(',', $a);

        }, $area));



        $today_start = strtotime(date("Y-m-d"));
        $today_end = $today_start + 3600 * 24 - 1;



        $where = [];
        $where["project.begintime"] = ["egt", $today_start];
        $where["project.endtime"] = ["elt", $today_end];
        $where["project.area_id"] = ["=", $area_id];

        $total = $projectModel
            ->alias('project')
            ->where($where)
            ->count();

        //巡检异常
        $where["status"] = ["=", "0"];
        $yc_count = $projectModel
            ->alias('project')
            ->where($where)
            ->where(["status" => 1, "state" => "2"])
            ->count();
        //巡检正常
        $zc_count = $projectModel
            ->alias('project')
            ->where($where)
            ->where(["status" => 1, "state" => "1"])
            ->count();
        $return_data = [
            "total" => $total,
            "yc_count" => $yc_count,
            "zc_count" => $zc_count,
        ];
        $this->success('当天巡检动态数据获取成功', $return_data);
    }

    /**
     * 6、【右上】单个水库当天巡检动态
     */
    public function today_inspection_projectbyreservoir_time()
    {
        $reservoir_id = $this->request->param("reservoir_id",'4');
        $time = 1;
        $lasttime = strtotime(date('Y-m-d 23:59:59')) - $time*60*60*24;
        //$where['createtime'] = ['between',[$lasttime,strtotime(date('Y-m-d 23:59:59'))]];
        $where['reservoir_list_id']=['=',$reservoir_id];
        $starttime = Date::unixtime('day', -6);
        $endtime = Date::unixtime('day', 0, 'end');

        $joinlist = Db("reservoir_hkws_alarm_monitoring")
            ->where($where)
            ->where('createtime', 'between time', [$starttime, $endtime])
            ->field('createtime, status, COUNT(*) AS nums, DATE_FORMAT(FROM_UNIXTIME(createtime), "%Y-%m-%d") AS join_date')
            ->group('join_date')
            ->select();

        for ($time = $starttime; $time <= $endtime;) {
            $column[] = date("Y-m-d", $time);
            $time += 86400;
        }
        $userlist = array_fill_keys($column, 0);
        foreach ($joinlist as $k => $v) {
            $userlist[$v['join_date']] = $v['nums'];
        }

        $data[0]=array_keys($userlist);
        foreach($data[0] as $ks=>$vs){
            $data[0][$ks]=date("m-d",strtotime($data[0][$ks]));
        }

        $data[1]=array_values($userlist);
        return $this->success("当天入侵动态数据表获取成功",$data);
    }

    public function alarm_monitoring_list(){
        $time = 1;
        $lasttime = strtotime(date('Y-m-d 23:59:59')) - $time*60*60*24;
        $where['createtime'] = ['between',[$lasttime,strtotime(date('Y-m-d 23:59:59'))]];
        $starttime = Date::unixtime('day', -6);
        $endtime = Date::unixtime('day', 0, 'end');

        $joinlist = Db("reservoir_hkws_alarm_monitoring")->where('createtime', 'between time', [$starttime, $endtime])
            ->field('createtime, status, COUNT(*) AS nums, DATE_FORMAT(FROM_UNIXTIME(createtime), "%Y-%m-%d") AS join_date')
            ->group('join_date')
            ->select();
        for ($time = $starttime; $time <= $endtime;) {
            $column[] = date("Y-m-d", $time);
            $time += 86400;
        }
        $userlist = array_fill_keys($column, 0);
        foreach ($joinlist as $k => $v) {
            $userlist[$v['join_date']] = $v['nums'];
        }

        $data[0]=array_keys($userlist);
        foreach($data[0] as $ks=>$vs){
            $data[0][$ks]=date("m-d",strtotime($data[0][$ks]));
        }
        $data[1]=array_values($userlist);
        return $this->success("当天入侵动态数据表获取成功",$data);
    }

    /**
     * 查询各个类型水库的入侵数量
     */
    public function alarm_monitoring_countbyreservoir_level(){
        $time = 1;
        $lasttime = strtotime(date('Y-m-d 23:59:59')) - $time*60*60*24;
        $where['createtime'] = ['between',[$lasttime,strtotime(date('Y-m-d 23:59:59'))]];
        $x1 = Db::name("reservoir_list")->where('reservoir_level', '小（1）型水库')->where('design_unit', "蒙自水利局")->field('id')->select();
        //拼接数组
        $x1string = implode(',', array_map(function($a) {

            return implode(',', $a);

        }, $x1));
        $where['reservoir_list_id']=['in',$x1string];
        $small_scale_first=Db::name('reservoir_hkws_alarm_monitoring')->where($where)->count();
        $x2 = Db::name("reservoir_list")->where('reservoir_level', '小（2）型水库')->where('design_unit', "蒙自水利局")->field('id')->select();
        $x2string = implode(',', array_map(function($b) {

            return implode(',', $b);

        }, $x2));
        $where['reservoir_list_id']=['in',$x2string];
        $small_scale_second=Db::name('reservoir_hkws_alarm_monitoring')->where($where)->count();

        $z = Db::name("reservoir_list")->where('reservoir_level', '中型水库')->where('design_unit', "蒙自水利局")->field('id')->select();
        $z2string = implode(',', array_map(function($c) {

            return implode(',', $c);

        }, $z));
        $where['reservoir_list_id']=['in',$z2string];
        $medium_sized=Db::name('reservoir_hkws_alarm_monitoring')->where($where)->count();
        $data['small_scale_first']=$small_scale_first;
        $data['small_scale_second']=$small_scale_second;
        $data['medium_sized']=$medium_sized;
        $data['total_num']=$small_scale_first+$small_scale_second+$medium_sized;
        return $this->success("",$data);

    }
    /**
     * 7、【右中1】入侵动态
     */
    public function alarm_monitoring_count()
    {
        $count=[];
        //当日
        $time = 1;
        $lasttime = strtotime(date('Y-m-d 23:59:59')) - $time*60*60*24;
        $cond['createtime'] = ['between',[$lasttime,strtotime(date('Y-m-d 23:59:59'))]];
        $crack = Db::name('reservoir_warning_crack')->where($cond)->count();
        $displacement = Db::name('reservoir_warning_displacement')->where($cond)->count();
        $rainfall = Db::name('reservoir_warning_rainfall')->where($cond)->count();
        $settlement = Db::name('reservoir_warning_settlement')->where($cond)->count();
        $waterlevel = Db::name('reservoir_warning_waterlevel')->where($cond)->count();
        $waterseepage = Db::name('reservoir_warning_waterseepage')->where($cond)->count();
        $weather = Db::name('reservoir_warning_weather')->where($cond)->count();
        $count['day'] = $crack+$displacement+$rainfall+$settlement+$waterlevel+$waterseepage+$weather;

        //当日
        $crack = Db::name('reservoir_warning_crack')->count();
        $displacement = Db::name('reservoir_warning_displacement')->count();
        $rainfall = Db::name('reservoir_warning_rainfall')->count();
        $settlement = Db::name('reservoir_warning_settlement')->count();
        $waterlevel = Db::name('reservoir_warning_waterlevel')->count();
        $waterseepage = Db::name('reservoir_warning_waterseepage')->count();
        $weather = Db::name('reservoir_warning_weather')->count();
        $count['all'] = $crack+$displacement+$rainfall+$settlement+$waterlevel+$waterseepage+$weather;
        $return_data['warning']=$count;

        $crackres= Db::name('reservoir_warning_crack')->find();
        $displacementres = Db::name('reservoir_warning_displacement')->find();
        $rainfallres = Db::name('reservoir_warning_rainfall')->find();
        $settlementres = Db::name('reservoir_warning_settlement')->find();
        $waterlevelres = Db::name('reservoir_warning_waterlevel')->find();
        $waterseepageres = Db::name('reservoir_warning_waterseepage')->find();
        $weatherres = Db::name('reservoir_warning_weather')->find();
        $warninginfo['info']=$crackres;
        $warninginfo['type']="warning_crack";
        $return_data['warning']=$warninginfo;
        $this->success("", $return_data);

    }

    /**
     * 8、【右中2】雨情动态
     */
    public function warning_rainfall_count()
    {
        $warning_limit = 100;//雨量限制100mm
        $return_data = [
            "warning_limit" => $warning_limit,
        ];

        $undeal_num = Db::name("reservoir_warning_rainfall")->where("deal", "1")->whereTime("createtime", "today")->count();
        $allreservoir=Db::name("reservoir_list")->count();
        $normal_reservoir=bcsub($allreservoir,$undeal_num);//正常水库
        $normal_reservoir_percentage=bcmul(bcdiv($normal_reservoir,$allreservoir,4),100,2)."%";//正常水库百分比
        $undeal_reservoir_percentage=bcmul(bcdiv($undeal_num,$allreservoir,4),100,2)."%";//超出水库百分比
        $return_data = [
            "warning_limit" => $warning_limit,
            "allreservoir" => $allreservoir,
            "normal_reservoir" => $normal_reservoir,
            "undeal_reservoir_percentage" => $undeal_reservoir_percentage,
            "normal_reservoir_percentage" => $normal_reservoir_percentage,
            "undeal_num" => $undeal_num
        ];

        $this->success("雨情预警数据获取成功", $return_data);
    }

    /**
     * 正在下雨的水库
     */
    public function israin_count(){
        //先查询所有最新降雨数据
        $time = 1;
        $lasttime = strtotime(date('Y-m-d 23:59:59')) - $time*60*60*24;
        $cond['createtime'] = ['between',[$lasttime,strtotime(date('Y-m-d 23:59:59'))]];
        $reservoir=Db::name("reservoir_list")->count();
        $rain=Db::name("reservoir_rain_rainfall")->where($cond)->group("reservoir_id")->count();
        $warning_rain=Db::name("reservoir_warning_rainfall")->where($cond)->group("reservoir_id")->count();
        $norain=$reservoir-$rain;
        $data=[
            'is_rain'=>$rain,
            'norain'=>$norain,
            'warning_rain'=>$warning_rain
        ];
        $this->success("下雨雨情数据获取成功", $data);
    }

    /**
     * 8、【右中2】雨情动态
     */
    public function warning_rainfall_countbyreservoir_id()
    {
        $reservoir_id = $this->request->param("reservoir_id");

        $warning_limit = 100;//雨量限制100mm
        $return_data = [
            "warning_limit" => $warning_limit,
        ];

        $undeal_num = Db::name("reservoir_warning_rainfall")->where("deal", "1")->whereTime("createtime", "today")->count();
        $allreservoir=Db::name("reservoir_list")->count();
        $normal_reservoir=bcsub($allreservoir,$undeal_num);//正常水库
        $normal_reservoir_percentage=bcmul(bcdiv($normal_reservoir,$allreservoir,4),100,2)."%";//正常水库百分比
        $undeal_reservoir_percentage=bcmul(bcdiv($undeal_num,$allreservoir,4),100,2)."%";//超出水库百分比
        $return_data = [
            "warning_limit" => $warning_limit,
            "allreservoir" => $allreservoir,
            "normal_reservoir" => $normal_reservoir,
            "undeal_reservoir_percentage" => $undeal_reservoir_percentage,
            "normal_reservoir_percentage" => $normal_reservoir_percentage,
            "undeal_num" => $undeal_num
        ];

        $this->success("雨情预警数据获取成功", $return_data);
    }

    /**
     * 9、【右下】库水位警告
     */
    public function warning_waterlevel_count()
    {

        $undeal_num = Db::name("reservoir_warning_waterlevel")
            ->where("deal", "1")
            ->whereTime("createtime", "today")
            ->group("reservoir_id")
            ->count();
        $allundeal=Db::name("reservoir_list")->count();
        $undeal_percentage=bcmul(bcdiv($undeal_num,$allundeal,4),100,2)."%";
        $data['allundeal']=$allundeal;
        $data['undeal_num']=$undeal_num;
        $data['undeal_percentage']=$undeal_percentage;
        $this->success("水位预警数据获取成功", $data);
    }

    /**
     * 11、某水库水位折线图数据
     */
    public function waterlevel_line_chart_data()
    {
        $deviceId = $this->request->param("deviceId","1000007069");
        if (!empty($deviceId)) {
            $where = [];
            $where = [
                "e.deviceId" => $deviceId,
                "e.type" => 1,//硬件类型:1=水位计,2=渗流计,3=渗压计,4=GNSS,5=雨量计,6=位移检测,7=其他
            ];

            $data = Db::name("reservoir_list")->alias("r")
                ->join("reservoir_equipment e", "e.reservoir_id = r.id")
                ->where($where)
                ->field("r.id,e.status,e.deviceId,e.name")
                ->order("e.id desc")
                ->find();
            if (!empty($data)) {
                //最近五天最后一条数据
                $date = [];
                $date_value = [];
                $kurong_value = [];
                for ($i = 4; $i >= 0; $i--) {
                    $beginTime = mktime(00, 00, 00, date('m'), date('d') - $i, date('Y'));
                    $endTime = mktime(23, 59, 59, date("m"), date("d") - $i, date("Y"));
                    array_push($date, date("m-d", $beginTime));
                    $rr = "";
                    $wh = [];
                    $wh["number"] = ["eq", $data['deviceId']];
                    $wh["createtime"] = ["between", [$beginTime, $endTime]];
                    $rr = Db::name("reservoir_rain_water_level")->where($wh)->order("createtime desc")->value("water_level");
                    if(!$rr){
                        $rr=0;
                    }
                    array_push($date_value, $rr);

                    $kr = "";
                    $wher = [];
                    $wher["reservoir_id"] = ["eq", $data['id']];
                    $wher["warterdata"] = ["eq", $rr];
                    $kr = Db::name("warterdata_capacityof")->where($wher)->order("id desc")->value("CapacityOf");
                    if(!$kr){
                        $rr=0;
                    }
                    array_push($kurong_value, $kr);
                }
                $data['time'] = $date;
                $data['warter'][0] = $date_value;
                $data['warter'][1] = $kurong_value;
            }
        }
        $this->success('水位库容折线图成功', $data);

    }


    /**
     * 13、某水库渗流量折线图数据
     */
    public function seepage_line_chart_data()
    {
        $post = $this->request->param();
        $id = $post['rid'];
        if (!empty($id)) {
            $day = input('post . day', 5) - 1;
            $categories = [];
            $series = [];
            $series = Db::name("reservoir_list")->where("id", $id)->field("name")->find();
            //最近五天最新一条数据
            $date = [];
            $date_value = [];
            for ($i = $day; $i >= 0; $i--) {
                $beginTime = mktime(00, 00, 00, date('m'), date('d') - $i, date('Y'));
                $endTime = mktime(23, 59, 59, date("m"), date("d") - $i, date("Y"));
                array_push($date, date("m/d", $beginTime));
                $rr = "";
                $wh = [];
                $wh["reservoir_id"] = ["eq", $id];
                $wh["createtime"] = ["between", [$beginTime, $endTime]];
                $rr = Db::name("reservoir_dam_seepage")->where($wh)->order("createtime desc")->value("value");
                $rr = $rr == null ? 0 : $rr;
                array_push($date_value, $rr);

            }
            $categories = $date;
            $series['data'] = $date_value;
        }
        $this->success('水位折线图成功', ["categories" => $categories, "series" => [$series]]);

    }

    /**
     * 14、某水库位移折线图数据
     */
    public function dam_displacement_line_chart_data()
    {
        $post = $this->request->param();
        $id = $post['rid'];
        $return_data = [];
        if ($id) {
            //有位移检测的水库
            $wh = [];
            $wh["a.id"] = $id;
            $wh["b.type"] = ["=", "6"];//设备类型:1=水位计,2=渗流计,3=渗压计,4=GNSS,5=雨量计,6=位移检测,7=其他
            $equipment = Db::name("reservoir_list")->alias("a")
                ->join("reservoir_equipment b", "b.reservoir_id=a.id")
                ->where($wh)
                ->order("a.id asc,b.id desc")
                ->field("a.id,b.deviceId,b.name")
                ->select();

            //最近7天
            $date = [];
            for ($i = 6; $i >= 0; $i--) {
                $beginTime = mktime(00, 00, 00, date('m'), date('d') - $i, date('Y'));
                $endTime = mktime(23, 59, 59, date("m"), date("d") - $i, date("Y"));
                array_push($date, date("Y-m-d", $beginTime));
            }
            $warter_series = [];
            if (!empty($equipment)) {
                foreach ($equipment as $k => $v) {
                    //最近7天最后一条数据
                    $date_value = [];
                    $kurong_value = [];
                    $zzhou_value = [];
                    for ($i = 6; $i >= 0; $i--) {
                        $beginTime = mktime(00, 00, 00, date('m'), date('d') - $i, date('Y'));
                        $endTime = mktime(23, 59, 59, date("m"), date("d") - $i, date("Y"));
                        $rr = "";
                        $wh = [];
                        $wh["reservoir_id"] = ["eq", $v['id']];
                        $wh["number"] = ["eq", $v['deviceId']];
                        $wh["createtime"] = ["between", [$beginTime, $endTime]];
                        $rr = Db::name("reservoir_dam_displacement")->where($wh)->order("createtime desc")->value("horizontal");
                        array_push($date_value, $rr);

                        $kr = "";
                        $wher = [];
                        $wher["reservoir_id"] = ["eq", $v['id']];
                        $wher["number"] = ["eq", $v['deviceId']];
                        $wher["createtime"] = ["between", [$beginTime, $endTime]];
                        $kr = Db::name("reservoir_dam_displacement")->where($wher)->order("createtime desc")->value("horizontalY");
                        array_push($kurong_value, $kr);

                        $zzhou = "";
                        $wher3 = [];
                        $wher3["reservoir_id"] = ["eq", $v['id']];
                        $wher3["number"] = ["eq", $v['deviceId']];
                        $wher3["createtime"] = ["between", [$beginTime, $endTime]];
                        $zzhou = Db::name("reservoir_dam_displacement")->where($wher3)->order("createtime desc")->value("vertical");
                        array_push($zzhou_value, $zzhou);
                    }
                    $warter_series[$k]['name'] = $v['name'];
                    $warter_series[$k]['x_data'] =$date_value;
                    $warter_series[$k]['y_data'] =$kurong_value;
                    $warter_series[$k]['offset_data'] =$zzhou_value;
                }
                $return_data["data"] = $date;
                $return_data["data_list"] = $warter_series;
            }
        }
        $this->success("位移折线图数据获取成功", $return_data);
    }

//    public function dam_displacement_line_chart_data———old()
//    {
//        $post = $this->request->param();
//        $id = $post['rid'];
//        $return_data = [];
//        if ($id) {
//            //有位移检测的水库
//            $wh = [];
//            $wh["a.id"] = $id;
//            $wh["b.type"] = ["=", "6"];//设备类型:1=水位计,2=渗流计,3=渗压计,4=GNSS,5=雨量计,6=位移检测,7=其他
//            $equipment = Db::name("reservoir_list")->alias("a")
//                ->join("reservoir_equipment b", "b.reservoir_id=a.id")
//                ->where($wh)
//                ->order("a.id asc,b.id desc")
//                ->field("a.id,b.deviceId,b.name")
//                ->select();
//
//            //最近7天
//            $date = [];
//            for ($i = 6; $i >= 0; $i--) {
//                $beginTime = mktime(00, 00, 00, date('m'), date('d') - $i, date('Y'));
//                $endTime = mktime(23, 59, 59, date("m"), date("d") - $i, date("Y"));
//                array_push($date, date("Y-m-d", $beginTime));
//            }
//            $warter_series = [];
//            if (!empty($equipment)) {
//                foreach ($equipment as $k => $v) {
//                    //最近7天最后一条数据
//                    $date_value = [];
//                    $kurong_value = [];
//                    $zzhou_value = [];
//                    for ($i = 6; $i >= 0; $i--) {
//                        $beginTime = mktime(00, 00, 00, date('m'), date('d') - $i, date('Y'));
//                        $endTime = mktime(23, 59, 59, date("m"), date("d") - $i, date("Y"));
//                        $rr = "";
//                        $wh = [];
//                        $wh["reservoir_id"] = ["eq", $v['id']];
//                        $wh["number"] = ["eq", $v['deviceId']];
//                        $wh["createtime"] = ["between", [$beginTime, $endTime]];
//                        $rr = Db::name("reservoir_dam_displacement")->where($wh)->order("createtime desc")->value("horizontal");
//                        array_push($date_value, $rr);
//
//                        $kr = "";
//                        $wher = [];
//                        $wher["reservoir_id"] = ["eq", $v['id']];
//                        $wher["number"] = ["eq", $v['deviceId']];
//                        $wher["createtime"] = ["between", [$beginTime, $endTime]];
//                        $kr = Db::name("reservoir_dam_displacement")->where($wher)->order("createtime desc")->value("horizontalY");
//                        array_push($kurong_value, $kr);
//
//                        $zzhou = "";
//                        $wher3 = [];
//                        $wher3["reservoir_id"] = ["eq", $v['id']];
//                        $wher3["number"] = ["eq", $v['deviceId']];
//                        $wher3["createtime"] = ["between", [$beginTime, $endTime]];
//                        $zzhou = Db::name("reservoir_dam_displacement")->where($wher3)->order("createtime desc")->value("vertical");
//                        array_push($zzhou_value, $zzhou);
//                    }
//                    $warter_series[] = [
//                        "itemStyle" => ["color" => 'rgba(49, 227, 128, 1)'],
////                    "areaStyle"=>["color"=>'rgba(0, 0, 0, .05)'],
//                        'type' => "line",
//                        "smooth" => true,
//                        "symbol" => 'none',
//                        'yAxisIndex' => 0,
//                        "name" => $v['name'],
//                        'data' => $date_value,
//                    ];
//                    $warter_series[] = [
//                        "itemStyle" => ["color" => 'rgba(90, 163, 237, 1)'],
////                    "areaStyle"=>["color"=>'rgba(0, 0, 0, .05)'],
//                        'type' => "line",
//                        "smooth" => true,
//                        "symbol" => 'none',
//                        'yAxisIndex' => 1,
//                        "name" => $v['name'],
//                        'data' => $kurong_value,
//                    ];
//                    $warter_series[] = [
//                        "itemStyle" => ["color" => 'rgba(122, 123, 123, 1)'],
////                    "areaStyle"=>["color"=>'rgba(0, 0, 0, .05)'],
//                        'type' => "line",
//                        "smooth" => true,
//                        "symbol" => 'none',
//                        'yAxisIndex' => 2,
//                        "name" => $v['name'],
//                        'data' => $zzhou_value,
//                    ];
//                }
//                $return_data["equipment"] = array_column($equipment, "name");
//                $return_data["data"] = $date;
//                $return_data["warter_series"] = $warter_series;
//            }
//        }
//        $this->success("位移折线图数据获取成功", $return_data);
//    }

    /**
     * 15、某水库渗压折线图数据
     */
    public function dam_isotonic_line_chart_data()
    {
        $post = $this->request->param();
        $id = $post['rid'];
        $return_data = [];
        if ($id) {

            //有渗压计的水库
            $wh = [];
            $wh["a.id"] = ["=",$id];
            $wh["b.type"] = ["=", "3"];//设备类型:1=水位计,2=渗流计,3=渗压计,4=GNSS,5=雨量计,6=位移检测,7=其他
            $equipment = Db::name("reservoir_list")->alias("a")
                ->join("reservoir_equipment b", "b.reservoir_id=a.id")
                ->where($wh)
                ->order("a.id asc,b.id desc")
                ->field("a.id,b.deviceId,b.name")
                ->select();
            //最近7天
            $date = [];
            for ($i = 6; $i >= 0; $i--) {
                $beginTime = mktime(00, 00, 00, date('m'), date('d') - $i, date('Y'));
                $endTime = mktime(23, 59, 59, date("m"), date("d") - $i, date("Y"));
                array_push($date, date("Y-m-d", $beginTime));
            }
            $warter_series = [];
            if (!empty($equipment)) {
                foreach ($equipment as $k => $v) {
                    //最近7天最后一条数据
                    $date_value = [];
                    $kurong_value = [];
                    for ($i = 6; $i >= 0; $i--) {
                        $beginTime = mktime(00, 00, 00, date('m'), date('d') - $i, date('Y'));
                        $endTime = mktime(23, 59, 59, date("m"), date("d") - $i, date("Y"));

                        $kr = "";
                        $wher = [];
                        $wher["reservoir_id"] = ["eq", $v['id']];
                        $wher["equipment_id"] = ["eq", $v['deviceId']];
                        $wher["createtime"] = ["between", [$beginTime, $endTime]];
                        $kr = Db::name("reservoir_dam_isotonic")->where($wher)->order("createtime desc")->value("dx_value");
                        array_push($kurong_value, $kr);
                    }

                    $warter_series[$k]['name'] =$v['name'];
                    $warter_series[$k]['x_data'] =$kurong_value;
                }
            }

            $return_data["data"] = $date;
            $return_data["data_list"] = $warter_series;
        }

        $this->success("渗压折线图数据获取成功", $return_data);
    }
//    public function dam_isotonic_line_chart_data——old()
//    {
//        $post = $this->request->param();
//        $id = $post['rid'];
//        $return_data = [];
//        if ($id) {
//
//            //有渗压计的水库
//            $wh = [];
//            $wh["a.id"] = ["=",$id];
//            $wh["b.type"] = ["=", "3"];//设备类型:1=水位计,2=渗流计,3=渗压计,4=GNSS,5=雨量计,6=位移检测,7=其他
//            $equipment = Db::name("reservoir_list")->alias("a")
//                ->join("reservoir_equipment b", "b.reservoir_id=a.id")
//                ->where($wh)
//                ->order("a.id asc,b.id desc")
//                ->field("a.id,b.deviceId,b.name")
//                ->select();
//            //最近7天
//            $date = [];
//            for ($i = 6; $i >= 0; $i--) {
//                $beginTime = mktime(00, 00, 00, date('m'), date('d') - $i, date('Y'));
//                $endTime = mktime(23, 59, 59, date("m"), date("d") - $i, date("Y"));
//                array_push($date, date("Y-m-d", $beginTime));
//            }
//            $warter_series = [];
//            if (!empty($equipment)) {
//                foreach ($equipment as $k => $v) {
//                    //最近7天最后一条数据
//                    $date_value = [];
//                    $kurong_value = [];
//                    for ($i = 6; $i >= 0; $i--) {
//                        $beginTime = mktime(00, 00, 00, date('m'), date('d') - $i, date('Y'));
//                        $endTime = mktime(23, 59, 59, date("m"), date("d") - $i, date("Y"));
//                        $rr = "";
//                        $wh = [];
//                        $wh["reservoir_id"] = ["eq", $v['id']];
//                        $wh["equipment_id"] = ["eq", $v['deviceId']];
//                        $wh["createtime"] = ["between", [$beginTime, $endTime]];
//                        $rr = Db::name("reservoir_dam_isotonic")->where($wh)->order("createtime desc")->value("value");
//                        array_push($date_value, $rr);
//
//                        $kr = "";
//                        $wher = [];
//                        $wher["reservoir_id"] = ["eq", $v['id']];
//                        $wher["equipment_id"] = ["eq", $v['deviceId']];
//                        $wher["createtime"] = ["between", [$beginTime, $endTime]];
//                        $kr = Db::name("reservoir_dam_isotonic")->where($wher)->order("createtime desc")->value("dx_value");
//                        array_push($kurong_value, $kr);
//                    }
//                    $warter_series[] = [
//                        "itemStyle" => ["color" => 'rgba(49, 227, 128, 1)'],
//                        "areaStyle" => ["color" => 'rgba(0, 0, 0, .05)'],
//                        'type' => "line",
//                        "smooth" => true,
//                        "symbol" => 'none',
//                        'yAxisIndex' => 0,
//                        "name" => $v['name'],
//                        'data' => $date_value,
//                    ];
//                    $warter_series[] = [
//                        "itemStyle" => ["color" => 'rgba(90, 163, 237, 1)'],
//                        "areaStyle" => ["color" => 'rgba(0, 0, 0, .05)'],
//                        'type' => "line",
//                        "smooth" => true,
//                        "symbol" => 'none',
//                        'yAxisIndex' => 1,
//                        "name" => $v['name'],
//                        'data' => $kurong_value,
//                    ];
//                }
//            }
//
//            $return_data["equipment"] = array_column($equipment, "name");
//            $return_data["data"] = $date;
//            $return_data["warter_series"] = $warter_series;
//        }
//
//        $this->success("渗压折线图数据获取成功", $return_data);
//    }


public function getwater_data(){
        $id=$this->request->param('rid');
    $skdata = Db::name('reservoir_list')->where('id', $id)->select();
    $skarr = [];
    $sy_equip_list = [];//渗压设备数据列表
    $wy_equip_list = [];//位移设备数据列表
    if (!empty($skdata)) {
        $revinfo = $skdata[0];
        $sk = $skdata[0];
        $where = [];
        $where["reservoir_id"] = $sk['id'];
        $where["type"] = ["IN", [1, 3, 5, 6]];//硬件类型:1=水位计,2=渗流计,3=渗压计,4=GNSS,5=雨量计,6=位移检测,7=其他
        //水库硬件设备
        $data = Db::name("reservoir_equipment")->where($where)->field("deviceId,name as equip_name,type")->order("type asc")->select();
        //当前水位

        $leval = Db::name('reservoir_rain_water_level')
            ->where(['reservoir_id' => $id])
            ->order('id', 'desc')
            ->find();
        $skarr['water_level'] = $leval['water_level'];
        //垂直，水平位移
        //水位剖面图
        $cross = [];
        $cross['warning_water_level'] = getWarterdataMaxWaterLevel($id);
        $cross['normal_water_level'] = $revinfo['normal_water_level'];
        $cross['water_level'] = $leval['water_level'];
        $cross['dead_water_level'] = $revinfo['dead_water_level'];
        $cross['max_capacityof'] = $skdata[0]['under'];
        $cross['now_capacityof'] = getWarterdataCapacityof($id, $leval['water_level']);
        $cross['dead_capacityof'] = getWarterdataCapacityof($id, $revinfo['dead_water_level']);
    }

    $this->success('水位图数据获取成功', $cross);
}
}