Subversion Repositories SmartDukaan

Rev

Rev 33367 | Rev 33400 | 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;
23638 amit.gupta 13
import com.spice.profitmandi.dao.entity.catalog.Item;
27861 tejbeer 14
import com.spice.profitmandi.dao.entity.catalog.TagListing;
22217 ashik.ali 15
import com.spice.profitmandi.dao.entity.dtr.InsurancePolicy;
23343 ashik.ali 16
import com.spice.profitmandi.dao.entity.dtr.InsuranceProvider;
23548 ashik.ali 17
import com.spice.profitmandi.dao.entity.dtr.PaymentOptionTransaction;
30322 amit.gupta 18
import com.spice.profitmandi.dao.entity.fofo.*;
33213 tejus.loha 19
import com.spice.profitmandi.dao.entity.transaction.TransactionApproval;
33336 tejus.loha 20
import com.spice.profitmandi.dao.entity.transaction.UserWalletHistory;
23298 ashik.ali 21
import com.spice.profitmandi.dao.entity.user.Address;
23548 ashik.ali 22
import com.spice.profitmandi.dao.enumuration.dtr.PaymentOptionReferenceType;
27046 tejbeer 23
import com.spice.profitmandi.dao.enumuration.transaction.OrderStatus;
33213 tejus.loha 24
import com.spice.profitmandi.dao.enumuration.transaction.TransactionApprovalStatus;
25
import com.spice.profitmandi.dao.repository.auth.AuthRepository;
23638 amit.gupta 26
import com.spice.profitmandi.dao.repository.catalog.ItemRepository;
27861 tejbeer 27
import com.spice.profitmandi.dao.repository.catalog.TagListingRepository;
30322 amit.gupta 28
import com.spice.profitmandi.dao.repository.dtr.*;
29
import com.spice.profitmandi.dao.repository.fofo.*;
24440 amit.gupta 30
import com.spice.profitmandi.dao.repository.inventory.StateRepository;
33336 tejus.loha 31
import com.spice.profitmandi.dao.repository.transaction.*;
23298 ashik.ali 32
import com.spice.profitmandi.dao.repository.user.AddressRepository;
33336 tejus.loha 33
import com.spice.profitmandi.dao.repository.user.CartRepository;
28377 tejbeer 34
import com.spice.profitmandi.service.EmailService;
32251 amit.gupta 35
import com.spice.profitmandi.service.NotificationService;
23798 amit.gupta 36
import com.spice.profitmandi.service.authentication.RoleManager;
25726 amit.gupta 37
import com.spice.profitmandi.service.integrations.zest.InsuranceService;
24440 amit.gupta 38
import com.spice.profitmandi.service.integrations.zest.MobileInsurancePlan;
33172 tejus.loha 39
import com.spice.profitmandi.service.order.BulkOrderService;
23366 ashik.ali 40
import com.spice.profitmandi.service.order.OrderService;
22069 ashik.ali 41
import com.spice.profitmandi.service.pricing.PricingService;
33213 tejus.loha 42
import com.spice.profitmandi.service.transaction.TransactionService;
26647 tejbeer 43
import com.spice.profitmandi.service.user.RetailerService;
33336 tejus.loha 44
import com.spice.profitmandi.service.wallet.WalletService;
32405 jai.hind 45
import com.spice.profitmandi.service.whatsapp.WhatsappMessageService;
32855 amit.gupta 46
import com.spice.profitmandi.service.whatsapp.WhatsappMessageType;
22139 amit.gupta 47
import com.spice.profitmandi.web.model.LoginDetails;
22069 ashik.ali 48
import com.spice.profitmandi.web.util.CookiesProcessor;
24105 govind 49
import com.spice.profitmandi.web.util.MVCResponseSender;
33336 tejus.loha 50
import in.shop2020.model.v1.order.WalletReferenceType;
30148 amit.gupta 51
import org.apache.logging.log4j.LogManager;
52
import org.apache.logging.log4j.Logger;
32405 jai.hind 53
import org.json.JSONArray;
30148 amit.gupta 54
import org.json.JSONObject;
55
import org.springframework.beans.factory.annotation.Autowired;
56
import org.springframework.core.io.InputStreamResource;
57
import org.springframework.http.HttpHeaders;
58
import org.springframework.http.HttpStatus;
59
import org.springframework.http.MediaType;
60
import org.springframework.http.ResponseEntity;
61
import org.springframework.stereotype.Controller;
62
import org.springframework.transaction.annotation.Transactional;
63
import org.springframework.ui.Model;
64
import org.springframework.web.bind.annotation.*;
33172 tejus.loha 65
import org.springframework.web.multipart.MultipartFile;
21612 ashik.ali 66
 
33336 tejus.loha 67
import javax.mail.MessagingException;
30148 amit.gupta 68
import javax.servlet.http.HttpServletRequest;
69
import javax.servlet.http.HttpServletResponse;
32409 amit.gupta 70
import java.io.ByteArrayInputStream;
71
import java.io.ByteArrayOutputStream;
33336 tejus.loha 72
import java.io.IOException;
32409 amit.gupta 73
import java.io.InputStream;
32271 amit.gupta 74
import java.nio.charset.StandardCharsets;
33367 ranu 75
import java.time.LocalDate;
30148 amit.gupta 76
import java.time.LocalDateTime;
77
import java.time.format.DateTimeFormatter;
78
import java.time.temporal.ChronoUnit;
79
import java.util.*;
80
import java.util.stream.Collectors;
81
 
