Subversion Repositories SmartDukaan

Rev

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