"""SQL queries for vector job priority rule matches."""


SELECT_JOBS_TO_PROCESS = """
SELECT
    eq.priority AS order_priority,
    eqd.upc,
    eqd.encoding_queue_detail_id AS encoding_queue_detail_id,
    eqd.dms_master_master_id AS dms_id,
    eq.meta_update AS is_meta_update
FROM encoding_queue eq
INNER JOIN encoding_queue_detail eqd FORCE INDEX (status_dms)
    ON eq.encoding_queue_id = eqd.encoding_queue_id
INNER JOIN dms_delivery_spec dds
    ON dds.dms_master_master_id = eqd.dms_master_master_id
    AND eq.encoding_order_type = dds.order_type
    AND dds.encoding = 'y'
LEFT JOIN job_priority jp
    ON eqd.encoding_queue_detail_id = jp.encoding_queue_detail_id
WHERE
    eqd.status IN ('new', 'encoded', 'ready_to_encode', 'ready_to_deliver')
    AND eq.encoder_id IN %(encoder_ids)s
    AND jp.encoding_queue_detail_id IS NULL
ORDER BY
    eqd.encoding_queue_detail_id
LIMIT
    %(limit)s
;
"""

GET_RELEASE_BY_UPC = """
SELECT
    r.release_id,
    r.upc,
    DATEDIFF(
        IFNULL(
            IFNULL(r.original_release_date, r.release_date),
            r.sale_start_date
        ),
        NOW()
    ) AS release_date_diff
FROM releases r
WHERE
    r.upc IN %(upcs)s
;
"""


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