diff --git a/portal-manager/src/main/java/com/mortals/xhx/thread/AlarmSendMsgThread.java b/portal-manager/src/main/java/com/mortals/xhx/thread/AlarmSendMsgThread.java index 3a13dd995d5df7b5662bbef8790678ae96e7d193..086ed26796e9e54f3930b3aba3ed3fee0f8ff776 100644 --- a/portal-manager/src/main/java/com/mortals/xhx/thread/AlarmSendMsgThread.java +++ b/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];