Subversion Repositories SmartDukaan

Rev

Rev 34788 | Rev 34798 | 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;
22217 ashik.ali 18
import com.spice.profitmandi.dao.entity.dtr.InsurancePolicy;
23343 ashik.ali 19
import com.spice.profitmandi.dao.entity.dtr.InsuranceProvider;
23548 ashik.ali 20
import com.spice.profitmandi.dao.entity.dtr.PaymentOptionTransaction;
33795 ranu 21
import com.spice.profitmandi.dao.entity.dtr.WebOffer;
30322 amit.gupta 22
import com.spice.profitmandi.dao.entity.fofo.*;
34194 ranu 23
import com.spice.profitmandi.dao.entity.transaction.EInvoiceDetails;
24
import com.spice.profitmandi.dao.entity.transaction.Order;
25
import com.spice.profitmandi.dao.entity.transaction.TransactionApproval;
26
import com.spice.profitmandi.dao.entity.transaction.UserWalletHistory;
23298 ashik.ali 27
import com.spice.profitmandi.dao.entity.user.Address;
33400 ranu 28
import com.spice.profitmandi.dao.enumuration.cs.EscalationType;
23548 ashik.ali 29
import com.spice.profitmandi.dao.enumuration.dtr.PaymentOptionReferenceType;
27046 tejbeer 30
import com.spice.profitmandi.dao.enumuration.transaction.OrderStatus;
33213 tejus.loha 31
import com.spice.profitmandi.dao.enumuration.transaction.TransactionApprovalStatus;
34788 ranu 32
import com.spice.profitmandi.dao.model.ItemWiseCustomerOfferSummaryModel;
34168 tejus.loha 33
import com.spice.profitmandi.dao.model.hdfc.IrnResetOrderModel;
33213 tejus.loha 34
import com.spice.profitmandi.dao.repository.auth.AuthRepository;
33795 ranu 35
import com.spice.profitmandi.dao.repository.catalog.*;
33400 ranu 36
import com.spice.profitmandi.dao.repository.cs.PositionRepository;
30322 amit.gupta 37
import com.spice.profitmandi.dao.repository.dtr.*;
38
import com.spice.profitmandi.dao.repository.fofo.*;
24440 amit.gupta 39
import com.spice.profitmandi.dao.repository.inventory.StateRepository;
33336 tejus.loha 40
import com.spice.profitmandi.dao.repository.transaction.*;
23298 ashik.ali 41
import com.spice.profitmandi.dao.repository.user.AddressRepository;
33336 tejus.loha 42
import com.spice.profitmandi.dao.repository.user.CartRepository;
34474 aman.kumar 43
import com.spice.profitmandi.dao.service.ScratchService;
28377 tejbeer 44
import com.spice.profitmandi.service.EmailService;
32251 amit.gupta 45
import com.spice.profitmandi.service.NotificationService;
23798 amit.gupta 46
import com.spice.profitmandi.service.authentication.RoleManager;
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
 
34789 ranu 215
/*    @Autowired
216
    IciciPolicyTrackerRepository iciciPolicyTrackerRepository;*/
34788 ranu 217
 
218
    @Autowired
34474 aman.kumar 219
    ScratchService scratchService;
34789 ranu 220
/*
34788 ranu 221
    @Autowired
34789 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
 
34788 ranu 560
   /* @RequestMapping(value = "/getPlanQuote", method = RequestMethod.GET)
561
    public String getPlanQuote(HttpServletRequest request, Model model,
562
                               @RequestParam String planCode, @RequestParam int sumInsured, @RequestParam @DateTimeFormat(pattern = "dd/MM/yyyy") LocalDate manufacturedDate, @RequestParam int itemId) throws ProfitMandiBusinessException {
563
 
564
        try {
565
            PlanVariant planVariant = insuranceService.getICICIPremiumByVariantId(planCode);
566
 
567
            LOGGER.info("planVariant111 {}",planVariant);
568
 
569
            String correlationId = UUID.randomUUID().toString();
570
            IciciPolicyTracker policyTracker = new IciciPolicyTracker();
571
            policyTracker.setCorrelationId(correlationId);
572
            iciciPolicyTrackerRepository.persist(policyTracker);
573
 
574
            // Policy validity (1 year from today)
575
            LocalDate today = LocalDate.now();
576
            LocalDate oneYearLater = today.plusYears(1);
577
 
578
            String itemBrand = itemRepository.selectById(itemId).getBrand();
579
 
580
            AfinityQuoteModel quoteModel = new AfinityQuoteModel();
581
            quoteModel.setPolicyStartDate(today.toString());          // format: yyyy-MM-dd
582
            quoteModel.setPolicyEndDate(oneYearLater.toString());
583
//            quoteModel.setPlanCode(String.valueOf(planVariant.getOurPlanId()));
584
            quoteModel.setPlanCode(String.valueOf(10357));
585
            quoteModel.setSumInsured((int) sumInsured);
586
            quoteModel.setBasisOfValuation("Market_Value");
587
            quoteModel.setPartyStateName("MAHARASHTRA");
588
            quoteModel.setRiskSIComponent("MOBILE");
589
            quoteModel.setMakeManufacturer(itemBrand.toUpperCase());
590
            quoteModel.setYearOfManufacture(manufacturedDate.getYear());
591
            quoteModel.setCoverName("All Risk");
592
            quoteModel.setCorrelationId(correlationId);
593
 
594
            String response = mvcResponseSender.createResponseString(iciciLombardService.hitAfinityQuote(quoteModel));
595
            LOGGER.info("response {}",response);
596
            model.addAttribute("response1", response);
597
        } catch (Exception e) {
598
            // TODO Auto-generated catch block
599
            LOGGER.info(e.getMessage(), e);
600
            throw new ProfitMandiBusinessException("Plans", "Plans Quote", "Error qutotation insurance plans");
601
        }
602
 
603
        return "response";
604
    }*/
605
 
34204 tejus.loha 606
    private boolean sendWhatsappInvoice(FofoOrder fofoOrder) throws Exception {
607
        return this.sendWhatsappInvoice(fofoOrder, "");
34179 tejus.loha 608
    }
609
 
34204 tejus.loha 610
    private boolean sendWhatsappInvoice(FofoOrder fofoOrder, String whatsAppNo) throws Exception {
611
        boolean shouldSendWhatsappMessage = notificationService.shouldSendWhatsappMessage(whatsAppNo);
34474 aman.kumar 612
        boolean isSend = false;
34204 tejus.loha 613
        if (shouldSendWhatsappMessage) {
614
            Customer customer = customerRepository.selectById(fofoOrder.getCustomerId());
615
            String mobileNumber;
616
            if (!whatsAppNo.isEmpty()) {
34474 aman.kumar 617
                mobileNumber = whatsAppNo;
618
            } else {
619
                mobileNumber = customer.getMobileNumber();
620
            }
621
            CustomRetailer retailer = retailerService.getFofoRetailer(fofoOrder.getFofoId());
622
            String message = String.format("Dear %s,\n" +
623
                    "Thank you for your purchase from SmartDukaan store - %s, %s.\n" +
624
                    "Your purchase invoice is attached for your reference.\n" +
625
                    "\n" +
626
                    "Download our app for offers and updates on new products.\n" +
627
                    "https://www.smartdukaan.com/b2c\n" +
628
                    "\n" +
629
                    "Best Regards\n" +
630
                    "SmartDukaan", customer.getFirstName(), retailer.getBusinessName(), retailer.getAddress().getCity());
34204 tejus.loha 631
 
34474 aman.kumar 632
            isSend = notificationService.sendWhatsappMediaMessage(message, mobileNumber, this.getPublicInvoiceUrl(fofoOrder.getInvoiceNumber()),
33213 tejus.loha 633
                    this.getFileName(fofoOrder.getInvoiceNumber()), WhatsappMessageType.DOCUMENT);
634
        }
34204 tejus.loha 635
        return isSend;
33213 tejus.loha 636
    }
28339 tejbeer 637
 
33213 tejus.loha 638
    private String getFileName(String invoiceNumber) {
639
        return "INV-" + invoiceNumber.replace("/", "-") + ".pdf";
640
    }
31375 tejbeer 641
 
33213 tejus.loha 642
    private String getPublicInvoiceUrl(String invoiceNumber) {
643
        String base64Encoded = Base64.getMimeEncoder().encodeToString(invoiceNumber.getBytes(StandardCharsets.UTF_8));
644
        String publicUrl = "https://partners.smartdukaan.com/wa-invoice-send/" + base64Encoded + ".pdf";
645
        LOGGER.info("Public Whatsapp Url for Invoice Message - {}", publicUrl);
646
        return publicUrl;
647
    }
28339 tejbeer 648
 
33213 tejus.loha 649
    @RequestMapping(value = "/order/bad_return", method = RequestMethod.POST)
650
    public ResponseEntity<?> badReturn(HttpServletRequest request, @RequestBody FoiBadReturnRequest foiBadReturnRequest,
651
                                       Model model) throws ProfitMandiBusinessException {
652
        LOGGER.info("request at uri {} body {}", request.getRequestURI(), foiBadReturnRequest);
653
        LoginDetails fofoDetails = cookiesProcessor.getCookiesObject(request);
654
        CustomerCreditNote custmoerCreditNote;
655
        if (roleManager.isAdmin(fofoDetails.getRoleIds())) {
656
            FofoOrderItem foi = fofoOrderItemRepository.selectById(foiBadReturnRequest.getFofoOrderItemId());
657
            FofoOrder fo = fofoOrderRepository.selectByOrderId(foi.getOrderId());
34168 tejus.loha 658
            custmoerCreditNote = orderService.badReturn(fofoDetails.getEmailId(), fo.getFofoId(), foiBadReturnRequest);
33213 tejus.loha 659
        } else {
660
            custmoerCreditNote = orderService.badReturn(fofoDetails.getFofoId(), foiBadReturnRequest);
661
        }
662
        return responseSender.ok(custmoerCreditNote.getId());
663
    }
28339 tejbeer 664
 
33213 tejus.loha 665
    @GetMapping(value = "/wa-invoice-send/{invoiceHash}")
666
    public ResponseEntity<?> generateInvoice(@PathVariable String invoiceHash) throws ProfitMandiBusinessException {
667
        String decodedInvoiceNumber = new String(Base64.getMimeDecoder().decode(invoiceHash));
668
        LOGGER.info("Invoice Hash {}", invoiceHash);
28339 tejbeer 669
 
23973 govind 670
 
33213 tejus.loha 671
        FofoOrder fofoOrder = fofoOrderRepository.selectByInvoiceNumber(decodedInvoiceNumber);
24844 amit.gupta 672
 
33213 tejus.loha 673
        InvoicePdfModel pdfModel = orderService.getInvoicePdfModel(fofoOrder.getId());
24844 amit.gupta 674
 
33213 tejus.loha 675
        ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
676
        PdfUtils.generateAndWrite(Arrays.asList(pdfModel), byteArrayOutputStream);
677
        final HttpHeaders headers = new HttpHeaders();
678
        //headers.setContentDispositionFormData("inline", number + ".pdf");
679
        headers.add(HttpHeaders.CONTENT_DISPOSITION, "inline;filename=" + pdfModel.getInvoiceNumber() + ".pdf");
680
        int contentLength = byteArrayOutputStream.toByteArray().length;
681
        final InputStream inputStream = new ByteArrayInputStream(byteArrayOutputStream.toByteArray());
682
        final InputStreamResource inputStreamResource = new InputStreamResource(inputStream);
683
        return ResponseEntity.ok()
684
                .headers(headers)
685
                .contentLength(contentLength)
686
                .contentType(MediaType.parseMediaType("application/pdf"))
687
                .body(inputStreamResource);
688
    }
