Subversion Repositories SmartDukaan

	private static Double parseDoubleOrNull(String s) {

		if (s == null || s.trim().isEmpty()) return null;

		try {

			return Double.parseDouble(s.trim());

		} catch (NumberFormatException e) {

			return null;

		}

	}

	private static double haversineKm(double lat1, double lng1, double lat2, double lng2) {

		double R = 6371;

		double dLat = Math.toRadians(lat2 - lat1);

		double dLng = Math.toRadians(lng2 - lng1);

		double a = Math.sin(dLat / 2) * Math.sin(dLat / 2)

				+ Math.cos(Math.toRadians(lat1)) * Math.cos(Math.toRadians(lat2))

				* Math.sin(dLng / 2) * Math.sin(dLng / 2);

		double c = 2 * Math.atan2(Math.sqrt(a), Math.sqrt(1 - a));

		return R * c;

	}

	// ====================== BASE LOCATION MANAGEMENT ======================

	// Inline page that lets Sales L3+ pick a user and set their base (home)

	// location via map. Reads use the existing /beatPlan/getBaseLocation, writes

	// go through the L3+-guarded endpoint below.

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

	public String baseLocationPage(HttpServletRequest request, Model model) {

		EscalationType[] escalationTypes = EscalationType.values();

		model.addAttribute("escalationTypes", escalationTypes);

		return "beat-plan-base-location";

	}

	@PostMapping(value = "/beatPlan/updateBaseLocation")

	public ResponseEntity<?> updateBaseLocation(

			HttpServletRequest request,

			@RequestParam int authUserId,

			@RequestParam String locationName,

			@RequestParam String latitude,

			@RequestParam String longitude,

			@RequestParam(required = false) String address) throws Exception {

		LoginDetails ld = cookiesProcessor.getCookiesObject(request);

		AuthUser me = authRepository.selectByEmailOrMobile(ld.getEmailId());

		if (me == null) return responseSender.badRequest("Not logged in");

		// Permission gate: only Sales L3 and above

		boolean isSalesL3Plus = csService.getAuthUserIds(

						com.spice.profitmandi.common.model.ProfitMandiConstants.TICKET_CATEGORY_SALES,

						Arrays.asList(EscalationType.L3, EscalationType.L4))

				.stream().anyMatch(u -> u.getId() == me.getId());

		if (!isSalesL3Plus) {

			return responseSender.badRequest("Only Sales L3 and above can update base location");

		}

		AuthUserLocation loc = new AuthUserLocation();

		loc.setAuthUserId(authUserId);

		loc.setLocationType("BASE");

		loc.setLocationName(locationName);

		loc.setLatitude(latitude);

		loc.setLongitude(longitude);

		loc.setAddress(address);

		loc.setCreatedTimestamp(LocalDateTime.now());

		authUserLocationRepository.persist(loc);

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

		result.put("status", true);

		result.put("id", loc.getId());

		result.put("message", "Base location updated");

		return responseSender.ok(result);

	}

	// ====================== ONE-TIME LAT/LNG MIGRATION ======================

	// For each active fofo_store, compare its stored lat/lng with the geocoded

	// address lat/lng (cached in Redis). If the gap is > thresholdKm (default 5)

	// OR the store has no lat/lng yet, update the store with the geocoded

	// coordinates. Otherwise keep the existing values.

	//

	// Usage:

	//   GET /beatPlan/migrateStoreLatLng              -> dry run, default 5km, all

	//   GET /beatPlan/migrateStoreLatLng?apply=true   -> actually update

	//   ?thresholdKm=3      -> use a different threshold

	//   ?limit=100          -> process only N stores (for staged runs)

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

	public ResponseEntity<?> migrateStoreLatLng(

			@RequestParam(required = false, defaultValue = "false") boolean apply,

			@RequestParam(required = false, defaultValue = "5") double thresholdKm,

			@RequestParam(required = false, defaultValue = "0") int limit) throws ProfitMandiBusinessException {

		List<FofoStore> stores = fofoStoreRepository.selectActiveStores();

		if (limit > 0 && stores.size() > limit) stores = stores.subList(0, limit);

		List<Integer> ids = stores.stream().map(FofoStore::getId).collect(Collectors.toList());

		Map<Integer, CustomRetailer> retailerMap = retailerService.getFofoRetailers(ids);

		int total = stores.size();

		int updated = 0, kept = 0, noAddress = 0, noGeocode = 0, errored = 0;

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

		for (FofoStore store : stores) {

			try {

				CustomRetailer retailer = retailerMap.get(store.getId());

				if (retailer == null || retailer.getAddress() == null) {

					noAddress++;

					continue;

				}

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

						retailer.getAddress().getLine1(), retailer.getAddress().getCity(),

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

				if (geoAddr == null || geoAddr.isEmpty()) {

					noAddress++;

					continue;

				}

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

				if (coords == null) {

					noGeocode++;

					continue;

				}

				Double existingLat = parseDoubleOrNull(store.getLatitude());

				Double existingLng = parseDoubleOrNull(store.getLongitude());

				boolean shouldUpdate;

				double distKm = -1;

				String reason;

				if (existingLat == null || existingLng == null) {

					shouldUpdate = true;

					reason = "missing existing lat/lng";

				} else {

					distKm = haversineKm(existingLat, existingLng, coords[0], coords[1]);

					shouldUpdate = distKm > thresholdKm;

					reason = shouldUpdate

							? "gap " + Math.round(distKm * 10.0) / 10.0 + "km > " + thresholdKm + "km"

							: "gap " + Math.round(distKm * 10.0) / 10.0 + "km within " + thresholdKm + "km";

				}

				if (shouldUpdate) {

					if (apply) {

						store.setLatitude(String.valueOf(coords[0]));

						store.setLongitude(String.valueOf(coords[1]));

						fofoStoreRepository.persist(store);

					}

					updated++;

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

					ch.put("storeId", store.getId());

					ch.put("code", store.getCode());

					ch.put("oldLat", existingLat);

					ch.put("oldLng", existingLng);

					ch.put("newLat", coords[0]);

					ch.put("newLng", coords[1]);

					ch.put("distKm", distKm >= 0 ? Math.round(distKm * 10.0) / 10.0 : null);

					ch.put("reason", reason);

					changes.add(ch);

				} else {

					kept++;

				}

			} catch (Exception e) {

				errored++;

				LOGGER.warn("Geocode/migrate failed for fofoId={}: {}", store.getId(), e.getMessage());

			}

		}

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

		result.put("mode", apply ? "APPLIED" : "DRY RUN — pass &apply=true to actually update");

		result.put("thresholdKm", thresholdKm);

		result.put("total", total);

		result.put("updated", updated);

		result.put("kept", kept);

		result.put("noAddress", noAddress);

		result.put("noGeocode", noGeocode);

		result.put("errored", errored);

		// Limit changes preview to avoid huge responses

		result.put("changes", changes.size() > 200 ? changes.subList(0, 200) : changes);

		result.put("changesShownCount", Math.min(changes.size(), 200));

		return responseSender.ok(result);

	}

				// Use FofoStore lat/lng directly (no geocoding needed after migration)

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

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

				}

			// Use FofoStore lat/lng directly (migrated from address geocode)

			if (store.getLatitude() != null && !store.getLatitude().isEmpty()

					&& store.getLongitude() != null && !store.getLongitude().isEmpty()) {

				partnerData.put("latitude", store.getLatitude());

			}