<?php

namespace app\api\controller;

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

/**
 * 千寻、匠星数据采集(删除测试数据、重新拉取老数据)
 * Class KevinTest
 * @package app\api\controller\reservoir
 */
class Testtt extends Api
{
    protected $model = '';
    protected $noNeedLogin = '*';
    protected $noNeedRight = '*';

    //硬件分类编码 1=水位计 L4_NW ；2=渗流计 L3_SL；3=渗压计 L3_SY（L3_DX）；5=雨量计 L3_SL；6=位移检测 L1_GP；
    protected $equipmentCateType = [
        "1" => "L4_NW",
        "2" => "L3_SL",
        "3" => "L3_SY",
        "5" => "L3_SL",
        "6" => "L1_GP"
    ];

    //匠星的部分渗压设备对应 探头高程
    protected $equipmentTantouHeight = [
        "L3_SY_sy015" => 1644.61,//蚂蚱冲水库-1号渗压计
        "L3_SY_sy002" => 1642.75,//蚂蚱冲水库-2号渗压计
        "L3_SY_sy003" => 1634.45,//蚂蚱冲水库-3号渗压计
        "L3_SY_sy004" => 1631.57,//蚂蚱冲水库-4号渗压计
        "L3_SY_sy005" => 1651.2,//蚂蚱冲水库-5号渗压计
        "L3_SY_sy006" => 1643.36,//蚂蚱冲水库-6号渗压计
        "L3_SY_sy007" => 1641.51,//蚂蚱冲水库-7号渗压计
        "L3_SY_sy008" => 1632.93,//蚂蚱冲水库-8号渗压计
        "L3_SY_sy009" => 1652.5,//蚂蚱冲水库-9号渗压计
        "L3_SY_sy010" => 1662.47,//蚂蚱冲水库-10号渗压计
        "L3_SY_sy011" => 1649.69,//蚂蚱冲水库-11号渗压计
        "L3_SY_sy012" => 1664.34,//蚂蚱冲水库-12号渗压计
        "L3_SY_sy013" => 1652.09,//蚂蚱冲水库-13号渗压计
        "L3_SY_sy014" => 1648.15,//蚂蚱冲水库-14号渗压计
        "L3_SY_sy018" => 1566.34,//鲁嘎水库-1号渗压计
        "L3_SY_sy016" => 1578.64,//鲁嘎水库-2号渗压计
        "L3_SY_sy017" => 1577.06,//鲁嘎水库-3号渗压计
    ];

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

    /**
     * 0、水位数据根据各个水位计初始有数据时间进行清除
     * 类型:1=水位计,2=渗流计,3=渗压计,4=GNSS,5=雨量计,6=位移检测,7=其他
     */
    public function reset_water_level()
    {
        //查询所有水位计的初始有数据时间
        $w = [];
        $w["type"] = ["=", "1"];//类型:1=水位计
        $list = Db::name("reservoir_equipment")->where($w)->order("servicetime asc,reservoir_id asc")->field("id,deviceId,reservoir_id,servicetime")->select();
        if (!empty($list)) {
            foreach ($list as $k => $v) {
                $count = 0;
                if ($v['servicetime']) {
                    //设置了初始有数据时间的才删除
                    $ww = [];
//                    $ww["number"] = ["=", $v['deviceId']]; //因为水位计只有一个，所以就直接按对应时间删除，不需要这个编号条件。若多个就需要这个条件了；
                    $ww["reservoir_id"] = ["=", $v['reservoir_id']];
                    $ww["createtime"] = ["egt", strtotime($v['servicetime'])];
                    $count = Db::name("reservoir_rain_water_level")->where($ww)->delete();
                }
                $list[$k]['delete_num'] = $count;
            }
        }
        $this->success("", $list);
    }

    /**
     * 1、（千寻）第一步：把以前水位数据拉一下
     */
    public function step1_water_level()
    {
        $w = [];
        $w["type"] = ["=", "1"];//硬件类型 1=水位计
        $w["company_type"] = ["=", "1"];//设备商 1=千寻，2=匠星
        $field = "deviceId,apiKey,qxDataKey,qxIsoKey,reservoir_id,type,company_type,servicetime";
        $list = Db::name('reservoir_equipment')->where($w)->field($field)->order("reservoir_id asc")->select();
        $data = [];

        foreach ($list as $k => $v) {
            $startTime = "";//开始时间
            $endTime = "";//结束时间
            $servicetime = "";//设备接口有数据时间（每个设备固定值）
            $servicetime = strtotime($v['servicetime']);
            $thirty_day = 24 * 3600 * 30;//千寻有效查询一个月

            //查最新一次设备更新数据时间
            $ww = [];
            $ww["number"] = ["=", $v['deviceId']];
            $ww["reservoir_id"] = ["=", $v['reservoir_id']];
            $last_createtime = Db::name("reservoir_rain_water_level")->where($ww)->order("createtime desc")->value("createtime");

            if ($last_createtime < $servicetime) {
                //数据中时间比接口开始时间都往前，就只能从接口开始有数据时间去采数据；
                $startTime = $servicetime * 1000; //接口开始有数据时间（毫秒）
                $endTime = $startTime + $thirty_day * 1000; //千寻有效三十天（毫秒）
            } elseif (($last_createtime + $thirty_day) <= time()) {
                $startTime = ($last_createtime + 1) * 1000; //数据库中上次接口更新时间（毫秒）
                $endTime = $startTime + $thirty_day * 1000;//千寻有效三十天（毫秒）
            } elseif ($last_createtime < time()) {
                $startTime = ($last_createtime + 1) * 1000; //数据库中上次接口更新时间（毫秒）
                $endTime = time() * 1000;
            }
            if ($startTime && $endTime) {
                $res = $this->qx_api_data($v['deviceId'], $startTime, $endTime);
                if (empty($res)) {
                    continue;
                }
                $info = $res['L4_NW'][$v['qxDataKey']];
                if ($info) {
                    //增加预警记录
                    $this->warning($v['deviceId'], $info);
                    foreach ($info as $k2 => $v2) {
                        $data[] = [
                            'reservoir_id' => $v['reservoir_id'],
                            'water_level' => $v2['value'],
                            'createtime' => $v2['reportTime'] / 1000,
                            'reporttime' => $v2['reportTime'],
                            'number' => $v['deviceId']
                        ];
                    }
                }
            }
        }
        $succ_num = Db::name('reservoir_rain_water_level')->insertAll($data);
        echo $succ_num . "/" . count($data);
    }

