Subversion Repositories SmartDukaan

Rev

Rev 36937 | Go to most recent revision | Details | Compare with Previous | Last modification | View Log | RSS feed

Rev Author Line No. Line
21612 ashik.ali 1
package com.spice.profitmandi.web.controller;
2
 
26817 amit.gupta 3
import com.google.gson.Gson;
23203 ashik.ali 4
import com.spice.profitmandi.common.enumuration.SearchType;
21612 ashik.ali 5
import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
30322 amit.gupta 6
import com.spice.profitmandi.common.model.*;
28339 tejbeer 7
import com.spice.profitmandi.common.solr.SolrService;
33213 tejus.loha 8
import com.spice.profitmandi.common.util.FileUtil;
21689 ashik.ali 9
import com.spice.profitmandi.common.util.PdfUtils;
23638 amit.gupta 10
import com.spice.profitmandi.common.util.StringUtils;
22244 ashik.ali 11
import com.spice.profitmandi.common.web.util.ResponseSender;
33213 tejus.loha 12
import com.spice.profitmandi.dao.entity.auth.AuthUser;
33795 ranu 13
import com.spice.profitmandi.dao.entity.catalog.CustomerOffer;
14
import com.spice.profitmandi.dao.entity.catalog.CustomerOfferItem;
23638 amit.gupta 15
import com.spice.profitmandi.dao.entity.catalog.Item;
27861 tejbeer 16
import com.spice.profitmandi.dao.entity.catalog.TagListing;
33400 ranu 17
import com.spice.profitmandi.dao.entity.cs.Position;
34798 ranu 18
import com.spice.profitmandi.dao.entity.dtr.*;
30322 amit.gupta 19
import com.spice.profitmandi.dao.entity.fofo.*;
34194 ranu 20
import com.spice.profitmandi.dao.entity.transaction.EInvoiceDetails;
21
import com.spice.profitmandi.dao.entity.transaction.Order;
22
import com.spice.profitmandi.dao.entity.transaction.TransactionApproval;
23
import com.spice.profitmandi.dao.entity.transaction.UserWalletHistory;
23298 ashik.ali 24
import com.spice.profitmandi.dao.entity.user.Address;
33400 ranu 25
import com.spice.profitmandi.dao.enumuration.cs.EscalationType;
23548 ashik.ali 26
import com.spice.profitmandi.dao.enumuration.dtr.PaymentOptionReferenceType;
36519 aman 27
import com.spice.profitmandi.dao.enumuration.dtr.StoreTimeline;
27046 tejbeer 28
import com.spice.profitmandi.dao.enumuration.transaction.OrderStatus;
33213 tejus.loha 29
import com.spice.profitmandi.dao.enumuration.transaction.TransactionApprovalStatus;
34788 ranu 30
import com.spice.profitmandi.dao.model.ItemWiseCustomerOfferSummaryModel;
34168 tejus.loha 31
import com.spice.profitmandi.dao.model.hdfc.IrnResetOrderModel;
33213 tejus.loha 32
import com.spice.profitmandi.dao.repository.auth.AuthRepository;
33795 ranu 33
import com.spice.profitmandi.dao.repository.catalog.*;
33400 ranu 34
import com.spice.profitmandi.dao.repository.cs.PositionRepository;
30322 amit.gupta 35
import com.spice.profitmandi.dao.repository.dtr.*;
36
import com.spice.profitmandi.dao.repository.fofo.*;
24440 amit.gupta 37
import com.spice.profitmandi.dao.repository.inventory.StateRepository;
33336 tejus.loha 38
import com.spice.profitmandi.dao.repository.transaction.*;
23298 ashik.ali 39
import com.spice.profitmandi.dao.repository.user.AddressRepository;
33336 tejus.loha 40
import com.spice.profitmandi.dao.repository.user.CartRepository;
34474 aman.kumar 41
import com.spice.profitmandi.dao.service.ScratchService;
28377 tejbeer 42
import com.spice.profitmandi.service.EmailService;
32251 amit.gupta 43
import com.spice.profitmandi.service.NotificationService;
23798 amit.gupta 44
import com.spice.profitmandi.service.authentication.RoleManager;
34798 ranu 45
import com.spice.profitmandi.service.integrations.bharti.model.PlanVariant;
46
import com.spice.profitmandi.service.integrations.icicilombard.IciciLombardService;
47
import com.spice.profitmandi.service.integrations.icicilombard.model.AfinityQuoteModel;
34805 ranu 48
import com.spice.profitmandi.service.integrations.icicilombard.model.AfinityQuoteResponseModel;
35269 ranu 49
import com.spice.profitmandi.service.integrations.oneassist.OneAssistService;
50
import com.spice.profitmandi.service.integrations.oneassist.model.CancelPlanRequestModel;
35971 aman 51
import com.spice.profitmandi.service.integrations.pinelabs.PinelabsOfferCacheService;
52
import com.spice.profitmandi.service.integrations.pinelabs.dto.Tenure;
25726 amit.gupta 53
import com.spice.profitmandi.service.integrations.zest.InsuranceService;
24440 amit.gupta 54
import com.spice.profitmandi.service.integrations.zest.MobileInsurancePlan;
33172 tejus.loha 55
import com.spice.profitmandi.service.order.BulkOrderService;
23366 ashik.ali 56
import com.spice.profitmandi.service.order.OrderService;
22069 ashik.ali 57
import com.spice.profitmandi.service.pricing.PricingService;
33696 amit.gupta 58
import com.spice.profitmandi.service.transaction.SDCreditService;
33213 tejus.loha 59
import com.spice.profitmandi.service.transaction.TransactionService;
26647 tejbeer 60
import com.spice.profitmandi.service.user.RetailerService;
33336 tejus.loha 61
import com.spice.profitmandi.service.wallet.WalletService;
32405 jai.hind 62
import com.spice.profitmandi.service.whatsapp.WhatsappMessageService;
22139 amit.gupta 63
import com.spice.profitmandi.web.model.LoginDetails;
22069 ashik.ali 64
import com.spice.profitmandi.web.util.CookiesProcessor;
24105 govind 65
import com.spice.profitmandi.web.util.MVCResponseSender;
33336 tejus.loha 66
import in.shop2020.model.v1.order.WalletReferenceType;
30148 amit.gupta 67
import org.apache.logging.log4j.LogManager;
68
import org.apache.logging.log4j.Logger;
32405 jai.hind 69
import org.json.JSONArray;
30148 amit.gupta 70
import org.json.JSONObject;
71
import org.springframework.beans.factory.annotation.Autowired;
72
import org.springframework.core.io.InputStreamResource;
73
import org.springframework.http.HttpHeaders;
74
import org.springframework.http.HttpStatus;
75
import org.springframework.http.MediaType;
76
import org.springframework.http.ResponseEntity;
77
import org.springframework.stereotype.Controller;
78
import org.springframework.transaction.annotation.Transactional;
79
import org.springframework.ui.Model;
80
import org.springframework.web.bind.annotation.*;
33172 tejus.loha 81
import org.springframework.web.multipart.MultipartFile;
21612 ashik.ali 82
 
33336 tejus.loha 83
import javax.mail.MessagingException;
30148 amit.gupta 84
import javax.servlet.http.HttpServletRequest;
85
import javax.servlet.http.HttpServletResponse;
34805 ranu 86
import java.io.*;
87
import java.nio.file.Files;
33367 ranu 88
import java.time.LocalDate;
30148 amit.gupta 89
import java.time.LocalDateTime;
90
import java.time.format.DateTimeFormatter;
91
import java.time.temporal.ChronoUnit;
92
import java.util.*;
93
import java.util.stream.Collectors;
94
 
