REQ-3345: 群聊天消息过滤

This commit is contained in:
yanglin 2025-02-20 16:05:16 +08:00
parent 7e6966865f
commit 2e01f785e2

View File

@ -205,6 +205,7 @@ public class MessageController implements MessageApi {
List<MessageTask.ReceivePerson> receivePersons = new ArrayList<>(requestReceivePersons); List<MessageTask.ReceivePerson> receivePersons = new ArrayList<>(requestReceivePersons);
if (CollectionUtils.isNotEmpty(request.getImReceiveAccounts())) { if (CollectionUtils.isNotEmpty(request.getImReceiveAccounts())) {
for (String account : request.getImReceiveAccounts()) { for (String account : request.getImReceiveAccounts()) {
ensureImAccountNotBlank(account);
receivePersons.add(MessageTask.ReceivePerson.builder() receivePersons.add(MessageTask.ReceivePerson.builder()
.imAccount(account) .imAccount(account)
.build()); .build());
@ -255,6 +256,7 @@ public class MessageController implements MessageApi {
List<MessageTask.ReceivePerson> receivePersons = new ArrayList<>(requestReceivePersons); List<MessageTask.ReceivePerson> receivePersons = new ArrayList<>(requestReceivePersons);
if (CollectionUtils.isNotEmpty(request.getImReceiveAccounts())) { if (CollectionUtils.isNotEmpty(request.getImReceiveAccounts())) {
for (String account : request.getImReceiveAccounts()) { for (String account : request.getImReceiveAccounts()) {
ensureImAccountNotBlank(account);
receivePersons.add(MessageTask.ReceivePerson.builder() receivePersons.add(MessageTask.ReceivePerson.builder()
.imAccount(account) .imAccount(account)
.build()); .build());
@ -274,6 +276,11 @@ public class MessageController implements MessageApi {
return ApiResult.ok(messageTask.getId()); return ApiResult.ok(messageTask.getId());
} }
private void ensureImAccountNotBlank(String imAccount) {
BizAssertions.assertTrue(StringUtils.isNotBlank(imAccount), "接收人IM账号不能为空");
BizAssertions.assertFalse("null".equalsIgnoreCase(imAccount), "接收人IM账号不能为空");
}
@Override @Override
public ApiResult<MessageUpdateResponse> updateMessage(UpdateMessageRequest request) { public ApiResult<MessageUpdateResponse> updateMessage(UpdateMessageRequest request) {
log.info("updateMessage, request={}", request); log.info("updateMessage, request={}", request);