|
@@ -112,17 +112,17 @@ public class MessageServiceImpl implements MessageService {
|
|
|
if (consumerAppExists == null) {
|
|
if (consumerAppExists == null) {
|
|
|
throw new IllegalOperatorException("接收应用不存在");
|
|
throw new IllegalOperatorException("接收应用不存在");
|
|
|
}
|
|
}
|
|
|
|
|
+
|
|
|
|
|
+ // 获取改应用应接收的未读、未发送的需要推送的消息
|
|
|
|
|
+ List<Message> messages = messageDao.findByConsumerAppIdAndIsReadAndIsSentNeedToSend(consumerAppExists.getId(),
|
|
|
|
|
+ Constant.NO, Constant.NO);
|
|
|
|
|
+
|
|
|
|
|
+ Map<String, Object> resultMap = sendMessageByAPI(messages, consumerApp);
|
|
|
|
|
+ resultMap.put("success", "success");
|
|
|
|
|
+ return resultMap;
|
|
|
} else {
|
|
} else {
|
|
|
throw new ParameterMissingException("接收应用信息为空");
|
|
throw new ParameterMissingException("接收应用信息为空");
|
|
|
}
|
|
}
|
|
|
-
|
|
|
|
|
- // 获取改应用应接收的未读、未发送的需要推送的消息
|
|
|
|
|
- List<Message> messages = messageDao.findByConsumerAppIdAndIsReadAndIsSentNeedToSend(consumerAppExists.getId(),
|
|
|
|
|
- Constant.NO, Constant.NO);
|
|
|
|
|
-
|
|
|
|
|
- Map<String, Object> resultMap = sendMessageByAPI(messages, consumerApp);
|
|
|
|
|
- resultMap.put("success", "success");
|
|
|
|
|
- return resultMap;
|
|
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
/**
|