<?php
/***
 * 千寻数据采集
 */

namespace app\api\controller\reservoir;

use app\common\controller\Api;
use app\common\helper\HttpHelper;
use think\Request;
use think\Db;
use qx\Qx;
use addons\alisms\controller\Index;

/**
 * Class Equipment
 * @package app\api\controller\reservoir
 */
class Hardwareapi extends Api
{
    protected $model = '';
    protected $noNeedLogin = ['*'];
    protected $noNeedRight = '*';



    /**
     * 获取渗压信息
     * @return void
     */
    public function getosmotic(){
        $equipment_id= $this->request->param('equipment_id',"");
        $res=Db::name("reservoir_dam_isotonic")
            ->where('equipment_id',$equipment_id)
            ->limit(20)
            ->select();
        foreach ($res as $k=>$v){
            $res[$k]['createtime']=date("Y-m-d H:i:s",$res[$k]['createtime']);
        }
        $this->success("获取渗压信息成功", $res);
    }

    /**
     * 获取最新一条渗压信息
     * @return void
     */
    public function getoneosmotic(){
        $equipment_id= $this->request->param('equipment_id',"");
        $res=Db::name("reservoir_dam_isotonic")
            ->where('equipment_id',$equipment_id)
            ->order("id desc")
            ->find();
        $res['createtime']=date("Y-m-d H:i:s",$res['createtime']);
        $this->success("获取渗压信息成功", $res);
    }

    /**
     * 获取最新一条渗压信息
     * @return void
     */
    public function getoneosmotictest(){
        $res=Db::name("reservoir_dam_isotonic")
            ->order("id desc")
            ->find();
        $res['createtime']=date("Y-m-d H:i:s",$res['createtime']);
        $this->success("获取渗压信息成功", $res);
    }

    /**
     * 获取渗流信息
     * @return void
     */
    public function select_transfusion(){
        $equipment_id= $this->request->param('equipment_id',"");
        $res=Db::name("reservoir_dam_seepage")
            ->where('equipment_id',$equipment_id)
            ->order("id desc")
            ->find();
        if ($res){
            $res['createtime']=date("Y-m-d H:i:s",$res['createtime']);
        }
        $this->success("获取渗流信息成功", $res);
    }

    /**
     * 获取最新一条渗流信息
     * @return void
     */
    public function select_onetransfusion(){
        $equipment_id= $this->request->param('equipment_id',"");
        $res=Db::name("reservoir_dam_seepage")
            ->where('equipment_id',$equipment_id)
            ->order("id desc")
            ->find();
        $res['createtime']=date("Y-m-d H:i:s",$res['createtime']);
        $this->success("获取渗流信息成功", $res);
    }

    /**
     * 获取最新一条渗流信息
     * @return void
     */
    public function get_onetransfusiontest(){
        $equipment_id= $this->request->param('equipment_id',"");
        $res=Db::name("reservoir_dam_seepage")
            ->order("id desc")
            ->find();
        $res['createtime']=date("Y-m-d H:i:s",$res['createtime']);
        $this->success("获取渗流信息成功", $res);
    }

    /**
     * 获取位移信息
     * @return void
     */
    public function select_dam_displacement(){
        $equipment_id= $this->request->param('equipment_id',"");
        $res=Db::name("reservoir_dam_displacement")
            ->where('number',$equipment_id)
            ->limit(20)
            ->select();
        foreach ($res as $k=>$v){
            $res[$k]['createtime']=date("Y-m-d H:i:s",$res[$k]['createtime']);
        }
        $this->success("获取位移信息成功", $res);
    }

