bert.hausmans
d3abdb7ed9
Implement Weeztix integration per documentation: database config and subscriber coupon_code, OAuth redirect/callback, admin setup UI with company/coupon selection via AJAX, synchronous coupon creation on public subscribe with duplicate and rate-limit handling, Mailwizz field mapping for coupon codes, subscriber table and CSV export, and connection hint on the pages list. Made-with: Cursor
112 lines
3.3 KiB
PHP
112 lines
3.3 KiB
PHP
<?php
|
|
|
|
declare(strict_types=1);
|
|
|
|
namespace App\Http\Controllers\Admin;
|
|
|
|
use App\Http\Controllers\Controller;
|
|
use App\Models\PreregistrationPage;
|
|
use App\Services\WeeztixService;
|
|
use Illuminate\Http\JsonResponse;
|
|
use Illuminate\Http\Request;
|
|
use RuntimeException;
|
|
|
|
class WeeztixApiController extends Controller
|
|
{
|
|
public function companies(Request $request): JsonResponse
|
|
{
|
|
$request->validate([
|
|
'page_id' => ['required', 'integer', 'exists:preregistration_pages,id'],
|
|
]);
|
|
|
|
$page = PreregistrationPage::query()->findOrFail($request->integer('page_id'));
|
|
$this->authorize('update', $page);
|
|
|
|
$config = $page->weeztixConfig;
|
|
if ($config === null || ! $config->is_connected) {
|
|
return response()->json([
|
|
'message' => __('Niet verbonden met Weeztix.'),
|
|
], 422);
|
|
}
|
|
|
|
try {
|
|
$companies = (new WeeztixService($config))->getCompanies();
|
|
|
|
return response()->json(['companies' => $companies]);
|
|
} catch (RuntimeException) {
|
|
return response()->json([
|
|
'message' => __('Kon bedrijven niet laden. Vernieuw de verbinding indien nodig.'),
|
|
], 422);
|
|
}
|
|
}
|
|
|
|
public function coupons(Request $request): JsonResponse
|
|
{
|
|
$request->validate([
|
|
'page_id' => ['required', 'integer', 'exists:preregistration_pages,id'],
|
|
'company_guid' => ['required', 'string', 'max:255'],
|
|
]);
|
|
|
|
$page = PreregistrationPage::query()->findOrFail($request->integer('page_id'));
|
|
$this->authorize('update', $page);
|
|
|
|
$config = $page->weeztixConfig;
|
|
if ($config === null || ! $config->is_connected) {
|
|
return response()->json([
|
|
'message' => __('Niet verbonden met Weeztix.'),
|
|
], 422);
|
|
}
|
|
|
|
$companyGuid = $request->string('company_guid')->toString();
|
|
$previousGuid = $config->company_guid;
|
|
$config->setAttribute('company_guid', $companyGuid);
|
|
|
|
try {
|
|
$raw = (new WeeztixService($config))->getCoupons();
|
|
$coupons = $this->normalizeCouponsPayload($raw);
|
|
|
|
return response()->json(['coupons' => $coupons]);
|
|
} catch (RuntimeException) {
|
|
return response()->json([
|
|
'message' => __('Kon kortingsbonnen niet laden.'),
|
|
], 422);
|
|
} finally {
|
|
$config->setAttribute('company_guid', $previousGuid);
|
|
}
|
|
}
|
|
|
|
/**
|
|
* @param array<string, mixed> $raw
|
|
* @return list<array{guid: string, name: string}>
|
|
*/
|
|
private function normalizeCouponsPayload(array $raw): array
|
|
{
|
|
$list = $raw;
|
|
if (isset($raw['data']) && is_array($raw['data'])) {
|
|
$list = $raw['data'];
|
|
}
|
|
|
|
if (! is_array($list)) {
|
|
return [];
|
|
}
|
|
|
|
$out = [];
|
|
foreach ($list as $row) {
|
|
if (! is_array($row)) {
|
|
continue;
|
|
}
|
|
$guid = data_get($row, 'guid') ?? data_get($row, 'id');
|
|
if (! is_string($guid) || $guid === '') {
|
|
continue;
|
|
}
|
|
$name = data_get($row, 'name') ?? data_get($row, 'title') ?? $guid;
|
|
$out[] = [
|
|
'guid' => $guid,
|
|
'name' => is_string($name) ? $name : $guid,
|
|
];
|
|
}
|
|
|
|
return $out;
|
|
}
|
|
}
|