Compare commits
No commits in common. "8c48514c04b983da8e66cdce3b1a820b65fdf4a2" and "6408748c3f6acdf6f32dee7a624e11fb41a6de41" have entirely different histories.
8c48514c04
...
6408748c3f
@ -1,20 +0,0 @@
|
||||
import sys
|
||||
|
||||
from django.views.debug import ExceptionReporter
|
||||
from django.core import mail
|
||||
|
||||
|
||||
class AdminEmailReporter:
|
||||
def __init__(self, **kwargs):
|
||||
pass
|
||||
|
||||
def report(self):
|
||||
reporter = ExceptionReporter(None, *sys.exc_info())
|
||||
message = f"Failed to run task\n{reporter.get_traceback_text()}"
|
||||
html_message = reporter.get_traceback_html()
|
||||
mail.mail_admins(
|
||||
"Django Q task failed",
|
||||
message,
|
||||
# fail_silently=True,
|
||||
html_message=html_message,
|
||||
)
|
@ -1,3 +1,5 @@
|
||||
import sys
|
||||
|
||||
from django_q.models import Schedule
|
||||
|
||||
|
||||
|
@ -124,7 +124,6 @@ Q_CLUSTER = {
|
||||
"retry": 60 * 6,
|
||||
"timeout": 60 * 5,
|
||||
"catch_up": False,
|
||||
"error_reporter": {"admin_email": {}},
|
||||
"ALT_CLUSTERS": {
|
||||
"internal": {
|
||||
"retry": 60 * 60,
|
||||
|
@ -1,11 +1,4 @@
|
||||
from django.apps import AppConfig
|
||||
from django.db.models.signals import post_migrate
|
||||
|
||||
|
||||
def post_migrate_callback(sender, **kwargs):
|
||||
from .tasks.scrapehidevents import schedule_tasks
|
||||
|
||||
schedule_tasks()
|
||||
|
||||
|
||||
class DoorControlConfig(AppConfig):
|
||||
@ -14,4 +7,6 @@ class DoorControlConfig(AppConfig):
|
||||
verbose_name = "Door Control"
|
||||
|
||||
def ready(self):
|
||||
post_migrate.connect(post_migrate_callback, sender=self)
|
||||
from .tasks.scrapehidevents import schedule_tasks
|
||||
|
||||
schedule_tasks()
|
||||
|
@ -1,26 +1,15 @@
|
||||
from datetime import datetime
|
||||
|
||||
from django.conf import settings
|
||||
from django.db import models
|
||||
from django.db.models import ExpressionWrapper, F, Func, Q
|
||||
from django.db.models.functions import Mod
|
||||
from django.utils import timezone
|
||||
|
||||
from .hid.DoorController import DoorController
|
||||
|
||||
|
||||
class Door(models.Model):
|
||||
name = models.CharField(max_length=64, unique=True)
|
||||
ip = models.GenericIPAddressField(protocol="IPv4")
|
||||
|
||||
@property
|
||||
def controller(self) -> DoorController:
|
||||
return DoorController(
|
||||
self.ip,
|
||||
settings.HID_DOOR_USERNAME,
|
||||
settings.HID_DOOR_PASSWORD,
|
||||
)
|
||||
|
||||
def __str__(self):
|
||||
return self.name
|
||||
|
||||
|
@ -1,5 +1,6 @@
|
||||
from datetime import datetime
|
||||
|
||||
from django.conf import settings
|
||||
from django.db import transaction
|
||||
from django.utils import timezone
|
||||
|
||||
@ -8,6 +9,7 @@ from django_q.models import Schedule
|
||||
|
||||
from cmsmanage.django_q2_helper import ensure_scheduled
|
||||
from doorcontrol.models import Door, HIDEvent
|
||||
from doorcontrol.hid.DoorController import DoorController
|
||||
|
||||
|
||||
@transaction.atomic()
|
||||
@ -18,7 +20,13 @@ def getMessages(door: Door):
|
||||
else:
|
||||
last_ts = datetime(2010, 1, 1)
|
||||
|
||||
for events_page in door.controller.get_events(last_ts):
|
||||
door_controller = DoorController(
|
||||
door.ip,
|
||||
settings.HID_DOOR_USERNAME,
|
||||
settings.HID_DOOR_PASSWORD,
|
||||
)
|
||||
|
||||
for events_page in door_controller.get_events(last_ts):
|
||||
print(f"Importing {len(events_page)} events for {door.name}")
|
||||
HIDEvent.objects.bulk_create(
|
||||
(HIDEvent.from_xml_attributes(door, event.attrib) for event in events_page),
|
||||
|
@ -35,9 +35,6 @@ server = [
|
||||
"setuptools~=68.2",
|
||||
]
|
||||
|
||||
[project.entry-points."djangoq.errorreporters"]
|
||||
admin_email = "cmsmanage.django_q2_admin_email_reporter:AdminEmailReporter"
|
||||
|
||||
[tool.black]
|
||||
line-length = 88
|
||||
|
||||
|
Loading…
Reference in New Issue
Block a user