Merge branch 'feature-2020/6/29-1.9.29-围餐-会阳' into qa

assortment-ordercenter-sdk/src/main/java/com/freemud/sdk/api/assortment/order/service/order/OrderCenterSdkServiceImpl.java

@@ -265,6 +265,17 @@ public class OrderCenterSdkServiceImpl implements OrderCenterSdkService {
                 return BaseOrderResponse.getErrorBaseOrderResponse(couponRedeemResponseBaseResponse.getCode(), "优惠券核销失败，请重试");
             }
         }
+
+        // 扣减积分，扣减失败冲正积分返回错误
+        UserScoreRequest userScoreRequest = orderSdkAdapter.convent2UserScoreRequest(orderBean, accounts, true);
+        if (userScoreRequest != null) {
+            BaseResponse userScoreResponse = memberScoreService.useScore(userScoreRequest, "");
+            if (!ObjectUtils.equals(RESPONSE_SUCCESS_STR, userScoreResponse.getCode())) {
+                //失败异步冲正库存，取消订单
+                backOrdersNotifyActivity(orderBean, mqMessageRequest.getBackOrdersNotifyActivityQueue(), mqMessageRequest.getBackOrdersNotifyActivityExchange());
+                return BaseOrderResponse.getErrorBaseOrderResponse(userScoreResponse.getCode(), "积分不足");
+            }
+        }
         return BaseOrderResponse.getErrorBaseOrderResponse(RESPONSE_SUCCESS_STR, "");
     }
     
