This commit is contained in:
2026-03-02 16:47:27 +08:00
parent 1910b27a98
commit 61217fd463
@@ -167,6 +167,7 @@ public class MsgNotifyController {
dao.insert(msgNotify); dao.insert(msgNotify);
List<MsgNotifyUser> msgNotifyUsers = new ArrayList<>();
MsgNotifyUser msgNotifyUser = new MsgNotifyUser(); MsgNotifyUser msgNotifyUser = new MsgNotifyUser();
msgNotifyUser.setSendUser(ShiroUtil.getUserId()); msgNotifyUser.setSendUser(ShiroUtil.getUserId());
msgNotifyUser.setTitle(msgNotify.getTitle()); msgNotifyUser.setTitle(msgNotify.getTitle());
@@ -187,8 +188,9 @@ public class MsgNotifyController {
} }
msgNotifyUser.setUserId(v.getString("id")); msgNotifyUser.setUserId(v.getString("id"));
msgNotifyUser.setTitleId(msgNotify.getId()); msgNotifyUser.setTitleId(msgNotify.getId());
msgNotifyUsers.add(msgNotifyUser);
}); });
dao.insert(msgNotifyUser); dao.insert(msgNotifyUsers);
} else if (msgNotify.getSendMode().equals("two")) { } else if (msgNotify.getSendMode().equals("two")) {
List<NutMap> userScopes = msgNotifyService.getUserScopes(msgNotify.getActivityGroupId()); List<NutMap> userScopes = msgNotifyService.getUserScopes(msgNotify.getActivityGroupId());
@@ -203,8 +205,9 @@ public class MsgNotifyController {
} }
msgNotifyUser.setUserId(v.getString("id")); msgNotifyUser.setUserId(v.getString("id"));
msgNotifyUser.setTitleId(msgNotify.getId()); msgNotifyUser.setTitleId(msgNotify.getId());
msgNotifyUsers.add(msgNotifyUser);
}); });
dao.insert(msgNotifyUser); dao.insert(msgNotifyUsers);
} else if (msgNotify.getSendMode().equals("three")) { } else if (msgNotify.getSendMode().equals("three")) {
if (flag) { if (flag) {
List<User> user = dao.query(User.class, Cnd.where("id", "in", users)); List<User> user = dao.query(User.class, Cnd.where("id", "in", users));
@@ -218,8 +221,9 @@ public class MsgNotifyController {
} }
msgNotifyUser.setUserId(u); msgNotifyUser.setUserId(u);
msgNotifyUser.setTitleId(msgNotify.getId()); msgNotifyUser.setTitleId(msgNotify.getId());
msgNotifyUsers.add(msgNotifyUser);
} }
dao.insert(msgNotifyUser); dao.insert(msgNotifyUsers);
} else if (msgNotify.getSendMode().equals("four")) { } else if (msgNotify.getSendMode().equals("four")) {
if (StrUtil.isNotBlank(existsLoginNameRedisKey)) { if (StrUtil.isNotBlank(existsLoginNameRedisKey)) {
List<String> loginNames = redisService.lrange(existsLoginNameRedisKey, 0, -1); List<String> loginNames = redisService.lrange(existsLoginNameRedisKey, 0, -1);
@@ -232,9 +236,9 @@ public class MsgNotifyController {
msgNotifyUser.setUserId(u.getId()); msgNotifyUser.setUserId(u.getId());
msgNotifyUser.setTitleId(msgNotify.getId()); msgNotifyUser.setTitleId(msgNotify.getId());
msgNotifyUser.setSendTime(DateUtil.getDateTime()); msgNotifyUser.setSendTime(DateUtil.getDateTime());
msgNotifyUsers.add(msgNotifyUser);
} }
dao.insert(msgNotifyUser); dao.insert(msgNotifyUsers);
} }
} }
dao.update(msgNotify); dao.update(msgNotify);