diff --git a/oms-api/src/main/java/com/qihang/oms/mq/ApiMessageReceiver.java b/oms-api/src/main/java/com/qihang/oms/mq/ApiMessageReceiver.java
index c2714cda..bac20474 100644
--- a/oms-api/src/main/java/com/qihang/oms/mq/ApiMessageReceiver.java
+++ b/oms-api/src/main/java/com/qihang/oms/mq/ApiMessageReceiver.java
@@ -44,17 +44,24 @@ public class ApiMessageReceiver implements MessageListener {
 
         if(vo.getMqType() == MqType.ORDER_MESSAGE){
             // 有新订单，插入新订单到shop_order
-            logger.info("订单消息"+messageContent);
+
             OOrderService orderService = SpringUtils.getBean(OOrderService.class);
             if(vo.getShopType().getIndex() == EnumShopType.JD.getIndex()) {
+                logger.info("订单消息JD"+messageContent);
                 orderService.jdOrderMessage(vo.getKeyId());
             }else if(vo.getShopType().getIndex() == EnumShopType.TAO.getIndex()) {
+                logger.info("订单消息TAO"+messageContent);
                 orderService.taoOrderMessage(vo.getKeyId());
             }
         }else if(vo.getMqType() == MqType.REFUND_MESSAGE){
-            logger.info("退款消息"+messageContent);
             ORefundService refundService = SpringUtils.getBean(ORefundService.class);
-            refundService.jdRefundMessage(vo.getKeyId());
+            if(vo.getShopType().getIndex() == EnumShopType.JD.getIndex()) {
+                logger.info("退款消息JD" + messageContent);
+                refundService.jdRefundMessage(vo.getKeyId());
+            }else if(vo.getShopType().getIndex() == EnumShopType.TAO.getIndex()) {
+                logger.info("退款消息TAO"+messageContent);
+                refundService.taoRefundMessage(vo.getKeyId());
+            }
         }
     }
 }
diff --git a/oms-api/src/main/java/com/qihang/oms/service/ORefundService.java b/oms-api/src/main/java/com/qihang/oms/service/ORefundService.java
index 2cafba3c..d7f376a5 100644
--- a/oms-api/src/main/java/com/qihang/oms/service/ORefundService.java
+++ b/oms-api/src/main/java/com/qihang/oms/service/ORefundService.java
@@ -12,4 +12,5 @@ import com.qihang.oms.domain.ORefund;
 */
 public interface ORefundService extends IService<ORefund> {
     ResultVo<Integer> jdRefundMessage(String refundId);
+    ResultVo<Integer> taoRefundMessage(String refundId);
 }
diff --git a/oms-api/src/main/java/com/qihang/oms/service/impl/ORefundServiceImpl.java b/oms-api/src/main/java/com/qihang/oms/service/impl/ORefundServiceImpl.java
index e78836f0..53f9bb86 100644
--- a/oms-api/src/main/java/com/qihang/oms/service/impl/ORefundServiceImpl.java
+++ b/oms-api/src/main/java/com/qihang/oms/service/impl/ORefundServiceImpl.java
@@ -98,6 +98,11 @@ public class ORefundServiceImpl extends ServiceImpl<ORefundMapper, ORefund>
         }
         return null;
     }
+
+    @Override
+    public ResultVo<Integer> taoRefundMessage(String refundId) {
+        return null;
+    }
 }