Subversion Repositories SmartDukaan

Rev

Rev 35140 | Rev 35211 | 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
 
31773 amit.gupta 206
        User user = saholicUserRepository.selectByCartId(cartId);
207
        FofoStore fs = fofoStoreRepository.selectByRetailerId(user.getId());
208
        Map<Integer, Integer> warehouseItemQtyMap = saholicInventoryService.getSaholicNetAvailability(fs.getWarehouseId(), new ArrayList<>(itemIds));
35170 vikas 209
        PartnerType partnerType = partnerTypeChangeService.getTypeOnDate(fs.getId(), LocalDate.now());
35140 ranu 210
        // Get in-transit data for this warehouse
211
        List<WarehouseIntransitDataModel> warehouseIntransitDataModels =
212
                saholicInventoryService.getWarehouseIntransistDataList().stream()
213
                        .filter(x -> x.getWarehouseId() == fs.getWarehouseId())
214
                        .collect(Collectors.toList());
28653 amit.gupta 215
 
35140 ranu 216
        // Add in-transit quantities into the map
217
        for (WarehouseIntransitDataModel intransitData : warehouseIntransitDataModels) {
218
            if (intransitData.getQty() > 0) {
219
                int itemId = intransitData.getItemId();
220
                int existingQty = warehouseItemQtyMap.getOrDefault(itemId, 0);
221
                warehouseItemQtyMap.put(itemId, existingQty + intransitData.getQty());
222
            }
223
        }
31773 amit.gupta 224
        cart.setTotalPrice(0);
225
        int nonAccessoryQuantity = 0;
226
        for (CartLine cartLine : cartLines) {
227
            CartItemResponseModel cartItemResponseModel = new CartItemResponseModel();
228
            int oldEstimate = cartLine.getEstimate();
229
            int itemId = cartLine.getItemId();
230
            Item item = null;
231
            try {
232
                item = itemRepository.selectById(itemId);
233
                cartItemResponseModel.setTitle(item.getItemDescriptionNoColor());
234
            } catch (ProfitMandiBusinessException e) {
235
                e.printStackTrace();
236
                logger.info("Error finding item with id {}", itemId);
237
                cartLineRepository.delete(cartLine);
238
                continue;
239
            }
240
            cartItemResponseModel.setItemId(itemId);
241
            cartItemResponseModel.setQuantity(cartLine.getQuantity());
242
            cartItemResponseModel.setColor(item.getColor());
243
            cartItemResponseModel.setCatalogItemId(item.getCatalogItemId());
244
            cartItemResponseModel.setMinBuyQuantity(1);
245
            cartItemResponseModel.setQuantityStep(1);
32588 amit.gupta 246
            cartItemResponseModel.setMaxQuantity(400);
31773 amit.gupta 247
            int currentAvailability = warehouseItemQtyMap.get(itemId) == null ? 0 : warehouseItemQtyMap.get(itemId);
248
            int oldAvailability = cartLine.getAvailability();
249
            cartItemResponseModel.setAvailability(currentAvailability);
28653 amit.gupta 250
 
31773 amit.gupta 251
            //Current availability is less than required quantity
252
            if (currentAvailability < cartLine.getQuantity()) {
253
                //Current Availability is reduced
254
                if (oldAvailability > currentAvailability) {
255
                    cartMessageChanged += 1;
256
                }
257
            }
28653 amit.gupta 258
 
31773 amit.gupta 259
            //As of now one can buy upto 100 Qty
260
            if (cartLine.getQuantity() > cartItemResponseModel.getMaxQuantity()) {
261
                cartMessageChanged +=1;
262
                cartLine.setQuantity(cartItemResponseModel.getMaxQuantity());
263
            }
28653 amit.gupta 264
 
31773 amit.gupta 265
            cartLine.setActualPrice(tagListingsMap.get(itemId).getSellingPrice());
266
            if (item.getCategoryId() == 10006 || item.getCategoryId() == 10010) {
267
                nonAccessoryQuantity += cartItemResponseModel.getQuantity();
268
                cartItemResponseModel.setCategoryName("mobile");
269
            }
35170 vikas 270
            if (cartItemResponseModel.getItemId() == ProfitMandiConstants.CARRY_BAG_ITEM_ID) {
271
                if (partnerType.equals(PartnerType.SILVER) || partnerType.equals(PartnerType.BRONZE)) {
272
                    cartItemResponseModel.setSellingPrice(cartLine.getActualPrice());
273
                } else {
274
                    cartItemResponseModel.setSellingPrice(1);
275
                }
276
            } else {
277
                cartItemResponseModel.setSellingPrice(cartLine.getActualPrice());
278
            }
28653 amit.gupta 279
 
31773 amit.gupta 280
            //if (availability > 0) {
281
            cart.setTotalPrice(cart.getTotalPrice() + (cartLine.getActualPrice() * cartLine.getQuantity()));
282
            cartItemResponseModel.setQuantity(cartLine.getQuantity());
283
            cartItemResponseModel.setEstimate(2);
284
            cartLine.setEstimate(cartItemResponseModel.getEstimate());
285
            cart.setUpdateTimestamp(LocalDateTime.now());
28653 amit.gupta 286
 
28166 tejbeer 287
 
31773 amit.gupta 288
            totalAmount += cartLine.getActualPrice() * cartLine.getQuantity();
289
            totalQty += cartItemResponseModel.getQuantity();
290
            cartResponse.getCartItems().add(cartItemResponseModel);
28166 tejbeer 291
 
31773 amit.gupta 292
        }
