WebSVN – SmartDukaan – Diff – /trunk/profitmandi-web/src/main/java/com/spice/profitmandi/web/controller/LeadController.java

 package com.spice.profitmandi.web.controller;
-import java.io.ByteArrayInputStream;
-import java.io.ByteArrayOutputStream;
 import java.io.IOException;
-import java.io.InputStream;
 import java.time.LocalDate;
 import java.time.LocalDateTime;
 import java.time.format.DateTimeFormatter;
 import java.util.ArrayList;
 import java.util.Arrays;
-import java.util.Base64;
 import java.util.Comparator;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 import java.util.Map.Entry;
 import org.apache.commons.csv.CSVRecord;
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.core.io.InputStreamResource;
 import org.springframework.format.annotation.DateTimeFormat;
 import org.springframework.http.HttpHeaders;
 import org.springframework.http.HttpStatus;
 import org.springframework.http.MediaType;
 import org.springframework.http.ResponseEntity;
 import org.springframework.web.bind.annotation.RequestParam;
 import org.springframework.web.bind.annotation.RequestPart;
 import org.springframework.web.multipart.MultipartFile;
 import com.mongodb.DBObject;
+import com.spice.profitmandi.common.enumuration.MessageType;
 import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
-import com.spice.profitmandi.common.model.BrandStockPrice;
 import com.spice.profitmandi.common.model.CustomRetailer;
-import com.spice.profitmandi.common.model.InvoicePdfModel;
 import com.spice.profitmandi.common.model.ProfitMandiConstants;
+import com.spice.profitmandi.common.model.SendNotificationModel;
 import com.spice.profitmandi.common.util.FileUtil;
-import com.spice.profitmandi.common.util.PdfUtils;
+import com.spice.profitmandi.common.util.FormattingUtils;
 import com.spice.profitmandi.common.web.util.ResponseSender;
 import com.spice.profitmandi.dao.entity.auth.AuthUser;
 import com.spice.profitmandi.dao.entity.auth.PartnerCollectionPlan;
 import com.spice.profitmandi.dao.entity.auth.PartnerCollectionRemark;
 import com.spice.profitmandi.dao.entity.auth.PartnerSecondaryPlan;
 import com.spice.profitmandi.dao.entity.cs.Ticket;
 import com.spice.profitmandi.dao.entity.cs.TicketCategory;
 import com.spice.profitmandi.dao.entity.cs.TicketSubCategory;
 import com.spice.profitmandi.dao.entity.dtr.User;
 import com.spice.profitmandi.dao.entity.dtr.UserAccount;
-import com.spice.profitmandi.dao.entity.fofo.FofoOrder;
 import com.spice.profitmandi.dao.entity.fofo.FofoStore;
 import com.spice.profitmandi.dao.entity.fofo.PartnerDailyInvestment;
 import com.spice.profitmandi.dao.entity.fofo.PartnerOnBoardingPanel;
 import com.spice.profitmandi.dao.entity.user.FranchiseeActivity;
 import com.spice.profitmandi.dao.entity.user.FranchiseeVisit;
 import com.spice.profitmandi.dao.entity.user.Lead;
 import com.spice.profitmandi.dao.entity.user.LeadActivity;
+import com.spice.profitmandi.dao.entity.user.VisitRequest;
 import com.spice.profitmandi.dao.enumuration.auth.CollectionRemark;
+import com.spice.profitmandi.dao.enumuration.dtr.CommunicationType;
 import com.spice.profitmandi.dao.enumuration.dtr.FranchiseeActivityStatus;
 import com.spice.profitmandi.dao.enumuration.dtr.FranchiseeVisitStatus;
 import com.spice.profitmandi.dao.enumuration.dtr.LeadStatus;
 import com.spice.profitmandi.dao.enumuration.dtr.StoreTimeline;
+import com.spice.profitmandi.dao.enumuration.dtr.VisitStatus;
 import com.spice.profitmandi.dao.model.CreateRefferalRequest;
 import com.spice.profitmandi.dao.model.OnBoardingTimelineModel;
