Subversion Repositories SmartDukaan

    private LeadLiveLocationRepository leadLiveLocationRepository;

    @Autowired

    private LeadVisitApprovalRepository leadVisitApprovalRepository;

    @Autowired

        // Geo location status map for all leads

        if (!leads.isEmpty()) {

            List<Integer> allLeadIds = leads.stream().map(Lead::getId).collect(Collectors.toList());

            Map<Integer, LeadLiveLocation> geoLocationMap = leadLiveLocationRepository.selectByLeadIds(allLeadIds).stream()

                    .collect(Collectors.toMap(LeadLiveLocation::getLeadId, x -> x, (a, b) -> a));

            model.addAttribute("geoLocationMap", geoLocationMap);

        } else {

            model.addAttribute("geoLocationMap", new HashMap<>());

        }

        model.addAttribute("salesUsers", salesUsers);

        model.addAttribute("bgcUsers", bgcUsers);

        // Validate approved geolocation for physical visit

        if (createLeadActivityRequest.getStatus() == LeadStatus.followUp

                && createLeadActivityRequest.getCommunicationType() != null

                && createLeadActivityRequest.getCommunicationType().equals(CommunicationType.VISIT)) {

            LeadLiveLocation approvedGeo = leadLiveLocationRepository.selectApprovedByLeadId(createLeadActivityRequest.getId());

            if (approvedGeo == null) {

                throw new ProfitMandiBusinessException("Lead", "", "Missing Valid Live Geo Location for the lead");

            }

        }

                // Create pending visit approval instead of direct visit request

                LeadVisitApproval approval = new LeadVisitApproval();

                approval.setLeadId(createLeadActivityRequest.getId());

                approval.setAssignedTo(createLeadActivityRequest.getAssignTo());

                approval.setRequestedBy(authUser.getId());

                approval.setStatus("PENDING");

                approval.setCreatedTimestamp(LocalDateTime.now());

                approval.setUpdatedTimestamp(LocalDateTime.now());

                // Parse beat selection if provided (format: "date|beatName|planGroupId")

                String beatSelection = createLeadActivityRequest.getBeatSelection();

                if (beatSelection != null && beatSelection.contains("|")) {

                    String[] parts = beatSelection.split("\\|", 3);

                    approval.setBeatDate(LocalDate.parse(parts[0]));

                    approval.setBeatName(parts.length > 1 ? parts[1] : "");

                    if (parts.length > 2) {

                        approval.setBeatPlanGroupId(parts[2]);

                    }

                } else if (createLeadActivityRequest.getScheldule() != null) {

                    approval.setBeatDate(createLeadActivityRequest.getScheldule().toLocalDate());

                }

                leadVisitApprovalRepository.persist(approval);

                // Log activity

                LeadActivity approvalActivity = new LeadActivity();

                approvalActivity.setLeadId(createLeadActivityRequest.getId());

                approvalActivity.setRemark("Visit requested on beat: " + approval.getBeatName()

                        + " (" + approval.getBeatDate() + ") - Pending L4 approval");

                approvalActivity.setAuthId(authUser.getId());

                approvalActivity.setCreatedTimestamp(LocalDateTime.now());

                leadActivityRepository.persist(approvalActivity);