293
        if (cart.getCheckoutTimestamp() != null) {
294
            if (cart.getUpdateTimestamp().isBefore(cart.getCheckoutTimestamp())) {
295
                cart.setCheckoutTimestamp(null);
296
            }
297
        }
298
        cartResponse.setTotalQty(totalQty);
299
        cartResponse.setTotalAmount(totalAmount);
300
        cartResponse.setNonAccessoryQuantity(nonAccessoryQuantity);
301
        cartResponse.setShippingCharge(0);
302
        cartResponse.setCartMessageChanged(cartMessageChanged);
303
        cartResponse.setCartMessageOOS(cartMessageOOS);
304
        cartResponse.setCartMessageUndeliverable(cartMessageUndeliverable);
305
        cartResponse.setCod(false);
306
        return cartResponse;
307
    }
28653 amit.gupta 308
 
31773 amit.gupta 309
    @Override
310
    public void addItemsToCart(int cartId, List<CartItem> cartItems) throws ProfitMandiBusinessException {
311
        logger.info("cart items {}", cartItems);
312
        cartItems = cartItems.stream().filter(x -> x.getQuantity() > 0).collect(Collectors.toList());
313
        Map<Integer, Integer> itemQuantityMap = cartItems.stream()
314
                .collect(Collectors.toMap(x -> x.getItemId(), x -> x.getQuantity()));
315
        List<CartLine> cartLines = cartLineRepository.selectAllByCart(cartId);
31781 amit.gupta 316
        Map<Integer, CartLine> itemCartLineMap = cartLines.stream().collect(Collectors.toMap(x->x.getItemId(), x->x));
31773 amit.gupta 317
        // Delete cartLines with 0 values
318
        for (CartLine cartLine : cartLines) {
319
            Integer quantity = itemQuantityMap.get(cartLine.getItemId());
320
            if (quantity == null || quantity.intValue() == 0) {
321
                cartLineRepository.delete(cartLine);
322
            } else {
323
                cartLine.setQuantity(itemQuantityMap.get(cartLine.getItemId()));
324
                cartLine.setUpdateTimestapm(LocalDateTime.now());
325
            }
326
        }
327
        for (CartItem cartItem : cartItems) {
31781 amit.gupta 328
            if (!itemCartLineMap.containsKey(cartItem.getItemId())) {
31773 amit.gupta 329
                CartLine cartLineNew = new CartLine();
330
                cartLineNew.setItemId(cartItem.getItemId());
331
                cartLineNew.setQuantity(cartItem.getQuantity());
332
                cartLineNew.setCartId(cartId);
32493 amit.gupta 333
                cartLineNew.setActualPrice((float) cartItem.getSellingPrice());
31773 amit.gupta 334
                cartLineNew.setCreateTimestamp(LocalDateTime.now());
335
                cartLineRepository.persist(cartLineNew);
336
            }
337
        }
29327 tejbeer 338
 
31773 amit.gupta 339
    }