-import com.spice.profitmandi.dao.model.PartnerCollectionAchievementModel;
 import com.spice.profitmandi.dao.model.PartnerCollectionPlanModel;
 import com.spice.profitmandi.dao.model.PartnerCollectionRemarkModel;
 import com.spice.profitmandi.dao.model.PartnerSecondaryPlanModel;
 import com.spice.profitmandi.dao.model.PartnerTargetAchievementModel;
 import com.spice.profitmandi.dao.model.TargetModel;
 import com.spice.profitmandi.dao.model.TicketViewModel;
 import com.spice.profitmandi.dao.model.UserCart;
+import com.spice.profitmandi.dao.model.UserVisitModel;
+import com.spice.profitmandi.dao.model.VisitDescriptionModel;
+import com.spice.profitmandi.dao.model.VisitSummaryModel;
 import com.spice.profitmandi.dao.repository.auth.AuthRepository;
 import com.spice.profitmandi.dao.repository.auth.AuthUserPartnerMappingRepository;
 import com.spice.profitmandi.dao.repository.auth.PartnerCollectionPlanRepository;
 import com.spice.profitmandi.dao.repository.auth.PartnerCollectionRemarkRepository;
 import com.spice.profitmandi.dao.repository.auth.PartnerSecondaryPlanRepository;
 import com.spice.profitmandi.dao.repository.cs.CsService;
-import com.spice.profitmandi.dao.repository.cs.PositionRepository;
 import com.spice.profitmandi.dao.repository.cs.TicketCategoryRepository;
 import com.spice.profitmandi.dao.repository.cs.TicketRepository;
 import com.spice.profitmandi.dao.repository.cs.TicketSubCategoryRepository;
 import com.spice.profitmandi.dao.repository.dtr.FofoStoreRepository;
 import com.spice.profitmandi.dao.repository.dtr.FranchiseeActivityRepository;
 import com.spice.profitmandi.dao.repository.dtr.LeadRepository;
 import com.spice.profitmandi.dao.repository.dtr.Mongo;
 import com.spice.profitmandi.dao.repository.dtr.PartnerOnBoardingPanelRepository;
 import com.spice.profitmandi.dao.repository.dtr.UserAccountRepository;
 import com.spice.profitmandi.dao.repository.dtr.UserRepository;
+import com.spice.profitmandi.dao.repository.dtr.VisitRequestRepository;
 import com.spice.profitmandi.dao.repository.fofo.PartnerDailyInvestmentRepository;
 import com.spice.profitmandi.dao.repository.transaction.OrderRepository;
+import com.spice.profitmandi.service.AuthService;
-import com.spice.profitmandi.dao.repository.transaction.UserWalletRepository;
+import com.spice.profitmandi.service.NotificationService;
 import com.spice.profitmandi.service.PartnerCollectionService;
 import com.spice.profitmandi.service.user.RetailerService;
 import com.spice.profitmandi.service.user.StoreTimelineTatService;
 import com.spice.profitmandi.web.req.CreateFranchiseeRequest;
 import com.spice.profitmandi.web.res.Partner;
 import io.swagger.annotations.ApiImplicitParam;
 import io.swagger.annotations.ApiImplicitParams;
