diff --git a/tasks/cron_tasks.py b/tasks/cron_tasks.py index 868a985..df088f3 100644 --- a/tasks/cron_tasks.py +++ b/tasks/cron_tasks.py @@ -15,13 +15,14 @@ def get_data_job(lottery_type='pls'): """ :param lottery_type """ - print("pls: I'm working...") url = f"https://kaijiang.500.com/{lottery_type}.shtml" r = session.get(url) if lottery_type == 'pls': issue_elem = r.html.search('排列3 第 {}期') - else: + elif lottery_type == 'plw': issue_elem = r.html.search('排列5 第 {}期') + else: + issue_elem = r.html.search('福彩3D 第 {}期') draw_date = r.html.xpath('//td[@class="td_title01"]/span[@class="span_right"]/text()', first=True) result = r.html.xpath('//li[@class="ball_orange"]/text()') if issue_elem is not None and draw_date is not None and result is not None and len(result) != 0 : @@ -35,6 +36,7 @@ def get_data_job(lottery_type='pls'): else: print(f'issue:{draw_issue}已经存在') + @repeat(every().day.at("00:01")) def pls_job(): get_data_job(lottery_type='pls') @@ -43,6 +45,10 @@ def pls_job(): def plw_job(): get_data_job(lottery_type='plw') +@repeat(every().day.at("00:03")) +def sd_job(): + get_data_job(lottery_type='sd') + while True: run_pending() time.sleep(1) \ No newline at end of file