Improve address deduplication and delete matching duplicates

- list.cfm: Use GROUP BY to show unique addresses only, removed
  BusinessID filter, simplified aggregation for better MySQL compat
- delete.cfm: Delete ALL addresses matching the same address content
  (Line1, Line2, City, State, ZIP) to keep data clean when user
  deletes a deduplicated address

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
This commit is contained in:
John Mizerek 2026-01-14 23:11:28 -08:00
parent b069290862
commit 261bab2bb6
2 changed files with 202 additions and 151 deletions

View file

@ -1,9 +1,26 @@
<cfsetting showdebugoutput="false"> <cfsetting showdebugoutput="false">
<cfsetting enablecfoutputonly="true"> <cfsetting enablecfoutputonly="true">
<cfcontent type="application/json; charset=utf-8"> <cfcontent type="application/json; charset=utf-8" reset="true">
<cfheader name="Cache-Control" value="no-store">
<!--- Soft-delete a delivery address for the authenticated user --->
<cfscript> <cfscript>
function apiAbort(required struct payload) {
writeOutput(serializeJSON(payload));
abort;
}
function getHeader(name) {
try {
req = getPageContext().getRequest();
val = req.getHeader(arguments.name);
if (!isNull(val)) return trim(val);
} catch (any e) {
k = "HTTP_" & ucase(reReplace(arguments.name, "[^A-Za-z0-9]", "_", "all"));
if (structKeyExists(cgi, k)) return trim(cgi[k]);
}
return "";
}
function readJsonBody() { function readJsonBody() {
var raw = getHttpRequestData().content; var raw = getHttpRequestData().content;
if (isNull(raw) || len(trim(toString(raw))) == 0) return {}; if (isNull(raw) || len(trim(toString(raw))) == 0) return {};
@ -15,78 +32,83 @@ function readJsonBody() {
} }
} }
// Get authenticated user
userId = 0;
if (structKeyExists(request, "UserID") && isNumeric(request.UserID) && request.UserID > 0) {
userId = request.UserID;
} else {
userToken = getHeader("X-User-Token");
if (len(userToken)) {
try { try {
userId = request.UserID ?: 0; qTok = queryExecute(
"SELECT UserID FROM UserTokens WHERE Token = ? LIMIT 1",
[{ value = userToken, cfsqltype = "cf_sql_varchar" }],
{ datasource = "payfrit" }
);
if (qTok.recordCount EQ 1) {
userId = qTok.UserID;
}
} catch (any e) {}
}
}
if (userId <= 0) { if (userId <= 0) {
writeOutput(serializeJSON({ apiAbort({ "OK": false, "ERROR": "not_logged_in", "MESSAGE": "Authentication required" });
"OK": false,
"ERROR": "unauthorized",
"MESSAGE": "Authentication required"
}));
abort;
} }
// Get address ID from URL, form, or JSON body
addressId = 0;
if (structKeyExists(url, "id") && isNumeric(url.id)) {
addressId = val(url.id);
} else if (structKeyExists(form, "addressId") && isNumeric(form.addressId)) {
addressId = val(form.addressId);
} else {
data = readJsonBody(); data = readJsonBody();
addressId = val(data.AddressID ?: 0); if (structKeyExists(data, "AddressID") && isNumeric(data.AddressID)) {
addressId = val(data.AddressID);
}
}
if (addressId <= 0) { if (addressId <= 0) {
writeOutput(serializeJSON({ apiAbort({ "OK": false, "ERROR": "invalid_id", "MESSAGE": "Address ID required" });
"OK": false,
"ERROR": "missing_field",
"MESSAGE": "AddressID is required"
}));
abort;
} }
// Verify address belongs to user try {
qCheck = queryExecute(" // First, get the address details so we can find all matching duplicates
SELECT AddressID, AddressIsDefaultDelivery qAddr = queryExecute("
SELECT AddressLine1, AddressLine2, AddressCity, AddressStateID, AddressZIPCode
FROM Addresses FROM Addresses
WHERE AddressID = :addressId WHERE AddressID = :addressId
AND AddressUserID = :userId AND AddressUserID = :userId
AND AddressIsDeleted = 0 AND AddressIsDeleted = 0
", { ", {
addressId: { value: addressId, cfsqltype: "cf_sql_integer" }, addressId: { value = addressId, cfsqltype = "cf_sql_integer" },
userId: { value: userId, cfsqltype: "cf_sql_integer" } userId: { value = userId, cfsqltype = "cf_sql_integer" }
}, { datasource: "payfrit" }); });
if (qCheck.recordCount == 0) { if (qAddr.recordCount EQ 0) {
writeOutput(serializeJSON({ apiAbort({ "OK": false, "ERROR": "not_found", "MESSAGE": "Address not found" });
"OK": false,
"ERROR": "not_found",
"MESSAGE": "Address not found"
}));
abort;
} }
wasDefault = qCheck.AddressIsDefaultDelivery == 1; // Soft-delete ALL addresses that match the same Line1, Line2, City, StateID, ZIPCode
qDelete = queryExecute("
// Soft delete the address
queryExecute("
UPDATE Addresses UPDATE Addresses
SET AddressIsDeleted = 1, SET AddressIsDeleted = 1
AddressIsDefaultDelivery = 0
WHERE AddressID = :addressId
", {
addressId: { value: addressId, cfsqltype: "cf_sql_integer" }
}, { datasource: "payfrit" });
// If this was the default, set another one as default
if (wasDefault) {
queryExecute("
UPDATE Addresses
SET AddressIsDefaultDelivery = 1
WHERE AddressUserID = :userId WHERE AddressUserID = :userId
AND (AddressBusinessID = 0 OR AddressBusinessID IS NULL) AND AddressLine1 = :line1
AND AddressTypeID LIKE '%2%' AND AddressLine2 = :line2
AND AddressCity = :city
AND AddressStateID = :stateId
AND AddressZIPCode = :zip
AND AddressIsDeleted = 0 AND AddressIsDeleted = 0
ORDER BY AddressID DESC
LIMIT 1
", { ", {
userId: { value: userId, cfsqltype: "cf_sql_integer" } userId: { value = userId, cfsqltype = "cf_sql_integer" },
}, { datasource: "payfrit" }); line1: { value = qAddr.AddressLine1, cfsqltype = "cf_sql_varchar", null = !len(qAddr.AddressLine1) },
} line2: { value = qAddr.AddressLine2, cfsqltype = "cf_sql_varchar", null = !len(qAddr.AddressLine2) },
city: { value = qAddr.AddressCity, cfsqltype = "cf_sql_varchar", null = !len(qAddr.AddressCity) },
stateId: { value = qAddr.AddressStateID, cfsqltype = "cf_sql_integer" },
zip: { value = qAddr.AddressZIPCode, cfsqltype = "cf_sql_varchar", null = !len(qAddr.AddressZIPCode) }
});
writeOutput(serializeJSON({ writeOutput(serializeJSON({
"OK": true, "OK": true,
@ -94,10 +116,11 @@ try {
})); }));
} catch (any e) { } catch (any e) {
writeOutput(serializeJSON({ apiAbort({
"OK": false, "OK": false,
"ERROR": "server_error", "ERROR": "server_error",
"MESSAGE": e.message "MESSAGE": e.message,
})); "LINE": e.tagContext[1].line ?: 0
});
} }
</cfscript> </cfscript>

