<?php
// +----------------------------------------------------------------------
// | ThinkCMF [ WE CAN DO IT MORE SIMPLE ]
// +----------------------------------------------------------------------
// | Copyright (c) 2013-2017 http://www.thinkcmf.com All rights reserved.
// +----------------------------------------------------------------------
// | Author: Dean <zxxjjforever@163.com>
// +----------------------------------------------------------------------
namespace api\home\controller;

use think\Db;
use think\Validate;
use cmf\controller\RestBaseController;
use app\portal\model\ExerciseModel;
use app\portal\model\ConfirmImageModel;
/**
 * @title 演习
 */
class ExerciseController extends RestBaseController
{

    /**
     * @title 甲方申请演习列表
     * @description 接口说明
     * @author 开发者
     * @url /api/home/exercise/exerciseList
     * @method GET
     *
     * @header name:token require:1 default: desc:header
     *
     * @param name:page type:inter require:1 default: other desc:分页页码
     * @param name:project_id type:inter require:1 default: other desc:项目id
     * @param name:status type:inter require:1 default: other desc:切换状态（-1：全部 0：待确认，1：进行中，2：已完成）
     * @return data:演习列表@
     * @data id:演习id uid:甲方提交人id status:培训状态（0：待乙方确认，1：进行中，2：已完成 ） user_login:甲方发起人 b_staff:乙方确认员工 project_name:项目名称 exercise_time:演习时间 address:演习地点 confirm:是否有确认按钮（0：无，1：有） finish:是否有确认完成按钮（0：无，1：有）
     * @return page:当前页数
     * @return total_page:总页数
     */
    public function exerciseList(){
        if($this->request->isGet()){
            $page = $this->request->get('page');
            $status = $this->request->get('status');//切换状态（-1：全部，0：待确认，1：进行中，2：已完成）
            $project_id = $this->request->get('project_id');

            $limit = config('site.limit');
            $rule = config('site.pages_list');
            $validate = new Validate($rule['rule'],$rule['msg']);
            if (!$validate->check(['page'=>$page,'status'=>$status,'project_id'=>$project_id])) {
                $this->error($validate->getError());
            }

            $common = new CommonController();
            if($status == -1){
                $where = ['project_id' => $project_id];
            }else{
                $where = ['project_id' => $project_id, 'status' => $status];
            }

            $res = Db::name('exercise')
                ->where($where)
                ->page($page,$limit)
                ->field('id,uid,status,h_uid,exercise_time,address,confirm_uid')
                ->order('id desc')
                ->select()
                ->toArray();
            //公司名称
            $project_name = $common->getProjectName($project_id);

            $total_page = $common->getCountPage('exercise',$where);
            foreach($res as &$value){
                //查看甲方提交人用户信息
                $user = $common->getUserById(['id'=>$value['uid']]);
                $value['user_login'] = isset($user['user_login'])&&!empty($user['user_login'])?$user['user_login']:'';

                //是否有确认按钮
                $value['confirm'] = 0;
                if($value['status'] == 0 && $value['h_uid'] == $this->userId){
                    $value['confirm'] = 1;
                }
                //是否有确认完成按钮
                $value['finish'] = 0;
                if($value['status'] == 1){
                    if($value['h_uid'] == $this->userId && empty($value['confirm_uid'])){
                        $value['finish'] = 1;
                    }else{
                        $u_ids = $common->getUnFinishUid(['type'=>1,'c_id'=>$value['id'],'is_image'=>1]);
                        $u_ids = array_values(array_column($u_ids,'uid'));
                        if(in_array($this->userId,$u_ids)){
                            $value['finish'] = 1;
                        }else{
                            $value['finish'] = 0;
                        }
                    }
                }

                //查看乙方确认员工
                $staff = $common->getUserById(['id'=>$value['h_uid']]);
                $value['b_staff'] = isset($staff['user_login'])&&!empty($staff['user_login'])?$staff['user_login']:'';
                $value['project_name'] = $project_name['project_name'];
            }
            $this->success('成功',['data'=>$res,'page'=>intval($page),'total_page'=>$total_page]);
        }else{
            $this->error('请求方式错误！');
        }
    }

