@@ -85,7 +85,7 @@ def update_item_order(self, queue_id: int, new_order: int):
8585 status = 1
8686 query = None
8787 cursor = self .conn .cursor ()
88- old_order = self .getQueueItemById (queue_id )["display_order" ]
88+ old_order = self .getQueueItemById (queue_id )[5 ]
8989 if new_order < old_order :
9090 query = "UPDATE queue_item SET display_order = display_order + 1 WHERE display_order >= ? AND display_order < ?"
9191 elif new_order > old_order :
@@ -154,10 +154,10 @@ def getScheduledDesigns(self):
154154 d.updated_at
155155 FROM queue_item q
156156 JOIN design d ON q.design_id = d.design_id
157- WHERE d.is_approved = 1
158- ORDER BY
159- CASE WHEN q.scheduled = 1 THEN q.start_time ELSE '9999-12-31 23:59:59' END ASC,
160- q.display_order ASC;
157+ WHERE d.is_approved = 1 AND q.scheduled = 1
158+ AND strftime('%Y-%m-%d %H:%M:%S', q.start_time) <= strftime('%Y-%m-%d %H:%M:%S', 'now')
159+ AND strftime('%Y-%m-%d %H:%M:%S', q.end_time) >= strftime('%Y-%m-%d %H:%M:%S', 'now')
160+ ORDER BY q.display_order ASC;
161161 """
162162 try :
163163 cursor .execute (query )
@@ -185,9 +185,7 @@ def get_all_items_paginated(self, page, page_size):
185185 d.is_approved
186186 FROM queue_item q
187187 JOIN design d ON q.design_id = d.design_id
188- ORDER BY
189- CASE WHEN q.scheduled = 1 THEN q.start_time ELSE '9999-12-31 23:59:59' END ASC,
190- q.display_order ASC
188+ ORDER BY q.display_order ASC
191189 LIMIT ? OFFSET ?;
192190 """
193191 cursor .execute (query , (page_size , offset ))
0 commit comments