|
|
@ -64,6 +64,10 @@ public class MessageSWebNoticeQueueReceiver {
|
|
|
|
// 添加消息
|
|
|
|
// 添加消息
|
|
|
|
SysMessage msg = JsonUtilTool.decode(data, SysMessage.class);
|
|
|
|
SysMessage msg = JsonUtilTool.decode(data, SysMessage.class);
|
|
|
|
try {
|
|
|
|
try {
|
|
|
|
|
|
|
|
if (msg!= null &&StringUtils.isBlank(msg.getCreateUser())) {
|
|
|
|
|
|
|
|
ConvertBean.serviceModelInitialize(msg, msg.getMessageSenderNameRdd());
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
msg = sysMessageService.insertSysMessage(msg);
|
|
|
|
msg = sysMessageService.insertSysMessage(msg);
|
|
|
|
|
|
|
|
|
|
|
|
// 添加附件信息
|
|
|
|
// 添加附件信息
|
|
|
@ -90,20 +94,23 @@ public class MessageSWebNoticeQueueReceiver {
|
|
|
|
try {
|
|
|
|
try {
|
|
|
|
userJsonArray = JSON.parseArray(msg.getMessageReceiversId());
|
|
|
|
userJsonArray = JSON.parseArray(msg.getMessageReceiversId());
|
|
|
|
}catch (JSONException e){
|
|
|
|
}catch (JSONException e){
|
|
|
|
LOGGER.error(" JSON转换错误【{0}】:{1}", msg.getMessageReceiversId(), e.getMessage());
|
|
|
|
LOGGER.error("JSON转换错误【{0}】", msg.getMessageReceiversId(), e.getMessage());
|
|
|
|
}
|
|
|
|
}
|
|
|
|
JSONObject userJsonObject;
|
|
|
|
JSONObject userJsonObject;
|
|
|
|
|
|
|
|
|
|
|
|
List<SysRefUserMessage> insertList = new ArrayList<>(userJsonArray.size());
|
|
|
|
List<SysRefUserMessage> insertList = new ArrayList<>(userJsonArray.size());
|
|
|
|
List<String> receiversId = new ArrayList();
|
|
|
|
List<Long> receiversId = new ArrayList<>();
|
|
|
|
List<String> receiversName = new ArrayList();
|
|
|
|
List<String> receiversName = new ArrayList<>();
|
|
|
|
SysRefUserMessage refUserMessage;
|
|
|
|
SysRefUserMessage refUserMessage;
|
|
|
|
|
|
|
|
|
|
|
|
for (Object user : userJsonArray) {
|
|
|
|
for (Object user : userJsonArray) {
|
|
|
|
// 约定格式:[{'id':'111','name':'张三'},{'id':'121','name':'张三2'}]
|
|
|
|
// 约定格式:[{'id':'111','name':'张三'},{'id':'121','name':'张三2'}]
|
|
|
|
userJsonObject = ( JSONObject )user;
|
|
|
|
userJsonObject = ( JSONObject )user;
|
|
|
|
receiversId.add(userJsonObject.get("id").toString());
|
|
|
|
if (userJsonObject.containsKey("id")) {
|
|
|
|
receiversName.add(userJsonObject.get("name").toString());
|
|
|
|
receiversId.add(userJsonObject.getLongValue("id"));
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
if (userJsonObject.containsKey("name")) {
|
|
|
|
|
|
|
|
receiversName.add(userJsonObject.getString("name"));
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
refUserMessage = new SysRefUserMessage();
|
|
|
|
refUserMessage = new SysRefUserMessage();
|
|
|
|
refUserMessage.setMessageId(msg.getId());
|
|
|
|
refUserMessage.setMessageId(msg.getId());
|
|
|
@ -111,8 +118,8 @@ public class MessageSWebNoticeQueueReceiver {
|
|
|
|
refUserMessage.setMessageTitleRdd(msg.getMessageTitle());
|
|
|
|
refUserMessage.setMessageTitleRdd(msg.getMessageTitle());
|
|
|
|
refUserMessage.setMessageTypeRdd(msg.getMessageType());
|
|
|
|
refUserMessage.setMessageTypeRdd(msg.getMessageType());
|
|
|
|
refUserMessage.setMessageSenderNameRdd(msg.getMessageSenderNameRdd());
|
|
|
|
refUserMessage.setMessageSenderNameRdd(msg.getMessageSenderNameRdd());
|
|
|
|
refUserMessage.setReceiverId(Long.parseLong(userJsonObject.get("id").toString()));
|
|
|
|
refUserMessage.setReceiverId(userJsonObject.getLongValue("id"));
|
|
|
|
refUserMessage.setReceiverNameRdd(userJsonObject.get("name").toString());
|
|
|
|
refUserMessage.setReceiverNameRdd(userJsonObject.getString("name"));
|
|
|
|
refUserMessage.setMessageStatus(ImppEnumUtil.MESSAGE_STATUS.UNREAD.getValue());
|
|
|
|
refUserMessage.setMessageStatus(ImppEnumUtil.MESSAGE_STATUS.UNREAD.getValue());
|
|
|
|
refUserMessage.setReceiverTime(TimeTool.getNowTime(true));
|
|
|
|
refUserMessage.setReceiverTime(TimeTool.getNowTime(true));
|
|
|
|
refUserMessage.setIsUrgent(msg.getIsUrgent());
|
|
|
|
refUserMessage.setIsUrgent(msg.getIsUrgent());
|
|
|
|