Repair ambiguous organization id migration
This commit is contained in:
1 parent
4f0020a61d
commit
4e77674cdf
1 file changed
+40
@@ -249,6 +249,46 @@ export async function migrate() {
|
|||||||
);
|
);
|
||||||
`);
|
`);
|
||||||
|
|
||||||
|
await query(`
|
||||||
|
UPDATE tickets t
|
||||||
|
SET organization_id = old_org.zammad_id
|
||||||
|
FROM organizations old_org
|
||||||
|
WHERE t.organization_id = old_org.id
|
||||||
|
AND t.organization_id <> old_org.zammad_id
|
||||||
|
AND COALESCE(t.customer_name, '') = old_org.name;
|
||||||
|
`);
|
||||||
|
|
||||||
|
await query(`
|
||||||
|
UPDATE sessions s
|
||||||
|
SET organization_id = old_org.zammad_id
|
||||||
|
FROM organizations old_org
|
||||||
|
WHERE s.organization_id = old_org.id
|
||||||
|
AND s.organization_id <> old_org.zammad_id
|
||||||
|
AND COALESCE(s.customer_name, '') = old_org.name;
|
||||||
|
`);
|
||||||
|
|
||||||
|
await query(`
|
||||||
|
UPDATE recurring_billings rb
|
||||||
|
SET organization_id = old_org.zammad_id
|
||||||
|
FROM organizations old_org
|
||||||
|
WHERE rb.organization_id = old_org.id
|
||||||
|
AND rb.organization_id <> old_org.zammad_id
|
||||||
|
AND (
|
||||||
|
EXISTS (
|
||||||
|
SELECT 1
|
||||||
|
FROM sessions s
|
||||||
|
WHERE s.recurring_billing_id = rb.id
|
||||||
|
AND COALESCE(s.customer_name, '') = old_org.name
|
||||||
|
)
|
||||||
|
OR EXISTS (
|
||||||
|
SELECT 1
|
||||||
|
FROM tickets t
|
||||||
|
WHERE t.ticket_number = COALESCE(rb.ticket_number, 'Fix#' || rb.id)
|
||||||
|
AND COALESCE(t.customer_name, '') = old_org.name
|
||||||
|
)
|
||||||
|
);
|
||||||
|
`);
|
||||||
|
|
||||||
await query(`
|
await query(`
|
||||||
UPDATE tickets
|
UPDATE tickets
|
||||||
SET organization_id = NULL
|
SET organization_id = NULL
|
||||||
|
|||||||
Reference in new issue
Block a user