<?php

namespace addons\jiangxingapi\controller;

use app\common\controller\Api;
use think\addons\Controller;
use think\Db;
use think\exception\ErrorException;

class Jiangxingapi extends Api
{
    protected $noNeedLogin = ['*'];
    protected $noNeedRight = ['*'];
    protected $water_levelsql = "reservoir_rain_water_level";//水位sql
    protected $rain_rainfallsql = "reservoir_rain_rainfall";//雨量sql
    protected $dam_seepagesql = "reservoir_dam_seepage";//渗流sql
    protected $dam_isotonicsql = "reservoir_dam_isotonic";//渗压sql
    protected $dam_displacementsql = "reservoir_dam_displacement";//坝体位移sql
    protected $reservoir_rain_flowsql = "reservoir_rain_flow";//流量sql

    public function _initialize()
    {
        parent::_initialize();
        $token = $this->request->param();
        $token = request()->header("token");//获取token
        //判断token是否有效
        $where=[];
        $where["token"] = ["eq", $token];
        $where["expiretime"] = ["egt", time()];
        $res=Db::name("jxapi_jxtoken")->where($where)->find();
        if(empty($res)){
            $this->error("token错误或失效","","430001");
        }
    }

    /**
     * 添加水位信息
     * @return void
     */
    public function water_level(){
        $number=$this->request->param("number");//设备编号
        $water_level=$this->request->param("water_level");//水位
        $reporttime=$this->request->param("reporttime");//检测时间 1704780600000
        $createtime=time();//创建时间
        try {
            //查询设备信息
            $equipment=Db::name("reservoir_equipment")->where('type',1)->where("deviceId",$number)->find();
            if(empty($equipment)){
                $this->error("设备编号错误");
            }
            //重组数组
            $data=[
                "number"=>$number,
                "water_level"=>$water_level,
                "reporttime"=>$reporttime,
                "createtime"=>$createtime,
                "reservoir_id"=>$equipment['reservoir_id'],
                "updatetime"=>$createtime,
            ];
            $res=Db::name($this->water_levelsql)->insert($data);
            $this->success("水位信息插入成功");
        }catch (ErrorException $exception ){
            //写入记录失败表
            $fail_data=json_encode($data);
            $fail_data=[
                "createtime"=>$createtime,
                "fail_data"=>$fail_data,
                "number"=>$number,
            ];
            $res=Db::name("jxapi_fail_log")->insert($fail_data);
            $this->error("水位信息插入失败");
        }
    }

    /**
     * 批量添加水位信息
     * @return void
     */
    public function batch_water_level(){
        $param=$this->request->param();//设备编号
        $water_level_data=$param['water_data'];
        if(empty($water_level_data)){
            $this->error("水位信息不能为空");
        }
        $createtime=time();//创建时间
        try {
            foreach ($water_level_data as $k=>$v){
                $equipment=Db::name("reservoir_equipment")->where('type',1)->where("deviceId",$v['number'])->find();
                if(empty($equipment)){
                    $this->error($v['number'].":水位设备编号错误");
                    continue;
                }
                $data[$k]=[
                    "number"=>$v['number'],
                    "water_level"=>$v['water_level'],
                    "reporttime"=>$v['reporttime']*1000,
                    "createtime"=>$v['reporttime'],
                    "reservoir_id"=>$equipment['reservoir_id'],
                    "updatetime"=>$createtime,
                ];
            }

            $res=Db::name($this->water_levelsql)->insertAll($data);
            $this->success("水位信息插入成功");
        }catch (ErrorException $exception ){
            //写入记录失败表
            $fail_data=json_encode($data);
            $fail_data=[
                "createtime"=>$createtime,
                "fail_data"=>$fail_data,
            ];
            $res=Db::name("jxapi_fail_log")->insert($fail_data);
            $this->error("水位信息插入失败");
        }
    }

    /**
     *添加降雨信息
     * @return void
     */
    public function rainfall(){
        $number=$this->request->param("number");//设备编号
        $rainfall=$this->request->param("rainfall");//实时降雨量
        $total_rainfall=$this->request->param("total_rainfall");//当日总降雨量
        $reporttime=$this->request->param("reporttime");//检测时间 1704780600000
        $createtime=time();//创建时间
        try {
            $equipment=Db::name("reservoir_equipment")->where('type',5)->where("deviceId",$number)->find();
            if(empty($equipment)){
                $this->error("设备编号错误");
            }
            //重组数组
            $data=[
                "number"=>$number,
                "rainfall"=>$rainfall,
                "total_rainfall"=>$total_rainfall,
                "reporttime"=>$reporttime,
                "createtime"=>$createtime,
                "reservoir_id"=>$equipment['reservoir_id'],
                "updatetime"=>$createtime,
            ];
            $res=Db::name($this->rain_rainfallsql)->insert($data);
            $this->success("降雨信息插入成功");
        }catch (ErrorException $exception){
            //写入记录失败表
            $fail_data=json_encode($data);
            $fail_data=[
                "createtime"=>$createtime,
                "fail_data"=>$fail_data,
                "number"=>$number,
            ];
            $res=Db::name("jxapi_fail_log")->insert($fail_data);
            $this->error("降雨信息插入失败");
        }
    }

