mirror of
https://github.com/invoiceninja/invoiceninja.git
synced 2026-03-03 02:47:02 +00:00
392 lines
12 KiB
PHP
392 lines
12 KiB
PHP
<?php
|
|
|
|
/**
|
|
* Invoice Ninja (https://invoiceninja.com).
|
|
*
|
|
* @link https://github.com/invoiceninja/invoiceninja source repository
|
|
*
|
|
* @copyright Copyright (c) 2025. Invoice Ninja LLC (https://invoiceninja.com)
|
|
*
|
|
* @license https://www.elastic.co/licensing/elastic-license
|
|
*/
|
|
|
|
namespace App\Services\Quickbooks;
|
|
|
|
use App\Models\Client;
|
|
use App\Models\Company;
|
|
use App\Models\Invoice;
|
|
use App\Models\Product;
|
|
use App\Factory\ClientFactory;
|
|
use App\Factory\InvoiceFactory;
|
|
use App\Factory\ProductFactory;
|
|
use App\DataMapper\QuickbooksSync;
|
|
use App\Factory\ClientContactFactory;
|
|
use App\Services\Quickbooks\Models\QbQuote;
|
|
use App\Services\Quickbooks\Models\QbClient;
|
|
use QuickBooksOnline\API\Core\CoreConstants;
|
|
use App\Services\Quickbooks\Models\QbInvoice;
|
|
use App\Services\Quickbooks\Models\QbPayment;
|
|
use App\Services\Quickbooks\Models\QbProduct;
|
|
use QuickBooksOnline\API\DataService\DataService;
|
|
use App\Services\Quickbooks\Jobs\QuickbooksImport;
|
|
use App\Services\Quickbooks\Transformers\ClientTransformer;
|
|
use App\Services\Quickbooks\Transformers\InvoiceTransformer;
|
|
use App\Services\Quickbooks\Transformers\PaymentTransformer;
|
|
use App\Services\Quickbooks\Transformers\ProductTransformer;
|
|
|
|
class QuickbooksService
|
|
{
|
|
public DataService $sdk;
|
|
|
|
public QbInvoice $invoice;
|
|
|
|
public QbProduct $product;
|
|
|
|
public QbClient $client;
|
|
|
|
public QbPayment $payment;
|
|
|
|
public QbQuote $quote;
|
|
|
|
public QuickbooksSync $settings;
|
|
|
|
private bool $testMode = true;
|
|
|
|
private bool $try_refresh = true;
|
|
|
|
public function __construct(public Company $company)
|
|
{
|
|
$this->init();
|
|
}
|
|
|
|
private function init(): self
|
|
{
|
|
|
|
if(config('services.quickbooks.client_id'))
|
|
{
|
|
$config = [
|
|
'ClientID' => config('services.quickbooks.client_id'),
|
|
'ClientSecret' => config('services.quickbooks.client_secret'),
|
|
'auth_mode' => 'oauth2',
|
|
'scope' => "com.intuit.quickbooks.accounting",
|
|
'RedirectURI' => $this->testMode ? 'https://qb.romulus.com.au/quickbooks/authorized' : 'https://invoicing.co/quickbooks/authorized',
|
|
'baseUrl' => $this->testMode ? CoreConstants::SANDBOX_DEVELOPMENT : CoreConstants::QBO_BASEURL,
|
|
];
|
|
|
|
$merged = array_merge($config, $this->ninjaAccessToken());
|
|
|
|
$this->sdk = DataService::Configure($merged);
|
|
|
|
$this->sdk->enableLog();
|
|
$this->sdk->setMinorVersion("75");
|
|
$this->sdk->throwExceptionOnError(true);
|
|
|
|
$this->checkToken();
|
|
}
|
|
|
|
$this->invoice = new QbInvoice($this);
|
|
|
|
$this->quote = new QbQuote($this);
|
|
|
|
$this->product = new QbProduct($this);
|
|
|
|
$this->client = new QbClient($this);
|
|
|
|
$this->payment = new QbPayment($this);
|
|
|
|
$this->settings = $this->company->quickbooks->settings;
|
|
|
|
// $this->checkDefaultAccounts(); // disabled, because if OAuth not present, we don't have access to the accounts.
|
|
|
|
return $this;
|
|
}
|
|
|
|
// private function checkDefaultAccounts(): self
|
|
// {
|
|
|
|
// $accountQuery = "SELECT * FROM Account WHERE AccountType IN ('Income', 'Cost of Goods Sold')";
|
|
|
|
// if (strlen($this->settings->default_income_account) == 0 || strlen($this->settings->default_expense_account) == 0) {
|
|
|
|
// nlog("Checking default accounts for company {$this->company->company_key}");
|
|
// $accounts = $this->sdk->Query($accountQuery);
|
|
|
|
// $find_income_account = true;
|
|
// $find_expense_account = true;
|
|
|
|
// foreach ($accounts as $account) {
|
|
// if ($account->AccountType->value == 'Income' && $find_income_account) {
|
|
// $this->settings->default_income_account = $account->Id->value;
|
|
// $find_income_account = false;
|
|
// } elseif ($account->AccountType->value == 'Cost of Goods Sold' && $find_expense_account) {
|
|
// $this->settings->default_expense_account = $account->Id->value;
|
|
// $find_expense_account = false;
|
|
// }
|
|
// }
|
|
|
|
// nlog($this->settings);
|
|
|
|
// $this->company->quickbooks->settings = $this->settings;
|
|
// $this->company->save();
|
|
// }
|
|
|
|
|
|
// return $this;
|
|
// }
|
|
|
|
/**
|
|
* Refresh the service after OAuth token has been updated.
|
|
* This reloads the company from the database and reinitializes the SDK
|
|
* with the new access token.
|
|
*
|
|
* @return self
|
|
*/
|
|
public function refresh(): self
|
|
{
|
|
// Reload company from database to get fresh token data
|
|
$this->company = $this->company->fresh();
|
|
|
|
// Reinitialize the SDK with the updated token
|
|
$this->init();
|
|
|
|
return $this;
|
|
}
|
|
|
|
private function checkToken(): self
|
|
{
|
|
|
|
if ($this->company->quickbooks->accessTokenExpiresAt == 0 || $this->company->quickbooks->accessTokenExpiresAt > time()) {
|
|
return $this;
|
|
}
|
|
|
|
if ($this->company->quickbooks->accessTokenExpiresAt && $this->company->quickbooks->accessTokenExpiresAt < time() && $this->try_refresh) {
|
|
$this->sdk()->refreshToken($this->company->quickbooks->refresh_token);
|
|
$this->company = $this->company->fresh();
|
|
$this->try_refresh = false;
|
|
$this->init();
|
|
|
|
return $this;
|
|
}
|
|
|
|
nlog('Quickbooks token expired and could not be refreshed => ' .$this->company->company_key);
|
|
throw new \Exception('Quickbooks token expired and could not be refreshed');
|
|
|
|
}
|
|
|
|
private function ninjaAccessToken(): array
|
|
{
|
|
return $this->company->quickbooks->accessTokenExpiresAt > 0 ? [
|
|
'accessTokenKey' => $this->company->quickbooks->accessTokenKey,
|
|
'refreshTokenKey' => $this->company->quickbooks->refresh_token,
|
|
'QBORealmID' => $this->company->quickbooks->realmID,
|
|
] : [];
|
|
}
|
|
|
|
public function sdk(): SdkWrapper
|
|
{
|
|
return new SdkWrapper($this->sdk, $this->company);
|
|
}
|
|
|
|
/**
|
|
*
|
|
*
|
|
* @return void
|
|
*/
|
|
public function syncFromQb(): void
|
|
{
|
|
QuickbooksImport::dispatch($this->company->id, $this->company->db);
|
|
}
|
|
|
|
public function findEntityById(string $entity, string $id): mixed
|
|
{
|
|
return $this->sdk->FindById($entity, $id);
|
|
}
|
|
|
|
public function query(string $query)
|
|
{
|
|
return $this->sdk->Query($query);
|
|
}
|
|
|
|
/**
|
|
* Flag to determine if a sync is allowed in either direction
|
|
*
|
|
* @param string $entity
|
|
* @param \App\Enum\SyncDirection $direction
|
|
* @return bool
|
|
*/
|
|
public function syncable(string $entity, \App\Enum\SyncDirection $direction): bool
|
|
{
|
|
return isset($this->settings->{$entity}->direction) && ($this->settings->{$entity}->direction === $direction || $this->settings->{$entity}->direction === \App\Enum\SyncDirection::BIDIRECTIONAL);
|
|
}
|
|
|
|
|
|
// [
|
|
// QuickBooksOnline\API\Data\IPPAccount {#7706
|
|
// +Id: "30",
|
|
// +SyncToken: "0",
|
|
// +MetaData: QuickBooksOnline\API\Data\IPPModificationMetaData {#7707
|
|
// +CreatedByRef: null,
|
|
// +CreateTime: "2024-05-22T14:46:30-07:00",
|
|
// +LastModifiedByRef: null,
|
|
// +LastUpdatedTime: "2024-05-22T14:46:30-07:00",
|
|
// +LastChangedInQB: null,
|
|
// +Synchronized: null,
|
|
// },
|
|
// +CustomField: null,
|
|
// +AttachableRef: null,
|
|
// +domain: null,
|
|
// +status: null,
|
|
// +sparse: null,
|
|
// +Name: "Uncategorized Income",
|
|
// +SubAccount: "false",
|
|
// +ParentRef: null,
|
|
// +Description: null,
|
|
// +FullyQualifiedName: "Uncategorized Income",
|
|
// +AccountAlias: null,
|
|
// +TxnLocationType: null,
|
|
// +Active: "true",
|
|
// +Classification: "Revenue",
|
|
// +AccountType: "Income",
|
|
// +AccountSubType: "ServiceFeeIncome",
|
|
// +AccountPurposes: null,
|
|
// +AcctNum: null,
|
|
// +AcctNumExtn: null,
|
|
// +BankNum: null,
|
|
// +OpeningBalance: null,
|
|
// +OpeningBalanceDate: null,
|
|
// +CurrentBalance: "0",
|
|
// +CurrentBalanceWithSubAccounts: "0",
|
|
// +CurrencyRef: "USD",
|
|
// +TaxAccount: null,
|
|
// +TaxCodeRef: null,
|
|
// +OnlineBankingEnabled: null,
|
|
// +FIName: null,
|
|
// +JournalCodeRef: null,
|
|
// +AccountEx: null,
|
|
// },
|
|
// ]
|
|
/**
|
|
* Fetch income accounts from QuickBooks.
|
|
*
|
|
* @return array Array of account objects with 'Id', 'Name', 'AccountType', etc.
|
|
*/
|
|
public function fetchIncomeAccounts(): array
|
|
{
|
|
try {
|
|
if (!$this->sdk) {
|
|
return [];
|
|
}
|
|
|
|
$query = "SELECT * FROM Account WHERE AccountType = 'Income' AND Active = true";
|
|
$accounts = $this->sdk->Query($query);
|
|
|
|
return is_array($accounts) ? $accounts : [];
|
|
} catch (\Exception $e) {
|
|
nlog("Error fetching income accounts: {$e->getMessage()}");
|
|
return [];
|
|
}
|
|
}
|
|
|
|
|
|
// [
|
|
// QuickBooksOnline\API\Data\IPPAccount {#7709
|
|
// +Id: "57",
|
|
// +SyncToken: "0",
|
|
// +MetaData: QuickBooksOnline\API\Data\IPPModificationMetaData {#7698
|
|
// +CreatedByRef: null,
|
|
// +CreateTime: "2024-05-27T10:17:24-07:00",
|
|
// +LastModifiedByRef: null,
|
|
// +LastUpdatedTime: "2024-05-27T10:17:24-07:00",
|
|
// +LastChangedInQB: null,
|
|
// +Synchronized: null,
|
|
// },
|
|
// +CustomField: null,
|
|
// +AttachableRef: null,
|
|
// +domain: null,
|
|
// +status: null,
|
|
// +sparse: null,
|
|
// +Name: "Workers Compensation",
|
|
// +SubAccount: "true",
|
|
// +ParentRef: "11",
|
|
// +Description: null,
|
|
// +FullyQualifiedName: "Insurance:Workers Compensation",
|
|
// +AccountAlias: null,
|
|
// +TxnLocationType: null,
|
|
// +Active: "true",
|
|
// +Classification: "Expense",
|
|
// +AccountType: "Expense",
|
|
// +AccountSubType: "Insurance",
|
|
// +AccountPurposes: null,
|
|
// +AcctNum: null,
|
|
// +AcctNumExtn: null,
|
|
// +BankNum: null,
|
|
// +OpeningBalance: null,
|
|
// +OpeningBalanceDate: null,
|
|
// +CurrentBalance: "0",
|
|
// +CurrentBalanceWithSubAccounts: "0",
|
|
// +CurrencyRef: "USD",
|
|
// +TaxAccount: null,
|
|
// +TaxCodeRef: null,
|
|
// +OnlineBankingEnabled: null,
|
|
// +FIName: null,
|
|
// +JournalCodeRef: null,
|
|
// +AccountEx: null,
|
|
// },
|
|
// ]
|
|
/**
|
|
* Fetch expense accounts from QuickBooks.
|
|
*
|
|
* @return array Array of account objects with 'Id', 'Name', 'AccountType', etc.
|
|
*/
|
|
public function fetchExpenseAccounts(): array
|
|
{
|
|
try {
|
|
if (!$this->sdk) {
|
|
return [];
|
|
}
|
|
|
|
$query = "SELECT * FROM Account WHERE AccountType IN ('Expense', 'Cost of Goods Sold') AND Active = true";
|
|
$accounts = $this->sdk->Query($query);
|
|
|
|
return is_array($accounts) ? $accounts : [];
|
|
} catch (\Exception $e) {
|
|
nlog("Error fetching expense accounts: {$e->getMessage()}");
|
|
return [];
|
|
}
|
|
}
|
|
|
|
/**
|
|
* Format accounts for UI dropdown consumption.
|
|
*
|
|
* @param array $accounts Raw account objects from QuickBooks API
|
|
* @return array Formatted array with 'value' (ID) and 'label' (Name) for each account
|
|
*/
|
|
public function formatAccountsForDropdown(array $accounts): array
|
|
{
|
|
$formatted = [];
|
|
|
|
foreach ($accounts as $account) {
|
|
$id = is_object($account) && isset($account->Id)
|
|
? (string) $account->Id
|
|
: (is_array($account) && isset($account['Id']) ? (string) $account['Id'] : null);
|
|
|
|
$name = is_object($account) && isset($account->Name)
|
|
? (string) $account->Name
|
|
: (is_array($account) && isset($account['Name']) ? (string) $account['Name'] : '');
|
|
|
|
if ($id && $name) {
|
|
$formatted[] = [
|
|
'value' => $id,
|
|
'label' => $name,
|
|
'account_type' => is_object($account) && isset($account->AccountType)
|
|
? (string) $account->AccountType
|
|
: (is_array($account) && isset($account['AccountType']) ? (string) $account['AccountType'] : ''),
|
|
];
|
|
}
|
|
}
|
|
|
|
return $formatted;
|
|
}
|
|
|
|
}
|