Admin

name	type	size	perms	modified	actions
[parent directory]
ApprovalService.php	file	12,366 B	0664	2026-07-30 14:57:20	edit
ApprovalSettingService.php	file	3,646 B	0664	2026-07-14 10:08:14	edit
AuthService.php	file	3,959 B	0664	2026-05-03 16:37:15	edit
BatchService.php	file	100,058 B	0664	2026-09-16 06:04:51	edit
BusinessService.php	file	11,437 B	0664	2026-05-03 16:37:15	edit
DayService.php	file	1,461 B	0664	2026-05-03 16:37:15	edit
FirebaseService.php	file	583 B	0664	2026-05-03 16:37:15	edit
HalaqohService.php	file	11,049 B	0664	2026-08-28 03:06:25	edit
KeycloakService.php	file	12,822 B	0664	2026-07-31 07:03:53	edit
LevelService.php	file	2,962 B	0664	2026-06-02 02:02:20	edit
MediaService.php	file	3,926 B	0664	2026-05-03 16:37:15	edit
ModulService.php	file	758 B	0664	2026-05-21 00:25:15	edit
PermissionService.php	file	2,410 B	0664	2026-05-03 16:37:15	edit
PertemuanActivityLogService.php	file	1,027 B	0664	2026-06-09 07:16:44	edit
PresensiPertemuanCommentService.php	file	1,358 B	0664	2026-06-09 07:16:44	edit
PresensiPertemuanService.php	file	5,669 B	0664	2026-06-09 07:16:44	edit
ProgramService.php	file	14,744 B	0664	2026-08-27 00:08:09	edit
RoleService.php	file	3,710 B	0664	2026-05-03 16:37:15	edit
SessionService.php	file	1,497 B	0664	2026-05-03 16:37:15	edit
UserService.php	file	23,413 B	0664	2026-09-14 10:32:26	edit

editing: BatchService.php

<?php

namespace App\Services;

use App\Models\Batch;
use App\Models\User;
use App\Models\Halaqoh;
use App\Models\Day;
use App\Models\Session;
use App\Models\UserTemporary;
use App\Models\HalaqohTemporary;
use App\Models\PertemuanTemporary;
use App\Models\HalaqohMappingPertemuan;
use App\Models\HalaqohMappingUser;
use App\Models\PresensiPertemuan;
use App\Models\PresensiPertemuanComment;
use App\Models\PertemuanActivityLog;
use App\Repositories\BatchRepository;
use Illuminate\Support\Facades\Gate;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Str;
use App\Helpers\GlobalHelper;
use App\Jobs\CreateKeycloakUserJob;

