<?php

namespace app\api\controller\inspection;
use app\common\controller\Api;
use think\Db;
/**
 * 员工接口
 */
class Warning extends Api
{
    // 无需登录的接口,*表示全部
//    protected $noNeedLogin = ['*'];
    // 无需鉴权的接口,*表示全部
    protected $noNeedRight = ['*'];

    public function _initialize()
    {
        parent::_initialize(); // TODO: Change the autogenerated stub
        $this->model = new \app\admin\model\inspection\Warning();
    }

    public function add()
    {
        if ($this->request->isPost()) {
            $params  = $this->request->post();
            if(!$params['title']){
              $this->error('隐患标题为空');
            }
            if(!$params['message']){
              $this->error('隐患内容为空');
            }
            $row = Db::name('inspection_staff')
                ->alias('staff')
                ->join('inspection_area area','area.reservoir_id=staff.reservoir_id','LEFT')
                ->field('staff.id as staff_id,area.id as area_id')
                ->where('staff.user_id',$this->auth->id)
                ->find();
            if (!$row) {
                $this->error('员工信息不存在');
            }
            $params['staff_id'] = $row['staff_id'] ;
            $params['area_id'] = $row['area_id'] ;
            $params['cover_images'] = implode(",",$this->request->post("cover_images/a"));
            $params['createtime'] = time();
            $result = $this->model->allowField(true)->save($params);
            if (!$result) {
                $this->error('网络繁忙');
            }
            $this->success('提交成功',$params);
        }
    }

    public function getInfo($id){
        $info = Db::name('inspection_warning')
            ->field('id,title,message,status,cover_images,FROM_UNIXTIME(createtime,"%Y-%m-%d %H:%i") as createtime')
            ->where('id',$id)
            ->find();
        $reply = Db::name('inspection_warning_reply')
            ->alias('r')
            ->join('inspection_staff s','s.id = r.staffid','LEFT')
            ->where('wid',$id)
            ->field('FROM_UNIXTIME(r.createtime,"%Y-%m-%d %H:%i:%s") as createtime,r.reply,s.staff_name,r.status')
            ->select();
        $info['list'] = $reply;
        if($info['cover_images']){
            $cover_images = explode(',',$info['cover_images']);
            if(!empty($cover_images)){
                foreach ($cover_images as $k=>$v){
                    if (substr($v, 0, 4) != 'http') {
                        $cover_images[$k] = 'https://qiniu.ynzhsk.cn' .$v;
                    }
                }

            }
            $info['cover_images'] = $cover_images;
        }
        $this->success('',$info);
    }

    public function getList(){
        $map = [];
        if(input('post.status')){
            $map['status'] = input('post.status');
        }
        if(input('post.ismine')){
            $staff_id = Db::name('inspection_staff')->where('user_id',$this->auth->id)->value('id');
            if(!$staff_id){
                $this->error('员工信息不存在');
            }
            $map['w.staff_id'] =['=',$staff_id];
        }

        if(input('post.time')){
            $createtime = strtotime(input('post.time'));
            $createtimeend = strtotime(input('post.time').' 23:59:59');
            $map['w.createtime'] = ['between',[$createtime,$createtimeend]];
        }
        $page = input('post.page')?input('post.page'):1;
        $list = Db::name('inspection_warning')
            ->alias('w')
            ->join('inspection_area a','w.area_id = a.id',"LEFT")
            ->field('w.createtime,w.id,a.area_name,w.status,w.message,w.title,w.cover_images')
            ->where($map)
            ->order('w.createtime desc')
//            ->page($page,10)
            ->select();
        foreach ($list as $k => &$v){
            $v['count'] = $this->getReply($v['id']);
            $v['createtime'] = date('Y-m-d H:i',$v['createtime']);
            if($v['cover_images']){
                $cover_images = explode(',',$v['cover_images'])[0];
                if (substr($cover_images, 0, 4) != 'http') {
                    $cover_images = 'https://qiniu.ynzhsk.cn' .$cover_images;
                }
                $v['cover_images'] = $cover_images;
            }
        }
        $this->success('',$list);
    }
    //获取隐患回复数量
    //$wid 隐患id
    public function getReply($wid){
        $count = Db::name('inspection_warning_reply')->where('wid',$wid)->count();
        return $count;
    }
    //隐患回复
    //隐患id
    public function reply($id){
        if(!input('post.reply')){
           $this->error('回复内容不能为空');
        }
        $status = Db::name('inspection_warning_reply')->where('wid',$id)->where('status','2')->find();
        if($status){
           $this->error('该隐患已解决');
        }
        $status = Db::name('inspection_warning_reply')->where('wid',$id)->where('status','3')->find();
        if($status){
           $this->error('该隐患已回复');
        }
        $info = Db::name('inspection_warning_reply')->where('wid',$id)->where('status','0')->find();
        unset($info['id']);
        $info['wid'] = $id;
        $info['staffid'] = Db::name('inspection_staff')->where('user_id',$this->auth->id)->value('id');
        $info['status'] = '3';
        $info['createtime'] = time();
        $info['reply'] = input('post.reply');
        Db::name('inspection_warning_reply')->insert($info);
        $this->success('回复成功');
    }
}