Subversion Repositories SmartDukaan

Rev

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