Subversion Repositories SmartDukaan

Rev

Rev 36678 | Rev 36723 | 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;
36267 ranu 16 
import com.spice.profitmandi.dao.entity.cs.Activity;
32978 amit.gupta 17 
import com.spice.profitmandi.dao.entity.cs.Position;
36267 ranu 18 
import com.spice.profitmandi.dao.entity.cs.Ticket;
25899 tejbeer 19 
import com.spice.profitmandi.dao.entity.dtr.User;
25952 tejbeer 20 
import com.spice.profitmandi.dao.entity.dtr.UserAccount;
34322 ranu 21 
import com.spice.profitmandi.dao.entity.fofo.*;
32978 amit.gupta 22 
import com.spice.profitmandi.dao.entity.user.*;
30416 tejbeer 23 
import com.spice.profitmandi.dao.enumuration.auth.CollectionRemark;
32978 amit.gupta 24 
import com.spice.profitmandi.dao.enumuration.cs.EscalationType;
25 
import com.spice.profitmandi.dao.enumuration.dtr.*;
26 
import com.spice.profitmandi.dao.model.*;
27 
import com.spice.profitmandi.dao.repository.auth.*;
28 
import com.spice.profitmandi.dao.repository.cs.*;
29 
import com.spice.profitmandi.dao.repository.dtr.*;
30087 tejbeer 30 
import com.spice.profitmandi.dao.repository.fofo.PartnerDailyInvestmentRepository;
35075 aman 31 
import com.spice.profitmandi.dao.repository.fofo.PurchaseRepository;
36286 ranu 32 
import com.spice.profitmandi.dao.repository.fofo.RatingReminderRepository;
34301 ranu 33 
import com.spice.profitmandi.dao.repository.fofo.RbmRatingRepository;
34322 ranu 34 
import com.spice.profitmandi.dao.repository.fofo.SalesRatingRepository;
35632 ranu 35 
import com.spice.profitmandi.dao.repository.transaction.LoanRepository;
30077 tejbeer 36 
import com.spice.profitmandi.dao.repository.transaction.OrderRepository;
32978 amit.gupta 37 
import com.spice.profitmandi.dao.repository.user.AddressRepository;
31249 tejbeer 38 
import com.spice.profitmandi.service.AuthService;
39 
import com.spice.profitmandi.service.NotificationService;
30348 tejbeer 40 
import com.spice.profitmandi.service.PartnerCollectionService;
35725 ranu 41 
import com.spice.profitmandi.service.integrations.kommuno.RecordingService;
25952 tejbeer 42 
import com.spice.profitmandi.service.user.RetailerService;
28935 tejbeer 43 
import com.spice.profitmandi.service.user.StoreTimelineTatService;
25952 tejbeer 44 
import com.spice.profitmandi.web.req.CreateFranchiseeRequest;
34322 ranu 45 
import com.spice.profitmandi.web.req.RbmSalesRatingRequest;
25952 tejbeer 46 
import com.spice.profitmandi.web.res.Partner;
25899 tejbeer 47 
import io.swagger.annotations.ApiImplicitParam;
48 
import io.swagger.annotations.ApiImplicitParams;
32978 amit.gupta 49 
import org.apache.commons.csv.CSVRecord;
50 
import org.apache.commons.io.output.ByteArrayOutputStream;
51 
import org.apache.logging.log4j.LogManager;
52 
import org.apache.logging.log4j.Logger;
53 
import org.springframework.beans.factory.annotation.Autowired;
54 
import org.springframework.format.annotation.DateTimeFormat;
55 
import org.springframework.http.HttpHeaders;
56 
import org.springframework.http.HttpStatus;
57 
import org.springframework.http.MediaType;
58 
import org.springframework.http.ResponseEntity;
59 
import org.springframework.mail.javamail.JavaMailSender;
60 
import org.springframework.stereotype.Controller;
61 
import org.springframework.transaction.annotation.Transactional;
62 
import org.springframework.ui.Model;
63 
import org.springframework.web.bind.annotation.*;
64 
import org.springframework.web.multipart.MultipartFile;
25899 tejbeer 65 
 
32978 amit.gupta 66 
import javax.servlet.http.HttpServletRequest;
67 
import java.io.IOException;
36114 ranu 68 
import java.time.DayOfWeek;
32978 amit.gupta 69 
import java.time.LocalDate;
70 
import java.time.LocalDateTime;
34301 ranu 71 
import java.time.YearMonth;
32978 amit.gupta 72 
import java.time.format.DateTimeFormatter;
36114 ranu 73 
import java.time.temporal.TemporalAdjusters;
32978 amit.gupta 74 
import java.util.*;
35415 amit 75 
import java.util.HashSet;
32978 amit.gupta 76 
import java.util.Map.Entry;
77 
import java.util.stream.Collectors;
78 
 
