Subversion Repositories SmartDukaan

Rev

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

Rev Author Line No. Line
23365 ashik.ali 1
package com.spice.profitmandi.service.order;
22859 ashik.ali 2
 
24264 amit.gupta 3
import com.spice.profitmandi.common.enumuration.ItemType;
23202 ashik.ali 4
import com.spice.profitmandi.common.enumuration.SearchType;
22859 ashik.ali 5
import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
30321 amit.gupta 6
import com.spice.profitmandi.common.model.*;
23650 amit.gupta 7
import com.spice.profitmandi.common.util.FormattingUtils;
22859 ashik.ali 8
import com.spice.profitmandi.common.util.StringUtils;
23172 ashik.ali 9
import com.spice.profitmandi.common.util.Utils;
29515 tejbeer 10
import com.spice.profitmandi.common.web.client.RestClient;
22859 ashik.ali 11
import com.spice.profitmandi.dao.entity.catalog.Item;
25103 amit.gupta 12
import com.spice.profitmandi.dao.entity.catalog.TagListing;
30321 amit.gupta 13
import com.spice.profitmandi.dao.entity.dtr.*;
14
import com.spice.profitmandi.dao.entity.fofo.*;
28978 amit.gupta 15
import com.spice.profitmandi.dao.entity.inventory.State;
24917 tejbeer 16
import com.spice.profitmandi.dao.entity.transaction.Order;
22859 ashik.ali 17
import com.spice.profitmandi.dao.entity.user.Address;
18
import com.spice.profitmandi.dao.entity.user.Counter;
19
import com.spice.profitmandi.dao.entity.user.PrivateDealUser;
27516 amit.gupta 20
import com.spice.profitmandi.dao.entity.warehouse.WarehouseInventoryItem;
24264 amit.gupta 21
import com.spice.profitmandi.dao.enumuration.catalog.SchemeType;
23546 ashik.ali 22
import com.spice.profitmandi.dao.enumuration.dtr.PaymentOptionReferenceType;
23650 amit.gupta 23
import com.spice.profitmandi.dao.enumuration.fofo.ReturnType;
22859 ashik.ali 24
import com.spice.profitmandi.dao.enumuration.fofo.ScanType;
23655 amit.gupta 25
import com.spice.profitmandi.dao.enumuration.fofo.SettlementType;
29515 tejbeer 26
import com.spice.profitmandi.dao.enumuration.inventory.ScratchedGift;
28339 tejbeer 27
import com.spice.profitmandi.dao.enumuration.transaction.OrderStatus;
22859 ashik.ali 28
import com.spice.profitmandi.dao.repository.catalog.ItemRepository;
26817 amit.gupta 29
import com.spice.profitmandi.dao.repository.catalog.StateGstRateRepository;
24823 amit.gupta 30
import com.spice.profitmandi.dao.repository.catalog.TagListingRepository;
30321 amit.gupta 31
import com.spice.profitmandi.dao.repository.dtr.*;
32
import com.spice.profitmandi.dao.repository.fofo.*;
24854 amit.gupta 33
import com.spice.profitmandi.dao.repository.inventory.StateRepository;
24917 tejbeer 34
import com.spice.profitmandi.dao.repository.transaction.OrderRepository;
22859 ashik.ali 35
import com.spice.profitmandi.dao.repository.user.AddressRepository;
36
import com.spice.profitmandi.dao.repository.user.CounterRepository;
37
import com.spice.profitmandi.dao.repository.user.PrivateDealUserRepository;
27516 amit.gupta 38
import com.spice.profitmandi.dao.repository.warehouse.WarehouseInventoryItemRepository;
25724 amit.gupta 39
import com.spice.profitmandi.service.integrations.zest.InsuranceService;
31274 amit.gupta 40
import com.spice.profitmandi.service.integrations.zest.MobileInsurancePlan;
23418 ashik.ali 41
import com.spice.profitmandi.service.inventory.InventoryService;
23655 amit.gupta 42
import com.spice.profitmandi.service.inventory.PurchaseReturnService;
26891 amit.gupta 43
import com.spice.profitmandi.service.inventory.SaholicInventoryService;
28166 tejbeer 44
import com.spice.profitmandi.service.offers.ItemCriteria;
22859 ashik.ali 45
import com.spice.profitmandi.service.pricing.PricingService;
46
import com.spice.profitmandi.service.scheme.SchemeService;
23655 amit.gupta 47
import com.spice.profitmandi.service.user.RetailerService;
23395 amit.gupta 48
import com.spice.profitmandi.service.wallet.WalletService;
30321 amit.gupta 49
import org.apache.logging.log4j.LogManager;
50
import org.apache.logging.log4j.Logger;
51
import org.hibernate.Session;
52
import org.hibernate.SessionFactory;
53
import org.json.JSONObject;
54
import org.springframework.beans.factory.annotation.Autowired;
55
import org.springframework.beans.factory.annotation.Qualifier;
56
import org.springframework.beans.factory.annotation.Value;
57
import org.springframework.cache.annotation.Cacheable;
58
import org.springframework.core.io.InputStreamResource;
59
import org.springframework.http.HttpHeaders;
60
import org.springframework.http.HttpStatus;
61
import org.springframework.http.ResponseEntity;
62
import org.springframework.stereotype.Component;
22859 ashik.ali 63
 
30321 amit.gupta 64
import javax.persistence.criteria.CriteriaBuilder;
65
import javax.persistence.criteria.CriteriaQuery;
66
import javax.persistence.criteria.Predicate;
67
import javax.persistence.criteria.Root;
68
import java.io.ByteArrayInputStream;
69
import java.io.InputStream;
70
import java.time.LocalDate;
71
import java.time.LocalDateTime;
72
import java.time.LocalTime;
73
import java.util.AbstractMap.SimpleEntry;
74
import java.util.*;
75
import java.util.function.Function;
76
import java.util.stream.Collectors;
77
 