23973 govind 689
 
33213 tejus.loha 690
    @RequestMapping(value = "/wa-listen", method = RequestMethod.POST)
691
    public ResponseEntity<?> listenWhatsappStatus(@RequestBody String whatsappJsonResponse) {
692
        LOGGER.info("whatsappJsonResponse {}", whatsappJsonResponse);
693
        //jaihind
694
        //  String jsonString = "[{\"srcAddr\":\"TESTSM\",\"channel\":\"WHATSAPP\",\"externalId\":\"4977024756456780043-180044363908187691\",\"cause\":\"SUCCESS\",\"errorCode\":\"000\",\"destAddr\":\"919813272029\",\"eventType\":\"DELIVERED\",\"eventTs\":1692848106000}]";
695
        JSONArray jsonArray = new JSONArray(whatsappJsonResponse);
696
        for (int i = 0; i < jsonArray.length(); i++) {
32711 amit.gupta 697
 
33213 tejus.loha 698
            JSONObject jsonObject = jsonArray.getJSONObject(i);
699
            String externalId = jsonObject.getString("externalId");
700
            String destAddr = jsonObject.getString("destAddr");
701
            String eventType = jsonObject.getString("eventType");
702
            whatsappMessageService.setWhatsappResponse(externalId, destAddr, eventType);
703
        }
704
        //jaihind
705
        return responseSender.ok("Success");
32711 amit.gupta 706
 
33213 tejus.loha 707
    }
32271 amit.gupta 708
 
33213 tejus.loha 709
    @RequestMapping(value = "/generateInvoice")
710
    public ResponseEntity<?> generateInvoice(HttpServletRequest request, HttpServletResponse response,
711
                                             @RequestParam(name = ProfitMandiConstants.ORDER_ID) int orderId) throws ProfitMandiBusinessException {
712
        LOGGER.info("Request received at url {} with params [{}={}] ", request.getRequestURI(),
713
                ProfitMandiConstants.ORDER_ID, orderId);
714
        LoginDetails fofoDetails = cookiesProcessor.getCookiesObject(request);
715
        InvoicePdfModel pdfModel = null;
716
        if (roleManager.isAdmin(fofoDetails.getRoleIds())) {
717
            pdfModel = orderService.getInvoicePdfModel(orderId);
718
        } else {
719
            pdfModel = orderService.getInvoicePdfModel(fofoDetails.getFofoId(), orderId);
720
        }
721
        ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
722
        PdfUtils.generateAndWrite(Arrays.asList(pdfModel), byteArrayOutputStream);
723
        LOGGER.info("Pdf Stream length {}", byteArrayOutputStream.toByteArray().length);
724
        final HttpHeaders headers = new HttpHeaders();
725
        headers.setContentType(MediaType.APPLICATION_PDF);
726
        headers.setContentDispositionFormData("inline", "invoice-" + pdfModel.getInvoiceNumber() + ".pdf");
727
        headers.setContentLength(byteArrayOutputStream.toByteArray().length);
728
        final InputStream inputStream = new ByteArrayInputStream(byteArrayOutputStream.toByteArray());
729
        final InputStreamResource inputStreamResource = new InputStreamResource(inputStream);
730
        return new ResponseEntity<>(inputStreamResource, headers, HttpStatus.OK);
731
    }
24087 amit.gupta 732
 
33213 tejus.loha 733
    @RequestMapping(value = "/generateInvoices")
734
    public ResponseEntity<?> generateInvoice(HttpServletRequest request, HttpServletResponse response,
735
                                             @RequestParam LocalDateTime startDate, @RequestParam LocalDateTime endDate, @RequestParam int partnerId)
736
            throws ProfitMandiBusinessException {
737
        LoginDetails fofoDetails = cookiesProcessor.getCookiesObject(request);
738
        List<InvoicePdfModel> pdfModels = new ArrayList<>();
739
        if (roleManager.isAdmin(fofoDetails.getRoleIds())) {
740
            List<Integer> orderIds = fofoOrderRepository.selectByFofoId(partnerId, startDate, endDate, 0, 0).stream()
741
                    .map(x -> x.getId()).collect(Collectors.toList());
742
            for (int orderId : orderIds) {
743
                pdfModels.add(orderService.getInvoicePdfModel(orderId));
744
            }
745
            ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
746
            PdfUtils.generateAndWrite(pdfModels, byteArrayOutputStream);
747
            LOGGER.info("Pdf Stream length {}", byteArrayOutputStream.toByteArray().length);
748
            final HttpHeaders headers = new HttpHeaders();
749
            headers.setContentType(MediaType.APPLICATION_PDF);
750
            headers.set("Content-disposition", "inline; filename=invoice-" + partnerId + ".pdf");
751
            headers.setContentLength(byteArrayOutputStream.toByteArray().length);
752
            final InputStream inputStream = new ByteArrayInputStream(byteArrayOutputStream.toByteArray());
753
            final InputStreamResource inputStreamResource = new InputStreamResource(inputStream);
754
            return new ResponseEntity<InputStreamResource>(inputStreamResource, headers, HttpStatus.OK);
755
        } else {
756
            throw new ProfitMandiBusinessException("Auth", fofoDetails.getEmailId(), "Unauthorised access");
757
        }
758
    }
23973 govind 759
 
33213 tejus.loha 760
    @RequestMapping(value = "/saleHistory")
761
    public String saleHistory(HttpServletRequest request,
762
                              @RequestParam(name = "searchValue", defaultValue = "") String searchValue,
763
                              @RequestParam(name = "searchType", defaultValue = "") SearchType searchType,
764
                              @RequestParam(required = false) LocalDateTime startTime,
765
                              @RequestParam(required = false) LocalDateTime endTime,
766
                              @RequestParam(name = "offset", defaultValue = "0") int offset,
767
                              @RequestParam(name = "limit", defaultValue = "10") int limit, Model model)
768
            throws ProfitMandiBusinessException {
769
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
32405 jai.hind 770
 
33213 tejus.loha 771
        Map<String, Object> map = orderService.getSaleHistory(loginDetails.getFofoId(), searchType, searchValue,
772
                startTime, endTime, offset, limit);
773
        model.addAllAttributes(map);
774
        return "sale-history";
775
    }
32405 jai.hind 776
 
33213 tejus.loha 777
    @RequestMapping(value = "/downloadInvoices")
778
    public ResponseEntity<?> downloadInvoices(HttpServletRequest request,
779
                                              @RequestParam(name = "searchValue", defaultValue = "") String searchValue,
780
                                              @RequestParam(name = "searchType", defaultValue = "") SearchType searchType,
781
                                              @RequestParam(required = false) LocalDateTime startTime,
782
                                              @RequestParam(required = false) LocalDateTime endTime,
783
                                              @RequestParam(name = "offset", defaultValue = "0") int offset,
784
                                              @RequestParam(name = "limit", defaultValue = "10") int limit, Model model)
785
            throws ProfitMandiBusinessException {
786
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
32409 amit.gupta 787
 
33213 tejus.loha 788
        Map<String, Object> map = orderService.getSaleHistory(loginDetails.getFofoId(), searchType, searchValue,
789
                startTime, endTime, offset, 100);
790
        List<FofoOrder> fofoOrders = (List<FofoOrder>) map.get("saleHistories");
23973 govind 791
 
33213 tejus.loha 792
        if (fofoOrders.size() == 0) {
793
            throw new ProfitMandiBusinessException("Search criteria", "", "No orders found for criteria");
794
        }
23654 amit.gupta 795
 
33213 tejus.loha 796
        final HttpHeaders headers = new HttpHeaders();
797
        headers.setContentType(MediaType.APPLICATION_PDF);
798
        headers.set("Content-disposition", "inline; filename=invoices.pdf");
799
        ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
800
        List<InvoicePdfModel> pdfModels = new ArrayList<>();
801
        for (FofoOrder fofoOrder : fofoOrders) {
802
            try {
803
                pdfModels.add(orderService.getInvoicePdfModel(fofoOrder.getId()));
804
            } catch (Exception e) {
805
                LOGGER.info("could not create invoice for {}, invoice number {}", fofoOrder.getId(),
806
                        fofoOrder.getInvoiceNumber());
807
            }
808
        }
809
        PdfUtils.generateAndWrite(pdfModels, byteArrayOutputStream);
810
        headers.setContentLength(byteArrayOutputStream.toByteArray().length);
811
        final InputStream inputStream = new ByteArrayInputStream(byteArrayOutputStream.toByteArray());
812
        final InputStreamResource inputStreamResource = new InputStreamResource(inputStream);
813
        return new ResponseEntity<InputStreamResource>(inputStreamResource, headers, HttpStatus.OK);
814
    }
23654 amit.gupta 815
 
33213 tejus.loha 816
    @RequestMapping(value = "/credit-note/{creditNoteId}")
817
    public ResponseEntity<?> downloadCreditNote(HttpServletRequest request, @PathVariable int creditNoteId)
818
            throws ProfitMandiBusinessException {
819
        CreditNotePdfModel creditNotePdfModel = orderService.getCreditNotePdfModel(creditNoteId);
820
        ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
821
        PdfUtils.generateAndWriteCustomerCreditNotes(Arrays.asList(creditNotePdfModel), byteArrayOutputStream);
822
        LOGGER.info("Pdf Stream length {}", byteArrayOutputStream.toByteArray().length);
823
        final HttpHeaders headers = new HttpHeaders();
824
        headers.setContentType(MediaType.APPLICATION_PDF);
825
        headers.set("Content-disposition",
826
                "inline; filename=invoice-" + creditNotePdfModel.getCreditNoteNumber() + ".pdf");
827
        headers.setContentLength(byteArrayOutputStream.toByteArray().length);
828
        final InputStream inputStream = new ByteArrayInputStream(byteArrayOutputStream.toByteArray());
829
        final InputStreamResource inputStreamResource = new InputStreamResource(inputStream);
830
        return new ResponseEntity<InputStreamResource>(inputStreamResource, headers, HttpStatus.OK);
831
    }
23973 govind 832
 
33213 tejus.loha 833
    @RequestMapping(value = "/getPaginatedSaleHistory")
