<?php
/**
 * Created by PhpStorm.
 * User: pcl
 * Date: 2022/4/3
 * Time: 9:24
 * ResvRaninDate
 * 水库雨水情大屏接口
 *
 */

namespace app\api\controller;

use app\common\controller\Api;
use fast\Tree;
use think\Db;
use think\Request;

/**
 *
 *
 * @icon fa fa-circle-o
 */
class Resvranindate extends Api
{

    /**
     * Depart模型对象
     * @var
     */
    protected $noNeedLogin = ['*'];
    protected $noNeedRight = ['*'];
    protected $model = null;
    protected $rid;

    public function _initialize()
    {
        parent::_initialize();
        $this->rid = $this->request->param('rid', 4);
    }

    /**
     * 顶部统计
     *
     */
    public function topCount()
    {
        if ($this->request->isGet()) {
            $rid = $this->rid;
            //累计降水量
            $rainAll = Db::name('reservoir_rainfall_ctday')->where(['reservoir_id' => $rid])->sum('total_rainfall');
            //今日降水量
            $nowday = date('Ymd', time());
            $dayRain = Db::name('reservoir_rainfall_ctday')->where(['reservoir_id' => $rid, 'daytime' => $nowday])->find();
            //当前降水量
            //读取今日的数据
            $start_time = strtotime(date("Y-m-d 00:00:00", time()));
            //当天结束时间
            $end_time = strtotime(date("Y-m-d 23:59:59", time()));
            $nowRain = Db::name('reservoir_rain_rainfall')
                ->where(['reservoir_id' => $rid])
                ->where('createtime between ' . $start_time . ' and ' . $end_time)
                ->order('id', 'desc')
                ->find();
            //当前水位
            $nowLevel = Db::name('reservoir_rain_water_level')
                ->where(['reservoir_id' => $rid])
                ->order('id', 'desc')
                ->find();
            //水库容量
            $krong = Db::name('warterdata_capacityof')
                ->where(['reservoir_id' => $rid, 'warterdata' => $nowLevel['water_level']])
                ->find();
            $data = [
                'rainAll' => round($rainAll, 2),
                'dayRain' => $dayRain['total_rainfall'] ? $dayRain['total_rainfall'] : 0,
                'nowRain' => $nowRain['total_rainfall'] ? $nowRain['total_rainfall'] : 0,
                'nowLevel' => $nowLevel['water_level'],
                'krong' => $krong['CapacityOf'],
            ];

            $this->success('获取成功', $data);
        }
    }

    /**
     * 左2区降雨量统计
     *
     */
    public function resvRain7DayCt()
    {
        if ($this->request->isGet()) {
            $rid = $this->rid;
            //今日降水量总计
            $nowday = date('Ymd', time());
            $dayRain = Db::name('reservoir_rainfall_ctday')->where(['reservoir_id' => $rid, 'daytime' => $nowday])->find();
            //近10日降水量总计
            $mytime10 = date("Ymd", strtotime("-10 day"));
            $day10Rain = Db::name('reservoir_rainfall_ctday')
                ->where(['reservoir_id' => $rid])
                ->where('daytime >= ' . $mytime10)
                ->sum('total_rainfall');

            $day10Rain = round($day10Rain, 2);
            //近1个月的降水量总计
            $mytimemth = date("Ymd", strtotime("-1 month"));
            $tmMthRain = Db::name('reservoir_rainfall_ctday')
                ->where(['reservoir_id' => $rid])
                ->where('daytime >= ' . $mytimemth)
                ->sum('total_rainfall');
            $tmMthRain = round($tmMthRain, 2);

            //获得近7天日期列表
            $rainList = [];
            $wklist = $this->getLatelyTimeList('week');
            sort($wklist);

            foreach ($wklist as $k => $v) {
                $row = Db::name('reservoir_rainfall_ctday')->where(['reservoir_id' => $rid, 'daytime' => $v])->find();
                $dtm = $row['daytime'] ? $row['daytime'] : date('Ymd', time());
                $rainList[$k]['dayTime'] = date('m/d', strtotime($v));
                $rainList[$k]['total_rainfall'] = $row['total_rainfall'] ? $row['total_rainfall'] : 0;
            }
            $data = [
                'rain_day' => $dayRain ? $dayRain['total_rainfall'] : 0,
                'rain_10_day' => $day10Rain ? $day10Rain : 0,
                'rain_1_mth' => $tmMthRain ? $tmMthRain : 0,
                'rainList' => $rainList,
            ];

            $this->success('获取成功', $data);
        }
    }

