paymnet methods cards new table

2026-06-28 22:41:50 +03:30
parent a565f93044
commit 604447d3e8
10 changed files with 262 additions and 111 deletions
@@ -0,0 +1,103 @@
+import { Migration } from '@mikro-orm/migrations';
+
+export class Migration20260627120000_add_payment_method_cards_table extends Migration {
+
+  override async up(): Promise<void> {
+    this.addSql(`
+      create table "payment_method_cards" (
+        "id" char(26) not null,
+        "created_at" timestamptz not null default now(),
+        "updated_at" timestamptz not null default now(),
+        "deleted_at" timestamptz null,
+        "payment_method_id" char(26) not null,
+        "card_number" varchar(255) not null,
+        "owner" varchar(255) not null,
+        constraint "payment_method_cards_pkey" primary key ("id")
+      );
+    `);
+    this.addSql(`create index "payment_method_cards_payment_method_id_index" on "payment_method_cards" ("payment_method_id");`);
+    this.addSql(`create index "payment_method_cards_deleted_at_index" on "payment_method_cards" ("deleted_at");`);
+    this.addSql(`create index "payment_method_cards_created_at_index" on "payment_method_cards" ("created_at");`);
+    this.addSql(`
+      alter table "payment_method_cards"
+      add constraint "payment_method_cards_payment_method_id_foreign"
+      foreign key ("payment_method_id") references "payment_methods" ("id")
+      on update cascade on delete cascade;
+    `);
+
+    this.addSql(`
+      insert into "payment_method_cards" ("id", "created_at", "updated_at", "payment_method_id", "card_number", "owner")
+      select substring(replace(gen_random_uuid()::text, '-', ''), 1, 26), now(), now(), "id", "card_number", "card_owner"
+      from "payment_methods"
+      where "card_number" is not null and "card_owner" is not null;
+    `);
+    this.addSql(`
+      insert into "payment_method_cards" ("id", "created_at", "updated_at", "payment_method_id", "card_number", "owner")
+      select substring(replace(gen_random_uuid()::text, '-', ''), 1, 26), now(), now(), "id", "card_number2", "card_owner2"
+      from "payment_methods"
+      where "card_number2" is not null and "card_owner2" is not null;
+    `);
+    this.addSql(`
+      insert into "payment_method_cards" ("id", "created_at", "updated_at", "payment_method_id", "card_number", "owner")
+      select substring(replace(gen_random_uuid()::text, '-', ''), 1, 26), now(), now(), "id", "card_number3", "card_owner3"
+      from "payment_methods"
+      where "card_number3" is not null and "card_owner3" is not null;
+    `);
+
+    this.addSql(`
+      alter table "payment_methods"
+      drop column "card_number",
+      drop column "card_number2",
+      drop column "card_number3",
+      drop column "card_owner",
+      drop column "card_owner2",
+      drop column "card_owner3";
+    `);
+  }
+
+  override async down(): Promise<void> {
+    this.addSql(`
+      alter table "payment_methods"
+      add column "card_number" varchar(255) null,
+      add column "card_number2" varchar(255) null,
+      add column "card_number3" varchar(255) null,
+      add column "card_owner" varchar(255) null,
+      add column "card_owner2" varchar(255) null,
+      add column "card_owner3" varchar(255) null;
+    `);
+
+    this.addSql(`
+      update "payment_methods" pm
+      set
+        "card_number" = c1."card_number",
+        "card_owner" = c1."owner",
+        "card_number2" = c2."card_number",
+        "card_owner2" = c2."owner",
+        "card_number3" = c3."card_number",
+        "card_owner3" = c3."owner"
+      from (
+        select distinct on ("payment_method_id") *
+        from "payment_method_cards"
+        order by "payment_method_id", "created_at"
+      ) c1
+      left join lateral (
+        select *
+        from "payment_method_cards"
+        where "payment_method_id" = c1."payment_method_id"
+        order by "created_at"
+        offset 1 limit 1
+      ) c2 on true
+      left join lateral (
+        select *
+        from "payment_method_cards"
+        where "payment_method_id" = c1."payment_method_id"
+        order by "created_at"
+        offset 2 limit 1
+      ) c3 on true
+      where pm."id" = c1."payment_method_id";
+    `);
+
+    this.addSql(`drop table if exists "payment_method_cards" cascade;`);
+  }
+
+}