-import okhttp3.OkHttpClient;
-import okhttp3.Request;
-import okhttp3.Response;
 @Controller
 @Transactional(rollbackFor = Throwable.class)
 public class LeadController {
 	private static final Logger LOGGER = LogManager.getLogger(LeadController.class);
 	@Autowired
 	private OrderRepository orderRepository;
 	@Autowired
-	private PositionRepository positionRepository;
-	@Autowired
-	private UserWalletRepository userWalletRepository;
-	@Autowired
 	private PartnerCollectionPlanRepository partnerCollectionPlanRepository;
 	@Autowired
 	private PartnerSecondaryPlanRepository partnerSecondaryPlanRepository;
 	private PartnerDailyInvestmentRepository partnerDailyInvestmentRepository;
 	@Autowired
 	private AuthUserPartnerMappingRepository authUserPartnerMappingRepository;
+	@Autowired
+	private VisitRequestRepository visitRequestRepository;
+	@Autowired
+	private AuthService authService;
+	@Autowired
+	private NotificationService notificationService;
 	@RequestMapping(value = "/lead", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_VALUE)
 	@ApiImplicitParams({
 			@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
 	public ResponseEntity<?> LeadUser(HttpServletRequest request,
 			@RequestBody CreateRefferalRequest createRefferalRequest) throws Exception {
 		leadRepository.persist(lead);
 		LeadActivity leadActivity = new LeadActivity();
 		leadActivity.setLeadId(lead.getId());
 		leadActivity.setRemark(createRefferalRequest.getRemark());
+		leadActivity.setAuthId(authUser.getId());
 		if (createRefferalRequest.getStatus().equals(LeadStatus.followUp)) {
 			leadActivity.setSchelduleTimestamp(createRefferalRequest.getSchelduleTimestamp());
+			leadActivity.setCommunicationType(createRefferalRequest.getCommunicationType());
+			if (leadActivity.getCommunicationType().equals(CommunicationType.VISIT)) {
+				visitRequestRepository.createVisitRequest(lead.getId(), "lead", lead.getAssignTo(),
+						createRefferalRequest.getSchelduleTimestamp());
+			}
+			//
 			leadActivity.setClosureTimestamp(createRefferalRequest.getClosureTimestamp());
 			lead.setClosureTimestamp(createRefferalRequest.getClosureTimestamp());
 		} else {
 			leadActivity.setSchelduleTimestamp(null);
 			leadActivity.setClosureTimestamp(null);
 	public ResponseEntity<?> leadDescription(HttpServletRequest request, @RequestParam(name = "gmailId") String gmailId,
 			@RequestParam(name = "status") LeadStatus status) throws ProfitMandiBusinessException {
 		AuthUser authUser = authRepository.selectByGmailId(gmailId);
 		List<Lead> leads = null;
 		LOGGER.info("emails" + status);
+		List<VisitRequest> visitRequests = visitRequestRepository.selectByAuthIdAndDate(authUser.getId(),
+				LocalDate.now());
+		Map<Integer, List<VisitRequest>> visitRequestMap = null;
+		if (!visitRequests.isEmpty()) {
+			visitRequestMap = visitRequests.stream().collect(Collectors.groupingBy(x -> x.getVisitId()));
+		}
 		if (status.equals(LeadStatus.followUp)) {
 			leads = leadRepository.selectLeadsScheduledBetweenDate(Arrays.asList(authUser.getId()), null, null);
+			if (visitRequestMap != null) {
+				for (Lead lead : leads) {
+					List<VisitRequest> visitRequest = visitRequestMap.get(lead.getId());
+					if (visitRequest != null) {
+						if (visitRequest.size() > 1) {
+							Comparator<VisitRequest> visitComparato = Comparator
+									.comparing(VisitRequest::getCreatedTimestamp);
+							VisitRequest youngestVisit = visitRequest.stream().max(visitComparato).get();
+							lead.setVisitStatus(youngestVisit.getStatus());
+						} else {
+							lead.setVisitStatus(visitRequest.get(0).getStatus());
+						}
+					}
+				}
+			}
 			leads = leads.stream()
 					.sorted(Comparator.comparing(Lead::getScheduledTimestamp,
 							Comparator.nullsFirst(Comparator.reverseOrder())))
 					.collect(Collectors
 							.toList());/*
 			@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
 	public ResponseEntity<?> leadUpdate(HttpServletRequest request, @RequestParam(name = "id") int id,
 			@RequestParam(name = "status") LeadStatus status, @RequestParam(name = "colorCheck") Boolean colorCheck,
 			@RequestParam(name = "remark") String remark, @RequestParam(name = "reason") String reason,
 			@RequestParam(name = "schelduleTimestamp") @DateTimeFormat(iso = DateTimeFormat.ISO.DATE_TIME) LocalDateTime schelduleTimestamp,
-			@RequestParam(name = "closureTimestamp") @DateTimeFormat(iso = DateTimeFormat.ISO.DATE_TIME) LocalDateTime closureTimestamp)
+			@RequestParam(name = "closureTimestamp") @DateTimeFormat(iso = DateTimeFormat.ISO.DATE_TIME) LocalDateTime closureTimestamp,
+			@RequestParam(name = "communicationType") CommunicationType communicationType)
 			throws ProfitMandiBusinessException {
 		Lead lead = leadRepository.selectById(id);
 		LeadActivity leadActivity = new LeadActivity();
 		leadActivity.setRemark(remark);
 		leadActivity.setLeadId(id);
 		leadActivity.setCreatedTimestamp(LocalDateTime.now());
 		leadActivity.setSchelduleTimestamp(null);
 		leadActivity.setClosureTimestamp(null);
+		leadActivity.setAuthId(lead.getAssignTo());
 		lead.setUpdatedTimestamp(LocalDateTime.now());
 		if (colorCheck == true) {
 			lead.setColor("Green");
 		} else {
 			lead.setColor("Yellow");
+		}
 		if (status == LeadStatus.followUp) {
+			if (schelduleTimestamp != null) {
+				leadActivity.setCommunicationType(communicationType);
+				if (leadActivity.getCommunicationType().equals(CommunicationType.VISIT)) {
+					visitRequestRepository.createVisitRequest(lead.getId(), "lead", lead.getAssignTo(),
+							schelduleTimestamp);
+				}
+			}
 			leadActivity.setSchelduleTimestamp(schelduleTimestamp);
 			leadActivity.setClosureTimestamp(closureTimestamp);
 			lead.setClosureTimestamp(closureTimestamp);
 		} else {
 		franchiseeVisit.setCreatedBy(authUserName);
 		franchiseeVisit.setAuthId(authUser.getId());
 		franchiseeVisitRepository.persist(franchiseeVisit);
+		FranchiseeActivity franchiseeActivity = new FranchiseeActivity();
+		franchiseeActivity.setAction(FranchiseeActivityStatus.FOLLOWUP);
+		franchiseeActivity.setFranchiseeVisitd(franchiseeVisit.getId());
+		franchiseeActivity.setResolution(createFranchiseeRequest.getResolution());
+		franchiseeActivity.setSchelduleTimestamp(createFranchiseeRequest.getFirstSchelduleTimestamp());
+		franchiseeActivity.setCreatedTimestamp(LocalDateTime.now());
+		franchiseeActivityRepository.persist(franchiseeActivity);
+		franchiseeVisit.setFranchiseActivityId(franchiseeActivity.getId());
+		visitRequestRepository.createVisitRequest(franchiseeVisit.getId(), "franchiseeVisit", authUser.getId(),
+				createFranchiseeRequest.getFirstSchelduleTimestamp());
 		return responseSender.ok(true);
+	}
 	@RequestMapping(value = "/franchise-visit", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_VALUE)
 	@ApiImplicitParams({
 		franchiseeActivity.setAction(createFranchiseeRequest.getAction());
 		franchiseeActivity.setFranchiseeVisitd(franchiseeVisit.getId());
 		franchiseeActivity.setResolution(createFranchiseeRequest.getResolution());
 		if (createFranchiseeRequest.getAction().equals(FranchiseeActivityStatus.FOLLOWUP)) {
 			franchiseeActivity.setSchelduleTimestamp(createFranchiseeRequest.getSchelduleTimestamp());
+			visitRequestRepository.createVisitRequest(franchiseeVisit.getId(), "franchiseeVisit",
+					franchiseeVisit.getAuthId(), createFranchiseeRequest.getSchelduleTimestamp());
 		} else {
 			franchiseeActivity.setSchelduleTimestamp(null);
+		}
 		franchiseeActivity.setCreatedTimestamp(LocalDateTime.now());
 		franchiseeActivityRepository.persist(franchiseeActivity);
 	public ResponseEntity<?> getFranchiseVisit(HttpServletRequest request,
 			@RequestParam(name = "gmailId") String gmailId, @RequestParam(name = "status") FranchiseeVisitStatus status,
 			@RequestParam(name = "offset", defaultValue = "0") int offset,
 			@RequestParam(name = "limit", defaultValue = "10") int limit) throws ProfitMandiBusinessException {
 		AuthUser authUser = authRepository.selectByGmailId(gmailId);
+		List<VisitRequest> visitRequests = visitRequestRepository.selectByAuthIdAndDate(authUser.getId(),
+				LocalDate.now());
+		Map<Integer, List<VisitRequest>> visitRequestMap = null;
+		if (!visitRequests.isEmpty()) {
+			visitRequestMap = visitRequests.stream().collect(Collectors.groupingBy(x -> x.getVisitId()));
+		}
 		List<FranchiseeVisit> franchiseeVisits = franchiseeVisitRepository.selectByAuthIdAndStatus(authUser.getId(),
 				status, offset, limit);
 		for (FranchiseeVisit fv : franchiseeVisits) {
+			if (visitRequestMap != null) {
+				List<VisitRequest> visitRequest = visitRequestMap.get(fv.getId());
+				if (visitRequest != null) {
+					if (visitRequest.size() > 1) {
+						Comparator<VisitRequest> visitComparato = Comparator
+								.comparing(VisitRequest::getCreatedTimestamp);
+						VisitRequest youngestVisit = visitRequest.stream().max(visitComparato).get();
+						fv.setVisitStatus(youngestVisit.getStatus());
+					} else {
+						fv.setVisitStatus(visitRequest.get(0).getStatus());
+					}
+				}
+			}
 			if (fv.getFranchiseActivityId() != 0) {
 				FranchiseeActivity fA = franchiseeActivityRepository.selectById(fv.getFranchiseActivityId());
 				fv.setFranchiseeActivity(fA);
+			}
+		}
 		return responseSender.ok(franchiseeVisits);
+	}
 		FranchiseeActivity franchiseeActivity = new FranchiseeActivity();
 		if (action == FranchiseeActivityStatus.FOLLOWUP) {
+			if (schelduleTimestamp != null) {
+				visitRequestRepository.createVisitRequest(franchiseeVisit.getId(), "franchiseeVisit",
+						franchiseeVisit.getAuthId(), schelduleTimestamp);
+			}
 			franchiseeActivity.setSchelduleTimestamp(schelduleTimestamp);
 			franchiseeVisit.setStatus(FranchiseeVisitStatus.OPEN);
 			franchiseeVisit.setUpdatedTimestamp(LocalDateTime.now());
 			franchiseeVisitRepository.persist(franchiseeVisit);
 		franchiseeVisit.setVisitTimestamp(LocalDateTime.now());
 		return responseSender.ok(true);
+	}
+	@RequestMapping(value = "/getVisitRequests", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
+	public ResponseEntity<?> getVisitRequests(HttpServletRequest request,
+			@RequestParam(name = "gmailId") String gmailId, Model model) throws Exception {
+		AuthUser authUser = authRepository.selectByGmailId(gmailId);
+		List<Integer> authUserIds = authService.getAllReportees(authUser.getId());
+		List<VisitSummaryModel> visitSummary = new ArrayList<>();
+		if (!authUserIds.isEmpty()) {
+			List<AuthUser> authUsers = authRepository.selectAllAuthUserByIds(authUserIds);
+			List<VisitRequest> allVisitRequests = visitRequestRepository.selectByAuthIdsAndDate(authUserIds,
+					LocalDate.now().minusDays(7), Arrays.asList(VisitStatus.approved, VisitStatus.pending));
+			LOGGER.info("allVisitRequests {}", allVisitRequests);
+			if (!allVisitRequests.isEmpty()) {
+				List<Integer> leadIds = allVisitRequests.stream().filter(x -> x.getVisitType().equals("lead"))
+						.map(x -> x.getVisitId()).collect(Collectors.toList());
+				List<Lead> leads = new ArrayList<>();
+				if (!leadIds.isEmpty()) {
+					leads = leadRepository.selectAllByIds(leadIds);
+					for (Lead lead : leads) {
+						List<LeadActivity> leadActivities = leadActivityRepository.selectBYLeadId(lead.getId());
+						lead.setScheduledTimestamp(leadActivities.get(0).getSchelduleTimestamp());
+						lead.setLeadActivity(leadActivities.get(0));
+					}
+				}
+				List<Integer> franchiseeIds = allVisitRequests.stream()
+						.filter(x -> x.getVisitType().equals("franchiseeVisit")).map(x -> x.getVisitId())
+						.collect(Collectors.toList());
+				List<FranchiseeVisit> franchiseeVisits = new ArrayList<>();
+				if (!franchiseeIds.isEmpty()) {
+					franchiseeVisits = franchiseeVisitRepository.selectAllByIds(franchiseeIds);
+					LOGGER.info("franchiseeVisits {}", franchiseeVisits);
+					for (FranchiseeVisit franchiseeVisit : franchiseeVisits) {
+						List<FranchiseeActivity> franchiseeActivities = franchiseeActivityRepository
+								.selectByFranchiseeVisitId(franchiseeVisit.getId());
+						LOGGER.info("franchiseeActivities {}", franchiseeActivities);
+						franchiseeVisit.setScheduleTimestamp(franchiseeActivities.get(0).getSchelduleTimestamp());
+						franchiseeVisit.setFranchiseeActivity(franchiseeActivities.get(0));
+					}
+				}
+				Map<LocalDate, List<VisitRequest>> dateWiseVisitRequest = allVisitRequests.stream()
+						.collect(Collectors.groupingBy(x -> x.getScheduleTimestamp().toLocalDate()));
+				for (Entry<LocalDate, List<VisitRequest>> visitEntry : dateWiseVisitRequest.entrySet()) {
+					LocalDate date = visitEntry.getKey();
+					List<VisitRequest> visitRequests = visitEntry.getValue();
+					VisitSummaryModel visitSummaryModel = new VisitSummaryModel();
+					visitSummaryModel.setDate(date);
+					List<Integer> dateWiseLeadEntry = visitRequests.stream()
+							.filter(x -> x.getVisitType().equals("lead")).map(x -> x.getVisitId())
+							.collect(Collectors.toList());
+					List<Integer> dateWiseFranchiseeIds = visitRequests.stream()
+							.filter(x -> x.getVisitType().equals("franchiseeVisit")).map(x -> x.getVisitId())
+							.collect(Collectors.toList());
+					Map<Integer, List<Lead>> filteredLeadsMap = null;
+					if (!leads.isEmpty()) {
+						filteredLeadsMap = leads.stream().filter(x -> dateWiseLeadEntry.contains(x.getId()))
+								.collect(Collectors.groupingBy(x -> x.getAssignTo()));
+					}
+					Map<Integer, List<FranchiseeVisit>> filteredFranchiseeVisitsMap = null;
+					if (!franchiseeVisits.isEmpty()) {
+						filteredFranchiseeVisitsMap = franchiseeVisits.stream()
+								.filter(x -> dateWiseFranchiseeIds.contains(x.getId()))
+								.collect(Collectors.groupingBy(x -> x.getAuthId()));
+					}
+					List<UserVisitModel> userVisits = new ArrayList<>();
+					for (AuthUser auth : authUsers) {
+						UserVisitModel userVisitModel = new UserVisitModel();
+						List<VisitDescriptionModel> visitDescriptions = new ArrayList<>();
+						List<Lead> authLeads = new ArrayList<>();
+						if (filteredLeadsMap != null) {
+							authLeads = filteredLeadsMap.get(auth.getId());
+						}
+						if (authLeads != null && !authLeads.isEmpty()) {
+							userVisitModel.setAuthUser(auth.getFullName());
+							for (Lead lead : authLeads) {
+								VisitRequest visitRequest = visitRequests.stream().filter(
+										x -> x.getVisitId() == lead.getId() && x.getCreatedBy() == lead.getAssignTo())
+										.findAny().orElse(null);
+								VisitDescriptionModel visitDescriptionModel = new VisitDescriptionModel();
+								visitDescriptionModel.setVisitId(visitRequest.getId());
+								visitDescriptionModel.setVisitName(lead.getFirstName());
+								visitDescriptionModel.setCity(lead.getCity());
+								visitDescriptionModel.setState(lead.getState());
+								visitDescriptionModel.setScheduleTime(lead.getScheduledTimestamp());
+								visitDescriptionModel.setStatus(visitRequest.getStatus());
+								visitDescriptionModel.setRemarks(lead.getLeadActivity().getRemark());
+								visitDescriptionModel.setVisitType(visitRequest.getVisitType());
+								visitDescriptions.add(visitDescriptionModel);
+							}
+						}
+						List<FranchiseeVisit> authfranchiseeVisit = new ArrayList<>();
+						if (filteredFranchiseeVisitsMap != null) {
+							authfranchiseeVisit = filteredFranchiseeVisitsMap.get(auth.getId());
+						}
+						if (authfranchiseeVisit != null && !authfranchiseeVisit.isEmpty()) {
+							userVisitModel.setAuthUser(auth.getFullName());
+							for (FranchiseeVisit franchiseeVisit : authfranchiseeVisit) {
+								VisitRequest visitRequest = visitRequests.stream()
+										.filter(x -> x.getVisitId() == franchiseeVisit.getId()
+												&& x.getCreatedBy() == franchiseeVisit.getAuthId())
+										.findAny().orElse(null);
+								CustomRetailer customRetailer = retailerService
+										.getFofoRetailer(franchiseeVisit.getFofoId());
+								VisitDescriptionModel visitDescriptionModel = new VisitDescriptionModel();
+								visitDescriptionModel.setVisitId(visitRequest.getId());
+								visitDescriptionModel.setVisitName(franchiseeVisit.getPartnerName());
+								visitDescriptionModel.setCity(customRetailer.getAddress().getCity());
+								visitDescriptionModel.setState(customRetailer.getAddress().getState());
+								visitDescriptionModel.setScheduleTime(
+										franchiseeVisit.getFranchiseeActivity().getSchelduleTimestamp());
+								visitDescriptionModel.setStatus(visitRequest.getStatus());
+								visitDescriptionModel.setRemarks(franchiseeVisit.getAgenda());
+								visitDescriptionModel.setVisitType(visitRequest.getVisitType());
+								visitDescriptions.add(visitDescriptionModel);
+							}
+						}
+						userVisitModel.setVisitDescriptions(visitDescriptions);
+						LOGGER.info("userVisit {}", userVisitModel);
+						if (userVisitModel.getAuthUser() != null) {
+							userVisits.add(userVisitModel);
+						}
+					}
+					visitSummaryModel.setUserVisits(userVisits);
+					visitSummary.add(visitSummaryModel);
+				}
+			}
+		}
+		return responseSender.ok(visitSummary);
+	}
+	@RequestMapping(value = "/visitRequest", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_VALUE)
+	public ResponseEntity<?> visitRequest(HttpServletRequest request, @RequestParam(name = "gmailId") String gmailId,
+			@RequestParam(name = "visitId") int visitId, @RequestParam(name = "status") VisitStatus status, Model model)
+			throws Exception {
+		AuthUser authUser = authRepository.selectByGmailId(gmailId);
+		VisitRequest visitRequest = visitRequestRepository.selectById(visitId);
+		visitRequest.setActionedBy(authUser.getId());
+		visitRequest.setStatus(status);
+		visitRequest.setUpdatedTimestamp(LocalDateTime.now());
+		if (status.equals(VisitStatus.approved)) {
+			visitRequest.setApprovedTimestamp(LocalDateTime.now());
+		}
+		SendNotificationModel sendNotificationModel = new SendNotificationModel();
+		sendNotificationModel.setCampaignName("Visit Request");
+		sendNotificationModel.setExpiresat(LocalDateTime.now().plusDays(1));
+		sendNotificationModel.setTitle("Visit Request");
+		String message = "Visit Request has been " + status + " for scheduled time on "
+				+ visitRequest.getScheduleTimestamp().toLocalDate();
+		sendNotificationModel.setMessage(message);
+		sendNotificationModel.setMessageType(MessageType.notification);
+		User user = userRepository.selectByEmailId(gmailId);
+		sendNotificationModel.setUserIds(new ArrayList<>(user.getId()));
+		notificationService.sendNotificationToAll(sendNotificationModel);
+		return responseSender.ok(true);
+	}
+}

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-web/src/main/java/com/spice/profitmandi/web/controller/LeadController.java – Rev 30822 → 31249