CsvCombine\LargeExport\LargeCsvExport

Complexity

Total Complexity

12

Size/Duplication

Total Lines	119
Duplicated Lines	3.36 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes	5
Bugs	0	Features	0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	9	1
A	getTmpFileName()	0	9	2
A	parseCsv()	4	14	3
A	addRow()	0	12	3
A	writeRow()	0	6	1
A	read()	0	11	1
A	getPath()	0	6	1

<?php
namespace CsvCombine\LargeExport;
use Cake\Network\Exception\MethodNotAllowedException;
use Cake\Utility\Security;
use Cake\Filesystem\File;

/**
 * LargeCsvExport  code license:
 *
 * @copyright Copyright (C) 2011 hagiwara.
 * @since CakePHP(tm) v 1.3
 * @license http://www.opensource.org/licenses/mit-license.php The MIT License
 */
class LargeCsvExport {

    private $tmpCsvFp;
    private $defaultSettings = [
        'delimiter' => ',',
        'export_encoding' => 'SJIS-win',
        'array_encoding' => 'UTF-8',
        'write_span' => 1,
    ];
    private $settings;
    private $tmpRowText = '';
    private $rowCount = 0;

    /**
     * __construct
     *
     */
    public function __construct($settings = [])
    {
        // 設定値
        $this->settings = array_merge(
            $this->defaultSettings,
            $settings
        );
        $this->tmpCsvFp = new File($this->getTmpFileName());
    }

    /**
     * getTmpFileName
     *　一時ファイルの取得
     */
    private function getTmpFileName()
    {
        $tmpFileName = TMP . 'csv_file_' . Security::hash(time() . rand());
        // ファイルが存在した場合は何もしない
        if (file_exists($tmpFileName)) {
            return $this->getTmpFileName();
        }
        return $tmpFileName;
    }

    /**
     * addRow
     *　都度都度ファイルに追記をしていく
     */
    public function addRow($lists)
    {
        if (!is_array($lists)) {
            throw new MethodNotAllowedException('$list must be array.');
        }
        $this->rowCount++;
        $csvRow = $this->parseCsv($lists);
        $this->tmpRowText .= $csvRow;
        if ($this->rowCount % $this->settings['write_span'] == 0) {
            $this->writeRow();
        }
    }

    /**
     * writeRow
     *　行の書き込み
     */
    private function writeRow()
    {
        $this->tmpCsvFp->write($this->tmpRowText, 'a');
        // 一時的なテキストの初期化
        $this->tmpRowText = '';
    }

    /**
     * read
     *　csvテキストデータの読み込み(及び一時ファイルの削除)
     */
    public function read()
    {
        // 書き込みの残りがあれば書き込む
        $this->writeRow();

        $csvText = $this->tmpCsvFp->read();
        // ファイル削除
        $this->tmpCsvFp->delete();
        $this->tmpCsvFp->close();
        return $csvText;
    }

    /**
     * getPath
     *　ファイルパスの取得。readメソッドでメモリで落ちる場合はパスを取得してrequest->fileでDLする
     */
    public function getPath()
    {
        // 書き込みの残りがあれば書き込む
        $this->writeRow();
        return $this->tmpCsvFp->pwd();
    }

    /*
     * _parseCsv
     * csv(など)の形式に変更
     *
     * @param array $lists 変換する値
     * @param string 1行分のCSVテキストデータ
     */
    private function parseCsv($lists)
    {
        // 文字コードの変換
        mb_convert_variables($this->settings['export_encoding'], $this->settings['array_encoding'], $lists);
        foreach ($lists as $listKey => $list) {
            //区切り文字・改行・ダブルクオートの時
            if (preg_match('/[' . $this->settings['delimiter'] . '\\n"]/', $list)) {

This code seems to be duplicated across your project.

                $list = str_replace('"', '""', $list);
                $lists[$listKey] = '"' . $list . '"';
            }
        }
        // カンマ区切り
        return implode($this->settings['delimiter'], $lists) . "\r\n";
    }

}