<?php

namespace app\mobile\controller\patrol;

use app\admin\controller\Curd;
use app\admin\service\AdminService;
use support\spark\model\risk\RiskManagement;
use support\spark\model\risk\RiskLibrary;
use support\spark\model\risk\RiskManagementPatrol;
use app\admin\controller\basicdata\BasicdataEngineeringController;
use support\spark\model\system\AdminOrg;
use support\spark\model\basicdata\Usedpart;
use support\Request;

/**
 * 危险源列表获取
 */
class SpecialInspIectController extends Curd
{
    private $RiskManagementModel;
    private $RiskManagementPatrolModel;
    protected $exportName = '';
    protected $exportField = '';
    protected $maplist = [];

    public function __construct()
    {
        parent::__construct();
        $this->RiskManagementModel = new RiskManagement();
        $this->RiskManagementPatrolModel = new RiskManagementPatrol();
    }

    public function index()
    {
        return view('sp_module_risk/riskmanagement');
    }

    /** 风险等级 */
    private function getLevel($id)
    {
        $arr = ['', '重大风险', '较大风险', '一般风险', '较小风险'];
        return $arr[$id];
    }

    /** 风险管理状态 */
    private function getStatus($id)
    {
        $arr = ['已开启', '已关闭'];
        return $arr[$id];
    }

    /** 风险管理列表 */
    public function list(Request $request)
    {
        $where['status'] = 0;
        $list = $this->RiskManagementModel->where($where)->get();
        $list ? $list->toArray() : [];

        foreach ($list as $key => $item) {
            $whereao = [['id', '=', $item['unit']]];
            $list[$key]['unitname'] = ((new AdminOrg())->findOne($whereao, 'name'))['data']['name'];
            $list[$key]['statusname'] = $this->getStatus($item['status']);
        }
        return sparKSuccess(dataReturn(0, 'success', $list));
    }

    /** 风险管理添加 */
    public function add(Request $request)
    {
        if ($request->isAjaxPost()) {
            $param = $request->post();
            $param['create_time'] = time();
            $res = $this->RiskManagementModel->insertOne($param);
            return sparkSuccess(dataReturn(0, '添加成功'));
        }
        return sparkSuccess(dataReturn(0, 'error'));
    }

    /** 风险管理编辑 */
    public function edit(Request $request)
    {
        if ($request->isAjaxPost()) {
            $param = $request->post();
            $param['update_time'] = time();
            unset($param['create_time']);
            unset($param['lid_list']);
            $res = $this->RiskManagementModel->updateById($param, $param['id']);
            return sparkSuccess(dataReturn(0, '编辑成功'));
        }
        return sparkSuccess(dataReturn(0, 'error'));
    }

    /** 查询风险管理 */
    public function getOne(Request $request)
    {
        $getData = $request->all();
        $data['row'] = $this->RiskManagementModel->getInfoById($getData['id']);
        // var_dump($data['row']['lid']);
        $whereun = [['id', '=', $data['row']['unit']]];
        $wherepa = [['id', '=', $data['row']['position']]];
        $data['row']['unitname'] = ((new AdminOrg())->findOne($whereun, 'name'))['data']['name'];
        $data['row']['partname'] = ((new Usedpart())->findOne($wherepa, 'name'))['data']['name'];
        $data['lid_list'] = $this->getlistids($data['row']['lid']);
        return sparKSuccess(dataReturn(0, 'success', $data));
    }

    /** 查询风险管理 */
    public function getUser(Request $request)
    {
        $getData = $request->all();
        $data['u_list'] = (new AdminService())->getList($getData);
        return sparKSuccess(dataReturn(0, 'success', $data));
    }

    /** 删除风险管理 */
    public function del(Request $request)
    {
        $id = $request->get('id');
        $row = $this->RiskManagementModel->delById($id);
        return sparKSuccess(dataReturn(0, '删除成功'));
    }

    /** 单位无分页列表 */
    public function getListorg()
    {
        $where = [['status', '=', 1]];
        $res = (new AdminOrg())->getAllList($where);
        $list = [];
        foreach ($res as $k => $v) {
            $list[$k]['value'] = $v['id'];
            $list[$k]['label'] = $v['name'];
            $list[$k]['pid'] = $v['pid'];
            $list[$k]['id'] = $v['id'];
            if (!empty($v['latitudelongitude'])) {
                //$map_arr = explode(",",$v1['longitude_latitude']);
                $this->maplist = array_merge($this->maplist, [$v]);
            }
        }
        return $this->getPidList($list);
    }

    private function getPidList($list)
    {
        $packData = [];
        $tree = [];
        foreach ($list as $data) {
            $packData[$data['id']] = $data;
        }
        foreach ($packData as $key => $val) {
            if ($val['pid'] == 0) {
                $tree[] = &$packData[$key];
            } else {
                $packData[$val['pid']]['children'][] = &$packData[$key];
            }
        }
        return $tree;
    }

    /** id集风险标准库 */
    public function getlistids($lid)
    {
        if (!isset($lid))
            return [];
        $lid = json_decode($lid);
        $where = [];
        if (count($lid) > 0) {
            $where['lid'] = ['id', 'in', $lid];
            $list = (new RiskLibrary())->getAllList($where);
            foreach ($list as $key => $item) {
                $list[$key]['levelname'] = $this->getLevel($item['level']);
                $list[$key]['projectname'] = (new BasicdataEngineeringController())->getOnename($item['name']);
            }
            return $list;
        } else {
            return [];
        }
    }

    /** 风险巡查编辑 */
    public function Patroledit(Request $request)
    {
        $param = $request->post();
        $param['update_time'] = time();
        //unset($param['lid_list']);
        $res = $this->RiskManagementModel->updateById($param, $param['id']);
        //$res = $this->RiskManagementPatrolModel->updateById($param, $param['id']);
        if ($res) {
            return sparkSuccess(dataReturn(0, '提交成功'));
        } else {
            return sparkSuccess(dataReturn(1, 'error'));
        }
    }
}