"""Query template for creating contract_mechanical_deduction snapshots in snowflake."""

from jinja2 import Template


def insert_snapshot_contract_mechanical_deduction_template():
    """Copy data from royalty_accounting snowflake replica into snapshot_contract_mechanical_deduction."""
    return Template("""
        INSERT INTO ROYALTY_ACCOUNTING.{{schema}}.SNAPSHOT_CONTRACT_MECHANICAL_DEDUCTION(
            ACCOUNTING_RUN_ID,
            CONTRACT_MECHANICAL_DEDUCTION_ID,
            CONTRACT_ID,
            TERRITORY,
            MECHANICAL_TYPE,
            ADMIN_TYPE,
            ADMIN_FEE
        )
        SELECT
            {{accounting_run_id}},
            cmd.CONTRACT_MECHANICAL_DEDUCTION_ID,
            cmd.CONTRACT_ID,
            cmd.TERRITORY,
            cmd.MECHANICAL_TYPE,
            cmd.ADMIN_TYPE,
            cmd.ADMIN_FEE
        FROM ORCHARD_APP_REPORTING_V2.{{schema}}_ROYALTY_ACCOUNTING_ROYALTY_ACCOUNTING.CONTRACT_MECHANICAL_DEDUCTION AS cmd
        INNER JOIN ORCHARD_APP_REPORTING_V2.{{schema}}_ROYALTY_ACCOUNTING_ROYALTY_ACCOUNTING.RUN_CONTROLLER_CONTRACT AS rcc
            ON cmd.CONTRACT_ID = rcc.CONTRACT_ID
        WHERE rcc.RUN_CONTROLLER_ID = {{run_controller_id}};
    """)