diff --git a/src/main/java/com/eactive/eai/rms/ext/djb/ums/UmsManager.java b/src/main/java/com/eactive/eai/rms/ext/djb/ums/UmsManager.java index 48b7a52..6031247 100644 --- a/src/main/java/com/eactive/eai/rms/ext/djb/ums/UmsManager.java +++ b/src/main/java/com/eactive/eai/rms/ext/djb/ums/UmsManager.java @@ -3,6 +3,7 @@ package com.eactive.eai.rms.ext.djb.ums; import java.util.HashMap; import java.util.List; +import org.apache.commons.lang3.StringUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.scheduling.annotation.Async; @@ -43,7 +44,10 @@ public class UmsManager { } for (UserInfo user : users) { - String cleanedPhone = user.getCphnno().replaceAll("[^0-9]", "").trim(); + String cleanedPhone = ""; + if (StringUtils.isNotEmpty(user.getCphnno())) { + cleanedPhone = user.getCphnno().replaceAll("[^0-9]", "").trim(); + } MessageRecipient recipient = MessageRecipient.builder() .userId(user.getUserid()) .username(user.getUsername()) @@ -52,6 +56,7 @@ public class UmsManager { .messengerId(user.getUserid()) .build(); messageHandlerService.publishEvent(messageCode, recipient, params); + } }