Subversion Repositories SmartDukaan

Rev

Rev 33354 | Rev 33505 | 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
            }
32681 amit.gupta 289
            model.addAttribute("partnerActiveLoanMap", partnerActiveLoanMap);
290
            model.addAttribute("partnerCreditDaysMap", partnerCreditDaysMap);
291
            model.addAttribute("partnerAverageCreditDaysMap", partnerAverageCreditDaysMap);
31110 tejbeer 292
 
32052 tejbeer 293
            Map<Integer, SDCreditRequirement> sdCreditRequirementMap = sdCreditRequirementRepository.selectAll().stream().collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
30967 tejbeer 294
 
32052 tejbeer 295
            Map<Integer, UserWallet> userWalletMap = userWalletRepository.selectByRetailerIds(new HashSet<>(fofoIds)).stream().collect(Collectors.toMap(x -> x.getUserId(), x -> x));
30859 tejbeer 296
 
32052 tejbeer 297
            Map<Integer, CustomRetailer> customRetailerMap = retailerService.getFofoRetailers(fofoIds);
298
            Map<Integer, PartnerDailyInvestment> partnerDailyInvestmentMap = partnerDailyInvestmentRepository.selectAll(fofoIds, LocalDate.now().minusDays(1)).stream().collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
30859 tejbeer 299
 
32052 tejbeer 300
            model.addAttribute("customRetailerMap", customRetailerMap);
30859 tejbeer 301
 
32052 tejbeer 302
            model.addAttribute("partnerDailyInvestmentMap", partnerDailyInvestmentMap);
303
            model.addAttribute("sdCreditRequirementMap", sdCreditRequirementMap);
30859 tejbeer 304
 
32052 tejbeer 305
            model.addAttribute("userWalletMap", userWalletMap);
32053 tejbeer 306
            model.addAttribute("authMap", authMap);
32528 tejbeer 307
            model.addAttribute("lmtdSale", lmtdSale);
308
            model.addAttribute("mtdSale", mtdSale);
309
            model.addAttribute("lmsSale", lmsSale);
31020 tejbeer 310
 
33354 amit.gupta 311
            List<CreditAccount> creditAccounts = creditAccountRepository.selectByFofoIds(fofoIds);
312
            model.addAttribute("creditAccounts", creditAccounts);
32052 tejbeer 313
        }
30859 tejbeer 314
 
32052 tejbeer 315
        model.addAttribute("sanctionRequests", sanctionRequests);
30859 tejbeer 316
 
32052 tejbeer 317
        model.addAttribute("sanctionStatus", SanctionStatus.values());
318
        return "sanction-request";
30859 tejbeer 319
 
32052 tejbeer 320
    }
30859 tejbeer 321
 
32052 tejbeer 322
    @RequestMapping(value = "/sanctionRequest", method = RequestMethod.POST)
