[UPDT] BIOMETRIC: Updated anviz_biometric_attendance_logs function to sync with device direction

biometric/views.py

@@ -2275,57 +2275,107 @@ def zk_biometric_attendance_scheduler(device_id):
 
 def anviz_biometric_attendance_logs(device):
     """
-    Retrieves attendance records from an Anviz biometric device and processes them.
-
-    :param device_id: The Object Id of the Anviz biometric device.
+    Retrieves attendance records from an Anviz biometric device
+    and processes them based on device direction configuration.
     """
+
     current_utc_time = datetime.utcnow()
+
     anviz_device = CrossChexCloudAPI(
         api_url=device.api_url,
         api_key=device.api_key,
         api_secret=device.api_secret,
         anviz_request_id=device.anviz_request_id,
     )
+
     begin_time = (
         datetime.combine(device.last_fetch_date, device.last_fetch_time)
         if device.last_fetch_date and device.last_fetch_time
         else current_utc_time.replace(hour=0, minute=0, second=0, microsecond=0)
     )
+
     attendance_records = anviz_device.get_attendance_records(
-        begin_time=begin_time, token=device.api_token
+        begin_time=begin_time,
+        token=device.api_token,
     )
-    device.last_fetch_date, device.last_fetch_time = (
-        current_utc_time.date(),
-        current_utc_time.time(),
-    )
-    device.save()
-    for attendance in attendance_records["list"]:
+
+    # Update last fetch time immediately
+    device.last_fetch_date = current_utc_time.date()
+    device.last_fetch_time = current_utc_time.time()
+    device.save(update_fields=["last_fetch_date", "last_fetch_time"])
+
+    processed_count = 0
+
+    for attendance in attendance_records.get("list", []):
         badge_id = attendance["employee"]["workno"]
         punch_code = attendance["checktype"]
+
         date_time_utc = datetime.strptime(
             attendance["checktime"], "%Y-%m-%dT%H:%M:%S%z"
         )
         date_time_obj = date_time_utc.astimezone(django_timezone.get_current_timezone())
+
         employee = Employee.objects.filter(badge_id=badge_id).first()
-        if employee:
-            request_data = Request(
-                user=employee.employee_user_id,
-                date=date_time_obj.date(),
-                time=date_time_obj.time(),
-                datetime=date_time_obj,
-            )
-            if punch_code in {0, 128}:
-                try:
+        if not employee:
+            continue
+
+        request_data = Request(
+            user=employee.employee_user_id,
+            date=date_time_obj.date(),
+            time=date_time_obj.time(),
+            datetime=date_time_obj,
+        )
+
+        try:
+            # --------------------------------------------------
+            # SYSTEM DIRECTION (auto based on punch code)
+            # --------------------------------------------------
+            if device.device_direction == "system":
+                if punch_code in {0, 128}:
                     clock_in(request_data)
-                except Exception as error:
-                    logger.error("Error in clock in ", error)
-            else:
-                try:
-                    # // 1 , 129 check type check out and door close
+                else:
                     clock_out(request_data)
-                except Exception as error:
-                    logger.error("Error in clock out ", error)
-    return len(attendance_records["list"])
+
+            # --------------------------------------------------
+            # FORCE IN DEVICE
+            # --------------------------------------------------
+            elif device.device_direction == "in":
+                clock_in(request_data)
+
+            # --------------------------------------------------
+            # FORCE OUT DEVICE
+            # --------------------------------------------------
+            elif device.device_direction == "out":
+                clock_out(request_data)
+
+            # --------------------------------------------------
+            # ALTERNATE IN / OUT DEVICE
+            # --------------------------------------------------
+            elif device.device_direction == "alternate":
+                last_activity = (
+                    AttendanceActivity.objects.filter(
+                        employee_id=employee,
+                        attendance_date=date_time_obj.date(),
+                    )
+                    .order_by("-in_datetime", "-out_datetime")
+                    .first()
+                )
+
+                # If no record or last record has clock_out → IN
+                if not last_activity or last_activity.clock_out:
+                    clock_in(request_data)
+                else:
+                    clock_out(request_data)
+
+            processed_count += 1
+
+        except Exception as error:
+            logger.error(
+                f"Attendance sync failed for employee {employee.id}",
+                exc_info=error,
+            )
+
+    return processed_count
 
 
 def anviz_biometric_attendance_scheduler(device_id):