瀏覽代碼

no message

libushang 3 月之前
父節點
當前提交
c966581e0b
共有 2 個文件被更改,包括 4 次插入3 次删除
  1. 1 1
      jobs/__init__.py
  2. 3 2
      jobs/hkvideo_job.py

+ 1 - 1
jobs/__init__.py

@@ -38,7 +38,7 @@ def register_jobs(scheduler: BaseScheduler):
     # scheduler.add_job(vehicle_proc, CronTrigger.from_crontab('*/5 * * * *'))
 
     # 视频状态更新
-    scheduler.add_job(hkvideo_proc, next_run_time=(datetime.now() + timedelta(seconds=30)))
+    scheduler.add_job(hkvideo_proc, next_run_time=(datetime.now() + timedelta(seconds=9)))
     scheduler.add_job(hkvideo_proc, CronTrigger.from_crontab('0 1 * * *'))
 
 

+ 3 - 2
jobs/hkvideo_job.py

@@ -30,16 +30,17 @@ def refresh_hkvideo(db: Session):
         video_code = row.video_code
         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()
-                row.commit()
+                db.commit()
         except Exception as e:
             traceback.print_exc()
 
             if row is not None:
                 row.status = 9
                 row.update_time = datetime.now()
-                row.commit()
+                db.commit()