323
    public String sanctionRequest(HttpServletRequest request, @RequestBody SanctionRequestModel sanctionRequestModel, Model model) throws Exception {
30859 tejbeer 324
 
32052 tejbeer 325
        LOGGER.info("sanctionRequestModel {} ", sanctionRequestModel);
326
        Map<Integer, SDCreditRequirement> sdCreditRequirementMap = sdCreditRequirementRepository.selectAll().stream().collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
30859 tejbeer 327
 
32052 tejbeer 328
        SanctionRequest sanctionRequest = sanctionRequestRepository.selectById(sanctionRequestModel.getId());
30859 tejbeer 329
 
33205 amit.gupta 330
        Map<Integer, String> authMap = new HashMap<>();
32052 tejbeer 331
        AuthUser authUser = authRepository.selectById(sanctionRequest.getAuthId());
30859 tejbeer 332
 
32052 tejbeer 333
        authMap.put(authUser.getId(), authUser.getFullName());
30859 tejbeer 334
 
32052 tejbeer 335
        model.addAttribute("authMap", authMap);
336
        List<Integer> fofoIds = sanctionRequestRepository.selectByDate(LocalDate.now()).stream().map(x -> x.getFofoId()).collect(Collectors.toList());
30859 tejbeer 337
 
32052 tejbeer 338
        Map<Integer, CustomRetailer> customRetailerMap = retailerService.getFofoRetailers(fofoIds);
30859 tejbeer 339
 
32052 tejbeer 340
        LOGGER.info("freeDays {} ", sdCreditRequirementMap.get(sanctionRequest.getFofoId()).getFreeDays());
30989 tejbeer 341
 
32052 tejbeer 342
        if (sanctionRequestModel.getStatus().equals(SanctionStatus.APPROVED)) {
343
            CustomRetailer customRetailer = customRetailerMap.get(sanctionRequest.getFofoId());
344
            sanctionRequest.setApprovalTimestamp(LocalDateTime.now());
345
            BigDecimal availableAmount = sdCreditService.getAvailableAmount(sanctionRequest.getFofoId());
30989 tejbeer 346
 
32052 tejbeer 347
            String title = "Sanction Request Approved";
348
            String url = "http://app.smartdukaan.com/pages/home/credit";
349
            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) + ".";
350
            notificationService.sendNotification(sanctionRequest.getFofoId(), title, MessageType.notification, title, message, url);
351
            com.spice.profitmandi.dao.entity.user.User user = userUserRepository.selectById(sanctionRequest.getFofoId());
30859 tejbeer 352
 
32052 tejbeer 353
            Address address = addressRepository.selectById(user.getAddressId());
32777 amit.gupta 354
            //TODO-Whatsapp
355
            //notificationService.sendWhatsappMessage(message, title, address.getPhoneNumber());
30859 tejbeer 356
 
32052 tejbeer 357
            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) + ".";
358
            SendNotificationModel sendNotificationModel = new SendNotificationModel();
359
            sendNotificationModel.setCampaignName("Sanction Request");
360
            sendNotificationModel.setTitle("title");
361
            sendNotificationModel.setMessage(empMessage);
362
            sendNotificationModel.setType("url");
363
            sendNotificationModel.setUrl("https://app.smartdukaan.com/pages/home/credit");
364
            sendNotificationModel.setExpiresat(LocalDateTime.now().plusDays(2));
365
            sendNotificationModel.setMessageType(MessageType.notification);
366
            sendNotificationModel.setUserIds(Arrays.asList(userRepository.selectByEmailId(authUser.getEmailId()).getId()));
367
            System.out.println(sendNotificationModel);
368
            notificationService.sendNotification(sendNotificationModel);
30859 tejbeer 369
 
32840 amit.gupta 370
            //notificationService.sendWhatsappMessage(empMessage, title, authUser.getMobileNumber());
30859 tejbeer 371
 
32052 tejbeer 372
        }
30859 tejbeer 373
 
32135 tejbeer 374
        sanctionRequest.setFreeDays(sanctionRequestModel.getFreeDays());
30967 tejbeer 375
 
32135 tejbeer 376
 
32052 tejbeer 377
        sanctionRequest.setApprovalAmount(sanctionRequestModel.getApprovalAmount());
378
        sanctionRequest.setStatus(sanctionRequestModel.getStatus());
379
        sanctionRequest.setStockHold(sanctionRequestModel.isStockHold());
32683 amit.gupta 380
 
32528 tejbeer 381
        LocalDateTime curDate = LocalDate.now().atStartOfDay();
30967 tejbeer 382
 
32528 tejbeer 383
        Map<Integer, Double> lmtdSale = fofoOrderItemRepository.selectSumMopGroupByRetailer(
384
                curDate.withDayOfMonth(1).minusMonths(1), curDate.with(LocalTime.MAX).minusMonths(1), sanctionRequest.getFofoId(), false);
385
 
386
        Map<Integer, Double> mtdSale = fofoOrderItemRepository.selectSumMopGroupByRetailer(curDate.withDayOfMonth(1), curDate.with(LocalTime.MAX), sanctionRequest.getFofoId(), false);
