Subversion Repositories SmartDukaan

Rev

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

Rev Author Line No. Line
25899 tejbeer 1 
package com.spice.profitmandi.web.controller;
2 
 
30487 tejbeer 3 
import java.io.IOException;
30416 tejbeer 4 
import java.time.LocalDate;
5 
import java.time.LocalDateTime;
30433 tejbeer 6 
import java.time.format.DateTimeFormatter;
30416 tejbeer 7 
import java.util.ArrayList;
8 
import java.util.Arrays;
9 
import java.util.Comparator;
10 
import java.util.HashMap;
11 
import java.util.List;
12 
import java.util.Map;
13 
import java.util.Map.Entry;
14 
import java.util.Set;
15 
import java.util.stream.Collectors;
16 
 
17 
import javax.servlet.http.HttpServletRequest;
18 
 
30433 tejbeer 19 
import org.apache.commons.csv.CSVRecord;
30416 tejbeer 20 
import org.apache.logging.log4j.LogManager;
21 
import org.apache.logging.log4j.Logger;
22 
import org.springframework.beans.factory.annotation.Autowired;
23 
import org.springframework.format.annotation.DateTimeFormat;
30487 tejbeer 24 
import org.springframework.http.HttpHeaders;
25 
import org.springframework.http.HttpStatus;
30416 tejbeer 26 
import org.springframework.http.MediaType;
27 
import org.springframework.http.ResponseEntity;
28 
import org.springframework.stereotype.Controller;
29 
import org.springframework.transaction.annotation.Transactional;
30 
import org.springframework.ui.Model;
31 
import org.springframework.web.bind.annotation.RequestBody;
32 
import org.springframework.web.bind.annotation.RequestMapping;
33 
import org.springframework.web.bind.annotation.RequestMethod;
34 
import org.springframework.web.bind.annotation.RequestParam;
30433 tejbeer 35 
import org.springframework.web.bind.annotation.RequestPart;
36 
import org.springframework.web.multipart.MultipartFile;
30416 tejbeer 37 
 
30487 tejbeer 38 
import com.mongodb.DBObject;
31249 tejbeer 39 
import com.spice.profitmandi.common.enumuration.MessageType;
25899 tejbeer 40 
import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
25952 tejbeer 41 
import com.spice.profitmandi.common.model.CustomRetailer;
27117 tejbeer 42 
import com.spice.profitmandi.common.model.ProfitMandiConstants;
31249 tejbeer 43 
import com.spice.profitmandi.common.model.SendNotificationModel;
30433 tejbeer 44 
import com.spice.profitmandi.common.util.FileUtil;
31249 tejbeer 45 
import com.spice.profitmandi.common.util.FormattingUtils;
25899 tejbeer 46 
import com.spice.profitmandi.common.web.util.ResponseSender;
47 
import com.spice.profitmandi.dao.entity.auth.AuthUser;
30077 tejbeer 48 
import com.spice.profitmandi.dao.entity.auth.PartnerCollectionPlan;
30416 tejbeer 49 
import com.spice.profitmandi.dao.entity.auth.PartnerCollectionRemark;
30077 tejbeer 50 
import com.spice.profitmandi.dao.entity.auth.PartnerSecondaryPlan;
30416 tejbeer 51 
import com.spice.profitmandi.dao.entity.cs.Ticket;
52 
import com.spice.profitmandi.dao.entity.cs.TicketCategory;
53 
import com.spice.profitmandi.dao.entity.cs.TicketSubCategory;
25899 tejbeer 54 
import com.spice.profitmandi.dao.entity.dtr.User;
25952 tejbeer 55 
import com.spice.profitmandi.dao.entity.dtr.UserAccount;
28935 tejbeer 56 
import com.spice.profitmandi.dao.entity.fofo.FofoStore;
30087 tejbeer 57 
import com.spice.profitmandi.dao.entity.fofo.PartnerDailyInvestment;
28935 tejbeer 58 
import com.spice.profitmandi.dao.entity.fofo.PartnerOnBoardingPanel;
25952 tejbeer 59 
import com.spice.profitmandi.dao.entity.user.FranchiseeActivity;
60 
import com.spice.profitmandi.dao.entity.user.FranchiseeVisit;
25899 tejbeer 61 
import com.spice.profitmandi.dao.entity.user.Lead;
62 
import com.spice.profitmandi.dao.entity.user.LeadActivity;
31249 tejbeer 63 
import com.spice.profitmandi.dao.entity.user.VisitRequest;
30416 tejbeer 64 
import com.spice.profitmandi.dao.enumuration.auth.CollectionRemark;
31249 tejbeer 65 
import com.spice.profitmandi.dao.enumuration.dtr.CommunicationType;
25952 tejbeer 66 
import com.spice.profitmandi.dao.enumuration.dtr.FranchiseeActivityStatus;
67 
import com.spice.profitmandi.dao.enumuration.dtr.FranchiseeVisitStatus;
25899 tejbeer 68 
import com.spice.profitmandi.dao.enumuration.dtr.LeadStatus;
28935 tejbeer 69 
import com.spice.profitmandi.dao.enumuration.dtr.StoreTimeline;
31249 tejbeer 70 
import com.spice.profitmandi.dao.enumuration.dtr.VisitStatus;
30416 tejbeer 71 
import com.spice.profitmandi.dao.model.CreateRefferalRequest;
72 
import com.spice.profitmandi.dao.model.OnBoardingTimelineModel;
73 
import com.spice.profitmandi.dao.model.PartnerCollectionPlanModel;
74 
import com.spice.profitmandi.dao.model.PartnerCollectionRemarkModel;
75 
import com.spice.profitmandi.dao.model.PartnerSecondaryPlanModel;
76 
import com.spice.profitmandi.dao.model.PartnerTargetAchievementModel;
77 
import com.spice.profitmandi.dao.model.TargetModel;
78 
import com.spice.profitmandi.dao.model.TicketViewModel;
79 
import com.spice.profitmandi.dao.model.UserCart;
31249 tejbeer 80 
import com.spice.profitmandi.dao.model.UserVisitModel;
81 
import com.spice.profitmandi.dao.model.VisitDescriptionModel;
82 
import com.spice.profitmandi.dao.model.VisitSummaryModel;
25899 tejbeer 83 
import com.spice.profitmandi.dao.repository.auth.AuthRepository;
30104 tejbeer 84 
import com.spice.profitmandi.dao.repository.auth.AuthUserPartnerMappingRepository;
30077 tejbeer 85 
import com.spice.profitmandi.dao.repository.auth.PartnerCollectionPlanRepository;
30416 tejbeer 86 
import com.spice.profitmandi.dao.repository.auth.PartnerCollectionRemarkRepository;
30077 tejbeer 87 
import com.spice.profitmandi.dao.repository.auth.PartnerSecondaryPlanRepository;
25952 tejbeer 88 
import com.spice.profitmandi.dao.repository.cs.CsService;
30416 tejbeer 89 
import com.spice.profitmandi.dao.repository.cs.TicketCategoryRepository;
90 
import com.spice.profitmandi.dao.repository.cs.TicketRepository;
91 
import com.spice.profitmandi.dao.repository.cs.TicketSubCategoryRepository;
92 
import com.spice.profitmandi.dao.repository.dtr.FofoStoreRepository;
93 
import com.spice.profitmandi.dao.repository.dtr.FranchiseeActivityRepository;
94 
import com.spice.profitmandi.dao.repository.dtr.FranchiseeVisitRepository;
95 
import com.spice.profitmandi.dao.repository.dtr.LeadActivityRepository;
96 
import com.spice.profitmandi.dao.repository.dtr.LeadRepository;
30487 tejbeer 97 
import com.spice.profitmandi.dao.repository.dtr.Mongo;
30416 tejbeer 98 
import com.spice.profitmandi.dao.repository.dtr.PartnerOnBoardingPanelRepository;
99 
import com.spice.profitmandi.dao.repository.dtr.UserAccountRepository;
100 
import com.spice.profitmandi.dao.repository.dtr.UserRepository;
31249 tejbeer 101 
import com.spice.profitmandi.dao.repository.dtr.VisitRequestRepository;
30087 tejbeer 102 
import com.spice.profitmandi.dao.repository.fofo.PartnerDailyInvestmentRepository;
30077 tejbeer 103 
import com.spice.profitmandi.dao.repository.transaction.OrderRepository;
31249 tejbeer 104 
import com.spice.profitmandi.service.AuthService;
105 
import com.spice.profitmandi.service.NotificationService;
30348 tejbeer 106 
import com.spice.profitmandi.service.PartnerCollectionService;
25952 tejbeer 107 
import com.spice.profitmandi.service.user.RetailerService;
28935 tejbeer 108 
import com.spice.profitmandi.service.user.StoreTimelineTatService;
25952 tejbeer 109 
import com.spice.profitmandi.web.req.CreateFranchiseeRequest;
110 
import com.spice.profitmandi.web.res.Partner;
30416 tejbeer 111 
 
25899 tejbeer 112 
import io.swagger.annotations.ApiImplicitParam;
113 
import io.swagger.annotations.ApiImplicitParams;
114 
 
