<?php
/**
 * Created by PhpStorm.
 * User: pcl
 * Date: 2022/7/28
 * Time: 15:32
 * 河长制接口River
 */

namespace app\api\controller\v1;

use think\Db;
use think\Exception;
use think\exception\PDOException;
use think\Request;
use fast\Distance;

class River extends Base
{

    public function __construct(Request $request = null)
    {
        parent::__construct($request);
    }

    /***
     * 获得当前用户身份
     *
     */
    public function getUserLevel()
    {
        $uid = $this->auth->id;
        if (empty($uid)) {
            $this->error('请先登录');
        }
        $user = $this->userLevel;

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

    /***
     * 用户上报问题
     *
     */
    public function askAdd()
    {
        if ($this->request->isPost()) {
            $uid = $this->auth->id;
            if (empty($uid)) {
                $this->error('请先登录');
            }
            $data = $this->request->post();
            if (empty($data['river_id'])) {
                $this->error('请选择河段');
            }
            if (empty($data['cat_id'])) {
                $this->error('请选择爆料分类');
            }
            if (empty($data['title'])) {
                $this->error('请问题描述内容');
            }
            if (!empty($data['image'])) {
                $data['image'] = implode(',', $data['image']);
            } else {
                unset($data['image']);
            }
            if (!empty($data['vdourl'])) {
                $data['vdourl'] = implode(',', $data['vdourl']);
            } else {
                unset($data['vdourl']);
            }
            $data['createtime'] = time();
            $data['ask_com'] = 1;
            $data['user_id'] = $uid;
            //上级河段
            $river = Db::name('river_list')
                ->where(['id' => $data['river_id']])
                ->field('id,river_pid')
                ->find();
            $data['river_pid'] = $river['river_pid'];
            $rs = Db::name('river_asklist')->insertGetId($data);
            if ($rs != false) {
                $this->success('上报成功');
            } else {
                $this->error('提交失败，请重试');
            }
        }
    }

    /***
     * 我上报的问题列表
     */
    public function getMyAskList()
    {
        if ($this->request->isPost()) {
            $uid = $this->auth->id;
            if (empty($uid)) {
                $this->error('请先登录');
            }
            $page = $this->request->post('page', 1);
            $total = $this->request->post('total', 12);
            $type = $this->request->post('type', '');

            $wh['a.user_id'] = ['=', $uid];
            if ($type > 0) {
                $wh['a.status'] = ['=', $type];
            }
            $list = Db::name('river_asklist')
                ->alias('a')
                ->join('river_ask_cat ac', 'a.cat_id=ac.id')
                ->join('river_list l', 'a.river_id=l.id')
                ->where($wh)
                ->field('a.id,a.title,a.image,a.vdourl,a.status,a.address,a.lat,a.lng,a.createtime,ac.catname,l.name')
                ->order("a.id desc")
                ->paginate($total, false, ['page' => $page])
                ->toArray();
            if (!empty($list)) {
                foreach ($list['data'] as $k => $v) {
                    $list['data'][$k]['createtime'] = setdateTimes($v['createtime']);
                    if (!empty($v['image'])) {
                        $imgarr = explode(',', $v['image']);
                        $list['data'][$k]['image'] = full_image($imgarr);
                    }
                    if (!empty($v['vdourl'])) {
                        $vdourlarr = explode(',', $v['vdourl']);
                        $list['data'][$k]['vdourl'] = full_image($vdourlarr);
                    }
                }
            }

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

    /***
     * 我上报的问题记录详情
     */
    public function myAskInfo()
    {
        if ($this->request->isPost()) {
            $uid = $this->auth->id;
            if (empty($uid)) {
                $this->error('请先登录');
            }
            $aid = $this->request->post('aid', 0);
            $row = Db::name('river_asklist')
                ->alias('a')
                ->join('river_ask_cat ac', 'a.cat_id=ac.id')
                ->join('river_list l', 'a.river_id=l.id')
                ->where(['a.user_id' => $uid, 'a.id' => $aid])
                ->field('a.id,a.title,a.image,a.vdourl,a.status,a.address,a.lat,a.lng,a.createtime,ac.catname,l.name')
                ->find();
            if (empty($row)) {
                $this->error('内容不存在');
            }
            //处理图片和视频地址
            $row['createtime'] = setdateTimes($row['createtime']);
            if (!empty($row['image'])) {
                $imgarr = explode(',', $row['image']);
                $row['image'] = full_image($imgarr);
            }
            if (!empty($row['vdourl'])) {
                $vdourlarr = explode(',', $row['vdourl']);
                $row['vdourl'] = full_image($vdourlarr);
            }

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

    /****
     * 判断当前用户是否有进行中的巡河
     *
     */
    public function getNowPatrolStu()
    {
        if ($this->request->isPost()) {
            $uid = $this->auth->id;
            if (empty($uid)) {
                $this->error('请先登录');
            }
            $wh['user_id'] = ['=', $uid];
            $wh['endtime'] = ['=', 0];
            $cks = Db::name('river_patrol_list')
                ->where($wh)
                ->find();
            if (empty($cks)) {
                //没有进行中的巡河
                $data['stu'] = 2;
                $data['stu_msg'] = '当前没有进行中的巡河';
                $this->success('获取成功', $data);
            } else {
                //河的名称
                $river = Db::name('river_list')
                    ->where(['id' => $cks['river_id']])
                    ->field('id,name')
                    ->find();
                $cks['river_name'] = $river['name'];
                //上报的坐标列表
                $latList = Db::name('river_patrol_logs')
                    ->where(['ordersn' => $cks['ordersn'], 'river_id' => $cks['river_id']])
                    ->where("lat>'0'")
                    ->order('id', 'asc')
                    ->select();
                $lat_list = [];
                if (!empty($latList)) {
                    foreach ($latList as $k => $v) {
                        $lat_list[$k]['latitude'] = $v['lat'];
                        $lat_list[$k]['longitude'] = $v['lng'];
                    }
                }
                $cks['lat_list'] = $lat_list;
                $cks['stu'] = 1;
                $cks['stu_msg'] = '巡河中';
                $this->success('获取成功', $cks);
            }
        }
    }

    /***
     * 点开始巡河
     * 生成巡河记录，保存坐标
     * 生成这次巡河订单id
     */
    public function patrolRivelStart()
    {
        if ($this->request->isPost()) {
            $uid = $this->auth->id;
            if (empty($uid)) {
                $this->error('请先登录');
            }
            //判断是否有未结束巡河状态
            $data = $this->request->post();
            if (empty($data['river_id'])) {
                $this->error('请选择河段');
            }
            $pcks = Db::name('river_patrol_list')
                ->where(['user_id' => $uid, 'endtime' => 0])
                ->select();
            if (!empty($pcks)) {
                $this->error('存在未结束的巡河状态');
            }
            //生成订单id
            $arr['ordersn'] = getOrderSn();
            $arr['river_id'] = $data['river_id'];
            $arr['user_id'] = $uid;
            $arr['createtime'] = time();
            $arr['daytime'] = date('Ymd', time());
            $rs = Db::name('river_patrol_list')->insertGetId($arr);
            if ($rs != false) {
                //保存巡河坐标日志
                $logs['user_id'] = $uid;
                $logs['createtime'] = time();
                $logs['ordersn'] = $arr['ordersn'];
                $logs['river_id'] = $data['river_id'];
                $logs['lat'] = $data['lat'];
                $logs['lng'] = $data['lng'];
                Db::name('river_patrol_logs')->insertGetId($logs);
                $this->success('成功', $logs['ordersn']);
            } else {
                $this->error('操作失败');
            }
        }
    }

    /***
     * 巡河中 上报坐标记录
     *
     */
    public function addlogs()
    {
        if ($this->request->isPost()) {
            $uid = $this->auth->id;
            if (empty($uid)) {
                $this->error('请先登录');
            }
            //判断是否有未结束巡河状态
            $data = $this->request->post();
            if (empty($data['river_id'])) {
                $this->error('请选择河段');
            }
            $cks = Db::name('river_patrol_list')
                ->where(['user_id' => $uid, 'river_id' => $data['river_id'], 'ordersn' => $data['ordersn']])
                ->find();
            if (empty($cks)) {
                $this->error('参数错误');
            }
            if (!empty($cks) && $cks['endtime'] > 0) {
                $this->error('巡河已经结束了');
            }

            //保存巡河坐标日志
            $logs['user_id'] = $uid;
            $logs['createtime'] = time();
            $logs['ordersn'] = $data['ordersn'];
            $logs['river_id'] = $data['river_id'];
            $logs['lat'] = $data['lat'];
            $logs['lng'] = $data['lng'];
            $rs = Db::name('river_patrol_logs')->insertGetId($logs);
            if ($rs !== false) {
                $this->success('保存成功', $rs);
            } else {
                $this->success('保存失败', $rs);
            }
        }
    }

    /***
     * 结束巡河
     *
     */
    public function endPatrolRivel()
    {
        if ($this->request->isPost()) {
            $uid = $this->auth->id;
            if (empty($uid)) {
                $this->error('请先登录');
            }
            //判断是否有未结束巡河状态
            $data = $this->request->post();
            if (empty($data['river_id'])) {
                $this->error('请选择河段');
            }
            $cks = Db::name('river_patrol_list')
                ->where(['user_id' => $uid, 'river_id' => $data['river_id'], 'ordersn' => $data['ordersn']])
                ->find();
            if (empty($cks)) {
                $this->error('参数错误');
            }
            if (!empty($cks) && $cks['endtime'] > 0) {
                $this->error('巡河已经结束了');
            }
            //更新巡河状态
            $uptime['endtime'] = time();
            $uptime['updatetime'] = time();
            //计算巡河时长
            $timeAll = time_diff($cks['createtime'], time());
            $uptime['river_time'] = json_encode($timeAll['time'], JSON_UNESCAPED_UNICODE);
            $uptime['river_time_all'] = $timeAll['timeall'];
            //计算巡河距离
            //开始的坐标
            $stratLat = Db::name('river_patrol_logs')
                ->where(['user_id' => $uid, 'river_id' => $data['river_id'], 'ordersn' => $data['ordersn']])
                ->find();
            $obj = new Distance();
            $enddis = $obj->get_distance_by_geo($stratLat['lat'], $stratLat['lng'], $data['lat'], $data['lng']);
            $uptime['river_distance'] = round($enddis, 2);
            $row = Db::name('river_patrol_list')
                ->where(['user_id' => $uid, 'river_id' => $data['river_id'], 'ordersn' => $data['ordersn']])
                ->update($uptime);
            if ($row != false) {
                //保存巡河坐标日志
                $logs['user_id'] = $uid;
                $logs['createtime'] = time();
                $logs['ordersn'] = $data['ordersn'];
                $logs['river_id'] = $data['river_id'];
                $logs['lat'] = $data['lat'];
                $logs['lng'] = $data['lng'];
                $rs = Db::name('river_patrol_logs')->insertGetId($logs);
                if ($rs !== false) {
                    $this->success('操作成功', $rs);
                } else {
                    $this->success('操作失败', $rs);
                }
            }
        }
    }

    /***
     * 我的巡河记录
     *
     */
    public function myPatrolLogs()
    {
        if ($this->request->isPost()) {
            $uid = $this->auth->id;
            if (empty($uid)) {
                $this->error('请先登录');
            }
            $page = $this->request->post('page', 1);
            $total = $this->request->post('total', 12);

            $wh['r.user_id'] = ['=', $uid];

            $list = Db::name('river_patrol_list')
                ->alias('r')
                ->join('river_list l', 'r.river_id=l.id')
                ->join('user u', 'r.user_id=u.id')
                ->where($wh)
                ->field('r.id,r.createtime,r.endtime,r.ordersn,l.name,u.username,u.mobile,u.avatar,u.group_id,r.river_time,r.river_distance')
                ->order('r.id', 'desc')
                ->paginate($total, false, ['page' => $page])
                ->toArray();
            if (!empty($list)) {
                foreach ($list['data'] as $k => $v) {
                    $ctime = $v['createtime'];
                    $list['data'][$k]['createtime'] = setdateTimes($v['createtime']);

                    //状态判断
                    if ($v['endtime'] > 0) {
                        $endtime = $v['endtime'];
                        $list['data'][$k]['endtime'] = setdateTimes($v['endtime']);
                        $list['data'][$k]['pstu'] = 1;
                        $list['data'][$k]['pstu_msg'] = '巡河结束';
                    } else {
                        $endtime = time();
                        $list['data'][$k]['pstu'] = 0;
                        $list['data'][$k]['pstu_msg'] = '巡河中';
                    }
                    //巡河时长
                    $list['data'][$k]['timeAll'] = json_decode($v['river_time'], true);
                }
            }

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

    /****
     * 我的巡河记录详情
     *
     */
    public function myPatrolInfo()
    {
        if ($this->request->isPost()) {
            $uid = $this->auth->id;
            if (empty($uid)) {
                $this->error('请先登录');
            }
            $id = $this->request->post('id', 0);
            $wh['r.user_id'] = ['=', $uid];
            $wh['r.id'] = ['=', $id];
            $list = Db::name('river_patrol_list')
                ->alias('r')
                ->join('river_list l', 'r.river_id=l.id')
                ->join('user u', 'r.user_id=u.id')
                ->where($wh)
                ->field('r.id,r.createtime,r.endtime,r.ordersn,l.name,u.username,u.mobile,u.avatar,u.group_id,r.river_time,r.river_distance')
                ->find();
            if (empty($row)) {
                $this->error('内容不存在');
            }
            if (!empty($list)) {
                $ctime = $list['createtime'];
                $list['createtime'] = setdateTimes($list['createtime']);

                //状态判断
                if ($list['endtime'] > 0) {
                    $endtime = $list['endtime'];
                    $list['endtime'] = setdateTimes($list['endtime']);
                    $list['pstu'] = 1;
                    $list['pstu_msg'] = '巡河结束';
                } else {
                    $endtime = time();
                    $list['pstu'] = 0;
                    $list['pstu_msg'] = '巡河中';
                }
                //计算巡河时长
                $list['timeAll'] = json_decode($list['river_time'], true);
            }

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

}