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, total FROM email_count where total > 1";
+    $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/install/Install.sql

@@ -1321,4 +1321,14 @@ CREATE TABLE `church_location_role` (
   PRIMARY KEY (`location_id`, `role_id`)
 ) ENGINE=InnoDB CHARACTER SET utf8 COLLATE utf8_unicode_ci;
 
+CREATE VIEW email_list AS
+    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 != '';
+
+CREATE VIEW email_count AS    
+    SELECT email, COUNT(*) AS total FROM email_list group by email;
+
 update version_ver set ver_update_end = now();

src/mysql/upgrade.json

@@ -166,7 +166,8 @@
             "2.9.3",
             "2.9.4"
         ],
-        "scripts": [],
+        "scripts": [
+            "/mysql/upgrade/2.10.0-email-dup.sql"],
         "dbVersion": "2.10.0"
     }
 }

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

@@ -0,0 +1,13 @@
+
+DROP VIEW email_list;
+CREATE VIEW email_list AS
+    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 != '';
+
+
+DROP VIEW email_count;    
+CREATE VIEW email_count AS    
+    SELECT email, COUNT(*) AS total FROM email_list group by email;