    /**
     * 2、（匠星）第一步：把以前水位数据拉一下
     */
    public function step01_water_level()
    {
        $id = $this->request->param('id', 1);
        //$appkey = Request::instance()->header("wxID");
        //print_r($appkey);return;

        $w = [];
        $w["type"] = ["=", "1"];//硬件类型 1=水位计
        $w["company_type"] = ["=", "2"];//设备商 1=千寻，2=匠星
        $field = "deviceId,apiKey,reservoir_id,type,company_type,servicetime";
        $list = Db::name('reservoir_equipment')->where($w)->field($field)->order("reservoir_id asc")->select();
        $data = [];

        foreach ($list as $k => $v) {
            $startTime = "";//开始时间
            $endTime = "";//结束时间
            $servicetime = "";//设备接口有数据时间（每个设备固定值）
            $servicetime = strtotime($v['servicetime']);//某日凌晨时间戳  （$v['servicetime']具体某日）

            //匠星有效查询一天内（开始日期和结束日期要是同一天，而不是24小时内）
            $res = $this->jx_api_data($id, "2023-09-11 17:48:00", "2023-09-11 17:53:45");//匠星查询用的apiKey的值 而不是deviceId的值
            //查最新一次设备更新数据时间
            $ww = [];
            $ww["number"] = ["=", $v['deviceId']];
            $ww["reservoir_id"] = ["=", $v['reservoir_id']];
            $last_createtime = Db::name("reservoir_rain_water_level")->where($ww)->order("createtime desc")->value("createtime");

            if ($last_createtime < $servicetime) {
                //数据中时间比接口开始时间都往前，就只能从接口开始有数据时间去采数据；
                $startTime = $servicetime; //接口开始有数据时间（某日凌晨时间戳）
                $time_arr = time_to_today_end($startTime);
            } else {
                $startTime = $last_createtime + 1;
                $time_arr = time_to_today_end($startTime);
            }

            if ($time_arr) {
                foreach ($time_arr as $k1 => $v1) {
                    if (!empty($v1)) {
                        $s_time = $v1[0];
                        $e_time = $v1[1];
                        
                        if (!empty($res)) {
                            if($v['deviceId']=="L3_YL_wylskyw01"){
                                $info = $res['L3_YL'][$v['deviceId']];
                            }elseif($v['deviceId']=="L3_SY_xbsyw01"){
                                $info = $res['L3_YL'][$v['deviceId']];
                            }else{
                                print_r($res['L4_NW']['L4_NW_lhbyw01']);
                                return;
                                $info = $res['L4_NW'][$v['deviceId']];
                            }
                            print_r($info);return;
                            if ($info) {
                                //增加预警记录
                                $this->warning($v['deviceId'], $info);
                                foreach ($info as $k2 => $v2) {
                                    $data[] = [
                                        'reservoir_id' => $v['reservoir_id'],
                                        'water_level' => $v2['value'],
                                        'createtime' => $v2['reportTime'] / 1000,
                                        'reporttime' => $v2['reportTime'],
                                        'number' => $v['deviceId']
                                    ];
                                }
                            }
                        }
                    }
                }
            }
        }
        $succ_num = Db::name('reservoir_rain_water_level')->insertAll($data);
        echo $succ_num . "/" . count($data);
    }

    /**
     * 3、删除某个水位设备 多余数据（一小时保留最靠近整点那条；>=整点那条）
     * 如：09.00-10.00之间很多条 只保留靠近09.00的
     */
    public function delete_water_level()
    {
        $param = $this->request->param("");
        $w = [];
        $w["deviceId"] = ["=", $param['deviceId']];
        $w["type"] = ["=", "1"];//硬件类型 1=水位计
        $reservoir_id = Db::name('reservoir_equipment')->where($w)->value("reservoir_id");
        if ($reservoir_id) {
            $ww = [];
            $ww["number"] = ["=", $param['deviceId']];
            $ww["reservoir_id"] = ["=", $reservoir_id];
            //最近时间
            $jin_time = Db::name("reservoir_rain_water_level")->where($ww)->order("createtime desc")->value("createtime");
            //最远时间
            $yuan_time = Db::name("reservoir_rain_water_level")->where($ww)->order("createtime asc")->value("createtime");

            if (!empty($jin_time) && !empty($yuan_time)) {
                $jin_time = strtotime(date("Y-m-d H:00:00", $jin_time)) + 3600;//只保留整点
                $yuan_time = strtotime(date("Y-m-d H:00:00", $yuan_time));//只保留整点
                $hour = ($jin_time - $yuan_time) / 3600;//多少个小时
                $end_time = $jin_time;//19:00
                for ($i = 1; $i <= $hour; $i++) {

                    $start_time = $jin_time - 3600 * $i;//18:00
                    $w2 = [];
                    $ids = [];
                    $w2["number"] = ["=", $param['deviceId']];
                    $w2["reservoir_id"] = ["=", $reservoir_id];
                    $ids = Db::name("reservoir_rain_water_level")
                        ->where($w2)
                        ->whereTime('createtime', '>=', $start_time)
                        ->whereTime('createtime', '<', $end_time)
                        ->order("createtime asc")->column("id");
                    if (count($ids) > 1) {
                        array_shift($ids);//剔除掉最合适的数据，其他删除
                        $w3 = [];
                        $w3["id"] = ["in", $ids];
                        Db::name("reservoir_rain_water_level")->where($w3)->delete();
                    }

                    //重置结束时间为上次开始时间
                    $end_time = $start_time;
                }

            }
        }
    }

    /**
     * 4、雨量数据根据各个雨量计初始有数据时间进行清除（记得这步做完后重置自增id+1）
     * 类型:1=水位计,2=渗流计,3=渗压计,4=GNSS,5=雨量计,6=位移检测,7=其他
     */
    public function reset_rain_rainfall()
    {
        //查询所有雨量计的初始有数据时间
        $w = [];
        $w["type"] = ["=", "5"];//类型:5=雨量计
        $list = Db::name("reservoir_equipment")->where($w)->order("servicetime asc,reservoir_id asc")->field("id,deviceId,reservoir_id,servicetime")->select();

        if (!empty($list)) {
            foreach ($list as $k => $v) {
                $count = 0;
                if ($v['servicetime']) {
                    //设置了初始有数据时间的才删除
                    $ww = [];
//                    $ww["number"] = ["=", $v['deviceId']]; //因为雨量计只有一个，所以就直接按对应时间删除，不需要这个编号条件。若多个就需要这个条件了；
                    $ww["reservoir_id"] = ["=", $v['reservoir_id']];
                    $ww["createtime"] = ["egt", strtotime($v['servicetime'])];
                    $count = Db::name("reservoir_rain_rainfall")->where($ww)->delete();
                }
                $list[$k]['delete_num'] = $count;
            }
        }
        $this->success("", $list);
    }


