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')); } }