diff --git a/src/main/java/io/v/nutz/zhgh/msgNotify/MsgNotifyController.java b/src/main/java/io/v/nutz/zhgh/msgNotify/MsgNotifyController.java index 1096c83..2ba622f 100644 --- a/src/main/java/io/v/nutz/zhgh/msgNotify/MsgNotifyController.java +++ b/src/main/java/io/v/nutz/zhgh/msgNotify/MsgNotifyController.java @@ -167,6 +167,7 @@ public class MsgNotifyController { dao.insert(msgNotify); + List msgNotifyUsers = new ArrayList<>(); MsgNotifyUser msgNotifyUser = new MsgNotifyUser(); msgNotifyUser.setSendUser(ShiroUtil.getUserId()); msgNotifyUser.setTitle(msgNotify.getTitle()); @@ -187,8 +188,9 @@ public class MsgNotifyController { } msgNotifyUser.setUserId(v.getString("id")); msgNotifyUser.setTitleId(msgNotify.getId()); + msgNotifyUsers.add(msgNotifyUser); }); - dao.insert(msgNotifyUser); + dao.insert(msgNotifyUsers); } else if (msgNotify.getSendMode().equals("two")) { List userScopes = msgNotifyService.getUserScopes(msgNotify.getActivityGroupId()); @@ -203,8 +205,9 @@ public class MsgNotifyController { } msgNotifyUser.setUserId(v.getString("id")); msgNotifyUser.setTitleId(msgNotify.getId()); + msgNotifyUsers.add(msgNotifyUser); }); - dao.insert(msgNotifyUser); + dao.insert(msgNotifyUsers); } else if (msgNotify.getSendMode().equals("three")) { if (flag) { List user = dao.query(User.class, Cnd.where("id", "in", users)); @@ -218,8 +221,9 @@ public class MsgNotifyController { } msgNotifyUser.setUserId(u); msgNotifyUser.setTitleId(msgNotify.getId()); + msgNotifyUsers.add(msgNotifyUser); } - dao.insert(msgNotifyUser); + dao.insert(msgNotifyUsers); } else if (msgNotify.getSendMode().equals("four")) { if (StrUtil.isNotBlank(existsLoginNameRedisKey)) { List loginNames = redisService.lrange(existsLoginNameRedisKey, 0, -1); @@ -232,9 +236,9 @@ public class MsgNotifyController { msgNotifyUser.setUserId(u.getId()); msgNotifyUser.setTitleId(msgNotify.getId()); msgNotifyUser.setSendTime(DateUtil.getDateTime()); + msgNotifyUsers.add(msgNotifyUser); } - dao.insert(msgNotifyUser); - + dao.insert(msgNotifyUsers); } } dao.update(msgNotify);