Subversion Repositories SmartDukaan

Rev

Rev 35811 | Details | Compare with Previous | Last modification | View Log | RSS feed

Rev Author Line No. Line
30859 tejbeer 1
package com.spice.profitmandi.web.controller;
2
 
3
import com.spice.profitmandi.common.enumuration.MessageType;
4
import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
5
import com.spice.profitmandi.common.model.CustomRetailer;
6
import com.spice.profitmandi.common.model.SendNotificationModel;
31020 tejbeer 7
import com.spice.profitmandi.common.util.Utils;
30859 tejbeer 8
import com.spice.profitmandi.dao.entity.auth.AuthUser;
9
import com.spice.profitmandi.dao.entity.dtr.CreditAccount;
10
import com.spice.profitmandi.dao.entity.dtr.CreditStatus;
30913 tejbeer 11
import com.spice.profitmandi.dao.entity.fofo.CurrentPartnerDailyInvestment;
35274 amit 12
import com.spice.profitmandi.dao.entity.fofo.FofoStore;
30859 tejbeer 13
import com.spice.profitmandi.dao.entity.fofo.PartnerDailyInvestment;
32681 amit.gupta 14
import com.spice.profitmandi.dao.entity.transaction.*;
30989 tejbeer 15
import com.spice.profitmandi.dao.entity.user.Address;
30859 tejbeer 16
import com.spice.profitmandi.dao.enumuration.fofo.Gateway;
32197 jai.hind 17
import com.spice.profitmandi.dao.enumuration.transaction.LoanSummaryType;
30859 tejbeer 18
import com.spice.profitmandi.dao.enumuration.transaction.SanctionStatus;
32681 amit.gupta 19
import com.spice.profitmandi.dao.model.*;
30859 tejbeer 20
import com.spice.profitmandi.dao.repository.auth.AuthRepository;
30936 tejbeer 21
import com.spice.profitmandi.dao.repository.cs.CsService;
31666 amit.gupta 22
import com.spice.profitmandi.dao.repository.cs.CsService1;
30859 tejbeer 23
import com.spice.profitmandi.dao.repository.dtr.CreditAccountRepository;
24
import com.spice.profitmandi.dao.repository.dtr.FofoStoreRepository;
25
import com.spice.profitmandi.dao.repository.dtr.UserRepository;
30913 tejbeer 26
import com.spice.profitmandi.dao.repository.fofo.CurrentPartnerDailyInvestmentRepository;
32528 tejbeer 27
import com.spice.profitmandi.dao.repository.fofo.FofoOrderItemRepository;
30859 tejbeer 28
import com.spice.profitmandi.dao.repository.fofo.PartnerDailyInvestmentRepository;
32681 amit.gupta 29
import com.spice.profitmandi.dao.repository.transaction.*;
30989 tejbeer 30
import com.spice.profitmandi.dao.repository.user.AddressRepository;
30859 tejbeer 31
import com.spice.profitmandi.service.NotificationService;
32
import com.spice.profitmandi.service.transaction.SDCreditService;
33
import com.spice.profitmandi.service.user.RetailerService;
32197 jai.hind 34
import com.spice.profitmandi.service.user.UserService;
30936 tejbeer 35
import com.spice.profitmandi.web.model.LoginDetails;
36
import com.spice.profitmandi.web.util.CookiesProcessor;
31020 tejbeer 37
import com.spice.profitmandi.web.util.MVCResponseSender;
32681 amit.gupta 38
import org.apache.logging.log4j.LogManager;
39
import org.apache.logging.log4j.Logger;
40
import org.springframework.beans.factory.annotation.Autowired;
41
import org.springframework.mail.javamail.JavaMailSender;
42
import org.springframework.stereotype.Controller;
43
import org.springframework.ui.Model;
33858 ranu 44
import org.springframework.web.bind.annotation.*;
30859 tejbeer 45
 
32681 amit.gupta 46
import javax.servlet.http.HttpServletRequest;
35458 amit 47
import org.springframework.transaction.annotation.Transactional;
32681 amit.gupta 48
import java.math.BigDecimal;
49
import java.math.RoundingMode;
50
import java.time.Duration;
51
import java.time.LocalDate;
52
import java.time.LocalDateTime;
53
import java.time.LocalTime;
54
import java.util.*;
55
import java.util.Map.Entry;
56
import java.util.stream.Collectors;
57
 
