Subversion Repositories SmartDukaan

Rev

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