115 
@Controller
116 
@Transactional(rollbackFor = Throwable.class)
117 
public class LeadController {
118 
	private static final Logger LOGGER = LogManager.getLogger(LeadController.class);
119 
	@Autowired
120 
	private ResponseSender<?> responseSender;
121 
 
122 
	@Autowired
123 
	private AuthRepository authRepository;
124 
 
125 
	@Autowired
126 
	private LeadRepository leadRepository;
127 
 
128 
	@Autowired
25952 tejbeer 129 
	private CsService csService;
130 
 
131 
	@Autowired
132 
	private UserRepository userRepository;
133 
 
134 
	@Autowired
135 
	private UserAccountRepository userAccountRepository;
136 
 
137 
	@Autowired
138 
	private com.spice.profitmandi.dao.repository.user.UserRepository userUserRepository;
139 
 
140 
	@Autowired
141 
	private RetailerService retailerService;
142 
 
143 
	@Autowired
25899 tejbeer 144 
	private LeadActivityRepository leadActivityRepository;
145 
 
25952 tejbeer 146 
	@Autowired
147 
	private FranchiseeVisitRepository franchiseeVisitRepository;
148 
 
149 
	@Autowired
150 
	private FranchiseeActivityRepository franchiseeActivityRepository;
151 
 
28935 tejbeer 152 
	@Autowired
153 
	private PartnerOnBoardingPanelRepository partnerOnBoardingPanelRepository;
154 
 
155 
	@Autowired
156 
	private FofoStoreRepository fofoStoreRepository;
157 
 
158 
	@Autowired
159 
	private StoreTimelineTatService storeTimelineTatService;
160 
 
30348 tejbeer 161 
	@Autowired
162 
	private PartnerCollectionService partnerCollectionService;
163 
 
30416 tejbeer 164 
	@Autowired
165 
	private TicketRepository ticketRepository;
166 
 
167 
	@Autowired
168 
	private TicketCategoryRepository ticketCategoryRepository;
169 
 
170 
	@Autowired
171 
	private TicketSubCategoryRepository ticketSubCategoryRepository;
172 
 
173 
	@Autowired
174 
	private PartnerCollectionRemarkRepository partnerCollectionRemarkRepository;
175 
 
30487 tejbeer 176 
	@Autowired
177 
	private Mongo mongoClient;
178 
 
179 
	@Autowired
180 
	private OrderRepository orderRepository;
181 
 
182 
	@Autowired
183 
	private PartnerCollectionPlanRepository partnerCollectionPlanRepository;
184 
 
185 
	@Autowired
186 
	private PartnerSecondaryPlanRepository partnerSecondaryPlanRepository;
187 
 
188 
	@Autowired
189 
	private PartnerDailyInvestmentRepository partnerDailyInvestmentRepository;
190 
 
191 
	@Autowired
192 
	private AuthUserPartnerMappingRepository authUserPartnerMappingRepository;
193 
 
31249 tejbeer 194 
	@Autowired
195 
	private VisitRequestRepository visitRequestRepository;
196 
 
197 
	@Autowired
198 
	private AuthService authService;
199 
 
200 
	@Autowired
201 
	private NotificationService notificationService;
202 
 
25899 tejbeer 203 
	@RequestMapping(value = "/lead", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_VALUE)
204 
	@ApiImplicitParams({
30294 tejbeer 205 
			@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
25899 tejbeer 206 
	public ResponseEntity<?> LeadUser(HttpServletRequest request,
30294 tejbeer 207 
			@RequestBody CreateRefferalRequest createRefferalRequest) throws Exception {
25899 tejbeer 208 
		Lead lead = new Lead();
209 
		lead.setFirstName(createRefferalRequest.getFirstName());
210 
		lead.setLastName(createRefferalRequest.getLastName());
211 
		lead.setLeadMobile(createRefferalRequest.getMobile());
212 
		lead.setState(createRefferalRequest.getState());
213 
		lead.setCity(createRefferalRequest.getCity());
214 
		lead.setAddress(createRefferalRequest.getAddress());
215 
		lead.setCreatedTimestamp(LocalDateTime.now());
216 
		lead.setUpdatedTimestamp(LocalDateTime.now());
217 
		lead.setStatus(createRefferalRequest.getStatus());
25979 tejbeer 218 
		lead.setSource(createRefferalRequest.getSource());
28201 tejbeer 219 
		lead.setNotinterestedReason(createRefferalRequest.getReason());
26244 tejbeer 220 
		if (createRefferalRequest.getColorCheck() == true) {
221 
			lead.setColor("Green");
222 
		} else {
223 
			lead.setColor("Yellow");
224 
		}
25900 amit.gupta 225 
		AuthUser authUser = authRepository.selectByGmailId(createRefferalRequest.getReffereeEmail());
226 
		String authUserName = authUser.getFirstName() + " " + authUser.getLastName();
227 
		lead.setCreatedBy(authUserName);
228 
		lead.setAuthId(authUser.getId());
25981 tejbeer 229 
		lead.setAssignTo(authUser.getId());
25899 tejbeer 230 
 
231 
		leadRepository.persist(lead);
232 
		LeadActivity leadActivity = new LeadActivity();
233 
		leadActivity.setLeadId(lead.getId());
234 
		leadActivity.setRemark(createRefferalRequest.getRemark());
235 
 
31249 tejbeer 236 
		leadActivity.setAuthId(authUser.getId());
237 
 
25899 tejbeer 238 
		if (createRefferalRequest.getStatus().equals(LeadStatus.followUp)) {
239 
			leadActivity.setSchelduleTimestamp(createRefferalRequest.getSchelduleTimestamp());
31249 tejbeer 240 
			leadActivity.setCommunicationType(createRefferalRequest.getCommunicationType());
241 
 
242 
			if (leadActivity.getCommunicationType().equals(CommunicationType.VISIT)) {
243 
 
244 
				visitRequestRepository.createVisitRequest(lead.getId(), "lead", lead.getAssignTo(),
245 
						createRefferalRequest.getSchelduleTimestamp());
246 
			}
247 
			//
26958 tejbeer 248 
			leadActivity.setClosureTimestamp(createRefferalRequest.getClosureTimestamp());
27025 tejbeer 249 
			lead.setClosureTimestamp(createRefferalRequest.getClosureTimestamp());
25899 tejbeer 250 
		} else {
251 
			leadActivity.setSchelduleTimestamp(null);
26958 tejbeer 252 
			leadActivity.setClosureTimestamp(null);
27025 tejbeer 253 
			lead.setClosureTimestamp(null);
25899 tejbeer 254 
		}
255 
		leadActivity.setCreatedTimestamp(LocalDateTime.now());
256 
		leadActivityRepository.persist(leadActivity);
257 
 
258 
		return responseSender.ok(true);
259 
	}
260 
 
261 
	@RequestMapping(value = "/lead-description", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
262 
	@ApiImplicitParams({
30294 tejbeer 263 
			@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
25899 tejbeer 264 
	public ResponseEntity<?> leadDescription(HttpServletRequest request, @RequestParam(name = "gmailId") String gmailId,
30294 tejbeer 265 
			@RequestParam(name = "status") LeadStatus status) throws ProfitMandiBusinessException {
25899 tejbeer 266 
		AuthUser authUser = authRepository.selectByGmailId(gmailId);
29434 amit.gupta 267 
		List<Lead> leads = null;
30306 tejbeer 268 
		LOGGER.info("emails" + status);
31249 tejbeer 269 
 
270 
		List<VisitRequest> visitRequests = visitRequestRepository.selectByAuthIdAndDate(authUser.getId(),
271 
				LocalDate.now());
272 
		Map<Integer, List<VisitRequest>> visitRequestMap = null;
273 
		if (!visitRequests.isEmpty()) {
274 
			visitRequestMap = visitRequests.stream().collect(Collectors.groupingBy(x -> x.getVisitId()));
275 
		}
29434 amit.gupta 276 
		if (status.equals(LeadStatus.followUp)) {
30306 tejbeer 277 
 
278 
			leads = leadRepository.selectLeadsScheduledBetweenDate(Arrays.asList(authUser.getId()), null, null);
31249 tejbeer 279 
 
280 
			if (visitRequestMap != null) {
281 
				for (Lead lead : leads) {
282 
					List<VisitRequest> visitRequest = visitRequestMap.get(lead.getId());
283 
 
284 
					if (visitRequest != null) {
285 
						if (visitRequest.size() > 1) {
286 
 
287 
							Comparator<VisitRequest> visitComparato = Comparator
288 
									.comparing(VisitRequest::getCreatedTimestamp);
289 
 
290 
							VisitRequest youngestVisit = visitRequest.stream().max(visitComparato).get();
291 
							lead.setVisitStatus(youngestVisit.getStatus());
292 
 
293 
						} else {
294 
							lead.setVisitStatus(visitRequest.get(0).getStatus());
295 
 
296 
						}
297 
					}
298 
 
299 
				}
300 
			}
301 
 
30306 tejbeer 302 
			leads = leads.stream()
303 
					.sorted(Comparator.comparing(Lead::getScheduledTimestamp,
304 
							Comparator.nullsFirst(Comparator.reverseOrder())))
305 
					.collect(Collectors
306 
							.toList());/*
307 
										 * Collections.sort(leads, (o1, o2) -> { if (o1.getScheduledTimestamp() != null
308 
										 * && o2.getScheduledTimestamp() != null) { return
309 
										 * o1.getScheduledTimestamp().isBefore(o2.getScheduledTimestamp()) ? -1 : 1; }
310 
										 * else if (o1.getScheduledTimestamp() != null) { return 1; } else { return -1;
311 
										 * } });
312 
										 */
313 
 
30294 tejbeer 314 
		} else {
315 
			leads = leadRepository.selectByAssignAuthIdAndStatus(authUser.getId(), status);
316 
 
29434 amit.gupta 317 
		}
25979 tejbeer 318 
 
25899 tejbeer 319 
		return responseSender.ok(leads);
320 
 
321 
	}
322 
 
323 
	@RequestMapping(value = "/getlead", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
324 
	@ApiImplicitParams({
30294 tejbeer 325 
			@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
25899 tejbeer 326 
	public ResponseEntity<?> getLead(HttpServletRequest request, @RequestParam(name = "id") int id)
327 
			throws ProfitMandiBusinessException {
328 
 
329 
		List<LeadActivity> leadActivities = leadActivityRepository.selectBYLeadId(id);
29317 tejbeer 330 
		Lead lead = leadRepository.selectById(id);
331 
		lead.setLeadActivities(leadActivities);
332 
		return responseSender.ok(lead);
25899 tejbeer 333 
 
334 
	}
335 
 
25948 amit.gupta 336 
	@RequestMapping(value = "/leadUpdate", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_VALUE)
25899 tejbeer 337 
	@ApiImplicitParams({
30294 tejbeer 338 
			@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
25899 tejbeer 339 
	public ResponseEntity<?> leadUpdate(HttpServletRequest request, @RequestParam(name = "id") int id,
30294 tejbeer 340 
			@RequestParam(name = "status") LeadStatus status, @RequestParam(name = "colorCheck") Boolean colorCheck,
341 
			@RequestParam(name = "remark") String remark, @RequestParam(name = "reason") String reason,
342 
			@RequestParam(name = "schelduleTimestamp") @DateTimeFormat(iso = DateTimeFormat.ISO.DATE_TIME) LocalDateTime schelduleTimestamp,
31249 tejbeer 343 
			@RequestParam(name = "closureTimestamp") @DateTimeFormat(iso = DateTimeFormat.ISO.DATE_TIME) LocalDateTime closureTimestamp,
344 
			@RequestParam(name = "communicationType") CommunicationType communicationType)
25899 tejbeer 345 
			throws ProfitMandiBusinessException {
346 
 
347 
		Lead lead = leadRepository.selectById(id);
348 
 
349 
		LeadActivity leadActivity = new LeadActivity();
26250 tejbeer 350 
		lead.setStatus(status);
28201 tejbeer 351 
		lead.setNotinterestedReason(reason);
26250 tejbeer 352 
		leadActivity.setRemark(remark);
353 
		leadActivity.setLeadId(id);
354 
		leadActivity.setCreatedTimestamp(LocalDateTime.now());
355 
		leadActivity.setSchelduleTimestamp(null);
26958 tejbeer 356 
		leadActivity.setClosureTimestamp(null);
31249 tejbeer 357 
		leadActivity.setAuthId(lead.getAssignTo());
26250 tejbeer 358 
		lead.setUpdatedTimestamp(LocalDateTime.now());
359 
		if (colorCheck == true) {
360 
			lead.setColor("Green");
361 
		} else {
362 
			lead.setColor("Yellow");
363 
		}
364 
		if (status == LeadStatus.followUp) {
25899 tejbeer 365 
 
31249 tejbeer 366 
			if (schelduleTimestamp != null) {
367 
 
368 
				leadActivity.setCommunicationType(communicationType);
369 
 
370 
				if (leadActivity.getCommunicationType().equals(CommunicationType.VISIT)) {
371 
 
372 
					visitRequestRepository.createVisitRequest(lead.getId(), "lead", lead.getAssignTo(),
373 
							schelduleTimestamp);
374 
				}
375 
 
376 
			}
25899 tejbeer 377 
			leadActivity.setSchelduleTimestamp(schelduleTimestamp);
26958 tejbeer 378 
			leadActivity.setClosureTimestamp(closureTimestamp);
27025 tejbeer 379 
			lead.setClosureTimestamp(closureTimestamp);
26250 tejbeer 380 
 
25899 tejbeer 381 
		} else {
26250 tejbeer 382 
 
25899 tejbeer 383 
			leadActivity.setSchelduleTimestamp(null);
26958 tejbeer 384 
			leadActivity.setClosureTimestamp(null);
27025 tejbeer 385 
			lead.setClosureTimestamp(null);
26244 tejbeer 386 
 
25899 tejbeer 387 
		}
26250 tejbeer 388 
		leadActivityRepository.persist(leadActivity);
25899 tejbeer 389 
		return responseSender.ok(true);
390 
 
391 
	}
25952 tejbeer 392 
 
27117 tejbeer 393 
	@RequestMapping(value = ProfitMandiConstants.URL_NEW_LEAD, method = RequestMethod.POST)
394 
	public ResponseEntity<?> newLead(HttpServletRequest request,
30294 tejbeer 395 
			@RequestBody CreateRefferalRequest createRefferalRequest) throws ProfitMandiBusinessException {
27117 tejbeer 396 
		LOGGER.info("requested url : " + request.getRequestURL().toString());
397 
		Lead lead = new Lead();
398 
		lead.setAddress(createRefferalRequest.getCity());
27625 tejbeer 399 
		Long.parseLong(createRefferalRequest.getMobile());
28201 tejbeer 400 
		if (createRefferalRequest.getMobile().length() != 10) {
401 
			throw new ProfitMandiBusinessException("Mobile Number", createRefferalRequest.getMobile(),
402 
					"Number should be of 10 digits");
27597 amit.gupta 403 
		}
27117 tejbeer 404 
		lead.setLeadMobile(createRefferalRequest.getMobile());
405 
		lead.setCity(createRefferalRequest.getCity());
406 
		lead.setState(createRefferalRequest.getState());
407 
		lead.setLastName(createRefferalRequest.getLastName());
408 
		if (lead.getState().equals("Uttar Pradesh")) {
29276 amit.gupta 409 
			lead.setAssignTo(53);
27117 tejbeer 410 
		} else if (lead.getState().equals("Haryana")) {
29276 amit.gupta 411 
			lead.setAssignTo(53);
27117 tejbeer 412 
		} else if (lead.getState().equals("Delhi")) {
29276 amit.gupta 413 
			lead.setAssignTo(53);
27117 tejbeer 414 
		} else {
28201 tejbeer 415 
			// Assign to sm
27992 amit.gupta 416 
			lead.setAssignTo(53);
28201 tejbeer 417 
			// Assign to neha
418 
			// lead.setAssignTo(1);
27117 tejbeer 419 
		}
420 
		lead.setAuthId(lead.getAssignTo());
421 
		lead.setCreatedBy("daily-sync");
422 
		lead.setSource("SD-WEB");
423 
		lead.setFirstName(createRefferalRequest.getFirstName());
424 
		lead.setStatus(LeadStatus.followUp);
425 
		lead.setColor("yellow");
426 
		lead.setCreatedTimestamp(LocalDateTime.now());
427 
		lead.setUpdatedTimestamp(LocalDateTime.now());
428 
		leadRepository.persist(lead);
429 
 
430 
		return responseSender.ok(true);
431 
 
432 
	}
433 
 
25952 tejbeer 434 
	@RequestMapping(value = "/getPartnersList", method = RequestMethod.GET)
435 
	@ApiImplicitParams({
30294 tejbeer 436 
			@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
25952 tejbeer 437 
	public ResponseEntity<?> getPartners(HttpServletRequest request, @RequestParam(name = "gmailId") String gmailId)
438 
			throws ProfitMandiBusinessException {
439 
 
25973 tejbeer 440 
		AuthUser authUser = authRepository.selectByGmailId(gmailId);
25952 tejbeer 441 
 
442 
		Map<String, Set<String>> storeGuyMap = csService.getAuthUserPartnerEmailMapping();
443 
 
30288 tejbeer 444 
		Set<String> emails = storeGuyMap.get(authUser.getEmailId());
25952 tejbeer 445 
		LOGGER.info("emails" + emails);
446 
		List<User> users = userRepository.selectAllByEmailIds(new ArrayList<>(emails));
447 
		List<Partner> partners = new ArrayList<>();
448 
		for (User user : users) {
449 
 
450 
			UserAccount uc = userAccountRepository.selectSaholicByUserId(user.getId());
451 
			com.spice.profitmandi.dao.entity.user.User userInfo = userUserRepository.selectById(uc.getAccountKey());
452 
			CustomRetailer customRetailer = retailerService.getFofoRetailer(userInfo.getId());
453 
 
454 
			Partner partner = new Partner();
455 
			partner.setBusinessName(customRetailer.getBusinessName());
456 
			partner.setPartnerId(customRetailer.getPartnerId());
457 
			partner.setCartId(customRetailer.getCartId());
458 
			partner.setEmail(customRetailer.getEmail());
459 
			partner.setGstNumber(customRetailer.getGstNumber());
460 
			partner.setDisplayName(customRetailer.getDisplayName());
461 
			partner.setCity(customRetailer.getAddress().getCity());
462 
			partner.setUserId(user.getId());
463 
			partners.add(partner);
464 
		}
465 
		LOGGER.info("partners" + partners);
466 
		return responseSender.ok(partners);
467 
	}
468 
 
469 
	@RequestMapping(value = "/franchise-first-visit", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_VALUE)
470 
	@ApiImplicitParams({
30294 tejbeer 471 
			@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
25952 tejbeer 472 
	public ResponseEntity<?> FranchiseFirstVisit(HttpServletRequest request,
30294 tejbeer 473 
			@RequestBody CreateFranchiseeRequest createFranchiseeRequest) throws Exception {
25952 tejbeer 474 
 
475 
		FranchiseeVisit franchiseeVisit = new FranchiseeVisit();
476 
		franchiseeVisit.setFofoId(createFranchiseeRequest.getFofoId());
477 
		CustomRetailer customRetailer = retailerService.getFofoRetailer(createFranchiseeRequest.getFofoId());
478 
 
479 
		franchiseeVisit.setPartnerName(customRetailer.getBusinessName());
480 
		franchiseeVisit.setAgenda(createFranchiseeRequest.getAgenda());
481 
		franchiseeVisit.setCreatedTimestamp(LocalDateTime.now());
482 
		franchiseeVisit.setUpdatedTimestamp(LocalDateTime.now());
483 
		franchiseeVisit.setStatus(FranchiseeVisitStatus.OPEN);
30530 tejbeer 484 
		franchiseeVisit.setScheduleTimestamp(createFranchiseeRequest.getFirstSchelduleTimestamp());
25952 tejbeer 485 
		// change
25973 tejbeer 486 
		AuthUser authUser = authRepository.selectByGmailId(createFranchiseeRequest.getCreatedBy());
25952 tejbeer 487 
 
488 
		String authUserName = authUser.getFirstName() + " " + authUser.getLastName();
489 
		franchiseeVisit.setCreatedBy(authUserName);
490 
		franchiseeVisit.setAuthId(authUser.getId());
491 
 
492 
		franchiseeVisitRepository.persist(franchiseeVisit);
493 
 
31249 tejbeer 494 
		FranchiseeActivity franchiseeActivity = new FranchiseeActivity();
495 
		franchiseeActivity.setAction(FranchiseeActivityStatus.FOLLOWUP);
496 
		franchiseeActivity.setFranchiseeVisitd(franchiseeVisit.getId());
497 
		franchiseeActivity.setResolution(createFranchiseeRequest.getResolution());
498 
		franchiseeActivity.setSchelduleTimestamp(createFranchiseeRequest.getFirstSchelduleTimestamp());
499 
 
500 
		franchiseeActivity.setCreatedTimestamp(LocalDateTime.now());
501 
		franchiseeActivityRepository.persist(franchiseeActivity);
502 
 
503 
		franchiseeVisit.setFranchiseActivityId(franchiseeActivity.getId());
504 
 
505 
		visitRequestRepository.createVisitRequest(franchiseeVisit.getId(), "franchiseeVisit", authUser.getId(),
506 
				createFranchiseeRequest.getFirstSchelduleTimestamp());
507 
 
25952 tejbeer 508 
		return responseSender.ok(true);
509 
	}
510 
 
511 
	@RequestMapping(value = "/franchise-visit", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_VALUE)
512 
	@ApiImplicitParams({
30294 tejbeer 513 
			@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
25952 tejbeer 514 
	public ResponseEntity<?> FranchiseVisit(HttpServletRequest request,
30294 tejbeer 515 
			@RequestBody CreateFranchiseeRequest createFranchiseeRequest) throws Exception {
25952 tejbeer 516 
 
517 
		FranchiseeVisit franchiseeVisit = franchiseeVisitRepository.selectById(createFranchiseeRequest.getId());
518 
		franchiseeVisit.setFofoId(createFranchiseeRequest.getFofoId());
519 
		CustomRetailer customRetailer = retailerService.getFofoRetailer(createFranchiseeRequest.getFofoId());
520 
 
521 
		franchiseeVisit.setPartnerName(customRetailer.getBusinessName());
522 
		franchiseeVisit.setAgenda(createFranchiseeRequest.getAgenda());
523 
		franchiseeVisit.setPartnerRemark(createFranchiseeRequest.getPartnerRemark());
524 
		franchiseeVisit.setOutsideVisibity(createFranchiseeRequest.getOutsideVisibity());
525 
		franchiseeVisit.setInstoreVisibility(createFranchiseeRequest.getInstoreVisibility());
526 
		franchiseeVisit.setOutsideStock(createFranchiseeRequest.getOutsideStock());
527 
		franchiseeVisit.setSystemKnowledge(createFranchiseeRequest.getSystemKnowledge());
528 
		franchiseeVisit.setWorkingDevice(createFranchiseeRequest.getWorkingDevice());
529 
		franchiseeVisit.setWorkingPrinter(createFranchiseeRequest.getWorkingPrinter());
530 
		franchiseeVisit.setCarryBags(createFranchiseeRequest.getCarryBags());
531 
		franchiseeVisit.setSmartdukaanTshirt(createFranchiseeRequest.getSmartdukaanTshirt());
532 
		franchiseeVisit.setLatestDummies(createFranchiseeRequest.getLatestDummies());
533 
		franchiseeVisit.setInvestment(createFranchiseeRequest.getInvestment());
534 
		franchiseeVisit.setMtd(createFranchiseeRequest.getMtd());
535 
		franchiseeVisit.setHygiene(createFranchiseeRequest.getHygiene());
536 
		franchiseeVisit.setCreatedTimestamp(LocalDateTime.now());
537 
		franchiseeVisit.setUpdatedTimestamp(LocalDateTime.now());
30487 tejbeer 538 
		franchiseeVisit.setInformedAboutOnline(createFranchiseeRequest.getOnline());
539 
		franchiseeVisit.setPendingBilling(createFranchiseeRequest.getPendingBilling());
25952 tejbeer 540 
		if (createFranchiseeRequest.getAction().equals(FranchiseeActivityStatus.FOLLOWUP)) {
541 
			franchiseeVisit.setStatus(FranchiseeVisitStatus.OPEN);
542 
		} else {
543 
			franchiseeVisit.setStatus(FranchiseeVisitStatus.CLOSE);
544 
		}
545 
 
546 
		// AuthUser authUser =
547 
		// authRepository.selectByGmailId(createFranchiseeRequest.getCreatedBy());
548 
		// change
25973 tejbeer 549 
		AuthUser authUser = authRepository.selectByGmailId(createFranchiseeRequest.getCreatedBy());
25952 tejbeer 550 
 
551 
		String authUserName = authUser.getFirstName() + " " + authUser.getLastName();
552 
		franchiseeVisit.setCreatedBy(authUserName);
553 
		franchiseeVisit.setAuthId(authUser.getId());
554 
 
555 
		franchiseeVisitRepository.persist(franchiseeVisit);
556 
 
557 
		FranchiseeActivity franchiseeActivity = new FranchiseeActivity();
558 
		franchiseeActivity.setAction(createFranchiseeRequest.getAction());
559 
		franchiseeActivity.setFranchiseeVisitd(franchiseeVisit.getId());
560 
		franchiseeActivity.setResolution(createFranchiseeRequest.getResolution());
561 
		if (createFranchiseeRequest.getAction().equals(FranchiseeActivityStatus.FOLLOWUP)) {
562 
			franchiseeActivity.setSchelduleTimestamp(createFranchiseeRequest.getSchelduleTimestamp());
31249 tejbeer 563 
 
564 
			visitRequestRepository.createVisitRequest(franchiseeVisit.getId(), "franchiseeVisit",
565 
					franchiseeVisit.getAuthId(), createFranchiseeRequest.getSchelduleTimestamp());
25952 tejbeer 566 
		} else {
567 
			franchiseeActivity.setSchelduleTimestamp(null);
568 
		}
569 
		franchiseeActivity.setCreatedTimestamp(LocalDateTime.now());
570 
		franchiseeActivityRepository.persist(franchiseeActivity);
571 
 
572 
		franchiseeVisit.setFranchiseActivityId(franchiseeActivity.getId());
573 
		return responseSender.ok(true);
574 
	}
575 
 
576 
	@RequestMapping(value = "/getFranchiseVisit", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
577 
	@ApiImplicitParams({
30294 tejbeer 578 
			@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
25952 tejbeer 579 
	public ResponseEntity<?> getFranchiseVisit(HttpServletRequest request,
30294 tejbeer 580 
			@RequestParam(name = "gmailId") String gmailId, @RequestParam(name = "status") FranchiseeVisitStatus status,
581 
			@RequestParam(name = "offset", defaultValue = "0") int offset,
582 
			@RequestParam(name = "limit", defaultValue = "10") int limit) throws ProfitMandiBusinessException {
25973 tejbeer 583 
		AuthUser authUser = authRepository.selectByGmailId(gmailId);
31249 tejbeer 584 
		List<VisitRequest> visitRequests = visitRequestRepository.selectByAuthIdAndDate(authUser.getId(),
585 
				LocalDate.now());
586 
		Map<Integer, List<VisitRequest>> visitRequestMap = null;
587 
		if (!visitRequests.isEmpty()) {
588 
			visitRequestMap = visitRequests.stream().collect(Collectors.groupingBy(x -> x.getVisitId()));
589 
		}
25952 tejbeer 590 
		List<FranchiseeVisit> franchiseeVisits = franchiseeVisitRepository.selectByAuthIdAndStatus(authUser.getId(),
591 
				status, offset, limit);
592 
 
593 
		for (FranchiseeVisit fv : franchiseeVisits) {
31249 tejbeer 594 
			if (visitRequestMap != null) {
595 
 
596 
				List<VisitRequest> visitRequest = visitRequestMap.get(fv.getId());
597 
				if (visitRequest != null) {
598 
					if (visitRequest.size() > 1) {
599 
 
600 
						Comparator<VisitRequest> visitComparato = Comparator
601 
								.comparing(VisitRequest::getCreatedTimestamp);
602 
 
603 
						VisitRequest youngestVisit = visitRequest.stream().max(visitComparato).get();
604 
						fv.setVisitStatus(youngestVisit.getStatus());
605 
 
606 
					} else {
607 
						fv.setVisitStatus(visitRequest.get(0).getStatus());
608 
 
609 
					}
610 
				}
611 
			}
25952 tejbeer 612 
			if (fv.getFranchiseActivityId() != 0) {
613 
				FranchiseeActivity fA = franchiseeActivityRepository.selectById(fv.getFranchiseActivityId());
614 
				fv.setFranchiseeActivity(fA);
615 
			}
31249 tejbeer 616 
 
25952 tejbeer 617 
		}
618 
 
619 
		return responseSender.ok(franchiseeVisits);
620 
 
621 
	}
622 
 
623 
	@RequestMapping(value = "/getFranchiseActivity", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
624 
	@ApiImplicitParams({
30294 tejbeer 625 
			@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
25952 tejbeer 626 
	public ResponseEntity<?> getFranchiseActivity(HttpServletRequest request, @RequestParam(name = "id") int id)
627 
			throws ProfitMandiBusinessException {
628 
 
629 
		List<FranchiseeActivity> franchiseeActivities = franchiseeActivityRepository.selectByFranchiseeVisitId(id);
630 
		return responseSender.ok(franchiseeActivities);
631 
 
632 
	}
633 
 
634 
	@RequestMapping(value = "/getFranchiseeInfo", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
635 
	@ApiImplicitParams({
30294 tejbeer 636 
			@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
25952 tejbeer 637 
	public ResponseEntity<?> getFranchiseeInfo(HttpServletRequest request, @RequestParam(name = "id") int id)
638 
			throws ProfitMandiBusinessException {
639 
		FranchiseeVisit franchiseeVisit = franchiseeVisitRepository.selectById(id);
640 
 
30487 tejbeer 641 
		List<DBObject> mobileBrands = mongoClient.getAllBrandsToDisplay(3);
642 
 
643 
		List<String> brands = mobileBrands.stream().filter(x -> (boolean) x.get("active"))
644 
				.map(x -> (String) x.get("name")).collect(Collectors.toList());
645 
 
646 
		franchiseeVisit.setBrands(brands);
647 
 
25952 tejbeer 648 
		return responseSender.ok(franchiseeVisit);
649 
 
650 
	}
651 
 
652 
	@RequestMapping(value = "/franchise-visit-update", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_VALUE)
653 
	@ApiImplicitParams({
30294 tejbeer 654 
			@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
25952 tejbeer 655 
	public ResponseEntity<?> franchiseVisitUpdate(HttpServletRequest request, @RequestParam(name = "id") int id,
30294 tejbeer 656 
			@RequestParam(name = "action") FranchiseeActivityStatus action,
657 
			@RequestParam(name = "resolution") String resolution,
658 
			@RequestParam(name = "schelduleTimestamp") @DateTimeFormat(iso = DateTimeFormat.ISO.DATE_TIME) LocalDateTime schelduleTimestamp)
25952 tejbeer 659 
			throws ProfitMandiBusinessException {
660 
		FranchiseeVisit franchiseeVisit = franchiseeVisitRepository.selectById(id);
661 
 
662 
		FranchiseeActivity franchiseeActivity = new FranchiseeActivity();
663 
 
664 
		if (action == FranchiseeActivityStatus.FOLLOWUP) {
30487 tejbeer 665 
 
31249 tejbeer 666 
			if (schelduleTimestamp != null) {
667 
 
668 
				visitRequestRepository.createVisitRequest(franchiseeVisit.getId(), "franchiseeVisit",
669 
						franchiseeVisit.getAuthId(), schelduleTimestamp);
670 
			}
671 
 
25952 tejbeer 672 
			franchiseeActivity.setSchelduleTimestamp(schelduleTimestamp);
673 
			franchiseeVisit.setStatus(FranchiseeVisitStatus.OPEN);
674 
			franchiseeVisit.setUpdatedTimestamp(LocalDateTime.now());
675 
			franchiseeVisitRepository.persist(franchiseeVisit);
676 
 
677 
		} else {
30487 tejbeer 678 
 
25952 tejbeer 679 
			franchiseeActivity.setSchelduleTimestamp(null);
680 
			franchiseeVisit.setFranchiseActivityId(franchiseeActivity.getId());
681 
			franchiseeVisit.setStatus(FranchiseeVisitStatus.CLOSE);
682 
			franchiseeVisit.setUpdatedTimestamp(LocalDateTime.now());
683 
			franchiseeVisitRepository.persist(franchiseeVisit);
684 
 
685 
		}
686 
 
30487 tejbeer 687 
		franchiseeActivity.setResolution(resolution);
688 
		franchiseeActivity.setFranchiseeVisitd(franchiseeVisit.getId());
689 
		franchiseeActivity.setAction(action);
690 
 
691 
		franchiseeActivity.setCreatedTimestamp(LocalDateTime.now());
692 
		franchiseeActivityRepository.persist(franchiseeActivity);
693 
 
694 
		franchiseeVisit.setFranchiseActivityId(franchiseeActivity.getId());
695 
		franchiseeVisit.setStatus(FranchiseeVisitStatus.OPEN);
696 
		franchiseeVisit.setUpdatedTimestamp(LocalDateTime.now());
697 
		franchiseeVisitRepository.persist(franchiseeVisit);
698 
 
25952 tejbeer 699 
		return responseSender.ok(true);
700 
 
701 
	}
28935 tejbeer 702 
 
703 
	@RequestMapping(value = "/onBoardingTimelineStatus", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
704 
	@ApiImplicitParams({
30294 tejbeer 705 
			@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
28935 tejbeer 706 
	public ResponseEntity<?> onBoardingTimelineStatus(HttpServletRequest request, Model model)
707 
			throws ProfitMandiBusinessException {
708 
		int userId = (int) request.getAttribute("userId");
709 
		UserCart uc = userAccountRepository.getUserCart(userId);
710 
		FofoStore fs = fofoStoreRepository.selectByRetailerId(uc.getUserId());
711 
		PartnerOnBoardingPanel partnerOnBoardingPanel = partnerOnBoardingPanelRepository.selectByCode(fs.getCode());
712 
		Map<StoreTimeline, OnBoardingTimelineModel> timelineStatus = null;
713 
		LOGGER.info("partnerOnBoardingPanel" + partnerOnBoardingPanel);
714 
		if (partnerOnBoardingPanel != null) {
715 
 
716 
			timelineStatus = storeTimelineTatService.getTimeline(partnerOnBoardingPanel.getId());
717 
		}
718 
		List<OnBoardingTimelineModel> onBoardingModel = new ArrayList<>();
719 
		if (timelineStatus != null) {
720 
			onBoardingModel = timelineStatus.values().stream().skip(2).map(x -> x).collect(Collectors.toList());
721 
		}
722 
		return responseSender.ok(onBoardingModel);
723 
 
724 
	}
28982 tejbeer 725 
 
726 
	@RequestMapping(value = "/onBoardingTimelineVisibility", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
727 
	@ApiImplicitParams({
30294 tejbeer 728 
			@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
28982 tejbeer 729 
	public ResponseEntity<?> onBoardingTimelineVisibility(HttpServletRequest request, Model model)
730 
			throws ProfitMandiBusinessException {
731 
		int userId = (int) request.getAttribute("userId");
732 
		UserCart uc = userAccountRepository.getUserCart(userId);
733 
 
734 
		FofoStore fs = fofoStoreRepository.selectByRetailerId(uc.getUserId());
735 
		PartnerOnBoardingPanel partnerOnBoardingPanel = partnerOnBoardingPanelRepository.selectByCode(fs.getCode());
736 
		boolean status = true;
737 
		if (partnerOnBoardingPanel != null) {
738 
 
739 
			status = storeTimelineTatService.getTimelineCompleted(partnerOnBoardingPanel.getId());
740 
		}
741 
 
28983 tejbeer 742 
		LOGGER.info("status" + status);
743 
 
28982 tejbeer 744 
		return responseSender.ok(status);
745 
 
746 
	}
30077 tejbeer 747 
 
748 
	@RequestMapping(value = "/getPartnerTarget", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
749 
	@ApiImplicitParams({
30294 tejbeer 750 
			@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
30077 tejbeer 751 
	public ResponseEntity<?> getPartnerTarget(HttpServletRequest request,
30294 tejbeer 752 
			@RequestParam(name = "gmailId") String gmailId, @RequestParam String dayValue)
30087 tejbeer 753 
			throws ProfitMandiBusinessException {
30077 tejbeer 754 
 
755 
		AuthUser authUser = authRepository.selectByGmailId(gmailId);
30348 tejbeer 756 
		Map<String, Set<Integer>> storeGuyMap = csService.getAuthUserPartnerIdMapping();
757 
		Set<Integer> fofoIds = storeGuyMap.get(authUser.getEmailId());
758 
		List<String> brands = Arrays.asList("Vivo", "Samsung", "Oppo", "Itel", "Almost New", "Others");
30078 tejbeer 759 
 
30077 tejbeer 760 
		float totalPartnerTargetSecondary = 0;
761 
		float totalPartnerTargetCollection = 0;
762 
		float totalPartnerAchievementSecondary = 0;
763 
		float totalPartnerAchievementCollection = 0;
764 
		TargetModel tm = new TargetModel();
30087 tejbeer 765 
		Map<Integer, PartnerDailyInvestment> partnerDailyInvestmentMap = new HashMap<>();
30416 tejbeer 766 
		Map<Integer, Long> partnerTicketCount = ticketRepository.selectAllOpenTicketsGroupByRetailer();
767 
 
768 
		LOGGER.info("partnerTicketCount {}", partnerTicketCount);
769 
 
30077 tejbeer 770 
		List<PartnerTargetAchievementModel> ptams = new ArrayList<>();
771 
 
30781 tejbeer 772 
		if (fofoIds != null && fofoIds.size() > 0) {
30087 tejbeer 773 
			List<Integer> fofoIdl = new ArrayList<>(fofoIds);
774 
			List<Integer> fofoIdList = fofoStoreRepository.selectByRetailerIds(fofoIdl).stream()
775 
					.filter(x -> !x.isInternal()).map(x -> x.getId()).collect(Collectors.toList());
30077 tejbeer 776 
 
777 
			LocalDateTime startDate = LocalDate.now().atStartOfDay();
778 
 
30087 tejbeer 779 
			if (dayValue.equals("previous")) {
780 
				startDate = LocalDate.now().minusDays(1).atStartOfDay();
30138 tejbeer 781 
 
30087 tejbeer 782 
			}
783 
 
784 
			List<PartnerDailyInvestment> partnerDailyInvestments = partnerDailyInvestmentRepository
30149 tejbeer 785 
					.selectAll(fofoIdList, startDate.toLocalDate().minusDays(1));
30453 tejbeer 786 
 
30087 tejbeer 787 
			if (!partnerDailyInvestments.isEmpty()) {
788 
				partnerDailyInvestmentMap = partnerDailyInvestments.stream()
789 
						.collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
790 
			}
791 
 
30426 tejbeer 792 
			Map<Integer, CustomRetailer> customRetailerMap = retailerService.getAllFofoRetailers();
30077 tejbeer 793 
 
30426 tejbeer 794 
			Map<Integer, CustomRetailer> customRetailers = fofoIdList.stream().map(x -> customRetailerMap.get(x))
795 
					.filter(x -> x != null).collect(Collectors.toList()).stream()
796 
					.collect(Collectors.toMap(x -> x.getPartnerId(), x -> x));
797 
 
30453 tejbeer 798 
			List<Integer> remarkIds = partnerCollectionRemarkRepository.selectMaxRemarkId(fofoIdList);
30330 tejbeer 799 
 
30453 tejbeer 800 
			LOGGER.info("remarkIds {}", remarkIds);
801 
 
802 
			long todayCollectionCount = 0;
803 
			if (!remarkIds.isEmpty()) {
804 
				todayCollectionCount = partnerCollectionRemarkRepository
805 
						.selectByAuthIdAndIds(authUser.getId(), remarkIds).stream()
806 
						.filter(x -> x.getCreateTimestamp().toLocalDate().equals(LocalDate.now()))
807 
						.collect(Collectors.counting());
808 
 
809 
			}
810 
 
30808 tejbeer 811 
			Map<Integer, PartnerCollectionPlanModel> CollectionMap = partnerCollectionService
30348 tejbeer 812 
					.getCollectionMap(fofoIdList, startDate);
30330 tejbeer 813 
 
30077 tejbeer 814 
			Map<Integer, List<PartnerSecondaryPlanModel>> partnerSecondayPlans = orderRepository
30110 tejbeer 815 
					.selectPartnerSecondaryGroupByBrand(fofoIdList, startDate.toLocalDate()).stream()
30077 tejbeer 816 
					.collect(Collectors.groupingBy(x -> x.getFofoId()));
817 
 
818 
			LOGGER.info("partnerSecondayPlans {}", partnerSecondayPlans);
819 
			for (Entry<Integer, CustomRetailer> customRetailerEntry : customRetailers.entrySet()) {
820 
				int fofoId = customRetailerEntry.getKey();
821 
				CustomRetailer customRetailer = customRetailerEntry.getValue();
822 
				float totalSecondaryPlan = 0;
823 
				float totalSecondaryAchivement = 0;
824 
 
825 
				PartnerTargetAchievementModel ptam = new PartnerTargetAchievementModel();
826 
				ptam.setFofoId(fofoId);
827 
				ptam.setBusinessName(customRetailer.getBusinessName());
30416 tejbeer 828 
				ptam.setMobile(customRetailer.getMobileNumber());
30077 tejbeer 829 
 
30087 tejbeer 830 
				if (partnerDailyInvestmentMap.get(fofoId) != null) {
831 
					ptam.setWalletAmount(partnerDailyInvestmentMap.get(fofoId).getWalletAmount());
832 
					ptam.setShortInvestment(partnerDailyInvestmentMap.get(fofoId).getShortInvestment());
833 
				}
834 
 
30808 tejbeer 835 
				if (CollectionMap.get(fofoId) != null) {
836 
					PartnerCollectionPlanModel collectionPlan = CollectionMap.get(fofoId);
837 
 
30416 tejbeer 838 
					ptam.setRemark(collectionPlan.getRemark());
839 
					ptam.setMessage(collectionPlan.getMessage());
840 
					ptam.setRemarkTimestamp(collectionPlan.getRemarkTimestamp());
30330 tejbeer 841 
					ptam.setRank(collectionPlan.getRank());
30137 tejbeer 842 
					Integer authId = collectionPlan.getAuthId();
30330 tejbeer 843 
 
30416 tejbeer 844 
					Map<Integer, String> rankColorMap = ProfitMandiConstants.Rank_Color_Map;
30330 tejbeer 845 
 
30416 tejbeer 846 
					ptam.setCollectionColor(rankColorMap.get(collectionPlan.getRank()));
847 
 
30087 tejbeer 848 
					LOGGER.info("authId" + authId);
30077 tejbeer 849 
 
30330 tejbeer 850 
					if (collectionPlan.getTargetPlan() != null && collectionPlan.getCommittedDate() != null) {
851 
						float targetCollection = 0;
30137 tejbeer 852 
 
30818 tejbeer 853 
						if (collectionPlan.getRank() == 2 && collectionPlan.getAchievementPlan() != null) {
30452 tejbeer 854 
							targetCollection = collectionPlan.getTargetPlan() - collectionPlan.getAchievementPlan();
855 
						} else {
856 
							targetCollection = collectionPlan.getTargetPlan();
857 
						}
30330 tejbeer 858 
 
30452 tejbeer 859 
						if (authId != null && authId == authUser.getId()) {
860 
 
861 
							if (!collectionPlan.getCommittedDate().isAfter(startDate)) {
862 
								totalPartnerTargetCollection += targetCollection;
30451 tejbeer 863 
							}
30452 tejbeer 864 
						}
30451 tejbeer 865 
 
30330 tejbeer 866 
						ptam.setCollectionTarget(targetCollection);
30822 tejbeer 867 
 
868 
						if (collectionPlan.getRank() == 2 && collectionPlan.getAchievementPlan() != null
869 
								&& collectionPlan.getWalletTimestamp() != null
870 
								&& collectionPlan.getWalletTimestamp().toLocalDate().equals(startDate.toLocalDate())) {
871 
							if (authId != null && authId == authUser.getId()) {
872 
 
873 
								totalPartnerAchievementCollection += collectionPlan.getAchievementPlan();
874 
							}
875 
							ptam.setCollectionAchievement(collectionPlan.getAchievementPlan());
876 
						} else if (collectionPlan.getCommittedDate().toLocalDate().isEqual(startDate.toLocalDate())
877 
								&& collectionPlan.getAchievementPlan() != null) {
878 
							if (authId != null && authId == authUser.getId()) {
879 
 
880 
								totalPartnerAchievementCollection += collectionPlan.getAchievementPlan();
881 
							}
882 
							ptam.setCollectionAchievement(collectionPlan.getAchievementPlan());
883 
 
884 
						}
30330 tejbeer 885 
					}
30087 tejbeer 886 
 
887 
					if (authId != null && authId != authUser.getId()) {
888 
						ptam.setAuthUser(authRepository.selectById(authId));
889 
 
890 
					}
891 
 
30137 tejbeer 892 
					if (collectionPlan.getCommittedDate() != null) {
893 
 
894 
						ptam.setCollectionCommitmentDate(collectionPlan.getCommittedDate().toLocalDate());
895 
					}
30821 tejbeer 896 
 
30077 tejbeer 897 
				}
898 
 
30330 tejbeer 899 
				// Secondary
900 
 
30077 tejbeer 901 
				PartnerSecondaryPlanModel otherPartnerSecondaryPlanModel = null;
30087 tejbeer 902 
				Map<String, PartnerSecondaryPlanModel> secondaryModelMap = new HashMap<>();
30077 tejbeer 903 
				if (partnerSecondayPlans.get(fofoId) != null) {
904 
					long otherBrandSecondary = 0;
905 
					for (PartnerSecondaryPlanModel pspm : partnerSecondayPlans.get(fofoId)) {
30087 tejbeer 906 
						Integer authId = pspm.getAuthId();
30077 tejbeer 907 
						if (!brands.contains(pspm.getBrand())) {
30087 tejbeer 908 
							if (pspm.getAchievementPlan() != null) {
909 
								otherBrandSecondary += pspm.getAchievementPlan();
910 
							}
30077 tejbeer 911 
						} else {
912 
							otherPartnerSecondaryPlanModel = pspm;
913 
						}
30087 tejbeer 914 
						if (pspm.getTargetPlan() != null) {
915 
							totalSecondaryPlan += pspm.getTargetPlan();
916 
						}
917 
 
918 
						if (pspm.getAchievementPlan() != null) {
919 
							totalSecondaryAchivement += pspm.getAchievementPlan();
920 
						}
30137 tejbeer 921 
 
922 
						if (pspm.getCommittedDate() != null) {
923 
 
924 
							ptam.setSecondaryCommitmentDate(pspm.getCommittedDate().toLocalDate());
925 
						}
30087 tejbeer 926 
						if (authId != null && authId == authUser.getId()) {
927 
 
30137 tejbeer 928 
							if (pspm.getTargetPlan() != null && pspm.getCommittedDate() != null) {
30087 tejbeer 929 
 
30137 tejbeer 930 
								if (pspm.getCommittedDate().isEqual(startDate)) {
931 
									totalPartnerTargetSecondary += pspm.getTargetPlan();
932 
								}
30087 tejbeer 933 
							}
934 
 
935 
							if (pspm.getAchievementPlan() != null) {
936 
								totalPartnerAchievementSecondary += pspm.getAchievementPlan();
937 
							}
938 
 
939 
						}
30077 tejbeer 940 
					}
941 
					if (otherPartnerSecondaryPlanModel != null) {
942 
						otherPartnerSecondaryPlanModel.setAchievementPlan(otherBrandSecondary);
943 
					}
30087 tejbeer 944 
					secondaryModelMap = partnerSecondayPlans.get(fofoId).stream()
30077 tejbeer 945 
							.filter(x -> brands.contains(x.getBrand()))
946 
							.collect(Collectors.toMap(x -> x.getBrand(), x -> x));
947 
 
948 
					if (secondaryModelMap.containsKey("Others")) {
949 
						PartnerSecondaryPlanModel psp = secondaryModelMap.get("Others");
950 
						psp.setAchievementPlan(otherBrandSecondary);
951 
					} else {
30087 tejbeer 952 
						secondaryModelMap.put("Others", new PartnerSecondaryPlanModel(fofoId, "Others", (long) 0,
30137 tejbeer 953 
								otherBrandSecondary, authUser.getId(), null));
30077 tejbeer 954 
					}
955 
					for (String brand : brands) {
956 
						if (!secondaryModelMap.containsKey(brand)) {
30137 tejbeer 957 
							secondaryModelMap.put(brand, new PartnerSecondaryPlanModel(fofoId, brand, (long) 0,
958 
									(long) 0, authUser.getId(), null));
30077 tejbeer 959 
						}
960 
					}
961 
 
30087 tejbeer 962 
					for (Entry<String, PartnerSecondaryPlanModel> secondaryModelEntry : secondaryModelMap.entrySet()) {
963 
						Integer authId = secondaryModelEntry.getValue().getAuthId();
964 
						if (authId != null && authId != authUser.getId()) {
965 
							secondaryModelEntry.getValue().setAuthUser(authRepository.selectById(authId));
966 
							ptam.setSecondaryColor("red");
967 
						}
968 
 
969 
					}
970 
 
30077 tejbeer 971 
					ptam.setPartnerSecondaryModel(secondaryModelMap);
972 
					ptam.setTotalSecondaryPlan(totalSecondaryPlan);
30087 tejbeer 973 
					ptam.setTotalSecondaryAchievement(totalSecondaryAchivement);
30330 tejbeer 974 
					// Secondary
30077 tejbeer 975 
 
30087 tejbeer 976 
				} else {
977 
					for (String brand : brands) {
978 
						PartnerSecondaryPlanModel pspm = new PartnerSecondaryPlanModel();
979 
						pspm.setAchievementPlan((long) 0);
980 
						pspm.setTargetPlan((long) 0);
981 
						pspm.setBrand(brand);
982 
						pspm.setFofoId(fofoId);
983 
						secondaryModelMap.put(brand, pspm);
984 
					}
985 
					ptam.setPartnerSecondaryModel(secondaryModelMap);
30077 tejbeer 986 
				}
987 
 
30416 tejbeer 988 
				if (!partnerTicketCount.isEmpty()) {
989 
					if (partnerTicketCount.get(fofoId) != null) {
990 
						ptam.setTicketCount(partnerTicketCount.get(fofoId));
991 
					} else {
992 
						ptam.setTicketCount(0);
993 
 
994 
					}
995 
				}
996 
 
30078 tejbeer 997 
				ptams.add(ptam);
998 
 
30077 tejbeer 999 
			}
1000 
 
1001 
			tm.setTotalPartnerTargetCollection(totalPartnerTargetCollection);
1002 
			tm.setTotalPartnerTargetSecondary(totalPartnerTargetSecondary);
1003 
			tm.setTotalPartnerSecondary(totalPartnerAchievementSecondary);
1004 
			tm.setTotalPartnerCollection(totalPartnerAchievementCollection);
30453 tejbeer 1005 
			tm.setTodayCollectionCount((int) todayCollectionCount);
30077 tejbeer 1006 
 
30330 tejbeer 1007 
			tm.setTargetAchievement(ptams.stream().sorted(Comparator.comparing(PartnerTargetAchievementModel::getRank))
30087 tejbeer 1008 
					.collect(Collectors.toList()));
1009 
 
30077 tejbeer 1010 
		}
1011 
 
1012 
		return responseSender.ok(tm);
1013 
 
1014 
	}
1015 
 
1016 
	@RequestMapping(value = "/target", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_VALUE)
1017 
	@ApiImplicitParams({
30294 tejbeer 1018 
			@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
30077 tejbeer 1019 
	public ResponseEntity<?> createPartnerTarget(HttpServletRequest request,
30294 tejbeer 1020 
			@RequestBody PartnerTargetAchievementModel ptam) throws ProfitMandiBusinessException {
30077 tejbeer 1021 
 
30089 tejbeer 1022 
		LOGGER.info("ptam" + ptam);
1023 
 
30087 tejbeer 1024 
		AuthUser authUser = authRepository.selectByGmailId(ptam.getCreatedBy());
30077 tejbeer 1025 
 
30137 tejbeer 1026 
		if (ptam.getCollectionCommitmentDate().isAfter(LocalDate.now())
1027 
				|| ptam.getCollectionCommitmentDate().isEqual(LocalDate.now())) {
1028 
			PartnerCollectionPlan partnerCollectionPlan = partnerCollectionPlanRepository
1029 
					.selectByLocalDate(LocalDate.now(), ptam.getFofoId(), true);
1030 
			LOGGER.info("pcp" + partnerCollectionPlan);
30077 tejbeer 1031 
 
30137 tejbeer 1032 
			if (partnerCollectionPlan == null) {
1033 
				if (ptam.getCollectionTarget() > 0) {
30087 tejbeer 1034 
 
30137 tejbeer 1035 
					partnerCollectionPlan = new PartnerCollectionPlan();
1036 
					partnerCollectionPlan.setCreateTimestamp(LocalDateTime.now());
1037 
					partnerCollectionPlan.setAuthId(authUser.getId());
1038 
					partnerCollectionPlan.setFofoId(ptam.getFofoId());
1039 
					partnerCollectionPlan.setActive(true);
1040 
					partnerCollectionPlan.setCollectionPlan(ptam.getCollectionTarget());
1041 
					partnerCollectionPlan.setUpdatedTimestamp(LocalDateTime.now());
1042 
					partnerCollectionPlan.setCommitedTimestamp(ptam.getCollectionCommitmentDate().atStartOfDay());
1043 
					partnerCollectionPlanRepository.persist(partnerCollectionPlan);
30416 tejbeer 1044 
 
30137 tejbeer 1045 
				}
30087 tejbeer 1046 
 
30137 tejbeer 1047 
			} else {
30087 tejbeer 1048 
 
30137 tejbeer 1049 
				if (partnerCollectionPlan.getCollectionPlan() != ptam.getCollectionTarget()) {
1050 
					float totalCollectionPlan = partnerCollectionPlan.getCollectionPlan() + 10000;
1051 
					if (authUser.getId() == partnerCollectionPlan.getAuthId()) {
30087 tejbeer 1052 
 
30185 tejbeer 1053 
						if (authUser.getEmailId().equals("tarun.verma@smartdukaan.com")
1054 
								|| authUser.getEmailId().equals("rakesh.sonawane@smartdukaan.com")
1055 
								|| ptam.getCollectionTarget() >= totalCollectionPlan) {
30137 tejbeer 1056 
							partnerCollectionPlan.setCollectionPlan(ptam.getCollectionTarget());
1057 
							partnerCollectionPlan.setActive(true);
1058 
							partnerCollectionPlan
1059 
									.setCommitedTimestamp(ptam.getCollectionCommitmentDate().atStartOfDay());
1060 
							partnerCollectionPlan.setUpdatedTimestamp(LocalDateTime.now());
1061 
						} else {
1062 
							throw new ProfitMandiBusinessException("collection target", "",
1063 
									"collection target should be more than " + totalCollectionPlan);
1064 
						}
30087 tejbeer 1065 
 
1066 
					} else {
30137 tejbeer 1067 
 
30185 tejbeer 1068 
						if (authUser.getEmailId().equals("tarun.verma@smartdukaan.com")
1069 
								|| authUser.getEmailId().equals("rakesh.sonawane@smartdukaan.com")
1070 
								|| ptam.getCollectionTarget() >= totalCollectionPlan) {
30137 tejbeer 1071 
 
1072 
							partnerCollectionPlan.setActive(false);
1073 
							partnerCollectionPlan.setUpdatedTimestamp(LocalDateTime.now());
1074 
							partnerCollectionPlan = new PartnerCollectionPlan();
1075 
							partnerCollectionPlan.setCreateTimestamp(LocalDateTime.now());
1076 
							partnerCollectionPlan.setAuthId(authUser.getId());
1077 
							partnerCollectionPlan.setFofoId(ptam.getFofoId());
1078 
							partnerCollectionPlan.setActive(true);
1079 
							partnerCollectionPlan
1080 
									.setCommitedTimestamp(ptam.getSecondaryCommitmentDate().atStartOfDay());
1081 
							partnerCollectionPlan.setCollectionPlan(ptam.getCollectionTarget());
1082 
							partnerCollectionPlan.setUpdatedTimestamp(LocalDateTime.now());
1083 
							partnerCollectionPlanRepository.persist(partnerCollectionPlan);
1084 
						} else {
1085 
							throw new ProfitMandiBusinessException("collection target", "",
1086 
									"collection target should be more than " + totalCollectionPlan);
1087 
						}
30087 tejbeer 1088 
					}
1089 
				}
30137 tejbeer 1090 
 
30146 tejbeer 1091 
				if ((LocalDate.now().atStartOfDay().equals(ptam.getCollectionCommitmentDate().atStartOfDay())
1092 
						|| ptam.getCollectionCommitmentDate().atStartOfDay().isAfter(LocalDate.now().atStartOfDay()))
30137 tejbeer 1093 
						&& partnerCollectionPlan.getCollectionPlan() == ptam.getCollectionTarget()) {
1094 
					partnerCollectionPlan.setCommitedTimestamp(ptam.getCollectionCommitmentDate().atStartOfDay());
1095 
					partnerCollectionPlan.setUpdatedTimestamp(LocalDateTime.now());
1096 
				}
30416 tejbeer 1097 
 
30087 tejbeer 1098 
			}
30433 tejbeer 1099 
 
1100 
			PartnerCollectionRemark pcr = new PartnerCollectionRemark();
1101 
			pcr.setFofoId(ptam.getFofoId());
1102 
			pcr.setAuthId(authUser.getId());
1103 
			pcr.setMessage("Collection plan for" + ptam.getCollectionCommitmentDate());
1104 
			pcr.setRemark(CollectionRemark.COLLECTION_PLAN);
1105 
			pcr.setCreateTimestamp(LocalDateTime.now());
1106 
			partnerCollectionRemarkRepository.persist(pcr);
30137 tejbeer 1107 
		} else {
1108 
			throw new ProfitMandiBusinessException("Date", "",
30138 tejbeer 1109 
					"you can't select the back date " + ptam.getCollectionCommitmentDate());
30077 tejbeer 1110 
		}
1111 
 
1112 
		for (Entry<String, PartnerSecondaryPlanModel> pspm : ptam.getPartnerSecondaryModel().entrySet()) {
30087 tejbeer 1113 
 
30137 tejbeer 1114 
			if (ptam.getCollectionCommitmentDate().isAfter(LocalDate.now())
1115 
					|| ptam.getCollectionCommitmentDate().isEqual(LocalDate.now())) {
1116 
				PartnerSecondaryPlanModel plan = pspm.getValue();
1117 
				PartnerSecondaryPlan psp = partnerSecondaryPlanRepository.selectByLocalDateBrand(plan.getBrand(),
1118 
						LocalDate.now(), ptam.getFofoId(), true);
1119 
				LOGGER.info("psp" + psp);
30087 tejbeer 1120 
 
30137 tejbeer 1121 
				if (psp == null) {
30461 tejbeer 1122 
					if (plan.getTargetPlan() != null && plan.getTargetPlan() > 0) {
30087 tejbeer 1123 
 
30137 tejbeer 1124 
						psp = new PartnerSecondaryPlan();
1125 
						psp.setAuthId(authUser.getId());
1126 
						psp.setBrand(pspm.getKey());
1127 
						psp.setFofoId(pspm.getValue().getFofoId());
1128 
						psp.setSecondaryPlan(pspm.getValue().getTargetPlan());
1129 
						psp.setCreateTimestamp(LocalDateTime.now());
1130 
						psp.setUpdatedTimestamp(LocalDateTime.now());
1131 
						psp.setCommitedTimestamp(ptam.getSecondaryCommitmentDate().atStartOfDay());
1132 
						psp.setActive(true);
1133 
						partnerSecondaryPlanRepository.persist(psp);
1134 
					}
30087 tejbeer 1135 
 
30137 tejbeer 1136 
				} else {
1137 
					if (plan.getTargetPlan() != psp.getSecondaryPlan()) {
1138 
						float totalSecondaryPlan = psp.getSecondaryPlan() + 10000;
1139 
						if (authUser.getId() == plan.getAuthId()) {
30185 tejbeer 1140 
							if (authUser.getEmailId().equals("tarun.verma@smartdukaan.com")
1141 
									|| authUser.getEmailId().equals("rakesh.sonawane@smartdukaan.com")
1142 
									|| plan.getTargetPlan() >= totalSecondaryPlan) {
30137 tejbeer 1143 
								psp.setSecondaryPlan(pspm.getValue().getTargetPlan());
1144 
								psp.setCommitedTimestamp(ptam.getSecondaryCommitmentDate().atStartOfDay());
1145 
								psp.setUpdatedTimestamp(LocalDateTime.now());
1146 
								psp.setActive(true);
1147 
							} else {
1148 
								throw new ProfitMandiBusinessException("secondary target", "",
1149 
										"secondary target should be more than " + totalSecondaryPlan);
1150 
							}
30087 tejbeer 1151 
 
30137 tejbeer 1152 
						} else {
30087 tejbeer 1153 
 
30185 tejbeer 1154 
							if (authUser.getEmailId().equals("tarun.verma@smartdukaan.com")
1155 
									|| authUser.getEmailId().equals("rakesh.sonawane@smartdukaan.com")
1156 
									|| plan.getTargetPlan() >= totalSecondaryPlan) {
30087 tejbeer 1157 
 
30137 tejbeer 1158 
								psp.setUpdatedTimestamp(LocalDateTime.now());
1159 
								psp.setActive(false);
1160 
								psp = new PartnerSecondaryPlan();
1161 
								psp.setAuthId(authUser.getId());
1162 
								psp.setBrand(pspm.getKey());
1163 
								psp.setFofoId(pspm.getValue().getFofoId());
1164 
								psp.setSecondaryPlan(pspm.getValue().getTargetPlan());
1165 
								psp.setCommitedTimestamp(ptam.getSecondaryCommitmentDate().atStartOfDay());
1166 
								psp.setCreateTimestamp(LocalDateTime.now());
1167 
								psp.setUpdatedTimestamp(LocalDateTime.now());
1168 
								psp.setActive(true);
1169 
								partnerSecondaryPlanRepository.persist(psp);
1170 
							} else {
1171 
								throw new ProfitMandiBusinessException("secondary target", "",
1172 
										"secondary target should be more than " + totalSecondaryPlan);
1173 
							}
30087 tejbeer 1174 
						}
1175 
					}
30137 tejbeer 1176 
 
30146 tejbeer 1177 
					if ((LocalDate.now().atStartOfDay().equals(ptam.getSecondaryCommitmentDate().atStartOfDay())
1178 
							|| ptam.getSecondaryCommitmentDate().atStartOfDay().isAfter(LocalDate.now().atStartOfDay()))
30137 tejbeer 1179 
							&& plan.getTargetPlan() == psp.getSecondaryPlan()) {
1180 
						psp.setCommitedTimestamp(ptam.getSecondaryCommitmentDate().atStartOfDay());
1181 
						psp.setUpdatedTimestamp(LocalDateTime.now());
1182 
					}
1183 
 
30087 tejbeer 1184 
				}
30137 tejbeer 1185 
			} else {
1186 
				throw new ProfitMandiBusinessException("Date", "",
30138 tejbeer 1187 
						"you can't select the back date " + ptam.getSecondaryCommitmentDate());
30077 tejbeer 1188 
			}
30137 tejbeer 1189 
 
30077 tejbeer 1190 
		}
1191 
 
1192 
		return responseSender.ok(true);
30137 tejbeer 1193 
 
30077 tejbeer 1194 
	}
1195 
 
30416 tejbeer 1196 
	@RequestMapping(value = "/viewTickets", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
1197 
	@ApiImplicitParams({
1198 
 
1199 
			@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
1200 
	public ResponseEntity<?> viewTickets(HttpServletRequest request, @RequestParam int fofoId)
1201 
			throws ProfitMandiBusinessException {
1202 
		List<Ticket> tickets = ticketRepository.selectAllOpenTicketByRetailer(fofoId);
1203 
 
1204 
		List<TicketViewModel> viewList = new ArrayList<>();
1205 
		for (Ticket ticket : tickets) {
1206 
 
1207 
			TicketViewModel ticketViewModel = new TicketViewModel();
1208 
			ticketViewModel.setId(ticket.getId());
1209 
			TicketSubCategory ticketSubCategory = ticketSubCategoryRepository.selectById(ticket.getSubCategoryId());
1210 
			TicketCategory ticketCategory = ticketCategoryRepository.selectById(ticketSubCategory.getCategoryId());
1211 
 
1212 
			ticketViewModel.setCategoryName(ticketCategory.getName());
1213 
			ticketViewModel.setSubCategoryName(ticketSubCategory.getName());
1214 
			ticketViewModel.setCreatedTimestamp(ticket.getCreateTimestamp());
1215 
 
1216 
			viewList.add(ticketViewModel);
1217 
		}
1218 
		return responseSender.ok(viewList);
1219 
 
1220 
	}
1221 
 
1222 
	@RequestMapping(value = "/viewRecentTickets", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
1223 
	@ApiImplicitParams({
1224 
 
1225 
			@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
1226 
	public ResponseEntity<?> viewRecentTickets(HttpServletRequest request, @RequestParam int fofoId)
1227 
			throws ProfitMandiBusinessException {
1228 
		List<TicketViewModel> viewList = ticketRepository.selectRecentClosedTicket(fofoId,
1229 
				LocalDateTime.now().minusDays(20));
1230 
 
1231 
		return responseSender.ok(viewList);
1232 
 
1233 
	}
1234 
 
1235 
	@RequestMapping(value = "/createTicket", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
1236 
	@ApiImplicitParams({
1237 
 
1238 
			@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
1239 
	public ResponseEntity<?> createTicket(HttpServletRequest request) throws ProfitMandiBusinessException {
1240 
		List<TicketCategory> ticketCategories = csService.getAllTicketCategotyFromSubCategory();
30460 tejbeer 1241 
 
30416 tejbeer 1242 
		return responseSender.ok(ticketCategories);
1243 
	}
1244 
 
1245 
	@RequestMapping(value = "/getSubCategoriesByCategoryId", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
1246 
	@ApiImplicitParams({
1247 
			@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
1248 
 
1249 
	public ResponseEntity<?> getSubCategoriesByCategoryId(HttpServletRequest request,
1250 
			@RequestParam(name = "categoryId", defaultValue = "0") int categoryId, Model model) {
1251 
		List<TicketSubCategory> ticketSubCategories = ticketSubCategoryRepository.selectAll(categoryId);
1252 
		LOGGER.info(ticketSubCategories);
1253 
		return responseSender.ok(ticketSubCategories);
1254 
	}
1255 
 
1256 
	@RequestMapping(value = "/createTicket", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_VALUE)
1257 
	@ApiImplicitParams({
1258 
 
1259 
			@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
1260 
	public ResponseEntity<?> createTicket(HttpServletRequest request, @RequestParam(name = "categoryId") int categoryId,
1261 
			@RequestParam(name = "subCategoryId") int subCategoryId, @RequestParam(name = "message") String message,
1262 
			@RequestParam(name = "fofoId") int fofoId) throws Exception {
30460 tejbeer 1263 
 
1264 
		int id = (int) request.getAttribute("userId");
1265 
 
1266 
		LOGGER.info("id" + id);
1267 
 
1268 
		User user = userRepository.selectById(id);
1269 
 
1270 
		AuthUser authUser = authRepository.selectByEmailOrMobile(user.getEmailId());
1271 
 
30416 tejbeer 1272 
		List<Ticket> tickets = ticketRepository.selectAllResolvedMarkedTicketByCreator(fofoId);
1273 
		if (tickets.size() > 3 || tickets.size() == 3) {
1274 
			return responseSender.ok(false);
1275 
		} else {
1276 
			csService.createTicket(fofoId, categoryId, subCategoryId, message);
1277 
 
30460 tejbeer 1278 
			PartnerCollectionRemark pcr = new PartnerCollectionRemark();
1279 
			pcr.setFofoId(fofoId);
1280 
			pcr.setAuthId(authUser.getId());
1281 
			pcr.setMessage("Ticket Created");
1282 
			pcr.setRemark(CollectionRemark.TICKET_CREATED);
1283 
			pcr.setCreateTimestamp(LocalDateTime.now());
1284 
			partnerCollectionRemarkRepository.persist(pcr);
1285 
 
30416 tejbeer 1286 
		}
1287 
		return responseSender.ok(true);
1288 
	}
1289 
 
1290 
	@RequestMapping(value = "/getCollectionRemark", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
1291 
	@ApiImplicitParams({
1292 
 
1293 
			@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
1294 
	public ResponseEntity<?> getCollectionRemark(HttpServletRequest request) throws ProfitMandiBusinessException {
30433 tejbeer 1295 
		List<CollectionRemark> remarks = Arrays.asList(CollectionRemark.values()).stream()
1296 
				.filter(x -> !x.equals(CollectionRemark.COLLECTION_PLAN)).collect(Collectors.toList());
1297 
		return responseSender.ok(remarks);
30416 tejbeer 1298 
	}
1299 
 
1300 
	@RequestMapping(value = "/createPartnerColectionRemark", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_VALUE)
1301 
	@ApiImplicitParams({
1302 
 
1303 
			@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header") })
1304 
	public ResponseEntity<?> createPartnerColectionRemark(HttpServletRequest request,
1305 
			@RequestBody PartnerCollectionRemarkModel partnerCollectionRemarkModel)
1306 
			throws ProfitMandiBusinessException {
1307 
		AuthUser authUser = authRepository.selectByGmailId(partnerCollectionRemarkModel.getGmailId());
1308 
 
1309 
		PartnerCollectionRemark pcr = new PartnerCollectionRemark();
1310 
		pcr.setFofoId(partnerCollectionRemarkModel.getFofoId());
1311 
		pcr.setAuthId(authUser.getId());
1312 
		pcr.setMessage(partnerCollectionRemarkModel.getMessage());
1313 
		pcr.setRemark(partnerCollectionRemarkModel.getRemark());
1314 
		pcr.setCreateTimestamp(LocalDateTime.now());
1315 
		partnerCollectionRemarkRepository.persist(pcr);
1316 
		return responseSender.ok(true);
1317 
 
1318 
	}
30433 tejbeer 1319 
 
1320 
	@RequestMapping(value = "/uploadFranchiseeVisit", method = RequestMethod.POST)
1321 
	public ResponseEntity<?> readCsvFileAndSetLead(HttpServletRequest request, @RequestPart MultipartFile multipartFile)
1322 
			throws Throwable {
1323 
 
1324 
		int id = (int) request.getAttribute("userId");
1325 
 
1326 
		LOGGER.info("id" + id);
1327 
 
1328 
		User user = userRepository.selectById(id);
1329 
 
1330 
		AuthUser authUser = authRepository.selectByEmailOrMobile(user.getEmailId());
1331 
 
1332 
		String fileName = multipartFile.getName();
1333 
		String fileNames = multipartFile.getOriginalFilename();
1334 
 
1335 
		LOGGER.info("fileName" + fileName);
1336 
		LOGGER.info("fileNames" + fileNames);
1337 
 
1338 
		List<CSVRecord> records = FileUtil.readFile(multipartFile);
1339 
 
1340 
		for (CSVRecord record : records) {
1341 
			FranchiseeVisit franchiseeVisit = new FranchiseeVisit();
1342 
			franchiseeVisit.setFofoId(Integer.parseInt(record.get(0)));
1343 
			CustomRetailer customRetailer = retailerService.getFofoRetailer(Integer.parseInt(record.get(0)));
1344 
 
1345 
			franchiseeVisit.setPartnerName(customRetailer.getBusinessName());
1346 
			franchiseeVisit.setAgenda(record.get(1));
1347 
			franchiseeVisit.setCreatedTimestamp(LocalDateTime.now());
1348 
			franchiseeVisit.setUpdatedTimestamp(LocalDateTime.now());
1349 
			franchiseeVisit.setStatus(FranchiseeVisitStatus.OPEN);
1350 
 
1351 
			DateTimeFormatter formatter = DateTimeFormatter.ofPattern("dd-MM-yyyy");
1352 
			LOGGER.info(record.get(1));
1353 
			LocalDate dateTime = LocalDate.parse(record.get(2), formatter);
1354 
 
30530 tejbeer 1355 
			franchiseeVisit.setScheduleTimestamp(dateTime.atStartOfDay());
30433 tejbeer 1356 
			// change
1357 
 
1358 
			String authUserName = authUser.getFirstName() + " " + authUser.getLastName();
1359 
			franchiseeVisit.setCreatedBy(authUserName);
1360 
			franchiseeVisit.setAuthId(authUser.getId());
1361 
 
1362 
			franchiseeVisitRepository.persist(franchiseeVisit);
1363 
 
1364 
			return responseSender.ok(true);
1365 
		}
1366 
 
1367 
		return responseSender.ok(true);
1368 
 
1369 
	}
30487 tejbeer 1370 
 
1371 
	@RequestMapping(value = "/downloadFranchiseeVisitTemplate", method = RequestMethod.GET)
1372 
	public ResponseEntity<?> downloadFranchiseeVisitTemplate(HttpServletRequest request) throws Exception {
1373 
 
1374 
		// ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
1375 
 
1376 
		List<List<?>> rows = new ArrayList<>();
1377 
 
1378 
		org.apache.commons.io.output.ByteArrayOutputStream byteArrayOutputStream = FileUtil
1379 
				.getCSVByteStream(Arrays.asList("Partner Id", "Agenda", "Schedule Timestamp"), rows);
1380 
 
1381 
		try {
1382 
			byteArrayOutputStream.close();
1383 
		} catch (IOException e) {
1384 
			// TODO Auto-generated catch block
1385 
			e.printStackTrace();
1386 
		}
1387 
 
30544 tejbeer 1388 
		String filename = "template.csv";
1389 
		HttpHeaders headers = new HttpHeaders();
1390 
		headers.add("Content-Type", "application/csv");
1391 
		headers.setContentDispositionFormData(filename, filename);
30487 tejbeer 1392 
 
30544 tejbeer 1393 
		headers.setCacheControl("must-revalidate, post-check=0, pre-check=0");
30487 tejbeer 1394 
 
30544 tejbeer 1395 
		ResponseEntity<byte[]> response = new ResponseEntity<byte[]>(byteArrayOutputStream.toByteArray(), headers,
1396 
				HttpStatus.OK);
1397 
		return response;
1398 
 
30487 tejbeer 1399 
	}
30542 tejbeer 1400 
 
1401 
	@RequestMapping(value = "/markVisitAttendance", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_VALUE)
1402 
	public ResponseEntity<?> markVisitAttendance(HttpServletRequest request, @RequestParam(name = "id") int id)
1403 
			throws ProfitMandiBusinessException {
1404 
		FranchiseeVisit franchiseeVisit = franchiseeVisitRepository.selectById(id);
1405 
 
1406 
		franchiseeVisit.setVisitTimestamp(LocalDateTime.now());
1407 
 
1408 
		return responseSender.ok(true);
1409 
 
1410 
	}
31249 tejbeer 1411 
 
1412 
	@RequestMapping(value = "/getVisitRequests", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
1413 
	public ResponseEntity<?> getVisitRequests(HttpServletRequest request,
1414 
			@RequestParam(name = "gmailId") String gmailId, Model model) throws Exception {
1415 
 
1416 
		AuthUser authUser = authRepository.selectByGmailId(gmailId);
1417 
 
1418 
		List<Integer> authUserIds = authService.getAllReportees(authUser.getId());
1419 
		List<VisitSummaryModel> visitSummary = new ArrayList<>();
1420 
 
1421 
		if (!authUserIds.isEmpty()) {
1422 
			List<AuthUser> authUsers = authRepository.selectAllAuthUserByIds(authUserIds);
1423 
 
1424 
			List<VisitRequest> allVisitRequests = visitRequestRepository.selectByAuthIdsAndDate(authUserIds,
1425 
					LocalDate.now().minusDays(7), Arrays.asList(VisitStatus.approved, VisitStatus.pending));
1426 
			LOGGER.info("allVisitRequests {}", allVisitRequests);
1427 
 
1428 
			if (!allVisitRequests.isEmpty()) {
1429 
 
1430 
				List<Integer> leadIds = allVisitRequests.stream().filter(x -> x.getVisitType().equals("lead"))
1431 
						.map(x -> x.getVisitId()).collect(Collectors.toList());
1432 
				List<Lead> leads = new ArrayList<>();
1433 
				if (!leadIds.isEmpty()) {
1434 
					leads = leadRepository.selectAllByIds(leadIds);
1435 
 
1436 
					for (Lead lead : leads) {
1437 
						List<LeadActivity> leadActivities = leadActivityRepository.selectBYLeadId(lead.getId());
1438 
						lead.setScheduledTimestamp(leadActivities.get(0).getSchelduleTimestamp());
1439 
						lead.setLeadActivity(leadActivities.get(0));
1440 
					}
1441 
				}
1442 
				List<Integer> franchiseeIds = allVisitRequests.stream()
1443 
						.filter(x -> x.getVisitType().equals("franchiseeVisit")).map(x -> x.getVisitId())
1444 
						.collect(Collectors.toList());
1445 
				List<FranchiseeVisit> franchiseeVisits = new ArrayList<>();
1446 
				if (!franchiseeIds.isEmpty()) {
1447 
					franchiseeVisits = franchiseeVisitRepository.selectAllByIds(franchiseeIds);
1448 
					LOGGER.info("franchiseeVisits {}", franchiseeVisits);
1449 
 
1450 
					for (FranchiseeVisit franchiseeVisit : franchiseeVisits) {
1451 
						List<FranchiseeActivity> franchiseeActivities = franchiseeActivityRepository
1452 
								.selectByFranchiseeVisitId(franchiseeVisit.getId());
1453 
						LOGGER.info("franchiseeActivities {}", franchiseeActivities);
1454 
 
1455 
						franchiseeVisit.setScheduleTimestamp(franchiseeActivities.get(0).getSchelduleTimestamp());
1456 
						franchiseeVisit.setFranchiseeActivity(franchiseeActivities.get(0));
1457 
					}
1458 
 
1459 
				}
1460 
 
1461 
				Map<LocalDate, List<VisitRequest>> dateWiseVisitRequest = allVisitRequests.stream()
1462 
						.collect(Collectors.groupingBy(x -> x.getScheduleTimestamp().toLocalDate()));
1463 
 
1464 
				for (Entry<LocalDate, List<VisitRequest>> visitEntry : dateWiseVisitRequest.entrySet()) {
1465 
 
1466 
					LocalDate date = visitEntry.getKey();
1467 
					List<VisitRequest> visitRequests = visitEntry.getValue();
1468 
 
1469 
					VisitSummaryModel visitSummaryModel = new VisitSummaryModel();
1470 
 
1471 
					visitSummaryModel.setDate(date);
1472 
					List<Integer> dateWiseLeadEntry = visitRequests.stream()
1473 
							.filter(x -> x.getVisitType().equals("lead")).map(x -> x.getVisitId())
1474 
							.collect(Collectors.toList());
1475 
 
1476 
					List<Integer> dateWiseFranchiseeIds = visitRequests.stream()
1477 
							.filter(x -> x.getVisitType().equals("franchiseeVisit")).map(x -> x.getVisitId())
1478 
							.collect(Collectors.toList());
1479 
 
1480 
					Map<Integer, List<Lead>> filteredLeadsMap = null;
1481 
					if (!leads.isEmpty()) {
1482 
						filteredLeadsMap = leads.stream().filter(x -> dateWiseLeadEntry.contains(x.getId()))
1483 
								.collect(Collectors.groupingBy(x -> x.getAssignTo()));
1484 
 
1485 
					}
1486 
 
1487 
					Map<Integer, List<FranchiseeVisit>> filteredFranchiseeVisitsMap = null;
1488 
 
1489 
					if (!franchiseeVisits.isEmpty()) {
1490 
						filteredFranchiseeVisitsMap = franchiseeVisits.stream()
1491 
								.filter(x -> dateWiseFranchiseeIds.contains(x.getId()))
1492 
								.collect(Collectors.groupingBy(x -> x.getAuthId()));
1493 
 
1494 
					}
1495 
 
1496 
					List<UserVisitModel> userVisits = new ArrayList<>();
1497 
 
1498 
					for (AuthUser auth : authUsers) {
1499 
						UserVisitModel userVisitModel = new UserVisitModel();
1500 
						List<VisitDescriptionModel> visitDescriptions = new ArrayList<>();
1501 
 
1502 
						List<Lead> authLeads = new ArrayList<>();
1503 
						if (filteredLeadsMap != null) {
1504 
							authLeads = filteredLeadsMap.get(auth.getId());
1505 
 
1506 
						}
1507 
 
1508 
						if (authLeads != null && !authLeads.isEmpty()) {
1509 
							userVisitModel.setAuthUser(auth.getFullName());
1510 
 
1511 
							for (Lead lead : authLeads) {
1512 
 
1513 
								VisitRequest visitRequest = visitRequests.stream().filter(
1514 
										x -> x.getVisitId() == lead.getId() && x.getCreatedBy() == lead.getAssignTo())
1515 
										.findAny().orElse(null);
1516 
								VisitDescriptionModel visitDescriptionModel = new VisitDescriptionModel();
1517 
								visitDescriptionModel.setVisitId(visitRequest.getId());
1518 
								visitDescriptionModel.setVisitName(lead.getFirstName());
1519 
								visitDescriptionModel.setCity(lead.getCity());
1520 
								visitDescriptionModel.setState(lead.getState());
1521 
								visitDescriptionModel.setScheduleTime(lead.getScheduledTimestamp());
1522 
								visitDescriptionModel.setStatus(visitRequest.getStatus());
1523 
								visitDescriptionModel.setRemarks(lead.getLeadActivity().getRemark());
1524 
								visitDescriptionModel.setVisitType(visitRequest.getVisitType());
1525 
								visitDescriptions.add(visitDescriptionModel);
1526 
 
1527 
							}
1528 
						}
1529 
 
1530 
						List<FranchiseeVisit> authfranchiseeVisit = new ArrayList<>();
1531 
						if (filteredFranchiseeVisitsMap != null) {
1532 
							authfranchiseeVisit = filteredFranchiseeVisitsMap.get(auth.getId());
1533 
 
1534 
						}
1535 
 
1536 
						if (authfranchiseeVisit != null && !authfranchiseeVisit.isEmpty()) {
1537 
							userVisitModel.setAuthUser(auth.getFullName());
1538 
 
1539 
							for (FranchiseeVisit franchiseeVisit : authfranchiseeVisit) {
1540 
 
1541 
								VisitRequest visitRequest = visitRequests.stream()
1542 
										.filter(x -> x.getVisitId() == franchiseeVisit.getId()
1543 
												&& x.getCreatedBy() == franchiseeVisit.getAuthId())
1544 
										.findAny().orElse(null);
1545 
 
1546 
								CustomRetailer customRetailer = retailerService
1547 
										.getFofoRetailer(franchiseeVisit.getFofoId());
1548 
								VisitDescriptionModel visitDescriptionModel = new VisitDescriptionModel();
1549 
								visitDescriptionModel.setVisitId(visitRequest.getId());
1550 
								visitDescriptionModel.setVisitName(franchiseeVisit.getPartnerName());
1551 
								visitDescriptionModel.setCity(customRetailer.getAddress().getCity());
1552 
								visitDescriptionModel.setState(customRetailer.getAddress().getState());
1553 
								visitDescriptionModel.setScheduleTime(
1554 
										franchiseeVisit.getFranchiseeActivity().getSchelduleTimestamp());
1555 
								visitDescriptionModel.setStatus(visitRequest.getStatus());
1556 
								visitDescriptionModel.setRemarks(franchiseeVisit.getAgenda());
1557 
								visitDescriptionModel.setVisitType(visitRequest.getVisitType());
1558 
 
1559 
								visitDescriptions.add(visitDescriptionModel);
1560 
 
1561 
							}
1562 
						}
1563 
 
1564 
						userVisitModel.setVisitDescriptions(visitDescriptions);
1565 
						LOGGER.info("userVisit {}", userVisitModel);
1566 
 
1567 
						if (userVisitModel.getAuthUser() != null) {
1568 
							userVisits.add(userVisitModel);
1569 
						}
1570 
 
1571 
					}
1572 
 
1573 
					visitSummaryModel.setUserVisits(userVisits);
1574 
 
1575 
					visitSummary.add(visitSummaryModel);
1576 
 
1577 
				}
1578 
 
1579 
			}
1580 
 
1581 
		}
1582 
		return responseSender.ok(visitSummary);
1583 
 
1584 
	}
1585 
 
1586 
	@RequestMapping(value = "/visitRequest", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_VALUE)
1587 
	public ResponseEntity<?> visitRequest(HttpServletRequest request, @RequestParam(name = "gmailId") String gmailId,
1588 
			@RequestParam(name = "visitId") int visitId, @RequestParam(name = "status") VisitStatus status, Model model)
1589 
			throws Exception {
1590 
		AuthUser authUser = authRepository.selectByGmailId(gmailId);
1591 
 
1592 
		VisitRequest visitRequest = visitRequestRepository.selectById(visitId);
1593 
		visitRequest.setActionedBy(authUser.getId());
1594 
		visitRequest.setStatus(status);
1595 
		visitRequest.setUpdatedTimestamp(LocalDateTime.now());
1596 
		if (status.equals(VisitStatus.approved)) {
1597 
			visitRequest.setApprovedTimestamp(LocalDateTime.now());
1598 
		}
1599 
 
1600 
		SendNotificationModel sendNotificationModel = new SendNotificationModel();
1601 
		sendNotificationModel.setCampaignName("Visit Request");
1602 
		sendNotificationModel.setExpiresat(LocalDateTime.now().plusDays(1));
1603 
		sendNotificationModel.setTitle("Visit Request");
1604 
		String message = "Visit Request has been " + status + " for scheduled time on "
1605 
				+ visitRequest.getScheduleTimestamp().toLocalDate();
1606 
 
1607 
		sendNotificationModel.setMessage(message);
1608 
		sendNotificationModel.setMessageType(MessageType.notification);
1609 
		User user = userRepository.selectByEmailId(gmailId);
1610 
		sendNotificationModel.setUserIds(new ArrayList<>(user.getId()));
1611 
 
1612 
		notificationService.sendNotificationToAll(sendNotificationModel);
1613 
 
1614 
		return responseSender.ok(true);
1615 
 
1616 
	}
1617 
 
30077 tejbeer 1618 
}