Document

Operation	:	Linux server.tradinguniversity.rs 3.10.0-1160.119.1.vz7.224.4 #1 SMP Mon Sep 30 15:36:27 MSK 2024 x86_64
Software	:	Apache
Server IP	:	68.66.251.59 \| Your IP: 216.73.216.158
Domains	:	4 Domain
Permission	:	[ drwxr-xr-x ]

/ home / tradinguniversit / public_html / vendor / maatwebsite / excel / src /

Web File Manager

主页上传上传 V2 命令行

QueuedWriter.php

<?php

namespace Maatwebsite\Excel;

use Illuminate\Foundation\Bus\PendingDispatch;
use Illuminate\Support\Collection;
use Illuminate\Support\LazyCollection;
use Maatwebsite\Excel\Concerns\FromCollection;
use Maatwebsite\Excel\Concerns\FromQuery;
use Maatwebsite\Excel\Concerns\FromView;
use Maatwebsite\Excel\Concerns\WithCustomChunkSize;
use Maatwebsite\Excel\Concerns\WithCustomQuerySize;
use Maatwebsite\Excel\Concerns\WithMultipleSheets;
use Maatwebsite\Excel\Files\TemporaryFile;
use Maatwebsite\Excel\Files\TemporaryFileFactory;
use Maatwebsite\Excel\Jobs\AppendDataToSheet;
use Maatwebsite\Excel\Jobs\AppendPaginatedToSheet;
use Maatwebsite\Excel\Jobs\AppendQueryToSheet;
use Maatwebsite\Excel\Jobs\AppendViewToSheet;
use Maatwebsite\Excel\Jobs\CloseSheet;
use Maatwebsite\Excel\Jobs\QueueExport;
use Maatwebsite\Excel\Jobs\StoreQueuedExport;
use Traversable;

