pushVo 增加判空

core/src/main/java/com/wecloud/im/mq/MqSender.java

@@ -16,6 +16,9 @@ import org.apache.rocketmq.client.producer.SendResult;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 import org.springframework.stereotype.Component;
 
 
+import static com.wecloud.im.ws.ImConstant.PUSH_BODY;
+import static com.wecloud.im.ws.ImConstant.PUSH_TITLE;
+
 /**
 /**
  * @Author wenzhida
  * @Author wenzhida
  * @Date 2022/1/28 11:47
  * @Date 2022/1/28 11:47
@@ -49,6 +52,11 @@ public class MqSender {
     public PushDTO buildPushDto(PushVO pushVO, ImClient imClientReceiver, ImApplication imApplication) {
     public PushDTO buildPushDto(PushVO pushVO, ImClient imClientReceiver, ImApplication imApplication) {
         PushDTO pushDTO = new PushDTO();
         PushDTO pushDTO = new PushDTO();
         MessageDTO messageDTO = new MessageDTO();
         MessageDTO messageDTO = new MessageDTO();
+        if (pushVO == null) {
+            pushVO = new PushVO();
+            pushVO.setTitle(PUSH_TITLE);
+            pushVO.setSubTitle(PUSH_BODY);
+        }
         messageDTO.setTitle(pushVO.getTitle());
         messageDTO.setTitle(pushVO.getTitle());
         messageDTO.setSubTitle(pushVO.getSubTitle());
         messageDTO.setSubTitle(pushVO.getSubTitle());
         messageDTO.setData(pushVO.getData());
         messageDTO.setData(pushVO.getData());