    /**
     * 5、（千寻）第二步：把以前雨量数据拉一下
     */
    public function step2_rain_rainfall()
    {
        $w = [];
        $w["type"] = ["=", "5"];//硬件类型 5=雨量计
        $w["company_type"] = ["=", "1"];//设备商 1=千寻，2=匠星
        $field = "deviceId,apiKey,qxDataKey,qxIsoKey,reservoir_id,type,company_type,servicetime";
        $list = Db::name('reservoir_equipment')->where($w)->field($field)->order("reservoir_id asc")->select();
        $data = [];

        foreach ($list as $k => $v) {
            $startTime = "";//开始时间
            $endTime = "";//结束时间
            $servicetime = "";//设备接口有数据时间（每个设备固定值）
            $servicetime = strtotime($v['servicetime']);
            $thirty_day = 24 * 3600 * 30;//千寻有效查询一个月

            //查最新一次设备更新数据时间
            $ww = [];
            $ww["number"] = ["=", $v['deviceId']];
            $ww["reservoir_id"] = ["=", $v['reservoir_id']];
            $last_createtime = Db::name("reservoir_rain_rainfall")->where($ww)->order("createtime desc")->value("createtime");

            if ($last_createtime < $servicetime) {
                //数据中时间比接口开始时间都往前，就只能从接口开始有数据时间去采数据；
                $startTime = $servicetime * 1000; //接口开始有数据时间（毫秒）
                $endTime = $startTime + $thirty_day * 1000; //千寻有效三十天（毫秒）
            } elseif (($last_createtime + $thirty_day) <= time()) {
                $startTime = ($last_createtime + 1) * 1000; //数据库中上次接口更新时间（毫秒）
                $endTime = $startTime + $thirty_day * 1000;//千寻有效三十天（毫秒）
            } elseif ($last_createtime < time()) {
                $startTime = ($last_createtime + 1) * 1000; //数据库中上次接口更新时间（毫秒）
                $endTime = time() * 1000;
            }
            if ($startTime && $endTime) {
                $res = $this->qx_api_data($v['deviceId'], $startTime, $endTime);
                if (empty($res)) {
                    continue;
                }
                $info = $res['L3_YL'][$v['qxDataKey']];
                if ($info) {
                    //增加预警记录
                    $this->warning($v['deviceId'], $info);
                    foreach ($info as $k2 => $v2) {
                        $data[] = [
                            'reservoir_id' => $v['reservoir_id'],
                            'rainfall' => $v2['value'],
                            'total_rainfall' => $v2['totalValue'],
                            'createtime' => $v2['reportTime'] / 1000,
                            'reporttime' => $v2['reportTime'],
                            'number' => $v['deviceId']
                        ];
                    }
                }
            }
        }
        $succ_num = Db::name('reservoir_rain_rainfall')->insertAll($data);
        echo $succ_num . "/" . count($data);
    }

    /**
     * 6、（匠星）第二步：把以前雨量数据拉一下
     */
    public function step02_rain_rainfall()
    {
        $w = [];
        $w["type"] = ["=", "5"];//硬件类型 5=雨量计
        $w["company_type"] = ["=", "2"];//设备商 1=千寻，2=匠星
        $field = "deviceId,apiKey,reservoir_id,type,company_type,servicetime";
        $list = Db::name('reservoir_equipment')->where($w)->field($field)->order("reservoir_id asc")->select();
        $data = [];

        foreach ($list as $k => $v) {
            $startTime = "";//开始时间
            $endTime = "";//结束时间
            $servicetime = "";//设备接口有数据时间（每个设备固定值）
            $servicetime = strtotime($v['servicetime']);//某日凌晨时间戳  （$v['servicetime']具体某日）

            //匠星有效查询一天内（开始日期和结束日期要是同一天，而不是24小时内）

            //查最新一次设备更新数据时间
            $ww = [];
            $ww["number"] = ["=", $v['deviceId']];
            $ww["reservoir_id"] = ["=", $v['reservoir_id']];
            $last_createtime = Db::name("reservoir_rain_rainfall")->where($ww)->order("createtime desc")->value("createtime");

            if ($last_createtime < $servicetime) {
                //数据中时间比接口开始时间都往前，就只能从接口开始有数据时间去采数据；
                $startTime = $servicetime; //接口开始有数据时间（某日凌晨时间戳）
                $time_arr = time_to_today_end($startTime);
            } else {
                $startTime = $last_createtime + 1;
                $time_arr = time_to_today_end($startTime);
            }

            if ($time_arr) {
                foreach ($time_arr as $k1 => $v1) {
                    if (!empty($v1)) {
                        $s_time = $v1[0];
                        $e_time = $v1[1];
                        $res = $this->jx_api_data($v['apiKey'], $s_time, $e_time);//匠星查询用的apiKey的值 而不是deviceId的值
                        if (!empty($res)) {
                            $info = $res['L3_YL'][$v['deviceId']];
                            if ($info) {
                                //增加预警记录
                                $this->warning($v['deviceId'], $info);
                                foreach ($info as $k2 => $v2) {
                                    $data[] = [
                                        'reservoir_id' => $v['reservoir_id'],
                                        'rainfall' => $v2['value'],
                                        'total_rainfall' => $v2['totalValue'],
                                        'createtime' => $v2['reportTime'] / 1000,
                                        'reporttime' => $v2['reportTime'],
                                        'number' => $v['deviceId']
                                    ];
                                }
                            }
                        }
                    }
                }
            }
        }
        $succ_num = Db::name('reservoir_rain_rainfall')->insertAll($data);
        echo $succ_num . "/" . count($data);
    }

    /**
     * 7、（千寻）老数据的雨量日统计(每日早8点的累积量算昨天的统计)
     *  1000000727、1000000783数据单独先统计（两个老设备的记录！！）
     */
    public function daycount_rain_rainfall_old()
    {
        $succ_num = 0;//成功数
        $origin = [["deviceId" => 1000000727, "reservoir_id" => 4], ["deviceId" => 1000000783, "reservoir_id" => 4]];
        foreach ($origin as $k => $v) {
            $w = [];
            $w["number"] = ["=", $v['deviceId']];
            $w["reservoir_id"] = ["=", $v['reservoir_id']];
            //最近时间
            $jin_time = Db::name('reservoir_rain_rainfall')->where($w)->order('createtime desc')->value("createtime");
            //最远时间
            $yuan_time = Db::name('reservoir_rain_rainfall')->where($w)->order('createtime asc')->value("createtime");
            if (!empty($jin_time) && !empty($yuan_time)) {
                $time_arr = time_to_time_end($yuan_time, $jin_time);
                if (!empty($time_arr)) {
                    foreach ($time_arr as $k1 => $v1) {
                        $s_time = $v1[0];//某天 08:00:00
                        $e_time = $v1[1];//和上面同天 09:00:00
                        $w2 = [];
                        $w2["number"] = ["=", $v['deviceId']];
                        $w2["reservoir_id"] = ["=", $v['reservoir_id']];
                        $w2["daytime"] = ["=", date("Ymd", strtotime($s_time) - 3600 * 24)];//每天早8点统计的都是昨天的数据
                        $dcks = Db::name("reservoir_rainfall_ctday")->where($w2)->count();
                        if ($dcks == 0) {
                            //日期对应当日累计雨量没记录过，找下数据有的话就存一下
                            $w3 = [];
                            $w3["number"] = ["=", $v['deviceId']];
                            $w3["reservoir_id"] = ["=", $v['reservoir_id']];
                            $record = Db::name("reservoir_rain_rainfall")
                                ->where($w3)
                                ->whereTime('createtime', '>=', strtotime($s_time))
                                ->whereTime('createtime', '<', strtotime($e_time))
                                ->order("createtime asc")
                                ->find();
                            if ($record) {
                                $insert_data = [];
                                $insert_data = [
                                    "number" => $record['number'],
                                    "total_rainfall" => $record['total_rainfall'],
                                    "reservoir_id" => $record['reservoir_id'],
                                    "createtime" => time(),
                                    "rrr_id" => $record['id'],
                                    "daytime" => date('Ymd', $record['createtime'] - 3600 * 24)
                                ];
                                $rs = Db::name('reservoir_rainfall_ctday')->insertGetId($insert_data);
                                if ($rs) {
                                    $succ_num = $succ_num + 1;
                                }
                            }

                        }

                    }
                }

            }
        }
        echo $succ_num;

    }