    /**
     * @title 甲方提交演习申请
     * @description 接口说明
     * @author 开发者
     * @url /api/home/exercise/applyExercise
     * @method POST
     *
     * @header name:token require:1 default: desc:header
     *
     * @param name:title type:string require:1 default: other desc:表头信息
     * @param name:exercise_time type:int require:1 default: other desc:演习时间
     * @param name:project_id type:int require:1 default: other desc:项目id
     * @param name:address type:string require:1 default: other desc:演习地点
     * @param name:remark type:string require:1 default: other desc:演习备注
     * @param name:u_id type:inter require:1 default: other desc:指派乙方员工id
     */
    public function applyExercise(){
        if($this->request->isPost()){
            $data = $this->request->post();
            $common = new CommonController();
            $user = $common->getUserIdentity();
            //如果是乙方，则没有权限操作
            if($user['party'] == 1){
                $this->error('无权操作');
            }
            $rule = config('site.exercise_post');
            $validate = new Validate($rule['rule'],$rule['msg']);
            if (!$validate->check($data)) {
                $this->error($validate->getError());
            }
            $data['uid'] = $this->userId;
            $data['create_time'] = time();
            $data['number'] = $common->genOrderSn();

            //指派乙方人员uid
            $data['h_uid'] = $data['u_id'];
            unset($data['u_id']);

            $exerciseModel = new ExerciseModel();
            $res = $exerciseModel->create($data);
            if($res){
                //极光推送
                //甲方发起，提醒指派乙方员工
                $user_ids = [$data['h_uid']];
                $content = config('site.exercise_content_add_a');

                $registration_id = $common->getPushUsers($user_ids);
                if($registration_id){
                    $common = new CommonController();
                    $title = config('site.title');
                    $common->pushMessage($registration_id,$content,$title);
                }

                //记录参与人员id
                $join_uid['project_id'] = $data['project_id'];
                $join_uid['create_time'] = $data['create_time'];
                $join_uid['service_id'] = $res->id;
                $common->createInsUid($join_uid,6);

                $this->success('演习信息提交成功');
            }else{
                $this->error('失败');
            }
        }else{
            $this->error('请求方式错误！');
        }
    }

    /**
     * @title 乙方演习确认
     * @description 接口说明
     * @author 开发者
     * @url /api/home/exercise/confirmB
     * @method GET
     *
     * @header name:token require:1 default: desc:header
     *
     * @param name:id type:inter require:1 default: other desc:演习id
     */
    public function confirmB(){
        if($this->request->isGet()){
            $id = $this->request->get('id');//演习列表id

            $rule = config('site.data');
            $validate = new Validate($rule['rule'],$rule['msg']);
            if (!$validate->check(['id'=>$id])) {
                $this->error($validate->getError());
            }
            $common = new CommonController();
            $user = $common->getIdentity();
            //如果是甲方，则没有权限操作
            if($user['party'] == 0){
                $this->error('无权操作');
            }
            $exerciseModel = new ExerciseModel();
            $res = $exerciseModel->where(['id'=>$id,'status'=>0])->update(['status'=>1,'b_confirm_time'=>time()]);
            if($res){
                //极光推送，推送发起甲方员工
                $user_ids = $common->getLaunchUid('exercise',$id);
                $user_ids = explode(',',trim($user_ids['uid'],','));
                $content = config('site.exercise_content_confirm_a');

                $registration_id = $common->getPushUsers($user_ids);
                if($registration_id){
                    $common = new CommonController();
                    $title = config('site.title');
                    $common->pushMessage($registration_id,$content,$title);
                }

                $this->success('成功！');
            }else{
                $this->error('失败');
            }
        }else{
            $this->error('请求方式错误！');
        }
    }

    /**
     * @title 甲乙方员工完善演习单详情
     * @description 接口说明
     * @author 开发者
     * @url /api/home/exercise/improveExerciseDetail
     * @method GET
     *
     * @header name:token require:1 default: desc:header
     * @param name:id type:inter require:1 default: other desc:列表id
     *
     * @return id:演习列表id
     * @return title:培训表头信息
     * @return exercise_time:演习时间
     * @return address:演习地点
     * @return images:完善图片@
     * @images image_url:图片路径 file_time:图片时间
     * @return remark:演习备注
     * @return number:演习单号
     */
    public function improveExerciseDetail(){
        if($this->request->isGet()){
            $id = $this->request->get('id');
            $rule = config('site.data');
            $validate = new Validate($rule['rule'],$rule['msg']);
            if (!$validate->check(['id'=>$id])) {
                $this->error($validate->getError());
            }
            //如果不是甲乙方员工，则没有权限操作
            $common = new CommonController();
            $user = $common->getUserIdentity();
            if($user['identity'] != config('site.a_staff') && $user['identity'] != config('site.b_staff')){
                $this->error('无权操作');
            }
            $field = 'id,exercise_time,title,address,images,number,project_id';
            $res = $common->getExerciseById(['id'=>$id,'status'=>1],$field);
            if($res){
                //查询培训演习项目
                $project = $common->getProjectName($res['project_id']);
                $res['project_name'] = $project['project_name'];

                if($res['images']){
                    $res['images'] = $common->absolutionUrl($res['images']);
                }else{
                    $res['images'] = [];
                }
            }
            $this->success('成功',$res);
        }else{
            $this->error('请求方式错误！');
        }
    }