21612 ashik.ali 95
@Controller
23973 govind 96
@Transactional(rollbackFor = Throwable.class)
21612 ashik.ali 97
public class OrderController {
98
 
33213 tejus.loha 99
    private static final Logger LOGGER = LogManager.getLogger(OrderController.class);
21985 kshitij.so 100
 
33213 tejus.loha 101
    private static final List<String> offlineOrders = Arrays.asList("EMIOD", "POD");
102
    private static final List<String> allowedDoaImeis = Arrays.asList("863903054378477");
103
    @Autowired
104
    NotificationService notificationService;
105
    @Autowired
106
    TransactionApprovalRepository transactionApprovalRepository;
107
    @Autowired
108
    LineItemRepository lineItemRepository;
109
    @Autowired
110
    AuthRepository authRepository;
111
    @Autowired
112
    TransactionService transactionService;
113
    @Autowired
114
    BulkOrderService bulkOrderService;
115
    @Autowired
116
    private CustomerRepository customerRepository;
35737 amit 117
    private static final boolean accessoriesDeals = true;
33213 tejus.loha 118
    @Autowired
119
    private RoleManager roleManager;
120
    @Autowired
121
    private Gson gson;
122
    @Autowired
123
    private CustomerReturnItemRepository customerReturnItemRepository;
124
    @Autowired
125
    private FofoOrderItemRepository fofoOrderItemRepository;
126
    @Autowired
127
    private PaymentOptionRepository paymentOptionRepository;
128
    @Autowired
129
    private StateRepository stateRepository;
130
    @Autowired
131
    private ItemRepository itemRepository;
132
    @Autowired
133
    private MVCResponseSender mvcResponseSender;
134
    @Autowired
135
    private InsuranceService insuranceService;
136
    @Autowired
137
    private FofoOrderRepository fofoOrderRepository;
138
    @Autowired
139
    private CustomerAddressRepository customerAddressRepository;
140
    @Autowired
141
    private InsurancePolicyRepository insurancePolicyRepository;
142
    @Autowired
143
    private InsuranceProviderRepository insuranceProviderRepository;
144
    @Autowired
145
    private CookiesProcessor cookiesProcessor;
146
    @Autowired
147
    private PricingService pricingService;
148
    @Autowired
149
    private OrderService orderService;
150
    @Autowired
151
    private RetailerRegisteredAddressRepository retailerRegisteredAddressRepository;
152
    @Autowired
153
    private AddressRepository addressRepository;
154
    @Autowired
155
    private PaymentOptionTransactionRepository paymentOptionTransactionRepository;
156
    @Autowired
157
    private FofoPartnerPaymentOptionRepository fofoPartnerPaymentOptionRepository;
158
    @Autowired
159
    private ResponseSender<?> responseSender;
160
    @Autowired
161
    private PendingOrderRepository pendingOrderRepository;
162
    @Autowired
163
    private OrderRepository orderRepository;
164
    @Autowired
165
    private PendingOrderItemRepository pendingOrderItemRepository;
166
    @Autowired
167
    private FofoStoreRepository fofoStoreRepository;
168
    @Autowired
169
    private RetailerService retailerService;
170
    @Autowired
171
    private CurrentInventorySnapshotRepository currentInventorySnapshotRepository;
172
    @Autowired
173
    private TagListingRepository tagListingRepository;
174
    @Autowired
175
    private PendingOrderService pendingOrderService;
176
    @Autowired
177
    private EmailService emailService;
178
    @Autowired
179
    private SolrService commonSolrService;
180
    @Autowired
181
    private MouRepository mouRepository;
182
    @Autowired
183
    private WhatsappMessageService whatsappMessageService;
184
    @Autowired
185
    private TransactionRepository transactionRepository;
33336 tejus.loha 186
    @Autowired
187
    WalletService walletService;
188
    @Autowired
189
    CartRepository cartRepository;
190
    @Autowired
191
    UserWalletRepository userWalletRepository;
28339 tejbeer 192
 
33795 ranu 193
    @Autowired
194
    private CatalogRepository catalogRepository;
33336 tejus.loha 195
 
33400 ranu 196
    @Autowired
33795 ranu 197
    private CustomerOfferRepository customerOfferRepository;
198
 
199
    @Autowired
200
    private CustomerOfferItemRepository customerOfferItemRepository;
201
 
202
    @Autowired
203
    private WebOfferRepository webOfferRepository;
204
 
205
    @Autowired
33400 ranu 206
    PositionRepository positionRepository;
32405 jai.hind 207
 
33437 ranu 208
    @Autowired
209
    PendingOrderPlanRepository pendingOrderPlanRepository;
24105 govind 210
 
34168 tejus.loha 211
    @Autowired
212
    PartnerOnBoardingPanelRepository partnerOnBoardingPanelRepository;
213
 
214
    @Autowired
215
    SDCreditService sdCreditService;
216
 
34798 ranu 217
    @Autowired
218
    IciciPolicyTrackerRepository iciciPolicyTrackerRepository;
34788 ranu 219
 
220
    @Autowired
34474 aman.kumar 221
    ScratchService scratchService;
34798 ranu 222
 
34788 ranu 223
    @Autowired
35971 aman 224
    com.spice.profitmandi.service.user.StoreTimelineTatService storeTimelineTatService;
225
 
226
    @Autowired
34798 ranu 227
    IciciLombardService iciciLombardService;
34788 ranu 228
 
35726 vikas 229
    @Autowired
230
    PinelabsOfferCacheService pinelabsOfferCacheService;
231
 
33419 amit.gupta 232
    @RequestMapping(value = "/wa-send-invoice", method = RequestMethod.GET)
233
    public String sendWhatsappMessage(HttpServletRequest request, @RequestParam(name = ProfitMandiConstants.ORDER_ID) int orderId, Model model) {
234
        try {
36064 aman 235
            FofoOrder fo = fofoOrderRepository.selectByOrderId(orderId);
236
            notificationService.sendWhatsappInvoice(fo.getCustomerId(), fo.getFofoId(), fo.getInvoiceNumber(), "");
33419 amit.gupta 237
        } catch (Exception e) {
35737 amit 238
            LOGGER.error("Could not send whatsapp message for order {}", orderId, e);
33419 amit.gupta 239
        }
240
        model.addAttribute("response1", true);
241
        return "response";
242
    }
243
 
33213 tejus.loha 244
    @RequestMapping(value = "/get-order", method = RequestMethod.GET)
245
    public String getOrder(HttpServletRequest request, @RequestParam(name = ProfitMandiConstants.ORDER_ID) int orderId,
246
                           Model model) throws ProfitMandiBusinessException {
247
        LoginDetails fofoDetails = cookiesProcessor.getCookiesObject(request);
248
        FofoOrder fofoOrder = fofoOrderRepository.selectByFofoIdAndOrderId(fofoDetails.getFofoId(), orderId);
249
        List<FofoOrderItem> fofoLineItems = fofoOrderItemRepository.selectByOrderId(fofoOrder.getId());
250
        CustomerAddress customerAddress = null;
251
        if (fofoOrder.getCustomerAddressId() != 0) {
252
            customerAddress = customerAddressRepository.selectById(fofoOrder.getCustomerAddressId());
253
        }
23973 govind 254
 
33213 tejus.loha 255
        Customer customer = customerRepository.selectById(fofoOrder.getCustomerId());
256
        if (customerAddress != null) {
257
            customerAddress.setPhoneNumber(customer.getMobileNumber());
258
        }
259
        LOGGER.info("Added to get invoice - {}, {}", customer, 123);
260
        List<PaymentOptionTransaction> paymentOptionTransactions = paymentOptionTransactionRepository
261
                .selectByReferenceIdAndType(fofoOrder.getId(), PaymentOptionReferenceType.ORDER);
262
        Map<Integer, PaymentOption> paymentOptionIdPaymentOptionMap = this
263
                .paymentOptionIdPaymentOptionMap(paymentOptionTransactions);
264
        List<InsurancePolicy> insurancePolicies = insurancePolicyRepository
265
                .selectByRetailerIdInvoiceNumber(fofoOrder.getInvoiceNumber());
266
        this.addInsuranceProvider(insurancePolicies);
32627 ranu 267
 
33213 tejus.loha 268
        model.addAttribute("fofoOrder", fofoOrder);
269
        model.addAttribute("fofoLineItems", fofoLineItems);
270
        if (customerAddress != null) {
271
            model.addAttribute("customerBillingAddress", orderService.getBillingAddress(customerAddress));
272
        } else {
273
            model.addAttribute("customerBillingAddress", "");
21985 kshitij.so 274
 
33213 tejus.loha 275
        }
276
        model.addAttribute("customerBillingAddressObj", customerAddress);
277
        model.addAttribute("customerDetailsObj", customer);
278
        model.addAttribute("paymentOptionTransactions", paymentOptionTransactions);
279
        model.addAttribute("paymentOptionIdPaymentOptionMap", paymentOptionIdPaymentOptionMap);
280
        model.addAttribute("insurancePolicies", insurancePolicies);
281
        return "order-details";
282
    }
32637 amit.gupta 283
 
33213 tejus.loha 284
    private Map<Integer, InsuranceProvider> toInsuranceProviderIdInsuranceProvider(
285
            List<InsuranceProvider> insuranceProviders) {
286
        Map<Integer, InsuranceProvider> insuranceProviderIdInsuranceProviderMap = new HashMap<>();
287
        for (InsuranceProvider insuranceProvider : insuranceProviders) {
288
            insuranceProviderIdInsuranceProviderMap.put(insuranceProvider.getId(), insuranceProvider);
289
        }
290
        return insuranceProviderIdInsuranceProviderMap;
291
    }
23973 govind 292
 
33247 ranu 293
    private void addInsuranceProvider(List<InsurancePolicy> insurancePolicies) throws ProfitMandiBusinessException {
33213 tejus.loha 294
        if (insurancePolicies.isEmpty()) {
295
            return;
296
        }
297
        Set<Integer> insuranceProviderIds = new HashSet<>();
298
        for (InsurancePolicy insurancePolicy : insurancePolicies) {
299
            insuranceProviderIds.add(insurancePolicy.getProviderId());
300
        }
301
        LOGGER.info("insuranceProviderIds {}", insuranceProviderIds);
302
        List<InsuranceProvider> insuranceProviders = insuranceProviderRepository.selectByIds(insuranceProviderIds);
303
        Map<Integer, InsuranceProvider> insuranceProviderIdInsuranceProviderMap = this
304
                .toInsuranceProviderIdInsuranceProvider(insuranceProviders);
305
        for (InsurancePolicy insurancePolicy : insurancePolicies) {
306
            insurancePolicy
307
                    .setInsuranceProvider(insuranceProviderIdInsuranceProviderMap.get(insurancePolicy.getProviderId()));
308
        }
309
    }
23973 govind 310
 
33213 tejus.loha 311
    @RequestMapping(value = "/saleDetails", method = RequestMethod.GET)
312
    public String getSaleDetails(HttpServletRequest request,
313
                                 @RequestParam(name = ProfitMandiConstants.ORDER_ID) int orderId, Model model) throws Exception {
314
        LoginDetails fofoDetails = cookiesProcessor.getCookiesObject(request);
315
        boolean isAdmin = roleManager.isAdmin(fofoDetails.getRoleIds());
316
        FofoOrder fofoOrder = fofoOrderRepository.selectByFofoIdAndOrderId(fofoDetails.getFofoId(), orderId);
317
        List<FofoOrderItem> fofoOrderItems = fofoOrderItemRepository.selectByOrderId(fofoOrder.getId());
318
        CustomerAddress customerAddress = customerAddressRepository.selectById(fofoOrder.getCustomerAddressId());
319
        List<PaymentOptionTransaction> paymentOptionTransactions = paymentOptionTransactionRepository
320
                .selectByReferenceIdAndType(fofoOrder.getId(), PaymentOptionReferenceType.ORDER);
23973 govind 321
 
33213 tejus.loha 322
        // Added Migration info as we lost it.
323
        if (paymentOptionTransactions == null || paymentOptionTransactions.size() == 0) {
324
            PaymentOptionTransaction pot = new PaymentOptionTransaction();
325
            pot.setAmount(fofoOrder.getTotalAmount());
326
            pot.setCreateTimestamp(fofoOrder.getCreateTimestamp());
327
            // Mark it paid through cash
328
            pot.setPaymentOptionId(1);
329
            pot.setReferenceType(PaymentOptionReferenceType.ORDER);
330
            paymentOptionTransactionRepository.persist(pot);
331
            paymentOptionTransactions.add(pot);
332
            LOGGER.info("Added to get invoice");
333
        }
334
        Map<Integer, PaymentOption> paymentOptionIdPaymentOptionMap = this
335
                .paymentOptionIdPaymentOptionMap(paymentOptionTransactions);
336
        List<InsurancePolicy> insurancePolicies = insurancePolicyRepository
337
                .selectByRetailerIdInvoiceNumber(fofoOrder.getInvoiceNumber());
338
        this.addInsuranceProvider(insurancePolicies);
35737 amit 339
        Set<Integer> itemIds = fofoOrderItems.stream().map(FofoOrderItem::getItemId).collect(Collectors.toSet());
340
        Map<Integer, Item> itemsMap = itemRepository.selectByIds(itemIds).stream()
341
                .collect(Collectors.toMap(Item::getId, item -> item));
33213 tejus.loha 342
        Map<Integer, Set<FofoLineItem>> fofoOrderItemIdLineItemMap = fofoOrderItems.stream()
343
                .collect(Collectors.toMap(FofoOrderItem::getId, FofoOrderItem::getFofoLineItems));
23973 govind 344
 
35737 amit 345
        Map<Integer, List<CustomerReturnItem>> foiIdCustomerReturnInventoryItemsMap = new HashMap<>();
33213 tejus.loha 346
        Map<Integer, Integer> inventoryItemBilledQtyMap = new HashMap<>();
23973 govind 347
 
33213 tejus.loha 348
        for (FofoOrderItem foi : fofoOrderItems) {
35737 amit 349
            List<CustomerReturnItem> customerReturnItems = customerReturnItemRepository
350
                    .selectAllByOrderItemId(foi.getId());
351
            foiIdCustomerReturnInventoryItemsMap.put(foi.getId(), customerReturnItems);
33213 tejus.loha 352
            for (FofoLineItem fli : foi.getFofoLineItems()) {
353
                inventoryItemBilledQtyMap.put(fli.getInventoryItemId(), fli.getQuantity());
354
            }
355
            this.markDoa(fofoOrder, foi, isAdmin);
356
            for (CustomerReturnItem customerReturnItem : customerReturnItems) {
357
                inventoryItemBilledQtyMap.put(customerReturnItem.getInventoryItemId(),
358
                        inventoryItemBilledQtyMap.get(customerReturnItem.getInventoryItemId()) - 1);
359
            }
360
        }
23973 govind 361
 
33213 tejus.loha 362
        LOGGER.info("fofoOrderItemIdLineItemMap {}", fofoOrderItemIdLineItemMap);
363
        model.addAttribute("fofoOrder", fofoOrder);
364
        model.addAttribute("itemsMap", itemsMap);
365
        model.addAttribute("fofoOrderItemIdLineItemsMap", StringUtils.toString(fofoOrderItemIdLineItemMap));
366
        model.addAttribute("foiIdCustomerReturnInventoryItemsMap",
367
                StringUtils.toString(foiIdCustomerReturnInventoryItemsMap));
368
        model.addAttribute("fofoOrderItemIdLineItemMap", fofoOrderItemIdLineItemMap);
23973 govind 369
 
33213 tejus.loha 370
        model.addAttribute("fofoOrderItems", fofoOrderItems);
371
        model.addAttribute("inventoryItemBilledQtyMap", StringUtils.toString(inventoryItemBilledQtyMap));
372
        if (customerAddress != null) {
30426 tejbeer 373
 
33213 tejus.loha 374
            model.addAttribute("customerBillingAddress", orderService.getBillingAddress(customerAddress));
375
        } else {
376
            model.addAttribute("customerBillingAddress", "");
32637 amit.gupta 377
 
33213 tejus.loha 378
        }
379
        model.addAttribute("customerBillingAddressObj", customerAddress);
380
        model.addAttribute("paymentOptionTransactions", paymentOptionTransactions);
381
        model.addAttribute("paymentOptionIdPaymentOptionMap", paymentOptionIdPaymentOptionMap);
382
        model.addAttribute("insurancePolicies", insurancePolicies);
383
        model.addAttribute("markDefective", this.markDefective(fofoOrder));
384
        return "sale-details";
385
    }
32637 amit.gupta 386
 
33213 tejus.loha 387
    private void markDoa(FofoOrder fofoOrder, FofoOrderItem foi, boolean isAdmin) {
388
        if (isAdmin) {
389
            foi.setDoa(true);
390
            return;
391
        }
392
        boolean isImei = foi.getFofoLineItems().stream()
393
                .anyMatch(x -> org.apache.commons.lang3.StringUtils.isNotEmpty(x.getSerialNumber())
394
                        && allowedDoaImeis.contains(x.getSerialNumber()));
395
        LocalDateTime buyDate = fofoOrder.getCreateTimestamp().truncatedTo(ChronoUnit.DAYS);
396
        LocalDateTime curDate = LocalDateTime.now().truncatedTo(ChronoUnit.DAYS);
397
        if (buyDate.isAfter(curDate.minusDays(45)) || isImei) {
398
            foi.setDoa(true);
399
        } else
400
            foi.setDoa(
401
                    foi.getBrand().equals("Nokia") && foi.getCost() < 4990 && buyDate.isAfter(curDate.minusYears(1)));
402
    }
30426 tejbeer 403
 
33213 tejus.loha 404
    private boolean markDefective(FofoOrder fofoOrder) {
36008 aman 405
 
33213 tejus.loha 406
        return fofoOrder.getCreateTimestamp().truncatedTo(ChronoUnit.DAYS).plusDays(180)
407
                .isAfter(LocalDateTime.now().truncatedTo(ChronoUnit.DAYS));
26647 tejbeer 408
 
33213 tejus.loha 409
    }
26647 tejbeer 410
 
33213 tejus.loha 411
    @RequestMapping(value = "/getSearchOrder")
412
    public String getSearchOrder(HttpServletRequest request, Model model) throws ProfitMandiBusinessException {
413
        return "search-order";
414
    }
26647 tejbeer 415
 
33213 tejus.loha 416
    @RequestMapping(value = "/getInvoiceSearchOrder")
417
    public String getInvoiceSearchOrder(HttpServletRequest request, Model model) throws ProfitMandiBusinessException {
418
        return "invoices-cancel";
419
    }
33172 tejus.loha 420
 
33213 tejus.loha 421
    @RequestMapping(value = "/customerDetails", method = RequestMethod.PUT)
422
    public String updateCustomerDetails(HttpServletRequest request, @RequestBody CustomCustomer customCustomer,
423
                                        @RequestParam(name = ProfitMandiConstants.INVOICE_NUMBER) String invoiceNumber, Model model)
424
            throws Exception {
34338 ranu 425
        LOGGER.info("CustomCustomer {}", customCustomer);
33172 tejus.loha 426
 
33213 tejus.loha 427
        orderService.updateCustomerDetails(customCustomer, invoiceNumber);
428
        return this.getSearchOrderDetails(request, invoiceNumber, model);
429
    }
33172 tejus.loha 430
 
33213 tejus.loha 431
    @RequestMapping(value = "/searchOrderDetails", method = RequestMethod.GET)
432
    public String getSearchOrderDetails(HttpServletRequest request,
433
                                        @RequestParam(name = ProfitMandiConstants.INVOICE_NUMBER) String invoiceNumber, Model model)
434
            throws Exception {
33172 tejus.loha 435
 
33213 tejus.loha 436
        FofoOrder fofoOrder = fofoOrderRepository.selectByInvoiceNumber(invoiceNumber);
34474 aman.kumar 437
        if (fofoOrder == null) {
438
            throw new ProfitMandiBusinessException("invalid invoice number", "invoice - " + invoiceNumber, "Please enter valid invoice number");
34181 tejus.loha 439
        }
440
 
33213 tejus.loha 441
        List<FofoOrderItem> fofoOrderItems = fofoOrderItemRepository.selectByOrderId(fofoOrder.getId());
442
        Customer customer = customerRepository.selectById(fofoOrder.getCustomerId());
443
        CustomerAddress customerAddress = customerAddressRepository.selectById(fofoOrder.getCustomerAddressId());
444
        Map<Integer, PaymentOption> paymentOptionIdPaymentOptionMap = paymentOptionRepository.selectActiveOption().stream().collect(Collectors.toMap(x -> x.getId(), x -> x));
445
        List<Integer> fofoPartnerPaymentOptions = new ArrayList<>(paymentOptionIdPaymentOptionMap.keySet());
35737 amit 446
        Set<Integer> searchItemIds = fofoOrderItems.stream().map(FofoOrderItem::getItemId).collect(Collectors.toSet());
35746 amit 447
        Map<Integer, Item> itemsMap = searchItemIds.isEmpty()
448
                ? new HashMap<>()
449
                : itemRepository.selectByIds(searchItemIds).stream()
450
                        .collect(Collectors.toMap(Item::getId, item -> item));
35737 amit 451
        LOGGER.info("fofoPartnerPaymentOptions {}", fofoPartnerPaymentOptions);
33213 tejus.loha 452
        List<PaymentOptionTransaction> paymentOptionTransactions = paymentOptionTransactionRepository
453
                .selectByReferenceIdAndType(fofoOrder.getId(), PaymentOptionReferenceType.ORDER);
35737 amit 454
        LOGGER.info("paymentOptionTransactions {}", paymentOptionTransactions);
26647 tejbeer 455
 
33213 tejus.loha 456
        Map<Integer, PaymentOptionTransaction> paymentOptionIdPaymentOptionTransactionMap = this
457
                .paymentOptionIdPaymentOptionTransactionMap(paymentOptionTransactions);
35737 amit 458
        LOGGER.info("paymentOptionIdPaymentOptionTransactionMap {}", paymentOptionIdPaymentOptionTransactionMap.keySet());
33213 tejus.loha 459
        List<InsurancePolicy> insurancePolicies = insurancePolicyRepository
460
                .selectByRetailerIdInvoiceNumber(fofoOrder.getInvoiceNumber());
461
        this.addInsuranceProvider(insurancePolicies);
462
        model.addAttribute("fofoOrder", fofoOrder);
463
        for (FofoOrderItem fofoOrderItem : fofoOrderItems) {
464
            fofoOrderItem.setDoa(true);
465
        }
27861 tejbeer 466
 
33213 tejus.loha 467
        Map<Integer, Set<FofoLineItem>> fofoOrderItemIdLineItemMap = fofoOrderItems.stream()
468
                .collect(Collectors.toMap(FofoOrderItem::getId, FofoOrderItem::getFofoLineItems));
28339 tejbeer 469
 
35737 amit 470
        Map<Integer, List<CustomerReturnItem>> foiIdCustomerReturnInventoryItemsMap = new HashMap<>();
33213 tejus.loha 471
        Map<Integer, Integer> inventoryItemBilledQtyMap = new HashMap<>();
28339 tejbeer 472
 
33213 tejus.loha 473
        for (FofoOrderItem foi : fofoOrderItems) {
35737 amit 474
            List<CustomerReturnItem> customerReturnItems = customerReturnItemRepository
475
                    .selectAllByOrderItemId(foi.getId());
476
            foiIdCustomerReturnInventoryItemsMap.put(foi.getId(), customerReturnItems);
33213 tejus.loha 477
            for (FofoLineItem fli : foi.getFofoLineItems()) {
478
                inventoryItemBilledQtyMap.put(fli.getInventoryItemId(), fli.getQuantity());
479
            }
480
            for (CustomerReturnItem customerReturnItem : customerReturnItems) {
481
                inventoryItemBilledQtyMap.put(customerReturnItem.getInventoryItemId(),
482
                        inventoryItemBilledQtyMap.get(customerReturnItem.getInventoryItemId()) - 1);
483
            }
484
        }
485
        model.addAttribute("foiIdCustomerReturnInventoryItemsMap",
486
                StringUtils.toString(foiIdCustomerReturnInventoryItemsMap));
487
        model.addAttribute("fofoOrderItems", fofoOrderItems);
488
        model.addAttribute("inventoryItemBilledQtyMap", StringUtils.toString(inventoryItemBilledQtyMap));
489
        model.addAttribute("fofoOrderItemIdLineItemsMap", StringUtils.toString(fofoOrderItemIdLineItemMap));
490
        model.addAttribute("itemsMap", itemsMap);
491
        model.addAttribute("markDefective", true);
492
        model.addAttribute("customer", customer);
493
        model.addAttribute("customerAddress", customerAddress);
494
        model.addAttribute("paymentOptionTransactions", paymentOptionTransactions);
495
        model.addAttribute("paymentOptionIdPaymentOptionMap", paymentOptionIdPaymentOptionMap);
496
        model.addAttribute("paymentOptionIdPaymentOptionTransactionMap", paymentOptionIdPaymentOptionTransactionMap);
497
        model.addAttribute("insurancePolicies", insurancePolicies);
498
        model.addAttribute("fofoPartnerPaymentOptions", fofoPartnerPaymentOptions);
499
        model.addAttribute("totalNumberOfPaymentOptionId", fofoPartnerPaymentOptions.size());
500
        model.addAttribute("stateNames",
501
                stateRepository.selectAll().stream().map(x -> x.getName()).collect(Collectors.toList()));
502
        return "search-order-details";
503
    }
28420 tejbeer 504
 
33213 tejus.loha 505
    private Map<Integer, PaymentOption> paymentOptionIdPaymentOptionMap(
33247 ranu 506
            List<PaymentOptionTransaction> paymentOptionTransactions) throws ProfitMandiBusinessException {
33213 tejus.loha 507
        Set<Integer> paymentOptionIds = new HashSet<>();
508
        for (PaymentOptionTransaction paymentOptionTransaction : paymentOptionTransactions) {
509
            paymentOptionIds.add(paymentOptionTransaction.getPaymentOptionId());
510
        }
511
        List<PaymentOption> paymentOptions = paymentOptionRepository.selectByIds(paymentOptionIds);
512
        Map<Integer, PaymentOption> paymentOptionIdPaymentOptionMap = new HashMap<>();
513
        for (PaymentOption paymentOption : paymentOptions) {
514
            paymentOptionIdPaymentOptionMap.put(paymentOption.getId(), paymentOption);
515
        }
516
        return paymentOptionIdPaymentOptionMap;
517
    }
23973 govind 518
 
33213 tejus.loha 519
    private Map<Integer, PaymentOption> paymentOptionIdPaymentOptionMapUsingPaymentOptions(
33247 ranu 520
            List<Integer> fofoPartnerPaymentOptions) throws ProfitMandiBusinessException {
33213 tejus.loha 521
        List<PaymentOption> paymentOptions = paymentOptionRepository
522
                .selectByIds(new HashSet<>(fofoPartnerPaymentOptions));
523
        Map<Integer, PaymentOption> paymentOptionIdPaymentOptionMap = new HashMap<>();
524
        for (PaymentOption paymentOption : paymentOptions) {
525
            paymentOptionIdPaymentOptionMap.put(paymentOption.getId(), paymentOption);
526
        }
527
        return paymentOptionIdPaymentOptionMap;
528
    }
23973 govind 529
 
33213 tejus.loha 530
    private Map<Integer, PaymentOptionTransaction> paymentOptionIdPaymentOptionTransactionMap(
531
            List<PaymentOptionTransaction> paymentOptionTransactions) {
532
        Map<Integer, PaymentOptionTransaction> paymentOptionIdPaymentOptionTransactionMap = new HashMap<>();
533
        for (PaymentOptionTransaction paymentOptionTransaction : paymentOptionTransactions) {
534
            paymentOptionIdPaymentOptionTransactionMap.put(paymentOptionTransaction.getPaymentOptionId(),
535
                    paymentOptionTransaction);
536
        }
537
        return paymentOptionIdPaymentOptionTransactionMap;
538
    }
28339 tejbeer 539
 
33437 ranu 540
    @RequestMapping(value = "/checkplans", method = RequestMethod.GET)
541
    public String getInsurancePrices(HttpServletRequest request, @RequestParam float price, Model model,
542
                                     @RequestParam int itemId, @RequestParam int poiId) throws ProfitMandiBusinessException {
543
        LOGGER.info("Request received at url : {}", request.getRequestURI());
28339 tejbeer 544
 
33437 ranu 545
        try {
546
            String response = mvcResponseSender.createResponseString(this.getPlans(price, itemId, poiId));
547
            model.addAttribute("response1", response);
548
        } catch (Exception e) {
549
            // TODO Auto-generated catch block
550
            LOGGER.info(e.getMessage(), e);
551
            throw new ProfitMandiBusinessException("Plans", "Plans API", "Error formatting insurance plans");
33213 tejus.loha 552
        }
33400 ranu 553
 
33437 ranu 554
        return "response";
33213 tejus.loha 555
    }
28339 tejbeer 556
 
34798 ranu 557
    @RequestMapping(value = "/getPlanQuote", method = RequestMethod.GET)
34788 ranu 558
    public String getPlanQuote(HttpServletRequest request, Model model,
35002 ranu 559
                               @RequestParam String planCode, @RequestParam int sumInsured, @RequestParam String manufacturedDate, @RequestParam int itemId, @RequestParam String planName) throws ProfitMandiBusinessException {
34788 ranu 560
 
561
        try {
34798 ranu 562
 
563
            DateTimeFormatter formatter = DateTimeFormatter.ofPattern("MM/dd/yyyy");
564
            LocalDate manufactured = LocalDate.parse(manufacturedDate, formatter);
565
 
34788 ranu 566
            PlanVariant planVariant = insuranceService.getICICIPremiumByVariantId(planCode);
567
 
35066 amit 568
            LOGGER.info("planVariant111 {}", planVariant);
34788 ranu 569
 
570
            String correlationId = UUID.randomUUID().toString();
571
            IciciPolicyTracker policyTracker = new IciciPolicyTracker();
572
            policyTracker.setCorrelationId(correlationId);
573
            iciciPolicyTrackerRepository.persist(policyTracker);
574
 
575
            // Policy validity (1 year from today)
576
            LocalDate today = LocalDate.now();
577
            LocalDate oneYearLater = today.plusYears(1);
578
 
579
            String itemBrand = itemRepository.selectById(itemId).getBrand();
580
 
581
            AfinityQuoteModel quoteModel = new AfinityQuoteModel();
35002 ranu 582
            quoteModel.setProductCode(iciciLombardService.PRODUCT_CODE_STAGGING);
583
            quoteModel.setPlanCode(String.valueOf(planVariant.getOurPlanId()));
584
            quoteModel.setPlanName(planName);
585
            quoteModel.setSumInsured((int) sumInsured);
34788 ranu 586
            quoteModel.setPolicyStartDate(today.toString());          // format: yyyy-MM-dd
587
            quoteModel.setPolicyEndDate(oneYearLater.toString());
35002 ranu 588
            quoteModel.setTaxEffectiveDate(today.toString());
589
            quoteModel.setPolicyType("New");
590
            quoteModel.setIlgicStateName(iciciLombardService.PARTY_STATE_NAME);
34805 ranu 591
            quoteModel.setPartyStateName(iciciLombardService.PARTY_STATE_NAME);
35002 ranu 592
            quoteModel.setUserLevel("UW3");
593
            quoteModel.setNoOfClaimsAllowed(999);
594
            quoteModel.setMakeAndModelOfGadget("High");
595
            quoteModel.setPremiumBeforeEndorsementCancellation(0);
596
            quoteModel.setGeographicalLimit("WithinIndia");
597
            quoteModel.setTransactionDate(today.toString());
598
            quoteModel.setEndorsementEffectiveDate(today.toString());
599
            quoteModel.setRegisteredCustomer(true);
34788 ranu 600
            quoteModel.setCorrelationId(correlationId);
601
 
35002 ranu 602
            // Set cover details
603
            AfinityQuoteModel.CoverDetail coverDetail = new AfinityQuoteModel.CoverDetail();
604
            coverDetail.setName("Accidental Damage");
605
            coverDetail.setPremium(0);
606
 
607
            // Set risk details
608
            AfinityQuoteModel.RiskDetail riskDetail = new AfinityQuoteModel.RiskDetail();
609
            riskDetail.setRiskSIComponent("MOBILE");
610
            riskDetail.setCoverDetails(Arrays.asList(coverDetail));
611
 
612
            quoteModel.setRisksDetails(Arrays.asList(riskDetail));
613
 
34805 ranu 614
            AfinityQuoteResponseModel afinityQuoteResponseModel = iciciLombardService.hitAfinityQuote(quoteModel);
615
            float planDp = insuranceService.getPlanDp(afinityQuoteResponseModel.getTotalPremium(), planVariant.getCoverage());
616
 
617
            Map<String, Object> responseMap = new HashMap<>();
618
            responseMap.put("afinityQuoteModel", afinityQuoteResponseModel);
619
            responseMap.put("planDp", planDp);
620
            model.addAttribute("response1", mvcResponseSender.createResponseString(responseMap));
34788 ranu 621
        } catch (Exception e) {
622
            // TODO Auto-generated catch block
623
            LOGGER.info(e.getMessage(), e);
624
            throw new ProfitMandiBusinessException("Plans", "Plans Quote", "Error qutotation insurance plans");
625
        }
626
 
627
        return "response";
34798 ranu 628
    }
34788 ranu 629
 
36937 ranu 630
    @RequestMapping(value = "/admin/policy/certificate", method = RequestMethod.GET)
631
    public ResponseEntity<byte[]> downloadPolicyCertificate(HttpServletRequest request,
36950 ranu 632
                                                            @RequestParam(required = false) String policyNumber,
633
                                                            @RequestParam(required = false) String proposalNumber) throws Exception {
36937 ranu 634
        LoginDetails fofoDetails = cookiesProcessor.getCookiesObject(request);
635
        if (!roleManager.isAdmin(fofoDetails.getRoleIds())) {
636
            return ResponseEntity.status(HttpStatus.FORBIDDEN).build();
637
        }
34179 tejus.loha 638
 
36950 ranu 639
        if ((policyNumber == null || policyNumber.isEmpty())
640
                && (proposalNumber == null || proposalNumber.isEmpty())) {
641
            return ResponseEntity.badRequest().build();
642
        }
643
 
644
        // If policyNumber wasn't given, resolve it from proposalNumber first.
645
        if (policyNumber == null || policyNumber.isEmpty()) {
646
            policyNumber = iciciLombardService.recoverPolicyNumberByProposalNumber(proposalNumber);
647
        }
648
 
36937 ranu 649
        String filePath = iciciLombardService.fetchPolicyCertificateByPolicyNumber(policyNumber);
650
        byte[] pdfBytes = Files.readAllBytes(new File(filePath).toPath());
651
 
652
        String safeName = "policy-" + policyNumber.replace("/", "-") + ".pdf";
653
        HttpHeaders headers = new HttpHeaders();
654
        headers.setContentType(MediaType.APPLICATION_PDF);
655
        headers.setContentDispositionFormData("inline", safeName);
656
        headers.setContentLength(pdfBytes.length);
657
        return new ResponseEntity<>(pdfBytes, headers, HttpStatus.OK);
658
    }
659
 
660
 
33213 tejus.loha 661
    @RequestMapping(value = "/order/bad_return", method = RequestMethod.POST)
662
    public ResponseEntity<?> badReturn(HttpServletRequest request, @RequestBody FoiBadReturnRequest foiBadReturnRequest,
663
                                       Model model) throws ProfitMandiBusinessException {
664
        LOGGER.info("request at uri {} body {}", request.getRequestURI(), foiBadReturnRequest);
665
        LoginDetails fofoDetails = cookiesProcessor.getCookiesObject(request);
666
        CustomerCreditNote custmoerCreditNote;
667
        if (roleManager.isAdmin(fofoDetails.getRoleIds())) {
668
            FofoOrderItem foi = fofoOrderItemRepository.selectById(foiBadReturnRequest.getFofoOrderItemId());
669
            FofoOrder fo = fofoOrderRepository.selectByOrderId(foi.getOrderId());
34168 tejus.loha 670
            custmoerCreditNote = orderService.badReturn(fofoDetails.getEmailId(), fo.getFofoId(), foiBadReturnRequest);
33213 tejus.loha 671
        } else {
672
            custmoerCreditNote = orderService.badReturn(fofoDetails.getFofoId(), foiBadReturnRequest);
673
        }
674
        return responseSender.ok(custmoerCreditNote.getId());
675
    }
28339 tejbeer 676
 
33213 tejus.loha 677
    @GetMapping(value = "/wa-invoice-send/{invoiceHash}")
678
    public ResponseEntity<?> generateInvoice(@PathVariable String invoiceHash) throws ProfitMandiBusinessException {
679
        String decodedInvoiceNumber = new String(Base64.getMimeDecoder().decode(invoiceHash));
680
        LOGGER.info("Invoice Hash {}", invoiceHash);
28339 tejbeer 681
 
23973 govind 682
 
33213 tejus.loha 683
        FofoOrder fofoOrder = fofoOrderRepository.selectByInvoiceNumber(decodedInvoiceNumber);
24844 amit.gupta 684
 
33213 tejus.loha 685
        InvoicePdfModel pdfModel = orderService.getInvoicePdfModel(fofoOrder.getId());
24844 amit.gupta 686
 
33213 tejus.loha 687
        ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
688
        PdfUtils.generateAndWrite(Arrays.asList(pdfModel), byteArrayOutputStream);
689
        final HttpHeaders headers = new HttpHeaders();
690
        //headers.setContentDispositionFormData("inline", number + ".pdf");
691
        headers.add(HttpHeaders.CONTENT_DISPOSITION, "inline;filename=" + pdfModel.getInvoiceNumber() + ".pdf");
692
        int contentLength = byteArrayOutputStream.toByteArray().length;
693
        final InputStream inputStream = new ByteArrayInputStream(byteArrayOutputStream.toByteArray());
694
        final InputStreamResource inputStreamResource = new InputStreamResource(inputStream);
695
        return ResponseEntity.ok()
696
                .headers(headers)
697
                .contentLength(contentLength)
698
                .contentType(MediaType.parseMediaType("application/pdf"))
699
                .body(inputStreamResource);
700
    }
23973 govind 701
 
33213 tejus.loha 702
    @RequestMapping(value = "/wa-listen", method = RequestMethod.POST)
703
    public ResponseEntity<?> listenWhatsappStatus(@RequestBody String whatsappJsonResponse) {
704
        LOGGER.info("whatsappJsonResponse {}", whatsappJsonResponse);
705
        //jaihind
706
        //  String jsonString = "[{\"srcAddr\":\"TESTSM\",\"channel\":\"WHATSAPP\",\"externalId\":\"4977024756456780043-180044363908187691\",\"cause\":\"SUCCESS\",\"errorCode\":\"000\",\"destAddr\":\"919813272029\",\"eventType\":\"DELIVERED\",\"eventTs\":1692848106000}]";
707
        JSONArray jsonArray = new JSONArray(whatsappJsonResponse);
708
        for (int i = 0; i < jsonArray.length(); i++) {
32711 amit.gupta 709
 
33213 tejus.loha 710
            JSONObject jsonObject = jsonArray.getJSONObject(i);
711
            String externalId = jsonObject.getString("externalId");
712
            String destAddr = jsonObject.getString("destAddr");
713
            String eventType = jsonObject.getString("eventType");
714
            whatsappMessageService.setWhatsappResponse(externalId, destAddr, eventType);
715
        }
716
        //jaihind
717
        return responseSender.ok("Success");
32711 amit.gupta 718
 
33213 tejus.loha 719
    }
32271 amit.gupta 720
 
33213 tejus.loha 721
    @RequestMapping(value = "/generateInvoice")
722
    public ResponseEntity<?> generateInvoice(HttpServletRequest request, HttpServletResponse response,
35081 ranu 723
                                             @RequestParam(name = ProfitMandiConstants.ORDER_ID) int orderId) throws ProfitMandiBusinessException {
724
        LOGGER.info("Request received at url {} with params [{}={}] ", request.getRequestURI(),
725
                ProfitMandiConstants.ORDER_ID, orderId);
726
        LoginDetails fofoDetails = cookiesProcessor.getCookiesObject(request);
727
        InvoicePdfModel pdfModel = null;
728
        if (roleManager.isAdmin(fofoDetails.getRoleIds())) {
729
            pdfModel = orderService.getInvoicePdfModel(orderId);
730
        } else {
731
            pdfModel = orderService.getInvoicePdfModel(fofoDetails.getFofoId(), orderId);
732
        }
733
        FofoOrder fofoOrder = fofoOrderRepository.selectByOrderId(orderId);
734
        List<InsurancePolicy> insurancePolicies = insurancePolicyRepository.selectByRetailerIdInvoiceNumber(fofoOrder.getInvoiceNumber());
735
 
736
        // Step 1: Generate invoice PDF
737
        ByteArrayOutputStream invoiceOutput = new ByteArrayOutputStream();
738
        PdfUtils.generateAndWrite(Arrays.asList(pdfModel), invoiceOutput);
739
        byte[] invoicePdf = invoiceOutput.toByteArray();
740
 
741
        // Step 2: Load all policy certificate PDFs
742
        List<byte[]> pdfFiles = new ArrayList<>();
743
        pdfFiles.add(invoicePdf); // first add invoice
744
 
745
        for (InsurancePolicy insurancePolicy : insurancePolicies) {
746
            if (insurancePolicy.getProviderId() == 6) {
747
                String policyNumber = insurancePolicy.getPolicyNumber();
748
                String safePolicyNo = policyNumber.replace("/", "-");
749
                String filePath = "/uploads/policy-certificate-" + safePolicyNo + ".pdf";
750
                File file = new File(filePath);
751
 
752
                if (file.exists()) {
753
                    try {
754
                        byte[] policyPdf = Files.readAllBytes(file.toPath());
755
                        pdfFiles.add(policyPdf);
756
                    } catch (IOException e) {
757
                        LOGGER.error("Failed to read policy PDF: {}", filePath, e);
758
                    }
759
                } else {
760
                    LOGGER.warn("Policy PDF not found: {}", filePath);
761
                }
762
            }
763
        }
764
 
765
        // Step 3: Merge all PDFs
766
        byte[] mergedPdf;
767
        try {
768
            mergedPdf = PdfUtils.mergePdfFiles(pdfFiles);
769
        } catch (Exception e) {
770
            LOGGER.error("Error merging PDFs", e);
771
            throw new ProfitMandiBusinessException("Failed to generate merged PDF", "", "");
772
        }
773
 
774
        // Step 4: Return merged PDF as response
775
        HttpHeaders headers = new HttpHeaders();
776
        headers.setContentType(MediaType.APPLICATION_PDF);
777
        headers.setContentDispositionFormData("inline", "invoice-with-policies-" + pdfModel.getInvoiceNumber() + ".pdf");
778
        headers.setContentLength(mergedPdf.length);
779
 
780
        InputStreamResource resource = new InputStreamResource(new ByteArrayInputStream(mergedPdf));
781
        return new ResponseEntity<>(resource, headers, HttpStatus.OK);
782
    }
783
 
784
   /* @RequestMapping(value = "/generateInvoice")
785
    public ResponseEntity<?> generateInvoice(HttpServletRequest request, HttpServletResponse response,
35066 amit 786
                                             @RequestParam(name = ProfitMandiConstants.ORDER_ID) int orderId, @RequestParam(required = false) PrinterType printerType) throws ProfitMandiBusinessException {
33213 tejus.loha 787
        LOGGER.info("Request received at url {} with params [{}={}] ", request.getRequestURI(),
788
                ProfitMandiConstants.ORDER_ID, orderId);
789
        LoginDetails fofoDetails = cookiesProcessor.getCookiesObject(request);
790
        InvoicePdfModel pdfModel = null;
35066 amit 791
        int fofoId;
33213 tejus.loha 792
        if (roleManager.isAdmin(fofoDetails.getRoleIds())) {
793
            pdfModel = orderService.getInvoicePdfModel(orderId);
35066 amit 794
            fofoId = pdfModel.getCustomer().getCustomerId();
33213 tejus.loha 795
        } else {
796
            pdfModel = orderService.getInvoicePdfModel(fofoDetails.getFofoId(), orderId);
35066 amit 797
            fofoId = fofoDetails.getFofoId();
33213 tejus.loha 798
        }
35066 amit 799
 
800
        if (printerType == null) {
801
            FofoStore fs = fofoStoreRepository.selectByRetailerId(fofoId);
802
            //printerType = fs.getPrinterType();
803
        }
804
 
805
 
34805 ranu 806
        FofoOrder fofoOrder = fofoOrderRepository.selectByOrderId(orderId);
807
        List<InsurancePolicy> insurancePolicies = insurancePolicyRepository.selectByRetailerIdInvoiceNumber(fofoOrder.getInvoiceNumber());
808
 
809
        // Step 1: Generate invoice PDF
810
        ByteArrayOutputStream invoiceOutput = new ByteArrayOutputStream();
35066 amit 811
 
812
        PdfUtils.generateAndWrite(Arrays.asList(pdfModel), printerType, invoiceOutput);
34805 ranu 813
        byte[] invoicePdf = invoiceOutput.toByteArray();
814
 
815
        // Step 2: Load all policy certificate PDFs
816
        List<byte[]> pdfFiles = new ArrayList<>();
817
        pdfFiles.add(invoicePdf); // first add invoice
818
 
819
        for (InsurancePolicy insurancePolicy : insurancePolicies) {
35076 ranu 820
            if (insurancePolicy.getProviderId() == 6) {
821
                String policyNumber = insurancePolicy.getPolicyNumber();
822
                String safePolicyNo = policyNumber.replace("/", "-");
823
                String filePath = "/uploads/policy-certificate-" + safePolicyNo + ".pdf";
824
                File file = new File(filePath);
34805 ranu 825
 
35076 ranu 826
                if (file.exists()) {
827
                    try {
828
                        byte[] policyPdf = Files.readAllBytes(file.toPath());
829
                        pdfFiles.add(policyPdf);
830
                    } catch (IOException e) {
831
                        LOGGER.error("Failed to read policy PDF: {}", filePath, e);
832
                    }
833
                } else {
834
                    LOGGER.warn("Policy PDF not found: {}", filePath);
34805 ranu 835
                }
836
            }
35076 ranu 837
 
34805 ranu 838
        }
839
 
840
        // Step 3: Merge all PDFs
841
        byte[] mergedPdf;
842
        try {
843
            mergedPdf = PdfUtils.mergePdfFiles(pdfFiles);
844
        } catch (Exception e) {
845
            LOGGER.error("Error merging PDFs", e);
846
            throw new ProfitMandiBusinessException("Failed to generate merged PDF", "", "");
847
        }
848
 
849
        // Step 4: Return merged PDF as response
850
        HttpHeaders headers = new HttpHeaders();
33213 tejus.loha 851
        headers.setContentType(MediaType.APPLICATION_PDF);
34805 ranu 852
        headers.setContentDispositionFormData("inline", "invoice-with-policies-" + pdfModel.getInvoiceNumber() + ".pdf");
853
        headers.setContentLength(mergedPdf.length);
854
 
855
        InputStreamResource resource = new InputStreamResource(new ByteArrayInputStream(mergedPdf));
856
        return new ResponseEntity<>(resource, headers, HttpStatus.OK);
35081 ranu 857
    }*/
24087 amit.gupta 858
 
33213 tejus.loha 859
    @RequestMapping(value = "/generateInvoices")
860
    public ResponseEntity<?> generateInvoice(HttpServletRequest request, HttpServletResponse response,
861
                                             @RequestParam LocalDateTime startDate, @RequestParam LocalDateTime endDate, @RequestParam int partnerId)
862
            throws ProfitMandiBusinessException {
863
        LoginDetails fofoDetails = cookiesProcessor.getCookiesObject(request);
864
        List<InvoicePdfModel> pdfModels = new ArrayList<>();
865
        if (roleManager.isAdmin(fofoDetails.getRoleIds())) {
866
            List<Integer> orderIds = fofoOrderRepository.selectByFofoId(partnerId, startDate, endDate, 0, 0).stream()
867
                    .map(x -> x.getId()).collect(Collectors.toList());
868
            for (int orderId : orderIds) {
869
                pdfModels.add(orderService.getInvoicePdfModel(orderId));
870
            }
871
            ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
872
            PdfUtils.generateAndWrite(pdfModels, byteArrayOutputStream);
873
            LOGGER.info("Pdf Stream length {}", byteArrayOutputStream.toByteArray().length);
874
            final HttpHeaders headers = new HttpHeaders();
875
            headers.setContentType(MediaType.APPLICATION_PDF);
876
            headers.set("Content-disposition", "inline; filename=invoice-" + partnerId + ".pdf");
877
            headers.setContentLength(byteArrayOutputStream.toByteArray().length);
878
            final InputStream inputStream = new ByteArrayInputStream(byteArrayOutputStream.toByteArray());
879
            final InputStreamResource inputStreamResource = new InputStreamResource(inputStream);
880
            return new ResponseEntity<InputStreamResource>(inputStreamResource, headers, HttpStatus.OK);
881
        } else {
882
            throw new ProfitMandiBusinessException("Auth", fofoDetails.getEmailId(), "Unauthorised access");
883
        }
884
    }
23973 govind 885
 
33213 tejus.loha 886
    @RequestMapping(value = "/saleHistory")
887
    public String saleHistory(HttpServletRequest request,
888
                              @RequestParam(name = "searchValue", defaultValue = "") String searchValue,
889
                              @RequestParam(name = "searchType", defaultValue = "") SearchType searchType,
890
                              @RequestParam(required = false) LocalDateTime startTime,
891
                              @RequestParam(required = false) LocalDateTime endTime,
892
                              @RequestParam(name = "offset", defaultValue = "0") int offset,
893
                              @RequestParam(name = "limit", defaultValue = "10") int limit, Model model)
894
            throws ProfitMandiBusinessException {
895
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
32405 jai.hind 896
 
33213 tejus.loha 897
        Map<String, Object> map = orderService.getSaleHistory(loginDetails.getFofoId(), searchType, searchValue,
898
                startTime, endTime, offset, limit);
899
        model.addAllAttributes(map);
900
        return "sale-history";
901
    }
32405 jai.hind 902
 
33213 tejus.loha 903
    @RequestMapping(value = "/downloadInvoices")
904
    public ResponseEntity<?> downloadInvoices(HttpServletRequest request,
905
                                              @RequestParam(name = "searchValue", defaultValue = "") String searchValue,
906
                                              @RequestParam(name = "searchType", defaultValue = "") SearchType searchType,
907
                                              @RequestParam(required = false) LocalDateTime startTime,
908
                                              @RequestParam(required = false) LocalDateTime endTime,
909
                                              @RequestParam(name = "offset", defaultValue = "0") int offset,
910
                                              @RequestParam(name = "limit", defaultValue = "10") int limit, Model model)
911
            throws ProfitMandiBusinessException {
912
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
32409 amit.gupta 913
 
33213 tejus.loha 914
        Map<String, Object> map = orderService.getSaleHistory(loginDetails.getFofoId(), searchType, searchValue,
915
                startTime, endTime, offset, 100);
916
        List<FofoOrder> fofoOrders = (List<FofoOrder>) map.get("saleHistories");
23973 govind 917
 
33213 tejus.loha 918
        if (fofoOrders.size() == 0) {
919
            throw new ProfitMandiBusinessException("Search criteria", "", "No orders found for criteria");
920
        }
23654 amit.gupta 921
 
33213 tejus.loha 922
        final HttpHeaders headers = new HttpHeaders();
923
        headers.setContentType(MediaType.APPLICATION_PDF);
924
        headers.set("Content-disposition", "inline; filename=invoices.pdf");
925
        ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
926
        List<InvoicePdfModel> pdfModels = new ArrayList<>();
927
        for (FofoOrder fofoOrder : fofoOrders) {
928
            try {
929
                pdfModels.add(orderService.getInvoicePdfModel(fofoOrder.getId()));
930
            } catch (Exception e) {
931
                LOGGER.info("could not create invoice for {}, invoice number {}", fofoOrder.getId(),
932
                        fofoOrder.getInvoiceNumber());
933
            }
934
        }
935
        PdfUtils.generateAndWrite(pdfModels, byteArrayOutputStream);
936
        headers.setContentLength(byteArrayOutputStream.toByteArray().length);
937
        final InputStream inputStream = new ByteArrayInputStream(byteArrayOutputStream.toByteArray());
938
        final InputStreamResource inputStreamResource = new InputStreamResource(inputStream);
939
        return new ResponseEntity<InputStreamResource>(inputStreamResource, headers, HttpStatus.OK);
940
    }
23654 amit.gupta 941
 
33213 tejus.loha 942
    @RequestMapping(value = "/credit-note/{creditNoteId}")
943
    public ResponseEntity<?> downloadCreditNote(HttpServletRequest request, @PathVariable int creditNoteId)
944
            throws ProfitMandiBusinessException {
945
        CreditNotePdfModel creditNotePdfModel = orderService.getCreditNotePdfModel(creditNoteId);
36151 amit 946
        InvoicePdfModel pdfModel = creditNotePdfModel.getPdfModel();
947
        pdfModel.setInvoiceNumber(creditNotePdfModel.getCreditNoteNumber());
948
        pdfModel.setInvoiceDate(creditNotePdfModel.getCreditNoteDate());
33213 tejus.loha 949
        ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
36151 amit 950
        PdfUtils.generateInvoiceV2(Arrays.asList(pdfModel), byteArrayOutputStream);
33213 tejus.loha 951
        LOGGER.info("Pdf Stream length {}", byteArrayOutputStream.toByteArray().length);
952
        final HttpHeaders headers = new HttpHeaders();
953
        headers.setContentType(MediaType.APPLICATION_PDF);
954
        headers.set("Content-disposition",
955
                "inline; filename=invoice-" + creditNotePdfModel.getCreditNoteNumber() + ".pdf");
956
        headers.setContentLength(byteArrayOutputStream.toByteArray().length);
957
        final InputStream inputStream = new ByteArrayInputStream(byteArrayOutputStream.toByteArray());
958
        final InputStreamResource inputStreamResource = new InputStreamResource(inputStream);
959
        return new ResponseEntity<InputStreamResource>(inputStreamResource, headers, HttpStatus.OK);
960
    }
23973 govind 961
 
33213 tejus.loha 962
    @RequestMapping(value = "/getPaginatedSaleHistory")
963
    public String getSaleHistoryPaginated(HttpServletRequest request,
964
                                          @RequestParam(name = "searchValue", defaultValue = "") String searchValue,
965
                                          @RequestParam(name = "searchType", defaultValue = "") SearchType searchType,
966
                                          @RequestParam(required = false) LocalDateTime startTime,
967
                                          @RequestParam(required = false) LocalDateTime endTime,
968
                                          @RequestParam(name = "offset", defaultValue = "0") int offset,
969
                                          @RequestParam(name = "limit", defaultValue = "10") int limit, Model model)
970
            throws ProfitMandiBusinessException {
971
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
972
        Map<String, Object> map = orderService.getSaleHistoryPaginated(loginDetails.getFofoId(), searchType,
973
                searchValue, startTime, endTime, offset, limit);
974
        model.addAllAttributes(map);
975
        return "sale-history-paginated";
976
    }
23973 govind 977
 
33213 tejus.loha 978
    @PutMapping(value = "/updatePaymentTransaction")
979
    public String updateTransactionDetails(HttpServletRequest request, @RequestParam String referenceType,
980
                                           @RequestParam int fofoId, @RequestParam int referenceId,
981
                                           @RequestBody PartnerOptionsAndItemAmountModel partnerOptionsAndItemAmountModel,
982
                                           @RequestParam float totalAmount, Model model) throws Exception {
29707 tejbeer 983
 
33213 tejus.loha 984
        List<PaymentOptionTransactionModel> paymentOptionTransactionModels = partnerOptionsAndItemAmountModel
985
                .getPaymentOptionTransactionModel();
986
        LOGGER.info(paymentOptionTransactionModels);
987
        FofoOrder fofoOrder = fofoOrderRepository.selectByFofoIdAndOrderId(fofoId, referenceId);
35737 amit 988
        LOGGER.info("fofoOrder: {}", fofoOrder);
33213 tejus.loha 989
        fofoOrder.setTotalAmount(totalAmount);
990
        List<FofoItemIdAmountModel> fofoItemIdAmountModel = partnerOptionsAndItemAmountModel.getItemAmountModel();
35737 amit 991
 
992
        Set<Integer> fimItemIds = fofoItemIdAmountModel.stream().map(FofoItemIdAmountModel::getItemId).collect(Collectors.toSet());
993
        Map<Integer, Item> fimItemMap = itemRepository.selectByIds(fimItemIds).stream()
994
                .collect(Collectors.toMap(Item::getId, item -> item));
995
        Map<Integer, TagListing> fimTagMap = tagListingRepository.selectByItemIds(fimItemIds);
996
        List<Integer> fimFofoItemIds = fofoItemIdAmountModel.stream().map(FofoItemIdAmountModel::getFofoItemId).collect(Collectors.toList());
997
        Map<Integer, FofoOrderItem> fimFofoItemMap = fofoOrderItemRepository.selectByIds(fimFofoItemIds).stream()
998
                .collect(Collectors.toMap(FofoOrderItem::getId, foi -> foi));
999
 
33213 tejus.loha 1000
        for (FofoItemIdAmountModel fim : fofoItemIdAmountModel) {
35737 amit 1001
            LOGGER.info("fim: {}", fim.getFofoItemId());
1002
            LOGGER.info("fimAmount: {}", fim.getAmount());
1003
            Item item = fimItemMap.get(fim.getItemId());
1004
            TagListing tagListing = fimTagMap.get(item.getId());
1005
            FofoOrderItem fofoOrderItem = fimFofoItemMap.get(fim.getFofoItemId());
1006
            LOGGER.info("category: {}", item.getCategoryId());
33213 tejus.loha 1007
            if (item.getCategoryId() == ProfitMandiConstants.MOBILE_CATEGORY_ID) {
1008
                if (fofoOrderItem.getMop() <= fim.getAmount()) {
23973 govind 1009
 
33213 tejus.loha 1010
                    if (fim.getAmount() <= tagListing.getMrp()) {
1011
                        fofoOrderItem.setSellingPrice(fim.getAmount());
1012
                    } else {
1013
                        throw new ProfitMandiBusinessException("Amount", fim.getAmount(),
1014
                                "Sum of amount is not less than  to MRP");
1015
                    }
23973 govind 1016
 
35737 amit 1017
                    LOGGER.info("fofoOrderItem2: {}", fofoOrderItem);
23973 govind 1018
 
33213 tejus.loha 1019
                } else {
1020
                    // TODO below mop condition need to added added
1021
                    fofoOrderItem.setSellingPrice(fim.getAmount());
1022
                }
23973 govind 1023
 
33213 tejus.loha 1024
            } else {
1025
                fofoOrderItem.setSellingPrice(fim.getAmount());
35737 amit 1026
                LOGGER.info("fofoOrderItem1: {}", fofoOrderItem);
27819 tejbeer 1027
 
33213 tejus.loha 1028
            }
35737 amit 1029
            LOGGER.info("fofoOrderItem: {}", fofoOrderItem);
23973 govind 1030
 
33213 tejus.loha 1031
        }
23973 govind 1032
 
33213 tejus.loha 1033
        /*
1034
         * for (PaymentOptionTransactionModel paymentOptionTransactionModel :
1035
         * paymentOptionTransactionModels) { amount = amount +
1036
         * paymentOptionTransactionModel.getAmount(); } LOGGER.info("FofoOrder amount" +
1037
         * fofoOrder.getUnitPrice() + "amount" + amount); if (amount ==
1038
         * fofoOrder.getUnitPrice()) {
1039
         */
1040
        if (paymentOptionTransactionModels.size() > 0) {
1041
            List<PaymentOptionTransaction> paymentOptionTransactions = paymentOptionTransactionRepository
1042
                    .selectByReferenceIdAndType(referenceId, PaymentOptionReferenceType.ORDER);
1043
            Map<Integer, PaymentOptionTransaction> paymentOptionIdPaymentOptionTransactionMap = this
1044
                    .paymentOptionIdPaymentOptionTransactionMap(paymentOptionTransactions);
35737 amit 1045
            LOGGER.info("paymentOptionIdPaymentOptionTransactionMap: {}", paymentOptionIdPaymentOptionTransactionMap.keySet());
33213 tejus.loha 1046
            for (PaymentOptionTransactionModel paymentOptionTransactionModel : paymentOptionTransactionModels) {
1047
                if (paymentOptionIdPaymentOptionTransactionMap
1048
                        .containsKey(paymentOptionTransactionModel.getPaymentOptionId())) {
23973 govind 1049
 
33213 tejus.loha 1050
                    PaymentOptionTransaction paymentOptionTransaction = paymentOptionIdPaymentOptionTransactionMap
1051
                            .get(paymentOptionTransactionModel.getPaymentOptionId());
31739 amit.gupta 1052
 
33213 tejus.loha 1053
                    if (paymentOptionTransactionModel.getAmount() == 0) {
1054
                        paymentOptionTransactionRepository.delete(paymentOptionTransaction);
1055
                        LOGGER.info("deleted successfully");
1056
                    } else {
24844 amit.gupta 1057
 
33213 tejus.loha 1058
                        paymentOptionTransaction.setAmount(paymentOptionTransactionModel.getAmount());
1059
                        paymentOptionTransactionRepository.persist(paymentOptionTransaction);
1060
                        LOGGER.info("updated successfully");
24281 amit.gupta 1061
 
33213 tejus.loha 1062
                    }
1063
                } else {
1064
                    if (paymentOptionTransactionModel.getAmount() > 0) {
1065
                        PaymentOptionTransaction paymentOptionTransaction = new PaymentOptionTransaction();
1066
                        paymentOptionTransaction.setReferenceId(referenceId);
1067
                        paymentOptionTransaction.setReferenceType(PaymentOptionReferenceType.ORDER);
1068
                        paymentOptionTransaction.setPaymentOptionId(paymentOptionTransactionModel.getPaymentOptionId());
1069
                        paymentOptionTransaction.setAmount(paymentOptionTransactionModel.getAmount());
1070
                        paymentOptionTransaction.setFofoId(fofoId);
1071
                        paymentOptionTransaction.setCreateTimestamp(fofoOrder.getCreateTimestamp());
1072
                        paymentOptionTransactionRepository.persist(paymentOptionTransaction);
1073
                        LOGGER.info("inserted successfully");
1074
                    }
1075
                }
24281 amit.gupta 1076
 
33213 tejus.loha 1077
            }
24281 amit.gupta 1078
 
33213 tejus.loha 1079
            model.addAttribute("response1", mvcResponseSender.createResponseString(true));
1080
        }
1081
        /*
1082
         * else
1083
         *
1084
         * { throw new ProfitMandiBusinessException("Amount", amount,
1085
         * "Sum of amount is not equal to total amount"); }
1086
         */
23973 govind 1087
 
33213 tejus.loha 1088
        return "response";
23973 govind 1089
 
33213 tejus.loha 1090
    }
24105 govind 1091
 
33437 ranu 1092
    @RequestMapping(value = "/order")
1093
    public String orderIndex(HttpServletRequest request, @RequestParam(name = "cartData") String cartData, Model model)
33213 tejus.loha 1094
            throws ProfitMandiBusinessException {
33437 ranu 1095
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1096
 
1097
        int addressId = retailerRegisteredAddressRepository.selectAddressIdByRetailerId(loginDetails.getFofoId());
1098
        Address address = addressRepository.selectById(addressId);
1099
 
1100
        List<CartFofo> cartItems = orderService.cartCheckout(cartData);
1101
        Set<Integer> itemIds = new HashSet<>();
1102
        List<Integer> poIds = new ArrayList<>();
1103
        List<Integer> poItemIds = new ArrayList<>();
1104
        for (CartFofo cartFofo : cartItems) {
1105
            itemIds.add(cartFofo.getItemId());
1106
            if (cartFofo.getPoId() != 0) {
1107
                poIds.add(cartFofo.getPoId());
1108
                poItemIds.add(cartFofo.getPoItemId());
1109
            }
1110
        }
1111
 
1112
        PendingOrder po = null;
1113
        Customer customer = null;
1114
        PendingOrderItem poi = null;
1115
        Map<Integer, PriceModel> mopPriceMap = pricingService.getPurchasePriceMopPriceNotFound(itemIds,
1116
                loginDetails.getFofoId());
1117
        List<Integer> paymentOptionIds = fofoPartnerPaymentOptionRepository
1118
                .selectPaymentOptionIdsByFofoId(loginDetails.getFofoId());
1119
 
1120
        if (!poIds.isEmpty()) {
1121
            po = pendingOrderRepository.selectById(poIds.get(0));
1122
            customer = customerRepository.selectById(po.getCustomerId());
1123
            if (!offlineOrders.contains(po.getPayMethod())) {
1124
                paymentOptionIds.add(23);
1125
            }
1126
        }
1127
 
1128
        if (!poItemIds.isEmpty()) {
1129
            poi = pendingOrderItemRepository.selectById(poItemIds.get(0));
1130
        }
1131
 
1132
        // List<PaymentOption> paymentOptions = paymentOptionRepository.selectByIds(new
1133
        // HashSet<>(paymentOptionIds));
1134
 
1135
        List<PaymentOption> paymentOptions = paymentOptionRepository.selectActiveOption();
1136
 
35737 amit 1137
        LOGGER.info("pendingOrder: {}", po);
1138
        LOGGER.info("pendingOrderItem: {}", poi);
33437 ranu 1139
 
1140
        int onlineSellingPrice = 0;
1141
        Map<Integer, PendingOrderItem> itemIdAndPoiMap = new HashMap<>();
1142
 
1143
        if (po != null) {
1144
            List<PendingOrderItem> pendingOrderItems = pendingOrderItemRepository.selectByOrderId(po.getId());
35737 amit 1145
            Map<Integer, PendingOrderItem> poiByIdMap = pendingOrderItems.stream()
1146
                    .collect(Collectors.toMap(PendingOrderItem::getId, x -> x));
33437 ranu 1147
            if (!(po.getPayMethod().equals("EMIOD") || po.getPayMethod().equals("POD"))) {
1148
                for (CartFofo cartItem : cartItems) {
35737 amit 1149
                    PendingOrderItem pendingOItem = poiByIdMap.get(cartItem.getPoItemId());
33437 ranu 1150
                    PendingOrderPlan pendingOrderPlan = pendingOrderPlanRepository.selectByPoid(cartItem.getPoItemId());
1151
                    if (pendingOrderPlan != null) {
1152
                        onlineSellingPrice += pendingOItem.getSellingPrice() * pendingOItem.getQuantity() + pendingOrderPlan.getPremiumPrice() * pendingOItem.getQuantity();
1153
                    } else {
1154
                        onlineSellingPrice += pendingOItem.getSellingPrice() * pendingOItem.getQuantity();
1155
                    }
1156
                }
1157
            }
1158
 
35737 amit 1159
            itemIdAndPoiMap = pendingOrderItems.stream().collect(Collectors.toMap(PendingOrderItem::getItemId, x -> x));
33437 ranu 1160
        }
1161
 
33795 ranu 1162
 
1163
//        get the list of customer item for every item code start here
1164
//        ...............................................................
1165
 
1166
        LocalDateTime todayDate = LocalDateTime.now();
1167
        LocalDate todayDate2 = LocalDate.now();
1168
 
1169
        Map<Integer, List<CustomerOfferItem>> offerItemMap = new HashMap<>();
1170
        Map<Integer, List<WebOffer>> webOfferMap = new HashMap<>();
1171
 
1172
        List<CustomerOffer> customerOffers = customerOfferRepository.selectOffersByDate(todayDate);
1173
        List<Integer> customerOfferIds = customerOffers.stream().map(x -> x.getId()).distinct().collect(Collectors.toList());
34788 ranu 1174
        /*for (CartFofo cartItem : cartItems) {
33795 ranu 1175
            Item item = itemRepository.selectById(cartItem.getItemId());
33907 amit.gupta 1176
            if (customerOfferIds.size() > 0) {
33795 ranu 1177
 
33907 amit.gupta 1178
                List<CustomerOfferItem> customerOfferItems = customerOfferItemRepository.selectByOfferIds(customerOfferIds, item.getCatalogItemId(), todayDate2);
33795 ranu 1179
 
33907 amit.gupta 1180
                List<CustomerOfferItem> filteredCustomerOfferItems = customerOfferItems.stream()
1181
                        .filter(x -> x.getEndDate() != null && !x.getEndDate().isBefore(todayDate2))
1182
                        .collect(Collectors.toList());
33795 ranu 1183
 
33907 amit.gupta 1184
                offerItemMap.put(item.getId(), filteredCustomerOfferItems);
1185
            }
33818 ranu 1186
 
33907 amit.gupta 1187
 
33795 ranu 1188
            List<WebOffer> webOffers = webOfferRepository.selectAllActiveOffers().get(item.getCatalogItemId());
1189
            webOfferMap.put(item.getId(), webOffers);
34788 ranu 1190
        }*/
1191
 
1192
 
1193
        Map<Integer, ItemWiseCustomerOfferSummaryModel> offerItemSummaryMap = new HashMap<>();
35737 amit 1194
        Map<Integer, Item> cartItemMap = itemRepository.selectByIds(itemIds).stream()
1195
                .collect(Collectors.toMap(Item::getId, item -> item));
34788 ranu 1196
 
1197
        for (CartFofo cartItem : cartItems) {
35737 amit 1198
            Item item = cartItemMap.get(cartItem.getItemId());
34838 amit 1199
            List<CustomerOfferItem> customerOfferItems = null;
1200
            if (customerOfferIds.size() > 0) {
1201
                customerOfferItems = customerOfferItemRepository
1202
                        .selectByOfferIds(customerOfferIds, item.getCatalogItemId(), todayDate2)
1203
                        .stream()
1204
                        .filter(x -> x.getEndDate() != null && !x.getEndDate().isBefore(todayDate2))
1205
                        .collect(Collectors.toList());
1206
            }
34788 ranu 1207
 
1208
 
1209
            ItemWiseCustomerOfferSummaryModel summary = new ItemWiseCustomerOfferSummaryModel();
1210
            summary.setItemId(item.getId());
1211
            summary.setCatalogId(item.getCatalogItemId());
1212
 
34838 amit 1213
            if (customerOfferItems != null) {
1214
                for (CustomerOfferItem coi : customerOfferItems) {
1215
                    String key = coi.getOfferType().name() + "-" + coi.getCustomerOfferId();
34788 ranu 1216
 
34838 amit 1217
                    ItemWiseCustomerOfferSummaryModel.OfferTypeSummary typeSummary =
1218
                            summary.getOfferTypeMap().computeIfAbsent(key, k -> {
1219
                                ItemWiseCustomerOfferSummaryModel.OfferTypeSummary ts = new ItemWiseCustomerOfferSummaryModel.OfferTypeSummary();
1220
                                ts.setOfferType(coi.getOfferType());
1221
                                ts.setCustomerOfferId(coi.getCustomerOfferId());
1222
                                return ts;
1223
                            });
34788 ranu 1224
 
34838 amit 1225
                    typeSummary.setTotalSchemePayout(typeSummary.getTotalSchemePayout() + coi.getSchemePayout());
1226
                    typeSummary.setTotalDealerPayout(typeSummary.getTotalDealerPayout() + coi.getDealerPayout());
1227
                    typeSummary.getDescriptions().add(coi.getAdditionalInfo());
1228
                    typeSummary.getOfferItemIds().add(coi.getId());
1229
                }
34788 ranu 1230
            }
1231
 
1232
            offerItemSummaryMap.put(item.getId(), summary);
33795 ranu 1233
        }
1234
 
34788 ranu 1235
 
33795 ranu 1236
//        get the list of customer item for every item code end here
1237
//        ...............................................................
1238
 
33437 ranu 1239
        LOGGER.info("itemIdAndPoiMap {}", itemIdAndPoiMap);
1240
        LOGGER.info("mopPriceMap {}", mopPriceMap);
1241
        model.addAttribute("stateNames",
1242
                stateRepository.selectAll().stream().map(x -> x.getName()).collect(Collectors.toList()));
1243
        model.addAttribute("retailerStateName", address.getState());
1244
        model.addAttribute("pendingPOCustomer", gson.toJson(customer));
1245
        model.addAttribute("pendingPO", gson.toJson(po));
1246
 
1247
        model.addAttribute("cartItems", cartItems);
1248
        model.addAttribute("pendingOrder", po);
1249
        model.addAttribute("pendingOrderItem", poi);
1250
        model.addAttribute("itemIdAndPoiMap", itemIdAndPoiMap);
1251
        model.addAttribute("onlineSellingPrice", onlineSellingPrice);
1252
 
1253
        model.addAttribute("mopPriceMap", mopPriceMap);
1254
        model.addAttribute("paymentOptions", paymentOptions);
1255
        model.addAttribute("accessoriesDeals", accessoriesDeals);
33795 ranu 1256
        model.addAttribute("webOfferMap", webOfferMap);
34788 ranu 1257
        model.addAttribute("offerItemSummaryMap", offerItemSummaryMap);
36394 amit 1258
        model.addAttribute("fofoId", loginDetails.getFofoId());
35726 vikas 1259
 
1260
        // Fetch pinelabs offers from cache and group by issuer display name
1261
        Map<Integer, Map<String, List<Tenure>>> pinelabsOfferMap =
1262
                pinelabsOfferCacheService.getGroupedCachedOffersForItems(new ArrayList<>(itemIds));
1263
        model.addAttribute("pinelabsOfferMap", pinelabsOfferMap);
1264
 
33437 ranu 1265
        return "order-index";
1266
    }
1267
 
1268
    private Map<String, List<MobileInsurancePlan>> getPlans(float sellingPrice, int itemId, int poiId)
1269
            throws ProfitMandiBusinessException {
33213 tejus.loha 1270
        try {
33437 ranu 1271
            Map<String, List<MobileInsurancePlan>> productDurationPlans = new HashMap<>();
1272
            PendingOrderPlan pendingOrderPlan = null;
1273
            if (poiId > 0) {
1274
                pendingOrderPlan = pendingOrderPlanRepository.selectByPoid(poiId);
1275
            }
1276
            if (pendingOrderPlan != null) {
33715 ranu 1277
                MobileInsurancePlan productDurationPlan = insuranceService.getPlanById(String.valueOf(pendingOrderPlan.getPlanId()), sellingPrice);
33437 ranu 1278
                productDurationPlans.put(pendingOrderPlan.getPlanName(), Collections.singletonList(productDurationPlan));
1279
 
1280
            } else {
1281
                productDurationPlans = insuranceService.getAllPlans(itemId,
1282
                        sellingPrice, false);
1283
            }
1284
 
33213 tejus.loha 1285
            return productDurationPlans;
1286
        } catch (Exception e) {
1287
            LOGGER.info(e, e);
1288
            throw new ProfitMandiBusinessException("Fetch Insurance Plans", "Insurance",
1289
                    "Could not fetch insurance Plans");
1290
        }
24105 govind 1291
 
33213 tejus.loha 1292
    }
23973 govind 1293
 
33795 ranu 1294
 
1295
    @GetMapping("/getItemWiseUpgradeOffer")
1296
    public String getItemWiseUpgradeOffer(HttpServletRequest request, @RequestParam int itemId, Model model)
1297
            throws ProfitMandiBusinessException {
1298
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1299
 
1300
        Item item = itemRepository.selectById(itemId);
1301
 
1302
        LocalDateTime todayDate = LocalDateTime.now();
1303
        LocalDate todayDate2 = LocalDate.now();
1304
 
1305
        List<CustomerOffer> customerOffers = customerOfferRepository.selectOffersByDate(todayDate);
1306
        Map<Integer, CustomerOffer> customerOfferMap = customerOffers.stream().collect(Collectors.toMap(x -> x.getId(), x -> x));
1307
        List<Integer> customerOfferIds = customerOffers.stream().map(x -> x.getId()).distinct().collect(Collectors.toList());
1308
        List<CustomerOfferItem> customerOfferItems = customerOfferItemRepository.selectByOfferIds(customerOfferIds, item.getCatalogItemId(), todayDate2);
1309
 
33818 ranu 1310
        List<CustomerOfferItem> filteredCustomerOfferItems = customerOfferItems.stream()
33822 ranu 1311
                .filter(x -> x.getEndDate() != null && !x.getEndDate().isBefore(todayDate2))
33818 ranu 1312
                .collect(Collectors.toList());
1313
 
33795 ranu 1314
        List<WebOffer> webOffers = webOfferRepository.selectAllActiveOffers().get(item.getCatalogItemId());
1315
 
1316
        model.addAttribute("webOffers", webOffers);
1317
        model.addAttribute("customerOfferMap", customerOfferMap);
33818 ranu 1318
        model.addAttribute("customerOfferItems", filteredCustomerOfferItems);
33795 ranu 1319
 
1320
        return "upgrade-customer-offer-model";
1321
    }
1322
 
33213 tejus.loha 1323
    @GetMapping("/insuranceDetails")
1324
    public String getInsuranceDetails(HttpServletRequest request,
1325
                                      @RequestParam(name = "offset", defaultValue = "0") int offset,
1326
                                      @RequestParam(name = "limit", defaultValue = "10") int limit, Model model)
1327
            throws ProfitMandiBusinessException {
1328
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1329
        long size = 0;
1330
        List<InsurancePolicy> insurancePolicies = insurancePolicyRepository.selectByRetailerId(loginDetails.getFofoId(),
1331
                offset, limit);
1332
        size = insurancePolicyRepository.selectCountByRetailerId(loginDetails.getFofoId());
1333
        Map<Integer, String> providerPolicyNameAndIdMap = insuranceProviderRepository
1334
                .selectByIds(insurancePolicies.stream().map(x -> x.getProviderId()).collect(Collectors.toSet()))
1335
                .stream().collect(Collectors.toMap(InsuranceProvider::getId, InsuranceProvider::getName));
1336
        if (size < limit) {
1337
            model.addAttribute("end", offset + size);
1338
        } else {
1339
            model.addAttribute("end", offset + limit);
1340
        }
1341
        model.addAttribute("start", offset + 1);
1342
        model.addAttribute("size", size);
1343
        model.addAttribute("insurancePolicies", insurancePolicies);
1344
        model.addAttribute("providerPolicyNameAndIdMap", providerPolicyNameAndIdMap);
1345
        return "insurance-details";
1346
    }
28339 tejbeer 1347
 
33213 tejus.loha 1348
    @GetMapping("/insuranceDetailsPaginated")
1349
    public String getInsuranceDetailsPaginated(HttpServletRequest request,
1350
                                               @RequestParam(name = "offset", defaultValue = "0") int offset,
1351
                                               @RequestParam(name = "limit", defaultValue = "10") int limit, Model model)
1352
            throws ProfitMandiBusinessException {
1353
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1354
        List<InsurancePolicy> insurancePolicies = insurancePolicyRepository.selectByRetailerId(loginDetails.getFofoId(),
1355
                offset, limit);
1356
        Map<Integer, String> providerPolicyNameAndIdMap = insuranceProviderRepository
1357
                .selectByIds(insurancePolicies.stream().map(x -> x.getProviderId()).collect(Collectors.toSet()))
1358
                .stream().collect(Collectors.toMap(InsuranceProvider::getId, InsuranceProvider::getName));
1359
        model.addAttribute("insurancePolicies", insurancePolicies);
1360
        model.addAttribute("providerPolicyNameAndIdMap", providerPolicyNameAndIdMap);
1361
        return "insurance-details-paginated";
1362
    }
23973 govind 1363
 
33213 tejus.loha 1364
    @GetMapping("/getMouForm")
1365
    public String getMouForm(HttpServletRequest request, Model model) throws Exception {
1366
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
21985 kshitij.so 1367
 
33213 tejus.loha 1368
        Mou mou = mouRepository.selectByFofoId(loginDetails.getFofoId());
1369
        if (mou != null) {
1370
            if (mou.getUpdateTimestamp().getMonth().equals(LocalDateTime.now().getMonth())) {
1371
                model.addAttribute("response1", mvcResponseSender.createResponseString(true));
1372
            } else {
1373
                model.addAttribute("response1", mvcResponseSender.createResponseString(false));
1374
            }
32238 amit.gupta 1375
 
33213 tejus.loha 1376
        } else {
1377
            model.addAttribute("response1", mvcResponseSender.createResponseString(false));
32238 amit.gupta 1378
 
33213 tejus.loha 1379
        }
1380
        return "response";
32238 amit.gupta 1381
 
33213 tejus.loha 1382
    }
23973 govind 1383
 
33213 tejus.loha 1384
    @GetMapping("/pendingOrders")
1385
    public String getPendingOrders(HttpServletRequest request, Model model) throws ProfitMandiBusinessException {
1386
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1387
        boolean isAdmin = roleManager.isAdmin(loginDetails.getRoleIds());
1388
        Mou mou = mouRepository.selectByFofoId(loginDetails.getFofoId());
1389
        if (mou == null) {
1390
            mou = new Mou();
1391
            mou.setFofoId(loginDetails.getFofoId());
1392
            mou.setCreateTimestamp(LocalDateTime.now());
1393
            mou.setUpdateTimestamp(LocalDateTime.now());
1394
            mouRepository.persist(mou);
1395
        } else if (!mou.getUpdateTimestamp().getMonth().equals(LocalDateTime.now().getMonth())) {
1396
            mou.setUpdateTimestamp(LocalDateTime.now());
1397
        }
24844 amit.gupta 1398
 
33213 tejus.loha 1399
        List<PendingOrderItem> pendingOrderItems = pendingOrderItemRepository.selectOrderItemByStatusAndFofoId(OrderStatus.PROCESSING,
1400
                loginDetails.getFofoId());
23973 govind 1401
 
34387 vikas.jang 1402
        Map<String, List<PendingOrderPlan>> pendingOrderPlansMap = pendingOrderPlanRepository.selectAll().stream()
1403
                .collect(Collectors.groupingBy(PendingOrderPlan::getPlanId));
33213 tejus.loha 1404
        Map<String, Object> map = pendingOrderService.getItemOrders(pendingOrderItems, loginDetails.getFofoId());
1405
        model.addAttribute("inventoryMap", map.get("inventoryMap"));
33437 ranu 1406
        model.addAttribute("pendingOrderPlansMap", pendingOrderPlansMap);
33213 tejus.loha 1407
        model.addAttribute("pendingOrderItems", (List<PendingOrderItem>) map.get("pendingOrderItems"));
23973 govind 1408
 
33213 tejus.loha 1409
        model.addAttribute("isAdmin", isAdmin);
1410
        return "pending_fofo_order";
25092 amit.gupta 1411
 
33213 tejus.loha 1412
    }
25092 amit.gupta 1413
 
33400 ranu 1414
    @RequestMapping(value = "/create-order", method = RequestMethod.POST)
1415
    public String createOrder(HttpServletRequest request, @RequestBody CreateOrderRequest createOrderRequest,
34194 ranu 1416
                              Model model) throws Exception {
33400 ranu 1417
        // throw new ProfitMandiBusinessException("Billing is on hold temporarily",
1418
        // "Billing is on hold temporarily", "Billing is on hold temporarily");
1419
        LOGGER.info("request at uri {}", request.getRequestURI());
1420
        LOGGER.info("request body {}", createOrderRequest);
1421
        LoginDetails fofoDetails = cookiesProcessor.getCookiesObject(request);
1422
        int fofoOrderId = orderService.createOrder(createOrderRequest, fofoDetails.getFofoId(), accessoriesDeals);
35084 aman 1423
        try {
35064 aman 1424
            Set<Integer> fofoOrderItemIds = createOrderRequest.getFofoOrderItems()
1425
                    .stream().map(CustomFofoOrderItem::getItemId).collect(Collectors.toSet());
1426
            scratchService.processScratchOffer(fofoOrderId, createOrderRequest.getPaymentOptions(), fofoOrderItemIds);
1427
        } catch (Exception e) {
35095 aman 1428
            LOGGER.error("Exception during processScratchOffer for order {}: {}", fofoOrderId, e.getMessage(), e);
35084 aman 1429
        }
34479 tejus.loha 1430
 
34179 tejus.loha 1431
        LOGGER.info("Order has been created successfully...");
36064 aman 1432
 
1433
        if (createOrderRequest.isSendInvoiceOnWhatsApp()) {
1434
            try {
1435
                FofoOrder fofoOrder = fofoOrderRepository.selectByOrderId(fofoOrderId);
1436
                if (fofoOrder != null && fofoOrder.getInvoiceNumber() != null) {
1437
                    notificationService.sendWhatsappInvoice(fofoOrder.getCustomerId(), fofoOrder.getFofoId(), fofoOrder.getInvoiceNumber(), "");
1438
                    LOGGER.info("WhatsApp invoice sent automatically for order {}", fofoOrderId);
1439
                }
1440
            } catch (Exception e) {
1441
                LOGGER.error("Failed to auto-send WhatsApp invoice for order {}", fofoOrderId, e);
1442
            }
1443
        }
1444
 
33400 ranu 1445
        return "redirect:/get-order/?orderId=" + fofoOrderId;
1446
    }
1447
 
33213 tejus.loha 1448
    @GetMapping("/billedOrders")
1449
    public String getBilledOrders(HttpServletRequest request, Model model) throws ProfitMandiBusinessException {
1450
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1451
        boolean isAdmin = roleManager.isAdmin(loginDetails.getRoleIds());
25092 amit.gupta 1452
 
33400 ranu 1453
        List<PendingOrderItem> pendingOrderItems;
23973 govind 1454
 
33213 tejus.loha 1455
        if (isAdmin) {
27861 tejbeer 1456
 
33400 ranu 1457
            pendingOrderItems = pendingOrderItemRepository.selectOrderItemByStatus(OrderStatus.BILLED);
27861 tejbeer 1458
 
33213 tejus.loha 1459
        } else {
33400 ranu 1460
            pendingOrderItems = pendingOrderItemRepository.selectOrderItemByStatusAndFofoId(OrderStatus.BILLED,
33213 tejus.loha 1461
                    loginDetails.getFofoId());
33400 ranu 1462
 
1463
 
33213 tejus.loha 1464
        }
27861 tejbeer 1465
 
33400 ranu 1466
        Map<String, Object> map = pendingOrderService.getItemOrders(pendingOrderItems, loginDetails.getFofoId());
1467
        model.addAttribute("pendingOrderItems", (List<PendingOrderItem>) map.get("pendingOrderItems"));
27861 tejbeer 1468
 
33213 tejus.loha 1469
        model.addAttribute("isAdmin", isAdmin);
1470
        return "billed_order_item";
1471
    }
27861 tejbeer 1472
 
33213 tejus.loha 1473
    @GetMapping("/settledOrders")
1474
    public String getSettledOrders(HttpServletRequest request, Model model) throws ProfitMandiBusinessException {
1475
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1476
        boolean isAdmin = roleManager.isAdmin(loginDetails.getRoleIds());
27861 tejbeer 1477
 
33213 tejus.loha 1478
        List<PendingOrderItem> pendingOrderItem = null;
27861 tejbeer 1479
 
33213 tejus.loha 1480
        if (isAdmin) {
24105 govind 1481
 
33213 tejus.loha 1482
            pendingOrderItem = pendingOrderItemRepository.selectOrderItemByStatus(OrderStatus.SETTLED);
24105 govind 1483
 
33213 tejus.loha 1484
        } else {
1485
            pendingOrderItem = pendingOrderItemRepository.selectOrderItemByStatusAndFofoId(OrderStatus.SETTLED,
1486
                    loginDetails.getFofoId());
1487
        }
24105 govind 1488
 
33213 tejus.loha 1489
        Map<String, Object> map = pendingOrderService.getItemOrders(pendingOrderItem, loginDetails.getFofoId());
24105 govind 1490
 
33400 ranu 1491
        model.addAttribute("pendingOrderItems", (List<PendingOrderItem>) map.get("pendingOrderItems"));
33213 tejus.loha 1492
        model.addAttribute("isAdmin", isAdmin);
1493
        return "settled_order_item";
1494
    }
27861 tejbeer 1495
 
33213 tejus.loha 1496
    @GetMapping("/unsettledOrders")
1497
    public String getunsettledOrders(HttpServletRequest request, Model model) throws ProfitMandiBusinessException {
1498
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1499
        boolean isAdmin = roleManager.isAdmin(loginDetails.getRoleIds());
24105 govind 1500
 
33213 tejus.loha 1501
        List<PendingOrderItem> pendingOrderItem = null;
27861 tejbeer 1502
 
33213 tejus.loha 1503
        if (isAdmin) {
24105 govind 1504
 
33213 tejus.loha 1505
            pendingOrderItem = pendingOrderItemRepository.selectOrderItemByStatus(OrderStatus.UNSETTLED);
27861 tejbeer 1506
 
33213 tejus.loha 1507
        } else {
1508
            pendingOrderItem = pendingOrderItemRepository.selectOrderItemByStatusAndFofoId(OrderStatus.UNSETTLED,
1509
                    loginDetails.getFofoId());
1510
        }
24440 amit.gupta 1511
 
33213 tejus.loha 1512
        Map<String, Object> map = pendingOrderService.getItemOrders(pendingOrderItem, loginDetails.getFofoId());
25726 amit.gupta 1513
 
33400 ranu 1514
        model.addAttribute("pendingOrderItems", (List<PendingOrderItem>) map.get("pendingOrderItems"));
33213 tejus.loha 1515
        model.addAttribute("isAdmin", isAdmin);
1516
        return "unsettled_order_item";
1517
    }
24880 govind 1518
 
33213 tejus.loha 1519
    @GetMapping("/getPendingOrderItem")
1520
    public String getPendingOrderItem(HttpServletRequest request, @RequestParam int orderId, Model model)
1521
            throws ProfitMandiBusinessException {
1522
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1523
        Map<Integer, Item> itemMap = new HashMap<>();
1524
        Map<Integer, CurrentInventorySnapshot> inventoryMap = new HashMap<>();
1525
        PendingOrder pendingPO = pendingOrderRepository.selectById(orderId);
1526
        Customer customer = customerRepository.selectById(pendingPO.getCustomerId());
1527
        List<PendingOrderItem> pendingOrderItems = pendingOrderItemRepository.selectByOrderId(orderId);
35737 amit 1528
        Set<Integer> poItemIds = pendingOrderItems.stream().map(PendingOrderItem::getItemId).collect(Collectors.toSet());
1529
        itemMap = itemRepository.selectByIds(poItemIds).stream()
1530
                .collect(Collectors.toMap(Item::getId, item -> item));
1531
        List<CurrentInventorySnapshot> snapshots = currentInventorySnapshotRepository
1532
                .selectByFofoItemIds(pendingPO.getFofoId(), poItemIds);
1533
        for (CurrentInventorySnapshot cis : snapshots) {
1534
            LOGGER.info("cis: {}", cis);
1535
            inventoryMap.put(cis.getItemId(), cis);
33213 tejus.loha 1536
        }
28339 tejbeer 1537
 
35737 amit 1538
        LOGGER.info("inventoryMap: {}", inventoryMap);
33213 tejus.loha 1539
        model.addAttribute("pendingOrderItems", pendingOrderItems);
1540
        model.addAttribute("itemMap", itemMap);
1541
        model.addAttribute("inventoryMap", inventoryMap);
1542
        model.addAttribute("pendingPO", gson.toJson(pendingPO));
1543
        model.addAttribute("pendingPOCustomer", gson.toJson(customer));
1544
        model.addAttribute("isAdmin", roleManager.isAdmin(loginDetails.getRoleIds()));
1545
        return "pending-order-item";
1546
    }
28339 tejbeer 1547
 
33213 tejus.loha 1548
    @RequestMapping(value = "/getPendingOrderItemById", method = RequestMethod.GET)
1549
    public String getPendingOrderItemById(HttpServletRequest request, @RequestParam int id, Model model)
1550
            throws Exception {
27046 tejbeer 1551
 
33213 tejus.loha 1552
        PendingOrderItem pendingOrderItem = pendingOrderItemRepository.selectById(id);
1553
        model.addAttribute("pendingOrderItem", pendingOrderItem);
1554
        return "cancel-pending-order";
1555
    }
27046 tejbeer 1556
 
33213 tejus.loha 1557
    @RequestMapping(value = "/getPendingOrderChangePartnerById", method = RequestMethod.GET)
33367 ranu 1558
    public String getPendingOrderChangePartnerById(HttpServletRequest request, @RequestParam int id, @RequestParam String pinCode, Model model)
33213 tejus.loha 1559
            throws Exception {
28350 tejbeer 1560
 
33213 tejus.loha 1561
        PendingOrder pendingOrder = pendingOrderRepository.selectById(id);
33374 ranu 1562
        Map<Integer, CustomRetailer> customRetailersMap = retailerService.getFofoRetailers(true);
33213 tejus.loha 1563
        model.addAttribute("customRetailersMap", customRetailersMap);
1564
        model.addAttribute("pendingOrder", pendingOrder);
1565
        return "change-partner-po";
1566
    }
28358 tejbeer 1567
 
33213 tejus.loha 1568
    @RequestMapping(value = "/changePendingOrderPartner", method = RequestMethod.POST)
1569
    public String changePendingOrderPartner(HttpServletRequest request, @RequestParam int id, @RequestParam int fofoId,
1570
                                            Model model) throws Exception {
28350 tejbeer 1571
 
33213 tejus.loha 1572
        PendingOrder pendingOrder = pendingOrderRepository.selectById(id);
1573
        pendingOrder.setFofoId(fofoId);
1574
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
28339 tejbeer 1575
 
33213 tejus.loha 1576
        return "response";
1577
    }
28339 tejbeer 1578
 
33213 tejus.loha 1579
    @RequestMapping(value = "/cancelPendingOrderItem", method = RequestMethod.POST)
1580
    public String cancelPendingOrderItem(HttpServletRequest request, @RequestParam int id, @RequestParam String reason,
1581
                                         Model model) throws Exception {
28339 tejbeer 1582
 
33213 tejus.loha 1583
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1584
        PendingOrderItem pendingOrderItem = pendingOrderItemRepository.selectById(id);
28339 tejbeer 1585
 
33213 tejus.loha 1586
        pendingOrderItem.setStatus(OrderStatus.CANCELLED);
1587
        pendingOrderItem.setStatusDescription(loginDetails.getEmailId());
1588
        pendingOrderItem.setRemark(reason);
1589
        pendingOrderItem.setCancelledTimestamp(LocalDateTime.now());
1590
        PendingOrder pendingOrder = pendingOrderRepository.selectById(pendingOrderItem.getOrderId());
27046 tejbeer 1591
 
33213 tejus.loha 1592
        List<OrderStatus> status = pendingOrderItemRepository.selectByOrderId(pendingOrderItem.getOrderId()).stream()
1593
                .map(x -> x.getStatus()).collect(Collectors.toList());
28339 tejbeer 1594
 
33213 tejus.loha 1595
        Customer customer = customerRepository.selectById(pendingOrder.getCustomerId());
26647 tejbeer 1596
 
33213 tejus.loha 1597
        List<Integer> catalogIds = new ArrayList<>();
28339 tejbeer 1598
 
33213 tejus.loha 1599
        Item item = itemRepository.selectById(pendingOrderItem.getItemId());
1600
        pendingOrderItem.setItemName(item.getItemDescription());
1601
        catalogIds.add(item.getCatalogItemId());
28339 tejbeer 1602
 
33213 tejus.loha 1603
        Map<Integer, JSONObject> contentMap = commonSolrService.getContentByCatalogIds(catalogIds);
1604
        JSONObject jsonObj = contentMap.get(item.getCatalogItemId());
1605
        pendingOrderItem.setImgUrl(jsonObj.getString("imageUrl_s"));
1606
        pendingOrder.setPendingOrderItems(Arrays.asList(pendingOrderItem));
1607
        CustomerAddress customerAddress = customerAddressRepository.selectById(pendingOrder.getCustomerAddressId());
28339 tejbeer 1608
 
33213 tejus.loha 1609
        DateTimeFormatter dateTimeFormatter = DateTimeFormatter.ofPattern("dd/MM/yyyy h:mm a");
28339 tejbeer 1610
 
33213 tejus.loha 1611
        Map<String, Object> emailModel = new HashMap<>();
1612
        emailModel.put("customer", customerAddress);
1613
        emailModel.put("pendingOrder", pendingOrder);
1614
        emailModel.put("date", dateTimeFormatter);
35737 amit 1615
        LOGGER.info("email: {}", customer.getEmailId());
33213 tejus.loha 1616
        String[] customerEmail = null;
1617
        if (customer.getEmailId() != null && !customer.getEmailId().isEmpty()) {
1618
            customerEmail = new String[]{customer.getEmailId()};
28339 tejbeer 1619
 
34211 vikas.jang 1620
            List<String> bccTo = Arrays.asList("vikas.jangra@smartdukaan.com");
28339 tejbeer 1621
 
33213 tejus.loha 1622
            emailService.sendMailWithAttachments("Order Cancellation", "order-cancellation.vm", emailModel,
1623
                    customerEmail, null, bccTo.toArray(new String[0]));
28339 tejbeer 1624
 
33213 tejus.loha 1625
        }
28339 tejbeer 1626
 
33213 tejus.loha 1627
        if (!status.contains(OrderStatus.PENDING) && !status.contains(OrderStatus.PROCESSING)
1628
                && !status.contains(OrderStatus.BILLED) && !status.contains(OrderStatus.UNSETTLED)
1629
                && !status.contains(OrderStatus.CLAIMED)) {
1630
            pendingOrder.setStatus(OrderStatus.CLOSED);
1631
        }
1632
        pendingOrderItemRepository.persist(pendingOrderItem);
28339 tejbeer 1633
 
33213 tejus.loha 1634
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
28339 tejbeer 1635
 
33213 tejus.loha 1636
        return "response";
1637
    }
28339 tejbeer 1638
 
33400 ranu 1639
    @GetMapping("/claimedOrders")
1640
    public String getclaimedOrders(HttpServletRequest request, Model model) throws ProfitMandiBusinessException {
33213 tejus.loha 1641
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
33400 ranu 1642
        boolean isAdmin = roleManager.isAdmin(loginDetails.getRoleIds());
1643
        List<Integer> fofoIds = fofoStoreRepository.selectActiveStores().stream().map(x -> x.getId())
1644
                .collect(Collectors.toList());
28339 tejbeer 1645
 
33400 ranu 1646
        List<PendingOrderItem> pendingOrderItem = null;
28339 tejbeer 1647
 
33400 ranu 1648
        if (isAdmin) {
28339 tejbeer 1649
 
33400 ranu 1650
            pendingOrderItem = pendingOrderItemRepository.selectOrderItemByStatus(OrderStatus.CLAIMED);
1651
            Map<Integer, CustomRetailer> customRetailerMap = retailerService.getAllFofoRetailers();
28339 tejbeer 1652
 
33400 ranu 1653
            Map<Integer, CustomRetailer> customRetailersMap = fofoIds.stream().map(x -> customRetailerMap.get(x))
1654
                    .filter(x -> x != null).collect(Collectors.toList()).stream()
1655
                    .collect(Collectors.toMap(x -> x.getPartnerId(), x -> x));
1656
            model.addAttribute("customRetailersMap", customRetailersMap);
28339 tejbeer 1657
 
33400 ranu 1658
        } else {
1659
            pendingOrderItem = pendingOrderItemRepository.selectOrderItemByStatusAndFofoId(OrderStatus.CLAIMED,
1660
                    loginDetails.getFofoId());
1661
        }
30426 tejbeer 1662
 
33400 ranu 1663
        Map<String, Object> map = pendingOrderService.getItemOrders(pendingOrderItem, loginDetails.getFofoId());
28339 tejbeer 1664
 
33400 ranu 1665
        model.addAttribute("pendingOrderItems", map.get("pendingOrderItems"));
1666
        model.addAttribute("isAdmin", isAdmin);
1667
        return "claim_raised_order_item";
33213 tejus.loha 1668
    }
27046 tejbeer 1669
 
33213 tejus.loha 1670
    @RequestMapping(value = "/raiseClaimOrderItem", method = RequestMethod.POST)
1671
    public String raiseClaimOrderItem(HttpServletRequest request, @RequestParam int id, Model model) throws Exception {
28352 tejbeer 1672
 
33213 tejus.loha 1673
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1674
        PendingOrderItem pendingOrderItem = pendingOrderItemRepository.selectById(id);
1675
        PendingOrder pendingOrder = pendingOrderRepository.selectById(pendingOrderItem.getOrderId());
28437 tejbeer 1676
 
33213 tejus.loha 1677
        if (pendingOrder.getTotalAmount() == pendingOrder.getPaidAmount()) {
1678
            pendingOrderItem.setStatus(OrderStatus.CLAIMED);
1679
            pendingOrderItem.setClaimedTimestamp(LocalDateTime.now());
28437 tejbeer 1680
 
33213 tejus.loha 1681
        }
1682
        pendingOrderItemRepository.persist(pendingOrderItem);
1683
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
28437 tejbeer 1684
 
33213 tejus.loha 1685
        return "response";
1686
    }
28437 tejbeer 1687
 
33213 tejus.loha 1688
    @RequestMapping(value = "/verifyOrderItem", method = RequestMethod.POST)
1689
    public String verifyOrderItem(HttpServletRequest request, @RequestParam int id, Model model) throws Exception {
28437 tejbeer 1690
 
33213 tejus.loha 1691
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1692
        PendingOrderItem pendingOrderItem = pendingOrderItemRepository.selectById(id);
1693
        pendingOrderItem.setVerifiedTimestamp(LocalDateTime.now());
28352 tejbeer 1694
 
33213 tejus.loha 1695
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
26721 tejbeer 1696
 
33213 tejus.loha 1697
        return "response";
1698
    }
26721 tejbeer 1699
 
33213 tejus.loha 1700
    @RequestMapping(value = "/cancelOrderByInvoice", method = RequestMethod.POST)
1701
    public String cancelOrder(HttpServletRequest request, @RequestParam List<String> invoiceNumbers, Model model)
1702
            throws Exception {
1703
        orderService.cancelOrder(invoiceNumbers);
1704
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
26721 tejbeer 1705
 
33213 tejus.loha 1706
        return "response";
1707
    }
28352 tejbeer 1708
 
33213 tejus.loha 1709
    @RequestMapping(value = "/getOnlineOrder", method = RequestMethod.GET)
1710
    public String cancelOrder(HttpServletRequest request, Model model) throws Exception {
1711
        return "online-order";
1712
    }
28352 tejbeer 1713
 
33400 ranu 1714
    @RequestMapping(value = "/deliveredPendingOrderItem", method = RequestMethod.POST)
1715
    public String deliveredPendingOrderItem(HttpServletRequest request, @RequestParam(name = "id") int pendingOrderItemId, Model model)
1716
            throws Exception {
1717
 
1718
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1719
        PendingOrderItem pendingOrderItem = pendingOrderItemRepository.selectById(pendingOrderItemId);
1720
        PendingOrder pendingOrder = pendingOrderRepository.selectById(pendingOrderItem.getOrderId());
1721
 
1722
        //Prepaid payment successful
1723
        if (pendingOrder.getTotalAmount() == pendingOrder.getPaidAmount()) {
1724
            //pendingOrderItem.setStatus(OrderStatus.UNSETTLED);
1725
//            pendingOrderItem.setSettled(false);
1726
            pendingOrderItem.setStatus(OrderStatus.CLAIMED);
1727
            pendingOrderItem.setClaimedTimestamp(LocalDateTime.now());
1728
        } else {
1729
            pendingOrderItem.setStatus(OrderStatus.SETTLED);
1730
        }
1731
        pendingOrderItem.setDeliveredTimestamp(LocalDateTime.now());
1732
 
1733
        List<OrderStatus> pendingOrderItemStatusList = pendingOrderItemRepository.selectByOrderId(pendingOrderItem.getOrderId()).stream()
1734
                .map(x -> x.getStatus()).collect(Collectors.toList());
1735
 
1736
        List<Integer> catalogIds = new ArrayList<>();
1737
 
1738
        Item item = itemRepository.selectById(pendingOrderItem.getItemId());
1739
        pendingOrderItem.setItemName(item.getItemDescription());
1740
        catalogIds.add(item.getCatalogItemId());
1741
 
1742
        Map<Integer, JSONObject> contentMap = commonSolrService.getContentByCatalogIds(catalogIds);
1743
        JSONObject jsonObj = contentMap.get(item.getCatalogItemId());
1744
        pendingOrderItem.setImgUrl(jsonObj.getString("imageUrl_s"));
1745
        pendingOrder.setPendingOrderItems(Arrays.asList(pendingOrderItem));
1746
        CustomerAddress customerAddress = customerAddressRepository.selectById(pendingOrder.getCustomerAddressId());
1747
        DateTimeFormatter dateTimeFormatter = DateTimeFormatter.ofPattern("dd/MM/yyyy h:mm a");
1748
        Map<String, Object> emailModel = new HashMap<>();
1749
        emailModel.put("customer", customerAddress);
1750
        emailModel.put("pendingOrder", pendingOrder);
1751
        emailModel.put("date", dateTimeFormatter);
1752
        Customer customer = customerRepository.selectById(pendingOrder.getCustomerId());
1753
        String[] customerEmail = null;
1754
        if (customer.getEmailId() != null && !customer.getEmailId().isEmpty()) {
1755
            customerEmail = new String[]{customer.getEmailId()};
34211 vikas.jang 1756
            List<String> bccTo = Arrays.asList("vikas.jangra@smartdukaan.com");
33400 ranu 1757
 
1758
            emailService.sendMailWithAttachments("Order Delivered with SmartDukaan", "order-delivered.vm", emailModel,
1759
                    customerEmail, null, bccTo.toArray(new String[0]));
1760
 
1761
        }
1762
        if (!pendingOrderItemStatusList.contains(OrderStatus.PENDING) && !pendingOrderItemStatusList.contains(OrderStatus.PROCESSING)
1763
                && !pendingOrderItemStatusList.contains(OrderStatus.BILLED) && !pendingOrderItemStatusList.contains(OrderStatus.UNSETTLED)
1764
                && !pendingOrderItemStatusList.contains(OrderStatus.CLAIMED)) {
1765
            pendingOrder.setStatus(OrderStatus.CLOSED);
1766
        }
1767
        pendingOrderItemRepository.persist(pendingOrderItem);
1768
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
1769
 
1770
        return "response";
1771
    }
1772
 
33213 tejus.loha 1773
    @GetMapping("/getAllOrdersByStatus")
1774
    public String getAllOrdersByStatus(HttpServletRequest request, @RequestParam OrderStatus status,
1775
                                       @RequestParam(required = false) LocalDateTime startTime,
1776
                                       @RequestParam(required = false) LocalDateTime endTime, Model model) throws ProfitMandiBusinessException {
1777
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1778
        boolean isAdmin = roleManager.isAdmin(loginDetails.getRoleIds());
33437 ranu 1779
        boolean isAccountsL2AndL3 = false;
33400 ranu 1780
        if (isAdmin) {
1781
            AuthUser authUser = authRepository.selectByEmailOrMobile(loginDetails.getEmailId());
1782
            List<Position> positions = positionRepository.selectPositionByAuthId(authUser.getId());
1783
            for (Position position : positions) {
33437 ranu 1784
                if (((position.getEscalationType().equals(EscalationType.L2) || position.getEscalationType().equals(EscalationType.L3))
33400 ranu 1785
                        && position.getCategoryId() == ProfitMandiConstants.TICKET_CATEGORY_ACCOUNTS)) {
33437 ranu 1786
                    isAccountsL2AndL3 = true;
33400 ranu 1787
                    break;
1788
                }
1789
            }
1790
        }
1791
 
33213 tejus.loha 1792
        LOGGER.info("startTime {}", startTime);
1793
        LOGGER.info("endTime {}", endTime);
28352 tejbeer 1794
 
33213 tejus.loha 1795
        List<PendingOrderItem> pendingOrderItems;
1796
        if (startTime == null) {
33367 ranu 1797
            LocalDate date = LocalDate.now().minusDays(15);
1798
            if (status.equals(OrderStatus.PENDING)) {
1799
                pendingOrderItems = pendingOrderItemRepository.selectByStatusAndCreateTimestamp(Collections.singletonList(status), date.atStartOfDay(), LocalDateTime.now());
1800
            } else {
1801
                pendingOrderItems = pendingOrderItemRepository.selectOrderItemByStatus(status);
1802
            }
1803
 
33213 tejus.loha 1804
        } else {
1805
            List<OrderStatus> statusList = new ArrayList<>();
1806
            if (status.equals(OrderStatus.DELIVERED)) {
1807
                statusList.add(OrderStatus.SETTLED);
1808
                statusList.add(OrderStatus.UNSETTLED);
1809
            } else {
1810
                statusList.add(status);
1811
            }
1812
            pendingOrderItems = pendingOrderItemRepository.selectByStatusAndCreateTimestamp(statusList,
1813
                    startTime.toLocalDate().atStartOfDay(), endTime);
1814
        }
28352 tejbeer 1815
 
33213 tejus.loha 1816
        List<Integer> pendingOrderIds = pendingOrderItems.stream().map(x -> x.getOrderId()).collect(Collectors.toList());
28352 tejbeer 1817
 
33213 tejus.loha 1818
        List<Integer> fofoIds = pendingOrderRepository.selectByIds(pendingOrderIds)
1819
                .stream().map(x -> x.getFofoId()).distinct().collect(Collectors.toList());
28356 tejbeer 1820
 
33213 tejus.loha 1821
        Map<Integer, CustomRetailer> customRetailerMap = retailerService.getAllFofoRetailers();
28352 tejbeer 1822
 
33213 tejus.loha 1823
        Map<Integer, CustomRetailer> customRetailersMap = fofoIds.stream().map(x -> customRetailerMap.get(x))
1824
                .filter(x -> x != null).collect(Collectors.toList()).stream()
1825
                .collect(Collectors.toMap(x -> x.getPartnerId(), x -> x));
1826
        model.addAttribute("customRetailersMap", customRetailersMap);
28352 tejbeer 1827
 
33213 tejus.loha 1828
        LOGGER.info("customRetailersMap {}", customRetailersMap);
28339 tejbeer 1829
 
33213 tejus.loha 1830
        Map<String, Object> map = pendingOrderService.getItemOrders(pendingOrderItems, 0);
32697 ranu 1831
 
33213 tejus.loha 1832
        model.addAttribute("pendingOrderItems", (List<PendingOrderItem>) map.get("pendingOrderItems"));
1833
        model.addAttribute("partnerInventoryMap", map.get("partnerInventoryMap"));
32697 ranu 1834
 
33213 tejus.loha 1835
        model.addAttribute("isAdmin", isAdmin);
33437 ranu 1836
        model.addAttribute("isAccountsL2AndL3", isAccountsL2AndL3);
33213 tejus.loha 1837
        return "online-order-item";
1838
    }
32697 ranu 1839
 
33400 ranu 1840
    @RequestMapping(value = "/onlinePaymentAddToPartnerWallet", method = RequestMethod.POST)
1841
    public String onlinePaymentAddToPartnerWallet(HttpServletRequest request, @RequestParam int id,
1842
                                                  Model model) throws Exception {
1843
        PendingOrderItem pendingOrderItem = pendingOrderItemRepository.selectById(id);
1844
        PendingOrder pendingOrder = pendingOrderRepository.selectById(pendingOrderItem.getOrderId());
1845
        int fofoId = pendingOrder.getFofoId();
1846
        double deductionPayment = (pendingOrderItem.getSellingPrice() * 2.36) / 100;
1847
        walletService.addAmountToWallet(fofoId, id, WalletReferenceType.ONLINE_ORDER_PAYMENT, "Online Order Payment", pendingOrderItem.getSellingPrice(), LocalDateTime.now());
1848
        walletService.consumeAmountFromWallet(fofoId, id,
1849
                WalletReferenceType.ONLINE_GATEWAY_FEE, "Payment Gatewayfee", (float) deductionPayment, LocalDateTime.now());
1850
 
1851
        pendingOrderItem.setStatus(OrderStatus.CLOSED);
1852
        pendingOrder.setStatus(OrderStatus.CLOSED);
1853
 
1854
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
1855
 
1856
        return "response";
1857
    }
1858
 
33213 tejus.loha 1859
    //TODO Tejus
1860
    @RequestMapping(value = "/getBulkOrder")
33336 tejus.loha 1861
    public String getBulkOrder(HttpServletRequest request, Model model) throws ProfitMandiBusinessException, MessagingException, IOException {
33213 tejus.loha 1862
        return "bulk-order";
1863
    }
32697 ranu 1864
 
33213 tejus.loha 1865
    @PostMapping(value = "/bulkOrder/upload")
1866
    public String uploadCatalog(HttpServletRequest request, @RequestPart("file") MultipartFile file, Model model)
1867
            throws Exception {
1868
        LoginDetails fofoDetails = cookiesProcessor.getCookiesObject(request);
1869
        int authId = authRepository.selectByEmailOrMobile(fofoDetails.getEmailId()).getId();
1870
        LOGGER.info("authId - {}", authId);
1871
        bulkOrderService.parseBulkOrders(file, authId);
1872
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
1873
        return "response";
1874
    }
32697 ranu 1875
 
36024 aman 1876
    private static final String PRICE_APPROVAL_EMAIL = "deena.nath@smartdukaan.com";
1877
 
1878
    /**
1879
     * Returns the highest Sales escalation level for this user, or null if not in Sales.
1880
     */
1881
    private EscalationType getSalesEscalationLevel(int authUserId) {
1882
        EscalationType highest = null;
1883
        List<Position> positions = positionRepository.selectPositionByAuthId(authUserId);
1884
        for (Position position : positions) {
1885
            if (position.getCategoryId() == ProfitMandiConstants.TICKET_CATEGORY_SALES) {
1886
                if (highest == null || position.getEscalationType().isGreaterThanEqualTo(highest)) {
1887
                    highest = position.getEscalationType();
1888
                }
1889
            }
1890
        }
1891
        return highest;
1892
    }
1893
 
33213 tejus.loha 1894
    // This method is use for sending all pending transaction to Transation Approval menu
1895
    @RequestMapping(value = "/transaction/pendingApprovals", method = RequestMethod.GET)
1896
    public String getTransactionApproval(HttpServletRequest request, Model model) throws Exception {
36024 aman 1897
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1898
        String email = loginDetails.getEmailId();
1899
        AuthUser authUser = authRepository.selectByEmailOrMobile(email);
1900
 
1901
        boolean canSeeAll = false;
1902
        boolean canSeeFirstPo = false;
1903
        boolean canSeePriceApproval = false;
1904
 
1905
        if (authUser != null) {
1906
            EscalationType salesLevel = getSalesEscalationLevel(authUser.getId());
1907
            if (salesLevel != null) {
1908
                if (salesLevel.isGreaterThanEqualTo(EscalationType.L4)) {
1909
                    canSeeAll = true;
1910
                } else if (salesLevel.isGreaterThanEqualTo(EscalationType.L3)) {
1911
                    canSeeFirstPo = true;
1912
                }
1913
            }
1914
        }
1915
 
1916
        if (PRICE_APPROVAL_EMAIL.equalsIgnoreCase(email)) {
1917
            canSeePriceApproval = true;
36884 ranu 1918
            canSeeAll = true;
36024 aman 1919
        }
1920
 
1921
        List<TransactionApprovalModel> approvalModelList;
1922
        if (canSeeAll || (canSeeFirstPo && canSeePriceApproval)) {
1923
            approvalModelList = bulkOrderService.getAllPendingTransactionApproval();
1924
        } else if (canSeeFirstPo || canSeePriceApproval) {
1925
            List<TransactionApprovalModel> allApprovals = bulkOrderService.getAllPendingTransactionApproval();
1926
            final boolean filterFirstPo = canSeeFirstPo;
1927
            approvalModelList = allApprovals.stream()
1928
                    .filter(a -> filterFirstPo ? a.isFirstPo() : !a.isFirstPo())
1929
                    .collect(Collectors.toList());
1930
        } else {
1931
            approvalModelList = Collections.emptyList();
1932
        }
1933
 
1934
        LOGGER.info("pendingApprovals user={} canSeeAll={} canSeeFirstPo={} canSeePriceApproval={} showing={}",
1935
                email, canSeeAll, canSeeFirstPo, canSeePriceApproval, approvalModelList.size());
33213 tejus.loha 1936
        model.addAttribute("approvalModelList", approvalModelList);
1937
        return "transaction/transaction-approvals";
1938
    }
33092 tejus.loha 1939
 
33213 tejus.loha 1940
    @RequestMapping(value = "transaction/approval", method = RequestMethod.PUT)
1941
    public String transactionApproval(HttpServletRequest request, Model model,
1942
                                      @RequestParam int transactionId,
1943
                                      @RequestParam String remark,
1944
                                      @RequestParam TransactionApprovalStatus transactionApprovalStatus
1945
    ) throws Exception {
1946
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
36024 aman 1947
        String email = loginDetails.getEmailId();
1948
        AuthUser authUser = authRepository.selectByEmailOrMobile(email);
1949
        if (authUser == null) {
1950
            throw new ProfitMandiBusinessException("UNAUTHORIZED", "User not found", "User not found");
1951
        }
1952
 
1953
        EscalationType salesLevel = getSalesEscalationLevel(authUser.getId());
36884 ranu 1954
        boolean isSuperApprover = (salesLevel != null && salesLevel.isGreaterThanEqualTo(EscalationType.L4))
1955
                || PRICE_APPROVAL_EMAIL.equalsIgnoreCase(email);
36024 aman 1956
 
1957
        if (!isSuperApprover) {
1958
            // Verify the user has permission to approve this specific transaction type
1959
            TransactionApproval ta = transactionApprovalRepository.selectById(transactionId);
1960
            if (ta.isFirstPo()) {
1961
                if (salesLevel == null || !salesLevel.isGreaterThanEqualTo(EscalationType.L3)) {
1962
                    throw new ProfitMandiBusinessException("UNAUTHORIZED",
1963
                            "Only Sales L3+ can approve First PO", "Only Sales L3+ can approve First PO");
1964
                }
1965
            } else {
1966
                if (!PRICE_APPROVAL_EMAIL.equalsIgnoreCase(email)) {
1967
                    throw new ProfitMandiBusinessException("UNAUTHORIZED",
1968
                            "Not authorized to approve price difference", "Not authorized to approve price difference");
1969
                }
1970
            }
1971
        }
1972
 
33213 tejus.loha 1973
        int approvalId = authUser.getId();
1974
        String approvedBy = authUser.getFullName();
1975
        LocalDateTime approvedOn = LocalDateTime.now();
1976
        this.updateApprovalStatus(transactionId, approvalId, approvedBy, approvedOn, remark, transactionApprovalStatus);
1977
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
1978
        return "response";
1979
 
1980
    }
1981
 
33696 amit.gupta 1982
 
33213 tejus.loha 1983
    private void updateApprovalStatus(int transactionId, int approvalId, String approvedBy, LocalDateTime approvedOn, String remark, TransactionApprovalStatus transactionApprovalStatus) throws Exception {
1984
        TransactionApproval transactionApproval = transactionApprovalRepository.selectById(transactionId);
33336 tejus.loha 1985
        int retailerId = transactionRepository.selectById(transactionId).getRetailerId();
33213 tejus.loha 1986
        if (!transactionApproval.getStatus().equals(TransactionApprovalStatus.PENDING)) {
1987
            throw new ProfitMandiBusinessException("Transaction already Processed", "Transaction already Processed", "Transaction already Processed");
1988
        }
1989
        transactionApproval.setStatus(transactionApprovalStatus);
1990
        transactionApproval.setRemark(remark);
1991
        transactionApproval.setApprovalId(approvalId);
1992
        transactionApproval.setApprovedBy(approvedBy);
1993
        transactionApproval.setApprovedOn(approvedOn);
1994
        if (transactionApprovalStatus.equals(TransactionApprovalStatus.APPROVED)) {
34313 ranu 1995
            transactionService.processTransaction(transactionId, 0);
36519 aman 1996
            // Track PO_APPROVAL on timeline (direct call like BILLING — bypasses BLOCKER_MAP
1997
            // since the PO is actually being approved, the timeline must record it)
35971 aman 1998
            try {
1999
                FofoStore fofoStore = fofoStoreRepository.selectByRetailerId(retailerId);
2000
                if (fofoStore != null && fofoStore.getCode() != null) {
2001
                    PartnerOnBoardingPanel pob = partnerOnBoardingPanelRepository.selectByCode(fofoStore.getCode());
2002
                    if (pob != null) {
36519 aman 2003
                        storeTimelineTatService.createStoreTimelinetb(pob.getId(), StoreTimeline.PO_APPROVAL);
35971 aman 2004
                    }
2005
                }
2006
            } catch (Exception e) {
2007
                LOGGER.error("Failed to track PO_APPROVAL timeline for transactionId: " + transactionId, e);
2008
            }
33336 tejus.loha 2009
        } else {
2010
            float totalAmount = 0;
2011
            // referense id = transaction id
2012
            // here refund the amount of an order
2013
            List<UserWalletHistory> uwhList = walletService.getAllByReference(retailerId, transactionId, WalletReferenceType.PURCHASE);
33687 amit.gupta 2014
            //Refund only if any amount is deducted from wallet for that particular Transaction
33696 amit.gupta 2015
            if (uwhList.size() > 0) {
33687 amit.gupta 2016
                totalAmount = -uwhList.get(0).getAmount();
2017
                walletService.refundToWallet(retailerId, totalAmount, transactionId, WalletReferenceType.PURCHASE, "Order canceled");
34733 amit.gupta 2018
                sdCreditService.settleBlockedLoan(transactionId, totalAmount);
36791 amit 2019
                // Mark the rejected PO's order rows so they drop out of pending indent (the wallet refund
2020
                // above releases the committed amount; without this the orders stay status=0 forever and
2021
                // inflate pending indent with no matching wallet liability).
2022
                orderRepository.cancelRejectedTransactionOrders(transactionId, approvedBy, "PO rejected: " + remark);
33687 amit.gupta 2023
            }
33213 tejus.loha 2024
        }
2025
    }
2026
 
35965 amit 2027
    @RequestMapping(value = "/transaction/bulkOrderApprovalReport", method = RequestMethod.GET)
2028
    public String getBulkOrderApprovalReport(
2029
            @RequestParam(required = false) String startDate,
2030
            @RequestParam(required = false) String endDate,
2031
            HttpServletRequest request, Model model) throws Exception {
2032
        DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd");
2033
        LocalDate end = (endDate != null && !endDate.isEmpty()) ? LocalDate.parse(endDate, formatter) : LocalDate.now();
2034
        LocalDate start = (startDate != null && !startDate.isEmpty()) ? LocalDate.parse(startDate, formatter) : end.minusDays(7);
2035
        List<TransactionApprovalModel> approvalModelList = bulkOrderService.getBulkOrderApprovalReport(
2036
                start.atStartOfDay(), end.plusDays(1).atStartOfDay());
2037
        model.addAttribute("approvalModelList", approvalModelList);
2038
        model.addAttribute("startDate", start.format(formatter));
2039
        model.addAttribute("endDate", end.format(formatter));
2040
        return "transaction/bulk-order-approval-report";
2041
    }
2042
 
33213 tejus.loha 2043
    @RequestMapping(value = "/bulkOrderTemplate", method = RequestMethod.GET)
2044
    public ResponseEntity<?> bulkOrderTemplate() throws Exception {
2045
        List<List<?>> rows = new ArrayList<>();
2046
        rows.add(Arrays.asList("Mahaveer", "Change description for your reference", "175139287", "28264", "0", "4"));
2047
        rows.add(Arrays.asList("Mahaveer", "Price =0 means system price", "175139287", "28268", "0", "7"));
2048
        rows.add(Arrays.asList("Jas", "You give custom price also ", "171273247", "28264", "300", "3"));
2049
        org.apache.commons.io.output.ByteArrayOutputStream baos = FileUtil
2050
                .getCSVByteStream(Arrays.asList("Partner name", "Description", "Partner Id", "Item Id", "Price", "Quantity"), rows);
2051
        ResponseEntity<?> responseEntity = orderService.downloadReportInCsv(baos, rows, "Bulk order template");
2052
 
2053
        return responseEntity;
2054
 
2055
    }
34168 tejus.loha 2056
 
2057
    @Autowired
2058
    EInvoiceDetailsRepository eInvoiceDetailsRepository;
2059
 
2060
    @GetMapping("/resetIrnGeneratedPanel")
2061
    public String resetIrnGeneratedPanel() {
2062
        return "reset-irn-panel";
2063
    }
2064
 
2065
    @GetMapping("/getTransactionForIrnReset")
2066
    public String getTransactionForIrnReset(@RequestParam String invoiceNumber, Model model) throws Exception {
2067
        List<String> invoiceNumbers = Arrays.asList(invoiceNumber.split(","));
2068
        List<EInvoiceDetails> eInvoiceDetailsList = eInvoiceDetailsRepository.selectByInvoiceNumbers(invoiceNumbers);
2069
        if (invoiceNumbers.size() == eInvoiceDetailsList.size()) {
2070
            model.addAttribute("irnResetOrderModelList", new ArrayList<>());
2071
            model.addAttribute("notEligibleInvoiceNumbers", invoiceNumber);
2072
            return "eligible-irn-reset-orders";
2073
        }
2074
        Set<String> existingInvoiceInEInvoiceDtl = eInvoiceDetailsList.stream().map(x -> x.getInvoiceNumber()).collect(Collectors.toSet());
2075
        List<String> missingInvoiceInEInvoiceDtl = invoiceNumbers.stream().filter(x -> !existingInvoiceInEInvoiceDtl.contains(x)).collect(Collectors.toList());
2076
 
2077
        List<Order> orderList = orderRepository.selectByInvoiceNumbers(missingInvoiceInEInvoiceDtl).stream().filter(x -> x.getIrnGenerated() != null).collect(Collectors.toList());
2078
        Map<String, List<Order>> invoiceMap = orderList.stream().collect(Collectors.groupingBy(x -> x.getInvoiceNumber()));
2079
        Set<String> notEligibleInvoiceNumbers = new HashSet<>();
2080
        notEligibleInvoiceNumbers.addAll(existingInvoiceInEInvoiceDtl);
2081
        List<IrnResetOrderModel> irnResetOrderModelList = new ArrayList<>();
2082
        for (Map.Entry<String, List<Order>> invoiceMapEntry : invoiceMap.entrySet()) {
2083
            String invoice = invoiceMapEntry.getKey();
2084
            List<Order> orders = invoiceMapEntry.getValue();
35066 amit 2085
            LocalDate earlierDate = LocalDate.now().minusDays(5);
2086
            boolean isEligible = !orders.isEmpty() && orders.stream().allMatch(x -> x.getBillingTimestamp().toLocalDate().isAfter(earlierDate) && x.getIrnGenerated() != null);
34168 tejus.loha 2087
            if (isEligible) {
2088
                Order order = orders.get(0);
2089
                FofoStore fofoStore = fofoStoreRepository.selectByRetailerId(order.getRetailerId());
2090
 
2091
                IrnResetOrderModel irnResetOrderModel = new IrnResetOrderModel();
2092
                irnResetOrderModel.setName(partnerOnBoardingPanelRepository.selectByCode(fofoStore.getCode()).getOutLetName());
2093
                irnResetOrderModel.setInvoiceNumber(order.getInvoiceNumber());
2094
                irnResetOrderModel.setInvoiceDate(order.getBillingTimestamp());
2095
                irnResetOrderModel.setWarehouseId(ProfitMandiConstants.WAREHOUSE_MAP.get(order.getWarehouseId()));
2096
                irnResetOrderModel.setTotalOrderValue(orders.stream().mapToDouble(Order::getTotalAmount).sum());
2097
                irnResetOrderModelList.add(irnResetOrderModel);
2098
            } else {
2099
                notEligibleInvoiceNumbers.add(invoice);
2100
            }
2101
        }
2102
        model.addAttribute("irnResetOrderModelList", irnResetOrderModelList);
2103
        model.addAttribute("notEligibleInvoiceNumbers", notEligibleInvoiceNumbers.stream().collect(Collectors.joining(", ")));
2104
        return "eligible-irn-reset-orders";
2105
    }
2106
 
2107
    @PutMapping("/resetOrdersIrn")
2108
    public String resetIrn(@RequestParam String invoiceNumbers, Model model) throws Exception {
2109
        List<String> invoices = new ArrayList<>();
2110
        if (!invoiceNumbers.isEmpty()) {
2111
            invoices = Arrays.asList(invoiceNumbers.split(","));
2112
        }
2113
        List<Order> orderList = orderRepository.selectByInvoiceNumbers(invoices);
2114
        orderList.forEach(order -> {
2115
            order.setIrnGenerated(null);
2116
        });
2117
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
2118
        return "response";
2119
    }
34179 tejus.loha 2120
 
34474 aman.kumar 2121
    @PutMapping(value = "/sendInvoiceOnWhatsApp")
2122
    public String sendInvoiceOnWhatsApp(HttpServletRequest request, @RequestParam int orderId, @RequestParam String whatsAppMobile, Model model) throws Exception {
36064 aman 2123
        FofoOrder fo = fofoOrderRepository.selectByOrderId(orderId);
2124
        boolean isSend = notificationService.sendWhatsappInvoice(fo.getCustomerId(), fo.getFofoId(), fo.getInvoiceNumber(), whatsAppMobile);
34474 aman.kumar 2125
        model.addAttribute("response1", isSend);
34179 tejus.loha 2126
        return "response";
2127
    }
2128
 
35269 ranu 2129
    @Autowired
2130
    OneAssistService oneAssistService;
34179 tejus.loha 2131
 
35269 ranu 2132
    @RequestMapping(value = "/cancelInsuranceWithoutInvoice/{applicationNumber}/{memberShipNumber}", method = RequestMethod.GET)
2133
    public String cancelInsuranceWithoutInvoice(HttpServletRequest request, @PathVariable int applicationNumber, @PathVariable int memberShipNumber, Model model) throws Exception {
2134
        CancelPlanRequestModel cancelPlanRequestModel = new CancelPlanRequestModel();
2135
        cancelPlanRequestModel.setMembershipId(Long.parseLong(String.valueOf(memberShipNumber)));
2136
        cancelPlanRequestModel.setApplicationNo(applicationNumber + "");
2137
        oneAssistService.cancelCertificate(cancelPlanRequestModel);
2138
 
2139
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
2140
 
2141
        return "response";
2142
 
2143
    }
2144
 
32409 amit.gupta 2145
}
32405 jai.hind 2146