29327 tejbeer 340
 
31773 amit.gupta 341
    @Override
342
    public void addAddressToCart(int cartId, long addressId) throws ProfitMandiBusinessException {
343
        Cart cart = cartRepository.selectById(cartId);
344
        cart.setAddressId((int) addressId);
29404 tejbeer 345
 
31773 amit.gupta 346
    }
29404 tejbeer 347
 
31773 amit.gupta 348
    @Override
349
    public void addShoppingBag(int cartId, long qty) {
350
        CartLine cl = new CartLine();
351
        cl.setItemId(ProfitMandiConstants.ITEM_CARRY_BAG);
352
        cl.setQuantity((int) qty);
353
        cl.setCartId(cartId);
354
        cl.setCreateTimestamp(LocalDateTime.now());
355
        cl.setDataProtectionAmount(0);
356
        cl.setEstimate(0);
357
        cl.setInsuranceAmount(0f);
358
        cl.setDataProtectionInsurer(0);
359
        cl.setActualPrice(0.01f);
360
        cartLineRepository.persist(cl);
29404 tejbeer 361
 
31773 amit.gupta 362
    }
29404 tejbeer 363
 
31773 amit.gupta 364
    @Override
365
    public CartModel removeFromCart(int cartId, int itemId) {
366
        // TODO Auto-generated method stub
367
        return null;
368
    }
29327 tejbeer 369
 
31773 amit.gupta 370
    @Override
