<?php

namespace app\api\controller\v7\pipes;

use app\admin\model\pipes\Category;
use app\admin\model\pipes\Line;
use app\admin\model\pipes\Route;
use app\admin\model\pipes\Section;
use app\admin\model\pipes\Waterhead;
use app\admin\model\pipes\Well;
use app\common\controller\Api;
use think\Db;

/**
 * 管网相关接口
 * Class Network
 * @package app\api\controller\v7\pipes
 */
class Network extends Api
{
    protected $noNeedLogin = ['*'];
    protected $noNeedRight = ['*'];

    public function _initialize()
    {
        parent::_initialize();
    }

    //获取管径分类列表
    public function category(){
        $categoryModel = new Category();
        $cateList = $categoryModel->field('id,start_diameter,end_diameter,pipe_color')->order(['id' => 'asc'])->select();
        foreach ($cateList as $cate){
            if ($cate['start_diameter'] == 0){
                $cate['title'] = '管径<'.$cate['end_diameter'];
            }
            if ($cate['end_diameter'] == 0){
                $cate['title'] = '管径>'.$cate['start_diameter'];
            }
            if ($cate['start_diameter'] != 0 && $cate['end_diameter'] != 0){
                $cate['title'] = $cate['start_diameter'].'<管径<'.$cate['end_diameter'];
            }
        }
        $this->success('成功', $cateList);
    }

    //获取管网列表
    public function lists()
    {
        $params = $this->request->get();
        $where = [];
        if (!empty($params['query'])) {
            $where['network_name|network_code'] = ['LIKE', "%{$params['query']}%", 'OR'];
        }
        $list = (new \app\admin\model\pipes\Network())
            ->where($where)
            ->select();
        $this->success('成功', $list);
    }

    //获取路线列表
    public function getRoute()
    {
        $params = $this->request->get();
        $where = [];
        if (!empty($params['query'])) {
            $where['route.route_name|route.route_code'] = ['LIKE', "%{$params['query']}%", 'OR'];
        }

        if (!empty($params['network_id'])) {
            $where['route.network_id'] = $params['network_id'];
        } else {
            //没有管网ID参数则默认获取第一个管网的ID
            $networkModel = new \app\admin\model\pipes\Network();
            $find = $networkModel->field('id')->order(['id' => 'asc'])->find();
            if ($find) {
                $where['route.network_id'] = $find['id'];
            }
        }

        $list = (new Route())
            ->with('network')
            ->where($where)
            ->select();
        $this->success('成功', $list);
    }

    //获取管线列表
    public function getLine()
    {
        $params = $this->request->post();
        $where = [];
        if (!empty($params['query'])) {
            $where['line.line_start_name|line.line_start_name|line.line_code'] = ['LIKE', "%{$params['query']}%", 'OR'];
        }
        if (!empty($params['network_id'])) {
            $where['line.network_id'] = $params['network_id'];
        } else {
            //没有管网ID参数则默认获取第一个管网的ID
            $networkModel = new \app\admin\model\pipes\Network();
            $find = $networkModel->field('id')->order(['id' => 'asc'])->find();
            if ($find) {
                $where['line.network_id'] = $find['id'];
            }
        }
        if (!empty($params['route_id'])) {
            $where["route_id"] = $params['route_id'];
        }
        $whereOr = [];
        if (!empty($params['line_diameter_out'])) {
            if (!is_array($params['line_diameter_out'])) {
                $this->error('line_diameter_out参数格式错误');
            }
            $whereOr = $params['line_diameter_out'];
        }
        $list = (new Line())
            ->field('line.*,n.network_name,r.route_name')
            ->alias('line')
            ->join('pipes_network n', 'n.id=line.network_id', 'LEFT')
            ->join('pipes_route r', 'r.id=line.route_id', 'LEFT')
            ->where($where)
            ->where(function ($query) use ($whereOr) {
                if (!empty($whereOr)){
                    foreach ($whereOr as $wh){
                        if (is_array($wh)){
                            $start_diameter = $wh[0];
                            $end_diameter = $wh[1];
                        }else{
                            $diameterArr = explode(',', $wh);
                            $start_diameter = $diameterArr[0];
                            $end_diameter = $diameterArr[1];
                        }
                        if ($end_diameter == 0){
                            $query->whereOr(['line.line_diameter_out' => ['egt', $start_diameter]]);
                        }else{
                            $query->whereOr(['line.line_diameter_out' => ['between', $wh]]);
                        }
                    }
                }
            })
            ->select();
        $this->success('成功', $list);
    }

