|
|
<?php
|
|
|
|
|
|
namespace App\Http\Controllers\Api;
|
|
|
|
|
|
use App\Http\Controllers\Controller;
|
|
|
use App\Models\Blacklist;
|
|
|
use App\Models\Reservation;
|
|
|
use App\Models\Venue;
|
|
|
use App\Services\ReservationExpiryService;
|
|
|
use Carbon\Carbon;
|
|
|
use Illuminate\Database\Eloquent\Builder;
|
|
|
use Illuminate\Http\JsonResponse;
|
|
|
use Illuminate\Http\Request;
|
|
|
use Symfony\Component\HttpFoundation\StreamedResponse;
|
|
|
|
|
|
class ActivityRegistrationController extends Controller
|
|
|
{
|
|
|
public function index(Request $request, ReservationExpiryService $reservationExpiryService): JsonResponse
|
|
|
{
|
|
|
$reservationExpiryService->expireStalePendingReservations();
|
|
|
|
|
|
$kind = (string) $request->input('reservation_kind', 'activity');
|
|
|
if ($kind === 'ticket_grab') {
|
|
|
$query = Reservation::with([
|
|
|
'venue:'.Venue::referenceNameSelectString(),
|
|
|
'ticketGrabEvent:id,title',
|
|
|
])
|
|
|
->where('reservation_kind', Reservation::KIND_TICKET_GRAB)
|
|
|
->orderByDesc('id');
|
|
|
} else {
|
|
|
$query = Reservation::with([
|
|
|
'venue:'.Venue::referenceNameSelectString(),
|
|
|
'activity:id,title',
|
|
|
'activityDay:id,activity_id,activity_date,session_name,session_start_at,session_end_at',
|
|
|
])
|
|
|
->where(function ($q) {
|
|
|
$q->whereNull('reservation_kind')
|
|
|
->orWhere('reservation_kind', Reservation::KIND_ACTIVITY);
|
|
|
})
|
|
|
->orderByDesc('id');
|
|
|
}
|
|
|
|
|
|
$user = $request->user();
|
|
|
if (! $user->isSuperAdmin()) {
|
|
|
$query->whereIn('venue_id', $user->venues()->pluck('venues.id'));
|
|
|
}
|
|
|
|
|
|
if ($request->filled('venue_id')) {
|
|
|
$vid = (int) $request->input('venue_id');
|
|
|
if ($vid > 0) {
|
|
|
if (! $user->isSuperAdmin()) {
|
|
|
abort_unless(
|
|
|
$user->venues()->where('venues.id', $vid)->exists(),
|
|
|
403,
|
|
|
'仅可筛选已绑定场馆'
|
|
|
);
|
|
|
}
|
|
|
$query->where('venue_id', $vid);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
if ($kind !== 'ticket_grab' && $request->filled('activity_id')) {
|
|
|
$aid = (int) $request->input('activity_id');
|
|
|
if ($aid > 0) {
|
|
|
$query->where('activity_id', $aid);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
if ($kind === 'ticket_grab' && $request->filled('ticket_grab_event_id')) {
|
|
|
$eid = (int) $request->input('ticket_grab_event_id');
|
|
|
if ($eid > 0) {
|
|
|
$query->where('ticket_grab_event_id', $eid);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
if ($request->filled('status') && $request->string('status')->toString() !== 'all') {
|
|
|
$query->where('status', (string) $request->string('status'));
|
|
|
}
|
|
|
if ($request->filled('keyword')) {
|
|
|
$keyword = trim((string) $request->input('keyword'));
|
|
|
$query->where(function ($q) use ($keyword, $kind) {
|
|
|
$q->where('visitor_name', 'like', "%{$keyword}%")
|
|
|
->orWhere('qr_token', 'like', "%{$keyword}%");
|
|
|
if ($kind === 'ticket_grab') {
|
|
|
$q->orWhere('id_card', 'like', "%{$keyword}%");
|
|
|
} else {
|
|
|
$q->orWhere('visitor_phone', 'like', "%{$keyword}%");
|
|
|
}
|
|
|
});
|
|
|
}
|
|
|
$this->applyReservationDateRangeFilter($query, $request, $kind);
|
|
|
|
|
|
$pageSize = max(1, min(200, (int) $request->input('page_size', 10)));
|
|
|
$page = $query->paginate($pageSize);
|
|
|
$rows = collect($page->items());
|
|
|
if ($rows->isNotEmpty()) {
|
|
|
$venueIds = $rows->pluck('venue_id')->filter()->map(fn ($v) => (int) $v)->unique()->values();
|
|
|
$phones = $rows->pluck('visitor_phone')->filter()->map(fn ($v) => (string) $v)->unique()->values();
|
|
|
$blackSet = $kind === 'ticket_grab'
|
|
|
? collect()
|
|
|
: Blacklist::query()
|
|
|
->active()
|
|
|
->whereIn('venue_id', $venueIds)
|
|
|
->whereIn('visitor_phone', $phones)
|
|
|
->get(['venue_id', 'visitor_phone'])
|
|
|
->mapWithKeys(fn ($b) => [$b->venue_id.'#'.$b->visitor_phone => true]);
|
|
|
|
|
|
$page->setCollection($rows->map(function ($row) use ($blackSet, $kind) {
|
|
|
$row->is_blacklisted = $kind === 'ticket_grab'
|
|
|
? false
|
|
|
: (bool) ($row->visitor_phone
|
|
|
&& isset($blackSet[$row->venue_id.'#'.$row->visitor_phone]));
|
|
|
if ($row->relationLoaded('venue') && $row->venue instanceof Venue) {
|
|
|
$row->venue->applyDisplayNameForReference();
|
|
|
}
|
|
|
|
|
|
return $row;
|
|
|
}));
|
|
|
}
|
|
|
|
|
|
return response()->json($page);
|
|
|
}
|
|
|
|
|
|
public function export(Request $request, ReservationExpiryService $reservationExpiryService): StreamedResponse
|
|
|
{
|
|
|
$reservationExpiryService->expireStalePendingReservations();
|
|
|
|
|
|
$query = Reservation::with([
|
|
|
'venue:'.Venue::referenceNameSelectString(),
|
|
|
'activity:id,title',
|
|
|
'activityDay:id,activity_id,activity_date,session_name,session_start_at,session_end_at',
|
|
|
])
|
|
|
->where(function ($q) {
|
|
|
$q->whereNull('reservation_kind')
|
|
|
->orWhere('reservation_kind', Reservation::KIND_ACTIVITY);
|
|
|
})
|
|
|
->orderByDesc('id');
|
|
|
$user = $request->user();
|
|
|
if (! $user->isSuperAdmin()) {
|
|
|
$query->whereIn('venue_id', $user->venues()->pluck('venues.id'));
|
|
|
}
|
|
|
if ($request->filled('venue_id')) {
|
|
|
$vid = (int) $request->input('venue_id');
|
|
|
if ($vid > 0) {
|
|
|
if (! $user->isSuperAdmin()) {
|
|
|
abort_unless(
|
|
|
$user->venues()->where('venues.id', $vid)->exists(),
|
|
|
403,
|
|
|
'仅可筛选已绑定场馆'
|
|
|
);
|
|
|
}
|
|
|
$query->where('venue_id', $vid);
|
|
|
}
|
|
|
}
|
|
|
if ($request->filled('activity_id')) {
|
|
|
$aid = (int) $request->input('activity_id');
|
|
|
if ($aid > 0) {
|
|
|
$query->where('activity_id', $aid);
|
|
|
}
|
|
|
}
|
|
|
if ($request->filled('status') && $request->string('status')->toString() !== 'all') {
|
|
|
$query->where('status', (string) $request->string('status'));
|
|
|
}
|
|
|
if ($request->filled('keyword')) {
|
|
|
$keyword = trim((string) $request->input('keyword'));
|
|
|
$query->where(function ($q) use ($keyword) {
|
|
|
$q->where('visitor_name', 'like', "%{$keyword}%")
|
|
|
->orWhere('visitor_phone', 'like', "%{$keyword}%")
|
|
|
->orWhere('qr_token', 'like', "%{$keyword}%");
|
|
|
});
|
|
|
}
|
|
|
$this->applyReservationDateRangeFilter($query, $request, 'activity');
|
|
|
|
|
|
$rows = $query->limit(5000)->get();
|
|
|
$filename = 'activity-registrations-'.now()->format('Ymd-His').'.csv';
|
|
|
|
|
|
return response()->streamDownload(function () use ($rows) {
|
|
|
$out = fopen('php://output', 'w');
|
|
|
fprintf($out, chr(0xEF).chr(0xBB).chr(0xBF));
|
|
|
fputcsv($out, ['ID', '活动', '场馆', '报名人', '手机号', '预约类型', '预约票数', '场次名称', '预约时间', '状态', '下单时间', '核销时间', '二维码Token']);
|
|
|
foreach ($rows as $row) {
|
|
|
if ($row->venue instanceof Venue) {
|
|
|
$row->venue->applyDisplayNameForReference();
|
|
|
}
|
|
|
$ad = $row->activityDay;
|
|
|
$sessionName = $ad ? (string) ($ad->session_name ?? '') : '';
|
|
|
$timeStr = $ad ? $ad->formatSessionTimeRangeZh() : '';
|
|
|
fputcsv($out, [
|
|
|
$row->id,
|
|
|
$row->activity?->title ?? '',
|
|
|
$row->venue?->name ?? '',
|
|
|
$row->visitor_name,
|
|
|
$row->visitor_phone ?? '',
|
|
|
self::bookingTypeLabel($row->booking_type, $row->ticket_count),
|
|
|
(string) ($row->ticket_count ?? 1),
|
|
|
$sessionName,
|
|
|
$timeStr,
|
|
|
self::statusLabel($row->status),
|
|
|
self::formatShanghai($row->created_at),
|
|
|
self::formatShanghai($row->verified_at),
|
|
|
$row->qr_token,
|
|
|
]);
|
|
|
}
|
|
|
fclose($out);
|
|
|
}, $filename, ['Content-Type' => 'text/csv; charset=UTF-8']);
|
|
|
}
|
|
|
|
|
|
public function quickBlacklist(Request $request, Reservation $reservation): JsonResponse
|
|
|
{
|
|
|
$user = $request->user();
|
|
|
if (! $user->isSuperAdmin()) {
|
|
|
$allowed = $user->venues()->where('venues.id', $reservation->venue_id)->exists();
|
|
|
abort_unless($allowed, 403, '仅可操作已绑定场馆');
|
|
|
}
|
|
|
|
|
|
if (! $reservation->visitor_phone) {
|
|
|
return response()->json(['message' => '该报名记录无手机号，无法加入灰名单'], 422);
|
|
|
}
|
|
|
|
|
|
$data = $request->validate([
|
|
|
'reason' => ['required', 'string', 'max:255'],
|
|
|
]);
|
|
|
|
|
|
$item = Blacklist::updateOrCreate(
|
|
|
['venue_id' => $reservation->venue_id, 'visitor_phone' => $reservation->visitor_phone],
|
|
|
[
|
|
|
'visitor_name' => $reservation->visitor_name,
|
|
|
'reason' => $data['reason'],
|
|
|
'revoked_at' => null,
|
|
|
],
|
|
|
);
|
|
|
|
|
|
return response()->json($item->load('venue:'.Venue::referenceNameSelectString()), 201);
|
|
|
}
|
|
|
|
|
|
public function batchQuickBlacklist(Request $request): JsonResponse
|
|
|
{
|
|
|
$data = $request->validate([
|
|
|
'reservation_ids' => ['required', 'array', 'min:1'],
|
|
|
'reservation_ids.*' => ['required', 'integer', 'exists:reservations,id'],
|
|
|
'reason' => ['required', 'string', 'max:255'],
|
|
|
]);
|
|
|
|
|
|
$user = $request->user();
|
|
|
$ids = collect($data['reservation_ids'])->map(fn ($v) => (int) $v)->unique()->values();
|
|
|
$reservations = Reservation::whereIn('id', $ids)->get();
|
|
|
|
|
|
$count = 0;
|
|
|
$failed = [];
|
|
|
foreach ($reservations as $reservation) {
|
|
|
if (! $user->isSuperAdmin()) {
|
|
|
$allowed = $user->venues()->where('venues.id', $reservation->venue_id)->exists();
|
|
|
if (! $allowed) {
|
|
|
$failed[] = ['reservation_id' => $reservation->id, 'reason' => '无场馆权限'];
|
|
|
|
|
|
continue;
|
|
|
}
|
|
|
}
|
|
|
if (! $reservation->visitor_phone) {
|
|
|
$failed[] = ['reservation_id' => $reservation->id, 'reason' => '缺少手机号'];
|
|
|
|
|
|
continue;
|
|
|
}
|
|
|
|
|
|
Blacklist::updateOrCreate(
|
|
|
['venue_id' => $reservation->venue_id, 'visitor_phone' => $reservation->visitor_phone],
|
|
|
[
|
|
|
'visitor_name' => $reservation->visitor_name,
|
|
|
'reason' => $data['reason'],
|
|
|
'revoked_at' => null,
|
|
|
],
|
|
|
);
|
|
|
$count++;
|
|
|
}
|
|
|
|
|
|
return response()->json([
|
|
|
'message' => '批量列入灰名单完成',
|
|
|
'count' => $count,
|
|
|
'failed_count' => count($failed),
|
|
|
'failed' => $failed,
|
|
|
]);
|
|
|
}
|
|
|
|
|
|
private static function formatShanghai(mixed $value): string
|
|
|
{
|
|
|
if ($value === null) {
|
|
|
return '';
|
|
|
}
|
|
|
|
|
|
return Carbon::parse($value)->timezone('Asia/Shanghai')->format('Y-m-d H:i:s');
|
|
|
}
|
|
|
|
|
|
private static function statusLabel(string $status): string
|
|
|
{
|
|
|
return match ($status) {
|
|
|
'pending' => '待核销',
|
|
|
'verified' => '已核销',
|
|
|
'cancelled' => '已取消',
|
|
|
'expired' => '已过期',
|
|
|
default => $status,
|
|
|
};
|
|
|
}
|
|
|
|
|
|
private static function bookingTypeLabel(?string $bookingType, mixed $ticketCount): string
|
|
|
{
|
|
|
if ($bookingType === 'group') {
|
|
|
return '团体';
|
|
|
}
|
|
|
if ($bookingType === 'individual') {
|
|
|
return '个人';
|
|
|
}
|
|
|
$n = max(1, (int) $ticketCount);
|
|
|
|
|
|
return $n > 1 ? '团体' : '个人';
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 日期筛选：activity_day=关联场次活动日（场次时间）；entry_date=抢票入馆日；created_at=下单时间。
|
|
|
*/
|
|
|
private function applyReservationDateRangeFilter(Builder $query, Request $request, string $kind): void
|
|
|
{
|
|
|
if (! $request->filled('start_date') && ! $request->filled('end_date')) {
|
|
|
return;
|
|
|
}
|
|
|
|
|
|
$dateField = (string) $request->input('date_field', $kind === 'ticket_grab' ? 'created_at' : 'activity_day');
|
|
|
|
|
|
if ($dateField === 'activity_day' && $kind !== 'ticket_grab') {
|
|
|
$start = $request->filled('start_date') ? (string) $request->input('start_date') : null;
|
|
|
$end = $request->filled('end_date') ? (string) $request->input('end_date') : $start;
|
|
|
$query->whereHas('activityDay', function ($q) use ($start, $end) {
|
|
|
if ($start !== null && $start !== '') {
|
|
|
$q->whereDate('activity_date', '>=', $start);
|
|
|
}
|
|
|
if ($end !== null && $end !== '') {
|
|
|
$q->whereDate('activity_date', '<=', $end);
|
|
|
}
|
|
|
});
|
|
|
|
|
|
return;
|
|
|
}
|
|
|
|
|
|
if ($dateField === 'entry_date' && $kind === 'ticket_grab') {
|
|
|
$start = $request->filled('start_date') ? (string) $request->input('start_date') : null;
|
|
|
$end = $request->filled('end_date') ? (string) $request->input('end_date') : $start;
|
|
|
if ($start !== null && $start !== '') {
|
|
|
$query->whereDate('entry_date', '>=', $start);
|
|
|
}
|
|
|
if ($end !== null && $end !== '') {
|
|
|
$query->whereDate('entry_date', '<=', $end);
|
|
|
}
|
|
|
|
|
|
return;
|
|
|
}
|
|
|
|
|
|
if ($request->filled('start_date')) {
|
|
|
$query->whereDate('created_at', '>=', (string) $request->input('start_date'));
|
|
|
}
|
|
|
if ($request->filled('end_date')) {
|
|
|
$query->whereDate('created_at', '<=', (string) $request->input('end_date'));
|
|
|
}
|
|
|
}
|
|
|
}
|
