|
|
@ -4,6 +4,7 @@ import cn.estsh.i3plus.core.api.iservice.busi.IPersonnelService;
|
|
|
|
import cn.estsh.i3plus.core.api.iservice.busi.ISysMessageService;
|
|
|
|
import cn.estsh.i3plus.core.api.iservice.busi.ISysMessageService;
|
|
|
|
import cn.estsh.i3plus.core.api.iservice.busi.ISysUserService;
|
|
|
|
import cn.estsh.i3plus.core.api.iservice.busi.ISysUserService;
|
|
|
|
import cn.estsh.i3plus.core.apiservice.websocket.MessageWebSocket;
|
|
|
|
import cn.estsh.i3plus.core.apiservice.websocket.MessageWebSocket;
|
|
|
|
|
|
|
|
import cn.estsh.i3plus.platform.common.convert.ConvertBean;
|
|
|
|
import cn.estsh.i3plus.platform.common.tool.JsonUtilTool;
|
|
|
|
import cn.estsh.i3plus.platform.common.tool.JsonUtilTool;
|
|
|
|
import cn.estsh.i3plus.platform.common.tool.StringTool;
|
|
|
|
import cn.estsh.i3plus.platform.common.tool.StringTool;
|
|
|
|
import cn.estsh.i3plus.platform.common.tool.TimeTool;
|
|
|
|
import cn.estsh.i3plus.platform.common.tool.TimeTool;
|
|
|
@ -68,6 +69,7 @@ public class MessageLetterQueueReceiver {
|
|
|
|
LOGGER.info("【MQ-{}】 数据接收成功:{}", PlatformConstWords.IMPP_MESSAGE_LETTER_QUEUE, data);
|
|
|
|
LOGGER.info("【MQ-{}】 数据接收成功:{}", PlatformConstWords.IMPP_MESSAGE_LETTER_QUEUE, data);
|
|
|
|
SysMessage msg = JsonUtilTool.decode(data, SysMessage.class);
|
|
|
|
SysMessage msg = JsonUtilTool.decode(data, SysMessage.class);
|
|
|
|
try {
|
|
|
|
try {
|
|
|
|
|
|
|
|
ConvertBean.serviceModelInitialize(msg, "system");
|
|
|
|
msg = sysMessageService.insertSysMessage(msg);
|
|
|
|
msg = sysMessageService.insertSysMessage(msg);
|
|
|
|
|
|
|
|
|
|
|
|
if (!StringUtils.isBlank(msg.getMessageReceiversId())) {
|
|
|
|
if (!StringUtils.isBlank(msg.getMessageReceiversId())) {
|
|
|
@ -92,6 +94,7 @@ public class MessageLetterQueueReceiver {
|
|
|
|
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());
|
|
|
|
|
|
|
|
ConvertBean.serviceModelInitialize(refUserMessage, "system");
|
|
|
|
|
|
|
|
|
|
|
|
insertList.add(refUserMessage);
|
|
|
|
insertList.add(refUserMessage);
|
|
|
|
}
|
|
|
|
}
|
|
|
|