fix群发消息异常重试

mec-biz/src/main/java/com/ym/mec/biz/service/impl/SysMessageServiceImpl.java

@@ -327,9 +327,9 @@ public class SysMessageServiceImpl extends BaseServiceImpl<Long, SysMessage> imp
 		//ExecutorService executor = Executors.newCachedThreadPool();
 		CompletableFuture.runAsync(()->{
 			Object ret;
-			int maxRetry = 3;
+			int maxRetry = 5;
 			do {
-				// 若发送失败，重试3次后放弃
+				// 若发送失败，重试5次后放弃
 				ret = imFeignService.groupSend(imMessageDto);
 				LOGGER.info("sendGroupMessage groupSend retry={}, ret={}", maxRetry, JSON.toJSONString(ret));
 			} while (ret == null && maxRetry-- > 0);
@@ -339,7 +339,15 @@ public class SysMessageServiceImpl extends BaseServiceImpl<Long, SysMessage> imp
 
     public void sendImMessage(ImMessageDto imMessageDto){
 		LOGGER.info("sendImMessage privateSend ret={}", JSON.toJSONString(imMessageDto));
-        CompletableFuture.runAsync(()-> imFeignService.privateSend(imMessageDto));
+        CompletableFuture.runAsync(()-> {
+			Object ret;
+			int maxRetry = 5;
+			do {
+				// 若发送失败，重试5次后放弃
+				ret = imFeignService.privateSend(imMessageDto);
+				LOGGER.info("sendGroupMessage groupSend retry={}, ret={}", maxRetry, JSON.toJSONString(ret));
+			} while (ret == null && maxRetry-- > 0);
+		});
     }
 
 	@Override