修改bug

ms-biz/src/main/java/com/ms/biz/quque/consumer/DsMessageConsumer.java

@@ -30,6 +30,7 @@ public class DsMessageConsumer extends BaseConsumer {
         log.info("DsMessageConsumer Receive New Messages: {}", JSON.toJSONString(list));
         for (MessageExt message: list) {
             try {
+                log.info("consume message: {}", new String(message.getBody()));
                 DsMessage dsMessage = JSON.parseObject(new String(message.getBody()), DsMessage.class);
                 dsMessageService.processDsMessage(dsMessage.getDsMessageId());
             } catch (Throwable e) {

ms-biz/src/main/java/com/ms/biz/service/impl/DsMessageServiceImpl.java

@@ -195,6 +195,7 @@ public class DsMessageServiceImpl implements DsMessageService {
 
     private void handleDsMessage(DsMessage dsMessage) {
         if (dsMessage == null) {
+            log.error("handleDsMessage: 消息不存在");
             throw new RuntimeException("消息不存在");
         }
 
@@ -205,6 +206,7 @@ public class DsMessageServiceImpl implements DsMessageService {
                 PurchaseOrderDTO purchaseOrderDTO = ((PurchaseOrderRelateMessageDTO)messageDTO).getPurchaseOrderInfo();
                 // do something
             }
+            log.error("handleDsMessage: 消息已过期");
             throw new RuntimeException("消息已过期");
         }
 
@@ -253,6 +255,8 @@ public class DsMessageServiceImpl implements DsMessageService {
 
         handlePurchaseOrderRefund(purchaseOrderDTO, purchaseOrder, skuIdAndPlatformPurchaseOrderSkuMap);
 
+        log.error("handleDsMessage purchaseOrderStatus: " + purchaseOrderStatus);
+
         if (!Objects.equals(purchaseOrder.getPurchaseOrderStatus(),purchaseOrderStatus)){
             switch (purchaseOrderStatus) {
                 case PurchaseOrderConst.PURCHASE_ORDER_STATUS_WAIT_SEND: