Subversion Repositories SmartDukaan

Rev

Rev 33205 | Rev 33419 | Go to most recent revision | 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;
30859 tejbeer 12
import com.spice.profitmandi.dao.entity.fofo.PartnerDailyInvestment;
32681 amit.gupta 13
import com.spice.profitmandi.dao.entity.transaction.*;
30989 tejbeer 14
import com.spice.profitmandi.dao.entity.user.Address;
30859 tejbeer 15
import com.spice.profitmandi.dao.enumuration.fofo.Gateway;
32197 jai.hind 16
import com.spice.profitmandi.dao.enumuration.transaction.LoanSummaryType;
30859 tejbeer 17
import com.spice.profitmandi.dao.enumuration.transaction.SanctionStatus;
32681 amit.gupta 18
import com.spice.profitmandi.dao.model.*;
30859 tejbeer 19
import com.spice.profitmandi.dao.repository.auth.AuthRepository;
30936 tejbeer 20
import com.spice.profitmandi.dao.repository.cs.CsService;
31666 amit.gupta 21
import com.spice.profitmandi.dao.repository.cs.CsService1;
30859 tejbeer 22
import com.spice.profitmandi.dao.repository.dtr.CreditAccountRepository;
23
import com.spice.profitmandi.dao.repository.dtr.FofoStoreRepository;
24
import com.spice.profitmandi.dao.repository.dtr.UserRepository;
30913 tejbeer 25
import com.spice.profitmandi.dao.repository.fofo.CurrentPartnerDailyInvestmentRepository;
32528 tejbeer 26
import com.spice.profitmandi.dao.repository.fofo.FofoOrderItemRepository;
30859 tejbeer 27
import com.spice.profitmandi.dao.repository.fofo.PartnerDailyInvestmentRepository;
32681 amit.gupta 28
import com.spice.profitmandi.dao.repository.transaction.*;
30989 tejbeer 29
import com.spice.profitmandi.dao.repository.user.AddressRepository;
30859 tejbeer 30
import com.spice.profitmandi.service.NotificationService;
31
import com.spice.profitmandi.service.transaction.SDCreditService;
32
import com.spice.profitmandi.service.user.RetailerService;
32197 jai.hind 33
import com.spice.profitmandi.service.user.UserService;
30936 tejbeer 34
import com.spice.profitmandi.web.model.LoginDetails;
35
import com.spice.profitmandi.web.util.CookiesProcessor;
31020 tejbeer 36
import com.spice.profitmandi.web.util.MVCResponseSender;
32681 amit.gupta 37
import org.apache.logging.log4j.LogManager;
38
import org.apache.logging.log4j.Logger;
39
import org.springframework.beans.factory.annotation.Autowired;
40
import org.springframework.mail.javamail.JavaMailSender;
41
import org.springframework.stereotype.Controller;
42
import org.springframework.ui.Model;
43
import org.springframework.web.bind.annotation.RequestBody;
44
import org.springframework.web.bind.annotation.RequestMapping;
45
import org.springframework.web.bind.annotation.RequestMethod;
46
import org.springframework.web.bind.annotation.RequestParam;
30859 tejbeer 47
 
32681 amit.gupta 48
import javax.servlet.http.HttpServletRequest;
49
import javax.transaction.Transactional;
50
import java.math.BigDecimal;
51
import java.math.RoundingMode;
52
import java.time.Duration;
53
import java.time.LocalDate;
54
import java.time.LocalDateTime;
55
import java.time.LocalTime;
56
import java.time.temporal.ChronoUnit;
57
import java.util.*;
58
import java.util.Map.Entry;
59
import java.util.stream.Collectors;
60
 
