Viewing file:  ContactsImport.php (3.58 KB) -rw-r--r--
Select action/file-type:
 (+) |  (+) |  (+) | Code (+) | Session (+) |  (+) | SDB (+) |  (+) |  (+) |  (+) |  (+) |  (+) |
<?php
namespace App\Imports;
use App\Models\Contact;
use App\Models\ContactGroup;
use App\Models\Group;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Support\Collection;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Log;
use Maatwebsite\Excel\Concerns\SkipsOnError;
use Maatwebsite\Excel\Concerns\SkipsOnFailure;
use Maatwebsite\Excel\Concerns\ToCollection;
use Maatwebsite\Excel\Concerns\WithChunkReading;
use Maatwebsite\Excel\Concerns\WithEvents;
use Maatwebsite\Excel\Concerns\WithHeadingRow;
use Maatwebsite\Excel\Concerns\WithValidation;
use Maatwebsite\Excel\Concerns\SkipsErrors;
use Maatwebsite\Excel\Events\AfterImport;
use Maatwebsite\Excel\Events\BeforeImport;
use Maatwebsite\Excel\Events\ImportFailed;
class ContactsImport implements ToCollection, WithHeadingRow, SkipsOnError, WithChunkReading, ShouldQueue, WithEvents
{
use SkipsErrors;
public $group_id = '';
public function __construct($group_id, $auth_user)
{
$this->auth_user = $auth_user;
$this->group_id = $group_id;
}
/**
* @param Collection $rows
* @throws \Throwable
*/
public function collection(Collection $rows)
{
$errorMsg = "";
DB::beginTransaction();
$i = 1;
$contactGroup = [];
foreach ($rows as $key => $row) {
if (isset($row['email']) && $row['email']) {
//You can validate other values using same steps.
$data['first_name'] = $row['first_name'] ?? '';
$data['last_name'] = $row['last_name'] ?? '';
$data['email'] = $row['email'] ?? '';
$data['company'] = $row['company'] ?? '';
$data['address'] = $row['address'] ?? '';
$data['city'] = $row['city'] ?? '';
$data['state'] = $row['state'] ?? '';
$data['zip_code'] = $row['zip_code'] ?? '';
$data['note'] = $row['note'] ?? '';
$contact = $this->auth_user->contacts()->create($data);
$contactGroup[] = [
'customer_id' => $this->auth_user->id,
'group_id' => $this->group_id,
'contact_id' => $contact->id,
'created_at' => now(),
'updated_at' => now()
];
if (!$contact) {
$errorMsg = "Error while inserting";
break;
}
$i++;
}
}
if ($contactGroup) {
foreach (array_chunk($contactGroup, 1000) as $contactChunk) {
ContactGroup::insert($contactChunk);
}
}
if (!empty($errorMsg)) {
// Rollback in case there is error
DB::rollBack();
} else {
// Commit to database
DB::commit();
}
}
public function chunkSize(): int
{
return 2000;
}
public function registerEvents(): array
{
return [
ImportFailed::class => function (ImportFailed $event) {
Group::where('id', $this->group_id)->update(['import_status' => 'failed', 'import_fail_message' => substr($event->getException(), 0, 191)]);
},
BeforeImport::class => function (BeforeImport $event) {
Group::where('id', $this->group_id)->update(['import_status' => 'running']);
},
AfterImport::class => function (AfterImport $event) {
Group::where('id', $this->group_id)->update(['import_status' => 'completed']);
}
];
}
}
|