834
    public String getSaleHistoryPaginated(HttpServletRequest request,
835
                                          @RequestParam(name = "searchValue", defaultValue = "") String searchValue,
836
                                          @RequestParam(name = "searchType", defaultValue = "") SearchType searchType,
837
                                          @RequestParam(required = false) LocalDateTime startTime,
838
                                          @RequestParam(required = false) LocalDateTime endTime,
839
                                          @RequestParam(name = "offset", defaultValue = "0") int offset,
840
                                          @RequestParam(name = "limit", defaultValue = "10") int limit, Model model)
841
            throws ProfitMandiBusinessException {
842
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
843
        Map<String, Object> map = orderService.getSaleHistoryPaginated(loginDetails.getFofoId(), searchType,
844
                searchValue, startTime, endTime, offset, limit);
845
        model.addAllAttributes(map);
846
        return "sale-history-paginated";
847
    }
23973 govind 848
 
33213 tejus.loha 849
    @PutMapping(value = "/updatePaymentTransaction")
850
    public String updateTransactionDetails(HttpServletRequest request, @RequestParam String referenceType,
851
                                           @RequestParam int fofoId, @RequestParam int referenceId,
852
                                           @RequestBody PartnerOptionsAndItemAmountModel partnerOptionsAndItemAmountModel,
853
                                           @RequestParam float totalAmount, Model model) throws Exception {
29707 tejbeer 854
 
33213 tejus.loha 855
        List<PaymentOptionTransactionModel> paymentOptionTransactionModels = partnerOptionsAndItemAmountModel
856
                .getPaymentOptionTransactionModel();
857
        LOGGER.info(paymentOptionTransactionModels);
858
        FofoOrder fofoOrder = fofoOrderRepository.selectByFofoIdAndOrderId(fofoId, referenceId);
859
        LOGGER.info("sdssd" + fofoOrder);
860
        fofoOrder.setTotalAmount(totalAmount);
861
        List<FofoItemIdAmountModel> fofoItemIdAmountModel = partnerOptionsAndItemAmountModel.getItemAmountModel();
862
        for (FofoItemIdAmountModel fim : fofoItemIdAmountModel) {
863
            LOGGER.info("fim" + fim.getFofoItemId());
23973 govind 864
 
33213 tejus.loha 865
            LOGGER.info("fimAmount" + fim.getAmount());
866
            Item item = itemRepository.selectById(fim.getItemId());
867
            TagListing tagListing = tagListingRepository.selectByItemId(item.getId());
868
            FofoOrderItem fofoOrderItem = fofoOrderItemRepository.selectById(fim.getFofoItemId());
869
            LOGGER.info("category" + item.getCategoryId());
870
            if (item.getCategoryId() == ProfitMandiConstants.MOBILE_CATEGORY_ID) {
871
                if (fofoOrderItem.getMop() <= fim.getAmount()) {
23973 govind 872
 
33213 tejus.loha 873
                    if (fim.getAmount() <= tagListing.getMrp()) {
874
                        fofoOrderItem.setSellingPrice(fim.getAmount());
875
                    } else {
876
                        throw new ProfitMandiBusinessException("Amount", fim.getAmount(),
877
                                "Sum of amount is not less than  to MRP");
878
                    }
23973 govind 879
 
33213 tejus.loha 880
                    LOGGER.info("fofoOrderItem2" + fofoOrderItem);
23973 govind 881
 
33213 tejus.loha 882
                } else {
883
                    // TODO below mop condition need to added added
884
                    fofoOrderItem.setSellingPrice(fim.getAmount());
885
                }
23973 govind 886
 
33213 tejus.loha 887
            } else {
888
                fofoOrderItem.setSellingPrice(fim.getAmount());
889
                LOGGER.info("fofoOrderItem1" + fofoOrderItem);
27819 tejbeer 890
 
33213 tejus.loha 891
            }
892
            LOGGER.info("fofoOrderItem" + fofoOrderItem);
23973 govind 893
 
33213 tejus.loha 894
        }
23973 govind 895
 
33213 tejus.loha 896
        /*
897
         * for (PaymentOptionTransactionModel paymentOptionTransactionModel :
898
         * paymentOptionTransactionModels) { amount = amount +
899
         * paymentOptionTransactionModel.getAmount(); } LOGGER.info("FofoOrder amount" +
900
         * fofoOrder.getUnitPrice() + "amount" + amount); if (amount ==
901
         * fofoOrder.getUnitPrice()) {
902
         */
903
        if (paymentOptionTransactionModels.size() > 0) {
904
            List<PaymentOptionTransaction> paymentOptionTransactions = paymentOptionTransactionRepository
905
                    .selectByReferenceIdAndType(referenceId, PaymentOptionReferenceType.ORDER);
906
            Map<Integer, PaymentOptionTransaction> paymentOptionIdPaymentOptionTransactionMap = this
907
                    .paymentOptionIdPaymentOptionTransactionMap(paymentOptionTransactions);
908
            LOGGER.info(
909
                    "paymentOptionIdPaymentOptionTransactionMap" + paymentOptionIdPaymentOptionTransactionMap.keySet());
910
            for (PaymentOptionTransactionModel paymentOptionTransactionModel : paymentOptionTransactionModels) {
911
                if (paymentOptionIdPaymentOptionTransactionMap
912
                        .containsKey(paymentOptionTransactionModel.getPaymentOptionId())) {
23973 govind 913
 
33213 tejus.loha 914
                    PaymentOptionTransaction paymentOptionTransaction = paymentOptionIdPaymentOptionTransactionMap
915
                            .get(paymentOptionTransactionModel.getPaymentOptionId());
31739 amit.gupta 916
 
33213 tejus.loha 917
                    if (paymentOptionTransactionModel.getAmount() == 0) {
918
                        paymentOptionTransactionRepository.delete(paymentOptionTransaction);
919
                        LOGGER.info("deleted successfully");
920
                    } else {
24844 amit.gupta 921
 
33213 tejus.loha 922
                        paymentOptionTransaction.setAmount(paymentOptionTransactionModel.getAmount());
923
                        paymentOptionTransactionRepository.persist(paymentOptionTransaction);
924
                        LOGGER.info("updated successfully");
24281 amit.gupta 925
 
33213 tejus.loha 926
                    }
927
                } else {
928
                    if (paymentOptionTransactionModel.getAmount() > 0) {
929
                        PaymentOptionTransaction paymentOptionTransaction = new PaymentOptionTransaction();
930
                        paymentOptionTransaction.setReferenceId(referenceId);
931
                        paymentOptionTransaction.setReferenceType(PaymentOptionReferenceType.ORDER);
932
                        paymentOptionTransaction.setPaymentOptionId(paymentOptionTransactionModel.getPaymentOptionId());
933
                        paymentOptionTransaction.setAmount(paymentOptionTransactionModel.getAmount());
934
                        paymentOptionTransaction.setFofoId(fofoId);
935
                        paymentOptionTransaction.setCreateTimestamp(fofoOrder.getCreateTimestamp());
936
                        paymentOptionTransactionRepository.persist(paymentOptionTransaction);
937
                        LOGGER.info("inserted successfully");
938
                    }
939
                }
24281 amit.gupta 940
 
33213 tejus.loha 941
            }
24281 amit.gupta 942
 
33213 tejus.loha 943
            model.addAttribute("response1", mvcResponseSender.createResponseString(true));
944
        }
945
        /*
946
         * else
947
         *
948
         * { throw new ProfitMandiBusinessException("Amount", amount,
949
         * "Sum of amount is not equal to total amount"); }
950
         */
23973 govind 951
 
33213 tejus.loha 952
        return "response";
23973 govind 953
 
33213 tejus.loha 954
    }
24105 govind 955
 
33437 ranu 956
    @RequestMapping(value = "/order")
957
    public String orderIndex(HttpServletRequest request, @RequestParam(name = "cartData") String cartData, Model model)
