Working on client import

app/Http/Controllers/ImportController.php

@@ -79,7 +79,7 @@ class ImportController extends Controller
         $hash = Str::random(32);
 
         //store the csv in cache with an expiry of 10 minutes
-        Cache::put($hash, base64_encode(file_get_contents($request->file('file')->getPathname())), 60);
+        Cache::put($hash, base64_encode(file_get_contents($request->file('file')->getPathname())), 3600);
 
         //parse CSV
         $csv_array = $this->getCsvData(file_get_contents($request->file('file')->getPathname()));

app/Import/Transformers/BaseTransformer.php

@@ -0,0 +1,352 @@
+<?php
+
+namespace App\Import\Transformers;
+
+use Carbon;
+use Exception;
+
+/**
+ * Class BaseTransformer.
+ */
+class BaseTransformer 
+{
+    /**
+     * @var
+     */
+    protected $maps;
+
+    /**
+     * BaseTransformer constructor.
+     *
+     * @param $maps
+     */
+    public function __construct($maps)
+    {
+        $this->maps = $maps;
+    }
+
+
+    /**
+     * @param $data
+     * @param $field
+     *
+     * @return string
+     */
+    public function getString($data, $field)
+    {
+        return (isset($data[$field]) && $data[$field]) ? $data[$field] : '';
+    }
+
+    public function getCurrencyByCode($data)
+    {
+        $code = $data['client.currency_id'];
+
+        info(print_r($this->maps['currencies']->where('code', $code)->first(),1));
+        
+        if($code)
+            return $this->maps['currencies']->where('code', $code)->first()->id;  
+
+        return $this->maps['company']->settings->currency_id;      
+    }
+
+    /**
+     * @param $name
+     *
+     * @return bool
+     */
+    public function hasClient($name)
+    {
+        $name = trim(strtolower($name));
+
+        return isset($this->maps[ENTITY_CLIENT][$name]);
+    }
+
+    /**
+     * @param $name
+     *
+     * @return bool
+     */
+    public function hasVendor($name)
+    {
+        $name = trim(strtolower($name));
+
+        return isset($this->maps[ENTITY_VENDOR][$name]);
+    }
+
+
+    /**
+     * @param $key
+     *
+     * @return bool
+     */
+    public function hasProduct($key)
+    {
+        $key = trim(strtolower($key));
+
+        return isset($this->maps[ENTITY_PRODUCT][$key]);
+    }
+
+
+    /**
+     * @param $data
+     * @param $field
+     *
+     * @return int
+     */
+    public function getNumber($data, $field)
+    {
+        return (isset($data->$field) && $data->$field) ? $data->$field : 0;
+    }
+
+    /**
+     * @param $data
+     * @param $field
+     *
+     * @return float
+     */
+    public function getFloat($data, $field)
+    {
+        return (isset($data->$field) && $data->$field) ? Utils::parseFloat($data->$field) : 0;
+    }
+
+    /**
+     * @param $name
+     *
+     * @return null
+     */
+    public function getClientId($name)
+    {
+        $name = strtolower(trim($name));
+
+        return isset($this->maps[ENTITY_CLIENT][$name]) ? $this->maps[ENTITY_CLIENT][$name] : null;
+    }
+
+    /**
+     * @param $name
+     *
+     * @return null
+     */
+    public function getProduct($data, $key, $field, $default = false)
+    {
+        $productKey = trim(strtolower($data->$key));
+
+        if (! isset($this->maps['product'][$productKey])) {
+            return $default;
+        }
+
+        $product = $this->maps['product'][$productKey];
+
+        return $product->$field ?: $default;
+    }
+
+    /**
+     * @param $name
+     *
+     * @return null
+     */
+    public function getContact($email)
+    {
+        $email = trim(strtolower($email));
+
+        if (! isset($this->maps['contact'][$email])) {
+            return false;
+        }
+
+        return $this->maps['contact'][$email];
+    }
+
+
+    /**
+     * @param $name
+     *
+     * @return null
+     */
+    public function getCustomer($key)
+    {
+        $key = trim($key);
+
+        if (! isset($this->maps['customer'][$key])) {
+            return false;
+        }
+
+        return $this->maps['customer'][$key];
+    }
+
+    /**
+     * @param $name
+     *
+     * @return null
+     */
+    public function getCountryId($name)
+    {
+        $name = strtolower(trim($name));
+
+        return isset($this->maps['countries'][$name]) ? $this->maps['countries'][$name] : null;
+    }
+
+    /**
+     * @param $name
+     *
+     * @return null
+     */
+    public function getCountryIdBy2($name)
+    {
+        $name = strtolower(trim($name));
+
+        return isset($this->maps['countries2'][$name]) ? $this->maps['countries2'][$name] : null;
+    }
+
+    /**
+     * @param $name
+     *
+     * @return null
+     */
+    public function getTaxRate($name)
+    {
+        $name = strtolower(trim($name));
+
+        return isset($this->maps['tax_rates'][$name]) ? $this->maps['tax_rates'][$name] : 0;
+    }
+
+    /**
+     * @param $name
+     *
+     * @return null
+     */
+    public function getTaxName($name)
+    {
+        $name = strtolower(trim($name));
+
+        return isset($this->maps['tax_names'][$name]) ? $this->maps['tax_names'][$name] : '';
+    }
+
+    /**
+     * @param $name
+     *
+     * @return mixed
+     */
+    public function getFirstName($name)
+    {
+        $name = Utils::splitName($name);
+
+        return $name[0];
+    }
+
+    /**
+     * @param $date
+     * @param string $format
+     * @param mixed  $data
+     * @param mixed  $field
+     *
+     * @return null
+     */
+    public function getDate($data, $field)
+    {
+        if ($date = data_get($data, $field)) {
+            try {
+                $date = new Carbon($date);
+            } catch (Exception $e) {
+                // if we fail to parse return blank
+                $date = false;
+            }
+        }
+
+        return $date ? $date->format('Y-m-d') : null;
+    }
+
+    /**
+     * @param $name
+     *
+     * @return mixed
+     */
+    public function getLastName($name)
+    {
+        $name = Utils::splitName($name);
+
+        return $name[1];
+    }
+
+    /**
+     * @param $number
+     *
+     * @return string
+     */
+    public function getInvoiceNumber($number)
+    {
+        return $number ? str_pad(trim($number), 4, '0', STR_PAD_LEFT) : null;
+    }
+
+    /**
+     * @param $invoiceNumber
+     *
+     * @return null
+     */
+    public function getInvoiceId($invoiceNumber)
+    {
+        $invoiceNumber = $this->getInvoiceNumber($invoiceNumber);
+        $invoiceNumber = strtolower($invoiceNumber);
+        return isset($this->maps[ENTITY_INVOICE][$invoiceNumber]) ? $this->maps[ENTITY_INVOICE][$invoiceNumber] : null;
+    }
+
+    /**
+     * @param $invoiceNumber
+     *
+     * @return null
+     */
+    public function getInvoicePublicId($invoiceNumber)
+    {
+        $invoiceNumber = $this->getInvoiceNumber($invoiceNumber);
+        $invoiceNumber = strtolower($invoiceNumber);
+        return isset($this->maps['invoices'][$invoiceNumber]) ? $this->maps['invoices'][$invoiceNumber]->public_id : null;
+    }
+
+    /**
+     * @param $invoiceNumber
+     *
+     * @return bool
+     */
+    public function hasInvoice($invoiceNumber)
+    {
+        $invoiceNumber = $this->getInvoiceNumber($invoiceNumber);
+        $invoiceNumber = strtolower($invoiceNumber);
+
+        return isset($this->maps[ENTITY_INVOICE][$invoiceNumber]);
+    }
+
+    /**
+     * @param $invoiceNumber
+     *
+     * @return null
+     */
+    public function getInvoiceClientId($invoiceNumber)
+    {
+        $invoiceNumber = $this->getInvoiceNumber($invoiceNumber);
+        $invoiceNumber = strtolower($invoiceNumber);
+
+        return isset($this->maps[ENTITY_INVOICE.'_'.ENTITY_CLIENT][$invoiceNumber]) ? $this->maps[ENTITY_INVOICE.'_'.ENTITY_CLIENT][$invoiceNumber] : null;
+    }
+
+    /**
+     * @param $name
+     *
+     * @return null
+     */
+    public function getVendorId($name)
+    {
+        $name = strtolower(trim($name));
+
+        return isset($this->maps[ENTITY_VENDOR][$name]) ? $this->maps[ENTITY_VENDOR][$name] : null;
+    }
+
+    /**
+     * @param $name
+     *
+     * @return null
+     */
+    public function getExpenseCategoryId($name)
+    {
+        $name = strtolower(trim($name));
+
+        return isset($this->maps[ENTITY_EXPENSE_CATEGORY][$name]) ? $this->maps[ENTITY_EXPENSE_CATEGORY][$name] : null;
+    }
+}