View file

@ -1,47 +1,74 @@
<cfsetting showdebugoutput="false"> <cfsetting showdebugoutput="false">
<cfsetting enablecfoutputonly="true"> <cfsetting enablecfoutputonly="true">
<cfcontent type="application/json; charset=utf-8"> <cfcontent type="application/json; charset=utf-8" reset="true">
<cfheader name="Cache-Control" value="no-store">
<!--- List delivery addresses for the authenticated user --->
<cfscript> <cfscript>
try { function apiAbort(required struct payload) {
// Get authenticated user ID from request context (set by Application.cfm) writeOutput(serializeJSON(payload));
userId = request.UserID ?: 0;
if (userId <= 0) {
writeOutput(serializeJSON({
"OK": false,
"ERROR": "unauthorized",
"MESSAGE": "Authentication required"
}));
abort; abort;
} }
// Get user's delivery addresses (AddressTypeID contains "2" for delivery, BusinessID is 0 or NULL for personal) function getHeader(name) {
// Use GROUP BY to return only distinct addresses based on content try {
req = getPageContext().getRequest();
val = req.getHeader(arguments.name);
if (!isNull(val)) return trim(val);
} catch (any e) {
k = "HTTP_" & ucase(reReplace(arguments.name, "[^A-Za-z0-9]", "_", "all"));
if (structKeyExists(cgi, k)) return trim(cgi[k]);
}
return "";
}
// Get authenticated user
userId = 0;
if (structKeyExists(request, "UserID") && isNumeric(request.UserID) && request.UserID > 0) {
userId = request.UserID;
} else {
userToken = getHeader("X-User-Token");
if (len(userToken)) {
try {
qTok = queryExecute(
"SELECT UserID FROM UserTokens WHERE Token = ? LIMIT 1",
[{ value = userToken, cfsqltype = "cf_sql_varchar" }],
{ datasource = "payfrit" }
);
if (qTok.recordCount EQ 1) {
userId = qTok.UserID;
}
} catch (any e) {}
}
}
if (userId <= 0) {
apiAbort({ "OK": false, "ERROR": "not_logged_in", "MESSAGE": "Authentication required" });
}
try {
// Get user's delivery addresses with GROUP BY to show unique addresses only
qAddresses = queryExecute(" qAddresses = queryExecute("
SELECT SELECT
MIN(a.AddressID) as AddressID, MIN(a.AddressID) as AddressID,
a.AddressLabel, MAX(a.AddressLabel) as AddressLabel,
MAX(a.AddressIsDefaultDelivery) as AddressIsDefaultDelivery, MAX(a.AddressIsDefaultDelivery) as AddressIsDefaultDelivery,
a.AddressLine1, a.AddressLine1,
a.AddressLine2, a.AddressLine2,
a.AddressCity, a.AddressCity,
a.AddressStateID, a.AddressStateID,
s.tt_StateAbbreviation as StateAbbreviation, MAX(s.tt_StateAbbreviation) as StateAbbreviation,
s.tt_StateName as StateName, MAX(s.tt_StateName) as StateName,
a.AddressZIPCode a.AddressZIPCode
FROM Addresses a FROM Addresses a
LEFT JOIN tt_States s ON a.AddressStateID = s.tt_StateID LEFT JOIN tt_States s ON a.AddressStateID = s.tt_StateID
WHERE a.AddressUserID = :userId WHERE a.AddressUserID = :userId
AND (a.AddressBusinessID = 0 OR a.AddressBusinessID IS NULL)
AND a.AddressTypeID LIKE '%2%' AND a.AddressTypeID LIKE '%2%'
AND a.AddressIsDeleted = 0 AND a.AddressIsDeleted = 0
GROUP BY a.AddressLine1, COALESCE(a.AddressLine2, ''), a.AddressCity, a.AddressStateID, a.AddressZIPCode GROUP BY a.AddressLine1, a.AddressLine2, a.AddressCity, a.AddressStateID, a.AddressZIPCode
ORDER BY AddressIsDefaultDelivery DESC, AddressID DESC ORDER BY MAX(a.AddressIsDefaultDelivery) DESC, MIN(a.AddressID) DESC
", { ", {
userId: { value: userId, cfsqltype: "cf_sql_integer" } userId: { value = userId, cfsqltype = "cf_sql_integer" }
}, { datasource: "payfrit" }); });
addresses = []; addresses = [];
for (row in qAddresses) { for (row in qAddresses) {
@ -66,10 +93,11 @@ try {
})); }));
} catch (any e) { } catch (any e) {
writeOutput(serializeJSON({ apiAbort({
"OK": false, "OK": false,
"ERROR": "server_error", "ERROR": "server_error",
"MESSAGE": e.message "MESSAGE": e.message,
})); "LINE": e.tagContext[1].line ?: 0
});
} }
</cfscript> </cfscript>