WebSVN – SmartDukaan – Diff – /trunk/profitmandi-dao/src/main/java/com/spice/profitmandi/dao/cart/CartServiceImpl.java

 package com.spice.profitmandi.dao.cart;
 import com.spice.profitmandi.common.exception.ProfitMandiBusinessException;
 import com.spice.profitmandi.common.model.ProfitMandiConstants;
+import org.springframework.beans.BeanUtils;
 import com.spice.profitmandi.dao.entity.catalog.Item;
 import com.spice.profitmandi.dao.entity.catalog.TagListing;
 import com.spice.profitmandi.dao.entity.cs.PartnerRegion;
 import com.spice.profitmandi.dao.entity.fofo.FofoStore;
 import com.spice.profitmandi.dao.entity.fofo.PartnerType;
 @Component
 public class CartServiceImpl implements CartService {
     private static final Set<Integer> tagIds = new HashSet<>(Arrays.asList(4));
+    private static final float CARRY_BAG_MIN_PHONE_PRICE = 12000f;
+    private static final float CARRY_BAG_FLAT_PRICE = 1f;
     private static final Logger logger = LogManager.getLogger(CartServiceImpl.class);
     private static final Map<Integer, List<Integer>> focusedModelVariantMap = new HashMap<>();
     @Autowired
                 warehouseItemQtyMap.put(itemId, existingQty + intransitData.getQty());
+            }
+        }
         cart.setTotalPrice(0);
         int nonAccessoryQuantity = 0;