    //获取管线列表
    public function getLineForScreen()
    {
        $params = $this->request->post();
        $whereSelect = [];
        if (!empty($params['line_diameter_out']) && !is_array($params['line_diameter_out'])) {
            $whereSelect["line_diameter_out"] = ["in", $params['line_diameter_out']];
        }

        $where = [];
        if (!empty($params['network_id'])) {
            $network_id = $params['network_id'];
            $where['id'] = ["=", $network_id];
        } else {
            //没有管网ID参数则默认获取第一个管网的ID
            $network_id = Db::name("pipes_network")->where("deletetime", null)->order("id asc")->value("id");
            if ($network_id) {
                $where['id'] = ["=", $network_id];
            }
        }
        $network = Db::name("pipes_network")->where($where)->where("deletetime", null)->field("id,network_name as name")->select();
        if (!empty($network)) {
            foreach ($network as $k => $v) {
                //找线路
                $where2 = [];
                $where2["network_id"] = ["=", $v['id']];
                if (!empty($params['route_id'])) {
                    $where2["id"] = $params['route_id'];
                }
                $route = Db::name("pipes_route")->where($where2)->where("deletetime", null)->field("id,route_name as name")->select();
                if (!empty($route)) {
                    foreach ($route as $k1 => $v1) {
                        //根据线路去找管线
                        $where3 = [];
                        $where3["network_id"] = ["=", $v['id']];
                        $where3["route_id"] = ["=", $v1['id']];
                        $line = Db::name("pipes_line")->where($where3)->where($whereSelect)->where("deletetime", null)->select();
                        if(!empty($line)){
                            foreach ($line as $k3=>$v3){
                                $line[$k3]["data"] =[[$v3["line_start_lng"],$v3['line_start_lat']],[$v3["line_end_lng"],$v3['line_end_lat']]];
                            }
                        }
                        $route[$k1]["line_list"] = $line ? $line : [];
                    }
                }
                $network[$k]["route_list"] = $route ? $route : [];
            }
            $this->success("数据获取成功", $network);

        } else {
            $this->error("暂无管网信息");
        }


//        $whereOr = [];
//        if (!empty($params['line_diameter_out'])) {
//            if (!is_array($params['line_diameter_out'])) {
//                $this->error('line_diameter_out参数格式错误');
//            }
//            $whereOr = $params['line_diameter_out'];
//        }

//        $list = (new Line())
//            ->with('network,route')
//            ->where($where)
//            ->where(function ($query) use($whereOr) {
//                foreach ($whereOr as $wh){
//                    $query->whereOr(['line.line_diameter_out' => ['between', $wh]]);
//                }
//            })
//            ->select();
    }

    //获取管线列表
    public function getLineForScreenForTest()
    {
        $param = $this->request->param();
        if(empty($param['route_id'])){
            $route_id =1;
        }else{
            $route_id=$param['route_id'];
        }
        $data = Db::name("pipes_line")->where("route_id",$route_id)->field("line_start_lng as lon,line_start_lat as lat,line_start_height as hight")->select();
        if(!empty($data)){
            $rdata = "";
            foreach ($data as $k=>$v){
                $rdata .= "Cesium.Cartesian3.fromDegrees(".$v['lon'].",".$v['lat'].",".$v['hight']."),";
            }
        }

        $this->success("数据获取成功", $rdata);
    }

    //获取水源列表
    public function getWaterhead()
    {
        $params = $this->request->get();
        $where = [];
        if (!empty($params['query'])) {
            $where['waterhead.waterhead_name|waterhead.waterhead_code'] = ['LIKE', "%{$params['query']}%", 'OR'];
        }

        if (!empty($params['network_id'])) {
            $where['waterhead.network_id'] = $params['network_id'];
        } else {
            //没有管网ID参数则默认获取第一个管网的ID
            $networkModel = new \app\admin\model\pipes\Network();
            $find = $networkModel->field('id')->order(['id' => 'asc'])->find();
            if ($find) {
                $where['waterhead.network_id'] = $find['id'];
            }
        }

        $list = (new Waterhead())
            ->with('network')
            ->where($where)
            ->select();
        $this->success('成功', $list);
    }

