|
@@ -291,6 +291,7 @@ public class SysMessageServiceImpl extends BaseServiceImpl<Long, SysMessage> imp
|
|
|
|
|
|
@Override
|
|
|
public void batchSendImGroupImgMessage(ImSendGroupMessage messageDto) throws Exception {
|
|
|
+ LOGGER.info("batchSendImGroupImgMessage messageDto={}", messageDto);
|
|
|
URL url = new URL(messageDto.getFileUrl());
|
|
|
BufferedImage bufferedImage = Thumbnails.of(url).scale(0.1f).outputQuality(0.25f).asBufferedImage();
|
|
|
ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
|
|
@@ -322,6 +323,7 @@ public class SysMessageServiceImpl extends BaseServiceImpl<Long, SysMessage> imp
|
|
|
}
|
|
|
|
|
|
public void sendGroupMessage(ImMessageDto imMessageDto){
|
|
|
+ LOGGER.info("sendGroupMessage groupSend ret={}", imMessageDto);
|
|
|
//ExecutorService executor = Executors.newCachedThreadPool();
|
|
|
CompletableFuture.runAsync(()->{
|
|
|
imFeignService.groupSend(imMessageDto);
|
|
@@ -330,6 +332,7 @@ public class SysMessageServiceImpl extends BaseServiceImpl<Long, SysMessage> imp
|
|
|
|
|
|
|
|
|
public void sendImMessage(ImMessageDto imMessageDto){
|
|
|
+ LOGGER.info("sendImMessage privateSend ret={}", imMessageDto);
|
|
|
CompletableFuture.runAsync(()-> imFeignService.privateSend(imMessageDto));
|
|
|
}
|
|
|
|