387
 
388
        Map<Integer, Double> lmsSale = fofoOrderItemRepository.selectSumMopGroupByRetailer(
389
                curDate.withDayOfMonth(1).minusMonths(1), curDate.withDayOfMonth(1), sanctionRequest.getFofoId(), false);
390
 
391
 
32052 tejbeer 392
        Map<Integer, PartnerDailyInvestment> partnerDailyInvestmentMap = partnerDailyInvestmentRepository.selectAll(fofoIds, LocalDate.now().minusDays(1)).stream().collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
30859 tejbeer 393
 
32052 tejbeer 394
        Map<Integer, UserWallet> userWalletMap = userWalletRepository.selectByRetailerIds(new HashSet<>(fofoIds)).stream().collect(Collectors.toMap(x -> x.getUserId(), x -> x));
30859 tejbeer 395
 
32052 tejbeer 396
        sanctionRequest = sanctionRequestRepository.selectById(sanctionRequestModel.getId());
397
        model.addAttribute("customRetailerMap", customRetailerMap);
398
        model.addAttribute("sanctionRequest", sanctionRequest);
399
        model.addAttribute("partnerDailyInvestmentMap", partnerDailyInvestmentMap);
400
        model.addAttribute("sdCreditRequirementMap", sdCreditRequirementMap);
401
        model.addAttribute("userWalletMap", userWalletMap);
30859 tejbeer 402
 
32052 tejbeer 403
        model.addAttribute("sanctionStatus", SanctionStatus.values());
32683 amit.gupta 404
 
32528 tejbeer 405
        model.addAttribute("lmtdSale", lmtdSale);
406
        model.addAttribute("mtdSale", mtdSale);
407
        model.addAttribute("lmsSale", lmsSale);
30859 tejbeer 408
 
33354 amit.gupta 409
        List<CreditAccount> creditAccounts = creditAccountRepository.selectByFofoIds(Arrays.asList(sanctionRequest.getFofoId()));
410
        model.addAttribute("creditAccounts", creditAccounts);
32052 tejbeer 411
        return "sanction-request-row";
30936 tejbeer 412
 
32052 tejbeer 413
    }
30929 tejbeer 414
 
32052 tejbeer 415
    List<String> emails = Arrays.asList("kamini.sharma@smartdukaan.com", "neeraj.gupta@smartdukaan.com", "amit.gupta@smartdukaan.com");
30929 tejbeer 416
 
32052 tejbeer 417
    @RequestMapping(value = "/getLoans", method = RequestMethod.GET)
418
    public String getLoans(HttpServletRequest request, Model model) throws ProfitMandiBusinessException {
30936 tejbeer 419
 
32052 tejbeer 420
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
421
        String email = loginDetails.getEmailId();
30936 tejbeer 422
 
32052 tejbeer 423
        AuthUser authUser = authRepository.selectByEmailOrMobile(email);
424
        Set<Integer> fofoIds = csService1.getAuthFofoIds(email, false);
30936 tejbeer 425
 
32052 tejbeer 426
        LOGGER.info("fofoIds" + fofoIds);
427
        if (fofoIds == null) {
428
            throw new ProfitMandiBusinessException("you are not authorized", "", "you are not authorized" + " " + "");
429
        }
30936 tejbeer 430
 
32052 tejbeer 431
        List<Loan> loans = loanRepository.selectAllLoans(new ArrayList<>(fofoIds));
30929 tejbeer 432
 
32052 tejbeer 433
        List<Integer> loanFofoIds = loans.stream().map(x -> x.getFofoId()).collect(Collectors.toList());
30929 tejbeer 434
 
32052 tejbeer 435
        List<SDCreditRequirement> sdCreditRequirements = sdCreditRequirementRepository.selectByFofoIds(new ArrayList<>(loanFofoIds));
30929 tejbeer 436
 
32052 tejbeer 437
        Map<Integer, Long> loanCountMap = loans.stream().collect(Collectors.groupingBy(x -> x.getFofoId(), Collectors.counting()));
32456 jai.hind 438
        LOGGER.info("loanCountMap" + loanCountMap);
30929 tejbeer 439
 
32052 tejbeer 440
        Map<Integer, UserWallet> userWalletMap = userWalletRepository.selectByRetailerIds(fofoIds).stream().collect(Collectors.toMap(x -> x.getUserId(), x -> x));
441
        Map<Integer, CurrentPartnerDailyInvestment> currentPartnerDailyInvestmentMap = currentPartnerDailyInvestmentRepository.selectAll().stream().collect(Collectors.toMap(x -> x.getFofoId(), x -> x));
30929 tejbeer 442
 
32052 tejbeer 443
        model.addAttribute("userWalletMap", userWalletMap);
30929 tejbeer 444
 
32052 tejbeer 445
        model.addAttribute("currentPartnerDailyInvestmentMap", currentPartnerDailyInvestmentMap);
30929 tejbeer 446
 
32052 tejbeer 447
        Map<Integer, CustomRetailer> customRetailerMap = retailerService.getFofoRetailers(new ArrayList<>(fofoIds));
448
        model.addAttribute("sdCreditRequirements", sdCreditRequirements);
449
        model.addAttribute("loanCountMap", loanCountMap);
450
        model.addAttribute("customRetailerMap", customRetailerMap);
451
        return "loan-summary";
30929 tejbeer 452
 
32052 tejbeer 453
    }
