Subversion Repositories SmartDukaan

Rev

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