Subversion Repositories SmartDukaan

Rev

Rev 31454 | Rev 31478 | Go to most recent revision | Details | Compare with Previous | Last modification | View Log | RSS feed

Rev Author Line No. Line
25979 tejbeer 1 
package com.spice.profitmandi.web.controller;
2 
 
29266 manish 3 
import com.google.gson.Gson;
31370 tejbeer 4 
import com.mongodb.DBObject;
25988 tejbeer 5 
import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
31422 amit.gupta 6 
import com.spice.profitmandi.common.model.*;
29426 manish 7 
import com.spice.profitmandi.common.util.FileUtil;
31370 tejbeer 8 
import com.spice.profitmandi.common.web.util.ResponseSender;
25979 tejbeer 9 
import com.spice.profitmandi.dao.entity.auth.AuthUser;
30416 tejbeer 10 
import com.spice.profitmandi.dao.entity.fofo.PartnerDailyInvestment;
31422 amit.gupta 11 
import com.spice.profitmandi.dao.entity.user.*;
30773 amit.gupta 12 
import com.spice.profitmandi.dao.enumuration.cs.EscalationType;
31249 tejbeer 13 
import com.spice.profitmandi.dao.enumuration.dtr.CommunicationType;
29598 tejbeer 14 
import com.spice.profitmandi.dao.enumuration.dtr.LeadSource;
25979 tejbeer 15 
import com.spice.profitmandi.dao.enumuration.dtr.LeadStatus;
31422 amit.gupta 16 
import com.spice.profitmandi.dao.model.*;
25979 tejbeer 17 
import com.spice.profitmandi.dao.repository.auth.AuthRepository;
30185 tejbeer 18 
import com.spice.profitmandi.dao.repository.auth.PartnerCollectionPlanRepository;
30434 tejbeer 19 
import com.spice.profitmandi.dao.repository.auth.PartnerCollectionRemarkRepository;
30416 tejbeer 20 
import com.spice.profitmandi.dao.repository.cs.CsService;
29266 manish 21 
import com.spice.profitmandi.dao.repository.cs.PositionRepository;
31422 amit.gupta 22 
import com.spice.profitmandi.dao.repository.dtr.*;
30416 tejbeer 23 
import com.spice.profitmandi.dao.repository.fofo.PartnerDailyInvestmentRepository;
25979 tejbeer 24 
import com.spice.profitmandi.dao.repository.inventory.StateRepository;
30445 tejbeer 25 
import com.spice.profitmandi.dao.repository.transaction.UserWalletRepository;
29266 manish 26 
import com.spice.profitmandi.service.AuthService;
30416 tejbeer 27 
import com.spice.profitmandi.service.PartnerCollectionService;
28 
import com.spice.profitmandi.service.user.RetailerService;
25979 tejbeer 29 
import com.spice.profitmandi.web.model.LoginDetails;
30 
import com.spice.profitmandi.web.util.CookiesProcessor;
31 
import com.spice.profitmandi.web.util.MVCResponseSender;
31422 amit.gupta 32 
import org.apache.commons.csv.CSVRecord;
33 
import org.apache.logging.log4j.LogManager;
34 
import org.apache.logging.log4j.Logger;
35 
import org.springframework.beans.factory.annotation.Autowired;
36 
import org.springframework.core.io.InputStreamResource;
37 
import org.springframework.http.HttpHeaders;
38 
import org.springframework.http.HttpStatus;
39 
import org.springframework.http.MediaType;
40 
import org.springframework.http.ResponseEntity;
41 
import org.springframework.stereotype.Controller;
42 
import org.springframework.ui.Model;
43 
import org.springframework.util.StringUtils;
44 
import org.springframework.web.bind.annotation.*;
45 
import org.springframework.web.multipart.MultipartFile;
25979 tejbeer 46 
 
31422 amit.gupta 47 
import javax.servlet.http.HttpServletRequest;
48 
import javax.servlet.http.HttpServletResponse;
49 
import javax.transaction.Transactional;
50 
import java.io.ByteArrayInputStream;
51 
import java.io.InputStream;
52 
import java.time.LocalDate;
53 
import java.time.LocalDateTime;
54 
import java.time.format.DateTimeFormatter;
55 
import java.util.*;
56 
import java.util.Map.Entry;
57 
import java.util.stream.Collectors;
58 
 
