促销计算代码优化

shopping-cart-application-service/src/main/java/cn/freemud/entities/vo/CartGoods.java

@@ -59,7 +59,7 @@ public class CartGoods {
      */
     private String specProductId;
     /**
-     * 购物车一行商品的原单机
+     * 购物车一行商品的原单价
      */
     private Long originalPrice;
     /**

shopping-cart-application-service/src/main/java/cn/freemud/service/impl/CalculationServiceImpl.java

-package cn.freemud.service.impl;
-
-import cn.freemud.constant.ResponseCodeConstant;
-import cn.freemud.entities.dto.ActivityCalculationDiscountRequestDto;
-import cn.freemud.entities.dto.ActivityCalculationDiscountResponseDto;
-import cn.freemud.entities.dto.UserLoginInfoDto;
-import cn.freemud.entities.dto.activity.ActivityQueryDto;
-import cn.freemud.entities.vo.*;
-import cn.freemud.enums.ActivityChannelEnum;
-import cn.freemud.enums.ResponseResult;
-import cn.freemud.interceptor.ServiceException;
-import cn.freemud.service.CommonService;
-import cn.freemud.service.thirdparty.ActivityClient;
-import cn.freemud.utils.PropertyConvertUtil;
-import com.freemud.application.sdk.api.log.ErrorLog;
-import org.apache.commons.lang.StringUtils;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.stereotype.Service;
-
-import java.util.ArrayList;
-import java.util.List;
-import java.util.Objects;
-
-/**
- * All rights Reserved, Designed By www.freemud.cn
- *
- * @version V1.0
- * @Title: CalculationServiceImpl
- * @Package cn.freemud.service.impl
- * @Description:
- * @author: shuhu.hou
- * @date: 2020/6/11 17:06
- * @Copyright: 2020 www.freemud.cn Inc. All rights reserved.
- * 注意：本内容仅限于上海非码科技内部传阅，禁止外泄以及用于其他的商业目
- */
-@Service
-public class CalculationServiceImpl {
-
-
-    @Autowired
-    private CommonService commonService;
-    @Autowired
-    private ActivityClient activityClient;
-
-    /**
-     * 更新购物车行优惠信息
-     */
-    public void updateShoppingCartGoodsDiscount(
-            String partnerId, String storeId, String userId, String appId, Integer orderType, boolean isMember,String menuType, Long deliveryAmount,
-            ShoppingCartInfoRequestVo requestVo, ShoppingCartGoodsResponseVo shoppingCartGoodsResponseVo, CustomerInfoVo customerInfoVo,
-            List<CartGoods> cartGoodsList,
-
-            CouponPromotionVO couponPromotionVO, ActivityQueryDto activityQueryDto,
-            UserLoginInfoDto userLoginInfoDto
-            ) {
-//        ActivityCalculationDiscountResponseDto.CalculationDiscountResult calculationDiscount = getCalculationDiscount(requestVo, customerInfoVo, cartGoodsList, deliveryAmout);
-//        defaultDiscountStrategy.updateShoppingCartGoodsDiscount(shoppingCartGoodsResponseVo, cartGoodsList, calculationDiscount);
-//        fullSubDiscountStrategy.updateShoppingCartGoodsDiscount(requestVo,shoppingCartGoodsResponseVo, cartGoodsList,customerInfoVo, calculationDiscount);
-//        customerScoreService.updateShoppingCartGoodsDiscount(null, null, calculationDiscount, cartGoodsList, shoppingCartGoodsResponseVo, BeanUtil.convertBean(customerInfoVo, UserLoginInfoDto::new), requestVo);
-//        setMealDiscountStrategy.updateShoppingCartGoodsDiscount(shoppingCartGoodsResponseVo, cartGoodsList, calculationDiscount);
-    }
-
-
-
-    public ActivityCalculationDiscountResponseDto.CalculationDiscountResult getCalculationDiscount(
-            String partnerId, String storeId, String userId, String appId, Integer orderType, boolean isMember, List<CartGoods> cartGoodsList,
-            List<ActivityCalculationDiscountRequestDto.CalculationDiscountCoupon> coupons,
-            List<ShoppingCartInfoRequestVo.SendGoods> sendGoodsList, String menuType, Long deliveryAmount) {
-
-        List<ActivityCalculationDiscountRequestDto.CalculationDiscountGoods> calculationDiscountGoodsList = new ArrayList<>();
-        for (CartGoods cartGoods : cartGoodsList){
-            addCalculationDiscountGoods(calculationDiscountGoodsList, cartGoods.getGoodsId(), cartGoods.getQty(), cartGoods.getFinalPrice(), cartGoods.getMemberDiscount());
-        }
-
-        ActivityCalculationDiscountRequestDto discountRequest = getActivityCalculationDiscountRequestDto(partnerId, storeId, userId, appId, orderType);
-        discountRequest.setGoods(calculationDiscountGoodsList);
-        discountRequest.setCoupons(coupons);
-        discountRequest.setOrgIds(commonService.getOrgIds(partnerId, storeId));
-        discountRequest.setDistributionFee(deliveryAmount);
-        discountRequest.setIsMember(isMember);
-        try {
-            ActivityCalculationDiscountResponseDto activityCalculationDiscountResponseDto = activityClient.calculationDiscountSharing(discountRequest);
-            // 返回成功
-            if (activityCalculationDiscountResponseDto != null && StringUtils.equals(activityCalculationDiscountResponseDto.getStatusCode(), ResponseCodeConstant.RESPONSE_SUCCESS_STR)) {
-                ActivityCalculationDiscountResponseDto.CalculationDiscountResult result = activityCalculationDiscountResponseDto.getResult();
-                result.setDeliveryAmount(deliveryAmount);
-                result.setDistributionFee(result.getDistributionFee());
-                return result;
-            }
-        } catch (Exception ex) {
-            ErrorLog.printErrorLog("calculation_discount_error", "/calculation/discount/sharding", discountRequest, ex);
-            throw new ServiceException(ResponseResult.OPERATE_TOO_OFTEN);
-        }
-        throw new ServiceException(ResponseResult.OPERATE_TOO_OFTEN);
-    }
-
-
-    /**
-     * 构建 ActivityCalculationDiscountRequestDto
-     *
-     * @param partnerId
-     * @param storeId
-     * @param userId
-     * @param appId
-     * @param orderType
-     * @return
-     */
-    private ActivityCalculationDiscountRequestDto getActivityCalculationDiscountRequestDto(String partnerId, String storeId, String userId, String appId, Integer orderType) {
-        ActivityCalculationDiscountRequestDto activityCalculationDiscountRequestDto = new ActivityCalculationDiscountRequestDto();
-        activityCalculationDiscountRequestDto.setPartnerCode(partnerId);
-        activityCalculationDiscountRequestDto.setStoreId(storeId);
-        activityCalculationDiscountRequestDto.setIsShowGoodsActivity(1);
-        activityCalculationDiscountRequestDto.setUserId(userId);
-        activityCalculationDiscountRequestDto.setVer(1);
-        activityCalculationDiscountRequestDto.setAppId(appId);
-        ActivityChannelEnum activityChannelEnum = PropertyConvertUtil.orderTypeConvert2ActivityChannel(orderType);
-        if (!Objects.isNull(activityChannelEnum)) {
-            activityCalculationDiscountRequestDto.setChannel(activityChannelEnum.getCode());
-        }
-        return activityCalculationDiscountRequestDto;
-    }
-
-    /**
-     * 将calculationDiscountGoods 封装后加入 calculationDiscountGoodsList
-     *
-     * @param calculationDiscountGoodsList
-     * @param goodsId
-     * @param goodsQuantity
-     * @param originalPrice
-     */
-    private void addCalculationDiscountGoods(List<ActivityCalculationDiscountRequestDto.CalculationDiscountGoods> calculationDiscountGoodsList,
-                                             String goodsId, Integer goodsQuantity, Long originalPrice, Integer memberDiscount) {
-        ActivityCalculationDiscountRequestDto.CalculationDiscountGoods calculationDiscountGoods = new ActivityCalculationDiscountRequestDto.CalculationDiscountGoods();
-        calculationDiscountGoods.setGoodsId(goodsId);
-        calculationDiscountGoods.setGoodsQuantity(goodsQuantity);
-        calculationDiscountGoods.setOriginalPrice(originalPrice);
-        calculationDiscountGoods.setMemberDiscount(memberDiscount);
-
-        //累加需加入计算的商品
-        int index;
-        // 当商品已存在时,需累加数量
-        if ((index = calculationDiscountGoodsList.indexOf(calculationDiscountGoods)) >= 0) {
-            ActivityCalculationDiscountRequestDto.CalculationDiscountGoods oldCalculationDiscountGoods = calculationDiscountGoodsList.get(index);
-            oldCalculationDiscountGoods.setGoodsQuantity(oldCalculationDiscountGoods.getGoodsQuantity() + calculationDiscountGoods.getGoodsQuantity());
-        } else {
-            calculationDiscountGoodsList.add(calculationDiscountGoods);
-        }
-    }
-
-
-}

shopping-cart-application-service/src/main/java/cn/freemud/service/impl/mcoffee/calculation/CouponDiscountCalculation.java

+package cn.freemud.service.impl.mcoffee.calculation;
+
+import cn.freemud.entities.dto.ActivityCalculationDiscountResponseDto;
+import cn.freemud.entities.dto.CheckSpqInfoResponseDto;
+import cn.freemud.entities.vo.ActivityClassifyCouponBean;
+import cn.freemud.entities.vo.CartGoods;
+import cn.freemud.entities.vo.CouponPromotionVO;
+import cn.freemud.entities.vo.ShoppingCartGoodsResponseVo;
+import cn.freemud.enums.CouponFlag;
+import cn.freemud.service.CouponService;
+import com.freemud.sdk.api.assortment.shoppingcart.constant.CommonsConstant;
+import com.google.common.collect.Lists;
+import org.apache.commons.collections4.CollectionUtils;
+import org.apache.commons.collections4.MapUtils;
+import org.apache.commons.lang.ObjectUtils;
+import org.apache.commons.lang.StringUtils;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.Objects;
+import java.util.stream.Collectors;
+
+/**
+ * All rights Reserved, Designed By www.freemud.cn
+ *
+ * @version V1.0
+ * @Title: CouponDiscountCalculation
+ * @Package cn.freemud.service.impl.mcoffee
+ * @Description:
+ * @author: ping1.wu
+ * @date: 2020/8/3 16:02
+ * @Copyright: 2020 www.freemud.cn Inc. All rights reserved.
+ * 注意：本内容仅限于上海非码科技内部传阅，禁止外泄以及用于其他的商业目
+ */
+@Service
+public class CouponDiscountCalculation {
+
+    @Autowired
+    private CouponService couponService;
+
+
+
+    public void updateShoppingCartGoodsDiscountCoupon(CouponPromotionVO couponPromotionVO, ActivityCalculationDiscountResponseDto.CalculationDiscountResult calculationDiscountResult, List<CartGoods> cartGoodsList, ShoppingCartGoodsResponseVo shoppingCartGoodsResponseVo) {
+        // 用户选择了查询优惠券信息
+        if (couponPromotionVO != null && ObjectUtils.equals(CouponFlag.YES.getCode(), couponPromotionVO.getFlg())) {
+            List<CartGoods> tmpCartGoods = cartGoodsList.parallelStream().filter(k -> k.getCartGoodsUid().startsWith(CommonsConstant.COUPON_PREFIX)).collect(Collectors.toList());
+            // 是否存在商品券
+            boolean hasGoodssCoupon = CollectionUtils.isNotEmpty(tmpCartGoods);
+            // 构建可用不可用优惠券
+            ActivityClassifyCouponBean activityClassifyCouponBean = couponService.availableCoupon(cartGoodsList, couponPromotionVO.getPartnerId()
+                    , couponPromotionVO.getUserId(), couponPromotionVO.getStoreId(), couponPromotionVO.getCouponCode(), hasGoodssCoupon, couponPromotionVO.getOrderType());
+            if (Objects.equals(activityClassifyCouponBean, null)) {
+                // 构建一个空得订单券信息
+                activityClassifyCouponBean = new ActivityClassifyCouponBean();
+                activityClassifyCouponBean.setCouponNum(0);
+                activityClassifyCouponBean.setDisableCouponNum(0);
+                activityClassifyCouponBean.setUsableCouponNum(0);
+                activityClassifyCouponBean.setDisableCoupons(Lists.newArrayList());
+                activityClassifyCouponBean.setUsableCoupons(Lists.newArrayList());
+            }
+            shoppingCartGoodsResponseVo.setAvailableCoupon(activityClassifyCouponBean);
+        }
+
+        // 当couponCode不为空时，需计算优惠价格
+        long couponDiscount = 0;
+        if (couponPromotionVO != null && StringUtils.isNotEmpty(couponPromotionVO.getCouponCode())
+                && calculationDiscountResult != null) {
+            List<ActivityCalculationDiscountResponseDto.CalculationDiscountResult.CouponResults> couponResultsList = calculationDiscountResult.getCouponDiscounts();
+            if (CollectionUtils.isNotEmpty(couponResultsList)) {
+                for (ActivityCalculationDiscountResponseDto.CalculationDiscountResult.CouponResults couponResults : couponResultsList) {
+                    couponDiscount = couponDiscount + (couponResults.getDiscountAmount() == null ? 0 : couponResults.getDiscountAmount());
+                }
+            }
+        }
+        shoppingCartGoodsResponseVo.setCouponDiscount(couponDiscount);
+        //循环购物车商品券
+        for (CartGoods cartGoods : cartGoodsList) {
+            if (cartGoods.getCartGoodsUid().startsWith(CommonsConstant.COUPON_PREFIX)) {
+                String spqId = cartGoods.getCartGoodsUid().substring(CommonsConstant.COUPON_PREFIX.length());
+                // 计算优惠信息时，已将券校验过，放在map中
+                Map<String, CheckSpqInfoResponseDto> validCouponMap = calculationDiscountResult == null ? new HashMap<>() : calculationDiscountResult.getValidCouponMap();
+                if (MapUtils.isNotEmpty(validCouponMap)) {
+                    CheckSpqInfoResponseDto checkSpqInfoResponseDto = validCouponMap.get(spqId);
+                    if (checkSpqInfoResponseDto != null) {
+                        cartGoods.setOriginalPrice(checkSpqInfoResponseDto.getPrice());
+                        cartGoods.setSpuId(checkSpqInfoResponseDto.getSpuId());
+                        cartGoods.setSkuId(StringUtils.isEmpty(checkSpqInfoResponseDto.getSkuId()) ? checkSpqInfoResponseDto.getSpuId() : checkSpqInfoResponseDto.getSkuId());
+                        cartGoods.setQty(1);
+                        cartGoods.setCouponCode(checkSpqInfoResponseDto.getCouponCode());
+                        cartGoods.setSpuName(checkSpqInfoResponseDto.getSpuName());
+                    }
+                }
+            }
+        }
+
+    }
+
+
+}

shopping-cart-application-service/src/main/java/cn/freemud/service/impl/mcoffee/calculation/TimeSaleCalculation.java

+package cn.freemud.service.impl.mcoffee.calculation;
+
+import cn.freemud.entities.dto.ActivityCalculationDiscountResponseDto;
+import cn.freemud.entities.vo.CartGoods;
+import cn.freemud.entities.vo.ShoppingCartGoodsResponseVo;
+import cn.freemud.enums.ActivityTypeEnum;
+import org.apache.commons.collections4.CollectionUtils;
+import org.apache.commons.lang.StringUtils;
+import org.springframework.stereotype.Service;
+
+import java.util.*;
+import java.util.function.Function;
+import java.util.stream.Collectors;
+
+/**
+ * All rights Reserved, Designed By www.freemud.cn
+ *
+ * @version V1.0
+ * @Title: TimeSaleCalculation
+ * @Package cn.freemud.service.impl.mcoffee
+ * @Description:
+ * @author: ping1.wu
+ * @date: 2020/8/3 16:07
+ * @Copyright: 2020 www.freemud.cn Inc. All rights reserved.
+ * 注意：本内容仅限于上海非码科技内部传阅，禁止外泄以及用于其他的商业目
+ */
+
+@Service
+public class TimeSaleCalculation {
+
+
+    /**
+     * 限时特价
+     *
+     * @return
+     */
+    public void TimeSaleUpdateShoppingCartGoodsDiscount(ActivityCalculationDiscountResponseDto.CalculationDiscountResult calculationDiscountResult, List<CartGoods> cartGoodsList, ShoppingCartGoodsResponseVo shoppingCartGoodsResponseVo) {
+        if (calculationDiscountResult == null || CollectionUtils.isEmpty(calculationDiscountResult.getDiscounts())
+                || !calculationDiscountResult.getDiscounts().stream().anyMatch(discount -> (ActivityTypeEnum.TYPE_2.getCode().equals(discount.getType()) || (ActivityTypeEnum.TYPE_21.getCode().equals(discount.getType()))))) {
+            return;
+        }
+        List<ActivityCalculationDiscountResponseDto.CalculationDiscountResult.Goods> goodsList = calculationDiscountResult.getGoods();
+        if (CollectionUtils.isEmpty(goodsList)) {
+            return;
+        }
+        String toastMsg = null;
+        Map<String, ActivityCalculationDiscountResponseDto.CalculationDiscountResult.Goods> goodsMap = goodsList.parallelStream()
+                .collect(Collectors.toMap(ActivityCalculationDiscountResponseDto.CalculationDiscountResult.Goods::getGoodsId, Function.identity(), (k1, k2) -> k1));
+        // 存储当前享受限时特价折扣的商品数量，key:goodsId; value:可享受数量
+        Map<String, Integer> numberMap = new HashMap<>();
+        List<Integer> discounts = Arrays.asList(ActivityTypeEnum.TYPE_2.getCode(), ActivityTypeEnum.TYPE_21.getCode());
+        for (CartGoods cartGoods : cartGoodsList) {
+            ActivityCalculationDiscountResponseDto.CalculationDiscountResult.Goods goods;
+            if ((goods = goodsMap.get(cartGoods.getGoodsId())) == null) {
+                continue;
+            }
+            ActivityCalculationDiscountResponseDto.CalculationDiscountResult.Goods.GoodsDiscount goodsDiscount = getGoodsDiscount(goods.getDiscounts(), discounts);
+            if (goodsDiscount == null) {
+                continue;
+            }
+            // 享受限时特价折扣的商品数量
+            Integer specialActualGoodsNumber = null;
+            // 商品现价
+            Long goodsNowPrice = cartGoods.getOriginalPrice() - goodsDiscount.getDiscount() / goodsDiscount.getActualGoodsNumber();
+            // numberMap用于暂存当前商品行可享受限时特价折扣的商品数量
+            if ((specialActualGoodsNumber = numberMap.get(goods.getGoodsId())) == null) {
+                numberMap.put(goods.getGoodsId(), specialActualGoodsNumber = goodsDiscount.getActualGoodsNumber());
+            }
+            //若可享受数量>=当前商品行的商品数量
+            if (specialActualGoodsNumber - cartGoods.getQty() >= 0) {
+                cartGoods.setAmount(goodsNowPrice * cartGoods.getQty());
+            } else {
+                //总价=可享受数量*优惠后单价+（当前商品行的商品数量-可享受数量）*商品原价
+                cartGoods.setAmount(specialActualGoodsNumber > 0 ? specialActualGoodsNumber * goodsNowPrice + (cartGoods.getQty() - specialActualGoodsNumber) * cartGoods.getOriginalPrice()
+                        : goods.getOriginalPrice() * cartGoods.getQty());
+                if (StringUtils.isEmpty(toastMsg)) {
+                    toastMsg = "该商品限" + goodsDiscount.getActualGoodsNumber() + "份优惠 超出按照原价计算哦";
+                }
+            }
+            numberMap.put(goods.getGoodsId(), specialActualGoodsNumber - cartGoods.getQty());
+        }
+        if (StringUtils.isNotBlank(toastMsg)) {
+            shoppingCartGoodsResponseVo.setToastMsg(toastMsg);
+        }
+    }
+
+
+
+    /**
+     * 获取指定促销类型的GoodsDiscount
+     *
+     * @param goodsDiscountList
+     * @param discounts
+     * @return
+     */
+    private ActivityCalculationDiscountResponseDto.CalculationDiscountResult.Goods.GoodsDiscount getGoodsDiscount(List<ActivityCalculationDiscountResponseDto.CalculationDiscountResult.Goods.GoodsDiscount> goodsDiscountList, List<Integer> discounts) {
+        if (CollectionUtils.isEmpty(goodsDiscountList)) {
+            return null;
+        }
+        for (ActivityCalculationDiscountResponseDto.CalculationDiscountResult.Goods.GoodsDiscount goodsDiscount : goodsDiscountList) {
+            if (discounts.contains(goodsDiscount.getType())) {
+                return goodsDiscount;
+            }
+        }
+        return null;
+    }
+
+    /**
+     * 获取指定促销类型的ApportionDetails
+     *
+     * @param apportionDetailsList
+     * @param type
+     * @return
+     */
+    private ActivityCalculationDiscountResponseDto.CalculationDiscountResult.ApportionGoods.ApportionDetails getApportionDetails(List<ActivityCalculationDiscountResponseDto.CalculationDiscountResult.ApportionGoods.ApportionDetails> apportionDetailsList, ActivityTypeEnum type) {
+        for (ActivityCalculationDiscountResponseDto.CalculationDiscountResult.ApportionGoods.ApportionDetails apportionDetails : apportionDetailsList) {
+            if (Objects.equals(apportionDetails.getActivityType(), ActivityTypeEnum.TYPE_2.getCode())) {
+                return apportionDetails;
+            }
+        }
+        return null;
+    }
+
+
+
+}