30859 tejbeer 61
@Controller
62
@Transactional(rollbackOn = Throwable.class)
63
public class SDCreditController {
64
 
32052 tejbeer 65
    @Autowired
66
    private RetailerService retailerService;
32439 tejbeer 67
 
32197 jai.hind 68
    @Autowired
69
    private UserService userService;
30859 tejbeer 70
 
32052 tejbeer 71
    @Autowired
72
    SDCreditRequirementRepository sdCreditRequirementRepository;
30859 tejbeer 73
 
32052 tejbeer 74
    @Autowired
75
    SanctionRequestRepository sanctionRequestRepository;
30859 tejbeer 76
 
32052 tejbeer 77
    @Autowired
78
    PartnerDailyInvestmentRepository partnerDailyInvestmentRepository;
30859 tejbeer 79
 
32052 tejbeer 80
    @Autowired
81
    private FofoStoreRepository fofoStoreRepository;
30859 tejbeer 82
 
32052 tejbeer 83
    @Autowired
84
    private CreditAccountRepository creditAccountRepository;
30859 tejbeer 85
 
32052 tejbeer 86
    @Autowired
87
    private SDCreditService sdCreditService;
30859 tejbeer 88
 
32052 tejbeer 89
    @Autowired
90
    private CsService1 csService1;
31666 amit.gupta 91
 
32052 tejbeer 92
    @Autowired
93
    private NotificationService notificationService;
30859 tejbeer 94
 
32052 tejbeer 95
    @Autowired
96
    private AuthRepository authRepository;
30859 tejbeer 97
 
32052 tejbeer 98
    @Autowired
99
    private UserRepository userRepository;
30859 tejbeer 100
 
32052 tejbeer 101
    @Autowired
102
    private CurrentPartnerDailyInvestmentRepository currentPartnerDailyInvestmentRepository;
30913 tejbeer 103
 
32052 tejbeer 104
    @Autowired
105
    private UserWalletRepository userWalletRepository;
30929 tejbeer 106
 
32052 tejbeer 107
    @Autowired
108
    LoanRepository loanRepository;
30929 tejbeer 109
 
32052 tejbeer 110
    @Autowired
111
    private CookiesProcessor cookiesProcessor;
30936 tejbeer 112
 
32052 tejbeer 113
    @Autowired
114
    private CsService csService;
30936 tejbeer 115
 
32052 tejbeer 116
    @Autowired
117
    AddressRepository addressRepository;
30989 tejbeer 118
 
32052 tejbeer 119
    @Autowired
120
    OrderRepository orderRepository;
31020 tejbeer 121
 
32052 tejbeer 122
    @Autowired
123
    private LoanStatementRepository loanStatementRepository;
31020 tejbeer 124
 
32052 tejbeer 125
    @Autowired
126
    private com.spice.profitmandi.dao.repository.user.UserRepository userUserRepository;
30989 tejbeer 127
 
32052 tejbeer 128
    @Autowired
129
    private JavaMailSender mailSender;
31020 tejbeer 130
 
32052 tejbeer 131
    @Autowired
132
    private MVCResponseSender mvcResponseSender;
31020 tejbeer 133
 
32528 tejbeer 134
    @Autowired
135
    private FofoOrderItemRepository fofoOrderItemRepository;
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 {
30859 tejbeer 141
 
32052 tejbeer 142
        Map<Integer, CustomRetailer> customRetailerMap = retailerService.getFofoRetailers(true);
30859 tejbeer 143
 
32052 tejbeer 144
        Map<Integer, SDCreditRequirement> sdCreditRequirementMap = sdCreditRequirementRepository.selectAll().stream().collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
145
        for (Entry<Integer, CustomRetailer> customRetailerEntry : customRetailerMap.entrySet()) {
146
            int fofoId = customRetailerEntry.getKey();
30859 tejbeer 147
 
32052 tejbeer 148
            SDCreditRequirement sdCreditRequirement = sdCreditRequirementMap.get(customRetailerEntry.getKey());
30859 tejbeer 149
 
32052 tejbeer 150
            if (sdCreditRequirement != null) {
30913 tejbeer 151
 
32052 tejbeer 152
                BigDecimal utilizedLimit = new BigDecimal(sdCreditService.getUtilizationAmount(fofoId));
30910 tejbeer 153
 
32052 tejbeer 154
                BigDecimal availableLimit = sdCreditRequirement.getLimit().subtract(utilizedLimit);
30910 tejbeer 155
 
32052 tejbeer 156
                LOGGER.info("utilizedLimit {} ", utilizedLimit);
30910 tejbeer 157
 
32052 tejbeer 158
                LOGGER.info("availableLimit {} ", availableLimit);
30910 tejbeer 159
 
32052 tejbeer 160
                sdCreditRequirement.setUtilizedAmount(utilizedLimit);
30910 tejbeer 161
 
32052 tejbeer 162
                sdCreditRequirement.setUpdateTimestamp(LocalDateTime.now());
163
            }
30859 tejbeer 164
 
32052 tejbeer 165
        }
30859 tejbeer 166
 
32052 tejbeer 167
        model.addAttribute("customRetailerMap", customRetailerMap);
168
        model.addAttribute("sdCreditRequirementMap", sdCreditRequirementMap);
169
        return "sd-credit";
170
    }
30921 tejbeer 171
 
32052 tejbeer 172
    @RequestMapping(value = "/creditRequirement", method = RequestMethod.POST)
173
    public String sdCredit(HttpServletRequest request, @RequestBody SdCreditRequirementModel sdCreditRequirementModel, Model model) throws Exception {
30859 tejbeer 174
 
32052 tejbeer 175
        LOGGER.info("sdCreditRequirementModel {} ", sdCreditRequirementModel);
30859 tejbeer 176
 
32052 tejbeer 177
        int fofoId = sdCreditRequirementModel.getFofoId();
30859 tejbeer 178
 
32052 tejbeer 179
        SDCreditRequirement sdCreditRequirement = sdCreditRequirementRepository.selectByFofoId(sdCreditRequirementModel.getFofoId());
30859 tejbeer 180
 
32052 tejbeer 181
        sdCreditRequirement.setSecurityCheck(sdCreditRequirementModel.getSecurityCheck());
182
        // sdCreditRequirement.setSecurityCheck(2);
30859 tejbeer 183
 
32052 tejbeer 184
        sdCreditRequirement.setInterestRate(sdCreditRequirementModel.getInterest());
185
        sdCreditRequirement.setFreeDays(sdCreditRequirementModel.getFreeDays());
186
        sdCreditRequirement.setLimit(sdCreditRequirementModel.getLimit());
187
        BigDecimal utilizedLimit = new BigDecimal(sdCreditService.getUtilizationAmount(fofoId));
30865 tejbeer 188
 
32052 tejbeer 189
        BigDecimal availableLimit = sdCreditRequirement.getLimit().subtract(utilizedLimit);
30865 tejbeer 190
 
32052 tejbeer 191
        LOGGER.info("utilizedLimit {} ", utilizedLimit);
30909 tejbeer 192
 
32052 tejbeer 193
        LOGGER.info("availableLimit {} ", availableLimit);
30909 tejbeer 194
 
32052 tejbeer 195
        sdCreditRequirement.setUtilizedAmount(utilizedLimit);
30859 tejbeer 196
 
32052 tejbeer 197
        sdCreditRequirement.setCreditDays(15);
198
        sdCreditRequirement.setUpdateTimestamp(LocalDateTime.now());
30859 tejbeer 199
 
32052 tejbeer 200
        if (sdCreditRequirement.getSecurityCheck() > 0) {
30859 tejbeer 201
 
32052 tejbeer 202
            CreditAccount creditAccount = creditAccountRepository.selectByFofoIdAndGateway(sdCreditRequirementModel.getFofoId(), Gateway.SDDIRECT);
203
            if (creditAccount == null) {
204
                creditAccount = new CreditAccount();
205
                creditAccount.setFofoId(sdCreditRequirementModel.getFofoId());
206
                creditAccount.setGateway(Gateway.SDDIRECT);
207
                creditAccount.setCreditStatus(CreditStatus.SANCTIONED);
208
                creditAccount.setActive(false);
30859 tejbeer 209
 
32052 tejbeer 210
                creditAccount.setUpdatedOn(LocalDateTime.now());
30859 tejbeer 211
 
32052 tejbeer 212
                creditAccountRepository.persist(creditAccount);
213
            }
214
            creditAccount.setInterestRate(sdCreditRequirement.getInterestRate().floatValue());
215
            creditAccount.setSanctionedAmount(sdCreditRequirement.getLimit().floatValue());
216
            creditAccount.setAvailableAmount(availableLimit.floatValue());
217
            creditAccount.setFreeDays(sdCreditRequirement.getFreeDays());
218
            creditAccount.setUpdatedOn(LocalDateTime.now());
219
        }
220
        LOGGER.info("sdCreditRequirement {} ", sdCreditRequirement);
30859 tejbeer 221
 
32052 tejbeer 222
        CustomRetailer customRetailer = retailerService.getFofoRetailer(sdCreditRequirementModel.getFofoId());
30859 tejbeer 223
 
32052 tejbeer 224
        sdCreditRequirement = sdCreditRequirementRepository.selectByFofoId(sdCreditRequirementModel.getFofoId());
30865 tejbeer 225
 
32052 tejbeer 226
        Map<Integer, SDCreditRequirement> sdCreditRequirementMap = new HashMap<>();
227
        sdCreditRequirementMap.put(sdCreditRequirement.getFofoId(), sdCreditRequirement);
228
        model.addAttribute("sdCreditRequirementMap", sdCreditRequirementMap);
229
        model.addAttribute("customRetailer", customRetailer);
30859 tejbeer 230
 
32052 tejbeer 231
        return "sd-credit-requirement-row";
30859 tejbeer 232
 
32052 tejbeer 233
    }
30859 tejbeer 234
 
32052 tejbeer 235
    @RequestMapping(value = "/getSanctionRequest", method = RequestMethod.GET)
236
    public String getSanctionRequest(HttpServletRequest request, Model model) throws ProfitMandiBusinessException {
30859 tejbeer 237
 
32052 tejbeer 238
        List<SanctionRequest> sanctionRequests = sanctionRequestRepository.selectByDate(LocalDate.now());
30859 tejbeer 239
 
32041 amit.gupta 240
 
32052 tejbeer 241
        if (!sanctionRequests.isEmpty()) {
30859 tejbeer 242
 
32053 tejbeer 243
            List<Integer> authIds = sanctionRequests.stream().map(x -> x.getAuthId()).collect(Collectors.toList());
244
 
245
            Map<Integer, String> authMap = authRepository.selectAllAuthUserByIds(authIds).stream().collect(Collectors.toMap(x -> x.getId(), x -> x.getFullName()));
246
 
247
 
32052 tejbeer 248
            List<Integer> fofoIds = sanctionRequests.stream().map(x -> x.getFofoId()).collect(Collectors.toList());
30859 tejbeer 249
 
32052 tejbeer 250
            Map<Integer, Long> partnerCreditDaysMap = new HashMap<>();
31110 tejbeer 251
 
32052 tejbeer 252
            Map<Integer, Integer> partnerActiveLoanMap = new HashMap<>();
32681 amit.gupta 253
            Map<Integer, Integer> partnerAverageCreditDaysMap = new HashMap<>();
31110 tejbeer 254
 
32528 tejbeer 255
            LocalDateTime curDate = LocalDate.now().atStartOfDay();
256
 
257
            Map<Integer, Double> lmtdSale = fofoOrderItemRepository.selectSumMopGroupByRetailer(
258
                    curDate.withDayOfMonth(1).minusMonths(1), curDate.with(LocalTime.MAX).minusMonths(1), 0, false);
259
 
260
            Map<Integer, Double> mtdSale = fofoOrderItemRepository.selectSumMopGroupByRetailer(curDate.withDayOfMonth(1), curDate.with(LocalTime.MAX), 0, false);
261
 
262
            Map<Integer, Double> lmsSale = fofoOrderItemRepository.selectSumMopGroupByRetailer(
263
                    curDate.withDayOfMonth(1).minusMonths(1), curDate.withDayOfMonth(1), 0, false);
264
 
32681 amit.gupta 265
            List<Loan> loans = loanRepository.selectAllLoans(fofoIds, DateRangeModel.withStartDate(curDate.minusYears(2)));
33205 amit.gupta 266
            Map<Integer, List<Loan>> partnerClosedLoansMap = loans.stream().filter(x -> x.getPendingAmount().compareTo(BigDecimal.ZERO) == 0)
32740 amit.gupta 267
                    .collect(Collectors.groupingBy(x -> x.getFofoId()));
32528 tejbeer 268
 
31110 tejbeer 269
 
32740 amit.gupta 270
            Map<Integer, List<Loan>> activeLoansMap = loans.stream().filter(x -> x.getPendingAmount().compareTo(BigDecimal.ZERO) == 1).collect(Collectors.groupingBy(x -> x.getFofoId()));
32528 tejbeer 271
 
32681 amit.gupta 272
            for (Integer fofoId : fofoIds) {
32693 amit.gupta 273
                LOGGER.info("Fofo Id - {}", fofoId);
32681 amit.gupta 274
                List<Loan> activeLoans = activeLoansMap.get(fofoId);
275
                if (activeLoans != null) {
276
                    partnerActiveLoanMap.put(fofoId, activeLoans.size());
32742 amit.gupta 277
                    Loan loan = activeLoans.stream().sorted(Comparator.comparing(Loan::getCreatedOn)).findFirst().get();
32052 tejbeer 278
                    long daysBetween = Duration.between(loan.getCreatedOn(), LocalDateTime.now()).toDays();
279
                    partnerCreditDaysMap.put(fofoId, daysBetween);
280
                }
32681 amit.gupta 281
                List<Loan> closedLoans = partnerClosedLoansMap.get(fofoId);
282
                if (closedLoans != null) {
283
                    long averageCreditDays = Math.round(closedLoans.stream().mapToLong(x -> Duration.between(x.getCreatedOn(),
32683 amit.gupta 284
                            x.getSettledOn() == null ? x.getCreatedOn().plusDays(10) : x.getSettledOn()).toDays() + 1).average().orElse(0.0));
32681 amit.gupta 285
                    partnerAverageCreditDaysMap.put(fofoId, (int) averageCreditDays);
286
                }
31110 tejbeer 287
 
32052 tejbeer 288
            }
32693 amit.gupta 289
            LOGGER.info("partnerAverageCreditDaysMap - {}", partnerAverageCreditDaysMap);
32681 amit.gupta 290
            model.addAttribute("partnerActiveLoanMap", partnerActiveLoanMap);
291
            model.addAttribute("partnerCreditDaysMap", partnerCreditDaysMap);
292
            model.addAttribute("partnerAverageCreditDaysMap", partnerAverageCreditDaysMap);
31110 tejbeer 293
 
32052 tejbeer 294
            Map<Integer, SDCreditRequirement> sdCreditRequirementMap = sdCreditRequirementRepository.selectAll().stream().collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
30967 tejbeer 295
 
32052 tejbeer 296
            Map<Integer, UserWallet> userWalletMap = userWalletRepository.selectByRetailerIds(new HashSet<>(fofoIds)).stream().collect(Collectors.toMap(x -> x.getUserId(), x -> x));
30859 tejbeer 297
 
32052 tejbeer 298
            Map<Integer, CustomRetailer> customRetailerMap = retailerService.getFofoRetailers(fofoIds);
299
            Map<Integer, PartnerDailyInvestment> partnerDailyInvestmentMap = partnerDailyInvestmentRepository.selectAll(fofoIds, LocalDate.now().minusDays(1)).stream().collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
30859 tejbeer 300
 
32052 tejbeer 301
            model.addAttribute("customRetailerMap", customRetailerMap);
30859 tejbeer 302
 
32052 tejbeer 303
            model.addAttribute("partnerDailyInvestmentMap", partnerDailyInvestmentMap);
304
            model.addAttribute("sdCreditRequirementMap", sdCreditRequirementMap);
30859 tejbeer 305
 
32052 tejbeer 306
            model.addAttribute("userWalletMap", userWalletMap);
32053 tejbeer 307
            model.addAttribute("authMap", authMap);
32528 tejbeer 308
            model.addAttribute("lmtdSale", lmtdSale);
309
            model.addAttribute("mtdSale", mtdSale);
310
            model.addAttribute("lmsSale", lmsSale);
31020 tejbeer 311
 
33354 amit.gupta 312
            List<CreditAccount> creditAccounts = creditAccountRepository.selectByFofoIds(fofoIds);
313
            model.addAttribute("creditAccounts", creditAccounts);
32052 tejbeer 314
        }
30859 tejbeer 315
 
32052 tejbeer 316
        model.addAttribute("sanctionRequests", sanctionRequests);
30859 tejbeer 317
 
32052 tejbeer 318
        model.addAttribute("sanctionStatus", SanctionStatus.values());
319
        return "sanction-request";
30859 tejbeer 320
 
32052 tejbeer 321
    }
30859 tejbeer 322
 
32052 tejbeer 323
    @RequestMapping(value = "/sanctionRequest", method = RequestMethod.POST)
324
    public String sanctionRequest(HttpServletRequest request, @RequestBody SanctionRequestModel sanctionRequestModel, Model model) throws Exception {
30859 tejbeer 325
 
32052 tejbeer 326
        LOGGER.info("sanctionRequestModel {} ", sanctionRequestModel);
327
        Map<Integer, SDCreditRequirement> sdCreditRequirementMap = sdCreditRequirementRepository.selectAll().stream().collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
30859 tejbeer 328
 
32052 tejbeer 329
        SanctionRequest sanctionRequest = sanctionRequestRepository.selectById(sanctionRequestModel.getId());
30859 tejbeer 330
 
33205 amit.gupta 331
        Map<Integer, String> authMap = new HashMap<>();
32052 tejbeer 332
        AuthUser authUser = authRepository.selectById(sanctionRequest.getAuthId());
30859 tejbeer 333
 
32052 tejbeer 334
        authMap.put(authUser.getId(), authUser.getFullName());
30859 tejbeer 335
 
32052 tejbeer 336
        model.addAttribute("authMap", authMap);
337
        List<Integer> fofoIds = sanctionRequestRepository.selectByDate(LocalDate.now()).stream().map(x -> x.getFofoId()).collect(Collectors.toList());
30859 tejbeer 338
 
32052 tejbeer 339
        Map<Integer, CustomRetailer> customRetailerMap = retailerService.getFofoRetailers(fofoIds);
30859 tejbeer 340
 
32052 tejbeer 341
        LOGGER.info("freeDays {} ", sdCreditRequirementMap.get(sanctionRequest.getFofoId()).getFreeDays());
30989 tejbeer 342
 
32052 tejbeer 343
        if (sanctionRequestModel.getStatus().equals(SanctionStatus.APPROVED)) {
344
            CustomRetailer customRetailer = customRetailerMap.get(sanctionRequest.getFofoId());
345
            sanctionRequest.setApprovalTimestamp(LocalDateTime.now());
346
            BigDecimal availableAmount = sdCreditService.getAvailableAmount(sanctionRequest.getFofoId());
30989 tejbeer 347
 
32052 tejbeer 348
            String title = "Sanction Request Approved";
349
            String url = "http://app.smartdukaan.com/pages/home/credit";
350
            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) + ".";
351
            notificationService.sendNotification(sanctionRequest.getFofoId(), title, MessageType.notification, title, message, url);
352
            com.spice.profitmandi.dao.entity.user.User user = userUserRepository.selectById(sanctionRequest.getFofoId());
30859 tejbeer 353
 
32052 tejbeer 354
            Address address = addressRepository.selectById(user.getAddressId());
32777 amit.gupta 355
            //TODO-Whatsapp
356
            //notificationService.sendWhatsappMessage(message, title, address.getPhoneNumber());
30859 tejbeer 357
 
32052 tejbeer 358
            String empMessage = "Congratulations! Your Partner " + customRetailer.getBusinessName() + " credit limit is increased for today Rs." + sanctionRequest.getApprovalAmount().setScale(2, RoundingMode.HALF_UP) + " and total available limit is Rs." + availableAmount.setScale(2, RoundingMode.HALF_UP) + ".";
359
            SendNotificationModel sendNotificationModel = new SendNotificationModel();
360
            sendNotificationModel.setCampaignName("Sanction Request");
361
            sendNotificationModel.setTitle("title");
362
            sendNotificationModel.setMessage(empMessage);
363
            sendNotificationModel.setType("url");
364
            sendNotificationModel.setUrl("https://app.smartdukaan.com/pages/home/credit");
365
            sendNotificationModel.setExpiresat(LocalDateTime.now().plusDays(2));
366
            sendNotificationModel.setMessageType(MessageType.notification);
367
            sendNotificationModel.setUserIds(Arrays.asList(userRepository.selectByEmailId(authUser.getEmailId()).getId()));
368
            System.out.println(sendNotificationModel);
369
            notificationService.sendNotification(sendNotificationModel);
30859 tejbeer 370
 
32840 amit.gupta 371
            //notificationService.sendWhatsappMessage(empMessage, title, authUser.getMobileNumber());
30859 tejbeer 372
 
32052 tejbeer 373
        }
30859 tejbeer 374
 
32135 tejbeer 375
        sanctionRequest.setFreeDays(sanctionRequestModel.getFreeDays());
30967 tejbeer 376
 
32135 tejbeer 377
 
32052 tejbeer 378
        sanctionRequest.setApprovalAmount(sanctionRequestModel.getApprovalAmount());
379
        sanctionRequest.setStatus(sanctionRequestModel.getStatus());
380
        sanctionRequest.setStockHold(sanctionRequestModel.isStockHold());
32683 amit.gupta 381
 
32528 tejbeer 382
        LocalDateTime curDate = LocalDate.now().atStartOfDay();
30967 tejbeer 383
 
32528 tejbeer 384
        Map<Integer, Double> lmtdSale = fofoOrderItemRepository.selectSumMopGroupByRetailer(
385
                curDate.withDayOfMonth(1).minusMonths(1), curDate.with(LocalTime.MAX).minusMonths(1), sanctionRequest.getFofoId(), false);
386
 
387
        Map<Integer, Double> mtdSale = fofoOrderItemRepository.selectSumMopGroupByRetailer(curDate.withDayOfMonth(1), curDate.with(LocalTime.MAX), sanctionRequest.getFofoId(), false);
388
 
389
        Map<Integer, Double> lmsSale = fofoOrderItemRepository.selectSumMopGroupByRetailer(
390
                curDate.withDayOfMonth(1).minusMonths(1), curDate.withDayOfMonth(1), sanctionRequest.getFofoId(), false);
391
 
392
 
32052 tejbeer 393
        Map<Integer, PartnerDailyInvestment> partnerDailyInvestmentMap = partnerDailyInvestmentRepository.selectAll(fofoIds, LocalDate.now().minusDays(1)).stream().collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
30859 tejbeer 394
 
32052 tejbeer 395
        Map<Integer, UserWallet> userWalletMap = userWalletRepository.selectByRetailerIds(new HashSet<>(fofoIds)).stream().collect(Collectors.toMap(x -> x.getUserId(), x -> x));
30859 tejbeer 396
 
32052 tejbeer 397
        sanctionRequest = sanctionRequestRepository.selectById(sanctionRequestModel.getId());
398
        model.addAttribute("customRetailerMap", customRetailerMap);
399
        model.addAttribute("sanctionRequest", sanctionRequest);
400
        model.addAttribute("partnerDailyInvestmentMap", partnerDailyInvestmentMap);
401
        model.addAttribute("sdCreditRequirementMap", sdCreditRequirementMap);
402
        model.addAttribute("userWalletMap", userWalletMap);
30859 tejbeer 403
 
32052 tejbeer 404
        model.addAttribute("sanctionStatus", SanctionStatus.values());
32683 amit.gupta 405
 
32528 tejbeer 406
        model.addAttribute("lmtdSale", lmtdSale);
407
        model.addAttribute("mtdSale", mtdSale);
408
        model.addAttribute("lmsSale", lmsSale);
30859 tejbeer 409
 
33354 amit.gupta 410
        List<CreditAccount> creditAccounts = creditAccountRepository.selectByFofoIds(Arrays.asList(sanctionRequest.getFofoId()));
411
        model.addAttribute("creditAccounts", creditAccounts);
32052 tejbeer 412
        return "sanction-request-row";
30936 tejbeer 413
 
32052 tejbeer 414
    }
