import datetime from collections import defaultdict from rest_framework import serializers, status from api.models import TtDepartment, TtZone, TtAvailability, TtStartPreference, TtUsagePreference, TtTag, TtSetting, \ TtModule, TtAcademicTerm, TtActivityType, TtStaff, TtLocation, TtSuitability, TtActivityTemplate, TtWeekPattern, \ TtWeek, TtPosModuleGroupModule, TtActivity from api.views.admin.base import AdminApiBase from api.validator import BaseValidator from api.utils import decrypt_aes_128_cbc, encrypt_aes_128_cbc, log_critical_error, get_exception_detail, \ calculate_preset_pattern_time, time_to_slot from rest_framework.exceptions import ValidationError from api.translation import __ class ActivityRules(AdminApiBase): def validate_request(self,request): rules = { "academic_term_id": "required|exists:api.TtAcademicTerm,id", } # if need rename field, can put here attribute = { # "email": __("attr.email"), } # validate id first, cause need get activity_template by id, if wrong id direct return error validator = BaseValidator(request.data,rules,attribute) error = validator.validate() if error: raise ValidationError(error) # custom error after basic validation if error: raise ValidationError(error) def post(self, request): # Validate input try: self.api_log_skip_outgoing_data=True self.validate_request(request) academic_term_id = request.data.get("academic_term_id") academic_term = TtAcademicTerm.objects.filter(id=academic_term_id).prefetch_related("week").first() # activities = ( # TtActivity.objects # .select_related("activity_template","department","academic_term", "week_pattern","module","activity_type","zone", "availability", "start_preference", "usage_preference") # .prefetch_related( # "week", # "week_pattern__week", # "tag__tag" # # tags means the relation add in models, __tag means the relation table tag_id get the tag object #2 # ) # .filter(academic_term_id=academic_term_id) # ) # # info = [] # if activities: # for activity in activities: # info_data = { # "id": activity.id, # "code": activity.code, # "name": activity.name, # "desc": activity.desc, # "duration": activity.duration, # "activity_type_id": activity.activity_type_id, # "activity_template_id": activity.activity_template_id, # "department_id": activity.department_id, # "zone_id": activity.zone_id, # "academic_term_id": activity.academic_term_id, # "planned_size": activity.planned_size, # "real_size": activity.real_size, # "module_id": activity.module_id, # 'scheduled_start_time': activity.scheduled_start_time, # 'scheduled_day': activity.scheduled_day, # 'suggested_day': activity.scheduled_day, # "week_pattern_id": activity.week_pattern_id, # "week_pattern_name": activity.week_pattern.name if activity.week_pattern else "-", # "week_pattern": [week.id for week in activity.week.all()], # "availability_id": activity.availability_id, # "availability_name": activity.availability.name if activity.availability else "-", # "availability_pattern": activity.availability_pattern, # "usage_preference_id": activity.usage_preference_id, # "usage_preference_name": activity.usage_preference.name if activity.usage_preference else "-", # "usage_preference_pattern": activity.usage_preference_pattern, # "start_preference_id": activity.start_preference_id, # "start_preference_name": activity.start_preference.name if activity.start_preference else "-", # "start_preference_pattern": activity.start_preference_pattern, # "tag": [t.tag_id for t in activity.tag.all()], # } # # for i in range(1, 11): # extra_data_field = f"extra_data_{i}" # info_data[extra_data_field] = getattr(activity, extra_data_field, None) # # info.append(info_data) data = {} data['delete_confirmation_api'] = False data["allow_remove"] = [ "desc", "department_id", "zone_id", "sequence_number", "suggested_day", "suggested_time", "week_pattern", "week_pattern_id", "availability_id", "availability_pattern", "start_preference_id", "start_preference_pattern", "usage_preference_id", "usage_preference_pattern", "tag", *[f"extra_data_{i}" for i in range(1, 11)] ] setting_params = { "minute_per_slot", "slot_per_day", "slot_per_week", } data['based_setting'] = TtSetting.get_multiple_setting(setting_params) models = { "academic_term": (TtAcademicTerm,["id", "code", "name", "start_time", "end_time", "default_availability","default_usage", "default_start"]), "department": (TtDepartment, ["id", "code", "name"]), "activity_template": (TtActivityTemplate, ["id", "code", "name"]), "zone": (TtZone, ["id", "code", "name"]), "staff": (TtStaff, ["id", "code", "name"]), "location": (TtLocation, ["id", "code", "name"]), "activity_type": (TtActivityType, ["id", "code", "name","color"]), "module": (TtModule, ["id", "code", "name"]), "availability": (TtAvailability, ["id", "code", "name", "pattern"]), "start_preference": (TtStartPreference, ["id","code", "name", "pattern"]), "usage_preference": (TtUsagePreference, ["id", "code", "name", "pattern"]), "tag": (TtTag, ["id", "code", "name"]), } for key, (model, fields) in models.items(): if key == "academic_term": data[key] = list( model.objects.filter(id=academic_term_id,status=model.STATUS_TO_CODE['active']).values(*fields) ) elif key in ["activity_template"]: data[key] = list( model.objects.filter(academic_term_id=academic_term_id,status=model.STATUS_TO_CODE['active']).values(*fields) ) else: data[key] = list( model.objects.filter(status=model.STATUS_TO_CODE['active']).values(*fields) ) # duration based on academic term and based setting minute_per_slot = int(data["based_setting"]["minute_per_slot"]) slot_per_day = int(data["based_setting"]["slot_per_day"]) start = datetime.datetime.strptime("00:00", "%H:%M") data["duration"] = [] current = start current_minute = 0 total_slot = 48 for slot in range(0, total_slot + 1): # dun show slot 0 if slot != 0: data["duration"].append({ "minute": current_minute, "slot": slot, "name": f"{current.strftime('%H:%M')} {__("attr.hours")} ({slot} {__('attr.period')})" }) current += datetime.timedelta(minutes=minute_per_slot) current_minute += minute_per_slot data['suggested_time'] = [] # Convert to datetime (use dummy date), cause time format not support timedelta to add minute today = datetime.date.today() suggested_time_start = datetime.datetime.combine(today, academic_term.start_time) suggested_time_end = datetime.datetime.combine(today, academic_term.end_time) delta = datetime.timedelta(minutes=minute_per_slot) while suggested_time_start <= suggested_time_end: data["suggested_time"].append({ "id": suggested_time_start.strftime('%H:%M'), "name": suggested_time_start.strftime('%H:%M') }) suggested_time_start += delta week_patterns = TtWeekPattern.objects.prefetch_related("week").filter(academic_term_id=academic_term_id,status=TtWeekPattern.STATUS_TO_CODE['active']) data["week_pattern"] = [] for week_pattern in week_patterns: data['week_pattern'].append({ "id": week_pattern.id, "code": week_pattern.code, "name": week_pattern.name, "academic_term_id": week_pattern.academic_term_id, "pattern": week_pattern.week.all().values("week","start_date"), }) data['week'] = list(academic_term.week.all().values("id","week","start_date").order_by("week")) # data['week'] = list(TtWeek.objects.filter(id__in=week_ids).values("id","week").order_by("week")) # FOR DISPLAY MODULE NAME ONLY # pos_module_group_modules = ( # TtPosModuleGroupModule.objects # .filter(pos_module_group__pos__academic_term_id=academic_term_id) # .select_related("pos_module_group", "pos_module_group__module_group", "module") # ) # # # make the pos_module_group_modules data key by pos_id, so it can filter inside pos rules # modules_by_pos = defaultdict(list) # pos_used_module = defaultdict(set) # used_module = set() # # data['module'] = [] # for val in pos_module_group_modules: # pos_id = val.pos_module_group.pos_id # # # Skip duplicate module_code for same POS # if val.module.id in pos_used_module[pos_id]: # continue # # pos_used_module[pos_id].add(val.module.id) # modules_by_pos[pos_id].append({ # # "pos_module_group_module_id": val.id, # "module_id": val.module.id, # "module_name": val.module.name, # "module_code": val.module.code, # # "module_group_name": val.pos_module_group.module_group.name, # }) # # if val.module.id not in used_module: # used_module.add(val.module.id) # data['module'].append({ # "id": val.module.id, # "name": val.module.name, # "code": val.module.code, # }) data['days'] = [] for i in range(0,7): data['days'].append({ "id": i, "name": __("attr.days_name."+str(i)) }) response = { "info": [], "rules": data, } return self.api_response(data=response) except ValidationError as e: first_message = e.detail['error'] errors = e.detail['errors'] return self.api_response(error=first_message,errors=errors,code=status.HTTP_400_BAD_REQUEST) except Exception as e: e_details = get_exception_detail(e) log_critical_error(user_id=None,descr=e_details['descr'],url=e_details['url'],trace=e_details['trace']) return self.api_response(error=__("message.internal_server_error"),code=status.HTTP_500_INTERNAL_SERVER_ERROR)