Subversion Repositories SmartDukaan

Rev

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

Rev Author Line No. Line
26522 amit.gupta 1
package com.spice.profitmandi.dao.cart;
2
 
28653 amit.gupta 3
import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
29261 amit.gupta 4
import com.spice.profitmandi.common.model.ProfitMandiConstants;
26522 amit.gupta 5
import com.spice.profitmandi.dao.entity.catalog.Item;
6
import com.spice.profitmandi.dao.entity.catalog.TagListing;
29327 tejbeer 7
import com.spice.profitmandi.dao.entity.cs.PartnerRegion;
8
import com.spice.profitmandi.dao.entity.fofo.FofoStore;
35170 vikas 9
import com.spice.profitmandi.dao.entity.fofo.PartnerType;
32493 amit.gupta 10
import com.spice.profitmandi.dao.entity.inventory.SaholicCISTable;
26522 amit.gupta 11
import com.spice.profitmandi.dao.entity.user.Cart;
28166 tejbeer 12
import com.spice.profitmandi.dao.entity.user.CartLine;
26522 amit.gupta 13
import com.spice.profitmandi.dao.entity.user.User;
33172 tejus.loha 14
import com.spice.profitmandi.dao.model.*;
29327 tejbeer 15
import com.spice.profitmandi.dao.repository.catalog.FocusedModelRepository;
26522 amit.gupta 16
import com.spice.profitmandi.dao.repository.catalog.ItemRepository;
17
import com.spice.profitmandi.dao.repository.catalog.TagListingRepository;
29327 tejbeer 18
import com.spice.profitmandi.dao.repository.cs.PartnerRegionRepository;
26522 amit.gupta 19
import com.spice.profitmandi.dao.repository.dtr.FofoStoreRepository;
29327 tejbeer 20
import com.spice.profitmandi.dao.repository.dtr.RetailerBlockBrandsRepository;
26522 amit.gupta 21
import com.spice.profitmandi.dao.repository.fofo.CurrentInventorySnapshotRepository;
35170 vikas 22
import com.spice.profitmandi.dao.repository.fofo.PartnerTypeChangeService;
32493 amit.gupta 23
import com.spice.profitmandi.dao.repository.inventory.SaholicCISTableRepository;
29327 tejbeer 24
import com.spice.profitmandi.dao.repository.transaction.OrderRepository;
28166 tejbeer 25
import com.spice.profitmandi.dao.repository.user.CartLineRepository;
26522 amit.gupta 26
import com.spice.profitmandi.dao.repository.user.CartRepository;
27
import com.spice.profitmandi.dao.repository.user.UserRepository;
32493 amit.gupta 28
import com.spice.profitmandi.dao.repository.warehouse.BrandRegionMappingRepository;
29327 tejbeer 29
import com.spice.profitmandi.service.NotificationService;
30
import com.spice.profitmandi.service.inventory.FocusedShortageModel;
28653 amit.gupta 31
import com.spice.profitmandi.service.inventory.SaholicInventoryService;
35140 ranu 32
import com.spice.profitmandi.service.inventory.WarehouseIntransitDataModel;
29327 tejbeer 33
import com.spice.profitmandi.service.transaction.TransactionService;
32493 amit.gupta 34
import org.apache.logging.log4j.LogManager;
35
import org.apache.logging.log4j.Logger;
36
import org.springframework.beans.factory.annotation.Autowired;
37
import org.springframework.stereotype.Component;
26522 amit.gupta 38
 
35170 vikas 39
import java.time.LocalDate;
32493 amit.gupta 40
import java.time.LocalDateTime;
41
import java.util.*;
42
import java.util.Map.Entry;
43
import java.util.stream.Collectors;
44
 
