ldc-crm/app/Lib/MigrateOldData.php

<?php

namespace App\Lib;

use App\Exceptions\AbortRowImportException;
use App\Models\Brand;
use App\Models\Customer;
use App\Models\CustomerInfo;
use App\Models\CustomerLogin;
use App\Models\SingleOptin;
use Carbon\Exceptions\InvalidFormatException;
use Database\migrations\LeGaulois2016Migration;
use Illuminate\Database\Eloquent\Builder;
use Illuminate\Support\Carbon;
use Illuminate\Support\Facades\File;
use Illuminate\Support\Facades\Hash;
use Illuminate\Support\Facades\Validator;
use Illuminate\Support\Str;

/**
 * @codeCoverageIgnore
 */
class MigrateOldData extends LeGaulois2016Migration
{
    /** @var \App\Models\Brand */
    private $brand;

    /** @var string */
    private $table;

    /**
     * RunMigration.
     *
     * @param \App\Models\Brand $brand
     * @param string            $table
     * @return void
     */
    public function runMigration(Brand $brand, string $table): void
    {
        $this->table = $table;
        $this->brand = $brand;
        $this->instruct();
        $this->up();
    }

    /**
     * Instruct.
     *
     * @return array
     * @phpcs:disable Generic.Metrics.CyclomaticComplexity.TooHigh
     */
    public function instruct(): array
    {
        //phpcs:enable
        $this->initFile();
        $cleanDegeu = function (string $str) {
            return html_entity_decode(
                trim(str_replace('\\', '', ucwords(stripcslashes(strtolower($str))))),
                ENT_QUOTES | ENT_HTML5,
                'UTF-8'
            );
        };
        return [
            'Users' => [
                'table' => $this->table,
                'model' => Customer::class,
                'comment' => sprintf('Migrating %s customers', $this->brand->name),
                'bind' => [
                    'email' => [
                        'apply' => function ($v, $model) use ($cleanDegeu) {
                            $v                      = \mb_convert_encoding($v, "UTF-8");
                            $v                      = explode('#|#', $v);
                            $oldId                  = $v[0];
                            $first_name             = $cleanDegeu($v[1]);
                            $last_name              = $cleanDegeu($v[2]);
                            $birth_date             = $v[3];
                            $address                = $cleanDegeu($v[4]);
                            $address2               = $cleanDegeu($v[5]);
                            $city                   = $cleanDegeu($v[6]);
                            $postcode               = $v[7];
                            $user_inscritNewsletter = $v[8];
                            $email                  = strtolower($v[9]);
                            $pwd                    = $v[10];
                            $created_at             = $v[11];
                            $updated_at             = $v[12];
                            $last_cnx               = $v[13];

                            // * Just save Single optin.
                            if (empty($first_name) && empty($last_name)) {
                                $sglOptin           = SingleOptin::query()->where('email', strtolower($email))
                                    ->whereHas('brand', function (Builder $q) {
                                        $q->where('id', $this->brand->id);
                                    })->firstOrNew();
                                $sglOptin->email    = strtolower($email);
                                $sglOptin->brand_id = $this->brand->id;
                                $sglOptin->save();
                            } else {
                                // * Validate Data.
                                $d = [
                                    'first_name' => $first_name,
                                    'last_name' => $last_name,
                                    'address' => $address,
                                    'address2' => $address2,
                                    'city' => $city,
                                    'postcode' => $postcode,
                                ];

                                $validator = Validator::make($d, [
                                    'first_name' => 'min:2',
                                    'last_name' => 'min:2'
                                ]);

                                if ($validator->fails()) {
                                    throw new AbortRowImportException();
                                }

                                $rules = [
                                    'address' => 'string|min:2',
                                    'address2' => 'string|min:2',
                                    'city' => 'string|min:2',
                                    'postcode' => 'digits_between:4,5'
                                ];

                                $validate = function (array $data, array $rule) {
                                    return Validator::make($data, $rule)->fails();
                                };

                                foreach ($rules as $key => $rule) {
                                    if ($validate([$key => $d[$key]], [$key => $rule])) {
                                        ${$key} = null;
                                    }
                                }

                                $model             = Customer::where('email', $email)->firstOrNew();
                                $model->email      = $email;
                                $model->created_at = $created_at;
                                $model->updated_at = $updated_at;
                                $model->save();

                                // * Filtre birthdate puisque c'est du sale dans la vielle crm.
                                try {
                                    $expl = explode('-', $birth_date);
                                    $d    = Carbon::parse($birth_date);
                                    if (
                                        $d->toDateString() === sprintf(
                                            '%s-%s-%s',
                                            $expl[2] ?? '',
                                            $expl[1] ?? '',
                                            $expl[0] ?? ''
                                        )
                                    ) {
                                        $birth_date = $d->toDateString();
                                    }
                                } catch (InvalidFormatException $e) {
                                    $birth_date = '';
                                }


                                if ($birth_date === '0000-00-00') {
                                    $birth_date = '';
                                }

                                $city     = !empty($city) ? $city : null;
                                $postcode = !empty($postcode) ? $postcode : null;
                                $address  = !empty($address) ? $address : null;
                                $address2 = !empty($address2) ? $address2 : null;

                                $cInfo              = new CustomerInfo();
                                $cInfo->hashcode    = Str::uuid();
                                $cInfo->firstname   = ucfirst(strtolower($first_name));
                                $cInfo->lastname    = ucfirst(strtolower($last_name));
                                $cInfo->birth_date  = !strlen($birth_date) ? null : $birth_date;
                                $cInfo->address     = $address;
                                $cInfo->address2    = $address2;
                                $cInfo->city        = $city;
                                $cInfo->postcode    = $postcode;
                                $cInfo->opt_in      = $user_inscritNewsletter ? true : false;
                                $cInfo->brand_id    = $this->brand->id;
                                $cInfo->customer_id = $model->id;
                                $cInfo->created_at  = $created_at;
                                $cInfo->updated_at  = $updated_at;
                                $cInfo->save();

                                $cLogin                  = new CustomerLogin();
                                $cLogin->password        = Hash::make(trim($pwd));
                                $cLogin->brand_id        = $this->brand->id;
                                $cLogin->customer_id     = $model->id;
                                $cLogin->status          = true;
                                $cLogin->created_at      = $created_at;
                                $cLogin->updated_at      = $updated_at;
                                $cLogin->last_connection = $last_cnx;
                                $cLogin->save();

                                $this->write(
                                    [
                                        'new' => $model->id,
                                        'old' => $oldId,
                                        'hashcode' => $cInfo->hashcode,
                                        'created_at' => $created_at,
                                        'updated_at' => $updated_at
                                    ]
                                );
                            } //end if
                            throw new AbortRowImportException();
                        },
                        'name' => [
                            'user_id',
                            'firstname',
                            'lastname',
                            'birthdate',
                            'address',
                            'address2',
                            'city',
                            'postcode',
                            'optin',
                            'email',
                            'pwd',
                            'created_at',
                            'updated_at',
                            'last_cnx'
                        ]
                    ],
                ]
            ],
        ];
    }

    /**
     * Create the migration file.
     *
     * @return void
     */
    public function initFile(): void
    {
        File::put(storage_path('crm_migration.csv'), sprintf('new;old;hashcode;created_at;updated_at') . PHP_EOL);
    }

    /**
     * Write date in the migration file.
     *
     * @param array $data
     * @return void
     */
    public function write(array $data): void
    {
        foreach ($data as &$d) {
            $d = sprintf('"%s"', $d);
        }
        File::append(storage_path('crm_migration.csv'), implode(';', $data) . PHP_EOL);
    }
}