Merge remote-tracking branch 'origin/develop' into develop

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

@@ -1324,7 +1324,7 @@ public class OrderAdapter {
     }
 
 
-    private OrderViewStatusDto getOrderViewStatusDesc(QueryOrdersResponse.DataBean.OrderBean orderBean, String wxAppId) {
+    public OrderViewStatusDto getOrderViewStatusDesc(QueryOrdersResponse.DataBean.OrderBean orderBean, String wxAppId) {
         OrderViewStatusDto orderViewStatusDto = new OrderViewStatusDto();
         LogUtil.info("getOrderStatusDesc start ", new Gson().toJson(orderBean), new Gson().toJson(orderBean));
         QueryOrdersResponse.DataBean.OrderBean.RefundBean refundBean = null;

order-application-service/src/main/java/cn/freemud/controller/OrderController.java

@@ -29,10 +29,7 @@ import io.swagger.annotations.ApiOperation;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.validation.annotation.Validated;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.bind.annotation.*;
 
 import javax.validation.Valid;
 
@@ -351,5 +348,14 @@ public class OrderController {
         return orderservice.listFreeRider(vo);
     }
 
+    /**
+     * 根据订单号查询订单状态和取餐码
+     */
+    @ApiAnnotation(logMessage = "mcCafePollingPickUpCode")
+    @PostMapping("/mcCafePollingPickUpCode")
+    public BaseResponse mcCafePollingPickUpCode(@Validated @LogParams @RequestBody MaCafeQueryOrderVo vo) {
+        return orderservice.mcCafePollingPickUpCode(vo);
+    }
+
 
 }

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

@@ -123,4 +123,6 @@ public interface Orderservice {
     BaseResponse mcCafeQueryOrderById(MaCafeQueryOrderVo queryOrderVo);
 
     BaseResponse mcCafeQueryOrders(McCafeQueryOrderVo queryOrderVo);
+
+    BaseResponse mcCafePollingPickUpCode(MaCafeQueryOrderVo vo );
 }

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

@@ -986,7 +986,7 @@ public class MCCafeOrderServiceImpl implements MCCafeOrderService {
         requestDto.setOpenId(orderExtInfoDto != null ? orderExtInfoDto.getOpenid() : "");
         buriedPointService.BuriedPointPayment(requestDto, orderBean);
 
-        if(OldOrderType.TAKE_OUT.equals(orderBean.getType())) {
+        if(OldOrderType.TAKE_OUT.getCode().equals(orderBean.getType())) {
             //调用基础订单接口更新信息
             UpdateDownstreamOrderCodeReq updateDownstreamOrderCodeReq = new UpdateDownstreamOrderCodeReq();
             updateDownstreamOrderCodeReq.setOrderCode(orderBean.getOid());
@@ -1001,6 +1001,9 @@ public class MCCafeOrderServiceImpl implements MCCafeOrderService {
             }
             CreateDeliveryVo createDeliveryVo = deliveryAdapter.buildDeliveryOrderRequestDto(orderBean, storeInfo, deliveryCallBackUrl, linkedHashMap.get("downstreamThirdOrderCode"));
             //创建配送单
+            //暂时写死配送店铺id
+            createDeliveryVo.setStoreId("1450026");
+            createDeliveryVo.setStoreCode("1450026");
             CreateDeliveryOrderResponseDto deliveryResponse = deliveryFeiginClient.deliveryOrderAdd(createDeliveryVo);
             //创建配送单失败，更新订单为异常单
             if (deliveryResponse == null || RESPONSE_SUCCESS_CODE != deliveryResponse.getCode() || deliveryResponse.getData() == null) {

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

@@ -986,6 +986,31 @@ public class OrderServiceImpl implements Orderservice {
         return ResponseUtil.success(responseMap);
     }
 
+    @Override
+    public BaseResponse mcCafePollingPickUpCode(MaCafeQueryOrderVo queryOrderVo) {
+        AssortmentCustomerInfoVo userLoginInfoDto = customerInfoManager.getCustomerInfoByObject(queryOrderVo.getSessionId());
+        if (userLoginInfoDto == null || StringUtils.isBlank(userLoginInfoDto.getMemberId())) {
+            return ResponseUtil.error(ResponseResult.NOT_LOGIN);
+        }
+        String oid =queryOrderVo.getOid();
+        if (StringUtils.isBlank(oid)) {
+            return ResponseUtil.error(ResponseResult.PARAMETER_MISSING.getCode(), "oid不能为空");
+        }
+        BaseQueryOrderRequest baseQueryOrderRequest = new BaseQueryOrderRequest();
+        baseQueryOrderRequest.setOrderId(oid);
+        baseQueryOrderRequest.setTrackingNo(LogTreadLocal.getTrackingNo());
+        QueryOrderByIdResponse response = orderCenterSdkService.queryOrderById(baseQueryOrderRequest);
+        if (!RESPONSE_SUCCESS_CODE.equals(response.getErrcode()) || response.getData() == null) {
+            return ResponseUtil.error(ResponseResult.ORDER_QUERYORDER_ERROR);
+        }
+        QueryOrdersResponse.DataBean.OrderBean orderBean = response.getData();
+        OrderViewStatusDto orderViewStatusDesc = orderAdapter.getOrderViewStatusDesc(orderBean, userLoginInfoDto.getWxAppId());
+        Map<String, Object> responseMap = Maps.newTreeMap();
+        responseMap.put("orderStatus", orderViewStatusDesc.getOrderStatus());
+        responseMap.put("takeCode",orderBean.getOtherCode() );
+        return ResponseUtil.success(responseMap);
+    }
+
     private String getRedpacketsPicture(String activityId) {
         if (StringUtils.isNotBlank(activityId)) {
             try {

shopping-cart-application-service/src/main/java/cn/freemud/entities/dto/ActivityCalculationDiscountResponseDto.java

@@ -296,6 +296,8 @@ public class ActivityCalculationDiscountResponseDto {
              * 优惠金额（单位分）
              */
             private Integer discountAmount;
+
+            private Integer activityType;
         }
 
         @Data

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

@@ -229,6 +229,7 @@ public class ShoppingCartMCoffeeServiceImpl {
 
         // check购物车中所有商品
         cartGoodsList = checkCartGoods(partnerId, storeId, orderType, menuType, shoppingCartGoodsResponseVo, cartGoodsList);
+
         // 重新存储最新购物车
         assortmentSdkService.setShoppingCart(partnerId, storeId, userId, cartGoodsList, sessionId, "", shoppingCartBaseService);
 
@@ -480,7 +481,6 @@ public class ShoppingCartMCoffeeServiceImpl {
         Integer orderType = 1;
         String userId = assortmentCustomerInfoVo.getMemberId();
         String partnerId = requestVo.getPartnerId();
-        String storeId = requestVo.getShopId();
         String appId = requestVo.getAppId();
         String orderId = requestVo.getOrderId();
         String trackingNo = LogThreadLocal.getTrackingNo();
@@ -491,7 +491,7 @@ public class ShoppingCartMCoffeeServiceImpl {
         }
 
         List<CartGoods> cartGoodsList = getOrderGoods(orderInfo.getResult());
-
+        String storeId = orderInfo.getResult().getStoreId();
         if(orderInfo.getResult().getOrderType() == 3 || orderInfo.getResult().getOrderType() == 4){
             menuType = "saasdelivery";
             orderType = 2;
@@ -899,6 +899,9 @@ public class ShoppingCartMCoffeeServiceImpl {
     private List<CartGoods> checkCartGoods(String partnerId, String storeId, Integer orderType, String menuType,
                                            ShoppingCartGoodsBaseResponseVo shoppingCartGoodsResponseVo, List<CartGoods> cartGoodsList) {
 
+        //筛选数量不为0商品
+        cartGoodsList = cartGoodsList.stream().filter(cartGoods -> cartGoods.getQty() != 0).collect(Collectors.toList());
+
         //筛选非加购商品--加价购商品不校验是否在菜单，不调用validateShopProduct
         List<CartGoods> checkGoods = cartGoodsList.stream().filter(cartGoods -> cartGoods.getGoodsType() != GoodsTypeEnum.REDUCE_PRICE_GOODS.getGoodsType()).collect(Collectors.toList());
         //加价购商品

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

@@ -195,6 +195,19 @@ public class CalculationServiceImpl {
                 activityDiscountsDtos.add(activityDiscountsDto);
             }
         }
+
+        for (ActivityCalculationDiscountResponseDto.CalculationDiscountResult.CouponResults discount : calculationDiscountResult.getCouponDiscounts()) {
+            int discountAmount = (discount.getDiscountAmount() == null) ? 0 : discount.getDiscountAmount();
+            Integer discountType = discount.getActivityType();
+            if (discountType != null && discountAmount > 0) {
+                ActivityDiscountsDto activityDiscountsDto = new ActivityDiscountsDto();
+                activityDiscountsDto.setActivityCode(discount.getCouponCode());
+                activityDiscountsDto.setActivityName(discount.getCouponCode());
+                activityDiscountsDto.setActivityType(discountType);
+                activityDiscountsDto.setDiscountAmount(0 - discountAmount);
+                activityDiscountsDtos.add(activityDiscountsDto);
+            }
+        }
         //过滤出加价购
         List<ActivityCalculationDiscountResponseDto.CalculationDiscountResult.Discount> addMoneyDiscounts = discounts.stream().filter(discount -> ActivityTypeEnum.TYPE_81.getCode().equals(discount.getType())).collect(Collectors.toList());
 
@@ -303,7 +316,7 @@ public class CalculationServiceImpl {
         if (storeInfo.getBizVO().getDeliveryPrice() == 0) {
             throw new ServiceException(ResponseResult.STORE_DELIVERY_AMOUNT_ERROR);
         }
-        Double deliveryPrice = storeInfo.getBizVO().getDeliveryPrice();
+        Double deliveryPrice = storeInfo.getBizVO().getDeliveryPrice()*100;
         deliveryAmount = deliveryPrice.longValue();
         return deliveryAmount;
     }