publish 0.9.5
This commit is contained in:
@@ -40,7 +40,8 @@ public class CoreMessageService {
|
||||
}
|
||||
|
||||
messageSenderList.forEach(sender -> {
|
||||
if (ArrayUtil.contains(channels, sender.getChannel()) || ArrayUtil.contains(channels, "all")) {
|
||||
boolean isChannel = ArrayUtil.contains(channels, sender.getChannel()) || ArrayUtil.contains(channels, "all");
|
||||
if (sender.support() && isChannel) {
|
||||
MessageReqResp reqResp = sender.send(user, title, body);
|
||||
coreLogMessageMapper.insert(BeanUtil.copyProperties(reqResp, CoreLogMessage.class));
|
||||
}
|
||||
@@ -61,7 +62,7 @@ public class CoreMessageService {
|
||||
}
|
||||
|
||||
TieshengMessageSender messageSender = CollUtil.findOne(messageSenderList,
|
||||
sender -> Objects.equals(sender.getChannel(), channel));
|
||||
sender -> Objects.equals(sender.getChannel(), channel) && sender.support());
|
||||
if (messageSender != null) {
|
||||
MessageReqResp reqResp = messageSender.send(user, title, body);
|
||||
coreLogMessageMapper.insert(BeanUtil.copyProperties(reqResp, CoreLogMessage.class));
|
||||
|
||||
Reference in New Issue
Block a user