class BatchService
{
    protected BatchRepository $repository;
    protected array $meetingDateCache = [];

public function __construct(BatchRepository $repository)
    {
        $this->repository = $repository;
    }

public function getAll(array $params)
    {
        Gate::authorize('viewAny', Batch::class);
        $params['with'] = array_merge($params['with'] ?? [], ['program']);

$statusFilter = $params['filters']['status'] ?? $params['status'] ?? null;
        if ($statusFilter !== null && (string)$statusFilter === '0') {
            $params['withCount'] = [
                'halaqohs' => function ($q) { $q->withTrashed(); },
                'gurus',
                'murids',
            ];
        } else {
            $params['withCount'] = array_merge($params['withCount'] ?? [], ['halaqohs', 'gurus', 'murids']);
        }

return $this->repository->filtered($params);
    }

public function getById(int|string $id, array $with = []): Batch
    {
        $batch = $this->repository->find($id);

if (!$batch) {
            throw new \InvalidArgumentException('Batch tidak ditemukan.');
        }

Gate::authorize('view', $batch);

return $batch;
    }

public function store(array $data): Batch
    {
        Gate::authorize('create', Batch::class);

return DB::transaction(function () use ($data) {
            // ── Pisahkan field halaqah/pertemuan dari data batch ──
            $halaqahKeys = [
                'halaqah_count', 'halaqah_name_prefix', 'halaqah_day_id',
                'halaqah_session_id', 'halaqah_description',
                'pertemuan_count', 'pertemuan_name_prefix', 'pertemuan_description',
                'location_type', 'online_url', 'offline_place', 'offline_address',
            ];
            $halaqahData = array_intersect_key($data, array_flip($halaqahKeys));
            $batchData   = array_diff_key($data, array_flip($halaqahKeys));

$batch = $this->repository->create($batchData);

// ── Auto-generate Halaqah & Pertemuan jika ada ──
            $halaqahCount = (int) ($halaqahData['halaqah_count'] ?? 0);
            if ($halaqahCount > 0) {
                $this->generateHalaqahAndPertemuan($batch, $halaqahData);
            }

return $batch;
        });
    }

/**
     * Generate Halaqah beserta Pertemuan-nya secara bulk setelah batch dibuat.
     */
    protected function generateHalaqahAndPertemuan(Batch $batch, array $data): void
    {
        $halaqahCount    = (int) ($data['halaqah_count'] ?? 0);
        $halaqahPrefix   = !empty($data['halaqah_name_prefix']) ? trim($data['halaqah_name_prefix']) : 'Halaqah';
        $dayId           = !empty($data['halaqah_day_id']) ? (int) $data['halaqah_day_id'] : null;
        $sessionId       = !empty($data['halaqah_session_id']) ? (int) $data['halaqah_session_id'] : null;
        $halaqahDesc     = $data['halaqah_description'] ?? null;
        $pertemuanCount  = (int) ($data['pertemuan_count'] ?? 0);
        $pertemuanPrefix = !empty($data['pertemuan_name_prefix']) ? trim($data['pertemuan_name_prefix']) : 'Pertemuan';
        $pertemuanDesc   = $data['pertemuan_description'] ?? null;
        $locationType    = $data['location_type'] ?? 'online';
        $onlineUrl       = $data['online_url'] ?? null;
        $offlinePlace    = $data['offline_place'] ?? null;
        $offlineAddress  = $data['offline_address'] ?? null;

$combinedOfflinePlace = $offlinePlace;
        if ($offlineAddress) {
            $combinedOfflinePlace = $offlinePlace ? ($offlinePlace . ' - ' . $offlineAddress) : $offlineAddress;
        }

$now = now();
        $pertemuansToInsert = [];

// Retrieve active days from the chosen day_id to calculate meeting dates
        $intDays = [];
        if ($dayId) {
            $day = \App\Models\Day::find($dayId);
            if ($day) {
                $intDays = is_string($day->int_days) ? json_decode($day->int_days, true) : $day->int_days;
                if (!is_array($intDays)) {
                    $intDays = [];
                }
            }
        }

// Pre-load session for start/end hour defaults
        $session = $sessionId ? \App\Models\Session::find($sessionId) : null;
        $startHour = $session?->start_hour ?? '00:00:00';
        $endHour   = $session?->end_hour   ?? '23:59:59';

for ($i = 1; $i <= $halaqahCount; $i++) {
            $halaqahName = $halaqahCount === 1 ? $halaqahPrefix : "{$halaqahPrefix} {$i}";

$halaqah = Halaqoh::create([
                'batch_id'    => $batch->id,
                'name'        => $halaqahName,
                'type'        => $locationType,
                'day_id'      => $dayId,
                'session_id'  => $sessionId,
                'description' => $halaqahDesc,
                'status'      => 1, // Aktif
            ]);

// Kumpulkan pertemuan untuk bulk insert
            for ($j = 1; $j <= $pertemuanCount; $j++) {
                $pertemuanName = $pertemuanCount === 1 ? $pertemuanPrefix : "{$pertemuanPrefix} {$j}";
                $scheduleDate = $this->calculateMeetingDate($batch->start_date, $intDays, $j);

$pertemuansToInsert[] = [
                    'batch_id'           => $batch->id,
                    'halaqah_id'         => $halaqah->id,
                    'guru_id'            => null,
                    'name'               => $pertemuanName,
                    'type_pertemuan'     => 'kelas',
                    'order'              => $j,
                    'type'               => $locationType,
                    'online_url'         => $onlineUrl,
                    'offline_place'      => $combinedOfflinePlace,
                    'notes'              => null,
                    'description'        => $pertemuanDesc,
                    'status'             => 1, // Aktif
                    'schedule_date'      => $scheduleDate,
                    'start_session_date' => $scheduleDate . ' ' . $startHour,
                    'end_session_date'   => $scheduleDate . ' ' . $endHour,
                    'created_at'         => $now,
                    'updated_at'         => $now,
                ];
            }
        }

// Bulk insert semua pertemuan sekaligus (500 per chunk)
        if (!empty($pertemuansToInsert)) {
            foreach (array_chunk($pertemuansToInsert, 500) as $chunk) {
                HalaqohMappingPertemuan::insert($chunk);
            }
        }
    }

/**
     * Tambah sejumlah Halaqah baru ke Batch yang sudah ada.
     */
    public function addHalaqahToBatch(int|string $batchId, array $data): array
    {
        $batch = $this->repository->find($batchId);
        if (!$batch) {
            throw new \InvalidArgumentException('Batch tidak ditemukan.');
        }

Gate::authorize('update', $batch);

return DB::transaction(function () use ($batch, $data) {
            $halaqahCount    = (int) ($data['halaqah_count'] ?? 1);
            $halaqahPrefix   = !empty($data['halaqah_name_prefix']) ? trim($data['halaqah_name_prefix']) : 'Halaqah';
            $dayId           = !empty($data['day_id']) ? (int) $data['day_id'] : (!empty($data['halaqah_day_id']) ? (int) $data['halaqah_day_id'] : null);
            $sessionId       = !empty($data['session_id']) ? (int) $data['session_id'] : (!empty($data['halaqah_session_id']) ? (int) $data['halaqah_session_id'] : null);
            $halaqahDesc     = $data['description'] ?? $data['halaqah_description'] ?? null;
            $locationType    = $data['location_type'] ?? $data['type'] ?? 'online';
            $onlineUrl       = $data['online_url'] ?? null;
            $offlinePlace    = $data['offline_place'] ?? null;
            $offlineAddress  = $data['offline_address'] ?? null;

$combinedOfflinePlace = $offlinePlace;
            if ($offlineAddress) {
                $combinedOfflinePlace = $offlinePlace ? ($offlinePlace . ' - ' . $offlineAddress) : $offlineAddress;
            }

// Find existing halaqahs in this batch to determine starting index
            $existingCount = Halaqoh::where('batch_id', $batch->id)->count();
            $startIndex = $existingCount + 1;
            $endIndex = $existingCount + $halaqahCount;

// Check if batch already has meetings on existing halaqahs to clone to new halaqahs
            $templateHalaqah = Halaqoh::where('batch_id', $batch->id)
                ->whereHas('jadwals', function ($q) {
                    $q->where('status', '!=', 0);
                })
                ->withCount(['jadwals' => function ($q) {
                    $q->where('status', '!=', 0);
                }])
                ->orderBy('jadwals_count', 'desc')
                ->first();

$existingPertemuans = $templateHalaqah
                ? HalaqohMappingPertemuan::where('halaqah_id', $templateHalaqah->id)
                    ->where('status', '!=', 0)
                    ->orderBy('order', 'asc')
                    ->get()
                : collect();

// Retrieve active days from the chosen day_id to calculate meeting dates
            $intDays = [];
            if ($dayId) {
                $day = Day::find($dayId);
                if ($day) {
                    $intDays = is_string($day->int_days) ? json_decode($day->int_days, true) : $day->int_days;
                    if (!is_array($intDays)) {
                        $intDays = [];
                    }
                }
            }

// Pre-load session for start/end hour defaults
            $session = $sessionId ? Session::find($sessionId) : null;
            $startHour = $session?->start_hour ?? '00:00:00';
            $endHour   = $session?->end_hour   ?? '23:59:59';
            $now = now();

$createdHalaqahs = [];
            $pertemuansToInsert = [];

for ($i = $startIndex; $i <= $endIndex; $i++) {
                $halaqahName = "{$halaqahPrefix} {$i}";

$halaqah = Halaqoh::create([
                    'batch_id'    => $batch->id,
                    'name'        => $halaqahName,
                    'type'        => $locationType,
                    'day_id'      => $dayId,
                    'session_id'  => $sessionId,
                    'description' => $halaqahDesc,
                    'status'      => 1, // Aktif
                ]);

$createdHalaqahs[] = $halaqah;

// If meetings exist for this batch, clone all of them for the new halaqah
                if ($existingPertemuans->isNotEmpty()) {
                    foreach ($existingPertemuans as $pertemuanTemplate) {
                        $order = $pertemuanTemplate->order;
                        $scheduleDate = !empty($intDays)
                            ? $this->calculateMeetingDate($batch->start_date, $intDays, $order)
                            : ($pertemuanTemplate->schedule_date ?: $this->calculateMeetingDate($batch->start_date, [], $order));

$pertemuansToInsert[] = [
                            'batch_id'           => $batch->id,
                            'halaqah_id'         => $halaqah->id,
                            'guru_id'            => null,
                            'name'               => $pertemuanTemplate->name ?: "Pertemuan {$order}",
                            'type_pertemuan'     => $pertemuanTemplate->type_pertemuan ?: 'kelas',
                            'order'              => $order,
                            'type'               => $locationType ?: ($pertemuanTemplate->type ?: 'online'),
                            'online_url'         => $onlineUrl ?: $pertemuanTemplate->online_url,
                            'offline_place'      => $combinedOfflinePlace ?: $pertemuanTemplate->offline_place,
                            'notes'              => $pertemuanTemplate->notes,
                            'description'        => $pertemuanTemplate->description,
                            'status'             => 1,
                            'schedule_date'      => $scheduleDate,
                            'start_session_date' => $scheduleDate ? ($scheduleDate . ' ' . $startHour) : null,
                            'end_session_date'   => $scheduleDate ? ($scheduleDate . ' ' . $endHour) : null,
                            'created_at'         => $now,
                            'updated_at'         => $now,
                        ];
                    }
                }
            }

if (!empty($pertemuansToInsert)) {
                foreach (array_chunk($pertemuansToInsert, 500) as $chunk) {
                    HalaqohMappingPertemuan::insert($chunk);
                }
            }

return [
                'batch' => $batch,
                'created_halaqahs_count' => count($createdHalaqahs),
                'total_halaqahs' => $endIndex,
                'cloned_pertemuans_per_halaqah' => $existingPertemuans->count(),
            ];
        });
    }

/**
     * Tambah sejumlah Pertemuan baru ke seluruh Halaqah dalam Batch.
     */
    public function addPertemuanToBatch(int|string $batchId, array $data): array
    {
        $batch = $this->repository->find($batchId);
        if (!$batch) {
            throw new \InvalidArgumentException('Batch tidak ditemukan.');
        }

Gate::authorize('update', $batch);

return DB::transaction(function () use ($batch, $data) {
            $pertemuanCount  = max(1, (int) ($data['pertemuan_count'] ?? 1));
            $customPrefix    = !empty($data['pertemuan_name_prefix']) ? trim($data['pertemuan_name_prefix']) : null;
            $pertemuanDesc   = $data['description'] ?? $data['pertemuan_description'] ?? null;
            $locationType    = $data['location_type'] ?? $data['type'] ?? 'online';
            $customStartDate = !empty($data['schedule_date']) ? $data['schedule_date'] : (!empty($data['start_date']) ? $data['start_date'] : null);
            $sessionId       = !empty($data['session_id']) ? (int) $data['session_id'] : null;
            $onlineUrl       = $data['online_url'] ?? null;
            $offlinePlace    = $data['offline_place'] ?? null;
            $offlineAddress  = $data['offline_address'] ?? null;

$session = $sessionId ? Session::find($sessionId) : null;
            $defaultStartHour = $session?->start_hour ?? '00:00:00';
            $defaultEndHour   = $session?->end_hour   ?? '23:59:59';
            $now = now();

$halaqahs = Halaqoh::with(['day', 'session'])
                ->where('batch_id', $batch->id)
                ->where('status', '!=', 0)
                ->get();

if ($halaqahs->isEmpty()) {
                throw new \InvalidArgumentException('Batch belum memiliki halaqah. Silakan tambahkan halaqah terlebih dahulu.');
            }

$pertemuansToInsert = [];

foreach ($halaqahs as $halaqah) {
                // Determine existing meeting count and last meeting for this halaqah
                $lastMeeting = HalaqohMappingPertemuan::where('halaqah_id', $halaqah->id)
                    ->where('status', '!=', 0)
                    ->orderBy('order', 'desc')
                    ->first();

$lastOrder = $lastMeeting ? (int) $lastMeeting->order : 0;

// Determine prefix from last meeting name if not explicitly provided
                $prefix = $customPrefix;
                if (empty($prefix)) {
                    if ($lastMeeting && !empty($lastMeeting->name)) {
                        if (preg_match('/^(.*?)(?:\s+\d+)?$/', trim($lastMeeting->name), $matches)) {
                            $prefix = trim($matches[1]) ?: 'Pertemuan';
                        } else {
                            $prefix = 'Pertemuan';
                        }
                    } else {
                        $prefix = 'Pertemuan';
                    }
                }

// Get active days from halaqah's day schedule
                $intDays = [];
                if ($halaqah->day) {
                    $intDays = is_string($halaqah->day->int_days) ? json_decode($halaqah->day->int_days, true) : $halaqah->day->int_days;
                    if (!is_array($intDays)) {
                        $intDays = [];
                    }
                }
                $carbonDays = array_map(function ($d) {
                    return $d === 6 ? 0 : $d + 1;
                }, $intDays);

// Hours from: 1. Request session_id, 2. Last meeting hours, 3. Halaqah session, 4. Fallback defaults
                $startHour = null;
                $endHour = null;
                if ($sessionId && $session) {
                    $startHour = $session->start_hour;
                    $endHour   = $session->end_hour;
                } elseif ($lastMeeting && !empty($lastMeeting->start_session_date) && !empty($lastMeeting->end_session_date)) {
                    $startHour = date('H:i:s', strtotime($lastMeeting->start_session_date));
                    $endHour   = date('H:i:s', strtotime($lastMeeting->end_session_date));
                } elseif ($halaqah->session) {
                    $startHour = $halaqah->session->start_hour;
                    $endHour   = $halaqah->session->end_hour;
                } else {
                    $startHour = $defaultStartHour;
                    $endHour   = $defaultEndHour;
                }

// Find assigned guru if any
                $guruMapping = HalaqohMappingUser::where('halaqah_id', $halaqah->id)->where('type', 'guru')->first();
                $guruId = $guruMapping?->user_id;

// Track cursor date for advancing meetings sequentially
                $cursorDate = null;
                if (empty($customStartDate) && $lastMeeting && !empty($lastMeeting->schedule_date)) {
                    try {
                        $cursorDate = \Carbon\Carbon::parse($lastMeeting->schedule_date);
                    } catch (\Exception $e) {
                        $cursorDate = null;
                    }
                }

for ($k = 1; $k <= $pertemuanCount; $k++) {
                    $order = $lastOrder + $k;
                    $pertemuanName = "{$prefix} {$order}";

if (!empty($customStartDate)) {
                        $scheduleDate = $this->calculateMeetingDate($customStartDate, $intDays, $k);
                    } elseif ($cursorDate) {
                        if (!empty($carbonDays)) {
                            for ($step = 0; $step < 1000; $step++) {
                                $cursorDate->addDay();
                                if (in_array($cursorDate->dayOfWeek, $carbonDays)) {
                                    break;
                                }
                            }
                            $scheduleDate = $cursorDate->format('Y-m-d');
                        } else {
                            $scheduleDate = $cursorDate->addWeek()->format('Y-m-d');
                        }
                    } else {
                        $scheduleDate = $this->calculateMeetingDate($batch->start_date, $intDays, $order);
                    }

$meetingLocationType = $locationType;
                    $meetingOnlineUrl = $onlineUrl;
                    $meetingOfflinePlace = $combinedOfflinePlace;

if (empty($meetingOnlineUrl) && empty($meetingOfflinePlace) && $lastMeeting) {
                        if ($meetingLocationType === ($lastMeeting->type ?? 'online')) {
                            $meetingOnlineUrl = $lastMeeting->online_url;
                            $meetingOfflinePlace = $lastMeeting->offline_place;
                        }
                    }

$pertemuansToInsert[] = [
                        'batch_id'           => $batch->id,
                        'halaqah_id'         => $halaqah->id,
                        'guru_id'            => $guruId,
                        'name'               => $pertemuanName,
                        'type_pertemuan'     => 'kelas',
                        'order'              => $order,
                        'type'               => $meetingLocationType,
                        'online_url'         => $meetingOnlineUrl,
                        'offline_place'      => $meetingOfflinePlace,
                        'notes'              => null,
                        'description'        => $pertemuanDesc,
                        'status'             => 1, // Aktif
                        'schedule_date'      => $scheduleDate,
                        'start_session_date' => $scheduleDate ? ($scheduleDate . ' ' . $startHour) : null,
                        'end_session_date'   => $scheduleDate ? ($scheduleDate . ' ' . $endHour) : null,
                        'created_at'         => $now,
                        'updated_at'         => $now,
                    ];
                }
            }

return [
                'batch' => $batch,
                'halaqahs_count' => $halaqahs->count(),
                'added_pertemuan_per_halaqah' => $pertemuanCount,
                'total_inserted_pertemuans' => count($pertemuansToInsert),
            ];
        });
    }

/**
     * Assign Guru ke masing-masing Halaqah di dalam Batch.
     */
    public function assignGurusToBatch(int|string $batchId, array $data): array
    {
        $batch = $this->repository->find($batchId);
        if (!$batch) {
            throw new \InvalidArgumentException('Batch tidak ditemukan.');
        }

Gate::authorize('update', $batch);

return DB::transaction(function () use ($batch, $data) {
            $assignments = $data['assignments'] ?? [];
            $updatedCount = 0;

foreach ($assignments as $item) {
                $halaqahId = $item['halaqah_id'] ?? null;
                $guruId    = !empty($item['guru_id']) ? (int) $item['guru_id'] : null;

if (!$halaqahId) continue;

$halaqah = Halaqoh::where('batch_id', $batch->id)->find($halaqahId);
                if (!$halaqah) continue;

if ($guruId) {
                    $guruMappings = HalaqohMappingUser::where('halaqah_id', $halaqah->id)
                        ->where('type', 'guru')
                        ->get();

if ($guruMappings->isNotEmpty()) {
                        $first = $guruMappings->first();
                        $first->update([
                            'batch_id' => $batch->id,
                            'user_id'  => $guruId,
                            'type'     => 'guru',
                            'status'   => 1,
                        ]);

if ($guruMappings->count() > 1) {
                            $guruMappings->skip(1)->each(fn($extra) => $extra->delete());
                        }
                    } else {
                        HalaqohMappingUser::create([
                            'batch_id'   => $batch->id,
                            'halaqah_id' => $halaqah->id,
                            'user_id'    => $guruId,
                            'type'       => 'guru',
                            'status'     => 1,
                        ]);
                    }

// Update guru_id in upcoming meetings that haven't been completed
                    $upcomingJadwals = HalaqohMappingPertemuan::where('halaqah_id', $halaqah->id)
                        ->whereNotIn('status', [3, 4])
                        ->get();

foreach ($upcomingJadwals as $jadwal) {
                        if (!$jadwal->presensis()->exists()) {
                            $jadwal->update(['guru_id' => $guruId]);
                        }
                    }
                } else {
                    // If guruId is null / unassigned, remove guru mapping and reset unstarted meetings
                    HalaqohMappingUser::where('halaqah_id', $halaqah->id)
                        ->where('type', 'guru')
                        ->delete();

$upcomingJadwals = HalaqohMappingPertemuan::where('halaqah_id', $halaqah->id)
                        ->whereNotIn('status', [3, 4])
                        ->get();

foreach ($upcomingJadwals as $jadwal) {
                        if (!$jadwal->presensis()->exists()) {
                            $jadwal->update(['guru_id' => null]);
                        }
                    }
                }

$updatedCount++;
            }

return [
                'batch' => $batch,
                'updated_count' => $updatedCount
            ];
        });
    }

public function update(array $data, int|string $id): Batch
    {
        $batch = $this->repository->find($id);

if (!$batch) {
            throw new \InvalidArgumentException('Batch tidak ditemukan.');
        }

Gate::authorize('update', $batch);

return DB::transaction(function () use ($data, $id, $batch) {
            $updatedBatch = $this->repository->update($data, $id);

if (isset($data['status']) && (int) $data['status'] === 0) {
                $this->archiveBatchChildren($batch->id);
            }

return $updatedBatch;
        });
    }

public function destroy(int|string $id): bool
    {
        $batch = $this->repository->find($id);

if (!$batch) {
            throw new \InvalidArgumentException('Batch tidak ditemukan.');
        }

Gate::authorize('delete', $batch);

return DB::transaction(function () use ($batch, $id) {
            $batch->update(['status' => 0]);
            $this->archiveBatchChildren($batch->id);
            return $this->repository->delete($id);
        });
    }

/**
     * Cascade archiving (status = 0 and soft delete) to all child entities under a Batch.
     */
    public function archiveBatchChildren(int|string $batchId): void
    {
        $halaqahIds = Halaqoh::where('batch_id', $batchId)->pluck('id');

$pertemuanIds = HalaqohMappingPertemuan::whereIn('halaqah_id', $halaqahIds)
            ->orWhere('batch_id', $batchId)
            ->pluck('id');

$mappingUserIds = HalaqohMappingUser::whereIn('halaqah_id', $halaqahIds)
            ->orWhere('batch_id', $batchId)
            ->pluck('id');

$presensiIds = PresensiPertemuan::whereIn('halaqah_jadwal_id', $pertemuanIds)
            ->orWhereIn('halaqah_user_id', $mappingUserIds)
            ->pluck('id');

if ($presensiIds->isNotEmpty()) {
            PresensiPertemuanComment::whereIn('presensi_pertemuan_id', $presensiIds)->delete();
            PresensiPertemuan::whereIn('id', $presensiIds)->delete();
        }

if ($pertemuanIds->isNotEmpty()) {
            PertemuanActivityLog::whereIn('pertemuan_id', $pertemuanIds)->delete();
            HalaqohMappingPertemuan::whereIn('id', $pertemuanIds)->update(['status' => 0]);
            HalaqohMappingPertemuan::whereIn('id', $pertemuanIds)->delete();
        }

if ($mappingUserIds->isNotEmpty()) {
            HalaqohMappingUser::whereIn('id', $mappingUserIds)->update(['status' => 0]);
            HalaqohMappingUser::whereIn('id', $mappingUserIds)->delete();
        }

if ($halaqahIds->isNotEmpty()) {
            Halaqoh::whereIn('id', $halaqahIds)->update(['status' => 0]);
            Halaqoh::whereIn('id', $halaqahIds)->delete();
        }
    }

public function saveToTemporary(array $data, int|string $batchId)
    {
        $batch = $this->repository->find($batchId);
        if (!$batch) {
            throw new \InvalidArgumentException('Batch tidak ditemukan.');
        }

Gate::authorize('update', $batch);

// Normalize 'minggu' to 'Ahad' in schedule string
        if (isset($data['halaqohs'])) {
            foreach ($data['halaqohs'] as $key => $hData) {
                if (isset($hData['schedule'])) {
                    $normalized = str_ireplace('minggu', 'Ahad', $hData['schedule']);
                    if (strtoupper($hData['schedule']) === 'MINGGU') {
                        $normalized = 'AHAD';
                    }
                    $data['halaqohs'][$key]['schedule'] = $normalized;
                }
            }
        }

return DB::transaction(function () use ($data, $batchId, $batch) {
            // Clear existing temporary data for this batch
            $this->clearTemporary($batchId);

$now = now();
            $allDays = Day::all();

// Build a map of halaqah name to days array and start date
            $halaqahDaysMap = [];
            $halaqahStartDateMap = [];
            foreach ($data['halaqohs'] ?? [] as $hData) {
                $intDays = [];
                if (!empty($hData['day_id'])) {
                    $day = $allDays->firstWhere('id', $hData['day_id']);
                    if ($day) {
                        $intDays = is_string($day->int_days) ? json_decode($day->int_days, true) : $day->int_days;
                    }
                }
                
                if (empty($intDays) && !empty($hData['schedule'])) {
                    $scheduleStr = strtolower(trim($hData['schedule']));
                    $mappedDays = [];
                    $daysMap = ['senin' => 0, 'selasa' => 1, 'rabu' => 2, 'kamis' => 3, 'jumat' => 4, 'sabtu' => 5, 'minggu' => 6, 'ahad' => 6];
                    $cleanSchedule = str_replace(' ', '', $scheduleStr);
                    
                    if ($cleanSchedule === 'setiaphari') {
                        $mappedDays = [0, 1, 2, 3, 4, 5, 6];
                    } elseif ($cleanSchedule === 'senin-jumat') {
                        $mappedDays = [0, 1, 2, 3, 4];
                    } elseif ($cleanSchedule === 'sabtu-minggu' || $cleanSchedule === 'sabtu-ahad') {
                        $mappedDays = [5, 6];
                    } else {
                        $strClean = str_replace(['&', '-'], ',', $scheduleStr);
                        $parts = explode(',', $strClean);
                        foreach ($parts as $p) {
                            $p = trim($p);
                            if (isset($daysMap[$p])) {
                                $mappedDays[] = $daysMap[$p];
                            }
                        }
                        if (str_contains($scheduleStr, '-') && count($mappedDays) == 2) {
                            $start = $mappedDays[0];
                            $end = $mappedDays[1];
                            if ($start < $end) {
                                $mappedDays = range($start, $end);
                            }
                        }
                        $mappedDays = array_values(array_unique($mappedDays));
                        sort($mappedDays);
                    }
                    $intDays = $mappedDays;
                }
                $halaqahDaysMap[$hData['name']] = $intDays;
                
                if (!empty($hData['jadwalTanggal'])) {
                    $halaqahStartDateMap[$hData['name']] = GlobalHelper::excel_to_date($hData['jadwalTanggal']);
                }
            }

// Save Halaqahs
            $halaqahsToInsert = [];
            foreach ($data['halaqohs'] ?? [] as $hData) {
                $halaqahsToInsert[] = [
                    'batch_id' => $batchId,
                    'name' => $hData['name'] ?? null,
                    'type' => $hData['method'] ?? null,
                    'day_id' => $hData['day_id'] ?? null,
                    'session_id' => $hData['session_id'] ?? null,
                    'schedule_name' => $hData['schedule'] ?? null,
                    'time_name' => $hData['time'] ?? null,
                    'guru_name' => $hData['guru'] ?? null,
                    'guru_id' => isset($hData['user_id']) && is_numeric($hData['user_id']) ? (int)$hData['user_id'] : null,
                    'murid_count' => $hData['murid'] ?? 0,
                    'description' => $hData['description'] ?? null,
                    'level_id' => isset($hData['level_id']) && is_numeric($hData['level_id']) ? (int)$hData['level_id'] : null,
                    'level_name' => $hData['level'] ?? null,
                    'created_at' => $now,
                    'updated_at' => $now,
                ];
            }
            if (!empty($halaqahsToInsert)) {
                foreach (array_chunk($halaqahsToInsert, 500) as $chunk) {
                    HalaqohTemporary::insert($chunk);
                }
            }

// Save Gurus & Murids in bulk
            $usersToInsert = [];
            foreach ($data['gurus'] ?? [] as $guru) {
                $usersToInsert[] = [
                    'batch_id' => $batchId,
                    'type' => 'guru',
                    'name' => $guru['name'] ?? null,
                    'email' => $guru['email'] ?? null,
                    'phone' => $guru['phone'] ?? null,
                    'gender' => (isset($guru['gender']) && strtolower($guru['gender']) === 'laki-laki') ? 1 : 2,
                    'halaqah_name' => isset($guru['halaqahs']) ? json_encode($guru['halaqahs']) : null,
                    'created_at' => $now,
                    'updated_at' => $now,
                    'birth_date' => null,
                    'city' => null,
                    'province' => null,
                    'job_id' => null,
                    'user_code' => null,
                    'meta' => null,
                ];
            }

foreach ($data['murids'] ?? [] as $murid) {
                $meta = [];
                $metaKeys = [
                    'kodeNegara', 'lahnJaliy', 'lahnKhafiy', 'catatan', 'pendidikanTerakhir',
                    'tingkatQuranTerakhir', 'waktuTerakhirBelajarQuran', 'alasanBelajarQuran',
                    'frekuensiLiveStream', 'alasanTidakIkutHits', 'setuju', 'urlRekamanTes',
                    'pilihanTipeKelas', 'pilihanWaktuKelas', 'pilihanHariKelas', 'wag', 'halaqah_id'
                ];

foreach ($metaKeys as $key) {
                    if (isset($murid[$key])) {
                        $meta[$key] = $murid[$key];
                    }
                }

$usersToInsert[] = [
                    'batch_id' => $batchId,
                    'type' => 'murid',
                    'name' => $murid['name'] ?? null,
                    'email' => $murid['email'] ?? null,
                    'phone' => $murid['phone'] ?? null,
                    'gender' => (isset($murid['gender']) && strtolower($murid['gender']) === 'perempuan') ? 2 : 1,
                    'birth_date' => $murid['tanggalLahir'] ?? null,
                    'city' => $murid['domisili'] ?? null,
                    'province' => $murid['provinsi'] ?? null,
                    'job_id' => $murid['pekerjaan'] ?? null,
                    'user_code' => $murid['murid_id'] ?? null,
                    'halaqah_name' => $murid['halaqah'] ?? null,
                    'meta' => !empty($meta) ? json_encode($meta) : null,
                    'created_at' => $now,
                    'updated_at' => $now,
                ];
            }

if (!empty($usersToInsert)) {
                foreach (array_chunk($usersToInsert, 500) as $chunk) {
                    UserTemporary::insert($chunk);
                }
            }

// Build a map of halaqah name to min order
            $halaqahMinOrderMap = [];
            foreach ($data['pertemuans'] ?? [] as $pertemuan) {
                $hName = $pertemuan['halaqah'] ?? '';
                $order = (int) ($pertemuan['pertemuanKe'] ?? 1);
                if (!isset($halaqahMinOrderMap[$hName]) || $order < $halaqahMinOrderMap[$hName]) {
                    $halaqahMinOrderMap[$hName] = $order;
                }
            }

// Save Pertemuans
            $pertemuansToInsert = [];
            foreach ($data['pertemuans'] ?? [] as $pertemuan) {
                $scheduleDate = null;
                if (!empty($pertemuan['jadwalTanggal'])) {
                    $scheduleDate = GlobalHelper::excel_to_date($pertemuan['jadwalTanggal']);
                }
                
                if (!$scheduleDate) {
                    $hName = $pertemuan['halaqah'] ?? '';
                    $intDays = $halaqahDaysMap[$hName] ?? [];
                    $order = (int) ($pertemuan['pertemuanKe'] ?? 1);
                    $hStartDate = !empty($halaqahStartDateMap[$hName]) ? $halaqahStartDateMap[$hName] : $batch->start_date;
                    $minOrder = $halaqahMinOrderMap[$hName] ?? 1;
                    $calcOrder = ($order >= $minOrder && $minOrder > 1) ? ($order - $minOrder + 1) : $order;
                    $scheduleDate = $this->calculateMeetingDate($hStartDate, $intDays, $calcOrder);
                }

$pertemuansToInsert[] = [
                    'batch_id' => $batchId,
                    'halaqah_name' => $pertemuan['halaqah'] ?? null,
                    'name' => $pertemuan['nama'] ?? null,
                    'type' => $pertemuan['tipe'] ?? null,
                    'order' => isset($pertemuan['pertemuanKe']) && is_numeric($pertemuan['pertemuanKe']) ? (int)$pertemuan['pertemuanKe'] : null,
                    'offline_place' => $pertemuan['tempat'] ?? null,
                    'online_url' => $pertemuan['link'] ?? null,
                    'schedule_date' => $scheduleDate,
                    'created_at' => $now,
                    'updated_at' => $now,
                ];
            }

if (!empty($pertemuansToInsert)) {
                foreach (array_chunk($pertemuansToInsert, 500) as $chunk) {
                    PertemuanTemporary::insert($chunk);
                }
            }

return true;
        });
    }

public function getTemporaryData(int|string $batchId)
    {
        $batch = $this->repository->find($batchId);
        if (!$batch) {
            throw new \InvalidArgumentException('Batch tidak ditemukan.');
        }

Gate::authorize('view', $batch);

$halaqahs = HalaqohTemporary::where('batch_id', $batchId)->get();
        $gurus = UserTemporary::where('batch_id', $batchId)->where('type', 'guru')->get();
        $murids = UserTemporary::where('batch_id', $batchId)->where('type', 'murid')->get();
        $pertemuans = PertemuanTemporary::where('batch_id', $batchId)->get();

$existingHalaqahs = Halaqoh::where('batch_id', $batchId)->select('id', 'name')->get();
        $tempHalaqahs = $halaqahs;

return [
            'halaqohs' => $halaqahs->map(fn($h) => [
                'name' => $h->name,
                'method' => $h->type,
                'day_id' => $h->day_id,
                'session_id' => $h->session_id,
                'schedule' => $h->schedule_name,
                'time' => $h->time_name,
                'guru' => $h->guru_name,
                'user_id' => $h->guru_id,
                'murid' => $h->murid_count,
                'description' => $h->description,
                'level_id' => $h->level_id,
                'level' => $h->level_name,
                'id' => $h->id
            ]),
            'gurus' => $gurus->map(fn($g) => [
                'name' => $g->name,
                'email' => $g->email,
                'phone' => $g->phone,
                'gender' => $g->gender === 1 ? 'Laki-laki' : 'Perempuan',
                'halaqahs' => json_decode($g->halaqah_name) ?? [],
                'id' => $g->id
            ]),
            'murids' => $murids->map(function($m) use ($existingHalaqahs, $tempHalaqahs) {
                $metaData = is_string($m->meta) ? json_decode($m->meta, true) : ($m->meta ?? []);
                $payloadHalaqahId = $metaData['halaqah_id'] ?? null;
                $payloadHalaqahName = $m->halaqah_name;

$matchedHalaqahId = null;
                $matchedHalaqahName = $payloadHalaqahName;

// 1. Check by halaqah_id in THIS batch
                if ($payloadHalaqahId) {
                    $found = $existingHalaqahs->firstWhere('id', (int)$payloadHalaqahId);
                    if ($found) {
                        $matchedHalaqahId = $found->id;
                        $matchedHalaqahName = $found->name;
                    }
                }

// 2. If not matched by id in THIS batch, check by name in THIS batch
                if (!$matchedHalaqahId && $payloadHalaqahName) {
                    $found = $existingHalaqahs->firstWhere(fn($h) => strtolower(trim($h->name)) === strtolower(trim($payloadHalaqahName)));
                    if ($found) {
                        $matchedHalaqahId = $found->id;
                        $matchedHalaqahName = $found->name;
                    }
                }

// 3. Check temporary halaqahs for THIS batch
                if (!$matchedHalaqahId && $payloadHalaqahName) {
                    $foundTemp = $tempHalaqahs->firstWhere(fn($h) => strtolower(trim($h->name)) === strtolower(trim($payloadHalaqahName)));
                    if ($foundTemp) {
                        $matchedHalaqahId = $foundTemp->id;
                        $matchedHalaqahName = $foundTemp->name;
                    }
                }

return array_merge(
                    is_array($metaData) ? $metaData : [],
                    [
                        'name' => $m->name,
                        'email' => $m->email,
                        'phone' => $m->phone,
                        'murid_id' => $m->user_code,
                        'gender' => $m->gender === 1 ? 'Laki-laki' : 'Perempuan',
                        'tanggalLahir' => $m->birth_date,
                        'domisili' => $m->city,
                        'provinsi' => $m->province,
                        'pekerjaan' => $m->job_id,
                        'halaqah' => $matchedHalaqahName,
                        'halaqah_id' => $matchedHalaqahId,
                        'id' => $m->id
                    ]
                );
            }),
            'pertemuans' => $pertemuans->map(fn($p) => [
                'halaqah' => $p->halaqah_name,
                'nama' => $p->name,
                'tipe' => $p->type,
                'pertemuanKe' => $p->order,
                'tempat' => $p->offline_place,
                'link' => $p->online_url,
                'jadwalTanggal' => $p->schedule_date,
                'id' => $p->id
            ])
        ];
    }

public function clearTemporary(int|string $batchId)
    {
        UserTemporary::where('batch_id', $batchId)->delete();
        HalaqohTemporary::where('batch_id', $batchId)->delete();
        PertemuanTemporary::where('batch_id', $batchId)->delete();
    }

public function import(array $data, int|string $batchId)
    {
        $batch = $this->repository->find($batchId);
        if (!$batch) {
            throw new \InvalidArgumentException('Batch tidak ditemukan.');
        }

Gate::authorize('update', $batch);

return DB::transaction(function () use ($data, $batchId, $batch) {
            $now = now();
            $halaqahStartDateMap = [];
            foreach ($data['halaqohs'] ?? [] as $hData) {
                if (!empty($hData['jadwalTanggal'])) {
                    $halaqahStartDateMap[$hData['name']] = GlobalHelper::excel_to_date($hData['jadwalTanggal']);
                }
            }
            $batch->update(['status' => 1]);
            
            // Warm up master tables / memory cache
            $allDays = Day::all();
            $allSessions = Session::all();
            $allLevels = \App\Models\Level::all();
            $allExistingHalaqahs = Halaqoh::where('batch_id', $batchId)->with(['day', 'session'])->get();
            
            // Pre-hash default password to avoid CPU bottleneck in the loop
            $defaultPasswordHash = bcrypt('password123');
            
            // Collect mappings to sync later
            $halaqahGurus = []; // [halaqah_id => [user_id => pivot_data]]
            $halaqahMurids = []; // [halaqah_id => [user_id => pivot_data]]
            $halaqahPertemuans = []; // [halaqah_id => [pertemuan_data]]
            $usedHalaqohIds = [];
            $usedLevels = []; // Store unique levels mapped in this batch

// 1. Warm up existing users to optimize queries (avoiding O(N) database queries)
            $guruEmails = collect($data['gurus'] ?? [])->pluck('email')->filter()->map(fn($e) => strtolower(trim($e)))->toArray();
            $guruPhones = collect($data['gurus'] ?? [])->pluck('phone')->filter()->map(fn($p) => trim($p))->toArray();
            $muridEmails = collect($data['murids'] ?? [])->pluck('email')->filter()->map(fn($e) => strtolower(trim($e)))->toArray();
            $muridPhones = collect($data['murids'] ?? [])->pluck('phone')->filter()->map(fn($p) => trim($p))->toArray();
            $muridUserCodes = collect($data['murids'] ?? [])->pluck('murid_id')->filter()->map(fn($c) => trim($c))->toArray();

// Extract names for entries without phone/email
            $guruNamesNoContact = collect($data['gurus'] ?? [])->filter(fn($g) => empty($g['email']) && empty($g['phone']))->pluck('name')->filter()->map(fn($n) => trim($n))->toArray();
            $muridNamesNoContact = collect($data['murids'] ?? [])->filter(fn($m) => empty($m['email']) && empty($m['phone']))->pluck('name')->filter()->map(fn($n) => trim($n))->toArray();

// Generate clean phone numbers for batch matching
            $allPhones = array_merge($guruPhones, $muridPhones);
            $cleanPhones = [];
            foreach ($allPhones as $phone) {
                $clean = preg_replace('/\D/', '', $phone);
                if ($clean) {
                    $cleanPhones[] = $clean;
                    if (str_starts_with($clean, '0')) {
                        $cleanPhones[] = '62' . substr($clean, 1);
                    } elseif (str_starts_with($clean, '62')) {
                        $cleanPhones[] = '0' . substr($clean, 2);
                    } elseif (str_starts_with($clean, '8')) {
                        $cleanPhones[] = '0' . $clean;
                        $cleanPhones[] = '62' . $clean;
                    }
                }
            }
            $cleanPhones = array_values(array_unique($cleanPhones));

$allEmails = array_values(array_unique(array_merge($guruEmails, $muridEmails)));
            $allNames = array_values(array_unique(array_merge($guruNamesNoContact, $muridNamesNoContact)));
            $lowerNames = array_map('strtolower', $allNames);

$existingUsersQuery = User::query();
            $existingUsersQuery->where(function ($q) use ($allEmails, $allPhones, $cleanPhones, $allNames, $lowerNames, $muridUserCodes) {
                if (!empty($allEmails)) {
                    $q->orWhereIn(DB::raw('LOWER(email)'), $allEmails)
                      ->orWhereIn('email', $allEmails);
                }
                if (!empty($allPhones)) {
                    $q->orWhereIn('phone', $allPhones);
                }
                if (!empty($cleanPhones)) {
                    $q->orWhereIn('phone', $cleanPhones);
                }
                if (!empty($allNames)) {
                    $q->orWhereIn(DB::raw('LOWER(name)'), $lowerNames)
                      ->orWhereIn('name', $allNames);
                }
                if (!empty($muridUserCodes)) {
                    $q->orWhereIn('user_code', $muridUserCodes);
                }
            });

$existingUsers = $existingUsersQuery->get();

$existingUsersByEmail = $existingUsers->whereNotNull('email')->keyBy(fn($u) => strtolower(trim($u->email)));
            $existingUsersByPhone = $existingUsers->whereNotNull('phone')->keyBy(fn($u) => trim($u->phone));
            $existingUsersByUserCode = $existingUsers->whereNotNull('user_code')->keyBy(fn($u) => trim($u->user_code));
            $existingUsersByCleanPhone = [];
            foreach ($existingUsers as $u) {
                if ($u->phone) {
                    $clean = preg_replace('/\D/', '', $u->phone);
                    if ($clean) {
                        $existingUsersByCleanPhone[$clean] = $u;
                        if (str_starts_with($clean, '0')) {
                            $existingUsersByCleanPhone['62' . substr($clean, 1)] = $u;
                        } elseif (str_starts_with($clean, '62')) {
                            $existingUsersByCleanPhone['0' . substr($clean, 2)] = $u;
                        }
                    }
                }
            }
            $existingUsersByName = $existingUsers->keyBy(fn($u) => strtolower(trim($u->name)));

// Fetch role IDs to perform optimized roles insertion
            $guruRoleId = DB::table('roles')->whereRaw('LOWER(name) = ?', ['guru'])->value('id') ?? DB::table('roles')->where('name', 'guru')->value('id');
            $muridRoleId = DB::table('roles')->whereRaw('LOWER(name) = ?', ['murid'])->value('id') ?? DB::table('roles')->where('name', 'murid')->value('id');

// Find all existing role assignments for found users
            $foundUserIds = $existingUsers->pluck('id')->toArray();
            $existingGuruRoleAssignments = DB::table('model_has_roles')
                ->where('model_type', 'App\\Models\\User')
                ->where('role_id', $guruRoleId)
                ->whereIn('model_id', $foundUserIds)
                ->pluck('model_id')
                ->toArray();
            $existingGuruRoleAssignmentsSet = array_flip($existingGuruRoleAssignments);

$existingMuridRoleAssignments = DB::table('model_has_roles')
                ->where('model_type', 'App\\Models\\User')
                ->where('role_id', $muridRoleId)
                ->whereIn('model_id', $foundUserIds)
                ->pluck('model_id')
                ->toArray();
            $existingMuridRoleAssignmentsSet = array_flip($existingMuridRoleAssignments);

$modelHasRolesToInsert = [];
            $userMetasToInsert = [];
            $mappingsToInsert = []; // for HalaqohMappingUser

// Find existing batch mappings for this batch
            $existingBatchMappings = \App\Models\HalaqohMappingUser::where('batch_id', $batchId)
                ->get()
                ->groupBy(fn($m) => $m->user_id . '_' . $m->type);

$createdId = auth()->id() ?? auth('api')->id() ?? 1;
            $createdName = auth()->user()?->name ?? auth('api')->user()?->name ?? 'System';

// 2. Process Gurus
            $guruUsers = [];
            foreach ($data['gurus'] ?? [] as $guru) {
                $email = !empty($guru['email']) ? strtolower(trim($guru['email'])) : null;
                $phone = !empty($guru['phone']) ? trim($guru['phone']) : null;
                $name = !empty($guru['name']) ? trim($guru['name']) : null;

$user = null;
                if ($email && isset($existingUsersByEmail[$email])) {
                    $user = $existingUsersByEmail[$email];
                } elseif ($phone && isset($existingUsersByPhone[$phone])) {
                    $user = $existingUsersByPhone[$phone];
                } elseif ($phone) {
                    $cleanPhone = preg_replace('/\D/', '', $phone);
                    if (isset($existingUsersByCleanPhone[$cleanPhone])) {
                        $user = $existingUsersByCleanPhone[$cleanPhone];
                    }
                }

if (!$user && !$email && !$phone && $name) {
                    $lowerName = strtolower($name);
                    if (isset($existingUsersByName[$lowerName])) {
                        $user = $existingUsersByName[$lowerName];
                    }
                }

// Fallback DB query if not matched by in-memory map
                if (!$user && $email) {
                    $user = User::whereRaw('LOWER(email) = ?', [$email])->first();
                }
                if (!$user && $phone) {
                    $user = User::where('phone', $phone)->first();
                }

if (!$user) {
                    $gender = 2; // Default perempuan
                    if (isset($guru['gender']) && strtolower($guru['gender']) === 'laki-laki') {
                        $gender = 1;
                    }

try {
                        $user = User::create([
                            'uuid' => (string) Str::uuid(),
                            'name' => $guru['name'],
                            'email' => $guru['email'] ?? null,
                            'phone' => $guru['phone'] ?? null,
                            'gender' => $gender,
                            'password' => $defaultPasswordHash,
                            'email_verified_at' => now(),
                            'status' => 1 // active
                        ]);
                    } catch (\Illuminate\Database\QueryException $e) {
                        if ($email) {
                            $user = User::whereRaw('LOWER(email) = ?', [$email])->first();
                        }
                        if (!$user && $phone) {
                            $user = User::where('phone', $phone)->first();
                        }
                        if (!$user) {
                            throw $e;
                        }
                    }
                    
                    $modelHasRolesToInsert[] = [
                        'role_id' => $guruRoleId,
                        'model_type' => 'App\\Models\\User',
                        'model_id' => $user->id
                    ];

// Add new user to in-memory lookup cache to prevent duplicates
                    $existingUsers->push($user);
                    if ($user->email) {
                        $existingUsersByEmail[strtolower(trim($user->email))] = $user;
                    }
                    if ($user->phone) {
                        $existingUsersByPhone[trim($user->phone)] = $user;
                        $clean = preg_replace('/\D/', '', $user->phone);
                        if ($clean) {
                            $existingUsersByCleanPhone[$clean] = $user;
                            if (str_starts_with($clean, '0')) {
                                $existingUsersByCleanPhone['62' . substr($clean, 1)] = $user;
                            } elseif (str_starts_with($clean, '62')) {
                                $existingUsersByCleanPhone['0' . substr($clean, 2)] = $user;
                            }
                        }
                    }
                    $existingUsersByName[strtolower(trim($user->name))] = $user;
                } else {
                    if (!isset($existingGuruRoleAssignmentsSet[$user->id])) {
                        $modelHasRolesToInsert[] = [
                            'role_id' => $guruRoleId,
                            'model_type' => 'App\\Models\\User',
                            'model_id' => $user->id
                        ];
                        $existingGuruRoleAssignmentsSet[$user->id] = true;
                    }
                    if (empty($user->email_verified_at)) {
                        $user->update(['email_verified_at' => $now]);
                    }
                }

// Defer Keycloak account creation/sync to a background queue job
                if (!empty($user->email)) {
                    CreateKeycloakUserJob::dispatch($user->id);
                }

$guruUsers[$guru['name']] = $user->id;

// Ensure registered to this batch
                $mappingKey = $user->id . '_guru';
                if (!isset($existingBatchMappings[$mappingKey])) {
                    $mappingsToInsert[] = [
                        'batch_id' => $batchId,
                        'user_id' => $user->id,
                        'type' => 'guru',
                        'halaqah_id' => null,
                        'status' => 1,
                        'created_at' => $now,
                        'updated_at' => $now
                    ];
                } else {
                    \App\Models\HalaqohMappingUser::where('batch_id', $batchId)
                        ->where('user_id', $user->id)
                        ->where('type', 'guru')
                        ->update(['status' => 1]);
                }
            }

// 3. Process Murids
            $muridUsers = [];
            $metaKeys = [
                'kodeNegara', 'lahnJaliy', 'lahnKhafiy', 'catatan', 'pendidikanTerakhir',
                'tingkatQuranTerakhir', 'waktuTerakhirBelajarQuran', 'alasanBelajarQuran',
                'frekuensiLiveStream', 'alasanTidakIkutHits', 'setuju', 'urlRekamanTes',
                'pilihanTipeKelas', 'pilihanWaktuKelas', 'pilihanHariKelas', 'wag'
            ];
            foreach ($data['murids'] ?? [] as $murid) {
                $email = !empty($murid['email']) ? strtolower(trim($murid['email'])) : null;
                $phone = !empty($murid['phone']) ? trim($murid['phone']) : null;
                $name = !empty($murid['name']) ? trim($murid['name']) : null;
                $userCode = !empty($murid['murid_id']) ? trim($murid['murid_id']) : null;

$user = null;
                if ($userCode && isset($existingUsersByUserCode[$userCode])) {
                    $user = $existingUsersByUserCode[$userCode];
                } elseif ($email && isset($existingUsersByEmail[$email])) {
                    $user = $existingUsersByEmail[$email];
                } elseif ($phone && isset($existingUsersByPhone[$phone])) {
                    $user = $existingUsersByPhone[$phone];
                } elseif ($phone) {
                    $cleanPhone = preg_replace('/\D/', '', $phone);
                    if (isset($existingUsersByCleanPhone[$cleanPhone])) {
                        $user = $existingUsersByCleanPhone[$cleanPhone];
                    }
                }

// Fallback DB query if not matched by in-memory map
                if (!$user && $userCode) {
                    $user = User::where('user_code', $userCode)->first();
                }
                if (!$user && $email) {
                    $user = User::whereRaw('LOWER(email) = ?', [$email])->first();
                }
                if (!$user && $phone) {
                    $user = User::where('phone', $phone)->first();
                }

if (!$user) {
                    $gender = 1; // Default laki-laki for murid
                    if (isset($murid['gender']) && strtolower($murid['gender']) === 'perempuan') {
                        $gender = 2;
                    }

try {
                        $user = User::create([
                            'uuid' => (string) Str::uuid(),
                            'name' => $murid['name'],
                            'email' => $murid['email'] ?? null,
                            'phone' => $murid['phone'] ?? null,
                            'user_code' => $murid['murid_id'] ?? null,
                            'gender' => $gender,
                            'birth_date' => isset($murid['tanggalLahir']) ? GlobalHelper::excel_to_date($murid['tanggalLahir']) : null,
                            'city' => $murid['domisili'] ?? null,
                            'province' => $murid['provinsi'] ?? null,
                            'job_id' => $murid['pekerjaan'] ?? null,
                            'email_verified_at' => $now,
                            'status' => 1 // active
                        ]);
                    } catch (\Illuminate\Database\QueryException $e) {
                        if ($userCode) {
                            $user = User::where('user_code', $userCode)->first();
                        }
                        if (!$user && $email) {
                            $user = User::whereRaw('LOWER(email) = ?', [$email])->first();
                        }
                        if (!$user && $phone) {
                            $user = User::where('phone', $phone)->first();
                        }
                        if (!$user) {
                            throw $e;
                        }
                    }
                    
                    $modelHasRolesToInsert[] = [
                        'role_id' => $muridRoleId,
                        'model_type' => 'App\\Models\\User',
                        'model_id' => $user->id
                    ];

// Add new user to in-memory lookup cache to prevent duplicates
                    $existingUsers->push($user);
                    if ($user->email) {
                        $existingUsersByEmail[strtolower(trim($user->email))] = $user;
                    }
                    if ($user->phone) {
                        $existingUsersByPhone[trim($user->phone)] = $user;
                        $clean = preg_replace('/\D/', '', $user->phone);
                        if ($clean) {
                            $existingUsersByCleanPhone[$clean] = $user;
                            if (str_starts_with($clean, '0')) {
                                $existingUsersByCleanPhone['62' . substr($clean, 1)] = $user;
                            } elseif (str_starts_with($clean, '62')) {
                                $existingUsersByCleanPhone['0' . substr($clean, 2)] = $user;
                            }
                        }
                    }
                    if ($user->user_code) {
                        $existingUsersByUserCode[trim($user->user_code)] = $user;
                    }
                    $existingUsersByName[strtolower(trim($user->name))] = $user;

// Store meta data for murid in buffer
                    foreach ($metaKeys as $key) {
                        if (isset($murid[$key])) {
                            $val = $murid[$key];
                            if ($key === 'waktuTerakhirBelajarQuran') {
                                $val = GlobalHelper::excel_to_date($val);
                            }
                            if (is_array($val) || is_object($val)) {
                                $val = json_encode($val);
                            } elseif ($val !== null) {
                                $val = (string)$val;
                            }
                            
                            $userMetasToInsert[] = [
                                'user_id' => $user->id,
                                'meta_key' => $key,
                                'meta_value' => $val,
                                'created_id' => $createdId,
                                'created_name' => $createdName,
                                'updated_id' => $createdId,
                                'updated_name' => $createdName,
                                'created_at' => $now,
                                'updated_at' => $now
                            ];
                        }
                    }
                } else {
                    if (!isset($existingMuridRoleAssignmentsSet[$user->id])) {
                        $modelHasRolesToInsert[] = [
                            'role_id' => $muridRoleId,
                            'model_type' => 'App\\Models\\User',
                            'model_id' => $user->id
                        ];
                        $existingMuridRoleAssignmentsSet[$user->id] = true;
                    }
                    if (empty($user->email_verified_at)) {
                        $user->update(['email_verified_at' => $now]);
                    }
                    foreach ($metaKeys as $key) {
                        if (isset($murid[$key])) {
                            $val = $murid[$key];
                            if ($key === 'waktuTerakhirBelajarQuran') {
                                $val = GlobalHelper::excel_to_date($val);
                            }
                            if (is_array($val) || is_object($val)) {
                                $val = json_encode($val);
                            } elseif ($val !== null) {
                                $val = (string)$val;
                            }
                            
                            $userMetasToInsert[] = [
                                'user_id' => $user->id,
                                'meta_key' => $key,
                                'meta_value' => $val,
                                'created_id' => $createdId,
                                'created_name' => $createdName,
                                'updated_id' => $createdId,
                                'updated_name' => $createdName,
                                'created_at' => $now,
                                'updated_at' => $now
                            ];
                        }
                    }
                }
                if ($name) {
                    $muridUsers[$name] = $user->id;
                    $muridUsers[strtolower($name)] = $user->id;
                }
                if (!empty($murid['name'])) {
                    $muridUsers[$murid['name']] = $user->id;
                }
                if (!empty($murid['email'])) {
                    $muridUsers[strtolower(trim($murid['email']))] = $user->id;
                }
                if (!empty($murid['phone'])) {
                    $muridUsers[trim($murid['phone'])] = $user->id;
                }
                if (!empty($murid['murid_id'])) {
                    $muridUsers[trim($murid['murid_id'])] = $user->id;
                }

// Ensure registered to this batch
                $mappingKey = $user->id . '_murid';
                if (!isset($existingBatchMappings[$mappingKey])) {
                    $mappingsToInsert[] = [
                        'batch_id' => $batchId,
                        'user_id' => $user->id,
                        'type' => 'murid',
                        'halaqah_id' => null,
                        'status' => 1,
                        'created_at' => $now,
                        'updated_at' => $now
                    ];
                } else {
                    \App\Models\HalaqohMappingUser::where('batch_id', $batchId)
                        ->where('user_id', $user->id)
                        ->where('type', 'murid')
                        ->update(['status' => 1]);
                }
            }

// Bulk Insert collected roles
            if (!empty($modelHasRolesToInsert)) {
                $uniqueModelHasRoles = [];
                foreach ($modelHasRolesToInsert as $r) {
                    if (!empty($r['role_id'])) {
                        $key = $r['model_id'] . '_' . $r['role_id'];
                        $uniqueModelHasRoles[$key] = $r;
                    }
                }
                if (!empty($uniqueModelHasRoles)) {
                    foreach (array_chunk(array_values($uniqueModelHasRoles), 1000) as $chunk) {
                        DB::table('model_has_roles')->insertOrIgnore($chunk);
                    }
                }
                app(\Spatie\Permission\PermissionRegistrar::class)->forgetCachedPermissions();
            }

// Bulk Insert user metas
            if (!empty($userMetasToInsert)) {
                foreach (array_chunk($userMetasToInsert, 1000) as $chunk) {
                    \App\Models\UserMeta::insert($chunk);
                }
            }

// Bulk Insert registration mappings
            if (!empty($mappingsToInsert)) {
                foreach (array_chunk($mappingsToInsert, 1000) as $chunk) {
                    \App\Models\HalaqohMappingUser::insert($chunk);
                }
            }

// 4. Process Halaqohs
            $resolvedHalaqahs = [];
            foreach ($data['halaqohs'] ?? [] as $hData) {
                $day = null;
                if (isset($hData['day_id'])) {
                    $day = $allDays->firstWhere('id', $hData['day_id']);
                }

if (!$day) {
                    $scheduleStr = strtolower(trim($hData['schedule'] ?? ''));
                    $mappedDays = [];
                    $daysMap = ['senin' => 0, 'selasa' => 1, 'rabu' => 2, 'kamis' => 3, 'jumat' => 4, 'sabtu' => 5, 'minggu' => 6, 'ahad' => 6];
                    
                    $cleanSchedule = str_replace(' ', '', $scheduleStr);
                    
                    if ($cleanSchedule === 'setiaphari') {
                        $mappedDays = [0, 1, 2, 3, 4, 5, 6];
                    } elseif ($cleanSchedule === 'senin-jumat') {
                        $mappedDays = [0, 1, 2, 3, 4];
                    } elseif ($cleanSchedule === 'sabtu-minggu' || $cleanSchedule === 'sabtu-ahad') {
                        $mappedDays = [5, 6];
                    } else {
                        // Handle multiple days separated by &, -, or ,
                        $strClean = str_replace(['&', '-'], ',', $scheduleStr);
                        $parts = explode(',', $strClean);
                        foreach ($parts as $p) {
                            $p = trim($p);
                            if (isset($daysMap[$p])) {
                                $mappedDays[] = $daysMap[$p];
                            }
                        }
                        
                        // If it was a range (e.g. senin - rabu) and we found exactly 2 days
                        if (str_contains($scheduleStr, '-') && count($mappedDays) == 2) {
                            $start = $mappedDays[0];
                            $end = $mappedDays[1];
                            if ($start < $end) {
                                $mappedDays = range($start, $end);
                            }
                        }
                        
                        $mappedDays = array_values(array_unique($mappedDays));
                        sort($mappedDays);
                    }

if (!empty($mappedDays)) {
                        foreach ($allDays as $d) {
                            $dbDays = is_string($d->int_days) ? json_decode($d->int_days, true) : $d->int_days;
                            if (is_array($dbDays)) {
                                sort($dbDays);
                                if ($dbDays == $mappedDays) {
                                    $day = $d;
                                    break;
                                }
                            }
                        }
                    }

if (!$day) {
                        $dayName = $hData['schedule'] ?? 'Senin - Jumat';
                        $day = Day::where('name', $dayName)->first();
                        if (!$day) {
                            $day = Day::create([
                                'name' => $dayName,
                                'int_days' => $mappedDays,
                                'status' => 1
                            ]);
                            $allDays->push($day);
                        }
                    }
                }

$session = null;
                if (isset($hData['session_id'])) {
                    $session = $allSessions->firstWhere('id', $hData['session_id']);
                }

if (!$session) {
                    $timeStr = trim($hData['time'] ?? '');
                    $sStart = null;
                    $sEnd = null;
                    $sessionName = null;
                    if ($timeStr) {
                        // Normalize dots to colons and clean spaces around dash
                        $timeStrClean = str_replace('.', ':', $timeStr);
                        if (preg_match('/(\d{1,2}):(\d{2})\s*-\s*(\d{1,2}):(\d{2})/', $timeStrClean, $matches)) {
                            $sStart = str_pad($matches[1], 2, '0', STR_PAD_LEFT) . ':' . $matches[2] . ':00';
                            $sEnd = str_pad($matches[3], 2, '0', STR_PAD_LEFT) . ':' . $matches[4] . ':00';
                            $sessionName = str_pad($matches[1], 2, '0', STR_PAD_LEFT) . ':' . $matches[2] . ' - ' . str_pad($matches[3], 2, '0', STR_PAD_LEFT) . ':' . $matches[4];
                        }
                    }

if ($sStart && $sEnd) {
                        foreach ($allSessions as $s) {
                            $dbStart = date('H:i:s', strtotime($s->start_hour));
                            $dbEnd = date('H:i:s', strtotime($s->end_hour));
                            if ($dbStart === $sStart && $dbEnd === $sEnd) {
                                $session = $s;
                                break;
                            }
                        }
                    }

if (!$session) {
                        if (!$sessionName) {
                            $sessionName = $hData['time'] ?? '00:00 - 00:00';
                        }
                        $session = $allSessions->firstWhere('name', $sessionName);
                        if (!$session) {
                            $session = Session::where('name', $sessionName)->first();
                        }
                        if (!$session) {
                            $session = Session::create([
                                'name' => $sessionName,
                                'start_hour' => $sStart ?? '00:00:00',
                                'end_hour' => $sEnd ?? '00:00:00',
                                'status' => 1
                            ]);
                        }
                        // Ensure it is in the collection
                        if ($session && !$allSessions->contains('id', $session->id)) {
                            $allSessions->push($session);
                        }
                    }
                }

$level = null;
                if (!empty($hData['level_id'])) {
                    $level = $allLevels->firstWhere('id', $hData['level_id']);
                }

if (!$level && !empty($hData['level'])) {
                    $levelName = trim($hData['level']);
                    $lowerLevelName = strtolower($levelName);
                    $level = $allLevels->first(fn($l) => strtolower($l->name) === $lowerLevelName);

if (!$level) {
                        $level = \App\Models\Level::create([
                            'name' => $levelName,
                            'status' => 1,
                            'description' => ''
                        ]);
                        $allLevels->push($level);
                    }
                }

if ($level) {
                    $usedLevels[$level->id] = $level;
                }

// Deduplicate by name, batch_id, day_id, session_id (checked in memory to avoid query loop)
                $halaqoh = $allExistingHalaqahs->first(fn($h) => 
                    $h->name === $hData['name'] && 
                    $h->day_id == $day->id && 
                    $h->session_id == $session->id
                );

if (!$halaqoh) {
                    $halaqoh = Halaqoh::create([
                        'batch_id' => $batchId,
                        'name' => $hData['name'],
                        'type' => strtolower($hData['method'] ?? 'hybrid'),
                        'level_id' => $level?->id,
                        'day_id' => $day->id,
                        'session_id' => $session->id,
                        'description' => $hData['description'] ?? '',
                        'status' => 1,
                    ]);
                    $halaqoh->setRelation('day', $day);
                    $halaqoh->setRelation('session', $session);
                    $allExistingHalaqahs->push($halaqoh);
                } else {
                    $halaqoh->update([
                        'type' => strtolower($hData['method'] ?? 'hybrid'),
                        'level_id' => $level?->id,
                        'description' => $hData['description'] ?? $halaqoh->description,
                    ]);
                    $halaqoh->setRelation('day', $day);
                    $halaqoh->setRelation('session', $session);
                }
                
                if (!in_array($halaqoh->id, $usedHalaqohIds)) {
                    $usedHalaqohIds[] = $halaqoh->id;
                }

if (!empty($hData['id']) && (is_string($hData['id']) || is_numeric($hData['id']))) {
                    $resolvedHalaqahs[$hData['id']] = $halaqoh;
                }
                if (!empty($hData['name']) && (is_string($hData['name']) || is_numeric($hData['name']))) {
                    $resolvedHalaqahs[$hData['name']] = $halaqoh;
                }

// Map the assigned guru from the row
                $assignedUserId = null;
                if (isset($hData['user_id']) && (is_string($hData['user_id']) || is_numeric($hData['user_id']))) {
                    $assignedUserId = $hData['user_id'];
                } else if (!empty($hData['guru']) && is_string($hData['guru']) && isset($guruUsers[$hData['guru']])) {
                    $assignedUserId = $guruUsers[$hData['guru']];
                }

if ($assignedUserId) {
                    if (!isset($halaqahGurus[$halaqoh->id])) $halaqahGurus[$halaqoh->id] = [];
                    $halaqahGurus[$halaqoh->id][$assignedUserId] = ['batch_id' => $batchId, 'type' => 'guru', 'status' => 1];
                }
            }

// Map gurus from its own list if they have halaqahs assigned
            foreach ($data['gurus'] ?? [] as $guru) {
                $guruNameKey = !empty($guru['name']) && is_string($guru['name']) ? $guru['name'] : null;
                if (!empty($guru['halaqahs']) && is_array($guru['halaqahs']) && $guruNameKey && isset($guruUsers[$guruNameKey])) {
                    $userId = $guruUsers[$guruNameKey];
                    foreach ($guru['halaqahs'] as $hId) {
                        if (is_array($hId)) {
                            $hId = $hId['id'] ?? $hId['name'] ?? $hId[0] ?? null;
                        }
                        if (!empty($hId) && (is_string($hId) || is_numeric($hId))) {
                            $halaqoh = $resolvedHalaqahs[$hId] ?? null;
                            if ($halaqoh) {
                                if (!in_array($halaqoh->id, $usedHalaqohIds)) {
                                    $usedHalaqohIds[] = $halaqoh->id;
                                }
                                if (!isset($halaqahGurus[$halaqoh->id])) $halaqahGurus[$halaqoh->id] = [];
                                $halaqahGurus[$halaqoh->id][$userId] = ['batch_id' => $batchId, 'type' => 'guru', 'status' => 1];
                            }
                        }
                    }
                }
            }

// Map murids to their halaqahs
            foreach ($data['murids'] ?? [] as $murid) {
                $halaqoh = null;
                $hId = $murid['halaqah_id'] ?? null;
                if (is_array($hId)) {
                    $hId = $hId['id'] ?? $hId[0] ?? null;
                }
                if (!empty($hId) && (is_string($hId) || is_numeric($hId))) {
                    $halaqoh = $resolvedHalaqahs[$hId] ?? Halaqoh::where('batch_id', $batchId)->where('id', $hId)->first() ?? Halaqoh::find($hId);
                }

if (!$halaqoh) {
                    $rawH = $murid['halaqah'] ?? $murid['nama_halaqah'] ?? $murid['nama_halaqoh'] ?? null;
                    if (is_array($rawH)) {
                        $rawH = $rawH['name'] ?? $rawH['id'] ?? $rawH[0] ?? null;
                    }
                    if (!empty($rawH) && (is_string($rawH) || is_numeric($rawH))) {
                        $hName = (string)$rawH;
                        $halaqoh = $resolvedHalaqahs[$hName] ?? Halaqoh::where('batch_id', $batchId)->where('name', $hName)->first();
                        if (!$halaqoh) {
                            $lowerH = strtolower(trim($hName));
                            $halaqoh = Halaqoh::where('batch_id', $batchId)->whereRaw('LOWER(name) = ?', [$lowerH])->first();
                        }
                    }
                }

if ($halaqoh && !in_array($halaqoh->id, $usedHalaqohIds)) {
                    $usedHalaqohIds[] = $halaqoh->id;
                }

$mName = !empty($murid['name']) ? trim($murid['name']) : (!empty($murid['nama']) ? trim($murid['nama']) : null);
                if (is_array($mName)) $mName = null;

$mEmail = !empty($murid['email']) && is_string($murid['email']) ? strtolower(trim($murid['email'])) : null;
                $mPhone = !empty($murid['phone']) && (is_string($murid['phone']) || is_numeric($murid['phone'])) ? trim((string)$murid['phone']) : null;
                $mUserCode = !empty($murid['murid_id']) && (is_string($murid['murid_id']) || is_numeric($murid['murid_id'])) ? trim((string)$murid['murid_id']) : null;

$userId = null;
                if ($mName && is_string($mName) && isset($muridUsers[$mName])) {
                    $userId = $muridUsers[$mName];
                } elseif ($mName && is_string($mName) && isset($muridUsers[strtolower($mName)])) {
                    $userId = $muridUsers[strtolower($mName)];
                } elseif ($mEmail && isset($muridUsers[$mEmail])) {
                    $userId = $muridUsers[$mEmail];
                } elseif ($mPhone && isset($muridUsers[$mPhone])) {
                    $userId = $muridUsers[$mPhone];
                } elseif ($mUserCode && isset($muridUsers[$mUserCode])) {
                    $userId = $muridUsers[$mUserCode];
                }

if ($halaqoh && $userId) {
                    if (!isset($halaqahMurids[$halaqoh->id])) $halaqahMurids[$halaqoh->id] = [];
                    $halaqahMurids[$halaqoh->id][$userId] = ['batch_id' => $batchId, 'type' => 'murid', 'status' => 1];
                }
            }

// Build min order map for pertemuans
            $halaqahMinOrderMap = [];
            foreach ($data['pertemuans'] ?? [] as $pData) {
                $rawH = $pData['halaqah'] ?? '';
                if (is_array($rawH)) {
                    $rawH = $rawH['name'] ?? $rawH['id'] ?? $rawH[0] ?? '';
                }
                $hName = (is_string($rawH) || is_numeric($rawH)) ? (string)$rawH : '';
                $order = (int) ($pData['pertemuanKe'] ?? 1);
                if ($hName !== '' && (!isset($halaqahMinOrderMap[$hName]) || $order < $halaqahMinOrderMap[$hName])) {
                    $halaqahMinOrderMap[$hName] = $order;
                }
            }

// Collect Pertemuans
            foreach ($data['pertemuans'] ?? [] as $pData) {
                $rawH = $pData['halaqah'] ?? '';
                if (is_array($rawH)) {
                    $rawH = $rawH['name'] ?? $rawH['id'] ?? $rawH[0] ?? '';
                }
                $hName = (is_string($rawH) || is_numeric($rawH)) ? (string)$rawH : '';
                $halaqoh = $hName !== '' ? ($resolvedHalaqahs[$hName] ?? null) : null;
                if ($halaqoh) {
                    if (!isset($halaqahPertemuans[$halaqoh->id])) $halaqahPertemuans[$halaqoh->id] = [];
                    
                    $scheduleDate = null;
                    if (!empty($pData['jadwalTanggal'])) {
                        $scheduleDate = GlobalHelper::excel_to_date($pData['jadwalTanggal']);
                    }
                    
                    if (!$scheduleDate) {
                        $day = $halaqoh->day;
                        $intDays = [];
                        if ($day) {
                            $intDays = is_string($day->int_days) ? json_decode($day->int_days, true) : $day->int_days;
                        }
                        
                        $order = (int) ($pData['pertemuanKe'] ?? 1);
                        $hStartDate = !empty($halaqahStartDateMap[$halaqoh->name]) ? $halaqahStartDateMap[$halaqoh->name] : $batch->start_date;
                        $minOrder = $halaqahMinOrderMap[$halaqoh->name] ?? 1;
                        $calcOrder = ($order >= $minOrder && $minOrder > 1) ? ($order - $minOrder + 1) : $order;
                        $scheduleDate = $this->calculateMeetingDate($hStartDate, $intDays, $calcOrder);
                    }
                    
                    $startSession = $scheduleDate . ' 00:00:00';
                    $endSession = $scheduleDate . ' 23:59:59';
                    
                    if ($halaqoh->session) {
                        $startHour = $halaqoh->session->start_hour ?? '00:00:00';
                        $endHour = $halaqoh->session->end_hour ?? '23:59:59';
                        $startSession = $scheduleDate . ' ' . $startHour;
                        $endSession = $scheduleDate . ' ' . $endHour;
                    }

$halaqahPertemuans[$halaqoh->id][] = [
                        'batch_id' => $batchId,
                        'halaqah_id' => $halaqoh->id,
                        'name' => $pData['name'] ?? $pData['nama'] ?? 'Pertemuan',
                        'order' => $pData['pertemuanKe'] ?? 1,
                        'type' => strtolower($pData['tipe'] ?? 'offline'),
                        'schedule_date' => $scheduleDate, 
                        'start_session_date' => $startSession, 
                        'end_session_date' => $endSession, 
                        'online_url' => $pData['link'] ?? null,
                        'offline_place' => $pData['tempat'] ?? null,
                    ];
                }
            }

$hasHalaqahsInPayload = isset($data['halaqohs']) && is_array($data['halaqohs']) && !empty($data['halaqohs']);
            $hasGurusInPayload = isset($data['gurus']) && is_array($data['gurus']) && !empty($data['gurus']);
            $hasMuridsInPayload = isset($data['murids']) && is_array($data['murids']) && !empty($data['murids']);
            $hasPertemuansInPayload = isset($data['pertemuans']) && is_array($data['pertemuans']) && !empty($data['pertemuans']);

// Delete halaqahs only on full batch creation import (when all sections are provided)
            if ($hasHalaqahsInPayload && $hasPertemuansInPayload && $hasGurusInPayload && !empty($usedHalaqohIds)) {
                $toDeleteHalaqahs = Halaqoh::where('batch_id', $batchId)->whereNotIn('id', $usedHalaqohIds)->get();
                foreach ($toDeleteHalaqahs as $h) {
                    $h->users()->detach();
                    $h->delete();
                }
            }

// Sync Halaqah-Guru mappings ONLY if guru mappings were explicitly resolved in payload
            if (!empty($halaqahGurus)) {
                $targetGuruHalaqahIds = array_keys($halaqahGurus);
                \App\Models\HalaqohMappingUser::where('batch_id', $batchId)
                    ->where('type', 'guru')
                    ->whereIn('halaqah_id', $targetGuruHalaqahIds)
                    ->delete();

$pivotGuruMappings = [];
                foreach ($halaqahGurus as $hId => $users) {
                    foreach ($users as $userId => $pivotData) {
                        $pivotGuruMappings[] = [
                            'batch_id'   => $batchId,
                            'halaqah_id' => $hId,
                            'user_id'    => $userId,
                            'type'       => 'guru',
                            'status'     => $pivotData['status'] ?? 1,
                            'reason'     => $pivotData['reason'] ?? null,
                            'created_at' => $now,
                            'updated_at' => $now
                        ];
                    }
                }
                if (!empty($pivotGuruMappings)) {
                    foreach (array_chunk($pivotGuruMappings, 1000) as $chunk) {
                        \App\Models\HalaqohMappingUser::insert($chunk);
                    }
                }
            }

// Sync Halaqah-Murid mappings ONLY if murid halaqah mappings were resolved!
            if (!empty($halaqahMurids)) {
                $targetMuridHalaqahIds = array_keys($halaqahMurids);
                \App\Models\HalaqohMappingUser::where('batch_id', $batchId)
                    ->where('type', 'murid')
                    ->whereIn('halaqah_id', $targetMuridHalaqahIds)
                    ->delete();

$pivotMuridMappings = [];
                foreach ($halaqahMurids as $hId => $users) {
                    foreach ($users as $userId => $pivotData) {
                        $pivotMuridMappings[] = [
                            'batch_id'   => $batchId,
                            'halaqah_id' => $hId,
                            'user_id'    => $userId,
                            'type'       => 'murid',
                            'status'     => $pivotData['status'] ?? 1,
                            'reason'     => $pivotData['reason'] ?? null,
                            'created_at' => $now,
                            'updated_at' => $now
                        ];
                    }
                }
                if (!empty($pivotMuridMappings)) {
                    foreach (array_chunk($pivotMuridMappings, 1000) as $chunk) {
                        \App\Models\HalaqohMappingUser::insert($chunk);
                    }
                }
            }

// Sync Pertemuans in bulk ONLY if pertemuans were sent in the upload payload!
            if ($hasPertemuansInPayload) {
                // Warm up existing pertemuans for this batch to do O(1) matching in memory
                $existingPertemuans = \App\Models\HalaqohMappingPertemuan::where('batch_id', $batchId)
                    ->get()
                    ->groupBy(fn($p) => $p->halaqah_id . '_' . $p->order);

$uploadedPertemuanKeys = [];
                $pertemuansToInsert = [];
                $pertemuansToUpdate = [];

$allBatchHalaqahs = Halaqoh::where('batch_id', $batchId)->get();
                foreach ($allBatchHalaqahs as $halaqoh) {
                    $newPertemuans = $halaqahPertemuans[$halaqoh->id] ?? [];
                    
                    $guruId = null;
                    if (!empty($halaqahGurus[$halaqoh->id])) {
                        $guruId = array_key_first($halaqahGurus[$halaqoh->id]);
                    }
                    if (!$guruId) {
                        $guruId = auth()->id() ?? auth('api')->id() ?? User::first()?->id ?? 1;
                    }
                    
                    foreach ($newPertemuans as $pFields) {
                        $pFields['guru_id'] = $guruId;
                        
                        $key = $halaqoh->id . '_' . $pFields['order'];
                        $uploadedPertemuanKeys[$key] = true;
                        
                        $existing = isset($existingPertemuans[$key]) ? $existingPertemuans[$key]->first() : null;
                        
                        if ($existing) {
                            $needsUpdate = false;
                            $updateFields = [];
                            foreach ($pFields as $field => $val) {
                                if ($existing->$field != $val) {
                                    $needsUpdate = true;
                                    $updateFields[$field] = $val;
                                }
                            }
                            if ($needsUpdate) {
                                $pertemuansToUpdate[$existing->id] = $updateFields;
                            }
                        } else {
                            $pertemuansToInsert[] = array_merge($pFields, [
                                'created_at' => $now,
                                'updated_at' => $now
                            ]);
                        }
                    }
                }

// Delete removed pertemuans only when pertemuans were sent in the upload
                $idsToDelete = [];
                foreach ($existingPertemuans as $key => $group) {
                    if (!isset($uploadedPertemuanKeys[$key])) {
                        foreach ($group as $p) {
                            $idsToDelete[] = $p->id;
                        }
                    }
                }

if (!empty($idsToDelete)) {
                    \App\Models\HalaqohMappingPertemuan::whereIn('id', $idsToDelete)->delete();
                }

// Bulk insert new pertemuans
                if (!empty($pertemuansToInsert)) {
                    foreach (array_chunk($pertemuansToInsert, 1000) as $chunk) {
                        \App\Models\HalaqohMappingPertemuan::insert($chunk);
                    }
                }

// Update modified pertemuans
                foreach ($pertemuansToUpdate as $id => $fields) {
                    \App\Models\HalaqohMappingPertemuan::where('id', $id)->update($fields);
                }
            }

// Sync Batch Level Moduls if levels were updated
            if (!empty($usedLevels)) {
                \App\Models\BatchLevelModul::where('batch_id', $batchId)->delete();
                
                $batchLevelModulRecords = [];
                $usedLevelIds = array_keys($usedLevels);
                $allModulMappings = \App\Models\LevelMappingModule::whereIn('level_id', $usedLevelIds)->get()->groupBy('level_id');
                
                foreach ($usedLevels as $lvl) {
                    $modulMappings = $allModulMappings->get($lvl->id, collect());
                    
                    if ($modulMappings->isEmpty()) {
                        $batchLevelModulRecords[] = [
                            'batch_id' => $batchId,
                            'level_id' => $lvl->id,
                            'level_name' => $lvl->name,
                            'modul_id' => null,
                            'created_at' => $now,
                            'updated_at' => $now,
                        ];
                    } else {
                        foreach ($modulMappings as $mapping) {
                            $batchLevelModulRecords[] = [
                                'batch_id' => $batchId,
                                'level_id' => $lvl->id,
                                'level_name' => $lvl->name,
                                'modul_id' => $mapping->modul_id,
                                'created_at' => $now,
                                'updated_at' => $now,
                            ];
                        }
                    }
                }
                
                if (!empty($batchLevelModulRecords)) {
                    \App\Models\BatchLevelModul::insert($batchLevelModulRecords);
                }
            }

// Clear temporary data
            $this->clearTemporary($batchId);

return true;
        });
    }

public function calculateMeetingDate($batchStartDateStr, array $intDays, int $order)
    {
        $startDateStr = !empty($batchStartDateStr) ? $batchStartDateStr : now()->format('Y-m-d');
        
        if (empty($intDays)) {
            try {
                $startDate = \Carbon\Carbon::parse($startDateStr);
            } catch (\Exception $e) {
                $startDate = \Carbon\Carbon::now();
            }
            return $startDate->addWeeks($order - 1)->format('Y-m-d');
        }
        
        sort($intDays);
        $cacheKey = $startDateStr . '_' . implode(',', $intDays);
        
        if (isset($this->meetingDateCache[$cacheKey][$order])) {
            return $this->meetingDateCache[$cacheKey][$order];
        }
        
        $lastOrder = 0;
        $currentDateStr = null;
        if (isset($this->meetingDateCache[$cacheKey])) {
            $calculatedOrders = array_keys($this->meetingDateCache[$cacheKey]);
            if (!empty($calculatedOrders)) {
                $lastOrder = max($calculatedOrders);
                $currentDateStr = $this->meetingDateCache[$cacheKey][$lastOrder];
            }
        }
        
        try {
            if ($lastOrder > 0 && $currentDateStr) {
                $currentDate = \Carbon\Carbon::parse($currentDateStr)->addDay();
            } else {
                $currentDate = \Carbon\Carbon::parse($startDateStr);
            }
        } catch (\Exception $e) {
            $currentDate = \Carbon\Carbon::now();
        }
        
        $carbonDays = array_map(function($d) {
            return $d === 6 ? 0 : $d + 1;
        }, $intDays);
        
        $matchesCount = $lastOrder;
        
        for ($i = 0; $i < 1000; $i++) {
            $dayOfWeek = $currentDate->dayOfWeek;
            if (in_array($dayOfWeek, $carbonDays)) {
                $matchesCount++;
                $this->meetingDateCache[$cacheKey][$matchesCount] = $currentDate->format('Y-m-d');
                if ($matchesCount === $order) {
                    return $this->meetingDateCache[$cacheKey][$order];
                }
            }
            $currentDate->addDay();
        }
        
        return $this->meetingDateCache[$cacheKey][$order] ?? $startDateStr;
    }

public function destroyTemporary($batchId)
    {
        $cacheKey = 'batch_temporary_import_' . $batchId;
        \Illuminate\Support\Facades\Cache::forget($cacheKey);
        return true;
    }
}

cancel

Admin

editing: BatchService.php

Deskripsi Program

Informasi Donatur

Gerakan Sehat Bermanfaat

Terkumpul

Target

Tentukan Nominal Sedekahmu

Gerakan Sehat Bermanfaat

⁠Masukkan Nominal Sedekah *

Terkumpul

Target