25899 tejbeer 79 
@Controller
80 
@Transactional(rollbackFor = Throwable.class)
81 
public class LeadController {
31677 amit.gupta 82 
    private static final Logger LOGGER = LogManager.getLogger(LeadController.class);
83 
    @Autowired
84 
    private ResponseSender<?> responseSender;
25899 tejbeer 85 
 
31677 amit.gupta 86 
    @Autowired
87 
    private AuthRepository authRepository;
25899 tejbeer 88 
 
31677 amit.gupta 89 
    @Autowired
90 
    private LeadRepository leadRepository;
25899 tejbeer 91 
 
31677 amit.gupta 92 
    @Autowired
32923 ranu 93 
    DocumentRepository documentRepository;
94 
 
95 
    @Autowired
96 
    PositionRepository positionRepository;
97 
 
98 
    @Autowired
99 
    private ActivityAttachmentRepository activityAttachmentRepository;
100 
 
101 
    @Autowired
31677 amit.gupta 102 
    private CsService csService;
25952 tejbeer 103 
 
31677 amit.gupta 104 
    @Autowired
105 
    private UserRepository userRepository;
25952 tejbeer 106 
 
31677 amit.gupta 107 
    @Autowired
32923 ranu 108 
    private AddressRepository addressRepository;
109 
 
110 
    @Autowired
111 
 
112 
    private UserRoleRepository userRoleRepository;
113 
 
114 
    @Autowired
31677 amit.gupta 115 
    private UserAccountRepository userAccountRepository;
25952 tejbeer 116 
 
31677 amit.gupta 117 
    @Autowired
118 
    private com.spice.profitmandi.dao.repository.user.UserRepository userUserRepository;
25952 tejbeer 119 
 
31677 amit.gupta 120 
    @Autowired
121 
    private RetailerService retailerService;
25952 tejbeer 122 
 
31677 amit.gupta 123 
    @Autowired
124 
    private LeadActivityRepository leadActivityRepository;
25899 tejbeer 125 
 
31677 amit.gupta 126 
    @Autowired
127 
    private FranchiseeVisitRepository franchiseeVisitRepository;
25952 tejbeer 128 
 
31677 amit.gupta 129 
    @Autowired
130 
    private FranchiseeActivityRepository franchiseeActivityRepository;
25952 tejbeer 131 
 
31677 amit.gupta 132 
    @Autowired
133 
    private PartnerOnBoardingPanelRepository partnerOnBoardingPanelRepository;
28935 tejbeer 134 
 
31677 amit.gupta 135 
    @Autowired
136 
    private FofoStoreRepository fofoStoreRepository;
28935 tejbeer 137 
 
31677 amit.gupta 138 
    @Autowired
139 
    private StoreTimelineTatService storeTimelineTatService;
28935 tejbeer 140 
 
31677 amit.gupta 141 
    @Autowired
142 
    private PartnerCollectionService partnerCollectionService;
30348 tejbeer 143 
 
31677 amit.gupta 144 
    @Autowired
145 
    private TicketRepository ticketRepository;
30416 tejbeer 146 
 
31677 amit.gupta 147 
    @Autowired
36267 ranu 148 
    private ActivityRepository activityRepository;
149 
 
150 
    @Autowired
31677 amit.gupta 151 
    private TicketCategoryRepository ticketCategoryRepository;
30416 tejbeer 152 
 
31677 amit.gupta 153 
    @Autowired
154 
    private TicketSubCategoryRepository ticketSubCategoryRepository;
30416 tejbeer 155 
 
31677 amit.gupta 156 
    @Autowired
157 
    private PartnerCollectionRemarkRepository partnerCollectionRemarkRepository;
30416 tejbeer 158 
 
31677 amit.gupta 159 
    @Autowired
160 
    private Mongo mongoClient;
30487 tejbeer 161 
 
31677 amit.gupta 162 
    @Autowired
163 
    private OrderRepository orderRepository;
30487 tejbeer 164 
 
31677 amit.gupta 165 
    @Autowired
166 
    private PartnerCollectionPlanRepository partnerCollectionPlanRepository;
30487 tejbeer 167 
 
31677 amit.gupta 168 
    @Autowired
169 
    private PartnerSecondaryPlanRepository partnerSecondaryPlanRepository;
30487 tejbeer 170 
 
31677 amit.gupta 171 
    @Autowired
172 
    private PartnerDailyInvestmentRepository partnerDailyInvestmentRepository;
30487 tejbeer 173 
 
31677 amit.gupta 174 
    @Autowired
175 
    private VisitRequestRepository visitRequestRepository;
31249 tejbeer 176 
 
31677 amit.gupta 177 
    @Autowired
178 
    private AuthService authService;
31249 tejbeer 179 
 
31677 amit.gupta 180 
    @Autowired
181 
    private NotificationService notificationService;
31249 tejbeer 182 
 
32923 ranu 183 
    @Autowired
36400 amit 184 
    JavaMailSender gmailRelaySender;
32923 ranu 185 
 
186 
    @Autowired
187 
    private TicketAssignedRepository ticketAssignedRepository;
188 
 
34124 tejus.loha 189 
    @Autowired
190 
    LeadDetailRepository leadDetailRepository;
191 
 
35075 aman 192 
    @Autowired
193 
    PurchaseRepository purchaseRepository;
194 
 
35632 ranu 195 
    @Autowired
196 
    private LoanRepository loanRepository;
197 
 
35725 ranu 198 
    @Autowired
199 
    private RecordingService recordingService;
200 
 
31677 amit.gupta 201 
    @RequestMapping(value = "/lead", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_VALUE)
202 
    @ApiImplicitParams({
203 
            @ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header")})
34118 tejus.loha 204 
 
205 
    public ResponseEntity<?> LeadUser(@RequestBody CreateRefferalRequest createRefferalRequest) throws Exception {
35079 vikas 206 
        LOGGER.info("CreateReferralRequest - " + createRefferalRequest);
34394 tejus.loha 207 
        if (createRefferalRequest.getOutletName() == null || createRefferalRequest.getPotential() == 0) {
35079 vikas 208 
            throw new Exception("Outlet should not be empty and potential should be greater > 0");
34386 ranu 209 
        }
35288 amit 210 
        Lead lead;
211 
        AuthUser authUser = authRepository.selectByGmailId(createRefferalRequest.getReffereeEmail());
212 
        if (createRefferalRequest.getId() > 0) {
213 
            lead = leadRepository.selectById(createRefferalRequest.getId());
214 
            lead.setAssignTo(authUser.getId());
31677 amit.gupta 215 
        } else {
35288 amit 216 
            lead = new Lead();
217 
            lead.setFirstName(createRefferalRequest.getFirstName());
218 
            lead.setLastName(createRefferalRequest.getLastName());
219 
            lead.setLeadMobile(createRefferalRequest.getMobile());
220 
            lead.setState(createRefferalRequest.getState());
221 
            lead.setCity(createRefferalRequest.getCity());
222 
            lead.setAddress(createRefferalRequest.getAddress());
223 
            lead.setCreatedTimestamp(LocalDateTime.now());
224 
            lead.setOutLetName(createRefferalRequest.getOutletName());
225 
            lead.setUpdatedTimestamp(LocalDateTime.now());
226 
            lead.setStatus(createRefferalRequest.getStatus());
227 
            lead.setSource(createRefferalRequest.getSource());
228 
            lead.setNotinterestedReason(createRefferalRequest.getReason());
229 
            lead.setPotential(createRefferalRequest.getPotential());
230 
            if (createRefferalRequest.getColorCheck() == true) {
231 
                lead.setColor("Green");
232 
            } else {
233 
                lead.setColor("Yellow");
234 
            }
235 
            String authUserName = authUser.getFullName();
236 
            lead.setAuthId(authUser.getId());
237 
            lead.setAssignTo(authUser.getId());
35079 vikas 238 
            lead.setCreatedBy(authUserName);
239 
            leadRepository.persist(lead);
35288 amit 240 
 
35079 vikas 241 
        }
34118 tejus.loha 242 
 
31677 amit.gupta 243 
        LeadActivity leadActivity = new LeadActivity();
244 
        leadActivity.setLeadId(lead.getId());
35288 amit 245 
        leadActivity.setRemark((createRefferalRequest.getId() > 0 ? "Self Assigned." : "") + createRefferalRequest.getRemark());
31677 amit.gupta 246 
        leadActivity.setAuthId(authUser.getId());
31249 tejbeer 247 
 
31677 amit.gupta 248 
        if (createRefferalRequest.getStatus().equals(LeadStatus.followUp)) {
249 
            leadActivity.setSchelduleTimestamp(createRefferalRequest.getSchelduleTimestamp());
250 
            leadActivity.setCommunicationType(createRefferalRequest.getCommunicationType());
31249 tejbeer 251 
 
31677 amit.gupta 252 
            if (leadActivity.getCommunicationType().equals(CommunicationType.VISIT)) {
31249 tejbeer 253 
 
31677 amit.gupta 254 
                visitRequestRepository.createVisitRequest(lead.getId(), "lead", lead.getAssignTo(),
255 
                        createRefferalRequest.getSchelduleTimestamp());
256 
            }
257 
            //
258 
            leadActivity.setClosureTimestamp(createRefferalRequest.getClosureTimestamp());
259 
            lead.setClosureTimestamp(createRefferalRequest.getClosureTimestamp());
260 
        } else {
261 
            leadActivity.setSchelduleTimestamp(null);
262 
            leadActivity.setClosureTimestamp(null);
263 
            lead.setClosureTimestamp(null);
264 
        }
265 
        leadActivity.setCreatedTimestamp(LocalDateTime.now());
266 
        leadActivityRepository.persist(leadActivity);
25899 tejbeer 267 
 
31677 amit.gupta 268 
        return responseSender.ok(true);
269 
    }
25899 tejbeer 270 
 
31677 amit.gupta 271 
    @RequestMapping(value = "/lead-description", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
272 
    @ApiImplicitParams({
273 
            @ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header")})
35288 amit 274 
    public ResponseEntity<?> leadDescription(HttpServletRequest request, @RequestParam(name = "gmailId") String
275 
                                                     gmailId,
31677 amit.gupta 276 
                                             @RequestParam(name = "status") LeadStatus status) throws ProfitMandiBusinessException {
277 
        AuthUser authUser = authRepository.selectByGmailId(gmailId);
278 
        List<Lead> leads = null;
279 
        LOGGER.info("emails" + status);
31249 tejbeer 280 
 
35469 vikas 281 
        List<VisitRequest> visitRequests = visitRequestRepository.selectByAuthIdAndDate(authUser.getId(),
282 
                LocalDate.now());
283 
        Map<Integer, List<VisitRequest>> visitRequestMap = null;
284 
        if (!visitRequests.isEmpty()) {
285 
            visitRequestMap = visitRequests.stream().collect(Collectors.groupingBy(x -> x.getVisitId()));
286 
        }
31677 amit.gupta 287 
        if (status.equals(LeadStatus.followUp)) {
35469 vikas 288 
 
31677 amit.gupta 289 
            leads = leadRepository.selectLeadsScheduledBetweenDate(Arrays.asList(authUser.getId()), null, null);
31249 tejbeer 290 
 
35469 vikas 291 
            if (visitRequestMap != null) {
31677 amit.gupta 292 
                for (Lead lead : leads) {
293 
                    List<VisitRequest> visitRequest = visitRequestMap.get(lead.getId());
35469 vikas 294 
 
31677 amit.gupta 295 
                    if (visitRequest != null) {
296 
                        if (visitRequest.size() > 1) {
35469 vikas 297 
 
298 
                            Comparator<VisitRequest> visitComparato = Comparator
299 
                                    .comparing(VisitRequest::getCreatedTimestamp);
300 
 
301 
                            VisitRequest youngestVisit = visitRequest.stream().max(visitComparato).get();
31677 amit.gupta 302 
                            lead.setVisitStatus(youngestVisit.getStatus());
35469 vikas 303 
 
31677 amit.gupta 304 
                        } else {
305 
                            lead.setVisitStatus(visitRequest.get(0).getStatus());
35469 vikas 306 
 
31677 amit.gupta 307 
                        }
308 
                    }
35469 vikas 309 
 
31677 amit.gupta 310 
                }
311 
            }
31249 tejbeer 312 
 
31677 amit.gupta 313 
            leads = leads.stream()
35079 vikas 314 
                    .sorted(Comparator.comparing(Lead::getScheduledTimestamp, Comparator.nullsFirst(Comparator.reverseOrder())))
315 
                    .collect(Collectors.toList());
35469 vikas 316 
            /*
317 
             * Collections.sort(leads, (o1, o2) -> { if (o1.getScheduledTimestamp() != null
318 
             * && o2.getScheduledTimestamp() != null) { return
319 
             * o1.getScheduledTimestamp().isBefore(o2.getScheduledTimestamp()) ? -1 : 1; }
320 
             * else if (o1.getScheduledTimestamp() != null) { return 1; } else { return -1;
321 
             * } });
322 
             */
323 
 
31677 amit.gupta 324 
        } else {
325 
            leads = leadRepository.selectByAssignAuthIdAndStatus(authUser.getId(), status);
35469 vikas 326 
 
31677 amit.gupta 327 
        }
25979 tejbeer 328 
 
31677 amit.gupta 329 
        return responseSender.ok(leads);
35469 vikas 330 
 
31677 amit.gupta 331 
    }
25899 tejbeer 332 
 
31677 amit.gupta 333 
    @RequestMapping(value = "/getlead", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
35288 amit 334 
    @ApiImplicitParams({@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header")})
335 
    public ResponseEntity<?> getLead(HttpServletRequest request, @RequestParam(name = "id") int id) throws
336 
            ProfitMandiBusinessException {
25899 tejbeer 337 
 
31677 amit.gupta 338 
        List<LeadActivity> leadActivities = leadActivityRepository.selectBYLeadId(id);
339 
        Lead lead = leadRepository.selectById(id);
340 
        lead.setLeadActivities(leadActivities);
341 
        return responseSender.ok(lead);
25899 tejbeer 342 
 
31677 amit.gupta 343 
    }
25899 tejbeer 344 
 
35079 vikas 345 
    @RequestMapping(value = "/check-existing-lead", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
35288 amit 346 
    @ApiImplicitParams({@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header")})
347 
    public ResponseEntity<?> getLeadByMobile(HttpServletRequest request, @RequestParam(name = "mobile") String
348 
            mobile) throws ProfitMandiBusinessException {
35079 vikas 349 
        int userId = (int) request.getAttribute("userId");
350 
        LOGGER.info("userId: " + userId);
351 
        Lead lead = leadRepository.selectByMobileNumber(mobile);
352 
        return responseSender.ok(lead);
353 
 
354 
    }
355 
 
31677 amit.gupta 356 
    @RequestMapping(value = "/leadUpdate", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_VALUE)
35288 amit 357 
    @ApiImplicitParams({@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header")})
31677 amit.gupta 358 
    public ResponseEntity<?> leadUpdate(HttpServletRequest request, @RequestParam(name = "id") int id,
35288 amit 359 
                                        @RequestParam(name = "status") LeadStatus status, @RequestParam(name = "colorCheck") Boolean colorCheck,
360 
                                        @RequestParam(name = "remark") String remark, @RequestParam(name = "reason") String reason,
361 
                                        @RequestParam(name = "schelduleTimestamp") @DateTimeFormat(iso = DateTimeFormat.ISO.DATE_TIME) LocalDateTime schelduleTimestamp,
362 
                                        @RequestParam(name = "closureTimestamp") @DateTimeFormat(iso = DateTimeFormat.ISO.DATE_TIME) LocalDateTime closureTimestamp,
363 
                                        @RequestParam(name = "communicationType") CommunicationType communicationType) throws
364 
            ProfitMandiBusinessException {
25899 tejbeer 365 
 
31677 amit.gupta 366 
        Lead lead = leadRepository.selectById(id);
25899 tejbeer 367 
 
31677 amit.gupta 368 
        LeadActivity leadActivity = new LeadActivity();
369 
        lead.setStatus(status);
370 
        lead.setNotinterestedReason(reason);
371 
        leadActivity.setRemark(remark);
372 
        leadActivity.setLeadId(id);
34394 tejus.loha 373 
        leadActivity.setOutletName(lead.getOutLetName());
374 
        leadActivity.setPotential(lead.getPotential());
31677 amit.gupta 375 
        leadActivity.setCreatedTimestamp(LocalDateTime.now());
376 
        leadActivity.setSchelduleTimestamp(null);
377 
        leadActivity.setClosureTimestamp(null);
378 
        leadActivity.setAuthId(lead.getAssignTo());
379 
        lead.setUpdatedTimestamp(LocalDateTime.now());
380 
        if (colorCheck == true) {
381 
            lead.setColor("Green");
382 
        } else {
383 
            lead.setColor("Yellow");
384 
        }
385 
        if (status == LeadStatus.followUp) {
25899 tejbeer 386 
 
31677 amit.gupta 387 
            if (schelduleTimestamp != null) {
31249 tejbeer 388 
 
31677 amit.gupta 389 
                leadActivity.setCommunicationType(communicationType);
31249 tejbeer 390 
 
31677 amit.gupta 391 
                if (leadActivity.getCommunicationType().equals(CommunicationType.VISIT)) {
31249 tejbeer 392 
 
35079 vikas 393 
                    visitRequestRepository.createVisitRequest(lead.getId(), "lead", lead.getAssignTo(), schelduleTimestamp);
31677 amit.gupta 394 
                }
31249 tejbeer 395 
 
31677 amit.gupta 396 
            }
397 
            leadActivity.setSchelduleTimestamp(schelduleTimestamp);
398 
            leadActivity.setClosureTimestamp(closureTimestamp);
399 
            lead.setClosureTimestamp(closureTimestamp);
26250 tejbeer 400 
 
31677 amit.gupta 401 
        } else {
26250 tejbeer 402 
 
31677 amit.gupta 403 
            leadActivity.setSchelduleTimestamp(null);
404 
            leadActivity.setClosureTimestamp(null);
405 
            lead.setClosureTimestamp(null);
26244 tejbeer 406 
 
31677 amit.gupta 407 
        }
408 
        leadActivityRepository.persist(leadActivity);
409 
        return responseSender.ok(true);
25899 tejbeer 410 
 
31677 amit.gupta 411 
    }
25952 tejbeer 412 
 
31677 amit.gupta 413 
    @RequestMapping(value = ProfitMandiConstants.URL_NEW_LEAD, method = RequestMethod.POST)
35288 amit 414 
    public ResponseEntity<?> newLead(HttpServletRequest request, @RequestBody CreateRefferalRequest
415 
            createRefferalRequest) throws ProfitMandiBusinessException {
31677 amit.gupta 416 
        LOGGER.info("requested url : " + request.getRequestURL().toString());
417 
        Lead lead = new Lead();
418 
        lead.setAddress(createRefferalRequest.getCity());
419 
        Long.parseLong(createRefferalRequest.getMobile());
420 
        if (createRefferalRequest.getMobile().length() != 10) {
35079 vikas 421 
            throw new ProfitMandiBusinessException("Mobile Number", createRefferalRequest.getMobile(), "Number should be of 10 digits");
31677 amit.gupta 422 
        }
423 
        lead.setLeadMobile(createRefferalRequest.getMobile());
424 
        lead.setCity(createRefferalRequest.getCity());
425 
        lead.setState(createRefferalRequest.getState());
426 
        lead.setLastName(createRefferalRequest.getLastName());
427 
        if (lead.getState().equals("Uttar Pradesh")) {
428 
            lead.setAssignTo(53);
429 
        } else if (lead.getState().equals("Haryana")) {
430 
            lead.setAssignTo(53);
431 
        } else if (lead.getState().equals("Delhi")) {
432 
            lead.setAssignTo(53);
433 
        } else {
434 
            // Assign to sm
435 
            lead.setAssignTo(53);
436 
            // Assign to neha
437 
            // lead.setAssignTo(1);
438 
        }
439 
        lead.setAuthId(lead.getAssignTo());
440 
        lead.setCreatedBy("daily-sync");
441 
        lead.setSource("SD-WEB");
442 
        lead.setFirstName(createRefferalRequest.getFirstName());
443 
        lead.setStatus(LeadStatus.followUp);
444 
        lead.setColor("yellow");
445 
        lead.setCreatedTimestamp(LocalDateTime.now());
446 
        lead.setUpdatedTimestamp(LocalDateTime.now());
447 
        leadRepository.persist(lead);
27117 tejbeer 448 
 
31677 amit.gupta 449 
        return responseSender.ok(true);
27117 tejbeer 450 
 
31677 amit.gupta 451 
    }
27117 tejbeer 452 
 
31677 amit.gupta 453 
    @RequestMapping(value = "/getPartnersList", method = RequestMethod.GET)
35079 vikas 454 
    @ApiImplicitParams({@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header")})
31677 amit.gupta 455 
    public ResponseEntity<?> getPartners(HttpServletRequest request, @RequestParam(name = "gmailId") String gmailId)
456 
            throws ProfitMandiBusinessException {
25952 tejbeer 457 
 
31677 amit.gupta 458 
        AuthUser authUser = authRepository.selectByGmailId(gmailId);
35630 aman 459 
        if (authUser == null) {
460 
            LOGGER.warn("No auth user found for gmailId: {}", gmailId);
461 
            return responseSender.badRequest("No user found for the provided email");
462 
        }
25952 tejbeer 463 
 
31677 amit.gupta 464 
        Map<String, Set<String>> storeGuyMap = csService.getAuthUserPartnerEmailMapping();
25952 tejbeer 465 
 
31677 amit.gupta 466 
        Set<String> emails = storeGuyMap.get(authUser.getEmailId());
35630 aman 467 
        LOGGER.info("emails: {}", emails);
468 
        if (emails == null || emails.isEmpty()) {
469 
            LOGGER.info("No partner emails found for user: {}", gmailId);
470 
            return responseSender.ok(new ArrayList<>());
471 
        }
31677 amit.gupta 472 
        List<User> users = userRepository.selectAllByEmailIds(new ArrayList<>(emails));
473 
        List<Partner> partners = new ArrayList<>();
474 
        for (User user : users) {
35630 aman 475 
            try {
476 
                UserAccount uc = userAccountRepository.selectSaholicByUserId(user.getId());
477 
                if (uc == null) {
478 
                    LOGGER.warn("No user account found for userId: {}", user.getId());
479 
                    continue;
480 
                }
481 
                com.spice.profitmandi.dao.entity.user.User userInfo = userUserRepository.selectById(uc.getAccountKey());
482 
                if (userInfo == null) {
483 
                    LOGGER.warn("No user info found for accountKey: {}", uc.getAccountKey());
484 
                    continue;
485 
                }
486 
                CustomRetailer customRetailer = retailerService.getFofoRetailer(userInfo.getId());
487 
                if (customRetailer == null) {
488 
                    LOGGER.warn("No custom retailer found for userInfoId: {}", userInfo.getId());
489 
                    continue;
490 
                }
25952 tejbeer 491 
 
35630 aman 492 
                Partner partner = new Partner();
493 
                partner.setBusinessName(customRetailer.getBusinessName());
494 
                partner.setPartnerId(customRetailer.getPartnerId());
495 
                partner.setCartId(customRetailer.getCartId());
496 
                partner.setEmail(customRetailer.getEmail());
497 
                partner.setGstNumber(customRetailer.getGstNumber());
498 
                partner.setDisplayName(customRetailer.getDisplayName());
499 
                partner.setCity(customRetailer.getAddress() != null ? customRetailer.getAddress().getCity() : null);
500 
                partner.setUserId(user.getId());
501 
                partners.add(partner);
502 
            } catch (Exception e) {
503 
                LOGGER.error("Error processing partner for userId: {}", user.getId(), e);
504 
            }
31677 amit.gupta 505 
        }
35630 aman 506 
        LOGGER.info("partners: {}", partners);
31677 amit.gupta 507 
        return responseSender.ok(partners);
508 
    }
25952 tejbeer 509 
 
31677 amit.gupta 510 
    @RequestMapping(value = "/franchise-first-visit", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_VALUE)
35079 vikas 511 
    @ApiImplicitParams({@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header")})
35288 amit 512 
    public ResponseEntity<?> FranchiseFirstVisit(HttpServletRequest request, @RequestBody CreateFranchiseeRequest
513 
            createFranchiseeRequest) throws Exception {
25952 tejbeer 514 
 
31677 amit.gupta 515 
        FranchiseeVisit franchiseeVisit = new FranchiseeVisit();
516 
        franchiseeVisit.setFofoId(createFranchiseeRequest.getFofoId());
517 
        CustomRetailer customRetailer = retailerService.getFofoRetailer(createFranchiseeRequest.getFofoId());
25952 tejbeer 518 
 
31677 amit.gupta 519 
        franchiseeVisit.setPartnerName(customRetailer.getBusinessName());
520 
        franchiseeVisit.setAgenda(createFranchiseeRequest.getAgenda());
521 
        franchiseeVisit.setCreatedTimestamp(LocalDateTime.now());
522 
        franchiseeVisit.setUpdatedTimestamp(LocalDateTime.now());
523 
        franchiseeVisit.setStatus(FranchiseeVisitStatus.OPEN);
524 
        franchiseeVisit.setScheduleTimestamp(createFranchiseeRequest.getFirstSchelduleTimestamp());
525 
        // change
526 
        AuthUser authUser = authRepository.selectByGmailId(createFranchiseeRequest.getCreatedBy());
25952 tejbeer 527 
 
31677 amit.gupta 528 
        String authUserName = authUser.getFirstName() + " " + authUser.getLastName();
529 
        franchiseeVisit.setCreatedBy(authUserName);
530 
        franchiseeVisit.setAuthId(authUser.getId());
25952 tejbeer 531 
 
31677 amit.gupta 532 
        franchiseeVisitRepository.persist(franchiseeVisit);
25952 tejbeer 533 
 
31677 amit.gupta 534 
        FranchiseeActivity franchiseeActivity = new FranchiseeActivity();
535 
        franchiseeActivity.setAction(FranchiseeActivityStatus.FOLLOWUP);
536 
        franchiseeActivity.setFranchiseeVisitd(franchiseeVisit.getId());
537 
        franchiseeActivity.setResolution(createFranchiseeRequest.getResolution());
538 
        franchiseeActivity.setSchelduleTimestamp(createFranchiseeRequest.getFirstSchelduleTimestamp());
31249 tejbeer 539 
 
31677 amit.gupta 540 
        franchiseeActivity.setCreatedTimestamp(LocalDateTime.now());
541 
        franchiseeActivityRepository.persist(franchiseeActivity);
31249 tejbeer 542 
 
31677 amit.gupta 543 
        franchiseeVisit.setFranchiseActivityId(franchiseeActivity.getId());
31249 tejbeer 544 
 
35079 vikas 545 
        visitRequestRepository.createVisitRequest(franchiseeVisit.getId(), "franchiseeVisit", authUser.getId(), createFranchiseeRequest.getFirstSchelduleTimestamp());
31249 tejbeer 546 
 
31677 amit.gupta 547 
        return responseSender.ok(true);
548 
    }
25952 tejbeer 549 
 
31677 amit.gupta 550 
    @RequestMapping(value = "/franchise-visit", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_VALUE)
35079 vikas 551 
    @ApiImplicitParams({@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header")})
31677 amit.gupta 552 
    public ResponseEntity<?> FranchiseVisit(HttpServletRequest request,
553 
                                            @RequestBody CreateFranchiseeRequest createFranchiseeRequest) throws Exception {
25952 tejbeer 554 
 
34394 tejus.loha 555 
        int rbmL1 = csService.getAuthUserId(ProfitMandiConstants.TICKET_CATEGORY_RBM, EscalationType.L1, createFranchiseeRequest.getFofoId());
34276 ranu 556 
 
36677 vikas 557 
        List<FranchiseeVisit> franchiseeVisits = franchiseeVisitRepository.selectAllByFofoId(createFranchiseeRequest.getFofoId());
558 
        if (franchiseeVisits.isEmpty()) {
36661 vikas 559 
            throw new ProfitMandiBusinessException("id", createFranchiseeRequest.getId(), "Franchisee visit not found for id: " + createFranchiseeRequest.getId());
560 
        }
36677 vikas 561 
        FranchiseeVisit franchiseeVisit = franchiseeVisits.get(0);
31677 amit.gupta 562 
        franchiseeVisit.setFofoId(createFranchiseeRequest.getFofoId());
563 
        CustomRetailer customRetailer = retailerService.getFofoRetailer(createFranchiseeRequest.getFofoId());
34394 tejus.loha 564 
        LOGGER.info("rbmL1 {}", rbmL1);
31677 amit.gupta 565 
        franchiseeVisit.setPartnerName(customRetailer.getBusinessName());
566 
        franchiseeVisit.setAgenda(createFranchiseeRequest.getAgenda());
567 
        franchiseeVisit.setPartnerRemark(createFranchiseeRequest.getPartnerRemark());
568 
        franchiseeVisit.setOutsideVisibity(createFranchiseeRequest.getOutsideVisibity());
569 
        franchiseeVisit.setInstoreVisibility(createFranchiseeRequest.getInstoreVisibility());
570 
        franchiseeVisit.setOutsideStock(createFranchiseeRequest.getOutsideStock());
571 
        franchiseeVisit.setSystemKnowledge(createFranchiseeRequest.getSystemKnowledge());
572 
        franchiseeVisit.setWorkingDevice(createFranchiseeRequest.getWorkingDevice());
573 
        franchiseeVisit.setWorkingPrinter(createFranchiseeRequest.getWorkingPrinter());
574 
        franchiseeVisit.setCarryBags(createFranchiseeRequest.getCarryBags());
575 
        franchiseeVisit.setSmartdukaanTshirt(createFranchiseeRequest.getSmartdukaanTshirt());
576 
        franchiseeVisit.setLatestDummies(createFranchiseeRequest.getLatestDummies());
577 
        franchiseeVisit.setInvestment(createFranchiseeRequest.getInvestment());
578 
        franchiseeVisit.setMtd(createFranchiseeRequest.getMtd());
579 
        franchiseeVisit.setHygiene(createFranchiseeRequest.getHygiene());
580 
        franchiseeVisit.setCreatedTimestamp(LocalDateTime.now());
581 
        franchiseeVisit.setUpdatedTimestamp(LocalDateTime.now());
582 
        franchiseeVisit.setInformedAboutOnline(createFranchiseeRequest.getOnline());
583 
        franchiseeVisit.setPendingBilling(createFranchiseeRequest.getPendingBilling());
34276 ranu 584 
        franchiseeVisit.setRbmId(rbmL1);
585 
        franchiseeVisit.setRbmRating(createFranchiseeRequest.getRbmRating());
31677 amit.gupta 586 
        if (createFranchiseeRequest.getAction().equals(FranchiseeActivityStatus.FOLLOWUP)) {
587 
            franchiseeVisit.setStatus(FranchiseeVisitStatus.OPEN);
588 
        } else {
589 
            franchiseeVisit.setStatus(FranchiseeVisitStatus.CLOSE);
590 
        }
25952 tejbeer 591 
 
31677 amit.gupta 592 
        // AuthUser authUser =
593 
        // authRepository.selectByGmailId(createFranchiseeRequest.getCreatedBy());
594 
        // change
595 
        AuthUser authUser = authRepository.selectByGmailId(createFranchiseeRequest.getCreatedBy());
25952 tejbeer 596 
 
31677 amit.gupta 597 
        String authUserName = authUser.getFirstName() + " " + authUser.getLastName();
598 
        franchiseeVisit.setCreatedBy(authUserName);
599 
        franchiseeVisit.setAuthId(authUser.getId());
25952 tejbeer 600 
 
31677 amit.gupta 601 
        franchiseeVisitRepository.persist(franchiseeVisit);
25952 tejbeer 602 
 
31677 amit.gupta 603 
        FranchiseeActivity franchiseeActivity = new FranchiseeActivity();
604 
        franchiseeActivity.setAction(createFranchiseeRequest.getAction());
605 
        franchiseeActivity.setFranchiseeVisitd(franchiseeVisit.getId());
606 
        franchiseeActivity.setResolution(createFranchiseeRequest.getResolution());
607 
        if (createFranchiseeRequest.getAction().equals(FranchiseeActivityStatus.FOLLOWUP)) {
608 
            franchiseeActivity.setSchelduleTimestamp(createFranchiseeRequest.getSchelduleTimestamp());
31249 tejbeer 609 
 
31677 amit.gupta 610 
            visitRequestRepository.createVisitRequest(franchiseeVisit.getId(), "franchiseeVisit",
611 
                    franchiseeVisit.getAuthId(), createFranchiseeRequest.getSchelduleTimestamp());
612 
        } else {
613 
            franchiseeActivity.setSchelduleTimestamp(null);
614 
        }
615 
        franchiseeActivity.setCreatedTimestamp(LocalDateTime.now());
616 
        franchiseeActivityRepository.persist(franchiseeActivity);
25952 tejbeer 617 
 
31677 amit.gupta 618 
        franchiseeVisit.setFranchiseActivityId(franchiseeActivity.getId());
34276 ranu 619 
 
34394 tejus.loha 620 
        if (!createFranchiseeRequest.getOutsideVisibityReason().isEmpty()) {
34288 ranu 621 
            csService.createTicket(createFranchiseeRequest.getFofoId(), ProfitMandiConstants.TICKET_CATEGORY_DESIGN, ProfitMandiConstants.TICKET_CATEGORY_DESIGNING_BRANDING_EXTERNAL_VISIBILITY, createFranchiseeRequest.getOutsideVisibityReason(), authUser.getId());
34276 ranu 622 
        }
623 
 
34394 tejus.loha 624 
        if (!createFranchiseeRequest.getInstoreVisibilityReason().isEmpty()) {
34288 ranu 625 
            csService.createTicket(createFranchiseeRequest.getFofoId(), ProfitMandiConstants.TICKET_CATEGORY_DESIGN, ProfitMandiConstants.TICKET_CATEGORY_DESIGNING_BRANDING_INTERNAL_VISIBILITY, createFranchiseeRequest.getInstoreVisibilityReason(), authUser.getId());
34276 ranu 626 
        }
627 
 
34394 tejus.loha 628 
        if (!createFranchiseeRequest.getOutsideStockReason().isEmpty()) {
34288 ranu 629 
            csService.createTicket(createFranchiseeRequest.getFofoId(), ProfitMandiConstants.TICKET_CATEGORY_SALES, ProfitMandiConstants.TICKET_CATEGORY_SALES_OUTSIDE_STOCK, createFranchiseeRequest.getOutsideStockReason(), authUser.getId());
34276 ranu 630 
        }
631 
 
34394 tejus.loha 632 
        if (!createFranchiseeRequest.getSystemKnowledgeReason().isEmpty()) {
34288 ranu 633 
            csService.createTicket(createFranchiseeRequest.getFofoId(), ProfitMandiConstants.TICKET_CATEGORY_TRAINING, ProfitMandiConstants.TICKET_CATEGORY_TRAINING_NEED, createFranchiseeRequest.getSystemKnowledgeReason(), authUser.getId());
34276 ranu 634 
        }
635 
 
34394 tejus.loha 636 
        if (!createFranchiseeRequest.getLatestDummiesReason().isEmpty()) {
34288 ranu 637 
            csService.createTicket(createFranchiseeRequest.getFofoId(), ProfitMandiConstants.TICKET_CATEGORY_MARKETING, ProfitMandiConstants.TICKET_CATEGORY_MARKETING_DUMMIES, createFranchiseeRequest.getLatestDummiesReason(), authUser.getId());
34276 ranu 638 
        }
639 
 
34394 tejus.loha 640 
        if (!createFranchiseeRequest.getInvestmentReason().isEmpty()) {
34288 ranu 641 
            csService.createTicket(createFranchiseeRequest.getFofoId(), ProfitMandiConstants.TICKET_CATEGORY_SALES, ProfitMandiConstants.TICKET_CATEGORY_SALES_LOW_INVESTMENT, createFranchiseeRequest.getInvestmentReason(), authUser.getId());
34276 ranu 642 
        }
643 
 
34394 tejus.loha 644 
        if (!createFranchiseeRequest.getHygieneReason().isEmpty()) {
34288 ranu 645 
            csService.createTicket(createFranchiseeRequest.getFofoId(), ProfitMandiConstants.TICKET_CATEGORY_SALES, ProfitMandiConstants.TICKET_CATEGORY_SALES_LOW_DATA_ACCURACY, createFranchiseeRequest.getHygieneReason(), authUser.getId());
646 
        }
34276 ranu 647 
 
31677 amit.gupta 648 
        return responseSender.ok(true);
34276 ranu 649 
 
31677 amit.gupta 650 
    }
25952 tejbeer 651 
 
31677 amit.gupta 652 
    @RequestMapping(value = "/getFranchiseVisit", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
35079 vikas 653 
    @ApiImplicitParams({@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header")})
31677 amit.gupta 654 
    public ResponseEntity<?> getFranchiseVisit(HttpServletRequest request,
35288 amit 655 
                                               @RequestParam(name = "gmailId") String gmailId, @RequestParam(name = "status") FranchiseeVisitStatus
656 
                                                       status,
31677 amit.gupta 657 
                                               @RequestParam(name = "offset", defaultValue = "0") int offset,
658 
                                               @RequestParam(name = "limit", defaultValue = "10") int limit) throws ProfitMandiBusinessException {
659 
        AuthUser authUser = authRepository.selectByGmailId(gmailId);
35079 vikas 660 
        List<VisitRequest> visitRequests = visitRequestRepository.selectByAuthIdAndDate(authUser.getId(), LocalDate.now());
31677 amit.gupta 661 
        Map<Integer, List<VisitRequest>> visitRequestMap = null;
662 
        if (!visitRequests.isEmpty()) {
663 
            visitRequestMap = visitRequests.stream().collect(Collectors.groupingBy(x -> x.getVisitId()));
664 
        }
35079 vikas 665 
        List<FranchiseeVisit> franchiseeVisits = franchiseeVisitRepository.selectByAuthIdAndStatus(authUser.getId(), status, offset, limit);
25952 tejbeer 666 
 
35415 amit 667 
        // Batch fetch all FranchiseeActivity in one query instead of N+1
668 
        List<Integer> activityIds = franchiseeVisits.stream()
669 
                .filter(fv -> fv.getFranchiseActivityId() != 0)
670 
                .map(FranchiseeVisit::getFranchiseActivityId)
671 
                .collect(Collectors.toList());
672 
        Map<Integer, FranchiseeActivity> activityMap = new HashMap<>();
673 
        if (!activityIds.isEmpty()) {
674 
            activityMap = franchiseeActivityRepository.selectByIds(activityIds).stream()
675 
                    .collect(Collectors.toMap(FranchiseeActivity::getId, x -> x));
676 
        }
677 
 
31677 amit.gupta 678 
        for (FranchiseeVisit fv : franchiseeVisits) {
679 
            if (visitRequestMap != null) {
31249 tejbeer 680 
 
31677 amit.gupta 681 
                List<VisitRequest> visitRequest = visitRequestMap.get(fv.getId());
682 
                if (visitRequest != null) {
683 
                    if (visitRequest.size() > 1) {
31249 tejbeer 684 
 
35079 vikas 685 
                        Comparator<VisitRequest> visitComparato = Comparator.comparing(VisitRequest::getCreatedTimestamp);
31249 tejbeer 686 
 
31677 amit.gupta 687 
                        VisitRequest youngestVisit = visitRequest.stream().max(visitComparato).get();
688 
                        fv.setVisitStatus(youngestVisit.getStatus());
31249 tejbeer 689 
 
31677 amit.gupta 690 
                    } else {
691 
                        fv.setVisitStatus(visitRequest.get(0).getStatus());
31249 tejbeer 692 
 
31677 amit.gupta 693 
                    }
694 
                }
695 
            }
696 
            if (fv.getFranchiseActivityId() != 0) {
35415 amit 697 
                FranchiseeActivity fA = activityMap.get(fv.getFranchiseActivityId());
31677 amit.gupta 698 
                fv.setFranchiseeActivity(fA);
699 
            }
31249 tejbeer 700 
 
31677 amit.gupta 701 
        }
25952 tejbeer 702 
 
31677 amit.gupta 703 
        return responseSender.ok(franchiseeVisits);
25952 tejbeer 704 
 
31677 amit.gupta 705 
    }
25952 tejbeer 706 
 
31677 amit.gupta 707 
    @RequestMapping(value = "/getFranchiseActivity", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
35079 vikas 708 
    @ApiImplicitParams({@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header")})
35288 amit 709 
    public ResponseEntity<?> getFranchiseActivity(HttpServletRequest request, @RequestParam(name = "id") int id) throws
710 
            ProfitMandiBusinessException {
25952 tejbeer 711 
 
31677 amit.gupta 712 
        List<FranchiseeActivity> franchiseeActivities = franchiseeActivityRepository.selectByFranchiseeVisitId(id);
713 
        return responseSender.ok(franchiseeActivities);
25952 tejbeer 714 
 
31677 amit.gupta 715 
    }
25952 tejbeer 716 
 
31677 amit.gupta 717 
    @RequestMapping(value = "/getFranchiseeInfo", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
35079 vikas 718 
    @ApiImplicitParams({@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header")})
35288 amit 719 
    public ResponseEntity<?> getFranchiseeInfo(HttpServletRequest request, @RequestParam(name = "id") int id) throws
720 
            ProfitMandiBusinessException {
36678 vikas 721 
        FranchiseeVisit franchiseeVisit;
722 
        if (String.valueOf(id).length() < 9) {
723 
            franchiseeVisit = franchiseeVisitRepository.selectById(id);
724 
        } else {
725 
            List<FranchiseeVisit> franchiseeVisits = franchiseeVisitRepository.selectAllByFofoId(id);
36722 vikas 726 
            if (franchiseeVisits.isEmpty()) {
727 
                return responseSender.ok(null);
728 
            }
36678 vikas 729 
            franchiseeVisit = franchiseeVisits.get(0);
730 
        }
25952 tejbeer 731 
 
31677 amit.gupta 732 
        List<DBObject> mobileBrands = mongoClient.getAllBrandsToDisplay(3);
30487 tejbeer 733 
 
31677 amit.gupta 734 
        List<String> brands = mobileBrands.stream().filter(x -> (boolean) x.get("active"))
735 
                .map(x -> (String) x.get("name")).collect(Collectors.toList());
30487 tejbeer 736 
 
31677 amit.gupta 737 
        franchiseeVisit.setBrands(brands);
30487 tejbeer 738 
 
31677 amit.gupta 739 
        return responseSender.ok(franchiseeVisit);
25952 tejbeer 740 
 
31677 amit.gupta 741 
    }
25952 tejbeer 742 
 
31677 amit.gupta 743 
    @RequestMapping(value = "/franchise-visit-update", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_VALUE)
35079 vikas 744 
    @ApiImplicitParams({@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header")})
35288 amit 745 
    public ResponseEntity<?> franchiseVisitUpdate(HttpServletRequest request, @RequestParam(name = "id") int id,
746 
                                                  @RequestParam(name = "action") FranchiseeActivityStatus action,
747 
                                                  @RequestParam(name = "resolution") String resolution,
748 
                                                  @RequestParam(name = "schelduleTimestamp") @DateTimeFormat(iso = DateTimeFormat.ISO.DATE_TIME) LocalDateTime schelduleTimestamp)
31677 amit.gupta 749 
            throws ProfitMandiBusinessException {
750 
        FranchiseeVisit franchiseeVisit = franchiseeVisitRepository.selectById(id);
25952 tejbeer 751 
 
31677 amit.gupta 752 
        FranchiseeActivity franchiseeActivity = new FranchiseeActivity();
25952 tejbeer 753 
 
31677 amit.gupta 754 
        if (action == FranchiseeActivityStatus.FOLLOWUP) {
30487 tejbeer 755 
 
31677 amit.gupta 756 
            if (schelduleTimestamp != null) {
31249 tejbeer 757 
 
31677 amit.gupta 758 
                visitRequestRepository.createVisitRequest(franchiseeVisit.getId(), "franchiseeVisit",
759 
                        franchiseeVisit.getAuthId(), schelduleTimestamp);
760 
            }
31249 tejbeer 761 
 
31677 amit.gupta 762 
            franchiseeActivity.setSchelduleTimestamp(schelduleTimestamp);
763 
            franchiseeVisit.setStatus(FranchiseeVisitStatus.OPEN);
764 
            franchiseeVisit.setUpdatedTimestamp(LocalDateTime.now());
765 
            franchiseeVisitRepository.persist(franchiseeVisit);
25952 tejbeer 766 
 
31677 amit.gupta 767 
        } else {
30487 tejbeer 768 
 
31677 amit.gupta 769 
            franchiseeActivity.setSchelduleTimestamp(null);
770 
            franchiseeVisit.setFranchiseActivityId(franchiseeActivity.getId());
771 
            franchiseeVisit.setStatus(FranchiseeVisitStatus.CLOSE);
772 
            franchiseeVisit.setUpdatedTimestamp(LocalDateTime.now());
773 
            franchiseeVisitRepository.persist(franchiseeVisit);
25952 tejbeer 774 
 
31677 amit.gupta 775 
        }
25952 tejbeer 776 
 
31677 amit.gupta 777 
        franchiseeActivity.setResolution(resolution);
778 
        franchiseeActivity.setFranchiseeVisitd(franchiseeVisit.getId());
779 
        franchiseeActivity.setAction(action);
30487 tejbeer 780 
 
31677 amit.gupta 781 
        franchiseeActivity.setCreatedTimestamp(LocalDateTime.now());
782 
        franchiseeActivityRepository.persist(franchiseeActivity);
30487 tejbeer 783 
 
31677 amit.gupta 784 
        franchiseeVisit.setFranchiseActivityId(franchiseeActivity.getId());
785 
        franchiseeVisit.setStatus(FranchiseeVisitStatus.OPEN);
786 
        franchiseeVisit.setUpdatedTimestamp(LocalDateTime.now());
787 
        franchiseeVisitRepository.persist(franchiseeVisit);
30487 tejbeer 788 
 
31677 amit.gupta 789 
        return responseSender.ok(true);
25952 tejbeer 790 
 
31677 amit.gupta 791 
    }
28935 tejbeer 792 
 
31677 amit.gupta 793 
    @RequestMapping(value = "/onBoardingTimelineStatus", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
35079 vikas 794 
    @ApiImplicitParams({@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header")})
31677 amit.gupta 795 
    public ResponseEntity<?> onBoardingTimelineStatus(HttpServletRequest request, Model model)
796 
            throws ProfitMandiBusinessException {
35075 aman 797 
        //This userId is of dtr.users
31677 amit.gupta 798 
        int userId = (int) request.getAttribute("userId");
35075 aman 799 
 
800 
        //UserCart contains userId/retailerId in context of user.user as
801 
        //uc contains retailerId and cartId of the retailerId that belongs to user schema
31677 amit.gupta 802 
        UserCart uc = userAccountRepository.getUserCart(userId);
803 
        FofoStore fs = fofoStoreRepository.selectByRetailerId(uc.getUserId());
804 
        PartnerOnBoardingPanel partnerOnBoardingPanel = partnerOnBoardingPanelRepository.selectByCode(fs.getCode());
805 
        Map<StoreTimeline, OnBoardingTimelineModel> timelineStatus = null;
806 
        LOGGER.info("partnerOnBoardingPanel" + partnerOnBoardingPanel);
807 
        if (partnerOnBoardingPanel != null) {
28935 tejbeer 808 
 
31677 amit.gupta 809 
            timelineStatus = storeTimelineTatService.getTimeline(partnerOnBoardingPanel.getId());
810 
        }
811 
        List<OnBoardingTimelineModel> onBoardingModel = new ArrayList<>();
812 
        if (timelineStatus != null) {
813 
            onBoardingModel = timelineStatus.values().stream().skip(2).map(x -> x).collect(Collectors.toList());
814 
        }
815 
        return responseSender.ok(onBoardingModel);
28935 tejbeer 816 
 
31677 amit.gupta 817 
    }
35288 amit 818 
 
35075 aman 819 
    @RequestMapping(value = "/purchaseExist", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
820 
    @ApiImplicitParams({
821 
            @ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header")})
35415 amit 822 
    public ResponseEntity<?> purchaseExist(HttpServletRequest request) throws ProfitMandiBusinessException {
35075 aman 823 
        int userId = (int) request.getAttribute("userId");
824 
        UserCart uc = userAccountRepository.getUserCart(userId);
35415 amit 825 
        return responseSender.ok(purchaseRepository.hasPurchaseForFofoId(uc.getUserId()));
35075 aman 826 
    }
35288 amit 827 
 
31677 amit.gupta 828 
    @RequestMapping(value = "/onBoardingTimelineVisibility", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
35079 vikas 829 
    @ApiImplicitParams({@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header")})
31677 amit.gupta 830 
    public ResponseEntity<?> onBoardingTimelineVisibility(HttpServletRequest request, Model model)
831 
            throws ProfitMandiBusinessException {
832 
        int userId = (int) request.getAttribute("userId");
833 
        UserCart uc = userAccountRepository.getUserCart(userId);
28982 tejbeer 834 
 
31677 amit.gupta 835 
        FofoStore fs = fofoStoreRepository.selectByRetailerId(uc.getUserId());
836 
        PartnerOnBoardingPanel partnerOnBoardingPanel = partnerOnBoardingPanelRepository.selectByCode(fs.getCode());
837 
        boolean status = true;
838 
        if (partnerOnBoardingPanel != null) {
28982 tejbeer 839 
 
31677 amit.gupta 840 
            status = storeTimelineTatService.getTimelineCompleted(partnerOnBoardingPanel.getId());
841 
        }
28982 tejbeer 842 
 
31677 amit.gupta 843 
        LOGGER.info("status" + status);
28983 tejbeer 844 
 
31677 amit.gupta 845 
        return responseSender.ok(status);
28982 tejbeer 846 
 
31677 amit.gupta 847 
    }
30077 tejbeer 848 
 
31677 amit.gupta 849 
    @RequestMapping(value = "/getPartnerTarget", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
35079 vikas 850 
    @ApiImplicitParams({@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header")})
35288 amit 851 
    public ResponseEntity<?> getPartnerTarget(HttpServletRequest request, @RequestParam String
852 
            gmailId, @RequestParam String dayValue, @RequestParam ActivationType activationType) throws
853 
            ProfitMandiBusinessException {
30077 tejbeer 854 
 
35632 ranu 855 
        long startTime = System.currentTimeMillis();
856 
        long lapTime = startTime;
857 
 
31677 amit.gupta 858 
        AuthUser authUser = authRepository.selectByGmailId(gmailId);
35632 ranu 859 
 
35649 ranu 860 
        Map<String, Set<Integer>> storeGuyMap = csService.getAuthUserPartnerIdMapping();
861 
        Set<Integer> fofoIds = storeGuyMap.get(authUser.getEmailId());
31677 amit.gupta 862 
        List<String> brands = Arrays.asList("Vivo", "Samsung", "Oppo", "Itel", "Almost New", "Others");
30078 tejbeer 863 
 
35649 ranu 864 
 
31677 amit.gupta 865 
        float totalPartnerTargetSecondary = 0;
866 
        float totalPartnerTargetCollection = 0;
867 
        float totalPartnerAchievementSecondary = 0;
868 
        float totalPartnerAchievementCollection = 0;
869 
        TargetModel tm = new TargetModel();
870 
        Map<Integer, PartnerDailyInvestment> partnerDailyInvestmentMap = new HashMap<>();
35632 ranu 871 
        Map<Integer, Long> partnerTicketCount = new HashMap<>(); // Will be populated after we have fofoIdList
30416 tejbeer 872 
 
31677 amit.gupta 873 
        List<PartnerTargetAchievementModel> ptams = new ArrayList<>();
30077 tejbeer 874 
 
31677 amit.gupta 875 
        if (fofoIds != null && fofoIds.size() > 0) {
32737 amit.gupta 876 
            LOGGER.info("fofoIds {}", fofoIds);
31727 amit.gupta 877 
            List<Integer> fofoIdList = fofoStoreRepository.selectByRetailerIds(new ArrayList<>(fofoIds)).stream()
31677 amit.gupta 878 
                    .filter(x -> (!x.isInternal() && (activationType == null || x.getActivationType().equals(activationType))))
879 
                    .map(x -> x.getId()).collect(Collectors.toList());
35632 ranu 880 
            LOGGER.info("PERF: selectByRetailerIds took {} ms", System.currentTimeMillis() - lapTime);
881 
            lapTime = System.currentTimeMillis();
882 
            LOGGER.info("fofoIdList size: {}", fofoIdList.size());
883 
 
884 
            // Optimized: fetch ticket counts only for specific fofoIds instead of all retailers
885 
            if (!fofoIdList.isEmpty()) {
886 
                partnerTicketCount = ticketRepository.selectOpenTicketsCountByFofoIds(fofoIdList);
887 
            }
888 
            LOGGER.info("PERF: selectOpenTicketsCountByFofoIds took {} ms", System.currentTimeMillis() - lapTime);
889 
            lapTime = System.currentTimeMillis();
31677 amit.gupta 890 
            LocalDateTime startDate = LocalDate.now().atStartOfDay();
30077 tejbeer 891 
 
31677 amit.gupta 892 
            if (dayValue.equals("previous")) {
893 
                startDate = LocalDate.now().minusDays(1).atStartOfDay();
30138 tejbeer 894 
 
31677 amit.gupta 895 
            }
30087 tejbeer 896 
 
31686 amit.gupta 897 
            if (fofoIdList.size() > 0) {
30453 tejbeer 898 
 
35632 ranu 899 
                // Fetch fofoIds with overdue loans (pending amount > 0 and created > 15 days ago)
900 
                // Optimized: returns only fofoIds, not full Loan objects
901 
                LocalDateTime fifteenDaysAgo = LocalDate.now().minusDays(15).atStartOfDay();
902 
                Set<Integer> fofoIdsWithOverdueLoans = loanRepository.selectFofoIdsWithOverdueLoans(fofoIdList, fifteenDaysAgo);
903 
                LOGGER.info("PERF: selectFofoIdsWithOverdueLoans took {} ms", System.currentTimeMillis() - lapTime);
904 
                lapTime = System.currentTimeMillis();
905 
 
906 
                // Fetch fofoIds with MTD billing above threshold (20000)
907 
                // Optimized: direct query on orders table instead of complex RBM query
908 
                LocalDateTime mtdStartDate = LocalDate.now().withDayOfMonth(1).atStartOfDay();
909 
                LocalDateTime mtdEndDate = LocalDate.now().plusDays(1).atStartOfDay();
35650 ranu 910 
                long billingThreshold = 1000L; // Same as RbmWeeklyBillingModel.BILLING_THRESHOLD
35632 ranu 911 
                Set<Integer> allMtdBilledFofoIds = orderRepository.selectFofoIdsWithMtdBillingAboveThreshold(
912 
                        fofoIdList, mtdStartDate, mtdEndDate, billingThreshold);
913 
                LOGGER.info("PERF: selectFofoIdsWithMtdBillingAboveThreshold took {} ms", System.currentTimeMillis() - lapTime);
914 
                lapTime = System.currentTimeMillis();
915 
 
35079 vikas 916 
                List<PartnerDailyInvestment> partnerDailyInvestments = partnerDailyInvestmentRepository.selectAll(fofoIdList, startDate.toLocalDate().minusDays(1));
35632 ranu 917 
                LOGGER.info("PERF: partnerDailyInvestmentRepository.selectAll took {} ms", System.currentTimeMillis() - lapTime);
918 
                lapTime = System.currentTimeMillis();
30087 tejbeer 919 
 
31686 amit.gupta 920 
                if (!partnerDailyInvestments.isEmpty()) {
35079 vikas 921 
                    partnerDailyInvestmentMap = partnerDailyInvestments.stream().collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
31686 amit.gupta 922 
                }
30077 tejbeer 923 
 
35632 ranu 924 
                // Optimized: fetch only specific fofoIds instead of all retailers
925 
                Map<Integer, CustomRetailer> customRetailers = retailerService.getFofoRetailers(fofoIdList);
926 
                LOGGER.info("PERF: getFofoRetailers took {} ms", System.currentTimeMillis() - lapTime);
927 
                lapTime = System.currentTimeMillis();
30426 tejbeer 928 
 
31686 amit.gupta 929 
                List<Integer> remarkIds = partnerCollectionRemarkRepository.selectMaxRemarkId(fofoIdList);
35632 ranu 930 
                LOGGER.info("PERF: selectMaxRemarkId took {} ms", System.currentTimeMillis() - lapTime);
931 
                lapTime = System.currentTimeMillis();
30453 tejbeer 932 
 
31686 amit.gupta 933 
                long todayCollectionCount = 0;
934 
                if (!remarkIds.isEmpty()) {
935 
                    todayCollectionCount = partnerCollectionRemarkRepository
936 
                            .selectByAuthIdAndIds(authUser.getId(), remarkIds).stream()
937 
                            .filter(x -> x.getCreateTimestamp().toLocalDate().equals(LocalDate.now()))
938 
                            .collect(Collectors.counting());
30453 tejbeer 939 
 
31686 amit.gupta 940 
                }
35632 ranu 941 
                LOGGER.info("PERF: selectByAuthIdAndIds took {} ms", System.currentTimeMillis() - lapTime);
942 
                lapTime = System.currentTimeMillis();
30330 tejbeer 943 
 
35079 vikas 944 
                Map<Integer, PartnerCollectionPlanModel> collectionMap = partnerCollectionService.getCollectionMap(fofoIdList, startDate);
35632 ranu 945 
                LOGGER.info("PERF: getCollectionMap took {} ms", System.currentTimeMillis() - lapTime);
946 
                lapTime = System.currentTimeMillis();
30077 tejbeer 947 
 
32978 amit.gupta 948 
                Map<Integer, List<PartnerSecondaryPlanModel>> partnerSecondaryPlans = orderRepository
31686 amit.gupta 949 
                        .selectPartnerSecondaryGroupByBrand(fofoIdList, startDate.toLocalDate()).stream()
950 
                        .collect(Collectors.groupingBy(x -> x.getFofoId()));
35632 ranu 951 
                LOGGER.info("PERF: selectPartnerSecondaryGroupByBrand took {} ms", System.currentTimeMillis() - lapTime);
952 
                lapTime = System.currentTimeMillis();
30077 tejbeer 953 
 
35415 amit 954 
                // Pre-fetch all AuthUsers that might be needed (instead of N+1 queries)
955 
                Set<Integer> allAuthIds = new HashSet<>();
956 
                collectionMap.values().stream()
957 
                        .map(PartnerCollectionPlanModel::getAuthId)
958 
                        .filter(id -> id != null && id != authUser.getId())
959 
                        .forEach(allAuthIds::add);
960 
                partnerSecondaryPlans.values().stream()
961 
                        .flatMap(List::stream)
962 
                        .map(PartnerSecondaryPlanModel::getAuthId)
963 
                        .filter(id -> id != null && id != authUser.getId())
964 
                        .forEach(allAuthIds::add);
965 
                Map<Integer, AuthUser> authUserMap = new HashMap<>();
966 
                if (!allAuthIds.isEmpty()) {
967 
                    authUserMap = authRepository.selectByIds(new ArrayList<>(allAuthIds)).stream()
968 
                            .collect(Collectors.toMap(AuthUser::getId, x -> x));
969 
                }
970 
 
35968 ranu 971 
                // Fetch BM/ASM/RBM for all partners
972 
                Map<Integer, Map<String, Integer>> bmAsmRbmMap = csService.getBmAsmRbmAuthUserIdsByFofoIds(new HashSet<>(fofoIdList));
973 
                LOGGER.info("PERF: getBmAsmRbmAuthUserIdsByFofoIds took {} ms", System.currentTimeMillis() - lapTime);
974 
                lapTime = System.currentTimeMillis();
975 
 
976 
                // Collect all BM/ASM/RBM auth IDs to batch fetch AuthUser names
977 
                Set<Integer> bmAsmRbmAuthIds = bmAsmRbmMap.values().stream()
978 
                        .flatMap(m -> m.values().stream())
979 
                        .filter(id -> id != null && id > 0)
980 
                        .collect(Collectors.toSet());
981 
 
982 
                Map<Integer, AuthUser> bmAsmRbmAuthUserMap = new HashMap<>();
983 
                if (!bmAsmRbmAuthIds.isEmpty()) {
984 
                    bmAsmRbmAuthUserMap = authRepository.selectByIds(new ArrayList<>(bmAsmRbmAuthIds)).stream()
985 
                            .collect(Collectors.toMap(AuthUser::getId, x -> x, (a, b) -> a));
986 
                }
987 
                LOGGER.info("PERF: fetch BM/ASM/RBM AuthUsers took {} ms", System.currentTimeMillis() - lapTime);
988 
                lapTime = System.currentTimeMillis();
989 
 
32978 amit.gupta 990 
                LOGGER.info("partnerSecondayPlans {}", partnerSecondaryPlans);
35968 ranu 991 
                final Map<Integer, AuthUser> finalBmAsmRbmAuthUserMap = bmAsmRbmAuthUserMap;
31686 amit.gupta 992 
                for (Entry<Integer, CustomRetailer> customRetailerEntry : customRetailers.entrySet()) {
993 
                    int fofoId = customRetailerEntry.getKey();
994 
                    CustomRetailer customRetailer = customRetailerEntry.getValue();
995 
                    float totalSecondaryPlan = 0;
996 
                    float totalSecondaryAchivement = 0;
30077 tejbeer 997 
 
31686 amit.gupta 998 
                    PartnerTargetAchievementModel ptam = new PartnerTargetAchievementModel();
999 
                    ptam.setFofoId(fofoId);
1000 
                    ptam.setBusinessName(customRetailer.getBusinessName());
1001 
                    ptam.setMobile(customRetailer.getMobileNumber());
36211 ranu 1002 
                    ptam.setActivationType(customRetailer.getActivationType());
30087 tejbeer 1003 
 
35968 ranu 1004 
                    // Set ASM/RBM/BM names
1005 
                    Map<String, Integer> roleMap = bmAsmRbmMap.get(fofoId);
1006 
                    if (roleMap != null) {
1007 
                        Integer asmId = roleMap.get("ASM");
1008 
                        if (asmId != null && asmId > 0 && finalBmAsmRbmAuthUserMap.get(asmId) != null) {
1009 
                            ptam.setAsmName(finalBmAsmRbmAuthUserMap.get(asmId).getFullName());
1010 
                        }
1011 
                        Integer rbmId = roleMap.get("RBM");
1012 
                        if (rbmId != null && rbmId > 0 && finalBmAsmRbmAuthUserMap.get(rbmId) != null) {
1013 
                            ptam.setRbmName(finalBmAsmRbmAuthUserMap.get(rbmId).getFullName());
1014 
                        }
1015 
                        Integer bmId = roleMap.get("BM");
1016 
                        if (bmId != null && bmId > 0 && finalBmAsmRbmAuthUserMap.get(bmId) != null) {
1017 
                            ptam.setBmName(finalBmAsmRbmAuthUserMap.get(bmId).getFullName());
1018 
                        }
1019 
                    }
1020 
 
31686 amit.gupta 1021 
                    if (partnerDailyInvestmentMap.get(fofoId) != null) {
1022 
                        ptam.setWalletAmount(partnerDailyInvestmentMap.get(fofoId).getWalletAmount());
1023 
                        ptam.setShortInvestment(partnerDailyInvestmentMap.get(fofoId).getShortInvestment());
1024 
                    }
30808 tejbeer 1025 
 
32978 amit.gupta 1026 
                    if (collectionMap.get(fofoId) != null) {
1027 
                        PartnerCollectionPlanModel collectionPlan = collectionMap.get(fofoId);
30330 tejbeer 1028 
 
31686 amit.gupta 1029 
                        ptam.setRemark(collectionPlan.getRemark());
1030 
                        ptam.setMessage(collectionPlan.getMessage());
1031 
                        ptam.setRemarkTimestamp(collectionPlan.getRemarkTimestamp());
35632 ranu 1032 
                        ptam.setRecordingUrl(collectionPlan.getRecordingUrl());
35835 ranu 1033 
                        ptam.setScheduledCallTime(collectionPlan.getScheduledCallTime());
31686 amit.gupta 1034 
                        ptam.setRank(collectionPlan.getRank());
36267 ranu 1035 
 
1036 
                        // If remark is SALES_ESCALATION, fetch open escalation ticket activities
1037 
                        if (CollectionRemark.SALES_ESCALATION.equals(collectionPlan.getRemark())
1038 
                                || CollectionRemark.PARTIAL_RESOLVE.equals(collectionPlan.getRemark())
1039 
                                || CollectionRemark.NOT_RESOLVED.equals(collectionPlan.getRemark())) {
1040 
                            List<Ticket> openTickets = ticketRepository.selectAllOpenTicketByRetailer(fofoId);
1041 
                            for (Ticket ticket : openTickets) {
1042 
                                if (ticket.getSubCategoryId() == ProfitMandiConstants.SALES_ESCALATION) {
1043 
                                    List<Activity> activities = activityRepository.selectAll(ticket.getId());
1044 
                                    ptam.setTicketActivities(activities);
1045 
                                    break;
1046 
                                }
1047 
                            }
1048 
                        }
1049 
 
31686 amit.gupta 1050 
                        Integer authId = collectionPlan.getAuthId();
30330 tejbeer 1051 
 
31686 amit.gupta 1052 
                        Map<Integer, String> rankColorMap = ProfitMandiConstants.Rank_Color_Map;
30416 tejbeer 1053 
 
31686 amit.gupta 1054 
                        ptam.setCollectionColor(rankColorMap.get(collectionPlan.getRank()));
30077 tejbeer 1055 
 
31686 amit.gupta 1056 
                        LOGGER.info("authId" + authId);
30137 tejbeer 1057 
 
31686 amit.gupta 1058 
                        if (collectionPlan.getTargetPlan() != null && collectionPlan.getCommittedDate() != null) {
1059 
                            float targetCollection = 0;
30330 tejbeer 1060 
 
31686 amit.gupta 1061 
                            if (collectionPlan.getRank() == 2 && collectionPlan.getAchievementPlan() != null) {
1062 
                                targetCollection = collectionPlan.getTargetPlan() - collectionPlan.getAchievementPlan();
1063 
                            } else {
1064 
                                targetCollection = collectionPlan.getTargetPlan();
31677 amit.gupta 1065 
                            }
30451 tejbeer 1066 
 
31677 amit.gupta 1067 
                            if (authId != null && authId == authUser.getId()) {
31686 amit.gupta 1068 
                                if (!collectionPlan.getCommittedDate().isAfter(startDate)) {
1069 
                                    totalPartnerTargetCollection += targetCollection;
1070 
                                }
31677 amit.gupta 1071 
                            }
31686 amit.gupta 1072 
                            ptam.setCollectionTarget(targetCollection);
1073 
                            if (collectionPlan.getRank() == 2 && collectionPlan.getAchievementPlan() != null
1074 
                                    && collectionPlan.getWalletTimestamp() != null
1075 
                                    && collectionPlan.getWalletTimestamp().toLocalDate().equals(startDate.toLocalDate())) {
1076 
                                if (authId != null && authId == authUser.getId()) {
1077 
                                    totalPartnerAchievementCollection += collectionPlan.getAchievementPlan();
1078 
                                }
1079 
                                ptam.setCollectionAchievement(collectionPlan.getAchievementPlan());
1080 
                            } else if (collectionPlan.getCommittedDate().toLocalDate().isEqual(startDate.toLocalDate())
1081 
                                    && collectionPlan.getAchievementPlan() != null) {
1082 
                                if (authId != null && authId == authUser.getId()) {
1083 
                                    totalPartnerAchievementCollection += collectionPlan.getAchievementPlan();
1084 
                                }
1085 
                                ptam.setCollectionAchievement(collectionPlan.getAchievementPlan());
1086 
 
31677 amit.gupta 1087 
                            }
31686 amit.gupta 1088 
                        }
30822 tejbeer 1089 
 
31686 amit.gupta 1090 
                        if (authId != null && authId != authUser.getId()) {
35415 amit 1091 
                            ptam.setAuthUser(authUserMap.get(authId));
31686 amit.gupta 1092 
 
31677 amit.gupta 1093 
                        }
30087 tejbeer 1094 
 
31686 amit.gupta 1095 
                        if (collectionPlan.getCommittedDate() != null) {
30087 tejbeer 1096 
 
31686 amit.gupta 1097 
                            ptam.setCollectionCommitmentDate(collectionPlan.getCommittedDate().toLocalDate());
1098 
                        }
30087 tejbeer 1099 
 
31677 amit.gupta 1100 
                    }
30821 tejbeer 1101 
 
31686 amit.gupta 1102 
                    // Secondary
30077 tejbeer 1103 
 
31686 amit.gupta 1104 
                    PartnerSecondaryPlanModel otherPartnerSecondaryPlanModel = null;
1105 
                    Map<String, PartnerSecondaryPlanModel> secondaryModelMap = new HashMap<>();
32978 amit.gupta 1106 
                    if (partnerSecondaryPlans.get(fofoId) != null) {
31686 amit.gupta 1107 
                        long otherBrandSecondary = 0;
32978 amit.gupta 1108 
                        for (PartnerSecondaryPlanModel pspm : partnerSecondaryPlans.get(fofoId)) {
31686 amit.gupta 1109 
                            Integer authId = pspm.getAuthId();
1110 
                            if (!brands.contains(pspm.getBrand())) {
1111 
                                if (pspm.getAchievementPlan() != null) {
1112 
                                    otherBrandSecondary += pspm.getAchievementPlan();
1113 
                                }
1114 
                            } else {
1115 
                                otherPartnerSecondaryPlanModel = pspm;
1116 
                            }
1117 
                            if (pspm.getTargetPlan() != null) {
1118 
                                totalSecondaryPlan += pspm.getTargetPlan();
1119 
                            }
30330 tejbeer 1120 
 
31677 amit.gupta 1121 
                            if (pspm.getAchievementPlan() != null) {
31686 amit.gupta 1122 
                                totalSecondaryAchivement += pspm.getAchievementPlan();
31677 amit.gupta 1123 
                            }
30087 tejbeer 1124 
 
31686 amit.gupta 1125 
                            if (pspm.getCommittedDate() != null) {
30137 tejbeer 1126 
 
31686 amit.gupta 1127 
                                ptam.setSecondaryCommitmentDate(pspm.getCommittedDate().toLocalDate());
1128 
                            }
1129 
                            if (authId != null && authId == authUser.getId()) {
30137 tejbeer 1130 
 
31686 amit.gupta 1131 
                                if (pspm.getTargetPlan() != null && pspm.getCommittedDate() != null) {
30087 tejbeer 1132 
 
31686 amit.gupta 1133 
                                    if (pspm.getCommittedDate().isEqual(startDate)) {
1134 
                                        totalPartnerTargetSecondary += pspm.getTargetPlan();
1135 
                                    }
1136 
                                }
30087 tejbeer 1137 
 
31686 amit.gupta 1138 
                                if (pspm.getAchievementPlan() != null) {
1139 
                                    totalPartnerAchievementSecondary += pspm.getAchievementPlan();
31677 amit.gupta 1140 
                                }
31686 amit.gupta 1141 
 
31677 amit.gupta 1142 
                            }
31686 amit.gupta 1143 
                        }
1144 
                        if (otherPartnerSecondaryPlanModel != null) {
1145 
                            otherPartnerSecondaryPlanModel.setAchievementPlan(otherBrandSecondary);
1146 
                        }
32978 amit.gupta 1147 
                        secondaryModelMap = partnerSecondaryPlans.get(fofoId).stream()
31686 amit.gupta 1148 
                                .filter(x -> brands.contains(x.getBrand()))
1149 
                                .collect(Collectors.toMap(x -> x.getBrand(), x -> x));
30087 tejbeer 1150 
 
31686 amit.gupta 1151 
                        if (secondaryModelMap.containsKey("Others")) {
1152 
                            PartnerSecondaryPlanModel psp = secondaryModelMap.get("Others");
1153 
                            psp.setAchievementPlan(otherBrandSecondary);
1154 
                        } else {
35079 vikas 1155 
                            secondaryModelMap.put("Others", new PartnerSecondaryPlanModel(fofoId, "Others", (long) 0, otherBrandSecondary, authUser.getId(), null));
31686 amit.gupta 1156 
                        }
1157 
                        for (String brand : brands) {
1158 
                            if (!secondaryModelMap.containsKey(brand)) {
35079 vikas 1159 
                                secondaryModelMap.put(brand, new PartnerSecondaryPlanModel(fofoId, brand, (long) 0, (long) 0, authUser.getId(), null));
31677 amit.gupta 1160 
                            }
31686 amit.gupta 1161 
                        }
30087 tejbeer 1162 
 
31686 amit.gupta 1163 
                        for (Entry<String, PartnerSecondaryPlanModel> secondaryModelEntry : secondaryModelMap.entrySet()) {
1164 
                            Integer authId = secondaryModelEntry.getValue().getAuthId();
1165 
                            if (authId != null && authId != authUser.getId()) {
35415 amit 1166 
                                secondaryModelEntry.getValue().setAuthUser(authUserMap.get(authId));
31686 amit.gupta 1167 
                                ptam.setSecondaryColor("red");
1168 
                            }
1169 
 
31677 amit.gupta 1170 
                        }
30077 tejbeer 1171 
 
31686 amit.gupta 1172 
                        ptam.setPartnerSecondaryModel(secondaryModelMap);
1173 
                        ptam.setTotalSecondaryPlan(totalSecondaryPlan);
1174 
                        ptam.setTotalSecondaryAchievement(totalSecondaryAchivement);
1175 
                        // Secondary
1176 
 
31677 amit.gupta 1177 
                    } else {
31686 amit.gupta 1178 
                        for (String brand : brands) {
1179 
                            PartnerSecondaryPlanModel pspm = new PartnerSecondaryPlanModel();
1180 
                            pspm.setAchievementPlan((long) 0);
1181 
                            pspm.setTargetPlan((long) 0);
1182 
                            pspm.setBrand(brand);
1183 
                            pspm.setFofoId(fofoId);
1184 
                            secondaryModelMap.put(brand, pspm);
31677 amit.gupta 1185 
                        }
31686 amit.gupta 1186 
                        ptam.setPartnerSecondaryModel(secondaryModelMap);
31677 amit.gupta 1187 
                    }
30077 tejbeer 1188 
 
31686 amit.gupta 1189 
                    if (!partnerTicketCount.isEmpty()) {
1190 
                        if (partnerTicketCount.get(fofoId) != null) {
1191 
                            ptam.setTicketCount(partnerTicketCount.get(fofoId));
1192 
                        } else {
1193 
                            ptam.setTicketCount(0);
1194 
 
31677 amit.gupta 1195 
                        }
1196 
                    }
30087 tejbeer 1197 
 
35632 ranu 1198 
                    // Category Assignment Logic (Priority: PLAN_TODAY > CARRY_FORWARD > ZERO_BILLED > UNTOUCHED > NORMAL)
1199 
                    // Check if partner has credit due (loans > 15 days with pending amount) - just a flag, doesn't affect sorting
1200 
                    boolean hasCreditDue = fofoIdsWithOverdueLoans.contains(fofoId);
1201 
                    ptam.setHasOverdue(hasCreditDue);
1202 
 
1203 
                    // Default rank to 5 (Normal) if no collection plan exists
1204 
                    int rank = ptam.getRank() > 0 ? ptam.getRank() : 5;
1205 
                    boolean hasZeroBilling = !allMtdBilledFofoIds.contains(fofoId);
1206 
 
1207 
                    // Assign category based on rank (overdue is just a flag, doesn't affect category)
1208 
                    if (rank == 1) {
1209 
                        ptam.setCategory("PLAN_TODAY");
1210 
                        ptam.setCategoryPriority(1);
1211 
                    } else if (rank == 2) {
1212 
                        ptam.setCategory("CARRY_FORWARD");
1213 
                        ptam.setCategoryPriority(2);
1214 
                    } else if (hasZeroBilling && rank < 5) {
1215 
                        // Zero billed only if NOT in normal category (rank 5+)
1216 
                        // If rank is 1,2,3,4 and has zero billing, include in ZERO_BILLED
1217 
                        ptam.setCategory("ZERO_BILLED");
1218 
                        ptam.setCategoryPriority(3);
1219 
                    } else if (rank == 3) {
1220 
                        ptam.setCategory("UNTOUCHED");
1221 
                        ptam.setCategoryPriority(4);
1222 
                    } else {
1223 
                        // rank 4 (future plan) and rank 5+ (normal) go to NORMAL
1224 
                        // Also, zero billing with rank 5+ goes to NORMAL (not ZERO_BILLED)
1225 
                        ptam.setCategory("NORMAL");
1226 
                        ptam.setCategoryPriority(5);
1227 
                    }
1228 
 
31686 amit.gupta 1229 
                    ptams.add(ptam);
30077 tejbeer 1230 
 
31677 amit.gupta 1231 
                }
32923 ranu 1232 
                List<Position> positions = positionRepository.selectPositionByAuthId(authUser.getId()).stream().collect(Collectors.toList());
30077 tejbeer 1233 
 
32923 ranu 1234 
                LOGGER.info("positions {}", positions);
1235 
 
35079 vikas 1236 
                boolean isRBMAndL1 = positions.stream().anyMatch(position -> ProfitMandiConstants.TICKET_CATEGORY_RBM == position.getCategoryId() && EscalationType.L1.equals(position.getEscalationType()));
36211 ranu 1237 
                boolean isRBMAndL2 = positions.stream().anyMatch(position -> ProfitMandiConstants.TICKET_CATEGORY_RBM == position.getCategoryId() && EscalationType.L2.equals(position.getEscalationType()));
1238 
                boolean isRBMAndL3 = positions.stream().anyMatch(position -> ProfitMandiConstants.TICKET_CATEGORY_RBM == position.getCategoryId() && EscalationType.L3.equals(position.getEscalationType()));
35079 vikas 1239 
                boolean isRBMAndNotL1 = positions.stream().anyMatch(position -> ProfitMandiConstants.TICKET_CATEGORY_RBM == position.getCategoryId() && !EscalationType.L1.equals(position.getEscalationType()));
32923 ranu 1240 
 
36211 ranu 1241 
                LOGGER.info("isRBMAndL1{}, isRBMAndL2{}, isRBMAndL3{}", isRBMAndL1, isRBMAndL2, isRBMAndL3);
32923 ranu 1242 
 
35079 vikas 1243 
                boolean isSales = positions.stream().anyMatch(position -> ProfitMandiConstants.TICKET_CATEGORY_SALES == position.getCategoryId());
32923 ranu 1244 
 
31686 amit.gupta 1245 
                tm.setTotalPartnerTargetCollection(totalPartnerTargetCollection);
1246 
                tm.setTotalPartnerTargetSecondary(totalPartnerTargetSecondary);
1247 
                tm.setTotalPartnerSecondary(totalPartnerAchievementSecondary);
1248 
                tm.setTotalPartnerCollection(totalPartnerAchievementCollection);
1249 
                tm.setTodayCollectionCount((int) todayCollectionCount);
32923 ranu 1250 
                List<PartnerTargetAchievementModel> filteredPtams;
30416 tejbeer 1251 
 
32923 ranu 1252 
                if (isRBMAndL1) {
34428 ranu 1253 
                    filteredPtams = ptams;
1254 
//                    as of now all party is showing to rbm
1255 
                    /*filteredPtams = ptams.stream()
32978 amit.gupta 1256 
                            .filter(ptam -> !(CollectionRemark.RBM_L2_ESCALATION.equals(ptam.getRemark()) || CollectionRemark.SALES_ESCALATION.equals(ptam.getRemark())))
34428 ranu 1257 
                            .collect(Collectors.toList());*/
32923 ranu 1258 
                } else if (isRBMAndNotL1) {
34429 ranu 1259 
                    filteredPtams = ptams;
1260 
                    /*filteredPtams = ptams.stream()
32923 ranu 1261 
                            .filter(ptam -> !(CollectionRemark.SALES_ESCALATION.equals(ptam.getRemark())))
34429 ranu 1262 
                            .collect(Collectors.toList());*/
33041 ranu 1263 
                } else if (isSales) {
1264 
                    filteredPtams = ptams.stream()
36211 ranu 1265 
                            .filter(ptam -> !(CollectionRemark.RBM_L2_ESCALATION.equals(ptam.getRemark()) || CollectionRemark.RBM_L3_ESCALATION.equals(ptam.getRemark())))
33041 ranu 1266 
                            .collect(Collectors.toList());
32923 ranu 1267 
                } else {
1268 
                    filteredPtams = ptams;
1269 
                }
34428 ranu 1270 
                tm.setRBMAndL1(isRBMAndL1);
36211 ranu 1271 
                tm.setRBMAndL2(isRBMAndL2);
1272 
                tm.setRBMAndL3(isRBMAndL3);
34428 ranu 1273 
                tm.setRBMAndNotL1(isRBMAndNotL1);
1274 
                tm.setSales(isSales);
35632 ranu 1275 
 
1276 
                // Calculate category counts
1277 
                Map<String, Long> categoryCounts = filteredPtams.stream()
1278 
                        .collect(Collectors.groupingBy(
1279 
                                p -> p.getCategory() != null ? p.getCategory() : "NORMAL",
1280 
                                Collectors.counting()));
1281 
                // Count parties with overdue flag (independent of category)
1282 
                tm.setOverdueCount((int) filteredPtams.stream().filter(PartnerTargetAchievementModel::isHasOverdue).count());
1283 
                tm.setPlanTodayCount(categoryCounts.getOrDefault("PLAN_TODAY", 0L).intValue());
1284 
                tm.setCarryForwardCount(categoryCounts.getOrDefault("CARRY_FORWARD", 0L).intValue());
1285 
                tm.setZeroBilledCount(categoryCounts.getOrDefault("ZERO_BILLED", 0L).intValue());
1286 
                tm.setUntouchedCount(categoryCounts.getOrDefault("UNTOUCHED", 0L).intValue());
1287 
                tm.setNormalCount(categoryCounts.getOrDefault("NORMAL", 0L).intValue());
1288 
 
1289 
                // Sort by: 1) Partners with today's remark go to bottom of entire list
35835 ranu 1290 
                //          EXCEPT: NO_ANSWER/SCHEDULE_CALL with scheduledCallTime reached → comes back up
35853 ranu 1291 
                //          EXCEPT: NO_ANSWER without scheduledCallTime older than 4 hours → comes back up
35632 ranu 1292 
                //          2) Category Priority (PLAN_TODAY=1, CARRY_FORWARD=2, ZERO_BILLED=3, UNTOUCHED=4, NORMAL=5)
1293 
                //          3) Then by rank
35835 ranu 1294 
                LocalDateTime now = LocalDateTime.now();
35853 ranu 1295 
                LocalDateTime fourHoursAgo = now.minusHours(4);
34796 ranu 1296 
                tm.setTargetAchievement(filteredPtams.stream()
1297 
                        .sorted(Comparator
35632 ranu 1298 
                                .comparing((PartnerTargetAchievementModel p) -> {
1299 
                                    if (p.getRemarkTimestamp() == null) {
1300 
                                        return false; // No remark → comes first
1301 
                                    }
1302 
                                    LocalDate remarkDate = p.getRemarkTimestamp().toLocalDate();
1303 
                                    if (!remarkDate.equals(LocalDate.now())) {
1304 
                                        return false; // Not today's remark → comes first
1305 
                                    }
35835 ranu 1306 
                                    // Check if SCHEDULE_CALL or NO_ANSWER with scheduledCallTime
1307 
                                    if (CollectionRemark.SCHEDULE_CALL.equals(p.getRemark()) || CollectionRemark.NO_ANSWER.equals(p.getRemark())) {
1308 
                                        if (p.getScheduledCallTime() != null) {
1309 
                                            // Has scheduled time - come up only when scheduled time is reached
1310 
                                            if (!p.getScheduledCallTime().isAfter(now)) {
1311 
                                                return false; // Scheduled time reached → comes back up
1312 
                                            }
1313 
                                            return true; // Scheduled time not reached → stays at bottom
1314 
                                        }
35853 ranu 1315 
                                        // NO_ANSWER without scheduledCallTime - use 4 hour logic
35835 ranu 1316 
                                        if (CollectionRemark.NO_ANSWER.equals(p.getRemark())
35853 ranu 1317 
                                                && p.getRemarkTimestamp().isBefore(fourHoursAgo)) {
1318 
                                            return false; // NO_ANSWER older than 4 hours → comes back up
35835 ranu 1319 
                                        }
35632 ranu 1320 
                                    }
1321 
                                    return true; // Other today's remarks → goes to bottom
1322 
                                }) // false → comes first, true → goes to bottom
1323 
                                .thenComparing(PartnerTargetAchievementModel::getCategoryPriority)
34796 ranu 1324 
                                .thenComparing(PartnerTargetAchievementModel::getRank)
1325 
                        )
31686 amit.gupta 1326 
                        .collect(Collectors.toList()));
30416 tejbeer 1327 
 
34796 ranu 1328 
 
31677 amit.gupta 1329 
            }
30077 tejbeer 1330 
 
31677 amit.gupta 1331 
        }
35632 ranu 1332 
        LOGGER.info("PERF: Total getPartnerTarget took {} ms", System.currentTimeMillis() - startTime);
31677 amit.gupta 1333 
        return responseSender.ok(tm);
30077 tejbeer 1334 
 
31677 amit.gupta 1335 
    }
32737 amit.gupta 1336 
 
35920 ranu 1337 
    @RequestMapping(value = "/getInactivePartnerTarget", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
1338 
    @ApiImplicitParams({@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header")})
1339 
    public ResponseEntity<?> getInactivePartnerTarget(HttpServletRequest request, @RequestParam String
1340 
            gmailId, @RequestParam String dayValue, @RequestParam ActivationType activationType) throws
1341 
            ProfitMandiBusinessException {
1342 
 
1343 
        long startTime = System.currentTimeMillis();
1344 
        long lapTime = startTime;
1345 
 
1346 
        AuthUser authUser = authRepository.selectByGmailId(gmailId);
1347 
 
1348 
        Map<String, Set<Integer>> storeGuyMap = csService.getAuthUserInactivePartnerIdMapping();
1349 
        Set<Integer> fofoIds = storeGuyMap.get(authUser.getEmailId());
1350 
        List<String> brands = Arrays.asList("Vivo", "Samsung", "Oppo", "Itel", "Almost New", "Others");
1351 
 
1352 
        float totalPartnerTargetSecondary = 0;
1353 
        float totalPartnerTargetCollection = 0;
1354 
        float totalPartnerAchievementSecondary = 0;
1355 
        float totalPartnerAchievementCollection = 0;
1356 
        TargetModel tm = new TargetModel();
1357 
        Map<Integer, PartnerDailyInvestment> partnerDailyInvestmentMap = new HashMap<>();
1358 
        Map<Integer, Long> partnerTicketCount = new HashMap<>();
1359 
 
1360 
        List<PartnerTargetAchievementModel> ptams = new ArrayList<>();
1361 
 
1362 
        if (fofoIds != null && fofoIds.size() > 0) {
1363 
            LOGGER.info("fofoIds {}", fofoIds);
1364 
            // Get inactive stores for the given retailer IDs
1365 
            List<Integer> fofoIdList = fofoStoreRepository.selectByRetailerIds(new ArrayList<>(fofoIds)).stream()
1366 
                    .filter(x -> (!x.isInternal()))
1367 
                    .map(x -> x.getId()).collect(Collectors.toList());
1368 
            LOGGER.info("PERF: selectInActiveStore took {} ms", System.currentTimeMillis() - lapTime);
1369 
            lapTime = System.currentTimeMillis();
1370 
            LOGGER.info("inactive fofoIdList size: {}", fofoIdList.size());
1371 
 
1372 
            if (!fofoIdList.isEmpty()) {
1373 
                partnerTicketCount = ticketRepository.selectOpenTicketsCountByFofoIds(fofoIdList);
1374 
            }
1375 
            LOGGER.info("PERF: selectOpenTicketsCountByFofoIds took {} ms", System.currentTimeMillis() - lapTime);
1376 
            lapTime = System.currentTimeMillis();
1377 
            LocalDateTime startDate = LocalDate.now().atStartOfDay();
1378 
 
1379 
            if (dayValue.equals("previous")) {
1380 
                startDate = LocalDate.now().minusDays(1).atStartOfDay();
1381 
            }
1382 
 
1383 
            if (fofoIdList.size() > 0) {
1384 
 
1385 
                LocalDateTime fifteenDaysAgo = LocalDate.now().minusDays(15).atStartOfDay();
1386 
                Set<Integer> fofoIdsWithOverdueLoans = loanRepository.selectFofoIdsWithOverdueLoans(fofoIdList, fifteenDaysAgo);
1387 
                LOGGER.info("PERF: selectFofoIdsWithOverdueLoans took {} ms", System.currentTimeMillis() - lapTime);
1388 
                lapTime = System.currentTimeMillis();
1389 
 
1390 
                LocalDateTime mtdStartDate = LocalDate.now().withDayOfMonth(1).atStartOfDay();
1391 
                LocalDateTime mtdEndDate = LocalDate.now().plusDays(1).atStartOfDay();
1392 
                long billingThreshold = 1000L;
1393 
                Set<Integer> allMtdBilledFofoIds = orderRepository.selectFofoIdsWithMtdBillingAboveThreshold(
1394 
                        fofoIdList, mtdStartDate, mtdEndDate, billingThreshold);
1395 
                LOGGER.info("PERF: selectFofoIdsWithMtdBillingAboveThreshold took {} ms", System.currentTimeMillis() - lapTime);
1396 
                lapTime = System.currentTimeMillis();
1397 
 
1398 
                List<PartnerDailyInvestment> partnerDailyInvestments = partnerDailyInvestmentRepository.selectAll(fofoIdList, startDate.toLocalDate().minusDays(1));
1399 
                LOGGER.info("PERF: partnerDailyInvestmentRepository.selectAll took {} ms", System.currentTimeMillis() - lapTime);
1400 
                lapTime = System.currentTimeMillis();
1401 
 
1402 
                if (!partnerDailyInvestments.isEmpty()) {
1403 
                    partnerDailyInvestmentMap = partnerDailyInvestments.stream().collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
1404 
                }
1405 
 
1406 
                Map<Integer, CustomRetailer> customRetailers = retailerService.getFofoRetailers(fofoIdList);
1407 
                LOGGER.info("PERF: getFofoRetailers took {} ms", System.currentTimeMillis() - lapTime);
1408 
                lapTime = System.currentTimeMillis();
1409 
 
1410 
                List<Integer> remarkIds = partnerCollectionRemarkRepository.selectMaxRemarkId(fofoIdList);
1411 
                LOGGER.info("PERF: selectMaxRemarkId took {} ms", System.currentTimeMillis() - lapTime);
1412 
                lapTime = System.currentTimeMillis();
1413 
 
1414 
                long todayCollectionCount = 0;
1415 
                if (!remarkIds.isEmpty()) {
1416 
                    todayCollectionCount = partnerCollectionRemarkRepository
1417 
                            .selectByAuthIdAndIds(authUser.getId(), remarkIds).stream()
1418 
                            .filter(x -> x.getCreateTimestamp().toLocalDate().equals(LocalDate.now()))
1419 
                            .collect(Collectors.counting());
1420 
                }
1421 
                LOGGER.info("PERF: selectByAuthIdAndIds took {} ms", System.currentTimeMillis() - lapTime);
1422 
                lapTime = System.currentTimeMillis();
1423 
 
1424 
                Map<Integer, PartnerCollectionPlanModel> collectionMap = partnerCollectionService.getCollectionMap(fofoIdList, startDate);
1425 
                LOGGER.info("PERF: getCollectionMap took {} ms", System.currentTimeMillis() - lapTime);
1426 
                lapTime = System.currentTimeMillis();
1427 
 
1428 
                Map<Integer, List<PartnerSecondaryPlanModel>> partnerSecondaryPlans = orderRepository
1429 
                        .selectPartnerSecondaryGroupByBrand(fofoIdList, startDate.toLocalDate()).stream()
1430 
                        .collect(Collectors.groupingBy(x -> x.getFofoId()));
1431 
                LOGGER.info("PERF: selectPartnerSecondaryGroupByBrand took {} ms", System.currentTimeMillis() - lapTime);
1432 
                lapTime = System.currentTimeMillis();
1433 
 
1434 
                Set<Integer> allAuthIds = new HashSet<>();
1435 
                collectionMap.values().stream()
1436 
                        .map(PartnerCollectionPlanModel::getAuthId)
1437 
                        .filter(id -> id != null && id != authUser.getId())
1438 
                        .forEach(allAuthIds::add);
1439 
                partnerSecondaryPlans.values().stream()
1440 
                        .flatMap(List::stream)
1441 
                        .map(PartnerSecondaryPlanModel::getAuthId)
1442 
                        .filter(id -> id != null && id != authUser.getId())
1443 
                        .forEach(allAuthIds::add);
1444 
                Map<Integer, AuthUser> authUserMap = new HashMap<>();
1445 
                if (!allAuthIds.isEmpty()) {
1446 
                    authUserMap = authRepository.selectByIds(new ArrayList<>(allAuthIds)).stream()
1447 
                            .collect(Collectors.toMap(AuthUser::getId, x -> x));
1448 
                }
1449 
 
1450 
                LOGGER.info("partnerSecondayPlans {}", partnerSecondaryPlans);
1451 
                for (Entry<Integer, CustomRetailer> customRetailerEntry : customRetailers.entrySet()) {
1452 
                    int fofoId = customRetailerEntry.getKey();
1453 
                    CustomRetailer customRetailer = customRetailerEntry.getValue();
1454 
                    float totalSecondaryPlan = 0;
1455 
                    float totalSecondaryAchivement = 0;
1456 
 
1457 
                    PartnerTargetAchievementModel ptam = new PartnerTargetAchievementModel();
1458 
                    ptam.setFofoId(fofoId);
1459 
                    ptam.setBusinessName(customRetailer.getBusinessName());
1460 
                    ptam.setMobile(customRetailer.getMobileNumber());
36211 ranu 1461 
                    ptam.setActivationType(customRetailer.getActivationType());
35920 ranu 1462 
 
1463 
                    if (partnerDailyInvestmentMap.get(fofoId) != null) {
1464 
                        ptam.setWalletAmount(partnerDailyInvestmentMap.get(fofoId).getWalletAmount());
1465 
                        ptam.setShortInvestment(partnerDailyInvestmentMap.get(fofoId).getShortInvestment());
1466 
                    }
1467 
 
1468 
                    if (collectionMap.get(fofoId) != null) {
1469 
                        PartnerCollectionPlanModel collectionPlan = collectionMap.get(fofoId);
1470 
 
1471 
                        ptam.setRemark(collectionPlan.getRemark());
1472 
                        ptam.setMessage(collectionPlan.getMessage());
1473 
                        ptam.setRemarkTimestamp(collectionPlan.getRemarkTimestamp());
1474 
                        ptam.setRecordingUrl(collectionPlan.getRecordingUrl());
1475 
                        ptam.setScheduledCallTime(collectionPlan.getScheduledCallTime());
1476 
                        ptam.setRank(collectionPlan.getRank());
1477 
                        Integer authId = collectionPlan.getAuthId();
1478 
 
1479 
                        Map<Integer, String> rankColorMap = ProfitMandiConstants.Rank_Color_Map;
1480 
                        ptam.setCollectionColor(rankColorMap.get(collectionPlan.getRank()));
1481 
 
1482 
                        LOGGER.info("authId" + authId);
1483 
 
1484 
                        if (collectionPlan.getTargetPlan() != null && collectionPlan.getCommittedDate() != null) {
1485 
                            float targetCollection = 0;
1486 
 
1487 
                            if (collectionPlan.getRank() == 2 && collectionPlan.getAchievementPlan() != null) {
1488 
                                targetCollection = collectionPlan.getTargetPlan() - collectionPlan.getAchievementPlan();
1489 
                            } else {
1490 
                                targetCollection = collectionPlan.getTargetPlan();
1491 
                            }
1492 
 
1493 
                            if (authId != null && authId == authUser.getId()) {
1494 
                                if (!collectionPlan.getCommittedDate().isAfter(startDate)) {
1495 
                                    totalPartnerTargetCollection += targetCollection;
1496 
                                }
1497 
                            }
1498 
                            ptam.setCollectionTarget(targetCollection);
1499 
                            if (collectionPlan.getRank() == 2 && collectionPlan.getAchievementPlan() != null
1500 
                                    && collectionPlan.getWalletTimestamp() != null
1501 
                                    && collectionPlan.getWalletTimestamp().toLocalDate().equals(startDate.toLocalDate())) {
1502 
                                if (authId != null && authId == authUser.getId()) {
1503 
                                    totalPartnerAchievementCollection += collectionPlan.getAchievementPlan();
1504 
                                }
1505 
                                ptam.setCollectionAchievement(collectionPlan.getAchievementPlan());
1506 
                            } else if (collectionPlan.getCommittedDate().toLocalDate().isEqual(startDate.toLocalDate())
1507 
                                    && collectionPlan.getAchievementPlan() != null) {
1508 
                                if (authId != null && authId == authUser.getId()) {
1509 
                                    totalPartnerAchievementCollection += collectionPlan.getAchievementPlan();
1510 
                                }
1511 
                                ptam.setCollectionAchievement(collectionPlan.getAchievementPlan());
1512 
                            }
1513 
                        }
1514 
 
1515 
                        if (authId != null && authId != authUser.getId()) {
1516 
                            ptam.setAuthUser(authUserMap.get(authId));
1517 
                        }
1518 
 
1519 
                        if (collectionPlan.getCommittedDate() != null) {
1520 
                            ptam.setCollectionCommitmentDate(collectionPlan.getCommittedDate().toLocalDate());
1521 
                        }
1522 
                    }
1523 
 
1524 
                    PartnerSecondaryPlanModel otherPartnerSecondaryPlanModel = null;
1525 
                    Map<String, PartnerSecondaryPlanModel> secondaryModelMap = new HashMap<>();
1526 
                    if (partnerSecondaryPlans.get(fofoId) != null) {
1527 
                        long otherBrandSecondary = 0;
1528 
                        for (PartnerSecondaryPlanModel pspm : partnerSecondaryPlans.get(fofoId)) {
1529 
                            Integer authId = pspm.getAuthId();
1530 
                            if (!brands.contains(pspm.getBrand())) {
1531 
                                if (pspm.getAchievementPlan() != null) {
1532 
                                    otherBrandSecondary += pspm.getAchievementPlan();
1533 
                                }
1534 
                            } else {
1535 
                                otherPartnerSecondaryPlanModel = pspm;
1536 
                            }
1537 
                            if (pspm.getTargetPlan() != null) {
1538 
                                totalSecondaryPlan += pspm.getTargetPlan();
1539 
                            }
1540 
 
1541 
                            if (pspm.getAchievementPlan() != null) {
1542 
                                totalSecondaryAchivement += pspm.getAchievementPlan();
1543 
                            }
1544 
 
1545 
                            if (pspm.getCommittedDate() != null) {
1546 
                                ptam.setSecondaryCommitmentDate(pspm.getCommittedDate().toLocalDate());
1547 
                            }
1548 
                            if (authId != null && authId == authUser.getId()) {
1549 
                                if (pspm.getTargetPlan() != null && pspm.getCommittedDate() != null) {
1550 
                                    if (pspm.getCommittedDate().isEqual(startDate)) {
1551 
                                        totalPartnerTargetSecondary += pspm.getTargetPlan();
1552 
                                    }
1553 
                                }
1554 
 
1555 
                                if (pspm.getAchievementPlan() != null) {
1556 
                                    totalPartnerAchievementSecondary += pspm.getAchievementPlan();
1557 
                                }
1558 
                            }
1559 
                        }
1560 
                        if (otherPartnerSecondaryPlanModel != null) {
1561 
                            otherPartnerSecondaryPlanModel.setAchievementPlan(otherBrandSecondary);
1562 
                        }
1563 
                        secondaryModelMap = partnerSecondaryPlans.get(fofoId).stream()
1564 
                                .filter(x -> brands.contains(x.getBrand()))
1565 
                                .collect(Collectors.toMap(x -> x.getBrand(), x -> x));
1566 
 
1567 
                        if (secondaryModelMap.containsKey("Others")) {
1568 
                            PartnerSecondaryPlanModel psp = secondaryModelMap.get("Others");
1569 
                            psp.setAchievementPlan(otherBrandSecondary);
1570 
                        } else {
1571 
                            secondaryModelMap.put("Others", new PartnerSecondaryPlanModel(fofoId, "Others", (long) 0, otherBrandSecondary, authUser.getId(), null));
1572 
                        }
1573 
                        for (String brand : brands) {
1574 
                            if (!secondaryModelMap.containsKey(brand)) {
1575 
                                secondaryModelMap.put(brand, new PartnerSecondaryPlanModel(fofoId, brand, (long) 0, (long) 0, authUser.getId(), null));
1576 
                            }
1577 
                        }
1578 
 
1579 
                        for (Entry<String, PartnerSecondaryPlanModel> secondaryModelEntry : secondaryModelMap.entrySet()) {
1580 
                            Integer authId = secondaryModelEntry.getValue().getAuthId();
1581 
                            if (authId != null && authId != authUser.getId()) {
1582 
                                secondaryModelEntry.getValue().setAuthUser(authUserMap.get(authId));
1583 
                                ptam.setSecondaryColor("red");
1584 
                            }
1585 
                        }
1586 
 
1587 
                        ptam.setPartnerSecondaryModel(secondaryModelMap);
1588 
                        ptam.setTotalSecondaryPlan(totalSecondaryPlan);
1589 
                        ptam.setTotalSecondaryAchievement(totalSecondaryAchivement);
1590 
 
1591 
                    } else {
1592 
                        for (String brand : brands) {
1593 
                            PartnerSecondaryPlanModel pspm = new PartnerSecondaryPlanModel();
1594 
                            pspm.setAchievementPlan((long) 0);
1595 
                            pspm.setTargetPlan((long) 0);
1596 
                            pspm.setBrand(brand);
1597 
                            pspm.setFofoId(fofoId);
1598 
                            secondaryModelMap.put(brand, pspm);
1599 
                        }
1600 
                        ptam.setPartnerSecondaryModel(secondaryModelMap);
1601 
                    }
1602 
 
1603 
                    if (!partnerTicketCount.isEmpty()) {
1604 
                        if (partnerTicketCount.get(fofoId) != null) {
1605 
                            ptam.setTicketCount(partnerTicketCount.get(fofoId));
1606 
                        } else {
1607 
                            ptam.setTicketCount(0);
1608 
                        }
1609 
                    }
1610 
 
1611 
                    boolean hasCreditDue = fofoIdsWithOverdueLoans.contains(fofoId);
1612 
                    ptam.setHasOverdue(hasCreditDue);
1613 
 
1614 
                    int rank = ptam.getRank() > 0 ? ptam.getRank() : 5;
1615 
                    boolean hasZeroBilling = !allMtdBilledFofoIds.contains(fofoId);
1616 
 
1617 
                    if (rank == 1) {
1618 
                        ptam.setCategory("PLAN_TODAY");
1619 
                        ptam.setCategoryPriority(1);
1620 
                    } else if (rank == 2) {
1621 
                        ptam.setCategory("CARRY_FORWARD");
1622 
                        ptam.setCategoryPriority(2);
1623 
                    } else if (hasZeroBilling && rank < 5) {
1624 
                        ptam.setCategory("ZERO_BILLED");
1625 
                        ptam.setCategoryPriority(3);
1626 
                    } else if (rank == 3) {
1627 
                        ptam.setCategory("UNTOUCHED");
1628 
                        ptam.setCategoryPriority(4);
1629 
                    } else {
1630 
                        ptam.setCategory("NORMAL");
1631 
                        ptam.setCategoryPriority(5);
1632 
                    }
1633 
 
1634 
                    ptams.add(ptam);
1635 
                }
1636 
 
1637 
                List<Position> positions = positionRepository.selectPositionByAuthId(authUser.getId()).stream().collect(Collectors.toList());
1638 
                LOGGER.info("positions {}", positions);
1639 
 
1640 
                boolean isRBMAndL1 = positions.stream().anyMatch(position -> ProfitMandiConstants.TICKET_CATEGORY_RBM == position.getCategoryId() && EscalationType.L1.equals(position.getEscalationType()));
36211 ranu 1641 
                boolean isRBMAndL2 = positions.stream().anyMatch(position -> ProfitMandiConstants.TICKET_CATEGORY_RBM == position.getCategoryId() && EscalationType.L2.equals(position.getEscalationType()));
1642 
                boolean isRBMAndL3 = positions.stream().anyMatch(position -> ProfitMandiConstants.TICKET_CATEGORY_RBM == position.getCategoryId() && EscalationType.L3.equals(position.getEscalationType()));
35920 ranu 1643 
                boolean isRBMAndNotL1 = positions.stream().anyMatch(position -> ProfitMandiConstants.TICKET_CATEGORY_RBM == position.getCategoryId() && !EscalationType.L1.equals(position.getEscalationType()));
36211 ranu 1644 
                LOGGER.info("isRBMAndL1{}, isRBMAndL2{}, isRBMAndL3{}", isRBMAndL1, isRBMAndL2, isRBMAndL3);
35920 ranu 1645 
 
1646 
                boolean isSales = positions.stream().anyMatch(position -> ProfitMandiConstants.TICKET_CATEGORY_SALES == position.getCategoryId());
1647 
 
1648 
                tm.setTotalPartnerTargetCollection(totalPartnerTargetCollection);
1649 
                tm.setTotalPartnerTargetSecondary(totalPartnerTargetSecondary);
1650 
                tm.setTotalPartnerSecondary(totalPartnerAchievementSecondary);
1651 
                tm.setTotalPartnerCollection(totalPartnerAchievementCollection);
1652 
                tm.setTodayCollectionCount((int) todayCollectionCount);
1653 
                List<PartnerTargetAchievementModel> filteredPtams;
1654 
 
1655 
                if (isRBMAndL1) {
1656 
                    filteredPtams = ptams;
1657 
                } else if (isRBMAndNotL1) {
1658 
                    filteredPtams = ptams;
1659 
                } else if (isSales) {
1660 
                    filteredPtams = ptams.stream()
36211 ranu 1661 
                            .filter(ptam -> !(CollectionRemark.RBM_L2_ESCALATION.equals(ptam.getRemark()) || CollectionRemark.RBM_L3_ESCALATION.equals(ptam.getRemark())))
35920 ranu 1662 
                            .collect(Collectors.toList());
1663 
                } else {
1664 
                    filteredPtams = ptams;
1665 
                }
1666 
                tm.setRBMAndL1(isRBMAndL1);
36211 ranu 1667 
                tm.setRBMAndL2(isRBMAndL2);
1668 
                tm.setRBMAndL3(isRBMAndL3);
35920 ranu 1669 
                tm.setRBMAndNotL1(isRBMAndNotL1);
1670 
                tm.setSales(isSales);
1671 
 
1672 
                Map<String, Long> categoryCounts = filteredPtams.stream()
1673 
                        .collect(Collectors.groupingBy(
1674 
                                p -> p.getCategory() != null ? p.getCategory() : "NORMAL",
1675 
                                Collectors.counting()));
1676 
                tm.setOverdueCount((int) filteredPtams.stream().filter(PartnerTargetAchievementModel::isHasOverdue).count());
1677 
                tm.setPlanTodayCount(categoryCounts.getOrDefault("PLAN_TODAY", 0L).intValue());
1678 
                tm.setCarryForwardCount(categoryCounts.getOrDefault("CARRY_FORWARD", 0L).intValue());
1679 
                tm.setZeroBilledCount(categoryCounts.getOrDefault("ZERO_BILLED", 0L).intValue());
1680 
                tm.setUntouchedCount(categoryCounts.getOrDefault("UNTOUCHED", 0L).intValue());
1681 
                tm.setNormalCount(categoryCounts.getOrDefault("NORMAL", 0L).intValue());
1682 
 
1683 
                LocalDateTime now = LocalDateTime.now();
1684 
                LocalDateTime fourHoursAgo = now.minusHours(4);
1685 
                tm.setTargetAchievement(filteredPtams.stream()
1686 
                        .sorted(Comparator
1687 
                                .comparing((PartnerTargetAchievementModel p) -> {
1688 
                                    if (p.getRemarkTimestamp() == null) {
1689 
                                        return false;
1690 
                                    }
1691 
                                    LocalDate remarkDate = p.getRemarkTimestamp().toLocalDate();
1692 
                                    if (!remarkDate.equals(LocalDate.now())) {
1693 
                                        return false;
1694 
                                    }
1695 
                                    if (CollectionRemark.SCHEDULE_CALL.equals(p.getRemark()) || CollectionRemark.NO_ANSWER.equals(p.getRemark())) {
1696 
                                        if (p.getScheduledCallTime() != null) {
1697 
                                            if (!p.getScheduledCallTime().isAfter(now)) {
1698 
                                                return false;
1699 
                                            }
1700 
                                            return true;
1701 
                                        }
1702 
                                        if (CollectionRemark.NO_ANSWER.equals(p.getRemark())
1703 
                                                && p.getRemarkTimestamp().isBefore(fourHoursAgo)) {
1704 
                                            return false;
1705 
                                        }
1706 
                                    }
1707 
                                    return true;
1708 
                                })
1709 
                                .thenComparing(PartnerTargetAchievementModel::getCategoryPriority)
1710 
                                .thenComparing(PartnerTargetAchievementModel::getRank)
1711 
                        )
1712 
                        .collect(Collectors.toList()));
1713 
            }
1714 
        }
1715 
        LOGGER.info("PERF: Total getInactivePartnerTarget took {} ms", System.currentTimeMillis() - startTime);
1716 
        return responseSender.ok(tm);
1717 
 
1718 
    }
1719 
 
32737 amit.gupta 1720 
    //TODO:Amit
31677 amit.gupta 1721 
    @RequestMapping(value = "/target", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_VALUE)
35079 vikas 1722 
    @ApiImplicitParams({@ApiImplicitParam(name = "Auth-Token", value = "Auth-Token", required = true, dataType = "string", paramType = "header")})
31677 amit.gupta 1723 
    public ResponseEntity<?> createPartnerTarget(HttpServletRequest request,
1724 
                                                 @RequestBody PartnerTargetAchievementModel ptam) throws ProfitMandiBusinessException {
30077 tejbeer 1725 
 
31677 amit.gupta 1726 
        LOGGER.info("ptam" + ptam);
30089 tejbeer 1727 
 
31677 amit.gupta 1728 
        AuthUser authUser = authRepository.selectByGmailId(ptam.getCreatedBy());
30077 tejbeer 1729 
 
31677 amit.gupta 1730 
        if (ptam.getCollectionCommitmentDate().isAfter(LocalDate.now())
1731 
                || ptam.getCollectionCommitmentDate().isEqual(LocalDate.now())) {
1732 
            PartnerCollectionPlan partnerCollectionPlan = partnerCollectionPlanRepository
1733 
                    .selectByLocalDate(LocalDate.now(), ptam.getFofoId(), true);
1734 
            LOGGER.info("pcp" + partnerCollectionPlan);
30077 tejbeer 1735 
 
31677 amit.gupta 1736 
            if (partnerCollectionPlan == null) {
1737 
                if (ptam.getCollectionTarget() > 0) {
30087 tejbeer 1738 
 
31677 amit.gupta 1739 
                    partnerCollectionPlan = new PartnerCollectionPlan();
1740 
                    partnerCollectionPlan.setCreateTimestamp(LocalDateTime.now());
1741 
                    partnerCollectionPlan.setAuthId(authUser.getId());
1742 
                    partnerCollectionPlan.setFofoId(ptam.getFofoId());
1743 
                    partnerCollectionPlan.setActive(true);
1744 
                    partnerCollectionPlan.setCollectionPlan(ptam.getCollectionTarget());
1745 
                    partnerCollectionPlan.setUpdatedTimestamp(LocalDateTime.now());
1746 
                    partnerCollectionPlan.setCommitedTimestamp(ptam.getCollectionCommitmentDate().atStartOfDay());
1747 
                    partnerCollectionPlanRepository.persist(partnerCollectionPlan);
30416 tejbeer 1748 
 
31677 amit.gupta 1749 
                }
30087 tejbeer 1750 
 
31677 amit.gupta 1751 
            } else {
30087 tejbeer 1752 
 
31677 amit.gupta 1753 
                if (partnerCollectionPlan.getCollectionPlan() != ptam.getCollectionTarget()) {
1754 
                    float totalCollectionPlan = partnerCollectionPlan.getCollectionPlan() + 10000;
1755 
                    if (authUser.getId() == partnerCollectionPlan.getAuthId()) {
30087 tejbeer 1756 
 
31677 amit.gupta 1757 
                        if (authUser.getEmailId().equals("tarun.verma@smartdukaan.com")
1758 
                                || authUser.getEmailId().equals("rakesh.sonawane@smartdukaan.com")
1759 
                                || ptam.getCollectionTarget() >= totalCollectionPlan) {
1760 
                            partnerCollectionPlan.setCollectionPlan(ptam.getCollectionTarget());
1761 
                            partnerCollectionPlan.setActive(true);
1762 
                            partnerCollectionPlan
1763 
                                    .setCommitedTimestamp(ptam.getCollectionCommitmentDate().atStartOfDay());
1764 
                            partnerCollectionPlan.setUpdatedTimestamp(LocalDateTime.now());
1765 
                        } else {
1766 
                            throw new ProfitMandiBusinessException("collection target", "",
1767 
                                    "collection target should be more than " + totalCollectionPlan);
1768 
                        }
30087 tejbeer 1769 
 
31677 amit.gupta 1770 
                    } else {
30137 tejbeer 1771 
 
31677 amit.gupta 1772 
                        if (authUser.getEmailId().equals("tarun.verma@smartdukaan.com")
1773 
                                || authUser.getEmailId().equals("rakesh.sonawane@smartdukaan.com")
1774 
                                || ptam.getCollectionTarget() >= totalCollectionPlan) {
30137 tejbeer 1775 
 
31677 amit.gupta 1776 
                            partnerCollectionPlan.setActive(false);
1777 
                            partnerCollectionPlan.setUpdatedTimestamp(LocalDateTime.now());
1778 
                            partnerCollectionPlan = new PartnerCollectionPlan();
1779 
                            partnerCollectionPlan.setCreateTimestamp(LocalDateTime.now());
1780 
                            partnerCollectionPlan.setAuthId(authUser.getId());
1781 
                            partnerCollectionPlan.setFofoId(ptam.getFofoId());
1782 
                            partnerCollectionPlan.setActive(true);
1783 
                            partnerCollectionPlan
1784 
                                    .setCommitedTimestamp(ptam.getSecondaryCommitmentDate().atStartOfDay());
1785 
                            partnerCollectionPlan.setCollectionPlan(ptam.getCollectionTarget());
1786 
                            partnerCollectionPlan.setUpdatedTimestamp(LocalDateTime.now());
1787 
                            partnerCollectionPlanRepository.persist(partnerCollectionPlan);
1788 
                        } else {
1789 
                            throw new ProfitMandiBusinessException("collection target", "",
1790 
                                    "collection target should be more than " + totalCollectionPlan);
1791 
                        }
1792 
                    }
1793 
                }
30137 tejbeer 1794 
 
31677 amit.gupta 1795 
                if ((LocalDate.now().atStartOfDay().equals(ptam.getCollectionCommitmentDate().atStartOfDay())
1796 
                        || ptam.getCollectionCommitmentDate().atStartOfDay().isAfter(LocalDate.now().atStartOfDay()))
1797 
                        && partnerCollectionPlan.getCollectionPlan() == ptam.getCollectionTarget()) {
1798 
                    partnerCollectionPlan.setCommitedTimestamp(ptam.getCollectionCommitmentDate().atStartOfDay());
1799 
                    partnerCollectionPlan.setUpdatedTimestamp(LocalDateTime.now());
1800 
                }
30416 tejbeer 1801 
 
31677 amit.gupta 1802 
            }
30433 tejbeer 1803 
 
35725 ranu 1804 
            long callLogId = recordingService.getLatestAgentCallLog(ptam.getFofoId(),authUser.getId());
1805 
 
31677 amit.gupta 1806 
            PartnerCollectionRemark pcr = new PartnerCollectionRemark();
1807 
            pcr.setFofoId(ptam.getFofoId());
1808 
            pcr.setAuthId(authUser.getId());
1809 
            pcr.setMessage("Collection plan for" + ptam.getCollectionCommitmentDate());
1810 
            pcr.setRemark(CollectionRemark.COLLECTION_PLAN);
35725 ranu 1811 
            pcr.setAgentCallLogId(callLogId);
31677 amit.gupta 1812 
            pcr.setCreateTimestamp(LocalDateTime.now());
1813 
            partnerCollectionRemarkRepository.persist(pcr);
1814 
        } else {
1815 
            throw new ProfitMandiBusinessException("Date", "",
1816 
                    "you can't select the back date " + ptam.getCollectionCommitmentDate());
1817 
        }
30077 tejbeer 1818 
 
31677 amit.gupta 1819 
        for (Entry<String, PartnerSecondaryPlanModel> pspm : ptam.getPartnerSecondaryModel().entrySet()) {
30087 tejbeer 1820 
 
31677 amit.gupta 1821 
            if (ptam.getCollectionCommitmentDate().isAfter(LocalDate.now())
1822 
                    || ptam.getCollectionCommitmentDate().isEqual(LocalDate.now())) {
1823 
                PartnerSecondaryPlanModel plan = pspm.getValue();
1824 
                PartnerSecondaryPlan psp = partnerSecondaryPlanRepository.selectByLocalDateBrand(plan.getBrand(),
1825 
                        LocalDate.now(), ptam.getFofoId(), true);
1826 
                LOGGER.info("psp" + psp);
30087 tejbeer 1827 
 
31677 amit.gupta 1828 
                if (psp == null) {
1829 
                    if (plan.getTargetPlan() != null && plan.getTargetPlan() > 0) {
30087 tejbeer 1830 
 
31677 amit.gupta 1831 
                        psp = new PartnerSecondaryPlan();
1832 
                        psp.setAuthId(authUser.getId());
1833 
                        psp.setBrand(pspm.getKey());
1834 
                        psp.setFofoId(pspm.getValue().getFofoId());
1835 
                        psp.setSecondaryPlan(pspm.getValue().getTargetPlan());
1836 
                        psp.setCreateTimestamp(LocalDateTime.now());
1837 
                        psp.setUpdatedTimestamp(LocalDateTime.now());
1838 
                        psp.setCommitedTimestamp(ptam.getSecondaryCommitmentDate().atStartOfDay());
1839 
                        psp.setActive(true);
1840 
                        partnerSecondaryPlanRepository.persist(psp);
1841 
                    }
30087 tejbeer 1842 
 
31677 amit.gupta 1843 
                } else {
1844 
                    if (plan.getTargetPlan() != psp.getSecondaryPlan()) {
1845 
                        float totalSecondaryPlan = psp.getSecondaryPlan() + 10000;
1846 
                        if (authUser.getId() == plan.getAuthId()) {
1847 
                            if (authUser.getEmailId().equals("tarun.verma@smartdukaan.com")
1848 
                                    || authUser.getEmailId().equals("rakesh.sonawane@smartdukaan.com")
1849 
                                    || plan.getTargetPlan() >= totalSecondaryPlan) {
1850 
                                psp.setSecondaryPlan(pspm.getValue().getTargetPlan());
1851 
                                psp.setCommitedTimestamp(ptam.getSecondaryCommitmentDate().atStartOfDay());
1852 
                                psp.setUpdatedTimestamp(LocalDateTime.now());
1853 
                                psp.setActive(true);
1854 
                            } else {
1855 
                                throw new ProfitMandiBusinessException("secondary target", "",
1856 
                                        "secondary target should be more than " + totalSecondaryPlan);
1857 
                            }
30087 tejbeer 1858 
 
31677 amit.gupta 1859 
                        } else {
30087 tejbeer 1860 
 
31677 amit.gupta 1861 
                            if (authUser.getEmailId().equals("tarun.verma@smartdukaan.com")
1862 
                                    || authUser.getEmailId().equals("rakesh.sonawane@smartdukaan.com")
1863 
                                    || plan.getTargetPlan() >= totalSecondaryPlan) {
30087 tejbeer 1864 
 
31677 amit.gupta 1865 
                                psp.setUpdatedTimestamp(LocalDateTime.now());
1866 
                                psp.setActive(false);
1867 
                                psp = new PartnerSecondaryPlan();
1868 
                                psp.setAuthId(authUser.getId());
1869 
                                psp.setBrand(pspm.getKey());
1870 
                                psp.setFofoId(pspm.getValue().getFofoId());
1871 
                                psp.setSecondaryPlan(pspm.getValue().getTargetPlan());
1872 
                                psp.setCommitedTimestamp(ptam.getSecondaryCommitmentDate().atStartOfDay());
1873 
                                psp.setCreateTimestamp(LocalDateTime.now());
1874 
                                psp.setUpdatedTimestamp(LocalDateTime.now());
1875 
                                psp.setActive(true);
1876 
                                partnerSecondaryPlanRepository.persist(psp);
1877 
                            } else {
1878 
                                throw new ProfitMandiBusinessException("secondary target", "",
1879 
                                        "secondary target should be more than " + totalSecondaryPlan);
1880 
                            }
1881 
                        }
1882 
                    }
30137 tejbeer 1883 
 
31677 amit.gupta 1884 
                    if ((LocalDate.now().atStartOfDay().equals(ptam.getSecondaryCommitmentDate().atStartOfDay())
1885 
                            || ptam.getSecondaryCommitmentDate().atStartOfDay().isAfter(LocalDate.now().atStartOfDay()))
1886 
                            && plan.getTargetPlan() == psp.getSecondaryPlan()) {
1887 
                        psp.setCommitedTimestamp(ptam.getSecondaryCommitmentDate().atStartOfDay());
1888 
                        psp.setUpdatedTimestamp(LocalDateTime.now());
1889 
                    }
30137 tejbeer 1890 
 
31677 amit.gupta 1891 
                }
1892 
            } else {
1893 
                throw new ProfitMandiBusinessException("Date", "",
1894 
                        "you can't select the back date " + ptam.getSecondaryCommitmentDate());
1895 
            }
30137 tejbeer 1896 
 
31677 amit.gupta 1897 
        }
30077 tejbeer 1898 
 
31677 amit.gupta 1899 
        return responseSender.ok(true);
30137 tejbeer 1900 
 
31677 amit.gupta 1901 
    }
30077 tejbeer 1902 
 
31677 amit.gupta 1903 
    @RequestMapping(value = "/uploadFranchiseeVisit", method = RequestMethod.POST)
35288 amit 1904 
    public ResponseEntity<?> readCsvFileAndSetLead(HttpServletRequest request, @RequestPart MultipartFile
1905 
            multipartFile) throws Throwable {
30433 tejbeer 1906 
 
31677 amit.gupta 1907 
        int id = (int) request.getAttribute("userId");
30433 tejbeer 1908 
 
31677 amit.gupta 1909 
        LOGGER.info("id" + id);
30433 tejbeer 1910 
 
31677 amit.gupta 1911 
        User user = userRepository.selectById(id);
30433 tejbeer 1912 
 
31677 amit.gupta 1913 
        AuthUser authUser = authRepository.selectByEmailOrMobile(user.getEmailId());
30433 tejbeer 1914 
 
31677 amit.gupta 1915 
        String fileName = multipartFile.getName();
1916 
        String fileNames = multipartFile.getOriginalFilename();
30433 tejbeer 1917 
 
31677 amit.gupta 1918 
        LOGGER.info("fileName" + fileName);
1919 
        LOGGER.info("fileNames" + fileNames);
30433 tejbeer 1920 
 
31677 amit.gupta 1921 
        List<CSVRecord> records = FileUtil.readFile(multipartFile);
30433 tejbeer 1922 
 
31677 amit.gupta 1923 
        for (CSVRecord record : records) {
1924 
            FranchiseeVisit franchiseeVisit = new FranchiseeVisit();
1925 
            franchiseeVisit.setFofoId(Integer.parseInt(record.get(0)));
1926 
            CustomRetailer customRetailer = retailerService.getFofoRetailer(Integer.parseInt(record.get(0)));
30433 tejbeer 1927 
 
31677 amit.gupta 1928 
            franchiseeVisit.setPartnerName(customRetailer.getBusinessName());
1929 
            franchiseeVisit.setAgenda(record.get(1));
1930 
            franchiseeVisit.setCreatedTimestamp(LocalDateTime.now());
1931 
            franchiseeVisit.setUpdatedTimestamp(LocalDateTime.now());
1932 
            franchiseeVisit.setStatus(FranchiseeVisitStatus.OPEN);
30433 tejbeer 1933 
 
31677 amit.gupta 1934 
            DateTimeFormatter formatter = DateTimeFormatter.ofPattern("dd-MM-yyyy");
1935 
            LOGGER.info(record.get(1));
1936 
            LocalDate dateTime = LocalDate.parse(record.get(2), formatter);
30433 tejbeer 1937 
 
31677 amit.gupta 1938 
            franchiseeVisit.setScheduleTimestamp(dateTime.atStartOfDay());
1939 
            // change
30433 tejbeer 1940 
 
31677 amit.gupta 1941 
            String authUserName = authUser.getFirstName() + " " + authUser.getLastName();
1942 
            franchiseeVisit.setCreatedBy(authUserName);
1943 
            franchiseeVisit.setAuthId(authUser.getId());
30433 tejbeer 1944 
 
31677 amit.gupta 1945 
            franchiseeVisitRepository.persist(franchiseeVisit);
30433 tejbeer 1946 
 
31677 amit.gupta 1947 
            return responseSender.ok(true);
1948 
        }
30433 tejbeer 1949 
 
31677 amit.gupta 1950 
        return responseSender.ok(true);
30433 tejbeer 1951 
 
31677 amit.gupta 1952 
    }
30487 tejbeer 1953 
 
31677 amit.gupta 1954 
    @RequestMapping(value = "/downloadFranchiseeVisitTemplate", method = RequestMethod.GET)
1955 
    public ResponseEntity<?> downloadFranchiseeVisitTemplate(HttpServletRequest request) throws Exception {
30487 tejbeer 1956 
 
31677 amit.gupta 1957 
        // ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
30487 tejbeer 1958 
 
31677 amit.gupta 1959 
        List<List<?>> rows = new ArrayList<>();
30487 tejbeer 1960 
 
32923 ranu 1961 
        ByteArrayOutputStream byteArrayOutputStream = FileUtil
31677 amit.gupta 1962 
                .getCSVByteStream(Arrays.asList("Partner Id", "Agenda", "Schedule Timestamp"), rows);
30487 tejbeer 1963 
 
31677 amit.gupta 1964 
        try {
1965 
            byteArrayOutputStream.close();
1966 
        } catch (IOException e) {
1967 
            // TODO Auto-generated catch block
1968 
            e.printStackTrace();
1969 
        }
30487 tejbeer 1970 
 
31677 amit.gupta 1971 
        String filename = "template.csv";
1972 
        HttpHeaders headers = new HttpHeaders();
1973 
        headers.add("Content-Type", "application/csv");
1974 
        headers.setContentDispositionFormData(filename, filename);
30487 tejbeer 1975 
 
31677 amit.gupta 1976 
        headers.setCacheControl("must-revalidate, post-check=0, pre-check=0");
30487 tejbeer 1977 
 
31677 amit.gupta 1978 
        ResponseEntity<byte[]> response = new ResponseEntity<byte[]>(byteArrayOutputStream.toByteArray(), headers,
1979 
                HttpStatus.OK);
1980 
        return response;
30544 tejbeer 1981 
 
31677 amit.gupta 1982 
    }
30542 tejbeer 1983 
 
31677 amit.gupta 1984 
    @RequestMapping(value = "/markVisitAttendance", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_VALUE)
1985 
    public ResponseEntity<?> markVisitAttendance(HttpServletRequest request, @RequestParam(name = "id") int id)
1986 
            throws ProfitMandiBusinessException {
1987 
        FranchiseeVisit franchiseeVisit = franchiseeVisitRepository.selectById(id);
30542 tejbeer 1988 
 
31677 amit.gupta 1989 
        franchiseeVisit.setVisitTimestamp(LocalDateTime.now());
30542 tejbeer 1990 
 
31677 amit.gupta 1991 
        return responseSender.ok(true);
30542 tejbeer 1992 
 
31677 amit.gupta 1993 
    }
31249 tejbeer 1994 
 
31677 amit.gupta 1995 
    @RequestMapping(value = "/getVisitRequests", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
1996 
    public ResponseEntity<?> getVisitRequests(HttpServletRequest request,
1997 
                                              @RequestParam(name = "gmailId") String gmailId, Model model) throws Exception {
31249 tejbeer 1998 
 
31677 amit.gupta 1999 
        AuthUser authUser = authRepository.selectByGmailId(gmailId);
31249 tejbeer 2000 
 
31677 amit.gupta 2001 
        List<Integer> authUserIds = authService.getAllReportees(authUser.getId());
2002 
        List<VisitSummaryModel> visitSummary = new ArrayList<>();
31249 tejbeer 2003 
 
31677 amit.gupta 2004 
        if (!authUserIds.isEmpty()) {
35397 amit 2005 
            List<AuthUser> authUsers = authRepository.selectByIds(authUserIds);
31249 tejbeer 2006 
 
31677 amit.gupta 2007 
            List<VisitRequest> allVisitRequests = visitRequestRepository.selectByAuthIdsAndDate(authUserIds,
2008 
                    LocalDate.now().minusDays(7), Arrays.asList(VisitStatus.approved, VisitStatus.pending));
2009 
            LOGGER.info("allVisitRequests {}", allVisitRequests);
31249 tejbeer 2010 
 
31677 amit.gupta 2011 
            if (!allVisitRequests.isEmpty()) {
31249 tejbeer 2012 
 
31677 amit.gupta 2013 
                List<Integer> leadIds = allVisitRequests.stream().filter(x -> x.getVisitType().equals("lead"))
2014 
                        .map(x -> x.getVisitId()).collect(Collectors.toList());
2015 
                List<Lead> leads = new ArrayList<>();
2016 
                if (!leadIds.isEmpty()) {
2017 
                    leads = leadRepository.selectAllByIds(leadIds);
31249 tejbeer 2018 
 
35415 amit 2019 
                    // Batch fetch all LeadActivities instead of N+1
2020 
                    List<LeadActivity> allLeadActivities = leadActivityRepository.selectAllByleadIds(leadIds);
2021 
                    Map<Integer, List<LeadActivity>> leadActivityMap = allLeadActivities.stream()
2022 
                            .collect(Collectors.groupingBy(LeadActivity::getLeadId));
2023 
 
31677 amit.gupta 2024 
                    for (Lead lead : leads) {
35415 amit 2025 
                        List<LeadActivity> leadActivities = leadActivityMap.get(lead.getId());
2026 
                        if (leadActivities != null && !leadActivities.isEmpty()) {
2027 
                            lead.setScheduledTimestamp(leadActivities.get(0).getSchelduleTimestamp());
2028 
                            lead.setLeadActivity(leadActivities.get(0));
2029 
                        }
31677 amit.gupta 2030 
                    }
2031 
                }
2032 
                List<Integer> franchiseeIds = allVisitRequests.stream()
2033 
                        .filter(x -> x.getVisitType().equals("franchiseeVisit")).map(x -> x.getVisitId())
2034 
                        .collect(Collectors.toList());
2035 
                List<FranchiseeVisit> franchiseeVisits = new ArrayList<>();
2036 
                if (!franchiseeIds.isEmpty()) {
2037 
                    franchiseeVisits = franchiseeVisitRepository.selectAllByIds(franchiseeIds);
2038 
                    LOGGER.info("franchiseeVisits {}", franchiseeVisits);
31249 tejbeer 2039 
 
35415 amit 2040 
                    // Batch fetch all FranchiseeActivities instead of N+1
2041 
                    List<FranchiseeActivity> allFranchiseeActivities = franchiseeActivityRepository
2042 
                            .selectByFranchiseeVisitIds(franchiseeIds);
2043 
                    Map<Integer, List<FranchiseeActivity>> franchiseeActivityMap = allFranchiseeActivities.stream()
2044 
                            .collect(Collectors.groupingBy(FranchiseeActivity::getFranchiseeVisitd));
2045 
 
31677 amit.gupta 2046 
                    for (FranchiseeVisit franchiseeVisit : franchiseeVisits) {
35415 amit 2047 
                        List<FranchiseeActivity> franchiseeActivities = franchiseeActivityMap.get(franchiseeVisit.getId());
31677 amit.gupta 2048 
                        LOGGER.info("franchiseeActivities {}", franchiseeActivities);
31249 tejbeer 2049 
 
35415 amit 2050 
                        if (franchiseeActivities != null && !franchiseeActivities.isEmpty()) {
2051 
                            franchiseeVisit.setScheduleTimestamp(franchiseeActivities.get(0).getSchelduleTimestamp());
2052 
                            franchiseeVisit.setFranchiseeActivity(franchiseeActivities.get(0));
2053 
                        }
31677 amit.gupta 2054 
                    }
31249 tejbeer 2055 
 
31677 amit.gupta 2056 
                }
31249 tejbeer 2057 
 
35415 amit 2058 
                // Pre-fetch all retailers using cached method (instead of N+1 getFofoRetailer calls)
2059 
                Map<Integer, CustomRetailer> allRetailersMap = retailerService.getAllFofoRetailers();
2060 
 
31677 amit.gupta 2061 
                Map<LocalDate, List<VisitRequest>> dateWiseVisitRequest = allVisitRequests.stream()
2062 
                        .collect(Collectors.groupingBy(x -> x.getScheduleTimestamp().toLocalDate()));
31249 tejbeer 2063 
 
31677 amit.gupta 2064 
                for (Entry<LocalDate, List<VisitRequest>> visitEntry : dateWiseVisitRequest.entrySet()) {
31249 tejbeer 2065 
 
31677 amit.gupta 2066 
                    LocalDate date = visitEntry.getKey();
2067 
                    List<VisitRequest> visitRequests = visitEntry.getValue();
31249 tejbeer 2068 
 
31677 amit.gupta 2069 
                    VisitSummaryModel visitSummaryModel = new VisitSummaryModel();
31249 tejbeer 2070 
 
31677 amit.gupta 2071 
                    visitSummaryModel.setDate(date);
2072 
                    List<Integer> dateWiseLeadEntry = visitRequests.stream()
2073 
                            .filter(x -> x.getVisitType().equals("lead")).map(x -> x.getVisitId())
2074 
                            .collect(Collectors.toList());
31249 tejbeer 2075 
 
31677 amit.gupta 2076 
                    List<Integer> dateWiseFranchiseeIds = visitRequests.stream()
2077 
                            .filter(x -> x.getVisitType().equals("franchiseeVisit")).map(x -> x.getVisitId())
2078 
                            .collect(Collectors.toList());
31249 tejbeer 2079 
 
31677 amit.gupta 2080 
                    Map<Integer, List<Lead>> filteredLeadsMap = null;
2081 
                    if (!leads.isEmpty()) {
2082 
                        filteredLeadsMap = leads.stream().filter(x -> dateWiseLeadEntry.contains(x.getId()))
2083 
                                .collect(Collectors.groupingBy(x -> x.getAssignTo()));
31249 tejbeer 2084 
 
31677 amit.gupta 2085 
                    }
31249 tejbeer 2086 
 
31677 amit.gupta 2087 
                    Map<Integer, List<FranchiseeVisit>> filteredFranchiseeVisitsMap = null;
31249 tejbeer 2088 
 
31677 amit.gupta 2089 
                    if (!franchiseeVisits.isEmpty()) {
2090 
                        filteredFranchiseeVisitsMap = franchiseeVisits.stream()
2091 
                                .filter(x -> dateWiseFranchiseeIds.contains(x.getId()))
2092 
                                .collect(Collectors.groupingBy(x -> x.getAuthId()));
31249 tejbeer 2093 
 
31677 amit.gupta 2094 
                    }
31249 tejbeer 2095 
 
31677 amit.gupta 2096 
                    List<UserVisitModel> userVisits = new ArrayList<>();
31249 tejbeer 2097 
 
31677 amit.gupta 2098 
                    for (AuthUser auth : authUsers) {
2099 
                        UserVisitModel userVisitModel = new UserVisitModel();
2100 
                        List<VisitDescriptionModel> visitDescriptions = new ArrayList<>();
31249 tejbeer 2101 
 
31677 amit.gupta 2102 
                        List<Lead> authLeads = new ArrayList<>();
2103 
                        if (filteredLeadsMap != null) {
2104 
                            authLeads = filteredLeadsMap.get(auth.getId());
31249 tejbeer 2105 
 
31677 amit.gupta 2106 
                        }
31249 tejbeer 2107 
 
31677 amit.gupta 2108 
                        if (authLeads != null && !authLeads.isEmpty()) {
2109 
                            userVisitModel.setAuthUser(auth.getFullName());
31249 tejbeer 2110 
 
31677 amit.gupta 2111 
                            for (Lead lead : authLeads) {
31249 tejbeer 2112 
 
31677 amit.gupta 2113 
                                VisitRequest visitRequest = visitRequests.stream().filter(
2114 
                                                x -> x.getVisitId() == lead.getId() && x.getCreatedBy() == lead.getAssignTo())
2115 
                                        .findAny().orElse(null);
2116 
                                VisitDescriptionModel visitDescriptionModel = new VisitDescriptionModel();
2117 
                                visitDescriptionModel.setVisitId(visitRequest.getId());
2118 
                                visitDescriptionModel.setVisitName(lead.getFirstName());
2119 
                                visitDescriptionModel.setCity(lead.getCity());
2120 
                                visitDescriptionModel.setState(lead.getState());
2121 
                                visitDescriptionModel.setScheduleTime(lead.getScheduledTimestamp());
2122 
                                visitDescriptionModel.setStatus(visitRequest.getStatus());
2123 
                                visitDescriptionModel.setRemarks(lead.getLeadActivity().getRemark());
2124 
                                visitDescriptionModel.setVisitType(visitRequest.getVisitType());
2125 
                                visitDescriptions.add(visitDescriptionModel);
31249 tejbeer 2126 
 
31677 amit.gupta 2127 
                            }
2128 
                        }
31249 tejbeer 2129 
 
31677 amit.gupta 2130 
                        List<FranchiseeVisit> authfranchiseeVisit = new ArrayList<>();
2131 
                        if (filteredFranchiseeVisitsMap != null) {
2132 
                            authfranchiseeVisit = filteredFranchiseeVisitsMap.get(auth.getId());
31249 tejbeer 2133 
 
31677 amit.gupta 2134 
                        }
31249 tejbeer 2135 
 
31677 amit.gupta 2136 
                        if (authfranchiseeVisit != null && !authfranchiseeVisit.isEmpty()) {
2137 
                            userVisitModel.setAuthUser(auth.getFullName());
31249 tejbeer 2138 
 
31677 amit.gupta 2139 
                            for (FranchiseeVisit franchiseeVisit : authfranchiseeVisit) {
31249 tejbeer 2140 
 
31677 amit.gupta 2141 
                                VisitRequest visitRequest = visitRequests.stream()
2142 
                                        .filter(x -> x.getVisitId() == franchiseeVisit.getId()
2143 
                                                && x.getCreatedBy() == franchiseeVisit.getAuthId())
2144 
                                        .findAny().orElse(null);
31249 tejbeer 2145 
 
35415 amit 2146 
                                CustomRetailer customRetailer = allRetailersMap.get(franchiseeVisit.getFofoId());
31677 amit.gupta 2147 
                                VisitDescriptionModel visitDescriptionModel = new VisitDescriptionModel();
2148 
                                visitDescriptionModel.setVisitId(visitRequest.getId());
2149 
                                visitDescriptionModel.setVisitName(franchiseeVisit.getPartnerName());
35415 amit 2150 
                                if (customRetailer != null && customRetailer.getAddress() != null) {
2151 
                                    visitDescriptionModel.setCity(customRetailer.getAddress().getCity());
2152 
                                    visitDescriptionModel.setState(customRetailer.getAddress().getState());
2153 
                                }
31677 amit.gupta 2154 
                                visitDescriptionModel.setScheduleTime(
2155 
                                        franchiseeVisit.getFranchiseeActivity().getSchelduleTimestamp());
2156 
                                visitDescriptionModel.setStatus(visitRequest.getStatus());
2157 
                                visitDescriptionModel.setRemarks(franchiseeVisit.getAgenda());
2158 
                                visitDescriptionModel.setVisitType(visitRequest.getVisitType());
31249 tejbeer 2159 
 
31677 amit.gupta 2160 
                                visitDescriptions.add(visitDescriptionModel);
31249 tejbeer 2161 
 
31677 amit.gupta 2162 
                            }
2163 
                        }
31249 tejbeer 2164 
 
31677 amit.gupta 2165 
                        userVisitModel.setVisitDescriptions(visitDescriptions);
2166 
                        LOGGER.info("userVisit {}", userVisitModel);
31249 tejbeer 2167 
 
31677 amit.gupta 2168 
                        if (userVisitModel.getAuthUser() != null) {
2169 
                            userVisits.add(userVisitModel);
2170 
                        }
31249 tejbeer 2171 
 
31677 amit.gupta 2172 
                    }
31249 tejbeer 2173 
 
31677 amit.gupta 2174 
                    visitSummaryModel.setUserVisits(userVisits);
31249 tejbeer 2175 
 
31677 amit.gupta 2176 
                    visitSummary.add(visitSummaryModel);
31249 tejbeer 2177 
 
31677 amit.gupta 2178 
                }
31249 tejbeer 2179 
 
31677 amit.gupta 2180 
            }
31249 tejbeer 2181 
 
31677 amit.gupta 2182 
        }
2183 
        return responseSender.ok(visitSummary);
31249 tejbeer 2184 
 
31677 amit.gupta 2185 
    }
31249 tejbeer 2186 
 
31677 amit.gupta 2187 
    @RequestMapping(value = "/visitRequest", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_VALUE)
35288 amit 2188 
    public ResponseEntity<?> visitRequest(HttpServletRequest request, @RequestParam(name = "gmailId") String
2189 
                                                  gmailId,
31677 amit.gupta 2190 
                                          @RequestParam(name = "visitId") int visitId, @RequestParam(name = "status") VisitStatus status, Model model)
2191 
            throws Exception {
2192 
        AuthUser authUser = authRepository.selectByGmailId(gmailId);
31249 tejbeer 2193 
 
31677 amit.gupta 2194 
        VisitRequest visitRequest = visitRequestRepository.selectById(visitId);
2195 
        visitRequest.setActionedBy(authUser.getId());
2196 
        visitRequest.setStatus(status);
2197 
        visitRequest.setUpdatedTimestamp(LocalDateTime.now());
2198 
        if (status.equals(VisitStatus.approved)) {
2199 
            visitRequest.setApprovedTimestamp(LocalDateTime.now());
2200 
        }
31249 tejbeer 2201 
 
31677 amit.gupta 2202 
        SendNotificationModel sendNotificationModel = new SendNotificationModel();
2203 
        sendNotificationModel.setCampaignName("Visit Request");
2204 
        sendNotificationModel.setExpiresat(LocalDateTime.now().plusDays(1));
2205 
        sendNotificationModel.setTitle("Visit Request");
2206 
        String message = "Visit Request has been " + status + " for scheduled time on "
2207 
                + visitRequest.getScheduleTimestamp().toLocalDate();
31249 tejbeer 2208 
 
31677 amit.gupta 2209 
        sendNotificationModel.setMessage(message);
2210 
        sendNotificationModel.setMessageType(MessageType.notification);
2211 
        User user = userRepository.selectByEmailId(gmailId);
2212 
        sendNotificationModel.setUserIds(new ArrayList<>(user.getId()));
31249 tejbeer 2213 
 
31677 amit.gupta 2214 
        notificationService.sendNotificationToAll(sendNotificationModel);
31249 tejbeer 2215 
 
31677 amit.gupta 2216 
        return responseSender.ok(true);
31249 tejbeer 2217 
 
31677 amit.gupta 2218 
    }
31249 tejbeer 2219 
 
34301 ranu 2220 
    @Autowired
2221 
    RbmRatingRepository rbmRatingRepository;
2222 
 
34322 ranu 2223 
    @Autowired
2224 
    SalesRatingRepository salesRatingRepository;
2225 
 
34301 ranu 2226 
    @RequestMapping(value = "/rbmRating", method = RequestMethod.POST, produces = MediaType.APPLICATION_JSON_VALUE)
35288 amit 2227 
    public ResponseEntity<?> rbmRating(HttpServletRequest request, @RequestBody RbmSalesRatingRequest
2228 
            rbmSalesRatingRequest, Model model) throws Exception {
34301 ranu 2229 
        int userId = (int) request.getAttribute(ProfitMandiConstants.USER_ID);
2230 
        UserCart uc = userAccountRepository.getUserCart(userId);
2231 
        int fofoId = uc.getUserId();
34322 ranu 2232 
 
34301 ranu 2233 
        int rbmL1 = csService.getAuthUserId(ProfitMandiConstants.TICKET_CATEGORY_RBM, EscalationType.L1, fofoId);
34322 ranu 2234 
        int salesL1Id = csService.getAuthUserId(ProfitMandiConstants.TICKET_CATEGORY_SALES, EscalationType.L1, fofoId);
34301 ranu 2235 
 
36114 ranu 2236 
        // Calculate current week boundaries (Monday to Sunday)
2237 
        LocalDate today = LocalDate.now();
2238 
        LocalDate startOfWeek = today.with(TemporalAdjusters.previousOrSame(DayOfWeek.MONDAY));
2239 
        LocalDate endOfWeek = today.with(TemporalAdjusters.nextOrSame(DayOfWeek.SUNDAY));
2240 
        LocalDateTime startOfWeekDateTime = startOfWeek.atStartOfDay();
2241 
        LocalDateTime endOfWeekDateTime = endOfWeek.atTime(23, 59, 59);
34301 ranu 2242 
 
36114 ranu 2243 
        // Check if RBM rating already exists for this week
2244 
        List<RbmRating> existingRbmRatings = rbmRatingRepository.findByFofoIdAndRbmIdForCurrentMonth(fofoId, rbmL1, startOfWeekDateTime, endOfWeekDateTime);
34322 ranu 2245 
        if (!existingRbmRatings.isEmpty()) {
36114 ranu 2246 
            return ResponseEntity.status(HttpStatus.BAD_REQUEST).body("Rating for this week already exists.");
34301 ranu 2247 
        }
2248 
 
36114 ranu 2249 
        // Check if Sales Person rating already exists for this week
2250 
        List<SalesRating> existingSalesRatings = salesRatingRepository.findByFofoIdAndSalesL1IdForCurrentMonth(fofoId, salesL1Id, startOfWeekDateTime, endOfWeekDateTime);
34322 ranu 2251 
        if (!existingSalesRatings.isEmpty()) {
36114 ranu 2252 
            return ResponseEntity.status(HttpStatus.BAD_REQUEST).body("Rating for this week already exists.");
34322 ranu 2253 
        }
34301 ranu 2254 
 
34322 ranu 2255 
        // Save RBM rating
34301 ranu 2256 
        RbmRating rbmRating = new RbmRating();
34322 ranu 2257 
        rbmRating.setComment(rbmSalesRatingRequest.getRbmComment());
2258 
        rbmRating.setRating(rbmSalesRatingRequest.getRbmRating());
34301 ranu 2259 
        rbmRating.setFofoId(fofoId);
2260 
        rbmRating.setRbmId(rbmL1);
2261 
        rbmRating.setCreateTimeStamp(LocalDateTime.now());
2262 
        rbmRatingRepository.persist(rbmRating);
2263 
 
34322 ranu 2264 
        // Save Sales Person rating
2265 
        SalesRating salesRating = new SalesRating();
2266 
        salesRating.setComment(rbmSalesRatingRequest.getSalesComment());
2267 
        salesRating.setRating(rbmSalesRatingRequest.getSalesRating());
2268 
        salesRating.setFofoId(fofoId);
2269 
        salesRating.setSalesL1Id(salesL1Id);
2270 
        salesRating.setCreateTimeStamp(LocalDateTime.now());
2271 
        salesRatingRepository.persist(salesRating);
2272 
 
2273 
        return responseSender.ok("Rating submitted successfully.");
34301 ranu 2274 
    }
2275 
 
36286 ranu 2276 
    @RequestMapping(value = "/rbmRating/weekly-status", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
2277 
    public ResponseEntity<?> rbmRatingWeeklyStatus(HttpServletRequest request) throws Exception {
2278 
        int userId = (int) request.getAttribute(ProfitMandiConstants.USER_ID);
2279 
        UserCart uc = userAccountRepository.getUserCart(userId);
2280 
        int fofoId = uc.getUserId();
34301 ranu 2281 
 
36286 ranu 2282 
        int rbmL1 = csService.getAuthUserId(ProfitMandiConstants.TICKET_CATEGORY_RBM, EscalationType.L1, fofoId);
2283 
        int salesL1Id = csService.getAuthUserId(ProfitMandiConstants.TICKET_CATEGORY_SALES, EscalationType.L1, fofoId);
2284 
 
2285 
        // Calculate current week boundaries (Monday to Sunday)
2286 
        LocalDate today = LocalDate.now();
2287 
        LocalDate startOfWeek = today.with(TemporalAdjusters.previousOrSame(DayOfWeek.MONDAY));
2288 
        LocalDate endOfWeek = today.with(TemporalAdjusters.nextOrSame(DayOfWeek.SUNDAY));
2289 
        LocalDateTime startOfWeekDateTime = startOfWeek.atStartOfDay();
2290 
        LocalDateTime endOfWeekDateTime = endOfWeek.atTime(23, 59, 59);
2291 
 
36336 ranu 2292 
        List<RbmRating> existingRbmRatings = rbmRatingRepository.findByFofoIdForCurrentWeek(fofoId, startOfWeekDateTime, endOfWeekDateTime);
2293 
        List<SalesRating> existingSalesRatings = salesRatingRepository.findByFofoIdForCurrentWeek(fofoId, startOfWeekDateTime, endOfWeekDateTime);
36286 ranu 2294 
 
2295 
        boolean pending = existingRbmRatings.isEmpty() || existingSalesRatings.isEmpty();
2296 
 
2297 
        Map<String, Object> response = new HashMap<>();
2298 
        response.put("pending", pending);
2299 
        response.put("weekStart", startOfWeek.toString());
2300 
        response.put("weekEnd", endOfWeek.toString());
2301 
 
2302 
        if (rbmL1 > 0) {
2303 
            AuthUser rbmUser = authRepository.selectById(rbmL1);
2304 
            if (rbmUser != null) {
2305 
                response.put("rbmName", rbmUser.getFullName());
2306 
            }
2307 
        }
2308 
        if (salesL1Id > 0) {
2309 
            AuthUser salesUser = authRepository.selectById(salesL1Id);
2310 
            if (salesUser != null) {
2311 
                response.put("salesPersonName", salesUser.getFullName());
2312 
            }
2313 
        }
2314 
 
2315 
        return responseSender.ok(response);
2316 
    }
2317 
 
2318 
    @Autowired
2319 
    private RatingReminderRepository ratingReminderRepository;
2320 
 
2321 
    @RequestMapping(value = "/rbmRating/reminder", method = RequestMethod.GET, produces = MediaType.APPLICATION_JSON_VALUE)
2322 
    public ResponseEntity<?> rbmRatingReminder(HttpServletRequest request) throws Exception {
2323 
        int userId = (int) request.getAttribute(ProfitMandiConstants.USER_ID);
2324 
        UserCart uc = userAccountRepository.getUserCart(userId);
2325 
        int fofoId = uc.getUserId();
2326 
 
2327 
        LocalDate today = LocalDate.now();
2328 
        LocalDate startOfWeek = today.with(TemporalAdjusters.previousOrSame(DayOfWeek.MONDAY));
2329 
        LocalDate endOfWeek = today.with(TemporalAdjusters.nextOrSame(DayOfWeek.SUNDAY));
2330 
 
2331 
        RatingReminder reminder = ratingReminderRepository.findByFofoIdAndWeek(fofoId, startOfWeek);
2332 
 
2333 
        int attemptsRemaining;
2334 
        if (reminder == null) {
2335 
            // First hit this week: create entry initialised to MAX, no decrement
2336 
            reminder = new RatingReminder();
2337 
            reminder.setFofoId(fofoId);
2338 
            reminder.setWeekStart(startOfWeek);
2339 
            reminder.setWeekEnd(endOfWeek);
2340 
            reminder.setAttemptsRemaining(RatingReminder.MAX_ATTEMPTS_PER_WEEK);
2341 
            reminder.setCreateTimestamp(LocalDateTime.now());
2342 
            ratingReminderRepository.persist(reminder);
2343 
            attemptsRemaining = RatingReminder.MAX_ATTEMPTS_PER_WEEK;
2344 
        } else {
2345 
            // Subsequent hit: atomically decrement (floor 0) and re-read
2346 
            ratingReminderRepository.decrementRemaining(reminder.getId());
2347 
            reminder = ratingReminderRepository.findByFofoIdAndWeek(fofoId, startOfWeek);
2348 
            attemptsRemaining = reminder.getAttemptsRemaining();
2349 
        }
2350 
 
2351 
        Map<String, Object> response = new HashMap<>();
2352 
        response.put("partnerId", fofoId);
2353 
        response.put("attemptsRemaining", attemptsRemaining);
2354 
 
2355 
        return responseSender.ok(response);
2356 
    }
2357 
 
2358 
 
30077 tejbeer 2359 
}