"""fix_project_campaigns_insert_on_update_project_flow

Revision ID: c1b13db9e76a
Revises: 9c343f4c9aa4
Create Date: 2021-11-01 12:18:36.575401

"""
from alembic import op
from migrations.fixtures.delphi_tables.v2.data_refresher import DelphiTablesDataRefresher
import sqlalchemy as sa


# revision identifiers, used by Alembic.
revision = 'c1b13db9e76a'
down_revision = '9c343f4c9aa4'
branch_labels = None
depends_on = None


def upgrade():
    bind = op.get_bind()

    op.execute(
        '''
        insert into "ProjectCampaign"(campaign_id, project_id, status)
            select campaign.id, campaign.project_id, 1
            from "Campaign" as campaign
            left join "ProjectCampaign" proj_camp on campaign.id =proj_camp.campaign_id
            where campaign.project_id is not null and campaign.external_id is not null and proj_camp.id is null;
        '''
    )
    DelphiTablesDataRefresher().refresh(bind)