    /**
     *  8、各水库雨量日统计（所有设备）
     * （每天08.30执行）
     * (每日早8点的累积量算昨天的统计)
     */
    public function daycount_rain_rainfall()
    {
        //获得水库列表
        $list = Db::name('reservoir_list')->order('id asc')->select();
        if ($list) {
            //昨天结束时间，就是今天8点
            $endtime = strtotime(date('Y-m-d 08:00:00', time()));
            //昨天开始时间
            $starttime = strtotime("-24 hour", $endtime);
            $yesrday = date('Ymd', $starttime);
            $map["createtime"] = ["between", [$starttime, $endtime]];
            foreach ($list as $k => $v) {
                //计算昨天的总降雨量，时间段内累计的总降雨量最大值就是昨天的总降雨量
                $rainAll = Db::name('reservoir_rain_rainfall')
                    ->where(['reservoir_id' => $v['id']])
                    ->where($map)
                    ->order('total_rainfall desc')
                    ->find();

                if (!empty($rainAll)) {
                    //查询水库当天是否有数据了
                    $cks = Db::name('reservoir_rainfall_ctday')
                        ->where(['reservoir_id' => $v['id'], 'daytime' => $yesrday])
                        ->find();
                    if (!empty($cks)) {
                        //更新
                        $insert_data = [
                            "number" => $rainAll['number'],
                            "total_rainfall" => $rainAll['total_rainfall'],
                            "createtime" => time(),
                            "rrr_id" => $rainAll['id'],
                        ];
                        $rs = Db::name('reservoir_rainfall_ctday')
                            ->where(['reservoir_id' => $v['id'], 'daytime' => $yesrday])
                            ->update($insert_data);
                    } else {
                        //添加
                        $insert_data = [
                            "number" => $rainAll['number'],
                            "total_rainfall" => $rainAll['total_rainfall'],
                            "reservoir_id" => $v['id'],
                            "createtime" => time(),
                            "rrr_id" => $rainAll['id'],
                            "daytime" => $yesrday
                        ];
                        $rs = Db::name('reservoir_rainfall_ctday')->insertGetId($insert_data);
                    }
                }
            }
        }

        $this->success('执行成功', $rs);
    }

    /**
     *  8、各水库雨量日统计（所有设备）
     * （每天08.30执行）
     * (每日早8点的累积量算昨天的统计)
     */
    public function daycount_rain_rainfall_2222()
    {
        $succ_num = 0;//成功数
        $w = [];
        $w["type"] = ["=", "5"];//硬件类型 5=雨量计
        $field = "deviceId,reservoir_id";
        $origin = Db::name('reservoir_equipment')->where($w)->field($field)->order("reservoir_id asc")->select();
        foreach ($origin as $k => $v) {
            $w = [];
            $w["number"] = ["=", $v['deviceId']];
            $w["reservoir_id"] = ["=", $v['reservoir_id']];
            //最近时间
            $jin_time = Db::name('reservoir_rain_rainfall')->where($w)->order('createtime desc')->value("createtime");
            //最远时间
            $yuan_time = Db::name('reservoir_rain_rainfall')->where($w)->order('createtime asc')->value("createtime");
            if (!empty($jin_time) && !empty($yuan_time)) {
                $time_arr = time_to_time_end($yuan_time, $jin_time);
                if (!empty($time_arr)) {
                    foreach ($time_arr as $k1 => $v1) {
                        $s_time = $v1[0];//某天 08:00:00
                        $e_time = $v1[1];//和上面同天 09:00:00
                        $w2 = [];
                        $w2["number"] = ["=", $v['deviceId']];
                        $w2["reservoir_id"] = ["=", $v['reservoir_id']];
                        $w2["daytime"] = ["=", date("Ymd", strtotime($s_time) - 3600 * 24)];//每天早8点统计的都是昨天的数据
                        $dcks = Db::name("reservoir_rainfall_ctday")->where($w2)->count();
                        if ($dcks == 0) {
                            //日期对应当日累计雨量没记录过，找下数据有的话就存一下
                            $w3 = [];
                            $w3["number"] = ["=", $v['deviceId']];
                            $w3["reservoir_id"] = ["=", $v['reservoir_id']];
                            $record = Db::name("reservoir_rain_rainfall")
                                ->where($w3)
                                ->whereTime('createtime', '>=', strtotime($s_time))
                                ->whereTime('createtime', '<', strtotime($e_time))
                                ->order("createtime asc")
                                ->find();
                            if ($record) {
                                $insert_data = [];
                                $insert_data = [
                                    "number" => $record['number'],
                                    "total_rainfall" => $record['total_rainfall'],
                                    "reservoir_id" => $record['reservoir_id'],
                                    "createtime" => time(),
                                    "rrr_id" => $record['id'],
                                    "daytime" => date('Ymd', $record['createtime'] - 3600 * 24)
                                ];
                                $rs = Db::name('reservoir_rainfall_ctday')->insertGetId($insert_data);
                                if ($rs) {
                                    $succ_num = $succ_num + 1;
                                }
                            }

                        }

                    }
                }

            }
        }
        echo $succ_num;
    }


    /**
     * 9、渗流数据根据各个渗流计初始有数据时间进行清除
     * 类型:1=水位计,2=渗流计,3=渗压计,4=GNSS,5=雨量计,6=位移检测,7=其他
     */
    public function reset_dam_seepage()
    {
        //查询所有渗流计的初始有数据时间
        $w = [];
        $w["type"] = ["=", "2"];//类型:2=渗流计
        $list = Db::name("reservoir_equipment")->where($w)->order("servicetime asc,reservoir_id asc")->field("id,deviceId,reservoir_id,servicetime")->select();

        if (!empty($list)) {
            foreach ($list as $k => $v) {
                $count = 0;
                if ($v['servicetime']) {
                    //设置了初始有数据时间的才删除
                    $ww = [];
//                    $ww["number"] = ["=", $v['deviceId']]; //因为渗流计只有一个，所以就直接按对应时间删除，不需要这个编号条件。若多个就需要这个条件了；
                    $ww["reservoir_id"] = ["=", $v['reservoir_id']];
                    $ww["createtime"] = ["egt", strtotime($v['servicetime'])];
                    $count = Db::name("reservoir_dam_seepage")->where($ww)->delete();
                }
                $list[$k]['delete_num'] = $count;
            }
        }
        $this->success("", $list);
    }

