添加消息发送系统

portal-manager/src/main/java/com/mortals/xhx/thread/AlarmSendMsgThread.java

@@ -20,6 +20,7 @@ import lombok.extern.slf4j.Slf4j;
 import org.springframework.amqp.rabbit.connection.CorrelationData;
 import org.springframework.amqp.rabbit.core.RabbitTemplate;
 import org.springframework.beans.factory.annotation.Value;
+import org.springframework.util.ObjectUtils;
 
 import java.util.Date;
 import java.util.List;
@@ -68,7 +69,14 @@ public class AlarmSendMsgThread extends AbstractThread {
             SmsThirdPartyReq smsThirdPartyReq = new SmsThirdPartyReq();
             smsThirdPartyReq.setAppid(apiId);
             //模板号
-            smsThirdPartyReq.setType(messageTask.getMessageConfigEntity().getTemplateId() + "");
+
+            if(!ObjectUtils.isEmpty(messageTask.getMessageConfigEntity())){
+                smsThirdPartyReq.setType(messageTask.getMessageConfigEntity().getTemplateId() + "");
+            }else {
+                log.info("短信发送模板号不能为空！");
+                continue;
+            }
+
             smsThirdPartyReq.setAlarmSmsSendId(messageTask.getId());
             smsThirdPartyReq.setPhone(messageTask.getRecipient());
             String[] json = new String[1];