    /**
     * resvRainNewList
     * 实时报告水位和降雨量列表
     */
    public function resvRainNewList()
    {
        if ($this->request->isGet()) {
            $rid = $this->rid;
            //最新20条数据
            $rinfo = Db::name('reservoir_list')
                ->where(['id' => $rid])
                ->find();
            $rlevel = Db::name('reservoir_rain_water_level')
                ->where(['reservoir_id' => $rid])
                ->field('water_level')
                ->order('createtime', 'desc')
                ->limit(20)
                ->select();
            $rrain = Db::name('reservoir_rain_rainfall')
                ->where(['reservoir_id' => $rid])
                ->field('id,total_rainfall,createtime')
                ->order('createtime', 'desc')
                ->limit(20)
                ->select();

            $res = [];
            foreach ($rrain as $k => $v) {
                $res[$k]['id'] = $v['id'];
                $res[$k]['name'] = $rinfo['name'];
                $res[$k]['water_level'] = $rlevel[$k]['water_level'];
                $krong = Db::name('warterdata_capacityof')
                    ->where(['warterdata' => $rlevel[$k]['water_level']])
                    ->find();
                $res[$k]['kurong'] = $krong['CapacityOf'];
                $res[$k]['total_rainfall'] = $v['total_rainfall'];
                $res[$k]['createtime'] = date('m/d H:i', $v['createtime']);
            }

            $this->success('获取成功', $res);
        }
    }

    /**
     * 库容量跟随库水位列表
     * resvRainLvList
     */
    public function resvRainLvList()
    {
        if ($this->request->isGet()) {
            $rid = $this->rid;
            //最新的7条水位列表
            $rlevel = Db::name('reservoir_rain_water_level')
                ->where(['reservoir_id' => $rid])
                ->field('createtime,water_level')
                ->order('createtime', 'desc')
                ->limit(7)->select();
            sort($rlevel);
            $rlist = [];
            $timelist = [];
            $lvList = [];
            foreach ($rlevel as $k => $v) {
                $rinfo = Db::name('warterdata_capacityof')->where(['warterdata' => $v['water_level']])->find();
                array_push($lvList, $v['water_level']);
                array_push($rlist, $rinfo['CapacityOf']);
                array_push($timelist, date('H:i', $v['createtime']));
            }

            $data = [
                'lvList' => $lvList,
                'rlList' => $rlist,
                'timelist' => $timelist,
            ];

            $this->success('获取成功', $data);
        }
    }

    /**
     * 库容量跟随库水位列表1
     * resvRainLvList
     */
    public function resvRainLvList1()
    {
        if ($this->request->isGet()) {
            $rid = $this->rid;
            //最新的7条水位列表
            $rlevel = Db::name('reservoir_rain_water_level')
                ->where(['reservoir_id' => $rid])
                ->field('createtime,water_level')
                ->order('createtime', 'desc')
                ->limit(7)->select();
            sort($rlevel);
            $rlist = [];
            $timelist = [];
            $lvList = [];
            foreach ($rlevel as $k => $v) {
                $rinfo = Db::name('warterdata_capacityof')->where(['warterdata' => $v['water_level']])->find();
                $lvList1 = ['lv' => $v['water_level']];
                $rlist1 = ['rl' => $rinfo['CapacityOf']];
                $timelist1 = ['tm' => date('H:i', $v['createtime'])];
                array_push($lvList, $lvList1);
                array_push($rlist, $rlist1);
                array_push($timelist, $timelist1);
            }

            $data = [
                'lvList' => $lvList,
                'rlList' => $rlist,
                'timelist' => $timelist,
            ];

            $this->success('获取成功', $data);
        }
    }

    /**
     * 右2区：水情分析
     *resvRainInfo
     */
    public function resvRainInfo()
    {
        if ($this->request->isGet()) {
            $rid = $this->rid;
            //近12小时最大降雨量
            $nowRain = Db::name('reservoir_rain_rainfall')
                ->where(['reservoir_id' => $rid])
                ->field('total_rainfall,id')
                ->order('id', 'desc')
                ->limit(12)
                ->select();
            rsort($nowRain);

            //近12小时最小降雨量
            $nowRain2 = Db::name('reservoir_rain_rainfall')
                ->where(['reservoir_id' => $rid])
                ->field('total_rainfall,id')
                ->order('id', 'desc')
                ->limit(12)
                ->select();
            sort($nowRain2);

            //近10天最大降雨量
            $mytime10 = date("Ymd", strtotime("-10 day"));
            $day10Rain = Db::name('reservoir_rainfall_ctday')
                ->where(['reservoir_id' => $rid])
                ->where('daytime >= ' . $mytime10)
                ->field('total_rainfall,id')
                ->select();
            rsort($day10Rain);

            $day10Rain2 = Db::name('reservoir_rainfall_ctday')
                ->where(['reservoir_id' => $rid])
                ->where('daytime >= ' . $mytime10)
                ->field('total_rainfall,id')
                ->select();
            sort($day10Rain2);

            $data = [
                'max_rain' => $nowRain[0]['total_rainfall'],
                'min_rain' => $nowRain2[0]['total_rainfall'],
                'max_rain_10' => $day10Rain[0]['total_rainfall'],
                'min_rain_10' => $day10Rain2[0]['total_rainfall'],
            ];
            $this->success('获取成功', $data);
        }
    }

