pepepper/tissue
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

インポート可能な件数に上限を設ける

Browse Source
This commit is contained in:
shibafu 2020-05-23 15:35:17 +09:00
parent c0d62f5112
commit bd84effedc
1 changed files with 10 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
app/Services/CheckinCsvImporter.php
View File

@ -17,6 +17,9 @@ use Throwable;
class CheckinCsvImporter class CheckinCsvImporter
{ {
/** @var int 取り込み件数の上限 */
private const IMPORT_LIMIT = 5000;
/** @var User Target user */ /** @var User Target user */
private $user; private $user;
/** @var string CSV filename */ /** @var string CSV filename */
@ -42,6 +45,7 @@ class CheckinCsvImporter
// Import // Import
return DB::transaction(function () use ($csv) { return DB::transaction(function () use ($csv) {
$alreadyImportedCount = $this->user->ejaculations()->where('ejaculation.source', Ejaculation::SOURCE_CSV)->count();
$errors = []; $errors = [];
if (!in_array('日時', $csv->getHeader(), true)) { if (!in_array('日時', $csv->getHeader(), true)) {
@ -55,6 +59,12 @@ class CheckinCsvImporter
$imported = 0; $imported = 0;
foreach ($csv->getRecords() as $offset => $record) { foreach ($csv->getRecords() as $offset => $record) {
$line = $offset + 1; $line = $offset + 1;
if (self::IMPORT_LIMIT < $alreadyImportedCount + $imported) {
$limit = self::IMPORT_LIMIT;
$errors[] = "{$line} 行 : インポート機能で取り込めるデータは{$limit}件までに制限されています。これ以上取り込みできません。";
throw new CsvImportException(...$errors);
}
$ejaculation = new Ejaculation(['user_id' => $this->user->id]); $ejaculation = new Ejaculation(['user_id' => $this->user->id]);
$validator = Validator::make($record, [ $validator = Validator::make($record, [