30929 tejbeer 415
 
32052 tejbeer 416
    List<String> emails = Arrays.asList("kamini.sharma@smartdukaan.com", "neeraj.gupta@smartdukaan.com", "amit.gupta@smartdukaan.com");
30929 tejbeer 417
 
32052 tejbeer 418
    @RequestMapping(value = "/getLoans", method = RequestMethod.GET)
419
    public String getLoans(HttpServletRequest request, Model model) throws ProfitMandiBusinessException {
30936 tejbeer 420
 
32052 tejbeer 421
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
422
        String email = loginDetails.getEmailId();
30936 tejbeer 423
 
32052 tejbeer 424
        AuthUser authUser = authRepository.selectByEmailOrMobile(email);
425
        Set<Integer> fofoIds = csService1.getAuthFofoIds(email, false);
30936 tejbeer 426
 
32052 tejbeer 427
        LOGGER.info("fofoIds" + fofoIds);
428
        if (fofoIds == null) {
429
            throw new ProfitMandiBusinessException("you are not authorized", "", "you are not authorized" + " " + "");
430
        }
30936 tejbeer 431
 
32052 tejbeer 432
        List<Loan> loans = loanRepository.selectAllLoans(new ArrayList<>(fofoIds));
30929 tejbeer 433
 
32052 tejbeer 434
        List<Integer> loanFofoIds = loans.stream().map(x -> x.getFofoId()).collect(Collectors.toList());
30929 tejbeer 435
 
32052 tejbeer 436
        List<SDCreditRequirement> sdCreditRequirements = sdCreditRequirementRepository.selectByFofoIds(new ArrayList<>(loanFofoIds));
30929 tejbeer 437
 
32052 tejbeer 438
        Map<Integer, Long> loanCountMap = loans.stream().collect(Collectors.groupingBy(x -> x.getFofoId(), Collectors.counting()));
32456 jai.hind 439
        LOGGER.info("loanCountMap" + loanCountMap);
30929 tejbeer 440
 
32052 tejbeer 441
        Map<Integer, UserWallet> userWalletMap = userWalletRepository.selectByRetailerIds(fofoIds).stream().collect(Collectors.toMap(x -> x.getUserId(), x -> x));
442
        Map<Integer, CurrentPartnerDailyInvestment> currentPartnerDailyInvestmentMap = currentPartnerDailyInvestmentRepository.selectAll().stream().collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
30929 tejbeer 443
 
32052 tejbeer 444
        model.addAttribute("userWalletMap", userWalletMap);
30929 tejbeer 445
 
32052 tejbeer 446
        model.addAttribute("currentPartnerDailyInvestmentMap", currentPartnerDailyInvestmentMap);
30929 tejbeer 447
 
32052 tejbeer 448
        Map<Integer, CustomRetailer> customRetailerMap = retailerService.getFofoRetailers(new ArrayList<>(fofoIds));
449
        model.addAttribute("sdCreditRequirements", sdCreditRequirements);
450
        model.addAttribute("loanCountMap", loanCountMap);
451
        model.addAttribute("customRetailerMap", customRetailerMap);
452
        return "loan-summary";
30929 tejbeer 453
 
32052 tejbeer 454
    }