    /**
     *时间数据处理
     *
     */
    public function rainDayList()
    {
        $rid = $this->rid;

        $list = Db::name('reservoir_rain_rainfall')
            ->where(['reservoir_id' => $rid])
            ->order('id', 'asc')
            ->select();
        //选择时间处理，每天取08时的1条数据
        $arr = [];
        foreach ($list as $v) {
            $time = date('H', $v['createtime']);
            if ($time == '08') {
                array_push($arr, $v);
            }
        }
        //保存每日统计数据到统计表
        foreach ($arr as $k => $j) {
            $data['number'] = $j['number'];
            $data['total_rainfall'] = $j['total_rainfall'];
            $data['reservoir_id'] = $j['reservoir_id'];
            $data['createtime'] = time();
            $data['daytime'] = date('Ymd', $j['createtime']);
            $data['rrr_id'] = $j['id'];
            $dcks = Db::name('reservoir_rainfall_ctday')->where(['daytime' => $data['daytime'], 'reservoir_id' => $j['reservoir_id']])->find();
            if (empty($dcks)) {
                $rs = Db::name('reservoir_rainfall_ctday')->insertGetId($data);
            }
        }

        echo $rs;
    }

    /**
     * @param $data
     * 定时任务接口
     * 处理每天的数据
     * 把降雨量08时的数据写入每日统计表
     * 目前：以前的数据统计表只水库4,6,9
     * 每日08：20分执行1次
     */
    public function resvRainCtDay()
    {
        //读取今日的数据
        $start_time = strtotime(date("Y-m-d 00:00:00", time()));
        //当天结束之间
        $end_time = strtotime(date("Y-m-d 23:59:59", time()));
        $list = Db::name('reservoir_rain_rainfall')
            ->where('createtime between ' . $start_time . ' and ' . $end_time)
            ->order('id', 'asc')
            ->select();
        //选择时间处理，每天取08时的1条数据
        $arr = [];
        foreach ($list as $v) {
            $time = date('H', $v['createtime']);
            if ($time == '08') {
                array_push($arr, $v);
            }
        }
        $data = [];
        //保存每日统计数据到统计表
        foreach ($arr as $k => $j) {
            $data['number'] = $j['number'];
            $data['total_rainfall'] = $j['total_rainfall'];
            $data['reservoir_id'] = $j['reservoir_id'];
            $data['createtime'] = time();
            $data['daytime'] = date('Ymd', $j['createtime']);
            $data['rrr_id'] = $j['id'];
            $dcks = Db::name('reservoir_rainfall_ctday')->where(['daytime' => $data['daytime'], 'reservoir_id' => $j['reservoir_id']])->find();
            if (empty($dcks)) {
                $rs = Db::name('reservoir_rainfall_ctday')->insertGetId($data);
                echo $rs . '<br/>';
            }
        }
    }

    /**
     * @param $data
     * 定时任务接口
     * 处理以前的数据
     * 把降雨量08时的数据写入每日统计表
     * 目前：以前的数据统计表只水库4,6,9
     * 每日08：20分执行1次
     */
    public function resvRainCtDayAll()
    {
        //读取今日的数据
        $start_time = strtotime('-1 month', time());
        //当天结束之间
        $end_time = time();
        $list = Db::name('reservoir_rain_rainfall')
            ->where('createtime between ' . $start_time . ' and ' . $end_time)
            ->order('id', 'asc')
            ->select();
        //选择时间处理，每天取08时的1条数据
        $arr = [];
        foreach ($list as $v) {
            $time = date('H', $v['createtime']);
            if ($time == '08') {
                array_push($arr, $v);
            }
        }

        $data = [];
        //保存每日统计数据到统计表
        foreach ($arr as $k => $j) {
            $data['number'] = $j['number'];
            $data['total_rainfall'] = $j['total_rainfall'];
            $data['reservoir_id'] = $j['reservoir_id'];
            $data['createtime'] = time();
            $data['daytime'] = date('Ymd', $j['createtime']);
            $data['rrr_id'] = $j['id'];
            //echo $j['reservoir_id'] . '-' . $j['total_rainfall'] . '-' . date('Y-m-d H:i:s', $j['createtime']) . '<br/>';
            $dcks = Db::name('reservoir_rainfall_ctday')->where(['daytime' => $data['daytime'], 'reservoir_id' => $j['reservoir_id']])->find();
            if (empty($dcks)) {
                $rs = Db::name('reservoir_rainfall_ctday')->insertGetId($data);
                echo $rs . '<br/>';
            }
        }
    }

    /**
     * @param $data
     * 日期处理
     *
     */
    private function getLatelyTimeList($type = '')
    {
        $now = time();
        $result = [];
        if ($type == 'week') {
            //最近一周
            for ($i = 0; $i < 7; $i++) {
                $result[] = date('Ymd', strtotime('-' . $i . ' day', $now));
            }
        } elseif ($type == 'month') {
            //最近一个月
            for ($i = 0; $i < 30; $i++) {
                $result[] = date('Y-m-d', strtotime('-' . $i . ' day', $now));
            }
        } elseif ($type == 'year') {
            //最近一年
            for ($i = 0; $i < 12; $i++) {
                $result[] = date('Y-m', strtotime('-' . $i . ' month', $now));
            }
        }
        return $result;
    }

    public
    function PCL($data)
    {
        echo '<pre>';
        print_r($data);
        echo '</pre>';
    }

}