<?php

namespace app\admin\controller\bomb\daily;

use app\admin\controller\Curd;
use support\Request;
use support\spark\model\bomb\PatrolProblem;
use support\spark\model\bomb\Patroltasks;

use support\spark\model\risk\Management;
use support\spark\model\system\AdminOrg;
use support\spark\model\system\AdminRole;
use support\spark\model\system\AdminUser;
use support\View;

//use support\spark\model\bomb\problem\Specialinspection;


class MypatrolController extends Curd
{

    # 隐患排查=》日常巡查=》我的巡查列表
    public function index(Request $request)
    {
        if (request()->isAjax()) {
            $param = request()->all();
            $where[] = ['report_user_id','=',admin_id()];
            $model = new Patroltasks();
            $project_id = isset($param['project_id']) ? $param['project_id'] : '';
            if (!empty($project_id)) {
                $where[] = ['engineering_id', '=', $project_id];
            }

            $list = $model->getPaginateList($where, ['*'], ['id' => 'asc'], [], $param['limit']);

            if($list['total']>0) {
                foreach ($list['data'] as $key => $item) {
                    $projectname = '';
                    $whereao = [['id','=',$item['project_id']]];
                    $projectItem = ((new AdminOrg())->findOne($whereao,'name'))['data'];

                    if (!empty($projectItem)) {
                        $projectname = $projectItem['name'];
                    }
                    $list['data'][$key]['projectname'] = $projectname;
                    $list['data'][$key]['risk_management_name'] =  (new Management())->where(['id'=>$item['risk_management_id']])->value('name');
                    $list['data'][$key]['role_name'] =  (new AdminRole())->where(['id'=>$item['role_id']])->value('name');
                    # 责任人
                    $userItem = (new AdminUser)
                        ->where('id', $item['report_user_id'])
                        ->first('nickname');
                    if ($userItem) {
                        $user_name = $userItem['nickname'];
                    } else {
                        $user_name = '';
                    }

                    $list['data'][$key]['user_name'] = $user_name;

                }
            }
            return sparkSuccess(dataReturn(0, 'success', $list));
        }
//var_dump(admin());
        return view('bomb/daily/mypatrol/index');
    }

    # 任务风险点列表
    public function risk_list(){
        $id =request()->get("id");
        if(request()->isAjax()){
            $param=request()->get();
            $management = new Management();

            $risk_management_id = $param['risk_management_id'];
            # 风险点列表
            $content= $management->getInfoById($risk_management_id)['content'];
//            if ($content) {
//                $patrolProblem = new PatrolProblem();
//
//                foreach ($content as $k=>$v) {
//                    $v = json_decode($v,true);
//                    $v['is_read'] = 2;
//                    $is_sb = $patrolProblem->where(['find_problem_type_source_id'=>$param['task_id'],'find_problem_type_source_id_detail'=>$v['id']])->first();
//                    if ($is_sb) {
//                        $v['is_read'] = 1;
//                    }
//                    $content[$k] = json_encode($v);
//
//                }
//            }
            return sparkSuccess(dataReturn(0,'success',['data'=>$content]));
        }
        $model = new Patroltasks();
        # 任务详情
        $row   = $model->getInfoById($id);
        if($row) {
            $projectname = '';
            $whereao = [['id','=',$row['project_id']]];
            $projectItem = ((new AdminOrg())->findOne($whereao,'name'))['data'];

            if (!empty($projectItem)) {
                $projectname = $projectItem['name'];
            }
            $row['projectname'] = $projectname;
            $row['risk_management_name'] =  (new Management())->where(['id'=>$row['risk_management_id']])->value('name');
            $row['role_name'] =  (new AdminRole())->where(['id'=>$row['role_id']])->value('name');

        }

        View::assign(['info'=>json_encode($row,true)]);
        return view('bomb/daily/mypatrol/risk_list');
    }

    # 上报我的任务隐患
    public function risk_submit()
    {
        $formData = request()->post();
//
//        $formData['find_problem_video'] = json_encode($formData['find_problem_video']);
        ## if 指定项目部 任务的分配人
        $task_allocation_org = (new AdminOrg)
            ->where('id', '=', $formData['find_problem_org_id'])->first();

        $task_allocation_user_id = $task_allocation_org['task_allocation_user_id'];
        if (empty($task_allocation_user_id)) {
            return sparkSuccess(dataReturn(-1, '该项目部未指定任务分配人,无法添加任务', $formData['find_problem_org_id']));
        }
        ## else  给一个默认的分配人
        $formData['distribution_person_id'] = $task_allocation_user_id;
        ##
        $formData['find_problem_org_deptcode'] = $task_allocation_org['deptcode'];
        $formData['find_problem_org_name'] = $task_allocation_org['name'];
        $formData['create_time'] = now();
        $formData['update_time'] = now();
        $formData['find_problem_time'] = date('Y-m-d H:i:s');
        $patrolProblem = new PatrolProblem();
        $patrolProblem->insertOne($formData);
        return sparkSuccess(dataReturn(0, '提交成功', $formData['find_problem_org_id']));
    }
}