Adding function to generate notifications (not generating yet) and django-cron package

Zambom
1 parent 180657c9
Showing 4 changed files with 50 additions and 0 deletions Show diff stats
amadeus/settings.py
notifications/cron.py
notifications/utils.py
requirements.txt
@@ -52,6 +52,7 @@ INSTALLED_APPS = [
     's3direct',
     'django_summernote',
     'session_security',
+    'django_cron',
  
     'amadeus',
     'users',
@@ -169,6 +170,10 @@ STATICFILES_DIRS = [
     os.path.join(BASE_DIR, "amadeus/static")
 ]
  
+CRON_CLASSES = [
+    'notifications.cron.Test'
+]
+
 #SECURITY
 SECURE_PROXY_SSL_HEADER = ('HTTP_X_FORWARDED_PROTO','https')
  
@@ -0,0 +1,14 @@
+import datetime
+from django_cron import CronJobBase, Schedule
+
+from .utils import set_notifications
+
+class Test(CronJobBase):
+	RUN_EVERY_MINS = 1 # every minute
+
+	schedule = Schedule(run_every_mins=RUN_EVERY_MINS)
+	code = 'amadeus.notification_cron'    # a unique code
+
+	def do(self):
+		print("Hey")
+		set_notifications()
 \ No newline at end of file
@@ -0,0 +1,30 @@
+from datetime import datetime
+from django.db.models import Q
+
+from log.models import Log
+from pendencies.models import Pendencies
+from users.models import User
+
+def get_resource_users(resource):
+	if resource.all_students:
+		return resource.topic.subject.students.all()
+
+	return User.objects.filter(Q(resource_students = resource) | Q(group_participants__resource_groups = resource)).distinct()
+
+def set_notifications():
+	pendencies = Pendencies.objects.filter(begin_date__date__lt = datetime.now(), resource__visible = True)
+
+	for pendency in pendencies:
+		users = get_resource_users(pendency.resource)
+		subject_begin_date = pendency.resource.topic.subject.init_date
+		pend_action = pendency.action
+		resource_type = pendency.resource._my_subclass
+		resource_key = resource_type + "_id"
+		resource_id = pendency.resource.id
+
+		for user in users:
+			has_action = Log.objects.filter(user_id = user.id, action = pend_action, resource = resource_type, context__contains = {resource_key: resource_id}, datetime__date__gte = subject_begin_date).exists()
+
+			print(has_action)
+
+
@@ -33,3 +33,4 @@ validators==0.11.0
 Werkzeug==0.11.11
 whitenoise==3.2.2
 django-session-security==2.4.0
+django-cron==0.5.0
 \ No newline at end of file
...	...	@@ -52,6 +52,7 @@ INSTALLED_APPS = [
52	52	's3direct',
53	53	'django_summernote',
54	54	'session_security',
	55	+ 'django_cron',
55	56
56	57	'amadeus',
57	58	'users',
...	...	@@ -169,6 +170,10 @@ STATICFILES_DIRS = [
169	170	os.path.join(BASE_DIR, "amadeus/static")
170	171	]
171	172
	173	+CRON_CLASSES = [
	174	+ 'notifications.cron.Test'
	175	+]
	176	+
172	177	#SECURITY
173	178	SECURE_PROXY_SSL_HEADER = ('HTTP_X_FORWARDED_PROTO','https')
174	179
...	...
...	...	@@ -0,0 +1,14 @@
	1	+import datetime
	2	+from django_cron import CronJobBase, Schedule
	3	+
	4	+from .utils import set_notifications
	5	+
	6	+class Test(CronJobBase):
	7	+ RUN_EVERY_MINS = 1 # every minute
	8	+
	9	+ schedule = Schedule(run_every_mins=RUN_EVERY_MINS)
	10	+ code = 'amadeus.notification_cron' # a unique code
	11	+
	12	+ def do(self):
	13	+ print("Hey")
	14	+ set_notifications()
0	15	\ No newline at end of file
...	...
...	...	@@ -0,0 +1,30 @@
	1	+from datetime import datetime
	2	+from django.db.models import Q
	3	+
	4	+from log.models import Log
	5	+from pendencies.models import Pendencies
	6	+from users.models import User
	7	+
	8	+def get_resource_users(resource):
	9	+ if resource.all_students:
	10	+ return resource.topic.subject.students.all()
	11	+
	12	+ return User.objects.filter(Q(resource_students = resource) \| Q(group_participants__resource_groups = resource)).distinct()
	13	+
	14	+def set_notifications():
	15	+ pendencies = Pendencies.objects.filter(begin_date__date__lt = datetime.now(), resource__visible = True)
	16	+
	17	+ for pendency in pendencies:
	18	+ users = get_resource_users(pendency.resource)
	19	+ subject_begin_date = pendency.resource.topic.subject.init_date
	20	+ pend_action = pendency.action
	21	+ resource_type = pendency.resource._my_subclass
	22	+ resource_key = resource_type + "_id"
	23	+ resource_id = pendency.resource.id
	24	+
	25	+ for user in users:
	26	+ has_action = Log.objects.filter(user_id = user.id, action = pend_action, resource = resource_type, context__contains = {resource_key: resource_id}, datetime__date__gte = subject_begin_date).exists()
	27	+
	28	+ print(has_action)
	29	+
	30	+
...	...
...	...	@@ -33,3 +33,4 @@ validators==0.11.0
33	33	Werkzeug==0.11.11
34	34	whitenoise==3.2.2
35	35	django-session-security==2.4.0
	36	+django-cron==0.5.0
36	37	\ No newline at end of file
...	...