33213 tejus.loha 958
            throws ProfitMandiBusinessException {
33437 ranu 959
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
960
 
961
        int addressId = retailerRegisteredAddressRepository.selectAddressIdByRetailerId(loginDetails.getFofoId());
962
        Address address = addressRepository.selectById(addressId);
963
 
964
        List<CartFofo> cartItems = orderService.cartCheckout(cartData);
965
        Set<Integer> itemIds = new HashSet<>();
966
        List<Integer> poIds = new ArrayList<>();
967
        List<Integer> poItemIds = new ArrayList<>();
968
        for (CartFofo cartFofo : cartItems) {
969
            itemIds.add(cartFofo.getItemId());
970
            if (cartFofo.getPoId() != 0) {
971
                poIds.add(cartFofo.getPoId());
972
                poItemIds.add(cartFofo.getPoItemId());
973
            }
974
        }
975
 
976
        PendingOrder po = null;
977
        Customer customer = null;
978
        PendingOrderItem poi = null;
979
        Map<Integer, PriceModel> mopPriceMap = pricingService.getPurchasePriceMopPriceNotFound(itemIds,
980
                loginDetails.getFofoId());
981
        List<Integer> paymentOptionIds = fofoPartnerPaymentOptionRepository
982
                .selectPaymentOptionIdsByFofoId(loginDetails.getFofoId());
983
 
984
        if (!poIds.isEmpty()) {
985
            po = pendingOrderRepository.selectById(poIds.get(0));
986
            customer = customerRepository.selectById(po.getCustomerId());
987
            if (!offlineOrders.contains(po.getPayMethod())) {
988
                paymentOptionIds.add(23);
989
            }
990
        }
991
 
992
        if (!poItemIds.isEmpty()) {
993
            poi = pendingOrderItemRepository.selectById(poItemIds.get(0));
994
        }
995
 
996
        // List<PaymentOption> paymentOptions = paymentOptionRepository.selectByIds(new
997
        // HashSet<>(paymentOptionIds));
998
 
999
        List<PaymentOption> paymentOptions = paymentOptionRepository.selectActiveOption();
1000
 
1001
        LOGGER.info("pendingOrder" + po);
1002
        LOGGER.info("pendingOrderItem" + poi);
1003
 
1004
        int onlineSellingPrice = 0;
1005
        Map<Integer, PendingOrderItem> itemIdAndPoiMap = new HashMap<>();
1006
 
1007
        if (po != null) {
1008
            List<PendingOrderItem> pendingOrderItems = pendingOrderItemRepository.selectByOrderId(po.getId());
1009
            if (!(po.getPayMethod().equals("EMIOD") || po.getPayMethod().equals("POD"))) {
1010
                for (CartFofo cartItem : cartItems) {
1011
                    PendingOrderItem pendingOItem = pendingOrderItemRepository.selectById(cartItem.getPoItemId());
1012
                    PendingOrderPlan pendingOrderPlan = pendingOrderPlanRepository.selectByPoid(cartItem.getPoItemId());
1013
                    if (pendingOrderPlan != null) {
1014
                        onlineSellingPrice += pendingOItem.getSellingPrice() * pendingOItem.getQuantity() + pendingOrderPlan.getPremiumPrice() * pendingOItem.getQuantity();
1015
                    } else {
1016
                        onlineSellingPrice += pendingOItem.getSellingPrice() * pendingOItem.getQuantity();
1017
                    }
1018
                }
1019
            }
1020
 
1021
            itemIdAndPoiMap = pendingOrderItems.stream().collect(Collectors.toMap(x -> x.getItemId(), x -> pendingOrderItemRepository.selectById(x.getId())));
1022
        }
1023
 
33795 ranu 1024
 
1025
//        get the list of customer item for every item code start here
1026
//        ...............................................................
1027
 
1028
        LocalDateTime todayDate = LocalDateTime.now();
1029
        LocalDate todayDate2 = LocalDate.now();
1030
 
1031
        Map<Integer, List<CustomerOfferItem>> offerItemMap = new HashMap<>();
1032
        Map<Integer, List<WebOffer>> webOfferMap = new HashMap<>();
1033
 
1034
        List<CustomerOffer> customerOffers = customerOfferRepository.selectOffersByDate(todayDate);
1035
        List<Integer> customerOfferIds = customerOffers.stream().map(x -> x.getId()).distinct().collect(Collectors.toList());
34788 ranu 1036
        /*for (CartFofo cartItem : cartItems) {
33795 ranu 1037
            Item item = itemRepository.selectById(cartItem.getItemId());
33907 amit.gupta 1038
            if (customerOfferIds.size() > 0) {
33795 ranu 1039
 
33907 amit.gupta 1040
                List<CustomerOfferItem> customerOfferItems = customerOfferItemRepository.selectByOfferIds(customerOfferIds, item.getCatalogItemId(), todayDate2);
33795 ranu 1041
 
33907 amit.gupta 1042
                List<CustomerOfferItem> filteredCustomerOfferItems = customerOfferItems.stream()
1043
                        .filter(x -> x.getEndDate() != null && !x.getEndDate().isBefore(todayDate2))
1044
                        .collect(Collectors.toList());
33795 ranu 1045
 
33907 amit.gupta 1046
                offerItemMap.put(item.getId(), filteredCustomerOfferItems);
1047
            }
33818 ranu 1048
 
33907 amit.gupta 1049
 
33795 ranu 1050
            List<WebOffer> webOffers = webOfferRepository.selectAllActiveOffers().get(item.getCatalogItemId());
1051
            webOfferMap.put(item.getId(), webOffers);
34788 ranu 1052
        }*/
1053
 
1054
 
1055
        Map<Integer, ItemWiseCustomerOfferSummaryModel> offerItemSummaryMap = new HashMap<>();
1056
 
1057
        for (CartFofo cartItem : cartItems) {
1058
            Item item = itemRepository.selectById(cartItem.getItemId());
1059
 
1060
            List<CustomerOfferItem> customerOfferItems = customerOfferItemRepository
1061
                    .selectByOfferIds(customerOfferIds, item.getCatalogItemId(), todayDate2)
1062
                    .stream()
1063
                    .filter(x -> x.getEndDate() != null && !x.getEndDate().isBefore(todayDate2))
1064
                    .collect(Collectors.toList());
1065
 
1066
            ItemWiseCustomerOfferSummaryModel summary = new ItemWiseCustomerOfferSummaryModel();
1067
            summary.setItemId(item.getId());
1068
            summary.setCatalogId(item.getCatalogItemId());
1069
 
1070
            for (CustomerOfferItem coi : customerOfferItems) {
1071
                String key = coi.getOfferType().name() + "-" + coi.getCustomerOfferId();
1072
 
1073
                ItemWiseCustomerOfferSummaryModel.OfferTypeSummary typeSummary =
1074
                        summary.getOfferTypeMap().computeIfAbsent(key, k -> {
1075
                            ItemWiseCustomerOfferSummaryModel.OfferTypeSummary ts = new ItemWiseCustomerOfferSummaryModel.OfferTypeSummary();
1076
                            ts.setOfferType(coi.getOfferType());
1077
                            ts.setCustomerOfferId(coi.getCustomerOfferId());
1078
                            return ts;
1079
                        });
1080
 
1081
                typeSummary.setTotalSchemePayout(typeSummary.getTotalSchemePayout() + coi.getSchemePayout());
1082
                typeSummary.setTotalDealerPayout(typeSummary.getTotalDealerPayout() + coi.getDealerPayout());
1083
                typeSummary.getDescriptions().add(coi.getAdditionalInfo());
1084
                typeSummary.getOfferItemIds().add(coi.getId());
1085
            }
1086
 
1087
            offerItemSummaryMap.put(item.getId(), summary);
33795 ranu 1088
        }
1089
 
34788 ranu 1090
 
1091
 
33795 ranu 1092
//        get the list of customer item for every item code end here
1093
//        ...............................................................
1094
 
33437 ranu 1095
        LOGGER.info("itemIdAndPoiMap {}", itemIdAndPoiMap);
1096
        LOGGER.info("mopPriceMap {}", mopPriceMap);
1097
        model.addAttribute("stateNames",
1098
                stateRepository.selectAll().stream().map(x -> x.getName()).collect(Collectors.toList()));
1099
        model.addAttribute("retailerStateName", address.getState());
1100
        model.addAttribute("pendingPOCustomer", gson.toJson(customer));
1101
        model.addAttribute("pendingPO", gson.toJson(po));
1102
 
1103
        model.addAttribute("cartItems", cartItems);
1104
        model.addAttribute("pendingOrder", po);
1105
        model.addAttribute("pendingOrderItem", poi);
1106
        model.addAttribute("itemIdAndPoiMap", itemIdAndPoiMap);
1107
        model.addAttribute("onlineSellingPrice", onlineSellingPrice);
1108
 
1109
        model.addAttribute("mopPriceMap", mopPriceMap);
1110
        model.addAttribute("paymentOptions", paymentOptions);
1111
        model.addAttribute("accessoriesDeals", accessoriesDeals);
33795 ranu 1112
        model.addAttribute("webOfferMap", webOfferMap);
34788 ranu 1113
        model.addAttribute("offerItemSummaryMap", offerItemSummaryMap);
33437 ranu 1114
        return "order-index";
1115
    }
1116
 
1117
    private Map<String, List<MobileInsurancePlan>> getPlans(float sellingPrice, int itemId, int poiId)
1118
            throws ProfitMandiBusinessException {
33213 tejus.loha 1119
        try {
33437 ranu 1120
            Map<String, List<MobileInsurancePlan>> productDurationPlans = new HashMap<>();
1121
            PendingOrderPlan pendingOrderPlan = null;
1122
            if (poiId > 0) {
1123
                pendingOrderPlan = pendingOrderPlanRepository.selectByPoid(poiId);
1124
            }
1125
            if (pendingOrderPlan != null) {
33715 ranu 1126
                MobileInsurancePlan productDurationPlan = insuranceService.getPlanById(String.valueOf(pendingOrderPlan.getPlanId()), sellingPrice);
33437 ranu 1127
                productDurationPlans.put(pendingOrderPlan.getPlanName(), Collections.singletonList(productDurationPlan));
1128
 
1129
            } else {
1130
                productDurationPlans = insuranceService.getAllPlans(itemId,
1131
                        sellingPrice, false);
1132
            }
1133
 
33213 tejus.loha 1134
            return productDurationPlans;
1135
        } catch (Exception e) {
1136
            LOGGER.info(e, e);
1137
            throw new ProfitMandiBusinessException("Fetch Insurance Plans", "Insurance",
1138
                    "Could not fetch insurance Plans");
1139
        }
24105 govind 1140
 
33213 tejus.loha 1141
    }
23973 govind 1142
 
33795 ranu 1143
 
1144
    @GetMapping("/getItemWiseUpgradeOffer")
1145
    public String getItemWiseUpgradeOffer(HttpServletRequest request, @RequestParam int itemId, Model model)
1146
            throws ProfitMandiBusinessException {
1147
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1148
 
1149
        Item item = itemRepository.selectById(itemId);
1150
 
1151
        LocalDateTime todayDate = LocalDateTime.now();
1152
        LocalDate todayDate2 = LocalDate.now();
1153
 
1154
        List<CustomerOffer> customerOffers = customerOfferRepository.selectOffersByDate(todayDate);
1155
        Map<Integer, CustomerOffer> customerOfferMap = customerOffers.stream().collect(Collectors.toMap(x -> x.getId(), x -> x));
1156
        List<Integer> customerOfferIds = customerOffers.stream().map(x -> x.getId()).distinct().collect(Collectors.toList());
1157
        List<CustomerOfferItem> customerOfferItems = customerOfferItemRepository.selectByOfferIds(customerOfferIds, item.getCatalogItemId(), todayDate2);
1158
 
33818 ranu 1159
        List<CustomerOfferItem> filteredCustomerOfferItems = customerOfferItems.stream()
33822 ranu 1160
                .filter(x -> x.getEndDate() != null && !x.getEndDate().isBefore(todayDate2))
33818 ranu 1161
                .collect(Collectors.toList());
1162
 
33795 ranu 1163
        List<WebOffer> webOffers = webOfferRepository.selectAllActiveOffers().get(item.getCatalogItemId());
1164
 
1165
        model.addAttribute("webOffers", webOffers);
1166
        model.addAttribute("customerOfferMap", customerOfferMap);
33818 ranu 1167
        model.addAttribute("customerOfferItems", filteredCustomerOfferItems);
33795 ranu 1168
 
1169
        return "upgrade-customer-offer-model";
1170
    }
1171
 
33213 tejus.loha 1172
    @GetMapping("/insuranceDetails")
1173
    public String getInsuranceDetails(HttpServletRequest request,
1174
                                      @RequestParam(name = "offset", defaultValue = "0") int offset,
1175
                                      @RequestParam(name = "limit", defaultValue = "10") int limit, Model model)
1176
            throws ProfitMandiBusinessException {
1177
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1178
        long size = 0;
1179
        List<InsurancePolicy> insurancePolicies = insurancePolicyRepository.selectByRetailerId(loginDetails.getFofoId(),
1180
                offset, limit);
1181
        size = insurancePolicyRepository.selectCountByRetailerId(loginDetails.getFofoId());
1182
        Map<Integer, String> providerPolicyNameAndIdMap = insuranceProviderRepository
1183
                .selectByIds(insurancePolicies.stream().map(x -> x.getProviderId()).collect(Collectors.toSet()))
1184
                .stream().collect(Collectors.toMap(InsuranceProvider::getId, InsuranceProvider::getName));
1185
        if (size < limit) {
1186
            model.addAttribute("end", offset + size);
1187
        } else {
1188
            model.addAttribute("end", offset + limit);
1189
        }
1190
        model.addAttribute("start", offset + 1);
1191
        model.addAttribute("size", size);
1192
        model.addAttribute("insurancePolicies", insurancePolicies);
1193
        model.addAttribute("providerPolicyNameAndIdMap", providerPolicyNameAndIdMap);
1194
        return "insurance-details";
1195
    }
28339 tejbeer 1196
 
33213 tejus.loha 1197
    @GetMapping("/insuranceDetailsPaginated")
1198
    public String getInsuranceDetailsPaginated(HttpServletRequest request,
1199
                                               @RequestParam(name = "offset", defaultValue = "0") int offset,
1200
                                               @RequestParam(name = "limit", defaultValue = "10") int limit, Model model)
