feat: [recorder] 修改录制优先顺序

isc_video_record/db/mysql.py

@@ -171,7 +171,7 @@ def update_video_info(cursor, conn, db_table, video_id, status,
 
 
 @query(cursor_dict=True)
-def get_untreated_events(cursor, conn, db_table, camera_code, status=3, **kw):
+def get_untreated_events(cursor, conn, db_table, camera_code, status=3, order_by='create_time', **kw):
 
     if 'retry' in kw:
         sub_str = '((status = 2 and next_retry_time < now()) or status = 3 or status = 0)'
@@ -192,8 +192,8 @@ def get_untreated_events(cursor, conn, db_table, camera_code, status=3, **kw):
         where device_code = %s
           and create_time > date_sub(now(), interval 7 day)
           and {}
-        order by create_time
-    '''.format(db_table, sub_str)
+        order by {}
+    '''.format(db_table, sub_str, order_by)
 
     cursor.execute(sql, [camera_code])
     return cursor.fetchall()

isc_video_record/recorder.py

@@ -141,7 +141,8 @@ class ProcessMessage:
         thread_id = threading.get_ident()
         ack = False
 
-        events = mysql.get_untreated_events(body['db_table'], body['camera_code'], retry=True)
+        events = mysql.get_untreated_events(body['db_table'], body['camera_code'],
+                                            order_by='start_time desc', retry=True)
         log.info('%s: events count: %s', body['camera_code'], len(events))
 
         for event in events:

setup.py

@@ -24,7 +24,7 @@ requires = [
 
 setuptools.setup(
     name='isc-video-record',
-    version='1.0.0b16',
+    version='1.0.0b17',
     description='ISC motion detection playback video stream recording service.',
     long_description=long_description,
     long_description_content_type='text/markdown',