Subversion Repositories SmartDukaan

import com.spice.profitmandi.dao.repository.fofo.RatingReminderRepository;

    @RequestMapping(value = "/rbmRating/weekly-status", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)

    public ResponseEntity<?> rbmRatingWeeklyStatus(HttpServletRequest request) throws Exception {

        int userId = (int) request.getAttribute(ProfitMandiConstants.USER_ID);

        UserCart uc = userAccountRepository.getUserCart(userId);

        int fofoId = uc.getUserId();

        int rbmL1 = csService.getAuthUserId(ProfitMandiConstants.TICKET_CATEGORY_RBM, EscalationType.L1, fofoId);

        int salesL1Id = csService.getAuthUserId(ProfitMandiConstants.TICKET_CATEGORY_SALES, EscalationType.L1, fofoId);

        // Calculate current week boundaries (Monday to Sunday)

        LocalDate today = LocalDate.now();

        LocalDate startOfWeek = today.with(TemporalAdjusters.previousOrSame(DayOfWeek.MONDAY));

        LocalDate endOfWeek = today.with(TemporalAdjusters.nextOrSame(DayOfWeek.SUNDAY));

        LocalDateTime startOfWeekDateTime = startOfWeek.atStartOfDay();

        LocalDateTime endOfWeekDateTime = endOfWeek.atTime(23, 59, 59);

        List<RbmRating> existingRbmRatings = rbmRatingRepository.findByFofoIdAndRbmIdForCurrentMonth(fofoId, rbmL1, startOfWeekDateTime, endOfWeekDateTime);

        List<SalesRating> existingSalesRatings = salesRatingRepository.findByFofoIdAndSalesL1IdForCurrentMonth(fofoId, salesL1Id, startOfWeekDateTime, endOfWeekDateTime);

        boolean pending = existingRbmRatings.isEmpty() || existingSalesRatings.isEmpty();

        Map<String, Object> response = new HashMap<>();

        response.put("pending", pending);

        response.put("weekStart", startOfWeek.toString());

        response.put("weekEnd", endOfWeek.toString());

        if (rbmL1 > 0) {

            AuthUser rbmUser = authRepository.selectById(rbmL1);

            if (rbmUser != null) {

                response.put("rbmName", rbmUser.getFullName());

            }

        }

        if (salesL1Id > 0) {

            AuthUser salesUser = authRepository.selectById(salesL1Id);

            if (salesUser != null) {

                response.put("salesPersonName", salesUser.getFullName());

            }

        }

        return responseSender.ok(response);

    }

    @Autowired

    private RatingReminderRepository ratingReminderRepository;

    @RequestMapping(value = "/rbmRating/reminder", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)

    public ResponseEntity<?> rbmRatingReminder(HttpServletRequest request) throws Exception {

        int userId = (int) request.getAttribute(ProfitMandiConstants.USER_ID);

        UserCart uc = userAccountRepository.getUserCart(userId);

        int fofoId = uc.getUserId();

        LocalDate today = LocalDate.now();

        LocalDate startOfWeek = today.with(TemporalAdjusters.previousOrSame(DayOfWeek.MONDAY));

        LocalDate endOfWeek = today.with(TemporalAdjusters.nextOrSame(DayOfWeek.SUNDAY));

        RatingReminder reminder = ratingReminderRepository.findByFofoIdAndWeek(fofoId, startOfWeek);

        int attemptsRemaining;

        if (reminder == null) {

            // First hit this week: create entry initialised to MAX, no decrement

            reminder = new RatingReminder();

            reminder.setFofoId(fofoId);

            reminder.setWeekStart(startOfWeek);

            reminder.setWeekEnd(endOfWeek);

            reminder.setAttemptsRemaining(RatingReminder.MAX_ATTEMPTS_PER_WEEK);

            reminder.setCreateTimestamp(LocalDateTime.now());

            ratingReminderRepository.persist(reminder);

            attemptsRemaining = RatingReminder.MAX_ATTEMPTS_PER_WEEK;

        } else {

            // Subsequent hit: atomically decrement (floor 0) and re-read

            ratingReminderRepository.decrementRemaining(reminder.getId());

            reminder = ratingReminderRepository.findByFofoIdAndWeek(fofoId, startOfWeek);

            attemptsRemaining = reminder.getAttemptsRemaining();

        }

        Map<String, Object> response = new HashMap<>();

        response.put("partnerId", fofoId);

        response.put("attemptsRemaining", attemptsRemaining);

        return responseSender.ok(response);

    }