diff --git a/cash-service/market-service/src/main/java/com/czg/service/market/service/impl/MkShopConsumeDiscountRecordServiceImpl.java b/cash-service/market-service/src/main/java/com/czg/service/market/service/impl/MkShopConsumeDiscountRecordServiceImpl.java
index af88c754d..5f61c2353 100644
--- a/cash-service/market-service/src/main/java/com/czg/service/market/service/impl/MkShopConsumeDiscountRecordServiceImpl.java
+++ b/cash-service/market-service/src/main/java/com/czg/service/market/service/impl/MkShopConsumeDiscountRecordServiceImpl.java
@@ -106,13 +106,14 @@ public class MkShopConsumeDiscountRecordServiceImpl extends ServiceImpl<MkShopCo
                 .eq(MkShopConsumeDiscountRecord::getIsUse, 1)
                 .eq(MkShopConsumeDiscountRecord::getShopUserId, shopUser.getId()));
         boolean exists = orderInfoService.exists(new QueryWrapper().eq(OrderInfo::getUserId, shopUser.getUserId())
-                .eq(OrderInfo::getShopId, shopUser.getSourceShopId()).eq(OrderInfo::getStatus, OrderStatusEnums.DONE.getCode()));
+                .eq(OrderInfo::getShopId, shopId).eq(OrderInfo::getStatus, OrderStatusEnums.DONE.getCode()));
         return !exists && discountRecord == null;
     }
 
     @Override
     public MkShopConsumeDiscountRecord getDiscount(Long shopId, Long userId, Long orderId) {
-        ShopUser shopUser = shopUserService.getOne(new QueryWrapper().eq(ShopUser::getUserId, userId).eq(ShopUser::getSourceShopId, shopId));
+        ShopUser shopUser = shopUserService.getUserInfo(shopId, userId);
+        AssertUtil.isTrue(shopUser == null, "用户不存在");
         boolean newUser = isNewUser(shopUser, shopId);
         if (!newUser) {
 //            throw new CzgException("新客立减仅新用户可用");