<?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 ResourceUseController extends Curd
{
    /**
     * @description = 资源消耗列表
     * @return \support\Response
     * @version     =${VERSION}
     * @author      = Administrator
     * @creator     = future-qq:2308019155
     * @time        = 2024/3/27 15:45
     */
    public function index()
    {
        if (request()->isAjax()) {
            $param = request()->get();
//            $where=[['spent','>',0]];
            $where = [];
            if ($param['equipment_name']) {
                $where[] = ['equipment_name', 'like', '%' . $param['equipment_name'] . '%'];
            }
            $resourceEquipment = new ResourceEquipment();
            $list              = $resourceEquipment->getPaginateList($where, ['*'], ['id' => 'desc'], [], $param['limit'], $param['page']);
            return sparkSuccess(dataReturn(0, 'success', $list));
        }
        return view('emergency/resourceUse/index');
    }

    public function resourceUse()
    {
        $param = request()->post();
        Db::beginTransaction();
        try {
            foreach ($param as $resource) {
                foreach ($resource['children'] as $children) {
                    if (isset($children['num']) && (int)$children['num'] > 0) {
                        $num  = Db::table('module_emergency_resource_equipment')->where('id', $children['id'])->increment('spent', $children['num']);
                        $num1 = Db::table('module_emergency_resource_equipment')->where('id', $children['id'])->decrement('equipment_num', $children['num']);
                    }
                }
            }
            Db::commit();
            return sparkSuccess(dataReturn(0, '添加消耗成功'));
        } catch (\Exception $e) {
            Db::rollBack();
            return sparkSuccess(dataReturn(-1, '库存不足'));
        }
    }

    public function resourceList()
    {
        $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']];
        }

        $resourceModel = new Resource();
        $list          = $resourceModel->where($where)->with(['children'])->get();

        return sparkSuccess(dataReturn(0, 'success', $list));
    }

    /**
     * @description = 添加资源消耗
     * @return \support\Response
     * @version     =${VERSION}
     * @author      = Administrator
     * @creator     = future-qq:2308019155
     * @time        = 2024/3/27 15:45
     */
    public function add()
    {
        if (request()->isAjax()) {
            $request_params = request()->post();
//            $orgId=request()->session()->get('org_id');
//            $adminOrg= new AdminOrg();
//            $org_row= $adminOrg->getInfoById($orgId);
//            $param['org_name']=$org_row['name'];
//            $param['org_id']=$orgId;

            $resource_equipment = new ResourceEquipment();

            $param['equipment_name']          = $request_params['equipment_name'];
            $param['equipment_specification'] = $request_params['equipment_specification'];
            $param['equipment_unit']          = $request_params['equipment_unit'];
            $param['equipment_num']           = $request_params['equipment_num'];
            $param['spent']                   = $request_params['spent'];
            $param['equipment_specification'] = $request_params['equipment_specification'];
            $param['remark']                  = $request_params['remark'];
            $param['create_time']             = now();
            $param['update_time']             = now();
            $resource_equipment->insertOne($param);
            return sparkSuccess(dataReturn(0, 'success'));
        }

        return view('emergency/resourceUse/add');
    }

    /**
     * @description = 编辑资源消耗
     * @return \support\Response
     * @version     =${VERSION}
     * @author      = Administrator
     * @creator     = future-qq:2308019155
     * @time        = 2024/3/27 15:46
     */
    public function edit()
    {
        $resource_equipment = new ResourceEquipment();
        if (request()->isAjax()) {
            $param                = request()->post();
            $param['update_time'] = now();
//            $param['attachment']=json_encode($param['attachment']);
            $resource_equipment->updateById($param, $param['id']);
            return sparkSuccess(dataReturn(0, 'success'));
        }
        $id  = request()->get('id');
        $row = $resource_equipment->getInfoById($id);
//        $row['attachment']=json_decode($row['attachment']);
        View::assign(['info' => json_encode($row)]);
        return view('emergency/resourceUse/edit');
    }

    /**
     * @description = 删除资源消耗
     * @return \support\Response
     * @version     =${VERSION}
     * @author      = Administrator
     * @creator     = future-qq:2308019155
     * @time        = 2024/3/27 15:46
     */
    public function del()
    {
        $id                = request()->get('id');
        $resourceEquipment = new ResourceEquipment();
//        $res= $resourceEquipment->updateById(['spent'=>0],$id);
        $resourceEquipment->delById($id);
        return sparkSuccess(dataReturn(0, 'success'));
    }
}