1201
            throws ProfitMandiBusinessException {
1202
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1203
        List<InsurancePolicy> insurancePolicies = insurancePolicyRepository.selectByRetailerId(loginDetails.getFofoId(),
1204
                offset, limit);
1205
        Map<Integer, String> providerPolicyNameAndIdMap = insuranceProviderRepository
1206
                .selectByIds(insurancePolicies.stream().map(x -> x.getProviderId()).collect(Collectors.toSet()))
1207
                .stream().collect(Collectors.toMap(InsuranceProvider::getId, InsuranceProvider::getName));
1208
        model.addAttribute("insurancePolicies", insurancePolicies);
1209
        model.addAttribute("providerPolicyNameAndIdMap", providerPolicyNameAndIdMap);
1210
        return "insurance-details-paginated";
1211
    }
23973 govind 1212
 
33213 tejus.loha 1213
    @GetMapping("/getMouForm")
1214
    public String getMouForm(HttpServletRequest request, Model model) throws Exception {
1215
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
21985 kshitij.so 1216
 
33213 tejus.loha 1217
        Mou mou = mouRepository.selectByFofoId(loginDetails.getFofoId());
1218
        if (mou != null) {
1219
            if (mou.getUpdateTimestamp().getMonth().equals(LocalDateTime.now().getMonth())) {
1220
                model.addAttribute("response1", mvcResponseSender.createResponseString(true));
1221
            } else {
1222
                model.addAttribute("response1", mvcResponseSender.createResponseString(false));
1223
            }
32238 amit.gupta 1224
 
33213 tejus.loha 1225
        } else {
1226
            model.addAttribute("response1", mvcResponseSender.createResponseString(false));
32238 amit.gupta 1227
 
33213 tejus.loha 1228
        }
1229
        return "response";
32238 amit.gupta 1230
 
33213 tejus.loha 1231
    }
23973 govind 1232
 
33213 tejus.loha 1233
    @GetMapping("/pendingOrders")
1234
    public String getPendingOrders(HttpServletRequest request, Model model) throws ProfitMandiBusinessException {
1235
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1236
        boolean isAdmin = roleManager.isAdmin(loginDetails.getRoleIds());
1237
        Mou mou = mouRepository.selectByFofoId(loginDetails.getFofoId());
1238
        if (mou == null) {
1239
            mou = new Mou();
1240
            mou.setFofoId(loginDetails.getFofoId());
1241
            mou.setCreateTimestamp(LocalDateTime.now());
1242
            mou.setUpdateTimestamp(LocalDateTime.now());
1243
            mouRepository.persist(mou);
1244
        } else if (!mou.getUpdateTimestamp().getMonth().equals(LocalDateTime.now().getMonth())) {
1245
            mou.setUpdateTimestamp(LocalDateTime.now());
1246
        }
24844 amit.gupta 1247
 
33213 tejus.loha 1248
        List<PendingOrderItem> pendingOrderItems = pendingOrderItemRepository.selectOrderItemByStatusAndFofoId(OrderStatus.PROCESSING,
1249
                loginDetails.getFofoId());
23973 govind 1250
 
34387 vikas.jang 1251
        Map<String, List<PendingOrderPlan>> pendingOrderPlansMap = pendingOrderPlanRepository.selectAll().stream()
1252
                .collect(Collectors.groupingBy(PendingOrderPlan::getPlanId));
33213 tejus.loha 1253
        Map<String, Object> map = pendingOrderService.getItemOrders(pendingOrderItems, loginDetails.getFofoId());
1254
        model.addAttribute("inventoryMap", map.get("inventoryMap"));
33437 ranu 1255
        model.addAttribute("pendingOrderPlansMap", pendingOrderPlansMap);
33213 tejus.loha 1256
        model.addAttribute("pendingOrderItems", (List<PendingOrderItem>) map.get("pendingOrderItems"));
23973 govind 1257
 
33213 tejus.loha 1258
        model.addAttribute("isAdmin", isAdmin);
1259
        return "pending_fofo_order";
25092 amit.gupta 1260
 
33213 tejus.loha 1261
    }
25092 amit.gupta 1262
 
33400 ranu 1263
    @RequestMapping(value = "/create-order", method = RequestMethod.POST)
1264
    public String createOrder(HttpServletRequest request, @RequestBody CreateOrderRequest createOrderRequest,
34194 ranu 1265
                              Model model) throws Exception {
33400 ranu 1266
        // throw new ProfitMandiBusinessException("Billing is on hold temporarily",
1267
        // "Billing is on hold temporarily", "Billing is on hold temporarily");
1268
        LOGGER.info("request at uri {}", request.getRequestURI());
1269
        LOGGER.info("request body {}", createOrderRequest);
1270
        LoginDetails fofoDetails = cookiesProcessor.getCookiesObject(request);
1271
        int fofoOrderId = orderService.createOrder(createOrderRequest, fofoDetails.getFofoId(), accessoriesDeals);
34479 tejus.loha 1272
//        try {
1273
//            scratchService.processScratchOffer(fofoOrderId, createOrderRequest.getPaymentOptions(), createOrderRequest.getFofoOrderItems());
1274
//        } catch (Exception e) {
1275
//            LOGGER.info("Exception during processScratchOffer - " + e.getMessage());
1276
//        }
1277
 
34179 tejus.loha 1278
        LOGGER.info("Order has been created successfully...");
33400 ranu 1279
        return "redirect:/get-order/?orderId=" + fofoOrderId;
1280
    }
1281
 
33213 tejus.loha 1282
    @GetMapping("/billedOrders")
1283
    public String getBilledOrders(HttpServletRequest request, Model model) throws ProfitMandiBusinessException {
1284
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1285
        boolean isAdmin = roleManager.isAdmin(loginDetails.getRoleIds());
25092 amit.gupta 1286
 
33400 ranu 1287
        List<PendingOrderItem> pendingOrderItems;
23973 govind 1288
 
33213 tejus.loha 1289
        if (isAdmin) {
27861 tejbeer 1290
 
33400 ranu 1291
            pendingOrderItems = pendingOrderItemRepository.selectOrderItemByStatus(OrderStatus.BILLED);
27861 tejbeer 1292
 
33213 tejus.loha 1293
        } else {
33400 ranu 1294
            pendingOrderItems = pendingOrderItemRepository.selectOrderItemByStatusAndFofoId(OrderStatus.BILLED,
33213 tejus.loha 1295
                    loginDetails.getFofoId());
33400 ranu 1296
 
1297
 
33213 tejus.loha 1298
        }
27861 tejbeer 1299
 
33400 ranu 1300
        Map<String, Object> map = pendingOrderService.getItemOrders(pendingOrderItems, loginDetails.getFofoId());
1301
        model.addAttribute("pendingOrderItems", (List<PendingOrderItem>) map.get("pendingOrderItems"));
27861 tejbeer 1302
 
33213 tejus.loha 1303
        model.addAttribute("isAdmin", isAdmin);
1304
        return "billed_order_item";
1305
    }
27861 tejbeer 1306
 
33213 tejus.loha 1307
    @GetMapping("/settledOrders")
1308
    public String getSettledOrders(HttpServletRequest request, Model model) throws ProfitMandiBusinessException {
1309
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1310
        boolean isAdmin = roleManager.isAdmin(loginDetails.getRoleIds());
27861 tejbeer 1311
 
33213 tejus.loha 1312
        List<PendingOrderItem> pendingOrderItem = null;
27861 tejbeer 1313
 
33213 tejus.loha 1314
        if (isAdmin) {
24105 govind 1315
 
33213 tejus.loha 1316
            pendingOrderItem = pendingOrderItemRepository.selectOrderItemByStatus(OrderStatus.SETTLED);
24105 govind 1317
 
33213 tejus.loha 1318
        } else {
1319
            pendingOrderItem = pendingOrderItemRepository.selectOrderItemByStatusAndFofoId(OrderStatus.SETTLED,
1320
                    loginDetails.getFofoId());
1321
        }
24105 govind 1322
 
33213 tejus.loha 1323
        Map<String, Object> map = pendingOrderService.getItemOrders(pendingOrderItem, loginDetails.getFofoId());
24105 govind 1324
 
33400 ranu 1325
        model.addAttribute("pendingOrderItems", (List<PendingOrderItem>) map.get("pendingOrderItems"));
33213 tejus.loha 1326
        model.addAttribute("isAdmin", isAdmin);
1327
        return "settled_order_item";
1328
    }
27861 tejbeer 1329
 
33213 tejus.loha 1330
    @GetMapping("/unsettledOrders")
1331
    public String getunsettledOrders(HttpServletRequest request, Model model) throws ProfitMandiBusinessException {
1332
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1333
        boolean isAdmin = roleManager.isAdmin(loginDetails.getRoleIds());
24105 govind 1334
 
33213 tejus.loha 1335
        List<PendingOrderItem> pendingOrderItem = null;
27861 tejbeer 1336
 
33213 tejus.loha 1337
        if (isAdmin) {
24105 govind 1338
 
33213 tejus.loha 1339
            pendingOrderItem = pendingOrderItemRepository.selectOrderItemByStatus(OrderStatus.UNSETTLED);
27861 tejbeer 1340
 
33213 tejus.loha 1341
        } else {
1342
            pendingOrderItem = pendingOrderItemRepository.selectOrderItemByStatusAndFofoId(OrderStatus.UNSETTLED,
1343
                    loginDetails.getFofoId());
1344
        }
24440 amit.gupta 1345
 
33213 tejus.loha 1346
        Map<String, Object> map = pendingOrderService.getItemOrders(pendingOrderItem, loginDetails.getFofoId());
25726 amit.gupta 1347
 
33400 ranu 1348
        model.addAttribute("pendingOrderItems", (List<PendingOrderItem>) map.get("pendingOrderItems"));
33213 tejus.loha 1349
        model.addAttribute("isAdmin", isAdmin);
1350
        return "unsettled_order_item";
1351
    }
24880 govind 1352
 
33213 tejus.loha 1353
    @GetMapping("/getPendingOrderItem")
1354
    public String getPendingOrderItem(HttpServletRequest request, @RequestParam int orderId, Model model)
