<?php
/**
 * Created by PhpStorm.
 * User: pcl
 * Date: 2023/7/11
 * Time: 14:50
 */

namespace app\api\controller;
header("Access-Control-Allow-Origin:*");
header("Access-Control-Allow-Methods:GET, POST, OPTIONS, DELETE");
header("Access-Control-Allow-Headers:DNT,X-Mx-ReqToken,Keep-Alive,User-Agent,X-Requested-With,If-Modified-Since,Cache-Control,Content-Type, Accept-Language, Origin, Accept-Encoding");
set_time_limit(0);

use app\common\controller\Api;
use think\Db;
use think\Exception;
use think\exception\PDOException;
use think\Request;

/**
 * 个旧
 * 读取数据 推送到州级平台
 */
class Datatozhou extends Api
{
    protected $noNeedLogin = ['*'];
    protected $noNeedRight = ['*'];
    protected $rid;//水库id
    protected $province_id;
    protected $state_id;
    protected $county_id;

    function _initialize()
    {
        parent::_initialize();
        $rid = $this->request->param('rid', 0);
        $this->rid = $rid;
        $this->province_id = 1;
        $this->state_id = 1;
        $this->county_id = 11;//个旧
    }

    /***
     * 库容信息
     */
    public function getKuRongList()
    {
        //数据比较大，按水库id分别获得数据
        //获得水库信息
        $data = [];
        $rever = Db::name('reservoir_list')
            ->where(['id' => $this->rid])
            ->value('name');
        if ($rever) {
            $list = Db::name('warterdata_capacityof')
                ->where(['reservoir_id' => $this->rid, 'issend' => 0])
                ->order('id asc')
                ->select();
            if (!empty($list)) {
                foreach ($list as $k => $v) {
                    $data['reservoir_name'] = $rever;
                    $data['province_id'] = $this->province_id;
                    $data['state_id'] = $this->state_id;
                    $data['county_id'] = $this->county_id;
                    $data['list'] = $v;
                    //推送数据到州级平台curl
                    $url = 'https://honghe.ynzhsk.cn/api/getdatatoarea/getKuRongData';
                    $res = $this->posturl($url, $data);
                    //更新推送状态
                    $sendok['issend'] = 1;
                    $sendok['updatetime'] = time();
                    Db::name('warterdata_capacityof')
                        ->where(['reservoir_id' => $this->rid, 'id' => $v['id']])
                        ->update($sendok);

                    var_dump($res);
                }
            }
        } else {
            echo '水库信息不存在';
        }
    }

    /***
     * 按水库id获得水位信息
     * 水位数据推送,今年的
     */
    public function getRiverRainWaterList()
    {
        //获得水库信息
        $data = [];
        $rever = Db::name('reservoir_list')
            ->where(['id' => $this->rid])
            ->value('name');
        $data['reservoir_name'] = $rever;
        $data['province_id'] = $this->province_id;
        $data['state_id'] = $this->state_id;
        $data['county_id'] = $this->county_id;
        if ($rever) {
            $list = Db::name('reservoir_rain_water_level')
                ->where(['reservoir_id' => $this->rid, 'issend' => 0])
                ->where('createtime>=1687190400')
                ->order('id asc')
                ->select();

            if (!empty($list)) {
                foreach ($list as $k => $v) {
                    $data['list'] = $v;
                    //推送数据到州级平台curl
                    $url = 'https://honghe.ynzhsk.cn/api/getdatatoarea/getRainWaterData';
                    $res = $this->posturl($url, $data);
                    //更新推送状态
                    $sendok['issend'] = 1;
                    $sendok['updatetime'] = time();
                    Db::name('reservoir_rain_water_level')
                        ->where(['reservoir_id' => $this->rid, 'id' => $v['id']])
                        ->update($sendok);
                    var_dump($res);
                }
            }
        } else {
            echo '水库信息不存在';
        }
    }

