<?php

namespace app\api\controller;

use app\common\controller\Api;
use PhpOffice\PhpSpreadsheet\Cell\Coordinate;
use PhpOffice\PhpSpreadsheet\Reader\Xlsx;
use PhpOffice\PhpSpreadsheet\Reader\Xls;
use PhpOffice\PhpSpreadsheet\Reader\Csv;
use think\Db;
use think\Exception;
use think\exception\PDOException;
use think\exception\ValidateException;
use app\common\helper\HttpHelper;

/**
 * 首页接口
 */
class Index extends Api
{
    protected $noNeedLogin = ['*'];
    protected $noNeedRight = ['*'];

    /**
     * 首页
     *
     */
    public function index()
    {
        $this->success('请求成功');
    }

    /**
     * app 版本更新检测
     */
    public function getAppVersion()
    {
        $app_type = $this->request->param("app_type");
        if ($app_type) {
            $where = [];
            $where = [
                "app_type" => $app_type,
                "status" => "1"
            ];
            $version = Db::name("appversion")->where($where)->order("version desc")->find();
            $this->success("最新版本获取成功", $version);
        } else {
            $this->error("未检测到App版本渠道");
        }

    }

    public function test()
    {
        $list = $this->reservoir_tree(0, 0, 0, 0);
        $this->success('', $list);
    }

    public function getPptnR()
    {
        $data = input('post.');
        if (!$data['STCD']) {
            $this->error('测站编码不能为空');
        }
        $res = Db::name('st_pptn_r')->insert($data);
        if ($res) {
            $this->success('添加成功');
        } else {
            $this->error('添加失败');
        }
    }

    /**
     * 巡检轨迹
     * 定时任务
     *
     */
    public function addProject()
    {
        $data = [
            "103.384563,23.330637",
            "103.384005,23.330883",
            "103.383447,23.33113",
            "103.382982,23.331346",
            "103.38237,23.331636",
            "103.381845,23.331882",
            "103.381297,23.332103",
            "103.380892,23.332294",
            "103.380476,23.332445",
            "103.380239,23.332493",
            "103.379767,23.332559",
            "103.379315,23.332621",
            "103.378801,23.332695",
            "103.378501,23.332746",
            "103.378168,23.332835",
            "103.377712,23.332916",
            "103.377271,23.333011",
            "103.376703,23.333088",
            "103.376306,23.333077",
            "103.376074,23.333044",
            "103.375882,23.332989",
            "103.375702,23.332901",
            "103.375569,23.332772",
            "103.375449,23.332636",
            "103.375341,23.332474",
            "103.375209,23.332257",
            "103.375093,23.332048",
            "103.374953,23.331805",
            "103.374825,23.331581",
            "103.374695,23.331353",
            "103.374594,23.331169",
            "103.374478,23.330941",
            "103.374354,23.330724",
            "103.374242,23.330496",
            "103.374118,23.330253",
            "103.373998,23.330059",
            "103.373914,23.329897",
            "103.37383,23.329757",
            "103.373722,23.329577",
            "103.373609,23.329393",
            "103.373637,23.329301",
            "103.373677,23.329143",
            "103.373774,23.328937",
            "103.373842,23.328786",
            "103.373782,23.328653",
            "103.373773,23.328418",
            "103.373902,23.328245",
            "103.373938,23.328091",
            "103.374006,23.327848",
            "103.374134,23.327686",
            "103.374222,23.327477"
        ];
        $ct = count($data);
        $times = date('Y-m-d 09:18:00', time());
        for ($i = 1; $i <= $ct; $i++) {
            $nowaddtime = strtotime(date("Y-m-d H:i:s", strtotime($times) + $i * 60));
            $logs['inspection_staff_id'] = 104;
            $str = $i - 1;
            $lgtarr = explode(',', $data[$str]);
            $logs['lat'] = $lgtarr[0];
            $logs['lng'] = $lgtarr[1];
            $logs['createtime'] = $nowaddtime;
//            echo "<pre>";
//            print_r($logs);
            //保存数据
            $rs = Db::name('inspection_staff_locus')->insertGetId($logs);

        }
        if ($rs != false) {
            echo '处理成功';
        } else {
            echo '处理失败';
        }

    }