1355
            throws ProfitMandiBusinessException {
1356
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1357
        Map<Integer, Item> itemMap = new HashMap<>();
1358
        Map<Integer, CurrentInventorySnapshot> inventoryMap = new HashMap<>();
1359
        PendingOrder pendingPO = pendingOrderRepository.selectById(orderId);
1360
        Customer customer = customerRepository.selectById(pendingPO.getCustomerId());
1361
        List<PendingOrderItem> pendingOrderItems = pendingOrderItemRepository.selectByOrderId(orderId);
1362
        for (PendingOrderItem pendingOrderItem : pendingOrderItems) {
1363
            Item item = itemRepository.selectById(pendingOrderItem.getItemId());
1364
            CurrentInventorySnapshot cis = currentInventorySnapshotRepository
1365
                    .selectByItemAndFofoId(pendingOrderItem.getItemId(), pendingPO.getFofoId());
1366
            itemMap.put(pendingOrderItem.getItemId(), item);
1367
            LOGGER.info("cis" + cis);
1368
            inventoryMap.put(pendingOrderItem.getItemId(), cis);
1369
        }
28339 tejbeer 1370
 
33213 tejus.loha 1371
        LOGGER.info("inventoryMap" + inventoryMap);
1372
        model.addAttribute("pendingOrderItems", pendingOrderItems);
1373
        model.addAttribute("itemMap", itemMap);
1374
        model.addAttribute("inventoryMap", inventoryMap);
1375
        model.addAttribute("pendingPO", gson.toJson(pendingPO));
1376
        model.addAttribute("pendingPOCustomer", gson.toJson(customer));
1377
        model.addAttribute("isAdmin", roleManager.isAdmin(loginDetails.getRoleIds()));
1378
        return "pending-order-item";
1379
    }
28339 tejbeer 1380
 
33213 tejus.loha 1381
    @RequestMapping(value = "/getPendingOrderItemById", method = RequestMethod.GET)
1382
    public String getPendingOrderItemById(HttpServletRequest request, @RequestParam int id, Model model)
1383
            throws Exception {
27046 tejbeer 1384
 
33213 tejus.loha 1385
        PendingOrderItem pendingOrderItem = pendingOrderItemRepository.selectById(id);
1386
        model.addAttribute("pendingOrderItem", pendingOrderItem);
1387
        return "cancel-pending-order";
1388
    }
27046 tejbeer 1389
 
33213 tejus.loha 1390
    @RequestMapping(value = "/getPendingOrderChangePartnerById", method = RequestMethod.GET)
33367 ranu 1391
    public String getPendingOrderChangePartnerById(HttpServletRequest request, @RequestParam int id, @RequestParam String pinCode, Model model)
33213 tejus.loha 1392
            throws Exception {
28350 tejbeer 1393
 
33213 tejus.loha 1394
        PendingOrder pendingOrder = pendingOrderRepository.selectById(id);
33374 ranu 1395
        Map<Integer, CustomRetailer> customRetailersMap = retailerService.getFofoRetailers(true);
33213 tejus.loha 1396
        model.addAttribute("customRetailersMap", customRetailersMap);
1397
        model.addAttribute("pendingOrder", pendingOrder);
1398
        return "change-partner-po";
1399
    }
28358 tejbeer 1400
 
33213 tejus.loha 1401
    @RequestMapping(value = "/changePendingOrderPartner", method = RequestMethod.POST)
1402
    public String changePendingOrderPartner(HttpServletRequest request, @RequestParam int id, @RequestParam int fofoId,
1403
                                            Model model) throws Exception {
28350 tejbeer 1404
 
33213 tejus.loha 1405
        PendingOrder pendingOrder = pendingOrderRepository.selectById(id);
1406
        pendingOrder.setFofoId(fofoId);
1407
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
28339 tejbeer 1408
 
33213 tejus.loha 1409
        return "response";
1410
    }
28339 tejbeer 1411
 
33213 tejus.loha 1412
    @RequestMapping(value = "/cancelPendingOrderItem", method = RequestMethod.POST)
1413
    public String cancelPendingOrderItem(HttpServletRequest request, @RequestParam int id, @RequestParam String reason,
1414
                                         Model model) throws Exception {
28339 tejbeer 1415
 
33213 tejus.loha 1416
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1417
        PendingOrderItem pendingOrderItem = pendingOrderItemRepository.selectById(id);
28339 tejbeer 1418
 
33213 tejus.loha 1419
        pendingOrderItem.setStatus(OrderStatus.CANCELLED);
1420
        pendingOrderItem.setStatusDescription(loginDetails.getEmailId());
1421
        pendingOrderItem.setRemark(reason);
1422
        pendingOrderItem.setCancelledTimestamp(LocalDateTime.now());
1423
        PendingOrder pendingOrder = pendingOrderRepository.selectById(pendingOrderItem.getOrderId());
27046 tejbeer 1424
 
33213 tejus.loha 1425
        List<OrderStatus> status = pendingOrderItemRepository.selectByOrderId(pendingOrderItem.getOrderId()).stream()
1426
                .map(x -> x.getStatus()).collect(Collectors.toList());
28339 tejbeer 1427
 
33213 tejus.loha 1428
        Customer customer = customerRepository.selectById(pendingOrder.getCustomerId());
26647 tejbeer 1429
 
33213 tejus.loha 1430
        List<Integer> catalogIds = new ArrayList<>();
28339 tejbeer 1431
 
33213 tejus.loha 1432
        Item item = itemRepository.selectById(pendingOrderItem.getItemId());
1433
        pendingOrderItem.setItemName(item.getItemDescription());
1434
        catalogIds.add(item.getCatalogItemId());
28339 tejbeer 1435
 
33213 tejus.loha 1436
        Map<Integer, JSONObject> contentMap = commonSolrService.getContentByCatalogIds(catalogIds);
1437
        JSONObject jsonObj = contentMap.get(item.getCatalogItemId());
1438
        pendingOrderItem.setImgUrl(jsonObj.getString("imageUrl_s"));
1439
        pendingOrder.setPendingOrderItems(Arrays.asList(pendingOrderItem));
1440
        CustomerAddress customerAddress = customerAddressRepository.selectById(pendingOrder.getCustomerAddressId());
28339 tejbeer 1441
 
33213 tejus.loha 1442
        DateTimeFormatter dateTimeFormatter = DateTimeFormatter.ofPattern("dd/MM/yyyy h:mm a");
28339 tejbeer 1443
 
33213 tejus.loha 1444
        Map<String, Object> emailModel = new HashMap<>();
1445
        emailModel.put("customer", customerAddress);
1446
        emailModel.put("pendingOrder", pendingOrder);
1447
        emailModel.put("date", dateTimeFormatter);
1448
        LOGGER.info("emal" + customer.getEmailId());
1449
        String[] customerEmail = null;
1450
        if (customer.getEmailId() != null && !customer.getEmailId().isEmpty()) {
1451
            customerEmail = new String[]{customer.getEmailId()};
28339 tejbeer 1452
 
34211 vikas.jang 1453
            List<String> bccTo = Arrays.asList("vikas.jangra@smartdukaan.com");
28339 tejbeer 1454
 
33213 tejus.loha 1455
            emailService.sendMailWithAttachments("Order Cancellation", "order-cancellation.vm", emailModel,
1456
                    customerEmail, null, bccTo.toArray(new String[0]));
28339 tejbeer 1457
 
33213 tejus.loha 1458
        }
28339 tejbeer 1459
 
33213 tejus.loha 1460
        if (!status.contains(OrderStatus.PENDING) && !status.contains(OrderStatus.PROCESSING)
1461
                && !status.contains(OrderStatus.BILLED) && !status.contains(OrderStatus.UNSETTLED)
1462
                && !status.contains(OrderStatus.CLAIMED)) {
1463
            pendingOrder.setStatus(OrderStatus.CLOSED);
1464
        }
1465
        pendingOrderItemRepository.persist(pendingOrderItem);
28339 tejbeer 1466
 
33213 tejus.loha 1467
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
28339 tejbeer 1468
 
33213 tejus.loha 1469
        return "response";
1470
    }
28339 tejbeer 1471
 
33400 ranu 1472
    @GetMapping("/claimedOrders")
1473
    public String getclaimedOrders(HttpServletRequest request, Model model) throws ProfitMandiBusinessException {
33213 tejus.loha 1474
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
33400 ranu 1475
        boolean isAdmin = roleManager.isAdmin(loginDetails.getRoleIds());
1476
        List<Integer> fofoIds = fofoStoreRepository.selectActiveStores().stream().map(x -> x.getId())
1477
                .collect(Collectors.toList());
28339 tejbeer 1478
 
33400 ranu 1479
        List<PendingOrderItem> pendingOrderItem = null;
28339 tejbeer 1480
 
33400 ranu 1481
        if (isAdmin) {
28339 tejbeer 1482
 
33400 ranu 1483
            pendingOrderItem = pendingOrderItemRepository.selectOrderItemByStatus(OrderStatus.CLAIMED);
1484
            Map<Integer, CustomRetailer> customRetailerMap = retailerService.getAllFofoRetailers();
28339 tejbeer 1485
 
33400 ranu 1486
            Map<Integer, CustomRetailer> customRetailersMap = fofoIds.stream().map(x -> customRetailerMap.get(x))
1487
                    .filter(x -> x != null).collect(Collectors.toList()).stream()
1488
                    .collect(Collectors.toMap(x -> x.getPartnerId(), x -> x));
1489
            model.addAttribute("customRetailersMap", customRetailersMap);
28339 tejbeer 1490
 
33400 ranu 1491
        } else {
1492
            pendingOrderItem = pendingOrderItemRepository.selectOrderItemByStatusAndFofoId(OrderStatus.CLAIMED,
1493
                    loginDetails.getFofoId());
1494
        }
30426 tejbeer 1495
 
33400 ranu 1496
        Map<String, Object> map = pendingOrderService.getItemOrders(pendingOrderItem, loginDetails.getFofoId());
28339 tejbeer 1497
 
33400 ranu 1498
        model.addAttribute("pendingOrderItems", map.get("pendingOrderItems"));
1499
        model.addAttribute("isAdmin", isAdmin);
1500
        return "claim_raised_order_item";
33213 tejus.loha 1501
    }
27046 tejbeer 1502
 
33213 tejus.loha 1503
    @RequestMapping(value = "/raiseClaimOrderItem", method = RequestMethod.POST)
1504
    public String raiseClaimOrderItem(HttpServletRequest request, @RequestParam int id, Model model) throws Exception {
28352 tejbeer 1505
 
33213 tejus.loha 1506
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1507
        PendingOrderItem pendingOrderItem = pendingOrderItemRepository.selectById(id);
1508
        PendingOrder pendingOrder = pendingOrderRepository.selectById(pendingOrderItem.getOrderId());
28437 tejbeer 1509
 
33213 tejus.loha 1510
        if (pendingOrder.getTotalAmount() == pendingOrder.getPaidAmount()) {
1511
            pendingOrderItem.setStatus(OrderStatus.CLAIMED);
1512
            pendingOrderItem.setClaimedTimestamp(LocalDateTime.now());
28437 tejbeer 1513
 
33213 tejus.loha 1514
        }
1515
        pendingOrderItemRepository.persist(pendingOrderItem);
1516
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
28437 tejbeer 1517
 
33213 tejus.loha 1518
        return "response";
1519
    }
28437 tejbeer 1520
 
33213 tejus.loha 1521
    @RequestMapping(value = "/verifyOrderItem", method = RequestMethod.POST)
1522
    public String verifyOrderItem(HttpServletRequest request, @RequestParam int id, Model model) throws Exception {
28437 tejbeer 1523
 
33213 tejus.loha 1524
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1525
        PendingOrderItem pendingOrderItem = pendingOrderItemRepository.selectById(id);
1526
        pendingOrderItem.setVerifiedTimestamp(LocalDateTime.now());
28352 tejbeer 1527
 
33213 tejus.loha 1528
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
26721 tejbeer 1529
 
33213 tejus.loha 1530
        return "response";
1531
    }