    /**
     * @title 甲乙方员工完善演习单
     * @description 接口说明
     * @author 开发者
     * @url /api/home/exercise/improveExercisePost
     * @method POST
     *
     * @header name:token require:1 default: desc:header
     * @param name:id type:inter require:1 default: other desc:列表id
     * @param name:images type:file require:1 default: other desc:完善图片（二维数组形式）
     */
    public function improveExercisePost(){
        if($this->request->isPost()){
            $data = $this->request->post();
            $rule = config('site.improve_check_post');
            $validate = new Validate($rule['rule'],$rule['msg']);
            if (!$validate->check($data)) {
                $this->error($validate->getError());
            }
            $common = new CommonController();
            $user = $common->getIdentity();
            //如果不是甲乙方员工，则无权操作
            if($user['identity'] != config('site.a_staff') && $user['identity'] != config('site.b_staff')){
                $this->error('无权操作');
            }
            $exerciseModel = new ExerciseModel();
            $images = $common->relationUrl($data['images']);
            $res = $exerciseModel->where(['id'=>$data['id'],'status'=>1])->update(['images'=>$images]);
            if($res){
                //记录参与人员id
                $project = $common->getLaunchUid('exercise',$data['id']);
                $join_uid['project_id'] = $project['project_id'];
                $join_uid['create_time'] = time();
                $join_uid['service_id'] = $data['id'];
                $common->createInsUid($join_uid,6);

                $this->success('成功');
            }else{
                $this->error('失败');
            }
        }else{
            $this->error('请求方式错误！');
        }
    }

    /**
     * @title 乙方员工完成演习单
     * @description 接口说明
     * @author 开发者
     * @url /api/home/exercise/finishExerciseB
     * @method POST
     *
     * @header name:token require:1 default: desc:header
     * @param name:id type:inter require:1 default: other desc:列表id
     * @param name:confirm_images type:file require:1 default: other desc:验收照片（二维数组形式）
     * @param name:u_ids type:string require:1 default: other desc:甲方被演习人员字符串逗号拼接（"2,4,5,8"）
     */
    public function finishExerciseB(){
        if($this->request->isPost()){
            $data = $this->request->post();
            $rule = config('site.check_exercise');
            $validate = new Validate($rule['rule'],$rule['msg']);
            if (!$validate->check($data)) {
                $this->error($validate->getError());
            }

            $common = new CommonController();
            $user = $common->getIdentity();
            //如果不是乙方员工，则无权操作
            if($user['identity'] != config('site.b_staff')){
                $this->error('无权操作');
            }
            $exerciseModel = new ExerciseModel();
            $confirm_images = $common->relationUrl($data['confirm_images']);
            $arr = [
                'confirm_images'=>$confirm_images,
                'confirm_uid'=>$this->userId
            ];
            $res = $exerciseModel->where(['id'=>$data['id'],'status'=>1])->update($arr);
            if($res){
                //记录参与人员id
                $project = $common->getLaunchUid('exercise',$data['id']);
                $join_uid['project_id'] = $project['project_id'];
                $join_uid['create_time'] = time();
                $join_uid['service_id'] = $data['id'];
                $common->createInsUid($join_uid,6);

                //指派甲方人员
                $u_ids = explode(',',$data['u_ids']);
                $user1['c_id'] = $data['id'];
                $user1['create_time'] = time();
                $user1['type'] = 1;
                $confirmModel = new ConfirmImageModel();
                foreach ($u_ids as $value) {
                    $user1['uid'] = $value;
                    $confirmModel->create($user1);
                }

                $this->success('成功');
            }else{
                $this->error('失败');
            }
        }else{
            $this->error('请求方式错误！');
        }
    }

    /**
     * @title 甲方员工完成演习单
     * @description 接口说明
     * @author 开发者
     * @url /api/home/exercise/finishTrainA
     * @method POST
     *
     * @header name:token require:1 default: desc:header
     * @param name:id type:inter require:1 default: other desc:列表id
     * @param name:confirm_images type:file require:1 default: other desc:验收照片（二维数组形式）
     */
    public function finishTrainA(){
        if($this->request->isPost()){
            $data = $this->request->post();
            $rule = config('site.check_train_a');
            $validate = new Validate($rule['rule'],$rule['msg']);
            if (!$validate->check($data)) {
                $this->error($validate->getError());
            }

            $common = new CommonController();
            $user = $common->getIdentity();
            //如果不是甲方员工，则无权操作
            if($user['identity'] != config('site.a_staff')){
                $this->error('无权操作');
            }
            $confirm_images = $common->relationUrl($data['confirm_images']);
            $arr = [
                'confirm_images'=>$confirm_images,
                'is_image' => 0,
            ];
            $confirmModel = new ConfirmImageModel();
            $res = $confirmModel->where(['c_id'=>$data['id'],'type'=>1,'uid'=>$this->userId])->update($arr);
            if($res){
                //记录参与人员id
                $project = $common->getLaunchUid('exercise',$data['id']);
                $join_uid['project_id'] = $project['project_id'];
                $join_uid['create_time'] = time();
                $join_uid['service_id'] = $data['id'];
                $common->createInsUid($join_uid,6);

                //查询培训单 甲方员工是否全部完成
                //已完成
                $finish_count = $common->getFinishCount(['type'=>1,'c_id'=>$data['id'],'is_image'=>0]);
                //所有
                $count = $common->getFinishCount(['type'=>1,'c_id'=>$data['id']]);
                if($finish_count == $count){
                    //全部甲方员已完成，更新状态已完成
                    $exerciseModel = new ExerciseModel();
                    $exerciseModel->where(['id'=>$data['id'],'status'=>1])->update(['status'=>2,'finish_time'=>time()]);

                    //推送系统指定人员

                }

                $this->success('成功');
            }else{
                $this->error('失败');
            }
        }else{
            $this->error('请求方式错误！');
        }
    }

}