<?php

function createCustomerRaw($accessToken, $realmId, $customerData)
{
    $url = "https://sandbox-quickbooks.api.intuit.com/v3/company/{$realmId}/customer";

    $ch = curl_init($url);

    curl_setopt($ch, CURLOPT_POST, true);
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
    curl_setopt($ch, CURLOPT_HTTPHEADER, [
        "Authorization: Bearer {$accessToken}",
        "Content-Type: application/json",
        "Accept: application/json",
    ]);
    curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($customerData));

    $response = curl_exec($ch);
    $httpCode = curl_getinfo($ch, CURLINFO_HTTP_CODE);

    if (curl_errno($ch)) {
        $error = curl_error($ch);
        curl_close($ch);
        throw new Exception("cURL Error: {$error}");
    }

    curl_close($ch);

    if ($httpCode >= 400) {
        throw new Exception("API Error ({$httpCode}): {$response}");
    }

    return json_decode($response, true);
}

// ทุกครั้งที่ต้องเรียก Endpoint ใหม่ ต้องเขียนซ้ำแบบนี้อีก...
function getCustomerRaw($accessToken, $realmId, $customerId)
{
    $url = "https://sandbox-quickbooks.api.intuit.com/v3/company/{$realmId}/customer/{$customerId}";
    // ... โค้ด cURL เหมือนเดิมอีกชุด
}

<?php

use QuickBooksOnline\API\DataService\DataService;
use QuickBooksOnline\API\Data\IPPCustomer;

$dataService = DataService::Configure([
    'auth_mode'    => 'oauth2',
    'ClientID'     => env('QB_CLIENT_ID'),
    'ClientSecret' => env('QB_CLIENT_SECRET'),
    'accessTokenKey'  => $accessToken,
    'refreshTokenKey' => $refreshToken,
    'baseUrl'      => 'development',
]);

$customer = new IPPCustomer();
$customer->DisplayName = $customerData['name'];
$customer->PrimaryEmailAddr = ['Address' => $customerData['email']];

$result = $dataService->Add($customer);

$error = $dataService->getLastError();
if ($error) {
    throw new Exception($error->getResponseBody());
}

<?php

namespace App\Libraries;

use QuickBooksOnline\API\DataService\DataService;
use QuickBooksOnline\API\Data\IPPCustomer;

class AccountingService
{
    protected DataService $dataService;

    public function __construct()
    {
        $this->dataService = DataService::Configure([
            'auth_mode'    => 'oauth2',
            'ClientID'     => getenv('QB_CLIENT_ID'),
            'ClientSecret' => getenv('QB_CLIENT_SECRET'),
            'accessTokenKey'  => getenv('QB_ACCESS_TOKEN'),
            'refreshTokenKey' => getenv('QB_REFRESH_TOKEN'),
            'baseUrl'      => 'development',
        ]);
    }

    public function createCustomer(array $data): array
    {
        $customer = new IPPCustomer();
        $customer->DisplayName = $data['name'];
        $customer->PrimaryEmailAddr = ['Address' => $data['email']];

        $result = $this->dataService->Add($customer);

        $error = $this->dataService->getLastError();
        if ($error) {
            throw new \RuntimeException($error->getResponseBody());
        }

        return (array) $result;
    }
}

<?php

namespace App\Controllers;

use App\Libraries\AccountingService;

class CustomerController extends BaseController
{
    public function store()
    {
        $accounting = new AccountingService();

        try {
            $result = $accounting->createCustomer([
                'name'  => $this->request->getPost('name'),
                'email' => $this->request->getPost('email'),
            ]);

            return $this->response->setJSON([
                'status' => 'success',
                'data'   => $result,
            ]);
        } catch (\RuntimeException $e) {
            return $this->response->setStatusCode(500)
                ->setJSON(['status' => 'error', 'message' => $e->getMessage()]);
        }
    }
}

<?php

namespace App\Services;

use QuickBooksOnline\API\DataService\DataService;
use QuickBooksOnline\API\Data\IPPCustomer;

class AccountingService
{
    protected DataService $dataService;

    public function __construct()
    {
        $this->dataService = DataService::Configure([
            'auth_mode'       => 'oauth2',
            'ClientID'        => config('services.quickbooks.client_id'),
            'ClientSecret'    => config('services.quickbooks.client_secret'),
            'accessTokenKey'  => config('services.quickbooks.access_token'),
            'refreshTokenKey' => config('services.quickbooks.refresh_token'),
            'baseUrl'         => 'development',
        ]);
    }

    public function createCustomer(array $data): array
    {
        $customer = new IPPCustomer();
        $customer->DisplayName = $data['name'];
        $customer->PrimaryEmailAddr = ['Address' => $data['email']];

        $result = $this->dataService->Add($customer);

        if ($error = $this->dataService->getLastError()) {
            throw new \RuntimeException($error->getResponseBody());
        }

        return (array) $result;
    }
}

<?php

namespace App\Http\Controllers;

use App\Services\AccountingService;
use Illuminate\Http\Request;

class CustomerController extends Controller
{
    public function __construct(protected AccountingService $accounting) {}

    public function store(Request $request)
    {
        $validated = $request->validate([
            'name'  => 'required|string|max:255',
            'email' => 'required|email',
        ]);

        try {
            $result = $this->accounting->createCustomer($validated);

            return response()->json(['status' => 'success', 'data' => $result]);
        } catch (\RuntimeException $e) {
            return response()->json(['status' => 'error', 'message' => $e->getMessage()], 500);
        }
    }
}

<?php

namespace App\Services;

use Illuminate\Support\Facades\Http;

class SimpleApiClient
{
    public function __construct(
        protected string $baseUrl,
        protected string $apiKey
    ) {}

    public function get(string $endpoint, array $query = []): array
    {
        $response = Http::withToken($this->apiKey)
            ->get("{$this->baseUrl}/{$endpoint}", $query);

        return $this->handleResponse($response);
    }

    public function post(string $endpoint, array $data = []): array
    {
        $response = Http::withToken($this->apiKey)
            ->post("{$this->baseUrl}/{$endpoint}", $data);

        return $this->handleResponse($response);
    }

    protected function handleResponse($response): array
    {
        if ($response->failed()) {
            throw new \RuntimeException(
                "API request failed: {$response->status()} - {$response->body()}"
            );
        }

        return $response->json();
    }
}