<?php

namespace app\api\controller\reservoir;

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

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

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

    public function _initialize()
    {
        parent::_initialize();
    }

    /**
     * 2、【左顶1-2】水库列表
     */
    public function reservoir_list()
    {
        $field = "id,name";
        $data = Db::name("reservoir_list")->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,
        ];
        $this->success('当天巡检动态数据获取成功', $return_data);
    }

    /**
     * 7、【右中1】入侵动态
     */
    public function alarm_monitoring_count()
    {
        $type_list = [
            "小（1）型水库",
            "小（2）型水库",
            "中型水库"
        ];

        $return_data = [];

        $reservoir_ids_0 = Db::name("reservoir_list")->where("reservoir_level", $type_list[0])->column("id");
        $reservoir_ids_1 = Db::name("reservoir_list")->where("reservoir_level", $type_list[1])->column("id");
        $reservoir_ids_2 = Db::name("reservoir_list")->where("reservoir_level", $type_list[2])->column("id");

        $where = [];
        $where["status"] = ["=", "0"];//待处理
        $return_data['total'] = Db::name("reservoir_hkws_alarm_monitoring")->where("status", "0")->count();

        if (!empty($reservoir_ids_0)) {
            $where = [];
            $where["status"] = ["=", "0"];//待处理
            $where["reservoir_list_id"] = ["in", $reservoir_ids_0];
            $return_data['small_1'] = Db::name("reservoir_hkws_alarm_monitoring")->where($where)->count();
        } else {
            $return_data['small_1'] = 0;
        }

        if (!empty($reservoir_ids_1)) {
            $where = [];
            $where["status"] = ["=", "0"];//待处理
            $where["reservoir_list_id"] = ["in", $reservoir_ids_1];
            $return_data['small_2'] = Db::name("reservoir_hkws_alarm_monitoring")->where($where)->count();
        } else {
            $return_data['small_2'] = 0;
        }

        if (!empty($reservoir_ids_2)) {
            $where = [];
            $where["status"] = ["=", "0"];//待处理
            $where["reservoir_list_id"] = ["in", $reservoir_ids_2];
            $return_data['medium'] = Db::name("reservoir_hkws_alarm_monitoring")->where($where)->count();
        } else {
            $return_data['medium'] = 0;
        }

        $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();
        $return_data = [
            "warning_limit" => $warning_limit,
            "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();

        $this->success("水位预警数据获取成功", $undeal_num);
    }

    /**
     * 11、某水库水位折线图数据
     */
    public function waterlevel_line_chart_data()
    {
        $post = $this->request->param();
        $id = $post['rid'];
        if (!empty($id)) {
            $where = [];
            $where = [
                "r.id" => $id,
                "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("Y-m-d", $beginTime));
                    $rr = "";
                    $wh = [];
                    $wh["reservoir_id"] = ["eq", $id];
                    $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");
                    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");
                    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);
//    }

}