"""remove_pending_projectcampaigns_diverse_currency

Revision ID: b2243490c23d
Revises: 6e16011951ae
Create Date: 2022-03-29 22:08:00.291231

"""
from alembic import op

# revision identifiers, used by Alembic.
revision = 'b2243490c23d'
down_revision = '6e16011951ae'
branch_labels = None
depends_on = None


def upgrade():
    op.execute(
        """
        DELETE FROM "ProjectCampaign"
        WHERE "ProjectCampaign".id IN (
            SELECT "ProjectCampaign".id
            FROM "ProjectCampaign"
            INNER JOIN "Project" ON "Project".id = "ProjectCampaign".project_id
            INNER JOIN "Campaign" ON "Campaign".id = "ProjectCampaign".campaign_id
            INNER JOIN "MarketingAccount" ON "MarketingAccount".external_id = "Campaign".external_marketing_account_id
            WHERE "ProjectCampaign".status = 0 AND "MarketingAccount".currency != "Project".currency)
        """
    )


def downgrade():
    pass