app/Import/Transformers/ClientTransformer.php

@@ -0,0 +1,70 @@
+<?php
+
+namespace App\Import\Transformers;
+
+use Illuminate\Support\Str;
+
+/**
+ * Class ClientTransformer.
+ */
+class ClientTransformer extends BaseTransformer
+{
+    /**
+     * @param $data
+     *
+     * @return bool|Item
+     */
+    public function transform($data)
+    {
+        if (isset($data->name) && $this->hasClient($data->name)) {
+            return false;
+        }
+
+            $settings = new \stdClass;
+            $settings->currency_id = (string)$this->getCurrencyByCode($data);
+
+            return [
+                'company_id' => $this->maps['company']->id,
+                'name' => $this->getString($data, 'client.name'),
+                'work_phone' => $this->getString($data, 'client.phone'),
+                'address1' => $this->getString($data, 'client.address1'),
+                'address2' => $this->getString($data, 'client.address2'),
+                'city' => $this->getString($data, 'client.city'),
+                'state' => $this->getString($data, 'client.state'),
+                'shipping_address1' => $this->getString($data, 'client.shipping_address1'),
+                'shipping_address2' => $this->getString($data, 'client.shipping_address2'),
+                'shipping_city' => $this->getString($data, 'client.shipping_city'),
+                'shipping_state' => $this->getString($data, 'client.shipping_state'),
+                'shipping_postal_code' => $this->getString($data, 'client.shipping_postal_code'),
+                'public_notes' => $this->getString($data, 'client.public_notes'),
+                'private_notes' => $this->getString($data, 'client.private_notes'),
+                'website' => $this->getString($data, 'client.website'),
+                'vat_number' => $this->getString($data, 'client.vat_number'),
+                'id_number' => $this->getString($data, 'client.id_number'),
+                'custom_value1' => $this->getString($data, 'client.custom1'),
+                'custom_value2' => $this->getString($data, 'client.custom2'),
+                'custom_value3' => $this->getString($data, 'client.custom3'),
+                'custom_value4' => $this->getString($data, 'client.custom4'),
+                'balance' => $this->getString($data, 'client.balance'),
+                'paid_to_date' => $this->getString($data, 'client.paid_to_date'),
+                'credit_balance' => 0,
+                'settings' => $settings,
+                'client_hash' => Str::random(40),
+                'contacts' => [
+                    [
+                        'first_name' => $this->getString($data, 'contact.first_name'),
+                        'last_name' => $this->getString($data, 'contact.last_name'),
+                        'email' => $this->getString($data, 'contact.email'),
+                        'phone' => $this->getString($data, 'contact.phone'),
+                        'custom_value1' => $this->getString($data, 'contact.custom1'),
+                        'custom_value2' => $this->getString($data, 'contact.custom2'),
+                        'custom_value3' => $this->getString($data, 'contact.custom3'),
+                        'custom_value4' => $this->getString($data, 'contact.custom4'),
+                    ],
+                ],
+                'country_id' => isset($data->country_id) ? $this->getCountryId($data->country_id) : null,
+                'shipping_country_id' => isset($data->shipping_country_id) ? $this->getCountryId($data->shipping_country_id) : null,
+            ];
+
+    }
+}