    /**
     * 10、（千寻）第三步：把以前渗流数据拉一下
     */
    public function step3_dam_seepage()
    {
        $w = [];
        $w["type"] = ["=", "2"];//硬件类型 2=渗流计
        $w["company_type"] = ["=", "1"];//设备商 1=千寻，2=匠星
        $field = "deviceId,apiKey,qxDataKey,qxIsoKey,reservoir_id,type,company_type,servicetime";
        $list = Db::name('reservoir_equipment')->where($w)->field($field)->order("reservoir_id asc")->select();
        $data = [];

        foreach ($list as $k => $v) {
            $startTime = "";//开始时间
            $endTime = "";//结束时间
            $servicetime = "";//设备接口有数据时间（每个设备固定值）
            $servicetime = strtotime($v['servicetime']);
            $thirty_day = 24 * 3600 * 30;//千寻有效查询一个月

            //查最新一次设备更新数据时间
            $ww = [];
            $ww["equipment_id"] = ["=", $v['deviceId']];
            $ww["reservoir_id"] = ["=", $v['reservoir_id']];
            $last_createtime = Db::name("reservoir_dam_seepage")->where($ww)->order("createtime desc")->value("createtime");

            if ($last_createtime < $servicetime) {
                //数据中时间比接口开始时间都往前，就只能从接口开始有数据时间去采数据；
                $startTime = $servicetime * 1000; //接口开始有数据时间（毫秒）
                $endTime = $startTime + $thirty_day * 1000; //千寻有效三十天（毫秒）
            } elseif (($last_createtime + $thirty_day) <= time()) {
                $startTime = ($last_createtime + 1) * 1000; //数据库中上次接口更新时间（毫秒）
                $endTime = $startTime + $thirty_day * 1000;//千寻有效三十天（毫秒）
            } elseif ($last_createtime < time()) {
                $startTime = ($last_createtime + 1) * 1000; //数据库中上次接口更新时间（毫秒）
                $endTime = time() * 1000;
            }
            if ($startTime && $endTime) {
                $res = $this->qx_api_data($v['deviceId'], $startTime, $endTime);
                if (empty($res)) {
                    continue;
                }
                $info = $res['L3_SL'][$v['qxDataKey']];
                if ($info) {
                    //增加预警记录
                    $this->warning($v['deviceId'], $info);
                    foreach ($info as $k2 => $v2) {
                        $data[] = [
                            'equipment_id' => $v['deviceId'],
                            'value' => (float)$v2['value'],
                            'reservoir_id' => $v['reservoir_id'],
                            'createtime' => $v2['reportTime'] / 1000,
                            'reporttime' => $v2['reportTime'],
                        ];
                    }
                }
            }
        }
        $succ_num = Db::name('reservoir_dam_seepage')->insertAll($data);
        echo $succ_num . "/" . count($data);
    }

    /**
     * 11、（匠星）第三步：把以前渗流数据拉一下
     */
    public function step03_dam_seepage()
    {
        $w = [];
        $w["type"] = ["=", "2"];//硬件类型 2=渗流计
        $w["company_type"] = ["=", "2"];//设备商 1=千寻，2=匠星
        $field = "deviceId,apiKey,reservoir_id,type,company_type,servicetime";
        $list = Db::name('reservoir_equipment')->where($w)->field($field)->order("reservoir_id asc")->select();
        $data = [];

        foreach ($list as $k => $v) {
            $startTime = "";//开始时间
            $endTime = "";//结束时间
            $servicetime = "";//设备接口有数据时间（每个设备固定值）
            $servicetime = strtotime($v['servicetime']);//某日凌晨时间戳  （$v['servicetime']具体某日）

            //匠星有效查询一天内（开始日期和结束日期要是同一天，而不是24小时内）

            //查最新一次设备更新数据时间
            $ww = [];
            $ww["equipment_id"] = ["=", $v['deviceId']];
            $ww["reservoir_id"] = ["=", $v['reservoir_id']];
            $last_createtime = Db::name("reservoir_dam_seepage")->where($ww)->order("createtime desc")->value("createtime");

            if ($last_createtime < $servicetime) {
                //数据中时间比接口开始时间都往前，就只能从接口开始有数据时间去采数据；
                $startTime = $servicetime; //接口开始有数据时间（某日凌晨时间戳）
                $time_arr = time_to_today_end($startTime);
            } else {
                $startTime = $last_createtime + 1;
                $time_arr = time_to_today_end($startTime);
            }

            if ($time_arr) {
                foreach ($time_arr as $k1 => $v1) {
                    if (!empty($v1)) {
                        $s_time = $v1[0];
                        $e_time = $v1[1];
                        $res = $this->jx_api_data($v['apiKey'], $s_time, $e_time);//匠星查询用的apiKey的值 而不是deviceId的值
                        if (!empty($res)) {
                            $info = $res['L3_SL'][$v['deviceId']];
                            if ($info) {
                                //增加预警记录
                                $this->warning($v['deviceId'], $info);
                                foreach ($info as $k2 => $v2) {
                                    $data[] = [
                                        'equipment_id' => $v['deviceId'],
                                        'value' => (float)$v2['value'],
                                        'reservoir_id' => $v['reservoir_id'],
                                        'createtime' => $v2['reportTime'] / 1000,
                                        'reporttime' => $v2['reportTime'],
                                    ];
                                }
                            }
                        }
                    }
                }
            }
        }
        $succ_num = Db::name('reservoir_dam_seepage')->insertAll($data);
        echo $succ_num . "/" . count($data);
    }


    /**
     * 12、渗压数据根据各个渗压计初始有数据时间进行清除
     * 类型:1=水位计,2=渗流计,3=渗压计,4=GNSS,5=雨量计,6=位移检测,7=其他
     */
    public function reset_dam_isotonic()
    {
        //查询所有渗压计的初始有数据时间
        $w = [];
        $w["type"] = ["=", "3"];//类型:3=渗压计
        $list = Db::name("reservoir_equipment")->where($w)->order("servicetime asc,reservoir_id asc")->field("id,deviceId,reservoir_id,servicetime")->select();

        if (!empty($list)) {
            foreach ($list as $k => $v) {
                $count = 0;
                if ($v['servicetime']) {
                    //设置了初始有数据时间的才删除
                    $ww = [];
                    $ww["equipment_id"] = ["=", $v['deviceId']];
                    $ww["reservoir_id"] = ["=", $v['reservoir_id']];
                    $ww["createtime"] = ["egt", strtotime($v['servicetime'])];
                    $count = Db::name("reservoir_dam_isotonic")->where($ww)->delete();
                }
                $list[$k]['delete_num'] = $count;
            }
        }
        $this->success("", $list);
    }

    /**
     * 13、（千寻）第四步：把以前渗压数据拉一下
     */
    public function step4_dam_isotonic()
    {
        $w = [];
        $w["type"] = ["=", "3"];//硬件类型 3=渗压计
        $w["company_type"] = ["=", "1"];//设备商 1=千寻，2=匠星
        $field = "deviceId,apiKey,qxDataKey,qxIsoKey,reservoir_id,type,company_type,servicetime";
        $list = Db::name('reservoir_equipment')->where($w)->field($field)->order("reservoir_id asc")->select();

        $data = [];
        foreach ($list as $k => $v) {
            $startTime = "";//开始时间
            $endTime = "";//结束时间
            $servicetime = "";//设备接口有数据时间（每个设备固定值）
            $servicetime = strtotime($v['servicetime']);
            $thirty_day = 24 * 3600 * 30;//千寻有效查询一个月

            //查最新一次设备更新数据时间
            $ww = [];
            $ww["equipment_id"] = ["=", $v['deviceId']];
            $ww["reservoir_id"] = ["=", $v['reservoir_id']];
            $last_createtime = Db::name("reservoir_dam_isotonic")->where($ww)->order("createtime desc")->value("createtime");

            if ($last_createtime < $servicetime) {
                //数据中时间比接口开始时间都往前，就只能从接口开始有数据时间去采数据；
                $startTime = $servicetime * 1000; //接口开始有数据时间（毫秒）
                $endTime = $startTime + $thirty_day * 1000; //千寻有效三十天（毫秒）
            } elseif (($last_createtime + $thirty_day) <= time()) {
                $startTime = ($last_createtime + 1) * 1000; //数据库中上次接口更新时间（毫秒）
                $endTime = $startTime + $thirty_day * 1000;//千寻有效三十天（毫秒）
            } elseif ($last_createtime < time()) {
                $startTime = ($last_createtime + 1) * 1000; //数据库中上次接口更新时间（毫秒）
                $endTime = time() * 1000;
            }
            if ($startTime && $endTime) {
                $res = $this->qx_api_data($v['deviceId'], $startTime, $endTime);
                if (empty($res)) {
                    continue;
                }
                $info = $res['L3_SY'][$v['qxDataKey']];//渗压
                $dx_data = $res['L3_DX'][$v['qxIsoKey']];//浸润线深度
                if ($info) {
                    //增加预警记录
                    $this->warning($v['deviceId'], $info);
                    foreach ($info as $k2 => $v2) {
                        $dx_value = 0;
                        if ($dx_data[$v2['reportTime']]) {
                            $dx_value = $dx_data[$v2['reportTime']];
                        } else {
                            $v2value = (float)$v2['value'];
                            if ($v2value > 0) {
                                $dx_value = bcdiv($v2value, 9.8, 2);
                            }
                        }
                        $data[] = [
                            'equipment_id' => $v['deviceId'],
                            'value' => (float)$v2['value'],
                            'dx_value' => $dx_value,//$dx_data[$v2['reportTime']] ? (float)$dx_data[$v2['reportTime']] : 0,//追加浸润性深度数据（根据渗压的reportTime与浸润性reportTime相同拿值）,
                            'temp' => (float)$v2['temp'],
                            'reservoir_id' => $v['reservoir_id'],
                            'createtime' => $v2['reportTime'] / 1000,
                            'reporttime' => $v2['reportTime'],
                        ];
                    }
                }
            }
        }
        $succ_num = Db::name('reservoir_dam_isotonic')->insertAll($data);
        echo $succ_num . "/" . count($data);
    }