32439 tejbeer 454
 
32197 jai.hind 455
    @RequestMapping(value = "/getPartnerWiseLoanSummary", method = RequestMethod.GET)
456
    public String getPartnerWiseLoanSummary(HttpServletRequest request, @RequestParam LoanSummaryType loanSummaryType, Model model) throws ProfitMandiBusinessException {
457
        Map<Integer, FofoReportingModel> fofoReportingModelMap = csService.getPartnerIdSalesHeaders();
458
        List<Loan> loans = new ArrayList<>();
459
        List<Loan> activeLoans = loanRepository.selectAllActiveLoan();
460
        if (loanSummaryType.equals(LoanSummaryType.TOTAL_LOAN)) {
461
            loans.addAll(activeLoans);
462
        } else if (loanSummaryType.equals(LoanSummaryType.DEFAULT_LOAN)) {
463
            for (Loan loan : activeLoans) {
464
                long noOfdaysBetween = ChronoUnit.DAYS.between(loan.getDueDate().toLocalDate(), LocalDateTime.now());
465
                if (noOfdaysBetween > 15) {
466
                    loans.add(loan);
467
                }
468
            }
30929 tejbeer 469
 
32197 jai.hind 470
        } else if (loanSummaryType.equals(LoanSummaryType.DUE_LOAN)) {
471
            for (Loan loan : activeLoans) {
472
                long noOfdaysBetween = ChronoUnit.DAYS.between(loan.getDueDate().toLocalDate(), LocalDateTime.now());
473
                if (noOfdaysBetween <= 15 && noOfdaysBetween >= 0) {
474
                    loans.add(loan);
475
                }
476
            }
477
        }
32439 tejbeer 478
        List<Integer> fofoIds = loans.stream().map(x -> x.getFofoId()).collect(Collectors.toList());
479
        Map<Integer, Double> fofoIdLoansMap = loans.stream().collect(Collectors.groupingBy(x -> x.getFofoId(), Collectors.summingDouble(x -> x.getPendingAmount().doubleValue())));
32197 jai.hind 480
        Map<Integer, CustomRetailer> customRetailerMap = retailerService.getFofoRetailers(fofoIds);
32528 tejbeer 481
        Map<Integer, Long> loanCountMap = loans.stream().collect(Collectors.groupingBy(x -> x.getFofoId(), Collectors.counting()));
32197 jai.hind 482
        model.addAttribute("customRetailerMap", customRetailerMap);
483
        model.addAttribute("loans", loans);
484
        model.addAttribute("fofoReportingModelMap", fofoReportingModelMap);
485
        model.addAttribute("fofoIdLoansMap", fofoIdLoansMap);
32456 jai.hind 486
        model.addAttribute("loanCountMap", loanCountMap);
32197 jai.hind 487
        return "partner-wise-loan-summary";
488
    }
