From 8a8b37553855cb714d05a2005600459f690a64ed Mon Sep 17 00:00:00 2001
From: Franklin-F <dewujie64@gmail.com>
Date: Fri, 27 Jun 2025 19:53:09 +0800
Subject: [PATCH] =?UTF-8?q?feat:=20=E6=B7=BB=E5=8A=A0=E6=B5=8B=E8=AF=95?=
 =?UTF-8?q?=E6=96=B9=E6=B3=95=E4=BB=A5=E9=AA=8C=E8=AF=81DailymotionClient?=
 =?UTF-8?q?=E5=8A=9F=E8=83=BD=E5=B9=B6=E8=AE=B0=E5=BD=95=E6=88=AA=E5=9B=BE?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 report.py | 85 ++++++++++++++++++++++++++++---------------------------
 1 file changed, 43 insertions(+), 42 deletions(-)

diff --git a/report.py b/report.py
index 83e3028..d328198 100644
--- a/report.py
+++ b/report.py
@@ -73,45 +73,46 @@ last_subsequent_run = 0
 MAIN_INTERVAL = 60 * 5  # 每 5 分钟执行一次
 SUBSEQUENT_INTERVAL = 60 * 60  # 每 60 分钟执行一次
 
-while True:
-    now = int(time.time())
-
-    # 处理主流程
-    if now - last_main_run >= MAIN_INTERVAL:
-        last_main_run = now
-        lis = db.item_report()
-        if len(lis) > 0:
-            for _, li in lis:
-                print(li)
-                logger.info(f"name:{li['name_title']},link:{li['link']} ")
-                try:
-                    info, report_id, status, report_ts = d.process_ticket(li['name_title'], li['link'])
-                    subsequent_status = k.get(status, 1)
-                    db.update_fight_record_status(
-                        li['id'], report_id, 2, f"http://{ip}:5000/image/{info}",
-                        report_ts, subsequent_status, MACHINE_ID
-                    )
-                    db.flush()
-                except Exception as e:
-                    logger.logger.error(f"ID:{li['id']}, e:{e}")
-                    db.update_fight_record_status(li['id'], 0, 3, str(e), mid=MACHINE_ID)
-                    time.sleep(60)  # 出错延迟
-
-    if now - last_subsequent_run >= SUBSEQUENT_INTERVAL and IsSubsequent:
-        last_subsequent_run = now
-        subsequent_list = db.get_subsequent_report_video()
-        if len(subsequent_list) > 0:
-            for li in subsequent_list:
-                rs_id = li['id']
-                r_id = li['report_id']
-                logger.info(f"subsequent id:{rs_id},report_id:{r_id} ")
-                # try:
-                subsequent_status, info = d.report_follow_up(r_id)
-                db.update_subsequent_status_by_id(
-                    rs_id, subsequent_status, f"http://{ip}:5000/image/{info}"
-                )
-                # except Exception as e:
-                #     logger.logger.error(f"ID:{rs_id}, e:{e}")
-                #     db.update_subsequent_status_by_id(rs_id, 1, str(e))
-                time.sleep(5)  # 避免频繁请求
-    time.sleep(5)
+d.test()
+# while True:
+#     now = int(time.time())
+#
+#     # 处理主流程
+#     if now - last_main_run >= MAIN_INTERVAL:
+#         last_main_run = now
+#         lis = db.item_report()
+#         if len(lis) > 0:
+#             for _, li in lis:
+#                 print(li)
+#                 logger.info(f"name:{li['name_title']},link:{li['link']} ")
+#                 try:
+#                     info, report_id, status, report_ts = d.process_ticket(li['name_title'], li['link'])
+#                     subsequent_status = k.get(status, 1)
+#                     db.update_fight_record_status(
+#                         li['id'], report_id, 2, f"http://{ip}:5000/image/{info}",
+#                         report_ts, subsequent_status, MACHINE_ID
+#                     )
+#                     db.flush()
+#                 except Exception as e:
+#                     logger.logger.error(f"ID:{li['id']}, e:{e}")
+#                     db.update_fight_record_status(li['id'], 0, 3, str(e), mid=MACHINE_ID)
+#                     time.sleep(60)  # 出错延迟
+#
+#     if now - last_subsequent_run >= SUBSEQUENT_INTERVAL and IsSubsequent:
+#         last_subsequent_run = now
+#         subsequent_list = db.get_subsequent_report_video()
+#         if len(subsequent_list) > 0:
+#             for li in subsequent_list:
+#                 rs_id = li['id']
+#                 r_id = li['report_id']
+#                 logger.info(f"subsequent id:{rs_id},report_id:{r_id} ")
+#                 # try:
+#                 subsequent_status, info = d.report_follow_up(r_id)
+#                 db.update_subsequent_status_by_id(
+#                     rs_id, subsequent_status, f"http://{ip}:5000/image/{info}"
+#                 )
+#                 # except Exception as e:
+#                 #     logger.logger.error(f"ID:{rs_id}, e:{e}")
+#                 #     db.update_subsequent_status_by_id(rs_id, 1, str(e))
+#                 time.sleep(5)  # 避免频繁请求
+#     time.sleep(5)