    /***
     * 导入库容数据
     * 读取excel数据
     */
    public function getExceldata()
    {
        $filePath = 'xsh.xls';
        die;
        if (!is_file($filePath)) {
            $this->error('找不到数据文件，请重新上传');
        }

        //实例化reader
        $ext = pathinfo($filePath, PATHINFO_EXTENSION);
        if (!in_array($ext, ['xls', 'xlsx'])) {
            $this->error('不支持的数据格式');
        }
        if ($ext === 'xls') {
            $reader = new Xls();
        } else {
            $reader = new Xlsx();
        }
        //读取EXCEl的内容
        $PHPExcel = $reader->load($filePath);
        if (!$PHPExcel) {
            $this->error('表格内没有数据内容');
        }
        $currentSheet = $PHPExcel->getSheet(0);  //读取文件中的第一个工作表
        $allColumn = $currentSheet->getHighestDataColumn(); //取得最大的列号
        $allRow = $currentSheet->getHighestRow(); //取得一共有多少行
        $maxColumnNumber = Coordinate::columnIndexFromString($allColumn);
        $fields = [];
        //获得表第1行栏目名称
        for ($currentRow = 1; $currentRow <= 1; $currentRow++) {
            for ($currentColumn = 1; $currentColumn <= $maxColumnNumber; $currentColumn++) {
                $val = $currentSheet->getCellByColumnAndRow($currentColumn, $currentRow)->getValue();
                $fields[] = $val;
            }
        }
        //获得从第2行起内容列表数组
        for ($currentRow = 1; $currentRow <= $allRow; $currentRow++) {
            $values = [];
            for ($currentColumn = 1; $currentColumn <= $maxColumnNumber; $currentColumn++) {
                $val = $currentSheet->getCellByColumnAndRow($currentColumn, $currentRow)->getValue();
                $values[] = is_null($val) ? '0' : $val;
            }

            //导入数据
            $data['warterdata'] = $values[0];
            $data['CapacityOf'] = $values[1];
            $data['reservoir_id'] = $values[2];
            //判断是否重复导入
            $cks = Db::name('warterdata_capacityof2_copy')
                ->where(['reservoir_id' => $data['reservoir_id'], 'warterdata' => $data['warterdata']])
                ->find();
            if (empty($cks)) {
                Db::name('warterdata_capacityof2_copy')->insertGetId($data);
            }

        }
        $this->success('导入成功');
    }

    /**
     * 2. 小新寨新库容表
     */
    public function dealcapacityof_4()
    {
        die;
        $data = Db::name("warterdata_capacityof2_copy")
            ->where("reservoir_id", 9)
            ->order("warterdata asc")
            ->select();
        $cha_list = [];
        // 启动事务
        Db::startTrans();
        try {
            if (!empty($data)) {
                $sum = count($data);
                foreach ($data as $k => $v) {
                    $new_insert = [];
                    $cha = 0;//库容差
                    $sw_cha = 0;//水位差
                    if ($k + 1 < $sum) {
                        $sw_cha = ($data[$k + 1]["warterdata"] - $v['warterdata']) * 100;//精度到0.01
                        $cha = $data[$k + 1]["CapacityOf"] - $v['CapacityOf'];
                        $cha_list[] = $cha;
                        //dump("+++++++");

                        //dump($sw_cha);
                        $meici_add = $cha / $sw_cha;
                        //dump($meici_add);
                        //dump("=======");

                        //warterdata每次加0.01；
                        for ($i = 1; $i < $sw_cha; $i++) {
                            $warterdata = $v['warterdata'] + $i * 0.01;
                            $new_add = $meici_add * $i;
                            $CapacityOf = bcadd($v['CapacityOf'], $new_add, 4);//两个高精度数相乘保留小数点后3位
                            $new_insert[] = [
                                "warterdata" => $warterdata,
                                "CapacityOf" => round($CapacityOf, 3),
                                "reservoir_id" => $v['reservoir_id']
                            ];
                        }
                        //dump($new_insert);die;

                        Db::name("warterdata_capacityof2_copy")->insertAll($new_insert);

                    } else {
                        $cha = 0;
                        $cha_list[] = $cha;
                    }

                    //dump($cha);

                }
                //dump($cha_list);

            }
            Db::commit();
        } catch (PDOException $e) {
            Db::rollback();
            $this->error($e->getMessage());
        } catch (Exception $e) {
            Db::rollback();
            $this->error($e->getMessage());
        }
    }

