对接促销会员价

shopping-cart-application-service/src/main/java/cn/freemud/demo/manager/promotion/KgdPromotionServiceImpl.java

@@ -14,7 +14,8 @@ import cn.freemud.entities.dto.calculate.CalculationSharingDiscountResponseDto;
 import cn.freemud.enums.ResponseResult;
 import cn.freemud.interceptor.ServiceException;
 import cn.freemud.service.ActivityService;
-import cn.freemud.service.thirdparty.CalculationClient;
+import cn.freemud.service.thirdparty.ActivityClient;
+//import cn.freemud.service.thirdparty.CalculationClient;
 import com.alibaba.fastjson.JSON;
 import com.freemud.application.sdk.api.log.ApiLog;
 import com.freemud.application.sdk.api.log.ErrorLog;
@@ -26,8 +27,11 @@ import org.springframework.stereotype.Service;
 //@Slf4j
 public class KgdPromotionServiceImpl implements PromotionService{
 
+//    @Autowired
+//    private CalculationClient calculationClient;
+
     @Autowired
-    private CalculationClient calculationClient;
+    private ActivityClient activityClient;
 
     @Autowired
     private ActivityService activityService;
@@ -46,7 +50,7 @@ public class KgdPromotionServiceImpl implements PromotionService{
         try {
             //ApiLog.debug("start sharing discount dto={}", JSON.toJSONString(shareDiscountRequestDto));
             ApiLog.printLog("start sharing discount dto={}",JSON.toJSONString(shareDiscountRequestDto),null,null);
-            calculationSharingDiscountResponseDto = calculationClient.calculationSharingDiscount(shareDiscountRequestDto);
+            calculationSharingDiscountResponseDto = activityClient.calculationSharingDiscount(shareDiscountRequestDto);
         }
         catch (Exception e) {
             ErrorLog.printErrorLog("calculation_discount_error", "/calculation/discount/sharing", calculationSharingDiscountResponseDto, e);

shopping-cart-application-service/src/main/java/cn/freemud/enums/ActivityTypeEnum.java

@@ -28,6 +28,7 @@ public enum ActivityTypeEnum {
     TYPE_21(21, "单品折扣"),
     TYPE_22(22, "单品立减"),
     TYPE_23(23, "超值加购"),
+    TYPE_27(27, "促销会员价"),
     /**
      * 优惠券
      */

shopping-cart-application-service/src/main/java/cn/freemud/enums/ShoppingCartPromotionEnum.java

@@ -27,7 +27,8 @@ public enum ShoppingCartPromotionEnum {
     MEMBER_DISCOUNT(11, "memberDiscountService"),
     Material(12, "MaterialPromotionService"),
     // 集点活动类
-    GATHER_SPOT(13, "gatherSpotPromotionService");
+    GATHER_SPOT(13, "gatherSpotPromotionService"),
+    MEMBER_DISCOUNT_NEw(27, "memberDiscountService");
 
     private Integer type;
     private String msgType;

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

@@ -76,4 +76,34 @@ public class MemberDiscountServiceImpl implements IPromotionService {
         return result;
     }
 
+
+    public void updateShoppingCartGoodsDiscountNew(CouponPromotionVO couponPromotionVO, ActivityQueryDto activityQueryDto, ActivityCalculationDiscountResponseDto.CalculationDiscountResult calculationDiscountResult, List<CartGoods> cartGoodsList, ShoppingCartGoodsResponseVo shoppingCartGoodsResponseVo, UserLoginInfoDto userLoginInfoDto, ShoppingCartInfoRequestVo shoppingCartInfoRequestVo) {
+        //获取每个商品的会员价优惠单价
+        if (calculationDiscountResult == null || CollectionUtils.isEmpty(calculationDiscountResult.getApportionGoods())) {
+            return ;
+        }
+        Map<String,Long> result=new HashMap<>();
+        for (ActivityCalculationDiscountResponseDto.CalculationDiscountResult.ApportionGoods apportionGood : calculationDiscountResult.getApportionGoods()) {
+            if (!CollectionUtils.isEmpty(apportionGood.getApportionDetails())) {
+                for (ActivityCalculationDiscountResponseDto.CalculationDiscountResult.ApportionGoods.ApportionDetails apportionDetail : apportionGood.getApportionDetails()) {
+                    if (apportionDetail.getActivityType().equals(ActivityTypeEnum.TYPE_27.getCode())) {
+                        result.putIfAbsent(apportionGood.getGoodsId(),apportionDetail.getActivityApportionAmount());
+                    }
+                }
+            }
+        }
+
+        if (result.size()==0){
+            return;
+        }
+
+        for (CartGoods cartGoods : cartGoodsList) {
+            //优惠单价
+            Long discountPrice = result.get(cartGoods.getGoodsId());
+            if (discountPrice!=null && discountPrice>0){
+                cartGoods.setAmount(cartGoods.getAmount()-discountPrice*cartGoods.getQty());
+            }
+        }
+    }
+
 }

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

@@ -1781,10 +1781,14 @@ public class ShoppingCartNewServiceImpl implements ShoppingCartNewService {
         BuyAndGiftsPromotionService buyAndGiftsPromotionService =(BuyAndGiftsPromotionService) PromotionFactory.getPromotionService(ShoppingCartPromotionEnum.BUY_GIFTS);
         buyAndGiftsPromotionService.updateShoppingCartGoodsDiscount(couponPromotionVO, activityQueryDto, calculationDiscountResult, cartGoodsList, shoppingCartGoodsResponseVo, userLoginInfoDto, shoppingCartInfoRequestVo);
 
-        //会员价
+        //商品会员价
         MemberDiscountServiceImpl memberDiscountService=(MemberDiscountServiceImpl) PromotionFactory.getPromotionService(ShoppingCartPromotionEnum.MEMBER_DISCOUNT);
         memberDiscountService.updateShoppingCartGoodsDiscount(couponPromotionVO, activityQueryDto, calculationDiscountResult, cartGoodsList, shoppingCartGoodsResponseVo, userLoginInfoDto, shoppingCartInfoRequestVo);
 
+        //促销会员价
+        MemberDiscountServiceImpl memberDiscountServiceNew=(MemberDiscountServiceImpl) PromotionFactory.getPromotionService(ShoppingCartPromotionEnum.MEMBER_DISCOUNT_NEw);
+        memberDiscountServiceNew.updateShoppingCartGoodsDiscountNew(couponPromotionVO, activityQueryDto, calculationDiscountResult, cartGoodsList, shoppingCartGoodsResponseVo, userLoginInfoDto, shoppingCartInfoRequestVo);
+
         /**
          * 满额减配送费   优选活动 再配送券
          */

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

@@ -20,7 +20,8 @@ import cn.freemud.service.CouponService;
 import cn.freemud.service.active.ActiveFactory;
 import cn.freemud.service.active.ActiveService;
 import cn.freemud.service.impl.AssortmentSdkService;
-import cn.freemud.service.thirdparty.CalculationClient;
+import cn.freemud.service.thirdparty.ActivityClient;
+//import cn.freemud.service.thirdparty.CalculationClient;
 import cn.freemud.utils.PropertyConvertUtil;
 import com.alibaba.fastjson.JSON;
 import com.freemud.application.sdk.api.log.ApiLog;
@@ -59,12 +60,18 @@ public class CalculationSharingDiscountService {
     private ShoppingCartBaseServiceImpl shoppingCartBaseService;
     @Autowired
     private CommonService commonService;
+//    @Autowired
+//    private CalculationClient calculationClient;
+
     @Autowired
-    private CalculationClient calculationClient;
+    private ActivityClient activityClient;
 
     @Autowired
     private ActiveFactory activeFactory;
 
+    public CalculationSharingDiscountService() {
+    }
+
 
     // 新算价
     public CalculationSharingDiscountResponseDto.CalculationDiscountResult getCalculationSharingDiscountResult(String menuType
@@ -200,7 +207,7 @@ public class CalculationSharingDiscountService {
         ActiveService activeService = activeFactory.getBuildChooseGoodsService(partnerId);
         activeService.buildChooseGoodsService(calculationSharingDiscountRequestDto,shoppingCartInfoRequestVo == null ? null : shoppingCartInfoRequestVo.getChooseGoods());
         try {
-            sharingDiscountResponseDto = calculationClient.calculationSharingDiscount(calculationSharingDiscountRequestDto);
+            sharingDiscountResponseDto = activityClient.calculationSharingDiscount(calculationSharingDiscountRequestDto);
         }
         catch (Exception e) {
             ErrorLog.printErrorLog("calculation_discount_error", "/calculation/discount/sharing", calculationSharingDiscountRequestDto, e);

shopping-cart-application-service/src/main/java/cn/freemud/service/thirdparty/ActivityClient.java

@@ -17,6 +17,8 @@ import cn.freemud.constant.ResponseCodeConstant;
 import cn.freemud.constant.ResponseCodeKeyConstant;
 import cn.freemud.entities.dto.*;
 import cn.freemud.entities.dto.activity.ActivityQueryResponseDto;
+import cn.freemud.entities.dto.calculate.CalculationSharingDiscountRequestDto;
+import cn.freemud.entities.dto.calculate.CalculationSharingDiscountResponseDto;
 import org.springframework.cloud.openfeign.FeignClient;
 import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
@@ -62,4 +64,12 @@ public interface ActivityClient {
     @PostMapping("/calculation/discount/sharing")
     //@IgnoreFeignLogAnnotation(excludeStatusCodes = {ResponseCodeConstant.RESPONSE_SUCCESS_STR},statusCodeFieldName= ResponseCodeKeyConstant.STATUS_CODE,messageFieldName=ResponseCodeKeyConstant.MSG)
     ActivityCalculationDiscountResponseDto calculationDiscountSharing(ActivityCalculationDiscountRequestDto activityCalculationDiscountRequestDto);
+
+
+    /**
+     * 促销新的算价对接
+     */
+    @PostMapping("/promotioncenter/calculateservice/discount/sharing")
+    //@IgnoreFeignLogAnnotation(excludeStatusCodes = {ResponseCodeConstant.RESPONSE_SUCCESS_STR},statusCodeFieldName= ResponseCodeKeyConstant.STATUS_CODE,messageFieldName=ResponseCodeKeyConstant.MEG)
+    CalculationSharingDiscountResponseDto calculationSharingDiscount(CalculationSharingDiscountRequestDto shareDiscountRequestDto);
 }

shopping-cart-application-service/src/main/java/cn/freemud/service/thirdparty/CalculationClient.java

-package cn.freemud.service.thirdparty;
-
-import cn.freemud.annotations.IgnoreFeignLogAnnotation;
-import cn.freemud.constant.ResponseCodeConstant;
-import cn.freemud.constant.ResponseCodeKeyConstant;
-import cn.freemud.entities.dto.calculate.CalculationSharingDiscountRequestDto;
-import cn.freemud.entities.dto.calculate.CalculationSharingDiscountResponseDto;
-import org.springframework.cloud.openfeign.FeignClient;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestMapping;
-
-@FeignClient(name = "promotion-service", url = "${saas.activityclient.feign.url}")
-@RequestMapping(produces = {"application/json;charset=UTF-8"})
-public interface CalculationClient {
-
-
-    // TODO: 21-3-31 和 ActivityClient　待合并
-    /**
-     * 促销新的算价对接
-     */
-    @PostMapping("/promotioncenter/calculateservice/discount/sharing")
-    //@IgnoreFeignLogAnnotation(excludeStatusCodes = {ResponseCodeConstant.RESPONSE_SUCCESS_STR},statusCodeFieldName= ResponseCodeKeyConstant.STATUS_CODE,messageFieldName=ResponseCodeKeyConstant.MEG)
-    CalculationSharingDiscountResponseDto calculationSharingDiscount(CalculationSharingDiscountRequestDto shareDiscountRequestDto);
-}
+//package cn.freemud.service.thirdparty;
+//
+//import cn.freemud.annotations.IgnoreFeignLogAnnotation;
+//import cn.freemud.constant.ResponseCodeConstant;
+//import cn.freemud.constant.ResponseCodeKeyConstant;
+//import cn.freemud.entities.dto.calculate.CalculationSharingDiscountRequestDto;
+//import cn.freemud.entities.dto.calculate.CalculationSharingDiscountResponseDto;
+//import org.springframework.cloud.openfeign.FeignClient;
+//import org.springframework.web.bind.annotation.PostMapping;
+//import org.springframework.web.bind.annotation.RequestMapping;
+//
+//@FeignClient(name = "promotion-service", url = "${saas.activityclient.feign.url}")
+//@RequestMapping(produces = {"application/json;charset=UTF-8"})
+//public interface CalculationClient {
+//
+//
+//    // TODO: 21-3-31 和 ActivityClient　待合并
+//    /**
+//     * 促销新的算价对接
+//     */
+//    @PostMapping("/promotioncenter/calculateservice/discount/sharing")
+//    //@IgnoreFeignLogAnnotation(excludeStatusCodes = {ResponseCodeConstant.RESPONSE_SUCCESS_STR},statusCodeFieldName= ResponseCodeKeyConstant.STATUS_CODE,messageFieldName=ResponseCodeKeyConstant.MEG)
+//    CalculationSharingDiscountResponseDto calculationSharingDiscount(CalculationSharingDiscountRequestDto shareDiscountRequestDto);
+//}