    /**
     * 14、（匠星）第四步：把以前渗压数据拉一下
     */
    public function step04_dam_isotonic()
    {
        $w = [];
        $w["type"] = ["=", "3"];//硬件类型 3=渗压计
        $w["id"] = ["=", "13"];//硬件类型 3=渗压计
        $w["company_type"] = ["=", "2"];//设备商 1=千寻，2=匠星
        $field = "deviceId,apiKey,reservoir_id,type,company_type,servicetime";
        //$w['reservoir_id'] = ['in', [11, 12, 13]];//1,5,6,8
        $list = Db::name('reservoir_equipment')
            ->where($w)
            ->field($field)
            ->order("reservoir_id asc")
            ->select();
        $data = [];
        $upt_succ = 0;

        foreach ($list as $k => $v) {
            $startTime = "";//开始时间
            $endTime = "";//结束时间
            $servicetime = "";//设备接口有数据时间（每个设备固定值）
            $servicetime = strtotime($v['servicetime']);//某日凌晨时间戳  （$v['servicetime']具体某日）

            //匠星有效查询一天内（开始日期和结束日期要是同一天，而不是24小时内）

            //查最新一次设备更新数据时间
            $ww = [];
            $ww["equipment_id"] = ["=", $v['deviceId']];
            $ww["reservoir_id"] = ["=", $v['reservoir_id']];
            $last_createtime = Db::name("reservoir_dam_isotonic")->where($ww)->order("createtime desc")->value("createtime");

            if ($last_createtime < $servicetime) {
                //数据中时间比接口开始时间都往前，就只能从接口开始有数据时间去采数据；
                $startTime = $servicetime; //接口开始有数据时间（某日凌晨时间戳）
                $time_arr = time_to_today_end($startTime);
            } else {
                $startTime = $last_createtime + 1;
                $time_arr = time_to_today_end($startTime);
            }

            if ($time_arr) {
                foreach ($time_arr as $k1 => $v1) {

                    if (!empty($v1)) {
                        $s_time = $v1[0];
                        $e_time = $v1[1];
                        $res = $this->jx_api_data($v['apiKey'], $s_time, $e_time);//匠星查询用的apiKey的值 而不是deviceId的值
                        if (!empty($res)) {
                            $info = $res['L3_SY'][$v['deviceId']];
                            if ($info) {
                                //增加预警记录
                                $this->warning($v['deviceId'], $info);

                                foreach ($info as $k2 => $v2) {
                                    $data = [];
                                    $data = [
                                        'equipment_id' => $v['deviceId'],
                                        'value' => (float)$v2['value'] * 9.8,//压强公式 P=ρgh  9.8*1*h
                                        'dx_value' => (float)$v2['value'],//匠星返回的value是浸润线深度
                                        'temp' => (float)$v2['temp'],
                                        'reservoir_id' => $v['reservoir_id'],
                                        'createtime' => $v2['reportTime'] / 1000,
                                        'reporttime' => $v2['reportTime'],
                                    ];
                                    print_r($v['apiKey']);
                                    print_r($v2);
                                    print_r($data);return;

                                    $rr = Db::name('reservoir_dam_isotonic')->insertGetId($data);
                                    if ($rr) {
                                        $upt_succ = $upt_succ + 1;
                                    }
                                }
                            }
                        }
                    }
                }
            }
        }
        echo $upt_succ;
    }

    /**
     * 15、循环删除渗压设备 多余数据（一小时保留最靠近整点那条；>=整点那条）
     * 如：09.00-10.00之间很多条 只保留靠近09.00的
     */
    public function delete_dam_isotonic()
    {
        //因为试过了循环处理会超时，所以现在一个个处理（比如设备总共47个），传参就传0-46即可；
        $param = $this->request->param("");
        $index = $param['index'];//（比如设备总共47个），传参就传0-46即可；
        $w = [];
        $w["type"] = ["=", "3"];//硬件类型 3=渗压计
        $list = Db::name('reservoir_equipment')->where($w)->field("deviceId,reservoir_id")->order("reservoir_id asc,id asc")->select();
        $list = [$list[$index]];
        $opt_succ = 0;
        if (!empty($list)) {
            foreach ($list as $k => $v) {
                $ww = [];
                $ww["equipment_id"] = ["=", $v['deviceId']];
                $ww["reservoir_id"] = ["=", $v['reservoir_id']];
                //最近时间
                $jin_time = Db::name("reservoir_dam_isotonic")->where($ww)->order("createtime desc")->value("createtime");
                //最远时间
                $yuan_time = Db::name("reservoir_dam_isotonic")->where($ww)->order("createtime asc")->value("createtime");

                if (!empty($jin_time) && !empty($yuan_time)) {
                    $jin_time = strtotime(date("Y-m-d H:00:00", $jin_time)) + 3600;//只保留整点
                    $yuan_time = strtotime(date("Y-m-d H:00:00", $yuan_time));//只保留整点
                    $hour = ($jin_time - $yuan_time) / 3600;//多少个小时
                    $end_time = $jin_time;//19:00
                    for ($i = 1; $i <= $hour; $i++) {

                        $start_time = $jin_time - 3600 * $i;//18:00
                        $w2 = [];
                        $ids = [];
                        $w2["equipment_id"] = ["=", $v['deviceId']];
                        $w2["reservoir_id"] = ["=", $v['reservoir_id']];
                        $ids = Db::name("reservoir_dam_isotonic")
                            ->where($w2)
                            ->whereTime('createtime', '>=', $start_time)
                            ->whereTime('createtime', '<', $end_time)
                            ->order("createtime asc")->column("id");
                        if (count($ids) > 1) {
                            array_shift($ids);//剔除掉最合适的数据，其他删除
                            $w3 = [];
                            $w3["id"] = ["in", $ids];
                            $rr = Db::name("reservoir_dam_isotonic")->where($w3)->delete();
                            $opt_succ = $opt_succ + $rr;
//                            echo "【" . $v['deviceId'] . ":" . $rr . "】";
                        }

                        //重置结束时间为上次开始时间
                        $end_time = $start_time;
                    }

                }
            }
        }
        echo $opt_succ;
    }


