recreate project
This commit is contained in:
root
@@ -0,0 +1,306 @@
|
||||
<?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);
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user