    /***
     * 导入库容数据
     * 读取excel数据
     */
    public function getkrExceldata()
    {
        $filePath = 'kr/a.xls';

        if (!is_file($filePath)) {
            $this->error('找不到数据文件，请重新上传');
        }

        //实例化reader
        $ext = pathinfo($filePath, PATHINFO_EXTENSION);
        if (!in_array($ext, ['xls', 'xlsx'])) {
            $this->error('不支持的数据格式');
        }
        if ($ext === 'xls') {
            $reader = new Xls();
        } else {
            $reader = new Xlsx();
        }
        //读取EXCEl的内容
        $PHPExcel = $reader->load($filePath);
        if (!$PHPExcel) {
            $this->error('表格内没有数据内容');
        }
        $currentSheet = $PHPExcel->getSheet(0);  //读取文件中的第一个工作表
        $allColumn = $currentSheet->getHighestDataColumn(); //取得最大的列号
        $allRow = $currentSheet->getHighestRow(); //取得一共有多少行
        $maxColumnNumber = Coordinate::columnIndexFromString($allColumn);
        $fields = [];
        //获得表第1行栏目名称
        for ($currentRow = 1; $currentRow <= 1; $currentRow++) {
            for ($currentColumn = 1; $currentColumn <= $maxColumnNumber; $currentColumn++) {
                $val = $currentSheet->getCellByColumnAndRow($currentColumn, $currentRow)->getValue();
                $fields[] = $val;
            }
        }
        //获得从第2行起内容列表数组
        for ($currentRow = 1; $currentRow <= $allRow; $currentRow++) {
            $values = [];
            for ($currentColumn = 1; $currentColumn <= $maxColumnNumber; $currentColumn++) {
                $val = $currentSheet->getCellByColumnAndRow($currentColumn, $currentRow)->getValue();
                $values[] = is_null($val) ? '0' : $val;
            }

            //导入数据
            $data['warterdata'] = $values[0];
            $data['CapacityOf'] = $values[1];
            $data['reservoir_id'] = $values[2];
            //判断是否重复导入
            $cks = Db::name('warterdata_capacityof_copy')
                ->where(['reservoir_id' => $data['reservoir_id'], 'warterdata' => $data['warterdata']])
                ->find();
            if (empty($cks)) {
                Db::name('warterdata_capacityof_copy')->insertGetId($data);
            }

        }
        $this->success('导入成功');
    }

    /**
     * 2. 更新补全库容表
     */
    public function dealcapacityofnew()
    {
        $data = Db::name("warterdata_capacityof_copy")
            ->where("reservoir_id", 40)
            ->order("warterdata asc")
            ->select();
        $cha_list = [];
        // 启动事务
        Db::startTrans();
        try {
            if (!empty($data)) {
                $sum = count($data);
                foreach ($data as $k => $v) {
                    $new_insert = [];
                    $cha = 0;//库容差
                    $sw_cha = 0;//水位差
                    if ($k + 1 < $sum) {
                        $sw_cha = ($data[$k + 1]["warterdata"] - $v['warterdata']) * 100;//精度到0.01
                        $cha = $data[$k + 1]["CapacityOf"] - $v['CapacityOf'];
                        $cha_list[] = $cha;
                        //dump("+++++++");

                        //dump($sw_cha);
                        $meici_add = $cha / $sw_cha;
                        //dump($meici_add);
                        //dump("=======");

                        //warterdata每次加0.01；
                        for ($i = 1; $i < $sw_cha; $i++) {
                            $warterdata = $v['warterdata'] + $i * 0.01;
                            $new_add = $meici_add * $i;
                            $CapacityOf = bcadd($v['CapacityOf'], $new_add, 4);//两个高精度数相乘保留小数点后3位
                            $new_insert[] = [
                                "warterdata" => $warterdata,
                                "CapacityOf" => round($CapacityOf, 4),
                                "reservoir_id" => $v['reservoir_id']
                            ];
                        }
                        //dump($new_insert);die;

                        Db::name("warterdata_capacityof_copy")->insertAll($new_insert);

                    } else {
                        $cha = 0;
                        $cha_list[] = $cha;
                    }

                    //dump($cha);

                }
                dump($cha_list);

            }
            Db::commit();
        } catch (PDOException $e) {
            Db::rollback();
            $this->error($e->getMessage());
        } catch (Exception $e) {
            Db::rollback();
            $this->error($e->getMessage());
        }
    }
}