    /**
     * 批量添加降雨信息
     * @return void
     */
    public function batch_rainfall(){
        $param=$this->request->param();//设备编号
        $rainfall_data=$param['rainfall_data'];
        if(empty($rainfall_data)){
            $this->error("降雨信息不能为空");
        }
        $createtime=time();//创建时间
        try {
            foreach ($rainfall_data as $k=>$v){
                $equipment=Db::name("reservoir_equipment")->where('type',5)->where("deviceId",$v['number'])->find();
                if(empty($equipment)){
                    $this->error($v['number'].":降雨设备编号错误");
                    continue;
                }
                $data[$k]=[
                    "number"=>$v['number'],
                    "rainfall"=>$v['rainfall'],
                    "reporttime"=>$v['reporttime']*1000,
                    "total_rainfall"=>$v['total_rainfall'],
                    "createtime"=>$v['reporttime'],
                    "reservoir_id"=>$equipment['reservoir_id'],
                    "updatetime"=>$createtime,
                ];
            }

            $res=Db::name($this->rain_rainfallsql)->insertAll($data);
            $this->success("降雨信息插入成功");
        }catch (ErrorException $exception ){
            //写入记录失败表
            $fail_data=json_encode($data);
            $fail_data=[
                "createtime"=>$createtime,
                "fail_data"=>$fail_data,
            ];
            $res=Db::name("jxapi_fail_log")->insert($fail_data);
            $this->error("降雨信息插入失败");
        }
    }
    /**
     *添加渗流信息
     * @return void
     */
    public function transfusion(){
        $number=$this->request->param("number");//设备编号
        $value=$this->request->param("value");//当日总降雨量
        $reporttime=$this->request->param("reporttime");//检测时间 1704780600000
        $createtime=time();//创建时间
        try {
            $equipment=Db::name("reservoir_equipment")->where('type',2)->where("deviceId",$number)->find();
            if(empty($equipment)){
                $this->error("设备编号错误");
            }
            //重组数组
            $data=[
                "equipment_id"=>$number,
                "value"=>$value,
                "reporttime"=>$reporttime,
                "createtime"=>$createtime,
                "reservoir_id"=>$equipment['reservoir_id'],
                "updatetime"=>$createtime,
            ];
            //$res=Db::name($this->dam_seepagesql)->insert($data);
            $this->success("渗流信息插入成功");
        }catch (ErrorException $exception){
            //写入记录失败表
            $fail_data=json_encode($data);
            $fail_data=[
                "createtime"=>$createtime,
                "fail_data"=>$fail_data,
                "number"=>$number,
            ];
            $res=Db::name("jxapi_fail_log")->insert($fail_data);
            $this->error("渗流信息插入失败");
        }
    }
    /**
     * 批量添加渗流信息
     * @return void
     */
    public function batch_transfusion(){
        $param=$this->request->param();//设备编号
        $transfusion_data=$param['transfusion_data'];
        file_put_contents("transfusion_data.txt",date("Y-m-d H:i:s",time()).json_encode($transfusion_data)."---\r\n",FILE_APPEND);
        if(empty($transfusion_data)){
            $this->error("渗流信息不能为空");
        }
        $createtime=time();//创建时间
        try {
            $returndata='';
            foreach ($transfusion_data as $k=>$v){
                $equipment=Db::name("reservoir_equipment")
                    ->where('type',2)
                    ->where("deviceId",$v['number'])->find();
                //查询设备信息

                if(empty($equipment)){
                    //$this->error($v['number'].":渗流设备编号错误");
                    $returndata=$returndata.$v['number'].":渗流设备编号错误  ";
                    continue;

                }
                $data[$k]=[
                    "equipment_id"=>$v['number'],
                    "value"=>$v['value'],
                    "reporttime"=>time()*1000,
                    "createtime"=>time(),
                    "reservoir_id"=>$equipment['reservoir_id'],
                    "updatetime"=>$createtime,
                ];

            }
            file_put_contents("transfusion_data.txt","data:".json_encode($data)."---\r\n",FILE_APPEND);
            $res=Db::name($this->dam_seepagesql)->insertAll($data);
            $this->success("渗流信息插入成功",$returndata);
        }catch (ErrorException $exception ){
            //写入记录失败表
            $fail_data=json_encode($data);
            $fail_data=[
                "createtime"=>$createtime,
                "fail_data"=>$fail_data,
            ];
            $res=Db::name("jxapi_fail_log")->insert($fail_data);
            $this->error("渗流信息插入失败");
        }
    }
    /**
     *添加渗压信息
     * @return void
     */
    public function osmotic(){
        $number=$this->request->param("number");//设备编号
        $value=$this->request->param("value");//渗压值（单位：kPa）
        $dx_value=$this->request->param("dx_value");//浸润性深度（单位：米）
        $reporttime=$this->request->param("reporttime");//检测时间 1704780600000
        $createtime=time();//创建时间
        try {
            if($value){
                $dx_value=$value/0.98;
            }
            $equipment=Db::name("reservoir_equipment")->where('type',3)->where("deviceId",$number)->find();
            if(empty($equipment)){
                $this->error("设备编号错误");
            }
            //重组数组
            $data=[
                "equipment_id"=>$number,
                "value"=>$value,
                "dx_value"=>$dx_value,
                "reporttime"=>$reporttime,
                "createtime"=>$createtime,
                "reservoir_id"=>$equipment['reservoir_id'],
                "updatetime"=>$createtime,
            ];
            $res=Db::name($this->dam_isotonicsql)->insert($data);
            $this->success("渗压信息插入成功");
        }catch (ErrorException $exception){
            //写入记录失败表
            $fail_data=json_encode($data);
            $fail_data=[
                "createtime"=>$createtime,
                "fail_data"=>$fail_data,
                "number"=>$number,
            ];
            $res=Db::name("jxapi_fail_log")->insert($fail_data);
            $this->error("渗流信息插入失败");
        }
    }
    /**
     * 批量添加渗压信息
     * @return void
     */
    public function batch_osmotic(){
        $param=$this->request->param();//设备编号
        $osmotic_data=$param['osmotic_data'];
        if(empty($osmotic_data)){
            $this->error("渗压信息不能为空");
        }
        $createtime=time();//创建时间
        try {
            foreach ($osmotic_data as $k=>$v){
                $equipment=Db::name("reservoir_equipment")->where('type',3)->where("deviceId",$v['number'])->find();
                //查询设备信息
                if(empty($equipment)){
                    $this->error($v['number'].":渗压设备编号错误");
                    continue;
                }
                if($v['value']){
                $v['dx_value']=$v['value']/0.98;
            }
                $data[$k]=[
                    "equipment_id"=>$v['number'],
                    "value"=>$v['value'],
                    "dx_value"=>$v['dx_value'],
                    "reporttime"=>$v['reporttime']*1000,
                    "createtime"=>$v['reporttime'],
                    "reservoir_id"=>$equipment['reservoir_id'],
                    "updatetime"=>$createtime,
                ];
            }

            $res=Db::name($this->dam_isotonicsql)->insertAll($data);
            $this->success("渗压信息插入成功");
        }catch (ErrorException $exception ){
            //写入记录失败表
            $fail_data=json_encode($data);
            $fail_data=[
                "createtime"=>$createtime,
                "fail_data"=>$fail_data,
            ];
            $res=Db::name("jxapi_fail_log")->insert($fail_data);
            $this->error("渗压信息插入失败");
        }
    }
    /**
     *添加坝体位移信息
     * @return void
     */
    public function displacement(){
        $number=$this->request->param("number");//设备编号
        $vertical=$this->request->param("vertical");//垂直位移
        $horizontal=$this->request->param("horizontal");//水平位移x
        $horizontalY=$this->request->param("horizontalY");//水平位移Y
        $reporttime=$this->request->param("reporttime");//检测时间 1704780600000
        $createtime=time();//创建时间
        try {
            $equipment=Db::name("reservoir_equipment")->where('type',4)->where("deviceId",$number)->find();
            if(empty($equipment)){
                $this->error("设备编号错误");
            }
            //重组数组
            $data=[
                "number"=>$number,
                "vertical"=>$vertical,
                "horizontal"=>$horizontal,
                "horizontalY"=>$horizontalY,
                "reporttime"=>$reporttime,
                "createtime"=>$createtime,
                "reservoir_id"=>$equipment['reservoir_id'],
                "updatetime"=>$createtime,
            ];
            $res=Db::name($this->dam_displacementsql)->insert($data);
            $this->success("坝体位移信息插入成功");
        }catch (ErrorException $exception){
            //写入记录失败表
            $fail_data=json_encode($data);
            $fail_data=[
                "createtime"=>$createtime,
                "fail_data"=>$fail_data,
                "number"=>$number,
            ];
            $res=Db::name("jxapi_fail_log")->insert($fail_data);
            $this->error("渗流信息插入失败");
        }
    }
    /**
     *添加流量信息
     * @return void
     */
    public function flow(){
        $number=$this->request->param("number");//设备编号
        $flow=$this->request->param("flow");//瞬时流量
        $accumulate_flow=$this->request->param("accumulate_flow");//瞬时流量
        $reporttime=$this->request->param("reporttime");//检测时间 1704780600000
        $createtime=time();//创建时间
        try {
            $equipment=Db::name("reservoir_equipment")->where('type',7)->where("deviceId",$number)->find();
            if(empty($equipment)){
                $this->error("设备编号错误");
            }
            //重组数组
            $data=[
                "number"=>$number,
                "accumulate_flow"=>$accumulate_flow,
                "flow"=>$flow,
                "reporttime"=>$reporttime,
                "createtime"=>$createtime,
                "reservoir_id"=>$equipment['reservoir_id'],
                "updatetime"=>$createtime,
            ];
            $res=Db::name($this->reservoir_rain_flowsql)->insert($data);
            $this->success("流量信息插入成功");
        }catch (ErrorException $exception){
            //写入记录失败表
            $fail_data=json_encode($data);
            $fail_data=[
                "createtime"=>$createtime,
                "fail_data"=>$fail_data,
                "number"=>$number,
            ];
            $res=Db::name("jxapi_fail_log")->insert($fail_data);
            $this->error("流量信息插入失败");
        }
    }
    /**
     * 批量添加流量信息
     * @return void
     */
    public function batch_flow(){
        $param=$this->request->param();//设备编号
        $flow_data=$param['flow_data'];

        if(empty($flow_data)){
            $this->error("流量信息不能为空");
        }
        $createtime=time();//创建时间
        try {
            foreach ($flow_data as $k=>$v){
                $equipment=Db::name("reservoir_equipment")->where('type',7)->where("deviceId",$v['number'])->find();
                if(empty($equipment)){
                    $this->error($v['number'].":流量设备编号错误");
                    continue;
                }
                $data[$k]=[
                    "number"=>$v['number'],
                    "accumulate_flow"=>$v['accumulate_flow'],
                    "flow"=>$v['flow'],
                    "reporttime"=>$v['reporttime']*1000,
                    "createtime"=>$v['reporttime'],
                    "reservoir_id"=>$equipment['reservoir_id'],
                    "updatetime"=>$createtime,
                ];
            }

            $res=Db::name($this->reservoir_rain_flowsql)->insertAll($data);
            $this->success("流量信息插入成功");
        }catch (ErrorException $exception ){
            //写入记录失败表
            $fail_data=json_encode($data);
            $fail_data=[
                "createtime"=>$createtime,
                "fail_data"=>$fail_data,
            ];
            $res=Db::name("jxapi_fail_log")->insert($fail_data);
            $this->error("流量信息插入失败");
        }
    }