28170 tejbeer 45
@Component
26522 amit.gupta 46
public class CartServiceImpl implements CartService {
47
 
31773 amit.gupta 48
    private static final Set<Integer> tagIds = new HashSet<>(Arrays.asList(4));
26522 amit.gupta 49
 
31773 amit.gupta 50
    private static final Logger logger = LogManager.getLogger(CartServiceImpl.class);
28653 amit.gupta 51
 
31773 amit.gupta 52
    private static final Map<Integer, List<Integer>> focusedModelVariantMap = new HashMap<>();
29404 tejbeer 53
 
31773 amit.gupta 54
    @Autowired
55
    CartRepository cartRepository;
26522 amit.gupta 56
 
31773 amit.gupta 57
    @Autowired
58
    CartLineRepository cartLineRepository;
26522 amit.gupta 59
 
31773 amit.gupta 60
    @Autowired
61
    FofoStoreRepository fofoStoreRepository;
26522 amit.gupta 62
 
31773 amit.gupta 63
    @Autowired
64
    TagListingRepository tagListingRepository;
26522 amit.gupta 65
 
31773 amit.gupta 66
    @Autowired
67
    SaholicInventoryService saholicInventoryService;
26522 amit.gupta 68
 
31773 amit.gupta 69
    @Autowired
70
    UserRepository saholicUserRepository;
26522 amit.gupta 71
 
31773 amit.gupta 72
    @Autowired
73
    ItemRepository itemRepository;
28170 tejbeer 74
 
26522 amit.gupta 75
 
31773 amit.gupta 76
    @Autowired
77
    CurrentInventorySnapshotRepository currentInventorySnapshotRepository;
29327 tejbeer 78
 
31773 amit.gupta 79
    @Autowired
80
    private FocusedModelRepository focusedModelRepository;
29327 tejbeer 81
 
31773 amit.gupta 82
    @Autowired
83
    private PartnerRegionRepository partnerRegionRepository;
29327 tejbeer 84
 
31773 amit.gupta 85
    @Autowired
86
    private TransactionService transactionService;
29327 tejbeer 87
 
31773 amit.gupta 88
    @Autowired
89
    private RetailerBlockBrandsRepository retailerBlockBrandRepository;
29327 tejbeer 90
 
31773 amit.gupta 91
    @Autowired
92
    private OrderRepository orderRepository;
29327 tejbeer 93
 
31773 amit.gupta 94
    @Autowired
95
    private NotificationService notificationService;
96
    @Autowired
97
    private SaholicCISTableRepository saholicCISTableRepository;
29327 tejbeer 98
 
31773 amit.gupta 99
    @Autowired
100
    private BrandRegionMappingRepository brandRegionMappingRepository;
26522 amit.gupta 101
 
35170 vikas 102
    @Autowired
103
    private PartnerTypeChangeService partnerTypeChangeService;
104
 
31773 amit.gupta 105
    @Override
106
    // Unused method
107
    public CartModel addToCart(int cartId, int itemId, int quantity, float sellingPrice) {
108
        CartLine cartItem = cartLineRepository.selectByCartItem(cartId, itemId);
109
        if (cartItem == null) {
110
            this.createCartItem(cartId, itemId, quantity, sellingPrice);
111
        } else {
112
            cartItem.setQuantity(quantity);
113
            cartItem.setActualPrice(sellingPrice);
114
        }
115
        return null;
116
    }
26522 amit.gupta 117
 
31773 amit.gupta 118
    private void createCartItem(int cartId, int itemId, int quantity, float sellingPrice) {
119
        CartLine cartLine = new CartLine();
120
        cartLine.setActualPrice(sellingPrice);
121
        cartLine.setCartId(cartId);
122
        cartLine.setQuantity(quantity);
123
        // TODO: Estmiate Logic
124
        cartLine.setEstimate(2);
125
        cartLineRepository.persist(cartLine);
26522 amit.gupta 126
 
31773 amit.gupta 127
    }
26522 amit.gupta 128
 
31773 amit.gupta 129
    @Override
130
    public boolean clearCart(int cartId) throws ProfitMandiBusinessException {
131
        List<CartLine> cartLines = cartLineRepository.selectAllByCart(cartId);
132
        cartLines.stream().forEach(cartLine -> cartLineRepository.delete(cartLine));
133
        Cart cart = cartRepository.selectById(cartId);
26522 amit.gupta 134
 
31773 amit.gupta 135
        cart.setUpdateTimestamp(LocalDateTime.now());
136
        cart.setCheckoutTimestamp(null);
137
        cart.setTotalPrice(0);
138
        cart.setWalletAmount(0);
139
        return true;
140
    }
26522 amit.gupta 141
 
31773 amit.gupta 142
    @Override
143
    public CartModel getCart(int cartId) {
144
        // TODO Auto-generated method stub
145
        return null;
146
    }
26522 amit.gupta 147
 
31773 amit.gupta 148
    // As of now it only works for Fofo Partners need to be refactored later
149
    private Map<Integer, Integer> getAvailabilityMap(User user, Set<Integer> itemIds) {
150
        Map<Integer, Integer> itemAvailabilityMap = new HashMap<>();
151
        List<TagListing> tags = tagListingRepository.selectByItemIdsAndTagIds(itemIds, tagIds);
152
        tags.stream().forEach(tagListing -> {
153
            if (!tagListing.isActive() || tagListing.isHotDeals()) {
154
                // show actual values here
155
            } else {
32585 amit.gupta 156
                itemAvailabilityMap.put(tagListing.getItemId(), 400);
31773 amit.gupta 157
            }
158
        });
159
        return itemAvailabilityMap;
160
    }
26522 amit.gupta 161
 
31773 amit.gupta 162
    // As of now it only works for Fofo Partners need to be refactored later
33244 ranu 163
    private Map<Integer, Integer> getMinBuyQtyMap(User user, Set<Integer> itemIds) throws ProfitMandiBusinessException {
31773 amit.gupta 164
        List<Item> items = itemRepository.selectByIds(itemIds);
165
        return items.stream().collect(Collectors.toMap(x -> x.getId(), x -> x.getCategoryId() == 10020 ? 1 : 10));
166
    }
26522 amit.gupta 167
 
31773 amit.gupta 168
    // As of now it only works for Fofo Partners need to be refactored later
169
    private Map<Integer, Float> getPriceMap(User user, Set<Integer> itemIds) {
170
        List<TagListing> tags = tagListingRepository.selectByItemIdsAndTagIds(itemIds, tagIds);
171
        return tags.stream().collect(Collectors.toMap(x -> x.getItemId(), x -> x.getSellingPrice()));
28653 amit.gupta 172
 
31773 amit.gupta 173
    }
28653 amit.gupta 174
 
31773 amit.gupta 175
    @Override
176
    public CartResponse getCartValidation(int cartId) throws ProfitMandiBusinessException {
177
        /*
178
         * # No need to validate duplicate items since there are only two ways # to add
179
         * items to a cart and both of them check whether the item being # added is a
180
         * duplicate of an already existing item.
181
         */
28653 amit.gupta 182
 
31773 amit.gupta 183
        Cart cart = cartRepository.selectById(cartId);
184
        List<CartLine> cartLines = cartLineRepository.selectAllByCart(cartId);
28653 amit.gupta 185
 
31792 amit.gupta 186
        //User saholicUser = saholicUserRepository.selectByCartId(cartId);
28653 amit.gupta 187
 
31773 amit.gupta 188
        int totalQty = 0;
189
        double totalAmount = 0;
190
        CartResponse cartResponse = new CartResponse();
191
        List<CartMessage> cartMessages = new ArrayList<>();
192
        List<CartItemResponseModel> cartItemModels = new ArrayList<>();
193
        cartResponse.setCartMessages(cartMessages);
194
        cartResponse.setCartItems(cartItemModels);
28653 amit.gupta 195
 
31773 amit.gupta 196
        int cartMessageChanged = 0;
197
        int cartMessageOOS = 0;
198
        int cartMessageUndeliverable = 0;
28653 amit.gupta 199
 
31773 amit.gupta 200
        Set<Integer> itemIds = cartLines.stream().map(x -> x.getItemId()).collect(Collectors.toSet());
31783 amit.gupta 201
        logger.info("Item ids {}", itemIds);
31773 amit.gupta 202
        List<TagListing> tagListings = tagListingRepository.selectByItemIdsAndTagIds(itemIds, tagIds);
203
        Map<Integer, TagListing> tagListingsMap = tagListings.stream()
204
                .collect(Collectors.toMap(x -> x.getItemId(), x -> x));
28653 amit.gupta 205
 
35493 amit 206
        // N+1 fix: Pre-fetch all items before the loop
207
        Map<Integer, Item> itemMap = itemRepository.selectByIds(itemIds).stream()
208
                .collect(Collectors.toMap(Item::getId, item -> item));
209
 
31773 amit.gupta 210
        User user = saholicUserRepository.selectByCartId(cartId);
211
        FofoStore fs = fofoStoreRepository.selectByRetailerId(user.getId());
212
        Map<Integer, Integer> warehouseItemQtyMap = saholicInventoryService.getSaholicNetAvailability(fs.getWarehouseId(), new ArrayList<>(itemIds));
35170 vikas 213
        PartnerType partnerType = partnerTypeChangeService.getTypeOnDate(fs.getId(), LocalDate.now());
35140 ranu 214
        // Get in-transit data for this warehouse
215
        List<WarehouseIntransitDataModel> warehouseIntransitDataModels =
216
                saholicInventoryService.getWarehouseIntransistDataList().stream()
217
                        .filter(x -> x.getWarehouseId() == fs.getWarehouseId())
218
                        .collect(Collectors.toList());
28653 amit.gupta 219
 
35140 ranu 220
        // Add in-transit quantities into the map
221
        for (WarehouseIntransitDataModel intransitData : warehouseIntransitDataModels) {
222
            if (intransitData.getQty() > 0) {
223
                int itemId = intransitData.getItemId();
224
                int existingQty = warehouseItemQtyMap.getOrDefault(itemId, 0);
225
                warehouseItemQtyMap.put(itemId, existingQty + intransitData.getQty());
226
            }
227
        }
31773 amit.gupta 228
        cart.setTotalPrice(0);
229
        int nonAccessoryQuantity = 0;
230
        for (CartLine cartLine : cartLines) {
231
            CartItemResponseModel cartItemResponseModel = new CartItemResponseModel();
232
            int oldEstimate = cartLine.getEstimate();
233
            int itemId = cartLine.getItemId();
35493 amit 234
            // N+1 fix: Use pre-fetched itemMap instead of querying per item
235
            Item item = itemMap.get(itemId);
236
            if (item == null) {
31773 amit.gupta 237
                logger.info("Error finding item with id {}", itemId);
238
                cartLineRepository.delete(cartLine);
239
                continue;
240
            }
35493 amit 241
            cartItemResponseModel.setTitle(item.getItemDescriptionNoColor());
31773 amit.gupta 242
            cartItemResponseModel.setItemId(itemId);
243
            cartItemResponseModel.setQuantity(cartLine.getQuantity());
244
            cartItemResponseModel.setColor(item.getColor());
245
            cartItemResponseModel.setCatalogItemId(item.getCatalogItemId());
246
            cartItemResponseModel.setMinBuyQuantity(1);
247
            cartItemResponseModel.setQuantityStep(1);
32588 amit.gupta 248
            cartItemResponseModel.setMaxQuantity(400);
31773 amit.gupta 249
            int currentAvailability = warehouseItemQtyMap.get(itemId) == null ? 0 : warehouseItemQtyMap.get(itemId);
250
            int oldAvailability = cartLine.getAvailability();
251
            cartItemResponseModel.setAvailability(currentAvailability);
28653 amit.gupta 252
 
31773 amit.gupta 253
            //Current availability is less than required quantity
254
            if (currentAvailability < cartLine.getQuantity()) {
255
                //Current Availability is reduced
256
                if (oldAvailability > currentAvailability) {
257
                    cartMessageChanged += 1;
258
                }
259
            }
28653 amit.gupta 260
 
31773 amit.gupta 261
            //As of now one can buy upto 100 Qty
262
            if (cartLine.getQuantity() > cartItemResponseModel.getMaxQuantity()) {
263
                cartMessageChanged +=1;
264
                cartLine.setQuantity(cartItemResponseModel.getMaxQuantity());
265
            }
28653 amit.gupta 266
 
31773 amit.gupta 267
            if (item.getCategoryId() == 10006 || item.getCategoryId() == 10010) {
268
                nonAccessoryQuantity += cartItemResponseModel.getQuantity();
269
                cartItemResponseModel.setCategoryName("mobile");
270
            }
35211 vikas 271
            if (cartItemResponseModel.getItemId() == ProfitMandiConstants.ITEM_CARRY_BAG) {
35170 vikas 272
                if (partnerType.equals(PartnerType.SILVER) || partnerType.equals(PartnerType.BRONZE)) {
35214 vikas 273
                    cartLine.setActualPrice(tagListingsMap.get(itemId).getSellingPrice());
35170 vikas 274
                    cartItemResponseModel.setSellingPrice(cartLine.getActualPrice());
275
                } else {
276
                    cartItemResponseModel.setSellingPrice(1);
35214 vikas 277
                    cartLine.setActualPrice(1);
35170 vikas 278
                }
279
            } else {
280
                cartItemResponseModel.setSellingPrice(cartLine.getActualPrice());
281
            }
28653 amit.gupta 282
 
31773 amit.gupta 283
            //if (availability > 0) {
284
            cart.setTotalPrice(cart.getTotalPrice() + (cartLine.getActualPrice() * cartLine.getQuantity()));
285
            cartItemResponseModel.setQuantity(cartLine.getQuantity());
286
            cartItemResponseModel.setEstimate(2);
287
            cartLine.setEstimate(cartItemResponseModel.getEstimate());
288
            cart.setUpdateTimestamp(LocalDateTime.now());
28653 amit.gupta 289
 
28166 tejbeer 290
 
31773 amit.gupta 291
            totalAmount += cartLine.getActualPrice() * cartLine.getQuantity();
292
            totalQty += cartItemResponseModel.getQuantity();
293
            cartResponse.getCartItems().add(cartItemResponseModel);
28166 tejbeer 294
 
31773 amit.gupta 295
        }
296
        if (cart.getCheckoutTimestamp() != null) {
297
            if (cart.getUpdateTimestamp().isBefore(cart.getCheckoutTimestamp())) {
298
                cart.setCheckoutTimestamp(null);
299
            }
300
        }
301
        cartResponse.setTotalQty(totalQty);
302
        cartResponse.setTotalAmount(totalAmount);
303
        cartResponse.setNonAccessoryQuantity(nonAccessoryQuantity);
304
        cartResponse.setShippingCharge(0);
305
        cartResponse.setCartMessageChanged(cartMessageChanged);
306
        cartResponse.setCartMessageOOS(cartMessageOOS);
307
        cartResponse.setCartMessageUndeliverable(cartMessageUndeliverable);
308
        cartResponse.setCod(false);
309
        return cartResponse;
310
    }
28653 amit.gupta 311
 
31773 amit.gupta 312
    @Override
313
    public void addItemsToCart(int cartId, List<CartItem> cartItems) throws ProfitMandiBusinessException {
314
        logger.info("cart items {}", cartItems);
315
        cartItems = cartItems.stream().filter(x -> x.getQuantity() > 0).collect(Collectors.toList());
316
        Map<Integer, Integer> itemQuantityMap = cartItems.stream()
317
                .collect(Collectors.toMap(x -> x.getItemId(), x -> x.getQuantity()));
318
        List<CartLine> cartLines = cartLineRepository.selectAllByCart(cartId);
31781 amit.gupta 319
        Map<Integer, CartLine> itemCartLineMap = cartLines.stream().collect(Collectors.toMap(x->x.getItemId(), x->x));
31773 amit.gupta 320
        // Delete cartLines with 0 values
321
        for (CartLine cartLine : cartLines) {
322
            Integer quantity = itemQuantityMap.get(cartLine.getItemId());
323
            if (quantity == null || quantity.intValue() == 0) {
324
                cartLineRepository.delete(cartLine);
325
            } else {
326
                cartLine.setQuantity(itemQuantityMap.get(cartLine.getItemId()));
327
                cartLine.setUpdateTimestapm(LocalDateTime.now());
328
            }
329
        }
330
        for (CartItem cartItem : cartItems) {
31781 amit.gupta 331
            if (!itemCartLineMap.containsKey(cartItem.getItemId())) {
31773 amit.gupta 332
                CartLine cartLineNew = new CartLine();
333
                cartLineNew.setItemId(cartItem.getItemId());
334
                cartLineNew.setQuantity(cartItem.getQuantity());
335
                cartLineNew.setCartId(cartId);
32493 amit.gupta 336
                cartLineNew.setActualPrice((float) cartItem.getSellingPrice());
31773 amit.gupta 337
                cartLineNew.setCreateTimestamp(LocalDateTime.now());
338
                cartLineRepository.persist(cartLineNew);
339
            }
340
        }
29327 tejbeer 341
 
31773 amit.gupta 342
    }
29327 tejbeer 343
 
31773 amit.gupta 344
    @Override
345
    public void addAddressToCart(int cartId, long addressId) throws ProfitMandiBusinessException {
346
        Cart cart = cartRepository.selectById(cartId);
347
        cart.setAddressId((int) addressId);
29404 tejbeer 348
 
31773 amit.gupta 349
    }
29404 tejbeer 350
 
31773 amit.gupta 351
    @Override
352
    public void addShoppingBag(int cartId, long qty) {
353
        CartLine cl = new CartLine();
354
        cl.setItemId(ProfitMandiConstants.ITEM_CARRY_BAG);
355
        cl.setQuantity((int) qty);
356
        cl.setCartId(cartId);
357
        cl.setCreateTimestamp(LocalDateTime.now());
358
        cl.setDataProtectionAmount(0);
359
        cl.setEstimate(0);
360
        cl.setInsuranceAmount(0f);
361
        cl.setDataProtectionInsurer(0);
362
        cl.setActualPrice(0.01f);
363
        cartLineRepository.persist(cl);
29404 tejbeer 364
 
31773 amit.gupta 365
    }
29404 tejbeer 366
 
31773 amit.gupta 367
    @Override
368
    public CartModel removeFromCart(int cartId, int itemId) {
369
        // TODO Auto-generated method stub
370
        return null;
371
    }
29327 tejbeer 372
 
31773 amit.gupta 373
    @Override
374
    public List<FocusedShortageModel> focusedModelShortageValidation(int fofoId,
375
                                                                     Map<Integer, Integer> catalogCartQtyMap) throws ProfitMandiBusinessException {
29327 tejbeer 376
 
31773 amit.gupta 377
        logger.info("fofoId {}", fofoId);
29327 tejbeer 378
 
31773 amit.gupta 379
        focusedModelVariantMap.put(1022771, Arrays.asList(1022771));
380
        focusedModelVariantMap.put(1023025, Arrays.asList(1022975, 1022945));
29327 tejbeer 381
 
31773 amit.gupta 382
        focusedModelVariantMap.put(1023027, Arrays.asList(1022706));
29327 tejbeer 383
 
31773 amit.gupta 384
        focusedModelVariantMap.put(1022976, Arrays.asList(1022744));
385
        focusedModelVariantMap.put(1023045, Arrays.asList(1022768));
29327 tejbeer 386
 
31773 amit.gupta 387
        focusedModelVariantMap.put(1023066, Arrays.asList(1022858));
29327 tejbeer 388
 
31773 amit.gupta 389
        Map<Integer, Long> inStockItemModel = new HashMap<>();
390
        Map<Integer, Long> itempendingIndent = new HashMap<>();
391
        Map<Integer, Long> grnItemPendingOrders = new HashMap<>();
29327 tejbeer 392
 
31773 amit.gupta 393
        Map<Integer, Integer> focusedModelMap = null;
29327 tejbeer 394
 
31773 amit.gupta 395
        inStockItemModel = currentInventorySnapshotRepository.selectSumInMobileStockGroupByCatalog(fofoId).stream()
396
                .collect(Collectors.toMap(x -> x.getCatalogItemId(), x -> x.getQty()));
29327 tejbeer 397
 
31773 amit.gupta 398
        itempendingIndent = transactionService.getInTransitOrders(fofoId).stream()
399
                .collect(Collectors.groupingBy(x -> x.getLineItem().getItem().getCatalogItemId(),
400
                        Collectors.summingLong(x -> (long) x.getLineItem().getQuantity())));
29327 tejbeer 401
 
31773 amit.gupta 402
        grnItemPendingOrders = orderRepository.selectPendingGrnOrders(fofoId).stream()
403
                .collect(Collectors.groupingBy(x -> x.getLineItem().getItem().getCatalogItemId(),
404
                        Collectors.summingLong(x -> (long) x.getLineItem().getQuantity())));
405
        List<PartnerRegion> partnerRegions = partnerRegionRepository.selectByfofoId(fofoId);
29327 tejbeer 406
 
31773 amit.gupta 407
        FofoStore fofoStore = fofoStoreRepository.selectByRetailerId(fofoId);
29327 tejbeer 408
 
31773 amit.gupta 409
        List<String> retailerBlockBrands = retailerBlockBrandRepository.selectAllByRetailer(fofoId).stream()
410
                .map(x -> x.getBlockBrands()).collect(Collectors.toList());
29327 tejbeer 411
 
31773 amit.gupta 412
        if (partnerRegions.size() > 0) {
413
            focusedModelMap = focusedModelRepository
414
                    .selectAllByRegionIds(
415
                            partnerRegions.stream().map(x -> x.getRegionId()).collect(Collectors.toList()))
416
                    .stream().collect(Collectors.toMap(x -> x.getCatalogId(), x -> x.getMinimumQty()));
417
        } else {
418
            focusedModelMap = new HashMap<>();
419
        }
29327 tejbeer 420
 
31773 amit.gupta 421
        Map<Integer, Integer> catalogItemAailabilityMap = new HashMap<>();
29327 tejbeer 422
 
31773 amit.gupta 423
        for (Entry<Integer, Integer> fm : focusedModelMap.entrySet()) {
424
            List<Item> items = itemRepository.selectAllByCatalogItemId(fm.getKey());
425
            int allColorNetAvailability = 0;
426
            for (Item item : items) {
427
                if (retailerBlockBrands.contains(item.getBrand()))
428
                    continue;
429
                List<SaholicCISTable> currentAvailability = saholicCISTableRepository.selectByItemWarehouse(item.getId(), fofoStore.getWarehouseId());
29327 tejbeer 430
 
31773 amit.gupta 431
                if (currentAvailability != null) {
432
                    allColorNetAvailability += currentAvailability.stream()
433
                            .collect(Collectors.summingInt(SaholicCISTable::getNetAvailability));
434
                }
435
            }
436
            catalogItemAailabilityMap.put(fm.getKey(), allColorNetAvailability);
437
        }
29327 tejbeer 438
 
31773 amit.gupta 439
        List<FocusedShortageModel> focusedModelShortageList = new ArrayList<>();
29327 tejbeer 440
 
31773 amit.gupta 441
        for (Entry<Integer, Integer> fm : focusedModelMap.entrySet()) {
29327 tejbeer 442
 
31773 amit.gupta 443
            logger.info("fm {}", fm);
29404 tejbeer 444
 
31773 amit.gupta 445
            long overallStock = (inStockItemModel.get(fm.getKey()) == null ? 0 : inStockItemModel.get(fm.getKey()))
446
                    + (itempendingIndent.get(fm.getKey()) == null ? 0 : itempendingIndent.get(fm.getKey()))
447
                    + (grnItemPendingOrders.get(fm.getKey()) == null ? 0 : grnItemPendingOrders.get(fm.getKey()));
448
            logger.info("overallStock {}", overallStock);
29404 tejbeer 449
 
31773 amit.gupta 450
            // Blocked brands available quantity is discussed to zero
451
            long warehouseStock = catalogItemAailabilityMap.get(fm.getKey()) == null ? 0
452
                    : catalogItemAailabilityMap.get(fm.getKey());
453
            logger.info("warehouseStock {}", warehouseStock);
29404 tejbeer 454
 
31773 amit.gupta 455
            long cartValue = catalogCartQtyMap.get(fm.getKey()) == null ? 0 : catalogCartQtyMap.get(fm.getKey());
29404 tejbeer 456
 
31773 amit.gupta 457
            logger.info("cartValue" + cartValue);
458
            long totalStock = overallStock + cartValue;
459
            logger.info("totalStock" + totalStock);
29404 tejbeer 460
 
31773 amit.gupta 461
            long shortQty = Math.min(fm.getValue() - totalStock, warehouseStock);
462
            logger.info("shortQty {}", shortQty);
29404 tejbeer 463
 
31773 amit.gupta 464
            if (shortQty > 0) {
465
                if (focusedModelVariantMap.get(fm.getKey()) != null) {
466
                    List<Integer> variantCatalogIds = focusedModelVariantMap.get(fm.getKey());
467
                    logger.info("variantCatalogIds {}", variantCatalogIds);
29404 tejbeer 468
 
31773 amit.gupta 469
                    int variantAvailability = 0;
470
                    for (Integer vc : variantCatalogIds) {
471
                        long variantOverallStock = (inStockItemModel.get(vc) == null ? 0 : inStockItemModel.get(vc))
472
                                + (itempendingIndent.get(vc) == null ? 0 : itempendingIndent.get(vc))
473
                                + (grnItemPendingOrders.get(vc) == null ? 0 : grnItemPendingOrders.get(vc));
474
                        logger.info("variantOverallStock {}", variantOverallStock);
29404 tejbeer 475
 
31773 amit.gupta 476
                        // Blocked brands available quantity is discussed to zero
477
                        long variantWarehouseStock = catalogItemAailabilityMap.get(vc) == null ? 0
478
                                : catalogItemAailabilityMap.get(vc);
479
                        logger.info("variantWarehouseStock {}", variantWarehouseStock);
29404 tejbeer 480
 
31773 amit.gupta 481
                        long variantCartValue = catalogCartQtyMap.get(vc) == null ? 0 : catalogCartQtyMap.get(vc);
29404 tejbeer 482
 
31773 amit.gupta 483
                        logger.info("variantCartValue" + variantCartValue);
484
                        long variantTotalStock = variantOverallStock + variantCartValue;
485
                        logger.info("variantTotalStock" + variantTotalStock);
29404 tejbeer 486
 
31773 amit.gupta 487
                        variantAvailability += (int) variantTotalStock;
29327 tejbeer 488
 
31773 amit.gupta 489
                    }
29327 tejbeer 490
 
31773 amit.gupta 491
                    logger.info("variantAvailability {}", variantAvailability);
29327 tejbeer 492
 
31773 amit.gupta 493
                    shortQty = shortQty - variantAvailability;
29327 tejbeer 494
 
31773 amit.gupta 495
                }
496
            }
29327 tejbeer 497
 
31773 amit.gupta 498
            logger.info("shortQty" + shortQty);
29327 tejbeer 499
 
31773 amit.gupta 500
            if (shortQty > 0) {
29327 tejbeer 501
 
31773 amit.gupta 502
                Map<Integer, Integer> requiredItemQty = new HashMap<>();
29327 tejbeer 503
 
31773 amit.gupta 504
                List<Item> it = itemRepository.selectAllByCatalogItemId(fm.getKey());
505
                FocusedShortageModel fms = new FocusedShortageModel();
506
                fms.setShortageQty((int) shortQty);
507
                fms.setCatalogId(fm.getKey());
508
                fms.setAvailabitiy(fm.getValue());
509
                fms.setInStock(overallStock);
29327 tejbeer 510
 
31773 amit.gupta 511
                fms.setItemName(it.get(0).getBrand() + it.get(0).getModelNumber() + it.get(0).getModelName());
29327 tejbeer 512
 
31773 amit.gupta 513
                Map<Integer, Integer> itemQtyMap = new HashMap<>();
29327 tejbeer 514
 
31773 amit.gupta 515
                for (Item i : it) {
29327 tejbeer 516
 
31773 amit.gupta 517
                    List<SaholicCISTable> ca = saholicCISTableRepository.selectByItemWarehouse(i.getId(), fofoStore.getWarehouseId());
518
                    if (ca != null) {
519
                        itemQtyMap.put(i.getId(),
520
                                ca.stream().collect(Collectors.summingInt(SaholicCISTable::getNetAvailability)));
521
                    }
522
                }
29327 tejbeer 523
 
31773 amit.gupta 524
                itemQtyMap = itemQtyMap.entrySet().stream()
525
                        .sorted(Collections.reverseOrder(Map.Entry.comparingByValue())).collect(Collectors
526
                                .toMap(Map.Entry::getKey, Map.Entry::getValue, (e1, e2) -> e2, LinkedHashMap::new));
29327 tejbeer 527
 
31773 amit.gupta 528
                for (long i = shortQty; i > 0; i--) {
529
                    if (shortQty == 0) {
530
                        break;
531
                    }
29327 tejbeer 532
 
31773 amit.gupta 533
                    for (Entry<Integer, Integer> itemQty : itemQtyMap.entrySet()) {
29327 tejbeer 534
 
31773 amit.gupta 535
                        int availbleQty = itemQty.getValue();
536
                        if (availbleQty == 0) {
537
                            break;
538
                        }
539
                        if (requiredItemQty.get(itemQty.getKey()) == null) {
540
                            requiredItemQty.put(itemQty.getKey(), 1);
541
                            availbleQty = availbleQty - 1;
542
                            if (availbleQty != 0) {
543
                                itemQtyMap.put(itemQty.getKey(), availbleQty);
544
                            }
545
                            shortQty -= 1;
546
                        } else {
29327 tejbeer 547
 
31773 amit.gupta 548
                            int qty = requiredItemQty.get(itemQty.getKey());
29327 tejbeer 549
 
31773 amit.gupta 550
                            requiredItemQty.put(itemQty.getKey(), qty + 1);
29327 tejbeer 551
 
31773 amit.gupta 552
                            availbleQty = availbleQty - 1;
553
                            if (availbleQty != 0) {
554
                                itemQtyMap.put(itemQty.getKey(), availbleQty);
555
                            }
556
                            shortQty -= 1;
557
                        }
29327 tejbeer 558
 
31773 amit.gupta 559
                        if (shortQty == 0) {
560
                            break;
561
                        }
29327 tejbeer 562
 
31773 amit.gupta 563
                    }
29327 tejbeer 564
 
31773 amit.gupta 565
                }
29327 tejbeer 566
 
31773 amit.gupta 567
                Set<CartItem> cartItems = new HashSet<>();
568
                for (Entry<Integer, Integer> itemQtySet : requiredItemQty.entrySet()) {
29327 tejbeer 569
 
31773 amit.gupta 570
                    CartItem ci = new CartItem();
571
                    Item item = itemRepository.selectById(itemQtySet.getKey());
572
                    TagListing tl = tagListingRepository.selectByItemId(item.getId());
573
                    ci.setItemId(item.getId());
574
                    ci.setQuantity(itemQtySet.getValue());
575
                    ci.setSellingPrice(tl.getSellingPrice());
576
                    cartItems.add(ci);
577
 
578
                }
579
                fms.setCartItems(cartItems);
580
 
581
                // fms.setItemQtyAvailability(requiredItemQty);
582
 
583
                focusedModelShortageList.add(fms);
584
 
585
            }
586
 
587
        }
588
 
589
        logger.info("focusedModelShortageList {}", focusedModelShortageList);
590
        return focusedModelShortageList;
591
    }
592
 
33172 tejus.loha 593
    @Override
594
    public UserCart setCartItems(int fofoId, List<CartItem> cartItems) throws ProfitMandiBusinessException {
595
        User user = saholicUserRepository.selectById(fofoId);
596
        this.clearCart(user.getActiveCartId());
597
        this.addItemsToCart(user.getActiveCartId(), cartItems);
598
 
599
        UserCart userCart = new UserCart();
600
        userCart.setCartId(user.getActiveCartId());
601
        userCart.setUserId(user.getId());
602
        return userCart;
603
    }
604
 
26522 amit.gupta 605
}