21612 ashik.ali 82
@Controller
23973 govind 83
@Transactional(rollbackFor = Throwable.class)
21612 ashik.ali 84
public class OrderController {
85
 
33213 tejus.loha 86
    private static final Logger LOGGER = LogManager.getLogger(OrderController.class);
21985 kshitij.so 87
 
33213 tejus.loha 88
    private static final List<String> offlineOrders = Arrays.asList("EMIOD", "POD");
89
    private static final List<String> allowedDoaImeis = Arrays.asList("863903054378477");
90
    @Autowired
91
    NotificationService notificationService;
92
    @Autowired
93
    TransactionApprovalRepository transactionApprovalRepository;
94
    @Autowired
95
    LineItemRepository lineItemRepository;
96
    @Autowired
97
    AuthRepository authRepository;
98
    @Autowired
99
    TransactionService transactionService;
100
    @Autowired
101
    BulkOrderService bulkOrderService;
102
    @Autowired
103
    private CustomerRepository customerRepository;
104
    private boolean accessoriesDeals = true;
105
    @Autowired
106
    private RoleManager roleManager;
107
    @Autowired
108
    private Gson gson;
109
    @Autowired
110
    private CustomerReturnItemRepository customerReturnItemRepository;
111
    @Autowired
112
    private FofoOrderItemRepository fofoOrderItemRepository;
113
    @Autowired
114
    private PaymentOptionRepository paymentOptionRepository;
115
    @Autowired
116
    private StateRepository stateRepository;
117
    @Autowired
118
    private ItemRepository itemRepository;
119
    @Autowired
120
    private MVCResponseSender mvcResponseSender;
121
    @Autowired
122
    private InsuranceService insuranceService;
123
    @Autowired
124
    private FofoOrderRepository fofoOrderRepository;
125
    @Autowired
126
    private CustomerAddressRepository customerAddressRepository;
127
    @Autowired
128
    private InsurancePolicyRepository insurancePolicyRepository;
129
    @Autowired
130
    private InsuranceProviderRepository insuranceProviderRepository;
131
    @Autowired
132
    private CookiesProcessor cookiesProcessor;
133
    @Autowired
134
    private PricingService pricingService;
135
    @Autowired
136
    private OrderService orderService;
137
    @Autowired
138
    private RetailerRegisteredAddressRepository retailerRegisteredAddressRepository;
139
    @Autowired
140
    private AddressRepository addressRepository;
141
    @Autowired
142
    private PaymentOptionTransactionRepository paymentOptionTransactionRepository;
143
    @Autowired
144
    private FofoPartnerPaymentOptionRepository fofoPartnerPaymentOptionRepository;
145
    @Autowired
146
    private ResponseSender<?> responseSender;
147
    @Autowired
148
    private PendingOrderRepository pendingOrderRepository;
149
    @Autowired
150
    private OrderRepository orderRepository;
151
    @Autowired
152
    private PendingOrderItemRepository pendingOrderItemRepository;
153
    @Autowired
154
    private FofoStoreRepository fofoStoreRepository;
155
    @Autowired
156
    private RetailerService retailerService;
157
    @Autowired
158
    private CurrentInventorySnapshotRepository currentInventorySnapshotRepository;
159
    @Autowired
160
    private TagListingRepository tagListingRepository;
161
    @Autowired
162
    private PendingOrderService pendingOrderService;
163
    @Autowired
164
    private EmailService emailService;
165
    @Autowired
166
    private SolrService commonSolrService;
167
    @Autowired
168
    private MouRepository mouRepository;
169
    @Autowired
170
    private WhatsappMessageService whatsappMessageService;
171
    @Autowired
172
    private TransactionRepository transactionRepository;
33336 tejus.loha 173
    @Autowired
174
    WalletService walletService;
175
    @Autowired
176
    CartRepository cartRepository;
177
    @Autowired
178
    UserWalletRepository userWalletRepository;
28339 tejbeer 179
 
33336 tejus.loha 180
 
33213 tejus.loha 181
    @RequestMapping(value = "/order")
182
    public String orderIndex(HttpServletRequest request, @RequestParam(name = "cartData") String cartData, Model model)
183
            throws ProfitMandiBusinessException {
184
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
32405 jai.hind 185
 
33213 tejus.loha 186
        int addressId = retailerRegisteredAddressRepository.selectAddressIdByRetailerId(loginDetails.getFofoId());
187
        Address address = addressRepository.selectById(addressId);
23973 govind 188
 
33213 tejus.loha 189
        List<CartFofo> cartItems = orderService.cartCheckout(cartData);
190
        Set<Integer> itemIds = new HashSet<>();
191
        List<Integer> poIds = new ArrayList<>();
192
        List<Integer> poItemIds = new ArrayList<>();
193
        for (CartFofo cartFofo : cartItems) {
194
            itemIds.add(cartFofo.getItemId());
195
            if (cartFofo.getPoId() != 0) {
196
                poIds.add(cartFofo.getPoId());
197
                poItemIds.add(cartFofo.getPoItemId());
198
            }
199
        }
21985 kshitij.so 200
 
33213 tejus.loha 201
        PendingOrder po = null;
202
        Customer customer = null;
203
        PendingOrderItem poi = null;
204
        Map<Integer, PriceModel> mopPriceMap = pricingService.getPurchasePriceMopPriceNotFound(itemIds,
205
                loginDetails.getFofoId());
206
        List<Integer> paymentOptionIds = fofoPartnerPaymentOptionRepository
207
                .selectPaymentOptionIdsByFofoId(loginDetails.getFofoId());
23973 govind 208
 
33213 tejus.loha 209
        if (!poIds.isEmpty()) {
210
            po = pendingOrderRepository.selectById(poIds.get(0));
211
            customer = customerRepository.selectById(po.getCustomerId());
212
            if (!offlineOrders.contains(po.getPayMethod())) {
213
                paymentOptionIds.add(23);
214
            }
215
        }
27046 tejbeer 216
 
33213 tejus.loha 217
        if (!poItemIds.isEmpty()) {
218
            poi = pendingOrderItemRepository.selectById(poItemIds.get(0));
219
        }
23973 govind 220
 
33213 tejus.loha 221
        // List<PaymentOption> paymentOptions = paymentOptionRepository.selectByIds(new
222
        // HashSet<>(paymentOptionIds));
21985 kshitij.so 223
 
33213 tejus.loha 224
        List<PaymentOption> paymentOptions = paymentOptionRepository.selectActiveOption();
29642 amit.gupta 225
 
33213 tejus.loha 226
        LOGGER.info("pendingOrder" + po);
227
        LOGGER.info("pendingOrderItem" + poi);
24844 amit.gupta 228
 
33213 tejus.loha 229
        LOGGER.info("mopPriceMap {}", mopPriceMap);
230
        model.addAttribute("stateNames",
231
                stateRepository.selectAll().stream().map(x -> x.getName()).collect(Collectors.toList()));
232
        model.addAttribute("retailerStateName", address.getState());
233
        model.addAttribute("pendingPOCustomer", gson.toJson(customer));
234
        model.addAttribute("pendingPO", gson.toJson(po));
23973 govind 235
 
33213 tejus.loha 236
        model.addAttribute("cartItems", cartItems);
237
        model.addAttribute("pendingOrder", po);
238
        model.addAttribute("pendingOrderItem", poi);
21985 kshitij.so 239
 
33213 tejus.loha 240
        model.addAttribute("mopPriceMap", mopPriceMap);
241
        model.addAttribute("paymentOptions", paymentOptions);
242
        model.addAttribute("accessoriesDeals", accessoriesDeals);
243
        return "order-index";
244
    }
24844 amit.gupta 245
 
33213 tejus.loha 246
    @RequestMapping(value = "/checkplans", method = RequestMethod.GET)
247
    public String getInsurancePrices(HttpServletRequest request, @RequestParam float price, Model model,
248
                                     @RequestParam int itemId) throws ProfitMandiBusinessException {
249
        LOGGER.info("Request received at url : {}", request.getRequestURI());
24105 govind 250
 
33213 tejus.loha 251
        try {
252
            String response = mvcResponseSender.createResponseString(this.getPlans(price, itemId));
253
            model.addAttribute("response1", response);
254
        } catch (Exception e) {
255
            // TODO Auto-generated catch block
256
            LOGGER.info(e.getMessage(), e);
257
            throw new ProfitMandiBusinessException("Plans", "Plans API", "Error formatting insurance plans");
258
        }
21985 kshitij.so 259
 
33213 tejus.loha 260
        return "response";
261
    }
23973 govind 262
 
33213 tejus.loha 263
    @RequestMapping(value = "/get-order", method = RequestMethod.GET)
264
    public String getOrder(HttpServletRequest request, @RequestParam(name = ProfitMandiConstants.ORDER_ID) int orderId,
265
                           Model model) throws ProfitMandiBusinessException {
266
        LoginDetails fofoDetails = cookiesProcessor.getCookiesObject(request);
267
        FofoOrder fofoOrder = fofoOrderRepository.selectByFofoIdAndOrderId(fofoDetails.getFofoId(), orderId);
268
        List<FofoOrderItem> fofoLineItems = fofoOrderItemRepository.selectByOrderId(fofoOrder.getId());
269
        CustomerAddress customerAddress = null;
270
        if (fofoOrder.getCustomerAddressId() != 0) {
271
            customerAddress = customerAddressRepository.selectById(fofoOrder.getCustomerAddressId());
272
        }
23973 govind 273
 
33213 tejus.loha 274
        Customer customer = customerRepository.selectById(fofoOrder.getCustomerId());
275
        if (customerAddress != null) {
276
            customerAddress.setPhoneNumber(customer.getMobileNumber());
277
        }
278
        LOGGER.info("Added to get invoice - {}, {}", customer, 123);
279
        List<PaymentOptionTransaction> paymentOptionTransactions = paymentOptionTransactionRepository
280
                .selectByReferenceIdAndType(fofoOrder.getId(), PaymentOptionReferenceType.ORDER);
281
        Map<Integer, PaymentOption> paymentOptionIdPaymentOptionMap = this
282
                .paymentOptionIdPaymentOptionMap(paymentOptionTransactions);
283
        List<InsurancePolicy> insurancePolicies = insurancePolicyRepository
284
                .selectByRetailerIdInvoiceNumber(fofoOrder.getInvoiceNumber());
285
        this.addInsuranceProvider(insurancePolicies);
32627 ranu 286
 
33213 tejus.loha 287
        model.addAttribute("fofoOrder", fofoOrder);
288
        model.addAttribute("fofoLineItems", fofoLineItems);
289
        if (customerAddress != null) {
290
            model.addAttribute("customerBillingAddress", orderService.getBillingAddress(customerAddress));
291
        } else {
292
            model.addAttribute("customerBillingAddress", "");
21985 kshitij.so 293
 
33213 tejus.loha 294
        }
295
        model.addAttribute("customerBillingAddressObj", customerAddress);
296
        model.addAttribute("customerDetailsObj", customer);
297
        model.addAttribute("paymentOptionTransactions", paymentOptionTransactions);
298
        model.addAttribute("paymentOptionIdPaymentOptionMap", paymentOptionIdPaymentOptionMap);
299
        model.addAttribute("insurancePolicies", insurancePolicies);
300
        return "order-details";
301
    }
32637 amit.gupta 302
 
33213 tejus.loha 303
    private Map<Integer, InsuranceProvider> toInsuranceProviderIdInsuranceProvider(
304
            List<InsuranceProvider> insuranceProviders) {
305
        Map<Integer, InsuranceProvider> insuranceProviderIdInsuranceProviderMap = new HashMap<>();
306
        for (InsuranceProvider insuranceProvider : insuranceProviders) {
307
            insuranceProviderIdInsuranceProviderMap.put(insuranceProvider.getId(), insuranceProvider);
308
        }
309
        return insuranceProviderIdInsuranceProviderMap;
310
    }
23973 govind 311
 
33247 ranu 312
    private void addInsuranceProvider(List<InsurancePolicy> insurancePolicies) throws ProfitMandiBusinessException {
33213 tejus.loha 313
        if (insurancePolicies.isEmpty()) {
314
            return;
315
        }
316
        Set<Integer> insuranceProviderIds = new HashSet<>();
317
        for (InsurancePolicy insurancePolicy : insurancePolicies) {
318
            insuranceProviderIds.add(insurancePolicy.getProviderId());
319
        }
320
        LOGGER.info("insuranceProviderIds {}", insuranceProviderIds);
321
        List<InsuranceProvider> insuranceProviders = insuranceProviderRepository.selectByIds(insuranceProviderIds);
322
        Map<Integer, InsuranceProvider> insuranceProviderIdInsuranceProviderMap = this
323
                .toInsuranceProviderIdInsuranceProvider(insuranceProviders);
324
        for (InsurancePolicy insurancePolicy : insurancePolicies) {
325
            insurancePolicy
326
                    .setInsuranceProvider(insuranceProviderIdInsuranceProviderMap.get(insurancePolicy.getProviderId()));
327
        }
328
    }
23973 govind 329
 
33213 tejus.loha 330
    @RequestMapping(value = "/saleDetails", method = RequestMethod.GET)
331
    public String getSaleDetails(HttpServletRequest request,
332
                                 @RequestParam(name = ProfitMandiConstants.ORDER_ID) int orderId, Model model) throws Exception {
333
        LoginDetails fofoDetails = cookiesProcessor.getCookiesObject(request);
334
        boolean isAdmin = roleManager.isAdmin(fofoDetails.getRoleIds());
335
        FofoOrder fofoOrder = fofoOrderRepository.selectByFofoIdAndOrderId(fofoDetails.getFofoId(), orderId);
336
        List<FofoOrderItem> fofoOrderItems = fofoOrderItemRepository.selectByOrderId(fofoOrder.getId());
337
        CustomerAddress customerAddress = customerAddressRepository.selectById(fofoOrder.getCustomerAddressId());
338
        List<PaymentOptionTransaction> paymentOptionTransactions = paymentOptionTransactionRepository
339
                .selectByReferenceIdAndType(fofoOrder.getId(), PaymentOptionReferenceType.ORDER);
23973 govind 340
 
33213 tejus.loha 341
        // Added Migration info as we lost it.
342
        if (paymentOptionTransactions == null || paymentOptionTransactions.size() == 0) {
343
            PaymentOptionTransaction pot = new PaymentOptionTransaction();
344
            pot.setAmount(fofoOrder.getTotalAmount());
345
            pot.setCreateTimestamp(fofoOrder.getCreateTimestamp());
346
            // Mark it paid through cash
347
            pot.setPaymentOptionId(1);
348
            pot.setReferenceType(PaymentOptionReferenceType.ORDER);
349
            paymentOptionTransactionRepository.persist(pot);
350
            paymentOptionTransactions.add(pot);
351
            LOGGER.info("Added to get invoice");
352
        }
353
        Map<Integer, PaymentOption> paymentOptionIdPaymentOptionMap = this
354
                .paymentOptionIdPaymentOptionMap(paymentOptionTransactions);
355
        List<InsurancePolicy> insurancePolicies = insurancePolicyRepository
356
                .selectByRetailerIdInvoiceNumber(fofoOrder.getInvoiceNumber());
357
        this.addInsuranceProvider(insurancePolicies);
358
        Map<Integer, Item> itemsMap = fofoOrderItems.stream().collect(Collectors.toMap(x -> x.getItemId(), x -> {
359
            try {
360
                return itemRepository.selectById(x.getItemId());
361
            } catch (ProfitMandiBusinessException e) {
362
                // TODO Auto-generated catch block
363
                return null;
364
            }
365
        }));
366
        Map<Integer, Set<FofoLineItem>> fofoOrderItemIdLineItemMap = fofoOrderItems.stream()
367
                .collect(Collectors.toMap(FofoOrderItem::getId, FofoOrderItem::getFofoLineItems));
23973 govind 368
 
33213 tejus.loha 369
        Map<Integer, List<CustomerReturnItem>> foiIdCustomerReturnInventoryItemsMap = fofoOrderItems.stream()
370
                .collect(Collectors.toMap(foi -> foi.getId(),
371
                        foi -> customerReturnItemRepository.selectAllByOrderItemId(foi.getId())));
23973 govind 372
 
33213 tejus.loha 373
        Map<Integer, Integer> inventoryItemBilledQtyMap = new HashMap<>();
23973 govind 374
 
33213 tejus.loha 375
        for (FofoOrderItem foi : fofoOrderItems) {
376
            for (FofoLineItem fli : foi.getFofoLineItems()) {
377
                inventoryItemBilledQtyMap.put(fli.getInventoryItemId(), fli.getQuantity());
378
            }
379
            List<CustomerReturnItem> customerReturnItems = customerReturnItemRepository
380
                    .selectAllByOrderItemId(foi.getId());
381
            this.markDoa(fofoOrder, foi, isAdmin);
382
            for (CustomerReturnItem customerReturnItem : customerReturnItems) {
383
                inventoryItemBilledQtyMap.put(customerReturnItem.getInventoryItemId(),
384
                        inventoryItemBilledQtyMap.get(customerReturnItem.getInventoryItemId()) - 1);
385
            }
386
        }
23973 govind 387
 
33213 tejus.loha 388
        LOGGER.info("fofoOrderItemIdLineItemMap {}", fofoOrderItemIdLineItemMap);
389
        model.addAttribute("fofoOrder", fofoOrder);
390
        model.addAttribute("itemsMap", itemsMap);
391
        model.addAttribute("fofoOrderItemIdLineItemsMap", StringUtils.toString(fofoOrderItemIdLineItemMap));
392
        model.addAttribute("foiIdCustomerReturnInventoryItemsMap",
393
                StringUtils.toString(foiIdCustomerReturnInventoryItemsMap));
394
        model.addAttribute("fofoOrderItemIdLineItemMap", fofoOrderItemIdLineItemMap);
23973 govind 395
 
33213 tejus.loha 396
        model.addAttribute("fofoOrderItems", fofoOrderItems);
397
        model.addAttribute("inventoryItemBilledQtyMap", StringUtils.toString(inventoryItemBilledQtyMap));
398
        if (customerAddress != null) {
30426 tejbeer 399
 
33213 tejus.loha 400
            model.addAttribute("customerBillingAddress", orderService.getBillingAddress(customerAddress));
401
        } else {
402
            model.addAttribute("customerBillingAddress", "");
32637 amit.gupta 403
 
33213 tejus.loha 404
        }
405
        model.addAttribute("customerBillingAddressObj", customerAddress);
406
        model.addAttribute("paymentOptionTransactions", paymentOptionTransactions);
407
        model.addAttribute("paymentOptionIdPaymentOptionMap", paymentOptionIdPaymentOptionMap);
408
        model.addAttribute("insurancePolicies", insurancePolicies);
409
        model.addAttribute("markDefective", this.markDefective(fofoOrder));
410
        return "sale-details";
411
    }
32637 amit.gupta 412
 
33213 tejus.loha 413
    private void markDoa(FofoOrder fofoOrder, FofoOrderItem foi, boolean isAdmin) {
414
        if (isAdmin) {
415
            foi.setDoa(true);
416
            return;
417
        }
418
        boolean isImei = foi.getFofoLineItems().stream()
419
                .anyMatch(x -> org.apache.commons.lang3.StringUtils.isNotEmpty(x.getSerialNumber())
420
                        && allowedDoaImeis.contains(x.getSerialNumber()));
421
        LocalDateTime buyDate = fofoOrder.getCreateTimestamp().truncatedTo(ChronoUnit.DAYS);
422
        LocalDateTime curDate = LocalDateTime.now().truncatedTo(ChronoUnit.DAYS);
423
        if (buyDate.isAfter(curDate.minusDays(45)) || isImei) {
424
            foi.setDoa(true);
425
        } else
426
            foi.setDoa(
427
                    foi.getBrand().equals("Nokia") && foi.getCost() < 4990 && buyDate.isAfter(curDate.minusYears(1)));
428
    }
30426 tejbeer 429
 
33213 tejus.loha 430
    private boolean markDefective(FofoOrder fofoOrder) {
431
        return fofoOrder.getCreateTimestamp().truncatedTo(ChronoUnit.DAYS).plusDays(180)
432
                .isAfter(LocalDateTime.now().truncatedTo(ChronoUnit.DAYS));
26647 tejbeer 433
 
33213 tejus.loha 434
    }
26647 tejbeer 435
 
33213 tejus.loha 436
    @RequestMapping(value = "/getSearchOrder")
437
    public String getSearchOrder(HttpServletRequest request, Model model) throws ProfitMandiBusinessException {
438
        return "search-order";
439
    }
26647 tejbeer 440
 
33213 tejus.loha 441
    @RequestMapping(value = "/getInvoiceSearchOrder")
442
    public String getInvoiceSearchOrder(HttpServletRequest request, Model model) throws ProfitMandiBusinessException {
443
        return "invoices-cancel";
444
    }
33172 tejus.loha 445
 
33213 tejus.loha 446
    @RequestMapping(value = "/customerDetails", method = RequestMethod.PUT)
447
    public String updateCustomerDetails(HttpServletRequest request, @RequestBody CustomCustomer customCustomer,
448
                                        @RequestParam(name = ProfitMandiConstants.INVOICE_NUMBER) String invoiceNumber, Model model)
449
            throws Exception {
33172 tejus.loha 450
 
33213 tejus.loha 451
        orderService.updateCustomerDetails(customCustomer, invoiceNumber);
452
        return this.getSearchOrderDetails(request, invoiceNumber, model);
453
    }
33172 tejus.loha 454
 
33213 tejus.loha 455
    @RequestMapping(value = "/searchOrderDetails", method = RequestMethod.GET)
456
    public String getSearchOrderDetails(HttpServletRequest request,
457
                                        @RequestParam(name = ProfitMandiConstants.INVOICE_NUMBER) String invoiceNumber, Model model)
458
            throws Exception {
33172 tejus.loha 459
 
33213 tejus.loha 460
        FofoOrder fofoOrder = fofoOrderRepository.selectByInvoiceNumber(invoiceNumber);
461
        List<FofoOrderItem> fofoOrderItems = fofoOrderItemRepository.selectByOrderId(fofoOrder.getId());
462
        Customer customer = customerRepository.selectById(fofoOrder.getCustomerId());
463
        CustomerAddress customerAddress = customerAddressRepository.selectById(fofoOrder.getCustomerAddressId());
464
        Map<Integer, PaymentOption> paymentOptionIdPaymentOptionMap = paymentOptionRepository.selectActiveOption().stream().collect(Collectors.toMap(x -> x.getId(), x -> x));
465
        List<Integer> fofoPartnerPaymentOptions = new ArrayList<>(paymentOptionIdPaymentOptionMap.keySet());
466
        Map<Integer, Item> itemsMap = fofoOrderItems.stream().collect(Collectors.toMap(x -> x.getItemId(), x -> {
467
            try {
468
                return itemRepository.selectById(x.getItemId());
469
            } catch (ProfitMandiBusinessException e) {
470
                // TODO Auto-generated catch block
471
                return null;
472
            }
473
        }));
474
        LOGGER.info("fofoPartnerPaymentOptions" + fofoPartnerPaymentOptions);
475
        List<PaymentOptionTransaction> paymentOptionTransactions = paymentOptionTransactionRepository
476
                .selectByReferenceIdAndType(fofoOrder.getId(), PaymentOptionReferenceType.ORDER);
477
        LOGGER.info("paymentOptionTransactions" + paymentOptionTransactions);
26647 tejbeer 478
 
33213 tejus.loha 479
        Map<Integer, PaymentOptionTransaction> paymentOptionIdPaymentOptionTransactionMap = this
480
                .paymentOptionIdPaymentOptionTransactionMap(paymentOptionTransactions);
481
        LOGGER.info("paymentOptionIdPaymentOptionTransactionMap" + paymentOptionIdPaymentOptionTransactionMap.keySet());
482
        List<InsurancePolicy> insurancePolicies = insurancePolicyRepository
483
                .selectByRetailerIdInvoiceNumber(fofoOrder.getInvoiceNumber());
484
        this.addInsuranceProvider(insurancePolicies);
485
        model.addAttribute("fofoOrder", fofoOrder);
486
        for (FofoOrderItem fofoOrderItem : fofoOrderItems) {
487
            fofoOrderItem.setDoa(true);
488
        }
27861 tejbeer 489
 
33213 tejus.loha 490
        Map<Integer, Set<FofoLineItem>> fofoOrderItemIdLineItemMap = fofoOrderItems.stream()
491
                .collect(Collectors.toMap(FofoOrderItem::getId, FofoOrderItem::getFofoLineItems));
28339 tejbeer 492
 
33213 tejus.loha 493
        Map<Integer, List<CustomerReturnItem>> foiIdCustomerReturnInventoryItemsMap = fofoOrderItems.stream()
494
                .collect(Collectors.toMap(foi -> foi.getId(),
495
                        foi -> customerReturnItemRepository.selectAllByOrderItemId(foi.getId())));
28339 tejbeer 496
 
33213 tejus.loha 497
        Map<Integer, Integer> inventoryItemBilledQtyMap = new HashMap<>();
28339 tejbeer 498
 
33213 tejus.loha 499
        for (FofoOrderItem foi : fofoOrderItems) {
500
            for (FofoLineItem fli : foi.getFofoLineItems()) {
501
                inventoryItemBilledQtyMap.put(fli.getInventoryItemId(), fli.getQuantity());
502
            }
503
            List<CustomerReturnItem> customerReturnItems = customerReturnItemRepository
504
                    .selectAllByOrderItemId(foi.getId());
505
            for (CustomerReturnItem customerReturnItem : customerReturnItems) {
506
                inventoryItemBilledQtyMap.put(customerReturnItem.getInventoryItemId(),
507
                        inventoryItemBilledQtyMap.get(customerReturnItem.getInventoryItemId()) - 1);
508
            }
509
        }
510
        model.addAttribute("foiIdCustomerReturnInventoryItemsMap",
511
                StringUtils.toString(foiIdCustomerReturnInventoryItemsMap));
512
        model.addAttribute("fofoOrderItems", fofoOrderItems);
513
        model.addAttribute("inventoryItemBilledQtyMap", StringUtils.toString(inventoryItemBilledQtyMap));
514
        model.addAttribute("fofoOrderItemIdLineItemsMap", StringUtils.toString(fofoOrderItemIdLineItemMap));
515
        model.addAttribute("itemsMap", itemsMap);
516
        model.addAttribute("markDefective", true);
517
        model.addAttribute("customer", customer);
518
        model.addAttribute("customerAddress", customerAddress);
519
        model.addAttribute("paymentOptionTransactions", paymentOptionTransactions);
520
        model.addAttribute("paymentOptionIdPaymentOptionMap", paymentOptionIdPaymentOptionMap);
521
        model.addAttribute("paymentOptionIdPaymentOptionTransactionMap", paymentOptionIdPaymentOptionTransactionMap);
522
        model.addAttribute("insurancePolicies", insurancePolicies);
523
        model.addAttribute("fofoPartnerPaymentOptions", fofoPartnerPaymentOptions);
524
        model.addAttribute("totalNumberOfPaymentOptionId", fofoPartnerPaymentOptions.size());
525
        model.addAttribute("stateNames",
526
                stateRepository.selectAll().stream().map(x -> x.getName()).collect(Collectors.toList()));
527
        return "search-order-details";
528
    }
28420 tejbeer 529
 
33213 tejus.loha 530
    private Map<Integer, PaymentOption> paymentOptionIdPaymentOptionMap(
33247 ranu 531
            List<PaymentOptionTransaction> paymentOptionTransactions) throws ProfitMandiBusinessException {
33213 tejus.loha 532
        Set<Integer> paymentOptionIds = new HashSet<>();
533
        for (PaymentOptionTransaction paymentOptionTransaction : paymentOptionTransactions) {
534
            paymentOptionIds.add(paymentOptionTransaction.getPaymentOptionId());
535
        }
536
        List<PaymentOption> paymentOptions = paymentOptionRepository.selectByIds(paymentOptionIds);
537
        Map<Integer, PaymentOption> paymentOptionIdPaymentOptionMap = new HashMap<>();
538
        for (PaymentOption paymentOption : paymentOptions) {
539
            paymentOptionIdPaymentOptionMap.put(paymentOption.getId(), paymentOption);
540
        }
541
        return paymentOptionIdPaymentOptionMap;
542
    }
23973 govind 543
 
33213 tejus.loha 544
    private Map<Integer, PaymentOption> paymentOptionIdPaymentOptionMapUsingPaymentOptions(
33247 ranu 545
            List<Integer> fofoPartnerPaymentOptions) throws ProfitMandiBusinessException {
33213 tejus.loha 546
        List<PaymentOption> paymentOptions = paymentOptionRepository
547
                .selectByIds(new HashSet<>(fofoPartnerPaymentOptions));
548
        Map<Integer, PaymentOption> paymentOptionIdPaymentOptionMap = new HashMap<>();
549
        for (PaymentOption paymentOption : paymentOptions) {
550
            paymentOptionIdPaymentOptionMap.put(paymentOption.getId(), paymentOption);
551
        }
552
        return paymentOptionIdPaymentOptionMap;
553
    }
23973 govind 554
 
33213 tejus.loha 555
    private Map<Integer, PaymentOptionTransaction> paymentOptionIdPaymentOptionTransactionMap(
556
            List<PaymentOptionTransaction> paymentOptionTransactions) {
557
        Map<Integer, PaymentOptionTransaction> paymentOptionIdPaymentOptionTransactionMap = new HashMap<>();
558
        for (PaymentOptionTransaction paymentOptionTransaction : paymentOptionTransactions) {
559
            paymentOptionIdPaymentOptionTransactionMap.put(paymentOptionTransaction.getPaymentOptionId(),
560
                    paymentOptionTransaction);
561
        }
562
        return paymentOptionIdPaymentOptionTransactionMap;
563
    }
28339 tejbeer 564
 
33213 tejus.loha 565
    @RequestMapping(value = "/create-order", method = RequestMethod.POST)
566
    public String createOrder(HttpServletRequest request, @RequestBody CreateOrderRequest createOrderRequest,
567
                              Model model) throws ProfitMandiBusinessException {
568
        // throw new ProfitMandiBusinessException("Billing is on hold temporarily",
569
        // "Billing is on hold temporarily", "Billing is on hold temporarily");
570
        LOGGER.info("request at uri {} body {}", request.getRequestURI(), createOrderRequest);
571
        LoginDetails fofoDetails = cookiesProcessor.getCookiesObject(request);
28339 tejbeer 572
 
33213 tejus.loha 573
        int fofoOrderId = orderService.createOrder(createOrderRequest, fofoDetails.getFofoId(), accessoriesDeals);
28339 tejbeer 574
 
33213 tejus.loha 575
        LOGGER.info("Order has been created successfully...");
576
        try {
577
            this.sendWhatsappInvoice(fofoOrderRepository.selectByOrderId(fofoOrderId));
578
        } catch (Exception e) {
579
            LOGGER.info("Could not send whatsapp message");
580
            e.printStackTrace();
581
        }
582
        return "redirect:/get-order/?orderId=" + fofoOrderId;
583
    }
28339 tejbeer 584
 
33213 tejus.loha 585
    private void sendWhatsappInvoice(FofoOrder fofoOrder) throws Exception {
586
        Customer customer = customerRepository.selectById(fofoOrder.getCustomerId());
587
        CustomRetailer retailer = retailerService.getFofoRetailer(fofoOrder.getFofoId());
588
        String message = String.format("Dear %s,\n" +
589
                "Thank you for your purchase from SmartDukaan store - %s, %s.\n" +
590
                "Your purchase invoice is attached for your reference.\n" +
591
                "\n" +
592
                "Download our app for offers and updates on new products.\n" +
593
                "https://www.smartdukaan.com/b2c\n" +
594
                "\n" +
595
                "Best Regards\n" +
596
                "SmartDukaan", customer.getFirstName(), retailer.getBusinessName(), retailer.getAddress().getCity());
597
        boolean sentMessage = notificationService.isWhatMessageSend(customer.getMobileNumber());
598
        if (sentMessage) {
599
            notificationService.sendWhatsappMediaMessage(message, customer.getMobileNumber(), this.getPublicInvoiceUrl(fofoOrder.getInvoiceNumber()),
600
                    this.getFileName(fofoOrder.getInvoiceNumber()), WhatsappMessageType.DOCUMENT);
601
        }
602
    }
28339 tejbeer 603
 
33213 tejus.loha 604
    private String getFileName(String invoiceNumber) {
605
        return "INV-" + invoiceNumber.replace("/", "-") + ".pdf";
606
    }
31375 tejbeer 607
 
33213 tejus.loha 608
    private String getPublicInvoiceUrl(String invoiceNumber) {
609
        String base64Encoded = Base64.getMimeEncoder().encodeToString(invoiceNumber.getBytes(StandardCharsets.UTF_8));
610
        String publicUrl = "https://partners.smartdukaan.com/wa-invoice-send/" + base64Encoded + ".pdf";
611
        LOGGER.info("Public Whatsapp Url for Invoice Message - {}", publicUrl);
612
        return publicUrl;
613
    }
28339 tejbeer 614
 
33213 tejus.loha 615
    @RequestMapping(value = "/order/bad_return", method = RequestMethod.POST)
616
    public ResponseEntity<?> badReturn(HttpServletRequest request, @RequestBody FoiBadReturnRequest foiBadReturnRequest,
617
                                       Model model) throws ProfitMandiBusinessException {
618
        LOGGER.info("request at uri {} body {}", request.getRequestURI(), foiBadReturnRequest);
619
        LoginDetails fofoDetails = cookiesProcessor.getCookiesObject(request);
620
        CustomerCreditNote custmoerCreditNote;
621
        if (roleManager.isAdmin(fofoDetails.getRoleIds())) {
622
            FofoOrderItem foi = fofoOrderItemRepository.selectById(foiBadReturnRequest.getFofoOrderItemId());
623
            FofoOrder fo = fofoOrderRepository.selectByOrderId(foi.getOrderId());
624
            custmoerCreditNote = orderService.badReturn(fo.getFofoId(), foiBadReturnRequest);
625
        } else {
626
            custmoerCreditNote = orderService.badReturn(fofoDetails.getFofoId(), foiBadReturnRequest);
627
        }
628
        return responseSender.ok(custmoerCreditNote.getId());
629
    }
28339 tejbeer 630
 
33213 tejus.loha 631
    @GetMapping(value = "/wa-invoice-send/{invoiceHash}")
632
    public ResponseEntity<?> generateInvoice(@PathVariable String invoiceHash) throws ProfitMandiBusinessException {
633
        String decodedInvoiceNumber = new String(Base64.getMimeDecoder().decode(invoiceHash));
634
        LOGGER.info("Invoice Hash {}", invoiceHash);
28339 tejbeer 635
 
23973 govind 636
 
33213 tejus.loha 637
        FofoOrder fofoOrder = fofoOrderRepository.selectByInvoiceNumber(decodedInvoiceNumber);
24844 amit.gupta 638
 
33213 tejus.loha 639
        InvoicePdfModel pdfModel = orderService.getInvoicePdfModel(fofoOrder.getId());
24844 amit.gupta 640
 
33213 tejus.loha 641
        ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
642
        PdfUtils.generateAndWrite(Arrays.asList(pdfModel), byteArrayOutputStream);
643
        final HttpHeaders headers = new HttpHeaders();
644
        //headers.setContentDispositionFormData("inline", number + ".pdf");
645
        headers.add(HttpHeaders.CONTENT_DISPOSITION, "inline;filename=" + pdfModel.getInvoiceNumber() + ".pdf");
646
        int contentLength = byteArrayOutputStream.toByteArray().length;
647
        final InputStream inputStream = new ByteArrayInputStream(byteArrayOutputStream.toByteArray());
648
        final InputStreamResource inputStreamResource = new InputStreamResource(inputStream);
649
        return ResponseEntity.ok()
650
                .headers(headers)
651
                .contentLength(contentLength)
652
                .contentType(MediaType.parseMediaType("application/pdf"))
653
                .body(inputStreamResource);
654
    }
23973 govind 655
 
33213 tejus.loha 656
    @RequestMapping(value = "/wa-listen", method = RequestMethod.POST)
657
    public ResponseEntity<?> listenWhatsappStatus(@RequestBody String whatsappJsonResponse) {
658
        LOGGER.info("whatsappJsonResponse {}", whatsappJsonResponse);
659
        //jaihind
660
        //  String jsonString = "[{\"srcAddr\":\"TESTSM\",\"channel\":\"WHATSAPP\",\"externalId\":\"4977024756456780043-180044363908187691\",\"cause\":\"SUCCESS\",\"errorCode\":\"000\",\"destAddr\":\"919813272029\",\"eventType\":\"DELIVERED\",\"eventTs\":1692848106000}]";
661
        JSONArray jsonArray = new JSONArray(whatsappJsonResponse);
662
        for (int i = 0; i < jsonArray.length(); i++) {
32711 amit.gupta 663
 
33213 tejus.loha 664
            JSONObject jsonObject = jsonArray.getJSONObject(i);
665
            String externalId = jsonObject.getString("externalId");
666
            String destAddr = jsonObject.getString("destAddr");
667
            String eventType = jsonObject.getString("eventType");
668
            whatsappMessageService.setWhatsappResponse(externalId, destAddr, eventType);
669
        }
670
        //jaihind
671
        return responseSender.ok("Success");
32711 amit.gupta 672
 
33213 tejus.loha 673
    }
32271 amit.gupta 674
 
33213 tejus.loha 675
    @RequestMapping(value = "/generateInvoice")
676
    public ResponseEntity<?> generateInvoice(HttpServletRequest request, HttpServletResponse response,
677
                                             @RequestParam(name = ProfitMandiConstants.ORDER_ID) int orderId) throws ProfitMandiBusinessException {
678
        LOGGER.info("Request received at url {} with params [{}={}] ", request.getRequestURI(),
679
                ProfitMandiConstants.ORDER_ID, orderId);
680
        LoginDetails fofoDetails = cookiesProcessor.getCookiesObject(request);
681
        InvoicePdfModel pdfModel = null;
682
        if (roleManager.isAdmin(fofoDetails.getRoleIds())) {
683
            pdfModel = orderService.getInvoicePdfModel(orderId);
684
        } else {
685
            pdfModel = orderService.getInvoicePdfModel(fofoDetails.getFofoId(), orderId);
686
        }
687
        ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
688
        PdfUtils.generateAndWrite(Arrays.asList(pdfModel), byteArrayOutputStream);
689
        LOGGER.info("Pdf Stream length {}", byteArrayOutputStream.toByteArray().length);
690
        final HttpHeaders headers = new HttpHeaders();
691
        headers.setContentType(MediaType.APPLICATION_PDF);
692
        headers.setContentDispositionFormData("inline", "invoice-" + pdfModel.getInvoiceNumber() + ".pdf");
693
        headers.setContentLength(byteArrayOutputStream.toByteArray().length);
694
        final InputStream inputStream = new ByteArrayInputStream(byteArrayOutputStream.toByteArray());
695
        final InputStreamResource inputStreamResource = new InputStreamResource(inputStream);
696
        return new ResponseEntity<>(inputStreamResource, headers, HttpStatus.OK);
697
    }
24087 amit.gupta 698
 
33213 tejus.loha 699
    @RequestMapping(value = "/generateInvoices")
700
    public ResponseEntity<?> generateInvoice(HttpServletRequest request, HttpServletResponse response,
701
                                             @RequestParam LocalDateTime startDate, @RequestParam LocalDateTime endDate, @RequestParam int partnerId)
702
            throws ProfitMandiBusinessException {
703
        LoginDetails fofoDetails = cookiesProcessor.getCookiesObject(request);
704
        List<InvoicePdfModel> pdfModels = new ArrayList<>();
705
        if (roleManager.isAdmin(fofoDetails.getRoleIds())) {
706
            List<Integer> orderIds = fofoOrderRepository.selectByFofoId(partnerId, startDate, endDate, 0, 0).stream()
707
                    .map(x -> x.getId()).collect(Collectors.toList());
708
            for (int orderId : orderIds) {
709
                pdfModels.add(orderService.getInvoicePdfModel(orderId));
710
            }
711
            ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
712
            PdfUtils.generateAndWrite(pdfModels, byteArrayOutputStream);
713
            LOGGER.info("Pdf Stream length {}", byteArrayOutputStream.toByteArray().length);
714
            final HttpHeaders headers = new HttpHeaders();
715
            headers.setContentType(MediaType.APPLICATION_PDF);
716
            headers.set("Content-disposition", "inline; filename=invoice-" + partnerId + ".pdf");
717
            headers.setContentLength(byteArrayOutputStream.toByteArray().length);
718
            final InputStream inputStream = new ByteArrayInputStream(byteArrayOutputStream.toByteArray());
719
            final InputStreamResource inputStreamResource = new InputStreamResource(inputStream);
720
            return new ResponseEntity<InputStreamResource>(inputStreamResource, headers, HttpStatus.OK);
721
        } else {
722
            throw new ProfitMandiBusinessException("Auth", fofoDetails.getEmailId(), "Unauthorised access");
723
        }
724
    }
23973 govind 725
 
33213 tejus.loha 726
    @RequestMapping(value = "/saleHistory")
727
    public String saleHistory(HttpServletRequest request,
728
                              @RequestParam(name = "searchValue", defaultValue = "") String searchValue,
729
                              @RequestParam(name = "searchType", defaultValue = "") SearchType searchType,
730
                              @RequestParam(required = false) LocalDateTime startTime,
731
                              @RequestParam(required = false) LocalDateTime endTime,
732
                              @RequestParam(name = "offset", defaultValue = "0") int offset,
733
                              @RequestParam(name = "limit", defaultValue = "10") int limit, Model model)
734
            throws ProfitMandiBusinessException {
735
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
32405 jai.hind 736
 
33213 tejus.loha 737
        Map<String, Object> map = orderService.getSaleHistory(loginDetails.getFofoId(), searchType, searchValue,
738
                startTime, endTime, offset, limit);
739
        model.addAllAttributes(map);
740
        return "sale-history";
741
    }
32405 jai.hind 742
 
33213 tejus.loha 743
    @RequestMapping(value = "/downloadInvoices")
744
    public ResponseEntity<?> downloadInvoices(HttpServletRequest request,
745
                                              @RequestParam(name = "searchValue", defaultValue = "") String searchValue,
746
                                              @RequestParam(name = "searchType", defaultValue = "") SearchType searchType,
747
                                              @RequestParam(required = false) LocalDateTime startTime,
748
                                              @RequestParam(required = false) LocalDateTime endTime,
749
                                              @RequestParam(name = "offset", defaultValue = "0") int offset,
750
                                              @RequestParam(name = "limit", defaultValue = "10") int limit, Model model)
751
            throws ProfitMandiBusinessException {
752
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
32409 amit.gupta 753
 
33213 tejus.loha 754
        Map<String, Object> map = orderService.getSaleHistory(loginDetails.getFofoId(), searchType, searchValue,
755
                startTime, endTime, offset, 100);
756
        List<FofoOrder> fofoOrders = (List<FofoOrder>) map.get("saleHistories");
23973 govind 757
 
33213 tejus.loha 758
        if (fofoOrders.size() == 0) {
759
            throw new ProfitMandiBusinessException("Search criteria", "", "No orders found for criteria");
760
        }
23654 amit.gupta 761
 
33213 tejus.loha 762
        final HttpHeaders headers = new HttpHeaders();
763
        headers.setContentType(MediaType.APPLICATION_PDF);
764
        headers.set("Content-disposition", "inline; filename=invoices.pdf");
765
        ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
766
        List<InvoicePdfModel> pdfModels = new ArrayList<>();
767
        for (FofoOrder fofoOrder : fofoOrders) {
768
            try {
769
                pdfModels.add(orderService.getInvoicePdfModel(fofoOrder.getId()));
770
            } catch (Exception e) {
771
                LOGGER.info("could not create invoice for {}, invoice number {}", fofoOrder.getId(),
772
                        fofoOrder.getInvoiceNumber());
773
            }
774
        }
775
        PdfUtils.generateAndWrite(pdfModels, byteArrayOutputStream);
776
        headers.setContentLength(byteArrayOutputStream.toByteArray().length);
777
        final InputStream inputStream = new ByteArrayInputStream(byteArrayOutputStream.toByteArray());
778
        final InputStreamResource inputStreamResource = new InputStreamResource(inputStream);
779
        return new ResponseEntity<InputStreamResource>(inputStreamResource, headers, HttpStatus.OK);
780
    }
23654 amit.gupta 781
 
33213 tejus.loha 782
    @RequestMapping(value = "/credit-note/{creditNoteId}")
783
    public ResponseEntity<?> downloadCreditNote(HttpServletRequest request, @PathVariable int creditNoteId)
784
            throws ProfitMandiBusinessException {
785
        CreditNotePdfModel creditNotePdfModel = orderService.getCreditNotePdfModel(creditNoteId);
786
        ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
787
        PdfUtils.generateAndWriteCustomerCreditNotes(Arrays.asList(creditNotePdfModel), byteArrayOutputStream);
788
        LOGGER.info("Pdf Stream length {}", byteArrayOutputStream.toByteArray().length);
789
        final HttpHeaders headers = new HttpHeaders();
790
        headers.setContentType(MediaType.APPLICATION_PDF);
791
        headers.set("Content-disposition",
792
                "inline; filename=invoice-" + creditNotePdfModel.getCreditNoteNumber() + ".pdf");
793
        headers.setContentLength(byteArrayOutputStream.toByteArray().length);
794
        final InputStream inputStream = new ByteArrayInputStream(byteArrayOutputStream.toByteArray());
795
        final InputStreamResource inputStreamResource = new InputStreamResource(inputStream);
796
        return new ResponseEntity<InputStreamResource>(inputStreamResource, headers, HttpStatus.OK);
797
    }
23973 govind 798
 
33213 tejus.loha 799
    @RequestMapping(value = "/getPaginatedSaleHistory")
800
    public String getSaleHistoryPaginated(HttpServletRequest request,
801
                                          @RequestParam(name = "searchValue", defaultValue = "") String searchValue,
802
                                          @RequestParam(name = "searchType", defaultValue = "") SearchType searchType,
803
                                          @RequestParam(required = false) LocalDateTime startTime,
804
                                          @RequestParam(required = false) LocalDateTime endTime,
805
                                          @RequestParam(name = "offset", defaultValue = "0") int offset,
806
                                          @RequestParam(name = "limit", defaultValue = "10") int limit, Model model)
807
            throws ProfitMandiBusinessException {
808
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
809
        Map<String, Object> map = orderService.getSaleHistoryPaginated(loginDetails.getFofoId(), searchType,
810
                searchValue, startTime, endTime, offset, limit);
811
        model.addAllAttributes(map);
812
        return "sale-history-paginated";
813
    }
23973 govind 814
 
33213 tejus.loha 815
    @PutMapping(value = "/updatePaymentTransaction")
816
    public String updateTransactionDetails(HttpServletRequest request, @RequestParam String referenceType,
817
                                           @RequestParam int fofoId, @RequestParam int referenceId,
818
                                           @RequestBody PartnerOptionsAndItemAmountModel partnerOptionsAndItemAmountModel,
819
                                           @RequestParam float totalAmount, Model model) throws Exception {
29707 tejbeer 820
 
33213 tejus.loha 821
        List<PaymentOptionTransactionModel> paymentOptionTransactionModels = partnerOptionsAndItemAmountModel
822
                .getPaymentOptionTransactionModel();
823
        LOGGER.info(paymentOptionTransactionModels);
824
        FofoOrder fofoOrder = fofoOrderRepository.selectByFofoIdAndOrderId(fofoId, referenceId);
825
        LOGGER.info("sdssd" + fofoOrder);
826
        fofoOrder.setTotalAmount(totalAmount);
827
        List<FofoItemIdAmountModel> fofoItemIdAmountModel = partnerOptionsAndItemAmountModel.getItemAmountModel();
828
        for (FofoItemIdAmountModel fim : fofoItemIdAmountModel) {
829
            LOGGER.info("fim" + fim.getFofoItemId());
23973 govind 830
 
33213 tejus.loha 831
            LOGGER.info("fimAmount" + fim.getAmount());
832
            Item item = itemRepository.selectById(fim.getItemId());
833
            TagListing tagListing = tagListingRepository.selectByItemId(item.getId());
834
            FofoOrderItem fofoOrderItem = fofoOrderItemRepository.selectById(fim.getFofoItemId());
835
            LOGGER.info("category" + item.getCategoryId());
836
            if (item.getCategoryId() == ProfitMandiConstants.MOBILE_CATEGORY_ID) {
837
                if (fofoOrderItem.getMop() <= fim.getAmount()) {
23973 govind 838
 
33213 tejus.loha 839
                    if (fim.getAmount() <= tagListing.getMrp()) {
840
                        fofoOrderItem.setSellingPrice(fim.getAmount());
841
                    } else {
842
                        throw new ProfitMandiBusinessException("Amount", fim.getAmount(),
843
                                "Sum of amount is not less than  to MRP");
844
                    }
23973 govind 845
 
33213 tejus.loha 846
                    LOGGER.info("fofoOrderItem2" + fofoOrderItem);
23973 govind 847
 
33213 tejus.loha 848
                } else {
849
                    // TODO below mop condition need to added added
850
                    fofoOrderItem.setSellingPrice(fim.getAmount());
851
                }
23973 govind 852
 
33213 tejus.loha 853
            } else {
854
                fofoOrderItem.setSellingPrice(fim.getAmount());
855
                LOGGER.info("fofoOrderItem1" + fofoOrderItem);
27819 tejbeer 856
 
33213 tejus.loha 857
            }
858
            LOGGER.info("fofoOrderItem" + fofoOrderItem);
23973 govind 859
 
33213 tejus.loha 860
        }
23973 govind 861
 
33213 tejus.loha 862
        /*
863
         * for (PaymentOptionTransactionModel paymentOptionTransactionModel :
864
         * paymentOptionTransactionModels) { amount = amount +
865
         * paymentOptionTransactionModel.getAmount(); } LOGGER.info("FofoOrder amount" +
866
         * fofoOrder.getUnitPrice() + "amount" + amount); if (amount ==
867
         * fofoOrder.getUnitPrice()) {
868
         */
869
        if (paymentOptionTransactionModels.size() > 0) {
870
            List<PaymentOptionTransaction> paymentOptionTransactions = paymentOptionTransactionRepository
871
                    .selectByReferenceIdAndType(referenceId, PaymentOptionReferenceType.ORDER);
872
            Map<Integer, PaymentOptionTransaction> paymentOptionIdPaymentOptionTransactionMap = this
873
                    .paymentOptionIdPaymentOptionTransactionMap(paymentOptionTransactions);
874
            LOGGER.info(
875
                    "paymentOptionIdPaymentOptionTransactionMap" + paymentOptionIdPaymentOptionTransactionMap.keySet());
876
            for (PaymentOptionTransactionModel paymentOptionTransactionModel : paymentOptionTransactionModels) {
877
                if (paymentOptionIdPaymentOptionTransactionMap
878
                        .containsKey(paymentOptionTransactionModel.getPaymentOptionId())) {
23973 govind 879
 
33213 tejus.loha 880
                    PaymentOptionTransaction paymentOptionTransaction = paymentOptionIdPaymentOptionTransactionMap
881
                            .get(paymentOptionTransactionModel.getPaymentOptionId());
31739 amit.gupta 882
 
33213 tejus.loha 883
                    if (paymentOptionTransactionModel.getAmount() == 0) {
884
                        paymentOptionTransactionRepository.delete(paymentOptionTransaction);
885
                        LOGGER.info("deleted successfully");
886
                    } else {
24844 amit.gupta 887
 
33213 tejus.loha 888
                        paymentOptionTransaction.setAmount(paymentOptionTransactionModel.getAmount());
889
                        paymentOptionTransactionRepository.persist(paymentOptionTransaction);
890
                        LOGGER.info("updated successfully");
24281 amit.gupta 891
 
33213 tejus.loha 892
                    }
893
                } else {
894
                    if (paymentOptionTransactionModel.getAmount() > 0) {
895
                        PaymentOptionTransaction paymentOptionTransaction = new PaymentOptionTransaction();
896
                        paymentOptionTransaction.setReferenceId(referenceId);
897
                        paymentOptionTransaction.setReferenceType(PaymentOptionReferenceType.ORDER);
898
                        paymentOptionTransaction.setPaymentOptionId(paymentOptionTransactionModel.getPaymentOptionId());
899
                        paymentOptionTransaction.setAmount(paymentOptionTransactionModel.getAmount());
900
                        paymentOptionTransaction.setFofoId(fofoId);
901
                        paymentOptionTransaction.setCreateTimestamp(fofoOrder.getCreateTimestamp());
902
                        paymentOptionTransactionRepository.persist(paymentOptionTransaction);
903
                        LOGGER.info("inserted successfully");
904
                    }
905
                }
24281 amit.gupta 906
 
33213 tejus.loha 907
            }
24281 amit.gupta 908
 
33213 tejus.loha 909
            model.addAttribute("response1", mvcResponseSender.createResponseString(true));
910
        }
911
        /*
912
         * else
913
         *
914
         * { throw new ProfitMandiBusinessException("Amount", amount,
915
         * "Sum of amount is not equal to total amount"); }
916
         */
23973 govind 917
 
33213 tejus.loha 918
        return "response";
23973 govind 919
 
33213 tejus.loha 920
    }
24105 govind 921
 
33213 tejus.loha 922
    private Map<String, List<MobileInsurancePlan>> getPlans(float sellingPrice, int itemId)
923
            throws ProfitMandiBusinessException {
924
        try {
925
            Map<String, List<MobileInsurancePlan>> productDurationPlans = insuranceService.getAllPlans(itemId,
926
                    sellingPrice);
927
            return productDurationPlans;
928
        } catch (Exception e) {
929
            LOGGER.info(e, e);
930
            throw new ProfitMandiBusinessException("Fetch Insurance Plans", "Insurance",
931
                    "Could not fetch insurance Plans");
932
        }
24105 govind 933
 
33213 tejus.loha 934
    }
23973 govind 935
 
33213 tejus.loha 936
    @GetMapping("/insuranceDetails")
937
    public String getInsuranceDetails(HttpServletRequest request,
938
                                      @RequestParam(name = "offset", defaultValue = "0") int offset,
939
                                      @RequestParam(name = "limit", defaultValue = "10") int limit, Model model)
940
            throws ProfitMandiBusinessException {
941
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
942
        long size = 0;
943
        List<InsurancePolicy> insurancePolicies = insurancePolicyRepository.selectByRetailerId(loginDetails.getFofoId(),
944
                offset, limit);
945
        size = insurancePolicyRepository.selectCountByRetailerId(loginDetails.getFofoId());
946
        Map<Integer, String> providerPolicyNameAndIdMap = insuranceProviderRepository
947
                .selectByIds(insurancePolicies.stream().map(x -> x.getProviderId()).collect(Collectors.toSet()))
948
                .stream().collect(Collectors.toMap(InsuranceProvider::getId, InsuranceProvider::getName));
949
        if (size < limit) {
950
            model.addAttribute("end", offset + size);
951
        } else {
952
            model.addAttribute("end", offset + limit);
953
        }
954
        model.addAttribute("start", offset + 1);
955
        model.addAttribute("size", size);
956
        model.addAttribute("insurancePolicies", insurancePolicies);
957
        model.addAttribute("providerPolicyNameAndIdMap", providerPolicyNameAndIdMap);
958
        return "insurance-details";
959
    }
28339 tejbeer 960
 
33213 tejus.loha 961
    @GetMapping("/insuranceDetailsPaginated")
962
    public String getInsuranceDetailsPaginated(HttpServletRequest request,
963
                                               @RequestParam(name = "offset", defaultValue = "0") int offset,
964
                                               @RequestParam(name = "limit", defaultValue = "10") int limit, Model model)
965
            throws ProfitMandiBusinessException {
966
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
967
        List<InsurancePolicy> insurancePolicies = insurancePolicyRepository.selectByRetailerId(loginDetails.getFofoId(),
968
                offset, limit);
969
        Map<Integer, String> providerPolicyNameAndIdMap = insuranceProviderRepository
970
                .selectByIds(insurancePolicies.stream().map(x -> x.getProviderId()).collect(Collectors.toSet()))
971
                .stream().collect(Collectors.toMap(InsuranceProvider::getId, InsuranceProvider::getName));
972
        model.addAttribute("insurancePolicies", insurancePolicies);
973
        model.addAttribute("providerPolicyNameAndIdMap", providerPolicyNameAndIdMap);
974
        return "insurance-details-paginated";
975
    }
23973 govind 976
 
33213 tejus.loha 977
    @GetMapping("/getMouForm")
978
    public String getMouForm(HttpServletRequest request, Model model) throws Exception {
979
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
21985 kshitij.so 980
 
33213 tejus.loha 981
        Mou mou = mouRepository.selectByFofoId(loginDetails.getFofoId());
982
        if (mou != null) {
983
            if (mou.getUpdateTimestamp().getMonth().equals(LocalDateTime.now().getMonth())) {
984
                model.addAttribute("response1", mvcResponseSender.createResponseString(true));
985
            } else {
986
                model.addAttribute("response1", mvcResponseSender.createResponseString(false));
987
            }
32238 amit.gupta 988
 
33213 tejus.loha 989
        } else {
990
            model.addAttribute("response1", mvcResponseSender.createResponseString(false));
32238 amit.gupta 991
 
33213 tejus.loha 992
        }
993
        return "response";
32238 amit.gupta 994
 
33213 tejus.loha 995
    }
23973 govind 996
 
33213 tejus.loha 997
    @GetMapping("/pendingOrders")
998
    public String getPendingOrders(HttpServletRequest request, Model model) throws ProfitMandiBusinessException {
999
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1000
        boolean isAdmin = roleManager.isAdmin(loginDetails.getRoleIds());
1001
        Mou mou = mouRepository.selectByFofoId(loginDetails.getFofoId());
1002
        if (mou == null) {
1003
            mou = new Mou();
1004
            mou.setFofoId(loginDetails.getFofoId());
1005
            mou.setCreateTimestamp(LocalDateTime.now());
1006
            mou.setUpdateTimestamp(LocalDateTime.now());
1007
            mouRepository.persist(mou);
1008
        } else if (!mou.getUpdateTimestamp().getMonth().equals(LocalDateTime.now().getMonth())) {
1009
            mou.setUpdateTimestamp(LocalDateTime.now());
1010
        }
24844 amit.gupta 1011
 
33213 tejus.loha 1012
        List<PendingOrderItem> pendingOrderItems = pendingOrderItemRepository.selectOrderItemByStatusAndFofoId(OrderStatus.PROCESSING,
1013
                loginDetails.getFofoId());
23973 govind 1014
 
33213 tejus.loha 1015
        Map<String, Object> map = pendingOrderService.getItemOrders(pendingOrderItems, loginDetails.getFofoId());
1016
        model.addAttribute("inventoryMap", map.get("inventoryMap"));
1017
        model.addAttribute("pendingOrderItems", (List<PendingOrderItem>) map.get("pendingOrderItems"));
23973 govind 1018
 
33213 tejus.loha 1019
        model.addAttribute("isAdmin", isAdmin);
1020
        return "pending_fofo_order";
25092 amit.gupta 1021
 
33213 tejus.loha 1022
    }
25092 amit.gupta 1023
 
33213 tejus.loha 1024
    @GetMapping("/billedOrders")
1025
    public String getBilledOrders(HttpServletRequest request, Model model) throws ProfitMandiBusinessException {
1026
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1027
        boolean isAdmin = roleManager.isAdmin(loginDetails.getRoleIds());
25092 amit.gupta 1028
 
33213 tejus.loha 1029
        List<PendingOrderItem> pendingOrderItem;
23973 govind 1030
 
33213 tejus.loha 1031
        if (isAdmin) {
27861 tejbeer 1032
 
33213 tejus.loha 1033
            pendingOrderItem = pendingOrderItemRepository.selectOrderItemByStatus(OrderStatus.BILLED);
27861 tejbeer 1034
 
33213 tejus.loha 1035
        } else {
1036
            pendingOrderItem = pendingOrderItemRepository.selectOrderItemByStatusAndFofoId(OrderStatus.BILLED,
1037
                    loginDetails.getFofoId());
1038
        }
27861 tejbeer 1039
 
33213 tejus.loha 1040
        Map<String, Object> map = pendingOrderService.getItemOrders(pendingOrderItem, loginDetails.getFofoId());
27861 tejbeer 1041
 
33213 tejus.loha 1042
        model.addAttribute("pendingOrderItem", map.get("pendingOrderItem"));
1043
        model.addAttribute("isAdmin", isAdmin);
1044
        return "billed_order_item";
1045
    }
27861 tejbeer 1046
 
33213 tejus.loha 1047
    @GetMapping("/settledOrders")
1048
    public String getSettledOrders(HttpServletRequest request, Model model) throws ProfitMandiBusinessException {
1049
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1050
        boolean isAdmin = roleManager.isAdmin(loginDetails.getRoleIds());
27861 tejbeer 1051
 
33213 tejus.loha 1052
        List<PendingOrderItem> pendingOrderItem = null;
27861 tejbeer 1053
 
33213 tejus.loha 1054
        if (isAdmin) {
24105 govind 1055
 
33213 tejus.loha 1056
            pendingOrderItem = pendingOrderItemRepository.selectOrderItemByStatus(OrderStatus.SETTLED);
24105 govind 1057
 
33213 tejus.loha 1058
        } else {
1059
            pendingOrderItem = pendingOrderItemRepository.selectOrderItemByStatusAndFofoId(OrderStatus.SETTLED,
1060
                    loginDetails.getFofoId());
1061
        }
24105 govind 1062
 
33213 tejus.loha 1063
        Map<String, Object> map = pendingOrderService.getItemOrders(pendingOrderItem, loginDetails.getFofoId());
24105 govind 1064
 
33213 tejus.loha 1065
        model.addAttribute("pendingOrderItem", map.get("pendingOrderItem"));
1066
        model.addAttribute("isAdmin", isAdmin);
1067
        return "settled_order_item";
1068
    }
27861 tejbeer 1069
 
33213 tejus.loha 1070
    @GetMapping("/unsettledOrders")
1071
    public String getunsettledOrders(HttpServletRequest request, Model model) throws ProfitMandiBusinessException {
1072
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1073
        boolean isAdmin = roleManager.isAdmin(loginDetails.getRoleIds());
24105 govind 1074
 
33213 tejus.loha 1075
        List<PendingOrderItem> pendingOrderItem = null;
27861 tejbeer 1076
 
33213 tejus.loha 1077
        if (isAdmin) {
24105 govind 1078
 
33213 tejus.loha 1079
            pendingOrderItem = pendingOrderItemRepository.selectOrderItemByStatus(OrderStatus.UNSETTLED);
27861 tejbeer 1080
 
33213 tejus.loha 1081
        } else {
1082
            pendingOrderItem = pendingOrderItemRepository.selectOrderItemByStatusAndFofoId(OrderStatus.UNSETTLED,
1083
                    loginDetails.getFofoId());
1084
        }
24440 amit.gupta 1085
 
33213 tejus.loha 1086
        Map<String, Object> map = pendingOrderService.getItemOrders(pendingOrderItem, loginDetails.getFofoId());
25726 amit.gupta 1087
 
33213 tejus.loha 1088
        model.addAttribute("pendingOrderItem", map.get("pendingOrderItem"));
1089
        model.addAttribute("isAdmin", isAdmin);
1090
        return "unsettled_order_item";
1091
    }
24880 govind 1092
 
33213 tejus.loha 1093
    @GetMapping("/claimedOrders")
1094
    public String getclaimedOrders(HttpServletRequest request, Model model) throws ProfitMandiBusinessException {
1095
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1096
        boolean isAdmin = roleManager.isAdmin(loginDetails.getRoleIds());
1097
        List<Integer> fofoIds = fofoStoreRepository.selectActiveStores().stream().map(x -> x.getId())
1098
                .collect(Collectors.toList());
25092 amit.gupta 1099
 
33213 tejus.loha 1100
        List<PendingOrderItem> pendingOrderItem = null;
26647 tejbeer 1101
 
33213 tejus.loha 1102
        if (isAdmin) {
28420 tejbeer 1103
 
33213 tejus.loha 1104
            pendingOrderItem = pendingOrderItemRepository.selectOrderItemByStatus(OrderStatus.CLAIMED);
1105
            Map<Integer, CustomRetailer> customRetailerMap = retailerService.getAllFofoRetailers();
28425 tejbeer 1106
 
33213 tejus.loha 1107
            Map<Integer, CustomRetailer> customRetailersMap = fofoIds.stream().map(x -> customRetailerMap.get(x))
1108
                    .filter(x -> x != null).collect(Collectors.toList()).stream()
1109
                    .collect(Collectors.toMap(x -> x.getPartnerId(), x -> x));
1110
            model.addAttribute("customRetailersMap", customRetailersMap);
28420 tejbeer 1111
 
33213 tejus.loha 1112
        } else {
1113
            pendingOrderItem = pendingOrderItemRepository.selectOrderItemByStatusAndFofoId(OrderStatus.CLAIMED,
1114
                    loginDetails.getFofoId());
1115
        }
28420 tejbeer 1116
 
33213 tejus.loha 1117
        Map<String, Object> map = pendingOrderService.getItemOrders(pendingOrderItem, loginDetails.getFofoId());
28420 tejbeer 1118
 
33213 tejus.loha 1119
        model.addAttribute("pendingOrderItem", map.get("pendingOrderItem"));
1120
        model.addAttribute("isAdmin", isAdmin);
1121
        return "claim_raised_order_item";
1122
    }
26647 tejbeer 1123
 
33213 tejus.loha 1124
    @GetMapping("/getPendingOrderItem")
1125
    public String getPendingOrderItem(HttpServletRequest request, @RequestParam int orderId, Model model)
1126
            throws ProfitMandiBusinessException {
1127
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1128
        Map<Integer, Item> itemMap = new HashMap<>();
1129
        Map<Integer, CurrentInventorySnapshot> inventoryMap = new HashMap<>();
1130
        PendingOrder pendingPO = pendingOrderRepository.selectById(orderId);
1131
        Customer customer = customerRepository.selectById(pendingPO.getCustomerId());
1132
        List<PendingOrderItem> pendingOrderItems = pendingOrderItemRepository.selectByOrderId(orderId);
1133
        for (PendingOrderItem pendingOrderItem : pendingOrderItems) {
1134
            Item item = itemRepository.selectById(pendingOrderItem.getItemId());
1135
            CurrentInventorySnapshot cis = currentInventorySnapshotRepository
1136
                    .selectByItemAndFofoId(pendingOrderItem.getItemId(), pendingPO.getFofoId());
1137
            itemMap.put(pendingOrderItem.getItemId(), item);
1138
            LOGGER.info("cis" + cis);
1139
            inventoryMap.put(pendingOrderItem.getItemId(), cis);
1140
        }
28339 tejbeer 1141
 
33213 tejus.loha 1142
        LOGGER.info("inventoryMap" + inventoryMap);
1143
        model.addAttribute("pendingOrderItems", pendingOrderItems);
1144
        model.addAttribute("itemMap", itemMap);
1145
        model.addAttribute("inventoryMap", inventoryMap);
1146
        model.addAttribute("pendingPO", gson.toJson(pendingPO));
1147
        model.addAttribute("pendingPOCustomer", gson.toJson(customer));
1148
        model.addAttribute("isAdmin", roleManager.isAdmin(loginDetails.getRoleIds()));
1149
        return "pending-order-item";
1150
    }
28339 tejbeer 1151
 
33213 tejus.loha 1152
    @RequestMapping(value = "/getPendingOrderItemById", method = RequestMethod.GET)
1153
    public String getPendingOrderItemById(HttpServletRequest request, @RequestParam int id, Model model)
1154
            throws Exception {
27046 tejbeer 1155
 
33213 tejus.loha 1156
        PendingOrderItem pendingOrderItem = pendingOrderItemRepository.selectById(id);
1157
        model.addAttribute("pendingOrderItem", pendingOrderItem);
1158
        return "cancel-pending-order";
1159
    }
27046 tejbeer 1160
 
33213 tejus.loha 1161
    @RequestMapping(value = "/getPendingOrderChangePartnerById", method = RequestMethod.GET)
33367 ranu 1162
    public String getPendingOrderChangePartnerById(HttpServletRequest request, @RequestParam int id, @RequestParam String pinCode, Model model)
33213 tejus.loha 1163
            throws Exception {
28350 tejbeer 1164
 
33213 tejus.loha 1165
        PendingOrder pendingOrder = pendingOrderRepository.selectById(id);
33374 ranu 1166
        Map<Integer, CustomRetailer> customRetailersMap = retailerService.getFofoRetailers(true);
33213 tejus.loha 1167
        model.addAttribute("customRetailersMap", customRetailersMap);
1168
        model.addAttribute("pendingOrder", pendingOrder);
1169
        return "change-partner-po";
1170
    }
28358 tejbeer 1171
 
33213 tejus.loha 1172
    @RequestMapping(value = "/changePendingOrderPartner", method = RequestMethod.POST)
1173
    public String changePendingOrderPartner(HttpServletRequest request, @RequestParam int id, @RequestParam int fofoId,
1174
                                            Model model) throws Exception {
28350 tejbeer 1175
 
33213 tejus.loha 1176
        PendingOrder pendingOrder = pendingOrderRepository.selectById(id);
1177
        pendingOrder.setFofoId(fofoId);
1178
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
28339 tejbeer 1179
 
33213 tejus.loha 1180
        return "response";
1181
    }
28339 tejbeer 1182
 
33213 tejus.loha 1183
    @RequestMapping(value = "/cancelPendingOrderItem", method = RequestMethod.POST)
1184
    public String cancelPendingOrderItem(HttpServletRequest request, @RequestParam int id, @RequestParam String reason,
1185
                                         Model model) throws Exception {
28339 tejbeer 1186
 
33213 tejus.loha 1187
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1188
        PendingOrderItem pendingOrderItem = pendingOrderItemRepository.selectById(id);
28339 tejbeer 1189
 
33213 tejus.loha 1190
        pendingOrderItem.setStatus(OrderStatus.CANCELLED);
1191
        pendingOrderItem.setStatusDescription(loginDetails.getEmailId());
1192
        pendingOrderItem.setRemark(reason);
1193
        pendingOrderItem.setCancelledTimestamp(LocalDateTime.now());
1194
        PendingOrder pendingOrder = pendingOrderRepository.selectById(pendingOrderItem.getOrderId());
27046 tejbeer 1195
 
33213 tejus.loha 1196
        List<OrderStatus> status = pendingOrderItemRepository.selectByOrderId(pendingOrderItem.getOrderId()).stream()
1197
                .map(x -> x.getStatus()).collect(Collectors.toList());
28339 tejbeer 1198
 
33213 tejus.loha 1199
        Customer customer = customerRepository.selectById(pendingOrder.getCustomerId());
26647 tejbeer 1200
 
33213 tejus.loha 1201
        List<Integer> catalogIds = new ArrayList<>();
28339 tejbeer 1202
 
33213 tejus.loha 1203
        Item item = itemRepository.selectById(pendingOrderItem.getItemId());
1204
        pendingOrderItem.setItemName(item.getItemDescription());
1205
        catalogIds.add(item.getCatalogItemId());
28339 tejbeer 1206
 
33213 tejus.loha 1207
        Map<Integer, JSONObject> contentMap = commonSolrService.getContentByCatalogIds(catalogIds);
1208
        JSONObject jsonObj = contentMap.get(item.getCatalogItemId());
1209
        pendingOrderItem.setImgUrl(jsonObj.getString("imageUrl_s"));
1210
        pendingOrder.setPendingOrderItems(Arrays.asList(pendingOrderItem));
1211
        CustomerAddress customerAddress = customerAddressRepository.selectById(pendingOrder.getCustomerAddressId());
28339 tejbeer 1212
 
33213 tejus.loha 1213
        DateTimeFormatter dateTimeFormatter = DateTimeFormatter.ofPattern("dd/MM/yyyy h:mm a");
28339 tejbeer 1214
 
33213 tejus.loha 1215
        Map<String, Object> emailModel = new HashMap<>();
1216
        emailModel.put("customer", customerAddress);
1217
        emailModel.put("pendingOrder", pendingOrder);
1218
        emailModel.put("date", dateTimeFormatter);
1219
        LOGGER.info("emal" + customer.getEmailId());
1220
        String[] customerEmail = null;
1221
        if (customer.getEmailId() != null && !customer.getEmailId().isEmpty()) {
1222
            customerEmail = new String[]{customer.getEmailId()};
28339 tejbeer 1223
 
33213 tejus.loha 1224
            List<String> bccTo = Arrays.asList("tejbeer.kaur@smartdukaan.com");
28339 tejbeer 1225
 
33213 tejus.loha 1226
            emailService.sendMailWithAttachments("Order Cancellation", "order-cancellation.vm", emailModel,
1227
                    customerEmail, null, bccTo.toArray(new String[0]));
28339 tejbeer 1228
 
33213 tejus.loha 1229
        }
28339 tejbeer 1230
 
33213 tejus.loha 1231
        if (!status.contains(OrderStatus.PENDING) && !status.contains(OrderStatus.PROCESSING)
1232
                && !status.contains(OrderStatus.BILLED) && !status.contains(OrderStatus.UNSETTLED)
1233
                && !status.contains(OrderStatus.CLAIMED)) {
1234
            pendingOrder.setStatus(OrderStatus.CLOSED);
1235
        }
1236
        pendingOrderItemRepository.persist(pendingOrderItem);
28339 tejbeer 1237
 
33213 tejus.loha 1238
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
28339 tejbeer 1239
 
33213 tejus.loha 1240
        return "response";
1241
    }
28339 tejbeer 1242
 
33213 tejus.loha 1243
    @RequestMapping(value = "/deliveredPendingOrderItem", method = RequestMethod.POST)
1244
    public String deliveredPendingOrderItem(HttpServletRequest request, @RequestParam int id, Model model)
1245
            throws Exception {
28339 tejbeer 1246
 
33213 tejus.loha 1247
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1248
        PendingOrderItem pendingOrderItem = pendingOrderItemRepository.selectById(id);
1249
        PendingOrder pendingOrder = pendingOrderRepository.selectById(pendingOrderItem.getOrderId());
28339 tejbeer 1250
 
33213 tejus.loha 1251
        if (pendingOrder.getTotalAmount() == pendingOrder.getPaidAmount()) {
1252
            pendingOrderItem.setStatus(OrderStatus.UNSETTLED);
1253
            pendingOrderItem.setDeliveredTimestamp(LocalDateTime.now());
28339 tejbeer 1254
 
33213 tejus.loha 1255
        } else {
1256
            pendingOrderItem.setStatus(OrderStatus.SETTLED);
1257
            pendingOrderItem.setDeliveredTimestamp(LocalDateTime.now());
28339 tejbeer 1258
 
33213 tejus.loha 1259
        }
28339 tejbeer 1260
 
33213 tejus.loha 1261
        List<OrderStatus> status = pendingOrderItemRepository.selectByOrderId(pendingOrderItem.getOrderId()).stream()
1262
                .map(x -> x.getStatus()).collect(Collectors.toList());
28339 tejbeer 1263
 
33213 tejus.loha 1264
        List<Integer> catalogIds = new ArrayList<>();
30426 tejbeer 1265
 
33213 tejus.loha 1266
        Item item = itemRepository.selectById(pendingOrderItem.getItemId());
1267
        pendingOrderItem.setItemName(item.getItemDescription());
1268
        catalogIds.add(item.getCatalogItemId());
28339 tejbeer 1269
 
33213 tejus.loha 1270
        Map<Integer, JSONObject> contentMap = commonSolrService.getContentByCatalogIds(catalogIds);
1271
        JSONObject jsonObj = contentMap.get(item.getCatalogItemId());
1272
        pendingOrderItem.setImgUrl(jsonObj.getString("imageUrl_s"));
1273
        pendingOrder.setPendingOrderItems(Arrays.asList(pendingOrderItem));
1274
        CustomerAddress customerAddress = customerAddressRepository.selectById(pendingOrder.getCustomerAddressId());
1275
        DateTimeFormatter dateTimeFormatter = DateTimeFormatter.ofPattern("dd/MM/yyyy h:mm a");
1276
        Map<String, Object> emailModel = new HashMap<>();
1277
        emailModel.put("customer", customerAddress);
1278
        emailModel.put("pendingOrder", pendingOrder);
1279
        emailModel.put("date", dateTimeFormatter);
1280
        Customer customer = customerRepository.selectById(pendingOrder.getCustomerId());
1281
        String[] customerEmail = null;
1282
        if (customer.getEmailId() != null && !customer.getEmailId().isEmpty()) {
1283
            customerEmail = new String[]{customer.getEmailId()};
1284
            List<String> bccTo = Arrays.asList("tejbeer.kaur@smartdukaan.com");
28339 tejbeer 1285
 
33213 tejus.loha 1286
            emailService.sendMailWithAttachments("Order Delivered with SmartDukaan", "order-delivered.vm", emailModel,
1287
                    customerEmail, null, bccTo.toArray(new String[0]));
26647 tejbeer 1288
 
33213 tejus.loha 1289
        }
1290
        if (!status.contains(OrderStatus.PENDING) && !status.contains(OrderStatus.PROCESSING)
1291
                && !status.contains(OrderStatus.BILLED) && !status.contains(OrderStatus.UNSETTLED)
1292
                && !status.contains(OrderStatus.CLAIMED)) {
1293
            pendingOrder.setStatus(OrderStatus.CLOSED);
1294
        }
1295
        pendingOrderItemRepository.persist(pendingOrderItem);
1296
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
26721 tejbeer 1297
 
33213 tejus.loha 1298
        return "response";
1299
    }
27046 tejbeer 1300
 
33213 tejus.loha 1301
    @RequestMapping(value = "/raiseClaimOrderItem", method = RequestMethod.POST)
1302
    public String raiseClaimOrderItem(HttpServletRequest request, @RequestParam int id, Model model) throws Exception {
28352 tejbeer 1303
 
33213 tejus.loha 1304
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1305
        PendingOrderItem pendingOrderItem = pendingOrderItemRepository.selectById(id);
1306
        PendingOrder pendingOrder = pendingOrderRepository.selectById(pendingOrderItem.getOrderId());
28437 tejbeer 1307
 
33213 tejus.loha 1308
        if (pendingOrder.getTotalAmount() == pendingOrder.getPaidAmount()) {
1309
            pendingOrderItem.setStatus(OrderStatus.CLAIMED);
1310
            pendingOrderItem.setClaimedTimestamp(LocalDateTime.now());
28437 tejbeer 1311
 
33213 tejus.loha 1312
        }
1313
        pendingOrderItemRepository.persist(pendingOrderItem);
1314
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
28437 tejbeer 1315
 
33213 tejus.loha 1316
        return "response";
1317
    }
28437 tejbeer 1318
 
33213 tejus.loha 1319
    @RequestMapping(value = "/verifyOrderItem", method = RequestMethod.POST)
1320
    public String verifyOrderItem(HttpServletRequest request, @RequestParam int id, Model model) throws Exception {
28437 tejbeer 1321
 
33213 tejus.loha 1322
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1323
        PendingOrderItem pendingOrderItem = pendingOrderItemRepository.selectById(id);
1324
        pendingOrderItem.setVerifiedTimestamp(LocalDateTime.now());
28352 tejbeer 1325
 
33213 tejus.loha 1326
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
26721 tejbeer 1327
 
33213 tejus.loha 1328
        return "response";
1329
    }
26721 tejbeer 1330
 
33213 tejus.loha 1331
    @RequestMapping(value = "/cancelOrderByInvoice", method = RequestMethod.POST)
1332
    public String cancelOrder(HttpServletRequest request, @RequestParam List<String> invoiceNumbers, Model model)
1333
            throws Exception {
1334
        orderService.cancelOrder(invoiceNumbers);
1335
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
26721 tejbeer 1336
 
33213 tejus.loha 1337
        return "response";
1338
    }
28352 tejbeer 1339
 
33213 tejus.loha 1340
    @RequestMapping(value = "/getOnlineOrder", method = RequestMethod.GET)
1341
    public String cancelOrder(HttpServletRequest request, Model model) throws Exception {
1342
        return "online-order";
1343
    }
28352 tejbeer 1344
 
33213 tejus.loha 1345
    @GetMapping("/getAllOrdersByStatus")
1346
    public String getAllOrdersByStatus(HttpServletRequest request, @RequestParam OrderStatus status,
1347
                                       @RequestParam(required = false) LocalDateTime startTime,
1348
                                       @RequestParam(required = false) LocalDateTime endTime, Model model) throws ProfitMandiBusinessException {
1349
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1350
        boolean isAdmin = roleManager.isAdmin(loginDetails.getRoleIds());
28352 tejbeer 1351
 
33213 tejus.loha 1352
        LOGGER.info("startTime {}", startTime);
1353
        LOGGER.info("endTime {}", endTime);
28352 tejbeer 1354
 
33213 tejus.loha 1355
        List<PendingOrderItem> pendingOrderItems;
1356
        if (startTime == null) {
33367 ranu 1357
            LocalDate date = LocalDate.now().minusDays(15);
1358
            if (status.equals(OrderStatus.PENDING)) {
1359
                pendingOrderItems = pendingOrderItemRepository.selectByStatusAndCreateTimestamp(Collections.singletonList(status), date.atStartOfDay(), LocalDateTime.now());
1360
            } else {
1361
                pendingOrderItems = pendingOrderItemRepository.selectOrderItemByStatus(status);
1362
            }
1363
 
33213 tejus.loha 1364
        } else {
1365
            List<OrderStatus> statusList = new ArrayList<>();
1366
            if (status.equals(OrderStatus.DELIVERED)) {
1367
                statusList.add(OrderStatus.SETTLED);
1368
                statusList.add(OrderStatus.UNSETTLED);
1369
            } else {
1370
                statusList.add(status);
1371
            }
1372
            pendingOrderItems = pendingOrderItemRepository.selectByStatusAndCreateTimestamp(statusList,
1373
                    startTime.toLocalDate().atStartOfDay(), endTime);
1374
        }
28352 tejbeer 1375
 
33213 tejus.loha 1376
        List<Integer> pendingOrderIds = pendingOrderItems.stream().map(x -> x.getOrderId()).collect(Collectors.toList());
28352 tejbeer 1377
 
33213 tejus.loha 1378
        List<Integer> fofoIds = pendingOrderRepository.selectByIds(pendingOrderIds)
1379
                .stream().map(x -> x.getFofoId()).distinct().collect(Collectors.toList());
28356 tejbeer 1380
 
33213 tejus.loha 1381
        Map<Integer, CustomRetailer> customRetailerMap = retailerService.getAllFofoRetailers();
28352 tejbeer 1382
 
33213 tejus.loha 1383
        Map<Integer, CustomRetailer> customRetailersMap = fofoIds.stream().map(x -> customRetailerMap.get(x))
1384
                .filter(x -> x != null).collect(Collectors.toList()).stream()
1385
                .collect(Collectors.toMap(x -> x.getPartnerId(), x -> x));
1386
        model.addAttribute("customRetailersMap", customRetailersMap);
28352 tejbeer 1387
 
33213 tejus.loha 1388
        LOGGER.info("customRetailersMap {}", customRetailersMap);
28339 tejbeer 1389
 
33213 tejus.loha 1390
        Map<String, Object> map = pendingOrderService.getItemOrders(pendingOrderItems, 0);
32697 ranu 1391
 
33213 tejus.loha 1392
        model.addAttribute("pendingOrderItems", (List<PendingOrderItem>) map.get("pendingOrderItems"));
1393
        model.addAttribute("partnerInventoryMap", map.get("partnerInventoryMap"));
32697 ranu 1394
 
33213 tejus.loha 1395
        model.addAttribute("isAdmin", isAdmin);
1396
        return "online-order-item";
1397
    }
32697 ranu 1398
 
33213 tejus.loha 1399
    //TODO Tejus
1400
    @RequestMapping(value = "/getBulkOrder")
33336 tejus.loha 1401
    public String getBulkOrder(HttpServletRequest request, Model model) throws ProfitMandiBusinessException, MessagingException, IOException {
33213 tejus.loha 1402
        return "bulk-order";
1403
    }
32697 ranu 1404
 
33213 tejus.loha 1405
    @PostMapping(value = "/bulkOrder/upload")
1406
    public String uploadCatalog(HttpServletRequest request, @RequestPart("file") MultipartFile file, Model model)
1407
            throws Exception {
1408
        LoginDetails fofoDetails = cookiesProcessor.getCookiesObject(request);
1409
        int authId = authRepository.selectByEmailOrMobile(fofoDetails.getEmailId()).getId();
1410
        LOGGER.info("authId - {}", authId);
1411
        bulkOrderService.parseBulkOrders(file, authId);
1412
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
1413
        return "response";
1414
    }
32697 ranu 1415
 
33213 tejus.loha 1416
    // This method is use for sending all pending transaction to Transation Approval menu
1417
    @RequestMapping(value = "/transaction/pendingApprovals", method = RequestMethod.GET)
1418
    public String getTransactionApproval(HttpServletRequest request, Model model) throws Exception {
33219 tejus.loha 1419
        List<TransactionApproval> transactionApprovals = transactionApprovalRepository.selectAllPending();
1420
        LOGGER.info("list of Approval transaction Id " + transactionApprovals);
33336 tejus.loha 1421
        List<TransactionApprovalModel> approvalModelList = bulkOrderService.getAllPendingTransactionApproval();
33213 tejus.loha 1422
        model.addAttribute("approvalModelList", approvalModelList);
1423
        return "transaction/transaction-approvals";
1424
    }
33092 tejus.loha 1425
 
33213 tejus.loha 1426
    @RequestMapping(value = "transaction/approval", method = RequestMethod.PUT)
1427
    public String transactionApproval(HttpServletRequest request, Model model,
1428
                                      @RequestParam int transactionId,
1429
                                      @RequestParam String remark,
1430
                                      @RequestParam TransactionApprovalStatus transactionApprovalStatus
1431
    ) throws Exception {
1432
        LoginDetails loginDetails = cookiesProcessor.getCookiesObject(request);
1433
        AuthUser authUser = authRepository.selectByEmailOrMobile(loginDetails.getEmailId());
1434
        int approvalId = authUser.getId();
1435
        String approvedBy = authUser.getFullName();
1436
        LocalDateTime approvedOn = LocalDateTime.now();
1437
        this.updateApprovalStatus(transactionId, approvalId, approvedBy, approvedOn, remark, transactionApprovalStatus);
1438
        model.addAttribute("response1", mvcResponseSender.createResponseString(true));
1439
        return "response";
1440
 
1441
    }
1442
 
1443
    private void updateApprovalStatus(int transactionId, int approvalId, String approvedBy, LocalDateTime approvedOn, String remark, TransactionApprovalStatus transactionApprovalStatus) throws Exception {
1444
        TransactionApproval transactionApproval = transactionApprovalRepository.selectById(transactionId);
33336 tejus.loha 1445
        int retailerId = transactionRepository.selectById(transactionId).getRetailerId();
33213 tejus.loha 1446
        if (!transactionApproval.getStatus().equals(TransactionApprovalStatus.PENDING)) {
1447
            throw new ProfitMandiBusinessException("Transaction already Processed", "Transaction already Processed", "Transaction already Processed");
1448
        }
1449
        transactionApproval.setStatus(transactionApprovalStatus);
1450
        transactionApproval.setRemark(remark);
1451
        transactionApproval.setApprovalId(approvalId);
1452
        transactionApproval.setApprovedBy(approvedBy);
1453
        transactionApproval.setApprovedOn(approvedOn);
1454
        if (transactionApprovalStatus.equals(TransactionApprovalStatus.APPROVED)) {
1455
            transactionService.processTransaction(transactionId);
33336 tejus.loha 1456
        } else {
1457
            float totalAmount = 0;
1458
            // referense id = transaction id
1459
            // here refund the amount of an order
1460
            List<UserWalletHistory> uwhList = walletService.getAllByReference(retailerId, transactionId, WalletReferenceType.PURCHASE);
1461
            // Do is negative so that add amount in wallet
1462
            totalAmount = -uwhList.get(0).getAmount();
1463
            walletService.refundToWallet(retailerId, totalAmount, transactionId, WalletReferenceType.PURCHASE, "Order canceled");
33213 tejus.loha 1464
        }
1465
    }
1466
 
1467
    @RequestMapping(value = "/bulkOrderTemplate", method = RequestMethod.GET)
1468
    public ResponseEntity<?> bulkOrderTemplate() throws Exception {
1469
        List<List<?>> rows = new ArrayList<>();
1470
        rows.add(Arrays.asList("Mahaveer", "Change description for your reference", "175139287", "28264", "0", "4"));
1471
        rows.add(Arrays.asList("Mahaveer", "Price =0 means system price", "175139287", "28268", "0", "7"));
1472
        rows.add(Arrays.asList("Jas", "You give custom price also ", "171273247", "28264", "300", "3"));
1473
        org.apache.commons.io.output.ByteArrayOutputStream baos = FileUtil
1474
                .getCSVByteStream(Arrays.asList("Partner name", "Description", "Partner Id", "Item Id", "Price", "Quantity"), rows);
1475
        ResponseEntity<?> responseEntity = orderService.downloadReportInCsv(baos, rows, "Bulk order template");
1476
 
1477
        return responseEntity;
1478
 
1479
    }
32409 amit.gupta 1480
}
32405 jai.hind 1481
 
1482
 
1483
 
1484
 
1485