"""DB queries."""

DD_INSERT_ENCODING_QUEUE = """
    INSERT INTO encoding_queue
    (
        encoding_order_id,
        priority,
        encoding_order_type,
        encoder_id,
        meta_update
    )
    VALUES
    (
        (
            SELECT MAX(eq1.encoding_order_id) + 1
            FROM encoding_queue AS eq1
        ),
        %(priority)s,
        %(encoding_order_type)s,
        %(encoder_id)s,
        %(meta_update)s
    )
    ;
"""

DD_SELECT_ENCODING_QUEUE = """
    SELECT *
    FROM encoding_queue
    WHERE
        encoding_queue_id = %(encoding_queue_id)s
    ;
"""

DD_INSERT_ENCODING_QUEUE_DETAIL = """
    INSERT INTO encoding_queue_detail
    (
        encoding_queue_id,
        upc,
        status,
        dms_master_master_id
    )
    VALUES
    (
        %(encoding_queue_id)s,
        %(upc)s,
        %(status)s,
        %(dms_master_master_id)s
    )
    ;
"""

DD_UPDATE_ENCODING_QUEUE_DETAIL_STATUS = """
    UPDATE encoding_queue_detail
    SET
        status = %(status)s
    WHERE
        encoding_queue_detail_id = %(encoding_queue_detail_id)s
    ;
"""

DD_SELECT_ENCODING_QUEUE_DETAIL = """
    SELECT
        eqd.*,
        eq.encoding_order_type AS order_type,
        jp.priority AS dpm_priority,
        cmm.priority AS cmm_priority
    FROM encoding_queue_detail AS eqd
    JOIN encoding_queue AS eq
        ON eq.encoding_queue_id = eqd.encoding_queue_id
    JOIN job_priority AS jp
        ON eqd.encoding_queue_detail_id = jp.encoding_queue_detail_id
    JOIN customer_master_master AS cmm
        ON eqd.dms_master_master_id = cmm.customer_master_master_id
    WHERE
        eqd.encoding_queue_detail_id = %(encoding_queue_detail_id)s
    ;
"""

DD_INSERT_JOB_PRIORITY = """
    INSERT INTO job_priority
    (
        encoding_queue_detail_id,
        rule_matches,
        priority
    )
    VALUES
    (
        %(encoding_queue_detail_id)s,
        %(rule_matches)s,
        %(priority)s
    )
    ;
"""

DD_INSERT_DELIVERY_BATCH = """
    INSERT INTO delivery_batch
    (
        dms_master_master_id,
        priority,
        remote_folder,
        status,
        order_type
    )
    VALUES
    (
        %(dms_master_master_id)s,
        %(priority)s,
        %(remote_folder)s,
        'open',
        %(order_type)s
    )
    ;
"""

DD_INSERT_DELIVERY_BATCH_DETAIL = """
    INSERT INTO delivery_batch_detail
    (
        delivery_batch_id,
        encoding_queue_detail_id
    )
    VALUES
    (
        %(delivery_batch_id)s,
        %(encoding_queue_detail_id)s
    )
    ON DUPLICATE KEY UPDATE
        delivery_batch_id = %(delivery_batch_id)s
    ;
"""

DD_SELECT_DELIVERY_SPEC = """
    SELECT *
    FROM dms_delivery_spec
    WHERE
        dms_master_master_id = %(dms_master_master_id)s
    ;
"""

DD_UPDATE_BATCH_STATUS = """
    UPDATE delivery_batch
    SET
        status = %(status)s
    WHERE
        delivery_batch_id = %(delivery_batch_id)s
    ;
"""

AR_SELECT_PRODUCT_BY_UPC = """
    SELECT *
    FROM releases
    WHERE
        upc = %(upc)s
    ;
"""