@@ -1206,6 +1217,10 @@ public class OrderCenterSdkServiceImpl implements OrderCenterSdkService {
         }
 
         if (AssortmentSdkUpdateOrderProductInfoRequest.OpUpdateOrderItemEnum.updatePrePayPrice == updateOrderProductInfoRequest.getOpUpdateOrderItemEnum()) {
+            // 围餐订单的创建不一定是付款人，需要重新赋值
+            if (OrderClientType.WAI_MEAL.getIndex() == Integer.valueOf(queryOrderByIdResponse.getData().getOrderClient())) {
+                queryOrderByIdResponse.getData().setUserId(updateOrderProductInfoRequest.getUserId());
+            }
             BaseOrderResponse baseOrderResponse = this.updateWcStockAndScore(queryOrderByIdResponse.getData(), orderItemListByRequest, updateOrderProductInfoRequest.getActivityUpdateStockRequest(), updateOrderProductInfoRequest.getAccounts(),
                     updateOrderProductInfoRequest.getMqMessageRequest(), updateOrderProductInfoRequest.getMenuType());
             if (!Objects.equals(baseOrderResponse.getErrcode(), RESPONSE_SUCCESS)) {

order-application-service/src/main/java/cn/freemud/adapter/OrderAdapter.java

@@ -2425,6 +2425,10 @@ public class OrderAdapter {
         for (ShoppingCartGoodsDto.CartGoodsDetailDto cartGoodsDetailDto : cartGoodsDetailDtos) {
             Integer qty = cartGoodsDetailDto.getQty();
             if (qty > 0) {
+                // 当存在sku是取sku,不取spu
+                if (StringUtils.isNotEmpty(cartGoodsDetailDto.getSkuId())){
+                    cartGoodsDetailDto.setSpuId(cartGoodsDetailDto.getSkuId());
+                }
                 CreateOrderProductRequest createOrderProductDto = convent2OrderProduct(cartGoodsDetailDto);
                 createOrderProductDto.setIgnoreProductPrice(1);
                 createOrderProductRequests.add(createOrderProductDto);
@@ -2511,6 +2515,7 @@ public class OrderAdapter {
         }
 
 
+        if (shoppingCartGoodsResponse != null) {
             Long scoreReduceAmount = shoppingCartGoodsResponse.getScoreReduceAmount() != null ? shoppingCartGoodsResponse.getScoreReduceAmount() : 0;
             if (scoreReduceAmount > 0 && CustomerScoreConstant.SUBSTRACT.getValue().equals(createReserveOrderVo.getUseCustomerScore())) {
                 Integer reduceScore = shoppingCartGoodsResponse.getReduceScore() != null ? shoppingCartGoodsResponse.getReduceScore().intValue() : 0;
@@ -2523,6 +2528,7 @@ public class OrderAdapter {
                         .build();
                 sdkUpdateOrderProductInfoRequest.getAccounts().add(createOrderAccountDto);
             }
+        }
 //        Long cardOriginalAmount = shoppingCartGoodsDto.getCardOriginalAmount() != null ? shoppingCartGoodsDto.getCardOriginalAmount() : 0L;
 //        if (cardOriginalAmount > 0) {
 //            CreateOrderAccountRequest createOrderAccountDto = CreateOrderAccountRequest.builder()

order-application-service/src/main/java/cn/freemud/service/IPromotionService.java

@@ -23,5 +23,5 @@ public interface IPromotionService {
     /**
      * 优惠计算和均摊
      */
-    void updateDiscountApportion(ShoppingCartGoodsResponse shoppingCartGoodsResponse, OrderBeanRequest request, CalculationDiscountResultDto calculationDiscountResult, CouponPromotionDto couponPromotionDto, ActivityQueryDto activityQueryDto);
+    void updateDiscountApportion(ShoppingCartGoodsResponse shoppingCartGoodsResponse, OrderBeanRequest request, CalculationDiscountResultDto calculationDiscountResult, CouponPromotionDto couponPromotionDto, ActivityQueryDto activityQueryDto, Boolean isApportion);
 }

order-application-service/src/main/java/cn/freemud/service/impl/ActivityCalculationDiscountService.java

@@ -21,6 +21,8 @@ import com.freemud.sdk.api.assortment.order.response.order.QueryOrdersResponse;
 import org.apache.commons.collections4.CollectionUtils;
 import org.apache.commons.lang.ObjectUtils;
 import org.apache.commons.lang.StringUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
@@ -44,6 +46,8 @@ import java.util.Objects;
 @Service
 public class ActivityCalculationDiscountService {
 
+    private static Logger logger = LoggerFactory.getLogger(ActivityCalculationDiscountService.class);
+
     private final static String RESPONSE_SUCCESS_STR = "100";
 
     @Autowired
@@ -66,7 +70,7 @@ public class ActivityCalculationDiscountService {
     private CustomerScoreService customerScoreService;
 
 
-    public ShoppingCartGoodsResponse updateDiscountApportion(OrderBeanRequest request, CouponPromotionDto couponPromotionDto) {
+    public ShoppingCartGoodsResponse updateDiscountApportion(OrderBeanRequest request, CouponPromotionDto couponPromotionDto,Boolean isApportion) {
         ShoppingCartGoodsResponse shoppingCartGoodsResponse = new ShoppingCartGoodsResponse();
 
         List<CalculationCouponDto> coupons = new ArrayList<>();
@@ -86,18 +90,20 @@ public class ActivityCalculationDiscountService {
                 .build();
 
         CalculationDiscountResultDto calculationDiscountResultDto = getCalculationResult(request, coupons);
+        logger.info("促销分摊:{}",calculationDiscountResultDto);
         // 默认计算
-        defaultPromotionService.updateDiscountApportion(shoppingCartGoodsResponse, request, calculationDiscountResultDto, couponPromotionDto, activityQueryDto);
+        defaultPromotionService.updateDiscountApportion(shoppingCartGoodsResponse, request, calculationDiscountResultDto, couponPromotionDto, activityQueryDto, isApportion);
         // 套餐计算
-        setMealPromotionService.updateDiscountApportion(shoppingCartGoodsResponse, request, calculationDiscountResultDto, couponPromotionDto, activityQueryDto);
+        setMealPromotionService.updateDiscountApportion(shoppingCartGoodsResponse, request, calculationDiscountResultDto, couponPromotionDto, activityQueryDto, isApportion);
         // 优惠券计算
-        couponPromotionService.updateDiscountApportion(shoppingCartGoodsResponse, request, calculationDiscountResultDto, couponPromotionDto, activityQueryDto);
+        couponPromotionService.updateDiscountApportion(shoppingCartGoodsResponse, request, calculationDiscountResultDto, couponPromotionDto, activityQueryDto, isApportion);
         // 满减
-        fullPromotionService.updateDiscountApportion(shoppingCartGoodsResponse, request, calculationDiscountResultDto, couponPromotionDto, activityQueryDto);
+        fullPromotionService.updateDiscountApportion(shoppingCartGoodsResponse, request, calculationDiscountResultDto, couponPromotionDto, activityQueryDto, isApportion);
         // 限时特价
-        timeSalePromotionService.updateDiscountApportion(shoppingCartGoodsResponse, request, calculationDiscountResultDto, couponPromotionDto, activityQueryDto);
+        timeSalePromotionService.updateDiscountApportion(shoppingCartGoodsResponse, request, calculationDiscountResultDto, couponPromotionDto, activityQueryDto, isApportion);
+        logger.info("限时特价shoppingCartGoodsResponse:{}",shoppingCartGoodsResponse);
         // 积分抵扣
-        customerScoreService.updateDiscountApportion(shoppingCartGoodsResponse, request, calculationDiscountResultDto, couponPromotionDto, activityQueryDto);
+        customerScoreService.updateDiscountApportion(shoppingCartGoodsResponse, request, calculationDiscountResultDto, couponPromotionDto, activityQueryDto, isApportion);
         return shoppingCartGoodsResponse;
     }
 

order-application-service/src/main/java/cn/freemud/service/impl/CouponPromotionService.java

@@ -25,7 +25,7 @@ public class CouponPromotionService implements IPromotionService {
     @Autowired
     private CouponService couponService;
     @Override
-    public void updateDiscountApportion(ShoppingCartGoodsResponse shoppingCartGoodsResponse, OrderBeanRequest request, CalculationDiscountResultDto calculationDiscountResult, CouponPromotionDto couponPromotionDto, ActivityQueryDto activityQueryDto) {
+    public void updateDiscountApportion(ShoppingCartGoodsResponse shoppingCartGoodsResponse, OrderBeanRequest request, CalculationDiscountResultDto calculationDiscountResult, CouponPromotionDto couponPromotionDto, ActivityQueryDto activityQueryDto,Boolean isApportion) {
         // 用户选择了查询优惠券信息
         if (couponPromotionDto != null && ObjectUtils.equals(CouponFlag.YES.getCode(), couponPromotionDto.getFlg())) {
             // 是否存在商品券

order-application-service/src/main/java/cn/freemud/service/impl/CustomerScoreService.java

@@ -37,7 +37,7 @@ public class CustomerScoreService implements IPromotionService {
     private CustomScoreClient customScoreClient;
 
     @Override
-    public void updateDiscountApportion(ShoppingCartGoodsResponse shoppingCartGoodsResponse, OrderBeanRequest request, CalculationDiscountResultDto calculationDiscountResult, CouponPromotionDto couponPromotionDto, ActivityQueryDto activityQueryDto) {
+    public void updateDiscountApportion(ShoppingCartGoodsResponse shoppingCartGoodsResponse, OrderBeanRequest request, CalculationDiscountResultDto calculationDiscountResult, CouponPromotionDto couponPromotionDto, ActivityQueryDto activityQueryDto,Boolean isApportion) {
         if (request == null || request.getUseCustomerScore() == null || request.getUseCustomerScore() == null || request.getUseCustomerScore().equals(CustomerScoreConstant.NO_DISPLAY.getValue())) {
             return;
         }

order-application-service/src/main/java/cn/freemud/service/impl/DefaultPromotionService.java

@@ -33,7 +33,7 @@ import java.util.stream.Collectors;
 public class DefaultPromotionService implements IPromotionService {
 
     @Override
-    public void updateDiscountApportion(ShoppingCartGoodsResponse shoppingCartGoodsResponse, OrderBeanRequest request, CalculationDiscountResultDto calculationDiscountResult, CouponPromotionDto couponPromotionDto, ActivityQueryDto activityQueryDto) {
+    public void updateDiscountApportion(ShoppingCartGoodsResponse shoppingCartGoodsResponse, OrderBeanRequest request, CalculationDiscountResultDto calculationDiscountResult, CouponPromotionDto couponPromotionDto, ActivityQueryDto activityQueryDto,Boolean isApportion) {
         // 总原价
         Long originalTotalAmount = 0L;
         // 总折扣
@@ -76,7 +76,7 @@ public class DefaultPromotionService implements IPromotionService {
                 if (Objects.equals(productBean.getProductType(), ProductTypeEnum.WEIGHT_PRODUCT.getCode())) {
                     originalDiscountAmount = new BigDecimal(productBean.getPrice()+"").multiply(productBean.getWeight()).longValue() - productBean.getSettlementPrice();
                 }
-                cartGoodsDetailDtoList.add(PromotionAdapter.convertCartGoods2DetailGoods(productBean, originalDiscountAmount.intValue(), apportionGoodsList, duplicateGoodsMap));
+                cartGoodsDetailDtoList.add(PromotionAdapter.convertCartGoods2DetailGoods(productBean, originalDiscountAmount.intValue(), apportionGoodsList, duplicateGoodsMap,isApportion));
             }
         }
 

order-application-service/src/main/java/cn/freemud/service/impl/EncircleOrderServiceImpl.java

@@ -382,7 +382,8 @@ public class EncircleOrderServiceImpl implements EncircleOrderService {
             payIsArouseStatus = 0;
             OrderBeanRequest orderBeanRequest = orderAdapter.conventOrderBeanRequest(queryOrderByIdResponse.getData(), assortmentCustomerInfoVo,createReserveOrderVo);
             CouponPromotionDto couponPromotionDto = couponAdapter.getCouponPromotionDto(orderBeanRequest, createReserveOrderVo.getCouponCode(), createReserveOrderVo.getActivityCode(), CouponFlag.YES.getCode());
-            ShoppingCartGoodsResponse shoppingCartGoodsResponse = calculationDiscountService.updateDiscountApportion(orderBeanRequest, couponPromotionDto);
+            //新增是否需要分摊计算优化金额，满减和优化券不进行优惠分摊
+            ShoppingCartGoodsResponse shoppingCartGoodsResponse = calculationDiscountService.updateDiscountApportion(orderBeanRequest, couponPromotionDto,false);
             calculationDiscountService.updatePreviewOrderInfoVo(previewOrderInfoVo, shoppingCartGoodsResponse);
         }
         //是否唤起支付
@@ -445,7 +446,7 @@ public class EncircleOrderServiceImpl implements EncircleOrderService {
             if (!prePayLock) {
                 OrderBeanRequest orderBeanRequest = orderAdapter.conventOrderBeanRequest(queryOrderByIdResponse.getData(), assortmentCustomerInfoVo,createReserveOrderVo);
                 CouponPromotionDto couponPromotionDto = couponAdapter.getCouponPromotionDto(orderBeanRequest, createReserveOrderVo.getCouponCode(), createReserveOrderVo.getActivityCode(), CouponFlag.YES.getCode());
-                shoppingCartGoodsResponse = calculationDiscountService.updateDiscountApportion(orderBeanRequest, couponPromotionDto);
+                shoppingCartGoodsResponse = calculationDiscountService.updateDiscountApportion(orderBeanRequest, couponPromotionDto,true);
             }
             boolean isUpdateAccounts = CollectionUtils.isEmpty(queryOrderByIdResponse.getData().getAccountList());
             AssortmentSdkUpdateOrderProductInfoRequest request = orderAdapter.conventShoppingPromotionInfo(shoppingCartGoodsResponse, queryOrderByIdResponse, assortmentCustomerInfoVo, isUpdateAccounts,createReserveOrderVo);

order-application-service/src/main/java/cn/freemud/service/impl/FullPromotionService.java

@@ -27,7 +27,7 @@ public class FullPromotionService implements IPromotionService {
     private ActivityService activityService;
 
     @Override
-    public void updateDiscountApportion(ShoppingCartGoodsResponse shoppingCartGoodsResponse, OrderBeanRequest request, CalculationDiscountResultDto calculationDiscountResult, CouponPromotionDto couponPromotionDto, ActivityQueryDto activityQueryDto) {
+    public void updateDiscountApportion(ShoppingCartGoodsResponse shoppingCartGoodsResponse, OrderBeanRequest request, CalculationDiscountResultDto calculationDiscountResult, CouponPromotionDto couponPromotionDto, ActivityQueryDto activityQueryDto,Boolean isApportion) {
         this.buildActivityTip(shoppingCartGoodsResponse, calculationDiscountResult, activityQueryDto);
 
         List<CalculationGoodsActivityDto> discountList = (calculationDiscountResult == null || calculationDiscountResult.getDiscounts() == null) ? new ArrayList<>() : calculationDiscountResult.getDiscounts();

order-application-service/src/main/java/cn/freemud/service/impl/OrderCommonService.java

@@ -17,6 +17,7 @@ import cn.freemud.enums.RedisCacheEnum;
 import cn.freemud.enums.ResponseResult;
 import cn.freemud.interceptor.ServiceException;
 import cn.freemud.redis.RedisCache;
+import cn.freemud.service.CouponActivityService;
 import cn.freemud.service.thirdparty.ShoppingCartClient;
 import cn.freemud.utils.DateTimeUtil;
 import cn.freemud.utils.LogUtil;
@@ -96,6 +97,8 @@ public class OrderCommonService {
     private MessageCenterClient messageNoticeClient;
     @Autowired
     private RedisService redisService;
+    @Autowired
+    private CouponActivityService couponActivityService;
 
     private final Integer RESPONSE_SUCCESS_CODE = 100;
     /**
@@ -268,6 +271,10 @@ public class OrderCommonService {
             LogUtil.error("paySuccessCallback_payAccess_faild", JSON.toJSONString(message), JSON.toJSONString(groupOrderResponse));
             return this.newSendPayFaileMessage();
         }
+
+        //若该订单使用了优惠券，则移除卡包,移除失败也不退款
+        couponActivityService.callbackNotify(orderBean);
+
         // 删除订单自增缓存
         redisCache.delete(RedisUtil.getPaymentTransIdSequenceKey(orderBean.getOid()));
         // 删除支付交易号订单关系缓存

order-application-service/src/main/java/cn/freemud/service/impl/OrderServiceImpl.java

@@ -953,7 +953,7 @@ public class OrderServiceImpl implements Orderservice {
             }
         }
 
-        if (IappIdType.WC_XCX.getCode().equals(userInfo.getIappId())) {
+        /*if (IappIdType.WC_XCX.getCode().equals(userInfo.getIappId())) {
             if(CollectionUtils.isNotEmpty(queryOrderResponseVo.getProducts()) ) {
                 queryOrderResponseVo.getProducts().stream().forEach(each -> {
                     orderBean.getProductList().forEach(var -> {
@@ -965,7 +965,7 @@ public class OrderServiceImpl implements Orderservice {
 
                 });
             }
-        }
+        }*/
 
         // 判断是否有裂变活动 订单扩展信息判断必须有wxappid
         String extInfo = response.getData().getExtInfo();

order-application-service/src/main/java/cn/freemud/service/impl/SetMealPromotionService.java

@@ -34,7 +34,7 @@ import java.util.stream.Collectors;
 @Service
 public class SetMealPromotionService implements IPromotionService {
     @Override
-    public void updateDiscountApportion(ShoppingCartGoodsResponse shoppingCartGoodsResponse, OrderBeanRequest request, CalculationDiscountResultDto calculationDiscountResult, CouponPromotionDto couponPromotionDto, ActivityQueryDto activityQueryDto) {
+    public void updateDiscountApportion(ShoppingCartGoodsResponse shoppingCartGoodsResponse, OrderBeanRequest request, CalculationDiscountResultDto calculationDiscountResult, CouponPromotionDto couponPromotionDto, ActivityQueryDto activityQueryDto ,Boolean isApportion) {
         // 套餐商品
         List<OrderBeanRequest.ProductBean> setMealProducts = request.getProductList().stream()
                 .filter(productBean -> {
@@ -69,7 +69,7 @@ public class SetMealPromotionService implements IPromotionService {
             Long productGroupDiscountAmount = productBean.getComboProduct().stream().filter(t -> !t.getIsFixedProduct()).mapToLong(t -> t.getPrice() * t.getNumber() - t.getSettlementPrice()).sum();
             totalDiscountAmount += discountAmount - productGroupDiscountAmount;
             // 设置套餐主商品
-            ShoppingCartGoodsResponse.CartGoodsDetailDto cartGoodsDetailDto = PromotionAdapter.convertCartGoods2DetailGoods(productBean, discountAmount.intValue(), apportionGoodsList, duplicateGoodsMap);
+            ShoppingCartGoodsResponse.CartGoodsDetailDto cartGoodsDetailDto = PromotionAdapter.convertCartGoods2DetailGoods(productBean, discountAmount.intValue(), apportionGoodsList, duplicateGoodsMap,true);
             cartGoodsDetailDto.getActivityDiscountsDtos().add(getActivityDiscountsDto(discountAmount.intValue() - productGroupDiscountAmount.intValue()));
             long apportionAmount = cartGoodsDetailDto.getTotalDiscountAmount() - discountAmount;
             Long comboFixedProductTotalDiscountAmount = discountAmount - productGroupDiscountAmount + apportionAmount;

order-application-service/src/main/java/cn/freemud/service/impl/TimeSalePromotionService.java

@@ -9,6 +9,7 @@ import cn.freemud.entities.vo.CartGoods;
 import cn.freemud.enums.ActivityTypeEnum;
 import cn.freemud.service.IPromotionService;
 import org.apache.commons.collections4.CollectionUtils;
+import org.apache.commons.lang.ObjectUtils;
 import org.apache.commons.lang.StringUtils;
 import org.springframework.stereotype.Service;
 
@@ -35,7 +36,7 @@ import java.util.stream.Collectors;
 public class TimeSalePromotionService implements IPromotionService {
 
     @Override
-    public void updateDiscountApportion(ShoppingCartGoodsResponse shoppingCartGoodsResponse, OrderBeanRequest request, CalculationDiscountResultDto calculationDiscountResult, CouponPromotionDto couponPromotionDto, ActivityQueryDto activityQueryDto) {
+    public void updateDiscountApportion(ShoppingCartGoodsResponse shoppingCartGoodsResponse, OrderBeanRequest request, CalculationDiscountResultDto calculationDiscountResult, CouponPromotionDto couponPromotionDto, ActivityQueryDto activityQueryDto,Boolean isApportion) {
         if (calculationDiscountResult == null || CollectionUtils.isEmpty(calculationDiscountResult.getDiscounts())
                 || CollectionUtils.isEmpty(shoppingCartGoodsResponse.getProducts())
                 || !calculationDiscountResult.getDiscounts().stream().anyMatch(discount -> ActivityTypeEnum.TYPE_2.getCode().equals(discount.getType()))) {
@@ -58,7 +59,10 @@ public class TimeSalePromotionService implements IPromotionService {
             if ((goods = goodsMap.get(product.getProductId())) == null) {
                 continue;
             }
-            CalculationGoodsActivityDto goodsDiscount = getGoodsDiscount(goods.getDiscounts(), ActivityTypeEnum.TYPE_2);
+            CalculationGoodsActivityDto goodsDiscount =null;
+            if (isApportion){
+                goodsDiscount = getGoodsDiscount(goods.getDiscounts(), ActivityTypeEnum.TYPE_2);
+            }
             if (goodsDiscount == null) {
                 continue;
             }
@@ -67,7 +71,15 @@ public class TimeSalePromotionService implements IPromotionService {
             }
             Integer actualGoodsNumber = numberMap.get(product.getProductId());
             if (actualGoodsNumber > 0) {
-                Integer totalDiscountAmount = product.getQty() > actualGoodsNumber ? goods.getDiscountAmount() * actualGoodsNumber / goods.getActualGoodsNumber() : goods.getDiscountAmount() * product.getQty() / goods.getActualGoodsNumber();
+                // 重新计算单品特价折扣
+                List<CalculationGoodsActivityDto> discounts = goods.getDiscounts();
+                Integer actual = 0;
+                for (CalculationGoodsActivityDto dto: discounts) {
+                    if (ObjectUtils.equals(dto.getType(),ActivityTypeEnum.TYPE_2.getCode())){
+                        actual += dto.getDiscount();
+                    }
+                }
+                Integer totalDiscountAmount = product.getQty() > actualGoodsNumber ? actual * actualGoodsNumber / goods.getActualGoodsNumber() : actual * product.getQty() / goods.getActualGoodsNumber();
                 ActivityDiscountsDto activityDiscountsDto = new ActivityDiscountsDto();
                 activityDiscountsDto.setActivityCode(goodsDiscount.getActivityCode());
                 activityDiscountsDto.setActivityName(goodsDiscount.getActivityName());