Subversion Repositories SmartDukaan

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

	public ResponseEntity<?> getBeatVisits(@RequestParam String planGroupId) {

		List<BeatPlan> visits = beatPlanRepository.selectByPlanGroupId(planGroupId);

		List<Map<String, Object>> result = visits.stream().map(v -> {

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

			map.put("fofoId", v.getFofoId());

			map.put("dayNumber", v.getDayNumber());

			map.put("sequenceOrder", v.getSequenceOrder());

			map.put("visitType", v.getVisitType());

			return map;

		}).collect(Collectors.toList());

		return responseSender.ok(result);

	}

			String displayAddress = null;

					// Build clean address for geocoding: city, state, pincode, India

					geoAddress = com.spice.profitmandi.service.GeocodingService.buildGeoAddress(

							retailer.getAddress().getLine1(),

							retailer.getAddress().getCity(),

							retailer.getAddress().getState(),

							retailer.getAddress().getPinCode());

	// ============ BULK UPLOAD ============

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

	public String bulkUploadPage(HttpServletRequest request, Model model) {

		return "beat-plan-bulk";

	}

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

	public ResponseEntity<?> downloadTemplate() {

		String csv = "beat_name,auth_user_id,start_date,day_number,partner_codes\n";

		csv += "Jaipur East Route,280,2026-06-02,1,\"RJKAI1478,RJBUN1449,RJDEG1443\"\n";

		csv += ",280,,2,\"RJALR1362,RJBTR1388\"\n";

		csv += ",280,,3,\"RJRSD1518,RJSML356\"\n";

		csv += "Agra Circuit,145,2026-06-05,1,\"UPAGR101,UPAGR102\"\n";

		org.springframework.http.HttpHeaders headers = new org.springframework.http.HttpHeaders();

		headers.add("Content-Disposition", "attachment; filename=beat_plan_template.csv");

		headers.add("Content-Type", "text/csv");

		return new ResponseEntity<>(csv, headers, org.springframework.http.HttpStatus.OK);

	}

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

	public ResponseEntity<?> bulkUploadProcess(

			HttpServletRequest request,

			@RequestParam("file") org.springframework.web.multipart.MultipartFile file,

			@RequestParam(value = "includeSundays", defaultValue = "false") boolean includeSundays) throws Exception {

		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);

		AuthUser currentUser = authRepository.selectByEmailOrMobile(loginDetails.getEmailId());

		java.io.Reader reader = new java.io.InputStreamReader(file.getInputStream());

		org.apache.commons.csv.CSVParser parser = new org.apache.commons.csv.CSVParser(reader,

				org.apache.commons.csv.CSVFormat.DEFAULT.withFirstRecordAsHeader().withTrim());

		// Each row = one day: beat_name, auth_user_id, start_date (only on day 1), day_number, partner_codes

		// First pass: collect all records, normalize beat_name

		List<org.apache.commons.csv.CSVRecord> allRecords = parser.getRecords();

		parser.close();

		// Track last beat_name per auth_user_id for blank name rows

		Map<String, String> lastBeatNameByUser = new HashMap<>();

		Map<String, List<org.apache.commons.csv.CSVRecord>> beatGroups = new LinkedHashMap<>();

		// Also store resolved beat names since CSVRecord is immutable

		Map<Long, String> resolvedBeatNames = new HashMap<>();

		for (org.apache.commons.csv.CSVRecord record : allRecords) {

			String authId = record.get("auth_user_id").trim();

			String rawName = record.get("beat_name").trim();

			// Normalize: collapse multiple spaces, trim

			String beatName = rawName.replaceAll("\\s+", " ").trim();

			// If blank, use last beat_name for this auth_user_id

			if (beatName.isEmpty()) {

				beatName = lastBeatNameByUser.getOrDefault(authId, "Beat");

			} else {

				lastBeatNameByUser.put(authId, beatName);

			}

			resolvedBeatNames.put(record.getRecordNumber(), beatName);

			String key = beatName + "|" + authId;

			beatGroups.computeIfAbsent(key, k -> new ArrayList<>()).add(record);

		}

		// Build FofoStore code → id lookup

		List<FofoStore> allStores = fofoStoreRepository.selectAll();

		Map<String, Integer> codeToId = new HashMap<>();

		for (FofoStore store : allStores) {

			codeToId.put(store.getCode(), store.getId());

		}

		// Load holidays for validation

		LocalDate holidayStart = LocalDate.now();

		LocalDate holidayEnd = holidayStart.plusMonths(6);

		List<PublicHolidays> holidays = publicHolidaysRepository.selectAllBetweenDates(holidayStart, holidayEnd);

		Set<LocalDate> holidayDates = holidays.stream().map(PublicHolidays::getDate).collect(Collectors.toSet());

		int beatsCreated = 0;

		int errors = 0;

		List<String> errorMessages = new ArrayList<>();

		for (Map.Entry<String, List<org.apache.commons.csv.CSVRecord>> entry : beatGroups.entrySet()) {

			try {

				String[] keyParts = entry.getKey().split("\\|");

				String beatName = keyParts[0];

				int authUserId = Integer.parseInt(keyParts[1]);

				List<org.apache.commons.csv.CSVRecord> rows = entry.getValue();

				// Sort rows by day_number

				rows.sort((a, b) -> Integer.parseInt(a.get("day_number").trim()) - Integer.parseInt(b.get("day_number").trim()));

				// Get start_date from first row

				String startDateStr = rows.get(0).get("start_date").trim();

				LocalDate startDate = null;

				if (!startDateStr.isEmpty()) {

					startDate = LocalDate.parse(startDateStr, DateTimeFormatter.ISO_DATE);

				}

				// Validate start date

				if (startDate != null && startDate.isBefore(LocalDate.now())) {

					errorMessages.add("Beat '" + beatName + "': start_date " + startDate + " is in the past. Skipped.");

					errors++;

					continue;

				}

				// Auto-calculate dates for each day, skipping Sundays and holidays

				int totalDays = rows.size();

				List<LocalDate> scheduleDates = new ArrayList<>();

				if (startDate != null) {

					LocalDate d = startDate;

					while (scheduleDates.size() < totalDays) {

						boolean isSunday = d.getDayOfWeek() == DayOfWeek.SUNDAY;

						boolean isHoliday = holidayDates.contains(d);

						if (isHoliday) {

							// Always skip holidays

							errorMessages.add("Beat '" + beatName + "': skipping " + d + " (Holiday)");

						} else if (isSunday && !includeSundays) {

							// Skip Sunday only if not including Sundays

							errorMessages.add("Beat '" + beatName + "': skipping " + d + " (Sunday)");

						} else {

							scheduleDates.add(d);

							if (isSunday) {

								errorMessages.add("Beat '" + beatName + "': including Sunday " + d);

							}

						}

						d = d.plusDays(1);

					}

				}

				String planGroupId = UUID.randomUUID().toString();

				String beatColor = BEAT_COLORS[Math.abs(planGroupId.hashCode()) % BEAT_COLORS.length];

				// Get home location for this auth user

				AuthUserLocation homeLoc = authUserLocationRepository.selectLatestByAuthUserIdAndType(authUserId, "BASE");

				String homeName = homeLoc != null ? homeLoc.getLocationName() : "Home";

				String homeLat = homeLoc != null ? homeLoc.getLatitude() : null;

				String homeLng = homeLoc != null ? homeLoc.getLongitude() : null;

				int totalRows = rows.size();

				for (int rowIdx = 0; rowIdx < totalRows; rowIdx++) {

					org.apache.commons.csv.CSVRecord row = rows.get(rowIdx);

					int dayNumber = Integer.parseInt(row.get("day_number").trim());

					boolean isFirstDay = (rowIdx == 0);

					boolean isLastDay = (rowIdx == totalRows - 1);

					LocalDate planDate = (rowIdx < scheduleDates.size()) ? scheduleDates.get(rowIdx) : null;

					// Save BeatPlanDay

					BeatPlanDay bpDay = new BeatPlanDay();

					bpDay.setPlanGroupId(planGroupId);

					bpDay.setAuthUserId(authUserId);

					bpDay.setDayNumber(dayNumber);

					bpDay.setPlanDate(planDate);

					bpDay.setBeatName(beatName);

					bpDay.setBeatColor(beatColor);

					// Start location: Day 1 starts from home, other days start from home too (each day starts fresh)

					bpDay.setStartLocationName(homeName);

					bpDay.setStartLatitude(homeLat);

					bpDay.setStartLongitude(homeLng);

					// End action: last day = HOME (return home), other days = DAYBREAK

					if (isLastDay) {

						bpDay.setEndAction("HOME");

					} else {

						bpDay.setEndAction("DAYBREAK");

					}

					bpDay.setCreatedBy(currentUser.getId());

					bpDay.setCreatedTimestamp(LocalDateTime.now());

					bpDay.setActive(true);

					beatPlanDayRepository.persist(bpDay);

					// Parse comma-separated partner codes

					String partnerCodesStr = row.get("partner_codes").trim();

					String[] partnerCodes = partnerCodesStr.split(",");

					for (int i = 0; i < partnerCodes.length; i++) {

						String partnerCode = partnerCodes[i].trim();

						if (partnerCode.isEmpty()) continue;

						Integer fofoId = codeToId.get(partnerCode);

						if (fofoId == null) {

							errorMessages.add("Partner code not found: " + partnerCode + " in beat '" + beatName + "'");

							errors++;

							continue;

						}

						BeatPlan bp = new BeatPlan();

						bp.setAuthUserId(authUserId);

						bp.setFofoId(fofoId);

						bp.setVisitType("partner");

						bp.setDayNumber(dayNumber);

						bp.setPlanGroupId(planGroupId);

						bp.setPlanDate(planDate);

						bp.setSequenceOrder(i);

						bp.setCreatedBy(currentUser.getId());

						bp.setCreatedTimestamp(LocalDateTime.now());

						bp.setUpdatedTimestamp(LocalDateTime.now());

						bp.setActive(true);

						beatPlanRepository.persist(bp);

					}

				}

				beatsCreated++;

				// Log scheduled dates

				if (!scheduleDates.isEmpty()) {

					errorMessages.add("Beat '" + beatName + "' for user " + authUserId + " scheduled on: " +

							scheduleDates.stream().map(LocalDate::toString).collect(Collectors.joining(", ")));

				}

			} catch (Exception e) {

				errors++;

				errorMessages.add("Error processing beat: " + entry.getKey() + " - " + e.getMessage());

				LOGGER.error("Bulk upload error for {}: {}", entry.getKey(), e.getMessage());

			}

		}

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

		response.put("status", true);

		response.put("beatsCreated", beatsCreated);

		response.put("errors", errors);

		response.put("errorMessages", errorMessages);

		return responseSender.ok(response);

	}

				authUserId, LocalDate.of(2000, 1, 1), LocalDate.of(2099, 12, 31));