|
@@ -383,12 +383,12 @@ def cxx_daily_main(log):
|
|
|
token = sql_pool.select_one("SELECT token FROM super_vault_token")
|
|
token = sql_pool.select_one("SELECT token FROM super_vault_token")
|
|
|
|
|
|
|
|
# 获取所有 pid
|
|
# 获取所有 pid
|
|
|
- # try:
|
|
|
|
|
- # get_vod_list(log, sql_pool, token[0])
|
|
|
|
|
- # except Exception as e:
|
|
|
|
|
- # log.error(f"Error fetching last_product_id: {e}")
|
|
|
|
|
- #
|
|
|
|
|
- # time.sleep(5)
|
|
|
|
|
|
|
+ try:
|
|
|
|
|
+ get_vod_list(log, sql_pool, token[0])
|
|
|
|
|
+ except Exception as e:
|
|
|
|
|
+ log.error(f"Error fetching last_product_id: {e}")
|
|
|
|
|
+
|
|
|
|
|
+ time.sleep(5)
|
|
|
|
|
|
|
|
# 获取所有 report_state = 0 的 pid
|
|
# 获取所有 report_state = 0 的 pid
|
|
|
sql_detail_id_list = sql_pool.select_all("SELECT pid FROM super_vault_product_record WHERE report_state != 1")
|
|
sql_detail_id_list = sql_pool.select_all("SELECT pid FROM super_vault_product_record WHERE report_state != 1")
|