diff --git a/im-center-server/src/main/java/cn/axzo/im/controller/MessageController.java b/im-center-server/src/main/java/cn/axzo/im/controller/MessageController.java index 960dba4..05eac95 100644 --- a/im-center-server/src/main/java/cn/axzo/im/controller/MessageController.java +++ b/im-center-server/src/main/java/cn/axzo/im/controller/MessageController.java @@ -205,6 +205,7 @@ public class MessageController implements MessageApi { List receivePersons = new ArrayList<>(requestReceivePersons); if (CollectionUtils.isNotEmpty(request.getImReceiveAccounts())) { for (String account : request.getImReceiveAccounts()) { + ensureImAccountNotBlank(account); receivePersons.add(MessageTask.ReceivePerson.builder() .imAccount(account) .build()); @@ -255,6 +256,7 @@ public class MessageController implements MessageApi { List receivePersons = new ArrayList<>(requestReceivePersons); if (CollectionUtils.isNotEmpty(request.getImReceiveAccounts())) { for (String account : request.getImReceiveAccounts()) { + ensureImAccountNotBlank(account); receivePersons.add(MessageTask.ReceivePerson.builder() .imAccount(account) .build()); @@ -274,6 +276,11 @@ public class MessageController implements MessageApi { return ApiResult.ok(messageTask.getId()); } + private void ensureImAccountNotBlank(String imAccount) { + BizAssertions.assertTrue(StringUtils.isNotBlank(imAccount), "接收人IM账号不能为空"); + BizAssertions.assertFalse("null".equalsIgnoreCase(imAccount), "接收人IM账号不能为空"); + } + @Override public ApiResult updateMessage(UpdateMessageRequest request) { log.info("updateMessage, request={}", request);