Subversion Repositories SmartDukaan

	private com.spice.profitmandi.dao.service.BeatPlanQueryService beatPlanQueryService;

	@Autowired

	@Autowired

	private com.spice.profitmandi.dao.repository.dtr.LeadLiveLocationRepository leadLiveLocationRepositoryAuto;

	// ====================== DAY VIEW ======================

	// Inline page (loaded into dashboard #main-content): tabular list of all beats

	// scheduled in a date range across all users. Each row has a View button that

	// opens that user's calendar in a modal.

	@GetMapping(value = "/beatPlan/dayView")

	public String beatPlanDayView(HttpServletRequest request, Model model) {

		EscalationType[] escalationTypes = EscalationType.values();

		model.addAttribute("escalationTypes", escalationTypes);

		return "beat-plan-day-view";

	}

	// Tabular JSON: one row per (beat, scheduled date) in [startDate, endDate].

	@GetMapping(value = "/beatPlan/scheduledList")

	public ResponseEntity<?> scheduledList(

			@RequestParam(required = false) String startDate,

			@RequestParam(required = false) String endDate) {

		LocalDate start, end;

		try {

			start = (startDate == null || startDate.isEmpty()) ? LocalDate.now() : LocalDate.parse(startDate);

			end = (endDate == null || endDate.isEmpty()) ? start.plusDays(7) : LocalDate.parse(endDate);

		} catch (Exception e) {

			return responseSender.badRequest("Invalid date — expected yyyy-MM-dd");

		}

		List<com.spice.profitmandi.dao.model.BeatDayDetails> beats =

				beatPlanQueryService.getAllScheduledBeats(start, end);

		// Resolve user names in bulk

		Set<Integer> userIds = beats.stream()

				.map(com.spice.profitmandi.dao.model.BeatDayDetails::getAuthUserId)

				.collect(java.util.stream.Collectors.toSet());

		Map<Integer, AuthUser> userMap = new HashMap<>();

		if (!userIds.isEmpty()) {

			authRepository.selectByIds(new ArrayList<>(userIds))

					.forEach(u -> userMap.put(u.getId(), u));

		}

		List<Map<String, Object>> rows = new ArrayList<>();

		for (com.spice.profitmandi.dao.model.BeatDayDetails b : beats) {

			AuthUser u = userMap.get(b.getAuthUserId());

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

			row.put("authUserId", b.getAuthUserId());

			row.put("userName", u != null ? (u.getFirstName() + " " + u.getLastName()) : "User #" + b.getAuthUserId());

			row.put("scheduleDate", b.getScheduleDate().toString());

			row.put("dayNumber", b.getDayNumber());

			row.put("beatId", b.getBeatId());

			row.put("beatName", b.getBeatName());

			row.put("beatColor", b.getBeatColor());

			row.put("partnerCount", b.getPartnerStops().size());

			row.put("leadCount", b.getLeadStops().size());

			row.put("visitCount", b.getPartnerStops().size() + b.getLeadStops().size());

			rows.add(row);

		}

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

		result.put("rows", rows);

		result.put("startDate", start.toString());

		result.put("endDate", end.toString());

		return responseSender.ok(result);

	}

	// JSON: beats running for (authUserId, date) — enriched with partner/lead names & coords

	@GetMapping(value = "/beatPlan/dayViewData")

	public ResponseEntity<?> beatPlanDayViewData(

			@RequestParam int authUserId,

			@RequestParam String date) throws ProfitMandiBusinessException {

		LocalDate localDate;

		try {

			localDate = LocalDate.parse(date);

		} catch (Exception e) {

			return responseSender.badRequest("Invalid date — expected yyyy-MM-dd");

		}

		List<com.spice.profitmandi.dao.model.BeatDayDetails> beats =

				beatPlanQueryService.getBeatsForUserOnDate(authUserId, localDate);

		// Collect all partner & lead IDs to fetch metadata in bulk

		Set<Integer> partnerIds = new HashSet<>();

		Set<Integer> leadIds = new HashSet<>();

		for (com.spice.profitmandi.dao.model.BeatDayDetails b : beats) {

			b.getPartnerStops().forEach(s -> partnerIds.add((Integer) s.get("fofoId")));

			b.getLeadStops().forEach(s -> leadIds.add((Integer) s.get("leadId")));

		}

		// Partners: name + geocoded lat/lng (geocoder is cached in Redis)

		Map<Integer, CustomRetailer> retailerMap = partnerIds.isEmpty()

				? new HashMap<>()

				: retailerService.getFofoRetailers(new ArrayList<>(partnerIds));

		Map<Integer, FofoStore> storeMap = new HashMap<>();

		if (!partnerIds.isEmpty()) {

			fofoStoreRepository.selectByRetailerIds(new ArrayList<>(partnerIds))

					.forEach(fs -> storeMap.put(fs.getId(), fs));

		}

		// Leads: name + geo

		Map<Integer, com.spice.profitmandi.dao.entity.user.Lead> leadMap = new HashMap<>();

		Map<Integer, com.spice.profitmandi.dao.entity.user.LeadLiveLocation> leadGeoMap = new HashMap<>();

		for (int leadId : leadIds) {

			com.spice.profitmandi.dao.entity.user.Lead l = leadRepository.selectById(leadId);

			if (l != null) leadMap.put(leadId, l);

			com.spice.profitmandi.dao.entity.user.LeadLiveLocation lg =

					leadLiveLocationRepositoryAuto.selectApprovedByLeadId(leadId);

			if (lg != null) leadGeoMap.put(leadId, lg);

		}

		// Enrich each stop

		List<Map<String, Object>> out = new ArrayList<>();

		for (com.spice.profitmandi.dao.model.BeatDayDetails b : beats) {

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

			beatJson.put("beatId", b.getBeatId());

			beatJson.put("beatName", b.getBeatName());

			beatJson.put("beatColor", b.getBeatColor());

			beatJson.put("dayNumber", b.getDayNumber());

			beatJson.put("scheduleDate", b.getScheduleDate().toString());

			beatJson.put("endAction", b.getEndAction());

			beatJson.put("totalDistanceKm", b.getTotalDistanceKm());

			beatJson.put("totalTimeMins", b.getTotalTimeMins());

			beatJson.put("startLocationName", b.getStartLocationName());

			beatJson.put("startLatitude", b.getStartLatitude());

			beatJson.put("startLongitude", b.getStartLongitude());

			List<Map<String, Object>> stops = new ArrayList<>();

			// Partners

			for (Map<String, Object> ps : b.getPartnerStops()) {

				int fofoId = (Integer) ps.get("fofoId");

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

				stop.put("type", "partner");

				stop.put("id", fofoId);

				stop.put("sequenceOrder", ps.get("sequenceOrder"));

				FofoStore fs = storeMap.get(fofoId);

				CustomRetailer cr = retailerMap.get(fofoId);

				stop.put("code", fs != null ? fs.getCode() : null);

				stop.put("name", fs != null && fs.getOutletName() != null ? fs.getOutletName()

						: (cr != null ? cr.getBusinessName() : "Store #" + fofoId));

				if (cr != null && cr.getAddress() != null) {

					stop.put("address", cr.getAddress().getAddressString());

					try {

						String geoAddr = com.spice.profitmandi.service.GeocodingService.buildGeoAddress(

								cr.getAddress().getLine1(), cr.getAddress().getCity(),

								cr.getAddress().getState(), cr.getAddress().getPinCode());

						double[] coords = geocodingService.geocodeAddress(geoAddr);

						if (coords != null) {

							stop.put("lat", coords[0]);

							stop.put("lng", coords[1]);

						}

					} catch (Exception ignored) {

					}

				}

				stops.add(stop);

			}

			// Leads

			for (Map<String, Object> ls : b.getLeadStops()) {

				int leadId = (Integer) ls.get("leadId");

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

				stop.put("type", "lead");

				stop.put("id", leadId);

				stop.put("sequenceOrder", ls.get("sequenceOrder"));

				stop.put("nearestStoreId", ls.get("nearestStoreId"));

				com.spice.profitmandi.dao.entity.user.Lead l = leadMap.get(leadId);

				stop.put("name", l != null ? l.getFirstName() + " " + l.getLastName() : "Lead #" + leadId);

				stop.put("mobile", l != null ? l.getLeadMobile() : null);

				stop.put("city", l != null ? l.getCity() : null);

				com.spice.profitmandi.dao.entity.user.LeadLiveLocation lg = leadGeoMap.get(leadId);

				if (lg != null) {

					stop.put("lat", lg.getLatitude());

					stop.put("lng", lg.getLongitude());

				}

				stops.add(stop);

			}

			beatJson.put("stops", stops);

			beatJson.put("partnerCount", b.getPartnerStops().size());

			beatJson.put("leadCount", b.getLeadStops().size());

			out.add(beatJson);

		}

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

		result.put("beats", out);

		return responseSender.ok(result);

	}