I have a Telegram bot written in Python using the Telethon library. The bot is supposed to function from 10:00 to 16:15 from Saturday to Thursday, and it should be completely inactive on Fridays. However, I'm having trouble getting the bot to stop exactly at 16:15. The bot currently doesn't stop correctly at the specified time.
I have tried to make the bot work from 10:00 to 16:15 from Saturday to Thursday and stop exactly at 16:15. However, it doesn't stop as expected. Could anyone help me identify what I'm doing wrong?
Thank you in advance for your help!
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 230 231 232 233 234 235 236 237 238 239 240 241 242 243 244 245 246 247 248 249 250 251 252 |
import loggingimport reimport randomimport jdatetimefrom telethon import TelegramClient, eventsfrom datetime import datetime, timedeltaimport asyncioimport pytz# اطلاعات APIgroup_usernames = ['@gheymateTehran2', '@DOLARRATE1', '@gheymateTehran'] # نام‌های کاربری سه گروه# اطلاعات کانال جدیدtarget_channel_id = '@DolarRates'# تنظیمات لاگینگlogging.basicConfig(level=logging.INFO)logger = logging.getLogger(__name__)# تنظیمات پراکسی (در صورت نیاز)proxy = None # ('socks5', '127.0.0.1', 9050) # نمونه برای پراکسی SOCKS5# ایجاد کلاینت تلگرام با تنظیمات پراکسیclient = TelegramClient('session_name', api_id, api_hash, proxy=proxy)# قفل برای مدیریت ارسال پیامsend_lock = asyncio.Lock()# متغیر زمان آخرین ارسال پیامlast_sent_time = datetime(1970, 1, 1, tzinfo=pytz.UTC)# متغیر سراسری برای ذخیره عدد جدید دلارglobal_new_number_str = "نامشخص" # مقدار اولیه# متغیر وضعیت کارکرد باتis_running = False# تابع محاسبه ساعت به وقت تهرانdef tehran_time(): tehran_tz = pytz.timezone('Asia/Tehran') return datetime.now(tehran_tz)async def send_message_to_channel(message): try: logger.info(f"Sending message to channel: {message}") await client.send_message(channel_id, message) except Exception as e: logger.error(f"Failed to send message: {e}")def get_persian_date(): today = jdatetime.date.today() return today.strftime('%Y/%m/%d')async def process_message_text(text): global last_sent_time, global_new_number_str current_time = tehran_time() async with send_lock: if (current_time - last_sent_time).total_seconds() < 60: logger.info("Skipping message send due to time limit.") return None # پیدا کردن اولین عدد 5 رقمی در متن match = re.search(r'\b\d{2},\d{3}\b', text) if match: # استخراج عدد original_number = match.group() # حذف کاما و تبدیل به عدد صحیح number = int(original_number.replace(',', '')) # کاهش عدد به مقدار 50 new_number = number - 50 # تبدیل عدد جدید به رشته با فرمت مناسب new_number_str = f'{new_number:,}' # ذخیره عدد جدید در متغیر سراسری global_new_number_str = new_number_str # ایجاد پیام خروجی processed_text = f""" ✨ #نرخ_دلار 📆 تاریخ: {get_persian_date()} 💸 #دلار سبزه : {new_number_str} تومان 🌟 بروزترین قیمت‌ها رو همین حالا مشاهده کنید. 📲 کانال قیمت #دلار تهران 👇 🆔@DolarRates """ last_sent_time = current_time return processed_text.strip() else: logger.error("No 5-digit number found in the text.") return None# تابع پردازش پیام‌های کانال جدیدdef process_new_channel_message(text): # حذف موارد ناخواسته text = re.sub(r'🔸دلار آمريکا.*?\n', '', text) text = re.sub(r'⏰ساعت.*?\n', '', text) text = re.sub(r'✅ @Akhbargeymat', '', text) text = re.sub(r'✅ .*?\n', '', text) text = text.replace('🔸', '') text = text.replace('✅', '') # حذف علامت ✅ text = text.replace('****', '') # حذف **** # جایگزینی پرچم‌ها text = text.replace('يورو', '🇪🇺 يورو') text = text.replace('پوند انگليس', '🇬🇧 پوند انگليس') text = text.replace('درهم امارات', '🇦🇪 درهم امارات') text = text.replace('يوآن چين', '🇨🇳 يوآن چين') text = text.replace('لير ترکيه', '🇹🇷 لير ترکيه') text = text.replace('دینار کویت', '🇰🇼 دینار کویت') text = text.replace('🔹', '🟡') text = text.replace('@Akhbargeymat', '') # راست‌چین کردن lines = text.split('\n') aligned_text = '\n'.join(line.strip() for line in lines if line.strip()) # اضافه کردن متن جدید additional_text = """🌟 بروزترین قیمت‌ها رو همین حالا مشاهده کنید.📲 کانال قیمت #دلار تهران 👇🆔@DolarRates """ return aligned_text.strip() + '\n\n' + additional_text.strip()# تابع خواندن آخرین پیام‌ها از گروه‌ها و ارسال جدیدترین پیام هر یک دقیقهasync def read_latest_posts(): while is_running: for group_username in group_usernames: try: logger.info(f"Reading latest post from {group_username}") messages = await client.get_messages(group_username, limit=1) if messages: latest_message = messages[0] processed_text = await process_message_text(latest_message.text) if processed_text: logger.info(f"Latest post fetched from {group_username}: {processed_text}") await send_message_to_channel(processed_text) except Exception as e: logger.error(f"Failed to read latest post from {group_username}: {e}") await asyncio.sleep(60) # انتظار یک دقیقه# تابع خواندن و ارسال پیام از کانال جدید هر 40 دقیقه بدون محدودیت زمانیasync def read_and_forward_from_new_channel(): while is_running: try: logger.info(f"Reading latest post from {new_channel_id}") messages = await client.get_messages(new_channel_id, limit=1) if messages: latest_message = messages[0] processed_text = process_new_channel_message(latest_message.text) if processed_text: logger.info(f"Latest post fetched from {new_channel_id}: {processed_text}") await send_message_to_channel(processed_text) await asyncio.sleep(2400) # انتظار 40 دقیقه except Exception as e: logger.error(f"Failed to read and forward from new channel: {e}")# هندلر برای پیام‌های جدید@client.on(events.NewMessage(chats=group_usernames))async def handler(event): if is_running: try: processed_text = await process_message_text(event.message.text) if processed_text: logger.info(f"New message received from {event.chat.username}: {processed_text}") await send_message_to_channel(processed_text) except Exception as e: logger.error(f"Failed to handle new message from {event.chat.username}: {e}")# ارسال پیام‌های خوش‌آمدگویی و خداحافظیasync def send_greeting_messages(): while is_running: now = tehran_time() if now.hour == 10 and now.minute == 0: await send_message_to_channel("به نام خدا") elif now.hour == 19 and now.minute == 0: await send_message_to_channel("به امید دیدار") await asyncio.sleep(60) # بررسی هر دقیقه# ارسال پیام‌های خودکار هر 5 تا 8 دقیقهasync def automated_posting(): while is_running: tehran_current_time = tehran_time().strftime('%H:%M:%S') special_message = f"""✨ #نرخ_دلار📆 تاریخ: {get_persian_date()}مـعامله انجام شد✅💸 #دلار سبزه : {global_new_number_str} تومان🌟 بروزترین قیمت‌ها رو همین حالا مشاهده کنید.📲 کانال قیمت #دلار تهران 👇🆔@DolarRates """ await send_message_to_channel(special_message.strip()) await asyncio.sleep(random.randint(300, 480)) # انتظار بین 5 الی 8 دقیقه# تابع متوقف کردن فعالیت رباتasync def shutdown_bot(): global is_running is_running = False logger.info("Bot activities have been stopped.")async def main(): global is_running logger.info("Starting client...") try: await client.start(phone_number) except Exception as e: logger.error(f"Failed to start client: {e}") else: logger.info("Client started.") while True: now = tehran_time() # Check for exact time to stop if now.hour == 17 and now.minute == 15: if is_running: await shutdown_bot() logger.info("Bot has been stopped exactly at 17:15.") # Check for weekdays and time range to start if now.weekday() != 4 and (10 <= now.hour < 16 or (now.hour == 16 and now.minute < 15)): if not is_running: is_running = True logger.info("Bot is starting its activities.") await asyncio.gather( send_greeting_messages(), automated_posting(), read_and_forward_from_new_channel(), read_latest_posts() ) # More precise time check every second await asyncio.sleep(1)if __name__ == "__main__": logger.info("Running main...") client.loop.run_until_complete(main()) client.run_until_disconnected() |
Thank you in advance for your help!
Larz60+ write Aug-07-2024, 05:32 PM:
Please post all code, output and errors (it it's entirety) between their respective tags. Refer to BBCode help topic on how to post. Use the "Preview Post" button to make sure the code is presented as you expect before hitting the "Post Reply/Thread" button.
Tgas added fir you this time, please use BBCode tags on future posts.
Please post all code, output and errors (it it's entirety) between their respective tags. Refer to BBCode help topic on how to post. Use the "Preview Post" button to make sure the code is presented as you expect before hitting the "Post Reply/Thread" button.
Tgas added fir you this time, please use BBCode tags on future posts.