    /**
     * 批量添加坝体位移信息
     * @return void
     */
    public function batch_displacement(){
        $param=$this->request->param();//设备编号
        $displacement_data=$param['displacement_data'];

        if(empty($displacement_data)){
            $this->error("坝体位移信息不能为空");
        }
        $createtime=time();//创建时间
        try {
            foreach ($displacement_data as $k=>$v){
                $equipment=Db::name("reservoir_equipment")->where('type',4)->where("deviceId",$v['number'])->find();
                if(empty($equipment)){
                    $this->error($v['number'].":坝体位移设备编号错误");
                    continue;
                }
                $data[$k]=[
                    "number"=>$v['number'],
                    "vertical"=>$v['vertical'],
                    "horizontal"=>$v['horizontal'],
                    "horizontalY"=>$v['horizontalY'],
                    "reporttime"=>$v['reporttime']*1000,
                    "createtime"=>$v['reporttime'],
                    "reservoir_id"=>$equipment['reservoir_id'],
                    "updatetime"=>$createtime,
                ];
            }

            $res=Db::name($this->dam_displacementsql)->insertAll($data);
            $this->success("坝体位移信息插入成功");
        }catch (ErrorException $exception ){
            //写入记录失败表
            $fail_data=json_encode($data);
            $fail_data=[
                "createtime"=>$createtime,
                "fail_data"=>$fail_data,
            ];
            $res=Db::name("jxapi_fail_log")->insert($fail_data);
            $this->error("坝体位移信息插入失败");
        }
    }
}