371
    public List<FocusedShortageModel> focusedModelShortageValidation(int fofoId,
372
                                                                     Map<Integer, Integer> catalogCartQtyMap) throws ProfitMandiBusinessException {
29327 tejbeer 373
 
31773 amit.gupta 374
        logger.info("fofoId {}", fofoId);
29327 tejbeer 375
 
31773 amit.gupta 376
        focusedModelVariantMap.put(1022771, Arrays.asList(1022771));
377
        focusedModelVariantMap.put(1023025, Arrays.asList(1022975, 1022945));
29327 tejbeer 378
 
31773 amit.gupta 379
        focusedModelVariantMap.put(1023027, Arrays.asList(1022706));
29327 tejbeer 380
 
31773 amit.gupta 381
        focusedModelVariantMap.put(1022976, Arrays.asList(1022744));
382
        focusedModelVariantMap.put(1023045, Arrays.asList(1022768));
29327 tejbeer 383
 
31773 amit.gupta 384
        focusedModelVariantMap.put(1023066, Arrays.asList(1022858));
29327 tejbeer 385
 
31773 amit.gupta 386
        Map<Integer, Long> inStockItemModel = new HashMap<>();
387
        Map<Integer, Long> itempendingIndent = new HashMap<>();
388
        Map<Integer, Long> grnItemPendingOrders = new HashMap<>();
29327 tejbeer 389
 
31773 amit.gupta 390
        Map<Integer, Integer> focusedModelMap = null;
29327 tejbeer 391
 
31773 amit.gupta 392
        inStockItemModel = currentInventorySnapshotRepository.selectSumInMobileStockGroupByCatalog(fofoId).stream()
393
                .collect(Collectors.toMap(x -> x.getCatalogItemId(), x -> x.getQty()));
29327 tejbeer 394
 
31773 amit.gupta 395
        itempendingIndent = transactionService.getInTransitOrders(fofoId).stream()
396
                .collect(Collectors.groupingBy(x -> x.getLineItem().getItem().getCatalogItemId(),
397
                        Collectors.summingLong(x -> (long) x.getLineItem().getQuantity())));
29327 tejbeer 398
 
31773 amit.gupta 399
        grnItemPendingOrders = orderRepository.selectPendingGrnOrders(fofoId).stream()
400
                .collect(Collectors.groupingBy(x -> x.getLineItem().getItem().getCatalogItemId(),
401
                        Collectors.summingLong(x -> (long) x.getLineItem().getQuantity())));
402
        List<PartnerRegion> partnerRegions = partnerRegionRepository.selectByfofoId(fofoId);
29327 tejbeer 403
 
31773 amit.gupta 404
        FofoStore fofoStore = fofoStoreRepository.selectByRetailerId(fofoId);
29327 tejbeer 405
 
31773 amit.gupta 406
        List<String> retailerBlockBrands = retailerBlockBrandRepository.selectAllByRetailer(fofoId).stream()
407
                .map(x -> x.getBlockBrands()).collect(Collectors.toList());
29327 tejbeer 408
 
31773 amit.gupta 409
        if (partnerRegions.size() > 0) {
410
            focusedModelMap = focusedModelRepository
411
                    .selectAllByRegionIds(
412
                            partnerRegions.stream().map(x -> x.getRegionId()).collect(Collectors.toList()))
413
                    .stream().collect(Collectors.toMap(x -> x.getCatalogId(), x -> x.getMinimumQty()));
414
        } else {
415
            focusedModelMap = new HashMap<>();
416
        }
29327 tejbeer 417
 
31773 amit.gupta 418
        Map<Integer, Integer> catalogItemAailabilityMap = new HashMap<>();
29327 tejbeer 419
 
31773 amit.gupta 420
        for (Entry<Integer, Integer> fm : focusedModelMap.entrySet()) {
421
            List<Item> items = itemRepository.selectAllByCatalogItemId(fm.getKey());
422
            int allColorNetAvailability = 0;
423
            for (Item item : items) {
424
                if (retailerBlockBrands.contains(item.getBrand()))
425
                    continue;
426
                List<SaholicCISTable> currentAvailability = saholicCISTableRepository.selectByItemWarehouse(item.getId(), fofoStore.getWarehouseId());
29327 tejbeer 427
 
31773 amit.gupta 428
                if (currentAvailability != null) {
429
                    allColorNetAvailability += currentAvailability.stream()
430
                            .collect(Collectors.summingInt(SaholicCISTable::getNetAvailability));
431
                }
432
            }
433
            catalogItemAailabilityMap.put(fm.getKey(), allColorNetAvailability);
434
        }
29327 tejbeer 435
 
31773 amit.gupta 436
        List<FocusedShortageModel> focusedModelShortageList = new ArrayList<>();
29327 tejbeer 437
 
31773 amit.gupta 438
        for (Entry<Integer, Integer> fm : focusedModelMap.entrySet()) {
29327 tejbeer 439
 
31773 amit.gupta 440
            logger.info("fm {}", fm);
29404 tejbeer 441
 
31773 amit.gupta 442
            long overallStock = (inStockItemModel.get(fm.getKey()) == null ? 0 : inStockItemModel.get(fm.getKey()))
443
                    + (itempendingIndent.get(fm.getKey()) == null ? 0 : itempendingIndent.get(fm.getKey()))
444
                    + (grnItemPendingOrders.get(fm.getKey()) == null ? 0 : grnItemPendingOrders.get(fm.getKey()));
445
            logger.info("overallStock {}", overallStock);
29404 tejbeer 446
 
31773 amit.gupta 447
            // Blocked brands available quantity is discussed to zero
448
            long warehouseStock = catalogItemAailabilityMap.get(fm.getKey()) == null ? 0
449
                    : catalogItemAailabilityMap.get(fm.getKey());
450
            logger.info("warehouseStock {}", warehouseStock);
29404 tejbeer 451
 
31773 amit.gupta 452
            long cartValue = catalogCartQtyMap.get(fm.getKey()) == null ? 0 : catalogCartQtyMap.get(fm.getKey());
29404 tejbeer 453
 
31773 amit.gupta 454
            logger.info("cartValue" + cartValue);
455
            long totalStock = overallStock + cartValue;
456
            logger.info("totalStock" + totalStock);
29404 tejbeer 457
 
31773 amit.gupta 458
            long shortQty = Math.min(fm.getValue() - totalStock, warehouseStock);
459
            logger.info("shortQty {}", shortQty);
29404 tejbeer 460
 
31773 amit.gupta 461
            if (shortQty > 0) {
462
                if (focusedModelVariantMap.get(fm.getKey()) != null) {
463
                    List<Integer> variantCatalogIds = focusedModelVariantMap.get(fm.getKey());
464
                    logger.info("variantCatalogIds {}", variantCatalogIds);
29404 tejbeer 465
 
31773 amit.gupta 466
                    int variantAvailability = 0;
467
                    for (Integer vc : variantCatalogIds) {
468
                        long variantOverallStock = (inStockItemModel.get(vc) == null ? 0 : inStockItemModel.get(vc))
469
                                + (itempendingIndent.get(vc) == null ? 0 : itempendingIndent.get(vc))
470
                                + (grnItemPendingOrders.get(vc) == null ? 0 : grnItemPendingOrders.get(vc));
471
                        logger.info("variantOverallStock {}", variantOverallStock);
29404 tejbeer 472
 
31773 amit.gupta 473
                        // Blocked brands available quantity is discussed to zero
474
                        long variantWarehouseStock = catalogItemAailabilityMap.get(vc) == null ? 0
475
                                : catalogItemAailabilityMap.get(vc);
476
                        logger.info("variantWarehouseStock {}", variantWarehouseStock);
29404 tejbeer 477
 
31773 amit.gupta 478
                        long variantCartValue = catalogCartQtyMap.get(vc) == null ? 0 : catalogCartQtyMap.get(vc);
29404 tejbeer 479
 
31773 amit.gupta 480
                        logger.info("variantCartValue" + variantCartValue);
481
                        long variantTotalStock = variantOverallStock + variantCartValue;
482
                        logger.info("variantTotalStock" + variantTotalStock);
29404 tejbeer 483
 
31773 amit.gupta 484
                        variantAvailability += (int) variantTotalStock;
29327 tejbeer 485
 
31773 amit.gupta 486
                    }
29327 tejbeer 487
 
31773 amit.gupta 488
                    logger.info("variantAvailability {}", variantAvailability);
29327 tejbeer 489
 
31773 amit.gupta 490
                    shortQty = shortQty - variantAvailability;
29327 tejbeer 491
 
31773 amit.gupta 492
                }
493
            }
29327 tejbeer 494
 
31773 amit.gupta 495
            logger.info("shortQty" + shortQty);
29327 tejbeer 496
 
31773 amit.gupta 497
            if (shortQty > 0) {
29327 tejbeer 498
 
31773 amit.gupta 499
                Map<Integer, Integer> requiredItemQty = new HashMap<>();
29327 tejbeer 500
 
31773 amit.gupta 501
                List<Item> it = itemRepository.selectAllByCatalogItemId(fm.getKey());
502
                FocusedShortageModel fms = new FocusedShortageModel();
503
                fms.setShortageQty((int) shortQty);
504
                fms.setCatalogId(fm.getKey());
505
                fms.setAvailabitiy(fm.getValue());
506
                fms.setInStock(overallStock);
29327 tejbeer 507
 
31773 amit.gupta 508
                fms.setItemName(it.get(0).getBrand() + it.get(0).getModelNumber() + it.get(0).getModelName());
29327 tejbeer 509
 
31773 amit.gupta 510
                Map<Integer, Integer> itemQtyMap = new HashMap<>();
29327 tejbeer 511
 
31773 amit.gupta 512
                for (Item i : it) {
29327 tejbeer 513
 
31773 amit.gupta 514
                    List<SaholicCISTable> ca = saholicCISTableRepository.selectByItemWarehouse(i.getId(), fofoStore.getWarehouseId());
515
                    if (ca != null) {
516
                        itemQtyMap.put(i.getId(),
517
                                ca.stream().collect(Collectors.summingInt(SaholicCISTable::getNetAvailability)));
518
                    }
519
                }
29327 tejbeer 520
 
31773 amit.gupta 521
                itemQtyMap = itemQtyMap.entrySet().stream()
522
                        .sorted(Collections.reverseOrder(Map.Entry.comparingByValue())).collect(Collectors
523
                                .toMap(Map.Entry::getKey, Map.Entry::getValue, (e1, e2) -> e2, LinkedHashMap::new));
29327 tejbeer 524
 
31773 amit.gupta 525
                for (long i = shortQty; i > 0; i--) {
526
                    if (shortQty == 0) {
527
                        break;
528
                    }
29327 tejbeer 529
 
31773 amit.gupta 530
                    for (Entry<Integer, Integer> itemQty : itemQtyMap.entrySet()) {
29327 tejbeer 531
 
31773 amit.gupta 532
                        int availbleQty = itemQty.getValue();
533
                        if (availbleQty == 0) {
534
                            break;
535
                        }
536
                        if (requiredItemQty.get(itemQty.getKey()) == null) {
537
                            requiredItemQty.put(itemQty.getKey(), 1);
538
                            availbleQty = availbleQty - 1;
539
                            if (availbleQty != 0) {
540
                                itemQtyMap.put(itemQty.getKey(), availbleQty);
541
                            }
542
                            shortQty -= 1;
543
                        } else {
29327 tejbeer 544
 
31773 amit.gupta 545
                            int qty = requiredItemQty.get(itemQty.getKey());
29327 tejbeer 546
 
31773 amit.gupta 547
                            requiredItemQty.put(itemQty.getKey(), qty + 1);
29327 tejbeer 548
 
31773 amit.gupta 549
                            availbleQty = availbleQty - 1;
550
                            if (availbleQty != 0) {
551
                                itemQtyMap.put(itemQty.getKey(), availbleQty);
552
                            }
553
                            shortQty -= 1;
554
                        }
29327 tejbeer 555
 
31773 amit.gupta 556
                        if (shortQty == 0) {
557
                            break;
558
                        }
29327 tejbeer 559
 
31773 amit.gupta 560
                    }
29327 tejbeer 561
 
31773 amit.gupta 562
                }
29327 tejbeer 563
 
31773 amit.gupta 564
                Set<CartItem> cartItems = new HashSet<>();
565
                for (Entry<Integer, Integer> itemQtySet : requiredItemQty.entrySet()) {
29327 tejbeer 566
 
31773 amit.gupta 567
                    CartItem ci = new CartItem();
568
                    Item item = itemRepository.selectById(itemQtySet.getKey());
569
                    TagListing tl = tagListingRepository.selectByItemId(item.getId());
570
                    ci.setItemId(item.getId());
571
                    ci.setQuantity(itemQtySet.getValue());
572
                    ci.setSellingPrice(tl.getSellingPrice());
573
                    cartItems.add(ci);
574
 
575
                }
576
                fms.setCartItems(cartItems);
577
 
578
                // fms.setItemQtyAvailability(requiredItemQty);
579
 
580
                focusedModelShortageList.add(fms);
581
 
582
            }
583
 
584
        }
585
 
586
        logger.info("focusedModelShortageList {}", focusedModelShortageList);
587
        return focusedModelShortageList;
588
    }
589
 
33172 tejus.loha 590
    @Override
591
    public UserCart setCartItems(int fofoId, List<CartItem> cartItems) throws ProfitMandiBusinessException {
592
        User user = saholicUserRepository.selectById(fofoId);
593
        this.clearCart(user.getActiveCartId());
594
        this.addItemsToCart(user.getActiveCartId(), cartItems);
595
 
596
        UserCart userCart = new UserCart();
597
        userCart.setCartId(user.getActiveCartId());
598
        userCart.setUserId(user.getId());
599
        return userCart;
600
    }
601
 
26522 amit.gupta 602
}