    /**
     * 获取最新一条位移信息
     * @return void
     */
    public function select_one_dam_displacement(){
        $equipment_id= $this->request->param('equipment_id',"");
        $res=Db::name("reservoir_dam_displacement")
            ->where('number',$equipment_id)
            ->order("id desc")
            ->find();
        $res['createtime']=date("Y-m-d H:i:s",$res['createtime']);
        $this->success("获取位移信息成功", $res);
    }
    /**
     * 获取最新一条位移信息
     * @return void
     */
    public function get_one_dam_displacementtest(){
        $equipment_id= $this->request->param('equipment_id',"");
        $res=Db::name("reservoir_dam_displacement")
            ->order("id desc")
            ->find();
        $res['createtime']=date("Y-m-d H:i:s",$res['createtime']);
        $this->success("获取位移信息成功", $res);
    }
    /**
     * 获取渗压列表信息
     * @return void
     */
    public function isotonic_pressure_list()
    {
        $isotonic = Db::name("reservoir_dam_isotonic")
            ->alias("a")
            ->join("reservoir_equipment b", 'a.equipment_id=b.deviceId')
            ->order('a.id desc')
            ->field("a.*,b.orifice_elevation")
            ->limit(50)
            ->select();
        foreach ($isotonic as $k => $v) {
            $isotonic[$k]['createtime'] = date("m-d H:i", $isotonic[$k]['createtime']);
        }
        $this->success("获取渗压列表成功", $isotonic);
    }