class QueuedWriter
{
    /**
     * @var Writer
     */
    protected $writer;

/**
     * @var int
     */
    protected $chunkSize;

/**
     * @var TemporaryFileFactory
     */
    protected $temporaryFileFactory;

/**
     * @param  Writer  $writer
     * @param  TemporaryFileFactory  $temporaryFileFactory
     */
    public function __construct(Writer $writer, TemporaryFileFactory $temporaryFileFactory)
    {
        $this->writer               = $writer;
        $this->chunkSize            = config('excel.exports.chunk_size', 1000);
        $this->temporaryFileFactory = $temporaryFileFactory;
    }

/**
     * @param  object  $export
     * @param  string  $filePath
     * @param  string  $disk
     * @param  string|null  $writerType
     * @param  array|string  $diskOptions
     * @return \Illuminate\Foundation\Bus\PendingDispatch
     */
    public function store($export, string $filePath, ?string $disk = null, ?string $writerType = null, $diskOptions = [])
    {
        $extension     = pathinfo($filePath, PATHINFO_EXTENSION);
        $temporaryFile = $this->temporaryFileFactory->make($extension);

$jobs = $this->buildExportJobs($export, $temporaryFile, $writerType);

$jobs->push(new StoreQueuedExport(
            $temporaryFile,
            $filePath,
            $disk,
            $diskOptions
        ));

return new PendingDispatch(
            (new QueueExport($export, $temporaryFile, $writerType))->chain($jobs->toArray())
        );
    }

/**
     * @param  object  $export
     * @param  TemporaryFile  $temporaryFile
     * @param  string  $writerType
     * @return Collection
     */
    private function buildExportJobs($export, TemporaryFile $temporaryFile, string $writerType): Collection
    {
        $sheetExports = [$export];
        if ($export instanceof WithMultipleSheets) {
            $sheetExports = $export->sheets();
        }

$jobs = new Collection;
        foreach ($sheetExports as $sheetIndex => $sheetExport) {
            if ($sheetExport instanceof FromCollection) {
                $jobs = $jobs->merge($this->exportCollection($sheetExport, $temporaryFile, $writerType, $sheetIndex));
            } elseif ($sheetExport instanceof FromQuery) {
                $jobs = $jobs->merge($this->exportQuery($sheetExport, $temporaryFile, $writerType, $sheetIndex));
            } elseif ($sheetExport instanceof FromView) {
                $jobs = $jobs->merge($this->exportView($sheetExport, $temporaryFile, $writerType, $sheetIndex));
            }

$jobs->push(new CloseSheet($sheetExport, $temporaryFile, $writerType, $sheetIndex));
        }

return $jobs;
    }

/**
     * @param  FromCollection  $export
     * @param  TemporaryFile  $temporaryFile
     * @param  string  $writerType
     * @param  int  $sheetIndex
     * @return Collection|LazyCollection
     */
    private function exportCollection(
        FromCollection $export,
        TemporaryFile $temporaryFile,
        string $writerType,
        int $sheetIndex
    ) {
        return $export
            ->collection()
            ->chunk($this->getChunkSize($export))
            ->map(function ($rows) use ($writerType, $temporaryFile, $sheetIndex, $export) {
                if ($rows instanceof Traversable) {
                    $rows = iterator_to_array($rows);
                }

return new AppendDataToSheet(
                    $export,
                    $temporaryFile,
                    $writerType,
                    $sheetIndex,
                    $rows
                );
            });
    }

/**
     * @param  FromQuery  $export
     * @param  TemporaryFile  $temporaryFile
     * @param  string  $writerType
     * @param  int  $sheetIndex
     * @return Collection
     */
    private function exportQuery(
        FromQuery $export,
        TemporaryFile $temporaryFile,
        string $writerType,
        int $sheetIndex
    ): Collection {
        $query = $export->query();

if ($query instanceof \Laravel\Scout\Builder) {
            return $this->exportScout($export, $temporaryFile, $writerType, $sheetIndex);
        }

$count = $export instanceof WithCustomQuerySize ? $export->querySize() : $query->count();
        $spins = ceil($count / $this->getChunkSize($export));

$jobs = new Collection();

for ($page = 1; $page <= $spins; $page++) {
            $jobs->push(new AppendQueryToSheet(
                $export,
                $temporaryFile,
                $writerType,
                $sheetIndex,
                $page,
                $this->getChunkSize($export)
            ));
        }

return $jobs;
    }

/**
     * @param  FromQuery  $export
     * @param  TemporaryFile  $temporaryFile
     * @param  string  $writerType
     * @param  int  $sheetIndex
     * @return Collection
     */
    private function exportScout(
        FromQuery $export,
        TemporaryFile $temporaryFile,
        string $writerType,
        int $sheetIndex
    ): Collection {
        $jobs = new Collection();

$chunk = $export->query()->paginate($this->getChunkSize($export));
        // Append first page
        $jobs->push(new AppendDataToSheet(
            $export,
            $temporaryFile,
            $writerType,
            $sheetIndex,
            $chunk->items()
        ));

// Append rest of pages
        for ($page = 2; $page <= $chunk->lastPage(); $page++) {
            $jobs->push(new AppendPaginatedToSheet(
                $export,
                $temporaryFile,
                $writerType,
                $sheetIndex,
                $page,
                $this->getChunkSize($export)
            ));
        }

return $jobs;
    }

/**
     * @param  FromView  $export
     * @param  TemporaryFile  $temporaryFile
     * @param  string  $writerType
     * @param  int  $sheetIndex
     * @return Collection
     */
    private function exportView(
        FromView $export,
        TemporaryFile $temporaryFile,
        string $writerType,
        int $sheetIndex
    ): Collection {
        $jobs = new Collection();
        $jobs->push(new AppendViewToSheet(
            $export,
            $temporaryFile,
            $writerType,
            $sheetIndex
        ));

return $jobs;
    }

/**
     * @param  object|WithCustomChunkSize  $export
     * @return int
     */
    private function getChunkSize($export): int
    {
        if ($export instanceof WithCustomChunkSize) {
            return $export->chunkSize();
        }

return $this->chunkSize;
    }
}

