| 
														
															@@ -75,7 +75,7 @@ async def run(): 
														 | 
													
												
											
												
													
														| 
														 | 
														
															     scheduler = AsyncIOScheduler() 
														 | 
														
														 | 
														
															     scheduler = AsyncIOScheduler() 
														 | 
													
												
											
												
													
														| 
														 | 
														
															     try: 
														 | 
														
														 | 
														
															     try: 
														 | 
													
												
											
												
													
														| 
														 | 
														
															         logger.info(f"[处理] 开始启动") 
														 | 
														
														 | 
														
															         logger.info(f"[处理] 开始启动") 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-        scheduler.add_job(ConsumptionRecommend.run, trigger=IntervalTrigger(minutes=2))  # 每2分钟启动一次 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															 
														 | 
														
														 | 
														
															+        scheduler.add_job(ConsumptionRecommend.run, trigger=IntervalTrigger(minutes=5))  # 每2分钟启动一次 
														 | 
													
												
											
												
													
														| 
														 | 
														
															         scheduler.start() 
														 | 
														
														 | 
														
															         scheduler.start() 
														 | 
													
												
											
												
													
														| 
														 | 
														
															         await asyncio.Event().wait() 
														 | 
														
														 | 
														
															         await asyncio.Event().wait() 
														 | 
													
												
											
												
													
														| 
														 | 
														
															     except KeyboardInterrupt: 
														 | 
														
														 | 
														
															     except KeyboardInterrupt: 
														 |