gitea-admin/lti-api
1
0
Fork 0
mirror of https://gitlab.com/mbugroup/lti-api.git synced 2026-05-20 13:31:56 +00:00
Code Issues Packages Projects Releases Wiki Activity

cmd: fix aggregation is not allowed in FILTER

Browse Source
This commit is contained in:
Adnan Zahir
2026-04-24 01:23:27 +07:00
parent 83eab9de17
commit 26a04d3bdd
1 changed files with 35 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files
cmd/consolidate-duplicate-product-warehouses/main.go
+30 -15
View File
@@ -120,27 +120,42 @@ func findDuplicateProductWarehouses(ctx context.Context, db *gorm.DB, opts *opti
} }
query := fmt.Sprintf(` query := fmt.Sprintf(`
SELECT WITH duplicates AS (
SELECT
pw.warehouse_id, pw.warehouse_id,
w.name AS warehouse_name, w.name AS warehouse_name,
pw.product_id, pw.product_id,
p.name AS product_name, p.name AS product_name,
COALESCE(a.name, 'N/A') AS area_name, COALESCE(a.name, 'N/A') AS area_name,
COALESCE(l.name, 'N/A') AS location_name, COALESCE(l.name, 'N/A') AS location_name,
MIN(pw.id) AS survivor_id, pw.id,
(SELECT qty FROM product_warehouses WHERE warehouse_id = pw.warehouse_id AND product_id = pw.product_id AND id = MIN(pw.id)) AS survivor_qty, pw.qty,
COUNT(*) - 1 AS absorbed_count, MIN(pw.id) OVER (PARTITION BY pw.warehouse_id, pw.product_id) AS survivor_id,
SUM(pw.qty) AS total_merged_qty, COUNT(*) OVER (PARTITION BY pw.warehouse_id, pw.product_id) AS duplicate_count,
STRING_AGG(pw.id::text, ', ' ORDER BY pw.id::text) FILTER (WHERE pw.id <> MIN(pw.id)) AS absorbed_ids SUM(pw.qty) OVER (PARTITION BY pw.warehouse_id, pw.product_id) AS total_qty
FROM product_warehouses pw FROM product_warehouses pw
JOIN warehouses w ON w.id = pw.warehouse_id JOIN warehouses w ON w.id = pw.warehouse_id
JOIN products p ON p.id = pw.product_id JOIN products p ON p.id = pw.product_id
LEFT JOIN locations l ON l.id = w.location_id LEFT JOIN locations l ON l.id = w.location_id
LEFT JOIN areas a ON a.id = l.area_id LEFT JOIN areas a ON a.id = l.area_id
%s %s
GROUP BY pw.warehouse_id, w.name, pw.product_id, p.name, a.name, l.name )
HAVING COUNT(*) > 1 SELECT
ORDER BY a.name, l.name, w.name, p.name warehouse_id,
warehouse_name,
product_id,
product_name,
area_name,
location_name,
survivor_id,
(SELECT qty FROM duplicates d2 WHERE d2.id = survivor_id LIMIT 1) AS survivor_qty,
duplicate_count - 1 AS absorbed_count,
total_qty AS total_merged_qty,
STRING_AGG(id::text, ', ' ORDER BY id::text) FILTER (WHERE id <> survivor_id) AS absorbed_ids
FROM duplicates
WHERE duplicate_count > 1
GROUP BY warehouse_id, warehouse_name, product_id, product_name, area_name, location_name, survivor_id, total_qty, duplicate_count
ORDER BY area_name, location_name, warehouse_name, product_name
`, filters) `, filters)
rows := make([]duplicateGroup, 0) rows := make([]duplicateGroup, 0)