489
 
32052 tejbeer 490
    @RequestMapping(value = "/getLoanSummary", method = RequestMethod.GET)
491
    public String getLoanSummary(HttpServletRequest request, @RequestParam int fofoId, Model model) throws ProfitMandiBusinessException {
30929 tejbeer 492
 
32052 tejbeer 493
        SDCreditResponseOut sdCreditResponseOut = sdCreditService.sdDirectService(fofoId);
494
        CustomRetailer customRetailer = retailerService.getFofoRetailer(fofoId);
30929 tejbeer 495
 
32052 tejbeer 496
        model.addAttribute("customRetailer", customRetailer);
497
        model.addAttribute("loanSummary", sdCreditResponseOut.getLoans());
30929 tejbeer 498
 
32052 tejbeer 499
        return "loan-summary-detail";
31020 tejbeer 500
 
32052 tejbeer 501
    }
31020 tejbeer 502
 
32439 tejbeer 503
    @RequestMapping(value = "/getSanctionUnholdOrder", method = RequestMethod.GET)
504
    public String getSanctionUnholdOrder(HttpServletRequest request, Model model) throws ProfitMandiBusinessException {
31020 tejbeer 505
 
32052 tejbeer 506
        List<Order> allOrders = orderRepository.selectHoldOrder();
31020 tejbeer 507
 
32439 tejbeer 508
        List<SanctionRequest> sanctionRequests = sanctionRequestRepository.selectHoldSanction();
31020 tejbeer 509
 
32442 tejbeer 510
 
511
        Map<Integer, CustomRetailer> customRetailerMap = retailerService.getAllFofoRetailers();
32052 tejbeer 512
        if (!allOrders.isEmpty()) {
513
            Map<Integer, Double> transactionAmountMap = allOrders.stream().collect(
514
                    Collectors.groupingBy(Order::getTransactionId, Collectors.summingDouble(x -> x.getTotalAmount())));
31020 tejbeer 515
 
32052 tejbeer 516
            Map<Integer, List<Order>> transactionOrdersMap = allOrders.stream().collect(Collectors.groupingBy(Order::getTransactionId, Collectors.toList()));
31020 tejbeer 517
 
518
 
32052 tejbeer 519
            model.addAttribute("transactionAmountMap", transactionAmountMap);
31020 tejbeer 520
 
32052 tejbeer 521
            model.addAttribute("transactionOrdersMap", transactionOrdersMap);
31020 tejbeer 522
 
32439 tejbeer 523
        }
524
        model.addAttribute("sanctionRequests", sanctionRequests);
31020 tejbeer 525
 
32442 tejbeer 526
        model.addAttribute("customRetailerMap", customRetailerMap);
31020 tejbeer 527
 
32442 tejbeer 528
 
32439 tejbeer 529
        return "sanction-order-unhold";
31020 tejbeer 530
 
32439 tejbeer 531
    }
31020 tejbeer 532
 
533
 
32439 tejbeer 534
    @RequestMapping(value = "/getSanctionHoldOrder", method = RequestMethod.GET)
