Data transfer

composer.json

@@ -59,6 +59,8 @@
             "Webkul\\Attribute\\": "packages/Webkul/Attribute/src",
             "Webkul\\Contact\\": "packages/Webkul/Contact/src",
             "Webkul\\Core\\": "packages/Webkul/Core/src",
+            "Webkul\\DataGrid\\": "packages/Webkul/DataGrid/src",
+            "Webkul\\DataTransfer\\": "packages/Webkul/DataTransfer/src",
             "Webkul\\Email\\": "packages/Webkul/Email/src",
             "Webkul\\EmailTemplate\\": "packages/Webkul/EmailTemplate/src",
             "Webkul\\Installer\\": "packages/Webkul/Installer/src",
@@ -69,8 +71,7 @@
             "Webkul\\User\\": "packages/Webkul/User/src",
             "Webkul\\Warehouse\\": "packages/Webkul/Warehouse/src",
             "Webkul\\WebForm\\": "packages/Webkul/WebForm/src",
-            "Webkul\\Automation\\": "packages/Webkul/Automation/src",
-            "Webkul\\DataGrid\\": "packages/Webkul/DataGrid/src"
+            "Webkul\\Automation\\": "packages/Webkul/Automation/src"
         }
     },
     "autoload-dev": {

config/app.php

@@ -206,6 +206,7 @@
         Webkul\Contact\Providers\ContactServiceProvider::class,
         Webkul\Core\Providers\CoreServiceProvider::class,
         Webkul\DataGrid\Providers\DataGridServiceProvider::class,
+        Webkul\DataTransfer\Providers\DataTransferServiceProvider::class,
         Webkul\EmailTemplate\Providers\EmailTemplateServiceProvider::class,
         Webkul\Email\Providers\EmailServiceProvider::class,
         Webkul\Installer\Providers\InstallerServiceProvider::class,

config/concord.php

@@ -18,6 +18,7 @@
         \Webkul\User\Providers\ModuleServiceProvider::class,
         \Webkul\Warehouse\Providers\ModuleServiceProvider::class,
         \Webkul\WebForm\Providers\ModuleServiceProvider::class,
+        \Webkul\DataTransfer\Providers\ModuleServiceProvider::class,
     ],
 
     'register_route_models' => true,

database/migrations/2024_09_09_094040_create_job_batches_table.php

@@ -0,0 +1,39 @@
+<?php
+
+use Illuminate\Database\Migrations\Migration;
+use Illuminate\Database\Schema\Blueprint;
+use Illuminate\Support\Facades\Schema;
+
+return new class extends Migration
+{
+    /**
+     * Run the migrations.
+     *
+     * @return void
+     */
+    public function up()
+    {
+        Schema::create('job_batches', function (Blueprint $table) {
+            $table->string('id')->primary();
+            $table->string('name');
+            $table->integer('total_jobs');
+            $table->integer('pending_jobs');
+            $table->integer('failed_jobs');
+            $table->text('failed_job_ids');
+            $table->mediumText('options')->nullable();
+            $table->integer('cancelled_at')->nullable();
+            $table->integer('created_at');
+            $table->integer('finished_at')->nullable();
+        });
+    }
+
+    /**
+     * Reverse the migrations.
+     *
+     * @return void
+     */
+    public function down()
+    {
+        Schema::dropIfExists('job_batches');
+    }
+};

database/migrations/2024_09_09_094042_create_jobs_table.php

@@ -0,0 +1,36 @@
+<?php
+
+use Illuminate\Database\Migrations\Migration;
+use Illuminate\Database\Schema\Blueprint;
+use Illuminate\Support\Facades\Schema;
+
+return new class extends Migration
+{
+    /**
+     * Run the migrations.
+     *
+     * @return void
+     */
+    public function up()
+    {
+        Schema::create('jobs', function (Blueprint $table) {
+            $table->bigIncrements('id');
+            $table->string('queue')->index();
+            $table->longText('payload');
+            $table->unsignedTinyInteger('attempts');
+            $table->unsignedInteger('reserved_at')->nullable();
+            $table->unsignedInteger('available_at');
+            $table->unsignedInteger('created_at');
+        });
+    }
+
+    /**
+     * Reverse the migrations.
+     *
+     * @return void
+     */
+    public function down()
+    {
+        Schema::dropIfExists('jobs');
+    }
+};