26721 tejbeer 1532
 
33213 tejus.loha 1533
    @RequestMapping(value = "/cancelOrderByInvoice", method = RequestMethod.POST)
1534
    public String cancelOrder(HttpServletRequest request, @RequestParam List<String> invoiceNumbers, Model model)
1535
            throws Exception {
1536
        orderService.cancelOrder(invoiceNumbers);
1537
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
26721 tejbeer 1538
 
33213 tejus.loha 1539
        return "response";
1540
    }
28352 tejbeer 1541
 
33213 tejus.loha 1542
    @RequestMapping(value = "/getOnlineOrder", method = RequestMethod.GET)
1543
    public String cancelOrder(HttpServletRequest request, Model model) throws Exception {
1544
        return "online-order";
1545
    }
28352 tejbeer 1546
 
33400 ranu 1547
    @RequestMapping(value = "/deliveredPendingOrderItem", method = RequestMethod.POST)
1548
    public String deliveredPendingOrderItem(HttpServletRequest request, @RequestParam(name = "id") int pendingOrderItemId, Model model)
1549
            throws Exception {
1550
 
1551
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1552
        PendingOrderItem pendingOrderItem = pendingOrderItemRepository.selectById(pendingOrderItemId);
1553
        PendingOrder pendingOrder = pendingOrderRepository.selectById(pendingOrderItem.getOrderId());
1554
 
1555
        //Prepaid payment successful
1556
        if (pendingOrder.getTotalAmount() == pendingOrder.getPaidAmount()) {
1557
            //pendingOrderItem.setStatus(OrderStatus.UNSETTLED);
1558
//            pendingOrderItem.setSettled(false);
1559
            pendingOrderItem.setStatus(OrderStatus.CLAIMED);
1560
            pendingOrderItem.setClaimedTimestamp(LocalDateTime.now());
1561
        } else {
1562
            pendingOrderItem.setStatus(OrderStatus.SETTLED);
1563
        }
1564
        pendingOrderItem.setDeliveredTimestamp(LocalDateTime.now());
1565
 
1566
        List<OrderStatus> pendingOrderItemStatusList = pendingOrderItemRepository.selectByOrderId(pendingOrderItem.getOrderId()).stream()
1567
                .map(x -> x.getStatus()).collect(Collectors.toList());
1568
 
1569
        List<Integer> catalogIds = new ArrayList<>();
1570
 
1571
        Item item = itemRepository.selectById(pendingOrderItem.getItemId());
1572
        pendingOrderItem.setItemName(item.getItemDescription());
1573
        catalogIds.add(item.getCatalogItemId());
1574
 
1575
        Map<Integer, JSONObject> contentMap = commonSolrService.getContentByCatalogIds(catalogIds);
1576
        JSONObject jsonObj = contentMap.get(item.getCatalogItemId());
1577
        pendingOrderItem.setImgUrl(jsonObj.getString("imageUrl_s"));
1578
        pendingOrder.setPendingOrderItems(Arrays.asList(pendingOrderItem));
1579
        CustomerAddress customerAddress = customerAddressRepository.selectById(pendingOrder.getCustomerAddressId());
1580
        DateTimeFormatter dateTimeFormatter = DateTimeFormatter.ofPattern("dd/MM/yyyy h:mm a");
1581
        Map<String, Object> emailModel = new HashMap<>();
1582
        emailModel.put("customer", customerAddress);
1583
        emailModel.put("pendingOrder", pendingOrder);
1584
        emailModel.put("date", dateTimeFormatter);
1585
        Customer customer = customerRepository.selectById(pendingOrder.getCustomerId());
1586
        String[] customerEmail = null;
1587
        if (customer.getEmailId() != null && !customer.getEmailId().isEmpty()) {
1588
            customerEmail = new String[]{customer.getEmailId()};
34211 vikas.jang 1589
            List<String> bccTo = Arrays.asList("vikas.jangra@smartdukaan.com");
33400 ranu 1590
 
1591
            emailService.sendMailWithAttachments("Order Delivered with SmartDukaan", "order-delivered.vm", emailModel,
1592
                    customerEmail, null, bccTo.toArray(new String[0]));
1593
 
1594
        }
1595
        if (!pendingOrderItemStatusList.contains(OrderStatus.PENDING) && !pendingOrderItemStatusList.contains(OrderStatus.PROCESSING)
1596
                && !pendingOrderItemStatusList.contains(OrderStatus.BILLED) && !pendingOrderItemStatusList.contains(OrderStatus.UNSETTLED)
1597
                && !pendingOrderItemStatusList.contains(OrderStatus.CLAIMED)) {
1598
            pendingOrder.setStatus(OrderStatus.CLOSED);
1599
        }
1600
        pendingOrderItemRepository.persist(pendingOrderItem);
1601
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
1602
 
1603
        return "response";
1604
    }
1605
 
33213 tejus.loha 1606
    @GetMapping("/getAllOrdersByStatus")
1607
    public String getAllOrdersByStatus(HttpServletRequest request, @RequestParam OrderStatus status,
1608
                                       @RequestParam(required = false) LocalDateTime startTime,
1609
                                       @RequestParam(required = false) LocalDateTime endTime, Model model) throws ProfitMandiBusinessException {
1610
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1611
        boolean isAdmin = roleManager.isAdmin(loginDetails.getRoleIds());
33437 ranu 1612
        boolean isAccountsL2AndL3 = false;
33400 ranu 1613
        if (isAdmin) {
1614
            AuthUser authUser = authRepository.selectByEmailOrMobile(loginDetails.getEmailId());
1615
            List<Position> positions = positionRepository.selectPositionByAuthId(authUser.getId());
1616
            for (Position position : positions) {
33437 ranu 1617
                if (((position.getEscalationType().equals(EscalationType.L2) || position.getEscalationType().equals(EscalationType.L3))
33400 ranu 1618
                        && position.getCategoryId() == ProfitMandiConstants.TICKET_CATEGORY_ACCOUNTS)) {
33437 ranu 1619
                    isAccountsL2AndL3 = true;
33400 ranu 1620
                    break;
1621
                }
1622
            }
1623
        }
1624
 
33213 tejus.loha 1625
        LOGGER.info("startTime {}", startTime);
1626
        LOGGER.info("endTime {}", endTime);
28352 tejbeer 1627
 
33213 tejus.loha 1628
        List<PendingOrderItem> pendingOrderItems;
1629
        if (startTime == null) {
33367 ranu 1630
            LocalDate date = LocalDate.now().minusDays(15);
1631
            if (status.equals(OrderStatus.PENDING)) {
1632
                pendingOrderItems = pendingOrderItemRepository.selectByStatusAndCreateTimestamp(Collections.singletonList(status), date.atStartOfDay(), LocalDateTime.now());
1633
            } else {
1634
                pendingOrderItems = pendingOrderItemRepository.selectOrderItemByStatus(status);
1635
            }
1636
 
33213 tejus.loha 1637
        } else {
1638
            List<OrderStatus> statusList = new ArrayList<>();
1639
            if (status.equals(OrderStatus.DELIVERED)) {
1640
                statusList.add(OrderStatus.SETTLED);
1641
                statusList.add(OrderStatus.UNSETTLED);
1642
            } else {
1643
                statusList.add(status);
1644
            }
1645
            pendingOrderItems = pendingOrderItemRepository.selectByStatusAndCreateTimestamp(statusList,
1646
                    startTime.toLocalDate().atStartOfDay(), endTime);
1647
        }
28352 tejbeer 1648
 
33213 tejus.loha 1649
        List<Integer> pendingOrderIds = pendingOrderItems.stream().map(x -> x.getOrderId()).collect(Collectors.toList());
28352 tejbeer 1650
 
33213 tejus.loha 1651
        List<Integer> fofoIds = pendingOrderRepository.selectByIds(pendingOrderIds)
1652
                .stream().map(x -> x.getFofoId()).distinct().collect(Collectors.toList());
28356 tejbeer 1653
 
33213 tejus.loha 1654
        Map<Integer, CustomRetailer> customRetailerMap = retailerService.getAllFofoRetailers();
28352 tejbeer 1655
 
33213 tejus.loha 1656
        Map<Integer, CustomRetailer> customRetailersMap = fofoIds.stream().map(x -> customRetailerMap.get(x))
1657
                .filter(x -> x != null).collect(Collectors.toList()).stream()
1658
                .collect(Collectors.toMap(x -> x.getPartnerId(), x -> x));
1659
        model.addAttribute("customRetailersMap", customRetailersMap);
28352 tejbeer 1660
 
33213 tejus.loha 1661
        LOGGER.info("customRetailersMap {}", customRetailersMap);
28339 tejbeer 1662
 
33213 tejus.loha 1663
        Map<String, Object> map = pendingOrderService.getItemOrders(pendingOrderItems, 0);
32697 ranu 1664
 
33213 tejus.loha 1665
        model.addAttribute("pendingOrderItems", (List<PendingOrderItem>) map.get("pendingOrderItems"));
1666
        model.addAttribute("partnerInventoryMap", map.get("partnerInventoryMap"));
32697 ranu 1667
 
33213 tejus.loha 1668
        model.addAttribute("isAdmin", isAdmin);
33437 ranu 1669
        model.addAttribute("isAccountsL2AndL3", isAccountsL2AndL3);
33213 tejus.loha 1670
        return "online-order-item";
1671
    }
32697 ranu 1672
 
33400 ranu 1673
    @RequestMapping(value = "/onlinePaymentAddToPartnerWallet", method = RequestMethod.POST)
1674
    public String onlinePaymentAddToPartnerWallet(HttpServletRequest request, @RequestParam int id,
1675
                                                  Model model) throws Exception {
1676
        PendingOrderItem pendingOrderItem = pendingOrderItemRepository.selectById(id);
1677
        PendingOrder pendingOrder = pendingOrderRepository.selectById(pendingOrderItem.getOrderId());
1678
        int fofoId = pendingOrder.getFofoId();
1679
        double deductionPayment = (pendingOrderItem.getSellingPrice() * 2.36) / 100;
1680
        walletService.addAmountToWallet(fofoId, id, WalletReferenceType.ONLINE_ORDER_PAYMENT, "Online Order Payment", pendingOrderItem.getSellingPrice(), LocalDateTime.now());
1681
        walletService.consumeAmountFromWallet(fofoId, id,
1682
                WalletReferenceType.ONLINE_GATEWAY_FEE, "Payment Gatewayfee", (float) deductionPayment, LocalDateTime.now());
1683
 
1684
        pendingOrderItem.setStatus(OrderStatus.CLOSED);
1685
        pendingOrder.setStatus(OrderStatus.CLOSED);
1686
 
1687
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
1688
 
1689
        return "response";
1690
    }
1691
 
33213 tejus.loha 1692
    //TODO Tejus