30859 tejbeer 58
@Controller
35458 amit 59
@Transactional(rollbackFor = Throwable.class)
30859 tejbeer 60
public class SDCreditController {
61
 
32052 tejbeer 62
    @Autowired
63
    private RetailerService retailerService;
32439 tejbeer 64
 
32197 jai.hind 65
    @Autowired
66
    private UserService userService;
30859 tejbeer 67
 
32052 tejbeer 68
    @Autowired
69
    SDCreditRequirementRepository sdCreditRequirementRepository;
30859 tejbeer 70
 
32052 tejbeer 71
    @Autowired
72
    SanctionRequestRepository sanctionRequestRepository;
30859 tejbeer 73
 
32052 tejbeer 74
    @Autowired
75
    PartnerDailyInvestmentRepository partnerDailyInvestmentRepository;
30859 tejbeer 76
 
32052 tejbeer 77
    @Autowired
78
    private FofoStoreRepository fofoStoreRepository;
30859 tejbeer 79
 
32052 tejbeer 80
    @Autowired
81
    private CreditAccountRepository creditAccountRepository;
30859 tejbeer 82
 
32052 tejbeer 83
    @Autowired
84
    private SDCreditService sdCreditService;
30859 tejbeer 85
 
32052 tejbeer 86
    @Autowired
87
    private CsService1 csService1;
31666 amit.gupta 88
 
32052 tejbeer 89
    @Autowired
90
    private NotificationService notificationService;
30859 tejbeer 91
 
32052 tejbeer 92
    @Autowired
93
    private AuthRepository authRepository;
30859 tejbeer 94
 
32052 tejbeer 95
    @Autowired
96
    private UserRepository userRepository;
30859 tejbeer 97
 
32052 tejbeer 98
    @Autowired
99
    private CurrentPartnerDailyInvestmentRepository currentPartnerDailyInvestmentRepository;
30913 tejbeer 100
 
32052 tejbeer 101
    @Autowired
102
    private UserWalletRepository userWalletRepository;
30929 tejbeer 103
 
32052 tejbeer 104
    @Autowired
105
    LoanRepository loanRepository;
30929 tejbeer 106
 
32052 tejbeer 107
    @Autowired
108
    private CookiesProcessor cookiesProcessor;
30936 tejbeer 109
 
32052 tejbeer 110
    @Autowired
111
    private CsService csService;
30936 tejbeer 112
 
32052 tejbeer 113
    @Autowired
114
    AddressRepository addressRepository;
30989 tejbeer 115
 
32052 tejbeer 116
    @Autowired
117
    OrderRepository orderRepository;
31020 tejbeer 118
 
32052 tejbeer 119
    @Autowired
120
    private LoanStatementRepository loanStatementRepository;
31020 tejbeer 121
 
32052 tejbeer 122
    @Autowired
123
    private com.spice.profitmandi.dao.repository.user.UserRepository userUserRepository;
30989 tejbeer 124
 
32052 tejbeer 125
    @Autowired
126
    private JavaMailSender mailSender;
31020 tejbeer 127
 
32052 tejbeer 128
    @Autowired
129
    private MVCResponseSender mvcResponseSender;
31020 tejbeer 130
 
32528 tejbeer 131
    @Autowired
132
    private FofoOrderItemRepository fofoOrderItemRepository;
133
 
35534 amit 134
    @Autowired
135
    private com.spice.profitmandi.service.transaction.CreditBlockedExceptionPartnersRepository creditBlockedExceptionPartnersRepository;
136
 
32052 tejbeer 137
    private static final Logger LOGGER = LogManager.getLogger(SDCreditController.class);
30859 tejbeer 138
 
32052 tejbeer 139
    @RequestMapping(value = "/getSDCreditReq", method = RequestMethod.GET)
140
    public String getSDCreditReq(HttpServletRequest request, Model model) throws ProfitMandiBusinessException {
33854 tejus.loha 141
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
34969 ranu 142
        boolean isTarun = loginDetails.getEmailId().equals("tarun.verma@smartdukaan.com") || loginDetails.getEmailId().equals("kamini.sharma@smartdukaan.com");
30859 tejbeer 143
 
32052 tejbeer 144
        Map<Integer, CustomRetailer> customRetailerMap = retailerService.getFofoRetailers(true);
30859 tejbeer 145
 
32052 tejbeer 146
        Map<Integer, SDCreditRequirement> sdCreditRequirementMap = sdCreditRequirementRepository.selectAll().stream().collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
35811 amit 147
        Map<Integer, com.spice.profitmandi.dao.model.BulkCreditSummary> summaryMap = sdCreditService.getCreditSummaryBulk();
32052 tejbeer 148
        for (Entry<Integer, CustomRetailer> customRetailerEntry : customRetailerMap.entrySet()) {
149
            int fofoId = customRetailerEntry.getKey();
30859 tejbeer 150
 
35811 amit 151
            SDCreditRequirement sdCreditRequirement = sdCreditRequirementMap.get(fofoId);
30859 tejbeer 152
 
32052 tejbeer 153
            if (sdCreditRequirement != null) {
35811 amit 154
                com.spice.profitmandi.dao.model.BulkCreditSummary bulk = summaryMap.get(fofoId);
155
                BigDecimal utilizedLimit = bulk != null ? bulk.getUtilization() : BigDecimal.ZERO;
32052 tejbeer 156
                sdCreditRequirement.setUtilizedAmount(utilizedLimit);
157
            }
30859 tejbeer 158
 
32052 tejbeer 159
        }
30859 tejbeer 160
 
32052 tejbeer 161
        model.addAttribute("customRetailerMap", customRetailerMap);
162
        model.addAttribute("sdCreditRequirementMap", sdCreditRequirementMap);
33854 tejus.loha 163
        model.addAttribute("isTarun", isTarun);
32052 tejbeer 164
        return "sd-credit";
165
    }
30921 tejbeer 166
 
32052 tejbeer 167
    @RequestMapping(value = "/creditRequirement", method = RequestMethod.POST)
168
    public String sdCredit(HttpServletRequest request, @RequestBody SdCreditRequirementModel sdCreditRequirementModel, Model model) throws Exception {
30859 tejbeer 169
 
32052 tejbeer 170
        LOGGER.info("sdCreditRequirementModel {} ", sdCreditRequirementModel);
30859 tejbeer 171
 
32052 tejbeer 172
        int fofoId = sdCreditRequirementModel.getFofoId();
30859 tejbeer 173
 
35578 amit 174
        SDCreditRequirement sdCreditRequirement = sdCreditRequirementRepository.selectByFofoId(fofoId);
30859 tejbeer 175
 
32052 tejbeer 176
        sdCreditRequirement.setSecurityCheck(sdCreditRequirementModel.getSecurityCheck());
30859 tejbeer 177
 
33854 tejus.loha 178
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
34969 ranu 179
        boolean isTarun = loginDetails.getEmailId().equals("tarun.verma@smartdukaan.com") || loginDetails.getEmailId().equals("kamini.sharma@smartdukaan.com");
35313 amit 180
        sdCreditRequirement.setInterestRate(sdCreditRequirementModel.getInterest());
181
        sdCreditRequirement.setFreeDays(sdCreditRequirementModel.getFreeDays());
35395 amit 182
        BigDecimal utilizedLimit = sdCreditService.getUtilizationAmount(fofoId);
35313 amit 183
        sdCreditRequirement.setUtilizedAmount(utilizedLimit);
35578 amit 184
 
33854 tejus.loha 185
        if (isTarun) {
186
            if (sdCreditRequirement.getLimit() != sdCreditRequirementModel.getLimit()) {
35318 amit 187
                sdCreditRequirement.setLimit(sdCreditRequirementModel.getLimit());
33854 tejus.loha 188
                sdCreditRequirement.setHardLimit(true);
189
            }
35578 amit 190
        } else if (!sdCreditRequirement.isHardLimit()) {
191
            sdCreditRequirement.setLimit(sdCreditRequirementModel.getLimit());
33854 tejus.loha 192
        }
193
 
32052 tejbeer 194
        sdCreditRequirement.setCreditDays(15);
195
        sdCreditRequirement.setUpdateTimestamp(LocalDateTime.now());
30859 tejbeer 196
 
35578 amit 197
        // Calculate availableLimit AFTER limit may have changed
198
        BigDecimal availableLimit = sdCreditRequirement.getLimit().subtract(utilizedLimit);
199
 
32052 tejbeer 200
        if (sdCreditRequirement.getSecurityCheck() > 0) {
35578 amit 201
            CreditAccount creditAccount = creditAccountRepository.selectByFofoIdAndGateway(fofoId, Gateway.SDDIRECT);
32052 tejbeer 202
            if (creditAccount == null) {
203
                creditAccount = new CreditAccount();
35578 amit 204
                creditAccount.setFofoId(fofoId);
32052 tejbeer 205
                creditAccount.setGateway(Gateway.SDDIRECT);
206
                creditAccount.setCreditStatus(CreditStatus.SANCTIONED);
207
                creditAccount.setActive(false);
208
                creditAccount.setUpdatedOn(LocalDateTime.now());
209
                creditAccountRepository.persist(creditAccount);
210
            }
211
            creditAccount.setInterestRate(sdCreditRequirement.getInterestRate().floatValue());
212
            creditAccount.setSanctionedAmount(sdCreditRequirement.getLimit().floatValue());
213
            creditAccount.setAvailableAmount(availableLimit.floatValue());
214
            creditAccount.setFreeDays(sdCreditRequirement.getFreeDays());
215
            creditAccount.setUpdatedOn(LocalDateTime.now());
216
        }
217
        LOGGER.info("sdCreditRequirement {} ", sdCreditRequirement);
30859 tejbeer 218
 
35578 amit 219
        CustomRetailer customRetailer = retailerService.getFofoRetailer(fofoId);
30859 tejbeer 220
 
32052 tejbeer 221
        Map<Integer, SDCreditRequirement> sdCreditRequirementMap = new HashMap<>();
222
        sdCreditRequirementMap.put(sdCreditRequirement.getFofoId(), sdCreditRequirement);
223
        model.addAttribute("sdCreditRequirementMap", sdCreditRequirementMap);
224
        model.addAttribute("customRetailer", customRetailer);
33854 tejus.loha 225
        model.addAttribute("isTarun", isTarun);
30859 tejbeer 226
 
32052 tejbeer 227
        return "sd-credit-requirement-row";
30859 tejbeer 228
 
32052 tejbeer 229
    }
30859 tejbeer 230
 
33854 tejus.loha 231
    @RequestMapping(value = "/resetHardLimit", method = RequestMethod.PUT)
232
    public String resetHardLimit(HttpServletRequest request, @RequestParam int id, Model model) throws Exception {
233
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
34969 ranu 234
        if (loginDetails.getEmailId().equals("tarun.verma@smartdukaan.com") || loginDetails.getEmailId().equals("kamini.sharma@smartdukaan.com")) {
33854 tejus.loha 235
            SDCreditRequirement sdCreditRequirement = sdCreditRequirementRepository.selectById(id);
35274 amit 236
            sdCreditRequirement.setHardLimit(false);
35139 amit 237
            sdCreditRequirement.setLimit(sdCreditRequirement.getSuggestedLimit());
33854 tejus.loha 238
        }
239
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
240
        return "response";
241
    }
242
 
35534 amit 243
    @RequestMapping(value = "/addCreditBlockedException", method = RequestMethod.POST)
244
    public String addCreditBlockedException(HttpServletRequest request, @RequestParam int fofoId, Model model) throws Exception {
245
        LOGGER.info("Adding credit blocked exception for fofoId: {} for today", fofoId);
246
 
247
        CreditBlockedExceptionPartner existingException = creditBlockedExceptionPartnersRepository.select(fofoId);
248
        if (existingException != null && existingException.getOnDate().equals(LocalDate.now())) {
249
            LOGGER.info("Exception already exists for fofoId: {} for today", fofoId);
250
            model.addAttribute("response1", mvcResponseSender.createResponseString(true));
251
            return "response";
252
        }
253
 
254
        CreditBlockedExceptionPartner exception = new CreditBlockedExceptionPartner();
255
        exception.setFofoId(fofoId);
256
        exception.setOnDate(LocalDate.now());
257
        creditBlockedExceptionPartnersRepository.persist(exception);
258
 
259
        LOGGER.info("Credit blocked exception added successfully for fofoId: {}", fofoId);
260
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
261
        return "response";
262
    }
263
 
32052 tejbeer 264
    @RequestMapping(value = "/getSanctionRequest", method = RequestMethod.GET)
265
    public String getSanctionRequest(HttpServletRequest request, Model model) throws ProfitMandiBusinessException {
30859 tejbeer 266
 
34355 ranu 267
        List<SanctionRequest> sanctionRequests = sanctionRequestRepository.getL2ApprovedByDate(LocalDate.now(), SanctionStatus.APPROVED);
30859 tejbeer 268
 
32041 amit.gupta 269
 
32052 tejbeer 270
        if (!sanctionRequests.isEmpty()) {
30859 tejbeer 271
 
32053 tejbeer 272
            List<Integer> authIds = sanctionRequests.stream().map(x -> x.getAuthId()).collect(Collectors.toList());
273
 
35395 amit 274
            Map<Integer, String> authMap = authRepository.selectByIds(authIds).stream().collect(Collectors.toMap(x -> x.getId(), x -> x.getFullName()));
32053 tejbeer 275
 
276
 
32052 tejbeer 277
            List<Integer> fofoIds = sanctionRequests.stream().map(x -> x.getFofoId()).collect(Collectors.toList());
30859 tejbeer 278
 
32052 tejbeer 279
            Map<Integer, Long> partnerCreditDaysMap = new HashMap<>();
31110 tejbeer 280
 
32052 tejbeer 281
            Map<Integer, Integer> partnerActiveLoanMap = new HashMap<>();
32681 amit.gupta 282
            Map<Integer, Integer> partnerAverageCreditDaysMap = new HashMap<>();
31110 tejbeer 283
 
32528 tejbeer 284
            LocalDateTime curDate = LocalDate.now().atStartOfDay();
285
 
33505 amit.gupta 286
            /*Map<Integer, Double> lmtdSale = fofoOrderItemRepository.selectSumMopGroupByRetailer(
32528 tejbeer 287
                    curDate.withDayOfMonth(1).minusMonths(1), curDate.with(LocalTime.MAX).minusMonths(1), 0, false);
288
 
289
            Map<Integer, Double> mtdSale = fofoOrderItemRepository.selectSumMopGroupByRetailer(curDate.withDayOfMonth(1), curDate.with(LocalTime.MAX), 0, false);
290
 
291
            Map<Integer, Double> lmsSale = fofoOrderItemRepository.selectSumMopGroupByRetailer(
33505 amit.gupta 292
                    curDate.withDayOfMonth(1).minusMonths(1), curDate.withDayOfMonth(1), 0, false);*/
32528 tejbeer 293
 
33505 amit.gupta 294
            Map<Integer, Double> secondaryMtd = orderRepository
295
                    .selectBillingDatesBetweenSumGroupByRetailerId(curDate.withDayOfMonth(1), curDate.with(LocalTime.MAX));
296
            Map<Integer, Double> secondaryLmtd = orderRepository.selectBillingDatesBetweenSumGroupByRetailerId(
297
                    curDate.withDayOfMonth(1).minusMonths(1), curDate.with(LocalTime.MAX).minusMonths(1));
298
            Map<Integer, Double> secondaryLms = orderRepository.selectBillingDatesBetweenSumGroupByRetailerId(
299
                    curDate.withDayOfMonth(1).minusMonths(1), curDate.withDayOfMonth(1));
300
 
32681 amit.gupta 301
            List<Loan> loans = loanRepository.selectAllLoans(fofoIds, DateRangeModel.withStartDate(curDate.minusYears(2)));
33205 amit.gupta 302
            Map<Integer, List<Loan>> partnerClosedLoansMap = loans.stream().filter(x -> x.getPendingAmount().compareTo(BigDecimal.ZERO) == 0)
32740 amit.gupta 303
                    .collect(Collectors.groupingBy(x -> x.getFofoId()));
32528 tejbeer 304
 
31110 tejbeer 305
 
32740 amit.gupta 306
            Map<Integer, List<Loan>> activeLoansMap = loans.stream().filter(x -> x.getPendingAmount().compareTo(BigDecimal.ZERO) == 1).collect(Collectors.groupingBy(x -> x.getFofoId()));
32528 tejbeer 307
 
32681 amit.gupta 308
            for (Integer fofoId : fofoIds) {
32693 amit.gupta 309
                LOGGER.info("Fofo Id - {}", fofoId);
32681 amit.gupta 310
                List<Loan> activeLoans = activeLoansMap.get(fofoId);
311
                if (activeLoans != null) {
312
                    partnerActiveLoanMap.put(fofoId, activeLoans.size());
32742 amit.gupta 313
                    Loan loan = activeLoans.stream().sorted(Comparator.comparing(Loan::getCreatedOn)).findFirst().get();
32052 tejbeer 314
                    long daysBetween = Duration.between(loan.getCreatedOn(), LocalDateTime.now()).toDays();
315
                    partnerCreditDaysMap.put(fofoId, daysBetween);
316
                }
32681 amit.gupta 317
                List<Loan> closedLoans = partnerClosedLoansMap.get(fofoId);
318
                if (closedLoans != null) {
319
                    long averageCreditDays = Math.round(closedLoans.stream().mapToLong(x -> Duration.between(x.getCreatedOn(),
32683 amit.gupta 320
                            x.getSettledOn() == null ? x.getCreatedOn().plusDays(10) : x.getSettledOn()).toDays() + 1).average().orElse(0.0));
32681 amit.gupta 321
                    partnerAverageCreditDaysMap.put(fofoId, (int) averageCreditDays);
322
                }
31110 tejbeer 323
 
32052 tejbeer 324
            }
32681 amit.gupta 325
            model.addAttribute("partnerActiveLoanMap", partnerActiveLoanMap);
326
            model.addAttribute("partnerCreditDaysMap", partnerCreditDaysMap);
327
            model.addAttribute("partnerAverageCreditDaysMap", partnerAverageCreditDaysMap);
31110 tejbeer 328
 
32052 tejbeer 329
            Map<Integer, SDCreditRequirement> sdCreditRequirementMap = sdCreditRequirementRepository.selectAll().stream().collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
30967 tejbeer 330
 
32052 tejbeer 331
            Map<Integer, UserWallet> userWalletMap = userWalletRepository.selectByRetailerIds(new HashSet<>(fofoIds)).stream().collect(Collectors.toMap(x -> x.getUserId(), x -> x));
30859 tejbeer 332
 
32052 tejbeer 333
            Map<Integer, CustomRetailer> customRetailerMap = retailerService.getFofoRetailers(fofoIds);
334
            Map<Integer, PartnerDailyInvestment> partnerDailyInvestmentMap = partnerDailyInvestmentRepository.selectAll(fofoIds, LocalDate.now().minusDays(1)).stream().collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
35216 ranu 335
            LOGGER.info("partnerDailyInvestmentMap {}", partnerDailyInvestmentMap);
30859 tejbeer 336
 
32052 tejbeer 337
            model.addAttribute("customRetailerMap", customRetailerMap);
30859 tejbeer 338
 
32052 tejbeer 339
            model.addAttribute("partnerDailyInvestmentMap", partnerDailyInvestmentMap);
340
            model.addAttribute("sdCreditRequirementMap", sdCreditRequirementMap);
30859 tejbeer 341
 
32052 tejbeer 342
            model.addAttribute("userWalletMap", userWalletMap);
32053 tejbeer 343
            model.addAttribute("authMap", authMap);
33505 amit.gupta 344
            model.addAttribute("secondaryMtd", secondaryMtd);
345
            model.addAttribute("secondarylmtd", secondaryLmtd);
346
            model.addAttribute("secondarylms", secondaryLms);
31020 tejbeer 347
 
33354 amit.gupta 348
            List<CreditAccount> creditAccounts = creditAccountRepository.selectByFofoIds(fofoIds);
33854 tejus.loha 349
            model.addAttribute("creditAccounts", creditAccounts.stream().collect(Collectors.toMap(x -> x.getFofoId(), x -> x.getGateway())));
32052 tejbeer 350
        }
30859 tejbeer 351
 
32052 tejbeer 352
        model.addAttribute("sanctionRequests", sanctionRequests);
30859 tejbeer 353
 
32052 tejbeer 354
        model.addAttribute("sanctionStatus", SanctionStatus.values());
355
        return "sanction-request";
30859 tejbeer 356
 
32052 tejbeer 357
    }
30859 tejbeer 358
 
34355 ranu 359
 
360
    @RequestMapping(value = "/getRbmL2SanctionRequest", method = RequestMethod.GET)
361
    public String getRbmL2SanctionRequest(HttpServletRequest request, Model model) throws ProfitMandiBusinessException {
362
 
363
        List<SanctionRequest> sanctionRequests = sanctionRequestRepository.selectByDate(LocalDate.now());
364
 
365
 
366
        if (!sanctionRequests.isEmpty()) {
367
 
368
            List<Integer> authIds = sanctionRequests.stream().map(x -> x.getAuthId()).collect(Collectors.toList());
369
 
35395 amit 370
            Map<Integer, String> authMap = authRepository.selectByIds(authIds).stream().collect(Collectors.toMap(x -> x.getId(), x -> x.getFullName()));
34355 ranu 371
 
372
 
373
            List<Integer> fofoIds = sanctionRequests.stream().map(x -> x.getFofoId()).collect(Collectors.toList());
374
 
375
            Map<Integer, Long> partnerCreditDaysMap = new HashMap<>();
376
 
377
            Map<Integer, Integer> partnerActiveLoanMap = new HashMap<>();
378
            Map<Integer, Integer> partnerAverageCreditDaysMap = new HashMap<>();
379
 
380
            LocalDateTime curDate = LocalDate.now().atStartOfDay();
381
 
382
            Map<Integer, Double> secondaryMtd = orderRepository
383
                    .selectBillingDatesBetweenSumGroupByRetailerId(curDate.withDayOfMonth(1), curDate.with(LocalTime.MAX));
384
            Map<Integer, Double> secondaryLmtd = orderRepository.selectBillingDatesBetweenSumGroupByRetailerId(
385
                    curDate.withDayOfMonth(1).minusMonths(1), curDate.with(LocalTime.MAX).minusMonths(1));
386
            Map<Integer, Double> secondaryLms = orderRepository.selectBillingDatesBetweenSumGroupByRetailerId(
387
                    curDate.withDayOfMonth(1).minusMonths(1), curDate.withDayOfMonth(1));
388
 
389
            List<Loan> loans = loanRepository.selectAllLoans(fofoIds, DateRangeModel.withStartDate(curDate.minusYears(2)));
390
            Map<Integer, List<Loan>> partnerClosedLoansMap = loans.stream().filter(x -> x.getPendingAmount().compareTo(BigDecimal.ZERO) == 0)
391
                    .collect(Collectors.groupingBy(x -> x.getFofoId()));
392
 
393
 
394
            Map<Integer, List<Loan>> activeLoansMap = loans.stream().filter(x -> x.getPendingAmount().compareTo(BigDecimal.ZERO) == 1).collect(Collectors.groupingBy(x -> x.getFofoId()));
395
 
396
            for (Integer fofoId : fofoIds) {
397
                LOGGER.info("Fofo Id - {}", fofoId);
398
                List<Loan> activeLoans = activeLoansMap.get(fofoId);
399
                if (activeLoans != null) {
400
                    partnerActiveLoanMap.put(fofoId, activeLoans.size());
401
                    Loan loan = activeLoans.stream().sorted(Comparator.comparing(Loan::getCreatedOn)).findFirst().get();
402
                    long daysBetween = Duration.between(loan.getCreatedOn(), LocalDateTime.now()).toDays();
403
                    partnerCreditDaysMap.put(fofoId, daysBetween);
404
                }
405
                List<Loan> closedLoans = partnerClosedLoansMap.get(fofoId);
406
                if (closedLoans != null) {
407
                    long averageCreditDays = Math.round(closedLoans.stream().mapToLong(x -> Duration.between(x.getCreatedOn(),
408
                            x.getSettledOn() == null ? x.getCreatedOn().plusDays(10) : x.getSettledOn()).toDays() + 1).average().orElse(0.0));
409
                    partnerAverageCreditDaysMap.put(fofoId, (int) averageCreditDays);
410
                }
411
 
412
            }
413
            model.addAttribute("partnerActiveLoanMap", partnerActiveLoanMap);
414
            model.addAttribute("partnerCreditDaysMap", partnerCreditDaysMap);
415
            model.addAttribute("partnerAverageCreditDaysMap", partnerAverageCreditDaysMap);
416
 
417
            Map<Integer, SDCreditRequirement> sdCreditRequirementMap = sdCreditRequirementRepository.selectAll().stream().collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
418
 
419
            Map<Integer, UserWallet> userWalletMap = userWalletRepository.selectByRetailerIds(new HashSet<>(fofoIds)).stream().collect(Collectors.toMap(x -> x.getUserId(), x -> x));
420
 
421
            Map<Integer, CustomRetailer> customRetailerMap = retailerService.getFofoRetailers(fofoIds);
422
            Map<Integer, PartnerDailyInvestment> partnerDailyInvestmentMap = partnerDailyInvestmentRepository.selectAll(fofoIds, LocalDate.now().minusDays(1)).stream().collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
423
 
424
            model.addAttribute("customRetailerMap", customRetailerMap);
425
 
426
            model.addAttribute("partnerDailyInvestmentMap", partnerDailyInvestmentMap);
427
            model.addAttribute("sdCreditRequirementMap", sdCreditRequirementMap);
428
 
429
            model.addAttribute("userWalletMap", userWalletMap);
430
            model.addAttribute("authMap", authMap);
431
            model.addAttribute("secondaryMtd", secondaryMtd);
432
            model.addAttribute("secondarylmtd", secondaryLmtd);
433
            model.addAttribute("secondarylms", secondaryLms);
434
 
435
            List<CreditAccount> creditAccounts = creditAccountRepository.selectByFofoIds(fofoIds);
436
            model.addAttribute("creditAccounts", creditAccounts.stream().collect(Collectors.toMap(x -> x.getFofoId(), x -> x.getGateway())));
437
        }
438
 
439
        model.addAttribute("sanctionRequests", sanctionRequests);
440
 
441
        model.addAttribute("sanctionStatus", SanctionStatus.values());
442
        return "sanction-request-l2";
443
 
444
    }
445
 
32052 tejbeer 446
    @RequestMapping(value = "/sanctionRequest", method = RequestMethod.POST)
447
    public String sanctionRequest(HttpServletRequest request, @RequestBody SanctionRequestModel sanctionRequestModel, Model model) throws Exception {
30859 tejbeer 448
 
32052 tejbeer 449
        LOGGER.info("sanctionRequestModel {} ", sanctionRequestModel);
450
        Map<Integer, SDCreditRequirement> sdCreditRequirementMap = sdCreditRequirementRepository.selectAll().stream().collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
30859 tejbeer 451
 
32052 tejbeer 452
        SanctionRequest sanctionRequest = sanctionRequestRepository.selectById(sanctionRequestModel.getId());
30859 tejbeer 453
 
33205 amit.gupta 454
        Map<Integer, String> authMap = new HashMap<>();
32052 tejbeer 455
        AuthUser authUser = authRepository.selectById(sanctionRequest.getAuthId());
30859 tejbeer 456
 
32052 tejbeer 457
        authMap.put(authUser.getId(), authUser.getFullName());
30859 tejbeer 458
 
32052 tejbeer 459
        model.addAttribute("authMap", authMap);
460
        List<Integer> fofoIds = sanctionRequestRepository.selectByDate(LocalDate.now()).stream().map(x -> x.getFofoId()).collect(Collectors.toList());
30859 tejbeer 461
 
32052 tejbeer 462
        Map<Integer, CustomRetailer> customRetailerMap = retailerService.getFofoRetailers(fofoIds);
30859 tejbeer 463
 
32052 tejbeer 464
        LOGGER.info("freeDays {} ", sdCreditRequirementMap.get(sanctionRequest.getFofoId()).getFreeDays());
30989 tejbeer 465
 
32052 tejbeer 466
        if (sanctionRequestModel.getStatus().equals(SanctionStatus.APPROVED)) {
467
            CustomRetailer customRetailer = customRetailerMap.get(sanctionRequest.getFofoId());
468
            sanctionRequest.setApprovalTimestamp(LocalDateTime.now());
469
            BigDecimal availableAmount = sdCreditService.getAvailableAmount(sanctionRequest.getFofoId());
30989 tejbeer 470
 
32052 tejbeer 471
            String title = "Sanction Request Approved";
472
            String url = "http://app.smartdukaan.com/pages/home/credit";
473
            String message = "Congratulations! Your credit limit is increased for today Rs." + sanctionRequest.getApprovalAmount().setScale(2, RoundingMode.HALF_UP) + ". Your total available limit is Rs." + availableAmount.setScale(2, RoundingMode.HALF_UP) + ".";
474
            notificationService.sendNotification(sanctionRequest.getFofoId(), title, MessageType.notification, title, message, url);
475
            com.spice.profitmandi.dao.entity.user.User user = userUserRepository.selectById(sanctionRequest.getFofoId());
30859 tejbeer 476
 
32052 tejbeer 477
            Address address = addressRepository.selectById(user.getAddressId());
32777 amit.gupta 478
            //TODO-Whatsapp
479
            //notificationService.sendWhatsappMessage(message, title, address.getPhoneNumber());
30859 tejbeer 480
 
35210 vikas 481
            String empMessage = "Congratulations! Your Partner " + customRetailer.getBusinessName() + " credit limit is increased for today by Rs." + sanctionRequest.getApprovalAmount().setScale(2, RoundingMode.HALF_UP) + " and now the new total available limit is Rs." + availableAmount.setScale(2, RoundingMode.HALF_UP) + ".";
32052 tejbeer 482
            SendNotificationModel sendNotificationModel = new SendNotificationModel();
483
            sendNotificationModel.setCampaignName("Sanction Request");
484
            sendNotificationModel.setTitle("title");
485
            sendNotificationModel.setMessage(empMessage);
486
            sendNotificationModel.setType("url");
487
            sendNotificationModel.setUrl("https://app.smartdukaan.com/pages/home/credit");
488
            sendNotificationModel.setExpiresat(LocalDateTime.now().plusDays(2));
489
            sendNotificationModel.setMessageType(MessageType.notification);
490
            sendNotificationModel.setUserIds(Arrays.asList(userRepository.selectByEmailId(authUser.getEmailId()).getId()));
491
            System.out.println(sendNotificationModel);
492
            notificationService.sendNotification(sendNotificationModel);
30859 tejbeer 493
 
32840 amit.gupta 494
            //notificationService.sendWhatsappMessage(empMessage, title, authUser.getMobileNumber());
30859 tejbeer 495
 
32052 tejbeer 496
        }
30859 tejbeer 497
 
32135 tejbeer 498
        sanctionRequest.setFreeDays(sanctionRequestModel.getFreeDays());
30967 tejbeer 499
 
34125 ranu 500
        sanctionRequest.setApprovalAmount(sanctionRequestModel.getApprovalAmount());
501
        if (sanctionRequestModel.getApprovalAmount() == null) {
502
            sanctionRequest.setStatus(SanctionStatus.REJECTED);
34355 ranu 503
            sanctionRequest.setRbmL2ApprovalStatus(SanctionStatus.REJECTED);
34125 ranu 504
        } else {
505
            sanctionRequest.setStatus(sanctionRequestModel.getStatus());
506
        }
32135 tejbeer 507
 
32052 tejbeer 508
        sanctionRequest.setStockHold(sanctionRequestModel.isStockHold());
32683 amit.gupta 509
 
32528 tejbeer 510
        LocalDateTime curDate = LocalDate.now().atStartOfDay();
30967 tejbeer 511
 
33505 amit.gupta 512
        /*Map<Integer, Double> lmtdSale = fofoOrderItemRepository.selectSumMopGroupByRetailer(
32528 tejbeer 513
                curDate.withDayOfMonth(1).minusMonths(1), curDate.with(LocalTime.MAX).minusMonths(1), sanctionRequest.getFofoId(), false);
514
 
515
        Map<Integer, Double> mtdSale = fofoOrderItemRepository.selectSumMopGroupByRetailer(curDate.withDayOfMonth(1), curDate.with(LocalTime.MAX), sanctionRequest.getFofoId(), false);
516
 
517
        Map<Integer, Double> lmsSale = fofoOrderItemRepository.selectSumMopGroupByRetailer(
33505 amit.gupta 518
                curDate.withDayOfMonth(1).minusMonths(1), curDate.withDayOfMonth(1), sanctionRequest.getFofoId(), false);*/
32528 tejbeer 519
 
33505 amit.gupta 520
        Map<Integer, Double> secondaryMtd = orderRepository
521
                .selectBillingDatesBetweenSumGroupByRetailerId(curDate.withDayOfMonth(1), curDate.with(LocalTime.MAX));
522
        Map<Integer, Double> secondarylmtd = orderRepository.selectBillingDatesBetweenSumGroupByRetailerId(
523
                curDate.withDayOfMonth(1).minusMonths(1), curDate.with(LocalTime.MAX).minusMonths(1));
524
        Map<Integer, Double> secondarylms = orderRepository.selectBillingDatesBetweenSumGroupByRetailerId(
525
                curDate.withDayOfMonth(1).minusMonths(1), curDate.withDayOfMonth(1));
32528 tejbeer 526
 
32052 tejbeer 527
        Map<Integer, PartnerDailyInvestment> partnerDailyInvestmentMap = partnerDailyInvestmentRepository.selectAll(fofoIds, LocalDate.now().minusDays(1)).stream().collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
30859 tejbeer 528
 
32052 tejbeer 529
        Map<Integer, UserWallet> userWalletMap = userWalletRepository.selectByRetailerIds(new HashSet<>(fofoIds)).stream().collect(Collectors.toMap(x -> x.getUserId(), x -> x));
30859 tejbeer 530
 
32052 tejbeer 531
        sanctionRequest = sanctionRequestRepository.selectById(sanctionRequestModel.getId());
532
        model.addAttribute("customRetailerMap", customRetailerMap);
533
        model.addAttribute("sanctionRequest", sanctionRequest);
534
        model.addAttribute("partnerDailyInvestmentMap", partnerDailyInvestmentMap);
535
        model.addAttribute("sdCreditRequirementMap", sdCreditRequirementMap);
536
        model.addAttribute("userWalletMap", userWalletMap);
30859 tejbeer 537
 
32052 tejbeer 538
        model.addAttribute("sanctionStatus", SanctionStatus.values());
32683 amit.gupta 539
 
33505 amit.gupta 540
        model.addAttribute("secondarylmtd", secondarylmtd);
541
        model.addAttribute("secondaryMtd", secondaryMtd);
542
        model.addAttribute("secondarylms", secondarylms);
30859 tejbeer 543
 
33354 amit.gupta 544
        List<CreditAccount> creditAccounts = creditAccountRepository.selectByFofoIds(Arrays.asList(sanctionRequest.getFofoId()));
33854 tejus.loha 545
        model.addAttribute("creditAccounts", creditAccounts.stream().collect(Collectors.toMap(x -> x.getFofoId(), x -> x.getGateway())));
32052 tejbeer 546
        return "sanction-request-row";
30936 tejbeer 547
 
32052 tejbeer 548
    }
30929 tejbeer 549
 
34355 ranu 550
    @RequestMapping(value = "/rbmL2ApprovalSanctionRequest", method = RequestMethod.POST)
551
    public String rbmL2ApprovalSanctionRequest(HttpServletRequest request, @RequestBody SanctionRequestModel sanctionRequestModel, Model model) throws Exception {
34357 ranu 552
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
553
        AuthUser approverAuthUser = authRepository.selectByEmailOrMobile(loginDetails.getEmailId());
34355 ranu 554
        LOGGER.info("sanctionRequestModel {} ", sanctionRequestModel);
555
        Map<Integer, SDCreditRequirement> sdCreditRequirementMap = sdCreditRequirementRepository.selectAll().stream().collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
556
 
557
        SanctionRequest sanctionRequest = sanctionRequestRepository.selectById(sanctionRequestModel.getId());
558
 
559
        Map<Integer, String> authMap = new HashMap<>();
34357 ranu 560
 
34355 ranu 561
        AuthUser authUser = authRepository.selectById(sanctionRequest.getAuthId());
562
 
563
        authMap.put(authUser.getId(), authUser.getFullName());
564
 
565
        model.addAttribute("authMap", authMap);
566
        List<Integer> fofoIds = sanctionRequestRepository.selectByDate(LocalDate.now()).stream().map(x -> x.getFofoId()).collect(Collectors.toList());
567
 
568
        Map<Integer, CustomRetailer> customRetailerMap = retailerService.getFofoRetailers(fofoIds);
569
 
570
        LOGGER.info("freeDays {} ", sdCreditRequirementMap.get(sanctionRequest.getFofoId()).getFreeDays());
571
 
572
        if (sanctionRequestModel.getStatus().equals(SanctionStatus.APPROVED)) {
573
            sanctionRequest.setRbmL2ApprovalTimestamp(LocalDateTime.now());
34357 ranu 574
            sanctionRequest.setRbmL2ApproverEmail(approverAuthUser.getEmailId());
34355 ranu 575
        }
576
 
577
        sanctionRequest.setFreeDays(sanctionRequestModel.getFreeDays());
578
 
579
        sanctionRequest.setApprovalAmount(sanctionRequestModel.getApprovalAmount());
580
        if (sanctionRequestModel.getApprovalAmount() == null) {
581
 
582
            sanctionRequest.setStatus(SanctionStatus.REJECTED);
583
 
584
            sanctionRequest.setRbmL2ApprovalStatus(SanctionStatus.REJECTED);
585
            sanctionRequest.setRbmL2ApprovalTimestamp(LocalDateTime.now());
34357 ranu 586
            sanctionRequest.setRbmL2ApproverEmail(approverAuthUser.getEmailId());
34355 ranu 587
        } else {
588
            sanctionRequest.setRbmL2ApprovalStatus(sanctionRequestModel.getStatus());
589
        }
590
 
591
        sanctionRequest.setStockHold(sanctionRequestModel.isStockHold());
592
 
593
        LocalDateTime curDate = LocalDate.now().atStartOfDay();
594
 
595
 
596
        Map<Integer, Double> secondaryMtd = orderRepository
597
                .selectBillingDatesBetweenSumGroupByRetailerId(curDate.withDayOfMonth(1), curDate.with(LocalTime.MAX));
598
        Map<Integer, Double> secondarylmtd = orderRepository.selectBillingDatesBetweenSumGroupByRetailerId(
599
                curDate.withDayOfMonth(1).minusMonths(1), curDate.with(LocalTime.MAX).minusMonths(1));
600
        Map<Integer, Double> secondarylms = orderRepository.selectBillingDatesBetweenSumGroupByRetailerId(
601
                curDate.withDayOfMonth(1).minusMonths(1), curDate.withDayOfMonth(1));
602
 
603
        Map<Integer, PartnerDailyInvestment> partnerDailyInvestmentMap = partnerDailyInvestmentRepository.selectAll(fofoIds, LocalDate.now().minusDays(1)).stream().collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
604
 
605
        Map<Integer, UserWallet> userWalletMap = userWalletRepository.selectByRetailerIds(new HashSet<>(fofoIds)).stream().collect(Collectors.toMap(x -> x.getUserId(), x -> x));
606
 
607
        sanctionRequest = sanctionRequestRepository.selectById(sanctionRequestModel.getId());
608
        model.addAttribute("customRetailerMap", customRetailerMap);
609
        model.addAttribute("sanctionRequest", sanctionRequest);
610
        model.addAttribute("partnerDailyInvestmentMap", partnerDailyInvestmentMap);
611
        model.addAttribute("sdCreditRequirementMap", sdCreditRequirementMap);
612
        model.addAttribute("userWalletMap", userWalletMap);
613
 
614
        model.addAttribute("sanctionStatus", SanctionStatus.values());
615
 
616
        model.addAttribute("secondarylmtd", secondarylmtd);
617
        model.addAttribute("secondaryMtd", secondaryMtd);
618
        model.addAttribute("secondarylms", secondarylms);
619
 
620
        List<CreditAccount> creditAccounts = creditAccountRepository.selectByFofoIds(Arrays.asList(sanctionRequest.getFofoId()));
621
        model.addAttribute("creditAccounts", creditAccounts.stream().collect(Collectors.toMap(x -> x.getFofoId(), x -> x.getGateway())));
622
        return "rbm-l2-pending-sanction-request";
623
 
624
    }
625
 
32052 tejbeer 626
    List<String> emails = Arrays.asList("kamini.sharma@smartdukaan.com", "neeraj.gupta@smartdukaan.com", "amit.gupta@smartdukaan.com");
30929 tejbeer 627
 
32052 tejbeer 628
    @RequestMapping(value = "/getLoans", method = RequestMethod.GET)
629
    public String getLoans(HttpServletRequest request, Model model) throws ProfitMandiBusinessException {
30936 tejbeer 630
 
32052 tejbeer 631
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
632
        String email = loginDetails.getEmailId();
30936 tejbeer 633
 
32052 tejbeer 634
        AuthUser authUser = authRepository.selectByEmailOrMobile(email);
635
        Set<Integer> fofoIds = csService1.getAuthFofoIds(email, false);
30936 tejbeer 636
 
32052 tejbeer 637
        LOGGER.info("fofoIds" + fofoIds);
638
        if (fofoIds == null) {
639
            throw new ProfitMandiBusinessException("you are not authorized", "", "you are not authorized" + " " + "");
640
        }
30936 tejbeer 641
 
33827 ranu 642
        List<LoanCountByFofoIdModel> loanCountByFofoIdModels = loanRepository.getAllLoanCountByFofoId(fofoIds);
643
        Map<Integer, Long> loanCountMap = loanCountByFofoIdModels.stream().collect(Collectors.toMap(LoanCountByFofoIdModel::getFofoId, LoanCountByFofoIdModel::getLoanCount));
30929 tejbeer 644
 
33827 ranu 645
//        List<Loan> loans = loanRepository.selectAllLoans(new ArrayList<>(fofoIds));
30929 tejbeer 646
 
33827 ranu 647
        List<Integer> loanFofoIds = loanCountByFofoIdModels.stream().map(x -> x.getFofoId()).collect(Collectors.toList());
648
 
32052 tejbeer 649
        List<SDCreditRequirement> sdCreditRequirements = sdCreditRequirementRepository.selectByFofoIds(new ArrayList<>(loanFofoIds));
30929 tejbeer 650
 
35811 amit 651
        Map<Integer, com.spice.profitmandi.dao.model.BulkCreditSummary> summaryMap = sdCreditService.getCreditSummaryBulk();
652
        for (SDCreditRequirement req : sdCreditRequirements) {
653
            com.spice.profitmandi.dao.model.BulkCreditSummary bulk = summaryMap.get(req.getFofoId());
654
            if (bulk != null) {
655
                req.setUtilizedAmount(bulk.getUtilization());
656
            }
657
        }
30929 tejbeer 658
 
32052 tejbeer 659
        Map<Integer, UserWallet> userWalletMap = userWalletRepository.selectByRetailerIds(fofoIds).stream().collect(Collectors.toMap(x -> x.getUserId(), x -> x));
660
        Map<Integer, CurrentPartnerDailyInvestment> currentPartnerDailyInvestmentMap = currentPartnerDailyInvestmentRepository.selectAll().stream().collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
30929 tejbeer 661
 
32052 tejbeer 662
        model.addAttribute("userWalletMap", userWalletMap);
30929 tejbeer 663
 
32052 tejbeer 664
        model.addAttribute("currentPartnerDailyInvestmentMap", currentPartnerDailyInvestmentMap);
30929 tejbeer 665
 
32052 tejbeer 666
        Map<Integer, CustomRetailer> customRetailerMap = retailerService.getFofoRetailers(new ArrayList<>(fofoIds));
667
        model.addAttribute("sdCreditRequirements", sdCreditRequirements);
668
        model.addAttribute("loanCountMap", loanCountMap);
669
        model.addAttribute("customRetailerMap", customRetailerMap);
670
        return "loan-summary";
30929 tejbeer 671
 
32052 tejbeer 672
    }
32439 tejbeer 673
 
32197 jai.hind 674
    @RequestMapping(value = "/getPartnerWiseLoanSummary", method = RequestMethod.GET)
675
    public String getPartnerWiseLoanSummary(HttpServletRequest request, @RequestParam LoanSummaryType loanSummaryType, Model model) throws ProfitMandiBusinessException {
676
        Map<Integer, FofoReportingModel> fofoReportingModelMap = csService.getPartnerIdSalesHeaders();
33533 amit.gupta 677
        List<Loan> loans = loanRepository.selectAllActiveLoan();
678
        if (loanSummaryType.equals(LoanSummaryType.DEFAULT_LOAN)) {
33854 tejus.loha 679
            loans = loans.stream().filter(x -> x.isDefault()).collect(Collectors.toList());
32197 jai.hind 680
        } else if (loanSummaryType.equals(LoanSummaryType.DUE_LOAN)) {
33854 tejus.loha 681
            loans = loans.stream().filter(x -> x.isOverdue()).collect(Collectors.toList());
32197 jai.hind 682
        }
32439 tejbeer 683
        List<Integer> fofoIds = loans.stream().map(x -> x.getFofoId()).collect(Collectors.toList());
684
        Map<Integer, Double> fofoIdLoansMap = loans.stream().collect(Collectors.groupingBy(x -> x.getFofoId(), Collectors.summingDouble(x -> x.getPendingAmount().doubleValue())));
32197 jai.hind 685
        Map<Integer, CustomRetailer> customRetailerMap = retailerService.getFofoRetailers(fofoIds);
32528 tejbeer 686
        Map<Integer, Long> loanCountMap = loans.stream().collect(Collectors.groupingBy(x -> x.getFofoId(), Collectors.counting()));
32197 jai.hind 687
        model.addAttribute("customRetailerMap", customRetailerMap);
688
        model.addAttribute("loans", loans);
689
        model.addAttribute("fofoReportingModelMap", fofoReportingModelMap);
690
        model.addAttribute("fofoIdLoansMap", fofoIdLoansMap);
32456 jai.hind 691
        model.addAttribute("loanCountMap", loanCountMap);
32197 jai.hind 692
        return "partner-wise-loan-summary";
693
    }
694
 
35320 ranu 695
    @RequestMapping(value = "/getPartnerStateWiseLoanSummary", method = RequestMethod.GET)
35335 ranu 696
    public String getPartnerStateWiseLoanSummary(HttpServletRequest request, @RequestParam LoanSummaryType loanSummaryType, @RequestParam String stateName, @RequestParam(required = false) Integer fromDays, @RequestParam(required = false) Integer toDays, Model model) throws ProfitMandiBusinessException {
35320 ranu 697
        Map<Integer, FofoReportingModel> fofoReportingModelMap = csService.getPartnerIdSalesHeaders();
698
        List<Loan> loans = loanRepository.selectAllStateWiseActiveLoan(stateName);
699
        if (loanSummaryType.equals(LoanSummaryType.DEFAULT_LOAN)) {
700
            loans = loans.stream().filter(x -> x.isDefault()).collect(Collectors.toList());
701
        } else if (loanSummaryType.equals(LoanSummaryType.DUE_LOAN)) {
702
            loans = loans.stream().filter(x -> x.isOverdue()).collect(Collectors.toList());
703
        }
704
 
35335 ranu 705
        // Apply aging filter
706
        if (fromDays != null && toDays != null) {
35320 ranu 707
            loans = loans.stream()
35335 ranu 708
                    .filter(x -> x.getLoanAgeInDays() >= fromDays &&
709
                            x.getLoanAgeInDays() <= toDays)
35320 ranu 710
                    .collect(Collectors.toList());
35335 ranu 711
 
712
        } else if (fromDays != null) {
713
            loans = loans.stream()
714
                    .filter(x -> x.getLoanAgeInDays() >= fromDays)
715
                    .collect(Collectors.toList());
716
 
35320 ranu 717
        }
718
 
719
        List<Integer> fofoIds = loans.stream().map(x -> x.getFofoId()).collect(Collectors.toList());
720
        Map<Integer, Double> fofoIdLoansMap = loans.stream().collect(Collectors.groupingBy(x -> x.getFofoId(), Collectors.summingDouble(x -> x.getPendingAmount().doubleValue())));
721
        Map<Integer, CustomRetailer> customRetailerMap = retailerService.getFofoRetailers(fofoIds);
722
        Map<Integer, Long> loanCountMap = loans.stream().collect(Collectors.groupingBy(x -> x.getFofoId(), Collectors.counting()));
723
        model.addAttribute("customRetailerMap", customRetailerMap);
724
        model.addAttribute("loans", loans);
725
        model.addAttribute("fofoReportingModelMap", fofoReportingModelMap);
726
        model.addAttribute("fofoIdLoansMap", fofoIdLoansMap);
727
        model.addAttribute("loanCountMap", loanCountMap);
728
        return "partner-wise-loan-summary";
729
    }
730
 
32052 tejbeer 731
    @RequestMapping(value = "/getLoanSummary", method = RequestMethod.GET)
732
    public String getLoanSummary(HttpServletRequest request, @RequestParam int fofoId, Model model) throws ProfitMandiBusinessException {
30929 tejbeer 733
 
32052 tejbeer 734
        SDCreditResponseOut sdCreditResponseOut = sdCreditService.sdDirectService(fofoId);
735
        CustomRetailer customRetailer = retailerService.getFofoRetailer(fofoId);
30929 tejbeer 736
 
32052 tejbeer 737
        model.addAttribute("customRetailer", customRetailer);
738
        model.addAttribute("loanSummary", sdCreditResponseOut.getLoans());
30929 tejbeer 739
 
32052 tejbeer 740
        return "loan-summary-detail";
31020 tejbeer 741
 
32052 tejbeer 742
    }
31020 tejbeer 743
 
32439 tejbeer 744
    @RequestMapping(value = "/getSanctionUnholdOrder", method = RequestMethod.GET)
745
    public String getSanctionUnholdOrder(HttpServletRequest request, Model model) throws ProfitMandiBusinessException {
31020 tejbeer 746
 
32052 tejbeer 747
        List<Order> allOrders = orderRepository.selectHoldOrder();
31020 tejbeer 748
 
32439 tejbeer 749
        List<SanctionRequest> sanctionRequests = sanctionRequestRepository.selectHoldSanction();
31020 tejbeer 750
 
32442 tejbeer 751
 
752
        Map<Integer, CustomRetailer> customRetailerMap = retailerService.getAllFofoRetailers();
32052 tejbeer 753
        if (!allOrders.isEmpty()) {
754
            Map<Integer, Double> transactionAmountMap = allOrders.stream().collect(
755
                    Collectors.groupingBy(Order::getTransactionId, Collectors.summingDouble(x -> x.getTotalAmount())));
31020 tejbeer 756
 
32052 tejbeer 757
            Map<Integer, List<Order>> transactionOrdersMap = allOrders.stream().collect(Collectors.groupingBy(Order::getTransactionId, Collectors.toList()));
31020 tejbeer 758
 
759
 
32052 tejbeer 760
            model.addAttribute("transactionAmountMap", transactionAmountMap);
31020 tejbeer 761
 
32052 tejbeer 762
            model.addAttribute("transactionOrdersMap", transactionOrdersMap);
31020 tejbeer 763
 
32439 tejbeer 764
        }
765
        model.addAttribute("sanctionRequests", sanctionRequests);
31020 tejbeer 766
 
32442 tejbeer 767
        model.addAttribute("customRetailerMap", customRetailerMap);
31020 tejbeer 768
 
32442 tejbeer 769
 
32439 tejbeer 770
        return "sanction-order-unhold";
31020 tejbeer 771
 
32439 tejbeer 772
    }
31020 tejbeer 773
 
774
 
32439 tejbeer 775
    @RequestMapping(value = "/getSanctionHoldOrder", method = RequestMethod.GET)
776
    public String getSanctionHoldOrder(HttpServletRequest request, Model model) throws ProfitMandiBusinessException {
31020 tejbeer 777
 
32439 tejbeer 778
        List<Order> allOrders = orderRepository.selectHoldOrder();
31020 tejbeer 779
 
32439 tejbeer 780
        List<SanctionRequest> sanctionRequests = sanctionRequestRepository.selectHoldSanction();
32442 tejbeer 781
        Map<Integer, CustomRetailer> customRetailerMap = retailerService.getAllFofoRetailers();
31020 tejbeer 782
 
32439 tejbeer 783
        if (!allOrders.isEmpty()) {
784
            Map<Integer, Double> transactionAmountMap = allOrders.stream().collect(
785
                    Collectors.groupingBy(Order::getTransactionId, Collectors.summingDouble(x -> x.getTotalAmount())));
31020 tejbeer 786
 
32439 tejbeer 787
            Map<Integer, List<Order>> transactionOrdersMap = allOrders.stream().collect(Collectors.groupingBy(Order::getTransactionId, Collectors.toList()));
788
 
789
 
790
            model.addAttribute("transactionAmountMap", transactionAmountMap);
791
 
792
            model.addAttribute("transactionOrdersMap", transactionOrdersMap);
793
 
32052 tejbeer 794
        }
32439 tejbeer 795
        model.addAttribute("sanctionRequests", sanctionRequests);
32442 tejbeer 796
        model.addAttribute("customRetailerMap", customRetailerMap);
31020 tejbeer 797
 
32439 tejbeer 798
 
32052 tejbeer 799
        return "sanction-order-hold";
31020 tejbeer 800
 
32052 tejbeer 801
    }
31020 tejbeer 802
 
32052 tejbeer 803
    @RequestMapping(value = "/unholdOrder", method = RequestMethod.POST)
804
    public String unholdOrder(HttpServletRequest request, @RequestParam int transactionId, Model model) throws Exception {
31020 tejbeer 805
 
32052 tejbeer 806
        List<Order> orders = orderRepository.selectAllByTransactionId(transactionId);
31020 tejbeer 807
 
32455 tejbeer 808
        SanctionRequest sanctionRequest = sanctionRequestRepository.selectByTransactionId(transactionId);
809
 
810
 
32052 tejbeer 811
        LOGGER.info("orders" + orders);
31020 tejbeer 812
 
32455 tejbeer 813
        if (sanctionRequest != null) {
814
            sanctionRequest.setPendingAmount(BigDecimal.ZERO);
815
        }
816
 
32052 tejbeer 817
        if (!orders.isEmpty()) {
818
            orders.forEach(x -> x.setShipmentHold(false));
819
        }
31020 tejbeer 820
 
32052 tejbeer 821
        double totalAmount = orders.stream().collect(Collectors.summingDouble(x -> x.getTotalAmount()));
31020 tejbeer 822
 
32052 tejbeer 823
        try {
31020 tejbeer 824
 
32052 tejbeer 825
            List<String> authUserEmail = csService.getAuthUserIdByPartnerId(orders.get(0).getRetailerId()).stream().map(x -> x.getEmailId()).collect(Collectors.toList());
31020 tejbeer 826
 
32052 tejbeer 827
            authUserEmail.add("vinay.p@smartdukaan.com");
828
            authUserEmail.add("shivam.gupta@smartdukaan.com");
31020 tejbeer 829
 
32052 tejbeer 830
            String[] emailTo = authUserEmail.toArray(new String[authUserEmail.size()]);
31020 tejbeer 831
 
32052 tejbeer 832
            String[] ccTo = {"tarun.verma@smartdukaan.com", "kamini.sharma@smartdukaan.com"};
31020 tejbeer 833
 
32052 tejbeer 834
            String subject = "Dispatched " + (orders.get(0).getRetailerName());
835
            String message = String.format("Dear Team, \n" + "Kindly note the meterial for the " + orders.get(0).getRetailerName() + "of Rs." + totalAmount + " is dispatched.");
31020 tejbeer 836
 
32052 tejbeer 837
            LOGGER.info("message" + message);
31020 tejbeer 838
 
32052 tejbeer 839
            Utils.sendMailWithAttachments(mailSender, emailTo, ccTo, subject, message);
840
        } catch (Exception e) {
31020 tejbeer 841
 
32052 tejbeer 842
            e.printStackTrace();
31020 tejbeer 843
 
32052 tejbeer 844
        }
31020 tejbeer 845
 
32052 tejbeer 846
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
31020 tejbeer 847
 
32052 tejbeer 848
        return "response";
849
 
850
    }
851
 
33851 ranu 852
 
853
//    adjusting loan for specific loan if loan is not adjusting and other loan is adjusting
854
 
33858 ranu 855
    @RequestMapping(value = "/settle-loan/{fofoId}/{loanId}", method = RequestMethod.GET)
856
    public String settleAndCreateLoanById(HttpServletRequest request, @PathVariable int loanId, @PathVariable int fofoId, Model model) throws Exception {
33852 ranu 857
        Loan loan = loanRepository.selectByLoanId(loanId);
858
        double loanAmount = loan.getPendingAmount().doubleValue();
33851 ranu 859
 
860
        if (loanAmount > 0) {
861
            sdCreditService.createLoan(fofoId, loanAmount, 0, "Amount added for loan adjustment");
33852 ranu 862
            sdCreditService.settleLoan(loan);
33851 ranu 863
        }
864
 
865
 
866
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
867
 
868
        return "response";
869
 
870
    }
871
 
34588 ranu 872
    @RequestMapping(value = "/settle-negative-wallet/{fofoId}", method = RequestMethod.GET)
873
    public String settleNegativeWalletCreateLoanById(HttpServletRequest request, @PathVariable int fofoId, Model model) throws Exception {
874
        this.sdCreditService.fundWallet(fofoId);
33851 ranu 875
 
34588 ranu 876
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
877
 
878
        return "response";
879
 
880
    }
881
 
33851 ranu 882
    private void sendUnholdEmail(List<Order> orders) throws Exception {
883
 
884
 
885
        orders.forEach(x -> x.setShipmentHold(false));
886
        orders = orders.stream().filter(x -> x.getRefundTimestamp() != null).collect(Collectors.toList());
887
        if (orders.size() > 0) {
888
 
889
            double totalAmount = orders.stream().collect(Collectors.summingDouble(x -> x.getTotalAmount()));
890
 
891
            List<String> authUserEmail = csService.getAuthUserIdByPartnerId(orders.get(0).getRetailerId()).stream().map(x -> x.getEmailId()).collect(Collectors.toList());
892
            authUserEmail.add("vinay.p@smartdukaan.com");
893
            authUserEmail.add("shivam.gupta@smartdukaan.com");
894
 
895
            String[] emailTo = authUserEmail.toArray(new String[authUserEmail.size()]);
896
 
897
            String[] ccTo = {"tarun.verma@smartdukaan.com", "kamini.sharma@smartdukaan.com"};
898
 
899
            String subject = "Dispatch held orders of - " + (orders.get(0).getRetailerName());
900
            String message = String.format("Dear Team, \n" + "kindly note the material for the " + orders.get(0).getRetailerName() + "of Rs." + totalAmount + "is unhold now and needs to be dispatched.");
901
            Utils.sendMailWithAttachments(mailSender, emailTo, ccTo, subject, message);
902
        }
903
 
904
 
905
    }
906
 
30859 tejbeer 907
}