FileController.php 12 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394
  1. <?php
  2. namespace App\Http\Controllers\API;
  3. use App\Http\Controllers\Controller;
  4. use App\Http\Requests\API\File\DownloadZipRequest;
  5. use App\Http\Requests\API\File\FileUploadRequest;
  6. use App\Http\Requests\API\File\KeepDirectoryUploadRequest;
  7. use App\Http\Resources\API\FileByObjectResource;
  8. use App\Http\Resources\API\FileDownloadResource;
  9. use App\Http\Resources\API\FileSimpleResource;
  10. use App\Http\Resources\API\FileUploadSuccessResource;
  11. use App\Libraries\BIM\BIMDriverEnum;
  12. use App\Libraries\ChunkedUpload\Disks\Cos;
  13. use App\Models\Enums\ActionObjectType;
  14. use App\Models\Enums\BimFileConvertStatus;
  15. use App\Models\Enums\BimFileModelType;
  16. use App\Models\Enums\FileObjectType;
  17. use App\Models\Enums\ObjectAction;
  18. use App\Models\File;
  19. use App\Repositories\ActionRepository;
  20. use App\Services\File\BimService;
  21. use App\Services\File\DownloadService;
  22. use App\Services\File\FileHideService;
  23. use App\Services\File\FileService;
  24. use App\Services\File\Upload\CompanyUploadService;
  25. use App\Services\File\Upload\FilesUploadService;
  26. use App\Services\File\Upload\KeepDirectoryUploadService;
  27. use App\Services\File\Upload\ProgressBar;
  28. use Illuminate\Http\Request;
  29. use Illuminate\Http\Response;
  30. use Illuminate\Support\Facades\Auth;
  31. use Illuminate\Support\Facades\Storage;
  32. class FileController extends Controller
  33. {
  34. public function download(string $id)
  35. {
  36. $file = File::query()->findOrFail($id);
  37. $fileObjectType = FileObjectType::from($file->object_type);
  38. $object = $fileObjectType->modelBuilderAllowed($file->object_id)->find($file->object_id);
  39. if (!$object) {
  40. return $this->badRequest(sprintf("File ID: %s, no permission to access", $file->id));
  41. }
  42. ActionRepository::create($id, ActionObjectType::CONTAINER_FILE, ObjectAction::DOWNLOAD);
  43. return new FileDownloadResource($file);
  44. }
  45. public function changeName(Request $request, string $id)
  46. {
  47. $isAction = $request->input('is_action', null);
  48. $result = ($isAction === '0') ? true : ($isAction === '1' ? false : false);
  49. $file = File::query()->findOrFail($id);
  50. $fileObjectType = FileObjectType::from($file->object_type);
  51. $object = $fileObjectType->modelBuilderAllowed($file->object_id, $result)->find($file->object_id);
  52. if (!$object) {
  53. return $this->badRequest(sprintf("File ID: %s, no permission to access", $file->id));
  54. }
  55. File::query()->where('title', $file->title)
  56. ->where('object_type', $file->object_type)
  57. ->where("object_id", $file->object_id)
  58. ->update(['title' => $request->get('title')]);
  59. ActionRepository::createByFile($file->object_id, $file->object_type, ObjectAction::EDITED_FILE);
  60. return $this->noContent();
  61. }
  62. public function destroy(Request $request, string $id)
  63. {
  64. $isAction = $request->input('is_action', null);
  65. $result = ($isAction === '0') ? true : ($isAction === '1' ? false : false);
  66. $file = File::query()->findOrFail($id);
  67. $fileObjectType = FileObjectType::from($file->object_type);
  68. $object = $fileObjectType->modelBuilderAllowed($file->object_id, $result)->find($file->object_id);
  69. if (!$object) {
  70. return $this->badRequest(sprintf("File ID: %s, no permission to access", $file->id));
  71. }
  72. $files = File::query()
  73. ->where('title', $file->title)
  74. ->where('object_type', $file->object_type)
  75. ->where("object_id", $file->object_id)
  76. ->where("folder_id", $file->folder_id)
  77. ->get();
  78. File::query()->whereIn("id", $files->pluck("id")->toArray())->delete();
  79. ActionRepository::createByFile($file->object_id, $file->object_type, ObjectAction::DELETED_FILE);
  80. Storage::delete($files->pluck("pathname")->toArray());
  81. $filesSize = $files->sum("size");
  82. $company = Auth::user()->company;
  83. $company->decrement("used_storage_capacity", $filesSize);
  84. $company->save();
  85. return $this->noContent();
  86. }
  87. public function downloadZip(DownloadZipRequest $request, DownloadService $service)
  88. {
  89. return $this->success([
  90. 'data' => $service->downloadByIds($request->get("ids")),
  91. ]);
  92. }
  93. public function downloadAllLatest(DownloadService $service, string $objectType, string $objectId)
  94. {
  95. return $this->success([
  96. 'data' => $service->downloadAllLatest($objectType, $objectId),
  97. ]);
  98. }
  99. public function downloadShareFile(DownloadService $service, string $uuid)
  100. {
  101. return $this->success([
  102. 'data' => $service->downloadShareFile($uuid),
  103. ]);
  104. }
  105. /**
  106. * 文件上传
  107. *
  108. * @param FileUploadRequest $request
  109. * @return FileUploadSuccessResource|\Illuminate\Http\JsonResponse
  110. */
  111. public function upload(FileUploadRequest $request)
  112. {
  113. set_time_limit(0);
  114. $uploadedFiles = (new FilesUploadService($request))->upload();
  115. if ($request->object_id !== null) {
  116. ActionRepository::createByFile($request->object_id, $request->object_type, ObjectAction::UPLOADED);
  117. }
  118. return $this->success([
  119. 'data' => $uploadedFiles
  120. ]);
  121. }
  122. /**
  123. * 模型上传
  124. * @param \App\Http\Requests\API\File\FileUploadRequest $request
  125. * @return
  126. */
  127. public function modelUpload(FileUploadRequest $request)
  128. {
  129. set_time_limit(0);
  130. $uploadedFiles = (new FilesUploadService($request))->uploadModels();
  131. if ($request->object_id !== null) {
  132. ActionRepository::createByFile($request->object_id, $request->object_type, ObjectAction::UPLOADED);
  133. }
  134. return FileUploadSuccessResource::collection($uploadedFiles);
  135. }
  136. public function companyUpload(FileUploadRequest $request)
  137. {
  138. set_time_limit(0);
  139. $uploadedFiles = (new CompanyUploadService($request))->upload();
  140. return $this->success([
  141. 'data' => $uploadedFiles
  142. ]);
  143. }
  144. /**
  145. * 文件夹上传
  146. *
  147. * @param KeepDirectoryUploadRequest $request
  148. * @return FileUploadSuccessResource|\Illuminate\Http\JsonResponse
  149. */
  150. public function keepDirectoryUpload(KeepDirectoryUploadRequest $request)
  151. {
  152. set_time_limit(0);
  153. $uploadedFiles = (new KeepDirectoryUploadService($request))->upload();
  154. if ($request->object_id !== null) {
  155. ActionRepository::createByFile($request->object_id, $request->object_type, ObjectAction::UPLOADED);
  156. }
  157. return $this->success([
  158. 'data' => $uploadedFiles
  159. ]);
  160. }
  161. public function uploadProgress(string $requestId)
  162. {
  163. return $this->success([
  164. 'data' => ProgressBar::queryByRequestId($requestId),
  165. ]);
  166. }
  167. public function byObject(string $objectType, string $objectId)
  168. {
  169. $fileObjectType = FileObjectType::from($objectType);
  170. $fileObjectType->modelBuilderAllowed($objectId)->findOrFail($objectId);
  171. $files = File::query()
  172. ->with(['createdBy'])
  173. ->where('object_type', $objectType)
  174. ->where('object_id', $objectId)
  175. ->orderByDesc("version")
  176. ->where("source", 1)
  177. ->get();
  178. $items = [];
  179. foreach ($files->groupBy("title") as $fileItems) {
  180. $item = (new FileByObjectResource($fileItems->first()))->toArray(request());
  181. $item['extraField'] = 'parent' . '_' . $item['id'];
  182. $item['children'] = [];
  183. foreach ($fileItems as $fileItem) {
  184. $resource = (new FileByObjectResource($fileItem))->toArray(request());
  185. $resource['extraField'] = 'children' . '_' . $resource['id'];
  186. $item['children'][] = $resource;
  187. }
  188. $items[] = $item;
  189. }
  190. return $this->success([
  191. 'data' => $items
  192. ]);
  193. }
  194. /**
  195. * 文件隐藏
  196. *
  197. * @param string $id
  198. * @param FileHideService $service
  199. * @return Response
  200. */
  201. public function hide(string $id, FileHideService $service)
  202. {
  203. $service->hide($id);
  204. return $this->noContent();
  205. }
  206. public function bimView(string $id)
  207. {
  208. $file = File::query()->where('is_bim', 1)->findOrFail($id);
  209. $fileObjectType = FileObjectType::from($file->object_type);
  210. $object = $fileObjectType->modelBuilderAllowed($file->object_id)->find($file->object_id);
  211. if (!$object) {
  212. return $this->badRequest(sprintf("File ID: %s, no permission to access", $file->id));
  213. }
  214. $bimFile = $file->bimFile;
  215. if ($bimFile->convert_status !== BimFileConvertStatus::DONE->value) {
  216. return $this->badRequest("BIM is in the process of conversion. Please wait a moment");
  217. }
  218. switch ($bimFile->bim_driver) {
  219. case BIMDriverEnum::GLENDALE->value:
  220. $result = (new BimService)->getGlendaleBimInfo($file->bimFile);
  221. break;
  222. default:
  223. $result = [];
  224. break;
  225. }
  226. return $this->success([
  227. 'data' => [
  228. 'bim_driver' => $bimFile->bim_driver,
  229. 'bim_view' => $result,
  230. ]
  231. ]);
  232. }
  233. /**
  234. * 获取上传COS临时密钥
  235. */
  236. public function getCOSToken(FileUploadRequest $request, Cos $cos)
  237. {
  238. $pathPrefix = cos_upload_prefix(Auth::user()->company_id, $request['object_type'] ?? '');
  239. $data = $cos->getTempKeys($pathPrefix);
  240. return $this->successData($data);
  241. }
  242. /**
  243. * 容器下的所有模型列表
  244. */
  245. public function models(Request $request)
  246. {
  247. $inputArr = $this->validate($request, [
  248. 'model_type' => 'array',
  249. 'container_id' => 'int',
  250. 'library_id' => 'int',
  251. 'asset_id' => 'int',
  252. 'project_id' => 'int',
  253. 'folder_id' => 'int',
  254. 'keyword' => '',
  255. ]);
  256. $containerId = (int) ($inputArr['container_id'] ?? 0);
  257. $libraryId = (int) ($inputArr['library_id'] ?? 0);
  258. $assetId = (int) ($inputArr['asset_id'] ?? 0);
  259. $projectId = (int) ($inputArr['project_id'] ?? 0);
  260. $folderId = (int) ($inputArr['folder_id'] ?? 0);
  261. $pageSize = (int) $request->get('page_size', 10);
  262. $keyword = $inputArr['keyword'] ?? '';
  263. $modelTypeArr = $inputArr['model_type'] ?? [];
  264. if (empty($modelTypeArr)) {
  265. $modelTypeArr = [BimFileModelType::BIM->value, BimFileModelType::CAD->value];
  266. }
  267. $files = File::query()
  268. ->where('is_bim', 1)
  269. ->where('is_latest_version', 1)
  270. ->folderId($folderId)
  271. ->projectId($projectId)
  272. ->assetId($assetId)
  273. ->containerId($containerId)
  274. ->containerLibraryId($libraryId)
  275. ->keyword($keyword)
  276. ->with(['bimFile', 'createdBy'])
  277. ->whereHas('bimFile', function ($query) use ($modelTypeArr) {
  278. return $query->modelType($modelTypeArr)->where('convert_status', BimFileConvertStatus::DONE->value);
  279. })
  280. ->latest('id')
  281. ->paginate($pageSize);
  282. return FileSimpleResource::collection($files);
  283. }
  284. // 模型历史记录
  285. public function modelHistory(Request $request)
  286. {
  287. $inputArr = $this->validate($request, [
  288. 'file_id' => 'required|int',
  289. ]);
  290. $fileId = (int) ($inputArr['file_id'] ?? 0);
  291. $pageSize = (int) $request->get('page_size', 10);
  292. $file = File::query()->findOrFail($fileId);
  293. if (!empty($file->source_file_id)) {
  294. $files = File::query()
  295. ->with(['bimFile', 'createdBy'])
  296. ->where('is_bim', 1)
  297. ->where('object_type', $file->object_type)
  298. ->where('object_id', $file->object_id)
  299. ->where('folder_id', $file->folder_id)
  300. ->where('source_file_id', $file->source_file_id)
  301. ->orWhere('id', $file->source_file_id)
  302. ->latest('version')
  303. ->paginate($pageSize);
  304. } else {
  305. $files[] = $file;
  306. }
  307. return FileSimpleResource::collection($files);
  308. }
  309. // 文件详情
  310. public function detail(int $fileId)
  311. {
  312. $file = File::findOrFail($fileId);
  313. return new FileByObjectResource($file);
  314. }
  315. public function update(
  316. Request $request,
  317. FileService $fileService,
  318. string $id
  319. ): Response
  320. {
  321. $fileService->update($id, $request->all());
  322. return $this->noContent();
  323. }
  324. }