22859 ashik.ali 78
@Component
79
public class OrderServiceImpl implements OrderService {
80
 
32145 tejbeer 81
    private static final Logger LOGGER = LogManager.getLogger(OrderServiceImpl.class);
22859 ashik.ali 82
 
32145 tejbeer 83
    private static Map<String, Integer> serialNumberOrderIdMap = new HashMap<>();
31030 amit.gupta 84
 
32145 tejbeer 85
    static {
86
        serialNumberOrderIdMap.put("862897055749275", 67228);
87
    }
31030 amit.gupta 88
 
32145 tejbeer 89
    @Autowired
90
    @Qualifier("fofoInventoryItemRepository")
91
    private InventoryItemRepository inventoryItemRepository;
27083 amit.gupta 92
 
32145 tejbeer 93
    @Autowired
94
    private StateGstRateRepository stateGstRateRepository;
23650 amit.gupta 95
 
32145 tejbeer 96
    @Autowired
97
    private SaholicInventoryService saholicInventoryService;
27083 amit.gupta 98
 
32145 tejbeer 99
    @Autowired
100
    private LiveDemoBillingRespository liveDemoBillingRespository;
24823 amit.gupta 101
 
32145 tejbeer 102
    @Autowired
103
    private InsuranceService insuranceService;
25724 amit.gupta 104
 
32145 tejbeer 105
    @Autowired
106
    private WalletService walletService;
22859 ashik.ali 107
 
32145 tejbeer 108
    @Autowired
109
    @Qualifier("fofoCurrentInventorySnapshotRepository")
110
    private CurrentInventorySnapshotRepository currentInventorySnapshotRepository;
22859 ashik.ali 111
 
32145 tejbeer 112
    @Autowired
113
    private InvoiceNumberGenerationSequenceRepository invoiceNumberGenerationSequenceRepository;
22859 ashik.ali 114
 
32145 tejbeer 115
    @Autowired
116
    private PurchaseReturnService purchaseReturnService;
23655 amit.gupta 117
 
32145 tejbeer 118
    @Autowired
119
    private RetailerService retailerService;
23655 amit.gupta 120
 
32145 tejbeer 121
    @Autowired
122
    private CustomerRepository customerRepository;
23650 amit.gupta 123
 
32145 tejbeer 124
    @Autowired
125
    private PurchaseReturnItemRepository purchaseReturnItemRepository;
22859 ashik.ali 126
 
32145 tejbeer 127
    @Autowired
128
    private AddressRepository addressRepository;
22859 ashik.ali 129
 
32145 tejbeer 130
    @Autowired
131
    private FofoLineItemRepository fofoLineItemRepository;
22859 ashik.ali 132
 
32145 tejbeer 133
    @Autowired
134
    private WarehouseInventoryItemRepository warehouseInventoryItemRepository;
27516 amit.gupta 135
 
32145 tejbeer 136
    @Autowired
137
    private FofoOrderItemRepository fofoOrderItemRepository;
23650 amit.gupta 138
 
32145 tejbeer 139
    @Autowired
140
    private PaymentOptionRepository paymentOptionRepository;
22859 ashik.ali 141
 
32145 tejbeer 142
    @Autowired
143
    private CustomerReturnItemRepository customerReturnItemRepository;
23650 amit.gupta 144
 
32145 tejbeer 145
    @Autowired
146
    @Qualifier("fofoScanRecordRepository")
147
    private ScanRecordRepository scanRecordRepository;
22859 ashik.ali 148
 
32145 tejbeer 149
    @Autowired
150
    private FofoOrderRepository fofoOrderRepository;
22859 ashik.ali 151
 
32145 tejbeer 152
    @Autowired
153
    private RetailerRepository retailerRepository;
22859 ashik.ali 154
 
32145 tejbeer 155
    @Autowired
156
    private UserRepository userRepository;
22859 ashik.ali 157
 
32145 tejbeer 158
    @Autowired
159
    private UserAccountRepository userAccountRepository;
22859 ashik.ali 160
 
32145 tejbeer 161
    @Autowired
162
    private RetailerRegisteredAddressRepository retailerRegisteredAddressRepository;
22859 ashik.ali 163
 
32145 tejbeer 164
    @Autowired
165
    private CustomerAddressRepository customerAddressRepository;
22859 ashik.ali 166
 
32145 tejbeer 167
    @Autowired
168
    @Qualifier("catalogItemRepository")
169
    private ItemRepository itemRepository;
23650 amit.gupta 170
 
32145 tejbeer 171
    @Autowired
172
    private InsuranceProviderRepository insuranceProviderRepository;
23650 amit.gupta 173
 
32145 tejbeer 174
    @Autowired
175
    private InsurancePolicyRepository insurancePolicyRepository;
24917 tejbeer 176
 
32145 tejbeer 177
    @Autowired
178
    private StateRepository stateRepository;
23650 amit.gupta 179
 
32145 tejbeer 180
    @Autowired
181
    private PolicyNumberGenerationSequenceRepository policyNumberGenerationSequenceRepository;
23650 amit.gupta 182
 
32145 tejbeer 183
    @Autowired
184
    private PricingService pricingService;
23650 amit.gupta 185
 
32145 tejbeer 186
    @Autowired
187
    private PrivateDealUserRepository privateDealUserRepository;
23650 amit.gupta 188
 
32145 tejbeer 189
    @Autowired
190
    private TagListingRepository tagListingRepository;
24823 amit.gupta 191
 
32145 tejbeer 192
    @Autowired
193
    private CounterRepository counterRepository;
23650 amit.gupta 194
 
32145 tejbeer 195
    @Autowired
196
    private FofoStoreRepository fofoStoreRepository;
23650 amit.gupta 197
 
32145 tejbeer 198
    @Autowired
199
    private PaymentOptionTransactionRepository paymentOptionTransactionRepository;
23650 amit.gupta 200
 
32145 tejbeer 201
    @Autowired
202
    private SchemeService schemeService;
23650 amit.gupta 203
 
32145 tejbeer 204
    private static final List<Integer> orderIdsConsumed = new ArrayList<>();
28166 tejbeer 205
 
32145 tejbeer 206
    @Autowired
207
    @Qualifier("fofoInventoryService")
208
    private InventoryService inventoryService;
23650 amit.gupta 209
 
32145 tejbeer 210
    @Autowired
211
    private CustomerCreditNoteRepository customerCreditNoteRepository;
23650 amit.gupta 212
 
32145 tejbeer 213
    @Autowired
214
    private OrderRepository orderRepository;
24917 tejbeer 215
 
32145 tejbeer 216
    @Autowired
217
    private HygieneDataRepository hygieneDataRepository;
25640 tejbeer 218
 
32145 tejbeer 219
    @Autowired
220
    private SessionFactory sessionFactory;
28166 tejbeer 221
 
32145 tejbeer 222
    @Autowired
223
    private Mongo mongoClient;
28964 tejbeer 224
 
32145 tejbeer 225
    @Autowired
226
    private PendingOrderRepository pendingOrderRepository;
28964 tejbeer 227
 
32145 tejbeer 228
    @Autowired
229
    private PendingOrderItemRepository pendingOrderItemRepository;
28166 tejbeer 230
 
32145 tejbeer 231
    @Autowired
232
    private ScratchOfferRepository scratchOfferRepository;
29515 tejbeer 233
 
32145 tejbeer 234
    @Autowired
235
    RestClient restClient;
29515 tejbeer 236
 
32145 tejbeer 237
    @Value("${prod}")
238
    private boolean prodEnv;
29515 tejbeer 239
 
32145 tejbeer 240
    private static final String SMS_GATEWAY = "http://api.pinnacle.in/index.php/sms/send";
241
    private static final String SENDER = "SMTDKN";
29515 tejbeer 242
 
32145 tejbeer 243
    public static final String APP_DOWNLOAD_BILLING_TEMPLATE_ID = "1507163542403945677";
29515 tejbeer 244
 
32145 tejbeer 245
    public static final String APP_DOWNLOAD_BILLING_OFFER = "Dear Customer, Thank you for purchasing from SmartDukaan pls click %s to download our app to see you invoice and special offers. SmartDukaan";
29515 tejbeer 246
 
32145 tejbeer 247
    @Override
248
    public int createOrder(CreateOrderRequest createOrderRequest, int fofoId, boolean accessoriesDeals) throws ProfitMandiBusinessException {
249
        LOGGER.info("fofoId -- {} Order Request -- {}", fofoId, createOrderRequest);
250
        CustomCustomer customCustomer = createOrderRequest.getCustomer();
251
        Customer customer = customerRepository.selectById(customCustomer.getCustomerId());
22872 ashik.ali 252
 
32145 tejbeer 253
        if (!StringUtils.isValidGstNumber(customCustomer.getGstNumber())) {
254
            LOGGER.error("invalid customer gstNumber {} ", customCustomer.getGstNumber());
255
            throw new ProfitMandiBusinessException(ProfitMandiConstants.CUSTOMER_GST_NUMBER, customCustomer.getGstNumber(), "VE_1072");
256
        }
23650 amit.gupta 257
 
32145 tejbeer 258
        Map<Integer, Integer> itemIdQuantity = new HashMap<>(); // this is for error
259
        Map<Integer, CustomFofoOrderItem> itemIdCustomFofoOrderItemMap = new HashMap<>();
260
        Map<Integer, Float> lineItemPrice = new HashMap<>(); // this is for pricing error
23650 amit.gupta 261
 
32145 tejbeer 262
        float totalAmount = 0;
263
        boolean noGST = false;
264
        for (CustomFofoOrderItem customFofoOrderItem : createOrderRequest.getFofoOrderItems()) {
265
            // itemIds.add(customFofoOrderItem.getItemId());
266
            Set<String> serialNumbers = this.serialNumberDetailsToSerialNumbers(customFofoOrderItem.getSerialNumberDetails());
267
            if (!serialNumbers.isEmpty() && customFofoOrderItem.getQuantity() != serialNumbers.size()) {
268
                itemIdQuantity.put(customFofoOrderItem.getItemId(), customFofoOrderItem.getQuantity());
269
            }
270
            if (!(customFofoOrderItem.getSellingPrice() > 0)) {
271
                lineItemPrice.put(customFofoOrderItem.getItemId(), customFofoOrderItem.getSellingPrice());
272
            } else {
273
                totalAmount = totalAmount + customFofoOrderItem.getSellingPrice() * customFofoOrderItem.getQuantity();
274
                for (SerialNumberDetail serialNumberDetail : customFofoOrderItem.getSerialNumberDetails()) {
275
                    if (serialNumberDetail.getAmount() > 0) {
276
                        totalAmount = totalAmount + serialNumberDetail.getAmount();
277
                    }
278
                }
279
            }
23650 amit.gupta 280
 
32145 tejbeer 281
            itemIdCustomFofoOrderItemMap.put(customFofoOrderItem.getItemId(), customFofoOrderItem);
282
        }
283
        if (!itemIdQuantity.isEmpty()) {
284
            // if item quantity does not match with given serialnumbers size
285
            LOGGER.error("itemId's quantity should be equal to given serialnumber size {} ", itemIdQuantity);
286
            throw new ProfitMandiBusinessException("itemIdQuantity", itemIdQuantity, "FFORDR_1001");
287
            // return "error";
288
        }
23650 amit.gupta 289
 
32145 tejbeer 290
        this.validatePaymentOptionsAndTotalAmount(createOrderRequest.getPaymentOptions(), totalAmount);
23650 amit.gupta 291
 
32145 tejbeer 292
        if (!lineItemPrice.isEmpty()) {
293
            // given fofo line item price must be greater than zero
294
            LOGGER.error("requested itemId's selling price must greater than 0");
295
            throw new ProfitMandiBusinessException(ProfitMandiConstants.PRICE, lineItemPrice, "FFORDR_1002");
296
        }
22859 ashik.ali 297
 
32145 tejbeer 298
        List<CurrentInventorySnapshot> currentInventorySnapshots = currentInventorySnapshotRepository.selectByFofoItemIds(fofoId, itemIdCustomFofoOrderItemMap.keySet());
23650 amit.gupta 299
 
32145 tejbeer 300
        this.validateCurrentInventorySnapshotQuantities(currentInventorySnapshots, itemIdCustomFofoOrderItemMap);
22859 ashik.ali 301
 
32145 tejbeer 302
        List<Item> items = itemRepository.selectByIds(itemIdCustomFofoOrderItemMap.keySet());
303
        if (items.size() != itemIdCustomFofoOrderItemMap.keySet().size()) {
304
            LOGGER.error("Requested ItemIds not found in catalog");
305
            // invalid itemIds
306
            throw new ProfitMandiBusinessException("invalidItemIds", itemIdCustomFofoOrderItemMap.keySet(), "FFORDR_1003");
307
        }
23650 amit.gupta 308
 
32145 tejbeer 309
        Map<Integer, Item> itemMap = this.toItemMap(items);
23650 amit.gupta 310
 
32145 tejbeer 311
        Set<Integer> nonSerializedItemIds = new HashSet<>();
312
        Set<String> serialNumbers = new HashSet<>();
313
        List<InsuranceModel> insuredModels = new ArrayList<>();
314
        for (CustomFofoOrderItem customFofoOrderItem : createOrderRequest.getFofoOrderItems()) {
315
            Item item = itemMap.get(customFofoOrderItem.getItemId());
316
            noGST = item.getHsnCode().equals("NOGST");
317
            if (item.getType().equals(ItemType.SERIALIZED)) {
318
                for (SerialNumberDetail serialNumberDetail : customFofoOrderItem.getSerialNumberDetails()) {
319
                    serialNumbers.add(serialNumberDetail.getSerialNumber());
320
                    if (serialNumberDetail.getAmount() > 0) {
321
                        if (customer.getEmailId() == null || customer.getEmailId().equals("")) {
322
                            throw new ProfitMandiBusinessException("Email Id is required for insurance", "Email Id is required for insurance", "Email Id is required for insurance");
323
                        }
324
                        InsuranceModel im = new InsuranceModel();
325
                        im.setBrand(item.getBrand());
326
                        im.setColor(item.getColor());
327
                        im.setModelName(item.getModelName() + item.getModelNumber());
328
                        im.setInsuranceAmount(serialNumberDetail.getAmount());
329
                        im.setDeviceSellingPrice(customFofoOrderItem.getSellingPrice());
330
                        im.setInsuranceId(serialNumberDetail.getInsurance());
331
                        im.setSerialNumber(serialNumberDetail.getSerialNumber());
332
                        im.setMemory(serialNumberDetail.getMemory());
333
                        im.setRam(serialNumberDetail.getRam());
334
                        im.setMfgDate(serialNumberDetail.getMfgDate());
335
                        insuredModels.add(im);
336
                        // Check for free insurance code
337
                        try {
338
                            Map<String, List<MobileInsurancePlan>> mobileInsurancePlanMap = insuranceService.getAllPlans(item.getId(), im.getDeviceSellingPrice());
339
                            MobileInsurancePlan mobileInsurancePlan = mobileInsurancePlanMap.entrySet().stream().flatMap(x -> x.getValue().stream()).filter(x -> x.getProductId().equals(serialNumberDetail.getInsurance())).findFirst().get();
340
                            LOGGER.info("OneAssist Plan - {}", mobileInsurancePlanMap);
341
                            LOGGER.info("SerialNumber Detqail InsuranceId - {}", serialNumberDetail.getInsurance());
342
                            LOGGER.info("product description - {}", mobileInsurancePlan);
343
                            if (mobileInsurancePlan.getPlanName().equals("OneAssist Damage Protection Plan")) {
344
                                MobileInsurancePlan freePlan = mobileInsurancePlanMap.get("Prolong Extendended Warranty(SmartDukaan Special Price)").get(0);
345
                                InsuranceModel imFree = new InsuranceModel();
346
                                imFree.setBrand(item.getBrand());
347
                                imFree.setColor(item.getColor());
348
                                imFree.setModelName(item.getModelName() + item.getModelNumber());
349
                                imFree.setInsuranceAmount(0);
350
                                imFree.setDeviceSellingPrice(customFofoOrderItem.getSellingPrice());
351
                                imFree.setInsuranceId(freePlan.getProductId());
352
                                imFree.setSerialNumber(serialNumberDetail.getSerialNumber());
353
                                imFree.setMemory(serialNumberDetail.getMemory());
354
                                imFree.setRam(serialNumberDetail.getRam());
355
                                imFree.setMfgDate(serialNumberDetail.getMfgDate());
356
                                insuredModels.add(imFree);
357
                            }
358
                        } catch (Exception e) {
359
                            LOGGER.error("Exception - {}", e);
360
                            throw new ProfitMandiBusinessException("problem fetching plans", "problem fetching plans", "problem fetching plans");
361
                        }
362
                    }
31274 amit.gupta 363
 
32145 tejbeer 364
                }
365
            } else {
366
                nonSerializedItemIds.add(customFofoOrderItem.getItemId());
367
            }
368
        }
23650 amit.gupta 369
 
32145 tejbeer 370
        Map<Integer, Set<InventoryItem>> serializedInventoryItemMap = new HashMap<>();
371
        Map<Integer, Set<InventoryItem>> nonSerializedInventoryItemMap = new HashMap<>();
372
        // Map<String, Float> serialNumberItemPrice = new HashMap<>();
23650 amit.gupta 373
 
32145 tejbeer 374
        if (!serialNumbers.isEmpty()) {
375
            List<InventoryItem> serializedInventoryItems = inventoryItemRepository.selectByFofoIdSerialNumbers(fofoId, serialNumbers, false);
376
            LOGGER.info("serializedInventoryItems {}", serializedInventoryItems);
377
            for (InventoryItem inventoryItem : serializedInventoryItems) {
378
                if (inventoryItem.getGoodQuantity() == 1) {
379
                    if (serializedInventoryItemMap.containsKey(inventoryItem.getItemId())) {
380
                        serializedInventoryItemMap.get(inventoryItem.getItemId()).add(inventoryItem);
381
                    } else {
382
                        Set<InventoryItem> itemIdInventoryItems = new HashSet<>();
383
                        itemIdInventoryItems.add(inventoryItem);
384
                        serializedInventoryItemMap.put(inventoryItem.getItemId(), itemIdInventoryItems);
385
                    }
386
                }
387
            }
388
        }
23418 ashik.ali 389
 
32145 tejbeer 390
        if (!nonSerializedItemIds.isEmpty()) {
391
            List<InventoryItem> nonSerializedInventoryItems = inventoryItemRepository.selectByFofoIdItemIds(fofoId, nonSerializedItemIds);
392
            LOGGER.info("nonSerializedInventoryItems {}", nonSerializedInventoryItems);
393
            for (InventoryItem it : nonSerializedInventoryItems) {
394
                if (it.getGoodQuantity() > 0) {
395
                    if (nonSerializedInventoryItemMap.containsKey(it.getItemId())) {
396
                        nonSerializedInventoryItemMap.get(it.getItemId()).add(it);
397
                    } else {
398
                        Set<InventoryItem> tmp = new HashSet<>();
399
                        tmp.add(it);
400
                        nonSerializedInventoryItemMap.put(it.getItemId(), tmp);
401
                    }
402
                }
403
            }
404
        }
23650 amit.gupta 405
 
32145 tejbeer 406
        this.validateItemsSerializedNonSerialized(items, itemIdCustomFofoOrderItemMap);
22859 ashik.ali 407
 
32145 tejbeer 408
        Map<Integer, Set<InventoryItem>> inventoryItemsToBill = new HashMap<>();
409
        Map<Integer, Integer> inventoryItemIdQuantityUsed = new HashMap<>(); // to keep track of inventoryitem quanity
410
        // used for scan records insertion
22859 ashik.ali 411
 
32145 tejbeer 412
        LOGGER.info("itemMap keys {}", itemMap.keySet());
413
        // Lets reduce quantity and decide what inventory items to use.
414
        for (Item item : items) {
415
            if (item.getType().equals(ItemType.SERIALIZED)) {
416
                // TODO:handle null
417
                if (serializedInventoryItemMap.get(item.getId()) == null || itemIdCustomFofoOrderItemMap.get(item.getId()).getSerialNumberDetails().size() != serializedInventoryItemMap.get(item.getId()).size()) {
24440 amit.gupta 418
 
32145 tejbeer 419
                    List<String> invalidSerialNumbers = itemIdCustomFofoOrderItemMap.get(item.getId()).getSerialNumberDetails().stream().map(x -> x.getSerialNumber()).collect(Collectors.toList());
420
                    throw new ProfitMandiBusinessException("invalidSerialNumbers", invalidSerialNumbers, "FFORDR_1004");
421
                }
422
                List<String> serialNumberList = liveDemoBillingRespository.selectAllSerialNumber();
24823 amit.gupta 423
 
32145 tejbeer 424
                Set<InventoryItem> inventoryItemsSerializedserialized = serializedInventoryItemMap.get(item.getId());
425
                for (InventoryItem inventoryItem : inventoryItemsSerializedserialized) {
426
                    inventoryItem.setGoodQuantity(0);
427
                    inventoryItemIdQuantityUsed.put(inventoryItem.getId(), 1);
428
                    if (serialNumberList.contains(inventoryItem.getSerialNumber())) {
429
                        LiveDemoSerialNumber liveDemoSerialNumber = liveDemoBillingRespository.selectBySerialNumber(inventoryItem.getSerialNumber());
430
                        liveDemoBillingRespository.delete(liveDemoSerialNumber);
431
                    }
432
                }
433
                inventoryItemsToBill.put(item.getId(), inventoryItemsSerializedserialized);
434
            } else {
435
                Set<InventoryItem> inventoryItemsNonSerialized = nonSerializedInventoryItemMap.get(item.getId());
436
                int quantityToBill = itemIdCustomFofoOrderItemMap.get(item.getId()).getQuantity();
437
                int totalLeft = quantityToBill;
438
                Set<InventoryItem> inventoryItemsNonSerializedUsed = new HashSet<>();
439
                if (inventoryItemsNonSerialized != null) {
440
                    for (InventoryItem inventoryItem : inventoryItemsNonSerialized) {
441
                        if (totalLeft > 0) {
442
                            int toUse = Math.min(totalLeft, inventoryItem.getGoodQuantity());
443
                            inventoryItemIdQuantityUsed.put(inventoryItem.getId(), toUse);
444
                            inventoryItem.setGoodQuantity(inventoryItem.getGoodQuantity() - toUse);
445
                            totalLeft = totalLeft - toUse;
446
                            inventoryItemsNonSerializedUsed.add(inventoryItem);
447
                        }
448
                    }
449
                }
23650 amit.gupta 450
 
32145 tejbeer 451
                if (totalLeft > 0) {
452
                    // not enough quanity for non-serialized
453
                    LOGGER.error("not enough quanity for non-serialized");
454
                    throw new ProfitMandiBusinessException("notEnoughQuantityForNonSerialized", totalLeft, "FFORDR_1005");
455
                }
456
                inventoryItemsToBill.put(item.getId(), inventoryItemsNonSerializedUsed);
457
            }
458
        }
23650 amit.gupta 459
 
32145 tejbeer 460
        Map<Integer, PriceModel> itemIdMopPriceMap = pricingService.getPurchasePriceMopPriceNotFound(itemIdCustomFofoOrderItemMap.keySet(), fofoId);
461
        LOGGER.info("itemIdMopMap {}", itemIdMopPriceMap);
462
        if (accessoriesDeals) {
463
            this.validateDpPrice(itemIdMopPriceMap, itemIdCustomFofoOrderItemMap);
464
        } else {
465
            this.validateMopPrice(itemIdMopPriceMap, itemIdCustomFofoOrderItemMap);
466
        }
23650 amit.gupta 467
 
32145 tejbeer 468
        String fofoStoreCode = this.getFofoStoreCode(fofoId);
469
        String documentNumber = null;
470
        if (noGST) {
471
            documentNumber = this.getSecurityDepositNumber(fofoId, fofoStoreCode);
24275 amit.gupta 472
 
32145 tejbeer 473
        } else {
474
            documentNumber = this.getInvoiceNumber(fofoId, fofoStoreCode);
475
        }
22859 ashik.ali 476
 
32145 tejbeer 477
        CustomerAddress customerAddress = customer.getCustomerAddress().stream().filter(x -> x.getId() == customCustomer.getCustomerAddressId()).findFirst().get();
23650 amit.gupta 478
 
32145 tejbeer 479
        FofoOrder fofoOrder = this.createAndGetFofoOrder(customer.getId(), customCustomer.getGstNumber(), fofoId, documentNumber, totalAmount, customerAddress.getId());
23650 amit.gupta 480
 
32145 tejbeer 481
        this.createPaymentOptions(fofoOrder, createOrderRequest.getPaymentOptions());
23650 amit.gupta 482
 
32145 tejbeer 483
        int retailerAddressId = retailerRegisteredAddressRepository.selectAddressIdByRetailerId(fofoId);
23650 amit.gupta 484
 
32145 tejbeer 485
        Address retailerAddress = addressRepository.selectById(retailerAddressId);
23650 amit.gupta 486
 
32145 tejbeer 487
        Integer stateId = null;
488
        if (customerAddress.getState().equals(retailerAddress.getState())) {
489
            try {
490
                State state = stateRepository.selectByName(customerAddress.getState());
491
                stateId = Long.valueOf(state.getId()).intValue();
492
            } catch (Exception e) {
493
                LOGGER.error("Unable to get state rates");
494
            }
495
        }
23650 amit.gupta 496
 
32145 tejbeer 497
        for (CustomFofoOrderItem customFofoOrderItem : createOrderRequest.getFofoOrderItems()) {
498
            FofoOrderItem fofoOrderItem = this.createAndGetFofoOrderItem(customFofoOrderItem, fofoOrder.getId(), itemMap, inventoryItemsToBill.get(customFofoOrderItem.getItemId()), stateId);
23650 amit.gupta 499
 
32145 tejbeer 500
            Set<InventoryItem> inventoryItems = inventoryItemsToBill.get(customFofoOrderItem.getItemId());
23650 amit.gupta 501
 
32145 tejbeer 502
            this.createFofoLineItem(fofoOrderItem.getId(), inventoryItems, inventoryItemIdQuantityUsed);
23650 amit.gupta 503
 
32145 tejbeer 504
            this.updateCurrentInventorySnapshot(currentInventorySnapshots, fofoId, customFofoOrderItem.getItemId(), customFofoOrderItem.getQuantity());
23650 amit.gupta 505
 
32145 tejbeer 506
            this.updateInventoryItemsAndScanRecord(inventoryItems, fofoId, inventoryItemIdQuantityUsed, fofoOrder.getId());
507
        }
23650 amit.gupta 508
 
32145 tejbeer 509
        List<FofoOrderItem> fofoItems = fofoOrderItemRepository.selectByOrderId(fofoOrder.getId());
25647 tejbeer 510
 
32145 tejbeer 511
        boolean smartPhone = false;
512
        for (FofoOrderItem fofoItem : fofoItems) {
513
            Item orderItem = itemRepository.selectById(fofoItem.getItemId());
514
            if (orderItem.isSmartPhone()) {
515
                smartPhone = true;
516
            }
31172 tejbeer 517
 
32145 tejbeer 518
        }
31172 tejbeer 519
 
32145 tejbeer 520
        if (smartPhone) {
521
            this.createAndGetHygieneData(fofoOrder.getId(), fofoOrder.getFofoId());
522
        }
523
        // insurance calculation is insurance flag is enabled
524
        //
525
        if (insuredModels.size() > 0) {
526
            LOGGER.info("Processing insurane for serialNumbers");
527
            LOGGER.info("InsuranceModels {}", insuredModels);
528
            LocalDate customerDateOfBirth = LocalDate.from(createOrderRequest.getCustomer().getDateOfBirth());
529
            fofoOrder.setDateOfBirth(customerDateOfBirth);
530
            for (InsuranceModel insuranceModel : insuredModels) {
531
                LOGGER.info("Creating insurance for {}", insuranceModel.getInsuranceId());
532
                insuranceService.createInsurance(fofoOrder, insuranceModel);
533
            }
534
        }
28339 tejbeer 535
 
32145 tejbeer 536
        schemeService.processSchemeOut(fofoOrder.getId(), fofoId);
31993 amit.gupta 537
 
32145 tejbeer 538
        if (createOrderRequest.getPoId() != 0) {
539
            PendingOrder po = pendingOrderRepository.selectById(createOrderRequest.getPoId());
540
            po.setBilledAmount(po.getBilledAmount() + totalAmount);
541
            PendingOrderItem poi = pendingOrderItemRepository.selectById(createOrderRequest.getPoItemId());
542
            poi.setStatus(OrderStatus.BILLED);
543
            poi.setBilledTimestamp(LocalDateTime.now());
544
        }
29515 tejbeer 545
 
32145 tejbeer 546
        LocalDate startDate = LocalDate.of(2023, 01, 13);
547
        LocalDate endDate = LocalDate.of(2023, 01, 27);
29515 tejbeer 548
 
32145 tejbeer 549
        if (smartPhone) {
550
            if (LocalDateTime.now().isAfter(startDate.atStartOfDay()) && LocalDateTime.now().isBefore(endDate.atStartOfDay())) {
29515 tejbeer 551
 
32145 tejbeer 552
                try {
553
                    this.sendAppDownloadBillingOffer(customer.getMobileNumber());
554
                } catch (Exception e) {
555
                    // TODO Auto-generated catch block
556
                    e.printStackTrace();
557
                }
558
                this.createScratchOffer(fofoOrder.getInvoiceNumber(), fofoOrder.getCustomerId());
559
            }
560
        }
561
        return fofoOrder.getId();
562
    }
23650 amit.gupta 563
 
32145 tejbeer 564
    public void sendAppDownloadBillingOffer(String mobileNumber) throws Exception {
565
        // In case of Cant receive SMS?
566
        // String mailMessage = java.text.MessageFormat.format(text, otp.getOtp());
567
        String sdurl = "http://surl.li/anhfn";
568
        try {
569
            if (prodEnv) {
570
                this.sendSms(APP_DOWNLOAD_BILLING_TEMPLATE_ID, String.format(APP_DOWNLOAD_BILLING_OFFER, sdurl), mobileNumber);
571
            }
572
        } catch (Exception e) {
573
            e.printStackTrace();
574
        }
29515 tejbeer 575
 
32145 tejbeer 576
    }
29515 tejbeer 577
 
32145 tejbeer 578
    public void sendSms(String dltTemplateId, String message, String mobileNumber) throws Exception {
579
        Map<String, String> map = new HashMap<>();
29515 tejbeer 580
 
32145 tejbeer 581
        map.put("sender", SENDER);
582
        map.put("messagetype", "TXT");
583
        map.put("apikey", "b866f7-c6c483-682ff5-054420-ad9e2c");
29515 tejbeer 584
 
32145 tejbeer 585
        map.put("numbers", "91" + mobileNumber);
586
        LOGGER.info("Message {}", message);
587
        // OTP Message Template
588
        map.put("message", message);
589
        map.put("dlttempid", dltTemplateId);
29515 tejbeer 590
 
32145 tejbeer 591
        String response = restClient.post(SMS_GATEWAY, map, new HashMap<>());
592
        LOGGER.info(response);
29515 tejbeer 593
 
32145 tejbeer 594
    }
29515 tejbeer 595
 
32145 tejbeer 596
    private void createScratchOffer(String invoiceNumber, int customerId) {
29515 tejbeer 597
 
32145 tejbeer 598
        /*
599
         * ScratchOffer so = new ScratchOffer(); so.setInvoiceNumber(invoiceNumber);
600
         * so.setOfferName(ScratchedGift.EW); so.setScratched(false);
601
         * so.setCreatedTimestamp(LocalDateTime.now());
602
         * so.setExpiredTimestamp(so.getCreatedTimestamp().plusDays(1));
603
         * so.setUnlockedAt(LocalDateTime.now()); so.setCustomerId(customerId);
604
         * scratchOfferRepository.persist(so);
605
         */
606
        LocalDateTime endDate = LocalDateTime.of(LocalDate.now().getYear(), LocalDate.now().getMonth(), 27, 21, 00);
29515 tejbeer 607
 
32145 tejbeer 608
        ScratchOffer so2 = new ScratchOffer();
609
        so2.setInvoiceNumber(invoiceNumber);
610
        so2.setScratched(false);
611
        so2.setCreatedTimestamp(LocalDateTime.now());
612
        so2.setExpiredTimestamp(endDate.plusDays(1).toLocalDate().atTime(LocalTime.MAX));
613
        so2.setOfferName(ScratchedGift.BLNT);
614
        so2.setCustomerId(customerId);
31057 tejbeer 615
 
32145 tejbeer 616
        LocalDate date = LocalDate.now();
617
        LocalDateTime seven = LocalDateTime.of(date.getYear(), date.getMonth(), date.getDayOfMonth(), 19, 0);
618
        LocalDateTime nine = LocalDateTime.of(date.getYear(), date.getMonth(), date.getDayOfMonth(), 21, 0);
31057 tejbeer 619
 
32145 tejbeer 620
        if (LocalDateTime.now().isAfter(seven)) {
621
            so2.setUnlockedAt(nine.plusDays(1));
622
        } else {
623
            so2.setUnlockedAt(nine);
624
        }
31057 tejbeer 625
 
32145 tejbeer 626
        scratchOfferRepository.persist(so2);
29515 tejbeer 627
 
32145 tejbeer 628
    }
29515 tejbeer 629
 
32145 tejbeer 630
    private HygieneData createAndGetHygieneData(int id, int fofoId) {
631
        HygieneData hygieneData = new HygieneData();
632
        hygieneData.setOrderId(id);
633
        hygieneData.setFofoId(fofoId);
634
        hygieneData.setCreatedTimestamp(LocalDateTime.now());
635
        hygieneDataRepository.persist(hygieneData);
25640 tejbeer 636
 
32145 tejbeer 637
        return hygieneData;
638
    }
25640 tejbeer 639
 
32145 tejbeer 640
    @Override
641
    public String getInvoiceNumber(int fofoId, String fofoStoreCode) {
642
        InvoiceNumberGenerationSequence invoiceNumberGenerationSequence = null;
643
        try {
644
            invoiceNumberGenerationSequence = invoiceNumberGenerationSequenceRepository.selectByFofoId(fofoId);
645
            invoiceNumberGenerationSequence.setSequence(invoiceNumberGenerationSequence.getSequence() + 1);
646
        } catch (ProfitMandiBusinessException profitMandiBusinessException) {
647
            invoiceNumberGenerationSequence = new InvoiceNumberGenerationSequence();
648
            invoiceNumberGenerationSequence.setFofoId(fofoId);
649
            invoiceNumberGenerationSequence.setPrefix(fofoStoreCode);
650
            invoiceNumberGenerationSequence.setSequence(1);
651
        }
652
        invoiceNumberGenerationSequenceRepository.persist(invoiceNumberGenerationSequence);
653
        return invoiceNumberGenerationSequence.getPrefix() + "/" + invoiceNumberGenerationSequence.getSequence();
654
    }
24275 amit.gupta 655
 
32145 tejbeer 656
    private String getSecurityDepositNumber(int fofoId, String fofoStoreCode) {
657
        InvoiceNumberGenerationSequence invoiceNumberGenerationSequence = null;
658
        try {
659
            invoiceNumberGenerationSequence = invoiceNumberGenerationSequenceRepository.selectByFofoId(fofoId);
660
            invoiceNumberGenerationSequence.setChallanNumberSequence(invoiceNumberGenerationSequence.getChallanNumberSequence() + 1);
661
        } catch (ProfitMandiBusinessException profitMandiBusinessException) {
662
            invoiceNumberGenerationSequence = new InvoiceNumberGenerationSequence();
663
            invoiceNumberGenerationSequence.setFofoId(fofoId);
664
            invoiceNumberGenerationSequence.setPrefix(fofoStoreCode);
665
            invoiceNumberGenerationSequence.setChallanNumberSequence(1);
666
        }
667
        invoiceNumberGenerationSequenceRepository.persist(invoiceNumberGenerationSequence);
668
        return invoiceNumberGenerationSequence.getPrefix() + "/SEC" + invoiceNumberGenerationSequence.getChallanNumberSequence();
669
    }
24226 amit.gupta 670
 
32145 tejbeer 671
    private Set<String> serialNumberDetailsToSerialNumbers(Set<SerialNumberDetail> serialNumberDetails) {
672
        Set<String> serialNumbers = new HashSet<>();
673
        for (SerialNumberDetail serialNumberDetail : serialNumberDetails) {
674
            if (serialNumberDetail.getSerialNumber() != null && !serialNumberDetail.getSerialNumber().isEmpty()) {
675
                serialNumbers.add(serialNumberDetail.getSerialNumber());
676
            }
677
        }
678
        return serialNumbers;
679
    }
23650 amit.gupta 680
 
32145 tejbeer 681
    @Override
682
    public InvoicePdfModel getInvoicePdfModel(int orderId) throws ProfitMandiBusinessException {
683
        FofoOrder fofoOrder = fofoOrderRepository.selectByOrderId(orderId);
684
        return this.getInvoicePdfModel(fofoOrder);
685
    }
23650 amit.gupta 686
 
32145 tejbeer 687
    @Override
688
    @Cacheable(value = "order.dummymodel", cacheManager = "oneDayCacheManager")
689
    public InvoicePdfModel getDummyPdfModel(String serialNumber) throws ProfitMandiBusinessException {
690
        List<WarehouseInventoryItem> warehouseInventoryItems = warehouseInventoryItemRepository.selectWarehouseInventoryItemBySerailNumbers(Arrays.asList(serialNumber));
691
        if (warehouseInventoryItems.size() > 0) {
692
            WarehouseInventoryItem warehouseInventoryItem = warehouseInventoryItems.get(0);
693
            int currentQuantity = warehouseInventoryItems.get(0).getCurrentQuantity();
694
            if (currentQuantity > 0) {
695
                throw new ProfitMandiBusinessException("Serial Number", serialNumber, "Serial Number exist in our warehouse");
696
            } else {
697
                try {
698
                    InventoryItem inventoryItem = inventoryItemRepository.selectBySerialNumber(serialNumber);
699
                    if (inventoryItem.getGoodQuantity() > 0) {
700
                        throw new ProfitMandiBusinessException("Serial Number", serialNumber, "Serial Number is not yet billed by the partner");
701
                    } else {
702
                        List<ScanRecord> scanRecords = scanRecordRepository.selectByInventoryItemId(inventoryItem.getId());
703
                        Optional<ScanRecord> scanRecord = scanRecords.stream().filter(x -> x.getOrderId() != 0).findFirst();
704
                        if (scanRecord.isPresent()) {
705
                            FofoOrder fofoOrder = fofoOrderRepository.selectByOrderId(scanRecord.get().getOrderId());
706
                            orderIdsConsumed.add(fofoOrder.getId());
707
                            return this.getInvoicePdfModel(fofoOrder);
708
                        } else {
709
                            throw new ProfitMandiBusinessException("Serial Number", serialNumber, "Serial Number returned by partner, but in transit");
710
                        }
711
                    }
712
                } catch (Exception e) {
713
                    int itemId = warehouseInventoryItem.getItemId();
714
                    if (serialNumberOrderIdMap.containsKey(serialNumber)) {
715
                        FofoOrder fofoOrder = fofoOrderRepository.selectByOrderId(serialNumberOrderIdMap.get(serialNumber));
716
                        InvoicePdfModel pdfModel = this.getInvoicePdfModel(fofoOrder.getId());
717
                        this.modifyDummyModel(fofoOrder, pdfModel, itemId, serialNumber);
718
                        return pdfModel;
719
                    }
720
                    // Map this serialNumber for dummy billing
721
                    LocalDateTime grnDate = warehouseInventoryItem.getCreated();
722
                    Random random = new Random();
723
                    int randomDays = random.ints(2, 15).findFirst().getAsInt();
724
                    LocalDateTime saleDate = grnDate.plusDays(randomDays);
725
                    if (saleDate.isAfter(LocalDate.now().atStartOfDay())) {
726
                        saleDate = LocalDateTime.now().minusDays(2);
727
                    }
728
                    Random offsetRandom = new Random();
729
                    int offset = offsetRandom.ints(2, 100).findFirst().getAsInt();
730
                    FofoOrder fofoOrder = fofoOrderRepository.selectFirstOrderAfterDate(saleDate, offset);
731
                    while (orderIdsConsumed.contains(fofoOrder.getId())) {
732
                        Random offsetRandom2 = new Random();
733
                        int offset2 = offsetRandom2.ints(2, 100).findFirst().getAsInt();
734
                        FofoOrder fofoOrder2 = fofoOrderRepository.selectFirstOrderAfterDate(saleDate, offset2);
735
                        if (fofoOrder2 != null) {
736
                            fofoOrder = fofoOrder2;
737
                        }
738
                    }
739
                    InvoicePdfModel pdfModel = this.getInvoicePdfModel(fofoOrder.getId());
740
                    orderIdsConsumed.add(fofoOrder.getId());
741
                    this.modifyDummyModel(fofoOrder, pdfModel, itemId, serialNumber);
742
                    return pdfModel;
27516 amit.gupta 743
 
32145 tejbeer 744
                }
745
            }
746
        } else {
747
            throw new ProfitMandiBusinessException("Serial Number", serialNumber, "Serial Number does not exist in our warehouse");
748
        }
749
    }
27516 amit.gupta 750
 
32145 tejbeer 751
    void modifyDummyModel(FofoOrder fofoOrder, InvoicePdfModel pdfModel, int itemId, String serialNumber) throws ProfitMandiBusinessException {
28166 tejbeer 752
 
32145 tejbeer 753
        int retailerAddressId = retailerRegisteredAddressRepository.selectAddressIdByRetailerId(fofoOrder.getFofoId());
27516 amit.gupta 754
 
32145 tejbeer 755
        Address retailerAddress = addressRepository.selectById(retailerAddressId);
756
        Customer customer = customerRepository.selectById(fofoOrder.getCustomerId());
27516 amit.gupta 757
 
32145 tejbeer 758
        CustomerAddress customerAddress = customer.getCustomerAddress().stream().filter(x -> x.getId() == fofoOrder.getCustomerAddressId()).findFirst().get();
27516 amit.gupta 759
 
32145 tejbeer 760
        Integer stateId = null;
761
        if (customerAddress.getState().equals(retailerAddress.getState())) {
762
            try {
763
                // stateId =
764
                // Long.valueOf(Utils.getStateInfo(customerAddress.getState()).getId()).intValue();
30527 tejbeer 765
 
32145 tejbeer 766
                stateId = Long.valueOf(stateRepository.selectByName(customerAddress.getState()).getId()).intValue();
767
            } catch (Exception e) {
768
                LOGGER.error("Unable to get state rates");
769
            }
770
        }
771
        CustomOrderItem cli = pdfModel.getOrderItems().stream().findFirst().get();
772
        List<FofoOrderItem> fofoOrderItems = Arrays.asList(this.getDummyFofoOrderItem(itemId, fofoOrder.getId(), serialNumber, stateId));
773
        pdfModel.setPaymentOptions(pdfModel.getPaymentOptions().stream().limit(1).collect(Collectors.toList()));
774
        CustomPaymentOption paymentOption = pdfModel.getPaymentOptions().get(0);
775
        paymentOption.setAmount(fofoOrderItems.get(0).getMop());
776
        Set<CustomOrderItem> customerFofoOrderItems = new HashSet<>();
777
        for (FofoOrderItem fofoOrderItem : fofoOrderItems) {
778
            CustomOrderItem customFofoOrderItem = new CustomOrderItem();
779
            float totalTaxRate = fofoOrderItem.getIgstRate() + fofoOrderItem.getSgstRate() + fofoOrderItem.getCgstRate();
780
            float taxableSellingPrice = fofoOrderItem.getSellingPrice() / (1 + totalTaxRate / 100);
781
            float taxableDiscountPrice = fofoOrderItem.getDiscount() / (1 + totalTaxRate / 100);
27516 amit.gupta 782
 
32145 tejbeer 783
            customFofoOrderItem.setAmount(fofoOrderItem.getQuantity() * (taxableSellingPrice - taxableDiscountPrice));
784
            customFofoOrderItem.setDescription(fofoOrderItem.getBrand() + " " + fofoOrderItem.getModelName() + " " + fofoOrderItem.getModelNumber() + "-" + fofoOrderItem.getColor());
785
            Set<String> serialNumbers = this.toSerialNumbers(fofoOrderItem.getFofoLineItems());
786
            // LOGGER.info("serialNumbers {}", serialNumbers);
787
            // LOGGER.info("serialNumbers is empty {}", serialNumbers.isEmpty());
788
            if (!serialNumbers.isEmpty()) {
789
                customFofoOrderItem.setDescription(
790
                        customFofoOrderItem.getDescription() + "\n IMEIS - " + String.join(", ", serialNumbers));
791
            }
792
            customFofoOrderItem.setRate(taxableSellingPrice);
793
            customFofoOrderItem.setDiscount(taxableDiscountPrice);
794
            customFofoOrderItem.setQuantity(fofoOrderItem.getQuantity());
795
            customFofoOrderItem.setNetAmount(
796
                    (fofoOrderItem.getSellingPrice() - fofoOrderItem.getDiscount()) * fofoOrderItem.getQuantity());
797
            float igstAmount = (customFofoOrderItem.getAmount() * fofoOrderItem.getIgstRate()) / 100;
798
            float cgstAmount = (customFofoOrderItem.getAmount() * fofoOrderItem.getCgstRate()) / 100;
799
            float sgstAmount = (customFofoOrderItem.getAmount() * fofoOrderItem.getSgstRate()) / 100;
800
            customFofoOrderItem.setIgstRate(fofoOrderItem.getIgstRate());
801
            customFofoOrderItem.setIgstAmount(igstAmount);
802
            customFofoOrderItem.setCgstRate(fofoOrderItem.getCgstRate());
803
            customFofoOrderItem.setCgstAmount(cgstAmount);
804
            customFofoOrderItem.setSgstRate(fofoOrderItem.getSgstRate());
805
            customFofoOrderItem.setSgstAmount(sgstAmount);
806
            customFofoOrderItem.setHsnCode(fofoOrderItem.getHsnCode());
807
            customerFofoOrderItems.add(customFofoOrderItem);
808
        }
809
        pdfModel.setTotalAmount(paymentOption.getAmount());
810
        pdfModel.setOrderItems(customerFofoOrderItems);
28166 tejbeer 811
 
32145 tejbeer 812
    }
27516 amit.gupta 813
 
32145 tejbeer 814
    private InvoicePdfModel getInvoicePdfModel(FofoOrder fofoOrder) throws ProfitMandiBusinessException {
23650 amit.gupta 815
 
32145 tejbeer 816
        List<PaymentOptionTransaction> paymentOptionTransactions = paymentOptionTransactionRepository.selectByReferenceIdAndTypes(fofoOrder.getId(), Arrays.asList(PaymentOptionReferenceType.ORDER, PaymentOptionReferenceType.INSURANCE));
23650 amit.gupta 817
 
32145 tejbeer 818
        List<CustomPaymentOption> paymentOptions = new ArrayList<>();
23552 amit.gupta 819
 
32145 tejbeer 820
        InvoicePdfModel pdfModel = new InvoicePdfModel();
821
        for (PaymentOptionTransaction paymentOptionTransaction : paymentOptionTransactions) {
822
            CustomPaymentOption cpi = new CustomPaymentOption();
823
            cpi.setAmount(paymentOptionTransaction.getAmount());
824
            cpi.setPaymentOption(
825
                    paymentOptionRepository.selectById(paymentOptionTransaction.getPaymentOptionId()).getName());
826
            paymentOptions.add(cpi);
827
        }
828
        List<FofoOrderItem> fofoOrderItems = this.getByOrderId(fofoOrder.getId());
24215 amit.gupta 829
 
32145 tejbeer 830
        pdfModel.setTitle("Retailer Invoice");
831
        Optional<FofoOrderItem> fofoOrderItemOptional = fofoOrderItems.stream().findAny();
832
        if (fofoOrderItemOptional.isPresent() && fofoOrderItemOptional.get().equals("NOGST")) {
833
            pdfModel.setTitle("Security Deposit Receipt");
834
        }
835
        pdfModel.setPaymentOptions(paymentOptions);
836
        pdfModel.setAuther("SmartDukaan");
837
        pdfModel.setInvoiceDate(FormattingUtils.formatDate(fofoOrder.getCreateTimestamp()));
23650 amit.gupta 838
 
32145 tejbeer 839
        // insurance calculation
840
        List<InsurancePolicy> insurancePolicies = insurancePolicyRepository.selectByRetailerIdInvoiceNumber(fofoOrder.getInvoiceNumber());
841
        Set<CustomInsurancePolicy> customInsurancePolicies = new HashSet<>();
842
        final float totalInsuranceTaxRate = 18;
843
        for (InsurancePolicy insurancePolicy : insurancePolicies) {
844
            float taxableInsurancePrice = insurancePolicy.getSaleAmount() / (1 + totalInsuranceTaxRate / 100);
845
            CustomInsurancePolicy customInsurancePolicy = new CustomInsurancePolicy();
846
            customInsurancePolicy.setDescription(insurancePolicy.getPolicyPlan() + " for Device #" + insurancePolicy.getSerialNumber() + "\n Plan Reference - " + insurancePolicy.getPolicyNumber());
847
            customInsurancePolicy.setHsnCode("998716");
848
            customInsurancePolicy.setRate(taxableInsurancePrice);
849
            customInsurancePolicy.setIgstRate(18);
850
            customInsurancePolicy.setIgstAmount(taxableInsurancePrice * 18 / 100);
851
            customInsurancePolicy.setCgstRate(9);
852
            customInsurancePolicy.setCgstAmount(taxableInsurancePrice * 9 / 100);
853
            customInsurancePolicy.setSgstRate(9);
854
            customInsurancePolicy.setSgstAmount(taxableInsurancePrice * 9 / 100);
855
            customInsurancePolicy.setNetAmount(insurancePolicy.getSaleAmount());
856
            customInsurancePolicies.add(customInsurancePolicy);
857
        }
858
        pdfModel.setInsurancePolicies(customInsurancePolicies);
24275 amit.gupta 859
 
32145 tejbeer 860
        pdfModel.setCustomer(getCustomCustomer(fofoOrder));
861
        pdfModel.setInvoiceNumber(fofoOrder.getInvoiceNumber());
862
        pdfModel.setTotalAmount(fofoOrder.getTotalAmount());
23650 amit.gupta 863
 
32145 tejbeer 864
        Retailer retailer = retailerRepository.selectById(fofoOrder.getFofoId());
865
        PrivateDealUser privateDealUser = null;
866
        try {
867
            privateDealUser = privateDealUserRepository.selectById(retailer.getId());
868
        } catch (ProfitMandiBusinessException profitMandiBusinessException) {
869
            LOGGER.error("Private Deal User not found : ", profitMandiBusinessException);
870
        }
23650 amit.gupta 871
 
32145 tejbeer 872
        User user = userRepository.selectById(userAccountRepository.selectUserIdByRetailerId(retailer.getId()));
873
        CustomRetailer customRetailer = new CustomRetailer();
874
        customRetailer.setBusinessName(retailer.getName());
875
        customRetailer.setMobileNumber(user.getMobileNumber());
876
        // customRetailer.setTinNumber(retailer.getNumber());
877
        if (privateDealUser == null) {
878
            customRetailer.setGstNumber(null);
879
        } else {
880
            if (null != privateDealUser.getCounterId()) {
881
                Counter counter = counterRepository.selectById(privateDealUser.getCounterId());
882
                customRetailer.setGstNumber(counter.getGstin());
883
            } else {
884
                customRetailer.setGstNumber(null);
885
            }
886
        }
887
        Address retailerAddress = addressRepository.selectById(retailerRegisteredAddressRepository.selectAddressIdByRetailerId(retailer.getId()));
888
        customRetailer.setAddress(this.createCustomAddress(retailerAddress));
889
        pdfModel.setRetailer(customRetailer);
23650 amit.gupta 890
 
32145 tejbeer 891
        Set<CustomOrderItem> customerFofoOrderItems = new HashSet<>();
892
        for (FofoOrderItem fofoOrderItem : fofoOrderItems) {
893
            float discount = fofoOrderItem.getDiscount();
894
            CustomOrderItem customFofoOrderItem = new CustomOrderItem();
895
            float totalTaxRate = fofoOrderItem.getIgstRate() + fofoOrderItem.getSgstRate() + fofoOrderItem.getCgstRate();
896
            float taxableSellingPrice = (fofoOrderItem.getSellingPrice() + discount) / (1 + totalTaxRate / 100);
897
            float taxableDiscountPrice = discount / (1 + totalTaxRate / 100);
23650 amit.gupta 898
 
32145 tejbeer 899
            customFofoOrderItem.setAmount(fofoOrderItem.getQuantity() * (taxableSellingPrice - taxableDiscountPrice));
900
            customFofoOrderItem.setDescription(fofoOrderItem.getBrand() + " " + fofoOrderItem.getModelName() + " " + fofoOrderItem.getModelNumber() + "-" + fofoOrderItem.getColor());
901
            Set<String> serialNumbers = this.toSerialNumbers(fofoOrderItem.getFofoLineItems());
902
            // LOGGER.info("serialNumbers {}", serialNumbers);
903
            // LOGGER.info("serialNumbers is empty {}", serialNumbers.isEmpty());
904
            if (!serialNumbers.isEmpty()) {
905
                customFofoOrderItem.setDescription(
906
                        customFofoOrderItem.getDescription() + "\n IMEIS - " + String.join(", ", serialNumbers));
907
            }
908
            customFofoOrderItem.setRate(taxableSellingPrice);
909
            customFofoOrderItem.setDiscount(taxableDiscountPrice);
910
            customFofoOrderItem.setQuantity(fofoOrderItem.getQuantity());
911
            customFofoOrderItem.setNetAmount(fofoOrderItem.getSellingPrice() * fofoOrderItem.getQuantity());
912
            float igstAmount = (customFofoOrderItem.getAmount() * fofoOrderItem.getIgstRate()) / 100;
913
            float cgstAmount = (customFofoOrderItem.getAmount() * fofoOrderItem.getCgstRate()) / 100;
914
            float sgstAmount = (customFofoOrderItem.getAmount() * fofoOrderItem.getSgstRate()) / 100;
915
            customFofoOrderItem.setIgstRate(fofoOrderItem.getIgstRate());
916
            customFofoOrderItem.setIgstAmount(igstAmount);
917
            customFofoOrderItem.setCgstRate(fofoOrderItem.getCgstRate());
918
            customFofoOrderItem.setCgstAmount(cgstAmount);
919
            customFofoOrderItem.setSgstRate(fofoOrderItem.getSgstRate());
920
            customFofoOrderItem.setSgstAmount(sgstAmount);
921
            customFofoOrderItem.setHsnCode(fofoOrderItem.getHsnCode());
922
            customerFofoOrderItems.add(customFofoOrderItem);
923
        }
924
        pdfModel.setOrderItems(customerFofoOrderItems);
925
        String partnerAddressStateCode = stateRepository.selectByName(pdfModel.getRetailer().getAddress().getState()).getCode();
926
        String customerAddressStateCode = stateRepository.selectByName(pdfModel.getCustomer().getAddress().getState()).getCode();
927
        pdfModel.setPartnerAddressStateCode(partnerAddressStateCode);
928
        pdfModel.setCustomerAddressStateCode(customerAddressStateCode);
929
        pdfModel.setCancelled(fofoOrder.getCancelledTimestamp() != null);
930
        List<String> tncs = new ArrayList<>();
931
        tncs.add("I agree that goods received are in good working condition");
932
        tncs.add("Goods once sold cannot be exchanged or taken back");
933
        tncs.add("Warranty for the goods received by me is the responsibility of the manufacturer only.");
934
        tncs.add("Customer needs to activate the handset at the time of delivery to be eligible for the discount");
935
        tncs.add(
936
                "Tempered Glass Replacement will be done only for the Mobile Phone which was purchased from SmartDukaan");
937
        tncs.add(
938
                "Customers requesting Tempered Glass Replacement will have to bring the broken tempered glass, either pasted on the phone or along with the phone");
939
        tncs.add("Service fee of Rs.20 will be chargeable for each Tempered Glass Replacement");
940
        if (pdfModel.getInsurancePolicies() != null && pdfModel.getInsurancePolicies().size() > 0) {
941
            tncs.add("Damage protection provided is the responisibility of Protection Provider only");
942
        }
943
        pdfModel.setTncs(tncs);
944
        return pdfModel;
23650 amit.gupta 945
 
32145 tejbeer 946
    }
23650 amit.gupta 947
 
32145 tejbeer 948
    private CustomCustomer getCustomCustomer(FofoOrder fofoOrder) throws ProfitMandiBusinessException {
949
        Customer customer = customerRepository.selectById(fofoOrder.getCustomerId());
950
        CustomCustomer customCustomer = new CustomCustomer();
951
        customCustomer.setFirstName(customer.getFirstName());
952
        customCustomer.setLastName(customer.getLastName());
953
        customCustomer.setEmailId(customer.getEmailId());
954
        customCustomer.setMobileNumber(customer.getMobileNumber());
955
        customCustomer.setGstNumber(fofoOrder.getCustomerGstNumber());
956
        CustomerAddress customerAddress = customerAddressRepository.selectById(fofoOrder.getCustomerAddressId());
957
        customCustomer.setAddress(this.createCustomAddress(customerAddress));
958
        return customCustomer;
959
    }
23655 amit.gupta 960
 
32145 tejbeer 961
    @Override
962
    public InvoicePdfModel getInvoicePdfModel(int fofoId, int orderId) throws ProfitMandiBusinessException {
963
        FofoOrder fofoOrder = fofoOrderRepository.selectByFofoIdAndOrderId(fofoId, orderId);
964
        return this.getInvoicePdfModel(fofoOrder);
965
    }
23650 amit.gupta 966
 
32145 tejbeer 967
    public String getBillingAddress(CustomerAddress customerAddress) {
968
        StringBuilder address = new StringBuilder();
969
        if ((customerAddress.getLine1() != null) && (!customerAddress.getLine1().isEmpty())) {
970
            address.append(customerAddress.getLine1());
971
            address.append(", ");
972
        }
22859 ashik.ali 973
 
32145 tejbeer 974
        if ((customerAddress.getLine2() != null) && (!customerAddress.getLine2().isEmpty())) {
975
            address.append(customerAddress.getLine2());
976
            address.append(", ");
977
        }
22859 ashik.ali 978
 
32145 tejbeer 979
        if ((customerAddress.getLandmark() != null) && (!customerAddress.getLandmark().isEmpty())) {
980
            address.append(customerAddress.getLandmark());
981
            address.append(", ");
982
        }
22859 ashik.ali 983
 
32145 tejbeer 984
        if ((customerAddress.getCity() != null) && (!customerAddress.getCity().isEmpty())) {
985
            address.append(customerAddress.getCity());
986
            address.append(", ");
987
        }
22859 ashik.ali 988
 
32145 tejbeer 989
        if ((customerAddress.getState() != null) && (!customerAddress.getState().isEmpty())) {
990
            address.append(customerAddress.getState());
991
        }
22859 ashik.ali 992
 
32145 tejbeer 993
        if ((customerAddress.getPinCode() != null) && (!customerAddress.getPinCode().isEmpty())) {
994
            address.append("- ");
995
            address.append(customerAddress.getPinCode());
996
        }
22859 ashik.ali 997
 
32145 tejbeer 998
        return address.toString();
999
    }
23650 amit.gupta 1000
 
32145 tejbeer 1001
    @Override
1002
    public List<CartFofo> cartCheckout(String cartJson) throws ProfitMandiBusinessException {
1003
        try {
1004
            JSONObject cartObject = new JSONObject(cartJson);
1005
            Iterator<?> keys = cartObject.keys();
23650 amit.gupta 1006
 
32145 tejbeer 1007
            Set<Integer> itemIds = new HashSet<>();
1008
            List<CartFofo> cartItems = new ArrayList<CartFofo>();
23650 amit.gupta 1009
 
32145 tejbeer 1010
            while (keys.hasNext()) {
1011
                String key = (String) keys.next();
1012
                if (cartObject.get(key) instanceof JSONObject) {
1013
                    LOGGER.info(cartObject.get(key).toString());
1014
                }
1015
                CartFofo cf = new CartFofo();
1016
                cf.setItemId(cartObject.getJSONObject(key).getInt("itemId"));
1017
                cf.setQuantity(cartObject.getJSONObject(key).getInt("quantity"));
1018
                if (cartObject.getJSONObject(key).has("poId")) {
23650 amit.gupta 1019
 
32145 tejbeer 1020
                    cf.setPoId(cartObject.getJSONObject(key).getInt("poId"));
1021
                    cf.setPoItemId(cartObject.getJSONObject(key).getInt("poItemId"));
1022
                }
1023
                if (cf.getQuantity() <= 0) {
1024
                    continue;
1025
                }
1026
                cartItems.add(cf);
1027
                itemIds.add(cartObject.getJSONObject(key).getInt("itemId"));
1028
            }
1029
            Map<Integer, Item> itemMap = new HashMap<Integer, Item>();
1030
            if (itemIds.size() > 0) {
1031
                List<Item> items = itemRepository.selectByIds(itemIds);
1032
                for (Item i : items) {
1033
                    itemMap.put(i.getId(), i);
1034
                }
23650 amit.gupta 1035
 
32145 tejbeer 1036
            }
1037
            for (CartFofo cf : cartItems) {
1038
                Item i = itemMap.get(cf.getItemId());
1039
                if (i == null) {
1040
                    continue;
1041
                }
1042
                cf.setDisplayName(getValidName(i.getBrand()) + " " + getValidName(i.getModelName()) + " " + getValidName(i.getModelNumber()) + " " + getValidName(i.getColor()).replaceAll("\\s+", " "));
1043
                cf.setItemType(i.getType());
1044
            }
1045
            return cartItems;
1046
        } catch (Exception e) {
1047
            LOGGER.error("Unable to Prepare cart to place order...", e);
1048
            throw new ProfitMandiBusinessException("cartData", cartJson, "FFORDR_1006");
1049
        }
1050
    }
23650 amit.gupta 1051
 
32145 tejbeer 1052
    @Override
1053
    public Map<String, Object> getSaleHistory(int fofoId, SearchType searchType, String searchValue, LocalDateTime startDate, LocalDateTime endDate, int offset, int limit) throws ProfitMandiBusinessException {
1054
        long countItems = 0;
1055
        List<FofoOrder> fofoOrders = new ArrayList<>();
23650 amit.gupta 1056
 
32145 tejbeer 1057
        if (searchType == SearchType.CUSTOMER_MOBILE_NUMBER && !searchValue.isEmpty()) {
1058
            fofoOrders = fofoOrderRepository.selectByFofoIdAndCustomerMobileNumber(fofoId, searchValue, null, null, offset, limit);
1059
            countItems = fofoOrderRepository.selectCountByCustomerMobileNumber(fofoId, searchValue, null, null);
1060
        } else if (searchType == SearchType.CUSTOMER_NAME && !searchValue.isEmpty()) {
1061
            fofoOrders = fofoOrderRepository.selectByFofoIdAndCustomerName(fofoId, searchValue, null, null, offset, limit);
1062
            countItems = fofoOrderRepository.selectCountByCustomerName(fofoId, searchValue, null, null);
1063
        } else if (searchType == SearchType.IMEI && !searchValue.isEmpty()) {
1064
            fofoOrders = fofoOrderRepository.selectByFofoIdAndSerialNumber(fofoId, searchValue, null, null, offset, limit);
1065
            countItems = fofoOrderRepository.selectCountBySerialNumber(fofoId, searchValue, null, null);
1066
        } else if (searchType == SearchType.ITEM_NAME && !searchValue.isEmpty()) {
1067
            fofoOrders = fofoOrderRepository.selectByFofoIdAndItemName(fofoId, searchValue, null, null, offset, limit);
1068
            countItems = fofoOrderRepository.selectCountByItemName(fofoId, searchValue, null, null);
1069
        } else if (searchType == SearchType.INVOICE_NUMBER && !searchValue.isEmpty()) {
1070
            fofoOrders = Arrays.asList(fofoOrderRepository.selectByFofoIdAndInvoiceNumber(fofoId, searchValue));
1071
            countItems = fofoOrders.size();
1072
        } else if (searchType == SearchType.DATE_RANGE) {
1073
            fofoOrders = fofoOrderRepository.selectByFofoId(fofoId, startDate, endDate, offset, limit);
1074
            countItems = fofoOrderRepository.selectCountByFofoId(fofoId, startDate, endDate);
1075
        }
1076
        Map<String, Object> map = new HashMap<>();
23650 amit.gupta 1077
 
32145 tejbeer 1078
        map.put("saleHistories", fofoOrders);
1079
        map.put("start", offset + 1);
1080
        map.put("size", countItems);
1081
        map.put("searchType", searchType);
1082
        map.put("searchTypes", SearchType.values());
1083
        map.put("startDate", startDate);
1084
        map.put("searchValue", searchValue);
1085
        map.put(ProfitMandiConstants.END_TIME, endDate);
1086
        if (fofoOrders.size() < limit) {
1087
            map.put("end", offset + fofoOrders.size());
1088
        } else {
1089
            map.put("end", offset + limit);
1090
        }
1091
        return map;
1092
    }
30426 tejbeer 1093
 
32145 tejbeer 1094
    public ResponseEntity<?> downloadReportInCsv(org.apache.commons.io.output.ByteArrayOutputStream baos, List<List<?>> rows, String fileName) {
1095
        final HttpHeaders headers = new HttpHeaders();
1096
        headers.set("Content-Type", "text/csv");
30426 tejbeer 1097
 
32145 tejbeer 1098
        headers.set("Content-disposition", "inline; filename=" + fileName + ".csv");
1099
        headers.setContentLength(baos.toByteArray().length);
23202 ashik.ali 1100
 
32145 tejbeer 1101
        final InputStream inputStream = new ByteArrayInputStream(baos.toByteArray());
1102
        final InputStreamResource inputStreamResource = new InputStreamResource(inputStream);
30426 tejbeer 1103
 
32145 tejbeer 1104
        return new ResponseEntity<InputStreamResource>(inputStreamResource, headers, HttpStatus.OK);
1105
    }
30157 manish 1106
 
32145 tejbeer 1107
    @Override
1108
    public Map<String, Object> getSaleHistoryPaginated(int fofoId, SearchType searchType, String searchValue, LocalDateTime startDate, LocalDateTime endDate, int offset, int limit) throws ProfitMandiBusinessException {
1109
        List<FofoOrder> fofoOrders = new ArrayList<>();
23650 amit.gupta 1110
 
32145 tejbeer 1111
        if (searchType == SearchType.CUSTOMER_MOBILE_NUMBER && !searchValue.isEmpty()) {
1112
            fofoOrders = fofoOrderRepository.selectByFofoIdAndCustomerMobileNumber(fofoId, searchValue, startDate, endDate, offset, limit);
1113
        } else if (searchType == SearchType.CUSTOMER_NAME && !searchValue.isEmpty()) {
1114
            fofoOrders = fofoOrderRepository.selectByFofoIdAndCustomerName(fofoId, searchValue, startDate, endDate, offset, limit);
1115
        } else if (searchType == SearchType.IMEI && !searchValue.isEmpty()) {
1116
            fofoOrders = fofoOrderRepository.selectByFofoIdAndSerialNumber(fofoId, searchValue, startDate, endDate, offset, limit);
1117
        } else if (searchType == SearchType.ITEM_NAME && !searchValue.isEmpty()) {
1118
            fofoOrders = fofoOrderRepository.selectByFofoIdAndItemName(fofoId, searchValue, startDate, endDate, offset, limit);
24275 amit.gupta 1119
 
32145 tejbeer 1120
        } else if (searchType == SearchType.DATE_RANGE) {
1121
            fofoOrders = fofoOrderRepository.selectByFofoId(fofoId, startDate, endDate, offset, limit);
1122
        }
1123
        Map<String, Object> map = new HashMap<>();
1124
        map.put("saleHistories", fofoOrders);
1125
        map.put("searchType", searchType);
1126
        map.put("searchTypes", SearchType.values());
1127
        map.put("startDate", startDate);
1128
        map.put("searchValue", searchValue);
1129
        map.put(ProfitMandiConstants.END_TIME, endDate);
1130
        return map;
1131
    }
23650 amit.gupta 1132
 
32145 tejbeer 1133
    private String getFofoStoreCode(int fofoId) throws ProfitMandiBusinessException {
1134
        FofoStore fofoStore = fofoStoreRepository.selectByRetailerId(fofoId);
1135
        return fofoStore.getCode();
1136
    }
23650 amit.gupta 1137
 
32145 tejbeer 1138
    private String getValidName(String name) {
1139
        return name != null ? name : "";
1140
    }
23650 amit.gupta 1141
 
32145 tejbeer 1142
    private Set<String> toSerialNumbers(Set<FofoLineItem> fofoLineItems) {
1143
        Set<String> serialNumbers = new HashSet<>();
1144
        for (FofoLineItem fofoLineItem : fofoLineItems) {
1145
            if (fofoLineItem.getSerialNumber() != null && !fofoLineItem.getSerialNumber().isEmpty()) {
1146
                serialNumbers.add(fofoLineItem.getSerialNumber());
1147
            }
1148
        }
1149
        return serialNumbers;
1150
    }
23650 amit.gupta 1151
 
32145 tejbeer 1152
    private void validateDpPrice(Map<Integer, PriceModel> itemIdMopPriceMap, Map<Integer, CustomFofoOrderItem> itemIdCustomFofoLineItemMap) throws ProfitMandiBusinessException {
1153
        for (Map.Entry<Integer, CustomFofoOrderItem> entry : itemIdCustomFofoLineItemMap.entrySet()) {
1154
            int itemId = entry.getKey();
1155
            CustomFofoOrderItem customFofoOrderItem = entry.getValue();
1156
            LOGGER.info("CustomFofoOrderItem -- {}", customFofoOrderItem);
1157
            PriceModel priceModel = itemIdMopPriceMap.get(itemId);
1158
            Item item = itemRepository.selectById(itemId);
1159
            if (!item.getBrand().equals("Live Demo") && (item.getCategoryId() == ProfitMandiConstants.MOBILE_CATEGORY_ID || item.getCategoryId() == ProfitMandiConstants.TABLET_CATEGORY_ID || item.getCategoryId() == ProfitMandiConstants.LED_CATEGORY_ID) && customFofoOrderItem.getSerialNumberDetails().stream().filter(x -> org.apache.commons.lang.StringUtils.isNotEmpty(x.getSerialNumber())).collect(Collectors.toList()).size() > 0) {
1160
                if (Utils.compareFloat(priceModel.getPrice(), customFofoOrderItem.getSellingPrice() + customFofoOrderItem.getDiscountAmount()) > 0) {
1161
                    throw new ProfitMandiBusinessException("Selling Price for ", item.getItemDescription(), "FFORDR_1010");
1162
                }
1163
            } else {
1164
                if (!item.getBrand().equals("Live Demo") && priceModel.getPurchasePrice() > customFofoOrderItem.getSellingPrice()) {
1165
                    throw new ProfitMandiBusinessException("Selling Price", itemRepository.selectById(itemId).getItemDescription(), "Selling Price should not be less than DP");
1166
                }
1167
            }
1168
        }
1169
    }
24275 amit.gupta 1170
 
32145 tejbeer 1171
    private void validateMopPrice(Map<Integer, PriceModel> itemIdMopPriceMap, Map<Integer, CustomFofoOrderItem> itemIdCustomFofoLineItemMap) throws ProfitMandiBusinessException {
1172
        Map<Integer, Float> invalidMopItemIdPriceMap = new HashMap<>();
1173
        for (Map.Entry<Integer, PriceModel> entry : itemIdMopPriceMap.entrySet()) {
1174
            CustomFofoOrderItem customFofoOrderItem = itemIdCustomFofoLineItemMap.get(entry.getKey());
1175
            Item item = itemRepository.selectById(customFofoOrderItem.getItemId());
1176
            if (!(item.getBrand().equals("Live Demo") || item.getCategoryId() != ProfitMandiConstants.MOBILE_CATEGORY_ID || item.getCategoryId() != ProfitMandiConstants.TABLET_CATEGORY_ID) && customFofoOrderItem.getSellingPrice() + customFofoOrderItem.getDiscountAmount() < entry.getValue().getPrice()) {
1177
                invalidMopItemIdPriceMap.put(entry.getKey(), customFofoOrderItem.getSellingPrice());
1178
            }
1179
        }
23650 amit.gupta 1180
 
32145 tejbeer 1181
        if (!invalidMopItemIdPriceMap.isEmpty()) {
1182
            LOGGER.error("Invalid itemIds selling prices{} should be greater than mop prices {}", invalidMopItemIdPriceMap, itemIdMopPriceMap);
1183
            throw new ProfitMandiBusinessException("invalidMopItemIdPrice", invalidMopItemIdPriceMap, "FFORDR_1010");
1184
        }
23650 amit.gupta 1185
 
32145 tejbeer 1186
    }
23650 amit.gupta 1187
 
32145 tejbeer 1188
    private void updateInventoryItemsAndScanRecord(Set<InventoryItem> inventoryItems, int fofoId, Map<Integer, Integer> inventoryItemQuantityUsed, int fofoOrderId) {
1189
        for (InventoryItem inventoryItem : inventoryItems) {
1190
            inventoryItem.setLastScanType(ScanType.SALE);
1191
            ScanRecord scanRecord = new ScanRecord();
1192
            scanRecord.setInventoryItemId(inventoryItem.getId());
1193
            scanRecord.setFofoId(fofoId);
1194
            scanRecord.setOrderId(fofoOrderId);
1195
            // correct this
1196
            scanRecord.setQuantity(inventoryItemQuantityUsed.get(inventoryItem.getId()));
1197
            scanRecord.setType(ScanType.SALE);
1198
            scanRecordRepository.persist(scanRecord);
1199
            purchaseReturnItemRepository.deleteById(inventoryItem.getId());
23650 amit.gupta 1200
 
32145 tejbeer 1201
        }
1202
    }
23650 amit.gupta 1203
 
32145 tejbeer 1204
    private void createFofoLineItem(int fofoOrderItemId, Set<InventoryItem> inventoryItems, Map<Integer, Integer> inventoryItemIdQuantityUsed) {
1205
        for (InventoryItem inventoryItem : inventoryItems) {
1206
            FofoLineItem fofoLineItem = new FofoLineItem();
1207
            fofoLineItem.setFofoOrderItemId(fofoOrderItemId);
1208
            fofoLineItem.setSerialNumber(inventoryItem.getSerialNumber());
1209
            fofoLineItem.setInventoryItemId(inventoryItem.getId());
1210
            fofoLineItem.setQuantity(inventoryItemIdQuantityUsed.get(inventoryItem.getId()));
1211
            fofoLineItemRepository.persist(fofoLineItem);
1212
        }
1213
    }
23650 amit.gupta 1214
 
32145 tejbeer 1215
    private FofoOrderItem createAndGetFofoOrderItem(CustomFofoOrderItem customFofoOrderItem, int fofoOrderId, Map<Integer, Item> itemMap, Set<InventoryItem> inventoryItems, Integer stateId) throws ProfitMandiBusinessException {
1216
        FofoOrderItem fofoOrderItem = new FofoOrderItem();
1217
        fofoOrderItem.setItemId(customFofoOrderItem.getItemId());
1218
        fofoOrderItem.setQuantity(customFofoOrderItem.getQuantity());
1219
        fofoOrderItem.setSellingPrice(customFofoOrderItem.getSellingPrice());
1220
        fofoOrderItem.setOrderId(fofoOrderId);
1221
        TagListing tl = tagListingRepository.selectByItemId(customFofoOrderItem.getItemId());
1222
        // In case listing gets removed rebill it using the selling price
1223
        if (tl != null) {
1224
            fofoOrderItem.setDp(tl.getSellingPrice());
1225
            fofoOrderItem.setMop(tl.getMop());
1226
        } else {
1227
            fofoOrderItem.setDp(customFofoOrderItem.getSellingPrice());
1228
            fofoOrderItem.setMop(customFofoOrderItem.getSellingPrice());
1229
        }
1230
        fofoOrderItem.setDiscount(customFofoOrderItem.getDiscountAmount());
24823 amit.gupta 1231
 
32145 tejbeer 1232
        Item item = itemMap.get(customFofoOrderItem.getItemId());
1233
        Map<Integer, GstRate> itemIdStateTaxRateMap = null;
1234
        if (stateId != null) {
1235
            itemIdStateTaxRateMap = stateGstRateRepository.getStateTaxRate(new ArrayList<>(itemMap.keySet()), stateId);
1236
        } else {
1237
            itemIdStateTaxRateMap = stateGstRateRepository.getIgstTaxRate(new ArrayList<>(itemMap.keySet()));
1238
        }
1239
        for (InventoryItem inventoryItem : inventoryItems) {
23650 amit.gupta 1240
 
32145 tejbeer 1241
            fofoOrderItem.setIgstRate(itemIdStateTaxRateMap.get(inventoryItem.getItemId()).getIgstRate());
23650 amit.gupta 1242
 
32145 tejbeer 1243
            fofoOrderItem.setCgstRate(itemIdStateTaxRateMap.get(inventoryItem.getItemId()).getCgstRate());
1244
            fofoOrderItem.setSgstRate(itemIdStateTaxRateMap.get(inventoryItem.getItemId()).getSgstRate());
27516 amit.gupta 1245
 
1246
 
32145 tejbeer 1247
            fofoOrderItem.setHsnCode(inventoryItem.getHsnCode());
1248
            break;
1249
        }
1250
        fofoOrderItem.setBrand(item.getBrand());
1251
        fofoOrderItem.setModelName(item.getModelName());
1252
        fofoOrderItem.setModelNumber(item.getModelNumber());
1253
        fofoOrderItem.setColor(item.getColor());
1254
        fofoOrderItemRepository.persist(fofoOrderItem);
1255
        return fofoOrderItem;
1256
    }
27516 amit.gupta 1257
 
32145 tejbeer 1258
    private FofoOrderItem getDummyFofoOrderItem(int itemId, int fofoOrderId, String serialNumber, Integer stateId) throws ProfitMandiBusinessException {
1259
        Item item = itemRepository.selectById(itemId);
1260
        TagListing tl = tagListingRepository.selectByItemId(itemId);
1261
        FofoOrderItem fofoOrderItem = new FofoOrderItem();
1262
        fofoOrderItem.setItemId(itemId);
1263
        fofoOrderItem.setQuantity(1);
1264
        fofoOrderItem.setSellingPrice(tl.getMop());
1265
        fofoOrderItem.setOrderId(fofoOrderId);
1266
        // In case listing gets removed rebill it using the selling price
1267
        fofoOrderItem.setDp(tl.getSellingPrice());
1268
        fofoOrderItem.setMop(tl.getMop());
1269
        fofoOrderItem.setDiscount(0);
27516 amit.gupta 1270
 
32145 tejbeer 1271
        Map<Integer, GstRate> itemIdStateTaxRateMap = null;
1272
        if (stateId != null) {
1273
            itemIdStateTaxRateMap = stateGstRateRepository.getStateTaxRate(Arrays.asList(itemId), stateId);
1274
        } else {
1275
            itemIdStateTaxRateMap = stateGstRateRepository.getIgstTaxRate(Arrays.asList(itemId));
1276
        }
27516 amit.gupta 1277
 
32145 tejbeer 1278
        fofoOrderItem.setIgstRate(itemIdStateTaxRateMap.get(itemId).getIgstRate());
27516 amit.gupta 1279
 
32145 tejbeer 1280
        fofoOrderItem.setCgstRate(itemIdStateTaxRateMap.get(itemId).getCgstRate());
1281
        fofoOrderItem.setSgstRate(itemIdStateTaxRateMap.get(itemId).getSgstRate());
23650 amit.gupta 1282
 
1283
 
32145 tejbeer 1284
        fofoOrderItem.setHsnCode(item.getHsnCode());
1285
        fofoOrderItem.setBrand(item.getBrand());
1286
        fofoOrderItem.setModelName(item.getModelName());
1287
        fofoOrderItem.setModelNumber(item.getModelNumber());
1288
        fofoOrderItem.setColor(item.getColor());
23650 amit.gupta 1289
 
32145 tejbeer 1290
        Set<FofoLineItem> fofoLineItems = new HashSet<>();
1291
        FofoLineItem fli = new FofoLineItem();
1292
        fli.setQuantity(1);
1293
        fli.setSerialNumber(serialNumber);
1294
        fofoLineItems.add(fli);
1295
        fofoOrderItem.setFofoLineItems(fofoLineItems);
22859 ashik.ali 1296
 
32145 tejbeer 1297
        return fofoOrderItem;
1298
    }
22859 ashik.ali 1299
 
32145 tejbeer 1300
    private void updateCurrentInventorySnapshot(List<CurrentInventorySnapshot> currentInventorySnapshots, int fofoId, int itemId, int quantity) throws ProfitMandiBusinessException {
1301
        for (CurrentInventorySnapshot currentInventorySnapshot : currentInventorySnapshots) {
1302
            if (currentInventorySnapshot.getItemId() == itemId && currentInventorySnapshot.getFofoId() == fofoId) {
1303
                currentInventorySnapshotRepository.updateAvailabilityByItemIdAndFofoId(itemId, fofoId, currentInventorySnapshot.getAvailability() - quantity);
1304
            }
1305
        }
1306
    }
23650 amit.gupta 1307
 
32145 tejbeer 1308
    private void createPaymentOptions(FofoOrder fofoOrder, Set<CustomPaymentOption> customPaymentOptions) throws ProfitMandiBusinessException {
1309
        for (CustomPaymentOption customPaymentOption : customPaymentOptions) {
1310
            if (customPaymentOption.getAmount() > 0) {
1311
                PaymentOptionTransaction paymentOptionTransaction = new PaymentOptionTransaction();
1312
                paymentOptionTransaction.setReferenceId(fofoOrder.getId());
1313
                paymentOptionTransaction.setPaymentOptionId(customPaymentOption.getPaymentOptionId());
1314
                paymentOptionTransaction.setReferenceType(PaymentOptionReferenceType.ORDER);
1315
                paymentOptionTransaction.setAmount(customPaymentOption.getAmount());
1316
                paymentOptionTransaction.setFofoId(fofoOrder.getFofoId());
1317
                paymentOptionTransactionRepository.persist(paymentOptionTransaction);
1318
            }
1319
        }
1320
    }
22859 ashik.ali 1321
 
32145 tejbeer 1322
    private FofoOrder createAndGetFofoOrder(int customerId, String customerGstNumber, int fofoId, String documentNumber, float totalAmount, int customerAddressId) {
1323
        FofoOrder fofoOrder = new FofoOrder();
1324
        fofoOrder.setCustomerGstNumber(customerGstNumber);
1325
        fofoOrder.setCustomerId(customerId);
1326
        fofoOrder.setFofoId(fofoId);
1327
        fofoOrder.setInvoiceNumber(documentNumber);
1328
        fofoOrder.setTotalAmount(totalAmount);
1329
        fofoOrder.setCustomerAddressId(customerAddressId);
1330
        fofoOrderRepository.persist(fofoOrder);
1331
        return fofoOrder;
1332
    }
23650 amit.gupta 1333
 
32145 tejbeer 1334
    private void validateItemsSerializedNonSerialized(List<Item> items, Map<Integer, CustomFofoOrderItem> customFofoOrderItemMap) throws ProfitMandiBusinessException {
1335
        List<Integer> invalidItemIdSerialNumbers = new ArrayList<Integer>();
1336
        List<Integer> itemIdNonSerializedSerialNumbers = new ArrayList<Integer>();
1337
        for (Item i : items) {
1338
            CustomFofoOrderItem customFofoOrderItem = customFofoOrderItemMap.get(i.getId());
1339
            if (i.getType().equals(ItemType.SERIALIZED)) {
1340
                if (customFofoOrderItem == null || customFofoOrderItem.getSerialNumberDetails().isEmpty()) {
1341
                    invalidItemIdSerialNumbers.add(i.getId());
1342
                }
1343
            } else {
1344
                Set<String> serialNumbers = this.serialNumberDetailsToSerialNumbers(customFofoOrderItem.getSerialNumberDetails());
1345
                if (customFofoOrderItem == null || !serialNumbers.isEmpty()) {
1346
                    itemIdNonSerializedSerialNumbers.add(i.getId());
1347
                }
1348
            }
1349
        }
23650 amit.gupta 1350
 
32145 tejbeer 1351
        if (!invalidItemIdSerialNumbers.isEmpty()) {
1352
            LOGGER.error("Invalid itemId's serialNumbers for serialized{}", invalidItemIdSerialNumbers);
1353
            // itemId's are serialized you are saying these are not serialized
1354
            throw new ProfitMandiBusinessException("invalidItemIdSerialNumbers", invalidItemIdSerialNumbers, "FFORDR_1013");
1355
        }
22859 ashik.ali 1356
 
32145 tejbeer 1357
        if (!itemIdNonSerializedSerialNumbers.isEmpty()) {
1358
            LOGGER.error("Invalid itemId's serialNumbers for non serialized{}", itemIdNonSerializedSerialNumbers);
1359
            // itemId's are non serialized you are saying these are serialized
1360
            throw new ProfitMandiBusinessException("itemIdNonSerializedSerialNumbers", itemIdNonSerializedSerialNumbers, "FFORDR_1014");
1361
        }
1362
    }
22859 ashik.ali 1363
 
32145 tejbeer 1364
    private void validateCurrentInventorySnapshotQuantities(List<CurrentInventorySnapshot> currentInventorySnapshots, Map<Integer, CustomFofoOrderItem> itemIdCustomFofoOrderItemMap) throws ProfitMandiBusinessException {
1365
        if (itemIdCustomFofoOrderItemMap.keySet().size() != currentInventorySnapshots.size()) {
1366
            throw new ProfitMandiBusinessException("quantiiesSize", currentInventorySnapshots.size(), "");
1367
        }
1368
        List<ItemIdQuantityAvailability> itemIdQuantityAvailabilities = new ArrayList<>(); // this is for error
1369
        LOGGER.info("currentInventorySnapshots " + currentInventorySnapshots);
1370
        LOGGER.info("CustomFofoLineItemMap {}", itemIdCustomFofoOrderItemMap);
1371
        for (CurrentInventorySnapshot currentInventorySnapshot : currentInventorySnapshots) {
1372
            CustomFofoOrderItem customFofoOrderItem = itemIdCustomFofoOrderItemMap.get(currentInventorySnapshot.getItemId());
1373
            LOGGER.info("customFofoOrderItem {}", customFofoOrderItem);
1374
            if (customFofoOrderItem.getQuantity() > currentInventorySnapshot.getAvailability()) {
1375
                ItemIdQuantityAvailability itemIdQuantityAvailability = new ItemIdQuantityAvailability();
1376
                itemIdQuantityAvailability.setItemId(customFofoOrderItem.getItemId());
1377
                Quantity quantity = new Quantity();
1378
                quantity.setAvailable(currentInventorySnapshot.getAvailability());
1379
                quantity.setRequested(customFofoOrderItem.getQuantity());
1380
                itemIdQuantityAvailability.setQuantity(quantity);
1381
                itemIdQuantityAvailabilities.add(itemIdQuantityAvailability);
1382
            }
1383
        }
22859 ashik.ali 1384
 
32145 tejbeer 1385
        if (!itemIdQuantityAvailabilities.isEmpty()) {
1386
            // itemIdQuantity request is not valid
1387
            LOGGER.error("Requested quantities should not be greater than currently available quantities {}", itemIdQuantityAvailabilities);
1388
            throw new ProfitMandiBusinessException("itemIdQuantityAvailabilities", itemIdQuantityAvailabilities, "FFORDR_1015");
1389
        }
1390
    }
22859 ashik.ali 1391
 
32145 tejbeer 1392
    private int getItemIdFromSerialNumber(Map<Integer, CustomFofoOrderItem> itemIdCustomFofoOrderItemMap, String serialNumber) {
1393
        int itemId = 0;
1394
        for (Map.Entry<Integer, CustomFofoOrderItem> entry : itemIdCustomFofoOrderItemMap.entrySet()) {
1395
            Set<SerialNumberDetail> serialNumberDetails = entry.getValue().getSerialNumberDetails();
1396
            for (SerialNumberDetail serialNumberDetail : serialNumberDetails) {
1397
                if (serialNumberDetail.getSerialNumber().equals(serialNumber)) {
1398
                    itemId = entry.getKey();
1399
                    break;
1400
                }
1401
            }
1402
        }
1403
        return itemId;
1404
    }
23650 amit.gupta 1405
 
32145 tejbeer 1406
    private Map<Integer, Item> toItemMap(List<Item> items) {
1407
        Function<Item, Integer> itemIdFunction = new Function<Item, Integer>() {
1408
            @Override
1409
            public Integer apply(Item item) {
1410
                return item.getId();
1411
            }
1412
        };
1413
        Function<Item, Item> itemFunction = new Function<Item, Item>() {
1414
            @Override
1415
            public Item apply(Item item) {
1416
                return item;
1417
            }
1418
        };
1419
        return items.stream().collect(Collectors.toMap(itemIdFunction, itemFunction));
1420
    }
23650 amit.gupta 1421
 
32145 tejbeer 1422
    private void setCustomerAddress(CustomerAddress customerAddress, CustomAddress customAddress) {
1423
        customerAddress.setName(customAddress.getName());
1424
        customerAddress.setLastName(customAddress.getLastName());
1425
        customerAddress.setLine1(customAddress.getLine1());
1426
        customerAddress.setLine2(customAddress.getLine2());
1427
        customerAddress.setLandmark(customAddress.getLandmark());
1428
        customerAddress.setCity(customAddress.getCity());
1429
        customerAddress.setPinCode(customAddress.getPinCode());
1430
        customerAddress.setState(customAddress.getState());
1431
        customerAddress.setCountry(customAddress.getCountry());
1432
        customerAddress.setPhoneNumber(customAddress.getPhoneNumber());
1433
    }
23650 amit.gupta 1434
 
32145 tejbeer 1435
    private CustomAddress createCustomAddress(Address address) {
1436
        CustomAddress customAddress = new CustomAddress();
1437
        customAddress.setName(address.getName());
1438
        customAddress.setLine1(address.getLine1());
1439
        customAddress.setLine2(address.getLine2());
1440
        customAddress.setLandmark(address.getLandmark());
1441
        customAddress.setCity(address.getCity());
1442
        customAddress.setPinCode(address.getPinCode());
1443
        customAddress.setState(address.getState());
1444
        customAddress.setCountry(address.getCountry());
1445
        customAddress.setPhoneNumber(address.getPhoneNumber());
1446
        return customAddress;
1447
    }
23650 amit.gupta 1448
 
32145 tejbeer 1449
    private CustomAddress createCustomAddress(CustomerAddress customerAddress) {
1450
        CustomAddress customAddress = new CustomAddress();
1451
        customAddress.setName(customerAddress.getName());
1452
        customAddress.setLastName(customerAddress.getLastName());
1453
        customAddress.setLine1(customerAddress.getLine1());
1454
        customAddress.setLine2(customerAddress.getLine2());
1455
        customAddress.setLandmark(customerAddress.getLandmark());
1456
        customAddress.setCity(customerAddress.getCity());
1457
        customAddress.setPinCode(customerAddress.getPinCode());
1458
        customAddress.setState(customerAddress.getState());
1459
        customAddress.setCountry(customerAddress.getCountry());
1460
        customAddress.setPhoneNumber(customerAddress.getPhoneNumber());
1461
        return customAddress;
1462
    }
23650 amit.gupta 1463
 
32145 tejbeer 1464
    private void validatePaymentOptionsAndTotalAmount(Set<CustomPaymentOption> customPaymentOptions, float totalAmount) throws ProfitMandiBusinessException {
1465
        Set<Integer> paymentOptionIds = new HashSet<>();
23650 amit.gupta 1466
 
32145 tejbeer 1467
        float calculatedAmount = 0;
1468
        for (CustomPaymentOption customPaymentOption : customPaymentOptions) {
1469
            paymentOptionIds.add(customPaymentOption.getPaymentOptionId());
1470
            calculatedAmount = calculatedAmount + customPaymentOption.getAmount();
1471
        }
1472
        if (calculatedAmount != totalAmount) {
1473
            LOGGER.warn("Error occured while validating payment options amount - {} != TotalAmount {}", calculatedAmount, totalAmount);
1474
            throw new ProfitMandiBusinessException(ProfitMandiConstants.PAYMENT_OPTION_CALCULATED_AMOUNT, calculatedAmount, "FFORDR_1016");
1475
        }
23418 ashik.ali 1476
 
32145 tejbeer 1477
        List<Integer> foundPaymentOptionIds = paymentOptionRepository.selectIdsByIds(paymentOptionIds);
1478
        if (foundPaymentOptionIds.size() != paymentOptionIds.size()) {
1479
            paymentOptionIds.removeAll(foundPaymentOptionIds);
1480
            throw new ProfitMandiBusinessException(ProfitMandiConstants.PAYMENT_OPTION_ID, paymentOptionIds, "FFORDR_1017");
1481
        }
1482
    }
25101 amit.gupta 1483
 
32145 tejbeer 1484
    @Override
1485
    public List<FofoOrderItem> getByOrderId(int orderId) throws ProfitMandiBusinessException {
1486
        List<FofoOrderItem> fofoOrderItems = fofoOrderItemRepository.selectByOrderId(orderId);
1487
        if (!fofoOrderItems.isEmpty()) {
1488
            List<FofoOrderItem> newFofoOrderItems = new ArrayList<>();
1489
            Map<Integer, Set<FofoLineItem>> fofoOrderItemIdFofoLineItemsMap = this.toFofoOrderItemIdFofoLineItems(fofoOrderItems);
1490
            Iterator<FofoOrderItem> fofoOrderItemsIterator = fofoOrderItems.iterator();
1491
            while (fofoOrderItemsIterator.hasNext()) {
1492
                FofoOrderItem fofoOrderItem = fofoOrderItemsIterator.next();
1493
                fofoOrderItem.setFofoLineItems(fofoOrderItemIdFofoLineItemsMap.get(fofoOrderItem.getId()));
1494
                newFofoOrderItems.add(fofoOrderItem);
1495
                fofoOrderItemsIterator.remove();
1496
            }
1497
            fofoOrderItems = newFofoOrderItems;
1498
        }
1499
        return fofoOrderItems;
1500
    }
25101 amit.gupta 1501
 
32145 tejbeer 1502
    private Set<Integer> toFofoOrderItemIds(List<FofoOrderItem> fofoOrderItems) {
1503
        Function<FofoOrderItem, Integer> fofoOrderItemToFofoOrderItemIdFunction = new Function<FofoOrderItem, Integer>() {
1504
            @Override
1505
            public Integer apply(FofoOrderItem fofoOrderItem) {
1506
                return fofoOrderItem.getId();
1507
            }
1508
        };
1509
        return fofoOrderItems.stream().map(fofoOrderItemToFofoOrderItemIdFunction).collect(Collectors.toSet());
1510
    }
25101 amit.gupta 1511
 
32145 tejbeer 1512
    private Map<Integer, Set<FofoLineItem>> toFofoOrderItemIdFofoLineItems(List<FofoOrderItem> fofoOrderItems) {
1513
        Set<Integer> fofoOrderItemIds = this.toFofoOrderItemIds(fofoOrderItems);
1514
        List<FofoLineItem> fofoLineItems = fofoLineItemRepository.selectByFofoOrderItemIds(fofoOrderItemIds);
1515
        Map<Integer, Set<FofoLineItem>> fofoOrderItemIdFofoLineItemsMap = new HashMap<>();
1516
        for (FofoLineItem fofoLineItem : fofoLineItems) {
1517
            if (!fofoOrderItemIdFofoLineItemsMap.containsKey(fofoLineItem.getFofoOrderItemId())) {
1518
                Set<FofoLineItem> fofoLineItems2 = new HashSet<>();
1519
                fofoLineItems2.add(fofoLineItem);
1520
                fofoOrderItemIdFofoLineItemsMap.put(fofoLineItem.getFofoOrderItemId(), fofoLineItems2);
1521
            } else {
1522
                fofoOrderItemIdFofoLineItemsMap.get(fofoLineItem.getFofoOrderItemId()).add(fofoLineItem);
1523
            }
1524
        }
1525
        return fofoOrderItemIdFofoLineItemsMap;
1526
    }
25101 amit.gupta 1527
 
32145 tejbeer 1528
    @Override
1529
    public void updateCustomerDetails(CustomCustomer customCustomer, String invoiceNumber) throws ProfitMandiBusinessException {
1530
        FofoOrder fofoOrder = fofoOrderRepository.selectByInvoiceNumber(invoiceNumber);
1531
        Customer customer = customerRepository.selectById(fofoOrder.getCustomerId());
1532
        customer.setFirstName(customCustomer.getFirstName());
1533
        customer.setLastName(customCustomer.getLastName());
1534
        customer.setMobileNumber(customCustomer.getMobileNumber());
1535
        customer.setEmailId(customCustomer.getEmailId());
1536
        customerRepository.persist(customer);
1537
        CustomerAddress customerAddress = customerAddressRepository.selectById(fofoOrder.getCustomerAddressId());
1538
        if (!customerAddress.getState().equalsIgnoreCase(customCustomer.getAddress().getState())) {
1539
            List<FofoOrderItem> fofoOrderItems = fofoOrderItemRepository.selectByOrderId(fofoOrder.getId());
1540
            resetTaxation(fofoOrder.getFofoId(), customerAddress, fofoOrderItems);
1541
        }
1542
        this.setCustomerAddress(customerAddress, customCustomer.getAddress());
1543
        customerAddressRepository.persist(customerAddress);
1544
        fofoOrder.setCustomerGstNumber(customCustomer.getGstNumber());
1545
    }
23638 amit.gupta 1546
 
32145 tejbeer 1547
    private void resetTaxation(int fofoId, CustomerAddress customerAddress, List<FofoOrderItem> fofoOrderItems) throws ProfitMandiBusinessException {
1548
        int retailerAddressId = retailerRegisteredAddressRepository.selectAddressIdByRetailerId(fofoId);
23650 amit.gupta 1549
 
32145 tejbeer 1550
        Address retailerAddress = addressRepository.selectById(retailerAddressId);
24275 amit.gupta 1551
 
32145 tejbeer 1552
        Integer stateId = null;
1553
        if (customerAddress.getState().equalsIgnoreCase(retailerAddress.getState())) {
1554
            try {
1555
                stateId = Long.valueOf(stateRepository.selectByName(customerAddress.getState()).getId()).intValue();
1556
            } catch (Exception e) {
1557
                LOGGER.error("Unable to get state rates");
1558
            }
1559
        }
1560
        List<Integer> itemIds = fofoOrderItems.stream().map(x -> x.getItemId()).collect(Collectors.toList());
1561
        final Map<Integer, GstRate> gstRates;
1562
        if (stateId != null) {
1563
            gstRates = stateGstRateRepository.getStateTaxRate(itemIds, stateId);
1564
        } else {
1565
            gstRates = stateGstRateRepository.getIgstTaxRate(itemIds);
1566
        }
1567
        for (FofoOrderItem fofoOrderItem : fofoOrderItems) {
1568
            GstRate rate = gstRates.get(fofoOrderItem.getItemId());
1569
            fofoOrderItem.setCgstRate(rate.getCgstRate());
1570
            fofoOrderItem.setSgstRate(rate.getSgstRate());
1571
            fofoOrderItem.setIgstRate(rate.getIgstRate());
1572
        }
1573
    }
24275 amit.gupta 1574
 
32145 tejbeer 1575
    @Override
1576
    public CustomerCreditNote badReturn(int fofoId, FoiBadReturnRequest foiBadReturnRequest) throws ProfitMandiBusinessException {
1577
        FofoOrderItem foi = fofoOrderItemRepository.selectById(foiBadReturnRequest.getFofoOrderItemId());
1578
        FofoOrder fofoOrder = fofoOrderRepository.selectByOrderId(foi.getOrderId());
1579
        if (fofoOrder.getFofoId() != fofoId) {
1580
            throw new ProfitMandiBusinessException("Partner Auth", "", "Invalid Order");
1581
        }
1582
        int billedQty = foi.getQuantity() - customerReturnItemRepository.selectAllByOrderItemId(foi.getId()).size();
1583
        if (foiBadReturnRequest.getMarkedBadArr().size() > billedQty) {
1584
            throw new ProfitMandiBusinessException("Cant bad return more than what is billed", "", "Invalid Quantity");
1585
        }
1586
        List<CustomerReturnItem> customerReturnItems = new ArrayList<>();
1587
        for (BadReturnRequest badReturnRequest : foiBadReturnRequest.getMarkedBadArr()) {
1588
            CustomerReturnItem customerReturnItem = new CustomerReturnItem();
1589
            customerReturnItem.setFofoId(fofoId);
1590
            customerReturnItem.setFofoOrderItemId(foiBadReturnRequest.getFofoOrderItemId());
1591
            customerReturnItem.setFofoOrderId(fofoOrder.getId());
1592
            customerReturnItem.setRemarks(badReturnRequest.getRemarks());
1593
            customerReturnItem.setInventoryItemId(badReturnRequest.getInventoryItemId());
1594
            customerReturnItem.setQuantity(1);
1595
            customerReturnItem.setType(ReturnType.BAD);
1596
            // customerReturnItemRepository.persist(customerReturnItem);
1597
            inventoryService.saleReturnInventoryItem(customerReturnItem);
1598
            customerReturnItems.add(customerReturnItem);
1599
        }
1600
        CustomerCreditNote creditNote = generateCreditNote(fofoOrder, customerReturnItems);
1601
        for (CustomerReturnItem customerReturnItem : customerReturnItems) {
1602
            purchaseReturnService.returnInventoryItem(fofoId, false, customerReturnItem.getInventoryItemId(), ReturnType.BAD);
1603
        }
1604
        // This should cancel the order
1605
        fofoOrder.setCancelledTimestamp(LocalDateTime.now());
1606
        this.reverseScheme(fofoOrder);
1607
        return creditNote;
1608
    }
23638 amit.gupta 1609
 
32145 tejbeer 1610
    private CustomerCreditNote generateCreditNote(FofoOrder fofoOrder, List<CustomerReturnItem> customerReturnItems) throws ProfitMandiBusinessException {
24275 amit.gupta 1611
 
32145 tejbeer 1612
        InvoiceNumberGenerationSequence sequence = invoiceNumberGenerationSequenceRepository.selectByFofoId(fofoOrder.getFofoId());
1613
        sequence.setCreditNoteSequence(sequence.getCreditNoteSequence() + 1);
1614
        invoiceNumberGenerationSequenceRepository.persist(sequence);
24275 amit.gupta 1615
 
32145 tejbeer 1616
        String creditNoteNumber = sequence.getPrefix() + "/" + sequence.getCreditNoteSequence();
1617
        CustomerCreditNote creditNote = new CustomerCreditNote();
1618
        creditNote.setCreditNoteNumber(creditNoteNumber);
1619
        creditNote.setFofoId(fofoOrder.getFofoId());
1620
        creditNote.setFofoOrderId(fofoOrder.getId());
1621
        creditNote.setFofoOrderItemId(customerReturnItems.get(0).getFofoOrderItemId());
1622
        creditNote.setSettlementType(SettlementType.UNSETTLED);
1623
        customerCreditNoteRepository.persist(creditNote);
24275 amit.gupta 1624
 
32145 tejbeer 1625
        for (CustomerReturnItem customerReturnItem : customerReturnItems) {
1626
            customerReturnItem.setCreditNoteId(creditNote.getId());
1627
            customerReturnItemRepository.persist(customerReturnItem);
1628
        }
1629
        // this.returnInventoryItems(inventoryItems, debitNote);
23655 amit.gupta 1630
 
32145 tejbeer 1631
        return creditNote;
1632
    }
23655 amit.gupta 1633
 
32145 tejbeer 1634
    @Override
1635
    public CreditNotePdfModel getCreditNotePdfModel(int customerCreditNoteId) throws ProfitMandiBusinessException {
1636
        CustomerCreditNote creditNote = customerCreditNoteRepository.selectById(customerCreditNoteId);
1637
        return getCreditNotePdfModel(creditNote);
1638
    }
24275 amit.gupta 1639
 
32145 tejbeer 1640
    private CreditNotePdfModel getCreditNotePdfModel(CustomerCreditNote creditNote) throws ProfitMandiBusinessException {
1641
        FofoOrder fofoOrder = fofoOrderRepository.selectByOrderId(creditNote.getFofoOrderId());
1642
        List<CustomerReturnItem> customerReturnItems = customerReturnItemRepository.selectAllByCreditNoteId(creditNote.getId());
1643
        CustomCustomer customCustomer = getCustomCustomer(fofoOrder);
24275 amit.gupta 1644
 
32145 tejbeer 1645
        Set<CustomOrderItem> customerFofoOrderItems = new HashSet<>();
1646
        CustomRetailer customRetailer = retailerService.getFofoRetailer(fofoOrder.getFofoId());
23655 amit.gupta 1647
 
32145 tejbeer 1648
        FofoOrderItem fofoOrderItem = fofoOrderItemRepository.selectById(creditNote.getFofoOrderItemId());
1649
        float totalTaxRate = fofoOrderItem.getIgstRate() + fofoOrderItem.getSgstRate() + fofoOrderItem.getCgstRate();
1650
        float taxableSellingPrice = fofoOrderItem.getSellingPrice() / (1 + totalTaxRate / 100);
1651
        float taxableDiscountPrice = fofoOrderItem.getDiscount() / (1 + totalTaxRate / 100);
24275 amit.gupta 1652
 
32145 tejbeer 1653
        CustomOrderItem customFofoOrderItem = new CustomOrderItem();
1654
        customFofoOrderItem.setAmount(customerReturnItems.size() * (taxableSellingPrice - taxableDiscountPrice));
1655
        customFofoOrderItem.setDescription(fofoOrderItem.getBrand() + " " + fofoOrderItem.getModelName() + " " + fofoOrderItem.getModelNumber() + "-" + fofoOrderItem.getColor());
24275 amit.gupta 1656
 
32145 tejbeer 1657
        if (ItemType.SERIALIZED.equals(itemRepository.selectById(fofoOrderItem.getItemId()).getType())) {
1658
            Set<Integer> inventoryItemIds = customerReturnItems.stream().map(x -> x.getInventoryItemId()).collect(Collectors.toSet());
1659
            List<String> serialNumbers = inventoryItemRepository.selectByIds(inventoryItemIds).stream().map(x -> x.getSerialNumber()).collect(Collectors.toList());
1660
            customFofoOrderItem.setDescription(
1661
                    customFofoOrderItem.getDescription() + "\n IMEIS - " + String.join(", ", serialNumbers));
1662
        }
23638 amit.gupta 1663
 
32145 tejbeer 1664
        customFofoOrderItem.setRate(taxableSellingPrice);
1665
        customFofoOrderItem.setDiscount(taxableDiscountPrice);
1666
        customFofoOrderItem.setQuantity(customerReturnItems.size());
1667
        customFofoOrderItem.setNetAmount(
1668
                (fofoOrderItem.getSellingPrice() - fofoOrderItem.getDiscount()) * customFofoOrderItem.getQuantity());
29707 tejbeer 1669
 
32145 tejbeer 1670
        float igstAmount = (customFofoOrderItem.getAmount() * fofoOrderItem.getIgstRate()) / 100;
1671
        float cgstAmount = (customFofoOrderItem.getAmount() * fofoOrderItem.getCgstRate()) / 100;
1672
        float sgstAmount = (customFofoOrderItem.getAmount() * fofoOrderItem.getSgstRate()) / 100;
1673
        LOGGER.info("fofoOrderItem - {}", fofoOrderItem);
1674
        customFofoOrderItem.setIgstRate(fofoOrderItem.getIgstRate());
1675
        customFofoOrderItem.setIgstAmount(igstAmount);
1676
        customFofoOrderItem.setCgstRate(fofoOrderItem.getCgstRate());
1677
        customFofoOrderItem.setCgstAmount(cgstAmount);
1678
        customFofoOrderItem.setSgstRate(fofoOrderItem.getSgstRate());
1679
        customFofoOrderItem.setSgstAmount(sgstAmount);
1680
        customFofoOrderItem.setHsnCode(fofoOrderItem.getHsnCode());
1681
        customFofoOrderItem.setOrderId(1);
1682
        customerFofoOrderItems.add(customFofoOrderItem);
29707 tejbeer 1683
 
32145 tejbeer 1684
        InvoicePdfModel pdfModel = new InvoicePdfModel();
1685
        pdfModel.setAuther("NSSPL");
1686
        pdfModel.setCustomer(customCustomer);
1687
        pdfModel.setInvoiceNumber(fofoOrder.getInvoiceNumber());
1688
        pdfModel.setInvoiceDate(FormattingUtils.formatDate(fofoOrder.getCreateTimestamp()));
1689
        pdfModel.setTitle("Credit Note");
1690
        pdfModel.setRetailer(customRetailer);
1691
        pdfModel.setTotalAmount(customFofoOrderItem.getNetAmount());
1692
        pdfModel.setOrderItems(customerFofoOrderItems);
29707 tejbeer 1693
 
32145 tejbeer 1694
        CreditNotePdfModel creditNotePdfModel = new CreditNotePdfModel();
1695
        creditNotePdfModel.setCreditNoteDate(FormattingUtils.formatDate(creditNote.getCreateTimestamp()));
1696
        creditNotePdfModel.setCreditNoteNumber(creditNote.getCreditNoteNumber());
1697
        creditNotePdfModel.setPdfModel(pdfModel);
1698
        return creditNotePdfModel;
1699
    }
24264 amit.gupta 1700
 
32145 tejbeer 1701
    // This will remove the order and maintain order record and reverse inventory
1702
    // and scheme
1703
    @Override
1704
    public void cancelOrder(List<String> invoiceNumbers) throws ProfitMandiBusinessException {
1705
        for (String invoiceNumber : invoiceNumbers) {
1706
            // Cancel only when not cancelled
1707
            FofoOrder fofoOrder = fofoOrderRepository.selectByInvoiceNumber(invoiceNumber);
1708
            if (fofoOrder.getCancelledTimestamp() == null) {
1709
                fofoOrder.setCancelledTimestamp(LocalDateTime.now());
1710
                PaymentOptionTransaction paymentTransaction = new PaymentOptionTransaction();
1711
                paymentTransaction.setAmount(-fofoOrder.getTotalAmount());
1712
                paymentTransaction.setFofoId(fofoOrder.getFofoId());
1713
                paymentTransaction.setReferenceId(fofoOrder.getId());
1714
                paymentTransaction.setReferenceType(PaymentOptionReferenceType.ORDER);
1715
                paymentTransaction.setPaymentOptionId(1);
1716
                paymentOptionTransactionRepository.persist(paymentTransaction);
31030 amit.gupta 1717
 
32145 tejbeer 1718
                List<FofoOrderItem> fois = fofoOrderItemRepository.selectByOrderId(fofoOrder.getId());
1719
                if (fois.size() > 0) {
1720
                    List<InventoryItem> inventoryItems = new ArrayList<>();
1721
                    fois.stream().forEach(x -> {
1722
                        x.getFofoLineItems().stream().forEach(y -> {
1723
                            inventoryService.rollbackInventory(y.getInventoryItemId(), y.getQuantity(), fofoOrder.getFofoId());
1724
                            inventoryItems.add(inventoryItemRepository.selectById(y.getInventoryItemId()));
1725
                        });
1726
                    });
1727
                    // if(invoice)
1728
                    this.reverseScheme(fofoOrder);
1729
                }
1730
                insuranceService.cancelInsurance(fofoOrder);
1731
            }
1732
        }
1733
    }
31030 amit.gupta 1734
 
32145 tejbeer 1735
    @Override
1736
    public void reverseScheme(FofoOrder fofoOrder) throws ProfitMandiBusinessException {
1737
        String reversalReason = "Order Rolledback/Cancelled/Returned for Invoice #" + fofoOrder.getInvoiceNumber();
1738
        List<FofoOrderItem> fois = fofoOrderItemRepository.selectByOrderId(fofoOrder.getId());
1739
        Set<Integer> inventoryItemIds = fois.stream().flatMap(x -> x.getFofoLineItems().stream().map(y -> y.getInventoryItemId())).collect(Collectors.toSet());
1740
        List<InventoryItem> inventoryItems = inventoryItemRepository.selectByIds(inventoryItemIds);
1741
        schemeService.reverseSchemes(inventoryItems, fofoOrder.getId(), reversalReason, SchemeService.OUT_SCHEME_TYPES);
1742
        schemeService.reverseSchemes(inventoryItems, fofoOrder.getId(), reversalReason, Arrays.asList(SchemeType.INVESTMENT));
1743
        schemeService.reverseSchemes(inventoryItems, fofoOrder.getId(), reversalReason, Arrays.asList(SchemeType.ACTIVATION));
1744
        schemeService.reverseSchemes(inventoryItems, fofoOrder.getId(), reversalReason, Arrays.asList(SchemeType.SPECIAL_SUPPORT));
31030 amit.gupta 1745
 
32145 tejbeer 1746
    }
24271 amit.gupta 1747
 
32145 tejbeer 1748
    @Override
1749
    public void reverseActivationScheme(List<Integer> inventoryItemIds) throws ProfitMandiBusinessException {
1750
        List<InventoryItem> inventoryItems = inventoryItemRepository.selectAllByIds(inventoryItemIds);
1751
        for (InventoryItem inventoryItem : inventoryItems) {
1752
            List<FofoLineItem> fofoLineItems = fofoLineItemRepository.selectByInventoryItemId(inventoryItem.getId());
1753
            FofoLineItem fofoLineItem = fofoLineItems.get(0);
1754
            FofoOrderItem fofoOrderItem = fofoOrderItemRepository.selectById(fofoLineItem.getFofoOrderItemId());
1755
            FofoOrder fofoOrder = fofoOrderRepository.selectByOrderId(fofoOrderItem.getOrderId());
1756
            String reversalReason = "Scheme rolled back as activation date is invalid for imei " + inventoryItem.getSerialNumber();
1757
            schemeService.reverseSchemes(Arrays.asList(inventoryItem), fofoOrder.getId(), reversalReason, Arrays.asList(SchemeType.ACTIVATION));
1758
            schemeService.reverseSchemes(Arrays.asList(inventoryItem), fofoOrder.getId(), reversalReason, Arrays.asList(SchemeType.SPECIAL_SUPPORT));
27083 amit.gupta 1759
 
32145 tejbeer 1760
        }
24271 amit.gupta 1761
 
32145 tejbeer 1762
    }
24271 amit.gupta 1763
 
32145 tejbeer 1764
    @Override
1765
    public float getSales(int fofoId, LocalDateTime startDate, LocalDateTime endDate) {
1766
        Float sales = fofoOrderRepository.selectSaleSumGroupByFofoIds(startDate, endDate).get(fofoId);
1767
        return sales == null ? 0f : sales;
1768
    }
24271 amit.gupta 1769
 
32145 tejbeer 1770
    @Override
1771
    public LocalDateTime getMaxSalesDate(int fofoId, LocalDateTime startDate, LocalDateTime endDate) {
1772
        LocalDateTime dateTime = fofoOrderRepository.selectMaxSaleDateGroupByFofoIds(startDate, endDate).get(fofoId);
1773
        return dateTime;
1774
    }
25101 amit.gupta 1775
 
32145 tejbeer 1776
    @Override
1777
    // Only being used internally
1778
    public float getSales(int fofoId, LocalDate onDate) {
1779
        LocalDateTime startTime = LocalDateTime.of(onDate, LocalTime.MIDNIGHT);
1780
        LocalDateTime endTime = LocalDateTime.of(onDate, LocalTime.MIDNIGHT).plusDays(1);
1781
        return this.getSales(fofoId, startTime, endTime);
1782
    }
24917 tejbeer 1783
 
32145 tejbeer 1784
    @Override
1785
    public float getSales(LocalDateTime onDate) {
1786
        // TODO Auto-generated method stub
1787
        return 0;
1788
    }
28166 tejbeer 1789
 
32145 tejbeer 1790
    @Override
1791
    public float getSales(LocalDateTime startDate, LocalDateTime endDate) {
1792
        // TODO Auto-generated method stub
1793
        return 0;
1794
    }
28166 tejbeer 1795
 
32145 tejbeer 1796
    @Override
1797
    public boolean notifyColorChange(int orderId, int itemId) throws ProfitMandiBusinessException {
1798
        Order order = orderRepository.selectById(orderId);
1799
        saholicInventoryService.reservationCountByColor(itemId, order);
28166 tejbeer 1800
 
32145 tejbeer 1801
        order.getLineItem().setItemId(itemId);
1802
        Item item = itemRepository.selectById(itemId);
1803
        order.getLineItem().setColor(item.getColor());
1804
        return true;
1805
    }
28166 tejbeer 1806
 
32145 tejbeer 1807
    @Override
1808
    public FofoOrder getOrderByInventoryItemId(int inventoryItemId) throws Exception {
1809
        List<FofoLineItem> lineItems = fofoLineItemRepository.selectByInventoryItemId(inventoryItemId);
1810
        if (lineItems.size() > 0) {
1811
            FofoOrderItem fofoOrderItem = fofoOrderItemRepository.selectById(lineItems.get(0).getFofoOrderItemId());
1812
            fofoOrderItem.setFofoLineItems(new HashSet<>(lineItems));
1813
            FofoOrder fofoOrder = fofoOrderRepository.selectByOrderId(fofoOrderItem.getOrderId());
1814
            fofoOrder.setOrderItem(fofoOrderItem);
1815
            return fofoOrder;
1816
        } else {
1817
            throw new Exception(String.format("Could not find inventoryItemId - %s", inventoryItemId));
1818
        }
1819
    }
28166 tejbeer 1820
 
32145 tejbeer 1821
    @Override
1822
    public Map<Integer, Long> carryBagCreditCount(int fofoId) throws ProfitMandiBusinessException {
28166 tejbeer 1823
 
32145 tejbeer 1824
        FofoStore fs = fofoStoreRepository.selectByRetailerId(fofoId);
1825
        LocalDateTime lastCredit = fs.getBagsLastCredited();
1826
        /*
1827
         * long carryBagCount = 0; List<FofoOrder> fofoOrders =
1828
         * fofoOrderRepository.selectByFofoIdBetweenCreatedTimeStamp(fofoId,
1829
         * lastCredit.atStartOfDay(), LocalDate.now().plusDays(1).atStartOfDay()); for
1830
         * (FofoOrder fo : fofoOrders) { carryBagCount +=
1831
         * fofoOrderItemRepository.selectByOrderId(fo.getId()).stream() .filter(x ->
1832
         * x.getSellingPrice() >= 12000).count();
1833
         *
1834
         * }
1835
         */
28166 tejbeer 1836
 
32145 tejbeer 1837
        Session session = sessionFactory.getCurrentSession();
1838
        CriteriaBuilder cb = session.getCriteriaBuilder();
1839
 
1840
        CriteriaQuery<SimpleEntry> query = cb.createQuery(SimpleEntry.class);
1841
        Root<FofoOrder> fofoOrder = query.from(FofoOrder.class);
1842
        Root<FofoOrderItem> fofoOrderItem = query.from(FofoOrderItem.class);
1843
        Root<TagListing> tagListingRoot = query.from(TagListing.class);
1844
        Root<Item> itemRoot = query.from(Item.class);
1845
 
1846
        Predicate p2 = cb.between(fofoOrder.get(ProfitMandiConstants.CREATE_TIMESTAMP), lastCredit, LocalDate.now().atStartOfDay());
1847
        Predicate p3 = cb.isNull(fofoOrder.get("cancelledTimestamp"));
1848
        Predicate joinPredicate = cb.and(
1849
                cb.equal(fofoOrder.get(ProfitMandiConstants.ID), fofoOrderItem.get(ProfitMandiConstants.ORDER_ID)), cb.equal(fofoOrderItem.get("itemId"), tagListingRoot.get("itemId")), cb.equal(itemRoot.get("id"), tagListingRoot.get("itemId")), cb.equal(fofoOrder.get(ProfitMandiConstants.FOFO_ID), fofoId));
1850
        ItemCriteria itemCriteria = new ItemCriteria();
1851
        itemCriteria.setBrands(mongoClient.getMongoBrands(fofoId, null, 3).stream().map(x -> (String) x.get("name")).collect(Collectors.toList()));
1852
        float startValue = 12000;
1853
        itemCriteria.setStartPrice(startValue);
1854
        itemCriteria.setEndPrice(0);
1855
        itemCriteria.setFeaturedPhone(false);
1856
        itemCriteria.setSmartPhone(true);
1857
        itemCriteria.setCatalogIds(new ArrayList<>());
1858
        itemCriteria.setExcludeCatalogIds(new ArrayList<>());
1859
        Predicate itemPredicate = itemRepository.getItemPredicate(itemCriteria, cb, itemRoot, tagListingRoot.get("itemId"), tagListingRoot.get("sellingPrice"));
1860
        Predicate finalPredicate = cb.and(itemPredicate, p2, p3, joinPredicate);
1861
        query = query.multiselect(fofoOrder.get(ProfitMandiConstants.FOFO_ID), cb.count(fofoOrder)).where(finalPredicate).groupBy(fofoOrder.get(ProfitMandiConstants.FOFO_ID));
1862
        List<SimpleEntry> simpleEntries = session.createQuery(query).getResultList();
1863
        Map<Integer, Long> returnMap = new HashMap<>();
1864
 
1865
        for (SimpleEntry simpleEntry : simpleEntries) {
1866
            returnMap.put((Integer) simpleEntry.getKey(), (Long) simpleEntry.getValue());
1867
        }
1868
        return returnMap;
1869
 
1870
    }
25724 amit.gupta 1871
}