Subversion Repositories SmartDukaan

Rev

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