|
|
@@ -140,12 +140,16 @@ public class WebSocketProcess implements ApplicationContextAware {
|
|
|
if (blackList.contains(websocketVo.getReceiverId())) {
|
|
|
lifeMessage.setDeletePhoneId(websocketVo.getReceiverId());
|
|
|
lifeMessageMapper.insert(lifeMessage);
|
|
|
+ // 发送消息
|
|
|
+ websocketVo.setMessageId(lifeMessage.getId());
|
|
|
+ websocketVo.setCategory("message");
|
|
|
+ websocketVo.setCreatedTime(lifeMessage.getCreatedTime());
|
|
|
+ sendMessage(websocketVo.getSenderId(), JSONObject.from(websocketVo).toJSONString());
|
|
|
return;
|
|
|
}
|
|
|
- } else {
|
|
|
- lifeMessageMapper.insert(lifeMessage);
|
|
|
}
|
|
|
|
|
|
+ lifeMessageMapper.insert(lifeMessage);
|
|
|
// 发送消息
|
|
|
websocketVo.setMessageId(lifeMessage.getId());
|
|
|
websocketVo.setCategory("message");
|