32439 tejbeer 455
 
32197 jai.hind 456
    @RequestMapping(value = "/getPartnerWiseLoanSummary", method = RequestMethod.GET)
457
    public String getPartnerWiseLoanSummary(HttpServletRequest request, @RequestParam LoanSummaryType loanSummaryType, Model model) throws ProfitMandiBusinessException {
458
        Map<Integer, FofoReportingModel> fofoReportingModelMap = csService.getPartnerIdSalesHeaders();
459
        List<Loan> loans = new ArrayList<>();
460
        List<Loan> activeLoans = loanRepository.selectAllActiveLoan();
461
        if (loanSummaryType.equals(LoanSummaryType.TOTAL_LOAN)) {
462
            loans.addAll(activeLoans);
463
        } else if (loanSummaryType.equals(LoanSummaryType.DEFAULT_LOAN)) {
464
            for (Loan loan : activeLoans) {
465
                long noOfdaysBetween = ChronoUnit.DAYS.between(loan.getDueDate().toLocalDate(), LocalDateTime.now());
466
                if (noOfdaysBetween > 15) {
467
                    loans.add(loan);
468
                }
469
            }
30929 tejbeer 470
 
32197 jai.hind 471
        } else if (loanSummaryType.equals(LoanSummaryType.DUE_LOAN)) {
472
            for (Loan loan : activeLoans) {
473
                long noOfdaysBetween = ChronoUnit.DAYS.between(loan.getDueDate().toLocalDate(), LocalDateTime.now());
474
                if (noOfdaysBetween <= 15 && noOfdaysBetween >= 0) {
475
                    loans.add(loan);
476
                }
477
            }
478
        }
32439 tejbeer 479
        List<Integer> fofoIds = loans.stream().map(x -> x.getFofoId()).collect(Collectors.toList());
480
        Map<Integer, Double> fofoIdLoansMap = loans.stream().collect(Collectors.groupingBy(x -> x.getFofoId(), Collectors.summingDouble(x -> x.getPendingAmount().doubleValue())));
32197 jai.hind 481
        Map<Integer, CustomRetailer> customRetailerMap = retailerService.getFofoRetailers(fofoIds);
32528 tejbeer 482
        Map<Integer, Long> loanCountMap = loans.stream().collect(Collectors.groupingBy(x -> x.getFofoId(), Collectors.counting()));
32197 jai.hind 483
        model.addAttribute("customRetailerMap", customRetailerMap);
484
        model.addAttribute("loans", loans);
485
        model.addAttribute("fofoReportingModelMap", fofoReportingModelMap);
486
        model.addAttribute("fofoIdLoansMap", fofoIdLoansMap);
32456 jai.hind 487
        model.addAttribute("loanCountMap", loanCountMap);
32197 jai.hind 488
        return "partner-wise-loan-summary";
489
    }
