|
|
@@ -0,0 +1,261 @@
|
|
|
+package com.macro.mall.portal.service.impl;
|
|
|
+
|
|
|
+import com.macro.mall.model.OmsCartItem;
|
|
|
+import com.macro.mall.model.PmsProductFullReduction;
|
|
|
+import com.macro.mall.model.PmsProductLadder;
|
|
|
+import com.macro.mall.model.PmsSkuStock;
|
|
|
+import com.macro.mall.portal.dao.PortalProductDao;
|
|
|
+import com.macro.mall.portal.domain.CartPromotionItem;
|
|
|
+import com.macro.mall.portal.domain.PromotionProduct;
|
|
|
+import com.macro.mall.portal.service.OmsPromotionService;
|
|
|
+import org.springframework.beans.factory.annotation.Autowired;
|
|
|
+import org.springframework.stereotype.Service;
|
|
|
+
|
|
|
+import java.math.BigDecimal;
|
|
|
+import java.util.*;
|
|
|
+
|
|
|
+/**
|
|
|
+ * Created by macro on 2018/8/27.
|
|
|
+ * 促销管理Service实现类
|
|
|
+ */
|
|
|
+@Service
|
|
|
+public class OmsPromotionServiceImpl implements OmsPromotionService {
|
|
|
+ @Autowired
|
|
|
+ private PortalProductDao portalProductDao;
|
|
|
+
|
|
|
+ @Override
|
|
|
+ public List<CartPromotionItem> calcCartPromotion(List<OmsCartItem> cartItemList) {
|
|
|
+ //1.先根据productId对CartItem进行分组，以spu为单位进行计算优惠
|
|
|
+ Map<Long, List<OmsCartItem>> productCartMap = groupCartItemBySpu(cartItemList);
|
|
|
+ //2.查询所有商品的优惠相关信息
|
|
|
+ List<PromotionProduct> promotionProductList = getPromotionProductList(cartItemList);
|
|
|
+ //3.根据商品促销类型计算商品促销优惠价格
|
|
|
+ List<CartPromotionItem> cartPromotionItemList = new ArrayList<>();
|
|
|
+ for (Map.Entry<Long, List<OmsCartItem>> entry : productCartMap.entrySet()) {
|
|
|
+ Long productId = entry.getKey();
|
|
|
+ PromotionProduct promotionProduct = getPromotionProductById(productId, promotionProductList);
|
|
|
+ List<OmsCartItem> itemList = entry.getValue();
|
|
|
+ Integer promotionType = promotionProduct.getPromotionType();
|
|
|
+ if (promotionType == 1) {
|
|
|
+ //单品促销
|
|
|
+ for (OmsCartItem item : itemList) {
|
|
|
+ CartPromotionItem cartPromotionItem = new CartPromotionItem();
|
|
|
+ cartPromotionItem.setCartItem(item);
|
|
|
+ cartPromotionItem.setPromotionMessage("单品促销");
|
|
|
+ //商品原价-促销价
|
|
|
+ cartPromotionItem.setReduceAmount(getOriginalPrice(promotionProduct, item.getProductSkuId()).subtract(getSinglePromotionPrice(promotionProduct, item.getProductSkuId())));
|
|
|
+ cartPromotionItemList.add(cartPromotionItem);
|
|
|
+ }
|
|
|
+ } else if (promotionType == 3) {
|
|
|
+ //打折优惠
|
|
|
+ int count = getCartItemCount(itemList);
|
|
|
+ PmsProductLadder ladder = getProductLadder(count, promotionProduct.getProductLadderList());
|
|
|
+ if(ladder!=null){
|
|
|
+ for (OmsCartItem item : itemList) {
|
|
|
+ CartPromotionItem cartPromotionItem = new CartPromotionItem();
|
|
|
+ cartPromotionItem.setCartItem(item);
|
|
|
+ String message = getLadderPromotionMessage(ladder);
|
|
|
+ cartPromotionItem.setPromotionMessage(message);
|
|
|
+ //商品原价-折扣金额*商品原价
|
|
|
+ BigDecimal originalPrice = getOriginalPrice(promotionProduct, item.getProductSkuId());
|
|
|
+ BigDecimal reduceAmount = originalPrice.subtract(ladder.getDiscount().multiply(originalPrice));
|
|
|
+ cartPromotionItem.setReduceAmount(reduceAmount);
|
|
|
+ cartPromotionItemList.add(cartPromotionItem);
|
|
|
+ }
|
|
|
+ }else{
|
|
|
+ handleNoReduce(cartPromotionItemList,itemList);
|
|
|
+ }
|
|
|
+ } else if (promotionType == 4) {
|
|
|
+ //满减
|
|
|
+ BigDecimal totalAmount= getCartItemAmount(itemList,promotionProductList);
|
|
|
+ PmsProductFullReduction fullReduction = getProductFullReduction(totalAmount,promotionProduct.getProductFullReductionList());
|
|
|
+ if(fullReduction!=null){
|
|
|
+ for (OmsCartItem item : itemList) {
|
|
|
+ CartPromotionItem cartPromotionItem = new CartPromotionItem();
|
|
|
+ cartPromotionItem.setCartItem(item);
|
|
|
+ String message = getFullReductionPromotionMessage(fullReduction);
|
|
|
+ cartPromotionItem.setPromotionMessage(message);
|
|
|
+ //(商品原价/总价)*满减金额
|
|
|
+ BigDecimal reduceAmount = (getOriginalPrice(promotionProduct,item.getProductSkuId()).divide(totalAmount)).multiply(fullReduction.getReducePrice());
|
|
|
+ cartPromotionItem.setReduceAmount(reduceAmount);
|
|
|
+ cartPromotionItemList.add(cartPromotionItem);
|
|
|
+ }
|
|
|
+ }else{
|
|
|
+ handleNoReduce(cartPromotionItemList,itemList);
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ //无优惠
|
|
|
+ handleNoReduce(cartPromotionItemList, itemList);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return cartPromotionItemList;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 查询所有商品的优惠相关信息
|
|
|
+ */
|
|
|
+ private List<PromotionProduct> getPromotionProductList(List<OmsCartItem> cartItemList) {
|
|
|
+ List<Long> productIdList = new ArrayList<>();
|
|
|
+ for(OmsCartItem cartItem:cartItemList){
|
|
|
+ productIdList.add(cartItem.getProductId());
|
|
|
+ }
|
|
|
+ return portalProductDao.getPromotionProductList(productIdList);
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 以spu为单位对购物车中商品进行分组
|
|
|
+ */
|
|
|
+ private Map<Long, List<OmsCartItem>> groupCartItemBySpu(List<OmsCartItem> cartItemList) {
|
|
|
+ Map<Long, List<OmsCartItem>> productCartMap = new TreeMap<>();
|
|
|
+ for (OmsCartItem cartItem : cartItemList) {
|
|
|
+ List<OmsCartItem> productCartItemList = productCartMap.get(cartItem.getId());
|
|
|
+ if (productCartItemList == null) {
|
|
|
+ productCartItemList = new ArrayList<>();
|
|
|
+ productCartItemList.add(cartItem);
|
|
|
+ productCartMap.put(cartItem.getProductId(), productCartItemList);
|
|
|
+ } else {
|
|
|
+ productCartItemList.add(cartItem);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return productCartMap;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 获取满减促销消息
|
|
|
+ */
|
|
|
+ private String getFullReductionPromotionMessage(PmsProductFullReduction fullReduction) {
|
|
|
+ StringBuilder sb = new StringBuilder();
|
|
|
+ sb.append("满减优惠：");
|
|
|
+ sb.append("满");
|
|
|
+ sb.append(fullReduction.getFullPrice());
|
|
|
+ sb.append("元，");
|
|
|
+ sb.append("减");
|
|
|
+ sb.append(fullReduction.getReducePrice());
|
|
|
+ sb.append("元");
|
|
|
+ return sb.toString();
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 对没满足优惠条件的商品进行处理
|
|
|
+ */
|
|
|
+ private void handleNoReduce(List<CartPromotionItem> cartPromotionItemList, List<OmsCartItem> itemList) {
|
|
|
+ for (OmsCartItem item : itemList) {
|
|
|
+ CartPromotionItem cartPromotionItem = new CartPromotionItem();
|
|
|
+ cartPromotionItem.setCartItem(item);
|
|
|
+ cartPromotionItem.setPromotionMessage("无优惠");
|
|
|
+ cartPromotionItem.setReduceAmount(new BigDecimal(0));
|
|
|
+ cartPromotionItemList.add(cartPromotionItem);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ private PmsProductFullReduction getProductFullReduction(BigDecimal totalAmount,List<PmsProductFullReduction> fullReductionList) {
|
|
|
+ //按条件从高到低排序
|
|
|
+ fullReductionList.sort(new Comparator<PmsProductFullReduction>() {
|
|
|
+ @Override
|
|
|
+ public int compare(PmsProductFullReduction o1, PmsProductFullReduction o2) {
|
|
|
+ return o2.getFullPrice().subtract(o1.getFullPrice()).intValue();
|
|
|
+ }
|
|
|
+ });
|
|
|
+ for(PmsProductFullReduction fullReduction:fullReductionList){
|
|
|
+ if(totalAmount.subtract(fullReduction.getFullPrice()).intValue()>=0){
|
|
|
+ return fullReduction;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return null;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 获取打折优惠的促销信息
|
|
|
+ */
|
|
|
+ private String getLadderPromotionMessage(PmsProductLadder ladder) {
|
|
|
+ StringBuilder sb = new StringBuilder();
|
|
|
+ sb.append("打折优惠：");
|
|
|
+ sb.append("满");
|
|
|
+ sb.append(ladder.getCount());
|
|
|
+ sb.append("件，");
|
|
|
+ sb.append("打");
|
|
|
+ sb.append(ladder.getDiscount().multiply(new BigDecimal(10)));
|
|
|
+ sb.append("折");
|
|
|
+ return sb.toString();
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 根据购买商品数量获取满足条件的打折优惠策略
|
|
|
+ */
|
|
|
+ private PmsProductLadder getProductLadder(int count, List<PmsProductLadder> productLadderList) {
|
|
|
+ //按数量从大到小排序
|
|
|
+ productLadderList.sort(new Comparator<PmsProductLadder>() {
|
|
|
+ @Override
|
|
|
+ public int compare(PmsProductLadder o1, PmsProductLadder o2) {
|
|
|
+ return o2.getCount() - o1.getCount();
|
|
|
+ }
|
|
|
+ });
|
|
|
+ for (PmsProductLadder productLadder : productLadderList) {
|
|
|
+ if (count >= productLadder.getCount()) {
|
|
|
+ return productLadder;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return null;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 获取购物车中指定商品的数量
|
|
|
+ */
|
|
|
+ private int getCartItemCount(List<OmsCartItem> itemList) {
|
|
|
+ int count = 0;
|
|
|
+ for (OmsCartItem item : itemList) {
|
|
|
+ count += item.getQuantity();
|
|
|
+ }
|
|
|
+ return count;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 获取购物车中指定商品的总价
|
|
|
+ */
|
|
|
+ private BigDecimal getCartItemAmount(List<OmsCartItem> itemList, List<PromotionProduct> promotionProductList) {
|
|
|
+ BigDecimal amount = new BigDecimal(0);
|
|
|
+ for (OmsCartItem item : itemList) {
|
|
|
+ //计算出商品原价
|
|
|
+ PromotionProduct promotionProduct = getPromotionProductById(item.getProductId(), promotionProductList);
|
|
|
+ BigDecimal price = getOriginalPrice(promotionProduct,item.getProductSkuId());
|
|
|
+ amount = amount.add(price.multiply(new BigDecimal(item.getQuantity())));
|
|
|
+ }
|
|
|
+ return amount;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 获取商品的单品促销价格
|
|
|
+ */
|
|
|
+ private BigDecimal getSinglePromotionPrice(PromotionProduct promotionProduct, Long productSkuId) {
|
|
|
+ for (PmsSkuStock skuStock : promotionProduct.getSkuStockList()) {
|
|
|
+ if (productSkuId == skuStock.getId()) {
|
|
|
+ return skuStock.getPromotionPrice();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return null;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 获取商品的原价
|
|
|
+ */
|
|
|
+ private BigDecimal getOriginalPrice(PromotionProduct promotionProduct, Long productSkuId) {
|
|
|
+ for (PmsSkuStock skuStock : promotionProduct.getSkuStockList()) {
|
|
|
+ if (productSkuId.equals(skuStock.getId())) {
|
|
|
+ return skuStock.getPrice();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return null;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 根据商品id获取商品的促销信息
|
|
|
+ */
|
|
|
+ private PromotionProduct getPromotionProductById(Long productId, List<PromotionProduct> promotionProductList) {
|
|
|
+ for (PromotionProduct promotionProduct : promotionProductList) {
|
|
|
+ if (productId.equals(promotionProduct.getId())) {
|
|
|
+ return promotionProduct;
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return null;
|
|
|
+ }
|
|
|
+}
|
zhh