@@ -3,6 +3,7 @@ package com.eactive.eai.rms.ext.djb.ums;
|
|||||||
import java.util.HashMap;
|
import java.util.HashMap;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
|
|
||||||
|
import org.apache.commons.lang3.StringUtils;
|
||||||
import org.slf4j.Logger;
|
import org.slf4j.Logger;
|
||||||
import org.slf4j.LoggerFactory;
|
import org.slf4j.LoggerFactory;
|
||||||
import org.springframework.scheduling.annotation.Async;
|
import org.springframework.scheduling.annotation.Async;
|
||||||
@@ -43,7 +44,10 @@ public class UmsManager {
|
|||||||
}
|
}
|
||||||
|
|
||||||
for (UserInfo user : users) {
|
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()
|
MessageRecipient recipient = MessageRecipient.builder()
|
||||||
.userId(user.getUserid())
|
.userId(user.getUserid())
|
||||||
.username(user.getUsername())
|
.username(user.getUsername())
|
||||||
@@ -52,6 +56,7 @@ public class UmsManager {
|
|||||||
.messengerId(user.getUserid())
|
.messengerId(user.getUserid())
|
||||||
.build();
|
.build();
|
||||||
messageHandlerService.publishEvent(messageCode, recipient, params);
|
messageHandlerService.publishEvent(messageCode, recipient, params);
|
||||||
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user