490
 
32052 tejbeer 491
    @RequestMapping(value = "/getLoanSummary", method = RequestMethod.GET)
492
    public String getLoanSummary(HttpServletRequest request, @RequestParam int fofoId, Model model) throws ProfitMandiBusinessException {
30929 tejbeer 493
 
32052 tejbeer 494
        SDCreditResponseOut sdCreditResponseOut = sdCreditService.sdDirectService(fofoId);
495
        CustomRetailer customRetailer = retailerService.getFofoRetailer(fofoId);
30929 tejbeer 496
 
32052 tejbeer 497
        model.addAttribute("customRetailer", customRetailer);
498
        model.addAttribute("loanSummary", sdCreditResponseOut.getLoans());
30929 tejbeer 499
 
32052 tejbeer 500
        return "loan-summary-detail";
31020 tejbeer 501
 
32052 tejbeer 502
    }
31020 tejbeer 503
 
32439 tejbeer 504
    @RequestMapping(value = "/getSanctionUnholdOrder", method = RequestMethod.GET)
505
    public String getSanctionUnholdOrder(HttpServletRequest request, Model model) throws ProfitMandiBusinessException {
31020 tejbeer 506
 
32052 tejbeer 507
        List<Order> allOrders = orderRepository.selectHoldOrder();
31020 tejbeer 508
 
32439 tejbeer 509
        List<SanctionRequest> sanctionRequests = sanctionRequestRepository.selectHoldSanction();
31020 tejbeer 510
 
32442 tejbeer 511
 
512
        Map<Integer, CustomRetailer> customRetailerMap = retailerService.getAllFofoRetailers();
32052 tejbeer 513
        if (!allOrders.isEmpty()) {
514
            Map<Integer, Double> transactionAmountMap = allOrders.stream().collect(
515
                    Collectors.groupingBy(Order::getTransactionId, Collectors.summingDouble(x -> x.getTotalAmount())));
31020 tejbeer 516
 
32052 tejbeer 517
            Map<Integer, List<Order>> transactionOrdersMap = allOrders.stream().collect(Collectors.groupingBy(Order::getTransactionId, Collectors.toList()));
31020 tejbeer 518
 
519
 
32052 tejbeer 520
            model.addAttribute("transactionAmountMap", transactionAmountMap);
31020 tejbeer 521
 
32052 tejbeer 522
            model.addAttribute("transactionOrdersMap", transactionOrdersMap);
31020 tejbeer 523
 
32439 tejbeer 524
        }
525
        model.addAttribute("sanctionRequests", sanctionRequests);
31020 tejbeer 526
 
32442 tejbeer 527
        model.addAttribute("customRetailerMap", customRetailerMap);
31020 tejbeer 528
 
32442 tejbeer 529
 
32439 tejbeer 530
        return "sanction-order-unhold";
31020 tejbeer 531
 
32439 tejbeer 532
    }
