Find email duplicates API

src/api/index.php

@@ -71,6 +71,7 @@
 
 require __DIR__.'/routes/dashboard.php';
 
+require __DIR__.'/routes/email.php';
 require __DIR__.'/routes/geocoder.php';
 
 require __DIR__.'/routes/public.php';

src/api/routes/email.php

@@ -0,0 +1,50 @@
+<?php
+
+use Propel\Runtime\Propel;
+use ChurchCRM\PersonQuery;
+use ChurchCRM\FamilyQuery;
+use Slim\Http\Request;
+use Slim\Http\Response;
+
+$app->group('/emails', function () {
+    $this->get('/duplicates', 'getEmailDupes');
+});
+
+
+/**
+ * A method that review dup emails in the db and returns families and people where that email is used.
+ *
+ * @param \Slim\Http\Request $p_request The request.
+ * @param \Slim\Http\Response $p_response The response.
+ * @param array $p_args Arguments
+ * @return \Slim\Http\Response The augmented response.
+ */
+function getEmailDupes(Request $request, Response $response, array $p_args)
+{
+    $connection = Propel::getConnection();
+    $dupEmailsSQL = "select email from emails_duplicate;";
+    $statement = $connection->prepare($dupEmailsSQL);
+    $statement->execute();
+    $dupEmails = $statement->fetchAll();
+
+    $emails = [];
+    foreach ($dupEmails as $dbEmail) {
+        $email = $dbEmail['email'];
+        $dbPeople = PersonQuery::create()->filterByEmail($email)->_or()->filterByWorkEmail($email)->find();
+        $people = [];
+        foreach ($dbPeople as $person) {
+            array_push($people, ["id" => $person->getId(), "name" => $person->getFullName()]);
+        }
+        $families = [];
+        $dbFamilies = FamilyQuery::create()->findByEmail($email);
+        foreach ($dbFamilies as $family) {
+            array_push($families, ["id" => $family->getId(), "nane" => $family->getName()]);
+        }
+        $emails[$email] = [
+            "people" => $people,
+            "families" => $families
+        ];
+    }
+
+    return $response->withJson($emails);
+}

src/mysql/upgrade/2.10.0-email-dup.sql

@@ -0,0 +1,29 @@
+CREATE VIEW emails_duplicate AS
+    SELECT
+        email, total
+    FROM
+        (SELECT
+            email, COUNT(*) AS total
+        FROM
+            (SELECT
+            fam_Email AS email, 'family' AS type, fam_id AS id
+        FROM
+            family_fam
+        WHERE
+            fam_email IS NOT NULL
+                AND fam_email != '' UNION SELECT
+            per_email AS email, 'person_home' AS type, per_id AS id
+        FROM
+            person_per
+        WHERE
+            per_email IS NOT NULL
+                AND per_email != '' UNION SELECT
+            per_WorkEmail AS email, 'person_work' AS type, per_id AS id
+        FROM
+            person_per
+        WHERE
+            per_WorkEmail IS NOT NULL
+                AND per_WorkEmail != '') emails
+        GROUP BY email) AS emailTotals
+    WHERE
+        total > 1