no message

jobs/hkvideo_job.py

@@ -24,23 +24,25 @@ def proc():
 
         redis_unlock(lock_key)
 
+
 def refresh_hkvideo(db: Session):
     rows = db.query(VideoJob).order_by(VideoJob.update_time.asc()).limit(200).all()
     for row in rows:
         video_code = row.video_code
+        status = 9
         try:
             data = hk_video_api.indexCode(video_code)
             # print(video_code, data)
             if data is not None:
                 status = data['status']
-                row.status = status
-                row.update_time = datetime.now()
-                db.commit()
         except Exception as e:
             traceback.print_exc()
 
-            if row is not None:
-                row.status = 9
-                row.update_time = datetime.now()
-                db.commit()
-            
+        row.status = status
+        row.update_time = datetime.now()
+        db.commit()
+
+        update_assis_video_table(video_code, status, db)
+            
+def update_assis_video_table(video_code: str, status: int, db: Session) -> None:
+    pass

utils/hk_video_api.py

@@ -34,7 +34,7 @@ def indexCode(id: str):
             data = result['data']
             if isinstance(data,str):
                 data = json.loads(data)
-    return data
+                return data
 
 def controlling(id: str, action: int, command: str, speed: int, presetIndex: str):
     api_url = "http://10.181.7.236:8081/controlling"