Subversion Repositories SmartDukaan

Rev

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

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