diff --git a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/service/impl/BizMessageProducerServiceImpl.java b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/service/impl/BizMessageProducerServiceImpl.java
index fd3948e..dc754eb 100644
--- a/src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/service/impl/BizMessageProducerServiceImpl.java
+++ b/src/main/java/com/chinaunicom/mall/ebtp/extend/bizmessage/service/impl/BizMessageProducerServiceImpl.java
@@ -171,10 +171,16 @@ public class BizMessageProducerServiceImpl implements BizMessageProducerService
         List<String> magIds = messageList.stream().map(BizMessage::getId).distinct().collect(Collectors.toList());
         Map<String,Integer> map = new HashMap<>();
         if(magIds!=null&&magIds.size()>0) {
-            List<String> userIds = new ArrayList<>();
-            userIds.add(userId);
+
+            List<String> userIds = null;
+            if(userId!=null){
+                userIds = new ArrayList<>();
+                userIds.add(userId);
+            }
+
+            List<String> finalUserIds = userIds;
             magIds.forEach(magid->{
-                messageMapper.deleteAuthorizeByServicecdoe(magid,userIds);
+                messageMapper.deleteAuthorizeByServicecdoe(magid, finalUserIds);
             });
         }
         return true;