|
@@ -107,16 +107,16 @@ public class SysMessageServiceImpl extends BaseServiceImpl<Long, SysMessage> imp
|
|
|
* @param group 消息组
|
|
|
* @return
|
|
|
*/
|
|
|
- private int addMessage(Map<Integer, String> receivers, String subject, String content, Date triggerTime, MessageSendMode mode, SendStatusEnum status,
|
|
|
+ private int addMessage(Map<Long, String> receivers, String subject, String content, Date triggerTime, MessageSendMode mode, SendStatusEnum status,
|
|
|
String errorMsg, Integer readStatus, String memo, String group,String jpushType) {
|
|
|
SysMessage message = null;
|
|
|
Date date = new Date();
|
|
|
|
|
|
List<SysMessage> messages = new ArrayList<>();
|
|
|
|
|
|
- Integer userId = null;
|
|
|
+ Long userId = null;
|
|
|
String receiver;
|
|
|
- for (Entry<Integer, String> entry : receivers.entrySet()) {
|
|
|
+ for (Entry<Long, String> entry : receivers.entrySet()) {
|
|
|
userId = entry.getKey();
|
|
|
receiver = entry.getValue();
|
|
|
|
|
@@ -156,7 +156,7 @@ public class SysMessageServiceImpl extends BaseServiceImpl<Long, SysMessage> imp
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
- public boolean batchSeoMessage(Set<Integer> userIds, MessageTypeEnum messageType,String memo, Object... args) {
|
|
|
+ public boolean batchSeoMessage(Set<Long> userIds, MessageTypeEnum messageType,String memo, Object... args) {
|
|
|
if(userIds != null){
|
|
|
userIds.removeAll(Collections.singleton(null));
|
|
|
}
|
|
@@ -176,7 +176,7 @@ public class SysMessageServiceImpl extends BaseServiceImpl<Long, SysMessage> imp
|
|
|
SysMessage message = null;
|
|
|
|
|
|
List<SysMessage> messages = new ArrayList<>();
|
|
|
- for (Integer userId : userIds) {
|
|
|
+ for (Long userId : userIds) {
|
|
|
message = new SysMessage();
|
|
|
message.setUserId(userId);
|
|
|
message.setContent(content);
|
|
@@ -197,14 +197,14 @@ public class SysMessageServiceImpl extends BaseServiceImpl<Long, SysMessage> imp
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
- public void batchSendMessage(MessageSender messageSender, MessageTypeEnum type, Map<Integer, String> receivers, Date triggerTime, Integer readStatus,
|
|
|
+ public void batchSendMessage(MessageSender messageSender, MessageTypeEnum type, Map<Long, String> receivers, Date triggerTime, Integer readStatus,
|
|
|
String url,String jpushType, Object... args) {
|
|
|
LOGGER.info("batchSendMessage msgSender {}, type {}, receivers {} ", messageSender, type, receivers);
|
|
|
if (receivers == null || receivers.size() == 0) {
|
|
|
LOGGER.error("接收地址不能为空");
|
|
|
return;
|
|
|
}
|
|
|
- Integer userId = receivers.keySet().iterator().next();
|
|
|
+ Long userId = receivers.keySet().iterator().next();
|
|
|
|
|
|
String[] tos = receivers.values().toArray(new String[receivers.size()]);
|
|
|
SysMessageConfig messageConfig = sysMessageConfigService.queryByType(type);
|
|
@@ -245,7 +245,7 @@ public class SysMessageServiceImpl extends BaseServiceImpl<Long, SysMessage> imp
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
- public void batchPushMessage(MessageTypeEnum type, Map<Integer, String> receivers, Date triggerTime, Integer readStatus,
|
|
|
+ public void batchPushMessage(MessageTypeEnum type, Map<Long, String> receivers, Date triggerTime, Integer readStatus,
|
|
|
String url,String jpushType,String sound,String channelId, Object... args) {
|
|
|
if (receivers == null || receivers.size() == 0) {
|
|
|
throw new BizException("接收地址不能为空");
|
|
@@ -282,7 +282,7 @@ public class SysMessageServiceImpl extends BaseServiceImpl<Long, SysMessage> imp
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
- public void sendMessage(MessageSender messageSender, Integer userId, String title, String content, String receiver, Date triggerTime, Integer readStatus, String url, String group,String jpushType) {
|
|
|
+ public void sendMessage(MessageSender messageSender, Long userId, String title, String content, String receiver, Date triggerTime, Integer readStatus, String url, String group,String jpushType) {
|
|
|
LOGGER.info("batchSendMessage {}, userId {}, receivers {} ", messageSender, userId, receiver);
|
|
|
if (StringUtils.isBlank(receiver)) {
|
|
|
throw new BizException("接收地址不能为空");
|
|
@@ -313,13 +313,13 @@ public class SysMessageServiceImpl extends BaseServiceImpl<Long, SysMessage> imp
|
|
|
mode = MessageSendMode.EMAIL;
|
|
|
LOGGER.info("发送邮件 {} ");
|
|
|
}
|
|
|
- Map<Integer, String> receivers = new HashMap<Integer, String>();
|
|
|
+ Map<Long, String> receivers = new HashMap<Long, String>();
|
|
|
receivers.put(userId, receiver);
|
|
|
addMessage(receivers, title, content, triggerTime, mode, status, errorMsg, readStatus, url, null,jpushType);
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
- public boolean sendSecurityCode(MessageSender messageSender, Integer userId, MessageTypeEnum messageType, String receiver) {
|
|
|
+ public boolean sendSecurityCode(MessageSender messageSender, Long userId, MessageTypeEnum messageType, String receiver) {
|
|
|
String key1 = getVerificationCode1CacheKey(messageType, receiver);
|
|
|
if (redisCache.get(key1) != null) {
|
|
|
throw new BizException("请勿频繁操作,获取验证码间隔时间为60秒");
|
|
@@ -330,7 +330,7 @@ public class SysMessageServiceImpl extends BaseServiceImpl<Long, SysMessage> imp
|
|
|
if (debugMode == false) {
|
|
|
code = getRandomCode(messageType, receiver);
|
|
|
}
|
|
|
- Map<Integer, String> receivers = new HashMap<>(1);
|
|
|
+ Map<Long, String> receivers = new HashMap<>(1);
|
|
|
receivers.put(userId, receiver);
|
|
|
batchSendMessage(messageSender, messageType, receivers, null, 1, "","", code);
|
|
|
redisCache.put(key, code + "", CODE_EXPIRE);
|
|
@@ -357,7 +357,7 @@ public class SysMessageServiceImpl extends BaseServiceImpl<Long, SysMessage> imp
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
- public Map<String, Integer> queryCountOfUnread(MessageSendMode type, Integer userId, String jpushType, Integer tenantId) {
|
|
|
+ public Map<String, Integer> queryCountOfUnread(MessageSendMode type, Long userId, String jpushType, Integer tenantId) {
|
|
|
List<Mapper> mappers = sysMessageDao.queryCountOfUnread(type, userId, jpushType, tenantId);
|
|
|
|
|
|
Map<String, Integer> map = new HashMap<String, Integer>();
|
|
@@ -396,7 +396,7 @@ public class SysMessageServiceImpl extends BaseServiceImpl<Long, SysMessage> imp
|
|
|
* @return 修改的条数
|
|
|
*/
|
|
|
@Override
|
|
|
- public int updateStatus(Integer userId, int status,String jpushType) {
|
|
|
+ public int updateStatus(Long userId, int status,String jpushType) {
|
|
|
return sysMessageDao.updateStatus(userId, status,jpushType);
|
|
|
}
|
|
|
|