    /**
     * 获取流量列表信息
     * @return void
     */
    public function river_flow_list()
    {
        $isotonic = Db::name("reservoir_rain_river_flow")
            ->alias("a")
            ->join("reservoir_equipment b", 'a.number=b.deviceId')
            ->order('a.id desc')
            ->field("a.*,b.orifice_elevation")
            ->limit(50)
            ->select();
        foreach ($isotonic as $k => $v) {
            $isotonic[$k]['createtime'] = date("m-d H:i", $isotonic[$k]['createtime']);
        }
        $this->success("获取流量列表成功", $isotonic);
    }
    /**
     * 获取gnss信息
     * @return void
     */
    public function displacement_list()
    {
        $isotonic = Db::name("reservoir_dam_displacement")
            ->order('id desc')
            ->limit(50)
            ->field("id,number,horizontal,horizontalY,vertical,createtime")
            ->select();
        foreach ($isotonic as $k => $v) {
            $isotonic[$k]['createtime'] = date("Y-m-d H:i:s", $isotonic[$k]['createtime']);
            $isotonic[$k]['detection'] = "在线";
            $isotonic[$k]['warning_detection'] = "正常";
        }
        $this->success("获取gnss成功", $isotonic);
    }
    /**
     * 通过设备id查询水位
     * @return void
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function getonewaterlevelbyequipment_id()
    {
        $equipment_id = $this->request->param('equipment_id', "80235820");
        $res = Db::name("reservoir_rain_water_level")
            ->where("number", $equipment_id)
            ->order("id desc")
            ->find();
        $res["water_level"]=$res["water_level"]."(m)";
        $res["flow"]=$res["flow"]."(L/S)";
        $res['createtime'] = date("Y-m-d H:i:s", $res['createtime']);
        $this->success("获取水位成功", $res);
    }

    /**
     * 通过设备id查询水位水位
     * @return void
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function getonewaterleveltest()
    {
        $equipment_id = $this->request->param('equipment_id', "80235820");
        $res = Db::name("reservoir_rain_water_level")
            ->order("id desc")
            ->find();
        $res["water_level"]=$res["water_level"]."(m)";
        $res["flow"]=$res["flow"]."(L/S)";
        $res['createtime'] = date("Y-m-d H:i:s", $res['createtime']);
        $this->success("获取水位成功", $res);
    }
    /**
     * 通过设备id查询降雨
     * @return void
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function getonerainfallbyequipment_id()
    {
        $equipment_id = $this->request->param('equipment_id', "80235820");
        $res = Db::name("reservoir_rain_rainfall")
            ->where("number", $equipment_id)
            ->order("id desc")
            ->find();
        $res["rainfall"]=$res["rainfall"]."(mm)";
        $res['createtime'] = date("Y-m-d H:i:s", $res['createtime']);
        $this->success("获取水位成功", $res);
    }


    /**
     * 通过设备id查询降雨
     * @return void
     * @throws \think\db\exception\DataNotFoundException
     * @throws \think\db\exception\ModelNotFoundException
     * @throws \think\exception\DbException
     */
    public function getonerainfall()
    {
        $equipment_id = $this->request->param('equipment_id', "80235820");
        $res = Db::name("reservoir_rain_rainfall")
            ->order("id desc")
            ->find();
        $res["rainfall"]=$res["rainfall"]."(mm)";
        $res['createtime'] = date("Y-m-d H:i:s", $res['createtime']);
        $this->success("获取水位成功", $res);
    }
    /**
     * 获取某个时间段内的水质信息
     * @return void
     */
    public function getwaterquality()
    {
        $data=[ "time"=> [
        "2023-10-16 16:22:34",
        "2023-10-16 16:22:53",
        "2023-10-16 16:22:54",
        "2023-10-16 16:23:10",
        "2023-10-16 16:23:10",
        "2023-10-16 16:23:10",
        "2023-10-16 16:23:10",
        "2023-10-16 16:23:10",
        "2023-10-17 10:03:09",
        "2023-10-17 10:08:16",
        "2023-10-17 12:00:01"
    ],
        "ammoniaNitrogen"=> [
        "0.082",
        "0.082",
        "0.082",
        "0.082",
        "0.082",
        "0.082",
        "0.082",
        "0.082",
        "0.082",
        "0.082",
        "0.082"
    ],
        "blueGreenAlgae"=> [
        "2566",
        "2566",
        "2566",
        "2958",
        "2981",
        "3134",
        "2559",
        "2566",
        "2622",
        "2622",
        "2622"
    ],
        "chlorophyllA"=> [
        "8.8300",
        "8.8300",
        "8.8300",
        "8.8300",
        "8.8300",
        "8.8300",
        "8.8300",
        "8.8300",
        "8.8300",
        "8.8300",
        "8.8300"
    ],
        "conductivity"=> [
        "386",
        "386",
        "386",
        "384",
        "384",
        "385",
        "385",
        "386",
        "386",
        "386",
        "386"
    ],
        "dissolvedOxygen"=> [
        "4.00",
        "4.00",
        "4.00",
        "4.15",
        "4.17",
        "3.84",
        "3.68",
        "4.00",
        "4.15",
        "4.15",
        "4.15"
    ],
        "nitrogen"=> [
        "1.155",
        "1.155",
        "1.155",
        "1.155",
        "1.155",
        "1.155",
        "1.155",
        "1.155",
        "1.155",
        "1.155",
        "1.155"
    ],
        "permanganate"=> [
        "1.728",
        "1.728",
        "1.728",
        "1.728",
        "1.728",
        "1.728",
        "1.728",
        "1.728",
        "1.728",
        "1.728",
        "1.728"
    ]];
        $this->success("获取水质图成功", $data);

    }
    /**
     * 获取某个时间段内的水位信息
     * @return void
     */
    public function getonewaterlevel()
    {
        $res = Db::name("reservoir_rain_water_level")
            ->order("id desc")
            ->find();
        if($res){
            $res['createtime']=date("Y-m-d H:i:s",$res['createtime']);
            $res['capacity']=getWarterdataCapacityof("40",$res['water_level']);
        }
        $this->success("获取水位成功", $res);
    }

    /**
     * 获取某个时间段内的水位信息
     * @return void
     */
    public function getrain_rainfall()
    {
        $beginTime = $this->request->param('beginTime', "1697013684");
        $endTime = $this->request->param('endTime', "1697445684");
        $endTime=time();
        $beginTime=$endTime-691200;
        $res = Db::name("reservoir_rain_rainfall")
            ->field('total_rainfall,DATE_FORMAT(FROM_UNIXTIME(createtime), "%Y/%m/%d") as createtimes')
            ->where("createtime",">",$beginTime)
            ->where("createtime","<",$endTime)
            ->group("createtimes")
            ->select();
        $data = [];

        foreach ($res as $k => $v) {
            $data['time'][$k] = $res[$k]['createtimes'];
            $data['total_rainfall'][$k] = $res[$k]['total_rainfall'];
        }
        $this->success("获取降雨图成功", $data);

    }
}