root
307 lines
11 KiB
PHP
307 lines
11 KiB
PHP
<?php
|
||
|
||
namespace App\Database\Seeds;
|
||
|
||
use CodeIgniter\Database\Seeder;
|
||
use CodeIgniter\Database\BaseConnection;
|
||
|
||
class FamiliesRebuildSeeder extends Seeder
|
||
{
|
||
/** @var BaseConnection */
|
||
protected $db;
|
||
|
||
/** Legacy parents table mapping (fits your schema exactly) */
|
||
protected array $legacy = [
|
||
'table' => 'parents',
|
||
'firstparent_id' => 'firstparent_id', // users.id of primary parent
|
||
'second_user_id' => 'secondparent_id', // users.id of 2nd parent (may be 0)
|
||
'second_email' => 'secondparent_email',
|
||
'second_firstname' => 'secondparent_firstname',
|
||
'second_lastname' => 'secondparent_lastname',
|
||
];
|
||
|
||
/** Defaults for prefs rows per category (your schema) */
|
||
protected array $prefsDefaults = [
|
||
// category => [via_email, via_sms, cc_all_guardians]
|
||
'attendance' => [1, 0, 1],
|
||
'grade' => [1, 0, 1],
|
||
'behavior' => [1, 0, 1],
|
||
'general' => [1, 0, 1],
|
||
];
|
||
|
||
public function run()
|
||
{
|
||
$this->db = \Config\Database::connect();
|
||
$this->db->transStrict(false); // don't auto-rollback the entire txn on one failure
|
||
$this->db->transException(false); // don't throw (so we can print errors ourselves)
|
||
|
||
// Start a transaction so the DB stays consistent; we'll print status after.
|
||
$this->db->transStart();
|
||
|
||
[$familiesCreated, $studentLinks] = $this->ensureFamiliesAndLinks();
|
||
$primaryLinked = $this->linkPrimaryGuardians();
|
||
[$stubUsers, $secondaryLinked] = $this->importSecondaryGuardiansFromParents();
|
||
$prefsUpserts = $this->seedFamilyCommPrefsPerCategory();
|
||
|
||
$this->db->transComplete();
|
||
|
||
echo PHP_EOL;
|
||
$status = $this->db->transStatus();
|
||
echo $status ? "[TXN] Transaction COMMITTED.\n" : "[TXN] Transaction FAILED.\n";
|
||
if (! $status) {
|
||
$err = $this->db->error();
|
||
echo " DB error: " . ($err['message'] ?? 'unknown') . " (code " . ($err['code'] ?? 'n/a') . ")\n";
|
||
}
|
||
echo "Families created: {$familiesCreated}\n";
|
||
echo "family_students links inserted: {$studentLinks}\n";
|
||
echo "Primary guardians linked: {$primaryLinked}\n";
|
||
echo "Stub users created (secondary): {$stubUsers}\n";
|
||
echo "Secondary guardians linked: {$secondaryLinked}\n";
|
||
echo "family_comm_prefs upserts: {$prefsUpserts}\n";
|
||
echo PHP_EOL;
|
||
}
|
||
|
||
|
||
protected function exec(string $label, string $sql): int
|
||
{
|
||
$ok = $this->db->query($sql);
|
||
if (! $ok) {
|
||
$err = $this->db->error();
|
||
echo "[ERROR] {$label}: " . ($err['message'] ?? 'unknown') . " (code " . ($err['code'] ?? 'n/a') . ")\n";
|
||
return 0;
|
||
}
|
||
$n = (int) $this->db->affectedRows();
|
||
echo "[OK] {$label}: affectedRows={$n}\n";
|
||
return $n;
|
||
}
|
||
|
||
/**
|
||
* Create families from students where parent_id maps to a real users.id,
|
||
* then link all students to their family's id.
|
||
*/
|
||
protected function ensureFamiliesAndLinks(): array
|
||
{
|
||
$familiesCreated = $this->exec(
|
||
'families insert',
|
||
"
|
||
INSERT IGNORE INTO families (family_code, household_name, is_active, created_at, updated_at)
|
||
SELECT DISTINCT
|
||
CONCAT('FAM-', s.parent_id),
|
||
CONCAT('Family of User ', s.parent_id),
|
||
1, NOW(), NOW()
|
||
FROM students s
|
||
JOIN users u ON u.id = s.parent_id
|
||
WHERE s.parent_id IS NOT NULL
|
||
"
|
||
);
|
||
|
||
$studentLinks = $this->exec(
|
||
'family_students insert',
|
||
"
|
||
INSERT IGNORE INTO family_students (family_id, student_id, is_primary_home)
|
||
SELECT f.id, s.id, 1
|
||
FROM students s
|
||
JOIN users u ON u.id = s.parent_id
|
||
JOIN families f ON f.family_code = CONCAT('FAM-', s.parent_id)
|
||
"
|
||
);
|
||
|
||
// Backfill addresses/phone/household_name from users if empty
|
||
$this->exec(
|
||
'families backfill address/phone/name',
|
||
"
|
||
UPDATE families f
|
||
JOIN users u ON u.id = CAST(SUBSTRING(f.family_code, 5) AS UNSIGNED)
|
||
SET
|
||
f.address_line1 = COALESCE(NULLIF(f.address_line1, ''), NULLIF(u.address_street, '')),
|
||
f.city = COALESCE(NULLIF(f.city, ''), NULLIF(u.city, '')),
|
||
f.state = COALESCE(NULLIF(f.state, ''), NULLIF(u.state, '')),
|
||
f.postal_code = COALESCE(NULLIF(f.postal_code, ''), NULLIF(u.zip, '')),
|
||
f.primary_phone = COALESCE(NULLIF(f.primary_phone, ''), NULLIF(u.cellphone, '')),
|
||
f.household_name= CASE
|
||
WHEN f.household_name IS NULL OR f.household_name = ''
|
||
THEN TRIM(CONCAT('Family of ', NULLIF(u.firstname, ''), ' ', NULLIF(u.lastname, '')))
|
||
ELSE f.household_name
|
||
END
|
||
"
|
||
);
|
||
|
||
return [$familiesCreated, $studentLinks];
|
||
}
|
||
|
||
|
||
|
||
/**
|
||
* Link primary guardians using student-anchored joins (no family_code parsing assumptions).
|
||
* relation uses a safe generic 'guardian' (fits varchar(32) and common enums).
|
||
*/
|
||
protected function linkPrimaryGuardians(): int
|
||
{
|
||
// Log candidate count (already printed earlier for you)
|
||
$row = $this->db->query("
|
||
SELECT COUNT(*) AS c FROM (
|
||
SELECT DISTINCT fs.family_id, u.id AS user_id
|
||
FROM family_students fs
|
||
JOIN students s ON s.id = fs.student_id
|
||
JOIN users u ON u.id = s.parent_id
|
||
WHERE s.parent_id IS NOT NULL
|
||
) X
|
||
")->getRowArray();
|
||
echo "[DEBUG] Primary guardian candidates (via students): " . (int)($row['c'] ?? 0) . "\n";
|
||
|
||
// Path A: student-anchored (ignore duplicates/violations)
|
||
$linkedA = $this->exec(
|
||
'primary guardians insert A (student-anchored, IGNORE)',
|
||
"
|
||
INSERT IGNORE INTO family_guardians
|
||
(family_id, user_id, relation, is_primary, receive_emails, receive_sms)
|
||
SELECT DISTINCT
|
||
fs.family_id,
|
||
u.id,
|
||
'guardian', 1, 1, 0
|
||
FROM family_students fs
|
||
JOIN students s ON s.id = fs.student_id
|
||
JOIN users u ON u.id = s.parent_id
|
||
WHERE s.parent_id IS NOT NULL
|
||
"
|
||
);
|
||
|
||
// Path B: via family_code (belt & suspenders)
|
||
$linkedB = $this->exec(
|
||
'primary guardians insert B (family_code, IGNORE)',
|
||
"
|
||
INSERT IGNORE INTO family_guardians
|
||
(family_id, user_id, relation, is_primary, receive_emails, receive_sms)
|
||
SELECT f.id, u.id, 'guardian', 1, 1, 0
|
||
FROM families f
|
||
JOIN users u ON u.id = CAST(SUBSTRING(f.family_code, 5) AS UNSIGNED)
|
||
"
|
||
);
|
||
|
||
return $linkedA + $linkedB;
|
||
}
|
||
|
||
/**
|
||
* Create/link secondary guardians from legacy parents:
|
||
* - Create stub users for secondparent_email not present in users.
|
||
* - Link those (or explicit secondparent_id) to all families of the first parent’s students.
|
||
*/
|
||
protected function importSecondaryGuardiansFromParents(): array
|
||
{
|
||
$L = $this->legacy;
|
||
|
||
if (! $this->db->tableExists($L['table'])) {
|
||
echo "[LEGACY] Table '{$L['table']}' not found; skipping secondary import.\n";
|
||
return [0, 0];
|
||
}
|
||
|
||
$fields = array_map('strtolower', array_column($this->db->getFieldData($L['table']), 'name'));
|
||
foreach (['firstparent_id','second_user_id','second_email','second_firstname','second_lastname'] as $k) {
|
||
$col = strtolower($L[$k]);
|
||
if (! in_array($col, $fields, true)) {
|
||
echo "[LEGACY] Missing column {$L[$k]} in {$L['table']}; skipping secondary import.\n";
|
||
return [0, 0];
|
||
}
|
||
}
|
||
|
||
$stubUsers = $this->exec(
|
||
'secondary guardian stubs (users)',
|
||
"
|
||
INSERT INTO users
|
||
(firstname, lastname, email, cellphone, address_street, apt, city, state, zip,
|
||
accept_school_policy, is_verified, status, is_suspended, failed_attempts,
|
||
password, created_at, updated_at, token, account_id, user_type, semester,
|
||
school_year, rfid_tag, last_failed_at)
|
||
SELECT
|
||
NULLIF(p.{$L['second_firstname']},''),
|
||
NULLIF(p.{$L['second_lastname']},''),
|
||
p.{$L['second_email']},
|
||
'', '', NULL, '', '', '',
|
||
0, 0, 'Active', 0, 0,
|
||
'$2y$10abcdefghijklmnopqrstuv',
|
||
NOW(), NOW(), NULL, NULL, 'secondary',
|
||
'', NULL, NULL, NULL
|
||
FROM {$L['table']} p
|
||
LEFT JOIN users u ON u.email = p.{$L['second_email']}
|
||
WHERE p.{$L['second_email']} IS NOT NULL
|
||
AND p.{$L['second_email']} <> ''
|
||
AND u.id IS NULL
|
||
"
|
||
);
|
||
|
||
$secondaryLinked = $this->exec(
|
||
'secondary guardians insert (IGNORE)',
|
||
"
|
||
INSERT IGNORE INTO family_guardians
|
||
(family_id, user_id, relation, is_primary, receive_emails, receive_sms)
|
||
SELECT DISTINCT
|
||
fs.family_id,
|
||
COALESCE(u2.id, u_email.id) AS user_id,
|
||
'guardian', 0, 1, 0
|
||
FROM {$L['table']} p
|
||
JOIN students s
|
||
ON s.parent_id = p.{$L['firstparent_id']}
|
||
OR s.parent_id = p.id
|
||
JOIN family_students fs ON fs.student_id = s.id
|
||
LEFT JOIN users u2 ON u2.id = NULLIF(p.{$L['second_user_id']}, 0)
|
||
LEFT JOIN users u_email ON u_email.email = p.{$L['second_email']}
|
||
WHERE p.{$L['second_email']} IS NOT NULL
|
||
AND p.{$L['second_email']} <> ''
|
||
AND COALESCE(u2.id, u_email.id) IS NOT NULL
|
||
"
|
||
);
|
||
|
||
return [$stubUsers, $secondaryLinked];
|
||
}
|
||
|
||
|
||
/**
|
||
* Seed one prefs row per (family_id, category) with your defaults.
|
||
* Counts how many rows were *actually inserted* across all categories.
|
||
*/
|
||
protected function seedFamilyCommPrefsPerCategory(): int
|
||
{
|
||
if (! $this->db->tableExists('family_comm_prefs')) {
|
||
echo "[INFO] family_comm_prefs not found; skipping prefs seed.\n";
|
||
return 0;
|
||
}
|
||
|
||
$insertedTotal = 0;
|
||
|
||
foreach ($this->prefsDefaults as $category => [$viaEmail, $viaSms, $ccAll]) {
|
||
// Count how many families are missing this category BEFORE
|
||
$row = $this->db->query("
|
||
SELECT COUNT(*) AS c
|
||
FROM families f
|
||
LEFT JOIN family_comm_prefs p
|
||
ON p.family_id = f.id AND p.category = ?
|
||
WHERE p.family_id IS NULL
|
||
", [$category])->getRowArray();
|
||
$missing = (int)($row['c'] ?? 0);
|
||
|
||
if ($missing > 0) {
|
||
$this->db->query("
|
||
INSERT INTO family_comm_prefs (family_id, category, via_email, via_sms, cc_all_guardians)
|
||
SELECT f.id, ?, ?, ?, ?
|
||
FROM families f
|
||
LEFT JOIN family_comm_prefs p
|
||
ON p.family_id = f.id AND p.category = ?
|
||
WHERE p.family_id IS NULL
|
||
", [$category, (int)$viaEmail, (int)$viaSms, (int)$ccAll, $category]);
|
||
|
||
$insertedTotal += $missing;
|
||
}
|
||
}
|
||
|
||
return $insertedTotal;
|
||
}
|
||
|
||
/** Utility: check if a column exists (case-insensitive) */
|
||
protected function columnExists(string $table, string $column): bool
|
||
{
|
||
if (! $this->db->tableExists($table)) return false;
|
||
$cols = array_map('strtolower', array_column($this->db->getFieldData($table), 'name'));
|
||
return in_array(strtolower($column), $cols, true);
|
||
}
|
||
}
|