mirror of
https://github.com/invoiceninja/invoiceninja.git
synced 2025-07-09 03:14:30 -04:00
add sdk wrapper
This commit is contained in:
parent
85220bf58f
commit
79ed325a29
14
app/Services/Import/Quickbooks/Contracts/SdkInterface.php
Normal file
14
app/Services/Import/Quickbooks/Contracts/SdkInterface.php
Normal file
@ -0,0 +1,14 @@
|
|||||||
|
<?php
|
||||||
|
|
||||||
|
namespace App\Services\Import\Quickbooks\Contracts;
|
||||||
|
|
||||||
|
interface SdkInterface
|
||||||
|
{
|
||||||
|
function getAuthorizationUrl(): string;
|
||||||
|
function accessToken(string $code, string $realm): array;
|
||||||
|
function refreshToken(): array;
|
||||||
|
function getAccessToken(): array;
|
||||||
|
function getRefreshToken(): array;
|
||||||
|
function totalRecords(string $entity): int;
|
||||||
|
function fetchRecords(string $entity, int $max): array;
|
||||||
|
}
|
103
app/Services/Import/Quickbooks/SdkWrapper.php
Normal file
103
app/Services/Import/Quickbooks/SdkWrapper.php
Normal file
@ -0,0 +1,103 @@
|
|||||||
|
<?php
|
||||||
|
|
||||||
|
namespace App\Services\Import\Quickbooks;
|
||||||
|
|
||||||
|
use App\Services\Import\Quickbooks\Contracts\SdkInterface as QuickbooksInterface;
|
||||||
|
|
||||||
|
final class SdkWrapper implements QuickbooksInterface
|
||||||
|
{
|
||||||
|
|
||||||
|
const MAXRESULTS = 10000;
|
||||||
|
|
||||||
|
private $sdk;
|
||||||
|
private $entities = ['Customer','Invoice','Payment','Item'];
|
||||||
|
|
||||||
|
public function __construct($sdk)
|
||||||
|
{
|
||||||
|
// Prep Data Services
|
||||||
|
$this->sdk = $sdk;
|
||||||
|
}
|
||||||
|
|
||||||
|
public function getAuthorizationUrl() : string
|
||||||
|
{
|
||||||
|
return ($this->sdk->getOAuth2LoginHelper())->getAuthorizationCodeURL();
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
public function getAccessToken() : array
|
||||||
|
{
|
||||||
|
return $this->getTokens();
|
||||||
|
}
|
||||||
|
|
||||||
|
public function getRefreshToken(): array{
|
||||||
|
return $this->gettokens();
|
||||||
|
}
|
||||||
|
|
||||||
|
public function accessToken(string $code, string $realm) : array
|
||||||
|
{
|
||||||
|
$token = ($this->sdk->getOAuth2LoginHelper())->exchangeAuthorizationCodeForToken($code,$realm);
|
||||||
|
|
||||||
|
return $this->getTokens();
|
||||||
|
}
|
||||||
|
|
||||||
|
private function getTokens() : array {
|
||||||
|
|
||||||
|
$token =($this->sdk->getOAuth2LoginHelper())->getAccessToken();
|
||||||
|
$access_token = $token->getAccessToken();
|
||||||
|
$refresh_token = $token->getRefreshToken();
|
||||||
|
$access_token_expires = $token->getAccessTokenExpiresAt();
|
||||||
|
$refresh_token_expires = $token->getRefreshTokenExpiresAt();
|
||||||
|
|
||||||
|
return compact('access_token', 'refresh_token','access_token_expires', 'refresh_token_expires');
|
||||||
|
}
|
||||||
|
|
||||||
|
public function refreshToken(): array
|
||||||
|
{
|
||||||
|
$token = ($this->sdk->getOAuth2LoginHelper())->refreshToken();
|
||||||
|
$this->sdk = $this->sdk->updateOAuth2Token($token);
|
||||||
|
|
||||||
|
return $this->getTokens();
|
||||||
|
}
|
||||||
|
|
||||||
|
public function handleCallbacks(array $data): void {
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
public function totalRecords(string $entity) : int {
|
||||||
|
return $this->sdk->Query("select count(*) from $entity");
|
||||||
|
}
|
||||||
|
|
||||||
|
private function queryData(string $query, int $start = 1, $limit = 100) : array
|
||||||
|
{
|
||||||
|
return (array) $this->sdk->Query($query, $start, $limit);
|
||||||
|
}
|
||||||
|
|
||||||
|
public function fetchRecords( string $entity, int $max = 1000): array {
|
||||||
|
|
||||||
|
if(!in_array($entity, $this->entities)) return [];
|
||||||
|
|
||||||
|
$records = [];
|
||||||
|
$start = 1;
|
||||||
|
$limit = 100;
|
||||||
|
try {
|
||||||
|
$total = $this->totalRecords($entity);
|
||||||
|
$total = min($max, $total);
|
||||||
|
|
||||||
|
// Step 3 & 4: Get chunks of records until the total required records are retrieved
|
||||||
|
do {
|
||||||
|
$limit = min(self::MAXRESULTS, $total - $start);
|
||||||
|
$recordsChunk = $this->queryData("select * from $entity", $start, $limit);
|
||||||
|
if(empty($recordsChunk)) break;
|
||||||
|
|
||||||
|
$records = array_merge($records,$recordsChunk);
|
||||||
|
$start += $limit;
|
||||||
|
} while ($start < $total);
|
||||||
|
if(empty($records)) throw new \Exceptions("No records retrieved!");
|
||||||
|
|
||||||
|
} catch (\Throwable $th) {
|
||||||
|
nlog("Fetch Quickbooks API Error: {$th->getMessage()}");
|
||||||
|
}
|
||||||
|
|
||||||
|
return $records;
|
||||||
|
}
|
||||||
|
}
|
Loading…
x
Reference in New Issue
Block a user