packages/Webkul/Admin/src/Config/acl.php

@@ -452,7 +452,39 @@
         'name'  => 'admin::app.acl.delete',
         'route' => ['admin.settings.tags.delete', 'admin.settings.tags.mass_delete', 'admin.leads.tags.detach'],
         'sort'  => 2,
+    ],
+    [
+        'key'   => 'settings.data_transfer',
+        'name'  => 'admin::app.acl.data-transfer',
+        'route' => 'admin.settings.data_transfer.imports.index',
+        'sort'  => 10,
+    ], [
+        'key'   => 'settings.data_transfer.imports',
+        'name'  => 'admin::app.acl.imports',
+        'route' => 'admin.settings.data_transfer.imports.index',
+        'sort'  => 1,
+    ], [
+        'key'   => 'settings.data_transfer.imports.create',
+        'name'  => 'admin::app.acl.create',
+        'route' => 'admin.settings.data_transfer.imports.create',
+        'sort'  => 1,
     ], [
+        'key'   => 'settings.data_transfer.imports.edit',
+        'name'  => 'admin::app.acl.edit',
+        'route' => 'admin.settings.data_transfer.imports.edit',
+        'sort'  => 2,
+    ], [
+        'key'   => 'settings.data_transfer.imports.delete',
+        'name'  => 'admin::app.acl.delete',
+        'route' => 'admin.settings.data_transfer.imports.delete',
+        'sort'  => 3,
+    ], [
+        'key'   => 'settings.data_transfer.imports.import',
+        'name'  => 'admin::app.acl.import',
+        'route' => 'admin.settings.data_transfer.imports.imports',
+        'sort'  => 4,
+    ],
+    [
         'key'   => 'configuration',
         'name'  => 'admin::app.acl.configuration',
         'route' => 'admin.configuration.index',

packages/Webkul/Admin/src/Config/menu.php

@@ -247,6 +247,14 @@
         'route'      => 'admin.settings.workflows.index',
         'sort'       => 3,
         'icon-class' => 'icon-settings-flow',
+    ],
+    [
+        'key'        => 'settings.automation.data_transfer',
+        'name'       => 'admin::app.layouts.data_transfer',
+        'info'       => 'admin::app.layouts.data_transfer_info',
+        'route'      => 'admin.settings.data_transfer.imports.index',
+        'sort'       => 4,
+        'icon-class' => 'icon-download',
     ], [
         'key'        => 'settings.other_settings',
         'name'       => 'admin::app.layouts.other-settings',
@@ -273,4 +281,5 @@
         'sort'       => 9,
         'icon-class' => 'icon-configuration',
     ],
+
 ];

packages/Webkul/Admin/src/DataGrids/Settings/DataTransfer/ImportDataGrid.php

