|
|
@ -95,6 +95,9 @@ public class MessageClient extends BladeController implements IMessageClient{ |
|
|
|
entity.setPusherName(UserCache.getUser(request.getReceiver()).getName()); |
|
|
|
entity.setPusherName(UserCache.getUser(request.getReceiver()).getName()); |
|
|
|
entity.setAccount(request.getReceiver().toString()); |
|
|
|
entity.setAccount(request.getReceiver().toString()); |
|
|
|
entity.setContent(request.getContent()); |
|
|
|
entity.setContent(request.getContent()); |
|
|
|
|
|
|
|
if(Func.isNotEmpty(request.getTenantId())) { |
|
|
|
|
|
|
|
entity.setTenantId(request.getTenantId()); |
|
|
|
|
|
|
|
} |
|
|
|
Assert.isTrue(recordService.saveAndSend(entity),()-> { |
|
|
|
Assert.isTrue(recordService.saveAndSend(entity),()-> { |
|
|
|
throw new ServiceException("消息保存失败!"); |
|
|
|
throw new ServiceException("消息保存失败!"); |
|
|
|
}); |
|
|
|
}); |
|
|
|