535
    public String getSanctionHoldOrder(HttpServletRequest request, Model model) throws ProfitMandiBusinessException {
31020 tejbeer 536
 
32439 tejbeer 537
        List<Order> allOrders = orderRepository.selectHoldOrder();
31020 tejbeer 538
 
32439 tejbeer 539
        List<SanctionRequest> sanctionRequests = sanctionRequestRepository.selectHoldSanction();
32442 tejbeer 540
        Map<Integer, CustomRetailer> customRetailerMap = retailerService.getAllFofoRetailers();
31020 tejbeer 541
 
32439 tejbeer 542
        if (!allOrders.isEmpty()) {
543
            Map<Integer, Double> transactionAmountMap = allOrders.stream().collect(
544
                    Collectors.groupingBy(Order::getTransactionId, Collectors.summingDouble(x -> x.getTotalAmount())));
31020 tejbeer 545
 
32439 tejbeer 546
            Map<Integer, List<Order>> transactionOrdersMap = allOrders.stream().collect(Collectors.groupingBy(Order::getTransactionId, Collectors.toList()));
547
 
548
 
549
            model.addAttribute("transactionAmountMap", transactionAmountMap);
550
 
551
            model.addAttribute("transactionOrdersMap", transactionOrdersMap);
552
 
32052 tejbeer 553
        }
32439 tejbeer 554
        model.addAttribute("sanctionRequests", sanctionRequests);
32442 tejbeer 555
        model.addAttribute("customRetailerMap", customRetailerMap);
31020 tejbeer 556
 
32439 tejbeer 557
 
32052 tejbeer 558
        return "sanction-order-hold";
31020 tejbeer 559
 
32052 tejbeer 560
    }
31020 tejbeer 561
 
32052 tejbeer 562
    @RequestMapping(value = "/unholdOrder", method = RequestMethod.POST)
563
    public String unholdOrder(HttpServletRequest request, @RequestParam int transactionId, Model model) throws Exception {
31020 tejbeer 564
 
32052 tejbeer 565
        List<Order> orders = orderRepository.selectAllByTransactionId(transactionId);
31020 tejbeer 566
 
32455 tejbeer 567
        SanctionRequest sanctionRequest = sanctionRequestRepository.selectByTransactionId(transactionId);
568
 
569
 
32052 tejbeer 570
        LOGGER.info("orders" + orders);
31020 tejbeer 571
 
32455 tejbeer 572
        if (sanctionRequest != null) {
573
            sanctionRequest.setPendingAmount(BigDecimal.ZERO);
574
        }
575
 
32052 tejbeer 576
        if (!orders.isEmpty()) {
577
            orders.forEach(x -> x.setShipmentHold(false));
578
        }
31020 tejbeer 579
 
32052 tejbeer 580
        double totalAmount = orders.stream().collect(Collectors.summingDouble(x -> x.getTotalAmount()));
31020 tejbeer 581
 
32052 tejbeer 582
        try {
31020 tejbeer 583
 
32052 tejbeer 584
            List<String> authUserEmail = csService.getAuthUserIdByPartnerId(orders.get(0).getRetailerId()).stream().map(x -> x.getEmailId()).collect(Collectors.toList());
31020 tejbeer 585
 
32052 tejbeer 586
            authUserEmail.add("vinay.p@smartdukaan.com");
587
            authUserEmail.add("shivam.gupta@smartdukaan.com");
31020 tejbeer 588
 
32052 tejbeer 589
            String[] emailTo = authUserEmail.toArray(new String[authUserEmail.size()]);
31020 tejbeer 590
 
32052 tejbeer 591
            String[] ccTo = {"tarun.verma@smartdukaan.com", "kamini.sharma@smartdukaan.com"};
31020 tejbeer 592
 
32052 tejbeer 593
            String subject = "Dispatched " + (orders.get(0).getRetailerName());
594
            String message = String.format("Dear Team, \n" + "Kindly note the meterial for the " + orders.get(0).getRetailerName() + "of Rs." + totalAmount + " is dispatched.");
31020 tejbeer 595
 
32052 tejbeer 596
            LOGGER.info("message" + message);
31020 tejbeer 597
 
32052 tejbeer 598
            Utils.sendMailWithAttachments(mailSender, emailTo, ccTo, subject, message);
599
        } catch (Exception e) {
31020 tejbeer 600
 
32052 tejbeer 601
            e.printStackTrace();
31020 tejbeer 602
 
32052 tejbeer 603
        }
31020 tejbeer 604
 
32052 tejbeer 605
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
31020 tejbeer 606
 
32052 tejbeer 607
        return "response";
608
 
609
    }
610
 
30859 tejbeer 611
}