    /**
     * 16、坝体位移数据根据各个位移计初始有数据时间进行清除
     * 类型:1=水位计,2=渗流计,3=渗压计,4=GNSS,5=雨量计,6=位移检测,7=其他
     */
    public function reset_dam_displacement()
    {
        //查询所有渗压计的初始有数据时间
        $w = [];
        $w["type"] = ["=", "6"];//类型:6=位移检测
        $list = Db::name("reservoir_equipment")->where($w)->order("servicetime asc,reservoir_id asc")->field("id,deviceId,reservoir_id,servicetime")->select();

        if (!empty($list)) {
            foreach ($list as $k => $v) {
                $count = 0;
                if ($v['servicetime']) {
                    //设置了初始有数据时间的才删除
                    $ww = [];
                    $ww["number"] = ["=", $v['deviceId']];
                    $ww["reservoir_id"] = ["=", $v['reservoir_id']];
                    $ww["createtime"] = ["egt", strtotime($v['servicetime'])];
                    $count = Db::name("reservoir_dam_displacement")->where($ww)->delete();
                }
                $list[$k]['delete_num'] = $count;
            }
        }
        $this->success("", $list);
    }

    /**
     * 17、（千寻）第五步：把以前坝体位移数据拉一下
     */
    public function step5_dam_displacement()
    {
        $w = [];
        $w["type"] = ["=", "6"];//硬件类型 6=位移检测
        $w["company_type"] = ["=", "1"];//设备商 1=千寻，2=匠星
        $field = "deviceId,apiKey,qxDataKey,qxIsoKey,reservoir_id,type,company_type,servicetime";
        $list = Db::name('reservoir_equipment')->where($w)->field($field)->order("reservoir_id asc")->select();
        $data = [];

        foreach ($list as $k => $v) {
            $startTime = "";//开始时间
            $endTime = "";//结束时间
            $servicetime = "";//设备接口有数据时间（每个设备固定值）
            $servicetime = strtotime($v['servicetime']);
            $thirty_day = 24 * 3600 * 30;//千寻有效查询一个月

            //查最新一次设备更新数据时间
            $ww = [];
            $ww["number"] = ["=", $v['deviceId']];
            $ww["reservoir_id"] = ["=", $v['reservoir_id']];
            $last_createtime = Db::name("reservoir_dam_displacement")->where($ww)->order("createtime desc")->value("createtime");

            if ($last_createtime < $servicetime) {
                //数据中时间比接口开始时间都往前，就只能从接口开始有数据时间去采数据；
                $startTime = $servicetime * 1000; //接口开始有数据时间（毫秒）
                $endTime = $startTime + $thirty_day * 1000; //千寻有效三十天（毫秒）
            } elseif (($last_createtime + $thirty_day) <= time()) {
                $startTime = ($last_createtime + 1) * 1000; //数据库中上次接口更新时间（毫秒）
                $endTime = $startTime + $thirty_day * 1000;//千寻有效三十天（毫秒）
            } elseif ($last_createtime < time()) {
                $startTime = ($last_createtime + 1) * 1000; //数据库中上次接口更新时间（毫秒）
                $endTime = time() * 1000;
            }
            if ($startTime && $endTime) {
                $res = $this->qx_api_data($v['deviceId'], $startTime, $endTime);
                if (empty($res)) {
                    continue;
                }

                $info = $res['L1_GP'][$v['qxDataKey']];

                if ($info) {
                    //增加预警记录
                    $this->warning($v['deviceId'], $info);
                    foreach ($info as $k2 => $v2) {
                        $data[] = [
                            'number' => $v['deviceId'],
                            'horizontal' => (float)$v2['gpsTotalX'],
                            'horizontalY' => (float)$v2['gpsTotalY'],
                            'vertical' => (float)$v2['gpsTotalZ'],
                            'reservoir_id' => $v['reservoir_id'],
                            'createtime' => $v2['reportTime'] / 1000,
                            'reporttime' => $v2['reportTime'],
                        ];
                    }
                }
            }
        }
        $succ_num = Db::name('reservoir_dam_displacement')->insertAll($data);
        echo $succ_num . "/" . count($data);
    }

    /**
     * 18、（匠星）第五步：把以前坝体位移数据拉一下
     * 数据量太大 一个个拉
     */
    public function step05_dam_displacement()
    {
        //因为试过了循环处理会超时，所以现在一个个处理（比如设备总共7个），传参就传0-6即可；
//        $param = $this->request->param("");
//        $index = $param['index'];//（比如设备总共7个），传参就传0-6即可；

        $w = [];
        $w["type"] = ["=", "6"];//硬件类型 6=位移检测
        $w["company_type"] = ["=", "2"];//设备商 1=千寻，2=匠星
        $field = "deviceId,apiKey,reservoir_id,type,company_type,servicetime";
        $list = Db::name('reservoir_equipment')->where($w)->field($field)->order("reservoir_id asc")->select();
//        $list = [$list[$index]];
        if (!empty($list)) {

            $data = [];

            foreach ($list as $k => $v) {
                $startTime = "";//开始时间
                $endTime = "";//结束时间
                $servicetime = "";//设备接口有数据时间（每个设备固定值）
                $servicetime = strtotime($v['servicetime']);//某日凌晨时间戳  （$v['servicetime']具体某日）

                //匠星有效查询一天内（开始日期和结束日期要是同一天，而不是24小时内）

                //查最新一次设备更新数据时间
                $ww = [];
                $ww["number"] = ["=", $v['deviceId']];
                $ww["reservoir_id"] = ["=", $v['reservoir_id']];
                $last_createtime = Db::name("reservoir_dam_displacement")->where($ww)->order("createtime desc")->value("createtime");

                if ($last_createtime < $servicetime) {
                    //数据中时间比接口开始时间都往前，就只能从接口开始有数据时间去采数据；
                    $startTime = $servicetime; //接口开始有数据时间（某日凌晨时间戳）
                    $time_arr = time_to_today_end($startTime);
                } else {
                    $startTime = $last_createtime + 1;
                    $time_arr = time_to_today_end($startTime);
                }

                if ($time_arr) {
                    foreach ($time_arr as $k1 => $v1) {
                        if (!empty($v1)) {
                            $s_time = $v1[0];
                            $e_time = $v1[1];
                            $res = $this->jx_api_data($v['apiKey'], $s_time, $e_time);//匠星查询用的apiKey的值 而不是deviceId的值
                            if (!empty($res)) {
                                $info = $res['L1_GP'][$v['deviceId']];

                                if ($info) {
                                    //增加预警记录
                                    $this->warning($v['deviceId'], $info);
                                    foreach ($info as $k2 => $v2) {
                                        $data[] = [
                                            'number' => $v['deviceId'],
                                            'horizontal' => (float)$v2['gpsTotalX'],
                                            'horizontalY' => (float)$v2['gpsTotalY'],
                                            'vertical' => (float)$v2['gpsTotalZ'],
                                            'reservoir_id' => $v['reservoir_id'],
                                            'createtime' => $v2['reportTime'] / 1000,
                                            'reporttime' => $v2['reportTime'],
                                        ];
                                    }
                                }
                            }
                        }
                    }
                }
            }
            $succ_num = Db::name('reservoir_dam_displacement')->insertAll($data);
            echo $succ_num . "/" . count($data);
        }

    }

