303834bbca
- Make all tests pass Client (V4),CRMV2,CRMV4 - Simplify client submodule path - Move App_url to .env.testing
251 lines
10 KiB
PHP
251 lines
10 KiB
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);
|
|
}
|
|
}
|