51 lines
1.8 KiB
Python
51 lines
1.8 KiB
Python
"""زمانبند/اسکنر: پیدا کردن موارد سررسیدشده و قرار دادن آنها در صف پیامک."""
|
|
import logging
|
|
import signal
|
|
import time
|
|
|
|
from django.core.management.base import BaseCommand
|
|
|
|
from admin_panel.sms.scanner import run_all
|
|
|
|
logger = logging.getLogger(__name__)
|
|
|
|
|
|
class Command(BaseCommand):
|
|
help = "اسکن یادآوریهای پیامک و قرار دادن آنها در صف."
|
|
|
|
def __init__(self, *args, **kwargs):
|
|
super().__init__(*args, **kwargs)
|
|
self._stop = False
|
|
|
|
def add_arguments(self, parser):
|
|
parser.add_argument("--loop", action="store_true", help="اجرای پیوسته")
|
|
parser.add_argument("--interval", type=float, default=300.0, help="فاصلهٔ بین اجراها (ثانیه)")
|
|
|
|
def handle(self, *args, **options):
|
|
signal.signal(signal.SIGTERM, self._handle_signal)
|
|
signal.signal(signal.SIGINT, self._handle_signal)
|
|
loop = options["loop"]
|
|
interval = options["interval"]
|
|
|
|
while not self._stop:
|
|
results = run_all()
|
|
summary = ", ".join(f"{name}={count}" for name, count in results.items())
|
|
self._emit(f"اسکن پیامک: {summary}")
|
|
if not loop:
|
|
break
|
|
# خواب قابلقطع
|
|
slept = 0.0
|
|
while slept < interval and not self._stop:
|
|
time.sleep(min(1.0, interval - slept))
|
|
slept += 1.0
|
|
|
|
def _handle_signal(self, signum, frame):
|
|
self._stop = True
|
|
|
|
def _emit(self, text):
|
|
"""نوشتن خروجی با تحمل کدگذاری محدود کنسول (مثلاً cp1252 در ویندوز)."""
|
|
try:
|
|
self.stdout.write(text)
|
|
except UnicodeEncodeError:
|
|
self.stdout.write(text.encode("ascii", "replace").decode("ascii"))
|