    //获取放水口列表
    public function getWell()
    {
        $params = $this->request->get();
        $where = [];
        if (!empty($params['query'])) {
            $where['well.well_name|well.well_code'] = ['LIKE', "%{$params['query']}%", 'OR'];
        }

        if (!empty($params['network_id'])) {
            $where['well.network_id'] = $params['network_id'];
        } else {
            //没有管网ID参数则默认获取第一个管网的ID
            $networkModel = new \app\admin\model\pipes\Network();
            $find = $networkModel->field('id')->order(['id' => 'asc'])->find();
            if ($find) {
                $where['well.network_id'] = $find['id'];
            }
        }

        $list = (new Well())
            ->with('network')
            ->where($where)
            ->select();
        $this->success('成功', $list);
    }

    //管网统计
    public function statistics()
    {
        $params = $this->request->get();
        $where = [];
        if (!empty($params['network_id'])) {
            $where['network_id'] = $params['network_id'];
        } else {
            //没有管网ID参数则默认获取第一个管网的ID
            $networkModel = new \app\admin\model\pipes\Network();
            $find = $networkModel->field('id')->order(['id' => 'asc'])->find();
            if ($find) {
                $where['network_id'] = $find['id'];
            }
        }

        //管网总里程
        $routeModel = new Route();
        $networkMileage = $routeModel
            ->where($where)
            ->sum('route_mileage');
        //里程段总数
        $sectionModel = new Section();
        $sectionCount = $sectionModel
            ->where($where)
            ->count();
        //管线总数
        $lineModel = new Line();
        $lineCount = $lineModel
            ->where($where)
            ->count();
        //放水口总数
        $wellModel = new Well();
        $wellCount = $wellModel
            ->where($where)
            ->count();
        $data = [
            'network_mileage' => $networkMileage,
            'section_num' => $sectionCount,
            'line_num' => $lineCount,
            'well_num' => $wellCount
        ];
        $this->success('成功', $data);
    }