1693
    @RequestMapping(value = "/getBulkOrder")
33336 tejus.loha 1694
    public String getBulkOrder(HttpServletRequest request, Model model) throws ProfitMandiBusinessException, MessagingException, IOException {
33213 tejus.loha 1695
        return "bulk-order";
1696
    }
32697 ranu 1697
 
33213 tejus.loha 1698
    @PostMapping(value = "/bulkOrder/upload")
1699
    public String uploadCatalog(HttpServletRequest request, @RequestPart("file") MultipartFile file, Model model)
1700
            throws Exception {
1701
        LoginDetails fofoDetails = cookiesProcessor.getCookiesObject(request);
1702
        int authId = authRepository.selectByEmailOrMobile(fofoDetails.getEmailId()).getId();
1703
        LOGGER.info("authId - {}", authId);
1704
        bulkOrderService.parseBulkOrders(file, authId);
1705
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
1706
        return "response";
1707
    }
32697 ranu 1708
 
33213 tejus.loha 1709
    // This method is use for sending all pending transaction to Transation Approval menu
1710
    @RequestMapping(value = "/transaction/pendingApprovals", method = RequestMethod.GET)
1711
    public String getTransactionApproval(HttpServletRequest request, Model model) throws Exception {
33219 tejus.loha 1712
        List<TransactionApproval> transactionApprovals = transactionApprovalRepository.selectAllPending();
1713
        LOGGER.info("list of Approval transaction Id " + transactionApprovals);
33336 tejus.loha 1714
        List<TransactionApprovalModel> approvalModelList = bulkOrderService.getAllPendingTransactionApproval();
33213 tejus.loha 1715
        model.addAttribute("approvalModelList", approvalModelList);
1716
        return "transaction/transaction-approvals";
1717
    }
33092 tejus.loha 1718
 
33213 tejus.loha 1719
    @RequestMapping(value = "transaction/approval", method = RequestMethod.PUT)
1720
    public String transactionApproval(HttpServletRequest request, Model model,
1721
                                      @RequestParam int transactionId,
1722
                                      @RequestParam String remark,
1723
                                      @RequestParam TransactionApprovalStatus transactionApprovalStatus
1724
    ) throws Exception {
1725
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1726
        AuthUser authUser = authRepository.selectByEmailOrMobile(loginDetails.getEmailId());
1727
        int approvalId = authUser.getId();
1728
        String approvedBy = authUser.getFullName();
1729
        LocalDateTime approvedOn = LocalDateTime.now();
1730
        this.updateApprovalStatus(transactionId, approvalId, approvedBy, approvedOn, remark, transactionApprovalStatus);
1731
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
1732
        return "response";
1733
 
1734
    }
1735
 
33696 amit.gupta 1736
 
33213 tejus.loha 1737
    private void updateApprovalStatus(int transactionId, int approvalId, String approvedBy, LocalDateTime approvedOn, String remark, TransactionApprovalStatus transactionApprovalStatus) throws Exception {
1738
        TransactionApproval transactionApproval = transactionApprovalRepository.selectById(transactionId);
33336 tejus.loha 1739
        int retailerId = transactionRepository.selectById(transactionId).getRetailerId();
33213 tejus.loha 1740
        if (!transactionApproval.getStatus().equals(TransactionApprovalStatus.PENDING)) {
1741
            throw new ProfitMandiBusinessException("Transaction already Processed", "Transaction already Processed", "Transaction already Processed");
1742
        }
1743
        transactionApproval.setStatus(transactionApprovalStatus);
1744
        transactionApproval.setRemark(remark);
1745
        transactionApproval.setApprovalId(approvalId);
1746
        transactionApproval.setApprovedBy(approvedBy);
1747
        transactionApproval.setApprovedOn(approvedOn);
1748
        if (transactionApprovalStatus.equals(TransactionApprovalStatus.APPROVED)) {
34313 ranu 1749
            transactionService.processTransaction(transactionId, 0);
33336 tejus.loha 1750
        } else {
1751
            float totalAmount = 0;
1752
            // referense id = transaction id
1753
            // here refund the amount of an order
1754
            List<UserWalletHistory> uwhList = walletService.getAllByReference(retailerId, transactionId, WalletReferenceType.PURCHASE);
33687 amit.gupta 1755
            //Refund only if any amount is deducted from wallet for that particular Transaction
33696 amit.gupta 1756
            if (uwhList.size() > 0) {
33687 amit.gupta 1757
                totalAmount = -uwhList.get(0).getAmount();
1758
                walletService.refundToWallet(retailerId, totalAmount, transactionId, WalletReferenceType.PURCHASE, "Order canceled");
34733 amit.gupta 1759
                sdCreditService.settleBlockedLoan(transactionId, totalAmount);
33687 amit.gupta 1760
            }
33213 tejus.loha 1761
        }
1762
    }
1763
 
1764
    @RequestMapping(value = "/bulkOrderTemplate", method = RequestMethod.GET)
1765
    public ResponseEntity<?> bulkOrderTemplate() throws Exception {
1766
        List<List<?>> rows = new ArrayList<>();
1767
        rows.add(Arrays.asList("Mahaveer", "Change description for your reference", "175139287", "28264", "0", "4"));
1768
        rows.add(Arrays.asList("Mahaveer", "Price =0 means system price", "175139287", "28268", "0", "7"));
1769
        rows.add(Arrays.asList("Jas", "You give custom price also ", "171273247", "28264", "300", "3"));
1770
        org.apache.commons.io.output.ByteArrayOutputStream baos = FileUtil
1771
                .getCSVByteStream(Arrays.asList("Partner name", "Description", "Partner Id", "Item Id", "Price", "Quantity"), rows);
1772
        ResponseEntity<?> responseEntity = orderService.downloadReportInCsv(baos, rows, "Bulk order template");
1773
 
1774
        return responseEntity;
1775
 
1776
    }
34168 tejus.loha 1777
 
1778
    @Autowired
1779
    EInvoiceDetailsRepository eInvoiceDetailsRepository;
1780
 
1781
    @GetMapping("/resetIrnGeneratedPanel")
1782
    public String resetIrnGeneratedPanel() {
1783
        return "reset-irn-panel";
1784
    }
1785
 
1786
    @GetMapping("/getTransactionForIrnReset")
1787
    public String getTransactionForIrnReset(@RequestParam String invoiceNumber, Model model) throws Exception {
1788
        List<String> invoiceNumbers = Arrays.asList(invoiceNumber.split(","));
1789
        List<EInvoiceDetails> eInvoiceDetailsList = eInvoiceDetailsRepository.selectByInvoiceNumbers(invoiceNumbers);
1790
        if (invoiceNumbers.size() == eInvoiceDetailsList.size()) {
1791
            model.addAttribute("irnResetOrderModelList", new ArrayList<>());
1792
            model.addAttribute("notEligibleInvoiceNumbers", invoiceNumber);
1793
            return "eligible-irn-reset-orders";
1794
        }
1795
        Set<String> existingInvoiceInEInvoiceDtl = eInvoiceDetailsList.stream().map(x -> x.getInvoiceNumber()).collect(Collectors.toSet());
1796
        List<String> missingInvoiceInEInvoiceDtl = invoiceNumbers.stream().filter(x -> !existingInvoiceInEInvoiceDtl.contains(x)).collect(Collectors.toList());
1797
 
1798
        List<Order> orderList = orderRepository.selectByInvoiceNumbers(missingInvoiceInEInvoiceDtl).stream().filter(x -> x.getIrnGenerated() != null).collect(Collectors.toList());
1799
        Map<String, List<Order>> invoiceMap = orderList.stream().collect(Collectors.groupingBy(x -> x.getInvoiceNumber()));
1800
        Set<String> notEligibleInvoiceNumbers = new HashSet<>();
1801
        notEligibleInvoiceNumbers.addAll(existingInvoiceInEInvoiceDtl);
1802
        List<IrnResetOrderModel> irnResetOrderModelList = new ArrayList<>();
1803
        for (Map.Entry<String, List<Order>> invoiceMapEntry : invoiceMap.entrySet()) {
1804
            String invoice = invoiceMapEntry.getKey();
1805
            List<Order> orders = invoiceMapEntry.getValue();
1806
            boolean isEligible = !orders.isEmpty() && orders.stream().allMatch(x -> x.getBillingTimestamp().toLocalDate().isAfter(LocalDate.now().minusDays(5)) && x.getIrnGenerated() != null);
1807
            if (isEligible) {
1808
                Order order = orders.get(0);
1809
                FofoStore fofoStore = fofoStoreRepository.selectByRetailerId(order.getRetailerId());
1810
 
1811
                IrnResetOrderModel irnResetOrderModel = new IrnResetOrderModel();
1812
                irnResetOrderModel.setName(partnerOnBoardingPanelRepository.selectByCode(fofoStore.getCode()).getOutLetName());
1813
                irnResetOrderModel.setInvoiceNumber(order.getInvoiceNumber());
1814
                irnResetOrderModel.setInvoiceDate(order.getBillingTimestamp());
1815
                irnResetOrderModel.setWarehouseId(ProfitMandiConstants.WAREHOUSE_MAP.get(order.getWarehouseId()));
1816
                irnResetOrderModel.setTotalOrderValue(orders.stream().mapToDouble(Order::getTotalAmount).sum());
1817
                irnResetOrderModelList.add(irnResetOrderModel);
1818
            } else {
1819
                notEligibleInvoiceNumbers.add(invoice);
1820
            }
1821
        }
1822
        model.addAttribute("irnResetOrderModelList", irnResetOrderModelList);
1823
        model.addAttribute("notEligibleInvoiceNumbers", notEligibleInvoiceNumbers.stream().collect(Collectors.joining(", ")));
1824
        return "eligible-irn-reset-orders";
1825
    }
1826
 
1827
    @PutMapping("/resetOrdersIrn")
1828
    public String resetIrn(@RequestParam String invoiceNumbers, Model model) throws Exception {
1829
        List<String> invoices = new ArrayList<>();
1830
        if (!invoiceNumbers.isEmpty()) {
1831
            invoices = Arrays.asList(invoiceNumbers.split(","));
1832
        }
1833
        List<Order> orderList = orderRepository.selectByInvoiceNumbers(invoices);
1834
        orderList.forEach(order -> {
1835
            order.setIrnGenerated(null);
1836
        });
1837
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
1838
        return "response";
1839
    }
34179 tejus.loha 1840
 
34474 aman.kumar 1841
    @PutMapping(value = "/sendInvoiceOnWhatsApp")
1842
    public String sendInvoiceOnWhatsApp(HttpServletRequest request, @RequestParam int orderId, @RequestParam String whatsAppMobile, Model model) throws Exception {
1843
        boolean isSend = this.sendWhatsappInvoice(fofoOrderRepository.selectByOrderId(orderId), whatsAppMobile);
1844
        model.addAttribute("response1", isSend);
34179 tejus.loha 1845
        return "response";
1846
    }
1847
 
1848
 
32409 amit.gupta 1849
}
32405 jai.hind 1850