@@ -0,0 +1,161 @@
+<?php
+
+namespace Webkul\Admin\DataGrids\Settings\DataTransfer;
+
+use Illuminate\Database\Query\Builder;
+use Illuminate\Support\Facades\DB;
+use Webkul\DataGrid\DataGrid;
+
+class ImportDataGrid extends DataGrid
+{
+    /**
+     * Prepare query builder.
+     */
+    public function prepareQueryBuilder(): Builder
+    {
+        return DB::table('imports')
+            ->select(
+                'id',
+                'state',
+                'file_path',
+                'error_file_path',
+                'started_at',
+                'completed_at',
+                'type',
+                'summary',
+            );
+    }
+
+    /**
+     * Prepare Columns.
+     */
+    public function prepareColumns(): void
+    {
+        $this->addColumn([
+            'index'      => 'id',
+            'label'      => trans('admin::app.settings.data-transfer.imports.index.datagrid.id'),
+            'type'       => 'integer',
+            'filterable' => true,
+            'sortable'   => true,
+        ]);
+
+        $this->addColumn([
+            'index'      => 'type',
+            'label'      => trans('admin::app.settings.data-transfer.imports.index.datagrid.type'),
+            'type'       => 'string',
+            'filterable' => true,
+            'sortable'   => true,
+        ]);
+
+        $this->addColumn([
+            'index'      => 'state',
+            'label'      => trans('admin::app.settings.data-transfer.imports.index.datagrid.state'),
+            'type'       => 'string',
+            'filterable' => true,
+            'sortable'   => true,
+        ]);
+
+        $this->addColumn([
+            'index'      => 'file_path',
+            'label'      => trans('admin::app.settings.data-transfer.imports.index.datagrid.uploaded-file'),
+            'type'       => 'string',
+            'closure'    => function ($row) {
+                return '<a href="'.route('admin.settings.data_transfer.imports.download', $row->id).'" class="cursor-pointer text-blue-600 hover:underline">'.$row->file_path.'<a>';
+            },
+        ]);
+
+        $this->addColumn([
+            'index'      => 'error_file_path',
+            'label'      => trans('admin::app.settings.data-transfer.imports.index.datagrid.error-file'),
+            'type'       => 'string',
+            'closure'    => function ($row) {
+                if (empty($row->error_file_path)) {
+                    return '';
+                }
+
+                return '<a href="'.route('admin.settings.data_transfer.imports.download_error_report', $row->id).'" class="cursor-pointer text-blue-600 hover:underline">'.$row->error_file_path.'<a>';
+            },
+        ]);
+
+        $this->addColumn([
+            'index'           => 'started_at',
+            'label'           => trans('admin::app.settings.data-transfer.imports.index.datagrid.started-at'),
+            'type'            => 'date',
+            'filterable'      => true,
+            'filterable_type' => 'date_range',
+            'sortable'        => true,
+        ]);
+
+        $this->addColumn([
+            'index'           => 'completed_at',
+            'label'           => trans('admin::app.settings.data-transfer.imports.index.datagrid.completed-at'),
+            'type'            => 'date',
+            'filterable'      => true,
+            'filterable_type' => 'date_range',
+            'sortable'        => true,
+        ]);
+
+        $this->addColumn([
+            'index'      => 'summary',
+            'label'      => trans('admin::app.settings.data-transfer.imports.index.datagrid.summary'),
+            'type'       => 'string',
+            'closure'    => function ($row) {
+                if (empty($row->summary)) {
+                    return '';
+                }
+
+                $summary = json_decode($row->summary, true);
+
+                $stats = [];
+
+                foreach ($summary as $type => $value) {
+                    $stats[] = trans('admin::app.settings.data-transfer.imports.index.datagrid.'.$type).': '.$summary[$type];
+                }
+
+                return implode(', ', $stats);
+            },
+        ]);
+    }
+
+    /**
+     * Prepare actions.
+     */
+    public function prepareActions(): void
+    {
+        if (bouncer()->hasPermission('settings.data_transfer.imports.import')) {
+            $this->addAction([
+                'index'  => 'import',
+                'icon'   => 'icon-import',
+                'title'  => trans('admin::app.settings.data-transfer.imports.index.datagrid.import'),
+                'method' => 'GET',
+                'url'    => function ($row) {
+                    return route('admin.settings.data_transfer.imports.import', $row->id);
+                },
+            ]);
+        }
+
+        if (bouncer()->hasPermission('settings.data_transfer.imports.edit')) {
+            $this->addAction([
+                'index'  => 'edit',
+                'icon'   => 'icon-edit',
+                'title'  => trans('admin::app.settings.data-transfer.imports.index.datagrid.edit'),
+                'method' => 'GET',
+                'url'    => function ($row) {
+                    return route('admin.settings.data_transfer.imports.edit', $row->id);
+                },
+            ]);
+        }
+
+        if (bouncer()->hasPermission('settings.data_transfer.imports.delete')) {
+            $this->addAction([
+                'index'  => 'delete',
+                'icon'   => 'icon-delete',
+                'title'  => trans('admin::app.settings.data-transfer.imports.index.datagrid.delete'),
+                'method' => 'DELETE',
+                'url'    => function ($row) {
+                    return route('admin.settings.data_transfer.imports.delete', $row->id);
+                },
+            ]);
+        }
+    }
+}

packages/Webkul/Admin/src/Http/Controllers/Contact/Persons/PersonController.php

@@ -186,8 +186,12 @@ private function sanitizeRequestedPersonData(array $data): array
             $data['organization_id'] = null;
         }
 
+        $data['unique_id'] = $data['user_id'].'|'.$data['organization_id'].'|'.$data['emails'][0]['value'];
+
         if (isset($data['contact_numbers'])) {
             $data['contact_numbers'] = collect($data['contact_numbers'])->filter(fn ($number) => ! is_null($number['value']))->toArray();
+
+            $data['unique_id'] .= '|'.$data['contact_numbers'][0]['value'];
         }
 
         return $data;