+        int carryBagAllowance = carryBagAllowance(cartLines.stream()
+                .collect(Collectors.toMap(CartLine::getItemId, CartLine::getQuantity, Integer::sum)), itemMap, tagListingsMap);
+        CarryBagQuote carryBagQuote = null;
         for (CartLine cartLine : cartLines) {
             CartItemResponseModel cartItemResponseModel = new CartItemResponseModel();
             int oldEstimate = cartLine.getEstimate();
             int itemId = cartLine.getItemId();
             // N+1 fix: Use pre-fetched itemMap instead of querying per item
             if (item.getCategoryId() == 10006 || item.getCategoryId() == 10010) {
                 nonAccessoryQuantity += cartItemResponseModel.getQuantity();
                 cartItemResponseModel.setCategoryName("mobile");
+            }
-            if (cartItemResponseModel.getItemId() == ProfitMandiConstants.ITEM_CARRY_BAG) {
+            if (itemId == ProfitMandiConstants.ITEM_CARRY_BAG) {
-                if (partnerType.equals(PartnerType.BRONZE)) {
+                carryBagQuote = carryBagQuote(partnerType, carryBagAllowance, cartLine.getQuantity(), tagListingsMap.get(itemId));
-                    cartLine.setActualPrice(tagListingsMap.get(itemId).getSellingPrice());
+                cartLine.setActualPrice(carryBagQuote.getUnitPrice());
-                    cartItemResponseModel.setSellingPrice(cartLine.getActualPrice());
+                cartItemResponseModel.setSellingPrice(cartLine.getActualPrice());
-                } else {
-                    cartItemResponseModel.setSellingPrice(1);
-                    cartLine.setActualPrice(1);
-                }
             } else {
                 // Check for price mismatch between cart and current TagListing
                 TagListing currentTagListing = tagListingsMap.get(itemId);
                 if (currentTagListing != null) {
                     float cartPrice = cartLine.getActualPrice();
+            }
+        }
         cartResponse.setTotalQty(totalQty);
         cartResponse.setTotalAmount(totalAmount);
         cartResponse.setNonAccessoryQuantity(nonAccessoryQuantity);
+        cartResponse.setCarryBag(carryBagQuote != null ? carryBagQuote
+                : carryBagQuote(partnerType, carryBagAllowance, 0, tagListingRepository.selectByItemId(ProfitMandiConstants.ITEM_CARRY_BAG)));
         cartResponse.setShippingCharge(0);
         cartResponse.setCartMessageChanged(cartMessageChanged);
         cartResponse.setCartMessageOOS(cartMessageOOS);
         cartResponse.setCartMessageUndeliverable(cartMessageUndeliverable);
         cartResponse.setCod(false);
         cart.setAddressId((int) addressId);
+    }
     @Override
-    public void addShoppingBag(int cartId, long qty) {
-        // Cart row first, then lines -- see CartRepository.selectByIdForUpdate.
+    public CarryBagQuote getCarryBagQuote(int fofoId, Map<Integer, Integer> itemQty) throws ProfitMandiBusinessException {
-        cartRepository.selectByIdForUpdate(cartId);
-        CartLine cl = new CartLine();
+        Set<Integer> itemIds = new HashSet<>(itemQty.keySet());
-        cl.setItemId(ProfitMandiConstants.ITEM_CARRY_BAG);
+        itemIds.add(ProfitMandiConstants.ITEM_CARRY_BAG);
-        cl.setQuantity((int) qty);
+        Map<Integer, Item> itemMap = itemRepository.selectByIds(itemIds).stream()
-        cl.setCartId(cartId);
+                .collect(Collectors.toMap(Item::getId, x -> x));
-        cl.setCreateTimestamp(LocalDateTime.now());
+        Map<Integer, TagListing> tagListingsMap = tagListingRepository.selectByItemIdsAndTagIds(itemIds, tagIds).stream()
-        cl.setDataProtectionAmount(0);
+                .collect(Collectors.toMap(TagListing::getItemId, x -> x, (a, b) -> a));
-        cl.setEstimate(0);
+        return carryBagQuote(partnerTypeChangeService.getTypeOnDate(fofoId, LocalDate.now()),
-        cl.setInsuranceAmount(0f);
+                carryBagAllowance(itemQty, itemMap, tagListingsMap),
-        cl.setDataProtectionInsurer(0);
+                itemQty.getOrDefault(ProfitMandiConstants.ITEM_CARRY_BAG, 0),
-        cl.setActualPrice(0.01f);
+                tagListingsMap.get(ProfitMandiConstants.ITEM_CARRY_BAG));
-        cartLineRepository.persist(cl);
+    }
+    @Override
+    public List<CartLine> splitCarryBagLine(int fofoId, List<CartLine> cartLines) throws ProfitMandiBusinessException {
+        CartLine bagLine = cartLines.stream()
+                .filter(x -> x.getItemId() == ProfitMandiConstants.ITEM_CARRY_BAG).findFirst().orElse(null);
+        if (bagLine == null) return cartLines;
+        CarryBagQuote quote = this.getCarryBagQuote(fofoId, cartLines.stream()
+                .collect(Collectors.toMap(CartLine::getItemId, CartLine::getQuantity, Integer::sum)));
+        List<CartLine> split = cartLines.stream().filter(x -> x != bagLine).collect(Collectors.toList());
+        addCarryBagPart(split, bagLine, quote.getFlatQty(), quote.getFlatPrice());
+        addCarryBagPart(split, bagLine, quote.getListingQty(), quote.getListingPrice());
+        return split;
+    }
+    // A detached copy of the bag line - never persisted, the cart keeps its single line
+    private static void addCarryBagPart(List<CartLine> lines, CartLine bagLine, int qty, float price) {
+        if (qty <= 0) return;
+        CartLine part = new CartLine();
+        BeanUtils.copyProperties(bagLine, part);
+        part.setQuantity(qty);
+        part.setActualPrice(price);
+        lines.add(part);
+    }
+    // Bronze partners pay the listing price for every bag
+    private static CarryBagQuote carryBagQuote(PartnerType partnerType, int allowance, int bags, TagListing bagListing) {
+        return new CarryBagQuote(allowance, bags, partnerType != PartnerType.BRONZE, CARRY_BAG_FLAT_PRICE, bagListing.getSellingPrice());
+    }
+    /** One carry bag per unit of a smartphone selling above Rs. 12,000. */
+    private static int carryBagAllowance(Map<Integer, Integer> itemQty, Map<Integer, Item> itemMap,
+                                         Map<Integer, TagListing> tagListingsMap) {
+        int allowance = 0;
+        for (Entry<Integer, Integer> e : itemQty.entrySet()) {
+            Item item = itemMap.get(e.getKey());
+            TagListing tagListing = tagListingsMap.get(e.getKey());
+            if (item != null && tagListing != null && item.getCategoryId() == ProfitMandiConstants.MOBILE_CATEGORY_ID
+                    && tagListing.getSellingPrice() > CARRY_BAG_MIN_PHONE_PRICE) {
+                allowance += e.getValue();
+            }
+        }
+        return allowance;
+    }
     @Override
     public CartModel removeFromCart(int cartId, int itemId) {
         // TODO Auto-generated method stub

Subversion Repositories SmartDukaan

(root)/trunk/profitmandi-dao/src/main/java/com/spice/profitmandi/dao/cart/CartServiceImpl.java – Rev 37706 → 37792