when($request->filled('id'), fn ($q) => $q->where('id', $request->id)); } // 查询列表 public function select(Request $request) { $page = new Pages($request, OrderSettRecord::query()); $page->before(function ($query) use ($request) { $query->select(OrderSettRecord::$selectFields); return $this->whens($query, $request); }); $result = $page->paginate(); return $result; } // 导出 public function export(Request $request) { $query = OrderSettRecord::select(OrderSettRecord::$selectFields); $query = $this->whens($query, $request); $query->orderBy('created_at', 'desc'); $header = [ '导入文件路径' => 'put_file', '结算结果文件路径' => 'out_file', '状态 0待执行 1执行中 2执行成功 3执行失败 4停止执行' => 'status', '创建时间' => 'created_at', '更新时间' => 'updated_at', '删除时间' => 'deleted_at', '备注' => 'remark', '标题' => 'title', '1号卡 2设备 3靓号 4宽带' => 'type', ]; $getEnValue = $this->getEnValue(); $excel = new SpoutExport($header); $excel->setData($query->get()); $result = $excel->setEnum($getEnValue)->spoutToExcel('excel_out'); return $result ? success($result['url']) : error(); } // 导入 public function import(Request $request) { $header = [ '导入文件路径' => 'put_file', '结算结果文件路径' => 'out_file', '状态 0待执行 1执行中 2执行成功 3执行失败 4停止执行' => 'status', '创建时间' => 'created_at', '更新时间' => 'updated_at', '删除时间' => 'deleted_at', '备注' => 'remark', '标题' => 'title', '1号卡 2设备 3靓号 4宽带' => 'type', ]; $getEnValue = $this->getEnValue(); $SpoutImport = new SpoutImport($header); $dataList = $SpoutImport->setRequest($request)->getExcelData(); return $dataList; } // 获取枚举值 public function getEnValue() { $data = [ 'open_status' => [ 0 => "待开卡", 1 => "开卡中", ] ]; return $data; } // 查询一条 public function find(Request $request) { $request->validate([ 'id' => 'required|integer', ]); $result = OrderSettRecord::where(['id' => $request->id])->select(OrderSettRecord::$selectFields)->first(); return success($result); } // 添加 public function insert(Request $request) { $request->validate([ 'file' => 'required|mimes:csv,xls,xlsx', 'type' => 'required|integer|in:1,2,3,4', ]); $title = $request->input('title', null); // 获取上传的文件 $file = $request->file('file'); $type = $request->type; // 生成唯一的文件名 $filename = "sttle_put_" . uniqid() . '_' . time() . '.' . $file->getClientOriginalExtension(); // 将文件保存到指定目录 public/csv/ $file->storeAs("/batch_order_settle/put", $filename, 'csv'); $file_path = "csv/batch_order_settle/put/" . $filename; $result = OrderSettRecord::create([ 'put_file' => $file_path, 'title' => $title, 'type' => $type, ]); if ($result) { AutoSettleJob::dispatch($result->id, $type); return ['code' => 1, 'msg' => "success", 'data' => config('app.url') . "/" . $file_path]; } else { return error(); } } // 修改 public function update(Request $request) { $request->validate([ 'id' => 'required|integer', ]); $result = OrderSettRecord::where(['id' => $request->id])->update($request->all()); if ($result) { return success(); } else { return error(); } } // 删除 public function delete(Request $request) { $request->validate([ 'ids' => 'required', ]); $id_str = $request->ids; $arr = explode(",", $id_str); // 查询是否存在子数据 // $count = Shop::whereIn('tm_id',$arr)->count(); // if($count > 0){ // return ['code'=>0,'msg'=>"存在子数据,禁止删除"]; // } $result = OrderSettRecord::whereIn('id', $arr)->delete(); if ($result) { return success(); } else { return error(); } } // 获取导入模版 public function getOrderSettImportTemplate() { $headers = ['订单号', '结算状态 [ 结算成功 结算失败 ]', '原因']; return (new SpoutImport([]))->generateImportTemplat($headers,[30,50,20]); } }