app/Jobs/Import/CSVImport.php

@@ -11,8 +11,16 @@
 
 namespace App\Jobs\Import;
 
+use App\Factory\ClientFactory;
+use App\Http\Requests\Client\StoreClientRequest;
+use App\Import\Transformers\ClientTransformer;
 use App\Libraries\MultiDB;
+use App\Models\Client;
 use App\Models\Company;
+use App\Models\Currency;
+use App\Models\User;
+use App\Repositories\ClientContactRepository;
+use App\Repositories\ClientRepository;
 use Exception;
 use Illuminate\Bus\Queueable;
 use Illuminate\Contracts\Queue\ShouldQueue;
@@ -21,8 +29,11 @@ use Illuminate\Http\Request;
 use Illuminate\Queue\InteractsWithQueue;
 use Illuminate\Queue\SerializesModels;
 use Illuminate\Support\Facades\Cache;
+use Illuminate\Support\Str;
 use League\Csv\Reader;
 use League\Csv\Statement;
+use Illuminate\Support\Facades\Validator;
+use Illuminate\Support\Facades\Auth;
 
 class CSVImport implements ShouldQueue
 {
@@ -40,6 +51,12 @@ class CSVImport implements ShouldQueue
 
     public $column_map;
 
+    public $import_array;
+
+    public $error_array;
+
+    public $maps;
+
     /*
         [hash] => 2lTm7HVR3i9Zv3y86eQYZIO16yVJ7J6l
         [entity_type] => client
@@ -84,7 +101,51 @@ class CSVImport implements ShouldQueue
     {
         MultiDB::setDb($this->company->db);
 
-        foreach($this->getCsv() as $record) {
+        $this->company->owner()->setCompany($this->company);
+        Auth::login($this->company->owner(), true);
+
+        $this->buildMaps();
+
+        //sort the array by key
+        ksort($this->column_map);
+
+        //clients
+        $records = $this->getCsvData();
+
+        $contact_repository = new ClientContactRepository();
+        $client_repository = new ClientRepository($contact_repository);
+        $client_transformer = new ClientTransformer($this->maps);
+
+        if($this->skip_header)
+            array_shift($records);
+
+        foreach($records as $record) {
+
+            $keys = $this->column_map;
+            $values = array_intersect_key($record, $this->column_map);
+
+            $client_data = array_combine($keys, $values);
+
+            $client = $client_transformer->transform($client_data);
+
+            $validator = Validator::make($client, (new StoreClientRequest())->rules());
+
+            if ($validator->fails()) {
+                $this->error_array[] = ['client' => $client, 'error' => json_encode($validator->errors())];
+            }
+            else{
+                $client = $client_repository->save($client, ClientFactory::create($this->company->id, $this->setUser($record)));
+
+                if(array_key_exists('client.balance', $client_data))
+                    $client->balance = preg_replace('/[^0-9,.]+/', '', $client_data['client.balance']);
+
+                if(array_key_exists('client.paid_to_date', $client_data))
+                    $client->paid_to_date = preg_replace('/[^0-9,.]+/', '', $client_data['client.paid_to_date']);
+
+                $client->save();
+
+                $this->import_array['clients'][] = $client->id;
+            }
 
         }
 
@@ -95,10 +156,46 @@ class CSVImport implements ShouldQueue
 
     }
 
+//////////////////////////////////////////////////////////////////////////////////////////////////////////////
+    private function buildMaps()
+    {
+        $this->maps['currencies'] = Currency::all();
+        $this->maps['users'] = $this->company->users;
+        $this->maps['company'] = $this->company;
+
+        return $this;
+    }
+
+
+    private function setUser($record)
+    {
+        $user_key_exists = array_search('client.user_id', $this->column_map);
+
+        if($user_key_exists)
+            return $this->findUser($record[$user_key_exists]);
+        else
+            return $this->company->owner()->id;
+
+    }
+
+    private function findUser($user_hash) 
+    {
+        $user = User::where('company_id', $this->company->id)
+                    ->where(\DB::raw('CONCAT_WS(" ", first_name, last_name)'), 'like', '%' . $user_hash . '%')
+                    ->first();
+
+        if($user)
+            return $user->id;
+        else
+            return $this->company->owner()->id;
+
+    }
+
     private function getCsvData()
     {
         $base64_encoded_csv = Cache::get($this->hash);
         $csv = base64_decode($base64_encoded_csv);
+        $csv = Reader::createFromString($csv);
 
         $stmt = new Statement();
         $data = iterator_to_array($stmt->process($csv));
@@ -109,7 +206,7 @@ class CSVImport implements ShouldQueue
             // Remove Invoice Ninja headers
             if (count($headers) && count($data) > 4) {
                 $firstCell = $headers[0];
-                if (strstr($firstCell, APP_NAME)) {
+                if (strstr($firstCell, config('ninja.app_name'))) {
                     array_shift($data); // Invoice Ninja...
                     array_shift($data); // <blank line>
                     array_shift($data); // Enitty Type Header