kali/DailyMotion
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: 添加测试方法以验证DailymotionClient功能并记录截图

Browse Source
This commit is contained in:
晓丰 2025-06-27 19:53:09 +08:00
parent bb9830887a
commit 8a8b375538
1 changed files with 43 additions and 42 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

85
report.py
View File

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