"""SQL queries.""" from src.constants import fields # Get 'encoding' and 'delivery' fields by store_id and order_type in bulk. DD_SELECT_DDS_BULK_NO_CONDITION = """ SELECT encoding, delivery, dms_master_master_id, order_type FROM dms_delivery_spec WHERE """ DD_SELECT_DDS_BULK_CONDITION_TEMPLATE = """ (dms_master_master_id = {store_id:d} AND order_type = '{order_type:s}') """ # Select multiple encoding_queue records by encoding_queue_id. DD_SELECT_ENCODING_QUEUE_BULK = """ SELECT encoding_queue_id, encoding_order_id, encoding_order_type, priority, meta_update, encoder_id FROM encoding_queue WHERE encoding_queue_id IN :{:s}; """.format(fields.SQL_ID_LIST) # get encoding_order user_id and date by encoding_order_id list. AR_SELECT_ENCODING_ORDER_BULK = """ SELECT encoding_order_id as order_id, orchadmin_user_id as user_id, entry_date as created_at FROM encoding_order WHERE encoding_order_id IN :{:s} """.format(fields.SQL_ID_LIST) # select encoding_queue_detail by encoding_queue_id DD_SELECT_ENCODING_QUEUE_DETAIL_BULK = """ SELECT delivery_started, delivery_ended, encoding_started, encoding_ended, encoding_queue_detail_id, encoding_queue_id, error_log, status, dms_master_master_id, upc FROM encoding_queue_detail WHERE encoding_queue_detail_id IN :{:s}; """.format(fields.SQL_ID_LIST)