31020 tejbeer 533
 
534
 
32439 tejbeer 535
    @RequestMapping(value = "/getSanctionHoldOrder", method = RequestMethod.GET)
536
    public String getSanctionHoldOrder(HttpServletRequest request, Model model) throws ProfitMandiBusinessException {
31020 tejbeer 537
 
32439 tejbeer 538
        List<Order> allOrders = orderRepository.selectHoldOrder();
31020 tejbeer 539
 
32439 tejbeer 540
        List<SanctionRequest> sanctionRequests = sanctionRequestRepository.selectHoldSanction();
32442 tejbeer 541
        Map<Integer, CustomRetailer> customRetailerMap = retailerService.getAllFofoRetailers();
31020 tejbeer 542
 
32439 tejbeer 543
        if (!allOrders.isEmpty()) {
544
            Map<Integer, Double> transactionAmountMap = allOrders.stream().collect(
545
                    Collectors.groupingBy(Order::getTransactionId, Collectors.summingDouble(x -> x.getTotalAmount())));
31020 tejbeer 546
 
32439 tejbeer 547
            Map<Integer, List<Order>> transactionOrdersMap = allOrders.stream().collect(Collectors.groupingBy(Order::getTransactionId, Collectors.toList()));
548
 
549
 
550
            model.addAttribute("transactionAmountMap", transactionAmountMap);
551
 
552
            model.addAttribute("transactionOrdersMap", transactionOrdersMap);
553
 
32052 tejbeer 554
        }
32439 tejbeer 555
        model.addAttribute("sanctionRequests", sanctionRequests);
32442 tejbeer 556
        model.addAttribute("customRetailerMap", customRetailerMap);
31020 tejbeer 557
 
32439 tejbeer 558
 
32052 tejbeer 559
        return "sanction-order-hold";
31020 tejbeer 560
 
32052 tejbeer 561
    }
