117 lines
3.7 KiB
Python
117 lines
3.7 KiB
Python
from datetime import datetime, timedelta
|
||
import itertools
|
||
|
||
from module_project.service import OneSignalService
|
||
from .models import InAppNotification
|
||
from module_iam.models import IAmPrincipal, IAmPrincipalType
|
||
from module_activity.models import MealRecord, Bowel, MealSymptomRecord, Medication
|
||
|
||
|
||
def notification_for_meal():
|
||
notification_message = "You haven’t filled your meal details yet."
|
||
current_date = datetime.now()
|
||
fifteen_days_ago = current_date - timedelta(days=20)
|
||
|
||
users = IAmPrincipal.objects.filter(
|
||
last_login__gte=fifteen_days_ago,
|
||
principal_type=IAmPrincipalType.get_principal_user(),
|
||
).values_list("id", flat=True)
|
||
|
||
meal_obj = MealRecord.objects.filter(date=current_date).values_list(
|
||
"principal", flat=True
|
||
)
|
||
|
||
# Remove IDs of users who have recorded meals for the current day
|
||
users_without_meals = set(users) - set(meal_obj)
|
||
print(f"user id {set(users)}")
|
||
print(
|
||
f"userwithoutmeal {users_without_meals}"
|
||
)
|
||
|
||
player_ids = list(
|
||
IAmPrincipal.objects.filter(
|
||
id__in=users_without_meals
|
||
).values_list("player_id", flat=True)
|
||
)
|
||
# removing none from list
|
||
player_ids = list(itertools.filterfalse(lambda x: x is None, player_ids))
|
||
|
||
notifications_to_create = []
|
||
if users_without_meals:
|
||
for user_id in users_without_meals:
|
||
message = notification_message
|
||
notifications_to_create.append(
|
||
InAppNotification(user_id=user_id, message=message)
|
||
)
|
||
|
||
# Bulk create notifications
|
||
if notifications_to_create:
|
||
InAppNotification.objects.bulk_create(notifications_to_create)
|
||
|
||
try:
|
||
notification = OneSignalService()
|
||
response = notification.send_notification(
|
||
headings="Meal",
|
||
contents=notification_message,
|
||
include_player_ids=player_ids,
|
||
)
|
||
except Exception as e:
|
||
print(f"Notification error in meal {str(e)}")
|
||
pass
|
||
|
||
def notification_for_medication():
|
||
notification_message = "You haven’t filled your medication details yet. "
|
||
current_date = datetime.now()
|
||
fifteen_days_ago = current_date - timedelta(days=20)
|
||
|
||
users = IAmPrincipal.objects.filter(
|
||
last_login__gte=fifteen_days_ago,
|
||
principal_type=IAmPrincipalType.get_principal_user(),
|
||
).values_list("id", flat=True)
|
||
|
||
medication_obj = Medication.objects.filter(date=current_date).values_list(
|
||
"principal", flat=True
|
||
)
|
||
|
||
# Remove IDs of users who have recorded medication for the current day
|
||
users_without_medications = set(users) - set(medication_obj)
|
||
print(f"user id {set(users)}")
|
||
print(
|
||
f"users_without_medication {users_without_medications}"
|
||
)
|
||
|
||
player_ids = list(
|
||
IAmPrincipal.objects.filter(
|
||
id__in=users_without_medications
|
||
).values_list("player_id", flat=True)
|
||
)
|
||
# removing none from list
|
||
player_ids = list(itertools.filterfalse(lambda x: x is None, player_ids))
|
||
|
||
notifications_to_create = []
|
||
if users_without_medications:
|
||
for user_id in users_without_medications:
|
||
message = notification_message
|
||
notifications_to_create.append(
|
||
InAppNotification(user_id=user_id, message=message)
|
||
)
|
||
|
||
# Bulk create notifications
|
||
if notifications_to_create:
|
||
InAppNotification.objects.bulk_create(notifications_to_create)
|
||
|
||
try:
|
||
notification = OneSignalService()
|
||
response = notification.send_notification(
|
||
headings="Medication",
|
||
contents=notification_message,
|
||
include_player_ids=player_ids,
|
||
)
|
||
except Exception as e:
|
||
print(f"Notification error in medication {str(e)}")
|
||
pass
|
||
|
||
|
||
def testing_cron():
|
||
print("cron is working ")
|