Subversion Repositories SmartDukaan

Rev

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