    //根据路线返回所有的管线信息
    public function route(){
        $params = $this->request->param();
        if (!empty($params['route_ids'])){
            $where['id'] = ['in', $params['route_ids']];
        }else{
            //不传该参数，或者为空数组，则返回空数据
            $this->success('成功', []);
        }
        if (!empty($params['network_id'])){
            $where['network_id'] = $params['network_id'];
        }else{
            //没有管网ID参数则默认获取第一个管网的ID
            $networkModel = new \app\admin\model\pipes\Network();
            $find = $networkModel->field('id')->order(['id' => 'asc'])->find();
            if ($find){
                $where['network_id'] = $find['id'];
            }
        }
//        if (!empty($params['line_diameter_out'])){
//            if (!is_array($params['line_diameter_out'])){
//                $this->error('line_diameter_out参数格式错误');
//            }
//            $whereOr = $params['line_diameter_out'];
//        }else{
//            $this->success('',[]);
//        }
        $lineModel = new Line();
        $routeModel = new \app\admin\model\pipes\Route();
        $routeList = $routeModel
            ->where($where)
            ->select();
        foreach ($routeList as $route){
            $lines = $lineModel
                ->field('id,line_start_lng,line_start_lat,line_end_lng,line_end_lat')
                ->where(['route_id' => $route['id']])
//                ->where(function ($query) use($whereOr) {
//                    if (!empty($whereOr)){
//                        foreach ($whereOr as $wh){
//                            if (is_array($wh)){
//                                $start_diameter = $wh[0];
//                                $end_diameter = $wh[1];
//                            }else{
//                                $diameterArr = explode(',', $wh);
//                                $start_diameter = $diameterArr[0];
//                                $end_diameter = $diameterArr[1];
//                            }
//                            if ($end_diameter == 0){
//                                $query->whereOr(['line_diameter_out' => ['egt', $start_diameter]]);
//                            }else{
//                                $query->whereOr(['line_diameter_out' => ['between', $wh]]);
//                            }
//                        }
//                    }
//                })
                ->order(['id' => 'asc'])
                ->select();
            //查询所有管线坐标
            $positionArr = [];
            foreach ($lines as $line){
                $positionArr[] = [$line['line_start_lng'], $line['line_start_lat']];
                $positionArr[] = [$line['line_end_lng'], $line['line_end_lat']];
            }
            $route['position_arr'] = $positionArr;
            //查询第一条管线信息
            $start_line = $lineModel
                ->where(['route_id' => $route['id']])
                ->order(['id' => 'asc'])
                ->find();
            //查询最后一条管线信息
            $end_line = $lineModel
                ->where(['route_id' => $route['id']])
                ->order(['id' => 'desc'])
                ->find();
            $route['position_start_info'] = $start_line;
            $route['position_end_info'] = $end_line;
        }
        $this->success('成功', $routeList);
    }
    //根据里程段返回所有的管线信息
    public function section(){
        $params = $this->request->param();
        if (!empty($params['network_id'])){
            $where['network_id'] = $params['network_id'];
        }else{
            //没有管网ID参数则默认获取第一个管网的ID
            $networkModel = new \app\admin\model\pipes\Network();
            $find = $networkModel->field('id')->order(['id' => 'asc'])->find();
            if ($find){
                $where['network_id'] = $find['id'];
            }
        }
        if (!empty($params['line_diameter_out'])){
            $w=[];
            $w["id"] = ["in",$params['line_diameter_out']];
            $category = Db::name("pipes_category")->where($w)->field("start_diameter,end_diameter")->select();
            $line_diameter_out = [];
            if(!empty($category)){
                foreach ($category as $k=>$v){
                    $line_diameter_out[$k] = $v['start_diameter'].",".$v['end_diameter'];
                }
            }
            $whereOr = $line_diameter_out;
        }else{
            //没这个条件则返回空数据
            $this->success('',[]);
        }
        $lineModel = new Line();
        $sectionModel = new Section();
        $sectionList = $sectionModel
            ->where($where)
            ->where(function ($query) use($whereOr) {
                if (!empty($whereOr)){
                    foreach ($whereOr as $wh){
                        if (is_array($wh)){
                            $start_diameter = $wh[0];
                            $end_diameter = $wh[1];
                        }else{
                            $diameterArr = explode(',', $wh);
                            $start_diameter = $diameterArr[0];
                            $end_diameter = $diameterArr[1];
                        }
                        if ($end_diameter == 0){
                            $query->whereOr(['line_diameter_out' => ['egt', $start_diameter]]);
                        }else{
                            $query->whereOr(['line_diameter_out' => ['between', $wh]]);
                        }
                    }
                }
            })
            ->select();

        $sectionListArr = [];
        foreach ($sectionList as $section){
            $lines = $lineModel
                ->field('id,line_start_lng,line_start_lat,line_end_lng,line_end_lat')
                ->where(['section_id' => $section['id']])
                ->order(['id' => 'asc'])
                ->select();
            //查询所有管线坐标
            $positionArr = [];
            foreach ($lines as $line){
                $positionArr[] = [$line['line_start_lng'], $line['line_start_lat']];
                $positionArr[] = [$line['line_end_lng'], $line['line_end_lat']];
            }
            $section['position_arr'] = $positionArr;
            //查询第一条管线信息
            $start_line = $lineModel
                ->where(['section_id' => $section['id']])
                ->order(['id' => 'asc'])
                ->find();
            //查询最后一条管线信息
            $end_line = $lineModel
                ->where(['section_id' => $section['id']])
                ->order(['id' => 'desc'])
                ->find();
            $section['position_start_info'] = $start_line;
            $section['position_end_info'] = $end_line;
            if (!empty($positionArr)){
                $sectionListArr[] = $section;
            }
        }
        $this->success('成功', $sectionListArr);
    }

    //获取里程段列表（供前端添加编辑用作选项）
    public function getSectionList(){
        $params = $this->request->get();
        if (!empty($params['network_id'])){
            $where['network_id'] = $params['network_id'];
        }else{
            //没有管网ID参数则默认获取第一个管网的ID
            $networkModel = new \app\admin\model\pipes\Network();
            $find = $networkModel->field('id')->order(['id' => 'asc'])->find();
            if ($find){
                $where['network_id'] = $find['id'];
            }
        }
        $sectionModel = new Section();
        $sectionList = $sectionModel
            ->where($where)
            ->select();
        $this->success('成功', $sectionList);
    }
}