    /**
     * 19、处理以前匠星渗压和浸润线深度异常数据（这部分是因为他们加了探头高程）
     * 这部分数据基本都大于1000；
     */
    public function deal_jx_dam_isotonic_error()
    {
        $succ_num = 0;
        $w = [];
        $w["dx_value"] = ["gt", 1000];
        $list = Db::name("reservoir_dam_isotonic")->where($w)->select();
        $equipmentTantouHeight = $this->equipmentTantouHeight;//渗压对应探头高程
        if (!empty($list)) {
            foreach ($list as $k => $v) {
                $tantou_heigh = $equipmentTantouHeight[$v['equipment_id']];
                if ($tantou_heigh) {
                    $dx_value = $v['dx_value'] - $tantou_heigh;
                    if ($dx_value <= 0) {
                        $dx_value = 0;
                        $value = 0;
                    } else {
                        $value = (float)($dx_value * 9.8);
                    }
                    $res = Db::name("reservoir_dam_isotonic")->where("id", $v['id'])->update(["value" => $value, "dx_value" => $dx_value]);
                    if ($res) {
                        $succ_num = $succ_num + 1;
                    }
                }
            }
        }
        echo $succ_num;
    }

    /**
     * 设备预警记录
     */
    public function warning($deviceid, $data)
    {
        $type = $this->model->where('deviceId', $deviceid)->value('type');
        //预警阈值表
        $threshold = Db::name('reservoir_threshold')->where('deviceId', $deviceid)->field('config,reservoir_id')->find();
        $config = json_decode($threshold['config'], true);
        $reservoir = Db::name('reservoir_list')->where('id', $threshold['reservoir_id'])->field('user_mobile,name')->find();

        if (!$config) {
            return;
        }
        //水位
        if ($type == '1') {
            $arr = explode(',', $config['value']);
            sort($arr);
            foreach ($data as $k => $v) {
                if ($v['value'] < $arr[0] || $v['value'] > $arr[1]) {
                    $insert = [
                        'value' => $v['value'],
                        'warning' => $arr[0] . ',' . $arr[1],
                        'equipment_id' => $deviceid,
                        'reservoir_id' => $threshold['reservoir_id'],
                        'createtime' => time(),
                        'reporttime' => $v['reportTime']
                    ];
                    Db::name('reservoir_warning_waterlevel')->insert($insert);
                    // $sms = new Index();
                    // $res = $sms->send_param($reservoir['user_mobile'],'SMS_227742188','云南智慧水库安全云平台',array('password'=>$reservoir['name']));
                }
            }
        } //渗压
        elseif ($type == '3') {
            $arr = explode(',', $config['value']);
            sort($arr);
            foreach ($data as $k => $v) {
                if ($v['value'] < $arr[0] || $v['value'] > $arr[1]) {
                    $insert = [
                        'value' => $v['value'],
                        'warning' => $arr[0] . ',' . $arr[1],
                        'equipment_id' => $deviceid,
                        'reservoir_id' => $threshold['reservoir_id'],
                        'createtime' => time(),
                        'reporttime' => $v['reportTime']
                    ];
                    Db::name('reservoir_warning_isotonic')->insert($insert);
                    // $sms = new Index();
                    // $res = $sms->send_param($reservoir['user_mobile'],'SMS_227742188','云南智慧水库安全云平台',array('password'=>$reservoir['name']));
                }
            }
        } //雨量
        elseif ($type == '5') {
            $arr = explode(',', $config['value']);
            sort($arr);
            foreach ($data as $k => $v) {
                if ($v['value'] < $arr[0] || $v['value'] > $arr[1]) {
                    $insert = [
                        'value' => $v['value'],
                        'warning' => $arr[0] . ',' . $arr[1],
                        'equipment_id' => $deviceid,
                        'reservoir_id' => $threshold['reservoir_id'],
                        'createtime' => time(),
                        'reporttime' => $v['reportTime']
                    ];
                    Db::name('reservoir_warning_rainfall')->insert($insert);
                    // $sms = new Index();
                    // $res = $sms->send_param($reservoir['user_mobile'],'SMS_227742188','云南智慧水库安全云平台',array('password'=>$reservoir['name']));
                }
            }
        } //位移
        elseif ($type == '6') {
            foreach ($data as $key => $val) {
                foreach ($config as $k => $v) {
                    $arr = explode(',', $v);
                    sort($arr);
                    $value = $val['gpsTotal' . strtoupper($k)];
                    if ($value < $arr[0] || $value > $arr[1]) {
                        $insert = [
                            'value' => $value,
                            'warning' => $arr[0] . ',' . $arr[1],
                            'equipment_id' => $deviceid,
                            'reservoir_id' => $threshold['reservoir_id'],
                            'createtime' => time(),
                            'reporttime' => $val['reportTime'],
                            'shaft' => $k
                        ];
                        Db::name('reservoir_warning_displacement')->insert($insert);
                        // $sms = new Index();
                        // $res = $sms->send_param($reservoir['user_mobile'],'SMS_227742188','云南智慧水库安全云平台',array('password'=>$reservoir['name']));
                    }
                }
            }
        }
    }


    /**
     * 千寻的数据请求封装
     */
    public function qx_api_data($deviceId, $startTime, $endTime)
    {
        $qx = new Qx();
        $url = "http://openapi.qxwz.com/rest/linkx.devices.data/ack/" . $qx->AccessKey . "?deviceId=" . $deviceId . "&startTime=" . $startTime . "&endTime=" . $endTime;
        $info = json_decode($qx->geturl($url), true);
        $data = [];
        if ($info['code'] == 0) {
            $data = $info['data'];
        } else {
            //记录异常
            $insert_data = [
                "type" => "1",//供应商:1=千寻,2=匠星
                "param" => json_encode(["deviceId" => $deviceId, "startTime" => $startTime, "endTime" => $endTime]),
                "code" => $info['code'],
                "msg" => $info['message'],
            ];
            Db::name("reservoir_api_log")->insertGetId($insert_data);
        }
        return $data;
    }

    /**
     * 匠星的数据请求封装
     * 匠星的deviceId 用的 apiKey
     */
    public function jx_api_data($deviceId, $startTime, $endTime)
    {
        $url = "http://47.108.153.209:2010/api/device/data";
        $param = ["deviceId" => $deviceId, "startTime" => $startTime, "endTime" => $endTime];
        $res = HttpHelper::get($url, $param);
        $info = json_decode($res, true);
        $data = [];
        if ($info['code'] == 0) {
            $data = $info['data'];
        } else {
            //记录异常
            $insert_data = [
                "type" => "2",//供应商:1=千寻,2=匠星
                "param" => json_encode(["deviceId" => $deviceId, "startTime" => $startTime, "endTime" => $endTime]),
                "code" => $info['code'],
                "msg" => $info['msg'],
            ];
            Db::name("reservoir_api_log")->insertGetId($insert_data);
        }
        return $data;
    }

}