独立出来一个发送消息的方法,消息通知功能已经制作完成

master
xm 4 years ago
parent 1c61b4dac8
commit 93ec550c3b

@ -636,18 +636,25 @@ public class FontController {
* *
* *
*/ */
@RequestMapping("sendMessageToOne") @RequestMapping("sendMessageWithNew")
@ResponseBody @ResponseBody
public Msg sendMessageToOne(Message message) throws Exception{ public Msg sendMessageWithNew(Message message) throws Exception{
if(null == message.getUserId()){ if(null == message.getUserId()){
return Msg.fail("消息用户id不能为空"); return Msg.fail("消息用户id不能为空");
} }
if(StringUtils.isBlank(message.getSysFlag())){
return Msg.fail("消息系统标识不能为空");
}
if(StringUtils.isBlank(message.getTitle())){
return Msg.fail("消息标题不能为空");
}
if(StringUtils.isBlank(message.getContent())){ if(StringUtils.isBlank(message.getContent())){
return Msg.fail("消息内容不能为空"); return Msg.fail("消息内容不能为空");
} }
WebSocket wsByUser = WsPool.getWsByUser(message.getUserId().toString()); WsPool.sendMessageToAll(message.getSysFlag() + "_" + message.getUserId(), message.getTitle() + STR_SPLIT + message.getContent() + STR_SPLIT + message.getTypeFlag());
WsPool.sendMessageToUser(wsByUser,message.getContent());
return Msg.success(); return Msg.success();
} }
} }

Loading…
Cancel
Save