Name	Type	Size	Owner/Group	Permission	Last Modified	Actions
.	dir	-	tradinguniversit/tradinguniversit	drwxr-xr-x	2025-02-24 11:12:50
..	dir	-	tradinguniversit/tradinguniversit	drwxr-xr-x	2025-02-24 11:12:50
Cache	dir	-	tradinguniversit/tradinguniversit	drwxr-xr-x	2025-02-24 11:12:50
Concerns	dir	-	tradinguniversit/tradinguniversit	drwxr-xr-x	2025-02-24 11:12:50
Console	dir	-	tradinguniversit/tradinguniversit	drwxr-xr-x	2025-02-24 11:12:50
Events	dir	-	tradinguniversit/tradinguniversit	drwxr-xr-x	2025-02-24 11:12:50
Exceptions	dir	-	tradinguniversit/tradinguniversit	drwxr-xr-x	2025-02-24 11:12:50
Facades	dir	-	tradinguniversit/tradinguniversit	drwxr-xr-x	2025-02-24 11:12:50
Factories	dir	-	tradinguniversit/tradinguniversit	drwxr-xr-x	2025-02-24 11:12:50
Fakes	dir	-	tradinguniversit/tradinguniversit	drwxr-xr-x	2025-02-24 11:12:50
Files	dir	-	tradinguniversit/tradinguniversit	drwxr-xr-x	2025-02-24 11:12:50
Filters	dir	-	tradinguniversit/tradinguniversit	drwxr-xr-x	2025-02-24 11:12:50
Helpers	dir	-	tradinguniversit/tradinguniversit	drwxr-xr-x	2025-02-24 11:12:50
Imports	dir	-	tradinguniversit/tradinguniversit	drwxr-xr-x	2025-02-24 11:12:50
Jobs	dir	-	tradinguniversit/tradinguniversit	drwxr-xr-x	2025-02-24 11:12:50
Middleware	dir	-	tradinguniversit/tradinguniversit	drwxr-xr-x	2025-02-24 11:12:50
Mixins	dir	-	tradinguniversit/tradinguniversit	drwxr-xr-x	2025-02-24 11:12:50
Transactions	dir	-	tradinguniversit/tradinguniversit	drwxr-xr-x	2025-02-24 11:12:50
Validators	dir	-	tradinguniversit/tradinguniversit	drwxr-xr-x	2025-02-24 11:12:50
Cell.php	text/x-php	2.34 KB	tradinguniversit/tradinguniversit	-rw-r--r--	2025-02-24 11:12:50
ChunkReader.php	text/x-php	4.51 KB	tradinguniversit/tradinguniversit	-rw-r--r--	2025-02-24 11:12:50
DefaultValueBinder.php	text/x-php	573 B	tradinguniversit/tradinguniversit	-rw-r--r--	2025-02-24 11:12:50
DelegatedMacroable.php	text/x-php	724 B	tradinguniversit/tradinguniversit	-rw-r--r--	2025-02-24 11:12:50
Excel.php	text/x-php	5.1 KB	tradinguniversit/tradinguniversit	-rw-r--r--	2025-02-24 11:12:50
ExcelServiceProvider.php	text/x-php	4.45 KB	tradinguniversit/tradinguniversit	-rw-r--r--	2025-02-24 11:12:50
Exporter.php	text/x-php	1.44 KB	tradinguniversit/tradinguniversit	-rw-r--r--	2025-02-24 11:12:50
HasEventBus.php	text/x-php	1.33 KB	tradinguniversit/tradinguniversit	-rw-r--r--	2025-02-24 11:12:50
HeadingRowImport.php	text/x-php	952 B	tradinguniversit/tradinguniversit	-rw-r--r--	2025-02-24 11:12:50
Importer.php	text/x-php	1.54 KB	tradinguniversit/tradinguniversit	-rw-r--r--	2025-02-24 11:12:50
MappedReader.php	text/x-php	1.39 KB	tradinguniversit/tradinguniversit	-rw-r--r--	2025-02-24 11:12:50
QueuedWriter.php	text/x-php	7.35 KB	tradinguniversit/tradinguniversit	-rw-r--r--	2025-02-24 11:12:50
Reader.php	text/x-php	13.8 KB	tradinguniversit/tradinguniversit	-rw-r--r--	2025-02-24 11:12:50
RegistersCustomConcerns.php	text/x-php	1.1 KB	tradinguniversit/tradinguniversit	-rw-r--r--	2025-02-24 11:12:50
Row.php	text/x-php	4.12 KB	tradinguniversit/tradinguniversit	-rw-r--r--	2025-02-24 11:12:50
SettingsProvider.php	text/x-php	575 B	tradinguniversit/tradinguniversit	-rw-r--r--	2025-02-24 11:12:50
Sheet.php	text/x-php	25.17 KB	tradinguniversit/tradinguniversit	-rw-r--r--	2025-02-24 11:12:50
Writer.php	text/x-php	8.3 KB	tradinguniversit/tradinguniversit	-rw-r--r--	2025-02-24 11:12:50