31020 tejbeer 562
 
32052 tejbeer 563
    @RequestMapping(value = "/unholdOrder", method = RequestMethod.POST)
564
    public String unholdOrder(HttpServletRequest request, @RequestParam int transactionId, Model model) throws Exception {
31020 tejbeer 565
 
32052 tejbeer 566
        List<Order> orders = orderRepository.selectAllByTransactionId(transactionId);
31020 tejbeer 567
 
32455 tejbeer 568
        SanctionRequest sanctionRequest = sanctionRequestRepository.selectByTransactionId(transactionId);
569
 
570
 
32052 tejbeer 571
        LOGGER.info("orders" + orders);
31020 tejbeer 572
 
32455 tejbeer 573
        if (sanctionRequest != null) {
574
            sanctionRequest.setPendingAmount(BigDecimal.ZERO);
575
        }
576
 
32052 tejbeer 577
        if (!orders.isEmpty()) {
578
            orders.forEach(x -> x.setShipmentHold(false));
579
        }
31020 tejbeer 580
 
32052 tejbeer 581
        double totalAmount = orders.stream().collect(Collectors.summingDouble(x -> x.getTotalAmount()));
31020 tejbeer 582
 
32052 tejbeer 583
        try {
31020 tejbeer 584
 
32052 tejbeer 585
            List<String> authUserEmail = csService.getAuthUserIdByPartnerId(orders.get(0).getRetailerId()).stream().map(x -> x.getEmailId()).collect(Collectors.toList());
31020 tejbeer 586
 
32052 tejbeer 587
            authUserEmail.add("vinay.p@smartdukaan.com");
588
            authUserEmail.add("shivam.gupta@smartdukaan.com");
31020 tejbeer 589
 
32052 tejbeer 590
            String[] emailTo = authUserEmail.toArray(new String[authUserEmail.size()]);
31020 tejbeer 591
 
32052 tejbeer 592
            String[] ccTo = {"tarun.verma@smartdukaan.com", "kamini.sharma@smartdukaan.com"};
31020 tejbeer 593
 
32052 tejbeer 594
            String subject = "Dispatched " + (orders.get(0).getRetailerName());
595
            String message = String.format("Dear Team, \n" + "Kindly note the meterial for the " + orders.get(0).getRetailerName() + "of Rs." + totalAmount + " is dispatched.");
31020 tejbeer 596
 
32052 tejbeer 597
            LOGGER.info("message" + message);
31020 tejbeer 598
 
32052 tejbeer 599
            Utils.sendMailWithAttachments(mailSender, emailTo, ccTo, subject, message);
600
        } catch (Exception e) {
31020 tejbeer 601
 
32052 tejbeer 602
            e.printStackTrace();
31020 tejbeer 603
 
32052 tejbeer 604
        }
31020 tejbeer 605
 
32052 tejbeer 606
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
31020 tejbeer 607
 
32052 tejbeer 608
        return "response";
609
 
610
    }
611
 
30859 tejbeer 612
}