FilesUploadTrait.php 5.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167
  1. <?php
  2. namespace App\Services\File\Upload;
  3. use App\Http\Resources\API\FileUploadSuccessResource;
  4. use App\Libraries\BIM\BIMFactory;
  5. use App\Libraries\ChunkedUpload\ChunkedUploadFactory;
  6. use App\Models\BimFile;
  7. use App\Models\ContainerContent;
  8. use App\Models\Enums\FileObjectType;
  9. use App\Models\File;
  10. use Illuminate\Http\Request;
  11. use Illuminate\Http\UploadedFile;
  12. use Illuminate\Support\Facades\Auth;
  13. trait FilesUploadTrait
  14. {
  15. protected ?FileObjectType $fileObjectType = null;
  16. protected $object = null;
  17. protected function checkRequestData(Request $request): int
  18. {
  19. $this->fileObjectType = FileObjectType::from($request->object_type);
  20. if ($request->object_id) {
  21. $this->object = $this->fileObjectType->modelBuilderAllowed($request->object_id)->findOrFail($request->object_id);
  22. }
  23. $filesSize = 0;
  24. foreach ($request->file("files") as $file) {
  25. throw_validation_if(! $file->isValid(), "File upload failed.");
  26. $filesSize += $file->getSize();
  27. }
  28. throw_validation_if(
  29. $filesSize + Auth::user()->company->used_storage_capacity > Auth::user()->company->storage_size,
  30. "Storage capacity is insufficient, please contact the administrator."
  31. );
  32. return $filesSize;
  33. }
  34. protected function uploadFile(Request $request, UploadedFile $file, ?ProgressBar $progressBar = null): array
  35. {
  36. $extension = $file->getClientOriginalExtension()
  37. ? $file->getClientOriginalExtension()
  38. : pathinfo($file->getClientOriginalName(), PATHINFO_EXTENSION);
  39. $pathname = ChunkedUploadFactory::make()->upload(
  40. $file,
  41. sprintf("c%s/%s/%s", Auth::user()->company_id, $request->get("object_type"), date("Ymd")),
  42. sprintf("%s.%s", md5(uniqid()), $extension),
  43. $progressBar
  44. );
  45. $data = [
  46. 'bim' => [],
  47. ];
  48. $isBimFile = 0;
  49. if (in_array($extension, config("bim.extensions")) && $request->object_type == FileObjectType::CONTAINER->value) {
  50. $isBimFile = true;
  51. $data['bim'] = BIMFactory::make()->uploadFile($file, [
  52. 'pathname' => $pathname,
  53. 'extension' => $extension,
  54. 'is_cad' => in_array($extension, ['dwg', 'dwf', 'dws', 'dwt']),
  55. ]);
  56. }
  57. $data['file'] = [
  58. 'pathname' => $pathname,
  59. 'title' => $file->getClientOriginalName(),
  60. 'size' => $file->getSize(),
  61. 'extension' => $extension,
  62. 'object_type' => $request->object_type,
  63. 'object_id' => $request->object_id,
  64. 'created_by' => Auth::id(),
  65. 'company_id' => Auth::user()->company_id,
  66. 'source' => $request->get("source", 1),
  67. 'uuid' => $request->get("uuid"),
  68. 'is_bim' => $isBimFile,
  69. ];
  70. return $data;
  71. }
  72. protected function storeFiles(array $items)
  73. {
  74. $uploadedFiles = [];
  75. foreach ($items as $item) {
  76. $fileInfo = $item['file'];
  77. if ($fileInfo['object_id'] && $fileInfo['source'] == 1||$fileInfo['uuid'] && $fileInfo['source']== 1) {
  78. $version = File::query()
  79. ->where('object_type', $fileInfo['object_type'])
  80. ->where('object_id', $fileInfo['object_id'])
  81. ->where("title", $fileInfo['title'])
  82. ->where("source", 1)
  83. ->where("folder_id", $fileInfo['folder_id'] ?? 0)
  84. ->count();
  85. $fileInfo['version'] = $version + 1;
  86. $fileInfo['is_latest_version'] = 1;
  87. File::query()
  88. ->where('object_type', $fileInfo['object_type'])
  89. ->where('object_id', $fileInfo['object_id'])
  90. ->where("title", $fileInfo['title'])
  91. ->where("folder_id", $fileInfo['folder_id'] ?? 0)
  92. ->where("source", 1)
  93. ->where("is_latest_version", 1)
  94. ->update([
  95. 'is_latest_version' => 0
  96. ]);
  97. }
  98. $file = File::query()->create($fileInfo);
  99. if (isset($item['bim']) && $item['bim']) {
  100. BimFile::query()->create([
  101. 'file_id' => $file->id,
  102. ...$item['bim']
  103. ]);
  104. }
  105. $uploadedFiles[] = new FileUploadSuccessResource($file);
  106. }
  107. $this->updateObjectVersion();
  108. return $uploadedFiles;
  109. }
  110. protected function updateObjectVersion()
  111. {
  112. if (!$this->object) {
  113. return;
  114. }
  115. if ($this->fileObjectType == FileObjectType::CONTAINER) {
  116. $version = $this->object->version;
  117. $this->object->version++;
  118. $this->object->save();
  119. $fileIds = File::query()->where([
  120. 'object_type' => $this->fileObjectType->value,
  121. 'object_id' => $this->object->id
  122. ])->pluck("id");
  123. ContainerContent::query()->create([
  124. ...$this->object->content($version)->first()->toArray(),
  125. 'created_by' => Auth::id(),
  126. 'files' => $fileIds->join(","),
  127. 'version' => $this->object->version,
  128. ]);
  129. }
  130. }
  131. protected function updateUsedStorageCapacity(int $filesSize)
  132. {
  133. $company = Auth::user()->company;
  134. $company->increment("used_storage_capacity", $filesSize);
  135. $company->save();
  136. }
  137. }