    /****
     * 定时任务,1小时
     * 水位数据推送
     */
    public function getRiverRainWaterDays()
    {
        $list = Db::name('reservoir_rain_water_level')
            ->alias('w')
            ->join('reservoir_list r', 'w.reservoir_id=r.id')
            ->where(['w.issend' => 0])
            ->order('w.id desc')
            ->limit(30)
            ->field('w.*,r.name as reservoir_name')
            ->select();
        if ($list) {
            foreach ($list as $k => $v) {
                $data['reservoir_name'] = $v['reservoir_name'];
                $data['province_id'] = $this->province_id;
                $data['state_id'] = $this->state_id;
                $data['county_id'] = $this->county_id;
                $data['list'] = $v;
                //推送数据到州级平台curl
                $url = 'https://honghe.ynzhsk.cn/api/getdatatoarea/getRainWaterData';
                $res = $this->posturl($url, $data);
                //更新推送状态
                $sendok['issend'] = 1;
                $sendok['updatetime'] = time();
                Db::name('reservoir_rain_water_level')
                    ->where(['id' => $v['id']])
                    ->update($sendok);

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

        $this->success('没有内容');
    }


    /***
     * 按水库id获得降雨量
     * 降雨量据推送,最近1个月的
     */
    public function getRiverRainFallList()
    {
        //获得水库信息
        $data = [];
        $rever = Db::name('reservoir_list')
            ->where(['id' => $this->rid])
            ->value('name');
        $data['reservoir_name'] = $rever;
        $data['province_id'] = $this->province_id;
        $data['state_id'] = $this->state_id;
        $data['county_id'] = $this->county_id;
        if ($rever) {
            $list = Db::name('reservoir_rain_rainfall')
                ->where(['reservoir_id' => $this->rid, 'issend' => 0])
                ->where('createtime>=1687190400')
                ->order('id asc')
                ->select();

            if (!empty($list)) {
                foreach ($list as $k => $v) {
                    $data['list'] = $v;
                    //推送数据到州级平台curl
                    $url = 'https://honghe.ynzhsk.cn/api/getdatatoarea/getRainFallData';
                    $res = $this->posturl($url, $data);
                    //更新推送状态
                    $sendok['issend'] = 1;
                    $sendok['updatetime'] = time();
                    Db::name('reservoir_rain_rainfall')
                        ->where(['reservoir_id' => $this->rid, 'id' => $v['id']])
                        ->update($sendok);
                    var_dump($res);
                }
            }
        } else {
            echo '水库信息不存在';
        }
    }

    /***
     * 定时任务，1小时
     * 降雨量据推送
     */
    public function getRainfallDays()
    {
        $list = Db::name('reservoir_rain_rainfall')
            ->alias('w')
            ->join('reservoir_list r', 'w.reservoir_id=r.id')
            ->where(['w.issend' => 0])
            ->order('w.id desc')
            ->limit(30)
            ->field('w.*,r.name as reservoir_name')
            ->select();
        if ($list) {
            foreach ($list as $k => $v) {
                $data['reservoir_name'] = $v['reservoir_name'];
                $data['province_id'] = $this->province_id;
                $data['state_id'] = $this->state_id;
                $data['county_id'] = $this->county_id;
                $data['list'] = $v;
                //推送数据到州级平台curl
                $url = 'https://honghe.ynzhsk.cn/api/getdatatoarea/getRainFallData';
                $res = $this->posturl($url, $data);
                //更新推送状态
                $sendok['issend'] = 1;
                $sendok['updatetime'] = time();
                Db::name('reservoir_rain_rainfall')
                    ->where(['id' => $v['id']])
                    ->update($sendok);

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

        $this->success('没有内容');
    }

    /***
     * 渗流数据列表 推送
     */
    public function getRiverDamSeepageList()
    {
        //获得水库信息
        $data = [];
        $rever = Db::name('reservoir_list')
            ->where(['id' => $this->rid])
            ->value('name');
        $data['reservoir_name'] = $rever;
        $data['province_id'] = $this->province_id;
        $data['state_id'] = $this->state_id;
        $data['county_id'] = $this->county_id;
        if ($rever) {
            $list = Db::name('reservoir_dam_seepage')
                ->where(['reservoir_id' => $this->rid, 'issend' => 0])
                ->where('createtime>=1672502400')
                ->order('id asc')
                ->select();

            if (!empty($list)) {
                foreach ($list as $k => $v) {
                    $data['list'] = $v;
                    //推送数据到州级平台curl
                    $url = 'https://honghe.ynzhsk.cn/api/getdatatoarea/getRainDamSeepageData';
                    $res = $this->posturl($url, $data);
                    //更新推送状态
                    $sendok['issend'] = 1;
                    $sendok['updatetime'] = time();
                    Db::name('reservoir_dam_seepage')
                        ->where(['reservoir_id' => $this->rid, 'id' => $v['id']])
                        ->update($sendok);
                    var_dump($res);
                }
            }
        } else {
            echo '水库信息不存在';
        }
    }

    /***
     * 渗流数据采集，10分钟
     * 数据推送
     */
    public function getDamSeepageDays()
    {
        $list = Db::name('reservoir_dam_seepage')
            ->alias('w')
            ->join('reservoir_list r', 'w.reservoir_id=r.id')
            ->where(['w.issend' => 0])
            ->order('w.id desc')
            ->limit(30)
            ->field('w.*,r.name as reservoir_name')
            ->select();
        if ($list) {
            foreach ($list as $k => $v) {
                $data['reservoir_name'] = $v['reservoir_name'];
                $data['province_id'] = $this->province_id;
                $data['state_id'] = $this->state_id;
                $data['county_id'] = $this->county_id;
                $data['list'] = $v;
                //推送数据到州级平台curl
                $url = 'https://honghe.ynzhsk.cn/api/getdatatoarea/getRainDamSeepageData';

                $res = $this->posturl($url, $data);
                //更新推送状态
                $sendok['issend'] = 1;
                $sendok['updatetime'] = time();
                Db::name('reservoir_dam_seepage')
                    ->where(['id' => $v['id']])
                    ->update($sendok);

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

    /***
     * 按水库id获得渗压列表
     * 推送,最近1个月的
     */
    public
    function getRiverdam_isotonicList()
    {
        //获得水库信息
        $data = [];
        $rever = Db::name('reservoir_list')
            ->where(['id' => $this->rid])
            ->value('name');
        $data['reservoir_name'] = $rever;
        $data['province_id'] = $this->province_id;
        $data['state_id'] = $this->state_id;
        $data['county_id'] = $this->county_id;
        if ($rever) {
            $list = Db::name('reservoir_dam_isotonic')
                ->where(['reservoir_id' => $this->rid, 'issend' => 0])
                ->where('createtime>=1687190400')
                ->order('id asc')
                ->select();

            if (!empty($list)) {
                foreach ($list as $k => $v) {
                    $data['list'] = $v;
                    //推送数据到州级平台curl
                    $url = 'https://honghe.ynzhsk.cn/api/getdatatoarea/getRaindam_isotonicData';
                    $res = $this->posturl($url, $data);
                    //更新推送状态
                    $sendok['issend'] = 1;
                    $sendok['updatetime'] = time();
                    Db::name('reservoir_dam_isotonic')
                        ->where(['reservoir_id' => $this->rid, 'id' => $v['id']])
                        ->update($sendok);
                    var_dump($res);
                }
            }
        } else {
            echo '水库信息不存在';
        }
    }

    /***
     * 渗压数据采集，1小时
     * 数据推送
     */
    public function getDam_isotonicDays()
    {
        $list = Db::name('reservoir_dam_isotonic')
            ->alias('w')
            ->join('reservoir_list r', 'w.reservoir_id=r.id')
            ->where(['w.issend' => 0])
            ->order('w.id desc')
            ->limit(30)
            ->field('w.*,r.name as reservoir_name')
            ->select();
        if ($list) {
            foreach ($list as $k => $v) {
                $data['reservoir_name'] = $v['reservoir_name'];
                $data['province_id'] = $this->province_id;
                $data['state_id'] = $this->state_id;
                $data['county_id'] = $this->county_id;
                $data['list'] = $v;
                //推送数据到州级平台curl
                $url = 'https://honghe.ynzhsk.cn/api/getdatatoarea/getRaindam_isotonicData';

                $res = $this->posturl($url, $data);
                //更新推送状态
                $sendok['issend'] = 1;
                $sendok['updatetime'] = time();
                Db::name('reservoir_dam_isotonic')
                    ->where(['id' => $v['id']])
                    ->update($sendok);

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

    /***
     * 位移推送，1小时
     * 定时任务 数据推送
     */
    public function getDam_displacementDays()
    {
        $list = Db::name('reservoir_dam_displacement')
            ->alias('w')
            ->join('reservoir_list r', 'w.reservoir_id=r.id')
            ->where(['w.issend' => 0])
            ->order('w.id desc')
            ->limit(90)
            ->field('w.*,r.name as reservoir_name')
            ->select();
        if ($list) {
            foreach ($list as $k => $v) {
                $data['reservoir_name'] = $v['reservoir_name'];
                $data['province_id'] = $this->province_id;
                $data['state_id'] = $this->state_id;
                $data['county_id'] = $this->county_id;
                $data['list'] = $v;
                //推送数据到州级平台curl
                $url = 'https://honghe.ynzhsk.cn/api/getdatatoarea/getRaindam_displacementData';

                $res = $this->posturl($url, $data);
                //更新推送状态
                $sendok['issend'] = 1;
                $sendok['updatetime'] = time();
                Db::name('reservoir_dam_displacement')
                    ->where(['id' => $v['id']])
                    ->update($sendok);

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

    /***
     * 定时任务，10分钟
     * 海康入侵记录推送
     */
    public function getHkws_alarm_monitoringDyas()
    {
        $list = Db::name('reservoir_hkws_alarm_monitoring')
            ->alias('w')
            ->join('reservoir_list r', 'w.reservoir_list_id=r.id')
            ->order('w.id desc')
            ->limit(90)
            ->field('w.*,r.name as reservoir_name')
            ->select();
        if ($list) {
            foreach ($list as $k => $v) {
                $data['reservoir_name'] = $v['reservoir_name'];
                $data['province_id'] = $this->province_id;
                $data['state_id'] = $this->state_id;
                $data['county_id'] = $this->county_id;
                $data['list'] = $v;
                //推送数据到州级平台curl
                $url = 'https://honghe.ynzhsk.cn/api/getdatatoarea/getHkws_alarm_monitoringData';

                $res = $this->posturl($url, $data);
                //更新推送状态
                $sendok['issend'] = 1;
                $sendok['updatetime'] = time();
                Db::name('reservoir_hkws_alarm_monitoring')
                    ->where(['id' => $v['id']])
                    ->update($sendok);

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

    /***
     * @param $url
     * @param $data
     * @param string $token
     * @param string $cookie
     * @param string $type
     * @param bool $ssl
     * @return mixed
     * 信息推送函数
     */
    protected
    function posturl($url, $data, $token = '', $cookie = '', $type = '', $ssl = false)
    {
        if (!$token) {
            $headerArray = array("Expect:", "Content-Type: application/x-www-form-urlencoded;");
        } else {
            $headerArray = array("Expect:", "Content-Type: application/x-www-form-urlencoded;", "Authorization: $token");
        }
        $user_agent = "Mozilla/5.0 (Windows NT 6.1; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/29.0.1547.66 Safari/537.36";
        $curl = curl_init();
        curl_setopt($curl, CURLOPT_URL, $url);
        if ($ssl) {
            curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, true);
            curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, true);
        } else {
            curl_setopt($curl, CURLOPT_SSL_VERIFYPEER, false);
            curl_setopt($curl, CURLOPT_SSL_VERIFYHOST, false);
        }
        curl_setopt($curl, CURLOPT_POST, 1);
        curl_setopt($curl, CURLOPT_POSTFIELDS, http_build_query($data));
        curl_setopt($curl, CURLOPT_HTTPHEADER, $headerArray);
        curl_setopt($curl, CURLOPT_RETURNTRANSFER, 1);
        if ($type === 0 && $cookie) {
            curl_setopt($curl, CURLOPT_COOKIEJAR, $cookie);
        } elseif ($type === 1 && $cookie) {
            curl_setopt($curl, CURLOPT_COOKIEFILE, $cookie);
        }
        curl_setopt($curl, CURLOPT_USERAGENT, $user_agent);
        //curl_setopt($curl, CURLOPT_HTTPHEADER, array('X-FORWARDED-FOR:'.Rand_IP(), 'CLIENT-IP:'.Rand_IP()));
        //curl_setopt($curl, CURLOPT_REFERER, 'https://www.thepaper.cn/');//模拟来路
        //curl_setopt($curl, CURLOPT_HEADER, true);
        curl_setopt($curl, CURLOPT_FOLLOWLOCATION, true);
        $output = curl_exec($curl);
        //echo $output;
        curl_close($curl);
        return $output;
    }
}