add-修改send

black-list/black-list-service/src/main/java/cn/axzo/nanopart/server/mq/producer/BlackProducer.java

@@ -52,8 +52,13 @@ public class BlackProducer implements InitializingBean {
     }
 
     public static void send(MQEventEnum mqEventEnum, String data) {
+        if(mqEventEnum == null){
+            throw new ServiceException("无法正确发送mq: mqEventEnum不能为空");
+        }
         //生产消息
         eventProducer.send(Event.builder()
+                .shardingKey("0")
+                .targetId("0")
                 .targetType(mqEventEnum.getModel())
                 .eventCode(mqEventEnum.getEventCode())
                 .eventModule(mqEventEnum.getModel())