修改腾讯短信

src/main/java/com/sooka/sponest/event/utils/RemoteApiUtil.java

@@ -70,25 +70,35 @@ public class RemoteApiUtil {
      */
     public void sendMessage(Set<String> phones, String message, String eventCode, String eventName) {
         if (StringUtils.isNotEmpty(phones) && StringUtils.isNotBlank(message)) {
-            RequestAttributes attributes = RequestContextHolder.getRequestAttributes();// 异步之前获取上下文
-            List<CompletableFuture> futures = new ArrayList<>();
-            phones.forEach(item -> {
-                MessageVo messageVo = new MessageVo();
-                messageVo.setPhone(item);
-                messageVo.setStr(message);
-                messageVo.setEventCode(StringUtils.isBlank(eventCode) ? "" : eventCode);
-                messageVo.setEventName(StringUtils.isBlank(eventName) ? "" : eventName);
-                futures.add(CompletableFuture.supplyAsync(() -> {
-                    RequestContextHolder.setRequestAttributes(attributes);
-                    try {
-                        return SpringUtils.getBean(RemoteMessageService.class).sendMessage(messageVo);
-                    } catch (Exception e) {
-                        logger.error(e.getMessage());
-                    }
-                    return null;
-                }));
-            });
-            CompletableFuture.allOf(futures.toArray(new CompletableFuture[0])).join();
+            //腾讯短信
+            MessageVo messageVo = new MessageVo();
+            messageVo.setType("1");
+            messageVo.setPhones(phones.toArray(new String[0]));
+            messageVo.setContent(new String[]{message});
+            messageVo.setEventCode(StringUtils.isBlank(eventCode) ? "" : eventCode);
+            messageVo.setEventName(StringUtils.isBlank(eventName) ? "" : eventName);
+            SpringUtils.getBean(RemoteMessageService.class).sendTxMessage(messageVo);
+
+            //阿里云短信
+//            RequestAttributes attributes = RequestContextHolder.getRequestAttributes();// 异步之前获取上下文
+//            List<CompletableFuture> futures = new ArrayList<>();
+//            phones.forEach(item -> {
+//                MessageVo messageVo = new MessageVo();
+//                messageVo.setPhone(item);
+//                messageVo.setStr(message);
+//                messageVo.setEventCode(StringUtils.isBlank(eventCode) ? "" : eventCode);
+//                messageVo.setEventName(StringUtils.isBlank(eventName) ? "" : eventName);
+//                futures.add(CompletableFuture.supplyAsync(() -> {
+//                    RequestContextHolder.setRequestAttributes(attributes);
+//                    try {
+//                        return SpringUtils.getBean(RemoteMessageService.class).sendMessage(messageVo);
+//                    } catch (Exception e) {
+//                        logger.error(e.getMessage());
+//                    }
+//                    return null;
+//                }));
+//            });
+//            CompletableFuture.allOf(futures.toArray(new CompletableFuture[0])).join();
         }
     }