mirror of
https://github.com/invoiceninja/invoiceninja.git
synced 2024-11-16 16:13:20 +01:00
135 lines
4.0 KiB
PHP
135 lines
4.0 KiB
PHP
<?php
|
|
|
|
/**
|
|
* Invoice Ninja (https://invoiceninja.com).
|
|
*
|
|
* @link https://github.com/invoiceninja/invoiceninja source repository
|
|
*
|
|
* @copyright Copyright (c) 2021. Invoice Ninja LLC (https://invoiceninja.com)
|
|
*
|
|
* @license https://www.elastic.co/licensing/elastic-license
|
|
*/
|
|
|
|
namespace App\PaymentDrivers\Stripe;
|
|
|
|
use App\Factory\ClientContactFactory;
|
|
use App\Factory\ClientFactory;
|
|
use App\Factory\ClientGatewayTokenFactory;
|
|
use App\Models\Client;
|
|
use App\Models\ClientGatewayToken;
|
|
use App\Models\Country;
|
|
use App\Models\Currency;
|
|
use App\Models\GatewayType;
|
|
use App\PaymentDrivers\StripePaymentDriver;
|
|
use App\PaymentDrivers\Stripe\UpdatePaymentMethods;
|
|
use App\Utils\Traits\MakesHash;
|
|
use Stripe\Customer;
|
|
use Stripe\PaymentMethod;
|
|
|
|
class ImportCustomers
|
|
{
|
|
use MakesHash;
|
|
|
|
/** @var StripePaymentDriver */
|
|
public $stripe;
|
|
|
|
public $update_payment_methods;
|
|
|
|
public function __construct(StripePaymentDriver $stripe)
|
|
{
|
|
$this->stripe = $stripe;
|
|
|
|
}
|
|
|
|
public function run()
|
|
{
|
|
|
|
$this->stripe->init();
|
|
|
|
$this->update_payment_methods = new UpdatePaymentMethods($this->stripe);
|
|
|
|
$customers = Customer::all([], $this->stripe->stripe_connect_auth);
|
|
|
|
foreach($customers as $customer)
|
|
{
|
|
$this->addCustomer($customer);
|
|
}
|
|
|
|
/* Now call the update payment methods handler*/
|
|
// $this->stripe->updateAllPaymentMethods();
|
|
|
|
}
|
|
|
|
private function addCustomer(Customer $customer)
|
|
{
|
|
|
|
$account = $this->stripe->company_gateway->company->account;
|
|
|
|
if(!$account->isPaidHostedClient() && Client::where('company_id', $this->stripe->company_gateway->company_id)->count() > config('ninja.quotas.free.clients'))
|
|
return;
|
|
|
|
nlog("search Stripe for {$customer->id}");
|
|
|
|
$existing_customer = $this->stripe
|
|
->company_gateway
|
|
->client_gateway_tokens()
|
|
->where('gateway_customer_reference', $customer->id)
|
|
->exists();
|
|
|
|
if($existing_customer){
|
|
nlog("Skipping - Customer exists: {$customer->email}");
|
|
return;
|
|
}
|
|
|
|
nlog("inserting a customer");
|
|
//nlog($customer);
|
|
|
|
$client = ClientFactory::create($this->stripe->company_gateway->company_id, $this->stripe->company_gateway->user_id);
|
|
|
|
if(property_exists($customer, 'address'))
|
|
{
|
|
$client->address1 = property_exists($customer->address, 'line1') ? $customer->address->line1 : '';
|
|
$client->address2 = property_exists($customer->address, 'line2') ? $customer->address->line2 : '';
|
|
$client->city = property_exists($customer->address, 'city') ? $customer->address->city : '';
|
|
$client->state = property_exists($customer->address, 'state') ? $customer->address->state : '';
|
|
$client->phone = property_exists($customer->address, 'phone') ? $customer->phone : '';
|
|
|
|
if(property_exists($customer->address, 'country')){
|
|
|
|
$country = Country::where('iso_3166_2', $customer->address->country)->first();
|
|
|
|
if($country)
|
|
$client->country_id = $country->id;
|
|
|
|
}
|
|
}
|
|
|
|
if($customer->currency) {
|
|
|
|
$currency = Currency::where('code', $customer->currency)->first();
|
|
|
|
if($currency){
|
|
|
|
$settings = $client->settings;
|
|
$settings->currency_id = (string)$currency->id;
|
|
$client->settings = $settings;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
$client->name = property_exists($customer, 'name') ? $customer->name : $customer->email;
|
|
|
|
$client->save();
|
|
|
|
$contact = ClientContactFactory::create($client->company_id, $client->user_id);
|
|
$contact->client_id = $client->id;
|
|
$contact->first_name = $client->name ?: '';
|
|
$contact->phone = $client->phone ?: '';
|
|
$contact->email = $customer->email ?: '';
|
|
$contact->save();
|
|
|
|
$this->update_payment_methods->updateMethods($customer, $client);
|
|
}
|
|
}
|