25979 tejbeer 59 
@Controller
60 
@Transactional(rollbackOn = Throwable.class)
61 
public class LeadController {
62 
	private static final Logger LOGGER = LogManager.getLogger(LeadController.class);
63 
 
64 
	@Autowired
65 
	private LeadRepository leadRepository;
66 
 
67 
	@Autowired
68 
	private LeadActivityRepository leadActivityRepository;
69 
 
70 
	@Autowired
71 
	private StateRepository stateRepository;
72 
 
73 
	@Autowired
29266 manish 74 
	private AuthService authService;
75 
 
76 
	@Autowired
25979 tejbeer 77 
	private AuthRepository authRepository;
78 
 
79 
	@Autowired
29266 manish 80 
	private Gson gson;
81 
 
82 
	@Autowired
25979 tejbeer 83 
	private CookiesProcessor cookiesProcessor;
29426 manish 84 
 
29278 manish 85 
	@Autowired
86 
	PositionRepository positionRepository;
25979 tejbeer 87 
 
88 
	@Autowired
89 
	private MVCResponseSender mvcResponseSender;
90 
 
30185 tejbeer 91 
	@Autowired
92 
	private PartnerCollectionPlanRepository partnerCollectionPlanRepository;
93 
 
30416 tejbeer 94 
	@Autowired
95 
	private CsService csService;
96 
 
97 
	@Autowired
98 
	private FofoStoreRepository fofoStoreRepository;
99 
 
100 
	@Autowired
101 
	private PartnerCollectionService partnerCollectionService;
102 
 
103 
	@Autowired
104 
	private RetailerService retailerService;
105 
 
106 
	@Autowired
30434 tejbeer 107 
	private PartnerCollectionRemarkRepository partnerCollectionRemarkRepository;
108 
 
109 
	@Autowired
30416 tejbeer 110 
	private PartnerDailyInvestmentRepository partnerDailyInvestmentRepository;
30445 tejbeer 111 
 
112 
	@Autowired
113 
	private UserWalletRepository userWalletRepository;
114 
 
30522 tejbeer 115 
	@Autowired
116 
	private FranchiseeVisitRepository franchiseeVisitRepository;
117 
 
118 
	@Autowired
119 
	private FranchiseeActivityRepository franchiseeActivityRepository;
120 
 
31249 tejbeer 121 
	@Autowired
122 
	private VisitRequestRepository visitRequestRepository;
123 
 
31370 tejbeer 124 
	@Autowired
125 
	private LeadBrandRepository leadBrandRepository;
126 
 
127 
	@Autowired
128 
	private LeadDetailRepository leadDetailRepository;
129 
 
130 
	@Autowired
131 
	private Mongo mongoClient;
132 
 
133 
	@Autowired
134 
	private ResponseSender<?> responseSender;
135 
 
25988 tejbeer 136 
	List<LeadStatus> status = Arrays.asList(LeadStatus.notInterested, LeadStatus.finalized);
137 
 
25979 tejbeer 138 
	@RequestMapping(value = "/getOpenLead", method = RequestMethod.GET)
27609 tejbeer 139 
	public String getOpenLead(HttpServletRequest request,
29426 manish 140 
			@RequestParam(name = "leadStatus", required = false, defaultValue = "All") List<LeadStatus> leadStatus,
29744 tejbeer 141 
			@RequestParam(name = "color", required = false, defaultValue = "All") List<String> color,
29445 manish 142 
			@RequestParam(name = "leadDate", required = false, defaultValue = "") LocalDate leadDate, Model model)
27642 tejbeer 143 
			throws Exception {
27609 tejbeer 144 
 
29445 manish 145 
		LocalDateTime localDateTime = null;
146 
		if (leadDate != null) {
147 
			localDateTime = leadDate.atStartOfDay();
148 
		}
149 
		LOGGER.info("localDateTime" + localDateTime);
150 
 
29266 manish 151 
		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
152 
		String emailId = loginDetails.getEmailId();
153 
		AuthUser authUser = authRepository.selectByEmailOrMobile(emailId);
29426 manish 154 
 
155 
		boolean authPositon = positionRepository.hasCategory(authUser.getId(),
156 
				ProfitMandiConstants.TICKET_CATEGORY_SALES);
157 
 
27610 tejbeer 158 
		if (leadStatus.contains(LeadStatus.All)) {
159 
 
29445 manish 160 
			leadStatus.add(LeadStatus.pending);
161 
			leadStatus.add(LeadStatus.notInterested);
162 
			leadStatus.add(LeadStatus.finalized);
27610 tejbeer 163 
		}
27615 tejbeer 164 
 
29744 tejbeer 165 
		if (color.contains("All")) {
166 
			color.add("yellow");
167 
			color.add("green");
168 
		}
169 
 
29852 tejbeer 170 
		List<Lead> leads = new ArrayList<>();
29445 manish 171 
 
172 
		model.addAttribute("colors", color);
173 
 
29744 tejbeer 174 
		Map<Integer, List<LeadActivity>> leadActivityMap = new HashMap<>();
175 
 
29287 amit.gupta 176 
		List<Integer> authUserIds = null;
29445 manish 177 
 
29744 tejbeer 178 
		LOGGER.info("color111" + color);
29445 manish 179 
 
29744 tejbeer 180 
		List<Lead> leadFollowUp = new ArrayList<>();
29426 manish 181 
 
29744 tejbeer 182 
		if (authPositon) {
183 
			authUserIds = authService.getAllReportees(authUser.getId());
184 
			authUserIds.add(authUser.getId());
185 
			LOGGER.info("authIds" + authUserIds);
29426 manish 186 
 
29753 tejbeer 187 
			LOGGER.info("leadStatus" + leadStatus);
188 
 
29744 tejbeer 189 
			if (localDateTime == null) {
29445 manish 190 
 
29852 tejbeer 191 
				if (!leadStatus.contains(LeadStatus.followUp)) {
29445 manish 192 
 
29852 tejbeer 193 
					leads = leadRepository.selectAllByColorStatusAndUpdatedTimestampAndAuthIds(leadStatus, authUserIds,
194 
							color, LocalDateTime.now().minusMonths(1));
195 
				}
196 
 
197 
				if (leadStatus.contains(LeadStatus.followUp) || leadStatus.contains(LeadStatus.All)) {
30290 tejbeer 198 
					leadFollowUp = leadRepository.selectByAssignAuthIdsAndStatus(authUserIds, LeadStatus.followUp);
29852 tejbeer 199 
					leads.addAll(leadFollowUp);
200 
				}
201 
 
29744 tejbeer 202 
			} else {
29445 manish 203 
 
29852 tejbeer 204 
				if (!leadStatus.contains(LeadStatus.followUp)) {
205 
 
206 
					leads = leadRepository.selectAllByColorStatusAndUpdatedTimestampAndAuthIds(leadStatus, authUserIds,
207 
							color, localDateTime);
208 
				}
209 
 
210 
				if (leadStatus.contains(LeadStatus.followUp) || leadStatus.contains(LeadStatus.All)) {
211 
 
30290 tejbeer 212 
					leadFollowUp = leadRepository.selectByAssignAuthIdsAndStatus(authUserIds, LeadStatus.followUp);
213 
 
29852 tejbeer 214 
					leads.addAll(leadFollowUp);
215 
 
216 
				}
217 
 
29744 tejbeer 218 
			}
29445 manish 219 
 
29744 tejbeer 220 
		} else {
29445 manish 221 
 
29744 tejbeer 222 
			if (localDateTime == null) {
29852 tejbeer 223 
				if (!leadStatus.contains(LeadStatus.followUp)) {
29445 manish 224 
 
29852 tejbeer 225 
					leads = leadRepository.selectAllByColorStatusAndUpdatedTimestamp(leadStatus, color,
226 
							LocalDateTime.now().minusMonths(1));
227 
				}
228 
				if (leadStatus.contains(LeadStatus.followUp) || leadStatus.contains(LeadStatus.All)) {
229 
 
30292 tejbeer 230 
					leadFollowUp = leadRepository.selectAllByStatus(LeadStatus.followUp);
30290 tejbeer 231 
 
29852 tejbeer 232 
					leads.addAll(leadFollowUp);
233 
				}
29744 tejbeer 234 
				LOGGER.info("leadlocalDateTime1" + leads);
29445 manish 235 
 
29744 tejbeer 236 
			} else {
29852 tejbeer 237 
				if (!leadStatus.contains(LeadStatus.followUp)) {
29445 manish 238 
 
29852 tejbeer 239 
					leads = leadRepository.selectAllByColorStatusAndUpdatedTimestamp(leadStatus, color, localDateTime);
240 
				}
241 
 
242 
				if (leadStatus.contains(LeadStatus.followUp) || leadStatus.contains(LeadStatus.All)) {
243 
 
30292 tejbeer 244 
					leadFollowUp = leadRepository.selectAllByStatus(LeadStatus.followUp);
30290 tejbeer 245 
 
29852 tejbeer 246 
					leads.addAll(leadFollowUp);
247 
				}
29744 tejbeer 248 
				LOGGER.info("leadlocalDateTime2" + leads);
29445 manish 249 
 
29278 manish 250 
			}
29426 manish 251 
 
29445 manish 252 
		}
253 
 
29426 manish 254 
		if (authPositon && authUserIds.size() > 0) {
29287 amit.gupta 255 
			List<String> leadCreators = new ArrayList<>();
256 
			leadCreators.add("daily-sync");
29426 manish 257 
			leadCreators.addAll(authRepository.selectAllAuthUserByIds(authUserIds).stream().map(x -> x.getFullName())
258 
					.collect(Collectors.toList()));
29289 amit.gupta 259 
			model.addAttribute("leadCreators", leadCreators);
29287 amit.gupta 260 
		}
29266 manish 261 
		List<Lead> weekLast = new ArrayList<>();
262 
		List<Lead> weekThird = new ArrayList<>();
263 
		List<Lead> weekSecond = new ArrayList<>();
264 
		List<Lead> weekFirst = new ArrayList<>();
265 
		LocalDateTime curDate = LocalDate.now().atStartOfDay();
266 
		List<LeadWeakWiseModel> lwDays = new ArrayList<>();
27642 tejbeer 267 
 
29266 manish 268 
		for (int i = 7; i >= 1; i--) {
269 
			LocalDateTime startOfDay = curDate.minusDays(i);
270 
 
271 
			LeadWeakWiseModel lm = new LeadWeakWiseModel();
272 
			lm.setMonth(startOfDay.toLocalDate());
273 
			lwDays.add(lm);
274 
		}
29426 manish 275 
		if (!leads.isEmpty()) {
29266 manish 276 
 
29744 tejbeer 277 
			weekLast.addAll(
278 
					leads.stream()
279 
							.filter(x -> x.getCreatedTimestamp().isAfter(curDate.minusDays(28))
280 
									&& x.getCreatedTimestamp().isBefore(curDate.minusDays(21)))
281 
							.collect(Collectors.toList()));
29266 manish 282 
 
29744 tejbeer 283 
			weekThird
284 
					.addAll(leads.stream()
285 
							.filter(x -> x.getCreatedTimestamp().isAfter(curDate.minusDays(21))
286 
									&& x.getCreatedTimestamp().isBefore(curDate.minusDays(14)))
287 
							.collect(Collectors.toList()));
29266 manish 288 
 
29744 tejbeer 289 
			weekSecond
290 
					.addAll(leads.stream()
291 
							.filter(x -> x.getCreatedTimestamp().isAfter(curDate.minusDays(14))
292 
									&& x.getCreatedTimestamp().isBefore(curDate.minusDays(7)))
293 
							.collect(Collectors.toList()));
29426 manish 294 
 
29744 tejbeer 295 
			weekFirst.addAll(leads.stream().filter(x -> x.getCreatedTimestamp().isAfter(curDate.minusDays(7)))
296 
					.collect(Collectors.toList()));
297 
 
29266 manish 298 
		}
299 
		LOGGER.info("weekLast" + weekLast);
300 
		LOGGER.info("weekThird" + weekThird);
301 
		LOGGER.info("weekSecond" + weekSecond);
29426 manish 302 
		Map<String, Long> leadLasts = weekLast.stream()
303 
				.collect(Collectors.groupingBy(x -> x.getCreatedBy(), Collectors.counting()));
304 
		Map<String, Long> leadThirds = weekThird.stream()
305 
				.collect(Collectors.groupingBy(x -> x.getCreatedBy(), Collectors.counting()));
29266 manish 306 
		Map<String, Long> leadSeconds = weekSecond.stream().collect(Collectors.groupingBy(x -> x.getCreatedBy(),
307 
				Collectors.mapping(Lead::getCreatedBy, Collectors.counting())));
308 
 
309 
		Map<String, Map<LocalDate, Long>> leadFirsts = weekFirst.stream()
310 
				.collect(Collectors.groupingBy(x -> x.getCreatedBy(),
311 
						Collectors.groupingBy(x -> x.getCreatedTimestamp().toLocalDate(), Collectors.counting())));
312 
 
313 
		LOGGER.info("leadFirsts" + leadFirsts);
314 
 
27723 tejbeer 315 
		List<Integer> authIds = new ArrayList<>();
316 
		if (!leads.isEmpty()) {
25979 tejbeer 317 
 
27723 tejbeer 318 
			authIds.addAll(leads.stream().map(x -> x.getAssignTo()).collect(Collectors.toList()));
27610 tejbeer 319 
 
29744 tejbeer 320 
			leadActivityMap = leadActivityRepository
321 
					.selectAllByleadIds(leads.stream().map(x -> x.getId()).collect(Collectors.toList())).stream()
322 
					.collect(Collectors.groupingBy(LeadActivity::getLeadId, Collectors.toList()));
323 
 
27723 tejbeer 324 
			Map<Integer, AuthUser> authIdAndAuthUserMap = authRepository.selectAllAuthUserByIds(authIds).stream()
325 
					.collect(Collectors.toMap(x -> x.getId(), x -> x));
326 
			model.addAttribute("leadActivityMap", leadActivityMap);
327 
			model.addAttribute("authIdAndAuthUserMap", authIdAndAuthUserMap);
328 
		}
329 
 
29266 manish 330 
		ChartLeadModel cm = this.getLeadChart(leads);
331 
		model.addAttribute("chartLead", gson.toJson(cm));
332 
 
333 
		LOGGER.info("ChartLeadModel" + gson.toJson(cm));
334 
		LOGGER.info("lwDays" + lwDays);
335 
 
27610 tejbeer 336 
		LOGGER.info("leads" + leads);
25979 tejbeer 337 
		List<String> stateNames = stateRepository.selectAll().stream().map(x -> x.getName())
338 
				.collect(Collectors.toList());
339 
		List<AuthUser> authUsers = authRepository.selectAllActiveUser();
29266 manish 340 
		LocalDate lastDate = curDate.minusDays(1).toLocalDate();
29426 manish 341 
 
29266 manish 342 
		List<LocalDate> weekDates = new ArrayList<>();
29426 manish 343 
 
29266 manish 344 
		weekDates.add(curDate.minusDays(28).toLocalDate());
345 
		weekDates.add(curDate.minusDays(22).toLocalDate());
346 
		weekDates.add(curDate.minusDays(21).toLocalDate());
347 
		weekDates.add(curDate.minusDays(15).toLocalDate());
348 
		weekDates.add(curDate.minusDays(14).toLocalDate());
349 
		weekDates.add(curDate.minusDays(8).toLocalDate());
350 
		weekDates.add(curDate.minusDays(7).toLocalDate());
351 
		LOGGER.info("lastDate" + lastDate);
29426 manish 352 
 
29266 manish 353 
		model.addAttribute("weekDates", weekDates);
29426 manish 354 
 
29445 manish 355 
		model.addAttribute("leadDate", leadDate);
29266 manish 356 
		model.addAttribute("lastDate", lastDate);
25979 tejbeer 357 
		model.addAttribute("stateNames", stateNames);
31249 tejbeer 358 
 
359 
		model.addAttribute("communicationTypes", CommunicationType.values());
360 
 
25979 tejbeer 361 
		model.addAttribute("authUsers", authUsers);
27610 tejbeer 362 
		model.addAttribute("lead", leads);
363 
		model.addAttribute("leadStatus", LeadStatus.values());
29266 manish 364 
		model.addAttribute("leadLasts", leadLasts);
365 
		model.addAttribute("leadThirds", leadThirds);
366 
		model.addAttribute("leadSeconds", leadSeconds);
367 
		model.addAttribute("leadFirsts", leadFirsts);
368 
		model.addAttribute("lwDays", lwDays);
25979 tejbeer 369 
 
27610 tejbeer 370 
		model.addAttribute("selectedLeadStatus", leadStatus.get(0));
31370 tejbeer 371 
 
372 
		List<DBObject> mobileBrands = mongoClient.getAllBrandsToDisplay(3);
373 
 
374 
		List<String> brands = mobileBrands.stream().map(x -> (String) x.get("name")).collect(Collectors.toList());
375 
 
376 
		model.addAttribute("brands", brands);
377 
 
25979 tejbeer 378 
		return "lead";
27642 tejbeer 379 
 
25979 tejbeer 380 
	}
381 
 
29266 manish 382 
	public ChartLeadModel getLeadChart(List<Lead> leads) throws ProfitMandiBusinessException {
383 
 
384 
		Map<LeadStatus, Long> leadStatusMap = leads.stream().collect(
385 
				Collectors.groupingBy(x -> x.getStatus(), Collectors.mapping(Lead::getStatus, Collectors.counting())));
386 
 
29426 manish 387 
		Map<String, Long> hotLeadsMap = leads.stream().collect(
388 
				Collectors.groupingBy(x -> x.getColor(), Collectors.mapping(Lead::getColor, Collectors.counting())));
389 
 
390 
		LOGGER.info("hotLeadsMap" + hotLeadsMap);
29266 manish 391 
		ChartLeadModel cm = new ChartLeadModel();
392 
 
393 
		HashSet<LeadStatus> labels = new HashSet<LeadStatus>();
394 
		labels.addAll(leadStatusMap.keySet());
29445 manish 395 
 
30771 amit.gupta 396 
		List<String> hotLeads = new ArrayList<>();
29426 manish 397 
		hotLeads.addAll(leadStatusMap.keySet().stream().map(x -> x.toString()).collect(Collectors.toSet()));
398 
		hotLeads.add("HotLead");
29445 manish 399 
 
30771 amit.gupta 400 
		List<String> hotLeadKeys = new ArrayList<>();
29445 manish 401 
 
29426 manish 402 
		hotLeadKeys.add("HotLead");
403 
		List<String> hotLeadGreen = new ArrayList<>(hotLeadKeys);
29598 tejbeer 404 
 
29448 manish 405 
		LOGGER.info("hotLeads" + hotLeads);
29445 manish 406 
 
29266 manish 407 
		List<LeadStatus> labelList = new ArrayList<>(labels);
408 
		List<String> backgroundColor = new ArrayList<>();
29426 manish 409 
		LOGGER.info("hotLeadKeys" + hotLeadKeys);
29266 manish 410 
		List<Long> values = new ArrayList<>();
411 
 
29448 manish 412 
		for (String hotLead : hotLeads) {
29266 manish 413 
 
29448 manish 414 
			if (hotLead.equals("pending")) {
29266 manish 415 
				backgroundColor.add("pink");
29448 manish 416 
				values.add(leadStatusMap.get(LeadStatus.pending));
29266 manish 417 
			}
29448 manish 418 
			if (hotLead.equals("notInterested")) {
29266 manish 419 
				backgroundColor.add("red");
29448 manish 420 
				values.add(leadStatusMap.get(LeadStatus.notInterested));
29266 manish 421 
			}
29448 manish 422 
			if (hotLead.equals("followUp")) {
29266 manish 423 
				backgroundColor.add("#9ACD32");
29448 manish 424 
				values.add(leadStatusMap.get(LeadStatus.followUp));
29266 manish 425 
			}
29448 manish 426 
			if (hotLead.equals("finalized")) {
29266 manish 427 
				backgroundColor.add("blue");
29448 manish 428 
				values.add(leadStatusMap.get(LeadStatus.finalized));
29445 manish 429 
			}
29598 tejbeer 430 
 
29448 manish 431 
			if (hotLead.equals("HotLead")) {
29426 manish 432 
				backgroundColor.add("green");
433 
				values.add(hotLeadsMap.get("Green"));
29445 manish 434 
 
29266 manish 435 
			}
29445 manish 436 
 
29266 manish 437 
		}
438 
		LOGGER.info("labelList" + labelList);
439 
 
440 
		LOGGER.info("backgroundColor" + backgroundColor);
441 
		LOGGER.info("labelsChartLead" + labels);
442 
		LeadStatusData data = new LeadStatusData();
443 
		data.setData(values);
444 
		data.setBackgroundColor(backgroundColor);
445 
		data.setLabel("DataSet 1");
446 
 
447 
		PieLables label = new PieLables();
448 
		label.setFontColor("black");
449 
		label.setFontSize(15);
450 
 
451 
		Legend legend = new Legend();
452 
		legend.setLabels(label);
453 
		legend.setPosition("left");
454 
 
455 
		List<LeadStatusData> dataList = new ArrayList<>();
456 
		dataList.add(data);
457 
 
458 
		DataLeadModel datasets = new DataLeadModel();
459 
		datasets.setDatasets(dataList);
29426 manish 460 
		datasets.setLabels(hotLeads);
29266 manish 461 
 
462 
		OptionModel om = new OptionModel();
463 
		om.setLegend(legend);
464 
 
465 
		cm.setType("pie");
466 
		cm.setData(datasets);
467 
		cm.setOptions(om);
468 
 
469 
		return cm;
470 
	}
471 
 
25988 tejbeer 472 
	@RequestMapping(value = "/getClosedLead", method = RequestMethod.GET)
473 
	public String getClosedLead(HttpServletRequest request,
474 
			@RequestParam(name = "offset", defaultValue = "0") int offset,
475 
			@RequestParam(name = "limit", defaultValue = "10") int limit,
476 
			@RequestParam(name = "searchTerm", required = false, defaultValue = "") String searchTerm, Model model)
477 
			throws Exception {
478 
		List<AuthUser> authUsers = authRepository.selectAllActiveUser();
479 
		List<Lead> leads = null;
480 
		long size = 0;
481 
		leads = leadRepository.selectAllByStatus(status, offset, limit);
482 
		size = leadRepository.selectCountByStatus(status);
483 
 
484 
		if (!leads.isEmpty()) {
485 
			List<Integer> authIds = new ArrayList<>();
486 
			for (Lead lead : leads) {
487 
				authIds.add(lead.getAssignTo());
488 
			}
489 
			Map<Integer, AuthUser> authIdAndAuthUserMap = authRepository.selectAllAuthUserByIds(authIds).stream()
490 
					.collect(Collectors.toMap(x -> x.getId(), x -> x));
491 
 
492 
			model.addAttribute("leads", leads);
493 
			model.addAttribute("start", offset + 1);
494 
			model.addAttribute("size", size);
495 
			model.addAttribute("searchTerm", searchTerm);
496 
			model.addAttribute("authIdAndAuthUserMap", authIdAndAuthUserMap);
25990 tejbeer 497 
			model.addAttribute("url", "/getPaginatedClosedLeads");
25988 tejbeer 498 
 
499 
			if (leads.size() < limit) {
500 
				model.addAttribute("end", offset + leads.size());
501 
			} else {
502 
				model.addAttribute("end", offset + limit);
503 
			}
504 
 
505 
		} else {
506 
			model.addAttribute("lead", leads);
507 
 
508 
			model.addAttribute("size", size);
509 
		}
510 
 
511 
		model.addAttribute("authUsers", authUsers);
512 
		return "lead-close";
513 
	}
514 
 
515 
	@RequestMapping(value = "/getPaginatedClosedLeads", method = RequestMethod.GET)
25990 tejbeer 516 
	public String getPaginatedClosedLeads(HttpServletRequest request,
25988 tejbeer 517 
			@RequestParam(name = "offset", defaultValue = "0") int offset,
518 
			@RequestParam(name = "limit", defaultValue = "10") int limit, Model model)
519 
			throws ProfitMandiBusinessException {
520 
		List<Lead> leads = null;
521 
		leads = leadRepository.selectAllByStatus(status, offset, limit);
522 
 
523 
		if (!leads.isEmpty()) {
524 
			List<Integer> authIds = new ArrayList<>();
525 
			for (Lead lead : leads) {
526 
				authIds.add(lead.getAssignTo());
527 
			}
528 
			Map<Integer, AuthUser> authIdAndAuthUserMap = authRepository.selectAllAuthUserByIds(authIds).stream()
529 
					.collect(Collectors.toMap(x -> x.getId(), x -> x));
530 
			model.addAttribute("authIdAndAuthUserMap", authIdAndAuthUserMap);
531 
			model.addAttribute("leads", leads);
25990 tejbeer 532 
			model.addAttribute("url", "/getPaginatedClosedLeads");
25988 tejbeer 533 
 
534 
		} else {
535 
			model.addAttribute("leads", leads);
536 
 
537 
		}
538 
		return "lead-close-paginated";
539 
	}
540 
 
541 
	@RequestMapping(value = "/searchLeads")
542 
	public String getClosedLeads(HttpServletRequest request,
543 
			@RequestParam(name = "offset", defaultValue = "0") int offset,
544 
			@RequestParam(name = "limit", defaultValue = "10") int limit,
545 
			@RequestParam(name = "searchTerm", required = false, defaultValue = "") String searchTerm, Model model)
546 
			throws ProfitMandiBusinessException {
547 
		List<AuthUser> authUsers = authRepository.selectAllActiveUser();
548 
		List<Lead> leads = null;
549 
		long size = 0;
550 
		if (!(searchTerm.equals(""))) {
551 
			leads = leadRepository.selectBySearchTerm(status, searchTerm, offset, limit);
552 
			if (!(leads.size() == 0)) {
553 
				size = leadRepository.selectCountByStatus(status);
554 
				List<Integer> authIds = new ArrayList<>();
555 
				for (Lead lead : leads) {
556 
					authIds.add(lead.getAssignTo());
557 
				}
558 
				Map<Integer, AuthUser> authIdAndAuthUserMap = authRepository.selectAllAuthUserByIds(authIds).stream()
559 
						.collect(Collectors.toMap(x -> x.getId(), x -> x));
560 
				model.addAttribute("authIdAndAuthUserMap", authIdAndAuthUserMap);
561 
				model.addAttribute("leads", leads);
562 
				model.addAttribute("start", offset + 1);
563 
				model.addAttribute("size", size);
564 
				model.addAttribute("searchTerm", searchTerm);
565 
 
566 
				if (leads.size() < limit) {
567 
					model.addAttribute("end", offset + leads.size());
568 
				} else {
569 
					model.addAttribute("end", offset + limit);
570 
				}
571 
			} else {
572 
				throw new ProfitMandiBusinessException("lead", searchTerm, "leads Not Found");
573 
			}
574 
		} else {
575 
			leads = leadRepository.selectAllByStatus(status, offset, limit);
576 
			size = leadRepository.selectCountByStatus(status);
577 
 
578 
			if (!leads.isEmpty()) {
579 
				List<Integer> authIds = new ArrayList<>();
580 
				for (Lead lead : leads) {
581 
					authIds.add(lead.getAssignTo());
582 
				}
583 
				Map<Integer, AuthUser> authIdAndAuthUserMap = authRepository.selectAllAuthUserByIds(authIds).stream()
584 
						.collect(Collectors.toMap(x -> x.getId(), x -> x));
585 
 
586 
				model.addAttribute("leads", leads);
587 
				model.addAttribute("start", offset + 1);
588 
				model.addAttribute("size", size);
589 
				model.addAttribute("searchTerm", searchTerm);
590 
				model.addAttribute("authIdAndAuthUserMap", authIdAndAuthUserMap);
591 
 
592 
				if (leads.size() < limit) {
593 
					model.addAttribute("end", offset + leads.size());
594 
				} else {
595 
					model.addAttribute("end", offset + limit);
596 
				}
597 
 
598 
			}
599 
		}
600 
 
601 
		model.addAttribute("authUsers", authUsers);
602 
		return "lead-close";
603 
	}
604 
 
605 
	@RequestMapping(value = "/searchLeadPaginated")
25990 tejbeer 606 
	public String searchLeadPaginated(HttpServletRequest request,
25988 tejbeer 607 
			@RequestParam(name = "offset", defaultValue = "0") int offset,
608 
			@RequestParam(name = "limit", defaultValue = "10") int limit,
609 
			@RequestParam(name = "searchTerm", required = false, defaultValue = "") String searchTerm, Model model)
610 
			throws ProfitMandiBusinessException {
611 
		LOGGER.info("In search Item....");
612 
		List<Lead> leads = null;
613 
		if (!searchTerm.equals("")) {
614 
			leads = leadRepository.selectBySearchTerm(status, searchTerm, offset, limit);
615 
			if (!(leads.size() == 0)) {
616 
 
617 
				List<Integer> authIds = new ArrayList<>();
618 
				for (Lead lead : leads) {
619 
					authIds.add(lead.getAssignTo());
620 
				}
621 
				Map<Integer, AuthUser> authIdAndAuthUserMap = authRepository.selectAllAuthUserByIds(authIds).stream()
622 
						.collect(Collectors.toMap(x -> x.getId(), x -> x));
623 
				model.addAttribute("authIdAndAuthUserMap", authIdAndAuthUserMap);
624 
				model.addAttribute("leads", leads);
625 
			}
626 
		}
627 
 
628 
		return "lead-close-paginated";
629 
 
630 
	}
631 
 
25979 tejbeer 632 
	@RequestMapping(value = "/getLeadActivity", method = RequestMethod.GET)
633 
	public String getLeadActivity(HttpServletRequest request, @RequestParam int leadId, Model model) throws Exception {
634 
		List<LeadActivity> leadActivity = leadActivityRepository.selectBYLeadId(leadId);
31249 tejbeer 635 
 
636 
		LOGGER.info("leadActivity" + leadActivity);
637 
 
25979 tejbeer 638 
		model.addAttribute("leadActivity", leadActivity);
31249 tejbeer 639 
		model.addAttribute("authUserMap",
640 
				authRepository.selectAllActiveUser().stream().collect(Collectors.toMap(x -> x.getId(), x -> x)));
641 
 
25979 tejbeer 642 
		return "lead_activity_modal";
643 
	}
644 
 
31370 tejbeer 645 
	@RequestMapping(value = "/getLead", method = RequestMethod.GET)
646 
	public ResponseEntity<?> getLead(HttpServletRequest request, @RequestParam int leadId) throws Exception {
647 
		Lead lead = leadRepository.selectById(leadId);
648 
 
649 
		LeadDetail leadDetail = leadDetailRepository.selectByLeadId(lead.getId());
650 
		if (leadDetail != null) {
651 
			lead.setOutLetName(leadDetail.getOutletName());
652 
		}
653 
 
654 
		return responseSender.ok(lead);
655 
 
656 
	}
657 
 
25979 tejbeer 658 
	@RequestMapping(value = "/createLead", method = RequestMethod.POST)
659 
	public String CreateLead(HttpServletRequest request, @RequestBody CreateRefferalRequest createRefferalRequest,
660 
			Model model) throws Exception {
661 
		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
31249 tejbeer 662 
 
25979 tejbeer 663 
		LOGGER.info("createRefferalRequest" + createRefferalRequest.getSchelduleTimestamp());
664 
		Lead lead = new Lead();
665 
		lead.setFirstName(createRefferalRequest.getFirstName());
666 
		lead.setLastName(createRefferalRequest.getLastName());
667 
		lead.setLeadMobile(createRefferalRequest.getMobile());
668 
		lead.setState(createRefferalRequest.getState());
669 
		lead.setCity(createRefferalRequest.getCity());
670 
		lead.setAddress(createRefferalRequest.getAddress());
671 
		lead.setCreatedTimestamp(LocalDateTime.now());
672 
		lead.setUpdatedTimestamp(LocalDateTime.now());
673 
		lead.setStatus(createRefferalRequest.getStatus());
674 
		lead.setAssignTo(createRefferalRequest.getAssignTo());
675 
		lead.setSource(createRefferalRequest.getSource());
26298 tejbeer 676 
		lead.setColor("yellow");
25979 tejbeer 677 
		// change
25989 tejbeer 678 
		AuthUser authUser = authRepository.selectByEmailOrMobile(loginDetails.getEmailId());
25979 tejbeer 679 
		String authUserName = authUser.getFirstName() + " " + authUser.getLastName();
680 
		lead.setCreatedBy(authUserName);
681 
		lead.setAuthId(authUser.getId());
31422 amit.gupta 682 
		LOGGER.info("lead --- {}", lead);
25979 tejbeer 683 
		leadRepository.persist(lead);
684 
		LeadActivity leadActivity = new LeadActivity();
685 
		leadActivity.setLeadId(lead.getId());
686 
		leadActivity.setRemark(createRefferalRequest.getRemark());
31249 tejbeer 687 
		leadActivity.setAuthId(authUser.getId());
688 
		LOGGER.info("createRefferalRequest" + createRefferalRequest.getCommunicationType());
25979 tejbeer 689 
 
690 
		if (createRefferalRequest.getStatus() == LeadStatus.followUp) {
691 
			leadActivity.setSchelduleTimestamp(createRefferalRequest.getSchelduleTimestamp());
31249 tejbeer 692 
			leadActivity.setCommunicationType(createRefferalRequest.getCommunicationType());
693 
 
694 
			if (leadActivity.getCommunicationType().equals(CommunicationType.VISIT)) {
695 
				visitRequestRepository.createVisitRequest(lead.getId(), "lead", lead.getAssignTo(),
696 
						createRefferalRequest.getSchelduleTimestamp());
697 
			}
25979 tejbeer 698 
		} else {
699 
			leadActivity.setSchelduleTimestamp(null);
700 
		}
701 
		leadActivity.setCreatedTimestamp(LocalDateTime.now());
702 
		leadActivityRepository.persist(leadActivity);
31265 tejbeer 703 
		model.addAttribute("response1", mvcResponseSender.createResponseString(true));
31249 tejbeer 704 
 
25979 tejbeer 705 
		return "response";
706 
 
707 
	}
708 
 
709 
	@RequestMapping(value = "/editLead", method = RequestMethod.POST)
27605 tejbeer 710 
	public String EditLead(HttpServletRequest request,
711 
			@RequestBody CreateLeacdActivityRequest createLeadActivityRequest, Model model) throws Exception {
31249 tejbeer 712 
		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
25979 tejbeer 713 
 
31249 tejbeer 714 
		AuthUser authUser = authRepository.selectByEmailOrMobile(loginDetails.getEmailId());
715 
 
31370 tejbeer 716 
		LeadDetail leadDetail = leadDetailRepository.selectByLeadId(createLeadActivityRequest.getId());
717 
 
718 
		if (leadDetail == null) {
719 
 
720 
			throw new ProfitMandiBusinessException("LeadDetail", "", "Please fill lead detail");
721 
		}
722 
 
25979 tejbeer 723 
		LeadActivity leadActivity = new LeadActivity();
27605 tejbeer 724 
		leadActivity.setLeadId(createLeadActivityRequest.getId());
725 
		leadActivity.setRemark(createLeadActivityRequest.getRemark());
29598 tejbeer 726 
 
29476 manish 727 
		LOGGER.info("createRefferalRequest" + createLeadActivityRequest);
27605 tejbeer 728 
 
729 
		if (createLeadActivityRequest.getStatus() == LeadStatus.followUp) {
730 
			leadActivity.setSchelduleTimestamp(createLeadActivityRequest.getScheldule());
31249 tejbeer 731 
			leadActivity.setCommunicationType(createLeadActivityRequest.getCommunicationType());
732 
			if (leadActivity.getCommunicationType().equals(CommunicationType.VISIT)) {
733 
				visitRequestRepository.createVisitRequest(createLeadActivityRequest.getId(), "lead",
734 
						createLeadActivityRequest.getAssignTo(), createLeadActivityRequest.getScheldule());
735 
			}
27605 tejbeer 736 
		} else {
737 
			leadActivity.setSchelduleTimestamp(null);
738 
		}
25979 tejbeer 739 
		leadActivity.setCreatedTimestamp(LocalDateTime.now());
31249 tejbeer 740 
		leadActivity.setAuthId(authUser.getId());
25979 tejbeer 741 
		leadActivityRepository.persist(leadActivity);
29598 tejbeer 742 
		Lead lead = leadRepository.selectById(createLeadActivityRequest.getId());
27605 tejbeer 743 
		lead.setAssignTo(createLeadActivityRequest.getAssignTo());
744 
		lead.setStatus(createLeadActivityRequest.getStatus());
28200 tejbeer 745 
		lead.setNotinterestedReason(createLeadActivityRequest.getReason());
25979 tejbeer 746 
		lead.setUpdatedTimestamp(LocalDateTime.now());
747 
 
29473 manish 748 
		lead = leadRepository.selectById(createLeadActivityRequest.getId());
29598 tejbeer 749 
 
29476 manish 750 
		int authId = 0;
751 
		if (lead != null) {
25979 tejbeer 752 
 
29476 manish 753 
			authId = lead.getAssignTo();
754 
			Map<Integer, LeadActivity> leadActivityMap = new HashMap<>();
29598 tejbeer 755 
 
756 
			List<LeadActivity> leadActivitys = leadActivityRepository.selectBYLeadId(lead.getId());
757 
 
758 
			if (!leadActivitys.isEmpty()) {
759 
				leadActivityMap.put(lead.getId(), leadActivitys.get(0));
760 
			}
761 
 
762 
			Map<Integer, AuthUser> authIdAndAuthUserMap = new HashMap<>();
763 
			AuthUser AuthUser = authRepository.selectById(authId);
764 
 
765 
			authIdAndAuthUserMap.put(AuthUser.getId(), AuthUser);
766 
 
29476 manish 767 
			model.addAttribute("leadActivityMap", leadActivityMap);
768 
			model.addAttribute("authIdAndAuthUserMap", authIdAndAuthUserMap);
769 
		}
770 
 
29473 manish 771 
		model.addAttribute("request", lead);
772 
 
773 
		return "edit-lead";
774 
 
25979 tejbeer 775 
	}
29445 manish 776 
 
29426 manish 777 
	@RequestMapping(value = "/downloadIvoryLead", method = RequestMethod.GET)
778 
	public ResponseEntity<?> downloadDelayDayTemplate(HttpServletRequest request) throws Exception {
29598 tejbeer 779 
		List<String> stateNames = stateRepository.selectAll().stream().map(x -> x.getName())
780 
				.collect(Collectors.toList());
781 
 
29426 manish 782 
		List<List<?>> rows = new ArrayList<>();
783 
 
29598 tejbeer 784 
		List<LeadSource> lss = LeadSource.enumValues;
29426 manish 785 
 
29598 tejbeer 786 
		for (LeadSource ls : lss) {
787 
			rows.add(Arrays.asList("-", "-", "-", "-", "-", "-", "-", ls));
788 
 
789 
		}
790 
		for (String stateName : stateNames) {
791 
			rows.add(Arrays.asList("-", "-", "-", "-", stateName, "-", "-", "-"));
792 
 
793 
		}
794 
 
795 
		org.apache.commons.io.output.ByteArrayOutputStream baos = FileUtil.getCSVByteStream(Arrays.asList("First Name",
796 
				"Last Name", "Address", "City", "State", "Mobile", "Assign To(email)", "Source"), rows);
797 
 
29426 manish 798 
		final HttpHeaders headers = new HttpHeaders();
799 
		headers.set("Content-Type", "text/csv");
29598 tejbeer 800 
		headers.set("Content-disposition", "inline; filename=leads.format.csv");
29426 manish 801 
		headers.setContentLength(baos.toByteArray().length);
802 
 
803 
		final InputStream inputStream = new ByteArrayInputStream(baos.toByteArray());
804 
		final InputStreamResource inputStreamResource = new InputStreamResource(inputStream);
805 
		return new ResponseEntity<InputStreamResource>(inputStreamResource, headers, HttpStatus.OK);
806 
 
807 
	}
29445 manish 808 
 
29426 manish 809 
	@RequestMapping(value = "/csvFileAndSetLead", method = RequestMethod.POST)
810 
	public String readCsvFileAndSetLead(HttpServletRequest request, Model model, HttpServletResponse response,
811 
			@RequestPart MultipartFile file) throws Throwable {
812 
 
29598 tejbeer 813 
		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
814 
		String email = loginDetails.getEmailId();
815 
 
816 
		AuthUser createdBy = authRepository.selectByEmailOrMobile(email);
817 
 
29426 manish 818 
		LOGGER.info("file" + file.toString());
819 
 
820 
		String fileName = file.getName();
821 
 
822 
		String fileNames = file.getOriginalFilename();
823 
 
824 
		LOGGER.info("fileName" + fileName);
825 
		LOGGER.info("fileNames" + fileNames);
826 
 
29598 tejbeer 827 
		List<CSVRecord> records = FileUtil.readFile(file);
29426 manish 828 
 
29598 tejbeer 829 
		for (CSVRecord record : records) {
29426 manish 830 
 
831 
			Lead lead = new Lead();
29598 tejbeer 832 
			lead.setFirstName(record.get(0));
833 
			lead.setLastName(record.get(1));
834 
			lead.setAddress(record.get(2));
835 
			lead.setCity(record.get(3));
836 
			lead.setState(record.get(4));
837 
			lead.setLeadMobile(record.get(5));
838 
			LOGGER.info("record" + record.get(6));
29426 manish 839 
 
29598 tejbeer 840 
			AuthUser assignTo = authRepository.selectByEmailOrMobile(record.get(6));
29426 manish 841 
 
29598 tejbeer 842 
			if (assignTo == null) {
843 
				throw new ProfitMandiBusinessException("Assign To ", record.get(6), "email id not exist");
844 
			}
29445 manish 845 
 
29598 tejbeer 846 
			lead.setAssignTo(assignTo.getId());
847 
			lead.setSource(record.get(7));
848 
 
849 
			lead.setCreatedTimestamp(LocalDateTime.now());
850 
 
29426 manish 851 
			lead.setUpdatedTimestamp(LocalDateTime.now());
852 
			lead.setStatus(LeadStatus.pending);
853 
			lead.setColor("yellow");
854 
			// change
29598 tejbeer 855 
			lead.setCreatedBy(createdBy.getFullName());
856 
			lead.setAuthId(createdBy.getId());
29426 manish 857 
 
858 
			leadRepository.persist(lead);
859 
 
860 
			LeadActivity leadActivity = new LeadActivity();
861 
			leadActivity.setLeadId(lead.getId());
29598 tejbeer 862 
			leadActivity.setRemark("New Lead");
29426 manish 863 
			leadActivity.setSchelduleTimestamp(null);
864 
 
865 
			leadActivity.setCreatedTimestamp(LocalDateTime.now());
866 
			leadActivityRepository.persist(leadActivity);
31238 amit.gupta 867 
			model.addAttribute("response1", mvcResponseSender.createResponseString(true));
29426 manish 868 
 
869 
		}
870 
 
871 
		model.addAttribute("responseSTG", mvcResponseSender.createResponseString(true));
872 
 
873 
		return "response";
874 
 
875 
	}
876 
 
30185 tejbeer 877 
	@RequestMapping(value = "/teamCommitment", method = RequestMethod.GET)
878 
	public String teamCommitments(HttpServletRequest request, Model model) throws Exception {
879 
 
880 
		return "team-commitment";
881 
 
882 
	}
883 
 
31370 tejbeer 884 
	@RequestMapping(value = "/leadDetail", method = RequestMethod.POST, consumes = MediaType.APPLICATION_JSON_VALUE)
885 
	public String leadDetail(HttpServletRequest request, @RequestBody LeadDetailModel leadDetailModel, Model model)
886 
			throws Exception {
887 
 
888 
		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
889 
		AuthUser authUser = authRepository.selectByEmailOrMobile(loginDetails.getEmailId());
890 
		LeadDetail leadDetail = leadDetailRepository.selectByLeadId(leadDetailModel.getLeadId());
891 
		if (leadDetail == null) {
892 
			leadDetail = new LeadDetail();
893 
			leadDetail.setLeadId(leadDetailModel.getLeadId());
894 
			leadDetail.setOutletName(leadDetailModel.getOutletName());
895 
			leadDetail.setCounterSize(leadDetailModel.getCounterSize());
896 
			leadDetail.setCreatedBy(authUser.getId());
897 
 
898 
			leadDetail.setFrontp(leadDetailModel.getFrontp());
899 
			leadDetail.setFrontWithMarket(leadDetailModel.getFrontWithMarket());
900 
			leadDetail.setInternalLongShot(leadDetailModel.getInternalLongShot());
901 
			leadDetail.setInternalLeftWall(leadDetailModel.getInternalLeftWall());
902 
			leadDetail.setInternalRightWall(leadDetailModel.getInternalRightWall());
903 
 
904 
			leadDetail.setCreatedTimestamp(LocalDateTime.now());
905 
 
906 
			leadDetailRepository.persist(leadDetail);
907 
			for (LeadBrandModel leadBrandModel : leadDetailModel.getLeadBrands()) {
908 
 
909 
				LeadBrand leadBrand = new LeadBrand();
910 
				leadBrand.setBrand(leadBrandModel.getBrand());
31408 tejbeer 911 
				leadBrand.setValue(leadBrandModel.getValue());
31370 tejbeer 912 
				leadBrand.setLeadDetailId(leadDetail.getId());
913 
				leadBrand.setLeadId(leadDetail.getLeadId());
914 
				leadBrand.setCreatedTimestamp(LocalDateTime.now());
915 
				leadBrandRepository.persist(leadBrand);
916 
 
917 
			}
918 
		} else {
919 
			throw new ProfitMandiBusinessException("LeadDetail", "", "Lead Detail Already Created");
920 
		}
921 
 
922 
		model.addAttribute("response1", mvcResponseSender.createResponseString(true));
923 
 
924 
		return "response";
925 
 
926 
	}
927 
 
928 
	@RequestMapping(value = "/getLeadDetail", method = RequestMethod.GET)
929 
	public String getLeadDetail(HttpServletRequest request, Model model) throws Exception {
31477 tejbeer 930 
		List<Integer> followUpleadIds = leadRepository.selectAllByStatus(LeadStatus.followUp).stream()
931 
				.map(x -> x.getId()).collect(Collectors.toList());
932 
		List<LeadDetail> leadDetails = leadDetailRepository.selectByLeadIds(followUpleadIds);
31370 tejbeer 933 
 
934 
		List<DBObject> mobileBrands = mongoClient.getAllBrandsToDisplay(3);
935 
 
936 
		List<String> brands = mobileBrands.stream().map(x -> (String) x.get("name")).collect(Collectors.toList());
937 
 
938 
		model.addAttribute("brands", brands);
939 
		if (!leadDetails.isEmpty()) {
940 
 
941 
			List<Integer> detailsIds = leadDetails.stream().map(x -> x.getId()).collect(Collectors.toList());
942 
 
943 
			List<Integer> leadIds = leadDetails.stream().map(x -> x.getLeadId()).collect(Collectors.toList());
944 
 
945 
			Map<Integer, Lead> leadMap = leadRepository.selectAllByIds(leadIds).stream()
31477 tejbeer 946 
					.filter(x -> x.getStatus().equals(LeadStatus.followUp))
31370 tejbeer 947 
					.collect(Collectors.toMap(x -> x.getId(), x -> x));
948 
 
949 
			Map<Integer, Optional<LeadActivity>> leadActivityMap = leadActivityRepository.selectAllByleadIds(leadIds)
950 
					.stream().collect(Collectors.groupingBy(x -> x.getLeadId(),
31454 tejbeer 951 
							Collectors.maxBy(Comparator.comparing(LeadActivity::getId))));
31370 tejbeer 952 
 
953 
			model.addAttribute("leadActivityMap", leadActivityMap);
954 
 
955 
			List<LeadBrand> leadBrands = leadBrandRepository.selectByLeadDetailId(detailsIds);
956 
 
957 
			LOGGER.info("leadBrands {}" + leadBrands);
958 
 
959 
			Map<Integer, Map<String, Integer>> leadDetailBrandValue = new HashMap<>();
960 
 
961 
			Map<Integer, List<LeadBrand>> leadDetail = leadBrands.stream()
962 
					.collect(Collectors.groupingBy(x -> x.getLeadDetailId(), Collectors.toList()));
963 
 
964 
			for (Entry<Integer, List<LeadBrand>> leadDetailEntry : leadDetail.entrySet()) {
965 
 
966 
				Map<String, Integer> brandValue = new HashMap<>();
967 
 
968 
				for (LeadBrand leadBrand : leadDetailEntry.getValue()) {
969 
					brandValue.put(leadBrand.getBrand(), leadBrand.getValue());
970 
 
971 
				}
972 
				leadDetailBrandValue.put(leadDetailEntry.getKey(), brandValue);
973 
			}
974 
 
975 
			LOGGER.info("leadDetailBrandValue {}" + leadDetailBrandValue);
976 
 
977 
			model.addAttribute("leadDetailBrandValue", leadDetailBrandValue);
978 
 
979 
			model.addAttribute("leadMap", leadMap);
980 
		}
981 
 
982 
		model.addAttribute("leadDetails", leadDetails);
983 
 
984 
		Map<Integer, AuthUser> authIdAndAuthUserMap = authRepository.selectAllActiveUser().stream()
985 
				.collect(Collectors.toMap(x -> x.getId(), x -> x));
986 
		model.addAttribute("authIdAndAuthUserMap", authIdAndAuthUserMap);
987 
 
988 
		return "lead-detail";
989 
 
990 
	}
991 
 
992 
	@RequestMapping(value = "/getLeadDetailByLeadId", method = RequestMethod.GET)
993 
	public ResponseEntity<?> getLeadDetailByLeadId(HttpServletRequest request, @RequestParam int leadId, Model model)
994 
			throws Exception {
995 
 
996 
		LeadDetail leadDetail = leadDetailRepository.selectByLeadId(leadId);
997 
		return responseSender.ok(leadDetail);
998 
 
999 
	}
1000 
 
30185 tejbeer 1001 
	@RequestMapping(value = "/getTeamCommitment", method = RequestMethod.GET)
1002 
	public String getTeamCommitments(HttpServletRequest request, @RequestParam LocalDateTime date, Model model)
1003 
			throws Exception {
1004 
 
1005 
		List<TeamCommitmentModel> commitments = partnerCollectionPlanRepository
1006 
				.selectTeamCommitmentByDate(date.toLocalDate());
1007 
 
1008 
		model.addAttribute("commitments", commitments);
1009 
		return "team-commitment-table";
1010 
 
1011 
	}
30416 tejbeer 1012 
 
1013 
	@RequestMapping(value = "/partnerHealth", method = RequestMethod.GET)
1014 
	public String partnerHealth(HttpServletRequest request,
1015 
			@RequestParam(name = "email", required = false) String email, Model model) throws Exception {
1016 
		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1017 
 
1018 
		if (StringUtils.isEmpty(email)) {
1019 
			email = loginDetails.getEmailId();
1020 
		} else {
1021 
			AuthUser selectedUser = authRepository.selectByEmailOrMobile(email);
1022 
 
1023 
			model.addAttribute("selectedUser", selectedUser);
1024 
 
1025 
		}
1026 
 
1027 
		AuthUser authUser = authRepository.selectByEmailOrMobile(loginDetails.getEmailId());
1028 
 
1029 
		Map<String, Set<Integer>> storeGuyMap = csService.getAuthUserPartnerIdMapping();
30771 amit.gupta 1030 
		List<Integer> fofoIds = new ArrayList<>(storeGuyMap.get(email));
30416 tejbeer 1031 
		LocalDateTime startDate = LocalDate.now().atStartOfDay();
30771 amit.gupta 1032 
		if (fofoIds != null && fofoIds.size() > 0) {
1033 
			List<Integer> fofoIdList = fofoStoreRepository.selectByRetailerIds(fofoIds).stream()
30416 tejbeer 1034 
					.filter(x -> !x.isInternal()).map(x -> x.getId()).collect(Collectors.toList());
1035 
 
1036 
			Map<Integer, PartnerCollectionPlanModel> foundCollectionMap = partnerCollectionService
1037 
					.getCollectionMap(fofoIdList, startDate);
1038 
 
30434 tejbeer 1039 
			List<Integer> remarkIds = partnerCollectionRemarkRepository.selectMaxRemarkId(fofoIdList);
1040 
 
1041 
			LOGGER.info("remarkIds {}", remarkIds);
1042 
 
1043 
			long todayOverallCall = 0;
1044 
			if (!remarkIds.isEmpty()) {
1045 
 
30459 tejbeer 1046 
				if (authUser.getEmailId().equals(email)) {
30458 tejbeer 1047 
 
1048 
					todayOverallCall = partnerCollectionRemarkRepository.selectByIds(remarkIds).stream()
1049 
							.filter(x -> x.getCreateTimestamp().toLocalDate().equals(LocalDate.now()))
1050 
							.collect(Collectors.counting());
1051 
				} else {
1052 
 
1053 
					todayOverallCall = partnerCollectionRemarkRepository
1054 
							.selectByAuthIdAndIds(authRepository.selectByEmailOrMobile(email).getId(), remarkIds)
1055 
							.stream().filter(x -> x.getCreateTimestamp().toLocalDate().equals(LocalDate.now()))
1056 
							.collect(Collectors.counting());
1057 
 
1058 
				}
1059 
 
30434 tejbeer 1060 
			}
30781 tejbeer 1061 
			ChartLeadModel cm = new ChartLeadModel();
30434 tejbeer 1062 
 
30781 tejbeer 1063 
			if (!foundCollectionMap.isEmpty()) {
1064 
				cm = this.getCollectionCount(foundCollectionMap.values().stream().collect(Collectors.toList()));
1065 
 
1066 
			}
30416 tejbeer 1067 
			model.addAttribute("chartPartnerHealth", gson.toJson(cm));
1068 
			Map<Integer, PartnerDailyInvestment> partnerDailyInvestmentMap = new HashMap<>();
1069 
 
1070 
			List<PartnerDailyInvestment> partnerDailyInvestments = partnerDailyInvestmentRepository
1071 
					.selectAll(fofoIdList, startDate.toLocalDate().minusDays(1));
1072 
			if (!partnerDailyInvestments.isEmpty()) {
1073 
				partnerDailyInvestmentMap = partnerDailyInvestments.stream()
1074 
						.collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
1075 
			}
1076 
 
1077 
			Map<LocalDate, Map<Integer, PartnerCollectionPlanModel>> pcpmMap = new TreeMap<>();
1078 
			for (int i = 0; i <= 6; i++) {
1079 
 
1080 
				Map<Integer, PartnerCollectionPlanModel> collectionMap = partnerCollectionService
1081 
						.getCollectionMap(fofoIdList, startDate.minusDays(i));
1082 
 
1083 
				pcpmMap.put(startDate.minusDays(i).toLocalDate(), collectionMap);
1084 
			}
1085 
 
1086 
			Map<Integer, PartnerCollectionPlanModel> todayPcpmMap = pcpmMap.get(startDate.toLocalDate());
1087 
			model.addAttribute("todayPcpmMap", todayPcpmMap);
30445 tejbeer 1088 
 
30808 tejbeer 1089 
			TotalTargetColectionModel totalTargetCollection = partnerCollectionService
1090 
					.getTotalTargetCollection(todayPcpmMap, startDate);
1091 
			model.addAttribute("totalPartnerTargetCollection", totalTargetCollection.getTotalTarget());
30445 tejbeer 1092 
 
30808 tejbeer 1093 
			model.addAttribute("totalPartnerAchievement", totalTargetCollection.getTotalAchievement());
30445 tejbeer 1094 
 
30426 tejbeer 1095 
			Map<Integer, CustomRetailer> customRetailerMap = retailerService.getAllFofoRetailers();
30582 tejbeer 1096 
			Map<Integer, CustomRetailer> customRetailers = fofoIdList.stream().distinct()
1097 
					.map(x -> customRetailerMap.get(x)).filter(x -> x != null).collect(Collectors.toList()).stream()
30426 tejbeer 1098 
					.collect(Collectors.toMap(x -> x.getPartnerId(), x -> x));
30416 tejbeer 1099 
			List<Integer> allReportees = authService.getAllReportees(authUser.getId());
30420 tejbeer 1100 
 
30416 tejbeer 1101 
			List<Integer> salesPositionsAuthIds = positionRepository
1102 
					.selectPositionByCategoryId(ProfitMandiConstants.TICKET_CATEGORY_SALES).stream()
1103 
					.map(x -> x.getAuthUserId()).collect(Collectors.toList());
1104 
			List<Integer> rbmPositionsAuthIds = positionRepository
1105 
					.selectPositionByCategoryId(ProfitMandiConstants.TICKET_CATEGORY_RBM).stream()
1106 
					.map(x -> x.getAuthUserId()).collect(Collectors.toList());
1107 
 
1108 
			salesPositionsAuthIds.addAll(rbmPositionsAuthIds);
1109 
 
1110 
			Set<Integer> empHierarchy = allReportees.stream().filter(x -> salesPositionsAuthIds.contains(x))
1111 
					.collect(Collectors.toSet());
1112 
 
1113 
			List<AuthUser> authUsers = authRepository.selectAllAuthUserByIds(new ArrayList<>(empHierarchy));
1114 
 
30441 tejbeer 1115 
			Map<Integer, AuthUser> authUserMap = authRepository.selectAll().stream()
1116 
					.collect(Collectors.toMap(x -> x.getId(), x -> x));
1117 
 
1118 
			LOGGER.info("todayPcpmMap {}", todayPcpmMap);
1119 
 
30416 tejbeer 1120 
			model.addAttribute("authUsers", authUsers);
30441 tejbeer 1121 
			model.addAttribute("authUserMap", authUserMap);
30416 tejbeer 1122 
			model.addAttribute("partnerCollectionPlanMap", pcpmMap);
1123 
			model.addAttribute("partnerDailyInvestmentMap", partnerDailyInvestmentMap);
1124 
			model.addAttribute("customRetailers", customRetailers);
1125 
			model.addAttribute("rankColorMap", ProfitMandiConstants.Rank_Color_Map);
30434 tejbeer 1126 
			model.addAttribute("todayOverallCall", todayOverallCall);
30416 tejbeer 1127 
 
1128 
		}
1129 
		return "partner-health";
1130 
 
1131 
	}
1132 
 
1133 
	public ChartLeadModel getCollectionCount(List<PartnerCollectionPlanModel> pcpm)
1134 
			throws ProfitMandiBusinessException {
1135 
 
1136 
		Map<Integer, Long> rankCount = pcpm.stream().collect(Collectors.groupingBy(x -> x.getRank(),
1137 
				Collectors.mapping(PartnerCollectionPlanModel::getRank, Collectors.counting())));
1138 
 
1139 
		ChartLeadModel cm = new ChartLeadModel();
1140 
 
30771 amit.gupta 1141 
		List<String> labels = new ArrayList<>();
30416 tejbeer 1142 
		labels.add("Plan for Today");
1143 
		labels.add("Carry Forward");
1144 
		labels.add("Untouched");
1145 
		labels.add("Plan for Future");
1146 
		labels.add("Normal");
1147 
 
1148 
		List<String> backgroundColor = new ArrayList<>();
1149 
		List<Long> values = new ArrayList<>();
1150 
 
1151 
		for (String label : labels) {
1152 
 
1153 
			if (label.equals("Plan for Today")) {
1154 
				backgroundColor.add("#007bff");
1155 
				values.add(rankCount.get(1));
1156 
			}
1157 
			if (label.equals("Carry Forward")) {
1158 
				backgroundColor.add("#ffc107");
1159 
				values.add(rankCount.get(2));
1160 
			}
1161 
			if (label.equals("Untouched")) {
1162 
				backgroundColor.add("#dc3545");
1163 
				values.add(rankCount.get(3));
1164 
			}
1165 
			if (label.equals("Plan for Future")) {
1166 
				backgroundColor.add("#6c757d");
1167 
				values.add(rankCount.get(4));
1168 
			}
1169 
			if (label.equals("Normal")) {
1170 
				backgroundColor.add("White");
1171 
				values.add(rankCount.get(5));
1172 
			}
1173 
 
1174 
		}
1175 
 
1176 
		LOGGER.info("backgroundColor" + backgroundColor);
1177 
		LOGGER.info("labelsChartLead" + labels);
1178 
		LeadStatusData data = new LeadStatusData();
1179 
		data.setData(values);
1180 
		data.setBackgroundColor(backgroundColor);
1181 
		data.setLabel("DataSet 1");
1182 
 
1183 
		PieLables label = new PieLables();
1184 
		label.setFontColor("black");
1185 
		label.setFontSize(15);
1186 
 
1187 
		Legend legend = new Legend();
1188 
		legend.setLabels(label);
1189 
		legend.setPosition("left");
1190 
 
1191 
		List<LeadStatusData> dataList = new ArrayList<>();
1192 
		dataList.add(data);
1193 
 
1194 
		DataLeadModel datasets = new DataLeadModel();
1195 
		datasets.setDatasets(dataList);
1196 
		datasets.setLabels(labels);
1197 
 
1198 
		OptionModel om = new OptionModel();
1199 
		om.setLegend(legend);
1200 
 
1201 
		cm.setType("pie");
1202 
		cm.setData(datasets);
1203 
		cm.setOptions(om);
1204 
 
1205 
		return cm;
1206 
	}
1207 
 
30522 tejbeer 1208 
	@RequestMapping(value = "/franchiseVisit", method = RequestMethod.GET)
1209 
	public String franchiseVisit(HttpServletRequest request,
1210 
			@RequestParam(name = "email", required = false) String email, Model model) throws Exception {
1211 
		LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1212 
 
1213 
		AuthUser authUser = authRepository.selectByEmailOrMobile(loginDetails.getEmailId());
1214 
 
1215 
		List<Integer> salesPositionsAuthIds = positionRepository
1216 
				.selectPositionByCategoryId(ProfitMandiConstants.TICKET_CATEGORY_SALES).stream()
1217 
				.map(x -> x.getAuthUserId()).collect(Collectors.toList());
1218 
		List<Integer> rbmPositionsAuthIds = positionRepository
1219 
				.selectPositionByCategoryId(ProfitMandiConstants.TICKET_CATEGORY_RBM).stream()
1220 
				.map(x -> x.getAuthUserId()).collect(Collectors.toList());
1221 
 
1222 
		salesPositionsAuthIds.addAll(rbmPositionsAuthIds);
1223 
 
1224 
		List<Integer> allReportees = authService.getAllReportees(authUser.getId());
1225 
 
1226 
		Set<Integer> empHierarchy = allReportees.stream().filter(x -> salesPositionsAuthIds.contains(x))
1227 
				.collect(Collectors.toSet());
1228 
 
1229 
		List<AuthUser> authUsers = authRepository.selectAllAuthUserByIds(new ArrayList<>(empHierarchy));
1230 
 
1231 
		Map<Integer, String> monthValueMap = new HashMap<>();
1232 
		for (int i = 0; i <= 5; i++) {
1233 
			LocalDateTime startOfMonth = LocalDateTime.now().withDayOfMonth(1).minusMonths(i);
1234 
			monthValueMap.put(i, startOfMonth.format(DateTimeFormatter.ofPattern("MMM''uu")));
1235 
		}
1236 
 
1237 
		model.addAttribute("authUsers", authUsers);
1238 
		model.addAttribute("monthValueMap", monthValueMap);
1239 
 
1240 
		return "franchise-visit";
1241 
 
1242 
	}
1243 
 
1244 
	@RequestMapping(value = "/getFranchiseVisit", method = RequestMethod.GET)
1245 
	public String getFranchiseVisit(HttpServletRequest request,
1246 
			@RequestParam(name = "authId", required = false) int authId, int yearMonth, Model model) throws Exception {
1247 
 
30582 tejbeer 1248 
		LocalDateTime startDate = LocalDate.now().minusMonths(8).withDayOfMonth(1).atStartOfDay();
30522 tejbeer 1249 
		LocalDateTime endDate = startDate.plusMonths(1).withDayOfMonth(1).toLocalDate().atStartOfDay();
1250 
 
1251 
		DateRangeModel drm = DateRangeModel.of(startDate, endDate);
1252 
 
1253 
		List<FranchiseeVisit> visits = franchiseeVisitRepository.selectByAuthUserAndDateRange(drm, authId);
1254 
 
1255 
		if (!visits.isEmpty()) {
1256 
 
1257 
			Map<Integer, List<FranchiseeVisit>> franchiseeVisitMap = visits.stream()
1258 
					.collect(Collectors.groupingBy(x -> x.getScheduleTimestamp().getDayOfMonth()));
1259 
 
1260 
			model.addAttribute("franchiseeVisitMap", franchiseeVisitMap);
1261 
 
1262 
		}
1263 
 
1264 
		model.addAttribute("visits", visits);
1265 
		model.addAttribute("monthLength", startDate.toLocalDate().lengthOfMonth());
1266 
 
1267 
		// Calender
1268 
 
1269 
		int Year = startDate.getYear(); // year
1270 
		int startDayOfMonth = 5;
1271 
		int spaces = startDayOfMonth;
1272 
 
1273 
		int month = startDate.getMonthValue();
1274 
 
1275 
		int[] days = { 0, 31, 28, 31, 30, 31, 30, 31, 31, 30, 31, 30, 31 };
1276 
 
1277 
		LOGGER.info("visits {} ", visits);
1278 
 
1279 
		if ((((Year % 4 == 0) && (Year % 100 != 0)) || (Year % 400 == 0)) && month == 2) {
1280 
			days[month] = 29;
1281 
		}
1282 
 
1283 
		spaces = (days[month - 1] + spaces) % 7;
1284 
 
1285 
		model.addAttribute("month", month);
1286 
		model.addAttribute("spaces", spaces);
1287 
		model.addAttribute("days", days);
1288 
 
1289 
		return "franchise-visit-container";
1290 
 
1291 
	}
1292 
 
1293 
	@RequestMapping(value = "/getFranchiseeActivity", method = RequestMethod.GET)
1294 
	public String getFranchiseeActivity(HttpServletRequest request, int visitId, Model model) throws Exception {
1295 
 
1296 
		List<FranchiseeActivity> franchiseeActivities = franchiseeActivityRepository.selectByFranchiseeVisitId(visitId);
1297 
 
1298 
		FranchiseeVisit franchiseeVisit = franchiseeVisitRepository.selectById(visitId);
1299 
 
1300 
		Map<Integer, AuthUser> authIdAndAuthUserMap = authRepository.selectAll().stream()
1301 
				.collect(Collectors.toMap(x -> x.getId(), x -> x));
1302 
		model.addAttribute("authIdAndAuthUserMap", authIdAndAuthUserMap);
1303 
 
1304 
		model.addAttribute("franchiseeVisit", franchiseeVisit);
1305 
		model.addAttribute("franchiseeActivity", franchiseeActivities.get(0));
1306 
 
1307 
		return "franchie-visit-detail";
1308 
 
1309 
	}
1310 
 
30771 amit.gupta 1311 
	@RequestMapping(value = "/indent/today_target", method = RequestMethod.GET)
1312 
	public String todayTarget(HttpServletRequest request, Model model) throws Exception {
1313 
		List<RBMPerformanceSummaryModel> summaryModels = new ArrayList<>();
1314 
		List<Integer> rbmPositionsAuthIds = positionRepository
30781 tejbeer 1315 
				.selectPositionByCategoryId(ProfitMandiConstants.TICKET_CATEGORY_RBM).stream()
1316 
				.filter(x -> Arrays.asList(EscalationType.L1, EscalationType.L2).contains(x.getEscalationType()))
30771 amit.gupta 1317 
				.map(x -> x.getAuthUserId()).distinct().collect(Collectors.toList());
1318 
		Map<String, Set<Integer>> storeGuyMap = csService.getAuthUserPartnerIdMapping();
30781 tejbeer 1319 
		List<TeamCommitmentModel> teamCommitmentModels = partnerCollectionPlanRepository
1320 
				.selectTeamCommitmentByDate(LocalDate.now());
1321 
		Map<Integer, Double> rbmSecondaryTargetMap = teamCommitmentModels.stream()
1322 
				.filter(x -> rbmPositionsAuthIds.contains(x.getAuthId()))
1323 
				.collect(Collectors.groupingBy(x -> x.getAuthId(),
1324 
						Collectors.summingDouble(x -> x.getTotalTarget() == null ? 0 : x.getTotalTarget())));
1325 
		Map<Integer, Double> rbmSecondaryMap = teamCommitmentModels.stream()
1326 
				.filter(x -> rbmPositionsAuthIds.contains(x.getAuthId()))
1327 
				.collect(Collectors.groupingBy(x -> x.getAuthId(),
1328 
						Collectors.summingDouble(x -> x.getTotalAchievement() == null ? 0 : x.getTotalAchievement())));
30771 amit.gupta 1329 
		LocalDateTime startDate = LocalDate.now().atStartOfDay();
1330 
		for (int rbmAuthId : rbmPositionsAuthIds) {
1331 
			RBMPerformanceSummaryModel rbmPerformanceSummaryModel = new RBMPerformanceSummaryModel();
1332 
			rbmPerformanceSummaryModel.setAuthId(rbmAuthId);
1333 
			AuthUser authUser = authRepository.selectById(rbmAuthId);
1334 
			rbmPerformanceSummaryModel.setAuthName(authUser.getFullName());
1335 
			List<Integer> fofoIds = new ArrayList<>(storeGuyMap.get(authUser.getEmailId()));
1336 
 
1337 
			if (fofoIds.size() > 0) {
30781 tejbeer 1338 
				fofoIds = fofoStoreRepository.selectByRetailerIds(fofoIds).stream().filter(x -> !x.isInternal())
1339 
						.map(x -> x.getId()).collect(Collectors.toList());
30771 amit.gupta 1340 
 
30781 tejbeer 1341 
				/*
1342 
				 * Map<Integer, PartnerCollectionPlanModel> foundCollectionMap =
1343 
				 * partnerCollectionService .getCollectionMap(fofoIds, startDate);
1344 
				 */
30771 amit.gupta 1345 
 
1346 
				List<Integer> remarkIds = partnerCollectionRemarkRepository.selectMaxRemarkId(fofoIds);
1347 
 
1348 
				LOGGER.info("remarkIds {}", remarkIds);
1349 
 
1350 
				long todayOverallCall = 0;
1351 
				if (!remarkIds.isEmpty()) {
1352 
					todayOverallCall = partnerCollectionRemarkRepository.selectByIds(remarkIds).stream()
1353 
							.filter(x -> x.getCreateTimestamp().toLocalDate().equals(LocalDate.now()))
1354 
							.collect(Collectors.counting());
1355 
 
1356 
				}
1357 
 
1358 
				Map<Integer, PartnerCollectionPlanModel> collectionMap = partnerCollectionService
1359 
						.getCollectionMap(fofoIds, startDate);
1360 
 
1361 
				ChartLeadModel cm = this
1362 
						.getCollectionCount(collectionMap.values().stream().collect(Collectors.toList()));
1363 
 
30781 tejbeer 1364 
				long collectionTarget = collectionMap.values().stream().filter(x -> x.getTargetPlan() != null)
1365 
						.collect(Collectors.summingLong(x -> x.getTargetPlan()));
1366 
				long collection = collectionMap.values().stream().filter(
1367 
						x -> x.getTargetPlan() != null && x.getTargetPlan() != 0 && x.getAchievementPlan() != null)
1368 
						.collect(Collectors.summingLong(x -> x.getAchievementPlan()));
30771 amit.gupta 1369 
				rbmPerformanceSummaryModel.setChartLeadModel(cm);
1370 
				rbmPerformanceSummaryModel.setPartnersCommunicated(todayOverallCall);
1371 
				rbmPerformanceSummaryModel.setCollectionTarget(collectionTarget);
1372 
				rbmPerformanceSummaryModel.setCollection(collection);
30781 tejbeer 1373 
				rbmPerformanceSummaryModel.setSecondaryTarget(rbmSecondaryTargetMap.get(rbmAuthId) == null ? 0
1374 
						: rbmSecondaryTargetMap.get(rbmAuthId).floatValue());
1375 
				rbmPerformanceSummaryModel.setSecondary(
1376 
						rbmSecondaryMap.get(rbmAuthId) == null ? 0 : rbmSecondaryMap.get(rbmAuthId).floatValue());
30771 amit.gupta 1377 
				summaryModels.add(rbmPerformanceSummaryModel);
30781 tejbeer 1378 
				// cm.getData().getDatasets().get(0).getData().;
1379 
				// cm.getData().getDatasets().get(0).getBackgroundColor();
1380 
				// cm.getData().getLabels()
30771 amit.gupta 1381 
 
1382 
			}
1383 
		}
1384 
		model.addAttribute("summaryModels", summaryModels);
1385 
		return "today_target";
1386 
	}
1387 
 
31249 tejbeer 1388 
	@RequestMapping(value = "/visitPlan", method = RequestMethod.GET)
1389 
	public String visitPlan(HttpServletRequest request, Model model) throws Exception {
1390 
 
1391 
		return "visit-request-plan";
1392 
	}
1393 
 
1394 
	@RequestMapping(value = "/visit/getVisitPlan", method = RequestMethod.GET)
1395 
	public String getVisitPlan(HttpServletRequest request, @RequestParam LocalDate date, Model model) throws Exception {
1396 
		List<VisitRequest> visitRequests = visitRequestRepository.selectByAuthIdAndDate(date);
1397 
 
1398 
		List<Integer> leadIds = visitRequests.stream().filter(x -> x.getVisitType().equals("lead"))
1399 
				.map(x -> x.getVisitId()).collect(Collectors.toList());
1400 
		Map<Integer, Lead> leadMap = new HashMap<>();
1401 
		if (!leadIds.isEmpty()) {
1402 
			List<Lead> leads = leadRepository.selectAllByIds(leadIds);
1403 
 
1404 
			for (Lead lead : leads) {
1405 
				List<LeadActivity> leadActivities = leadActivityRepository.selectBYLeadId(lead.getId());
1406 
				lead.setScheduledTimestamp(leadActivities.get(0).getSchelduleTimestamp());
1407 
				lead.setLeadActivity(leadActivities.get(0));
1408 
 
1409 
				leadMap.put(lead.getId(), lead);
1410 
			}
1411 
 
1412 
		}
1413 
		List<Integer> franchiseeIds = visitRequests.stream().filter(x -> x.getVisitType().equals("franchiseeVisit"))
1414 
				.map(x -> x.getVisitId()).collect(Collectors.toList());
1415 
		Map<Integer, FranchiseeVisit> franchiseeVisitsMap = new HashMap<>();
1416 
		if (!franchiseeIds.isEmpty()) {
1417 
			List<FranchiseeVisit> franchiseeVisits = franchiseeVisitRepository.selectAllByIds(franchiseeIds);
1418 
			LOGGER.info("franchiseeVisits {}", franchiseeVisits);
1419 
 
1420 
			for (FranchiseeVisit franchiseeVisit : franchiseeVisits) {
1421 
				List<FranchiseeActivity> franchiseeActivities = franchiseeActivityRepository
1422 
						.selectByFranchiseeVisitId(franchiseeVisit.getId());
1423 
				LOGGER.info("franchiseeActivities {}", franchiseeActivities);
1424 
 
1425 
				franchiseeVisit.setScheduleTimestamp(franchiseeActivities.get(0).getSchelduleTimestamp());
1426 
				franchiseeVisit.setFranchiseeActivity(franchiseeActivities.get(0));
1427 
 
1428 
				franchiseeVisitsMap.put(franchiseeVisit.getId(), franchiseeVisit);
1429 
			}
1430 
 
1431 
		}
1432 
 
1433 
		Map<Integer, List<VisitRequest>> visitRequestMap = visitRequests.stream()
1434 
				.collect(Collectors.groupingBy(x -> x.getCreatedBy()));
1435 
		List<AuthUser> authUsers = authRepository.selectAllActiveUser();
1436 
		List<UserVisitModel> userVisits = new ArrayList<>();
1437 
 
1438 
		for (AuthUser authUser : authUsers) {
1439 
 
1440 
			List<VisitRequest> authVisitRequests = visitRequestMap.get(authUser.getId());
1441 
 
1442 
			if (authVisitRequests != null) {
1443 
				UserVisitModel userVisitModel = new UserVisitModel();
1444 
				userVisitModel.setAuthUser(authUser.getFullName());
1445 
				List<VisitDescriptionModel> visitDescriptions = new ArrayList<>();
1446 
 
1447 
				for (VisitRequest authVisitRequest : authVisitRequests) {
1448 
					VisitDescriptionModel visitDescriptionModel = new VisitDescriptionModel();
1449 
					visitDescriptionModel.setVisitId(authVisitRequest.getVisitId());
1450 
 
1451 
					if (authVisitRequest.getVisitType().equals("lead")) {
1452 
						Lead lead = leadMap.get(authVisitRequest.getVisitId());
1453 
 
1454 
						visitDescriptionModel.setVisitName(lead.getFirstName());
1455 
						visitDescriptionModel.setCity(lead.getCity());
1456 
						visitDescriptionModel.setState(lead.getState());
1457 
						visitDescriptionModel.setScheduleTime(lead.getScheduledTimestamp());
1458 
						visitDescriptionModel.setRemarks(lead.getLeadActivity().getRemark());
1459 
 
1460 
					} else {
1461 
						FranchiseeVisit franchiseeVisit = franchiseeVisitsMap.get(authVisitRequest.getVisitId());
1462 
						CustomRetailer customRetailer = retailerService.getFofoRetailer(franchiseeVisit.getFofoId());
1463 
 
1464 
						visitDescriptionModel.setVisitName(franchiseeVisit.getPartnerName());
1465 
						visitDescriptionModel.setCity(customRetailer.getAddress().getCity());
1466 
						visitDescriptionModel.setState(customRetailer.getAddress().getState());
1467 
						visitDescriptionModel
1468 
								.setScheduleTime(franchiseeVisit.getFranchiseeActivity().getSchelduleTimestamp());
1469 
						visitDescriptionModel.setRemarks(franchiseeVisit.getAgenda());
1470 
 
1471 
					}
1472 
 
1473 
					if (authVisitRequest.getActionedBy() != 0) {
1474 
						AuthUser au = authRepository.selectById(authVisitRequest.getActionedBy());
1475 
 
1476 
						visitDescriptionModel.setActionBy(au.getFullName());
1477 
					}
1478 
					visitDescriptionModel.setStatus(authVisitRequest.getStatus());
1479 
					visitDescriptionModel.setVisitType(authVisitRequest.getVisitType());
1480 
					visitDescriptions.add(visitDescriptionModel);
1481 
				}
1482 
 
1483 
				userVisitModel.setVisitDescriptions(visitDescriptions);
1484 
				userVisits.add(userVisitModel);
1485 
			}
1486 
 
1487 
		}
1488 
 
1489 
		model.addAttribute("userVisits", userVisits);
1490 
 
1491 
		return "visit-request-plan";
1492 
	}
25979 tejbeer 1493 
}