diff --git a/cash-common/cash-common-tools/src/main/java/com/czg/enums/ShopUserFlowBizEnum.java b/cash-common/cash-common-tools/src/main/java/com/czg/enums/ShopUserFlowBizEnum.java
index 9351fe249..d34ff6ef0 100644
--- a/cash-common/cash-common-tools/src/main/java/com/czg/enums/ShopUserFlowBizEnum.java
+++ b/cash-common/cash-common-tools/src/main/java/com/czg/enums/ShopUserFlowBizEnum.java
@@ -11,6 +11,8 @@ public enum ShopUserFlowBizEnum {
     // 会员充值
     CASH_IN("cashIn", "会员充值"),
     CASHBACK("cashback", "消费返现"),
+    CASHBACK_REFUND("cashback_refund", "消费返现扣减"),
+
     FREE_IN("freeIn", "霸王餐充值"),
     // 重置奖励
     AWARD_IN("awardIn", "充值奖励"),
diff --git a/cash-service/market-service/src/main/java/com/czg/service/market/service/impl/MkConsumeCashbackServiceImpl.java b/cash-service/market-service/src/main/java/com/czg/service/market/service/impl/MkConsumeCashbackServiceImpl.java
index bde15ea62..87ab18ba0 100644
--- a/cash-service/market-service/src/main/java/com/czg/service/market/service/impl/MkConsumeCashbackServiceImpl.java
+++ b/cash-service/market-service/src/main/java/com/czg/service/market/service/impl/MkConsumeCashbackServiceImpl.java
@@ -203,7 +203,7 @@ public class MkConsumeCashbackServiceImpl extends ServiceImpl<MkConsumeCashbackM
                 .setType(0)
                 .setRelationId(mkConsumeCashbackRecord.getId())
                 .setMoney(record.getCashbackAmount())
-                .setBizEnum(ShopUserFlowBizEnum.CASHBACK)
+                .setBizEnum(ShopUserFlowBizEnum.CASHBACK_REFUND)
                 .setRemark(StrUtil.format("订单退款，扣除返现: {}", record.getCashbackAmount())));
         log.info("订单退款扣除返现 订单ID:{}, 店铺用户id: {},  扣除返现: {}", orderId, record.getShopUserId(), record.getCashbackAmount());
 
diff --git a/cash-service/order-service/src/main/java/com/czg/service/order/service/impl/OrderPaymentServiceImpl.java b/cash-service/order-service/src/main/java/com/czg/service/order/service/impl/OrderPaymentServiceImpl.java
index 5faa2deec..0ca7dda58 100644
--- a/cash-service/order-service/src/main/java/com/czg/service/order/service/impl/OrderPaymentServiceImpl.java
+++ b/cash-service/order-service/src/main/java/com/czg/service/order/service/impl/OrderPaymentServiceImpl.java
@@ -1,11 +1,14 @@
 package com.czg.service.order.service.impl;
 
-import com.mybatisflex.spring.service.impl.ServiceImpl;
+import com.czg.constants.PayTypeConstants;
 import com.czg.order.entity.OrderPayment;
 import com.czg.order.service.OrderPaymentService;
 import com.czg.service.order.mapper.OrderPaymentMapper;
+import com.mybatisflex.core.query.QueryWrapper;
+import com.mybatisflex.spring.service.impl.ServiceImpl;
 import org.apache.dubbo.config.annotation.DubboService;
-import org.springframework.stereotype.Service;
+
+import java.math.BigDecimal;
 
 /**
  * 支付详情 服务层实现。
@@ -14,6 +17,15 @@ import org.springframework.stereotype.Service;
  * @since 2025-02-15
  */
 @DubboService
-public class OrderPaymentServiceImpl extends ServiceImpl<OrderPaymentMapper, OrderPayment> implements OrderPaymentService{
+public class OrderPaymentServiceImpl extends ServiceImpl<OrderPaymentMapper, OrderPayment> implements OrderPaymentService {
 
+    @Override
+    public BigDecimal countMemberInAmount(Long shopId, Long shopUserId) {
+        return getOneAs(QueryWrapper.create().select("sum(amount)")
+                .eq(OrderPayment::getShopId, 143)
+                .eq(OrderPayment::getSourceType, PayTypeConstants.SourceType.MEMBER_IN)
+                .eq(OrderPayment::getPayType, PayTypeConstants.PayType.PAY)
+                .eq(OrderPayment::getSourceId, 127452)
+                .eq(OrderPayment::getPayStatus, PayTypeConstants.PayStatus.SUCCESS), BigDecimal.class);
+    }
 }