xyzshop/helper/bank/execl_loader.php

<?php

namespace bank;

require_once(BASE_ROOT_PATH . '/vendor/autoload.php');

use PhpOffice;
use Log;

function file_generator($path)
{
    if (!file_exists($path)) {
        return;
    }

    $fd = opendir($path);
    if ($fd)
    {
        while (($item = @readdir($fd)) !== false)
        {
            $sub = $path . DIRECTORY_SEPARATOR . $item;
            if (is_dir($sub) && $item != '.' && $item != '..')
            {
                $files = file_generator($sub);
                foreach ($files as $file) {
                    yield $file;
                }
            }
            elseif (is_file($sub)) {
                yield $sub;
            }
        }
    }
    closedir($fd);
}


class execl_loader
{
    public function load_dirs($dirs)
    {
        foreach ($dirs as $dir) {
            $this->load_dir($dir);
        }
    }

    public function load_dir($dir)
    {
        $files = file_generator($dir);
        foreach ($files as $file) {
            Log::record("$file",Log::DEBUG);
            $this->load_file($file);
        }
    }

    public function load_file($file)
    {
        $line_reader = function ($file)
        {
            $ext = pathinfo($file,PATHINFO_EXTENSION);
            if(!in_array($ext,['xls','xlsx'])) {
                return;
            }

            $reader = PhpOffice\PhpSpreadsheet\IOFactory::createReaderForFile($file);
            $reader->setReadDataOnly(true);
            $spreadsheet = PhpOffice\PhpSpreadsheet\IOFactory::load($file);

            yield 'start' => 1;

            foreach ($spreadsheet->getWorksheetIterator() as $worksheet)
            {
                foreach ($worksheet->getRowIterator() as $row)
                {
                    $cellIterator = $row->getCellIterator();
                    $cellIterator->setIterateOnlyExistingCells(false); // Loop all cells, even if it is not set

                    $item = [];
                    foreach ($cellIterator as $cell)
                    {
                        if ($cell !== null) {
                            $item[] = trim($cell->getFormattedValue());
                        }
                    }

                    yield 'line' => $item;
                }
            }

            yield 'start' => 0;
        };

        $mod_record = Model();
        $inserter = function ($line) use ($mod_record){
            $mod_record->table('bank_record')->insert($line);
        };

        $lines = $line_reader($file);
        $convert = new converter();
        foreach ($lines as $key => $val)
        {
            if($key === 'start') {
                $convert->start();
            }
            elseif($key === 'line')
            {
                $line = $convert->convert($val);
                if(!empty($line) && !empty($line['trade_no'])) {
                    $inserter($line);
                }
                else {
                    Log::record(json_encode($val,JSON_UNESCAPED_UNICODE),Log::DEBUG);
                }
            }
            else {
                $convert->end();
            }
        }
    }
}