<?php

namespace app\admin\controller\emergency;

use app\admin\controller\Curd;

use support\Db;
use support\spark\model\emergency\Resource;
use support\spark\model\emergency\ResourceEquipment;
use support\spark\model\system\AdminOrg;
use \support\View;


class ResourceController extends Curd
{
    public function index(){
        if(request()->isAjax()){
            $param=request()->get();
            $where=[];
            // 通过session获取当前数据范围公司
            $orgInfo = getOrgSelfAndChildrenOrgsById();
            $org = end($orgInfo);
            if ($org['org_type'] === 'type_corporation') {
                $where[] = ['company_org_id', '=', $org['id']];
            } elseif($org['org_type'] === 'type_company') {
                $where[] = ['project_org_id', '=', $org['id']];
            } else {
                $where[] = ['org_id', '=', $org['id']];
            }
            $resource= new Resource();
            $list= $resource->getPaginateList($where,['*'],['id'=>'desc'],[],$param['limit'],$param['page']);
            return sparkSuccess(dataReturn(0,'success',$list));
        }
        return view('emergency/resource/index');
    }
    public function add(){
        if(request()->isAjax()){
            $param=request()->post();
            $resource= new Resource();
            $orgInfo = getOrgFromLevel4($param['org_id']);
            $resource->create(array_merge($param, $orgInfo));
            return sparkSuccess(dataReturn(0,'添加成功'));
        }
        View::assign([
            'orgList' => asTreeArray((new AdminOrg())
                ->getAllList([['status', '=', 1]], ['id', 'name', 'pid']), 'pid'),
        ]);
        return view('emergency/resource/add');
    }
    public function edit(){
        $resource= new Resource();
        if(request()->isAjax()){
            $param=request()->post();
            $resource->updateById($param,$param['id']);
            return sparkSuccess(dataReturn(0,'修改成功'));
        }
        $id=request()->get('id');
        $row= $resource->getInfoById($id);
        View::assign([
            'orgList' => asTreeArray((new AdminOrg())
                ->getAllList([['status', '=', 1]], ['id', 'name', 'pid']), 'pid'),
            'info'=>$row
        ]);
        return view('emergency/resource/edit');
    }
    public function del(){
        $id=request()->get('id');
        $resource = new Resource();
        $resource->delById($id);
        return sparkSuccess(dataReturn(0,'删除成功'));
    }
    //查看详情
    public function details(){
        $id=request()->get("id");
        if(request()->isAjax()){
            $param=request()->get();
           $resourceEquipment= new ResourceEquipment();
            $res= $resourceEquipment->getPaginateList(['resource_id'=>$param['id']],['*'],[],[],$param['limit'],$param['page']);
            return sparkSuccess(dataReturn(0,'success',$res));
        }
        $resource= new Resource();
        $row= $resource->getInfoById($id);
        View::assign(['info'=>json_encode($row)]);
        return view('emergency/resource/details');
    }
    public function expend(){
        $param=request()->get();

        Db::beginTransaction();
        try{
            $num=  Db::table('module_emergency_resource_equipment')->where('id',$param['id'])->increment('spent',$param['num']);
            $num1=  Db::table('module_emergency_resource_equipment')->where('id',$param['id'])->decrement('equipment_num',$param['num']);
            Db::commit();
            return  sparkSuccess(dataReturn(0,'添加消耗成功'));
        }catch (\Exception $e){
             Db::rollBack();
             return sparkSuccess(dataReturn(-1,'库存不足'));
        }

    }
}