publish 1.0.17

springboot-web/src/main/java/com/tiesheng/core/service/CoreMessageService.java

@@ -28,10 +28,38 @@ public class CoreMessageService {
     CoreLogMessageMapper coreLogMessageMapper;
 
 
+    /**
+     * 插入数据
+     *
+     * @param reqResp
+     */
+    private void insertMessageLog(MessageReqResp reqResp) {
+        if (reqResp == null) {
+            return;
+        }
+        coreLogMessageMapper.insert(BeanUtil.copyProperties(reqResp, CoreLogMessage.class));
+    }
+
+    /**
+     * 发送所有消息
+     *
+     * @param userIds
+     * @param body
+     */
+    public void all(List<String> userIds, JSONObject body) {
+        messageSenderList.stream().filter(TieshengMessageSender::support)
+                .forEach(sender -> {
+                    for (String user : userIds) {
+                        insertMessageLog(sender.send(user, body));
+                    }
+                });
+    }
+
+
     /**
      * 发送消息
      *
-     * @param title
+     * @param channels
      * @param body
      * @param channels 消息通道，如果为all时，表示发送全部通道
      */
@@ -41,12 +69,8 @@ public class CoreMessageService {
         }
 
         messageSenderList.stream().filter(TieshengMessageSender::support)
-                .forEach(sender -> {
-                    channels.stream().filter(it -> Objects.equals(it.getChannel(), sender.getChannel())).forEach(it -> {
-                        MessageReqResp reqResp = sender.send(it.getUser(), body);
-                        coreLogMessageMapper.insert(BeanUtil.copyProperties(reqResp, CoreLogMessage.class));
-                    });
-                });
+                .forEach(sender -> channels.stream().filter(it -> Objects.equals(it.getChannel(), sender.getChannel()))
+                        .forEach(it -> insertMessageLog(sender.send(it.getUser(), body))));
     }
 
 
@@ -54,7 +78,6 @@ public class CoreMessageService {
      * 发送消息
      *
      * @param userChannel
-     * @param title
      * @param body
      */
     public MessageReqResp send(UserChannel userChannel, JSONObject body) {
@@ -67,7 +90,7 @@ public class CoreMessageService {
                 sender -> Objects.equals(sender.getChannel(), userChannel.getChannel()) && sender.support());
         if (messageSender != null) {
             MessageReqResp reqResp = messageSender.send(userChannel.getUser(), body);
-            coreLogMessageMapper.insert(BeanUtil.copyProperties(reqResp, CoreLogMessage.class));
+            insertMessageLog(reqResp);
             return reqResp;
         }
         return null;